update sources to v12.1.0

[ceph.git] / ceph / src / os / bluestore / NVMEDevice.cc

diff --git a/ceph/src/os/bluestore/NVMEDevice.cc b/ceph/src/os/bluestore/NVMEDevice.cc
index 89b8b5552a3e26512cb673aac1f2b7fb07c7ee8b..9d1a84066720ca670802b06e8050830a246634a9 100644 (file)
--- a/ceph/src/os/bluestore/NVMEDevice.cc
+++ b/ceph/src/os/bluestore/NVMEDevice.cc
@@ -816,11 +816,7 @@ void io_complete(void *t, const struct spdk_nvme_cpl *completion)
         task->device->aio_callback(task->device->aio_callback_priv, ctx->priv);
       }
     } else {
-      if (ctx->num_running == 1) {
-       ctx->aio_wake();
-      } else {
-       --ctx->num_running;
-      }
+      ctx->try_aio_wake();
     }
     task->release_segs(queue);
     delete task;
@@ -837,11 +833,7 @@ void io_complete(void *t, const struct spdk_nvme_cpl *completion)
           task->device->aio_callback(task->device->aio_callback_priv, ctx->priv);
        }
       } else {
-       if (ctx->num_running == 1) {
-         ctx->aio_wake();
-       } else {
-         --ctx->num_running;
-       }
+       ctx->try_aio_wake();
       }
       delete task;
     } else {