DecisionSvc.cxx File Reference

#include "DecisionSvc.h"
#include "GaudiKernel/EventContext.h"
#include "PersistentDataModel/AthenaAttributeList.h"
#include <algorithm>

Include dependency graph for DecisionSvc.cxx:

Go to the source code of this file.

Functions
StatusCode DecisionSvc::DeclareToCutFlowSvc	ATLAS_NOT_THREAD_SAFE ()
	Install fatal handler with default options. More...

Function Documentation

ATLAS_NOT_THREAD_SAFE()

StatusCode DecisionSvc::DeclareToCutFlowSvc ATLAS_NOT_THREAD_SAFE

(

)

Install fatal handler with default options.

This is meant to be easy to call from python via ctypes.

Definition at line 368 of file DecisionSvc.cxx.

{
  // Declare all decisions to CutFlowSvc for bookkeeping
  
  // Loop over all streams
  for(auto ait  = m_streamNames.begin();
           ait != m_streamNames.end(); ++ait) {
    const std::string &streamName=*ait;
    const std::vector<std::string> *accFilt=nullptr;
    const std::vector<std::string> *reqFilt=nullptr;
    const std::vector<std::string> *vetFilt=nullptr;
    std::vector< const std::vector<std::string>* > totFilt;
    if (auto itr = m_stream_accept.find(streamName); itr != m_stream_accept.end())  {
      accFilt = &itr->second;
      totFilt.push_back(accFilt);
    }
    if (auto itr = m_stream_require.find(streamName); itr != m_stream_require.end()) {
      reqFilt = &itr->second;
      totFilt.push_back(reqFilt);
    }
    if (auto itr = m_stream_veto.find(streamName); itr != m_stream_veto.end())    {
      vetFilt = &itr->second;
      totFilt.push_back(vetFilt);
    }
 
    // Now build logicalKey as string of filt ||, &&, ! based on 
    // whether it is accept, require, veto
    std::string accstring(""), reqstring(""), vetstring("");
    if(accFilt){
       for (auto it = accFilt->begin(); it != accFilt->end(); ++it) {
         if(!accstring.empty()) accstring += "||";
         else accstring += '(';
         accstring+=*it;
       }
    }
    if(reqFilt){
       for (auto it = reqFilt->begin(); it != reqFilt->end(); ++it) {
         if(!reqstring.empty()) reqstring += "&&";
         else reqstring += '(';
         reqstring+=*it;
       }
    }
    if(vetFilt){
       for (auto it = vetFilt->begin(); it != vetFilt->end(); ++it) {
         if(!vetstring.empty()) vetstring += "||";
         else vetstring += '(';
         vetstring+=*it;
       }
    }
    std::string logicalKey("");
    if(!accstring.empty()) {
      accstring += ')';
      logicalKey += accstring;
    }
    if(!reqstring.empty()) {
      reqstring += ')';
      if (!logicalKey.empty()) logicalKey += "&&";
      logicalKey += reqstring;
    }
    if(!vetstring.empty()) {
      vetstring += ')';
      if (!logicalKey.empty()) logicalKey += "&&";
      logicalKey += '!';
      logicalKey += vetstring;
    }
    // If no filters, mark as PasThru
    if (logicalKey.empty()) logicalKey="PassThru";
    ATH_MSG_DEBUG("stream " << streamName << " uses logic " << logicalKey);
 
    // Now actually declare to the cutflowsvc
    for(auto vec  = totFilt.begin();
             vec != totFilt.end(); ++vec) {
      ATH_MSG_DEBUG("Declaring logic " << logicalKey << " for " << streamName);
      for (auto filter  = (*vec)->begin();
                filter != (*vec)->end(); ++filter) {
        if(!m_cutflowSvc.empty()) {m_cutflowSvc->registerTopFilter( (*filter), logicalKey, 2, streamName, true ); } // TODO: validate
      }
    }
  }
 
  return StatusCode::SUCCESS;
}