1 /* Driver for USB Mass Storage compliant devices
3 * Current development and maintenance by:
4 * (c) 1999-2003 Matthew Dharm (mdharm-usb@one-eyed-alien.net)
6 * Developed with the assistance of:
7 * (c) 2000 David L. Brown, Jr. (usb-storage@davidb.org)
8 * (c) 2003 Alan Stern (stern@rowland.harvard.edu)
11 * (c) 1999 Michael Gee (michael@linuxspecific.com)
13 * usb_device_id support by Adam J. Richter (adam@yggdrasil.com):
14 * (c) 2000 Yggdrasil Computing, Inc.
16 * This driver is based on the 'USB Mass Storage Class' document. This
17 * describes in detail the protocol used to communicate with such
18 * devices. Clearly, the designers had SCSI and ATAPI commands in
19 * mind when they created this document. The commands are all very
20 * similar to commands in the SCSI-II and ATAPI specifications.
22 * It is important to note that in a number of cases this class
23 * exhibits class-specific exemptions from the USB specification.
24 * Notably the usage of NAK, STALL and ACK differs from the norm, in
25 * that they are used to communicate wait, failed and OK on commands.
27 * Also, for certain devices, the interrupt endpoint is used to convey
28 * status of a command.
30 * Please see http://www.one-eyed-alien.net/~mdharm/linux-usb for more
31 * information about this driver.
33 * This program is free software; you can redistribute it and/or modify it
34 * under the terms of the GNU General Public License as published by the
35 * Free Software Foundation; either version 2, or (at your option) any
38 * This program is distributed in the hope that it will be useful, but
39 * WITHOUT ANY WARRANTY; without even the implied warranty of
40 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
41 * General Public License for more details.
43 * You should have received a copy of the GNU General Public License along
44 * with this program; if not, write to the Free Software Foundation, Inc.,
45 * 675 Mass Ave, Cambridge, MA 02139, USA.
48 #include <linux/sched.h>
49 #include <linux/errno.h>
50 #include <linux/freezer.h>
51 #include <linux/module.h>
52 #include <linux/init.h>
53 #include <linux/slab.h>
54 #include <linux/kthread.h>
55 #include <linux/mutex.h>
56 #include <linux/utsname.h>
58 #include <scsi/scsi.h>
59 #include <scsi/scsi_cmnd.h>
60 #include <scsi/scsi_device.h>
64 #include "transport.h"
67 #include "initializers.h"
69 #ifdef CONFIG_USB_STORAGE_USBAT
70 #include "shuttle_usbat.h"
72 #ifdef CONFIG_USB_STORAGE_SDDR09
75 #ifdef CONFIG_USB_STORAGE_SDDR55
78 #ifdef CONFIG_USB_STORAGE_DPCM
81 #ifdef CONFIG_USB_STORAGE_FREECOM
84 #ifdef CONFIG_USB_STORAGE_ISD200
87 #ifdef CONFIG_USB_STORAGE_DATAFAB
90 #ifdef CONFIG_USB_STORAGE_JUMPSHOT
93 #ifdef CONFIG_USB_STORAGE_ONETOUCH
96 #ifdef CONFIG_USB_STORAGE_ALAUDA
99 #ifdef CONFIG_USB_STORAGE_KARMA
102 #ifdef CONFIG_USB_STORAGE_CYPRESS_ATACB
103 #include "cypress_atacb.h"
106 /* Some informational data */
107 MODULE_AUTHOR("Matthew Dharm <mdharm-usb@one-eyed-alien.net>");
108 MODULE_DESCRIPTION("USB Mass Storage driver for Linux");
109 MODULE_LICENSE("GPL");
111 static unsigned int delay_use = 5;
112 module_param(delay_use, uint, S_IRUGO | S_IWUSR);
113 MODULE_PARM_DESC(delay_use, "seconds to delay before using a new device");
117 * The entries in this table correspond, line for line,
118 * with the entries of us_unusual_dev_list[].
120 #ifndef CONFIG_USB_LIBUSUAL
122 #define UNUSUAL_DEV(id_vendor, id_product, bcdDeviceMin, bcdDeviceMax, \
123 vendorName, productName,useProtocol, useTransport, \
124 initFunction, flags) \
125 { USB_DEVICE_VER(id_vendor, id_product, bcdDeviceMin,bcdDeviceMax), \
126 .driver_info = (flags)|(USB_US_TYPE_STOR<<24) }
128 #define USUAL_DEV(useProto, useTrans, useType) \
129 { USB_INTERFACE_INFO(USB_CLASS_MASS_STORAGE, useProto, useTrans), \
130 .driver_info = (USB_US_TYPE_STOR<<24) }
132 static struct usb_device_id storage_usb_ids [] = {
134 # include "unusual_devs.h"
137 /* Terminating entry */
141 MODULE_DEVICE_TABLE (usb, storage_usb_ids);
142 #endif /* CONFIG_USB_LIBUSUAL */
144 /* This is the list of devices we recognize, along with their flag data */
146 /* The vendor name should be kept at eight characters or less, and
147 * the product name should be kept at 16 characters or less. If a device
148 * has the US_FL_FIX_INQUIRY flag, then the vendor and product names
149 * normally generated by a device thorugh the INQUIRY response will be
150 * taken from this list, and this is the reason for the above size
151 * restriction. However, if the flag is not present, then you
152 * are free to use as many characters as you like.
155 #define UNUSUAL_DEV(idVendor, idProduct, bcdDeviceMin, bcdDeviceMax, \
156 vendor_name, product_name, use_protocol, use_transport, \
157 init_function, Flags) \
159 .vendorName = vendor_name, \
160 .productName = product_name, \
161 .useProtocol = use_protocol, \
162 .useTransport = use_transport, \
163 .initFunction = init_function, \
166 #define USUAL_DEV(use_protocol, use_transport, use_type) \
168 .useProtocol = use_protocol, \
169 .useTransport = use_transport, \
172 static struct us_unusual_dev us_unusual_dev_list[] = {
173 # include "unusual_devs.h"
177 /* Terminating entry */
182 #ifdef CONFIG_PM /* Minimal support for suspend and resume */
184 static int storage_suspend(struct usb_interface *iface, pm_message_t message)
186 struct us_data *us = usb_get_intfdata(iface);
188 /* Wait until no command is running */
189 mutex_lock(&us->dev_mutex);
191 US_DEBUGP("%s\n", __func__);
192 if (us->suspend_resume_hook)
193 (us->suspend_resume_hook)(us, US_SUSPEND);
195 /* When runtime PM is working, we'll set a flag to indicate
196 * whether we should autoresume when a SCSI request arrives. */
198 mutex_unlock(&us->dev_mutex);
202 static int storage_resume(struct usb_interface *iface)
204 struct us_data *us = usb_get_intfdata(iface);
206 mutex_lock(&us->dev_mutex);
208 US_DEBUGP("%s\n", __func__);
209 if (us->suspend_resume_hook)
210 (us->suspend_resume_hook)(us, US_RESUME);
212 mutex_unlock(&us->dev_mutex);
216 static int storage_reset_resume(struct usb_interface *iface)
218 struct us_data *us = usb_get_intfdata(iface);
220 US_DEBUGP("%s\n", __func__);
222 /* Report the reset to the SCSI core */
223 usb_stor_report_bus_reset(us);
225 /* FIXME: Notify the subdrivers that they need to reinitialize
230 #endif /* CONFIG_PM */
233 * The next two routines get called just before and just after
234 * a USB port reset, whether from this driver or a different one.
237 static int storage_pre_reset(struct usb_interface *iface)
239 struct us_data *us = usb_get_intfdata(iface);
241 US_DEBUGP("%s\n", __func__);
243 /* Make sure no command runs during the reset */
244 mutex_lock(&us->dev_mutex);
248 static int storage_post_reset(struct usb_interface *iface)
250 struct us_data *us = usb_get_intfdata(iface);
252 US_DEBUGP("%s\n", __func__);
254 /* Report the reset to the SCSI core */
255 usb_stor_report_bus_reset(us);
257 /* FIXME: Notify the subdrivers that they need to reinitialize
260 mutex_unlock(&us->dev_mutex);
265 * fill_inquiry_response takes an unsigned char array (which must
266 * be at least 36 characters) and populates the vendor name,
267 * product name, and revision fields. Then the array is copied
268 * into the SCSI command's response buffer (oddly enough
269 * called request_buffer). data_len contains the length of the
270 * data array, which again must be at least 36.
273 void fill_inquiry_response(struct us_data *us, unsigned char *data,
274 unsigned int data_len)
276 if (data_len<36) // You lose.
279 if(data[0]&0x20) { /* USB device currently not connected. Return
280 peripheral qualifier 001b ("...however, the
281 physical device is not currently connected
282 to this logical unit") and leave vendor and
283 product identification empty. ("If the target
284 does store some of the INQUIRY data on the
285 device, it may return zeros or ASCII spaces
286 (20h) in those fields until the data is
287 available from the device."). */
290 u16 bcdDevice = le16_to_cpu(us->pusb_dev->descriptor.bcdDevice);
291 memcpy(data+8, us->unusual_dev->vendorName,
292 strlen(us->unusual_dev->vendorName) > 8 ? 8 :
293 strlen(us->unusual_dev->vendorName));
294 memcpy(data+16, us->unusual_dev->productName,
295 strlen(us->unusual_dev->productName) > 16 ? 16 :
296 strlen(us->unusual_dev->productName));
297 data[32] = 0x30 + ((bcdDevice>>12) & 0x0F);
298 data[33] = 0x30 + ((bcdDevice>>8) & 0x0F);
299 data[34] = 0x30 + ((bcdDevice>>4) & 0x0F);
300 data[35] = 0x30 + ((bcdDevice) & 0x0F);
303 usb_stor_set_xfer_buf(data, data_len, us->srb);
306 static int usb_stor_control_thread(void * __us)
308 struct us_data *us = (struct us_data *)__us;
309 struct Scsi_Host *host = us_to_host(us);
312 US_DEBUGP("*** thread sleeping.\n");
313 if (wait_for_completion_interruptible(&us->cmnd_ready))
316 US_DEBUGP("*** thread awakened.\n");
318 /* lock the device pointers */
319 mutex_lock(&(us->dev_mutex));
321 /* lock access to the state */
324 /* When we are called with no command pending, we're done */
325 if (us->srb == NULL) {
327 mutex_unlock(&us->dev_mutex);
328 US_DEBUGP("-- exiting\n");
332 /* has the command timed out *already* ? */
333 if (test_bit(US_FLIDX_TIMED_OUT, &us->dflags)) {
334 us->srb->result = DID_ABORT << 16;
340 /* reject the command if the direction indicator
343 if (us->srb->sc_data_direction == DMA_BIDIRECTIONAL) {
344 US_DEBUGP("UNKNOWN data direction\n");
345 us->srb->result = DID_ERROR << 16;
348 /* reject if target != 0 or if LUN is higher than
349 * the maximum known LUN
351 else if (us->srb->device->id &&
352 !(us->fflags & US_FL_SCM_MULT_TARG)) {
353 US_DEBUGP("Bad target number (%d:%d)\n",
354 us->srb->device->id, us->srb->device->lun);
355 us->srb->result = DID_BAD_TARGET << 16;
358 else if (us->srb->device->lun > us->max_lun) {
359 US_DEBUGP("Bad LUN (%d:%d)\n",
360 us->srb->device->id, us->srb->device->lun);
361 us->srb->result = DID_BAD_TARGET << 16;
364 /* Handle those devices which need us to fake
365 * their inquiry data */
366 else if ((us->srb->cmnd[0] == INQUIRY) &&
367 (us->fflags & US_FL_FIX_INQUIRY)) {
368 unsigned char data_ptr[36] = {
369 0x00, 0x80, 0x02, 0x02,
370 0x1F, 0x00, 0x00, 0x00};
372 US_DEBUGP("Faking INQUIRY command\n");
373 fill_inquiry_response(us, data_ptr, 36);
374 us->srb->result = SAM_STAT_GOOD;
377 /* we've got a command, let's do it! */
379 US_DEBUG(usb_stor_show_command(us->srb));
380 us->proto_handler(us->srb, us);
383 /* lock access to the state */
386 /* indicate that the command is done */
387 if (us->srb->result != DID_ABORT << 16) {
388 US_DEBUGP("scsi cmd done, result=0x%x\n",
390 us->srb->scsi_done(us->srb);
393 US_DEBUGP("scsi command aborted\n");
396 /* If an abort request was received we need to signal that
397 * the abort has finished. The proper test for this is
398 * the TIMED_OUT flag, not srb->result == DID_ABORT, because
399 * the timeout might have occurred after the command had
400 * already completed with a different result code. */
401 if (test_bit(US_FLIDX_TIMED_OUT, &us->dflags)) {
402 complete(&(us->notify));
404 /* Allow USB transfers to resume */
405 clear_bit(US_FLIDX_ABORTING, &us->dflags);
406 clear_bit(US_FLIDX_TIMED_OUT, &us->dflags);
409 /* finished working on this command */
413 /* unlock the device pointers */
414 mutex_unlock(&us->dev_mutex);
417 /* Wait until we are told to stop */
419 set_current_state(TASK_INTERRUPTIBLE);
420 if (kthread_should_stop())
424 __set_current_state(TASK_RUNNING);
428 /***********************************************************************
429 * Device probing and disconnecting
430 ***********************************************************************/
432 /* Associate our private data with the USB device */
433 static int associate_dev(struct us_data *us, struct usb_interface *intf)
435 US_DEBUGP("-- %s\n", __func__);
437 /* Fill in the device-related fields */
438 us->pusb_dev = interface_to_usbdev(intf);
439 us->pusb_intf = intf;
440 us->ifnum = intf->cur_altsetting->desc.bInterfaceNumber;
441 US_DEBUGP("Vendor: 0x%04x, Product: 0x%04x, Revision: 0x%04x\n",
442 le16_to_cpu(us->pusb_dev->descriptor.idVendor),
443 le16_to_cpu(us->pusb_dev->descriptor.idProduct),
444 le16_to_cpu(us->pusb_dev->descriptor.bcdDevice));
445 US_DEBUGP("Interface Subclass: 0x%02x, Protocol: 0x%02x\n",
446 intf->cur_altsetting->desc.bInterfaceSubClass,
447 intf->cur_altsetting->desc.bInterfaceProtocol);
449 /* Store our private data in the interface */
450 usb_set_intfdata(intf, us);
452 /* Allocate the device-related DMA-mapped buffers */
453 us->cr = usb_buffer_alloc(us->pusb_dev, sizeof(*us->cr),
454 GFP_KERNEL, &us->cr_dma);
456 US_DEBUGP("usb_ctrlrequest allocation failed\n");
460 us->iobuf = usb_buffer_alloc(us->pusb_dev, US_IOBUF_SIZE,
461 GFP_KERNEL, &us->iobuf_dma);
463 US_DEBUGP("I/O buffer allocation failed\n");
467 us->sensebuf = kmalloc(US_SENSE_SIZE, GFP_KERNEL);
469 US_DEBUGP("Sense buffer allocation failed\n");
475 /* Find an unusual_dev descriptor (always succeeds in the current code) */
476 static struct us_unusual_dev *find_unusual(const struct usb_device_id *id)
478 const int id_index = id - storage_usb_ids;
479 return &us_unusual_dev_list[id_index];
482 /* Get the unusual_devs entries and the string descriptors */
483 static int get_device_info(struct us_data *us, const struct usb_device_id *id)
485 struct usb_device *dev = us->pusb_dev;
486 struct usb_interface_descriptor *idesc =
487 &us->pusb_intf->cur_altsetting->desc;
488 struct us_unusual_dev *unusual_dev = find_unusual(id);
490 /* Store the entries */
491 us->unusual_dev = unusual_dev;
492 us->subclass = (unusual_dev->useProtocol == US_SC_DEVICE) ?
493 idesc->bInterfaceSubClass :
494 unusual_dev->useProtocol;
495 us->protocol = (unusual_dev->useTransport == US_PR_DEVICE) ?
496 idesc->bInterfaceProtocol :
497 unusual_dev->useTransport;
498 us->fflags = USB_US_ORIG_FLAGS(id->driver_info);
500 if (us->fflags & US_FL_IGNORE_DEVICE) {
501 printk(KERN_INFO USB_STORAGE "device ignored\n");
506 * This flag is only needed when we're in high-speed, so let's
507 * disable it if we're in full-speed
509 if (dev->speed != USB_SPEED_HIGH)
510 us->fflags &= ~US_FL_GO_SLOW;
512 /* Log a message if a non-generic unusual_dev entry contains an
513 * unnecessary subclass or protocol override. This may stimulate
514 * reports from users that will help us remove unneeded entries
515 * from the unusual_devs.h table.
517 if (id->idVendor || id->idProduct) {
518 static const char *msgs[3] = {
519 "an unneeded SubClass entry",
520 "an unneeded Protocol entry",
521 "unneeded SubClass and Protocol entries"};
522 struct usb_device_descriptor *ddesc = &dev->descriptor;
525 if (unusual_dev->useProtocol != US_SC_DEVICE &&
526 us->subclass == idesc->bInterfaceSubClass)
528 if (unusual_dev->useTransport != US_PR_DEVICE &&
529 us->protocol == idesc->bInterfaceProtocol)
531 if (msg >= 0 && !(us->fflags & US_FL_NEED_OVERRIDE))
532 printk(KERN_NOTICE USB_STORAGE "This device "
533 "(%04x,%04x,%04x S %02x P %02x)"
534 " has %s in unusual_devs.h (kernel"
536 " Please send a copy of this message to "
537 "<linux-usb@vger.kernel.org> and "
538 "<usb-storage@lists.one-eyed-alien.net>\n",
539 le16_to_cpu(ddesc->idVendor),
540 le16_to_cpu(ddesc->idProduct),
541 le16_to_cpu(ddesc->bcdDevice),
542 idesc->bInterfaceSubClass,
543 idesc->bInterfaceProtocol,
551 /* Get the transport settings */
552 static int get_transport(struct us_data *us)
554 switch (us->protocol) {
556 us->transport_name = "Control/Bulk";
557 us->transport = usb_stor_CB_transport;
558 us->transport_reset = usb_stor_CB_reset;
563 us->transport_name = "Control/Bulk/Interrupt";
564 us->transport = usb_stor_CBI_transport;
565 us->transport_reset = usb_stor_CB_reset;
570 us->transport_name = "Bulk";
571 us->transport = usb_stor_Bulk_transport;
572 us->transport_reset = usb_stor_Bulk_reset;
575 #ifdef CONFIG_USB_STORAGE_USBAT
577 us->transport_name = "Shuttle USBAT";
578 us->transport = usbat_transport;
579 us->transport_reset = usb_stor_CB_reset;
584 #ifdef CONFIG_USB_STORAGE_SDDR09
585 case US_PR_EUSB_SDDR09:
586 us->transport_name = "EUSB/SDDR09";
587 us->transport = sddr09_transport;
588 us->transport_reset = usb_stor_CB_reset;
593 #ifdef CONFIG_USB_STORAGE_SDDR55
595 us->transport_name = "SDDR55";
596 us->transport = sddr55_transport;
597 us->transport_reset = sddr55_reset;
602 #ifdef CONFIG_USB_STORAGE_DPCM
604 us->transport_name = "Control/Bulk-EUSB/SDDR09";
605 us->transport = dpcm_transport;
606 us->transport_reset = usb_stor_CB_reset;
611 #ifdef CONFIG_USB_STORAGE_FREECOM
613 us->transport_name = "Freecom";
614 us->transport = freecom_transport;
615 us->transport_reset = usb_stor_freecom_reset;
620 #ifdef CONFIG_USB_STORAGE_DATAFAB
622 us->transport_name = "Datafab Bulk-Only";
623 us->transport = datafab_transport;
624 us->transport_reset = usb_stor_Bulk_reset;
629 #ifdef CONFIG_USB_STORAGE_JUMPSHOT
631 us->transport_name = "Lexar Jumpshot Control/Bulk";
632 us->transport = jumpshot_transport;
633 us->transport_reset = usb_stor_Bulk_reset;
638 #ifdef CONFIG_USB_STORAGE_ALAUDA
640 us->transport_name = "Alauda Control/Bulk";
641 us->transport = alauda_transport;
642 us->transport_reset = usb_stor_Bulk_reset;
647 #ifdef CONFIG_USB_STORAGE_KARMA
649 us->transport_name = "Rio Karma/Bulk";
650 us->transport = rio_karma_transport;
651 us->transport_reset = usb_stor_Bulk_reset;
658 US_DEBUGP("Transport: %s\n", us->transport_name);
660 /* fix for single-lun devices */
661 if (us->fflags & US_FL_SINGLE_LUN)
666 /* Get the protocol settings */
667 static int get_protocol(struct us_data *us)
669 switch (us->subclass) {
671 us->protocol_name = "Reduced Block Commands (RBC)";
672 us->proto_handler = usb_stor_transparent_scsi_command;
676 us->protocol_name = "8020i";
677 us->proto_handler = usb_stor_ATAPI_command;
682 us->protocol_name = "QIC-157";
683 us->proto_handler = usb_stor_qic157_command;
688 us->protocol_name = "8070i";
689 us->proto_handler = usb_stor_ATAPI_command;
694 us->protocol_name = "Transparent SCSI";
695 us->proto_handler = usb_stor_transparent_scsi_command;
699 us->protocol_name = "Uniform Floppy Interface (UFI)";
700 us->proto_handler = usb_stor_ufi_command;
703 #ifdef CONFIG_USB_STORAGE_ISD200
705 us->protocol_name = "ISD200 ATA/ATAPI";
706 us->proto_handler = isd200_ata_command;
710 #ifdef CONFIG_USB_STORAGE_CYPRESS_ATACB
711 case US_SC_CYP_ATACB:
712 us->protocol_name = "Transparent SCSI with Cypress ATACB";
713 us->proto_handler = cypress_atacb_passthrough;
720 US_DEBUGP("Protocol: %s\n", us->protocol_name);
724 /* Get the pipe settings */
725 static int get_pipes(struct us_data *us)
727 struct usb_host_interface *altsetting =
728 us->pusb_intf->cur_altsetting;
730 struct usb_endpoint_descriptor *ep;
731 struct usb_endpoint_descriptor *ep_in = NULL;
732 struct usb_endpoint_descriptor *ep_out = NULL;
733 struct usb_endpoint_descriptor *ep_int = NULL;
736 * Find the first endpoint of each type we need.
737 * We are expecting a minimum of 2 endpoints - in and out (bulk).
738 * An optional interrupt-in is OK (necessary for CBI protocol).
739 * We will ignore any others.
741 for (i = 0; i < altsetting->desc.bNumEndpoints; i++) {
742 ep = &altsetting->endpoint[i].desc;
744 if (usb_endpoint_xfer_bulk(ep)) {
745 if (usb_endpoint_dir_in(ep)) {
754 else if (usb_endpoint_is_int_in(ep)) {
760 if (!ep_in || !ep_out || (us->protocol == US_PR_CBI && !ep_int)) {
761 US_DEBUGP("Endpoint sanity check failed! Rejecting dev.\n");
765 /* Calculate and store the pipe values */
766 us->send_ctrl_pipe = usb_sndctrlpipe(us->pusb_dev, 0);
767 us->recv_ctrl_pipe = usb_rcvctrlpipe(us->pusb_dev, 0);
768 us->send_bulk_pipe = usb_sndbulkpipe(us->pusb_dev,
769 ep_out->bEndpointAddress & USB_ENDPOINT_NUMBER_MASK);
770 us->recv_bulk_pipe = usb_rcvbulkpipe(us->pusb_dev,
771 ep_in->bEndpointAddress & USB_ENDPOINT_NUMBER_MASK);
773 us->recv_intr_pipe = usb_rcvintpipe(us->pusb_dev,
774 ep_int->bEndpointAddress & USB_ENDPOINT_NUMBER_MASK);
775 us->ep_bInterval = ep_int->bInterval;
780 /* Initialize all the dynamic resources we need */
781 static int usb_stor_acquire_resources(struct us_data *us)
784 struct task_struct *th;
786 us->current_urb = usb_alloc_urb(0, GFP_KERNEL);
787 if (!us->current_urb) {
788 US_DEBUGP("URB allocation failed\n");
792 /* Just before we start our control thread, initialize
793 * the device if it needs initialization */
794 if (us->unusual_dev->initFunction) {
795 p = us->unusual_dev->initFunction(us);
800 /* Start up our control thread */
801 th = kthread_run(usb_stor_control_thread, us, "usb-storage");
803 printk(KERN_WARNING USB_STORAGE
804 "Unable to start control thread\n");
812 /* Release all our dynamic resources */
813 static void usb_stor_release_resources(struct us_data *us)
815 US_DEBUGP("-- %s\n", __func__);
817 /* Tell the control thread to exit. The SCSI host must
818 * already have been removed and the DISCONNECTING flag set
819 * so that we won't accept any more commands.
821 US_DEBUGP("-- sending exit command to thread\n");
822 complete(&us->cmnd_ready);
824 kthread_stop(us->ctl_thread);
826 /* Call the destructor routine, if it exists */
827 if (us->extra_destructor) {
828 US_DEBUGP("-- calling extra_destructor()\n");
829 us->extra_destructor(us->extra);
832 /* Free the extra data and the URB */
834 usb_free_urb(us->current_urb);
837 /* Dissociate from the USB device */
838 static void dissociate_dev(struct us_data *us)
840 US_DEBUGP("-- %s\n", __func__);
844 /* Free the device-related DMA-mapped buffers */
846 usb_buffer_free(us->pusb_dev, sizeof(*us->cr), us->cr,
849 usb_buffer_free(us->pusb_dev, US_IOBUF_SIZE, us->iobuf,
852 /* Remove our private data from the interface */
853 usb_set_intfdata(us->pusb_intf, NULL);
856 /* First stage of disconnect processing: stop SCSI scanning,
857 * remove the host, and stop accepting new commands
859 static void quiesce_and_remove_host(struct us_data *us)
861 struct Scsi_Host *host = us_to_host(us);
863 /* If the device is really gone, cut short reset delays */
864 if (us->pusb_dev->state == USB_STATE_NOTATTACHED)
865 set_bit(US_FLIDX_DISCONNECTING, &us->dflags);
867 /* Prevent SCSI-scanning (if it hasn't started yet)
868 * and wait for the SCSI-scanning thread to stop.
870 set_bit(US_FLIDX_DONT_SCAN, &us->dflags);
871 wake_up(&us->delay_wait);
872 wait_for_completion(&us->scanning_done);
874 /* Removing the host will perform an orderly shutdown: caches
875 * synchronized, disks spun down, etc.
877 scsi_remove_host(host);
879 /* Prevent any new commands from being accepted and cut short
883 set_bit(US_FLIDX_DISCONNECTING, &us->dflags);
885 wake_up(&us->delay_wait);
888 /* Second stage of disconnect processing: deallocate all resources */
889 static void release_everything(struct us_data *us)
891 usb_stor_release_resources(us);
894 /* Drop our reference to the host; the SCSI core will free it
895 * (and "us" along with it) when the refcount becomes 0. */
896 scsi_host_put(us_to_host(us));
899 /* Thread to carry out delayed SCSI-device scanning */
900 static int usb_stor_scan_thread(void * __us)
902 struct us_data *us = (struct us_data *)__us;
905 "usb-storage: device found at %d\n", us->pusb_dev->devnum);
908 /* Wait for the timeout to expire or for a disconnect */
910 printk(KERN_DEBUG "usb-storage: waiting for device "
911 "to settle before scanning\n");
912 wait_event_freezable_timeout(us->delay_wait,
913 test_bit(US_FLIDX_DONT_SCAN, &us->dflags),
917 /* If the device is still connected, perform the scanning */
918 if (!test_bit(US_FLIDX_DONT_SCAN, &us->dflags)) {
920 /* For bulk-only devices, determine the max LUN value */
921 if (us->protocol == US_PR_BULK &&
922 !(us->fflags & US_FL_SINGLE_LUN)) {
923 mutex_lock(&us->dev_mutex);
924 us->max_lun = usb_stor_Bulk_max_lun(us);
925 mutex_unlock(&us->dev_mutex);
927 scsi_scan_host(us_to_host(us));
928 printk(KERN_DEBUG "usb-storage: device scan complete\n");
930 /* Should we unbind if no devices were detected? */
933 complete_and_exit(&us->scanning_done, 0);
937 /* Probe to see if we can drive a newly-connected USB device */
938 static int storage_probe(struct usb_interface *intf,
939 const struct usb_device_id *id)
941 struct Scsi_Host *host;
944 struct task_struct *th;
946 if (usb_usual_check_type(id, USB_US_TYPE_STOR))
949 US_DEBUGP("USB Mass Storage device detected\n");
952 * Ask the SCSI layer to allocate a host structure, with extra
953 * space at the end for our private us_data structure.
955 host = scsi_host_alloc(&usb_stor_host_template, sizeof(*us));
957 printk(KERN_WARNING USB_STORAGE
958 "Unable to allocate the scsi host\n");
963 * Allow 16-byte CDBs and thus > 2TB
965 host->max_cmd_len = 16;
966 us = host_to_us(host);
967 memset(us, 0, sizeof(struct us_data));
968 mutex_init(&(us->dev_mutex));
969 init_completion(&us->cmnd_ready);
970 init_completion(&(us->notify));
971 init_waitqueue_head(&us->delay_wait);
972 init_completion(&us->scanning_done);
974 /* Associate the us_data structure with the USB device */
975 result = associate_dev(us, intf);
980 * Get the unusual_devs entries and the descriptors
982 * id_index is calculated in the declaration to be the index number
983 * of the match from the usb_device_id table, so we can find the
984 * corresponding entry in the private table.
986 result = get_device_info(us, id);
990 /* Get the transport, protocol, and pipe settings */
991 result = get_transport(us);
994 result = get_protocol(us);
997 result = get_pipes(us);
1001 /* Acquire all the other resources and add the host */
1002 result = usb_stor_acquire_resources(us);
1005 result = scsi_add_host(host, &intf->dev);
1007 printk(KERN_WARNING USB_STORAGE
1008 "Unable to add the scsi host\n");
1012 /* Start up the thread for delayed SCSI-device scanning */
1013 th = kthread_create(usb_stor_scan_thread, us, "usb-stor-scan");
1015 printk(KERN_WARNING USB_STORAGE
1016 "Unable to start the device-scanning thread\n");
1017 complete(&us->scanning_done);
1018 quiesce_and_remove_host(us);
1019 result = PTR_ERR(th);
1023 wake_up_process(th);
1027 /* We come here if there are any problems */
1029 US_DEBUGP("storage_probe() failed\n");
1030 release_everything(us);
1034 /* Handle a disconnect event from the USB core */
1035 static void storage_disconnect(struct usb_interface *intf)
1037 struct us_data *us = usb_get_intfdata(intf);
1039 US_DEBUGP("storage_disconnect() called\n");
1040 quiesce_and_remove_host(us);
1041 release_everything(us);
1044 /***********************************************************************
1045 * Initialization and registration
1046 ***********************************************************************/
1048 static struct usb_driver usb_storage_driver = {
1049 .name = "usb-storage",
1050 .probe = storage_probe,
1051 .disconnect = storage_disconnect,
1053 .suspend = storage_suspend,
1054 .resume = storage_resume,
1055 .reset_resume = storage_reset_resume,
1057 .pre_reset = storage_pre_reset,
1058 .post_reset = storage_post_reset,
1059 .id_table = storage_usb_ids,
1063 static int __init usb_stor_init(void)
1066 printk(KERN_INFO "Initializing USB Mass Storage driver...\n");
1068 /* register the driver, return usb_register return code if error */
1069 retval = usb_register(&usb_storage_driver);
1071 printk(KERN_INFO "USB Mass Storage support registered.\n");
1072 usb_usual_set_present(USB_US_TYPE_STOR);
1077 static void __exit usb_stor_exit(void)
1079 US_DEBUGP("usb_stor_exit() called\n");
1081 /* Deregister the driver
1082 * This will cause disconnect() to be called for each
1085 US_DEBUGP("-- calling usb_deregister()\n");
1086 usb_deregister(&usb_storage_driver) ;
1088 usb_usual_clear_present(USB_US_TYPE_STOR);
1091 module_init(usb_stor_init);
1092 module_exit(usb_stor_exit);