AthXRT::StateHandler Class Reference

Base class to provide common infrastructure for handling multiprocess state transitions for FPGA. Based on CaloRecGPU/CaloGPUCUDAInitialization.h. More...

#include <StateHandler.h>

Inheritance diagram for AthXRT::StateHandler:

Collaboration diagram for AthXRT::StateHandler:

Public Member Functions
void	handle (const Incident &incident) override
virtual	~StateHandler ()=default

Protected Member Functions
virtual StatusCode	initialize_global ()
	Glocal XRT initialization. More...
virtual StatusCode	initialize_worker ()
	Initialization per process. More...
virtual StatusCode	stop_worker ()
	clean up More...
virtual StatusCode	initialize ()
virtual StatusCode	stop ()

Protected Attributes
bool	m_is_child = false

Detailed Description

Base class to provide common infrastructure for handling multiprocess state transitions for FPGA. Based on CaloRecGPU/CaloGPUCUDAInitialization.h.

Definition at line 26 of file StateHandler.h.

Constructor & Destructor Documentation

~StateHandler()

virtual AthXRT::StateHandler::~StateHandler ( )

virtualdefault

Member Function Documentation

handle()

void AthXRT::StateHandler::handle ( const Incident &  incident )

inlineoverride

Definition at line 85 of file StateHandler.h.

  {
    const bool is_multiprocess = (Gaudi::Concurrency::ConcurrencyFlags::numProcs() > 0);
    if (is_multiprocess && incident.type() == AthenaInterprocess::UpdateAfterFork::type())
      {
    m_is_child = true;
        if (!this->initialize_worker().isSuccess())
        {
          throw GaudiException("Failed to initialize the XRT setup!",
                               "StateHandler::handle",
                               StatusCode::FAILURE);
        }
      }
  }

initialize()

virtual StatusCode AthXRT::StateHandler::initialize ( )

inlineprotectedvirtual

Reimplemented in AthExXRT::VectorAddXRTExampleAlg, AthExXRT::VectorMultXRTExampleAlg, AthExXRT::VectorAddOCLExampleAlg, and AthExXRT::VectorMultOCLExampleAlg.

Definition at line 48 of file StateHandler.h.

  {
    ATH_CHECK(this->initialize_global());
 
    const bool is_multiprocess = (Gaudi::Concurrency::ConcurrencyFlags::numProcs() > 0);
 
    if (is_multiprocess)
      {
        ServiceHandle<IIncidentSvc> incidentSvc("IncidentSvc","StateHandler");
        incidentSvc->addListener(this, AthenaInterprocess::UpdateAfterFork::type());
      }
    else
      {
        ATH_CHECK(this->initialize_worker());
      }
 
    return StatusCode::SUCCESS;
  }

initialize_global()

virtual StatusCode AthXRT::StateHandler::initialize_global ( )

inlineprotectedvirtual

Glocal XRT initialization.

Reimplemented in AthExXRT::VectorAddXRTExampleAlg, AthExXRT::VectorMultXRTExampleAlg, AthExXRT::VectorAddOCLExampleAlg, and AthExXRT::VectorMultOCLExampleAlg.

Definition at line 31 of file StateHandler.h.

  {
    return StatusCode::SUCCESS;
  }

initialize_worker()

virtual StatusCode AthXRT::StateHandler::initialize_worker ( )

inlineprotectedvirtual

Initialization per process.

Reimplemented in AthExXRT::VectorAddXRTExampleAlg, AthExXRT::VectorMultXRTExampleAlg, AthExXRT::VectorAddOCLExampleAlg, and AthExXRT::VectorMultOCLExampleAlg.

Definition at line 37 of file StateHandler.h.

  {
    return StatusCode::SUCCESS;
  }

stop()

virtual StatusCode AthXRT::StateHandler::stop ( )

inlineprotectedvirtual

Reimplemented in AthExXRT::VectorAddOCLExampleAlg, and AthExXRT::VectorMultOCLExampleAlg.

Definition at line 67 of file StateHandler.h.

                            {
    const bool is_multiprocess = (Gaudi::Concurrency::ConcurrencyFlags::numProcs() > 0);
 
    if (!is_multiprocess) {
      ATH_CHECK(this->stop_worker());
    } else {
      if (m_is_child){
              ATH_CHECK(this->stop_worker());
      }
    }
 
  return StatusCode::SUCCESS;
  }

stop_worker()

virtual StatusCode AthXRT::StateHandler::stop_worker ( )

inlineprotectedvirtual

clean up

Reimplemented in AthExXRT::VectorAddOCLExampleAlg, and AthExXRT::VectorMultOCLExampleAlg.

Definition at line 43 of file StateHandler.h.

  {
    return StatusCode::SUCCESS;
  }

Member Data Documentation

m_is_child

bool AthXRT::StateHandler::m_is_child = false

protected

Definition at line 81 of file StateHandler.h.

---

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

• StateHandler.h