---

MessageServicePresence.cc

Go to the documentation of this file.

// ----------------------------------------------------------------------
//
// MessageService Presence.cc
//
// Changes:
//
//   1 - 2/11/07  mf    Added a call to edm::disableAllSigs(&oldset)
//                      to disable signals so that they are all handled 
//                      by the event processor thread
// 

#include "FWCore/MessageService/interface/MessageServicePresence.h"
#include "FWCore/MessageService/interface/MessageLoggerScribe.h"

#include "FWCore/MessageLogger/interface/MessageLoggerQ.h"
#include "FWCore/Utilities/interface/UnixSignalHandlers.h"


using namespace edm::service;


namespace  {
void
  runMessageLoggerScribe()
{
  sigset_t oldset;
  edm::disableAllSigs(&oldset);
  MessageLoggerScribe  m;  
  m.run();
  // explicitly DO NOT reenableSigs(oldset) because -
  // 1) When this terminates, the main thread may not yet have done a join() and we
  //    don't want to handle the sigs at that point in this thread
  // 2) If we re-enable sigs, we will get the entire stack of accumulated ones (if any) 
}
}  // namespace

namespace edm {
namespace service {


MessageServicePresence::MessageServicePresence()
  : Presence()
  , scribe( ( (void) MessageLoggerQ::instance() // ensure Q's static data init'd
            , runMessageLoggerScribe            // start a new thread
          ) ) 
          // Note that scribe, 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. 
{
  //std::cout << "MessageServicePresence ctor\n";
}


MessageServicePresence::~MessageServicePresence()
{
  MessageLoggerQ::MLqEND();
  scribe.join();
}

} // end of namespace service  
} // end of namespace edm  

---