summaryrefslogtreecommitdiff
path: root/rust/kernel/block/mq/request.rs
diff options
context:
space:
mode:
authorAndreas Hindborg <a.hindborg@kernel.org>2025-09-02 11:55:10 +0200
committerJens Axboe <axboe@kernel.dk>2025-09-02 05:23:56 -0600
commit4ec052841a545297a276e833817990f0e13b1b32 (patch)
treee45b84d99cdadcf3c89d59432b72ee447723d3d4 /rust/kernel/block/mq/request.rs
parentbde50e28f7c5fe874112fe9d98e84873548fa8de (diff)
downloadlinux-4ec052841a545297a276e833817990f0e13b1b32.tar.gz
linux-4ec052841a545297a276e833817990f0e13b1b32.tar.bz2
linux-4ec052841a545297a276e833817990f0e13b1b32.zip
rust: block: add remote completion to `Request`
Allow users of rust block device driver API to schedule completion of requests via `blk_mq_complete_request_remote`. Reviewed-by: Alice Ryhl <aliceryhl@google.com> Reviewed-by: Daniel Almeida <daniel.almeida@collabora.com> Signed-off-by: Andreas Hindborg <a.hindborg@kernel.org> Link: https://lore.kernel.org/r/20250902-rnull-up-v6-16-v7-16-b5212cc89b98@kernel.org Signed-off-by: Jens Axboe <axboe@kernel.dk>
Diffstat (limited to 'rust/kernel/block/mq/request.rs')
-rw-r--r--rust/kernel/block/mq/request.rs17
1 files changed, 17 insertions, 0 deletions
diff --git a/rust/kernel/block/mq/request.rs b/rust/kernel/block/mq/request.rs
index 3848cfe63f77..f7f757f7459f 100644
--- a/rust/kernel/block/mq/request.rs
+++ b/rust/kernel/block/mq/request.rs
@@ -135,6 +135,23 @@ impl<T: Operations> Request<T> {
Ok(())
}
+ /// Complete the request by scheduling `Operations::complete` for
+ /// execution.
+ ///
+ /// The function may be scheduled locally, via SoftIRQ or remotely via IPMI.
+ /// See `blk_mq_complete_request_remote` in [`blk-mq.c`] for details.
+ ///
+ /// [`blk-mq.c`]: srctree/block/blk-mq.c
+ pub fn complete(this: ARef<Self>) {
+ let ptr = ARef::into_raw(this).cast::<bindings::request>().as_ptr();
+ // SAFETY: By type invariant, `self.0` is a valid `struct request`
+ if !unsafe { bindings::blk_mq_complete_request_remote(ptr) } {
+ // SAFETY: We released a refcount above that we can reclaim here.
+ let this = unsafe { Request::aref_from_raw(ptr) };
+ T::complete(this);
+ }
+ }
+
/// Return a pointer to the [`RequestDataWrapper`] stored in the private area
/// of the request structure.
///