Project
Loading...
Searching...
No Matches
Classes | Public Types | Public Member Functions | Static Public Member Functions | Protected Member Functions | List of all members
o2::devices::O2SimDevice Class Referencefinal

#include <O2SimDevice.h>

Inherits fair::mq::Device.

Classes

struct  FetchedChunk
 

Public Types

enum class  ChunkStatus { Work , Retry , EndOfWork , Stop }
 outcome of asking the primary server for work More...
 

Public Member Functions

 O2SimDevice ()=default
 
 O2SimDevice (o2::steer::O2MCApplication *vmcapp, TVirtualMC *vmc)
 
 ~O2SimDevice () final
 Default destructor.
 
void lateInit ()
 
bool isWorkAvailable (fair::mq::Channel &statuschannel, int workerID=-1)
 
bool Kernel (int workerID, fair::mq::Channel &requestchannel, fair::mq::Channel &dataoutchannel, fair::mq::Channel *statuschannel=nullptr)
 

Static Public Member Functions

static bool initSim (fair::mq::Channel &channel, std::unique_ptr< FairRunSim > &simptr)
 
static FetchedChunk fetchChunk (int workerID, fair::mq::Channel &requestchannel)
 requests one chunk of primaries from the server on the given channel
 

Protected Member Functions

void InitTask () final
 Overloads the InitTask() method of fair::mq::Device.
 
bool ConditionalRun () final
 Overloads the ConditionalRun() method of fair::mq::Device.
 
void PostRun () final
 

Detailed Description

Definition at line 41 of file O2SimDevice.h.

Member Enumeration Documentation

◆ ChunkStatus

enum class o2::devices::O2SimDevice::ChunkStatus
strong

outcome of asking the primary server for work

Enumerator
Work 

a chunk to transport

Retry 

nothing yet (server busy or no answer); ask again

EndOfWork 

the server sent the end-of-work marker

Stop 

the request could not be sent, or the server has nothing more to give; stop asking

Definition at line 65 of file O2SimDevice.h.

Constructor & Destructor Documentation

◆ O2SimDevice() [1/2]

o2::devices::O2SimDevice::O2SimDevice ( )
default

◆ O2SimDevice() [2/2]

o2::devices::O2SimDevice::O2SimDevice ( o2::steer::O2MCApplication *  vmcapp,
TVirtualMC *  vmc 
)
inline

Definition at line 45 of file O2SimDevice.h.

◆ ~O2SimDevice()

o2::devices::O2SimDevice::~O2SimDevice ( )
final

Default destructor.

Definition at line 39 of file O2SimDevice.cxx.

Member Function Documentation

◆ ConditionalRun()

bool o2::devices::O2SimDevice::ConditionalRun ( )
finalprotected

Overloads the ConditionalRun() method of fair::mq::Device.

Definition at line 253 of file O2SimDevice.cxx.

◆ fetchChunk()

O2SimDevice::FetchedChunk o2::devices::O2SimDevice::fetchChunk ( int  workerID,
fair::mq::Channel &  requestchannel 
)
static

requests one chunk of primaries from the server on the given channel

Definition at line 201 of file O2SimDevice.cxx.

◆ initSim()

bool o2::devices::O2SimDevice::initSim ( fair::mq::Channel &  channel,
std::unique_ptr< FairRunSim > &  simptr 
)
static

Definition at line 68 of file O2SimDevice.cxx.

◆ InitTask()

void o2::devices::O2SimDevice::InitTask ( )
finalprotected

Overloads the InitTask() method of fair::mq::Device.

Definition at line 48 of file O2SimDevice.cxx.

◆ isWorkAvailable()

bool o2::devices::O2SimDevice::isWorkAvailable ( fair::mq::Channel &  statuschannel,
int  workerID = -1 
)

Definition at line 89 of file O2SimDevice.cxx.

◆ Kernel()

bool o2::devices::O2SimDevice::Kernel ( int  workerID,
fair::mq::Channel &  requestchannel,
fair::mq::Channel &  dataoutchannel,
fair::mq::Channel *  statuschannel = nullptr 
)

Definition at line 133 of file O2SimDevice.cxx.

◆ lateInit()

void o2::devices::O2SimDevice::lateInit ( )

Definition at line 62 of file O2SimDevice.cxx.

◆ PostRun()

void o2::devices::O2SimDevice::PostRun ( )
finalprotected

Definition at line 258 of file O2SimDevice.cxx.

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