OpenDDS::DCPS::SendResponseListener Class Reference

Simple listener to discard response samples. More...

#include <SendResponseListener.h>

Inheritance diagram for OpenDDS::DCPS::SendResponseListener:

[legend]

Collaboration diagram for OpenDDS::DCPS::SendResponseListener:

[legend]

List of all members.

Public Member Functions
	SendResponseListener (const OPENDDS_STRING &msg_src)
virtual	~SendResponseListener ()
virtual void	data_delivered (const DataSampleElement *sample)
virtual void	data_dropped (const DataSampleElement *sample, bool dropped_by_transport)
virtual void	control_delivered (const Message_Block_Ptr &sample)
virtual void	control_dropped (const Message_Block_Ptr &sample, bool dropped_by_transport)
void	notify_publication_disconnected (const ReaderIdSeq &)
void	notify_publication_reconnected (const ReaderIdSeq &)
void	notify_publication_lost (const ReaderIdSeq &)
void	remove_associations (const ReaderIdSeq &, bool)
void	track_message ()
Private Member Functions
void	_add_ref ()
void	_remove_ref ()
Private Attributes
MessageTracker	tracker_

---

Detailed Description

Simple listener to discard response samples.

This is a simple listener implementation used to release response samples once they have been either delivered or dropped. No special actions are taken to distinguish between the two results.

Definition at line 30 of file SendResponseListener.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::SendResponseListener::SendResponseListener

(

const OPENDDS_STRING &

msg_src

)

[explicit]

Definition at line 18 of file SendResponseListener.cpp.

: tracker_(msg_src)
{
}

OpenDDS::DCPS::SendResponseListener::~SendResponseListener

(

)

[virtual]

Definition at line 23 of file SendResponseListener.cpp.

References OPENDDS_STRING, tracker_, and OpenDDS::DCPS::MessageTracker::wait_messages_pending().

{
  OPENDDS_STRING caller_string("SendResponseListener::~SendResponseListener");
  tracker_.wait_messages_pending(caller_string);
}

Here is the call graph for this function:

---

Member Function Documentation

void OpenDDS::DCPS::SendResponseListener::_add_ref

(

void

)

[inline, private, virtual]

Reimplemented from OpenDDS::DCPS::RcObject.

Definition at line 52 of file SendResponseListener.h.

{}

void OpenDDS::DCPS::SendResponseListener::_remove_ref

(

void

)

[inline, private, virtual]

Reimplemented from OpenDDS::DCPS::RcObject.

Definition at line 53 of file SendResponseListener.h.

{}

void OpenDDS::DCPS::SendResponseListener::control_delivered

(

const Message_Block_Ptr &

sample

)

[virtual]

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 44 of file SendResponseListener.cpp.

References OpenDDS::DCPS::MessageTracker::message_delivered(), and tracker_.

{
  tracker_.message_delivered();
}

Here is the call graph for this function:

void OpenDDS::DCPS::SendResponseListener::control_dropped	(	const Message_Block_Ptr &	sample,
		bool	dropped_by_transport
	)			[virtual]

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 50 of file SendResponseListener.cpp.

References OpenDDS::DCPS::MessageTracker::message_dropped(), and tracker_.

{
  tracker_.message_dropped();
}

Here is the call graph for this function:

void OpenDDS::DCPS::SendResponseListener::data_delivered

(

const DataSampleElement *

sample

)

[virtual]

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 30 of file SendResponseListener.cpp.

References OpenDDS::DCPS::MessageTracker::message_delivered(), and tracker_.

{
  tracker_.message_delivered();
}

Here is the call graph for this function:

void OpenDDS::DCPS::SendResponseListener::data_dropped	(	const DataSampleElement *	sample,
		bool	dropped_by_transport
	)			[virtual]

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 36 of file SendResponseListener.cpp.

References OpenDDS::DCPS::MessageTracker::message_dropped(), and tracker_.

{
  tracker_.message_dropped();
}

Here is the call graph for this function:

void OpenDDS::DCPS::SendResponseListener::notify_publication_disconnected

(

const ReaderIdSeq &

)

[inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 44 of file SendResponseListener.h.

{}

void OpenDDS::DCPS::SendResponseListener::notify_publication_lost

(

const ReaderIdSeq &

)

[inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 46 of file SendResponseListener.h.

{}

void OpenDDS::DCPS::SendResponseListener::notify_publication_reconnected

(

const ReaderIdSeq &

)

[inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 45 of file SendResponseListener.h.

{}

void OpenDDS::DCPS::SendResponseListener::remove_associations	(	const ReaderIdSeq &	,
		bool
	)			[inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 47 of file SendResponseListener.h.

{}

void OpenDDS::DCPS::SendResponseListener::track_message

(

)

Definition at line 58 of file SendResponseListener.cpp.

References OpenDDS::DCPS::MessageTracker::message_sent(), and tracker_.

Referenced by OpenDDS::DCPS::DataLink::send_control(), and OpenDDS::DCPS::DataLinkSet::send_response().

{
  tracker_.message_sent();
}

Here is the call graph for this function:

Here is the caller graph for this function:

---

Member Data Documentation

MessageTracker OpenDDS::DCPS::SendResponseListener::tracker_ [private]

Definition at line 55 of file SendResponseListener.h.

Referenced by control_delivered(), control_dropped(), data_delivered(), data_dropped(), track_message(), and ~SendResponseListener().

---

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

• SendResponseListener.h
• SendResponseListener.cpp