#include <MessageServicePresence.h>

Inheritance diagram for edm::service::MessageServicePresence:

Public Member Functions
	MessageServicePresence ()

	~MessageServicePresence () override

Public Member Functions inherited from edm::Presence
	Presence ()

virtual	~Presence ()=0

Private Member Functions
	MessageServicePresence (MessageServicePresence const &)=delete

void	operator= (MessageServicePresence const &)=delete

std::shared_ptr< ThreadQueue const >	queue () const

std::shared_ptr< ThreadQueue > &	queue ()

Private Attributes
edm::propagate_const< std::shared_ptr< ThreadQueue > >	m_queue

boost::thread	m_scribeThread

Detailed Description

Definition at line 17 of file MessageServicePresence.h.

Constructor & Destructor Documentation

edm::service::MessageServicePresence::MessageServicePresence ( )

Definition at line 50 of file MessageServicePresence.cc.

References 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, 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>(queue())));
                                     // change log 3
   //std::cout << "MessageServicePresence ctor\n";
 }

edm::service::MessageServicePresence::~MessageServicePresence ( )

override

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
 }