isp_netbsd.c revision 1.29 1 1.29 mjacob /* $NetBSD: isp_netbsd.c,v 1.29 2000/08/08 22:58:31 mjacob Exp $ */
2 1.1 mjacob /*
3 1.1 mjacob * Platform (NetBSD) dependent common attachment code for Qlogic adapters.
4 1.15 mjacob * Matthew Jacob <mjacob (at) nas.nasa.gov>
5 1.15 mjacob */
6 1.15 mjacob /*
7 1.15 mjacob * Copyright (C) 1997, 1998, 1999 National Aeronautics & Space Administration
8 1.1 mjacob * All rights reserved.
9 1.1 mjacob *
10 1.1 mjacob * Redistribution and use in source and binary forms, with or without
11 1.1 mjacob * modification, are permitted provided that the following conditions
12 1.1 mjacob * are met:
13 1.1 mjacob * 1. Redistributions of source code must retain the above copyright
14 1.15 mjacob * notice, this list of conditions and the following disclaimer.
15 1.1 mjacob * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 mjacob * notice, this list of conditions and the following disclaimer in the
17 1.1 mjacob * documentation and/or other materials provided with the distribution.
18 1.1 mjacob * 3. The name of the author may not be used to endorse or promote products
19 1.15 mjacob * derived from this software without specific prior written permission
20 1.1 mjacob *
21 1.15 mjacob * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
22 1.15 mjacob * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
23 1.15 mjacob * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
24 1.15 mjacob * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
25 1.15 mjacob * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
26 1.15 mjacob * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
27 1.15 mjacob * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
28 1.15 mjacob * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
29 1.15 mjacob * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
30 1.15 mjacob * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
31 1.1 mjacob */
32 1.1 mjacob
33 1.1 mjacob #include <dev/ic/isp_netbsd.h>
34 1.17 mjacob #include <sys/scsiio.h>
35 1.1 mjacob
36 1.27 mjacob
37 1.27 mjacob /*
38 1.27 mjacob * Set a timeout for the watchdogging of a command.
39 1.27 mjacob *
40 1.27 mjacob * The dimensional analysis is
41 1.27 mjacob *
42 1.27 mjacob * milliseconds * (seconds/millisecond) * (ticks/second) = ticks
43 1.27 mjacob *
44 1.27 mjacob * =
45 1.27 mjacob *
46 1.27 mjacob * (milliseconds / 1000) * hz = ticks
47 1.27 mjacob *
48 1.27 mjacob *
49 1.27 mjacob * For timeouts less than 1 second, we'll get zero. Because of this, and
50 1.27 mjacob * because we want to establish *our* timeout to be longer than what the
51 1.27 mjacob * firmware might do, we just add 3 seconds at the back end.
52 1.27 mjacob */
53 1.27 mjacob #define _XT(xs) ((((xs)->timeout/1000) * hz) + (3 * hz))
54 1.26 mjacob
55 1.1 mjacob static void ispminphys __P((struct buf *));
56 1.28 mjacob static int32_t ispcmd __P((XS_T *));
57 1.17 mjacob static int
58 1.17 mjacob ispioctl __P((struct scsipi_link *, u_long, caddr_t, int, struct proc *));
59 1.1 mjacob
60 1.1 mjacob static struct scsipi_device isp_dev = { NULL, NULL, NULL, NULL };
61 1.28 mjacob static int isp_polled_cmd __P((struct ispsoftc *, XS_T *));
62 1.26 mjacob static void isp_dog __P((void *));
63 1.17 mjacob static void isp_command_requeue __P((void *));
64 1.10 mjacob static void isp_internal_restart __P((void *));
65 1.10 mjacob
66 1.1 mjacob /*
67 1.1 mjacob * Complete attachment of hardware, include subdevices.
68 1.1 mjacob */
69 1.1 mjacob void
70 1.1 mjacob isp_attach(isp)
71 1.1 mjacob struct ispsoftc *isp;
72 1.1 mjacob {
73 1.28 mjacob int maxluns;
74 1.6 thorpej isp->isp_osinfo._adapter.scsipi_minphys = ispminphys;
75 1.17 mjacob isp->isp_osinfo._adapter.scsipi_ioctl = ispioctl;
76 1.29 mjacob isp->isp_osinfo._adapter.scsipi_cmd = ispcmd;
77 1.6 thorpej
78 1.1 mjacob isp->isp_state = ISP_RUNSTATE;
79 1.21 mjacob isp->isp_osinfo._link.scsipi_scsi.channel =
80 1.21 mjacob (IS_DUALBUS(isp))? 0 : SCSI_CHANNEL_ONLY_ONE;
81 1.1 mjacob isp->isp_osinfo._link.adapter_softc = isp;
82 1.1 mjacob isp->isp_osinfo._link.device = &isp_dev;
83 1.6 thorpej isp->isp_osinfo._link.adapter = &isp->isp_osinfo._adapter;
84 1.17 mjacob isp->isp_osinfo._link.openings = isp->isp_maxcmds;
85 1.26 mjacob isp->isp_osinfo._link.scsipi_scsi.max_lun = maxluns;
86 1.28 mjacob /*
87 1.28 mjacob * Until the midlayer is fixed to use REPORT LUNS, limit to 8 luns.
88 1.28 mjacob */
89 1.28 mjacob isp->isp_osinfo._link.scsipi_scsi.max_lun =
90 1.28 mjacob (isp->isp_maxluns < 7)? isp->isp_maxluns - 1 : 7;
91 1.28 mjacob TAILQ_INIT(&isp->isp_osinfo.waitq); /* The 2nd bus will share.. */
92 1.1 mjacob
93 1.15 mjacob if (IS_FC(isp)) {
94 1.1 mjacob isp->isp_osinfo._link.scsipi_scsi.max_target = MAX_FC_TARG-1;
95 1.1 mjacob } else {
96 1.14 mjacob sdparam *sdp = isp->isp_param;
97 1.1 mjacob isp->isp_osinfo._link.scsipi_scsi.max_target = MAX_TARGETS-1;
98 1.1 mjacob isp->isp_osinfo._link.scsipi_scsi.adapter_target =
99 1.14 mjacob sdp->isp_initiator_id;
100 1.17 mjacob isp->isp_osinfo.discovered[0] = 1 << sdp->isp_initiator_id;
101 1.21 mjacob if (IS_DUALBUS(isp)) {
102 1.14 mjacob isp->isp_osinfo._link_b = isp->isp_osinfo._link;
103 1.14 mjacob sdp++;
104 1.18 mjacob isp->isp_osinfo.discovered[1] =
105 1.18 mjacob 1 << sdp->isp_initiator_id;
106 1.14 mjacob isp->isp_osinfo._link_b.scsipi_scsi.adapter_target =
107 1.14 mjacob sdp->isp_initiator_id;
108 1.14 mjacob isp->isp_osinfo._link_b.scsipi_scsi.channel = 1;
109 1.26 mjacob isp->isp_osinfo._link_b.scsipi_scsi.max_lun =
110 1.26 mjacob isp->isp_osinfo._link.scsipi_scsi.max_lun;
111 1.14 mjacob }
112 1.1 mjacob }
113 1.1 mjacob isp->isp_osinfo._link.type = BUS_SCSI;
114 1.8 mjacob
115 1.8 mjacob /*
116 1.25 he * Send a SCSI Bus Reset.
117 1.10 mjacob */
118 1.14 mjacob if (IS_SCSI(isp)) {
119 1.14 mjacob int bus = 0;
120 1.28 mjacob ISP_LOCK(isp);
121 1.14 mjacob (void) isp_control(isp, ISPCTL_RESET_BUS, &bus);
122 1.21 mjacob if (IS_DUALBUS(isp)) {
123 1.14 mjacob bus++;
124 1.14 mjacob (void) isp_control(isp, ISPCTL_RESET_BUS, &bus);
125 1.14 mjacob }
126 1.29 mjacob ISP_UNLOCK(isp);
127 1.19 mjacob } else {
128 1.28 mjacob int defid;
129 1.19 mjacob fcparam *fcp = isp->isp_param;
130 1.19 mjacob delay(2 * 1000000);
131 1.28 mjacob defid = MAX_FC_TARG;
132 1.28 mjacob ISP_LOCK(isp);
133 1.28 mjacob /*
134 1.28 mjacob * We probably won't have clock interrupts running,
135 1.28 mjacob * so we'll be really short (smoke test, really)
136 1.28 mjacob * at this time.
137 1.28 mjacob */
138 1.28 mjacob if (isp_control(isp, ISPCTL_FCLINK_TEST, NULL)) {
139 1.28 mjacob (void) isp_control(isp, ISPCTL_PDB_SYNC, NULL);
140 1.19 mjacob if (fcp->isp_fwstate == FW_READY &&
141 1.19 mjacob fcp->isp_loopstate >= LOOP_PDB_RCVD) {
142 1.28 mjacob defid = fcp->isp_loopid;
143 1.19 mjacob }
144 1.19 mjacob }
145 1.28 mjacob ISP_UNLOCK(isp);
146 1.28 mjacob isp->isp_osinfo._link.scsipi_scsi.adapter_target = defid;
147 1.11 mjacob }
148 1.10 mjacob
149 1.10 mjacob /*
150 1.28 mjacob * After this point, we'll be doing the new configuration
151 1.28 mjacob * schema which allows interrups, so we can do tsleep/wakeup
152 1.28 mjacob * for mailbox stuff at that point.
153 1.28 mjacob */
154 1.28 mjacob isp->isp_osinfo.no_mbox_ints = 0;
155 1.28 mjacob
156 1.28 mjacob /*
157 1.8 mjacob * And attach children (if any).
158 1.8 mjacob */
159 1.1 mjacob config_found((void *)isp, &isp->isp_osinfo._link, scsiprint);
160 1.21 mjacob if (IS_DUALBUS(isp)) {
161 1.14 mjacob config_found((void *)isp, &isp->isp_osinfo._link_b, scsiprint);
162 1.14 mjacob }
163 1.1 mjacob }
164 1.1 mjacob
165 1.1 mjacob /*
166 1.1 mjacob * minphys our xfers
167 1.1 mjacob *
168 1.1 mjacob * Unfortunately, the buffer pointer describes the target device- not the
169 1.1 mjacob * adapter device, so we can't use the pointer to find out what kind of
170 1.1 mjacob * adapter we are and adjust accordingly.
171 1.1 mjacob */
172 1.1 mjacob
173 1.1 mjacob static void
174 1.1 mjacob ispminphys(bp)
175 1.1 mjacob struct buf *bp;
176 1.1 mjacob {
177 1.1 mjacob /*
178 1.1 mjacob * XX: Only the 1020 has a 24 bit limit.
179 1.1 mjacob */
180 1.1 mjacob if (bp->b_bcount >= (1 << 24)) {
181 1.1 mjacob bp->b_bcount = (1 << 24);
182 1.1 mjacob }
183 1.1 mjacob minphys(bp);
184 1.1 mjacob }
185 1.1 mjacob
186 1.17 mjacob static int
187 1.17 mjacob ispioctl(sc_link, cmd, addr, flag, p)
188 1.17 mjacob struct scsipi_link *sc_link;
189 1.17 mjacob u_long cmd;
190 1.17 mjacob caddr_t addr;
191 1.17 mjacob int flag;
192 1.17 mjacob struct proc *p;
193 1.17 mjacob {
194 1.17 mjacob struct ispsoftc *isp = sc_link->adapter_softc;
195 1.17 mjacob int s, chan, retval = ENOTTY;
196 1.17 mjacob
197 1.29 mjacob chan = (sc_link->scsipi_scsi.channel == SCSI_CHANNEL_ONLY_ONE)? 0 :
198 1.29 mjacob sc_link->scsipi_scsi.channel;
199 1.29 mjacob
200 1.17 mjacob switch (cmd) {
201 1.29 mjacob case SCBUSACCEL:
202 1.29 mjacob {
203 1.29 mjacob struct scbusaccel_args *sp = (struct scbusaccel_args *)addr;
204 1.29 mjacob if (IS_SCSI(isp) && sp->sa_lun == 0) {
205 1.29 mjacob int dflags = 0;
206 1.29 mjacob sdparam *sdp = SDPARAM(isp);
207 1.29 mjacob
208 1.29 mjacob sdp += chan;
209 1.29 mjacob if (sp->sa_flags & SC_ACCEL_TAGS)
210 1.29 mjacob dflags |= DPARM_TQING;
211 1.29 mjacob if (sp->sa_flags & SC_ACCEL_WIDE)
212 1.29 mjacob dflags |= DPARM_WIDE;
213 1.29 mjacob if (sp->sa_flags & SC_ACCEL_SYNC)
214 1.29 mjacob dflags |= DPARM_SYNC;
215 1.29 mjacob s = splbio();
216 1.29 mjacob sdp->isp_devparam[sp->sa_target].dev_flags |= dflags;
217 1.29 mjacob dflags = sdp->isp_devparam[sp->sa_target].dev_flags;
218 1.29 mjacob sdp->isp_devparam[sp->sa_target].dev_update = 1;
219 1.29 mjacob isp->isp_update |= (1 << chan);
220 1.29 mjacob splx(s);
221 1.29 mjacob isp_prt(isp, ISP_LOGDEBUG1,
222 1.29 mjacob "ispioctl: device flags 0x%x for %d.%d.X",
223 1.29 mjacob dflags, chan, sp->sa_target);
224 1.29 mjacob }
225 1.29 mjacob retval = 0;
226 1.29 mjacob break;
227 1.29 mjacob }
228 1.17 mjacob case SCBUSIORESET:
229 1.17 mjacob s = splbio();
230 1.17 mjacob if (isp_control(isp, ISPCTL_RESET_BUS, &chan))
231 1.17 mjacob retval = EIO;
232 1.17 mjacob else
233 1.17 mjacob retval = 0;
234 1.17 mjacob (void) splx(s);
235 1.17 mjacob break;
236 1.17 mjacob default:
237 1.17 mjacob break;
238 1.3 mjacob }
239 1.17 mjacob return (retval);
240 1.17 mjacob }
241 1.17 mjacob
242 1.17 mjacob
243 1.17 mjacob static int32_t
244 1.17 mjacob ispcmd(xs)
245 1.28 mjacob XS_T *xs;
246 1.17 mjacob {
247 1.17 mjacob struct ispsoftc *isp;
248 1.17 mjacob int result, s;
249 1.11 mjacob
250 1.17 mjacob isp = XS_ISP(xs);
251 1.17 mjacob s = splbio();
252 1.11 mjacob if (isp->isp_state < ISP_RUNSTATE) {
253 1.11 mjacob DISABLE_INTS(isp);
254 1.11 mjacob isp_init(isp);
255 1.11 mjacob if (isp->isp_state != ISP_INITSTATE) {
256 1.11 mjacob ENABLE_INTS(isp);
257 1.11 mjacob (void) splx(s);
258 1.11 mjacob XS_SETERR(xs, HBA_BOTCH);
259 1.17 mjacob return (COMPLETE);
260 1.11 mjacob }
261 1.11 mjacob isp->isp_state = ISP_RUNSTATE;
262 1.11 mjacob ENABLE_INTS(isp);
263 1.11 mjacob }
264 1.11 mjacob
265 1.10 mjacob /*
266 1.10 mjacob * Check for queue blockage...
267 1.10 mjacob */
268 1.10 mjacob if (isp->isp_osinfo.blocked) {
269 1.16 thorpej if (xs->xs_control & XS_CTL_POLL) {
270 1.10 mjacob xs->error = XS_DRIVER_STUFFUP;
271 1.10 mjacob splx(s);
272 1.10 mjacob return (TRY_AGAIN_LATER);
273 1.10 mjacob }
274 1.10 mjacob TAILQ_INSERT_TAIL(&isp->isp_osinfo.waitq, xs, adapter_q);
275 1.10 mjacob splx(s);
276 1.17 mjacob return (SUCCESSFULLY_QUEUED);
277 1.10 mjacob }
278 1.17 mjacob
279 1.26 mjacob if (xs->xs_control & XS_CTL_POLL) {
280 1.28 mjacob volatile u_int8_t ombi = isp->isp_osinfo.no_mbox_ints;
281 1.28 mjacob isp->isp_osinfo.no_mbox_ints = 1;
282 1.26 mjacob result = isp_polled_cmd(isp, xs);
283 1.28 mjacob isp->isp_osinfo.no_mbox_ints = ombi;
284 1.10 mjacob (void) splx(s);
285 1.3 mjacob return (result);
286 1.1 mjacob }
287 1.1 mjacob
288 1.28 mjacob result = isp_start(xs);
289 1.26 mjacob switch (result) {
290 1.26 mjacob case CMD_QUEUED:
291 1.26 mjacob result = SUCCESSFULLY_QUEUED;
292 1.26 mjacob if (xs->timeout) {
293 1.26 mjacob callout_reset(&xs->xs_callout, _XT(xs), isp_dog, xs);
294 1.26 mjacob }
295 1.26 mjacob break;
296 1.26 mjacob case CMD_EAGAIN:
297 1.26 mjacob result = TRY_AGAIN_LATER;
298 1.26 mjacob break;
299 1.26 mjacob case CMD_RQLATER:
300 1.26 mjacob result = SUCCESSFULLY_QUEUED;
301 1.26 mjacob callout_reset(&xs->xs_callout, hz, isp_command_requeue, xs);
302 1.26 mjacob break;
303 1.26 mjacob case CMD_COMPLETE:
304 1.26 mjacob result = COMPLETE;
305 1.26 mjacob break;
306 1.26 mjacob }
307 1.26 mjacob (void) splx(s);
308 1.26 mjacob return (result);
309 1.26 mjacob }
310 1.26 mjacob
311 1.26 mjacob static int
312 1.26 mjacob isp_polled_cmd(isp, xs)
313 1.26 mjacob struct ispsoftc *isp;
314 1.28 mjacob XS_T *xs;
315 1.26 mjacob {
316 1.26 mjacob int result;
317 1.26 mjacob int infinite = 0, mswait;
318 1.26 mjacob
319 1.28 mjacob result = isp_start(xs);
320 1.26 mjacob
321 1.17 mjacob switch (result) {
322 1.17 mjacob case CMD_QUEUED:
323 1.17 mjacob result = SUCCESSFULLY_QUEUED;
324 1.17 mjacob break;
325 1.17 mjacob case CMD_RQLATER:
326 1.17 mjacob case CMD_EAGAIN:
327 1.17 mjacob if (XS_NOERR(xs)) {
328 1.17 mjacob xs->error = XS_DRIVER_STUFFUP;
329 1.17 mjacob }
330 1.17 mjacob result = TRY_AGAIN_LATER;
331 1.17 mjacob break;
332 1.17 mjacob case CMD_COMPLETE:
333 1.17 mjacob result = COMPLETE;
334 1.17 mjacob break;
335 1.17 mjacob
336 1.17 mjacob }
337 1.26 mjacob
338 1.26 mjacob if (result != SUCCESSFULLY_QUEUED) {
339 1.26 mjacob return (result);
340 1.26 mjacob }
341 1.26 mjacob
342 1.1 mjacob /*
343 1.1 mjacob * If we can't use interrupts, poll on completion.
344 1.1 mjacob */
345 1.26 mjacob if ((mswait = XS_TIME(xs)) == 0)
346 1.26 mjacob infinite = 1;
347 1.26 mjacob
348 1.26 mjacob while (mswait || infinite) {
349 1.26 mjacob if (isp_intr((void *)isp)) {
350 1.26 mjacob if (XS_CMD_DONE_P(xs)) {
351 1.26 mjacob break;
352 1.1 mjacob }
353 1.1 mjacob }
354 1.28 mjacob USEC_DELAY(1000);
355 1.26 mjacob mswait -= 1;
356 1.26 mjacob }
357 1.26 mjacob
358 1.26 mjacob /*
359 1.26 mjacob * If no other error occurred but we didn't finish,
360 1.26 mjacob * something bad happened.
361 1.26 mjacob */
362 1.26 mjacob if (XS_CMD_DONE_P(xs) == 0) {
363 1.26 mjacob if (isp_control(isp, ISPCTL_ABORT_CMD, xs)) {
364 1.28 mjacob isp_reinit(isp);
365 1.26 mjacob }
366 1.26 mjacob if (XS_NOERR(xs)) {
367 1.26 mjacob XS_SETERR(xs, HBA_BOTCH);
368 1.26 mjacob }
369 1.1 mjacob }
370 1.26 mjacob result = COMPLETE;
371 1.17 mjacob return (result);
372 1.1 mjacob }
373 1.1 mjacob
374 1.26 mjacob void
375 1.26 mjacob isp_done(xs)
376 1.28 mjacob XS_T *xs;
377 1.1 mjacob {
378 1.26 mjacob XS_CMD_S_DONE(xs);
379 1.26 mjacob if (XS_CMD_WDOG_P(xs) == 0) {
380 1.26 mjacob struct ispsoftc *isp = XS_ISP(xs);
381 1.26 mjacob callout_stop(&xs->xs_callout);
382 1.26 mjacob if (XS_CMD_GRACE_P(xs)) {
383 1.28 mjacob isp_prt(isp, ISP_LOGDEBUG1,
384 1.28 mjacob "finished command on borrowed time");
385 1.1 mjacob }
386 1.26 mjacob XS_CMD_S_CLEAR(xs);
387 1.26 mjacob scsipi_done(xs);
388 1.1 mjacob }
389 1.8 mjacob }
390 1.8 mjacob
391 1.8 mjacob static void
392 1.26 mjacob isp_dog(arg)
393 1.8 mjacob void *arg;
394 1.8 mjacob {
395 1.28 mjacob XS_T *xs = arg;
396 1.26 mjacob struct ispsoftc *isp = XS_ISP(xs);
397 1.26 mjacob u_int32_t handle;
398 1.26 mjacob int s = splbio();
399 1.8 mjacob
400 1.8 mjacob /*
401 1.26 mjacob * We've decided this command is dead. Make sure we're not trying
402 1.26 mjacob * to kill a command that's already dead by getting it's handle and
403 1.26 mjacob * and seeing whether it's still alive.
404 1.26 mjacob */
405 1.26 mjacob handle = isp_find_handle(isp, xs);
406 1.26 mjacob if (handle) {
407 1.26 mjacob u_int16_t r, r1, i;
408 1.26 mjacob
409 1.26 mjacob if (XS_CMD_DONE_P(xs)) {
410 1.28 mjacob isp_prt(isp, ISP_LOGDEBUG1,
411 1.28 mjacob "watchdog found done cmd (handle 0x%x)", handle);
412 1.26 mjacob (void) splx(s);
413 1.26 mjacob return;
414 1.26 mjacob }
415 1.26 mjacob
416 1.26 mjacob if (XS_CMD_WDOG_P(xs)) {
417 1.28 mjacob isp_prt(isp, ISP_LOGDEBUG1,
418 1.28 mjacob "recursive watchdog (handle 0x%x)", handle);
419 1.26 mjacob (void) splx(s);
420 1.26 mjacob return;
421 1.26 mjacob }
422 1.26 mjacob
423 1.26 mjacob XS_CMD_S_WDOG(xs);
424 1.26 mjacob
425 1.26 mjacob i = 0;
426 1.26 mjacob do {
427 1.26 mjacob r = ISP_READ(isp, BIU_ISR);
428 1.28 mjacob USEC_DELAY(1);
429 1.26 mjacob r1 = ISP_READ(isp, BIU_ISR);
430 1.26 mjacob } while (r != r1 && ++i < 1000);
431 1.26 mjacob
432 1.26 mjacob if (INT_PENDING(isp, r) && isp_intr(isp) && XS_CMD_DONE_P(xs)) {
433 1.28 mjacob isp_prt(isp, ISP_LOGDEBUG1, "watchdog cleanup (%x, %x)",
434 1.28 mjacob handle, r);
435 1.26 mjacob XS_CMD_C_WDOG(xs);
436 1.26 mjacob isp_done(xs);
437 1.26 mjacob } else if (XS_CMD_GRACE_P(xs)) {
438 1.28 mjacob isp_prt(isp, ISP_LOGDEBUG1, "watchdog timeout (%x, %x)",
439 1.28 mjacob handle, r);
440 1.26 mjacob /*
441 1.26 mjacob * Make sure the command is *really* dead before we
442 1.26 mjacob * release the handle (and DMA resources) for reuse.
443 1.26 mjacob */
444 1.26 mjacob (void) isp_control(isp, ISPCTL_ABORT_CMD, arg);
445 1.26 mjacob
446 1.26 mjacob /*
447 1.26 mjacob * After this point, the comamnd is really dead.
448 1.26 mjacob */
449 1.26 mjacob if (XS_XFRLEN(xs)) {
450 1.26 mjacob ISP_DMAFREE(isp, xs, handle);
451 1.26 mjacob }
452 1.26 mjacob isp_destroy_handle(isp, handle);
453 1.26 mjacob XS_SETERR(xs, XS_TIMEOUT);
454 1.26 mjacob XS_CMD_S_CLEAR(xs);
455 1.26 mjacob isp_done(xs);
456 1.26 mjacob } else {
457 1.26 mjacob u_int16_t iptr, optr;
458 1.26 mjacob ispreq_t *mp;
459 1.28 mjacob isp_prt(isp, ISP_LOGDEBUG2,
460 1.28 mjacob "possible command timeout (%x, %x)", handle, r);
461 1.26 mjacob XS_CMD_C_WDOG(xs);
462 1.26 mjacob callout_reset(&xs->xs_callout, hz, isp_dog, xs);
463 1.26 mjacob if (isp_getrqentry(isp, &iptr, &optr, (void **) &mp)) {
464 1.26 mjacob (void) splx(s);
465 1.26 mjacob return;
466 1.26 mjacob }
467 1.26 mjacob XS_CMD_S_GRACE(xs);
468 1.26 mjacob MEMZERO((void *) mp, sizeof (*mp));
469 1.26 mjacob mp->req_header.rqs_entry_count = 1;
470 1.26 mjacob mp->req_header.rqs_entry_type = RQSTYPE_MARKER;
471 1.26 mjacob mp->req_modifier = SYNC_ALL;
472 1.26 mjacob mp->req_target = XS_CHANNEL(xs) << 7;
473 1.26 mjacob ISP_SWIZZLE_REQUEST(isp, mp);
474 1.26 mjacob ISP_ADD_REQUEST(isp, iptr);
475 1.8 mjacob }
476 1.26 mjacob } else if (isp->isp_dblev) {
477 1.28 mjacob isp_prt(isp, ISP_LOGDEBUG2, "watchdog with no command");
478 1.8 mjacob }
479 1.17 mjacob (void) splx(s);
480 1.8 mjacob }
481 1.8 mjacob
482 1.8 mjacob /*
483 1.8 mjacob * Free any associated resources prior to decommissioning and
484 1.8 mjacob * set the card to a known state (so it doesn't wake up and kick
485 1.8 mjacob * us when we aren't expecting it to).
486 1.8 mjacob *
487 1.8 mjacob * Locks are held before coming here.
488 1.8 mjacob */
489 1.8 mjacob void
490 1.8 mjacob isp_uninit(isp)
491 1.8 mjacob struct ispsoftc *isp;
492 1.8 mjacob {
493 1.28 mjacob isp_lock(isp);
494 1.8 mjacob /*
495 1.8 mjacob * Leave with interrupts disabled.
496 1.8 mjacob */
497 1.8 mjacob DISABLE_INTS(isp);
498 1.28 mjacob isp_unlock(isp);
499 1.9 mjacob }
500 1.9 mjacob
501 1.10 mjacob /*
502 1.17 mjacob * Restart function for a command to be requeued later.
503 1.17 mjacob */
504 1.17 mjacob static void
505 1.17 mjacob isp_command_requeue(arg)
506 1.17 mjacob void *arg;
507 1.17 mjacob {
508 1.17 mjacob struct scsipi_xfer *xs = arg;
509 1.17 mjacob struct ispsoftc *isp = XS_ISP(xs);
510 1.17 mjacob int s = splbio();
511 1.29 mjacob switch (ispcmd(xs)) {
512 1.17 mjacob case SUCCESSFULLY_QUEUED:
513 1.28 mjacob isp_prt(isp, ISP_LOGINFO,
514 1.28 mjacob "requeued commands for %d.%d", XS_TGT(xs), XS_LUN(xs));
515 1.26 mjacob if (xs->timeout) {
516 1.26 mjacob callout_reset(&xs->xs_callout, _XT(xs), isp_dog, xs);
517 1.26 mjacob }
518 1.17 mjacob break;
519 1.17 mjacob case TRY_AGAIN_LATER:
520 1.28 mjacob isp_prt(isp, ISP_LOGINFO,
521 1.28 mjacob "EAGAIN on requeue for %d.%d", XS_TGT(xs), XS_LUN(xs));
522 1.28 mjacob callout_reset(&xs->xs_callout, hz, isp_command_requeue, xs);
523 1.28 mjacob break;
524 1.17 mjacob case COMPLETE:
525 1.18 mjacob /* can only be an error */
526 1.26 mjacob XS_CMD_S_DONE(xs);
527 1.26 mjacob callout_stop(&xs->xs_callout);
528 1.17 mjacob if (XS_NOERR(xs)) {
529 1.17 mjacob XS_SETERR(xs, HBA_BOTCH);
530 1.17 mjacob }
531 1.17 mjacob scsipi_done(xs);
532 1.17 mjacob break;
533 1.17 mjacob }
534 1.17 mjacob (void) splx(s);
535 1.17 mjacob }
536 1.18 mjacob
537 1.17 mjacob /*
538 1.10 mjacob * Restart function after a LOOP UP event (e.g.),
539 1.10 mjacob * done as a timeout for some hysteresis.
540 1.10 mjacob */
541 1.10 mjacob static void
542 1.10 mjacob isp_internal_restart(arg)
543 1.10 mjacob void *arg;
544 1.10 mjacob {
545 1.10 mjacob struct ispsoftc *isp = arg;
546 1.11 mjacob int result, nrestarted = 0, s;
547 1.10 mjacob
548 1.11 mjacob s = splbio();
549 1.10 mjacob if (isp->isp_osinfo.blocked == 0) {
550 1.10 mjacob struct scsipi_xfer *xs;
551 1.10 mjacob while ((xs = TAILQ_FIRST(&isp->isp_osinfo.waitq)) != NULL) {
552 1.10 mjacob TAILQ_REMOVE(&isp->isp_osinfo.waitq, xs, adapter_q);
553 1.28 mjacob result = isp_start(xs);
554 1.11 mjacob if (result != CMD_QUEUED) {
555 1.28 mjacob isp_prt(isp, ISP_LOGERR,
556 1.28 mjacob "botched command restart (err=%d)", result);
557 1.26 mjacob XS_CMD_S_DONE(xs);
558 1.10 mjacob if (xs->error == XS_NOERROR)
559 1.10 mjacob xs->error = XS_DRIVER_STUFFUP;
560 1.26 mjacob callout_stop(&xs->xs_callout);
561 1.10 mjacob scsipi_done(xs);
562 1.26 mjacob } else if (xs->timeout) {
563 1.26 mjacob callout_reset(&xs->xs_callout,
564 1.26 mjacob _XT(xs), isp_dog, xs);
565 1.10 mjacob }
566 1.10 mjacob nrestarted++;
567 1.10 mjacob }
568 1.28 mjacob isp_prt(isp, ISP_LOGINFO,
569 1.28 mjacob "isp_restart requeued %d commands", nrestarted);
570 1.10 mjacob }
571 1.10 mjacob (void) splx(s);
572 1.10 mjacob }
573 1.18 mjacob
574 1.9 mjacob int
575 1.9 mjacob isp_async(isp, cmd, arg)
576 1.9 mjacob struct ispsoftc *isp;
577 1.9 mjacob ispasync_t cmd;
578 1.9 mjacob void *arg;
579 1.9 mjacob {
580 1.14 mjacob int bus, tgt;
581 1.10 mjacob int s = splbio();
582 1.9 mjacob switch (cmd) {
583 1.9 mjacob case ISPASYNC_NEW_TGT_PARAMS:
584 1.17 mjacob if (IS_SCSI(isp) && isp->isp_dblev) {
585 1.17 mjacob sdparam *sdp = isp->isp_param;
586 1.17 mjacob char *wt;
587 1.17 mjacob int mhz, flags, period;
588 1.17 mjacob
589 1.17 mjacob tgt = *((int *) arg);
590 1.17 mjacob bus = (tgt >> 16) & 0xffff;
591 1.17 mjacob tgt &= 0xffff;
592 1.21 mjacob sdp += bus;
593 1.17 mjacob flags = sdp->isp_devparam[tgt].cur_dflags;
594 1.17 mjacob period = sdp->isp_devparam[tgt].cur_period;
595 1.21 mjacob
596 1.17 mjacob if ((flags & DPARM_SYNC) && period &&
597 1.17 mjacob (sdp->isp_devparam[tgt].cur_offset) != 0) {
598 1.21 mjacob /*
599 1.21 mjacob * There's some ambiguity about our negotiated speed
600 1.21 mjacob * if we haven't detected LVD mode correctly (which
601 1.21 mjacob * seems to happen, unfortunately). If we're in LVD
602 1.21 mjacob * mode, then different rules apply about speed.
603 1.21 mjacob */
604 1.21 mjacob if (sdp->isp_lvdmode || period < 0xc) {
605 1.17 mjacob switch (period) {
606 1.23 mjacob case 0x9:
607 1.23 mjacob mhz = 80;
608 1.23 mjacob break;
609 1.17 mjacob case 0xa:
610 1.17 mjacob mhz = 40;
611 1.17 mjacob break;
612 1.17 mjacob case 0xb:
613 1.17 mjacob mhz = 33;
614 1.17 mjacob break;
615 1.17 mjacob case 0xc:
616 1.17 mjacob mhz = 25;
617 1.17 mjacob break;
618 1.17 mjacob default:
619 1.12 mjacob mhz = 1000 / (period * 4);
620 1.17 mjacob break;
621 1.12 mjacob }
622 1.9 mjacob } else {
623 1.17 mjacob mhz = 1000 / (period * 4);
624 1.9 mjacob }
625 1.17 mjacob } else {
626 1.17 mjacob mhz = 0;
627 1.17 mjacob }
628 1.17 mjacob switch (flags & (DPARM_WIDE|DPARM_TQING)) {
629 1.17 mjacob case DPARM_WIDE:
630 1.28 mjacob wt = ", 16 bit wide";
631 1.17 mjacob break;
632 1.17 mjacob case DPARM_TQING:
633 1.28 mjacob wt = ", Tagged Queueing Enabled";
634 1.17 mjacob break;
635 1.17 mjacob case DPARM_WIDE|DPARM_TQING:
636 1.28 mjacob wt = ", 16 bit wide, Tagged Queueing Enabled";
637 1.17 mjacob break;
638 1.17 mjacob default:
639 1.28 mjacob wt = " ";
640 1.17 mjacob break;
641 1.17 mjacob }
642 1.17 mjacob if (mhz) {
643 1.28 mjacob isp_prt(isp, ISP_LOGINFO,
644 1.28 mjacob "Bus %d Target %d at %dMHz Max Offset %d%s",
645 1.28 mjacob bus, tgt, mhz, sdp->isp_devparam[tgt].cur_offset,
646 1.28 mjacob wt);
647 1.17 mjacob } else {
648 1.28 mjacob isp_prt(isp, ISP_LOGINFO,
649 1.28 mjacob "Bus %d Target %d Async Mode%s", bus, tgt, wt);
650 1.9 mjacob }
651 1.11 mjacob break;
652 1.17 mjacob }
653 1.11 mjacob case ISPASYNC_BUS_RESET:
654 1.14 mjacob if (arg)
655 1.14 mjacob bus = *((int *) arg);
656 1.14 mjacob else
657 1.14 mjacob bus = 0;
658 1.28 mjacob isp_prt(isp, ISP_LOGINFO, "SCSI bus %d reset detected", bus);
659 1.11 mjacob break;
660 1.11 mjacob case ISPASYNC_LOOP_DOWN:
661 1.11 mjacob /*
662 1.11 mjacob * Hopefully we get here in time to minimize the number
663 1.11 mjacob * of commands we are firing off that are sure to die.
664 1.11 mjacob */
665 1.11 mjacob isp->isp_osinfo.blocked = 1;
666 1.28 mjacob isp_prt(isp, ISP_LOGINFO, "Loop DOWN");
667 1.11 mjacob break;
668 1.11 mjacob case ISPASYNC_LOOP_UP:
669 1.11 mjacob isp->isp_osinfo.blocked = 0;
670 1.24 thorpej callout_reset(&isp->isp_osinfo._restart, 1,
671 1.24 thorpej isp_internal_restart, isp);
672 1.28 mjacob isp_prt(isp, ISP_LOGINFO, "Loop UP");
673 1.11 mjacob break;
674 1.15 mjacob case ISPASYNC_PDB_CHANGED:
675 1.17 mjacob if (IS_FC(isp) && isp->isp_dblev) {
676 1.28 mjacob const char *fmt = "Target %d (Loop 0x%x) Port ID 0x%x "
677 1.28 mjacob "role %s %s\n Port WWN 0x%08x%08x\n Node WWN 0x%08x%08x";
678 1.15 mjacob const static char *roles[4] = {
679 1.11 mjacob "No", "Target", "Initiator", "Target/Initiator"
680 1.11 mjacob };
681 1.15 mjacob char *ptr;
682 1.15 mjacob fcparam *fcp = isp->isp_param;
683 1.15 mjacob int tgt = *((int *) arg);
684 1.15 mjacob struct lportdb *lp = &fcp->portdb[tgt];
685 1.15 mjacob
686 1.15 mjacob if (lp->valid) {
687 1.15 mjacob ptr = "arrived";
688 1.15 mjacob } else {
689 1.15 mjacob ptr = "disappeared";
690 1.11 mjacob }
691 1.28 mjacob isp_prt(isp, ISP_LOGINFO, fmt, tgt, lp->loopid, lp->portid,
692 1.15 mjacob roles[lp->roles & 0x3], ptr,
693 1.15 mjacob (u_int32_t) (lp->port_wwn >> 32),
694 1.15 mjacob (u_int32_t) (lp->port_wwn & 0xffffffffLL),
695 1.15 mjacob (u_int32_t) (lp->node_wwn >> 32),
696 1.15 mjacob (u_int32_t) (lp->node_wwn & 0xffffffffLL));
697 1.11 mjacob break;
698 1.11 mjacob }
699 1.15 mjacob #ifdef ISP2100_FABRIC
700 1.11 mjacob case ISPASYNC_CHANGE_NOTIFY:
701 1.28 mjacob isp_prt(isp, ISP_LOGINFO, "Name Server Database Changed");
702 1.9 mjacob break;
703 1.15 mjacob case ISPASYNC_FABRIC_DEV:
704 1.15 mjacob {
705 1.15 mjacob int target;
706 1.15 mjacob struct lportdb *lp;
707 1.15 mjacob sns_scrsp_t *resp = (sns_scrsp_t *) arg;
708 1.15 mjacob u_int32_t portid;
709 1.15 mjacob u_int64_t wwn;
710 1.15 mjacob fcparam *fcp = isp->isp_param;
711 1.15 mjacob
712 1.15 mjacob portid =
713 1.15 mjacob (((u_int32_t) resp->snscb_port_id[0]) << 16) |
714 1.15 mjacob (((u_int32_t) resp->snscb_port_id[1]) << 8) |
715 1.15 mjacob (((u_int32_t) resp->snscb_port_id[2]));
716 1.15 mjacob wwn =
717 1.15 mjacob (((u_int64_t)resp->snscb_portname[0]) << 56) |
718 1.15 mjacob (((u_int64_t)resp->snscb_portname[1]) << 48) |
719 1.15 mjacob (((u_int64_t)resp->snscb_portname[2]) << 40) |
720 1.15 mjacob (((u_int64_t)resp->snscb_portname[3]) << 32) |
721 1.15 mjacob (((u_int64_t)resp->snscb_portname[4]) << 24) |
722 1.15 mjacob (((u_int64_t)resp->snscb_portname[5]) << 16) |
723 1.15 mjacob (((u_int64_t)resp->snscb_portname[6]) << 8) |
724 1.15 mjacob (((u_int64_t)resp->snscb_portname[7]));
725 1.28 mjacob isp_prt(isp, ISP_LOGINFO,
726 1.28 mjacob "Fabric Device (Type 0x%x)@PortID 0x%x WWN 0x%08x%08x",
727 1.28 mjacob resp->snscb_port_type, portid, ((u_int32_t)(wwn >> 32)),
728 1.15 mjacob ((u_int32_t)(wwn & 0xffffffff)));
729 1.15 mjacob if (resp->snscb_port_type != 2)
730 1.15 mjacob break;
731 1.15 mjacob for (target = FC_SNS_ID+1; target < MAX_FC_TARG; target++) {
732 1.15 mjacob lp = &fcp->portdb[target];
733 1.15 mjacob if (lp->port_wwn == wwn)
734 1.15 mjacob break;
735 1.15 mjacob }
736 1.15 mjacob if (target < MAX_FC_TARG) {
737 1.15 mjacob break;
738 1.15 mjacob }
739 1.15 mjacob for (target = FC_SNS_ID+1; target < MAX_FC_TARG; target++) {
740 1.15 mjacob lp = &fcp->portdb[target];
741 1.15 mjacob if (lp->port_wwn == 0)
742 1.15 mjacob break;
743 1.15 mjacob }
744 1.15 mjacob if (target == MAX_FC_TARG) {
745 1.28 mjacob isp_prt(isp, ISP_LOGWARN,
746 1.28 mjacob "no more space for fabric devices");
747 1.15 mjacob return (-1);
748 1.15 mjacob }
749 1.15 mjacob lp->port_wwn = lp->node_wwn = wwn;
750 1.15 mjacob lp->portid = portid;
751 1.15 mjacob break;
752 1.15 mjacob }
753 1.15 mjacob #endif
754 1.9 mjacob default:
755 1.9 mjacob break;
756 1.9 mjacob }
757 1.10 mjacob (void) splx(s);
758 1.9 mjacob return (0);
759 1.28 mjacob }
760 1.28 mjacob
761 1.28 mjacob #include <machine/stdarg.h>
762 1.28 mjacob void
763 1.28 mjacob #ifdef __STDC__
764 1.28 mjacob isp_prt(struct ispsoftc *isp, int level, const char *fmt, ...)
765 1.28 mjacob #else
766 1.28 mjacob isp_prt(isp, fmt, va_alist)
767 1.28 mjacob struct ispsoftc *isp;
768 1.28 mjacob char *fmt;
769 1.28 mjacob va_dcl;
770 1.28 mjacob #endif
771 1.28 mjacob {
772 1.28 mjacob va_list ap;
773 1.28 mjacob if (level != ISP_LOGALL && (level & isp->isp_dblev) == 0) {
774 1.28 mjacob return;
775 1.28 mjacob }
776 1.28 mjacob printf("%s: ", isp->isp_name);
777 1.28 mjacob va_start(ap, fmt);
778 1.28 mjacob vprintf(fmt, ap);
779 1.28 mjacob va_end(ap);
780 1.28 mjacob printf("\n");
781 1.1 mjacob }
782