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