nvmet: cleanups the loop in nvmet_async_events_process

[ Upstream commit 1cdf9f7670a7d74e27177d5c390c2f8b3b9ba338 ]

Based-on-a-patch-by: Christoph Hellwig <hch@infradead.org>
Tested-by: Yi Zhang <yi.zhang@redhat.com>
Signed-off-by: David Milburn <dmilburn@redhat.com>
Signed-off-by: Christoph Hellwig <hch@lst.de>
Signed-off-by: Sasha Levin <sashal@kernel.org>

diff --git a/drivers/nvme/target/core.c b/drivers/nvme/target/core.c
index aa5ca222c6f59289283971604d43f5b16b4a9969..ac7ae031ce78db842c4c5b69fce15114afd95f3f 100644 (file)
--- 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)