Line data    Source code

       1             : /*
       2             :  *
       3             :  *
       4             :  * Distributed under the OpenDDS License.
       5             :  * See: http://www.opendds.org/license.html
       6             :  */
       7             : 
       8             : #include "DCPS/DdsDcps_pch.h" //Only the _pch include should start with DCPS/
       9             : #include "dds/DCPS/Service_Participant.h"
      10             : #include "TransportSendListener.h"
      11             : #include "EntryExit.h"
      12             : 
      13             : OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
      14             : 
      15             : namespace OpenDDS {
      16             : namespace DCPS {
      17             : 
      18           3 : TransportSendListener::TransportSendListener()
      19             : {
      20             :   DBG_ENTRY_LVL("TransportSendListener","TransportSendListener",6);
      21           3 : }
      22             : 
      23           3 : TransportSendListener::~TransportSendListener()
      24             : {
      25             :   DBG_ENTRY_LVL("TransportSendListener","~TransportSendListener",6);
      26           3 : }
      27             : 
      28             : void
      29           0 : TransportSendListener::data_delivered(const DataSampleElement* sample)
      30             : {
      31             :   ACE_UNUSED_ARG(sample);
      32           0 :   ACE_ERROR((LM_ERROR,
      33             :              "(%P|%t) ERROR: Subclass should override if sending data samples.\n"));
      34           0 : }
      35             : 
      36             : void
      37           0 : TransportSendListener::data_dropped(const DataSampleElement* sample,
      38             :                                                    bool dropped_by_transport)
      39             : {
      40             :   ACE_UNUSED_ARG(sample);
      41             :   ACE_UNUSED_ARG(dropped_by_transport);
      42           0 :   ACE_ERROR((LM_ERROR,
      43             :              "(%P|%t) ERROR: Subclass should override if sending data samples.\n"));
      44           0 : }
      45             : 
      46             : void
      47           0 : TransportSendListener::control_delivered(const Message_Block_Ptr& sample)
      48             : {
      49             :   ACE_UNUSED_ARG(sample);
      50           0 :   ACE_ERROR((LM_ERROR,
      51             :              "(%P|%t) ERROR: Subclass should override if sending control samples.\n"));
      52           0 : }
      53             : 
      54             : void
      55           0 : TransportSendListener::control_dropped(const Message_Block_Ptr& sample,
      56             :                                        bool dropped_by_transport)
      57             : {
      58             :   ACE_UNUSED_ARG(sample);
      59             :   ACE_UNUSED_ARG(dropped_by_transport);
      60           0 :   ACE_ERROR((LM_ERROR,
      61             :              "(%P|%t) ERROR: Subclass should override if sending control samples.\n"));
      62           0 : }
      63             : 
      64             : SendControlStatus
      65           0 : TransportSendListener::send_control_customized(const DataLinkSet_rch&,
      66             :                                                const DataSampleHeader&,
      67             :                                                ACE_Message_Block*, void*)
      68             : {
      69           0 :   return SEND_CONTROL_OK;
      70             : }
      71             : 
      72             : void
      73           0 : TransportSendListener::retrieve_inline_qos_data(InlineQosData& qos_data) const
      74             : {
      75           0 :   qos_data.dw_qos     = TheServiceParticipant->initial_DataWriterQos();
      76           0 :   qos_data.pub_qos    = TheServiceParticipant->initial_PublisherQos();
      77           0 :   qos_data.topic_name = "";
      78           0 : }
      79             : 
      80             : } }
      81             : 
      82             : OPENDDS_END_VERSIONED_NAMESPACE_DECL