IntegratingMerger.h

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.
 
#ifndef ALICEO2_INTEGRATINGMERGER_H
#define ALICEO2_INTEGRATINGMERGER_H
 
 
#include "Mergers/MergerConfig.h"
#include "Mergers/MergeInterface.h"
#include "Mergers/ObjectStore.h"
 
#include "Framework/Task.h"
 
#include <memory>
 
class TObject;
 
namespace o2::monitoring
{
class Monitoring;
}
 
namespace o2::mergers
{
 
class IntegratingMerger : public framework::Task
{
 public:
  IntegratingMerger(const MergerConfig&, const header::DataHeader::SubSpecificationType&);
  ~IntegratingMerger() override = default;
 
  void init(framework::InitContext& ctx) override;
  void run(framework::ProcessingContext& ctx) override;
 
  void endOfStream(framework::EndOfStreamContext& eosContext) override;
 
 private:
  void finishCycle(framework::DataAllocator& outputs);
  void publishIntegral(framework::DataAllocator& allocator);
  void publishMovingWindow(framework::DataAllocator& allocator);
  static void merge(ObjectStore& mMergedDelta, ObjectStore&& other);
  void clear();
  bool shouldFinishCycle(const framework::InputRecord&) const;
 
 private:
  header::DataHeader::SubSpecificationType mSubSpec;
  // data points since the last cycle end. it allows us to create moving windows
  ObjectStore mMergedObjectLastCycle = std::monostate{};
  // data points since the last state reset
  ObjectStore mMergedObjectIntegral = std::monostate{};
  MergerConfig mConfig;
  std::unique_ptr<monitoring::Monitoring> mCollector;
  int mCyclesSinceReset = 0;
 
  // stats
  int mTotalDeltasMerged = 0;
  int mDeltasMerged = 0;
};
 
} // namespace o2::mergers
 
#endif //ALICEO2_INTEGRATINGMERGER_H