pubRtms.hpp

Go to the documentation of this file.

 
#ifndef CCF_STDPUB_PUB_RTMS_HPP_H_
#define CCF_STDPUB_PUB_RTMS_HPP_H_
 
#define BOOST_BIND_NO_PLACEHOLDERS
 
#include <mudpiif/MudpiSender.hpp>
 
#include <ccf/common/config.hpp>
#include <ccf/common/pubBase.hpp>
#include <ccf/stdpub/mudpiCreator.hpp>
 
namespace ccf::stdpub {
 
  class PubRtms: public ccf::common::PubBase {
  public:
 
    static void _SetSimulation(); // Warning: Don't use this.
 
    const std::string SETUP_KEY_BPP            = "bpp";
    const std::string SETUP_KEY_TOPIC_ID       = "topic_id";
    const std::string SETUP_KEY_SAMPLE_ID      = "sample_id";
    const std::string SETUP_KEY_PKT_SEND_DELAY = "pkt_send_delay";
 
    PubRtms(const std::string& proc_thread_name,
            const std::string& pub_thread_name);
 
    PubRtms();
 
    virtual ~PubRtms();
 
    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:
    static bool                                s_simulation;
    double                                     m_min_period;
    double                                     m_time_last_publishing;
    double                                     m_packet_send_delay;
    int                                        m_bpp{2};
    std::string                                m_address{"127.0.0.1"};
    int                                        m_port{59000};
    // Basic MUDPI configuration
    int                                        m_topicid{10};
    int                                        m_sampleid{500};
    std::unique_ptr<ccf::stdpub::MudpiCreator> m_mudpi_creator;
    std::unique_ptr<mudpiif::mudpiSenderJumbo> m_mudpi_sender;
    boost::asio::io_context                    m_ioc;
  };
 
}
 
#endif // CCF_STDPUB_PUB_RTMS_HPP_H_