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 "SendResponseListener.h"
      10             : 
      11             : #include "ace/Message_Block.h"
      12             : 
      13             : OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
      14             : 
      15             : namespace OpenDDS {
      16             : namespace DCPS {
      17             : 
      18           3 : SendResponseListener::SendResponseListener(const OPENDDS_STRING& msg_src)
      19           3 : : tracker_(msg_src)
      20             : {
      21           3 : }
      22             : 
      23           3 : SendResponseListener::~SendResponseListener()
      24             : {
      25           3 :   tracker_.wait_messages_pending("SendResponseListener::~SendResponseListener");
      26           3 : }
      27             : 
      28             : void
      29           0 : SendResponseListener::data_delivered(const DataSampleElement* /* sample */)
      30             : {
      31           0 :   tracker_.message_delivered();
      32           0 : }
      33             : 
      34             : void
      35           0 : SendResponseListener::data_dropped(
      36             :   const DataSampleElement* /* sample */,
      37             :   bool /* dropped_by_transport */)
      38             : {
      39           0 :   tracker_.message_dropped();
      40           0 : }
      41             : 
      42             : void
      43           0 : SendResponseListener::control_delivered(const Message_Block_Ptr& /* sample */)
      44             : {
      45           0 :   tracker_.message_delivered();
      46           0 : }
      47             : 
      48             : void
      49           0 : SendResponseListener::control_dropped(
      50             :   const Message_Block_Ptr& /* sample */,
      51             :   bool /* dropped_by_transport */)
      52             : {
      53           0 :   tracker_.message_dropped();
      54           0 : }
      55             : 
      56             : void
      57           0 : SendResponseListener::track_message()
      58             : {
      59           0 :   tracker_.message_sent();
      60           0 : }
      61             : 
      62             : } // namespace DCPS
      63             : } // namespace OpenDDS
      64             : 
      65             : OPENDDS_END_VERSIONED_NAMESPACE_DECL