ddtProducerConsumerBase.hpp

Go to the documentation of this file.

 
#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:
  explicit DdtProducerConsumerBase(DdtLogger* ddt_logger);

  virtual ~DdtProducerConsumerBase();

  enum NotificationType {
    NEW_DATA,
    PUB_REG,
    PUB_UNREG,
    SHM_DEL
  };

  virtual void Notify(NotificationType type) = 0;
 
 protected:
  void Init(DdtLogger* ddt_logger);

  void LoadDefaults();

  void ReadIni();

  void PrintConfigValues();

  int32_t GetFreePort() const;

  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_ */