dcs-processor-workflow.cxx File Reference

#include "CCDB/CcdbApi.h"
#include "CCDB/CcdbObjectInfo.h"
#include "CommonUtils/MemFileHelper.h"
#include "DetectorsCalibration/Utils.h"
#include "DetectorsDCS/DataPointCompositeObject.h"
#include "Framework/CallbackService.h"
#include "Framework/ConfigParamSpec.h"
#include "Framework/EndOfStreamContext.h"
#include "Framework/WorkflowSpec.h"
#include "Framework/runDataProcessing.h"
#include "subsysname.h"
#include <array>
#include <chrono>
#include <gsl/span>
#include <iostream>
#include <unordered_map>
#include <vector>
#include <TStopwatch.h>
#include "CommonUtils/ConfigurableParam.h"

Go to the source code of this file.

Functions
WorkflowSpec	defineDataProcessing (ConfigContext const &configcontext)

Function Documentation

defineDataProcessing()

WorkflowSpec defineDataProcessing

(

ConfigContext const &

configcontext

)

DPL Workflow to process MCH or MID DCS data points.

The expected input is a vector of DataPointCompositeObject containing only MCH (or only MID) data points.

Those datapoints are accumulated into DPMAPs (map from alias names to vector of DataPointValue).

The accumulated DPMAPs are sent to the output whenever :

• they reach a given size (–xx-max-size option(s))
• they span a given duration (–xx-max-duration option(s))
• the workflow is ended

Definition at line 388 of file dcs-processor-workflow.cxx.