Merge branch 'master' of git://git.kernel.org/pub/scm/linux/kernel/git/torvalds/linux-2.6
[linux-2.6] / drivers / s390 / block / dasd_eer.c
1 /*
2  *  Character device driver for extended error reporting.
3  *
4  *  Copyright (C) 2005 IBM Corporation
5  *  extended error reporting for DASD ECKD devices
6  *  Author(s): Stefan Weinhuber <wein@de.ibm.com>
7  */
8
9 #include <linux/init.h>
10 #include <linux/fs.h>
11 #include <linux/kernel.h>
12 #include <linux/miscdevice.h>
13 #include <linux/module.h>
14 #include <linux/moduleparam.h>
15 #include <linux/device.h>
16 #include <linux/poll.h>
17 #include <linux/mutex.h>
18 #include <linux/smp_lock.h>
19
20 #include <asm/uaccess.h>
21 #include <asm/atomic.h>
22 #include <asm/ebcdic.h>
23
24 #include "dasd_int.h"
25 #include "dasd_eckd.h"
26
27 #ifdef PRINTK_HEADER
28 #undef PRINTK_HEADER
29 #endif                          /* PRINTK_HEADER */
30 #define PRINTK_HEADER "dasd(eer):"
31
32 /*
33  * SECTION: the internal buffer
34  */
35
36 /*
37  * The internal buffer is meant to store obaque blobs of data, so it does
38  * not know of higher level concepts like triggers.
39  * It consists of a number of pages that are used as a ringbuffer. Each data
40  * blob is stored in a simple record that consists of an integer, which
41  * contains the size of the following data, and the data bytes themselfes.
42  *
43  * To allow for multiple independent readers we create one internal buffer
44  * each time the device is opened and destroy the buffer when the file is
45  * closed again. The number of pages used for this buffer is determined by
46  * the module parmeter eer_pages.
47  *
48  * One record can be written to a buffer by using the functions
49  * - dasd_eer_start_record (one time per record to write the size to the
50  *                          buffer and reserve the space for the data)
51  * - dasd_eer_write_buffer (one or more times per record to write the data)
52  * The data can be written in several steps but you will have to compute
53  * the total size up front for the invocation of dasd_eer_start_record.
54  * If the ringbuffer is full, dasd_eer_start_record will remove the required
55  * number of old records.
56  *
57  * A record is typically read in two steps, first read the integer that
58  * specifies the size of the following data, then read the data.
59  * Both can be done by
60  * - dasd_eer_read_buffer
61  *
62  * For all mentioned functions you need to get the bufferlock first and keep
63  * it until a complete record is written or read.
64  *
65  * All information necessary to keep track of an internal buffer is kept in
66  * a struct eerbuffer. The buffer specific to a file pointer is strored in
67  * the private_data field of that file. To be able to write data to all
68  * existing buffers, each buffer is also added to the bufferlist.
69  * If the user does not want to read a complete record in one go, we have to
70  * keep track of the rest of the record. residual stores the number of bytes
71  * that are still to deliver. If the rest of the record is invalidated between
72  * two reads then residual will be set to -1 so that the next read will fail.
73  * All entries in the eerbuffer structure are protected with the bufferlock.
74  * To avoid races between writing to a buffer on the one side and creating
75  * and destroying buffers on the other side, the bufferlock must also be used
76  * to protect the bufferlist.
77  */
78
79 static int eer_pages = 5;
80 module_param(eer_pages, int, S_IRUGO|S_IWUSR);
81
82 struct eerbuffer {
83         struct list_head list;
84         char **buffer;
85         int buffersize;
86         int buffer_page_count;
87         int head;
88         int tail;
89         int residual;
90 };
91
92 static LIST_HEAD(bufferlist);
93 static DEFINE_SPINLOCK(bufferlock);
94 static DECLARE_WAIT_QUEUE_HEAD(dasd_eer_read_wait_queue);
95
96 /*
97  * How many free bytes are available on the buffer.
98  * Needs to be called with bufferlock held.
99  */
100 static int dasd_eer_get_free_bytes(struct eerbuffer *eerb)
101 {
102         if (eerb->head < eerb->tail)
103                 return eerb->tail - eerb->head - 1;
104         return eerb->buffersize - eerb->head + eerb->tail -1;
105 }
106
107 /*
108  * How many bytes of buffer space are used.
109  * Needs to be called with bufferlock held.
110  */
111 static int dasd_eer_get_filled_bytes(struct eerbuffer *eerb)
112 {
113
114         if (eerb->head >= eerb->tail)
115                 return eerb->head - eerb->tail;
116         return eerb->buffersize - eerb->tail + eerb->head;
117 }
118
119 /*
120  * The dasd_eer_write_buffer function just copies count bytes of data
121  * to the buffer. Make sure to call dasd_eer_start_record first, to
122  * make sure that enough free space is available.
123  * Needs to be called with bufferlock held.
124  */
125 static void dasd_eer_write_buffer(struct eerbuffer *eerb,
126                                   char *data, int count)
127 {
128
129         unsigned long headindex,localhead;
130         unsigned long rest, len;
131         char *nextdata;
132
133         nextdata = data;
134         rest = count;
135         while (rest > 0) {
136                 headindex = eerb->head / PAGE_SIZE;
137                 localhead = eerb->head % PAGE_SIZE;
138                 len = min(rest, PAGE_SIZE - localhead);
139                 memcpy(eerb->buffer[headindex]+localhead, nextdata, len);
140                 nextdata += len;
141                 rest -= len;
142                 eerb->head += len;
143                 if (eerb->head == eerb->buffersize)
144                         eerb->head = 0; /* wrap around */
145                 BUG_ON(eerb->head > eerb->buffersize);
146         }
147 }
148
149 /*
150  * Needs to be called with bufferlock held.
151  */
152 static int dasd_eer_read_buffer(struct eerbuffer *eerb, char *data, int count)
153 {
154
155         unsigned long tailindex,localtail;
156         unsigned long rest, len, finalcount;
157         char *nextdata;
158
159         finalcount = min(count, dasd_eer_get_filled_bytes(eerb));
160         nextdata = data;
161         rest = finalcount;
162         while (rest > 0) {
163                 tailindex = eerb->tail / PAGE_SIZE;
164                 localtail = eerb->tail % PAGE_SIZE;
165                 len = min(rest, PAGE_SIZE - localtail);
166                 memcpy(nextdata, eerb->buffer[tailindex] + localtail, len);
167                 nextdata += len;
168                 rest -= len;
169                 eerb->tail += len;
170                 if (eerb->tail == eerb->buffersize)
171                         eerb->tail = 0; /* wrap around */
172                 BUG_ON(eerb->tail > eerb->buffersize);
173         }
174         return finalcount;
175 }
176
177 /*
178  * Whenever you want to write a blob of data to the internal buffer you
179  * have to start by using this function first. It will write the number
180  * of bytes that will be written to the buffer. If necessary it will remove
181  * old records to make room for the new one.
182  * Needs to be called with bufferlock held.
183  */
184 static int dasd_eer_start_record(struct eerbuffer *eerb, int count)
185 {
186         int tailcount;
187
188         if (count + sizeof(count) > eerb->buffersize)
189                 return -ENOMEM;
190         while (dasd_eer_get_free_bytes(eerb) < count + sizeof(count)) {
191                 if (eerb->residual > 0) {
192                         eerb->tail += eerb->residual;
193                         if (eerb->tail >= eerb->buffersize)
194                                 eerb->tail -= eerb->buffersize;
195                         eerb->residual = -1;
196                 }
197                 dasd_eer_read_buffer(eerb, (char *) &tailcount,
198                                      sizeof(tailcount));
199                 eerb->tail += tailcount;
200                 if (eerb->tail >= eerb->buffersize)
201                         eerb->tail -= eerb->buffersize;
202         }
203         dasd_eer_write_buffer(eerb, (char*) &count, sizeof(count));
204
205         return 0;
206 };
207
208 /*
209  * Release pages that are not used anymore.
210  */
211 static void dasd_eer_free_buffer_pages(char **buf, int no_pages)
212 {
213         int i;
214
215         for (i = 0; i < no_pages; i++)
216                 free_page((unsigned long) buf[i]);
217 }
218
219 /*
220  * Allocate a new set of memory pages.
221  */
222 static int dasd_eer_allocate_buffer_pages(char **buf, int no_pages)
223 {
224         int i;
225
226         for (i = 0; i < no_pages; i++) {
227                 buf[i] = (char *) get_zeroed_page(GFP_KERNEL);
228                 if (!buf[i]) {
229                         dasd_eer_free_buffer_pages(buf, i);
230                         return -ENOMEM;
231                 }
232         }
233         return 0;
234 }
235
236 /*
237  * SECTION: The extended error reporting functionality
238  */
239
240 /*
241  * When a DASD device driver wants to report an error, it calls the
242  * function dasd_eer_write and gives the respective trigger ID as
243  * parameter. Currently there are four kinds of triggers:
244  *
245  * DASD_EER_FATALERROR:  all kinds of unrecoverable I/O problems
246  * DASD_EER_PPRCSUSPEND: PPRC was suspended
247  * DASD_EER_NOPATH:      There is no path to the device left.
248  * DASD_EER_STATECHANGE: The state of the device has changed.
249  *
250  * For the first three triggers all required information can be supplied by
251  * the caller. For these triggers a record is written by the function
252  * dasd_eer_write_standard_trigger.
253  *
254  * The DASD_EER_STATECHANGE trigger is special since a sense subsystem
255  * status ccw need to be executed to gather the necessary sense data first.
256  * The dasd_eer_snss function will queue the SNSS request and the request
257  * callback will then call dasd_eer_write with the DASD_EER_STATCHANGE
258  * trigger.
259  *
260  * To avoid memory allocations at runtime, the necessary memory is allocated
261  * when the extended error reporting is enabled for a device (by
262  * dasd_eer_probe). There is one sense subsystem status request for each
263  * eer enabled DASD device. The presence of the cqr in device->eer_cqr
264  * indicates that eer is enable for the device. The use of the snss request
265  * is protected by the DASD_FLAG_EER_IN_USE bit. When this flag indicates
266  * that the cqr is currently in use, dasd_eer_snss cannot start a second
267  * request but sets the DASD_FLAG_EER_SNSS flag instead. The callback of
268  * the SNSS request will check the bit and call dasd_eer_snss again.
269  */
270
271 #define SNSS_DATA_SIZE 44
272
273 #define DASD_EER_BUSID_SIZE 10
274 struct dasd_eer_header {
275         __u32 total_size;
276         __u32 trigger;
277         __u64 tv_sec;
278         __u64 tv_usec;
279         char busid[DASD_EER_BUSID_SIZE];
280 } __attribute__ ((packed));
281
282 /*
283  * The following function can be used for those triggers that have
284  * all necessary data available when the function is called.
285  * If the parameter cqr is not NULL, the chain of requests will be searched
286  * for valid sense data, and all valid sense data sets will be added to
287  * the triggers data.
288  */
289 static void dasd_eer_write_standard_trigger(struct dasd_device *device,
290                                             struct dasd_ccw_req *cqr,
291                                             int trigger)
292 {
293         struct dasd_ccw_req *temp_cqr;
294         int data_size;
295         struct timeval tv;
296         struct dasd_eer_header header;
297         unsigned long flags;
298         struct eerbuffer *eerb;
299
300         /* go through cqr chain and count the valid sense data sets */
301         data_size = 0;
302         for (temp_cqr = cqr; temp_cqr; temp_cqr = temp_cqr->refers)
303                 if (temp_cqr->irb.esw.esw0.erw.cons)
304                         data_size += 32;
305
306         header.total_size = sizeof(header) + data_size + 4; /* "EOR" */
307         header.trigger = trigger;
308         do_gettimeofday(&tv);
309         header.tv_sec = tv.tv_sec;
310         header.tv_usec = tv.tv_usec;
311         strncpy(header.busid, device->cdev->dev.bus_id, DASD_EER_BUSID_SIZE);
312
313         spin_lock_irqsave(&bufferlock, flags);
314         list_for_each_entry(eerb, &bufferlist, list) {
315                 dasd_eer_start_record(eerb, header.total_size);
316                 dasd_eer_write_buffer(eerb, (char *) &header, sizeof(header));
317                 for (temp_cqr = cqr; temp_cqr; temp_cqr = temp_cqr->refers)
318                         if (temp_cqr->irb.esw.esw0.erw.cons)
319                                 dasd_eer_write_buffer(eerb, cqr->irb.ecw, 32);
320                 dasd_eer_write_buffer(eerb, "EOR", 4);
321         }
322         spin_unlock_irqrestore(&bufferlock, flags);
323         wake_up_interruptible(&dasd_eer_read_wait_queue);
324 }
325
326 /*
327  * This function writes a DASD_EER_STATECHANGE trigger.
328  */
329 static void dasd_eer_write_snss_trigger(struct dasd_device *device,
330                                         struct dasd_ccw_req *cqr,
331                                         int trigger)
332 {
333         int data_size;
334         int snss_rc;
335         struct timeval tv;
336         struct dasd_eer_header header;
337         unsigned long flags;
338         struct eerbuffer *eerb;
339
340         snss_rc = (cqr->status == DASD_CQR_DONE) ? 0 : -EIO;
341         if (snss_rc)
342                 data_size = 0;
343         else
344                 data_size = SNSS_DATA_SIZE;
345
346         header.total_size = sizeof(header) + data_size + 4; /* "EOR" */
347         header.trigger = DASD_EER_STATECHANGE;
348         do_gettimeofday(&tv);
349         header.tv_sec = tv.tv_sec;
350         header.tv_usec = tv.tv_usec;
351         strncpy(header.busid, device->cdev->dev.bus_id, DASD_EER_BUSID_SIZE);
352
353         spin_lock_irqsave(&bufferlock, flags);
354         list_for_each_entry(eerb, &bufferlist, list) {
355                 dasd_eer_start_record(eerb, header.total_size);
356                 dasd_eer_write_buffer(eerb, (char *) &header , sizeof(header));
357                 if (!snss_rc)
358                         dasd_eer_write_buffer(eerb, cqr->data, SNSS_DATA_SIZE);
359                 dasd_eer_write_buffer(eerb, "EOR", 4);
360         }
361         spin_unlock_irqrestore(&bufferlock, flags);
362         wake_up_interruptible(&dasd_eer_read_wait_queue);
363 }
364
365 /*
366  * This function is called for all triggers. It calls the appropriate
367  * function that writes the actual trigger records.
368  */
369 void dasd_eer_write(struct dasd_device *device, struct dasd_ccw_req *cqr,
370                     unsigned int id)
371 {
372         if (!device->eer_cqr)
373                 return;
374         switch (id) {
375         case DASD_EER_FATALERROR:
376         case DASD_EER_PPRCSUSPEND:
377                 dasd_eer_write_standard_trigger(device, cqr, id);
378                 break;
379         case DASD_EER_NOPATH:
380                 dasd_eer_write_standard_trigger(device, NULL, id);
381                 break;
382         case DASD_EER_STATECHANGE:
383                 dasd_eer_write_snss_trigger(device, cqr, id);
384                 break;
385         default: /* unknown trigger, so we write it without any sense data */
386                 dasd_eer_write_standard_trigger(device, NULL, id);
387                 break;
388         }
389 }
390 EXPORT_SYMBOL(dasd_eer_write);
391
392 /*
393  * Start a sense subsystem status request.
394  * Needs to be called with the device held.
395  */
396 void dasd_eer_snss(struct dasd_device *device)
397 {
398         struct dasd_ccw_req *cqr;
399
400         cqr = device->eer_cqr;
401         if (!cqr)       /* Device not eer enabled. */
402                 return;
403         if (test_and_set_bit(DASD_FLAG_EER_IN_USE, &device->flags)) {
404                 /* Sense subsystem status request in use. */
405                 set_bit(DASD_FLAG_EER_SNSS, &device->flags);
406                 return;
407         }
408         /* cdev is already locked, can't use dasd_add_request_head */
409         clear_bit(DASD_FLAG_EER_SNSS, &device->flags);
410         cqr->status = DASD_CQR_QUEUED;
411         list_add(&cqr->devlist, &device->ccw_queue);
412         dasd_schedule_device_bh(device);
413 }
414
415 /*
416  * Callback function for use with sense subsystem status request.
417  */
418 static void dasd_eer_snss_cb(struct dasd_ccw_req *cqr, void *data)
419 {
420         struct dasd_device *device = cqr->startdev;
421         unsigned long flags;
422
423         dasd_eer_write(device, cqr, DASD_EER_STATECHANGE);
424         spin_lock_irqsave(get_ccwdev_lock(device->cdev), flags);
425         if (device->eer_cqr == cqr) {
426                 clear_bit(DASD_FLAG_EER_IN_USE, &device->flags);
427                 if (test_bit(DASD_FLAG_EER_SNSS, &device->flags))
428                         /* Another SNSS has been requested in the meantime. */
429                         dasd_eer_snss(device);
430                 cqr = NULL;
431         }
432         spin_unlock_irqrestore(get_ccwdev_lock(device->cdev), flags);
433         if (cqr)
434                 /*
435                  * Extended error recovery has been switched off while
436                  * the SNSS request was running. It could even have
437                  * been switched off and on again in which case there
438                  * is a new ccw in device->eer_cqr. Free the "old"
439                  * snss request now.
440                  */
441                 dasd_kfree_request(cqr, device);
442 }
443
444 /*
445  * Enable error reporting on a given device.
446  */
447 int dasd_eer_enable(struct dasd_device *device)
448 {
449         struct dasd_ccw_req *cqr;
450         unsigned long flags;
451
452         if (device->eer_cqr)
453                 return 0;
454
455         if (!device->discipline || strcmp(device->discipline->name, "ECKD"))
456                 return -EPERM;  /* FIXME: -EMEDIUMTYPE ? */
457
458         cqr = dasd_kmalloc_request("ECKD", 1 /* SNSS */,
459                                    SNSS_DATA_SIZE, device);
460         if (!cqr)
461                 return -ENOMEM;
462
463         cqr->startdev = device;
464         cqr->retries = 255;
465         cqr->expires = 10 * HZ;
466         clear_bit(DASD_CQR_FLAGS_USE_ERP, &cqr->flags);
467
468         cqr->cpaddr->cmd_code = DASD_ECKD_CCW_SNSS;
469         cqr->cpaddr->count = SNSS_DATA_SIZE;
470         cqr->cpaddr->flags = 0;
471         cqr->cpaddr->cda = (__u32)(addr_t) cqr->data;
472
473         cqr->buildclk = get_clock();
474         cqr->status = DASD_CQR_FILLED;
475         cqr->callback = dasd_eer_snss_cb;
476
477         spin_lock_irqsave(get_ccwdev_lock(device->cdev), flags);
478         if (!device->eer_cqr) {
479                 device->eer_cqr = cqr;
480                 cqr = NULL;
481         }
482         spin_unlock_irqrestore(get_ccwdev_lock(device->cdev), flags);
483         if (cqr)
484                 dasd_kfree_request(cqr, device);
485         return 0;
486 }
487
488 /*
489  * Disable error reporting on a given device.
490  */
491 void dasd_eer_disable(struct dasd_device *device)
492 {
493         struct dasd_ccw_req *cqr;
494         unsigned long flags;
495         int in_use;
496
497         if (!device->eer_cqr)
498                 return;
499         spin_lock_irqsave(get_ccwdev_lock(device->cdev), flags);
500         cqr = device->eer_cqr;
501         device->eer_cqr = NULL;
502         clear_bit(DASD_FLAG_EER_SNSS, &device->flags);
503         in_use = test_and_clear_bit(DASD_FLAG_EER_IN_USE, &device->flags);
504         spin_unlock_irqrestore(get_ccwdev_lock(device->cdev), flags);
505         if (cqr && !in_use)
506                 dasd_kfree_request(cqr, device);
507 }
508
509 /*
510  * SECTION: the device operations
511  */
512
513 /*
514  * On the one side we need a lock to access our internal buffer, on the
515  * other side a copy_to_user can sleep. So we need to copy the data we have
516  * to transfer in a readbuffer, which is protected by the readbuffer_mutex.
517  */
518 static char readbuffer[PAGE_SIZE];
519 static DEFINE_MUTEX(readbuffer_mutex);
520
521 static int dasd_eer_open(struct inode *inp, struct file *filp)
522 {
523         struct eerbuffer *eerb;
524         unsigned long flags;
525
526         eerb = kzalloc(sizeof(struct eerbuffer), GFP_KERNEL);
527         if (!eerb)
528                 return -ENOMEM;
529         lock_kernel();
530         eerb->buffer_page_count = eer_pages;
531         if (eerb->buffer_page_count < 1 ||
532             eerb->buffer_page_count > INT_MAX / PAGE_SIZE) {
533                 kfree(eerb);
534                 MESSAGE(KERN_WARNING, "can't open device since module "
535                         "parameter eer_pages is smaller then 1 or"
536                         " bigger then %d", (int)(INT_MAX / PAGE_SIZE));
537                 unlock_kernel();
538                 return -EINVAL;
539         }
540         eerb->buffersize = eerb->buffer_page_count * PAGE_SIZE;
541         eerb->buffer = kmalloc(eerb->buffer_page_count * sizeof(char *),
542                                GFP_KERNEL);
543         if (!eerb->buffer) {
544                 kfree(eerb);
545                 unlock_kernel();
546                 return -ENOMEM;
547         }
548         if (dasd_eer_allocate_buffer_pages(eerb->buffer,
549                                            eerb->buffer_page_count)) {
550                 kfree(eerb->buffer);
551                 kfree(eerb);
552                 unlock_kernel();
553                 return -ENOMEM;
554         }
555         filp->private_data = eerb;
556         spin_lock_irqsave(&bufferlock, flags);
557         list_add(&eerb->list, &bufferlist);
558         spin_unlock_irqrestore(&bufferlock, flags);
559
560         unlock_kernel();
561         return nonseekable_open(inp,filp);
562 }
563
564 static int dasd_eer_close(struct inode *inp, struct file *filp)
565 {
566         struct eerbuffer *eerb;
567         unsigned long flags;
568
569         eerb = (struct eerbuffer *) filp->private_data;
570         spin_lock_irqsave(&bufferlock, flags);
571         list_del(&eerb->list);
572         spin_unlock_irqrestore(&bufferlock, flags);
573         dasd_eer_free_buffer_pages(eerb->buffer, eerb->buffer_page_count);
574         kfree(eerb->buffer);
575         kfree(eerb);
576
577         return 0;
578 }
579
580 static ssize_t dasd_eer_read(struct file *filp, char __user *buf,
581                              size_t count, loff_t *ppos)
582 {
583         int tc,rc;
584         int tailcount,effective_count;
585         unsigned long flags;
586         struct eerbuffer *eerb;
587
588         eerb = (struct eerbuffer *) filp->private_data;
589         if (mutex_lock_interruptible(&readbuffer_mutex))
590                 return -ERESTARTSYS;
591
592         spin_lock_irqsave(&bufferlock, flags);
593
594         if (eerb->residual < 0) { /* the remainder of this record */
595                                   /* has been deleted             */
596                 eerb->residual = 0;
597                 spin_unlock_irqrestore(&bufferlock, flags);
598                 mutex_unlock(&readbuffer_mutex);
599                 return -EIO;
600         } else if (eerb->residual > 0) {
601                 /* OK we still have a second half of a record to deliver */
602                 effective_count = min(eerb->residual, (int) count);
603                 eerb->residual -= effective_count;
604         } else {
605                 tc = 0;
606                 while (!tc) {
607                         tc = dasd_eer_read_buffer(eerb, (char *) &tailcount,
608                                                   sizeof(tailcount));
609                         if (!tc) {
610                                 /* no data available */
611                                 spin_unlock_irqrestore(&bufferlock, flags);
612                                 mutex_unlock(&readbuffer_mutex);
613                                 if (filp->f_flags & O_NONBLOCK)
614                                         return -EAGAIN;
615                                 rc = wait_event_interruptible(
616                                         dasd_eer_read_wait_queue,
617                                         eerb->head != eerb->tail);
618                                 if (rc)
619                                         return rc;
620                                 if (mutex_lock_interruptible(&readbuffer_mutex))
621                                         return -ERESTARTSYS;
622                                 spin_lock_irqsave(&bufferlock, flags);
623                         }
624                 }
625                 WARN_ON(tc != sizeof(tailcount));
626                 effective_count = min(tailcount,(int)count);
627                 eerb->residual = tailcount - effective_count;
628         }
629
630         tc = dasd_eer_read_buffer(eerb, readbuffer, effective_count);
631         WARN_ON(tc != effective_count);
632
633         spin_unlock_irqrestore(&bufferlock, flags);
634
635         if (copy_to_user(buf, readbuffer, effective_count)) {
636                 mutex_unlock(&readbuffer_mutex);
637                 return -EFAULT;
638         }
639
640         mutex_unlock(&readbuffer_mutex);
641         return effective_count;
642 }
643
644 static unsigned int dasd_eer_poll(struct file *filp, poll_table *ptable)
645 {
646         unsigned int mask;
647         unsigned long flags;
648         struct eerbuffer *eerb;
649
650         eerb = (struct eerbuffer *) filp->private_data;
651         poll_wait(filp, &dasd_eer_read_wait_queue, ptable);
652         spin_lock_irqsave(&bufferlock, flags);
653         if (eerb->head != eerb->tail)
654                 mask = POLLIN | POLLRDNORM ;
655         else
656                 mask = 0;
657         spin_unlock_irqrestore(&bufferlock, flags);
658         return mask;
659 }
660
661 static const struct file_operations dasd_eer_fops = {
662         .open           = &dasd_eer_open,
663         .release        = &dasd_eer_close,
664         .read           = &dasd_eer_read,
665         .poll           = &dasd_eer_poll,
666         .owner          = THIS_MODULE,
667 };
668
669 static struct miscdevice *dasd_eer_dev = NULL;
670
671 int __init dasd_eer_init(void)
672 {
673         int rc;
674
675         dasd_eer_dev = kzalloc(sizeof(*dasd_eer_dev), GFP_KERNEL);
676         if (!dasd_eer_dev)
677                 return -ENOMEM;
678
679         dasd_eer_dev->minor = MISC_DYNAMIC_MINOR;
680         dasd_eer_dev->name  = "dasd_eer";
681         dasd_eer_dev->fops  = &dasd_eer_fops;
682
683         rc = misc_register(dasd_eer_dev);
684         if (rc) {
685                 kfree(dasd_eer_dev);
686                 dasd_eer_dev = NULL;
687                 MESSAGE(KERN_ERR, "%s", "dasd_eer_init could not "
688                        "register misc device");
689                 return rc;
690         }
691
692         return 0;
693 }
694
695 void dasd_eer_exit(void)
696 {
697         if (dasd_eer_dev) {
698                 WARN_ON(misc_deregister(dasd_eer_dev) != 0);
699                 kfree(dasd_eer_dev);
700                 dasd_eer_dev = NULL;
701         }
702 }