1 // SPDX-License-Identifier: GPL-2.0
2 /* Driver for Microtek Scanmaker X6 USB scanner, and possibly others.
3  *
4  * (C) Copyright 2000 John Fremlin <vii@penguinpowered.com>
5  * (C) Copyright 2000 Oliver Neukum <Oliver.Neukum@lrz.uni-muenchen.de>
6  *
7  * Parts shamelessly stolen from usb-storage and copyright by their
8  * authors. Thanks to Matt Dharm for giving us permission!
9  *
10  * This driver implements a SCSI host controller driver and a USB
11  * device driver. To avoid confusion, all the USB related stuff is
12  * prefixed by mts_usb_ and all the SCSI stuff by mts_scsi_.
13  *
14  * Microtek (www.microtek.com) did not release the specifications for
15  * their USB protocol to us, so we had to reverse engineer them. We
16  * don't know for which models they are valid.
17  *
18  * The X6 USB has three bulk endpoints, one output (0x1) down which
19  * commands and outgoing data are sent, and two input: 0x82 from which
20  * normal data is read from the scanner (in packets of maximum 32
21  * bytes) and from which the status byte is read, and 0x83 from which
22  * the results of a scan (or preview) are read in up to 64 * 1024 byte
23  * chunks by the Windows driver. We don't know how much it is possible
24  * to read at a time from 0x83.
25  *
26  * It seems possible to read (with URB transfers) everything from 0x82
27  * in one go, without bothering to read in 32 byte chunks.
28  *
29  * There seems to be an optimisation of a further READ implicit if
30  * you simply read from 0x83.
31  *
32  * Guessed protocol:
33  *
34  *	Send raw SCSI command to EP 0x1
35  *
36  *	If there is data to receive:
37  *		If the command was READ datatype=image:
38  *			Read a lot of data from EP 0x83
39  *		Else:
40  *			Read data from EP 0x82
41  *	Else:
42  *		If there is data to transmit:
43  *			Write it to EP 0x1
44  *
45  *	Read status byte from EP 0x82
46  *
47  * References:
48  *
49  * The SCSI command set for the scanner is available from
50  *	ftp://ftp.microtek.com/microtek/devpack/
51  *
52  * Microtek NV sent us a more up to date version of the document. If
53  * you want it, just send mail.
54  *
55  * Status:
56  *
57  *	Untested with multiple scanners.
58  *	Untested on SMP.
59  *	Untested on a bigendian machine.
60  *
61  * History:
62  *
63  *	20000417 starting history
64  *	20000417 fixed load oops
65  *	20000417 fixed unload oops
66  *	20000419 fixed READ IMAGE detection
67  *	20000424 started conversion to use URBs
68  *	20000502 handled short transfers as errors
69  *	20000513 rename and organisation of functions (john)
70  *	20000513 added IDs for all products supported by Windows driver (john)
71  *	20000514 Rewrote mts_scsi_queuecommand to use URBs (john)
72  *	20000514 Version 0.0.8j
73  *      20000514 Fix reporting of non-existent devices to SCSI layer (john)
74  *	20000514 Added MTS_DEBUG_INT (john)
75  *	20000514 Changed "usb-microtek" to "microtek" for consistency (john)
76  *	20000514 Stupid bug fixes (john)
77  *	20000514 Version 0.0.9j
78  *	20000515 Put transfer context and URB in mts_desc (john)
79  *	20000515 Added prelim turn off debugging support (john)
80  *	20000515 Version 0.0.10j
81  *      20000515 Fixed up URB allocation (clear URB on alloc) (john)
82  *      20000515 Version 0.0.11j
83  *	20000516 Removed unnecessary spinlock in mts_transfer_context (john)
84  *	20000516 Removed unnecessary up on instance lock in mts_remove_nolock (john)
85  *	20000516 Implemented (badly) scsi_abort (john)
86  *	20000516 Version 0.0.12j
87  *      20000517 Hopefully removed mts_remove_nolock quasideadlock (john)
88  *      20000517 Added mts_debug_dump to print ll USB info (john)
89  *	20000518 Tweaks and documentation updates (john)
90  *	20000518 Version 0.0.13j
91  *	20000518 Cleaned up abort handling (john)
92  *	20000523 Removed scsi_command and various scsi_..._resets (john)
93  *	20000523 Added unlink URB on scsi_abort, now OHCI supports it (john)
94  *	20000523 Fixed last tiresome compile warning (john)
95  *	20000523 Version 0.0.14j (though version 0.1 has come out?)
96  *	20000602 Added primitive reset
97  *	20000602 Version 0.2.0
98  *	20000603 various cosmetic changes
99  *	20000603 Version 0.2.1
100  *	20000620 minor cosmetic changes
101  *	20000620 Version 0.2.2
102  *	20000822 Hopefully fixed deadlock in mts_remove_nolock()
103  *	20000822 Fixed minor race in mts_transfer_cleanup()
104  *	20000822 Fixed deadlock on submission error in queuecommand
105  *	20000822 Version 0.2.3
106  *	20000913 Reduced module size if debugging is off
107  *	20000913 Version 0.2.4
108  *      20010210 New abort logic
109  *      20010210 Version 0.3.0
110  *	20010217 Merged scatter/gather
111  *	20010218 Version 0.4.0
112  *	20010218 Cosmetic fixes
113  *	20010218 Version 0.4.1
114  *      20010306 Abort while using scatter/gather
115  *      20010306 Version 0.4.2
116  *      20010311 Remove all timeouts and tidy up generally (john)
117  *	20010320 check return value of scsi_register()
118  *	20010320 Version 0.4.3
119  *	20010408 Identify version on module load.
120  *	20011003 Fix multiple requests
121  */
122 
123 #include <linux/module.h>
124 #include <linux/kernel.h>
125 #include <linux/signal.h>
126 #include <linux/errno.h>
127 #include <linux/random.h>
128 #include <linux/poll.h>
129 #include <linux/slab.h>
130 #include <linux/spinlock.h>
131 #include <linux/usb.h>
132 #include <linux/proc_fs.h>
133 
134 #include <linux/atomic.h>
135 #include <linux/blkdev.h>
136 #include "../../scsi/scsi.h"
137 #include <scsi/scsi_host.h>
138 
139 #include "microtek.h"
140 
141 #define DRIVER_AUTHOR "John Fremlin <vii@penguinpowered.com>, Oliver Neukum <Oliver.Neukum@lrz.uni-muenchen.de>"
142 #define DRIVER_DESC "Microtek Scanmaker X6 USB scanner driver"
143 
144 /* Should we do debugging? */
145 
146 //#define MTS_DO_DEBUG
147 
148 /* USB layer driver interface */
149 
150 static int mts_usb_probe(struct usb_interface *intf,
151 			 const struct usb_device_id *id);
152 static void mts_usb_disconnect(struct usb_interface *intf);
153 
154 static const struct usb_device_id mts_usb_ids[];
155 
156 static struct usb_driver mts_usb_driver = {
157 	.name =		"microtekX6",
158 	.probe =	mts_usb_probe,
159 	.disconnect =	mts_usb_disconnect,
160 	.id_table =	mts_usb_ids,
161 };
162 
163 
164 /* Internal driver stuff */
165 
166 #define MTS_VERSION	"0.4.3"
167 #define MTS_NAME	"microtek usb (rev " MTS_VERSION "): "
168 
169 #define MTS_WARNING(x...) \
170 	printk( KERN_WARNING MTS_NAME x )
171 #define MTS_ERROR(x...) \
172 	printk( KERN_ERR MTS_NAME x )
173 #define MTS_INT_ERROR(x...) \
174 	MTS_ERROR(x)
175 #define MTS_MESSAGE(x...) \
176 	printk( KERN_INFO MTS_NAME x )
177 
178 #if defined MTS_DO_DEBUG
179 
180 #define MTS_DEBUG(x...) \
181 	printk( KERN_DEBUG MTS_NAME x )
182 
183 #define MTS_DEBUG_GOT_HERE() \
184 	MTS_DEBUG("got to %s:%d (%s)\n", __FILE__, (int)__LINE__, __func__ )
185 #define MTS_DEBUG_INT() \
186 	do { MTS_DEBUG_GOT_HERE(); \
187 	     MTS_DEBUG("transfer = 0x%x context = 0x%x\n",(int)transfer,(int)context ); \
188 	     MTS_DEBUG("status = 0x%x data-length = 0x%x sent = 0x%x\n",transfer->status,(int)context->data_length, (int)transfer->actual_length ); \
189              mts_debug_dump(context->instance);\
190 	   } while(0)
191 #else
192 
193 #define MTS_NUL_STATEMENT do { } while(0)
194 
195 #define MTS_DEBUG(x...)	MTS_NUL_STATEMENT
196 #define MTS_DEBUG_GOT_HERE() MTS_NUL_STATEMENT
197 #define MTS_DEBUG_INT() MTS_NUL_STATEMENT
198 
199 #endif
200 
201 
202 
203 #define MTS_INT_INIT()\
204 	struct mts_transfer_context* context = (struct mts_transfer_context*)transfer->context; \
205 	MTS_DEBUG_INT();\
206 
207 #ifdef MTS_DO_DEBUG
208 
mts_debug_dump(struct mts_desc * desc)209 static inline void mts_debug_dump(struct mts_desc* desc) {
210 	MTS_DEBUG("desc at 0x%x: toggle = %02x%02x\n",
211 		  (int)desc,
212 		  (int)desc->usb_dev->toggle[1],(int)desc->usb_dev->toggle[0]
213 		);
214 	MTS_DEBUG("ep_out=%x ep_response=%x ep_image=%x\n",
215 		  usb_sndbulkpipe(desc->usb_dev,desc->ep_out),
216 		  usb_rcvbulkpipe(desc->usb_dev,desc->ep_response),
217 		  usb_rcvbulkpipe(desc->usb_dev,desc->ep_image)
218 		);
219 }
220 
221 
mts_show_command(struct scsi_cmnd * srb)222 static inline void mts_show_command(struct scsi_cmnd *srb)
223 {
224 	char *what = NULL;
225 
226 	switch (srb->cmnd[0]) {
227 	case TEST_UNIT_READY: what = "TEST_UNIT_READY"; break;
228 	case REZERO_UNIT: what = "REZERO_UNIT"; break;
229 	case REQUEST_SENSE: what = "REQUEST_SENSE"; break;
230 	case FORMAT_UNIT: what = "FORMAT_UNIT"; break;
231 	case READ_BLOCK_LIMITS: what = "READ_BLOCK_LIMITS"; break;
232 	case REASSIGN_BLOCKS: what = "REASSIGN_BLOCKS"; break;
233 	case READ_6: what = "READ_6"; break;
234 	case WRITE_6: what = "WRITE_6"; break;
235 	case SEEK_6: what = "SEEK_6"; break;
236 	case READ_REVERSE: what = "READ_REVERSE"; break;
237 	case WRITE_FILEMARKS: what = "WRITE_FILEMARKS"; break;
238 	case SPACE: what = "SPACE"; break;
239 	case INQUIRY: what = "INQUIRY"; break;
240 	case RECOVER_BUFFERED_DATA: what = "RECOVER_BUFFERED_DATA"; break;
241 	case MODE_SELECT: what = "MODE_SELECT"; break;
242 	case RESERVE: what = "RESERVE"; break;
243 	case RELEASE: what = "RELEASE"; break;
244 	case COPY: what = "COPY"; break;
245 	case ERASE: what = "ERASE"; break;
246 	case MODE_SENSE: what = "MODE_SENSE"; break;
247 	case START_STOP: what = "START_STOP"; break;
248 	case RECEIVE_DIAGNOSTIC: what = "RECEIVE_DIAGNOSTIC"; break;
249 	case SEND_DIAGNOSTIC: what = "SEND_DIAGNOSTIC"; break;
250 	case ALLOW_MEDIUM_REMOVAL: what = "ALLOW_MEDIUM_REMOVAL"; break;
251 	case SET_WINDOW: what = "SET_WINDOW"; break;
252 	case READ_CAPACITY: what = "READ_CAPACITY"; break;
253 	case READ_10: what = "READ_10"; break;
254 	case WRITE_10: what = "WRITE_10"; break;
255 	case SEEK_10: what = "SEEK_10"; break;
256 	case WRITE_VERIFY: what = "WRITE_VERIFY"; break;
257 	case VERIFY: what = "VERIFY"; break;
258 	case SEARCH_HIGH: what = "SEARCH_HIGH"; break;
259 	case SEARCH_EQUAL: what = "SEARCH_EQUAL"; break;
260 	case SEARCH_LOW: what = "SEARCH_LOW"; break;
261 	case SET_LIMITS: what = "SET_LIMITS"; break;
262 	case READ_POSITION: what = "READ_POSITION"; break;
263 	case SYNCHRONIZE_CACHE: what = "SYNCHRONIZE_CACHE"; break;
264 	case LOCK_UNLOCK_CACHE: what = "LOCK_UNLOCK_CACHE"; break;
265 	case READ_DEFECT_DATA: what = "READ_DEFECT_DATA"; break;
266 	case MEDIUM_SCAN: what = "MEDIUM_SCAN"; break;
267 	case COMPARE: what = "COMPARE"; break;
268 	case COPY_VERIFY: what = "COPY_VERIFY"; break;
269 	case WRITE_BUFFER: what = "WRITE_BUFFER"; break;
270 	case READ_BUFFER: what = "READ_BUFFER"; break;
271 	case UPDATE_BLOCK: what = "UPDATE_BLOCK"; break;
272 	case READ_LONG: what = "READ_LONG"; break;
273 	case WRITE_LONG: what = "WRITE_LONG"; break;
274 	case CHANGE_DEFINITION: what = "CHANGE_DEFINITION"; break;
275 	case WRITE_SAME: what = "WRITE_SAME"; break;
276 	case READ_TOC: what = "READ_TOC"; break;
277 	case LOG_SELECT: what = "LOG_SELECT"; break;
278 	case LOG_SENSE: what = "LOG_SENSE"; break;
279 	case MODE_SELECT_10: what = "MODE_SELECT_10"; break;
280 	case MODE_SENSE_10: what = "MODE_SENSE_10"; break;
281 	case MOVE_MEDIUM: what = "MOVE_MEDIUM"; break;
282 	case READ_12: what = "READ_12"; break;
283 	case WRITE_12: what = "WRITE_12"; break;
284 	case WRITE_VERIFY_12: what = "WRITE_VERIFY_12"; break;
285 	case SEARCH_HIGH_12: what = "SEARCH_HIGH_12"; break;
286 	case SEARCH_EQUAL_12: what = "SEARCH_EQUAL_12"; break;
287 	case SEARCH_LOW_12: what = "SEARCH_LOW_12"; break;
288 	case READ_ELEMENT_STATUS: what = "READ_ELEMENT_STATUS"; break;
289 	case SEND_VOLUME_TAG: what = "SEND_VOLUME_TAG"; break;
290 	case WRITE_LONG_2: what = "WRITE_LONG_2"; break;
291 	default:
292 		MTS_DEBUG("can't decode command\n");
293 		goto out;
294 		break;
295 	}
296 	MTS_DEBUG( "Command %s (%d bytes)\n", what, srb->cmd_len);
297 
298  out:
299 	MTS_DEBUG( "  %10ph\n", srb->cmnd);
300 }
301 
302 #else
303 
mts_show_command(struct scsi_cmnd * dummy)304 static inline void mts_show_command(struct scsi_cmnd * dummy)
305 {
306 }
307 
mts_debug_dump(struct mts_desc * dummy)308 static inline void mts_debug_dump(struct mts_desc* dummy)
309 {
310 }
311 
312 #endif
313 
mts_urb_abort(struct mts_desc * desc)314 static inline void mts_urb_abort(struct mts_desc* desc) {
315 	MTS_DEBUG_GOT_HERE();
316 	mts_debug_dump(desc);
317 
318 	usb_kill_urb( desc->urb );
319 }
320 
mts_slave_alloc(struct scsi_device * s)321 static int mts_slave_alloc (struct scsi_device *s)
322 {
323 	s->inquiry_len = 0x24;
324 	return 0;
325 }
326 
mts_slave_configure(struct scsi_device * s)327 static int mts_slave_configure (struct scsi_device *s)
328 {
329 	blk_queue_dma_alignment(s->request_queue, (512 - 1));
330 	return 0;
331 }
332 
mts_scsi_abort(struct scsi_cmnd * srb)333 static int mts_scsi_abort(struct scsi_cmnd *srb)
334 {
335 	struct mts_desc* desc = (struct mts_desc*)(srb->device->host->hostdata[0]);
336 
337 	MTS_DEBUG_GOT_HERE();
338 
339 	mts_urb_abort(desc);
340 
341 	return FAILED;
342 }
343 
mts_scsi_host_reset(struct scsi_cmnd * srb)344 static int mts_scsi_host_reset(struct scsi_cmnd *srb)
345 {
346 	struct mts_desc* desc = (struct mts_desc*)(srb->device->host->hostdata[0]);
347 	int result;
348 
349 	MTS_DEBUG_GOT_HERE();
350 	mts_debug_dump(desc);
351 
352 	result = usb_lock_device_for_reset(desc->usb_dev, desc->usb_intf);
353 	if (result == 0) {
354 		result = usb_reset_device(desc->usb_dev);
355 		usb_unlock_device(desc->usb_dev);
356 	}
357 	return result ? FAILED : SUCCESS;
358 }
359 
360 static int
361 mts_scsi_queuecommand(struct Scsi_Host *shost, struct scsi_cmnd *srb);
362 
363 static void mts_transfer_cleanup( struct urb *transfer );
364 static void mts_do_sg(struct urb * transfer);
365 
366 static inline
mts_int_submit_urb(struct urb * transfer,int pipe,void * data,unsigned length,usb_complete_t callback)367 void mts_int_submit_urb (struct urb* transfer,
368 			int pipe,
369 			void* data,
370 			unsigned length,
371 			usb_complete_t callback )
372 /* Interrupt context! */
373 
374 /* Holding transfer->context->lock! */
375 {
376 	int res;
377 
378 	MTS_INT_INIT();
379 
380 	usb_fill_bulk_urb(transfer,
381 		      context->instance->usb_dev,
382 		      pipe,
383 		      data,
384 		      length,
385 		      callback,
386 		      context
387 		);
388 
389 	res = usb_submit_urb( transfer, GFP_ATOMIC );
390 	if ( unlikely(res) ) {
391 		MTS_INT_ERROR( "could not submit URB! Error was %d\n",(int)res );
392 		set_host_byte(context->srb, DID_ERROR);
393 		mts_transfer_cleanup(transfer);
394 	}
395 }
396 
397 
mts_transfer_cleanup(struct urb * transfer)398 static void mts_transfer_cleanup( struct urb *transfer )
399 /* Interrupt context! */
400 {
401 	MTS_INT_INIT();
402 
403 	if ( likely(context->final_callback != NULL) )
404 		context->final_callback(context->srb);
405 }
406 
mts_transfer_done(struct urb * transfer)407 static void mts_transfer_done( struct urb *transfer )
408 {
409 	MTS_INT_INIT();
410 
411 	context->srb->result &= MTS_SCSI_ERR_MASK;
412 	context->srb->result |= (unsigned)(*context->scsi_status)<<1;
413 
414 	mts_transfer_cleanup(transfer);
415 }
416 
417 
mts_get_status(struct urb * transfer)418 static void mts_get_status( struct urb *transfer )
419 /* Interrupt context! */
420 {
421 	MTS_INT_INIT();
422 
423 	mts_int_submit_urb(transfer,
424 			   usb_rcvbulkpipe(context->instance->usb_dev,
425 					   context->instance->ep_response),
426 			   context->scsi_status,
427 			   1,
428 			   mts_transfer_done );
429 }
430 
mts_data_done(struct urb * transfer)431 static void mts_data_done( struct urb* transfer )
432 /* Interrupt context! */
433 {
434 	int status = transfer->status;
435 	MTS_INT_INIT();
436 
437 	if ( context->data_length != transfer->actual_length ) {
438 		scsi_set_resid(context->srb, context->data_length -
439 			       transfer->actual_length);
440 	} else if ( unlikely(status) ) {
441 		set_host_byte(context->srb, (status == -ENOENT ? DID_ABORT : DID_ERROR));
442 	}
443 
444 	mts_get_status(transfer);
445 }
446 
447 
mts_command_done(struct urb * transfer)448 static void mts_command_done( struct urb *transfer )
449 /* Interrupt context! */
450 {
451 	int status = transfer->status;
452 	MTS_INT_INIT();
453 
454 	if ( unlikely(status) ) {
455 	        if (status == -ENOENT) {
456 		        /* We are being killed */
457 			MTS_DEBUG_GOT_HERE();
458 			set_host_byte(context->srb, DID_ABORT);
459                 } else {
460 		        /* A genuine error has occurred */
461 			MTS_DEBUG_GOT_HERE();
462 
463 		        set_host_byte(context->srb, DID_ERROR);
464                 }
465 		mts_transfer_cleanup(transfer);
466 
467 		return;
468 	}
469 
470 	if (context->srb->cmnd[0] == REQUEST_SENSE) {
471 		mts_int_submit_urb(transfer,
472 				   context->data_pipe,
473 				   context->srb->sense_buffer,
474 				   context->data_length,
475 				   mts_data_done);
476 	} else { if ( context->data ) {
477 			mts_int_submit_urb(transfer,
478 					   context->data_pipe,
479 					   context->data,
480 					   context->data_length,
481 					   scsi_sg_count(context->srb) > 1 ?
482 					           mts_do_sg : mts_data_done);
483 		} else {
484 			mts_get_status(transfer);
485 		}
486 	}
487 }
488 
mts_do_sg(struct urb * transfer)489 static void mts_do_sg (struct urb* transfer)
490 {
491 	int status = transfer->status;
492 	MTS_INT_INIT();
493 
494 	MTS_DEBUG("Processing fragment %d of %d\n", context->fragment,
495 	                                          scsi_sg_count(context->srb));
496 
497 	if (unlikely(status)) {
498                 set_host_byte(context->srb, (status == -ENOENT ? DID_ABORT : DID_ERROR));
499 		mts_transfer_cleanup(transfer);
500         }
501 
502 	context->curr_sg = sg_next(context->curr_sg);
503 	mts_int_submit_urb(transfer,
504 			   context->data_pipe,
505 			   sg_virt(context->curr_sg),
506 			   context->curr_sg->length,
507 			   sg_is_last(context->curr_sg) ?
508 			   mts_data_done : mts_do_sg);
509 }
510 
511 static const u8 mts_read_image_sig[] = { 0x28, 00, 00, 00 };
512 static const u8 mts_read_image_sig_len = 4;
513 static const unsigned char mts_direction[256/8] = {
514 	0x28, 0x81, 0x14, 0x14, 0x20, 0x01, 0x90, 0x77,
515 	0x0C, 0x20, 0x00, 0x04, 0x00, 0x00, 0x00, 0x00,
516 	0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x00, 0x01,
517 	0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00
518 };
519 
520 
521 #define MTS_DIRECTION_IS_IN(x) ((mts_direction[x>>3] >> (x & 7)) & 1)
522 
523 static void
mts_build_transfer_context(struct scsi_cmnd * srb,struct mts_desc * desc)524 mts_build_transfer_context(struct scsi_cmnd *srb, struct mts_desc* desc)
525 {
526 	int pipe;
527 
528 	MTS_DEBUG_GOT_HERE();
529 
530 	desc->context.instance = desc;
531 	desc->context.srb = srb;
532 
533 	if (!scsi_bufflen(srb)) {
534 		desc->context.data = NULL;
535 		desc->context.data_length = 0;
536 		return;
537 	} else {
538 		desc->context.curr_sg = scsi_sglist(srb);
539 		desc->context.data = sg_virt(desc->context.curr_sg);
540 		desc->context.data_length = desc->context.curr_sg->length;
541 	}
542 
543 
544 	/* can't rely on srb->sc_data_direction */
545 
546 	/* Brutally ripped from usb-storage */
547 
548 	if ( !memcmp( srb->cmnd, mts_read_image_sig, mts_read_image_sig_len )
549 ) { 		pipe = usb_rcvbulkpipe(desc->usb_dev,desc->ep_image);
550 		MTS_DEBUG( "transferring from desc->ep_image == %d\n",
551 			   (int)desc->ep_image );
552 	} else if ( MTS_DIRECTION_IS_IN(srb->cmnd[0]) ) {
553 			pipe = usb_rcvbulkpipe(desc->usb_dev,desc->ep_response);
554 			MTS_DEBUG( "transferring from desc->ep_response == %d\n",
555 				   (int)desc->ep_response);
556 	} else {
557 		MTS_DEBUG("transferring to desc->ep_out == %d\n",
558 			  (int)desc->ep_out);
559 		pipe = usb_sndbulkpipe(desc->usb_dev,desc->ep_out);
560 	}
561 	desc->context.data_pipe = pipe;
562 }
563 
564 
565 static int
mts_scsi_queuecommand_lck(struct scsi_cmnd * srb,mts_scsi_cmnd_callback callback)566 mts_scsi_queuecommand_lck(struct scsi_cmnd *srb, mts_scsi_cmnd_callback callback)
567 {
568 	struct mts_desc* desc = (struct mts_desc*)(srb->device->host->hostdata[0]);
569 	int res;
570 
571 	MTS_DEBUG_GOT_HERE();
572 	mts_show_command(srb);
573 	mts_debug_dump(desc);
574 
575 	if ( srb->device->lun || srb->device->id || srb->device->channel ) {
576 
577 		MTS_DEBUG("Command to LUN=%d ID=%d CHANNEL=%d from SCSI layer\n",(int)srb->device->lun,(int)srb->device->id, (int)srb->device->channel );
578 
579 		MTS_DEBUG("this device doesn't exist\n");
580 
581 		set_host_byte(srb, DID_BAD_TARGET);
582 
583 		if(likely(callback != NULL))
584 			callback(srb);
585 
586 		goto out;
587 	}
588 
589 
590 	usb_fill_bulk_urb(desc->urb,
591 		      desc->usb_dev,
592 		      usb_sndbulkpipe(desc->usb_dev,desc->ep_out),
593 		      srb->cmnd,
594 		      srb->cmd_len,
595 		      mts_command_done,
596 		      &desc->context
597 		      );
598 
599 
600 	mts_build_transfer_context( srb, desc );
601 	desc->context.final_callback = callback;
602 
603 	/* here we need ATOMIC as we are called with the iolock */
604 	res=usb_submit_urb(desc->urb, GFP_ATOMIC);
605 
606 	if(unlikely(res)){
607 		MTS_ERROR("error %d submitting URB\n",(int)res);
608 		set_host_byte(srb, DID_ERROR);
609 
610 		if(likely(callback != NULL))
611 			callback(srb);
612 
613 	}
614 out:
615 	return 0;
616 }
617 
618 static DEF_SCSI_QCMD(mts_scsi_queuecommand)
619 
620 static struct scsi_host_template mts_scsi_host_template = {
621 	.module			= THIS_MODULE,
622 	.name			= "microtekX6",
623 	.proc_name		= "microtekX6",
624 	.queuecommand		= mts_scsi_queuecommand,
625 	.eh_abort_handler	= mts_scsi_abort,
626 	.eh_host_reset_handler	= mts_scsi_host_reset,
627 	.sg_tablesize =		SG_ALL,
628 	.can_queue =		1,
629 	.this_id =		-1,
630 	.emulated =		1,
631 	.slave_alloc =		mts_slave_alloc,
632 	.slave_configure =	mts_slave_configure,
633 	.max_sectors=		256, /* 128 K */
634 };
635 
636 /* The entries of microtek_table must correspond, line-by-line to
637    the entries of mts_supported_products[]. */
638 
639 static const struct usb_device_id mts_usb_ids[] =
640 {
641 	{ USB_DEVICE(0x4ce, 0x0300) },
642 	{ USB_DEVICE(0x5da, 0x0094) },
643 	{ USB_DEVICE(0x5da, 0x0099) },
644 	{ USB_DEVICE(0x5da, 0x009a) },
645 	{ USB_DEVICE(0x5da, 0x00a0) },
646 	{ USB_DEVICE(0x5da, 0x00a3) },
647 	{ USB_DEVICE(0x5da, 0x80a3) },
648 	{ USB_DEVICE(0x5da, 0x80ac) },
649 	{ USB_DEVICE(0x5da, 0x00b6) },
650 	{ }						/* Terminating entry */
651 };
652 
653 MODULE_DEVICE_TABLE (usb, mts_usb_ids);
654 
655 
mts_usb_probe(struct usb_interface * intf,const struct usb_device_id * id)656 static int mts_usb_probe(struct usb_interface *intf,
657 			 const struct usb_device_id *id)
658 {
659 	int i;
660 	int ep_out = -1;
661 	int ep_in_set[3]; /* this will break if we have more than three endpoints
662 			   which is why we check */
663 	int *ep_in_current = ep_in_set;
664 	int err_retval = -ENOMEM;
665 
666 	struct mts_desc * new_desc;
667 	struct usb_device *dev = interface_to_usbdev (intf);
668 
669 	/* the current altsetting on the interface we're probing */
670 	struct usb_host_interface *altsetting;
671 
672 	MTS_DEBUG_GOT_HERE();
673 	MTS_DEBUG( "usb-device descriptor at %x\n", (int)dev );
674 
675 	MTS_DEBUG( "product id = 0x%x, vendor id = 0x%x\n",
676 		   le16_to_cpu(dev->descriptor.idProduct),
677 		   le16_to_cpu(dev->descriptor.idVendor) );
678 
679 	MTS_DEBUG_GOT_HERE();
680 
681 	/* the current altsetting on the interface we're probing */
682 	altsetting = intf->cur_altsetting;
683 
684 
685 	/* Check if the config is sane */
686 
687 	if ( altsetting->desc.bNumEndpoints != MTS_EP_TOTAL ) {
688 		MTS_WARNING( "expecting %d got %d endpoints! Bailing out.\n",
689 			     (int)MTS_EP_TOTAL, (int)altsetting->desc.bNumEndpoints );
690 		return -ENODEV;
691 	}
692 
693 	for( i = 0; i < altsetting->desc.bNumEndpoints; i++ ) {
694 		if ((altsetting->endpoint[i].desc.bmAttributes &
695 		     USB_ENDPOINT_XFERTYPE_MASK) != USB_ENDPOINT_XFER_BULK) {
696 
697 			MTS_WARNING( "can only deal with bulk endpoints; endpoint %d is not bulk.\n",
698 			     (int)altsetting->endpoint[i].desc.bEndpointAddress );
699 		} else {
700 			if (altsetting->endpoint[i].desc.bEndpointAddress &
701 			    USB_DIR_IN)
702 				*ep_in_current++
703 					= altsetting->endpoint[i].desc.bEndpointAddress &
704 					USB_ENDPOINT_NUMBER_MASK;
705 			else {
706 				if ( ep_out != -1 ) {
707 					MTS_WARNING( "can only deal with one output endpoints. Bailing out." );
708 					return -ENODEV;
709 				}
710 
711 				ep_out = altsetting->endpoint[i].desc.bEndpointAddress &
712 					USB_ENDPOINT_NUMBER_MASK;
713 			}
714 		}
715 
716 	}
717 
718 	if (ep_in_current != &ep_in_set[2]) {
719 		MTS_WARNING("couldn't find two input bulk endpoints. Bailing out.\n");
720 		return -ENODEV;
721 	}
722 
723 	if ( ep_out == -1 ) {
724 		MTS_WARNING( "couldn't find an output bulk endpoint. Bailing out.\n" );
725 		return -ENODEV;
726 	}
727 
728 
729 	new_desc = kzalloc(sizeof(struct mts_desc), GFP_KERNEL);
730 	if (!new_desc)
731 		goto out;
732 
733 	new_desc->urb = usb_alloc_urb(0, GFP_KERNEL);
734 	if (!new_desc->urb)
735 		goto out_kfree;
736 
737 	new_desc->context.scsi_status = kmalloc(1, GFP_KERNEL);
738 	if (!new_desc->context.scsi_status)
739 		goto out_free_urb;
740 
741 	new_desc->usb_dev = dev;
742 	new_desc->usb_intf = intf;
743 
744 	/* endpoints */
745 	new_desc->ep_out = ep_out;
746 	new_desc->ep_response = ep_in_set[0];
747 	new_desc->ep_image = ep_in_set[1];
748 
749 	if ( new_desc->ep_out != MTS_EP_OUT )
750 		MTS_WARNING( "will this work? Command EP is not usually %d\n",
751 			     (int)new_desc->ep_out );
752 
753 	if ( new_desc->ep_response != MTS_EP_RESPONSE )
754 		MTS_WARNING( "will this work? Response EP is not usually %d\n",
755 			     (int)new_desc->ep_response );
756 
757 	if ( new_desc->ep_image != MTS_EP_IMAGE )
758 		MTS_WARNING( "will this work? Image data EP is not usually %d\n",
759 			     (int)new_desc->ep_image );
760 
761 	new_desc->host = scsi_host_alloc(&mts_scsi_host_template,
762 			sizeof(new_desc));
763 	if (!new_desc->host)
764 		goto out_kfree2;
765 
766 	new_desc->host->hostdata[0] = (unsigned long)new_desc;
767 	if (scsi_add_host(new_desc->host, &dev->dev)) {
768 		err_retval = -EIO;
769 		goto out_host_put;
770 	}
771 	scsi_scan_host(new_desc->host);
772 
773 	usb_set_intfdata(intf, new_desc);
774 	return 0;
775 
776  out_host_put:
777 	scsi_host_put(new_desc->host);
778  out_kfree2:
779 	kfree(new_desc->context.scsi_status);
780  out_free_urb:
781 	usb_free_urb(new_desc->urb);
782  out_kfree:
783 	kfree(new_desc);
784  out:
785 	return err_retval;
786 }
787 
mts_usb_disconnect(struct usb_interface * intf)788 static void mts_usb_disconnect (struct usb_interface *intf)
789 {
790 	struct mts_desc *desc = usb_get_intfdata(intf);
791 
792 	usb_set_intfdata(intf, NULL);
793 
794 	usb_kill_urb(desc->urb);
795 	scsi_remove_host(desc->host);
796 
797 	scsi_host_put(desc->host);
798 	usb_free_urb(desc->urb);
799 	kfree(desc->context.scsi_status);
800 	kfree(desc);
801 }
802 
803 module_usb_driver(mts_usb_driver);
804 
805 MODULE_AUTHOR( DRIVER_AUTHOR );
806 MODULE_DESCRIPTION( DRIVER_DESC );
807 MODULE_LICENSE("GPL");
808