LocalStream.hpp

Go to the documentation of this file.

/*
 * DUNE DAQ modification notice:
 * This file has been modified from the original ATLAS ers source for the DUNE DAQ project.
 * Fork baseline commit: 8267df82a4f6fe6bf02c4014923eba19eddc4614 (2020-04-14).
 * Renamed since fork: yes (from ers/LocalStream.h to include/ers/LocalStream.hpp).
 *
 * Original copyright:
 * Copyright (C) 2001-2020 CERN for the benefit of the ATLAS collaboration.
 * Licensed under the Apache License, Version 2.0.
 */
 
#ifndef ERS_LOCAL_STREAM_H
#define ERS_LOCAL_STREAM_H
 
/*
 *  LocalStream.h
 *  ers
 *
 *  Created by Serguei Kolos on 21.11.05.
 *  Copyright 2005 CERN. All rights reserved.
 *
 */

 
#include <condition_variable>
#include <functional>
#include <iostream>
#include <mutex>
#include <queue>
#include <thread>
 
#include <ers/Issue.hpp>
#include <ers/IssueCatcherHandler.hpp>
 
ERS_DECLARE_ISSUE(ers,                                        // namespace
                  IssueCatcherAlreadySet,                     // issue class name
                  "Local error catcher has been already set", //
                  ERS_EMPTY                                   // no attributes
)
 
namespace ers {
class Issue;
template<class>
class SingletonCreator;
 
class IssueCatcherHandler;

 
class LocalStream
{
  friend class IssueCatcherHandler;
  template<class>
  friend class SingletonCreator;
 
public:
  static LocalStream& instance();

  IssueCatcherHandler* set_issue_catcher(const std::function<void(const ers::Issue&)>& catcher);
 
  void error(const ers::Issue& issue);
 
  void fatal(const ers::Issue& issue);
 
  void warning(const ers::Issue& issue);
 
private:
  LocalStream();
  ~LocalStream();
 
  void remove_issue_catcher();
 
  void report_issue(ers::severity type, const ers::Issue& issue);
 
  void thread_wrapper();
 
private:
  std::function<void(const ers::Issue&)> m_issue_catcher;
  std::unique_ptr<std::thread> m_issue_catcher_thread;
  std::mutex m_mutex;
  std::condition_variable m_condition;
  bool m_terminated;
  std::queue<ers::Issue*> m_issues;
  std::thread::id m_catcher_thread_id;
};
}
 
#endif