mudpiPublisher.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_MUDPIGENPUB_MUDPI_PUBLISHER_HPP
#define RTCTK_REUSABLECOMPONENT_MUDPIGENPUB_MUDPI_PUBLISHER_HPP
 
#include <atomic>
#include <string>
#include <thread>
#include <vector>
 
#include "rtctk/componentFramework/logger.hpp"
#include "rtctk/mudpiPub/mudpiPubCfg.hpp"
 
namespace rtctk::mudpiPub {
 
class Publisher {
public:
    Publisher(const std::string& pub_id, const PubCfg& cfg);
    virtual ~Publisher();
    void SendSample();
    void WaitUntilSendingDone();
 
private:
    void Run();
 
    // Helper function to load data from file.
    void LoadDataFromFile(const std::string& filename, const std::string& colname);
 
    // Helper function to fill a sample buffer with a pattern.
    void FillSample(std::vector<char>& sample_data, std::uint32_t sample_id);
 
    log4cplus::Logger& m_logger;
 
    std::string m_id;
 
    PubCfg m_cfg;
 
    // Buffers of sample data loaded from the data file.
    std::vector<std::vector<char>> m_sample_data_from_file;
 
    std::atomic<bool> m_send_sample;
    std::atomic<bool> m_stop;
 
    std::thread m_thread;
};
 
}  // namespace rtctk::mudpiPub
 
#endif  // RTCTK_REUSABLECOMPONENT_MUDPIGENPUB_PUBLISHER_HPP