test_RawDeviceInjector.cxx

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
#include "Framework/runDataProcessing.h"
#include "Framework/ExternalFairMQDeviceProxy.h"
#include "Framework/Logger.h"
#include "Headers/HeartbeatFrame.h"
 
using namespace o2::framework;
 
using DataOrigin = o2::header::DataOrigin;
 
// A simple workflow which takes heartbeats from
// a raw FairMQ device as input and uses them as
// part of the DPL.
WorkflowSpec defineDataProcessing(ConfigContext const& specs)
{
  auto outspec = OutputSpec{o2::header::DataOrigin("SMPL"),
                            o2::header::gDataDescriptionHeartbeatFrame};
  auto inspec = InputSpec{"heatbeat",
                          o2::header::DataOrigin("SMPL"),
                          o2::header::gDataDescriptionHeartbeatFrame};
  return WorkflowSpec{
    specifyExternalFairMQDeviceProxy("foreign-source",
                                     {outspec},
                                     "type=sub,method=connect,address=tcp://localhost:5450,rateLogging=1",
                                     o2DataModelAdaptor(outspec, 0, 1)),
    DataProcessorSpec{
      "foreign-consumer",
      Inputs{inspec},
      {},
      AlgorithmSpec{
        [](ProcessingContext& ctx) {
          LOG(debug) << ctx.inputs().size();
        }}}};
}