xref: /freebsd/sys/cam/cam_periph.c (revision e3e9c656c9003719ecd29ca5b28aff7671de9117)
1 /*-
2  * Common functions for CAM "type" (peripheral) drivers.
3  *
4  * Copyright (c) 1997, 1998 Justin T. Gibbs.
5  * Copyright (c) 1997, 1998, 1999, 2000 Kenneth D. Merry.
6  * All rights reserved.
7  *
8  * Redistribution and use in source and binary forms, with or without
9  * modification, are permitted provided that the following conditions
10  * are met:
11  * 1. Redistributions of source code must retain the above copyright
12  *    notice, this list of conditions, and the following disclaimer,
13  *    without modification, immediately at the beginning of the file.
14  * 2. The name of the author may not be used to endorse or promote products
15  *    derived from this software without specific prior written permission.
16  *
17  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
18  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20  * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE FOR
21  * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27  * SUCH DAMAGE.
28  */
29 
30 #include <sys/cdefs.h>
31 __FBSDID("$FreeBSD$");
32 
33 #include <sys/param.h>
34 #include <sys/systm.h>
35 #include <sys/types.h>
36 #include <sys/malloc.h>
37 #include <sys/kernel.h>
38 #include <sys/bio.h>
39 #include <sys/lock.h>
40 #include <sys/mutex.h>
41 #include <sys/buf.h>
42 #include <sys/proc.h>
43 #include <sys/devicestat.h>
44 #include <sys/bus.h>
45 #include <sys/sbuf.h>
46 #include <vm/vm.h>
47 #include <vm/vm_extern.h>
48 
49 #include <cam/cam.h>
50 #include <cam/cam_ccb.h>
51 #include <cam/cam_queue.h>
52 #include <cam/cam_xpt_periph.h>
53 #include <cam/cam_periph.h>
54 #include <cam/cam_debug.h>
55 #include <cam/cam_sim.h>
56 
57 #include <cam/scsi/scsi_all.h>
58 #include <cam/scsi/scsi_message.h>
59 #include <cam/scsi/scsi_pass.h>
60 
61 static	u_int		camperiphnextunit(struct periph_driver *p_drv,
62 					  u_int newunit, int wired,
63 					  path_id_t pathid, target_id_t target,
64 					  lun_id_t lun);
65 static	u_int		camperiphunit(struct periph_driver *p_drv,
66 				      path_id_t pathid, target_id_t target,
67 				      lun_id_t lun);
68 static	void		camperiphdone(struct cam_periph *periph,
69 					union ccb *done_ccb);
70 static  void		camperiphfree(struct cam_periph *periph);
71 static int		camperiphscsistatuserror(union ccb *ccb,
72 					        union ccb **orig_ccb,
73 						 cam_flags camflags,
74 						 u_int32_t sense_flags,
75 						 int *openings,
76 						 u_int32_t *relsim_flags,
77 						 u_int32_t *timeout,
78 						 u_int32_t  *action,
79 						 const char **action_string);
80 static	int		camperiphscsisenseerror(union ccb *ccb,
81 					        union ccb **orig_ccb,
82 					        cam_flags camflags,
83 					        u_int32_t sense_flags,
84 					        int *openings,
85 					        u_int32_t *relsim_flags,
86 					        u_int32_t *timeout,
87 					        u_int32_t *action,
88 					        const char **action_string);
89 static void		cam_periph_devctl_notify(union ccb *ccb);
90 
91 static int nperiph_drivers;
92 static int initialized = 0;
93 struct periph_driver **periph_drivers;
94 
95 static MALLOC_DEFINE(M_CAMPERIPH, "CAM periph", "CAM peripheral buffers");
96 
97 static int periph_selto_delay = 1000;
98 TUNABLE_INT("kern.cam.periph_selto_delay", &periph_selto_delay);
99 static int periph_noresrc_delay = 500;
100 TUNABLE_INT("kern.cam.periph_noresrc_delay", &periph_noresrc_delay);
101 static int periph_busy_delay = 500;
102 TUNABLE_INT("kern.cam.periph_busy_delay", &periph_busy_delay);
103 
104 
105 void
106 periphdriver_register(void *data)
107 {
108 	struct periph_driver *drv = (struct periph_driver *)data;
109 	struct periph_driver **newdrivers, **old;
110 	int ndrivers;
111 
112 again:
113 	ndrivers = nperiph_drivers + 2;
114 	newdrivers = malloc(sizeof(*newdrivers) * ndrivers, M_CAMPERIPH,
115 			    M_WAITOK);
116 	xpt_lock_buses();
117 	if (ndrivers != nperiph_drivers + 2) {
118 		/*
119 		 * Lost race against itself; go around.
120 		 */
121 		xpt_unlock_buses();
122 		free(newdrivers, M_CAMPERIPH);
123 		goto again;
124 	}
125 	if (periph_drivers)
126 		bcopy(periph_drivers, newdrivers,
127 		      sizeof(*newdrivers) * nperiph_drivers);
128 	newdrivers[nperiph_drivers] = drv;
129 	newdrivers[nperiph_drivers + 1] = NULL;
130 	old = periph_drivers;
131 	periph_drivers = newdrivers;
132 	nperiph_drivers++;
133 	xpt_unlock_buses();
134 	if (old)
135 		free(old, M_CAMPERIPH);
136 	/* If driver marked as early or it is late now, initialize it. */
137 	if (((drv->flags & CAM_PERIPH_DRV_EARLY) != 0 && initialized > 0) ||
138 	    initialized > 1)
139 		(*drv->init)();
140 }
141 
142 int
143 periphdriver_unregister(void *data)
144 {
145 	struct periph_driver *drv = (struct periph_driver *)data;
146 	int error, n;
147 
148 	/* If driver marked as early or it is late now, deinitialize it. */
149 	if (((drv->flags & CAM_PERIPH_DRV_EARLY) != 0 && initialized > 0) ||
150 	    initialized > 1) {
151 		if (drv->deinit == NULL) {
152 			printf("CAM periph driver '%s' doesn't have deinit.\n",
153 			    drv->driver_name);
154 			return (EOPNOTSUPP);
155 		}
156 		error = drv->deinit();
157 		if (error != 0)
158 			return (error);
159 	}
160 
161 	xpt_lock_buses();
162 	for (n = 0; n < nperiph_drivers && periph_drivers[n] != drv; n++)
163 		;
164 	KASSERT(n < nperiph_drivers,
165 	    ("Periph driver '%s' was not registered", drv->driver_name));
166 	for (; n + 1 < nperiph_drivers; n++)
167 		periph_drivers[n] = periph_drivers[n + 1];
168 	periph_drivers[n + 1] = NULL;
169 	nperiph_drivers--;
170 	xpt_unlock_buses();
171 	return (0);
172 }
173 
174 void
175 periphdriver_init(int level)
176 {
177 	int	i, early;
178 
179 	initialized = max(initialized, level);
180 	for (i = 0; periph_drivers[i] != NULL; i++) {
181 		early = (periph_drivers[i]->flags & CAM_PERIPH_DRV_EARLY) ? 1 : 2;
182 		if (early == initialized)
183 			(*periph_drivers[i]->init)();
184 	}
185 }
186 
187 cam_status
188 cam_periph_alloc(periph_ctor_t *periph_ctor,
189 		 periph_oninv_t *periph_oninvalidate,
190 		 periph_dtor_t *periph_dtor, periph_start_t *periph_start,
191 		 char *name, cam_periph_type type, struct cam_path *path,
192 		 ac_callback_t *ac_callback, ac_code code, void *arg)
193 {
194 	struct		periph_driver **p_drv;
195 	struct		cam_sim *sim;
196 	struct		cam_periph *periph;
197 	struct		cam_periph *cur_periph;
198 	path_id_t	path_id;
199 	target_id_t	target_id;
200 	lun_id_t	lun_id;
201 	cam_status	status;
202 	u_int		init_level;
203 
204 	init_level = 0;
205 	/*
206 	 * Handle Hot-Plug scenarios.  If there is already a peripheral
207 	 * of our type assigned to this path, we are likely waiting for
208 	 * final close on an old, invalidated, peripheral.  If this is
209 	 * the case, queue up a deferred call to the peripheral's async
210 	 * handler.  If it looks like a mistaken re-allocation, complain.
211 	 */
212 	if ((periph = cam_periph_find(path, name)) != NULL) {
213 
214 		if ((periph->flags & CAM_PERIPH_INVALID) != 0
215 		 && (periph->flags & CAM_PERIPH_NEW_DEV_FOUND) == 0) {
216 			periph->flags |= CAM_PERIPH_NEW_DEV_FOUND;
217 			periph->deferred_callback = ac_callback;
218 			periph->deferred_ac = code;
219 			return (CAM_REQ_INPROG);
220 		} else {
221 			printf("cam_periph_alloc: attempt to re-allocate "
222 			       "valid device %s%d rejected flags %#x "
223 			       "refcount %d\n", periph->periph_name,
224 			       periph->unit_number, periph->flags,
225 			       periph->refcount);
226 		}
227 		return (CAM_REQ_INVALID);
228 	}
229 
230 	periph = (struct cam_periph *)malloc(sizeof(*periph), M_CAMPERIPH,
231 					     M_NOWAIT|M_ZERO);
232 
233 	if (periph == NULL)
234 		return (CAM_RESRC_UNAVAIL);
235 
236 	init_level++;
237 
238 
239 	sim = xpt_path_sim(path);
240 	path_id = xpt_path_path_id(path);
241 	target_id = xpt_path_target_id(path);
242 	lun_id = xpt_path_lun_id(path);
243 	periph->periph_start = periph_start;
244 	periph->periph_dtor = periph_dtor;
245 	periph->periph_oninval = periph_oninvalidate;
246 	periph->type = type;
247 	periph->periph_name = name;
248 	periph->scheduled_priority = CAM_PRIORITY_NONE;
249 	periph->immediate_priority = CAM_PRIORITY_NONE;
250 	periph->refcount = 1;		/* Dropped by invalidation. */
251 	periph->sim = sim;
252 	SLIST_INIT(&periph->ccb_list);
253 	status = xpt_create_path(&path, periph, path_id, target_id, lun_id);
254 	if (status != CAM_REQ_CMP)
255 		goto failure;
256 	periph->path = path;
257 
258 	xpt_lock_buses();
259 	for (p_drv = periph_drivers; *p_drv != NULL; p_drv++) {
260 		if (strcmp((*p_drv)->driver_name, name) == 0)
261 			break;
262 	}
263 	if (*p_drv == NULL) {
264 		printf("cam_periph_alloc: invalid periph name '%s'\n", name);
265 		xpt_unlock_buses();
266 		xpt_free_path(periph->path);
267 		free(periph, M_CAMPERIPH);
268 		return (CAM_REQ_INVALID);
269 	}
270 	periph->unit_number = camperiphunit(*p_drv, path_id, target_id, lun_id);
271 	cur_periph = TAILQ_FIRST(&(*p_drv)->units);
272 	while (cur_periph != NULL
273 	    && cur_periph->unit_number < periph->unit_number)
274 		cur_periph = TAILQ_NEXT(cur_periph, unit_links);
275 	if (cur_periph != NULL) {
276 		KASSERT(cur_periph->unit_number != periph->unit_number, ("duplicate units on periph list"));
277 		TAILQ_INSERT_BEFORE(cur_periph, periph, unit_links);
278 	} else {
279 		TAILQ_INSERT_TAIL(&(*p_drv)->units, periph, unit_links);
280 		(*p_drv)->generation++;
281 	}
282 	xpt_unlock_buses();
283 
284 	init_level++;
285 
286 	status = xpt_add_periph(periph);
287 	if (status != CAM_REQ_CMP)
288 		goto failure;
289 
290 	init_level++;
291 	CAM_DEBUG(periph->path, CAM_DEBUG_INFO, ("Periph created\n"));
292 
293 	status = periph_ctor(periph, arg);
294 
295 	if (status == CAM_REQ_CMP)
296 		init_level++;
297 
298 failure:
299 	switch (init_level) {
300 	case 4:
301 		/* Initialized successfully */
302 		break;
303 	case 3:
304 		CAM_DEBUG(periph->path, CAM_DEBUG_INFO, ("Periph destroyed\n"));
305 		xpt_remove_periph(periph);
306 		/* FALLTHROUGH */
307 	case 2:
308 		xpt_lock_buses();
309 		TAILQ_REMOVE(&(*p_drv)->units, periph, unit_links);
310 		xpt_unlock_buses();
311 		xpt_free_path(periph->path);
312 		/* FALLTHROUGH */
313 	case 1:
314 		free(periph, M_CAMPERIPH);
315 		/* FALLTHROUGH */
316 	case 0:
317 		/* No cleanup to perform. */
318 		break;
319 	default:
320 		panic("%s: Unknown init level", __func__);
321 	}
322 	return(status);
323 }
324 
325 /*
326  * Find a peripheral structure with the specified path, target, lun,
327  * and (optionally) type.  If the name is NULL, this function will return
328  * the first peripheral driver that matches the specified path.
329  */
330 struct cam_periph *
331 cam_periph_find(struct cam_path *path, char *name)
332 {
333 	struct periph_driver **p_drv;
334 	struct cam_periph *periph;
335 
336 	xpt_lock_buses();
337 	for (p_drv = periph_drivers; *p_drv != NULL; p_drv++) {
338 
339 		if (name != NULL && (strcmp((*p_drv)->driver_name, name) != 0))
340 			continue;
341 
342 		TAILQ_FOREACH(periph, &(*p_drv)->units, unit_links) {
343 			if (xpt_path_comp(periph->path, path) == 0) {
344 				xpt_unlock_buses();
345 				cam_periph_assert(periph, MA_OWNED);
346 				return(periph);
347 			}
348 		}
349 		if (name != NULL) {
350 			xpt_unlock_buses();
351 			return(NULL);
352 		}
353 	}
354 	xpt_unlock_buses();
355 	return(NULL);
356 }
357 
358 /*
359  * Find peripheral driver instances attached to the specified path.
360  */
361 int
362 cam_periph_list(struct cam_path *path, struct sbuf *sb)
363 {
364 	struct sbuf local_sb;
365 	struct periph_driver **p_drv;
366 	struct cam_periph *periph;
367 	int count;
368 	int sbuf_alloc_len;
369 
370 	sbuf_alloc_len = 16;
371 retry:
372 	sbuf_new(&local_sb, NULL, sbuf_alloc_len, SBUF_FIXEDLEN);
373 	count = 0;
374 	xpt_lock_buses();
375 	for (p_drv = periph_drivers; *p_drv != NULL; p_drv++) {
376 
377 		TAILQ_FOREACH(periph, &(*p_drv)->units, unit_links) {
378 			if (xpt_path_comp(periph->path, path) != 0)
379 				continue;
380 
381 			if (sbuf_len(&local_sb) != 0)
382 				sbuf_cat(&local_sb, ",");
383 
384 			sbuf_printf(&local_sb, "%s%d", periph->periph_name,
385 				    periph->unit_number);
386 
387 			if (sbuf_error(&local_sb) == ENOMEM) {
388 				sbuf_alloc_len *= 2;
389 				xpt_unlock_buses();
390 				sbuf_delete(&local_sb);
391 				goto retry;
392 			}
393 			count++;
394 		}
395 	}
396 	xpt_unlock_buses();
397 	sbuf_finish(&local_sb);
398 	sbuf_cpy(sb, sbuf_data(&local_sb));
399 	sbuf_delete(&local_sb);
400 	return (count);
401 }
402 
403 cam_status
404 cam_periph_acquire(struct cam_periph *periph)
405 {
406 	cam_status status;
407 
408 	status = CAM_REQ_CMP_ERR;
409 	if (periph == NULL)
410 		return (status);
411 
412 	xpt_lock_buses();
413 	if ((periph->flags & CAM_PERIPH_INVALID) == 0) {
414 		periph->refcount++;
415 		status = CAM_REQ_CMP;
416 	}
417 	xpt_unlock_buses();
418 
419 	return (status);
420 }
421 
422 void
423 cam_periph_doacquire(struct cam_periph *periph)
424 {
425 
426 	xpt_lock_buses();
427 	KASSERT(periph->refcount >= 1,
428 	    ("cam_periph_doacquire() with refcount == %d", periph->refcount));
429 	periph->refcount++;
430 	xpt_unlock_buses();
431 }
432 
433 void
434 cam_periph_release_locked_buses(struct cam_periph *periph)
435 {
436 
437 	cam_periph_assert(periph, MA_OWNED);
438 	KASSERT(periph->refcount >= 1, ("periph->refcount >= 1"));
439 	if (--periph->refcount == 0)
440 		camperiphfree(periph);
441 }
442 
443 void
444 cam_periph_release_locked(struct cam_periph *periph)
445 {
446 
447 	if (periph == NULL)
448 		return;
449 
450 	xpt_lock_buses();
451 	cam_periph_release_locked_buses(periph);
452 	xpt_unlock_buses();
453 }
454 
455 void
456 cam_periph_release(struct cam_periph *periph)
457 {
458 	struct mtx *mtx;
459 
460 	if (periph == NULL)
461 		return;
462 
463 	cam_periph_assert(periph, MA_NOTOWNED);
464 	mtx = cam_periph_mtx(periph);
465 	mtx_lock(mtx);
466 	cam_periph_release_locked(periph);
467 	mtx_unlock(mtx);
468 }
469 
470 int
471 cam_periph_hold(struct cam_periph *periph, int priority)
472 {
473 	int error;
474 
475 	/*
476 	 * Increment the reference count on the peripheral
477 	 * while we wait for our lock attempt to succeed
478 	 * to ensure the peripheral doesn't disappear out
479 	 * from user us while we sleep.
480 	 */
481 
482 	if (cam_periph_acquire(periph) != CAM_REQ_CMP)
483 		return (ENXIO);
484 
485 	cam_periph_assert(periph, MA_OWNED);
486 	while ((periph->flags & CAM_PERIPH_LOCKED) != 0) {
487 		periph->flags |= CAM_PERIPH_LOCK_WANTED;
488 		if ((error = cam_periph_sleep(periph, periph, priority,
489 		    "caplck", 0)) != 0) {
490 			cam_periph_release_locked(periph);
491 			return (error);
492 		}
493 		if (periph->flags & CAM_PERIPH_INVALID) {
494 			cam_periph_release_locked(periph);
495 			return (ENXIO);
496 		}
497 	}
498 
499 	periph->flags |= CAM_PERIPH_LOCKED;
500 	return (0);
501 }
502 
503 void
504 cam_periph_unhold(struct cam_periph *periph)
505 {
506 
507 	cam_periph_assert(periph, MA_OWNED);
508 
509 	periph->flags &= ~CAM_PERIPH_LOCKED;
510 	if ((periph->flags & CAM_PERIPH_LOCK_WANTED) != 0) {
511 		periph->flags &= ~CAM_PERIPH_LOCK_WANTED;
512 		wakeup(periph);
513 	}
514 
515 	cam_periph_release_locked(periph);
516 }
517 
518 /*
519  * Look for the next unit number that is not currently in use for this
520  * peripheral type starting at "newunit".  Also exclude unit numbers that
521  * are reserved by for future "hardwiring" unless we already know that this
522  * is a potential wired device.  Only assume that the device is "wired" the
523  * first time through the loop since after that we'll be looking at unit
524  * numbers that did not match a wiring entry.
525  */
526 static u_int
527 camperiphnextunit(struct periph_driver *p_drv, u_int newunit, int wired,
528 		  path_id_t pathid, target_id_t target, lun_id_t lun)
529 {
530 	struct	cam_periph *periph;
531 	char	*periph_name;
532 	int	i, val, dunit, r;
533 	const char *dname, *strval;
534 
535 	periph_name = p_drv->driver_name;
536 	for (;;newunit++) {
537 
538 		for (periph = TAILQ_FIRST(&p_drv->units);
539 		     periph != NULL && periph->unit_number != newunit;
540 		     periph = TAILQ_NEXT(periph, unit_links))
541 			;
542 
543 		if (periph != NULL && periph->unit_number == newunit) {
544 			if (wired != 0) {
545 				xpt_print(periph->path, "Duplicate Wired "
546 				    "Device entry!\n");
547 				xpt_print(periph->path, "Second device (%s "
548 				    "device at scbus%d target %d lun %d) will "
549 				    "not be wired\n", periph_name, pathid,
550 				    target, lun);
551 				wired = 0;
552 			}
553 			continue;
554 		}
555 		if (wired)
556 			break;
557 
558 		/*
559 		 * Don't match entries like "da 4" as a wired down
560 		 * device, but do match entries like "da 4 target 5"
561 		 * or even "da 4 scbus 1".
562 		 */
563 		i = 0;
564 		dname = periph_name;
565 		for (;;) {
566 			r = resource_find_dev(&i, dname, &dunit, NULL, NULL);
567 			if (r != 0)
568 				break;
569 			/* if no "target" and no specific scbus, skip */
570 			if (resource_int_value(dname, dunit, "target", &val) &&
571 			    (resource_string_value(dname, dunit, "at",&strval)||
572 			     strcmp(strval, "scbus") == 0))
573 				continue;
574 			if (newunit == dunit)
575 				break;
576 		}
577 		if (r != 0)
578 			break;
579 	}
580 	return (newunit);
581 }
582 
583 static u_int
584 camperiphunit(struct periph_driver *p_drv, path_id_t pathid,
585 	      target_id_t target, lun_id_t lun)
586 {
587 	u_int	unit;
588 	int	wired, i, val, dunit;
589 	const char *dname, *strval;
590 	char	pathbuf[32], *periph_name;
591 
592 	periph_name = p_drv->driver_name;
593 	snprintf(pathbuf, sizeof(pathbuf), "scbus%d", pathid);
594 	unit = 0;
595 	i = 0;
596 	dname = periph_name;
597 	for (wired = 0; resource_find_dev(&i, dname, &dunit, NULL, NULL) == 0;
598 	     wired = 0) {
599 		if (resource_string_value(dname, dunit, "at", &strval) == 0) {
600 			if (strcmp(strval, pathbuf) != 0)
601 				continue;
602 			wired++;
603 		}
604 		if (resource_int_value(dname, dunit, "target", &val) == 0) {
605 			if (val != target)
606 				continue;
607 			wired++;
608 		}
609 		if (resource_int_value(dname, dunit, "lun", &val) == 0) {
610 			if (val != lun)
611 				continue;
612 			wired++;
613 		}
614 		if (wired != 0) {
615 			unit = dunit;
616 			break;
617 		}
618 	}
619 
620 	/*
621 	 * Either start from 0 looking for the next unit or from
622 	 * the unit number given in the resource config.  This way,
623 	 * if we have wildcard matches, we don't return the same
624 	 * unit number twice.
625 	 */
626 	unit = camperiphnextunit(p_drv, unit, wired, pathid, target, lun);
627 
628 	return (unit);
629 }
630 
631 void
632 cam_periph_invalidate(struct cam_periph *periph)
633 {
634 
635 	cam_periph_assert(periph, MA_OWNED);
636 	/*
637 	 * We only call this routine the first time a peripheral is
638 	 * invalidated.
639 	 */
640 	if ((periph->flags & CAM_PERIPH_INVALID) != 0)
641 		return;
642 
643 	CAM_DEBUG(periph->path, CAM_DEBUG_INFO, ("Periph invalidated\n"));
644 	if ((periph->flags & CAM_PERIPH_ANNOUNCED) && !rebooting)
645 		xpt_denounce_periph(periph);
646 	periph->flags |= CAM_PERIPH_INVALID;
647 	periph->flags &= ~CAM_PERIPH_NEW_DEV_FOUND;
648 	if (periph->periph_oninval != NULL)
649 		periph->periph_oninval(periph);
650 	cam_periph_release_locked(periph);
651 }
652 
653 static void
654 camperiphfree(struct cam_periph *periph)
655 {
656 	struct periph_driver **p_drv;
657 
658 	cam_periph_assert(periph, MA_OWNED);
659 	KASSERT(periph->periph_allocating == 0, ("%s%d: freed while allocating",
660 	    periph->periph_name, periph->unit_number));
661 	for (p_drv = periph_drivers; *p_drv != NULL; p_drv++) {
662 		if (strcmp((*p_drv)->driver_name, periph->periph_name) == 0)
663 			break;
664 	}
665 	if (*p_drv == NULL) {
666 		printf("camperiphfree: attempt to free non-existant periph\n");
667 		return;
668 	}
669 
670 	/*
671 	 * We need to set this flag before dropping the topology lock, to
672 	 * let anyone who is traversing the list that this peripheral is
673 	 * about to be freed, and there will be no more reference count
674 	 * checks.
675 	 */
676 	periph->flags |= CAM_PERIPH_FREE;
677 
678 	/*
679 	 * The peripheral destructor semantics dictate calling with only the
680 	 * SIM mutex held.  Since it might sleep, it should not be called
681 	 * with the topology lock held.
682 	 */
683 	xpt_unlock_buses();
684 
685 	/*
686 	 * We need to call the peripheral destructor prior to removing the
687 	 * peripheral from the list.  Otherwise, we risk running into a
688 	 * scenario where the peripheral unit number may get reused
689 	 * (because it has been removed from the list), but some resources
690 	 * used by the peripheral are still hanging around.  In particular,
691 	 * the devfs nodes used by some peripherals like the pass(4) driver
692 	 * aren't fully cleaned up until the destructor is run.  If the
693 	 * unit number is reused before the devfs instance is fully gone,
694 	 * devfs will panic.
695 	 */
696 	if (periph->periph_dtor != NULL)
697 		periph->periph_dtor(periph);
698 
699 	/*
700 	 * The peripheral list is protected by the topology lock.
701 	 */
702 	xpt_lock_buses();
703 
704 	TAILQ_REMOVE(&(*p_drv)->units, periph, unit_links);
705 	(*p_drv)->generation++;
706 
707 	xpt_remove_periph(periph);
708 
709 	xpt_unlock_buses();
710 	if ((periph->flags & CAM_PERIPH_ANNOUNCED) && !rebooting)
711 		xpt_print(periph->path, "Periph destroyed\n");
712 	else
713 		CAM_DEBUG(periph->path, CAM_DEBUG_INFO, ("Periph destroyed\n"));
714 
715 	if (periph->flags & CAM_PERIPH_NEW_DEV_FOUND) {
716 		union ccb ccb;
717 		void *arg;
718 
719 		switch (periph->deferred_ac) {
720 		case AC_FOUND_DEVICE:
721 			ccb.ccb_h.func_code = XPT_GDEV_TYPE;
722 			xpt_setup_ccb(&ccb.ccb_h, periph->path, CAM_PRIORITY_NORMAL);
723 			xpt_action(&ccb);
724 			arg = &ccb;
725 			break;
726 		case AC_PATH_REGISTERED:
727 			ccb.ccb_h.func_code = XPT_PATH_INQ;
728 			xpt_setup_ccb(&ccb.ccb_h, periph->path, CAM_PRIORITY_NORMAL);
729 			xpt_action(&ccb);
730 			arg = &ccb;
731 			break;
732 		default:
733 			arg = NULL;
734 			break;
735 		}
736 		periph->deferred_callback(NULL, periph->deferred_ac,
737 					  periph->path, arg);
738 	}
739 	xpt_free_path(periph->path);
740 	free(periph, M_CAMPERIPH);
741 	xpt_lock_buses();
742 }
743 
744 /*
745  * Map user virtual pointers into kernel virtual address space, so we can
746  * access the memory.  This is now a generic function that centralizes most
747  * of the sanity checks on the data flags, if any.
748  * This also only works for up to MAXPHYS memory.  Since we use
749  * buffers to map stuff in and out, we're limited to the buffer size.
750  */
751 int
752 cam_periph_mapmem(union ccb *ccb, struct cam_periph_map_info *mapinfo,
753     u_int maxmap)
754 {
755 	int numbufs, i, j;
756 	int flags[CAM_PERIPH_MAXMAPS];
757 	u_int8_t **data_ptrs[CAM_PERIPH_MAXMAPS];
758 	u_int32_t lengths[CAM_PERIPH_MAXMAPS];
759 	u_int32_t dirs[CAM_PERIPH_MAXMAPS];
760 
761 	if (maxmap == 0)
762 		maxmap = DFLTPHYS;	/* traditional default */
763 	else if (maxmap > MAXPHYS)
764 		maxmap = MAXPHYS;	/* for safety */
765 	switch(ccb->ccb_h.func_code) {
766 	case XPT_DEV_MATCH:
767 		if (ccb->cdm.match_buf_len == 0) {
768 			printf("cam_periph_mapmem: invalid match buffer "
769 			       "length 0\n");
770 			return(EINVAL);
771 		}
772 		if (ccb->cdm.pattern_buf_len > 0) {
773 			data_ptrs[0] = (u_int8_t **)&ccb->cdm.patterns;
774 			lengths[0] = ccb->cdm.pattern_buf_len;
775 			dirs[0] = CAM_DIR_OUT;
776 			data_ptrs[1] = (u_int8_t **)&ccb->cdm.matches;
777 			lengths[1] = ccb->cdm.match_buf_len;
778 			dirs[1] = CAM_DIR_IN;
779 			numbufs = 2;
780 		} else {
781 			data_ptrs[0] = (u_int8_t **)&ccb->cdm.matches;
782 			lengths[0] = ccb->cdm.match_buf_len;
783 			dirs[0] = CAM_DIR_IN;
784 			numbufs = 1;
785 		}
786 		/*
787 		 * This request will not go to the hardware, no reason
788 		 * to be so strict. vmapbuf() is able to map up to MAXPHYS.
789 		 */
790 		maxmap = MAXPHYS;
791 		break;
792 	case XPT_SCSI_IO:
793 	case XPT_CONT_TARGET_IO:
794 		if ((ccb->ccb_h.flags & CAM_DIR_MASK) == CAM_DIR_NONE)
795 			return(0);
796 		if ((ccb->ccb_h.flags & CAM_DATA_MASK) != CAM_DATA_VADDR)
797 			return (EINVAL);
798 		data_ptrs[0] = &ccb->csio.data_ptr;
799 		lengths[0] = ccb->csio.dxfer_len;
800 		dirs[0] = ccb->ccb_h.flags & CAM_DIR_MASK;
801 		numbufs = 1;
802 		break;
803 	case XPT_ATA_IO:
804 		if ((ccb->ccb_h.flags & CAM_DIR_MASK) == CAM_DIR_NONE)
805 			return(0);
806 		if ((ccb->ccb_h.flags & CAM_DATA_MASK) != CAM_DATA_VADDR)
807 			return (EINVAL);
808 		data_ptrs[0] = &ccb->ataio.data_ptr;
809 		lengths[0] = ccb->ataio.dxfer_len;
810 		dirs[0] = ccb->ccb_h.flags & CAM_DIR_MASK;
811 		numbufs = 1;
812 		break;
813 	case XPT_SMP_IO:
814 		data_ptrs[0] = &ccb->smpio.smp_request;
815 		lengths[0] = ccb->smpio.smp_request_len;
816 		dirs[0] = CAM_DIR_OUT;
817 		data_ptrs[1] = &ccb->smpio.smp_response;
818 		lengths[1] = ccb->smpio.smp_response_len;
819 		dirs[1] = CAM_DIR_IN;
820 		numbufs = 2;
821 		break;
822 	case XPT_DEV_ADVINFO:
823 		if (ccb->cdai.bufsiz == 0)
824 			return (0);
825 
826 		data_ptrs[0] = (uint8_t **)&ccb->cdai.buf;
827 		lengths[0] = ccb->cdai.bufsiz;
828 		dirs[0] = CAM_DIR_IN;
829 		numbufs = 1;
830 
831 		/*
832 		 * This request will not go to the hardware, no reason
833 		 * to be so strict. vmapbuf() is able to map up to MAXPHYS.
834 		 */
835 		maxmap = MAXPHYS;
836 		break;
837 	default:
838 		return(EINVAL);
839 		break; /* NOTREACHED */
840 	}
841 
842 	/*
843 	 * Check the transfer length and permissions first, so we don't
844 	 * have to unmap any previously mapped buffers.
845 	 */
846 	for (i = 0; i < numbufs; i++) {
847 
848 		flags[i] = 0;
849 
850 		/*
851 		 * The userland data pointer passed in may not be page
852 		 * aligned.  vmapbuf() truncates the address to a page
853 		 * boundary, so if the address isn't page aligned, we'll
854 		 * need enough space for the given transfer length, plus
855 		 * whatever extra space is necessary to make it to the page
856 		 * boundary.
857 		 */
858 		if ((lengths[i] +
859 		    (((vm_offset_t)(*data_ptrs[i])) & PAGE_MASK)) > maxmap){
860 			printf("cam_periph_mapmem: attempt to map %lu bytes, "
861 			       "which is greater than %lu\n",
862 			       (long)(lengths[i] +
863 			       (((vm_offset_t)(*data_ptrs[i])) & PAGE_MASK)),
864 			       (u_long)maxmap);
865 			return(E2BIG);
866 		}
867 
868 		if (dirs[i] & CAM_DIR_OUT) {
869 			flags[i] = BIO_WRITE;
870 		}
871 
872 		if (dirs[i] & CAM_DIR_IN) {
873 			flags[i] = BIO_READ;
874 		}
875 
876 	}
877 
878 	/*
879 	 * This keeps the kernel stack of current thread from getting
880 	 * swapped.  In low-memory situations where the kernel stack might
881 	 * otherwise get swapped out, this holds it and allows the thread
882 	 * to make progress and release the kernel mapped pages sooner.
883 	 *
884 	 * XXX KDM should I use P_NOSWAP instead?
885 	 */
886 	PHOLD(curproc);
887 
888 	for (i = 0; i < numbufs; i++) {
889 		/*
890 		 * Get the buffer.
891 		 */
892 		mapinfo->bp[i] = getpbuf(NULL);
893 
894 		/* put our pointer in the data slot */
895 		mapinfo->bp[i]->b_data = *data_ptrs[i];
896 
897 		/* save the user's data address */
898 		mapinfo->bp[i]->b_caller1 = *data_ptrs[i];
899 
900 		/* set the transfer length, we know it's < MAXPHYS */
901 		mapinfo->bp[i]->b_bufsize = lengths[i];
902 
903 		/* set the direction */
904 		mapinfo->bp[i]->b_iocmd = flags[i];
905 
906 		/*
907 		 * Map the buffer into kernel memory.
908 		 *
909 		 * Note that useracc() alone is not a  sufficient test.
910 		 * vmapbuf() can still fail due to a smaller file mapped
911 		 * into a larger area of VM, or if userland races against
912 		 * vmapbuf() after the useracc() check.
913 		 */
914 		if (vmapbuf(mapinfo->bp[i], 1) < 0) {
915 			for (j = 0; j < i; ++j) {
916 				*data_ptrs[j] = mapinfo->bp[j]->b_caller1;
917 				vunmapbuf(mapinfo->bp[j]);
918 				relpbuf(mapinfo->bp[j], NULL);
919 			}
920 			relpbuf(mapinfo->bp[i], NULL);
921 			PRELE(curproc);
922 			return(EACCES);
923 		}
924 
925 		/* set our pointer to the new mapped area */
926 		*data_ptrs[i] = mapinfo->bp[i]->b_data;
927 
928 		mapinfo->num_bufs_used++;
929 	}
930 
931 	/*
932 	 * Now that we've gotten this far, change ownership to the kernel
933 	 * of the buffers so that we don't run afoul of returning to user
934 	 * space with locks (on the buffer) held.
935 	 */
936 	for (i = 0; i < numbufs; i++) {
937 		BUF_KERNPROC(mapinfo->bp[i]);
938 	}
939 
940 
941 	return(0);
942 }
943 
944 /*
945  * Unmap memory segments mapped into kernel virtual address space by
946  * cam_periph_mapmem().
947  */
948 void
949 cam_periph_unmapmem(union ccb *ccb, struct cam_periph_map_info *mapinfo)
950 {
951 	int numbufs, i;
952 	u_int8_t **data_ptrs[CAM_PERIPH_MAXMAPS];
953 
954 	if (mapinfo->num_bufs_used <= 0) {
955 		/* nothing to free and the process wasn't held. */
956 		return;
957 	}
958 
959 	switch (ccb->ccb_h.func_code) {
960 	case XPT_DEV_MATCH:
961 		numbufs = min(mapinfo->num_bufs_used, 2);
962 
963 		if (numbufs == 1) {
964 			data_ptrs[0] = (u_int8_t **)&ccb->cdm.matches;
965 		} else {
966 			data_ptrs[0] = (u_int8_t **)&ccb->cdm.patterns;
967 			data_ptrs[1] = (u_int8_t **)&ccb->cdm.matches;
968 		}
969 		break;
970 	case XPT_SCSI_IO:
971 	case XPT_CONT_TARGET_IO:
972 		data_ptrs[0] = &ccb->csio.data_ptr;
973 		numbufs = min(mapinfo->num_bufs_used, 1);
974 		break;
975 	case XPT_ATA_IO:
976 		data_ptrs[0] = &ccb->ataio.data_ptr;
977 		numbufs = min(mapinfo->num_bufs_used, 1);
978 		break;
979 	case XPT_SMP_IO:
980 		numbufs = min(mapinfo->num_bufs_used, 2);
981 		data_ptrs[0] = &ccb->smpio.smp_request;
982 		data_ptrs[1] = &ccb->smpio.smp_response;
983 		break;
984 	case XPT_DEV_ADVINFO:
985 		numbufs = min(mapinfo->num_bufs_used, 1);
986 		data_ptrs[0] = (uint8_t **)&ccb->cdai.buf;
987 		break;
988 	default:
989 		/* allow ourselves to be swapped once again */
990 		PRELE(curproc);
991 		return;
992 		break; /* NOTREACHED */
993 	}
994 
995 	for (i = 0; i < numbufs; i++) {
996 		/* Set the user's pointer back to the original value */
997 		*data_ptrs[i] = mapinfo->bp[i]->b_caller1;
998 
999 		/* unmap the buffer */
1000 		vunmapbuf(mapinfo->bp[i]);
1001 
1002 		/* release the buffer */
1003 		relpbuf(mapinfo->bp[i], NULL);
1004 	}
1005 
1006 	/* allow ourselves to be swapped once again */
1007 	PRELE(curproc);
1008 }
1009 
1010 int
1011 cam_periph_ioctl(struct cam_periph *periph, u_long cmd, caddr_t addr,
1012 		 int (*error_routine)(union ccb *ccb,
1013 				      cam_flags camflags,
1014 				      u_int32_t sense_flags))
1015 {
1016 	union ccb 	     *ccb;
1017 	int 		     error;
1018 	int		     found;
1019 
1020 	error = found = 0;
1021 
1022 	switch(cmd){
1023 	case CAMGETPASSTHRU:
1024 		ccb = cam_periph_getccb(periph, CAM_PRIORITY_NORMAL);
1025 		xpt_setup_ccb(&ccb->ccb_h,
1026 			      ccb->ccb_h.path,
1027 			      CAM_PRIORITY_NORMAL);
1028 		ccb->ccb_h.func_code = XPT_GDEVLIST;
1029 
1030 		/*
1031 		 * Basically, the point of this is that we go through
1032 		 * getting the list of devices, until we find a passthrough
1033 		 * device.  In the current version of the CAM code, the
1034 		 * only way to determine what type of device we're dealing
1035 		 * with is by its name.
1036 		 */
1037 		while (found == 0) {
1038 			ccb->cgdl.index = 0;
1039 			ccb->cgdl.status = CAM_GDEVLIST_MORE_DEVS;
1040 			while (ccb->cgdl.status == CAM_GDEVLIST_MORE_DEVS) {
1041 
1042 				/* we want the next device in the list */
1043 				xpt_action(ccb);
1044 				if (strncmp(ccb->cgdl.periph_name,
1045 				    "pass", 4) == 0){
1046 					found = 1;
1047 					break;
1048 				}
1049 			}
1050 			if ((ccb->cgdl.status == CAM_GDEVLIST_LAST_DEVICE) &&
1051 			    (found == 0)) {
1052 				ccb->cgdl.periph_name[0] = '\0';
1053 				ccb->cgdl.unit_number = 0;
1054 				break;
1055 			}
1056 		}
1057 
1058 		/* copy the result back out */
1059 		bcopy(ccb, addr, sizeof(union ccb));
1060 
1061 		/* and release the ccb */
1062 		xpt_release_ccb(ccb);
1063 
1064 		break;
1065 	default:
1066 		error = ENOTTY;
1067 		break;
1068 	}
1069 	return(error);
1070 }
1071 
1072 static void
1073 cam_periph_done_panic(struct cam_periph *periph, union ccb *done_ccb)
1074 {
1075 
1076 	panic("%s: already done with ccb %p", __func__, done_ccb);
1077 }
1078 
1079 static void
1080 cam_periph_done(struct cam_periph *periph, union ccb *done_ccb)
1081 {
1082 
1083 	/* Caller will release the CCB */
1084 	xpt_path_assert(done_ccb->ccb_h.path, MA_OWNED);
1085 	done_ccb->ccb_h.cbfcnp = cam_periph_done_panic;
1086 	wakeup(&done_ccb->ccb_h.cbfcnp);
1087 }
1088 
1089 static void
1090 cam_periph_ccbwait(union ccb *ccb)
1091 {
1092 
1093 	if ((ccb->ccb_h.func_code & XPT_FC_QUEUED) != 0) {
1094 		while (ccb->ccb_h.cbfcnp != cam_periph_done_panic)
1095 			xpt_path_sleep(ccb->ccb_h.path, &ccb->ccb_h.cbfcnp,
1096 			    PRIBIO, "cbwait", 0);
1097 	}
1098 	KASSERT(ccb->ccb_h.pinfo.index == CAM_UNQUEUED_INDEX &&
1099 	    (ccb->ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_INPROG,
1100 	    ("%s: proceeding with incomplete ccb: ccb=%p, func_code=%#x, "
1101 	     "status=%#x, index=%d", __func__, ccb, ccb->ccb_h.func_code,
1102 	     ccb->ccb_h.status, ccb->ccb_h.pinfo.index));
1103 }
1104 
1105 int
1106 cam_periph_runccb(union ccb *ccb,
1107 		  int (*error_routine)(union ccb *ccb,
1108 				       cam_flags camflags,
1109 				       u_int32_t sense_flags),
1110 		  cam_flags camflags, u_int32_t sense_flags,
1111 		  struct devstat *ds)
1112 {
1113 	struct bintime *starttime;
1114 	struct bintime ltime;
1115 	int error;
1116 
1117 	starttime = NULL;
1118 	xpt_path_assert(ccb->ccb_h.path, MA_OWNED);
1119 	KASSERT((ccb->ccb_h.flags & CAM_UNLOCKED) == 0,
1120 	    ("%s: ccb=%p, func_code=%#x, flags=%#x", __func__, ccb,
1121 	     ccb->ccb_h.func_code, ccb->ccb_h.flags));
1122 
1123 	/*
1124 	 * If the user has supplied a stats structure, and if we understand
1125 	 * this particular type of ccb, record the transaction start.
1126 	 */
1127 	if ((ds != NULL) && (ccb->ccb_h.func_code == XPT_SCSI_IO ||
1128 	    ccb->ccb_h.func_code == XPT_ATA_IO)) {
1129 		starttime = &ltime;
1130 		binuptime(starttime);
1131 		devstat_start_transaction(ds, starttime);
1132 	}
1133 
1134 	ccb->ccb_h.cbfcnp = cam_periph_done;
1135 	xpt_action(ccb);
1136 
1137 	do {
1138 		cam_periph_ccbwait(ccb);
1139 		if ((ccb->ccb_h.status & CAM_STATUS_MASK) == CAM_REQ_CMP)
1140 			error = 0;
1141 		else if (error_routine != NULL) {
1142 			ccb->ccb_h.cbfcnp = cam_periph_done;
1143 			error = (*error_routine)(ccb, camflags, sense_flags);
1144 		} else
1145 			error = 0;
1146 
1147 	} while (error == ERESTART);
1148 
1149 	if ((ccb->ccb_h.status & CAM_DEV_QFRZN) != 0) {
1150 		cam_release_devq(ccb->ccb_h.path,
1151 				 /* relsim_flags */0,
1152 				 /* openings */0,
1153 				 /* timeout */0,
1154 				 /* getcount_only */ FALSE);
1155 		ccb->ccb_h.status &= ~CAM_DEV_QFRZN;
1156 	}
1157 
1158 	if (ds != NULL) {
1159 		if (ccb->ccb_h.func_code == XPT_SCSI_IO) {
1160 			devstat_end_transaction(ds,
1161 					ccb->csio.dxfer_len - ccb->csio.resid,
1162 					ccb->csio.tag_action & 0x3,
1163 					((ccb->ccb_h.flags & CAM_DIR_MASK) ==
1164 					CAM_DIR_NONE) ?  DEVSTAT_NO_DATA :
1165 					(ccb->ccb_h.flags & CAM_DIR_OUT) ?
1166 					DEVSTAT_WRITE :
1167 					DEVSTAT_READ, NULL, starttime);
1168 		} else if (ccb->ccb_h.func_code == XPT_ATA_IO) {
1169 			devstat_end_transaction(ds,
1170 					ccb->ataio.dxfer_len - ccb->ataio.resid,
1171 					0, /* Not used in ATA */
1172 					((ccb->ccb_h.flags & CAM_DIR_MASK) ==
1173 					CAM_DIR_NONE) ?  DEVSTAT_NO_DATA :
1174 					(ccb->ccb_h.flags & CAM_DIR_OUT) ?
1175 					DEVSTAT_WRITE :
1176 					DEVSTAT_READ, NULL, starttime);
1177 		}
1178 	}
1179 
1180 	return(error);
1181 }
1182 
1183 void
1184 cam_freeze_devq(struct cam_path *path)
1185 {
1186 	struct ccb_hdr ccb_h;
1187 
1188 	CAM_DEBUG(path, CAM_DEBUG_TRACE, ("cam_freeze_devq\n"));
1189 	xpt_setup_ccb(&ccb_h, path, /*priority*/1);
1190 	ccb_h.func_code = XPT_NOOP;
1191 	ccb_h.flags = CAM_DEV_QFREEZE;
1192 	xpt_action((union ccb *)&ccb_h);
1193 }
1194 
1195 u_int32_t
1196 cam_release_devq(struct cam_path *path, u_int32_t relsim_flags,
1197 		 u_int32_t openings, u_int32_t arg,
1198 		 int getcount_only)
1199 {
1200 	struct ccb_relsim crs;
1201 
1202 	CAM_DEBUG(path, CAM_DEBUG_TRACE, ("cam_release_devq(%u, %u, %u, %d)\n",
1203 	    relsim_flags, openings, arg, getcount_only));
1204 	xpt_setup_ccb(&crs.ccb_h, path, CAM_PRIORITY_NORMAL);
1205 	crs.ccb_h.func_code = XPT_REL_SIMQ;
1206 	crs.ccb_h.flags = getcount_only ? CAM_DEV_QFREEZE : 0;
1207 	crs.release_flags = relsim_flags;
1208 	crs.openings = openings;
1209 	crs.release_timeout = arg;
1210 	xpt_action((union ccb *)&crs);
1211 	return (crs.qfrozen_cnt);
1212 }
1213 
1214 #define saved_ccb_ptr ppriv_ptr0
1215 static void
1216 camperiphdone(struct cam_periph *periph, union ccb *done_ccb)
1217 {
1218 	union ccb      *saved_ccb;
1219 	cam_status	status;
1220 	struct scsi_start_stop_unit *scsi_cmd;
1221 	int    error_code, sense_key, asc, ascq;
1222 
1223 	scsi_cmd = (struct scsi_start_stop_unit *)
1224 	    &done_ccb->csio.cdb_io.cdb_bytes;
1225 	status = done_ccb->ccb_h.status;
1226 
1227 	if ((status & CAM_STATUS_MASK) != CAM_REQ_CMP) {
1228 		if (scsi_extract_sense_ccb(done_ccb,
1229 		    &error_code, &sense_key, &asc, &ascq)) {
1230 			/*
1231 			 * If the error is "invalid field in CDB",
1232 			 * and the load/eject flag is set, turn the
1233 			 * flag off and try again.  This is just in
1234 			 * case the drive in question barfs on the
1235 			 * load eject flag.  The CAM code should set
1236 			 * the load/eject flag by default for
1237 			 * removable media.
1238 			 */
1239 			if ((scsi_cmd->opcode == START_STOP_UNIT) &&
1240 			    ((scsi_cmd->how & SSS_LOEJ) != 0) &&
1241 			     (asc == 0x24) && (ascq == 0x00)) {
1242 				scsi_cmd->how &= ~SSS_LOEJ;
1243 				if (status & CAM_DEV_QFRZN) {
1244 					cam_release_devq(done_ccb->ccb_h.path,
1245 					    0, 0, 0, 0);
1246 					done_ccb->ccb_h.status &=
1247 					    ~CAM_DEV_QFRZN;
1248 				}
1249 				xpt_action(done_ccb);
1250 				goto out;
1251 			}
1252 		}
1253 		if (cam_periph_error(done_ccb,
1254 		    0, SF_RETRY_UA | SF_NO_PRINT, NULL) == ERESTART)
1255 			goto out;
1256 		if (done_ccb->ccb_h.status & CAM_DEV_QFRZN) {
1257 			cam_release_devq(done_ccb->ccb_h.path, 0, 0, 0, 0);
1258 			done_ccb->ccb_h.status &= ~CAM_DEV_QFRZN;
1259 		}
1260 	} else {
1261 		/*
1262 		 * If we have successfully taken a device from the not
1263 		 * ready to ready state, re-scan the device and re-get
1264 		 * the inquiry information.  Many devices (mostly disks)
1265 		 * don't properly report their inquiry information unless
1266 		 * they are spun up.
1267 		 */
1268 		if (scsi_cmd->opcode == START_STOP_UNIT)
1269 			xpt_async(AC_INQ_CHANGED, done_ccb->ccb_h.path, NULL);
1270 	}
1271 
1272 	/*
1273 	 * Perform the final retry with the original CCB so that final
1274 	 * error processing is performed by the owner of the CCB.
1275 	 */
1276 	saved_ccb = (union ccb *)done_ccb->ccb_h.saved_ccb_ptr;
1277 	bcopy(saved_ccb, done_ccb, sizeof(*done_ccb));
1278 	xpt_free_ccb(saved_ccb);
1279 	if (done_ccb->ccb_h.cbfcnp != camperiphdone)
1280 		periph->flags &= ~CAM_PERIPH_RECOVERY_INPROG;
1281 	xpt_action(done_ccb);
1282 
1283 out:
1284 	/* Drop freeze taken due to CAM_DEV_QFREEZE flag set. */
1285 	cam_release_devq(done_ccb->ccb_h.path, 0, 0, 0, 0);
1286 }
1287 
1288 /*
1289  * Generic Async Event handler.  Peripheral drivers usually
1290  * filter out the events that require personal attention,
1291  * and leave the rest to this function.
1292  */
1293 void
1294 cam_periph_async(struct cam_periph *periph, u_int32_t code,
1295 		 struct cam_path *path, void *arg)
1296 {
1297 	switch (code) {
1298 	case AC_LOST_DEVICE:
1299 		cam_periph_invalidate(periph);
1300 		break;
1301 	default:
1302 		break;
1303 	}
1304 }
1305 
1306 void
1307 cam_periph_bus_settle(struct cam_periph *periph, u_int bus_settle)
1308 {
1309 	struct ccb_getdevstats cgds;
1310 
1311 	xpt_setup_ccb(&cgds.ccb_h, periph->path, CAM_PRIORITY_NORMAL);
1312 	cgds.ccb_h.func_code = XPT_GDEV_STATS;
1313 	xpt_action((union ccb *)&cgds);
1314 	cam_periph_freeze_after_event(periph, &cgds.last_reset, bus_settle);
1315 }
1316 
1317 void
1318 cam_periph_freeze_after_event(struct cam_periph *periph,
1319 			      struct timeval* event_time, u_int duration_ms)
1320 {
1321 	struct timeval delta;
1322 	struct timeval duration_tv;
1323 
1324 	if (!timevalisset(event_time))
1325 		return;
1326 
1327 	microtime(&delta);
1328 	timevalsub(&delta, event_time);
1329 	duration_tv.tv_sec = duration_ms / 1000;
1330 	duration_tv.tv_usec = (duration_ms % 1000) * 1000;
1331 	if (timevalcmp(&delta, &duration_tv, <)) {
1332 		timevalsub(&duration_tv, &delta);
1333 
1334 		duration_ms = duration_tv.tv_sec * 1000;
1335 		duration_ms += duration_tv.tv_usec / 1000;
1336 		cam_freeze_devq(periph->path);
1337 		cam_release_devq(periph->path,
1338 				RELSIM_RELEASE_AFTER_TIMEOUT,
1339 				/*reduction*/0,
1340 				/*timeout*/duration_ms,
1341 				/*getcount_only*/0);
1342 	}
1343 
1344 }
1345 
1346 static int
1347 camperiphscsistatuserror(union ccb *ccb, union ccb **orig_ccb,
1348     cam_flags camflags, u_int32_t sense_flags,
1349     int *openings, u_int32_t *relsim_flags,
1350     u_int32_t *timeout, u_int32_t *action, const char **action_string)
1351 {
1352 	int error;
1353 
1354 	switch (ccb->csio.scsi_status) {
1355 	case SCSI_STATUS_OK:
1356 	case SCSI_STATUS_COND_MET:
1357 	case SCSI_STATUS_INTERMED:
1358 	case SCSI_STATUS_INTERMED_COND_MET:
1359 		error = 0;
1360 		break;
1361 	case SCSI_STATUS_CMD_TERMINATED:
1362 	case SCSI_STATUS_CHECK_COND:
1363 		error = camperiphscsisenseerror(ccb, orig_ccb,
1364 					        camflags,
1365 					        sense_flags,
1366 					        openings,
1367 					        relsim_flags,
1368 					        timeout,
1369 					        action,
1370 					        action_string);
1371 		break;
1372 	case SCSI_STATUS_QUEUE_FULL:
1373 	{
1374 		/* no decrement */
1375 		struct ccb_getdevstats cgds;
1376 
1377 		/*
1378 		 * First off, find out what the current
1379 		 * transaction counts are.
1380 		 */
1381 		xpt_setup_ccb(&cgds.ccb_h,
1382 			      ccb->ccb_h.path,
1383 			      CAM_PRIORITY_NORMAL);
1384 		cgds.ccb_h.func_code = XPT_GDEV_STATS;
1385 		xpt_action((union ccb *)&cgds);
1386 
1387 		/*
1388 		 * If we were the only transaction active, treat
1389 		 * the QUEUE FULL as if it were a BUSY condition.
1390 		 */
1391 		if (cgds.dev_active != 0) {
1392 			int total_openings;
1393 
1394 			/*
1395 		 	 * Reduce the number of openings to
1396 			 * be 1 less than the amount it took
1397 			 * to get a queue full bounded by the
1398 			 * minimum allowed tag count for this
1399 			 * device.
1400 		 	 */
1401 			total_openings = cgds.dev_active + cgds.dev_openings;
1402 			*openings = cgds.dev_active;
1403 			if (*openings < cgds.mintags)
1404 				*openings = cgds.mintags;
1405 			if (*openings < total_openings)
1406 				*relsim_flags = RELSIM_ADJUST_OPENINGS;
1407 			else {
1408 				/*
1409 				 * Some devices report queue full for
1410 				 * temporary resource shortages.  For
1411 				 * this reason, we allow a minimum
1412 				 * tag count to be entered via a
1413 				 * quirk entry to prevent the queue
1414 				 * count on these devices from falling
1415 				 * to a pessimisticly low value.  We
1416 				 * still wait for the next successful
1417 				 * completion, however, before queueing
1418 				 * more transactions to the device.
1419 				 */
1420 				*relsim_flags = RELSIM_RELEASE_AFTER_CMDCMPLT;
1421 			}
1422 			*timeout = 0;
1423 			error = ERESTART;
1424 			*action &= ~SSQ_PRINT_SENSE;
1425 			break;
1426 		}
1427 		/* FALLTHROUGH */
1428 	}
1429 	case SCSI_STATUS_BUSY:
1430 		/*
1431 		 * Restart the queue after either another
1432 		 * command completes or a 1 second timeout.
1433 		 */
1434 		if ((sense_flags & SF_RETRY_BUSY) != 0 ||
1435 		    (ccb->ccb_h.retry_count--) > 0) {
1436 			error = ERESTART;
1437 			*relsim_flags = RELSIM_RELEASE_AFTER_TIMEOUT
1438 				      | RELSIM_RELEASE_AFTER_CMDCMPLT;
1439 			*timeout = 1000;
1440 		} else {
1441 			error = EIO;
1442 		}
1443 		break;
1444 	case SCSI_STATUS_RESERV_CONFLICT:
1445 	default:
1446 		error = EIO;
1447 		break;
1448 	}
1449 	return (error);
1450 }
1451 
1452 static int
1453 camperiphscsisenseerror(union ccb *ccb, union ccb **orig,
1454     cam_flags camflags, u_int32_t sense_flags,
1455     int *openings, u_int32_t *relsim_flags,
1456     u_int32_t *timeout, u_int32_t *action, const char **action_string)
1457 {
1458 	struct cam_periph *periph;
1459 	union ccb *orig_ccb = ccb;
1460 	int error, recoveryccb;
1461 
1462 #if defined(BUF_TRACKING) || defined(FULL_BUF_TRACKING)
1463 	if (ccb->ccb_h.func_code == XPT_SCSI_IO && ccb->csio.bio != NULL)
1464 		biotrack(ccb->csio.bio, __func__);
1465 #endif
1466 
1467 	periph = xpt_path_periph(ccb->ccb_h.path);
1468 	recoveryccb = (ccb->ccb_h.cbfcnp == camperiphdone);
1469 	if ((periph->flags & CAM_PERIPH_RECOVERY_INPROG) && !recoveryccb) {
1470 		/*
1471 		 * If error recovery is already in progress, don't attempt
1472 		 * to process this error, but requeue it unconditionally
1473 		 * and attempt to process it once error recovery has
1474 		 * completed.  This failed command is probably related to
1475 		 * the error that caused the currently active error recovery
1476 		 * action so our  current recovery efforts should also
1477 		 * address this command.  Be aware that the error recovery
1478 		 * code assumes that only one recovery action is in progress
1479 		 * on a particular peripheral instance at any given time
1480 		 * (e.g. only one saved CCB for error recovery) so it is
1481 		 * imperitive that we don't violate this assumption.
1482 		 */
1483 		error = ERESTART;
1484 		*action &= ~SSQ_PRINT_SENSE;
1485 	} else {
1486 		scsi_sense_action err_action;
1487 		struct ccb_getdev cgd;
1488 
1489 		/*
1490 		 * Grab the inquiry data for this device.
1491 		 */
1492 		xpt_setup_ccb(&cgd.ccb_h, ccb->ccb_h.path, CAM_PRIORITY_NORMAL);
1493 		cgd.ccb_h.func_code = XPT_GDEV_TYPE;
1494 		xpt_action((union ccb *)&cgd);
1495 
1496 		err_action = scsi_error_action(&ccb->csio, &cgd.inq_data,
1497 		    sense_flags);
1498 		error = err_action & SS_ERRMASK;
1499 
1500 		/*
1501 		 * Do not autostart sequential access devices
1502 		 * to avoid unexpected tape loading.
1503 		 */
1504 		if ((err_action & SS_MASK) == SS_START &&
1505 		    SID_TYPE(&cgd.inq_data) == T_SEQUENTIAL) {
1506 			*action_string = "Will not autostart a "
1507 			    "sequential access device";
1508 			goto sense_error_done;
1509 		}
1510 
1511 		/*
1512 		 * Avoid recovery recursion if recovery action is the same.
1513 		 */
1514 		if ((err_action & SS_MASK) >= SS_START && recoveryccb) {
1515 			if (((err_action & SS_MASK) == SS_START &&
1516 			     ccb->csio.cdb_io.cdb_bytes[0] == START_STOP_UNIT) ||
1517 			    ((err_action & SS_MASK) == SS_TUR &&
1518 			     (ccb->csio.cdb_io.cdb_bytes[0] == TEST_UNIT_READY))) {
1519 				err_action = SS_RETRY|SSQ_DECREMENT_COUNT|EIO;
1520 				*relsim_flags = RELSIM_RELEASE_AFTER_TIMEOUT;
1521 				*timeout = 500;
1522 			}
1523 		}
1524 
1525 		/*
1526 		 * If the recovery action will consume a retry,
1527 		 * make sure we actually have retries available.
1528 		 */
1529 		if ((err_action & SSQ_DECREMENT_COUNT) != 0) {
1530 		 	if (ccb->ccb_h.retry_count > 0 &&
1531 			    (periph->flags & CAM_PERIPH_INVALID) == 0)
1532 		 		ccb->ccb_h.retry_count--;
1533 			else {
1534 				*action_string = "Retries exhausted";
1535 				goto sense_error_done;
1536 			}
1537 		}
1538 
1539 		if ((err_action & SS_MASK) >= SS_START) {
1540 			/*
1541 			 * Do common portions of commands that
1542 			 * use recovery CCBs.
1543 			 */
1544 			orig_ccb = xpt_alloc_ccb_nowait();
1545 			if (orig_ccb == NULL) {
1546 				*action_string = "Can't allocate recovery CCB";
1547 				goto sense_error_done;
1548 			}
1549 			/*
1550 			 * Clear freeze flag for original request here, as
1551 			 * this freeze will be dropped as part of ERESTART.
1552 			 */
1553 			ccb->ccb_h.status &= ~CAM_DEV_QFRZN;
1554 			bcopy(ccb, orig_ccb, sizeof(*orig_ccb));
1555 		}
1556 
1557 		switch (err_action & SS_MASK) {
1558 		case SS_NOP:
1559 			*action_string = "No recovery action needed";
1560 			error = 0;
1561 			break;
1562 		case SS_RETRY:
1563 			*action_string = "Retrying command (per sense data)";
1564 			error = ERESTART;
1565 			break;
1566 		case SS_FAIL:
1567 			*action_string = "Unretryable error";
1568 			break;
1569 		case SS_START:
1570 		{
1571 			int le;
1572 
1573 			/*
1574 			 * Send a start unit command to the device, and
1575 			 * then retry the command.
1576 			 */
1577 			*action_string = "Attempting to start unit";
1578 			periph->flags |= CAM_PERIPH_RECOVERY_INPROG;
1579 
1580 			/*
1581 			 * Check for removable media and set
1582 			 * load/eject flag appropriately.
1583 			 */
1584 			if (SID_IS_REMOVABLE(&cgd.inq_data))
1585 				le = TRUE;
1586 			else
1587 				le = FALSE;
1588 
1589 			scsi_start_stop(&ccb->csio,
1590 					/*retries*/1,
1591 					camperiphdone,
1592 					MSG_SIMPLE_Q_TAG,
1593 					/*start*/TRUE,
1594 					/*load/eject*/le,
1595 					/*immediate*/FALSE,
1596 					SSD_FULL_SIZE,
1597 					/*timeout*/50000);
1598 			break;
1599 		}
1600 		case SS_TUR:
1601 		{
1602 			/*
1603 			 * Send a Test Unit Ready to the device.
1604 			 * If the 'many' flag is set, we send 120
1605 			 * test unit ready commands, one every half
1606 			 * second.  Otherwise, we just send one TUR.
1607 			 * We only want to do this if the retry
1608 			 * count has not been exhausted.
1609 			 */
1610 			int retries;
1611 
1612 			if ((err_action & SSQ_MANY) != 0) {
1613 				*action_string = "Polling device for readiness";
1614 				retries = 120;
1615 			} else {
1616 				*action_string = "Testing device for readiness";
1617 				retries = 1;
1618 			}
1619 			periph->flags |= CAM_PERIPH_RECOVERY_INPROG;
1620 			scsi_test_unit_ready(&ccb->csio,
1621 					     retries,
1622 					     camperiphdone,
1623 					     MSG_SIMPLE_Q_TAG,
1624 					     SSD_FULL_SIZE,
1625 					     /*timeout*/5000);
1626 
1627 			/*
1628 			 * Accomplish our 500ms delay by deferring
1629 			 * the release of our device queue appropriately.
1630 			 */
1631 			*relsim_flags = RELSIM_RELEASE_AFTER_TIMEOUT;
1632 			*timeout = 500;
1633 			break;
1634 		}
1635 		default:
1636 			panic("Unhandled error action %x", err_action);
1637 		}
1638 
1639 		if ((err_action & SS_MASK) >= SS_START) {
1640 			/*
1641 			 * Drop the priority, so that the recovery
1642 			 * CCB is the first to execute.  Freeze the queue
1643 			 * after this command is sent so that we can
1644 			 * restore the old csio and have it queued in
1645 			 * the proper order before we release normal
1646 			 * transactions to the device.
1647 			 */
1648 			ccb->ccb_h.pinfo.priority--;
1649 			ccb->ccb_h.flags |= CAM_DEV_QFREEZE;
1650 			ccb->ccb_h.saved_ccb_ptr = orig_ccb;
1651 			error = ERESTART;
1652 			*orig = orig_ccb;
1653 		}
1654 
1655 sense_error_done:
1656 		*action = err_action;
1657 	}
1658 	return (error);
1659 }
1660 
1661 /*
1662  * Generic error handler.  Peripheral drivers usually filter
1663  * out the errors that they handle in a unique manner, then
1664  * call this function.
1665  */
1666 int
1667 cam_periph_error(union ccb *ccb, cam_flags camflags,
1668 		 u_int32_t sense_flags, union ccb *save_ccb)
1669 {
1670 	struct cam_path *newpath;
1671 	union ccb  *orig_ccb, *scan_ccb;
1672 	struct cam_periph *periph;
1673 	const char *action_string;
1674 	cam_status  status;
1675 	int	    frozen, error, openings, devctl_err;
1676 	u_int32_t   action, relsim_flags, timeout;
1677 
1678 	action = SSQ_PRINT_SENSE;
1679 	periph = xpt_path_periph(ccb->ccb_h.path);
1680 	action_string = NULL;
1681 	status = ccb->ccb_h.status;
1682 	frozen = (status & CAM_DEV_QFRZN) != 0;
1683 	status &= CAM_STATUS_MASK;
1684 	devctl_err = openings = relsim_flags = timeout = 0;
1685 	orig_ccb = ccb;
1686 
1687 	/* Filter the errors that should be reported via devctl */
1688 	switch (ccb->ccb_h.status & CAM_STATUS_MASK) {
1689 	case CAM_CMD_TIMEOUT:
1690 	case CAM_REQ_ABORTED:
1691 	case CAM_REQ_CMP_ERR:
1692 	case CAM_REQ_TERMIO:
1693 	case CAM_UNREC_HBA_ERROR:
1694 	case CAM_DATA_RUN_ERR:
1695 	case CAM_SCSI_STATUS_ERROR:
1696 	case CAM_ATA_STATUS_ERROR:
1697 	case CAM_SMP_STATUS_ERROR:
1698 		devctl_err++;
1699 		break;
1700 	default:
1701 		break;
1702 	}
1703 
1704 	switch (status) {
1705 	case CAM_REQ_CMP:
1706 		error = 0;
1707 		action &= ~SSQ_PRINT_SENSE;
1708 		break;
1709 	case CAM_SCSI_STATUS_ERROR:
1710 		error = camperiphscsistatuserror(ccb, &orig_ccb,
1711 		    camflags, sense_flags, &openings, &relsim_flags,
1712 		    &timeout, &action, &action_string);
1713 		break;
1714 	case CAM_AUTOSENSE_FAIL:
1715 		error = EIO;	/* we have to kill the command */
1716 		break;
1717 	case CAM_UA_ABORT:
1718 	case CAM_UA_TERMIO:
1719 	case CAM_MSG_REJECT_REC:
1720 		/* XXX Don't know that these are correct */
1721 		error = EIO;
1722 		break;
1723 	case CAM_SEL_TIMEOUT:
1724 		if ((camflags & CAM_RETRY_SELTO) != 0) {
1725 			if (ccb->ccb_h.retry_count > 0 &&
1726 			    (periph->flags & CAM_PERIPH_INVALID) == 0) {
1727 				ccb->ccb_h.retry_count--;
1728 				error = ERESTART;
1729 
1730 				/*
1731 				 * Wait a bit to give the device
1732 				 * time to recover before we try again.
1733 				 */
1734 				relsim_flags = RELSIM_RELEASE_AFTER_TIMEOUT;
1735 				timeout = periph_selto_delay;
1736 				break;
1737 			}
1738 			action_string = "Retries exhausted";
1739 		}
1740 		/* FALLTHROUGH */
1741 	case CAM_DEV_NOT_THERE:
1742 		error = ENXIO;
1743 		action = SSQ_LOST;
1744 		break;
1745 	case CAM_REQ_INVALID:
1746 	case CAM_PATH_INVALID:
1747 	case CAM_NO_HBA:
1748 	case CAM_PROVIDE_FAIL:
1749 	case CAM_REQ_TOO_BIG:
1750 	case CAM_LUN_INVALID:
1751 	case CAM_TID_INVALID:
1752 	case CAM_FUNC_NOTAVAIL:
1753 		error = EINVAL;
1754 		break;
1755 	case CAM_SCSI_BUS_RESET:
1756 	case CAM_BDR_SENT:
1757 		/*
1758 		 * Commands that repeatedly timeout and cause these
1759 		 * kinds of error recovery actions, should return
1760 		 * CAM_CMD_TIMEOUT, which allows us to safely assume
1761 		 * that this command was an innocent bystander to
1762 		 * these events and should be unconditionally
1763 		 * retried.
1764 		 */
1765 	case CAM_REQUEUE_REQ:
1766 		/* Unconditional requeue if device is still there */
1767 		if (periph->flags & CAM_PERIPH_INVALID) {
1768 			action_string = "Periph was invalidated";
1769 			error = EIO;
1770 		} else if (sense_flags & SF_NO_RETRY) {
1771 			error = EIO;
1772 			action_string = "Retry was blocked";
1773 		} else {
1774 			error = ERESTART;
1775 			action &= ~SSQ_PRINT_SENSE;
1776 		}
1777 		break;
1778 	case CAM_RESRC_UNAVAIL:
1779 		/* Wait a bit for the resource shortage to abate. */
1780 		timeout = periph_noresrc_delay;
1781 		/* FALLTHROUGH */
1782 	case CAM_BUSY:
1783 		if (timeout == 0) {
1784 			/* Wait a bit for the busy condition to abate. */
1785 			timeout = periph_busy_delay;
1786 		}
1787 		relsim_flags = RELSIM_RELEASE_AFTER_TIMEOUT;
1788 		/* FALLTHROUGH */
1789 	case CAM_ATA_STATUS_ERROR:
1790 	case CAM_REQ_CMP_ERR:
1791 	case CAM_CMD_TIMEOUT:
1792 	case CAM_UNEXP_BUSFREE:
1793 	case CAM_UNCOR_PARITY:
1794 	case CAM_DATA_RUN_ERR:
1795 	default:
1796 		if (periph->flags & CAM_PERIPH_INVALID) {
1797 			error = EIO;
1798 			action_string = "Periph was invalidated";
1799 		} else if (ccb->ccb_h.retry_count == 0) {
1800 			error = EIO;
1801 			action_string = "Retries exhausted";
1802 		} else if (sense_flags & SF_NO_RETRY) {
1803 			error = EIO;
1804 			action_string = "Retry was blocked";
1805 		} else {
1806 			ccb->ccb_h.retry_count--;
1807 			error = ERESTART;
1808 		}
1809 		break;
1810 	}
1811 
1812 	if ((sense_flags & SF_PRINT_ALWAYS) ||
1813 	    CAM_DEBUGGED(ccb->ccb_h.path, CAM_DEBUG_INFO))
1814 		action |= SSQ_PRINT_SENSE;
1815 	else if (sense_flags & SF_NO_PRINT)
1816 		action &= ~SSQ_PRINT_SENSE;
1817 	if ((action & SSQ_PRINT_SENSE) != 0)
1818 		cam_error_print(orig_ccb, CAM_ESF_ALL, CAM_EPF_ALL);
1819 	if (error != 0 && (action & SSQ_PRINT_SENSE) != 0) {
1820 		if (error != ERESTART) {
1821 			if (action_string == NULL)
1822 				action_string = "Unretryable error";
1823 			xpt_print(ccb->ccb_h.path, "Error %d, %s\n",
1824 			    error, action_string);
1825 		} else if (action_string != NULL)
1826 			xpt_print(ccb->ccb_h.path, "%s\n", action_string);
1827 		else
1828 			xpt_print(ccb->ccb_h.path, "Retrying command\n");
1829 	}
1830 
1831 	if (devctl_err && (error != 0 || (action & SSQ_PRINT_SENSE) != 0))
1832 		cam_periph_devctl_notify(orig_ccb);
1833 
1834 	if ((action & SSQ_LOST) != 0) {
1835 		lun_id_t lun_id;
1836 
1837 		/*
1838 		 * For a selection timeout, we consider all of the LUNs on
1839 		 * the target to be gone.  If the status is CAM_DEV_NOT_THERE,
1840 		 * then we only get rid of the device(s) specified by the
1841 		 * path in the original CCB.
1842 		 */
1843 		if (status == CAM_SEL_TIMEOUT)
1844 			lun_id = CAM_LUN_WILDCARD;
1845 		else
1846 			lun_id = xpt_path_lun_id(ccb->ccb_h.path);
1847 
1848 		/* Should we do more if we can't create the path?? */
1849 		if (xpt_create_path(&newpath, periph,
1850 				    xpt_path_path_id(ccb->ccb_h.path),
1851 				    xpt_path_target_id(ccb->ccb_h.path),
1852 				    lun_id) == CAM_REQ_CMP) {
1853 
1854 			/*
1855 			 * Let peripheral drivers know that this
1856 			 * device has gone away.
1857 			 */
1858 			xpt_async(AC_LOST_DEVICE, newpath, NULL);
1859 			xpt_free_path(newpath);
1860 		}
1861 	}
1862 
1863 	/* Broadcast UNIT ATTENTIONs to all periphs. */
1864 	if ((action & SSQ_UA) != 0)
1865 		xpt_async(AC_UNIT_ATTENTION, orig_ccb->ccb_h.path, orig_ccb);
1866 
1867 	/* Rescan target on "Reported LUNs data has changed" */
1868 	if ((action & SSQ_RESCAN) != 0) {
1869 		if (xpt_create_path(&newpath, NULL,
1870 				    xpt_path_path_id(ccb->ccb_h.path),
1871 				    xpt_path_target_id(ccb->ccb_h.path),
1872 				    CAM_LUN_WILDCARD) == CAM_REQ_CMP) {
1873 
1874 			scan_ccb = xpt_alloc_ccb_nowait();
1875 			if (scan_ccb != NULL) {
1876 				scan_ccb->ccb_h.path = newpath;
1877 				scan_ccb->ccb_h.func_code = XPT_SCAN_TGT;
1878 				scan_ccb->crcn.flags = 0;
1879 				xpt_rescan(scan_ccb);
1880 			} else {
1881 				xpt_print(newpath,
1882 				    "Can't allocate CCB to rescan target\n");
1883 				xpt_free_path(newpath);
1884 			}
1885 		}
1886 	}
1887 
1888 	/* Attempt a retry */
1889 	if (error == ERESTART || error == 0) {
1890 		if (frozen != 0)
1891 			ccb->ccb_h.status &= ~CAM_DEV_QFRZN;
1892 		if (error == ERESTART)
1893 			xpt_action(ccb);
1894 		if (frozen != 0)
1895 			cam_release_devq(ccb->ccb_h.path,
1896 					 relsim_flags,
1897 					 openings,
1898 					 timeout,
1899 					 /*getcount_only*/0);
1900 	}
1901 
1902 	return (error);
1903 }
1904 
1905 #define CAM_PERIPH_DEVD_MSG_SIZE	256
1906 
1907 static void
1908 cam_periph_devctl_notify(union ccb *ccb)
1909 {
1910 	struct cam_periph *periph;
1911 	struct ccb_getdev *cgd;
1912 	struct sbuf sb;
1913 	int serr, sk, asc, ascq;
1914 	char *sbmsg, *type;
1915 
1916 	sbmsg = malloc(CAM_PERIPH_DEVD_MSG_SIZE, M_CAMPERIPH, M_NOWAIT);
1917 	if (sbmsg == NULL)
1918 		return;
1919 
1920 	sbuf_new(&sb, sbmsg, CAM_PERIPH_DEVD_MSG_SIZE, SBUF_FIXEDLEN);
1921 
1922 	periph = xpt_path_periph(ccb->ccb_h.path);
1923 	sbuf_printf(&sb, "device=%s%d ", periph->periph_name,
1924 	    periph->unit_number);
1925 
1926 	sbuf_printf(&sb, "serial=\"");
1927 	if ((cgd = (struct ccb_getdev *)xpt_alloc_ccb_nowait()) != NULL) {
1928 		xpt_setup_ccb(&cgd->ccb_h, ccb->ccb_h.path,
1929 		    CAM_PRIORITY_NORMAL);
1930 		cgd->ccb_h.func_code = XPT_GDEV_TYPE;
1931 		xpt_action((union ccb *)cgd);
1932 
1933 		if (cgd->ccb_h.status == CAM_REQ_CMP)
1934 			sbuf_bcat(&sb, cgd->serial_num, cgd->serial_num_len);
1935 		xpt_free_ccb((union ccb *)cgd);
1936 	}
1937 	sbuf_printf(&sb, "\" ");
1938 	sbuf_printf(&sb, "cam_status=\"0x%x\" ", ccb->ccb_h.status);
1939 
1940 	switch (ccb->ccb_h.status & CAM_STATUS_MASK) {
1941 	case CAM_CMD_TIMEOUT:
1942 		sbuf_printf(&sb, "timeout=%d ", ccb->ccb_h.timeout);
1943 		type = "timeout";
1944 		break;
1945 	case CAM_SCSI_STATUS_ERROR:
1946 		sbuf_printf(&sb, "scsi_status=%d ", ccb->csio.scsi_status);
1947 		if (scsi_extract_sense_ccb(ccb, &serr, &sk, &asc, &ascq))
1948 			sbuf_printf(&sb, "scsi_sense=\"%02x %02x %02x %02x\" ",
1949 			    serr, sk, asc, ascq);
1950 		type = "error";
1951 		break;
1952 	case CAM_ATA_STATUS_ERROR:
1953 		sbuf_printf(&sb, "RES=\"");
1954 		ata_res_sbuf(&ccb->ataio.res, &sb);
1955 		sbuf_printf(&sb, "\" ");
1956 		type = "error";
1957 		break;
1958 	default:
1959 		type = "error";
1960 		break;
1961 	}
1962 
1963 	if (ccb->ccb_h.func_code == XPT_SCSI_IO) {
1964 		sbuf_printf(&sb, "CDB=\"");
1965 		scsi_cdb_sbuf(scsiio_cdb_ptr(&ccb->csio), &sb);
1966 		sbuf_printf(&sb, "\" ");
1967 	} else if (ccb->ccb_h.func_code == XPT_ATA_IO) {
1968 		sbuf_printf(&sb, "ACB=\"");
1969 		ata_cmd_sbuf(&ccb->ataio.cmd, &sb);
1970 		sbuf_printf(&sb, "\" ");
1971 	}
1972 
1973 	if (sbuf_finish(&sb) == 0)
1974 		devctl_notify("CAM", "periph", type, sbuf_data(&sb));
1975 	sbuf_delete(&sb);
1976 	free(sbmsg, M_CAMPERIPH);
1977 }
1978 
1979