ddtPublisher.hpp

Go to the documentation of this file.

 
#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_ */