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 (ACE_Message_Block *sample)
virtual void	control_dropped (ACE_Message_Block *sample, bool dropped_by_transport)
void	notify_publication_disconnected (const ReaderIdSeq &)
void	notify_publication_reconnected (const ReaderIdSeq &)
void	notify_publication_lost (const ReaderIdSeq &)
void	notify_connection_deleted (const RepoId &)
void	remove_associations (const ReaderIdSeq &, bool)
void	track_message ()
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 28 of file SendResponseListener.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::SendResponseListener::SendResponseListener

(

const OPENDDS_STRING &

msg_src

)

Definition at line 16 of file SendResponseListener.cpp.

: tracker_(msg_src)
{
}

OpenDDS::DCPS::SendResponseListener::~SendResponseListener

(

)

[virtual]

Definition at line 21 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);
}

---

Member Function Documentation

void OpenDDS::DCPS::SendResponseListener::control_delivered

(

ACE_Message_Block *

sample

)

[virtual]

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 42 of file SendResponseListener.cpp.

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

{
  if (sample != 0) sample->release();
  tracker_.message_delivered();
}

void OpenDDS::DCPS::SendResponseListener::control_dropped	(	ACE_Message_Block *	sample,
		bool	dropped_by_transport
	)			[virtual]

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 49 of file SendResponseListener.cpp.

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

{
  if (sample != 0) sample->release();
  tracker_.message_dropped();
}

void OpenDDS::DCPS::SendResponseListener::data_delivered

(

const DataSampleElement *

sample

)

[virtual]

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 28 of file SendResponseListener.cpp.

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

{
  tracker_.message_delivered();
}

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

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 34 of file SendResponseListener.cpp.

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

{
  tracker_.message_dropped();
}

void OpenDDS::DCPS::SendResponseListener::notify_connection_deleted

(

const RepoId &

)

[inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 45 of file SendResponseListener.h.

{}

void OpenDDS::DCPS::SendResponseListener::notify_publication_disconnected

(

const ReaderIdSeq &

)

[inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 42 of file SendResponseListener.h.

{}

void OpenDDS::DCPS::SendResponseListener::notify_publication_lost

(

const ReaderIdSeq &

)

[inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 44 of file SendResponseListener.h.

{}

void OpenDDS::DCPS::SendResponseListener::notify_publication_reconnected

(

const ReaderIdSeq &

)

[inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 43 of file SendResponseListener.h.

{}

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

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 46 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();
}

---

Member Data Documentation

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

Definition at line 50 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

---