OpenDDS::DCPS::TransportSendListener Class Reference

#include <TransportSendListener.h>

Inheritance diagram for OpenDDS::DCPS::TransportSendListener:

[legend]

Collaboration diagram for OpenDDS::DCPS::TransportSendListener:

[legend]

List of all members.

Classes
struct	InlineQosData
Public Member Functions
virtual	~TransportSendListener ()
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)
virtual void	notify_publication_disconnected (const ReaderIdSeq &subids)=0
virtual void	notify_publication_reconnected (const ReaderIdSeq &subids)=0
virtual void	notify_publication_lost (const ReaderIdSeq &subids)=0
virtual void	remove_associations (const ReaderIdSeq &subids, bool notify)=0
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
Protected Member Functions
	TransportSendListener ()

---

Detailed Description

Definition at line 37 of file TransportSendListener.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::TransportSendListener::~TransportSendListener

(

)

[virtual]

Definition at line 23 of file TransportSendListener.cpp.

References DBG_ENTRY_LVL.

{
  DBG_ENTRY_LVL("TransportSendListener","~TransportSendListener",6);
}

OpenDDS::DCPS::TransportSendListener::TransportSendListener

(

)

[protected]

Definition at line 18 of file TransportSendListener.cpp.

References DBG_ENTRY_LVL.

{
  DBG_ENTRY_LVL("TransportSendListener","TransportSendListener",6);
}

---

Member Function Documentation

void OpenDDS::DCPS::TransportSendListener::control_delivered

(

const Message_Block_Ptr &

sample

)

[virtual]

Reimplemented in OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::ReplayerImpl, OpenDDS::RTPS::Sedp::Writer, and OpenDDS::DCPS::SendResponseListener.

Definition at line 47 of file TransportSendListener.cpp.

References LM_ERROR.

{
  ACE_UNUSED_ARG(sample);
  ACE_ERROR((LM_ERROR,
             "(%P|%t) ERROR: Subclass should override if sending control samples.\n"));
}

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

Reimplemented in OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::ReplayerImpl, OpenDDS::RTPS::Sedp::Writer, and OpenDDS::DCPS::SendResponseListener.

Definition at line 55 of file TransportSendListener.cpp.

References LM_ERROR.

{
  ACE_UNUSED_ARG(sample);
  ACE_UNUSED_ARG(dropped_by_transport);
  ACE_ERROR((LM_ERROR,
             "(%P|%t) ERROR: Subclass should override if sending control samples.\n"));
}

void OpenDDS::DCPS::TransportSendListener::data_delivered

(

const DataSampleElement *

sample

)

[virtual]

Reimplemented in OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::ReplayerImpl, OpenDDS::RTPS::Sedp::Writer, and OpenDDS::DCPS::SendResponseListener.

Definition at line 29 of file TransportSendListener.cpp.

References LM_ERROR.

Referenced by OpenDDS::DCPS::TransportSendElement::release_element(), and OpenDDS::DCPS::TransportClient::send_i().

{
  ACE_UNUSED_ARG(sample);
  ACE_ERROR((LM_ERROR,
             "(%P|%t) ERROR: Subclass should override if sending data samples.\n"));
}

Here is the caller graph for this function:

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

Reimplemented in OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::ReplayerImpl, OpenDDS::RTPS::Sedp::Writer, and OpenDDS::DCPS::SendResponseListener.

Definition at line 37 of file TransportSendListener.cpp.

References LM_ERROR.

Referenced by OpenDDS::DCPS::TransportSendElement::release_element().

{
  ACE_UNUSED_ARG(sample);
  ACE_UNUSED_ARG(dropped_by_transport);
  ACE_ERROR((LM_ERROR,
             "(%P|%t) ERROR: Subclass should override if sending data samples.\n"));
}

Here is the caller graph for this function:

virtual void OpenDDS::DCPS::TransportSendListener::notify_publication_disconnected

(

const ReaderIdSeq &

subids

)

[pure virtual]

Implemented in OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::ReplayerImpl, OpenDDS::RTPS::Sedp::Writer, and OpenDDS::DCPS::SendResponseListener.

virtual void OpenDDS::DCPS::TransportSendListener::notify_publication_lost

(

const ReaderIdSeq &

subids

)

[pure virtual]

Implemented in OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::ReplayerImpl, OpenDDS::RTPS::Sedp::Writer, and OpenDDS::DCPS::SendResponseListener.

virtual void OpenDDS::DCPS::TransportSendListener::notify_publication_reconnected

(

const ReaderIdSeq &

subids

)

[pure virtual]

Implemented in OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::ReplayerImpl, OpenDDS::RTPS::Sedp::Writer, and OpenDDS::DCPS::SendResponseListener.

virtual void OpenDDS::DCPS::TransportSendListener::remove_associations	(	const ReaderIdSeq &	subids,
		bool	notify
	)			[pure virtual]

Implemented in OpenDDS::DCPS::DataWriterImpl, OpenDDS::RTPS::Sedp::Writer, and OpenDDS::DCPS::SendResponseListener.

void OpenDDS::DCPS::TransportSendListener::retrieve_inline_qos_data

(

InlineQosData &

qos_data

)

const [virtual]

Reimplemented in OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::ReplayerImpl, and OpenDDS::RTPS::Sedp::Writer.

Definition at line 73 of file TransportSendListener.cpp.

References OpenDDS::DCPS::TransportSendListener::InlineQosData::dw_qos, OpenDDS::DCPS::TransportSendListener::InlineQosData::pub_qos, TheServiceParticipant, and OpenDDS::DCPS::TransportSendListener::InlineQosData::topic_name.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), and OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages().

{
  qos_data.dw_qos     = TheServiceParticipant->initial_DataWriterQos();
  qos_data.pub_qos    = TheServiceParticipant->initial_PublisherQos();
  qos_data.topic_name = "";
}

Here is the caller graph for this function:

SendControlStatus OpenDDS::DCPS::TransportSendListener::send_control_customized	(	const DataLinkSet_rch &	links,
		const DataSampleHeader &	header,
		ACE_Message_Block *	msg,
		void *	extra
	)			[virtual]

Hook for the listener to override a normal control message with customized messages to different DataLinks.

Definition at line 65 of file TransportSendListener.cpp.

References OpenDDS::DCPS::SEND_CONTROL_OK.

{
  return SEND_CONTROL_OK;
}

---

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

• TransportSendListener.h
• TransportSendListener.cpp