rmw_fastrtps_shared_cpp  master
Code shared on static and dynamic type support of rmw_fastrtps_cpp.
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
Public Member Functions | List of all members
PubListener Class Reference

#include <custom_publisher_info.hpp>

Inheritance diagram for PubListener:
Inheritance graph
[legend]
Collaboration diagram for PubListener:
Collaboration graph
[legend]

Public Member Functions

 PubListener (CustomPublisherInfo *info)
 
void onPublicationMatched (eprosima::fastrtps::Publisher *pub, eprosima::fastrtps::rtps::MatchingInfo &info) final
 
void on_offered_deadline_missed (eprosima::fastrtps::Publisher *publisher, const eprosima::fastrtps::OfferedDeadlineMissedStatus &status) final
 
void on_liveliness_lost (eprosima::fastrtps::Publisher *publisher, const eprosima::fastrtps::LivelinessLostStatus &status) final
 
bool hasEvent (rmw_event_type_t event_type) const final
 Check if there is new data available for a specific event type. More...
 
bool takeNextEvent (rmw_event_type_t event_type, void *event_info) final
 Take ready data for an event type. More...
 
size_t subscriptionCount ()
 
void attachCondition (std::mutex *conditionMutex, std::condition_variable *conditionVariable)
 Connect a condition variable so a waiter can be notified of new data. More...
 
void detachCondition ()
 Unset the information from attachCondition. More...
 

Constructor & Destructor Documentation

◆ PubListener()

PubListener::PubListener ( CustomPublisherInfo info)
inlineexplicit

Member Function Documentation

◆ onPublicationMatched()

void PubListener::onPublicationMatched ( eprosima::fastrtps::Publisher *  pub,
eprosima::fastrtps::rtps::MatchingInfo &  info 
)
inlinefinal

◆ on_offered_deadline_missed()

void PubListener::on_offered_deadline_missed ( eprosima::fastrtps::Publisher *  publisher,
const eprosima::fastrtps::OfferedDeadlineMissedStatus &  status 
)
final

◆ on_liveliness_lost()

void PubListener::on_liveliness_lost ( eprosima::fastrtps::Publisher *  publisher,
const eprosima::fastrtps::LivelinessLostStatus &  status 
)
final

◆ hasEvent()

bool PubListener::hasEvent ( rmw_event_type_t  event_type) const
finalvirtual

Check if there is new data available for a specific event type.

Parameters
event_typeThe event type to check on.
Returns
true if new data is available.

Implements EventListenerInterface.

◆ takeNextEvent()

bool PubListener::takeNextEvent ( rmw_event_type_t  event_type,
void *  event_info 
)
finalvirtual

Take ready data for an event type.

Parameters
event_typeThe event type to get data for.
event_infoA preallocated event information (from rmw/types.h) to fill with data
Returns
true if data was successfully taken.
false if data was not available, in this case nothing was written to event_info.

Implements EventListenerInterface.

◆ subscriptionCount()

size_t PubListener::subscriptionCount ( )
inline

◆ attachCondition()

void PubListener::attachCondition ( std::mutex conditionMutex,
std::condition_variable conditionVariable 
)
inlinevirtual

Connect a condition variable so a waiter can be notified of new data.

Implements EventListenerInterface.

◆ detachCondition()

void PubListener::detachCondition ( )
inlinevirtual

Unset the information from attachCondition.

Implements EventListenerInterface.


The documentation for this class was generated from the following file: