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