Received-SPF: pass (google.com: domain of linux-kernel+bounces-162794-linux.lists.archive=gmail.com@vger.kernel.org designates 2604:1380:45d1:ec00::1 as permitted sender) client-ip=2604:1380:45d1:ec00::1;
From: John Garry <john.g.garry@oracle.com>
To: david@fromorbit.com, djwong@kernel.org, hch@lst.de,
        viro@zeniv.linux.org.uk, brauner@kernel.org, jack@suse.cz,
        chandan.babu@oracle.com, willy@infradead.org
Cc: axboe@kernel.dk, martin.petersen@oracle.com, linux-kernel@vger.kernel.org,
        linux-fsdevel@vger.kernel.org, tytso@mit.edu, jbongio@google.com,
        ojaswin@linux.ibm.com, ritesh.list@gmail.com, mcgrof@kernel.org,
        p.raghav@samsung.com, linux-xfs@vger.kernel.org,
        catherine.hoang@oracle.com, John Garry <john.g.garry@oracle.com>
Subject: [PATCH v3 17/21] iomap: Atomic write support
Date: Mon, 29 Apr 2024 17:47:42 +0000
Message-Id: <20240429174746.2132161-18-john.g.garry@oracle.com>
In-Reply-To: <20240429174746.2132161-1-john.g.garry@oracle.com>
References: <20240429174746.2132161-1-john.g.garry@oracle.com>
Content-Transfer-Encoding: 8bit
Content-Type: text/plain
Precedence: bulk
MIME-Version: 1.0
X-MS-Exchange-AntiSpam-MessageData-ChunkCount: 1
X-MS-Exchange-AntiSpam-MessageData-0: 
	=?us-ascii?Q?UBCqII4TqbJL+4el0XlfMrxMqPjOQ6Z2zw6eW/qzvZr9k00zkxCQJoeeYzc1?=
 =?us-ascii?Q?IXk+rtF76Cm1nDBjKwQoRqS2Ehc/Cjove1PjrQsbhBbhjv8NHVDQdj6vWu7C?=
 =?us-ascii?Q?ArgyJXa7YxPlP2fiZ9btMaEBXel37b+z+n4snZqM4Qs47CJmdiZziIjd155R?=
 =?us-ascii?Q?XvTq9F4s4ypXbws8KdJbeN9QMsrKh0vpRYtzgKKqOLFdIjBCUI/xlhyYPgXh?=
 =?us-ascii?Q?jHK2++xIRfBTUvhMCFOI6oKKWaXphK612/lFlSQ15LMer7DznYKpgGtyihCw?=
 =?us-ascii?Q?nWV1HQhqMak98owgF00GrQvq48p98q0F7M4gaBUmdE0yhDlXZ9x55nb4hbYk?=
 =?us-ascii?Q?YQ5eNM3HMmBDXEfQGk7JOJwVnysJMfl8EYRb+F1FRdj23KuQ1e9ub9zGXyT8?=
 =?us-ascii?Q?E5nLbw721hDaaIq5Eujx2gSm/0PxxJidLMF2HuJFZYWQsferumzKc2+tlybg?=
 =?us-ascii?Q?bJQsSDCPTmcHy+4nVAlf8HPYZXR8EuRBJfjQ3xxcISRgNUG8YUmGK/OwgkyF?=
 =?us-ascii?Q?nJBN4ODiI1hON2QCrCGezLkbUOuAIylIi1GecFyAw+cZAK2rDbnBgJRO9buz?=
 =?us-ascii?Q?+xutZjaJ58Lj0lnAUoNJMrGju/DorAlQs+LfCLXLi2Fj44frA9/cCDpeeOEs?=
 =?us-ascii?Q?BZfO0OEHQ75TmtPpYIjVX6a1mlil7gbbp/nGJi0bQtZdj53b5dNPUu08F2nP?=
 =?us-ascii?Q?QxprlJnzesW2ITO6nylND8nGrCtdmBccbHvao/kCwQKE8C7RrebDqwl3N+sI?=
 =?us-ascii?Q?r8wnyUcris6XSPZDuzpZDZQcun/Pvj3H1JnMc1KpUgvfcCU1rgkbqjc0jkUz?=
 =?us-ascii?Q?Oa83KtSWgVnG4PM1W6GrUtxxSRSzCrixcG5CNIS+5Qn5xXl4yjvZq7SX7SbG?=
 =?us-ascii?Q?O0oYe7Im/iA9+4FjA3MF1ZiYKTmJzDyBUeu7w7wyOw+Aa8inPYUVwPf16Z74?=
 =?us-ascii?Q?kflRuILkqwJoEl9hXESRrvyZJd7zw0OuXKodTsqnK1VkIphRpmGEMGRyLF0G?=
 =?us-ascii?Q?/I3ErnEca3vACq5wYgwfO9M6y9TOuR/Tf+aj2y6h3BsShLcYyJiLHCRyy+FH?=
 =?us-ascii?Q?1uGdCCRmRl46orMu9Q06OMh9Uax8rxyEm9jLdAZg36xH5uOqObTtsmnXoYOg?=
 =?us-ascii?Q?SnGXDKGxaRymY7uCe7iXqeQzmCeEmaI1HeHaKMgTQ/yDfb8ad1G4580bW4Zh?=
 =?us-ascii?Q?kHTGiYAVtDI388neWG1jYKjSVjHQMCOaJLFFDugffuz8thSiA/zX6Tdlm7TV?=
 =?us-ascii?Q?rwsEWhYNLgcZAsNzRFxHvjLYqRd/O/+FtX3Pz2gsACwRFLmb9G/qx7TSJSdH?=
 =?us-ascii?Q?ElxEF+ChVFn+2h01L9SMo9W6rUK3Y1GIc5E3SufiQa3A1LrzSbb/WMI8P8Hg?=
 =?us-ascii?Q?ArR5nMdYdbp0oyoOY6YWA28SOCx1NRbiM4crd0JeE2T2EMckImWOXiqrpFKM?=
 =?us-ascii?Q?TgI0j9jx7SMP1PUmBya32JnxzpkoLAezblW62+DVoYRj8/AamhrnVA+RWRZb?=
 =?us-ascii?Q?T5vsRoQT0Eyyizs/5LJTmUFJn949OvywMQwvyRz5aVTfqud8e6GBoaFqR01o?=
 =?us-ascii?Q?W2mY8sNhJnixkzzH0NqOicL8AAUv+3qPELimZJNBJfCZ/c8f1IqiDM6vPZMt?=
 =?us-ascii?Q?qA=3D=3D?=
X-MS-Exchange-AntiSpam-ExternalHop-MessageData-ChunkCount: 1
X-MS-Exchange-AntiSpam-ExternalHop-MessageData-0: 
	y24vc8+nCMvJSOnAXrsl6InKcI/E4Lh2AEeVf6UyuP8JBrk/hukrJa7dwm46YWlVY1XSU+j+PQTQhQCfYxTnTly0hPLYJMS91CR3Z/RHCKCdVqy18/WJHV0Yusf/awICen01ghFpOO8d+EkII98KG/ep/e0GaliMw29NJKbkNTIYOrpNFl+1/jIc/qrq2rCWW8AY7+XB5kjvr2NBKpsdQb9pB+15XDdPbKKSf8cN77SebANRHzNpICXRnZzwdjuHFULZxEwiKj6miSuAimg6GzRFmJPOvaBwnugqDKjp5ccGO7zgGj+vcZNEimAcia7670M1KSl3EN1lq5IJ1cVrFFr69Tz3q4Q9hHsX+GLwVcr5hkN9FOpPcYabvhmp4qAQiaQ+dJzXHttE4dtbcLdTexQk33Z5F8opuNTaxwPpmsO0eXeiDLrwIMBlLCRLR9i09HMBdOU3KxWXaucFxMPexhggKNG83CIR9FSC/LduGnqwGwXzXuhiv+v+kzc7GCUA5DkfuRIo7OzgdFRJqRF66KAlhERXuuEnyt7dRQnksPj5VS3CvHD+7q06XCRjM3KdfxC85Z4rS1UZzPObTQFGFV2g24lCY4rYf9TKZAA93R0=
X-OriginatorOrg: oracle.com
X-MS-Exchange-CrossTenant-Network-Message-Id: b06148c2-5b0a-4b29-94be-08dc68749db3
X-MS-Exchange-CrossTenant-AuthSource: DM6PR10MB4313.namprd10.prod.outlook.com
X-MS-Exchange-CrossTenant-AuthAs: Internal
X-MS-Exchange-CrossTenant-OriginalArrivalTime: 29 Apr 2024 17:48:45.3007
 (UTC)
X-MS-Exchange-CrossTenant-FromEntityHeader: Hosted
X-MS-Exchange-CrossTenant-Id: 4e2c6054-71cb-48f1-bd6c-3a9705aca71b
X-MS-Exchange-CrossTenant-MailboxType: HOSTED
X-MS-Exchange-CrossTenant-UserPrincipalName: e7ujqYL59XztNftBQKT466lItzV0vYZzZVQy8cXRTaf17NT1tw5+nXWzQ7EFrgOWxLvZniK0EbH4Pb6eDixHQA==
X-MS-Exchange-Transport-CrossTenantHeadersStamped: CH3PR10MB7763
X-Proofpoint-Virus-Version: vendor=baseguard
 engine=ICAP:2.0.293,Aquarius:18.0.1011,Hydra:6.0.650,FMLib:17.11.176.26
 definitions=2024-04-29_15,2024-04-29_01,2023-05-22_02
X-Proofpoint-Spam-Details: rule=notspam policy=default score=0 mlxlogscore=999 malwarescore=0
 phishscore=0 spamscore=0 bulkscore=0 suspectscore=0 adultscore=0
 mlxscore=0 classifier=spam adjust=0 reason=mlx scancount=1
 engine=8.12.0-2404010000 definitions=main-2404290115
X-Proofpoint-GUID: C1qosgTCqetTfyof4vZ3cbmq4rrdBfMO
X-Proofpoint-ORIG-GUID: C1qosgTCqetTfyof4vZ3cbmq4rrdBfMO

Support atomic writes by producing a single BIO with REQ_ATOMIC flag set.

We rely on the FS to guarantee extent alignment, such that an atomic write
should never straddle two or more extents. The FS should also check for
validity of an atomic write length/alignment.

Signed-off-by: John Garry <john.g.garry@oracle.com>
---
 fs/iomap/direct-io.c | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/fs/iomap/direct-io.c b/fs/iomap/direct-io.c
index a3ed7cfa95bc..d7bdeb675068 100644
--- a/fs/iomap/direct-io.c
+++ b/fs/iomap/direct-io.c
@@ -275,6 +275,7 @@ static inline blk_opf_t iomap_dio_bio_opflags(struct iomap_dio *dio,
 static loff_t iomap_dio_bio_iter(const struct iomap_iter *iter,
 		struct iomap_dio *dio)
 {
+	bool is_atomic = dio->iocb->ki_flags & IOCB_ATOMIC;
 	const struct iomap *iomap = &iter->iomap;
 	struct inode *inode = iter->inode;
 	unsigned int zeroing_size, pad;
@@ -387,6 +388,9 @@ static loff_t iomap_dio_bio_iter(const struct iomap_iter *iter,
 		bio->bi_iter.bi_sector = iomap_sector(iomap, pos);
 		bio->bi_write_hint = inode->i_write_hint;
 		bio->bi_ioprio = dio->iocb->ki_ioprio;
+		if (is_atomic)
+			bio->bi_opf |= REQ_ATOMIC;
+
 		bio->bi_private = dio;
 		bio->bi_end_io = iomap_dio_bio_end_io;
 
@@ -403,6 +407,12 @@ static loff_t iomap_dio_bio_iter(const struct iomap_iter *iter,
 		}
 
 		n = bio->bi_iter.bi_size;
+		if (is_atomic && n != orig_count) {
+			/* This bio should have covered the complete length */
+			ret = -EINVAL;
+			bio_put(bio);
+			goto out;
+		}
 		if (dio->flags & IOMAP_DIO_WRITE) {
 			task_io_account_write(n);
 		} else {
-- 
2.31.1