/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_6_2_7/src/FWCore/MessageLogger/src/MessageSender.cc

Go to the documentation of this file.

#include "FWCore/MessageLogger/interface/MessageSender.h"
#include "FWCore/MessageLogger/interface/MessageLoggerQ.h"
#include "FWCore/MessageLogger/interface/MessageDrop.h"

#define TRACE_DROP
#ifdef TRACE_DROP
#include <iostream>
#endif

// Change log
//
//  1  mf 8/25/08       keeping the error summary information for
//                      LoggedErrorsSummary()
//                      
// 2  mf 11/2/10        Use new moduleContext method of MessageDrop:
//                      see MessageServer/src/MessageLogger.cc change 17.
//                      


using namespace edm;

bool MessageSender::errorSummaryIsBeingKept = false;            // change log 1
bool MessageSender::freshError              = false;
std::map<ErrorSummaryMapKey, unsigned int> MessageSender::errorSummaryMap; 

MessageSender::MessageSender( ELseverityLevel const & sev, 
                              ELstring const & id,
                              bool verbatim, bool suppressed )
: errorobj_p( suppressed ? 0 : new ErrorObj(sev,id,verbatim), ErrorObjDeleter())
{
  //std::cout << "MessageSender ctor; new ErrorObj at: " << errorobj_p << '\n';
}


// This destructor must not be permitted to throw. A
// boost::thread_resoruce_error is thrown at static destruction time,
// if the MessageLogger library is loaded -- even if it is not used.
void MessageSender::ErrorObjDeleter::operator()(ErrorObj * errorObjPtr) {
  if (errorObjPtr == 0) {
    return;
  }
  try 
    {
      //std::cout << "MessageSender dtor; ErrorObj at: " << errorobj_p << '\n';

      // surrender ownership of our ErrorObj, transferring ownership
      // (via the intermediate MessageLoggerQ) to the MessageLoggerScribe
      // that will (a) route the message text to its destination(s)
      // and will then (b) dispose of the ErrorObj
      
      MessageDrop * drop = MessageDrop::instance();
      if (drop) {
        errorObjPtr->setModule(drop->moduleContext());          // change log 
        errorObjPtr->setContext(drop->runEvent);
      } 
#ifdef TRACE_DROP
      if (!drop) std::cerr << "MessageSender::~MessageSender() - Null drop pointer \n";
#endif
                                                                // change log 1
      if ( errorSummaryIsBeingKept && 
           errorObjPtr->xid().severity >= ELwarning ) 
      {                         
        ELextendedID const & xid = errorObjPtr->xid();
        ErrorSummaryMapKey key (xid.id, xid.module, xid.severity);
        ErrorSummaryMapIterator i = errorSummaryMap.find(key);
        if (i != errorSummaryMap.end()) {
          ++(i->second);  // same as ++errorSummaryMap[key]
        } else {
          errorSummaryMap[key] = 1;
        }
        freshError = true;
      }
      
      MessageLoggerQ::MLqLOG(errorObjPtr);
    }
  catch ( ... )
    {
      // nothing to do
      
      // for test that removal of thread-involved static works, 
      // simply throw here, then run in trivial_main in totalview
      // and Next or Step so that the exception would be detected.
      // That test has been done 12/14/07.
    }
}
MessageSender::~MessageSender()
{
}