OpenDDS::DCPS::SendResponseListener Class Reference

Simple listener to discard response samples. More...

#include <SendResponseListener.h>

Inheritance diagram for OpenDDS::DCPS::SendResponseListener:

Collaboration diagram for OpenDDS::DCPS::SendResponseListener:

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	replay_durable_data_for (const GUID_t &)
void	track_message ()
Public Member Functions inherited from OpenDDS::DCPS::TransportSendListener
virtual	~TransportSendListener ()
virtual void	data_acked (const GUID_t &)
virtual SendControlStatus	send_control_customized (const DataLinkSet_rch &links, const DataSampleHeader &header, ACE_Message_Block *msg, void *extra)
virtual void	retrieve_inline_qos_data (InlineQosData &qos_data) const
virtual void	transport_discovery_change ()
Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()
long	ref_count () const
WeakObject *	_get_weak_object () const

Private Member Functions
void	_add_ref ()
void	_remove_ref ()

Private Attributes
MessageTracker	tracker_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::TransportSendListener
	TransportSendListener ()
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

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

SendResponseListener()

OpenDDS::DCPS::SendResponseListener::SendResponseListener ( const OPENDDS_STRING &  msg_src )

explicit

Definition at line 18 of file SendResponseListener.cpp.

: tracker_(msg_src)
{
}

~SendResponseListener()

OpenDDS::DCPS::SendResponseListener::~SendResponseListener ( )

virtual

Definition at line 23 of file SendResponseListener.cpp.

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

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

Member Function Documentation

_add_ref()

void OpenDDS::DCPS::SendResponseListener::_add_ref ( void  )

inlineprivatevirtual

Reimplemented from OpenDDS::DCPS::RcObject.

Definition at line 53 of file SendResponseListener.h.

{}

_remove_ref()

void OpenDDS::DCPS::SendResponseListener::_remove_ref ( void  )

inlineprivatevirtual

Reimplemented from OpenDDS::DCPS::RcObject.

Definition at line 54 of file SendResponseListener.h.

{}

control_delivered()

void OpenDDS::DCPS::SendResponseListener::control_delivered ( const Message_Block_Ptr &  sample )

virtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 43 of file SendResponseListener.cpp.

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

{
  tracker_.message_delivered();
}

control_dropped()

void OpenDDS::DCPS::SendResponseListener::control_dropped ( const Message_Block_Ptr &  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_.

{
  tracker_.message_dropped();
}

data_delivered()

void OpenDDS::DCPS::SendResponseListener::data_delivered ( const DataSampleElement *  sample )

virtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 29 of file SendResponseListener.cpp.

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

{
  tracker_.message_delivered();
}

data_dropped()

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

virtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 35 of file SendResponseListener.cpp.

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

{
  tracker_.message_dropped();
}

notify_publication_disconnected()

void OpenDDS::DCPS::SendResponseListener::notify_publication_disconnected ( const ReaderIdSeq &  )

inlinevirtual

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 44 of file SendResponseListener.h.

{}

notify_publication_lost()

void OpenDDS::DCPS::SendResponseListener::notify_publication_lost ( const ReaderIdSeq &  )

inlinevirtual

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 46 of file SendResponseListener.h.

{}

notify_publication_reconnected()

void OpenDDS::DCPS::SendResponseListener::notify_publication_reconnected ( const ReaderIdSeq &  )

inlinevirtual

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 45 of file SendResponseListener.h.

{}

remove_associations()

void OpenDDS::DCPS::SendResponseListener::remove_associations ( const ReaderIdSeq &  , bool    )

inlinevirtual

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 47 of file SendResponseListener.h.

{}

replay_durable_data_for()

void OpenDDS::DCPS::SendResponseListener::replay_durable_data_for ( const GUID_t &  )

inlinevirtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 48 of file SendResponseListener.h.

{}

track_message()

void OpenDDS::DCPS::SendResponseListener::track_message

(

)

Definition at line 57 of file SendResponseListener.cpp.

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

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

{
  tracker_.message_sent();
}

Member Data Documentation

tracker_

MessageTracker OpenDDS::DCPS::SendResponseListener::tracker_

private

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