27void customize(std::vector<o2::framework::CallbacksPolicy>& policies)
32void customize(std::vector<o2::framework::CompletionPolicy>& policies)
37void customize(std::vector<o2::framework::ConfigParamSpec>& workflowOptions)
39 std::vector<o2::framework::ConfigParamSpec> options{
47 {
"configKeyValues", VariantType::String,
"", {
"Semicolon separated key=value strings"}},
48 {
"nThreads", VariantType::Int, 1, {
"Number of CA tracker threads"}},
49 {
"use-geom", VariantType::Bool,
false, {
"alias for --use-full-geometry"}},
52 {
"tracking-mode", VariantType::String,
"sync", {
"sync,async,cosmics,unset,off; async uses 3 passes by default (MFTCATrackerParam.nIterations=-1); set nIterations=1 to retain one pass"}},
57 std::swap(workflowOptions, options);
static void writeINI(std::string const &filename, std::string const &keyOnly="")
WorkflowSpec defineDataProcessing(ConfigContext const &configContext)
void customize(std::vector< o2::framework::CallbacksPolicy > &policies)
Defining ITS Vertex explicitly as messageable.
std::vector< DataProcessorSpec > WorkflowSpec
framework::WorkflowSpec getWorkflow(const ca::WorkflowOptions &options)
WorkflowOptions readWorkflowOptions(const o2::framework::ConfigContext &, WorkflowKind)
static CompletionPolicy consumeWhenAllOrdered(const char *name, CompletionPolicy::Matcher matcher)
as consumeWhenAll, but ensures that records are processed with incremental timeSlice (DataHeader::sta...
static void addMFTConfigOption(std::vector< o2::framework::ConfigParamSpec > &opts)
static void addNewTimeSliceCallback(std::vector< o2::framework::CallbacksPolicy > &policies)
static void addConfigOption(std::vector< o2::framework::ConfigParamSpec > &opts, const std::string &defOpt=std::string(o2::base::NameConf::DIGITIZATIONCONFIGFILE))