OpenDDS::DCPS::ReactorSynch Class Reference

Send thread synchronization utilizing a reactor. More...

#include <ReactorSynch.h>

Inheritance diagram for OpenDDS::DCPS::ReactorSynch:

[legend]Collaboration diagram for OpenDDS::DCPS::ReactorSynch:

[legend]List of all members.

Public Member Functions
	ReactorSynch (ThreadSynchResource *synch_resource, TransportSendStrategy *strategy, ACE_Reactor *reactor)
virtual	~ReactorSynch ()
virtual void	work_available ()
Private Attributes
ScheduleOutputHandler *	scheduleOutputHandler_
	Notification event handler.
ACE_Event_Handler_var	safeHandler_
	Memory management using the provided (kluge) var type.

---

Detailed Description

Send thread synchronization utilizing a reactor.

This class implements sending thread synchronization by scheduling qeueued data sending to be handled by a reactor. The initial implementation will share the TransportReactorTask reactor for all sending threads; which means that all receiving and queued sends will be sharing the same thread. Or thread pool.

Calls to enable and disable sending on queued data by the reactor are scheduled to be enabled and disabled on the reactor by notifying the reactor to make the update. This ensures that no locks will be held (other than the Reactor::token_) when the call into the reactor is made.

References to the containing TransportSendStrategy and the reactor are held as raw pointers since they are guaranteed to be valid for the lifetime of this object (this is held in the same containing object).

Definition at line 37 of file ReactorSynch.h.

---

Constructor & Destructor Documentation

ACE_INLINE OpenDDS::DCPS::ReactorSynch::ReactorSynch	(	ThreadSynchResource *	synch_resource,
		TransportSendStrategy *	strategy,
		ACE_Reactor *	reactor
	)

Construct with raw pointers from the containing TransportSendStrategy.

Definition at line 12 of file ReactorSynch.inl.

References DBG_ENTRY_LVL, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::ThreadSynchWorker::id(), safeHandler_, scheduleOutputHandler_, and OpenDDS::DCPS::ThreadSynch::worker().

  : ThreadSynch(synch_resource),
    scheduleOutputHandler_( new ScheduleOutputHandler( strategy, reactor))
{
  DBG_ENTRY_LVL("ReactorSynch","ReactorSynch",6);

  // Manage the handler storage using the provided _var.
  safeHandler_ = scheduleOutputHandler_;

  if (DCPS_debug_level > 4) {
    std::size_t id = 0;
    if( worker()) {
      id = worker()->id();
    }
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) ReactorSynch::ReactorSynch() [%d] - ")
               ACE_TEXT("establishing synch %C a worker.\n"),
               id,(worker()?"with":"without")));
  }
}

OpenDDS::DCPS::ReactorSynch::~ReactorSynch

(

)

[virtual]

Definition at line 16 of file ReactorSynch.cpp.

References DBG_ENTRY_LVL, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::ThreadSynchWorker::id(), scheduleOutputHandler_, and OpenDDS::DCPS::ThreadSynch::worker().

{
  DBG_ENTRY_LVL("ReactorSynch","~ReactorSynch",6);

  // Release out unmanaged copy of the handler.
  // The managed copy will perform the actual delete.
  scheduleOutputHandler_ = 0;

  if (DCPS_debug_level > 4) {
    std::size_t id = 0;
    if( worker()) {
      id = worker()->id();
    }
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) ReactorSynch::~ReactorSynch() [%d] - ")
               ACE_TEXT("dismantling synch %C worker.\n"),
               id,(worker()?"with":"without")));
  }
}

---

Member Function Documentation

void OpenDDS::DCPS::ReactorSynch::work_available

(

)

[virtual]

The ThreadSynchWorker would like to have its perform_work() called from the appropriate thread once the ThreadSynchResource claims that it is_ready_for_work().

Implements OpenDDS::DCPS::ThreadSynch.

Definition at line 37 of file ReactorSynch.cpp.

References DBG_ENTRY_LVL, OpenDDS::DCPS::ScheduleOutputHandler::schedule_output(), and scheduleOutputHandler_.

{
  DBG_ENTRY_LVL("ReactorSynch","work_available",6);

  // Schedule queued data to be sent by the reactor.
  scheduleOutputHandler_->schedule_output();
}

---

Member Data Documentation

ACE_Event_Handler_var OpenDDS::DCPS::ReactorSynch::safeHandler_ [private]

Memory management using the provided (kluge) var type.

Definition at line 54 of file ReactorSynch.h.

Referenced by ReactorSynch().

ScheduleOutputHandler* OpenDDS::DCPS::ReactorSynch::scheduleOutputHandler_ [private]

Notification event handler.

Definition at line 51 of file ReactorSynch.h.

Referenced by ReactorSynch(), work_available(), and ~ReactorSynch().

---

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

• ReactorSynch.h
• ReactorSynch.cpp
• ReactorSynch.inl

---