ddtProducerConsumerBase.hpp

Go to the documentation of this file.

// @copyright
// (c) Copyright ESO 2020
// All Rights Reserved
// ESO (eso.org) is an Intergovernmental Organization, and therefore special
// legal conditions apply.
//
// @file ddtProducerConsumerBase.hpp
// @brief Base class for DdtDataProducer and DdtDataConsumer.
//
// This class serves as a base class for DdtDataProducer and DdtDataConsumer
// classes. It provides the ReadIni() and GetFreePort() functions for derived
// classes.
//
// @author Matthias Grimm, CGI
// @since  2020/08/04
//
 
#ifndef DDTPRODUCERCONSUMERBASE_HPP_
#define DDTPRODUCERCONSUMERBASE_HPP_
 
#include <boost/property_tree/ini_parser.hpp>
#include <boost/property_tree/ptree.hpp>
 
#include "ddt/ddtConstants.hpp"
#include "ddt/ddtLogger.hpp"
#include "ddt/ddtMemoryAccessor.hpp"
#include "ddt/ddtPublisher.hpp"
 
namespace mal = ::elt::mal;
namespace datatransfer = ::elt::ddt::datatransfer;
 
namespace ddt {
 
class DdtProducerConsumerBase {
 public:
  DdtProducerConsumerBase(DdtLogger* logger);
 
  virtual ~DdtProducerConsumerBase();
 
  enum NotificationType {
    NEW_DATA,
    PUB_REG,
    PUB_UNREG,
    SHM_DEL
  };
 
  virtual void Notify(NotificationType) = 0;
 
 protected:
  void LoadDefaults();
 
  void ReadIni();
 
  void PrintConfigValues();
 
  int32_t GetFreePort();
 
  int32_t min_port;
 
  int32_t max_port;
 
  DdtLogger* logger;
 
  const int MIN_PORT_DEFAULT = 5100;
  const int MAX_PORT_DEFAULT = 5500;
  const int MIN_RANGE = 3;
  const int LINE_LENGTH = 256;
};
 
}  // namespace ddt
 
#endif /* DDTPRODUCERCONSUMERBASE_HPP_ */