ddtPublisher.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 ddtPublisher.hpp
// @brief MAL Publisher.
//
// This class provides the functionality to create MAL Publishers used for
// publishing data packets or for notifying other components that new data is
// available.
//
// @author Matthias Grimm, CGI
// @since  2020/01/16
//
 
#ifndef DDTPUBLISHER_HPP_
#define DDTPUBLISHER_HPP_
 
#include <Ddtdatatransfericd.hpp>
#include <chrono>
#include <cstring>
#include <iostream>
#include <mal/Cii.hpp>
#include <mal/ps/qos/Deadline.hpp>
#include <mal/ps/qos/Latency.hpp>
#include <mal/utility/LoadMal.hpp>
#include <map>
#include <memory>
#include <stdexcept>
#include <thread>
 
#include "ddt/ddtLogger.hpp"
 
namespace mal = ::elt::mal;
namespace datatransfer = ::elt::ddt::datatransfer;
 
namespace ddt {
 
class DdtPublisher {
 public:
  DdtPublisher();
 
  virtual ~DdtPublisher();
 
  static std::unique_ptr<mal::ps::InstancePublisher<datatransfer::DataPacket>,
                         std::default_delete<mal::ps::InstancePublisher<
                             datatransfer::DataPacket> > >
  CreatePublisher(const std::string& data_stream_identifier,
                  const std::string& publishing_uri, const int32_t latency,
                  const int32_t deadline, DdtLogger* logger);
 
  static std::unique_ptr<
      mal::ps::InstancePublisher<datatransfer::NotificationSample>,
      std::default_delete<
          mal::ps::InstancePublisher<datatransfer::NotificationSample> > >
  CreateNotifier(const std::string& data_stream_identifier,
                 const int32_t latency, const int32_t deadline,
                 const int32_t notification_port, DdtLogger* logger);
};
 
}  // namespace ddt
 
#endif /* DDTPUBLISHER_HPP_ */