pubDdt.hpp

Go to the documentation of this file.

 
#ifndef CCF_STDPUB_PUB_DDT_HPP_H_
#define CCF_STDPUB_PUB_DDT_HPP_H_
 
#include <ccf/common/configBase.hpp>
#include <ccf/common/pubBase.hpp>
 
// DDT related includes
#include <ddt/ddtDataPublisherApplication.hpp>
#include <ddt/ddtDataPublisher.hpp>
#include <ddt/ddtDataTransferFactory.hpp>
#include <ddt/ddtEncDecMultiLayer.hpp>
#include <ddt/ddtLogger.hpp>
 
namespace ccf::stdpub {
 
  class PubDdt: public ccf::common::PubBase {
  public:
 
    static uint32_t CcfToDdtDataType(ccf::common::ImageDataType ccf_datatype);
 
    static void _SetSimulation(); // Warning: Don't use this.
 
    const std::string SETUP_KEY_DDT_ID      = "proc%d.pub%d.ddt.id";
    const std::string SETUP_KEY_DDT_BROKER  = "proc%d.pub%d.ddt.broker";
    const std::string SETUP_KEY_MAX_RATE    = "proc%d.pub%d.ddt.max_rate";
 
 
    PubDdt(const uint16_t proc_thread_nb,
           const uint16_t pub_thread_nb,
           const std::string& pub_name);
 
    PubDdt();
 
    virtual ~PubDdt();
 
    virtual void InitialiseUser();
 
    virtual void PublishUser(ccf::common::DataFrame& frame);
 
    //virtual void ActivateUser();
 
    //virtual void DeactivateUser();
 
    virtual void DismantleUser();
 
    virtual void CreateObjectUser(const uint16_t proc_thread_nb,
                                  const uint16_t pub_thread_nb,
                                  const std::string& pub_name,
                                  ccf::common::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;
    DdtEncDecMultiLayer                    m_encoder;
  };
 
}
 
#endif // CCF_STDPUB_PUB_DDT_HPP_H_