DataSamplingConditionCustom.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 <fairlogger/Logger.h>
 
#include <TClass.h>
#include <TROOT.h>
#include <TSystem.h>
#include <boost/property_tree/ptree.hpp>
 
using namespace o2::framework;
 
namespace o2::utilities
{
 
class DataSamplingConditionCustom : public DataSamplingCondition
{
 
 public:
  DataSamplingConditionCustom() : DataSamplingCondition(){};
  ~DataSamplingConditionCustom() override = default;
 
  void configure(const boost::property_tree::ptree& config) override
  {
    std::string libraryName = "lib" + config.get<std::string>("moduleName");
    std::string className = config.get<std::string>("className");
 
    int libLoaded = gSystem->Load(libraryName.c_str(), "", true);
    if (libLoaded < 0) {
      throw std::runtime_error("Failed to load the library: " + libraryName);
    }
 
    // it does not seem to be documented anywhere, but this pointer to
    // a dictionary should not be deleted - it results in segfaults.
    TClass* dictionary = TClass::GetClass(className.c_str());
    if (!dictionary) {
      throw std::runtime_error("Failed to load the dictionary of the class: " + className + " from the library: " + libraryName);
    }
 
    mCondition.reset(static_cast<DataSamplingCondition*>(dictionary->New()));
    if (mCondition == nullptr) {
      throw std::runtime_error("Failed to instantiate the class: " + className + " from the library: " + libraryName);
    }
 
    mCondition->configure(config);
  }
 
  bool decide(const o2::framework::DataRef& dataRef) override
  {
    return mCondition->decide(dataRef);
  }
 
 private:
  std::unique_ptr<DataSamplingCondition> mCondition;
};
 
std::unique_ptr<DataSamplingCondition> DataSamplingConditionFactory::createDataSamplingConditionCustom()
{
  return std::make_unique<DataSamplingConditionCustom>();
}
 
} // namespace o2::utilities