17void customize(std::vector<o2::framework::CompletionPolicy>& policies)
23void customize(std::vector<o2::framework::ConfigParamSpec>& workflowOptions)
35 if (
cc.helpOnCommandLine()) {
39 cc.options().get<std::string>(
"device-name")));
WorkflowSpec defineDataProcessing(ConfigContext const &cc)
void customize(std::vector< o2::framework::CompletionPolicy > &policies)
Defining PrimaryVertex explicitly as messageable.
std::vector< DataProcessorSpec > WorkflowSpec
o2::framework::DataProcessorSpec getIRFrameWriterSpec(const std::string &spec, const std::string &defFileName="o2_irframe.root", const std::string &devName="irframe-writer")
static CompletionPolicy consumeWhenAllOrdered(const char *name, CompletionPolicy::Matcher matcher)
as consumeWhenAll, but ensures that records are processed with incremental timeSlice (DataHeader::sta...
std::vector< o2::mch::ChannelCode > cc