shmPublisher.hpp

Go to the documentation of this file.

 
#ifndef RTCKT_TELSUB_SHMPUBLISHER_HPP
#define RTCKT_TELSUB_SHMPUBLISHER_HPP
#include <cstdint>
#include <system_error>
#include <vector>
 
#include <ipcq/writer.hpp>
 
#include "dataSample.hpp"
#include "shmPublisherIf.hpp"
 
namespace rtctk::telSub {
 
template <class UserTopicType, class DataBlender, class ShmWriter = ipcq::Writer<UserTopicType>>
class ShmPublisher final : public ShmPublisherIf {
public:
    ShmPublisher(ShmWriter&& shm_writer, DataBlender& blender);
 
    std::error_code Publish(CorrelatedDataSamplesRef const& dds_samples) noexcept override;
 
    void CloseQueue() noexcept override;
private:
    UserTopicType m_topic;
    DataBlender& m_blender;
    ShmWriter m_shm;
};
 
template <class UserTopicType, class DataBlender, class ShmWriter>
auto MakeShmPublisher(ShmWriter&& shm_writer, DataBlender& blender)
    -> std::unique_ptr<ShmPublisher<UserTopicType, DataBlender, ShmWriter>> {
    return std::make_unique<ShmPublisher<UserTopicType, DataBlender, ShmWriter>>(
        std::move(shm_writer), blender);
}
 
template <class UserTopicType, class DataBlender, class ShmWriter>
ShmPublisher<UserTopicType, DataBlender, ShmWriter>::ShmPublisher(ShmWriter&& shm_writer,
                                                                  DataBlender& blender)
    : m_topic()
    , m_blender(blender)
    , m_shm(std::move(shm_writer)) {
    static_assert(std::is_invocable_r<std::error_code,
                                      DataBlender,
                                      rtctk::telSub::CorrelatedDataSamplesRef const&,
                                      UserTopicType&>::value,
                  "DataBlender must have the signature "
                  "`std::error_code(const rtctk::telSub::CorrelatedDataSamplesRef&, "
                  "UserTopicType&)`");
}
 
template <class UserTopicType, class DataBlender, class ShmWriter>
std::error_code ShmPublisher<UserTopicType, DataBlender, ShmWriter>::Publish(
    CorrelatedDataSamplesRef const& dds_samples) noexcept {
    // Invoke blender and write to SHM queue.
    if (auto err = m_blender(dds_samples, m_topic); !err) /*[[likely]]*/ {
        return m_shm.Write(m_topic, ipcq::Notify::All);
    } else /*[[unlikely]]*/ {
        return err;
    }
}
 
template <class UserTopicType, class DataBlender, class ShmWriter>
void ShmPublisher<UserTopicType, DataBlender, ShmWriter>::CloseQueue() noexcept {
    m_shm.Close();
}
 
 
}  // namespace rtctk::telSub
#endif  // #ifndef RTCKT_TELSUB_SHMPUBLISHER_HPP