StreamManager.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/StreamManager.h to include/ers/StreamManager.hpp).
 *
 * Original copyright:
 * Copyright (C) 2001-2020 CERN for the benefit of the ATLAS collaboration.
 * Licensed under the Apache License, Version 2.0.
 */
 
/*
 *  StreamManager.h
 *  ers
 *
 *  Created by Serguei Kolos on 21.11.05.
 *  Copyright 2005 CERN. All rights reserved.
 *
 */
 
#ifndef ERS_STREAM_MANAGER_H
#define ERS_STREAM_MANAGER_H
 
#include <initializer_list>
 
#include <memory>
#include <mutex>
 
#include <ers/Context.hpp>
#include <ers/IssueReceiver.hpp>
#include <ers/Severity.hpp>
#include <ers/StreamFactory.hpp>
#include <ers/internal/PluginManager.hpp>
 
#include <list>

namespace ers {
class InputStream;
class LocalStream;
class OutputStream;
class ErrorHandler;
class Issue;
class StreamInitializer;
template<class>
class SingletonCreator;

 
class StreamManager
{
  friend class StreamInitializer;
  friend class ers::LocalStream;
  friend class ers::ErrorHandler;
  template<class>
  friend class SingletonCreator;
 
public:
  ~StreamManager();
 
  static StreamManager& instance(); 
 
  void debug(const Issue& issue, int level); 
 
  void error(const Issue& issue); 
 
  void fatal(const Issue& issue); 
 
  void information(const Issue& issue); 
 
  void log(const Issue& issue); 
 
  void warning(const Issue& issue); 
 
  void add_receiver(const std::string& stream, const std::string& filter, ers::IssueReceiver* receiver);
 
  void add_receiver(const std::string& stream,
                    const std::initializer_list<std::string>& params,
                    ers::IssueReceiver* receiver);
 
  void remove_receiver(ers::IssueReceiver* receiver);
 
  void add_output_stream(ers::severity severity, ers::OutputStream* new_stream);
 
  void report_issue(ers::severity type, const Issue& issue);
 
private:
  StreamManager();
 
  OutputStream* setup_stream(ers::severity severity);
  OutputStream* setup_stream(const std::vector<std::string>& streams);
 
  PluginManager m_plugin_manager;
  std::mutex m_mutex;
  std::list<std::shared_ptr<InputStream>> m_in_streams;
  std::shared_ptr<OutputStream> m_init_streams[ers::Fatal + 1]; 
  std::shared_ptr<OutputStream> m_out_streams[ers::Fatal + 1];  
};
 
std::ostream&
operator<<(std::ostream&, const ers::StreamManager&);
}
 
#endif