CbmTbDaqBuffer.h

Go to the documentation of this file.

/* Copyright (C) 2012-2020 PI-UHd, GSI
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Volker Friese, Norbert Herrmann [committer] */
 
#ifndef CBMTBDAQBUFFER_H
#define CBMTBDAQBUFFER_H 1
 
#include "CbmDefs.h"
 
#include <RtypesCore.h>  // for Double_t, Int_t
 
#include <boost/any.hpp>
 
#include <map>      // for multimap, __map_const_iterator, multimap<>::...
#include <utility>  // for pair
 
class CbmTbDaqBuffer {
public:
  typedef std::pair<boost::any, ECbmModuleId> Data;
 
  ~CbmTbDaqBuffer();
 
  //  boost::any GetNextData(Double_t time);
  Data GetNextData(Double_t time);
 
 
  Int_t GetSize() const { return fData.size(); }
 
 
  Double_t GetTimeFirst() const;
 
  Double_t GetTimeLast() const;
 
  static CbmTbDaqBuffer* Instance();
 
  void PrintStatus() const;
 
  template<class Digi>
  void InsertData(Digi* digi)
  {
    Double_t digi_time    = digi->GetTime();
    ECbmModuleId systemID = Digi::GetSystem();
    InsertData(digi, digi_time, systemID);
  }
 
private:
  std::multimap<Double_t, Data> fData;
 
 
  static CbmTbDaqBuffer* fgInstance;
 
 
  CbmTbDaqBuffer();
 
 
  CbmTbDaqBuffer(const CbmTbDaqBuffer&);
 
 
  CbmTbDaqBuffer& operator=(const CbmTbDaqBuffer&);
 
  //  void InsertData(boost::any digi);
  void InsertData(boost::any digi, Double_t time, ECbmModuleId systemID)
  {
    fData.insert(std::make_pair(time, std::make_pair(std::move(digi), systemID)));
  }
};
 
 
#endif /* CBMTBDAQBUFFER_H */