diff options
-rw-r--r-- | drivers/usb/storage/scsiglue.c | 2 | ||||
-rw-r--r-- | drivers/usb/storage/usb.c | 8 | ||||
-rw-r--r-- | drivers/usb/storage/usb.h | 2 |
3 files changed, 6 insertions, 6 deletions
diff --git a/drivers/usb/storage/scsiglue.c b/drivers/usb/storage/scsiglue.c index 1caf3f7af34..043b60b2ad1 100644 --- a/drivers/usb/storage/scsiglue.c +++ b/drivers/usb/storage/scsiglue.c | |||
@@ -248,7 +248,7 @@ static int queuecommand(struct scsi_cmnd *srb, | |||
248 | /* enqueue the command and wake up the control thread */ | 248 | /* enqueue the command and wake up the control thread */ |
249 | srb->scsi_done = done; | 249 | srb->scsi_done = done; |
250 | us->srb = srb; | 250 | us->srb = srb; |
251 | up(&(us->sema)); | 251 | complete(&us->cmnd_ready); |
252 | 252 | ||
253 | return 0; | 253 | return 0; |
254 | } | 254 | } |
diff --git a/drivers/usb/storage/usb.c b/drivers/usb/storage/usb.c index 78c0c7ee6b9..6b14f8d253f 100644 --- a/drivers/usb/storage/usb.c +++ b/drivers/usb/storage/usb.c | |||
@@ -312,9 +312,9 @@ static int usb_stor_control_thread(void * __us) | |||
312 | 312 | ||
313 | for(;;) { | 313 | for(;;) { |
314 | US_DEBUGP("*** thread sleeping.\n"); | 314 | US_DEBUGP("*** thread sleeping.\n"); |
315 | if(down_interruptible(&us->sema)) | 315 | if (wait_for_completion_interruptible(&us->cmnd_ready)) |
316 | break; | 316 | break; |
317 | 317 | ||
318 | US_DEBUGP("*** thread awakened.\n"); | 318 | US_DEBUGP("*** thread awakened.\n"); |
319 | 319 | ||
320 | /* lock the device pointers */ | 320 | /* lock the device pointers */ |
@@ -825,7 +825,7 @@ static void usb_stor_release_resources(struct us_data *us) | |||
825 | */ | 825 | */ |
826 | US_DEBUGP("-- sending exit command to thread\n"); | 826 | US_DEBUGP("-- sending exit command to thread\n"); |
827 | set_bit(US_FLIDX_DISCONNECTING, &us->dflags); | 827 | set_bit(US_FLIDX_DISCONNECTING, &us->dflags); |
828 | up(&us->sema); | 828 | complete(&us->cmnd_ready); |
829 | if (us->ctl_thread) | 829 | if (us->ctl_thread) |
830 | kthread_stop(us->ctl_thread); | 830 | kthread_stop(us->ctl_thread); |
831 | 831 | ||
@@ -975,7 +975,7 @@ static int storage_probe(struct usb_interface *intf, | |||
975 | us = host_to_us(host); | 975 | us = host_to_us(host); |
976 | memset(us, 0, sizeof(struct us_data)); | 976 | memset(us, 0, sizeof(struct us_data)); |
977 | mutex_init(&(us->dev_mutex)); | 977 | mutex_init(&(us->dev_mutex)); |
978 | init_MUTEX_LOCKED(&(us->sema)); | 978 | init_completion(&us->cmnd_ready); |
979 | init_completion(&(us->notify)); | 979 | init_completion(&(us->notify)); |
980 | init_waitqueue_head(&us->delay_wait); | 980 | init_waitqueue_head(&us->delay_wait); |
981 | init_completion(&us->scanning_done); | 981 | init_completion(&us->scanning_done); |
diff --git a/drivers/usb/storage/usb.h b/drivers/usb/storage/usb.h index b169132f021..8da96da5875 100644 --- a/drivers/usb/storage/usb.h +++ b/drivers/usb/storage/usb.h | |||
@@ -148,7 +148,7 @@ struct us_data { | |||
148 | struct task_struct *ctl_thread; /* the control thread */ | 148 | struct task_struct *ctl_thread; /* the control thread */ |
149 | 149 | ||
150 | /* mutual exclusion and synchronization structures */ | 150 | /* mutual exclusion and synchronization structures */ |
151 | struct semaphore sema; /* to sleep thread on */ | 151 | struct completion cmnd_ready; /* to sleep thread on */ |
152 | struct completion notify; /* thread begin/end */ | 152 | struct completion notify; /* thread begin/end */ |
153 | wait_queue_head_t delay_wait; /* wait during scan, reset */ | 153 | wait_queue_head_t delay_wait; /* wait during scan, reset */ |
154 | struct completion scanning_done; /* wait for scan thread */ | 154 | struct completion scanning_done; /* wait for scan thread */ |