read_write.c 27.4 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
}

44 45 46 47 48 49 50 51 52 53 54 55 56 57 58
static loff_t lseek_execute(struct file *file, struct inode *inode,
		loff_t offset, loff_t maxsize)
{
	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;
}

59
/**
A
Andi Kleen 已提交
60
 * generic_file_llseek_size - generic llseek implementation for regular files
61 62
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
63
 * @whence:	type of seek
64 65
 * @size:	max size of this file in file system
 * @eof:	offset used for SEEK_END position
66
 *
A
Andi Kleen 已提交
67
 * This is a variant of generic_file_llseek that allows passing in a custom
68
 * maximum file size and a custom EOF position, for e.g. hashed directories
69 70
 *
 * Synchronization:
A
Andi Kleen 已提交
71
 * SEEK_SET and SEEK_END are unsynchronized (but atomic on 64bit platforms)
72 73
 * SEEK_CUR is synchronized against other SEEK_CURs, but not read/writes.
 * read/writes behave like SEEK_SET against seeks.
74
 */
A
Andi Kleen 已提交
75
loff_t
76
generic_file_llseek_size(struct file *file, loff_t offset, int whence,
77
		loff_t maxsize, loff_t eof)
L
Linus Torvalds 已提交
78 79 80
{
	struct inode *inode = file->f_mapping->host;

81
	switch (whence) {
82
	case SEEK_END:
83
		offset += eof;
84 85
		break;
	case SEEK_CUR:
86 87 88 89 90 91 92 93
		/*
		 * 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;
94 95 96 97 98 99 100
		/*
		 * 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);
		offset = lseek_execute(file, inode, file->f_pos + offset,
A
Andi Kleen 已提交
101
				       maxsize);
102 103
		spin_unlock(&file->f_lock);
		return offset;
104 105 106 107 108
	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.
		 */
109
		if (offset >= eof)
110 111 112 113 114 115 116
			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.
		 */
117
		if (offset >= eof)
118
			return -ENXIO;
119
		offset = eof;
120
		break;
L
Linus Torvalds 已提交
121
	}
122

A
Andi Kleen 已提交
123 124 125 126 127 128 129 130
	return lseek_execute(file, inode, offset, maxsize);
}
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
131
 * @whence:	type of seek
A
Andi Kleen 已提交
132 133 134
 *
 * This is a generic implemenation of ->llseek useable for all normal local
 * filesystems.  It just updates the file offset to the value specified by
135
 * @offset and @whence.
A
Andi Kleen 已提交
136
 */
137
loff_t generic_file_llseek(struct file *file, loff_t offset, int whence)
A
Andi Kleen 已提交
138 139 140
{
	struct inode *inode = file->f_mapping->host;

141
	return generic_file_llseek_size(file, offset, whence,
142 143
					inode->i_sb->s_maxbytes,
					i_size_read(inode));
L
Linus Torvalds 已提交
144
}
A
Andi Kleen 已提交
145
EXPORT_SYMBOL(generic_file_llseek);
L
Linus Torvalds 已提交
146

A
Al Viro 已提交
147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166
/**
 * 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 已提交
167 168 169 170
/**
 * noop_llseek - No Operation Performed llseek implementation
 * @file:	file structure to seek on
 * @offset:	file offset to seek to
171
 * @whence:	type of seek
J
jan Blunck 已提交
172 173 174 175 176 177
 *
 * 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.
 */
178
loff_t noop_llseek(struct file *file, loff_t offset, int whence)
J
jan Blunck 已提交
179 180 181 182 183
{
	return file->f_pos;
}
EXPORT_SYMBOL(noop_llseek);

184
loff_t no_llseek(struct file *file, loff_t offset, int whence)
L
Linus Torvalds 已提交
185 186 187 188 189
{
	return -ESPIPE;
}
EXPORT_SYMBOL(no_llseek);

190
loff_t default_llseek(struct file *file, loff_t offset, int whence)
L
Linus Torvalds 已提交
191
{
A
Al Viro 已提交
192
	struct inode *inode = file_inode(file);
193
	loff_t retval;
L
Linus Torvalds 已提交
194

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

245
loff_t vfs_llseek(struct file *file, loff_t offset, int whence)
L
Linus Torvalds 已提交
246 247 248 249 250 251 252 253
{
	loff_t (*fn)(struct file *, loff_t, int);

	fn = no_llseek;
	if (file->f_mode & FMODE_LSEEK) {
		if (file->f_op && file->f_op->llseek)
			fn = file->f_op->llseek;
	}
254
	return fn(file, offset, whence);
L
Linus Torvalds 已提交
255 256 257
}
EXPORT_SYMBOL(vfs_llseek);

258
SYSCALL_DEFINE3(lseek, unsigned int, fd, off_t, offset, unsigned int, whence)
L
Linus Torvalds 已提交
259 260
{
	off_t retval;
261 262 263
	struct fd f = fdget(fd);
	if (!f.file)
		return -EBADF;
L
Linus Torvalds 已提交
264 265

	retval = -EINVAL;
266 267
	if (whence <= SEEK_MAX) {
		loff_t res = vfs_llseek(f.file, offset, whence);
L
Linus Torvalds 已提交
268 269 270 271
		retval = res;
		if (res != (loff_t)retval)
			retval = -EOVERFLOW;	/* LFS: should only happen on 32 bit platforms */
	}
272
	fdput(f);
L
Linus Torvalds 已提交
273 274 275
	return retval;
}

A
Al Viro 已提交
276 277 278 279 280 281 282
#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 已提交
283
#ifdef __ARCH_WANT_SYS_LLSEEK
284 285
SYSCALL_DEFINE5(llseek, unsigned int, fd, unsigned long, offset_high,
		unsigned long, offset_low, loff_t __user *, result,
286
		unsigned int, whence)
L
Linus Torvalds 已提交
287 288
{
	int retval;
289
	struct fd f = fdget(fd);
L
Linus Torvalds 已提交
290 291
	loff_t offset;

292 293
	if (!f.file)
		return -EBADF;
L
Linus Torvalds 已提交
294 295

	retval = -EINVAL;
296
	if (whence > SEEK_MAX)
L
Linus Torvalds 已提交
297 298
		goto out_putf;

299
	offset = vfs_llseek(f.file, ((loff_t) offset_high << 32) | offset_low,
300
			whence);
L
Linus Torvalds 已提交
301 302 303 304 305 306 307 308

	retval = (int)offset;
	if (offset >= 0) {
		retval = -EFAULT;
		if (!copy_to_user(result, &offset, sizeof(offset)))
			retval = 0;
	}
out_putf:
309
	fdput(f);
L
Linus Torvalds 已提交
310 311 312 313
	return retval;
}
#endif

314 315 316 317 318
/*
 * 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.
 */
L
Linus Torvalds 已提交
319 320 321 322
int rw_verify_area(int read_write, struct file *file, loff_t *ppos, size_t count)
{
	struct inode *inode;
	loff_t pos;
323
	int retval = -EINVAL;
L
Linus Torvalds 已提交
324

A
Al Viro 已提交
325
	inode = file_inode(file);
326
	if (unlikely((ssize_t) count < 0))
327
		return retval;
L
Linus Torvalds 已提交
328
	pos = *ppos;
329 330 331 332 333 334 335
	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))
336 337
			return retval;
	}
L
Linus Torvalds 已提交
338

339
	if (unlikely(inode->i_flock && mandatory_lock(inode))) {
340
		retval = locks_mandatory_area(
341 342 343 344 345
			read_write == READ ? FLOCK_VERIFY_READ : FLOCK_VERIFY_WRITE,
			inode, file, pos, count);
		if (retval < 0)
			return retval;
	}
346 347 348 349
	retval = security_file_permission(file,
				read_write == READ ? MAY_READ : MAY_WRITE);
	if (retval)
		return retval;
350
	return count > MAX_RW_COUNT ? MAX_RW_COUNT : count;
L
Linus Torvalds 已提交
351 352 353 354
}

ssize_t do_sync_read(struct file *filp, char __user *buf, size_t len, loff_t *ppos)
{
355
	struct iovec iov = { .iov_base = buf, .iov_len = len };
L
Linus Torvalds 已提交
356 357 358 359 360
	struct kiocb kiocb;
	ssize_t ret;

	init_sync_kiocb(&kiocb, filp);
	kiocb.ki_pos = *ppos;
361
	kiocb.ki_left = len;
362
	kiocb.ki_nbytes = len;
363

Z
Zach Brown 已提交
364
	ret = filp->f_op->aio_read(&kiocb, &iov, 1, kiocb.ki_pos);
L
Linus Torvalds 已提交
365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384
	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;
	if (!file->f_op || (!file->f_op->read && !file->f_op->aio_read))
		return -EINVAL;
	if (unlikely(!access_ok(VERIFY_WRITE, buf, count)))
		return -EFAULT;

	ret = rw_verify_area(READ, file, pos, count);
385 386
	if (ret >= 0) {
		count = ret;
387 388 389 390 391
		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) {
392
			fsnotify_access(file);
393
			add_rchar(current, ret);
L
Linus Torvalds 已提交
394
		}
395
		inc_syscr(current);
L
Linus Torvalds 已提交
396 397 398 399 400 401 402 403 404
	}

	return ret;
}

EXPORT_SYMBOL(vfs_read);

ssize_t do_sync_write(struct file *filp, const char __user *buf, size_t len, loff_t *ppos)
{
405
	struct iovec iov = { .iov_base = (void __user *)buf, .iov_len = len };
L
Linus Torvalds 已提交
406 407 408 409 410
	struct kiocb kiocb;
	ssize_t ret;

	init_sync_kiocb(&kiocb, filp);
	kiocb.ki_pos = *ppos;
411
	kiocb.ki_left = len;
412
	kiocb.ki_nbytes = len;
413

Z
Zach Brown 已提交
414
	ret = filp->f_op->aio_write(&kiocb, &iov, 1, kiocb.ki_pos);
L
Linus Torvalds 已提交
415 416 417 418 419 420 421 422
	if (-EIOCBQUEUED == ret)
		ret = wait_on_sync_kiocb(&kiocb);
	*ppos = kiocb.ki_pos;
	return ret;
}

EXPORT_SYMBOL(do_sync_write);

423 424 425 426 427 428
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;

429 430 431
	if (!file->f_op || (!file->f_op->write && !file->f_op->aio_write))
		return -EINVAL;

432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449
	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 已提交
450 451 452 453 454 455 456 457 458 459 460 461
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;
	if (!file->f_op || (!file->f_op->write && !file->f_op->aio_write))
		return -EINVAL;
	if (unlikely(!access_ok(VERIFY_READ, buf, count)))
		return -EFAULT;

	ret = rw_verify_area(WRITE, file, pos, count);
462 463
	if (ret >= 0) {
		count = ret;
A
Al Viro 已提交
464
		file_start_write(file);
465 466 467 468 469
		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) {
470
			fsnotify_modify(file);
471
			add_wchar(current, ret);
L
Linus Torvalds 已提交
472
		}
473
		inc_syscw(current);
A
Al Viro 已提交
474
		file_end_write(file);
L
Linus Torvalds 已提交
475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491
	}

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

492
SYSCALL_DEFINE3(read, unsigned int, fd, char __user *, buf, size_t, count)
L
Linus Torvalds 已提交
493
{
494
	struct fd f = fdget(fd);
L
Linus Torvalds 已提交
495 496
	ssize_t ret = -EBADF;

497 498 499
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
		ret = vfs_read(f.file, buf, count, &pos);
500 501
		if (ret >= 0)
			file_pos_write(f.file, pos);
502
		fdput(f);
L
Linus Torvalds 已提交
503 504 505 506
	}
	return ret;
}

507 508
SYSCALL_DEFINE3(write, unsigned int, fd, const char __user *, buf,
		size_t, count)
L
Linus Torvalds 已提交
509
{
510
	struct fd f = fdget(fd);
L
Linus Torvalds 已提交
511 512
	ssize_t ret = -EBADF;

513 514 515
	if (f.file) {
		loff_t pos = file_pos_read(f.file);
		ret = vfs_write(f.file, buf, count, &pos);
516 517
		if (ret >= 0)
			file_pos_write(f.file, pos);
518
		fdput(f);
L
Linus Torvalds 已提交
519 520 521 522 523
	}

	return ret;
}

524 525
SYSCALL_DEFINE4(pread64, unsigned int, fd, char __user *, buf,
			size_t, count, loff_t, pos)
L
Linus Torvalds 已提交
526
{
527
	struct fd f;
L
Linus Torvalds 已提交
528 529 530 531 532
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

533 534
	f = fdget(fd);
	if (f.file) {
L
Linus Torvalds 已提交
535
		ret = -ESPIPE;
536 537 538
		if (f.file->f_mode & FMODE_PREAD)
			ret = vfs_read(f.file, buf, count, &pos);
		fdput(f);
L
Linus Torvalds 已提交
539 540 541 542 543
	}

	return ret;
}

544 545
SYSCALL_DEFINE4(pwrite64, unsigned int, fd, const char __user *, buf,
			 size_t, count, loff_t, pos)
L
Linus Torvalds 已提交
546
{
547
	struct fd f;
L
Linus Torvalds 已提交
548 549 550 551 552
	ssize_t ret = -EBADF;

	if (pos < 0)
		return -EINVAL;

553 554
	f = fdget(fd);
	if (f.file) {
L
Linus Torvalds 已提交
555
		ret = -ESPIPE;
556 557 558
		if (f.file->f_mode & FMODE_PWRITE)  
			ret = vfs_write(f.file, buf, count, &pos);
		fdput(f);
L
Linus Torvalds 已提交
559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582
	}

	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;
}
583
EXPORT_SYMBOL(iov_shorten);
L
Linus Torvalds 已提交
584

585
static ssize_t do_sync_readv_writev(struct file *filp, const struct iovec *iov,
586 587 588 589 590 591 592 593 594 595
		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_left = len;
	kiocb.ki_nbytes = len;

Z
Zach Brown 已提交
596
	ret = fn(&kiocb, iov, nr_segs, kiocb.ki_pos);
597 598 599 600 601 602 603
	if (ret == -EIOCBQUEUED)
		ret = wait_on_sync_kiocb(&kiocb);
	*ppos = kiocb.ki_pos;
	return ret;
}

/* Do it by hand, with file-ops */
604
static ssize_t do_loop_readv_writev(struct file *filp, struct iovec *iov,
605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634
		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 已提交
635 636 637
/* 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 已提交
638 639 640
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,
641
			      struct iovec **ret_pointer)
642
{
B
Badari Pulavarty 已提交
643
	unsigned long seg;
644
	ssize_t ret;
B
Badari Pulavarty 已提交
645 646
	struct iovec *iov = fast_pointer;

647 648 649 650 651
	/*
	 * 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 已提交
652 653
	if (nr_segs == 0) {
		ret = 0;
654
		goto out;
B
Badari Pulavarty 已提交
655 656
	}

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

677
	/*
B
Badari Pulavarty 已提交
678 679 680 681
	 * 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.
682 683 684 685
	 *
	 * Linux caps all read/write calls to MAX_RW_COUNT, and avoids the
	 * overflow case.
	 */
B
Badari Pulavarty 已提交
686
	ret = 0;
687 688 689
	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 已提交
690 691 692

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

L
Linus Torvalds 已提交
713 714 715 716 717 718
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];
719
	struct iovec *iov = iovstack;
L
Linus Torvalds 已提交
720 721 722 723
	ssize_t ret;
	io_fn_t fn;
	iov_fn_t fnv;

B
Badari Pulavarty 已提交
724 725
	if (!file->f_op) {
		ret = -EINVAL;
L
Linus Torvalds 已提交
726 727 728
		goto out;
	}

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

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

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

749 750 751 752 753
	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 已提交
754

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

L
Linus Torvalds 已提交
758 759 760
out:
	if (iov != iovstack)
		kfree(iov);
R
Robert Love 已提交
761 762
	if ((ret + (type == READ)) > 0) {
		if (type == READ)
763
			fsnotify_access(file);
R
Robert Love 已提交
764
		else
765
			fsnotify_modify(file);
R
Robert Love 已提交
766
	}
L
Linus Torvalds 已提交
767 768 769 770 771 772 773 774
	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;
775
	if (!file->f_op || (!file->f_op->aio_read && !file->f_op->read))
L
Linus Torvalds 已提交
776 777 778 779 780 781 782 783 784 785 786 787
		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;
788
	if (!file->f_op || (!file->f_op->aio_write && !file->f_op->write))
L
Linus Torvalds 已提交
789 790 791 792 793 794 795
		return -EINVAL;

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

EXPORT_SYMBOL(vfs_writev);

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

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

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

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

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

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

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

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

	if (pos < 0)
		return -EINVAL;

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

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

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

	if (pos < 0)
		return -EINVAL;

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

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

890 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 921 922 923 924 925 926 927
#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 = -EINVAL;
	if (!file->f_op)
		goto out;

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

	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 已提交
928
		file_start_write(file);
929 930
	}

A
Al Viro 已提交
931
	if (fnv)
932 933
		ret = do_sync_readv_writev(file, iov, nr_segs, tot_len,
						pos, fnv);
A
Al Viro 已提交
934
	else
935 936
		ret = do_loop_readv_writev(file, iov, nr_segs, pos, fn);

A
Al Viro 已提交
937 938 939
	if (type != READ)
		file_end_write(file);

940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985
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;
	if (!file->f_op || (!file->f_op->aio_read && !file->f_op->read))
		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;
}

COMPAT_SYSCALL_DEFINE3(readv, unsigned long, fd,
		const struct compat_iovec __user *,vec,
		unsigned long, vlen)
{
	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);
986 987
	if (ret >= 0)
		f.file->f_pos = pos;
988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052
	fdput(f);
	return ret;
}

COMPAT_SYSCALL_DEFINE4(preadv64, unsigned long, fd,
		const struct compat_iovec __user *,vec,
		unsigned long, vlen, loff_t, pos)
{
	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;
}

COMPAT_SYSCALL_DEFINE5(preadv, unsigned long, fd,
		const struct compat_iovec __user *,vec,
		unsigned long, vlen, u32, pos_low, u32, pos_high)
{
	loff_t pos = ((loff_t)pos_high << 32) | pos_low;
	return compat_sys_preadv64(fd, vec, vlen, pos);
}

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;
	if (!file->f_op || (!file->f_op->aio_write && !file->f_op->write))
		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;
}

COMPAT_SYSCALL_DEFINE3(writev, unsigned long, fd,
		const struct compat_iovec __user *, vec,
		unsigned long, vlen)
{
	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);
1053 1054
	if (ret >= 0)
		f.file->f_pos = pos;
1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086
	fdput(f);
	return ret;
}

COMPAT_SYSCALL_DEFINE4(pwritev64, unsigned long, fd,
		const struct compat_iovec __user *,vec,
		unsigned long, vlen, loff_t, pos)
{
	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;
}

COMPAT_SYSCALL_DEFINE5(pwritev, unsigned long, fd,
		const struct compat_iovec __user *,vec,
		unsigned long, vlen, u32, pos_low, u32, pos_high)
{
	loff_t pos = ((loff_t)pos_high << 32) | pos_low;
	return compat_sys_pwritev64(fd, vec, vlen, pos);
}
#endif

1087 1088
static ssize_t do_sendfile(int out_fd, int in_fd, loff_t *ppos,
		  	   size_t count, loff_t max)
L
Linus Torvalds 已提交
1089
{
1090 1091
	struct fd in, out;
	struct inode *in_inode, *out_inode;
L
Linus Torvalds 已提交
1092
	loff_t pos;
1093
	loff_t out_pos;
L
Linus Torvalds 已提交
1094
	ssize_t retval;
1095
	int fl;
L
Linus Torvalds 已提交
1096 1097 1098 1099 1100

	/*
	 * Get input file, and verify that it is ok..
	 */
	retval = -EBADF;
1101 1102
	in = fdget(in_fd);
	if (!in.file)
L
Linus Torvalds 已提交
1103
		goto out;
1104
	if (!(in.file->f_mode & FMODE_READ))
L
Linus Torvalds 已提交
1105 1106
		goto fput_in;
	retval = -ESPIPE;
1107 1108 1109 1110
	if (!ppos) {
		pos = in.file->f_pos;
	} else {
		pos = *ppos;
1111
		if (!(in.file->f_mode & FMODE_PREAD))
L
Linus Torvalds 已提交
1112
			goto fput_in;
1113 1114
	}
	retval = rw_verify_area(READ, in.file, &pos, count);
1115
	if (retval < 0)
L
Linus Torvalds 已提交
1116
		goto fput_in;
1117
	count = retval;
L
Linus Torvalds 已提交
1118 1119 1120 1121 1122

	/*
	 * Get output file, and verify that it is ok..
	 */
	retval = -EBADF;
1123 1124
	out = fdget(out_fd);
	if (!out.file)
L
Linus Torvalds 已提交
1125
		goto fput_in;
1126
	if (!(out.file->f_mode & FMODE_WRITE))
L
Linus Torvalds 已提交
1127 1128
		goto fput_out;
	retval = -EINVAL;
A
Al Viro 已提交
1129 1130
	in_inode = file_inode(in.file);
	out_inode = file_inode(out.file);
1131 1132
	out_pos = out.file->f_pos;
	retval = rw_verify_area(WRITE, out.file, &out_pos, count);
1133
	if (retval < 0)
L
Linus Torvalds 已提交
1134
		goto fput_out;
1135
	count = retval;
L
Linus Torvalds 已提交
1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146

	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 已提交
1147
	fl = 0;
1148
#if 0
J
Jens Axboe 已提交
1149 1150 1151 1152 1153 1154
	/*
	 * 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.
	 */
1155
	if (in.file->f_flags & O_NONBLOCK)
J
Jens Axboe 已提交
1156
		fl = SPLICE_F_NONBLOCK;
1157
#endif
1158
	file_start_write(out.file);
1159
	retval = do_splice_direct(in.file, &pos, out.file, &out_pos, count, fl);
1160
	file_end_write(out.file);
L
Linus Torvalds 已提交
1161 1162

	if (retval > 0) {
1163 1164
		add_rchar(current, retval);
		add_wchar(current, retval);
1165 1166
		fsnotify_access(in.file);
		fsnotify_modify(out.file);
1167 1168 1169 1170 1171
		out.file->f_pos = out_pos;
		if (ppos)
			*ppos = pos;
		else
			in.file->f_pos = pos;
L
Linus Torvalds 已提交
1172 1173
	}

1174 1175
	inc_syscr(current);
	inc_syscw(current);
1176
	if (pos > max)
L
Linus Torvalds 已提交
1177 1178 1179
		retval = -EOVERFLOW;

fput_out:
1180
	fdput(out);
L
Linus Torvalds 已提交
1181
fput_in:
1182
	fdput(in);
L
Linus Torvalds 已提交
1183 1184 1185 1186
out:
	return retval;
}

1187
SYSCALL_DEFINE4(sendfile, int, out_fd, int, in_fd, off_t __user *, offset, size_t, count)
L
Linus Torvalds 已提交
1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205
{
	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);
}

1206
SYSCALL_DEFINE4(sendfile64, int, out_fd, int, in_fd, loff_t __user *, offset, size_t, count)
L
Linus Torvalds 已提交
1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221
{
	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);
}
1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 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

#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