#include <WriterInfo.h>
Inheritance diagram for OpenDDS::DCPS::WriterInfoListener:
Public Member Functions | |
WriterInfoListener () | |
virtual | ~WriterInfoListener () |
virtual void | writer_became_alive (WriterInfo &info, const ACE_Time_Value &when) |
virtual void | writer_became_dead (WriterInfo &info, const ACE_Time_Value &when) |
virtual void | writer_removed (WriterInfo &info) |
Public Attributes | |
RepoId | subscription_id_ |
ACE_Time_Value | liveliness_lease_duration_ |
Definition at line 26 of file WriterInfo.h.
OpenDDS::DCPS::WriterInfoListener::WriterInfoListener | ( | ) |
Definition at line 20 of file WriterInfo.cpp.
00021 : subscription_id_(GUID_UNKNOWN), 00022 liveliness_lease_duration_(ACE_Time_Value::zero) 00023 { 00024 }
OpenDDS::DCPS::WriterInfoListener::~WriterInfoListener | ( | ) | [virtual] |
void OpenDDS::DCPS::WriterInfoListener::writer_became_alive | ( | WriterInfo & | info, | |
const ACE_Time_Value & | when | |||
) | [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 34 of file WriterInfo.cpp.
Referenced by OpenDDS::DCPS::WriterInfo::received_activity().
void OpenDDS::DCPS::WriterInfoListener::writer_became_dead | ( | WriterInfo & | info, | |
const ACE_Time_Value & | when | |||
) | [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 43 of file WriterInfo.cpp.
Referenced by OpenDDS::DCPS::WriterInfo::check_activity().
void OpenDDS::DCPS::WriterInfoListener::writer_removed | ( | WriterInfo & | info | ) | [virtual] |
tell instance when a DataWriter is removed. The liveliness status need update.
Reimplemented in OpenDDS::DCPS::DataReaderImpl.
Definition at line 51 of file WriterInfo.cpp.
Referenced by OpenDDS::DCPS::WriterInfo::removed().
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 40 of file WriterInfo.h.
Referenced by OpenDDS::DCPS::WriterInfo::active(), OpenDDS::DCPS::WriterInfo::check_activity(), OpenDDS::DCPS::DataReaderImpl::enable(), and OpenDDS::DCPS::DataReaderImpl::transport_assoc_done().
Definition at line 32 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::DataReaderImpl::data_received(), OpenDDS::DCPS::RecorderImpl::enable(), OpenDDS::DCPS::DataReaderImpl::enable(), OpenDDS::DCPS::DataReaderImpl::filter_instance(), OpenDDS::DCPS::RecorderImpl::get_instance_handle(), OpenDDS::DCPS::DataReaderImpl::get_instance_handle(), OpenDDS::DCPS::RecorderImpl::get_repo_id(), OpenDDS::DCPS::DataReaderImpl::get_subscription_id(), OpenDDS::DCPS::DataReaderImpl::notify_liveliness_change(), OpenDDS::DCPS::DataReaderImpl::process_latency(), OpenDDS::DCPS::DataReaderImpl::remove_associations(), OpenDDS::DCPS::RecorderImpl::remove_associations_i(), OpenDDS::DCPS::DataReaderImpl::remove_associations_i(), OpenDDS::DCPS::DataReaderImpl::set_qos(), OpenDDS::DCPS::DataReaderImpl::transport_assoc_done(), OpenDDS::DCPS::DataReaderImpl::update_subscription_params(), OpenDDS::DCPS::DataReaderImpl::writer_activity(), OpenDDS::DCPS::DataReaderImpl::writer_became_alive(), OpenDDS::DCPS::DataReaderImpl::writer_became_dead(), OpenDDS::DCPS::DataReaderImpl::writer_removed(), and OpenDDS::DCPS::WriterInfo::WriterInfo().