#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 > &	queue ()

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

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

boost::thread	m_scribeThread

Detailed Description

Definition at line 16 of file MessageServicePresence.h.

Constructor & Destructor Documentation

◆ MessageServicePresence() [1/2]

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

Definition at line 46 of file MessageServicePresence.cc.

         : 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";
     }

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

◆ ~MessageServicePresence()

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

override

Definition at line 69 of file MessageServicePresence.cc.

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