OpenDDS::DCPS::ReactorSynchStrategy Class Reference

strategy to construct ReactorSynch implementations of ThreadSynch. More...

#include <ReactorSynchStrategy.h>

Inheritance diagram for OpenDDS::DCPS::ReactorSynchStrategy:

[legend]

Collaboration diagram for OpenDDS::DCPS::ReactorSynchStrategy:

[legend]

List of all members.

Public Member Functions
	ReactorSynchStrategy (TransportSendStrategy *strategy, ACE_Reactor *reactor)
virtual	~ReactorSynchStrategy ()
virtual ThreadSynch *	create_synch_object (ThreadSynchResource *synch_resource, long priority=0, int scheduler=0)
Private Attributes
TransportSendStrategy *	strategy_
ACE_Reactor *	reactor_

---

Detailed Description

strategy to construct ReactorSynch implementations of ThreadSynch.

This class is used as a factory for ReactorSynch objects that can be used to scheduled queued output for processing on a reactor. The initial implementation will share the Transport reactor for all of the sending and receiving processing to be performed. If the reactor is upgraded to a thread pool reactor, then this processing can be split between those threads using the default leader-follower dispatching.

The usage idiom for ThreadSynchStrategy ensures that his object will have valid raw pointer values during its lifetime.

Definition at line 39 of file ReactorSynchStrategy.h.

---

Constructor & Destructor Documentation

ACE_INLINE OpenDDS::DCPS::ReactorSynchStrategy::ReactorSynchStrategy	(	TransportSendStrategy *	strategy,
		ACE_Reactor *	reactor
	)

Construct with strategy, reactor, and handle to configure the ReactorSynch with.

Definition at line 11 of file ReactorSynchStrategy.inl.

References DBG_ENTRY_LVL.

 : strategy_( strategy),
   reactor_( reactor)
{
  DBG_ENTRY_LVL("ReactorSynchStrategy","ReactorSynchStrategy",6);
}

OpenDDS::DCPS::ReactorSynchStrategy::~ReactorSynchStrategy

(

)

[virtual]

Definition at line 16 of file ReactorSynchStrategy.cpp.

References DBG_ENTRY_LVL.

{
  DBG_ENTRY_LVL("ReactorSynchStrategy","~ReactorSynchStrategy",6);
}

---

Member Function Documentation

OpenDDS::DCPS::ThreadSynch * OpenDDS::DCPS::ReactorSynchStrategy::create_synch_object	(	ThreadSynchResource *	synch_resource,
		long	priority = 0,
		int	scheduler = 0
	)			[virtual]

Implements OpenDDS::DCPS::ThreadSynchStrategy.

Definition at line 22 of file ReactorSynchStrategy.cpp.

References DBG_ENTRY_LVL, reactor_, and strategy_.

{
  DBG_ENTRY_LVL("ReactorSynchStrategy","create_synch_object",6);
  return new ReactorSynch(
               synch_resource, strategy_, reactor_);
}

---

Member Data Documentation

ACE_Reactor* OpenDDS::DCPS::ReactorSynchStrategy::reactor_ [private]

Raw pointer to reactor. This is ok since the strategy will pass the pointer on to the ReactorSynch, which is guaranteed to span the lifetime of both the strategy and the reactor.

Definition at line 63 of file ReactorSynchStrategy.h.

Referenced by create_synch_object().

TransportSendStrategy* OpenDDS::DCPS::ReactorSynchStrategy::strategy_ [private]

Raw pointer to the strategy. This is the strategy that contains the TreadSynch (which will receive this pointer) so the lifetime is assured.

Definition at line 58 of file ReactorSynchStrategy.h.

Referenced by create_synch_object().

---

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

• ReactorSynchStrategy.h
• ReactorSynchStrategy.cpp
• ReactorSynchStrategy.inl