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 <queue>
#include <mutex>
#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