OpenDDS  Snapshot(2023/04/07-19:43)
Public Member Functions | Private Attributes | List of all members
OpenDDS::DCPS::TcpSynchResource Class Reference

#include <TcpSynchResource.h>

Inheritance diagram for OpenDDS::DCPS::TcpSynchResource:
Inheritance graph
[legend]
Collaboration diagram for OpenDDS::DCPS::TcpSynchResource:
Collaboration graph
[legend]

Public Member Functions

 TcpSynchResource (TcpDataLink &link, const int &max_output_pause_period_ms)
 
virtual ~TcpSynchResource ()
 
virtual void notify_lost_on_backpressure_timeout ()
 
- Public Member Functions inherited from OpenDDS::DCPS::ThreadSynchResource
virtual ~ThreadSynchResource ()
 
virtual int wait_to_unclog ()
 
void set_handle (ACE_HANDLE handle)
 

Private Attributes

TcpDataLinklink_
 

Additional Inherited Members

- Protected Member Functions inherited from OpenDDS::DCPS::ThreadSynchResource
 ThreadSynchResource ()
 
- Protected Attributes inherited from OpenDDS::DCPS::ThreadSynchResource
ACE_HANDLE handle_
 
TimeDurationtimeout_
 

Detailed Description

Definition at line 22 of file TcpSynchResource.h.

Constructor & Destructor Documentation

◆ TcpSynchResource()

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL OpenDDS::DCPS::TcpSynchResource::TcpSynchResource ( TcpDataLink link,
const int &  max_output_pause_period_ms 
)

Definition at line 15 of file TcpSynchResource.cpp.

References DBG_ENTRY_LVL, OpenDDS::DCPS::TimeDuration::from_msec(), and OpenDDS::DCPS::ThreadSynchResource::timeout_.

19  , link_(link)
20 {
21  DBG_ENTRY_LVL("TcpSynchResource","TcpSynchResource",6);
22 
23  if (max_output_pause_period_ms >= 0) {
24  timeout_ = new TimeDuration(TimeDuration::from_msec(max_output_pause_period_ms));
25  }
26 }
static TimeDuration from_msec(const ACE_UINT64 &ms)
#define DBG_ENTRY_LVL(CNAME, MNAME, DBG_LVL)
Definition: EntryExit.h:68

◆ ~TcpSynchResource()

OpenDDS::DCPS::TcpSynchResource::~TcpSynchResource ( )
virtual

Definition at line 28 of file TcpSynchResource.cpp.

References DBG_ENTRY_LVL.

29 {
30  DBG_ENTRY_LVL("TcpSynchResource","~TcpSynchResource",6);
31 }
#define DBG_ENTRY_LVL(CNAME, MNAME, DBG_LVL)
Definition: EntryExit.h:68

Member Function Documentation

◆ notify_lost_on_backpressure_timeout()

void OpenDDS::DCPS::TcpSynchResource::notify_lost_on_backpressure_timeout ( )
virtual

Implements OpenDDS::DCPS::ThreadSynchResource.

Definition at line 34 of file TcpSynchResource.cpp.

References DBG_ENTRY_LVL, OpenDDS::DCPS::TcpDataLink::get_connection(), link_, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

35 {
36  DBG_ENTRY_LVL("TcpSynchResource","notify_lost_on_backpressure_timeout",6);
37 
38  TcpConnection_rch connection = link_.get_connection();
39  connection->notify_lost_on_backpressure_timeout();
40 }
RcHandle< TcpConnection > TcpConnection_rch
#define DBG_ENTRY_LVL(CNAME, MNAME, DBG_LVL)
Definition: EntryExit.h:68
TcpConnection_rch get_connection()
Definition: TcpDataLink.inl:22

Member Data Documentation

◆ link_

TcpDataLink& OpenDDS::DCPS::TcpSynchResource::link_
private

Definition at line 33 of file TcpSynchResource.h.

Referenced by notify_lost_on_backpressure_timeout().


The documentation for this class was generated from the following files: