DataSamplingConditionPayloadSize.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 "Headers/DataHeader.h"
#include "Framework/Logger.h"
#include "Framework/DataRefUtils.h"
#include <boost/property_tree/ptree.hpp>
 
using namespace o2::framework;
 
namespace o2::utilities
{
 
using namespace o2::header;
 
class DataSamplingConditionPayloadSize : public DataSamplingCondition
{
 
 public:
  DataSamplingConditionPayloadSize() : DataSamplingCondition(), mLowerLimit(1), mUpperLimit(0){};
  ~DataSamplingConditionPayloadSize() override = default;
 
  void configure(const boost::property_tree::ptree& config) override
  {
    mLowerLimit = config.get<size_t>("lowerLimit");
    mUpperLimit = config.get<size_t>("upperLimit");
    if (mLowerLimit > mUpperLimit) {
      LOG(warn) << "Lower limit is higher than upper limit.";
    }
  };
  bool decide(const o2::framework::DataRef& dataRef) override
  {
    auto payloadSize = o2::framework::DataRefUtils::getPayloadSize(dataRef);
 
    return payloadSize >= mLowerLimit && payloadSize <= mUpperLimit;
  }
 
 private:
  size_t mLowerLimit;
  size_t mUpperLimit;
};
 
std::unique_ptr<DataSamplingCondition> DataSamplingConditionFactory::createDataSamplingConditionPayloadSize()
{
  return std::make_unique<DataSamplingConditionPayloadSize>();
}
 
} // namespace o2::utilities