Project
Loading...
Searching...
No Matches
dcs-config-proxy.cxx File Reference
#include "Framework/WorkflowSpec.h"
#include "Framework/DataProcessorSpec.h"
#include "Framework/DataSpecUtils.h"
#include "Framework/ControlService.h"
#include "Framework/RawDeviceService.h"
#include "Framework/Logger.h"
#include "Framework/Lifetime.h"
#include "Framework/ConfigParamSpec.h"
#include "Framework/ExternalFairMQDeviceProxy.h"
#include "DetectorsCommonDataFormats/DetID.h"
#include "Headers/DataHeaderHelpers.h"
#include <fairmq/Device.h>
#include <fairmq/Parts.h>
#include "CommonUtils/StringUtils.h"
#include <vector>
#include <string>
#include <chrono>
#include "Framework/runDataProcessing.h"

Go to the source code of this file.

Typedefs

using DetID = o2::detectors::DetID
 

Functions

void sendAnswer (const std::string &what, const std::string &ack_chan, fair::mq::Device &device)
 
auto getDataOriginFromFilename (const std::string &filename)
 
InjectorFunction dcs2dpl (const std::string &acknowledge)
 
void customize (std::vector< ConfigParamSpec > &workflowOptions)
 
WorkflowSpec defineDataProcessing (ConfigContext const &config)
 

Variables

std::array< o2::header::DataOrigin, 2 > exceptionsDetID {"GRP", "AGD"}
 

Typedef Documentation

◆ DetID

Definition at line 35 of file dcs-config-proxy.cxx.

Function Documentation

◆ customize()

void customize ( std::vector< ConfigParamSpec > &  workflowOptions)

Definition at line 148 of file dcs-config-proxy.cxx.

◆ dcs2dpl()

InjectorFunction dcs2dpl ( const std::string acknowledge)

Definition at line 68 of file dcs-config-proxy.cxx.

◆ defineDataProcessing()

WorkflowSpec defineDataProcessing ( ConfigContext const &  config)

To be implemented by the user to specify one or more DataProcessorSpec.

Use the ConfigContext context in input to get the value of global configuration properties like command line options, number of available CPUs or whatever can affect the creation of the actual workflow.

Returns
a std::vector of DataProcessorSpec which represents the actual workflow to be executed

The workflow executable for the stand alone CPV reconstruction workflow The basic workflow for CPV reconstruction is defined in RecoWorkflow.cxx and contains the following default processors

  • digit reader
  • clusterer

The default workflow can be customized by specifying input and output types e.g. digits, raw, tracks.

MC info is processed by default, disabled by using command line option --disable-mc

This function hooks up the the workflow specifications into the DPL driver.

The workflow executable for the stand alone CTP reconstruction workflow

  • digit and lumi reader This function hooks up the the workflow specifications into the DPL driver.

Definition at line 156 of file dcs-config-proxy.cxx.

◆ getDataOriginFromFilename()

auto getDataOriginFromFilename ( const std::string filename)

Definition at line 51 of file dcs-config-proxy.cxx.

◆ sendAnswer()

void sendAnswer ( const std::string what,
const std::string ack_chan,
fair::mq::Device device 
)

Definition at line 39 of file dcs-config-proxy.cxx.

Variable Documentation

◆ exceptionsDetID

std::array<o2::header::DataOrigin, 2> exceptionsDetID {"GRP", "AGD"}

Definition at line 37 of file dcs-config-proxy.cxx.