TrigServicesHelper Class Reference

Helper class to call ITrigEventLoopMgr methods from Python. More...

Collaboration diagram for TrigServicesHelper:

Public Member Functions
	TrigServicesHelper ()=default
	~TrigServicesHelper ()=default
bool	prepareForStart (uint32_t run_number, const std::string &det_mask, const std::string &sor_time, uint32_t lb_number=0, uint32_t beam_type=0, uint32_t beam_energy=0, float toroids_current=20400.0f, float solenoid_current=7730.0f, const std::string &run_type="Physics", uint32_t trigger_type=0, bool recording_enabled=false, const std::string &event_loop_name="HltEventLoopMgr")
	Call prepareForStart on the HltEventLoopMgr.
bool	prepareForRun (const std::string &event_loop_name="HltEventLoopMgr")
	Call prepareForRun on the HltEventLoopMgr.
bool	hltUpdateAfterFork (int worker_id=1, int worker_pid=-1, const std::string &event_loop_name="HltEventLoopMgr")
	Call hltUpdateAfterFork on the HltEventLoopMgr.

Detailed Description

Helper class to call ITrigEventLoopMgr methods from Python.

Definition at line 88 of file TrigServicesHelper.cxx.

Constructor & Destructor Documentation

TrigServicesHelper()

TrigServicesHelper::TrigServicesHelper ( )

default

~TrigServicesHelper()

TrigServicesHelper::~TrigServicesHelper ( )

default

Member Function Documentation

hltUpdateAfterFork()

bool TrigServicesHelper::hltUpdateAfterFork ( int worker_id = 1, int worker_pid = -1, const std::string & event_loop_name = "HltEventLoopMgr" )

inline

Call hltUpdateAfterFork on the HltEventLoopMgr.

This initializes the scheduler and other components that need to be set up after forking. In athenaEF (without PSC), this should be called after prepareForRun() and before running the event loop.

Parameters

worker_id	Worker ID (use 1 for single-process mode without forking)
worker_pid	Worker PID (defaults to current process PID)
event_loop_name	Name of the EventLoopMgr service

Returns

true on success, false on failure

Definition at line 209 of file TrigServicesHelper.cxx.

  {
    // Use current PID if not specified
    if (worker_pid < 0) {
      worker_pid = getpid();
    }
    
    // Get the service locator
    ISvcLocator* svcLoc = Gaudi::svcLocator();
    if (!svcLoc) {
      std::cerr << "TrigServicesHelper: Failed to get ISvcLocator" << std::endl;
      return false;
    }
    
    // Set DataFlow properties via JobOptionsSvc so updateDFProps() can read them
    // HltEventLoopMgr::updateDFProps() reads from "DataFlowConfig.DF_*" properties
    auto jobOptSvc = svcLoc->service<Gaudi::Interfaces::IOptionsSvc>("JobOptionsSvc");
    if (!jobOptSvc) {
      std::cerr << "TrigServicesHelper: Failed to get JobOptionsSvc" << std::endl;
      return false;
    }
    
    // Set worker ID > 0 to avoid mother process behavior in stop()
    jobOptSvc->set("DataFlowConfig.DF_WorkerId", std::to_string(worker_id));
    jobOptSvc->set("DataFlowConfig.DF_Pid", std::to_string(worker_pid));
    jobOptSvc->set("DataFlowConfig.DF_ApplicationName", "athenaEF");
    
    std::cout << "TrigServicesHelper: Set DataFlowConfig properties (WorkerId=" 
              << worker_id << ", Pid=" << worker_pid << ")" << std::endl;
    
    // Build an empty ptree - the actual values are read from JobOptionsSvc
    boost::property_tree::ptree pt;
    
    // Get the EventLoopMgr service
    auto evtLoopMgr = svcLoc->service<ITrigEventLoopMgr>(event_loop_name);
    if (!evtLoopMgr) {
      std::cerr << "TrigServicesHelper: Failed to retrieve ITrigEventLoopMgr '" 
                << event_loop_name << "'" << std::endl;
      return false;
    }
    
    // Call hltUpdateAfterFork
    std::cout << "TrigServicesHelper: Calling hltUpdateAfterFork on " << event_loop_name << std::endl;
    StatusCode sc = evtLoopMgr->hltUpdateAfterFork(pt);
    
    if (sc.isFailure()) {
      std::cerr << "TrigServicesHelper: hltUpdateAfterFork failed" << std::endl;
      return false;
    }
    
    std::cout << "TrigServicesHelper: hltUpdateAfterFork completed successfully" << std::endl;
    return true;
  }

prepareForRun()

bool TrigServicesHelper::prepareForRun ( const std::string & event_loop_name = "HltEventLoopMgr" )

inline

Call prepareForRun on the HltEventLoopMgr.

This initializes the COOL folder helper and fires the BeginRun incident. It must be called after start() and before hltUpdateAfterFork().

Parameters

event_loop_name

Name of the EventLoopMgr service

Returns

true on success, false on failure

Definition at line 164 of file TrigServicesHelper.cxx.

  {
    // Get the service locator
    ISvcLocator* svcLoc = Gaudi::svcLocator();
    if (!svcLoc) {
      std::cerr << "TrigServicesHelper: Failed to get ISvcLocator" << std::endl;
      return false;
    }
 
    // Get the EventLoopMgr service
    auto evtLoopMgr = svcLoc->service<ITrigEventLoopMgr>(event_loop_name);
    if (!evtLoopMgr) {
      std::cerr << "TrigServicesHelper: Failed to retrieve ITrigEventLoopMgr '" 
                << event_loop_name << "'" << std::endl;
      return false;
    }
 
    // Build an empty ptree (prepareForRun doesn't use it currently)
    boost::property_tree::ptree pt;
 
    // Call prepareForRun
    std::cout << "TrigServicesHelper: Calling prepareForRun on " << event_loop_name << std::endl;
    StatusCode sc ATLAS_THREAD_SAFE = evtLoopMgr->prepareForRun(pt);
 
    if (sc.isFailure()) {
      std::cerr << "TrigServicesHelper: prepareForRun failed" << std::endl;
      return false;
    }
 
    std::cout << "TrigServicesHelper: prepareForRun completed successfully" << std::endl;
    return true;
  }

prepareForStart()

bool TrigServicesHelper::prepareForStart ( uint32_t run_number, const std::string & det_mask, const std::string & sor_time, uint32_t lb_number = 0, uint32_t beam_type = 0, uint32_t beam_energy = 0, float toroids_current = 20400.0f, float solenoid_current = 7730.0f, const std::string & run_type = "Physics", uint32_t trigger_type = 0, bool recording_enabled = false, const std::string & event_loop_name = "HltEventLoopMgr" )

inline

Call prepareForStart on the HltEventLoopMgr.

Parameters

run_number	Run number
det_mask	Detector mask (32 hex chars)
sor_time	Start of run time string (format: "dd/mm/yy HH:MM:SS.ffffff")
lb_number	Lumi block number
beam_type	Beam type
beam_energy	Beam energy
toroids_current	Toroids current (default 20400)
solenoid_current	Solenoid current (default 7730)
event_loop_name	Name of the EventLoopMgr service

Returns

true on success, false on failure

Definition at line 107 of file TrigServicesHelper.cxx.

  {
    // Build the ptree directly
    boost::property_tree::ptree pt = buildPrepareForStartPtree(
        run_number, det_mask, sor_time, lb_number,
        beam_type, beam_energy, toroids_current, solenoid_current,
        run_type, trigger_type, recording_enabled);
    
    // Get the service locator
    ISvcLocator* svcLoc = Gaudi::svcLocator();
    if (!svcLoc) {
      std::cerr << "TrigServicesHelper: Failed to get ISvcLocator" << std::endl;
      return false;
    }
    
    // Get the EventLoopMgr service (use template version that returns SmartIF directly)
    auto evtLoopMgr = svcLoc->service<ITrigEventLoopMgr>(event_loop_name);
    if (!evtLoopMgr) {
      std::cerr << "TrigServicesHelper: Failed to retrieve ITrigEventLoopMgr '" 
                << event_loop_name << "'" << std::endl;
      return false;
    }
    
    // Call prepareForStart
    std::cout << "TrigServicesHelper: Calling prepareForStart on " << event_loop_name << std::endl;
    StatusCode sc = evtLoopMgr->prepareForStart(pt);
    
    if (sc.isFailure()) {
      std::cerr << "TrigServicesHelper: prepareForStart failed" << std::endl;
      return false;
    }
    
    std::cout << "TrigServicesHelper: prepareForStart completed successfully" << std::endl;
    return true;
  }

---

The documentation for this class was generated from the following file:

• TrigServicesHelper.cxx