pubDdt.hpp

Go to the documentation of this file.

 
#ifndef CCF_STDPUB_PUB_DDT_HPP_H_
#define CCF_STDPUB_PUB_DDT_HPP_H_
 
//#define BOOST_BIND_NO_PLACEHOLDERS
 
#include <ccf/common/config.hpp>
#include <ccf/common/pubBase.hpp>
 
// DDT related includes
#include <ddt/ddtDataPublisherApplication.hpp>
#include <ddt/ddtDataPublisher.hpp>
#include <ddt/ddtDataTransferFactory.hpp>
#include <ddt/ddtEncDecImage3D.hpp>
#include <ddt/ddtLogger.hpp>
 
namespace ccf::stdpub {
 
  class PubDdt: public ccf::common::PubBase {
  public:
 
    static uint32_t GetDdtDataType(ccf::DataType data_type);
 
    static void _SetSimulation(); // Warning: Don't use this.
 
    const std::string SETUP_KEY_DDT_ID      = "ddt_id";
    const std::string SETUP_KEY_DDT_BROKER  = "ddt_broker";
    const std::string SETUP_KEY_MAX_RATE    = "ddt_max_rate";
 
 
    PubDdt(const std::string& proc_thread_name,
           const std::string& pub_thread_name);
 
    PubDdt();
 
    virtual ~PubDdt();
 
    virtual void InitialiseUser();
 
    virtual void PublishUser(ccf::common::DataFrame& frame);
 
    virtual void DismantleUser();
 
    // virtual void CreateObjectUser(const std::string& proc_thread_name,
    //                               const std::string& pub_thread_name,
    //                               std::shared_ptr<PubBase>& new_object);
 
    virtual void CreateObjectUser(const std::string& proc_thread_name,
                                  const std::string& pub_thread_name,
                                  PubBase** new_object);
 
  protected:
 
  private:
    // TODO: Not the right way to be able to use the class for unit tests, without starting the DDT
    // Broker. A better solution should be found, maybe based on an intemediate DDT adapter.
    static bool                            s_simulation;
 
    double                                 m_min_period;
    double                                 m_time_last_publishing;
 
    // DDT required objects.
    ddt::DdtLogger*                        m_logger;
    std::unique_ptr<ddt::DdtDataPublisher> m_publisher;
    DdtEncDecImage3D                       m_encoder;
  };
 
}
 
#endif // CCF_STDPUB_PUB_DDT_HPP_H_