OpenDDS::DCPS::ThreadSynchResource Class Reference

#include <ThreadSynchResource.h>

Inheritance diagram for OpenDDS::DCPS::ThreadSynchResource:

Collaboration diagram for OpenDDS::DCPS::ThreadSynchResource:

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_
TimeDuration *	timeout_

Detailed Description

Definition at line 19 of file ThreadSynchResource.h.

Constructor & Destructor Documentation

~ThreadSynchResource()

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_;
}

ThreadSynchResource()

ACE_INLINE OpenDDS::DCPS::ThreadSynchResource::ThreadSynchResource ( )

protected

Definition at line 12 of file ThreadSynchResource.inl.

References ACE_INLINE, and DBG_ENTRY_LVL.

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

Member Function Documentation

notify_lost_on_backpressure_timeout()

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

protectedpure virtual

Implemented in OpenDDS::DCPS::TcpSynchResource.

Referenced by wait_to_unclog().

set_handle()

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

(

ACE_HANDLE

handle

)

Definition at line 42 of file ThreadSynchResource.inl.

References handle_.

{
  handle_ = handle;
}

wait_to_unclog()

ACE_INLINE int OpenDDS::DCPS::ThreadSynchResource::wait_to_unclog ( )

virtual

Definition at line 20 of file ThreadSynchResource.inl.

References ACE_ERROR, ACE_INLINE, ACE_TEXT(), DBG_ENTRY_LVL, ETIME, handle_, ACE::handle_write_ready(), LM_ERROR, notify_lost_on_backpressure_timeout(), timeout_, and OpenDDS::DCPS::TimeDuration::value().

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

  if (ACE::handle_write_ready(handle_, timeout_ ? &timeout_->value() : 0) == -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;
}

Member Data Documentation

handle_

ACE_HANDLE OpenDDS::DCPS::ThreadSynchResource::handle_

protected

Definition at line 32 of file ThreadSynchResource.h.

Referenced by set_handle(), and wait_to_unclog().

timeout_

TimeDuration* 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