mudpiProcessor.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_TELREPUB_MUDPIPROCESSOR_HPP_
#define RTCTK_REUSABLECOMPONENT_TELREPUB_MUDPIPROCESSOR_HPP_
 
#include <boost/asio.hpp>
#include <thread>
#include <iostream>
#include <map>
#include <boost/array.hpp>
 
#include "mudpi.h"
#include "mudpiProcessingError.hpp"
 
#include "ddsPubThread.hpp"
 
using boost::asio::ip::udp;
using boost::asio::ip::address;
 
 
namespace rtctk::telRepub  {
 
 
 
class MudpiProcessor {
 
    uint32_t m_statisticMsgUpdateRate;
 
    bool inSynch = true;
    uint32_t frameIdErrors =  0;
    uint32_t sampleIdErrors =  0;
 
    uint32_t m_frameIdErrorsPerTopic = 0;
    uint32_t m_sampleIdErrorsPerTopic = 0;
 
    char *m_recvBuffer;
 
    mudpi::mudpiHeader *m_mht;
 
    PubThreadBase<>& m_pub;
 
    uint16_t m_totalBufLen;
    topicT m_topicBuf;
    
    mudpi::uint32_t m_lastSampleId = -1; //TBC!!!
    mudpi::timestamp_t m_lastTimestamp = 0.0;
 
    mudpi::uint16_t m_lastFrameId = 0;
    mudpi::uint16_t m_numFrames = -1; //TBC !!!
 
    struct timeval m_startTime;
    struct timeval m_nowTime;
    double m_elapsedTime;
    double m_pckPerSecEst;
 
    uint32_t m_recvd = 0;
    mudpi::uint16_t m_topicId = 0;
    mudpi::uint32_t  m_sampleId = 0;
    mudpi::uint16_t  m_frameId = 0;
 
    time_t ctt;
public:
 
    explicit MudpiProcessor(char* buf, PubThreadBase<>& pub, uint32_t statisticMsgUpdateRate=5000);
    ~MudpiProcessor();
 
    std::error_code ProcessMudpi(size_t bytes_transferred);
 
    void Statistics();
};//MudpiProcessor
 
} // closing namespace
 
#endif //RTCTK_REUSABLECOMPONENT_TELREPUB_MUDPIPROCESSOR_HPP_