|
@@ -225,6 +225,7 @@ static void ld_usb_interrupt_in_callback(struct urb *urb)
|
|
|
size_t *actual_buffer;
|
|
|
unsigned int next_ring_head;
|
|
|
int status = urb->status;
|
|
|
+ unsigned long flags;
|
|
|
int retval;
|
|
|
|
|
|
if (status) {
|
|
@@ -236,12 +237,12 @@ static void ld_usb_interrupt_in_callback(struct urb *urb)
|
|
|
dev_dbg(&dev->intf->dev,
|
|
|
"%s: nonzero status received: %d\n", __func__,
|
|
|
status);
|
|
|
- spin_lock(&dev->rbsl);
|
|
|
+ spin_lock_irqsave(&dev->rbsl, flags);
|
|
|
goto resubmit; /* maybe we can recover */
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- spin_lock(&dev->rbsl);
|
|
|
+ spin_lock_irqsave(&dev->rbsl, flags);
|
|
|
if (urb->actual_length > 0) {
|
|
|
next_ring_head = (dev->ring_head+1) % ring_buffer_size;
|
|
|
if (next_ring_head != dev->ring_tail) {
|
|
@@ -270,7 +271,7 @@ resubmit:
|
|
|
dev->buffer_overflow = 1;
|
|
|
}
|
|
|
}
|
|
|
- spin_unlock(&dev->rbsl);
|
|
|
+ spin_unlock_irqrestore(&dev->rbsl, flags);
|
|
|
exit:
|
|
|
dev->interrupt_in_done = 1;
|
|
|
wake_up_interruptible(&dev->read_wait);
|