diff options
51 files changed, 450 insertions, 226 deletions
diff --git a/Documentation/filesystems/sysfs.txt b/Documentation/filesystems/sysfs.txt index c8bce82ddcac..89b1d196ca80 100644 --- a/Documentation/filesystems/sysfs.txt +++ b/Documentation/filesystems/sysfs.txt | |||
| @@ -246,6 +246,7 @@ class/ | |||
| 246 | devices/ | 246 | devices/ |
| 247 | firmware/ | 247 | firmware/ |
| 248 | net/ | 248 | net/ |
| 249 | fs/ | ||
| 249 | 250 | ||
| 250 | devices/ contains a filesystem representation of the device tree. It maps | 251 | devices/ contains a filesystem representation of the device tree. It maps |
| 251 | directly to the internal kernel device tree, which is a hierarchy of | 252 | directly to the internal kernel device tree, which is a hierarchy of |
| @@ -264,6 +265,10 @@ drivers/ contains a directory for each device driver that is loaded | |||
| 264 | for devices on that particular bus (this assumes that drivers do not | 265 | for devices on that particular bus (this assumes that drivers do not |
| 265 | span multiple bus types). | 266 | span multiple bus types). |
| 266 | 267 | ||
| 268 | fs/ contains a directory for some filesystems. Currently each | ||
| 269 | filesystem wanting to export attributes must create its own hierarchy | ||
| 270 | below fs/ (see ./fuse.txt for an example). | ||
| 271 | |||
| 267 | 272 | ||
| 268 | More information can driver-model specific features can be found in | 273 | More information can driver-model specific features can be found in |
| 269 | Documentation/driver-model/. | 274 | Documentation/driver-model/. |
| @@ -1,7 +1,7 @@ | |||
| 1 | VERSION = 2 | 1 | VERSION = 2 |
| 2 | PATCHLEVEL = 6 | 2 | PATCHLEVEL = 6 |
| 3 | SUBLEVEL = 17 | 3 | SUBLEVEL = 17 |
| 4 | EXTRAVERSION =-rc2 | 4 | EXTRAVERSION =-rc3 |
| 5 | NAME=Sliding Snow Leopard | 5 | NAME=Sliding Snow Leopard |
| 6 | 6 | ||
| 7 | # *DOCUMENTATION* | 7 | # *DOCUMENTATION* |
diff --git a/arch/arm/Makefile b/arch/arm/Makefile index 95a96275f88a..6f8e84c1c1f2 100644 --- a/arch/arm/Makefile +++ b/arch/arm/Makefile | |||
| @@ -66,7 +66,7 @@ tune-$(CONFIG_CPU_XSC3) :=$(call cc-option,-mtune=xscale,-mtune=strongarm110) - | |||
| 66 | tune-$(CONFIG_CPU_V6) :=$(call cc-option,-mtune=arm1136j-s,-mtune=strongarm) | 66 | tune-$(CONFIG_CPU_V6) :=$(call cc-option,-mtune=arm1136j-s,-mtune=strongarm) |
| 67 | 67 | ||
| 68 | ifeq ($(CONFIG_AEABI),y) | 68 | ifeq ($(CONFIG_AEABI),y) |
| 69 | CFLAGS_ABI :=-mabi=aapcs -mno-thumb-interwork | 69 | CFLAGS_ABI :=-mabi=aapcs-linux -mno-thumb-interwork |
| 70 | else | 70 | else |
| 71 | CFLAGS_ABI :=$(call cc-option,-mapcs-32,-mabi=apcs-gnu) $(call cc-option,-mno-thumb-interwork,) | 71 | CFLAGS_ABI :=$(call cc-option,-mapcs-32,-mabi=apcs-gnu) $(call cc-option,-mno-thumb-interwork,) |
| 72 | endif | 72 | endif |
diff --git a/arch/arm/kernel/Makefile b/arch/arm/kernel/Makefile index 2ce0e3a27a45..a601b8b55f35 100644 --- a/arch/arm/kernel/Makefile +++ b/arch/arm/kernel/Makefile | |||
| @@ -29,7 +29,7 @@ ifneq ($(CONFIG_ARCH_EBSA110),y) | |||
| 29 | obj-y += io.o | 29 | obj-y += io.o |
| 30 | endif | 30 | endif |
| 31 | 31 | ||
| 32 | head-y := head.o | 32 | head-y := head$(MMUEXT).o |
| 33 | obj-$(CONFIG_DEBUG_LL) += debug.o | 33 | obj-$(CONFIG_DEBUG_LL) += debug.o |
| 34 | 34 | ||
| 35 | extra-y := $(head-y) init_task.o vmlinux.lds | 35 | extra-y := $(head-y) init_task.o vmlinux.lds |
diff --git a/arch/arm/kernel/head-nommu.S b/arch/arm/kernel/head-nommu.S index b093ab8738b5..0bea65864051 100644 --- a/arch/arm/kernel/head-nommu.S +++ b/arch/arm/kernel/head-nommu.S | |||
| @@ -20,10 +20,11 @@ | |||
| 20 | #include <asm/mach-types.h> | 20 | #include <asm/mach-types.h> |
| 21 | #include <asm/procinfo.h> | 21 | #include <asm/procinfo.h> |
| 22 | #include <asm/ptrace.h> | 22 | #include <asm/ptrace.h> |
| 23 | #include <asm/constants.h> | 23 | #include <asm/thread_info.h> |
| 24 | #include <asm/system.h> | 24 | #include <asm/system.h> |
| 25 | 25 | ||
| 26 | #define PROCINFO_INITFUNC 12 | 26 | #define PROCINFO_INITFUNC 12 |
| 27 | #define MACHINFO_TYPE 0 | ||
| 27 | 28 | ||
| 28 | /* | 29 | /* |
| 29 | * Kernel startup entry point. | 30 | * Kernel startup entry point. |
| @@ -79,5 +80,6 @@ __after_proc_init: | |||
| 79 | 80 | ||
| 80 | mov pc, r13 @ clear the BSS and jump | 81 | mov pc, r13 @ clear the BSS and jump |
| 81 | @ to start_kernel | 82 | @ to start_kernel |
| 83 | .ltorg | ||
| 82 | 84 | ||
| 83 | #include "head-common.S" | 85 | #include "head-common.S" |
diff --git a/arch/arm/vfp/vfpdouble.c b/arch/arm/vfp/vfpdouble.c index febd115dba28..009038c8113e 100644 --- a/arch/arm/vfp/vfpdouble.c +++ b/arch/arm/vfp/vfpdouble.c | |||
| @@ -197,7 +197,7 @@ u32 vfp_double_normaliseround(int dd, struct vfp_double *vd, u32 fpscr, u32 exce | |||
| 197 | dd, d, exceptions); | 197 | dd, d, exceptions); |
| 198 | vfp_put_double(dd, d); | 198 | vfp_put_double(dd, d); |
| 199 | } | 199 | } |
| 200 | return exceptions & ~VFP_NAN_FLAG; | 200 | return exceptions; |
| 201 | } | 201 | } |
| 202 | 202 | ||
| 203 | /* | 203 | /* |
diff --git a/arch/arm/vfp/vfpmodule.c b/arch/arm/vfp/vfpmodule.c index 22f3da4e0829..37ff8145b5b5 100644 --- a/arch/arm/vfp/vfpmodule.c +++ b/arch/arm/vfp/vfpmodule.c | |||
| @@ -180,7 +180,7 @@ static u32 vfp_emulate_instruction(u32 inst, u32 fpscr, struct pt_regs *regs) | |||
| 180 | * emulate it. | 180 | * emulate it. |
| 181 | */ | 181 | */ |
| 182 | } | 182 | } |
| 183 | return exceptions; | 183 | return exceptions & ~VFP_NAN_FLAG; |
| 184 | } | 184 | } |
| 185 | 185 | ||
| 186 | /* | 186 | /* |
diff --git a/arch/arm/vfp/vfpsingle.c b/arch/arm/vfp/vfpsingle.c index 4ac27f193934..dae2c2f46052 100644 --- a/arch/arm/vfp/vfpsingle.c +++ b/arch/arm/vfp/vfpsingle.c | |||
| @@ -203,7 +203,7 @@ u32 vfp_single_normaliseround(int sd, struct vfp_single *vs, u32 fpscr, u32 exce | |||
| 203 | vfp_put_float(sd, d); | 203 | vfp_put_float(sd, d); |
| 204 | } | 204 | } |
| 205 | 205 | ||
| 206 | return exceptions & ~VFP_NAN_FLAG; | 206 | return exceptions; |
| 207 | } | 207 | } |
| 208 | 208 | ||
| 209 | /* | 209 | /* |
diff --git a/arch/i386/kernel/cpu/intel_cacheinfo.c b/arch/i386/kernel/cpu/intel_cacheinfo.c index 9df87b03612c..c8547a6fa7e6 100644 --- a/arch/i386/kernel/cpu/intel_cacheinfo.c +++ b/arch/i386/kernel/cpu/intel_cacheinfo.c | |||
| @@ -642,7 +642,7 @@ static void __cpuexit cache_remove_dev(struct sys_device * sys_dev) | |||
| 642 | return; | 642 | return; |
| 643 | } | 643 | } |
| 644 | 644 | ||
| 645 | static int __cpuinit cacheinfo_cpu_callback(struct notifier_block *nfb, | 645 | static int cacheinfo_cpu_callback(struct notifier_block *nfb, |
| 646 | unsigned long action, void *hcpu) | 646 | unsigned long action, void *hcpu) |
| 647 | { | 647 | { |
| 648 | unsigned int cpu = (unsigned long)hcpu; | 648 | unsigned int cpu = (unsigned long)hcpu; |
diff --git a/arch/ia64/kernel/entry.S b/arch/ia64/kernel/entry.S index e30798811216..bcb80ca5cf40 100644 --- a/arch/ia64/kernel/entry.S +++ b/arch/ia64/kernel/entry.S | |||
| @@ -1610,5 +1610,6 @@ sys_call_table: | |||
| 1610 | data8 sys_get_robust_list | 1610 | data8 sys_get_robust_list |
| 1611 | data8 sys_sync_file_range // 1300 | 1611 | data8 sys_sync_file_range // 1300 |
| 1612 | data8 sys_tee | 1612 | data8 sys_tee |
| 1613 | data8 sys_vmsplice | ||
| 1613 | 1614 | ||
| 1614 | .org sys_call_table + 8*NR_syscalls // guard against failures to increase NR_syscalls | 1615 | .org sys_call_table + 8*NR_syscalls // guard against failures to increase NR_syscalls |
diff --git a/arch/ia64/kernel/palinfo.c b/arch/ia64/kernel/palinfo.c index 6386f63c413e..859fb37ff49b 100644 --- a/arch/ia64/kernel/palinfo.c +++ b/arch/ia64/kernel/palinfo.c | |||
| @@ -959,7 +959,7 @@ remove_palinfo_proc_entries(unsigned int hcpu) | |||
| 959 | } | 959 | } |
| 960 | } | 960 | } |
| 961 | 961 | ||
| 962 | static int __devinit palinfo_cpu_callback(struct notifier_block *nfb, | 962 | static int palinfo_cpu_callback(struct notifier_block *nfb, |
| 963 | unsigned long action, | 963 | unsigned long action, |
| 964 | void *hcpu) | 964 | void *hcpu) |
| 965 | { | 965 | { |
diff --git a/arch/ia64/kernel/salinfo.c b/arch/ia64/kernel/salinfo.c index 9d5a823479a3..663a186ad194 100644 --- a/arch/ia64/kernel/salinfo.c +++ b/arch/ia64/kernel/salinfo.c | |||
| @@ -572,7 +572,7 @@ static struct file_operations salinfo_data_fops = { | |||
| 572 | }; | 572 | }; |
| 573 | 573 | ||
| 574 | #ifdef CONFIG_HOTPLUG_CPU | 574 | #ifdef CONFIG_HOTPLUG_CPU |
| 575 | static int __devinit | 575 | static int |
| 576 | salinfo_cpu_callback(struct notifier_block *nb, unsigned long action, void *hcpu) | 576 | salinfo_cpu_callback(struct notifier_block *nb, unsigned long action, void *hcpu) |
| 577 | { | 577 | { |
| 578 | unsigned int i, cpu = (unsigned long)hcpu; | 578 | unsigned int i, cpu = (unsigned long)hcpu; |
diff --git a/arch/ia64/kernel/topology.c b/arch/ia64/kernel/topology.c index b47476d655f1..7da4739f536e 100644 --- a/arch/ia64/kernel/topology.c +++ b/arch/ia64/kernel/topology.c | |||
| @@ -429,7 +429,7 @@ static int __cpuinit cache_remove_dev(struct sys_device * sys_dev) | |||
| 429 | * When a cpu is hot-plugged, do a check and initiate | 429 | * When a cpu is hot-plugged, do a check and initiate |
| 430 | * cache kobject if necessary | 430 | * cache kobject if necessary |
| 431 | */ | 431 | */ |
| 432 | static int __cpuinit cache_cpu_callback(struct notifier_block *nfb, | 432 | static int cache_cpu_callback(struct notifier_block *nfb, |
| 433 | unsigned long action, void *hcpu) | 433 | unsigned long action, void *hcpu) |
| 434 | { | 434 | { |
| 435 | unsigned int cpu = (unsigned long)hcpu; | 435 | unsigned int cpu = (unsigned long)hcpu; |
diff --git a/arch/mips/kernel/linux32.c b/arch/mips/kernel/linux32.c index 7c953bcc5f6a..a7d2bb3cf835 100644 --- a/arch/mips/kernel/linux32.c +++ b/arch/mips/kernel/linux32.c | |||
| @@ -356,73 +356,13 @@ asmlinkage int sys32_llseek(unsigned int fd, unsigned int offset_high, | |||
| 356 | asmlinkage ssize_t sys32_pread(unsigned int fd, char __user * buf, | 356 | asmlinkage ssize_t sys32_pread(unsigned int fd, char __user * buf, |
| 357 | size_t count, u32 unused, u64 a4, u64 a5) | 357 | size_t count, u32 unused, u64 a4, u64 a5) |
| 358 | { | 358 | { |
| 359 | ssize_t ret; | 359 | return sys_pread64(fd, buf, count, merge_64(a4, a5)); |
| 360 | struct file * file; | ||
| 361 | ssize_t (*read)(struct file *, char __user *, size_t, loff_t *); | ||
| 362 | loff_t pos; | ||
| 363 | |||
| 364 | ret = -EBADF; | ||
| 365 | file = fget(fd); | ||
| 366 | if (!file) | ||
| 367 | goto bad_file; | ||
| 368 | if (!(file->f_mode & FMODE_READ)) | ||
| 369 | goto out; | ||
| 370 | pos = merge_64(a4, a5); | ||
| 371 | ret = rw_verify_area(READ, file, &pos, count); | ||
| 372 | if (ret < 0) | ||
| 373 | goto out; | ||
| 374 | ret = -EINVAL; | ||
| 375 | if (!file->f_op || !(read = file->f_op->read)) | ||
| 376 | goto out; | ||
| 377 | if (pos < 0) | ||
| 378 | goto out; | ||
| 379 | ret = -ESPIPE; | ||
| 380 | if (!(file->f_mode & FMODE_PREAD)) | ||
| 381 | goto out; | ||
| 382 | ret = read(file, buf, count, &pos); | ||
| 383 | if (ret > 0) | ||
| 384 | dnotify_parent(file->f_dentry, DN_ACCESS); | ||
| 385 | out: | ||
| 386 | fput(file); | ||
| 387 | bad_file: | ||
| 388 | return ret; | ||
| 389 | } | 360 | } |
| 390 | 361 | ||
| 391 | asmlinkage ssize_t sys32_pwrite(unsigned int fd, const char __user * buf, | 362 | asmlinkage ssize_t sys32_pwrite(unsigned int fd, const char __user * buf, |
| 392 | size_t count, u32 unused, u64 a4, u64 a5) | 363 | size_t count, u32 unused, u64 a4, u64 a5) |
| 393 | { | 364 | { |
| 394 | ssize_t ret; | 365 | return sys_pwrite64(fd, buf, count, merge_64(a4, a5)); |
| 395 | struct file * file; | ||
| 396 | ssize_t (*write)(struct file *, const char __user *, size_t, loff_t *); | ||
| 397 | loff_t pos; | ||
| 398 | |||
| 399 | ret = -EBADF; | ||
| 400 | file = fget(fd); | ||
| 401 | if (!file) | ||
| 402 | goto bad_file; | ||
| 403 | if (!(file->f_mode & FMODE_WRITE)) | ||
| 404 | goto out; | ||
| 405 | pos = merge_64(a4, a5); | ||
| 406 | ret = rw_verify_area(WRITE, file, &pos, count); | ||
| 407 | if (ret < 0) | ||
| 408 | goto out; | ||
| 409 | ret = -EINVAL; | ||
| 410 | if (!file->f_op || !(write = file->f_op->write)) | ||
| 411 | goto out; | ||
| 412 | if (pos < 0) | ||
| 413 | goto out; | ||
| 414 | |||
| 415 | ret = -ESPIPE; | ||
| 416 | if (!(file->f_mode & FMODE_PWRITE)) | ||
| 417 | goto out; | ||
| 418 | |||
| 419 | ret = write(file, buf, count, &pos); | ||
| 420 | if (ret > 0) | ||
| 421 | dnotify_parent(file->f_dentry, DN_MODIFY); | ||
| 422 | out: | ||
| 423 | fput(file); | ||
| 424 | bad_file: | ||
| 425 | return ret; | ||
| 426 | } | 366 | } |
| 427 | 367 | ||
| 428 | asmlinkage int sys32_sched_rr_get_interval(compat_pid_t pid, | 368 | asmlinkage int sys32_sched_rr_get_interval(compat_pid_t pid, |
diff --git a/arch/powerpc/kernel/sysfs.c b/arch/powerpc/kernel/sysfs.c index 73560ef6f802..ed737cacf92d 100644 --- a/arch/powerpc/kernel/sysfs.c +++ b/arch/powerpc/kernel/sysfs.c | |||
| @@ -279,7 +279,7 @@ static void unregister_cpu_online(unsigned int cpu) | |||
| 279 | } | 279 | } |
| 280 | #endif /* CONFIG_HOTPLUG_CPU */ | 280 | #endif /* CONFIG_HOTPLUG_CPU */ |
| 281 | 281 | ||
| 282 | static int __devinit sysfs_cpu_notify(struct notifier_block *self, | 282 | static int sysfs_cpu_notify(struct notifier_block *self, |
| 283 | unsigned long action, void *hcpu) | 283 | unsigned long action, void *hcpu) |
| 284 | { | 284 | { |
| 285 | unsigned int cpu = (unsigned int)(long)hcpu; | 285 | unsigned int cpu = (unsigned int)(long)hcpu; |
| @@ -297,7 +297,7 @@ static int __devinit sysfs_cpu_notify(struct notifier_block *self, | |||
| 297 | return NOTIFY_OK; | 297 | return NOTIFY_OK; |
| 298 | } | 298 | } |
| 299 | 299 | ||
| 300 | static struct notifier_block __devinitdata sysfs_cpu_nb = { | 300 | static struct notifier_block sysfs_cpu_nb = { |
| 301 | .notifier_call = sysfs_cpu_notify, | 301 | .notifier_call = sysfs_cpu_notify, |
| 302 | }; | 302 | }; |
| 303 | 303 | ||
diff --git a/arch/powerpc/kernel/systbl.S b/arch/powerpc/kernel/systbl.S index 8d1522690501..0b98eea73c5e 100644 --- a/arch/powerpc/kernel/systbl.S +++ b/arch/powerpc/kernel/systbl.S | |||
| @@ -324,6 +324,7 @@ COMPAT_SYS(ppoll) | |||
| 324 | SYSCALL(unshare) | 324 | SYSCALL(unshare) |
| 325 | SYSCALL(splice) | 325 | SYSCALL(splice) |
| 326 | SYSCALL(tee) | 326 | SYSCALL(tee) |
| 327 | SYSCALL(vmsplice) | ||
| 327 | 328 | ||
| 328 | /* | 329 | /* |
| 329 | * please add new calls to arch/powerpc/platforms/cell/spu_callbacks.c | 330 | * please add new calls to arch/powerpc/platforms/cell/spu_callbacks.c |
diff --git a/arch/powerpc/platforms/cell/spu_callbacks.c b/arch/powerpc/platforms/cell/spu_callbacks.c index deb3afb94484..b283380a2a18 100644 --- a/arch/powerpc/platforms/cell/spu_callbacks.c +++ b/arch/powerpc/platforms/cell/spu_callbacks.c | |||
| @@ -318,6 +318,7 @@ void *spu_syscall_table[] = { | |||
| 318 | [__NR_unshare] sys_unshare, | 318 | [__NR_unshare] sys_unshare, |
| 319 | [__NR_splice] sys_splice, | 319 | [__NR_splice] sys_splice, |
| 320 | [__NR_tee] sys_tee, | 320 | [__NR_tee] sys_tee, |
| 321 | [__NR_vmsplice] sys_vmsplice, | ||
| 321 | }; | 322 | }; |
| 322 | 323 | ||
| 323 | long spu_sys_callback(struct spu_syscall_block *s) | 324 | long spu_sys_callback(struct spu_syscall_block *s) |
diff --git a/arch/s390/appldata/appldata_base.c b/arch/s390/appldata/appldata_base.c index 54d35c130907..9a22434a580c 100644 --- a/arch/s390/appldata/appldata_base.c +++ b/arch/s390/appldata/appldata_base.c | |||
| @@ -652,7 +652,7 @@ appldata_cpu_notify(struct notifier_block *self, | |||
| 652 | return NOTIFY_OK; | 652 | return NOTIFY_OK; |
| 653 | } | 653 | } |
| 654 | 654 | ||
| 655 | static struct notifier_block __devinitdata appldata_nb = { | 655 | static struct notifier_block appldata_nb = { |
| 656 | .notifier_call = appldata_cpu_notify, | 656 | .notifier_call = appldata_cpu_notify, |
| 657 | }; | 657 | }; |
| 658 | 658 | ||
diff --git a/arch/x86_64/kernel/mce.c b/arch/x86_64/kernel/mce.c index 6f0790e8b6d3..c69fc43cee7b 100644 --- a/arch/x86_64/kernel/mce.c +++ b/arch/x86_64/kernel/mce.c | |||
| @@ -629,7 +629,7 @@ static __cpuinit void mce_remove_device(unsigned int cpu) | |||
| 629 | #endif | 629 | #endif |
| 630 | 630 | ||
| 631 | /* Get notified when a cpu comes on/off. Be hotplug friendly. */ | 631 | /* Get notified when a cpu comes on/off. Be hotplug friendly. */ |
| 632 | static __cpuinit int | 632 | static int |
| 633 | mce_cpu_callback(struct notifier_block *nfb, unsigned long action, void *hcpu) | 633 | mce_cpu_callback(struct notifier_block *nfb, unsigned long action, void *hcpu) |
| 634 | { | 634 | { |
| 635 | unsigned int cpu = (unsigned long)hcpu; | 635 | unsigned int cpu = (unsigned long)hcpu; |
diff --git a/arch/x86_64/kernel/mce_amd.c b/arch/x86_64/kernel/mce_amd.c index d3ad7d81266d..d13b241ad094 100644 --- a/arch/x86_64/kernel/mce_amd.c +++ b/arch/x86_64/kernel/mce_amd.c | |||
| @@ -482,7 +482,7 @@ static void threshold_remove_device(unsigned int cpu) | |||
| 482 | #endif | 482 | #endif |
| 483 | 483 | ||
| 484 | /* get notified when a cpu comes on/off */ | 484 | /* get notified when a cpu comes on/off */ |
| 485 | static __cpuinit int threshold_cpu_callback(struct notifier_block *nfb, | 485 | static int threshold_cpu_callback(struct notifier_block *nfb, |
| 486 | unsigned long action, void *hcpu) | 486 | unsigned long action, void *hcpu) |
| 487 | { | 487 | { |
| 488 | /* cpu was unsigned int to begin with */ | 488 | /* cpu was unsigned int to begin with */ |
diff --git a/block/ll_rw_blk.c b/block/ll_rw_blk.c index 1755c053fd68..e5041a02e21f 100644 --- a/block/ll_rw_blk.c +++ b/block/ll_rw_blk.c | |||
| @@ -3385,7 +3385,7 @@ static int blk_cpu_notify(struct notifier_block *self, unsigned long action, | |||
| 3385 | } | 3385 | } |
| 3386 | 3386 | ||
| 3387 | 3387 | ||
| 3388 | static struct notifier_block __devinitdata blk_cpu_notifier = { | 3388 | static struct notifier_block blk_cpu_notifier = { |
| 3389 | .notifier_call = blk_cpu_notify, | 3389 | .notifier_call = blk_cpu_notify, |
| 3390 | }; | 3390 | }; |
| 3391 | 3391 | ||
diff --git a/drivers/base/topology.c b/drivers/base/topology.c index 915810f6237e..8c52421cbc54 100644 --- a/drivers/base/topology.c +++ b/drivers/base/topology.c | |||
| @@ -107,7 +107,7 @@ static int __cpuinit topology_remove_dev(struct sys_device * sys_dev) | |||
| 107 | return 0; | 107 | return 0; |
| 108 | } | 108 | } |
| 109 | 109 | ||
| 110 | static int __cpuinit topology_cpu_callback(struct notifier_block *nfb, | 110 | static int topology_cpu_callback(struct notifier_block *nfb, |
| 111 | unsigned long action, void *hcpu) | 111 | unsigned long action, void *hcpu) |
| 112 | { | 112 | { |
| 113 | unsigned int cpu = (unsigned long)hcpu; | 113 | unsigned int cpu = (unsigned long)hcpu; |
diff --git a/drivers/char/mem.c b/drivers/char/mem.c index 66719f9d294c..1fa9fa157c12 100644 --- a/drivers/char/mem.c +++ b/drivers/char/mem.c | |||
| @@ -27,6 +27,7 @@ | |||
| 27 | #include <linux/crash_dump.h> | 27 | #include <linux/crash_dump.h> |
| 28 | #include <linux/backing-dev.h> | 28 | #include <linux/backing-dev.h> |
| 29 | #include <linux/bootmem.h> | 29 | #include <linux/bootmem.h> |
| 30 | #include <linux/pipe_fs_i.h> | ||
| 30 | 31 | ||
| 31 | #include <asm/uaccess.h> | 32 | #include <asm/uaccess.h> |
| 32 | #include <asm/io.h> | 33 | #include <asm/io.h> |
| @@ -578,6 +579,18 @@ static ssize_t write_null(struct file * file, const char __user * buf, | |||
| 578 | return count; | 579 | return count; |
| 579 | } | 580 | } |
| 580 | 581 | ||
| 582 | static int pipe_to_null(struct pipe_inode_info *info, struct pipe_buffer *buf, | ||
| 583 | struct splice_desc *sd) | ||
| 584 | { | ||
| 585 | return sd->len; | ||
| 586 | } | ||
| 587 | |||
| 588 | static ssize_t splice_write_null(struct pipe_inode_info *pipe,struct file *out, | ||
| 589 | loff_t *ppos, size_t len, unsigned int flags) | ||
| 590 | { | ||
| 591 | return splice_from_pipe(pipe, out, ppos, len, flags, pipe_to_null); | ||
| 592 | } | ||
| 593 | |||
| 581 | #ifdef CONFIG_MMU | 594 | #ifdef CONFIG_MMU |
| 582 | /* | 595 | /* |
| 583 | * For fun, we are using the MMU for this. | 596 | * For fun, we are using the MMU for this. |
| @@ -785,6 +798,7 @@ static struct file_operations null_fops = { | |||
| 785 | .llseek = null_lseek, | 798 | .llseek = null_lseek, |
| 786 | .read = read_null, | 799 | .read = read_null, |
| 787 | .write = write_null, | 800 | .write = write_null, |
| 801 | .splice_write = splice_write_null, | ||
| 788 | }; | 802 | }; |
| 789 | 803 | ||
| 790 | #if defined(CONFIG_ISA) || !defined(__mc68000__) | 804 | #if defined(CONFIG_ISA) || !defined(__mc68000__) |
diff --git a/drivers/cpufreq/cpufreq.c b/drivers/cpufreq/cpufreq.c index 9759d05b1972..29b2fa5534ae 100644 --- a/drivers/cpufreq/cpufreq.c +++ b/drivers/cpufreq/cpufreq.c | |||
| @@ -1497,7 +1497,7 @@ int cpufreq_update_policy(unsigned int cpu) | |||
| 1497 | } | 1497 | } |
| 1498 | EXPORT_SYMBOL(cpufreq_update_policy); | 1498 | EXPORT_SYMBOL(cpufreq_update_policy); |
| 1499 | 1499 | ||
| 1500 | static int __cpuinit cpufreq_cpu_callback(struct notifier_block *nfb, | 1500 | static int cpufreq_cpu_callback(struct notifier_block *nfb, |
| 1501 | unsigned long action, void *hcpu) | 1501 | unsigned long action, void *hcpu) |
| 1502 | { | 1502 | { |
| 1503 | unsigned int cpu = (unsigned long)hcpu; | 1503 | unsigned int cpu = (unsigned long)hcpu; |
diff --git a/drivers/mmc/pxamci.c b/drivers/mmc/pxamci.c index eb9a8826e9b5..eb42cb349420 100644 --- a/drivers/mmc/pxamci.c +++ b/drivers/mmc/pxamci.c | |||
| @@ -65,11 +65,6 @@ struct pxamci_host { | |||
| 65 | unsigned int dma_dir; | 65 | unsigned int dma_dir; |
| 66 | }; | 66 | }; |
| 67 | 67 | ||
| 68 | static inline unsigned int ns_to_clocks(unsigned int ns) | ||
| 69 | { | ||
| 70 | return (ns * (CLOCKRATE / 1000000) + 999) / 1000; | ||
| 71 | } | ||
| 72 | |||
| 73 | static void pxamci_stop_clock(struct pxamci_host *host) | 68 | static void pxamci_stop_clock(struct pxamci_host *host) |
| 74 | { | 69 | { |
| 75 | if (readl(host->base + MMC_STAT) & STAT_CLK_EN) { | 70 | if (readl(host->base + MMC_STAT) & STAT_CLK_EN) { |
| @@ -113,6 +108,7 @@ static void pxamci_disable_irq(struct pxamci_host *host, unsigned int mask) | |||
| 113 | static void pxamci_setup_data(struct pxamci_host *host, struct mmc_data *data) | 108 | static void pxamci_setup_data(struct pxamci_host *host, struct mmc_data *data) |
| 114 | { | 109 | { |
| 115 | unsigned int nob = data->blocks; | 110 | unsigned int nob = data->blocks; |
| 111 | unsigned long long clks; | ||
| 116 | unsigned int timeout; | 112 | unsigned int timeout; |
| 117 | u32 dcmd; | 113 | u32 dcmd; |
| 118 | int i; | 114 | int i; |
| @@ -125,7 +121,9 @@ static void pxamci_setup_data(struct pxamci_host *host, struct mmc_data *data) | |||
| 125 | writel(nob, host->base + MMC_NOB); | 121 | writel(nob, host->base + MMC_NOB); |
| 126 | writel(1 << data->blksz_bits, host->base + MMC_BLKLEN); | 122 | writel(1 << data->blksz_bits, host->base + MMC_BLKLEN); |
| 127 | 123 | ||
| 128 | timeout = ns_to_clocks(data->timeout_ns) + data->timeout_clks; | 124 | clks = (unsigned long long)data->timeout_ns * CLOCKRATE; |
| 125 | do_div(clks, 1000000000UL); | ||
| 126 | timeout = (unsigned int)clks + (data->timeout_clks << host->clkrt); | ||
| 129 | writel((timeout + 255) / 256, host->base + MMC_RDTO); | 127 | writel((timeout + 255) / 256, host->base + MMC_RDTO); |
| 130 | 128 | ||
| 131 | if (data->flags & MMC_DATA_READ) { | 129 | if (data->flags & MMC_DATA_READ) { |
diff --git a/drivers/usb/gadget/inode.c b/drivers/usb/gadget/inode.c index 42b457030b03..0eb010a3f5bc 100644 --- a/drivers/usb/gadget/inode.c +++ b/drivers/usb/gadget/inode.c | |||
| @@ -1614,6 +1614,7 @@ static int activate_ep_files (struct dev_data *dev) | |||
| 1614 | data, &ep_config_operations, | 1614 | data, &ep_config_operations, |
| 1615 | &data->dentry); | 1615 | &data->dentry); |
| 1616 | if (!data->inode) { | 1616 | if (!data->inode) { |
| 1617 | usb_ep_free_request(ep, data->req); | ||
| 1617 | kfree (data); | 1618 | kfree (data); |
| 1618 | goto enomem; | 1619 | goto enomem; |
| 1619 | } | 1620 | } |
diff --git a/fs/compat.c b/fs/compat.c index 7f8e26ea427c..2e32bd340474 100644 --- a/fs/compat.c +++ b/fs/compat.c | |||
| @@ -1217,6 +1217,10 @@ static ssize_t compat_do_readv_writev(int type, struct file *file, | |||
| 1217 | if (ret < 0) | 1217 | if (ret < 0) |
| 1218 | goto out; | 1218 | goto out; |
| 1219 | 1219 | ||
| 1220 | ret = security_file_permission(file, type == READ ? MAY_READ:MAY_WRITE); | ||
| 1221 | if (ret) | ||
| 1222 | goto out; | ||
| 1223 | |||
| 1220 | fnv = NULL; | 1224 | fnv = NULL; |
| 1221 | if (type == READ) { | 1225 | if (type == READ) { |
| 1222 | fn = file->f_op->read; | 1226 | fn = file->f_op->read; |
diff --git a/fs/ext3/ioctl.c b/fs/ext3/ioctl.c index aaf1da17b6d4..8c22aa9a7fbb 100644 --- a/fs/ext3/ioctl.c +++ b/fs/ext3/ioctl.c | |||
| @@ -48,6 +48,7 @@ int ext3_ioctl (struct inode * inode, struct file * filp, unsigned int cmd, | |||
| 48 | if (!S_ISDIR(inode->i_mode)) | 48 | if (!S_ISDIR(inode->i_mode)) |
| 49 | flags &= ~EXT3_DIRSYNC_FL; | 49 | flags &= ~EXT3_DIRSYNC_FL; |
| 50 | 50 | ||
| 51 | mutex_lock(&inode->i_mutex); | ||
| 51 | oldflags = ei->i_flags; | 52 | oldflags = ei->i_flags; |
| 52 | 53 | ||
| 53 | /* The JOURNAL_DATA flag is modifiable only by root */ | 54 | /* The JOURNAL_DATA flag is modifiable only by root */ |
| @@ -60,8 +61,10 @@ int ext3_ioctl (struct inode * inode, struct file * filp, unsigned int cmd, | |||
| 60 | * This test looks nicer. Thanks to Pauline Middelink | 61 | * This test looks nicer. Thanks to Pauline Middelink |
| 61 | */ | 62 | */ |
| 62 | if ((flags ^ oldflags) & (EXT3_APPEND_FL | EXT3_IMMUTABLE_FL)) { | 63 | if ((flags ^ oldflags) & (EXT3_APPEND_FL | EXT3_IMMUTABLE_FL)) { |
| 63 | if (!capable(CAP_LINUX_IMMUTABLE)) | 64 | if (!capable(CAP_LINUX_IMMUTABLE)) { |
| 65 | mutex_unlock(&inode->i_mutex); | ||
| 64 | return -EPERM; | 66 | return -EPERM; |
| 67 | } | ||
| 65 | } | 68 | } |
| 66 | 69 | ||
| 67 | /* | 70 | /* |
| @@ -69,14 +72,18 @@ int ext3_ioctl (struct inode * inode, struct file * filp, unsigned int cmd, | |||
| 69 | * the relevant capability. | 72 | * the relevant capability. |
| 70 | */ | 73 | */ |
| 71 | if ((jflag ^ oldflags) & (EXT3_JOURNAL_DATA_FL)) { | 74 | if ((jflag ^ oldflags) & (EXT3_JOURNAL_DATA_FL)) { |
| 72 | if (!capable(CAP_SYS_RESOURCE)) | 75 | if (!capable(CAP_SYS_RESOURCE)) { |
| 76 | mutex_unlock(&inode->i_mutex); | ||
| 73 | return -EPERM; | 77 | return -EPERM; |
| 78 | } | ||
| 74 | } | 79 | } |
| 75 | 80 | ||
| 76 | 81 | ||
| 77 | handle = ext3_journal_start(inode, 1); | 82 | handle = ext3_journal_start(inode, 1); |
| 78 | if (IS_ERR(handle)) | 83 | if (IS_ERR(handle)) { |
| 84 | mutex_unlock(&inode->i_mutex); | ||
| 79 | return PTR_ERR(handle); | 85 | return PTR_ERR(handle); |
| 86 | } | ||
| 80 | if (IS_SYNC(inode)) | 87 | if (IS_SYNC(inode)) |
| 81 | handle->h_sync = 1; | 88 | handle->h_sync = 1; |
| 82 | err = ext3_reserve_inode_write(handle, inode, &iloc); | 89 | err = ext3_reserve_inode_write(handle, inode, &iloc); |
| @@ -93,11 +100,14 @@ int ext3_ioctl (struct inode * inode, struct file * filp, unsigned int cmd, | |||
| 93 | err = ext3_mark_iloc_dirty(handle, inode, &iloc); | 100 | err = ext3_mark_iloc_dirty(handle, inode, &iloc); |
| 94 | flags_err: | 101 | flags_err: |
| 95 | ext3_journal_stop(handle); | 102 | ext3_journal_stop(handle); |
| 96 | if (err) | 103 | if (err) { |
| 104 | mutex_unlock(&inode->i_mutex); | ||
| 97 | return err; | 105 | return err; |
| 106 | } | ||
| 98 | 107 | ||
| 99 | if ((jflag ^ oldflags) & (EXT3_JOURNAL_DATA_FL)) | 108 | if ((jflag ^ oldflags) & (EXT3_JOURNAL_DATA_FL)) |
| 100 | err = ext3_change_inode_journal_flag(inode, jflag); | 109 | err = ext3_change_inode_journal_flag(inode, jflag); |
| 110 | mutex_unlock(&inode->i_mutex); | ||
| 101 | return err; | 111 | return err; |
| 102 | } | 112 | } |
| 103 | case EXT3_IOC_GETVERSION: | 113 | case EXT3_IOC_GETVERSION: |
diff --git a/fs/ext3/resize.c b/fs/ext3/resize.c index c5ffa8523968..8aac5334680d 100644 --- a/fs/ext3/resize.c +++ b/fs/ext3/resize.c | |||
| @@ -213,7 +213,7 @@ static int setup_new_group_blocks(struct super_block *sb, | |||
| 213 | goto exit_bh; | 213 | goto exit_bh; |
| 214 | } | 214 | } |
| 215 | lock_buffer(bh); | 215 | lock_buffer(bh); |
| 216 | memcpy(gdb->b_data, sbi->s_group_desc[i], bh->b_size); | 216 | memcpy(gdb->b_data, sbi->s_group_desc[i]->b_data, bh->b_size); |
| 217 | set_buffer_uptodate(gdb); | 217 | set_buffer_uptodate(gdb); |
| 218 | unlock_buffer(bh); | 218 | unlock_buffer(bh); |
| 219 | ext3_journal_dirty_metadata(handle, gdb); | 219 | ext3_journal_dirty_metadata(handle, gdb); |
diff --git a/fs/fuse/dev.c b/fs/fuse/dev.c index cc750c68fe70..104a62dadb94 100644 --- a/fs/fuse/dev.c +++ b/fs/fuse/dev.c | |||
| @@ -128,14 +128,24 @@ void fuse_put_request(struct fuse_conn *fc, struct fuse_req *req) | |||
| 128 | } | 128 | } |
| 129 | } | 129 | } |
| 130 | 130 | ||
| 131 | void fuse_remove_background(struct fuse_conn *fc, struct fuse_req *req) | 131 | /* |
| 132 | * Called with sbput_sem held for read (request_end) or write | ||
| 133 | * (fuse_put_super). By the time fuse_put_super() is finished, all | ||
| 134 | * inodes belonging to background requests must be released, so the | ||
| 135 | * iputs have to be done within the locked region. | ||
| 136 | */ | ||
| 137 | void fuse_release_background(struct fuse_conn *fc, struct fuse_req *req) | ||
| 132 | { | 138 | { |
| 133 | list_del_init(&req->bg_entry); | 139 | iput(req->inode); |
| 140 | iput(req->inode2); | ||
| 141 | spin_lock(&fc->lock); | ||
| 142 | list_del(&req->bg_entry); | ||
| 134 | if (fc->num_background == FUSE_MAX_BACKGROUND) { | 143 | if (fc->num_background == FUSE_MAX_BACKGROUND) { |
| 135 | fc->blocked = 0; | 144 | fc->blocked = 0; |
| 136 | wake_up_all(&fc->blocked_waitq); | 145 | wake_up_all(&fc->blocked_waitq); |
| 137 | } | 146 | } |
| 138 | fc->num_background--; | 147 | fc->num_background--; |
| 148 | spin_unlock(&fc->lock); | ||
| 139 | } | 149 | } |
| 140 | 150 | ||
| 141 | /* | 151 | /* |
| @@ -165,27 +175,22 @@ static void request_end(struct fuse_conn *fc, struct fuse_req *req) | |||
| 165 | wake_up(&req->waitq); | 175 | wake_up(&req->waitq); |
| 166 | fuse_put_request(fc, req); | 176 | fuse_put_request(fc, req); |
| 167 | } else { | 177 | } else { |
| 168 | struct inode *inode = req->inode; | ||
| 169 | struct inode *inode2 = req->inode2; | ||
| 170 | struct file *file = req->file; | ||
| 171 | void (*end) (struct fuse_conn *, struct fuse_req *) = req->end; | 178 | void (*end) (struct fuse_conn *, struct fuse_req *) = req->end; |
| 172 | req->end = NULL; | 179 | req->end = NULL; |
| 173 | req->inode = NULL; | ||
| 174 | req->inode2 = NULL; | ||
| 175 | req->file = NULL; | ||
| 176 | if (!list_empty(&req->bg_entry)) | ||
| 177 | fuse_remove_background(fc, req); | ||
| 178 | spin_unlock(&fc->lock); | 180 | spin_unlock(&fc->lock); |
| 181 | down_read(&fc->sbput_sem); | ||
| 182 | if (fc->mounted) | ||
| 183 | fuse_release_background(fc, req); | ||
| 184 | up_read(&fc->sbput_sem); | ||
| 185 | |||
| 186 | /* fput must go outside sbput_sem, otherwise it can deadlock */ | ||
| 187 | if (req->file) | ||
| 188 | fput(req->file); | ||
| 179 | 189 | ||
| 180 | if (end) | 190 | if (end) |
| 181 | end(fc, req); | 191 | end(fc, req); |
| 182 | else | 192 | else |
| 183 | fuse_put_request(fc, req); | 193 | fuse_put_request(fc, req); |
| 184 | |||
| 185 | if (file) | ||
| 186 | fput(file); | ||
| 187 | iput(inode); | ||
| 188 | iput(inode2); | ||
| 189 | } | 194 | } |
| 190 | } | 195 | } |
| 191 | 196 | ||
diff --git a/fs/fuse/fuse_i.h b/fs/fuse/fuse_i.h index 59661c481d9d..0474202cb5dc 100644 --- a/fs/fuse/fuse_i.h +++ b/fs/fuse/fuse_i.h | |||
| @@ -258,9 +258,15 @@ struct fuse_conn { | |||
| 258 | /** waitq for blocked connection */ | 258 | /** waitq for blocked connection */ |
| 259 | wait_queue_head_t blocked_waitq; | 259 | wait_queue_head_t blocked_waitq; |
| 260 | 260 | ||
| 261 | /** RW semaphore for exclusion with fuse_put_super() */ | ||
| 262 | struct rw_semaphore sbput_sem; | ||
| 263 | |||
| 261 | /** The next unique request id */ | 264 | /** The next unique request id */ |
| 262 | u64 reqctr; | 265 | u64 reqctr; |
| 263 | 266 | ||
| 267 | /** Mount is active */ | ||
| 268 | unsigned mounted; | ||
| 269 | |||
| 264 | /** Connection established, cleared on umount, connection | 270 | /** Connection established, cleared on umount, connection |
| 265 | abort and device release */ | 271 | abort and device release */ |
| 266 | unsigned connected; | 272 | unsigned connected; |
| @@ -471,11 +477,11 @@ void request_send_noreply(struct fuse_conn *fc, struct fuse_req *req); | |||
| 471 | void request_send_background(struct fuse_conn *fc, struct fuse_req *req); | 477 | void request_send_background(struct fuse_conn *fc, struct fuse_req *req); |
| 472 | 478 | ||
| 473 | /** | 479 | /** |
| 474 | * Remove request from the the background list | 480 | * Release inodes and file associated with background request |
| 475 | */ | 481 | */ |
| 476 | void fuse_remove_background(struct fuse_conn *fc, struct fuse_req *req); | 482 | void fuse_release_background(struct fuse_conn *fc, struct fuse_req *req); |
| 477 | 483 | ||
| 478 | /** Abort all requests */ | 484 | /* Abort all requests */ |
| 479 | void fuse_abort_conn(struct fuse_conn *fc); | 485 | void fuse_abort_conn(struct fuse_conn *fc); |
| 480 | 486 | ||
| 481 | /** | 487 | /** |
diff --git a/fs/fuse/inode.c b/fs/fuse/inode.c index 43a6fc0db8a7..7627022446b2 100644 --- a/fs/fuse/inode.c +++ b/fs/fuse/inode.c | |||
| @@ -204,26 +204,17 @@ static void fuse_put_super(struct super_block *sb) | |||
| 204 | { | 204 | { |
| 205 | struct fuse_conn *fc = get_fuse_conn_super(sb); | 205 | struct fuse_conn *fc = get_fuse_conn_super(sb); |
| 206 | 206 | ||
| 207 | down_write(&fc->sbput_sem); | ||
| 208 | while (!list_empty(&fc->background)) | ||
| 209 | fuse_release_background(fc, | ||
| 210 | list_entry(fc->background.next, | ||
| 211 | struct fuse_req, bg_entry)); | ||
| 212 | |||
| 207 | spin_lock(&fc->lock); | 213 | spin_lock(&fc->lock); |
| 214 | fc->mounted = 0; | ||
| 208 | fc->connected = 0; | 215 | fc->connected = 0; |
| 209 | while (!list_empty(&fc->background)) { | ||
| 210 | struct fuse_req *req = list_entry(fc->background.next, | ||
| 211 | struct fuse_req, bg_entry); | ||
| 212 | struct inode *inode = req->inode; | ||
| 213 | struct inode *inode2 = req->inode2; | ||
| 214 | |||
| 215 | /* File would hold a reference to vfsmount */ | ||
| 216 | BUG_ON(req->file); | ||
| 217 | req->inode = NULL; | ||
| 218 | req->inode2 = NULL; | ||
| 219 | fuse_remove_background(fc, req); | ||
| 220 | |||
| 221 | spin_unlock(&fc->lock); | ||
| 222 | iput(inode); | ||
| 223 | iput(inode2); | ||
| 224 | spin_lock(&fc->lock); | ||
| 225 | } | ||
| 226 | spin_unlock(&fc->lock); | 216 | spin_unlock(&fc->lock); |
| 217 | up_write(&fc->sbput_sem); | ||
| 227 | /* Flush all readers on this fs */ | 218 | /* Flush all readers on this fs */ |
| 228 | kill_fasync(&fc->fasync, SIGIO, POLL_IN); | 219 | kill_fasync(&fc->fasync, SIGIO, POLL_IN); |
| 229 | wake_up_all(&fc->waitq); | 220 | wake_up_all(&fc->waitq); |
| @@ -395,6 +386,7 @@ static struct fuse_conn *new_conn(void) | |||
| 395 | INIT_LIST_HEAD(&fc->processing); | 386 | INIT_LIST_HEAD(&fc->processing); |
| 396 | INIT_LIST_HEAD(&fc->io); | 387 | INIT_LIST_HEAD(&fc->io); |
| 397 | INIT_LIST_HEAD(&fc->background); | 388 | INIT_LIST_HEAD(&fc->background); |
| 389 | init_rwsem(&fc->sbput_sem); | ||
| 398 | kobj_set_kset_s(fc, connections_subsys); | 390 | kobj_set_kset_s(fc, connections_subsys); |
| 399 | kobject_init(&fc->kobj); | 391 | kobject_init(&fc->kobj); |
| 400 | atomic_set(&fc->num_waiting, 0); | 392 | atomic_set(&fc->num_waiting, 0); |
| @@ -508,11 +500,6 @@ static int fuse_fill_super(struct super_block *sb, void *data, int silent) | |||
| 508 | if (file->f_op != &fuse_dev_operations) | 500 | if (file->f_op != &fuse_dev_operations) |
| 509 | return -EINVAL; | 501 | return -EINVAL; |
| 510 | 502 | ||
| 511 | /* Setting file->private_data can't race with other mount() | ||
| 512 | instances, since BKL is held for ->get_sb() */ | ||
| 513 | if (file->private_data) | ||
| 514 | return -EINVAL; | ||
| 515 | |||
| 516 | fc = new_conn(); | 503 | fc = new_conn(); |
| 517 | if (!fc) | 504 | if (!fc) |
| 518 | return -ENOMEM; | 505 | return -ENOMEM; |
| @@ -548,7 +535,14 @@ static int fuse_fill_super(struct super_block *sb, void *data, int silent) | |||
| 548 | if (err) | 535 | if (err) |
| 549 | goto err_free_req; | 536 | goto err_free_req; |
| 550 | 537 | ||
| 538 | /* Setting file->private_data can't race with other mount() | ||
| 539 | instances, since BKL is held for ->get_sb() */ | ||
| 540 | err = -EINVAL; | ||
| 541 | if (file->private_data) | ||
| 542 | goto err_kobject_del; | ||
| 543 | |||
| 551 | sb->s_root = root_dentry; | 544 | sb->s_root = root_dentry; |
| 545 | fc->mounted = 1; | ||
| 552 | fc->connected = 1; | 546 | fc->connected = 1; |
| 553 | kobject_get(&fc->kobj); | 547 | kobject_get(&fc->kobj); |
| 554 | file->private_data = fc; | 548 | file->private_data = fc; |
| @@ -563,6 +557,8 @@ static int fuse_fill_super(struct super_block *sb, void *data, int silent) | |||
| 563 | 557 | ||
| 564 | return 0; | 558 | return 0; |
| 565 | 559 | ||
| 560 | err_kobject_del: | ||
| 561 | kobject_del(&fc->kobj); | ||
| 566 | err_free_req: | 562 | err_free_req: |
| 567 | fuse_request_free(init_req); | 563 | fuse_request_free(init_req); |
| 568 | err_put_root: | 564 | err_put_root: |
diff --git a/fs/splice.c b/fs/splice.c index 0559e7577a04..447ebc0a37f3 100644 --- a/fs/splice.c +++ b/fs/splice.c | |||
| @@ -27,15 +27,22 @@ | |||
| 27 | #include <linux/buffer_head.h> | 27 | #include <linux/buffer_head.h> |
| 28 | #include <linux/module.h> | 28 | #include <linux/module.h> |
| 29 | #include <linux/syscalls.h> | 29 | #include <linux/syscalls.h> |
| 30 | #include <linux/uio.h> | ||
| 31 | |||
| 32 | struct partial_page { | ||
| 33 | unsigned int offset; | ||
| 34 | unsigned int len; | ||
| 35 | }; | ||
| 30 | 36 | ||
| 31 | /* | 37 | /* |
| 32 | * Passed to the actors | 38 | * Passed to splice_to_pipe |
| 33 | */ | 39 | */ |
| 34 | struct splice_desc { | 40 | struct splice_pipe_desc { |
| 35 | unsigned int len, total_len; /* current and remaining length */ | 41 | struct page **pages; /* page map */ |
| 42 | struct partial_page *partial; /* pages[] may not be contig */ | ||
| 43 | int nr_pages; /* number of pages in map */ | ||
| 36 | unsigned int flags; /* splice flags */ | 44 | unsigned int flags; /* splice flags */ |
| 37 | struct file *file; /* file to read/write */ | 45 | struct pipe_buf_operations *ops;/* ops associated with output pipe */ |
| 38 | loff_t pos; /* file position */ | ||
| 39 | }; | 46 | }; |
| 40 | 47 | ||
| 41 | /* | 48 | /* |
| @@ -128,6 +135,19 @@ static void page_cache_pipe_buf_unmap(struct pipe_inode_info *info, | |||
| 128 | kunmap(buf->page); | 135 | kunmap(buf->page); |
| 129 | } | 136 | } |
| 130 | 137 | ||
| 138 | static void *user_page_pipe_buf_map(struct file *file, | ||
| 139 | struct pipe_inode_info *pipe, | ||
| 140 | struct pipe_buffer *buf) | ||
| 141 | { | ||
| 142 | return kmap(buf->page); | ||
| 143 | } | ||
| 144 | |||
| 145 | static void user_page_pipe_buf_unmap(struct pipe_inode_info *pipe, | ||
| 146 | struct pipe_buffer *buf) | ||
| 147 | { | ||
| 148 | kunmap(buf->page); | ||
| 149 | } | ||
| 150 | |||
| 131 | static void page_cache_pipe_buf_get(struct pipe_inode_info *info, | 151 | static void page_cache_pipe_buf_get(struct pipe_inode_info *info, |
| 132 | struct pipe_buffer *buf) | 152 | struct pipe_buffer *buf) |
| 133 | { | 153 | { |
| @@ -143,19 +163,33 @@ static struct pipe_buf_operations page_cache_pipe_buf_ops = { | |||
| 143 | .get = page_cache_pipe_buf_get, | 163 | .get = page_cache_pipe_buf_get, |
| 144 | }; | 164 | }; |
| 145 | 165 | ||
| 166 | static int user_page_pipe_buf_steal(struct pipe_inode_info *pipe, | ||
| 167 | struct pipe_buffer *buf) | ||
| 168 | { | ||
| 169 | return 1; | ||
| 170 | } | ||
| 171 | |||
| 172 | static struct pipe_buf_operations user_page_pipe_buf_ops = { | ||
| 173 | .can_merge = 0, | ||
| 174 | .map = user_page_pipe_buf_map, | ||
| 175 | .unmap = user_page_pipe_buf_unmap, | ||
| 176 | .release = page_cache_pipe_buf_release, | ||
| 177 | .steal = user_page_pipe_buf_steal, | ||
| 178 | .get = page_cache_pipe_buf_get, | ||
| 179 | }; | ||
| 180 | |||
| 146 | /* | 181 | /* |
| 147 | * Pipe output worker. This sets up our pipe format with the page cache | 182 | * Pipe output worker. This sets up our pipe format with the page cache |
| 148 | * pipe buffer operations. Otherwise very similar to the regular pipe_writev(). | 183 | * pipe buffer operations. Otherwise very similar to the regular pipe_writev(). |
| 149 | */ | 184 | */ |
| 150 | static ssize_t move_to_pipe(struct pipe_inode_info *pipe, struct page **pages, | 185 | static ssize_t splice_to_pipe(struct pipe_inode_info *pipe, |
| 151 | int nr_pages, unsigned long len, | 186 | struct splice_pipe_desc *spd) |
| 152 | unsigned int offset, unsigned int flags) | ||
| 153 | { | 187 | { |
| 154 | int ret, do_wakeup, i; | 188 | int ret, do_wakeup, page_nr; |
| 155 | 189 | ||
| 156 | ret = 0; | 190 | ret = 0; |
| 157 | do_wakeup = 0; | 191 | do_wakeup = 0; |
| 158 | i = 0; | 192 | page_nr = 0; |
| 159 | 193 | ||
| 160 | if (pipe->inode) | 194 | if (pipe->inode) |
| 161 | mutex_lock(&pipe->inode->i_mutex); | 195 | mutex_lock(&pipe->inode->i_mutex); |
| @@ -171,27 +205,19 @@ static ssize_t move_to_pipe(struct pipe_inode_info *pipe, struct page **pages, | |||
| 171 | if (pipe->nrbufs < PIPE_BUFFERS) { | 205 | if (pipe->nrbufs < PIPE_BUFFERS) { |
| 172 | int newbuf = (pipe->curbuf + pipe->nrbufs) & (PIPE_BUFFERS - 1); | 206 | int newbuf = (pipe->curbuf + pipe->nrbufs) & (PIPE_BUFFERS - 1); |
| 173 | struct pipe_buffer *buf = pipe->bufs + newbuf; | 207 | struct pipe_buffer *buf = pipe->bufs + newbuf; |
| 174 | struct page *page = pages[i++]; | ||
| 175 | unsigned long this_len; | ||
| 176 | 208 | ||
| 177 | this_len = PAGE_CACHE_SIZE - offset; | 209 | buf->page = spd->pages[page_nr]; |
| 178 | if (this_len > len) | 210 | buf->offset = spd->partial[page_nr].offset; |
| 179 | this_len = len; | 211 | buf->len = spd->partial[page_nr].len; |
| 180 | 212 | buf->ops = spd->ops; | |
| 181 | buf->page = page; | ||
| 182 | buf->offset = offset; | ||
| 183 | buf->len = this_len; | ||
| 184 | buf->ops = &page_cache_pipe_buf_ops; | ||
| 185 | pipe->nrbufs++; | 213 | pipe->nrbufs++; |
| 214 | page_nr++; | ||
| 215 | ret += buf->len; | ||
| 216 | |||
| 186 | if (pipe->inode) | 217 | if (pipe->inode) |
| 187 | do_wakeup = 1; | 218 | do_wakeup = 1; |
| 188 | 219 | ||
| 189 | ret += this_len; | 220 | if (!--spd->nr_pages) |
| 190 | len -= this_len; | ||
| 191 | offset = 0; | ||
| 192 | if (!--nr_pages) | ||
| 193 | break; | ||
| 194 | if (!len) | ||
| 195 | break; | 221 | break; |
| 196 | if (pipe->nrbufs < PIPE_BUFFERS) | 222 | if (pipe->nrbufs < PIPE_BUFFERS) |
| 197 | continue; | 223 | continue; |
| @@ -199,7 +225,7 @@ static ssize_t move_to_pipe(struct pipe_inode_info *pipe, struct page **pages, | |||
| 199 | break; | 225 | break; |
| 200 | } | 226 | } |
| 201 | 227 | ||
| 202 | if (flags & SPLICE_F_NONBLOCK) { | 228 | if (spd->flags & SPLICE_F_NONBLOCK) { |
| 203 | if (!ret) | 229 | if (!ret) |
| 204 | ret = -EAGAIN; | 230 | ret = -EAGAIN; |
| 205 | break; | 231 | break; |
| @@ -234,8 +260,8 @@ static ssize_t move_to_pipe(struct pipe_inode_info *pipe, struct page **pages, | |||
| 234 | kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); | 260 | kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); |
| 235 | } | 261 | } |
| 236 | 262 | ||
| 237 | while (i < nr_pages) | 263 | while (page_nr < spd->nr_pages) |
| 238 | page_cache_release(pages[i++]); | 264 | page_cache_release(spd->pages[page_nr++]); |
| 239 | 265 | ||
| 240 | return ret; | 266 | return ret; |
| 241 | } | 267 | } |
| @@ -246,17 +272,24 @@ __generic_file_splice_read(struct file *in, loff_t *ppos, | |||
| 246 | unsigned int flags) | 272 | unsigned int flags) |
| 247 | { | 273 | { |
| 248 | struct address_space *mapping = in->f_mapping; | 274 | struct address_space *mapping = in->f_mapping; |
| 249 | unsigned int loff, offset, nr_pages; | 275 | unsigned int loff, nr_pages; |
| 250 | struct page *pages[PIPE_BUFFERS]; | 276 | struct page *pages[PIPE_BUFFERS]; |
| 277 | struct partial_page partial[PIPE_BUFFERS]; | ||
| 251 | struct page *page; | 278 | struct page *page; |
| 252 | pgoff_t index, end_index; | 279 | pgoff_t index, end_index; |
| 253 | loff_t isize; | 280 | loff_t isize; |
| 254 | size_t bytes; | 281 | size_t total_len; |
| 255 | int i, error; | 282 | int error; |
| 283 | struct splice_pipe_desc spd = { | ||
| 284 | .pages = pages, | ||
| 285 | .partial = partial, | ||
| 286 | .flags = flags, | ||
| 287 | .ops = &page_cache_pipe_buf_ops, | ||
| 288 | }; | ||
| 256 | 289 | ||
| 257 | index = *ppos >> PAGE_CACHE_SHIFT; | 290 | index = *ppos >> PAGE_CACHE_SHIFT; |
| 258 | loff = offset = *ppos & ~PAGE_CACHE_MASK; | 291 | loff = *ppos & ~PAGE_CACHE_MASK; |
| 259 | nr_pages = (len + offset + PAGE_CACHE_SIZE - 1) >> PAGE_CACHE_SHIFT; | 292 | nr_pages = (len + loff + PAGE_CACHE_SIZE - 1) >> PAGE_CACHE_SHIFT; |
| 260 | 293 | ||
| 261 | if (nr_pages > PIPE_BUFFERS) | 294 | if (nr_pages > PIPE_BUFFERS) |
| 262 | nr_pages = PIPE_BUFFERS; | 295 | nr_pages = PIPE_BUFFERS; |
| @@ -266,15 +299,15 @@ __generic_file_splice_read(struct file *in, loff_t *ppos, | |||
| 266 | * read-ahead if this is a non-zero offset (we are likely doing small | 299 | * read-ahead if this is a non-zero offset (we are likely doing small |
| 267 | * chunk splice and the page is already there) for a single page. | 300 | * chunk splice and the page is already there) for a single page. |
| 268 | */ | 301 | */ |
| 269 | if (!offset || nr_pages > 1) | 302 | if (!loff || spd.nr_pages > 1) |
| 270 | do_page_cache_readahead(mapping, in, index, nr_pages); | 303 | do_page_cache_readahead(mapping, in, index, spd.nr_pages); |
| 271 | 304 | ||
| 272 | /* | 305 | /* |
| 273 | * Now fill in the holes: | 306 | * Now fill in the holes: |
| 274 | */ | 307 | */ |
| 275 | error = 0; | 308 | error = 0; |
| 276 | bytes = 0; | 309 | total_len = 0; |
| 277 | for (i = 0; i < nr_pages; i++, index++) { | 310 | for (spd.nr_pages = 0; spd.nr_pages < nr_pages; spd.nr_pages++, index++) { |
| 278 | unsigned int this_len; | 311 | unsigned int this_len; |
| 279 | 312 | ||
| 280 | if (!len) | 313 | if (!len) |
| @@ -283,7 +316,7 @@ __generic_file_splice_read(struct file *in, loff_t *ppos, | |||
| 283 | /* | 316 | /* |
| 284 | * this_len is the max we'll use from this page | 317 | * this_len is the max we'll use from this page |
| 285 | */ | 318 | */ |
| 286 | this_len = min(len, PAGE_CACHE_SIZE - loff); | 319 | this_len = min_t(unsigned long, len, PAGE_CACHE_SIZE - loff); |
| 287 | find_page: | 320 | find_page: |
| 288 | /* | 321 | /* |
| 289 | * lookup the page for this index | 322 | * lookup the page for this index |
| @@ -367,26 +400,29 @@ readpage: | |||
| 367 | */ | 400 | */ |
| 368 | if (end_index == index) { | 401 | if (end_index == index) { |
| 369 | loff = PAGE_CACHE_SIZE - (isize & ~PAGE_CACHE_MASK); | 402 | loff = PAGE_CACHE_SIZE - (isize & ~PAGE_CACHE_MASK); |
| 370 | if (bytes + loff > isize) { | 403 | if (total_len + loff > isize) { |
| 371 | page_cache_release(page); | 404 | page_cache_release(page); |
| 372 | break; | 405 | break; |
| 373 | } | 406 | } |
| 374 | /* | 407 | /* |
| 375 | * force quit after adding this page | 408 | * force quit after adding this page |
| 376 | */ | 409 | */ |
| 377 | nr_pages = i; | 410 | nr_pages = spd.nr_pages; |
| 378 | this_len = min(this_len, loff); | 411 | this_len = min(this_len, loff); |
| 412 | loff = 0; | ||
| 379 | } | 413 | } |
| 380 | } | 414 | } |
| 381 | fill_it: | 415 | fill_it: |
| 382 | pages[i] = page; | 416 | pages[spd.nr_pages] = page; |
| 383 | bytes += this_len; | 417 | partial[spd.nr_pages].offset = loff; |
| 418 | partial[spd.nr_pages].len = this_len; | ||
| 384 | len -= this_len; | 419 | len -= this_len; |
| 420 | total_len += this_len; | ||
| 385 | loff = 0; | 421 | loff = 0; |
| 386 | } | 422 | } |
| 387 | 423 | ||
| 388 | if (i) | 424 | if (spd.nr_pages) |
| 389 | return move_to_pipe(pipe, pages, i, bytes, offset, flags); | 425 | return splice_to_pipe(pipe, &spd); |
| 390 | 426 | ||
| 391 | return error; | 427 | return error; |
| 392 | } | 428 | } |
| @@ -439,14 +475,13 @@ EXPORT_SYMBOL(generic_file_splice_read); | |||
| 439 | 475 | ||
| 440 | /* | 476 | /* |
| 441 | * Send 'sd->len' bytes to socket from 'sd->file' at position 'sd->pos' | 477 | * Send 'sd->len' bytes to socket from 'sd->file' at position 'sd->pos' |
| 442 | * using sendpage(). | 478 | * using sendpage(). Return the number of bytes sent. |
| 443 | */ | 479 | */ |
| 444 | static int pipe_to_sendpage(struct pipe_inode_info *info, | 480 | static int pipe_to_sendpage(struct pipe_inode_info *info, |
| 445 | struct pipe_buffer *buf, struct splice_desc *sd) | 481 | struct pipe_buffer *buf, struct splice_desc *sd) |
| 446 | { | 482 | { |
| 447 | struct file *file = sd->file; | 483 | struct file *file = sd->file; |
| 448 | loff_t pos = sd->pos; | 484 | loff_t pos = sd->pos; |
| 449 | unsigned int offset; | ||
| 450 | ssize_t ret; | 485 | ssize_t ret; |
| 451 | void *ptr; | 486 | void *ptr; |
| 452 | int more; | 487 | int more; |
| @@ -461,16 +496,13 @@ static int pipe_to_sendpage(struct pipe_inode_info *info, | |||
| 461 | if (IS_ERR(ptr)) | 496 | if (IS_ERR(ptr)) |
| 462 | return PTR_ERR(ptr); | 497 | return PTR_ERR(ptr); |
| 463 | 498 | ||
| 464 | offset = pos & ~PAGE_CACHE_MASK; | ||
| 465 | more = (sd->flags & SPLICE_F_MORE) || sd->len < sd->total_len; | 499 | more = (sd->flags & SPLICE_F_MORE) || sd->len < sd->total_len; |
| 466 | 500 | ||
| 467 | ret = file->f_op->sendpage(file, buf->page, offset, sd->len, &pos,more); | 501 | ret = file->f_op->sendpage(file, buf->page, buf->offset, sd->len, |
| 502 | &pos, more); | ||
| 468 | 503 | ||
| 469 | buf->ops->unmap(info, buf); | 504 | buf->ops->unmap(info, buf); |
| 470 | if (ret == sd->len) | 505 | return ret; |
| 471 | return 0; | ||
| 472 | |||
| 473 | return -EIO; | ||
| 474 | } | 506 | } |
| 475 | 507 | ||
| 476 | /* | 508 | /* |
| @@ -499,7 +531,7 @@ static int pipe_to_file(struct pipe_inode_info *info, struct pipe_buffer *buf, | |||
| 499 | struct file *file = sd->file; | 531 | struct file *file = sd->file; |
| 500 | struct address_space *mapping = file->f_mapping; | 532 | struct address_space *mapping = file->f_mapping; |
| 501 | gfp_t gfp_mask = mapping_gfp_mask(mapping); | 533 | gfp_t gfp_mask = mapping_gfp_mask(mapping); |
| 502 | unsigned int offset; | 534 | unsigned int offset, this_len; |
| 503 | struct page *page; | 535 | struct page *page; |
| 504 | pgoff_t index; | 536 | pgoff_t index; |
| 505 | char *src; | 537 | char *src; |
| @@ -515,6 +547,10 @@ static int pipe_to_file(struct pipe_inode_info *info, struct pipe_buffer *buf, | |||
| 515 | index = sd->pos >> PAGE_CACHE_SHIFT; | 547 | index = sd->pos >> PAGE_CACHE_SHIFT; |
| 516 | offset = sd->pos & ~PAGE_CACHE_MASK; | 548 | offset = sd->pos & ~PAGE_CACHE_MASK; |
| 517 | 549 | ||
| 550 | this_len = sd->len; | ||
| 551 | if (this_len + offset > PAGE_CACHE_SIZE) | ||
| 552 | this_len = PAGE_CACHE_SIZE - offset; | ||
| 553 | |||
| 518 | /* | 554 | /* |
| 519 | * Reuse buf page, if SPLICE_F_MOVE is set. | 555 | * Reuse buf page, if SPLICE_F_MOVE is set. |
| 520 | */ | 556 | */ |
| @@ -558,7 +594,7 @@ find_page: | |||
| 558 | * the full page. | 594 | * the full page. |
| 559 | */ | 595 | */ |
| 560 | if (!PageUptodate(page)) { | 596 | if (!PageUptodate(page)) { |
| 561 | if (sd->len < PAGE_CACHE_SIZE) { | 597 | if (this_len < PAGE_CACHE_SIZE) { |
| 562 | ret = mapping->a_ops->readpage(file, page); | 598 | ret = mapping->a_ops->readpage(file, page); |
| 563 | if (unlikely(ret)) | 599 | if (unlikely(ret)) |
| 564 | goto out; | 600 | goto out; |
| @@ -582,7 +618,7 @@ find_page: | |||
| 582 | } | 618 | } |
| 583 | } | 619 | } |
| 584 | 620 | ||
| 585 | ret = mapping->a_ops->prepare_write(file, page, 0, sd->len); | 621 | ret = mapping->a_ops->prepare_write(file, page, offset, offset+this_len); |
| 586 | if (ret == AOP_TRUNCATED_PAGE) { | 622 | if (ret == AOP_TRUNCATED_PAGE) { |
| 587 | page_cache_release(page); | 623 | page_cache_release(page); |
| 588 | goto find_page; | 624 | goto find_page; |
| @@ -592,18 +628,22 @@ find_page: | |||
| 592 | if (!(buf->flags & PIPE_BUF_FLAG_STOLEN)) { | 628 | if (!(buf->flags & PIPE_BUF_FLAG_STOLEN)) { |
| 593 | char *dst = kmap_atomic(page, KM_USER0); | 629 | char *dst = kmap_atomic(page, KM_USER0); |
| 594 | 630 | ||
| 595 | memcpy(dst + offset, src + buf->offset, sd->len); | 631 | memcpy(dst + offset, src + buf->offset, this_len); |
| 596 | flush_dcache_page(page); | 632 | flush_dcache_page(page); |
| 597 | kunmap_atomic(dst, KM_USER0); | 633 | kunmap_atomic(dst, KM_USER0); |
| 598 | } | 634 | } |
| 599 | 635 | ||
| 600 | ret = mapping->a_ops->commit_write(file, page, 0, sd->len); | 636 | ret = mapping->a_ops->commit_write(file, page, offset, offset+this_len); |
| 601 | if (ret == AOP_TRUNCATED_PAGE) { | 637 | if (ret == AOP_TRUNCATED_PAGE) { |
| 602 | page_cache_release(page); | 638 | page_cache_release(page); |
| 603 | goto find_page; | 639 | goto find_page; |
| 604 | } else if (ret) | 640 | } else if (ret) |
| 605 | goto out; | 641 | goto out; |
| 606 | 642 | ||
| 643 | /* | ||
| 644 | * Return the number of bytes written. | ||
| 645 | */ | ||
| 646 | ret = this_len; | ||
| 607 | mark_page_accessed(page); | 647 | mark_page_accessed(page); |
| 608 | balance_dirty_pages_ratelimited(mapping); | 648 | balance_dirty_pages_ratelimited(mapping); |
| 609 | out: | 649 | out: |
| @@ -616,17 +656,14 @@ out_nomem: | |||
| 616 | return ret; | 656 | return ret; |
| 617 | } | 657 | } |
| 618 | 658 | ||
| 619 | typedef int (splice_actor)(struct pipe_inode_info *, struct pipe_buffer *, | ||
| 620 | struct splice_desc *); | ||
| 621 | |||
| 622 | /* | 659 | /* |
| 623 | * Pipe input worker. Most of this logic works like a regular pipe, the | 660 | * Pipe input worker. Most of this logic works like a regular pipe, the |
| 624 | * key here is the 'actor' worker passed in that actually moves the data | 661 | * key here is the 'actor' worker passed in that actually moves the data |
| 625 | * to the wanted destination. See pipe_to_file/pipe_to_sendpage above. | 662 | * to the wanted destination. See pipe_to_file/pipe_to_sendpage above. |
| 626 | */ | 663 | */ |
| 627 | static ssize_t move_from_pipe(struct pipe_inode_info *pipe, struct file *out, | 664 | ssize_t splice_from_pipe(struct pipe_inode_info *pipe, struct file *out, |
| 628 | loff_t *ppos, size_t len, unsigned int flags, | 665 | loff_t *ppos, size_t len, unsigned int flags, |
| 629 | splice_actor *actor) | 666 | splice_actor *actor) |
| 630 | { | 667 | { |
| 631 | int ret, do_wakeup, err; | 668 | int ret, do_wakeup, err; |
| 632 | struct splice_desc sd; | 669 | struct splice_desc sd; |
| @@ -652,16 +689,22 @@ static ssize_t move_from_pipe(struct pipe_inode_info *pipe, struct file *out, | |||
| 652 | sd.len = sd.total_len; | 689 | sd.len = sd.total_len; |
| 653 | 690 | ||
| 654 | err = actor(pipe, buf, &sd); | 691 | err = actor(pipe, buf, &sd); |
| 655 | if (err) { | 692 | if (err <= 0) { |
| 656 | if (!ret && err != -ENODATA) | 693 | if (!ret && err != -ENODATA) |
| 657 | ret = err; | 694 | ret = err; |
| 658 | 695 | ||
| 659 | break; | 696 | break; |
| 660 | } | 697 | } |
| 661 | 698 | ||
| 662 | ret += sd.len; | 699 | ret += err; |
| 663 | buf->offset += sd.len; | 700 | buf->offset += err; |
| 664 | buf->len -= sd.len; | 701 | buf->len -= err; |
| 702 | |||
| 703 | sd.len -= err; | ||
| 704 | sd.pos += err; | ||
| 705 | sd.total_len -= err; | ||
| 706 | if (sd.len) | ||
| 707 | continue; | ||
| 665 | 708 | ||
| 666 | if (!buf->len) { | 709 | if (!buf->len) { |
| 667 | buf->ops = NULL; | 710 | buf->ops = NULL; |
| @@ -672,8 +715,6 @@ static ssize_t move_from_pipe(struct pipe_inode_info *pipe, struct file *out, | |||
| 672 | do_wakeup = 1; | 715 | do_wakeup = 1; |
| 673 | } | 716 | } |
| 674 | 717 | ||
| 675 | sd.pos += sd.len; | ||
| 676 | sd.total_len -= sd.len; | ||
| 677 | if (!sd.total_len) | 718 | if (!sd.total_len) |
| 678 | break; | 719 | break; |
| 679 | } | 720 | } |
| @@ -741,7 +782,7 @@ generic_file_splice_write(struct pipe_inode_info *pipe, struct file *out, | |||
| 741 | struct address_space *mapping = out->f_mapping; | 782 | struct address_space *mapping = out->f_mapping; |
| 742 | ssize_t ret; | 783 | ssize_t ret; |
| 743 | 784 | ||
| 744 | ret = move_from_pipe(pipe, out, ppos, len, flags, pipe_to_file); | 785 | ret = splice_from_pipe(pipe, out, ppos, len, flags, pipe_to_file); |
| 745 | if (ret > 0) { | 786 | if (ret > 0) { |
| 746 | struct inode *inode = mapping->host; | 787 | struct inode *inode = mapping->host; |
| 747 | 788 | ||
| @@ -783,7 +824,7 @@ EXPORT_SYMBOL(generic_file_splice_write); | |||
| 783 | ssize_t generic_splice_sendpage(struct pipe_inode_info *pipe, struct file *out, | 824 | ssize_t generic_splice_sendpage(struct pipe_inode_info *pipe, struct file *out, |
| 784 | loff_t *ppos, size_t len, unsigned int flags) | 825 | loff_t *ppos, size_t len, unsigned int flags) |
| 785 | { | 826 | { |
| 786 | return move_from_pipe(pipe, out, ppos, len, flags, pipe_to_sendpage); | 827 | return splice_from_pipe(pipe, out, ppos, len, flags, pipe_to_sendpage); |
| 787 | } | 828 | } |
| 788 | 829 | ||
| 789 | EXPORT_SYMBOL(generic_splice_sendpage); | 830 | EXPORT_SYMBOL(generic_splice_sendpage); |
| @@ -870,7 +911,7 @@ long do_splice_direct(struct file *in, loff_t *ppos, struct file *out, | |||
| 870 | 911 | ||
| 871 | /* | 912 | /* |
| 872 | * We don't have an immediate reader, but we'll read the stuff | 913 | * We don't have an immediate reader, but we'll read the stuff |
| 873 | * out of the pipe right after the move_to_pipe(). So set | 914 | * out of the pipe right after the splice_to_pipe(). So set |
| 874 | * PIPE_READERS appropriately. | 915 | * PIPE_READERS appropriately. |
| 875 | */ | 916 | */ |
| 876 | pipe->readers = 1; | 917 | pipe->readers = 1; |
| @@ -1010,6 +1051,174 @@ static long do_splice(struct file *in, loff_t __user *off_in, | |||
| 1010 | return -EINVAL; | 1051 | return -EINVAL; |
| 1011 | } | 1052 | } |
| 1012 | 1053 | ||
| 1054 | /* | ||
| 1055 | * Map an iov into an array of pages and offset/length tupples. With the | ||
| 1056 | * partial_page structure, we can map several non-contiguous ranges into | ||
| 1057 | * our ones pages[] map instead of splitting that operation into pieces. | ||
| 1058 | * Could easily be exported as a generic helper for other users, in which | ||
| 1059 | * case one would probably want to add a 'max_nr_pages' parameter as well. | ||
| 1060 | */ | ||
| 1061 | static int get_iovec_page_array(const struct iovec __user *iov, | ||
| 1062 | unsigned int nr_vecs, struct page **pages, | ||
| 1063 | struct partial_page *partial) | ||
| 1064 | { | ||
| 1065 | int buffers = 0, error = 0; | ||
| 1066 | |||
| 1067 | /* | ||
| 1068 | * It's ok to take the mmap_sem for reading, even | ||
| 1069 | * across a "get_user()". | ||
| 1070 | */ | ||
| 1071 | down_read(¤t->mm->mmap_sem); | ||
| 1072 | |||
| 1073 | while (nr_vecs) { | ||
| 1074 | unsigned long off, npages; | ||
| 1075 | void __user *base; | ||
| 1076 | size_t len; | ||
| 1077 | int i; | ||
| 1078 | |||
| 1079 | /* | ||
| 1080 | * Get user address base and length for this iovec. | ||
| 1081 | */ | ||
| 1082 | error = get_user(base, &iov->iov_base); | ||
| 1083 | if (unlikely(error)) | ||
| 1084 | break; | ||
| 1085 | error = get_user(len, &iov->iov_len); | ||
| 1086 | if (unlikely(error)) | ||
| 1087 | break; | ||
| 1088 | |||
| 1089 | /* | ||
| 1090 | * Sanity check this iovec. 0 read succeeds. | ||
| 1091 | */ | ||
| 1092 | if (unlikely(!len)) | ||
| 1093 | break; | ||
| 1094 | error = -EFAULT; | ||
| 1095 | if (unlikely(!base)) | ||
| 1096 | break; | ||
| 1097 | |||
| 1098 | /* | ||
| 1099 | * Get this base offset and number of pages, then map | ||
| 1100 | * in the user pages. | ||
| 1101 | */ | ||
| 1102 | off = (unsigned long) base & ~PAGE_MASK; | ||
| 1103 | npages = (off + len + PAGE_SIZE - 1) >> PAGE_SHIFT; | ||
| 1104 | if (npages > PIPE_BUFFERS - buffers) | ||
| 1105 | npages = PIPE_BUFFERS - buffers; | ||
| 1106 | |||
| 1107 | error = get_user_pages(current, current->mm, | ||
| 1108 | (unsigned long) base, npages, 0, 0, | ||
| 1109 | &pages[buffers], NULL); | ||
| 1110 | |||
| 1111 | if (unlikely(error <= 0)) | ||
| 1112 | break; | ||
| 1113 | |||
| 1114 | /* | ||
| 1115 | * Fill this contiguous range into the partial page map. | ||
| 1116 | */ | ||
| 1117 | for (i = 0; i < error; i++) { | ||
| 1118 | const int plen = min_t(size_t, len, PAGE_SIZE) - off; | ||
| 1119 | |||
| 1120 | partial[buffers].offset = off; | ||
| 1121 | partial[buffers].len = plen; | ||
| 1122 | |||
| 1123 | off = 0; | ||
| 1124 | len -= plen; | ||
| 1125 | buffers++; | ||
| 1126 | } | ||
| 1127 | |||
| 1128 | /* | ||
| 1129 | * We didn't complete this iov, stop here since it probably | ||
| 1130 | * means we have to move some of this into a pipe to | ||
| 1131 | * be able to continue. | ||
| 1132 | */ | ||
| 1133 | if (len) | ||
| 1134 | break; | ||
| 1135 | |||
| 1136 | /* | ||
| 1137 | * Don't continue if we mapped fewer pages than we asked for, | ||
| 1138 | * or if we mapped the max number of pages that we have | ||
| 1139 | * room for. | ||
| 1140 | */ | ||
| 1141 | if (error < npages || buffers == PIPE_BUFFERS) | ||
| 1142 | break; | ||
| 1143 | |||
| 1144 | nr_vecs--; | ||
| 1145 | iov++; | ||
| 1146 | } | ||
| 1147 | |||
| 1148 | up_read(¤t->mm->mmap_sem); | ||
| 1149 | |||
| 1150 | if (buffers) | ||
| 1151 | return buffers; | ||
| 1152 | |||
| 1153 | return error; | ||
| 1154 | } | ||
| 1155 | |||
| 1156 | /* | ||
| 1157 | * vmsplice splices a user address range into a pipe. It can be thought of | ||
| 1158 | * as splice-from-memory, where the regular splice is splice-from-file (or | ||
| 1159 | * to file). In both cases the output is a pipe, naturally. | ||
| 1160 | * | ||
| 1161 | * Note that vmsplice only supports splicing _from_ user memory to a pipe, | ||
| 1162 | * not the other way around. Splicing from user memory is a simple operation | ||
| 1163 | * that can be supported without any funky alignment restrictions or nasty | ||
| 1164 | * vm tricks. We simply map in the user memory and fill them into a pipe. | ||
| 1165 | * The reverse isn't quite as easy, though. There are two possible solutions | ||
| 1166 | * for that: | ||
| 1167 | * | ||
| 1168 | * - memcpy() the data internally, at which point we might as well just | ||
| 1169 | * do a regular read() on the buffer anyway. | ||
| 1170 | * - Lots of nasty vm tricks, that are neither fast nor flexible (it | ||
| 1171 | * has restriction limitations on both ends of the pipe). | ||
| 1172 | * | ||
| 1173 | * Alas, it isn't here. | ||
| 1174 | * | ||
| 1175 | */ | ||
| 1176 | static long do_vmsplice(struct file *file, const struct iovec __user *iov, | ||
| 1177 | unsigned long nr_segs, unsigned int flags) | ||
| 1178 | { | ||
| 1179 | struct pipe_inode_info *pipe = file->f_dentry->d_inode->i_pipe; | ||
| 1180 | struct page *pages[PIPE_BUFFERS]; | ||
| 1181 | struct partial_page partial[PIPE_BUFFERS]; | ||
| 1182 | struct splice_pipe_desc spd = { | ||
| 1183 | .pages = pages, | ||
| 1184 | .partial = partial, | ||
| 1185 | .flags = flags, | ||
| 1186 | .ops = &user_page_pipe_buf_ops, | ||
| 1187 | }; | ||
| 1188 | |||
| 1189 | if (unlikely(!pipe)) | ||
| 1190 | return -EBADF; | ||
| 1191 | if (unlikely(nr_segs > UIO_MAXIOV)) | ||
| 1192 | return -EINVAL; | ||
| 1193 | else if (unlikely(!nr_segs)) | ||
| 1194 | return 0; | ||
| 1195 | |||
| 1196 | spd.nr_pages = get_iovec_page_array(iov, nr_segs, pages, partial); | ||
| 1197 | if (spd.nr_pages <= 0) | ||
| 1198 | return spd.nr_pages; | ||
| 1199 | |||
| 1200 | return splice_to_pipe(pipe, &spd); | ||
| 1201 | } | ||
| 1202 | |||
| 1203 | asmlinkage long sys_vmsplice(int fd, const struct iovec __user *iov, | ||
| 1204 | unsigned long nr_segs, unsigned int flags) | ||
| 1205 | { | ||
| 1206 | struct file *file; | ||
| 1207 | long error; | ||
| 1208 | int fput; | ||
| 1209 | |||
| 1210 | error = -EBADF; | ||
| 1211 | file = fget_light(fd, &fput); | ||
| 1212 | if (file) { | ||
| 1213 | if (file->f_mode & FMODE_WRITE) | ||
| 1214 | error = do_vmsplice(file, iov, nr_segs, flags); | ||
| 1215 | |||
| 1216 | fput_light(file, fput); | ||
| 1217 | } | ||
| 1218 | |||
| 1219 | return error; | ||
| 1220 | } | ||
| 1221 | |||
| 1013 | asmlinkage long sys_splice(int fd_in, loff_t __user *off_in, | 1222 | asmlinkage long sys_splice(int fd_in, loff_t __user *off_in, |
| 1014 | int fd_out, loff_t __user *off_out, | 1223 | int fd_out, loff_t __user *off_out, |
| 1015 | size_t len, unsigned int flags) | 1224 | size_t len, unsigned int flags) |
diff --git a/include/asm-i386/unistd.h b/include/asm-i386/unistd.h index d81d6cfc1bb4..eb4b152c82fc 100644 --- a/include/asm-i386/unistd.h +++ b/include/asm-i386/unistd.h | |||
| @@ -321,8 +321,9 @@ | |||
| 321 | #define __NR_splice 313 | 321 | #define __NR_splice 313 |
| 322 | #define __NR_sync_file_range 314 | 322 | #define __NR_sync_file_range 314 |
| 323 | #define __NR_tee 315 | 323 | #define __NR_tee 315 |
| 324 | #define __NR_vmsplice 316 | ||
| 324 | 325 | ||
| 325 | #define NR_syscalls 316 | 326 | #define NR_syscalls 317 |
| 326 | 327 | ||
| 327 | /* | 328 | /* |
| 328 | * user-visible error numbers are in the range -1 - -128: see | 329 | * user-visible error numbers are in the range -1 - -128: see |
diff --git a/include/asm-ia64/unistd.h b/include/asm-ia64/unistd.h index a40ebec6aeeb..7107763168bf 100644 --- a/include/asm-ia64/unistd.h +++ b/include/asm-ia64/unistd.h | |||
| @@ -290,12 +290,13 @@ | |||
| 290 | #define __NR_get_robust_list 1299 | 290 | #define __NR_get_robust_list 1299 |
| 291 | #define __NR_sync_file_range 1300 | 291 | #define __NR_sync_file_range 1300 |
| 292 | #define __NR_tee 1301 | 292 | #define __NR_tee 1301 |
| 293 | #define __NR_vmsplice 1302 | ||
| 293 | 294 | ||
| 294 | #ifdef __KERNEL__ | 295 | #ifdef __KERNEL__ |
| 295 | 296 | ||
| 296 | #include <linux/config.h> | 297 | #include <linux/config.h> |
| 297 | 298 | ||
| 298 | #define NR_syscalls 278 /* length of syscall table */ | 299 | #define NR_syscalls 279 /* length of syscall table */ |
| 299 | 300 | ||
| 300 | #define __ARCH_WANT_SYS_RT_SIGACTION | 301 | #define __ARCH_WANT_SYS_RT_SIGACTION |
| 301 | 302 | ||
diff --git a/include/asm-powerpc/unistd.h b/include/asm-powerpc/unistd.h index c612f1a62772..34325e292596 100644 --- a/include/asm-powerpc/unistd.h +++ b/include/asm-powerpc/unistd.h | |||
| @@ -303,8 +303,9 @@ | |||
| 303 | #define __NR_unshare 282 | 303 | #define __NR_unshare 282 |
| 304 | #define __NR_splice 283 | 304 | #define __NR_splice 283 |
| 305 | #define __NR_tee 284 | 305 | #define __NR_tee 284 |
| 306 | #define __NR_vmsplice 285 | ||
| 306 | 307 | ||
| 307 | #define __NR_syscalls 285 | 308 | #define __NR_syscalls 286 |
| 308 | 309 | ||
| 309 | #ifdef __KERNEL__ | 310 | #ifdef __KERNEL__ |
| 310 | #define __NR__exit __NR_exit | 311 | #define __NR__exit __NR_exit |
diff --git a/include/asm-x86_64/unistd.h b/include/asm-x86_64/unistd.h index 98c36eae567c..feb77cb8c044 100644 --- a/include/asm-x86_64/unistd.h +++ b/include/asm-x86_64/unistd.h | |||
| @@ -615,8 +615,10 @@ __SYSCALL(__NR_splice, sys_splice) | |||
| 615 | __SYSCALL(__NR_tee, sys_tee) | 615 | __SYSCALL(__NR_tee, sys_tee) |
| 616 | #define __NR_sync_file_range 277 | 616 | #define __NR_sync_file_range 277 |
| 617 | __SYSCALL(__NR_sync_file_range, sys_sync_file_range) | 617 | __SYSCALL(__NR_sync_file_range, sys_sync_file_range) |
| 618 | #define __NR_vmsplice 278 | ||
| 619 | __SYSCALL(__NR_vmsplice, sys_vmsplice) | ||
| 618 | 620 | ||
| 619 | #define __NR_syscall_max __NR_sync_file_range | 621 | #define __NR_syscall_max __NR_vmsplice |
| 620 | 622 | ||
| 621 | #ifndef __NO_STUBS | 623 | #ifndef __NO_STUBS |
| 622 | 624 | ||
diff --git a/include/linux/pipe_fs_i.h b/include/linux/pipe_fs_i.h index ef7f33c0be19..0008d4bd4059 100644 --- a/include/linux/pipe_fs_i.h +++ b/include/linux/pipe_fs_i.h | |||
| @@ -61,4 +61,21 @@ void __free_pipe_info(struct pipe_inode_info *); | |||
| 61 | /* from/to, of course */ | 61 | /* from/to, of course */ |
| 62 | #define SPLICE_F_MORE (0x04) /* expect more data */ | 62 | #define SPLICE_F_MORE (0x04) /* expect more data */ |
| 63 | 63 | ||
| 64 | /* | ||
| 65 | * Passed to the actors | ||
| 66 | */ | ||
| 67 | struct splice_desc { | ||
| 68 | unsigned int len, total_len; /* current and remaining length */ | ||
| 69 | unsigned int flags; /* splice flags */ | ||
| 70 | struct file *file; /* file to read/write */ | ||
| 71 | loff_t pos; /* file position */ | ||
| 72 | }; | ||
| 73 | |||
| 74 | typedef int (splice_actor)(struct pipe_inode_info *, struct pipe_buffer *, | ||
| 75 | struct splice_desc *); | ||
| 76 | |||
| 77 | extern ssize_t splice_from_pipe(struct pipe_inode_info *, struct file *, | ||
| 78 | loff_t *, size_t, unsigned int, | ||
| 79 | splice_actor *); | ||
| 80 | |||
| 64 | #endif | 81 | #endif |
diff --git a/include/linux/syscalls.h b/include/linux/syscalls.h index d3ebc0e68b2b..3996960fc565 100644 --- a/include/linux/syscalls.h +++ b/include/linux/syscalls.h | |||
| @@ -574,6 +574,9 @@ asmlinkage long sys_splice(int fd_in, loff_t __user *off_in, | |||
| 574 | int fd_out, loff_t __user *off_out, | 574 | int fd_out, loff_t __user *off_out, |
| 575 | size_t len, unsigned int flags); | 575 | size_t len, unsigned int flags); |
| 576 | 576 | ||
| 577 | asmlinkage long sys_vmsplice(int fd, const struct iovec __user *iov, | ||
| 578 | unsigned long nr_segs, unsigned int flags); | ||
| 579 | |||
| 577 | asmlinkage long sys_tee(int fdin, int fdout, size_t len, unsigned int flags); | 580 | asmlinkage long sys_tee(int fdin, int fdout, size_t len, unsigned int flags); |
| 578 | 581 | ||
| 579 | asmlinkage long sys_sync_file_range(int fd, loff_t offset, loff_t nbytes, | 582 | asmlinkage long sys_sync_file_range(int fd, loff_t offset, loff_t nbytes, |
diff --git a/kernel/hrtimer.c b/kernel/hrtimer.c index d2a7296c8251..b7f0388bd71c 100644 --- a/kernel/hrtimer.c +++ b/kernel/hrtimer.c | |||
| @@ -836,7 +836,7 @@ static void migrate_hrtimers(int cpu) | |||
| 836 | } | 836 | } |
| 837 | #endif /* CONFIG_HOTPLUG_CPU */ | 837 | #endif /* CONFIG_HOTPLUG_CPU */ |
| 838 | 838 | ||
| 839 | static int __devinit hrtimer_cpu_notify(struct notifier_block *self, | 839 | static int hrtimer_cpu_notify(struct notifier_block *self, |
| 840 | unsigned long action, void *hcpu) | 840 | unsigned long action, void *hcpu) |
| 841 | { | 841 | { |
| 842 | long cpu = (long)hcpu; | 842 | long cpu = (long)hcpu; |
| @@ -860,7 +860,7 @@ static int __devinit hrtimer_cpu_notify(struct notifier_block *self, | |||
| 860 | return NOTIFY_OK; | 860 | return NOTIFY_OK; |
| 861 | } | 861 | } |
| 862 | 862 | ||
| 863 | static struct notifier_block __devinitdata hrtimers_nb = { | 863 | static struct notifier_block hrtimers_nb = { |
| 864 | .notifier_call = hrtimer_cpu_notify, | 864 | .notifier_call = hrtimer_cpu_notify, |
| 865 | }; | 865 | }; |
| 866 | 866 | ||
diff --git a/kernel/profile.c b/kernel/profile.c index 5a730fdb1a2c..68afe121e507 100644 --- a/kernel/profile.c +++ b/kernel/profile.c | |||
| @@ -299,7 +299,7 @@ out: | |||
| 299 | } | 299 | } |
| 300 | 300 | ||
| 301 | #ifdef CONFIG_HOTPLUG_CPU | 301 | #ifdef CONFIG_HOTPLUG_CPU |
| 302 | static int __devinit profile_cpu_callback(struct notifier_block *info, | 302 | static int profile_cpu_callback(struct notifier_block *info, |
| 303 | unsigned long action, void *__cpu) | 303 | unsigned long action, void *__cpu) |
| 304 | { | 304 | { |
| 305 | int node, cpu = (unsigned long)__cpu; | 305 | int node, cpu = (unsigned long)__cpu; |
diff --git a/kernel/rcupdate.c b/kernel/rcupdate.c index 13458bbaa1be..6d32ff26f948 100644 --- a/kernel/rcupdate.c +++ b/kernel/rcupdate.c | |||
| @@ -520,7 +520,7 @@ static void __devinit rcu_online_cpu(int cpu) | |||
| 520 | tasklet_init(&per_cpu(rcu_tasklet, cpu), rcu_process_callbacks, 0UL); | 520 | tasklet_init(&per_cpu(rcu_tasklet, cpu), rcu_process_callbacks, 0UL); |
| 521 | } | 521 | } |
| 522 | 522 | ||
| 523 | static int __devinit rcu_cpu_notify(struct notifier_block *self, | 523 | static int rcu_cpu_notify(struct notifier_block *self, |
| 524 | unsigned long action, void *hcpu) | 524 | unsigned long action, void *hcpu) |
| 525 | { | 525 | { |
| 526 | long cpu = (long)hcpu; | 526 | long cpu = (long)hcpu; |
| @@ -537,7 +537,7 @@ static int __devinit rcu_cpu_notify(struct notifier_block *self, | |||
| 537 | return NOTIFY_OK; | 537 | return NOTIFY_OK; |
| 538 | } | 538 | } |
| 539 | 539 | ||
| 540 | static struct notifier_block __devinitdata rcu_nb = { | 540 | static struct notifier_block rcu_nb = { |
| 541 | .notifier_call = rcu_cpu_notify, | 541 | .notifier_call = rcu_cpu_notify, |
| 542 | }; | 542 | }; |
| 543 | 543 | ||
diff --git a/kernel/sched.c b/kernel/sched.c index 365f0b90b4de..4c64f85698ae 100644 --- a/kernel/sched.c +++ b/kernel/sched.c | |||
| @@ -4814,7 +4814,7 @@ static int migration_call(struct notifier_block *nfb, unsigned long action, | |||
| 4814 | /* Register at highest priority so that task migration (migrate_all_tasks) | 4814 | /* Register at highest priority so that task migration (migrate_all_tasks) |
| 4815 | * happens before everything else. | 4815 | * happens before everything else. |
| 4816 | */ | 4816 | */ |
| 4817 | static struct notifier_block __devinitdata migration_notifier = { | 4817 | static struct notifier_block migration_notifier = { |
| 4818 | .notifier_call = migration_call, | 4818 | .notifier_call = migration_call, |
| 4819 | .priority = 10 | 4819 | .priority = 10 |
| 4820 | }; | 4820 | }; |
diff --git a/kernel/softirq.c b/kernel/softirq.c index ec8fed42a86f..336f92d64e2e 100644 --- a/kernel/softirq.c +++ b/kernel/softirq.c | |||
| @@ -446,7 +446,7 @@ static void takeover_tasklets(unsigned int cpu) | |||
| 446 | } | 446 | } |
| 447 | #endif /* CONFIG_HOTPLUG_CPU */ | 447 | #endif /* CONFIG_HOTPLUG_CPU */ |
| 448 | 448 | ||
| 449 | static int __devinit cpu_callback(struct notifier_block *nfb, | 449 | static int cpu_callback(struct notifier_block *nfb, |
| 450 | unsigned long action, | 450 | unsigned long action, |
| 451 | void *hcpu) | 451 | void *hcpu) |
| 452 | { | 452 | { |
| @@ -484,7 +484,7 @@ static int __devinit cpu_callback(struct notifier_block *nfb, | |||
| 484 | return NOTIFY_OK; | 484 | return NOTIFY_OK; |
| 485 | } | 485 | } |
| 486 | 486 | ||
| 487 | static struct notifier_block __devinitdata cpu_nfb = { | 487 | static struct notifier_block cpu_nfb = { |
| 488 | .notifier_call = cpu_callback | 488 | .notifier_call = cpu_callback |
| 489 | }; | 489 | }; |
| 490 | 490 | ||
diff --git a/kernel/softlockup.c b/kernel/softlockup.c index ced91e1ff564..14c7faf02909 100644 --- a/kernel/softlockup.c +++ b/kernel/softlockup.c | |||
| @@ -104,7 +104,7 @@ static int watchdog(void * __bind_cpu) | |||
| 104 | /* | 104 | /* |
| 105 | * Create/destroy watchdog threads as CPUs come and go: | 105 | * Create/destroy watchdog threads as CPUs come and go: |
| 106 | */ | 106 | */ |
| 107 | static int __devinit | 107 | static int |
| 108 | cpu_callback(struct notifier_block *nfb, unsigned long action, void *hcpu) | 108 | cpu_callback(struct notifier_block *nfb, unsigned long action, void *hcpu) |
| 109 | { | 109 | { |
| 110 | int hotcpu = (unsigned long)hcpu; | 110 | int hotcpu = (unsigned long)hcpu; |
| @@ -140,7 +140,7 @@ cpu_callback(struct notifier_block *nfb, unsigned long action, void *hcpu) | |||
| 140 | return NOTIFY_OK; | 140 | return NOTIFY_OK; |
| 141 | } | 141 | } |
| 142 | 142 | ||
| 143 | static struct notifier_block __devinitdata cpu_nfb = { | 143 | static struct notifier_block cpu_nfb = { |
| 144 | .notifier_call = cpu_callback | 144 | .notifier_call = cpu_callback |
| 145 | }; | 145 | }; |
| 146 | 146 | ||
diff --git a/kernel/timer.c b/kernel/timer.c index 883773788836..67eaf0f54096 100644 --- a/kernel/timer.c +++ b/kernel/timer.c | |||
| @@ -1314,7 +1314,7 @@ static void __devinit migrate_timers(int cpu) | |||
| 1314 | } | 1314 | } |
| 1315 | #endif /* CONFIG_HOTPLUG_CPU */ | 1315 | #endif /* CONFIG_HOTPLUG_CPU */ |
| 1316 | 1316 | ||
| 1317 | static int __devinit timer_cpu_notify(struct notifier_block *self, | 1317 | static int timer_cpu_notify(struct notifier_block *self, |
| 1318 | unsigned long action, void *hcpu) | 1318 | unsigned long action, void *hcpu) |
| 1319 | { | 1319 | { |
| 1320 | long cpu = (long)hcpu; | 1320 | long cpu = (long)hcpu; |
| @@ -1334,7 +1334,7 @@ static int __devinit timer_cpu_notify(struct notifier_block *self, | |||
| 1334 | return NOTIFY_OK; | 1334 | return NOTIFY_OK; |
| 1335 | } | 1335 | } |
| 1336 | 1336 | ||
| 1337 | static struct notifier_block __devinitdata timers_nb = { | 1337 | static struct notifier_block timers_nb = { |
| 1338 | .notifier_call = timer_cpu_notify, | 1338 | .notifier_call = timer_cpu_notify, |
| 1339 | }; | 1339 | }; |
| 1340 | 1340 | ||
diff --git a/kernel/workqueue.c b/kernel/workqueue.c index e9e464a90376..880fb415a8f6 100644 --- a/kernel/workqueue.c +++ b/kernel/workqueue.c | |||
| @@ -547,7 +547,7 @@ static void take_over_work(struct workqueue_struct *wq, unsigned int cpu) | |||
| 547 | } | 547 | } |
| 548 | 548 | ||
| 549 | /* We're holding the cpucontrol mutex here */ | 549 | /* We're holding the cpucontrol mutex here */ |
| 550 | static int __devinit workqueue_cpu_callback(struct notifier_block *nfb, | 550 | static int workqueue_cpu_callback(struct notifier_block *nfb, |
| 551 | unsigned long action, | 551 | unsigned long action, |
| 552 | void *hcpu) | 552 | void *hcpu) |
| 553 | { | 553 | { |
diff --git a/mm/page_alloc.c b/mm/page_alloc.c index 123c60586740..ea77c999047e 100644 --- a/mm/page_alloc.c +++ b/mm/page_alloc.c | |||
| @@ -1962,7 +1962,7 @@ static inline void free_zone_pagesets(int cpu) | |||
| 1962 | } | 1962 | } |
| 1963 | } | 1963 | } |
| 1964 | 1964 | ||
| 1965 | static int __cpuinit pageset_cpuup_callback(struct notifier_block *nfb, | 1965 | static int pageset_cpuup_callback(struct notifier_block *nfb, |
| 1966 | unsigned long action, | 1966 | unsigned long action, |
| 1967 | void *hcpu) | 1967 | void *hcpu) |
| 1968 | { | 1968 | { |
| @@ -1036,7 +1036,7 @@ static inline void free_alien_cache(struct array_cache **ac_ptr) | |||
| 1036 | 1036 | ||
| 1037 | #endif | 1037 | #endif |
| 1038 | 1038 | ||
| 1039 | static int __devinit cpuup_callback(struct notifier_block *nfb, | 1039 | static int cpuup_callback(struct notifier_block *nfb, |
| 1040 | unsigned long action, void *hcpu) | 1040 | unsigned long action, void *hcpu) |
| 1041 | { | 1041 | { |
| 1042 | long cpu = (long)hcpu; | 1042 | long cpu = (long)hcpu; |
diff --git a/mm/vmscan.c b/mm/vmscan.c index acdf001d6941..4649a63a8cb6 100644 --- a/mm/vmscan.c +++ b/mm/vmscan.c | |||
| @@ -1328,7 +1328,7 @@ repeat: | |||
| 1328 | not required for correctness. So if the last cpu in a node goes | 1328 | not required for correctness. So if the last cpu in a node goes |
| 1329 | away, we get changed to run anywhere: as the first one comes back, | 1329 | away, we get changed to run anywhere: as the first one comes back, |
| 1330 | restore their cpu bindings. */ | 1330 | restore their cpu bindings. */ |
| 1331 | static int __devinit cpu_callback(struct notifier_block *nfb, | 1331 | static int cpu_callback(struct notifier_block *nfb, |
| 1332 | unsigned long action, void *hcpu) | 1332 | unsigned long action, void *hcpu) |
| 1333 | { | 1333 | { |
| 1334 | pg_data_t *pgdat; | 1334 | pg_data_t *pgdat; |
diff --git a/net/bridge/br_forward.c b/net/bridge/br_forward.c index 2d24fb400e0c..56f3aa47e758 100644 --- a/net/bridge/br_forward.c +++ b/net/bridge/br_forward.c | |||
| @@ -16,6 +16,7 @@ | |||
| 16 | #include <linux/kernel.h> | 16 | #include <linux/kernel.h> |
| 17 | #include <linux/netdevice.h> | 17 | #include <linux/netdevice.h> |
| 18 | #include <linux/skbuff.h> | 18 | #include <linux/skbuff.h> |
| 19 | #include <linux/if_vlan.h> | ||
| 19 | #include <linux/netfilter_bridge.h> | 20 | #include <linux/netfilter_bridge.h> |
| 20 | #include "br_private.h" | 21 | #include "br_private.h" |
| 21 | 22 | ||
| @@ -29,10 +30,15 @@ static inline int should_deliver(const struct net_bridge_port *p, | |||
| 29 | return 1; | 30 | return 1; |
| 30 | } | 31 | } |
| 31 | 32 | ||
| 33 | static inline unsigned packet_length(const struct sk_buff *skb) | ||
| 34 | { | ||
| 35 | return skb->len - (skb->protocol == htons(ETH_P_8021Q) ? VLAN_HLEN : 0); | ||
| 36 | } | ||
| 37 | |||
| 32 | int br_dev_queue_push_xmit(struct sk_buff *skb) | 38 | int br_dev_queue_push_xmit(struct sk_buff *skb) |
| 33 | { | 39 | { |
| 34 | /* drop mtu oversized packets except tso */ | 40 | /* drop mtu oversized packets except tso */ |
| 35 | if (skb->len > skb->dev->mtu && !skb_shinfo(skb)->tso_size) | 41 | if (packet_length(skb) > skb->dev->mtu && !skb_shinfo(skb)->tso_size) |
| 36 | kfree_skb(skb); | 42 | kfree_skb(skb); |
| 37 | else { | 43 | else { |
| 38 | #ifdef CONFIG_BRIDGE_NETFILTER | 44 | #ifdef CONFIG_BRIDGE_NETFILTER |
