TcpSynchResource.cpp

Go to the documentation of this file.
00001 /*
00002  *
00003  *
00004  * Distributed under the OpenDDS License.
00005  * See: http://www.opendds.org/license.html
00006  */
00007 
00008 #include "Tcp_pch.h"
00009 #include "TcpSynchResource.h"
00010 #include "TcpConnection.h"
00011 #include "TcpSendStrategy.h"
00012 #include "TcpDataLink.h"
00013 
00014 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
00015 
00016 OpenDDS::DCPS::TcpSynchResource::TcpSynchResource(
00017   TcpDataLink& link,
00018   const int& max_output_pause_period_ms)
00019   : ThreadSynchResource()
00020   , link_(link)
00021 {
00022   DBG_ENTRY_LVL("TcpSynchResource","TcpSynchResource",6);
00023 
00024   if (max_output_pause_period_ms >= 0) {
00025     this->timeout_ = new ACE_Time_Value(max_output_pause_period_ms / 1000,
00026                                         max_output_pause_period_ms % 1000 * 1000);
00027   }
00028 }
00029 
00030 OpenDDS::DCPS::TcpSynchResource::~TcpSynchResource()
00031 {
00032   DBG_ENTRY_LVL("TcpSynchResource","~TcpSynchResource",6);
00033 }
00034 
00035 void
00036 OpenDDS::DCPS::TcpSynchResource::notify_lost_on_backpressure_timeout()
00037 {
00038   DBG_ENTRY_LVL("TcpSynchResource","notify_lost_on_backpressure_timeout",6);
00039 
00040   TcpConnection_rch connection = link_.get_connection();
00041   connection->notify_lost_on_backpressure_timeout();
00042 }
00043 
00044 OPENDDS_END_VERSIONED_NAMESPACE_DECL