OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner Struct Reference

#include <DiscoveryBase.h>

Inheritance diagram for OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner:

Collaboration diagram for OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner:

Public Member Functions
	ReactorRunner ()
int	svc ()
void	end ()
Public Attributes
unique_ptr< ACE_Reactor >	reactor_
ACE_Thread_Mutex	mtx_

Detailed Description

template<typename Participant>
struct OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner

Definition at line 1930 of file DiscoveryBase.h.

Constructor & Destructor Documentation

template<typename Participant>

OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner::ReactorRunner ( ) [inline]

Definition at line 1931 of file DiscoveryBase.h.

01931 {}

Member Function Documentation

template<typename Participant>

void OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner::end ( void ) [inline]

Definition at line 1940 of file DiscoveryBase.h.

References OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner::mtx_, OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner::reactor_, and ACE_Task_Base::wait().

Referenced by OpenDDS::DCPS::PeerDiscovery< Spdp >::~PeerDiscovery().

01941         {
01942           ACE_GUARD(ACE_Thread_Mutex, g, mtx_);
01943           if (reactor_) {
01944             reactor_->end_reactor_event_loop();
01945             wait();
01946           }
01947         }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename Participant>

int OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner::svc ( void ) [inline, virtual]

Reimplemented from ACE_Task_Base.

Definition at line 1933 of file DiscoveryBase.h.

References ACE_Thread_Manager::instance(), OpenDDS::DCPS::PeerDiscovery< Participant >::ReactorRunner::reactor_, and thr_self().

01934         {
01935           reactor_->owner(ACE_Thread_Manager::instance()->thr_self());
01936           reactor_->run_reactor_event_loop();
01937           return 0;
01938         }

Here is the call graph for this function: