OpenDDS::DCPS::Service_Participant::ReactorTask Struct Reference

Inheritance diagram for OpenDDS::DCPS::Service_Participant::ReactorTask:

[legend]Collaboration diagram for OpenDDS::DCPS::Service_Participant::ReactorTask:

[legend]List of all members.

Public Member Functions
	ReactorTask ()
int	svc ()
void	wait_for_startup ()
Private Attributes
ACE_Barrier	barrier_

---

Detailed Description

Definition at line 431 of file Service_Participant.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::Service_Participant::ReactorTask::ReactorTask

(

)

[inline]

Definition at line 432 of file Service_Participant.h.

      : barrier_(2)
    { }

---

Member Function Documentation

int OpenDDS::DCPS::Service_Participant::ReactorTask::svc

(

)

Definition at line 223 of file Service_Participant.cpp.

References OpenDDS::DCPS::Service_Participant::instance(), OpenDDS::DCPS::Service_Participant::reactor_, OpenDDS::DCPS::Service_Participant::reactor_owner_, and wait_for_startup().

{
  Service_Participant* sp = instance();
  sp->reactor_->owner(ACE_Thread_Manager::instance()->thr_self());
  sp->reactor_owner_ = ACE_Thread_Manager::instance()->thr_self();
  this->wait_for_startup();
  sp->reactor_->run_reactor_event_loop();
  return 0;
}

void OpenDDS::DCPS::Service_Participant::ReactorTask::wait_for_startup

(

)

[inline]

Definition at line 436 of file Service_Participant.h.

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

{ barrier_.wait(); }

---

Member Data Documentation

ACE_Barrier OpenDDS::DCPS::Service_Participant::ReactorTask::barrier_ [private]

Definition at line 438 of file Service_Participant.h.

---

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

• Service_Participant.h
• Service_Participant.cpp

---