1 // SPDX-License-Identifier: GPL-2.0-or-later
14 	struct inode *inode = wreq->inode;  in netfs_cleanup_dio_write()
15 	unsigned long long end = wreq->start + wreq->transferred;  in netfs_cleanup_dio_write()
17 	if (!wreq->error &&  in netfs_cleanup_dio_write()
19 		if (wreq->netfs_ops->update_i_size)  in netfs_cleanup_dio_write()
20 			wreq->netfs_ops->update_i_size(inode, end);  in netfs_cleanup_dio_write()
34 	unsigned long long start = iocb->ki_pos;  in netfs_unbuffered_write_iter_locked()
48 	_debug("uw %llx-%llx", start, end);  in netfs_unbuffered_write_iter_locked()
50 	wreq = netfs_create_write_req(iocb->ki_filp->f_mapping, iocb->ki_filp, start,  in netfs_unbuffered_write_iter_locked()
51 				      iocb->ki_flags & IOCB_DIRECT ?  in netfs_unbuffered_write_iter_locked()
56 	wreq->io_streams[0].avail = true;  in netfs_unbuffered_write_iter_locked()
57 	trace_netfs_write(wreq, (iocb->ki_flags & IOCB_DIRECT ?  in netfs_unbuffered_write_iter_locked()
71 			n = netfs_extract_user_iter(iter, len, &wreq->buffer.iter, 0);  in netfs_unbuffered_write_iter_locked()
76 			wreq->direct_bv = (struct bio_vec *)wreq->buffer.iter.bvec;  in netfs_unbuffered_write_iter_locked()
77 			wreq->direct_bv_count = n;  in netfs_unbuffered_write_iter_locked()
78 			wreq->direct_bv_unpin = iov_iter_extract_will_pin(iter);  in netfs_unbuffered_write_iter_locked()
80 			/* If this is a kernel-generated async DIO request,  in netfs_unbuffered_write_iter_locked()
85 			wreq->buffer.iter = *iter;  in netfs_unbuffered_write_iter_locked()
89 	__set_bit(NETFS_RREQ_USE_IO_ITER, &wreq->flags);  in netfs_unbuffered_write_iter_locked()
95 	__set_bit(NETFS_RREQ_UPLOAD_TO_SERVER, &wreq->flags);  in netfs_unbuffered_write_iter_locked()
97 		wreq->iocb = iocb;  in netfs_unbuffered_write_iter_locked()
98 	wreq->len = iov_iter_count(&wreq->buffer.iter);  in netfs_unbuffered_write_iter_locked()
99 	wreq->cleanup = netfs_cleanup_dio_write;  in netfs_unbuffered_write_iter_locked()
100 	ret = netfs_unbuffered_write(wreq, is_sync_kiocb(iocb), wreq->len);  in netfs_unbuffered_write_iter_locked()
108 		wait_on_bit(&wreq->flags, NETFS_RREQ_IN_PROGRESS,  in netfs_unbuffered_write_iter_locked()
110 		ret = wreq->error;  in netfs_unbuffered_write_iter_locked()
112 			ret = wreq->transferred;  in netfs_unbuffered_write_iter_locked()
113 			iocb->ki_pos += ret;  in netfs_unbuffered_write_iter_locked()
116 		ret = -EIOCBQUEUED;  in netfs_unbuffered_write_iter_locked()
126  * netfs_unbuffered_write_iter - Unbuffered write to a file
134  * * Negative error code if no data has been written at all of
140 	struct file *file = iocb->ki_filp;  in netfs_unbuffered_write_iter()
141 	struct address_space *mapping = file->f_mapping;  in netfs_unbuffered_write_iter()
142 	struct inode *inode = mapping->host;  in netfs_unbuffered_write_iter()
145 	loff_t pos = iocb->ki_pos;  in netfs_unbuffered_write_iter()
146 	unsigned long long end = pos + iov_iter_count(from) - 1;  in netfs_unbuffered_write_iter()
168 	if (iocb->ki_flags & IOCB_NOWAIT) {  in netfs_unbuffered_write_iter()
170 		ret = -EAGAIN;  in netfs_unbuffered_write_iter()
181 	 * After a write we want buffered reads to be sure to go to disk to get  in netfs_unbuffered_write_iter()
184 	 * without clobbering -EIOCBQUEUED from ->direct_IO().  in netfs_unbuffered_write_iter()
189 	end = iocb->ki_pos + iov_iter_count(from);  in netfs_unbuffered_write_iter()
190 	if (end > ictx->zero_point)  in netfs_unbuffered_write_iter()
191 		ictx->zero_point = end;  in netfs_unbuffered_write_iter()