diff options
-rw-r--r-- | drivers/usb/class/cdc-acm.c | 29 | ||||
-rw-r--r-- | include/linux/usb/cdc.h | 7 |
2 files changed, 25 insertions, 11 deletions
diff --git a/drivers/usb/class/cdc-acm.c b/drivers/usb/class/cdc-acm.c index 98199628e394..023cf5d45a9d 100644 --- a/drivers/usb/class/cdc-acm.c +++ b/drivers/usb/class/cdc-acm.c | |||
@@ -326,10 +326,16 @@ static void acm_rx_tasklet(unsigned long _acm) | |||
326 | struct tty_struct *tty = acm->tty; | 326 | struct tty_struct *tty = acm->tty; |
327 | struct acm_ru *rcv; | 327 | struct acm_ru *rcv; |
328 | unsigned long flags; | 328 | unsigned long flags; |
329 | int i = 0; | 329 | unsigned char throttled; |
330 | dbg("Entering acm_rx_tasklet"); | 330 | dbg("Entering acm_rx_tasklet"); |
331 | 331 | ||
332 | if (!ACM_READY(acm) || acm->throttle) | 332 | if (!ACM_READY(acm)) |
333 | return; | ||
334 | |||
335 | spin_lock(&acm->throttle_lock); | ||
336 | throttled = acm->throttle; | ||
337 | spin_unlock(&acm->throttle_lock); | ||
338 | if (throttled) | ||
333 | return; | 339 | return; |
334 | 340 | ||
335 | next_buffer: | 341 | next_buffer: |
@@ -346,22 +352,20 @@ next_buffer: | |||
346 | dbg("acm_rx_tasklet: procesing buf 0x%p, size = %d", buf, buf->size); | 352 | dbg("acm_rx_tasklet: procesing buf 0x%p, size = %d", buf, buf->size); |
347 | 353 | ||
348 | tty_buffer_request_room(tty, buf->size); | 354 | tty_buffer_request_room(tty, buf->size); |
349 | if (!acm->throttle) | 355 | spin_lock(&acm->throttle_lock); |
356 | throttled = acm->throttle; | ||
357 | spin_unlock(&acm->throttle_lock); | ||
358 | if (!throttled) | ||
350 | tty_insert_flip_string(tty, buf->base, buf->size); | 359 | tty_insert_flip_string(tty, buf->base, buf->size); |
351 | tty_flip_buffer_push(tty); | 360 | tty_flip_buffer_push(tty); |
352 | 361 | ||
353 | spin_lock(&acm->throttle_lock); | 362 | if (throttled) { |
354 | if (acm->throttle) { | 363 | dbg("Throttling noticed"); |
355 | dbg("Throtteling noticed"); | ||
356 | memmove(buf->base, buf->base + i, buf->size - i); | ||
357 | buf->size -= i; | ||
358 | spin_unlock(&acm->throttle_lock); | ||
359 | spin_lock_irqsave(&acm->read_lock, flags); | 364 | spin_lock_irqsave(&acm->read_lock, flags); |
360 | list_add(&buf->list, &acm->filled_read_bufs); | 365 | list_add(&buf->list, &acm->filled_read_bufs); |
361 | spin_unlock_irqrestore(&acm->read_lock, flags); | 366 | spin_unlock_irqrestore(&acm->read_lock, flags); |
362 | return; | 367 | return; |
363 | } | 368 | } |
364 | spin_unlock(&acm->throttle_lock); | ||
365 | 369 | ||
366 | spin_lock_irqsave(&acm->read_lock, flags); | 370 | spin_lock_irqsave(&acm->read_lock, flags); |
367 | list_add(&buf->list, &acm->spare_read_bufs); | 371 | list_add(&buf->list, &acm->spare_read_bufs); |
@@ -467,7 +471,8 @@ static int acm_tty_open(struct tty_struct *tty, struct file *filp) | |||
467 | goto bail_out; | 471 | goto bail_out; |
468 | } | 472 | } |
469 | 473 | ||
470 | if (0 > acm_set_control(acm, acm->ctrlout = ACM_CTRL_DTR | ACM_CTRL_RTS)) | 474 | if (0 > acm_set_control(acm, acm->ctrlout = ACM_CTRL_DTR | ACM_CTRL_RTS) && |
475 | (acm->ctrl_caps & USB_CDC_CAP_LINE)) | ||
471 | goto full_bailout; | 476 | goto full_bailout; |
472 | 477 | ||
473 | INIT_LIST_HEAD(&acm->spare_read_urbs); | 478 | INIT_LIST_HEAD(&acm->spare_read_urbs); |
@@ -480,6 +485,8 @@ static int acm_tty_open(struct tty_struct *tty, struct file *filp) | |||
480 | list_add(&(acm->rb[i].list), &acm->spare_read_bufs); | 485 | list_add(&(acm->rb[i].list), &acm->spare_read_bufs); |
481 | } | 486 | } |
482 | 487 | ||
488 | acm->throttle = 0; | ||
489 | |||
483 | tasklet_schedule(&acm->urb_task); | 490 | tasklet_schedule(&acm->urb_task); |
484 | 491 | ||
485 | done: | 492 | done: |
diff --git a/include/linux/usb/cdc.h b/include/linux/usb/cdc.h index ba617c372455..956edf3bbecb 100644 --- a/include/linux/usb/cdc.h +++ b/include/linux/usb/cdc.h | |||
@@ -73,6 +73,13 @@ struct usb_cdc_acm_descriptor { | |||
73 | __u8 bmCapabilities; | 73 | __u8 bmCapabilities; |
74 | } __attribute__ ((packed)); | 74 | } __attribute__ ((packed)); |
75 | 75 | ||
76 | /* capabilities from 5.2.3.3 */ | ||
77 | |||
78 | #define USB_CDC_COMM_FEATURE 0x01 | ||
79 | #define USB_CDC_CAP_LINE 0x02 | ||
80 | #define USB_CDC_CAP_BRK 0x04 | ||
81 | #define USB_CDC_CAP_NOTIFY 0x08 | ||
82 | |||
76 | /* "Union Functional Descriptor" from CDC spec 5.2.3.8 */ | 83 | /* "Union Functional Descriptor" from CDC spec 5.2.3.8 */ |
77 | struct usb_cdc_union_desc { | 84 | struct usb_cdc_union_desc { |
78 | __u8 bLength; | 85 | __u8 bLength; |