From: David Milburn <dmilb...@redhat.com>

[ Upstream commit 1cdf9f7670a7d74e27177d5c390c2f8b3b9ba338 ]

Based-on-a-patch-by: Christoph Hellwig <h...@infradead.org>
Tested-by: Yi Zhang <yi.zh...@redhat.com>
Signed-off-by: David Milburn <dmilb...@redhat.com>
Signed-off-by: Christoph Hellwig <h...@lst.de>
Signed-off-by: Sasha Levin <sas...@kernel.org>
---
 drivers/nvme/target/core.c | 15 ++++++---------
 1 file changed, 6 insertions(+), 9 deletions(-)

diff --git a/drivers/nvme/target/core.c b/drivers/nvme/target/core.c
index aa5ca222c6f59..ac7ae031ce78d 100644
--- a/drivers/nvme/target/core.c
+++ b/drivers/nvme/target/core.c
@@ -134,15 +134,10 @@ static void nvmet_async_events_process(struct nvmet_ctrl 
*ctrl, u16 status)
        struct nvmet_async_event *aen;
        struct nvmet_req *req;
 
-       while (1) {
-               mutex_lock(&ctrl->lock);
-               aen = list_first_entry_or_null(&ctrl->async_events,
-                               struct nvmet_async_event, entry);
-               if (!aen || !ctrl->nr_async_event_cmds) {
-                       mutex_unlock(&ctrl->lock);
-                       break;
-               }
-
+       mutex_lock(&ctrl->lock);
+       while (ctrl->nr_async_event_cmds && !list_empty(&ctrl->async_events)) {
+               aen = list_first_entry(&ctrl->async_events,
+                                      struct nvmet_async_event, entry);
                req = ctrl->async_event_cmds[--ctrl->nr_async_event_cmds];
                if (status == 0)
                        nvmet_set_result(req, nvmet_async_event_result(aen));
@@ -152,7 +147,9 @@ static void nvmet_async_events_process(struct nvmet_ctrl 
*ctrl, u16 status)
 
                mutex_unlock(&ctrl->lock);
                nvmet_req_complete(req, status);
+               mutex_lock(&ctrl->lock);
        }
+       mutex_unlock(&ctrl->lock);
 }
 
 static void nvmet_async_events_free(struct nvmet_ctrl *ctrl)
-- 
2.25.1

Reply via email to