isp_netbsd.c revision 1.20 1 1.20 mjacob /* $NetBSD: isp_netbsd.c,v 1.20 1999/12/05 18:20:53 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.1 mjacob static void ispminphys __P((struct buf *));
37 1.17 mjacob static int32_t ispcmd_slow __P((ISP_SCSI_XFER_T *));
38 1.1 mjacob static int32_t ispcmd __P((ISP_SCSI_XFER_T *));
39 1.17 mjacob static int
40 1.17 mjacob ispioctl __P((struct scsipi_link *, u_long, caddr_t, int, struct proc *));
41 1.1 mjacob
42 1.1 mjacob static struct scsipi_device isp_dev = { NULL, NULL, NULL, NULL };
43 1.1 mjacob static int isp_poll __P((struct ispsoftc *, ISP_SCSI_XFER_T *, int));
44 1.10 mjacob static void isp_watch __P((void *));
45 1.17 mjacob static void isp_command_requeue __P((void *));
46 1.10 mjacob static void isp_internal_restart __P((void *));
47 1.10 mjacob
48 1.1 mjacob /*
49 1.1 mjacob * Complete attachment of hardware, include subdevices.
50 1.1 mjacob */
51 1.1 mjacob void
52 1.1 mjacob isp_attach(isp)
53 1.1 mjacob struct ispsoftc *isp;
54 1.1 mjacob {
55 1.6 thorpej
56 1.6 thorpej isp->isp_osinfo._adapter.scsipi_minphys = ispminphys;
57 1.17 mjacob isp->isp_osinfo._adapter.scsipi_ioctl = ispioctl;
58 1.6 thorpej
59 1.1 mjacob isp->isp_state = ISP_RUNSTATE;
60 1.1 mjacob isp->isp_osinfo._link.scsipi_scsi.channel = SCSI_CHANNEL_ONLY_ONE;
61 1.1 mjacob isp->isp_osinfo._link.adapter_softc = isp;
62 1.1 mjacob isp->isp_osinfo._link.device = &isp_dev;
63 1.6 thorpej isp->isp_osinfo._link.adapter = &isp->isp_osinfo._adapter;
64 1.17 mjacob isp->isp_osinfo._link.openings = isp->isp_maxcmds;
65 1.18 mjacob TAILQ_INIT(&isp->isp_osinfo.waitq); /* XXX 2nd Bus? */
66 1.1 mjacob
67 1.15 mjacob if (IS_FC(isp)) {
68 1.11 mjacob /*
69 1.11 mjacob * Give it another chance here to come alive...
70 1.11 mjacob */
71 1.17 mjacob isp->isp_osinfo._adapter.scsipi_cmd = ispcmd;
72 1.1 mjacob isp->isp_osinfo._link.scsipi_scsi.max_target = MAX_FC_TARG-1;
73 1.11 mjacob #ifdef ISP2100_SCCLUN
74 1.7 mjacob /*
75 1.7 mjacob * 16 bits worth, but let's be reasonable..
76 1.7 mjacob */
77 1.7 mjacob isp->isp_osinfo._link.scsipi_scsi.max_lun = 255;
78 1.7 mjacob #else
79 1.7 mjacob isp->isp_osinfo._link.scsipi_scsi.max_lun = 15;
80 1.7 mjacob #endif
81 1.19 mjacob /* set below */
82 1.1 mjacob } else {
83 1.14 mjacob sdparam *sdp = isp->isp_param;
84 1.17 mjacob isp->isp_osinfo._adapter.scsipi_cmd = ispcmd_slow;
85 1.1 mjacob isp->isp_osinfo._link.scsipi_scsi.max_target = MAX_TARGETS-1;
86 1.7 mjacob if (isp->isp_bustype == ISP_BT_SBUS) {
87 1.7 mjacob isp->isp_osinfo._link.scsipi_scsi.max_lun = 7;
88 1.7 mjacob } else {
89 1.7 mjacob /*
90 1.7 mjacob * Too much target breakage at present.
91 1.7 mjacob */
92 1.7 mjacob #if 0
93 1.13 mjacob if (isp->isp_fwrev >= ISP_FW_REV(7,55,0))
94 1.7 mjacob isp->isp_osinfo._link.scsipi_scsi.max_lun = 31;
95 1.7 mjacob else
96 1.7 mjacob #endif
97 1.7 mjacob isp->isp_osinfo._link.scsipi_scsi.max_lun = 7;
98 1.7 mjacob }
99 1.1 mjacob isp->isp_osinfo._link.scsipi_scsi.adapter_target =
100 1.14 mjacob sdp->isp_initiator_id;
101 1.17 mjacob isp->isp_osinfo.discovered[0] = 1 << sdp->isp_initiator_id;
102 1.14 mjacob if (IS_12X0(isp)) {
103 1.14 mjacob isp->isp_osinfo._link_b = isp->isp_osinfo._link;
104 1.14 mjacob sdp++;
105 1.18 mjacob isp->isp_osinfo.discovered[1] =
106 1.18 mjacob 1 << sdp->isp_initiator_id;
107 1.14 mjacob isp->isp_osinfo._link_b.scsipi_scsi.adapter_target =
108 1.14 mjacob sdp->isp_initiator_id;
109 1.14 mjacob isp->isp_osinfo._link_b.scsipi_scsi.channel = 1;
110 1.14 mjacob }
111 1.1 mjacob }
112 1.1 mjacob isp->isp_osinfo._link.type = BUS_SCSI;
113 1.8 mjacob
114 1.8 mjacob /*
115 1.10 mjacob * Send a SCSI Bus Reset (used to be done as part of attach,
116 1.10 mjacob * but now left to the OS outer layers).
117 1.10 mjacob */
118 1.14 mjacob if (IS_SCSI(isp)) {
119 1.14 mjacob int bus = 0;
120 1.14 mjacob (void) isp_control(isp, ISPCTL_RESET_BUS, &bus);
121 1.14 mjacob if (IS_12X0(isp)) {
122 1.14 mjacob bus++;
123 1.14 mjacob (void) isp_control(isp, ISPCTL_RESET_BUS, &bus);
124 1.14 mjacob }
125 1.11 mjacob SYS_DELAY(2*1000000);
126 1.19 mjacob } else {
127 1.19 mjacob int i, j;
128 1.19 mjacob fcparam *fcp = isp->isp_param;
129 1.19 mjacob delay(2 * 1000000);
130 1.19 mjacob for (j = 0; j < 5; j++) {
131 1.19 mjacob for (i = 0; i < 5; i++) {
132 1.19 mjacob if (isp_control(isp, ISPCTL_FCLINK_TEST, NULL))
133 1.19 mjacob continue;
134 1.19 mjacob #ifdef ISP2100_FABRIC
135 1.19 mjacob /*
136 1.19 mjacob * Wait extra time to see if the f/w
137 1.19 mjacob * eventually completed an FLOGI that
138 1.19 mjacob * will allow us to know we're on a
139 1.19 mjacob * fabric.
140 1.19 mjacob */
141 1.19 mjacob if (fcp->isp_onfabric == 0) {
142 1.19 mjacob delay(1 * 1000000);
143 1.19 mjacob continue;
144 1.19 mjacob }
145 1.19 mjacob #endif
146 1.19 mjacob break;
147 1.19 mjacob }
148 1.19 mjacob if (fcp->isp_fwstate == FW_READY &&
149 1.19 mjacob fcp->isp_loopstate >= LOOP_PDB_RCVD) {
150 1.19 mjacob break;
151 1.19 mjacob }
152 1.19 mjacob }
153 1.19 mjacob isp->isp_osinfo._link.scsipi_scsi.adapter_target =
154 1.19 mjacob fcp->isp_loopid;
155 1.11 mjacob }
156 1.10 mjacob
157 1.10 mjacob /*
158 1.8 mjacob * Start the watchdog.
159 1.8 mjacob */
160 1.8 mjacob isp->isp_dogactive = 1;
161 1.17 mjacob timeout(isp_watch, isp, WATCH_INTERVAL * hz);
162 1.8 mjacob
163 1.8 mjacob /*
164 1.8 mjacob * And attach children (if any).
165 1.8 mjacob */
166 1.1 mjacob config_found((void *)isp, &isp->isp_osinfo._link, scsiprint);
167 1.14 mjacob if (IS_12X0(isp)) {
168 1.14 mjacob config_found((void *)isp, &isp->isp_osinfo._link_b, scsiprint);
169 1.14 mjacob }
170 1.1 mjacob }
171 1.1 mjacob
172 1.1 mjacob /*
173 1.1 mjacob * minphys our xfers
174 1.1 mjacob *
175 1.1 mjacob * Unfortunately, the buffer pointer describes the target device- not the
176 1.1 mjacob * adapter device, so we can't use the pointer to find out what kind of
177 1.1 mjacob * adapter we are and adjust accordingly.
178 1.1 mjacob */
179 1.1 mjacob
180 1.1 mjacob static void
181 1.1 mjacob ispminphys(bp)
182 1.1 mjacob struct buf *bp;
183 1.1 mjacob {
184 1.1 mjacob /*
185 1.1 mjacob * XX: Only the 1020 has a 24 bit limit.
186 1.1 mjacob */
187 1.1 mjacob if (bp->b_bcount >= (1 << 24)) {
188 1.1 mjacob bp->b_bcount = (1 << 24);
189 1.1 mjacob }
190 1.1 mjacob minphys(bp);
191 1.1 mjacob }
192 1.1 mjacob
193 1.17 mjacob static int32_t
194 1.17 mjacob ispcmd_slow(xs)
195 1.1 mjacob ISP_SCSI_XFER_T *xs;
196 1.1 mjacob {
197 1.19 mjacob sdparam *sdp;
198 1.20 mjacob int tgt, chan, s;
199 1.19 mjacob u_int16_t f;
200 1.19 mjacob struct ispsoftc *isp = XS_ISP(xs);
201 1.19 mjacob
202 1.19 mjacob /*
203 1.19 mjacob * Have we completed discovery for this target on this adapter?
204 1.19 mjacob */
205 1.20 mjacob tgt = XS_TGT(xs);
206 1.20 mjacob chan = XS_CHANNEL(xs);
207 1.19 mjacob sdp = isp->isp_param;
208 1.19 mjacob sdp += chan;
209 1.19 mjacob if ((xs->xs_control & XS_CTL_DISCOVERY) != 0 ||
210 1.19 mjacob (isp->isp_osinfo.discovered[chan] & (1 << tgt)) != 0) {
211 1.19 mjacob return (ispcmd(xs));
212 1.19 mjacob }
213 1.19 mjacob
214 1.19 mjacob f = DPARM_DEFAULT;
215 1.19 mjacob if (xs->sc_link->quirks & SDEV_NOSYNC) {
216 1.19 mjacob f ^= DPARM_SYNC;
217 1.19 mjacob #ifdef DEBUG
218 1.19 mjacob } else {
219 1.19 mjacob printf("%s: channel %d target %d can do SYNC xfers\n",
220 1.19 mjacob isp->isp_name, chan, tgt);
221 1.19 mjacob #endif
222 1.19 mjacob }
223 1.19 mjacob if (xs->sc_link->quirks & SDEV_NOWIDE) {
224 1.19 mjacob f ^= DPARM_WIDE;
225 1.19 mjacob #ifdef DEBUG
226 1.19 mjacob } else {
227 1.19 mjacob printf("%s: channel %d target %d can do WIDE xfers\n",
228 1.19 mjacob isp->isp_name, chan, tgt);
229 1.19 mjacob #endif
230 1.19 mjacob }
231 1.19 mjacob if (xs->sc_link->quirks & SDEV_NOTAG) {
232 1.19 mjacob f ^= DPARM_TQING;
233 1.19 mjacob #ifdef DEBUG
234 1.19 mjacob } else {
235 1.19 mjacob printf("%s: channel %d target %d can do TAGGED xfers\n",
236 1.19 mjacob isp->isp_name, chan, tgt);
237 1.19 mjacob #endif
238 1.19 mjacob }
239 1.19 mjacob /*
240 1.19 mjacob * Okay, we know about this device now,
241 1.19 mjacob * so mark parameters to be updated for it.
242 1.19 mjacob */
243 1.20 mjacob s = splbio();
244 1.19 mjacob sdp->isp_devparam[tgt].dev_flags = f;
245 1.19 mjacob sdp->isp_devparam[tgt].dev_update = 1;
246 1.19 mjacob isp->isp_update |= (1 << chan);
247 1.19 mjacob
248 1.3 mjacob /*
249 1.19 mjacob * Now check to see whether we can get out of this checking mode now.
250 1.19 mjacob * XXX: WE CANNOT AS YET BECAUSE THERE IS NO MECHANISM TO TELL US
251 1.19 mjacob * XXX: WHEN WE'RE DONE DISCOVERY BECAUSE WE NEED ONE COMMAND AFTER
252 1.19 mjacob * XXX: DISCOVERY IS DONE FOR EACH TARGET TO TELL US THAT WE'RE DONE
253 1.19 mjacob * XXX: AND THAT DOESN'T HAPPEN HERE. AT BEST WE CAN MARK OURSELVES
254 1.19 mjacob * XXX: DONE WITH DISCOVERY FOR THIS TARGET AND SO SAVE MAYBE 20
255 1.19 mjacob * XXX: LINES OF C CODE.
256 1.3 mjacob */
257 1.19 mjacob isp->isp_osinfo.discovered[chan] |= (1 << tgt);
258 1.19 mjacob /* do not bother with these lines- they'll never execute correctly */
259 1.19 mjacob #if 0
260 1.19 mjacob sdp = isp->isp_param;
261 1.19 mjacob for (chan = 0; chan < (IS_12X0(isp)? 2 : 1); chan++, sdp++) {
262 1.19 mjacob f = 0xffff & ~(1 << sdp->isp_initiator_id);
263 1.19 mjacob if (isp->isp_osinfo.discovered[chan] != f) {
264 1.19 mjacob break;
265 1.3 mjacob }
266 1.17 mjacob }
267 1.19 mjacob if (chan == (IS_12X0(isp)? 2 : 1)) {
268 1.19 mjacob CFGPRINTF("%s: allowing sync/wide negotiation and "
269 1.19 mjacob "tag usage\n", isp->isp_name);
270 1.19 mjacob isp->isp_osinfo._adapter.scsipi_cmd = ispcmd;
271 1.19 mjacob if (IS_12X0(isp))
272 1.19 mjacob isp->isp_update |= 2;
273 1.19 mjacob }
274 1.19 mjacob #endif
275 1.20 mjacob splx(s);
276 1.17 mjacob return (ispcmd(xs));
277 1.17 mjacob }
278 1.17 mjacob
279 1.17 mjacob static int
280 1.17 mjacob ispioctl(sc_link, cmd, addr, flag, p)
281 1.17 mjacob struct scsipi_link *sc_link;
282 1.17 mjacob u_long cmd;
283 1.17 mjacob caddr_t addr;
284 1.17 mjacob int flag;
285 1.17 mjacob struct proc *p;
286 1.17 mjacob {
287 1.17 mjacob struct ispsoftc *isp = sc_link->adapter_softc;
288 1.17 mjacob int s, chan, retval = ENOTTY;
289 1.17 mjacob
290 1.17 mjacob switch (cmd) {
291 1.17 mjacob case SCBUSIORESET:
292 1.17 mjacob chan = sc_link->scsipi_scsi.channel;
293 1.17 mjacob s = splbio();
294 1.17 mjacob if (isp_control(isp, ISPCTL_RESET_BUS, &chan))
295 1.17 mjacob retval = EIO;
296 1.17 mjacob else
297 1.17 mjacob retval = 0;
298 1.17 mjacob (void) splx(s);
299 1.17 mjacob break;
300 1.17 mjacob default:
301 1.17 mjacob break;
302 1.3 mjacob }
303 1.17 mjacob return (retval);
304 1.17 mjacob }
305 1.17 mjacob
306 1.17 mjacob
307 1.17 mjacob static int32_t
308 1.17 mjacob ispcmd(xs)
309 1.17 mjacob ISP_SCSI_XFER_T *xs;
310 1.17 mjacob {
311 1.17 mjacob struct ispsoftc *isp;
312 1.17 mjacob int result, s;
313 1.11 mjacob
314 1.17 mjacob isp = XS_ISP(xs);
315 1.17 mjacob s = splbio();
316 1.11 mjacob if (isp->isp_state < ISP_RUNSTATE) {
317 1.11 mjacob DISABLE_INTS(isp);
318 1.11 mjacob isp_init(isp);
319 1.11 mjacob if (isp->isp_state != ISP_INITSTATE) {
320 1.11 mjacob ENABLE_INTS(isp);
321 1.11 mjacob (void) splx(s);
322 1.11 mjacob XS_SETERR(xs, HBA_BOTCH);
323 1.17 mjacob return (COMPLETE);
324 1.11 mjacob }
325 1.11 mjacob isp->isp_state = ISP_RUNSTATE;
326 1.11 mjacob ENABLE_INTS(isp);
327 1.11 mjacob }
328 1.11 mjacob
329 1.10 mjacob /*
330 1.10 mjacob * Check for queue blockage...
331 1.10 mjacob */
332 1.10 mjacob if (isp->isp_osinfo.blocked) {
333 1.16 thorpej if (xs->xs_control & XS_CTL_POLL) {
334 1.10 mjacob xs->error = XS_DRIVER_STUFFUP;
335 1.10 mjacob splx(s);
336 1.10 mjacob return (TRY_AGAIN_LATER);
337 1.10 mjacob }
338 1.10 mjacob TAILQ_INSERT_TAIL(&isp->isp_osinfo.waitq, xs, adapter_q);
339 1.10 mjacob splx(s);
340 1.17 mjacob return (SUCCESSFULLY_QUEUED);
341 1.10 mjacob }
342 1.11 mjacob DISABLE_INTS(isp);
343 1.3 mjacob result = ispscsicmd(xs);
344 1.11 mjacob ENABLE_INTS(isp);
345 1.17 mjacob
346 1.17 mjacob if ((xs->xs_control & XS_CTL_POLL) == 0) {
347 1.17 mjacob switch (result) {
348 1.17 mjacob case CMD_QUEUED:
349 1.17 mjacob result = SUCCESSFULLY_QUEUED;
350 1.17 mjacob break;
351 1.17 mjacob case CMD_EAGAIN:
352 1.17 mjacob result = TRY_AGAIN_LATER;
353 1.17 mjacob break;
354 1.17 mjacob case CMD_RQLATER:
355 1.17 mjacob result = SUCCESSFULLY_QUEUED;
356 1.17 mjacob timeout(isp_command_requeue, xs, hz);
357 1.17 mjacob break;
358 1.17 mjacob case CMD_COMPLETE:
359 1.17 mjacob result = COMPLETE;
360 1.17 mjacob break;
361 1.17 mjacob }
362 1.10 mjacob (void) splx(s);
363 1.3 mjacob return (result);
364 1.1 mjacob }
365 1.1 mjacob
366 1.17 mjacob switch (result) {
367 1.17 mjacob case CMD_QUEUED:
368 1.17 mjacob result = SUCCESSFULLY_QUEUED;
369 1.17 mjacob break;
370 1.17 mjacob case CMD_RQLATER:
371 1.17 mjacob case CMD_EAGAIN:
372 1.17 mjacob if (XS_NOERR(xs)) {
373 1.17 mjacob xs->error = XS_DRIVER_STUFFUP;
374 1.17 mjacob }
375 1.17 mjacob result = TRY_AGAIN_LATER;
376 1.17 mjacob break;
377 1.17 mjacob case CMD_COMPLETE:
378 1.17 mjacob result = COMPLETE;
379 1.17 mjacob break;
380 1.17 mjacob
381 1.17 mjacob }
382 1.1 mjacob /*
383 1.1 mjacob * If we can't use interrupts, poll on completion.
384 1.1 mjacob */
385 1.17 mjacob if (result == SUCCESSFULLY_QUEUED) {
386 1.17 mjacob if (isp_poll(isp, xs, XS_TIME(xs))) {
387 1.17 mjacob /*
388 1.17 mjacob * If no other error occurred but we didn't finish,
389 1.17 mjacob * something bad happened.
390 1.17 mjacob */
391 1.17 mjacob if (XS_IS_CMD_DONE(xs) == 0) {
392 1.17 mjacob if (isp_control(isp, ISPCTL_ABORT_CMD, xs)) {
393 1.17 mjacob isp_restart(isp);
394 1.17 mjacob }
395 1.17 mjacob if (XS_NOERR(xs)) {
396 1.17 mjacob XS_SETERR(xs, HBA_BOTCH);
397 1.17 mjacob }
398 1.1 mjacob }
399 1.1 mjacob }
400 1.17 mjacob result = COMPLETE;
401 1.1 mjacob }
402 1.10 mjacob (void) splx(s);
403 1.17 mjacob return (result);
404 1.1 mjacob }
405 1.1 mjacob
406 1.1 mjacob static int
407 1.1 mjacob isp_poll(isp, xs, mswait)
408 1.1 mjacob struct ispsoftc *isp;
409 1.1 mjacob ISP_SCSI_XFER_T *xs;
410 1.1 mjacob int mswait;
411 1.1 mjacob {
412 1.1 mjacob
413 1.1 mjacob while (mswait) {
414 1.1 mjacob /* Try the interrupt handling routine */
415 1.1 mjacob (void)isp_intr((void *)isp);
416 1.1 mjacob
417 1.1 mjacob /* See if the xs is now done */
418 1.1 mjacob if (XS_IS_CMD_DONE(xs)) {
419 1.1 mjacob return (0);
420 1.1 mjacob }
421 1.1 mjacob SYS_DELAY(1000); /* wait one millisecond */
422 1.1 mjacob mswait--;
423 1.1 mjacob }
424 1.1 mjacob return (1);
425 1.8 mjacob }
426 1.8 mjacob
427 1.8 mjacob static void
428 1.8 mjacob isp_watch(arg)
429 1.8 mjacob void *arg;
430 1.8 mjacob {
431 1.8 mjacob int i;
432 1.8 mjacob struct ispsoftc *isp = arg;
433 1.17 mjacob struct scsipi_xfer *xs;
434 1.17 mjacob int s;
435 1.8 mjacob
436 1.8 mjacob /*
437 1.8 mjacob * Look for completely dead commands (but not polled ones).
438 1.8 mjacob */
439 1.17 mjacob s = splbio();
440 1.17 mjacob for (i = 0; i < isp->isp_maxcmds; i++) {
441 1.17 mjacob xs = isp->isp_xflist[i];
442 1.17 mjacob if (xs == NULL) {
443 1.8 mjacob continue;
444 1.8 mjacob }
445 1.17 mjacob if (xs->timeout == 0 || (xs->xs_control & XS_CTL_POLL)) {
446 1.8 mjacob continue;
447 1.8 mjacob }
448 1.17 mjacob xs->timeout -= (WATCH_INTERVAL * 1000);
449 1.8 mjacob /*
450 1.8 mjacob * Avoid later thinking that this
451 1.8 mjacob * transaction is not being timed.
452 1.8 mjacob * Then give ourselves to watchdog
453 1.8 mjacob * periods of grace.
454 1.8 mjacob */
455 1.17 mjacob if (xs->timeout == 0) {
456 1.17 mjacob xs->timeout = 1;
457 1.17 mjacob } else if (xs->timeout > -(2 * WATCH_INTERVAL * 1000)) {
458 1.8 mjacob continue;
459 1.8 mjacob }
460 1.8 mjacob if (isp_control(isp, ISPCTL_ABORT_CMD, xs)) {
461 1.8 mjacob printf("%s: isp_watch failed to abort command\n",
462 1.8 mjacob isp->isp_name);
463 1.8 mjacob isp_restart(isp);
464 1.8 mjacob break;
465 1.8 mjacob }
466 1.8 mjacob }
467 1.8 mjacob timeout(isp_watch, isp, WATCH_INTERVAL * hz);
468 1.8 mjacob isp->isp_dogactive = 1;
469 1.17 mjacob (void) splx(s);
470 1.8 mjacob }
471 1.8 mjacob
472 1.8 mjacob /*
473 1.8 mjacob * Free any associated resources prior to decommissioning and
474 1.8 mjacob * set the card to a known state (so it doesn't wake up and kick
475 1.8 mjacob * us when we aren't expecting it to).
476 1.8 mjacob *
477 1.8 mjacob * Locks are held before coming here.
478 1.8 mjacob */
479 1.8 mjacob void
480 1.8 mjacob isp_uninit(isp)
481 1.8 mjacob struct ispsoftc *isp;
482 1.8 mjacob {
483 1.8 mjacob ISP_ILOCKVAL_DECL;
484 1.8 mjacob ISP_ILOCK(isp);
485 1.8 mjacob /*
486 1.8 mjacob * Leave with interrupts disabled.
487 1.8 mjacob */
488 1.8 mjacob DISABLE_INTS(isp);
489 1.8 mjacob
490 1.8 mjacob /*
491 1.8 mjacob * Turn off the watchdog (if active).
492 1.8 mjacob */
493 1.8 mjacob if (isp->isp_dogactive) {
494 1.8 mjacob untimeout(isp_watch, isp);
495 1.8 mjacob isp->isp_dogactive = 0;
496 1.8 mjacob }
497 1.8 mjacob
498 1.8 mjacob ISP_IUNLOCK(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.17 mjacob switch (ispcmd_slow(xs)) {
512 1.17 mjacob case SUCCESSFULLY_QUEUED:
513 1.18 mjacob printf("%s: isp_command_requeue: requeued for %d.%d\n",
514 1.17 mjacob isp->isp_name, XS_TGT(xs), XS_LUN(xs));
515 1.17 mjacob break;
516 1.17 mjacob case TRY_AGAIN_LATER:
517 1.17 mjacob printf("%s: EAGAIN for %d.%d\n",
518 1.17 mjacob isp->isp_name, XS_TGT(xs), XS_LUN(xs));
519 1.17 mjacob /* FALLTHROUGH */
520 1.17 mjacob case COMPLETE:
521 1.18 mjacob /* can only be an error */
522 1.17 mjacob xs->xs_status |= XS_STS_DONE;
523 1.17 mjacob if (XS_NOERR(xs)) {
524 1.17 mjacob XS_SETERR(xs, HBA_BOTCH);
525 1.17 mjacob }
526 1.17 mjacob scsipi_done(xs);
527 1.17 mjacob break;
528 1.17 mjacob }
529 1.17 mjacob (void) splx(s);
530 1.17 mjacob }
531 1.18 mjacob
532 1.17 mjacob /*
533 1.10 mjacob * Restart function after a LOOP UP event (e.g.),
534 1.10 mjacob * done as a timeout for some hysteresis.
535 1.10 mjacob */
536 1.10 mjacob static void
537 1.10 mjacob isp_internal_restart(arg)
538 1.10 mjacob void *arg;
539 1.10 mjacob {
540 1.10 mjacob struct ispsoftc *isp = arg;
541 1.11 mjacob int result, nrestarted = 0, s;
542 1.10 mjacob
543 1.11 mjacob s = splbio();
544 1.10 mjacob if (isp->isp_osinfo.blocked == 0) {
545 1.10 mjacob struct scsipi_xfer *xs;
546 1.10 mjacob while ((xs = TAILQ_FIRST(&isp->isp_osinfo.waitq)) != NULL) {
547 1.10 mjacob TAILQ_REMOVE(&isp->isp_osinfo.waitq, xs, adapter_q);
548 1.11 mjacob DISABLE_INTS(isp);
549 1.11 mjacob result = ispscsicmd(xs);
550 1.11 mjacob ENABLE_INTS(isp);
551 1.11 mjacob if (result != CMD_QUEUED) {
552 1.10 mjacob printf("%s: botched command restart (0x%x)\n",
553 1.10 mjacob isp->isp_name, result);
554 1.16 thorpej xs->xs_status |= XS_STS_DONE;
555 1.10 mjacob if (xs->error == XS_NOERROR)
556 1.10 mjacob xs->error = XS_DRIVER_STUFFUP;
557 1.10 mjacob scsipi_done(xs);
558 1.10 mjacob }
559 1.10 mjacob nrestarted++;
560 1.10 mjacob }
561 1.10 mjacob printf("%s: requeued %d commands\n", isp->isp_name, nrestarted);
562 1.10 mjacob }
563 1.10 mjacob (void) splx(s);
564 1.10 mjacob }
565 1.18 mjacob
566 1.9 mjacob int
567 1.9 mjacob isp_async(isp, cmd, arg)
568 1.9 mjacob struct ispsoftc *isp;
569 1.9 mjacob ispasync_t cmd;
570 1.9 mjacob void *arg;
571 1.9 mjacob {
572 1.14 mjacob int bus, tgt;
573 1.10 mjacob int s = splbio();
574 1.9 mjacob switch (cmd) {
575 1.9 mjacob case ISPASYNC_NEW_TGT_PARAMS:
576 1.17 mjacob if (IS_SCSI(isp) && isp->isp_dblev) {
577 1.17 mjacob sdparam *sdp = isp->isp_param;
578 1.17 mjacob char *wt;
579 1.17 mjacob int mhz, flags, period;
580 1.17 mjacob
581 1.17 mjacob tgt = *((int *) arg);
582 1.17 mjacob bus = (tgt >> 16) & 0xffff;
583 1.17 mjacob tgt &= 0xffff;
584 1.17 mjacob
585 1.17 mjacob flags = sdp->isp_devparam[tgt].cur_dflags;
586 1.17 mjacob period = sdp->isp_devparam[tgt].cur_period;
587 1.17 mjacob if ((flags & DPARM_SYNC) && period &&
588 1.17 mjacob (sdp->isp_devparam[tgt].cur_offset) != 0) {
589 1.17 mjacob if (sdp->isp_lvdmode) {
590 1.17 mjacob switch (period) {
591 1.17 mjacob case 0xa:
592 1.17 mjacob mhz = 40;
593 1.17 mjacob break;
594 1.17 mjacob case 0xb:
595 1.17 mjacob mhz = 33;
596 1.17 mjacob break;
597 1.17 mjacob case 0xc:
598 1.17 mjacob mhz = 25;
599 1.17 mjacob break;
600 1.17 mjacob default:
601 1.12 mjacob mhz = 1000 / (period * 4);
602 1.17 mjacob break;
603 1.12 mjacob }
604 1.9 mjacob } else {
605 1.17 mjacob mhz = 1000 / (period * 4);
606 1.9 mjacob }
607 1.17 mjacob } else {
608 1.17 mjacob mhz = 0;
609 1.17 mjacob }
610 1.17 mjacob switch (flags & (DPARM_WIDE|DPARM_TQING)) {
611 1.17 mjacob case DPARM_WIDE:
612 1.17 mjacob wt = ", 16 bit wide\n";
613 1.17 mjacob break;
614 1.17 mjacob case DPARM_TQING:
615 1.17 mjacob wt = ", Tagged Queueing Enabled\n";
616 1.17 mjacob break;
617 1.17 mjacob case DPARM_WIDE|DPARM_TQING:
618 1.17 mjacob wt = ", 16 bit wide, Tagged Queueing Enabled\n";
619 1.17 mjacob break;
620 1.17 mjacob default:
621 1.17 mjacob wt = "\n";
622 1.17 mjacob break;
623 1.17 mjacob }
624 1.17 mjacob if (mhz) {
625 1.19 mjacob CFGPRINTF("%s: Bus %d Target %d at %dMHz Max "
626 1.17 mjacob "Offset %d%s", isp->isp_name, bus, tgt, mhz,
627 1.17 mjacob sdp->isp_devparam[tgt].cur_offset, wt);
628 1.17 mjacob } else {
629 1.19 mjacob CFGPRINTF("%s: Bus %d Target %d Async Mode%s",
630 1.17 mjacob isp->isp_name, bus, tgt, wt);
631 1.9 mjacob }
632 1.11 mjacob break;
633 1.17 mjacob }
634 1.11 mjacob case ISPASYNC_BUS_RESET:
635 1.14 mjacob if (arg)
636 1.14 mjacob bus = *((int *) arg);
637 1.14 mjacob else
638 1.14 mjacob bus = 0;
639 1.14 mjacob printf("%s: SCSI bus %d reset detected\n", isp->isp_name, bus);
640 1.11 mjacob break;
641 1.11 mjacob case ISPASYNC_LOOP_DOWN:
642 1.11 mjacob /*
643 1.11 mjacob * Hopefully we get here in time to minimize the number
644 1.11 mjacob * of commands we are firing off that are sure to die.
645 1.11 mjacob */
646 1.11 mjacob isp->isp_osinfo.blocked = 1;
647 1.11 mjacob printf("%s: Loop DOWN\n", isp->isp_name);
648 1.11 mjacob break;
649 1.11 mjacob case ISPASYNC_LOOP_UP:
650 1.11 mjacob isp->isp_osinfo.blocked = 0;
651 1.11 mjacob timeout(isp_internal_restart, isp, 1);
652 1.11 mjacob printf("%s: Loop UP\n", isp->isp_name);
653 1.11 mjacob break;
654 1.15 mjacob case ISPASYNC_PDB_CHANGED:
655 1.17 mjacob if (IS_FC(isp) && isp->isp_dblev) {
656 1.15 mjacob const char *fmt = "%s: Target %d (Loop 0x%x) Port ID 0x%x "
657 1.15 mjacob "role %s %s\n Port WWN 0x%08x%08x\n Node WWN 0x%08x%08x\n";
658 1.15 mjacob const static char *roles[4] = {
659 1.11 mjacob "No", "Target", "Initiator", "Target/Initiator"
660 1.11 mjacob };
661 1.15 mjacob char *ptr;
662 1.15 mjacob fcparam *fcp = isp->isp_param;
663 1.15 mjacob int tgt = *((int *) arg);
664 1.15 mjacob struct lportdb *lp = &fcp->portdb[tgt];
665 1.15 mjacob
666 1.15 mjacob if (lp->valid) {
667 1.15 mjacob ptr = "arrived";
668 1.15 mjacob } else {
669 1.15 mjacob ptr = "disappeared";
670 1.11 mjacob }
671 1.15 mjacob printf(fmt, isp->isp_name, tgt, lp->loopid, lp->portid,
672 1.15 mjacob roles[lp->roles & 0x3], ptr,
673 1.15 mjacob (u_int32_t) (lp->port_wwn >> 32),
674 1.15 mjacob (u_int32_t) (lp->port_wwn & 0xffffffffLL),
675 1.15 mjacob (u_int32_t) (lp->node_wwn >> 32),
676 1.15 mjacob (u_int32_t) (lp->node_wwn & 0xffffffffLL));
677 1.11 mjacob break;
678 1.11 mjacob }
679 1.15 mjacob #ifdef ISP2100_FABRIC
680 1.11 mjacob case ISPASYNC_CHANGE_NOTIFY:
681 1.11 mjacob printf("%s: Name Server Database Changed\n", isp->isp_name);
682 1.9 mjacob break;
683 1.15 mjacob case ISPASYNC_FABRIC_DEV:
684 1.15 mjacob {
685 1.15 mjacob int target;
686 1.15 mjacob struct lportdb *lp;
687 1.15 mjacob sns_scrsp_t *resp = (sns_scrsp_t *) arg;
688 1.15 mjacob u_int32_t portid;
689 1.15 mjacob u_int64_t wwn;
690 1.15 mjacob fcparam *fcp = isp->isp_param;
691 1.15 mjacob
692 1.15 mjacob portid =
693 1.15 mjacob (((u_int32_t) resp->snscb_port_id[0]) << 16) |
694 1.15 mjacob (((u_int32_t) resp->snscb_port_id[1]) << 8) |
695 1.15 mjacob (((u_int32_t) resp->snscb_port_id[2]));
696 1.15 mjacob wwn =
697 1.15 mjacob (((u_int64_t)resp->snscb_portname[0]) << 56) |
698 1.15 mjacob (((u_int64_t)resp->snscb_portname[1]) << 48) |
699 1.15 mjacob (((u_int64_t)resp->snscb_portname[2]) << 40) |
700 1.15 mjacob (((u_int64_t)resp->snscb_portname[3]) << 32) |
701 1.15 mjacob (((u_int64_t)resp->snscb_portname[4]) << 24) |
702 1.15 mjacob (((u_int64_t)resp->snscb_portname[5]) << 16) |
703 1.15 mjacob (((u_int64_t)resp->snscb_portname[6]) << 8) |
704 1.15 mjacob (((u_int64_t)resp->snscb_portname[7]));
705 1.15 mjacob printf("%s: Fabric Device (Type 0x%x)@PortID 0x%x WWN "
706 1.15 mjacob "0x%08x%08x\n", isp->isp_name, resp->snscb_port_type,
707 1.15 mjacob portid, ((u_int32_t)(wwn >> 32)),
708 1.15 mjacob ((u_int32_t)(wwn & 0xffffffff)));
709 1.15 mjacob if (resp->snscb_port_type != 2)
710 1.15 mjacob break;
711 1.15 mjacob for (target = FC_SNS_ID+1; target < MAX_FC_TARG; target++) {
712 1.15 mjacob lp = &fcp->portdb[target];
713 1.15 mjacob if (lp->port_wwn == wwn)
714 1.15 mjacob break;
715 1.15 mjacob }
716 1.15 mjacob if (target < MAX_FC_TARG) {
717 1.15 mjacob break;
718 1.15 mjacob }
719 1.15 mjacob for (target = FC_SNS_ID+1; target < MAX_FC_TARG; target++) {
720 1.15 mjacob lp = &fcp->portdb[target];
721 1.15 mjacob if (lp->port_wwn == 0)
722 1.15 mjacob break;
723 1.15 mjacob }
724 1.15 mjacob if (target == MAX_FC_TARG) {
725 1.15 mjacob printf("%s: no more space for fabric devices\n",
726 1.15 mjacob isp->isp_name);
727 1.15 mjacob return (-1);
728 1.15 mjacob }
729 1.15 mjacob lp->port_wwn = lp->node_wwn = wwn;
730 1.15 mjacob lp->portid = portid;
731 1.15 mjacob break;
732 1.15 mjacob }
733 1.15 mjacob #endif
734 1.9 mjacob default:
735 1.9 mjacob break;
736 1.9 mjacob }
737 1.10 mjacob (void) splx(s);
738 1.9 mjacob return (0);
739 1.1 mjacob }
740