ld_ataraid.c revision 1.26 1 1.26 cegger /* $NetBSD: ld_ataraid.c,v 1.26 2008/04/05 22:04:36 cegger Exp $ */
2 1.1 thorpej
3 1.1 thorpej /*
4 1.1 thorpej * Copyright (c) 2003 Wasabi Systems, Inc.
5 1.1 thorpej * All rights reserved.
6 1.1 thorpej *
7 1.1 thorpej * Written by Jason R. Thorpe for Wasabi Systems, Inc.
8 1.1 thorpej *
9 1.1 thorpej * Redistribution and use in source and binary forms, with or without
10 1.1 thorpej * modification, are permitted provided that the following conditions
11 1.1 thorpej * are met:
12 1.1 thorpej * 1. Redistributions of source code must retain the above copyright
13 1.1 thorpej * notice, this list of conditions and the following disclaimer.
14 1.1 thorpej * 2. Redistributions in binary form must reproduce the above copyright
15 1.1 thorpej * notice, this list of conditions and the following disclaimer in the
16 1.1 thorpej * documentation and/or other materials provided with the distribution.
17 1.1 thorpej * 3. All advertising materials mentioning features or use of this software
18 1.1 thorpej * must display the following acknowledgement:
19 1.1 thorpej * This product includes software developed for the NetBSD Project by
20 1.1 thorpej * Wasabi Systems, Inc.
21 1.1 thorpej * 4. The name of Wasabi Systems, Inc. may not be used to endorse
22 1.1 thorpej * or promote products derived from this software without specific prior
23 1.1 thorpej * written permission.
24 1.1 thorpej *
25 1.1 thorpej * THIS SOFTWARE IS PROVIDED BY WASABI SYSTEMS, INC. ``AS IS'' AND
26 1.1 thorpej * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
27 1.1 thorpej * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
28 1.1 thorpej * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL WASABI SYSTEMS, INC
29 1.1 thorpej * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
30 1.1 thorpej * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
31 1.1 thorpej * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
32 1.1 thorpej * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
33 1.1 thorpej * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
34 1.1 thorpej * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
35 1.1 thorpej * POSSIBILITY OF SUCH DAMAGE.
36 1.1 thorpej */
37 1.1 thorpej
38 1.1 thorpej /*
39 1.1 thorpej * Support for ATA RAID logical disks.
40 1.1 thorpej *
41 1.1 thorpej * Note that all the RAID happens in software here; the ATA RAID
42 1.1 thorpej * controllers we're dealing with (Promise, etc.) only support
43 1.1 thorpej * configuration data on the component disks, with the BIOS supporting
44 1.1 thorpej * booting from the RAID volumes.
45 1.1 thorpej */
46 1.8 lukem
47 1.8 lukem #include <sys/cdefs.h>
48 1.26 cegger __KERNEL_RCSID(0, "$NetBSD: ld_ataraid.c,v 1.26 2008/04/05 22:04:36 cegger Exp $");
49 1.1 thorpej
50 1.1 thorpej #include "rnd.h"
51 1.1 thorpej
52 1.1 thorpej #include <sys/param.h>
53 1.1 thorpej #include <sys/systm.h>
54 1.1 thorpej #include <sys/conf.h>
55 1.1 thorpej #include <sys/kernel.h>
56 1.1 thorpej #include <sys/device.h>
57 1.1 thorpej #include <sys/buf.h>
58 1.13 yamt #include <sys/bufq.h>
59 1.1 thorpej #include <sys/dkio.h>
60 1.1 thorpej #include <sys/disk.h>
61 1.1 thorpej #include <sys/disklabel.h>
62 1.1 thorpej #include <sys/fcntl.h>
63 1.1 thorpej #include <sys/malloc.h>
64 1.1 thorpej #include <sys/vnode.h>
65 1.16 elad #include <sys/kauth.h>
66 1.1 thorpej #if NRND > 0
67 1.1 thorpej #include <sys/rnd.h>
68 1.1 thorpej #endif
69 1.1 thorpej
70 1.1 thorpej #include <miscfs/specfs/specdev.h>
71 1.1 thorpej
72 1.1 thorpej #include <dev/ldvar.h>
73 1.1 thorpej
74 1.1 thorpej #include <dev/ata/ata_raidvar.h>
75 1.1 thorpej
76 1.1 thorpej struct ld_ataraid_softc {
77 1.1 thorpej struct ld_softc sc_ld;
78 1.1 thorpej
79 1.1 thorpej struct ataraid_array_info *sc_aai;
80 1.1 thorpej struct vnode *sc_vnodes[ATA_RAID_MAX_DISKS];
81 1.1 thorpej
82 1.1 thorpej void (*sc_iodone)(struct buf *);
83 1.1 thorpej };
84 1.1 thorpej
85 1.1 thorpej static int ld_ataraid_match(struct device *, struct cfdata *, void *);
86 1.1 thorpej static void ld_ataraid_attach(struct device *, struct device *, void *);
87 1.1 thorpej
88 1.1 thorpej static int ld_ataraid_dump(struct ld_softc *, void *, int, int);
89 1.1 thorpej
90 1.1 thorpej static int ld_ataraid_start_span(struct ld_softc *, struct buf *);
91 1.1 thorpej
92 1.1 thorpej static int ld_ataraid_start_raid0(struct ld_softc *, struct buf *);
93 1.1 thorpej static void ld_ataraid_iodone_raid0(struct buf *);
94 1.1 thorpej
95 1.1 thorpej CFATTACH_DECL(ld_ataraid, sizeof(struct ld_ataraid_softc),
96 1.1 thorpej ld_ataraid_match, ld_ataraid_attach, NULL, NULL);
97 1.1 thorpej
98 1.1 thorpej static int ld_ataraid_initialized;
99 1.1 thorpej static struct pool ld_ataraid_cbufpl;
100 1.1 thorpej
101 1.1 thorpej struct cbuf {
102 1.1 thorpej struct buf cb_buf; /* new I/O buf */
103 1.1 thorpej struct buf *cb_obp; /* ptr. to original I/O buf */
104 1.1 thorpej struct ld_ataraid_softc *cb_sc; /* pointer to ld softc */
105 1.1 thorpej u_int cb_comp; /* target component */
106 1.1 thorpej SIMPLEQ_ENTRY(cbuf) cb_q; /* fifo of component buffers */
107 1.12 enami struct cbuf *cb_other; /* other cbuf in case of mirror */
108 1.12 enami int cb_flags;
109 1.12 enami #define CBUF_IODONE 0x00000001 /* I/O is already successfully done */
110 1.1 thorpej };
111 1.1 thorpej
112 1.1 thorpej #define CBUF_GET() pool_get(&ld_ataraid_cbufpl, PR_NOWAIT);
113 1.1 thorpej #define CBUF_PUT(cbp) pool_put(&ld_ataraid_cbufpl, (cbp))
114 1.1 thorpej
115 1.1 thorpej static int
116 1.18 christos ld_ataraid_match(struct device *parent,
117 1.18 christos struct cfdata *match, void *aux)
118 1.1 thorpej {
119 1.1 thorpej
120 1.1 thorpej return (1);
121 1.1 thorpej }
122 1.1 thorpej
123 1.1 thorpej static void
124 1.18 christos ld_ataraid_attach(struct device *parent, struct device *self,
125 1.17 christos void *aux)
126 1.1 thorpej {
127 1.1 thorpej struct ld_ataraid_softc *sc = (void *) self;
128 1.1 thorpej struct ld_softc *ld = &sc->sc_ld;
129 1.1 thorpej struct ataraid_array_info *aai = aux;
130 1.1 thorpej const char *level;
131 1.1 thorpej struct vnode *vp;
132 1.1 thorpej char unklev[32];
133 1.1 thorpej u_int i;
134 1.1 thorpej
135 1.1 thorpej if (ld_ataraid_initialized == 0) {
136 1.1 thorpej ld_ataraid_initialized = 1;
137 1.1 thorpej pool_init(&ld_ataraid_cbufpl, sizeof(struct cbuf), 0,
138 1.20 ad 0, 0, "ldcbuf", NULL, IPL_BIO);
139 1.1 thorpej }
140 1.1 thorpej
141 1.1 thorpej sc->sc_aai = aai; /* this data persists */
142 1.1 thorpej
143 1.1 thorpej ld->sc_maxxfer = MAXPHYS * aai->aai_width; /* XXX */
144 1.1 thorpej ld->sc_secperunit = aai->aai_capacity;
145 1.1 thorpej ld->sc_secsize = 512; /* XXX */
146 1.1 thorpej ld->sc_maxqueuecnt = 128; /* XXX */
147 1.1 thorpej ld->sc_dump = ld_ataraid_dump;
148 1.1 thorpej
149 1.1 thorpej switch (aai->aai_level) {
150 1.1 thorpej case AAI_L_SPAN:
151 1.1 thorpej level = "SPAN";
152 1.1 thorpej ld->sc_start = ld_ataraid_start_span;
153 1.1 thorpej sc->sc_iodone = ld_ataraid_iodone_raid0;
154 1.1 thorpej break;
155 1.1 thorpej
156 1.1 thorpej case AAI_L_RAID0:
157 1.9 thorpej level = "RAID-0";
158 1.1 thorpej ld->sc_start = ld_ataraid_start_raid0;
159 1.1 thorpej sc->sc_iodone = ld_ataraid_iodone_raid0;
160 1.1 thorpej break;
161 1.1 thorpej
162 1.1 thorpej case AAI_L_RAID1:
163 1.9 thorpej level = "RAID-1";
164 1.12 enami ld->sc_start = ld_ataraid_start_raid0;
165 1.12 enami sc->sc_iodone = ld_ataraid_iodone_raid0;
166 1.1 thorpej break;
167 1.1 thorpej
168 1.1 thorpej case AAI_L_RAID0 | AAI_L_RAID1:
169 1.9 thorpej level = "RAID-10";
170 1.12 enami ld->sc_start = ld_ataraid_start_raid0;
171 1.12 enami sc->sc_iodone = ld_ataraid_iodone_raid0;
172 1.1 thorpej break;
173 1.1 thorpej
174 1.1 thorpej default:
175 1.11 itojun snprintf(unklev, sizeof(unklev), "<unknown level 0x%x>",
176 1.11 itojun aai->aai_level);
177 1.1 thorpej level = unklev;
178 1.1 thorpej }
179 1.1 thorpej
180 1.1 thorpej aprint_naive(": ATA %s array\n", level);
181 1.1 thorpej aprint_normal(": %s ATA %s array\n",
182 1.1 thorpej ata_raid_type_name(aai->aai_type), level);
183 1.1 thorpej
184 1.1 thorpej if (ld->sc_start == NULL) {
185 1.26 cegger aprint_error_dev(&ld->sc_dv, "unsupported array type\n");
186 1.1 thorpej return;
187 1.1 thorpej }
188 1.1 thorpej
189 1.1 thorpej /*
190 1.1 thorpej * We get a geometry from the device; use it.
191 1.1 thorpej */
192 1.1 thorpej ld->sc_nheads = aai->aai_heads;
193 1.1 thorpej ld->sc_nsectors = aai->aai_sectors;
194 1.1 thorpej ld->sc_ncylinders = aai->aai_cylinders;
195 1.1 thorpej
196 1.1 thorpej /*
197 1.1 thorpej * Configure all the component disks.
198 1.1 thorpej */
199 1.1 thorpej for (i = 0; i < aai->aai_ndisks; i++) {
200 1.1 thorpej struct ataraid_disk_info *adi = &aai->aai_disks[i];
201 1.1 thorpej int bmajor, error;
202 1.1 thorpej dev_t dev;
203 1.1 thorpej
204 1.26 cegger bmajor = devsw_name2blk(device_xname(adi->adi_dev), NULL, 0);
205 1.15 thorpej dev = MAKEDISKDEV(bmajor, device_unit(adi->adi_dev), RAW_PART);
206 1.1 thorpej error = bdevvp(dev, &vp);
207 1.1 thorpej if (error)
208 1.3 thorpej break;
209 1.22 pooka error = VOP_OPEN(vp, FREAD|FWRITE, NOCRED);
210 1.1 thorpej if (error) {
211 1.1 thorpej vput(vp);
212 1.1 thorpej /*
213 1.1 thorpej * XXX This is bogus. We should just mark the
214 1.1 thorpej * XXX component as FAILED, and write-back new
215 1.1 thorpej * XXX config blocks.
216 1.1 thorpej */
217 1.3 thorpej break;
218 1.1 thorpej }
219 1.1 thorpej
220 1.1 thorpej VOP_UNLOCK(vp, 0);
221 1.1 thorpej sc->sc_vnodes[i] = vp;
222 1.1 thorpej }
223 1.3 thorpej if (i == aai->aai_ndisks) {
224 1.3 thorpej ld->sc_flags = LDF_ENABLED;
225 1.3 thorpej goto finish;
226 1.3 thorpej }
227 1.1 thorpej
228 1.1 thorpej for (i = 0; i < aai->aai_ndisks; i++) {
229 1.1 thorpej vp = sc->sc_vnodes[i];
230 1.1 thorpej sc->sc_vnodes[i] = NULL;
231 1.3 thorpej if (vp != NULL)
232 1.25 ad (void) vn_close(vp, FREAD|FWRITE, NOCRED);
233 1.1 thorpej }
234 1.3 thorpej
235 1.3 thorpej finish:
236 1.3 thorpej ldattach(ld);
237 1.1 thorpej }
238 1.1 thorpej
239 1.1 thorpej static struct cbuf *
240 1.1 thorpej ld_ataraid_make_cbuf(struct ld_ataraid_softc *sc, struct buf *bp,
241 1.19 christos u_int comp, daddr_t bn, void *addr, long bcount)
242 1.1 thorpej {
243 1.1 thorpej struct cbuf *cbp;
244 1.1 thorpej
245 1.1 thorpej cbp = CBUF_GET();
246 1.1 thorpej if (cbp == NULL)
247 1.1 thorpej return (NULL);
248 1.23 ad buf_init(&cbp->cb_buf);
249 1.23 ad cbp->cb_buf.b_flags = bp->b_flags;
250 1.23 ad cbp->cb_buf.b_oflags = bp->b_oflags;
251 1.23 ad cbp->cb_buf.b_cflags = bp->b_cflags;
252 1.1 thorpej cbp->cb_buf.b_iodone = sc->sc_iodone;
253 1.1 thorpej cbp->cb_buf.b_proc = bp->b_proc;
254 1.1 thorpej cbp->cb_buf.b_vp = sc->sc_vnodes[comp];
255 1.24 ad cbp->cb_buf.b_objlock = &sc->sc_vnodes[comp]->v_interlock;
256 1.1 thorpej cbp->cb_buf.b_blkno = bn + sc->sc_aai->aai_offset;
257 1.1 thorpej cbp->cb_buf.b_data = addr;
258 1.1 thorpej cbp->cb_buf.b_bcount = bcount;
259 1.1 thorpej
260 1.1 thorpej /* Context for iodone */
261 1.1 thorpej cbp->cb_obp = bp;
262 1.1 thorpej cbp->cb_sc = sc;
263 1.1 thorpej cbp->cb_comp = comp;
264 1.12 enami cbp->cb_other = NULL;
265 1.12 enami cbp->cb_flags = 0;
266 1.1 thorpej
267 1.1 thorpej return (cbp);
268 1.1 thorpej }
269 1.1 thorpej
270 1.1 thorpej static int
271 1.1 thorpej ld_ataraid_start_span(struct ld_softc *ld, struct buf *bp)
272 1.1 thorpej {
273 1.1 thorpej struct ld_ataraid_softc *sc = (void *) ld;
274 1.1 thorpej struct ataraid_array_info *aai = sc->sc_aai;
275 1.1 thorpej struct ataraid_disk_info *adi;
276 1.1 thorpej SIMPLEQ_HEAD(, cbuf) cbufq;
277 1.1 thorpej struct cbuf *cbp;
278 1.19 christos char *addr;
279 1.1 thorpej daddr_t bn;
280 1.1 thorpej long bcount, rcount;
281 1.1 thorpej u_int comp;
282 1.1 thorpej
283 1.1 thorpej /* Allocate component buffers. */
284 1.1 thorpej SIMPLEQ_INIT(&cbufq);
285 1.1 thorpej addr = bp->b_data;
286 1.1 thorpej
287 1.1 thorpej /* Find the first component. */
288 1.1 thorpej comp = 0;
289 1.1 thorpej adi = &aai->aai_disks[comp];
290 1.1 thorpej bn = bp->b_rawblkno;
291 1.1 thorpej while (bn >= adi->adi_compsize) {
292 1.1 thorpej bn -= adi->adi_compsize;
293 1.1 thorpej adi = &aai->aai_disks[++comp];
294 1.1 thorpej }
295 1.1 thorpej
296 1.1 thorpej bp->b_resid = bp->b_bcount;
297 1.1 thorpej
298 1.1 thorpej for (bcount = bp->b_bcount; bcount > 0; bcount -= rcount) {
299 1.1 thorpej rcount = bp->b_bcount;
300 1.1 thorpej if ((adi->adi_compsize - bn) < btodb(rcount))
301 1.1 thorpej rcount = dbtob(adi->adi_compsize - bn);
302 1.1 thorpej
303 1.1 thorpej cbp = ld_ataraid_make_cbuf(sc, bp, comp, bn, addr, rcount);
304 1.1 thorpej if (cbp == NULL) {
305 1.1 thorpej /* Free the already allocated component buffers. */
306 1.1 thorpej while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
307 1.1 thorpej SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
308 1.23 ad buf_destroy(&cbp->cb_buf);
309 1.1 thorpej CBUF_PUT(cbp);
310 1.1 thorpej }
311 1.5 thorpej return (EAGAIN);
312 1.1 thorpej }
313 1.1 thorpej
314 1.1 thorpej /*
315 1.1 thorpej * For a span, we always know we advance to the next disk,
316 1.1 thorpej * and always start at offset 0 on that disk.
317 1.1 thorpej */
318 1.1 thorpej adi = &aai->aai_disks[++comp];
319 1.1 thorpej bn = 0;
320 1.1 thorpej
321 1.1 thorpej SIMPLEQ_INSERT_TAIL(&cbufq, cbp, cb_q);
322 1.1 thorpej addr += rcount;
323 1.1 thorpej }
324 1.1 thorpej
325 1.1 thorpej /* Now fire off the requests. */
326 1.1 thorpej while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
327 1.1 thorpej SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
328 1.24 ad if ((cbp->cb_buf.b_flags & B_READ) == 0) {
329 1.24 ad mutex_enter(&cbp->cb_buf.b_vp->v_interlock);
330 1.1 thorpej cbp->cb_buf.b_vp->v_numoutput++;
331 1.24 ad mutex_exit(&cbp->cb_buf.b_vp->v_interlock);
332 1.24 ad }
333 1.10 hannken VOP_STRATEGY(cbp->cb_buf.b_vp, &cbp->cb_buf);
334 1.1 thorpej }
335 1.1 thorpej
336 1.1 thorpej return (0);
337 1.1 thorpej }
338 1.1 thorpej
339 1.1 thorpej static int
340 1.1 thorpej ld_ataraid_start_raid0(struct ld_softc *ld, struct buf *bp)
341 1.1 thorpej {
342 1.1 thorpej struct ld_ataraid_softc *sc = (void *) ld;
343 1.1 thorpej struct ataraid_array_info *aai = sc->sc_aai;
344 1.12 enami struct ataraid_disk_info *adi;
345 1.1 thorpej SIMPLEQ_HEAD(, cbuf) cbufq;
346 1.12 enami struct cbuf *cbp, *other_cbp;
347 1.19 christos char *addr;
348 1.1 thorpej daddr_t bn, cbn, tbn, off;
349 1.1 thorpej long bcount, rcount;
350 1.1 thorpej u_int comp;
351 1.12 enami const int read = bp->b_flags & B_READ;
352 1.12 enami const int mirror = aai->aai_level & AAI_L_RAID1;
353 1.12 enami int error;
354 1.1 thorpej
355 1.1 thorpej /* Allocate component buffers. */
356 1.1 thorpej SIMPLEQ_INIT(&cbufq);
357 1.1 thorpej addr = bp->b_data;
358 1.1 thorpej bn = bp->b_rawblkno;
359 1.1 thorpej
360 1.1 thorpej bp->b_resid = bp->b_bcount;
361 1.1 thorpej
362 1.1 thorpej for (bcount = bp->b_bcount; bcount > 0; bcount -= rcount) {
363 1.1 thorpej tbn = bn / aai->aai_interleave;
364 1.1 thorpej off = bn % aai->aai_interleave;
365 1.1 thorpej
366 1.1 thorpej if (__predict_false(tbn == aai->aai_capacity /
367 1.1 thorpej aai->aai_interleave)) {
368 1.1 thorpej /* Last stripe. */
369 1.1 thorpej daddr_t sz = (aai->aai_capacity -
370 1.1 thorpej (tbn * aai->aai_interleave)) /
371 1.1 thorpej aai->aai_width;
372 1.1 thorpej comp = off / sz;
373 1.1 thorpej cbn = ((tbn / aai->aai_width) * aai->aai_interleave) +
374 1.1 thorpej (off % sz);
375 1.1 thorpej rcount = min(bcount, dbtob(sz));
376 1.1 thorpej } else {
377 1.1 thorpej comp = tbn % aai->aai_width;
378 1.1 thorpej cbn = ((tbn / aai->aai_width) * aai->aai_interleave) +
379 1.1 thorpej off;
380 1.1 thorpej rcount = min(bcount, dbtob(aai->aai_interleave - off));
381 1.1 thorpej }
382 1.1 thorpej
383 1.12 enami /*
384 1.12 enami * See if a component is valid.
385 1.12 enami */
386 1.12 enami try_mirror:
387 1.12 enami adi = &aai->aai_disks[comp];
388 1.12 enami if ((adi->adi_status & ADI_S_ONLINE) == 0) {
389 1.12 enami if (mirror && comp < aai->aai_width) {
390 1.12 enami comp += aai->aai_width;
391 1.12 enami goto try_mirror;
392 1.12 enami }
393 1.12 enami
394 1.12 enami /*
395 1.12 enami * No component available.
396 1.12 enami */
397 1.12 enami error = EIO;
398 1.12 enami goto free_and_exit;
399 1.12 enami }
400 1.12 enami
401 1.1 thorpej cbp = ld_ataraid_make_cbuf(sc, bp, comp, cbn, addr, rcount);
402 1.1 thorpej if (cbp == NULL) {
403 1.12 enami resource_shortage:
404 1.12 enami error = EAGAIN;
405 1.12 enami free_and_exit:
406 1.1 thorpej /* Free the already allocated component buffers. */
407 1.1 thorpej while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
408 1.1 thorpej SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
409 1.23 ad buf_destroy(&cbp->cb_buf);
410 1.1 thorpej CBUF_PUT(cbp);
411 1.1 thorpej }
412 1.12 enami return (error);
413 1.1 thorpej }
414 1.1 thorpej SIMPLEQ_INSERT_TAIL(&cbufq, cbp, cb_q);
415 1.12 enami if (mirror && !read && comp < aai->aai_width) {
416 1.12 enami comp += aai->aai_width;
417 1.12 enami adi = &aai->aai_disks[comp];
418 1.12 enami if (adi->adi_status & ADI_S_ONLINE) {
419 1.12 enami other_cbp = ld_ataraid_make_cbuf(sc, bp,
420 1.12 enami comp, cbn, addr, rcount);
421 1.12 enami if (other_cbp == NULL)
422 1.12 enami goto resource_shortage;
423 1.12 enami SIMPLEQ_INSERT_TAIL(&cbufq, other_cbp, cb_q);
424 1.12 enami other_cbp->cb_other = cbp;
425 1.12 enami cbp->cb_other = other_cbp;
426 1.12 enami }
427 1.12 enami }
428 1.1 thorpej bn += btodb(rcount);
429 1.1 thorpej addr += rcount;
430 1.1 thorpej }
431 1.1 thorpej
432 1.1 thorpej /* Now fire off the requests. */
433 1.1 thorpej while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
434 1.1 thorpej SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
435 1.24 ad if ((cbp->cb_buf.b_flags & B_READ) == 0) {
436 1.24 ad mutex_enter(&cbp->cb_buf.b_vp->v_interlock);
437 1.1 thorpej cbp->cb_buf.b_vp->v_numoutput++;
438 1.24 ad mutex_exit(&cbp->cb_buf.b_vp->v_interlock);
439 1.24 ad }
440 1.10 hannken VOP_STRATEGY(cbp->cb_buf.b_vp, &cbp->cb_buf);
441 1.1 thorpej }
442 1.1 thorpej
443 1.1 thorpej return (0);
444 1.1 thorpej }
445 1.1 thorpej
446 1.1 thorpej /*
447 1.1 thorpej * Called at interrupt time. Mark the component as done and if all
448 1.1 thorpej * components are done, take an "interrupt".
449 1.1 thorpej */
450 1.1 thorpej static void
451 1.1 thorpej ld_ataraid_iodone_raid0(struct buf *vbp)
452 1.1 thorpej {
453 1.12 enami struct cbuf *cbp = (struct cbuf *) vbp, *other_cbp;
454 1.1 thorpej struct buf *bp = cbp->cb_obp;
455 1.1 thorpej struct ld_ataraid_softc *sc = cbp->cb_sc;
456 1.12 enami struct ataraid_array_info *aai = sc->sc_aai;
457 1.12 enami struct ataraid_disk_info *adi;
458 1.1 thorpej long count;
459 1.12 enami int s, iodone;
460 1.1 thorpej
461 1.1 thorpej s = splbio();
462 1.1 thorpej
463 1.12 enami iodone = cbp->cb_flags & CBUF_IODONE;
464 1.12 enami other_cbp = cbp->cb_other;
465 1.12 enami if (other_cbp != NULL)
466 1.12 enami /* You are alone */
467 1.12 enami other_cbp->cb_other = NULL;
468 1.12 enami
469 1.21 ad if (cbp->cb_buf.b_error != 0) {
470 1.12 enami /*
471 1.12 enami * Mark this component broken.
472 1.12 enami */
473 1.12 enami adi = &aai->aai_disks[cbp->cb_comp];
474 1.12 enami adi->adi_status &= ~ADI_S_ONLINE;
475 1.12 enami
476 1.12 enami printf("%s: error %d on component %d (%s)\n",
477 1.26 cegger device_xname(&sc->sc_ld.sc_dv), bp->b_error, cbp->cb_comp,
478 1.26 cegger device_xname(adi->adi_dev));
479 1.12 enami
480 1.12 enami /*
481 1.12 enami * If we didn't see an error yet and we are reading
482 1.12 enami * RAID1 disk, try another component.
483 1.12 enami */
484 1.21 ad if (bp->b_error == 0 &&
485 1.12 enami (cbp->cb_buf.b_flags & B_READ) != 0 &&
486 1.12 enami (aai->aai_level & AAI_L_RAID1) != 0 &&
487 1.12 enami cbp->cb_comp < aai->aai_width) {
488 1.12 enami cbp->cb_comp += aai->aai_width;
489 1.12 enami adi = &aai->aai_disks[cbp->cb_comp];
490 1.12 enami if (adi->adi_status & ADI_S_ONLINE) {
491 1.21 ad cbp->cb_buf.b_error = 0;
492 1.12 enami VOP_STRATEGY(cbp->cb_buf.b_vp, &cbp->cb_buf);
493 1.12 enami goto out;
494 1.12 enami }
495 1.12 enami }
496 1.12 enami
497 1.12 enami if (iodone || other_cbp != NULL)
498 1.12 enami /*
499 1.12 enami * If I/O on other component successfully done
500 1.12 enami * or the I/O is still in progress, no need
501 1.12 enami * to tell an error to upper layer.
502 1.12 enami */
503 1.12 enami ;
504 1.12 enami else {
505 1.12 enami bp->b_error = cbp->cb_buf.b_error ?
506 1.12 enami cbp->cb_buf.b_error : EIO;
507 1.12 enami }
508 1.1 thorpej
509 1.1 thorpej /* XXX Update component config blocks. */
510 1.1 thorpej
511 1.12 enami } else {
512 1.12 enami /*
513 1.12 enami * If other I/O is still in progress, tell it that
514 1.12 enami * our I/O is successfully done.
515 1.12 enami */
516 1.12 enami if (other_cbp != NULL)
517 1.12 enami other_cbp->cb_flags |= CBUF_IODONE;
518 1.1 thorpej }
519 1.1 thorpej count = cbp->cb_buf.b_bcount;
520 1.1 thorpej CBUF_PUT(cbp);
521 1.1 thorpej
522 1.12 enami if (other_cbp != NULL)
523 1.12 enami goto out;
524 1.12 enami
525 1.1 thorpej /* If all done, "interrupt". */
526 1.1 thorpej bp->b_resid -= count;
527 1.1 thorpej if (bp->b_resid < 0)
528 1.1 thorpej panic("ld_ataraid_iodone_raid0: count");
529 1.1 thorpej if (bp->b_resid == 0)
530 1.1 thorpej lddone(&sc->sc_ld, bp);
531 1.12 enami
532 1.12 enami out:
533 1.1 thorpej splx(s);
534 1.1 thorpej }
535 1.1 thorpej
536 1.1 thorpej static int
537 1.18 christos ld_ataraid_dump(struct ld_softc *sc, void *data,
538 1.18 christos int blkno, int blkcnt)
539 1.1 thorpej {
540 1.1 thorpej
541 1.1 thorpej return (EIO);
542 1.1 thorpej }
543