rf_disks.c revision 1.15 1 1.15 oster /* $NetBSD: rf_disks.c,v 1.15 2000/02/13 04:53:57 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.14 oster #include "rf_kintf.h"
77 1.15 oster #include "rf_netbsd.h"
78 1.1 oster
79 1.1 oster #include <sys/types.h>
80 1.1 oster #include <sys/param.h>
81 1.1 oster #include <sys/systm.h>
82 1.1 oster #include <sys/proc.h>
83 1.1 oster #include <sys/ioctl.h>
84 1.1 oster #include <sys/fcntl.h>
85 1.1 oster #include <sys/vnode.h>
86 1.1 oster
87 1.6 oster /* XXX these should be in a header file somewhere */
88 1.6 oster void rf_UnconfigureVnodes( RF_Raid_t * );
89 1.6 oster int rf_CheckLabels( RF_Raid_t *, RF_Config_t *);
90 1.15 oster static int rf_AllocDiskStructures(RF_Raid_t *, RF_Config_t *);
91 1.1 oster
92 1.1 oster #define DPRINTF6(a,b,c,d,e,f) if (rf_diskDebug) printf(a,b,c,d,e,f)
93 1.1 oster #define DPRINTF7(a,b,c,d,e,f,g) if (rf_diskDebug) printf(a,b,c,d,e,f,g)
94 1.1 oster
95 1.6 oster /**************************************************************************
96 1.1 oster *
97 1.1 oster * initialize the disks comprising the array
98 1.1 oster *
99 1.6 oster * We want the spare disks to have regular row,col numbers so that we can
100 1.6 oster * easily substitue a spare for a failed disk. But, the driver code assumes
101 1.6 oster * throughout that the array contains numRow by numCol _non-spare_ disks, so
102 1.6 oster * it's not clear how to fit in the spares. This is an unfortunate holdover
103 1.6 oster * from raidSim. The quick and dirty fix is to make row zero bigger than the
104 1.6 oster * rest, and put all the spares in it. This probably needs to get changed
105 1.6 oster * eventually.
106 1.1 oster *
107 1.6 oster **************************************************************************/
108 1.6 oster
109 1.5 oster int
110 1.6 oster rf_ConfigureDisks( listp, raidPtr, cfgPtr )
111 1.6 oster RF_ShutdownList_t **listp;
112 1.6 oster RF_Raid_t *raidPtr;
113 1.6 oster RF_Config_t *cfgPtr;
114 1.1 oster {
115 1.5 oster RF_RaidDisk_t **disks;
116 1.5 oster RF_SectorCount_t min_numblks = (RF_SectorCount_t) 0x7FFFFFFFFFFFLL;
117 1.5 oster RF_RowCol_t r, c;
118 1.6 oster int bs, ret;
119 1.5 oster unsigned i, count, foundone = 0, numFailuresThisRow;
120 1.7 oster int force;
121 1.5 oster
122 1.7 oster force = cfgPtr->force;
123 1.5 oster
124 1.6 oster RF_CallocAndAdd(disks, raidPtr->numRow, sizeof(RF_RaidDisk_t *),
125 1.6 oster (RF_RaidDisk_t **), raidPtr->cleanupList);
126 1.5 oster if (disks == NULL) {
127 1.5 oster ret = ENOMEM;
128 1.5 oster goto fail;
129 1.5 oster }
130 1.5 oster raidPtr->Disks = disks;
131 1.5 oster
132 1.5 oster /* get space for the device-specific stuff... */
133 1.5 oster RF_CallocAndAdd(raidPtr->raid_cinfo, raidPtr->numRow,
134 1.5 oster sizeof(struct raidcinfo *), (struct raidcinfo **),
135 1.5 oster raidPtr->cleanupList);
136 1.5 oster if (raidPtr->raid_cinfo == NULL) {
137 1.5 oster ret = ENOMEM;
138 1.5 oster goto fail;
139 1.5 oster }
140 1.5 oster for (r = 0; r < raidPtr->numRow; r++) {
141 1.5 oster numFailuresThisRow = 0;
142 1.6 oster /* We allocate RF_MAXSPARE on the first row so that we
143 1.6 oster have room to do hot-swapping of spares */
144 1.6 oster RF_CallocAndAdd(disks[r], raidPtr->numCol
145 1.6 oster + ((r == 0) ? RF_MAXSPARE : 0),
146 1.6 oster sizeof(RF_RaidDisk_t), (RF_RaidDisk_t *),
147 1.6 oster raidPtr->cleanupList);
148 1.5 oster if (disks[r] == NULL) {
149 1.5 oster ret = ENOMEM;
150 1.5 oster goto fail;
151 1.5 oster }
152 1.5 oster /* get more space for device specific stuff.. */
153 1.5 oster RF_CallocAndAdd(raidPtr->raid_cinfo[r],
154 1.5 oster raidPtr->numCol + ((r == 0) ? raidPtr->numSpare : 0),
155 1.5 oster sizeof(struct raidcinfo), (struct raidcinfo *),
156 1.1 oster raidPtr->cleanupList);
157 1.5 oster if (raidPtr->raid_cinfo[r] == NULL) {
158 1.5 oster ret = ENOMEM;
159 1.5 oster goto fail;
160 1.5 oster }
161 1.5 oster for (c = 0; c < raidPtr->numCol; c++) {
162 1.15 oster ret = rf_ConfigureDisk(raidPtr,
163 1.15 oster &cfgPtr->devnames[r][c][0],
164 1.15 oster &disks[r][c], r, c);
165 1.15 oster
166 1.5 oster if (ret)
167 1.5 oster goto fail;
168 1.7 oster
169 1.6 oster if (disks[r][c].status == rf_ds_optimal) {
170 1.6 oster raidread_component_label(
171 1.6 oster raidPtr->raid_cinfo[r][c].ci_dev,
172 1.6 oster raidPtr->raid_cinfo[r][c].ci_vp,
173 1.6 oster &raidPtr->raid_cinfo[r][c].ci_label);
174 1.6 oster }
175 1.7 oster
176 1.5 oster if (disks[r][c].status != rf_ds_optimal) {
177 1.5 oster numFailuresThisRow++;
178 1.5 oster } else {
179 1.5 oster if (disks[r][c].numBlocks < min_numblks)
180 1.5 oster min_numblks = disks[r][c].numBlocks;
181 1.5 oster DPRINTF7("Disk at row %d col %d: dev %s numBlocks %ld blockSize %d (%ld MB)\n",
182 1.5 oster r, c, disks[r][c].devname,
183 1.5 oster (long int) disks[r][c].numBlocks,
184 1.5 oster disks[r][c].blockSize,
185 1.6 oster (long int) disks[r][c].numBlocks *
186 1.6 oster disks[r][c].blockSize / 1024 / 1024);
187 1.5 oster }
188 1.5 oster }
189 1.5 oster /* XXX fix for n-fault tolerant */
190 1.6 oster /* XXX this should probably check to see how many failures
191 1.6 oster we can handle for this configuration! */
192 1.5 oster if (numFailuresThisRow > 0)
193 1.5 oster raidPtr->status[r] = rf_rs_degraded;
194 1.5 oster }
195 1.6 oster
196 1.5 oster /* all disks must be the same size & have the same block size, bs must
197 1.5 oster * be a power of 2 */
198 1.5 oster bs = 0;
199 1.5 oster for (foundone = r = 0; !foundone && r < raidPtr->numRow; r++) {
200 1.5 oster for (c = 0; !foundone && c < raidPtr->numCol; c++) {
201 1.5 oster if (disks[r][c].status == rf_ds_optimal) {
202 1.5 oster bs = disks[r][c].blockSize;
203 1.5 oster foundone = 1;
204 1.5 oster }
205 1.5 oster }
206 1.5 oster }
207 1.5 oster if (!foundone) {
208 1.5 oster RF_ERRORMSG("RAIDFRAME: Did not find any live disks in the array.\n");
209 1.5 oster ret = EINVAL;
210 1.5 oster goto fail;
211 1.5 oster }
212 1.5 oster for (count = 0, i = 1; i; i <<= 1)
213 1.5 oster if (bs & i)
214 1.5 oster count++;
215 1.5 oster if (count != 1) {
216 1.5 oster RF_ERRORMSG1("Error: block size on disks (%d) must be a power of 2\n", bs);
217 1.5 oster ret = EINVAL;
218 1.5 oster goto fail;
219 1.5 oster }
220 1.6 oster
221 1.6 oster if (rf_CheckLabels( raidPtr, cfgPtr )) {
222 1.7 oster printf("raid%d: There were fatal errors\n", raidPtr->raidid);
223 1.7 oster if (force != 0) {
224 1.7 oster printf("raid%d: Fatal errors being ignored.\n",
225 1.7 oster raidPtr->raidid);
226 1.7 oster } else {
227 1.7 oster ret = EINVAL;
228 1.7 oster goto fail;
229 1.7 oster }
230 1.6 oster }
231 1.7 oster
232 1.5 oster for (r = 0; r < raidPtr->numRow; r++) {
233 1.5 oster for (c = 0; c < raidPtr->numCol; c++) {
234 1.5 oster if (disks[r][c].status == rf_ds_optimal) {
235 1.5 oster if (disks[r][c].blockSize != bs) {
236 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);
237 1.5 oster ret = EINVAL;
238 1.5 oster goto fail;
239 1.5 oster }
240 1.5 oster if (disks[r][c].numBlocks != min_numblks) {
241 1.5 oster RF_ERRORMSG3("WARNING: truncating disk at r %d c %d to %d blocks\n",
242 1.5 oster r, c, (int) min_numblks);
243 1.5 oster disks[r][c].numBlocks = min_numblks;
244 1.5 oster }
245 1.5 oster }
246 1.5 oster }
247 1.5 oster }
248 1.5 oster
249 1.5 oster raidPtr->sectorsPerDisk = min_numblks;
250 1.5 oster raidPtr->logBytesPerSector = ffs(bs) - 1;
251 1.5 oster raidPtr->bytesPerSector = bs;
252 1.5 oster raidPtr->sectorMask = bs - 1;
253 1.5 oster return (0);
254 1.1 oster
255 1.1 oster fail:
256 1.6 oster
257 1.6 oster rf_UnconfigureVnodes( raidPtr );
258 1.1 oster
259 1.5 oster return (ret);
260 1.1 oster }
261 1.1 oster
262 1.1 oster
263 1.6 oster /****************************************************************************
264 1.1 oster * set up the data structures describing the spare disks in the array
265 1.1 oster * recall from the above comment that the spare disk descriptors are stored
266 1.1 oster * in row zero, which is specially expanded to hold them.
267 1.6 oster ****************************************************************************/
268 1.5 oster int
269 1.6 oster rf_ConfigureSpareDisks( listp, raidPtr, cfgPtr )
270 1.6 oster RF_ShutdownList_t ** listp;
271 1.6 oster RF_Raid_t * raidPtr;
272 1.6 oster RF_Config_t * cfgPtr;
273 1.1 oster {
274 1.6 oster int i, ret;
275 1.6 oster unsigned int bs;
276 1.5 oster RF_RaidDisk_t *disks;
277 1.5 oster int num_spares_done;
278 1.1 oster
279 1.5 oster num_spares_done = 0;
280 1.5 oster
281 1.5 oster /* The space for the spares should have already been allocated by
282 1.5 oster * ConfigureDisks() */
283 1.5 oster
284 1.5 oster disks = &raidPtr->Disks[0][raidPtr->numCol];
285 1.5 oster for (i = 0; i < raidPtr->numSpare; i++) {
286 1.5 oster ret = rf_ConfigureDisk(raidPtr, &cfgPtr->spare_names[i][0],
287 1.6 oster &disks[i], 0, raidPtr->numCol + i);
288 1.5 oster if (ret)
289 1.5 oster goto fail;
290 1.5 oster if (disks[i].status != rf_ds_optimal) {
291 1.6 oster RF_ERRORMSG1("Warning: spare disk %s failed TUR\n",
292 1.6 oster &cfgPtr->spare_names[i][0]);
293 1.5 oster } else {
294 1.5 oster disks[i].status = rf_ds_spare; /* change status to
295 1.5 oster * spare */
296 1.5 oster DPRINTF6("Spare Disk %d: dev %s numBlocks %ld blockSize %d (%ld MB)\n", i,
297 1.5 oster disks[i].devname,
298 1.5 oster (long int) disks[i].numBlocks, disks[i].blockSize,
299 1.6 oster (long int) disks[i].numBlocks *
300 1.6 oster disks[i].blockSize / 1024 / 1024);
301 1.5 oster }
302 1.5 oster num_spares_done++;
303 1.5 oster }
304 1.1 oster
305 1.5 oster /* check sizes and block sizes on spare disks */
306 1.5 oster bs = 1 << raidPtr->logBytesPerSector;
307 1.5 oster for (i = 0; i < raidPtr->numSpare; i++) {
308 1.5 oster if (disks[i].blockSize != bs) {
309 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);
310 1.5 oster ret = EINVAL;
311 1.5 oster goto fail;
312 1.5 oster }
313 1.5 oster if (disks[i].numBlocks < raidPtr->sectorsPerDisk) {
314 1.5 oster RF_ERRORMSG3("Spare disk %s (%d blocks) is too small to serve as a spare (need %ld blocks)\n",
315 1.6 oster disks[i].devname, disks[i].blockSize,
316 1.6 oster (long int) raidPtr->sectorsPerDisk);
317 1.5 oster ret = EINVAL;
318 1.5 oster goto fail;
319 1.5 oster } else
320 1.5 oster if (disks[i].numBlocks > raidPtr->sectorsPerDisk) {
321 1.5 oster RF_ERRORMSG2("Warning: truncating spare disk %s to %ld blocks\n", disks[i].devname, (long int) raidPtr->sectorsPerDisk);
322 1.5 oster
323 1.5 oster disks[i].numBlocks = raidPtr->sectorsPerDisk;
324 1.5 oster }
325 1.5 oster }
326 1.5 oster
327 1.5 oster return (0);
328 1.1 oster
329 1.1 oster fail:
330 1.2 oster
331 1.5 oster /* Release the hold on the main components. We've failed to allocate
332 1.6 oster * a spare, and since we're failing, we need to free things..
333 1.6 oster
334 1.6 oster XXX failing to allocate a spare is *not* that big of a deal...
335 1.6 oster We *can* survive without it, if need be, esp. if we get hot
336 1.6 oster adding working.
337 1.1 oster
338 1.6 oster If we don't fail out here, then we need a way to remove this spare...
339 1.6 oster that should be easier to do here than if we are "live"...
340 1.1 oster
341 1.6 oster */
342 1.1 oster
343 1.6 oster rf_UnconfigureVnodes( raidPtr );
344 1.15 oster
345 1.5 oster return (ret);
346 1.1 oster }
347 1.1 oster
348 1.15 oster static int
349 1.15 oster rf_AllocDiskStructures(raidPtr, cfgPtr)
350 1.15 oster RF_Raid_t *raidPtr;
351 1.15 oster RF_Config_t *cfgPtr;
352 1.15 oster {
353 1.15 oster RF_RaidDisk_t **disks;
354 1.15 oster int ret;
355 1.15 oster int r;
356 1.1 oster
357 1.15 oster RF_CallocAndAdd(disks, raidPtr->numRow, sizeof(RF_RaidDisk_t *),
358 1.15 oster (RF_RaidDisk_t **), raidPtr->cleanupList);
359 1.15 oster if (disks == NULL) {
360 1.15 oster ret = ENOMEM;
361 1.15 oster goto fail;
362 1.15 oster }
363 1.15 oster raidPtr->Disks = disks;
364 1.15 oster /* get space for the device-specific stuff... */
365 1.15 oster RF_CallocAndAdd(raidPtr->raid_cinfo, raidPtr->numRow,
366 1.15 oster sizeof(struct raidcinfo *), (struct raidcinfo **),
367 1.15 oster raidPtr->cleanupList);
368 1.15 oster if (raidPtr->raid_cinfo == NULL) {
369 1.15 oster ret = ENOMEM;
370 1.15 oster goto fail;
371 1.15 oster }
372 1.15 oster
373 1.15 oster for (r = 0; r < raidPtr->numRow; r++) {
374 1.15 oster /* We allocate RF_MAXSPARE on the first row so that we
375 1.15 oster have room to do hot-swapping of spares */
376 1.15 oster RF_CallocAndAdd(disks[r], raidPtr->numCol
377 1.15 oster + ((r == 0) ? RF_MAXSPARE : 0),
378 1.15 oster sizeof(RF_RaidDisk_t), (RF_RaidDisk_t *),
379 1.15 oster raidPtr->cleanupList);
380 1.15 oster if (disks[r] == NULL) {
381 1.15 oster ret = ENOMEM;
382 1.15 oster goto fail;
383 1.15 oster }
384 1.15 oster /* get more space for device specific stuff.. */
385 1.15 oster RF_CallocAndAdd(raidPtr->raid_cinfo[r],
386 1.15 oster raidPtr->numCol + ((r == 0) ? raidPtr->numSpare : 0),
387 1.15 oster sizeof(struct raidcinfo), (struct raidcinfo *),
388 1.15 oster raidPtr->cleanupList);
389 1.15 oster if (raidPtr->raid_cinfo[r] == NULL) {
390 1.15 oster ret = ENOMEM;
391 1.15 oster goto fail;
392 1.15 oster }
393 1.15 oster }
394 1.15 oster return(0);
395 1.15 oster fail:
396 1.15 oster rf_UnconfigureVnodes( raidPtr );
397 1.15 oster
398 1.15 oster return(ret);
399 1.15 oster }
400 1.15 oster
401 1.15 oster
402 1.15 oster /* configure a single disk during auto-configuration at boot */
403 1.15 oster int
404 1.15 oster rf_AutoConfigureDisks(raidPtr, cfgPtr, auto_config)
405 1.15 oster RF_Raid_t *raidPtr;
406 1.15 oster RF_Config_t *cfgPtr;
407 1.15 oster RF_AutoConfig_t *auto_config;
408 1.15 oster {
409 1.15 oster RF_RaidDisk_t **disks;
410 1.15 oster RF_RaidDisk_t *diskPtr;
411 1.15 oster RF_RowCol_t r, c;
412 1.15 oster RF_SectorCount_t min_numblks = (RF_SectorCount_t) 0x7FFFFFFFFFFFLL;
413 1.15 oster int bs, ret;
414 1.15 oster int numFailuresThisRow;
415 1.15 oster int force;
416 1.15 oster RF_AutoConfig_t *ac;
417 1.15 oster
418 1.15 oster #if DEBUG
419 1.15 oster printf("Starting autoconfiguration of RAID set...\n");
420 1.15 oster #endif
421 1.15 oster force = cfgPtr->force;
422 1.15 oster
423 1.15 oster ret = rf_AllocDiskStructures(raidPtr, cfgPtr);
424 1.15 oster if (ret)
425 1.15 oster goto fail;
426 1.15 oster
427 1.15 oster disks = raidPtr->Disks;
428 1.15 oster
429 1.15 oster for (r = 0; r < raidPtr->numRow; r++) {
430 1.15 oster numFailuresThisRow = 0;
431 1.15 oster for (c = 0; c < raidPtr->numCol; c++) {
432 1.15 oster diskPtr = &disks[r][c];
433 1.15 oster
434 1.15 oster /* find this row/col in the autoconfig */
435 1.15 oster #if DEBUG
436 1.15 oster printf("Looking for %d,%d in autoconfig\n",r,c);
437 1.15 oster #endif
438 1.15 oster ac = auto_config;
439 1.15 oster while(ac!=NULL) {
440 1.15 oster if (ac->clabel==NULL) {
441 1.15 oster /* big-time bad news. */
442 1.15 oster goto fail;
443 1.15 oster }
444 1.15 oster if ((ac->clabel->row == r) &&
445 1.15 oster (ac->clabel->column == c)) {
446 1.15 oster /* it's this one... */
447 1.15 oster #if DEBUG
448 1.15 oster printf("Found: %s at %d,%d\n",
449 1.15 oster ac->devname,r,c);
450 1.15 oster #endif
451 1.15 oster break;
452 1.15 oster }
453 1.15 oster ac=ac->next;
454 1.15 oster }
455 1.15 oster
456 1.15 oster if (ac!=NULL) {
457 1.15 oster /* Found it. Configure it.. */
458 1.15 oster diskPtr->blockSize = ac->clabel->blockSize;
459 1.15 oster diskPtr->numBlocks = ac->clabel->numBlocks;
460 1.15 oster /* Note: rf_protectedSectors is already
461 1.15 oster factored into numBlocks here */
462 1.15 oster raidPtr->raid_cinfo[r][c].ci_vp = ac->vp;
463 1.15 oster raidPtr->raid_cinfo[r][c].ci_dev = ac->dev;
464 1.15 oster
465 1.15 oster memcpy(&raidPtr->raid_cinfo[r][c].ci_label,
466 1.15 oster ac->clabel, sizeof(*ac->clabel));
467 1.15 oster sprintf(diskPtr->devname, "/dev/%s",
468 1.15 oster ac->devname);
469 1.15 oster diskPtr->dev = ac->dev;
470 1.15 oster
471 1.15 oster /*
472 1.15 oster * we allow the user to specify that
473 1.15 oster * only a fraction of the disks should
474 1.15 oster * be used this is just for debug: it
475 1.15 oster * speeds up the parity scan
476 1.15 oster */
477 1.15 oster
478 1.15 oster diskPtr->numBlocks = diskPtr->numBlocks *
479 1.15 oster rf_sizePercentage / 100;
480 1.15 oster
481 1.15 oster /* XXX these will get set multiple times,
482 1.15 oster but since we're autoconfiguring, they'd
483 1.15 oster better be always the same each time!
484 1.15 oster If not, this is the least of your worries */
485 1.15 oster
486 1.15 oster bs = diskPtr->blockSize;
487 1.15 oster min_numblks = diskPtr->numBlocks;
488 1.15 oster } else {
489 1.15 oster /* Didn't find it!! Component must be dead */
490 1.15 oster disks[r][c].status = rf_ds_failed;
491 1.15 oster numFailuresThisRow++;
492 1.15 oster }
493 1.15 oster }
494 1.15 oster /* XXX fix for n-fault tolerant */
495 1.15 oster /* XXX this should probably check to see how many failures
496 1.15 oster we can handle for this configuration! */
497 1.15 oster if (numFailuresThisRow > 0)
498 1.15 oster raidPtr->status[r] = rf_rs_degraded;
499 1.15 oster }
500 1.15 oster
501 1.15 oster raidPtr->sectorsPerDisk = min_numblks;
502 1.15 oster raidPtr->logBytesPerSector = ffs(bs) - 1;
503 1.15 oster raidPtr->bytesPerSector = bs;
504 1.15 oster raidPtr->sectorMask = bs - 1;
505 1.15 oster return (0);
506 1.15 oster
507 1.15 oster fail:
508 1.15 oster
509 1.15 oster rf_UnconfigureVnodes( raidPtr );
510 1.15 oster
511 1.15 oster return (ret);
512 1.15 oster
513 1.15 oster }
514 1.1 oster
515 1.1 oster /* configure a single disk in the array */
516 1.5 oster int
517 1.6 oster rf_ConfigureDisk(raidPtr, buf, diskPtr, row, col)
518 1.6 oster RF_Raid_t *raidPtr;
519 1.5 oster char *buf;
520 1.5 oster RF_RaidDisk_t *diskPtr;
521 1.5 oster RF_RowCol_t row;
522 1.5 oster RF_RowCol_t col;
523 1.1 oster {
524 1.5 oster char *p;
525 1.5 oster int retcode;
526 1.1 oster
527 1.1 oster struct partinfo dpart;
528 1.1 oster struct vnode *vp;
529 1.1 oster struct vattr va;
530 1.1 oster struct proc *proc;
531 1.5 oster int error;
532 1.1 oster
533 1.5 oster retcode = 0;
534 1.5 oster p = rf_find_non_white(buf);
535 1.5 oster if (p[strlen(p) - 1] == '\n') {
536 1.5 oster /* strip off the newline */
537 1.5 oster p[strlen(p) - 1] = '\0';
538 1.5 oster }
539 1.5 oster (void) strcpy(diskPtr->devname, p);
540 1.1 oster
541 1.13 oster proc = raidPtr->engine_thread;
542 1.5 oster
543 1.5 oster /* Let's start by claiming the component is fine and well... */
544 1.5 oster diskPtr->status = rf_ds_optimal;
545 1.5 oster
546 1.5 oster raidPtr->raid_cinfo[row][col].ci_vp = NULL;
547 1.5 oster raidPtr->raid_cinfo[row][col].ci_dev = NULL;
548 1.5 oster
549 1.5 oster error = raidlookup(diskPtr->devname, proc, &vp);
550 1.5 oster if (error) {
551 1.5 oster printf("raidlookup on device: %s failed!\n", diskPtr->devname);
552 1.5 oster if (error == ENXIO) {
553 1.6 oster /* the component isn't there... must be dead :-( */
554 1.5 oster diskPtr->status = rf_ds_failed;
555 1.5 oster } else {
556 1.5 oster return (error);
557 1.5 oster }
558 1.5 oster }
559 1.5 oster if (diskPtr->status == rf_ds_optimal) {
560 1.5 oster
561 1.5 oster if ((error = VOP_GETATTR(vp, &va, proc->p_ucred, proc)) != 0) {
562 1.5 oster return (error);
563 1.5 oster }
564 1.5 oster error = VOP_IOCTL(vp, DIOCGPART, (caddr_t) & dpart,
565 1.6 oster FREAD, proc->p_ucred, proc);
566 1.5 oster if (error) {
567 1.5 oster return (error);
568 1.5 oster }
569 1.6 oster
570 1.5 oster diskPtr->blockSize = dpart.disklab->d_secsize;
571 1.6 oster
572 1.5 oster diskPtr->numBlocks = dpart.part->p_size - rf_protectedSectors;
573 1.15 oster diskPtr->partitionSize = dpart.part->p_size;
574 1.15 oster
575 1.5 oster raidPtr->raid_cinfo[row][col].ci_vp = vp;
576 1.5 oster raidPtr->raid_cinfo[row][col].ci_dev = va.va_rdev;
577 1.6 oster
578 1.6 oster diskPtr->dev = va.va_rdev;
579 1.6 oster
580 1.6 oster /* we allow the user to specify that only a fraction of the
581 1.6 oster * disks should be used this is just for debug: it speeds up
582 1.6 oster * the parity scan */
583 1.6 oster diskPtr->numBlocks = diskPtr->numBlocks *
584 1.6 oster rf_sizePercentage / 100;
585 1.6 oster }
586 1.6 oster return (0);
587 1.6 oster }
588 1.6 oster
589 1.7 oster static void rf_print_label_status( RF_Raid_t *, int, int, char *,
590 1.7 oster RF_ComponentLabel_t *);
591 1.7 oster
592 1.7 oster static void
593 1.7 oster rf_print_label_status( raidPtr, row, column, dev_name, ci_label )
594 1.7 oster RF_Raid_t *raidPtr;
595 1.7 oster int row;
596 1.7 oster int column;
597 1.7 oster char *dev_name;
598 1.7 oster RF_ComponentLabel_t *ci_label;
599 1.7 oster {
600 1.7 oster
601 1.7 oster printf("raid%d: Component %s being configured at row: %d col: %d\n",
602 1.7 oster raidPtr->raidid, dev_name, row, column );
603 1.7 oster printf(" Row: %d Column: %d Num Rows: %d Num Columns: %d\n",
604 1.7 oster ci_label->row, ci_label->column,
605 1.7 oster ci_label->num_rows, ci_label->num_columns);
606 1.7 oster printf(" Version: %d Serial Number: %d Mod Counter: %d\n",
607 1.7 oster ci_label->version, ci_label->serial_number,
608 1.7 oster ci_label->mod_counter);
609 1.11 oster printf(" Clean: %s Status: %d\n",
610 1.11 oster ci_label->clean ? "Yes" : "No", ci_label->status );
611 1.7 oster }
612 1.7 oster
613 1.7 oster static int rf_check_label_vitals( RF_Raid_t *, int, int, char *,
614 1.7 oster RF_ComponentLabel_t *, int, int );
615 1.7 oster static int rf_check_label_vitals( raidPtr, row, column, dev_name, ci_label,
616 1.7 oster serial_number, mod_counter )
617 1.7 oster RF_Raid_t *raidPtr;
618 1.7 oster int row;
619 1.7 oster int column;
620 1.7 oster char *dev_name;
621 1.7 oster RF_ComponentLabel_t *ci_label;
622 1.7 oster int serial_number;
623 1.7 oster int mod_counter;
624 1.7 oster {
625 1.7 oster int fatal_error = 0;
626 1.7 oster
627 1.7 oster if (serial_number != ci_label->serial_number) {
628 1.7 oster printf("%s has a different serial number: %d %d\n",
629 1.7 oster dev_name, serial_number, ci_label->serial_number);
630 1.7 oster fatal_error = 1;
631 1.7 oster }
632 1.7 oster if (mod_counter != ci_label->mod_counter) {
633 1.7 oster printf("%s has a different modfication count: %d %d\n",
634 1.7 oster dev_name, mod_counter, ci_label->mod_counter);
635 1.7 oster }
636 1.7 oster
637 1.7 oster if (row != ci_label->row) {
638 1.7 oster printf("Row out of alignment for: %s\n", dev_name);
639 1.7 oster fatal_error = 1;
640 1.7 oster }
641 1.7 oster if (column != ci_label->column) {
642 1.7 oster printf("Column out of alignment for: %s\n", dev_name);
643 1.7 oster fatal_error = 1;
644 1.7 oster }
645 1.7 oster if (raidPtr->numRow != ci_label->num_rows) {
646 1.7 oster printf("Number of rows do not match for: %s\n", dev_name);
647 1.7 oster fatal_error = 1;
648 1.7 oster }
649 1.7 oster if (raidPtr->numCol != ci_label->num_columns) {
650 1.7 oster printf("Number of columns do not match for: %s\n", dev_name);
651 1.7 oster fatal_error = 1;
652 1.7 oster }
653 1.7 oster if (ci_label->clean == 0) {
654 1.7 oster /* it's not clean, but that's not fatal */
655 1.7 oster printf("%s is not clean!\n", dev_name);
656 1.7 oster }
657 1.7 oster return(fatal_error);
658 1.7 oster }
659 1.7 oster
660 1.7 oster
661 1.6 oster /*
662 1.6 oster
663 1.6 oster rf_CheckLabels() - check all the component labels for consistency.
664 1.6 oster Return an error if there is anything major amiss.
665 1.6 oster
666 1.6 oster */
667 1.1 oster
668 1.6 oster int
669 1.6 oster rf_CheckLabels( raidPtr, cfgPtr )
670 1.6 oster RF_Raid_t *raidPtr;
671 1.6 oster RF_Config_t *cfgPtr;
672 1.6 oster {
673 1.6 oster int r,c;
674 1.6 oster char *dev_name;
675 1.6 oster RF_ComponentLabel_t *ci_label;
676 1.6 oster int serial_number = 0;
677 1.7 oster int mod_number = 0;
678 1.6 oster int fatal_error = 0;
679 1.7 oster int mod_values[4];
680 1.7 oster int mod_count[4];
681 1.7 oster int ser_values[4];
682 1.7 oster int ser_count[4];
683 1.7 oster int num_ser;
684 1.7 oster int num_mod;
685 1.7 oster int i;
686 1.7 oster int found;
687 1.7 oster int hosed_row;
688 1.7 oster int hosed_column;
689 1.7 oster int too_fatal;
690 1.7 oster int parity_good;
691 1.7 oster int force;
692 1.7 oster
693 1.7 oster hosed_row = -1;
694 1.7 oster hosed_column = -1;
695 1.7 oster too_fatal = 0;
696 1.7 oster force = cfgPtr->force;
697 1.7 oster
698 1.7 oster /*
699 1.7 oster We're going to try to be a little intelligent here. If one
700 1.7 oster component's label is bogus, and we can identify that it's the
701 1.7 oster *only* one that's gone, we'll mark it as "failed" and allow
702 1.7 oster the configuration to proceed. This will be the *only* case
703 1.7 oster that we'll proceed if there would be (otherwise) fatal errors.
704 1.7 oster
705 1.7 oster Basically we simply keep a count of how many components had
706 1.7 oster what serial number. If all but one agree, we simply mark
707 1.7 oster the disagreeing component as being failed, and allow
708 1.7 oster things to come up "normally".
709 1.7 oster
710 1.7 oster We do this first for serial numbers, and then for "mod_counter".
711 1.6 oster
712 1.7 oster */
713 1.7 oster
714 1.7 oster num_ser = 0;
715 1.7 oster num_mod = 0;
716 1.7 oster for (r = 0; r < raidPtr->numRow && !fatal_error ; r++) {
717 1.7 oster for (c = 0; c < raidPtr->numCol; c++) {
718 1.7 oster ci_label = &raidPtr->raid_cinfo[r][c].ci_label;
719 1.7 oster found=0;
720 1.7 oster for(i=0;i<num_ser;i++) {
721 1.7 oster if (ser_values[i] == ci_label->serial_number) {
722 1.7 oster ser_count[i]++;
723 1.7 oster found=1;
724 1.7 oster break;
725 1.7 oster }
726 1.7 oster }
727 1.7 oster if (!found) {
728 1.7 oster ser_values[num_ser] = ci_label->serial_number;
729 1.7 oster ser_count[num_ser] = 1;
730 1.7 oster num_ser++;
731 1.7 oster if (num_ser>2) {
732 1.7 oster fatal_error = 1;
733 1.7 oster break;
734 1.7 oster }
735 1.7 oster }
736 1.7 oster found=0;
737 1.7 oster for(i=0;i<num_mod;i++) {
738 1.7 oster if (mod_values[i] == ci_label->mod_counter) {
739 1.7 oster mod_count[i]++;
740 1.7 oster found=1;
741 1.7 oster break;
742 1.7 oster }
743 1.7 oster }
744 1.7 oster if (!found) {
745 1.7 oster mod_values[num_mod] = ci_label->mod_counter;
746 1.7 oster mod_count[num_mod] = 1;
747 1.7 oster num_mod++;
748 1.7 oster if (num_mod>2) {
749 1.7 oster fatal_error = 1;
750 1.7 oster break;
751 1.7 oster }
752 1.7 oster }
753 1.7 oster }
754 1.7 oster }
755 1.7 oster #if DEBUG
756 1.7 oster printf("raid%d: Summary of serial numbers:\n", raidPtr->raidid);
757 1.7 oster for(i=0;i<num_ser;i++) {
758 1.7 oster printf("%d %d\n", ser_values[i], ser_count[i]);
759 1.7 oster }
760 1.7 oster printf("raid%d: Summary of mod counters:\n", raidPtr->raidid);
761 1.7 oster for(i=0;i<num_mod;i++) {
762 1.7 oster printf("%d %d\n", mod_values[i], mod_count[i]);
763 1.7 oster }
764 1.7 oster #endif
765 1.7 oster serial_number = ser_values[0];
766 1.7 oster if (num_ser == 2) {
767 1.7 oster if ((ser_count[0] == 1) || (ser_count[1] == 1)) {
768 1.7 oster /* Locate the maverick component */
769 1.7 oster if (ser_count[1] > ser_count[0]) {
770 1.7 oster serial_number = ser_values[1];
771 1.7 oster }
772 1.7 oster for (r = 0; r < raidPtr->numRow; r++) {
773 1.7 oster for (c = 0; c < raidPtr->numCol; c++) {
774 1.7 oster ci_label = &raidPtr->raid_cinfo[r][c].ci_label;
775 1.7 oster if (serial_number !=
776 1.7 oster ci_label->serial_number) {
777 1.7 oster hosed_row = r;
778 1.7 oster hosed_column = c;
779 1.7 oster break;
780 1.7 oster }
781 1.7 oster }
782 1.7 oster }
783 1.7 oster printf("Hosed component: %s\n",
784 1.7 oster &cfgPtr->devnames[hosed_row][hosed_column][0]);
785 1.7 oster if (!force) {
786 1.7 oster /* we'll fail this component, as if there are
787 1.7 oster other major errors, we arn't forcing things
788 1.7 oster and we'll abort the config anyways */
789 1.7 oster raidPtr->Disks[hosed_row][hosed_column].status
790 1.7 oster = rf_ds_failed;
791 1.7 oster raidPtr->numFailures++;
792 1.7 oster raidPtr->status[hosed_row] = rf_rs_degraded;
793 1.7 oster }
794 1.7 oster } else {
795 1.7 oster too_fatal = 1;
796 1.7 oster }
797 1.7 oster if (cfgPtr->parityConfig == '0') {
798 1.7 oster /* We've identified two different serial numbers.
799 1.7 oster RAID 0 can't cope with that, so we'll punt */
800 1.7 oster too_fatal = 1;
801 1.7 oster }
802 1.7 oster
803 1.7 oster }
804 1.7 oster
805 1.7 oster /* record the serial number for later. If we bail later, setting
806 1.7 oster this doesn't matter, otherwise we've got the best guess at the
807 1.7 oster correct serial number */
808 1.7 oster raidPtr->serial_number = serial_number;
809 1.7 oster
810 1.7 oster mod_number = mod_values[0];
811 1.7 oster if (num_mod == 2) {
812 1.7 oster if ((mod_count[0] == 1) || (mod_count[1] == 1)) {
813 1.7 oster /* Locate the maverick component */
814 1.7 oster if (mod_count[1] > mod_count[0]) {
815 1.7 oster mod_number = mod_values[1];
816 1.8 oster } else if (mod_count[1] < mod_count[0]) {
817 1.8 oster mod_number = mod_values[0];
818 1.8 oster } else {
819 1.8 oster /* counts of different modification values
820 1.8 oster are the same. Assume greater value is
821 1.8 oster the correct one, all other things
822 1.8 oster considered */
823 1.8 oster if (mod_values[0] > mod_values[1]) {
824 1.8 oster mod_number = mod_values[0];
825 1.8 oster } else {
826 1.8 oster mod_number = mod_values[1];
827 1.8 oster }
828 1.8 oster
829 1.8 oster }
830 1.7 oster for (r = 0; r < raidPtr->numRow && !too_fatal ; r++) {
831 1.7 oster for (c = 0; c < raidPtr->numCol; c++) {
832 1.7 oster ci_label = &raidPtr->raid_cinfo[r][c].ci_label;
833 1.7 oster if (mod_number !=
834 1.7 oster ci_label->mod_counter) {
835 1.7 oster if ( ( hosed_row == r ) &&
836 1.7 oster ( hosed_column == c )) {
837 1.7 oster /* same one. Can
838 1.7 oster deal with it. */
839 1.7 oster } else {
840 1.7 oster hosed_row = r;
841 1.7 oster hosed_column = c;
842 1.7 oster if (num_ser != 1) {
843 1.7 oster too_fatal = 1;
844 1.7 oster break;
845 1.7 oster }
846 1.7 oster }
847 1.7 oster }
848 1.7 oster }
849 1.7 oster }
850 1.7 oster printf("Hosed component: %s\n",
851 1.7 oster &cfgPtr->devnames[hosed_row][hosed_column][0]);
852 1.7 oster if (!force) {
853 1.7 oster /* we'll fail this component, as if there are
854 1.7 oster other major errors, we arn't forcing things
855 1.7 oster and we'll abort the config anyways */
856 1.9 oster if (raidPtr->Disks[hosed_row][hosed_column].status != rf_ds_failed) {
857 1.9 oster raidPtr->Disks[hosed_row][hosed_column].status
858 1.9 oster = rf_ds_failed;
859 1.9 oster raidPtr->numFailures++;
860 1.9 oster raidPtr->status[hosed_row] = rf_rs_degraded;
861 1.9 oster }
862 1.7 oster }
863 1.7 oster } else {
864 1.7 oster too_fatal = 1;
865 1.7 oster }
866 1.7 oster if (cfgPtr->parityConfig == '0') {
867 1.7 oster /* We've identified two different mod counters.
868 1.7 oster RAID 0 can't cope with that, so we'll punt */
869 1.7 oster too_fatal = 1;
870 1.7 oster }
871 1.7 oster }
872 1.7 oster
873 1.7 oster raidPtr->mod_counter = mod_number;
874 1.7 oster
875 1.7 oster if (too_fatal) {
876 1.7 oster /* we've had both a serial number mismatch, and a mod_counter
877 1.7 oster mismatch -- and they involved two different components!!
878 1.7 oster Bail -- make things fail so that the user must force
879 1.7 oster the issue... */
880 1.7 oster hosed_row = -1;
881 1.7 oster hosed_column = -1;
882 1.7 oster }
883 1.7 oster
884 1.7 oster if (num_ser > 2) {
885 1.7 oster printf("raid%d: Too many different serial numbers!\n",
886 1.7 oster raidPtr->raidid);
887 1.7 oster }
888 1.7 oster
889 1.7 oster if (num_mod > 2) {
890 1.7 oster printf("raid%d: Too many different mod counters!\n",
891 1.7 oster raidPtr->raidid);
892 1.7 oster }
893 1.7 oster
894 1.7 oster /* we start by assuming the parity will be good, and flee from
895 1.7 oster that notion at the slightest sign of trouble */
896 1.7 oster
897 1.7 oster parity_good = RF_RAID_CLEAN;
898 1.6 oster for (r = 0; r < raidPtr->numRow; r++) {
899 1.6 oster for (c = 0; c < raidPtr->numCol; c++) {
900 1.6 oster dev_name = &cfgPtr->devnames[r][c][0];
901 1.6 oster ci_label = &raidPtr->raid_cinfo[r][c].ci_label;
902 1.7 oster
903 1.7 oster if ((r == hosed_row) && (c == hosed_column)) {
904 1.7 oster printf("raid%d: Ignoring %s\n",
905 1.7 oster raidPtr->raidid, dev_name);
906 1.7 oster } else {
907 1.7 oster rf_print_label_status( raidPtr, r, c,
908 1.7 oster dev_name, ci_label );
909 1.7 oster if (rf_check_label_vitals( raidPtr, r, c,
910 1.7 oster dev_name, ci_label,
911 1.7 oster serial_number,
912 1.7 oster mod_number )) {
913 1.6 oster fatal_error = 1;
914 1.6 oster }
915 1.7 oster if (ci_label->clean != RF_RAID_CLEAN) {
916 1.7 oster parity_good = RF_RAID_DIRTY;
917 1.6 oster }
918 1.6 oster }
919 1.6 oster }
920 1.6 oster }
921 1.7 oster if (fatal_error) {
922 1.7 oster parity_good = RF_RAID_DIRTY;
923 1.7 oster }
924 1.7 oster
925 1.7 oster /* we note the state of the parity */
926 1.7 oster raidPtr->parity_good = parity_good;
927 1.6 oster
928 1.6 oster return(fatal_error);
929 1.6 oster }
930 1.6 oster
931 1.7 oster int rf_add_hot_spare(RF_Raid_t *, RF_SingleComponent_t *);
932 1.6 oster int
933 1.6 oster rf_add_hot_spare(raidPtr, sparePtr)
934 1.6 oster RF_Raid_t *raidPtr;
935 1.7 oster RF_SingleComponent_t *sparePtr;
936 1.6 oster {
937 1.6 oster RF_RaidDisk_t *disks;
938 1.9 oster RF_DiskQueue_t *spareQueues;
939 1.6 oster int ret;
940 1.6 oster unsigned int bs;
941 1.6 oster int spare_number;
942 1.6 oster
943 1.6 oster printf("Just in rf_add_hot_spare: %d\n",raidPtr->numSpare);
944 1.6 oster printf("Num col: %d\n",raidPtr->numCol);
945 1.6 oster if (raidPtr->numSpare >= RF_MAXSPARE) {
946 1.6 oster RF_ERRORMSG1("Too many spares: %d\n", raidPtr->numSpare);
947 1.6 oster return(EINVAL);
948 1.6 oster }
949 1.9 oster
950 1.10 oster RF_LOCK_MUTEX(raidPtr->mutex);
951 1.10 oster
952 1.6 oster /* the beginning of the spares... */
953 1.6 oster disks = &raidPtr->Disks[0][raidPtr->numCol];
954 1.6 oster
955 1.6 oster spare_number = raidPtr->numSpare;
956 1.1 oster
957 1.7 oster ret = rf_ConfigureDisk(raidPtr, sparePtr->component_name,
958 1.6 oster &disks[spare_number], 0,
959 1.6 oster raidPtr->numCol + spare_number);
960 1.1 oster
961 1.6 oster if (ret)
962 1.6 oster goto fail;
963 1.6 oster if (disks[spare_number].status != rf_ds_optimal) {
964 1.6 oster RF_ERRORMSG1("Warning: spare disk %s failed TUR\n",
965 1.7 oster sparePtr->component_name);
966 1.6 oster ret=EINVAL;
967 1.6 oster goto fail;
968 1.6 oster } else {
969 1.6 oster disks[spare_number].status = rf_ds_spare;
970 1.6 oster DPRINTF6("Spare Disk %d: dev %s numBlocks %ld blockSize %d (%ld MB)\n", spare_number,
971 1.6 oster disks[spare_number].devname,
972 1.6 oster (long int) disks[spare_number].numBlocks,
973 1.6 oster disks[spare_number].blockSize,
974 1.6 oster (long int) disks[spare_number].numBlocks *
975 1.6 oster disks[spare_number].blockSize / 1024 / 1024);
976 1.6 oster }
977 1.6 oster
978 1.1 oster
979 1.6 oster /* check sizes and block sizes on the spare disk */
980 1.6 oster bs = 1 << raidPtr->logBytesPerSector;
981 1.6 oster if (disks[spare_number].blockSize != bs) {
982 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);
983 1.6 oster ret = EINVAL;
984 1.6 oster goto fail;
985 1.6 oster }
986 1.6 oster if (disks[spare_number].numBlocks < raidPtr->sectorsPerDisk) {
987 1.6 oster RF_ERRORMSG3("Spare disk %s (%d blocks) is too small to serve as a spare (need %ld blocks)\n",
988 1.6 oster disks[spare_number].devname,
989 1.6 oster disks[spare_number].blockSize,
990 1.6 oster (long int) raidPtr->sectorsPerDisk);
991 1.6 oster ret = EINVAL;
992 1.6 oster goto fail;
993 1.6 oster } else {
994 1.6 oster if (disks[spare_number].numBlocks >
995 1.6 oster raidPtr->sectorsPerDisk) {
996 1.6 oster RF_ERRORMSG2("Warning: truncating spare disk %s to %ld blocks\n", disks[spare_number].devname,
997 1.6 oster (long int) raidPtr->sectorsPerDisk);
998 1.6 oster
999 1.6 oster disks[spare_number].numBlocks = raidPtr->sectorsPerDisk;
1000 1.6 oster }
1001 1.5 oster }
1002 1.6 oster
1003 1.9 oster spareQueues = &raidPtr->Queues[0][raidPtr->numCol];
1004 1.15 oster ret = rf_ConfigureDiskQueue( raidPtr, &spareQueues[spare_number],
1005 1.9 oster 0, raidPtr->numCol + spare_number,
1006 1.9 oster raidPtr->Queues[0][0].qPtr, /* XXX */
1007 1.9 oster raidPtr->sectorsPerDisk,
1008 1.9 oster raidPtr->Disks[0][raidPtr->numCol + spare_number].dev,
1009 1.9 oster raidPtr->Queues[0][0].maxOutstanding, /* XXX */
1010 1.9 oster &raidPtr->shutdownList,
1011 1.9 oster raidPtr->cleanupList);
1012 1.9 oster
1013 1.9 oster
1014 1.6 oster raidPtr->numSpare++;
1015 1.10 oster RF_UNLOCK_MUTEX(raidPtr->mutex);
1016 1.5 oster return (0);
1017 1.6 oster
1018 1.6 oster fail:
1019 1.10 oster RF_UNLOCK_MUTEX(raidPtr->mutex);
1020 1.6 oster return(ret);
1021 1.6 oster }
1022 1.6 oster
1023 1.6 oster int
1024 1.6 oster rf_remove_hot_spare(raidPtr,sparePtr)
1025 1.6 oster RF_Raid_t *raidPtr;
1026 1.7 oster RF_SingleComponent_t *sparePtr;
1027 1.6 oster {
1028 1.6 oster int spare_number;
1029 1.6 oster
1030 1.6 oster
1031 1.6 oster if (raidPtr->numSpare==0) {
1032 1.6 oster printf("No spares to remove!\n");
1033 1.6 oster return(EINVAL);
1034 1.6 oster }
1035 1.6 oster
1036 1.7 oster spare_number = sparePtr->column;
1037 1.6 oster
1038 1.6 oster return(EINVAL); /* XXX not implemented yet */
1039 1.6 oster #if 0
1040 1.6 oster if (spare_number < 0 || spare_number > raidPtr->numSpare) {
1041 1.6 oster return(EINVAL);
1042 1.6 oster }
1043 1.6 oster
1044 1.6 oster /* verify that this spare isn't in use... */
1045 1.6 oster
1046 1.6 oster
1047 1.6 oster
1048 1.6 oster
1049 1.6 oster /* it's gone.. */
1050 1.6 oster
1051 1.6 oster raidPtr->numSpare--;
1052 1.6 oster
1053 1.6 oster return(0);
1054 1.6 oster #endif
1055 1.1 oster }
1056 1.6 oster
1057 1.6 oster
1058