ers::StreamInitializer Class Reference

Inheritance diagram for ers::StreamInitializer:

Collaboration diagram for ers::StreamInitializer:

Public Member Functions
	StreamInitializer (StreamManager &manager)
void	write (const Issue &issue)
Public Member Functions inherited from ers::OutputStream
virtual	~OutputStream ()
	Sends the issue into this stream.

Private Attributes
std::recursive_mutex	m_mutex
StreamManager &	m_manager
bool	m_in_progress

Additional Inherited Members
Protected Member Functions inherited from ers::OutputStream
	OutputStream ()
OutputStream &	chained ()
virtual bool	isNull () const

Detailed Description

Definition at line 115 of file StreamManager.cpp.

Constructor & Destructor Documentation

StreamInitializer()

ers::StreamInitializer::StreamInitializer ( StreamManager & manager )

inline

Definition at line 118 of file StreamManager.cpp.

            : m_manager( manager ),
              m_in_progress( false )
          { ; }

Member Function Documentation

write()

void ers::StreamInitializer::write ( const Issue & issue )

inlinevirtual

Implements ers::OutputStream.

Definition at line 123 of file StreamManager.cpp.

          {
        ers::severity s = issue.severity();
        std::scoped_lock lock( m_mutex );
 
        if ( !m_in_progress ) {
        m_in_progress = true;
            }
        else {
        // The issue is coming from the stream constructor
                // We can't use ERS streams, so print it to std
                if ( s < ers::Warning )
                    std::cout << issue << std::endl;
                else
                    std::cerr << issue << std::endl;
                return ;
            }
 
        if ( m_manager.m_out_streams[s].get() == this ) {
        m_manager.m_out_streams[s] =
            std::shared_ptr<OutputStream>( m_manager.setup_stream( s ) );
        }
        m_manager.report_issue( s, issue );
            m_in_progress = false;
      }

Member Data Documentation

m_in_progress

bool ers::StreamInitializer::m_in_progress

private

Definition at line 152 of file StreamManager.cpp.

m_manager

StreamManager& ers::StreamInitializer::m_manager

private

Definition at line 151 of file StreamManager.cpp.

m_mutex

std::recursive_mutex ers::StreamInitializer::m_mutex

private

Definition at line 150 of file StreamManager.cpp.

---

The documentation for this class was generated from the following file:

• /github/workspace/dunedaq/sourcecode/ers/src/StreamManager.cpp