ddtDataPublisher.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 ddtDataPublisher.hpp
// @brief Data Publisher.
//
// This class provides the functionality for publisher applications to register
// / unregister at a local broker and to publish data for a specified data
// stream.
//
// @author Matthias Grimm, CGI
// @since  2020/01/16
//
 
#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/ddtDataTransferLib.hpp"
 
namespace ddt {
 
class DdtDataPublisher : public DdtDataTransferLib {
 public:
  DdtDataPublisher(DdtLogger *logger);
 
  virtual ~DdtDataPublisher();
 
  int RegisterPublisher(std::string broker_uri,
                        std::string data_stream_identifier,
                        bool compute_checksum) override;
 
  int UnregisterPublisher() override;
 
  void PublishData() override;
 
  void SetBufferSize(int max_data_sample_size, int number_of_samples);
 
  void WriteData(int32_t sample_id, const std::vector<uint8_t> &datavec,
                 const std::vector<uint8_t> &metadatavec);
 
  void set_topic_id(int topic_id);
 
  bool get_connected_to_broker();
 
 protected:
  void LoadDefaults();
 
  void ReadIni();
 
  int topic_id;
 
 private:
  void Init();
 
  void PrintConfigValues();
 
  void Reregister();
 
  DdtMemoryAccessor *memory_accessor;
  std::string shm_id;
  std::string data_stream_identifier;
  int writer_index;
  int max_data_sample_size;
  int number_of_samples;
 
  bool compute_checksum;
  std::string publishing_uri;
};
 
}  // namespace ddt
 
#endif /* SRC_DDTDATAPUBLISHER_H_ */