xref: /freebsd/sys/cam/scsi/scsi_da.c (revision aca5021d5f7dcab1e11692923266373e35322d9a)
1 /*-
2  * Implementation of SCSI Direct Access Peripheral driver for CAM.
3  *
4  * Copyright (c) 1997 Justin T. Gibbs.
5  * All rights reserved.
6  *
7  * Redistribution and use in source and binary forms, with or without
8  * modification, are permitted provided that the following conditions
9  * are met:
10  * 1. Redistributions of source code must retain the above copyright
11  *    notice, this list of conditions, and the following disclaimer,
12  *    without modification, immediately at the beginning of the file.
13  * 2. The name of the author may not be used to endorse or promote products
14  *    derived from this software without specific prior written permission.
15  *
16  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19  * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE FOR
20  * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26  * SUCH DAMAGE.
27  */
28 
29 #include <sys/cdefs.h>
30 __FBSDID("$FreeBSD$");
31 
32 #include <sys/param.h>
33 
34 #ifdef _KERNEL
35 #include <sys/systm.h>
36 #include <sys/kernel.h>
37 #include <sys/bio.h>
38 #include <sys/sysctl.h>
39 #include <sys/taskqueue.h>
40 #include <sys/lock.h>
41 #include <sys/mutex.h>
42 #include <sys/conf.h>
43 #include <sys/devicestat.h>
44 #include <sys/eventhandler.h>
45 #include <sys/malloc.h>
46 #include <sys/cons.h>
47 #include <sys/endian.h>
48 #include <sys/proc.h>
49 #include <geom/geom.h>
50 #include <geom/geom_disk.h>
51 #endif /* _KERNEL */
52 
53 #ifndef _KERNEL
54 #include <stdio.h>
55 #include <string.h>
56 #endif /* _KERNEL */
57 
58 #include <cam/cam.h>
59 #include <cam/cam_ccb.h>
60 #include <cam/cam_periph.h>
61 #include <cam/cam_xpt_periph.h>
62 #include <cam/cam_sim.h>
63 
64 #include <cam/scsi/scsi_message.h>
65 
66 #ifndef _KERNEL
67 #include <cam/scsi/scsi_da.h>
68 #endif /* !_KERNEL */
69 
70 #ifdef _KERNEL
71 typedef enum {
72 	DA_STATE_PROBE_RC,
73 	DA_STATE_PROBE_RC16,
74 	DA_STATE_PROBE_LBP,
75 	DA_STATE_PROBE_BLK_LIMITS,
76 	DA_STATE_PROBE_BDC,
77 	DA_STATE_PROBE_ATA,
78 	DA_STATE_NORMAL
79 } da_state;
80 
81 typedef enum {
82 	DA_FLAG_PACK_INVALID	= 0x001,
83 	DA_FLAG_NEW_PACK	= 0x002,
84 	DA_FLAG_PACK_LOCKED	= 0x004,
85 	DA_FLAG_PACK_REMOVABLE	= 0x008,
86 	DA_FLAG_NEED_OTAG	= 0x020,
87 	DA_FLAG_WENT_IDLE	= 0x040,
88 	DA_FLAG_RETRY_UA	= 0x080,
89 	DA_FLAG_OPEN		= 0x100,
90 	DA_FLAG_SCTX_INIT	= 0x200,
91 	DA_FLAG_CAN_RC16	= 0x400,
92 	DA_FLAG_PROBED		= 0x800,
93 	DA_FLAG_DIRTY		= 0x1000
94 } da_flags;
95 
96 typedef enum {
97 	DA_Q_NONE		= 0x00,
98 	DA_Q_NO_SYNC_CACHE	= 0x01,
99 	DA_Q_NO_6_BYTE		= 0x02,
100 	DA_Q_NO_PREVENT		= 0x04,
101 	DA_Q_4K			= 0x08,
102 	DA_Q_NO_RC16		= 0x10
103 } da_quirks;
104 
105 #define DA_Q_BIT_STRING		\
106 	"\020"			\
107 	"\001NO_SYNC_CACHE"	\
108 	"\002NO_6_BYTE"		\
109 	"\003NO_PREVENT"	\
110 	"\0044K"		\
111 	"\005NO_RC16"
112 
113 typedef enum {
114 	DA_CCB_PROBE_RC		= 0x01,
115 	DA_CCB_PROBE_RC16	= 0x02,
116 	DA_CCB_PROBE_LBP	= 0x03,
117 	DA_CCB_PROBE_BLK_LIMITS	= 0x04,
118 	DA_CCB_PROBE_BDC	= 0x05,
119 	DA_CCB_PROBE_ATA	= 0x06,
120 	DA_CCB_BUFFER_IO	= 0x07,
121 	DA_CCB_WAITING		= 0x08,
122 	DA_CCB_DUMP		= 0x0A,
123 	DA_CCB_DELETE		= 0x0B,
124  	DA_CCB_TUR		= 0x0C,
125 	DA_CCB_TYPE_MASK	= 0x0F,
126 	DA_CCB_RETRY_UA		= 0x10
127 } da_ccb_state;
128 
129 /*
130  * Order here is important for method choice
131  *
132  * We prefer ATA_TRIM as tests run against a Sandforce 2281 SSD attached to
133  * LSI 2008 (mps) controller (FW: v12, Drv: v14) resulted 20% quicker deletes
134  * using ATA_TRIM than the corresponding UNMAP results for a real world mysql
135  * import taking 5mins.
136  *
137  */
138 typedef enum {
139 	DA_DELETE_NONE,
140 	DA_DELETE_DISABLE,
141 	DA_DELETE_ATA_TRIM,
142 	DA_DELETE_UNMAP,
143 	DA_DELETE_WS16,
144 	DA_DELETE_WS10,
145 	DA_DELETE_ZERO,
146 	DA_DELETE_MIN = DA_DELETE_ATA_TRIM,
147 	DA_DELETE_MAX = DA_DELETE_ZERO
148 } da_delete_methods;
149 
150 typedef void da_delete_func_t (struct cam_periph *periph, union ccb *ccb,
151 			      struct bio *bp);
152 static da_delete_func_t da_delete_trim;
153 static da_delete_func_t da_delete_unmap;
154 static da_delete_func_t da_delete_ws;
155 
156 static const void * da_delete_functions[] = {
157 	NULL,
158 	NULL,
159 	da_delete_trim,
160 	da_delete_unmap,
161 	da_delete_ws,
162 	da_delete_ws,
163 	da_delete_ws
164 };
165 
166 static const char *da_delete_method_names[] =
167     { "NONE", "DISABLE", "ATA_TRIM", "UNMAP", "WS16", "WS10", "ZERO" };
168 static const char *da_delete_method_desc[] =
169     { "NONE", "DISABLED", "ATA TRIM", "UNMAP", "WRITE SAME(16) with UNMAP",
170       "WRITE SAME(10) with UNMAP", "ZERO" };
171 
172 /* Offsets into our private area for storing information */
173 #define ccb_state	ppriv_field0
174 #define ccb_bp		ppriv_ptr1
175 
176 struct disk_params {
177 	u_int8_t  heads;
178 	u_int32_t cylinders;
179 	u_int8_t  secs_per_track;
180 	u_int32_t secsize;	/* Number of bytes/sector */
181 	u_int64_t sectors;	/* total number sectors */
182 	u_int     stripesize;
183 	u_int     stripeoffset;
184 };
185 
186 #define UNMAP_RANGE_MAX		0xffffffff
187 #define UNMAP_HEAD_SIZE		8
188 #define UNMAP_RANGE_SIZE	16
189 #define UNMAP_MAX_RANGES	2048 /* Protocol Max is 4095 */
190 #define UNMAP_BUF_SIZE		((UNMAP_MAX_RANGES * UNMAP_RANGE_SIZE) + \
191 				UNMAP_HEAD_SIZE)
192 
193 #define WS10_MAX_BLKS		0xffff
194 #define WS16_MAX_BLKS		0xffffffff
195 #define ATA_TRIM_MAX_RANGES	((UNMAP_BUF_SIZE / \
196 	(ATA_DSM_RANGE_SIZE * ATA_DSM_BLK_SIZE)) * ATA_DSM_BLK_SIZE)
197 
198 struct da_softc {
199 	struct	 bio_queue_head bio_queue;
200 	struct	 bio_queue_head delete_queue;
201 	struct	 bio_queue_head delete_run_queue;
202 	SLIST_ENTRY(da_softc) links;
203 	LIST_HEAD(, ccb_hdr) pending_ccbs;
204 	da_state state;
205 	da_flags flags;
206 	da_quirks quirks;
207 	int	 sort_io_queue;
208 	int	 minimum_cmd_size;
209 	int	 error_inject;
210 	int	 ordered_tag_count;
211 	int	 outstanding_cmds;
212 	int	 trim_max_ranges;
213 	int	 delete_running;
214 	int	 tur;
215 	int	 delete_available;	/* Delete methods possibly available */
216 	uint32_t		unmap_max_ranges;
217 	uint32_t		unmap_max_lba;
218 	uint64_t		ws_max_blks;
219 	da_delete_methods	delete_method;
220 	da_delete_func_t	*delete_func;
221 	struct	 disk_params params;
222 	struct	 disk *disk;
223 	union	 ccb saved_ccb;
224 	struct task		sysctl_task;
225 	struct sysctl_ctx_list	sysctl_ctx;
226 	struct sysctl_oid	*sysctl_tree;
227 	struct callout		sendordered_c;
228 	uint64_t wwpn;
229 	uint8_t	 unmap_buf[UNMAP_BUF_SIZE];
230 	struct scsi_read_capacity_data_long rcaplong;
231 	struct callout		mediapoll_c;
232 };
233 
234 #define dadeleteflag(softc, delete_method, enable)			\
235 	if (enable) {							\
236 		softc->delete_available |= (1 << delete_method);	\
237 	} else {							\
238 		softc->delete_available &= ~(1 << delete_method);	\
239 	}
240 
241 struct da_quirk_entry {
242 	struct scsi_inquiry_pattern inq_pat;
243 	da_quirks quirks;
244 };
245 
246 static const char quantum[] = "QUANTUM";
247 static const char microp[] = "MICROP";
248 
249 static struct da_quirk_entry da_quirk_table[] =
250 {
251 	/* SPI, FC devices */
252 	{
253 		/*
254 		 * Fujitsu M2513A MO drives.
255 		 * Tested devices: M2513A2 firmware versions 1200 & 1300.
256 		 * (dip switch selects whether T_DIRECT or T_OPTICAL device)
257 		 * Reported by: W.Scholten <whs@xs4all.nl>
258 		 */
259 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "FUJITSU", "M2513A", "*"},
260 		/*quirks*/ DA_Q_NO_SYNC_CACHE
261 	},
262 	{
263 		/* See above. */
264 		{T_OPTICAL, SIP_MEDIA_REMOVABLE, "FUJITSU", "M2513A", "*"},
265 		/*quirks*/ DA_Q_NO_SYNC_CACHE
266 	},
267 	{
268 		/*
269 		 * This particular Fujitsu drive doesn't like the
270 		 * synchronize cache command.
271 		 * Reported by: Tom Jackson <toj@gorilla.net>
272 		 */
273 		{T_DIRECT, SIP_MEDIA_FIXED, "FUJITSU", "M2954*", "*"},
274 		/*quirks*/ DA_Q_NO_SYNC_CACHE
275 	},
276 	{
277 		/*
278 		 * This drive doesn't like the synchronize cache command
279 		 * either.  Reported by: Matthew Jacob <mjacob@feral.com>
280 		 * in NetBSD PR kern/6027, August 24, 1998.
281 		 */
282 		{T_DIRECT, SIP_MEDIA_FIXED, microp, "2217*", "*"},
283 		/*quirks*/ DA_Q_NO_SYNC_CACHE
284 	},
285 	{
286 		/*
287 		 * This drive doesn't like the synchronize cache command
288 		 * either.  Reported by: Hellmuth Michaelis (hm@kts.org)
289 		 * (PR 8882).
290 		 */
291 		{T_DIRECT, SIP_MEDIA_FIXED, microp, "2112*", "*"},
292 		/*quirks*/ DA_Q_NO_SYNC_CACHE
293 	},
294 	{
295 		/*
296 		 * Doesn't like the synchronize cache command.
297 		 * Reported by: Blaz Zupan <blaz@gold.amis.net>
298 		 */
299 		{T_DIRECT, SIP_MEDIA_FIXED, "NEC", "D3847*", "*"},
300 		/*quirks*/ DA_Q_NO_SYNC_CACHE
301 	},
302 	{
303 		/*
304 		 * Doesn't like the synchronize cache command.
305 		 * Reported by: Blaz Zupan <blaz@gold.amis.net>
306 		 */
307 		{T_DIRECT, SIP_MEDIA_FIXED, quantum, "MAVERICK 540S", "*"},
308 		/*quirks*/ DA_Q_NO_SYNC_CACHE
309 	},
310 	{
311 		/*
312 		 * Doesn't like the synchronize cache command.
313 		 */
314 		{T_DIRECT, SIP_MEDIA_FIXED, quantum, "LPS525S", "*"},
315 		/*quirks*/ DA_Q_NO_SYNC_CACHE
316 	},
317 	{
318 		/*
319 		 * Doesn't like the synchronize cache command.
320 		 * Reported by: walter@pelissero.de
321 		 */
322 		{T_DIRECT, SIP_MEDIA_FIXED, quantum, "LPS540S", "*"},
323 		/*quirks*/ DA_Q_NO_SYNC_CACHE
324 	},
325 	{
326 		/*
327 		 * Doesn't work correctly with 6 byte reads/writes.
328 		 * Returns illegal request, and points to byte 9 of the
329 		 * 6-byte CDB.
330 		 * Reported by:  Adam McDougall <bsdx@spawnet.com>
331 		 */
332 		{T_DIRECT, SIP_MEDIA_FIXED, quantum, "VIKING 4*", "*"},
333 		/*quirks*/ DA_Q_NO_6_BYTE
334 	},
335 	{
336 		/* See above. */
337 		{T_DIRECT, SIP_MEDIA_FIXED, quantum, "VIKING 2*", "*"},
338 		/*quirks*/ DA_Q_NO_6_BYTE
339 	},
340 	{
341 		/*
342 		 * Doesn't like the synchronize cache command.
343 		 * Reported by: walter@pelissero.de
344 		 */
345 		{T_DIRECT, SIP_MEDIA_FIXED, "CONNER", "CP3500*", "*"},
346 		/*quirks*/ DA_Q_NO_SYNC_CACHE
347 	},
348 	{
349 		/*
350 		 * The CISS RAID controllers do not support SYNC_CACHE
351 		 */
352 		{T_DIRECT, SIP_MEDIA_FIXED, "COMPAQ", "RAID*", "*"},
353 		/*quirks*/ DA_Q_NO_SYNC_CACHE
354 	},
355 	/* USB mass storage devices supported by umass(4) */
356 	{
357 		/*
358 		 * EXATELECOM (Sigmatel) i-Bead 100/105 USB Flash MP3 Player
359 		 * PR: kern/51675
360 		 */
361 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "EXATEL", "i-BEAD10*", "*"},
362 		/*quirks*/ DA_Q_NO_SYNC_CACHE
363 	},
364 	{
365 		/*
366 		 * Power Quotient Int. (PQI) USB flash key
367 		 * PR: kern/53067
368 		 */
369 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Generic*", "USB Flash Disk*",
370 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
371 	},
372  	{
373  		/*
374  		 * Creative Nomad MUVO mp3 player (USB)
375  		 * PR: kern/53094
376  		 */
377  		{T_DIRECT, SIP_MEDIA_REMOVABLE, "CREATIVE", "NOMAD_MUVO", "*"},
378  		/*quirks*/ DA_Q_NO_SYNC_CACHE|DA_Q_NO_PREVENT
379  	},
380 	{
381 		/*
382 		 * Jungsoft NEXDISK USB flash key
383 		 * PR: kern/54737
384 		 */
385 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "JUNGSOFT", "NEXDISK*", "*"},
386 		/*quirks*/ DA_Q_NO_SYNC_CACHE
387 	},
388 	{
389 		/*
390 		 * FreeDik USB Mini Data Drive
391 		 * PR: kern/54786
392 		 */
393 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "FreeDik*", "Mini Data Drive",
394 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
395 	},
396 	{
397 		/*
398 		 * Sigmatel USB Flash MP3 Player
399 		 * PR: kern/57046
400 		 */
401 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "SigmaTel", "MSCN", "*"},
402 		/*quirks*/ DA_Q_NO_SYNC_CACHE|DA_Q_NO_PREVENT
403 	},
404 	{
405 		/*
406 		 * Neuros USB Digital Audio Computer
407 		 * PR: kern/63645
408 		 */
409 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "NEUROS", "dig. audio comp.",
410 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
411 	},
412 	{
413 		/*
414 		 * SEAGRAND NP-900 MP3 Player
415 		 * PR: kern/64563
416 		 */
417 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "SEAGRAND", "NP-900*", "*"},
418 		/*quirks*/ DA_Q_NO_SYNC_CACHE|DA_Q_NO_PREVENT
419 	},
420 	{
421 		/*
422 		 * iRiver iFP MP3 player (with UMS Firmware)
423 		 * PR: kern/54881, i386/63941, kern/66124
424 		 */
425 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "iRiver", "iFP*", "*"},
426 		/*quirks*/ DA_Q_NO_SYNC_CACHE
427  	},
428 	{
429 		/*
430 		 * Frontier Labs NEX IA+ Digital Audio Player, rev 1.10/0.01
431 		 * PR: kern/70158
432 		 */
433 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "FL" , "Nex*", "*"},
434 		/*quirks*/ DA_Q_NO_SYNC_CACHE
435 	},
436 	{
437 		/*
438 		 * ZICPlay USB MP3 Player with FM
439 		 * PR: kern/75057
440 		 */
441 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "ACTIONS*" , "USB DISK*", "*"},
442 		/*quirks*/ DA_Q_NO_SYNC_CACHE
443 	},
444 	{
445 		/*
446 		 * TEAC USB floppy mechanisms
447 		 */
448 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "TEAC" , "FD-05*", "*"},
449 		/*quirks*/ DA_Q_NO_SYNC_CACHE
450 	},
451 	{
452 		/*
453 		 * Kingston DataTraveler II+ USB Pen-Drive.
454 		 * Reported by: Pawel Jakub Dawidek <pjd@FreeBSD.org>
455 		 */
456 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Kingston" , "DataTraveler II+",
457 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
458 	},
459 	{
460 		/*
461 		 * USB DISK Pro PMAP
462 		 * Reported by: jhs
463 		 * PR: usb/96381
464 		 */
465 		{T_DIRECT, SIP_MEDIA_REMOVABLE, " ", "USB DISK Pro", "PMAP"},
466 		/*quirks*/ DA_Q_NO_SYNC_CACHE
467 	},
468 	{
469 		/*
470 		 * Motorola E398 Mobile Phone (TransFlash memory card).
471 		 * Reported by: Wojciech A. Koszek <dunstan@FreeBSD.czest.pl>
472 		 * PR: usb/89889
473 		 */
474 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Motorola" , "Motorola Phone",
475 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
476 	},
477 	{
478 		/*
479 		 * Qware BeatZkey! Pro
480 		 * PR: usb/79164
481 		 */
482 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "GENERIC", "USB DISK DEVICE",
483 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
484 	},
485 	{
486 		/*
487 		 * Time DPA20B 1GB MP3 Player
488 		 * PR: usb/81846
489 		 */
490 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "USB2.0*", "(FS) FLASH DISK*",
491 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
492 	},
493 	{
494 		/*
495 		 * Samsung USB key 128Mb
496 		 * PR: usb/90081
497 		 */
498 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "USB-DISK", "FreeDik-FlashUsb",
499 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
500 	},
501 	{
502 		/*
503 		 * Kingston DataTraveler 2.0 USB Flash memory.
504 		 * PR: usb/89196
505 		 */
506 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Kingston", "DataTraveler 2.0",
507 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
508 	},
509 	{
510 		/*
511 		 * Creative MUVO Slim mp3 player (USB)
512 		 * PR: usb/86131
513 		 */
514 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "CREATIVE", "MuVo Slim",
515 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE|DA_Q_NO_PREVENT
516 		},
517 	{
518 		/*
519 		 * United MP5512 Portable MP3 Player (2-in-1 USB DISK/MP3)
520 		 * PR: usb/80487
521 		 */
522 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Generic*", "MUSIC DISK",
523 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
524 	},
525 	{
526 		/*
527 		 * SanDisk Micro Cruzer 128MB
528 		 * PR: usb/75970
529 		 */
530 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "SanDisk" , "Micro Cruzer",
531 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
532 	},
533 	{
534 		/*
535 		 * TOSHIBA TransMemory USB sticks
536 		 * PR: kern/94660
537 		 */
538 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "TOSHIBA", "TransMemory",
539 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
540 	},
541 	{
542 		/*
543 		 * PNY USB Flash keys
544 		 * PR: usb/75578, usb/72344, usb/65436
545 		 */
546 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "*" , "USB DISK*",
547 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
548 	},
549 	{
550 		/*
551 		 * Genesys 6-in-1 Card Reader
552 		 * PR: usb/94647
553 		 */
554 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Generic*", "STORAGE DEVICE*",
555 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
556 	},
557 	{
558 		/*
559 		 * Rekam Digital CAMERA
560 		 * PR: usb/98713
561 		 */
562 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "CAMERA*", "4MP-9J6*",
563 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
564 	},
565 	{
566 		/*
567 		 * iRiver H10 MP3 player
568 		 * PR: usb/102547
569 		 */
570 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "iriver", "H10*",
571 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
572 	},
573 	{
574 		/*
575 		 * iRiver U10 MP3 player
576 		 * PR: usb/92306
577 		 */
578 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "iriver", "U10*",
579 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
580 	},
581 	{
582 		/*
583 		 * X-Micro Flash Disk
584 		 * PR: usb/96901
585 		 */
586 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "X-Micro", "Flash Disk",
587 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
588 	},
589 	{
590 		/*
591 		 * EasyMP3 EM732X USB 2.0 Flash MP3 Player
592 		 * PR: usb/96546
593 		 */
594 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "EM732X", "MP3 Player*",
595 		"1.00"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
596 	},
597 	{
598 		/*
599 		 * Denver MP3 player
600 		 * PR: usb/107101
601 		 */
602 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "DENVER", "MP3 PLAYER",
603 		 "*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
604 	},
605 	{
606 		/*
607 		 * Philips USB Key Audio KEY013
608 		 * PR: usb/68412
609 		 */
610 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "PHILIPS", "Key*", "*"},
611 		/*quirks*/ DA_Q_NO_SYNC_CACHE | DA_Q_NO_PREVENT
612 	},
613 	{
614 		/*
615 		 * JNC MP3 Player
616 		 * PR: usb/94439
617 		 */
618 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "JNC*" , "MP3 Player*",
619 		 "*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
620 	},
621 	{
622 		/*
623 		 * SAMSUNG MP0402H
624 		 * PR: usb/108427
625 		 */
626 		{T_DIRECT, SIP_MEDIA_FIXED, "SAMSUNG", "MP0402H", "*"},
627 		/*quirks*/ DA_Q_NO_SYNC_CACHE
628 	},
629 	{
630 		/*
631 		 * I/O Magic USB flash - Giga Bank
632 		 * PR: usb/108810
633 		 */
634 		{T_DIRECT, SIP_MEDIA_FIXED, "GS-Magic", "stor*", "*"},
635 		/*quirks*/ DA_Q_NO_SYNC_CACHE
636 	},
637 	{
638 		/*
639 		 * JoyFly 128mb USB Flash Drive
640 		 * PR: 96133
641 		 */
642 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "USB 2.0", "Flash Disk*",
643 		 "*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
644 	},
645 	{
646 		/*
647 		 * ChipsBnk usb stick
648 		 * PR: 103702
649 		 */
650 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "ChipsBnk", "USB*",
651 		 "*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
652 	},
653 	{
654 		/*
655 		 * Storcase (Kingston) InfoStation IFS FC2/SATA-R 201A
656 		 * PR: 129858
657 		 */
658 		{T_DIRECT, SIP_MEDIA_FIXED, "IFS", "FC2/SATA-R*",
659 		 "*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
660 	},
661 	{
662 		/*
663 		 * Samsung YP-U3 mp3-player
664 		 * PR: 125398
665 		 */
666 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Samsung", "YP-U3",
667 		 "*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
668 	},
669 	{
670 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Netac", "OnlyDisk*",
671 		 "2000"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
672 	},
673 	{
674 		/*
675 		 * Sony Cyber-Shot DSC cameras
676 		 * PR: usb/137035
677 		 */
678 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Sony", "Sony DSC", "*"},
679 		/*quirks*/ DA_Q_NO_SYNC_CACHE | DA_Q_NO_PREVENT
680 	},
681 	{
682 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "Kingston", "DataTraveler G3",
683 		 "1.00"}, /*quirks*/ DA_Q_NO_PREVENT
684 	},
685 	{
686 		/* At least several Transcent USB sticks lie on RC16. */
687 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "JetFlash", "Transcend*",
688 		 "*"}, /*quirks*/ DA_Q_NO_RC16
689 	},
690 	/* ATA/SATA devices over SAS/USB/... */
691 	{
692 		/* Hitachi Advanced Format (4k) drives */
693 		{ T_DIRECT, SIP_MEDIA_FIXED, "Hitachi", "H??????????E3*", "*" },
694 		/*quirks*/DA_Q_4K
695 	},
696 	{
697 		/* Samsung Advanced Format (4k) drives */
698 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "SAMSUNG HD155UI*", "*" },
699 		/*quirks*/DA_Q_4K
700 	},
701 	{
702 		/* Samsung Advanced Format (4k) drives */
703 		{ T_DIRECT, SIP_MEDIA_FIXED, "SAMSUNG", "HD155UI*", "*" },
704 		/*quirks*/DA_Q_4K
705 	},
706 	{
707 		/* Samsung Advanced Format (4k) drives */
708 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "SAMSUNG HD204UI*", "*" },
709 		/*quirks*/DA_Q_4K
710 	},
711 	{
712 		/* Samsung Advanced Format (4k) drives */
713 		{ T_DIRECT, SIP_MEDIA_FIXED, "SAMSUNG", "HD204UI*", "*" },
714 		/*quirks*/DA_Q_4K
715 	},
716 	{
717 		/* Seagate Barracuda Green Advanced Format (4k) drives */
718 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST????DL*", "*" },
719 		/*quirks*/DA_Q_4K
720 	},
721 	{
722 		/* Seagate Barracuda Green Advanced Format (4k) drives */
723 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST????DL", "*", "*" },
724 		/*quirks*/DA_Q_4K
725 	},
726 	{
727 		/* Seagate Barracuda Green Advanced Format (4k) drives */
728 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST???DM*", "*" },
729 		/*quirks*/DA_Q_4K
730 	},
731 	{
732 		/* Seagate Barracuda Green Advanced Format (4k) drives */
733 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST???DM*", "*", "*" },
734 		/*quirks*/DA_Q_4K
735 	},
736 	{
737 		/* Seagate Barracuda Green Advanced Format (4k) drives */
738 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST????DM*", "*" },
739 		/*quirks*/DA_Q_4K
740 	},
741 	{
742 		/* Seagate Barracuda Green Advanced Format (4k) drives */
743 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST????DM", "*", "*" },
744 		/*quirks*/DA_Q_4K
745 	},
746 	{
747 		/* Seagate Momentus Advanced Format (4k) drives */
748 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST9500423AS*", "*" },
749 		/*quirks*/DA_Q_4K
750 	},
751 	{
752 		/* Seagate Momentus Advanced Format (4k) drives */
753 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST950042", "3AS*", "*" },
754 		/*quirks*/DA_Q_4K
755 	},
756 	{
757 		/* Seagate Momentus Advanced Format (4k) drives */
758 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST9500424AS*", "*" },
759 		/*quirks*/DA_Q_4K
760 	},
761 	{
762 		/* Seagate Momentus Advanced Format (4k) drives */
763 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST950042", "4AS*", "*" },
764 		/*quirks*/DA_Q_4K
765 	},
766 	{
767 		/* Seagate Momentus Advanced Format (4k) drives */
768 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST9640423AS*", "*" },
769 		/*quirks*/DA_Q_4K
770 	},
771 	{
772 		/* Seagate Momentus Advanced Format (4k) drives */
773 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST964042", "3AS*", "*" },
774 		/*quirks*/DA_Q_4K
775 	},
776 	{
777 		/* Seagate Momentus Advanced Format (4k) drives */
778 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST9640424AS*", "*" },
779 		/*quirks*/DA_Q_4K
780 	},
781 	{
782 		/* Seagate Momentus Advanced Format (4k) drives */
783 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST964042", "4AS*", "*" },
784 		/*quirks*/DA_Q_4K
785 	},
786 	{
787 		/* Seagate Momentus Advanced Format (4k) drives */
788 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST9750420AS*", "*" },
789 		/*quirks*/DA_Q_4K
790 	},
791 	{
792 		/* Seagate Momentus Advanced Format (4k) drives */
793 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST975042", "0AS*", "*" },
794 		/*quirks*/DA_Q_4K
795 	},
796 	{
797 		/* Seagate Momentus Advanced Format (4k) drives */
798 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST9750422AS*", "*" },
799 		/*quirks*/DA_Q_4K
800 	},
801 	{
802 		/* Seagate Momentus Advanced Format (4k) drives */
803 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST975042", "2AS*", "*" },
804 		/*quirks*/DA_Q_4K
805 	},
806 	{
807 		/* Seagate Momentus Advanced Format (4k) drives */
808 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST9750423AS*", "*" },
809 		/*quirks*/DA_Q_4K
810 	},
811 	{
812 		/* Seagate Momentus Advanced Format (4k) drives */
813 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST975042", "3AS*", "*" },
814 		/*quirks*/DA_Q_4K
815 	},
816 	{
817 		/* Seagate Momentus Thin Advanced Format (4k) drives */
818 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "ST???LT*", "*" },
819 		/*quirks*/DA_Q_4K
820 	},
821 	{
822 		/* Seagate Momentus Thin Advanced Format (4k) drives */
823 		{ T_DIRECT, SIP_MEDIA_FIXED, "ST???LT*", "*", "*" },
824 		/*quirks*/DA_Q_4K
825 	},
826 	{
827 		/* WDC Caviar Green Advanced Format (4k) drives */
828 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "WDC WD????RS*", "*" },
829 		/*quirks*/DA_Q_4K
830 	},
831 	{
832 		/* WDC Caviar Green Advanced Format (4k) drives */
833 		{ T_DIRECT, SIP_MEDIA_FIXED, "WDC WD??", "??RS*", "*" },
834 		/*quirks*/DA_Q_4K
835 	},
836 	{
837 		/* WDC Caviar Green Advanced Format (4k) drives */
838 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "WDC WD????RX*", "*" },
839 		/*quirks*/DA_Q_4K
840 	},
841 	{
842 		/* WDC Caviar Green Advanced Format (4k) drives */
843 		{ T_DIRECT, SIP_MEDIA_FIXED, "WDC WD??", "??RX*", "*" },
844 		/*quirks*/DA_Q_4K
845 	},
846 	{
847 		/* WDC Caviar Green Advanced Format (4k) drives */
848 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "WDC WD??????RS*", "*" },
849 		/*quirks*/DA_Q_4K
850 	},
851 	{
852 		/* WDC Caviar Green Advanced Format (4k) drives */
853 		{ T_DIRECT, SIP_MEDIA_FIXED, "WDC WD??", "????RS*", "*" },
854 		/*quirks*/DA_Q_4K
855 	},
856 	{
857 		/* WDC Caviar Green Advanced Format (4k) drives */
858 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "WDC WD??????RX*", "*" },
859 		/*quirks*/DA_Q_4K
860 	},
861 	{
862 		/* WDC Caviar Green Advanced Format (4k) drives */
863 		{ T_DIRECT, SIP_MEDIA_FIXED, "WDC WD??", "????RX*", "*" },
864 		/*quirks*/DA_Q_4K
865 	},
866 	{
867 		/* WDC Scorpio Black Advanced Format (4k) drives */
868 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "WDC WD???PKT*", "*" },
869 		/*quirks*/DA_Q_4K
870 	},
871 	{
872 		/* WDC Scorpio Black Advanced Format (4k) drives */
873 		{ T_DIRECT, SIP_MEDIA_FIXED, "WDC WD??", "?PKT*", "*" },
874 		/*quirks*/DA_Q_4K
875 	},
876 	{
877 		/* WDC Scorpio Black Advanced Format (4k) drives */
878 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "WDC WD?????PKT*", "*" },
879 		/*quirks*/DA_Q_4K
880 	},
881 	{
882 		/* WDC Scorpio Black Advanced Format (4k) drives */
883 		{ T_DIRECT, SIP_MEDIA_FIXED, "WDC WD??", "???PKT*", "*" },
884 		/*quirks*/DA_Q_4K
885 	},
886 	{
887 		/* WDC Scorpio Blue Advanced Format (4k) drives */
888 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "WDC WD???PVT*", "*" },
889 		/*quirks*/DA_Q_4K
890 	},
891 	{
892 		/* WDC Scorpio Blue Advanced Format (4k) drives */
893 		{ T_DIRECT, SIP_MEDIA_FIXED, "WDC WD??", "?PVT*", "*" },
894 		/*quirks*/DA_Q_4K
895 	},
896 	{
897 		/* WDC Scorpio Blue Advanced Format (4k) drives */
898 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "WDC WD?????PVT*", "*" },
899 		/*quirks*/DA_Q_4K
900 	},
901 	{
902 		/* WDC Scorpio Blue Advanced Format (4k) drives */
903 		{ T_DIRECT, SIP_MEDIA_FIXED, "WDC WD??", "???PVT*", "*" },
904 		/*quirks*/DA_Q_4K
905 	},
906 	{
907 		/*
908 		 * Olympus FE-210 camera
909 		 */
910 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "OLYMPUS", "FE210*",
911 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
912 	},
913 	{
914 		/*
915 		 * LG UP3S MP3 player
916 		 */
917 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "LG", "UP3S",
918 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
919 	},
920 	{
921 		/*
922 		 * Laser MP3-2GA13 MP3 player
923 		 */
924 		{T_DIRECT, SIP_MEDIA_REMOVABLE, "USB 2.0", "(HS) Flash Disk",
925 		"*"}, /*quirks*/ DA_Q_NO_SYNC_CACHE
926 	},
927 	{
928 		/*
929 		 * LaCie external 250GB Hard drive des by Porsche
930 		 * Submitted by: Ben Stuyts <ben@altesco.nl>
931 		 * PR: 121474
932 		 */
933 		{T_DIRECT, SIP_MEDIA_FIXED, "SAMSUNG", "HM250JI", "*"},
934 		/*quirks*/ DA_Q_NO_SYNC_CACHE
935 	},
936 	/* SATA SSDs */
937 	{
938 		/*
939 		 * Corsair Force 2 SSDs
940 		 * 4k optimised & trim only works in 4k requests + 4k aligned
941 		 */
942 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "Corsair CSSD-F*", "*" },
943 		/*quirks*/DA_Q_4K
944 	},
945 	{
946 		/*
947 		 * Corsair Force 3 SSDs
948 		 * 4k optimised & trim only works in 4k requests + 4k aligned
949 		 */
950 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "Corsair Force 3*", "*" },
951 		/*quirks*/DA_Q_4K
952 	},
953 	{
954 		/*
955 		 * Corsair Force GT SSDs
956 		 * 4k optimised & trim only works in 4k requests + 4k aligned
957 		 */
958 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "Corsair Force GT*", "*" },
959 		/*quirks*/DA_Q_4K
960 	},
961 	{
962 		/*
963 		 * Crucial M4 SSDs
964 		 * 4k optimised & trim only works in 4k requests + 4k aligned
965 		 */
966 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "M4-CT???M4SSD2*", "*" },
967 		/*quirks*/DA_Q_4K
968 	},
969 	{
970 		/*
971 		 * Crucial RealSSD C300 SSDs
972 		 * 4k optimised
973 		 */
974 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "C300-CTFDDAC???MAG*",
975 		"*" }, /*quirks*/DA_Q_4K
976 	},
977 	{
978 		/*
979 		 * Intel 320 Series SSDs
980 		 * 4k optimised & trim only works in 4k requests + 4k aligned
981 		 */
982 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "INTEL SSDSA2CW*", "*" },
983 		/*quirks*/DA_Q_4K
984 	},
985 	{
986 		/*
987 		 * Intel 330 Series SSDs
988 		 * 4k optimised & trim only works in 4k requests + 4k aligned
989 		 */
990 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "INTEL SSDSC2CT*", "*" },
991 		/*quirks*/DA_Q_4K
992 	},
993 	{
994 		/*
995 		 * Intel 510 Series SSDs
996 		 * 4k optimised & trim only works in 4k requests + 4k aligned
997 		 */
998 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "INTEL SSDSC2MH*", "*" },
999 		/*quirks*/DA_Q_4K
1000 	},
1001 	{
1002 		/*
1003 		 * Intel 520 Series SSDs
1004 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1005 		 */
1006 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "INTEL SSDSC2BW*", "*" },
1007 		/*quirks*/DA_Q_4K
1008 	},
1009 	{
1010 		/*
1011 		 * Kingston E100 Series SSDs
1012 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1013 		 */
1014 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "KINGSTON SE100S3*", "*" },
1015 		/*quirks*/DA_Q_4K
1016 	},
1017 	{
1018 		/*
1019 		 * Kingston HyperX 3k SSDs
1020 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1021 		 */
1022 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "KINGSTON SH103S3*", "*" },
1023 		/*quirks*/DA_Q_4K
1024 	},
1025 	{
1026 		/*
1027 		 * OCZ Agility 3 SSDs
1028 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1029 		 */
1030 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "OCZ-AGILITY3*", "*" },
1031 		/*quirks*/DA_Q_4K
1032 	},
1033 	{
1034 		/*
1035 		 * OCZ Deneva R Series SSDs
1036 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1037 		 */
1038 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "DENRSTE251M45*", "*" },
1039 		/*quirks*/DA_Q_4K
1040 	},
1041 	{
1042 		/*
1043 		 * OCZ Vertex 2 SSDs (inc pro series)
1044 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1045 		 */
1046 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "OCZ?VERTEX2*", "*" },
1047 		/*quirks*/DA_Q_4K
1048 	},
1049 	{
1050 		/*
1051 		 * OCZ Vertex 3 SSDs
1052 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1053 		 */
1054 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "OCZ-VERTEX3*", "*" },
1055 		/*quirks*/DA_Q_4K
1056 	},
1057 	{
1058 		/*
1059 		 * OCZ Vertex 4 SSDs
1060 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1061 		 */
1062 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "OCZ-VERTEX4*", "*" },
1063 		/*quirks*/DA_Q_4K
1064 	},
1065 	{
1066 		/*
1067 		 * Samsung 830 Series SSDs
1068 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1069 		 */
1070 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "SAMSUNG SSD 830 Series*", "*" },
1071 		/*quirks*/DA_Q_4K
1072 	},
1073 	{
1074 		/*
1075 		 * SuperTalent TeraDrive CT SSDs
1076 		 * 4k optimised & trim only works in 4k requests + 4k aligned
1077 		 */
1078 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "FTM??CT25H*", "*" },
1079 		/*quirks*/DA_Q_4K
1080 	},
1081 	{
1082 		/*
1083 		 * XceedIOPS SATA SSDs
1084 		 * 4k optimised
1085 		 */
1086 		{ T_DIRECT, SIP_MEDIA_FIXED, "ATA", "SG9XCS2D*", "*" },
1087 		/*quirks*/DA_Q_4K
1088 	},
1089 };
1090 
1091 static	disk_strategy_t	dastrategy;
1092 static	dumper_t	dadump;
1093 static	periph_init_t	dainit;
1094 static	void		daasync(void *callback_arg, u_int32_t code,
1095 				struct cam_path *path, void *arg);
1096 static	void		dasysctlinit(void *context, int pending);
1097 static	int		dacmdsizesysctl(SYSCTL_HANDLER_ARGS);
1098 static	int		dadeletemethodsysctl(SYSCTL_HANDLER_ARGS);
1099 static	int		dadeletemaxsysctl(SYSCTL_HANDLER_ARGS);
1100 static	void		dadeletemethodset(struct da_softc *softc,
1101 					  da_delete_methods delete_method);
1102 static	off_t		dadeletemaxsize(struct da_softc *softc,
1103 					da_delete_methods delete_method);
1104 static	void		dadeletemethodchoose(struct da_softc *softc,
1105 					     da_delete_methods default_method);
1106 static	void		daprobedone(struct cam_periph *periph, union ccb *ccb);
1107 
1108 static	periph_ctor_t	daregister;
1109 static	periph_dtor_t	dacleanup;
1110 static	periph_start_t	dastart;
1111 static	periph_oninv_t	daoninvalidate;
1112 static	void		dadone(struct cam_periph *periph,
1113 			       union ccb *done_ccb);
1114 static  int		daerror(union ccb *ccb, u_int32_t cam_flags,
1115 				u_int32_t sense_flags);
1116 static void		daprevent(struct cam_periph *periph, int action);
1117 static void		dareprobe(struct cam_periph *periph);
1118 static void		dasetgeom(struct cam_periph *periph, uint32_t block_len,
1119 				  uint64_t maxsector,
1120 				  struct scsi_read_capacity_data_long *rcaplong,
1121 				  size_t rcap_size);
1122 static timeout_t	dasendorderedtag;
1123 static void		dashutdown(void *arg, int howto);
1124 static timeout_t	damediapoll;
1125 
1126 #ifndef	DA_DEFAULT_POLL_PERIOD
1127 #define	DA_DEFAULT_POLL_PERIOD	3
1128 #endif
1129 
1130 #ifndef DA_DEFAULT_TIMEOUT
1131 #define DA_DEFAULT_TIMEOUT 60	/* Timeout in seconds */
1132 #endif
1133 
1134 #ifndef	DA_DEFAULT_RETRY
1135 #define	DA_DEFAULT_RETRY	4
1136 #endif
1137 
1138 #ifndef	DA_DEFAULT_SEND_ORDERED
1139 #define	DA_DEFAULT_SEND_ORDERED	1
1140 #endif
1141 
1142 #define DA_SIO (softc->sort_io_queue >= 0 ? \
1143     softc->sort_io_queue : cam_sort_io_queues)
1144 
1145 static int da_poll_period = DA_DEFAULT_POLL_PERIOD;
1146 static int da_retry_count = DA_DEFAULT_RETRY;
1147 static int da_default_timeout = DA_DEFAULT_TIMEOUT;
1148 static int da_send_ordered = DA_DEFAULT_SEND_ORDERED;
1149 
1150 static SYSCTL_NODE(_kern_cam, OID_AUTO, da, CTLFLAG_RD, 0,
1151             "CAM Direct Access Disk driver");
1152 SYSCTL_INT(_kern_cam_da, OID_AUTO, poll_period, CTLFLAG_RW,
1153            &da_poll_period, 0, "Media polling period in seconds");
1154 TUNABLE_INT("kern.cam.da.poll_period", &da_poll_period);
1155 SYSCTL_INT(_kern_cam_da, OID_AUTO, retry_count, CTLFLAG_RW,
1156            &da_retry_count, 0, "Normal I/O retry count");
1157 TUNABLE_INT("kern.cam.da.retry_count", &da_retry_count);
1158 SYSCTL_INT(_kern_cam_da, OID_AUTO, default_timeout, CTLFLAG_RW,
1159            &da_default_timeout, 0, "Normal I/O timeout (in seconds)");
1160 TUNABLE_INT("kern.cam.da.default_timeout", &da_default_timeout);
1161 SYSCTL_INT(_kern_cam_da, OID_AUTO, send_ordered, CTLFLAG_RW,
1162            &da_send_ordered, 0, "Send Ordered Tags");
1163 TUNABLE_INT("kern.cam.da.send_ordered", &da_send_ordered);
1164 
1165 /*
1166  * DA_ORDEREDTAG_INTERVAL determines how often, relative
1167  * to the default timeout, we check to see whether an ordered
1168  * tagged transaction is appropriate to prevent simple tag
1169  * starvation.  Since we'd like to ensure that there is at least
1170  * 1/2 of the timeout length left for a starved transaction to
1171  * complete after we've sent an ordered tag, we must poll at least
1172  * four times in every timeout period.  This takes care of the worst
1173  * case where a starved transaction starts during an interval that
1174  * meets the requirement "don't send an ordered tag" test so it takes
1175  * us two intervals to determine that a tag must be sent.
1176  */
1177 #ifndef DA_ORDEREDTAG_INTERVAL
1178 #define DA_ORDEREDTAG_INTERVAL 4
1179 #endif
1180 
1181 static struct periph_driver dadriver =
1182 {
1183 	dainit, "da",
1184 	TAILQ_HEAD_INITIALIZER(dadriver.units), /* generation */ 0
1185 };
1186 
1187 PERIPHDRIVER_DECLARE(da, dadriver);
1188 
1189 static MALLOC_DEFINE(M_SCSIDA, "scsi_da", "scsi_da buffers");
1190 
1191 static int
1192 daopen(struct disk *dp)
1193 {
1194 	struct cam_periph *periph;
1195 	struct da_softc *softc;
1196 	int error;
1197 
1198 	periph = (struct cam_periph *)dp->d_drv1;
1199 	if (cam_periph_acquire(periph) != CAM_REQ_CMP) {
1200 		return (ENXIO);
1201 	}
1202 
1203 	cam_periph_lock(periph);
1204 	if ((error = cam_periph_hold(periph, PRIBIO|PCATCH)) != 0) {
1205 		cam_periph_unlock(periph);
1206 		cam_periph_release(periph);
1207 		return (error);
1208 	}
1209 
1210 	CAM_DEBUG(periph->path, CAM_DEBUG_TRACE | CAM_DEBUG_PERIPH,
1211 	    ("daopen\n"));
1212 
1213 	softc = (struct da_softc *)periph->softc;
1214 	dareprobe(periph);
1215 
1216 	/* Wait for the disk size update.  */
1217 	error = cam_periph_sleep(periph, &softc->disk->d_mediasize, PRIBIO,
1218 	    "dareprobe", 0);
1219 	if (error != 0)
1220 		xpt_print(periph->path, "unable to retrieve capacity data");
1221 
1222 	if (periph->flags & CAM_PERIPH_INVALID)
1223 		error = ENXIO;
1224 
1225 	if (error == 0 && (softc->flags & DA_FLAG_PACK_REMOVABLE) != 0 &&
1226 	    (softc->quirks & DA_Q_NO_PREVENT) == 0)
1227 		daprevent(periph, PR_PREVENT);
1228 
1229 	if (error == 0) {
1230 		softc->flags &= ~DA_FLAG_PACK_INVALID;
1231 		softc->flags |= DA_FLAG_OPEN;
1232 	}
1233 
1234 	cam_periph_unhold(periph);
1235 	cam_periph_unlock(periph);
1236 
1237 	if (error != 0)
1238 		cam_periph_release(periph);
1239 
1240 	return (error);
1241 }
1242 
1243 static int
1244 daclose(struct disk *dp)
1245 {
1246 	struct	cam_periph *periph;
1247 	struct	da_softc *softc;
1248 	int error;
1249 
1250 	periph = (struct cam_periph *)dp->d_drv1;
1251 	cam_periph_lock(periph);
1252 	if (cam_periph_hold(periph, PRIBIO) != 0) {
1253 		cam_periph_unlock(periph);
1254 		cam_periph_release(periph);
1255 		return (0);
1256 	}
1257 
1258 	softc = (struct da_softc *)periph->softc;
1259 
1260 	CAM_DEBUG(periph->path, CAM_DEBUG_TRACE | CAM_DEBUG_PERIPH,
1261 	    ("daclose\n"));
1262 
1263 	if ((softc->flags & DA_FLAG_DIRTY) != 0 &&
1264 	    (softc->quirks & DA_Q_NO_SYNC_CACHE) == 0 &&
1265 	    (softc->flags & DA_FLAG_PACK_INVALID) == 0) {
1266 		union	ccb *ccb;
1267 
1268 		ccb = cam_periph_getccb(periph, CAM_PRIORITY_NORMAL);
1269 
1270 		scsi_synchronize_cache(&ccb->csio,
1271 				       /*retries*/1,
1272 				       /*cbfcnp*/dadone,
1273 				       MSG_SIMPLE_Q_TAG,
1274 				       /*begin_lba*/0,/* Cover the whole disk */
1275 				       /*lb_count*/0,
1276 				       SSD_FULL_SIZE,
1277 				       5 * 60 * 1000);
1278 
1279 		error = cam_periph_runccb(ccb, daerror, /*cam_flags*/0,
1280 				  /*sense_flags*/SF_RETRY_UA | SF_QUIET_IR,
1281 				  softc->disk->d_devstat);
1282 		if (error == 0)
1283 			softc->flags &= ~DA_FLAG_DIRTY;
1284 		xpt_release_ccb(ccb);
1285 
1286 	}
1287 
1288 	if ((softc->flags & DA_FLAG_PACK_REMOVABLE) != 0) {
1289 		if ((softc->quirks & DA_Q_NO_PREVENT) == 0)
1290 			daprevent(periph, PR_ALLOW);
1291 		/*
1292 		 * If we've got removeable media, mark the blocksize as
1293 		 * unavailable, since it could change when new media is
1294 		 * inserted.
1295 		 */
1296 		softc->disk->d_devstat->flags |= DEVSTAT_BS_UNAVAILABLE;
1297 	}
1298 
1299 	softc->flags &= ~DA_FLAG_OPEN;
1300 	cam_periph_unhold(periph);
1301 	cam_periph_unlock(periph);
1302 	cam_periph_release(periph);
1303 	return (0);
1304 }
1305 
1306 static void
1307 daschedule(struct cam_periph *periph)
1308 {
1309 	struct da_softc *softc = (struct da_softc *)periph->softc;
1310 	uint32_t prio;
1311 
1312 	if (softc->state != DA_STATE_NORMAL)
1313 		return;
1314 
1315 	/* Check if cam_periph_getccb() was called. */
1316 	prio = periph->immediate_priority;
1317 
1318 	/* Check if we have more work to do. */
1319 	if (bioq_first(&softc->bio_queue) ||
1320 	    (!softc->delete_running && bioq_first(&softc->delete_queue)) ||
1321 	    softc->tur) {
1322 		prio = CAM_PRIORITY_NORMAL;
1323 	}
1324 
1325 	/* Schedule CCB if any of above is true. */
1326 	if (prio != CAM_PRIORITY_NONE)
1327 		xpt_schedule(periph, prio);
1328 }
1329 
1330 /*
1331  * Actually translate the requested transfer into one the physical driver
1332  * can understand.  The transfer is described by a buf and will include
1333  * only one physical transfer.
1334  */
1335 static void
1336 dastrategy(struct bio *bp)
1337 {
1338 	struct cam_periph *periph;
1339 	struct da_softc *softc;
1340 
1341 	periph = (struct cam_periph *)bp->bio_disk->d_drv1;
1342 	softc = (struct da_softc *)periph->softc;
1343 
1344 	cam_periph_lock(periph);
1345 
1346 	/*
1347 	 * If the device has been made invalid, error out
1348 	 */
1349 	if ((softc->flags & DA_FLAG_PACK_INVALID)) {
1350 		cam_periph_unlock(periph);
1351 		biofinish(bp, NULL, ENXIO);
1352 		return;
1353 	}
1354 
1355 	CAM_DEBUG(periph->path, CAM_DEBUG_TRACE, ("dastrategy(%p)\n", bp));
1356 
1357 	/*
1358 	 * Place it in the queue of disk activities for this disk
1359 	 */
1360 	if (bp->bio_cmd == BIO_DELETE) {
1361 		if (bp->bio_bcount == 0)
1362 			biodone(bp);
1363 		else if (DA_SIO)
1364 			bioq_disksort(&softc->delete_queue, bp);
1365 		else
1366 			bioq_insert_tail(&softc->delete_queue, bp);
1367 	} else if (DA_SIO) {
1368 		bioq_disksort(&softc->bio_queue, bp);
1369 	} else {
1370 		bioq_insert_tail(&softc->bio_queue, bp);
1371 	}
1372 
1373 	/*
1374 	 * Schedule ourselves for performing the work.
1375 	 */
1376 	daschedule(periph);
1377 	cam_periph_unlock(periph);
1378 
1379 	return;
1380 }
1381 
1382 static int
1383 dadump(void *arg, void *virtual, vm_offset_t physical, off_t offset, size_t length)
1384 {
1385 	struct	    cam_periph *periph;
1386 	struct	    da_softc *softc;
1387 	u_int	    secsize;
1388 	struct	    ccb_scsiio csio;
1389 	struct	    disk *dp;
1390 	int	    error = 0;
1391 
1392 	dp = arg;
1393 	periph = dp->d_drv1;
1394 	softc = (struct da_softc *)periph->softc;
1395 	cam_periph_lock(periph);
1396 	secsize = softc->params.secsize;
1397 
1398 	if ((softc->flags & DA_FLAG_PACK_INVALID) != 0) {
1399 		cam_periph_unlock(periph);
1400 		return (ENXIO);
1401 	}
1402 
1403 	if (length > 0) {
1404 		xpt_setup_ccb(&csio.ccb_h, periph->path, CAM_PRIORITY_NORMAL);
1405 		csio.ccb_h.ccb_state = DA_CCB_DUMP;
1406 		scsi_read_write(&csio,
1407 				/*retries*/0,
1408 				dadone,
1409 				MSG_ORDERED_Q_TAG,
1410 				/*read*/SCSI_RW_WRITE,
1411 				/*byte2*/0,
1412 				/*minimum_cmd_size*/ softc->minimum_cmd_size,
1413 				offset / secsize,
1414 				length / secsize,
1415 				/*data_ptr*/(u_int8_t *) virtual,
1416 				/*dxfer_len*/length,
1417 				/*sense_len*/SSD_FULL_SIZE,
1418 				da_default_timeout * 1000);
1419 		xpt_polled_action((union ccb *)&csio);
1420 
1421 		error = cam_periph_error((union ccb *)&csio,
1422 		    0, SF_NO_RECOVERY | SF_NO_RETRY, NULL);
1423 		if ((csio.ccb_h.status & CAM_DEV_QFRZN) != 0)
1424 			cam_release_devq(csio.ccb_h.path, /*relsim_flags*/0,
1425 			    /*reduction*/0, /*timeout*/0, /*getcount_only*/0);
1426 		if (error != 0)
1427 			printf("Aborting dump due to I/O error.\n");
1428 		cam_periph_unlock(periph);
1429 		return (error);
1430 	}
1431 
1432 	/*
1433 	 * Sync the disk cache contents to the physical media.
1434 	 */
1435 	if ((softc->quirks & DA_Q_NO_SYNC_CACHE) == 0) {
1436 
1437 		xpt_setup_ccb(&csio.ccb_h, periph->path, CAM_PRIORITY_NORMAL);
1438 		csio.ccb_h.ccb_state = DA_CCB_DUMP;
1439 		scsi_synchronize_cache(&csio,
1440 				       /*retries*/0,
1441 				       /*cbfcnp*/dadone,
1442 				       MSG_SIMPLE_Q_TAG,
1443 				       /*begin_lba*/0,/* Cover the whole disk */
1444 				       /*lb_count*/0,
1445 				       SSD_FULL_SIZE,
1446 				       5 * 60 * 1000);
1447 		xpt_polled_action((union ccb *)&csio);
1448 
1449 		error = cam_periph_error((union ccb *)&csio,
1450 		    0, SF_NO_RECOVERY | SF_NO_RETRY | SF_QUIET_IR, NULL);
1451 		if ((csio.ccb_h.status & CAM_DEV_QFRZN) != 0)
1452 			cam_release_devq(csio.ccb_h.path, /*relsim_flags*/0,
1453 			    /*reduction*/0, /*timeout*/0, /*getcount_only*/0);
1454 		if (error != 0)
1455 			xpt_print(periph->path, "Synchronize cache failed\n");
1456 	}
1457 	cam_periph_unlock(periph);
1458 	return (error);
1459 }
1460 
1461 static int
1462 dagetattr(struct bio *bp)
1463 {
1464 	int ret;
1465 	struct cam_periph *periph;
1466 
1467 	periph = (struct cam_periph *)bp->bio_disk->d_drv1;
1468 	cam_periph_lock(periph);
1469 	ret = xpt_getattr(bp->bio_data, bp->bio_length, bp->bio_attribute,
1470 	    periph->path);
1471 	cam_periph_unlock(periph);
1472 	if (ret == 0)
1473 		bp->bio_completed = bp->bio_length;
1474 	return ret;
1475 }
1476 
1477 static void
1478 dainit(void)
1479 {
1480 	cam_status status;
1481 
1482 	/*
1483 	 * Install a global async callback.  This callback will
1484 	 * receive async callbacks like "new device found".
1485 	 */
1486 	status = xpt_register_async(AC_FOUND_DEVICE, daasync, NULL, NULL);
1487 
1488 	if (status != CAM_REQ_CMP) {
1489 		printf("da: Failed to attach master async callback "
1490 		       "due to status 0x%x!\n", status);
1491 	} else if (da_send_ordered) {
1492 
1493 		/* Register our shutdown event handler */
1494 		if ((EVENTHANDLER_REGISTER(shutdown_post_sync, dashutdown,
1495 					   NULL, SHUTDOWN_PRI_DEFAULT)) == NULL)
1496 		    printf("dainit: shutdown event registration failed!\n");
1497 	}
1498 }
1499 
1500 /*
1501  * Callback from GEOM, called when it has finished cleaning up its
1502  * resources.
1503  */
1504 static void
1505 dadiskgonecb(struct disk *dp)
1506 {
1507 	struct cam_periph *periph;
1508 
1509 	periph = (struct cam_periph *)dp->d_drv1;
1510 	cam_periph_release(periph);
1511 }
1512 
1513 static void
1514 daoninvalidate(struct cam_periph *periph)
1515 {
1516 	struct da_softc *softc;
1517 
1518 	softc = (struct da_softc *)periph->softc;
1519 
1520 	/*
1521 	 * De-register any async callbacks.
1522 	 */
1523 	xpt_register_async(0, daasync, periph, periph->path);
1524 
1525 	softc->flags |= DA_FLAG_PACK_INVALID;
1526 
1527 	/*
1528 	 * Return all queued I/O with ENXIO.
1529 	 * XXX Handle any transactions queued to the card
1530 	 *     with XPT_ABORT_CCB.
1531 	 */
1532 	bioq_flush(&softc->bio_queue, NULL, ENXIO);
1533 	bioq_flush(&softc->delete_queue, NULL, ENXIO);
1534 
1535 	/*
1536 	 * Tell GEOM that we've gone away, we'll get a callback when it is
1537 	 * done cleaning up its resources.
1538 	 */
1539 	disk_gone(softc->disk);
1540 
1541 	xpt_print(periph->path, "lost device - %d outstanding, %d refs\n",
1542 		  softc->outstanding_cmds, periph->refcount);
1543 }
1544 
1545 static void
1546 dacleanup(struct cam_periph *periph)
1547 {
1548 	struct da_softc *softc;
1549 
1550 	softc = (struct da_softc *)periph->softc;
1551 
1552 	xpt_print(periph->path, "removing device entry\n");
1553 	cam_periph_unlock(periph);
1554 
1555 	/*
1556 	 * If we can't free the sysctl tree, oh well...
1557 	 */
1558 	if ((softc->flags & DA_FLAG_SCTX_INIT) != 0
1559 	    && sysctl_ctx_free(&softc->sysctl_ctx) != 0) {
1560 		xpt_print(periph->path, "can't remove sysctl context\n");
1561 	}
1562 
1563 	callout_drain(&softc->mediapoll_c);
1564 	disk_destroy(softc->disk);
1565 	callout_drain(&softc->sendordered_c);
1566 	free(softc, M_DEVBUF);
1567 	cam_periph_lock(periph);
1568 }
1569 
1570 static void
1571 daasync(void *callback_arg, u_int32_t code,
1572 	struct cam_path *path, void *arg)
1573 {
1574 	struct cam_periph *periph;
1575 	struct da_softc *softc;
1576 
1577 	periph = (struct cam_periph *)callback_arg;
1578 	switch (code) {
1579 	case AC_FOUND_DEVICE:
1580 	{
1581 		struct ccb_getdev *cgd;
1582 		cam_status status;
1583 
1584 		cgd = (struct ccb_getdev *)arg;
1585 		if (cgd == NULL)
1586 			break;
1587 
1588 		if (cgd->protocol != PROTO_SCSI)
1589 			break;
1590 
1591 		if (SID_TYPE(&cgd->inq_data) != T_DIRECT
1592 		    && SID_TYPE(&cgd->inq_data) != T_RBC
1593 		    && SID_TYPE(&cgd->inq_data) != T_OPTICAL)
1594 			break;
1595 
1596 		/*
1597 		 * Allocate a peripheral instance for
1598 		 * this device and start the probe
1599 		 * process.
1600 		 */
1601 		status = cam_periph_alloc(daregister, daoninvalidate,
1602 					  dacleanup, dastart,
1603 					  "da", CAM_PERIPH_BIO,
1604 					  cgd->ccb_h.path, daasync,
1605 					  AC_FOUND_DEVICE, cgd);
1606 
1607 		if (status != CAM_REQ_CMP
1608 		 && status != CAM_REQ_INPROG)
1609 			printf("daasync: Unable to attach to new device "
1610 				"due to status 0x%x\n", status);
1611 		return;
1612 	}
1613 	case AC_ADVINFO_CHANGED:
1614 	{
1615 		uintptr_t buftype;
1616 
1617 		buftype = (uintptr_t)arg;
1618 		if (buftype == CDAI_TYPE_PHYS_PATH) {
1619 			struct da_softc *softc;
1620 
1621 			softc = periph->softc;
1622 			disk_attr_changed(softc->disk, "GEOM::physpath",
1623 					  M_NOWAIT);
1624 		}
1625 		break;
1626 	}
1627 	case AC_UNIT_ATTENTION:
1628 	{
1629 		union ccb *ccb;
1630 		int error_code, sense_key, asc, ascq;
1631 
1632 		softc = (struct da_softc *)periph->softc;
1633 		ccb = (union ccb *)arg;
1634 
1635 		/*
1636 		 * Handle all UNIT ATTENTIONs except our own,
1637 		 * as they will be handled by daerror().
1638 		 */
1639 		if (xpt_path_periph(ccb->ccb_h.path) != periph &&
1640 		    scsi_extract_sense_ccb(ccb,
1641 		     &error_code, &sense_key, &asc, &ascq)) {
1642 			if (asc == 0x2A && ascq == 0x09) {
1643 				xpt_print(ccb->ccb_h.path,
1644 				    "capacity data has changed\n");
1645 				dareprobe(periph);
1646 			} else if (asc == 0x28 && ascq == 0x00)
1647 				disk_media_changed(softc->disk, M_NOWAIT);
1648 		}
1649 		cam_periph_async(periph, code, path, arg);
1650 		break;
1651 	}
1652 	case AC_SCSI_AEN:
1653 		softc = (struct da_softc *)periph->softc;
1654 		if (!softc->tur) {
1655 			if (cam_periph_acquire(periph) == CAM_REQ_CMP) {
1656 				softc->tur = 1;
1657 				daschedule(periph);
1658 			}
1659 		}
1660 		/* FALLTHROUGH */
1661 	case AC_SENT_BDR:
1662 	case AC_BUS_RESET:
1663 	{
1664 		struct ccb_hdr *ccbh;
1665 
1666 		softc = (struct da_softc *)periph->softc;
1667 		/*
1668 		 * Don't fail on the expected unit attention
1669 		 * that will occur.
1670 		 */
1671 		softc->flags |= DA_FLAG_RETRY_UA;
1672 		LIST_FOREACH(ccbh, &softc->pending_ccbs, periph_links.le)
1673 			ccbh->ccb_state |= DA_CCB_RETRY_UA;
1674 		break;
1675 	}
1676 	default:
1677 		break;
1678 	}
1679 	cam_periph_async(periph, code, path, arg);
1680 }
1681 
1682 static void
1683 dasysctlinit(void *context, int pending)
1684 {
1685 	struct cam_periph *periph;
1686 	struct da_softc *softc;
1687 	char tmpstr[80], tmpstr2[80];
1688 	struct ccb_trans_settings cts;
1689 
1690 	periph = (struct cam_periph *)context;
1691 	/*
1692 	 * periph was held for us when this task was enqueued
1693 	 */
1694 	if (periph->flags & CAM_PERIPH_INVALID) {
1695 		cam_periph_release(periph);
1696 		return;
1697 	}
1698 
1699 	softc = (struct da_softc *)periph->softc;
1700 	snprintf(tmpstr, sizeof(tmpstr), "CAM DA unit %d", periph->unit_number);
1701 	snprintf(tmpstr2, sizeof(tmpstr2), "%d", periph->unit_number);
1702 
1703 	sysctl_ctx_init(&softc->sysctl_ctx);
1704 	softc->flags |= DA_FLAG_SCTX_INIT;
1705 	softc->sysctl_tree = SYSCTL_ADD_NODE(&softc->sysctl_ctx,
1706 		SYSCTL_STATIC_CHILDREN(_kern_cam_da), OID_AUTO, tmpstr2,
1707 		CTLFLAG_RD, 0, tmpstr);
1708 	if (softc->sysctl_tree == NULL) {
1709 		printf("dasysctlinit: unable to allocate sysctl tree\n");
1710 		cam_periph_release(periph);
1711 		return;
1712 	}
1713 
1714 	/*
1715 	 * Now register the sysctl handler, so the user can change the value on
1716 	 * the fly.
1717 	 */
1718 	SYSCTL_ADD_PROC(&softc->sysctl_ctx, SYSCTL_CHILDREN(softc->sysctl_tree),
1719 		OID_AUTO, "delete_method", CTLTYPE_STRING | CTLFLAG_RW,
1720 		softc, 0, dadeletemethodsysctl, "A",
1721 		"BIO_DELETE execution method");
1722 	SYSCTL_ADD_PROC(&softc->sysctl_ctx, SYSCTL_CHILDREN(softc->sysctl_tree),
1723 		OID_AUTO, "delete_max", CTLTYPE_U64 | CTLFLAG_RW,
1724 		softc, 0, dadeletemaxsysctl, "Q",
1725 		"Maximum BIO_DELETE size");
1726 	SYSCTL_ADD_PROC(&softc->sysctl_ctx, SYSCTL_CHILDREN(softc->sysctl_tree),
1727 		OID_AUTO, "minimum_cmd_size", CTLTYPE_INT | CTLFLAG_RW,
1728 		&softc->minimum_cmd_size, 0, dacmdsizesysctl, "I",
1729 		"Minimum CDB size");
1730 	SYSCTL_ADD_INT(&softc->sysctl_ctx, SYSCTL_CHILDREN(softc->sysctl_tree),
1731 		OID_AUTO, "sort_io_queue", CTLFLAG_RW, &softc->sort_io_queue, 0,
1732 		"Sort IO queue to try and optimise disk access patterns");
1733 
1734 	SYSCTL_ADD_INT(&softc->sysctl_ctx,
1735 		       SYSCTL_CHILDREN(softc->sysctl_tree),
1736 		       OID_AUTO,
1737 		       "error_inject",
1738 		       CTLFLAG_RW,
1739 		       &softc->error_inject,
1740 		       0,
1741 		       "error_inject leaf");
1742 
1743 
1744 	/*
1745 	 * Add some addressing info.
1746 	 */
1747 	memset(&cts, 0, sizeof (cts));
1748 	xpt_setup_ccb(&cts.ccb_h, periph->path, CAM_PRIORITY_NONE);
1749 	cts.ccb_h.func_code = XPT_GET_TRAN_SETTINGS;
1750 	cts.type = CTS_TYPE_CURRENT_SETTINGS;
1751 	cam_periph_lock(periph);
1752 	xpt_action((union ccb *)&cts);
1753 	cam_periph_unlock(periph);
1754 	if (cts.ccb_h.status != CAM_REQ_CMP) {
1755 		cam_periph_release(periph);
1756 		return;
1757 	}
1758 	if (cts.protocol == PROTO_SCSI && cts.transport == XPORT_FC) {
1759 		struct ccb_trans_settings_fc *fc = &cts.xport_specific.fc;
1760 		if (fc->valid & CTS_FC_VALID_WWPN) {
1761 			softc->wwpn = fc->wwpn;
1762 			SYSCTL_ADD_UQUAD(&softc->sysctl_ctx,
1763 			    SYSCTL_CHILDREN(softc->sysctl_tree),
1764 			    OID_AUTO, "wwpn", CTLFLAG_RD,
1765 			    &softc->wwpn, "World Wide Port Name");
1766 		}
1767 	}
1768 	cam_periph_release(periph);
1769 }
1770 
1771 static int
1772 dadeletemaxsysctl(SYSCTL_HANDLER_ARGS)
1773 {
1774 	int error;
1775 	uint64_t value;
1776 	struct da_softc *softc;
1777 
1778 	softc = (struct da_softc *)arg1;
1779 
1780 	value = softc->disk->d_delmaxsize;
1781 	error = sysctl_handle_64(oidp, &value, 0, req);
1782 	if ((error != 0) || (req->newptr == NULL))
1783 		return (error);
1784 
1785 	/* only accept values smaller than the calculated value */
1786 	if (value > dadeletemaxsize(softc, softc->delete_method)) {
1787 		return (EINVAL);
1788 	}
1789 	softc->disk->d_delmaxsize = value;
1790 
1791 	return (0);
1792 }
1793 
1794 static int
1795 dacmdsizesysctl(SYSCTL_HANDLER_ARGS)
1796 {
1797 	int error, value;
1798 
1799 	value = *(int *)arg1;
1800 
1801 	error = sysctl_handle_int(oidp, &value, 0, req);
1802 
1803 	if ((error != 0)
1804 	 || (req->newptr == NULL))
1805 		return (error);
1806 
1807 	/*
1808 	 * Acceptable values here are 6, 10, 12 or 16.
1809 	 */
1810 	if (value < 6)
1811 		value = 6;
1812 	else if ((value > 6)
1813 	      && (value <= 10))
1814 		value = 10;
1815 	else if ((value > 10)
1816 	      && (value <= 12))
1817 		value = 12;
1818 	else if (value > 12)
1819 		value = 16;
1820 
1821 	*(int *)arg1 = value;
1822 
1823 	return (0);
1824 }
1825 
1826 static void
1827 dadeletemethodset(struct da_softc *softc, da_delete_methods delete_method)
1828 {
1829 
1830 
1831 	softc->delete_method = delete_method;
1832 	softc->disk->d_delmaxsize = dadeletemaxsize(softc, delete_method);
1833 	softc->delete_func = da_delete_functions[delete_method];
1834 
1835 	if (softc->delete_method > DA_DELETE_DISABLE)
1836 		softc->disk->d_flags |= DISKFLAG_CANDELETE;
1837 	else
1838 		softc->disk->d_flags &= ~DISKFLAG_CANDELETE;
1839 }
1840 
1841 static off_t
1842 dadeletemaxsize(struct da_softc *softc, da_delete_methods delete_method)
1843 {
1844 	off_t sectors;
1845 
1846 	switch(delete_method) {
1847 	case DA_DELETE_UNMAP:
1848 		sectors = (off_t)softc->unmap_max_lba * softc->unmap_max_ranges;
1849 		break;
1850 	case DA_DELETE_ATA_TRIM:
1851 		sectors = (off_t)ATA_DSM_RANGE_MAX * softc->trim_max_ranges;
1852 		break;
1853 	case DA_DELETE_WS16:
1854 		sectors = (off_t)min(softc->ws_max_blks, WS16_MAX_BLKS);
1855 		break;
1856 	case DA_DELETE_ZERO:
1857 	case DA_DELETE_WS10:
1858 		sectors = (off_t)min(softc->ws_max_blks, WS10_MAX_BLKS);
1859 		break;
1860 	default:
1861 		return 0;
1862 	}
1863 
1864 	return (off_t)softc->params.secsize *
1865 	    min(sectors, (off_t)softc->params.sectors);
1866 }
1867 
1868 static void
1869 daprobedone(struct cam_periph *periph, union ccb *ccb)
1870 {
1871 	struct da_softc *softc;
1872 
1873 	softc = (struct da_softc *)periph->softc;
1874 
1875 	dadeletemethodchoose(softc, DA_DELETE_NONE);
1876 
1877 	if (bootverbose && (softc->flags & DA_FLAG_PROBED) == 0) {
1878 		char buf[80];
1879 		int i, sep;
1880 
1881 		snprintf(buf, sizeof(buf), "Delete methods: <");
1882 		sep = 0;
1883 		for (i = DA_DELETE_MIN; i <= DA_DELETE_MAX; i++) {
1884 			if (softc->delete_available & (1 << i)) {
1885 				if (sep) {
1886 					strlcat(buf, ",", sizeof(buf));
1887 				} else {
1888 				    sep = 1;
1889 				}
1890 				strlcat(buf, da_delete_method_names[i],
1891 				    sizeof(buf));
1892 				if (i == softc->delete_method) {
1893 					strlcat(buf, "(*)", sizeof(buf));
1894 				}
1895 			}
1896 		}
1897 		if (sep == 0) {
1898 			if (softc->delete_method == DA_DELETE_NONE)
1899 				strlcat(buf, "NONE(*)", sizeof(buf));
1900 			else
1901 				strlcat(buf, "DISABLED(*)", sizeof(buf));
1902 		}
1903 		strlcat(buf, ">", sizeof(buf));
1904 		printf("%s%d: %s\n", periph->periph_name,
1905 		    periph->unit_number, buf);
1906 	}
1907 
1908 	/*
1909 	 * Since our peripheral may be invalidated by an error
1910 	 * above or an external event, we must release our CCB
1911 	 * before releasing the probe lock on the peripheral.
1912 	 * The peripheral will only go away once the last lock
1913 	 * is removed, and we need it around for the CCB release
1914 	 * operation.
1915 	 */
1916 	xpt_release_ccb(ccb);
1917 	softc->state = DA_STATE_NORMAL;
1918 	daschedule(periph);
1919 	wakeup(&softc->disk->d_mediasize);
1920 	if ((softc->flags & DA_FLAG_PROBED) == 0) {
1921 		softc->flags |= DA_FLAG_PROBED;
1922 		cam_periph_unhold(periph);
1923 	} else
1924 		cam_periph_release_locked(periph);
1925 }
1926 
1927 static void
1928 dadeletemethodchoose(struct da_softc *softc, da_delete_methods default_method)
1929 {
1930 	int i, delete_method;
1931 
1932 	delete_method = default_method;
1933 
1934 	/*
1935 	 * Use the pre-defined order to choose the best
1936 	 * performing delete.
1937 	 */
1938 	for (i = DA_DELETE_MIN; i <= DA_DELETE_MAX; i++) {
1939 		if (softc->delete_available & (1 << i)) {
1940 			dadeletemethodset(softc, i);
1941 			return;
1942 		}
1943 	}
1944 	dadeletemethodset(softc, delete_method);
1945 }
1946 
1947 static int
1948 dadeletemethodsysctl(SYSCTL_HANDLER_ARGS)
1949 {
1950 	char buf[16];
1951 	const char *p;
1952 	struct da_softc *softc;
1953 	int i, error, value;
1954 
1955 	softc = (struct da_softc *)arg1;
1956 
1957 	value = softc->delete_method;
1958 	if (value < 0 || value > DA_DELETE_MAX)
1959 		p = "UNKNOWN";
1960 	else
1961 		p = da_delete_method_names[value];
1962 	strncpy(buf, p, sizeof(buf));
1963 	error = sysctl_handle_string(oidp, buf, sizeof(buf), req);
1964 	if (error != 0 || req->newptr == NULL)
1965 		return (error);
1966 	for (i = 0; i <= DA_DELETE_MAX; i++) {
1967 		if (!(softc->delete_available & (1 << i)) ||
1968 		    strcmp(buf, da_delete_method_names[i]) != 0)
1969 			continue;
1970 		dadeletemethodset(softc, i);
1971 		return (0);
1972 	}
1973 	return (EINVAL);
1974 }
1975 
1976 static cam_status
1977 daregister(struct cam_periph *periph, void *arg)
1978 {
1979 	struct da_softc *softc;
1980 	struct ccb_pathinq cpi;
1981 	struct ccb_getdev *cgd;
1982 	char tmpstr[80];
1983 	caddr_t match;
1984 
1985 	cgd = (struct ccb_getdev *)arg;
1986 	if (cgd == NULL) {
1987 		printf("daregister: no getdev CCB, can't register device\n");
1988 		return(CAM_REQ_CMP_ERR);
1989 	}
1990 
1991 	softc = (struct da_softc *)malloc(sizeof(*softc), M_DEVBUF,
1992 	    M_NOWAIT|M_ZERO);
1993 
1994 	if (softc == NULL) {
1995 		printf("daregister: Unable to probe new device. "
1996 		       "Unable to allocate softc\n");
1997 		return(CAM_REQ_CMP_ERR);
1998 	}
1999 
2000 	LIST_INIT(&softc->pending_ccbs);
2001 	softc->state = DA_STATE_PROBE_RC;
2002 	bioq_init(&softc->bio_queue);
2003 	bioq_init(&softc->delete_queue);
2004 	bioq_init(&softc->delete_run_queue);
2005 	if (SID_IS_REMOVABLE(&cgd->inq_data))
2006 		softc->flags |= DA_FLAG_PACK_REMOVABLE;
2007 	softc->unmap_max_ranges = UNMAP_MAX_RANGES;
2008 	softc->unmap_max_lba = UNMAP_RANGE_MAX;
2009 	softc->ws_max_blks = WS16_MAX_BLKS;
2010 	softc->trim_max_ranges = ATA_TRIM_MAX_RANGES;
2011 	softc->sort_io_queue = -1;
2012 
2013 	periph->softc = softc;
2014 
2015 	/*
2016 	 * See if this device has any quirks.
2017 	 */
2018 	match = cam_quirkmatch((caddr_t)&cgd->inq_data,
2019 			       (caddr_t)da_quirk_table,
2020 			       sizeof(da_quirk_table)/sizeof(*da_quirk_table),
2021 			       sizeof(*da_quirk_table), scsi_inquiry_match);
2022 
2023 	if (match != NULL)
2024 		softc->quirks = ((struct da_quirk_entry *)match)->quirks;
2025 	else
2026 		softc->quirks = DA_Q_NONE;
2027 
2028 	/* Check if the SIM does not want 6 byte commands */
2029 	bzero(&cpi, sizeof(cpi));
2030 	xpt_setup_ccb(&cpi.ccb_h, periph->path, CAM_PRIORITY_NORMAL);
2031 	cpi.ccb_h.func_code = XPT_PATH_INQ;
2032 	xpt_action((union ccb *)&cpi);
2033 	if (cpi.ccb_h.status == CAM_REQ_CMP && (cpi.hba_misc & PIM_NO_6_BYTE))
2034 		softc->quirks |= DA_Q_NO_6_BYTE;
2035 
2036 	TASK_INIT(&softc->sysctl_task, 0, dasysctlinit, periph);
2037 
2038 	/*
2039 	 * Take an exclusive refcount on the periph while dastart is called
2040 	 * to finish the probe.  The reference will be dropped in dadone at
2041 	 * the end of probe.
2042 	 */
2043 	(void)cam_periph_hold(periph, PRIBIO);
2044 
2045 	/*
2046 	 * Schedule a periodic event to occasionally send an
2047 	 * ordered tag to a device.
2048 	 */
2049 	callout_init_mtx(&softc->sendordered_c, periph->sim->mtx, 0);
2050 	callout_reset(&softc->sendordered_c,
2051 	    (da_default_timeout * hz) / DA_ORDEREDTAG_INTERVAL,
2052 	    dasendorderedtag, softc);
2053 
2054 	cam_periph_unlock(periph);
2055 	/*
2056 	 * RBC devices don't have to support READ(6), only READ(10).
2057 	 */
2058 	if (softc->quirks & DA_Q_NO_6_BYTE || SID_TYPE(&cgd->inq_data) == T_RBC)
2059 		softc->minimum_cmd_size = 10;
2060 	else
2061 		softc->minimum_cmd_size = 6;
2062 
2063 	/*
2064 	 * Load the user's default, if any.
2065 	 */
2066 	snprintf(tmpstr, sizeof(tmpstr), "kern.cam.da.%d.minimum_cmd_size",
2067 		 periph->unit_number);
2068 	TUNABLE_INT_FETCH(tmpstr, &softc->minimum_cmd_size);
2069 
2070 	/*
2071 	 * 6, 10, 12 and 16 are the currently permissible values.
2072 	 */
2073 	if (softc->minimum_cmd_size < 6)
2074 		softc->minimum_cmd_size = 6;
2075 	else if ((softc->minimum_cmd_size > 6)
2076 	      && (softc->minimum_cmd_size <= 10))
2077 		softc->minimum_cmd_size = 10;
2078 	else if ((softc->minimum_cmd_size > 10)
2079 	      && (softc->minimum_cmd_size <= 12))
2080 		softc->minimum_cmd_size = 12;
2081 	else if (softc->minimum_cmd_size > 12)
2082 		softc->minimum_cmd_size = 16;
2083 
2084 	/* Predict whether device may support READ CAPACITY(16). */
2085 	if (SID_ANSI_REV(&cgd->inq_data) >= SCSI_REV_SPC3 &&
2086 	    (softc->quirks & DA_Q_NO_RC16) == 0) {
2087 		softc->flags |= DA_FLAG_CAN_RC16;
2088 		softc->state = DA_STATE_PROBE_RC16;
2089 	}
2090 
2091 	/*
2092 	 * Register this media as a disk.
2093 	 */
2094 	softc->disk = disk_alloc();
2095 	softc->disk->d_devstat = devstat_new_entry(periph->periph_name,
2096 			  periph->unit_number, 0,
2097 			  DEVSTAT_BS_UNAVAILABLE,
2098 			  SID_TYPE(&cgd->inq_data) |
2099 			  XPORT_DEVSTAT_TYPE(cpi.transport),
2100 			  DEVSTAT_PRIORITY_DISK);
2101 	softc->disk->d_open = daopen;
2102 	softc->disk->d_close = daclose;
2103 	softc->disk->d_strategy = dastrategy;
2104 	softc->disk->d_dump = dadump;
2105 	softc->disk->d_getattr = dagetattr;
2106 	softc->disk->d_gone = dadiskgonecb;
2107 	softc->disk->d_name = "da";
2108 	softc->disk->d_drv1 = periph;
2109 	if (cpi.maxio == 0)
2110 		softc->disk->d_maxsize = DFLTPHYS;	/* traditional default */
2111 	else if (cpi.maxio > MAXPHYS)
2112 		softc->disk->d_maxsize = MAXPHYS;	/* for safety */
2113 	else
2114 		softc->disk->d_maxsize = cpi.maxio;
2115 	softc->disk->d_unit = periph->unit_number;
2116 	softc->disk->d_flags = 0;
2117 	if ((softc->quirks & DA_Q_NO_SYNC_CACHE) == 0)
2118 		softc->disk->d_flags |= DISKFLAG_CANFLUSHCACHE;
2119 	if ((cpi.hba_misc & PIM_UNMAPPED) != 0)
2120 		softc->disk->d_flags |= DISKFLAG_UNMAPPED_BIO;
2121 	cam_strvis(softc->disk->d_descr, cgd->inq_data.vendor,
2122 	    sizeof(cgd->inq_data.vendor), sizeof(softc->disk->d_descr));
2123 	strlcat(softc->disk->d_descr, " ", sizeof(softc->disk->d_descr));
2124 	cam_strvis(&softc->disk->d_descr[strlen(softc->disk->d_descr)],
2125 	    cgd->inq_data.product, sizeof(cgd->inq_data.product),
2126 	    sizeof(softc->disk->d_descr) - strlen(softc->disk->d_descr));
2127 	softc->disk->d_hba_vendor = cpi.hba_vendor;
2128 	softc->disk->d_hba_device = cpi.hba_device;
2129 	softc->disk->d_hba_subvendor = cpi.hba_subvendor;
2130 	softc->disk->d_hba_subdevice = cpi.hba_subdevice;
2131 
2132 	/*
2133 	 * Acquire a reference to the periph before we register with GEOM.
2134 	 * We'll release this reference once GEOM calls us back (via
2135 	 * dadiskgonecb()) telling us that our provider has been freed.
2136 	 */
2137 	if (cam_periph_acquire(periph) != CAM_REQ_CMP) {
2138 		xpt_print(periph->path, "%s: lost periph during "
2139 			  "registration!\n", __func__);
2140 		cam_periph_lock(periph);
2141 		return (CAM_REQ_CMP_ERR);
2142 	}
2143 
2144 	disk_create(softc->disk, DISK_VERSION);
2145 	cam_periph_lock(periph);
2146 
2147 	/*
2148 	 * Add async callbacks for events of interest.
2149 	 * I don't bother checking if this fails as,
2150 	 * in most cases, the system will function just
2151 	 * fine without them and the only alternative
2152 	 * would be to not attach the device on failure.
2153 	 */
2154 	xpt_register_async(AC_SENT_BDR | AC_BUS_RESET | AC_LOST_DEVICE |
2155 	    AC_ADVINFO_CHANGED | AC_SCSI_AEN | AC_UNIT_ATTENTION,
2156 	    daasync, periph, periph->path);
2157 
2158 	/*
2159 	 * Emit an attribute changed notification just in case
2160 	 * physical path information arrived before our async
2161 	 * event handler was registered, but after anyone attaching
2162 	 * to our disk device polled it.
2163 	 */
2164 	disk_attr_changed(softc->disk, "GEOM::physpath", M_NOWAIT);
2165 
2166 	/*
2167 	 * Schedule a periodic media polling events.
2168 	 */
2169 	callout_init_mtx(&softc->mediapoll_c, periph->sim->mtx, 0);
2170 	if ((softc->flags & DA_FLAG_PACK_REMOVABLE) &&
2171 	    (cgd->inq_flags & SID_AEN) == 0 &&
2172 	    da_poll_period != 0)
2173 		callout_reset(&softc->mediapoll_c, da_poll_period * hz,
2174 		    damediapoll, periph);
2175 
2176 	xpt_schedule(periph, CAM_PRIORITY_DEV);
2177 
2178 	return(CAM_REQ_CMP);
2179 }
2180 
2181 static void
2182 dastart(struct cam_periph *periph, union ccb *start_ccb)
2183 {
2184 	struct da_softc *softc;
2185 
2186 	softc = (struct da_softc *)periph->softc;
2187 
2188 	CAM_DEBUG(periph->path, CAM_DEBUG_TRACE, ("dastart\n"));
2189 
2190 skipstate:
2191 	switch (softc->state) {
2192 	case DA_STATE_NORMAL:
2193 	{
2194 		struct bio *bp;
2195 		uint8_t tag_code;
2196 
2197 		/* Execute immediate CCB if waiting. */
2198 		if (periph->immediate_priority <= periph->pinfo.priority) {
2199 			CAM_DEBUG(periph->path, CAM_DEBUG_SUBTRACE,
2200 					("queuing for immediate ccb\n"));
2201 			start_ccb->ccb_h.ccb_state = DA_CCB_WAITING;
2202 			SLIST_INSERT_HEAD(&periph->ccb_list, &start_ccb->ccb_h,
2203 					  periph_links.sle);
2204 			periph->immediate_priority = CAM_PRIORITY_NONE;
2205 			wakeup(&periph->ccb_list);
2206 			/* May have more work to do, so ensure we stay scheduled */
2207 			daschedule(periph);
2208 			break;
2209 		}
2210 
2211 		/* Run BIO_DELETE if not running yet. */
2212 		if (!softc->delete_running &&
2213 		    (bp = bioq_first(&softc->delete_queue)) != NULL) {
2214 			if (softc->delete_func != NULL) {
2215 				softc->delete_func(periph, start_ccb, bp);
2216 				goto out;
2217 			} else {
2218 				bioq_flush(&softc->delete_queue, NULL, 0);
2219 				/* FALLTHROUGH */
2220 			}
2221 		}
2222 
2223 		/* Run regular command. */
2224 		bp = bioq_takefirst(&softc->bio_queue);
2225 		if (bp == NULL) {
2226 			if (softc->tur) {
2227 				softc->tur = 0;
2228 				scsi_test_unit_ready(&start_ccb->csio,
2229 				     /*retries*/ da_retry_count,
2230 				     dadone,
2231 				     MSG_SIMPLE_Q_TAG,
2232 				     SSD_FULL_SIZE,
2233 				     da_default_timeout * 1000);
2234 				start_ccb->ccb_h.ccb_bp = NULL;
2235 				start_ccb->ccb_h.ccb_state = DA_CCB_TUR;
2236 				xpt_action(start_ccb);
2237 			} else
2238 				xpt_release_ccb(start_ccb);
2239 			break;
2240 		}
2241 		if (softc->tur) {
2242 			softc->tur = 0;
2243 			cam_periph_release_locked(periph);
2244 		}
2245 
2246 		if ((bp->bio_flags & BIO_ORDERED) != 0 ||
2247 		    (softc->flags & DA_FLAG_NEED_OTAG) != 0) {
2248 			softc->flags &= ~DA_FLAG_NEED_OTAG;
2249 			softc->ordered_tag_count++;
2250 			tag_code = MSG_ORDERED_Q_TAG;
2251 		} else {
2252 			tag_code = MSG_SIMPLE_Q_TAG;
2253 		}
2254 
2255 		switch (bp->bio_cmd) {
2256 		case BIO_WRITE:
2257 			softc->flags |= DA_FLAG_DIRTY;
2258 			/* FALLTHROUGH */
2259 		case BIO_READ:
2260 			scsi_read_write(&start_ccb->csio,
2261 					/*retries*/da_retry_count,
2262 					/*cbfcnp*/dadone,
2263 					/*tag_action*/tag_code,
2264 					/*read_op*/(bp->bio_cmd == BIO_READ ?
2265 					SCSI_RW_READ : SCSI_RW_WRITE) |
2266 					((bp->bio_flags & BIO_UNMAPPED) != 0 ?
2267 					SCSI_RW_BIO : 0),
2268 					/*byte2*/0,
2269 					softc->minimum_cmd_size,
2270 					/*lba*/bp->bio_pblkno,
2271 					/*block_count*/bp->bio_bcount /
2272 					softc->params.secsize,
2273 					/*data_ptr*/ (bp->bio_flags &
2274 					BIO_UNMAPPED) != 0 ? (void *)bp :
2275 					bp->bio_data,
2276 					/*dxfer_len*/ bp->bio_bcount,
2277 					/*sense_len*/SSD_FULL_SIZE,
2278 					da_default_timeout * 1000);
2279 			break;
2280 		case BIO_FLUSH:
2281 			/*
2282 			 * BIO_FLUSH doesn't currently communicate
2283 			 * range data, so we synchronize the cache
2284 			 * over the whole disk.  We also force
2285 			 * ordered tag semantics the flush applies
2286 			 * to all previously queued I/O.
2287 			 */
2288 			scsi_synchronize_cache(&start_ccb->csio,
2289 					       /*retries*/1,
2290 					       /*cbfcnp*/dadone,
2291 					       MSG_ORDERED_Q_TAG,
2292 					       /*begin_lba*/0,
2293 					       /*lb_count*/0,
2294 					       SSD_FULL_SIZE,
2295 					       da_default_timeout*1000);
2296 			break;
2297 		}
2298 		start_ccb->ccb_h.ccb_state = DA_CCB_BUFFER_IO;
2299 
2300 out:
2301 		/*
2302 		 * Block out any asynchronous callbacks
2303 		 * while we touch the pending ccb list.
2304 		 */
2305 		LIST_INSERT_HEAD(&softc->pending_ccbs,
2306 				 &start_ccb->ccb_h, periph_links.le);
2307 		softc->outstanding_cmds++;
2308 
2309 		/* We expect a unit attention from this device */
2310 		if ((softc->flags & DA_FLAG_RETRY_UA) != 0) {
2311 			start_ccb->ccb_h.ccb_state |= DA_CCB_RETRY_UA;
2312 			softc->flags &= ~DA_FLAG_RETRY_UA;
2313 		}
2314 
2315 		start_ccb->ccb_h.ccb_bp = bp;
2316 		xpt_action(start_ccb);
2317 
2318 		/* May have more work to do, so ensure we stay scheduled */
2319 		daschedule(periph);
2320 		break;
2321 	}
2322 	case DA_STATE_PROBE_RC:
2323 	{
2324 		struct scsi_read_capacity_data *rcap;
2325 
2326 		rcap = (struct scsi_read_capacity_data *)
2327 		    malloc(sizeof(*rcap), M_SCSIDA, M_NOWAIT|M_ZERO);
2328 		if (rcap == NULL) {
2329 			printf("dastart: Couldn't malloc read_capacity data\n");
2330 			/* da_free_periph??? */
2331 			break;
2332 		}
2333 		scsi_read_capacity(&start_ccb->csio,
2334 				   /*retries*/da_retry_count,
2335 				   dadone,
2336 				   MSG_SIMPLE_Q_TAG,
2337 				   rcap,
2338 				   SSD_FULL_SIZE,
2339 				   /*timeout*/5000);
2340 		start_ccb->ccb_h.ccb_bp = NULL;
2341 		start_ccb->ccb_h.ccb_state = DA_CCB_PROBE_RC;
2342 		xpt_action(start_ccb);
2343 		break;
2344 	}
2345 	case DA_STATE_PROBE_RC16:
2346 	{
2347 		struct scsi_read_capacity_data_long *rcaplong;
2348 
2349 		rcaplong = (struct scsi_read_capacity_data_long *)
2350 			malloc(sizeof(*rcaplong), M_SCSIDA, M_NOWAIT|M_ZERO);
2351 		if (rcaplong == NULL) {
2352 			printf("dastart: Couldn't malloc read_capacity data\n");
2353 			/* da_free_periph??? */
2354 			break;
2355 		}
2356 		scsi_read_capacity_16(&start_ccb->csio,
2357 				      /*retries*/ da_retry_count,
2358 				      /*cbfcnp*/ dadone,
2359 				      /*tag_action*/ MSG_SIMPLE_Q_TAG,
2360 				      /*lba*/ 0,
2361 				      /*reladr*/ 0,
2362 				      /*pmi*/ 0,
2363 				      /*rcap_buf*/ (uint8_t *)rcaplong,
2364 				      /*rcap_buf_len*/ sizeof(*rcaplong),
2365 				      /*sense_len*/ SSD_FULL_SIZE,
2366 				      /*timeout*/ da_default_timeout * 1000);
2367 		start_ccb->ccb_h.ccb_bp = NULL;
2368 		start_ccb->ccb_h.ccb_state = DA_CCB_PROBE_RC16;
2369 		xpt_action(start_ccb);
2370 		break;
2371 	}
2372 	case DA_STATE_PROBE_LBP:
2373 	{
2374 		struct scsi_vpd_logical_block_prov *lbp;
2375 
2376 		if (!scsi_vpd_supported_page(periph, SVPD_LBP)) {
2377 			/*
2378 			 * If we get here we don't support any SBC-3 delete
2379 			 * methods with UNMAP as the Logical Block Provisioning
2380 			 * VPD page support is required for devices which
2381 			 * support it according to T10/1799-D Revision 31
2382 			 * however older revisions of the spec don't mandate
2383 			 * this so we currently don't remove these methods
2384 			 * from the available set.
2385 			 */
2386 			softc->state = DA_STATE_PROBE_BLK_LIMITS;
2387 			goto skipstate;
2388 		}
2389 
2390 		lbp = (struct scsi_vpd_logical_block_prov *)
2391 			malloc(sizeof(*lbp), M_SCSIDA, M_NOWAIT|M_ZERO);
2392 
2393 		if (lbp == NULL) {
2394 			printf("dastart: Couldn't malloc lbp data\n");
2395 			/* da_free_periph??? */
2396 			break;
2397 		}
2398 
2399 		scsi_inquiry(&start_ccb->csio,
2400 			     /*retries*/da_retry_count,
2401 			     /*cbfcnp*/dadone,
2402 			     /*tag_action*/MSG_SIMPLE_Q_TAG,
2403 			     /*inq_buf*/(u_int8_t *)lbp,
2404 			     /*inq_len*/sizeof(*lbp),
2405 			     /*evpd*/TRUE,
2406 			     /*page_code*/SVPD_LBP,
2407 			     /*sense_len*/SSD_MIN_SIZE,
2408 			     /*timeout*/da_default_timeout * 1000);
2409 		start_ccb->ccb_h.ccb_bp = NULL;
2410 		start_ccb->ccb_h.ccb_state = DA_CCB_PROBE_LBP;
2411 		xpt_action(start_ccb);
2412 		break;
2413 	}
2414 	case DA_STATE_PROBE_BLK_LIMITS:
2415 	{
2416 		struct scsi_vpd_block_limits *block_limits;
2417 
2418 		if (!scsi_vpd_supported_page(periph, SVPD_BLOCK_LIMITS)) {
2419 			/* Not supported skip to next probe */
2420 			softc->state = DA_STATE_PROBE_BDC;
2421 			goto skipstate;
2422 		}
2423 
2424 		block_limits = (struct scsi_vpd_block_limits *)
2425 			malloc(sizeof(*block_limits), M_SCSIDA, M_NOWAIT|M_ZERO);
2426 
2427 		if (block_limits == NULL) {
2428 			printf("dastart: Couldn't malloc block_limits data\n");
2429 			/* da_free_periph??? */
2430 			break;
2431 		}
2432 
2433 		scsi_inquiry(&start_ccb->csio,
2434 			     /*retries*/da_retry_count,
2435 			     /*cbfcnp*/dadone,
2436 			     /*tag_action*/MSG_SIMPLE_Q_TAG,
2437 			     /*inq_buf*/(u_int8_t *)block_limits,
2438 			     /*inq_len*/sizeof(*block_limits),
2439 			     /*evpd*/TRUE,
2440 			     /*page_code*/SVPD_BLOCK_LIMITS,
2441 			     /*sense_len*/SSD_MIN_SIZE,
2442 			     /*timeout*/da_default_timeout * 1000);
2443 		start_ccb->ccb_h.ccb_bp = NULL;
2444 		start_ccb->ccb_h.ccb_state = DA_CCB_PROBE_BLK_LIMITS;
2445 		xpt_action(start_ccb);
2446 		break;
2447 	}
2448 	case DA_STATE_PROBE_BDC:
2449 	{
2450 		struct scsi_vpd_block_characteristics *bdc;
2451 
2452 		if (!scsi_vpd_supported_page(periph, SVPD_BDC)) {
2453 			softc->state = DA_STATE_PROBE_ATA;
2454 			goto skipstate;
2455 		}
2456 
2457 		bdc = (struct scsi_vpd_block_characteristics *)
2458 			malloc(sizeof(*bdc), M_SCSIDA, M_NOWAIT|M_ZERO);
2459 
2460 		if (bdc == NULL) {
2461 			printf("dastart: Couldn't malloc bdc data\n");
2462 			/* da_free_periph??? */
2463 			break;
2464 		}
2465 
2466 		scsi_inquiry(&start_ccb->csio,
2467 			     /*retries*/da_retry_count,
2468 			     /*cbfcnp*/dadone,
2469 			     /*tag_action*/MSG_SIMPLE_Q_TAG,
2470 			     /*inq_buf*/(u_int8_t *)bdc,
2471 			     /*inq_len*/sizeof(*bdc),
2472 			     /*evpd*/TRUE,
2473 			     /*page_code*/SVPD_BDC,
2474 			     /*sense_len*/SSD_MIN_SIZE,
2475 			     /*timeout*/da_default_timeout * 1000);
2476 		start_ccb->ccb_h.ccb_bp = NULL;
2477 		start_ccb->ccb_h.ccb_state = DA_CCB_PROBE_BDC;
2478 		xpt_action(start_ccb);
2479 		break;
2480 	}
2481 	case DA_STATE_PROBE_ATA:
2482 	{
2483 		struct ata_params *ata_params;
2484 
2485 		if (!scsi_vpd_supported_page(periph, SVPD_ATA_INFORMATION)) {
2486 			daprobedone(periph, start_ccb);
2487 			break;
2488 		}
2489 
2490 		ata_params = (struct ata_params*)
2491 			malloc(sizeof(*ata_params), M_SCSIDA, M_NOWAIT|M_ZERO);
2492 
2493 		if (ata_params == NULL) {
2494 			printf("dastart: Couldn't malloc ata_params data\n");
2495 			/* da_free_periph??? */
2496 			break;
2497 		}
2498 
2499 		scsi_ata_identify(&start_ccb->csio,
2500 				  /*retries*/da_retry_count,
2501 				  /*cbfcnp*/dadone,
2502                                   /*tag_action*/MSG_SIMPLE_Q_TAG,
2503 				  /*data_ptr*/(u_int8_t *)ata_params,
2504 				  /*dxfer_len*/sizeof(*ata_params),
2505 				  /*sense_len*/SSD_FULL_SIZE,
2506 				  /*timeout*/da_default_timeout * 1000);
2507 		start_ccb->ccb_h.ccb_bp = NULL;
2508 		start_ccb->ccb_h.ccb_state = DA_CCB_PROBE_ATA;
2509 		xpt_action(start_ccb);
2510 		break;
2511 	}
2512 	}
2513 }
2514 
2515 /*
2516  * In each of the methods below, while its the caller's
2517  * responsibility to ensure the request will fit into a
2518  * single device request, we might have changed the delete
2519  * method due to the device incorrectly advertising either
2520  * its supported methods or limits.
2521  *
2522  * To prevent this causing further issues we validate the
2523  * against the methods limits, and warn which would
2524  * otherwise be unnecessary.
2525  */
2526 static void
2527 da_delete_unmap(struct cam_periph *periph, union ccb *ccb, struct bio *bp)
2528 {
2529 	struct da_softc *softc = (struct da_softc *)periph->softc;;
2530 	struct bio *bp1;
2531 	uint8_t *buf = softc->unmap_buf;
2532 	uint64_t lba, lastlba = (uint64_t)-1;
2533 	uint64_t totalcount = 0;
2534 	uint64_t count;
2535 	uint32_t lastcount = 0, c;
2536 	uint32_t off, ranges = 0;
2537 
2538 	/*
2539 	 * Currently this doesn't take the UNMAP
2540 	 * Granularity and Granularity Alignment
2541 	 * fields into account.
2542 	 *
2543 	 * This could result in both unoptimal unmap
2544 	 * requests as as well as UNMAP calls unmapping
2545 	 * fewer LBA's than requested.
2546 	 */
2547 
2548 	softc->delete_running = 1;
2549 	bzero(softc->unmap_buf, sizeof(softc->unmap_buf));
2550 	bp1 = bp;
2551 	do {
2552 		bioq_remove(&softc->delete_queue, bp1);
2553 		if (bp1 != bp)
2554 			bioq_insert_tail(&softc->delete_run_queue, bp1);
2555 		lba = bp1->bio_pblkno;
2556 		count = bp1->bio_bcount / softc->params.secsize;
2557 
2558 		/* Try to extend the previous range. */
2559 		if (lba == lastlba) {
2560 			c = min(count, softc->unmap_max_lba - lastcount);
2561 			lastcount += c;
2562 			off = ((ranges - 1) * UNMAP_RANGE_SIZE) +
2563 			      UNMAP_HEAD_SIZE;
2564 			scsi_ulto4b(lastcount, &buf[off + 8]);
2565 			count -= c;
2566 			lba +=c;
2567 			totalcount += c;
2568 		}
2569 
2570 		while (count > 0) {
2571 			c = min(count, softc->unmap_max_lba);
2572 			if (totalcount + c > softc->unmap_max_lba ||
2573 			    ranges >= softc->unmap_max_ranges) {
2574 				xpt_print(periph->path,
2575 				    "%s issuing short delete %ld > %ld"
2576 				    "|| %d >= %d",
2577 				    da_delete_method_desc[softc->delete_method],
2578 				    totalcount + c, softc->unmap_max_lba,
2579 				    ranges, softc->unmap_max_ranges);
2580 				break;
2581 			}
2582 			off = (ranges * UNMAP_RANGE_SIZE) + UNMAP_HEAD_SIZE;
2583 			scsi_u64to8b(lba, &buf[off + 0]);
2584 			scsi_ulto4b(c, &buf[off + 8]);
2585 			lba += c;
2586 			totalcount += c;
2587 			ranges++;
2588 			count -= c;
2589 			lastcount = c;
2590 		}
2591 		lastlba = lba;
2592 		bp1 = bioq_first(&softc->delete_queue);
2593 		if (bp1 == NULL || ranges >= softc->unmap_max_ranges ||
2594 		    totalcount + bp1->bio_bcount /
2595 		    softc->params.secsize > softc->unmap_max_lba)
2596 			break;
2597 	} while (1);
2598 	scsi_ulto2b(ranges * 16 + 6, &buf[0]);
2599 	scsi_ulto2b(ranges * 16, &buf[2]);
2600 
2601 	scsi_unmap(&ccb->csio,
2602 		   /*retries*/da_retry_count,
2603 		   /*cbfcnp*/dadone,
2604 		   /*tag_action*/MSG_SIMPLE_Q_TAG,
2605 		   /*byte2*/0,
2606 		   /*data_ptr*/ buf,
2607 		   /*dxfer_len*/ ranges * 16 + 8,
2608 		   /*sense_len*/SSD_FULL_SIZE,
2609 		   da_default_timeout * 1000);
2610 	ccb->ccb_h.ccb_state = DA_CCB_DELETE;
2611 }
2612 
2613 static void
2614 da_delete_trim(struct cam_periph *periph, union ccb *ccb, struct bio *bp)
2615 {
2616 	struct da_softc *softc = (struct da_softc *)periph->softc;
2617 	struct bio *bp1;
2618 	uint8_t *buf = softc->unmap_buf;
2619 	uint64_t lastlba = (uint64_t)-1;
2620 	uint64_t count;
2621 	uint64_t lba;
2622 	uint32_t lastcount = 0, c, requestcount;
2623 	int ranges = 0, off, block_count;
2624 
2625 	softc->delete_running = 1;
2626 	bzero(softc->unmap_buf, sizeof(softc->unmap_buf));
2627 	bp1 = bp;
2628 	do {
2629 		bioq_remove(&softc->delete_queue, bp1);
2630 		if (bp1 != bp)
2631 			bioq_insert_tail(&softc->delete_run_queue, bp1);
2632 		lba = bp1->bio_pblkno;
2633 		count = bp1->bio_bcount / softc->params.secsize;
2634 		requestcount = count;
2635 
2636 		/* Try to extend the previous range. */
2637 		if (lba == lastlba) {
2638 			c = min(count, ATA_DSM_RANGE_MAX - lastcount);
2639 			lastcount += c;
2640 			off = (ranges - 1) * 8;
2641 			buf[off + 6] = lastcount & 0xff;
2642 			buf[off + 7] = (lastcount >> 8) & 0xff;
2643 			count -= c;
2644 			lba += c;
2645 		}
2646 
2647 		while (count > 0) {
2648 			c = min(count, ATA_DSM_RANGE_MAX);
2649 			off = ranges * 8;
2650 
2651 			buf[off + 0] = lba & 0xff;
2652 			buf[off + 1] = (lba >> 8) & 0xff;
2653 			buf[off + 2] = (lba >> 16) & 0xff;
2654 			buf[off + 3] = (lba >> 24) & 0xff;
2655 			buf[off + 4] = (lba >> 32) & 0xff;
2656 			buf[off + 5] = (lba >> 40) & 0xff;
2657 			buf[off + 6] = c & 0xff;
2658 			buf[off + 7] = (c >> 8) & 0xff;
2659 			lba += c;
2660 			ranges++;
2661 			count -= c;
2662 			lastcount = c;
2663 			if (count != 0 && ranges == softc->trim_max_ranges) {
2664 				xpt_print(periph->path,
2665 				    "%s issuing short delete %ld > %ld",
2666 				    da_delete_method_desc[softc->delete_method],
2667 				    requestcount,
2668 				    (softc->trim_max_ranges - ranges) *
2669 				    ATA_DSM_RANGE_MAX);
2670 				break;
2671 			}
2672 		}
2673 		lastlba = lba;
2674 		bp1 = bioq_first(&softc->delete_queue);
2675 		if (bp1 == NULL || bp1->bio_bcount / softc->params.secsize >
2676 		    (softc->trim_max_ranges - ranges) * ATA_DSM_RANGE_MAX)
2677 			break;
2678 	} while (1);
2679 
2680 	block_count = (ranges + ATA_DSM_BLK_RANGES - 1) / ATA_DSM_BLK_RANGES;
2681 	scsi_ata_trim(&ccb->csio,
2682 		      /*retries*/da_retry_count,
2683 		      /*cbfcnp*/dadone,
2684 		      /*tag_action*/MSG_SIMPLE_Q_TAG,
2685 		      block_count,
2686 		      /*data_ptr*/buf,
2687 		      /*dxfer_len*/block_count * ATA_DSM_BLK_SIZE,
2688 		      /*sense_len*/SSD_FULL_SIZE,
2689 		      da_default_timeout * 1000);
2690 	ccb->ccb_h.ccb_state = DA_CCB_DELETE;
2691 }
2692 
2693 /*
2694  * We calculate ws_max_blks here based off d_delmaxsize instead
2695  * of using softc->ws_max_blks as it is absolute max for the
2696  * device not the protocol max which may well be lower
2697  */
2698 static void
2699 da_delete_ws(struct cam_periph *periph, union ccb *ccb, struct bio *bp)
2700 {
2701 	struct da_softc *softc;
2702 	struct bio *bp1;
2703 	uint64_t ws_max_blks;
2704 	uint64_t lba;
2705 	uint64_t count; /* forward compat with WS32 */
2706 
2707 	softc = (struct da_softc *)periph->softc;
2708 	ws_max_blks = softc->disk->d_delmaxsize / softc->params.secsize;
2709 	softc->delete_running = 1;
2710 	lba = bp->bio_pblkno;
2711 	count = 0;
2712 	bp1 = bp;
2713 	do {
2714 		bioq_remove(&softc->delete_queue, bp1);
2715 		if (bp1 != bp)
2716 			bioq_insert_tail(&softc->delete_run_queue, bp1);
2717 		count += bp1->bio_bcount / softc->params.secsize;
2718 		if (count > ws_max_blks) {
2719 			count = min(count, ws_max_blks);
2720 			xpt_print(periph->path,
2721 			    "%s issuing short delete %ld > %ld",
2722 			    da_delete_method_desc[softc->delete_method],
2723 			    count, ws_max_blks);
2724 			break;
2725 		}
2726 		bp1 = bioq_first(&softc->delete_queue);
2727 		if (bp1 == NULL || lba + count != bp1->bio_pblkno ||
2728 		    count + bp1->bio_bcount /
2729 		    softc->params.secsize > ws_max_blks)
2730 			break;
2731 	} while (1);
2732 
2733 	scsi_write_same(&ccb->csio,
2734 			/*retries*/da_retry_count,
2735 			/*cbfcnp*/dadone,
2736 			/*tag_action*/MSG_SIMPLE_Q_TAG,
2737 			/*byte2*/softc->delete_method ==
2738 			    DA_DELETE_ZERO ? 0 : SWS_UNMAP,
2739 			softc->delete_method == DA_DELETE_WS16 ? 16 : 10,
2740 			/*lba*/lba,
2741 			/*block_count*/count,
2742 			/*data_ptr*/ __DECONST(void *, zero_region),
2743 			/*dxfer_len*/ softc->params.secsize,
2744 			/*sense_len*/SSD_FULL_SIZE,
2745 			da_default_timeout * 1000);
2746 	ccb->ccb_h.ccb_state = DA_CCB_DELETE;
2747 }
2748 
2749 static int
2750 cmd6workaround(union ccb *ccb)
2751 {
2752 	struct scsi_rw_6 cmd6;
2753 	struct scsi_rw_10 *cmd10;
2754 	struct da_softc *softc;
2755 	u_int8_t *cdb;
2756 	struct bio *bp;
2757 	int frozen;
2758 
2759 	cdb = ccb->csio.cdb_io.cdb_bytes;
2760 	softc = (struct da_softc *)xpt_path_periph(ccb->ccb_h.path)->softc;
2761 
2762 	if (ccb->ccb_h.ccb_state == DA_CCB_DELETE) {
2763 		da_delete_methods old_method = softc->delete_method;
2764 
2765 		/*
2766 		 * Typically there are two reasons for failure here
2767 		 * 1. Delete method was detected as supported but isn't
2768 		 * 2. Delete failed due to invalid params e.g. too big
2769 		 *
2770 		 * While we will attempt to choose an alternative delete method
2771 		 * this may result in short deletes if the existing delete
2772 		 * requests from geom are big for the new method choosen.
2773 		 *
2774 		 * This method assumes that the error which triggered this
2775 		 * will not retry the io otherwise a panic will occur
2776 		 */
2777 		dadeleteflag(softc, old_method, 0);
2778 		dadeletemethodchoose(softc, DA_DELETE_DISABLE);
2779 		if (softc->delete_method == DA_DELETE_DISABLE)
2780 			xpt_print(ccb->ccb_h.path,
2781 				  "%s failed, disabling BIO_DELETE\n",
2782 				  da_delete_method_desc[old_method]);
2783 		else
2784 			xpt_print(ccb->ccb_h.path,
2785 				  "%s failed, switching to %s BIO_DELETE\n",
2786 				  da_delete_method_desc[old_method],
2787 				  da_delete_method_desc[softc->delete_method]);
2788 
2789 		if (DA_SIO) {
2790 			while ((bp = bioq_takefirst(&softc->delete_run_queue))
2791 			    != NULL)
2792 				bioq_disksort(&softc->delete_queue, bp);
2793 		} else {
2794 			while ((bp = bioq_takefirst(&softc->delete_run_queue))
2795 			    != NULL)
2796 				bioq_insert_tail(&softc->delete_queue, bp);
2797 		}
2798 		bioq_insert_tail(&softc->delete_queue,
2799 		    (struct bio *)ccb->ccb_h.ccb_bp);
2800 		ccb->ccb_h.ccb_bp = NULL;
2801 		return (0);
2802 	}
2803 
2804 	/* Detect unsupported PREVENT ALLOW MEDIUM REMOVAL. */
2805 	if ((ccb->ccb_h.flags & CAM_CDB_POINTER) == 0 &&
2806 	    (*cdb == PREVENT_ALLOW) &&
2807 	    (softc->quirks & DA_Q_NO_PREVENT) == 0) {
2808 		if (bootverbose)
2809 			xpt_print(ccb->ccb_h.path,
2810 			    "PREVENT ALLOW MEDIUM REMOVAL not supported.\n");
2811 		softc->quirks |= DA_Q_NO_PREVENT;
2812 		return (0);
2813 	}
2814 
2815 	/* Detect unsupported SYNCHRONIZE CACHE(10). */
2816 	if ((ccb->ccb_h.flags & CAM_CDB_POINTER) == 0 &&
2817 	    (*cdb == SYNCHRONIZE_CACHE) &&
2818 	    (softc->quirks & DA_Q_NO_SYNC_CACHE) == 0) {
2819 		if (bootverbose)
2820 			xpt_print(ccb->ccb_h.path,
2821 			    "SYNCHRONIZE CACHE(10) not supported.\n");
2822 		softc->quirks |= DA_Q_NO_SYNC_CACHE;
2823 		softc->disk->d_flags &= ~DISKFLAG_CANFLUSHCACHE;
2824 		return (0);
2825 	}
2826 
2827 	/* Translation only possible if CDB is an array and cmd is R/W6 */
2828 	if ((ccb->ccb_h.flags & CAM_CDB_POINTER) != 0 ||
2829 	    (*cdb != READ_6 && *cdb != WRITE_6))
2830 		return 0;
2831 
2832 	xpt_print(ccb->ccb_h.path, "READ(6)/WRITE(6) not supported, "
2833 	    "increasing minimum_cmd_size to 10.\n");
2834  	softc->minimum_cmd_size = 10;
2835 
2836 	bcopy(cdb, &cmd6, sizeof(struct scsi_rw_6));
2837 	cmd10 = (struct scsi_rw_10 *)cdb;
2838 	cmd10->opcode = (cmd6.opcode == READ_6) ? READ_10 : WRITE_10;
2839 	cmd10->byte2 = 0;
2840 	scsi_ulto4b(scsi_3btoul(cmd6.addr), cmd10->addr);
2841 	cmd10->reserved = 0;
2842 	scsi_ulto2b(cmd6.length, cmd10->length);
2843 	cmd10->control = cmd6.control;
2844 	ccb->csio.cdb_len = sizeof(*cmd10);
2845 
2846 	/* Requeue request, unfreezing queue if necessary */
2847 	frozen = (ccb->ccb_h.status & CAM_DEV_QFRZN) != 0;
2848  	ccb->ccb_h.status = CAM_REQUEUE_REQ;
2849 	xpt_action(ccb);
2850 	if (frozen) {
2851 		cam_release_devq(ccb->ccb_h.path,
2852 				 /*relsim_flags*/0,
2853 				 /*reduction*/0,
2854 				 /*timeout*/0,
2855 				 /*getcount_only*/0);
2856 	}
2857 	return (ERESTART);
2858 }
2859 
2860 static void
2861 dadone(struct cam_periph *periph, union ccb *done_ccb)
2862 {
2863 	struct da_softc *softc;
2864 	struct ccb_scsiio *csio;
2865 	u_int32_t  priority;
2866 	da_ccb_state state;
2867 
2868 	softc = (struct da_softc *)periph->softc;
2869 	priority = done_ccb->ccb_h.pinfo.priority;
2870 
2871 	CAM_DEBUG(periph->path, CAM_DEBUG_TRACE, ("dadone\n"));
2872 
2873 	csio = &done_ccb->csio;
2874 	state = csio->ccb_h.ccb_state & DA_CCB_TYPE_MASK;
2875 	switch (state) {
2876 	case DA_CCB_BUFFER_IO:
2877 	case DA_CCB_DELETE:
2878 	{
2879 		struct bio *bp, *bp1;
2880 
2881 		bp = (struct bio *)done_ccb->ccb_h.ccb_bp;
2882 		if ((done_ccb->ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) {
2883 			int error;
2884 			int sf;
2885 
2886 			if ((csio->ccb_h.ccb_state & DA_CCB_RETRY_UA) != 0)
2887 				sf = SF_RETRY_UA;
2888 			else
2889 				sf = 0;
2890 
2891 			error = daerror(done_ccb, CAM_RETRY_SELTO, sf);
2892 			if (error == ERESTART) {
2893 				/*
2894 				 * A retry was scheduled, so
2895 				 * just return.
2896 				 */
2897 				return;
2898 			}
2899 			bp = (struct bio *)done_ccb->ccb_h.ccb_bp;
2900 			if (error != 0) {
2901 				int queued_error;
2902 
2903 				/*
2904 				 * return all queued I/O with EIO, so that
2905 				 * the client can retry these I/Os in the
2906 				 * proper order should it attempt to recover.
2907 				 */
2908 				queued_error = EIO;
2909 
2910 				if (error == ENXIO
2911 				 && (softc->flags & DA_FLAG_PACK_INVALID)== 0) {
2912 					/*
2913 					 * Catastrophic error.  Mark our pack as
2914 					 * invalid.
2915 					 */
2916 					/*
2917 					 * XXX See if this is really a media
2918 					 * XXX change first?
2919 					 */
2920 					xpt_print(periph->path,
2921 					    "Invalidating pack\n");
2922 					softc->flags |= DA_FLAG_PACK_INVALID;
2923 					queued_error = ENXIO;
2924 				}
2925 				bioq_flush(&softc->bio_queue, NULL,
2926 					   queued_error);
2927 				if (bp != NULL) {
2928 					bp->bio_error = error;
2929 					bp->bio_resid = bp->bio_bcount;
2930 					bp->bio_flags |= BIO_ERROR;
2931 				}
2932 			} else if (bp != NULL) {
2933 				if (state == DA_CCB_DELETE)
2934 					bp->bio_resid = 0;
2935 				else
2936 					bp->bio_resid = csio->resid;
2937 				bp->bio_error = 0;
2938 				if (bp->bio_resid != 0)
2939 					bp->bio_flags |= BIO_ERROR;
2940 			}
2941 			if ((done_ccb->ccb_h.status & CAM_DEV_QFRZN) != 0)
2942 				cam_release_devq(done_ccb->ccb_h.path,
2943 						 /*relsim_flags*/0,
2944 						 /*reduction*/0,
2945 						 /*timeout*/0,
2946 						 /*getcount_only*/0);
2947 		} else if (bp != NULL) {
2948 			if ((done_ccb->ccb_h.status & CAM_DEV_QFRZN) != 0)
2949 				panic("REQ_CMP with QFRZN");
2950 			if (state == DA_CCB_DELETE)
2951 				bp->bio_resid = 0;
2952 			else
2953 				bp->bio_resid = csio->resid;
2954 			if (csio->resid > 0)
2955 				bp->bio_flags |= BIO_ERROR;
2956 			if (softc->error_inject != 0) {
2957 				bp->bio_error = softc->error_inject;
2958 				bp->bio_resid = bp->bio_bcount;
2959 				bp->bio_flags |= BIO_ERROR;
2960 				softc->error_inject = 0;
2961 			}
2962 		}
2963 
2964 		/*
2965 		 * Block out any asynchronous callbacks
2966 		 * while we touch the pending ccb list.
2967 		 */
2968 		LIST_REMOVE(&done_ccb->ccb_h, periph_links.le);
2969 		softc->outstanding_cmds--;
2970 		if (softc->outstanding_cmds == 0)
2971 			softc->flags |= DA_FLAG_WENT_IDLE;
2972 
2973 		if (state == DA_CCB_DELETE) {
2974 			while ((bp1 = bioq_takefirst(&softc->delete_run_queue))
2975 			    != NULL) {
2976 				bp1->bio_error = bp->bio_error;
2977 				if (bp->bio_flags & BIO_ERROR) {
2978 					bp1->bio_flags |= BIO_ERROR;
2979 					bp1->bio_resid = bp1->bio_bcount;
2980 				} else
2981 					bp1->bio_resid = 0;
2982 				biodone(bp1);
2983 			}
2984 			softc->delete_running = 0;
2985 			if (bp != NULL)
2986 				biodone(bp);
2987 			daschedule(periph);
2988 		} else if (bp != NULL)
2989 			biodone(bp);
2990 		break;
2991 	}
2992 	case DA_CCB_PROBE_RC:
2993 	case DA_CCB_PROBE_RC16:
2994 	{
2995 		struct	   scsi_read_capacity_data *rdcap;
2996 		struct     scsi_read_capacity_data_long *rcaplong;
2997 		char	   announce_buf[80];
2998 		int	   lbp;
2999 
3000 		lbp = 0;
3001 		rdcap = NULL;
3002 		rcaplong = NULL;
3003 		if (state == DA_CCB_PROBE_RC)
3004 			rdcap =(struct scsi_read_capacity_data *)csio->data_ptr;
3005 		else
3006 			rcaplong = (struct scsi_read_capacity_data_long *)
3007 				csio->data_ptr;
3008 
3009 		if ((csio->ccb_h.status & CAM_STATUS_MASK) == CAM_REQ_CMP) {
3010 			struct disk_params *dp;
3011 			uint32_t block_size;
3012 			uint64_t maxsector;
3013 			u_int lbppbe;	/* LB per physical block exponent. */
3014 			u_int lalba;	/* Lowest aligned LBA. */
3015 
3016 			if (state == DA_CCB_PROBE_RC) {
3017 				block_size = scsi_4btoul(rdcap->length);
3018 				maxsector = scsi_4btoul(rdcap->addr);
3019 				lbppbe = 0;
3020 				lalba = 0;
3021 
3022 				/*
3023 				 * According to SBC-2, if the standard 10
3024 				 * byte READ CAPACITY command returns 2^32,
3025 				 * we should issue the 16 byte version of
3026 				 * the command, since the device in question
3027 				 * has more sectors than can be represented
3028 				 * with the short version of the command.
3029 				 */
3030 				if (maxsector == 0xffffffff) {
3031 					free(rdcap, M_SCSIDA);
3032 					xpt_release_ccb(done_ccb);
3033 					softc->state = DA_STATE_PROBE_RC16;
3034 					xpt_schedule(periph, priority);
3035 					return;
3036 				}
3037 			} else {
3038 				block_size = scsi_4btoul(rcaplong->length);
3039 				maxsector = scsi_8btou64(rcaplong->addr);
3040 				lbppbe = rcaplong->prot_lbppbe & SRC16_LBPPBE;
3041 				lalba = scsi_2btoul(rcaplong->lalba_lbp);
3042 			}
3043 
3044 			/*
3045 			 * Because GEOM code just will panic us if we
3046 			 * give them an 'illegal' value we'll avoid that
3047 			 * here.
3048 			 */
3049 			if (block_size == 0 && maxsector == 0) {
3050 				block_size = 512;
3051 				maxsector = -1;
3052 			}
3053 			if (block_size >= MAXPHYS || block_size == 0) {
3054 				xpt_print(periph->path,
3055 				    "unsupportable block size %ju\n",
3056 				    (uintmax_t) block_size);
3057 				announce_buf[0] = '\0';
3058 				cam_periph_invalidate(periph);
3059 			} else {
3060 				/*
3061 				 * We pass rcaplong into dasetgeom(),
3062 				 * because it will only use it if it is
3063 				 * non-NULL.
3064 				 */
3065 				dasetgeom(periph, block_size, maxsector,
3066 					  rcaplong, sizeof(*rcaplong));
3067 				lbp = (lalba & SRC16_LBPME_A);
3068 				dp = &softc->params;
3069 				snprintf(announce_buf, sizeof(announce_buf),
3070 				        "%juMB (%ju %u byte sectors: %dH %dS/T "
3071                                         "%dC)", (uintmax_t)
3072 	                                (((uintmax_t)dp->secsize *
3073 				        dp->sectors) / (1024*1024)),
3074 			                (uintmax_t)dp->sectors,
3075 				        dp->secsize, dp->heads,
3076                                         dp->secs_per_track, dp->cylinders);
3077 			}
3078 		} else {
3079 			int	error;
3080 
3081 			announce_buf[0] = '\0';
3082 
3083 			/*
3084 			 * Retry any UNIT ATTENTION type errors.  They
3085 			 * are expected at boot.
3086 			 */
3087 			error = daerror(done_ccb, CAM_RETRY_SELTO,
3088 					SF_RETRY_UA|SF_NO_PRINT);
3089 			if (error == ERESTART) {
3090 				/*
3091 				 * A retry was scheuled, so
3092 				 * just return.
3093 				 */
3094 				return;
3095 			} else if (error != 0) {
3096 				int asc, ascq;
3097 				int sense_key, error_code;
3098 				int have_sense;
3099 				cam_status status;
3100 				struct ccb_getdev cgd;
3101 
3102 				/* Don't wedge this device's queue */
3103 				status = done_ccb->ccb_h.status;
3104 				if ((status & CAM_DEV_QFRZN) != 0)
3105 					cam_release_devq(done_ccb->ccb_h.path,
3106 							 /*relsim_flags*/0,
3107 							 /*reduction*/0,
3108 							 /*timeout*/0,
3109 							 /*getcount_only*/0);
3110 
3111 
3112 				xpt_setup_ccb(&cgd.ccb_h,
3113 					      done_ccb->ccb_h.path,
3114 					      CAM_PRIORITY_NORMAL);
3115 				cgd.ccb_h.func_code = XPT_GDEV_TYPE;
3116 				xpt_action((union ccb *)&cgd);
3117 
3118 				if (scsi_extract_sense_ccb(done_ccb,
3119 				    &error_code, &sense_key, &asc, &ascq))
3120 					have_sense = TRUE;
3121 				else
3122 					have_sense = FALSE;
3123 
3124 				/*
3125 				 * If we tried READ CAPACITY(16) and failed,
3126 				 * fallback to READ CAPACITY(10).
3127 				 */
3128 				if ((state == DA_CCB_PROBE_RC16) &&
3129 				    (softc->flags & DA_FLAG_CAN_RC16) &&
3130 				    (((csio->ccb_h.status & CAM_STATUS_MASK) ==
3131 					CAM_REQ_INVALID) ||
3132 				     ((have_sense) &&
3133 				      (error_code == SSD_CURRENT_ERROR) &&
3134 				      (sense_key == SSD_KEY_ILLEGAL_REQUEST)))) {
3135 					softc->flags &= ~DA_FLAG_CAN_RC16;
3136 					free(rdcap, M_SCSIDA);
3137 					xpt_release_ccb(done_ccb);
3138 					softc->state = DA_STATE_PROBE_RC;
3139 					xpt_schedule(periph, priority);
3140 					return;
3141 				} else
3142 				/*
3143 				 * Attach to anything that claims to be a
3144 				 * direct access or optical disk device,
3145 				 * as long as it doesn't return a "Logical
3146 				 * unit not supported" (0x25) error.
3147 				 */
3148 				if ((have_sense) && (asc != 0x25)
3149 				 && (error_code == SSD_CURRENT_ERROR)) {
3150 					const char *sense_key_desc;
3151 					const char *asc_desc;
3152 
3153 					dasetgeom(periph, 512, -1, NULL, 0);
3154 					scsi_sense_desc(sense_key, asc, ascq,
3155 							&cgd.inq_data,
3156 							&sense_key_desc,
3157 							&asc_desc);
3158 					snprintf(announce_buf,
3159 					    sizeof(announce_buf),
3160 						"Attempt to query device "
3161 						"size failed: %s, %s",
3162 						sense_key_desc,
3163 						asc_desc);
3164 				} else {
3165 					if (have_sense)
3166 						scsi_sense_print(
3167 							&done_ccb->csio);
3168 					else {
3169 						xpt_print(periph->path,
3170 						    "got CAM status %#x\n",
3171 						    done_ccb->ccb_h.status);
3172 					}
3173 
3174 					xpt_print(periph->path, "fatal error, "
3175 					    "failed to attach to device\n");
3176 
3177 					/*
3178 					 * Free up resources.
3179 					 */
3180 					cam_periph_invalidate(periph);
3181 				}
3182 			}
3183 		}
3184 		free(csio->data_ptr, M_SCSIDA);
3185 		if (announce_buf[0] != '\0' && ((softc->flags & DA_FLAG_PROBED) == 0)) {
3186 			/*
3187 			 * Create our sysctl variables, now that we know
3188 			 * we have successfully attached.
3189 			 */
3190 			/* increase the refcount */
3191 			if (cam_periph_acquire(periph) == CAM_REQ_CMP) {
3192 				taskqueue_enqueue(taskqueue_thread,
3193 						  &softc->sysctl_task);
3194 				xpt_announce_periph(periph, announce_buf);
3195 				xpt_announce_quirks(periph, softc->quirks,
3196 				    DA_Q_BIT_STRING);
3197 			} else {
3198 				xpt_print(periph->path, "fatal error, "
3199 				    "could not acquire reference count\n");
3200 			}
3201 		}
3202 
3203 		/* Ensure re-probe doesn't see old delete. */
3204 		softc->delete_available = 0;
3205 		if (lbp) {
3206 			/*
3207 			 * Based on older SBC-3 spec revisions
3208 			 * any of the UNMAP methods "may" be
3209 			 * available via LBP given this flag so
3210 			 * we flag all of them as availble and
3211 			 * then remove those which further
3212 			 * probes confirm aren't available
3213 			 * later.
3214 			 *
3215 			 * We could also check readcap(16) p_type
3216 			 * flag to exclude one or more invalid
3217 			 * write same (X) types here
3218 			 */
3219 			dadeleteflag(softc, DA_DELETE_WS16, 1);
3220 			dadeleteflag(softc, DA_DELETE_WS10, 1);
3221 			dadeleteflag(softc, DA_DELETE_ZERO, 1);
3222 			dadeleteflag(softc, DA_DELETE_UNMAP, 1);
3223 
3224 			xpt_release_ccb(done_ccb);
3225 			softc->state = DA_STATE_PROBE_LBP;
3226 			xpt_schedule(periph, priority);
3227 			return;
3228 		}
3229 
3230 		xpt_release_ccb(done_ccb);
3231 		softc->state = DA_STATE_PROBE_BDC;
3232 		xpt_schedule(periph, priority);
3233 		return;
3234 	}
3235 	case DA_CCB_PROBE_LBP:
3236 	{
3237 		struct scsi_vpd_logical_block_prov *lbp;
3238 
3239 		lbp = (struct scsi_vpd_logical_block_prov *)csio->data_ptr;
3240 
3241 		if ((csio->ccb_h.status & CAM_STATUS_MASK) == CAM_REQ_CMP) {
3242 			/*
3243 			 * T10/1799-D Revision 31 states at least one of these
3244 			 * must be supported but we don't currently enforce this.
3245 			 */
3246 			dadeleteflag(softc, DA_DELETE_WS16,
3247 				     (lbp->flags & SVPD_LBP_WS16));
3248 			dadeleteflag(softc, DA_DELETE_WS10,
3249 				     (lbp->flags & SVPD_LBP_WS10));
3250 			dadeleteflag(softc, DA_DELETE_ZERO,
3251 				     (lbp->flags & SVPD_LBP_WS10));
3252 			dadeleteflag(softc, DA_DELETE_UNMAP,
3253 				     (lbp->flags & SVPD_LBP_UNMAP));
3254 
3255 			if (lbp->flags & SVPD_LBP_UNMAP) {
3256 				free(lbp, M_SCSIDA);
3257 				xpt_release_ccb(done_ccb);
3258 				softc->state = DA_STATE_PROBE_BLK_LIMITS;
3259 				xpt_schedule(periph, priority);
3260 				return;
3261 			}
3262 		} else {
3263 			int error;
3264 			error = daerror(done_ccb, CAM_RETRY_SELTO,
3265 					SF_RETRY_UA|SF_NO_PRINT);
3266 			if (error == ERESTART)
3267 				return;
3268 			else if (error != 0) {
3269 				if ((done_ccb->ccb_h.status & CAM_DEV_QFRZN) != 0) {
3270 					/* Don't wedge this device's queue */
3271 					cam_release_devq(done_ccb->ccb_h.path,
3272 							 /*relsim_flags*/0,
3273 							 /*reduction*/0,
3274 							 /*timeout*/0,
3275 							 /*getcount_only*/0);
3276 				}
3277 
3278 				/*
3279 				 * Failure indicates we don't support any SBC-3
3280 				 * delete methods with UNMAP
3281 				 */
3282 			}
3283 		}
3284 
3285 		free(lbp, M_SCSIDA);
3286 		xpt_release_ccb(done_ccb);
3287 		softc->state = DA_STATE_PROBE_BDC;
3288 		xpt_schedule(periph, priority);
3289 		return;
3290 	}
3291 	case DA_CCB_PROBE_BLK_LIMITS:
3292 	{
3293 		struct scsi_vpd_block_limits *block_limits;
3294 
3295 		block_limits = (struct scsi_vpd_block_limits *)csio->data_ptr;
3296 
3297 		if ((csio->ccb_h.status & CAM_STATUS_MASK) == CAM_REQ_CMP) {
3298 			uint32_t max_unmap_lba_cnt = scsi_4btoul(
3299 				block_limits->max_unmap_lba_cnt);
3300 			uint32_t max_unmap_blk_cnt = scsi_4btoul(
3301 				block_limits->max_unmap_blk_cnt);
3302 			uint64_t ws_max_blks = scsi_8btou64(
3303 				block_limits->max_write_same_length);
3304 			/*
3305 			 * We should already support UNMAP but we check lba
3306 			 * and block count to be sure
3307 			 */
3308 			if (max_unmap_lba_cnt != 0x00L &&
3309 			    max_unmap_blk_cnt != 0x00L) {
3310 				softc->unmap_max_lba = max_unmap_lba_cnt;
3311 				softc->unmap_max_ranges = min(max_unmap_blk_cnt,
3312 					UNMAP_MAX_RANGES);
3313 			} else {
3314 				/*
3315 				 * Unexpected UNMAP limits which means the
3316 				 * device doesn't actually support UNMAP
3317 				 */
3318 				dadeleteflag(softc, DA_DELETE_UNMAP, 0);
3319 			}
3320 
3321 			if (ws_max_blks != 0x00L)
3322 				softc->ws_max_blks = ws_max_blks;
3323 		} else {
3324 			int error;
3325 			error = daerror(done_ccb, CAM_RETRY_SELTO,
3326 					SF_RETRY_UA|SF_NO_PRINT);
3327 			if (error == ERESTART)
3328 				return;
3329 			else if (error != 0) {
3330 				if ((done_ccb->ccb_h.status & CAM_DEV_QFRZN) != 0) {
3331 					/* Don't wedge this device's queue */
3332 					cam_release_devq(done_ccb->ccb_h.path,
3333 							 /*relsim_flags*/0,
3334 							 /*reduction*/0,
3335 							 /*timeout*/0,
3336 							 /*getcount_only*/0);
3337 				}
3338 
3339 				/*
3340 				 * Failure here doesn't mean UNMAP is not
3341 				 * supported as this is an optional page.
3342 				 */
3343 				softc->unmap_max_lba = 1;
3344 				softc->unmap_max_ranges = 1;
3345 			}
3346 		}
3347 
3348 		free(block_limits, M_SCSIDA);
3349 		xpt_release_ccb(done_ccb);
3350 		softc->state = DA_STATE_PROBE_BDC;
3351 		xpt_schedule(periph, priority);
3352 		return;
3353 	}
3354 	case DA_CCB_PROBE_BDC:
3355 	{
3356 		struct scsi_vpd_block_characteristics *bdc;
3357 
3358 		bdc = (struct scsi_vpd_block_characteristics *)csio->data_ptr;
3359 
3360 		if ((csio->ccb_h.status & CAM_STATUS_MASK) == CAM_REQ_CMP) {
3361 			/*
3362 			 * Disable queue sorting for non-rotational media
3363 			 * by default.
3364 			 */
3365 			if (scsi_2btoul(bdc->medium_rotation_rate) ==
3366 			    SVPD_BDC_RATE_NONE_ROTATING)
3367 				softc->sort_io_queue = 0;
3368 		} else {
3369 			int error;
3370 			error = daerror(done_ccb, CAM_RETRY_SELTO,
3371 					SF_RETRY_UA|SF_NO_PRINT);
3372 			if (error == ERESTART)
3373 				return;
3374 			else if (error != 0) {
3375 				if ((done_ccb->ccb_h.status & CAM_DEV_QFRZN) != 0) {
3376 					/* Don't wedge this device's queue */
3377 					cam_release_devq(done_ccb->ccb_h.path,
3378 							 /*relsim_flags*/0,
3379 							 /*reduction*/0,
3380 							 /*timeout*/0,
3381 							 /*getcount_only*/0);
3382 				}
3383 			}
3384 		}
3385 
3386 		free(bdc, M_SCSIDA);
3387 		xpt_release_ccb(done_ccb);
3388 		softc->state = DA_STATE_PROBE_ATA;
3389 		xpt_schedule(periph, priority);
3390 		return;
3391 	}
3392 	case DA_CCB_PROBE_ATA:
3393 	{
3394 		int i;
3395 		struct ata_params *ata_params;
3396 		int16_t *ptr;
3397 
3398 		ata_params = (struct ata_params *)csio->data_ptr;
3399 		ptr = (uint16_t *)ata_params;
3400 
3401 		if ((csio->ccb_h.status & CAM_STATUS_MASK) == CAM_REQ_CMP) {
3402 			for (i = 0; i < sizeof(*ata_params) / 2; i++)
3403 				ptr[i] = le16toh(ptr[i]);
3404 			if (ata_params->support_dsm & ATA_SUPPORT_DSM_TRIM) {
3405 				dadeleteflag(softc, DA_DELETE_ATA_TRIM, 1);
3406 				if (ata_params->max_dsm_blocks != 0)
3407 					softc->trim_max_ranges = min(
3408 					  softc->trim_max_ranges,
3409 					  ata_params->max_dsm_blocks *
3410 					  ATA_DSM_BLK_RANGES);
3411 			}
3412 			/*
3413 			 * Disable queue sorting for non-rotational media
3414 			 * by default.
3415 			 */
3416 			if (ata_params->media_rotation_rate == 1)
3417 				softc->sort_io_queue = 0;
3418 		} else {
3419 			int error;
3420 			error = daerror(done_ccb, CAM_RETRY_SELTO,
3421 					SF_RETRY_UA|SF_NO_PRINT);
3422 			if (error == ERESTART)
3423 				return;
3424 			else if (error != 0) {
3425 				if ((done_ccb->ccb_h.status & CAM_DEV_QFRZN) != 0) {
3426 					/* Don't wedge this device's queue */
3427 					cam_release_devq(done_ccb->ccb_h.path,
3428 							 /*relsim_flags*/0,
3429 							 /*reduction*/0,
3430 							 /*timeout*/0,
3431 							 /*getcount_only*/0);
3432 				}
3433 			}
3434 		}
3435 
3436 		free(ata_params, M_SCSIDA);
3437 		daprobedone(periph, done_ccb);
3438 		return;
3439 	}
3440 	case DA_CCB_WAITING:
3441 	{
3442 		/* Caller will release the CCB */
3443 		wakeup(&done_ccb->ccb_h.cbfcnp);
3444 		return;
3445 	}
3446 	case DA_CCB_DUMP:
3447 		/* No-op.  We're polling */
3448 		return;
3449 	case DA_CCB_TUR:
3450 	{
3451 		if ((done_ccb->ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) {
3452 
3453 			if (daerror(done_ccb, CAM_RETRY_SELTO,
3454 			    SF_RETRY_UA | SF_NO_RECOVERY | SF_NO_PRINT) ==
3455 			    ERESTART)
3456 				return;
3457 			if ((done_ccb->ccb_h.status & CAM_DEV_QFRZN) != 0)
3458 				cam_release_devq(done_ccb->ccb_h.path,
3459 						 /*relsim_flags*/0,
3460 						 /*reduction*/0,
3461 						 /*timeout*/0,
3462 						 /*getcount_only*/0);
3463 		}
3464 		xpt_release_ccb(done_ccb);
3465 		cam_periph_release_locked(periph);
3466 		return;
3467 	}
3468 	default:
3469 		break;
3470 	}
3471 	xpt_release_ccb(done_ccb);
3472 }
3473 
3474 static void
3475 dareprobe(struct cam_periph *periph)
3476 {
3477 	struct da_softc	  *softc;
3478 	cam_status status;
3479 
3480 	softc = (struct da_softc *)periph->softc;
3481 
3482 	/* Probe in progress; don't interfere. */
3483 	if (softc->state != DA_STATE_NORMAL)
3484 		return;
3485 
3486 	status = cam_periph_acquire(periph);
3487 	KASSERT(status == CAM_REQ_CMP,
3488 	    ("dareprobe: cam_periph_acquire failed"));
3489 
3490 	if (softc->flags & DA_FLAG_CAN_RC16)
3491 		softc->state = DA_STATE_PROBE_RC16;
3492 	else
3493 		softc->state = DA_STATE_PROBE_RC;
3494 
3495 	xpt_schedule(periph, CAM_PRIORITY_DEV);
3496 }
3497 
3498 static int
3499 daerror(union ccb *ccb, u_int32_t cam_flags, u_int32_t sense_flags)
3500 {
3501 	struct da_softc	  *softc;
3502 	struct cam_periph *periph;
3503 	int error, error_code, sense_key, asc, ascq;
3504 
3505 	periph = xpt_path_periph(ccb->ccb_h.path);
3506 	softc = (struct da_softc *)periph->softc;
3507 
3508  	/*
3509 	 * Automatically detect devices that do not support
3510  	 * READ(6)/WRITE(6) and upgrade to using 10 byte cdbs.
3511  	 */
3512 	error = 0;
3513 	if ((ccb->ccb_h.status & CAM_STATUS_MASK) == CAM_REQ_INVALID) {
3514 		error = cmd6workaround(ccb);
3515 	} else if (scsi_extract_sense_ccb(ccb,
3516 	    &error_code, &sense_key, &asc, &ascq)) {
3517 		if (sense_key == SSD_KEY_ILLEGAL_REQUEST)
3518  			error = cmd6workaround(ccb);
3519 		/*
3520 		 * If the target replied with CAPACITY DATA HAS CHANGED UA,
3521 		 * query the capacity and notify upper layers.
3522 		 */
3523 		else if (sense_key == SSD_KEY_UNIT_ATTENTION &&
3524 		    asc == 0x2A && ascq == 0x09) {
3525 			xpt_print(periph->path, "capacity data has changed\n");
3526 			dareprobe(periph);
3527 			sense_flags |= SF_NO_PRINT;
3528 		} else if (sense_key == SSD_KEY_UNIT_ATTENTION &&
3529 		    asc == 0x28 && ascq == 0x00)
3530 			disk_media_changed(softc->disk, M_NOWAIT);
3531 		else if (sense_key == SSD_KEY_NOT_READY &&
3532 		    asc == 0x3a && (softc->flags & DA_FLAG_PACK_INVALID) == 0) {
3533 			softc->flags |= DA_FLAG_PACK_INVALID;
3534 			disk_media_gone(softc->disk, M_NOWAIT);
3535 		}
3536 	}
3537 	if (error == ERESTART)
3538 		return (ERESTART);
3539 
3540 	/*
3541 	 * XXX
3542 	 * Until we have a better way of doing pack validation,
3543 	 * don't treat UAs as errors.
3544 	 */
3545 	sense_flags |= SF_RETRY_UA;
3546 	return(cam_periph_error(ccb, cam_flags, sense_flags,
3547 				&softc->saved_ccb));
3548 }
3549 
3550 static void
3551 damediapoll(void *arg)
3552 {
3553 	struct cam_periph *periph = arg;
3554 	struct da_softc *softc = periph->softc;
3555 
3556 	if (!softc->tur && softc->outstanding_cmds == 0) {
3557 		if (cam_periph_acquire(periph) == CAM_REQ_CMP) {
3558 			softc->tur = 1;
3559 			daschedule(periph);
3560 		}
3561 	}
3562 	/* Queue us up again */
3563 	if (da_poll_period != 0)
3564 		callout_schedule(&softc->mediapoll_c, da_poll_period * hz);
3565 }
3566 
3567 static void
3568 daprevent(struct cam_periph *periph, int action)
3569 {
3570 	struct	da_softc *softc;
3571 	union	ccb *ccb;
3572 	int	error;
3573 
3574 	softc = (struct da_softc *)periph->softc;
3575 
3576 	if (((action == PR_ALLOW)
3577 	  && (softc->flags & DA_FLAG_PACK_LOCKED) == 0)
3578 	 || ((action == PR_PREVENT)
3579 	  && (softc->flags & DA_FLAG_PACK_LOCKED) != 0)) {
3580 		return;
3581 	}
3582 
3583 	ccb = cam_periph_getccb(periph, CAM_PRIORITY_NORMAL);
3584 
3585 	scsi_prevent(&ccb->csio,
3586 		     /*retries*/1,
3587 		     /*cbcfp*/dadone,
3588 		     MSG_SIMPLE_Q_TAG,
3589 		     action,
3590 		     SSD_FULL_SIZE,
3591 		     5000);
3592 
3593 	error = cam_periph_runccb(ccb, daerror, CAM_RETRY_SELTO,
3594 	    SF_RETRY_UA | SF_NO_PRINT, softc->disk->d_devstat);
3595 
3596 	if (error == 0) {
3597 		if (action == PR_ALLOW)
3598 			softc->flags &= ~DA_FLAG_PACK_LOCKED;
3599 		else
3600 			softc->flags |= DA_FLAG_PACK_LOCKED;
3601 	}
3602 
3603 	xpt_release_ccb(ccb);
3604 }
3605 
3606 static void
3607 dasetgeom(struct cam_periph *periph, uint32_t block_len, uint64_t maxsector,
3608 	  struct scsi_read_capacity_data_long *rcaplong, size_t rcap_len)
3609 {
3610 	struct ccb_calc_geometry ccg;
3611 	struct da_softc *softc;
3612 	struct disk_params *dp;
3613 	u_int lbppbe, lalba;
3614 	int error;
3615 
3616 	softc = (struct da_softc *)periph->softc;
3617 
3618 	dp = &softc->params;
3619 	dp->secsize = block_len;
3620 	dp->sectors = maxsector + 1;
3621 	if (rcaplong != NULL) {
3622 		lbppbe = rcaplong->prot_lbppbe & SRC16_LBPPBE;
3623 		lalba = scsi_2btoul(rcaplong->lalba_lbp);
3624 		lalba &= SRC16_LALBA_A;
3625 	} else {
3626 		lbppbe = 0;
3627 		lalba = 0;
3628 	}
3629 
3630 	if (lbppbe > 0) {
3631 		dp->stripesize = block_len << lbppbe;
3632 		dp->stripeoffset = (dp->stripesize - block_len * lalba) %
3633 		    dp->stripesize;
3634 	} else if (softc->quirks & DA_Q_4K) {
3635 		dp->stripesize = 4096;
3636 		dp->stripeoffset = 0;
3637 	} else {
3638 		dp->stripesize = 0;
3639 		dp->stripeoffset = 0;
3640 	}
3641 	/*
3642 	 * Have the controller provide us with a geometry
3643 	 * for this disk.  The only time the geometry
3644 	 * matters is when we boot and the controller
3645 	 * is the only one knowledgeable enough to come
3646 	 * up with something that will make this a bootable
3647 	 * device.
3648 	 */
3649 	xpt_setup_ccb(&ccg.ccb_h, periph->path, CAM_PRIORITY_NORMAL);
3650 	ccg.ccb_h.func_code = XPT_CALC_GEOMETRY;
3651 	ccg.block_size = dp->secsize;
3652 	ccg.volume_size = dp->sectors;
3653 	ccg.heads = 0;
3654 	ccg.secs_per_track = 0;
3655 	ccg.cylinders = 0;
3656 	xpt_action((union ccb*)&ccg);
3657 	if ((ccg.ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) {
3658 		/*
3659 		 * We don't know what went wrong here- but just pick
3660 		 * a geometry so we don't have nasty things like divide
3661 		 * by zero.
3662 		 */
3663 		dp->heads = 255;
3664 		dp->secs_per_track = 255;
3665 		dp->cylinders = dp->sectors / (255 * 255);
3666 		if (dp->cylinders == 0) {
3667 			dp->cylinders = 1;
3668 		}
3669 	} else {
3670 		dp->heads = ccg.heads;
3671 		dp->secs_per_track = ccg.secs_per_track;
3672 		dp->cylinders = ccg.cylinders;
3673 	}
3674 
3675 	/*
3676 	 * If the user supplied a read capacity buffer, and if it is
3677 	 * different than the previous buffer, update the data in the EDT.
3678 	 * If it's the same, we don't bother.  This avoids sending an
3679 	 * update every time someone opens this device.
3680 	 */
3681 	if ((rcaplong != NULL)
3682 	 && (bcmp(rcaplong, &softc->rcaplong,
3683 		  min(sizeof(softc->rcaplong), rcap_len)) != 0)) {
3684 		struct ccb_dev_advinfo cdai;
3685 
3686 		xpt_setup_ccb(&cdai.ccb_h, periph->path, CAM_PRIORITY_NORMAL);
3687 		cdai.ccb_h.func_code = XPT_DEV_ADVINFO;
3688 		cdai.buftype = CDAI_TYPE_RCAPLONG;
3689 		cdai.flags |= CDAI_FLAG_STORE;
3690 		cdai.bufsiz = rcap_len;
3691 		cdai.buf = (uint8_t *)rcaplong;
3692 		xpt_action((union ccb *)&cdai);
3693 		if ((cdai.ccb_h.status & CAM_DEV_QFRZN) != 0)
3694 			cam_release_devq(cdai.ccb_h.path, 0, 0, 0, FALSE);
3695 		if (cdai.ccb_h.status != CAM_REQ_CMP) {
3696 			xpt_print(periph->path, "%s: failed to set read "
3697 				  "capacity advinfo\n", __func__);
3698 			/* Use cam_error_print() to decode the status */
3699 			cam_error_print((union ccb *)&cdai, CAM_ESF_CAM_STATUS,
3700 					CAM_EPF_ALL);
3701 		} else {
3702 			bcopy(rcaplong, &softc->rcaplong,
3703 			      min(sizeof(softc->rcaplong), rcap_len));
3704 		}
3705 	}
3706 
3707 	softc->disk->d_sectorsize = softc->params.secsize;
3708 	softc->disk->d_mediasize = softc->params.secsize * (off_t)softc->params.sectors;
3709 	softc->disk->d_stripesize = softc->params.stripesize;
3710 	softc->disk->d_stripeoffset = softc->params.stripeoffset;
3711 	/* XXX: these are not actually "firmware" values, so they may be wrong */
3712 	softc->disk->d_fwsectors = softc->params.secs_per_track;
3713 	softc->disk->d_fwheads = softc->params.heads;
3714 	softc->disk->d_devstat->block_size = softc->params.secsize;
3715 	softc->disk->d_devstat->flags &= ~DEVSTAT_BS_UNAVAILABLE;
3716 
3717 	error = disk_resize(softc->disk, M_NOWAIT);
3718 	if (error != 0)
3719 		xpt_print(periph->path, "disk_resize(9) failed, error = %d\n", error);
3720 }
3721 
3722 static void
3723 dasendorderedtag(void *arg)
3724 {
3725 	struct da_softc *softc = arg;
3726 
3727 	if (da_send_ordered) {
3728 		if ((softc->ordered_tag_count == 0)
3729 		 && ((softc->flags & DA_FLAG_WENT_IDLE) == 0)) {
3730 			softc->flags |= DA_FLAG_NEED_OTAG;
3731 		}
3732 		if (softc->outstanding_cmds > 0)
3733 			softc->flags &= ~DA_FLAG_WENT_IDLE;
3734 
3735 		softc->ordered_tag_count = 0;
3736 	}
3737 	/* Queue us up again */
3738 	callout_reset(&softc->sendordered_c,
3739 	    (da_default_timeout * hz) / DA_ORDEREDTAG_INTERVAL,
3740 	    dasendorderedtag, softc);
3741 }
3742 
3743 /*
3744  * Step through all DA peripheral drivers, and if the device is still open,
3745  * sync the disk cache to physical media.
3746  */
3747 static void
3748 dashutdown(void * arg, int howto)
3749 {
3750 	struct cam_periph *periph;
3751 	struct da_softc *softc;
3752 	union ccb *ccb;
3753 	int error;
3754 
3755 	CAM_PERIPH_FOREACH(periph, &dadriver) {
3756 		softc = (struct da_softc *)periph->softc;
3757 		if (SCHEDULER_STOPPED()) {
3758 			/* If we paniced with the lock held, do not recurse. */
3759 			if (!cam_periph_owned(periph) &&
3760 			    (softc->flags & DA_FLAG_OPEN)) {
3761 				dadump(softc->disk, NULL, 0, 0, 0);
3762 			}
3763 			continue;
3764 		}
3765 		cam_periph_lock(periph);
3766 
3767 		/*
3768 		 * We only sync the cache if the drive is still open, and
3769 		 * if the drive is capable of it..
3770 		 */
3771 		if (((softc->flags & DA_FLAG_OPEN) == 0)
3772 		 || (softc->quirks & DA_Q_NO_SYNC_CACHE)) {
3773 			cam_periph_unlock(periph);
3774 			continue;
3775 		}
3776 
3777 		ccb = cam_periph_getccb(periph, CAM_PRIORITY_NORMAL);
3778 		scsi_synchronize_cache(&ccb->csio,
3779 				       /*retries*/0,
3780 				       /*cbfcnp*/dadone,
3781 				       MSG_SIMPLE_Q_TAG,
3782 				       /*begin_lba*/0, /* whole disk */
3783 				       /*lb_count*/0,
3784 				       SSD_FULL_SIZE,
3785 				       60 * 60 * 1000);
3786 
3787 		error = cam_periph_runccb(ccb, daerror, /*cam_flags*/0,
3788 		    /*sense_flags*/ SF_NO_RECOVERY | SF_NO_RETRY | SF_QUIET_IR,
3789 		    softc->disk->d_devstat);
3790 		if (error != 0)
3791 			xpt_print(periph->path, "Synchronize cache failed\n");
3792 		xpt_release_ccb(ccb);
3793 		cam_periph_unlock(periph);
3794 	}
3795 }
3796 
3797 #else /* !_KERNEL */
3798 
3799 /*
3800  * XXX This is only left out of the kernel build to silence warnings.  If,
3801  * for some reason this function is used in the kernel, the ifdefs should
3802  * be moved so it is included both in the kernel and userland.
3803  */
3804 void
3805 scsi_format_unit(struct ccb_scsiio *csio, u_int32_t retries,
3806 		 void (*cbfcnp)(struct cam_periph *, union ccb *),
3807 		 u_int8_t tag_action, u_int8_t byte2, u_int16_t ileave,
3808 		 u_int8_t *data_ptr, u_int32_t dxfer_len, u_int8_t sense_len,
3809 		 u_int32_t timeout)
3810 {
3811 	struct scsi_format_unit *scsi_cmd;
3812 
3813 	scsi_cmd = (struct scsi_format_unit *)&csio->cdb_io.cdb_bytes;
3814 	scsi_cmd->opcode = FORMAT_UNIT;
3815 	scsi_cmd->byte2 = byte2;
3816 	scsi_ulto2b(ileave, scsi_cmd->interleave);
3817 
3818 	cam_fill_csio(csio,
3819 		      retries,
3820 		      cbfcnp,
3821 		      /*flags*/ (dxfer_len > 0) ? CAM_DIR_OUT : CAM_DIR_NONE,
3822 		      tag_action,
3823 		      data_ptr,
3824 		      dxfer_len,
3825 		      sense_len,
3826 		      sizeof(*scsi_cmd),
3827 		      timeout);
3828 }
3829 
3830 #endif /* _KERNEL */
3831