publisher.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_MUDPIPUB_PUBLISHER_HPP
#define RTCTK_REUSABLECOMPONENT_MUDPIPUB_PUBLISHER_HPP
 
#include <semaphore>
#include <string>
#include <thread>
#include <vector>
 
#include <rtctk/componentFramework/logger.hpp>
#include <rtctk/mudpiPub/config.hpp>
 
namespace rtctk::mudpiPub {
 
// forward declaration to hide internally used class
class SampleGenerator;

class Publisher {
public:
    /*
     * @brief type alias for provided user data
     *
     * user data is basially a vector of blobs, where each element represents a sample
     */
    using UserSamples = std::vector<std::vector<uint8_t>>;

    Publisher(const std::string& pub_id, const PubCfg& cfg, UserSamples data = {});

    virtual ~Publisher();

    void SendSample();

    void WaitUntilSendingDone();

    void Init();

    void UpdateDynamicConfig(const PubDynamicCfg& cfg, UserSamples user_samples = {});

    const std::string& GetId() const {
        return m_id;
    }
 
private:
    void Run(std::stop_token st);
 
    log4cplus::Logger& m_logger;
 
    std::string m_id;
 
    PubStaticCfg m_cfg;
 
    std::binary_semaphore m_sem_start;
    std::binary_semaphore m_sem_done;
 
    std::mutex m_generator_mutex;
    std::unique_ptr<SampleGenerator> m_generator;
 
    std::jthread m_thread;
};
 
}  // namespace rtctk::mudpiPub
 
#endif  // RTCTK_REUSABLECOMPONENT_MUDPIPUB_PUBLISHER_HPP