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

#include <ReactorSynchStrategy.h>

Inheritance diagram for OpenDDS::DCPS::ReactorSynchStrategy:

Collaboration diagram for OpenDDS::DCPS::ReactorSynchStrategy:

[legend]

Public Member Functions
	ReactorSynchStrategy (TransportSendStrategy strategy, ACE_Reactor reactor)

virtual	~ReactorSynchStrategy ()

virtual ThreadSynch *	create_synch_object (ThreadSynchResource *synch_resource, long priority=0, long scheduler=0)

Public Member Functions inherited from OpenDDS::DCPS::ThreadSynchStrategy
virtual	~ThreadSynchStrategy ()

Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()

virtual void	_add_ref ()

virtual void	_remove_ref ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Private Attributes
TransportSendStrategy *	strategy_

ACE_Reactor *	reactor_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::ThreadSynchStrategy
	ThreadSynchStrategy ()

Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

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

◆ ReactorSynchStrategy()

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

◆ ~ReactorSynchStrategy()

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

◆ create_synch_object()

OpenDDS::DCPS::ThreadSynch * OpenDDS::DCPS::ReactorSynchStrategy::create_synch_object	(	ThreadSynchResource *	synch_resource,
		long	priority = `0`,
		long	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

◆ reactor_

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().

◆ strategy_

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.