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 106 of file StreamManager.cpp.

Constructor & Destructor Documentation

StreamInitializer()

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

inline

Definition at line 109 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 116 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 143 of file StreamManager.cpp.

m_manager

StreamManager& ers::StreamInitializer::m_manager

private

Definition at line 142 of file StreamManager.cpp.

m_mutex

std::recursive_mutex ers::StreamInitializer::m_mutex

private

Definition at line 141 of file StreamManager.cpp.

---

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

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