OpenDDS::DCPS::WriterInfoListener Class Reference

#include <WriterInfo.h>

Inheritance diagram for OpenDDS::DCPS::WriterInfoListener:

[legend]

Collaboration diagram for OpenDDS::DCPS::WriterInfoListener:

[legend]

List of all members.

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_

---

Detailed Description

Definition at line 28 of file WriterInfo.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::WriterInfoListener::WriterInfoListener

(

)

Definition at line 22 of file WriterInfo.cpp.

  : subscription_id_(GUID_UNKNOWN),
  liveliness_lease_duration_(ACE_Time_Value::zero)
{
}

OpenDDS::DCPS::WriterInfoListener::~WriterInfoListener

(

)

[virtual]

Definition at line 28 of file WriterInfo.cpp.

{
}

---

Member Function Documentation

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 36 of file WriterInfo.cpp.

Referenced by OpenDDS::DCPS::WriterInfo::received_activity().

{
}

Here is the caller graph for this function:

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 45 of file WriterInfo.cpp.

Referenced by OpenDDS::DCPS::WriterInfo::check_activity().

{
}

Here is the caller graph for this function:

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 53 of file WriterInfo.cpp.

Referenced by OpenDDS::DCPS::WriterInfo::removed().

{
}

Here is the caller graph for this function:

---

Member Data Documentation

ACE_Time_Value 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 42 of file WriterInfo.h.

Referenced by OpenDDS::DCPS::WriterInfo::activity_wait_period(), OpenDDS::DCPS::WriterInfo::check_activity(), OpenDDS::DCPS::DataReaderImpl::enable(), and OpenDDS::DCPS::DataReaderImpl::transport_assoc_done().

RepoId OpenDDS::DCPS::WriterInfoListener::subscription_id_

Definition at line 34 of file WriterInfo.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::accept_coherent(), OpenDDS::DCPS::DataReaderImpl::accept_sample_processing(), 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::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::ownership_filter_instance(), OpenDDS::DCPS::DataReaderImpl::process_latency(), OpenDDS::DCPS::DataReaderImpl::reject_coherent(), OpenDDS::DCPS::DataReaderImpl::remove_associations(), OpenDDS::DCPS::RecorderImpl::remove_associations_i(), OpenDDS::DCPS::DataReaderImpl::remove_associations_i(), OpenDDS::DCPS::WriterInfo::set_group_info(), OpenDDS::DCPS::RecorderImpl::set_qos(), OpenDDS::DCPS::DataReaderImpl::set_qos(), OpenDDS::DCPS::DataReaderImpl::transport_assoc_done(), OpenDDS::DCPS::DataReaderImpl::update_ownership_strength(), OpenDDS::DCPS::DataReaderImpl::update_subscription_params(), OpenDDS::DCPS::DataReaderImpl::writer_activity(), OpenDDS::DCPS::DataReaderImpl::writer_became_alive(), OpenDDS::DCPS::DataReaderImpl::writer_became_dead(), and OpenDDS::DCPS::DataReaderImpl::writer_removed().

---

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

• WriterInfo.h
• WriterInfo.cpp