Received: by 2002:a89:d88:0:b0:1fa:5c73:8e2d with SMTP id eb8csp2643531lqb; Tue, 28 May 2024 06:28:16 -0700 (PDT) X-Forwarded-Encrypted: i=3; AJvYcCVn4mUCfGk1DyGD4+uvBobmHDekVSnOgVvD4MUL9jiSjSn0d0hT3WgkK/GWd1eaYYHrvnxFkFvSaTrAGBD3e0LJSlVDfce+FbDqmSSqRA== X-Google-Smtp-Source: AGHT+IHJRa3mKuDMawYpFtzyRMf12cnGgarp8ajz9ZdxRK5q3uGlGJ9jnwQXxutU4lXf3xl//ol2 X-Received: by 2002:a50:d68b:0:b0:572:6846:b899 with SMTP id 4fb4d7f45d1cf-578519ba7abmr7514466a12.41.1716902895975; Tue, 28 May 2024 06:28:15 -0700 (PDT) ARC-Seal: i=2; a=rsa-sha256; t=1716902895; cv=pass; d=google.com; s=arc-20160816; b=FsQL3DcaMYp2fxy2+BnHrwuYuDOwEO1lee2FQz5a4hdOEuolfGUNYbv2S4J0e1O1Xi 88aU8PJdidn/FsTt8Mv9EoPOE1NADXzTPxsximviTpquvU7WWp4M5AKJoZ05PB6sVHjf RX939TlrNsMYWWiQYw25C+5qR9DnYEAulkd7f4BGac+pG/ciy9wMe4Ey3MAQW0GEjXP0 yRgjaiWIZ1ElrgG8/GY1gWP08Nd1phIO42L9JgvkaSrpYdvMjocglov4tbcMayQeXJp+ 1LMxQurvW4Uh27F8g+MnZ7qiDgYZHDFA/AYs8RYMQF22xb9PMcZnetKe2HXf822y5ZSp hQLQ== ARC-Message-Signature: i=2; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=content-transfer-encoding:mime-version:list-unsubscribe :list-subscribe:list-id:precedence:feedback-id:references :in-reply-to:message-id:subject:cc:from:to:date:dkim-signature; bh=qqtgzJlmFD04DRomp01Lp8PnnmfNEYuAnmxTd28A+mA=; fh=5Uk5eHj3wIw8VuTUn/umANY+EZ6Ozb0aCmYyC7Yu+LQ=; b=e5eJSIEvIDy+eq6ZPD4QsznpYIYOpcnOQhAyDV8HDS1Wt4+dcBdA6cepJrNu27v0il IUCwrAui0kehwDZ9dKvfhIiJb6RTWzwXPHdcJGUuClMhlRKJCzFZcTzjbMkhVEVNY2cp OqMlzeRY0sQtHGhnQ1pYsVjY7tI3oypqK2RMLCQFtgimgKrt64t6xE9xyEe1Bax2jTho Syl9ufxCZF29X58i8IJd7DF0DEigtML6GFQBcZEIoqnSxDGxeNtgBPTraDYRNot3eApE yM8A5JCs7x8PgKxpfAHpJgvsE2OZN0sTMn2IOTAEk0P+osup8LJobOru8A6WoOMb373M VCCA==; dara=google.com ARC-Authentication-Results: i=2; mx.google.com; dkim=pass header.i=@proton.me header.s=protonmail header.b=iz7cX5nU; arc=pass (i=1 spf=pass spfdomain=proton.me dkim=pass dkdomain=proton.me dmarc=pass fromdomain=proton.me); spf=pass (google.com: domain of linux-kernel+bounces-192410-linux.lists.archive=gmail.com@vger.kernel.org designates 2604:1380:4601:e00::3 as permitted sender) smtp.mailfrom="linux-kernel+bounces-192410-linux.lists.archive=gmail.com@vger.kernel.org"; dmarc=pass (p=QUARANTINE sp=QUARANTINE dis=NONE) header.from=proton.me Return-Path: Received: from am.mirrors.kernel.org (am.mirrors.kernel.org. [2604:1380:4601:e00::3]) by mx.google.com with ESMTPS id 4fb4d7f45d1cf-578524a0900si5044160a12.476.2024.05.28.06.28.15 for (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Tue, 28 May 2024 06:28:15 -0700 (PDT) Received-SPF: pass (google.com: domain of linux-kernel+bounces-192410-linux.lists.archive=gmail.com@vger.kernel.org designates 2604:1380:4601:e00::3 as permitted sender) client-ip=2604:1380:4601:e00::3; Authentication-Results: mx.google.com; dkim=pass header.i=@proton.me header.s=protonmail header.b=iz7cX5nU; arc=pass (i=1 spf=pass spfdomain=proton.me dkim=pass dkdomain=proton.me dmarc=pass fromdomain=proton.me); spf=pass (google.com: domain of linux-kernel+bounces-192410-linux.lists.archive=gmail.com@vger.kernel.org designates 2604:1380:4601:e00::3 as permitted sender) smtp.mailfrom="linux-kernel+bounces-192410-linux.lists.archive=gmail.com@vger.kernel.org"; dmarc=pass (p=QUARANTINE sp=QUARANTINE dis=NONE) header.from=proton.me Received: from smtp.subspace.kernel.org (wormhole.subspace.kernel.org [52.25.139.140]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by am.mirrors.kernel.org (Postfix) with ESMTPS id 4F0CE1F26194 for ; Tue, 28 May 2024 13:28:09 +0000 (UTC) Received: from localhost.localdomain (localhost.localdomain [127.0.0.1]) by smtp.subspace.kernel.org (Postfix) with ESMTP id C9F1416F0EA; Tue, 28 May 2024 13:28:03 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=proton.me header.i=@proton.me header.b="iz7cX5nU" Received: from mail-4322.protonmail.ch (mail-4322.protonmail.ch [185.70.43.22]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by smtp.subspace.kernel.org (Postfix) with ESMTPS id 1C3B316E87B for ; Tue, 28 May 2024 13:28:00 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.client-ip=185.70.43.22 ARC-Seal:i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1716902882; cv=none; b=tbALBHRLxHitjQ9M1U5m012v7/lf7ti3xSGV3xIbvfWr37ErMyUuSnk3vVb8/y3XX0TQXb2W++0KZqmiqA5/ENMKFDo4d5HfzGxZbGo+amOU1g/mEdM/0gN+JPlAF3+qrdXuletS+YkiJG1kG0dynM3d/lyfoHPcS7PDqRsEy5g= ARC-Message-Signature:i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1716902882; c=relaxed/simple; bh=uqJvrqqgKH4Ec/381jSSZ52PTmJenP9/HfohYBBu8t8=; h=Date:To:From:Cc:Subject:Message-ID:In-Reply-To:References: MIME-Version:Content-Type; b=I+5z+9YVVyg/wbonYHgRKHsZ/RouQ8NGiXGtYX2wsnFU3fOGwKiXPHUDYjhwKt2o9ZXAEdS+ZuWcQPvPSv2C2+r6SwISAR0RzFMOI2BxUAw6sbU/tXpqvRL0pOHpfU7vQ6ljjK9smsy67rabDrsfMJbLuT/AOcQo83J4/w2bNlM= ARC-Authentication-Results:i=1; smtp.subspace.kernel.org; dmarc=pass (p=quarantine dis=none) header.from=proton.me; spf=pass smtp.mailfrom=proton.me; dkim=pass (2048-bit key) header.d=proton.me header.i=@proton.me header.b=iz7cX5nU; arc=none smtp.client-ip=185.70.43.22 Authentication-Results: smtp.subspace.kernel.org; dmarc=pass (p=quarantine dis=none) header.from=proton.me Authentication-Results: smtp.subspace.kernel.org; spf=pass smtp.mailfrom=proton.me DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=proton.me; s=protonmail; t=1716902877; x=1717162077; bh=qqtgzJlmFD04DRomp01Lp8PnnmfNEYuAnmxTd28A+mA=; h=Date:To:From:Cc:Subject:Message-ID:In-Reply-To:References: Feedback-ID:From:To:Cc:Date:Subject:Reply-To:Feedback-ID: Message-ID:BIMI-Selector; b=iz7cX5nUCsaHQ52ilcQPLn8UCQS6kbxIvJYCj1eOLRr1srtopY4o2ivbhPDQlUzHK 6BHbaaKvpcNWNCqh3e5tW+82RM5JcCp5KvNR4KDm4FubnmbcnFjd0SUN2RaZ7nOYEF QUhuU1pdOxv1xYcM3ISSI4XRFIDyUbndnv83j3AIh5PKZGoB72roa39rIZWMqppKFn gCBMJmFKi4xHXnD1VdGaQbnaJgQ45lqsAV+HDX9FkoZmyslo/h04c/Yv7QumbgATss JNic77RjO0rpHPEGuGRN0V/1iKLivB8I/lQS23qUMmRQ2+opsfoeWRT9Tx0VMhaNhm RKMwSzl2RNm9Q== Date: Tue, 28 May 2024 13:27:53 +0000 To: Andreas Hindborg , Jens Axboe , Christoph Hellwig , Keith Busch , Damien Le Moal , Bart Van Assche , Hannes Reinecke , Ming Lei , "linux-block@vger.kernel.org" From: Benno Lossin Cc: Andreas Hindborg , Greg KH , Matthew Wilcox , Miguel Ojeda , Alex Gaynor , Wedson Almeida Filho , Boqun Feng , Gary Guo , =?utf-8?Q?Bj=C3=B6rn_Roy_Baron?= , Alice Ryhl , Chaitanya Kulkarni , Luis Chamberlain , Yexuan Yang <1182282462@bupt.edu.cn>, =?utf-8?Q?Sergio_Gonz=C3=A1lez_Collado?= , Joel Granados , "Pankaj Raghav (Samsung)" , Daniel Gomez , Niklas Cassel , Philipp Stanner , Conor Dooley , Johannes Thumshirn , =?utf-8?Q?Matias_Bj=C3=B8rling?= , open list , "rust-for-linux@vger.kernel.org" , "lsf-pc@lists.linux-foundation.org" , "gost.dev@samsung.com" Subject: Re: [PATCH v2 2/3] rust: block: add rnull, Rust null_blk implementation Message-ID: In-Reply-To: <20240521140323.2960069-3-nmi@metaspace.dk> References: <20240521140323.2960069-1-nmi@metaspace.dk> <20240521140323.2960069-3-nmi@metaspace.dk> Feedback-ID: 71780778:user:proton X-Pm-Message-ID: dba9a313b25dad8f775da433a567bc08de8caa87 Precedence: bulk X-Mailing-List: linux-kernel@vger.kernel.org List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable On 21.05.24 16:03, Andreas Hindborg wrote: > From: Andreas Hindborg >=20 > This patch adds an initial version of the Rust null block driver. >=20 > Signed-off-by: Andreas Hindborg > --- > drivers/block/Kconfig | 9 +++++ > drivers/block/Makefile | 3 ++ > drivers/block/rnull.rs | 86 +++++++++++++++++++++++++++++++++++++++++ > rust/kernel/block/mq.rs | 4 +- > 4 files changed, 101 insertions(+), 1 deletion(-) > create mode 100644 drivers/block/rnull.rs >=20 > diff --git a/drivers/block/Kconfig b/drivers/block/Kconfig > index 5b9d4aaebb81..ed209f4f2798 100644 > --- a/drivers/block/Kconfig > +++ b/drivers/block/Kconfig > @@ -354,6 +354,15 @@ config VIRTIO_BLK > =09 This is the virtual block driver for virtio. It can be used with > QEMU based VMMs (like KVM or Xen). Say Y or M. >=20 > +config BLK_DEV_RUST_NULL > +=09tristate "Rust null block driver (Experimental)" > +=09depends on RUST > +=09help > +=09 This is the Rust implementation of the null block driver. For now i= t > +=09 is only a minimal stub. > + > +=09 If unsure, say N. > + > config BLK_DEV_RBD > =09tristate "Rados block device (RBD)" > =09depends on INET && BLOCK > diff --git a/drivers/block/Makefile b/drivers/block/Makefile > index 101612cba303..1105a2d4fdcb 100644 > --- a/drivers/block/Makefile > +++ b/drivers/block/Makefile > @@ -9,6 +9,9 @@ > # needed for trace events > ccflags-y=09=09=09=09+=3D -I$(src) >=20 > +obj-$(CONFIG_BLK_DEV_RUST_NULL) +=3D rnull_mod.o > +rnull_mod-y :=3D rnull.o > + > obj-$(CONFIG_MAC_FLOPPY)=09+=3D swim3.o > obj-$(CONFIG_BLK_DEV_SWIM)=09+=3D swim_mod.o > obj-$(CONFIG_BLK_DEV_FD)=09+=3D floppy.o > diff --git a/drivers/block/rnull.rs b/drivers/block/rnull.rs > new file mode 100644 > index 000000000000..1d6ab6f0f26f > --- /dev/null > +++ b/drivers/block/rnull.rs > @@ -0,0 +1,86 @@ > +// SPDX-License-Identifier: GPL-2.0 > + > +//! This is a Rust implementation of the C null block driver. > +//! > +//! Supported features: > +//! > +//! - blk-mq interface > +//! - direct completion > +//! - block size 4k > +//! > +//! The driver is not configurable. > + > +use kernel::{ > + alloc::flags, > + block::mq::{ > + self, > + gen_disk::{self, GenDisk}, > + Operations, TagSet, > + }, > + error::Result, > + new_mutex, pr_info, > + prelude::*, > + sync::{Arc, Mutex}, > + types::ARef, > +}; > + > +module! { > + type: NullBlkModule, > + name: "rnull_mod", > + author: "Andreas Hindborg", > + license: "GPL v2", > +} > + > +struct NullBlkModule { > + _disk: Pin>>>, > +} > + > +fn add_disk(tagset: Arc>) -> Result> { Any reason that this is its own function and not in the `NullBlkModule::init` function? > + let block_size: u16 =3D 4096; > + if block_size % 512 !=3D 0 || !(512..=3D4096).contains(&block_size) = { > + return Err(kernel::error::code::EINVAL); > + } > + > + let mut disk =3D gen_disk::try_new(tagset)?; > + disk.set_name(format_args!("rnullb{}", 0))?; > + disk.set_capacity_sectors(4096 << 11); > + disk.set_queue_logical_block_size(block_size.into()); > + disk.set_queue_physical_block_size(block_size.into()); > + disk.set_rotational(false); > + disk.add() > +} > + > +impl kernel::Module for NullBlkModule { > + fn init(_module: &'static ThisModule) -> Result { > + pr_info!("Rust null_blk loaded\n"); > + let tagset =3D Arc::pin_init(TagSet::try_new(1, 256, 1), flags::= GFP_KERNEL)?; > + let disk =3D Box::pin_init( > + new_mutex!(add_disk(tagset)?, "nullb:disk"), > + flags::GFP_KERNEL, > + )?; > + > + Ok(Self { _disk: disk }) > + } > +} > + > +struct NullBlkDevice; > + > +#[vtable] > +impl Operations for NullBlkDevice { > + #[inline(always)] > + fn queue_rq(rq: ARef>, _is_last: bool) -> Result { > + mq::Request::end_ok(rq) > + .map_err(|_e| kernel::error::code::EIO) > + .expect("Failed to complete request"); This error would only happen if `rq` is not the only ARef to that request, right? > + > + Ok(()) > + } > + > + fn commit_rqs() {} > + > + fn complete(rq: ARef>) { Am I correct in thinking that this function is never actually called, since all requests that are queued are immediately ended? > + mq::Request::end_ok(rq) > + .map_err(|_e| kernel::error::code::EIO) > + .expect("Failed to complete request") > + } > +} > diff --git a/rust/kernel/block/mq.rs b/rust/kernel/block/mq.rs > index efbd2588791b..54e032bbdffd 100644 > --- a/rust/kernel/block/mq.rs > +++ b/rust/kernel/block/mq.rs > @@ -51,6 +51,7 @@ > //! > //! ```rust > //! use kernel::{ > +//! alloc::flags, > //! block::mq::*, > //! new_mutex, > //! prelude::*, > @@ -77,7 +78,8 @@ > //! } > //! } > //! > -//! let tagset: Arc> =3D Arc::pin_init(TagSet::try_n= ew(1, 256, 1))?; > +//! let tagset: Arc> =3D > +//! Arc::pin_init(TagSet::try_new(1, 256, 1), flags::GFP_KERNEL)?; This change should probably be in the patch before (seems like an artifact from rebasing). --- Cheers, Benno > //! let mut disk =3D gen_disk::try_new(tagset)?; > //! disk.set_name(format_args!("myblk"))?; > //! disk.set_capacity_sectors(4096); > -- > 2.44.0 >=20 >=20