Method stop

dds/DCPS/ReactorTask.cpp:331–374

}

void ReactorTask::stop()
{
  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();
  }

  reactor_wrapper_.close();

  // 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.
  ThreadStatusManager::Sleeper sleeper(thread_status_manager_);
  wait();

  // Reset the thread manager in case it goes away before the next open.
  thr_mgr(0);
}

bool ReactorTask::on_thread() const
{