diff options
author | Linus Torvalds <torvalds@linux-foundation.org> | 2009-01-09 16:56:06 -0500 |
---|---|---|
committer | Linus Torvalds <torvalds@linux-foundation.org> | 2009-01-09 16:56:06 -0500 |
commit | 7d671f3e713fc5ff18a5227a8dc16dfdb8bc0664 (patch) | |
tree | 07b7bb776eb2c3d4f5944ae81661f85de62984e1 | |
parent | d7d717fa889fc7a60c38497846c7618940a999d9 (diff) | |
parent | 555d61d6542d51563e50532ff604dcd31c96fb24 (diff) |
Merge branch 'for-linus' of git://git390.osdl.marist.edu/pub/scm/linux-2.6
* 'for-linus' of git://git390.osdl.marist.edu/pub/scm/linux-2.6:
[S390] update documentation for hvc_iucv kernel parameter.
[S390] hvc_iucv: Special handling of IUCV HVC devices
[S390] hvc_iucv: Refactor console and device initialization
[S390] hvc_iucv: Update function documentation
[S390] hvc_iucv: Limit rate of outgoing IUCV messages
[S390] hvc_iucv: Change IUCV term id and use one device as default
[S390] Use unsigned long long for u64 on 64bit.
[S390] qdio: fix broken pointer in case of CONFIG_DEBUG_FS is disabled
[S390] vdso: compile fix
[S390] remove code for oldselect system call
[S390] types: add/fix types.h include in header files
[S390] dasd: add device attribute to disable blocking on lost paths
[S390] dasd: send change uevents for dasd block devices
[S390] tape block: fix dependencies
[S390] asm-s390/posix_types.h: drop __USE_ALL usage
[S390] gettimeofday.S: removed duplicated #includes
[S390] ptrace: no extern declarations for userspace
28 files changed, 376 insertions, 203 deletions
diff --git a/Documentation/kernel-parameters.txt b/Documentation/kernel-parameters.txt index fcc48bf722a8..8511d3532c27 100644 --- a/Documentation/kernel-parameters.txt +++ b/Documentation/kernel-parameters.txt | |||
@@ -834,8 +834,8 @@ and is between 256 and 4096 characters. It is defined in the file | |||
834 | 834 | ||
835 | hlt [BUGS=ARM,SH] | 835 | hlt [BUGS=ARM,SH] |
836 | 836 | ||
837 | hvc_iucv= [S390] Number of z/VM IUCV Hypervisor console (HVC) | 837 | hvc_iucv= [S390] Number of z/VM IUCV hypervisor console (HVC) |
838 | back-ends. Valid parameters: 0..8 | 838 | terminal devices. Valid values: 0..8 |
839 | 839 | ||
840 | i8042.debug [HW] Toggle i8042 debug mode | 840 | i8042.debug [HW] Toggle i8042 debug mode |
841 | i8042.direct [HW] Put keyboard port into non-translated mode | 841 | i8042.direct [HW] Put keyboard port into non-translated mode |
diff --git a/arch/s390/include/asm/chpid.h b/arch/s390/include/asm/chpid.h index dfe3c7f3439a..fc71d8a6709b 100644 --- a/arch/s390/include/asm/chpid.h +++ b/arch/s390/include/asm/chpid.h | |||
@@ -9,7 +9,7 @@ | |||
9 | #define _ASM_S390_CHPID_H _ASM_S390_CHPID_H | 9 | #define _ASM_S390_CHPID_H _ASM_S390_CHPID_H |
10 | 10 | ||
11 | #include <linux/string.h> | 11 | #include <linux/string.h> |
12 | #include <asm/types.h> | 12 | #include <linux/types.h> |
13 | 13 | ||
14 | #define __MAX_CHPID 255 | 14 | #define __MAX_CHPID 255 |
15 | 15 | ||
diff --git a/arch/s390/include/asm/chsc.h b/arch/s390/include/asm/chsc.h index d38d0cf62d4b..807997f7414b 100644 --- a/arch/s390/include/asm/chsc.h +++ b/arch/s390/include/asm/chsc.h | |||
@@ -8,6 +8,7 @@ | |||
8 | #ifndef _ASM_CHSC_H | 8 | #ifndef _ASM_CHSC_H |
9 | #define _ASM_CHSC_H | 9 | #define _ASM_CHSC_H |
10 | 10 | ||
11 | #include <linux/types.h> | ||
11 | #include <asm/chpid.h> | 12 | #include <asm/chpid.h> |
12 | #include <asm/schid.h> | 13 | #include <asm/schid.h> |
13 | 14 | ||
diff --git a/arch/s390/include/asm/cmb.h b/arch/s390/include/asm/cmb.h index 50196857d27a..39ae03294794 100644 --- a/arch/s390/include/asm/cmb.h +++ b/arch/s390/include/asm/cmb.h | |||
@@ -1,5 +1,8 @@ | |||
1 | #ifndef S390_CMB_H | 1 | #ifndef S390_CMB_H |
2 | #define S390_CMB_H | 2 | #define S390_CMB_H |
3 | |||
4 | #include <linux/types.h> | ||
5 | |||
3 | /** | 6 | /** |
4 | * struct cmbdata - channel measurement block data for user space | 7 | * struct cmbdata - channel measurement block data for user space |
5 | * @size: size of the stored data | 8 | * @size: size of the stored data |
diff --git a/arch/s390/include/asm/dasd.h b/arch/s390/include/asm/dasd.h index 55b2b80cdf6e..e2db6f16d9c8 100644 --- a/arch/s390/include/asm/dasd.h +++ b/arch/s390/include/asm/dasd.h | |||
@@ -14,6 +14,7 @@ | |||
14 | 14 | ||
15 | #ifndef DASD_H | 15 | #ifndef DASD_H |
16 | #define DASD_H | 16 | #define DASD_H |
17 | #include <linux/types.h> | ||
17 | #include <linux/ioctl.h> | 18 | #include <linux/ioctl.h> |
18 | 19 | ||
19 | #define DASD_IOCTL_LETTER 'D' | 20 | #define DASD_IOCTL_LETTER 'D' |
@@ -78,6 +79,7 @@ typedef struct dasd_information2_t { | |||
78 | #define DASD_FEATURE_USEDIAG 0x02 | 79 | #define DASD_FEATURE_USEDIAG 0x02 |
79 | #define DASD_FEATURE_INITIAL_ONLINE 0x04 | 80 | #define DASD_FEATURE_INITIAL_ONLINE 0x04 |
80 | #define DASD_FEATURE_ERPLOG 0x08 | 81 | #define DASD_FEATURE_ERPLOG 0x08 |
82 | #define DASD_FEATURE_FAILFAST 0x10 | ||
81 | 83 | ||
82 | #define DASD_PARTN_BITS 2 | 84 | #define DASD_PARTN_BITS 2 |
83 | 85 | ||
diff --git a/arch/s390/include/asm/kvm.h b/arch/s390/include/asm/kvm.h index d74002f95794..e1f54654e3ae 100644 --- a/arch/s390/include/asm/kvm.h +++ b/arch/s390/include/asm/kvm.h | |||
@@ -13,7 +13,7 @@ | |||
13 | * Author(s): Carsten Otte <cotte@de.ibm.com> | 13 | * Author(s): Carsten Otte <cotte@de.ibm.com> |
14 | * Christian Borntraeger <borntraeger@de.ibm.com> | 14 | * Christian Borntraeger <borntraeger@de.ibm.com> |
15 | */ | 15 | */ |
16 | #include <asm/types.h> | 16 | #include <linux/types.h> |
17 | 17 | ||
18 | /* for KVM_GET_IRQCHIP and KVM_SET_IRQCHIP */ | 18 | /* for KVM_GET_IRQCHIP and KVM_SET_IRQCHIP */ |
19 | struct kvm_pic_state { | 19 | struct kvm_pic_state { |
diff --git a/arch/s390/include/asm/posix_types.h b/arch/s390/include/asm/posix_types.h index 397d93fba3a7..8cc113f92523 100644 --- a/arch/s390/include/asm/posix_types.h +++ b/arch/s390/include/asm/posix_types.h | |||
@@ -68,11 +68,7 @@ typedef unsigned short __kernel_old_dev_t; | |||
68 | #endif /* __s390x__ */ | 68 | #endif /* __s390x__ */ |
69 | 69 | ||
70 | typedef struct { | 70 | typedef struct { |
71 | #if defined(__KERNEL__) || defined(__USE_ALL) | ||
72 | int val[2]; | 71 | int val[2]; |
73 | #else /* !defined(__KERNEL__) && !defined(__USE_ALL)*/ | ||
74 | int __val[2]; | ||
75 | #endif /* !defined(__KERNEL__) && !defined(__USE_ALL)*/ | ||
76 | } __kernel_fsid_t; | 72 | } __kernel_fsid_t; |
77 | 73 | ||
78 | 74 | ||
diff --git a/arch/s390/include/asm/ptrace.h b/arch/s390/include/asm/ptrace.h index 5396f9f12263..8920025c3c02 100644 --- a/arch/s390/include/asm/ptrace.h +++ b/arch/s390/include/asm/ptrace.h | |||
@@ -272,12 +272,15 @@ typedef struct | |||
272 | #define PSW_ASC_SECONDARY 0x0000800000000000UL | 272 | #define PSW_ASC_SECONDARY 0x0000800000000000UL |
273 | #define PSW_ASC_HOME 0x0000C00000000000UL | 273 | #define PSW_ASC_HOME 0x0000C00000000000UL |
274 | 274 | ||
275 | extern long psw_user32_bits; | ||
276 | |||
277 | #endif /* __s390x__ */ | 275 | #endif /* __s390x__ */ |
278 | 276 | ||
277 | #ifdef __KERNEL__ | ||
279 | extern long psw_kernel_bits; | 278 | extern long psw_kernel_bits; |
280 | extern long psw_user_bits; | 279 | extern long psw_user_bits; |
280 | #ifdef CONFIG_64BIT | ||
281 | extern long psw_user32_bits; | ||
282 | #endif | ||
283 | #endif | ||
281 | 284 | ||
282 | /* This macro merges a NEW PSW mask specified by the user into | 285 | /* This macro merges a NEW PSW mask specified by the user into |
283 | the currently active PSW mask CURRENT, modifying only those | 286 | the currently active PSW mask CURRENT, modifying only those |
diff --git a/arch/s390/include/asm/qeth.h b/arch/s390/include/asm/qeth.h index 930d378ef75a..06cbd1e8c943 100644 --- a/arch/s390/include/asm/qeth.h +++ b/arch/s390/include/asm/qeth.h | |||
@@ -10,6 +10,7 @@ | |||
10 | */ | 10 | */ |
11 | #ifndef __ASM_S390_QETH_IOCTL_H__ | 11 | #ifndef __ASM_S390_QETH_IOCTL_H__ |
12 | #define __ASM_S390_QETH_IOCTL_H__ | 12 | #define __ASM_S390_QETH_IOCTL_H__ |
13 | #include <linux/types.h> | ||
13 | #include <linux/ioctl.h> | 14 | #include <linux/ioctl.h> |
14 | 15 | ||
15 | #define SIOC_QETH_ARP_SET_NO_ENTRIES (SIOCDEVPRIVATE) | 16 | #define SIOC_QETH_ARP_SET_NO_ENTRIES (SIOCDEVPRIVATE) |
diff --git a/arch/s390/include/asm/schid.h b/arch/s390/include/asm/schid.h index 825503cf3dc2..3e4d401b4e45 100644 --- a/arch/s390/include/asm/schid.h +++ b/arch/s390/include/asm/schid.h | |||
@@ -1,6 +1,8 @@ | |||
1 | #ifndef ASM_SCHID_H | 1 | #ifndef ASM_SCHID_H |
2 | #define ASM_SCHID_H | 2 | #define ASM_SCHID_H |
3 | 3 | ||
4 | #include <linux/types.h> | ||
5 | |||
4 | struct subchannel_id { | 6 | struct subchannel_id { |
5 | __u32 cssid : 8; | 7 | __u32 cssid : 8; |
6 | __u32 : 4; | 8 | __u32 : 4; |
diff --git a/arch/s390/include/asm/swab.h b/arch/s390/include/asm/swab.h index bd9321aa55a9..eb18dc1f327b 100644 --- a/arch/s390/include/asm/swab.h +++ b/arch/s390/include/asm/swab.h | |||
@@ -9,7 +9,7 @@ | |||
9 | * Author(s): Martin Schwidefsky (schwidefsky@de.ibm.com) | 9 | * Author(s): Martin Schwidefsky (schwidefsky@de.ibm.com) |
10 | */ | 10 | */ |
11 | 11 | ||
12 | #include <asm/types.h> | 12 | #include <linux/types.h> |
13 | 13 | ||
14 | #ifndef __s390x__ | 14 | #ifndef __s390x__ |
15 | # define __SWAB_64_THRU_32__ | 15 | # define __SWAB_64_THRU_32__ |
diff --git a/arch/s390/include/asm/types.h b/arch/s390/include/asm/types.h index 41c547656130..3dc3fc228812 100644 --- a/arch/s390/include/asm/types.h +++ b/arch/s390/include/asm/types.h | |||
@@ -9,11 +9,7 @@ | |||
9 | #ifndef _S390_TYPES_H | 9 | #ifndef _S390_TYPES_H |
10 | #define _S390_TYPES_H | 10 | #define _S390_TYPES_H |
11 | 11 | ||
12 | #ifndef __s390x__ | 12 | #include <asm-generic/int-ll64.h> |
13 | # include <asm-generic/int-ll64.h> | ||
14 | #else | ||
15 | # include <asm-generic/int-l64.h> | ||
16 | #endif | ||
17 | 13 | ||
18 | #ifndef __ASSEMBLY__ | 14 | #ifndef __ASSEMBLY__ |
19 | 15 | ||
diff --git a/arch/s390/kernel/entry.h b/arch/s390/kernel/entry.h index 6b1896345eda..a65afc91e8aa 100644 --- a/arch/s390/kernel/entry.h +++ b/arch/s390/kernel/entry.h | |||
@@ -54,7 +54,5 @@ long sys_sigreturn(void); | |||
54 | long sys_rt_sigreturn(void); | 54 | long sys_rt_sigreturn(void); |
55 | long sys32_sigreturn(void); | 55 | long sys32_sigreturn(void); |
56 | long sys32_rt_sigreturn(void); | 56 | long sys32_rt_sigreturn(void); |
57 | long old_select(struct sel_arg_struct __user *arg); | ||
58 | long sys_ptrace(long request, long pid, long addr, long data); | ||
59 | 57 | ||
60 | #endif /* _ENTRY_H */ | 58 | #endif /* _ENTRY_H */ |
diff --git a/arch/s390/kernel/smp.c b/arch/s390/kernel/smp.c index 9c0ccb532a45..2d337cbb9329 100644 --- a/arch/s390/kernel/smp.c +++ b/arch/s390/kernel/smp.c | |||
@@ -685,7 +685,8 @@ void __init smp_prepare_cpus(unsigned int max_cpus) | |||
685 | if (MACHINE_HAS_IEEE) | 685 | if (MACHINE_HAS_IEEE) |
686 | lowcore->extended_save_area_addr = (u32) save_area; | 686 | lowcore->extended_save_area_addr = (u32) save_area; |
687 | #else | 687 | #else |
688 | BUG_ON(vdso_alloc_per_cpu(smp_processor_id(), lowcore)); | 688 | if (vdso_alloc_per_cpu(smp_processor_id(), lowcore)) |
689 | BUG(); | ||
689 | #endif | 690 | #endif |
690 | set_prefix((u32)(unsigned long) lowcore); | 691 | set_prefix((u32)(unsigned long) lowcore); |
691 | local_mcck_enable(); | 692 | local_mcck_enable(); |
diff --git a/arch/s390/kernel/sys_s390.c b/arch/s390/kernel/sys_s390.c index 4fe952e557ac..c34be4568b80 100644 --- a/arch/s390/kernel/sys_s390.c +++ b/arch/s390/kernel/sys_s390.c | |||
@@ -103,25 +103,6 @@ out: | |||
103 | return error; | 103 | return error; |
104 | } | 104 | } |
105 | 105 | ||
106 | #ifndef CONFIG_64BIT | ||
107 | struct sel_arg_struct { | ||
108 | unsigned long n; | ||
109 | fd_set __user *inp, *outp, *exp; | ||
110 | struct timeval __user *tvp; | ||
111 | }; | ||
112 | |||
113 | asmlinkage long old_select(struct sel_arg_struct __user *arg) | ||
114 | { | ||
115 | struct sel_arg_struct a; | ||
116 | |||
117 | if (copy_from_user(&a, arg, sizeof(a))) | ||
118 | return -EFAULT; | ||
119 | /* sys_select() does the appropriate kernel locking */ | ||
120 | return sys_select(a.n, a.inp, a.outp, a.exp, a.tvp); | ||
121 | |||
122 | } | ||
123 | #endif /* CONFIG_64BIT */ | ||
124 | |||
125 | /* | 106 | /* |
126 | * sys_ipc() is the de-multiplexer for the SysV IPC calls.. | 107 | * sys_ipc() is the de-multiplexer for the SysV IPC calls.. |
127 | * | 108 | * |
diff --git a/arch/s390/kernel/vdso.c b/arch/s390/kernel/vdso.c index 25a6a82f1c02..690e17819686 100644 --- a/arch/s390/kernel/vdso.c +++ b/arch/s390/kernel/vdso.c | |||
@@ -322,7 +322,8 @@ static int __init vdso_init(void) | |||
322 | vdso64_pagelist[vdso64_pages - 1] = virt_to_page(vdso_data); | 322 | vdso64_pagelist[vdso64_pages - 1] = virt_to_page(vdso_data); |
323 | vdso64_pagelist[vdso64_pages] = NULL; | 323 | vdso64_pagelist[vdso64_pages] = NULL; |
324 | #ifndef CONFIG_SMP | 324 | #ifndef CONFIG_SMP |
325 | BUG_ON(vdso_alloc_per_cpu(0, S390_lowcore)); | 325 | if (vdso_alloc_per_cpu(0, &S390_lowcore)) |
326 | BUG(); | ||
326 | #endif | 327 | #endif |
327 | vdso_init_cr5(); | 328 | vdso_init_cr5(); |
328 | #endif /* CONFIG_64BIT */ | 329 | #endif /* CONFIG_64BIT */ |
diff --git a/arch/s390/kernel/vdso32/gettimeofday.S b/arch/s390/kernel/vdso32/gettimeofday.S index c32f29c3d70c..ad8acfc949fb 100644 --- a/arch/s390/kernel/vdso32/gettimeofday.S +++ b/arch/s390/kernel/vdso32/gettimeofday.S | |||
@@ -13,10 +13,6 @@ | |||
13 | #include <asm/asm-offsets.h> | 13 | #include <asm/asm-offsets.h> |
14 | #include <asm/unistd.h> | 14 | #include <asm/unistd.h> |
15 | 15 | ||
16 | #include <asm/vdso.h> | ||
17 | #include <asm/asm-offsets.h> | ||
18 | #include <asm/unistd.h> | ||
19 | |||
20 | .text | 16 | .text |
21 | .align 4 | 17 | .align 4 |
22 | .globl __kernel_gettimeofday | 18 | .globl __kernel_gettimeofday |
diff --git a/arch/s390/kvm/diag.c b/arch/s390/kvm/diag.c index a0775e1f08df..8300309698fa 100644 --- a/arch/s390/kvm/diag.c +++ b/arch/s390/kvm/diag.c | |||
@@ -47,7 +47,7 @@ static int __diag_ipl_functions(struct kvm_vcpu *vcpu) | |||
47 | vcpu->run->s390_reset_flags |= KVM_S390_RESET_IPL; | 47 | vcpu->run->s390_reset_flags |= KVM_S390_RESET_IPL; |
48 | vcpu->run->s390_reset_flags |= KVM_S390_RESET_CPU_INIT; | 48 | vcpu->run->s390_reset_flags |= KVM_S390_RESET_CPU_INIT; |
49 | vcpu->run->exit_reason = KVM_EXIT_S390_RESET; | 49 | vcpu->run->exit_reason = KVM_EXIT_S390_RESET; |
50 | VCPU_EVENT(vcpu, 3, "requesting userspace resets %lx", | 50 | VCPU_EVENT(vcpu, 3, "requesting userspace resets %llx", |
51 | vcpu->run->s390_reset_flags); | 51 | vcpu->run->s390_reset_flags); |
52 | return -EREMOTE; | 52 | return -EREMOTE; |
53 | } | 53 | } |
diff --git a/arch/s390/kvm/interrupt.c b/arch/s390/kvm/interrupt.c index 2960702b4824..f4fe28a2521a 100644 --- a/arch/s390/kvm/interrupt.c +++ b/arch/s390/kvm/interrupt.c | |||
@@ -160,7 +160,7 @@ static void __do_deliver_interrupt(struct kvm_vcpu *vcpu, | |||
160 | break; | 160 | break; |
161 | 161 | ||
162 | case KVM_S390_INT_VIRTIO: | 162 | case KVM_S390_INT_VIRTIO: |
163 | VCPU_EVENT(vcpu, 4, "interrupt: virtio parm:%x,parm64:%lx", | 163 | VCPU_EVENT(vcpu, 4, "interrupt: virtio parm:%x,parm64:%llx", |
164 | inti->ext.ext_params, inti->ext.ext_params2); | 164 | inti->ext.ext_params, inti->ext.ext_params2); |
165 | vcpu->stat.deliver_virtio_interrupt++; | 165 | vcpu->stat.deliver_virtio_interrupt++; |
166 | rc = put_guest_u16(vcpu, __LC_EXT_INT_CODE, 0x2603); | 166 | rc = put_guest_u16(vcpu, __LC_EXT_INT_CODE, 0x2603); |
@@ -360,7 +360,7 @@ int kvm_s390_handle_wait(struct kvm_vcpu *vcpu) | |||
360 | vcpu->arch.ckc_timer.expires = jiffies + sltime; | 360 | vcpu->arch.ckc_timer.expires = jiffies + sltime; |
361 | 361 | ||
362 | add_timer(&vcpu->arch.ckc_timer); | 362 | add_timer(&vcpu->arch.ckc_timer); |
363 | VCPU_EVENT(vcpu, 5, "enabled wait timer:%lx jiffies", sltime); | 363 | VCPU_EVENT(vcpu, 5, "enabled wait timer:%llx jiffies", sltime); |
364 | no_timer: | 364 | no_timer: |
365 | spin_lock_bh(&vcpu->arch.local_int.float_int->lock); | 365 | spin_lock_bh(&vcpu->arch.local_int.float_int->lock); |
366 | spin_lock_bh(&vcpu->arch.local_int.lock); | 366 | spin_lock_bh(&vcpu->arch.local_int.lock); |
@@ -491,7 +491,7 @@ int kvm_s390_inject_vm(struct kvm *kvm, | |||
491 | 491 | ||
492 | switch (s390int->type) { | 492 | switch (s390int->type) { |
493 | case KVM_S390_INT_VIRTIO: | 493 | case KVM_S390_INT_VIRTIO: |
494 | VM_EVENT(kvm, 5, "inject: virtio parm:%x,parm64:%lx", | 494 | VM_EVENT(kvm, 5, "inject: virtio parm:%x,parm64:%llx", |
495 | s390int->parm, s390int->parm64); | 495 | s390int->parm, s390int->parm64); |
496 | inti->type = s390int->type; | 496 | inti->type = s390int->type; |
497 | inti->ext.ext_params = s390int->parm; | 497 | inti->ext.ext_params = s390int->parm; |
diff --git a/arch/s390/kvm/priv.c b/arch/s390/kvm/priv.c index cce40ff2913b..3605df45dd41 100644 --- a/arch/s390/kvm/priv.c +++ b/arch/s390/kvm/priv.c | |||
@@ -118,7 +118,7 @@ static int handle_store_cpu_address(struct kvm_vcpu *vcpu) | |||
118 | goto out; | 118 | goto out; |
119 | } | 119 | } |
120 | 120 | ||
121 | VCPU_EVENT(vcpu, 5, "storing cpu address to %lx", useraddr); | 121 | VCPU_EVENT(vcpu, 5, "storing cpu address to %llx", useraddr); |
122 | out: | 122 | out: |
123 | return 0; | 123 | return 0; |
124 | } | 124 | } |
diff --git a/drivers/char/hvc_iucv.c b/drivers/char/hvc_iucv.c index 5ea7d7713fca..a53496828b76 100644 --- a/drivers/char/hvc_iucv.c +++ b/drivers/char/hvc_iucv.c | |||
@@ -1,26 +1,30 @@ | |||
1 | /* | 1 | /* |
2 | * hvc_iucv.c - z/VM IUCV back-end for the Hypervisor Console (HVC) | 2 | * hvc_iucv.c - z/VM IUCV hypervisor console (HVC) device driver |
3 | * | 3 | * |
4 | * This back-end for HVC provides terminal access via | 4 | * This HVC device driver provides terminal access using |
5 | * z/VM IUCV communication paths. | 5 | * z/VM IUCV communication paths. |
6 | * | 6 | * |
7 | * Copyright IBM Corp. 2008. | 7 | * Copyright IBM Corp. 2008 |
8 | * | 8 | * |
9 | * Author(s): Hendrik Brueckner <brueckner@linux.vnet.ibm.com> | 9 | * Author(s): Hendrik Brueckner <brueckner@linux.vnet.ibm.com> |
10 | */ | 10 | */ |
11 | #define KMSG_COMPONENT "hvc_iucv" | 11 | #define KMSG_COMPONENT "hvc_iucv" |
12 | #define pr_fmt(fmt) KMSG_COMPONENT ": " fmt | ||
12 | 13 | ||
13 | #include <linux/types.h> | 14 | #include <linux/types.h> |
14 | #include <asm/ebcdic.h> | 15 | #include <asm/ebcdic.h> |
16 | #include <linux/delay.h> | ||
17 | #include <linux/init.h> | ||
15 | #include <linux/mempool.h> | 18 | #include <linux/mempool.h> |
16 | #include <linux/module.h> | 19 | #include <linux/module.h> |
17 | #include <linux/tty.h> | 20 | #include <linux/tty.h> |
21 | #include <linux/wait.h> | ||
18 | #include <net/iucv/iucv.h> | 22 | #include <net/iucv/iucv.h> |
19 | 23 | ||
20 | #include "hvc_console.h" | 24 | #include "hvc_console.h" |
21 | 25 | ||
22 | 26 | ||
23 | /* HVC backend for z/VM IUCV */ | 27 | /* General device driver settings */ |
24 | #define HVC_IUCV_MAGIC 0xc9e4c3e5 | 28 | #define HVC_IUCV_MAGIC 0xc9e4c3e5 |
25 | #define MAX_HVC_IUCV_LINES HVC_ALLOC_TTY_ADAPTERS | 29 | #define MAX_HVC_IUCV_LINES HVC_ALLOC_TTY_ADAPTERS |
26 | #define MEMPOOL_MIN_NR (PAGE_SIZE / sizeof(struct iucv_tty_buffer)/4) | 30 | #define MEMPOOL_MIN_NR (PAGE_SIZE / sizeof(struct iucv_tty_buffer)/4) |
@@ -33,14 +37,14 @@ | |||
33 | #define MSG_TYPE_WINSIZE 0x08 /* Terminal window size update */ | 37 | #define MSG_TYPE_WINSIZE 0x08 /* Terminal window size update */ |
34 | #define MSG_TYPE_DATA 0x10 /* Terminal data */ | 38 | #define MSG_TYPE_DATA 0x10 /* Terminal data */ |
35 | 39 | ||
36 | #define MSG_SIZE(s) ((s) + offsetof(struct iucv_tty_msg, data)) | ||
37 | struct iucv_tty_msg { | 40 | struct iucv_tty_msg { |
38 | u8 version; /* Message version */ | 41 | u8 version; /* Message version */ |
39 | u8 type; /* Message type */ | 42 | u8 type; /* Message type */ |
40 | #define MSG_MAX_DATALEN (~(u16)0) | 43 | #define MSG_MAX_DATALEN ((u16)(~0)) |
41 | u16 datalen; /* Payload length */ | 44 | u16 datalen; /* Payload length */ |
42 | u8 data[]; /* Payload buffer */ | 45 | u8 data[]; /* Payload buffer */ |
43 | } __attribute__((packed)); | 46 | } __attribute__((packed)); |
47 | #define MSG_SIZE(s) ((s) + offsetof(struct iucv_tty_msg, data)) | ||
44 | 48 | ||
45 | enum iucv_state_t { | 49 | enum iucv_state_t { |
46 | IUCV_DISCONN = 0, | 50 | IUCV_DISCONN = 0, |
@@ -54,19 +58,26 @@ enum tty_state_t { | |||
54 | }; | 58 | }; |
55 | 59 | ||
56 | struct hvc_iucv_private { | 60 | struct hvc_iucv_private { |
57 | struct hvc_struct *hvc; /* HVC console struct reference */ | 61 | struct hvc_struct *hvc; /* HVC struct reference */ |
58 | u8 srv_name[8]; /* IUCV service name (ebcdic) */ | 62 | u8 srv_name[8]; /* IUCV service name (ebcdic) */ |
63 | unsigned char is_console; /* Linux console usage flag */ | ||
59 | enum iucv_state_t iucv_state; /* IUCV connection status */ | 64 | enum iucv_state_t iucv_state; /* IUCV connection status */ |
60 | enum tty_state_t tty_state; /* TTY status */ | 65 | enum tty_state_t tty_state; /* TTY status */ |
61 | struct iucv_path *path; /* IUCV path pointer */ | 66 | struct iucv_path *path; /* IUCV path pointer */ |
62 | spinlock_t lock; /* hvc_iucv_private lock */ | 67 | spinlock_t lock; /* hvc_iucv_private lock */ |
68 | #define SNDBUF_SIZE (PAGE_SIZE) /* must be < MSG_MAX_DATALEN */ | ||
69 | void *sndbuf; /* send buffer */ | ||
70 | size_t sndbuf_len; /* length of send buffer */ | ||
71 | #define QUEUE_SNDBUF_DELAY (HZ / 25) | ||
72 | struct delayed_work sndbuf_work; /* work: send iucv msg(s) */ | ||
73 | wait_queue_head_t sndbuf_waitq; /* wait for send completion */ | ||
63 | struct list_head tty_outqueue; /* outgoing IUCV messages */ | 74 | struct list_head tty_outqueue; /* outgoing IUCV messages */ |
64 | struct list_head tty_inqueue; /* incoming IUCV messages */ | 75 | struct list_head tty_inqueue; /* incoming IUCV messages */ |
65 | }; | 76 | }; |
66 | 77 | ||
67 | struct iucv_tty_buffer { | 78 | struct iucv_tty_buffer { |
68 | struct list_head list; /* list pointer */ | 79 | struct list_head list; /* list pointer */ |
69 | struct iucv_message msg; /* store an incoming IUCV message */ | 80 | struct iucv_message msg; /* store an IUCV message */ |
70 | size_t offset; /* data buffer offset */ | 81 | size_t offset; /* data buffer offset */ |
71 | struct iucv_tty_msg *mbuf; /* buffer to store input/output data */ | 82 | struct iucv_tty_msg *mbuf; /* buffer to store input/output data */ |
72 | }; | 83 | }; |
@@ -78,11 +89,12 @@ static void hvc_iucv_msg_pending(struct iucv_path *, struct iucv_message *); | |||
78 | static void hvc_iucv_msg_complete(struct iucv_path *, struct iucv_message *); | 89 | static void hvc_iucv_msg_complete(struct iucv_path *, struct iucv_message *); |
79 | 90 | ||
80 | 91 | ||
81 | /* Kernel module parameters */ | 92 | /* Kernel module parameter: use one terminal device as default */ |
82 | static unsigned long hvc_iucv_devices; | 93 | static unsigned long hvc_iucv_devices = 1; |
83 | 94 | ||
84 | /* Array of allocated hvc iucv tty lines... */ | 95 | /* Array of allocated hvc iucv tty lines... */ |
85 | static struct hvc_iucv_private *hvc_iucv_table[MAX_HVC_IUCV_LINES]; | 96 | static struct hvc_iucv_private *hvc_iucv_table[MAX_HVC_IUCV_LINES]; |
97 | #define IUCV_HVC_CON_IDX (0) | ||
86 | 98 | ||
87 | /* Kmem cache and mempool for iucv_tty_buffer elements */ | 99 | /* Kmem cache and mempool for iucv_tty_buffer elements */ |
88 | static struct kmem_cache *hvc_iucv_buffer_cache; | 100 | static struct kmem_cache *hvc_iucv_buffer_cache; |
@@ -112,7 +124,7 @@ struct hvc_iucv_private *hvc_iucv_get_private(uint32_t num) | |||
112 | } | 124 | } |
113 | 125 | ||
114 | /** | 126 | /** |
115 | * alloc_tty_buffer() - Returns a new struct iucv_tty_buffer element. | 127 | * alloc_tty_buffer() - Return a new struct iucv_tty_buffer element. |
116 | * @size: Size of the internal buffer used to store data. | 128 | * @size: Size of the internal buffer used to store data. |
117 | * @flags: Memory allocation flags passed to mempool. | 129 | * @flags: Memory allocation flags passed to mempool. |
118 | * | 130 | * |
@@ -120,7 +132,6 @@ struct hvc_iucv_private *hvc_iucv_get_private(uint32_t num) | |||
120 | * allocates an internal data buffer with the specified size @size. | 132 | * allocates an internal data buffer with the specified size @size. |
121 | * Note: The total message size arises from the internal buffer size and the | 133 | * Note: The total message size arises from the internal buffer size and the |
122 | * members of the iucv_tty_msg structure. | 134 | * members of the iucv_tty_msg structure. |
123 | * | ||
124 | * The function returns NULL if memory allocation has failed. | 135 | * The function returns NULL if memory allocation has failed. |
125 | */ | 136 | */ |
126 | static struct iucv_tty_buffer *alloc_tty_buffer(size_t size, gfp_t flags) | 137 | static struct iucv_tty_buffer *alloc_tty_buffer(size_t size, gfp_t flags) |
@@ -130,7 +141,7 @@ static struct iucv_tty_buffer *alloc_tty_buffer(size_t size, gfp_t flags) | |||
130 | bufp = mempool_alloc(hvc_iucv_mempool, flags); | 141 | bufp = mempool_alloc(hvc_iucv_mempool, flags); |
131 | if (!bufp) | 142 | if (!bufp) |
132 | return NULL; | 143 | return NULL; |
133 | memset(bufp, 0, sizeof(struct iucv_tty_buffer)); | 144 | memset(bufp, 0, sizeof(*bufp)); |
134 | 145 | ||
135 | if (size > 0) { | 146 | if (size > 0) { |
136 | bufp->msg.length = MSG_SIZE(size); | 147 | bufp->msg.length = MSG_SIZE(size); |
@@ -149,9 +160,6 @@ static struct iucv_tty_buffer *alloc_tty_buffer(size_t size, gfp_t flags) | |||
149 | /** | 160 | /** |
150 | * destroy_tty_buffer() - destroy struct iucv_tty_buffer element. | 161 | * destroy_tty_buffer() - destroy struct iucv_tty_buffer element. |
151 | * @bufp: Pointer to a struct iucv_tty_buffer element, SHALL NOT be NULL. | 162 | * @bufp: Pointer to a struct iucv_tty_buffer element, SHALL NOT be NULL. |
152 | * | ||
153 | * The destroy_tty_buffer() function frees the internal data buffer and returns | ||
154 | * the struct iucv_tty_buffer element back to the mempool for freeing. | ||
155 | */ | 163 | */ |
156 | static void destroy_tty_buffer(struct iucv_tty_buffer *bufp) | 164 | static void destroy_tty_buffer(struct iucv_tty_buffer *bufp) |
157 | { | 165 | { |
@@ -161,11 +169,7 @@ static void destroy_tty_buffer(struct iucv_tty_buffer *bufp) | |||
161 | 169 | ||
162 | /** | 170 | /** |
163 | * destroy_tty_buffer_list() - call destroy_tty_buffer() for each list element. | 171 | * destroy_tty_buffer_list() - call destroy_tty_buffer() for each list element. |
164 | * @list: List head pointer to a list containing struct iucv_tty_buffer | 172 | * @list: List containing struct iucv_tty_buffer elements. |
165 | * elements. | ||
166 | * | ||
167 | * Calls destroy_tty_buffer() for each struct iucv_tty_buffer element in the | ||
168 | * list @list. | ||
169 | */ | 173 | */ |
170 | static void destroy_tty_buffer_list(struct list_head *list) | 174 | static void destroy_tty_buffer_list(struct list_head *list) |
171 | { | 175 | { |
@@ -178,24 +182,24 @@ static void destroy_tty_buffer_list(struct list_head *list) | |||
178 | } | 182 | } |
179 | 183 | ||
180 | /** | 184 | /** |
181 | * hvc_iucv_write() - Receive IUCV message write data to HVC console buffer. | 185 | * hvc_iucv_write() - Receive IUCV message & write data to HVC buffer. |
182 | * @priv: Pointer to hvc_iucv_private structure. | 186 | * @priv: Pointer to struct hvc_iucv_private |
183 | * @buf: HVC console buffer for writing received terminal data. | 187 | * @buf: HVC buffer for writing received terminal data. |
184 | * @count: HVC console buffer size. | 188 | * @count: HVC buffer size. |
185 | * @has_more_data: Pointer to an int variable. | 189 | * @has_more_data: Pointer to an int variable. |
186 | * | 190 | * |
187 | * The function picks up pending messages from the input queue and receives | 191 | * The function picks up pending messages from the input queue and receives |
188 | * the message data that is then written to the specified buffer @buf. | 192 | * the message data that is then written to the specified buffer @buf. |
189 | * If the buffer size @count is less than the data message size, then the | 193 | * If the buffer size @count is less than the data message size, the |
190 | * message is kept on the input queue and @has_more_data is set to 1. | 194 | * message is kept on the input queue and @has_more_data is set to 1. |
191 | * If the message data has been entirely written, the message is removed from | 195 | * If all message data has been written, the message is removed from |
192 | * the input queue. | 196 | * the input queue. |
193 | * | 197 | * |
194 | * The function returns the number of bytes written to the terminal, zero if | 198 | * The function returns the number of bytes written to the terminal, zero if |
195 | * there are no pending data messages available or if there is no established | 199 | * there are no pending data messages available or if there is no established |
196 | * IUCV path. | 200 | * IUCV path. |
197 | * If the IUCV path has been severed, then -EPIPE is returned to cause a | 201 | * If the IUCV path has been severed, then -EPIPE is returned to cause a |
198 | * hang up (that is issued by the HVC console layer). | 202 | * hang up (that is issued by the HVC layer). |
199 | */ | 203 | */ |
200 | static int hvc_iucv_write(struct hvc_iucv_private *priv, | 204 | static int hvc_iucv_write(struct hvc_iucv_private *priv, |
201 | char *buf, int count, int *has_more_data) | 205 | char *buf, int count, int *has_more_data) |
@@ -204,12 +208,12 @@ static int hvc_iucv_write(struct hvc_iucv_private *priv, | |||
204 | int written; | 208 | int written; |
205 | int rc; | 209 | int rc; |
206 | 210 | ||
207 | /* Immediately return if there is no IUCV connection */ | 211 | /* immediately return if there is no IUCV connection */ |
208 | if (priv->iucv_state == IUCV_DISCONN) | 212 | if (priv->iucv_state == IUCV_DISCONN) |
209 | return 0; | 213 | return 0; |
210 | 214 | ||
211 | /* If the IUCV path has been severed, return -EPIPE to inform the | 215 | /* if the IUCV path has been severed, return -EPIPE to inform the |
212 | * hvc console layer to hang up the tty device. */ | 216 | * HVC layer to hang up the tty device. */ |
213 | if (priv->iucv_state == IUCV_SEVERED) | 217 | if (priv->iucv_state == IUCV_SEVERED) |
214 | return -EPIPE; | 218 | return -EPIPE; |
215 | 219 | ||
@@ -217,7 +221,7 @@ static int hvc_iucv_write(struct hvc_iucv_private *priv, | |||
217 | if (list_empty(&priv->tty_inqueue)) | 221 | if (list_empty(&priv->tty_inqueue)) |
218 | return 0; | 222 | return 0; |
219 | 223 | ||
220 | /* receive a iucv message and flip data to the tty (ldisc) */ | 224 | /* receive an iucv message and flip data to the tty (ldisc) */ |
221 | rb = list_first_entry(&priv->tty_inqueue, struct iucv_tty_buffer, list); | 225 | rb = list_first_entry(&priv->tty_inqueue, struct iucv_tty_buffer, list); |
222 | 226 | ||
223 | written = 0; | 227 | written = 0; |
@@ -260,7 +264,7 @@ static int hvc_iucv_write(struct hvc_iucv_private *priv, | |||
260 | case MSG_TYPE_WINSIZE: | 264 | case MSG_TYPE_WINSIZE: |
261 | if (rb->mbuf->datalen != sizeof(struct winsize)) | 265 | if (rb->mbuf->datalen != sizeof(struct winsize)) |
262 | break; | 266 | break; |
263 | hvc_resize(priv->hvc, *((struct winsize *)rb->mbuf->data)); | 267 | hvc_resize(priv->hvc, *((struct winsize *) rb->mbuf->data)); |
264 | break; | 268 | break; |
265 | 269 | ||
266 | case MSG_TYPE_ERROR: /* ignored ... */ | 270 | case MSG_TYPE_ERROR: /* ignored ... */ |
@@ -284,10 +288,9 @@ out_written: | |||
284 | * @buf: Pointer to a buffer to store data | 288 | * @buf: Pointer to a buffer to store data |
285 | * @count: Size of buffer available for writing | 289 | * @count: Size of buffer available for writing |
286 | * | 290 | * |
287 | * The hvc_console thread calls this method to read characters from | 291 | * The HVC thread calls this method to read characters from the back-end. |
288 | * the terminal backend. If an IUCV communication path has been established, | 292 | * If an IUCV communication path has been established, pending IUCV messages |
289 | * pending IUCV messages are received and data is copied into buffer @buf | 293 | * are received and data is copied into buffer @buf up to @count bytes. |
290 | * up to @count bytes. | ||
291 | * | 294 | * |
292 | * Locking: The routine gets called under an irqsave() spinlock; and | 295 | * Locking: The routine gets called under an irqsave() spinlock; and |
293 | * the routine locks the struct hvc_iucv_private->lock to call | 296 | * the routine locks the struct hvc_iucv_private->lock to call |
@@ -318,66 +321,122 @@ static int hvc_iucv_get_chars(uint32_t vtermno, char *buf, int count) | |||
318 | } | 321 | } |
319 | 322 | ||
320 | /** | 323 | /** |
321 | * hvc_iucv_send() - Send an IUCV message containing terminal data. | 324 | * hvc_iucv_queue() - Buffer terminal data for sending. |
322 | * @priv: Pointer to struct hvc_iucv_private instance. | 325 | * @priv: Pointer to struct hvc_iucv_private instance. |
323 | * @buf: Buffer containing data to send. | 326 | * @buf: Buffer containing data to send. |
324 | * @size: Size of buffer and amount of data to send. | 327 | * @count: Size of buffer and amount of data to send. |
328 | * | ||
329 | * The function queues data for sending. To actually send the buffered data, | ||
330 | * a work queue function is scheduled (with QUEUE_SNDBUF_DELAY). | ||
331 | * The function returns the number of data bytes that has been buffered. | ||
325 | * | 332 | * |
326 | * If an IUCV communication path is established, the function copies the buffer | 333 | * If the device is not connected, data is ignored and the function returns |
327 | * data to a newly allocated struct iucv_tty_buffer element, sends the data and | 334 | * @count. |
328 | * puts the element to the outqueue. | 335 | * If the buffer is full, the function returns 0. |
336 | * If an existing IUCV communicaton path has been severed, -EPIPE is returned | ||
337 | * (that can be passed to HVC layer to cause a tty hangup). | ||
338 | */ | ||
339 | static int hvc_iucv_queue(struct hvc_iucv_private *priv, const char *buf, | ||
340 | int count) | ||
341 | { | ||
342 | size_t len; | ||
343 | |||
344 | if (priv->iucv_state == IUCV_DISCONN) | ||
345 | return count; /* ignore data */ | ||
346 | |||
347 | if (priv->iucv_state == IUCV_SEVERED) | ||
348 | return -EPIPE; | ||
349 | |||
350 | len = min_t(size_t, count, SNDBUF_SIZE - priv->sndbuf_len); | ||
351 | if (!len) | ||
352 | return 0; | ||
353 | |||
354 | memcpy(priv->sndbuf + priv->sndbuf_len, buf, len); | ||
355 | priv->sndbuf_len += len; | ||
356 | |||
357 | if (priv->iucv_state == IUCV_CONNECTED) | ||
358 | schedule_delayed_work(&priv->sndbuf_work, QUEUE_SNDBUF_DELAY); | ||
359 | |||
360 | return len; | ||
361 | } | ||
362 | |||
363 | /** | ||
364 | * hvc_iucv_send() - Send an IUCV message containing terminal data. | ||
365 | * @priv: Pointer to struct hvc_iucv_private instance. | ||
329 | * | 366 | * |
330 | * If there is no IUCV communication path established, the function returns 0. | 367 | * If an IUCV communication path has been established, the buffered output data |
331 | * If an existing IUCV communicaton path has been severed, the function returns | 368 | * is sent via an IUCV message and the number of bytes sent is returned. |
332 | * -EPIPE (can be passed to HVC layer to cause a tty hangup). | 369 | * Returns 0 if there is no established IUCV communication path or |
370 | * -EPIPE if an existing IUCV communicaton path has been severed. | ||
333 | */ | 371 | */ |
334 | static int hvc_iucv_send(struct hvc_iucv_private *priv, const char *buf, | 372 | static int hvc_iucv_send(struct hvc_iucv_private *priv) |
335 | int count) | ||
336 | { | 373 | { |
337 | struct iucv_tty_buffer *sb; | 374 | struct iucv_tty_buffer *sb; |
338 | int rc; | 375 | int rc, len; |
339 | u16 len; | ||
340 | 376 | ||
341 | if (priv->iucv_state == IUCV_SEVERED) | 377 | if (priv->iucv_state == IUCV_SEVERED) |
342 | return -EPIPE; | 378 | return -EPIPE; |
343 | 379 | ||
344 | if (priv->iucv_state == IUCV_DISCONN) | 380 | if (priv->iucv_state == IUCV_DISCONN) |
345 | return 0; | 381 | return -EIO; |
346 | 382 | ||
347 | len = min_t(u16, MSG_MAX_DATALEN, count); | 383 | if (!priv->sndbuf_len) |
384 | return 0; | ||
348 | 385 | ||
349 | /* allocate internal buffer to store msg data and also compute total | 386 | /* allocate internal buffer to store msg data and also compute total |
350 | * message length */ | 387 | * message length */ |
351 | sb = alloc_tty_buffer(len, GFP_ATOMIC); | 388 | sb = alloc_tty_buffer(priv->sndbuf_len, GFP_ATOMIC); |
352 | if (!sb) | 389 | if (!sb) |
353 | return -ENOMEM; | 390 | return -ENOMEM; |
354 | 391 | ||
355 | sb->mbuf->datalen = len; | 392 | memcpy(sb->mbuf->data, priv->sndbuf, priv->sndbuf_len); |
356 | memcpy(sb->mbuf->data, buf, len); | 393 | sb->mbuf->datalen = (u16) priv->sndbuf_len; |
394 | sb->msg.length = MSG_SIZE(sb->mbuf->datalen); | ||
357 | 395 | ||
358 | list_add_tail(&sb->list, &priv->tty_outqueue); | 396 | list_add_tail(&sb->list, &priv->tty_outqueue); |
359 | 397 | ||
360 | rc = __iucv_message_send(priv->path, &sb->msg, 0, 0, | 398 | rc = __iucv_message_send(priv->path, &sb->msg, 0, 0, |
361 | (void *) sb->mbuf, sb->msg.length); | 399 | (void *) sb->mbuf, sb->msg.length); |
362 | if (rc) { | 400 | if (rc) { |
401 | /* drop the message here; however we might want to handle | ||
402 | * 0x03 (msg limit reached) by trying again... */ | ||
363 | list_del(&sb->list); | 403 | list_del(&sb->list); |
364 | destroy_tty_buffer(sb); | 404 | destroy_tty_buffer(sb); |
365 | len = 0; | ||
366 | } | 405 | } |
406 | len = priv->sndbuf_len; | ||
407 | priv->sndbuf_len = 0; | ||
367 | 408 | ||
368 | return len; | 409 | return len; |
369 | } | 410 | } |
370 | 411 | ||
371 | /** | 412 | /** |
413 | * hvc_iucv_sndbuf_work() - Send buffered data over IUCV | ||
414 | * @work: Work structure. | ||
415 | * | ||
416 | * This work queue function sends buffered output data over IUCV and, | ||
417 | * if not all buffered data could be sent, reschedules itself. | ||
418 | */ | ||
419 | static void hvc_iucv_sndbuf_work(struct work_struct *work) | ||
420 | { | ||
421 | struct hvc_iucv_private *priv; | ||
422 | |||
423 | priv = container_of(work, struct hvc_iucv_private, sndbuf_work.work); | ||
424 | if (!priv) | ||
425 | return; | ||
426 | |||
427 | spin_lock_bh(&priv->lock); | ||
428 | hvc_iucv_send(priv); | ||
429 | spin_unlock_bh(&priv->lock); | ||
430 | } | ||
431 | |||
432 | /** | ||
372 | * hvc_iucv_put_chars() - HVC put_chars operation. | 433 | * hvc_iucv_put_chars() - HVC put_chars operation. |
373 | * @vtermno: HVC virtual terminal number. | 434 | * @vtermno: HVC virtual terminal number. |
374 | * @buf: Pointer to an buffer to read data from | 435 | * @buf: Pointer to an buffer to read data from |
375 | * @count: Size of buffer available for reading | 436 | * @count: Size of buffer available for reading |
376 | * | 437 | * |
377 | * The hvc_console thread calls this method to write characters from | 438 | * The HVC thread calls this method to write characters to the back-end. |
378 | * to the terminal backend. | 439 | * The function calls hvc_iucv_queue() to queue terminal data for sending. |
379 | * The function calls hvc_iucv_send() under the lock of the | ||
380 | * struct hvc_iucv_private instance that corresponds to the tty @vtermno. | ||
381 | * | 440 | * |
382 | * Locking: The method gets called under an irqsave() spinlock; and | 441 | * Locking: The method gets called under an irqsave() spinlock; and |
383 | * locks struct hvc_iucv_private->lock. | 442 | * locks struct hvc_iucv_private->lock. |
@@ -385,7 +444,7 @@ static int hvc_iucv_send(struct hvc_iucv_private *priv, const char *buf, | |||
385 | static int hvc_iucv_put_chars(uint32_t vtermno, const char *buf, int count) | 444 | static int hvc_iucv_put_chars(uint32_t vtermno, const char *buf, int count) |
386 | { | 445 | { |
387 | struct hvc_iucv_private *priv = hvc_iucv_get_private(vtermno); | 446 | struct hvc_iucv_private *priv = hvc_iucv_get_private(vtermno); |
388 | int sent; | 447 | int queued; |
389 | 448 | ||
390 | if (count <= 0) | 449 | if (count <= 0) |
391 | return 0; | 450 | return 0; |
@@ -394,10 +453,10 @@ static int hvc_iucv_put_chars(uint32_t vtermno, const char *buf, int count) | |||
394 | return -ENODEV; | 453 | return -ENODEV; |
395 | 454 | ||
396 | spin_lock(&priv->lock); | 455 | spin_lock(&priv->lock); |
397 | sent = hvc_iucv_send(priv, buf, count); | 456 | queued = hvc_iucv_queue(priv, buf, count); |
398 | spin_unlock(&priv->lock); | 457 | spin_unlock(&priv->lock); |
399 | 458 | ||
400 | return sent; | 459 | return queued; |
401 | } | 460 | } |
402 | 461 | ||
403 | /** | 462 | /** |
@@ -406,7 +465,7 @@ static int hvc_iucv_put_chars(uint32_t vtermno, const char *buf, int count) | |||
406 | * @id: Additional data (originally passed to hvc_alloc): the index of an struct | 465 | * @id: Additional data (originally passed to hvc_alloc): the index of an struct |
407 | * hvc_iucv_private instance. | 466 | * hvc_iucv_private instance. |
408 | * | 467 | * |
409 | * The function sets the tty state to TTY_OPEN for the struct hvc_iucv_private | 468 | * The function sets the tty state to TTY_OPENED for the struct hvc_iucv_private |
410 | * instance that is derived from @id. Always returns 0. | 469 | * instance that is derived from @id. Always returns 0. |
411 | * | 470 | * |
412 | * Locking: struct hvc_iucv_private->lock, spin_lock_bh | 471 | * Locking: struct hvc_iucv_private->lock, spin_lock_bh |
@@ -427,12 +486,8 @@ static int hvc_iucv_notifier_add(struct hvc_struct *hp, int id) | |||
427 | } | 486 | } |
428 | 487 | ||
429 | /** | 488 | /** |
430 | * hvc_iucv_cleanup() - Clean up function if the tty portion is finally closed. | 489 | * hvc_iucv_cleanup() - Clean up and reset a z/VM IUCV HVC instance. |
431 | * @priv: Pointer to the struct hvc_iucv_private instance. | 490 | * @priv: Pointer to the struct hvc_iucv_private instance. |
432 | * | ||
433 | * The functions severs the established IUCV communication path (if any), and | ||
434 | * destroy struct iucv_tty_buffer elements from the in- and outqueue. Finally, | ||
435 | * the functions resets the states to TTY_CLOSED and IUCV_DISCONN. | ||
436 | */ | 491 | */ |
437 | static void hvc_iucv_cleanup(struct hvc_iucv_private *priv) | 492 | static void hvc_iucv_cleanup(struct hvc_iucv_private *priv) |
438 | { | 493 | { |
@@ -441,25 +496,62 @@ static void hvc_iucv_cleanup(struct hvc_iucv_private *priv) | |||
441 | 496 | ||
442 | priv->tty_state = TTY_CLOSED; | 497 | priv->tty_state = TTY_CLOSED; |
443 | priv->iucv_state = IUCV_DISCONN; | 498 | priv->iucv_state = IUCV_DISCONN; |
499 | |||
500 | priv->sndbuf_len = 0; | ||
444 | } | 501 | } |
445 | 502 | ||
446 | /** | 503 | /** |
447 | * hvc_iucv_notifier_hangup() - HVC notifier for tty hangups. | 504 | * tty_outqueue_empty() - Test if the tty outq is empty |
448 | * @hp: Pointer to the HVC device (struct hvc_struct) | 505 | * @priv: Pointer to struct hvc_iucv_private instance. |
449 | * @id: Additional data (originally passed to hvc_alloc): the index of an struct | 506 | */ |
450 | * hvc_iucv_private instance. | 507 | static inline int tty_outqueue_empty(struct hvc_iucv_private *priv) |
508 | { | ||
509 | int rc; | ||
510 | |||
511 | spin_lock_bh(&priv->lock); | ||
512 | rc = list_empty(&priv->tty_outqueue); | ||
513 | spin_unlock_bh(&priv->lock); | ||
514 | |||
515 | return rc; | ||
516 | } | ||
517 | |||
518 | /** | ||
519 | * flush_sndbuf_sync() - Flush send buffer and wait for completion | ||
520 | * @priv: Pointer to struct hvc_iucv_private instance. | ||
451 | * | 521 | * |
452 | * This routine notifies the HVC backend that a tty hangup (carrier loss, | 522 | * The routine cancels a pending sndbuf work, calls hvc_iucv_send() |
453 | * virtual or otherwise) has occured. | 523 | * to flush any buffered terminal output data and waits for completion. |
524 | */ | ||
525 | static void flush_sndbuf_sync(struct hvc_iucv_private *priv) | ||
526 | { | ||
527 | int sync_wait; | ||
528 | |||
529 | cancel_delayed_work_sync(&priv->sndbuf_work); | ||
530 | |||
531 | spin_lock_bh(&priv->lock); | ||
532 | hvc_iucv_send(priv); /* force sending buffered data */ | ||
533 | sync_wait = !list_empty(&priv->tty_outqueue); /* anything queued ? */ | ||
534 | spin_unlock_bh(&priv->lock); | ||
535 | |||
536 | if (sync_wait) | ||
537 | wait_event_timeout(priv->sndbuf_waitq, | ||
538 | tty_outqueue_empty(priv), HZ); | ||
539 | } | ||
540 | |||
541 | /** | ||
542 | * hvc_iucv_notifier_hangup() - HVC notifier for TTY hangups. | ||
543 | * @hp: Pointer to the HVC device (struct hvc_struct) | ||
544 | * @id: Additional data (originally passed to hvc_alloc): | ||
545 | * the index of an struct hvc_iucv_private instance. | ||
454 | * | 546 | * |
455 | * The HVC backend for z/VM IUCV ignores virtual hangups (vhangup()), to keep | 547 | * This routine notifies the HVC back-end that a tty hangup (carrier loss, |
456 | * an existing IUCV communication path established. | 548 | * virtual or otherwise) has occured. |
549 | * The z/VM IUCV HVC device driver ignores virtual hangups (vhangup()) | ||
550 | * to keep an existing IUCV communication path established. | ||
457 | * (Background: vhangup() is called from user space (by getty or login) to | 551 | * (Background: vhangup() is called from user space (by getty or login) to |
458 | * disable writing to the tty by other applications). | 552 | * disable writing to the tty by other applications). |
459 | * | 553 | * If the tty has been opened and an established IUCV path has been severed |
460 | * If the tty has been opened (e.g. getty) and an established IUCV path has been | 554 | * (we caused the tty hangup), the function calls hvc_iucv_cleanup(). |
461 | * severed (we caused the tty hangup in that case), then the functions invokes | ||
462 | * hvc_iucv_cleanup() to clean up. | ||
463 | * | 555 | * |
464 | * Locking: struct hvc_iucv_private->lock | 556 | * Locking: struct hvc_iucv_private->lock |
465 | */ | 557 | */ |
@@ -471,12 +563,12 @@ static void hvc_iucv_notifier_hangup(struct hvc_struct *hp, int id) | |||
471 | if (!priv) | 563 | if (!priv) |
472 | return; | 564 | return; |
473 | 565 | ||
566 | flush_sndbuf_sync(priv); | ||
567 | |||
474 | spin_lock_bh(&priv->lock); | 568 | spin_lock_bh(&priv->lock); |
475 | /* NOTE: If the hangup was scheduled by ourself (from the iucv | 569 | /* NOTE: If the hangup was scheduled by ourself (from the iucv |
476 | * path_servered callback [IUCV_SEVERED]), then we have to | 570 | * path_servered callback [IUCV_SEVERED]), we have to clean up |
477 | * finally clean up the tty backend structure and set state to | 571 | * our structure and to set state to TTY_CLOSED. |
478 | * TTY_CLOSED. | ||
479 | * | ||
480 | * If the tty was hung up otherwise (e.g. vhangup()), then we | 572 | * If the tty was hung up otherwise (e.g. vhangup()), then we |
481 | * ignore this hangup and keep an established IUCV path open... | 573 | * ignore this hangup and keep an established IUCV path open... |
482 | * (...the reason is that we are not able to connect back to the | 574 | * (...the reason is that we are not able to connect back to the |
@@ -494,10 +586,9 @@ static void hvc_iucv_notifier_hangup(struct hvc_struct *hp, int id) | |||
494 | * @id: Additional data (originally passed to hvc_alloc): | 586 | * @id: Additional data (originally passed to hvc_alloc): |
495 | * the index of an struct hvc_iucv_private instance. | 587 | * the index of an struct hvc_iucv_private instance. |
496 | * | 588 | * |
497 | * This routine notifies the HVC backend that the last tty device file | 589 | * This routine notifies the HVC back-end that the last tty device fd has been |
498 | * descriptor has been closed. | 590 | * closed. The function calls hvc_iucv_cleanup() to clean up the struct |
499 | * The function calls hvc_iucv_cleanup() to clean up the struct hvc_iucv_private | 591 | * hvc_iucv_private instance. |
500 | * instance. | ||
501 | * | 592 | * |
502 | * Locking: struct hvc_iucv_private->lock | 593 | * Locking: struct hvc_iucv_private->lock |
503 | */ | 594 | */ |
@@ -510,6 +601,8 @@ static void hvc_iucv_notifier_del(struct hvc_struct *hp, int id) | |||
510 | if (!priv) | 601 | if (!priv) |
511 | return; | 602 | return; |
512 | 603 | ||
604 | flush_sndbuf_sync(priv); | ||
605 | |||
513 | spin_lock_bh(&priv->lock); | 606 | spin_lock_bh(&priv->lock); |
514 | path = priv->path; /* save reference to IUCV path */ | 607 | path = priv->path; /* save reference to IUCV path */ |
515 | priv->path = NULL; | 608 | priv->path = NULL; |
@@ -527,20 +620,18 @@ static void hvc_iucv_notifier_del(struct hvc_struct *hp, int id) | |||
527 | /** | 620 | /** |
528 | * hvc_iucv_path_pending() - IUCV handler to process a connection request. | 621 | * hvc_iucv_path_pending() - IUCV handler to process a connection request. |
529 | * @path: Pending path (struct iucv_path) | 622 | * @path: Pending path (struct iucv_path) |
530 | * @ipvmid: Originator z/VM system identifier | 623 | * @ipvmid: z/VM system identifier of originator |
531 | * @ipuser: User specified data for this path | 624 | * @ipuser: User specified data for this path |
532 | * (AF_IUCV: port/service name and originator port) | 625 | * (AF_IUCV: port/service name and originator port) |
533 | * | 626 | * |
534 | * The function uses the @ipuser data to check to determine if the pending | 627 | * The function uses the @ipuser data to determine if the pending path belongs |
535 | * path belongs to a terminal managed by this HVC backend. | 628 | * to a terminal managed by this device driver. |
536 | * If the check is successful, then an additional check is done to ensure | 629 | * If the path belongs to this driver, ensure that the terminal is not accessed |
537 | * that a terminal cannot be accessed multiple times (only one connection | 630 | * multiple times (only one connection to a terminal is allowed). |
538 | * to a terminal is allowed). In that particular case, the pending path is | 631 | * If the terminal is not yet connected, the pending path is accepted and is |
539 | * severed. If it is the first connection, the pending path is accepted and | 632 | * associated to the appropriate struct hvc_iucv_private instance. |
540 | * associated to the struct hvc_iucv_private. The iucv state is updated to | ||
541 | * reflect that a communication path has been established. | ||
542 | * | 633 | * |
543 | * Returns 0 if the path belongs to a terminal managed by the this HVC backend; | 634 | * Returns 0 if @path belongs to a terminal managed by the this device driver; |
544 | * otherwise returns -ENODEV in order to dispatch this path to other handlers. | 635 | * otherwise returns -ENODEV in order to dispatch this path to other handlers. |
545 | * | 636 | * |
546 | * Locking: struct hvc_iucv_private->lock | 637 | * Locking: struct hvc_iucv_private->lock |
@@ -559,7 +650,6 @@ static int hvc_iucv_path_pending(struct iucv_path *path, | |||
559 | priv = hvc_iucv_table[i]; | 650 | priv = hvc_iucv_table[i]; |
560 | break; | 651 | break; |
561 | } | 652 | } |
562 | |||
563 | if (!priv) | 653 | if (!priv) |
564 | return -ENODEV; | 654 | return -ENODEV; |
565 | 655 | ||
@@ -588,6 +678,9 @@ static int hvc_iucv_path_pending(struct iucv_path *path, | |||
588 | priv->path = path; | 678 | priv->path = path; |
589 | priv->iucv_state = IUCV_CONNECTED; | 679 | priv->iucv_state = IUCV_CONNECTED; |
590 | 680 | ||
681 | /* flush buffered output data... */ | ||
682 | schedule_delayed_work(&priv->sndbuf_work, 5); | ||
683 | |||
591 | out_path_handled: | 684 | out_path_handled: |
592 | spin_unlock(&priv->lock); | 685 | spin_unlock(&priv->lock); |
593 | return 0; | 686 | return 0; |
@@ -603,8 +696,7 @@ out_path_handled: | |||
603 | * sets the iucv state to IUCV_SEVERED for the associated struct | 696 | * sets the iucv state to IUCV_SEVERED for the associated struct |
604 | * hvc_iucv_private instance. Later, the IUCV_SEVERED state triggers a tty | 697 | * hvc_iucv_private instance. Later, the IUCV_SEVERED state triggers a tty |
605 | * hangup (hvc_iucv_get_chars() / hvc_iucv_write()). | 698 | * hangup (hvc_iucv_get_chars() / hvc_iucv_write()). |
606 | * | 699 | * If tty portion of the HVC is closed, clean up the outqueue. |
607 | * If tty portion of the HVC is closed then clean up the outqueue in addition. | ||
608 | * | 700 | * |
609 | * Locking: struct hvc_iucv_private->lock | 701 | * Locking: struct hvc_iucv_private->lock |
610 | */ | 702 | */ |
@@ -615,15 +707,25 @@ static void hvc_iucv_path_severed(struct iucv_path *path, u8 ipuser[16]) | |||
615 | spin_lock(&priv->lock); | 707 | spin_lock(&priv->lock); |
616 | priv->iucv_state = IUCV_SEVERED; | 708 | priv->iucv_state = IUCV_SEVERED; |
617 | 709 | ||
618 | /* NOTE: If the tty has not yet been opened by a getty program | 710 | /* If the tty has not yet been opened, clean up the hvc_iucv_private |
619 | * (e.g. to see console messages), then cleanup the | 711 | * structure to allow re-connects. |
620 | * hvc_iucv_private structure to allow re-connects. | 712 | * This is also done for our console device because console hangups |
713 | * are handled specially and no notifier is called by HVC. | ||
714 | * The tty session is active (TTY_OPEN) and ready for re-connects... | ||
621 | * | 715 | * |
622 | * If the tty has been opened, the get_chars() callback returns | 716 | * If it has been opened, let get_chars() return -EPIPE to signal the |
623 | * -EPIPE to signal the hvc console layer to hang up the tty. */ | 717 | * HVC layer to hang up the tty. |
718 | * If so, we need to wake up the HVC thread to call get_chars()... | ||
719 | */ | ||
624 | priv->path = NULL; | 720 | priv->path = NULL; |
625 | if (priv->tty_state == TTY_CLOSED) | 721 | if (priv->tty_state == TTY_CLOSED) |
626 | hvc_iucv_cleanup(priv); | 722 | hvc_iucv_cleanup(priv); |
723 | else | ||
724 | if (priv->is_console) { | ||
725 | hvc_iucv_cleanup(priv); | ||
726 | priv->tty_state = TTY_OPENED; | ||
727 | } else | ||
728 | hvc_kick(); | ||
627 | spin_unlock(&priv->lock); | 729 | spin_unlock(&priv->lock); |
628 | 730 | ||
629 | /* finally sever path (outside of priv->lock due to lock ordering) */ | 731 | /* finally sever path (outside of priv->lock due to lock ordering) */ |
@@ -636,9 +738,9 @@ static void hvc_iucv_path_severed(struct iucv_path *path, u8 ipuser[16]) | |||
636 | * @path: Pending path (struct iucv_path) | 738 | * @path: Pending path (struct iucv_path) |
637 | * @msg: Pointer to the IUCV message | 739 | * @msg: Pointer to the IUCV message |
638 | * | 740 | * |
639 | * The function stores an incoming message on the input queue for later | 741 | * The function puts an incoming message on the input queue for later |
640 | * processing (by hvc_iucv_get_chars() / hvc_iucv_write()). | 742 | * processing (by hvc_iucv_get_chars() / hvc_iucv_write()). |
641 | * However, if the tty has not yet been opened, the message is rejected. | 743 | * If the tty has not yet been opened, the message is rejected. |
642 | * | 744 | * |
643 | * Locking: struct hvc_iucv_private->lock | 745 | * Locking: struct hvc_iucv_private->lock |
644 | */ | 746 | */ |
@@ -648,6 +750,12 @@ static void hvc_iucv_msg_pending(struct iucv_path *path, | |||
648 | struct hvc_iucv_private *priv = path->private; | 750 | struct hvc_iucv_private *priv = path->private; |
649 | struct iucv_tty_buffer *rb; | 751 | struct iucv_tty_buffer *rb; |
650 | 752 | ||
753 | /* reject messages that exceed max size of iucv_tty_msg->datalen */ | ||
754 | if (msg->length > MSG_SIZE(MSG_MAX_DATALEN)) { | ||
755 | iucv_message_reject(path, msg); | ||
756 | return; | ||
757 | } | ||
758 | |||
651 | spin_lock(&priv->lock); | 759 | spin_lock(&priv->lock); |
652 | 760 | ||
653 | /* reject messages if tty has not yet been opened */ | 761 | /* reject messages if tty has not yet been opened */ |
@@ -656,7 +764,7 @@ static void hvc_iucv_msg_pending(struct iucv_path *path, | |||
656 | goto unlock_return; | 764 | goto unlock_return; |
657 | } | 765 | } |
658 | 766 | ||
659 | /* allocate buffer an empty buffer element */ | 767 | /* allocate tty buffer to save iucv msg only */ |
660 | rb = alloc_tty_buffer(0, GFP_ATOMIC); | 768 | rb = alloc_tty_buffer(0, GFP_ATOMIC); |
661 | if (!rb) { | 769 | if (!rb) { |
662 | iucv_message_reject(path, msg); | 770 | iucv_message_reject(path, msg); |
@@ -666,7 +774,7 @@ static void hvc_iucv_msg_pending(struct iucv_path *path, | |||
666 | 774 | ||
667 | list_add_tail(&rb->list, &priv->tty_inqueue); | 775 | list_add_tail(&rb->list, &priv->tty_inqueue); |
668 | 776 | ||
669 | hvc_kick(); /* wakup hvc console thread */ | 777 | hvc_kick(); /* wake up hvc thread */ |
670 | 778 | ||
671 | unlock_return: | 779 | unlock_return: |
672 | spin_unlock(&priv->lock); | 780 | spin_unlock(&priv->lock); |
@@ -677,10 +785,10 @@ unlock_return: | |||
677 | * @path: Pending path (struct iucv_path) | 785 | * @path: Pending path (struct iucv_path) |
678 | * @msg: Pointer to the IUCV message | 786 | * @msg: Pointer to the IUCV message |
679 | * | 787 | * |
680 | * The function is called upon completion of message delivery and the | 788 | * The function is called upon completion of message delivery to remove the |
681 | * message is removed from the outqueue. Additional delivery information | 789 | * message from the outqueue. Additional delivery information can be found |
682 | * can be found in msg->audit: rejected messages (0x040000 (IPADRJCT)) and | 790 | * msg->audit: rejected messages (0x040000 (IPADRJCT)), and |
683 | * purged messages (0x010000 (IPADPGNR)). | 791 | * purged messages (0x010000 (IPADPGNR)). |
684 | * | 792 | * |
685 | * Locking: struct hvc_iucv_private->lock | 793 | * Locking: struct hvc_iucv_private->lock |
686 | */ | 794 | */ |
@@ -697,6 +805,7 @@ static void hvc_iucv_msg_complete(struct iucv_path *path, | |||
697 | list_move(&ent->list, &list_remove); | 805 | list_move(&ent->list, &list_remove); |
698 | break; | 806 | break; |
699 | } | 807 | } |
808 | wake_up(&priv->sndbuf_waitq); | ||
700 | spin_unlock(&priv->lock); | 809 | spin_unlock(&priv->lock); |
701 | destroy_tty_buffer_list(&list_remove); | 810 | destroy_tty_buffer_list(&list_remove); |
702 | } | 811 | } |
@@ -713,13 +822,14 @@ static struct hv_ops hvc_iucv_ops = { | |||
713 | 822 | ||
714 | /** | 823 | /** |
715 | * hvc_iucv_alloc() - Allocates a new struct hvc_iucv_private instance | 824 | * hvc_iucv_alloc() - Allocates a new struct hvc_iucv_private instance |
716 | * @id: hvc_iucv_table index | 825 | * @id: hvc_iucv_table index |
826 | * @is_console: Flag if the instance is used as Linux console | ||
717 | * | 827 | * |
718 | * This function allocates a new hvc_iucv_private struct and put the | 828 | * This function allocates a new hvc_iucv_private structure and stores |
719 | * instance into hvc_iucv_table at index @id. | 829 | * the instance in hvc_iucv_table at index @id. |
720 | * Returns 0 on success; otherwise non-zero. | 830 | * Returns 0 on success; otherwise non-zero. |
721 | */ | 831 | */ |
722 | static int __init hvc_iucv_alloc(int id) | 832 | static int __init hvc_iucv_alloc(int id, unsigned int is_console) |
723 | { | 833 | { |
724 | struct hvc_iucv_private *priv; | 834 | struct hvc_iucv_private *priv; |
725 | char name[9]; | 835 | char name[9]; |
@@ -732,18 +842,33 @@ static int __init hvc_iucv_alloc(int id) | |||
732 | spin_lock_init(&priv->lock); | 842 | spin_lock_init(&priv->lock); |
733 | INIT_LIST_HEAD(&priv->tty_outqueue); | 843 | INIT_LIST_HEAD(&priv->tty_outqueue); |
734 | INIT_LIST_HEAD(&priv->tty_inqueue); | 844 | INIT_LIST_HEAD(&priv->tty_inqueue); |
845 | INIT_DELAYED_WORK(&priv->sndbuf_work, hvc_iucv_sndbuf_work); | ||
846 | init_waitqueue_head(&priv->sndbuf_waitq); | ||
847 | |||
848 | priv->sndbuf = (void *) get_zeroed_page(GFP_KERNEL); | ||
849 | if (!priv->sndbuf) { | ||
850 | kfree(priv); | ||
851 | return -ENOMEM; | ||
852 | } | ||
853 | |||
854 | /* set console flag */ | ||
855 | priv->is_console = is_console; | ||
735 | 856 | ||
736 | /* Finally allocate hvc */ | 857 | /* finally allocate hvc */ |
737 | priv->hvc = hvc_alloc(HVC_IUCV_MAGIC + id, | 858 | priv->hvc = hvc_alloc(HVC_IUCV_MAGIC + id, /* PAGE_SIZE */ |
738 | HVC_IUCV_MAGIC + id, &hvc_iucv_ops, PAGE_SIZE); | 859 | HVC_IUCV_MAGIC + id, &hvc_iucv_ops, 256); |
739 | if (IS_ERR(priv->hvc)) { | 860 | if (IS_ERR(priv->hvc)) { |
740 | rc = PTR_ERR(priv->hvc); | 861 | rc = PTR_ERR(priv->hvc); |
862 | free_page((unsigned long) priv->sndbuf); | ||
741 | kfree(priv); | 863 | kfree(priv); |
742 | return rc; | 864 | return rc; |
743 | } | 865 | } |
744 | 866 | ||
867 | /* notify HVC thread instead of using polling */ | ||
868 | priv->hvc->irq_requested = 1; | ||
869 | |||
745 | /* setup iucv related information */ | 870 | /* setup iucv related information */ |
746 | snprintf(name, 9, "ihvc%-4d", id); | 871 | snprintf(name, 9, "lnxhvc%-2d", id); |
747 | memcpy(priv->srv_name, name, 8); | 872 | memcpy(priv->srv_name, name, 8); |
748 | ASCEBC(priv->srv_name, 8); | 873 | ASCEBC(priv->srv_name, 8); |
749 | 874 | ||
@@ -752,15 +877,16 @@ static int __init hvc_iucv_alloc(int id) | |||
752 | } | 877 | } |
753 | 878 | ||
754 | /** | 879 | /** |
755 | * hvc_iucv_init() - Initialization of HVC backend for z/VM IUCV | 880 | * hvc_iucv_init() - z/VM IUCV HVC device driver initialization |
756 | */ | 881 | */ |
757 | static int __init hvc_iucv_init(void) | 882 | static int __init hvc_iucv_init(void) |
758 | { | 883 | { |
759 | int rc, i; | 884 | int rc; |
885 | unsigned int i; | ||
760 | 886 | ||
761 | if (!MACHINE_IS_VM) { | 887 | if (!MACHINE_IS_VM) { |
762 | pr_warning("The z/VM IUCV Hypervisor console cannot be " | 888 | pr_info("The z/VM IUCV HVC device driver cannot " |
763 | "used without z/VM.\n"); | 889 | "be used without z/VM\n"); |
764 | return -ENODEV; | 890 | return -ENODEV; |
765 | } | 891 | } |
766 | 892 | ||
@@ -774,26 +900,33 @@ static int __init hvc_iucv_init(void) | |||
774 | sizeof(struct iucv_tty_buffer), | 900 | sizeof(struct iucv_tty_buffer), |
775 | 0, 0, NULL); | 901 | 0, 0, NULL); |
776 | if (!hvc_iucv_buffer_cache) { | 902 | if (!hvc_iucv_buffer_cache) { |
777 | pr_err("Not enough memory for driver initialization " | 903 | pr_err("Allocating memory failed with reason code=%d\n", 1); |
778 | "(rs=%d).\n", 1); | ||
779 | return -ENOMEM; | 904 | return -ENOMEM; |
780 | } | 905 | } |
781 | 906 | ||
782 | hvc_iucv_mempool = mempool_create_slab_pool(MEMPOOL_MIN_NR, | 907 | hvc_iucv_mempool = mempool_create_slab_pool(MEMPOOL_MIN_NR, |
783 | hvc_iucv_buffer_cache); | 908 | hvc_iucv_buffer_cache); |
784 | if (!hvc_iucv_mempool) { | 909 | if (!hvc_iucv_mempool) { |
785 | pr_err("Not enough memory for driver initialization " | 910 | pr_err("Allocating memory failed with reason code=%d\n", 2); |
786 | "(rs=%d).\n", 2); | ||
787 | kmem_cache_destroy(hvc_iucv_buffer_cache); | 911 | kmem_cache_destroy(hvc_iucv_buffer_cache); |
788 | return -ENOMEM; | 912 | return -ENOMEM; |
789 | } | 913 | } |
790 | 914 | ||
915 | /* register the first terminal device as console | ||
916 | * (must be done before allocating hvc terminal devices) */ | ||
917 | rc = hvc_instantiate(HVC_IUCV_MAGIC, IUCV_HVC_CON_IDX, &hvc_iucv_ops); | ||
918 | if (rc) { | ||
919 | pr_err("Registering HVC terminal device as " | ||
920 | "Linux console failed\n"); | ||
921 | goto out_error_memory; | ||
922 | } | ||
923 | |||
791 | /* allocate hvc_iucv_private structs */ | 924 | /* allocate hvc_iucv_private structs */ |
792 | for (i = 0; i < hvc_iucv_devices; i++) { | 925 | for (i = 0; i < hvc_iucv_devices; i++) { |
793 | rc = hvc_iucv_alloc(i); | 926 | rc = hvc_iucv_alloc(i, (i == IUCV_HVC_CON_IDX) ? 1 : 0); |
794 | if (rc) { | 927 | if (rc) { |
795 | pr_err("Could not create new z/VM IUCV HVC backend " | 928 | pr_err("Creating a new HVC terminal device " |
796 | "rc=%d.\n", rc); | 929 | "failed with error code=%d\n", rc); |
797 | goto out_error_hvc; | 930 | goto out_error_hvc; |
798 | } | 931 | } |
799 | } | 932 | } |
@@ -801,7 +934,8 @@ static int __init hvc_iucv_init(void) | |||
801 | /* register IUCV callback handler */ | 934 | /* register IUCV callback handler */ |
802 | rc = iucv_register(&hvc_iucv_handler, 0); | 935 | rc = iucv_register(&hvc_iucv_handler, 0); |
803 | if (rc) { | 936 | if (rc) { |
804 | pr_err("Could not register iucv handler (rc=%d).\n", rc); | 937 | pr_err("Registering IUCV handlers failed with error code=%d\n", |
938 | rc); | ||
805 | goto out_error_iucv; | 939 | goto out_error_iucv; |
806 | } | 940 | } |
807 | 941 | ||
@@ -816,22 +950,13 @@ out_error_hvc: | |||
816 | hvc_remove(hvc_iucv_table[i]->hvc); | 950 | hvc_remove(hvc_iucv_table[i]->hvc); |
817 | kfree(hvc_iucv_table[i]); | 951 | kfree(hvc_iucv_table[i]); |
818 | } | 952 | } |
953 | out_error_memory: | ||
819 | mempool_destroy(hvc_iucv_mempool); | 954 | mempool_destroy(hvc_iucv_mempool); |
820 | kmem_cache_destroy(hvc_iucv_buffer_cache); | 955 | kmem_cache_destroy(hvc_iucv_buffer_cache); |
821 | return rc; | 956 | return rc; |
822 | } | 957 | } |
823 | 958 | ||
824 | /** | 959 | /** |
825 | * hvc_iucv_console_init() - Early console initialization | ||
826 | */ | ||
827 | static int __init hvc_iucv_console_init(void) | ||
828 | { | ||
829 | if (!MACHINE_IS_VM || !hvc_iucv_devices) | ||
830 | return -ENODEV; | ||
831 | return hvc_instantiate(HVC_IUCV_MAGIC, 0, &hvc_iucv_ops); | ||
832 | } | ||
833 | |||
834 | /** | ||
835 | * hvc_iucv_config() - Parsing of hvc_iucv= kernel command line parameter | 960 | * hvc_iucv_config() - Parsing of hvc_iucv= kernel command line parameter |
836 | * @val: Parameter value (numeric) | 961 | * @val: Parameter value (numeric) |
837 | */ | 962 | */ |
@@ -841,10 +966,5 @@ static int __init hvc_iucv_config(char *val) | |||
841 | } | 966 | } |
842 | 967 | ||
843 | 968 | ||
844 | module_init(hvc_iucv_init); | 969 | device_initcall(hvc_iucv_init); |
845 | console_initcall(hvc_iucv_console_init); | ||
846 | __setup("hvc_iucv=", hvc_iucv_config); | 970 | __setup("hvc_iucv=", hvc_iucv_config); |
847 | |||
848 | MODULE_LICENSE("GPL"); | ||
849 | MODULE_DESCRIPTION("HVC back-end for z/VM IUCV."); | ||
850 | MODULE_AUTHOR("Hendrik Brueckner <brueckner@linux.vnet.ibm.com>"); | ||
diff --git a/drivers/s390/block/dasd.c b/drivers/s390/block/dasd.c index 570ae59c1d5e..bd5914994142 100644 --- a/drivers/s390/block/dasd.c +++ b/drivers/s390/block/dasd.c | |||
@@ -336,6 +336,9 @@ static int | |||
336 | dasd_state_ready_to_online(struct dasd_device * device) | 336 | dasd_state_ready_to_online(struct dasd_device * device) |
337 | { | 337 | { |
338 | int rc; | 338 | int rc; |
339 | struct gendisk *disk; | ||
340 | struct disk_part_iter piter; | ||
341 | struct hd_struct *part; | ||
339 | 342 | ||
340 | if (device->discipline->ready_to_online) { | 343 | if (device->discipline->ready_to_online) { |
341 | rc = device->discipline->ready_to_online(device); | 344 | rc = device->discipline->ready_to_online(device); |
@@ -343,8 +346,14 @@ dasd_state_ready_to_online(struct dasd_device * device) | |||
343 | return rc; | 346 | return rc; |
344 | } | 347 | } |
345 | device->state = DASD_STATE_ONLINE; | 348 | device->state = DASD_STATE_ONLINE; |
346 | if (device->block) | 349 | if (device->block) { |
347 | dasd_schedule_block_bh(device->block); | 350 | dasd_schedule_block_bh(device->block); |
351 | disk = device->block->bdev->bd_disk; | ||
352 | disk_part_iter_init(&piter, disk, DISK_PITER_INCL_PART0); | ||
353 | while ((part = disk_part_iter_next(&piter))) | ||
354 | kobject_uevent(&part_to_dev(part)->kobj, KOBJ_CHANGE); | ||
355 | disk_part_iter_exit(&piter); | ||
356 | } | ||
348 | return 0; | 357 | return 0; |
349 | } | 358 | } |
350 | 359 | ||
@@ -354,6 +363,9 @@ dasd_state_ready_to_online(struct dasd_device * device) | |||
354 | static int dasd_state_online_to_ready(struct dasd_device *device) | 363 | static int dasd_state_online_to_ready(struct dasd_device *device) |
355 | { | 364 | { |
356 | int rc; | 365 | int rc; |
366 | struct gendisk *disk; | ||
367 | struct disk_part_iter piter; | ||
368 | struct hd_struct *part; | ||
357 | 369 | ||
358 | if (device->discipline->online_to_ready) { | 370 | if (device->discipline->online_to_ready) { |
359 | rc = device->discipline->online_to_ready(device); | 371 | rc = device->discipline->online_to_ready(device); |
@@ -361,6 +373,13 @@ static int dasd_state_online_to_ready(struct dasd_device *device) | |||
361 | return rc; | 373 | return rc; |
362 | } | 374 | } |
363 | device->state = DASD_STATE_READY; | 375 | device->state = DASD_STATE_READY; |
376 | if (device->block) { | ||
377 | disk = device->block->bdev->bd_disk; | ||
378 | disk_part_iter_init(&piter, disk, DISK_PITER_INCL_PART0); | ||
379 | while ((part = disk_part_iter_next(&piter))) | ||
380 | kobject_uevent(&part_to_dev(part)->kobj, KOBJ_CHANGE); | ||
381 | disk_part_iter_exit(&piter); | ||
382 | } | ||
364 | return 0; | 383 | return 0; |
365 | } | 384 | } |
366 | 385 | ||
diff --git a/drivers/s390/block/dasd_devmap.c b/drivers/s390/block/dasd_devmap.c index 2ef25731d197..300e28a531f8 100644 --- a/drivers/s390/block/dasd_devmap.c +++ b/drivers/s390/block/dasd_devmap.c | |||
@@ -206,6 +206,8 @@ dasd_feature_list(char *str, char **endp) | |||
206 | features |= DASD_FEATURE_USEDIAG; | 206 | features |= DASD_FEATURE_USEDIAG; |
207 | else if (len == 6 && !strncmp(str, "erplog", 6)) | 207 | else if (len == 6 && !strncmp(str, "erplog", 6)) |
208 | features |= DASD_FEATURE_ERPLOG; | 208 | features |= DASD_FEATURE_ERPLOG; |
209 | else if (len == 8 && !strncmp(str, "failfast", 8)) | ||
210 | features |= DASD_FEATURE_FAILFAST; | ||
209 | else { | 211 | else { |
210 | MESSAGE(KERN_WARNING, | 212 | MESSAGE(KERN_WARNING, |
211 | "unsupported feature: %*s, " | 213 | "unsupported feature: %*s, " |
@@ -667,6 +669,51 @@ dasd_device_from_cdev(struct ccw_device *cdev) | |||
667 | */ | 669 | */ |
668 | 670 | ||
669 | /* | 671 | /* |
672 | * failfast controls the behaviour, if no path is available | ||
673 | */ | ||
674 | static ssize_t dasd_ff_show(struct device *dev, struct device_attribute *attr, | ||
675 | char *buf) | ||
676 | { | ||
677 | struct dasd_devmap *devmap; | ||
678 | int ff_flag; | ||
679 | |||
680 | devmap = dasd_find_busid(dev->bus_id); | ||
681 | if (!IS_ERR(devmap)) | ||
682 | ff_flag = (devmap->features & DASD_FEATURE_FAILFAST) != 0; | ||
683 | else | ||
684 | ff_flag = (DASD_FEATURE_DEFAULT & DASD_FEATURE_FAILFAST) != 0; | ||
685 | return snprintf(buf, PAGE_SIZE, ff_flag ? "1\n" : "0\n"); | ||
686 | } | ||
687 | |||
688 | static ssize_t dasd_ff_store(struct device *dev, struct device_attribute *attr, | ||
689 | const char *buf, size_t count) | ||
690 | { | ||
691 | struct dasd_devmap *devmap; | ||
692 | int val; | ||
693 | char *endp; | ||
694 | |||
695 | devmap = dasd_devmap_from_cdev(to_ccwdev(dev)); | ||
696 | if (IS_ERR(devmap)) | ||
697 | return PTR_ERR(devmap); | ||
698 | |||
699 | val = simple_strtoul(buf, &endp, 0); | ||
700 | if (((endp + 1) < (buf + count)) || (val > 1)) | ||
701 | return -EINVAL; | ||
702 | |||
703 | spin_lock(&dasd_devmap_lock); | ||
704 | if (val) | ||
705 | devmap->features |= DASD_FEATURE_FAILFAST; | ||
706 | else | ||
707 | devmap->features &= ~DASD_FEATURE_FAILFAST; | ||
708 | if (devmap->device) | ||
709 | devmap->device->features = devmap->features; | ||
710 | spin_unlock(&dasd_devmap_lock); | ||
711 | return count; | ||
712 | } | ||
713 | |||
714 | static DEVICE_ATTR(failfast, 0644, dasd_ff_show, dasd_ff_store); | ||
715 | |||
716 | /* | ||
670 | * readonly controls the readonly status of a dasd | 717 | * readonly controls the readonly status of a dasd |
671 | */ | 718 | */ |
672 | static ssize_t | 719 | static ssize_t |
@@ -1020,6 +1067,7 @@ static struct attribute * dasd_attrs[] = { | |||
1020 | &dev_attr_use_diag.attr, | 1067 | &dev_attr_use_diag.attr, |
1021 | &dev_attr_eer_enabled.attr, | 1068 | &dev_attr_eer_enabled.attr, |
1022 | &dev_attr_erplog.attr, | 1069 | &dev_attr_erplog.attr, |
1070 | &dev_attr_failfast.attr, | ||
1023 | NULL, | 1071 | NULL, |
1024 | }; | 1072 | }; |
1025 | 1073 | ||
diff --git a/drivers/s390/block/dasd_diag.c b/drivers/s390/block/dasd_diag.c index 7844461a995b..ef2a56952054 100644 --- a/drivers/s390/block/dasd_diag.c +++ b/drivers/s390/block/dasd_diag.c | |||
@@ -544,7 +544,8 @@ static struct dasd_ccw_req *dasd_diag_build_cp(struct dasd_device *memdev, | |||
544 | } | 544 | } |
545 | cqr->retries = DIAG_MAX_RETRIES; | 545 | cqr->retries = DIAG_MAX_RETRIES; |
546 | cqr->buildclk = get_clock(); | 546 | cqr->buildclk = get_clock(); |
547 | if (blk_noretry_request(req)) | 547 | if (blk_noretry_request(req) || |
548 | block->base->features & DASD_FEATURE_FAILFAST) | ||
548 | set_bit(DASD_CQR_FLAGS_FAILFAST, &cqr->flags); | 549 | set_bit(DASD_CQR_FLAGS_FAILFAST, &cqr->flags); |
549 | cqr->startdev = memdev; | 550 | cqr->startdev = memdev; |
550 | cqr->memdev = memdev; | 551 | cqr->memdev = memdev; |
diff --git a/drivers/s390/block/dasd_eckd.c b/drivers/s390/block/dasd_eckd.c index bd2c52e20762..bdb87998f364 100644 --- a/drivers/s390/block/dasd_eckd.c +++ b/drivers/s390/block/dasd_eckd.c | |||
@@ -1700,7 +1700,8 @@ static struct dasd_ccw_req *dasd_eckd_build_cp(struct dasd_device *startdev, | |||
1700 | recid++; | 1700 | recid++; |
1701 | } | 1701 | } |
1702 | } | 1702 | } |
1703 | if (blk_noretry_request(req)) | 1703 | if (blk_noretry_request(req) || |
1704 | block->base->features & DASD_FEATURE_FAILFAST) | ||
1704 | set_bit(DASD_CQR_FLAGS_FAILFAST, &cqr->flags); | 1705 | set_bit(DASD_CQR_FLAGS_FAILFAST, &cqr->flags); |
1705 | cqr->startdev = startdev; | 1706 | cqr->startdev = startdev; |
1706 | cqr->memdev = startdev; | 1707 | cqr->memdev = startdev; |
diff --git a/drivers/s390/block/dasd_fba.c b/drivers/s390/block/dasd_fba.c index 7d442aeff3d1..f1d176021694 100644 --- a/drivers/s390/block/dasd_fba.c +++ b/drivers/s390/block/dasd_fba.c | |||
@@ -355,7 +355,8 @@ static struct dasd_ccw_req *dasd_fba_build_cp(struct dasd_device * memdev, | |||
355 | recid++; | 355 | recid++; |
356 | } | 356 | } |
357 | } | 357 | } |
358 | if (blk_noretry_request(req)) | 358 | if (blk_noretry_request(req) || |
359 | block->base->features & DASD_FEATURE_FAILFAST) | ||
359 | set_bit(DASD_CQR_FLAGS_FAILFAST, &cqr->flags); | 360 | set_bit(DASD_CQR_FLAGS_FAILFAST, &cqr->flags); |
360 | cqr->startdev = memdev; | 361 | cqr->startdev = memdev; |
361 | cqr->memdev = memdev; | 362 | cqr->memdev = memdev; |
diff --git a/drivers/s390/char/Kconfig b/drivers/s390/char/Kconfig index 643033890e34..0769ced52dbd 100644 --- a/drivers/s390/char/Kconfig +++ b/drivers/s390/char/Kconfig | |||
@@ -100,7 +100,7 @@ comment "S/390 tape interface support" | |||
100 | 100 | ||
101 | config S390_TAPE_BLOCK | 101 | config S390_TAPE_BLOCK |
102 | bool "Support for tape block devices" | 102 | bool "Support for tape block devices" |
103 | depends on S390_TAPE | 103 | depends on S390_TAPE && BLOCK |
104 | help | 104 | help |
105 | Select this option if you want to access your channel-attached tape | 105 | Select this option if you want to access your channel-attached tape |
106 | devices using the block device interface. This interface is similar | 106 | devices using the block device interface. This interface is similar |
diff --git a/drivers/s390/cio/qdio_debug.c b/drivers/s390/cio/qdio_debug.c index f8a3b6967f69..da7afb04e71f 100644 --- a/drivers/s390/cio/qdio_debug.c +++ b/drivers/s390/cio/qdio_debug.c | |||
@@ -169,6 +169,8 @@ static void setup_debugfs_entry(struct qdio_q *q, struct ccw_device *cdev) | |||
169 | q->nr); | 169 | q->nr); |
170 | debugfs_queues[i] = debugfs_create_file(name, S_IFREG | S_IRUGO | S_IWUSR, | 170 | debugfs_queues[i] = debugfs_create_file(name, S_IFREG | S_IRUGO | S_IWUSR, |
171 | debugfs_root, q, &debugfs_fops); | 171 | debugfs_root, q, &debugfs_fops); |
172 | if (IS_ERR(debugfs_queues[i])) | ||
173 | debugfs_queues[i] = NULL; | ||
172 | } | 174 | } |
173 | 175 | ||
174 | void qdio_setup_debug_entries(struct qdio_irq *irq_ptr, struct ccw_device *cdev) | 176 | void qdio_setup_debug_entries(struct qdio_irq *irq_ptr, struct ccw_device *cdev) |