ddsWriterListener.hpp

Go to the documentation of this file.

#ifndef RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDS_WRITER_LISTENER_HPP
#define RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDS_WRITER_LISTENER_HPP
 
#include <log4cplus/logger.h>
#include <rtctk/componentFramework/ddsCommon.hpp>
 
namespace rtctk::componentFramework {

class DdsWriterListener : public virtual DataWriterListener {
public:
    // Constructor
    DdsWriterListener();
 
    // Destructor
    ~DdsWriterListener() noexcept override = default;
 
    void on_offered_deadline_missed(DataWriter* writer,
                                    const OfferedDeadlineMissedStatus& status) override;
 
    void on_offered_incompatible_qos(DataWriter* writer,
                                     const OfferedIncompatibleQosStatus& status) override;
 
    void on_liveliness_lost(DataWriter* writer, const LivelinessLostStatus& status) override;
 
    void
    on_publication_matched(DataWriter* writer, const PublicationMatchedStatus& status) override;
 
    uint16_t GetMatched() const {
        return m_matched_subs;
    }
 
protected:
    uint32_t m_sum_unacknowledged_sample = 0;
    uint32_t m_max_unacknowledged_sample = 0;
    uint32_t m_iter = 0;
    std::atomic<uint16_t> m_matched_subs = 0;
 
    log4cplus::Logger m_logger;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDS_WRITER_LISTENER_HPP