read_write.c 27.8 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6 7 8 9 10 11
/*
 *  linux/fs/read_write.c
 *
 *  Copyright (C) 1991, 1992  Linus Torvalds
 */

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

#include <asm/uaccess.h>
#include <asm/unistd.h>

A
Al Viro 已提交
25 26 27 28
typedef ssize_t (*io_fn_t)(struct file *, char __user *, size_t, loff_t *);
typedef ssize_t (*iov_fn_t)(struct kiocb *, const struct iovec *,
		unsigned long, loff_t);

29
const struct file_operations generic_ro_fops = {
L
Linus Torvalds 已提交
30
	.llseek		= generic_file_llseek,
31 32
	.read		= do_sync_read,
	.aio_read	= generic_file_aio_read,
L
Linus Torvalds 已提交
33
	.mmap		= generic_file_readonly_mmap,
34
	.splice_read	= generic_file_splice_read,
L
Linus Torvalds 已提交
35 36 37 38
};

EXPORT_SYMBOL(generic_ro_fops);

39
static inline int unsigned_offsets(struct file *file)
40
{
41
	return file->f_mode & FMODE_UNSIGNED_OFFSET;
42 43
}

J
Jie Liu 已提交
44 45 46 47 48 49 50 51 52 53 54 55 56
/**
 * 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)
57 58 59 60 61 62 63 64 65 66 67 68
{
	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 已提交
69
EXPORT_SYMBOL(vfs_setpos);
70

71
/**
A
Andi Kleen 已提交
72
 * generic_file_llseek_size - generic llseek implementation for regular files
73 74
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
75
 * @whence:	type of seek
76 77
 * @size:	max size of this file in file system
 * @eof:	offset used for SEEK_END position
78
 *
A
Andi Kleen 已提交
79
 * This is a variant of generic_file_llseek that allows passing in a custom
80
 * maximum file size and a custom EOF position, for e.g. hashed directories
81 82
 *
 * Synchronization:
A
Andi Kleen 已提交
83
 * SEEK_SET and SEEK_END are unsynchronized (but atomic on 64bit platforms)
84 85
 * SEEK_CUR is synchronized against other SEEK_CURs, but not read/writes.
 * read/writes behave like SEEK_SET against seeks.
86
 */
A
Andi Kleen 已提交
87
loff_t
88
generic_file_llseek_size(struct file *file, loff_t offset, int whence,
89
		loff_t maxsize, loff_t eof)
L
Linus Torvalds 已提交
90
{
91
	switch (whence) {
92
	case SEEK_END:
93
		offset += eof;
94 95
		break;
	case SEEK_CUR:
96 97 98 99 100 101 102 103
		/*
		 * 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;
104 105 106 107 108 109
		/*
		 * 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 已提交
110
		offset = vfs_setpos(file, file->f_pos + offset, maxsize);
111 112
		spin_unlock(&file->f_lock);
		return offset;
113 114 115 116 117
	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.
		 */
118
		if (offset >= eof)
119 120 121 122 123 124 125
			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.
		 */
126
		if (offset >= eof)
127
			return -ENXIO;
128
		offset = eof;
129
		break;
L
Linus Torvalds 已提交
130
	}
131

J
Jie Liu 已提交
132
	return vfs_setpos(file, offset, maxsize);
A
Andi Kleen 已提交
133 134 135 136 137 138 139
}
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
140
 * @whence:	type of seek
A
Andi Kleen 已提交
141 142 143
 *
 * This is a generic implemenation of ->llseek useable for all normal local
 * filesystems.  It just updates the file offset to the value specified by
144
 * @offset and @whence.
A
Andi Kleen 已提交
145
 */
146
loff_t generic_file_llseek(struct file *file, loff_t offset, int whence)
A
Andi Kleen 已提交
147 148 149
{
	struct inode *inode = file->f_mapping->host;

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

A
Al Viro 已提交
156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175
/**
 * 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);

J
jan Blunck 已提交
176 177 178 179
/**
 * noop_llseek - No Operation Performed llseek implementation
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
180
 * @whence:	type of seek
J
jan Blunck 已提交
181 182 183 184 185 186
 *
 * 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.
 */
187
loff_t noop_llseek(struct file *file, loff_t offset, int whence)
J
jan Blunck 已提交
188 189 190 191 192
{
	return file->f_pos;
}
EXPORT_SYMBOL(noop_llseek);

193
loff_t no_llseek(struct file *file, loff_t offset, int whence)
L
Linus Torvalds 已提交
194 195 196 197 198
{
	return -ESPIPE;
}
EXPORT_SYMBOL(no_llseek);

199
loff_t default_llseek(struct file *file, loff_t offset, int whence)
L
Linus Torvalds 已提交
200
{
A
Al Viro 已提交
201
	struct inode *inode = file_inode(file);
202
	loff_t retval;
L
Linus Torvalds 已提交
203

204
	mutex_lock(&inode->i_mutex);
205
	switch (whence) {
206
		case SEEK_END:
207
			offset += i_size_read(inode);
L
Linus Torvalds 已提交
208
			break;
209
		case SEEK_CUR:
210 211 212 213
			if (offset == 0) {
				retval = file->f_pos;
				goto out;
			}
L
Linus Torvalds 已提交
214
			offset += file->f_pos;
215 216 217 218 219 220 221
			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.
			 */
222 223 224 225
			if (offset >= inode->i_size) {
				retval = -ENXIO;
				goto out;
			}
226 227 228 229 230 231 232
			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.
			 */
233 234 235 236
			if (offset >= inode->i_size) {
				retval = -ENXIO;
				goto out;
			}
237 238
			offset = inode->i_size;
			break;
L
Linus Torvalds 已提交
239 240
	}
	retval = -EINVAL;
241
	if (offset >= 0 || unsigned_offsets(file)) {
L
Linus Torvalds 已提交
242 243 244 245 246 247
		if (offset != file->f_pos) {
			file->f_pos = offset;
			file->f_version = 0;
		}
		retval = offset;
	}
248
out:
249
	mutex_unlock(&inode->i_mutex);
L
Linus Torvalds 已提交
250 251 252 253
	return retval;
}
EXPORT_SYMBOL(default_llseek);

254
loff_t vfs_llseek(struct file *file, loff_t offset, int whence)
L
Linus Torvalds 已提交
255 256 257 258 259
{
	loff_t (*fn)(struct file *, loff_t, int);

	fn = no_llseek;
	if (file->f_mode & FMODE_LSEEK) {
A
Al Viro 已提交
260
		if (file->f_op->llseek)
L
Linus Torvalds 已提交
261 262
			fn = file->f_op->llseek;
	}
263
	return fn(file, offset, whence);
L
Linus Torvalds 已提交
264 265 266
}
EXPORT_SYMBOL(vfs_llseek);

267
SYSCALL_DEFINE3(lseek, unsigned int, fd, off_t, offset, unsigned int, whence)
L
Linus Torvalds 已提交
268 269
{
	off_t retval;
270 271 272
	struct fd f = fdget(fd);
	if (!f.file)
		return -EBADF;
L
Linus Torvalds 已提交
273 274

	retval = -EINVAL;
275 276
	if (whence <= SEEK_MAX) {
		loff_t res = vfs_llseek(f.file, offset, whence);
L
Linus Torvalds 已提交
277 278 279 280
		retval = res;
		if (res != (loff_t)retval)
			retval = -EOVERFLOW;	/* LFS: should only happen on 32 bit platforms */
	}
281
	fdput(f);
L
Linus Torvalds 已提交
282 283 284
	return retval;
}

A
Al Viro 已提交
285 286 287 288 289 290 291
#ifdef CONFIG_COMPAT
COMPAT_SYSCALL_DEFINE3(lseek, unsigned int, fd, compat_off_t, offset, unsigned int, whence)
{
	return sys_lseek(fd, offset, whence);
}
#endif

L
Linus Torvalds 已提交
292
#ifdef __ARCH_WANT_SYS_LLSEEK
293 294
SYSCALL_DEFINE5(llseek, unsigned int, fd, unsigned long, offset_high,
		unsigned long, offset_low, loff_t __user *, result,
295
		unsigned int, whence)
L
Linus Torvalds 已提交
296 297
{
	int retval;
298
	struct fd f = fdget(fd);
L
Linus Torvalds 已提交
299 300
	loff_t offset;

301 302
	if (!f.file)
		return -EBADF;
L
Linus Torvalds 已提交
303 304

	retval = -EINVAL;
305
	if (whence > SEEK_MAX)
L
Linus Torvalds 已提交
306 307
		goto out_putf;

308
	offset = vfs_llseek(f.file, ((loff_t) offset_high << 32) | offset_low,
309
			whence);
L
Linus Torvalds 已提交
310 311 312 313 314 315 316 317

	retval = (int)offset;
	if (offset >= 0) {
		retval = -EFAULT;
		if (!copy_to_user(result, &offset, sizeof(offset)))
			retval = 0;
	}
out_putf:
318
	fdput(f);
L
Linus Torvalds 已提交
319 320 321 322
	return retval;
}
#endif

323 324 325 326 327
/*
 * rw_verify_area doesn't like huge counts. We limit
 * them to something that fits in "int" so that others
 * won't have to do range checks all the time.
 */
A
Al Viro 已提交
328
int rw_verify_area(int read_write, struct file *file, const loff_t *ppos, size_t count)
L
Linus Torvalds 已提交
329 330 331
{
	struct inode *inode;
	loff_t pos;
332
	int retval = -EINVAL;
L
Linus Torvalds 已提交
333

A
Al Viro 已提交
334
	inode = file_inode(file);
335
	if (unlikely((ssize_t) count < 0))
336
		return retval;
L
Linus Torvalds 已提交
337
	pos = *ppos;
338 339 340 341 342 343 344
	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))
345 346
			return retval;
	}
L
Linus Torvalds 已提交
347

348
	if (unlikely(inode->i_flock && mandatory_lock(inode))) {
349
		retval = locks_mandatory_area(
350 351 352 353 354
			read_write == READ ? FLOCK_VERIFY_READ : FLOCK_VERIFY_WRITE,
			inode, file, pos, count);
		if (retval < 0)
			return retval;
	}
355 356 357 358
	retval = security_file_permission(file,
				read_write == READ ? MAY_READ : MAY_WRITE);
	if (retval)
		return retval;
359
	return count > MAX_RW_COUNT ? MAX_RW_COUNT : count;
L
Linus Torvalds 已提交
360 361 362 363
}

ssize_t do_sync_read(struct file *filp, char __user *buf, size_t len, loff_t *ppos)
{
364
	struct iovec iov = { .iov_base = buf, .iov_len = len };
L
Linus Torvalds 已提交
365 366 367 368 369
	struct kiocb kiocb;
	ssize_t ret;

	init_sync_kiocb(&kiocb, filp);
	kiocb.ki_pos = *ppos;
370
	kiocb.ki_nbytes = len;
371

Z
Zach Brown 已提交
372
	ret = filp->f_op->aio_read(&kiocb, &iov, 1, kiocb.ki_pos);
L
Linus Torvalds 已提交
373 374 375 376 377 378 379 380 381 382 383 384 385 386
	if (-EIOCBQUEUED == ret)
		ret = wait_on_sync_kiocb(&kiocb);
	*ppos = kiocb.ki_pos;
	return ret;
}

EXPORT_SYMBOL(do_sync_read);

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;
A
Al Viro 已提交
387
	if (!file->f_op->read && !file->f_op->aio_read)
L
Linus Torvalds 已提交
388 389 390 391 392
		return -EINVAL;
	if (unlikely(!access_ok(VERIFY_WRITE, buf, count)))
		return -EFAULT;

	ret = rw_verify_area(READ, file, pos, count);
393 394
	if (ret >= 0) {
		count = ret;
395 396 397 398 399
		if (file->f_op->read)
			ret = file->f_op->read(file, buf, count, pos);
		else
			ret = do_sync_read(file, buf, count, pos);
		if (ret > 0) {
400
			fsnotify_access(file);
401
			add_rchar(current, ret);
L
Linus Torvalds 已提交
402
		}
403
		inc_syscr(current);
L
Linus Torvalds 已提交
404 405 406 407 408 409 410 411 412
	}

	return ret;
}

EXPORT_SYMBOL(vfs_read);

ssize_t do_sync_write(struct file *filp, const char __user *buf, size_t len, loff_t *ppos)
{
413
	struct iovec iov = { .iov_base = (void __user *)buf, .iov_len = len };
L
Linus Torvalds 已提交
414 415 416 417 418
	struct kiocb kiocb;
	ssize_t ret;

	init_sync_kiocb(&kiocb, filp);
	kiocb.ki_pos = *ppos;
419
	kiocb.ki_nbytes = len;
420

Z
Zach Brown 已提交
421
	ret = filp->f_op->aio_write(&kiocb, &iov, 1, kiocb.ki_pos);
L
Linus Torvalds 已提交
422 423 424 425 426 427 428 429
	if (-EIOCBQUEUED == ret)
		ret = wait_on_sync_kiocb(&kiocb);
	*ppos = kiocb.ki_pos;
	return ret;
}

EXPORT_SYMBOL(do_sync_write);

430 431 432 433 434 435
ssize_t __kernel_write(struct file *file, const char *buf, size_t count, loff_t *pos)
{
	mm_segment_t old_fs;
	const char __user *p;
	ssize_t ret;

A
Al Viro 已提交
436
	if (!file->f_op->write && !file->f_op->aio_write)
437 438
		return -EINVAL;

439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456
	old_fs = get_fs();
	set_fs(get_ds());
	p = (__force const char __user *)buf;
	if (count > MAX_RW_COUNT)
		count =  MAX_RW_COUNT;
	if (file->f_op->write)
		ret = file->f_op->write(file, p, count, pos);
	else
		ret = do_sync_write(file, p, count, pos);
	set_fs(old_fs);
	if (ret > 0) {
		fsnotify_modify(file);
		add_wchar(current, ret);
	}
	inc_syscw(current);
	return ret;
}

L
Linus Torvalds 已提交
457 458 459 460 461 462
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;
A
Al Viro 已提交
463
	if (!file->f_op->write && !file->f_op->aio_write)
L
Linus Torvalds 已提交
464 465 466 467 468
		return -EINVAL;
	if (unlikely(!access_ok(VERIFY_READ, buf, count)))
		return -EFAULT;

	ret = rw_verify_area(WRITE, file, pos, count);
469 470
	if (ret >= 0) {
		count = ret;
A
Al Viro 已提交
471
		file_start_write(file);
472 473 474 475 476
		if (file->f_op->write)
			ret = file->f_op->write(file, buf, count, pos);
		else
			ret = do_sync_write(file, buf, count, pos);
		if (ret > 0) {
477
			fsnotify_modify(file);
478
			add_wchar(current, ret);
L
Linus Torvalds 已提交
479
		}
480
		inc_syscw(current);
A
Al Viro 已提交
481
		file_end_write(file);
L
Linus Torvalds 已提交
482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498
	}

	return ret;
}

EXPORT_SYMBOL(vfs_write);

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;
}

499
SYSCALL_DEFINE3(read, unsigned int, fd, char __user *, buf, size_t, count)
L
Linus Torvalds 已提交
500
{
501
	struct fd f = fdget(fd);
L
Linus Torvalds 已提交
502 503
	ssize_t ret = -EBADF;

504 505 506
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
		ret = vfs_read(f.file, buf, count, &pos);
507 508
		if (ret >= 0)
			file_pos_write(f.file, pos);
509
		fdput(f);
L
Linus Torvalds 已提交
510 511 512 513
	}
	return ret;
}

514 515
SYSCALL_DEFINE3(write, unsigned int, fd, const char __user *, buf,
		size_t, count)
L
Linus Torvalds 已提交
516
{
517
	struct fd f = fdget(fd);
L
Linus Torvalds 已提交
518 519
	ssize_t ret = -EBADF;

520 521 522
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
		ret = vfs_write(f.file, buf, count, &pos);
523 524
		if (ret >= 0)
			file_pos_write(f.file, pos);
525
		fdput(f);
L
Linus Torvalds 已提交
526 527 528 529 530
	}

	return ret;
}

531 532
SYSCALL_DEFINE4(pread64, unsigned int, fd, char __user *, buf,
			size_t, count, loff_t, pos)
L
Linus Torvalds 已提交
533
{
534
	struct fd f;
L
Linus Torvalds 已提交
535 536 537 538 539
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

540 541
	f = fdget(fd);
	if (f.file) {
L
Linus Torvalds 已提交
542
		ret = -ESPIPE;
543 544 545
		if (f.file->f_mode & FMODE_PREAD)
			ret = vfs_read(f.file, buf, count, &pos);
		fdput(f);
L
Linus Torvalds 已提交
546 547 548 549 550
	}

	return ret;
}

551 552
SYSCALL_DEFINE4(pwrite64, unsigned int, fd, const char __user *, buf,
			 size_t, count, loff_t, pos)
L
Linus Torvalds 已提交
553
{
554
	struct fd f;
L
Linus Torvalds 已提交
555 556 557 558 559
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

560 561
	f = fdget(fd);
	if (f.file) {
L
Linus Torvalds 已提交
562
		ret = -ESPIPE;
563 564 565
		if (f.file->f_mode & FMODE_PWRITE)  
			ret = vfs_write(f.file, buf, count, &pos);
		fdput(f);
L
Linus Torvalds 已提交
566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589
	}

	return ret;
}

/*
 * Reduce an iovec's length in-place.  Return the resulting number of segments
 */
unsigned long iov_shorten(struct iovec *iov, unsigned long nr_segs, size_t to)
{
	unsigned long seg = 0;
	size_t len = 0;

	while (seg < nr_segs) {
		seg++;
		if (len + iov->iov_len >= to) {
			iov->iov_len = to - len;
			break;
		}
		len += iov->iov_len;
		iov++;
	}
	return seg;
}
590
EXPORT_SYMBOL(iov_shorten);
L
Linus Torvalds 已提交
591

592
static ssize_t do_sync_readv_writev(struct file *filp, const struct iovec *iov,
593 594 595 596 597 598 599 600 601
		unsigned long nr_segs, size_t len, loff_t *ppos, iov_fn_t fn)
{
	struct kiocb kiocb;
	ssize_t ret;

	init_sync_kiocb(&kiocb, filp);
	kiocb.ki_pos = *ppos;
	kiocb.ki_nbytes = len;

Z
Zach Brown 已提交
602
	ret = fn(&kiocb, iov, nr_segs, kiocb.ki_pos);
603 604 605 606 607 608 609
	if (ret == -EIOCBQUEUED)
		ret = wait_on_sync_kiocb(&kiocb);
	*ppos = kiocb.ki_pos;
	return ret;
}

/* Do it by hand, with file-ops */
610
static ssize_t do_loop_readv_writev(struct file *filp, struct iovec *iov,
611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640
		unsigned long nr_segs, loff_t *ppos, io_fn_t fn)
{
	struct iovec *vector = iov;
	ssize_t ret = 0;

	while (nr_segs > 0) {
		void __user *base;
		size_t len;
		ssize_t nr;

		base = vector->iov_base;
		len = vector->iov_len;
		vector++;
		nr_segs--;

		nr = fn(filp, base, len, ppos);

		if (nr < 0) {
			if (!ret)
				ret = nr;
			break;
		}
		ret += nr;
		if (nr != len)
			break;
	}

	return ret;
}

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

B
Badari Pulavarty 已提交
644 645 646
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,
647
			      struct iovec **ret_pointer)
648
{
B
Badari Pulavarty 已提交
649
	unsigned long seg;
650
	ssize_t ret;
B
Badari Pulavarty 已提交
651 652
	struct iovec *iov = fast_pointer;

653 654 655 656 657
	/*
	 * 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 已提交
658 659
	if (nr_segs == 0) {
		ret = 0;
660
		goto out;
B
Badari Pulavarty 已提交
661 662
	}

663 664 665 666
	/*
	 * First get the "struct iovec" from user memory and
	 * verify all the pointers
	 */
B
Badari Pulavarty 已提交
667 668
	if (nr_segs > UIO_MAXIOV) {
		ret = -EINVAL;
669
		goto out;
B
Badari Pulavarty 已提交
670 671
	}
	if (nr_segs > fast_segs) {
672
		iov = kmalloc(nr_segs*sizeof(struct iovec), GFP_KERNEL);
B
Badari Pulavarty 已提交
673 674
		if (iov == NULL) {
			ret = -ENOMEM;
675
			goto out;
B
Badari Pulavarty 已提交
676
		}
677
	}
B
Badari Pulavarty 已提交
678 679
	if (copy_from_user(iov, uvector, nr_segs*sizeof(*uvector))) {
		ret = -EFAULT;
680
		goto out;
B
Badari Pulavarty 已提交
681 682
	}

683
	/*
B
Badari Pulavarty 已提交
684 685 686 687
	 * 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.
688 689 690 691
	 *
	 * Linux caps all read/write calls to MAX_RW_COUNT, and avoids the
	 * overflow case.
	 */
B
Badari Pulavarty 已提交
692
	ret = 0;
693 694 695
	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 已提交
696 697 698

		/* see if we we're about to use an invalid len or if
		 * it's about to overflow ssize_t */
699
		if (len < 0) {
B
Badari Pulavarty 已提交
700
			ret = -EINVAL;
701
			goto out;
B
Badari Pulavarty 已提交
702
		}
703
		if (type >= 0
C
Christopher Yeoh 已提交
704
		    && unlikely(!access_ok(vrfy_dir(type), buf, len))) {
B
Badari Pulavarty 已提交
705
			ret = -EFAULT;
706 707 708 709 710
			goto out;
		}
		if (len > MAX_RW_COUNT - ret) {
			len = MAX_RW_COUNT - ret;
			iov[seg].iov_len = len;
B
Badari Pulavarty 已提交
711 712
		}
		ret += len;
713
	}
B
Badari Pulavarty 已提交
714 715 716 717 718
out:
	*ret_pointer = iov;
	return ret;
}

L
Linus Torvalds 已提交
719 720 721 722 723 724
static ssize_t do_readv_writev(int type, struct file *file,
			       const struct iovec __user * uvector,
			       unsigned long nr_segs, loff_t *pos)
{
	size_t tot_len;
	struct iovec iovstack[UIO_FASTIOV];
725
	struct iovec *iov = iovstack;
L
Linus Torvalds 已提交
726 727 728 729
	ssize_t ret;
	io_fn_t fn;
	iov_fn_t fnv;

B
Badari Pulavarty 已提交
730
	ret = rw_copy_check_uvector(type, uvector, nr_segs,
731
				    ARRAY_SIZE(iovstack), iovstack, &iov);
B
Badari Pulavarty 已提交
732
	if (ret <= 0)
L
Linus Torvalds 已提交
733 734
		goto out;

B
Badari Pulavarty 已提交
735
	tot_len = ret;
L
Linus Torvalds 已提交
736
	ret = rw_verify_area(type, file, pos, tot_len);
737
	if (ret < 0)
738
		goto out;
L
Linus Torvalds 已提交
739 740 741 742

	fnv = NULL;
	if (type == READ) {
		fn = file->f_op->read;
743
		fnv = file->f_op->aio_read;
L
Linus Torvalds 已提交
744 745
	} else {
		fn = (io_fn_t)file->f_op->write;
746
		fnv = file->f_op->aio_write;
A
Al Viro 已提交
747
		file_start_write(file);
L
Linus Torvalds 已提交
748 749
	}

750 751 752 753 754
	if (fnv)
		ret = do_sync_readv_writev(file, iov, nr_segs, tot_len,
						pos, fnv);
	else
		ret = do_loop_readv_writev(file, iov, nr_segs, pos, fn);
L
Linus Torvalds 已提交
755

A
Al Viro 已提交
756 757 758
	if (type != READ)
		file_end_write(file);

L
Linus Torvalds 已提交
759 760 761
out:
	if (iov != iovstack)
		kfree(iov);
R
Robert Love 已提交
762 763
	if ((ret + (type == READ)) > 0) {
		if (type == READ)
764
			fsnotify_access(file);
R
Robert Love 已提交
765
		else
766
			fsnotify_modify(file);
R
Robert Love 已提交
767
	}
L
Linus Torvalds 已提交
768 769 770 771 772 773 774 775
	return ret;
}

ssize_t vfs_readv(struct file *file, const struct iovec __user *vec,
		  unsigned long vlen, loff_t *pos)
{
	if (!(file->f_mode & FMODE_READ))
		return -EBADF;
A
Al Viro 已提交
776
	if (!file->f_op->aio_read && !file->f_op->read)
L
Linus Torvalds 已提交
777 778 779 780 781 782 783 784 785 786 787 788
		return -EINVAL;

	return do_readv_writev(READ, file, vec, vlen, pos);
}

EXPORT_SYMBOL(vfs_readv);

ssize_t vfs_writev(struct file *file, const struct iovec __user *vec,
		   unsigned long vlen, loff_t *pos)
{
	if (!(file->f_mode & FMODE_WRITE))
		return -EBADF;
A
Al Viro 已提交
789
	if (!file->f_op->aio_write && !file->f_op->write)
L
Linus Torvalds 已提交
790 791 792 793 794 795 796
		return -EINVAL;

	return do_readv_writev(WRITE, file, vec, vlen, pos);
}

EXPORT_SYMBOL(vfs_writev);

797 798
SYSCALL_DEFINE3(readv, unsigned long, fd, const struct iovec __user *, vec,
		unsigned long, vlen)
L
Linus Torvalds 已提交
799
{
800
	struct fd f = fdget(fd);
L
Linus Torvalds 已提交
801 802
	ssize_t ret = -EBADF;

803 804 805
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
		ret = vfs_readv(f.file, vec, vlen, &pos);
806 807
		if (ret >= 0)
			file_pos_write(f.file, pos);
808
		fdput(f);
L
Linus Torvalds 已提交
809 810 811
	}

	if (ret > 0)
812 813
		add_rchar(current, ret);
	inc_syscr(current);
L
Linus Torvalds 已提交
814 815 816
	return ret;
}

817 818
SYSCALL_DEFINE3(writev, unsigned long, fd, const struct iovec __user *, vec,
		unsigned long, vlen)
L
Linus Torvalds 已提交
819
{
820
	struct fd f = fdget(fd);
L
Linus Torvalds 已提交
821 822
	ssize_t ret = -EBADF;

823 824 825
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
		ret = vfs_writev(f.file, vec, vlen, &pos);
826 827
		if (ret >= 0)
			file_pos_write(f.file, pos);
828
		fdput(f);
L
Linus Torvalds 已提交
829 830 831
	}

	if (ret > 0)
832 833
		add_wchar(current, ret);
	inc_syscw(current);
L
Linus Torvalds 已提交
834 835 836
	return ret;
}

837 838 839 840 841 842
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;
}

843
SYSCALL_DEFINE5(preadv, unsigned long, fd, const struct iovec __user *, vec,
844
		unsigned long, vlen, unsigned long, pos_l, unsigned long, pos_h)
845
{
846
	loff_t pos = pos_from_hilo(pos_h, pos_l);
847
	struct fd f;
848 849 850 851 852
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

853 854
	f = fdget(fd);
	if (f.file) {
855
		ret = -ESPIPE;
856 857 858
		if (f.file->f_mode & FMODE_PREAD)
			ret = vfs_readv(f.file, vec, vlen, &pos);
		fdput(f);
859 860 861 862 863 864 865 866 867
	}

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

SYSCALL_DEFINE5(pwritev, unsigned long, fd, const struct iovec __user *, vec,
868
		unsigned long, vlen, unsigned long, pos_l, unsigned long, pos_h)
869
{
870
	loff_t pos = pos_from_hilo(pos_h, pos_l);
871
	struct fd f;
872 873 874 875 876
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

877 878
	f = fdget(fd);
	if (f.file) {
879
		ret = -ESPIPE;
880 881 882
		if (f.file->f_mode & FMODE_PWRITE)
			ret = vfs_writev(f.file, vec, vlen, &pos);
		fdput(f);
883 884 885 886 887 888 889 890
	}

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

891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920
#ifdef CONFIG_COMPAT

static ssize_t compat_do_readv_writev(int type, struct file *file,
			       const struct compat_iovec __user *uvector,
			       unsigned long nr_segs, loff_t *pos)
{
	compat_ssize_t tot_len;
	struct iovec iovstack[UIO_FASTIOV];
	struct iovec *iov = iovstack;
	ssize_t ret;
	io_fn_t fn;
	iov_fn_t fnv;

	ret = compat_rw_copy_check_uvector(type, uvector, nr_segs,
					       UIO_FASTIOV, iovstack, &iov);
	if (ret <= 0)
		goto out;

	tot_len = ret;
	ret = rw_verify_area(type, file, pos, tot_len);
	if (ret < 0)
		goto out;

	fnv = NULL;
	if (type == READ) {
		fn = file->f_op->read;
		fnv = file->f_op->aio_read;
	} else {
		fn = (io_fn_t)file->f_op->write;
		fnv = file->f_op->aio_write;
A
Al Viro 已提交
921
		file_start_write(file);
922 923
	}

A
Al Viro 已提交
924
	if (fnv)
925 926
		ret = do_sync_readv_writev(file, iov, nr_segs, tot_len,
						pos, fnv);
A
Al Viro 已提交
927
	else
928 929
		ret = do_loop_readv_writev(file, iov, nr_segs, pos, fn);

A
Al Viro 已提交
930 931 932
	if (type != READ)
		file_end_write(file);

933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954
out:
	if (iov != iovstack)
		kfree(iov);
	if ((ret + (type == READ)) > 0) {
		if (type == READ)
			fsnotify_access(file);
		else
			fsnotify_modify(file);
	}
	return ret;
}

static size_t compat_readv(struct file *file,
			   const struct compat_iovec __user *vec,
			   unsigned long vlen, loff_t *pos)
{
	ssize_t ret = -EBADF;

	if (!(file->f_mode & FMODE_READ))
		goto out;

	ret = -EINVAL;
A
Al Viro 已提交
955
	if (!file->f_op->aio_read && !file->f_op->read)
956 957 958 959 960 961 962 963 964 965 966
		goto out;

	ret = compat_do_readv_writev(READ, file, vec, vlen, pos);

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

967
COMPAT_SYSCALL_DEFINE3(readv, compat_ulong_t, fd,
968
		const struct compat_iovec __user *,vec,
969
		compat_ulong_t, vlen)
970 971 972 973 974 975 976 977 978
{
	struct fd f = fdget(fd);
	ssize_t ret;
	loff_t pos;

	if (!f.file)
		return -EBADF;
	pos = f.file->f_pos;
	ret = compat_readv(f.file, vec, vlen, &pos);
979 980
	if (ret >= 0)
		f.file->f_pos = pos;
981 982 983 984
	fdput(f);
	return ret;
}

985 986 987
static long __compat_sys_preadv64(unsigned long fd,
				  const struct compat_iovec __user *vec,
				  unsigned long vlen, loff_t pos)
988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003
{
	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)
		ret = compat_readv(f.file, vec, vlen, &pos);
	fdput(f);
	return ret;
}

1004 1005 1006 1007 1008 1009 1010 1011 1012
#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)
{
	return __compat_sys_preadv64(fd, vec, vlen, pos);
}
#endif

1013
COMPAT_SYSCALL_DEFINE5(preadv, compat_ulong_t, fd,
1014
		const struct compat_iovec __user *,vec,
1015
		compat_ulong_t, vlen, u32, pos_low, u32, pos_high)
1016 1017
{
	loff_t pos = ((loff_t)pos_high << 32) | pos_low;
1018 1019

	return __compat_sys_preadv64(fd, vec, vlen, pos);
1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031
}

static size_t compat_writev(struct file *file,
			    const struct compat_iovec __user *vec,
			    unsigned long vlen, loff_t *pos)
{
	ssize_t ret = -EBADF;

	if (!(file->f_mode & FMODE_WRITE))
		goto out;

	ret = -EINVAL;
A
Al Viro 已提交
1032
	if (!file->f_op->aio_write && !file->f_op->write)
1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043
		goto out;

	ret = compat_do_readv_writev(WRITE, file, vec, vlen, pos);

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

1044
COMPAT_SYSCALL_DEFINE3(writev, compat_ulong_t, fd,
1045
		const struct compat_iovec __user *, vec,
1046
		compat_ulong_t, vlen)
1047 1048 1049 1050 1051 1052 1053 1054 1055
{
	struct fd f = fdget(fd);
	ssize_t ret;
	loff_t pos;

	if (!f.file)
		return -EBADF;
	pos = f.file->f_pos;
	ret = compat_writev(f.file, vec, vlen, &pos);
1056 1057
	if (ret >= 0)
		f.file->f_pos = pos;
1058 1059 1060 1061
	fdput(f);
	return ret;
}

1062 1063 1064
static long __compat_sys_pwritev64(unsigned long fd,
				   const struct compat_iovec __user *vec,
				   unsigned long vlen, loff_t pos)
1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080
{
	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)
		ret = compat_writev(f.file, vec, vlen, &pos);
	fdput(f);
	return ret;
}

1081 1082 1083 1084 1085 1086 1087 1088 1089
#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)
{
	return __compat_sys_pwritev64(fd, vec, vlen, pos);
}
#endif

1090
COMPAT_SYSCALL_DEFINE5(pwritev, compat_ulong_t, fd,
1091
		const struct compat_iovec __user *,vec,
1092
		compat_ulong_t, vlen, u32, pos_low, u32, pos_high)
1093 1094
{
	loff_t pos = ((loff_t)pos_high << 32) | pos_low;
1095 1096

	return __compat_sys_pwritev64(fd, vec, vlen, pos);
1097 1098 1099
}
#endif

1100 1101
static ssize_t do_sendfile(int out_fd, int in_fd, loff_t *ppos,
		  	   size_t count, loff_t max)
L
Linus Torvalds 已提交
1102
{
1103 1104
	struct fd in, out;
	struct inode *in_inode, *out_inode;
L
Linus Torvalds 已提交
1105
	loff_t pos;
1106
	loff_t out_pos;
L
Linus Torvalds 已提交
1107
	ssize_t retval;
1108
	int fl;
L
Linus Torvalds 已提交
1109 1110 1111 1112 1113

	/*
	 * Get input file, and verify that it is ok..
	 */
	retval = -EBADF;
1114 1115
	in = fdget(in_fd);
	if (!in.file)
L
Linus Torvalds 已提交
1116
		goto out;
1117
	if (!(in.file->f_mode & FMODE_READ))
L
Linus Torvalds 已提交
1118 1119
		goto fput_in;
	retval = -ESPIPE;
1120 1121 1122 1123
	if (!ppos) {
		pos = in.file->f_pos;
	} else {
		pos = *ppos;
1124
		if (!(in.file->f_mode & FMODE_PREAD))
L
Linus Torvalds 已提交
1125
			goto fput_in;
1126 1127
	}
	retval = rw_verify_area(READ, in.file, &pos, count);
1128
	if (retval < 0)
L
Linus Torvalds 已提交
1129
		goto fput_in;
1130
	count = retval;
L
Linus Torvalds 已提交
1131 1132 1133 1134 1135

	/*
	 * Get output file, and verify that it is ok..
	 */
	retval = -EBADF;
1136 1137
	out = fdget(out_fd);
	if (!out.file)
L
Linus Torvalds 已提交
1138
		goto fput_in;
1139
	if (!(out.file->f_mode & FMODE_WRITE))
L
Linus Torvalds 已提交
1140 1141
		goto fput_out;
	retval = -EINVAL;
A
Al Viro 已提交
1142 1143
	in_inode = file_inode(in.file);
	out_inode = file_inode(out.file);
1144 1145
	out_pos = out.file->f_pos;
	retval = rw_verify_area(WRITE, out.file, &out_pos, count);
1146
	if (retval < 0)
L
Linus Torvalds 已提交
1147
		goto fput_out;
1148
	count = retval;
L
Linus Torvalds 已提交
1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159

	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 已提交
1160
	fl = 0;
1161
#if 0
J
Jens Axboe 已提交
1162 1163 1164 1165 1166 1167
	/*
	 * 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.
	 */
1168
	if (in.file->f_flags & O_NONBLOCK)
J
Jens Axboe 已提交
1169
		fl = SPLICE_F_NONBLOCK;
1170
#endif
1171
	file_start_write(out.file);
1172
	retval = do_splice_direct(in.file, &pos, out.file, &out_pos, count, fl);
1173
	file_end_write(out.file);
L
Linus Torvalds 已提交
1174 1175

	if (retval > 0) {
1176 1177
		add_rchar(current, retval);
		add_wchar(current, retval);
1178 1179
		fsnotify_access(in.file);
		fsnotify_modify(out.file);
1180 1181 1182 1183 1184
		out.file->f_pos = out_pos;
		if (ppos)
			*ppos = pos;
		else
			in.file->f_pos = pos;
L
Linus Torvalds 已提交
1185 1186
	}

1187 1188
	inc_syscr(current);
	inc_syscw(current);
1189
	if (pos > max)
L
Linus Torvalds 已提交
1190 1191 1192
		retval = -EOVERFLOW;

fput_out:
1193
	fdput(out);
L
Linus Torvalds 已提交
1194
fput_in:
1195
	fdput(in);
L
Linus Torvalds 已提交
1196 1197 1198 1199
out:
	return retval;
}

1200
SYSCALL_DEFINE4(sendfile, int, out_fd, int, in_fd, off_t __user *, offset, size_t, count)
L
Linus Torvalds 已提交
1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218
{
	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);
}

1219
SYSCALL_DEFINE4(sendfile64, int, out_fd, int, in_fd, loff_t __user *, offset, size_t, count)
L
Linus Torvalds 已提交
1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234
{
	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);
}
1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274

#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