#include <TransportSendListener.h>

Inheritance diagram for OpenDDS::DCPS::TransportSendListener:

[legend]

Collaboration diagram for OpenDDS::DCPS::TransportSendListener:

[legend]

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	data_acked (const GUID_t &)

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 void	replay_durable_data_for (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 ()

virtual void	_add_ref ()

virtual void	_remove_ref ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Protected Member Functions
	TransportSendListener ()

Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Definition at line 38 of file TransportSendListener.h.

Constructor & Destructor Documentation

◆ ~TransportSendListener()

OpenDDS::DCPS::TransportSendListener::~TransportSendListener ( )

virtual

Definition at line 23 of file TransportSendListener.cpp.

References DBG_ENTRY_LVL.

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

◆ TransportSendListener()

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

◆ control_delivered()

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

virtual

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

Definition at line 47 of file TransportSendListener.cpp.

References ACE_ERROR, and LM_ERROR.

Referenced by OpenDDS::DCPS::TransportSendControlElement::requires_exclusive_packet().

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

◆ control_dropped()

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

virtual

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

Definition at line 55 of file TransportSendListener.cpp.

References ACE_ERROR, and LM_ERROR.

Referenced by OpenDDS::DCPS::TransportSendControlElement::requires_exclusive_packet().

 {
   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"));
 }

◆ data_acked()

virtual void OpenDDS::DCPS::TransportSendListener::data_acked ( const GUID_t & )

inlinevirtual

Reimplemented in OpenDDS::RTPS::Sedp::Writer.

Definition at line 48 of file TransportSendListener.h.

48 {}

◆ data_delivered()

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

virtual

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

Definition at line 29 of file TransportSendListener.cpp.

References ACE_ERROR, and LM_ERROR.

Referenced by OpenDDS::DCPS::TransportSendElement::release_element(), OpenDDS::DCPS::TransportSendControlElement::requires_exclusive_packet(), 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"));
 }

◆ data_dropped()

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

virtual

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

Definition at line 37 of file TransportSendListener.cpp.

References ACE_ERROR, and LM_ERROR.

Referenced by OpenDDS::DCPS::TransportSendElement::release_element(), OpenDDS::DCPS::TransportSendControlElement::requires_exclusive_packet(), and OpenDDS::DCPS::DataLinkSet::send().

 {
   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"));
 }

◆ notify_publication_disconnected()

virtual void OpenDDS::DCPS::TransportSendListener::notify_publication_disconnected ( const ReaderIdSeq & subids )

pure virtual

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

◆ notify_publication_lost()

virtual void OpenDDS::DCPS::TransportSendListener::notify_publication_lost ( const ReaderIdSeq & subids )

pure virtual

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

◆ notify_publication_reconnected()

virtual void OpenDDS::DCPS::TransportSendListener::notify_publication_reconnected ( const ReaderIdSeq & subids )

pure virtual

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

◆ remove_associations()

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

pure virtual

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

◆ replay_durable_data_for()

virtual void OpenDDS::DCPS::TransportSendListener::replay_durable_data_for ( const GUID_t & )

inlinevirtual

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

Definition at line 60 of file TransportSendListener.h.

References header.

60 {}

◆ retrieve_inline_qos_data()

void OpenDDS::DCPS::TransportSendListener::retrieve_inline_qos_data ( InlineQosData & qos_data ) const

virtual

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

Definition at line 73 of file TransportSendListener.cpp.

References OpenDDS::DCPS::TransportSendListener::InlineQosData::dw_qos, OPENDDS_END_VERSIONED_NAMESPACE_DECL, 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 = "";
 }

◆ send_control_customized()

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;
 }

◆ transport_discovery_change()

virtual void OpenDDS::DCPS::TransportSendListener::transport_discovery_change ( )

inlinevirtual

Reimplemented in OpenDDS::DCPS::DataWriterImpl.

Definition at line 78 of file TransportSendListener.h.

78 {}

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

Classes

Public Member Functions

Protected Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ ~TransportSendListener()

◆ TransportSendListener()

Member Function Documentation

◆ control_delivered()

◆ control_dropped()

◆ data_acked()

◆ data_delivered()

◆ data_dropped()

◆ notify_publication_disconnected()

◆ notify_publication_lost()

◆ notify_publication_reconnected()

◆ remove_associations()

◆ replay_durable_data_for()

◆ retrieve_inline_qos_data()

◆ send_control_customized()

◆ transport_discovery_change()