edm::service::MessageServicePresence Class Reference

#include <MessageServicePresence.h>

Inheritance diagram for edm::service::MessageServicePresence:

Public Member Functions
	MessageServicePresence ()
	~MessageServicePresence ()
Public Member Functions inherited from edm::Presence
	Presence ()
virtual	~Presence ()=0

Private Member Functions
	MessageServicePresence (MessageServicePresence const &)
void	operator= (MessageServicePresence const &)

Private Attributes
std::shared_ptr< ThreadQueue >	m_queue
boost::thread	m_scribeThread

Detailed Description

Definition at line 16 of file MessageServicePresence.h.

Constructor & Destructor Documentation

edm::service::MessageServicePresence::MessageServicePresence

(

)

Definition at line 50 of file MessageServicePresence.cc.

References m_queue, and edm::MessageLoggerQ::setMLscribe_ptr().

  : Presence()
  , m_queue (new ThreadQueue)
  , m_scribeThread
         ( ( (void) MessageLoggerQ::instance() // ensure Q's static data init'd
            , std::bind(&runMessageLoggerScribe, m_queue)
                    // start a new thread, run rMLS(m_queue)
                // ChangeLog 2
          ) ) 
      // Note that m_scribeThread, which is a boost::thread, has a single-argument ctor - 
      // just the function to be run.  But we need to do something first, namely,
      // ensure that the MessageLoggerQ is in a valid state - and that requires
      // a statement.  So we bundle that statement in parenthesis, separated by 
      // a comma, with the argument we really want (runMessageLoggerScribe).  This
      // creates a single argument, wheich evaluates to runMessageLoggerScribe after
      // first executing the before-the-comma statement. 
{
  MessageLoggerQ::setMLscribe_ptr(
    std::shared_ptr<edm::service::AbstractMLscribe>(std::make_shared<MainThreadMLscribe>(m_queue)));
                                    // change log 3
  //std::cout << "MessageServicePresence ctor\n";
}

edm::service::MessageServicePresence::~MessageServicePresence

(

)

Definition at line 74 of file MessageServicePresence.cc.

References m_scribeThread, edm::MessageLoggerQ::MLqEND(), and edm::MessageLoggerQ::setMLscribe_ptr().

{
  MessageLoggerQ::MLqEND();
  m_scribeThread.join();
  MessageLoggerQ::setMLscribe_ptr
    (std::shared_ptr<edm::service::AbstractMLscribe>());   // change log 3
}

edm::service::MessageServicePresence::MessageServicePresence ( MessageServicePresence const &  )

private

Member Function Documentation

void edm::service::MessageServicePresence::operator= ( MessageServicePresence const &  )

private

Member Data Documentation

std::shared_ptr<ThreadQueue> edm::service::MessageServicePresence::m_queue

private

Definition at line 29 of file MessageServicePresence.h.

Referenced by MessageServicePresence().

boost::thread edm::service::MessageServicePresence::m_scribeThread

private

Definition at line 30 of file MessageServicePresence.h.

Referenced by ~MessageServicePresence().