mudpiProcessor.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_TELREPUB_MUDPIPROCESSOR_HPP_
#define RTCTK_REUSABLECOMPONENT_TELREPUB_MUDPIPROCESSOR_HPP_
 
#include <atomic>
#include <boost/asio.hpp>
#include <thread>
 
#include "mudpi.h"
#include "mudpiProcessingError.hpp"
 
#include "ddsPubThread.hpp"
 
namespace rtctk::telRepub {
 
class MudpiProcessor {
    uint32_t m_statistic_msg_update_rate;
 
    bool m_in_synch = true;
    uint32_t m_frame_id_errors = 0;
    uint32_t m_sample_id_errors = 0;
 
    std::atomic<uint32_t> m_frame_id_errors_per_topic = 0;
    std::atomic<uint32_t> m_sample_id_errors_per_topic = 0;
 
    PubThreadBase<>& m_pub;
 
    RepubBuf<rtctk::AgnosticTopic>* m_repub_buf;
    rtctk::AgnosticTopic* m_dds_topic;
 
    uint32_t m_total_buf_len;  // changed from 16 bit for Pixel topic (DOR)
#ifdef USE_RTI_DDS
    topicT m_topicBuf;
#endif
 
    mudpi::uint32_t m_last_sample_id = -1;  // TBC!!!
    mudpi::timestamp_t m_last_timestamp = 0.0;
 
    mudpi::uint16_t m_last_frame_id = 0;
    mudpi::uint16_t m_num_frames = -1;  // TBC !!!
 
    struct timeval m_start_time;
    struct timeval m_now_time;
    double m_elapsed_time;
    double m_pck_per_sec_est;
 
    std::atomic<uint32_t> m_recvd = 0;
    mudpi::uint16_t m_topic_id = 0;
    mudpi::uint32_t m_sample_id = 0;
    mudpi::uint16_t m_frame_id = 0;
 
    time_t m_ctt = {};
 
    log4cplus::Logger m_logger;
 
public:
    explicit MudpiProcessor(PubThreadBase<>& pub, uint32_t statisticMsgUpdateRate = 5000);
 
    MudpiProcessor(MudpiProcessor const& rhs);
 
    ~MudpiProcessor();
 
    std::error_code ProcessMudpi(mudpi::mudpiHeader* packet);
 
    void Statistics();
};  // MudpiProcessor
 
}  // namespace rtctk::telRepub
 
#endif  // RTCTK_REUSABLECOMPONENT_TELREPUB_MUDPIPROCESSOR_HPP_