OpenDDS::DCPS::ThreadSynchResource Class Reference

#include <ThreadSynchResource.h>

Inheritance diagram for OpenDDS::DCPS::ThreadSynchResource:

[legend]

Collaboration diagram for OpenDDS::DCPS::ThreadSynchResource:

[legend]

List of all members.

Public Member Functions
virtual	~ThreadSynchResource ()
virtual int	wait_to_unclog ()
void	set_handle (ACE_HANDLE handle)
Protected Member Functions
virtual void	notify_lost_on_backpressure_timeout ()=0
	ThreadSynchResource ()
Protected Attributes
ACE_HANDLE	handle_
ACE_Time_Value *	timeout_

---

Detailed Description

Definition at line 19 of file ThreadSynchResource.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::ThreadSynchResource::~ThreadSynchResource

(

)

[virtual]

Definition at line 15 of file ThreadSynchResource.cpp.

References DBG_ENTRY_LVL, and timeout_.

{
  DBG_ENTRY_LVL("ThreadSynchResource","~ThreadSynchResource",6);
  delete this->timeout_;
}

ACE_INLINE OpenDDS::DCPS::ThreadSynchResource::ThreadSynchResource

(

)

[protected]

Definition at line 12 of file ThreadSynchResource.inl.

References DBG_ENTRY_LVL.

  : handle_(ACE_INVALID_HANDLE)
  , timeout_(0)
{
  DBG_ENTRY_LVL("ThreadSynchResource","ThreadSynchResource",6);
}

---

Member Function Documentation

virtual void OpenDDS::DCPS::ThreadSynchResource::notify_lost_on_backpressure_timeout

(

)

[protected, pure virtual]

Implemented in OpenDDS::DCPS::TcpSynchResource.

Referenced by wait_to_unclog().

Here is the caller graph for this function:

ACE_INLINE void OpenDDS::DCPS::ThreadSynchResource::set_handle

(

ACE_HANDLE

handle

)

Definition at line 42 of file ThreadSynchResource.inl.

References handle_.

{
  handle_ = handle;
}

ACE_INLINE int OpenDDS::DCPS::ThreadSynchResource::wait_to_unclog

(

)

[virtual]

Definition at line 20 of file ThreadSynchResource.inl.

References ACE_TEXT(), DBG_ENTRY_LVL, handle_, ACE::handle_write_ready(), LM_ERROR, notify_lost_on_backpressure_timeout(), and timeout_.

{
  DBG_ENTRY_LVL("ThreadSynchResource","wait_to_unclog",6);

  if (ACE::handle_write_ready(this->handle_, this->timeout_) == -1) {
    if (errno == ETIME) {
      ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: handle_write_ready timed out\n"));
      this->notify_lost_on_backpressure_timeout();

    } else {
      ACE_ERROR((LM_ERROR,
                 "(%P|%t) ERROR: ACE::handle_write_ready return -1 while waiting "
                 " to unclog. %p \n", ACE_TEXT("handle_write_ready")));
    }

    return -1;
  }

  return 0;
}

Here is the call graph for this function:

---

Member Data Documentation

ACE_HANDLE OpenDDS::DCPS::ThreadSynchResource::handle_ [protected]

Definition at line 32 of file ThreadSynchResource.h.

Referenced by set_handle(), and wait_to_unclog().

ACE_Time_Value* OpenDDS::DCPS::ThreadSynchResource::timeout_ [protected]

Definition at line 33 of file ThreadSynchResource.h.

Referenced by OpenDDS::DCPS::TcpSynchResource::TcpSynchResource(), wait_to_unclog(), and ~ThreadSynchResource().

---

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

• ThreadSynchResource.h
• ThreadSynchResource.cpp
• ThreadSynchResource.inl