resume libaio requesters maximal gets libaio_ctx->iodepth events

Signed-off-by: Coldwings <coldwings@me.com>
Coldwings · Jan 18, 2024 · fa0e119 · fa0e119
1 parent a3c638e
commit fa0e119
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/io/aio-wrapper.cpp b/io/aio-wrapper.cpp
@@ -153,7 +153,7 @@ namespace photon
  {
 retry:
  struct io_event events[IODEPTH_MAX];
- int n = HAVE_N_TRY(my_io_getevents, (0, IODEPTH_MAX, events));
+ int n = HAVE_N_TRY(my_io_getevents, (0, libaio_ctx->iodepth, events));
  for (int i=0; i<n; ++i)
  {
  auto piocb = (libaiocb*)events[i].obj;
@@ -166,7 +166,7 @@ namespace photon
  VALUE(piocb->u.c.buf), VALUE(piocb->u.c.resfd));
  thread_interrupt((thread *)events[i].data, EOK);
  }
- if (n == IODEPTH_MAX)
+ if (n == libaio_ctx->iodepth)
  {
  thread_yield();
  goto retry;