#include <TcpSynchResource.h>
Public Member Functions | |
TcpSynchResource (TcpDataLink &link, const int &max_output_pause_period_ms) | |
virtual | ~TcpSynchResource () |
virtual void | notify_lost_on_backpressure_timeout () |
Private Attributes | |
TcpDataLink & | link_ |
Definition at line 22 of file TcpSynchResource.h.
OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL OpenDDS::DCPS::TcpSynchResource::TcpSynchResource | ( | TcpDataLink & | link, | |
const int & | max_output_pause_period_ms | |||
) |
Definition at line 16 of file TcpSynchResource.cpp.
References DBG_ENTRY_LVL, and OpenDDS::DCPS::ThreadSynchResource::timeout_.
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 }
OpenDDS::DCPS::TcpSynchResource::~TcpSynchResource | ( | ) | [virtual] |
Definition at line 30 of file TcpSynchResource.cpp.
References DBG_ENTRY_LVL.
00031 { 00032 DBG_ENTRY_LVL("TcpSynchResource","~TcpSynchResource",6); 00033 }
void OpenDDS::DCPS::TcpSynchResource::notify_lost_on_backpressure_timeout | ( | ) | [virtual] |
Implements OpenDDS::DCPS::ThreadSynchResource.
Definition at line 36 of file TcpSynchResource.cpp.
References DBG_ENTRY_LVL, OpenDDS::DCPS::TcpDataLink::get_connection(), and link_.
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 }
Definition at line 33 of file TcpSynchResource.h.
Referenced by notify_lost_on_backpressure_timeout().