rf_disks.c revision 1.8 1 1.8 oster /* $NetBSD: rf_disks.c,v 1.8 1999/03/18 03:02:38 oster Exp $ */
2 1.6 oster /*-
3 1.6 oster * Copyright (c) 1999 The NetBSD Foundation, Inc.
4 1.6 oster * All rights reserved.
5 1.6 oster *
6 1.6 oster * This code is derived from software contributed to The NetBSD Foundation
7 1.6 oster * by Greg Oster
8 1.6 oster *
9 1.6 oster * Redistribution and use in source and binary forms, with or without
10 1.6 oster * modification, are permitted provided that the following conditions
11 1.6 oster * are met:
12 1.6 oster * 1. Redistributions of source code must retain the above copyright
13 1.6 oster * notice, this list of conditions and the following disclaimer.
14 1.6 oster * 2. Redistributions in binary form must reproduce the above copyright
15 1.6 oster * notice, this list of conditions and the following disclaimer in the
16 1.6 oster * documentation and/or other materials provided with the distribution.
17 1.6 oster * 3. All advertising materials mentioning features or use of this software
18 1.6 oster * must display the following acknowledgement:
19 1.6 oster * This product includes software developed by the NetBSD
20 1.6 oster * Foundation, Inc. and its contributors.
21 1.6 oster * 4. Neither the name of The NetBSD Foundation nor the names of its
22 1.6 oster * contributors may be used to endorse or promote products derived
23 1.6 oster * from this software without specific prior written permission.
24 1.6 oster *
25 1.6 oster * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
26 1.6 oster * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
27 1.6 oster * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
28 1.6 oster * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
29 1.6 oster * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
30 1.6 oster * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
31 1.6 oster * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
32 1.6 oster * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
33 1.6 oster * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
34 1.6 oster * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
35 1.6 oster * POSSIBILITY OF SUCH DAMAGE.
36 1.6 oster */
37 1.6 oster
38 1.1 oster /*
39 1.1 oster * Copyright (c) 1995 Carnegie-Mellon University.
40 1.1 oster * All rights reserved.
41 1.1 oster *
42 1.1 oster * Author: Mark Holland
43 1.1 oster *
44 1.1 oster * Permission to use, copy, modify and distribute this software and
45 1.1 oster * its documentation is hereby granted, provided that both the copyright
46 1.1 oster * notice and this permission notice appear in all copies of the
47 1.1 oster * software, derivative works or modified versions, and any portions
48 1.1 oster * thereof, and that both notices appear in supporting documentation.
49 1.1 oster *
50 1.1 oster * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
51 1.1 oster * CONDITION. CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND
52 1.1 oster * FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
53 1.1 oster *
54 1.1 oster * Carnegie Mellon requests users of this software to return to
55 1.1 oster *
56 1.1 oster * Software Distribution Coordinator or Software.Distribution (at) CS.CMU.EDU
57 1.1 oster * School of Computer Science
58 1.1 oster * Carnegie Mellon University
59 1.1 oster * Pittsburgh PA 15213-3890
60 1.1 oster *
61 1.1 oster * any improvements or extensions that they make and grant Carnegie the
62 1.1 oster * rights to redistribute these changes.
63 1.1 oster */
64 1.1 oster
65 1.1 oster /***************************************************************
66 1.1 oster * rf_disks.c -- code to perform operations on the actual disks
67 1.1 oster ***************************************************************/
68 1.1 oster
69 1.1 oster #include "rf_types.h"
70 1.1 oster #include "rf_raid.h"
71 1.1 oster #include "rf_alloclist.h"
72 1.1 oster #include "rf_utils.h"
73 1.1 oster #include "rf_configure.h"
74 1.1 oster #include "rf_general.h"
75 1.1 oster #include "rf_options.h"
76 1.1 oster #include "rf_sys.h"
77 1.1 oster
78 1.1 oster #include <sys/types.h>
79 1.1 oster #include <sys/param.h>
80 1.1 oster #include <sys/systm.h>
81 1.1 oster #include <sys/proc.h>
82 1.1 oster #include <sys/ioctl.h>
83 1.1 oster #include <sys/fcntl.h>
84 1.1 oster #include <sys/vnode.h>
85 1.1 oster
86 1.6 oster /* XXX these should be in a header file somewhere */
87 1.5 oster int raidlookup __P((char *, struct proc * p, struct vnode **));
88 1.6 oster int raidwrite_component_label(dev_t, struct vnode *, RF_ComponentLabel_t *);
89 1.6 oster int raidread_component_label(dev_t, struct vnode *, RF_ComponentLabel_t *);
90 1.6 oster void rf_UnconfigureVnodes( RF_Raid_t * );
91 1.6 oster int rf_CheckLabels( RF_Raid_t *, RF_Config_t *);
92 1.1 oster
93 1.1 oster #define DPRINTF6(a,b,c,d,e,f) if (rf_diskDebug) printf(a,b,c,d,e,f)
94 1.1 oster #define DPRINTF7(a,b,c,d,e,f,g) if (rf_diskDebug) printf(a,b,c,d,e,f,g)
95 1.1 oster
96 1.6 oster /**************************************************************************
97 1.1 oster *
98 1.1 oster * initialize the disks comprising the array
99 1.1 oster *
100 1.6 oster * We want the spare disks to have regular row,col numbers so that we can
101 1.6 oster * easily substitue a spare for a failed disk. But, the driver code assumes
102 1.6 oster * throughout that the array contains numRow by numCol _non-spare_ disks, so
103 1.6 oster * it's not clear how to fit in the spares. This is an unfortunate holdover
104 1.6 oster * from raidSim. The quick and dirty fix is to make row zero bigger than the
105 1.6 oster * rest, and put all the spares in it. This probably needs to get changed
106 1.6 oster * eventually.
107 1.1 oster *
108 1.6 oster **************************************************************************/
109 1.6 oster
110 1.5 oster int
111 1.6 oster rf_ConfigureDisks( listp, raidPtr, cfgPtr )
112 1.6 oster RF_ShutdownList_t **listp;
113 1.6 oster RF_Raid_t *raidPtr;
114 1.6 oster RF_Config_t *cfgPtr;
115 1.1 oster {
116 1.5 oster RF_RaidDisk_t **disks;
117 1.5 oster RF_SectorCount_t min_numblks = (RF_SectorCount_t) 0x7FFFFFFFFFFFLL;
118 1.5 oster RF_RowCol_t r, c;
119 1.6 oster int bs, ret;
120 1.5 oster unsigned i, count, foundone = 0, numFailuresThisRow;
121 1.6 oster int num_rows_done, num_cols_done;
122 1.7 oster int force;
123 1.5 oster
124 1.5 oster num_rows_done = 0;
125 1.5 oster num_cols_done = 0;
126 1.7 oster force = cfgPtr->force;
127 1.5 oster
128 1.6 oster RF_CallocAndAdd(disks, raidPtr->numRow, sizeof(RF_RaidDisk_t *),
129 1.6 oster (RF_RaidDisk_t **), raidPtr->cleanupList);
130 1.5 oster if (disks == NULL) {
131 1.5 oster ret = ENOMEM;
132 1.5 oster goto fail;
133 1.5 oster }
134 1.5 oster raidPtr->Disks = disks;
135 1.5 oster
136 1.5 oster /* get space for the device-specific stuff... */
137 1.5 oster RF_CallocAndAdd(raidPtr->raid_cinfo, raidPtr->numRow,
138 1.5 oster sizeof(struct raidcinfo *), (struct raidcinfo **),
139 1.5 oster raidPtr->cleanupList);
140 1.5 oster if (raidPtr->raid_cinfo == NULL) {
141 1.5 oster ret = ENOMEM;
142 1.5 oster goto fail;
143 1.5 oster }
144 1.5 oster for (r = 0; r < raidPtr->numRow; r++) {
145 1.5 oster numFailuresThisRow = 0;
146 1.6 oster /* We allocate RF_MAXSPARE on the first row so that we
147 1.6 oster have room to do hot-swapping of spares */
148 1.6 oster RF_CallocAndAdd(disks[r], raidPtr->numCol
149 1.6 oster + ((r == 0) ? RF_MAXSPARE : 0),
150 1.6 oster sizeof(RF_RaidDisk_t), (RF_RaidDisk_t *),
151 1.6 oster raidPtr->cleanupList);
152 1.5 oster if (disks[r] == NULL) {
153 1.5 oster ret = ENOMEM;
154 1.5 oster goto fail;
155 1.5 oster }
156 1.5 oster /* get more space for device specific stuff.. */
157 1.5 oster RF_CallocAndAdd(raidPtr->raid_cinfo[r],
158 1.5 oster raidPtr->numCol + ((r == 0) ? raidPtr->numSpare : 0),
159 1.5 oster sizeof(struct raidcinfo), (struct raidcinfo *),
160 1.1 oster raidPtr->cleanupList);
161 1.5 oster if (raidPtr->raid_cinfo[r] == NULL) {
162 1.5 oster ret = ENOMEM;
163 1.5 oster goto fail;
164 1.5 oster }
165 1.5 oster for (c = 0; c < raidPtr->numCol; c++) {
166 1.6 oster ret = rf_ConfigureDisk(raidPtr,
167 1.6 oster &cfgPtr->devnames[r][c][0],
168 1.6 oster &disks[r][c], r, c);
169 1.5 oster if (ret)
170 1.5 oster goto fail;
171 1.7 oster
172 1.6 oster if (disks[r][c].status == rf_ds_optimal) {
173 1.6 oster raidread_component_label(
174 1.6 oster raidPtr->raid_cinfo[r][c].ci_dev,
175 1.6 oster raidPtr->raid_cinfo[r][c].ci_vp,
176 1.6 oster &raidPtr->raid_cinfo[r][c].ci_label);
177 1.6 oster }
178 1.7 oster
179 1.5 oster if (disks[r][c].status != rf_ds_optimal) {
180 1.5 oster numFailuresThisRow++;
181 1.5 oster } else {
182 1.5 oster if (disks[r][c].numBlocks < min_numblks)
183 1.5 oster min_numblks = disks[r][c].numBlocks;
184 1.5 oster DPRINTF7("Disk at row %d col %d: dev %s numBlocks %ld blockSize %d (%ld MB)\n",
185 1.5 oster r, c, disks[r][c].devname,
186 1.5 oster (long int) disks[r][c].numBlocks,
187 1.5 oster disks[r][c].blockSize,
188 1.6 oster (long int) disks[r][c].numBlocks *
189 1.6 oster disks[r][c].blockSize / 1024 / 1024);
190 1.5 oster }
191 1.5 oster num_cols_done++;
192 1.5 oster }
193 1.5 oster /* XXX fix for n-fault tolerant */
194 1.6 oster /* XXX this should probably check to see how many failures
195 1.6 oster we can handle for this configuration! */
196 1.5 oster if (numFailuresThisRow > 0)
197 1.5 oster raidPtr->status[r] = rf_rs_degraded;
198 1.5 oster num_rows_done++;
199 1.5 oster }
200 1.6 oster
201 1.5 oster /* all disks must be the same size & have the same block size, bs must
202 1.5 oster * be a power of 2 */
203 1.5 oster bs = 0;
204 1.5 oster for (foundone = r = 0; !foundone && r < raidPtr->numRow; r++) {
205 1.5 oster for (c = 0; !foundone && c < raidPtr->numCol; c++) {
206 1.5 oster if (disks[r][c].status == rf_ds_optimal) {
207 1.5 oster bs = disks[r][c].blockSize;
208 1.5 oster foundone = 1;
209 1.5 oster }
210 1.5 oster }
211 1.5 oster }
212 1.5 oster if (!foundone) {
213 1.5 oster RF_ERRORMSG("RAIDFRAME: Did not find any live disks in the array.\n");
214 1.5 oster ret = EINVAL;
215 1.5 oster goto fail;
216 1.5 oster }
217 1.5 oster for (count = 0, i = 1; i; i <<= 1)
218 1.5 oster if (bs & i)
219 1.5 oster count++;
220 1.5 oster if (count != 1) {
221 1.5 oster RF_ERRORMSG1("Error: block size on disks (%d) must be a power of 2\n", bs);
222 1.5 oster ret = EINVAL;
223 1.5 oster goto fail;
224 1.5 oster }
225 1.6 oster
226 1.6 oster if (rf_CheckLabels( raidPtr, cfgPtr )) {
227 1.7 oster printf("raid%d: There were fatal errors\n", raidPtr->raidid);
228 1.7 oster if (force != 0) {
229 1.7 oster printf("raid%d: Fatal errors being ignored.\n",
230 1.7 oster raidPtr->raidid);
231 1.7 oster } else {
232 1.7 oster ret = EINVAL;
233 1.7 oster goto fail;
234 1.7 oster }
235 1.6 oster }
236 1.7 oster
237 1.5 oster for (r = 0; r < raidPtr->numRow; r++) {
238 1.5 oster for (c = 0; c < raidPtr->numCol; c++) {
239 1.5 oster if (disks[r][c].status == rf_ds_optimal) {
240 1.5 oster if (disks[r][c].blockSize != bs) {
241 1.5 oster RF_ERRORMSG2("Error: block size of disk at r %d c %d different from disk at r 0 c 0\n", r, c);
242 1.5 oster ret = EINVAL;
243 1.5 oster goto fail;
244 1.5 oster }
245 1.5 oster if (disks[r][c].numBlocks != min_numblks) {
246 1.5 oster RF_ERRORMSG3("WARNING: truncating disk at r %d c %d to %d blocks\n",
247 1.5 oster r, c, (int) min_numblks);
248 1.5 oster disks[r][c].numBlocks = min_numblks;
249 1.5 oster }
250 1.5 oster }
251 1.5 oster }
252 1.5 oster }
253 1.5 oster
254 1.5 oster raidPtr->sectorsPerDisk = min_numblks;
255 1.5 oster raidPtr->logBytesPerSector = ffs(bs) - 1;
256 1.5 oster raidPtr->bytesPerSector = bs;
257 1.5 oster raidPtr->sectorMask = bs - 1;
258 1.5 oster return (0);
259 1.1 oster
260 1.1 oster fail:
261 1.6 oster
262 1.6 oster rf_UnconfigureVnodes( raidPtr );
263 1.1 oster
264 1.5 oster return (ret);
265 1.1 oster }
266 1.1 oster
267 1.1 oster
268 1.6 oster /****************************************************************************
269 1.1 oster * set up the data structures describing the spare disks in the array
270 1.1 oster * recall from the above comment that the spare disk descriptors are stored
271 1.1 oster * in row zero, which is specially expanded to hold them.
272 1.6 oster ****************************************************************************/
273 1.5 oster int
274 1.6 oster rf_ConfigureSpareDisks( listp, raidPtr, cfgPtr )
275 1.6 oster RF_ShutdownList_t ** listp;
276 1.6 oster RF_Raid_t * raidPtr;
277 1.6 oster RF_Config_t * cfgPtr;
278 1.1 oster {
279 1.6 oster int i, ret;
280 1.6 oster unsigned int bs;
281 1.5 oster RF_RaidDisk_t *disks;
282 1.5 oster int num_spares_done;
283 1.1 oster
284 1.5 oster num_spares_done = 0;
285 1.5 oster
286 1.5 oster /* The space for the spares should have already been allocated by
287 1.5 oster * ConfigureDisks() */
288 1.5 oster
289 1.5 oster disks = &raidPtr->Disks[0][raidPtr->numCol];
290 1.5 oster for (i = 0; i < raidPtr->numSpare; i++) {
291 1.5 oster ret = rf_ConfigureDisk(raidPtr, &cfgPtr->spare_names[i][0],
292 1.6 oster &disks[i], 0, raidPtr->numCol + i);
293 1.5 oster if (ret)
294 1.5 oster goto fail;
295 1.5 oster if (disks[i].status != rf_ds_optimal) {
296 1.6 oster RF_ERRORMSG1("Warning: spare disk %s failed TUR\n",
297 1.6 oster &cfgPtr->spare_names[i][0]);
298 1.5 oster } else {
299 1.5 oster disks[i].status = rf_ds_spare; /* change status to
300 1.5 oster * spare */
301 1.5 oster DPRINTF6("Spare Disk %d: dev %s numBlocks %ld blockSize %d (%ld MB)\n", i,
302 1.5 oster disks[i].devname,
303 1.5 oster (long int) disks[i].numBlocks, disks[i].blockSize,
304 1.6 oster (long int) disks[i].numBlocks *
305 1.6 oster disks[i].blockSize / 1024 / 1024);
306 1.5 oster }
307 1.5 oster num_spares_done++;
308 1.5 oster }
309 1.1 oster
310 1.5 oster /* check sizes and block sizes on spare disks */
311 1.5 oster bs = 1 << raidPtr->logBytesPerSector;
312 1.5 oster for (i = 0; i < raidPtr->numSpare; i++) {
313 1.5 oster if (disks[i].blockSize != bs) {
314 1.5 oster RF_ERRORMSG3("Block size of %d on spare disk %s is not the same as on other disks (%d)\n", disks[i].blockSize, disks[i].devname, bs);
315 1.5 oster ret = EINVAL;
316 1.5 oster goto fail;
317 1.5 oster }
318 1.5 oster if (disks[i].numBlocks < raidPtr->sectorsPerDisk) {
319 1.5 oster RF_ERRORMSG3("Spare disk %s (%d blocks) is too small to serve as a spare (need %ld blocks)\n",
320 1.6 oster disks[i].devname, disks[i].blockSize,
321 1.6 oster (long int) raidPtr->sectorsPerDisk);
322 1.5 oster ret = EINVAL;
323 1.5 oster goto fail;
324 1.5 oster } else
325 1.5 oster if (disks[i].numBlocks > raidPtr->sectorsPerDisk) {
326 1.5 oster RF_ERRORMSG2("Warning: truncating spare disk %s to %ld blocks\n", disks[i].devname, (long int) raidPtr->sectorsPerDisk);
327 1.5 oster
328 1.5 oster disks[i].numBlocks = raidPtr->sectorsPerDisk;
329 1.5 oster }
330 1.5 oster }
331 1.5 oster
332 1.5 oster return (0);
333 1.1 oster
334 1.1 oster fail:
335 1.2 oster
336 1.5 oster /* Release the hold on the main components. We've failed to allocate
337 1.6 oster * a spare, and since we're failing, we need to free things..
338 1.6 oster
339 1.6 oster XXX failing to allocate a spare is *not* that big of a deal...
340 1.6 oster We *can* survive without it, if need be, esp. if we get hot
341 1.6 oster adding working.
342 1.1 oster
343 1.6 oster If we don't fail out here, then we need a way to remove this spare...
344 1.6 oster that should be easier to do here than if we are "live"...
345 1.1 oster
346 1.6 oster */
347 1.1 oster
348 1.6 oster rf_UnconfigureVnodes( raidPtr );
349 1.1 oster
350 1.5 oster return (ret);
351 1.1 oster }
352 1.1 oster
353 1.1 oster
354 1.1 oster
355 1.1 oster /* configure a single disk in the array */
356 1.5 oster int
357 1.6 oster rf_ConfigureDisk(raidPtr, buf, diskPtr, row, col)
358 1.6 oster RF_Raid_t *raidPtr;
359 1.5 oster char *buf;
360 1.5 oster RF_RaidDisk_t *diskPtr;
361 1.5 oster RF_RowCol_t row;
362 1.5 oster RF_RowCol_t col;
363 1.1 oster {
364 1.5 oster char *p;
365 1.5 oster int retcode;
366 1.1 oster
367 1.1 oster struct partinfo dpart;
368 1.1 oster struct vnode *vp;
369 1.1 oster struct vattr va;
370 1.1 oster struct proc *proc;
371 1.5 oster int error;
372 1.1 oster
373 1.5 oster retcode = 0;
374 1.5 oster p = rf_find_non_white(buf);
375 1.5 oster if (p[strlen(p) - 1] == '\n') {
376 1.5 oster /* strip off the newline */
377 1.5 oster p[strlen(p) - 1] = '\0';
378 1.5 oster }
379 1.5 oster (void) strcpy(diskPtr->devname, p);
380 1.1 oster
381 1.5 oster proc = raidPtr->proc; /* XXX Yes, this is not nice.. */
382 1.5 oster
383 1.5 oster /* Let's start by claiming the component is fine and well... */
384 1.5 oster diskPtr->status = rf_ds_optimal;
385 1.5 oster
386 1.5 oster raidPtr->raid_cinfo[row][col].ci_vp = NULL;
387 1.5 oster raidPtr->raid_cinfo[row][col].ci_dev = NULL;
388 1.5 oster
389 1.5 oster error = raidlookup(diskPtr->devname, proc, &vp);
390 1.5 oster if (error) {
391 1.5 oster printf("raidlookup on device: %s failed!\n", diskPtr->devname);
392 1.5 oster if (error == ENXIO) {
393 1.6 oster /* the component isn't there... must be dead :-( */
394 1.5 oster diskPtr->status = rf_ds_failed;
395 1.5 oster } else {
396 1.5 oster return (error);
397 1.5 oster }
398 1.5 oster }
399 1.5 oster if (diskPtr->status == rf_ds_optimal) {
400 1.5 oster
401 1.5 oster if ((error = VOP_GETATTR(vp, &va, proc->p_ucred, proc)) != 0) {
402 1.5 oster return (error);
403 1.5 oster }
404 1.5 oster error = VOP_IOCTL(vp, DIOCGPART, (caddr_t) & dpart,
405 1.6 oster FREAD, proc->p_ucred, proc);
406 1.5 oster if (error) {
407 1.5 oster return (error);
408 1.5 oster }
409 1.6 oster
410 1.5 oster diskPtr->blockSize = dpart.disklab->d_secsize;
411 1.6 oster
412 1.5 oster diskPtr->numBlocks = dpart.part->p_size - rf_protectedSectors;
413 1.6 oster
414 1.5 oster raidPtr->raid_cinfo[row][col].ci_vp = vp;
415 1.5 oster raidPtr->raid_cinfo[row][col].ci_dev = va.va_rdev;
416 1.6 oster
417 1.6 oster diskPtr->dev = va.va_rdev;
418 1.6 oster
419 1.6 oster /* we allow the user to specify that only a fraction of the
420 1.6 oster * disks should be used this is just for debug: it speeds up
421 1.6 oster * the parity scan */
422 1.6 oster diskPtr->numBlocks = diskPtr->numBlocks *
423 1.6 oster rf_sizePercentage / 100;
424 1.6 oster }
425 1.6 oster return (0);
426 1.6 oster }
427 1.6 oster
428 1.7 oster static void rf_print_label_status( RF_Raid_t *, int, int, char *,
429 1.7 oster RF_ComponentLabel_t *);
430 1.7 oster
431 1.7 oster static void
432 1.7 oster rf_print_label_status( raidPtr, row, column, dev_name, ci_label )
433 1.7 oster RF_Raid_t *raidPtr;
434 1.7 oster int row;
435 1.7 oster int column;
436 1.7 oster char *dev_name;
437 1.7 oster RF_ComponentLabel_t *ci_label;
438 1.7 oster {
439 1.7 oster
440 1.7 oster printf("raid%d: Component %s being configured at row: %d col: %d\n",
441 1.7 oster raidPtr->raidid, dev_name, row, column );
442 1.7 oster printf(" Row: %d Column: %d Num Rows: %d Num Columns: %d\n",
443 1.7 oster ci_label->row, ci_label->column,
444 1.7 oster ci_label->num_rows, ci_label->num_columns);
445 1.7 oster printf(" Version: %d Serial Number: %d Mod Counter: %d\n",
446 1.7 oster ci_label->version, ci_label->serial_number,
447 1.7 oster ci_label->mod_counter);
448 1.7 oster printf(" Clean: %d Status: %d\n",
449 1.7 oster ci_label->clean, ci_label->status );
450 1.7 oster }
451 1.7 oster
452 1.7 oster static int rf_check_label_vitals( RF_Raid_t *, int, int, char *,
453 1.7 oster RF_ComponentLabel_t *, int, int );
454 1.7 oster static int rf_check_label_vitals( raidPtr, row, column, dev_name, ci_label,
455 1.7 oster serial_number, mod_counter )
456 1.7 oster RF_Raid_t *raidPtr;
457 1.7 oster int row;
458 1.7 oster int column;
459 1.7 oster char *dev_name;
460 1.7 oster RF_ComponentLabel_t *ci_label;
461 1.7 oster int serial_number;
462 1.7 oster int mod_counter;
463 1.7 oster {
464 1.7 oster int fatal_error = 0;
465 1.7 oster
466 1.7 oster if (serial_number != ci_label->serial_number) {
467 1.7 oster printf("%s has a different serial number: %d %d\n",
468 1.7 oster dev_name, serial_number, ci_label->serial_number);
469 1.7 oster fatal_error = 1;
470 1.7 oster }
471 1.7 oster if (mod_counter != ci_label->mod_counter) {
472 1.7 oster printf("%s has a different modfication count: %d %d\n",
473 1.7 oster dev_name, mod_counter, ci_label->mod_counter);
474 1.7 oster }
475 1.7 oster
476 1.7 oster if (row != ci_label->row) {
477 1.7 oster printf("Row out of alignment for: %s\n", dev_name);
478 1.7 oster fatal_error = 1;
479 1.7 oster }
480 1.7 oster if (column != ci_label->column) {
481 1.7 oster printf("Column out of alignment for: %s\n", dev_name);
482 1.7 oster fatal_error = 1;
483 1.7 oster }
484 1.7 oster if (raidPtr->numRow != ci_label->num_rows) {
485 1.7 oster printf("Number of rows do not match for: %s\n", dev_name);
486 1.7 oster fatal_error = 1;
487 1.7 oster }
488 1.7 oster if (raidPtr->numCol != ci_label->num_columns) {
489 1.7 oster printf("Number of columns do not match for: %s\n", dev_name);
490 1.7 oster fatal_error = 1;
491 1.7 oster }
492 1.7 oster if (ci_label->clean == 0) {
493 1.7 oster /* it's not clean, but that's not fatal */
494 1.7 oster printf("%s is not clean!\n", dev_name);
495 1.7 oster }
496 1.7 oster return(fatal_error);
497 1.7 oster }
498 1.7 oster
499 1.7 oster
500 1.6 oster /*
501 1.6 oster
502 1.6 oster rf_CheckLabels() - check all the component labels for consistency.
503 1.6 oster Return an error if there is anything major amiss.
504 1.6 oster
505 1.6 oster */
506 1.1 oster
507 1.6 oster int
508 1.6 oster rf_CheckLabels( raidPtr, cfgPtr )
509 1.6 oster RF_Raid_t *raidPtr;
510 1.6 oster RF_Config_t *cfgPtr;
511 1.6 oster {
512 1.6 oster int r,c;
513 1.6 oster char *dev_name;
514 1.6 oster RF_ComponentLabel_t *ci_label;
515 1.6 oster int serial_number = 0;
516 1.7 oster int mod_number = 0;
517 1.6 oster int fatal_error = 0;
518 1.7 oster int mod_values[4];
519 1.7 oster int mod_count[4];
520 1.7 oster int ser_values[4];
521 1.7 oster int ser_count[4];
522 1.7 oster int num_ser;
523 1.7 oster int num_mod;
524 1.7 oster int i;
525 1.7 oster int found;
526 1.7 oster int hosed_row;
527 1.7 oster int hosed_column;
528 1.7 oster int too_fatal;
529 1.7 oster int parity_good;
530 1.7 oster int force;
531 1.7 oster
532 1.7 oster hosed_row = -1;
533 1.7 oster hosed_column = -1;
534 1.7 oster too_fatal = 0;
535 1.7 oster force = cfgPtr->force;
536 1.7 oster
537 1.7 oster /*
538 1.7 oster We're going to try to be a little intelligent here. If one
539 1.7 oster component's label is bogus, and we can identify that it's the
540 1.7 oster *only* one that's gone, we'll mark it as "failed" and allow
541 1.7 oster the configuration to proceed. This will be the *only* case
542 1.7 oster that we'll proceed if there would be (otherwise) fatal errors.
543 1.7 oster
544 1.7 oster Basically we simply keep a count of how many components had
545 1.7 oster what serial number. If all but one agree, we simply mark
546 1.7 oster the disagreeing component as being failed, and allow
547 1.7 oster things to come up "normally".
548 1.7 oster
549 1.7 oster We do this first for serial numbers, and then for "mod_counter".
550 1.6 oster
551 1.7 oster */
552 1.7 oster
553 1.7 oster num_ser = 0;
554 1.7 oster num_mod = 0;
555 1.7 oster for (r = 0; r < raidPtr->numRow && !fatal_error ; r++) {
556 1.7 oster for (c = 0; c < raidPtr->numCol; c++) {
557 1.7 oster ci_label = &raidPtr->raid_cinfo[r][c].ci_label;
558 1.7 oster found=0;
559 1.7 oster for(i=0;i<num_ser;i++) {
560 1.7 oster if (ser_values[i] == ci_label->serial_number) {
561 1.7 oster ser_count[i]++;
562 1.7 oster found=1;
563 1.7 oster break;
564 1.7 oster }
565 1.7 oster }
566 1.7 oster if (!found) {
567 1.7 oster ser_values[num_ser] = ci_label->serial_number;
568 1.7 oster ser_count[num_ser] = 1;
569 1.7 oster num_ser++;
570 1.7 oster if (num_ser>2) {
571 1.7 oster fatal_error = 1;
572 1.7 oster break;
573 1.7 oster }
574 1.7 oster }
575 1.7 oster found=0;
576 1.7 oster for(i=0;i<num_mod;i++) {
577 1.7 oster if (mod_values[i] == ci_label->mod_counter) {
578 1.7 oster mod_count[i]++;
579 1.7 oster found=1;
580 1.7 oster break;
581 1.7 oster }
582 1.7 oster }
583 1.7 oster if (!found) {
584 1.7 oster mod_values[num_mod] = ci_label->mod_counter;
585 1.7 oster mod_count[num_mod] = 1;
586 1.7 oster num_mod++;
587 1.7 oster if (num_mod>2) {
588 1.7 oster fatal_error = 1;
589 1.7 oster break;
590 1.7 oster }
591 1.7 oster }
592 1.7 oster }
593 1.7 oster }
594 1.7 oster #if DEBUG
595 1.7 oster printf("raid%d: Summary of serial numbers:\n", raidPtr->raidid);
596 1.7 oster for(i=0;i<num_ser;i++) {
597 1.7 oster printf("%d %d\n", ser_values[i], ser_count[i]);
598 1.7 oster }
599 1.7 oster printf("raid%d: Summary of mod counters:\n", raidPtr->raidid);
600 1.7 oster for(i=0;i<num_mod;i++) {
601 1.7 oster printf("%d %d\n", mod_values[i], mod_count[i]);
602 1.7 oster }
603 1.7 oster #endif
604 1.7 oster serial_number = ser_values[0];
605 1.7 oster if (num_ser == 2) {
606 1.7 oster if ((ser_count[0] == 1) || (ser_count[1] == 1)) {
607 1.7 oster /* Locate the maverick component */
608 1.7 oster if (ser_count[1] > ser_count[0]) {
609 1.7 oster serial_number = ser_values[1];
610 1.7 oster }
611 1.7 oster for (r = 0; r < raidPtr->numRow; r++) {
612 1.7 oster for (c = 0; c < raidPtr->numCol; c++) {
613 1.7 oster ci_label = &raidPtr->raid_cinfo[r][c].ci_label;
614 1.7 oster if (serial_number !=
615 1.7 oster ci_label->serial_number) {
616 1.7 oster hosed_row = r;
617 1.7 oster hosed_column = c;
618 1.7 oster break;
619 1.7 oster }
620 1.7 oster }
621 1.7 oster }
622 1.7 oster printf("Hosed component: %s\n",
623 1.7 oster &cfgPtr->devnames[hosed_row][hosed_column][0]);
624 1.7 oster if (!force) {
625 1.7 oster /* we'll fail this component, as if there are
626 1.7 oster other major errors, we arn't forcing things
627 1.7 oster and we'll abort the config anyways */
628 1.7 oster raidPtr->Disks[hosed_row][hosed_column].status
629 1.7 oster = rf_ds_failed;
630 1.7 oster raidPtr->numFailures++;
631 1.7 oster raidPtr->status[hosed_row] = rf_rs_degraded;
632 1.7 oster }
633 1.7 oster } else {
634 1.7 oster too_fatal = 1;
635 1.7 oster }
636 1.7 oster if (cfgPtr->parityConfig == '0') {
637 1.7 oster /* We've identified two different serial numbers.
638 1.7 oster RAID 0 can't cope with that, so we'll punt */
639 1.7 oster too_fatal = 1;
640 1.7 oster }
641 1.7 oster
642 1.7 oster }
643 1.7 oster
644 1.7 oster /* record the serial number for later. If we bail later, setting
645 1.7 oster this doesn't matter, otherwise we've got the best guess at the
646 1.7 oster correct serial number */
647 1.7 oster raidPtr->serial_number = serial_number;
648 1.7 oster
649 1.7 oster mod_number = mod_values[0];
650 1.7 oster if (num_mod == 2) {
651 1.7 oster if ((mod_count[0] == 1) || (mod_count[1] == 1)) {
652 1.7 oster /* Locate the maverick component */
653 1.7 oster if (mod_count[1] > mod_count[0]) {
654 1.7 oster mod_number = mod_values[1];
655 1.8 oster } else if (mod_count[1] < mod_count[0]) {
656 1.8 oster mod_number = mod_values[0];
657 1.8 oster } else {
658 1.8 oster /* counts of different modification values
659 1.8 oster are the same. Assume greater value is
660 1.8 oster the correct one, all other things
661 1.8 oster considered */
662 1.8 oster if (mod_values[0] > mod_values[1]) {
663 1.8 oster mod_number = mod_values[0];
664 1.8 oster } else {
665 1.8 oster mod_number = mod_values[1];
666 1.8 oster }
667 1.8 oster
668 1.8 oster }
669 1.7 oster for (r = 0; r < raidPtr->numRow && !too_fatal ; r++) {
670 1.7 oster for (c = 0; c < raidPtr->numCol; c++) {
671 1.7 oster ci_label = &raidPtr->raid_cinfo[r][c].ci_label;
672 1.7 oster if (mod_number !=
673 1.7 oster ci_label->mod_counter) {
674 1.7 oster if ( ( hosed_row == r ) &&
675 1.7 oster ( hosed_column == c )) {
676 1.7 oster /* same one. Can
677 1.7 oster deal with it. */
678 1.7 oster } else {
679 1.7 oster hosed_row = r;
680 1.7 oster hosed_column = c;
681 1.7 oster if (num_ser != 1) {
682 1.7 oster too_fatal = 1;
683 1.7 oster break;
684 1.7 oster }
685 1.7 oster }
686 1.7 oster }
687 1.7 oster }
688 1.7 oster }
689 1.7 oster printf("Hosed component: %s\n",
690 1.7 oster &cfgPtr->devnames[hosed_row][hosed_column][0]);
691 1.7 oster if (!force) {
692 1.7 oster /* we'll fail this component, as if there are
693 1.7 oster other major errors, we arn't forcing things
694 1.7 oster and we'll abort the config anyways */
695 1.7 oster raidPtr->Disks[hosed_row][hosed_column].status
696 1.7 oster = rf_ds_failed;
697 1.7 oster raidPtr->numFailures++;
698 1.7 oster raidPtr->status[hosed_row] = rf_rs_degraded;
699 1.7 oster }
700 1.7 oster } else {
701 1.7 oster too_fatal = 1;
702 1.7 oster }
703 1.7 oster if (cfgPtr->parityConfig == '0') {
704 1.7 oster /* We've identified two different mod counters.
705 1.7 oster RAID 0 can't cope with that, so we'll punt */
706 1.7 oster too_fatal = 1;
707 1.7 oster }
708 1.7 oster }
709 1.7 oster
710 1.7 oster raidPtr->mod_counter = mod_number;
711 1.7 oster
712 1.7 oster if (too_fatal) {
713 1.7 oster /* we've had both a serial number mismatch, and a mod_counter
714 1.7 oster mismatch -- and they involved two different components!!
715 1.7 oster Bail -- make things fail so that the user must force
716 1.7 oster the issue... */
717 1.7 oster hosed_row = -1;
718 1.7 oster hosed_column = -1;
719 1.7 oster }
720 1.7 oster
721 1.7 oster if (num_ser > 2) {
722 1.7 oster printf("raid%d: Too many different serial numbers!\n",
723 1.7 oster raidPtr->raidid);
724 1.7 oster }
725 1.7 oster
726 1.7 oster if (num_mod > 2) {
727 1.7 oster printf("raid%d: Too many different mod counters!\n",
728 1.7 oster raidPtr->raidid);
729 1.7 oster }
730 1.7 oster
731 1.7 oster /* we start by assuming the parity will be good, and flee from
732 1.7 oster that notion at the slightest sign of trouble */
733 1.7 oster
734 1.7 oster parity_good = RF_RAID_CLEAN;
735 1.6 oster for (r = 0; r < raidPtr->numRow; r++) {
736 1.6 oster for (c = 0; c < raidPtr->numCol; c++) {
737 1.6 oster dev_name = &cfgPtr->devnames[r][c][0];
738 1.6 oster ci_label = &raidPtr->raid_cinfo[r][c].ci_label;
739 1.7 oster
740 1.7 oster if ((r == hosed_row) && (c == hosed_column)) {
741 1.7 oster printf("raid%d: Ignoring %s\n",
742 1.7 oster raidPtr->raidid, dev_name);
743 1.7 oster } else {
744 1.7 oster rf_print_label_status( raidPtr, r, c,
745 1.7 oster dev_name, ci_label );
746 1.7 oster if (rf_check_label_vitals( raidPtr, r, c,
747 1.7 oster dev_name, ci_label,
748 1.7 oster serial_number,
749 1.7 oster mod_number )) {
750 1.6 oster fatal_error = 1;
751 1.6 oster }
752 1.7 oster if (ci_label->clean != RF_RAID_CLEAN) {
753 1.7 oster parity_good = RF_RAID_DIRTY;
754 1.6 oster }
755 1.6 oster }
756 1.6 oster }
757 1.6 oster }
758 1.7 oster if (fatal_error) {
759 1.7 oster parity_good = RF_RAID_DIRTY;
760 1.7 oster }
761 1.7 oster
762 1.7 oster /* we note the state of the parity */
763 1.7 oster raidPtr->parity_good = parity_good;
764 1.6 oster
765 1.6 oster return(fatal_error);
766 1.6 oster }
767 1.6 oster
768 1.6 oster
769 1.7 oster int rf_add_hot_spare(RF_Raid_t *, RF_SingleComponent_t *);
770 1.6 oster int
771 1.6 oster rf_add_hot_spare(raidPtr, sparePtr)
772 1.6 oster RF_Raid_t *raidPtr;
773 1.7 oster RF_SingleComponent_t *sparePtr;
774 1.6 oster {
775 1.6 oster RF_RaidDisk_t *disks;
776 1.6 oster int ret;
777 1.6 oster unsigned int bs;
778 1.6 oster int spare_number;
779 1.6 oster
780 1.6 oster printf("Just in rf_add_hot_spare: %d\n",raidPtr->numSpare);
781 1.6 oster printf("Num col: %d\n",raidPtr->numCol);
782 1.6 oster if (raidPtr->numSpare >= RF_MAXSPARE) {
783 1.6 oster RF_ERRORMSG1("Too many spares: %d\n", raidPtr->numSpare);
784 1.6 oster return(EINVAL);
785 1.6 oster }
786 1.6 oster
787 1.6 oster /* the beginning of the spares... */
788 1.6 oster disks = &raidPtr->Disks[0][raidPtr->numCol];
789 1.6 oster
790 1.6 oster spare_number = raidPtr->numSpare;
791 1.1 oster
792 1.7 oster ret = rf_ConfigureDisk(raidPtr, sparePtr->component_name,
793 1.6 oster &disks[spare_number], 0,
794 1.6 oster raidPtr->numCol + spare_number);
795 1.1 oster
796 1.6 oster if (ret)
797 1.6 oster goto fail;
798 1.6 oster if (disks[spare_number].status != rf_ds_optimal) {
799 1.6 oster RF_ERRORMSG1("Warning: spare disk %s failed TUR\n",
800 1.7 oster sparePtr->component_name);
801 1.6 oster ret=EINVAL;
802 1.6 oster goto fail;
803 1.6 oster } else {
804 1.6 oster disks[spare_number].status = rf_ds_spare;
805 1.6 oster DPRINTF6("Spare Disk %d: dev %s numBlocks %ld blockSize %d (%ld MB)\n", spare_number,
806 1.6 oster disks[spare_number].devname,
807 1.6 oster (long int) disks[spare_number].numBlocks,
808 1.6 oster disks[spare_number].blockSize,
809 1.6 oster (long int) disks[spare_number].numBlocks *
810 1.6 oster disks[spare_number].blockSize / 1024 / 1024);
811 1.6 oster }
812 1.6 oster
813 1.1 oster
814 1.6 oster /* check sizes and block sizes on the spare disk */
815 1.6 oster bs = 1 << raidPtr->logBytesPerSector;
816 1.6 oster if (disks[spare_number].blockSize != bs) {
817 1.6 oster RF_ERRORMSG3("Block size of %d on spare disk %s is not the same as on other disks (%d)\n", disks[spare_number].blockSize, disks[spare_number].devname, bs);
818 1.6 oster ret = EINVAL;
819 1.6 oster goto fail;
820 1.6 oster }
821 1.6 oster if (disks[spare_number].numBlocks < raidPtr->sectorsPerDisk) {
822 1.6 oster RF_ERRORMSG3("Spare disk %s (%d blocks) is too small to serve as a spare (need %ld blocks)\n",
823 1.6 oster disks[spare_number].devname,
824 1.6 oster disks[spare_number].blockSize,
825 1.6 oster (long int) raidPtr->sectorsPerDisk);
826 1.6 oster ret = EINVAL;
827 1.6 oster goto fail;
828 1.6 oster } else {
829 1.6 oster if (disks[spare_number].numBlocks >
830 1.6 oster raidPtr->sectorsPerDisk) {
831 1.6 oster RF_ERRORMSG2("Warning: truncating spare disk %s to %ld blocks\n", disks[spare_number].devname,
832 1.6 oster (long int) raidPtr->sectorsPerDisk);
833 1.6 oster
834 1.6 oster disks[spare_number].numBlocks = raidPtr->sectorsPerDisk;
835 1.6 oster }
836 1.5 oster }
837 1.6 oster
838 1.6 oster raidPtr->numSpare++;
839 1.6 oster
840 1.5 oster return (0);
841 1.6 oster
842 1.6 oster fail:
843 1.6 oster return(ret);
844 1.6 oster }
845 1.6 oster
846 1.6 oster int
847 1.6 oster rf_remove_hot_spare(raidPtr,sparePtr)
848 1.6 oster RF_Raid_t *raidPtr;
849 1.7 oster RF_SingleComponent_t *sparePtr;
850 1.6 oster {
851 1.6 oster int spare_number;
852 1.6 oster
853 1.6 oster
854 1.6 oster if (raidPtr->numSpare==0) {
855 1.6 oster printf("No spares to remove!\n");
856 1.6 oster return(EINVAL);
857 1.6 oster }
858 1.6 oster
859 1.7 oster spare_number = sparePtr->column;
860 1.6 oster
861 1.6 oster return(EINVAL); /* XXX not implemented yet */
862 1.6 oster #if 0
863 1.6 oster if (spare_number < 0 || spare_number > raidPtr->numSpare) {
864 1.6 oster return(EINVAL);
865 1.6 oster }
866 1.6 oster
867 1.6 oster /* verify that this spare isn't in use... */
868 1.6 oster
869 1.6 oster
870 1.6 oster
871 1.6 oster
872 1.6 oster /* it's gone.. */
873 1.6 oster
874 1.6 oster raidPtr->numSpare--;
875 1.6 oster
876 1.6 oster return(0);
877 1.6 oster #endif
878 1.1 oster }
879 1.6 oster
880 1.6 oster
881