DataSamplingConditionNConsecutive.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 "DataSampling/DataSamplingCondition.h"
#include "DataSampling/DataSamplingConditionFactory.h"
#include "Framework/DataProcessingHeader.h"
#include "Framework/Logger.h"
 
#include <boost/property_tree/ptree.hpp>
 
using namespace o2::framework;
 
namespace o2::utilities
{
 
using namespace o2::header;
 
// always increments by one.
class DataSamplingConditionNConsecutive : public DataSamplingCondition
{
 
 public:
  DataSamplingConditionNConsecutive() : DataSamplingCondition(){};
  ~DataSamplingConditionNConsecutive() override = default;
 
  void configure(const boost::property_tree::ptree& config) override
  {
    mSamplesNumber = config.get<size_t>("samplesNumber");
    mCycleSize = config.get<size_t>("cycleSize");
    if (mSamplesNumber > mCycleSize) {
      LOG(warn) << "Consecutive number of samples is higher than cycle size.";
    }
  };
  bool decide(const o2::framework::DataRef& dataRef) override
  {
    const auto* dpHeader = get<DataProcessingHeader*>(dataRef.header);
    assert(dpHeader);
 
    // strongly relying on assumption, that timesliceID always increments by one.
    return dpHeader->startTime % mCycleSize < mSamplesNumber;
  }
 
 private:
  size_t mSamplesNumber;
  size_t mCycleSize;
};
 
std::unique_ptr<DataSamplingCondition> DataSamplingConditionFactory::createDataSamplingConditionNConsecutive()
{
  return std::make_unique<DataSamplingConditionNConsecutive>();
}
 
} // namespace o2::utilities