Method svc

dds/DCPS/transport/framework/QueueTaskBase_T.h:109–163

The "mainline" executed by the worker thread.

  /// The "mainline" executed by the worker thread.
  virtual int svc() {
    DBG_ENTRY("QueueTaskBase","svc");

    ThreadStatusManager& thread_status_manager = TheServiceParticipant->get_thread_status_manager();

    ThreadStatusManager::Start s(thread_status_manager, "QueueTaskBase");

    thr_id_ = ACE_OS::thr_self();

    // Start the "GetWork-And-PerformWork" loop for the current worker thread.
    while (!this->shutdown_initiated_) {
      T req;
      {
        GuardType guard(this->lock_);

        if (this->queue_.is_empty() && !shutdown_initiated_) {
          const TimeDuration thread_status_interval = thread_status_manager.thread_status_interval();
          if (thread_status_interval) {
            MonotonicTimePoint expire = MonotonicTimePoint::now() + thread_status_interval;

            do {
              work_available_.wait_until(expire, thread_status_manager);

              MonotonicTimePoint now = MonotonicTimePoint::now();
              if (now > expire) {
                expire = now + thread_status_interval;
              }
            } while (this->queue_.is_empty() && !shutdown_initiated_);
          } else {
            this->work_available_.wait(thread_status_manager);
          }
        }

        if (this->shutdown_initiated_)
          break;

        int result = queue_.dequeue_head(req);

        if (result != 0) {
          //I'm not sure why this thread got more signals than actual signals
          //when using thread_per_connection and the user application thread
          //send requests without interval. We just need ignore the dequeue
          //failure.
          //ACE_ERROR ((LM_ERROR, "(%P|%t) ERROR: QueueTaskBase::svc  %p\n",
          //  ACE_TEXT("dequeue_head")));
          continue;
        }
      }

      this->execute(req);
    }

    // This will never get executed.
    return 0;
  }

  /// Called when the thread exits.
  virtual int close(u_long flag = 0) {