|
@@ -209,6 +209,7 @@ skip_error:
|
|
|
static void wdm_int_callback(struct urb *urb)
|
|
|
{
|
|
|
int rv = 0;
|
|
|
+ int responding;
|
|
|
int status = urb->status;
|
|
|
struct wdm_device *desc;
|
|
|
struct usb_cdc_notification *dr;
|
|
@@ -262,8 +263,8 @@ static void wdm_int_callback(struct urb *urb)
|
|
|
|
|
|
spin_lock(&desc->iuspin);
|
|
|
clear_bit(WDM_READ, &desc->flags);
|
|
|
- set_bit(WDM_RESPONDING, &desc->flags);
|
|
|
- if (!test_bit(WDM_DISCONNECTING, &desc->flags)
|
|
|
+ responding = test_and_set_bit(WDM_RESPONDING, &desc->flags);
|
|
|
+ if (!responding && !test_bit(WDM_DISCONNECTING, &desc->flags)
|
|
|
&& !test_bit(WDM_SUSPENDING, &desc->flags)) {
|
|
|
rv = usb_submit_urb(desc->response, GFP_ATOMIC);
|
|
|
dev_dbg(&desc->intf->dev, "%s: usb_submit_urb %d",
|
|
@@ -685,16 +686,20 @@ static void wdm_rxwork(struct work_struct *work)
|
|
|
{
|
|
|
struct wdm_device *desc = container_of(work, struct wdm_device, rxwork);
|
|
|
unsigned long flags;
|
|
|
- int rv;
|
|
|
+ int rv = 0;
|
|
|
+ int responding;
|
|
|
|
|
|
spin_lock_irqsave(&desc->iuspin, flags);
|
|
|
if (test_bit(WDM_DISCONNECTING, &desc->flags)) {
|
|
|
spin_unlock_irqrestore(&desc->iuspin, flags);
|
|
|
} else {
|
|
|
+ responding = test_and_set_bit(WDM_RESPONDING, &desc->flags);
|
|
|
spin_unlock_irqrestore(&desc->iuspin, flags);
|
|
|
- rv = usb_submit_urb(desc->response, GFP_KERNEL);
|
|
|
+ if (!responding)
|
|
|
+ rv = usb_submit_urb(desc->response, GFP_KERNEL);
|
|
|
if (rv < 0 && rv != -EPERM) {
|
|
|
spin_lock_irqsave(&desc->iuspin, flags);
|
|
|
+ clear_bit(WDM_RESPONDING, &desc->flags);
|
|
|
if (!test_bit(WDM_DISCONNECTING, &desc->flags))
|
|
|
schedule_work(&desc->rxwork);
|
|
|
spin_unlock_irqrestore(&desc->iuspin, flags);
|