From mboxrd@z Thu Jan 1 00:00:00 1970 Received: from smtp.kernel.org (aws-us-west-2-korg-mail-alma10-1.taild15c8.ts.net [100.103.45.18]) (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 6D2C440D577 for ; Wed, 10 Jun 2026 00:40:42 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.client-ip=100.103.45.18 ARC-Seal:i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1781052043; cv=none; b=g623zTxiJW1dhOVPSbXDGRtZEVSrjs0JGflONPgH4iIOwBxARZNjANyPiip3sppfsjLIX0abrvvvtvkIUruoDcVWMWkp7OemPTyJpxh4m5orWrQvwCN8rgP8IVDvVq2mImY6fVxQ8jgUIfRDs8H4eXZbbxPJ5n/xk4e/QuNBnGk= ARC-Message-Signature:i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1781052043; c=relaxed/simple; bh=UW1+cwgB/7llFB9lse6jWAcNMEWJTS8C0awQ0xwdlpA=; h=Date:From:To:Cc:Subject:Message-ID:References:MIME-Version: Content-Type:Content-Disposition:In-Reply-To; b=S6Qssg3cAtJkgWfpNdn3w/nIZOeJa94F28YdkD0NkJsoxWy0MG7tIrfbjWxhBRsDnCWZfNYbN5DKYD0EU+u/TXgoQSDbWd1+7XKTysUNj7lXju1SGj45igtXjYo5Twyy/4PUdFoCgv+2TqrXGad60verUfI11lM3ng1UAnJLr6A= ARC-Authentication-Results:i=1; smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b=FA5yMXpI; arc=none smtp.client-ip=100.103.45.18 Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b="FA5yMXpI" Received: by smtp.kernel.org (Postfix) with ESMTPSA id CD2CE1F00893; Wed, 10 Jun 2026 00:40:41 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=kernel.org; s=k20260515; t=1781052042; bh=5XEnPYT/t4pzh4JXROa8wrBWYGt4Z0Jma3WAo1+RNXY=; h=Date:From:To:Cc:Subject:References:In-Reply-To; b=FA5yMXpIpWWB/jErTJXheiiVw5zwDQETSyWQcN9qPEMXxGZFcKtLG8fN5UnGdIEN+ lMjyDqgc3b+9REz8XHlSVwJU1qIImo6SqdaxeJL9lcrnbdVmYOptoLWAXOLuWYj1zr nQdNHJywNSwmHCosTjcwUZwWhKyk/h5Yd8pEXTvI8eJn5EXdbKh25RNtBLEO27vMIB jDNEBoBdxkjPUz3dJh90CBzDVWYeGJXm+cKgJS8ODb7+fzoRSejWNQKPe1zrfCcURh WST8nv0XRT6twR4ttQgqolosHsvKgSxQ5SEzQKTyBfQLcUFsO2jx48K6+BH52e0ZvU nbneh6FSt7Lbg== Date: Wed, 10 Jun 2026 00:40:40 +0000 From: Jaegeuk Kim To: Wenjie Qi Cc: chao@kernel.org, linux-f2fs-devel@lists.sourceforge.net, linux-kernel@vger.kernel.org, qiwenjie@xiaomi.com Subject: Re: [PATCH] f2fs: honor per-I/O write streams for direct writes Message-ID: References: <20260522061206.2405336-1-qiwenjie@xiaomi.com> 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=us-ascii Content-Disposition: inline In-Reply-To: <20260522061206.2405336-1-qiwenjie@xiaomi.com> On 05/22, Wenjie Qi wrote: > io_uring can pass a per-I/O write stream through kiocb->ki_write_stream, > and block direct I/O propagates that value to bio->bi_write_stream. > > F2FS added FDP stream mapping for DATA writes, but its direct write > submit hook always rewrites bio->bi_write_stream from the inode write > hint and F2FS temperature. As a result, a direct write with an explicit > io_uring write_stream is submitted to the F2FS-selected stream instead > of the user-requested stream. > > Validate an explicit write stream before starting F2FS direct I/O, pass > the kiocb through the iomap private pointer, and preserve the per-I/O > stream in the direct write bio. When no per-I/O stream is supplied, keep > using the existing F2FS temperature-to-stream mapping. > > Fixes: 42f7a7a50a33 ("f2fs: map data writes to FDP streams") > Signed-off-by: Wenjie Qi > --- > fs/f2fs/file.c | 30 +++++++++++++++++++++++++++--- > 1 file changed, 27 insertions(+), 3 deletions(-) > > diff --git a/fs/f2fs/file.c b/fs/f2fs/file.c > index 71385ca4163d..20d6e7ab7416 100644 > --- a/fs/f2fs/file.c > +++ b/fs/f2fs/file.c > @@ -5074,17 +5074,36 @@ static int f2fs_dio_write_end_io(struct kiocb *iocb, ssize_t size, int error, > return 0; > } > > +static bool f2fs_valid_write_stream(struct f2fs_sb_info *sbi, u8 write_stream) > +{ > + int i; > + > + if (!write_stream) > + return true; > + if (!f2fs_is_multi_device(sbi)) > + return write_stream <= bdev_max_write_streams(sbi->sb->s_bdev); > + > + for (i = 0; i < sbi->s_ndevs; i++) > + if (write_stream > bdev_max_write_streams(FDEV(i).bdev)) > + return false; > + return true; > +} > + > static void f2fs_dio_write_submit_io(const struct iomap_iter *iter, > struct bio *bio, loff_t file_offset) > { > struct inode *inode = iter->inode; > struct f2fs_sb_info *sbi = F2FS_I_SB(inode); > + struct kiocb *iocb = iter->private; > enum log_type type = f2fs_rw_hint_to_seg_type(sbi, inode->i_write_hint); > enum temp_type temp = f2fs_get_segment_temp(sbi, type); > > bio->bi_write_hint = f2fs_io_type_to_rw_hint(sbi, DATA, temp); > - bio->bi_write_stream = > - f2fs_io_type_to_write_stream(bio->bi_bdev, DATA, temp); > + if (iocb->ki_write_stream) > + bio->bi_write_stream = iocb->ki_write_stream; > + else > + bio->bi_write_stream = > + f2fs_io_type_to_write_stream(bio->bi_bdev, DATA, temp); Let me apply as below. bio->bi_write_stream = + iocb->ki_write_stream ? iocb->ki_write_stream : f2fs_io_type_to_write_stream(bio->bi_bdev, DATA, temp); > blk_crypto_submit_bio(bio); > } > > @@ -5122,6 +5141,11 @@ static ssize_t f2fs_dio_write_iter(struct kiocb *iocb, struct iov_iter *from, > > trace_f2fs_direct_IO_enter(inode, iocb, count, WRITE); > > + if (!f2fs_valid_write_stream(sbi, iocb->ki_write_stream)) { > + ret = -EINVAL; > + goto out; > + } > + > if (iocb->ki_flags & IOCB_NOWAIT) { > /* f2fs_convert_inline_inode() and block allocation can block */ > if (f2fs_has_inline_data(inode) || > @@ -5159,7 +5183,7 @@ static ssize_t f2fs_dio_write_iter(struct kiocb *iocb, struct iov_iter *from, > if (pos + count > inode->i_size) > dio_flags |= IOMAP_DIO_FORCE_WAIT; > dio = __iomap_dio_rw(iocb, from, &f2fs_iomap_ops, > - &f2fs_iomap_dio_write_ops, dio_flags, NULL, 0); > + &f2fs_iomap_dio_write_ops, dio_flags, iocb, 0); > if (IS_ERR_OR_NULL(dio)) { > ret = PTR_ERR_OR_ZERO(dio); > if (ret == -ENOTBLK) > > base-commit: 520760b9f9156bf9698de38dc44c614fad68a1f9 > -- > 2.43.0 >