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