Method aio_thread_main

src/iocore/aio/AIO.cc:496–550

}

void *
AIOThreadInfo::aio_thread_main(AIOThreadInfo *thr_info)
{
  AIO_Reqs    *my_aio_req = thr_info->req;
  AIOCallback *op         = nullptr;
  ink_mutex_acquire(&my_aio_req->aio_mutex);
  for (;;) {
    do {
      if (TSSystemState::is_event_system_shut_down()) {
        ink_mutex_release(&my_aio_req->aio_mutex);
        return nullptr;
      }
      /* check if any pending requests on the atomic list */
      aio_move(my_aio_req);
      if (!(op = my_aio_req->aio_todo.pop())) {
        break;
      }
#ifdef AIO_STATS
      num_requests--;
      my_aio_req->queued--;
      ink_atomic_increment(&my_aio_req->pending, 1);
#endif
      ink_mutex_release(&my_aio_req->aio_mutex);

      // update the stats;
      if (op->aiocb.aio_lio_opcode == LIO_WRITE) {
        ts::Metrics::Counter::increment(aio_rsb.write_count);
        ts::Metrics::Counter::increment(aio_rsb.kb_write, op->aiocb.aio_nbytes >> 10);
      } else {
        ts::Metrics::Counter::increment(aio_rsb.read_count);
        ts::Metrics::Counter::increment(aio_rsb.kb_read, op->aiocb.aio_nbytes >> 10);
      }
      cache_op(reinterpret_cast<AIOCallback *>(op));
      ink_atomic_increment(&my_aio_req->requests_queued, -1);
#ifdef AIO_STATS
      ink_atomic_increment(&my_aio_req->pending, -1);
#endif
      op->link.prev = nullptr;
      op->link.next = nullptr;
      op->mutex     = op->action.mutex;
      if (op->thread == AIO_CALLBACK_THREAD_AIO) {
        SCOPED_MUTEX_LOCK(lock, op->mutex, thr_info->mutex->thread_holding);
        op->handleEvent(EVENT_NONE, nullptr);
      } else if (op->thread == AIO_CALLBACK_THREAD_ANY) {
        eventProcessor.schedule_imm(op);
      } else {
        op->thread->schedule_imm(op);
      }
      ink_mutex_acquire(&my_aio_req->aio_mutex);
    } while (true);
    timespec timedwait_msec = ink_hrtime_to_timespec(ink_get_hrtime() + HRTIME_MSECONDS(EThread::default_wait_interval_ms));
    ink_cond_timedwait(&my_aio_req->aio_cond, &my_aio_req->aio_mutex, &timedwait_msec);
  }
  return nullptr;
}

#if TS_USE_LINUX_IO_URING
#include "iocore/io_uring/IO_URING.h"