Project
Loading...
Searching...
No Matches
statusmaps-writer-workflow.cxx
Go to the documentation of this file.
1
// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
2
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
3
// All rights not expressly granted are reserved.
4
//
5
// This software is distributed under the terms of the GNU General Public
6
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
7
//
8
// In applying this license CERN does not waive the privileges and immunities
9
// granted to it by virtue of its status as an Intergovernmental Organization
10
// or submit itself to any jurisdiction.
11
12
#include <vector>
13
#include "
Framework/CompletionPolicyHelpers.h
"
14
#include "
StatusMapWriterSpec.h
"
15
16
using namespace
o2::framework
;
17
18
void
customize
(std::vector<o2::framework::CompletionPolicy>& policies)
19
{
20
// ordered policies for the writers
21
policies.push_back(
CompletionPolicyHelpers::consumeWhenAllOrdered
(
".*(?:MCH|mch).*[W,w]riter.*"
));
22
}
23
24
#include "
Framework/runDataProcessing.h
"
25
26
WorkflowSpec
defineDataProcessing
(
const
ConfigContext
&)
27
{
28
return
WorkflowSpec
{
o2::mch::getStatusMapWriterSpec
(
"mch-statusmap-writer"
)};
29
}
CompletionPolicyHelpers.h
StatusMapWriterSpec.h
o2::framework::ConfigContext
Definition
ConfigContext.h:24
o2::framework
Defining PrimaryVertex explicitly as messageable.
Definition
TFIDInfo.h:20
o2::framework::WorkflowSpec
std::vector< DataProcessorSpec > WorkflowSpec
Definition
HBFUtilsInitializer.h:39
o2::mch::getStatusMapWriterSpec
DataProcessorSpec getStatusMapWriterSpec(const char *specName)
Definition
StatusMapWriterSpec.cxx:25
runDataProcessing.h
defineDataProcessing
WorkflowSpec defineDataProcessing(const ConfigContext &)
Definition
statusmaps-writer-workflow.cxx:26
customize
void customize(std::vector< o2::framework::CompletionPolicy > &policies)
Definition
statusmaps-writer-workflow.cxx:18
o2::framework::CompletionPolicyHelpers::consumeWhenAllOrdered
static CompletionPolicy consumeWhenAllOrdered(const char *name, CompletionPolicy::Matcher matcher)
as consumeWhenAll, but ensures that records are processed with incremental timeSlice (DataHeader::sta...
Definition
CompletionPolicyHelpers.cxx:174
Detectors
MUON
MCH
IO
src
statusmaps-writer-workflow.cxx
Generated on Tue Feb 25 2025 23:16:22 for Project by
1.9.8