OpenDDS::DCPS::TransportSendListener

OpenDDS::DCPS::TransportSendListener Class Reference

#include <TransportSendListener.h>

Inheritance diagram for OpenDDS::DCPS::TransportSendListener:

Inheritance graph
[legend]
List of all members.

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 (ACE_Message_Block *sample)
virtual void control_dropped (ACE_Message_Block *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 notify_connection_deleted (const RepoId &peerId)=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 ()

Classes

struct  InlineQosData

Detailed Description

Definition at line 33 of file TransportSendListener.h.

Constructor & Destructor Documentation

OpenDDS::DCPS::TransportSendListener::~TransportSendListener (  )  [virtual]

Definition at line 25 of file TransportSendListener.cpp.

References DBG_ENTRY_LVL.

00026 {
00027   DBG_ENTRY_LVL("TransportSendListener","~TransportSendListener",6);
00028 }

OpenDDS::DCPS::TransportSendListener::TransportSendListener (  )  [protected]

Definition at line 20 of file TransportSendListener.cpp.

References DBG_ENTRY_LVL.

00021 {
00022   DBG_ENTRY_LVL("TransportSendListener","TransportSendListener",6);
00023 }

Member Function Documentation

void OpenDDS::DCPS::TransportSendListener::control_delivered ( ACE_Message_Block *  sample  )  [virtual]

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

Definition at line 49 of file TransportSendListener.cpp.

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

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

void OpenDDS::DCPS::TransportSendListener::control_dropped ( ACE_Message_Block *  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 57 of file TransportSendListener.cpp.

Referenced by OpenDDS::DCPS::handle_message().

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

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 31 of file TransportSendListener.cpp.

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

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

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 39 of file TransportSendListener.cpp.

Referenced by OpenDDS::DCPS::handle_message().

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

virtual void OpenDDS::DCPS::TransportSendListener::notify_connection_deleted ( const RepoId &  peerId  )  [pure virtual]

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

Referenced by OpenDDS::DCPS::DataLink::notify_connection_deleted().

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.

Definition at line 75 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().

00076 {
00077   qos_data.dw_qos     = TheServiceParticipant->initial_DataWriterQos();
00078   qos_data.pub_qos    = TheServiceParticipant->initial_PublisherQos();
00079   qos_data.topic_name = "";
00080 }

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 67 of file TransportSendListener.cpp.

References OpenDDS::DCPS::SEND_CONTROL_OK.

00070 {
00071   return SEND_CONTROL_OK;
00072 }

The documentation for this class was generated from the following files:
Generated on Fri Feb 12 20:06:33 2016 for OpenDDS by  doxygen 1.4.7