LocalStream.hpp File Reference

#include <condition_variable>
#include <functional>
#include <iostream>
#include <queue>
#include <mutex>
#include <thread>
#include <ers/Issue.hpp>
#include <ers/IssueCatcherHandler.hpp>

Include dependency graph for LocalStream.hpp:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
	ERS_DECLARE_ISSUE (ers, IssueCatcherAlreadySet, "Local error catcher has been already set", ERS_EMPTY) namespace ers

Function Documentation

ERS_DECLARE_ISSUE()

ERS_DECLARE_ISSUE	(	ers	,
		IssueCatcherAlreadySet	,
		"Local error catcher has been already set"	,
		ERS_EMPTY	)

The LocalStream class can be used for passing issues between threads of the same process.

Author

Serguei Kolos

Version

1.2

returns the singleton

sets local issue catcher

Definition at line 28 of file LocalStream.hpp.

{    
    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;
    };
}