* [PATCH V2 1/3] lib: Introduce completion chain helper
2026-02-24 12:25 [PATCH V2 0/3] Ensure ordered namespace registration during async scan Maurizio Lombardi
@ 2026-02-24 12:25 ` Maurizio Lombardi
2026-02-24 14:35 ` Christoph Hellwig
2026-02-24 12:25 ` [PATCH V2 2/3] nvme-core: register namespaces in order during async scan Maurizio Lombardi
2026-02-24 12:25 ` [PATCH V2 3/3] scsi: Convert async scanning to use the completion chain helper Maurizio Lombardi
2 siblings, 1 reply; 7+ messages in thread
From: Maurizio Lombardi @ 2026-02-24 12:25 UTC (permalink / raw)
To: kbusch
Cc: hch, hare, chaitanyak, bvanassche, linux-scsi, linux-nvme,
James.Bottomley, mlombard, jmeneghi, emilne, bgurney
Introduce a new helper library, the completion chain, designed to serialize
asynchronous operations that must execute in a strict First-In, First-Out
(FIFO) order.
Certain workflows, particularly in storage drivers, require operations to
complete in the same sequence they were submitted.
This helper provides a generic mechanism to enforce this ordering.
compl_chain: The main structure representing the queue of operations
compl_chain_entry: An entry embedded in a per-operation structure
The typical usage pattern is:
* An operation is enqueued by calling compl_chain_add().
* The worker thread for the operation calls
compl_chain_wait(), which blocks until the previously
enqueued operation has finished.
* After the work is done, the thread calls compl_chain_complete().
This signals the next operation in the chain that it can now
proceed and removes the current entry from the list.
Signed-off-by: Maurizio Lombardi <mlombard@redhat.com>
---
include/linux/compl_chain.h | 35 +++++++++++
lib/Makefile | 2 +-
lib/compl_chain.c | 120 ++++++++++++++++++++++++++++++++++++
3 files changed, 156 insertions(+), 1 deletion(-)
create mode 100644 include/linux/compl_chain.h
create mode 100644 lib/compl_chain.c
diff --git a/include/linux/compl_chain.h b/include/linux/compl_chain.h
new file mode 100644
index 000000000000..a2bf271144e0
--- /dev/null
+++ b/include/linux/compl_chain.h
@@ -0,0 +1,35 @@
+/* SPDX-License-Identifier: GPL-2.0 */
+#ifndef _LINUX_COMPLETION_CHAIN_H
+#define _LINUX_COMPLETION_CHAIN_H
+
+#include <linux/list.h>
+#include <linux/completion.h>
+#include <linux/spinlock.h>
+
+struct compl_chain {
+ spinlock_t lock;
+ struct list_head list;
+};
+
+#define COMPL_CHAIN_INIT(name) \
+ { .lock = __SPIN_LOCK_UNLOCKED((name).lock), \
+ .list = LIST_HEAD_INIT((name).list) }
+
+#define DEFINE_COMPL_CHAIN(name) \
+ struct compl_chain name = COMPL_CHAIN_INIT(name)
+
+struct compl_chain_entry {
+ struct compl_chain *chain;
+ struct list_head list;
+ struct completion prev_finished;
+};
+
+void compl_chain_init(struct compl_chain *chain);
+void compl_chain_add(struct compl_chain *chain,
+ struct compl_chain_entry *entry);
+void compl_chain_wait(struct compl_chain_entry *entry);
+void compl_chain_complete(struct compl_chain_entry *entry);
+bool compl_chain_pending(struct compl_chain_entry *entry);
+void compl_chain_flush(struct compl_chain *chain);
+
+#endif /* _LINUX_COMPLETION_CHAIN_H */
diff --git a/lib/Makefile b/lib/Makefile
index 1b9ee167517f..c3ccd82bb190 100644
--- a/lib/Makefile
+++ b/lib/Makefile
@@ -58,7 +58,7 @@ obj-y += bcd.o sort.o parser.o debug_locks.o random32.o \
bsearch.o find_bit.o llist.o lwq.o memweight.o kfifo.o \
percpu-refcount.o rhashtable.o base64.o \
once.o refcount.o rcuref.o usercopy.o errseq.o bucket_locks.o \
- generic-radix-tree.o bitmap-str.o
+ generic-radix-tree.o bitmap-str.o compl_chain.o
obj-y += string_helpers.o
obj-y += hexdump.o
obj-$(CONFIG_TEST_HEXDUMP) += test_hexdump.o
diff --git a/lib/compl_chain.c b/lib/compl_chain.c
new file mode 100644
index 000000000000..4e4f47b1cff9
--- /dev/null
+++ b/lib/compl_chain.c
@@ -0,0 +1,120 @@
+// SPDX-License-Identifier: GPL-2.0
+/*
+ * Author: Maurizio Lombardi <mlombard@redhat.com>
+ */
+#include <linux/compl_chain.h>
+
+/**
+ * compl_chain_init - Initialize a completion chain
+ * @chain: The completion chain to be initialized.
+ *
+ * Initializes a compl_chain structure
+ */
+void compl_chain_init(struct compl_chain *chain)
+{
+ spin_lock_init(&chain->lock);
+ INIT_LIST_HEAD(&chain->list);
+}
+EXPORT_SYMBOL_GPL(compl_chain_init);
+
+/**
+ * compl_chain_add - Add a new entry to the tail of the chain
+ * @chain: The completion chain to add the entry to.
+ * @entry: The entry to be enqueued.
+ *
+ * Adds a new operation to the end of the queue.
+ * If the chain is empty when this entry is added, it is
+ * immediately marked as ready to run, as there is no
+ * preceding operation to wait for.
+ */
+void compl_chain_add(struct compl_chain *chain,
+ struct compl_chain_entry *entry)
+{
+ init_completion(&entry->prev_finished);
+ INIT_LIST_HEAD(&entry->list);
+
+ WRITE_ONCE(entry->chain, chain);
+
+ spin_lock(&chain->lock);
+ if (list_empty(&chain->list))
+ complete_all(&entry->prev_finished);
+ list_add_tail(&entry->list, &chain->list);
+ spin_unlock(&chain->lock);
+}
+EXPORT_SYMBOL_GPL(compl_chain_add);
+
+/**
+ * compl_chain_wait - Wait for the preceding operation to finish
+ * @entry: The entry for the current operation.
+ *
+ * Blocks the current execution thread until the
+ * previous entry in the chain has called compl_chain_complete().
+ */
+void compl_chain_wait(struct compl_chain_entry *entry)
+{
+ WARN_ON(!entry->chain);
+
+ wait_for_completion(&entry->prev_finished);
+}
+EXPORT_SYMBOL_GPL(compl_chain_wait);
+
+/**
+ * compl_chain_complete - Mark an operation as complete and signal the next one
+ * @entry: The entry for the operation that has just finished.
+ *
+ * Removes the current entry from the chain and signals the next waiting
+ * operation (if one exists) that it is now allowed to proceed.
+ */
+void compl_chain_complete(struct compl_chain_entry *entry)
+{
+ struct compl_chain *chain = entry->chain;
+
+ WARN_ON(!chain);
+
+ wait_for_completion(&entry->prev_finished);
+
+ spin_lock(&chain->lock);
+ list_del(&entry->list);
+ if (!list_empty(&chain->list)) {
+ struct compl_chain_entry *next =
+ list_first_entry(&chain->list,
+ struct compl_chain_entry, list);
+ complete_all(&next->prev_finished);
+ }
+ spin_unlock(&chain->lock);
+
+ WRITE_ONCE(entry->chain, NULL);
+}
+EXPORT_SYMBOL_GPL(compl_chain_complete);
+
+/**
+ * compl_chain_pending - Check if an operation is pending
+ * @entry: The entry to check.
+ *
+ * Returns true if an entry has been added to a chain and hasn't yet
+ * been completed.
+ */
+bool compl_chain_pending(struct compl_chain_entry *entry)
+{
+ return READ_ONCE(entry->chain) != NULL;
+}
+EXPORT_SYMBOL_GPL(compl_chain_pending);
+
+/**
+ * compl_chain_flush - Wait for all operations currently in the chain to finish
+ * @chain: The completion chain to flush.
+ *
+ * Enqueues a dummy entry into the chain and immediately waits for it to
+ * complete. Because operations execute in strict FIFO order, this acts as
+ * a barrier, blocking the calling thread until all previously enqueued
+ * operations have finished.
+ */
+void compl_chain_flush(struct compl_chain *chain)
+{
+ struct compl_chain_entry dummy_entry;
+
+ compl_chain_add(chain, &dummy_entry);
+ compl_chain_complete(&dummy_entry);
+}
+EXPORT_SYMBOL_GPL(compl_chain_flush);
+
--
2.53.0
^ permalink raw reply related [flat|nested] 7+ messages in thread* Re: [PATCH V2 1/3] lib: Introduce completion chain helper
2026-02-24 12:25 ` [PATCH V2 1/3] lib: Introduce completion chain helper Maurizio Lombardi
@ 2026-02-24 14:35 ` Christoph Hellwig
0 siblings, 0 replies; 7+ messages in thread
From: Christoph Hellwig @ 2026-02-24 14:35 UTC (permalink / raw)
To: Maurizio Lombardi
Cc: kbusch, hch, hare, chaitanyak, bvanassche, linux-scsi, linux-nvme,
James.Bottomley, mlombard, jmeneghi, emilne, bgurney
Looks good:
Reviewed-by: Christoph Hellwig <hch@lst.de>
^ permalink raw reply [flat|nested] 7+ messages in thread
* [PATCH V2 2/3] nvme-core: register namespaces in order during async scan
2026-02-24 12:25 [PATCH V2 0/3] Ensure ordered namespace registration during async scan Maurizio Lombardi
2026-02-24 12:25 ` [PATCH V2 1/3] lib: Introduce completion chain helper Maurizio Lombardi
@ 2026-02-24 12:25 ` Maurizio Lombardi
2026-02-24 14:37 ` Christoph Hellwig
2026-02-24 12:25 ` [PATCH V2 3/3] scsi: Convert async scanning to use the completion chain helper Maurizio Lombardi
2 siblings, 1 reply; 7+ messages in thread
From: Maurizio Lombardi @ 2026-02-24 12:25 UTC (permalink / raw)
To: kbusch
Cc: hch, hare, chaitanyak, bvanassche, linux-scsi, linux-nvme,
James.Bottomley, mlombard, jmeneghi, emilne, bgurney
The fully asynchronous namespace scanning, while fast, can result in
namespaces being allocated and registered out of order. This leads to
unpredictable device naming across reboots which can be confusing
for users.
To solve this, introduce a serialization mechanism for the asynchronous
namespace scan. This is achieved by using the generic compl_chain helper,
which ensures that the initialization of one namespace (nvme_alloc_ns)
completes before the next one begins.
This approach preserves the performance benefits of asynchronous
identification while guaranteeing that the final device registration
occurs in the correct order.
Performance testing shows that this change has no noticeable impact on
scan times compared to the fully asynchronous method.
High latency NVMe/TCP, ~150ms ping, 100 namespaces
Synchronous namespace scan (RHEL-10.1): 32375ms
Fully async namespace scan (7.0-rc1): 2543ms
Async namespace scan with dependency chain (7.0-rc1): 2431ms
Low latency NVMe/TCP, ~0.2ms ping, 100 namespaces
Synchronous namespace scan (RHEL-10.1): 352ms
Fully async namespace scan (7.0-rc1): 248ms
Async namespace scan with dependency chain (7.0-rc1): 191ms
Signed-off-by: Maurizio Lombardi <mlombard@redhat.com>
---
drivers/nvme/host/core.c | 94 +++++++++++++++++++++++++---------------
drivers/nvme/host/nvme.h | 2 +
2 files changed, 62 insertions(+), 34 deletions(-)
diff --git a/drivers/nvme/host/core.c b/drivers/nvme/host/core.c
index f5ebcaa2f859..24c62bdf8abc 100644
--- a/drivers/nvme/host/core.c
+++ b/drivers/nvme/host/core.c
@@ -4105,13 +4105,27 @@ static void nvme_ns_add_to_ctrl_list(struct nvme_ns *ns)
list_add_rcu(&ns->list, &ns->ctrl->namespaces);
}
-static void nvme_alloc_ns(struct nvme_ctrl *ctrl, struct nvme_ns_info *info)
+/**
+ * struct async_scan_task - keeps track of controller & NSID to scan
+ * @entry link to the completion chain list
+ * @ctrl: Controller on which namespaces are being scanned
+ * @nsid: The NSID to scan
+ */
+struct async_scan_task {
+ struct compl_chain_entry chain_entry;
+ struct nvme_ctrl *ctrl;
+ u32 nsid;
+};
+
+static void nvme_alloc_ns(struct nvme_ctrl *ctrl, struct nvme_ns_info *info,
+ struct compl_chain_entry *cc_entry)
{
struct queue_limits lim = { };
struct nvme_ns *ns;
struct gendisk *disk;
int node = ctrl->numa_node;
bool last_path = false;
+ int r;
ns = kzalloc_node(sizeof(*ns), GFP_KERNEL, node);
if (!ns)
@@ -4134,7 +4148,19 @@ static void nvme_alloc_ns(struct nvme_ctrl *ctrl, struct nvme_ns_info *info)
ns->ctrl = ctrl;
kref_init(&ns->kref);
- if (nvme_init_ns_head(ns, info))
+ /*
+ * Wait for the previous async task to finish before
+ * allocating the namespace.
+ */
+ if (cc_entry)
+ compl_chain_wait(cc_entry);
+
+ r = nvme_init_ns_head(ns, info);
+
+ if (cc_entry)
+ compl_chain_complete(cc_entry);
+
+ if (r)
goto out_cleanup_disk;
/*
@@ -4309,7 +4335,8 @@ static void nvme_validate_ns(struct nvme_ns *ns, struct nvme_ns_info *info)
nvme_ns_remove(ns);
}
-static void nvme_scan_ns(struct nvme_ctrl *ctrl, unsigned nsid)
+static void nvme_scan_ns(struct nvme_ctrl *ctrl, unsigned int nsid,
+ struct compl_chain_entry *cc_entry)
{
struct nvme_ns_info info = { .nsid = nsid };
struct nvme_ns *ns;
@@ -4348,40 +4375,30 @@ static void nvme_scan_ns(struct nvme_ctrl *ctrl, unsigned nsid)
ns = nvme_find_get_ns(ctrl, nsid);
if (ns) {
+ /* Release the chain early so the next task can proceed */
+ if (cc_entry)
+ compl_chain_complete(cc_entry);
nvme_validate_ns(ns, &info);
nvme_put_ns(ns);
} else {
- nvme_alloc_ns(ctrl, &info);
+ nvme_alloc_ns(ctrl, &info, cc_entry);
}
}
-/**
- * struct async_scan_info - keeps track of controller & NSIDs to scan
- * @ctrl: Controller on which namespaces are being scanned
- * @next_nsid: Index of next NSID to scan in ns_list
- * @ns_list: Pointer to list of NSIDs to scan
- *
- * Note: There is a single async_scan_info structure shared by all instances
- * of nvme_scan_ns_async() scanning a given controller, so the atomic
- * operations on next_nsid are critical to ensure each instance scans a unique
- * NSID.
- */
-struct async_scan_info {
- struct nvme_ctrl *ctrl;
- atomic_t next_nsid;
- __le32 *ns_list;
-};
-
static void nvme_scan_ns_async(void *data, async_cookie_t cookie)
{
- struct async_scan_info *scan_info = data;
- int idx;
- u32 nsid;
+ struct async_scan_task *task = data;
+
+ nvme_scan_ns(task->ctrl, task->nsid, &task->chain_entry);
- idx = (u32)atomic_fetch_inc(&scan_info->next_nsid);
- nsid = le32_to_cpu(scan_info->ns_list[idx]);
+ /*
+ * If the task failed early and returned without completing the
+ * chain entry, ensure the chain progresses safely.
+ */
+ if (compl_chain_pending(&task->chain_entry))
+ compl_chain_complete(&task->chain_entry);
- nvme_scan_ns(scan_info->ctrl, nsid);
+ kfree(task);
}
static void nvme_remove_invalid_namespaces(struct nvme_ctrl *ctrl,
@@ -4411,14 +4428,12 @@ static int nvme_scan_ns_list(struct nvme_ctrl *ctrl)
u32 prev = 0;
int ret = 0, i;
ASYNC_DOMAIN(domain);
- struct async_scan_info scan_info;
+ struct async_scan_task *task;
ns_list = kzalloc(NVME_IDENTIFY_DATA_SIZE, GFP_KERNEL);
if (!ns_list)
return -ENOMEM;
- scan_info.ctrl = ctrl;
- scan_info.ns_list = ns_list;
for (;;) {
struct nvme_command cmd = {
.identify.opcode = nvme_admin_identify,
@@ -4434,20 +4449,30 @@ static int nvme_scan_ns_list(struct nvme_ctrl *ctrl)
goto free;
}
- atomic_set(&scan_info.next_nsid, 0);
for (i = 0; i < nr_entries; i++) {
u32 nsid = le32_to_cpu(ns_list[i]);
if (!nsid) /* end of the list? */
goto out;
- async_schedule_domain(nvme_scan_ns_async, &scan_info,
+
+ task = kmalloc_obj(*task);
+ if (!task) {
+ ret = -ENOMEM;
+ goto out;
+ }
+
+ task->nsid = nsid;
+ task->ctrl = ctrl;
+ compl_chain_add(&ctrl->scan_chain, &task->chain_entry);
+
+ async_schedule_domain(nvme_scan_ns_async, task,
&domain);
while (++prev < nsid)
nvme_ns_remove_by_nsid(ctrl, prev);
}
- async_synchronize_full_domain(&domain);
}
out:
+ async_synchronize_full_domain(&domain);
nvme_remove_invalid_namespaces(ctrl, prev);
free:
async_synchronize_full_domain(&domain);
@@ -4466,7 +4491,7 @@ static void nvme_scan_ns_sequential(struct nvme_ctrl *ctrl)
kfree(id);
for (i = 1; i <= nn; i++)
- nvme_scan_ns(ctrl, i);
+ nvme_scan_ns(ctrl, i, NULL);
nvme_remove_invalid_namespaces(ctrl, nn);
}
@@ -5094,6 +5119,7 @@ int nvme_init_ctrl(struct nvme_ctrl *ctrl, struct device *dev,
mutex_init(&ctrl->scan_lock);
INIT_LIST_HEAD(&ctrl->namespaces);
+ compl_chain_init(&ctrl->scan_chain);
xa_init(&ctrl->cels);
ctrl->dev = dev;
ctrl->ops = ops;
diff --git a/drivers/nvme/host/nvme.h b/drivers/nvme/host/nvme.h
index 9a5f28c5103c..95f8c40ec86b 100644
--- a/drivers/nvme/host/nvme.h
+++ b/drivers/nvme/host/nvme.h
@@ -17,6 +17,7 @@
#include <linux/wait.h>
#include <linux/t10-pi.h>
#include <linux/ratelimit_types.h>
+#include <linux/compl_chain.h>
#include <trace/events/block.h>
@@ -294,6 +295,7 @@ struct nvme_ctrl {
struct blk_mq_tag_set *tagset;
struct blk_mq_tag_set *admin_tagset;
struct list_head namespaces;
+ struct compl_chain scan_chain;
struct mutex namespaces_lock;
struct srcu_struct srcu;
struct device ctrl_device;
--
2.53.0
^ permalink raw reply related [flat|nested] 7+ messages in thread* Re: [PATCH V2 2/3] nvme-core: register namespaces in order during async scan
2026-02-24 12:25 ` [PATCH V2 2/3] nvme-core: register namespaces in order during async scan Maurizio Lombardi
@ 2026-02-24 14:37 ` Christoph Hellwig
0 siblings, 0 replies; 7+ messages in thread
From: Christoph Hellwig @ 2026-02-24 14:37 UTC (permalink / raw)
To: Maurizio Lombardi
Cc: kbusch, hch, hare, chaitanyak, bvanassche, linux-scsi, linux-nvme,
James.Bottomley, mlombard, jmeneghi, emilne, bgurney
Looks good:
Reviewed-by: Christoph Hellwig <hch@lst.de>
^ permalink raw reply [flat|nested] 7+ messages in thread
* [PATCH V2 3/3] scsi: Convert async scanning to use the completion chain helper
2026-02-24 12:25 [PATCH V2 0/3] Ensure ordered namespace registration during async scan Maurizio Lombardi
2026-02-24 12:25 ` [PATCH V2 1/3] lib: Introduce completion chain helper Maurizio Lombardi
2026-02-24 12:25 ` [PATCH V2 2/3] nvme-core: register namespaces in order during async scan Maurizio Lombardi
@ 2026-02-24 12:25 ` Maurizio Lombardi
2026-02-24 14:39 ` Christoph Hellwig
2 siblings, 1 reply; 7+ messages in thread
From: Maurizio Lombardi @ 2026-02-24 12:25 UTC (permalink / raw)
To: kbusch
Cc: hch, hare, chaitanyak, bvanassche, linux-scsi, linux-nvme,
James.Bottomley, mlombard, jmeneghi, emilne, bgurney
The asynchronous host scanning logic in scsi_scan.c uses a custom,
open-coded implementation to serialize scans. This involves a manually
managed list of tasks, each with its own completion, to ensure that hosts
are scanned and added to the system in a deterministic order.
Refactors the SCSI async scanning implementation to use the new
compl_async_chain helper. This simplifies the scsi_scan.c code and makes
the serialization logic more readable.
Signed-off-by: Maurizio Lombardi <mlombard@redhat.com>
---
drivers/scsi/scsi_priv.h | 2 +-
drivers/scsi/scsi_scan.c | 68 +++++-----------------------------------
2 files changed, 9 insertions(+), 61 deletions(-)
diff --git a/drivers/scsi/scsi_priv.h b/drivers/scsi/scsi_priv.h
index 7a193cc04e5b..d8a157bc9078 100644
--- a/drivers/scsi/scsi_priv.h
+++ b/drivers/scsi/scsi_priv.h
@@ -132,7 +132,7 @@ extern void scsi_exit_procfs(void);
/* scsi_scan.c */
void scsi_enable_async_suspend(struct device *dev);
-extern int scsi_complete_async_scans(void);
+extern void scsi_complete_async_scans(void);
extern int scsi_scan_host_selected(struct Scsi_Host *, unsigned int,
unsigned int, u64, enum scsi_scan_mode);
extern void scsi_forget_host(struct Scsi_Host *);
diff --git a/drivers/scsi/scsi_scan.c b/drivers/scsi/scsi_scan.c
index 60c06fa4ec32..4157d8fe4893 100644
--- a/drivers/scsi/scsi_scan.c
+++ b/drivers/scsi/scsi_scan.c
@@ -36,6 +36,7 @@
#include <linux/async.h>
#include <linux/slab.h>
#include <linux/unaligned.h>
+#include <linux/compl_chain.h>
#include <scsi/scsi.h>
#include <scsi/scsi_cmnd.h>
@@ -112,14 +113,11 @@ MODULE_PARM_DESC(inq_timeout,
"Timeout (in seconds) waiting for devices to answer INQUIRY."
" Default is 20. Some devices may need more; most need less.");
-/* This lock protects only this list */
-static DEFINE_SPINLOCK(async_scan_lock);
-static LIST_HEAD(scanning_hosts);
+DEFINE_COMPL_CHAIN(scanning_hosts);
struct async_scan_data {
- struct list_head list;
+ struct compl_chain_entry chain_entry;
struct Scsi_Host *shost;
- struct completion prev_finished;
};
/*
@@ -146,48 +144,10 @@ void scsi_enable_async_suspend(struct device *dev)
* started scanning after this function was called may or may not have
* finished.
*/
-int scsi_complete_async_scans(void)
+void scsi_complete_async_scans(void)
{
- struct async_scan_data *data;
-
- do {
- scoped_guard(spinlock, &async_scan_lock)
- if (list_empty(&scanning_hosts))
- return 0;
- /* If we can't get memory immediately, that's OK. Just
- * sleep a little. Even if we never get memory, the async
- * scans will finish eventually.
- */
- data = kmalloc(sizeof(*data), GFP_KERNEL);
- if (!data)
- msleep(1);
- } while (!data);
-
- data->shost = NULL;
- init_completion(&data->prev_finished);
-
- spin_lock(&async_scan_lock);
- /* Check that there's still somebody else on the list */
- if (list_empty(&scanning_hosts))
- goto done;
- list_add_tail(&data->list, &scanning_hosts);
- spin_unlock(&async_scan_lock);
-
printk(KERN_INFO "scsi: waiting for bus probes to complete ...\n");
- wait_for_completion(&data->prev_finished);
-
- spin_lock(&async_scan_lock);
- list_del(&data->list);
- if (!list_empty(&scanning_hosts)) {
- struct async_scan_data *next = list_entry(scanning_hosts.next,
- struct async_scan_data, list);
- complete(&next->prev_finished);
- }
- done:
- spin_unlock(&async_scan_lock);
-
- kfree(data);
- return 0;
+ compl_chain_flush(&scanning_hosts);
}
/**
@@ -1960,18 +1920,13 @@ static struct async_scan_data *scsi_prep_async_scan(struct Scsi_Host *shost)
data->shost = scsi_host_get(shost);
if (!data->shost)
goto err;
- init_completion(&data->prev_finished);
spin_lock_irqsave(shost->host_lock, flags);
shost->async_scan = 1;
spin_unlock_irqrestore(shost->host_lock, flags);
mutex_unlock(&shost->scan_mutex);
- spin_lock(&async_scan_lock);
- if (list_empty(&scanning_hosts))
- complete(&data->prev_finished);
- list_add_tail(&data->list, &scanning_hosts);
- spin_unlock(&async_scan_lock);
+ compl_chain_add(&scanning_hosts, &data->chain_entry);
return data;
@@ -2008,7 +1963,7 @@ static void scsi_finish_async_scan(struct async_scan_data *data)
return;
}
- wait_for_completion(&data->prev_finished);
+ compl_chain_wait(&data->chain_entry);
scsi_sysfs_add_devices(shost);
@@ -2018,14 +1973,7 @@ static void scsi_finish_async_scan(struct async_scan_data *data)
mutex_unlock(&shost->scan_mutex);
- spin_lock(&async_scan_lock);
- list_del(&data->list);
- if (!list_empty(&scanning_hosts)) {
- struct async_scan_data *next = list_entry(scanning_hosts.next,
- struct async_scan_data, list);
- complete(&next->prev_finished);
- }
- spin_unlock(&async_scan_lock);
+ compl_chain_complete(&data->chain_entry);
scsi_autopm_put_host(shost);
scsi_host_put(shost);
--
2.53.0
^ permalink raw reply related [flat|nested] 7+ messages in thread* Re: [PATCH V2 3/3] scsi: Convert async scanning to use the completion chain helper
2026-02-24 12:25 ` [PATCH V2 3/3] scsi: Convert async scanning to use the completion chain helper Maurizio Lombardi
@ 2026-02-24 14:39 ` Christoph Hellwig
0 siblings, 0 replies; 7+ messages in thread
From: Christoph Hellwig @ 2026-02-24 14:39 UTC (permalink / raw)
To: Maurizio Lombardi
Cc: kbusch, hch, hare, chaitanyak, bvanassche, linux-scsi, linux-nvme,
James.Bottomley, mlombard, jmeneghi, emilne, bgurney
On Tue, Feb 24, 2026 at 01:25:05PM +0100, Maurizio Lombardi wrote:
> diff --git a/drivers/scsi/scsi_priv.h b/drivers/scsi/scsi_priv.h
> index 7a193cc04e5b..d8a157bc9078 100644
> --- a/drivers/scsi/scsi_priv.h
> +++ b/drivers/scsi/scsi_priv.h
> @@ -132,7 +132,7 @@ extern void scsi_exit_procfs(void);
>
> /* scsi_scan.c */
> void scsi_enable_async_suspend(struct device *dev);
> -extern int scsi_complete_async_scans(void);
> +extern void scsi_complete_async_scans(void);
No need for the extern here.
> +DEFINE_COMPL_CHAIN(scanning_hosts);
This looks like it should be marked static.
^ permalink raw reply [flat|nested] 7+ messages in thread