#include <WriterInfo.h>
Public Member Functions | |
| WriterInfoListener () | |
| virtual | ~WriterInfoListener () |
| virtual void | writer_became_alive (WriterInfo &info, const MonotonicTimePoint &when) |
| virtual void | writer_became_dead (WriterInfo &info) |
| virtual void | writer_removed (WriterInfo &info) |
 Public Member Functions inherited from OpenDDS::DCPS::RcObject | |
| virtual | ~RcObject () |
| virtual void | _add_ref () |
| virtual void | _remove_ref () |
| long | ref_count () const |
| WeakObject * | _get_weak_object () const |
Public Attributes | |
| GUID_t | subscription_id_ |
| TimeDuration | liveliness_lease_duration_ |
Additional Inherited Members | |
| Protected Member Functions inherited from OpenDDS::DCPS::RcObject | |
| RcObject () | |
Detailed Description
Definition at line 38 of file WriterInfo.h.
Constructor & Destructor Documentation
◆ WriterInfoListener()
| OpenDDS::DCPS::WriterInfoListener::WriterInfoListener | ( | ) |
Definition at line 23 of file WriterInfo.cpp.
◆ ~WriterInfoListener()
|
virtual |
Definition at line 28 of file WriterInfo.cpp.
Member Function Documentation
◆ writer_became_alive()
|
virtual |
tell instances when a DataWriter transitions to being alive The writer state is inout parameter, it has to be set ALIVE before handle_timeout is called since some subroutine use the state.
Reimplemented in OpenDDS::DCPS::DataReaderImpl.
Definition at line 36 of file WriterInfo.cpp.
◆ writer_became_dead()
|
virtual |
tell instances when a DataWriter transitions to DEAD The writer state is inout parameter, the state is set to DEAD when it returns.
Reimplemented in OpenDDS::DCPS::DataReaderImpl.
Definition at line 45 of file WriterInfo.cpp.
◆ writer_removed()
|
virtual |
tell instance when a DataWriter is removed. The liveliness status need update.
Reimplemented in OpenDDS::DCPS::DataReaderImpl.
Definition at line 52 of file WriterInfo.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), Update::DataWriterQos, OpenDDS::DCPS::DCPS_debug_level, DDS::HANDLE_NIL, LM_DEBUG, OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), and OpenDDS::DCPS::WriterInfo::WriterInfo().
Member Data Documentation
◆ liveliness_lease_duration_
| TimeDuration OpenDDS::DCPS::WriterInfoListener::liveliness_lease_duration_ |
The time interval for checking liveliness. TBD: Should this be initialized with DDS::DURATION_INFINITE_SEC and DDS::DURATION_INFINITE_NSEC instead of ACE_Time_Value::zero to be consistent with default duration qos ? Or should we simply use the ACE_Time_Value::zero to indicate the INFINITY duration ?
Definition at line 52 of file WriterInfo.h.
Referenced by OpenDDS::DCPS::DataReaderImpl::enable(), and OpenDDS::DCPS::DataReaderImpl::transport_assoc_done().
◆ subscription_id_
| GUID_t OpenDDS::DCPS::WriterInfoListener::subscription_id_ |
Definition at line 44 of file WriterInfo.h.
Referenced by OpenDDS::DCPS::RecorderImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::add_association(), OpenDDS::DCPS::RecorderImpl::cleanup(), OpenDDS::DCPS::RecorderImpl::data_received(), OpenDDS::DCPS::RecorderImpl::enable(), OpenDDS::DCPS::DataReaderImpl::enable(), OpenDDS::DCPS::RecorderImpl::get_guid(), OpenDDS::DCPS::RecorderImpl::get_instance_handle(), OpenDDS::DCPS::DataReaderImpl::get_instance_handle(), OpenDDS::DCPS::RecorderImpl::remove_associations(), OpenDDS::DCPS::RecorderImpl::remove_associations_i(), OpenDDS::DCPS::RecorderImpl::set_qos(), OpenDDS::DCPS::DataReaderImpl::set_qos(), and OpenDDS::DCPS::DataReaderImpl::~DataReaderImpl().
The documentation for this class was generated from the following files:
