Method waitForActivity

src/iocore/net/NetHandler.cc:340–385

}

int
NetHandler::waitForActivity(ink_hrtime timeout)
{
  EventIO *epd = nullptr;
#if TS_USE_LINUX_IO_URING
  IOUringContext *ur = IOUringContext::local_context();
#endif

  Metrics::Counter::increment(net_rsb.handler_run);
  SCOPED_MUTEX_LOCK(lock, mutex, this->thread);

  process_enabled_list();

#if TS_USE_LINUX_IO_URING
  ur->submit();
#endif

  // Polling event by PollCont
  PollCont  *p        = get_PollCont(this->thread);
  ink_hrtime pre_poll = ink_get_hrtime();
  p->do_poll(timeout);
  ink_hrtime post_poll = ink_get_hrtime();
  ink_hrtime poll_time = post_poll - pre_poll;

  // Get & Process polling result
  PollDescriptor *pd = get_PollDescriptor(this->thread);
  for (int x = 0; x < pd->result; x++) {
    epd                                = static_cast<EventIO *> get_ev_data(pd, x);
    int                          flags = get_ev_events(pd, x);
    epd->process_event(flags);
    ev_next_event(pd, x);
  }

  pd->result = 0;

  process_ready_list();
  ink_hrtime post_process = ink_get_hrtime();
  ink_hrtime process_time = post_process - post_poll;
  this->thread->metrics.current_slice.load(std::memory_order_acquire)->record_io_stats(poll_time, process_time);

#if TS_USE_LINUX_IO_URING
  ur->service();
#endif

  return EVENT_CONT;
}

void
NetHandler::signalActivity()