DDS_SubscriberListener_cd Struct Reference

The DDS_SubscriberListener_cd provides asynchronous notification of DDS_Subscriber events with additional callback data. More...

Public Attributes
void(*	on_requested_deadline_missed )(struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_RequestedDeadlineMissedStatus status, void *callback_data)
void(*	on_requested_incompatible_qos )(struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_RequestedIncompatibleQosStatus status, void *callback_data)
void(*	on_sample_rejected )(struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_SampleRejectedStatus status, void *callback_data)
void(*	on_liveliness_changed )(struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_LivelinessChangedStatus status, void *callback_data)
void(*	on_data_available )(struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, void *callback_data)
void(*	on_subscription_matched )(struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_SubscriptionMatchedStatus status, void *callback_data)
void(*	on_sample_lost )(struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_SampleLostStatus status, void *callback_data)
void(*	on_data_on_readers )(struct DDS_SubscriberListener_cd *self, DDS_Subscriber the_subscriber, void *callback_data)

Detailed Description

The DDS_SubscriberListener_cd provides asynchronous notification of DDS_Subscriber events with additional callback data.

This listener can be installed by calling DDS_Subscriber_set_listener_cd().

Note

The listener callback methods should be lightweight and should not block. If a callback method blocks, it will block all other callback operations within the same DomainParticipant.

Member Data Documentation

void(* DDS_SubscriberListener_cd::on_data_available) (struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, void *callback_data)

on_data_available() is called when the CoreDX DDS middleware detects that a DataReader contained in the Subscriber has new data or data state information available. This listener is invoked only if the concerned DDS_DataReader does not have an on_data_available listener installed.

The status argument provides a snapshot of the status at the time the listener was invoked.

void(* DDS_SubscriberListener_cd::on_data_on_readers) (struct DDS_SubscriberListener_cd *self, DDS_Subscriber the_subscriber, void *callback_data)

on_data_on_readers() is called when the CoreDX DDS middleware detects that data or data state information arrives at any DataReader contained within the Subscriber.

The status argument provides a snapshot of the status at the time the listener was invoked.

void(* DDS_SubscriberListener_cd::on_liveliness_changed) (struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_LivelinessChangedStatus status, void *callback_data)

on_liveliness_changed() is called when the CoreDX DDS middleware detects that the liveliness of a DataWriter, matched to a DataReader within this Subscriber, has changed (either 'active' or 'inactive'). This listener is invoked only if the concerned DDS_DataReader does not have an on_liveliness_changed listener installed.

The status argument provides a snapshot of the status at the time the listener was invoked.

void(* DDS_SubscriberListener_cd::on_requested_deadline_missed) (struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_RequestedDeadlineMissedStatus status, void *callback_data)

on_requested_deadline_missed() is called when the CoreDX DDS middleware detects that the QoS DEADLINE policy of a DataReader, contained in this Subscriber, was not satisfied for a data instance. This listener is invoked only if the concerned DDS_DataReader does not have an on_requested_deadline_missed listener installed.

The status argument provides a snapshot of the status at the time the listener was invoked.

void(* DDS_SubscriberListener_cd::on_requested_incompatible_qos) (struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_RequestedIncompatibleQosStatus status, void *callback_data)

on_requested_incompatible_qos() is called when the CoreDX DDS middleware detects that a DataReader contained in the Subscriber has requested a QoS policy that was incompatible with that offered by a DataWriter. This listener is invoked only if the concerned DDS_DataReader does not have an on_requested_incompatible_qos listener installed.

The status argument provides a snapshot of the status at the time the listener was invoked.

void(* DDS_SubscriberListener_cd::on_sample_lost) (struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_SampleLostStatus status, void *callback_data)

on_sample_lost() is called when the CoreDX DDS middleware detects that a DataReader contained in the Subscriber has lost a sample (never received). This listener is invoked only if the concerned DDS_DataReader does not have an on_sample_lost listener installed.

The status argument provides a snapshot of the status at the time the listener was invoked.

void(* DDS_SubscriberListener_cd::on_sample_rejected) (struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_SampleRejectedStatus status, void *callback_data)

on_sample_rejected() is called when the CoreDX DDS middleware detects that a DataReader contained in the Subscriber has rejected a sample. This listener is invoked only if the concerned DDS_DataReader does not have an on_sample_rejected listener installed.

The status argument provides a snapshot of the status at the time the listener was invoked.

void(* DDS_SubscriberListener_cd::on_subscription_matched) (struct DDS_SubscriberListener_cd *self, DDS_DataReader the_reader, DDS_SubscriptionMatchedStatus status, void *callback_data)

on_subscription_matched() is called when the CoreDX DDS middleware detects that a DataReader contained in the Subscriber has matched or ceased to be matched with a DataWriter. This listener is invoked only if the concerned DDS_DataReader does not have an on_subscription_matched listener installed.

The status argument provides a snapshot of the status at the time the listener was invoked.