#include <ReactorTask.h>

Inheritance diagram for OpenDDS::DCPS::ReactorTask:

[legend]

Collaboration diagram for OpenDDS::DCPS::ReactorTask:

[legend]

Classes
class	Interceptor

Public Member Functions
	ReactorTask (bool useAsyncSend)

virtual	~ReactorTask ()

int	open_reactor_task (void , ThreadStatusManager thread_status_manager=0, const String &name="")

virtual int	open (void *ptr)

virtual int	svc ()

virtual int	close (u_long flags=0)

void	stop ()

ACE_Reactor *	get_reactor ()

const ACE_Reactor *	get_reactor () const

ACE_thread_t	get_reactor_owner () const

ACE_Proactor *	get_proactor ()

const ACE_Proactor *	get_proactor () const

void	wait_for_startup () const

bool	is_shut_down () const

ReactorInterceptor_rch	interceptor () const

Public Member Functions inherited from ACE_Task_Base
	ACE_Task_Base (ACE_Thread_Manager *=0)

virtual	~ACE_Task_Base (void)

virtual int	module_closed (void)

virtual int	put (ACE_Message_Block , ACE_Time_Value =0)

virtual int	activate (long flags=THR_NEW_LWP\|THR_JOINABLE\|THR_INHERIT_SCHED, int n_threads=1, int force_active=0, long priority=ACE_DEFAULT_THREAD_PRIORITY, int grp_id=-1, ACE_Task_Base task=0, ACE_hthread_t thread_handles[]=0, void stack[]=0, size_t stack_size[]=0, ACE_thread_t thread_ids[]=0, const char *thr_name[]=0)

virtual int	wait (void)

virtual int	suspend (void)

virtual int	resume (void)

int	grp_id (void) const

void	grp_id (int)

ACE_Thread_Manager *	thr_mgr (void) const

void	thr_mgr (ACE_Thread_Manager *)

int	is_reader (void) const

int	is_writer (void) const

size_t	thr_count (void) const

ACE_thread_t	last_thread (void) const

Public Member Functions inherited from ACE_Service_Object
	ACE_Service_Object (ACE_Reactor *=0)

virtual	~ACE_Service_Object (void)

Public Member Functions inherited from ACE_Event_Handler
virtual	~ACE_Event_Handler (void)

virtual ACE_HANDLE	get_handle (void) const

virtual void	set_handle (ACE_HANDLE)

virtual int	priority (void) const

virtual void	priority (int priority)

virtual int	handle_input (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_timeout (const ACE_Time_Value &current_time, const void *act=0)

virtual int	handle_exit (ACE_Process *)

virtual int	handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask)

virtual int	handle_signal (int signum, siginfo_t =0, ucontext_t =0)

virtual int	resume_handler (void)

virtual int	handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE)

virtual int	handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE)

virtual ACE_Reactor_Timer_Interface *	reactor_timer_interface (void) const

virtual Reference_Count	add_reference (void)

virtual Reference_Count	remove_reference (void)

Reference_Counting_Policy &	reference_counting_policy (void)

Public Member Functions inherited from ACE_Shared_Object
	ACE_Shared_Object (void)

virtual	~ACE_Shared_Object (void)

virtual int	init (int argc, ACE_TCHAR *argv[])

virtual int	fini (void)

virtual int	info (ACE_TCHAR **info_string, size_t length=0) const

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 Types
enum	State { STATE_UNINITIALIZED, STATE_OPENING, STATE_RUNNING, STATE_SHUT_DOWN }

typedef ACE_SYNCH_MUTEX	LockType

typedef ACE_Guard< LockType >	GuardType

typedef ConditionVariable< LockType >	ConditionVariableType

typedef ACE_Timer_Heap_T< ACE_Event_Handler *, ACE_Event_Handler_Handle_Timeout_Upcall, ACE_SYNCH_RECURSIVE_MUTEX, MonotonicClock >	TimerQueueType

Private Member Functions
virtual void	reactor (ACE_Reactor *reactor)

virtual ACE_Reactor *	reactor () const

void	cleanup ()

void	wait_for_startup_i () const

Additional Inherited Members
Public Types inherited from ACE_Event_Handler
typedef long	Reference_Count

Static Public Member Functions inherited from ACE_Task_Base
static ACE_THR_FUNC_RETURN	svc_run (void *)

static void	cleanup (void object, void params)

Static Public Member Functions inherited from ACE_Event_Handler
static ACE_THR_FUNC_RETURN	read_adapter (void *event_handler)

static int	register_stdin_handler (ACE_Event_Handler eh, ACE_Reactor reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)

static int	remove_stdin_handler (ACE_Reactor reactor, ACE_Thread_Manager thr_mgr)

Public Attributes inherited from ACE_Service_Object
	ACE_ALLOC_HOOK_DECLARE

Public Attributes inherited from ACE_Event_Handler
	LO_PRIORITY

	HI_PRIORITY

	NULL_MASK

	READ_MASK

	WRITE_MASK

	EXCEPT_MASK

	ACCEPT_MASK

	CONNECT_MASK

	TIMER_MASK

	QOS_MASK

	GROUP_QOS_MASK

	SIGNAL_MASK

	ALL_EVENTS_MASK

	RWE_MASK

	DONT_CALL

	ACE_EVENT_HANDLER_NOT_RESUMED

	ACE_REACTOR_RESUMES_HANDLER

	ACE_APPLICATION_RESUMES_HANDLER

Protected Types inherited from ACE_Event_Handler
typedef ACE_Atomic_Op< ACE_SYNCH_MUTEX, Reference_Count >	Atomic_Reference_Count

Protected Member Functions inherited from ACE_Event_Handler
	ACE_Event_Handler (ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY)

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

Protected Attributes inherited from ACE_Task_Base
size_t	thr_count_

ACE_Thread_Manager *	thr_mgr_

u_long	flags_

int	grp_id_

ACE_thread_t	last_thread_id_

Protected Attributes inherited from ACE_Event_Handler
Atomic_Reference_Count	reference_count_

Detailed Description

Definition at line 34 of file ReactorTask.h.

Member Typedef Documentation

◆ ConditionVariableType

typedef ConditionVariable<LockType> OpenDDS::DCPS::ReactorTask::ConditionVariableType

private

Definition at line 80 of file ReactorTask.h.

◆ GuardType

typedef ACE_Guard<LockType> OpenDDS::DCPS::ReactorTask::GuardType

private

Definition at line 79 of file ReactorTask.h.

◆ LockType

typedef ACE_SYNCH_MUTEX OpenDDS::DCPS::ReactorTask::LockType

private

Definition at line 78 of file ReactorTask.h.

◆ TimerQueueType

typedef ACE_Timer_Heap_T< ACE_Event_Handler*, ACE_Event_Handler_Handle_Timeout_Upcall, ACE_SYNCH_RECURSIVE_MUTEX, MonotonicClock> OpenDDS::DCPS::ReactorTask::TimerQueueType

private

Definition at line 83 of file ReactorTask.h.

Member Enumeration Documentation

◆ State

enum OpenDDS::DCPS::ReactorTask::State

private

Enumerator
STATE_UNINITIALIZED
STATE_OPENING
STATE_RUNNING
STATE_SHUT_DOWN

Definition at line 85 of file ReactorTask.h.

85 { STATE_UNINITIALIZED, STATE_OPENING, STATE_RUNNING, STATE_SHUT_DOWN };

OpenDDS::DCPS::ReactorTask::STATE_RUNNING

Definition: ReactorTask.h:85

OpenDDS::DCPS::ReactorTask::STATE_UNINITIALIZED

Definition: ReactorTask.h:85

OpenDDS::DCPS::ReactorTask::STATE_SHUT_DOWN

Definition: ReactorTask.h:85

OpenDDS::DCPS::ReactorTask::STATE_OPENING

Definition: ReactorTask.h:85

Constructor & Destructor Documentation

◆ ReactorTask()

OpenDDS::DCPS::ReactorTask::ReactorTask ( bool useAsyncSend )

explicit

Definition at line 32 of file ReactorTask.cpp.

References NULL_thread.

   : condition_(lock_)
   , state_(STATE_UNINITIALIZED)
   , reactor_(0)
   , reactor_owner_(ACE_OS::NULL_thread)
   , proactor_(0)
 #ifdef OPENDDS_REACTOR_TASK_ASYNC
   , use_async_send_(useAsyncSend)
 #endif
   , timer_queue_(0)
   , thread_status_manager_(0)
 {
   ACE_UNUSED_ARG(useAsyncSend);
 }

◆ ~ReactorTask()

OpenDDS::DCPS::ReactorTask::~ReactorTask ( )

virtual

Definition at line 47 of file ReactorTask.cpp.

References cleanup().

 {
   cleanup();
 }

Member Function Documentation

◆ cleanup()

void OpenDDS::DCPS::ReactorTask::cleanup ( void )

private

Definition at line 61 of file ReactorTask.cpp.

References ACE_Event_Handler::DONT_CALL, ACE_Proactor_Impl::get_handle(), ACE_Proactor::implementation(), proactor_, reactor_, ACE_Reactor::remove_handler(), and timer_queue_.

Referenced by open_reactor_task(), and ~ReactorTask().

 {
 #if defined (ACE_HAS_WIN32_OVERLAPPED_IO) || defined (ACE_HAS_AIO_CALLS)
   if (proactor_) {
     reactor_->remove_handler(
       proactor_->implementation()->get_handle(),
       ACE_Event_Handler::DONT_CALL);
     delete proactor_;
     proactor_ = 0;
   }
 #endif
 
   delete reactor_;
   reactor_ = 0;
   delete timer_queue_;
   timer_queue_ = 0;
 }

◆ close()

int OpenDDS::DCPS::ReactorTask::close ( u_long flags = 0 )

virtual

Reimplemented from ACE_Task_Base.

Definition at line 178 of file ReactorTask.cpp.

References OpenDDS::DCPS::RcObject::_remove_ref().

 {
   ACE_UNUSED_ARG(flags);
   // This is called after the reactor threads exit.
   // We should not set state here since we are not
   // sure how many reactor threads we will use.
   // If there is one reactor thread then we should
   // set the state so the stop will not call
   // end_reactor_event_loop.
   // If there are multiple reactor threads, we still
   // need call end_reactor_event_loop in stop() while
   // one reactor thread already exited.
 //MJM: Right.
 
   _remove_ref();
   return 0;
 }

◆ get_proactor() [1/2]

ACE_INLINE ACE_Proactor * OpenDDS::DCPS::ReactorTask::get_proactor ( )

Definition at line 37 of file ReactorTask.inl.

References ACE_INLINE, lock_, and proactor_.

Referenced by OpenDDS::DCPS::MulticastDataLink::get_proactor().

 {
   ACE_Guard<ACE_SYNCH_MUTEX> guard(lock_);
   return proactor_;
 }

◆ get_proactor() [2/2]

ACE_INLINE const ACE_Proactor * OpenDDS::DCPS::ReactorTask::get_proactor ( ) const

Definition at line 44 of file ReactorTask.inl.

References ACE_INLINE, lock_, and proactor_.

 {
   ACE_Guard<ACE_SYNCH_MUTEX> guard(lock_);
   return proactor_;
 }

◆ get_reactor() [1/2]

ACE_INLINE ACE_Reactor * OpenDDS::DCPS::ReactorTask::get_reactor ( void )

Definition at line 14 of file ReactorTask.inl.

References ACE_INLINE, lock_, and reactor_.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::close(), OpenDDS::DCPS::RtpsUdpTransport::configure_i(), OpenDDS::DCPS::TcpTransport::configure_i(), OpenDDS::DCPS::Service_Participant::get_domain_participant_factory(), OpenDDS::DCPS::TcpReceiveStrategy::get_reactor(), OpenDDS::DCPS::UdpDataLink::get_reactor(), OpenDDS::DCPS::MulticastDataLink::get_reactor(), OpenDDS::DCPS::RtpsUdpDataLink::get_reactor(), OpenDDS::RTPS::Sedp::init(), OpenDDS::RTPS::Spdp::SpdpTransport::open(), OpenDDS::DCPS::Service_Participant::reactor(), OpenDDS::DCPS::TransportImpl::reactor(), OpenDDS::RTPS::Spdp::SpdpTransport::register_handlers(), OpenDDS::DCPS::TcpReceiveStrategy::reset(), OpenDDS::DCPS::TcpReceiveStrategy::start_i(), and OpenDDS::DCPS::Service_Participant::timer().

 {
   ACE_Guard<ACE_SYNCH_MUTEX> guard(lock_);
   return reactor_;
 }

◆ get_reactor() [2/2]

ACE_INLINE const ACE_Reactor * OpenDDS::DCPS::ReactorTask::get_reactor ( void ) const

Definition at line 21 of file ReactorTask.inl.

References ACE_INLINE, lock_, reactor_, and wait_for_startup_i().

 {
   ACE_Guard<ACE_SYNCH_MUTEX> guard(lock_);
   wait_for_startup_i();
   return reactor_;
 }

◆ get_reactor_owner()

ACE_INLINE ACE_thread_t OpenDDS::DCPS::ReactorTask::get_reactor_owner ( ) const

Definition at line 29 of file ReactorTask.inl.

References ACE_INLINE, lock_, reactor_owner_, and wait_for_startup_i().

Referenced by OpenDDS::DCPS::Service_Participant::reactor_owner(), and OpenDDS::DCPS::TransportImpl::reactor_owner().

 {
   ACE_Guard<ACE_SYNCH_MUTEX> guard(lock_);
   wait_for_startup_i();
   return reactor_owner_;
 }

◆ interceptor()

ACE_INLINE ReactorInterceptor_rch OpenDDS::DCPS::ReactorTask::interceptor ( ) const

Definition at line 65 of file ReactorTask.inl.

References interceptor_, lock_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, and wait_for_startup_i().

Referenced by OpenDDS::DCPS::RtpsUdpTransport::configure_i(), OpenDDS::DCPS::Service_Participant::get_domain_participant_factory(), OpenDDS::DCPS::RtpsUdpDataLink::get_reactor_interceptor(), OpenDDS::RTPS::Sedp::init(), OpenDDS::DCPS::Service_Participant::interceptor(), OpenDDS::DCPS::RtpsUdpTransport::make_datalink(), OpenDDS::DCPS::ShmemDataLink::open(), OpenDDS::RTPS::Spdp::SpdpTransport::open(), OpenDDS::DCPS::RtpsUdpTransport::start_ice(), and OpenDDS::DCPS::RtpsUdpTransport::stop_ice().

 {
   ACE_Guard<ACE_SYNCH_MUTEX> guard(lock_);
   wait_for_startup_i();
   return interceptor_;
 }

◆ is_shut_down()

ACE_INLINE bool OpenDDS::DCPS::ReactorTask::is_shut_down ( ) const

Definition at line 58 of file ReactorTask.inl.

References ACE_INLINE, lock_, state_, and STATE_SHUT_DOWN.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::reactor_is_shut_down().

 {
   ACE_Guard<ACE_SYNCH_MUTEX> guard(lock_);
   return state_ == STATE_SHUT_DOWN;
 }

◆ open()

virtual int OpenDDS::DCPS::ReactorTask::open ( void * ptr )

inlinevirtual

Reimplemented from ACE_Task_Base.

Definition at line 46 of file ReactorTask.h.

References close(), and OPENDDS_POOL_ALLOCATION_FWD.

                               {
     return open_reactor_task(ptr);
   }

◆ open_reactor_task()

int OpenDDS::DCPS::ReactorTask::open_reactor_task	(	void *	,
		ThreadStatusManager *	thread_status_manager = `0`,
		const String &	name = `""`
	)

Definition at line 79 of file ReactorTask.cpp.

References ACE_ERROR_RETURN, ACE_Task_Base::activate(), cleanup(), condition_, ACE_WIN32_Proactor::get_handle(), LM_ERROR, lock_, name, name_, OpenDDS::DCPS::ConditionVariable< Mutex >::notify_all(), proactor_, reactor_, ACE_Reactor::register_handler(), state_, STATE_OPENING, STATE_RUNNING, thread_status_manager_, ACE_Reactor::timer_queue(), timer_queue_, and OpenDDS::DCPS::ConditionVariable< Mutex >::wait().

Referenced by OpenDDS::DCPS::TransportImpl::create_reactor_task(), and OpenDDS::DCPS::Service_Participant::get_domain_participant_factory().

 {
   GuardType guard(lock_);
 
   // If we've already been opened, let's clean up the old stuff
   cleanup();
 
   // thread status reporting support
   thread_status_manager_ = thread_status_manager;
   name_ = name;
 
   // Set our reactor and proactor pointers to a new reactor/proactor objects.
 #ifdef OPENDDS_REACTOR_TASK_ASYNC
   if (use_async_send_ && !reactor_) {
     reactor_ = new ACE_Reactor(new ACE_WFMO_Reactor, 1);
 
     ACE_WIN32_Proactor* proactor_impl = new ACE_WIN32_Proactor(0, 1);
     proactor_ = new ACE_Proactor(proactor_impl, 1);
     reactor_->register_handler(proactor_impl, proactor_impl->get_handle());
   } else
 #endif
   if (!reactor_) {
     reactor_ = new ACE_Reactor(new ACE_Select_Reactor, true);
     proactor_ = 0;
   }
 
   if (!timer_queue_) {
     timer_queue_ = new TimerQueueType();
     reactor_->timer_queue(timer_queue_);
   }
 
   state_ = STATE_OPENING;
   condition_.notify_all();
 
   if (activate(THR_NEW_LWP | THR_JOINABLE, 1) != 0) {
     ACE_ERROR_RETURN((LM_ERROR,
                       "(%P|%t) ERROR: ReactorTask Failed to activate "
                       "itself.\n"),
                      -1);
   }
 
   while (state_ != STATE_RUNNING) {
     condition_.wait(*thread_status_manager);
   }
 
   return 0;
 }

◆ reactor() [1/2]

void OpenDDS::DCPS::ReactorTask::reactor ( ACE_Reactor * reactor )

privatevirtual

Reimplemented from ACE_Event_Handler.

Definition at line 245 of file ReactorTask.cpp.

References ACE_Event_Handler::reactor().

 {
   ACE_Event_Handler::reactor(reactor);
 }

◆ reactor() [2/2]

ACE_Reactor * OpenDDS::DCPS::ReactorTask::reactor ( void ) const

privatevirtual

Reimplemented from ACE_Event_Handler.

Definition at line 250 of file ReactorTask.cpp.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL, and ACE_Event_Handler::reactor().

Referenced by stop().

 {
   return ACE_Event_Handler::reactor();
 }

◆ stop()

void OpenDDS::DCPS::ReactorTask::stop ( void )

Definition at line 196 of file ReactorTask.cpp.

References ACE_Event_Handler::DONT_CALL, ACE_Reactor::end_reactor_event_loop(), ACE_Proactor_Impl::get_handle(), ACE_Proactor::implementation(), lock_, OPENDDS_ASSERT, proactor_, reactor(), reactor_, ACE_Reactor::remove_handler(), state_, STATE_SHUT_DOWN, STATE_UNINITIALIZED, ACE_Task_Base::thr_mgr(), thread_status_manager_, and ACE_Task_Base::wait().

Referenced by OpenDDS::DCPS::Service_Participant::shutdown(), and OpenDDS::DCPS::TransportImpl::shutdown().

 {
   ACE_Reactor* reactor = 0;
   {
     GuardType guard(lock_);
 
     if (state_ == STATE_UNINITIALIZED || state_ == STATE_SHUT_DOWN) {
       // We are already "stopped".  Just return.
       return;
     }
 
     state_ = STATE_SHUT_DOWN;
 
 #if defined (ACE_HAS_WIN32_OVERLAPPED_IO) || defined (ACE_HAS_AIO_CALLS)
     // Remove the proactor handler so the reactor stops forwarding messages.
     if (proactor_) {
       reactor_->remove_handler(
         proactor_->implementation()->get_handle(),
         ACE_Event_Handler::DONT_CALL);
     }
 #endif
     reactor = reactor_;
   }
 
   if (reactor) {
     // We can't hold the lock when we call this, because the reactor threads may need to
     // access the lock as part of normal execution before they return to the reactor control loop
     reactor->end_reactor_event_loop();
   }
 
   {
     GuardType guard(lock_);
 
     // In the future, we will likely want to replace this assert with a new "SHUTTING_DOWN" state
     // which can be used to delay any potential new calls to open_reactor_task()
     OPENDDS_ASSERT(state_ == STATE_SHUT_DOWN);
 
     // Let's wait for the reactor task's thread to complete before we
     // leave this stop method.
     if (thread_status_manager_) {
       ThreadStatusManager::Sleeper sleeper(*thread_status_manager_);
       wait();
 
       // Reset the thread manager in case it goes away before the next open.
       thr_mgr(0);
     }
   }
 }

◆ svc()

int OpenDDS::DCPS::ReactorTask::svc ( void )

virtual

Reimplemented from ACE_Task_Base.

Definition at line 129 of file ReactorTask.cpp.

References OpenDDS::DCPS::RcObject::_add_ref(), ACE_ERROR, condition_, ACE_Thread_Manager::instance(), interceptor_, LM_ERROR, lock_, name_, OpenDDS::DCPS::ConditionVariable< Mutex >::notify_all(), ACE_Reactor::owner(), reactor_, reactor_owner_, ACE_Reactor::run_reactor_event_loop(), SIG_SETMASK, ACE_OS::sigfillset(), state_, STATE_RUNNING, ACE_Thread_Manager::thr_self(), ACE_OS::thr_sigsetmask(), OpenDDS::DCPS::ThreadStatusManager::thread_status_interval(), thread_status_manager_, and OpenDDS::DCPS::ThreadStatusManager::update_thread_status().

 {
   ThreadStatusManager::Start s(*thread_status_manager_, name_);
 
   {
     GuardType guard(lock_);
 
     // First off - We need to obtain our own reference to ourselves such
     // that we don't get deleted while still running in our own thread.
     // In essence, our current thread "owns" a copy of our reference.
     // It's all done with the magic of intrusive reference counting!
     _add_ref();
 
     // Ignore all signals to avoid
     //     ERROR: <something descriptive> Interrupted system call
     // The main thread will handle signals.
     sigset_t set;
     ACE_OS::sigfillset(&set);
     ACE_OS::thr_sigsetmask(SIG_SETMASK, &set, NULL);
 
     // Tell the reactor that this thread will be its owner
     if (reactor_->owner(ACE_Thread_Manager::instance()->thr_self()) != 0) {
       ACE_ERROR((LM_ERROR,
                  "(%P|%t) ERROR: Failed to change the reactor's owner().\n"));
     }
     reactor_owner_ = ACE_Thread_Manager::instance()->thr_self();
 
     interceptor_ = make_rch<Interceptor>(this, reactor_, reactor_owner_);
 
     // Advance the state.
     state_ = STATE_RUNNING;
     condition_.notify_all();
   }
 
   // Tell the reactor to handle events.
   if (thread_status_manager_->update_thread_status()) {
     while (state_ == STATE_RUNNING) {
       ACE_Time_Value t = thread_status_manager_->thread_status_interval().value();
       ThreadStatusManager::Sleeper sleeper(*thread_status_manager_);
       reactor_->run_reactor_event_loop(t, 0);
     }
 
   } else {
     reactor_->run_reactor_event_loop();
   }
 
   return 0;
 }

◆ wait_for_startup()

ACE_INLINE void OpenDDS::DCPS::ReactorTask::wait_for_startup ( ) const

Definition at line 51 of file ReactorTask.inl.

References ACE_INLINE, lock_, and wait_for_startup_i().

 {
   ACE_Guard<ACE_SYNCH_MUTEX> guard(lock_);
   wait_for_startup_i();
 }

◆ wait_for_startup_i()

void OpenDDS::DCPS::ReactorTask::wait_for_startup_i ( ) const

private

Definition at line 52 of file ReactorTask.cpp.

References condition_, state_, STATE_OPENING, STATE_UNINITIALIZED, TheServiceParticipant, thread_status_manager_, and OpenDDS::DCPS::ConditionVariable< Mutex >::wait().

Referenced by get_reactor(), get_reactor_owner(), interceptor(), and wait_for_startup().

 {
   while (state_ == STATE_UNINITIALIZED || state_ == STATE_OPENING) {
     condition_.wait(thread_status_manager_ ?
                       *thread_status_manager_ :
                       TheServiceParticipant->get_thread_status_manager());
   }
 }

Member Data Documentation

◆ condition_

ConditionVariableType OpenDDS::DCPS::ReactorTask::condition_

mutableprivate

Definition at line 103 of file ReactorTask.h.

Referenced by open_reactor_task(), svc(), and wait_for_startup_i().

◆ interceptor_

ReactorInterceptor_rch OpenDDS::DCPS::ReactorTask::interceptor_

private

Definition at line 119 of file ReactorTask.h.

Referenced by interceptor(), and svc().

◆ lock_

LockType OpenDDS::DCPS::ReactorTask::lock_

mutableprivate

Definition at line 102 of file ReactorTask.h.

Referenced by get_proactor(), get_reactor(), get_reactor_owner(), interceptor(), is_shut_down(), open_reactor_task(), stop(), svc(), and wait_for_startup().

◆ name_

String OpenDDS::DCPS::ReactorTask::name_

private

Definition at line 117 of file ReactorTask.h.

Referenced by open_reactor_task(), and svc().

◆ proactor_

ACE_Proactor* OpenDDS::DCPS::ReactorTask::proactor_

private

Definition at line 107 of file ReactorTask.h.

Referenced by cleanup(), get_proactor(), open_reactor_task(), and stop().

◆ reactor_

ACE_Reactor* OpenDDS::DCPS::ReactorTask::reactor_

private

Definition at line 105 of file ReactorTask.h.

Referenced by cleanup(), get_reactor(), open_reactor_task(), stop(), and svc().

◆ reactor_owner_

ACE_thread_t OpenDDS::DCPS::ReactorTask::reactor_owner_

private

Definition at line 106 of file ReactorTask.h.

Referenced by get_reactor_owner(), and svc().

◆ state_

State OpenDDS::DCPS::ReactorTask::state_

private

Definition at line 104 of file ReactorTask.h.

Referenced by is_shut_down(), open_reactor_task(), stop(), svc(), and wait_for_startup_i().

◆ thread_status_manager_

ThreadStatusManager* OpenDDS::DCPS::ReactorTask::thread_status_manager_

private

Definition at line 120 of file ReactorTask.h.

Referenced by open_reactor_task(), stop(), svc(), and wait_for_startup_i().

◆ timer_queue_

TimerQueueType* OpenDDS::DCPS::ReactorTask::timer_queue_

private

Definition at line 114 of file ReactorTask.h.

Referenced by cleanup(), and open_reactor_task().

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

Private Attributes
LockType	lock_

ConditionVariableType	condition_

State	state_

ACE_Reactor *	reactor_

ACE_thread_t	reactor_owner_

ACE_Proactor *	proactor_

TimerQueueType *	timer_queue_

String	name_

ReactorInterceptor_rch	interceptor_

ThreadStatusManager *	thread_status_manager_

Classes

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ConditionVariableType

◆ GuardType

◆ LockType

◆ TimerQueueType

Member Enumeration Documentation

◆ State

Constructor & Destructor Documentation

◆ ReactorTask()

◆ ~ReactorTask()

Member Function Documentation

◆ cleanup()

◆ close()

◆ get_proactor() [1/2]

◆ get_proactor() [2/2]

◆ get_reactor() [1/2]

◆ get_reactor() [2/2]

◆ get_reactor_owner()

◆ interceptor()

◆ is_shut_down()

◆ open()

◆ open_reactor_task()

◆ reactor() [1/2]

◆ reactor() [2/2]

◆ stop()

◆ svc()

◆ wait_for_startup()

◆ wait_for_startup_i()

Member Data Documentation

◆ condition_

◆ interceptor_

◆ lock_

◆ name_

◆ proactor_

◆ reactor_

◆ reactor_owner_

◆ state_

◆ thread_status_manager_

◆ timer_queue_