mlx.c revision 1.54 1 1.54 cegger /* $NetBSD: mlx.c,v 1.54 2008/04/08 12:07:26 cegger Exp $ */
2 1.1 ad
3 1.1 ad /*-
4 1.1 ad * Copyright (c) 2001 The NetBSD Foundation, Inc.
5 1.1 ad * All rights reserved.
6 1.1 ad *
7 1.1 ad * This code is derived from software contributed to The NetBSD Foundation
8 1.1 ad * by Andrew Doran.
9 1.1 ad *
10 1.1 ad * Redistribution and use in source and binary forms, with or without
11 1.1 ad * modification, are permitted provided that the following conditions
12 1.1 ad * are met:
13 1.1 ad * 1. Redistributions of source code must retain the above copyright
14 1.1 ad * notice, this list of conditions and the following disclaimer.
15 1.1 ad * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 ad * notice, this list of conditions and the following disclaimer in the
17 1.1 ad * documentation and/or other materials provided with the distribution.
18 1.1 ad * 3. All advertising materials mentioning features or use of this software
19 1.1 ad * must display the following acknowledgement:
20 1.1 ad * This product includes software developed by the NetBSD
21 1.1 ad * Foundation, Inc. and its contributors.
22 1.1 ad * 4. Neither the name of The NetBSD Foundation nor the names of its
23 1.1 ad * contributors may be used to endorse or promote products derived
24 1.1 ad * from this software without specific prior written permission.
25 1.1 ad *
26 1.1 ad * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
27 1.1 ad * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
28 1.1 ad * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
29 1.1 ad * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
30 1.1 ad * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
31 1.1 ad * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
32 1.1 ad * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
33 1.1 ad * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
34 1.1 ad * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
35 1.1 ad * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
36 1.1 ad * POSSIBILITY OF SUCH DAMAGE.
37 1.1 ad */
38 1.1 ad
39 1.1 ad /*-
40 1.1 ad * Copyright (c) 1999 Michael Smith
41 1.1 ad * All rights reserved.
42 1.1 ad *
43 1.1 ad * Redistribution and use in source and binary forms, with or without
44 1.1 ad * modification, are permitted provided that the following conditions
45 1.1 ad * are met:
46 1.1 ad * 1. Redistributions of source code must retain the above copyright
47 1.1 ad * notice, this list of conditions and the following disclaimer.
48 1.1 ad * 2. Redistributions in binary form must reproduce the above copyright
49 1.1 ad * notice, this list of conditions and the following disclaimer in the
50 1.1 ad * documentation and/or other materials provided with the distribution.
51 1.1 ad *
52 1.1 ad * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
53 1.1 ad * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
54 1.1 ad * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
55 1.1 ad * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
56 1.1 ad * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
57 1.1 ad * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
58 1.1 ad * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
59 1.1 ad * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
60 1.1 ad * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
61 1.1 ad * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
62 1.1 ad * SUCH DAMAGE.
63 1.1 ad *
64 1.1 ad * from FreeBSD: mlx.c,v 1.14.2.3 2000/08/04 06:52:50 msmith Exp
65 1.1 ad */
66 1.1 ad
67 1.1 ad /*
68 1.1 ad * Driver for the Mylex DAC960 family of RAID controllers.
69 1.1 ad *
70 1.1 ad * TODO:
71 1.1 ad *
72 1.1 ad * o Test and enable channel pause.
73 1.1 ad * o SCSI pass-through.
74 1.1 ad */
75 1.15 lukem
76 1.15 lukem #include <sys/cdefs.h>
77 1.54 cegger __KERNEL_RCSID(0, "$NetBSD: mlx.c,v 1.54 2008/04/08 12:07:26 cegger Exp $");
78 1.1 ad
79 1.1 ad #include "ld.h"
80 1.1 ad
81 1.1 ad #include <sys/param.h>
82 1.1 ad #include <sys/systm.h>
83 1.1 ad #include <sys/kernel.h>
84 1.1 ad #include <sys/device.h>
85 1.1 ad #include <sys/queue.h>
86 1.1 ad #include <sys/proc.h>
87 1.1 ad #include <sys/buf.h>
88 1.31 yamt #include <sys/bufq.h>
89 1.1 ad #include <sys/endian.h>
90 1.1 ad #include <sys/malloc.h>
91 1.1 ad #include <sys/conf.h>
92 1.1 ad #include <sys/kthread.h>
93 1.1 ad #include <sys/disk.h>
94 1.47 elad #include <sys/kauth.h>
95 1.1 ad
96 1.1 ad #include <machine/vmparam.h>
97 1.53 ad #include <sys/bus.h>
98 1.2 enami
99 1.2 enami #include <uvm/uvm_extern.h>
100 1.1 ad
101 1.1 ad #include <dev/ldvar.h>
102 1.1 ad
103 1.1 ad #include <dev/ic/mlxreg.h>
104 1.1 ad #include <dev/ic/mlxio.h>
105 1.1 ad #include <dev/ic/mlxvar.h>
106 1.1 ad
107 1.30 drochner #include "locators.h"
108 1.30 drochner
109 1.1 ad #define MLX_TIMEOUT 60
110 1.1 ad
111 1.1 ad #ifdef DIAGNOSTIC
112 1.1 ad #define DPRINTF(x) printf x
113 1.1 ad #else
114 1.1 ad #define DPRINTF(x)
115 1.1 ad #endif
116 1.1 ad
117 1.1 ad static void mlx_adjqparam(struct mlx_softc *, int, int);
118 1.1 ad static int mlx_ccb_submit(struct mlx_softc *, struct mlx_ccb *);
119 1.1 ad static int mlx_check(struct mlx_softc *, int);
120 1.1 ad static void mlx_configure(struct mlx_softc *, int);
121 1.1 ad static void mlx_describe(struct mlx_softc *);
122 1.1 ad static void *mlx_enquire(struct mlx_softc *, int, size_t,
123 1.1 ad void (*)(struct mlx_ccb *), int);
124 1.1 ad static int mlx_fw_message(struct mlx_softc *, int, int, int);
125 1.1 ad static void mlx_pause_action(struct mlx_softc *);
126 1.1 ad static void mlx_pause_done(struct mlx_ccb *);
127 1.1 ad static void mlx_periodic(struct mlx_softc *);
128 1.1 ad static void mlx_periodic_enquiry(struct mlx_ccb *);
129 1.1 ad static void mlx_periodic_eventlog_poll(struct mlx_softc *);
130 1.1 ad static void mlx_periodic_eventlog_respond(struct mlx_ccb *);
131 1.1 ad static void mlx_periodic_rebuild(struct mlx_ccb *);
132 1.1 ad static void mlx_periodic_thread(void *);
133 1.1 ad static int mlx_print(void *, const char *);
134 1.1 ad static int mlx_rebuild(struct mlx_softc *, int, int);
135 1.1 ad static void mlx_shutdown(void *);
136 1.1 ad static int mlx_user_command(struct mlx_softc *, struct mlx_usercommand *);
137 1.1 ad
138 1.20 gehenna dev_type_open(mlxopen);
139 1.20 gehenna dev_type_close(mlxclose);
140 1.20 gehenna dev_type_ioctl(mlxioctl);
141 1.20 gehenna
142 1.20 gehenna const struct cdevsw mlx_cdevsw = {
143 1.20 gehenna mlxopen, mlxclose, noread, nowrite, mlxioctl,
144 1.45 christos nostop, notty, nopoll, nommap, nokqfilter, D_OTHER,
145 1.20 gehenna };
146 1.1 ad
147 1.32 perry extern struct cfdriver mlx_cd;
148 1.52 ad static struct lwp *mlx_periodic_lwp;
149 1.1 ad static void *mlx_sdh;
150 1.1 ad
151 1.45 christos static struct {
152 1.1 ad int hwid;
153 1.1 ad const char *name;
154 1.45 christos } const mlx_cname[] = {
155 1.18 ad { 0x00, "960E/960M" },
156 1.1 ad { 0x01, "960P/PD" },
157 1.1 ad { 0x02, "960PL" },
158 1.1 ad { 0x10, "960PG" },
159 1.1 ad { 0x11, "960PJ" },
160 1.1 ad { 0x12, "960PR" },
161 1.1 ad { 0x13, "960PT" },
162 1.1 ad { 0x14, "960PTL0" },
163 1.1 ad { 0x15, "960PRL" },
164 1.1 ad { 0x16, "960PTL1" },
165 1.1 ad { 0x20, "1164PVX" },
166 1.1 ad };
167 1.1 ad
168 1.1 ad static const char * const mlx_sense_msgs[] = {
169 1.1 ad "because write recovery failed",
170 1.1 ad "because of SCSI bus reset failure",
171 1.1 ad "because of double check condition",
172 1.1 ad "because it was removed",
173 1.1 ad "because of gross error on SCSI chip",
174 1.1 ad "because of bad tag returned from drive",
175 1.1 ad "because of timeout on SCSI command",
176 1.1 ad "because of reset SCSI command issued from system",
177 1.1 ad "because busy or parity error count exceeded limit",
178 1.1 ad "because of 'kill drive' command from system",
179 1.1 ad "because of selection timeout",
180 1.1 ad "due to SCSI phase sequence error",
181 1.1 ad "due to unknown status"
182 1.1 ad };
183 1.1 ad
184 1.1 ad static const char * const mlx_status_msgs[] = {
185 1.1 ad "normal completion", /* 0 */
186 1.1 ad "irrecoverable data error", /* 1 */
187 1.1 ad "drive does not exist, or is offline", /* 2 */
188 1.1 ad "attempt to write beyond end of drive", /* 3 */
189 1.1 ad "bad data encountered", /* 4 */
190 1.1 ad "invalid log entry request", /* 5 */
191 1.1 ad "attempt to rebuild online drive", /* 6 */
192 1.1 ad "new disk failed during rebuild", /* 7 */
193 1.1 ad "invalid channel/target", /* 8 */
194 1.1 ad "rebuild/check already in progress", /* 9 */
195 1.1 ad "one or more disks are dead", /* 10 */
196 1.1 ad "invalid or non-redundant drive", /* 11 */
197 1.1 ad "channel is busy", /* 12 */
198 1.1 ad "channel is not stopped", /* 13 */
199 1.1 ad "rebuild successfully terminated", /* 14 */
200 1.1 ad "unsupported command", /* 15 */
201 1.1 ad "check condition received", /* 16 */
202 1.1 ad "device is busy", /* 17 */
203 1.1 ad "selection or command timeout", /* 18 */
204 1.1 ad "command terminated abnormally", /* 19 */
205 1.1 ad "controller wedged", /* 20 */
206 1.1 ad "software timeout", /* 21 */
207 1.7 lukem "command busy (?)", /* 22 */
208 1.1 ad };
209 1.1 ad
210 1.45 christos static struct {
211 1.1 ad u_char command;
212 1.1 ad u_char msg; /* Index into mlx_status_msgs[]. */
213 1.1 ad u_short status;
214 1.45 christos } const mlx_msgs[] = {
215 1.1 ad { MLX_CMD_READSG, 1, 0x0001 },
216 1.1 ad { MLX_CMD_READSG, 1, 0x0002 },
217 1.1 ad { MLX_CMD_READSG, 3, 0x0105 },
218 1.1 ad { MLX_CMD_READSG, 4, 0x010c },
219 1.1 ad { MLX_CMD_WRITESG, 1, 0x0001 },
220 1.1 ad { MLX_CMD_WRITESG, 1, 0x0002 },
221 1.1 ad { MLX_CMD_WRITESG, 3, 0x0105 },
222 1.1 ad { MLX_CMD_READSG_OLD, 1, 0x0001 },
223 1.1 ad { MLX_CMD_READSG_OLD, 1, 0x0002 },
224 1.1 ad { MLX_CMD_READSG_OLD, 3, 0x0105 },
225 1.1 ad { MLX_CMD_WRITESG_OLD, 1, 0x0001 },
226 1.1 ad { MLX_CMD_WRITESG_OLD, 1, 0x0002 },
227 1.1 ad { MLX_CMD_WRITESG_OLD, 3, 0x0105 },
228 1.1 ad { MLX_CMD_LOGOP, 5, 0x0105 },
229 1.1 ad { MLX_CMD_REBUILDASYNC, 6, 0x0002 },
230 1.1 ad { MLX_CMD_REBUILDASYNC, 7, 0x0004 },
231 1.1 ad { MLX_CMD_REBUILDASYNC, 8, 0x0105 },
232 1.1 ad { MLX_CMD_REBUILDASYNC, 9, 0x0106 },
233 1.1 ad { MLX_CMD_REBUILDASYNC, 14, 0x0107 },
234 1.1 ad { MLX_CMD_CHECKASYNC, 10, 0x0002 },
235 1.1 ad { MLX_CMD_CHECKASYNC, 11, 0x0105 },
236 1.1 ad { MLX_CMD_CHECKASYNC, 9, 0x0106 },
237 1.1 ad { MLX_CMD_STOPCHANNEL, 12, 0x0106 },
238 1.1 ad { MLX_CMD_STOPCHANNEL, 8, 0x0105 },
239 1.1 ad { MLX_CMD_STARTCHANNEL, 13, 0x0005 },
240 1.1 ad { MLX_CMD_STARTCHANNEL, 8, 0x0105 },
241 1.1 ad { MLX_CMD_DIRECT_CDB, 16, 0x0002 },
242 1.1 ad { MLX_CMD_DIRECT_CDB, 17, 0x0008 },
243 1.1 ad { MLX_CMD_DIRECT_CDB, 18, 0x000e },
244 1.1 ad { MLX_CMD_DIRECT_CDB, 19, 0x000f },
245 1.1 ad { MLX_CMD_DIRECT_CDB, 8, 0x0105 },
246 1.1 ad
247 1.1 ad { 0, 20, MLX_STATUS_WEDGED },
248 1.1 ad { 0, 21, MLX_STATUS_LOST },
249 1.1 ad { 0, 22, MLX_STATUS_BUSY },
250 1.1 ad
251 1.1 ad { 0, 14, 0x0104 },
252 1.1 ad };
253 1.1 ad
254 1.1 ad /*
255 1.1 ad * Initialise the controller and our interface.
256 1.1 ad */
257 1.1 ad void
258 1.1 ad mlx_init(struct mlx_softc *mlx, const char *intrstr)
259 1.1 ad {
260 1.1 ad struct mlx_ccb *mc;
261 1.1 ad struct mlx_enquiry_old *meo;
262 1.18 ad struct mlx_enquiry2 *me2;
263 1.18 ad struct mlx_cinfo *ci;
264 1.1 ad int rv, fwminor, hscode, hserr, hsparam1, hsparam2, hsmsg;
265 1.1 ad int size, i, rseg;
266 1.1 ad const char *wantfwstr;
267 1.1 ad bus_dma_segment_t seg;
268 1.1 ad
269 1.1 ad SIMPLEQ_INIT(&mlx->mlx_ccb_queue);
270 1.1 ad SLIST_INIT(&mlx->mlx_ccb_freelist);
271 1.1 ad TAILQ_INIT(&mlx->mlx_ccb_worklist);
272 1.1 ad
273 1.1 ad if (intrstr != NULL)
274 1.54 cegger printf("%s: interrupting at %s\n", device_xname(&mlx->mlx_dv),
275 1.1 ad intrstr);
276 1.1 ad
277 1.1 ad /*
278 1.1 ad * Allocate the scatter/gather lists.
279 1.1 ad */
280 1.1 ad size = MLX_SGL_SIZE * MLX_MAX_QUEUECNT;
281 1.1 ad
282 1.1 ad if ((rv = bus_dmamem_alloc(mlx->mlx_dmat, size, PAGE_SIZE, 0, &seg, 1,
283 1.1 ad &rseg, BUS_DMA_NOWAIT)) != 0) {
284 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "unable to allocate sglists, rv = %d\n", rv);
285 1.1 ad return;
286 1.1 ad }
287 1.1 ad
288 1.32 perry if ((rv = bus_dmamem_map(mlx->mlx_dmat, &seg, rseg, size,
289 1.51 christos (void **)&mlx->mlx_sgls,
290 1.1 ad BUS_DMA_NOWAIT | BUS_DMA_COHERENT)) != 0) {
291 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "unable to map sglists, rv = %d\n", rv);
292 1.1 ad return;
293 1.1 ad }
294 1.1 ad
295 1.32 perry if ((rv = bus_dmamap_create(mlx->mlx_dmat, size, 1, size, 0,
296 1.50 tsutsui BUS_DMA_NOWAIT, &mlx->mlx_dmamap)) != 0) {
297 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "unable to create sglist DMA map, rv = %d\n", rv);
298 1.1 ad return;
299 1.1 ad }
300 1.1 ad
301 1.1 ad if ((rv = bus_dmamap_load(mlx->mlx_dmat, mlx->mlx_dmamap,
302 1.1 ad mlx->mlx_sgls, size, NULL, BUS_DMA_NOWAIT)) != 0) {
303 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "unable to load sglist DMA map, rv = %d\n", rv);
304 1.1 ad return;
305 1.1 ad }
306 1.1 ad
307 1.1 ad mlx->mlx_sgls_paddr = mlx->mlx_dmamap->dm_segs[0].ds_addr;
308 1.1 ad memset(mlx->mlx_sgls, 0, size);
309 1.1 ad
310 1.1 ad /*
311 1.14 wiz * Allocate and initialize the CCBs.
312 1.1 ad */
313 1.1 ad mc = malloc(sizeof(*mc) * MLX_MAX_QUEUECNT, M_DEVBUF, M_NOWAIT);
314 1.1 ad mlx->mlx_ccbs = mc;
315 1.1 ad
316 1.1 ad for (i = 0; i < MLX_MAX_QUEUECNT; i++, mc++) {
317 1.1 ad mc->mc_ident = i;
318 1.1 ad rv = bus_dmamap_create(mlx->mlx_dmat, MLX_MAX_XFER,
319 1.9 ad MLX_MAX_SEGS, MLX_MAX_XFER, 0,
320 1.1 ad BUS_DMA_NOWAIT | BUS_DMA_ALLOCNOW,
321 1.1 ad &mc->mc_xfer_map);
322 1.1 ad if (rv != 0)
323 1.1 ad break;
324 1.1 ad mlx->mlx_nccbs++;
325 1.1 ad mlx_ccb_free(mlx, mc);
326 1.1 ad }
327 1.1 ad if (mlx->mlx_nccbs != MLX_MAX_QUEUECNT)
328 1.54 cegger printf("%s: %d/%d CCBs usable\n", device_xname(&mlx->mlx_dv),
329 1.1 ad mlx->mlx_nccbs, MLX_MAX_QUEUECNT);
330 1.1 ad
331 1.1 ad /* Disable interrupts before we start talking to the controller */
332 1.1 ad (*mlx->mlx_intaction)(mlx, 0);
333 1.1 ad
334 1.8 ad /* If we've got a reset routine, then reset the controller now. */
335 1.8 ad if (mlx->mlx_reset != NULL) {
336 1.54 cegger printf("%s: resetting controller...\n", device_xname(&mlx->mlx_dv));
337 1.8 ad if ((*mlx->mlx_reset)(mlx) != 0) {
338 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "reset failed\n");
339 1.8 ad return;
340 1.8 ad }
341 1.8 ad }
342 1.8 ad
343 1.32 perry /*
344 1.1 ad * Wait for the controller to come ready, handshaking with the
345 1.1 ad * firmware if required. This is typically only necessary on
346 1.1 ad * platforms where the controller BIOS does not run.
347 1.1 ad */
348 1.1 ad hsmsg = 0;
349 1.1 ad
350 1.1 ad for (;;) {
351 1.1 ad hscode = (*mlx->mlx_fw_handshake)(mlx, &hserr, &hsparam1,
352 1.1 ad &hsparam2);
353 1.1 ad if (hscode == 0) {
354 1.1 ad if (hsmsg != 0)
355 1.1 ad printf("%s: initialization complete\n",
356 1.54 cegger device_xname(&mlx->mlx_dv));
357 1.1 ad break;
358 1.1 ad }
359 1.1 ad
360 1.1 ad /* Report first time around... */
361 1.1 ad if (hsmsg == 0) {
362 1.1 ad printf("%s: initializing (may take some time)...\n",
363 1.54 cegger device_xname(&mlx->mlx_dv));
364 1.1 ad hsmsg = 1;
365 1.1 ad }
366 1.1 ad
367 1.1 ad /* Did we get a real message? */
368 1.1 ad if (hscode == 2) {
369 1.1 ad hscode = mlx_fw_message(mlx, hserr, hsparam1, hsparam2);
370 1.1 ad
371 1.1 ad /* Fatal initialisation error? */
372 1.1 ad if (hscode != 0)
373 1.1 ad return;
374 1.1 ad }
375 1.1 ad }
376 1.1 ad
377 1.1 ad /*
378 1.1 ad * Do quirk/feature related things.
379 1.1 ad */
380 1.18 ad ci = &mlx->mlx_ci;
381 1.18 ad
382 1.18 ad if (ci->ci_iftype > 1) {
383 1.18 ad me2 = mlx_enquire(mlx, MLX_CMD_ENQUIRY2,
384 1.18 ad sizeof(struct mlx_enquiry2), NULL, 0);
385 1.18 ad if (me2 == NULL) {
386 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "ENQUIRY2 failed\n");
387 1.18 ad return;
388 1.18 ad }
389 1.18 ad
390 1.18 ad ci->ci_firmware_id[0] = me2->me_firmware_id[0];
391 1.18 ad ci->ci_firmware_id[1] = me2->me_firmware_id[1];
392 1.18 ad ci->ci_firmware_id[2] = me2->me_firmware_id[2];
393 1.18 ad ci->ci_firmware_id[3] = me2->me_firmware_id[3];
394 1.18 ad ci->ci_hardware_id = me2->me_hardware_id[0];
395 1.18 ad ci->ci_mem_size = le32toh(me2->me_mem_size);
396 1.18 ad ci->ci_max_sg = le16toh(me2->me_max_sg);
397 1.18 ad ci->ci_max_commands = le16toh(me2->me_max_commands);
398 1.18 ad ci->ci_nchan = me2->me_actual_channels;
399 1.18 ad
400 1.18 ad free(me2, M_DEVBUF);
401 1.18 ad }
402 1.18 ad
403 1.18 ad if (ci->ci_iftype <= 2) {
404 1.1 ad /*
405 1.1 ad * These controllers may not report the firmware version in
406 1.18 ad * the ENQUIRY2 response, or may not even support it.
407 1.1 ad */
408 1.1 ad meo = mlx_enquire(mlx, MLX_CMD_ENQUIRY_OLD,
409 1.1 ad sizeof(struct mlx_enquiry_old), NULL, 0);
410 1.1 ad if (meo == NULL) {
411 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "ENQUIRY_OLD failed\n");
412 1.1 ad return;
413 1.1 ad }
414 1.18 ad ci->ci_firmware_id[0] = meo->me_fwmajor;
415 1.18 ad ci->ci_firmware_id[1] = meo->me_fwminor;
416 1.18 ad ci->ci_firmware_id[2] = 0;
417 1.18 ad ci->ci_firmware_id[3] = '0';
418 1.18 ad
419 1.18 ad if (ci->ci_iftype == 1) {
420 1.18 ad ci->ci_hardware_id = 0; /* XXX */
421 1.18 ad ci->ci_mem_size = 0; /* XXX */
422 1.18 ad ci->ci_max_sg = 17; /* XXX */
423 1.18 ad ci->ci_max_commands = meo->me_max_commands;
424 1.18 ad }
425 1.18 ad
426 1.1 ad free(meo, M_DEVBUF);
427 1.1 ad }
428 1.1 ad
429 1.1 ad wantfwstr = NULL;
430 1.18 ad fwminor = ci->ci_firmware_id[1];
431 1.1 ad
432 1.18 ad switch (ci->ci_firmware_id[0]) {
433 1.1 ad case 2:
434 1.18 ad if (ci->ci_iftype == 1) {
435 1.1 ad if (fwminor < 14)
436 1.1 ad wantfwstr = "2.14";
437 1.1 ad } else if (fwminor < 42)
438 1.1 ad wantfwstr = "2.42";
439 1.1 ad break;
440 1.1 ad
441 1.1 ad case 3:
442 1.1 ad if (fwminor < 51)
443 1.1 ad wantfwstr = "3.51";
444 1.1 ad break;
445 1.1 ad
446 1.1 ad case 4:
447 1.1 ad if (fwminor < 6)
448 1.1 ad wantfwstr = "4.06";
449 1.1 ad break;
450 1.1 ad
451 1.1 ad case 5:
452 1.1 ad if (fwminor < 7)
453 1.1 ad wantfwstr = "5.07";
454 1.1 ad break;
455 1.1 ad }
456 1.1 ad
457 1.1 ad /* Print a little information about the controller. */
458 1.1 ad mlx_describe(mlx);
459 1.1 ad
460 1.1 ad if (wantfwstr != NULL) {
461 1.1 ad printf("%s: WARNING: this f/w revision is not recommended\n",
462 1.54 cegger device_xname(&mlx->mlx_dv));
463 1.1 ad printf("%s: WARNING: use revision %s or later\n",
464 1.54 cegger device_xname(&mlx->mlx_dv), wantfwstr);
465 1.1 ad }
466 1.1 ad
467 1.1 ad /* We don't (yet) know where the event log is up to. */
468 1.1 ad mlx->mlx_currevent = -1;
469 1.1 ad
470 1.1 ad /* No user-requested background operation is in progress. */
471 1.1 ad mlx->mlx_bg = 0;
472 1.1 ad mlx->mlx_rebuildstat.rs_code = MLX_REBUILDSTAT_IDLE;
473 1.1 ad
474 1.1 ad /* Set maximum number of queued commands for `regular' operations. */
475 1.1 ad mlx->mlx_max_queuecnt =
476 1.18 ad min(ci->ci_max_commands, MLX_MAX_QUEUECNT) -
477 1.21 ad MLX_NCCBS_CONTROL;
478 1.1 ad #ifdef DIAGNOSTIC
479 1.21 ad if (mlx->mlx_max_queuecnt < MLX_NCCBS_CONTROL + MLX_MAX_DRIVES)
480 1.1 ad printf("%s: WARNING: few CCBs available\n",
481 1.54 cegger device_xname(&mlx->mlx_dv));
482 1.18 ad if (ci->ci_max_sg < MLX_MAX_SEGS) {
483 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "oops, not enough S/G segments\n");
484 1.1 ad return;
485 1.1 ad }
486 1.1 ad #endif
487 1.1 ad
488 1.52 ad /* Attach child devices and enable interrupts. */
489 1.52 ad mlx_configure(mlx, 0);
490 1.52 ad (*mlx->mlx_intaction)(mlx, 1);
491 1.52 ad mlx->mlx_flags |= MLXF_INITOK;
492 1.52 ad
493 1.1 ad if (mlx_sdh == NULL) {
494 1.1 ad /*
495 1.1 ad * Set our `shutdownhook' before we start any device
496 1.1 ad * activity.
497 1.1 ad */
498 1.1 ad mlx_sdh = shutdownhook_establish(mlx_shutdown, NULL);
499 1.1 ad
500 1.52 ad /* Create a status monitoring thread. */
501 1.52 ad rv = kthread_create(PRI_NONE, 0, NULL, mlx_periodic_thread,
502 1.52 ad NULL, &mlx_periodic_lwp, "mlxtask");
503 1.52 ad if (rv != 0)
504 1.52 ad printf("mlx_init: unable to create thread (%d)\n", rv);
505 1.1 ad }
506 1.1 ad }
507 1.1 ad
508 1.1 ad /*
509 1.1 ad * Tell the world about the controller.
510 1.1 ad */
511 1.1 ad static void
512 1.1 ad mlx_describe(struct mlx_softc *mlx)
513 1.1 ad {
514 1.18 ad struct mlx_cinfo *ci;
515 1.33 christos static char tbuf[80];
516 1.1 ad const char *model;
517 1.1 ad int i;
518 1.1 ad
519 1.1 ad model = NULL;
520 1.18 ad ci = &mlx->mlx_ci;
521 1.1 ad
522 1.1 ad for (i = 0; i < sizeof(mlx_cname) / sizeof(mlx_cname[0]); i++)
523 1.18 ad if (ci->ci_hardware_id == mlx_cname[i].hwid) {
524 1.1 ad model = mlx_cname[i].name;
525 1.1 ad break;
526 1.1 ad }
527 1.1 ad
528 1.1 ad if (model == NULL) {
529 1.33 christos snprintf(tbuf, sizeof(tbuf), " model 0x%x", ci->ci_hardware_id);
530 1.33 christos model = tbuf;
531 1.1 ad }
532 1.1 ad
533 1.18 ad printf("%s: DAC%s, %d channel%s, firmware %d.%02d-%c-%02d",
534 1.54 cegger device_xname(&mlx->mlx_dv), model, ci->ci_nchan,
535 1.18 ad ci->ci_nchan > 1 ? "s" : "",
536 1.18 ad ci->ci_firmware_id[0], ci->ci_firmware_id[1],
537 1.18 ad ci->ci_firmware_id[3], ci->ci_firmware_id[2]);
538 1.18 ad if (ci->ci_mem_size != 0)
539 1.18 ad printf(", %dMB RAM", ci->ci_mem_size >> 20);
540 1.18 ad printf("\n");
541 1.1 ad }
542 1.1 ad
543 1.1 ad /*
544 1.1 ad * Locate disk resources and attach children to them.
545 1.1 ad */
546 1.1 ad static void
547 1.1 ad mlx_configure(struct mlx_softc *mlx, int waitok)
548 1.1 ad {
549 1.6 ad struct mlx_enquiry *me;
550 1.10 ad struct mlx_enquiry_old *meo;
551 1.1 ad struct mlx_enq_sys_drive *mes;
552 1.1 ad struct mlx_sysdrive *ms;
553 1.1 ad struct mlx_attach_args mlxa;
554 1.1 ad int i, nunits;
555 1.1 ad u_int size;
556 1.35 drochner int locs[MLXCF_NLOCS];
557 1.1 ad
558 1.12 ad mlx->mlx_flags |= MLXF_RESCANNING;
559 1.12 ad
560 1.18 ad if (mlx->mlx_ci.ci_iftype <= 2) {
561 1.10 ad meo = mlx_enquire(mlx, MLX_CMD_ENQUIRY_OLD,
562 1.10 ad sizeof(struct mlx_enquiry_old), NULL, waitok);
563 1.10 ad if (meo == NULL) {
564 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "ENQUIRY_OLD failed\n");
565 1.12 ad goto out;
566 1.10 ad }
567 1.10 ad mlx->mlx_numsysdrives = meo->me_num_sys_drvs;
568 1.10 ad free(meo, M_DEVBUF);
569 1.10 ad } else {
570 1.10 ad me = mlx_enquire(mlx, MLX_CMD_ENQUIRY,
571 1.10 ad sizeof(struct mlx_enquiry), NULL, waitok);
572 1.10 ad if (me == NULL) {
573 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "ENQUIRY failed\n");
574 1.12 ad goto out;
575 1.10 ad }
576 1.10 ad mlx->mlx_numsysdrives = me->me_num_sys_drvs;
577 1.10 ad free(me, M_DEVBUF);
578 1.6 ad }
579 1.6 ad
580 1.1 ad mes = mlx_enquire(mlx, MLX_CMD_ENQSYSDRIVE,
581 1.1 ad sizeof(*mes) * MLX_MAX_DRIVES, NULL, waitok);
582 1.1 ad if (mes == NULL) {
583 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "error fetching drive status\n");
584 1.12 ad goto out;
585 1.1 ad }
586 1.1 ad
587 1.1 ad /* Allow 1 queued command per unit while re-configuring. */
588 1.1 ad mlx_adjqparam(mlx, 1, 0);
589 1.1 ad
590 1.1 ad ms = &mlx->mlx_sysdrive[0];
591 1.6 ad nunits = 0;
592 1.1 ad for (i = 0; i < MLX_MAX_DRIVES; i++, ms++) {
593 1.1 ad size = le32toh(mes[i].sd_size);
594 1.6 ad ms->ms_state = mes[i].sd_state;
595 1.6 ad
596 1.1 ad /*
597 1.1 ad * If an existing device has changed in some way (e.g. no
598 1.1 ad * longer present) then detach it.
599 1.1 ad */
600 1.1 ad if (ms->ms_dv != NULL && (size != ms->ms_size ||
601 1.1 ad (mes[i].sd_raidlevel & 0xf) != ms->ms_raidlevel))
602 1.1 ad config_detach(ms->ms_dv, DETACH_FORCE);
603 1.1 ad
604 1.1 ad ms->ms_size = size;
605 1.1 ad ms->ms_raidlevel = mes[i].sd_raidlevel & 0xf;
606 1.1 ad ms->ms_state = mes[i].sd_state;
607 1.1 ad ms->ms_dv = NULL;
608 1.1 ad
609 1.10 ad if (i >= mlx->mlx_numsysdrives)
610 1.10 ad continue;
611 1.1 ad if (size == 0xffffffffU || size == 0)
612 1.1 ad continue;
613 1.1 ad
614 1.1 ad /*
615 1.1 ad * Attach a new device.
616 1.1 ad */
617 1.1 ad mlxa.mlxa_unit = i;
618 1.30 drochner
619 1.35 drochner locs[MLXCF_UNIT] = i;
620 1.30 drochner
621 1.35 drochner ms->ms_dv = config_found_sm_loc(&mlx->mlx_dv, "mlx", locs,
622 1.36 drochner &mlxa, mlx_print, config_stdsubmatch);
623 1.6 ad nunits += (ms->ms_dv != NULL);
624 1.1 ad }
625 1.1 ad
626 1.1 ad free(mes, M_DEVBUF);
627 1.6 ad
628 1.6 ad if (nunits != 0)
629 1.6 ad mlx_adjqparam(mlx, mlx->mlx_max_queuecnt / nunits,
630 1.6 ad mlx->mlx_max_queuecnt % nunits);
631 1.12 ad out:
632 1.12 ad mlx->mlx_flags &= ~MLXF_RESCANNING;
633 1.1 ad }
634 1.1 ad
635 1.1 ad /*
636 1.1 ad * Print autoconfiguration message for a sub-device.
637 1.1 ad */
638 1.1 ad static int
639 1.1 ad mlx_print(void *aux, const char *pnp)
640 1.1 ad {
641 1.1 ad struct mlx_attach_args *mlxa;
642 1.1 ad
643 1.1 ad mlxa = (struct mlx_attach_args *)aux;
644 1.1 ad
645 1.1 ad if (pnp != NULL)
646 1.26 thorpej aprint_normal("block device at %s", pnp);
647 1.26 thorpej aprint_normal(" unit %d", mlxa->mlxa_unit);
648 1.1 ad return (UNCONF);
649 1.1 ad }
650 1.1 ad
651 1.1 ad /*
652 1.1 ad * Shut down all configured `mlx' devices.
653 1.1 ad */
654 1.1 ad static void
655 1.48 christos mlx_shutdown(void *cookie)
656 1.1 ad {
657 1.1 ad struct mlx_softc *mlx;
658 1.1 ad int i;
659 1.1 ad
660 1.1 ad for (i = 0; i < mlx_cd.cd_ndevs; i++)
661 1.1 ad if ((mlx = device_lookup(&mlx_cd, i)) != NULL)
662 1.1 ad mlx_flush(mlx, 0);
663 1.1 ad }
664 1.1 ad
665 1.1 ad /*
666 1.1 ad * Adjust queue parameters for all child devices.
667 1.1 ad */
668 1.1 ad static void
669 1.1 ad mlx_adjqparam(struct mlx_softc *mlx, int mpu, int slop)
670 1.1 ad {
671 1.1 ad #if NLD > 0
672 1.1 ad extern struct cfdriver ld_cd;
673 1.1 ad struct ld_softc *ld;
674 1.1 ad int i;
675 1.1 ad
676 1.1 ad for (i = 0; i < ld_cd.cd_ndevs; i++) {
677 1.1 ad if ((ld = device_lookup(&ld_cd, i)) == NULL)
678 1.1 ad continue;
679 1.39 thorpej if (device_parent(&ld->sc_dv) != &mlx->mlx_dv)
680 1.1 ad continue;
681 1.1 ad ldadjqparam(ld, mpu + (slop-- > 0));
682 1.1 ad }
683 1.1 ad #endif
684 1.1 ad }
685 1.1 ad
686 1.1 ad /*
687 1.1 ad * Accept an open operation on the control device.
688 1.1 ad */
689 1.1 ad int
690 1.48 christos mlxopen(dev_t dev, int flag, int mode, struct lwp *l)
691 1.1 ad {
692 1.1 ad struct mlx_softc *mlx;
693 1.1 ad
694 1.1 ad if ((mlx = device_lookup(&mlx_cd, minor(dev))) == NULL)
695 1.1 ad return (ENXIO);
696 1.1 ad if ((mlx->mlx_flags & MLXF_INITOK) == 0)
697 1.1 ad return (ENXIO);
698 1.1 ad if ((mlx->mlx_flags & MLXF_OPEN) != 0)
699 1.1 ad return (EBUSY);
700 1.1 ad
701 1.1 ad mlx->mlx_flags |= MLXF_OPEN;
702 1.1 ad return (0);
703 1.1 ad }
704 1.1 ad
705 1.1 ad /*
706 1.1 ad * Accept the last close on the control device.
707 1.1 ad */
708 1.1 ad int
709 1.48 christos mlxclose(dev_t dev, int flag, int mode,
710 1.48 christos struct lwp *l)
711 1.1 ad {
712 1.1 ad struct mlx_softc *mlx;
713 1.1 ad
714 1.1 ad mlx = device_lookup(&mlx_cd, minor(dev));
715 1.1 ad mlx->mlx_flags &= ~MLXF_OPEN;
716 1.1 ad return (0);
717 1.1 ad }
718 1.1 ad
719 1.1 ad /*
720 1.1 ad * Handle control operations.
721 1.1 ad */
722 1.1 ad int
723 1.51 christos mlxioctl(dev_t dev, u_long cmd, void *data, int flag,
724 1.48 christos struct lwp *l)
725 1.1 ad {
726 1.1 ad struct mlx_softc *mlx;
727 1.1 ad struct mlx_rebuild_request *rb;
728 1.1 ad struct mlx_rebuild_status *rs;
729 1.1 ad struct mlx_pause *mp;
730 1.1 ad struct mlx_sysdrive *ms;
731 1.1 ad int i, rv, *arg, result;
732 1.1 ad
733 1.1 ad mlx = device_lookup(&mlx_cd, minor(dev));
734 1.1 ad
735 1.1 ad rb = (struct mlx_rebuild_request *)data;
736 1.1 ad rs = (struct mlx_rebuild_status *)data;
737 1.1 ad arg = (int *)data;
738 1.1 ad rv = 0;
739 1.1 ad
740 1.1 ad switch (cmd) {
741 1.1 ad case MLX_RESCAN_DRIVES:
742 1.1 ad /*
743 1.1 ad * Scan the controller to see whether new drives have
744 1.1 ad * appeared, or old ones disappeared.
745 1.1 ad */
746 1.1 ad mlx_configure(mlx, 1);
747 1.1 ad return (0);
748 1.1 ad
749 1.1 ad case MLX_PAUSE_CHANNEL:
750 1.1 ad /*
751 1.1 ad * Pause one or more SCSI channels for a period of time, to
752 1.1 ad * assist in the process of hot-swapping devices.
753 1.1 ad *
754 1.1 ad * Note that at least the 3.51 firmware on the DAC960PL
755 1.1 ad * doesn't seem to do this right.
756 1.1 ad */
757 1.1 ad if ((mlx->mlx_flags & MLXF_PAUSEWORKS) == 0)
758 1.1 ad return (EOPNOTSUPP);
759 1.1 ad
760 1.1 ad mp = (struct mlx_pause *)data;
761 1.1 ad
762 1.1 ad if ((mp->mp_which == MLX_PAUSE_CANCEL) &&
763 1.1 ad (mlx->mlx_pause.mp_when != 0)) {
764 1.1 ad /* Cancel a pending pause operation. */
765 1.1 ad mlx->mlx_pause.mp_which = 0;
766 1.1 ad break;
767 1.1 ad }
768 1.1 ad
769 1.1 ad /* Fix for legal channels. */
770 1.18 ad mp->mp_which &= ((1 << mlx->mlx_ci.ci_nchan) -1);
771 1.1 ad
772 1.1 ad /* Check time values. */
773 1.1 ad if (mp->mp_when < 0 || mp->mp_when > 3600 ||
774 1.1 ad mp->mp_howlong < 1 || mp->mp_howlong > (0xf * 30)) {
775 1.1 ad rv = EINVAL;
776 1.1 ad break;
777 1.1 ad }
778 1.1 ad
779 1.1 ad /* Check for a pause currently running. */
780 1.1 ad if ((mlx->mlx_pause.mp_which != 0) &&
781 1.1 ad (mlx->mlx_pause.mp_when == 0)) {
782 1.1 ad rv = EBUSY;
783 1.1 ad break;
784 1.1 ad }
785 1.1 ad
786 1.1 ad /* Looks ok, go with it. */
787 1.1 ad mlx->mlx_pause.mp_which = mp->mp_which;
788 1.43 kardel mlx->mlx_pause.mp_when = time_second + mp->mp_when;
789 1.1 ad mlx->mlx_pause.mp_howlong =
790 1.1 ad mlx->mlx_pause.mp_when + mp->mp_howlong;
791 1.1 ad
792 1.1 ad return (0);
793 1.1 ad
794 1.1 ad case MLX_COMMAND:
795 1.49 elad rv = kauth_authorize_device_passthru(l->l_cred, dev,
796 1.49 elad KAUTH_REQ_DEVICE_RAWIO_PASSTHRU_ALL, data);
797 1.47 elad if (rv)
798 1.47 elad return (rv);
799 1.44 christos
800 1.1 ad /*
801 1.1 ad * Accept a command passthrough-style.
802 1.1 ad */
803 1.1 ad return (mlx_user_command(mlx, (struct mlx_usercommand *)data));
804 1.1 ad
805 1.1 ad case MLX_REBUILDASYNC:
806 1.1 ad /*
807 1.1 ad * Start a rebuild on a given SCSI disk
808 1.1 ad */
809 1.1 ad if (mlx->mlx_bg != 0) {
810 1.1 ad rb->rr_status = 0x0106;
811 1.1 ad rv = EBUSY;
812 1.1 ad break;
813 1.1 ad }
814 1.1 ad
815 1.1 ad rb->rr_status = mlx_rebuild(mlx, rb->rr_channel, rb->rr_target);
816 1.1 ad switch (rb->rr_status) {
817 1.1 ad case 0:
818 1.1 ad rv = 0;
819 1.1 ad break;
820 1.1 ad case 0x10000:
821 1.1 ad rv = ENOMEM; /* Couldn't set up the command. */
822 1.1 ad break;
823 1.32 perry case 0x0002:
824 1.1 ad rv = EBUSY;
825 1.1 ad break;
826 1.1 ad case 0x0104:
827 1.1 ad rv = EIO;
828 1.1 ad break;
829 1.1 ad case 0x0105:
830 1.1 ad rv = ERANGE;
831 1.1 ad break;
832 1.1 ad case 0x0106:
833 1.1 ad rv = EBUSY;
834 1.1 ad break;
835 1.1 ad default:
836 1.1 ad rv = EINVAL;
837 1.1 ad break;
838 1.1 ad }
839 1.1 ad
840 1.1 ad if (rv == 0)
841 1.1 ad mlx->mlx_bg = MLX_BG_REBUILD;
842 1.1 ad
843 1.1 ad return (0);
844 1.1 ad
845 1.1 ad case MLX_REBUILDSTAT:
846 1.1 ad /*
847 1.1 ad * Get the status of the current rebuild or consistency check.
848 1.1 ad */
849 1.1 ad *rs = mlx->mlx_rebuildstat;
850 1.1 ad return (0);
851 1.1 ad
852 1.1 ad case MLX_GET_SYSDRIVE:
853 1.1 ad /*
854 1.1 ad * Return the system drive number matching the `ld' device
855 1.1 ad * unit in (arg), if it happens to belong to us.
856 1.1 ad */
857 1.1 ad for (i = 0; i < MLX_MAX_DRIVES; i++) {
858 1.1 ad ms = &mlx->mlx_sysdrive[i];
859 1.1 ad if (ms->ms_dv != NULL)
860 1.54 cegger if (device_xname(ms->ms_dv)[2] == '0' + *arg) {
861 1.16 ad *arg = i;
862 1.16 ad return (0);
863 1.16 ad }
864 1.1 ad }
865 1.1 ad return (ENOENT);
866 1.19 ad
867 1.19 ad case MLX_GET_CINFO:
868 1.19 ad /*
869 1.19 ad * Return controller info.
870 1.19 ad */
871 1.19 ad memcpy(arg, &mlx->mlx_ci, sizeof(mlx->mlx_ci));
872 1.19 ad return (0);
873 1.1 ad }
874 1.1 ad
875 1.1 ad switch (cmd) {
876 1.1 ad case MLXD_DETACH:
877 1.1 ad case MLXD_STATUS:
878 1.1 ad case MLXD_CHECKASYNC:
879 1.1 ad if ((u_int)*arg >= MLX_MAX_DRIVES)
880 1.1 ad return (EINVAL);
881 1.1 ad ms = &mlx->mlx_sysdrive[*arg];
882 1.1 ad if (*arg > MLX_MAX_DRIVES || ms->ms_dv == NULL)
883 1.1 ad return (ENOENT);
884 1.1 ad break;
885 1.1 ad
886 1.1 ad default:
887 1.1 ad return (ENOTTY);
888 1.1 ad }
889 1.1 ad
890 1.1 ad switch (cmd) {
891 1.1 ad case MLXD_DETACH:
892 1.1 ad /*
893 1.32 perry * Disconnect from the specified drive; it may be about to go
894 1.1 ad * away.
895 1.1 ad */
896 1.1 ad return (config_detach(ms->ms_dv, 0));
897 1.1 ad
898 1.1 ad case MLXD_STATUS:
899 1.1 ad /*
900 1.1 ad * Return the current status of this drive.
901 1.1 ad */
902 1.1 ad *arg = ms->ms_state;
903 1.1 ad return (0);
904 1.1 ad
905 1.1 ad case MLXD_CHECKASYNC:
906 1.1 ad /*
907 1.1 ad * Start a background consistency check on this drive.
908 1.1 ad */
909 1.1 ad if (mlx->mlx_bg != 0) {
910 1.1 ad *arg = 0x0106;
911 1.1 ad return (EBUSY);
912 1.1 ad }
913 1.1 ad
914 1.1 ad switch (result = mlx_check(mlx, *arg)) {
915 1.1 ad case 0:
916 1.1 ad rv = 0;
917 1.1 ad break;
918 1.1 ad case 0x10000:
919 1.1 ad rv = ENOMEM; /* Couldn't set up the command. */
920 1.1 ad break;
921 1.32 perry case 0x0002:
922 1.1 ad rv = EIO;
923 1.1 ad break;
924 1.1 ad case 0x0105:
925 1.1 ad rv = ERANGE;
926 1.1 ad break;
927 1.1 ad case 0x0106:
928 1.1 ad rv = EBUSY;
929 1.1 ad break;
930 1.1 ad default:
931 1.1 ad rv = EINVAL;
932 1.1 ad break;
933 1.1 ad }
934 1.1 ad
935 1.1 ad if (rv == 0)
936 1.1 ad mlx->mlx_bg = MLX_BG_CHECK;
937 1.1 ad *arg = result;
938 1.1 ad return (rv);
939 1.1 ad }
940 1.1 ad
941 1.1 ad return (ENOTTY); /* XXX shut up gcc */
942 1.1 ad }
943 1.1 ad
944 1.1 ad static void
945 1.48 christos mlx_periodic_thread(void *cookie)
946 1.1 ad {
947 1.1 ad struct mlx_softc *mlx;
948 1.1 ad int i;
949 1.1 ad
950 1.1 ad for (;;) {
951 1.1 ad for (i = 0; i < mlx_cd.cd_ndevs; i++)
952 1.1 ad if ((mlx = device_lookup(&mlx_cd, i)) != NULL)
953 1.18 ad if (mlx->mlx_ci.ci_iftype > 1)
954 1.18 ad mlx_periodic(mlx);
955 1.1 ad
956 1.21 ad tsleep(mlx_periodic_thread, PWAIT, "mlxzzz", hz * 2);
957 1.1 ad }
958 1.1 ad }
959 1.1 ad
960 1.1 ad static void
961 1.1 ad mlx_periodic(struct mlx_softc *mlx)
962 1.1 ad {
963 1.1 ad struct mlx_ccb *mc, *nmc;
964 1.1 ad int etype, s;
965 1.1 ad
966 1.1 ad if ((mlx->mlx_pause.mp_which != 0) &&
967 1.1 ad (mlx->mlx_pause.mp_when > 0) &&
968 1.43 kardel (time_second >= mlx->mlx_pause.mp_when)) {
969 1.1 ad /*
970 1.1 ad * Start bus pause.
971 1.1 ad */
972 1.1 ad mlx_pause_action(mlx);
973 1.1 ad mlx->mlx_pause.mp_when = 0;
974 1.1 ad } else if ((mlx->mlx_pause.mp_which != 0) &&
975 1.1 ad (mlx->mlx_pause.mp_when == 0)) {
976 1.1 ad /*
977 1.1 ad * Stop pause if required.
978 1.1 ad */
979 1.43 kardel if (time_second >= mlx->mlx_pause.mp_howlong) {
980 1.1 ad mlx_pause_action(mlx);
981 1.1 ad mlx->mlx_pause.mp_which = 0;
982 1.1 ad }
983 1.43 kardel } else if (time_second > (mlx->mlx_lastpoll + 10)) {
984 1.32 perry /*
985 1.1 ad * Run normal periodic activities...
986 1.1 ad */
987 1.43 kardel mlx->mlx_lastpoll = time_second;
988 1.1 ad
989 1.32 perry /*
990 1.1 ad * Check controller status.
991 1.1 ad */
992 1.1 ad if ((mlx->mlx_flags & MLXF_PERIODIC_CTLR) == 0) {
993 1.1 ad mlx->mlx_flags |= MLXF_PERIODIC_CTLR;
994 1.1 ad
995 1.18 ad if (mlx->mlx_ci.ci_iftype <= 2)
996 1.1 ad etype = MLX_CMD_ENQUIRY_OLD;
997 1.1 ad else
998 1.1 ad etype = MLX_CMD_ENQUIRY;
999 1.1 ad
1000 1.1 ad mlx_enquire(mlx, etype, max(sizeof(struct mlx_enquiry),
1001 1.1 ad sizeof(struct mlx_enquiry_old)),
1002 1.1 ad mlx_periodic_enquiry, 1);
1003 1.1 ad }
1004 1.1 ad
1005 1.1 ad /*
1006 1.1 ad * Check system drive status.
1007 1.1 ad */
1008 1.1 ad if ((mlx->mlx_flags & MLXF_PERIODIC_DRIVE) == 0) {
1009 1.1 ad mlx->mlx_flags |= MLXF_PERIODIC_DRIVE;
1010 1.1 ad mlx_enquire(mlx, MLX_CMD_ENQSYSDRIVE,
1011 1.1 ad sizeof(struct mlx_enq_sys_drive) * MLX_MAX_DRIVES,
1012 1.1 ad mlx_periodic_enquiry, 1);
1013 1.1 ad }
1014 1.1 ad }
1015 1.1 ad
1016 1.1 ad /*
1017 1.1 ad * Get drive rebuild/check status.
1018 1.1 ad */
1019 1.1 ad if ((mlx->mlx_flags & MLXF_PERIODIC_REBUILD) == 0) {
1020 1.1 ad mlx->mlx_flags |= MLXF_PERIODIC_REBUILD;
1021 1.1 ad mlx_enquire(mlx, MLX_CMD_REBUILDSTAT,
1022 1.1 ad sizeof(struct mlx_rebuild_stat), mlx_periodic_rebuild, 1);
1023 1.1 ad }
1024 1.1 ad
1025 1.1 ad /*
1026 1.1 ad * Time-out busy CCBs.
1027 1.1 ad */
1028 1.1 ad s = splbio();
1029 1.1 ad for (mc = TAILQ_FIRST(&mlx->mlx_ccb_worklist); mc != NULL; mc = nmc) {
1030 1.1 ad nmc = TAILQ_NEXT(mc, mc_chain.tailq);
1031 1.43 kardel if (mc->mc_expiry > time_second) {
1032 1.1 ad /*
1033 1.1 ad * The remaining CCBs will expire after this one, so
1034 1.1 ad * there's no point in going further.
1035 1.1 ad */
1036 1.1 ad break;
1037 1.1 ad }
1038 1.32 perry TAILQ_REMOVE(&mlx->mlx_ccb_worklist, mc, mc_chain.tailq);
1039 1.1 ad mc->mc_status = MLX_STATUS_LOST;
1040 1.1 ad if (mc->mc_mx.mx_handler != NULL)
1041 1.1 ad (*mc->mc_mx.mx_handler)(mc);
1042 1.1 ad else if ((mc->mc_flags & MC_WAITING) != 0)
1043 1.1 ad wakeup(mc);
1044 1.1 ad }
1045 1.1 ad splx(s);
1046 1.1 ad }
1047 1.1 ad
1048 1.1 ad /*
1049 1.1 ad * Handle the result of an ENQUIRY command instigated by periodic status
1050 1.1 ad * polling.
1051 1.1 ad */
1052 1.1 ad static void
1053 1.1 ad mlx_periodic_enquiry(struct mlx_ccb *mc)
1054 1.1 ad {
1055 1.1 ad struct mlx_softc *mlx;
1056 1.1 ad struct mlx_enquiry *me;
1057 1.1 ad struct mlx_enquiry_old *meo;
1058 1.1 ad struct mlx_enq_sys_drive *mes;
1059 1.1 ad struct mlx_sysdrive *dr;
1060 1.1 ad const char *statestr;
1061 1.1 ad int i, j;
1062 1.1 ad u_int lsn;
1063 1.1 ad
1064 1.1 ad mlx = (struct mlx_softc *)mc->mc_mx.mx_dv;
1065 1.34 mhitch mlx_ccb_unmap(mlx, mc);
1066 1.1 ad
1067 1.1 ad /*
1068 1.1 ad * Command completed OK?
1069 1.1 ad */
1070 1.1 ad if (mc->mc_status != 0) {
1071 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "periodic enquiry failed - %s\n",
1072 1.54 cegger mlx_ccb_diagnose(mc));
1073 1.1 ad goto out;
1074 1.1 ad }
1075 1.1 ad
1076 1.1 ad /*
1077 1.1 ad * Respond to command.
1078 1.1 ad */
1079 1.1 ad switch (mc->mc_mbox[0]) {
1080 1.1 ad case MLX_CMD_ENQUIRY_OLD:
1081 1.1 ad /*
1082 1.1 ad * This is currently a bit fruitless, as we don't know how
1083 1.1 ad * to extract the eventlog pointer yet.
1084 1.1 ad */
1085 1.1 ad me = (struct mlx_enquiry *)mc->mc_mx.mx_context;
1086 1.1 ad meo = (struct mlx_enquiry_old *)mc->mc_mx.mx_context;
1087 1.1 ad
1088 1.1 ad /* Convert data in-place to new format */
1089 1.1 ad i = sizeof(me->me_dead) / sizeof(me->me_dead[0]);
1090 1.1 ad while (--i >= 0) {
1091 1.1 ad me->me_dead[i].dd_chan = meo->me_dead[i].dd_chan;
1092 1.1 ad me->me_dead[i].dd_targ = meo->me_dead[i].dd_targ;
1093 1.1 ad }
1094 1.1 ad
1095 1.1 ad me->me_misc_flags = 0;
1096 1.1 ad me->me_rebuild_count = meo->me_rebuild_count;
1097 1.1 ad me->me_dead_count = meo->me_dead_count;
1098 1.1 ad me->me_critical_sd_count = meo->me_critical_sd_count;
1099 1.1 ad me->me_event_log_seq_num = 0;
1100 1.1 ad me->me_offline_sd_count = meo->me_offline_sd_count;
1101 1.1 ad me->me_max_commands = meo->me_max_commands;
1102 1.1 ad me->me_rebuild_flag = meo->me_rebuild_flag;
1103 1.1 ad me->me_fwmajor = meo->me_fwmajor;
1104 1.1 ad me->me_fwminor = meo->me_fwminor;
1105 1.1 ad me->me_status_flags = meo->me_status_flags;
1106 1.1 ad me->me_flash_age = meo->me_flash_age;
1107 1.1 ad
1108 1.1 ad i = sizeof(me->me_drvsize) / sizeof(me->me_drvsize[0]);
1109 1.1 ad j = sizeof(meo->me_drvsize) / sizeof(meo->me_drvsize[0]);
1110 1.1 ad
1111 1.1 ad while (--i >= 0) {
1112 1.1 ad if (i >= j)
1113 1.1 ad me->me_drvsize[i] = 0;
1114 1.1 ad else
1115 1.1 ad me->me_drvsize[i] = meo->me_drvsize[i];
1116 1.1 ad }
1117 1.1 ad
1118 1.1 ad me->me_num_sys_drvs = meo->me_num_sys_drvs;
1119 1.1 ad
1120 1.1 ad /* FALLTHROUGH */
1121 1.1 ad
1122 1.1 ad case MLX_CMD_ENQUIRY:
1123 1.1 ad /*
1124 1.1 ad * Generic controller status update. We could do more with
1125 1.1 ad * this than just checking the event log.
1126 1.1 ad */
1127 1.1 ad me = (struct mlx_enquiry *)mc->mc_mx.mx_context;
1128 1.1 ad lsn = le16toh(me->me_event_log_seq_num);
1129 1.1 ad
1130 1.1 ad if (mlx->mlx_currevent == -1) {
1131 1.1 ad /* Initialise our view of the event log. */
1132 1.1 ad mlx->mlx_currevent = lsn;
1133 1.1 ad mlx->mlx_lastevent = lsn;
1134 1.1 ad } else if (lsn != mlx->mlx_lastevent &&
1135 1.1 ad (mlx->mlx_flags & MLXF_EVENTLOG_BUSY) == 0) {
1136 1.1 ad /* Record where current events are up to */
1137 1.1 ad mlx->mlx_currevent = lsn;
1138 1.1 ad
1139 1.1 ad /* Mark the event log as busy. */
1140 1.1 ad mlx->mlx_flags |= MLXF_EVENTLOG_BUSY;
1141 1.1 ad
1142 1.1 ad /* Drain new eventlog entries. */
1143 1.1 ad mlx_periodic_eventlog_poll(mlx);
1144 1.1 ad }
1145 1.1 ad break;
1146 1.1 ad
1147 1.1 ad case MLX_CMD_ENQSYSDRIVE:
1148 1.12 ad /*
1149 1.32 perry * Perform drive status comparison to see if something
1150 1.12 ad * has failed. Don't perform the comparison if we're
1151 1.12 ad * reconfiguring, since the system drive table will be
1152 1.12 ad * changing.
1153 1.12 ad */
1154 1.12 ad if ((mlx->mlx_flags & MLXF_RESCANNING) != 0)
1155 1.12 ad break;
1156 1.12 ad
1157 1.1 ad mes = (struct mlx_enq_sys_drive *)mc->mc_mx.mx_context;
1158 1.1 ad dr = &mlx->mlx_sysdrive[0];
1159 1.1 ad
1160 1.10 ad for (i = 0; i < mlx->mlx_numsysdrives; i++) {
1161 1.1 ad /* Has state been changed by controller? */
1162 1.1 ad if (dr->ms_state != mes[i].sd_state) {
1163 1.1 ad switch (mes[i].sd_state) {
1164 1.1 ad case MLX_SYSD_OFFLINE:
1165 1.1 ad statestr = "offline";
1166 1.1 ad break;
1167 1.1 ad
1168 1.1 ad case MLX_SYSD_ONLINE:
1169 1.1 ad statestr = "online";
1170 1.1 ad break;
1171 1.1 ad
1172 1.1 ad case MLX_SYSD_CRITICAL:
1173 1.1 ad statestr = "critical";
1174 1.10 ad break;
1175 1.32 perry
1176 1.10 ad default:
1177 1.10 ad statestr = "unknown";
1178 1.1 ad break;
1179 1.1 ad }
1180 1.1 ad
1181 1.54 cegger printf("%s: unit %d %s\n", device_xname(&mlx->mlx_dv),
1182 1.1 ad i, statestr);
1183 1.1 ad
1184 1.1 ad /* Save new state. */
1185 1.1 ad dr->ms_state = mes[i].sd_state;
1186 1.1 ad }
1187 1.1 ad }
1188 1.1 ad break;
1189 1.1 ad
1190 1.1 ad #ifdef DIAGNOSTIC
1191 1.1 ad default:
1192 1.1 ad printf("%s: mlx_periodic_enquiry: eh?\n",
1193 1.54 cegger device_xname(&mlx->mlx_dv));
1194 1.1 ad break;
1195 1.1 ad #endif
1196 1.1 ad }
1197 1.1 ad
1198 1.3 ad out:
1199 1.1 ad if (mc->mc_mbox[0] == MLX_CMD_ENQSYSDRIVE)
1200 1.1 ad mlx->mlx_flags &= ~MLXF_PERIODIC_DRIVE;
1201 1.1 ad else
1202 1.1 ad mlx->mlx_flags &= ~MLXF_PERIODIC_CTLR;
1203 1.1 ad
1204 1.1 ad free(mc->mc_mx.mx_context, M_DEVBUF);
1205 1.1 ad mlx_ccb_free(mlx, mc);
1206 1.1 ad }
1207 1.1 ad
1208 1.1 ad /*
1209 1.1 ad * Instigate a poll for one event log message on (mlx). We only poll for
1210 1.1 ad * one message at a time, to keep our command usage down.
1211 1.1 ad */
1212 1.1 ad static void
1213 1.1 ad mlx_periodic_eventlog_poll(struct mlx_softc *mlx)
1214 1.1 ad {
1215 1.1 ad struct mlx_ccb *mc;
1216 1.1 ad void *result;
1217 1.1 ad int rv;
1218 1.1 ad
1219 1.1 ad result = NULL;
1220 1.1 ad
1221 1.1 ad if ((rv = mlx_ccb_alloc(mlx, &mc, 1)) != 0)
1222 1.1 ad goto out;
1223 1.1 ad
1224 1.1 ad if ((result = malloc(1024, M_DEVBUF, M_WAITOK)) == NULL) {
1225 1.1 ad rv = ENOMEM;
1226 1.1 ad goto out;
1227 1.1 ad }
1228 1.1 ad if ((rv = mlx_ccb_map(mlx, mc, result, 1024, MC_XFER_IN)) != 0)
1229 1.1 ad goto out;
1230 1.6 ad if (mc->mc_nsgent != 1) {
1231 1.6 ad mlx_ccb_unmap(mlx, mc);
1232 1.6 ad printf("mlx_periodic_eventlog_poll: too many segs\n");
1233 1.6 ad goto out;
1234 1.6 ad }
1235 1.1 ad
1236 1.1 ad /* Build the command to get one log entry. */
1237 1.1 ad mlx_make_type3(mc, MLX_CMD_LOGOP, MLX_LOGOP_GET, 1,
1238 1.1 ad mlx->mlx_lastevent, 0, 0, mc->mc_xfer_phys, 0);
1239 1.1 ad
1240 1.1 ad mc->mc_mx.mx_handler = mlx_periodic_eventlog_respond;
1241 1.1 ad mc->mc_mx.mx_dv = &mlx->mlx_dv;
1242 1.1 ad mc->mc_mx.mx_context = result;
1243 1.1 ad
1244 1.1 ad /* Start the command. */
1245 1.1 ad mlx_ccb_enqueue(mlx, mc);
1246 1.1 ad
1247 1.3 ad out:
1248 1.1 ad if (rv != 0) {
1249 1.1 ad if (mc != NULL)
1250 1.1 ad mlx_ccb_free(mlx, mc);
1251 1.1 ad if (result != NULL)
1252 1.1 ad free(result, M_DEVBUF);
1253 1.1 ad }
1254 1.1 ad }
1255 1.1 ad
1256 1.1 ad /*
1257 1.1 ad * Handle the result of polling for a log message, generate diagnostic
1258 1.1 ad * output. If this wasn't the last message waiting for us, we'll go collect
1259 1.1 ad * another.
1260 1.1 ad */
1261 1.1 ad static void
1262 1.1 ad mlx_periodic_eventlog_respond(struct mlx_ccb *mc)
1263 1.1 ad {
1264 1.1 ad struct mlx_softc *mlx;
1265 1.1 ad struct mlx_eventlog_entry *el;
1266 1.1 ad const char *reason;
1267 1.1 ad u_int8_t sensekey, chan, targ;
1268 1.1 ad
1269 1.1 ad mlx = (struct mlx_softc *)mc->mc_mx.mx_dv;
1270 1.1 ad el = mc->mc_mx.mx_context;
1271 1.1 ad mlx_ccb_unmap(mlx, mc);
1272 1.1 ad
1273 1.1 ad mlx->mlx_lastevent++;
1274 1.1 ad
1275 1.1 ad if (mc->mc_status == 0) {
1276 1.1 ad switch (el->el_type) {
1277 1.1 ad case MLX_LOGMSG_SENSE: /* sense data */
1278 1.1 ad sensekey = el->el_sense & 0x0f;
1279 1.1 ad chan = (el->el_target >> 4) & 0x0f;
1280 1.1 ad targ = el->el_target & 0x0f;
1281 1.1 ad
1282 1.1 ad /*
1283 1.1 ad * This is the only sort of message we understand at
1284 1.1 ad * the moment. The tests here are probably
1285 1.1 ad * incomplete.
1286 1.1 ad */
1287 1.1 ad
1288 1.1 ad /*
1289 1.1 ad * Mylex vendor-specific message indicating a drive
1290 1.1 ad * was killed?
1291 1.1 ad */
1292 1.1 ad if (sensekey == 9 && el->el_asc == 0x80) {
1293 1.1 ad if (el->el_asq < sizeof(mlx_sense_msgs) /
1294 1.1 ad sizeof(mlx_sense_msgs[0]))
1295 1.1 ad reason = mlx_sense_msgs[el->el_asq];
1296 1.1 ad else
1297 1.1 ad reason = "for unknown reason";
1298 1.1 ad
1299 1.1 ad printf("%s: physical drive %d:%d killed %s\n",
1300 1.54 cegger device_xname(&mlx->mlx_dv), chan, targ, reason);
1301 1.1 ad }
1302 1.1 ad
1303 1.1 ad /*
1304 1.1 ad * SCSI drive was reset?
1305 1.1 ad */
1306 1.1 ad if (sensekey == 6 && el->el_asc == 0x29)
1307 1.1 ad printf("%s: physical drive %d:%d reset\n",
1308 1.54 cegger device_xname(&mlx->mlx_dv), chan, targ);
1309 1.1 ad
1310 1.1 ad /*
1311 1.1 ad * SCSI drive error?
1312 1.1 ad */
1313 1.1 ad if (!(sensekey == 0 ||
1314 1.1 ad (sensekey == 2 &&
1315 1.1 ad el->el_asc == 0x04 &&
1316 1.1 ad (el->el_asq == 0x01 || el->el_asq == 0x02)))) {
1317 1.1 ad printf("%s: physical drive %d:%d error log: "
1318 1.1 ad "sense = %d asc = %x asq = %x\n",
1319 1.54 cegger device_xname(&mlx->mlx_dv), chan, targ, sensekey,
1320 1.1 ad el->el_asc, el->el_asq);
1321 1.1 ad printf("%s: info = %d:%d:%d:%d "
1322 1.12 ad " csi = %d:%d:%d:%d\n",
1323 1.54 cegger device_xname(&mlx->mlx_dv),
1324 1.12 ad el->el_information[0],
1325 1.12 ad el->el_information[1],
1326 1.12 ad el->el_information[2],
1327 1.12 ad el->el_information[3],
1328 1.1 ad el->el_csi[0], el->el_csi[1],
1329 1.1 ad el->el_csi[2], el->el_csi[3]);
1330 1.1 ad }
1331 1.1 ad
1332 1.1 ad break;
1333 1.32 perry
1334 1.1 ad default:
1335 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "unknown log message type 0x%x\n",
1336 1.54 cegger el->el_type);
1337 1.1 ad break;
1338 1.1 ad }
1339 1.1 ad } else {
1340 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "error reading message log - %s\n",
1341 1.54 cegger mlx_ccb_diagnose(mc));
1342 1.1 ad
1343 1.1 ad /*
1344 1.1 ad * Give up on all the outstanding messages, as we may have
1345 1.1 ad * come unsynched.
1346 1.1 ad */
1347 1.1 ad mlx->mlx_lastevent = mlx->mlx_currevent;
1348 1.1 ad }
1349 1.1 ad
1350 1.1 ad free(mc->mc_mx.mx_context, M_DEVBUF);
1351 1.1 ad mlx_ccb_free(mlx, mc);
1352 1.1 ad
1353 1.1 ad /*
1354 1.1 ad * Is there another message to obtain?
1355 1.1 ad */
1356 1.1 ad if (mlx->mlx_lastevent != mlx->mlx_currevent)
1357 1.1 ad mlx_periodic_eventlog_poll(mlx);
1358 1.1 ad else
1359 1.1 ad mlx->mlx_flags &= ~MLXF_EVENTLOG_BUSY;
1360 1.1 ad }
1361 1.1 ad
1362 1.1 ad /*
1363 1.1 ad * Handle check/rebuild operations in progress.
1364 1.1 ad */
1365 1.1 ad static void
1366 1.1 ad mlx_periodic_rebuild(struct mlx_ccb *mc)
1367 1.1 ad {
1368 1.1 ad struct mlx_softc *mlx;
1369 1.1 ad const char *opstr;
1370 1.1 ad struct mlx_rebuild_status *mr;
1371 1.1 ad
1372 1.1 ad mlx = (struct mlx_softc *)mc->mc_mx.mx_dv;
1373 1.1 ad mr = mc->mc_mx.mx_context;
1374 1.1 ad mlx_ccb_unmap(mlx, mc);
1375 1.1 ad
1376 1.1 ad switch (mc->mc_status) {
1377 1.1 ad case 0:
1378 1.1 ad /*
1379 1.1 ad * Operation running, update stats.
1380 1.1 ad */
1381 1.1 ad mlx->mlx_rebuildstat = *mr;
1382 1.1 ad
1383 1.1 ad /* Spontaneous rebuild/check? */
1384 1.1 ad if (mlx->mlx_bg == 0) {
1385 1.1 ad mlx->mlx_bg = MLX_BG_SPONTANEOUS;
1386 1.1 ad printf("%s: background check/rebuild started\n",
1387 1.54 cegger device_xname(&mlx->mlx_dv));
1388 1.1 ad }
1389 1.1 ad break;
1390 1.1 ad
1391 1.1 ad case 0x0105:
1392 1.1 ad /*
1393 1.1 ad * Nothing running, finalise stats and report.
1394 1.1 ad */
1395 1.1 ad switch (mlx->mlx_bg) {
1396 1.1 ad case MLX_BG_CHECK:
1397 1.1 ad /* XXX Print drive? */
1398 1.1 ad opstr = "consistency check";
1399 1.1 ad break;
1400 1.1 ad
1401 1.1 ad case MLX_BG_REBUILD:
1402 1.1 ad /* XXX Print channel:target? */
1403 1.1 ad opstr = "drive rebuild";
1404 1.1 ad break;
1405 1.1 ad
1406 1.1 ad case MLX_BG_SPONTANEOUS:
1407 1.1 ad default:
1408 1.1 ad /*
1409 1.1 ad * If we have previously been non-idle, report the
1410 1.1 ad * transition
1411 1.1 ad */
1412 1.1 ad if (mlx->mlx_rebuildstat.rs_code !=
1413 1.1 ad MLX_REBUILDSTAT_IDLE)
1414 1.1 ad opstr = "background check/rebuild";
1415 1.1 ad else
1416 1.1 ad opstr = NULL;
1417 1.1 ad }
1418 1.1 ad
1419 1.1 ad if (opstr != NULL)
1420 1.54 cegger printf("%s: %s completed\n", device_xname(&mlx->mlx_dv),
1421 1.1 ad opstr);
1422 1.1 ad
1423 1.1 ad mlx->mlx_bg = 0;
1424 1.1 ad mlx->mlx_rebuildstat.rs_code = MLX_REBUILDSTAT_IDLE;
1425 1.1 ad break;
1426 1.1 ad }
1427 1.1 ad
1428 1.1 ad free(mc->mc_mx.mx_context, M_DEVBUF);
1429 1.1 ad mlx_ccb_free(mlx, mc);
1430 1.1 ad mlx->mlx_flags &= ~MLXF_PERIODIC_REBUILD;
1431 1.1 ad }
1432 1.1 ad
1433 1.1 ad /*
1434 1.1 ad * It's time to perform a channel pause action for (mlx), either start or
1435 1.1 ad * stop the pause.
1436 1.1 ad */
1437 1.1 ad static void
1438 1.1 ad mlx_pause_action(struct mlx_softc *mlx)
1439 1.1 ad {
1440 1.1 ad struct mlx_ccb *mc;
1441 1.1 ad int failsafe, i, cmd;
1442 1.1 ad
1443 1.1 ad /* What are we doing here? */
1444 1.1 ad if (mlx->mlx_pause.mp_when == 0) {
1445 1.1 ad cmd = MLX_CMD_STARTCHANNEL;
1446 1.1 ad failsafe = 0;
1447 1.1 ad } else {
1448 1.1 ad cmd = MLX_CMD_STOPCHANNEL;
1449 1.1 ad
1450 1.32 perry /*
1451 1.1 ad * Channels will always start again after the failsafe
1452 1.32 perry * period, which is specified in multiples of 30 seconds.
1453 1.1 ad * This constrains us to a maximum pause of 450 seconds.
1454 1.1 ad */
1455 1.43 kardel failsafe = ((mlx->mlx_pause.mp_howlong - time_second) + 5) / 30;
1456 1.1 ad
1457 1.1 ad if (failsafe > 0xf) {
1458 1.1 ad failsafe = 0xf;
1459 1.43 kardel mlx->mlx_pause.mp_howlong =
1460 1.43 kardel time_second + (0xf * 30) - 5;
1461 1.1 ad }
1462 1.1 ad }
1463 1.1 ad
1464 1.1 ad /* Build commands for every channel requested. */
1465 1.18 ad for (i = 0; i < mlx->mlx_ci.ci_nchan; i++) {
1466 1.1 ad if ((1 << i) & mlx->mlx_pause.mp_which) {
1467 1.1 ad if (mlx_ccb_alloc(mlx, &mc, 1) != 0) {
1468 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "%s failed for channel %d\n",
1469 1.1 ad cmd == MLX_CMD_STOPCHANNEL ?
1470 1.1 ad "pause" : "resume", i);
1471 1.1 ad continue;
1472 1.1 ad }
1473 1.1 ad
1474 1.1 ad /* Build the command. */
1475 1.1 ad mlx_make_type2(mc, cmd, (failsafe << 4) | i, 0, 0,
1476 1.1 ad 0, 0, 0, 0, 0);
1477 1.1 ad mc->mc_mx.mx_handler = mlx_pause_done;
1478 1.1 ad mc->mc_mx.mx_dv = &mlx->mlx_dv;
1479 1.1 ad
1480 1.1 ad mlx_ccb_enqueue(mlx, mc);
1481 1.1 ad }
1482 1.1 ad }
1483 1.1 ad }
1484 1.1 ad
1485 1.1 ad static void
1486 1.1 ad mlx_pause_done(struct mlx_ccb *mc)
1487 1.1 ad {
1488 1.1 ad struct mlx_softc *mlx;
1489 1.1 ad int command, channel;
1490 1.1 ad
1491 1.1 ad mlx = (struct mlx_softc *)mc->mc_mx.mx_dv;
1492 1.1 ad command = mc->mc_mbox[0];
1493 1.1 ad channel = mc->mc_mbox[2] & 0xf;
1494 1.1 ad
1495 1.1 ad if (mc->mc_status != 0)
1496 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "%s command failed - %s\n",
1497 1.1 ad command == MLX_CMD_STOPCHANNEL ? "pause" : "resume",
1498 1.1 ad mlx_ccb_diagnose(mc));
1499 1.1 ad else if (command == MLX_CMD_STOPCHANNEL)
1500 1.1 ad printf("%s: channel %d pausing for %ld seconds\n",
1501 1.54 cegger device_xname(&mlx->mlx_dv), channel,
1502 1.43 kardel (long)(mlx->mlx_pause.mp_howlong - time_second));
1503 1.1 ad else
1504 1.54 cegger printf("%s: channel %d resuming\n", device_xname(&mlx->mlx_dv),
1505 1.1 ad channel);
1506 1.1 ad
1507 1.1 ad mlx_ccb_free(mlx, mc);
1508 1.1 ad }
1509 1.1 ad
1510 1.1 ad /*
1511 1.1 ad * Perform an Enquiry command using a type-3 command buffer and a return a
1512 1.1 ad * single linear result buffer. If the completion function is specified, it
1513 1.1 ad * will be called with the completed command (and the result response will
1514 1.1 ad * not be valid until that point). Otherwise, the command will either be
1515 1.1 ad * busy-waited for (interrupts must be blocked), or slept for.
1516 1.1 ad */
1517 1.1 ad static void *
1518 1.1 ad mlx_enquire(struct mlx_softc *mlx, int command, size_t bufsize,
1519 1.1 ad void (*handler)(struct mlx_ccb *mc), int waitok)
1520 1.1 ad {
1521 1.1 ad struct mlx_ccb *mc;
1522 1.1 ad void *result;
1523 1.1 ad int rv, mapped;
1524 1.1 ad
1525 1.1 ad result = NULL;
1526 1.1 ad mapped = 0;
1527 1.1 ad
1528 1.1 ad if ((rv = mlx_ccb_alloc(mlx, &mc, 1)) != 0)
1529 1.1 ad goto out;
1530 1.1 ad
1531 1.1 ad result = malloc(bufsize, M_DEVBUF, waitok ? M_WAITOK : M_NOWAIT);
1532 1.1 ad if (result == NULL) {
1533 1.1 ad printf("mlx_enquire: malloc() failed\n");
1534 1.1 ad goto out;
1535 1.1 ad }
1536 1.1 ad if ((rv = mlx_ccb_map(mlx, mc, result, bufsize, MC_XFER_IN)) != 0)
1537 1.1 ad goto out;
1538 1.1 ad mapped = 1;
1539 1.6 ad if (mc->mc_nsgent != 1) {
1540 1.6 ad printf("mlx_enquire: too many segs\n");
1541 1.6 ad goto out;
1542 1.6 ad }
1543 1.1 ad
1544 1.1 ad /* Build an enquiry command. */
1545 1.1 ad mlx_make_type2(mc, command, 0, 0, 0, 0, 0, 0, mc->mc_xfer_phys, 0);
1546 1.1 ad
1547 1.1 ad /* Do we want a completion callback? */
1548 1.1 ad if (handler != NULL) {
1549 1.1 ad mc->mc_mx.mx_context = result;
1550 1.1 ad mc->mc_mx.mx_dv = &mlx->mlx_dv;
1551 1.1 ad mc->mc_mx.mx_handler = handler;
1552 1.1 ad mlx_ccb_enqueue(mlx, mc);
1553 1.1 ad } else {
1554 1.1 ad /* Run the command in either polled or wait mode. */
1555 1.9 ad if (waitok)
1556 1.9 ad rv = mlx_ccb_wait(mlx, mc);
1557 1.9 ad else
1558 1.9 ad rv = mlx_ccb_poll(mlx, mc, 5000);
1559 1.1 ad }
1560 1.1 ad
1561 1.3 ad out:
1562 1.1 ad /* We got a command, but nobody else will free it. */
1563 1.1 ad if (handler == NULL && mc != NULL) {
1564 1.1 ad if (mapped)
1565 1.1 ad mlx_ccb_unmap(mlx, mc);
1566 1.1 ad mlx_ccb_free(mlx, mc);
1567 1.1 ad }
1568 1.1 ad
1569 1.1 ad /* We got an error, and we allocated a result. */
1570 1.1 ad if (rv != 0 && result != NULL) {
1571 1.42 christos if (mc != NULL)
1572 1.1 ad mlx_ccb_free(mlx, mc);
1573 1.1 ad free(result, M_DEVBUF);
1574 1.1 ad result = NULL;
1575 1.1 ad }
1576 1.1 ad
1577 1.1 ad return (result);
1578 1.1 ad }
1579 1.1 ad
1580 1.1 ad /*
1581 1.1 ad * Perform a Flush command on the nominated controller.
1582 1.1 ad *
1583 1.1 ad * May be called with interrupts enabled or disabled; will not return until
1584 1.1 ad * the flush operation completes or fails.
1585 1.1 ad */
1586 1.1 ad int
1587 1.1 ad mlx_flush(struct mlx_softc *mlx, int async)
1588 1.1 ad {
1589 1.1 ad struct mlx_ccb *mc;
1590 1.1 ad int rv;
1591 1.1 ad
1592 1.1 ad if ((rv = mlx_ccb_alloc(mlx, &mc, 1)) != 0)
1593 1.1 ad goto out;
1594 1.1 ad
1595 1.1 ad /* Build a flush command and fire it off. */
1596 1.1 ad mlx_make_type2(mc, MLX_CMD_FLUSH, 0, 0, 0, 0, 0, 0, 0, 0);
1597 1.1 ad
1598 1.1 ad if (async)
1599 1.1 ad rv = mlx_ccb_wait(mlx, mc);
1600 1.1 ad else
1601 1.1 ad rv = mlx_ccb_poll(mlx, mc, MLX_TIMEOUT * 1000);
1602 1.1 ad if (rv != 0)
1603 1.1 ad goto out;
1604 1.1 ad
1605 1.1 ad /* Command completed OK? */
1606 1.1 ad if (mc->mc_status != 0) {
1607 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "FLUSH failed - %s\n",
1608 1.1 ad mlx_ccb_diagnose(mc));
1609 1.1 ad rv = EIO;
1610 1.1 ad }
1611 1.3 ad out:
1612 1.1 ad if (mc != NULL)
1613 1.1 ad mlx_ccb_free(mlx, mc);
1614 1.1 ad
1615 1.1 ad return (rv);
1616 1.1 ad }
1617 1.1 ad
1618 1.1 ad /*
1619 1.1 ad * Start a background consistency check on (drive).
1620 1.1 ad */
1621 1.1 ad static int
1622 1.1 ad mlx_check(struct mlx_softc *mlx, int drive)
1623 1.1 ad {
1624 1.1 ad struct mlx_ccb *mc;
1625 1.1 ad int rv;
1626 1.1 ad
1627 1.1 ad /* Get ourselves a command buffer. */
1628 1.1 ad rv = 0x10000;
1629 1.1 ad
1630 1.1 ad if (mlx_ccb_alloc(mlx, &mc, 1) != 0)
1631 1.1 ad goto out;
1632 1.1 ad
1633 1.1 ad /* Build a checkasync command, set the "fix it" flag. */
1634 1.1 ad mlx_make_type2(mc, MLX_CMD_CHECKASYNC, 0, 0, 0, 0, 0, drive | 0x80,
1635 1.1 ad 0, 0);
1636 1.1 ad
1637 1.1 ad /* Start the command and wait for it to be returned. */
1638 1.1 ad if (mlx_ccb_wait(mlx, mc) != 0)
1639 1.1 ad goto out;
1640 1.1 ad
1641 1.1 ad /* Command completed OK? */
1642 1.1 ad if (mc->mc_status != 0)
1643 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "CHECK ASYNC failed - %s\n",
1644 1.1 ad mlx_ccb_diagnose(mc));
1645 1.1 ad else
1646 1.1 ad printf("%s: consistency check started",
1647 1.54 cegger device_xname(mlx->mlx_sysdrive[drive].ms_dv));
1648 1.1 ad
1649 1.1 ad rv = mc->mc_status;
1650 1.3 ad out:
1651 1.1 ad if (mc != NULL)
1652 1.1 ad mlx_ccb_free(mlx, mc);
1653 1.1 ad
1654 1.1 ad return (rv);
1655 1.1 ad }
1656 1.1 ad
1657 1.1 ad /*
1658 1.1 ad * Start a background rebuild of the physical drive at (channel),(target).
1659 1.1 ad *
1660 1.1 ad * May be called with interrupts enabled or disabled; will return as soon as
1661 1.1 ad * the operation has started or been refused.
1662 1.1 ad */
1663 1.1 ad static int
1664 1.1 ad mlx_rebuild(struct mlx_softc *mlx, int channel, int target)
1665 1.1 ad {
1666 1.1 ad struct mlx_ccb *mc;
1667 1.1 ad int error;
1668 1.1 ad
1669 1.1 ad error = 0x10000;
1670 1.1 ad if (mlx_ccb_alloc(mlx, &mc, 1) != 0)
1671 1.1 ad goto out;
1672 1.1 ad
1673 1.1 ad /* Build a rebuildasync command, set the "fix it" flag. */
1674 1.1 ad mlx_make_type2(mc, MLX_CMD_REBUILDASYNC, channel, target, 0, 0, 0, 0,
1675 1.1 ad 0, 0);
1676 1.1 ad
1677 1.1 ad /* Start the command and wait for it to be returned. */
1678 1.1 ad if (mlx_ccb_wait(mlx, mc) != 0)
1679 1.1 ad goto out;
1680 1.1 ad
1681 1.1 ad /* Command completed OK? */
1682 1.54 cegger aprint_normal_dev(&mlx->mlx_dv, "");
1683 1.1 ad if (mc->mc_status != 0)
1684 1.1 ad printf("REBUILD ASYNC failed - %s\n", mlx_ccb_diagnose(mc));
1685 1.1 ad else
1686 1.1 ad printf("rebuild started for %d:%d\n", channel, target);
1687 1.1 ad
1688 1.1 ad error = mc->mc_status;
1689 1.1 ad
1690 1.3 ad out:
1691 1.1 ad if (mc != NULL)
1692 1.1 ad mlx_ccb_free(mlx, mc);
1693 1.1 ad
1694 1.1 ad return (error);
1695 1.1 ad }
1696 1.1 ad
1697 1.1 ad /*
1698 1.1 ad * Take a command from user-space and try to run it.
1699 1.1 ad *
1700 1.1 ad * XXX Note that this can't perform very much in the way of error checking,
1701 1.1 ad * XXX and as such, applications _must_ be considered trustworthy.
1702 1.1 ad *
1703 1.1 ad * XXX Commands using S/G for data are not supported.
1704 1.1 ad */
1705 1.1 ad static int
1706 1.1 ad mlx_user_command(struct mlx_softc *mlx, struct mlx_usercommand *mu)
1707 1.1 ad {
1708 1.1 ad struct mlx_ccb *mc;
1709 1.1 ad struct mlx_dcdb *dcdb;
1710 1.1 ad void *kbuf;
1711 1.1 ad int rv, mapped;
1712 1.1 ad
1713 1.1 ad if ((mu->mu_bufdir & ~MU_XFER_MASK) != 0)
1714 1.1 ad return (EINVAL);
1715 1.1 ad
1716 1.1 ad kbuf = NULL;
1717 1.1 ad dcdb = NULL;
1718 1.1 ad mapped = 0;
1719 1.1 ad
1720 1.1 ad /* Get ourselves a command and copy in from user space. */
1721 1.1 ad if ((rv = mlx_ccb_alloc(mlx, &mc, 1)) != 0) {
1722 1.1 ad DPRINTF(("mlx_user_command: mlx_ccb_alloc = %d\n", rv));
1723 1.1 ad goto out;
1724 1.1 ad }
1725 1.1 ad
1726 1.1 ad memcpy(mc->mc_mbox, mu->mu_command, sizeof(mc->mc_mbox));
1727 1.1 ad
1728 1.1 ad /*
1729 1.1 ad * If we need a buffer for data transfer, allocate one and copy in
1730 1.1 ad * its initial contents.
1731 1.1 ad */
1732 1.1 ad if (mu->mu_datasize > 0) {
1733 1.13 jdolecek if (mu->mu_datasize > MAXPHYS)
1734 1.13 jdolecek return (EINVAL);
1735 1.13 jdolecek
1736 1.1 ad kbuf = malloc(mu->mu_datasize, M_DEVBUF, M_WAITOK);
1737 1.1 ad if (kbuf == NULL) {
1738 1.1 ad DPRINTF(("mlx_user_command: malloc = NULL\n"));
1739 1.1 ad rv = ENOMEM;
1740 1.1 ad goto out;
1741 1.1 ad }
1742 1.1 ad
1743 1.1 ad if ((mu->mu_bufdir & MU_XFER_OUT) != 0) {
1744 1.1 ad rv = copyin(mu->mu_buf, kbuf, mu->mu_datasize);
1745 1.1 ad if (rv != 0) {
1746 1.1 ad DPRINTF(("mlx_user_command: copyin = %d\n",
1747 1.1 ad rv));
1748 1.1 ad goto out;
1749 1.1 ad }
1750 1.1 ad }
1751 1.1 ad
1752 1.1 ad /* Map the buffer so the controller can see it. */
1753 1.1 ad rv = mlx_ccb_map(mlx, mc, kbuf, mu->mu_datasize, mu->mu_bufdir);
1754 1.1 ad if (rv != 0) {
1755 1.1 ad DPRINTF(("mlx_user_command: mlx_ccb_map = %d\n", rv));
1756 1.1 ad goto out;
1757 1.1 ad }
1758 1.1 ad if (mc->mc_nsgent > 1) {
1759 1.1 ad DPRINTF(("mlx_user_command: too many s/g entries\n"));
1760 1.1 ad rv = EFBIG;
1761 1.1 ad goto out;
1762 1.1 ad }
1763 1.1 ad mapped = 1;
1764 1.41 christos /*
1765 1.41 christos * If this is a passthrough SCSI command, the DCDB is packed at
1766 1.41 christos * the beginning of the data area. Fix up the DCDB to point to
1767 1.41 christos * the correct physical address and override any bufptr
1768 1.41 christos * supplied by the caller since we know what it's meant to be.
1769 1.41 christos */
1770 1.41 christos if (mc->mc_mbox[0] == MLX_CMD_DIRECT_CDB) {
1771 1.41 christos dcdb = (struct mlx_dcdb *)kbuf;
1772 1.41 christos dcdb->dcdb_physaddr = mc->mc_xfer_phys + sizeof(*dcdb);
1773 1.41 christos mu->mu_bufptr = 8;
1774 1.41 christos }
1775 1.1 ad }
1776 1.1 ad
1777 1.1 ad
1778 1.32 perry /*
1779 1.1 ad * If there's a data buffer, fix up the command's buffer pointer.
1780 1.1 ad */
1781 1.1 ad if (mu->mu_datasize > 0) {
1782 1.1 ad /* Range check the pointer to physical buffer address. */
1783 1.1 ad if (mu->mu_bufptr < 0 ||
1784 1.1 ad mu->mu_bufptr > sizeof(mu->mu_command) - 4) {
1785 1.1 ad DPRINTF(("mlx_user_command: bufptr botch\n"));
1786 1.1 ad rv = EINVAL;
1787 1.1 ad goto out;
1788 1.1 ad }
1789 1.1 ad
1790 1.1 ad mc->mc_mbox[mu->mu_bufptr] = mc->mc_xfer_phys;
1791 1.1 ad mc->mc_mbox[mu->mu_bufptr+1] = mc->mc_xfer_phys >> 8;
1792 1.1 ad mc->mc_mbox[mu->mu_bufptr+2] = mc->mc_xfer_phys >> 16;
1793 1.1 ad mc->mc_mbox[mu->mu_bufptr+3] = mc->mc_xfer_phys >> 24;
1794 1.1 ad }
1795 1.1 ad
1796 1.1 ad /* Submit the command and wait. */
1797 1.1 ad if ((rv = mlx_ccb_wait(mlx, mc)) != 0) {
1798 1.1 ad #ifdef DEBUG
1799 1.1 ad printf("mlx_user_command: mlx_ccb_wait = %d\n", rv);
1800 1.1 ad #endif
1801 1.1 ad }
1802 1.1 ad
1803 1.3 ad out:
1804 1.1 ad if (mc != NULL) {
1805 1.40 christos /* Copy out status and data */
1806 1.40 christos mu->mu_status = mc->mc_status;
1807 1.1 ad if (mapped)
1808 1.1 ad mlx_ccb_unmap(mlx, mc);
1809 1.1 ad mlx_ccb_free(mlx, mc);
1810 1.1 ad }
1811 1.1 ad
1812 1.1 ad if (kbuf != NULL) {
1813 1.1 ad if (mu->mu_datasize > 0 && (mu->mu_bufdir & MU_XFER_IN) != 0) {
1814 1.1 ad rv = copyout(kbuf, mu->mu_buf, mu->mu_datasize);
1815 1.1 ad #ifdef DIAGNOSTIC
1816 1.1 ad if (rv != 0)
1817 1.1 ad printf("mlx_user_command: copyout = %d\n", rv);
1818 1.1 ad #endif
1819 1.1 ad }
1820 1.1 ad }
1821 1.1 ad if (kbuf != NULL)
1822 1.1 ad free(kbuf, M_DEVBUF);
1823 1.1 ad
1824 1.1 ad return (rv);
1825 1.1 ad }
1826 1.1 ad
1827 1.1 ad /*
1828 1.1 ad * Allocate and initialise a CCB.
1829 1.1 ad */
1830 1.1 ad int
1831 1.21 ad mlx_ccb_alloc(struct mlx_softc *mlx, struct mlx_ccb **mcp, int control)
1832 1.1 ad {
1833 1.1 ad struct mlx_ccb *mc;
1834 1.1 ad int s;
1835 1.1 ad
1836 1.1 ad s = splbio();
1837 1.24 ad mc = SLIST_FIRST(&mlx->mlx_ccb_freelist);
1838 1.21 ad if (control) {
1839 1.21 ad if (mlx->mlx_nccbs_ctrl >= MLX_NCCBS_CONTROL) {
1840 1.21 ad splx(s);
1841 1.21 ad *mcp = NULL;
1842 1.21 ad return (EAGAIN);
1843 1.21 ad }
1844 1.21 ad mc->mc_flags |= MC_CONTROL;
1845 1.21 ad mlx->mlx_nccbs_ctrl++;
1846 1.1 ad }
1847 1.1 ad SLIST_REMOVE_HEAD(&mlx->mlx_ccb_freelist, mc_chain.slist);
1848 1.1 ad splx(s);
1849 1.1 ad
1850 1.1 ad *mcp = mc;
1851 1.1 ad return (0);
1852 1.1 ad }
1853 1.1 ad
1854 1.1 ad /*
1855 1.1 ad * Free a CCB.
1856 1.1 ad */
1857 1.1 ad void
1858 1.1 ad mlx_ccb_free(struct mlx_softc *mlx, struct mlx_ccb *mc)
1859 1.1 ad {
1860 1.1 ad int s;
1861 1.1 ad
1862 1.1 ad s = splbio();
1863 1.21 ad if ((mc->mc_flags & MC_CONTROL) != 0)
1864 1.21 ad mlx->mlx_nccbs_ctrl--;
1865 1.1 ad mc->mc_flags = 0;
1866 1.1 ad SLIST_INSERT_HEAD(&mlx->mlx_ccb_freelist, mc, mc_chain.slist);
1867 1.1 ad splx(s);
1868 1.1 ad }
1869 1.1 ad
1870 1.1 ad /*
1871 1.1 ad * If a CCB is specified, enqueue it. Pull CCBs off the software queue in
1872 1.1 ad * the order that they were enqueued and try to submit their mailboxes to
1873 1.1 ad * the controller for execution.
1874 1.1 ad */
1875 1.1 ad void
1876 1.1 ad mlx_ccb_enqueue(struct mlx_softc *mlx, struct mlx_ccb *mc)
1877 1.1 ad {
1878 1.1 ad int s;
1879 1.1 ad
1880 1.1 ad s = splbio();
1881 1.1 ad
1882 1.1 ad if (mc != NULL)
1883 1.1 ad SIMPLEQ_INSERT_TAIL(&mlx->mlx_ccb_queue, mc, mc_chain.simpleq);
1884 1.1 ad
1885 1.1 ad while ((mc = SIMPLEQ_FIRST(&mlx->mlx_ccb_queue)) != NULL) {
1886 1.1 ad if (mlx_ccb_submit(mlx, mc) != 0)
1887 1.1 ad break;
1888 1.17 lukem SIMPLEQ_REMOVE_HEAD(&mlx->mlx_ccb_queue, mc_chain.simpleq);
1889 1.12 ad TAILQ_INSERT_TAIL(&mlx->mlx_ccb_worklist, mc, mc_chain.tailq);
1890 1.1 ad }
1891 1.1 ad
1892 1.1 ad splx(s);
1893 1.1 ad }
1894 1.1 ad
1895 1.1 ad /*
1896 1.1 ad * Map the specified CCB's data buffer onto the bus, and fill the
1897 1.1 ad * scatter-gather list.
1898 1.1 ad */
1899 1.1 ad int
1900 1.1 ad mlx_ccb_map(struct mlx_softc *mlx, struct mlx_ccb *mc, void *data, int size,
1901 1.1 ad int dir)
1902 1.1 ad {
1903 1.1 ad struct mlx_sgentry *sge;
1904 1.1 ad int nsegs, i, rv, sgloff;
1905 1.1 ad bus_dmamap_t xfer;
1906 1.1 ad
1907 1.1 ad xfer = mc->mc_xfer_map;
1908 1.1 ad
1909 1.1 ad rv = bus_dmamap_load(mlx->mlx_dmat, xfer, data, size, NULL,
1910 1.11 thorpej BUS_DMA_NOWAIT | BUS_DMA_STREAMING |
1911 1.11 thorpej ((dir & MC_XFER_IN) ? BUS_DMA_READ : BUS_DMA_WRITE));
1912 1.1 ad if (rv != 0)
1913 1.1 ad return (rv);
1914 1.1 ad
1915 1.1 ad nsegs = xfer->dm_nsegs;
1916 1.1 ad mc->mc_xfer_size = size;
1917 1.1 ad mc->mc_flags |= dir;
1918 1.1 ad mc->mc_nsgent = nsegs;
1919 1.1 ad mc->mc_xfer_phys = xfer->dm_segs[0].ds_addr;
1920 1.1 ad
1921 1.1 ad sgloff = MLX_SGL_SIZE * mc->mc_ident;
1922 1.51 christos sge = (struct mlx_sgentry *)((char *)mlx->mlx_sgls + sgloff);
1923 1.1 ad
1924 1.1 ad for (i = 0; i < nsegs; i++, sge++) {
1925 1.1 ad sge->sge_addr = htole32(xfer->dm_segs[i].ds_addr);
1926 1.1 ad sge->sge_count = htole32(xfer->dm_segs[i].ds_len);
1927 1.1 ad }
1928 1.1 ad
1929 1.1 ad if ((dir & MC_XFER_OUT) != 0)
1930 1.1 ad i = BUS_DMASYNC_PREWRITE;
1931 1.1 ad else
1932 1.1 ad i = 0;
1933 1.1 ad if ((dir & MC_XFER_IN) != 0)
1934 1.1 ad i |= BUS_DMASYNC_PREREAD;
1935 1.1 ad
1936 1.1 ad bus_dmamap_sync(mlx->mlx_dmat, xfer, 0, mc->mc_xfer_size, i);
1937 1.1 ad bus_dmamap_sync(mlx->mlx_dmat, mlx->mlx_dmamap, sgloff,
1938 1.1 ad MLX_SGL_SIZE, BUS_DMASYNC_PREWRITE);
1939 1.1 ad
1940 1.1 ad return (0);
1941 1.1 ad }
1942 1.1 ad
1943 1.1 ad /*
1944 1.1 ad * Unmap the specified CCB's data buffer.
1945 1.1 ad */
1946 1.1 ad void
1947 1.1 ad mlx_ccb_unmap(struct mlx_softc *mlx, struct mlx_ccb *mc)
1948 1.1 ad {
1949 1.1 ad int i;
1950 1.1 ad
1951 1.1 ad bus_dmamap_sync(mlx->mlx_dmat, mlx->mlx_dmamap,
1952 1.1 ad MLX_SGL_SIZE * mc->mc_ident, MLX_SGL_SIZE,
1953 1.1 ad BUS_DMASYNC_POSTWRITE);
1954 1.1 ad
1955 1.1 ad if ((mc->mc_flags & MC_XFER_OUT) != 0)
1956 1.6 ad i = BUS_DMASYNC_POSTWRITE;
1957 1.1 ad else
1958 1.1 ad i = 0;
1959 1.1 ad if ((mc->mc_flags & MC_XFER_IN) != 0)
1960 1.6 ad i |= BUS_DMASYNC_POSTREAD;
1961 1.1 ad
1962 1.1 ad bus_dmamap_sync(mlx->mlx_dmat, mc->mc_xfer_map, 0, mc->mc_xfer_size, i);
1963 1.1 ad bus_dmamap_unload(mlx->mlx_dmat, mc->mc_xfer_map);
1964 1.1 ad }
1965 1.1 ad
1966 1.1 ad /*
1967 1.1 ad * Submit the CCB, and busy-wait for it to complete. Return non-zero on
1968 1.1 ad * timeout or submission error. Must be called with interrupts blocked.
1969 1.1 ad */
1970 1.1 ad int
1971 1.1 ad mlx_ccb_poll(struct mlx_softc *mlx, struct mlx_ccb *mc, int timo)
1972 1.1 ad {
1973 1.1 ad int rv;
1974 1.1 ad
1975 1.1 ad mc->mc_mx.mx_handler = NULL;
1976 1.1 ad
1977 1.1 ad if ((rv = mlx_ccb_submit(mlx, mc)) != 0)
1978 1.1 ad return (rv);
1979 1.32 perry TAILQ_INSERT_TAIL(&mlx->mlx_ccb_worklist, mc, mc_chain.tailq);
1980 1.1 ad
1981 1.1 ad for (timo *= 10; timo != 0; timo--) {
1982 1.1 ad mlx_intr(mlx);
1983 1.1 ad if (mc->mc_status != MLX_STATUS_BUSY)
1984 1.1 ad break;
1985 1.1 ad DELAY(100);
1986 1.1 ad }
1987 1.1 ad
1988 1.1 ad if (timo != 0) {
1989 1.1 ad if (mc->mc_status != 0) {
1990 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "command failed - %s\n",
1991 1.54 cegger mlx_ccb_diagnose(mc));
1992 1.1 ad rv = EIO;
1993 1.1 ad } else
1994 1.1 ad rv = 0;
1995 1.1 ad } else {
1996 1.54 cegger printf("%s: command timed out\n", device_xname(&mlx->mlx_dv));
1997 1.1 ad rv = EIO;
1998 1.1 ad }
1999 1.1 ad
2000 1.1 ad return (rv);
2001 1.1 ad }
2002 1.1 ad
2003 1.1 ad /*
2004 1.1 ad * Enqueue the CCB, and sleep until it completes. Return non-zero on
2005 1.1 ad * timeout or error.
2006 1.1 ad */
2007 1.1 ad int
2008 1.1 ad mlx_ccb_wait(struct mlx_softc *mlx, struct mlx_ccb *mc)
2009 1.1 ad {
2010 1.1 ad int s;
2011 1.1 ad
2012 1.1 ad mc->mc_flags |= MC_WAITING;
2013 1.1 ad mc->mc_mx.mx_handler = NULL;
2014 1.1 ad
2015 1.1 ad s = splbio();
2016 1.1 ad mlx_ccb_enqueue(mlx, mc);
2017 1.1 ad tsleep(mc, PRIBIO, "mlxwccb", 0);
2018 1.1 ad splx(s);
2019 1.1 ad
2020 1.1 ad if (mc->mc_status != 0) {
2021 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "command failed - %s\n",
2022 1.1 ad mlx_ccb_diagnose(mc));
2023 1.1 ad return (EIO);
2024 1.1 ad }
2025 1.1 ad
2026 1.1 ad return (0);
2027 1.1 ad }
2028 1.1 ad
2029 1.1 ad /*
2030 1.1 ad * Try to submit a CCB's mailbox to the controller for execution. Return
2031 1.1 ad * non-zero on timeout or error. Must be called with interrupts blocked.
2032 1.1 ad */
2033 1.1 ad static int
2034 1.1 ad mlx_ccb_submit(struct mlx_softc *mlx, struct mlx_ccb *mc)
2035 1.1 ad {
2036 1.1 ad int i, s, r;
2037 1.1 ad
2038 1.1 ad /* Save the ident so we can handle this command when complete. */
2039 1.21 ad mc->mc_mbox[1] = (u_int8_t)(mc->mc_ident + 1);
2040 1.1 ad
2041 1.1 ad /* Mark the command as currently being processed. */
2042 1.1 ad mc->mc_status = MLX_STATUS_BUSY;
2043 1.43 kardel mc->mc_expiry = time_second + MLX_TIMEOUT;
2044 1.1 ad
2045 1.1 ad /* Spin waiting for the mailbox. */
2046 1.1 ad for (i = 100; i != 0; i--) {
2047 1.1 ad s = splbio();
2048 1.1 ad r = (*mlx->mlx_submit)(mlx, mc);
2049 1.1 ad splx(s);
2050 1.1 ad if (r != 0)
2051 1.1 ad break;
2052 1.1 ad DELAY(100);
2053 1.1 ad }
2054 1.4 ad if (i != 0)
2055 1.1 ad return (0);
2056 1.1 ad
2057 1.1 ad DPRINTF(("mlx_ccb_submit: rejected; queueing\n"));
2058 1.1 ad mc->mc_status = MLX_STATUS_WEDGED;
2059 1.1 ad return (EIO);
2060 1.1 ad }
2061 1.1 ad
2062 1.1 ad /*
2063 1.1 ad * Return a string that describes why a command has failed.
2064 1.1 ad */
2065 1.1 ad const char *
2066 1.1 ad mlx_ccb_diagnose(struct mlx_ccb *mc)
2067 1.1 ad {
2068 1.33 christos static char tbuf[80];
2069 1.1 ad int i;
2070 1.1 ad
2071 1.1 ad for (i = 0; i < sizeof(mlx_msgs) / sizeof(mlx_msgs[0]); i++)
2072 1.1 ad if ((mc->mc_mbox[0] == mlx_msgs[i].command ||
2073 1.1 ad mlx_msgs[i].command == 0) &&
2074 1.1 ad mc->mc_status == mlx_msgs[i].status) {
2075 1.33 christos snprintf(tbuf, sizeof(tbuf), "%s (0x%x)",
2076 1.1 ad mlx_status_msgs[mlx_msgs[i].msg], mc->mc_status);
2077 1.33 christos return (tbuf);
2078 1.1 ad }
2079 1.1 ad
2080 1.33 christos snprintf(tbuf, sizeof(tbuf), "unknown response 0x%x for command 0x%x",
2081 1.1 ad (int)mc->mc_status, (int)mc->mc_mbox[0]);
2082 1.1 ad
2083 1.33 christos return (tbuf);
2084 1.1 ad }
2085 1.1 ad
2086 1.1 ad /*
2087 1.1 ad * Poll the controller for completed commands. Returns non-zero if one or
2088 1.1 ad * more commands were completed. Must be called with interrupts blocked.
2089 1.1 ad */
2090 1.1 ad int
2091 1.1 ad mlx_intr(void *cookie)
2092 1.1 ad {
2093 1.1 ad struct mlx_softc *mlx;
2094 1.1 ad struct mlx_ccb *mc;
2095 1.1 ad int result;
2096 1.1 ad u_int ident, status;
2097 1.1 ad
2098 1.1 ad mlx = cookie;
2099 1.1 ad result = 0;
2100 1.1 ad
2101 1.1 ad while ((*mlx->mlx_findcomplete)(mlx, &ident, &status) != 0) {
2102 1.1 ad result = 1;
2103 1.21 ad ident--;
2104 1.1 ad
2105 1.1 ad if (ident >= MLX_MAX_QUEUECNT) {
2106 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "bad completion returned\n");
2107 1.1 ad continue;
2108 1.1 ad }
2109 1.1 ad
2110 1.1 ad mc = mlx->mlx_ccbs + ident;
2111 1.1 ad
2112 1.1 ad if (mc->mc_status != MLX_STATUS_BUSY) {
2113 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "bad completion returned\n");
2114 1.1 ad continue;
2115 1.1 ad }
2116 1.1 ad
2117 1.32 perry TAILQ_REMOVE(&mlx->mlx_ccb_worklist, mc, mc_chain.tailq);
2118 1.1 ad
2119 1.1 ad /* Record status and notify the initiator, if requested. */
2120 1.1 ad mc->mc_status = status;
2121 1.1 ad if (mc->mc_mx.mx_handler != NULL)
2122 1.1 ad (*mc->mc_mx.mx_handler)(mc);
2123 1.1 ad else if ((mc->mc_flags & MC_WAITING) != 0)
2124 1.1 ad wakeup(mc);
2125 1.1 ad }
2126 1.1 ad
2127 1.1 ad /* If we've completed any commands, try posting some more. */
2128 1.1 ad if (result)
2129 1.1 ad mlx_ccb_enqueue(mlx, NULL);
2130 1.1 ad
2131 1.1 ad return (result);
2132 1.1 ad }
2133 1.1 ad
2134 1.1 ad /*
2135 1.1 ad * Emit a string describing the firmware handshake status code, and return a
2136 1.1 ad * flag indicating whether the code represents a fatal error.
2137 1.1 ad *
2138 1.1 ad * Error code interpretations are from the Linux driver, and don't directly
2139 1.1 ad * match the messages printed by Mylex's BIOS. This may change if
2140 1.1 ad * documentation on the codes is forthcoming.
2141 1.1 ad */
2142 1.1 ad static int
2143 1.1 ad mlx_fw_message(struct mlx_softc *mlx, int error, int param1, int param2)
2144 1.1 ad {
2145 1.1 ad const char *fmt;
2146 1.1 ad
2147 1.1 ad switch (error) {
2148 1.1 ad case 0x00:
2149 1.1 ad fmt = "physical drive %d:%d not responding";
2150 1.1 ad break;
2151 1.1 ad
2152 1.1 ad case 0x08:
2153 1.1 ad /*
2154 1.1 ad * We could be neater about this and give some indication
2155 1.1 ad * when we receive more of them.
2156 1.1 ad */
2157 1.1 ad if ((mlx->mlx_flags & MLXF_SPINUP_REPORTED) == 0) {
2158 1.1 ad printf("%s: spinning up drives...\n",
2159 1.54 cegger device_xname(&mlx->mlx_dv));
2160 1.1 ad mlx->mlx_flags |= MLXF_SPINUP_REPORTED;
2161 1.1 ad }
2162 1.23 kristerw return (0);
2163 1.1 ad
2164 1.1 ad case 0x30:
2165 1.1 ad fmt = "configuration checksum error";
2166 1.1 ad break;
2167 1.1 ad
2168 1.1 ad case 0x60:
2169 1.1 ad fmt = "mirror race recovery failed";
2170 1.1 ad break;
2171 1.1 ad
2172 1.1 ad case 0x70:
2173 1.1 ad fmt = "mirror race recovery in progress";
2174 1.1 ad break;
2175 1.1 ad
2176 1.1 ad case 0x90:
2177 1.1 ad fmt = "physical drive %d:%d COD mismatch";
2178 1.1 ad break;
2179 1.1 ad
2180 1.1 ad case 0xa0:
2181 1.1 ad fmt = "logical drive installation aborted";
2182 1.1 ad break;
2183 1.1 ad
2184 1.1 ad case 0xb0:
2185 1.1 ad fmt = "mirror race on a critical system drive";
2186 1.1 ad break;
2187 1.1 ad
2188 1.1 ad case 0xd0:
2189 1.1 ad fmt = "new controller configuration found";
2190 1.1 ad break;
2191 1.1 ad
2192 1.1 ad case 0xf0:
2193 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "FATAL MEMORY PARITY ERROR\n");
2194 1.1 ad return (1);
2195 1.1 ad
2196 1.1 ad default:
2197 1.54 cegger aprint_error_dev(&mlx->mlx_dv, "unknown firmware init error %02x:%02x:%02x\n",
2198 1.54 cegger error, param1, param2);
2199 1.1 ad return (0);
2200 1.1 ad }
2201 1.1 ad
2202 1.54 cegger aprint_normal_dev(&mlx->mlx_dv, "");
2203 1.54 cegger aprint_normal(fmt, param2, param1);
2204 1.54 cegger aprint_normal("\n");
2205 1.1 ad
2206 1.1 ad return (0);
2207 1.1 ad }
2208