edm::MessageSender::ErrorObjDeleter Struct Reference

Public Member Functions
	ErrorObjDeleter ()
void	operator() (ErrorObj *errorObjPtr)

Detailed Description

Definition at line 26 of file MessageSender.h.

Constructor & Destructor Documentation

edm::MessageSender::ErrorObjDeleter::ErrorObjDeleter ( )

inline

Definition at line 27 of file MessageSender.h.

References operator()().

{}

Member Function Documentation

void MessageSender::ErrorObjDeleter::operator()

(

ErrorObj *

errorObjPtr

)

Definition at line 93 of file MessageSender.cc.

References MessageLogger_cfi::cerr, drop, edm::ELwarning, errorSummaryIsBeingKept, errorSummaryMaps, mps_fire::i, edm::ELextendedID::id, edm::MessageDrop::instance(), crabWrapper::key, SiStripPI::max, edm::MessageLoggerQ::MLqLOG(), edm::ELextendedID::module, edm::MessageDrop::moduleContext(), edm::MessageDrop::runEvent, edm::ErrorObj::setContext(), edm::ErrorObj::setModule(), edm::ELextendedID::severity, edm::MessageDrop::streamID, and edm::ErrorObj::xid().

Referenced by ErrorObjDeleter().

                                                                   {
  if (errorObjPtr == nullptr) {
    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.load(std::memory_order_acquire) && errorObjPtr->xid().severity >= ELwarning && drop &&
        drop->streamID < std::numeric_limits<unsigned int>::max()) {
      auto& errorSummaryMap = errorSummaryMaps[drop->streamID];

      ELextendedID const& xid = errorObjPtr->xid();
      ErrorSummaryMapKey key{xid.id, xid.module, xid.severity};
      auto i = errorSummaryMap.find(key);
      if (i != errorSummaryMap.end()) {
        i->second.value().fetch_add(1, std::memory_order_acq_rel);  // same as ++errorSummaryMap[key]
      } else {
        errorSummaryMap[key].value().store(1, std::memory_order_release);
      }
    }

    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.
  }
}