Method open_reactor_task

dds/DCPS/ReactorTask.cpp:157–176

}

int ReactorTask::open_reactor_task(ThreadStatusManager* thread_status_manager,
                                   const String& name,
                                   ACE_Reactor* reactor)
{
  GuardType guard(lock_);
  init_i(thread_status_manager, name, reactor);

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

int ReactorTask::svc()
{