File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -41,7 +41,9 @@ using namespace o2::framework;
4141
4242// Additional configuration of the topology, which is done by implementing `customize` functions and placing them
4343// before `runDataProcessing.h` header. In this case, both Dispatcher and Merger are configured to accept incoming
44- // messages without waiting for the rest of inputs.
44+ // messages without waiting for the rest of inputs. The `customize` functions have to be above
45+ // `#include "Framework/runDataProcessing.h"` - that header checks if these functions are defined by user and if so, it
46+ // invokes them. It uses a trick with SFINAE expressions to do that.
4547void customize (std::vector<CompletionPolicy>& policies)
4648{
4749 DataSampling::CustomizeInfrastructure (policies);
Original file line number Diff line number Diff line change 3939using namespace o2 ;
4040using namespace o2 ::framework;
4141
42+ // The customize() functions are used to declare the executable arguments and to specify custom completion and channel
43+ // configuration policies. They have to be above `#include "Framework/runDataProcessing.h"` - that header checks if
44+ // these functions are defined by user and if so, it invokes them. It uses a trick with SFINAE expressions to do that.
45+
4246void customize (std::vector<CompletionPolicy>& policies)
4347{
4448 DataSampling::CustomizeInfrastructure (policies);
Original file line number Diff line number Diff line change 2222#include < random>
2323using namespace o2 ::framework;
2424
25+ // The customize() functions are used to declare the executable arguments and to specify custom completion and channel
26+ // configuration policies. They have to be above `#include "Framework/runDataProcessing.h"` - that header checks if
27+ // these functions are defined by user and if so, it invokes them. It uses a trick with SFINAE expressions to do that.
28+
2529void customize (std::vector<CompletionPolicy>& policies)
2630{
2731 CompletionPolicy mergerConsumesASAP =
Original file line number Diff line number Diff line change 3131using namespace o2 ;
3232using namespace o2 ::framework;
3333
34+ // The customize() functions are used to declare the executable arguments and to specify custom completion and channel
35+ // configuration policies. They have to be above `#include "Framework/runDataProcessing.h"` - that header checks if
36+ // these functions are defined by user and if so, it invokes them. It uses a trick with SFINAE expressions to do that.
37+
3438void customize (std::vector<ConfigParamSpec>& workflowOptions)
3539{
3640 workflowOptions.push_back (
You can’t perform that action at this time.
0 commit comments