read_write.c 49.2 KB
Newer Older
1
// SPDX-License-Identifier: GPL-2.0
L
Linus Torvalds 已提交
2 3 4 5 6 7
/*
 *  linux/fs/read_write.c
 *
 *  Copyright (C) 1991, 1992  Linus Torvalds
 */

8
#include <linux/slab.h>
L
Linus Torvalds 已提交
9
#include <linux/stat.h>
10
#include <linux/sched/xacct.h>
L
Linus Torvalds 已提交
11 12 13
#include <linux/fcntl.h>
#include <linux/file.h>
#include <linux/uio.h>
R
Robert Love 已提交
14
#include <linux/fsnotify.h>
L
Linus Torvalds 已提交
15
#include <linux/security.h>
16
#include <linux/export.h>
L
Linus Torvalds 已提交
17
#include <linux/syscalls.h>
18
#include <linux/pagemap.h>
19
#include <linux/splice.h>
A
Al Viro 已提交
20
#include <linux/compat.h>
21
#include <linux/mount.h>
22
#include <linux/fs.h>
23
#include "internal.h"
L
Linus Torvalds 已提交
24

25
#include <linux/uaccess.h>
L
Linus Torvalds 已提交
26 27
#include <asm/unistd.h>

28
const struct file_operations generic_ro_fops = {
L
Linus Torvalds 已提交
29
	.llseek		= generic_file_llseek,
30
	.read_iter	= generic_file_read_iter,
L
Linus Torvalds 已提交
31
	.mmap		= generic_file_readonly_mmap,
32
	.splice_read	= generic_file_splice_read,
L
Linus Torvalds 已提交
33 34 35 36
};

EXPORT_SYMBOL(generic_ro_fops);

C
Christoph Hellwig 已提交
37
static inline bool unsigned_offsets(struct file *file)
38
{
39
	return file->f_mode & FMODE_UNSIGNED_OFFSET;
40 41
}

J
Jie Liu 已提交
42 43 44 45 46 47 48 49 50 51 52 53 54
/**
 * vfs_setpos - update the file offset for lseek
 * @file:	file structure in question
 * @offset:	file offset to seek to
 * @maxsize:	maximum file size
 *
 * This is a low-level filesystem helper for updating the file offset to
 * the value specified by @offset if the given offset is valid and it is
 * not equal to the current file offset.
 *
 * Return the specified offset on success and -EINVAL on invalid offset.
 */
loff_t vfs_setpos(struct file *file, loff_t offset, loff_t maxsize)
55 56 57 58 59 60 61 62 63 64 65 66
{
	if (offset < 0 && !unsigned_offsets(file))
		return -EINVAL;
	if (offset > maxsize)
		return -EINVAL;

	if (offset != file->f_pos) {
		file->f_pos = offset;
		file->f_version = 0;
	}
	return offset;
}
J
Jie Liu 已提交
67
EXPORT_SYMBOL(vfs_setpos);
68

69
/**
A
Andi Kleen 已提交
70
 * generic_file_llseek_size - generic llseek implementation for regular files
71 72
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
73
 * @whence:	type of seek
74 75
 * @size:	max size of this file in file system
 * @eof:	offset used for SEEK_END position
76
 *
A
Andi Kleen 已提交
77
 * This is a variant of generic_file_llseek that allows passing in a custom
78
 * maximum file size and a custom EOF position, for e.g. hashed directories
79 80
 *
 * Synchronization:
A
Andi Kleen 已提交
81
 * SEEK_SET and SEEK_END are unsynchronized (but atomic on 64bit platforms)
82 83
 * SEEK_CUR is synchronized against other SEEK_CURs, but not read/writes.
 * read/writes behave like SEEK_SET against seeks.
84
 */
A
Andi Kleen 已提交
85
loff_t
86
generic_file_llseek_size(struct file *file, loff_t offset, int whence,
87
		loff_t maxsize, loff_t eof)
L
Linus Torvalds 已提交
88
{
89
	switch (whence) {
90
	case SEEK_END:
91
		offset += eof;
92 93
		break;
	case SEEK_CUR:
94 95 96 97 98 99 100 101
		/*
		 * Here we special-case the lseek(fd, 0, SEEK_CUR)
		 * position-querying operation.  Avoid rewriting the "same"
		 * f_pos value back to the file because a concurrent read(),
		 * write() or lseek() might have altered it
		 */
		if (offset == 0)
			return file->f_pos;
102 103 104 105 106 107
		/*
		 * f_lock protects against read/modify/write race with other
		 * SEEK_CURs. Note that parallel writes and reads behave
		 * like SEEK_SET.
		 */
		spin_lock(&file->f_lock);
J
Jie Liu 已提交
108
		offset = vfs_setpos(file, file->f_pos + offset, maxsize);
109 110
		spin_unlock(&file->f_lock);
		return offset;
111 112 113 114 115
	case SEEK_DATA:
		/*
		 * In the generic case the entire file is data, so as long as
		 * offset isn't at the end of the file then the offset is data.
		 */
116
		if ((unsigned long long)offset >= eof)
117 118 119 120 121 122 123
			return -ENXIO;
		break;
	case SEEK_HOLE:
		/*
		 * There is a virtual hole at the end of the file, so as long as
		 * offset isn't i_size or larger, return i_size.
		 */
124
		if ((unsigned long long)offset >= eof)
125
			return -ENXIO;
126
		offset = eof;
127
		break;
L
Linus Torvalds 已提交
128
	}
129

J
Jie Liu 已提交
130
	return vfs_setpos(file, offset, maxsize);
A
Andi Kleen 已提交
131 132 133 134 135 136 137
}
EXPORT_SYMBOL(generic_file_llseek_size);

/**
 * generic_file_llseek - generic llseek implementation for regular files
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
138
 * @whence:	type of seek
A
Andi Kleen 已提交
139 140 141
 *
 * This is a generic implemenation of ->llseek useable for all normal local
 * filesystems.  It just updates the file offset to the value specified by
142
 * @offset and @whence.
A
Andi Kleen 已提交
143
 */
144
loff_t generic_file_llseek(struct file *file, loff_t offset, int whence)
A
Andi Kleen 已提交
145 146 147
{
	struct inode *inode = file->f_mapping->host;

148
	return generic_file_llseek_size(file, offset, whence,
149 150
					inode->i_sb->s_maxbytes,
					i_size_read(inode));
L
Linus Torvalds 已提交
151
}
A
Andi Kleen 已提交
152
EXPORT_SYMBOL(generic_file_llseek);
L
Linus Torvalds 已提交
153

A
Al Viro 已提交
154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173
/**
 * fixed_size_llseek - llseek implementation for fixed-sized devices
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
 * @whence:	type of seek
 * @size:	size of the file
 *
 */
loff_t fixed_size_llseek(struct file *file, loff_t offset, int whence, loff_t size)
{
	switch (whence) {
	case SEEK_SET: case SEEK_CUR: case SEEK_END:
		return generic_file_llseek_size(file, offset, whence,
						size, size);
	default:
		return -EINVAL;
	}
}
EXPORT_SYMBOL(fixed_size_llseek);

174 175 176 177 178 179 180 181 182 183 184 185
/**
 * no_seek_end_llseek - llseek implementation for fixed-sized devices
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
 * @whence:	type of seek
 *
 */
loff_t no_seek_end_llseek(struct file *file, loff_t offset, int whence)
{
	switch (whence) {
	case SEEK_SET: case SEEK_CUR:
		return generic_file_llseek_size(file, offset, whence,
186
						OFFSET_MAX, 0);
187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212
	default:
		return -EINVAL;
	}
}
EXPORT_SYMBOL(no_seek_end_llseek);

/**
 * no_seek_end_llseek_size - llseek implementation for fixed-sized devices
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
 * @whence:	type of seek
 * @size:	maximal offset allowed
 *
 */
loff_t no_seek_end_llseek_size(struct file *file, loff_t offset, int whence, loff_t size)
{
	switch (whence) {
	case SEEK_SET: case SEEK_CUR:
		return generic_file_llseek_size(file, offset, whence,
						size, 0);
	default:
		return -EINVAL;
	}
}
EXPORT_SYMBOL(no_seek_end_llseek_size);

J
jan Blunck 已提交
213 214 215 216
/**
 * noop_llseek - No Operation Performed llseek implementation
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
217
 * @whence:	type of seek
J
jan Blunck 已提交
218 219 220 221 222 223
 *
 * This is an implementation of ->llseek useable for the rare special case when
 * userspace expects the seek to succeed but the (device) file is actually not
 * able to perform the seek. In this case you use noop_llseek() instead of
 * falling back to the default implementation of ->llseek.
 */
224
loff_t noop_llseek(struct file *file, loff_t offset, int whence)
J
jan Blunck 已提交
225 226 227 228 229
{
	return file->f_pos;
}
EXPORT_SYMBOL(noop_llseek);

230
loff_t no_llseek(struct file *file, loff_t offset, int whence)
L
Linus Torvalds 已提交
231 232 233 234 235
{
	return -ESPIPE;
}
EXPORT_SYMBOL(no_llseek);

236
loff_t default_llseek(struct file *file, loff_t offset, int whence)
L
Linus Torvalds 已提交
237
{
A
Al Viro 已提交
238
	struct inode *inode = file_inode(file);
239
	loff_t retval;
L
Linus Torvalds 已提交
240

A
Al Viro 已提交
241
	inode_lock(inode);
242
	switch (whence) {
243
		case SEEK_END:
244
			offset += i_size_read(inode);
L
Linus Torvalds 已提交
245
			break;
246
		case SEEK_CUR:
247 248 249 250
			if (offset == 0) {
				retval = file->f_pos;
				goto out;
			}
L
Linus Torvalds 已提交
251
			offset += file->f_pos;
252 253 254 255 256 257 258
			break;
		case SEEK_DATA:
			/*
			 * In the generic case the entire file is data, so as
			 * long as offset isn't at the end of the file then the
			 * offset is data.
			 */
259 260 261 262
			if (offset >= inode->i_size) {
				retval = -ENXIO;
				goto out;
			}
263 264 265 266 267 268 269
			break;
		case SEEK_HOLE:
			/*
			 * There is a virtual hole at the end of the file, so
			 * as long as offset isn't i_size or larger, return
			 * i_size.
			 */
270 271 272 273
			if (offset >= inode->i_size) {
				retval = -ENXIO;
				goto out;
			}
274 275
			offset = inode->i_size;
			break;
L
Linus Torvalds 已提交
276 277
	}
	retval = -EINVAL;
278
	if (offset >= 0 || unsigned_offsets(file)) {
L
Linus Torvalds 已提交
279 280 281 282 283 284
		if (offset != file->f_pos) {
			file->f_pos = offset;
			file->f_version = 0;
		}
		retval = offset;
	}
285
out:
A
Al Viro 已提交
286
	inode_unlock(inode);
L
Linus Torvalds 已提交
287 288 289 290
	return retval;
}
EXPORT_SYMBOL(default_llseek);

291
loff_t vfs_llseek(struct file *file, loff_t offset, int whence)
L
Linus Torvalds 已提交
292 293 294 295 296
{
	loff_t (*fn)(struct file *, loff_t, int);

	fn = no_llseek;
	if (file->f_mode & FMODE_LSEEK) {
A
Al Viro 已提交
297
		if (file->f_op->llseek)
L
Linus Torvalds 已提交
298 299
			fn = file->f_op->llseek;
	}
300
	return fn(file, offset, whence);
L
Linus Torvalds 已提交
301 302 303
}
EXPORT_SYMBOL(vfs_llseek);

304
off_t ksys_lseek(unsigned int fd, off_t offset, unsigned int whence)
L
Linus Torvalds 已提交
305 306
{
	off_t retval;
307
	struct fd f = fdget_pos(fd);
308 309
	if (!f.file)
		return -EBADF;
L
Linus Torvalds 已提交
310 311

	retval = -EINVAL;
312 313
	if (whence <= SEEK_MAX) {
		loff_t res = vfs_llseek(f.file, offset, whence);
L
Linus Torvalds 已提交
314 315 316 317
		retval = res;
		if (res != (loff_t)retval)
			retval = -EOVERFLOW;	/* LFS: should only happen on 32 bit platforms */
	}
318
	fdput_pos(f);
L
Linus Torvalds 已提交
319 320 321
	return retval;
}

322 323 324 325 326
SYSCALL_DEFINE3(lseek, unsigned int, fd, off_t, offset, unsigned int, whence)
{
	return ksys_lseek(fd, offset, whence);
}

A
Al Viro 已提交
327 328 329
#ifdef CONFIG_COMPAT
COMPAT_SYSCALL_DEFINE3(lseek, unsigned int, fd, compat_off_t, offset, unsigned int, whence)
{
330
	return ksys_lseek(fd, offset, whence);
A
Al Viro 已提交
331 332 333
}
#endif

L
Linus Torvalds 已提交
334
#ifdef __ARCH_WANT_SYS_LLSEEK
335 336
SYSCALL_DEFINE5(llseek, unsigned int, fd, unsigned long, offset_high,
		unsigned long, offset_low, loff_t __user *, result,
337
		unsigned int, whence)
L
Linus Torvalds 已提交
338 339
{
	int retval;
340
	struct fd f = fdget_pos(fd);
L
Linus Torvalds 已提交
341 342
	loff_t offset;

343 344
	if (!f.file)
		return -EBADF;
L
Linus Torvalds 已提交
345 346

	retval = -EINVAL;
347
	if (whence > SEEK_MAX)
L
Linus Torvalds 已提交
348 349
		goto out_putf;

350
	offset = vfs_llseek(f.file, ((loff_t) offset_high << 32) | offset_low,
351
			whence);
L
Linus Torvalds 已提交
352 353 354 355 356 357 358 359

	retval = (int)offset;
	if (offset >= 0) {
		retval = -EFAULT;
		if (!copy_to_user(result, &offset, sizeof(offset)))
			retval = 0;
	}
out_putf:
360
	fdput_pos(f);
L
Linus Torvalds 已提交
361 362 363 364
	return retval;
}
#endif

A
Al Viro 已提交
365
int rw_verify_area(int read_write, struct file *file, const loff_t *ppos, size_t count)
L
Linus Torvalds 已提交
366 367 368
{
	struct inode *inode;
	loff_t pos;
369
	int retval = -EINVAL;
L
Linus Torvalds 已提交
370

A
Al Viro 已提交
371
	inode = file_inode(file);
372
	if (unlikely((ssize_t) count < 0))
373
		return retval;
L
Linus Torvalds 已提交
374
	pos = *ppos;
375 376 377 378 379 380 381
	if (unlikely(pos < 0)) {
		if (!unsigned_offsets(file))
			return retval;
		if (count >= -pos) /* both values are in 0..LLONG_MAX */
			return -EOVERFLOW;
	} else if (unlikely((loff_t) (pos + count) < 0)) {
		if (!unsigned_offsets(file))
382 383
			return retval;
	}
L
Linus Torvalds 已提交
384

385
	if (unlikely(inode->i_flctx && mandatory_lock(inode))) {
386 387
		retval = locks_mandatory_area(inode, file, pos, pos + count - 1,
				read_write == READ ? F_RDLCK : F_WRLCK);
388 389 390
		if (retval < 0)
			return retval;
	}
391
	return security_file_permission(file,
392
				read_write == READ ? MAY_READ : MAY_WRITE);
L
Linus Torvalds 已提交
393 394
}

A
Al Viro 已提交
395
static ssize_t new_sync_read(struct file *filp, char __user *buf, size_t len, loff_t *ppos)
396 397 398 399 400 401 402 403 404 405
{
	struct iovec iov = { .iov_base = buf, .iov_len = len };
	struct kiocb kiocb;
	struct iov_iter iter;
	ssize_t ret;

	init_sync_kiocb(&kiocb, filp);
	kiocb.ki_pos = *ppos;
	iov_iter_init(&iter, READ, &iov, 1, len);

406
	ret = call_read_iter(filp, &kiocb, &iter);
407
	BUG_ON(ret == -EIOCBQUEUED);
408 409 410 411
	*ppos = kiocb.ki_pos;
	return ret;
}

D
Dmitry Kasatkin 已提交
412 413 414 415
ssize_t __vfs_read(struct file *file, char __user *buf, size_t count,
		   loff_t *pos)
{
	if (file->f_op->read)
A
Al Viro 已提交
416
		return file->f_op->read(file, buf, count, pos);
D
Dmitry Kasatkin 已提交
417
	else if (file->f_op->read_iter)
A
Al Viro 已提交
418
		return new_sync_read(file, buf, count, pos);
D
Dmitry Kasatkin 已提交
419
	else
A
Al Viro 已提交
420
		return -EINVAL;
D
Dmitry Kasatkin 已提交
421 422
}

423
ssize_t kernel_read(struct file *file, void *buf, size_t count, loff_t *pos)
424 425
{
	mm_segment_t old_fs;
426
	ssize_t result;
427 428 429 430

	old_fs = get_fs();
	set_fs(get_ds());
	/* The cast to a user pointer is valid due to the set_fs() */
431
	result = vfs_read(file, (void __user *)buf, count, pos);
432 433 434 435
	set_fs(old_fs);
	return result;
}
EXPORT_SYMBOL(kernel_read);
D
Dmitry Kasatkin 已提交
436

L
Linus Torvalds 已提交
437 438 439 440 441 442
ssize_t vfs_read(struct file *file, char __user *buf, size_t count, loff_t *pos)
{
	ssize_t ret;

	if (!(file->f_mode & FMODE_READ))
		return -EBADF;
443
	if (!(file->f_mode & FMODE_CAN_READ))
L
Linus Torvalds 已提交
444 445 446 447 448
		return -EINVAL;
	if (unlikely(!access_ok(VERIFY_WRITE, buf, count)))
		return -EFAULT;

	ret = rw_verify_area(READ, file, pos, count);
449 450 451
	if (!ret) {
		if (count > MAX_RW_COUNT)
			count =  MAX_RW_COUNT;
D
Dmitry Kasatkin 已提交
452
		ret = __vfs_read(file, buf, count, pos);
453
		if (ret > 0) {
454
			fsnotify_access(file);
455
			add_rchar(current, ret);
L
Linus Torvalds 已提交
456
		}
457
		inc_syscr(current);
L
Linus Torvalds 已提交
458 459 460 461 462
	}

	return ret;
}

A
Al Viro 已提交
463
static ssize_t new_sync_write(struct file *filp, const char __user *buf, size_t len, loff_t *ppos)
464 465 466 467 468 469 470 471 472 473
{
	struct iovec iov = { .iov_base = (void __user *)buf, .iov_len = len };
	struct kiocb kiocb;
	struct iov_iter iter;
	ssize_t ret;

	init_sync_kiocb(&kiocb, filp);
	kiocb.ki_pos = *ppos;
	iov_iter_init(&iter, WRITE, &iov, 1, len);

474
	ret = call_write_iter(filp, &kiocb, &iter);
475
	BUG_ON(ret == -EIOCBQUEUED);
476 477
	if (ret > 0)
		*ppos = kiocb.ki_pos;
478 479 480
	return ret;
}

A
Al Viro 已提交
481 482 483 484 485 486 487 488 489 490 491
ssize_t __vfs_write(struct file *file, const char __user *p, size_t count,
		    loff_t *pos)
{
	if (file->f_op->write)
		return file->f_op->write(file, p, count, pos);
	else if (file->f_op->write_iter)
		return new_sync_write(file, p, count, pos);
	else
		return -EINVAL;
}

492
ssize_t __kernel_write(struct file *file, const void *buf, size_t count, loff_t *pos)
493 494 495 496 497
{
	mm_segment_t old_fs;
	const char __user *p;
	ssize_t ret;

498
	if (!(file->f_mode & FMODE_CAN_WRITE))
499 500
		return -EINVAL;

501 502 503 504 505
	old_fs = get_fs();
	set_fs(get_ds());
	p = (__force const char __user *)buf;
	if (count > MAX_RW_COUNT)
		count =  MAX_RW_COUNT;
A
Al Viro 已提交
506
	ret = __vfs_write(file, p, count, pos);
507 508 509 510 511 512 513 514
	set_fs(old_fs);
	if (ret > 0) {
		fsnotify_modify(file);
		add_wchar(current, ret);
	}
	inc_syscw(current);
	return ret;
}
515 516
EXPORT_SYMBOL(__kernel_write);

517 518
ssize_t kernel_write(struct file *file, const void *buf, size_t count,
			    loff_t *pos)
519 520 521 522 523 524 525
{
	mm_segment_t old_fs;
	ssize_t res;

	old_fs = get_fs();
	set_fs(get_ds());
	/* The cast to a user pointer is valid due to the set_fs() */
526
	res = vfs_write(file, (__force const char __user *)buf, count, pos);
527 528 529 530 531 532
	set_fs(old_fs);

	return res;
}
EXPORT_SYMBOL(kernel_write);

L
Linus Torvalds 已提交
533 534 535 536 537 538
ssize_t vfs_write(struct file *file, const char __user *buf, size_t count, loff_t *pos)
{
	ssize_t ret;

	if (!(file->f_mode & FMODE_WRITE))
		return -EBADF;
539
	if (!(file->f_mode & FMODE_CAN_WRITE))
L
Linus Torvalds 已提交
540 541 542 543 544
		return -EINVAL;
	if (unlikely(!access_ok(VERIFY_READ, buf, count)))
		return -EFAULT;

	ret = rw_verify_area(WRITE, file, pos, count);
545 546 547
	if (!ret) {
		if (count > MAX_RW_COUNT)
			count =  MAX_RW_COUNT;
A
Al Viro 已提交
548
		file_start_write(file);
A
Al Viro 已提交
549
		ret = __vfs_write(file, buf, count, pos);
550
		if (ret > 0) {
551
			fsnotify_modify(file);
552
			add_wchar(current, ret);
L
Linus Torvalds 已提交
553
		}
554
		inc_syscw(current);
A
Al Viro 已提交
555
		file_end_write(file);
L
Linus Torvalds 已提交
556 557 558 559 560 561 562 563 564 565 566 567 568 569 570
	}

	return ret;
}

static inline loff_t file_pos_read(struct file *file)
{
	return file->f_pos;
}

static inline void file_pos_write(struct file *file, loff_t pos)
{
	file->f_pos = pos;
}

571
ssize_t ksys_read(unsigned int fd, char __user *buf, size_t count)
L
Linus Torvalds 已提交
572
{
573
	struct fd f = fdget_pos(fd);
L
Linus Torvalds 已提交
574 575
	ssize_t ret = -EBADF;

576 577 578
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
		ret = vfs_read(f.file, buf, count, &pos);
579 580
		if (ret >= 0)
			file_pos_write(f.file, pos);
581
		fdput_pos(f);
L
Linus Torvalds 已提交
582 583 584 585
	}
	return ret;
}

586 587 588 589 590
SYSCALL_DEFINE3(read, unsigned int, fd, char __user *, buf, size_t, count)
{
	return ksys_read(fd, buf, count);
}

591
ssize_t ksys_write(unsigned int fd, const char __user *buf, size_t count)
L
Linus Torvalds 已提交
592
{
593
	struct fd f = fdget_pos(fd);
L
Linus Torvalds 已提交
594 595
	ssize_t ret = -EBADF;

596 597 598
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
		ret = vfs_write(f.file, buf, count, &pos);
599 600
		if (ret >= 0)
			file_pos_write(f.file, pos);
601
		fdput_pos(f);
L
Linus Torvalds 已提交
602 603 604 605 606
	}

	return ret;
}

607 608 609 610 611 612
SYSCALL_DEFINE3(write, unsigned int, fd, const char __user *, buf,
		size_t, count)
{
	return ksys_write(fd, buf, count);
}

613 614
ssize_t ksys_pread64(unsigned int fd, char __user *buf, size_t count,
		     loff_t pos)
L
Linus Torvalds 已提交
615
{
616
	struct fd f;
L
Linus Torvalds 已提交
617 618 619 620 621
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

622 623
	f = fdget(fd);
	if (f.file) {
L
Linus Torvalds 已提交
624
		ret = -ESPIPE;
625 626 627
		if (f.file->f_mode & FMODE_PREAD)
			ret = vfs_read(f.file, buf, count, &pos);
		fdput(f);
L
Linus Torvalds 已提交
628 629 630 631 632
	}

	return ret;
}

633 634 635 636 637 638 639 640
SYSCALL_DEFINE4(pread64, unsigned int, fd, char __user *, buf,
			size_t, count, loff_t, pos)
{
	return ksys_pread64(fd, buf, count, pos);
}

ssize_t ksys_pwrite64(unsigned int fd, const char __user *buf,
		      size_t count, loff_t pos)
L
Linus Torvalds 已提交
641
{
642
	struct fd f;
L
Linus Torvalds 已提交
643 644 645 646 647
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

648 649
	f = fdget(fd);
	if (f.file) {
L
Linus Torvalds 已提交
650
		ret = -ESPIPE;
651 652 653
		if (f.file->f_mode & FMODE_PWRITE)  
			ret = vfs_write(f.file, buf, count, &pos);
		fdput(f);
L
Linus Torvalds 已提交
654 655 656 657 658
	}

	return ret;
}

659 660 661 662 663 664
SYSCALL_DEFINE4(pwrite64, unsigned int, fd, const char __user *, buf,
			 size_t, count, loff_t, pos)
{
	return ksys_pwrite64(fd, buf, count, pos);
}

665
static ssize_t do_iter_readv_writev(struct file *filp, struct iov_iter *iter,
C
Christoph Hellwig 已提交
666
		loff_t *ppos, int type, rwf_t flags)
667 668 669 670 671
{
	struct kiocb kiocb;
	ssize_t ret;

	init_sync_kiocb(&kiocb, filp);
672 673 674
	ret = kiocb_set_rw_flags(&kiocb, flags);
	if (ret)
		return ret;
675 676
	kiocb.ki_pos = *ppos;

677
	if (type == READ)
678
		ret = call_read_iter(filp, &kiocb, iter);
679
	else
680
		ret = call_write_iter(filp, &kiocb, iter);
681
	BUG_ON(ret == -EIOCBQUEUED);
682 683 684 685
	*ppos = kiocb.ki_pos;
	return ret;
}

686
/* Do it by hand, with file-ops */
687
static ssize_t do_loop_readv_writev(struct file *filp, struct iov_iter *iter,
C
Christoph Hellwig 已提交
688
		loff_t *ppos, int type, rwf_t flags)
689 690 691
{
	ssize_t ret = 0;

692
	if (flags & ~RWF_HIPRI)
693 694
		return -EOPNOTSUPP;

695 696
	while (iov_iter_count(iter)) {
		struct iovec iovec = iov_iter_iovec(iter);
697 698
		ssize_t nr;

699 700 701 702 703 704 705
		if (type == READ) {
			nr = filp->f_op->read(filp, iovec.iov_base,
					      iovec.iov_len, ppos);
		} else {
			nr = filp->f_op->write(filp, iovec.iov_base,
					       iovec.iov_len, ppos);
		}
706 707 708 709 710 711 712

		if (nr < 0) {
			if (!ret)
				ret = nr;
			break;
		}
		ret += nr;
713
		if (nr != iovec.iov_len)
714
			break;
715
		iov_iter_advance(iter, nr);
716 717 718 719 720
	}

	return ret;
}

L
Linus Torvalds 已提交
721 722 723
/* A write operation does a read from user space and vice versa */
#define vrfy_dir(type) ((type) == READ ? VERIFY_WRITE : VERIFY_READ)

724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752
/**
 * rw_copy_check_uvector() - Copy an array of &struct iovec from userspace
 *     into the kernel and check that it is valid.
 *
 * @type: One of %CHECK_IOVEC_ONLY, %READ, or %WRITE.
 * @uvector: Pointer to the userspace array.
 * @nr_segs: Number of elements in userspace array.
 * @fast_segs: Number of elements in @fast_pointer.
 * @fast_pointer: Pointer to (usually small on-stack) kernel array.
 * @ret_pointer: (output parameter) Pointer to a variable that will point to
 *     either @fast_pointer, a newly allocated kernel array, or NULL,
 *     depending on which array was used.
 *
 * This function copies an array of &struct iovec of @nr_segs from
 * userspace into the kernel and checks that each element is valid (e.g.
 * it does not point to a kernel address or cause overflow by being too
 * large, etc.).
 *
 * As an optimization, the caller may provide a pointer to a small
 * on-stack array in @fast_pointer, typically %UIO_FASTIOV elements long
 * (the size of this array, or 0 if unused, should be given in @fast_segs).
 *
 * @ret_pointer will always point to the array that was used, so the
 * caller must take care not to call kfree() on it e.g. in case the
 * @fast_pointer array was used and it was allocated on the stack.
 *
 * Return: The total number of bytes covered by the iovec array on success
 *   or a negative error code on error.
 */
B
Badari Pulavarty 已提交
753 754 755
ssize_t rw_copy_check_uvector(int type, const struct iovec __user * uvector,
			      unsigned long nr_segs, unsigned long fast_segs,
			      struct iovec *fast_pointer,
756
			      struct iovec **ret_pointer)
757
{
B
Badari Pulavarty 已提交
758
	unsigned long seg;
759
	ssize_t ret;
B
Badari Pulavarty 已提交
760 761
	struct iovec *iov = fast_pointer;

762 763 764 765 766
	/*
	 * SuS says "The readv() function *may* fail if the iovcnt argument
	 * was less than or equal to 0, or greater than {IOV_MAX}.  Linux has
	 * traditionally returned zero for zero segments, so...
	 */
B
Badari Pulavarty 已提交
767 768
	if (nr_segs == 0) {
		ret = 0;
769
		goto out;
B
Badari Pulavarty 已提交
770 771
	}

772 773 774 775
	/*
	 * First get the "struct iovec" from user memory and
	 * verify all the pointers
	 */
B
Badari Pulavarty 已提交
776 777
	if (nr_segs > UIO_MAXIOV) {
		ret = -EINVAL;
778
		goto out;
B
Badari Pulavarty 已提交
779 780
	}
	if (nr_segs > fast_segs) {
781
		iov = kmalloc_array(nr_segs, sizeof(struct iovec), GFP_KERNEL);
B
Badari Pulavarty 已提交
782 783
		if (iov == NULL) {
			ret = -ENOMEM;
784
			goto out;
B
Badari Pulavarty 已提交
785
		}
786
	}
B
Badari Pulavarty 已提交
787 788
	if (copy_from_user(iov, uvector, nr_segs*sizeof(*uvector))) {
		ret = -EFAULT;
789
		goto out;
B
Badari Pulavarty 已提交
790 791
	}

792
	/*
B
Badari Pulavarty 已提交
793 794 795 796
	 * According to the Single Unix Specification we should return EINVAL
	 * if an element length is < 0 when cast to ssize_t or if the
	 * total length would overflow the ssize_t return value of the
	 * system call.
797 798 799 800
	 *
	 * Linux caps all read/write calls to MAX_RW_COUNT, and avoids the
	 * overflow case.
	 */
B
Badari Pulavarty 已提交
801
	ret = 0;
802 803 804
	for (seg = 0; seg < nr_segs; seg++) {
		void __user *buf = iov[seg].iov_base;
		ssize_t len = (ssize_t)iov[seg].iov_len;
B
Badari Pulavarty 已提交
805 806 807

		/* see if we we're about to use an invalid len or if
		 * it's about to overflow ssize_t */
808
		if (len < 0) {
B
Badari Pulavarty 已提交
809
			ret = -EINVAL;
810
			goto out;
B
Badari Pulavarty 已提交
811
		}
812
		if (type >= 0
C
Christopher Yeoh 已提交
813
		    && unlikely(!access_ok(vrfy_dir(type), buf, len))) {
B
Badari Pulavarty 已提交
814
			ret = -EFAULT;
815 816 817 818 819
			goto out;
		}
		if (len > MAX_RW_COUNT - ret) {
			len = MAX_RW_COUNT - ret;
			iov[seg].iov_len = len;
B
Badari Pulavarty 已提交
820 821
		}
		ret += len;
822
	}
B
Badari Pulavarty 已提交
823 824 825 826 827
out:
	*ret_pointer = iov;
	return ret;
}

828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851
#ifdef CONFIG_COMPAT
ssize_t compat_rw_copy_check_uvector(int type,
		const struct compat_iovec __user *uvector, unsigned long nr_segs,
		unsigned long fast_segs, struct iovec *fast_pointer,
		struct iovec **ret_pointer)
{
	compat_ssize_t tot_len;
	struct iovec *iov = *ret_pointer = fast_pointer;
	ssize_t ret = 0;
	int seg;

	/*
	 * SuS says "The readv() function *may* fail if the iovcnt argument
	 * was less than or equal to 0, or greater than {IOV_MAX}.  Linux has
	 * traditionally returned zero for zero segments, so...
	 */
	if (nr_segs == 0)
		goto out;

	ret = -EINVAL;
	if (nr_segs > UIO_MAXIOV)
		goto out;
	if (nr_segs > fast_segs) {
		ret = -ENOMEM;
852
		iov = kmalloc_array(nr_segs, sizeof(struct iovec), GFP_KERNEL);
853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902
		if (iov == NULL)
			goto out;
	}
	*ret_pointer = iov;

	ret = -EFAULT;
	if (!access_ok(VERIFY_READ, uvector, nr_segs*sizeof(*uvector)))
		goto out;

	/*
	 * Single unix specification:
	 * We should -EINVAL if an element length is not >= 0 and fitting an
	 * ssize_t.
	 *
	 * In Linux, the total length is limited to MAX_RW_COUNT, there is
	 * no overflow possibility.
	 */
	tot_len = 0;
	ret = -EINVAL;
	for (seg = 0; seg < nr_segs; seg++) {
		compat_uptr_t buf;
		compat_ssize_t len;

		if (__get_user(len, &uvector->iov_len) ||
		   __get_user(buf, &uvector->iov_base)) {
			ret = -EFAULT;
			goto out;
		}
		if (len < 0)	/* size_t not fitting in compat_ssize_t .. */
			goto out;
		if (type >= 0 &&
		    !access_ok(vrfy_dir(type), compat_ptr(buf), len)) {
			ret = -EFAULT;
			goto out;
		}
		if (len > MAX_RW_COUNT - tot_len)
			len = MAX_RW_COUNT - tot_len;
		tot_len += len;
		iov->iov_base = compat_ptr(buf);
		iov->iov_len = (compat_size_t) len;
		uvector++;
		iov++;
	}
	ret = tot_len;

out:
	return ret;
}
#endif

C
Christoph Hellwig 已提交
903
static ssize_t do_iter_read(struct file *file, struct iov_iter *iter,
C
Christoph Hellwig 已提交
904
		loff_t *pos, rwf_t flags)
L
Linus Torvalds 已提交
905 906
{
	size_t tot_len;
907
	ssize_t ret = 0;
L
Linus Torvalds 已提交
908

909 910 911 912 913
	if (!(file->f_mode & FMODE_READ))
		return -EBADF;
	if (!(file->f_mode & FMODE_CAN_READ))
		return -EINVAL;

914
	tot_len = iov_iter_count(iter);
915 916
	if (!tot_len)
		goto out;
C
Christoph Hellwig 已提交
917
	ret = rw_verify_area(READ, file, pos, tot_len);
918
	if (ret < 0)
C
Christoph Hellwig 已提交
919
		return ret;
L
Linus Torvalds 已提交
920

C
Christoph Hellwig 已提交
921 922
	if (file->f_op->read_iter)
		ret = do_iter_readv_writev(file, iter, pos, READ, flags);
923
	else
C
Christoph Hellwig 已提交
924
		ret = do_loop_readv_writev(file, iter, pos, READ, flags);
L
Linus Torvalds 已提交
925
out:
C
Christoph Hellwig 已提交
926 927
	if (ret >= 0)
		fsnotify_access(file);
L
Linus Torvalds 已提交
928 929 930
	return ret;
}

931
ssize_t vfs_iter_read(struct file *file, struct iov_iter *iter, loff_t *ppos,
C
Christoph Hellwig 已提交
932
		rwf_t flags)
933
{
934 935 936 937 938
	if (!file->f_op->read_iter)
		return -EINVAL;
	return do_iter_read(file, iter, ppos, flags);
}
EXPORT_SYMBOL(vfs_iter_read);
939

C
Christoph Hellwig 已提交
940
static ssize_t do_iter_write(struct file *file, struct iov_iter *iter,
C
Christoph Hellwig 已提交
941
		loff_t *pos, rwf_t flags)
C
Christoph Hellwig 已提交
942 943 944
{
	size_t tot_len;
	ssize_t ret = 0;
A
Al Viro 已提交
945

946 947 948 949 950
	if (!(file->f_mode & FMODE_WRITE))
		return -EBADF;
	if (!(file->f_mode & FMODE_CAN_WRITE))
		return -EINVAL;

C
Christoph Hellwig 已提交
951 952 953 954
	tot_len = iov_iter_count(iter);
	if (!tot_len)
		return 0;
	ret = rw_verify_area(WRITE, file, pos, tot_len);
955 956 957
	if (ret < 0)
		return ret;

C
Christoph Hellwig 已提交
958 959 960 961 962 963
	if (file->f_op->write_iter)
		ret = do_iter_readv_writev(file, iter, pos, WRITE, flags);
	else
		ret = do_loop_readv_writev(file, iter, pos, WRITE, flags);
	if (ret > 0)
		fsnotify_modify(file);
964 965 966
	return ret;
}

967
ssize_t vfs_iter_write(struct file *file, struct iov_iter *iter, loff_t *ppos,
C
Christoph Hellwig 已提交
968
		rwf_t flags)
969 970 971 972 973 974 975
{
	if (!file->f_op->write_iter)
		return -EINVAL;
	return do_iter_write(file, iter, ppos, flags);
}
EXPORT_SYMBOL(vfs_iter_write);

L
Linus Torvalds 已提交
976
ssize_t vfs_readv(struct file *file, const struct iovec __user *vec,
C
Christoph Hellwig 已提交
977
		  unsigned long vlen, loff_t *pos, rwf_t flags)
L
Linus Torvalds 已提交
978
{
979 980 981 982
	struct iovec iovstack[UIO_FASTIOV];
	struct iovec *iov = iovstack;
	struct iov_iter iter;
	ssize_t ret;
L
Linus Torvalds 已提交
983

C
Christoph Hellwig 已提交
984
	ret = import_iovec(READ, vec, vlen, ARRAY_SIZE(iovstack), &iov, &iter);
985 986 987 988
	if (ret >= 0) {
		ret = do_iter_read(file, &iter, pos, flags);
		kfree(iov);
	}
L
Linus Torvalds 已提交
989

C
Christoph Hellwig 已提交
990 991
	return ret;
}
L
Linus Torvalds 已提交
992

993
static ssize_t vfs_writev(struct file *file, const struct iovec __user *vec,
C
Christoph Hellwig 已提交
994
		   unsigned long vlen, loff_t *pos, rwf_t flags)
L
Linus Torvalds 已提交
995
{
C
Christoph Hellwig 已提交
996 997 998 999
	struct iovec iovstack[UIO_FASTIOV];
	struct iovec *iov = iovstack;
	struct iov_iter iter;
	ssize_t ret;
L
Linus Torvalds 已提交
1000

C
Christoph Hellwig 已提交
1001
	ret = import_iovec(WRITE, vec, vlen, ARRAY_SIZE(iovstack), &iov, &iter);
1002
	if (ret >= 0) {
1003
		file_start_write(file);
1004
		ret = do_iter_write(file, &iter, pos, flags);
1005
		file_end_write(file);
1006 1007
		kfree(iov);
	}
C
Christoph Hellwig 已提交
1008
	return ret;
L
Linus Torvalds 已提交
1009 1010
}

1011
static ssize_t do_readv(unsigned long fd, const struct iovec __user *vec,
C
Christoph Hellwig 已提交
1012
			unsigned long vlen, rwf_t flags)
L
Linus Torvalds 已提交
1013
{
1014
	struct fd f = fdget_pos(fd);
L
Linus Torvalds 已提交
1015 1016
	ssize_t ret = -EBADF;

1017 1018
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
1019
		ret = vfs_readv(f.file, vec, vlen, &pos, flags);
1020 1021
		if (ret >= 0)
			file_pos_write(f.file, pos);
1022
		fdput_pos(f);
L
Linus Torvalds 已提交
1023 1024 1025
	}

	if (ret > 0)
1026 1027
		add_rchar(current, ret);
	inc_syscr(current);
L
Linus Torvalds 已提交
1028 1029 1030
	return ret;
}

1031
static ssize_t do_writev(unsigned long fd, const struct iovec __user *vec,
C
Christoph Hellwig 已提交
1032
			 unsigned long vlen, rwf_t flags)
L
Linus Torvalds 已提交
1033
{
1034
	struct fd f = fdget_pos(fd);
L
Linus Torvalds 已提交
1035 1036
	ssize_t ret = -EBADF;

1037 1038
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
1039
		ret = vfs_writev(f.file, vec, vlen, &pos, flags);
1040 1041
		if (ret >= 0)
			file_pos_write(f.file, pos);
1042
		fdput_pos(f);
L
Linus Torvalds 已提交
1043 1044 1045
	}

	if (ret > 0)
1046 1047
		add_wchar(current, ret);
	inc_syscw(current);
L
Linus Torvalds 已提交
1048 1049 1050
	return ret;
}

1051 1052 1053 1054 1055 1056
static inline loff_t pos_from_hilo(unsigned long high, unsigned long low)
{
#define HALF_LONG_BITS (BITS_PER_LONG / 2)
	return (((loff_t)high << HALF_LONG_BITS) << HALF_LONG_BITS) | low;
}

1057
static ssize_t do_preadv(unsigned long fd, const struct iovec __user *vec,
C
Christoph Hellwig 已提交
1058
			 unsigned long vlen, loff_t pos, rwf_t flags)
1059
{
1060
	struct fd f;
1061 1062 1063 1064 1065
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

1066 1067
	f = fdget(fd);
	if (f.file) {
1068
		ret = -ESPIPE;
1069
		if (f.file->f_mode & FMODE_PREAD)
1070
			ret = vfs_readv(f.file, vec, vlen, &pos, flags);
1071
		fdput(f);
1072 1073 1074 1075 1076 1077 1078 1079
	}

	if (ret > 0)
		add_rchar(current, ret);
	inc_syscr(current);
	return ret;
}

1080
static ssize_t do_pwritev(unsigned long fd, const struct iovec __user *vec,
C
Christoph Hellwig 已提交
1081
			  unsigned long vlen, loff_t pos, rwf_t flags)
1082
{
1083
	struct fd f;
1084 1085 1086 1087 1088
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

1089 1090
	f = fdget(fd);
	if (f.file) {
1091
		ret = -ESPIPE;
1092
		if (f.file->f_mode & FMODE_PWRITE)
1093
			ret = vfs_writev(f.file, vec, vlen, &pos, flags);
1094
		fdput(f);
1095 1096 1097 1098 1099 1100 1101 1102
	}

	if (ret > 0)
		add_wchar(current, ret);
	inc_syscw(current);
	return ret;
}

1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124
SYSCALL_DEFINE3(readv, unsigned long, fd, const struct iovec __user *, vec,
		unsigned long, vlen)
{
	return do_readv(fd, vec, vlen, 0);
}

SYSCALL_DEFINE3(writev, unsigned long, fd, const struct iovec __user *, vec,
		unsigned long, vlen)
{
	return do_writev(fd, vec, vlen, 0);
}

SYSCALL_DEFINE5(preadv, unsigned long, fd, const struct iovec __user *, vec,
		unsigned long, vlen, unsigned long, pos_l, unsigned long, pos_h)
{
	loff_t pos = pos_from_hilo(pos_h, pos_l);

	return do_preadv(fd, vec, vlen, pos, 0);
}

SYSCALL_DEFINE6(preadv2, unsigned long, fd, const struct iovec __user *, vec,
		unsigned long, vlen, unsigned long, pos_l, unsigned long, pos_h,
C
Christoph Hellwig 已提交
1125
		rwf_t, flags)
1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144
{
	loff_t pos = pos_from_hilo(pos_h, pos_l);

	if (pos == -1)
		return do_readv(fd, vec, vlen, flags);

	return do_preadv(fd, vec, vlen, pos, flags);
}

SYSCALL_DEFINE5(pwritev, unsigned long, fd, const struct iovec __user *, vec,
		unsigned long, vlen, unsigned long, pos_l, unsigned long, pos_h)
{
	loff_t pos = pos_from_hilo(pos_h, pos_l);

	return do_pwritev(fd, vec, vlen, pos, 0);
}

SYSCALL_DEFINE6(pwritev2, unsigned long, fd, const struct iovec __user *, vec,
		unsigned long, vlen, unsigned long, pos_l, unsigned long, pos_h,
C
Christoph Hellwig 已提交
1145
		rwf_t, flags)
1146 1147 1148 1149 1150 1151 1152 1153 1154
{
	loff_t pos = pos_from_hilo(pos_h, pos_l);

	if (pos == -1)
		return do_writev(fd, vec, vlen, flags);

	return do_pwritev(fd, vec, vlen, pos, flags);
}

1155 1156 1157
#ifdef CONFIG_COMPAT
static size_t compat_readv(struct file *file,
			   const struct compat_iovec __user *vec,
C
Christoph Hellwig 已提交
1158
			   unsigned long vlen, loff_t *pos, rwf_t flags)
1159 1160 1161
{
	struct iovec iovstack[UIO_FASTIOV];
	struct iovec *iov = iovstack;
1162
	struct iov_iter iter;
1163 1164
	ssize_t ret;

1165
	ret = compat_import_iovec(READ, vec, vlen, UIO_FASTIOV, &iov, &iter);
1166 1167 1168 1169
	if (ret >= 0) {
		ret = do_iter_read(file, &iter, pos, flags);
		kfree(iov);
	}
1170 1171 1172 1173 1174 1175
	if (ret > 0)
		add_rchar(current, ret);
	inc_syscr(current);
	return ret;
}

1176 1177
static size_t do_compat_readv(compat_ulong_t fd,
				 const struct compat_iovec __user *vec,
C
Christoph Hellwig 已提交
1178
				 compat_ulong_t vlen, rwf_t flags)
1179
{
1180
	struct fd f = fdget_pos(fd);
1181 1182 1183 1184 1185 1186
	ssize_t ret;
	loff_t pos;

	if (!f.file)
		return -EBADF;
	pos = f.file->f_pos;
1187
	ret = compat_readv(f.file, vec, vlen, &pos, flags);
1188 1189
	if (ret >= 0)
		f.file->f_pos = pos;
1190
	fdput_pos(f);
1191
	return ret;
1192

1193 1194
}

1195 1196 1197 1198 1199 1200 1201 1202
COMPAT_SYSCALL_DEFINE3(readv, compat_ulong_t, fd,
		const struct compat_iovec __user *,vec,
		compat_ulong_t, vlen)
{
	return do_compat_readv(fd, vec, vlen, 0);
}

static long do_compat_preadv64(unsigned long fd,
1203
				  const struct compat_iovec __user *vec,
C
Christoph Hellwig 已提交
1204
				  unsigned long vlen, loff_t pos, rwf_t flags)
1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215
{
	struct fd f;
	ssize_t ret;

	if (pos < 0)
		return -EINVAL;
	f = fdget(fd);
	if (!f.file)
		return -EBADF;
	ret = -ESPIPE;
	if (f.file->f_mode & FMODE_PREAD)
1216
		ret = compat_readv(f.file, vec, vlen, &pos, flags);
1217 1218 1219 1220
	fdput(f);
	return ret;
}

1221 1222 1223 1224 1225
#ifdef __ARCH_WANT_COMPAT_SYS_PREADV64
COMPAT_SYSCALL_DEFINE4(preadv64, unsigned long, fd,
		const struct compat_iovec __user *,vec,
		unsigned long, vlen, loff_t, pos)
{
1226
	return do_compat_preadv64(fd, vec, vlen, pos, 0);
1227 1228 1229
}
#endif

1230
COMPAT_SYSCALL_DEFINE5(preadv, compat_ulong_t, fd,
1231
		const struct compat_iovec __user *,vec,
1232
		compat_ulong_t, vlen, u32, pos_low, u32, pos_high)
1233 1234
{
	loff_t pos = ((loff_t)pos_high << 32) | pos_low;
1235

1236 1237 1238
	return do_compat_preadv64(fd, vec, vlen, pos, 0);
}

1239 1240 1241
#ifdef __ARCH_WANT_COMPAT_SYS_PREADV64V2
COMPAT_SYSCALL_DEFINE5(preadv64v2, unsigned long, fd,
		const struct compat_iovec __user *,vec,
C
Christoph Hellwig 已提交
1242
		unsigned long, vlen, loff_t, pos, rwf_t, flags)
1243 1244 1245 1246 1247
{
	return do_compat_preadv64(fd, vec, vlen, pos, flags);
}
#endif

1248 1249 1250
COMPAT_SYSCALL_DEFINE6(preadv2, compat_ulong_t, fd,
		const struct compat_iovec __user *,vec,
		compat_ulong_t, vlen, u32, pos_low, u32, pos_high,
C
Christoph Hellwig 已提交
1251
		rwf_t, flags)
1252 1253 1254 1255 1256 1257 1258
{
	loff_t pos = ((loff_t)pos_high << 32) | pos_low;

	if (pos == -1)
		return do_compat_readv(fd, vec, vlen, flags);

	return do_compat_preadv64(fd, vec, vlen, pos, flags);
1259 1260 1261 1262
}

static size_t compat_writev(struct file *file,
			    const struct compat_iovec __user *vec,
C
Christoph Hellwig 已提交
1263
			    unsigned long vlen, loff_t *pos, rwf_t flags)
1264
{
1265 1266 1267
	struct iovec iovstack[UIO_FASTIOV];
	struct iovec *iov = iovstack;
	struct iov_iter iter;
1268
	ssize_t ret;
1269

1270
	ret = compat_import_iovec(WRITE, vec, vlen, UIO_FASTIOV, &iov, &iter);
1271
	if (ret >= 0) {
1272
		file_start_write(file);
1273
		ret = do_iter_write(file, &iter, pos, flags);
1274
		file_end_write(file);
1275 1276
		kfree(iov);
	}
1277 1278 1279 1280 1281 1282
	if (ret > 0)
		add_wchar(current, ret);
	inc_syscw(current);
	return ret;
}

1283 1284
static size_t do_compat_writev(compat_ulong_t fd,
				  const struct compat_iovec __user* vec,
C
Christoph Hellwig 已提交
1285
				  compat_ulong_t vlen, rwf_t flags)
1286
{
1287
	struct fd f = fdget_pos(fd);
1288 1289 1290 1291 1292 1293
	ssize_t ret;
	loff_t pos;

	if (!f.file)
		return -EBADF;
	pos = f.file->f_pos;
1294
	ret = compat_writev(f.file, vec, vlen, &pos, flags);
1295 1296
	if (ret >= 0)
		f.file->f_pos = pos;
1297
	fdput_pos(f);
1298 1299 1300
	return ret;
}

1301 1302 1303 1304 1305 1306 1307 1308
COMPAT_SYSCALL_DEFINE3(writev, compat_ulong_t, fd,
		const struct compat_iovec __user *, vec,
		compat_ulong_t, vlen)
{
	return do_compat_writev(fd, vec, vlen, 0);
}

static long do_compat_pwritev64(unsigned long fd,
1309
				   const struct compat_iovec __user *vec,
C
Christoph Hellwig 已提交
1310
				   unsigned long vlen, loff_t pos, rwf_t flags)
1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321
{
	struct fd f;
	ssize_t ret;

	if (pos < 0)
		return -EINVAL;
	f = fdget(fd);
	if (!f.file)
		return -EBADF;
	ret = -ESPIPE;
	if (f.file->f_mode & FMODE_PWRITE)
1322
		ret = compat_writev(f.file, vec, vlen, &pos, flags);
1323 1324 1325 1326
	fdput(f);
	return ret;
}

1327 1328 1329 1330 1331
#ifdef __ARCH_WANT_COMPAT_SYS_PWRITEV64
COMPAT_SYSCALL_DEFINE4(pwritev64, unsigned long, fd,
		const struct compat_iovec __user *,vec,
		unsigned long, vlen, loff_t, pos)
{
1332
	return do_compat_pwritev64(fd, vec, vlen, pos, 0);
1333 1334 1335
}
#endif

1336
COMPAT_SYSCALL_DEFINE5(pwritev, compat_ulong_t, fd,
1337
		const struct compat_iovec __user *,vec,
1338
		compat_ulong_t, vlen, u32, pos_low, u32, pos_high)
1339 1340
{
	loff_t pos = ((loff_t)pos_high << 32) | pos_low;
1341

1342
	return do_compat_pwritev64(fd, vec, vlen, pos, 0);
1343
}
1344

1345 1346 1347
#ifdef __ARCH_WANT_COMPAT_SYS_PWRITEV64V2
COMPAT_SYSCALL_DEFINE5(pwritev64v2, unsigned long, fd,
		const struct compat_iovec __user *,vec,
C
Christoph Hellwig 已提交
1348
		unsigned long, vlen, loff_t, pos, rwf_t, flags)
1349 1350 1351 1352 1353
{
	return do_compat_pwritev64(fd, vec, vlen, pos, flags);
}
#endif

1354 1355
COMPAT_SYSCALL_DEFINE6(pwritev2, compat_ulong_t, fd,
		const struct compat_iovec __user *,vec,
C
Christoph Hellwig 已提交
1356
		compat_ulong_t, vlen, u32, pos_low, u32, pos_high, rwf_t, flags)
1357 1358 1359 1360 1361 1362 1363
{
	loff_t pos = ((loff_t)pos_high << 32) | pos_low;

	if (pos == -1)
		return do_compat_writev(fd, vec, vlen, flags);

	return do_compat_pwritev64(fd, vec, vlen, pos, flags);
1364
}
1365

1366 1367
#endif

1368 1369
static ssize_t do_sendfile(int out_fd, int in_fd, loff_t *ppos,
		  	   size_t count, loff_t max)
L
Linus Torvalds 已提交
1370
{
1371 1372
	struct fd in, out;
	struct inode *in_inode, *out_inode;
L
Linus Torvalds 已提交
1373
	loff_t pos;
1374
	loff_t out_pos;
L
Linus Torvalds 已提交
1375
	ssize_t retval;
1376
	int fl;
L
Linus Torvalds 已提交
1377 1378 1379 1380 1381

	/*
	 * Get input file, and verify that it is ok..
	 */
	retval = -EBADF;
1382 1383
	in = fdget(in_fd);
	if (!in.file)
L
Linus Torvalds 已提交
1384
		goto out;
1385
	if (!(in.file->f_mode & FMODE_READ))
L
Linus Torvalds 已提交
1386 1387
		goto fput_in;
	retval = -ESPIPE;
1388 1389 1390 1391
	if (!ppos) {
		pos = in.file->f_pos;
	} else {
		pos = *ppos;
1392
		if (!(in.file->f_mode & FMODE_PREAD))
L
Linus Torvalds 已提交
1393
			goto fput_in;
1394 1395
	}
	retval = rw_verify_area(READ, in.file, &pos, count);
1396
	if (retval < 0)
L
Linus Torvalds 已提交
1397
		goto fput_in;
1398 1399
	if (count > MAX_RW_COUNT)
		count =  MAX_RW_COUNT;
L
Linus Torvalds 已提交
1400 1401 1402 1403 1404

	/*
	 * Get output file, and verify that it is ok..
	 */
	retval = -EBADF;
1405 1406
	out = fdget(out_fd);
	if (!out.file)
L
Linus Torvalds 已提交
1407
		goto fput_in;
1408
	if (!(out.file->f_mode & FMODE_WRITE))
L
Linus Torvalds 已提交
1409 1410
		goto fput_out;
	retval = -EINVAL;
A
Al Viro 已提交
1411 1412
	in_inode = file_inode(in.file);
	out_inode = file_inode(out.file);
1413 1414
	out_pos = out.file->f_pos;
	retval = rw_verify_area(WRITE, out.file, &out_pos, count);
1415
	if (retval < 0)
L
Linus Torvalds 已提交
1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427
		goto fput_out;

	if (!max)
		max = min(in_inode->i_sb->s_maxbytes, out_inode->i_sb->s_maxbytes);

	if (unlikely(pos + count > max)) {
		retval = -EOVERFLOW;
		if (pos >= max)
			goto fput_out;
		count = max - pos;
	}

J
Jens Axboe 已提交
1428
	fl = 0;
1429
#if 0
J
Jens Axboe 已提交
1430 1431 1432 1433 1434 1435
	/*
	 * We need to debate whether we can enable this or not. The
	 * man page documents EAGAIN return for the output at least,
	 * and the application is arguably buggy if it doesn't expect
	 * EAGAIN on a non-blocking file descriptor.
	 */
1436
	if (in.file->f_flags & O_NONBLOCK)
J
Jens Axboe 已提交
1437
		fl = SPLICE_F_NONBLOCK;
1438
#endif
1439
	file_start_write(out.file);
1440
	retval = do_splice_direct(in.file, &pos, out.file, &out_pos, count, fl);
1441
	file_end_write(out.file);
L
Linus Torvalds 已提交
1442 1443

	if (retval > 0) {
1444 1445
		add_rchar(current, retval);
		add_wchar(current, retval);
1446 1447
		fsnotify_access(in.file);
		fsnotify_modify(out.file);
1448 1449 1450 1451 1452
		out.file->f_pos = out_pos;
		if (ppos)
			*ppos = pos;
		else
			in.file->f_pos = pos;
L
Linus Torvalds 已提交
1453 1454
	}

1455 1456
	inc_syscr(current);
	inc_syscw(current);
1457
	if (pos > max)
L
Linus Torvalds 已提交
1458 1459 1460
		retval = -EOVERFLOW;

fput_out:
1461
	fdput(out);
L
Linus Torvalds 已提交
1462
fput_in:
1463
	fdput(in);
L
Linus Torvalds 已提交
1464 1465 1466 1467
out:
	return retval;
}

1468
SYSCALL_DEFINE4(sendfile, int, out_fd, int, in_fd, off_t __user *, offset, size_t, count)
L
Linus Torvalds 已提交
1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486
{
	loff_t pos;
	off_t off;
	ssize_t ret;

	if (offset) {
		if (unlikely(get_user(off, offset)))
			return -EFAULT;
		pos = off;
		ret = do_sendfile(out_fd, in_fd, &pos, count, MAX_NON_LFS);
		if (unlikely(put_user(pos, offset)))
			return -EFAULT;
		return ret;
	}

	return do_sendfile(out_fd, in_fd, NULL, count, 0);
}

1487
SYSCALL_DEFINE4(sendfile64, int, out_fd, int, in_fd, loff_t __user *, offset, size_t, count)
L
Linus Torvalds 已提交
1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502
{
	loff_t pos;
	ssize_t ret;

	if (offset) {
		if (unlikely(copy_from_user(&pos, offset, sizeof(loff_t))))
			return -EFAULT;
		ret = do_sendfile(out_fd, in_fd, &pos, count, 0);
		if (unlikely(put_user(pos, offset)))
			return -EFAULT;
		return ret;
	}

	return do_sendfile(out_fd, in_fd, NULL, count, 0);
}
1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542

#ifdef CONFIG_COMPAT
COMPAT_SYSCALL_DEFINE4(sendfile, int, out_fd, int, in_fd,
		compat_off_t __user *, offset, compat_size_t, count)
{
	loff_t pos;
	off_t off;
	ssize_t ret;

	if (offset) {
		if (unlikely(get_user(off, offset)))
			return -EFAULT;
		pos = off;
		ret = do_sendfile(out_fd, in_fd, &pos, count, MAX_NON_LFS);
		if (unlikely(put_user(pos, offset)))
			return -EFAULT;
		return ret;
	}

	return do_sendfile(out_fd, in_fd, NULL, count, 0);
}

COMPAT_SYSCALL_DEFINE4(sendfile64, int, out_fd, int, in_fd,
		compat_loff_t __user *, offset, compat_size_t, count)
{
	loff_t pos;
	ssize_t ret;

	if (offset) {
		if (unlikely(copy_from_user(&pos, offset, sizeof(loff_t))))
			return -EFAULT;
		ret = do_sendfile(out_fd, in_fd, &pos, count, 0);
		if (unlikely(put_user(pos, offset)))
			return -EFAULT;
		return ret;
	}

	return do_sendfile(out_fd, in_fd, NULL, count, 0);
}
#endif
1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559

/*
 * copy_file_range() differs from regular file read and write in that it
 * specifically allows return partial success.  When it does so is up to
 * the copy_file_range method.
 */
ssize_t vfs_copy_file_range(struct file *file_in, loff_t pos_in,
			    struct file *file_out, loff_t pos_out,
			    size_t len, unsigned int flags)
{
	struct inode *inode_in = file_inode(file_in);
	struct inode *inode_out = file_inode(file_out);
	ssize_t ret;

	if (flags != 0)
		return -EINVAL;

1560 1561 1562 1563 1564
	if (S_ISDIR(inode_in->i_mode) || S_ISDIR(inode_out->i_mode))
		return -EISDIR;
	if (!S_ISREG(inode_in->i_mode) || !S_ISREG(inode_out->i_mode))
		return -EINVAL;

1565
	ret = rw_verify_area(READ, file_in, &pos_in, len);
1566 1567 1568 1569 1570
	if (unlikely(ret))
		return ret;

	ret = rw_verify_area(WRITE, file_out, &pos_out, len);
	if (unlikely(ret))
1571 1572 1573 1574
		return ret;

	if (!(file_in->f_mode & FMODE_READ) ||
	    !(file_out->f_mode & FMODE_WRITE) ||
1575
	    (file_out->f_flags & O_APPEND))
1576 1577 1578 1579 1580 1581 1582 1583 1584
		return -EBADF;

	/* this could be relaxed once a method supports cross-fs copies */
	if (inode_in->i_sb != inode_out->i_sb)
		return -EXDEV;

	if (len == 0)
		return 0;

1585
	file_start_write(file_out);
1586

1587 1588 1589 1590
	/*
	 * Try cloning first, this is supported by more file systems, and
	 * more efficient if both clone and copy are supported (e.g. NFS).
	 */
1591
	if (file_in->f_op->remap_file_range) {
1592 1593 1594 1595
		loff_t cloned;

		cloned = file_in->f_op->remap_file_range(file_in, pos_in,
				file_out, pos_out,
1596 1597
				min_t(loff_t, MAX_RW_COUNT, len),
				REMAP_FILE_CAN_SHORTEN);
1598 1599
		if (cloned > 0) {
			ret = cloned;
1600 1601 1602 1603 1604
			goto done;
		}
	}

	if (file_out->f_op->copy_file_range) {
1605 1606
		ret = file_out->f_op->copy_file_range(file_in, pos_in, file_out,
						      pos_out, len, flags);
1607 1608 1609
		if (ret != -EOPNOTSUPP)
			goto done;
	}
1610

1611 1612
	ret = do_splice_direct(file_in, &pos_in, file_out, &pos_out,
			len > MAX_RW_COUNT ? MAX_RW_COUNT : len, 0);
1613

1614
done:
1615 1616 1617 1618 1619 1620
	if (ret > 0) {
		fsnotify_access(file_in);
		add_rchar(current, ret);
		fsnotify_modify(file_out);
		add_wchar(current, ret);
	}
1621

1622 1623 1624
	inc_syscr(current);
	inc_syscw(current);

1625
	file_end_write(file_out);
1626 1627 1628 1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658 1659 1660 1661 1662 1663 1664 1665 1666 1667 1668 1669 1670 1671 1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 1689 1690 1691

	return ret;
}
EXPORT_SYMBOL(vfs_copy_file_range);

SYSCALL_DEFINE6(copy_file_range, int, fd_in, loff_t __user *, off_in,
		int, fd_out, loff_t __user *, off_out,
		size_t, len, unsigned int, flags)
{
	loff_t pos_in;
	loff_t pos_out;
	struct fd f_in;
	struct fd f_out;
	ssize_t ret = -EBADF;

	f_in = fdget(fd_in);
	if (!f_in.file)
		goto out2;

	f_out = fdget(fd_out);
	if (!f_out.file)
		goto out1;

	ret = -EFAULT;
	if (off_in) {
		if (copy_from_user(&pos_in, off_in, sizeof(loff_t)))
			goto out;
	} else {
		pos_in = f_in.file->f_pos;
	}

	if (off_out) {
		if (copy_from_user(&pos_out, off_out, sizeof(loff_t)))
			goto out;
	} else {
		pos_out = f_out.file->f_pos;
	}

	ret = vfs_copy_file_range(f_in.file, pos_in, f_out.file, pos_out, len,
				  flags);
	if (ret > 0) {
		pos_in += ret;
		pos_out += ret;

		if (off_in) {
			if (copy_to_user(off_in, &pos_in, sizeof(loff_t)))
				ret = -EFAULT;
		} else {
			f_in.file->f_pos = pos_in;
		}

		if (off_out) {
			if (copy_to_user(off_out, &pos_out, sizeof(loff_t)))
				ret = -EFAULT;
		} else {
			f_out.file->f_pos = pos_out;
		}
	}

out:
	fdput(f_out);
out1:
	fdput(f_in);
out2:
	return ret;
}
1692

1693 1694
static int remap_verify_area(struct file *file, loff_t pos, loff_t len,
			     bool write)
1695 1696 1697
{
	struct inode *inode = file_inode(file);

1698
	if (unlikely(pos < 0 || len < 0))
1699 1700 1701 1702 1703 1704 1705 1706 1707 1708 1709 1710 1711 1712 1713 1714 1715
		return -EINVAL;

	 if (unlikely((loff_t) (pos + len) < 0))
		return -EINVAL;

	if (unlikely(inode->i_flctx && mandatory_lock(inode))) {
		loff_t end = len ? pos + len - 1 : OFFSET_MAX;
		int retval;

		retval = locks_mandatory_area(inode, file, pos, end,
				write ? F_WRLCK : F_RDLCK);
		if (retval < 0)
			return retval;
	}

	return security_file_permission(file, write ? MAY_WRITE : MAY_READ);
}
1716 1717 1718 1719 1720 1721 1722 1723 1724
/*
 * Ensure that we don't remap a partial EOF block in the middle of something
 * else.  Assume that the offsets have already been checked for block
 * alignment.
 *
 * For deduplication we always scale down to the previous block because we
 * can't meaningfully compare post-EOF contents.
 *
 * For clone we only link a partial EOF block above the destination file's EOF.
1725 1726
 *
 * Shorten the request if possible.
1727 1728 1729 1730
 */
static int generic_remap_check_len(struct inode *inode_in,
				   struct inode *inode_out,
				   loff_t pos_out,
1731
				   loff_t *len,
1732
				   unsigned int remap_flags)
1733 1734
{
	u64 blkmask = i_blocksize(inode_in) - 1;
1735
	loff_t new_len = *len;
1736 1737 1738 1739

	if ((*len & blkmask) == 0)
		return 0;

1740 1741 1742
	if ((remap_flags & REMAP_FILE_DEDUP) ||
	    pos_out + *len < i_size_read(inode_out))
		new_len &= ~blkmask;
1743

1744 1745 1746 1747 1748 1749 1750 1751 1752
	if (new_len == *len)
		return 0;

	if (remap_flags & REMAP_FILE_CAN_SHORTEN) {
		*len = new_len;
		return 0;
	}

	return (remap_flags & REMAP_FILE_DEDUP) ? -EBADE : -EINVAL;
1753
}
1754

1755 1756 1757 1758 1759 1760 1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798 1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845
/*
 * Read a page's worth of file data into the page cache.  Return the page
 * locked.
 */
static struct page *vfs_dedupe_get_page(struct inode *inode, loff_t offset)
{
	struct page *page;

	page = read_mapping_page(inode->i_mapping, offset >> PAGE_SHIFT, NULL);
	if (IS_ERR(page))
		return page;
	if (!PageUptodate(page)) {
		put_page(page);
		return ERR_PTR(-EIO);
	}
	lock_page(page);
	return page;
}

/*
 * Compare extents of two files to see if they are the same.
 * Caller must have locked both inodes to prevent write races.
 */
static int vfs_dedupe_file_range_compare(struct inode *src, loff_t srcoff,
					 struct inode *dest, loff_t destoff,
					 loff_t len, bool *is_same)
{
	loff_t src_poff;
	loff_t dest_poff;
	void *src_addr;
	void *dest_addr;
	struct page *src_page;
	struct page *dest_page;
	loff_t cmp_len;
	bool same;
	int error;

	error = -EINVAL;
	same = true;
	while (len) {
		src_poff = srcoff & (PAGE_SIZE - 1);
		dest_poff = destoff & (PAGE_SIZE - 1);
		cmp_len = min(PAGE_SIZE - src_poff,
			      PAGE_SIZE - dest_poff);
		cmp_len = min(cmp_len, len);
		if (cmp_len <= 0)
			goto out_error;

		src_page = vfs_dedupe_get_page(src, srcoff);
		if (IS_ERR(src_page)) {
			error = PTR_ERR(src_page);
			goto out_error;
		}
		dest_page = vfs_dedupe_get_page(dest, destoff);
		if (IS_ERR(dest_page)) {
			error = PTR_ERR(dest_page);
			unlock_page(src_page);
			put_page(src_page);
			goto out_error;
		}
		src_addr = kmap_atomic(src_page);
		dest_addr = kmap_atomic(dest_page);

		flush_dcache_page(src_page);
		flush_dcache_page(dest_page);

		if (memcmp(src_addr + src_poff, dest_addr + dest_poff, cmp_len))
			same = false;

		kunmap_atomic(dest_addr);
		kunmap_atomic(src_addr);
		unlock_page(dest_page);
		unlock_page(src_page);
		put_page(dest_page);
		put_page(src_page);

		if (!same)
			break;

		srcoff += cmp_len;
		destoff += cmp_len;
		len -= cmp_len;
	}

	*is_same = same;
	return 0;

out_error:
	return error;
}

1846 1847 1848 1849
/*
 * Check that the two inodes are eligible for cloning, the ranges make
 * sense, and then flush all dirty data.  Caller must ensure that the
 * inodes have been locked against any other modifications.
1850 1851 1852
 *
 * Returns: 0 for "nothing to clone", 1 for "something to clone", or
 * the usual negative error code.
1853
 */
1854 1855
int generic_remap_file_range_prep(struct file *file_in, loff_t pos_in,
				  struct file *file_out, loff_t pos_out,
1856
				  loff_t *len, unsigned int remap_flags)
1857
{
1858 1859
	struct inode *inode_in = file_inode(file_in);
	struct inode *inode_out = file_inode(file_out);
1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873 1874 1875 1876 1877
	bool same_inode = (inode_in == inode_out);
	int ret;

	/* Don't touch certain kinds of inodes */
	if (IS_IMMUTABLE(inode_out))
		return -EPERM;

	if (IS_SWAPFILE(inode_in) || IS_SWAPFILE(inode_out))
		return -ETXTBSY;

	/* Don't reflink dirs, pipes, sockets... */
	if (S_ISDIR(inode_in->i_mode) || S_ISDIR(inode_out->i_mode))
		return -EISDIR;
	if (!S_ISREG(inode_in->i_mode) || !S_ISREG(inode_out->i_mode))
		return -EINVAL;

	/* Zero length dedupe exits immediately; reflink goes to EOF. */
	if (*len == 0) {
1878 1879
		loff_t isize = i_size_read(inode_in);

1880
		if ((remap_flags & REMAP_FILE_DEDUP) || pos_in == isize)
1881
			return 0;
1882 1883
		if (pos_in > isize)
			return -EINVAL;
1884
		*len = isize - pos_in;
1885 1886
		if (*len == 0)
			return 0;
1887 1888
	}

1889 1890
	/* Check that we don't violate system file offset limits. */
	ret = generic_remap_checks(file_in, pos_in, file_out, pos_out, len,
1891
			remap_flags);
1892 1893
	if (ret)
		return ret;
1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912

	/* Wait for the completion of any pending IOs on both files */
	inode_dio_wait(inode_in);
	if (!same_inode)
		inode_dio_wait(inode_out);

	ret = filemap_write_and_wait_range(inode_in->i_mapping,
			pos_in, pos_in + *len - 1);
	if (ret)
		return ret;

	ret = filemap_write_and_wait_range(inode_out->i_mapping,
			pos_out, pos_out + *len - 1);
	if (ret)
		return ret;

	/*
	 * Check that the extents are the same.
	 */
1913
	if (remap_flags & REMAP_FILE_DEDUP) {
1914 1915 1916 1917 1918 1919 1920 1921 1922 1923
		bool		is_same = false;

		ret = vfs_dedupe_file_range_compare(inode_in, pos_in,
				inode_out, pos_out, *len, &is_same);
		if (ret)
			return ret;
		if (!is_same)
			return -EBADE;
	}

1924
	ret = generic_remap_check_len(inode_in, inode_out, pos_out, len,
1925
			remap_flags);
1926 1927 1928
	if (ret)
		return ret;

1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942 1943 1944 1945 1946 1947
	/* If can't alter the file contents, we're done. */
	if (!(remap_flags & REMAP_FILE_DEDUP)) {
		/* Update the timestamps, since we can alter file contents. */
		if (!(file_out->f_mode & FMODE_NOCMTIME)) {
			ret = file_update_time(file_out);
			if (ret)
				return ret;
		}

		/*
		 * Clear the security bits if the process is not being run by
		 * root.  This keeps people from modifying setuid and setgid
		 * binaries.
		 */
		ret = file_remove_privs(file_out);
		if (ret)
			return ret;
	}

1948
	return 1;
1949
}
1950
EXPORT_SYMBOL(generic_remap_file_range_prep);
1951

1952
loff_t do_clone_file_range(struct file *file_in, loff_t pos_in,
1953 1954
			   struct file *file_out, loff_t pos_out,
			   loff_t len, unsigned int remap_flags)
1955 1956 1957
{
	struct inode *inode_in = file_inode(file_in);
	struct inode *inode_out = file_inode(file_out);
1958
	loff_t ret;
1959

1960 1961
	WARN_ON_ONCE(remap_flags);

1962 1963 1964 1965 1966
	if (S_ISDIR(inode_in->i_mode) || S_ISDIR(inode_out->i_mode))
		return -EISDIR;
	if (!S_ISREG(inode_in->i_mode) || !S_ISREG(inode_out->i_mode))
		return -EINVAL;

1967 1968 1969 1970 1971 1972
	/*
	 * FICLONE/FICLONERANGE ioctls enforce that src and dest files are on
	 * the same mount. Practically, they only need to be on the same file
	 * system.
	 */
	if (inode_in->i_sb != inode_out->i_sb)
1973 1974 1975 1976
		return -EXDEV;

	if (!(file_in->f_mode & FMODE_READ) ||
	    !(file_out->f_mode & FMODE_WRITE) ||
1977
	    (file_out->f_flags & O_APPEND))
1978 1979
		return -EBADF;

1980
	if (!file_in->f_op->remap_file_range)
1981 1982
		return -EOPNOTSUPP;

1983
	ret = remap_verify_area(file_in, pos_in, len, false);
1984 1985 1986
	if (ret)
		return ret;

1987
	ret = remap_verify_area(file_out, pos_out, len, true);
1988 1989 1990
	if (ret)
		return ret;

1991
	ret = file_in->f_op->remap_file_range(file_in, pos_in,
1992
			file_out, pos_out, len, remap_flags);
1993 1994
	if (ret < 0)
		return ret;
1995

1996 1997
	fsnotify_access(file_in);
	fsnotify_modify(file_out);
1998 1999
	return ret;
}
2000 2001
EXPORT_SYMBOL(do_clone_file_range);

2002
loff_t vfs_clone_file_range(struct file *file_in, loff_t pos_in,
2003 2004
			    struct file *file_out, loff_t pos_out,
			    loff_t len, unsigned int remap_flags)
2005
{
2006
	loff_t ret;
2007 2008

	file_start_write(file_out);
2009 2010
	ret = do_clone_file_range(file_in, pos_in, file_out, pos_out, len,
				  remap_flags);
2011 2012 2013 2014
	file_end_write(file_out);

	return ret;
}
2015
EXPORT_SYMBOL(vfs_clone_file_range);
2016

2017 2018
loff_t vfs_dedupe_file_range_one(struct file *src_file, loff_t src_pos,
				 struct file *dst_file, loff_t dst_pos,
2019
				 loff_t len, unsigned int remap_flags)
2020
{
2021
	loff_t ret;
2022

2023 2024
	WARN_ON_ONCE(remap_flags & ~(REMAP_FILE_DEDUP |
				     REMAP_FILE_CAN_SHORTEN));
2025

2026 2027 2028 2029
	ret = mnt_want_write_file(dst_file);
	if (ret)
		return ret;

2030
	ret = remap_verify_area(dst_file, dst_pos, len, true);
2031 2032 2033 2034 2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046
	if (ret < 0)
		goto out_drop_write;

	ret = -EINVAL;
	if (!(capable(CAP_SYS_ADMIN) || (dst_file->f_mode & FMODE_WRITE)))
		goto out_drop_write;

	ret = -EXDEV;
	if (src_file->f_path.mnt != dst_file->f_path.mnt)
		goto out_drop_write;

	ret = -EISDIR;
	if (S_ISDIR(file_inode(dst_file)->i_mode))
		goto out_drop_write;

	ret = -EINVAL;
2047
	if (!dst_file->f_op->remap_file_range)
2048 2049
		goto out_drop_write;

2050 2051 2052 2053 2054
	if (len == 0) {
		ret = 0;
		goto out_drop_write;
	}

2055
	ret = dst_file->f_op->remap_file_range(src_file, src_pos, dst_file,
2056
			dst_pos, len, remap_flags | REMAP_FILE_DEDUP);
2057 2058 2059 2060 2061
out_drop_write:
	mnt_drop_write_file(dst_file);

	return ret;
}
2062
EXPORT_SYMBOL(vfs_dedupe_file_range_one);
2063

2064 2065 2066 2067 2068 2069 2070 2071 2072
int vfs_dedupe_file_range(struct file *file, struct file_dedupe_range *same)
{
	struct file_dedupe_range_info *info;
	struct inode *src = file_inode(file);
	u64 off;
	u64 len;
	int i;
	int ret;
	u16 count = same->dest_count;
2073
	loff_t deduped;
2074 2075 2076 2077 2078 2079 2080 2081 2082 2083 2084 2085 2086 2087 2088 2089 2090 2091

	if (!(file->f_mode & FMODE_READ))
		return -EINVAL;

	if (same->reserved1 || same->reserved2)
		return -EINVAL;

	off = same->src_offset;
	len = same->src_length;

	ret = -EISDIR;
	if (S_ISDIR(src->i_mode))
		goto out;

	ret = -EINVAL;
	if (!S_ISREG(src->i_mode))
		goto out;

2092
	ret = remap_verify_area(file, off, len, false);
2093 2094 2095 2096
	if (ret < 0)
		goto out;
	ret = 0;

2097 2098 2099
	if (off + len > i_size_read(src))
		return -EINVAL;

M
Miklos Szeredi 已提交
2100 2101 2102
	/* Arbitrary 1G limit on a single dedupe request, can be raised. */
	len = min_t(u64, len, 1 << 30);

2103 2104 2105 2106 2107 2108 2109 2110
	/* pre-format output fields to sane values */
	for (i = 0; i < count; i++) {
		same->info[i].bytes_deduped = 0ULL;
		same->info[i].status = FILE_DEDUPE_RANGE_SAME;
	}

	for (i = 0, info = same->info; i < count; i++, info++) {
		struct fd dst_fd = fdget(info->dest_fd);
2111
		struct file *dst_file = dst_fd.file;
2112 2113 2114 2115 2116 2117 2118 2119

		if (!dst_file) {
			info->status = -EBADF;
			goto next_loop;
		}

		if (info->reserved) {
			info->status = -EINVAL;
2120
			goto next_fdput;
2121 2122
		}

2123
		deduped = vfs_dedupe_file_range_one(file, off, dst_file,
2124
						    info->dest_offset, len,
2125
						    REMAP_FILE_CAN_SHORTEN);
2126 2127 2128 2129 2130 2131 2132
		if (deduped == -EBADE)
			info->status = FILE_DEDUPE_RANGE_DIFFERS;
		else if (deduped < 0)
			info->status = deduped;
		else
			info->bytes_deduped = len;

2133
next_fdput:
2134
		fdput(dst_fd);
2135
next_loop:
2136 2137
		if (fatal_signal_pending(current))
			goto out;
2138 2139 2140 2141 2142 2143
	}

out:
	return ret;
}
EXPORT_SYMBOL(vfs_dedupe_file_range);