Method svc

dds/DCPS/ReactorTask.cpp:178–243

}

int ReactorTask::svc()
{
  // Every activated ACE task thread ends with close(), which drops a
  // self-reference. Take that reference here for both single-threaded and
  // multi-threaded reactor execution.
  _add_ref();

  if (n_threads_ > 1) {
    return run_reactor_i();
  }

  ThreadStatusManager::Start s(*thread_status_manager_, name_);

  {
    GuardType guard(lock_);

    // Ignore all signals to avoid
    //     ERROR: <something descriptive> Interrupted system call
    // The main thread will handle signals.
    sigset_t set;
    ACE_OS::sigfillset(&set);
    ACE_OS::thr_sigsetmask(SIG_SETMASK, &set, NULL);

    // Tell the reactor that this thread will be its owner
    if (reactor_->owner(ACE_Thread_Manager::instance()->thr_self()) != 0) {
      ACE_ERROR((LM_ERROR,
                 "(%P|%t) ERROR: Failed to change the reactor's owner().\n"));
    }
    reactor_owners_.bind(ACE_Thread_Manager::instance()->thr_self(), 1);

    ACE_Event_Handler::reactor(reactor_);

    // Advance the state.
    state_ = STATE_RUNNING;
    condition_.notify_all();
  }

  thread_status_period_ = thread_status_manager_->thread_status_interval();
  if (thread_status_period_) {
    tsm_updater_handler_ = make_rch<ThreadStatusManager::Updater>();
    thread_status_timer_ = reactor_wrapper_.schedule(*tsm_updater_handler_, thread_status_manager_,
                                                     thread_status_period_, thread_status_period_);

    if (thread_status_timer_ == ReactorWrapper::InvalidTimerId) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_ERROR, "(%P|%t) NOTICE: ReactorTask::svc: failed to "
                              "schedule timer for ThreadStatusManager::Updater\n"));
      }
    }
  }

  ConfigReaderListener_rch this_rch(this, inc_count());
  ConfigReader_rch config_reader = make_rch<ConfigReader>(TheServiceParticipant->config_store()->datareader_qos(), this_rch);
  TheServiceParticipant->config_topic()->connect(config_reader);

  ThreadStatusManager::Sleeper sleeper(thread_status_manager_);
  reactor_->run_reactor_event_loop();