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 446 of file Service_Participant.h.

---

Constructor & Destructor Documentation

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

(

)

[inline]

Definition at line 447 of file Service_Participant.h.

      : barrier_(2)
    { }

---

Member Function Documentation

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

(

void

)

[virtual]

Reimplemented from ACE_Task_Base.

Definition at line 223 of file Service_Participant.cpp.

References ACE_Thread_Manager::instance(), OpenDDS::DCPS::Service_Participant::instance(), OpenDDS::DCPS::Service_Participant::reactor_, OpenDDS::DCPS::Service_Participant::reactor_owner_, thr_self(), 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;
}

Here is the call graph for this function:

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

(

)

[inline]

Definition at line 451 of file Service_Participant.h.

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

{ barrier_.wait(); }

Here is the caller graph for this function:

---

Member Data Documentation

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

Definition at line 453 of file Service_Participant.h.

---

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

• Service_Participant.h
• Service_Participant.cpp