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/Severity.hpp>
#include <ers/Context.hpp>
#include <ers/IssueReceiver.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