ddtDataProducer.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 ddtDataProducer.hpp
// @brief Data Producer.
//
// This class provides the functionality to publish data over network
// and enables sending new data notifications.
//
// @author Matthias Grimm, CGI
// @since  2020/01/16
//
 
#ifndef DDTDATAPRODUCER_HPP_
#define DDTDATAPRODUCER_HPP_
 
#include "ddt/ddtProducerConsumerBase.hpp"
 
namespace mal = ::elt::mal;
namespace datatransfer = ::elt::ddt::datatransfer;
 
static const std::chrono::milliseconds PUBLISH_TIMEOUT{450};
 
namespace ddt {
 
class DdtDataProducer : public DdtProducerConsumerBase {
 public:
  DdtDataProducer(const std::string& data_stream_identifier, DdtLogger* logger);
 
  DdtDataProducer(const std::string& data_stream_identifier, int32_t latency,
                  int32_t deadline, std::string publishing_uri,
                  DdtLogger* logger);
 
  virtual ~DdtDataProducer();
 
  void Publish(DataPacket data_packet);
 
  void Notify(NotificationType);
 
  std::string get_publishing_uri();
 
 private:
  void Initialize(const std::string& data_stream_identifier, int32_t latency,
                  int32_t deadline, std::string publishing_uri,
                  DdtLogger* logger);
 
  std::string CreatePublishingUri(const std::string& data_stream_identifier);
 
  std::unique_ptr<mal::ps::InstancePublisher<datatransfer::DataPacket>,
                  std::default_delete<
                      mal::ps::InstancePublisher<datatransfer::DataPacket> > >
      data_publisher;
  std::shared_ptr<datatransfer::DataPacket> ddt_data_packet;
 
  double timestamp_prev;
  std::string publishing_uri;
};
 
}  // namespace ddt
 
#endif /* DDTDATAPRODUCER_HPP_ */