Project
Loading...
Searching...
No Matches
o2::workflows Namespace Reference

Typedefs

using OutputBuffer = o2::pmr::vector< char >
 

Functions

o2::framework::DataProcessorSpec sim_its_ALP3 ()
 
DataProcessorSpec sim_tpc ()
 
o2f::Output getOutput (const o2f::OutputSpec outputSpec)
 
std::shared_ptr< std::vector< o2f::Output > > getOutputList (const o2f::Outputs outputSpecs)
 
o2f::DataProcessorSpec defineBroadcaster (std::string devName, o2f::InputSpec usrInput, o2f::Outputs usrOutputs, std::function< size_t(o2f::DataRef)> const func)
 
o2f::DataProcessorSpec defineBroadcaster (std::string devName, o2f::InputSpec usrInput, o2f::Outputs usrOutputs, size_t fixMsgSize)
 
o2f::DataProcessorSpec defineBroadcaster (std::string devName, o2f::InputSpec usrInput, o2f::Outputs usrOutputs)
 
o2f::DataProcessorSpec defineMerger (std::string devName, o2f::Inputs usrInputs, o2f::OutputSpec usrOutput, std::function< void(OutputBuffer, const o2f::DataRef)> const mergerFunc)
 
o2f::DataProcessorSpec defineMerger (std::string devName, o2f::Inputs usrInputs, o2f::OutputSpec usrOutput)
 
o2f::DataProcessorSpec defineRouter (std::string devName, o2f::Inputs usrInput, o2f::Outputs usrOutputs, std::function< size_t(const o2f::DataRef)> const mappingFunc)
 
o2f::DataProcessorSpec defineGatherer (std::string devName, o2f::Inputs usrInputs, o2f::OutputSpec usrOutput)
 
o2f::DataProcessorSpec defineGenerator (o2f::OutputSpec usrOutput)
 
o2f::DataProcessorSpec definePipeline (std::string devName, o2f::InputSpec usrInput, o2f::OutputSpec usrOutput)
 
o2f::DataProcessorSpec defineSink (o2f::InputSpec usrInput)
 
o2::framework::WorkflowSpec DPLBroadcasterMergerWorkflow ()
 
o2::framework::WorkflowSpec DPLOutputTest ()
 

Variables

o2f::Inputs noInputs {}
 
o2f::Outputs noOutputs {}
 

Detailed Description

Author
Gabriele Gaetano Fronzé, gfron.nosp@m.ze@c.nosp@m.ern.c.nosp@m.h

Typedef Documentation

◆ OutputBuffer

Definition at line 40 of file Utils.h.

Function Documentation

◆ defineBroadcaster() [1/3]

o2f::DataProcessorSpec o2::workflows::defineBroadcaster ( std::string  devName,
o2f::InputSpec  usrInput,
o2f::Outputs  usrOutputs 
)

◆ defineBroadcaster() [2/3]

o2f::DataProcessorSpec o2::workflows::defineBroadcaster ( std::string  devName,
o2f::InputSpec  usrInput,
o2f::Outputs  usrOutputs,
size_t  fixMsgSize 
)

◆ defineBroadcaster() [3/3]

o2f::DataProcessorSpec o2::workflows::defineBroadcaster ( std::string  devName,
o2f::InputSpec  usrInput,
o2f::Outputs  usrOutputs,
std::function< size_t(o2f::DataRef)> const  func 
)

◆ defineGatherer()

o2f::DataProcessorSpec o2::workflows::defineGatherer ( std::string  devName,
o2f::Inputs  usrInputs,
o2f::OutputSpec  usrOutput 
)

◆ defineGenerator()

o2f::DataProcessorSpec o2::workflows::defineGenerator ( o2f::OutputSpec  usrOutput)

Definition at line 32 of file DPLBroadcasterMerger.cxx.

◆ defineMerger() [1/2]

o2f::DataProcessorSpec o2::workflows::defineMerger ( std::string  devName,
o2f::Inputs  usrInputs,
o2f::OutputSpec  usrOutput 
)

◆ defineMerger() [2/2]

o2f::DataProcessorSpec o2::workflows::defineMerger ( std::string  devName,
o2f::Inputs  usrInputs,
o2f::OutputSpec  usrOutput,
std::function< void(OutputBuffer, const o2f::DataRef)> const  mergerFunc 
)

◆ definePipeline()

o2f::DataProcessorSpec o2::workflows::definePipeline ( std::string  devName,
o2f::InputSpec  usrInput,
o2f::OutputSpec  usrOutput 
)

Definition at line 77 of file DPLBroadcasterMerger.cxx.

◆ defineRouter()

o2f::DataProcessorSpec o2::workflows::defineRouter ( std::string  devName,
o2f::Inputs  usrInput,
o2f::Outputs  usrOutputs,
std::function< size_t(const o2f::DataRef)> const  mappingFunc 
)

◆ defineSink()

o2f::DataProcessorSpec o2::workflows::defineSink ( o2f::InputSpec  usrInput)

Definition at line 95 of file DPLBroadcasterMerger.cxx.

◆ DPLBroadcasterMergerWorkflow()

o2::framework::WorkflowSpec o2::workflows::DPLBroadcasterMergerWorkflow ( )

Definition at line 119 of file DPLBroadcasterMerger.cxx.

◆ DPLOutputTest()

o2::framework::WorkflowSpec o2::workflows::DPLOutputTest ( )

◆ getOutput()

Output o2::workflows::getOutput ( const o2f::OutputSpec  outputSpec)

Definition at line 28 of file Utils.cxx.

◆ getOutputList()

std::shared_ptr< std::vector< Output > > o2::workflows::getOutputList ( const o2f::Outputs  outputSpecs)

Definition at line 36 of file Utils.cxx.

◆ sim_its_ALP3()

o2::framework::DataProcessorSpec o2::workflows::sim_its_ALP3 ( )

◆ sim_tpc()

o2::framework::DataProcessorSpec o2::workflows::sim_tpc ( )

Definition at line 45 of file o2_sim_tpc.cxx.

Variable Documentation

◆ noInputs

o2f::Inputs o2::workflows::noInputs {}

Definition at line 29 of file DPLBroadcasterMerger.cxx.

◆ noOutputs

o2f::Outputs o2::workflows::noOutputs {}

Definition at line 30 of file DPLBroadcasterMerger.cxx.