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