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/ddtConstants.hpp"
#include "ddt/ddtDataTransferLib.hpp"
 
namespace ddt {
 
class DdtDataPublisher : public DdtDataTransferLib {
 public:
  explicit DdtDataPublisher(DdtLogger *logger);
 
  explicit DdtDataPublisher(log4cplus::Logger const &log4cplusLogger);
 
  ~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;
 
 private:
  void Init();
 
  void PrintConfigValues();
 
  void Reregister();
 
  void PrintParameters();
 
  int Register();
 
  DdtMemoryAccessor *memory_accessor;
  std::string shm_id;
  std::string broker_uri;
  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_ */