adw.c revision 1.15 1 1.15 thorpej /* $NetBSD: adw.c,v 1.15 2000/03/23 07:01:28 thorpej Exp $ */
2 1.1 dante
3 1.1 dante /*
4 1.1 dante * Generic driver for the Advanced Systems Inc. SCSI controllers
5 1.1 dante *
6 1.13 dante * Copyright (c) 1998, 1999, 2000 The NetBSD Foundation, Inc.
7 1.1 dante * All rights reserved.
8 1.1 dante *
9 1.1 dante * Author: Baldassare Dante Profeta <dante (at) mclink.it>
10 1.1 dante *
11 1.1 dante * Redistribution and use in source and binary forms, with or without
12 1.1 dante * modification, are permitted provided that the following conditions
13 1.1 dante * are met:
14 1.1 dante * 1. Redistributions of source code must retain the above copyright
15 1.1 dante * notice, this list of conditions and the following disclaimer.
16 1.1 dante * 2. Redistributions in binary form must reproduce the above copyright
17 1.1 dante * notice, this list of conditions and the following disclaimer in the
18 1.1 dante * documentation and/or other materials provided with the distribution.
19 1.1 dante * 3. All advertising materials mentioning features or use of this software
20 1.1 dante * must display the following acknowledgement:
21 1.1 dante * This product includes software developed by the NetBSD
22 1.1 dante * Foundation, Inc. and its contributors.
23 1.1 dante * 4. Neither the name of The NetBSD Foundation nor the names of its
24 1.1 dante * contributors may be used to endorse or promote products derived
25 1.1 dante * from this software without specific prior written permission.
26 1.1 dante *
27 1.1 dante * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
28 1.1 dante * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
29 1.1 dante * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
30 1.1 dante * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
31 1.1 dante * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
32 1.1 dante * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
33 1.1 dante * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
34 1.1 dante * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
35 1.1 dante * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
36 1.1 dante * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
37 1.1 dante * POSSIBILITY OF SUCH DAMAGE.
38 1.1 dante */
39 1.1 dante
40 1.1 dante #include <sys/types.h>
41 1.1 dante #include <sys/param.h>
42 1.1 dante #include <sys/systm.h>
43 1.15 thorpej #include <sys/callout.h>
44 1.1 dante #include <sys/kernel.h>
45 1.1 dante #include <sys/errno.h>
46 1.1 dante #include <sys/ioctl.h>
47 1.1 dante #include <sys/device.h>
48 1.1 dante #include <sys/malloc.h>
49 1.1 dante #include <sys/buf.h>
50 1.1 dante #include <sys/proc.h>
51 1.1 dante #include <sys/user.h>
52 1.1 dante
53 1.1 dante #include <machine/bus.h>
54 1.1 dante #include <machine/intr.h>
55 1.1 dante
56 1.1 dante #include <vm/vm.h>
57 1.1 dante #include <vm/vm_param.h>
58 1.1 dante #include <vm/pmap.h>
59 1.1 dante
60 1.1 dante #include <dev/scsipi/scsi_all.h>
61 1.1 dante #include <dev/scsipi/scsipi_all.h>
62 1.1 dante #include <dev/scsipi/scsiconf.h>
63 1.1 dante
64 1.1 dante #include <dev/ic/adwlib.h>
65 1.1 dante #include <dev/ic/adw.h>
66 1.1 dante
67 1.1 dante #ifndef DDB
68 1.11 dante #define Debugger() panic("should call debugger here (adw.c)")
69 1.2 dante #endif /* ! DDB */
70 1.1 dante
71 1.1 dante /******************************************************************************/
72 1.1 dante
73 1.1 dante
74 1.13 dante static int adw_alloc_controls __P((ADW_SOFTC *));
75 1.13 dante static int adw_alloc_carriers __P((ADW_SOFTC *));
76 1.13 dante static int adw_create_carriers __P((ADW_SOFTC *));
77 1.13 dante static int adw_init_carrier __P((ADW_SOFTC *, ADW_CARRIER *));
78 1.1 dante static int adw_create_ccbs __P((ADW_SOFTC *, ADW_CCB *, int));
79 1.1 dante static void adw_free_ccb __P((ADW_SOFTC *, ADW_CCB *));
80 1.1 dante static void adw_reset_ccb __P((ADW_CCB *));
81 1.1 dante static int adw_init_ccb __P((ADW_SOFTC *, ADW_CCB *));
82 1.1 dante static ADW_CCB *adw_get_ccb __P((ADW_SOFTC *, int));
83 1.13 dante static int adw_queue_ccb __P((ADW_SOFTC *, ADW_CCB *, int));
84 1.1 dante
85 1.1 dante static int adw_scsi_cmd __P((struct scsipi_xfer *));
86 1.14 thorpej static int adw_build_req __P((struct scsipi_xfer *, ADW_CCB *, int));
87 1.7 dante static void adw_build_sglist __P((ADW_CCB *, ADW_SCSI_REQ_Q *, ADW_SG_BLOCK *));
88 1.1 dante static void adwminphys __P((struct buf *));
89 1.13 dante static void adw_isr_callback __P((ADW_SOFTC *, ADW_SCSI_REQ_Q *));
90 1.13 dante static void adw_async_callback __P((ADW_SOFTC *, u_int8_t));
91 1.1 dante
92 1.1 dante static int adw_poll __P((ADW_SOFTC *, struct scsipi_xfer *, int));
93 1.1 dante static void adw_timeout __P((void *));
94 1.1 dante
95 1.1 dante
96 1.1 dante /******************************************************************************/
97 1.1 dante
98 1.1 dante
99 1.1 dante /* the below structure is so we have a default dev struct for out link struct */
100 1.1 dante struct scsipi_device adw_dev =
101 1.1 dante {
102 1.1 dante NULL, /* Use default error handler */
103 1.1 dante NULL, /* have a queue, served by this */
104 1.1 dante NULL, /* have no async handler */
105 1.1 dante NULL, /* Use default 'done' routine */
106 1.1 dante };
107 1.1 dante
108 1.1 dante
109 1.1 dante #define ADW_ABORT_TIMEOUT 10000 /* time to wait for abort (mSec) */
110 1.1 dante #define ADW_WATCH_TIMEOUT 10000 /* time to wait for watchdog (mSec) */
111 1.1 dante
112 1.1 dante
113 1.1 dante /******************************************************************************/
114 1.7 dante /* Control Blocks routines */
115 1.1 dante /******************************************************************************/
116 1.1 dante
117 1.1 dante
118 1.1 dante static int
119 1.13 dante adw_alloc_controls(sc)
120 1.1 dante ADW_SOFTC *sc;
121 1.1 dante {
122 1.1 dante bus_dma_segment_t seg;
123 1.1 dante int error, rseg;
124 1.1 dante
125 1.1 dante /*
126 1.13 dante * Allocate the control structure.
127 1.1 dante */
128 1.1 dante if ((error = bus_dmamem_alloc(sc->sc_dmat, sizeof(struct adw_control),
129 1.1 dante NBPG, 0, &seg, 1, &rseg, BUS_DMA_NOWAIT)) != 0) {
130 1.1 dante printf("%s: unable to allocate control structures,"
131 1.1 dante " error = %d\n", sc->sc_dev.dv_xname, error);
132 1.1 dante return (error);
133 1.1 dante }
134 1.1 dante if ((error = bus_dmamem_map(sc->sc_dmat, &seg, rseg,
135 1.1 dante sizeof(struct adw_control), (caddr_t *) & sc->sc_control,
136 1.1 dante BUS_DMA_NOWAIT | BUS_DMA_COHERENT)) != 0) {
137 1.1 dante printf("%s: unable to map control structures, error = %d\n",
138 1.1 dante sc->sc_dev.dv_xname, error);
139 1.1 dante return (error);
140 1.1 dante }
141 1.13 dante
142 1.1 dante /*
143 1.1 dante * Create and load the DMA map used for the control blocks.
144 1.1 dante */
145 1.1 dante if ((error = bus_dmamap_create(sc->sc_dmat, sizeof(struct adw_control),
146 1.1 dante 1, sizeof(struct adw_control), 0, BUS_DMA_NOWAIT,
147 1.1 dante &sc->sc_dmamap_control)) != 0) {
148 1.1 dante printf("%s: unable to create control DMA map, error = %d\n",
149 1.1 dante sc->sc_dev.dv_xname, error);
150 1.1 dante return (error);
151 1.1 dante }
152 1.1 dante if ((error = bus_dmamap_load(sc->sc_dmat, sc->sc_dmamap_control,
153 1.1 dante sc->sc_control, sizeof(struct adw_control), NULL,
154 1.1 dante BUS_DMA_NOWAIT)) != 0) {
155 1.1 dante printf("%s: unable to load control DMA map, error = %d\n",
156 1.1 dante sc->sc_dev.dv_xname, error);
157 1.1 dante return (error);
158 1.1 dante }
159 1.13 dante
160 1.13 dante return (0);
161 1.13 dante }
162 1.13 dante
163 1.13 dante
164 1.13 dante static int
165 1.13 dante adw_alloc_carriers(sc)
166 1.13 dante ADW_SOFTC *sc;
167 1.13 dante {
168 1.13 dante bus_dma_segment_t seg;
169 1.13 dante int error, rseg;
170 1.13 dante
171 1.13 dante /*
172 1.13 dante * Allocate the control structure.
173 1.13 dante */
174 1.13 dante sc->sc_control->carriers = malloc(ADW_CARRIER_SIZE * ADW_MAX_CARRIER,
175 1.13 dante M_DEVBUF, M_WAITOK);
176 1.13 dante if(!sc->sc_control->carriers) {
177 1.13 dante printf("%s: malloc() failed in allocating carrier structures,"
178 1.13 dante " error = %d\n", sc->sc_dev.dv_xname, error);
179 1.13 dante return (error);
180 1.13 dante }
181 1.13 dante
182 1.13 dante if ((error = bus_dmamem_alloc(sc->sc_dmat,
183 1.13 dante ADW_CARRIER_SIZE * ADW_MAX_CARRIER,
184 1.13 dante NBPG, 0, &seg, 1, &rseg, BUS_DMA_NOWAIT)) != 0) {
185 1.13 dante printf("%s: unable to allocate carrier structures,"
186 1.13 dante " error = %d\n", sc->sc_dev.dv_xname, error);
187 1.13 dante return (error);
188 1.13 dante }
189 1.13 dante if ((error = bus_dmamem_map(sc->sc_dmat, &seg, rseg,
190 1.13 dante ADW_CARRIER_SIZE * ADW_MAX_CARRIER,
191 1.13 dante (caddr_t *) &sc->sc_control->carriers,
192 1.13 dante BUS_DMA_NOWAIT | BUS_DMA_COHERENT)) != 0) {
193 1.13 dante printf("%s: unable to map carrier structures,"
194 1.13 dante " error = %d\n", sc->sc_dev.dv_xname, error);
195 1.13 dante return (error);
196 1.13 dante }
197 1.13 dante
198 1.13 dante /*
199 1.13 dante * Create and load the DMA map used for the control blocks.
200 1.13 dante */
201 1.13 dante if ((error = bus_dmamap_create(sc->sc_dmat,
202 1.13 dante ADW_CARRIER_SIZE * ADW_MAX_CARRIER, 1,
203 1.13 dante ADW_CARRIER_SIZE * ADW_MAX_CARRIER, 0, BUS_DMA_NOWAIT,
204 1.13 dante &sc->sc_dmamap_carrier)) != 0) {
205 1.13 dante printf("%s: unable to create carriers DMA map,"
206 1.13 dante " error = %d\n", sc->sc_dev.dv_xname, error);
207 1.13 dante return (error);
208 1.13 dante }
209 1.13 dante if ((error = bus_dmamap_load(sc->sc_dmat,
210 1.13 dante sc->sc_dmamap_carrier, sc->sc_control->carriers,
211 1.13 dante ADW_CARRIER_SIZE * ADW_MAX_CARRIER, NULL,
212 1.13 dante BUS_DMA_NOWAIT)) != 0) {
213 1.13 dante printf("%s: unable to load carriers DMA map,"
214 1.13 dante " error = %d\n", sc->sc_dev.dv_xname, error);
215 1.13 dante return (error);
216 1.13 dante }
217 1.13 dante
218 1.13 dante error = bus_dmamap_create(sc->sc_dmat, ADW_CARRIER_SIZE* ADW_MAX_CARRIER,
219 1.13 dante 1, ADW_CARRIER_SIZE * ADW_MAX_CARRIER,
220 1.13 dante 0, BUS_DMA_NOWAIT | BUS_DMA_ALLOCNOW,
221 1.13 dante &sc->sc_control->dmamap_xfer);
222 1.13 dante if (error) {
223 1.13 dante printf("%s: unable to create Carrier DMA map, error = %d\n",
224 1.13 dante sc->sc_dev.dv_xname, error);
225 1.13 dante return (error);
226 1.13 dante }
227 1.13 dante
228 1.1 dante return (0);
229 1.1 dante }
230 1.1 dante
231 1.1 dante
232 1.1 dante /*
233 1.13 dante * Create a set of Carriers and add them to the free list. Called once
234 1.13 dante * by adw_init(). We return the number of Carriers successfully created.
235 1.13 dante */
236 1.13 dante static int
237 1.13 dante adw_create_carriers(sc)
238 1.13 dante ADW_SOFTC *sc;
239 1.13 dante {
240 1.13 dante ADW_CARRIER *carr;
241 1.13 dante u_int32_t carr_next = NULL;
242 1.13 dante int i, error;
243 1.13 dante
244 1.13 dante for(i=0; i < ADW_MAX_CARRIER; i++) {
245 1.13 dante carr = (ADW_CARRIER *)(((u_int8_t *)sc->sc_control->carriers) +
246 1.13 dante (ADW_CARRIER_SIZE * i));
247 1.13 dante if ((error = adw_init_carrier(sc, carr)) != 0) {
248 1.13 dante printf("%s: unable to initialize carrier, error = %d\n",
249 1.13 dante sc->sc_dev.dv_xname, error);
250 1.13 dante return (i);
251 1.13 dante }
252 1.13 dante carr->next_vpa = carr_next;
253 1.13 dante carr_next = carr->carr_pa;
254 1.13 dante carr->id = i;
255 1.13 dante }
256 1.13 dante sc->carr_freelist = carr;
257 1.13 dante return (i);
258 1.13 dante }
259 1.13 dante
260 1.13 dante
261 1.13 dante static int
262 1.13 dante adw_init_carrier(sc, carr)
263 1.13 dante ADW_SOFTC *sc;
264 1.13 dante ADW_CARRIER *carr;
265 1.13 dante {
266 1.13 dante u_int32_t carr_pa;
267 1.13 dante int /*error, */hashnum;
268 1.13 dante
269 1.13 dante /*
270 1.13 dante * Create the DMA map for all of the Carriers.
271 1.13 dante */
272 1.13 dante /* error = bus_dmamap_create(sc->sc_dmat, ADW_CARRIER_SIZE,
273 1.13 dante 1, ADW_CARRIER_SIZE,
274 1.13 dante 0, BUS_DMA_NOWAIT | BUS_DMA_ALLOCNOW,
275 1.13 dante &carr->dmamap_xfer);
276 1.13 dante if (error) {
277 1.13 dante printf("%s: unable to create Carrier DMA map, error = %d\n",
278 1.13 dante sc->sc_dev.dv_xname, error);
279 1.13 dante return (error);
280 1.13 dante }
281 1.13 dante */
282 1.13 dante /*
283 1.13 dante * put in the phystokv hash table
284 1.13 dante * Never gets taken out.
285 1.13 dante */
286 1.13 dante carr_pa = ADW_CARRIER_ADDR(sc, carr);
287 1.13 dante carr->carr_pa = carr_pa;
288 1.13 dante hashnum = CARRIER_HASH(carr_pa);
289 1.13 dante carr->nexthash = sc->sc_carrhash[hashnum];
290 1.13 dante sc->sc_carrhash[hashnum] = carr;
291 1.13 dante
292 1.13 dante return(0);
293 1.13 dante }
294 1.13 dante
295 1.13 dante
296 1.13 dante /*
297 1.13 dante * Given a physical address, find the Carrier that it corresponds to.
298 1.13 dante */
299 1.13 dante ADW_CARRIER *
300 1.13 dante adw_carrier_phys_kv(sc, carr_phys)
301 1.13 dante ADW_SOFTC *sc;
302 1.13 dante u_int32_t carr_phys;
303 1.13 dante {
304 1.13 dante int hashnum = CARRIER_HASH(carr_phys);
305 1.13 dante ADW_CARRIER *carr = sc->sc_carrhash[hashnum];
306 1.13 dante
307 1.13 dante while (carr) {
308 1.13 dante if (carr->carr_pa == carr_phys)
309 1.13 dante break;
310 1.13 dante carr = carr->nexthash;
311 1.13 dante }
312 1.13 dante return (carr);
313 1.13 dante }
314 1.13 dante
315 1.13 dante
316 1.13 dante /*
317 1.1 dante * Create a set of ccbs and add them to the free list. Called once
318 1.1 dante * by adw_init(). We return the number of CCBs successfully created.
319 1.1 dante */
320 1.1 dante static int
321 1.1 dante adw_create_ccbs(sc, ccbstore, count)
322 1.1 dante ADW_SOFTC *sc;
323 1.1 dante ADW_CCB *ccbstore;
324 1.1 dante int count;
325 1.1 dante {
326 1.1 dante ADW_CCB *ccb;
327 1.1 dante int i, error;
328 1.1 dante
329 1.1 dante for (i = 0; i < count; i++) {
330 1.1 dante ccb = &ccbstore[i];
331 1.1 dante if ((error = adw_init_ccb(sc, ccb)) != 0) {
332 1.1 dante printf("%s: unable to initialize ccb, error = %d\n",
333 1.1 dante sc->sc_dev.dv_xname, error);
334 1.1 dante return (i);
335 1.1 dante }
336 1.1 dante TAILQ_INSERT_TAIL(&sc->sc_free_ccb, ccb, chain);
337 1.1 dante }
338 1.1 dante
339 1.1 dante return (i);
340 1.1 dante }
341 1.1 dante
342 1.1 dante
343 1.1 dante /*
344 1.1 dante * A ccb is put onto the free list.
345 1.1 dante */
346 1.1 dante static void
347 1.1 dante adw_free_ccb(sc, ccb)
348 1.1 dante ADW_SOFTC *sc;
349 1.1 dante ADW_CCB *ccb;
350 1.1 dante {
351 1.1 dante int s;
352 1.1 dante
353 1.1 dante s = splbio();
354 1.1 dante
355 1.1 dante adw_reset_ccb(ccb);
356 1.1 dante TAILQ_INSERT_HEAD(&sc->sc_free_ccb, ccb, chain);
357 1.1 dante
358 1.1 dante /*
359 1.1 dante * If there were none, wake anybody waiting for one to come free,
360 1.1 dante * starting with queued entries.
361 1.1 dante */
362 1.1 dante if (ccb->chain.tqe_next == 0)
363 1.1 dante wakeup(&sc->sc_free_ccb);
364 1.1 dante
365 1.1 dante splx(s);
366 1.1 dante }
367 1.1 dante
368 1.1 dante
369 1.1 dante static void
370 1.1 dante adw_reset_ccb(ccb)
371 1.1 dante ADW_CCB *ccb;
372 1.1 dante {
373 1.1 dante
374 1.1 dante ccb->flags = 0;
375 1.1 dante }
376 1.1 dante
377 1.1 dante
378 1.1 dante static int
379 1.1 dante adw_init_ccb(sc, ccb)
380 1.1 dante ADW_SOFTC *sc;
381 1.1 dante ADW_CCB *ccb;
382 1.1 dante {
383 1.7 dante int hashnum, error;
384 1.1 dante
385 1.1 dante /*
386 1.1 dante * Create the DMA map for this CCB.
387 1.1 dante */
388 1.1 dante error = bus_dmamap_create(sc->sc_dmat,
389 1.1 dante (ADW_MAX_SG_LIST - 1) * PAGE_SIZE,
390 1.1 dante ADW_MAX_SG_LIST, (ADW_MAX_SG_LIST - 1) * PAGE_SIZE,
391 1.1 dante 0, BUS_DMA_NOWAIT | BUS_DMA_ALLOCNOW, &ccb->dmamap_xfer);
392 1.1 dante if (error) {
393 1.13 dante printf("%s: unable to create CCB DMA map, error = %d\n",
394 1.1 dante sc->sc_dev.dv_xname, error);
395 1.1 dante return (error);
396 1.1 dante }
397 1.7 dante
398 1.7 dante /*
399 1.7 dante * put in the phystokv hash table
400 1.7 dante * Never gets taken out.
401 1.7 dante */
402 1.7 dante ccb->hashkey = sc->sc_dmamap_control->dm_segs[0].ds_addr +
403 1.7 dante ADW_CCB_OFF(ccb);
404 1.7 dante hashnum = CCB_HASH(ccb->hashkey);
405 1.7 dante ccb->nexthash = sc->sc_ccbhash[hashnum];
406 1.7 dante sc->sc_ccbhash[hashnum] = ccb;
407 1.1 dante adw_reset_ccb(ccb);
408 1.1 dante return (0);
409 1.1 dante }
410 1.1 dante
411 1.1 dante
412 1.1 dante /*
413 1.1 dante * Get a free ccb
414 1.1 dante *
415 1.1 dante * If there are none, see if we can allocate a new one
416 1.1 dante */
417 1.1 dante static ADW_CCB *
418 1.1 dante adw_get_ccb(sc, flags)
419 1.1 dante ADW_SOFTC *sc;
420 1.1 dante int flags;
421 1.1 dante {
422 1.1 dante ADW_CCB *ccb = 0;
423 1.1 dante int s;
424 1.1 dante
425 1.1 dante s = splbio();
426 1.1 dante
427 1.1 dante /*
428 1.1 dante * If we can and have to, sleep waiting for one to come free
429 1.1 dante * but only if we can't allocate a new one.
430 1.1 dante */
431 1.1 dante for (;;) {
432 1.1 dante ccb = sc->sc_free_ccb.tqh_first;
433 1.1 dante if (ccb) {
434 1.1 dante TAILQ_REMOVE(&sc->sc_free_ccb, ccb, chain);
435 1.1 dante break;
436 1.1 dante }
437 1.12 thorpej if ((flags & XS_CTL_NOSLEEP) != 0)
438 1.1 dante goto out;
439 1.1 dante
440 1.1 dante tsleep(&sc->sc_free_ccb, PRIBIO, "adwccb", 0);
441 1.1 dante }
442 1.1 dante
443 1.1 dante ccb->flags |= CCB_ALLOC;
444 1.1 dante
445 1.1 dante out:
446 1.1 dante splx(s);
447 1.1 dante return (ccb);
448 1.1 dante }
449 1.1 dante
450 1.1 dante
451 1.1 dante /*
452 1.7 dante * Given a physical address, find the ccb that it corresponds to.
453 1.7 dante */
454 1.7 dante ADW_CCB *
455 1.7 dante adw_ccb_phys_kv(sc, ccb_phys)
456 1.7 dante ADW_SOFTC *sc;
457 1.9 thorpej u_int32_t ccb_phys;
458 1.7 dante {
459 1.7 dante int hashnum = CCB_HASH(ccb_phys);
460 1.7 dante ADW_CCB *ccb = sc->sc_ccbhash[hashnum];
461 1.7 dante
462 1.7 dante while (ccb) {
463 1.7 dante if (ccb->hashkey == ccb_phys)
464 1.7 dante break;
465 1.7 dante ccb = ccb->nexthash;
466 1.7 dante }
467 1.7 dante return (ccb);
468 1.7 dante }
469 1.7 dante
470 1.7 dante
471 1.7 dante /*
472 1.1 dante * Queue a CCB to be sent to the controller, and send it if possible.
473 1.1 dante */
474 1.13 dante static int
475 1.13 dante adw_queue_ccb(sc, ccb, retry)
476 1.1 dante ADW_SOFTC *sc;
477 1.1 dante ADW_CCB *ccb;
478 1.13 dante int retry;
479 1.1 dante {
480 1.13 dante int errcode;
481 1.1 dante
482 1.13 dante if(!retry)
483 1.13 dante TAILQ_INSERT_TAIL(&sc->sc_waiting_ccb, ccb, chain);
484 1.1 dante
485 1.13 dante while ((ccb = sc->sc_waiting_ccb.tqh_first) != NULL) {
486 1.1 dante
487 1.13 dante errcode = AdvExeScsiQueue(sc, &ccb->scsiq);
488 1.13 dante switch(errcode) {
489 1.13 dante case ADW_SUCCESS:
490 1.13 dante break;
491 1.1 dante
492 1.13 dante case ADW_BUSY:
493 1.13 dante printf("ADW_BUSY\n");
494 1.13 dante return(ADW_BUSY);
495 1.13 dante
496 1.13 dante case ADW_ERROR:
497 1.13 dante printf("ADW_ERROR\n");
498 1.13 dante TAILQ_REMOVE(&sc->sc_waiting_ccb, ccb, chain);
499 1.13 dante return(ADW_ERROR);
500 1.13 dante }
501 1.11 dante
502 1.1 dante TAILQ_REMOVE(&sc->sc_waiting_ccb, ccb, chain);
503 1.1 dante
504 1.12 thorpej if ((ccb->xs->xs_control & XS_CTL_POLL) == 0)
505 1.15 thorpej callout_reset(&ccb->xs->xs_callout,
506 1.15 thorpej (ccb->timeout * hz) / 1000, adw_timeout, ccb);
507 1.1 dante }
508 1.13 dante
509 1.13 dante return(errcode);
510 1.1 dante }
511 1.1 dante
512 1.1 dante
513 1.1 dante /******************************************************************************/
514 1.7 dante /* SCSI layer interfacing routines */
515 1.1 dante /******************************************************************************/
516 1.1 dante
517 1.1 dante
518 1.1 dante int
519 1.1 dante adw_init(sc)
520 1.1 dante ADW_SOFTC *sc;
521 1.1 dante {
522 1.2 dante u_int16_t warn_code;
523 1.1 dante
524 1.1 dante
525 1.1 dante sc->cfg.lib_version = (ADW_LIB_VERSION_MAJOR << 8) |
526 1.2 dante ADW_LIB_VERSION_MINOR;
527 1.1 dante sc->cfg.chip_version =
528 1.1 dante ADW_GET_CHIP_VERSION(sc->sc_iot, sc->sc_ioh, sc->bus_type);
529 1.1 dante
530 1.1 dante /*
531 1.1 dante * Reset the chip to start and allow register writes.
532 1.1 dante */
533 1.1 dante if (ADW_FIND_SIGNATURE(sc->sc_iot, sc->sc_ioh) == 0) {
534 1.1 dante panic("adw_init: adw_find_signature failed");
535 1.2 dante } else {
536 1.1 dante AdvResetChip(sc->sc_iot, sc->sc_ioh);
537 1.1 dante
538 1.13 dante warn_code = (sc->chip_type == ADV_CHIP_ASC3550)?
539 1.13 dante AdvInitFrom3550EEP(sc) :
540 1.13 dante AdvInitFrom38C0800EEP(sc);
541 1.13 dante
542 1.2 dante if (warn_code & ASC_WARN_EEPROM_CHKSUM)
543 1.1 dante printf("%s: Bad checksum found. "
544 1.2 dante "Setting default values\n",
545 1.2 dante sc->sc_dev.dv_xname);
546 1.2 dante if (warn_code & ASC_WARN_EEPROM_TERMINATION)
547 1.1 dante printf("%s: Bad bus termination setting."
548 1.2 dante "Using automatic termination.\n",
549 1.2 dante sc->sc_dev.dv_xname);
550 1.1 dante }
551 1.1 dante
552 1.13 dante sc->isr_callback = (ADW_CALLBACK) adw_isr_callback;
553 1.13 dante sc->async_callback = (ADW_CALLBACK) adw_async_callback;
554 1.1 dante
555 1.1 dante return (0);
556 1.1 dante }
557 1.1 dante
558 1.1 dante
559 1.1 dante void
560 1.1 dante adw_attach(sc)
561 1.1 dante ADW_SOFTC *sc;
562 1.1 dante {
563 1.1 dante int i, error;
564 1.1 dante
565 1.1 dante
566 1.13 dante TAILQ_INIT(&sc->sc_free_ccb);
567 1.13 dante TAILQ_INIT(&sc->sc_waiting_ccb);
568 1.13 dante TAILQ_INIT(&sc->sc_queue);
569 1.13 dante
570 1.13 dante
571 1.13 dante /*
572 1.13 dante * Allocate the Control Blocks.
573 1.13 dante */
574 1.13 dante error = adw_alloc_controls(sc);
575 1.13 dante if (error)
576 1.13 dante return; /* (error) */ ;
577 1.13 dante
578 1.13 dante bzero(sc->sc_control, sizeof(struct adw_control));
579 1.13 dante
580 1.13 dante /*
581 1.13 dante * Create and initialize the Control Blocks.
582 1.13 dante */
583 1.13 dante i = adw_create_ccbs(sc, sc->sc_control->ccbs, ADW_MAX_CCB);
584 1.13 dante if (i == 0) {
585 1.13 dante printf("%s: unable to create Control Blocks\n",
586 1.13 dante sc->sc_dev.dv_xname);
587 1.13 dante return; /* (ENOMEM) */ ;
588 1.13 dante } else if (i != ADW_MAX_CCB) {
589 1.13 dante printf("%s: WARNING: only %d of %d Control Blocks"
590 1.13 dante " created\n",
591 1.13 dante sc->sc_dev.dv_xname, i, ADW_MAX_CCB);
592 1.13 dante }
593 1.13 dante
594 1.13 dante /*
595 1.13 dante * Create and initialize the Carriers.
596 1.13 dante */
597 1.13 dante error = adw_alloc_carriers(sc);
598 1.13 dante if (error)
599 1.13 dante return; /* (error) */ ;
600 1.13 dante
601 1.13 dante bzero(sc->sc_control->carriers, ADW_CARRIER_SIZE * ADW_MAX_CARRIER);
602 1.13 dante
603 1.13 dante i = adw_create_carriers(sc);
604 1.13 dante if (i == 0) {
605 1.13 dante printf("%s: unable to create Carriers\n",
606 1.13 dante sc->sc_dev.dv_xname);
607 1.13 dante return; /* (ENOMEM) */ ;
608 1.13 dante } else if (i != ADW_MAX_CARRIER) {
609 1.13 dante printf("%s: WARNING: only %d of %d Carriers created\n",
610 1.13 dante sc->sc_dev.dv_xname, i, ADW_MAX_CARRIER);
611 1.13 dante }
612 1.13 dante
613 1.13 dante
614 1.1 dante /*
615 1.1 dante * Initialize the ASC3550.
616 1.1 dante */
617 1.13 dante error = (sc->chip_type == ADV_CHIP_ASC3550)?
618 1.13 dante AdvInitAsc3550Driver(sc) :
619 1.13 dante AdvInitAsc38C0800Driver(sc);
620 1.13 dante switch (error) {
621 1.2 dante case ASC_IERR_MCODE_CHKSUM:
622 1.2 dante panic("%s: Microcode checksum error",
623 1.2 dante sc->sc_dev.dv_xname);
624 1.2 dante break;
625 1.2 dante
626 1.2 dante case ASC_IERR_ILLEGAL_CONNECTION:
627 1.2 dante panic("%s: All three connectors are in use",
628 1.2 dante sc->sc_dev.dv_xname);
629 1.2 dante break;
630 1.2 dante
631 1.2 dante case ASC_IERR_REVERSED_CABLE:
632 1.2 dante panic("%s: Cable is reversed",
633 1.2 dante sc->sc_dev.dv_xname);
634 1.2 dante break;
635 1.2 dante
636 1.2 dante case ASC_IERR_SINGLE_END_DEVICE:
637 1.2 dante panic("%s: single-ended device is attached to"
638 1.2 dante " one of the connectors",
639 1.2 dante sc->sc_dev.dv_xname);
640 1.2 dante break;
641 1.13 dante
642 1.13 dante case ASC_IERR_NO_CARRIER:
643 1.13 dante panic("%s: no carrier",
644 1.13 dante sc->sc_dev.dv_xname);
645 1.13 dante break;
646 1.13 dante
647 1.13 dante case ASC_WARN_BUSRESET_ERROR:
648 1.13 dante printf("%s: WARNING: Bus Reset Error\n",
649 1.13 dante sc->sc_dev.dv_xname);
650 1.13 dante break;
651 1.1 dante }
652 1.1 dante
653 1.4 thorpej /*
654 1.4 thorpej * Fill in the adapter.
655 1.4 thorpej */
656 1.4 thorpej sc->sc_adapter.scsipi_cmd = adw_scsi_cmd;
657 1.4 thorpej sc->sc_adapter.scsipi_minphys = adwminphys;
658 1.1 dante
659 1.1 dante /*
660 1.1 dante * fill in the prototype scsipi_link.
661 1.1 dante */
662 1.1 dante sc->sc_link.scsipi_scsi.channel = SCSI_CHANNEL_ONLY_ONE;
663 1.1 dante sc->sc_link.adapter_softc = sc;
664 1.1 dante sc->sc_link.scsipi_scsi.adapter_target = sc->chip_scsi_id;
665 1.4 thorpej sc->sc_link.adapter = &sc->sc_adapter;
666 1.1 dante sc->sc_link.device = &adw_dev;
667 1.1 dante sc->sc_link.openings = 4;
668 1.1 dante sc->sc_link.scsipi_scsi.max_target = ADW_MAX_TID;
669 1.5 mjacob sc->sc_link.scsipi_scsi.max_lun = 7;
670 1.1 dante sc->sc_link.type = BUS_SCSI;
671 1.1 dante
672 1.1 dante
673 1.1 dante config_found(&sc->sc_dev, &sc->sc_link, scsiprint);
674 1.1 dante }
675 1.1 dante
676 1.1 dante
677 1.1 dante static void
678 1.1 dante adwminphys(bp)
679 1.1 dante struct buf *bp;
680 1.1 dante {
681 1.1 dante
682 1.1 dante if (bp->b_bcount > ((ADW_MAX_SG_LIST - 1) * PAGE_SIZE))
683 1.1 dante bp->b_bcount = ((ADW_MAX_SG_LIST - 1) * PAGE_SIZE);
684 1.1 dante minphys(bp);
685 1.1 dante }
686 1.1 dante
687 1.1 dante
688 1.1 dante /*
689 1.2 dante * start a scsi operation given the command and the data address.
690 1.2 dante * Also needs the unit, target and lu.
691 1.1 dante */
692 1.1 dante static int
693 1.1 dante adw_scsi_cmd(xs)
694 1.1 dante struct scsipi_xfer *xs;
695 1.1 dante {
696 1.1 dante struct scsipi_link *sc_link = xs->sc_link;
697 1.1 dante ADW_SOFTC *sc = sc_link->adapter_softc;
698 1.1 dante ADW_CCB *ccb;
699 1.14 thorpej int s, fromqueue = 1, dontqueue = 0, nowait = 0, retry = 0;
700 1.14 thorpej int flags;
701 1.1 dante
702 1.1 dante s = splbio(); /* protect the queue */
703 1.1 dante
704 1.1 dante /*
705 1.1 dante * If we're running the queue from adw_done(), we've been
706 1.1 dante * called with the first queue entry as our argument.
707 1.1 dante */
708 1.6 thorpej if (xs == TAILQ_FIRST(&sc->sc_queue)) {
709 1.6 thorpej TAILQ_REMOVE(&sc->sc_queue, xs, adapter_q);
710 1.1 dante fromqueue = 1;
711 1.14 thorpej nowait = 1;
712 1.1 dante } else {
713 1.1 dante
714 1.1 dante /* Polled requests can't be queued for later. */
715 1.12 thorpej dontqueue = xs->xs_control & XS_CTL_POLL;
716 1.1 dante
717 1.1 dante /*
718 1.1 dante * If there are jobs in the queue, run them first.
719 1.1 dante */
720 1.6 thorpej if (TAILQ_FIRST(&sc->sc_queue) != NULL) {
721 1.1 dante /*
722 1.1 dante * If we can't queue, we have to abort, since
723 1.1 dante * we have to preserve order.
724 1.1 dante */
725 1.1 dante if (dontqueue) {
726 1.1 dante splx(s);
727 1.1 dante xs->error = XS_DRIVER_STUFFUP;
728 1.1 dante return (TRY_AGAIN_LATER);
729 1.1 dante }
730 1.1 dante /*
731 1.1 dante * Swap with the first queue entry.
732 1.1 dante */
733 1.6 thorpej TAILQ_INSERT_TAIL(&sc->sc_queue, xs, adapter_q);
734 1.6 thorpej xs = TAILQ_FIRST(&sc->sc_queue);
735 1.6 thorpej TAILQ_REMOVE(&sc->sc_queue, xs, adapter_q);
736 1.1 dante fromqueue = 1;
737 1.1 dante }
738 1.1 dante }
739 1.1 dante
740 1.1 dante
741 1.1 dante /*
742 1.1 dante * get a ccb to use. If the transfer
743 1.1 dante * is from a buf (possibly from interrupt time)
744 1.1 dante * then we can't allow it to sleep
745 1.1 dante */
746 1.1 dante
747 1.14 thorpej flags = xs->xs_control;
748 1.14 thorpej if (nowait)
749 1.14 thorpej flags |= XS_CTL_NOSLEEP;
750 1.14 thorpej if ((ccb = adw_get_ccb(sc, flags)) == NULL) {
751 1.1 dante /*
752 1.1 dante * If we can't queue, we lose.
753 1.1 dante */
754 1.1 dante if (dontqueue) {
755 1.1 dante splx(s);
756 1.1 dante xs->error = XS_DRIVER_STUFFUP;
757 1.1 dante return (TRY_AGAIN_LATER);
758 1.1 dante }
759 1.1 dante /*
760 1.1 dante * Stuff ourselves into the queue, in front
761 1.1 dante * if we came off in the first place.
762 1.1 dante */
763 1.6 thorpej if (fromqueue)
764 1.6 thorpej TAILQ_INSERT_HEAD(&sc->sc_queue, xs, adapter_q);
765 1.6 thorpej else
766 1.6 thorpej TAILQ_INSERT_TAIL(&sc->sc_queue, xs, adapter_q);
767 1.1 dante splx(s);
768 1.1 dante return (SUCCESSFULLY_QUEUED);
769 1.1 dante }
770 1.1 dante splx(s); /* done playing with the queue */
771 1.1 dante
772 1.1 dante ccb->xs = xs;
773 1.1 dante ccb->timeout = xs->timeout;
774 1.1 dante
775 1.14 thorpej if (adw_build_req(xs, ccb, flags)) {
776 1.13 dante retryagain:
777 1.13 dante s = splbio();
778 1.13 dante retry = adw_queue_ccb(sc, ccb, retry);
779 1.13 dante splx(s);
780 1.13 dante
781 1.13 dante switch(retry) {
782 1.13 dante case ADW_BUSY:
783 1.13 dante goto retryagain;
784 1.13 dante
785 1.13 dante case ADW_ERROR:
786 1.13 dante xs->error = XS_DRIVER_STUFFUP;
787 1.13 dante return (COMPLETE);
788 1.13 dante
789 1.13 dante }
790 1.1 dante
791 1.1 dante /*
792 1.1 dante * Usually return SUCCESSFULLY QUEUED
793 1.1 dante */
794 1.12 thorpej if ((xs->xs_control & XS_CTL_POLL) == 0)
795 1.1 dante return (SUCCESSFULLY_QUEUED);
796 1.1 dante
797 1.1 dante /*
798 1.1 dante * If we can't use interrupts, poll on completion
799 1.1 dante */
800 1.1 dante if (adw_poll(sc, xs, ccb->timeout)) {
801 1.1 dante adw_timeout(ccb);
802 1.1 dante if (adw_poll(sc, xs, ccb->timeout))
803 1.1 dante adw_timeout(ccb);
804 1.1 dante }
805 1.1 dante }
806 1.2 dante return (COMPLETE);
807 1.1 dante }
808 1.1 dante
809 1.1 dante
810 1.1 dante /*
811 1.1 dante * Build a request structure for the Wide Boards.
812 1.1 dante */
813 1.1 dante static int
814 1.14 thorpej adw_build_req(xs, ccb, flags)
815 1.2 dante struct scsipi_xfer *xs;
816 1.2 dante ADW_CCB *ccb;
817 1.14 thorpej int flags;
818 1.1 dante {
819 1.2 dante struct scsipi_link *sc_link = xs->sc_link;
820 1.2 dante ADW_SOFTC *sc = sc_link->adapter_softc;
821 1.2 dante bus_dma_tag_t dmat = sc->sc_dmat;
822 1.2 dante ADW_SCSI_REQ_Q *scsiqp;
823 1.2 dante int error;
824 1.1 dante
825 1.1 dante scsiqp = &ccb->scsiq;
826 1.1 dante bzero(scsiqp, sizeof(ADW_SCSI_REQ_Q));
827 1.1 dante
828 1.1 dante /*
829 1.7 dante * Set the ADW_SCSI_REQ_Q 'ccb_ptr' to point to the
830 1.7 dante * physical CCB structure.
831 1.1 dante */
832 1.10 thorpej scsiqp->ccb_ptr = ccb->hashkey;
833 1.1 dante
834 1.1 dante /*
835 1.1 dante * Build the ADW_SCSI_REQ_Q request.
836 1.1 dante */
837 1.1 dante
838 1.1 dante /*
839 1.1 dante * Set CDB length and copy it to the request structure.
840 1.1 dante */
841 1.1 dante bcopy(xs->cmd, &scsiqp->cdb, scsiqp->cdb_len = xs->cmdlen);
842 1.1 dante
843 1.1 dante scsiqp->target_id = sc_link->scsipi_scsi.target;
844 1.1 dante scsiqp->target_lun = sc_link->scsipi_scsi.lun;
845 1.1 dante
846 1.7 dante scsiqp->vsense_addr = &ccb->scsi_sense;
847 1.13 dante scsiqp->sense_addr = sc->sc_dmamap_control->dm_segs[0].ds_addr +
848 1.13 dante ADW_CCB_OFF(ccb) + offsetof(struct adw_ccb, scsi_sense);
849 1.13 dante /* scsiqp->sense_addr = ccb->hashkey +
850 1.10 thorpej offsetof(struct adw_ccb, scsi_sense);
851 1.13 dante */ scsiqp->sense_len = sizeof(struct scsipi_sense_data);
852 1.1 dante
853 1.1 dante /*
854 1.1 dante * Build ADW_SCSI_REQ_Q for a scatter-gather buffer command.
855 1.1 dante */
856 1.1 dante if (xs->datalen) {
857 1.1 dante /*
858 1.1 dante * Map the DMA transfer.
859 1.1 dante */
860 1.1 dante #ifdef TFS
861 1.12 thorpej if (xs->xs_control & SCSI_DATA_UIO) {
862 1.1 dante error = bus_dmamap_load_uio(dmat,
863 1.2 dante ccb->dmamap_xfer, (struct uio *) xs->data,
864 1.14 thorpej (flags & XS_CTL_NOSLEEP) ?
865 1.12 thorpej BUS_DMA_NOWAIT : BUS_DMA_WAITOK);
866 1.1 dante } else
867 1.13 dante #endif /* TFS */
868 1.1 dante {
869 1.1 dante error = bus_dmamap_load(dmat,
870 1.2 dante ccb->dmamap_xfer, xs->data, xs->datalen, NULL,
871 1.14 thorpej (flags & XS_CTL_NOSLEEP) ?
872 1.12 thorpej BUS_DMA_NOWAIT : BUS_DMA_WAITOK);
873 1.1 dante }
874 1.1 dante
875 1.1 dante if (error) {
876 1.1 dante if (error == EFBIG) {
877 1.1 dante printf("%s: adw_scsi_cmd, more than %d dma"
878 1.1 dante " segments\n",
879 1.1 dante sc->sc_dev.dv_xname, ADW_MAX_SG_LIST);
880 1.1 dante } else {
881 1.1 dante printf("%s: adw_scsi_cmd, error %d loading"
882 1.1 dante " dma map\n",
883 1.1 dante sc->sc_dev.dv_xname, error);
884 1.1 dante }
885 1.1 dante
886 1.1 dante xs->error = XS_DRIVER_STUFFUP;
887 1.1 dante adw_free_ccb(sc, ccb);
888 1.1 dante return (0);
889 1.1 dante }
890 1.1 dante bus_dmamap_sync(dmat, ccb->dmamap_xfer, 0,
891 1.1 dante ccb->dmamap_xfer->dm_mapsize,
892 1.13 dante (xs->xs_control & XS_CTL_DATA_IN) ?
893 1.13 dante BUS_DMASYNC_PREREAD : BUS_DMASYNC_PREWRITE);
894 1.1 dante
895 1.1 dante /*
896 1.1 dante * Build scatter-gather list.
897 1.1 dante */
898 1.1 dante scsiqp->data_cnt = xs->datalen;
899 1.7 dante scsiqp->vdata_addr = xs->data;
900 1.1 dante scsiqp->data_addr = ccb->dmamap_xfer->dm_segs[0].ds_addr;
901 1.7 dante bzero(ccb->sg_block, sizeof(ADW_SG_BLOCK) * ADW_NUM_SG_BLOCK);
902 1.7 dante adw_build_sglist(ccb, scsiqp, ccb->sg_block);
903 1.1 dante } else {
904 1.1 dante /*
905 1.1 dante * No data xfer, use non S/G values.
906 1.1 dante */
907 1.1 dante scsiqp->data_cnt = 0;
908 1.1 dante scsiqp->vdata_addr = 0;
909 1.1 dante scsiqp->data_addr = 0;
910 1.1 dante }
911 1.1 dante
912 1.1 dante return (1);
913 1.1 dante }
914 1.1 dante
915 1.1 dante
916 1.1 dante /*
917 1.1 dante * Build scatter-gather list for Wide Boards.
918 1.1 dante */
919 1.1 dante static void
920 1.7 dante adw_build_sglist(ccb, scsiqp, sg_block)
921 1.2 dante ADW_CCB *ccb;
922 1.2 dante ADW_SCSI_REQ_Q *scsiqp;
923 1.7 dante ADW_SG_BLOCK *sg_block;
924 1.1 dante {
925 1.9 thorpej u_long sg_block_next_addr; /* block and its next */
926 1.9 thorpej u_int32_t sg_block_physical_addr;
927 1.13 dante int i; /* how many SG entries */
928 1.1 dante bus_dma_segment_t *sg_list = &ccb->dmamap_xfer->dm_segs[0];
929 1.2 dante int sg_elem_cnt = ccb->dmamap_xfer->dm_nsegs;
930 1.1 dante
931 1.1 dante
932 1.9 thorpej sg_block_next_addr = (u_long) sg_block; /* allow math operation */
933 1.10 thorpej sg_block_physical_addr = ccb->hashkey +
934 1.10 thorpej offsetof(struct adw_ccb, sg_block[0]);
935 1.1 dante scsiqp->sg_real_addr = sg_block_physical_addr;
936 1.1 dante
937 1.1 dante /*
938 1.1 dante * If there are more than NO_OF_SG_PER_BLOCK dma segments (hw sg-list)
939 1.1 dante * then split the request into multiple sg-list blocks.
940 1.1 dante */
941 1.1 dante
942 1.2 dante do {
943 1.2 dante for (i = 0; i < NO_OF_SG_PER_BLOCK; i++) {
944 1.1 dante sg_block->sg_list[i].sg_addr = sg_list->ds_addr;
945 1.1 dante sg_block->sg_list[i].sg_count = sg_list->ds_len;
946 1.1 dante
947 1.2 dante if (--sg_elem_cnt == 0) {
948 1.1 dante /* last entry, get out */
949 1.13 dante sg_block->sg_cnt = i + i;
950 1.2 dante sg_block->sg_ptr = NULL; /* next link = NULL */
951 1.1 dante return;
952 1.1 dante }
953 1.1 dante sg_list++;
954 1.1 dante }
955 1.1 dante sg_block_next_addr += sizeof(ADW_SG_BLOCK);
956 1.1 dante sg_block_physical_addr += sizeof(ADW_SG_BLOCK);
957 1.1 dante
958 1.13 dante sg_block->sg_cnt = NO_OF_SG_PER_BLOCK;
959 1.9 thorpej sg_block->sg_ptr = sg_block_physical_addr;
960 1.2 dante sg_block = (ADW_SG_BLOCK *) sg_block_next_addr; /* virt. addr */
961 1.10 thorpej } while (1);
962 1.1 dante }
963 1.1 dante
964 1.1 dante
965 1.1 dante int
966 1.1 dante adw_intr(arg)
967 1.1 dante void *arg;
968 1.1 dante {
969 1.1 dante ADW_SOFTC *sc = arg;
970 1.1 dante struct scsipi_xfer *xs;
971 1.1 dante
972 1.1 dante
973 1.13 dante if(AdvISR(sc) != ADW_FALSE) {
974 1.13 dante /*
975 1.13 dante * If there are queue entries in the software queue, try to
976 1.13 dante * run the first one. We should be more or less guaranteed
977 1.13 dante * to succeed, since we just freed a CCB.
978 1.13 dante *
979 1.13 dante * NOTE: adw_scsi_cmd() relies on our calling it with
980 1.13 dante * the first entry in the queue.
981 1.13 dante */
982 1.13 dante if ((xs = TAILQ_FIRST(&sc->sc_queue)) != NULL)
983 1.13 dante (void) adw_scsi_cmd(xs);
984 1.13 dante }
985 1.1 dante
986 1.1 dante return (1);
987 1.1 dante }
988 1.1 dante
989 1.1 dante
990 1.1 dante /*
991 1.1 dante * Poll a particular unit, looking for a particular xs
992 1.1 dante */
993 1.1 dante static int
994 1.1 dante adw_poll(sc, xs, count)
995 1.1 dante ADW_SOFTC *sc;
996 1.1 dante struct scsipi_xfer *xs;
997 1.1 dante int count;
998 1.1 dante {
999 1.1 dante
1000 1.1 dante /* timeouts are in msec, so we loop in 1000 usec cycles */
1001 1.1 dante while (count) {
1002 1.1 dante adw_intr(sc);
1003 1.12 thorpej if (xs->xs_status & XS_STS_DONE)
1004 1.1 dante return (0);
1005 1.1 dante delay(1000); /* only happens in boot so ok */
1006 1.1 dante count--;
1007 1.1 dante }
1008 1.1 dante return (1);
1009 1.1 dante }
1010 1.1 dante
1011 1.1 dante
1012 1.1 dante static void
1013 1.1 dante adw_timeout(arg)
1014 1.1 dante void *arg;
1015 1.1 dante {
1016 1.1 dante ADW_CCB *ccb = arg;
1017 1.1 dante struct scsipi_xfer *xs = ccb->xs;
1018 1.1 dante struct scsipi_link *sc_link = xs->sc_link;
1019 1.1 dante ADW_SOFTC *sc = sc_link->adapter_softc;
1020 1.1 dante int s;
1021 1.1 dante
1022 1.1 dante scsi_print_addr(sc_link);
1023 1.1 dante printf("timed out");
1024 1.1 dante
1025 1.1 dante s = splbio();
1026 1.1 dante
1027 1.1 dante /*
1028 1.1 dante * If it has been through before, then a previous abort has failed,
1029 1.1 dante * don't try abort again, reset the bus instead.
1030 1.1 dante */
1031 1.11 dante if (ccb->flags & CCB_ABORTED) {
1032 1.11 dante /*
1033 1.11 dante * Abort Timed Out
1034 1.11 dante * Lets try resetting the bus!
1035 1.11 dante */
1036 1.11 dante printf(" AGAIN. Resetting SCSI Bus\n");
1037 1.11 dante ccb->flags &= ~CCB_ABORTED;
1038 1.11 dante /* AdvResetSCSIBus() will call sbreset_callback() */
1039 1.1 dante AdvResetSCSIBus(sc);
1040 1.1 dante } else {
1041 1.11 dante /*
1042 1.11 dante * Abort the operation that has timed out
1043 1.11 dante */
1044 1.1 dante printf("\n");
1045 1.11 dante xs->error = XS_TIMEOUT;
1046 1.11 dante ccb->flags |= CCB_ABORTING;
1047 1.11 dante /* ADW_ABORT_CCB() will implicitly call isr_callback() */
1048 1.1 dante ADW_ABORT_CCB(sc, ccb);
1049 1.1 dante }
1050 1.1 dante
1051 1.1 dante splx(s);
1052 1.1 dante }
1053 1.1 dante
1054 1.1 dante
1055 1.1 dante /******************************************************************************/
1056 1.7 dante /* WIDE boards Interrupt callbacks */
1057 1.1 dante /******************************************************************************/
1058 1.1 dante
1059 1.1 dante
1060 1.1 dante /*
1061 1.13 dante * adw__isr_callback() - Second Level Interrupt Handler called by AdvISR()
1062 1.1 dante *
1063 1.1 dante * Interrupt callback function for the Wide SCSI Adv Library.
1064 1.1 dante */
1065 1.1 dante static void
1066 1.13 dante adw_isr_callback(sc, scsiq)
1067 1.1 dante ADW_SOFTC *sc;
1068 1.1 dante ADW_SCSI_REQ_Q *scsiq;
1069 1.1 dante {
1070 1.2 dante bus_dma_tag_t dmat = sc->sc_dmat;
1071 1.7 dante ADW_CCB *ccb;
1072 1.7 dante struct scsipi_xfer *xs;
1073 1.1 dante struct scsipi_sense_data *s1, *s2;
1074 1.13 dante // int s;
1075 1.1 dante
1076 1.7 dante
1077 1.7 dante ccb = adw_ccb_phys_kv(sc, scsiq->ccb_ptr);
1078 1.11 dante
1079 1.15 thorpej callout_stop(&ccb->xs->xs_callout);
1080 1.11 dante
1081 1.13 dante /* if(ccb->flags & CCB_ABORTING) {
1082 1.11 dante printf("Retrying request\n");
1083 1.11 dante ccb->flags &= ~CCB_ABORTING;
1084 1.11 dante ccb->flags |= CCB_ABORTED;
1085 1.11 dante s = splbio();
1086 1.11 dante adw_queue_ccb(sc, ccb);
1087 1.11 dante splx(s);
1088 1.11 dante return;
1089 1.11 dante }
1090 1.13 dante */
1091 1.7 dante xs = ccb->xs;
1092 1.1 dante
1093 1.1 dante /*
1094 1.1 dante * If we were a data transfer, unload the map that described
1095 1.1 dante * the data buffer.
1096 1.1 dante */
1097 1.1 dante if (xs->datalen) {
1098 1.1 dante bus_dmamap_sync(dmat, ccb->dmamap_xfer, 0,
1099 1.1 dante ccb->dmamap_xfer->dm_mapsize,
1100 1.12 thorpej (xs->xs_control & XS_CTL_DATA_IN) ?
1101 1.12 thorpej BUS_DMASYNC_POSTREAD : BUS_DMASYNC_POSTWRITE);
1102 1.1 dante bus_dmamap_unload(dmat, ccb->dmamap_xfer);
1103 1.1 dante }
1104 1.1 dante if ((ccb->flags & CCB_ALLOC) == 0) {
1105 1.1 dante printf("%s: exiting ccb not allocated!\n", sc->sc_dev.dv_xname);
1106 1.1 dante Debugger();
1107 1.1 dante return;
1108 1.1 dante }
1109 1.1 dante /*
1110 1.1 dante * Check for an underrun condition.
1111 1.1 dante */
1112 1.2 dante /*
1113 1.2 dante * if (xs->request_bufflen != 0 && scsiqp->data_cnt != 0) {
1114 1.2 dante * ASC_DBG1(1, "adw_isr_callback: underrun condition %lu bytes\n",
1115 1.2 dante * scsiqp->data_cnt); underrun = ASC_TRUE; }
1116 1.2 dante */
1117 1.1 dante /*
1118 1.1 dante * 'done_status' contains the command's ending status.
1119 1.1 dante */
1120 1.1 dante switch (scsiq->done_status) {
1121 1.1 dante case QD_NO_ERROR:
1122 1.1 dante switch (scsiq->host_status) {
1123 1.1 dante case QHSTA_NO_ERROR:
1124 1.1 dante xs->error = XS_NOERROR;
1125 1.1 dante xs->resid = 0;
1126 1.1 dante break;
1127 1.1 dante default:
1128 1.1 dante /* QHSTA error occurred. */
1129 1.1 dante xs->error = XS_DRIVER_STUFFUP;
1130 1.1 dante break;
1131 1.1 dante }
1132 1.13 dante break;
1133 1.1 dante
1134 1.1 dante case QD_WITH_ERROR:
1135 1.1 dante switch (scsiq->host_status) {
1136 1.1 dante case QHSTA_NO_ERROR:
1137 1.11 dante switch(scsiq->scsi_status) {
1138 1.11 dante case SS_CHK_CONDITION:
1139 1.11 dante case SS_CMD_TERMINATED:
1140 1.1 dante s1 = &ccb->scsi_sense;
1141 1.1 dante s2 = &xs->sense.scsi_sense;
1142 1.1 dante *s2 = *s1;
1143 1.1 dante xs->error = XS_SENSE;
1144 1.11 dante break;
1145 1.11 dante case SS_TARGET_BUSY:
1146 1.11 dante case SS_RSERV_CONFLICT:
1147 1.11 dante case SS_QUEUE_FULL:
1148 1.11 dante xs->error = XS_DRIVER_STUFFUP;
1149 1.11 dante break;
1150 1.11 dante case SS_CONDITION_MET:
1151 1.11 dante case SS_INTERMID:
1152 1.11 dante case SS_INTERMID_COND_MET:
1153 1.1 dante xs->error = XS_DRIVER_STUFFUP;
1154 1.11 dante break;
1155 1.11 dante case SS_GOOD:
1156 1.11 dante break;
1157 1.1 dante }
1158 1.1 dante break;
1159 1.1 dante
1160 1.11 dante case QHSTA_M_SEL_TIMEOUT:
1161 1.11 dante xs->error = XS_DRIVER_STUFFUP;
1162 1.11 dante break;
1163 1.11 dante
1164 1.1 dante default:
1165 1.1 dante /* Some other QHSTA error occurred. */
1166 1.1 dante xs->error = XS_DRIVER_STUFFUP;
1167 1.1 dante break;
1168 1.1 dante }
1169 1.1 dante break;
1170 1.1 dante
1171 1.1 dante case QD_ABORTED_BY_HOST:
1172 1.11 dante xs->error = XS_DRIVER_STUFFUP;
1173 1.11 dante break;
1174 1.11 dante
1175 1.1 dante default:
1176 1.1 dante xs->error = XS_DRIVER_STUFFUP;
1177 1.1 dante break;
1178 1.1 dante }
1179 1.1 dante
1180 1.1 dante adw_free_ccb(sc, ccb);
1181 1.12 thorpej xs->xs_status |= XS_STS_DONE;
1182 1.1 dante scsipi_done(xs);
1183 1.11 dante }
1184 1.11 dante
1185 1.11 dante
1186 1.13 dante /*
1187 1.13 dante * adv_async_callback() - Adv Library asynchronous event callback function.
1188 1.13 dante */
1189 1.11 dante static void
1190 1.13 dante adw_async_callback(sc, code)
1191 1.11 dante ADW_SOFTC *sc;
1192 1.13 dante u_int8_t code;
1193 1.11 dante {
1194 1.13 dante switch (code) {
1195 1.13 dante case ADV_ASYNC_SCSI_BUS_RESET_DET:
1196 1.13 dante /*
1197 1.13 dante * The firmware detected a SCSI Bus reset.
1198 1.13 dante */
1199 1.13 dante break;
1200 1.13 dante
1201 1.13 dante case ADV_ASYNC_RDMA_FAILURE:
1202 1.13 dante /*
1203 1.13 dante * Handle RDMA failure by resetting the SCSI Bus and
1204 1.13 dante * possibly the chip if it is unresponsive. Log the error
1205 1.13 dante * with a unique code.
1206 1.13 dante */
1207 1.13 dante AdvResetSCSIBus(sc);
1208 1.13 dante break;
1209 1.13 dante
1210 1.13 dante case ADV_HOST_SCSI_BUS_RESET:
1211 1.13 dante /*
1212 1.13 dante * Host generated SCSI bus reset occurred.
1213 1.13 dante */
1214 1.13 dante break;
1215 1.13 dante
1216 1.13 dante default:
1217 1.13 dante break;
1218 1.13 dante }
1219 1.1 dante }
1220