LatencyBufferConcept.hpp

Go to the documentation of this file.

 
#ifndef DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_CONCEPTS_LATENCYBUFFERCONCEPT_HPP_
#define DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_CONCEPTS_LATENCYBUFFERCONCEPT_HPP_
 
#include "appfwk/DAQModule.hpp"
#include "appmodel/LatencyBuffer.hpp"
#include "opmonlib/MonitorableObject.hpp"
 
#include <cstddef>
#include <concepts>
 
namespace dunedaq {
namespace datahandlinglibs {
 
template<typename T>
concept SupportsDelayedPostprocessing = T::supports_delayed_postprocessing;
 
template<class T>
class LatencyBufferConcept : public opmonlib::MonitorableObject
{
 
public:
  LatencyBufferConcept() {}
 
  virtual ~LatencyBufferConcept() {}
  
  LatencyBufferConcept(const LatencyBufferConcept&) = delete; 
  LatencyBufferConcept& operator=(const LatencyBufferConcept&) =
    delete;                                                         
  LatencyBufferConcept(LatencyBufferConcept&&) = delete;            
  LatencyBufferConcept& operator=(LatencyBufferConcept&&) = delete; 
 
  virtual void conf(const appmodel::LatencyBuffer* conf) = 0;
 
  virtual void scrap(const appfwk::DAQModule::CommandData_t& cfg) = 0;
 
  virtual std::size_t occupancy() const = 0;
 
  virtual bool write(T&& element) = 0;
 
  virtual bool read(T& element) = 0;
 
  // virtual bool put(T& element) = 0;
 
  virtual const T* front() = 0;
 
  virtual const T* back() = 0;
 
  virtual void pop(std::size_t amount) = 0;
 
  virtual void flush() = 0;
 
  virtual void allocate_memory(size_t /*size*/) = 0;
};
 
} // namespace datahandlinglibs
} // namespace dunedaq
 
#endif // DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_CONCEPTS_LATENCYBUFFERCONCEPT_HPP_