publisher.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_MUDPIPUB_PUBLISHER_HPP
#define RTCTK_REUSABLECOMPONENT_MUDPIPUB_PUBLISHER_HPP
 
#include <atomic>
#include <string>
#include <thread>
#include <vector>
 
#include "rtctk/componentFramework/logger.hpp"
#include "rtctk/mudpiPub/config.hpp"
 
namespace rtctk::mudpiPub {
 
class Publisher {
public:
    Publisher(const std::string& pub_id, const PubCfg& cfg);
 
    virtual ~Publisher();
    void SendSample();
    void WaitUntilSendingDone();
    void Init();
 
    void UpdateDynamicConfig(const PubCfg& cfg);
 
    void SetData(std::vector<std::vector<uint8_t>> data);
 
    const std::string& GetId() const {
        return m_id;
    }
 
private:
    void Run();
 
    // Helper function to fill a sample buffer with a pattern.
    void FillSample(std::vector<uint8_t>& sample_data, std::uint32_t sample_id);
 
    // cppcheck-suppress-begin unusedStructMember
 
    log4cplus::Logger& m_logger;
 
    std::string m_id;
 
    PubCfg m_cfg;
 
    // Buffers of sample data loaded from the data file i.e. provided by user.
    std::vector<std::vector<uint8_t>> m_user_samples_data;
 
    std::atomic<bool> m_send_sample;
    std::atomic<bool> m_stop;
 
    std::thread m_thread;
    // next members are used in Run method which is executed just in Running
    // ... and UpdateDynamicConfig which can be executed just in Idle, so should not be a problem
    // ... with race condition
    uint32_t m_n_frames_per_sample;
    unsigned int m_sample_id = 0;
    std::vector<uint8_t> m_sample_data;
 
    // cppcheck-suppress-end unusedStructMember
};
 
}  // namespace rtctk::mudpiPub
 
#endif  // RTCTK_REUSABLECOMPONENT_MUDPIPUB_PUBLISHER_HPP