Blame view
fs/read_write.c
51.6 KB
b24413180 License cleanup: ... |
1 |
// SPDX-License-Identifier: GPL-2.0 |
1da177e4c Linux-2.6.12-rc2 |
2 3 4 5 6 |
/* * linux/fs/read_write.c * * Copyright (C) 1991, 1992 Linus Torvalds */ |
b12fb7f46 sched/headers: Pr... |
7 |
#include <linux/slab.h> |
1da177e4c Linux-2.6.12-rc2 |
8 |
#include <linux/stat.h> |
b12fb7f46 sched/headers: Pr... |
9 |
#include <linux/sched/xacct.h> |
1da177e4c Linux-2.6.12-rc2 |
10 11 12 |
#include <linux/fcntl.h> #include <linux/file.h> #include <linux/uio.h> |
0eeca2830 [PATCH] inotify |
13 |
#include <linux/fsnotify.h> |
1da177e4c Linux-2.6.12-rc2 |
14 |
#include <linux/security.h> |
630d9c472 fs: reduce the us... |
15 |
#include <linux/export.h> |
1da177e4c Linux-2.6.12-rc2 |
16 |
#include <linux/syscalls.h> |
e28cc7157 Relax the rw_veri... |
17 |
#include <linux/pagemap.h> |
d6b29d7ce splice: divorce t... |
18 |
#include <linux/splice.h> |
561c67319 switch lseek to C... |
19 |
#include <linux/compat.h> |
29732938a vfs: add copy_fil... |
20 |
#include <linux/mount.h> |
2feb55f89 fs: allow no_seek... |
21 |
#include <linux/fs.h> |
06ae43f34 Don't bother with... |
22 |
#include "internal.h" |
1da177e4c Linux-2.6.12-rc2 |
23 |
|
7c0f6ba68 Replace <asm/uacc... |
24 |
#include <linux/uaccess.h> |
1da177e4c Linux-2.6.12-rc2 |
25 |
#include <asm/unistd.h> |
4b6f5d20b [PATCH] Make most... |
26 |
const struct file_operations generic_ro_fops = { |
1da177e4c Linux-2.6.12-rc2 |
27 |
.llseek = generic_file_llseek, |
aad4f8bb4 switch simple gen... |
28 |
.read_iter = generic_file_read_iter, |
1da177e4c Linux-2.6.12-rc2 |
29 |
.mmap = generic_file_readonly_mmap, |
534f2aaa6 sys_sendfile: swi... |
30 |
.splice_read = generic_file_splice_read, |
1da177e4c Linux-2.6.12-rc2 |
31 32 33 |
}; EXPORT_SYMBOL(generic_ro_fops); |
ddef7ed2b annotate RWF_... ... |
34 |
static inline bool unsigned_offsets(struct file *file) |
4a3956c79 vfs: introduce FM... |
35 |
{ |
cccb5a1e6 fix signedness me... |
36 |
return file->f_mode & FMODE_UNSIGNED_OFFSET; |
4a3956c79 vfs: introduce FM... |
37 |
} |
46a1c2c7a vfs: export lseek... |
38 39 40 41 42 43 44 45 46 47 48 49 50 |
/** * 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) |
ef3d0fd27 vfs: do (nearly) ... |
51 52 53 54 55 56 57 58 59 60 61 62 |
{ 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; } |
46a1c2c7a vfs: export lseek... |
63 |
EXPORT_SYMBOL(vfs_setpos); |
ef3d0fd27 vfs: do (nearly) ... |
64 |
|
3a8cff4f0 [PATCH] generic_f... |
65 |
/** |
5760495a8 vfs: add generic_... |
66 |
* generic_file_llseek_size - generic llseek implementation for regular files |
3a8cff4f0 [PATCH] generic_f... |
67 68 |
* @file: file structure to seek on * @offset: file offset to seek to |
965c8e59c lseek: the "whenc... |
69 |
* @whence: type of seek |
e8b96eb50 vfs: allow custom... |
70 71 |
* @size: max size of this file in file system * @eof: offset used for SEEK_END position |
3a8cff4f0 [PATCH] generic_f... |
72 |
* |
5760495a8 vfs: add generic_... |
73 |
* This is a variant of generic_file_llseek that allows passing in a custom |
e8b96eb50 vfs: allow custom... |
74 |
* maximum file size and a custom EOF position, for e.g. hashed directories |
ef3d0fd27 vfs: do (nearly) ... |
75 76 |
* * Synchronization: |
5760495a8 vfs: add generic_... |
77 |
* SEEK_SET and SEEK_END are unsynchronized (but atomic on 64bit platforms) |
ef3d0fd27 vfs: do (nearly) ... |
78 79 |
* SEEK_CUR is synchronized against other SEEK_CURs, but not read/writes. * read/writes behave like SEEK_SET against seeks. |
3a8cff4f0 [PATCH] generic_f... |
80 |
*/ |
9465efc9e Remove BKL from r... |
81 |
loff_t |
965c8e59c lseek: the "whenc... |
82 |
generic_file_llseek_size(struct file *file, loff_t offset, int whence, |
e8b96eb50 vfs: allow custom... |
83 |
loff_t maxsize, loff_t eof) |
1da177e4c Linux-2.6.12-rc2 |
84 |
{ |
965c8e59c lseek: the "whenc... |
85 |
switch (whence) { |
3a8cff4f0 [PATCH] generic_f... |
86 |
case SEEK_END: |
e8b96eb50 vfs: allow custom... |
87 |
offset += eof; |
3a8cff4f0 [PATCH] generic_f... |
88 89 |
break; case SEEK_CUR: |
5b6f1eb97 vfs: lseek(fd, 0,... |
90 91 92 93 94 95 96 97 |
/* * 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; |
ef3d0fd27 vfs: do (nearly) ... |
98 99 100 101 102 103 |
/* * 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); |
46a1c2c7a vfs: export lseek... |
104 |
offset = vfs_setpos(file, file->f_pos + offset, maxsize); |
ef3d0fd27 vfs: do (nearly) ... |
105 106 |
spin_unlock(&file->f_lock); return offset; |
982d81658 fs: add SEEK_HOLE... |
107 108 109 110 111 |
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. */ |
fc46820b2 vfs: Return -ENXI... |
112 |
if ((unsigned long long)offset >= eof) |
982d81658 fs: add SEEK_HOLE... |
113 114 115 116 117 118 119 |
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. */ |
fc46820b2 vfs: Return -ENXI... |
120 |
if ((unsigned long long)offset >= eof) |
982d81658 fs: add SEEK_HOLE... |
121 |
return -ENXIO; |
e8b96eb50 vfs: allow custom... |
122 |
offset = eof; |
982d81658 fs: add SEEK_HOLE... |
123 |
break; |
1da177e4c Linux-2.6.12-rc2 |
124 |
} |
3a8cff4f0 [PATCH] generic_f... |
125 |
|
46a1c2c7a vfs: export lseek... |
126 |
return vfs_setpos(file, offset, maxsize); |
5760495a8 vfs: add generic_... |
127 128 129 130 131 132 133 |
} 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 |
965c8e59c lseek: the "whenc... |
134 |
* @whence: type of seek |
5760495a8 vfs: add generic_... |
135 136 137 |
* * This is a generic implemenation of ->llseek useable for all normal local * filesystems. It just updates the file offset to the value specified by |
546ae2d2f fs/read_write.c: ... |
138 |
* @offset and @whence. |
5760495a8 vfs: add generic_... |
139 |
*/ |
965c8e59c lseek: the "whenc... |
140 |
loff_t generic_file_llseek(struct file *file, loff_t offset, int whence) |
5760495a8 vfs: add generic_... |
141 142 |
{ struct inode *inode = file->f_mapping->host; |
965c8e59c lseek: the "whenc... |
143 |
return generic_file_llseek_size(file, offset, whence, |
e8b96eb50 vfs: allow custom... |
144 145 |
inode->i_sb->s_maxbytes, i_size_read(inode)); |
1da177e4c Linux-2.6.12-rc2 |
146 |
} |
9465efc9e Remove BKL from r... |
147 |
EXPORT_SYMBOL(generic_file_llseek); |
1da177e4c Linux-2.6.12-rc2 |
148 |
|
ae6afc3f5 vfs: introduce no... |
149 |
/** |
1bf9d14df new helper: fixed... |
150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 |
* 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); /** |
b25472f9b new helpers: no_s... |
170 171 172 173 174 175 176 177 178 179 180 |
* 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, |
2feb55f89 fs: allow no_seek... |
181 |
OFFSET_MAX, 0); |
b25472f9b new helpers: no_s... |
182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 |
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); /** |
ae6afc3f5 vfs: introduce no... |
209 210 211 |
* noop_llseek - No Operation Performed llseek implementation * @file: file structure to seek on * @offset: file offset to seek to |
965c8e59c lseek: the "whenc... |
212 |
* @whence: type of seek |
ae6afc3f5 vfs: introduce no... |
213 214 215 216 217 218 |
* * 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. */ |
965c8e59c lseek: the "whenc... |
219 |
loff_t noop_llseek(struct file *file, loff_t offset, int whence) |
ae6afc3f5 vfs: introduce no... |
220 221 222 223 |
{ return file->f_pos; } EXPORT_SYMBOL(noop_llseek); |
965c8e59c lseek: the "whenc... |
224 |
loff_t no_llseek(struct file *file, loff_t offset, int whence) |
1da177e4c Linux-2.6.12-rc2 |
225 226 227 228 |
{ return -ESPIPE; } EXPORT_SYMBOL(no_llseek); |
965c8e59c lseek: the "whenc... |
229 |
loff_t default_llseek(struct file *file, loff_t offset, int whence) |
1da177e4c Linux-2.6.12-rc2 |
230 |
{ |
496ad9aa8 new helper: file_... |
231 |
struct inode *inode = file_inode(file); |
16abef0e9 fs: use loff_t ty... |
232 |
loff_t retval; |
1da177e4c Linux-2.6.12-rc2 |
233 |
|
5955102c9 wrappers for ->i_... |
234 |
inode_lock(inode); |
965c8e59c lseek: the "whenc... |
235 |
switch (whence) { |
7b8e89249 use symbolic cons... |
236 |
case SEEK_END: |
982d81658 fs: add SEEK_HOLE... |
237 |
offset += i_size_read(inode); |
1da177e4c Linux-2.6.12-rc2 |
238 |
break; |
7b8e89249 use symbolic cons... |
239 |
case SEEK_CUR: |
5b6f1eb97 vfs: lseek(fd, 0,... |
240 241 242 243 |
if (offset == 0) { retval = file->f_pos; goto out; } |
1da177e4c Linux-2.6.12-rc2 |
244 |
offset += file->f_pos; |
982d81658 fs: add SEEK_HOLE... |
245 246 247 248 249 250 251 |
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. */ |
bacb2d816 fs: add missing u... |
252 253 254 255 |
if (offset >= inode->i_size) { retval = -ENXIO; goto out; } |
982d81658 fs: add SEEK_HOLE... |
256 257 258 259 260 261 262 |
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. */ |
bacb2d816 fs: add missing u... |
263 264 265 266 |
if (offset >= inode->i_size) { retval = -ENXIO; goto out; } |
982d81658 fs: add SEEK_HOLE... |
267 268 |
offset = inode->i_size; break; |
1da177e4c Linux-2.6.12-rc2 |
269 270 |
} retval = -EINVAL; |
cccb5a1e6 fix signedness me... |
271 |
if (offset >= 0 || unsigned_offsets(file)) { |
1da177e4c Linux-2.6.12-rc2 |
272 273 274 275 276 277 |
if (offset != file->f_pos) { file->f_pos = offset; file->f_version = 0; } retval = offset; } |
5b6f1eb97 vfs: lseek(fd, 0,... |
278 |
out: |
5955102c9 wrappers for ->i_... |
279 |
inode_unlock(inode); |
1da177e4c Linux-2.6.12-rc2 |
280 281 282 |
return retval; } EXPORT_SYMBOL(default_llseek); |
965c8e59c lseek: the "whenc... |
283 |
loff_t vfs_llseek(struct file *file, loff_t offset, int whence) |
1da177e4c Linux-2.6.12-rc2 |
284 285 286 287 288 |
{ loff_t (*fn)(struct file *, loff_t, int); fn = no_llseek; if (file->f_mode & FMODE_LSEEK) { |
72c2d5319 file->f_op is nev... |
289 |
if (file->f_op->llseek) |
1da177e4c Linux-2.6.12-rc2 |
290 291 |
fn = file->f_op->llseek; } |
965c8e59c lseek: the "whenc... |
292 |
return fn(file, offset, whence); |
1da177e4c Linux-2.6.12-rc2 |
293 294 |
} EXPORT_SYMBOL(vfs_llseek); |
76847e434 fs: add ksys_lsee... |
295 |
off_t ksys_lseek(unsigned int fd, off_t offset, unsigned int whence) |
1da177e4c Linux-2.6.12-rc2 |
296 297 |
{ off_t retval; |
9c225f265 vfs: atomic f_pos... |
298 |
struct fd f = fdget_pos(fd); |
2903ff019 switch simple cas... |
299 300 |
if (!f.file) return -EBADF; |
1da177e4c Linux-2.6.12-rc2 |
301 302 |
retval = -EINVAL; |
965c8e59c lseek: the "whenc... |
303 304 |
if (whence <= SEEK_MAX) { loff_t res = vfs_llseek(f.file, offset, whence); |
1da177e4c Linux-2.6.12-rc2 |
305 306 307 308 |
retval = res; if (res != (loff_t)retval) retval = -EOVERFLOW; /* LFS: should only happen on 32 bit platforms */ } |
9c225f265 vfs: atomic f_pos... |
309 |
fdput_pos(f); |
1da177e4c Linux-2.6.12-rc2 |
310 311 |
return retval; } |
76847e434 fs: add ksys_lsee... |
312 313 314 315 |
SYSCALL_DEFINE3(lseek, unsigned int, fd, off_t, offset, unsigned int, whence) { return ksys_lseek(fd, offset, whence); } |
561c67319 switch lseek to C... |
316 317 318 |
#ifdef CONFIG_COMPAT COMPAT_SYSCALL_DEFINE3(lseek, unsigned int, fd, compat_off_t, offset, unsigned int, whence) { |
76847e434 fs: add ksys_lsee... |
319 |
return ksys_lseek(fd, offset, whence); |
561c67319 switch lseek to C... |
320 321 |
} #endif |
caf6f9c8a asm-generic: Remo... |
322 |
#if !defined(CONFIG_64BIT) || defined(CONFIG_COMPAT) |
003d7ab47 [CVE-2009-0029] S... |
323 324 |
SYSCALL_DEFINE5(llseek, unsigned int, fd, unsigned long, offset_high, unsigned long, offset_low, loff_t __user *, result, |
965c8e59c lseek: the "whenc... |
325 |
unsigned int, whence) |
1da177e4c Linux-2.6.12-rc2 |
326 327 |
{ int retval; |
d7a15f8d0 vfs: atomic f_pos... |
328 |
struct fd f = fdget_pos(fd); |
1da177e4c Linux-2.6.12-rc2 |
329 |
loff_t offset; |
1da177e4c Linux-2.6.12-rc2 |
330 |
|
2903ff019 switch simple cas... |
331 332 |
if (!f.file) return -EBADF; |
1da177e4c Linux-2.6.12-rc2 |
333 334 |
retval = -EINVAL; |
965c8e59c lseek: the "whenc... |
335 |
if (whence > SEEK_MAX) |
1da177e4c Linux-2.6.12-rc2 |
336 |
goto out_putf; |
2903ff019 switch simple cas... |
337 |
offset = vfs_llseek(f.file, ((loff_t) offset_high << 32) | offset_low, |
965c8e59c lseek: the "whenc... |
338 |
whence); |
1da177e4c Linux-2.6.12-rc2 |
339 340 341 342 343 344 345 346 |
retval = (int)offset; if (offset >= 0) { retval = -EFAULT; if (!copy_to_user(result, &offset, sizeof(offset))) retval = 0; } out_putf: |
d7a15f8d0 vfs: atomic f_pos... |
347 |
fdput_pos(f); |
1da177e4c Linux-2.6.12-rc2 |
348 349 350 |
return retval; } #endif |
68d70d03f constify rw_verif... |
351 |
int rw_verify_area(int read_write, struct file *file, const loff_t *ppos, size_t count) |
1da177e4c Linux-2.6.12-rc2 |
352 353 |
{ struct inode *inode; |
c43e259cc security: call se... |
354 |
int retval = -EINVAL; |
1da177e4c Linux-2.6.12-rc2 |
355 |
|
496ad9aa8 new helper: file_... |
356 |
inode = file_inode(file); |
e28cc7157 Relax the rw_veri... |
357 |
if (unlikely((ssize_t) count < 0)) |
c43e259cc security: call se... |
358 |
return retval; |
1da177e4c Linux-2.6.12-rc2 |
359 |
|
438ab720c vfs: pass ppos=NU... |
360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 |
/* * ranged mandatory locking does not apply to streams - it makes sense * only for files where position has a meaning. */ if (ppos) { loff_t pos = *ppos; 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)) return retval; } if (unlikely(inode->i_flctx && mandatory_lock(inode))) { retval = locks_mandatory_area(inode, file, pos, pos + count - 1, read_write == READ ? F_RDLCK : F_WRLCK); if (retval < 0) return retval; } |
e28cc7157 Relax the rw_veri... |
383 |
} |
438ab720c vfs: pass ppos=NU... |
384 |
|
bc61384dc rw_verify_area():... |
385 |
return security_file_permission(file, |
c43e259cc security: call se... |
386 |
read_write == READ ? MAY_READ : MAY_WRITE); |
1da177e4c Linux-2.6.12-rc2 |
387 |
} |
5d5d56897 make new_sync_{re... |
388 |
static ssize_t new_sync_read(struct file *filp, char __user *buf, size_t len, loff_t *ppos) |
293bc9822 new methods: ->re... |
389 390 391 392 393 394 395 |
{ struct iovec iov = { .iov_base = buf, .iov_len = len }; struct kiocb kiocb; struct iov_iter iter; ssize_t ret; init_sync_kiocb(&kiocb, filp); |
438ab720c vfs: pass ppos=NU... |
396 |
kiocb.ki_pos = (ppos ? *ppos : 0); |
293bc9822 new methods: ->re... |
397 |
iov_iter_init(&iter, READ, &iov, 1, len); |
bb7462b6f vfs: use helpers ... |
398 |
ret = call_read_iter(filp, &kiocb, &iter); |
599bd19bd fs: don't allow t... |
399 |
BUG_ON(ret == -EIOCBQUEUED); |
438ab720c vfs: pass ppos=NU... |
400 401 |
if (ppos) *ppos = kiocb.ki_pos; |
293bc9822 new methods: ->re... |
402 403 |
return ret; } |
6fb5032eb VFS: refactor vfs... |
404 405 406 |
ssize_t __vfs_read(struct file *file, char __user *buf, size_t count, loff_t *pos) { |
6fb5032eb VFS: refactor vfs... |
407 |
if (file->f_op->read) |
3d04c8a17 export __vfs_read() |
408 |
return file->f_op->read(file, buf, count, pos); |
6fb5032eb VFS: refactor vfs... |
409 |
else if (file->f_op->read_iter) |
3d04c8a17 export __vfs_read() |
410 |
return new_sync_read(file, buf, count, pos); |
6fb5032eb VFS: refactor vfs... |
411 |
else |
3d04c8a17 export __vfs_read() |
412 |
return -EINVAL; |
6fb5032eb VFS: refactor vfs... |
413 |
} |
bdd1d2d3d fs: fix kernel_re... |
414 |
ssize_t kernel_read(struct file *file, void *buf, size_t count, loff_t *pos) |
c41fbad01 fs: move kernel_r... |
415 416 |
{ mm_segment_t old_fs; |
bdd1d2d3d fs: fix kernel_re... |
417 |
ssize_t result; |
c41fbad01 fs: move kernel_r... |
418 419 |
old_fs = get_fs(); |
736706bee get rid of legacy... |
420 |
set_fs(KERNEL_DS); |
c41fbad01 fs: move kernel_r... |
421 |
/* The cast to a user pointer is valid due to the set_fs() */ |
bdd1d2d3d fs: fix kernel_re... |
422 |
result = vfs_read(file, (void __user *)buf, count, pos); |
c41fbad01 fs: move kernel_r... |
423 424 425 426 |
set_fs(old_fs); return result; } EXPORT_SYMBOL(kernel_read); |
6fb5032eb VFS: refactor vfs... |
427 |
|
1da177e4c Linux-2.6.12-rc2 |
428 429 430 431 432 433 |
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; |
7f7f25e82 replace checking ... |
434 |
if (!(file->f_mode & FMODE_CAN_READ)) |
1da177e4c Linux-2.6.12-rc2 |
435 |
return -EINVAL; |
96d4f267e Remove 'type' arg... |
436 |
if (unlikely(!access_ok(buf, count))) |
1da177e4c Linux-2.6.12-rc2 |
437 438 439 |
return -EFAULT; ret = rw_verify_area(READ, file, pos, count); |
bc61384dc rw_verify_area():... |
440 441 442 |
if (!ret) { if (count > MAX_RW_COUNT) count = MAX_RW_COUNT; |
6fb5032eb VFS: refactor vfs... |
443 |
ret = __vfs_read(file, buf, count, pos); |
c43e259cc security: call se... |
444 |
if (ret > 0) { |
2a12a9d78 fsnotify: pass a ... |
445 |
fsnotify_access(file); |
c43e259cc security: call se... |
446 |
add_rchar(current, ret); |
1da177e4c Linux-2.6.12-rc2 |
447 |
} |
c43e259cc security: call se... |
448 |
inc_syscr(current); |
1da177e4c Linux-2.6.12-rc2 |
449 450 451 452 |
} return ret; } |
5d5d56897 make new_sync_{re... |
453 |
static ssize_t new_sync_write(struct file *filp, const char __user *buf, size_t len, loff_t *ppos) |
293bc9822 new methods: ->re... |
454 455 456 457 458 459 460 |
{ 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); |
438ab720c vfs: pass ppos=NU... |
461 |
kiocb.ki_pos = (ppos ? *ppos : 0); |
293bc9822 new methods: ->re... |
462 |
iov_iter_init(&iter, WRITE, &iov, 1, len); |
bb7462b6f vfs: use helpers ... |
463 |
ret = call_write_iter(filp, &kiocb, &iter); |
599bd19bd fs: don't allow t... |
464 |
BUG_ON(ret == -EIOCBQUEUED); |
438ab720c vfs: pass ppos=NU... |
465 |
if (ret > 0 && ppos) |
f765b134c new_sync_write():... |
466 |
*ppos = kiocb.ki_pos; |
293bc9822 new methods: ->re... |
467 468 |
return ret; } |
12e1e7af1 vfs: Make __vfs_w... |
469 470 |
static ssize_t __vfs_write(struct file *file, const char __user *p, size_t count, loff_t *pos) |
493c84c07 new helper: __vfs... |
471 472 473 |
{ if (file->f_op->write) return file->f_op->write(file, p, count, pos); |
493c84c07 new helper: __vfs... |
474 475 476 477 478 |
else if (file->f_op->write_iter) return new_sync_write(file, p, count, pos); else return -EINVAL; } |
493c84c07 new helper: __vfs... |
479 |
|
73e18f7c0 fs: make the buf ... |
480 |
ssize_t __kernel_write(struct file *file, const void *buf, size_t count, loff_t *pos) |
06ae43f34 Don't bother with... |
481 482 483 484 |
{ mm_segment_t old_fs; const char __user *p; ssize_t ret; |
7f7f25e82 replace checking ... |
485 |
if (!(file->f_mode & FMODE_CAN_WRITE)) |
3e84f48ed vfs/splice: Fix m... |
486 |
return -EINVAL; |
06ae43f34 Don't bother with... |
487 |
old_fs = get_fs(); |
736706bee get rid of legacy... |
488 |
set_fs(KERNEL_DS); |
06ae43f34 Don't bother with... |
489 490 491 |
p = (__force const char __user *)buf; if (count > MAX_RW_COUNT) count = MAX_RW_COUNT; |
493c84c07 new helper: __vfs... |
492 |
ret = __vfs_write(file, p, count, pos); |
06ae43f34 Don't bother with... |
493 494 495 496 497 498 499 500 |
set_fs(old_fs); if (ret > 0) { fsnotify_modify(file); add_wchar(current, ret); } inc_syscw(current); return ret; } |
2ec3a12a6 cachefiles_write_... |
501 |
EXPORT_SYMBOL(__kernel_write); |
e13ec939e fs: fix kernel_wr... |
502 503 |
ssize_t kernel_write(struct file *file, const void *buf, size_t count, loff_t *pos) |
ac452acae fs: move kernel_w... |
504 505 506 507 508 |
{ mm_segment_t old_fs; ssize_t res; old_fs = get_fs(); |
736706bee get rid of legacy... |
509 |
set_fs(KERNEL_DS); |
ac452acae fs: move kernel_w... |
510 |
/* The cast to a user pointer is valid due to the set_fs() */ |
e13ec939e fs: fix kernel_wr... |
511 |
res = vfs_write(file, (__force const char __user *)buf, count, pos); |
ac452acae fs: move kernel_w... |
512 513 514 515 516 |
set_fs(old_fs); return res; } EXPORT_SYMBOL(kernel_write); |
1da177e4c Linux-2.6.12-rc2 |
517 518 519 520 521 522 |
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; |
7f7f25e82 replace checking ... |
523 |
if (!(file->f_mode & FMODE_CAN_WRITE)) |
1da177e4c Linux-2.6.12-rc2 |
524 |
return -EINVAL; |
96d4f267e Remove 'type' arg... |
525 |
if (unlikely(!access_ok(buf, count))) |
1da177e4c Linux-2.6.12-rc2 |
526 527 528 |
return -EFAULT; ret = rw_verify_area(WRITE, file, pos, count); |
bc61384dc rw_verify_area():... |
529 530 531 |
if (!ret) { if (count > MAX_RW_COUNT) count = MAX_RW_COUNT; |
03d95eb2f lift sb_start_wri... |
532 |
file_start_write(file); |
493c84c07 new helper: __vfs... |
533 |
ret = __vfs_write(file, buf, count, pos); |
c43e259cc security: call se... |
534 |
if (ret > 0) { |
2a12a9d78 fsnotify: pass a ... |
535 |
fsnotify_modify(file); |
c43e259cc security: call se... |
536 |
add_wchar(current, ret); |
1da177e4c Linux-2.6.12-rc2 |
537 |
} |
c43e259cc security: call se... |
538 |
inc_syscw(current); |
03d95eb2f lift sb_start_wri... |
539 |
file_end_write(file); |
1da177e4c Linux-2.6.12-rc2 |
540 541 542 543 |
} return ret; } |
438ab720c vfs: pass ppos=NU... |
544 545 |
/* file_ppos returns &file->f_pos or NULL if file is stream */ static inline loff_t *file_ppos(struct file *file) |
1da177e4c Linux-2.6.12-rc2 |
546 |
{ |
438ab720c vfs: pass ppos=NU... |
547 |
return file->f_mode & FMODE_STREAM ? NULL : &file->f_pos; |
1da177e4c Linux-2.6.12-rc2 |
548 |
} |
3ce4a7bf6 fs: add ksys_read... |
549 |
ssize_t ksys_read(unsigned int fd, char __user *buf, size_t count) |
1da177e4c Linux-2.6.12-rc2 |
550 |
{ |
9c225f265 vfs: atomic f_pos... |
551 |
struct fd f = fdget_pos(fd); |
1da177e4c Linux-2.6.12-rc2 |
552 |
ssize_t ret = -EBADF; |
1da177e4c Linux-2.6.12-rc2 |
553 |
|
2903ff019 switch simple cas... |
554 |
if (f.file) { |
438ab720c vfs: pass ppos=NU... |
555 556 557 558 559 560 561 562 |
loff_t pos, *ppos = file_ppos(f.file); if (ppos) { pos = *ppos; ppos = &pos; } ret = vfs_read(f.file, buf, count, ppos); if (ret >= 0 && ppos) f.file->f_pos = pos; |
9c225f265 vfs: atomic f_pos... |
563 |
fdput_pos(f); |
1da177e4c Linux-2.6.12-rc2 |
564 |
} |
1da177e4c Linux-2.6.12-rc2 |
565 566 |
return ret; } |
1da177e4c Linux-2.6.12-rc2 |
567 |
|
3ce4a7bf6 fs: add ksys_read... |
568 569 570 571 |
SYSCALL_DEFINE3(read, unsigned int, fd, char __user *, buf, size_t, count) { return ksys_read(fd, buf, count); } |
e7a3e8b2e fs: add ksys_writ... |
572 |
ssize_t ksys_write(unsigned int fd, const char __user *buf, size_t count) |
1da177e4c Linux-2.6.12-rc2 |
573 |
{ |
9c225f265 vfs: atomic f_pos... |
574 |
struct fd f = fdget_pos(fd); |
1da177e4c Linux-2.6.12-rc2 |
575 |
ssize_t ret = -EBADF; |
1da177e4c Linux-2.6.12-rc2 |
576 |
|
2903ff019 switch simple cas... |
577 |
if (f.file) { |
438ab720c vfs: pass ppos=NU... |
578 579 580 581 582 583 584 585 |
loff_t pos, *ppos = file_ppos(f.file); if (ppos) { pos = *ppos; ppos = &pos; } ret = vfs_write(f.file, buf, count, ppos); if (ret >= 0 && ppos) f.file->f_pos = pos; |
9c225f265 vfs: atomic f_pos... |
586 |
fdput_pos(f); |
1da177e4c Linux-2.6.12-rc2 |
587 588 589 590 |
} return ret; } |
e7a3e8b2e fs: add ksys_writ... |
591 592 593 594 595 |
SYSCALL_DEFINE3(write, unsigned int, fd, const char __user *, buf, size_t, count) { return ksys_write(fd, buf, count); } |
36028d5dd fs: add ksys_p{re... |
596 597 |
ssize_t ksys_pread64(unsigned int fd, char __user *buf, size_t count, loff_t pos) |
1da177e4c Linux-2.6.12-rc2 |
598 |
{ |
2903ff019 switch simple cas... |
599 |
struct fd f; |
1da177e4c Linux-2.6.12-rc2 |
600 |
ssize_t ret = -EBADF; |
1da177e4c Linux-2.6.12-rc2 |
601 602 603 |
if (pos < 0) return -EINVAL; |
2903ff019 switch simple cas... |
604 605 |
f = fdget(fd); if (f.file) { |
1da177e4c Linux-2.6.12-rc2 |
606 |
ret = -ESPIPE; |
2903ff019 switch simple cas... |
607 608 609 |
if (f.file->f_mode & FMODE_PREAD) ret = vfs_read(f.file, buf, count, &pos); fdput(f); |
1da177e4c Linux-2.6.12-rc2 |
610 611 612 613 |
} return ret; } |
36028d5dd fs: add ksys_p{re... |
614 615 616 617 618 619 620 621 |
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) |
1da177e4c Linux-2.6.12-rc2 |
622 |
{ |
2903ff019 switch simple cas... |
623 |
struct fd f; |
1da177e4c Linux-2.6.12-rc2 |
624 |
ssize_t ret = -EBADF; |
1da177e4c Linux-2.6.12-rc2 |
625 626 627 |
if (pos < 0) return -EINVAL; |
2903ff019 switch simple cas... |
628 629 |
f = fdget(fd); if (f.file) { |
1da177e4c Linux-2.6.12-rc2 |
630 |
ret = -ESPIPE; |
2903ff019 switch simple cas... |
631 632 633 |
if (f.file->f_mode & FMODE_PWRITE) ret = vfs_write(f.file, buf, count, &pos); fdput(f); |
1da177e4c Linux-2.6.12-rc2 |
634 635 636 637 |
} return ret; } |
36028d5dd fs: add ksys_p{re... |
638 639 640 641 642 |
SYSCALL_DEFINE4(pwrite64, unsigned int, fd, const char __user *, buf, size_t, count, loff_t, pos) { return ksys_pwrite64(fd, buf, count, pos); } |
ac15ac066 lift iov_iter int... |
643 |
static ssize_t do_iter_readv_writev(struct file *filp, struct iov_iter *iter, |
ddef7ed2b annotate RWF_... ... |
644 |
loff_t *ppos, int type, rwf_t flags) |
293bc9822 new methods: ->re... |
645 646 |
{ struct kiocb kiocb; |
293bc9822 new methods: ->re... |
647 648 649 |
ssize_t ret; init_sync_kiocb(&kiocb, filp); |
fdd2f5b7d fs: Separate out ... |
650 651 652 |
ret = kiocb_set_rw_flags(&kiocb, flags); if (ret) return ret; |
438ab720c vfs: pass ppos=NU... |
653 |
kiocb.ki_pos = (ppos ? *ppos : 0); |
293bc9822 new methods: ->re... |
654 |
|
0f78d06ac vfs: pass type in... |
655 |
if (type == READ) |
bb7462b6f vfs: use helpers ... |
656 |
ret = call_read_iter(filp, &kiocb, iter); |
0f78d06ac vfs: pass type in... |
657 |
else |
bb7462b6f vfs: use helpers ... |
658 |
ret = call_write_iter(filp, &kiocb, iter); |
599bd19bd fs: don't allow t... |
659 |
BUG_ON(ret == -EIOCBQUEUED); |
438ab720c vfs: pass ppos=NU... |
660 661 |
if (ppos) *ppos = kiocb.ki_pos; |
293bc9822 new methods: ->re... |
662 663 |
return ret; } |
ee0b3e671 [PATCH] Remove re... |
664 |
/* Do it by hand, with file-ops */ |
ac15ac066 lift iov_iter int... |
665 |
static ssize_t do_loop_readv_writev(struct file *filp, struct iov_iter *iter, |
ddef7ed2b annotate RWF_... ... |
666 |
loff_t *ppos, int type, rwf_t flags) |
ee0b3e671 [PATCH] Remove re... |
667 |
{ |
ee0b3e671 [PATCH] Remove re... |
668 |
ssize_t ret = 0; |
97be7ebe5 vfs: add the RWF_... |
669 |
if (flags & ~RWF_HIPRI) |
793b80ef1 vfs: pass a flags... |
670 |
return -EOPNOTSUPP; |
ac15ac066 lift iov_iter int... |
671 672 |
while (iov_iter_count(iter)) { struct iovec iovec = iov_iter_iovec(iter); |
ee0b3e671 [PATCH] Remove re... |
673 |
ssize_t nr; |
0f78d06ac vfs: pass type in... |
674 675 676 677 678 679 680 |
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); } |
ee0b3e671 [PATCH] Remove re... |
681 682 683 684 685 686 687 |
if (nr < 0) { if (!ret) ret = nr; break; } ret += nr; |
ac15ac066 lift iov_iter int... |
688 |
if (nr != iovec.iov_len) |
ee0b3e671 [PATCH] Remove re... |
689 |
break; |
ac15ac066 lift iov_iter int... |
690 |
iov_iter_advance(iter, nr); |
ee0b3e671 [PATCH] Remove re... |
691 692 693 694 |
} return ret; } |
ffecee4f2 iov_iter: kernel-... |
695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 |
/** * 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. */ |
eed4e51fb [PATCH] Add vecto... |
724 725 726 |
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, |
ac34ebb3a aio/vfs: cleanup ... |
727 |
struct iovec **ret_pointer) |
435f49a51 readv/writev: do ... |
728 |
{ |
eed4e51fb [PATCH] Add vecto... |
729 |
unsigned long seg; |
435f49a51 readv/writev: do ... |
730 |
ssize_t ret; |
eed4e51fb [PATCH] Add vecto... |
731 |
struct iovec *iov = fast_pointer; |
435f49a51 readv/writev: do ... |
732 733 734 735 736 |
/* * 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... */ |
eed4e51fb [PATCH] Add vecto... |
737 738 |
if (nr_segs == 0) { ret = 0; |
435f49a51 readv/writev: do ... |
739 |
goto out; |
eed4e51fb [PATCH] Add vecto... |
740 |
} |
435f49a51 readv/writev: do ... |
741 742 743 744 |
/* * First get the "struct iovec" from user memory and * verify all the pointers */ |
eed4e51fb [PATCH] Add vecto... |
745 746 |
if (nr_segs > UIO_MAXIOV) { ret = -EINVAL; |
435f49a51 readv/writev: do ... |
747 |
goto out; |
eed4e51fb [PATCH] Add vecto... |
748 749 |
} if (nr_segs > fast_segs) { |
6da2ec560 treewide: kmalloc... |
750 |
iov = kmalloc_array(nr_segs, sizeof(struct iovec), GFP_KERNEL); |
eed4e51fb [PATCH] Add vecto... |
751 752 |
if (iov == NULL) { ret = -ENOMEM; |
435f49a51 readv/writev: do ... |
753 |
goto out; |
eed4e51fb [PATCH] Add vecto... |
754 |
} |
435f49a51 readv/writev: do ... |
755 |
} |
eed4e51fb [PATCH] Add vecto... |
756 757 |
if (copy_from_user(iov, uvector, nr_segs*sizeof(*uvector))) { ret = -EFAULT; |
435f49a51 readv/writev: do ... |
758 |
goto out; |
eed4e51fb [PATCH] Add vecto... |
759 |
} |
435f49a51 readv/writev: do ... |
760 |
/* |
eed4e51fb [PATCH] Add vecto... |
761 762 763 764 |
* 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. |
435f49a51 readv/writev: do ... |
765 766 767 768 |
* * Linux caps all read/write calls to MAX_RW_COUNT, and avoids the * overflow case. */ |
eed4e51fb [PATCH] Add vecto... |
769 |
ret = 0; |
435f49a51 readv/writev: do ... |
770 771 772 |
for (seg = 0; seg < nr_segs; seg++) { void __user *buf = iov[seg].iov_base; ssize_t len = (ssize_t)iov[seg].iov_len; |
eed4e51fb [PATCH] Add vecto... |
773 774 775 |
/* see if we we're about to use an invalid len or if * it's about to overflow ssize_t */ |
435f49a51 readv/writev: do ... |
776 |
if (len < 0) { |
eed4e51fb [PATCH] Add vecto... |
777 |
ret = -EINVAL; |
435f49a51 readv/writev: do ... |
778 |
goto out; |
eed4e51fb [PATCH] Add vecto... |
779 |
} |
ac34ebb3a aio/vfs: cleanup ... |
780 |
if (type >= 0 |
96d4f267e Remove 'type' arg... |
781 |
&& unlikely(!access_ok(buf, len))) { |
eed4e51fb [PATCH] Add vecto... |
782 |
ret = -EFAULT; |
435f49a51 readv/writev: do ... |
783 784 785 786 787 |
goto out; } if (len > MAX_RW_COUNT - ret) { len = MAX_RW_COUNT - ret; iov[seg].iov_len = len; |
eed4e51fb [PATCH] Add vecto... |
788 |
} |
eed4e51fb [PATCH] Add vecto... |
789 |
ret += len; |
435f49a51 readv/writev: do ... |
790 |
} |
eed4e51fb [PATCH] Add vecto... |
791 792 793 794 |
out: *ret_pointer = iov; return ret; } |
f50298556 move compat_rw_co... |
795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 |
#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; |
6da2ec560 treewide: kmalloc... |
819 |
iov = kmalloc_array(nr_segs, sizeof(struct iovec), GFP_KERNEL); |
f50298556 move compat_rw_co... |
820 821 822 823 824 825 |
if (iov == NULL) goto out; } *ret_pointer = iov; ret = -EFAULT; |
96d4f267e Remove 'type' arg... |
826 |
if (!access_ok(uvector, nr_segs*sizeof(*uvector))) |
f50298556 move compat_rw_co... |
827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 |
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 && |
96d4f267e Remove 'type' arg... |
851 |
!access_ok(compat_ptr(buf), len)) { |
f50298556 move compat_rw_co... |
852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 |
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 |
19c735868 fs: remove __do_r... |
869 |
static ssize_t do_iter_read(struct file *file, struct iov_iter *iter, |
ddef7ed2b annotate RWF_... ... |
870 |
loff_t *pos, rwf_t flags) |
1da177e4c Linux-2.6.12-rc2 |
871 |
{ |
1da177e4c Linux-2.6.12-rc2 |
872 |
size_t tot_len; |
7687a7a44 vfs: extract comm... |
873 |
ssize_t ret = 0; |
1da177e4c Linux-2.6.12-rc2 |
874 |
|
edab5fe38 fs: move more cod... |
875 876 877 878 |
if (!(file->f_mode & FMODE_READ)) return -EBADF; if (!(file->f_mode & FMODE_CAN_READ)) return -EINVAL; |
7687a7a44 vfs: extract comm... |
879 |
tot_len = iov_iter_count(iter); |
0504c074b switch {compat_,}... |
880 881 |
if (!tot_len) goto out; |
19c735868 fs: remove __do_r... |
882 |
ret = rw_verify_area(READ, file, pos, tot_len); |
e28cc7157 Relax the rw_veri... |
883 |
if (ret < 0) |
19c735868 fs: remove __do_r... |
884 |
return ret; |
1da177e4c Linux-2.6.12-rc2 |
885 |
|
19c735868 fs: remove __do_r... |
886 887 |
if (file->f_op->read_iter) ret = do_iter_readv_writev(file, iter, pos, READ, flags); |
ee0b3e671 [PATCH] Remove re... |
888 |
else |
19c735868 fs: remove __do_r... |
889 |
ret = do_loop_readv_writev(file, iter, pos, READ, flags); |
1da177e4c Linux-2.6.12-rc2 |
890 |
out: |
19c735868 fs: remove __do_r... |
891 892 |
if (ret >= 0) fsnotify_access(file); |
1da177e4c Linux-2.6.12-rc2 |
893 |
return ret; |
1da177e4c Linux-2.6.12-rc2 |
894 |
} |
18e9710ee fs: implement vfs... |
895 |
ssize_t vfs_iter_read(struct file *file, struct iov_iter *iter, loff_t *ppos, |
ddef7ed2b annotate RWF_... ... |
896 |
rwf_t flags) |
7687a7a44 vfs: extract comm... |
897 |
{ |
18e9710ee fs: implement vfs... |
898 899 900 901 902 |
if (!file->f_op->read_iter) return -EINVAL; return do_iter_read(file, iter, ppos, flags); } EXPORT_SYMBOL(vfs_iter_read); |
7687a7a44 vfs: extract comm... |
903 |
|
19c735868 fs: remove __do_r... |
904 |
static ssize_t do_iter_write(struct file *file, struct iov_iter *iter, |
ddef7ed2b annotate RWF_... ... |
905 |
loff_t *pos, rwf_t flags) |
19c735868 fs: remove __do_r... |
906 907 908 |
{ size_t tot_len; ssize_t ret = 0; |
03d95eb2f lift sb_start_wri... |
909 |
|
edab5fe38 fs: move more cod... |
910 911 912 913 |
if (!(file->f_mode & FMODE_WRITE)) return -EBADF; if (!(file->f_mode & FMODE_CAN_WRITE)) return -EINVAL; |
19c735868 fs: remove __do_r... |
914 915 916 917 |
tot_len = iov_iter_count(iter); if (!tot_len) return 0; ret = rw_verify_area(WRITE, file, pos, tot_len); |
7687a7a44 vfs: extract comm... |
918 919 |
if (ret < 0) return ret; |
19c735868 fs: remove __do_r... |
920 921 922 923 |
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); |
19c735868 fs: remove __do_r... |
924 925 |
if (ret > 0) fsnotify_modify(file); |
7687a7a44 vfs: extract comm... |
926 927 |
return ret; } |
abbb65899 fs: implement vfs... |
928 |
ssize_t vfs_iter_write(struct file *file, struct iov_iter *iter, loff_t *ppos, |
ddef7ed2b annotate RWF_... ... |
929 |
rwf_t flags) |
abbb65899 fs: implement vfs... |
930 931 932 933 934 935 |
{ if (!file->f_op->write_iter) return -EINVAL; return do_iter_write(file, iter, ppos, flags); } EXPORT_SYMBOL(vfs_iter_write); |
1da177e4c Linux-2.6.12-rc2 |
936 |
ssize_t vfs_readv(struct file *file, const struct iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
937 |
unsigned long vlen, loff_t *pos, rwf_t flags) |
1da177e4c Linux-2.6.12-rc2 |
938 |
{ |
7687a7a44 vfs: extract comm... |
939 940 941 942 |
struct iovec iovstack[UIO_FASTIOV]; struct iovec *iov = iovstack; struct iov_iter iter; ssize_t ret; |
1da177e4c Linux-2.6.12-rc2 |
943 |
|
251b42a1d fs: remove do_rea... |
944 |
ret = import_iovec(READ, vec, vlen, ARRAY_SIZE(iovstack), &iov, &iter); |
edab5fe38 fs: move more cod... |
945 946 947 948 |
if (ret >= 0) { ret = do_iter_read(file, &iter, pos, flags); kfree(iov); } |
1da177e4c Linux-2.6.12-rc2 |
949 |
|
251b42a1d fs: remove do_rea... |
950 951 |
return ret; } |
1da177e4c Linux-2.6.12-rc2 |
952 |
|
9725d4cef fs: unexport vfs_... |
953 |
static ssize_t vfs_writev(struct file *file, const struct iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
954 |
unsigned long vlen, loff_t *pos, rwf_t flags) |
1da177e4c Linux-2.6.12-rc2 |
955 |
{ |
251b42a1d fs: remove do_rea... |
956 957 958 959 |
struct iovec iovstack[UIO_FASTIOV]; struct iovec *iov = iovstack; struct iov_iter iter; ssize_t ret; |
1da177e4c Linux-2.6.12-rc2 |
960 |
|
251b42a1d fs: remove do_rea... |
961 |
ret = import_iovec(WRITE, vec, vlen, ARRAY_SIZE(iovstack), &iov, &iter); |
edab5fe38 fs: move more cod... |
962 |
if (ret >= 0) { |
62473a2d6 move file_{start,... |
963 |
file_start_write(file); |
edab5fe38 fs: move more cod... |
964 |
ret = do_iter_write(file, &iter, pos, flags); |
62473a2d6 move file_{start,... |
965 |
file_end_write(file); |
edab5fe38 fs: move more cod... |
966 967 |
kfree(iov); } |
251b42a1d fs: remove do_rea... |
968 |
return ret; |
1da177e4c Linux-2.6.12-rc2 |
969 |
} |
1da177e4c Linux-2.6.12-rc2 |
970 |
|
f17d8b354 vfs: vfs: Define ... |
971 |
static ssize_t do_readv(unsigned long fd, const struct iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
972 |
unsigned long vlen, rwf_t flags) |
1da177e4c Linux-2.6.12-rc2 |
973 |
{ |
9c225f265 vfs: atomic f_pos... |
974 |
struct fd f = fdget_pos(fd); |
1da177e4c Linux-2.6.12-rc2 |
975 |
ssize_t ret = -EBADF; |
1da177e4c Linux-2.6.12-rc2 |
976 |
|
2903ff019 switch simple cas... |
977 |
if (f.file) { |
438ab720c vfs: pass ppos=NU... |
978 979 980 981 982 983 984 985 |
loff_t pos, *ppos = file_ppos(f.file); if (ppos) { pos = *ppos; ppos = &pos; } ret = vfs_readv(f.file, vec, vlen, ppos, flags); if (ret >= 0 && ppos) f.file->f_pos = pos; |
9c225f265 vfs: atomic f_pos... |
986 |
fdput_pos(f); |
1da177e4c Linux-2.6.12-rc2 |
987 988 989 |
} if (ret > 0) |
4b98d11b4 [PATCH] ifdef ->r... |
990 991 |
add_rchar(current, ret); inc_syscr(current); |
1da177e4c Linux-2.6.12-rc2 |
992 993 |
return ret; } |
f17d8b354 vfs: vfs: Define ... |
994 |
static ssize_t do_writev(unsigned long fd, const struct iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
995 |
unsigned long vlen, rwf_t flags) |
1da177e4c Linux-2.6.12-rc2 |
996 |
{ |
9c225f265 vfs: atomic f_pos... |
997 |
struct fd f = fdget_pos(fd); |
1da177e4c Linux-2.6.12-rc2 |
998 |
ssize_t ret = -EBADF; |
1da177e4c Linux-2.6.12-rc2 |
999 |
|
2903ff019 switch simple cas... |
1000 |
if (f.file) { |
438ab720c vfs: pass ppos=NU... |
1001 1002 1003 1004 1005 1006 1007 1008 |
loff_t pos, *ppos = file_ppos(f.file); if (ppos) { pos = *ppos; ppos = &pos; } ret = vfs_writev(f.file, vec, vlen, ppos, flags); if (ret >= 0 && ppos) f.file->f_pos = pos; |
9c225f265 vfs: atomic f_pos... |
1009 |
fdput_pos(f); |
1da177e4c Linux-2.6.12-rc2 |
1010 1011 1012 |
} if (ret > 0) |
4b98d11b4 [PATCH] ifdef ->r... |
1013 1014 |
add_wchar(current, ret); inc_syscw(current); |
1da177e4c Linux-2.6.12-rc2 |
1015 1016 |
return ret; } |
601cc11d0 Make non-compat p... |
1017 1018 1019 1020 1021 |
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; } |
f17d8b354 vfs: vfs: Define ... |
1022 |
static ssize_t do_preadv(unsigned long fd, const struct iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
1023 |
unsigned long vlen, loff_t pos, rwf_t flags) |
f3554f4bc preadv/pwritev: A... |
1024 |
{ |
2903ff019 switch simple cas... |
1025 |
struct fd f; |
f3554f4bc preadv/pwritev: A... |
1026 |
ssize_t ret = -EBADF; |
f3554f4bc preadv/pwritev: A... |
1027 1028 1029 |
if (pos < 0) return -EINVAL; |
2903ff019 switch simple cas... |
1030 1031 |
f = fdget(fd); if (f.file) { |
f3554f4bc preadv/pwritev: A... |
1032 |
ret = -ESPIPE; |
2903ff019 switch simple cas... |
1033 |
if (f.file->f_mode & FMODE_PREAD) |
f17d8b354 vfs: vfs: Define ... |
1034 |
ret = vfs_readv(f.file, vec, vlen, &pos, flags); |
2903ff019 switch simple cas... |
1035 |
fdput(f); |
f3554f4bc preadv/pwritev: A... |
1036 1037 1038 1039 1040 1041 1042 |
} if (ret > 0) add_rchar(current, ret); inc_syscr(current); return ret; } |
f17d8b354 vfs: vfs: Define ... |
1043 |
static ssize_t do_pwritev(unsigned long fd, const struct iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
1044 |
unsigned long vlen, loff_t pos, rwf_t flags) |
f3554f4bc preadv/pwritev: A... |
1045 |
{ |
2903ff019 switch simple cas... |
1046 |
struct fd f; |
f3554f4bc preadv/pwritev: A... |
1047 |
ssize_t ret = -EBADF; |
f3554f4bc preadv/pwritev: A... |
1048 1049 1050 |
if (pos < 0) return -EINVAL; |
2903ff019 switch simple cas... |
1051 1052 |
f = fdget(fd); if (f.file) { |
f3554f4bc preadv/pwritev: A... |
1053 |
ret = -ESPIPE; |
2903ff019 switch simple cas... |
1054 |
if (f.file->f_mode & FMODE_PWRITE) |
f17d8b354 vfs: vfs: Define ... |
1055 |
ret = vfs_writev(f.file, vec, vlen, &pos, flags); |
2903ff019 switch simple cas... |
1056 |
fdput(f); |
f3554f4bc preadv/pwritev: A... |
1057 1058 1059 1060 1061 1062 1063 |
} if (ret > 0) add_wchar(current, ret); inc_syscw(current); return ret; } |
f17d8b354 vfs: vfs: Define ... |
1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 |
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, |
ddef7ed2b annotate RWF_... ... |
1086 |
rwf_t, flags) |
f17d8b354 vfs: vfs: Define ... |
1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 |
{ 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, |
ddef7ed2b annotate RWF_... ... |
1106 |
rwf_t, flags) |
f17d8b354 vfs: vfs: Define ... |
1107 1108 1109 1110 1111 1112 1113 1114 |
{ 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); } |
72ec35163 switch compat rea... |
1115 |
#ifdef CONFIG_COMPAT |
72ec35163 switch compat rea... |
1116 1117 |
static size_t compat_readv(struct file *file, const struct compat_iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
1118 |
unsigned long vlen, loff_t *pos, rwf_t flags) |
72ec35163 switch compat rea... |
1119 |
{ |
72ec35163 switch compat rea... |
1120 1121 |
struct iovec iovstack[UIO_FASTIOV]; struct iovec *iov = iovstack; |
ac15ac066 lift iov_iter int... |
1122 |
struct iov_iter iter; |
72ec35163 switch compat rea... |
1123 |
ssize_t ret; |
72ec35163 switch compat rea... |
1124 |
|
26c87fb7d fs: remove do_com... |
1125 |
ret = compat_import_iovec(READ, vec, vlen, UIO_FASTIOV, &iov, &iter); |
edab5fe38 fs: move more cod... |
1126 1127 1128 1129 |
if (ret >= 0) { ret = do_iter_read(file, &iter, pos, flags); kfree(iov); } |
72ec35163 switch compat rea... |
1130 1131 1132 1133 1134 |
if (ret > 0) add_rchar(current, ret); inc_syscr(current); return ret; } |
f17d8b354 vfs: vfs: Define ... |
1135 1136 |
static size_t do_compat_readv(compat_ulong_t fd, const struct compat_iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
1137 |
compat_ulong_t vlen, rwf_t flags) |
72ec35163 switch compat rea... |
1138 |
{ |
9c225f265 vfs: atomic f_pos... |
1139 |
struct fd f = fdget_pos(fd); |
72ec35163 switch compat rea... |
1140 1141 1142 1143 1144 1145 |
ssize_t ret; loff_t pos; if (!f.file) return -EBADF; pos = f.file->f_pos; |
f17d8b354 vfs: vfs: Define ... |
1146 |
ret = compat_readv(f.file, vec, vlen, &pos, flags); |
5faf153eb don't call file_p... |
1147 1148 |
if (ret >= 0) f.file->f_pos = pos; |
9c225f265 vfs: atomic f_pos... |
1149 |
fdput_pos(f); |
72ec35163 switch compat rea... |
1150 |
return ret; |
f17d8b354 vfs: vfs: Define ... |
1151 |
|
72ec35163 switch compat rea... |
1152 |
} |
f17d8b354 vfs: vfs: Define ... |
1153 1154 1155 1156 1157 1158 1159 1160 |
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, |
378a10f3a fs/compat: option... |
1161 |
const struct compat_iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
1162 |
unsigned long vlen, loff_t pos, rwf_t flags) |
72ec35163 switch compat rea... |
1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 |
{ 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) |
f17d8b354 vfs: vfs: Define ... |
1174 |
ret = compat_readv(f.file, vec, vlen, &pos, flags); |
72ec35163 switch compat rea... |
1175 1176 1177 |
fdput(f); return ret; } |
378a10f3a fs/compat: option... |
1178 1179 1180 1181 1182 |
#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) { |
f17d8b354 vfs: vfs: Define ... |
1183 |
return do_compat_preadv64(fd, vec, vlen, pos, 0); |
378a10f3a fs/compat: option... |
1184 1185 |
} #endif |
dfd948e32 fs/compat: fix pa... |
1186 |
COMPAT_SYSCALL_DEFINE5(preadv, compat_ulong_t, fd, |
72ec35163 switch compat rea... |
1187 |
const struct compat_iovec __user *,vec, |
dfd948e32 fs/compat: fix pa... |
1188 |
compat_ulong_t, vlen, u32, pos_low, u32, pos_high) |
72ec35163 switch compat rea... |
1189 1190 |
{ loff_t pos = ((loff_t)pos_high << 32) | pos_low; |
378a10f3a fs/compat: option... |
1191 |
|
f17d8b354 vfs: vfs: Define ... |
1192 1193 |
return do_compat_preadv64(fd, vec, vlen, pos, 0); } |
3ebfd81f7 x86/syscalls: Add... |
1194 1195 1196 |
#ifdef __ARCH_WANT_COMPAT_SYS_PREADV64V2 COMPAT_SYSCALL_DEFINE5(preadv64v2, unsigned long, fd, const struct compat_iovec __user *,vec, |
ddef7ed2b annotate RWF_... ... |
1197 |
unsigned long, vlen, loff_t, pos, rwf_t, flags) |
3ebfd81f7 x86/syscalls: Add... |
1198 |
{ |
cc4b1242d vfs: fix preadv64... |
1199 1200 |
if (pos == -1) return do_compat_readv(fd, vec, vlen, flags); |
3ebfd81f7 x86/syscalls: Add... |
1201 1202 1203 |
return do_compat_preadv64(fd, vec, vlen, pos, flags); } #endif |
f17d8b354 vfs: vfs: Define ... |
1204 1205 1206 |
COMPAT_SYSCALL_DEFINE6(preadv2, compat_ulong_t, fd, const struct compat_iovec __user *,vec, compat_ulong_t, vlen, u32, pos_low, u32, pos_high, |
ddef7ed2b annotate RWF_... ... |
1207 |
rwf_t, flags) |
f17d8b354 vfs: vfs: Define ... |
1208 1209 1210 1211 1212 1213 1214 |
{ 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); |
72ec35163 switch compat rea... |
1215 1216 1217 1218 |
} static size_t compat_writev(struct file *file, const struct compat_iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
1219 |
unsigned long vlen, loff_t *pos, rwf_t flags) |
72ec35163 switch compat rea... |
1220 |
{ |
26c87fb7d fs: remove do_com... |
1221 1222 1223 |
struct iovec iovstack[UIO_FASTIOV]; struct iovec *iov = iovstack; struct iov_iter iter; |
edab5fe38 fs: move more cod... |
1224 |
ssize_t ret; |
72ec35163 switch compat rea... |
1225 |
|
26c87fb7d fs: remove do_com... |
1226 |
ret = compat_import_iovec(WRITE, vec, vlen, UIO_FASTIOV, &iov, &iter); |
edab5fe38 fs: move more cod... |
1227 |
if (ret >= 0) { |
62473a2d6 move file_{start,... |
1228 |
file_start_write(file); |
edab5fe38 fs: move more cod... |
1229 |
ret = do_iter_write(file, &iter, pos, flags); |
62473a2d6 move file_{start,... |
1230 |
file_end_write(file); |
edab5fe38 fs: move more cod... |
1231 1232 |
kfree(iov); } |
72ec35163 switch compat rea... |
1233 1234 1235 1236 1237 |
if (ret > 0) add_wchar(current, ret); inc_syscw(current); return ret; } |
f17d8b354 vfs: vfs: Define ... |
1238 1239 |
static size_t do_compat_writev(compat_ulong_t fd, const struct compat_iovec __user* vec, |
ddef7ed2b annotate RWF_... ... |
1240 |
compat_ulong_t vlen, rwf_t flags) |
72ec35163 switch compat rea... |
1241 |
{ |
9c225f265 vfs: atomic f_pos... |
1242 |
struct fd f = fdget_pos(fd); |
72ec35163 switch compat rea... |
1243 1244 1245 1246 1247 1248 |
ssize_t ret; loff_t pos; if (!f.file) return -EBADF; pos = f.file->f_pos; |
f17d8b354 vfs: vfs: Define ... |
1249 |
ret = compat_writev(f.file, vec, vlen, &pos, flags); |
5faf153eb don't call file_p... |
1250 1251 |
if (ret >= 0) f.file->f_pos = pos; |
9c225f265 vfs: atomic f_pos... |
1252 |
fdput_pos(f); |
72ec35163 switch compat rea... |
1253 1254 |
return ret; } |
f17d8b354 vfs: vfs: Define ... |
1255 1256 1257 1258 1259 1260 1261 1262 |
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, |
378a10f3a fs/compat: option... |
1263 |
const struct compat_iovec __user *vec, |
ddef7ed2b annotate RWF_... ... |
1264 |
unsigned long vlen, loff_t pos, rwf_t flags) |
72ec35163 switch compat rea... |
1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 |
{ 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) |
f17d8b354 vfs: vfs: Define ... |
1276 |
ret = compat_writev(f.file, vec, vlen, &pos, flags); |
72ec35163 switch compat rea... |
1277 1278 1279 |
fdput(f); return ret; } |
378a10f3a fs/compat: option... |
1280 1281 1282 1283 1284 |
#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) { |
f17d8b354 vfs: vfs: Define ... |
1285 |
return do_compat_pwritev64(fd, vec, vlen, pos, 0); |
378a10f3a fs/compat: option... |
1286 1287 |
} #endif |
dfd948e32 fs/compat: fix pa... |
1288 |
COMPAT_SYSCALL_DEFINE5(pwritev, compat_ulong_t, fd, |
72ec35163 switch compat rea... |
1289 |
const struct compat_iovec __user *,vec, |
dfd948e32 fs/compat: fix pa... |
1290 |
compat_ulong_t, vlen, u32, pos_low, u32, pos_high) |
72ec35163 switch compat rea... |
1291 1292 |
{ loff_t pos = ((loff_t)pos_high << 32) | pos_low; |
378a10f3a fs/compat: option... |
1293 |
|
f17d8b354 vfs: vfs: Define ... |
1294 |
return do_compat_pwritev64(fd, vec, vlen, pos, 0); |
72ec35163 switch compat rea... |
1295 |
} |
f17d8b354 vfs: vfs: Define ... |
1296 |
|
3ebfd81f7 x86/syscalls: Add... |
1297 1298 1299 |
#ifdef __ARCH_WANT_COMPAT_SYS_PWRITEV64V2 COMPAT_SYSCALL_DEFINE5(pwritev64v2, unsigned long, fd, const struct compat_iovec __user *,vec, |
ddef7ed2b annotate RWF_... ... |
1300 |
unsigned long, vlen, loff_t, pos, rwf_t, flags) |
3ebfd81f7 x86/syscalls: Add... |
1301 |
{ |
cc4b1242d vfs: fix preadv64... |
1302 1303 |
if (pos == -1) return do_compat_writev(fd, vec, vlen, flags); |
3ebfd81f7 x86/syscalls: Add... |
1304 1305 1306 |
return do_compat_pwritev64(fd, vec, vlen, pos, flags); } #endif |
f17d8b354 vfs: vfs: Define ... |
1307 1308 |
COMPAT_SYSCALL_DEFINE6(pwritev2, compat_ulong_t, fd, const struct compat_iovec __user *,vec, |
ddef7ed2b annotate RWF_... ... |
1309 |
compat_ulong_t, vlen, u32, pos_low, u32, pos_high, rwf_t, flags) |
f17d8b354 vfs: vfs: Define ... |
1310 1311 1312 1313 1314 1315 1316 |
{ 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); |
72ec35163 switch compat rea... |
1317 |
} |
f17d8b354 vfs: vfs: Define ... |
1318 |
|
72ec35163 switch compat rea... |
1319 |
#endif |
19f4fc3ae convert sendfile{... |
1320 1321 |
static ssize_t do_sendfile(int out_fd, int in_fd, loff_t *ppos, size_t count, loff_t max) |
1da177e4c Linux-2.6.12-rc2 |
1322 |
{ |
2903ff019 switch simple cas... |
1323 1324 |
struct fd in, out; struct inode *in_inode, *out_inode; |
1da177e4c Linux-2.6.12-rc2 |
1325 |
loff_t pos; |
7995bd287 splice: don't pas... |
1326 |
loff_t out_pos; |
1da177e4c Linux-2.6.12-rc2 |
1327 |
ssize_t retval; |
2903ff019 switch simple cas... |
1328 |
int fl; |
1da177e4c Linux-2.6.12-rc2 |
1329 1330 1331 1332 1333 |
/* * Get input file, and verify that it is ok.. */ retval = -EBADF; |
2903ff019 switch simple cas... |
1334 1335 |
in = fdget(in_fd); if (!in.file) |
1da177e4c Linux-2.6.12-rc2 |
1336 |
goto out; |
2903ff019 switch simple cas... |
1337 |
if (!(in.file->f_mode & FMODE_READ)) |
1da177e4c Linux-2.6.12-rc2 |
1338 |
goto fput_in; |
1da177e4c Linux-2.6.12-rc2 |
1339 |
retval = -ESPIPE; |
7995bd287 splice: don't pas... |
1340 1341 1342 1343 |
if (!ppos) { pos = in.file->f_pos; } else { pos = *ppos; |
2903ff019 switch simple cas... |
1344 |
if (!(in.file->f_mode & FMODE_PREAD)) |
1da177e4c Linux-2.6.12-rc2 |
1345 |
goto fput_in; |
7995bd287 splice: don't pas... |
1346 1347 |
} retval = rw_verify_area(READ, in.file, &pos, count); |
e28cc7157 Relax the rw_veri... |
1348 |
if (retval < 0) |
1da177e4c Linux-2.6.12-rc2 |
1349 |
goto fput_in; |
bc61384dc rw_verify_area():... |
1350 1351 |
if (count > MAX_RW_COUNT) count = MAX_RW_COUNT; |
1da177e4c Linux-2.6.12-rc2 |
1352 |
|
1da177e4c Linux-2.6.12-rc2 |
1353 1354 1355 1356 |
/* * Get output file, and verify that it is ok.. */ retval = -EBADF; |
2903ff019 switch simple cas... |
1357 1358 |
out = fdget(out_fd); if (!out.file) |
1da177e4c Linux-2.6.12-rc2 |
1359 |
goto fput_in; |
2903ff019 switch simple cas... |
1360 |
if (!(out.file->f_mode & FMODE_WRITE)) |
1da177e4c Linux-2.6.12-rc2 |
1361 |
goto fput_out; |
496ad9aa8 new helper: file_... |
1362 1363 |
in_inode = file_inode(in.file); out_inode = file_inode(out.file); |
7995bd287 splice: don't pas... |
1364 1365 |
out_pos = out.file->f_pos; retval = rw_verify_area(WRITE, out.file, &out_pos, count); |
e28cc7157 Relax the rw_veri... |
1366 |
if (retval < 0) |
1da177e4c Linux-2.6.12-rc2 |
1367 |
goto fput_out; |
1da177e4c Linux-2.6.12-rc2 |
1368 1369 |
if (!max) max = min(in_inode->i_sb->s_maxbytes, out_inode->i_sb->s_maxbytes); |
1da177e4c Linux-2.6.12-rc2 |
1370 1371 1372 1373 1374 1375 |
if (unlikely(pos + count > max)) { retval = -EOVERFLOW; if (pos >= max) goto fput_out; count = max - pos; } |
d96e6e716 Remove remnants o... |
1376 |
fl = 0; |
534f2aaa6 sys_sendfile: swi... |
1377 |
#if 0 |
d96e6e716 Remove remnants o... |
1378 1379 1380 1381 1382 1383 |
/* * 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. */ |
2903ff019 switch simple cas... |
1384 |
if (in.file->f_flags & O_NONBLOCK) |
d96e6e716 Remove remnants o... |
1385 |
fl = SPLICE_F_NONBLOCK; |
534f2aaa6 sys_sendfile: swi... |
1386 |
#endif |
50cd2c577 lift file_*_write... |
1387 |
file_start_write(out.file); |
7995bd287 splice: don't pas... |
1388 |
retval = do_splice_direct(in.file, &pos, out.file, &out_pos, count, fl); |
50cd2c577 lift file_*_write... |
1389 |
file_end_write(out.file); |
1da177e4c Linux-2.6.12-rc2 |
1390 1391 |
if (retval > 0) { |
4b98d11b4 [PATCH] ifdef ->r... |
1392 1393 |
add_rchar(current, retval); add_wchar(current, retval); |
a68c2f12b sendfile: allows ... |
1394 1395 |
fsnotify_access(in.file); fsnotify_modify(out.file); |
7995bd287 splice: don't pas... |
1396 1397 1398 1399 1400 |
out.file->f_pos = out_pos; if (ppos) *ppos = pos; else in.file->f_pos = pos; |
1da177e4c Linux-2.6.12-rc2 |
1401 |
} |
1da177e4c Linux-2.6.12-rc2 |
1402 |
|
4b98d11b4 [PATCH] ifdef ->r... |
1403 1404 |
inc_syscr(current); inc_syscw(current); |
7995bd287 splice: don't pas... |
1405 |
if (pos > max) |
1da177e4c Linux-2.6.12-rc2 |
1406 1407 1408 |
retval = -EOVERFLOW; fput_out: |
2903ff019 switch simple cas... |
1409 |
fdput(out); |
1da177e4c Linux-2.6.12-rc2 |
1410 |
fput_in: |
2903ff019 switch simple cas... |
1411 |
fdput(in); |
1da177e4c Linux-2.6.12-rc2 |
1412 1413 1414 |
out: return retval; } |
002c8976e [CVE-2009-0029] S... |
1415 |
SYSCALL_DEFINE4(sendfile, int, out_fd, int, in_fd, off_t __user *, offset, size_t, count) |
1da177e4c Linux-2.6.12-rc2 |
1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 |
{ 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); } |
002c8976e [CVE-2009-0029] S... |
1433 |
SYSCALL_DEFINE4(sendfile64, int, out_fd, int, in_fd, loff_t __user *, offset, size_t, count) |
1da177e4c Linux-2.6.12-rc2 |
1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 |
{ 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); } |
19f4fc3ae convert sendfile{... |
1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 |
#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 |
29732938a vfs: add copy_fil... |
1489 |
|
f16acc9d9 vfs: introduce ge... |
1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 |
/** * generic_copy_file_range - copy data between two files * @file_in: file structure to read from * @pos_in: file offset to read from * @file_out: file structure to write data to * @pos_out: file offset to write data to * @len: amount of data to copy * @flags: copy flags * * This is a generic filesystem helper to copy data from one file to another. * It has no constraints on the source or destination file owners - the files * can belong to different superblocks and different filesystem types. Short * copies are allowed. * * This should be called from the @file_out filesystem, as per the * ->copy_file_range() method. * * Returns the number of bytes copied or a negative error indicating the * failure. */ ssize_t generic_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) { return do_splice_direct(file_in, &pos_in, file_out, &pos_out, len > MAX_RW_COUNT ? MAX_RW_COUNT : len, 0); } EXPORT_SYMBOL(generic_copy_file_range); |
64bf5ff58 vfs: no fallback ... |
1519 1520 1521 1522 |
static ssize_t do_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) { |
5dae222a5 vfs: allow copy_f... |
1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 |
/* * Although we now allow filesystems to handle cross sb copy, passing * a file of the wrong filesystem type to filesystem driver can result * in an attempt to dereference the wrong type of ->private_data, so * avoid doing that until we really have a good reason. NFS defines * several different file_system_type structures, but they all end up * using the same ->copy_file_range() function pointer. */ if (file_out->f_op->copy_file_range && file_out->f_op->copy_file_range == file_in->f_op->copy_file_range) |
64bf5ff58 vfs: no fallback ... |
1533 1534 1535 1536 1537 1538 1539 |
return file_out->f_op->copy_file_range(file_in, pos_in, file_out, pos_out, len, flags); return generic_copy_file_range(file_in, pos_in, file_out, pos_out, len, flags); } |
29732938a vfs: add copy_fil... |
1540 1541 1542 1543 1544 1545 1546 1547 1548 |
/* * 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) { |
29732938a vfs: add copy_fil... |
1549 1550 1551 1552 |
ssize_t ret; if (flags != 0) return -EINVAL; |
96e6e8f4a vfs: add missing ... |
1553 1554 |
ret = generic_copy_file_checks(file_in, pos_in, file_out, pos_out, &len, flags); |
a31713517 vfs: introduce ge... |
1555 1556 |
if (unlikely(ret)) return ret; |
11cbfb107 vfs: deny copy_fi... |
1557 |
|
29732938a vfs: add copy_fil... |
1558 |
ret = rw_verify_area(READ, file_in, &pos_in, len); |
bc61384dc rw_verify_area():... |
1559 1560 1561 1562 1563 |
if (unlikely(ret)) return ret; ret = rw_verify_area(WRITE, file_out, &pos_out, len); if (unlikely(ret)) |
29732938a vfs: add copy_fil... |
1564 |
return ret; |
29732938a vfs: add copy_fil... |
1565 1566 |
if (len == 0) return 0; |
bfe219d37 vfs: wrap write f... |
1567 |
file_start_write(file_out); |
29732938a vfs: add copy_fil... |
1568 |
|
a76b5b043 fs: try to clone ... |
1569 1570 1571 1572 |
/* * Try cloning first, this is supported by more file systems, and * more efficient if both clone and copy are supported (e.g. NFS). */ |
5dae222a5 vfs: allow copy_f... |
1573 1574 |
if (file_in->f_op->remap_file_range && file_inode(file_in)->i_sb == file_inode(file_out)->i_sb) { |
42ec3d4c0 vfs: make remap_f... |
1575 1576 1577 1578 |
loff_t cloned; cloned = file_in->f_op->remap_file_range(file_in, pos_in, file_out, pos_out, |
eca3654e3 vfs: enable remap... |
1579 1580 |
min_t(loff_t, MAX_RW_COUNT, len), REMAP_FILE_CAN_SHORTEN); |
42ec3d4c0 vfs: make remap_f... |
1581 1582 |
if (cloned > 0) { ret = cloned; |
a76b5b043 fs: try to clone ... |
1583 1584 1585 |
goto done; } } |
64bf5ff58 vfs: no fallback ... |
1586 1587 1588 |
ret = do_copy_file_range(file_in, pos_in, file_out, pos_out, len, flags); WARN_ON_ONCE(ret == -EOPNOTSUPP); |
a76b5b043 fs: try to clone ... |
1589 |
done: |
29732938a vfs: add copy_fil... |
1590 1591 1592 1593 1594 1595 |
if (ret > 0) { fsnotify_access(file_in); add_rchar(current, ret); fsnotify_modify(file_out); add_wchar(current, ret); } |
a76b5b043 fs: try to clone ... |
1596 |
|
29732938a vfs: add copy_fil... |
1597 1598 |
inc_syscr(current); inc_syscw(current); |
bfe219d37 vfs: wrap write f... |
1599 |
file_end_write(file_out); |
29732938a vfs: add copy_fil... |
1600 1601 1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621 1622 1623 1624 1625 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 |
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; } |
04b38d601 vfs: pull btrfs c... |
1666 |
|
42ec3d4c0 vfs: make remap_f... |
1667 1668 |
static int remap_verify_area(struct file *file, loff_t pos, loff_t len, bool write) |
04b38d601 vfs: pull btrfs c... |
1669 1670 |
{ struct inode *inode = file_inode(file); |
42ec3d4c0 vfs: make remap_f... |
1671 |
if (unlikely(pos < 0 || len < 0)) |
04b38d601 vfs: pull btrfs c... |
1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 |
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); } |
07d19dc9f vfs: avoid proble... |
1689 1690 1691 1692 1693 |
/* * 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. * |
a421f5137 fs: allow dedupli... |
1694 1695 1696 |
* For clone we only link a partial EOF block above or at the destination file's * EOF. For deduplication we accept a partial EOF block only if it ends at the * destination file's EOF (can not link it into the middle of a file). |
eca3654e3 vfs: enable remap... |
1697 1698 |
* * Shorten the request if possible. |
07d19dc9f vfs: avoid proble... |
1699 1700 1701 1702 |
*/ static int generic_remap_check_len(struct inode *inode_in, struct inode *inode_out, loff_t pos_out, |
42ec3d4c0 vfs: make remap_f... |
1703 |
loff_t *len, |
a91ae49bb vfs: pass remap f... |
1704 |
unsigned int remap_flags) |
07d19dc9f vfs: avoid proble... |
1705 1706 |
{ u64 blkmask = i_blocksize(inode_in) - 1; |
eca3654e3 vfs: enable remap... |
1707 |
loff_t new_len = *len; |
07d19dc9f vfs: avoid proble... |
1708 1709 1710 |
if ((*len & blkmask) == 0) return 0; |
a421f5137 fs: allow dedupli... |
1711 |
if (pos_out + *len < i_size_read(inode_out)) |
eca3654e3 vfs: enable remap... |
1712 |
new_len &= ~blkmask; |
07d19dc9f vfs: avoid proble... |
1713 |
|
eca3654e3 vfs: enable remap... |
1714 1715 1716 1717 1718 1719 1720 1721 1722 |
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; |
07d19dc9f vfs: avoid proble... |
1723 |
} |
04b38d601 vfs: pull btrfs c... |
1724 |
|
edc58dd01 vfs: fix page loc... |
1725 |
/* Read a page's worth of file data into the page cache. */ |
c32e5f399 vfs: hide file ra... |
1726 1727 1728 1729 1730 1731 1732 1733 1734 1735 1736 |
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); } |
c32e5f399 vfs: hide file ra... |
1737 1738 1739 1740 |
return page; } /* |
edc58dd01 vfs: fix page loc... |
1741 1742 1743 1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755 1756 1757 1758 1759 1760 1761 1762 1763 |
* Lock two pages, ensuring that we lock in offset order if the pages are from * the same file. */ static void vfs_lock_two_pages(struct page *page1, struct page *page2) { /* Always lock in order of increasing index. */ if (page1->index > page2->index) swap(page1, page2); lock_page(page1); if (page1 != page2) lock_page(page2); } /* Unlock two pages, being careful not to unlock the same page twice. */ static void vfs_unlock_two_pages(struct page *page1, struct page *page2) { unlock_page(page1); if (page1 != page2) unlock_page(page2); } /* |
c32e5f399 vfs: hide file ra... |
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 |
* 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); |
c32e5f399 vfs: hide file ra... |
1800 1801 1802 |
put_page(src_page); goto out_error; } |
edc58dd01 vfs: fix page loc... |
1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 |
vfs_lock_two_pages(src_page, dest_page); /* * Now that we've locked both pages, make sure they're still * mapped to the file data we're interested in. If not, * someone is invalidating pages on us and we lose. */ if (!PageUptodate(src_page) || !PageUptodate(dest_page) || src_page->mapping != src->i_mapping || dest_page->mapping != dest->i_mapping) { same = false; goto unlock; } |
c32e5f399 vfs: hide file ra... |
1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 |
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); |
edc58dd01 vfs: fix page loc... |
1828 1829 |
unlock: vfs_unlock_two_pages(src_page, dest_page); |
c32e5f399 vfs: hide file ra... |
1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 |
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; } |
04b38d601 vfs: pull btrfs c... |
1847 |
|
876bec6f9 vfs: refactor clo... |
1848 1849 1850 1851 |
/* * 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. |
22725ce4e vfs: fix isize/po... |
1852 |
* |
8c5c836bd vfs: clean up gen... |
1853 1854 |
* If there's an error, then the usual negative error code is returned. * Otherwise returns 0 with *len set to the request length. |
876bec6f9 vfs: refactor clo... |
1855 |
*/ |
a83ab01a6 vfs: rename vfs_c... |
1856 1857 |
int generic_remap_file_range_prep(struct file *file_in, loff_t pos_in, struct file *file_out, loff_t pos_out, |
42ec3d4c0 vfs: make remap_f... |
1858 |
loff_t *len, unsigned int remap_flags) |
876bec6f9 vfs: refactor clo... |
1859 |
{ |
1383a7ed6 vfs: check file r... |
1860 1861 |
struct inode *inode_in = file_inode(file_in); struct inode *inode_out = file_inode(file_out); |
876bec6f9 vfs: refactor clo... |
1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873 1874 1875 1876 |
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; |
876bec6f9 vfs: refactor clo... |
1877 1878 |
/* Zero length dedupe exits immediately; reflink goes to EOF. */ if (*len == 0) { |
1383a7ed6 vfs: check file r... |
1879 |
loff_t isize = i_size_read(inode_in); |
a91ae49bb vfs: pass remap f... |
1880 |
if ((remap_flags & REMAP_FILE_DEDUP) || pos_in == isize) |
876bec6f9 vfs: refactor clo... |
1881 |
return 0; |
22725ce4e vfs: fix isize/po... |
1882 1883 |
if (pos_in > isize) return -EINVAL; |
876bec6f9 vfs: refactor clo... |
1884 |
*len = isize - pos_in; |
2c5773f10 vfs: exit early f... |
1885 1886 |
if (*len == 0) return 0; |
876bec6f9 vfs: refactor clo... |
1887 |
} |
1383a7ed6 vfs: check file r... |
1888 1889 |
/* Check that we don't violate system file offset limits. */ ret = generic_remap_checks(file_in, pos_in, file_out, pos_out, len, |
3d28193e1 vfs: pass remap f... |
1890 |
remap_flags); |
1383a7ed6 vfs: check file r... |
1891 1892 |
if (ret) return ret; |
876bec6f9 vfs: refactor clo... |
1893 1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 |
/* 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. */ |
a91ae49bb vfs: pass remap f... |
1912 |
if (remap_flags & REMAP_FILE_DEDUP) { |
876bec6f9 vfs: refactor clo... |
1913 1914 1915 1916 1917 1918 1919 1920 1921 |
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; } |
07d19dc9f vfs: avoid proble... |
1922 |
ret = generic_remap_check_len(inode_in, inode_out, pos_out, len, |
a91ae49bb vfs: pass remap f... |
1923 |
remap_flags); |
07d19dc9f vfs: avoid proble... |
1924 1925 |
if (ret) return ret; |
8dde90bca vfs: remap helper... |
1926 |
/* If can't alter the file contents, we're done. */ |
e38f7f53c vfs: introduce fi... |
1927 1928 |
if (!(remap_flags & REMAP_FILE_DEDUP)) ret = file_modified(file_out); |
8dde90bca vfs: remap helper... |
1929 |
|
e38f7f53c vfs: introduce fi... |
1930 |
return ret; |
876bec6f9 vfs: refactor clo... |
1931 |
} |
a83ab01a6 vfs: rename vfs_c... |
1932 |
EXPORT_SYMBOL(generic_remap_file_range_prep); |
876bec6f9 vfs: refactor clo... |
1933 |
|
42ec3d4c0 vfs: make remap_f... |
1934 |
loff_t do_clone_file_range(struct file *file_in, loff_t pos_in, |
452ce6595 vfs: plumb remap ... |
1935 1936 |
struct file *file_out, loff_t pos_out, loff_t len, unsigned int remap_flags) |
04b38d601 vfs: pull btrfs c... |
1937 |
{ |
42ec3d4c0 vfs: make remap_f... |
1938 |
loff_t ret; |
04b38d601 vfs: pull btrfs c... |
1939 |
|
6744557b5 vfs: allow some r... |
1940 |
WARN_ON_ONCE(remap_flags & REMAP_FILE_DEDUP); |
04b38d601 vfs: pull btrfs c... |
1941 |
|
913b86e92 vfs: allow vfs_cl... |
1942 1943 1944 1945 1946 |
/* * 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. */ |
a31713517 vfs: introduce ge... |
1947 |
if (file_inode(file_in)->i_sb != file_inode(file_out)->i_sb) |
04b38d601 vfs: pull btrfs c... |
1948 |
return -EXDEV; |
a31713517 vfs: introduce ge... |
1949 1950 1951 |
ret = generic_file_rw_checks(file_in, file_out); if (ret < 0) return ret; |
04b38d601 vfs: pull btrfs c... |
1952 |
|
2e5dfc99f vfs: combine the ... |
1953 |
if (!file_in->f_op->remap_file_range) |
0fcbf996d fs: return -EOPNO... |
1954 |
return -EOPNOTSUPP; |
6095028b4 vfs: rename clone... |
1955 |
ret = remap_verify_area(file_in, pos_in, len, false); |
04b38d601 vfs: pull btrfs c... |
1956 1957 |
if (ret) return ret; |
6095028b4 vfs: rename clone... |
1958 |
ret = remap_verify_area(file_out, pos_out, len, true); |
04b38d601 vfs: pull btrfs c... |
1959 1960 |
if (ret) return ret; |
2e5dfc99f vfs: combine the ... |
1961 |
ret = file_in->f_op->remap_file_range(file_in, pos_in, |
452ce6595 vfs: plumb remap ... |
1962 |
file_out, pos_out, len, remap_flags); |
42ec3d4c0 vfs: make remap_f... |
1963 1964 |
if (ret < 0) return ret; |
04b38d601 vfs: pull btrfs c... |
1965 |
|
42ec3d4c0 vfs: make remap_f... |
1966 1967 |
fsnotify_access(file_in); fsnotify_modify(file_out); |
04b38d601 vfs: pull btrfs c... |
1968 1969 |
return ret; } |
a725356b6 vfs: swap names o... |
1970 |
EXPORT_SYMBOL(do_clone_file_range); |
42ec3d4c0 vfs: make remap_f... |
1971 |
loff_t vfs_clone_file_range(struct file *file_in, loff_t pos_in, |
452ce6595 vfs: plumb remap ... |
1972 1973 |
struct file *file_out, loff_t pos_out, loff_t len, unsigned int remap_flags) |
a725356b6 vfs: swap names o... |
1974 |
{ |
42ec3d4c0 vfs: make remap_f... |
1975 |
loff_t ret; |
a725356b6 vfs: swap names o... |
1976 1977 |
file_start_write(file_out); |
452ce6595 vfs: plumb remap ... |
1978 1979 |
ret = do_clone_file_range(file_in, pos_in, file_out, pos_out, len, remap_flags); |
a725356b6 vfs: swap names o... |
1980 1981 1982 1983 |
file_end_write(file_out); return ret; } |
04b38d601 vfs: pull btrfs c... |
1984 |
EXPORT_SYMBOL(vfs_clone_file_range); |
54dbc1517 vfs: hoist the bt... |
1985 |
|
5de4480ae vfs: allow dedupe... |
1986 1987 1988 1989 1990 1991 1992 1993 1994 1995 1996 1997 1998 |
/* Check whether we are allowed to dedupe the destination file */ static bool allow_file_dedupe(struct file *file) { if (capable(CAP_SYS_ADMIN)) return true; if (file->f_mode & FMODE_WRITE) return true; if (uid_eq(current_fsuid(), file_inode(file)->i_uid)) return true; if (!inode_permission(file_inode(file), MAY_WRITE)) return true; return false; } |
42ec3d4c0 vfs: make remap_f... |
1999 2000 |
loff_t vfs_dedupe_file_range_one(struct file *src_file, loff_t src_pos, struct file *dst_file, loff_t dst_pos, |
df3658361 vfs: plumb remap ... |
2001 |
loff_t len, unsigned int remap_flags) |
1b4f42a1e vfs: dedupe: extr... |
2002 |
{ |
42ec3d4c0 vfs: make remap_f... |
2003 |
loff_t ret; |
1b4f42a1e vfs: dedupe: extr... |
2004 |
|
eca3654e3 vfs: enable remap... |
2005 2006 |
WARN_ON_ONCE(remap_flags & ~(REMAP_FILE_DEDUP | REMAP_FILE_CAN_SHORTEN)); |
1b4f42a1e vfs: dedupe: extr... |
2007 2008 2009 2010 |
ret = mnt_want_write_file(dst_file); if (ret) return ret; |
6095028b4 vfs: rename clone... |
2011 |
ret = remap_verify_area(dst_file, dst_pos, len, true); |
1b4f42a1e vfs: dedupe: extr... |
2012 2013 |
if (ret < 0) goto out_drop_write; |
85c95f208 vfs: dedupe shoul... |
2014 |
ret = -EPERM; |
5de4480ae vfs: allow dedupe... |
2015 |
if (!allow_file_dedupe(dst_file)) |
1b4f42a1e vfs: dedupe: extr... |
2016 2017 2018 2019 2020 2021 2022 2023 2024 2025 2026 |
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; |
2e5dfc99f vfs: combine the ... |
2027 |
if (!dst_file->f_op->remap_file_range) |
1b4f42a1e vfs: dedupe: extr... |
2028 |
goto out_drop_write; |
9aae20500 vfs: skip zero-le... |
2029 2030 2031 2032 |
if (len == 0) { ret = 0; goto out_drop_write; } |
2e5dfc99f vfs: combine the ... |
2033 |
ret = dst_file->f_op->remap_file_range(src_file, src_pos, dst_file, |
df3658361 vfs: plumb remap ... |
2034 |
dst_pos, len, remap_flags | REMAP_FILE_DEDUP); |
1b4f42a1e vfs: dedupe: extr... |
2035 2036 2037 2038 2039 |
out_drop_write: mnt_drop_write_file(dst_file); return ret; } |
f18253668 vfs: export vfs_d... |
2040 |
EXPORT_SYMBOL(vfs_dedupe_file_range_one); |
1b4f42a1e vfs: dedupe: extr... |
2041 |
|
54dbc1517 vfs: hoist the bt... |
2042 2043 2044 2045 2046 2047 2048 2049 |
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; |
54dbc1517 vfs: hoist the bt... |
2050 |
u16 count = same->dest_count; |
42ec3d4c0 vfs: make remap_f... |
2051 |
loff_t deduped; |
54dbc1517 vfs: hoist the bt... |
2052 2053 2054 2055 2056 2057 2058 2059 2060 |
if (!(file->f_mode & FMODE_READ)) return -EINVAL; if (same->reserved1 || same->reserved2) return -EINVAL; off = same->src_offset; len = same->src_length; |
54dbc1517 vfs: hoist the bt... |
2061 |
if (S_ISDIR(src->i_mode)) |
494633fac vfs: vfs_dedupe_f... |
2062 |
return -EISDIR; |
54dbc1517 vfs: hoist the bt... |
2063 |
|
54dbc1517 vfs: hoist the bt... |
2064 |
if (!S_ISREG(src->i_mode)) |
494633fac vfs: vfs_dedupe_f... |
2065 2066 2067 2068 |
return -EINVAL; if (!file->f_op->remap_file_range) return -EOPNOTSUPP; |
54dbc1517 vfs: hoist the bt... |
2069 |
|
6095028b4 vfs: rename clone... |
2070 |
ret = remap_verify_area(file, off, len, false); |
54dbc1517 vfs: hoist the bt... |
2071 |
if (ret < 0) |
494633fac vfs: vfs_dedupe_f... |
2072 |
return ret; |
54dbc1517 vfs: hoist the bt... |
2073 |
ret = 0; |
22725ce4e vfs: fix isize/po... |
2074 2075 |
if (off + len > i_size_read(src)) return -EINVAL; |
92b66d2cd vfs: limit size o... |
2076 2077 |
/* Arbitrary 1G limit on a single dedupe request, can be raised. */ len = min_t(u64, len, 1 << 30); |
54dbc1517 vfs: hoist the bt... |
2078 2079 2080 2081 2082 2083 2084 |
/* 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++) { |
54dbc1517 vfs: hoist the bt... |
2085 |
struct fd dst_fd = fdget(info->dest_fd); |
1b4f42a1e vfs: dedupe: extr... |
2086 |
struct file *dst_file = dst_fd.file; |
54dbc1517 vfs: hoist the bt... |
2087 |
|
54dbc1517 vfs: hoist the bt... |
2088 2089 2090 2091 |
if (!dst_file) { info->status = -EBADF; goto next_loop; } |
54dbc1517 vfs: hoist the bt... |
2092 2093 2094 |
if (info->reserved) { info->status = -EINVAL; |
1b4f42a1e vfs: dedupe: extr... |
2095 |
goto next_fdput; |
54dbc1517 vfs: hoist the bt... |
2096 |
} |
1b4f42a1e vfs: dedupe: extr... |
2097 |
deduped = vfs_dedupe_file_range_one(file, off, dst_file, |
df3658361 vfs: plumb remap ... |
2098 |
info->dest_offset, len, |
eca3654e3 vfs: enable remap... |
2099 |
REMAP_FILE_CAN_SHORTEN); |
1b4f42a1e vfs: dedupe: extr... |
2100 2101 2102 2103 2104 2105 |
if (deduped == -EBADE) info->status = FILE_DEDUPE_RANGE_DIFFERS; else if (deduped < 0) info->status = deduped; else info->bytes_deduped = len; |
227627114 fs: avoid fdput()... |
2106 |
next_fdput: |
54dbc1517 vfs: hoist the bt... |
2107 |
fdput(dst_fd); |
227627114 fs: avoid fdput()... |
2108 |
next_loop: |
e62e560fc vfs: abort dedupe... |
2109 |
if (fatal_signal_pending(current)) |
494633fac vfs: vfs_dedupe_f... |
2110 |
break; |
54dbc1517 vfs: hoist the bt... |
2111 |
} |
54dbc1517 vfs: hoist the bt... |
2112 2113 2114 |
return ret; } EXPORT_SYMBOL(vfs_dedupe_file_range); |