Lines Matching refs:dev
105 static inline void adu_debug_data(struct device *dev, const char *function,
108 dev_dbg(dev, "%s - length = %d, data = %*ph\n",
116 static void adu_abort_transfers(struct adu_device *dev)
120 if (dev->disconnected)
126 spin_lock_irqsave(&dev->buflock, flags);
127 if (!dev->read_urb_finished) {
128 spin_unlock_irqrestore(&dev->buflock, flags);
129 usb_kill_urb(dev->interrupt_in_urb);
131 spin_unlock_irqrestore(&dev->buflock, flags);
133 spin_lock_irqsave(&dev->buflock, flags);
134 if (!dev->out_urb_finished) {
135 spin_unlock_irqrestore(&dev->buflock, flags);
136 wait_event_timeout(dev->write_wait, dev->out_urb_finished,
138 usb_kill_urb(dev->interrupt_out_urb);
140 spin_unlock_irqrestore(&dev->buflock, flags);
143 static void adu_delete(struct adu_device *dev)
146 usb_free_urb(dev->interrupt_in_urb);
147 usb_free_urb(dev->interrupt_out_urb);
148 kfree(dev->read_buffer_primary);
149 kfree(dev->read_buffer_secondary);
150 kfree(dev->interrupt_in_buffer);
151 kfree(dev->interrupt_out_buffer);
152 usb_put_dev(dev->udev);
153 kfree(dev);
158 struct adu_device *dev = urb->context;
162 adu_debug_data(&dev->udev->dev, __func__,
165 spin_lock_irqsave(&dev->buflock, flags);
170 dev_dbg(&dev->udev->dev,
177 if (urb->actual_length > 0 && dev->interrupt_in_buffer[0] != 0x00) {
178 if (dev->read_buffer_length <
179 (4 * usb_endpoint_maxp(dev->interrupt_in_endpoint)) -
181 memcpy (dev->read_buffer_primary +
182 dev->read_buffer_length,
183 dev->interrupt_in_buffer, urb->actual_length);
185 dev->read_buffer_length += urb->actual_length;
186 dev_dbg(&dev->udev->dev,"%s reading %d\n", __func__,
189 dev_dbg(&dev->udev->dev,"%s : read_buffer overflow\n",
195 dev->read_urb_finished = 1;
196 spin_unlock_irqrestore(&dev->buflock, flags);
198 wake_up_interruptible(&dev->read_wait);
203 struct adu_device *dev = urb->context;
207 adu_debug_data(&dev->udev->dev, __func__,
214 dev_dbg(&dev->udev->dev,
221 spin_lock_irqsave(&dev->buflock, flags);
222 dev->out_urb_finished = 1;
223 wake_up(&dev->write_wait);
224 spin_unlock_irqrestore(&dev->buflock, flags);
229 struct adu_device *dev = NULL;
248 dev = usb_get_intfdata(interface);
249 if (!dev) {
255 if (dev->open_count) {
260 ++dev->open_count;
261 dev_dbg(&dev->udev->dev, "%s: open count %d\n", __func__,
262 dev->open_count);
265 file->private_data = dev;
268 dev->read_buffer_length = 0;
271 usb_fill_int_urb(dev->interrupt_in_urb, dev->udev,
272 usb_rcvintpipe(dev->udev,
273 dev->interrupt_in_endpoint->bEndpointAddress),
274 dev->interrupt_in_buffer,
275 usb_endpoint_maxp(dev->interrupt_in_endpoint),
276 adu_interrupt_in_callback, dev,
277 dev->interrupt_in_endpoint->bInterval);
278 dev->read_urb_finished = 0;
279 if (usb_submit_urb(dev->interrupt_in_urb, GFP_KERNEL))
280 dev->read_urb_finished = 1;
285 dev->out_urb_finished = 1;
295 static void adu_release_internal(struct adu_device *dev)
298 --dev->open_count;
299 dev_dbg(&dev->udev->dev, "%s : open count %d\n", __func__,
300 dev->open_count);
301 if (dev->open_count <= 0) {
302 adu_abort_transfers(dev);
303 dev->open_count = 0;
309 struct adu_device *dev;
317 dev = file->private_data;
318 if (dev == NULL) {
325 if (dev->open_count <= 0) {
326 dev_dbg(&dev->udev->dev, "%s : device not opened\n", __func__);
331 adu_release_internal(dev);
332 if (dev->disconnected) {
334 if (!dev->open_count) /* ... and we're the last user */
335 adu_delete(dev);
346 struct adu_device *dev;
355 dev = file->private_data;
356 if (mutex_lock_interruptible(&dev->mtx))
360 if (dev->disconnected) {
368 dev_dbg(&dev->udev->dev, "%s : read request of 0 bytes\n",
374 dev_dbg(&dev->udev->dev, "%s : about to start looping\n", __func__);
376 size_t data_in_secondary = dev->secondary_tail - dev->secondary_head;
377 dev_dbg(&dev->udev->dev,
380 dev->interrupt_in_urb->status);
385 if (copy_to_user(buffer, dev->read_buffer_secondary+dev->secondary_head, amount)) {
389 dev->secondary_head += amount;
394 spin_lock_irqsave (&dev->buflock, flags);
395 if (dev->read_buffer_length) {
398 dev_dbg(&dev->udev->dev,
400 __func__, dev->read_buffer_length);
401 tmp = dev->read_buffer_secondary;
402 dev->read_buffer_secondary = dev->read_buffer_primary;
403 dev->read_buffer_primary = tmp;
404 dev->secondary_head = 0;
405 dev->secondary_tail = dev->read_buffer_length;
406 dev->read_buffer_length = 0;
407 spin_unlock_irqrestore(&dev->buflock, flags);
412 if (!dev->read_urb_finished) {
414 spin_unlock_irqrestore(&dev->buflock, flags);
415 dev_dbg(&dev->udev->dev,
420 dev_dbg(&dev->udev->dev,
423 dev->read_urb_finished = 0;
424 spin_unlock_irqrestore(&dev->buflock, flags);
426 usb_fill_int_urb(dev->interrupt_in_urb, dev->udev,
427 usb_rcvintpipe(dev->udev,
428 dev->interrupt_in_endpoint->bEndpointAddress),
429 dev->interrupt_in_buffer,
430 usb_endpoint_maxp(dev->interrupt_in_endpoint),
432 dev,
433 dev->interrupt_in_endpoint->bInterval);
434 retval = usb_submit_urb(dev->interrupt_in_urb, GFP_KERNEL);
436 dev->read_urb_finished = 1;
440 dev_dbg(&dev->udev->dev,
449 add_wait_queue(&dev->read_wait, &wait);
450 spin_lock_irqsave(&dev->buflock, flags);
451 if (!dev->read_urb_finished) {
452 spin_unlock_irqrestore(&dev->buflock, flags);
455 spin_unlock_irqrestore(&dev->buflock, flags);
458 remove_wait_queue(&dev->read_wait, &wait);
461 dev_dbg(&dev->udev->dev,
468 dev_dbg(&dev->udev->dev,
480 spin_lock_irqsave(&dev->buflock, flags);
481 if (should_submit && dev->read_urb_finished) {
482 dev->read_urb_finished = 0;
483 spin_unlock_irqrestore(&dev->buflock, flags);
484 usb_fill_int_urb(dev->interrupt_in_urb, dev->udev,
485 usb_rcvintpipe(dev->udev,
486 dev->interrupt_in_endpoint->bEndpointAddress),
487 dev->interrupt_in_buffer,
488 usb_endpoint_maxp(dev->interrupt_in_endpoint),
490 dev,
491 dev->interrupt_in_endpoint->bInterval);
492 if (usb_submit_urb(dev->interrupt_in_urb, GFP_KERNEL) != 0)
493 dev->read_urb_finished = 1;
496 spin_unlock_irqrestore(&dev->buflock, flags);
501 mutex_unlock(&dev->mtx);
510 struct adu_device *dev;
517 dev = file->private_data;
519 retval = mutex_lock_interruptible(&dev->mtx);
524 if (dev->disconnected) {
532 dev_dbg(&dev->udev->dev, "%s : write request of 0 bytes\n",
538 add_wait_queue(&dev->write_wait, &waita);
540 spin_lock_irqsave(&dev->buflock, flags);
541 if (!dev->out_urb_finished) {
542 spin_unlock_irqrestore(&dev->buflock, flags);
544 mutex_unlock(&dev->mtx);
546 dev_dbg(&dev->udev->dev, "%s : interrupted\n",
553 dev_dbg(&dev->udev->dev,
558 remove_wait_queue(&dev->write_wait, &waita);
559 retval = mutex_lock_interruptible(&dev->mtx);
565 dev_dbg(&dev->udev->dev,
569 spin_unlock_irqrestore(&dev->buflock, flags);
571 remove_wait_queue(&dev->write_wait, &waita);
572 dev_dbg(&dev->udev->dev, "%s : sending, count = %zd\n",
576 buffer_size = usb_endpoint_maxp(dev->interrupt_out_endpoint);
578 dev_dbg(&dev->udev->dev,
582 if (copy_from_user(dev->interrupt_out_buffer, buffer, bytes_to_write) != 0) {
589 dev->interrupt_out_urb,
590 dev->udev,
591 usb_sndintpipe(dev->udev, dev->interrupt_out_endpoint->bEndpointAddress),
592 dev->interrupt_out_buffer,
595 dev,
596 dev->interrupt_out_endpoint->bInterval);
597 dev->interrupt_out_urb->actual_length = bytes_to_write;
598 dev->out_urb_finished = 0;
599 retval = usb_submit_urb(dev->interrupt_out_urb, GFP_KERNEL);
601 dev->out_urb_finished = 1;
602 dev_err(&dev->udev->dev, "Couldn't submit "
613 mutex_unlock(&dev->mtx);
617 mutex_unlock(&dev->mtx);
622 remove_wait_queue(&dev->write_wait, &waita);
656 struct adu_device *dev = NULL;
663 dev = kzalloc(sizeof(struct adu_device), GFP_KERNEL);
664 if (!dev)
667 mutex_init(&dev->mtx);
668 spin_lock_init(&dev->buflock);
669 dev->udev = usb_get_dev(udev);
670 init_waitqueue_head(&dev->read_wait);
671 init_waitqueue_head(&dev->write_wait);
675 &dev->interrupt_in_endpoint,
676 &dev->interrupt_out_endpoint);
678 dev_err(&interface->dev, "interrupt endpoints not found\n");
683 in_end_size = usb_endpoint_maxp(dev->interrupt_in_endpoint);
684 out_end_size = usb_endpoint_maxp(dev->interrupt_out_endpoint);
686 dev->read_buffer_primary = kmalloc((4 * in_end_size), GFP_KERNEL);
687 if (!dev->read_buffer_primary)
691 memset(dev->read_buffer_primary, 'a', in_end_size);
692 memset(dev->read_buffer_primary + in_end_size, 'b', in_end_size);
693 memset(dev->read_buffer_primary + (2 * in_end_size), 'c', in_end_size);
694 memset(dev->read_buffer_primary + (3 * in_end_size), 'd', in_end_size);
696 dev->read_buffer_secondary = kmalloc((4 * in_end_size), GFP_KERNEL);
697 if (!dev->read_buffer_secondary)
701 memset(dev->read_buffer_secondary, 'e', in_end_size);
702 memset(dev->read_buffer_secondary + in_end_size, 'f', in_end_size);
703 memset(dev->read_buffer_secondary + (2 * in_end_size), 'g', in_end_size);
704 memset(dev->read_buffer_secondary + (3 * in_end_size), 'h', in_end_size);
706 dev->interrupt_in_buffer = kmalloc(in_end_size, GFP_KERNEL);
707 if (!dev->interrupt_in_buffer)
711 memset(dev->interrupt_in_buffer, 'i', in_end_size);
713 dev->interrupt_in_urb = usb_alloc_urb(0, GFP_KERNEL);
714 if (!dev->interrupt_in_urb)
716 dev->interrupt_out_buffer = kmalloc(out_end_size, GFP_KERNEL);
717 if (!dev->interrupt_out_buffer)
719 dev->interrupt_out_urb = usb_alloc_urb(0, GFP_KERNEL);
720 if (!dev->interrupt_out_urb)
723 if (!usb_string(udev, udev->descriptor.iSerialNumber, dev->serial_number,
724 sizeof(dev->serial_number))) {
725 dev_err(&interface->dev, "Could not retrieve serial number\n");
729 dev_dbg(&interface->dev,"serial_number=%s", dev->serial_number);
732 usb_set_intfdata(interface, dev);
738 dev_err(&interface->dev, "Not able to get a minor for this device.\n");
743 dev->minor = interface->minor;
746 dev_info(&interface->dev, "ADU%d %s now attached to /dev/usb/adutux%d\n",
747 le16_to_cpu(udev->descriptor.idProduct), dev->serial_number,
748 (dev->minor - ADU_MINOR_BASE));
753 adu_delete(dev);
764 struct adu_device *dev;
766 dev = usb_get_intfdata(interface);
770 usb_poison_urb(dev->interrupt_in_urb);
771 usb_poison_urb(dev->interrupt_out_urb);
776 mutex_lock(&dev->mtx); /* not interruptible */
777 dev->disconnected = 1;
778 mutex_unlock(&dev->mtx);
781 if (!dev->open_count)
782 adu_delete(dev);