Lines Matching refs:dev
105 static inline void adu_debug_data(struct device *dev, const char *function, in adu_debug_data() argument
108 dev_dbg(dev, "%s - length = %d, data = %*ph\n", in adu_debug_data()
116 static void adu_abort_transfers(struct adu_device *dev) in adu_abort_transfers() argument
120 if (dev->disconnected) in adu_abort_transfers()
126 spin_lock_irqsave(&dev->buflock, flags); in adu_abort_transfers()
127 if (!dev->read_urb_finished) { in adu_abort_transfers()
128 spin_unlock_irqrestore(&dev->buflock, flags); in adu_abort_transfers()
129 usb_kill_urb(dev->interrupt_in_urb); in adu_abort_transfers()
131 spin_unlock_irqrestore(&dev->buflock, flags); in adu_abort_transfers()
133 spin_lock_irqsave(&dev->buflock, flags); in adu_abort_transfers()
134 if (!dev->out_urb_finished) { in adu_abort_transfers()
135 spin_unlock_irqrestore(&dev->buflock, flags); in adu_abort_transfers()
136 wait_event_timeout(dev->write_wait, dev->out_urb_finished, in adu_abort_transfers()
138 usb_kill_urb(dev->interrupt_out_urb); in adu_abort_transfers()
140 spin_unlock_irqrestore(&dev->buflock, flags); in adu_abort_transfers()
143 static void adu_delete(struct adu_device *dev) in adu_delete() argument
146 usb_free_urb(dev->interrupt_in_urb); in adu_delete()
147 usb_free_urb(dev->interrupt_out_urb); in adu_delete()
148 kfree(dev->read_buffer_primary); in adu_delete()
149 kfree(dev->read_buffer_secondary); in adu_delete()
150 kfree(dev->interrupt_in_buffer); in adu_delete()
151 kfree(dev->interrupt_out_buffer); in adu_delete()
152 usb_put_dev(dev->udev); in adu_delete()
153 kfree(dev); in adu_delete()
158 struct adu_device *dev = urb->context; in adu_interrupt_in_callback() local
162 adu_debug_data(&dev->udev->dev, __func__, in adu_interrupt_in_callback()
165 spin_lock_irqsave(&dev->buflock, flags); in adu_interrupt_in_callback()
170 dev_dbg(&dev->udev->dev, in adu_interrupt_in_callback()
177 if (urb->actual_length > 0 && dev->interrupt_in_buffer[0] != 0x00) { in adu_interrupt_in_callback()
178 if (dev->read_buffer_length < in adu_interrupt_in_callback()
179 (4 * usb_endpoint_maxp(dev->interrupt_in_endpoint)) - in adu_interrupt_in_callback()
181 memcpy (dev->read_buffer_primary + in adu_interrupt_in_callback()
182 dev->read_buffer_length, in adu_interrupt_in_callback()
183 dev->interrupt_in_buffer, urb->actual_length); in adu_interrupt_in_callback()
185 dev->read_buffer_length += urb->actual_length; in adu_interrupt_in_callback()
186 dev_dbg(&dev->udev->dev, "%s reading %d\n", __func__, in adu_interrupt_in_callback()
189 dev_dbg(&dev->udev->dev, "%s : read_buffer overflow\n", in adu_interrupt_in_callback()
195 dev->read_urb_finished = 1; in adu_interrupt_in_callback()
196 spin_unlock_irqrestore(&dev->buflock, flags); in adu_interrupt_in_callback()
198 wake_up_interruptible(&dev->read_wait); in adu_interrupt_in_callback()
203 struct adu_device *dev = urb->context; in adu_interrupt_out_callback() local
207 adu_debug_data(&dev->udev->dev, __func__, in adu_interrupt_out_callback()
214 dev_dbg(&dev->udev->dev, in adu_interrupt_out_callback()
221 spin_lock_irqsave(&dev->buflock, flags); in adu_interrupt_out_callback()
222 dev->out_urb_finished = 1; in adu_interrupt_out_callback()
223 wake_up(&dev->write_wait); in adu_interrupt_out_callback()
224 spin_unlock_irqrestore(&dev->buflock, flags); in adu_interrupt_out_callback()
229 struct adu_device *dev = NULL; in adu_open() local
248 dev = usb_get_intfdata(interface); in adu_open()
249 if (!dev) { in adu_open()
255 if (dev->open_count) { in adu_open()
260 ++dev->open_count; in adu_open()
261 dev_dbg(&dev->udev->dev, "%s: open count %d\n", __func__, in adu_open()
262 dev->open_count); in adu_open()
265 file->private_data = dev; in adu_open()
268 dev->read_buffer_length = 0; in adu_open()
271 usb_fill_int_urb(dev->interrupt_in_urb, dev->udev, in adu_open()
272 usb_rcvintpipe(dev->udev, in adu_open()
273 dev->interrupt_in_endpoint->bEndpointAddress), in adu_open()
274 dev->interrupt_in_buffer, in adu_open()
275 usb_endpoint_maxp(dev->interrupt_in_endpoint), in adu_open()
276 adu_interrupt_in_callback, dev, in adu_open()
277 dev->interrupt_in_endpoint->bInterval); in adu_open()
278 dev->read_urb_finished = 0; in adu_open()
279 if (usb_submit_urb(dev->interrupt_in_urb, GFP_KERNEL)) in adu_open()
280 dev->read_urb_finished = 1; in adu_open()
285 dev->out_urb_finished = 1; in adu_open()
295 static void adu_release_internal(struct adu_device *dev) in adu_release_internal() argument
298 --dev->open_count; in adu_release_internal()
299 dev_dbg(&dev->udev->dev, "%s : open count %d\n", __func__, in adu_release_internal()
300 dev->open_count); in adu_release_internal()
301 if (dev->open_count <= 0) { in adu_release_internal()
302 adu_abort_transfers(dev); in adu_release_internal()
303 dev->open_count = 0; in adu_release_internal()
309 struct adu_device *dev; in adu_release() local
317 dev = file->private_data; in adu_release()
318 if (dev == NULL) { in adu_release()
325 if (dev->open_count <= 0) { in adu_release()
326 dev_dbg(&dev->udev->dev, "%s : device not opened\n", __func__); in adu_release()
331 adu_release_internal(dev); in adu_release()
332 if (dev->disconnected) { in adu_release()
334 if (!dev->open_count) /* ... and we're the last user */ in adu_release()
335 adu_delete(dev); in adu_release()
346 struct adu_device *dev; in adu_read() local
355 dev = file->private_data; in adu_read()
356 if (mutex_lock_interruptible(&dev->mtx)) in adu_read()
360 if (dev->disconnected) { in adu_read()
368 dev_dbg(&dev->udev->dev, "%s : read request of 0 bytes\n", in adu_read()
374 dev_dbg(&dev->udev->dev, "%s : about to start looping\n", __func__); in adu_read()
376 size_t data_in_secondary = dev->secondary_tail - dev->secondary_head; in adu_read()
377 dev_dbg(&dev->udev->dev, in adu_read()
380 dev->interrupt_in_urb->status); in adu_read()
385 if (copy_to_user(buffer, dev->read_buffer_secondary+dev->secondary_head, amount)) { in adu_read()
389 dev->secondary_head += amount; in adu_read()
394 spin_lock_irqsave (&dev->buflock, flags); in adu_read()
395 if (dev->read_buffer_length) { in adu_read()
397 dev_dbg(&dev->udev->dev, in adu_read()
399 __func__, dev->read_buffer_length); in adu_read()
400 swap(dev->read_buffer_primary, dev->read_buffer_secondary); in adu_read()
401 dev->secondary_head = 0; in adu_read()
402 dev->secondary_tail = dev->read_buffer_length; in adu_read()
403 dev->read_buffer_length = 0; in adu_read()
404 spin_unlock_irqrestore(&dev->buflock, flags); in adu_read()
409 if (!dev->read_urb_finished) { in adu_read()
411 spin_unlock_irqrestore(&dev->buflock, flags); in adu_read()
412 dev_dbg(&dev->udev->dev, in adu_read()
417 dev_dbg(&dev->udev->dev, in adu_read()
420 dev->read_urb_finished = 0; in adu_read()
421 spin_unlock_irqrestore(&dev->buflock, flags); in adu_read()
423 usb_fill_int_urb(dev->interrupt_in_urb, dev->udev, in adu_read()
424 usb_rcvintpipe(dev->udev, in adu_read()
425 dev->interrupt_in_endpoint->bEndpointAddress), in adu_read()
426 dev->interrupt_in_buffer, in adu_read()
427 usb_endpoint_maxp(dev->interrupt_in_endpoint), in adu_read()
429 dev, in adu_read()
430 dev->interrupt_in_endpoint->bInterval); in adu_read()
431 retval = usb_submit_urb(dev->interrupt_in_urb, GFP_KERNEL); in adu_read()
433 dev->read_urb_finished = 1; in adu_read()
437 dev_dbg(&dev->udev->dev, in adu_read()
446 add_wait_queue(&dev->read_wait, &wait); in adu_read()
447 spin_lock_irqsave(&dev->buflock, flags); in adu_read()
448 if (!dev->read_urb_finished) { in adu_read()
449 spin_unlock_irqrestore(&dev->buflock, flags); in adu_read()
452 spin_unlock_irqrestore(&dev->buflock, flags); in adu_read()
455 remove_wait_queue(&dev->read_wait, &wait); in adu_read()
458 dev_dbg(&dev->udev->dev, in adu_read()
465 dev_dbg(&dev->udev->dev, in adu_read()
477 spin_lock_irqsave(&dev->buflock, flags); in adu_read()
478 if (should_submit && dev->read_urb_finished) { in adu_read()
479 dev->read_urb_finished = 0; in adu_read()
480 spin_unlock_irqrestore(&dev->buflock, flags); in adu_read()
481 usb_fill_int_urb(dev->interrupt_in_urb, dev->udev, in adu_read()
482 usb_rcvintpipe(dev->udev, in adu_read()
483 dev->interrupt_in_endpoint->bEndpointAddress), in adu_read()
484 dev->interrupt_in_buffer, in adu_read()
485 usb_endpoint_maxp(dev->interrupt_in_endpoint), in adu_read()
487 dev, in adu_read()
488 dev->interrupt_in_endpoint->bInterval); in adu_read()
489 if (usb_submit_urb(dev->interrupt_in_urb, GFP_KERNEL) != 0) in adu_read()
490 dev->read_urb_finished = 1; in adu_read()
493 spin_unlock_irqrestore(&dev->buflock, flags); in adu_read()
498 mutex_unlock(&dev->mtx); in adu_read()
507 struct adu_device *dev; in adu_write() local
514 dev = file->private_data; in adu_write()
516 retval = mutex_lock_interruptible(&dev->mtx); in adu_write()
521 if (dev->disconnected) { in adu_write()
529 dev_dbg(&dev->udev->dev, "%s : write request of 0 bytes\n", in adu_write()
535 add_wait_queue(&dev->write_wait, &waita); in adu_write()
537 spin_lock_irqsave(&dev->buflock, flags); in adu_write()
538 if (!dev->out_urb_finished) { in adu_write()
539 spin_unlock_irqrestore(&dev->buflock, flags); in adu_write()
541 mutex_unlock(&dev->mtx); in adu_write()
543 dev_dbg(&dev->udev->dev, "%s : interrupted\n", in adu_write()
550 dev_dbg(&dev->udev->dev, in adu_write()
555 remove_wait_queue(&dev->write_wait, &waita); in adu_write()
556 retval = mutex_lock_interruptible(&dev->mtx); in adu_write()
562 dev_dbg(&dev->udev->dev, in adu_write()
566 spin_unlock_irqrestore(&dev->buflock, flags); in adu_write()
568 remove_wait_queue(&dev->write_wait, &waita); in adu_write()
569 dev_dbg(&dev->udev->dev, "%s : sending, count = %zd\n", in adu_write()
573 buffer_size = usb_endpoint_maxp(dev->interrupt_out_endpoint); in adu_write()
575 dev_dbg(&dev->udev->dev, in adu_write()
579 if (copy_from_user(dev->interrupt_out_buffer, buffer, bytes_to_write) != 0) { in adu_write()
586 dev->interrupt_out_urb, in adu_write()
587 dev->udev, in adu_write()
588 usb_sndintpipe(dev->udev, dev->interrupt_out_endpoint->bEndpointAddress), in adu_write()
589 dev->interrupt_out_buffer, in adu_write()
592 dev, in adu_write()
593 dev->interrupt_out_endpoint->bInterval); in adu_write()
594 dev->interrupt_out_urb->actual_length = bytes_to_write; in adu_write()
595 dev->out_urb_finished = 0; in adu_write()
596 retval = usb_submit_urb(dev->interrupt_out_urb, GFP_KERNEL); in adu_write()
598 dev->out_urb_finished = 1; in adu_write()
599 dev_err(&dev->udev->dev, "Couldn't submit " in adu_write()
610 mutex_unlock(&dev->mtx); in adu_write()
614 mutex_unlock(&dev->mtx); in adu_write()
619 remove_wait_queue(&dev->write_wait, &waita); in adu_write()
653 struct adu_device *dev = NULL; in adu_probe() local
660 dev = kzalloc(sizeof(struct adu_device), GFP_KERNEL); in adu_probe()
661 if (!dev) in adu_probe()
664 mutex_init(&dev->mtx); in adu_probe()
665 spin_lock_init(&dev->buflock); in adu_probe()
666 dev->udev = usb_get_dev(udev); in adu_probe()
667 init_waitqueue_head(&dev->read_wait); in adu_probe()
668 init_waitqueue_head(&dev->write_wait); in adu_probe()
672 &dev->interrupt_in_endpoint, in adu_probe()
673 &dev->interrupt_out_endpoint); in adu_probe()
675 dev_err(&interface->dev, "interrupt endpoints not found\n"); in adu_probe()
680 in_end_size = usb_endpoint_maxp(dev->interrupt_in_endpoint); in adu_probe()
681 out_end_size = usb_endpoint_maxp(dev->interrupt_out_endpoint); in adu_probe()
683 dev->read_buffer_primary = kmalloc((4 * in_end_size), GFP_KERNEL); in adu_probe()
684 if (!dev->read_buffer_primary) in adu_probe()
688 memset(dev->read_buffer_primary, 'a', in_end_size); in adu_probe()
689 memset(dev->read_buffer_primary + in_end_size, 'b', in_end_size); in adu_probe()
690 memset(dev->read_buffer_primary + (2 * in_end_size), 'c', in_end_size); in adu_probe()
691 memset(dev->read_buffer_primary + (3 * in_end_size), 'd', in_end_size); in adu_probe()
693 dev->read_buffer_secondary = kmalloc((4 * in_end_size), GFP_KERNEL); in adu_probe()
694 if (!dev->read_buffer_secondary) in adu_probe()
698 memset(dev->read_buffer_secondary, 'e', in_end_size); in adu_probe()
699 memset(dev->read_buffer_secondary + in_end_size, 'f', in_end_size); in adu_probe()
700 memset(dev->read_buffer_secondary + (2 * in_end_size), 'g', in_end_size); in adu_probe()
701 memset(dev->read_buffer_secondary + (3 * in_end_size), 'h', in_end_size); in adu_probe()
703 dev->interrupt_in_buffer = kmalloc(in_end_size, GFP_KERNEL); in adu_probe()
704 if (!dev->interrupt_in_buffer) in adu_probe()
708 memset(dev->interrupt_in_buffer, 'i', in_end_size); in adu_probe()
710 dev->interrupt_in_urb = usb_alloc_urb(0, GFP_KERNEL); in adu_probe()
711 if (!dev->interrupt_in_urb) in adu_probe()
713 dev->interrupt_out_buffer = kmalloc(out_end_size, GFP_KERNEL); in adu_probe()
714 if (!dev->interrupt_out_buffer) in adu_probe()
716 dev->interrupt_out_urb = usb_alloc_urb(0, GFP_KERNEL); in adu_probe()
717 if (!dev->interrupt_out_urb) in adu_probe()
720 if (!usb_string(udev, udev->descriptor.iSerialNumber, dev->serial_number, in adu_probe()
721 sizeof(dev->serial_number))) { in adu_probe()
722 dev_err(&interface->dev, "Could not retrieve serial number\n"); in adu_probe()
726 dev_dbg(&interface->dev, "serial_number=%s", dev->serial_number); in adu_probe()
729 usb_set_intfdata(interface, dev); in adu_probe()
735 dev_err(&interface->dev, "Not able to get a minor for this device.\n"); in adu_probe()
740 dev->minor = interface->minor; in adu_probe()
743 dev_info(&interface->dev, "ADU%d %s now attached to /dev/usb/adutux%d\n", in adu_probe()
744 le16_to_cpu(udev->descriptor.idProduct), dev->serial_number, in adu_probe()
745 (dev->minor - ADU_MINOR_BASE)); in adu_probe()
750 adu_delete(dev); in adu_probe()
761 struct adu_device *dev; in adu_disconnect() local
763 dev = usb_get_intfdata(interface); in adu_disconnect()
767 usb_poison_urb(dev->interrupt_in_urb); in adu_disconnect()
768 usb_poison_urb(dev->interrupt_out_urb); in adu_disconnect()
773 mutex_lock(&dev->mtx); /* not interruptible */ in adu_disconnect()
774 dev->disconnected = 1; in adu_disconnect()
775 mutex_unlock(&dev->mtx); in adu_disconnect()
778 if (!dev->open_count) in adu_disconnect()
779 adu_delete(dev); in adu_disconnect()