ddtDataPublisher.hpp

Go to the documentation of this file.

 
#ifndef SRC_DDTDATAPUBLISHER_H_
#define SRC_DDTDATAPUBLISHER_H_
 
#include <boost/circular_buffer.hpp>
#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/signals2/signal.hpp>
 
#include "ddt/ddtConstants.hpp"
#include "ddt/ddtDataTransferLib.hpp"
 
namespace ddt {

class DdtDataPublisher : public DdtDataTransferLib {
 public:
  explicit DdtDataPublisher(DdtLogger *logger);

  explicit DdtDataPublisher(log4cplus::Logger const &log4cplus_logger);

  ~DdtDataPublisher() override;
 
  int RegisterPublisher(const std::string uri, const std::string dsi,
                        const bool compute_crc) override;
 
  int UnregisterPublisher() override;
 
  void PublishData() override;

  void SetBufferSize(const int max_sample_size, const int number_samples);

  void WriteData(const int32_t sample_id, const std::vector<uint8_t> &datavec,
                 const std::vector<uint8_t> &metadatavec);

  void WriteData(const int32_t sample_id, const uint8_t *const data,
                 const int32_t data_size, const uint8_t *const metadata,
                 const int32_t metadata_size);

  void set_topic_id(const int id);

  bool get_connected_to_broker() const;
 
 protected:
  void LoadDefaults();

  void ReadIni();

  int topic_id = 0;
 
 private:
  void Init();

  void PrintConfigValues();

  void Reregister() override;

  void PrintParameters();

  int Register();
 
  DdtMemoryAccessor *memory_accessor = nullptr;
  std::string shm_id;
  std::string broker_uri;
  std::string data_stream_identifier;
  int writer_index = 0;
  int max_data_sample_size = 0;
  int number_of_samples = 0;
 
  bool compute_checksum = false;
  std::string publishing_uri;
  bool registered = false;
};
 
}  // namespace ddt
 
#endif /* SRC_DDTDATAPUBLISHER_H_ */