PrecedenceSvc.h

Go to the documentation of this file.

/***********************************************************************************\
* (c) Copyright 1998-2026 CERN for the benefit of the LHCb and ATLAS collaborations *
*                                                                                   *
* This software is distributed under the terms of the Apache version 2 licence,     *
* copied verbatim in the file "LICENSE".                                            *
*                                                                                   *
* In applying this licence, CERN does not waive the privileges and immunities       *
* granted to it by virtue of its status as an Intergovernmental Organization        *
* or submit itself to any jurisdiction.                                             *
\***********************************************************************************/
#pragma once
 
// Local includes
#include "IPrecedenceSvc.h"
#include "PRGraph/PrecedenceRulesGraph.h"
 
// Framework include
#include <GaudiKernel/IAlgResourcePool.h>
#include <GaudiKernel/Service.h>
 
// STL includes
#include <cstdlib>
#include <filesystem>
#include <unistd.h>

 
class PrecedenceSvc : public extends<Service, IPrecedenceSvc> {
 
public:
  PrecedenceSvc( const std::string& name, ISvcLocator* svcLoc ) : base_class( name, svcLoc ) {}

  StatusCode initialize() override;

  StatusCode finalize() override;

  StatusCode iterate( EventSlot&, const Cause& ) override;

  StatusCode simulate( EventSlot& ) const override;

  bool CFRulesResolved( EventSlot& ) const override;

  uint getPriority( const std::string& name ) const override {
    return (int)m_PRGraph.getAlgorithmNode( name )->getRank();
  }

  bool isAsynchronous( const std::string& name ) const override {
    return m_PRGraph.getAlgorithmNode( name )->isAsynchronous();
  }

  void              dumpControlFlow() const override;
  void              dumpDataFlow() const override;
  const std::string printState( EventSlot& ) const override;

  void dumpPrecedenceRules( const EventSlot& ) override;
  void dumpPrecedenceTrace( const EventSlot& ) override;

  const concurrency::PrecedenceRulesGraph* getRules() const { return &m_PRGraph; }
 
private:
  StatusCode assembleCFRules( Gaudi::Algorithm*, const std::string&, unsigned int recursionDepth = 0 );
 
private:
  SmartIF<IAlgResourcePool> m_algResourcePool;
  concurrency::PrecedenceRulesGraph m_PRGraph{ "PrecedenceRulesGraph", serviceLocator() };
  Gaudi::Property<std::string> m_mode{ this, "TaskPriorityRule", "", "Task avalanche induction strategy." };
  Gaudi::Property<bool> m_ignoreDFRules{ this, "IgnoreDFRules", false, "Ignore the data flow rules." };
  std::filesystem::path        m_dumpDirName;
  Gaudi::Property<bool>        m_dumpPrecTrace{ this, "DumpPrecedenceTrace", false,
                                         "Dump task precedence traces for each event." };
  Gaudi::Property<std::string> m_dumpPrecTraceFile{
      this, "PrecedenceTraceFile", "",
      "Override default name of the GRAPHML trace file. NOTE: if more than "
      "1 event is processed, the setting forces creation of a single file "
      "with cumulative precedence trace." };
  Gaudi::Property<bool>        m_dumpPrecRules{ this, "DumpPrecedenceRules", false, "Dump task precedence rules." };
  Gaudi::Property<std::string> m_dumpPrecRulesFile{ this, "PrecedenceRulesFile", "",
                                                    "Override default name of the GRAPHML precedence rules file." };
  Gaudi::Property<bool>        m_verifyRules{ this, "VerifyTaskPrecedenceRules", true,
                                       "Verify task precedence rules for common errors." };
  Gaudi::Property<bool>        m_showDataFlow{ this, "ShowDataFlow", false,
                                        "Show the configuration of DataFlow between Algorithms" };
};