QueueBase.hpp

Go to the documentation of this file.

 
#ifndef IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUEBASE_HPP_
#define IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUEBASE_HPP_
 
#include "utilities/NamedObject.hpp"
 
#include "iomanager/opmon/queue.pb.h"
#include "opmonlib/MonitorableObject.hpp"
 
#include "ers/Issue.hpp"
 
#include <atomic>
#include <chrono>
#include <cstddef>
#include <memory>
#include <string>
#include <utility>
#include <vector>
 
namespace dunedaq::iomanager {
 
class QueueBase
  : public utilities::NamedObject
  , public opmonlib::MonitorableObject
{
public:
  explicit QueueBase(const std::string& name)
    : utilities::NamedObject(name)
    , opmonlib::MonitorableObject()
  {
  }
 
  virtual size_t get_capacity() const = 0;
 
  virtual size_t get_num_elements() const = 0;
 
protected:
  void generate_opmon_data() override
  {
    opmon::QueueInfo info;
    info.set_capacity(this->get_capacity());
    info.set_number_of_elements(this->get_num_elements());
    publish(std::move(info));
  }
 
private:
  QueueBase(const QueueBase&) = delete;
  QueueBase& operator=(const QueueBase&) = delete;
  QueueBase(QueueBase&&) = delete;
  QueueBase& operator=(QueueBase&&) = delete;
};
 
} // namespace dunedaq::iomanager
 
#endif // IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUEBASE_HPP_