rf_netbsdkintf.c revision 1.60 1 1.60 oster /* $NetBSD: rf_netbsdkintf.c,v 1.60 2000/02/25 19:56:56 oster Exp $ */
2 1.1 oster /*-
3 1.1 oster * Copyright (c) 1996, 1997, 1998 The NetBSD Foundation, Inc.
4 1.1 oster * All rights reserved.
5 1.1 oster *
6 1.1 oster * This code is derived from software contributed to The NetBSD Foundation
7 1.1 oster * by Greg Oster; Jason R. Thorpe.
8 1.1 oster *
9 1.1 oster * Redistribution and use in source and binary forms, with or without
10 1.1 oster * modification, are permitted provided that the following conditions
11 1.1 oster * are met:
12 1.1 oster * 1. Redistributions of source code must retain the above copyright
13 1.1 oster * notice, this list of conditions and the following disclaimer.
14 1.1 oster * 2. Redistributions in binary form must reproduce the above copyright
15 1.1 oster * notice, this list of conditions and the following disclaimer in the
16 1.1 oster * documentation and/or other materials provided with the distribution.
17 1.1 oster * 3. All advertising materials mentioning features or use of this software
18 1.1 oster * must display the following acknowledgement:
19 1.1 oster * This product includes software developed by the NetBSD
20 1.1 oster * Foundation, Inc. and its contributors.
21 1.1 oster * 4. Neither the name of The NetBSD Foundation nor the names of its
22 1.1 oster * contributors may be used to endorse or promote products derived
23 1.1 oster * from this software without specific prior written permission.
24 1.1 oster *
25 1.1 oster * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
26 1.1 oster * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
27 1.1 oster * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
28 1.1 oster * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
29 1.1 oster * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
30 1.1 oster * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
31 1.1 oster * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
32 1.1 oster * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
33 1.1 oster * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
34 1.1 oster * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
35 1.1 oster * POSSIBILITY OF SUCH DAMAGE.
36 1.1 oster */
37 1.1 oster
38 1.1 oster /*
39 1.1 oster * Copyright (c) 1988 University of Utah.
40 1.1 oster * Copyright (c) 1990, 1993
41 1.1 oster * The Regents of the University of California. All rights reserved.
42 1.1 oster *
43 1.1 oster * This code is derived from software contributed to Berkeley by
44 1.1 oster * the Systems Programming Group of the University of Utah Computer
45 1.1 oster * Science Department.
46 1.1 oster *
47 1.1 oster * Redistribution and use in source and binary forms, with or without
48 1.1 oster * modification, are permitted provided that the following conditions
49 1.1 oster * are met:
50 1.1 oster * 1. Redistributions of source code must retain the above copyright
51 1.1 oster * notice, this list of conditions and the following disclaimer.
52 1.1 oster * 2. Redistributions in binary form must reproduce the above copyright
53 1.1 oster * notice, this list of conditions and the following disclaimer in the
54 1.1 oster * documentation and/or other materials provided with the distribution.
55 1.1 oster * 3. All advertising materials mentioning features or use of this software
56 1.1 oster * must display the following acknowledgement:
57 1.1 oster * This product includes software developed by the University of
58 1.1 oster * California, Berkeley and its contributors.
59 1.1 oster * 4. Neither the name of the University nor the names of its contributors
60 1.1 oster * may be used to endorse or promote products derived from this software
61 1.1 oster * without specific prior written permission.
62 1.1 oster *
63 1.1 oster * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
64 1.1 oster * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
65 1.1 oster * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
66 1.1 oster * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
67 1.1 oster * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
68 1.1 oster * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
69 1.1 oster * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
70 1.1 oster * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
71 1.1 oster * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
72 1.1 oster * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
73 1.1 oster * SUCH DAMAGE.
74 1.1 oster *
75 1.1 oster * from: Utah $Hdr: cd.c 1.6 90/11/28$
76 1.1 oster *
77 1.1 oster * @(#)cd.c 8.2 (Berkeley) 11/16/93
78 1.1 oster */
79 1.1 oster
80 1.1 oster
81 1.1 oster
82 1.1 oster
83 1.1 oster /*
84 1.1 oster * Copyright (c) 1995 Carnegie-Mellon University.
85 1.1 oster * All rights reserved.
86 1.1 oster *
87 1.1 oster * Authors: Mark Holland, Jim Zelenka
88 1.1 oster *
89 1.1 oster * Permission to use, copy, modify and distribute this software and
90 1.1 oster * its documentation is hereby granted, provided that both the copyright
91 1.1 oster * notice and this permission notice appear in all copies of the
92 1.1 oster * software, derivative works or modified versions, and any portions
93 1.1 oster * thereof, and that both notices appear in supporting documentation.
94 1.1 oster *
95 1.1 oster * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
96 1.1 oster * CONDITION. CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND
97 1.1 oster * FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
98 1.1 oster *
99 1.1 oster * Carnegie Mellon requests users of this software to return to
100 1.1 oster *
101 1.1 oster * Software Distribution Coordinator or Software.Distribution (at) CS.CMU.EDU
102 1.1 oster * School of Computer Science
103 1.1 oster * Carnegie Mellon University
104 1.1 oster * Pittsburgh PA 15213-3890
105 1.1 oster *
106 1.1 oster * any improvements or extensions that they make and grant Carnegie the
107 1.1 oster * rights to redistribute these changes.
108 1.1 oster */
109 1.1 oster
110 1.1 oster /***********************************************************
111 1.1 oster *
112 1.1 oster * rf_kintf.c -- the kernel interface routines for RAIDframe
113 1.1 oster *
114 1.1 oster ***********************************************************/
115 1.1 oster
116 1.1 oster #include <sys/errno.h>
117 1.1 oster #include <sys/param.h>
118 1.1 oster #include <sys/pool.h>
119 1.1 oster #include <sys/queue.h>
120 1.1 oster #include <sys/disk.h>
121 1.1 oster #include <sys/device.h>
122 1.1 oster #include <sys/stat.h>
123 1.1 oster #include <sys/ioctl.h>
124 1.1 oster #include <sys/fcntl.h>
125 1.1 oster #include <sys/systm.h>
126 1.1 oster #include <sys/namei.h>
127 1.1 oster #include <sys/vnode.h>
128 1.1 oster #include <sys/param.h>
129 1.1 oster #include <sys/types.h>
130 1.1 oster #include <machine/types.h>
131 1.1 oster #include <sys/disklabel.h>
132 1.1 oster #include <sys/conf.h>
133 1.1 oster #include <sys/lock.h>
134 1.1 oster #include <sys/buf.h>
135 1.1 oster #include <sys/user.h>
136 1.8 oster
137 1.8 oster #include "raid.h"
138 1.1 oster #include "rf_raid.h"
139 1.1 oster #include "rf_raidframe.h"
140 1.44 oster #include "rf_copyback.h"
141 1.1 oster #include "rf_dag.h"
142 1.1 oster #include "rf_dagflags.h"
143 1.1 oster #include "rf_diskqueue.h"
144 1.1 oster #include "rf_acctrace.h"
145 1.1 oster #include "rf_etimer.h"
146 1.1 oster #include "rf_general.h"
147 1.1 oster #include "rf_debugMem.h"
148 1.1 oster #include "rf_kintf.h"
149 1.1 oster #include "rf_options.h"
150 1.1 oster #include "rf_driver.h"
151 1.1 oster #include "rf_parityscan.h"
152 1.1 oster #include "rf_debugprint.h"
153 1.1 oster #include "rf_threadstuff.h"
154 1.1 oster
155 1.9 oster int rf_kdebug_level = 0;
156 1.1 oster
157 1.1 oster #ifdef DEBUG
158 1.1 oster #define db1_printf(a) if (rf_kdebug_level > 0) printf a
159 1.9 oster #else /* DEBUG */
160 1.1 oster #define db1_printf(a) { }
161 1.9 oster #endif /* DEBUG */
162 1.1 oster
163 1.9 oster static RF_Raid_t **raidPtrs; /* global raid device descriptors */
164 1.1 oster
165 1.11 oster RF_DECLARE_STATIC_MUTEX(rf_sparet_wait_mutex)
166 1.1 oster
167 1.10 oster static RF_SparetWait_t *rf_sparet_wait_queue; /* requests to install a
168 1.10 oster * spare table */
169 1.10 oster static RF_SparetWait_t *rf_sparet_resp_queue; /* responses from
170 1.10 oster * installation process */
171 1.10 oster
172 1.1 oster /* prototypes */
173 1.10 oster static void KernelWakeupFunc(struct buf * bp);
174 1.10 oster static void InitBP(struct buf * bp, struct vnode *, unsigned rw_flag,
175 1.10 oster dev_t dev, RF_SectorNum_t startSect,
176 1.10 oster RF_SectorCount_t numSect, caddr_t buf,
177 1.10 oster void (*cbFunc) (struct buf *), void *cbArg,
178 1.10 oster int logBytesPerSector, struct proc * b_proc);
179 1.59 oster static void raidinit __P((RF_Raid_t *));
180 1.1 oster
181 1.10 oster void raidattach __P((int));
182 1.10 oster int raidsize __P((dev_t));
183 1.10 oster int raidopen __P((dev_t, int, int, struct proc *));
184 1.10 oster int raidclose __P((dev_t, int, int, struct proc *));
185 1.10 oster int raidioctl __P((dev_t, u_long, caddr_t, int, struct proc *));
186 1.10 oster int raidwrite __P((dev_t, struct uio *, int));
187 1.10 oster int raidread __P((dev_t, struct uio *, int));
188 1.10 oster void raidstrategy __P((struct buf *));
189 1.10 oster int raiddump __P((dev_t, daddr_t, caddr_t, size_t));
190 1.1 oster
191 1.1 oster /*
192 1.1 oster * Pilfered from ccd.c
193 1.1 oster */
194 1.1 oster
195 1.10 oster struct raidbuf {
196 1.10 oster struct buf rf_buf; /* new I/O buf. MUST BE FIRST!!! */
197 1.10 oster struct buf *rf_obp; /* ptr. to original I/O buf */
198 1.10 oster int rf_flags; /* misc. flags */
199 1.11 oster RF_DiskQueueData_t *req;/* the request that this was part of.. */
200 1.10 oster };
201 1.1 oster
202 1.1 oster
203 1.1 oster #define RAIDGETBUF(rs) pool_get(&(rs)->sc_cbufpool, PR_NOWAIT)
204 1.1 oster #define RAIDPUTBUF(rs, cbp) pool_put(&(rs)->sc_cbufpool, cbp)
205 1.1 oster
206 1.9 oster /* XXX Not sure if the following should be replacing the raidPtrs above,
207 1.53 oster or if it should be used in conjunction with that...
208 1.59 oster */
209 1.1 oster
210 1.10 oster struct raid_softc {
211 1.10 oster int sc_flags; /* flags */
212 1.10 oster int sc_cflags; /* configuration flags */
213 1.11 oster size_t sc_size; /* size of the raid device */
214 1.10 oster char sc_xname[20]; /* XXX external name */
215 1.10 oster struct disk sc_dkdev; /* generic disk device info */
216 1.10 oster struct pool sc_cbufpool; /* component buffer pool */
217 1.47 thorpej struct buf_queue buf_queue; /* used for the device queue */
218 1.10 oster };
219 1.1 oster /* sc_flags */
220 1.1 oster #define RAIDF_INITED 0x01 /* unit has been initialized */
221 1.1 oster #define RAIDF_WLABEL 0x02 /* label area is writable */
222 1.1 oster #define RAIDF_LABELLING 0x04 /* unit is currently being labelled */
223 1.1 oster #define RAIDF_WANTED 0x40 /* someone is waiting to obtain a lock */
224 1.1 oster #define RAIDF_LOCKED 0x80 /* unit is locked */
225 1.1 oster
226 1.1 oster #define raidunit(x) DISKUNIT(x)
227 1.48 oster int numraid = 0;
228 1.1 oster
229 1.20 oster /*
230 1.20 oster * Allow RAIDOUTSTANDING number of simultaneous IO's to this RAID device.
231 1.20 oster * Be aware that large numbers can allow the driver to consume a lot of
232 1.28 oster * kernel memory, especially on writes, and in degraded mode reads.
233 1.28 oster *
234 1.28 oster * For example: with a stripe width of 64 blocks (32k) and 5 disks,
235 1.28 oster * a single 64K write will typically require 64K for the old data,
236 1.28 oster * 64K for the old parity, and 64K for the new parity, for a total
237 1.28 oster * of 192K (if the parity buffer is not re-used immediately).
238 1.28 oster * Even it if is used immedately, that's still 128K, which when multiplied
239 1.28 oster * by say 10 requests, is 1280K, *on top* of the 640K of incoming data.
240 1.28 oster *
241 1.28 oster * Now in degraded mode, for example, a 64K read on the above setup may
242 1.28 oster * require data reconstruction, which will require *all* of the 4 remaining
243 1.28 oster * disks to participate -- 4 * 32K/disk == 128K again.
244 1.20 oster */
245 1.20 oster
246 1.20 oster #ifndef RAIDOUTSTANDING
247 1.28 oster #define RAIDOUTSTANDING 6
248 1.20 oster #endif
249 1.20 oster
250 1.1 oster #define RAIDLABELDEV(dev) \
251 1.1 oster (MAKEDISKDEV(major((dev)), raidunit((dev)), RAW_PART))
252 1.1 oster
253 1.1 oster /* declared here, and made public, for the benefit of KVM stuff.. */
254 1.10 oster struct raid_softc *raid_softc;
255 1.9 oster
256 1.10 oster static void raidgetdefaultlabel __P((RF_Raid_t *, struct raid_softc *,
257 1.10 oster struct disklabel *));
258 1.10 oster static void raidgetdisklabel __P((dev_t));
259 1.10 oster static void raidmakedisklabel __P((struct raid_softc *));
260 1.1 oster
261 1.10 oster static int raidlock __P((struct raid_softc *));
262 1.10 oster static void raidunlock __P((struct raid_softc *));
263 1.1 oster
264 1.12 oster static void rf_markalldirty __P((RF_Raid_t *));
265 1.48 oster void rf_mountroot_hook __P((struct device *));
266 1.48 oster
267 1.48 oster struct device *raidrootdev;
268 1.48 oster struct cfdata cf_raidrootdev;
269 1.48 oster struct cfdriver cfdrv;
270 1.48 oster /* XXX these should be moved up */
271 1.48 oster #include "rf_configure.h"
272 1.48 oster #include <sys/reboot.h>
273 1.1 oster
274 1.37 oster void rf_ReconThread __P((struct rf_recon_req *));
275 1.37 oster /* XXX what I want is: */
276 1.37 oster /*void rf_ReconThread __P((RF_Raid_t *raidPtr)); */
277 1.37 oster void rf_RewriteParityThread __P((RF_Raid_t *raidPtr));
278 1.37 oster void rf_CopybackThread __P((RF_Raid_t *raidPtr));
279 1.37 oster void rf_ReconstructInPlaceThread __P((struct rf_recon_req *));
280 1.48 oster void rf_buildroothack __P((void *));
281 1.48 oster
282 1.48 oster RF_AutoConfig_t *rf_find_raid_components __P((void));
283 1.48 oster void print_component_label __P((RF_ComponentLabel_t *));
284 1.48 oster RF_ConfigSet_t *rf_create_auto_sets __P((RF_AutoConfig_t *));
285 1.49 oster static int rf_does_it_fit __P((RF_ConfigSet_t *,RF_AutoConfig_t *));
286 1.49 oster static int rf_reasonable_label __P((RF_ComponentLabel_t *));
287 1.49 oster void rf_create_configuration __P((RF_AutoConfig_t *,RF_Config_t *,
288 1.49 oster RF_Raid_t *));
289 1.48 oster int rf_set_autoconfig __P((RF_Raid_t *, int));
290 1.48 oster int rf_set_rootpartition __P((RF_Raid_t *, int));
291 1.49 oster void rf_release_all_vps __P((RF_ConfigSet_t *));
292 1.49 oster void rf_cleanup_config_set __P((RF_ConfigSet_t *));
293 1.51 oster int rf_have_enough_components __P((RF_ConfigSet_t *));
294 1.51 oster int rf_auto_config_set __P((RF_ConfigSet_t *, int *));
295 1.48 oster
296 1.48 oster static int raidautoconfig = 0; /* Debugging, mostly. Set to 0 to not
297 1.48 oster allow autoconfig to take place */
298 1.48 oster extern struct device *booted_device;
299 1.37 oster
300 1.10 oster void
301 1.10 oster raidattach(num)
302 1.9 oster int num;
303 1.1 oster {
304 1.14 oster int raidID;
305 1.14 oster int i, rc;
306 1.48 oster RF_AutoConfig_t *ac_list; /* autoconfig list */
307 1.48 oster RF_ConfigSet_t *config_sets;
308 1.1 oster
309 1.1 oster #ifdef DEBUG
310 1.9 oster printf("raidattach: Asked for %d units\n", num);
311 1.1 oster #endif
312 1.1 oster
313 1.1 oster if (num <= 0) {
314 1.1 oster #ifdef DIAGNOSTIC
315 1.1 oster panic("raidattach: count <= 0");
316 1.1 oster #endif
317 1.1 oster return;
318 1.1 oster }
319 1.9 oster /* This is where all the initialization stuff gets done. */
320 1.1 oster
321 1.50 oster numraid = num;
322 1.50 oster
323 1.1 oster /* Make some space for requested number of units... */
324 1.1 oster
325 1.1 oster RF_Calloc(raidPtrs, num, sizeof(RF_Raid_t *), (RF_Raid_t **));
326 1.1 oster if (raidPtrs == NULL) {
327 1.1 oster panic("raidPtrs is NULL!!\n");
328 1.1 oster }
329 1.14 oster
330 1.14 oster rc = rf_mutex_init(&rf_sparet_wait_mutex);
331 1.14 oster if (rc) {
332 1.14 oster RF_PANIC();
333 1.14 oster }
334 1.14 oster
335 1.14 oster rf_sparet_wait_queue = rf_sparet_resp_queue = NULL;
336 1.14 oster
337 1.58 oster for (i = 0; i < num; i++)
338 1.14 oster raidPtrs[i] = NULL;
339 1.14 oster rc = rf_BootRaidframe();
340 1.14 oster if (rc == 0)
341 1.14 oster printf("Kernelized RAIDframe activated\n");
342 1.14 oster else
343 1.1 oster panic("Serious error booting RAID!!\n");
344 1.14 oster
345 1.9 oster /* put together some datastructures like the CCD device does.. This
346 1.9 oster * lets us lock the device and what-not when it gets opened. */
347 1.1 oster
348 1.1 oster raid_softc = (struct raid_softc *)
349 1.48 oster malloc(num * sizeof(struct raid_softc),
350 1.48 oster M_RAIDFRAME, M_NOWAIT);
351 1.1 oster if (raid_softc == NULL) {
352 1.1 oster printf("WARNING: no memory for RAIDframe driver\n");
353 1.1 oster return;
354 1.1 oster }
355 1.50 oster
356 1.1 oster bzero(raid_softc, num * sizeof(struct raid_softc));
357 1.34 oster
358 1.48 oster raidrootdev = (struct device *)malloc(num * sizeof(struct device),
359 1.48 oster M_RAIDFRAME, M_NOWAIT);
360 1.48 oster if (raidrootdev == NULL) {
361 1.48 oster panic("No memory for RAIDframe driver!!?!?!\n");
362 1.48 oster }
363 1.48 oster
364 1.9 oster for (raidID = 0; raidID < num; raidID++) {
365 1.47 thorpej BUFQ_INIT(&raid_softc[raidID].buf_queue);
366 1.48 oster
367 1.48 oster raidrootdev[raidID].dv_class = DV_DISK;
368 1.48 oster raidrootdev[raidID].dv_cfdata = NULL;
369 1.48 oster raidrootdev[raidID].dv_unit = raidID;
370 1.48 oster raidrootdev[raidID].dv_parent = NULL;
371 1.48 oster raidrootdev[raidID].dv_flags = 0;
372 1.48 oster sprintf(raidrootdev[raidID].dv_xname,"raid%d",raidID);
373 1.48 oster
374 1.9 oster RF_Calloc(raidPtrs[raidID], 1, sizeof(RF_Raid_t),
375 1.11 oster (RF_Raid_t *));
376 1.9 oster if (raidPtrs[raidID] == NULL) {
377 1.39 oster printf("WARNING: raidPtrs[%d] is NULL\n", raidID);
378 1.39 oster numraid = raidID;
379 1.39 oster return;
380 1.1 oster }
381 1.1 oster }
382 1.48 oster
383 1.48 oster if (raidautoconfig) {
384 1.48 oster /* 1. locate all RAID components on the system */
385 1.48 oster
386 1.48 oster #if DEBUG
387 1.48 oster printf("Searching for raid components...\n");
388 1.48 oster #endif
389 1.48 oster ac_list = rf_find_raid_components();
390 1.48 oster
391 1.48 oster /* 2. sort them into their respective sets */
392 1.48 oster
393 1.48 oster config_sets = rf_create_auto_sets(ac_list);
394 1.48 oster
395 1.48 oster /* 3. evaluate each set and configure the valid ones
396 1.48 oster This gets done in rf_buildroothack() */
397 1.48 oster
398 1.48 oster /* schedule the creation of the thread to do the
399 1.48 oster "/ on RAID" stuff */
400 1.48 oster
401 1.48 oster kthread_create(rf_buildroothack,config_sets);
402 1.48 oster
403 1.48 oster /* 4. make sure we get our mud.. I mean root.. hooks in.. */
404 1.48 oster /* XXXX pick raid0 for now... and this should be only done
405 1.48 oster if we find something that's bootable!!! */
406 1.48 oster #if 0
407 1.48 oster mountroothook_establish(rf_mountroot_hook, &raidrootdev[0]);
408 1.48 oster #endif
409 1.48 oster }
410 1.48 oster
411 1.48 oster }
412 1.48 oster
413 1.48 oster void
414 1.48 oster rf_buildroothack(arg)
415 1.48 oster void *arg;
416 1.48 oster {
417 1.48 oster RF_ConfigSet_t *config_sets = arg;
418 1.48 oster RF_ConfigSet_t *cset;
419 1.48 oster RF_ConfigSet_t *next_cset;
420 1.51 oster int retcode;
421 1.48 oster int raidID;
422 1.51 oster int rootID;
423 1.51 oster int num_root;
424 1.48 oster
425 1.51 oster num_root = 0;
426 1.48 oster cset = config_sets;
427 1.48 oster while(cset != NULL ) {
428 1.48 oster next_cset = cset->next;
429 1.51 oster if (rf_have_enough_components(cset) &&
430 1.51 oster cset->ac->clabel->autoconfigure==1) {
431 1.51 oster retcode = rf_auto_config_set(cset,&raidID);
432 1.51 oster if (!retcode) {
433 1.51 oster if (cset->rootable) {
434 1.51 oster rootID = raidID;
435 1.51 oster num_root++;
436 1.51 oster }
437 1.51 oster } else {
438 1.51 oster /* The autoconfig didn't work :( */
439 1.51 oster #if DEBUG
440 1.51 oster printf("Autoconfig failed with code %d for raid%d\n", retcode, raidID);
441 1.51 oster #endif
442 1.51 oster rf_release_all_vps(cset);
443 1.48 oster #if DEBUG
444 1.51 oster printf("Done cleanup\n");
445 1.48 oster #endif
446 1.48 oster }
447 1.48 oster } else {
448 1.48 oster /* we're not autoconfiguring this set...
449 1.48 oster release the associated resources */
450 1.48 oster #if DEBUG
451 1.48 oster printf("Releasing vp's\n");
452 1.48 oster #endif
453 1.49 oster rf_release_all_vps(cset);
454 1.48 oster #if DEBUG
455 1.48 oster printf("Done.\n");
456 1.48 oster #endif
457 1.48 oster }
458 1.48 oster /* cleanup */
459 1.48 oster #if DEBUG
460 1.48 oster printf("Cleaning up config set\n");
461 1.48 oster #endif
462 1.49 oster rf_cleanup_config_set(cset);
463 1.48 oster #if DEBUG
464 1.48 oster printf("Done cleanup\n");
465 1.48 oster #endif
466 1.48 oster cset = next_cset;
467 1.48 oster }
468 1.51 oster if (boothowto & RB_ASKNAME) {
469 1.51 oster /* We don't auto-config... */
470 1.51 oster } else {
471 1.51 oster /* They didn't ask, and we found something bootable... */
472 1.51 oster /* XXX pretend for now.. */
473 1.51 oster if (num_root == 1) {
474 1.51 oster #if 1
475 1.51 oster booted_device = &raidrootdev[rootID];
476 1.51 oster #endif
477 1.51 oster } else if (num_root > 1) {
478 1.51 oster /* we can't guess.. require the user to answer... */
479 1.51 oster boothowto |= RB_ASKNAME;
480 1.51 oster }
481 1.51 oster }
482 1.1 oster }
483 1.1 oster
484 1.1 oster
485 1.1 oster int
486 1.1 oster raidsize(dev)
487 1.9 oster dev_t dev;
488 1.1 oster {
489 1.1 oster struct raid_softc *rs;
490 1.1 oster struct disklabel *lp;
491 1.9 oster int part, unit, omask, size;
492 1.1 oster
493 1.1 oster unit = raidunit(dev);
494 1.1 oster if (unit >= numraid)
495 1.1 oster return (-1);
496 1.1 oster rs = &raid_softc[unit];
497 1.1 oster
498 1.1 oster if ((rs->sc_flags & RAIDF_INITED) == 0)
499 1.1 oster return (-1);
500 1.1 oster
501 1.1 oster part = DISKPART(dev);
502 1.1 oster omask = rs->sc_dkdev.dk_openmask & (1 << part);
503 1.1 oster lp = rs->sc_dkdev.dk_label;
504 1.1 oster
505 1.1 oster if (omask == 0 && raidopen(dev, 0, S_IFBLK, curproc))
506 1.1 oster return (-1);
507 1.1 oster
508 1.1 oster if (lp->d_partitions[part].p_fstype != FS_SWAP)
509 1.1 oster size = -1;
510 1.1 oster else
511 1.1 oster size = lp->d_partitions[part].p_size *
512 1.1 oster (lp->d_secsize / DEV_BSIZE);
513 1.1 oster
514 1.1 oster if (omask == 0 && raidclose(dev, 0, S_IFBLK, curproc))
515 1.1 oster return (-1);
516 1.1 oster
517 1.1 oster return (size);
518 1.1 oster
519 1.1 oster }
520 1.1 oster
521 1.1 oster int
522 1.1 oster raiddump(dev, blkno, va, size)
523 1.9 oster dev_t dev;
524 1.1 oster daddr_t blkno;
525 1.1 oster caddr_t va;
526 1.9 oster size_t size;
527 1.1 oster {
528 1.1 oster /* Not implemented. */
529 1.1 oster return ENXIO;
530 1.1 oster }
531 1.1 oster /* ARGSUSED */
532 1.1 oster int
533 1.1 oster raidopen(dev, flags, fmt, p)
534 1.9 oster dev_t dev;
535 1.9 oster int flags, fmt;
536 1.1 oster struct proc *p;
537 1.1 oster {
538 1.9 oster int unit = raidunit(dev);
539 1.1 oster struct raid_softc *rs;
540 1.1 oster struct disklabel *lp;
541 1.9 oster int part, pmask;
542 1.9 oster int error = 0;
543 1.9 oster
544 1.1 oster if (unit >= numraid)
545 1.1 oster return (ENXIO);
546 1.1 oster rs = &raid_softc[unit];
547 1.1 oster
548 1.1 oster if ((error = raidlock(rs)) != 0)
549 1.9 oster return (error);
550 1.1 oster lp = rs->sc_dkdev.dk_label;
551 1.1 oster
552 1.1 oster part = DISKPART(dev);
553 1.1 oster pmask = (1 << part);
554 1.1 oster
555 1.1 oster db1_printf(("Opening raid device number: %d partition: %d\n",
556 1.14 oster unit, part));
557 1.1 oster
558 1.1 oster
559 1.1 oster if ((rs->sc_flags & RAIDF_INITED) &&
560 1.1 oster (rs->sc_dkdev.dk_openmask == 0))
561 1.9 oster raidgetdisklabel(dev);
562 1.1 oster
563 1.1 oster /* make sure that this partition exists */
564 1.1 oster
565 1.1 oster if (part != RAW_PART) {
566 1.1 oster db1_printf(("Not a raw partition..\n"));
567 1.1 oster if (((rs->sc_flags & RAIDF_INITED) == 0) ||
568 1.1 oster ((part >= lp->d_npartitions) ||
569 1.9 oster (lp->d_partitions[part].p_fstype == FS_UNUSED))) {
570 1.1 oster error = ENXIO;
571 1.1 oster raidunlock(rs);
572 1.1 oster db1_printf(("Bailing out...\n"));
573 1.9 oster return (error);
574 1.1 oster }
575 1.1 oster }
576 1.1 oster /* Prevent this unit from being unconfigured while open. */
577 1.1 oster switch (fmt) {
578 1.1 oster case S_IFCHR:
579 1.1 oster rs->sc_dkdev.dk_copenmask |= pmask;
580 1.1 oster break;
581 1.1 oster
582 1.1 oster case S_IFBLK:
583 1.1 oster rs->sc_dkdev.dk_bopenmask |= pmask;
584 1.1 oster break;
585 1.1 oster }
586 1.13 oster
587 1.13 oster if ((rs->sc_dkdev.dk_openmask == 0) &&
588 1.13 oster ((rs->sc_flags & RAIDF_INITED) != 0)) {
589 1.13 oster /* First one... mark things as dirty... Note that we *MUST*
590 1.13 oster have done a configure before this. I DO NOT WANT TO BE
591 1.13 oster SCRIBBLING TO RANDOM COMPONENTS UNTIL IT'S BEEN DETERMINED
592 1.13 oster THAT THEY BELONG TOGETHER!!!!! */
593 1.13 oster /* XXX should check to see if we're only open for reading
594 1.13 oster here... If so, we needn't do this, but then need some
595 1.13 oster other way of keeping track of what's happened.. */
596 1.13 oster
597 1.13 oster rf_markalldirty( raidPtrs[unit] );
598 1.13 oster }
599 1.13 oster
600 1.13 oster
601 1.1 oster rs->sc_dkdev.dk_openmask =
602 1.1 oster rs->sc_dkdev.dk_copenmask | rs->sc_dkdev.dk_bopenmask;
603 1.1 oster
604 1.1 oster raidunlock(rs);
605 1.1 oster
606 1.9 oster return (error);
607 1.1 oster
608 1.1 oster
609 1.1 oster }
610 1.1 oster /* ARGSUSED */
611 1.1 oster int
612 1.1 oster raidclose(dev, flags, fmt, p)
613 1.9 oster dev_t dev;
614 1.9 oster int flags, fmt;
615 1.1 oster struct proc *p;
616 1.1 oster {
617 1.9 oster int unit = raidunit(dev);
618 1.1 oster struct raid_softc *rs;
619 1.9 oster int error = 0;
620 1.9 oster int part;
621 1.1 oster
622 1.1 oster if (unit >= numraid)
623 1.1 oster return (ENXIO);
624 1.1 oster rs = &raid_softc[unit];
625 1.1 oster
626 1.1 oster if ((error = raidlock(rs)) != 0)
627 1.1 oster return (error);
628 1.1 oster
629 1.1 oster part = DISKPART(dev);
630 1.1 oster
631 1.1 oster /* ...that much closer to allowing unconfiguration... */
632 1.1 oster switch (fmt) {
633 1.1 oster case S_IFCHR:
634 1.1 oster rs->sc_dkdev.dk_copenmask &= ~(1 << part);
635 1.1 oster break;
636 1.1 oster
637 1.1 oster case S_IFBLK:
638 1.1 oster rs->sc_dkdev.dk_bopenmask &= ~(1 << part);
639 1.1 oster break;
640 1.1 oster }
641 1.1 oster rs->sc_dkdev.dk_openmask =
642 1.1 oster rs->sc_dkdev.dk_copenmask | rs->sc_dkdev.dk_bopenmask;
643 1.13 oster
644 1.13 oster if ((rs->sc_dkdev.dk_openmask == 0) &&
645 1.13 oster ((rs->sc_flags & RAIDF_INITED) != 0)) {
646 1.13 oster /* Last one... device is not unconfigured yet.
647 1.13 oster Device shutdown has taken care of setting the
648 1.13 oster clean bits if RAIDF_INITED is not set
649 1.13 oster mark things as clean... */
650 1.54 oster #ifdef DEBUG
651 1.54 oster printf("Last one on raid%d. Updating status.\n",unit);
652 1.54 oster #endif
653 1.13 oster rf_update_component_labels( raidPtrs[unit] );
654 1.13 oster }
655 1.1 oster
656 1.1 oster raidunlock(rs);
657 1.1 oster return (0);
658 1.1 oster
659 1.1 oster }
660 1.1 oster
661 1.1 oster void
662 1.1 oster raidstrategy(bp)
663 1.1 oster register struct buf *bp;
664 1.1 oster {
665 1.1 oster register int s;
666 1.1 oster
667 1.1 oster unsigned int raidID = raidunit(bp->b_dev);
668 1.1 oster RF_Raid_t *raidPtr;
669 1.1 oster struct raid_softc *rs = &raid_softc[raidID];
670 1.1 oster struct disklabel *lp;
671 1.9 oster int wlabel;
672 1.1 oster
673 1.30 oster if ((rs->sc_flags & RAIDF_INITED) ==0) {
674 1.30 oster bp->b_error = ENXIO;
675 1.30 oster bp->b_flags = B_ERROR;
676 1.30 oster bp->b_resid = bp->b_bcount;
677 1.30 oster biodone(bp);
678 1.1 oster return;
679 1.30 oster }
680 1.1 oster if (raidID >= numraid || !raidPtrs[raidID]) {
681 1.1 oster bp->b_error = ENODEV;
682 1.1 oster bp->b_flags |= B_ERROR;
683 1.1 oster bp->b_resid = bp->b_bcount;
684 1.1 oster biodone(bp);
685 1.1 oster return;
686 1.1 oster }
687 1.1 oster raidPtr = raidPtrs[raidID];
688 1.1 oster if (!raidPtr->valid) {
689 1.1 oster bp->b_error = ENODEV;
690 1.1 oster bp->b_flags |= B_ERROR;
691 1.1 oster bp->b_resid = bp->b_bcount;
692 1.1 oster biodone(bp);
693 1.1 oster return;
694 1.1 oster }
695 1.1 oster if (bp->b_bcount == 0) {
696 1.1 oster db1_printf(("b_bcount is zero..\n"));
697 1.1 oster biodone(bp);
698 1.1 oster return;
699 1.1 oster }
700 1.1 oster lp = rs->sc_dkdev.dk_label;
701 1.1 oster
702 1.1 oster /*
703 1.1 oster * Do bounds checking and adjust transfer. If there's an
704 1.1 oster * error, the bounds check will flag that for us.
705 1.1 oster */
706 1.1 oster
707 1.9 oster wlabel = rs->sc_flags & (RAIDF_WLABEL | RAIDF_LABELLING);
708 1.1 oster if (DISKPART(bp->b_dev) != RAW_PART)
709 1.1 oster if (bounds_check_with_label(bp, lp, wlabel) <= 0) {
710 1.1 oster db1_printf(("Bounds check failed!!:%d %d\n",
711 1.9 oster (int) bp->b_blkno, (int) wlabel));
712 1.1 oster biodone(bp);
713 1.1 oster return;
714 1.1 oster }
715 1.34 oster s = splbio();
716 1.1 oster
717 1.1 oster bp->b_resid = 0;
718 1.34 oster
719 1.34 oster /* stuff it onto our queue */
720 1.47 thorpej BUFQ_INSERT_TAIL(&rs->buf_queue, bp);
721 1.34 oster
722 1.34 oster raidstart(raidPtrs[raidID]);
723 1.34 oster
724 1.1 oster splx(s);
725 1.1 oster }
726 1.1 oster /* ARGSUSED */
727 1.1 oster int
728 1.1 oster raidread(dev, uio, flags)
729 1.9 oster dev_t dev;
730 1.1 oster struct uio *uio;
731 1.9 oster int flags;
732 1.1 oster {
733 1.9 oster int unit = raidunit(dev);
734 1.1 oster struct raid_softc *rs;
735 1.9 oster int part;
736 1.1 oster
737 1.1 oster if (unit >= numraid)
738 1.1 oster return (ENXIO);
739 1.1 oster rs = &raid_softc[unit];
740 1.1 oster
741 1.1 oster if ((rs->sc_flags & RAIDF_INITED) == 0)
742 1.1 oster return (ENXIO);
743 1.1 oster part = DISKPART(dev);
744 1.1 oster
745 1.9 oster db1_printf(("raidread: unit: %d partition: %d\n", unit, part));
746 1.1 oster
747 1.1 oster return (physio(raidstrategy, NULL, dev, B_READ, minphys, uio));
748 1.1 oster
749 1.1 oster }
750 1.1 oster /* ARGSUSED */
751 1.1 oster int
752 1.1 oster raidwrite(dev, uio, flags)
753 1.9 oster dev_t dev;
754 1.1 oster struct uio *uio;
755 1.9 oster int flags;
756 1.1 oster {
757 1.9 oster int unit = raidunit(dev);
758 1.1 oster struct raid_softc *rs;
759 1.1 oster
760 1.1 oster if (unit >= numraid)
761 1.1 oster return (ENXIO);
762 1.1 oster rs = &raid_softc[unit];
763 1.1 oster
764 1.1 oster if ((rs->sc_flags & RAIDF_INITED) == 0)
765 1.1 oster return (ENXIO);
766 1.1 oster db1_printf(("raidwrite\n"));
767 1.1 oster return (physio(raidstrategy, NULL, dev, B_WRITE, minphys, uio));
768 1.1 oster
769 1.1 oster }
770 1.1 oster
771 1.1 oster int
772 1.1 oster raidioctl(dev, cmd, data, flag, p)
773 1.9 oster dev_t dev;
774 1.9 oster u_long cmd;
775 1.1 oster caddr_t data;
776 1.9 oster int flag;
777 1.1 oster struct proc *p;
778 1.1 oster {
779 1.9 oster int unit = raidunit(dev);
780 1.9 oster int error = 0;
781 1.9 oster int part, pmask;
782 1.1 oster struct raid_softc *rs;
783 1.1 oster RF_Config_t *k_cfg, *u_cfg;
784 1.42 oster RF_Raid_t *raidPtr;
785 1.48 oster RF_RaidDisk_t *diskPtr;
786 1.41 oster RF_AccTotals_t *totals;
787 1.41 oster RF_DeviceConfig_t *d_cfg, **ucfgp;
788 1.1 oster u_char *specific_buf;
789 1.11 oster int retcode = 0;
790 1.11 oster int row;
791 1.11 oster int column;
792 1.1 oster struct rf_recon_req *rrcopy, *rr;
793 1.48 oster RF_ComponentLabel_t *clabel;
794 1.11 oster RF_ComponentLabel_t ci_label;
795 1.48 oster RF_ComponentLabel_t **clabel_ptr;
796 1.12 oster RF_SingleComponent_t *sparePtr,*componentPtr;
797 1.12 oster RF_SingleComponent_t hot_spare;
798 1.12 oster RF_SingleComponent_t component;
799 1.41 oster int i, j, d;
800 1.1 oster
801 1.1 oster if (unit >= numraid)
802 1.1 oster return (ENXIO);
803 1.1 oster rs = &raid_softc[unit];
804 1.42 oster raidPtr = raidPtrs[unit];
805 1.1 oster
806 1.9 oster db1_printf(("raidioctl: %d %d %d %d\n", (int) dev,
807 1.9 oster (int) DISKPART(dev), (int) unit, (int) cmd));
808 1.1 oster
809 1.1 oster /* Must be open for writes for these commands... */
810 1.1 oster switch (cmd) {
811 1.1 oster case DIOCSDINFO:
812 1.1 oster case DIOCWDINFO:
813 1.1 oster case DIOCWLABEL:
814 1.1 oster if ((flag & FWRITE) == 0)
815 1.1 oster return (EBADF);
816 1.1 oster }
817 1.1 oster
818 1.1 oster /* Must be initialized for these... */
819 1.1 oster switch (cmd) {
820 1.1 oster case DIOCGDINFO:
821 1.1 oster case DIOCSDINFO:
822 1.1 oster case DIOCWDINFO:
823 1.1 oster case DIOCGPART:
824 1.1 oster case DIOCWLABEL:
825 1.1 oster case DIOCGDEFLABEL:
826 1.1 oster case RAIDFRAME_SHUTDOWN:
827 1.1 oster case RAIDFRAME_REWRITEPARITY:
828 1.1 oster case RAIDFRAME_GET_INFO:
829 1.1 oster case RAIDFRAME_RESET_ACCTOTALS:
830 1.1 oster case RAIDFRAME_GET_ACCTOTALS:
831 1.1 oster case RAIDFRAME_KEEP_ACCTOTALS:
832 1.1 oster case RAIDFRAME_GET_SIZE:
833 1.1 oster case RAIDFRAME_FAIL_DISK:
834 1.1 oster case RAIDFRAME_COPYBACK:
835 1.37 oster case RAIDFRAME_CHECK_RECON_STATUS:
836 1.11 oster case RAIDFRAME_GET_COMPONENT_LABEL:
837 1.11 oster case RAIDFRAME_SET_COMPONENT_LABEL:
838 1.11 oster case RAIDFRAME_ADD_HOT_SPARE:
839 1.11 oster case RAIDFRAME_REMOVE_HOT_SPARE:
840 1.11 oster case RAIDFRAME_INIT_LABELS:
841 1.12 oster case RAIDFRAME_REBUILD_IN_PLACE:
842 1.23 oster case RAIDFRAME_CHECK_PARITY:
843 1.37 oster case RAIDFRAME_CHECK_PARITYREWRITE_STATUS:
844 1.37 oster case RAIDFRAME_CHECK_COPYBACK_STATUS:
845 1.48 oster case RAIDFRAME_SET_AUTOCONFIG:
846 1.48 oster case RAIDFRAME_SET_ROOT:
847 1.1 oster if ((rs->sc_flags & RAIDF_INITED) == 0)
848 1.1 oster return (ENXIO);
849 1.1 oster }
850 1.9 oster
851 1.1 oster switch (cmd) {
852 1.1 oster
853 1.1 oster /* configure the system */
854 1.1 oster case RAIDFRAME_CONFIGURE:
855 1.48 oster
856 1.48 oster if (raidPtr->valid) {
857 1.48 oster /* There is a valid RAID set running on this unit! */
858 1.48 oster printf("raid%d: Device already configured!\n",unit);
859 1.48 oster }
860 1.48 oster
861 1.1 oster /* copy-in the configuration information */
862 1.1 oster /* data points to a pointer to the configuration structure */
863 1.43 oster
864 1.9 oster u_cfg = *((RF_Config_t **) data);
865 1.9 oster RF_Malloc(k_cfg, sizeof(RF_Config_t), (RF_Config_t *));
866 1.1 oster if (k_cfg == NULL) {
867 1.9 oster return (ENOMEM);
868 1.1 oster }
869 1.9 oster retcode = copyin((caddr_t) u_cfg, (caddr_t) k_cfg,
870 1.9 oster sizeof(RF_Config_t));
871 1.1 oster if (retcode) {
872 1.33 oster RF_Free(k_cfg, sizeof(RF_Config_t));
873 1.46 oster db1_printf(("rf_ioctl: retcode=%d copyin.1\n",
874 1.9 oster retcode));
875 1.9 oster return (retcode);
876 1.1 oster }
877 1.9 oster /* allocate a buffer for the layout-specific data, and copy it
878 1.9 oster * in */
879 1.1 oster if (k_cfg->layoutSpecificSize) {
880 1.9 oster if (k_cfg->layoutSpecificSize > 10000) {
881 1.1 oster /* sanity check */
882 1.33 oster RF_Free(k_cfg, sizeof(RF_Config_t));
883 1.9 oster return (EINVAL);
884 1.1 oster }
885 1.9 oster RF_Malloc(specific_buf, k_cfg->layoutSpecificSize,
886 1.9 oster (u_char *));
887 1.1 oster if (specific_buf == NULL) {
888 1.9 oster RF_Free(k_cfg, sizeof(RF_Config_t));
889 1.9 oster return (ENOMEM);
890 1.1 oster }
891 1.9 oster retcode = copyin(k_cfg->layoutSpecific,
892 1.9 oster (caddr_t) specific_buf,
893 1.9 oster k_cfg->layoutSpecificSize);
894 1.1 oster if (retcode) {
895 1.33 oster RF_Free(k_cfg, sizeof(RF_Config_t));
896 1.42 oster RF_Free(specific_buf,
897 1.42 oster k_cfg->layoutSpecificSize);
898 1.46 oster db1_printf(("rf_ioctl: retcode=%d copyin.2\n",
899 1.9 oster retcode));
900 1.9 oster return (retcode);
901 1.1 oster }
902 1.9 oster } else
903 1.9 oster specific_buf = NULL;
904 1.1 oster k_cfg->layoutSpecific = specific_buf;
905 1.9 oster
906 1.9 oster /* should do some kind of sanity check on the configuration.
907 1.9 oster * Store the sum of all the bytes in the last byte? */
908 1.1 oster
909 1.1 oster /* configure the system */
910 1.1 oster
911 1.48 oster /*
912 1.48 oster * Clear the entire RAID descriptor, just to make sure
913 1.48 oster * there is no stale data left in the case of a
914 1.48 oster * reconfiguration
915 1.48 oster */
916 1.48 oster bzero((char *) raidPtr, sizeof(RF_Raid_t));
917 1.42 oster raidPtr->raidid = unit;
918 1.20 oster
919 1.48 oster retcode = rf_Configure(raidPtr, k_cfg, NULL);
920 1.1 oster
921 1.40 oster if (retcode == 0) {
922 1.37 oster
923 1.40 oster /* allow this many simultaneous IO's to
924 1.40 oster this RAID device */
925 1.42 oster raidPtr->openings = RAIDOUTSTANDING;
926 1.48 oster
927 1.59 oster raidinit(raidPtr);
928 1.59 oster rf_markalldirty(raidPtr);
929 1.9 oster }
930 1.1 oster /* free the buffers. No return code here. */
931 1.1 oster if (k_cfg->layoutSpecificSize) {
932 1.9 oster RF_Free(specific_buf, k_cfg->layoutSpecificSize);
933 1.1 oster }
934 1.9 oster RF_Free(k_cfg, sizeof(RF_Config_t));
935 1.9 oster
936 1.9 oster return (retcode);
937 1.9 oster
938 1.9 oster /* shutdown the system */
939 1.1 oster case RAIDFRAME_SHUTDOWN:
940 1.9 oster
941 1.9 oster if ((error = raidlock(rs)) != 0)
942 1.9 oster return (error);
943 1.1 oster
944 1.1 oster /*
945 1.1 oster * If somebody has a partition mounted, we shouldn't
946 1.1 oster * shutdown.
947 1.1 oster */
948 1.1 oster
949 1.1 oster part = DISKPART(dev);
950 1.1 oster pmask = (1 << part);
951 1.9 oster if ((rs->sc_dkdev.dk_openmask & ~pmask) ||
952 1.9 oster ((rs->sc_dkdev.dk_bopenmask & pmask) &&
953 1.9 oster (rs->sc_dkdev.dk_copenmask & pmask))) {
954 1.9 oster raidunlock(rs);
955 1.9 oster return (EBUSY);
956 1.9 oster }
957 1.11 oster
958 1.42 oster retcode = rf_Shutdown(raidPtr);
959 1.1 oster
960 1.1 oster pool_destroy(&rs->sc_cbufpool);
961 1.1 oster
962 1.1 oster /* It's no longer initialized... */
963 1.1 oster rs->sc_flags &= ~RAIDF_INITED;
964 1.16 oster
965 1.9 oster /* Detach the disk. */
966 1.9 oster disk_detach(&rs->sc_dkdev);
967 1.1 oster
968 1.1 oster raidunlock(rs);
969 1.1 oster
970 1.9 oster return (retcode);
971 1.11 oster case RAIDFRAME_GET_COMPONENT_LABEL:
972 1.48 oster clabel_ptr = (RF_ComponentLabel_t **) data;
973 1.11 oster /* need to read the component label for the disk indicated
974 1.48 oster by row,column in clabel */
975 1.11 oster
976 1.11 oster /* For practice, let's get it directly fromdisk, rather
977 1.11 oster than from the in-core copy */
978 1.48 oster RF_Malloc( clabel, sizeof( RF_ComponentLabel_t ),
979 1.11 oster (RF_ComponentLabel_t *));
980 1.48 oster if (clabel == NULL)
981 1.11 oster return (ENOMEM);
982 1.11 oster
983 1.48 oster bzero((char *) clabel, sizeof(RF_ComponentLabel_t));
984 1.11 oster
985 1.48 oster retcode = copyin( *clabel_ptr, clabel,
986 1.11 oster sizeof(RF_ComponentLabel_t));
987 1.11 oster
988 1.11 oster if (retcode) {
989 1.48 oster RF_Free( clabel, sizeof(RF_ComponentLabel_t));
990 1.11 oster return(retcode);
991 1.11 oster }
992 1.11 oster
993 1.48 oster row = clabel->row;
994 1.48 oster column = clabel->column;
995 1.26 oster
996 1.42 oster if ((row < 0) || (row >= raidPtr->numRow) ||
997 1.42 oster (column < 0) || (column >= raidPtr->numCol)) {
998 1.48 oster RF_Free( clabel, sizeof(RF_ComponentLabel_t));
999 1.26 oster return(EINVAL);
1000 1.11 oster }
1001 1.11 oster
1002 1.48 oster raidread_component_label(raidPtr->Disks[row][column].dev,
1003 1.48 oster raidPtr->raid_cinfo[row][column].ci_vp,
1004 1.48 oster clabel );
1005 1.11 oster
1006 1.48 oster retcode = copyout((caddr_t) clabel,
1007 1.48 oster (caddr_t) *clabel_ptr,
1008 1.11 oster sizeof(RF_ComponentLabel_t));
1009 1.48 oster RF_Free( clabel, sizeof(RF_ComponentLabel_t));
1010 1.11 oster return (retcode);
1011 1.11 oster
1012 1.11 oster case RAIDFRAME_SET_COMPONENT_LABEL:
1013 1.48 oster clabel = (RF_ComponentLabel_t *) data;
1014 1.11 oster
1015 1.11 oster /* XXX check the label for valid stuff... */
1016 1.11 oster /* Note that some things *should not* get modified --
1017 1.11 oster the user should be re-initing the labels instead of
1018 1.11 oster trying to patch things.
1019 1.11 oster */
1020 1.11 oster
1021 1.11 oster printf("Got component label:\n");
1022 1.48 oster printf("Version: %d\n",clabel->version);
1023 1.48 oster printf("Serial Number: %d\n",clabel->serial_number);
1024 1.48 oster printf("Mod counter: %d\n",clabel->mod_counter);
1025 1.48 oster printf("Row: %d\n", clabel->row);
1026 1.48 oster printf("Column: %d\n", clabel->column);
1027 1.48 oster printf("Num Rows: %d\n", clabel->num_rows);
1028 1.48 oster printf("Num Columns: %d\n", clabel->num_columns);
1029 1.48 oster printf("Clean: %d\n", clabel->clean);
1030 1.48 oster printf("Status: %d\n", clabel->status);
1031 1.11 oster
1032 1.48 oster row = clabel->row;
1033 1.48 oster column = clabel->column;
1034 1.12 oster
1035 1.42 oster if ((row < 0) || (row >= raidPtr->numRow) ||
1036 1.42 oster (column < 0) || (column >= raidPtr->numCol)) {
1037 1.12 oster return(EINVAL);
1038 1.11 oster }
1039 1.12 oster
1040 1.12 oster /* XXX this isn't allowed to do anything for now :-) */
1041 1.48 oster
1042 1.48 oster /* XXX and before it is, we need to fill in the rest
1043 1.48 oster of the fields!?!?!?! */
1044 1.12 oster #if 0
1045 1.11 oster raidwrite_component_label(
1046 1.42 oster raidPtr->Disks[row][column].dev,
1047 1.42 oster raidPtr->raid_cinfo[row][column].ci_vp,
1048 1.48 oster clabel );
1049 1.12 oster #endif
1050 1.12 oster return (0);
1051 1.11 oster
1052 1.11 oster case RAIDFRAME_INIT_LABELS:
1053 1.48 oster clabel = (RF_ComponentLabel_t *) data;
1054 1.11 oster /*
1055 1.11 oster we only want the serial number from
1056 1.11 oster the above. We get all the rest of the information
1057 1.11 oster from the config that was used to create this RAID
1058 1.11 oster set.
1059 1.11 oster */
1060 1.12 oster
1061 1.48 oster raidPtr->serial_number = clabel->serial_number;
1062 1.51 oster
1063 1.51 oster raid_init_component_label(raidPtr, &ci_label);
1064 1.51 oster ci_label.serial_number = clabel->serial_number;
1065 1.11 oster
1066 1.42 oster for(row=0;row<raidPtr->numRow;row++) {
1067 1.11 oster ci_label.row = row;
1068 1.42 oster for(column=0;column<raidPtr->numCol;column++) {
1069 1.48 oster diskPtr = &raidPtr->Disks[row][column];
1070 1.48 oster ci_label.partitionSize = diskPtr->partitionSize;
1071 1.11 oster ci_label.column = column;
1072 1.11 oster raidwrite_component_label(
1073 1.42 oster raidPtr->Disks[row][column].dev,
1074 1.42 oster raidPtr->raid_cinfo[row][column].ci_vp,
1075 1.11 oster &ci_label );
1076 1.11 oster }
1077 1.11 oster }
1078 1.11 oster
1079 1.11 oster return (retcode);
1080 1.48 oster case RAIDFRAME_SET_AUTOCONFIG:
1081 1.48 oster d = rf_set_autoconfig(raidPtr, *data);
1082 1.48 oster printf("New autoconfig value is: %d\n", d);
1083 1.48 oster *data = d;
1084 1.48 oster return (retcode);
1085 1.48 oster
1086 1.48 oster case RAIDFRAME_SET_ROOT:
1087 1.48 oster d = rf_set_rootpartition(raidPtr, *data);
1088 1.48 oster printf("New rootpartition value is: %d\n", d);
1089 1.48 oster *data = d;
1090 1.48 oster return (retcode);
1091 1.9 oster
1092 1.1 oster /* initialize all parity */
1093 1.1 oster case RAIDFRAME_REWRITEPARITY:
1094 1.1 oster
1095 1.42 oster if (raidPtr->Layout.map->faultsTolerated == 0) {
1096 1.17 oster /* Parity for RAID 0 is trivially correct */
1097 1.42 oster raidPtr->parity_good = RF_RAID_CLEAN;
1098 1.17 oster return(0);
1099 1.17 oster }
1100 1.37 oster
1101 1.42 oster if (raidPtr->parity_rewrite_in_progress == 1) {
1102 1.37 oster /* Re-write is already in progress! */
1103 1.37 oster return(EINVAL);
1104 1.37 oster }
1105 1.27 oster
1106 1.42 oster retcode = RF_CREATE_THREAD(raidPtr->parity_rewrite_thread,
1107 1.37 oster rf_RewriteParityThread,
1108 1.42 oster raidPtr,"raid_parity");
1109 1.9 oster return (retcode);
1110 1.9 oster
1111 1.11 oster
1112 1.11 oster case RAIDFRAME_ADD_HOT_SPARE:
1113 1.12 oster sparePtr = (RF_SingleComponent_t *) data;
1114 1.12 oster memcpy( &hot_spare, sparePtr, sizeof(RF_SingleComponent_t));
1115 1.12 oster printf("Adding spare\n");
1116 1.42 oster retcode = rf_add_hot_spare(raidPtr, &hot_spare);
1117 1.11 oster return(retcode);
1118 1.11 oster
1119 1.11 oster case RAIDFRAME_REMOVE_HOT_SPARE:
1120 1.11 oster return(retcode);
1121 1.11 oster
1122 1.12 oster case RAIDFRAME_REBUILD_IN_PLACE:
1123 1.24 oster
1124 1.42 oster if (raidPtr->Layout.map->faultsTolerated == 0) {
1125 1.24 oster /* Can't do this on a RAID 0!! */
1126 1.24 oster return(EINVAL);
1127 1.24 oster }
1128 1.24 oster
1129 1.42 oster if (raidPtr->recon_in_progress == 1) {
1130 1.37 oster /* a reconstruct is already in progress! */
1131 1.37 oster return(EINVAL);
1132 1.37 oster }
1133 1.37 oster
1134 1.12 oster componentPtr = (RF_SingleComponent_t *) data;
1135 1.12 oster memcpy( &component, componentPtr,
1136 1.12 oster sizeof(RF_SingleComponent_t));
1137 1.12 oster row = component.row;
1138 1.12 oster column = component.column;
1139 1.12 oster printf("Rebuild: %d %d\n",row, column);
1140 1.42 oster if ((row < 0) || (row >= raidPtr->numRow) ||
1141 1.42 oster (column < 0) || (column >= raidPtr->numCol)) {
1142 1.12 oster return(EINVAL);
1143 1.12 oster }
1144 1.37 oster
1145 1.37 oster RF_Malloc(rrcopy, sizeof(*rrcopy), (struct rf_recon_req *));
1146 1.38 oster if (rrcopy == NULL)
1147 1.38 oster return(ENOMEM);
1148 1.37 oster
1149 1.42 oster rrcopy->raidPtr = (void *) raidPtr;
1150 1.37 oster rrcopy->row = row;
1151 1.37 oster rrcopy->col = column;
1152 1.37 oster
1153 1.42 oster retcode = RF_CREATE_THREAD(raidPtr->recon_thread,
1154 1.37 oster rf_ReconstructInPlaceThread,
1155 1.37 oster rrcopy,"raid_reconip");
1156 1.12 oster return(retcode);
1157 1.12 oster
1158 1.1 oster case RAIDFRAME_GET_INFO:
1159 1.42 oster if (!raidPtr->valid)
1160 1.41 oster return (ENODEV);
1161 1.41 oster ucfgp = (RF_DeviceConfig_t **) data;
1162 1.41 oster RF_Malloc(d_cfg, sizeof(RF_DeviceConfig_t),
1163 1.41 oster (RF_DeviceConfig_t *));
1164 1.41 oster if (d_cfg == NULL)
1165 1.41 oster return (ENOMEM);
1166 1.41 oster bzero((char *) d_cfg, sizeof(RF_DeviceConfig_t));
1167 1.42 oster d_cfg->rows = raidPtr->numRow;
1168 1.42 oster d_cfg->cols = raidPtr->numCol;
1169 1.42 oster d_cfg->ndevs = raidPtr->numRow * raidPtr->numCol;
1170 1.41 oster if (d_cfg->ndevs >= RF_MAX_DISKS) {
1171 1.41 oster RF_Free(d_cfg, sizeof(RF_DeviceConfig_t));
1172 1.41 oster return (ENOMEM);
1173 1.41 oster }
1174 1.42 oster d_cfg->nspares = raidPtr->numSpare;
1175 1.41 oster if (d_cfg->nspares >= RF_MAX_DISKS) {
1176 1.41 oster RF_Free(d_cfg, sizeof(RF_DeviceConfig_t));
1177 1.41 oster return (ENOMEM);
1178 1.41 oster }
1179 1.42 oster d_cfg->maxqdepth = raidPtr->maxQueueDepth;
1180 1.41 oster d = 0;
1181 1.41 oster for (i = 0; i < d_cfg->rows; i++) {
1182 1.41 oster for (j = 0; j < d_cfg->cols; j++) {
1183 1.42 oster d_cfg->devs[d] = raidPtr->Disks[i][j];
1184 1.41 oster d++;
1185 1.1 oster }
1186 1.41 oster }
1187 1.41 oster for (j = d_cfg->cols, i = 0; i < d_cfg->nspares; i++, j++) {
1188 1.42 oster d_cfg->spares[i] = raidPtr->Disks[0][j];
1189 1.41 oster }
1190 1.41 oster retcode = copyout((caddr_t) d_cfg, (caddr_t) * ucfgp,
1191 1.41 oster sizeof(RF_DeviceConfig_t));
1192 1.41 oster RF_Free(d_cfg, sizeof(RF_DeviceConfig_t));
1193 1.41 oster
1194 1.41 oster return (retcode);
1195 1.9 oster
1196 1.22 oster case RAIDFRAME_CHECK_PARITY:
1197 1.42 oster *(int *) data = raidPtr->parity_good;
1198 1.22 oster return (0);
1199 1.41 oster
1200 1.1 oster case RAIDFRAME_RESET_ACCTOTALS:
1201 1.42 oster bzero(&raidPtr->acc_totals, sizeof(raidPtr->acc_totals));
1202 1.41 oster return (0);
1203 1.9 oster
1204 1.1 oster case RAIDFRAME_GET_ACCTOTALS:
1205 1.41 oster totals = (RF_AccTotals_t *) data;
1206 1.42 oster *totals = raidPtr->acc_totals;
1207 1.41 oster return (0);
1208 1.9 oster
1209 1.1 oster case RAIDFRAME_KEEP_ACCTOTALS:
1210 1.42 oster raidPtr->keep_acc_totals = *(int *)data;
1211 1.41 oster return (0);
1212 1.9 oster
1213 1.1 oster case RAIDFRAME_GET_SIZE:
1214 1.42 oster *(int *) data = raidPtr->totalSectors;
1215 1.9 oster return (0);
1216 1.1 oster
1217 1.1 oster /* fail a disk & optionally start reconstruction */
1218 1.1 oster case RAIDFRAME_FAIL_DISK:
1219 1.24 oster
1220 1.42 oster if (raidPtr->Layout.map->faultsTolerated == 0) {
1221 1.24 oster /* Can't do this on a RAID 0!! */
1222 1.24 oster return(EINVAL);
1223 1.24 oster }
1224 1.24 oster
1225 1.1 oster rr = (struct rf_recon_req *) data;
1226 1.9 oster
1227 1.42 oster if (rr->row < 0 || rr->row >= raidPtr->numRow
1228 1.42 oster || rr->col < 0 || rr->col >= raidPtr->numCol)
1229 1.9 oster return (EINVAL);
1230 1.1 oster
1231 1.12 oster printf("raid%d: Failing the disk: row: %d col: %d\n",
1232 1.12 oster unit, rr->row, rr->col);
1233 1.9 oster
1234 1.9 oster /* make a copy of the recon request so that we don't rely on
1235 1.9 oster * the user's buffer */
1236 1.1 oster RF_Malloc(rrcopy, sizeof(*rrcopy), (struct rf_recon_req *));
1237 1.38 oster if (rrcopy == NULL)
1238 1.38 oster return(ENOMEM);
1239 1.1 oster bcopy(rr, rrcopy, sizeof(*rr));
1240 1.42 oster rrcopy->raidPtr = (void *) raidPtr;
1241 1.1 oster
1242 1.42 oster retcode = RF_CREATE_THREAD(raidPtr->recon_thread,
1243 1.37 oster rf_ReconThread,
1244 1.37 oster rrcopy,"raid_recon");
1245 1.9 oster return (0);
1246 1.9 oster
1247 1.9 oster /* invoke a copyback operation after recon on whatever disk
1248 1.9 oster * needs it, if any */
1249 1.9 oster case RAIDFRAME_COPYBACK:
1250 1.24 oster
1251 1.42 oster if (raidPtr->Layout.map->faultsTolerated == 0) {
1252 1.24 oster /* This makes no sense on a RAID 0!! */
1253 1.24 oster return(EINVAL);
1254 1.24 oster }
1255 1.24 oster
1256 1.42 oster if (raidPtr->copyback_in_progress == 1) {
1257 1.37 oster /* Copyback is already in progress! */
1258 1.37 oster return(EINVAL);
1259 1.37 oster }
1260 1.27 oster
1261 1.42 oster retcode = RF_CREATE_THREAD(raidPtr->copyback_thread,
1262 1.37 oster rf_CopybackThread,
1263 1.42 oster raidPtr,"raid_copyback");
1264 1.37 oster return (retcode);
1265 1.9 oster
1266 1.1 oster /* return the percentage completion of reconstruction */
1267 1.37 oster case RAIDFRAME_CHECK_RECON_STATUS:
1268 1.42 oster if (raidPtr->Layout.map->faultsTolerated == 0) {
1269 1.24 oster /* This makes no sense on a RAID 0 */
1270 1.24 oster return(EINVAL);
1271 1.24 oster }
1272 1.37 oster row = 0; /* XXX we only consider a single row... */
1273 1.42 oster if (raidPtr->status[row] != rf_rs_reconstructing)
1274 1.1 oster *(int *) data = 100;
1275 1.9 oster else
1276 1.42 oster *(int *) data = raidPtr->reconControl[row]->percentComplete;
1277 1.9 oster return (0);
1278 1.9 oster
1279 1.37 oster case RAIDFRAME_CHECK_PARITYREWRITE_STATUS:
1280 1.42 oster if (raidPtr->Layout.map->faultsTolerated == 0) {
1281 1.37 oster /* This makes no sense on a RAID 0 */
1282 1.37 oster return(EINVAL);
1283 1.37 oster }
1284 1.42 oster if (raidPtr->parity_rewrite_in_progress == 1) {
1285 1.42 oster *(int *) data = 100 * raidPtr->parity_rewrite_stripes_done / raidPtr->Layout.numStripe;
1286 1.37 oster } else {
1287 1.37 oster *(int *) data = 100;
1288 1.37 oster }
1289 1.37 oster return (0);
1290 1.37 oster
1291 1.37 oster case RAIDFRAME_CHECK_COPYBACK_STATUS:
1292 1.42 oster if (raidPtr->Layout.map->faultsTolerated == 0) {
1293 1.37 oster /* This makes no sense on a RAID 0 */
1294 1.37 oster return(EINVAL);
1295 1.37 oster }
1296 1.42 oster if (raidPtr->copyback_in_progress == 1) {
1297 1.42 oster *(int *) data = 100 * raidPtr->copyback_stripes_done /
1298 1.42 oster raidPtr->Layout.numStripe;
1299 1.37 oster } else {
1300 1.37 oster *(int *) data = 100;
1301 1.37 oster }
1302 1.37 oster return (0);
1303 1.37 oster
1304 1.37 oster
1305 1.9 oster /* the sparetable daemon calls this to wait for the kernel to
1306 1.9 oster * need a spare table. this ioctl does not return until a
1307 1.9 oster * spare table is needed. XXX -- calling mpsleep here in the
1308 1.9 oster * ioctl code is almost certainly wrong and evil. -- XXX XXX
1309 1.9 oster * -- I should either compute the spare table in the kernel,
1310 1.9 oster * or have a different -- XXX XXX -- interface (a different
1311 1.42 oster * character device) for delivering the table -- XXX */
1312 1.1 oster #if 0
1313 1.1 oster case RAIDFRAME_SPARET_WAIT:
1314 1.1 oster RF_LOCK_MUTEX(rf_sparet_wait_mutex);
1315 1.9 oster while (!rf_sparet_wait_queue)
1316 1.9 oster mpsleep(&rf_sparet_wait_queue, (PZERO + 1) | PCATCH, "sparet wait", 0, (void *) simple_lock_addr(rf_sparet_wait_mutex), MS_LOCK_SIMPLE);
1317 1.1 oster waitreq = rf_sparet_wait_queue;
1318 1.1 oster rf_sparet_wait_queue = rf_sparet_wait_queue->next;
1319 1.1 oster RF_UNLOCK_MUTEX(rf_sparet_wait_mutex);
1320 1.9 oster
1321 1.42 oster /* structure assignment */
1322 1.42 oster *((RF_SparetWait_t *) data) = *waitreq;
1323 1.9 oster
1324 1.1 oster RF_Free(waitreq, sizeof(*waitreq));
1325 1.9 oster return (0);
1326 1.9 oster
1327 1.9 oster /* wakes up a process waiting on SPARET_WAIT and puts an error
1328 1.9 oster * code in it that will cause the dameon to exit */
1329 1.1 oster case RAIDFRAME_ABORT_SPARET_WAIT:
1330 1.1 oster RF_Malloc(waitreq, sizeof(*waitreq), (RF_SparetWait_t *));
1331 1.1 oster waitreq->fcol = -1;
1332 1.1 oster RF_LOCK_MUTEX(rf_sparet_wait_mutex);
1333 1.1 oster waitreq->next = rf_sparet_wait_queue;
1334 1.1 oster rf_sparet_wait_queue = waitreq;
1335 1.1 oster RF_UNLOCK_MUTEX(rf_sparet_wait_mutex);
1336 1.1 oster wakeup(&rf_sparet_wait_queue);
1337 1.9 oster return (0);
1338 1.1 oster
1339 1.9 oster /* used by the spare table daemon to deliver a spare table
1340 1.9 oster * into the kernel */
1341 1.1 oster case RAIDFRAME_SEND_SPARET:
1342 1.9 oster
1343 1.1 oster /* install the spare table */
1344 1.42 oster retcode = rf_SetSpareTable(raidPtr, *(void **) data);
1345 1.9 oster
1346 1.9 oster /* respond to the requestor. the return status of the spare
1347 1.9 oster * table installation is passed in the "fcol" field */
1348 1.1 oster RF_Malloc(waitreq, sizeof(*waitreq), (RF_SparetWait_t *));
1349 1.1 oster waitreq->fcol = retcode;
1350 1.1 oster RF_LOCK_MUTEX(rf_sparet_wait_mutex);
1351 1.1 oster waitreq->next = rf_sparet_resp_queue;
1352 1.1 oster rf_sparet_resp_queue = waitreq;
1353 1.1 oster wakeup(&rf_sparet_resp_queue);
1354 1.1 oster RF_UNLOCK_MUTEX(rf_sparet_wait_mutex);
1355 1.9 oster
1356 1.9 oster return (retcode);
1357 1.1 oster #endif
1358 1.1 oster
1359 1.9 oster default:
1360 1.36 oster break; /* fall through to the os-specific code below */
1361 1.1 oster
1362 1.1 oster }
1363 1.9 oster
1364 1.42 oster if (!raidPtr->valid)
1365 1.9 oster return (EINVAL);
1366 1.9 oster
1367 1.1 oster /*
1368 1.1 oster * Add support for "regular" device ioctls here.
1369 1.1 oster */
1370 1.9 oster
1371 1.1 oster switch (cmd) {
1372 1.1 oster case DIOCGDINFO:
1373 1.9 oster *(struct disklabel *) data = *(rs->sc_dkdev.dk_label);
1374 1.1 oster break;
1375 1.1 oster
1376 1.1 oster case DIOCGPART:
1377 1.9 oster ((struct partinfo *) data)->disklab = rs->sc_dkdev.dk_label;
1378 1.9 oster ((struct partinfo *) data)->part =
1379 1.1 oster &rs->sc_dkdev.dk_label->d_partitions[DISKPART(dev)];
1380 1.1 oster break;
1381 1.1 oster
1382 1.1 oster case DIOCWDINFO:
1383 1.1 oster case DIOCSDINFO:
1384 1.1 oster if ((error = raidlock(rs)) != 0)
1385 1.1 oster return (error);
1386 1.1 oster
1387 1.1 oster rs->sc_flags |= RAIDF_LABELLING;
1388 1.1 oster
1389 1.1 oster error = setdisklabel(rs->sc_dkdev.dk_label,
1390 1.9 oster (struct disklabel *) data, 0, rs->sc_dkdev.dk_cpulabel);
1391 1.1 oster if (error == 0) {
1392 1.1 oster if (cmd == DIOCWDINFO)
1393 1.1 oster error = writedisklabel(RAIDLABELDEV(dev),
1394 1.1 oster raidstrategy, rs->sc_dkdev.dk_label,
1395 1.1 oster rs->sc_dkdev.dk_cpulabel);
1396 1.1 oster }
1397 1.1 oster rs->sc_flags &= ~RAIDF_LABELLING;
1398 1.1 oster
1399 1.1 oster raidunlock(rs);
1400 1.1 oster
1401 1.1 oster if (error)
1402 1.1 oster return (error);
1403 1.1 oster break;
1404 1.1 oster
1405 1.1 oster case DIOCWLABEL:
1406 1.9 oster if (*(int *) data != 0)
1407 1.1 oster rs->sc_flags |= RAIDF_WLABEL;
1408 1.1 oster else
1409 1.1 oster rs->sc_flags &= ~RAIDF_WLABEL;
1410 1.1 oster break;
1411 1.1 oster
1412 1.1 oster case DIOCGDEFLABEL:
1413 1.42 oster raidgetdefaultlabel(raidPtr, rs,
1414 1.9 oster (struct disklabel *) data);
1415 1.1 oster break;
1416 1.1 oster
1417 1.1 oster default:
1418 1.39 oster retcode = ENOTTY;
1419 1.1 oster }
1420 1.9 oster return (retcode);
1421 1.1 oster
1422 1.1 oster }
1423 1.1 oster
1424 1.1 oster
1425 1.9 oster /* raidinit -- complete the rest of the initialization for the
1426 1.1 oster RAIDframe device. */
1427 1.1 oster
1428 1.1 oster
1429 1.59 oster static void
1430 1.59 oster raidinit(raidPtr)
1431 1.1 oster RF_Raid_t *raidPtr;
1432 1.1 oster {
1433 1.1 oster struct raid_softc *rs;
1434 1.59 oster int unit;
1435 1.1 oster
1436 1.59 oster unit = raidPtr->raidid;
1437 1.1 oster
1438 1.1 oster rs = &raid_softc[unit];
1439 1.1 oster pool_init(&rs->sc_cbufpool, sizeof(struct raidbuf), 0,
1440 1.11 oster 0, 0, "raidpl", 0, NULL, NULL, M_RAIDFRAME);
1441 1.9 oster
1442 1.1 oster
1443 1.1 oster /* XXX should check return code first... */
1444 1.1 oster rs->sc_flags |= RAIDF_INITED;
1445 1.1 oster
1446 1.9 oster sprintf(rs->sc_xname, "raid%d", unit); /* XXX doesn't check bounds. */
1447 1.1 oster
1448 1.9 oster rs->sc_dkdev.dk_name = rs->sc_xname;
1449 1.11 oster
1450 1.1 oster /* disk_attach actually creates space for the CPU disklabel, among
1451 1.9 oster * other things, so it's critical to call this *BEFORE* we try putzing
1452 1.9 oster * with disklabels. */
1453 1.11 oster
1454 1.1 oster disk_attach(&rs->sc_dkdev);
1455 1.1 oster
1456 1.1 oster /* XXX There may be a weird interaction here between this, and
1457 1.9 oster * protectedSectors, as used in RAIDframe. */
1458 1.11 oster
1459 1.9 oster rs->sc_size = raidPtr->totalSectors;
1460 1.11 oster
1461 1.1 oster }
1462 1.1 oster
1463 1.1 oster /* wake up the daemon & tell it to get us a spare table
1464 1.1 oster * XXX
1465 1.9 oster * the entries in the queues should be tagged with the raidPtr
1466 1.11 oster * so that in the extremely rare case that two recons happen at once,
1467 1.11 oster * we know for which device were requesting a spare table
1468 1.1 oster * XXX
1469 1.39 oster *
1470 1.39 oster * XXX This code is not currently used. GO
1471 1.1 oster */
1472 1.9 oster int
1473 1.9 oster rf_GetSpareTableFromDaemon(req)
1474 1.9 oster RF_SparetWait_t *req;
1475 1.9 oster {
1476 1.9 oster int retcode;
1477 1.9 oster
1478 1.9 oster RF_LOCK_MUTEX(rf_sparet_wait_mutex);
1479 1.9 oster req->next = rf_sparet_wait_queue;
1480 1.9 oster rf_sparet_wait_queue = req;
1481 1.9 oster wakeup(&rf_sparet_wait_queue);
1482 1.9 oster
1483 1.9 oster /* mpsleep unlocks the mutex */
1484 1.9 oster while (!rf_sparet_resp_queue) {
1485 1.15 oster tsleep(&rf_sparet_resp_queue, PRIBIO,
1486 1.9 oster "raidframe getsparetable", 0);
1487 1.9 oster }
1488 1.9 oster req = rf_sparet_resp_queue;
1489 1.9 oster rf_sparet_resp_queue = req->next;
1490 1.9 oster RF_UNLOCK_MUTEX(rf_sparet_wait_mutex);
1491 1.9 oster
1492 1.9 oster retcode = req->fcol;
1493 1.9 oster RF_Free(req, sizeof(*req)); /* this is not the same req as we
1494 1.9 oster * alloc'd */
1495 1.9 oster return (retcode);
1496 1.1 oster }
1497 1.39 oster
1498 1.11 oster /* a wrapper around rf_DoAccess that extracts appropriate info from the
1499 1.11 oster * bp & passes it down.
1500 1.1 oster * any calls originating in the kernel must use non-blocking I/O
1501 1.1 oster * do some extra sanity checking to return "appropriate" error values for
1502 1.1 oster * certain conditions (to make some standard utilities work)
1503 1.34 oster *
1504 1.34 oster * Formerly known as: rf_DoAccessKernel
1505 1.1 oster */
1506 1.34 oster void
1507 1.34 oster raidstart(raidPtr)
1508 1.9 oster RF_Raid_t *raidPtr;
1509 1.1 oster {
1510 1.1 oster RF_SectorCount_t num_blocks, pb, sum;
1511 1.1 oster RF_RaidAddr_t raid_addr;
1512 1.9 oster int retcode;
1513 1.1 oster struct partition *pp;
1514 1.9 oster daddr_t blocknum;
1515 1.9 oster int unit;
1516 1.1 oster struct raid_softc *rs;
1517 1.9 oster int do_async;
1518 1.34 oster struct buf *bp;
1519 1.1 oster
1520 1.1 oster unit = raidPtr->raidid;
1521 1.1 oster rs = &raid_softc[unit];
1522 1.34 oster
1523 1.56 oster /* quick check to see if anything has died recently */
1524 1.56 oster RF_LOCK_MUTEX(raidPtr->mutex);
1525 1.56 oster if (raidPtr->numNewFailures > 0) {
1526 1.56 oster rf_update_component_labels(raidPtr);
1527 1.56 oster raidPtr->numNewFailures--;
1528 1.56 oster }
1529 1.56 oster RF_UNLOCK_MUTEX(raidPtr->mutex);
1530 1.56 oster
1531 1.34 oster /* Check to see if we're at the limit... */
1532 1.34 oster RF_LOCK_MUTEX(raidPtr->mutex);
1533 1.34 oster while (raidPtr->openings > 0) {
1534 1.34 oster RF_UNLOCK_MUTEX(raidPtr->mutex);
1535 1.34 oster
1536 1.34 oster /* get the next item, if any, from the queue */
1537 1.47 thorpej if ((bp = BUFQ_FIRST(&rs->buf_queue)) == NULL) {
1538 1.34 oster /* nothing more to do */
1539 1.34 oster return;
1540 1.34 oster }
1541 1.47 thorpej BUFQ_REMOVE(&rs->buf_queue, bp);
1542 1.34 oster
1543 1.34 oster /* Ok, for the bp we have here, bp->b_blkno is relative to the
1544 1.34 oster * partition.. Need to make it absolute to the underlying
1545 1.34 oster * device.. */
1546 1.1 oster
1547 1.34 oster blocknum = bp->b_blkno;
1548 1.34 oster if (DISKPART(bp->b_dev) != RAW_PART) {
1549 1.34 oster pp = &rs->sc_dkdev.dk_label->d_partitions[DISKPART(bp->b_dev)];
1550 1.34 oster blocknum += pp->p_offset;
1551 1.34 oster }
1552 1.1 oster
1553 1.34 oster db1_printf(("Blocks: %d, %d\n", (int) bp->b_blkno,
1554 1.34 oster (int) blocknum));
1555 1.34 oster
1556 1.34 oster db1_printf(("bp->b_bcount = %d\n", (int) bp->b_bcount));
1557 1.34 oster db1_printf(("bp->b_resid = %d\n", (int) bp->b_resid));
1558 1.34 oster
1559 1.34 oster /* *THIS* is where we adjust what block we're going to...
1560 1.34 oster * but DO NOT TOUCH bp->b_blkno!!! */
1561 1.34 oster raid_addr = blocknum;
1562 1.34 oster
1563 1.34 oster num_blocks = bp->b_bcount >> raidPtr->logBytesPerSector;
1564 1.34 oster pb = (bp->b_bcount & raidPtr->sectorMask) ? 1 : 0;
1565 1.34 oster sum = raid_addr + num_blocks + pb;
1566 1.34 oster if (1 || rf_debugKernelAccess) {
1567 1.34 oster db1_printf(("raid_addr=%d sum=%d num_blocks=%d(+%d) (%d)\n",
1568 1.34 oster (int) raid_addr, (int) sum, (int) num_blocks,
1569 1.34 oster (int) pb, (int) bp->b_resid));
1570 1.34 oster }
1571 1.34 oster if ((sum > raidPtr->totalSectors) || (sum < raid_addr)
1572 1.34 oster || (sum < num_blocks) || (sum < pb)) {
1573 1.34 oster bp->b_error = ENOSPC;
1574 1.34 oster bp->b_flags |= B_ERROR;
1575 1.34 oster bp->b_resid = bp->b_bcount;
1576 1.34 oster biodone(bp);
1577 1.34 oster RF_LOCK_MUTEX(raidPtr->mutex);
1578 1.34 oster continue;
1579 1.34 oster }
1580 1.34 oster /*
1581 1.34 oster * XXX rf_DoAccess() should do this, not just DoAccessKernel()
1582 1.34 oster */
1583 1.34 oster
1584 1.34 oster if (bp->b_bcount & raidPtr->sectorMask) {
1585 1.34 oster bp->b_error = EINVAL;
1586 1.34 oster bp->b_flags |= B_ERROR;
1587 1.34 oster bp->b_resid = bp->b_bcount;
1588 1.34 oster biodone(bp);
1589 1.34 oster RF_LOCK_MUTEX(raidPtr->mutex);
1590 1.34 oster continue;
1591 1.34 oster
1592 1.34 oster }
1593 1.34 oster db1_printf(("Calling DoAccess..\n"));
1594 1.34 oster
1595 1.1 oster
1596 1.34 oster RF_LOCK_MUTEX(raidPtr->mutex);
1597 1.34 oster raidPtr->openings--;
1598 1.34 oster RF_UNLOCK_MUTEX(raidPtr->mutex);
1599 1.1 oster
1600 1.34 oster /*
1601 1.34 oster * Everything is async.
1602 1.34 oster */
1603 1.34 oster do_async = 1;
1604 1.34 oster
1605 1.34 oster /* don't ever condition on bp->b_flags & B_WRITE.
1606 1.34 oster * always condition on B_READ instead */
1607 1.34 oster
1608 1.34 oster /* XXX we're still at splbio() here... do we *really*
1609 1.34 oster need to be? */
1610 1.20 oster
1611 1.37 oster
1612 1.34 oster retcode = rf_DoAccess(raidPtr, (bp->b_flags & B_READ) ?
1613 1.34 oster RF_IO_TYPE_READ : RF_IO_TYPE_WRITE,
1614 1.34 oster do_async, raid_addr, num_blocks,
1615 1.34 oster bp->b_un.b_addr, bp, NULL, NULL,
1616 1.34 oster RF_DAG_NONBLOCKING_IO, NULL, NULL, NULL);
1617 1.20 oster
1618 1.20 oster
1619 1.20 oster RF_LOCK_MUTEX(raidPtr->mutex);
1620 1.20 oster }
1621 1.34 oster RF_UNLOCK_MUTEX(raidPtr->mutex);
1622 1.34 oster }
1623 1.20 oster
1624 1.20 oster
1625 1.7 explorer
1626 1.7 explorer
1627 1.1 oster /* invoke an I/O from kernel mode. Disk queue should be locked upon entry */
1628 1.1 oster
1629 1.9 oster int
1630 1.9 oster rf_DispatchKernelIO(queue, req)
1631 1.9 oster RF_DiskQueue_t *queue;
1632 1.9 oster RF_DiskQueueData_t *req;
1633 1.1 oster {
1634 1.9 oster int op = (req->type == RF_IO_TYPE_READ) ? B_READ : B_WRITE;
1635 1.1 oster struct buf *bp;
1636 1.9 oster struct raidbuf *raidbp = NULL;
1637 1.1 oster struct raid_softc *rs;
1638 1.9 oster int unit;
1639 1.37 oster int s;
1640 1.9 oster
1641 1.37 oster s=0;
1642 1.37 oster /* s = splbio();*/ /* want to test this */
1643 1.1 oster /* XXX along with the vnode, we also need the softc associated with
1644 1.9 oster * this device.. */
1645 1.9 oster
1646 1.1 oster req->queue = queue;
1647 1.9 oster
1648 1.1 oster unit = queue->raidPtr->raidid;
1649 1.1 oster
1650 1.9 oster db1_printf(("DispatchKernelIO unit: %d\n", unit));
1651 1.1 oster
1652 1.9 oster if (unit >= numraid) {
1653 1.9 oster printf("Invalid unit number: %d %d\n", unit, numraid);
1654 1.1 oster panic("Invalid Unit number in rf_DispatchKernelIO\n");
1655 1.1 oster }
1656 1.1 oster rs = &raid_softc[unit];
1657 1.1 oster
1658 1.1 oster /* XXX is this the right place? */
1659 1.9 oster disk_busy(&rs->sc_dkdev);
1660 1.1 oster
1661 1.1 oster bp = req->bp;
1662 1.16 oster #if 1
1663 1.9 oster /* XXX when there is a physical disk failure, someone is passing us a
1664 1.9 oster * buffer that contains old stuff!! Attempt to deal with this problem
1665 1.9 oster * without taking a performance hit... (not sure where the real bug
1666 1.9 oster * is. It's buried in RAIDframe somewhere) :-( GO ) */
1667 1.4 oster
1668 1.4 oster if (bp->b_flags & B_ERROR) {
1669 1.4 oster bp->b_flags &= ~B_ERROR;
1670 1.4 oster }
1671 1.9 oster if (bp->b_error != 0) {
1672 1.4 oster bp->b_error = 0;
1673 1.4 oster }
1674 1.16 oster #endif
1675 1.1 oster raidbp = RAIDGETBUF(rs);
1676 1.1 oster
1677 1.9 oster raidbp->rf_flags = 0; /* XXX not really used anywhere... */
1678 1.1 oster
1679 1.1 oster /*
1680 1.1 oster * context for raidiodone
1681 1.1 oster */
1682 1.1 oster raidbp->rf_obp = bp;
1683 1.1 oster raidbp->req = req;
1684 1.1 oster
1685 1.32 oster LIST_INIT(&raidbp->rf_buf.b_dep);
1686 1.32 oster
1687 1.1 oster switch (req->type) {
1688 1.9 oster case RF_IO_TYPE_NOP: /* used primarily to unlock a locked queue */
1689 1.1 oster /* XXX need to do something extra here.. */
1690 1.9 oster /* I'm leaving this in, as I've never actually seen it used,
1691 1.9 oster * and I'd like folks to report it... GO */
1692 1.1 oster printf(("WAKEUP CALLED\n"));
1693 1.1 oster queue->numOutstanding++;
1694 1.1 oster
1695 1.1 oster /* XXX need to glue the original buffer into this?? */
1696 1.1 oster
1697 1.1 oster KernelWakeupFunc(&raidbp->rf_buf);
1698 1.1 oster break;
1699 1.9 oster
1700 1.1 oster case RF_IO_TYPE_READ:
1701 1.1 oster case RF_IO_TYPE_WRITE:
1702 1.9 oster
1703 1.1 oster if (req->tracerec) {
1704 1.1 oster RF_ETIMER_START(req->tracerec->timer);
1705 1.1 oster }
1706 1.9 oster InitBP(&raidbp->rf_buf, queue->rf_cinfo->ci_vp,
1707 1.9 oster op | bp->b_flags, queue->rf_cinfo->ci_dev,
1708 1.9 oster req->sectorOffset, req->numSector,
1709 1.9 oster req->buf, KernelWakeupFunc, (void *) req,
1710 1.9 oster queue->raidPtr->logBytesPerSector, req->b_proc);
1711 1.1 oster
1712 1.1 oster if (rf_debugKernelAccess) {
1713 1.9 oster db1_printf(("dispatch: bp->b_blkno = %ld\n",
1714 1.9 oster (long) bp->b_blkno));
1715 1.1 oster }
1716 1.1 oster queue->numOutstanding++;
1717 1.1 oster queue->last_deq_sector = req->sectorOffset;
1718 1.9 oster /* acc wouldn't have been let in if there were any pending
1719 1.9 oster * reqs at any other priority */
1720 1.1 oster queue->curPriority = req->priority;
1721 1.1 oster
1722 1.1 oster db1_printf(("Going for %c to unit %d row %d col %d\n",
1723 1.9 oster req->type, unit, queue->row, queue->col));
1724 1.1 oster db1_printf(("sector %d count %d (%d bytes) %d\n",
1725 1.9 oster (int) req->sectorOffset, (int) req->numSector,
1726 1.9 oster (int) (req->numSector <<
1727 1.9 oster queue->raidPtr->logBytesPerSector),
1728 1.9 oster (int) queue->raidPtr->logBytesPerSector));
1729 1.1 oster if ((raidbp->rf_buf.b_flags & B_READ) == 0) {
1730 1.1 oster raidbp->rf_buf.b_vp->v_numoutput++;
1731 1.1 oster }
1732 1.9 oster VOP_STRATEGY(&raidbp->rf_buf);
1733 1.1 oster
1734 1.1 oster break;
1735 1.9 oster
1736 1.1 oster default:
1737 1.1 oster panic("bad req->type in rf_DispatchKernelIO");
1738 1.1 oster }
1739 1.1 oster db1_printf(("Exiting from DispatchKernelIO\n"));
1740 1.37 oster /* splx(s); */ /* want to test this */
1741 1.9 oster return (0);
1742 1.1 oster }
1743 1.9 oster /* this is the callback function associated with a I/O invoked from
1744 1.1 oster kernel code.
1745 1.1 oster */
1746 1.9 oster static void
1747 1.9 oster KernelWakeupFunc(vbp)
1748 1.9 oster struct buf *vbp;
1749 1.9 oster {
1750 1.9 oster RF_DiskQueueData_t *req = NULL;
1751 1.9 oster RF_DiskQueue_t *queue;
1752 1.9 oster struct raidbuf *raidbp = (struct raidbuf *) vbp;
1753 1.9 oster struct buf *bp;
1754 1.9 oster struct raid_softc *rs;
1755 1.9 oster int unit;
1756 1.9 oster register int s;
1757 1.9 oster
1758 1.36 oster s = splbio();
1759 1.9 oster db1_printf(("recovering the request queue:\n"));
1760 1.9 oster req = raidbp->req;
1761 1.1 oster
1762 1.9 oster bp = raidbp->rf_obp;
1763 1.1 oster
1764 1.9 oster queue = (RF_DiskQueue_t *) req->queue;
1765 1.1 oster
1766 1.9 oster if (raidbp->rf_buf.b_flags & B_ERROR) {
1767 1.9 oster bp->b_flags |= B_ERROR;
1768 1.9 oster bp->b_error = raidbp->rf_buf.b_error ?
1769 1.9 oster raidbp->rf_buf.b_error : EIO;
1770 1.9 oster }
1771 1.1 oster
1772 1.9 oster /* XXX methinks this could be wrong... */
1773 1.1 oster #if 1
1774 1.9 oster bp->b_resid = raidbp->rf_buf.b_resid;
1775 1.1 oster #endif
1776 1.1 oster
1777 1.9 oster if (req->tracerec) {
1778 1.9 oster RF_ETIMER_STOP(req->tracerec->timer);
1779 1.9 oster RF_ETIMER_EVAL(req->tracerec->timer);
1780 1.9 oster RF_LOCK_MUTEX(rf_tracing_mutex);
1781 1.9 oster req->tracerec->diskwait_us += RF_ETIMER_VAL_US(req->tracerec->timer);
1782 1.9 oster req->tracerec->phys_io_us += RF_ETIMER_VAL_US(req->tracerec->timer);
1783 1.9 oster req->tracerec->num_phys_ios++;
1784 1.9 oster RF_UNLOCK_MUTEX(rf_tracing_mutex);
1785 1.9 oster }
1786 1.9 oster bp->b_bcount = raidbp->rf_buf.b_bcount; /* XXXX ?? */
1787 1.1 oster
1788 1.9 oster unit = queue->raidPtr->raidid; /* *Much* simpler :-> */
1789 1.1 oster
1790 1.1 oster
1791 1.9 oster /* XXX Ok, let's get aggressive... If B_ERROR is set, let's go
1792 1.9 oster * ballistic, and mark the component as hosed... */
1793 1.36 oster
1794 1.9 oster if (bp->b_flags & B_ERROR) {
1795 1.9 oster /* Mark the disk as dead */
1796 1.9 oster /* but only mark it once... */
1797 1.9 oster if (queue->raidPtr->Disks[queue->row][queue->col].status ==
1798 1.9 oster rf_ds_optimal) {
1799 1.9 oster printf("raid%d: IO Error. Marking %s as failed.\n",
1800 1.9 oster unit, queue->raidPtr->Disks[queue->row][queue->col].devname);
1801 1.9 oster queue->raidPtr->Disks[queue->row][queue->col].status =
1802 1.9 oster rf_ds_failed;
1803 1.9 oster queue->raidPtr->status[queue->row] = rf_rs_degraded;
1804 1.9 oster queue->raidPtr->numFailures++;
1805 1.56 oster queue->raidPtr->numNewFailures++;
1806 1.11 oster /* XXX here we should bump the version number for each component, and write that data out */
1807 1.9 oster } else { /* Disk is already dead... */
1808 1.9 oster /* printf("Disk already marked as dead!\n"); */
1809 1.9 oster }
1810 1.4 oster
1811 1.9 oster }
1812 1.4 oster
1813 1.9 oster rs = &raid_softc[unit];
1814 1.9 oster RAIDPUTBUF(rs, raidbp);
1815 1.9 oster
1816 1.4 oster
1817 1.9 oster if (bp->b_resid == 0) {
1818 1.9 oster /* XXX is this the right place for a disk_unbusy()??!??!?!? */
1819 1.9 oster disk_unbusy(&rs->sc_dkdev, (bp->b_bcount - bp->b_resid));
1820 1.36 oster }
1821 1.1 oster
1822 1.9 oster rf_DiskIOComplete(queue, req, (bp->b_flags & B_ERROR) ? 1 : 0);
1823 1.9 oster (req->CompleteFunc) (req->argument, (bp->b_flags & B_ERROR) ? 1 : 0);
1824 1.1 oster
1825 1.36 oster splx(s);
1826 1.1 oster }
1827 1.1 oster
1828 1.1 oster
1829 1.1 oster
1830 1.1 oster /*
1831 1.1 oster * initialize a buf structure for doing an I/O in the kernel.
1832 1.1 oster */
1833 1.9 oster static void
1834 1.9 oster InitBP(
1835 1.9 oster struct buf * bp,
1836 1.9 oster struct vnode * b_vp,
1837 1.9 oster unsigned rw_flag,
1838 1.9 oster dev_t dev,
1839 1.9 oster RF_SectorNum_t startSect,
1840 1.9 oster RF_SectorCount_t numSect,
1841 1.9 oster caddr_t buf,
1842 1.9 oster void (*cbFunc) (struct buf *),
1843 1.9 oster void *cbArg,
1844 1.9 oster int logBytesPerSector,
1845 1.9 oster struct proc * b_proc)
1846 1.9 oster {
1847 1.9 oster /* bp->b_flags = B_PHYS | rw_flag; */
1848 1.9 oster bp->b_flags = B_CALL | rw_flag; /* XXX need B_PHYS here too??? */
1849 1.9 oster bp->b_bcount = numSect << logBytesPerSector;
1850 1.9 oster bp->b_bufsize = bp->b_bcount;
1851 1.9 oster bp->b_error = 0;
1852 1.9 oster bp->b_dev = dev;
1853 1.9 oster bp->b_un.b_addr = buf;
1854 1.9 oster bp->b_blkno = startSect;
1855 1.9 oster bp->b_resid = bp->b_bcount; /* XXX is this right!??!?!! */
1856 1.1 oster if (bp->b_bcount == 0) {
1857 1.1 oster panic("bp->b_bcount is zero in InitBP!!\n");
1858 1.1 oster }
1859 1.9 oster bp->b_proc = b_proc;
1860 1.9 oster bp->b_iodone = cbFunc;
1861 1.9 oster bp->b_vp = b_vp;
1862 1.9 oster
1863 1.1 oster }
1864 1.1 oster
1865 1.1 oster static void
1866 1.1 oster raidgetdefaultlabel(raidPtr, rs, lp)
1867 1.1 oster RF_Raid_t *raidPtr;
1868 1.1 oster struct raid_softc *rs;
1869 1.1 oster struct disklabel *lp;
1870 1.1 oster {
1871 1.1 oster db1_printf(("Building a default label...\n"));
1872 1.1 oster bzero(lp, sizeof(*lp));
1873 1.1 oster
1874 1.1 oster /* fabricate a label... */
1875 1.1 oster lp->d_secperunit = raidPtr->totalSectors;
1876 1.1 oster lp->d_secsize = raidPtr->bytesPerSector;
1877 1.45 oster lp->d_nsectors = raidPtr->Layout.dataSectorsPerStripe;
1878 1.1 oster lp->d_ntracks = 1;
1879 1.45 oster lp->d_ncylinders = raidPtr->totalSectors /
1880 1.45 oster (lp->d_nsectors * lp->d_ntracks);
1881 1.1 oster lp->d_secpercyl = lp->d_ntracks * lp->d_nsectors;
1882 1.1 oster
1883 1.1 oster strncpy(lp->d_typename, "raid", sizeof(lp->d_typename));
1884 1.9 oster lp->d_type = DTYPE_RAID;
1885 1.1 oster strncpy(lp->d_packname, "fictitious", sizeof(lp->d_packname));
1886 1.1 oster lp->d_rpm = 3600;
1887 1.1 oster lp->d_interleave = 1;
1888 1.1 oster lp->d_flags = 0;
1889 1.1 oster
1890 1.1 oster lp->d_partitions[RAW_PART].p_offset = 0;
1891 1.1 oster lp->d_partitions[RAW_PART].p_size = raidPtr->totalSectors;
1892 1.1 oster lp->d_partitions[RAW_PART].p_fstype = FS_UNUSED;
1893 1.1 oster lp->d_npartitions = RAW_PART + 1;
1894 1.1 oster
1895 1.1 oster lp->d_magic = DISKMAGIC;
1896 1.1 oster lp->d_magic2 = DISKMAGIC;
1897 1.1 oster lp->d_checksum = dkcksum(rs->sc_dkdev.dk_label);
1898 1.1 oster
1899 1.1 oster }
1900 1.1 oster /*
1901 1.1 oster * Read the disklabel from the raid device. If one is not present, fake one
1902 1.1 oster * up.
1903 1.1 oster */
1904 1.1 oster static void
1905 1.1 oster raidgetdisklabel(dev)
1906 1.9 oster dev_t dev;
1907 1.1 oster {
1908 1.9 oster int unit = raidunit(dev);
1909 1.1 oster struct raid_softc *rs = &raid_softc[unit];
1910 1.9 oster char *errstring;
1911 1.1 oster struct disklabel *lp = rs->sc_dkdev.dk_label;
1912 1.1 oster struct cpu_disklabel *clp = rs->sc_dkdev.dk_cpulabel;
1913 1.1 oster RF_Raid_t *raidPtr;
1914 1.1 oster
1915 1.1 oster db1_printf(("Getting the disklabel...\n"));
1916 1.1 oster
1917 1.1 oster bzero(clp, sizeof(*clp));
1918 1.1 oster
1919 1.1 oster raidPtr = raidPtrs[unit];
1920 1.1 oster
1921 1.1 oster raidgetdefaultlabel(raidPtr, rs, lp);
1922 1.1 oster
1923 1.1 oster /*
1924 1.1 oster * Call the generic disklabel extraction routine.
1925 1.1 oster */
1926 1.1 oster errstring = readdisklabel(RAIDLABELDEV(dev), raidstrategy,
1927 1.1 oster rs->sc_dkdev.dk_label, rs->sc_dkdev.dk_cpulabel);
1928 1.9 oster if (errstring)
1929 1.1 oster raidmakedisklabel(rs);
1930 1.1 oster else {
1931 1.9 oster int i;
1932 1.1 oster struct partition *pp;
1933 1.1 oster
1934 1.1 oster /*
1935 1.1 oster * Sanity check whether the found disklabel is valid.
1936 1.1 oster *
1937 1.1 oster * This is necessary since total size of the raid device
1938 1.1 oster * may vary when an interleave is changed even though exactly
1939 1.1 oster * same componets are used, and old disklabel may used
1940 1.1 oster * if that is found.
1941 1.1 oster */
1942 1.1 oster if (lp->d_secperunit != rs->sc_size)
1943 1.1 oster printf("WARNING: %s: "
1944 1.1 oster "total sector size in disklabel (%d) != "
1945 1.18 oster "the size of raid (%ld)\n", rs->sc_xname,
1946 1.18 oster lp->d_secperunit, (long) rs->sc_size);
1947 1.1 oster for (i = 0; i < lp->d_npartitions; i++) {
1948 1.1 oster pp = &lp->d_partitions[i];
1949 1.1 oster if (pp->p_offset + pp->p_size > rs->sc_size)
1950 1.1 oster printf("WARNING: %s: end of partition `%c' "
1951 1.18 oster "exceeds the size of raid (%ld)\n",
1952 1.18 oster rs->sc_xname, 'a' + i, (long) rs->sc_size);
1953 1.1 oster }
1954 1.1 oster }
1955 1.1 oster
1956 1.1 oster }
1957 1.1 oster /*
1958 1.1 oster * Take care of things one might want to take care of in the event
1959 1.1 oster * that a disklabel isn't present.
1960 1.1 oster */
1961 1.1 oster static void
1962 1.1 oster raidmakedisklabel(rs)
1963 1.1 oster struct raid_softc *rs;
1964 1.1 oster {
1965 1.1 oster struct disklabel *lp = rs->sc_dkdev.dk_label;
1966 1.1 oster db1_printf(("Making a label..\n"));
1967 1.1 oster
1968 1.1 oster /*
1969 1.1 oster * For historical reasons, if there's no disklabel present
1970 1.1 oster * the raw partition must be marked FS_BSDFFS.
1971 1.1 oster */
1972 1.1 oster
1973 1.1 oster lp->d_partitions[RAW_PART].p_fstype = FS_BSDFFS;
1974 1.1 oster
1975 1.1 oster strncpy(lp->d_packname, "default label", sizeof(lp->d_packname));
1976 1.1 oster
1977 1.1 oster lp->d_checksum = dkcksum(lp);
1978 1.1 oster }
1979 1.1 oster /*
1980 1.1 oster * Lookup the provided name in the filesystem. If the file exists,
1981 1.1 oster * is a valid block device, and isn't being used by anyone else,
1982 1.1 oster * set *vpp to the file's vnode.
1983 1.9 oster * You'll find the original of this in ccd.c
1984 1.1 oster */
1985 1.1 oster int
1986 1.1 oster raidlookup(path, p, vpp)
1987 1.9 oster char *path;
1988 1.1 oster struct proc *p;
1989 1.1 oster struct vnode **vpp; /* result */
1990 1.1 oster {
1991 1.1 oster struct nameidata nd;
1992 1.1 oster struct vnode *vp;
1993 1.1 oster struct vattr va;
1994 1.9 oster int error;
1995 1.1 oster
1996 1.1 oster NDINIT(&nd, LOOKUP, FOLLOW, UIO_SYSSPACE, path, p);
1997 1.9 oster if ((error = vn_open(&nd, FREAD | FWRITE, 0)) != 0) {
1998 1.1 oster #ifdef DEBUG
1999 1.9 oster printf("RAIDframe: vn_open returned %d\n", error);
2000 1.1 oster #endif
2001 1.1 oster return (error);
2002 1.1 oster }
2003 1.1 oster vp = nd.ni_vp;
2004 1.1 oster if (vp->v_usecount > 1) {
2005 1.1 oster VOP_UNLOCK(vp, 0);
2006 1.9 oster (void) vn_close(vp, FREAD | FWRITE, p->p_ucred, p);
2007 1.1 oster return (EBUSY);
2008 1.1 oster }
2009 1.1 oster if ((error = VOP_GETATTR(vp, &va, p->p_ucred, p)) != 0) {
2010 1.1 oster VOP_UNLOCK(vp, 0);
2011 1.9 oster (void) vn_close(vp, FREAD | FWRITE, p->p_ucred, p);
2012 1.1 oster return (error);
2013 1.1 oster }
2014 1.1 oster /* XXX: eventually we should handle VREG, too. */
2015 1.1 oster if (va.va_type != VBLK) {
2016 1.1 oster VOP_UNLOCK(vp, 0);
2017 1.9 oster (void) vn_close(vp, FREAD | FWRITE, p->p_ucred, p);
2018 1.1 oster return (ENOTBLK);
2019 1.1 oster }
2020 1.1 oster VOP_UNLOCK(vp, 0);
2021 1.1 oster *vpp = vp;
2022 1.1 oster return (0);
2023 1.1 oster }
2024 1.1 oster /*
2025 1.1 oster * Wait interruptibly for an exclusive lock.
2026 1.1 oster *
2027 1.1 oster * XXX
2028 1.1 oster * Several drivers do this; it should be abstracted and made MP-safe.
2029 1.1 oster * (Hmm... where have we seen this warning before :-> GO )
2030 1.1 oster */
2031 1.1 oster static int
2032 1.1 oster raidlock(rs)
2033 1.1 oster struct raid_softc *rs;
2034 1.1 oster {
2035 1.9 oster int error;
2036 1.1 oster
2037 1.1 oster while ((rs->sc_flags & RAIDF_LOCKED) != 0) {
2038 1.1 oster rs->sc_flags |= RAIDF_WANTED;
2039 1.9 oster if ((error =
2040 1.9 oster tsleep(rs, PRIBIO | PCATCH, "raidlck", 0)) != 0)
2041 1.1 oster return (error);
2042 1.1 oster }
2043 1.1 oster rs->sc_flags |= RAIDF_LOCKED;
2044 1.1 oster return (0);
2045 1.1 oster }
2046 1.1 oster /*
2047 1.1 oster * Unlock and wake up any waiters.
2048 1.1 oster */
2049 1.1 oster static void
2050 1.1 oster raidunlock(rs)
2051 1.1 oster struct raid_softc *rs;
2052 1.1 oster {
2053 1.1 oster
2054 1.1 oster rs->sc_flags &= ~RAIDF_LOCKED;
2055 1.1 oster if ((rs->sc_flags & RAIDF_WANTED) != 0) {
2056 1.1 oster rs->sc_flags &= ~RAIDF_WANTED;
2057 1.1 oster wakeup(rs);
2058 1.1 oster }
2059 1.11 oster }
2060 1.11 oster
2061 1.11 oster
2062 1.11 oster #define RF_COMPONENT_INFO_OFFSET 16384 /* bytes */
2063 1.11 oster #define RF_COMPONENT_INFO_SIZE 1024 /* bytes */
2064 1.11 oster
2065 1.11 oster int
2066 1.12 oster raidmarkclean(dev_t dev, struct vnode *b_vp, int mod_counter)
2067 1.12 oster {
2068 1.48 oster RF_ComponentLabel_t clabel;
2069 1.48 oster raidread_component_label(dev, b_vp, &clabel);
2070 1.48 oster clabel.mod_counter = mod_counter;
2071 1.48 oster clabel.clean = RF_RAID_CLEAN;
2072 1.48 oster raidwrite_component_label(dev, b_vp, &clabel);
2073 1.12 oster return(0);
2074 1.12 oster }
2075 1.12 oster
2076 1.12 oster
2077 1.12 oster int
2078 1.12 oster raidmarkdirty(dev_t dev, struct vnode *b_vp, int mod_counter)
2079 1.11 oster {
2080 1.48 oster RF_ComponentLabel_t clabel;
2081 1.48 oster raidread_component_label(dev, b_vp, &clabel);
2082 1.48 oster clabel.mod_counter = mod_counter;
2083 1.48 oster clabel.clean = RF_RAID_DIRTY;
2084 1.48 oster raidwrite_component_label(dev, b_vp, &clabel);
2085 1.11 oster return(0);
2086 1.11 oster }
2087 1.11 oster
2088 1.11 oster /* ARGSUSED */
2089 1.11 oster int
2090 1.48 oster raidread_component_label(dev, b_vp, clabel)
2091 1.11 oster dev_t dev;
2092 1.11 oster struct vnode *b_vp;
2093 1.48 oster RF_ComponentLabel_t *clabel;
2094 1.11 oster {
2095 1.11 oster struct buf *bp;
2096 1.11 oster int error;
2097 1.11 oster
2098 1.11 oster /* XXX should probably ensure that we don't try to do this if
2099 1.11 oster someone has changed rf_protected_sectors. */
2100 1.11 oster
2101 1.11 oster /* get a block of the appropriate size... */
2102 1.11 oster bp = geteblk((int)RF_COMPONENT_INFO_SIZE);
2103 1.11 oster bp->b_dev = dev;
2104 1.11 oster
2105 1.11 oster /* get our ducks in a row for the read */
2106 1.11 oster bp->b_blkno = RF_COMPONENT_INFO_OFFSET / DEV_BSIZE;
2107 1.11 oster bp->b_bcount = RF_COMPONENT_INFO_SIZE;
2108 1.11 oster bp->b_flags = B_BUSY | B_READ;
2109 1.11 oster bp->b_resid = RF_COMPONENT_INFO_SIZE / DEV_BSIZE;
2110 1.11 oster
2111 1.11 oster (*bdevsw[major(bp->b_dev)].d_strategy)(bp);
2112 1.11 oster
2113 1.11 oster error = biowait(bp);
2114 1.11 oster
2115 1.11 oster if (!error) {
2116 1.48 oster memcpy(clabel, bp->b_un.b_addr,
2117 1.11 oster sizeof(RF_ComponentLabel_t));
2118 1.12 oster #if 0
2119 1.48 oster print_component_label( clabel );
2120 1.11 oster #endif
2121 1.11 oster } else {
2122 1.48 oster #if 0
2123 1.11 oster printf("Failed to read RAID component label!\n");
2124 1.48 oster #endif
2125 1.11 oster }
2126 1.11 oster
2127 1.11 oster bp->b_flags = B_INVAL | B_AGE;
2128 1.11 oster brelse(bp);
2129 1.11 oster return(error);
2130 1.11 oster }
2131 1.11 oster /* ARGSUSED */
2132 1.11 oster int
2133 1.48 oster raidwrite_component_label(dev, b_vp, clabel)
2134 1.11 oster dev_t dev;
2135 1.11 oster struct vnode *b_vp;
2136 1.48 oster RF_ComponentLabel_t *clabel;
2137 1.11 oster {
2138 1.11 oster struct buf *bp;
2139 1.11 oster int error;
2140 1.11 oster
2141 1.11 oster /* get a block of the appropriate size... */
2142 1.11 oster bp = geteblk((int)RF_COMPONENT_INFO_SIZE);
2143 1.11 oster bp->b_dev = dev;
2144 1.11 oster
2145 1.11 oster /* get our ducks in a row for the write */
2146 1.11 oster bp->b_blkno = RF_COMPONENT_INFO_OFFSET / DEV_BSIZE;
2147 1.11 oster bp->b_bcount = RF_COMPONENT_INFO_SIZE;
2148 1.11 oster bp->b_flags = B_BUSY | B_WRITE;
2149 1.11 oster bp->b_resid = RF_COMPONENT_INFO_SIZE / DEV_BSIZE;
2150 1.11 oster
2151 1.11 oster memset( bp->b_un.b_addr, 0, RF_COMPONENT_INFO_SIZE );
2152 1.11 oster
2153 1.48 oster memcpy( bp->b_un.b_addr, clabel, sizeof(RF_ComponentLabel_t));
2154 1.11 oster
2155 1.11 oster (*bdevsw[major(bp->b_dev)].d_strategy)(bp);
2156 1.11 oster error = biowait(bp);
2157 1.11 oster bp->b_flags = B_INVAL | B_AGE;
2158 1.11 oster brelse(bp);
2159 1.11 oster if (error) {
2160 1.48 oster #if 1
2161 1.11 oster printf("Failed to write RAID component info!\n");
2162 1.48 oster #endif
2163 1.11 oster }
2164 1.11 oster
2165 1.11 oster return(error);
2166 1.1 oster }
2167 1.12 oster
2168 1.12 oster void
2169 1.12 oster rf_markalldirty( raidPtr )
2170 1.12 oster RF_Raid_t *raidPtr;
2171 1.12 oster {
2172 1.48 oster RF_ComponentLabel_t clabel;
2173 1.12 oster int r,c;
2174 1.12 oster
2175 1.12 oster raidPtr->mod_counter++;
2176 1.12 oster for (r = 0; r < raidPtr->numRow; r++) {
2177 1.12 oster for (c = 0; c < raidPtr->numCol; c++) {
2178 1.12 oster if (raidPtr->Disks[r][c].status != rf_ds_failed) {
2179 1.12 oster raidread_component_label(
2180 1.12 oster raidPtr->Disks[r][c].dev,
2181 1.12 oster raidPtr->raid_cinfo[r][c].ci_vp,
2182 1.48 oster &clabel);
2183 1.48 oster if (clabel.status == rf_ds_spared) {
2184 1.12 oster /* XXX do something special...
2185 1.12 oster but whatever you do, don't
2186 1.12 oster try to access it!! */
2187 1.12 oster } else {
2188 1.12 oster #if 0
2189 1.48 oster clabel.status =
2190 1.12 oster raidPtr->Disks[r][c].status;
2191 1.12 oster raidwrite_component_label(
2192 1.12 oster raidPtr->Disks[r][c].dev,
2193 1.12 oster raidPtr->raid_cinfo[r][c].ci_vp,
2194 1.48 oster &clabel);
2195 1.12 oster #endif
2196 1.12 oster raidmarkdirty(
2197 1.12 oster raidPtr->Disks[r][c].dev,
2198 1.12 oster raidPtr->raid_cinfo[r][c].ci_vp,
2199 1.12 oster raidPtr->mod_counter);
2200 1.12 oster }
2201 1.12 oster }
2202 1.12 oster }
2203 1.12 oster }
2204 1.13 oster /* printf("Component labels marked dirty.\n"); */
2205 1.12 oster #if 0
2206 1.12 oster for( c = 0; c < raidPtr->numSpare ; c++) {
2207 1.12 oster sparecol = raidPtr->numCol + c;
2208 1.12 oster if (raidPtr->Disks[r][sparecol].status == rf_ds_used_spare) {
2209 1.12 oster /*
2210 1.12 oster
2211 1.12 oster XXX this is where we get fancy and map this spare
2212 1.12 oster into it's correct spot in the array.
2213 1.12 oster
2214 1.12 oster */
2215 1.12 oster /*
2216 1.12 oster
2217 1.12 oster we claim this disk is "optimal" if it's
2218 1.12 oster rf_ds_used_spare, as that means it should be
2219 1.12 oster directly substitutable for the disk it replaced.
2220 1.12 oster We note that too...
2221 1.12 oster
2222 1.12 oster */
2223 1.12 oster
2224 1.12 oster for(i=0;i<raidPtr->numRow;i++) {
2225 1.12 oster for(j=0;j<raidPtr->numCol;j++) {
2226 1.12 oster if ((raidPtr->Disks[i][j].spareRow ==
2227 1.12 oster r) &&
2228 1.12 oster (raidPtr->Disks[i][j].spareCol ==
2229 1.12 oster sparecol)) {
2230 1.12 oster srow = r;
2231 1.12 oster scol = sparecol;
2232 1.12 oster break;
2233 1.12 oster }
2234 1.12 oster }
2235 1.12 oster }
2236 1.12 oster
2237 1.12 oster raidread_component_label(
2238 1.12 oster raidPtr->Disks[r][sparecol].dev,
2239 1.12 oster raidPtr->raid_cinfo[r][sparecol].ci_vp,
2240 1.48 oster &clabel);
2241 1.12 oster /* make sure status is noted */
2242 1.48 oster clabel.version = RF_COMPONENT_LABEL_VERSION;
2243 1.48 oster clabel.mod_counter = raidPtr->mod_counter;
2244 1.48 oster clabel.serial_number = raidPtr->serial_number;
2245 1.48 oster clabel.row = srow;
2246 1.48 oster clabel.column = scol;
2247 1.48 oster clabel.num_rows = raidPtr->numRow;
2248 1.48 oster clabel.num_columns = raidPtr->numCol;
2249 1.48 oster clabel.clean = RF_RAID_DIRTY; /* changed in a bit*/
2250 1.48 oster clabel.status = rf_ds_optimal;
2251 1.12 oster raidwrite_component_label(
2252 1.12 oster raidPtr->Disks[r][sparecol].dev,
2253 1.12 oster raidPtr->raid_cinfo[r][sparecol].ci_vp,
2254 1.48 oster &clabel);
2255 1.12 oster raidmarkclean( raidPtr->Disks[r][sparecol].dev,
2256 1.12 oster raidPtr->raid_cinfo[r][sparecol].ci_vp);
2257 1.12 oster }
2258 1.12 oster }
2259 1.12 oster
2260 1.12 oster #endif
2261 1.12 oster }
2262 1.12 oster
2263 1.13 oster
2264 1.13 oster void
2265 1.13 oster rf_update_component_labels( raidPtr )
2266 1.13 oster RF_Raid_t *raidPtr;
2267 1.13 oster {
2268 1.48 oster RF_ComponentLabel_t clabel;
2269 1.13 oster int sparecol;
2270 1.13 oster int r,c;
2271 1.13 oster int i,j;
2272 1.13 oster int srow, scol;
2273 1.13 oster
2274 1.13 oster srow = -1;
2275 1.13 oster scol = -1;
2276 1.13 oster
2277 1.13 oster /* XXX should do extra checks to make sure things really are clean,
2278 1.13 oster rather than blindly setting the clean bit... */
2279 1.13 oster
2280 1.13 oster raidPtr->mod_counter++;
2281 1.13 oster
2282 1.13 oster for (r = 0; r < raidPtr->numRow; r++) {
2283 1.13 oster for (c = 0; c < raidPtr->numCol; c++) {
2284 1.13 oster if (raidPtr->Disks[r][c].status == rf_ds_optimal) {
2285 1.13 oster raidread_component_label(
2286 1.13 oster raidPtr->Disks[r][c].dev,
2287 1.13 oster raidPtr->raid_cinfo[r][c].ci_vp,
2288 1.48 oster &clabel);
2289 1.13 oster /* make sure status is noted */
2290 1.48 oster clabel.status = rf_ds_optimal;
2291 1.57 oster /* bump the counter */
2292 1.60 oster #if 0
2293 1.57 oster clabel.mod_counter++;
2294 1.60 oster #endif
2295 1.60 oster clabel.mod_counter = raidPtr->mod_counter;
2296 1.58 oster #if 0
2297 1.58 oster /* note where this set was configured last */
2298 1.58 oster clabel.last_unit = raidPtr->raidid;
2299 1.58 oster #endif
2300 1.57 oster #if DEBUG
2301 1.57 oster if (raidPtr->mod_counter !=
2302 1.57 oster clabel.mod_counter) {
2303 1.57 oster printf("raid%d: mod_counter for row: %d col: %d not in sync\n", raidPtr->raidid, r, c);
2304 1.57 oster }
2305 1.57 oster #endif
2306 1.57 oster
2307 1.13 oster raidwrite_component_label(
2308 1.13 oster raidPtr->Disks[r][c].dev,
2309 1.13 oster raidPtr->raid_cinfo[r][c].ci_vp,
2310 1.48 oster &clabel);
2311 1.13 oster if (raidPtr->parity_good == RF_RAID_CLEAN) {
2312 1.13 oster raidmarkclean(
2313 1.13 oster raidPtr->Disks[r][c].dev,
2314 1.13 oster raidPtr->raid_cinfo[r][c].ci_vp,
2315 1.13 oster raidPtr->mod_counter);
2316 1.13 oster }
2317 1.13 oster }
2318 1.13 oster /* else we don't touch it.. */
2319 1.13 oster #if 0
2320 1.13 oster else if (raidPtr->Disks[r][c].status !=
2321 1.13 oster rf_ds_failed) {
2322 1.13 oster raidread_component_label(
2323 1.13 oster raidPtr->Disks[r][c].dev,
2324 1.13 oster raidPtr->raid_cinfo[r][c].ci_vp,
2325 1.48 oster &clabel);
2326 1.13 oster /* make sure status is noted */
2327 1.48 oster clabel.status =
2328 1.13 oster raidPtr->Disks[r][c].status;
2329 1.13 oster raidwrite_component_label(
2330 1.13 oster raidPtr->Disks[r][c].dev,
2331 1.13 oster raidPtr->raid_cinfo[r][c].ci_vp,
2332 1.48 oster &clabel);
2333 1.13 oster if (raidPtr->parity_good == RF_RAID_CLEAN) {
2334 1.13 oster raidmarkclean(
2335 1.13 oster raidPtr->Disks[r][c].dev,
2336 1.13 oster raidPtr->raid_cinfo[r][c].ci_vp,
2337 1.13 oster raidPtr->mod_counter);
2338 1.13 oster }
2339 1.13 oster }
2340 1.13 oster #endif
2341 1.13 oster }
2342 1.13 oster }
2343 1.13 oster
2344 1.13 oster for( c = 0; c < raidPtr->numSpare ; c++) {
2345 1.13 oster sparecol = raidPtr->numCol + c;
2346 1.13 oster if (raidPtr->Disks[0][sparecol].status == rf_ds_used_spare) {
2347 1.13 oster /*
2348 1.13 oster
2349 1.13 oster we claim this disk is "optimal" if it's
2350 1.13 oster rf_ds_used_spare, as that means it should be
2351 1.13 oster directly substitutable for the disk it replaced.
2352 1.13 oster We note that too...
2353 1.13 oster
2354 1.13 oster */
2355 1.13 oster
2356 1.13 oster for(i=0;i<raidPtr->numRow;i++) {
2357 1.13 oster for(j=0;j<raidPtr->numCol;j++) {
2358 1.13 oster if ((raidPtr->Disks[i][j].spareRow ==
2359 1.13 oster 0) &&
2360 1.13 oster (raidPtr->Disks[i][j].spareCol ==
2361 1.13 oster sparecol)) {
2362 1.13 oster srow = i;
2363 1.13 oster scol = j;
2364 1.13 oster break;
2365 1.13 oster }
2366 1.13 oster }
2367 1.13 oster }
2368 1.13 oster
2369 1.57 oster /* XXX shouldn't *really* need this... */
2370 1.13 oster raidread_component_label(
2371 1.13 oster raidPtr->Disks[0][sparecol].dev,
2372 1.13 oster raidPtr->raid_cinfo[0][sparecol].ci_vp,
2373 1.48 oster &clabel);
2374 1.13 oster /* make sure status is noted */
2375 1.57 oster
2376 1.57 oster raid_init_component_label(raidPtr, &clabel);
2377 1.57 oster
2378 1.48 oster clabel.mod_counter = raidPtr->mod_counter;
2379 1.48 oster clabel.row = srow;
2380 1.48 oster clabel.column = scol;
2381 1.48 oster clabel.status = rf_ds_optimal;
2382 1.57 oster
2383 1.13 oster raidwrite_component_label(
2384 1.13 oster raidPtr->Disks[0][sparecol].dev,
2385 1.13 oster raidPtr->raid_cinfo[0][sparecol].ci_vp,
2386 1.48 oster &clabel);
2387 1.13 oster if (raidPtr->parity_good == RF_RAID_CLEAN) {
2388 1.13 oster raidmarkclean( raidPtr->Disks[0][sparecol].dev,
2389 1.13 oster raidPtr->raid_cinfo[0][sparecol].ci_vp,
2390 1.13 oster raidPtr->mod_counter);
2391 1.13 oster }
2392 1.13 oster }
2393 1.13 oster }
2394 1.13 oster /* printf("Component labels updated\n"); */
2395 1.37 oster }
2396 1.37 oster
2397 1.37 oster void
2398 1.37 oster rf_ReconThread(req)
2399 1.37 oster struct rf_recon_req *req;
2400 1.37 oster {
2401 1.37 oster int s;
2402 1.37 oster RF_Raid_t *raidPtr;
2403 1.37 oster
2404 1.37 oster s = splbio();
2405 1.37 oster raidPtr = (RF_Raid_t *) req->raidPtr;
2406 1.37 oster raidPtr->recon_in_progress = 1;
2407 1.37 oster
2408 1.37 oster rf_FailDisk((RF_Raid_t *) req->raidPtr, req->row, req->col,
2409 1.37 oster ((req->flags & RF_FDFLAGS_RECON) ? 1 : 0));
2410 1.37 oster
2411 1.37 oster /* XXX get rid of this! we don't need it at all.. */
2412 1.37 oster RF_Free(req, sizeof(*req));
2413 1.37 oster
2414 1.37 oster raidPtr->recon_in_progress = 0;
2415 1.37 oster splx(s);
2416 1.37 oster
2417 1.37 oster /* That's all... */
2418 1.37 oster kthread_exit(0); /* does not return */
2419 1.37 oster }
2420 1.37 oster
2421 1.37 oster void
2422 1.37 oster rf_RewriteParityThread(raidPtr)
2423 1.37 oster RF_Raid_t *raidPtr;
2424 1.37 oster {
2425 1.37 oster int retcode;
2426 1.37 oster int s;
2427 1.37 oster
2428 1.37 oster raidPtr->parity_rewrite_in_progress = 1;
2429 1.37 oster s = splbio();
2430 1.37 oster retcode = rf_RewriteParity(raidPtr);
2431 1.37 oster splx(s);
2432 1.37 oster if (retcode) {
2433 1.37 oster printf("raid%d: Error re-writing parity!\n",raidPtr->raidid);
2434 1.37 oster } else {
2435 1.37 oster /* set the clean bit! If we shutdown correctly,
2436 1.37 oster the clean bit on each component label will get
2437 1.37 oster set */
2438 1.37 oster raidPtr->parity_good = RF_RAID_CLEAN;
2439 1.37 oster }
2440 1.37 oster raidPtr->parity_rewrite_in_progress = 0;
2441 1.37 oster
2442 1.37 oster /* That's all... */
2443 1.37 oster kthread_exit(0); /* does not return */
2444 1.37 oster }
2445 1.37 oster
2446 1.37 oster
2447 1.37 oster void
2448 1.37 oster rf_CopybackThread(raidPtr)
2449 1.37 oster RF_Raid_t *raidPtr;
2450 1.37 oster {
2451 1.37 oster int s;
2452 1.37 oster
2453 1.37 oster raidPtr->copyback_in_progress = 1;
2454 1.37 oster s = splbio();
2455 1.37 oster rf_CopybackReconstructedData(raidPtr);
2456 1.37 oster splx(s);
2457 1.37 oster raidPtr->copyback_in_progress = 0;
2458 1.37 oster
2459 1.37 oster /* That's all... */
2460 1.37 oster kthread_exit(0); /* does not return */
2461 1.37 oster }
2462 1.37 oster
2463 1.37 oster
2464 1.37 oster void
2465 1.37 oster rf_ReconstructInPlaceThread(req)
2466 1.37 oster struct rf_recon_req *req;
2467 1.37 oster {
2468 1.37 oster int retcode;
2469 1.37 oster int s;
2470 1.37 oster RF_Raid_t *raidPtr;
2471 1.37 oster
2472 1.37 oster s = splbio();
2473 1.37 oster raidPtr = req->raidPtr;
2474 1.37 oster raidPtr->recon_in_progress = 1;
2475 1.37 oster retcode = rf_ReconstructInPlace(raidPtr, req->row, req->col);
2476 1.37 oster RF_Free(req, sizeof(*req));
2477 1.37 oster raidPtr->recon_in_progress = 0;
2478 1.37 oster splx(s);
2479 1.37 oster
2480 1.37 oster /* That's all... */
2481 1.37 oster kthread_exit(0); /* does not return */
2482 1.48 oster }
2483 1.48 oster
2484 1.48 oster void
2485 1.48 oster rf_mountroot_hook(dev)
2486 1.48 oster struct device *dev;
2487 1.48 oster {
2488 1.59 oster
2489 1.48 oster }
2490 1.48 oster
2491 1.48 oster
2492 1.48 oster RF_AutoConfig_t *
2493 1.48 oster rf_find_raid_components()
2494 1.48 oster {
2495 1.48 oster struct devnametobdevmaj *dtobdm;
2496 1.48 oster struct vnode *vp;
2497 1.48 oster struct disklabel label;
2498 1.48 oster struct device *dv;
2499 1.48 oster char *cd_name;
2500 1.48 oster dev_t dev;
2501 1.48 oster int error;
2502 1.48 oster int i;
2503 1.48 oster int good_one;
2504 1.48 oster RF_ComponentLabel_t *clabel;
2505 1.48 oster RF_AutoConfig_t *ac_list;
2506 1.48 oster RF_AutoConfig_t *ac;
2507 1.48 oster
2508 1.48 oster
2509 1.48 oster /* initialize the AutoConfig list */
2510 1.48 oster ac_list = NULL;
2511 1.48 oster
2512 1.48 oster if (raidautoconfig) {
2513 1.48 oster
2514 1.48 oster /* we begin by trolling through *all* the devices on the system */
2515 1.48 oster
2516 1.48 oster for (dv = alldevs.tqh_first; dv != NULL;
2517 1.48 oster dv = dv->dv_list.tqe_next) {
2518 1.48 oster
2519 1.48 oster /* we are only interested in disks... */
2520 1.48 oster if (dv->dv_class != DV_DISK)
2521 1.48 oster continue;
2522 1.48 oster
2523 1.48 oster /* we don't care about floppies... */
2524 1.48 oster if (!strcmp(dv->dv_cfdata->cf_driver->cd_name,"fd")) {
2525 1.48 oster continue;
2526 1.48 oster }
2527 1.48 oster
2528 1.48 oster /* need to find the device_name_to_block_device_major stuff */
2529 1.48 oster cd_name = dv->dv_cfdata->cf_driver->cd_name;
2530 1.48 oster dtobdm = dev_name2blk;
2531 1.48 oster while (dtobdm->d_name && strcmp(dtobdm->d_name, cd_name)) {
2532 1.48 oster dtobdm++;
2533 1.48 oster }
2534 1.48 oster
2535 1.48 oster /* get a vnode for the raw partition of this disk */
2536 1.48 oster
2537 1.48 oster dev = MAKEDISKDEV(dtobdm->d_maj, dv->dv_unit, RAW_PART);
2538 1.48 oster if (bdevvp(dev, &vp))
2539 1.48 oster panic("RAID can't alloc vnode");
2540 1.48 oster
2541 1.48 oster error = VOP_OPEN(vp, FREAD, NOCRED, 0);
2542 1.48 oster
2543 1.48 oster if (error) {
2544 1.48 oster /* "Who cares." Continue looking
2545 1.48 oster for something that exists*/
2546 1.48 oster vput(vp);
2547 1.48 oster continue;
2548 1.48 oster }
2549 1.48 oster
2550 1.48 oster /* Ok, the disk exists. Go get the disklabel. */
2551 1.48 oster error = VOP_IOCTL(vp, DIOCGDINFO, (caddr_t)&label,
2552 1.48 oster FREAD, NOCRED, 0);
2553 1.48 oster if (error) {
2554 1.48 oster /*
2555 1.48 oster * XXX can't happen - open() would
2556 1.48 oster * have errored out (or faked up one)
2557 1.48 oster */
2558 1.48 oster printf("can't get label for dev %s%c (%d)!?!?\n",
2559 1.48 oster dv->dv_xname, 'a' + RAW_PART, error);
2560 1.48 oster }
2561 1.48 oster
2562 1.48 oster /* don't need this any more. We'll allocate it again
2563 1.48 oster a little later if we really do... */
2564 1.48 oster VOP_CLOSE(vp, FREAD, NOCRED, 0);
2565 1.48 oster vput(vp);
2566 1.48 oster
2567 1.48 oster for (i=0; i < label.d_npartitions; i++) {
2568 1.48 oster /* We only support partitions marked as RAID */
2569 1.48 oster if (label.d_partitions[i].p_fstype != FS_RAID)
2570 1.48 oster continue;
2571 1.48 oster
2572 1.48 oster dev = MAKEDISKDEV(dtobdm->d_maj, dv->dv_unit, i);
2573 1.48 oster if (bdevvp(dev, &vp))
2574 1.48 oster panic("RAID can't alloc vnode");
2575 1.48 oster
2576 1.48 oster error = VOP_OPEN(vp, FREAD, NOCRED, 0);
2577 1.48 oster if (error) {
2578 1.48 oster /* Whatever... */
2579 1.48 oster vput(vp);
2580 1.48 oster continue;
2581 1.48 oster }
2582 1.48 oster
2583 1.48 oster good_one = 0;
2584 1.48 oster
2585 1.48 oster clabel = (RF_ComponentLabel_t *)
2586 1.48 oster malloc(sizeof(RF_ComponentLabel_t),
2587 1.48 oster M_RAIDFRAME, M_NOWAIT);
2588 1.48 oster if (clabel == NULL) {
2589 1.48 oster /* XXX CLEANUP HERE */
2590 1.48 oster printf("RAID auto config: out of memory!\n");
2591 1.48 oster return(NULL); /* XXX probably should panic? */
2592 1.48 oster }
2593 1.48 oster
2594 1.48 oster if (!raidread_component_label(dev, vp, clabel)) {
2595 1.48 oster /* Got the label. Does it look reasonable? */
2596 1.49 oster if (rf_reasonable_label(clabel) &&
2597 1.54 oster (clabel->partitionSize <=
2598 1.48 oster label.d_partitions[i].p_size)) {
2599 1.48 oster #if DEBUG
2600 1.48 oster printf("Component on: %s%c: %d\n",
2601 1.48 oster dv->dv_xname, 'a'+i,
2602 1.48 oster label.d_partitions[i].p_size);
2603 1.48 oster print_component_label(clabel);
2604 1.48 oster #endif
2605 1.48 oster /* if it's reasonable, add it,
2606 1.48 oster else ignore it. */
2607 1.48 oster ac = (RF_AutoConfig_t *)
2608 1.48 oster malloc(sizeof(RF_AutoConfig_t),
2609 1.48 oster M_RAIDFRAME,
2610 1.48 oster M_NOWAIT);
2611 1.48 oster if (ac == NULL) {
2612 1.48 oster /* XXX should panic?? */
2613 1.48 oster return(NULL);
2614 1.48 oster }
2615 1.48 oster
2616 1.48 oster sprintf(ac->devname, "%s%c",
2617 1.48 oster dv->dv_xname, 'a'+i);
2618 1.48 oster ac->dev = dev;
2619 1.48 oster ac->vp = vp;
2620 1.48 oster ac->clabel = clabel;
2621 1.48 oster ac->next = ac_list;
2622 1.48 oster ac_list = ac;
2623 1.48 oster good_one = 1;
2624 1.48 oster }
2625 1.48 oster }
2626 1.48 oster if (!good_one) {
2627 1.48 oster /* cleanup */
2628 1.48 oster free(clabel, M_RAIDFRAME);
2629 1.48 oster VOP_CLOSE(vp, FREAD, NOCRED, 0);
2630 1.48 oster vput(vp);
2631 1.48 oster }
2632 1.48 oster }
2633 1.48 oster }
2634 1.48 oster }
2635 1.48 oster return(ac_list);
2636 1.48 oster }
2637 1.48 oster
2638 1.48 oster static int
2639 1.49 oster rf_reasonable_label(clabel)
2640 1.48 oster RF_ComponentLabel_t *clabel;
2641 1.48 oster {
2642 1.48 oster
2643 1.48 oster if (((clabel->version==RF_COMPONENT_LABEL_VERSION_1) ||
2644 1.48 oster (clabel->version==RF_COMPONENT_LABEL_VERSION)) &&
2645 1.48 oster ((clabel->clean == RF_RAID_CLEAN) ||
2646 1.48 oster (clabel->clean == RF_RAID_DIRTY)) &&
2647 1.48 oster clabel->row >=0 &&
2648 1.48 oster clabel->column >= 0 &&
2649 1.48 oster clabel->num_rows > 0 &&
2650 1.48 oster clabel->num_columns > 0 &&
2651 1.48 oster clabel->row < clabel->num_rows &&
2652 1.48 oster clabel->column < clabel->num_columns &&
2653 1.48 oster clabel->blockSize > 0 &&
2654 1.48 oster clabel->numBlocks > 0) {
2655 1.48 oster /* label looks reasonable enough... */
2656 1.48 oster return(1);
2657 1.48 oster }
2658 1.48 oster return(0);
2659 1.48 oster }
2660 1.48 oster
2661 1.48 oster
2662 1.48 oster void
2663 1.48 oster print_component_label(clabel)
2664 1.48 oster RF_ComponentLabel_t *clabel;
2665 1.48 oster {
2666 1.48 oster printf(" Row: %d Column: %d Num Rows: %d Num Columns: %d\n",
2667 1.48 oster clabel->row, clabel->column,
2668 1.48 oster clabel->num_rows, clabel->num_columns);
2669 1.48 oster printf(" Version: %d Serial Number: %d Mod Counter: %d\n",
2670 1.48 oster clabel->version, clabel->serial_number,
2671 1.48 oster clabel->mod_counter);
2672 1.48 oster printf(" Clean: %s Status: %d\n",
2673 1.48 oster clabel->clean ? "Yes" : "No", clabel->status );
2674 1.48 oster printf(" sectPerSU: %d SUsPerPU: %d SUsPerRU: %d\n",
2675 1.48 oster clabel->sectPerSU, clabel->SUsPerPU, clabel->SUsPerRU);
2676 1.48 oster printf(" RAID Level: %c blocksize: %d numBlocks: %d\n",
2677 1.48 oster (char) clabel->parityConfig, clabel->blockSize,
2678 1.48 oster clabel->numBlocks);
2679 1.48 oster printf(" Autoconfig: %s\n", clabel->autoconfigure ? "Yes" : "No" );
2680 1.48 oster printf(" Last configured as: raid%d\n", clabel->last_unit );
2681 1.51 oster #if 0
2682 1.51 oster printf(" Config order: %d\n", clabel->config_order);
2683 1.51 oster #endif
2684 1.48 oster
2685 1.48 oster }
2686 1.48 oster
2687 1.48 oster RF_ConfigSet_t *
2688 1.48 oster rf_create_auto_sets(ac_list)
2689 1.48 oster RF_AutoConfig_t *ac_list;
2690 1.48 oster {
2691 1.48 oster RF_AutoConfig_t *ac;
2692 1.48 oster RF_ConfigSet_t *config_sets;
2693 1.48 oster RF_ConfigSet_t *cset;
2694 1.48 oster RF_AutoConfig_t *ac_next;
2695 1.48 oster
2696 1.48 oster
2697 1.48 oster config_sets = NULL;
2698 1.48 oster
2699 1.48 oster /* Go through the AutoConfig list, and figure out which components
2700 1.48 oster belong to what sets. */
2701 1.48 oster ac = ac_list;
2702 1.48 oster while(ac!=NULL) {
2703 1.48 oster /* we're going to putz with ac->next, so save it here
2704 1.48 oster for use at the end of the loop */
2705 1.48 oster ac_next = ac->next;
2706 1.48 oster
2707 1.48 oster if (config_sets == NULL) {
2708 1.48 oster /* will need at least this one... */
2709 1.48 oster config_sets = (RF_ConfigSet_t *)
2710 1.48 oster malloc(sizeof(RF_ConfigSet_t),
2711 1.48 oster M_RAIDFRAME, M_NOWAIT);
2712 1.48 oster if (config_sets == NULL) {
2713 1.48 oster panic("rf_create_auto_sets: No memory!\n");
2714 1.48 oster }
2715 1.48 oster /* this one is easy :) */
2716 1.48 oster config_sets->ac = ac;
2717 1.48 oster config_sets->next = NULL;
2718 1.51 oster config_sets->rootable = 0;
2719 1.48 oster ac->next = NULL;
2720 1.48 oster } else {
2721 1.48 oster /* which set does this component fit into? */
2722 1.48 oster cset = config_sets;
2723 1.48 oster while(cset!=NULL) {
2724 1.49 oster if (rf_does_it_fit(cset, ac)) {
2725 1.48 oster /* looks like it matches */
2726 1.48 oster ac->next = cset->ac;
2727 1.48 oster cset->ac = ac;
2728 1.48 oster break;
2729 1.48 oster }
2730 1.48 oster cset = cset->next;
2731 1.48 oster }
2732 1.48 oster if (cset==NULL) {
2733 1.48 oster /* didn't find a match above... new set..*/
2734 1.48 oster cset = (RF_ConfigSet_t *)
2735 1.48 oster malloc(sizeof(RF_ConfigSet_t),
2736 1.48 oster M_RAIDFRAME, M_NOWAIT);
2737 1.48 oster if (cset == NULL) {
2738 1.48 oster panic("rf_create_auto_sets: No memory!\n");
2739 1.48 oster }
2740 1.48 oster cset->ac = ac;
2741 1.48 oster ac->next = NULL;
2742 1.48 oster cset->next = config_sets;
2743 1.51 oster cset->rootable = 0;
2744 1.48 oster config_sets = cset;
2745 1.48 oster }
2746 1.48 oster }
2747 1.48 oster ac = ac_next;
2748 1.48 oster }
2749 1.48 oster
2750 1.48 oster
2751 1.48 oster return(config_sets);
2752 1.48 oster }
2753 1.48 oster
2754 1.48 oster static int
2755 1.49 oster rf_does_it_fit(cset, ac)
2756 1.48 oster RF_ConfigSet_t *cset;
2757 1.48 oster RF_AutoConfig_t *ac;
2758 1.48 oster {
2759 1.48 oster RF_ComponentLabel_t *clabel1, *clabel2;
2760 1.48 oster
2761 1.48 oster /* If this one matches the *first* one in the set, that's good
2762 1.48 oster enough, since the other members of the set would have been
2763 1.48 oster through here too... */
2764 1.60 oster /* note that we are not checking partitionSize here..
2765 1.60 oster
2766 1.60 oster Note that we are also not checking the mod_counters here.
2767 1.60 oster If everything else matches execpt the mod_counter, that's
2768 1.60 oster good enough for this test. We will deal with the mod_counters
2769 1.60 oster a little later in the autoconfiguration process.
2770 1.60 oster
2771 1.60 oster (clabel1->mod_counter == clabel2->mod_counter) &&
2772 1.60 oster
2773 1.60 oster */
2774 1.48 oster
2775 1.48 oster clabel1 = cset->ac->clabel;
2776 1.48 oster clabel2 = ac->clabel;
2777 1.48 oster if ((clabel1->version == clabel2->version) &&
2778 1.48 oster (clabel1->serial_number == clabel2->serial_number) &&
2779 1.48 oster (clabel1->num_rows == clabel2->num_rows) &&
2780 1.48 oster (clabel1->num_columns == clabel2->num_columns) &&
2781 1.48 oster (clabel1->sectPerSU == clabel2->sectPerSU) &&
2782 1.48 oster (clabel1->SUsPerPU == clabel2->SUsPerPU) &&
2783 1.48 oster (clabel1->SUsPerRU == clabel2->SUsPerRU) &&
2784 1.48 oster (clabel1->parityConfig == clabel2->parityConfig) &&
2785 1.48 oster (clabel1->maxOutstanding == clabel2->maxOutstanding) &&
2786 1.48 oster (clabel1->blockSize == clabel2->blockSize) &&
2787 1.48 oster (clabel1->numBlocks == clabel2->numBlocks) &&
2788 1.48 oster (clabel1->autoconfigure == clabel2->autoconfigure) &&
2789 1.48 oster (clabel1->root_partition == clabel2->root_partition) &&
2790 1.48 oster (clabel1->last_unit == clabel2->last_unit) &&
2791 1.48 oster (clabel1->config_order == clabel2->config_order)) {
2792 1.48 oster /* if it get's here, it almost *has* to be a match */
2793 1.48 oster } else {
2794 1.48 oster /* it's not consistent with somebody in the set..
2795 1.48 oster punt */
2796 1.48 oster return(0);
2797 1.48 oster }
2798 1.48 oster /* all was fine.. it must fit... */
2799 1.48 oster return(1);
2800 1.48 oster }
2801 1.48 oster
2802 1.48 oster int
2803 1.51 oster rf_have_enough_components(cset)
2804 1.51 oster RF_ConfigSet_t *cset;
2805 1.48 oster {
2806 1.51 oster RF_AutoConfig_t *ac;
2807 1.51 oster RF_AutoConfig_t *auto_config;
2808 1.51 oster RF_ComponentLabel_t *clabel;
2809 1.51 oster int r,c;
2810 1.51 oster int num_rows;
2811 1.51 oster int num_cols;
2812 1.51 oster int num_missing;
2813 1.51 oster
2814 1.48 oster /* check to see that we have enough 'live' components
2815 1.48 oster of this set. If so, we can configure it if necessary */
2816 1.48 oster
2817 1.51 oster num_rows = cset->ac->clabel->num_rows;
2818 1.51 oster num_cols = cset->ac->clabel->num_columns;
2819 1.51 oster
2820 1.51 oster /* XXX Check for duplicate components!?!?!? */
2821 1.51 oster
2822 1.51 oster num_missing = 0;
2823 1.51 oster auto_config = cset->ac;
2824 1.51 oster
2825 1.51 oster for(r=0; r<num_rows; r++) {
2826 1.51 oster for(c=0; c<num_cols; c++) {
2827 1.51 oster ac = auto_config;
2828 1.51 oster while(ac!=NULL) {
2829 1.51 oster if (ac->clabel==NULL) {
2830 1.51 oster /* big-time bad news. */
2831 1.51 oster goto fail;
2832 1.51 oster }
2833 1.51 oster if ((ac->clabel->row == r) &&
2834 1.51 oster (ac->clabel->column == c)) {
2835 1.51 oster /* it's this one... */
2836 1.51 oster #if DEBUG
2837 1.51 oster printf("Found: %s at %d,%d\n",
2838 1.51 oster ac->devname,r,c);
2839 1.51 oster #endif
2840 1.51 oster break;
2841 1.51 oster }
2842 1.51 oster ac=ac->next;
2843 1.51 oster }
2844 1.51 oster if (ac==NULL) {
2845 1.51 oster /* Didn't find one here! */
2846 1.51 oster num_missing++;
2847 1.51 oster }
2848 1.51 oster }
2849 1.51 oster }
2850 1.51 oster
2851 1.51 oster clabel = cset->ac->clabel;
2852 1.51 oster
2853 1.51 oster if (((clabel->parityConfig == '0') && (num_missing > 0)) ||
2854 1.51 oster ((clabel->parityConfig == '1') && (num_missing > 1)) ||
2855 1.51 oster ((clabel->parityConfig == '4') && (num_missing > 1)) ||
2856 1.51 oster ((clabel->parityConfig == '5') && (num_missing > 1))) {
2857 1.51 oster /* XXX this needs to be made *much* more general */
2858 1.51 oster /* Too many failures */
2859 1.51 oster return(0);
2860 1.51 oster }
2861 1.51 oster /* otherwise, all is well, and we've got enough to take a kick
2862 1.51 oster at autoconfiguring this set */
2863 1.51 oster return(1);
2864 1.51 oster fail:
2865 1.51 oster return(0);
2866 1.51 oster
2867 1.48 oster }
2868 1.48 oster
2869 1.48 oster void
2870 1.49 oster rf_create_configuration(ac,config,raidPtr)
2871 1.48 oster RF_AutoConfig_t *ac;
2872 1.48 oster RF_Config_t *config;
2873 1.48 oster RF_Raid_t *raidPtr;
2874 1.48 oster {
2875 1.48 oster RF_ComponentLabel_t *clabel;
2876 1.48 oster
2877 1.48 oster clabel = ac->clabel;
2878 1.48 oster
2879 1.48 oster /* 1. Fill in the common stuff */
2880 1.48 oster config->numRow = clabel->num_rows;
2881 1.48 oster config->numCol = clabel->num_columns;
2882 1.48 oster config->numSpare = 0; /* XXX should this be set here? */
2883 1.48 oster config->sectPerSU = clabel->sectPerSU;
2884 1.48 oster config->SUsPerPU = clabel->SUsPerPU;
2885 1.48 oster config->SUsPerRU = clabel->SUsPerRU;
2886 1.48 oster config->parityConfig = clabel->parityConfig;
2887 1.48 oster /* XXX... */
2888 1.48 oster strcpy(config->diskQueueType,"fifo");
2889 1.48 oster config->maxOutstandingDiskReqs = clabel->maxOutstanding;
2890 1.48 oster config->layoutSpecificSize = 0; /* XXX ?? */
2891 1.48 oster
2892 1.48 oster while(ac!=NULL) {
2893 1.48 oster /* row/col values will be in range due to the checks
2894 1.48 oster in reasonable_label() */
2895 1.48 oster strcpy(config->devnames[ac->clabel->row][ac->clabel->column],
2896 1.48 oster ac->devname);
2897 1.48 oster ac = ac->next;
2898 1.48 oster }
2899 1.48 oster
2900 1.48 oster }
2901 1.48 oster
2902 1.48 oster int
2903 1.48 oster rf_set_autoconfig(raidPtr, new_value)
2904 1.48 oster RF_Raid_t *raidPtr;
2905 1.48 oster int new_value;
2906 1.48 oster {
2907 1.48 oster RF_ComponentLabel_t clabel;
2908 1.48 oster struct vnode *vp;
2909 1.48 oster dev_t dev;
2910 1.48 oster int row, column;
2911 1.48 oster
2912 1.54 oster raidPtr->autoconfigure = new_value;
2913 1.48 oster for(row=0; row<raidPtr->numRow; row++) {
2914 1.48 oster for(column=0; column<raidPtr->numCol; column++) {
2915 1.48 oster dev = raidPtr->Disks[row][column].dev;
2916 1.48 oster vp = raidPtr->raid_cinfo[row][column].ci_vp;
2917 1.48 oster raidread_component_label(dev, vp, &clabel);
2918 1.48 oster clabel.autoconfigure = new_value;
2919 1.48 oster raidwrite_component_label(dev, vp, &clabel);
2920 1.48 oster }
2921 1.48 oster }
2922 1.48 oster return(new_value);
2923 1.48 oster }
2924 1.48 oster
2925 1.48 oster int
2926 1.48 oster rf_set_rootpartition(raidPtr, new_value)
2927 1.48 oster RF_Raid_t *raidPtr;
2928 1.48 oster int new_value;
2929 1.48 oster {
2930 1.48 oster RF_ComponentLabel_t clabel;
2931 1.48 oster struct vnode *vp;
2932 1.48 oster dev_t dev;
2933 1.48 oster int row, column;
2934 1.48 oster
2935 1.54 oster raidPtr->root_partition = new_value;
2936 1.48 oster for(row=0; row<raidPtr->numRow; row++) {
2937 1.48 oster for(column=0; column<raidPtr->numCol; column++) {
2938 1.48 oster dev = raidPtr->Disks[row][column].dev;
2939 1.48 oster vp = raidPtr->raid_cinfo[row][column].ci_vp;
2940 1.48 oster raidread_component_label(dev, vp, &clabel);
2941 1.48 oster clabel.root_partition = new_value;
2942 1.48 oster raidwrite_component_label(dev, vp, &clabel);
2943 1.48 oster }
2944 1.48 oster }
2945 1.48 oster return(new_value);
2946 1.48 oster }
2947 1.48 oster
2948 1.48 oster void
2949 1.49 oster rf_release_all_vps(cset)
2950 1.48 oster RF_ConfigSet_t *cset;
2951 1.48 oster {
2952 1.48 oster RF_AutoConfig_t *ac;
2953 1.48 oster
2954 1.48 oster ac = cset->ac;
2955 1.48 oster while(ac!=NULL) {
2956 1.48 oster /* Close the vp, and give it back */
2957 1.48 oster if (ac->vp) {
2958 1.48 oster VOP_CLOSE(ac->vp, FREAD, NOCRED, 0);
2959 1.48 oster vput(ac->vp);
2960 1.48 oster }
2961 1.48 oster ac = ac->next;
2962 1.48 oster }
2963 1.48 oster }
2964 1.48 oster
2965 1.48 oster
2966 1.48 oster void
2967 1.49 oster rf_cleanup_config_set(cset)
2968 1.48 oster RF_ConfigSet_t *cset;
2969 1.48 oster {
2970 1.48 oster RF_AutoConfig_t *ac;
2971 1.48 oster RF_AutoConfig_t *next_ac;
2972 1.48 oster
2973 1.48 oster ac = cset->ac;
2974 1.48 oster while(ac!=NULL) {
2975 1.48 oster next_ac = ac->next;
2976 1.48 oster /* nuke the label */
2977 1.48 oster free(ac->clabel, M_RAIDFRAME);
2978 1.48 oster /* cleanup the config structure */
2979 1.48 oster free(ac, M_RAIDFRAME);
2980 1.48 oster /* "next.." */
2981 1.48 oster ac = next_ac;
2982 1.48 oster }
2983 1.48 oster /* and, finally, nuke the config set */
2984 1.48 oster free(cset, M_RAIDFRAME);
2985 1.48 oster }
2986 1.48 oster
2987 1.48 oster
2988 1.48 oster void
2989 1.48 oster raid_init_component_label(raidPtr, clabel)
2990 1.48 oster RF_Raid_t *raidPtr;
2991 1.48 oster RF_ComponentLabel_t *clabel;
2992 1.48 oster {
2993 1.48 oster /* current version number */
2994 1.48 oster clabel->version = RF_COMPONENT_LABEL_VERSION;
2995 1.57 oster clabel->serial_number = raidPtr->serial_number;
2996 1.48 oster clabel->mod_counter = raidPtr->mod_counter;
2997 1.48 oster clabel->num_rows = raidPtr->numRow;
2998 1.48 oster clabel->num_columns = raidPtr->numCol;
2999 1.48 oster clabel->clean = RF_RAID_DIRTY; /* not clean */
3000 1.48 oster clabel->status = rf_ds_optimal; /* "It's good!" */
3001 1.48 oster
3002 1.48 oster clabel->sectPerSU = raidPtr->Layout.sectorsPerStripeUnit;
3003 1.48 oster clabel->SUsPerPU = raidPtr->Layout.SUsPerPU;
3004 1.48 oster clabel->SUsPerRU = raidPtr->Layout.SUsPerRU;
3005 1.54 oster
3006 1.54 oster clabel->blockSize = raidPtr->bytesPerSector;
3007 1.54 oster clabel->numBlocks = raidPtr->sectorsPerDisk;
3008 1.54 oster
3009 1.48 oster /* XXX not portable */
3010 1.48 oster clabel->parityConfig = raidPtr->Layout.map->parityConfig;
3011 1.54 oster clabel->maxOutstanding = raidPtr->maxOutstanding;
3012 1.54 oster clabel->autoconfigure = raidPtr->autoconfigure;
3013 1.54 oster clabel->root_partition = raidPtr->root_partition;
3014 1.48 oster clabel->last_unit = raidPtr->raidid;
3015 1.54 oster clabel->config_order = raidPtr->config_order;
3016 1.51 oster }
3017 1.51 oster
3018 1.51 oster int
3019 1.51 oster rf_auto_config_set(cset,unit)
3020 1.51 oster RF_ConfigSet_t *cset;
3021 1.51 oster int *unit;
3022 1.51 oster {
3023 1.51 oster RF_Raid_t *raidPtr;
3024 1.51 oster RF_Config_t *config;
3025 1.51 oster int raidID;
3026 1.51 oster int retcode;
3027 1.51 oster
3028 1.51 oster printf("Starting autoconfigure on raid%d\n",raidID);
3029 1.51 oster
3030 1.51 oster retcode = 0;
3031 1.51 oster *unit = -1;
3032 1.51 oster
3033 1.51 oster /* 1. Create a config structure */
3034 1.51 oster
3035 1.51 oster config = (RF_Config_t *)malloc(sizeof(RF_Config_t),
3036 1.51 oster M_RAIDFRAME,
3037 1.51 oster M_NOWAIT);
3038 1.51 oster if (config==NULL) {
3039 1.51 oster printf("Out of mem!?!?\n");
3040 1.51 oster /* XXX do something more intelligent here. */
3041 1.51 oster return(1);
3042 1.51 oster }
3043 1.51 oster /* XXX raidID needs to be set correctly.. */
3044 1.51 oster
3045 1.51 oster /*
3046 1.51 oster 2. Figure out what RAID ID this one is supposed to live at
3047 1.51 oster See if we can get the same RAID dev that it was configured
3048 1.51 oster on last time..
3049 1.51 oster */
3050 1.51 oster
3051 1.51 oster raidID = cset->ac->clabel->last_unit;
3052 1.52 oster if ((raidID < 0) || (raidID >= numraid)) {
3053 1.51 oster /* let's not wander off into lala land. */
3054 1.51 oster raidID = numraid - 1;
3055 1.51 oster }
3056 1.51 oster if (raidPtrs[raidID]->valid != 0) {
3057 1.51 oster
3058 1.51 oster /*
3059 1.51 oster Nope... Go looking for an alternative...
3060 1.51 oster Start high so we don't immediately use raid0 if that's
3061 1.51 oster not taken.
3062 1.51 oster */
3063 1.51 oster
3064 1.51 oster for(raidID = numraid; raidID >= 0; raidID--) {
3065 1.51 oster if (raidPtrs[raidID]->valid == 0) {
3066 1.51 oster /* can use this one! */
3067 1.51 oster break;
3068 1.51 oster }
3069 1.51 oster }
3070 1.51 oster }
3071 1.51 oster
3072 1.51 oster if (raidID < 0) {
3073 1.51 oster /* punt... */
3074 1.51 oster printf("Unable to auto configure this set!\n");
3075 1.51 oster printf("(Out of RAID devs!)\n");
3076 1.51 oster return(1);
3077 1.51 oster }
3078 1.51 oster
3079 1.51 oster raidPtr = raidPtrs[raidID];
3080 1.51 oster
3081 1.51 oster /* XXX all this stuff should be done SOMEWHERE ELSE! */
3082 1.51 oster raidPtr->raidid = raidID;
3083 1.51 oster raidPtr->openings = RAIDOUTSTANDING;
3084 1.51 oster
3085 1.51 oster /* 3. Build the configuration structure */
3086 1.51 oster rf_create_configuration(cset->ac, config, raidPtr);
3087 1.51 oster
3088 1.51 oster /* 4. Do the configuration */
3089 1.51 oster retcode = rf_Configure(raidPtr, config, cset->ac);
3090 1.51 oster
3091 1.51 oster if (retcode == 0) {
3092 1.51 oster #if DEBUG
3093 1.51 oster printf("Calling raidinit()\n");
3094 1.51 oster #endif
3095 1.51 oster /* XXX the 0 below is bogus! */
3096 1.59 oster raidinit(raidPtrs[raidID]);
3097 1.59 oster
3098 1.59 oster rf_markalldirty(raidPtrs[raidID]);
3099 1.54 oster raidPtrs[raidID]->autoconfigure = 1; /* XXX do this here? */
3100 1.51 oster if (cset->ac->clabel->root_partition==1) {
3101 1.51 oster /* everything configured just fine. Make a note
3102 1.51 oster that this set is eligible to be root. */
3103 1.51 oster cset->rootable = 1;
3104 1.54 oster /* XXX do this here? */
3105 1.54 oster raidPtrs[raidID]->root_partition = 1;
3106 1.51 oster }
3107 1.51 oster }
3108 1.51 oster
3109 1.51 oster /* 5. Cleanup */
3110 1.51 oster free(config, M_RAIDFRAME);
3111 1.51 oster
3112 1.51 oster *unit = raidID;
3113 1.51 oster return(retcode);
3114 1.13 oster }
3115