Home | History | Annotate | Line # | Download | only in dev
ccd.c revision 1.127.6.2
      1  1.127.6.2       mjf /*	$NetBSD: ccd.c,v 1.127.6.2 2008/04/05 23:33:20 mjf Exp $	*/
      2       1.11   thorpej 
      3       1.28   thorpej /*-
      4      1.117        ad  * Copyright (c) 1996, 1997, 1998, 1999, 2007 The NetBSD Foundation, Inc.
      5       1.11   thorpej  * All rights reserved.
      6       1.11   thorpej  *
      7       1.28   thorpej  * This code is derived from software contributed to The NetBSD Foundation
      8       1.28   thorpej  * by Jason R. Thorpe.
      9       1.28   thorpej  *
     10       1.11   thorpej  * Redistribution and use in source and binary forms, with or without
     11       1.11   thorpej  * modification, are permitted provided that the following conditions
     12       1.11   thorpej  * are met:
     13       1.11   thorpej  * 1. Redistributions of source code must retain the above copyright
     14       1.11   thorpej  *    notice, this list of conditions and the following disclaimer.
     15       1.11   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     16       1.11   thorpej  *    notice, this list of conditions and the following disclaimer in the
     17       1.11   thorpej  *    documentation and/or other materials provided with the distribution.
     18       1.11   thorpej  * 3. All advertising materials mentioning features or use of this software
     19       1.11   thorpej  *    must display the following acknowledgement:
     20       1.28   thorpej  *        This product includes software developed by the NetBSD
     21       1.28   thorpej  *        Foundation, Inc. and its contributors.
     22       1.28   thorpej  * 4. Neither the name of The NetBSD Foundation nor the names of its
     23       1.28   thorpej  *    contributors may be used to endorse or promote products derived
     24       1.28   thorpej  *    from this software without specific prior written permission.
     25       1.11   thorpej  *
     26       1.28   thorpej  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     27       1.28   thorpej  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     28       1.28   thorpej  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     29       1.45       jtc  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     30       1.45       jtc  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     31       1.28   thorpej  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     32       1.28   thorpej  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     33       1.28   thorpej  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     34       1.28   thorpej  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     35       1.28   thorpej  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     36       1.28   thorpej  * POSSIBILITY OF SUCH DAMAGE.
     37       1.11   thorpej  */
     38        1.2       cgd 
     39        1.1   hpeyerl /*
     40        1.3   hpeyerl  * Copyright (c) 1990, 1993
     41        1.3   hpeyerl  *	The Regents of the University of California.  All rights reserved.
     42        1.1   hpeyerl  *
     43        1.1   hpeyerl  * This code is derived from software contributed to Berkeley by
     44        1.1   hpeyerl  * the Systems Programming Group of the University of Utah Computer
     45        1.1   hpeyerl  * Science Department.
     46        1.1   hpeyerl  *
     47        1.1   hpeyerl  * Redistribution and use in source and binary forms, with or without
     48        1.1   hpeyerl  * modification, are permitted provided that the following conditions
     49        1.1   hpeyerl  * are met:
     50        1.1   hpeyerl  * 1. Redistributions of source code must retain the above copyright
     51        1.1   hpeyerl  *    notice, this list of conditions and the following disclaimer.
     52        1.1   hpeyerl  * 2. Redistributions in binary form must reproduce the above copyright
     53        1.1   hpeyerl  *    notice, this list of conditions and the following disclaimer in the
     54        1.1   hpeyerl  *    documentation and/or other materials provided with the distribution.
     55       1.91       agc  * 3. Neither the name of the University nor the names of its contributors
     56       1.91       agc  *    may be used to endorse or promote products derived from this software
     57       1.91       agc  *    without specific prior written permission.
     58       1.91       agc  *
     59       1.91       agc  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     60       1.91       agc  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     61       1.91       agc  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     62       1.91       agc  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     63       1.91       agc  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     64       1.91       agc  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     65       1.91       agc  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     66       1.91       agc  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     67       1.91       agc  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     68       1.91       agc  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     69       1.91       agc  * SUCH DAMAGE.
     70       1.91       agc  *
     71       1.91       agc  * from: Utah $Hdr: cd.c 1.6 90/11/28$
     72       1.91       agc  *
     73       1.91       agc  *	@(#)cd.c	8.2 (Berkeley) 11/16/93
     74       1.91       agc  */
     75       1.91       agc 
     76       1.91       agc /*
     77       1.91       agc  * Copyright (c) 1988 University of Utah.
     78       1.91       agc  *
     79       1.91       agc  * This code is derived from software contributed to Berkeley by
     80       1.91       agc  * the Systems Programming Group of the University of Utah Computer
     81       1.91       agc  * Science Department.
     82       1.91       agc  *
     83       1.91       agc  * Redistribution and use in source and binary forms, with or without
     84       1.91       agc  * modification, are permitted provided that the following conditions
     85       1.91       agc  * are met:
     86       1.91       agc  * 1. Redistributions of source code must retain the above copyright
     87       1.91       agc  *    notice, this list of conditions and the following disclaimer.
     88       1.91       agc  * 2. Redistributions in binary form must reproduce the above copyright
     89       1.91       agc  *    notice, this list of conditions and the following disclaimer in the
     90       1.91       agc  *    documentation and/or other materials provided with the distribution.
     91        1.1   hpeyerl  * 3. All advertising materials mentioning features or use of this software
     92        1.1   hpeyerl  *    must display the following acknowledgement:
     93        1.1   hpeyerl  *	This product includes software developed by the University of
     94        1.1   hpeyerl  *	California, Berkeley and its contributors.
     95        1.1   hpeyerl  * 4. Neither the name of the University nor the names of its contributors
     96        1.1   hpeyerl  *    may be used to endorse or promote products derived from this software
     97        1.1   hpeyerl  *    without specific prior written permission.
     98        1.1   hpeyerl  *
     99        1.1   hpeyerl  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
    100        1.1   hpeyerl  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
    101        1.1   hpeyerl  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
    102        1.1   hpeyerl  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
    103        1.1   hpeyerl  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
    104        1.1   hpeyerl  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
    105        1.1   hpeyerl  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
    106        1.1   hpeyerl  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
    107        1.1   hpeyerl  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
    108        1.1   hpeyerl  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
    109        1.1   hpeyerl  * SUCH DAMAGE.
    110        1.1   hpeyerl  *
    111        1.2       cgd  * from: Utah $Hdr: cd.c 1.6 90/11/28$
    112        1.2       cgd  *
    113        1.3   hpeyerl  *	@(#)cd.c	8.2 (Berkeley) 11/16/93
    114        1.1   hpeyerl  */
    115        1.1   hpeyerl 
    116        1.1   hpeyerl /*
    117        1.1   hpeyerl  * "Concatenated" disk driver.
    118       1.11   thorpej  *
    119       1.11   thorpej  * Dynamic configuration and disklabel support by:
    120       1.11   thorpej  *	Jason R. Thorpe <thorpej (at) nas.nasa.gov>
    121       1.11   thorpej  *	Numerical Aerodynamic Simulation Facility
    122       1.11   thorpej  *	Mail Stop 258-6
    123       1.11   thorpej  *	NASA Ames Research Center
    124       1.11   thorpej  *	Moffett Field, CA 94035
    125        1.1   hpeyerl  */
    126       1.74     lukem 
    127       1.74     lukem #include <sys/cdefs.h>
    128  1.127.6.2       mjf __KERNEL_RCSID(0, "$NetBSD: ccd.c,v 1.127.6.2 2008/04/05 23:33:20 mjf Exp $");
    129        1.1   hpeyerl 
    130        1.1   hpeyerl #include <sys/param.h>
    131        1.1   hpeyerl #include <sys/systm.h>
    132        1.3   hpeyerl #include <sys/proc.h>
    133        1.1   hpeyerl #include <sys/errno.h>
    134        1.1   hpeyerl #include <sys/buf.h>
    135      1.101      yamt #include <sys/bufq.h>
    136        1.1   hpeyerl #include <sys/malloc.h>
    137       1.63   thorpej #include <sys/pool.h>
    138       1.11   thorpej #include <sys/namei.h>
    139        1.3   hpeyerl #include <sys/stat.h>
    140        1.3   hpeyerl #include <sys/ioctl.h>
    141        1.3   hpeyerl #include <sys/disklabel.h>
    142       1.11   thorpej #include <sys/device.h>
    143       1.11   thorpej #include <sys/disk.h>
    144       1.11   thorpej #include <sys/syslog.h>
    145        1.3   hpeyerl #include <sys/fcntl.h>
    146       1.11   thorpej #include <sys/vnode.h>
    147       1.31  christos #include <sys/conf.h>
    148      1.117        ad #include <sys/mutex.h>
    149       1.56   thorpej #include <sys/queue.h>
    150      1.110      elad #include <sys/kauth.h>
    151        1.1   hpeyerl 
    152        1.1   hpeyerl #include <dev/ccdvar.h>
    153      1.113  christos #include <dev/dkvar.h>
    154        1.1   hpeyerl 
    155       1.11   thorpej #if defined(CCDDEBUG) && !defined(DEBUG)
    156       1.11   thorpej #define DEBUG
    157       1.11   thorpej #endif
    158       1.11   thorpej 
    159        1.1   hpeyerl #ifdef DEBUG
    160        1.3   hpeyerl #define CCDB_FOLLOW	0x01
    161        1.3   hpeyerl #define CCDB_INIT	0x02
    162        1.3   hpeyerl #define CCDB_IO		0x04
    163       1.11   thorpej #define CCDB_LABEL	0x08
    164       1.11   thorpej #define CCDB_VNODE	0x10
    165       1.24   thorpej int ccddebug = 0x00;
    166        1.1   hpeyerl #endif
    167        1.1   hpeyerl 
    168        1.6       cgd #define	ccdunit(x)	DISKUNIT(x)
    169        1.6       cgd 
    170        1.6       cgd struct ccdbuf {
    171        1.6       cgd 	struct buf	cb_buf;		/* new I/O buf */
    172        1.6       cgd 	struct buf	*cb_obp;	/* ptr. to original I/O buf */
    173       1.59   thorpej 	struct ccd_softc *cb_sc;	/* pointer to ccd softc */
    174        1.6       cgd 	int		cb_comp;	/* target component */
    175       1.56   thorpej 	SIMPLEQ_ENTRY(ccdbuf) cb_q;	/* fifo of component buffers */
    176       1.38   thorpej };
    177       1.24   thorpej 
    178       1.63   thorpej /* component buffer pool */
    179       1.97   thorpej static struct pool ccd_cbufpool;
    180       1.63   thorpej 
    181       1.63   thorpej #define	CCD_GETBUF()		pool_get(&ccd_cbufpool, PR_NOWAIT)
    182       1.63   thorpej #define	CCD_PUTBUF(cbp)		pool_put(&ccd_cbufpool, cbp)
    183        1.1   hpeyerl 
    184       1.11   thorpej #define CCDLABELDEV(dev)	\
    185       1.11   thorpej 	(MAKEDISKDEV(major((dev)), ccdunit((dev)), RAW_PART))
    186        1.1   hpeyerl 
    187       1.11   thorpej /* called by main() at boot time */
    188       1.97   thorpej void	ccdattach(int);
    189       1.11   thorpej 
    190       1.11   thorpej /* called by biodone() at interrupt time */
    191       1.97   thorpej static void	ccdiodone(struct buf *);
    192       1.11   thorpej 
    193       1.97   thorpej static void	ccdstart(struct ccd_softc *);
    194       1.97   thorpej static void	ccdinterleave(struct ccd_softc *);
    195       1.97   thorpej static void	ccdintr(struct ccd_softc *, struct buf *);
    196       1.97   thorpej static int	ccdinit(struct ccd_softc *, char **, struct vnode **,
    197      1.107  christos 		    struct lwp *);
    198       1.97   thorpej static struct ccdbuf *ccdbuffer(struct ccd_softc *, struct buf *,
    199      1.118  christos 		    daddr_t, void *, long);
    200       1.97   thorpej static void	ccdgetdefaultlabel(struct ccd_softc *, struct disklabel *);
    201       1.97   thorpej static void	ccdgetdisklabel(dev_t);
    202       1.97   thorpej static void	ccdmakedisklabel(struct ccd_softc *);
    203       1.97   thorpej 
    204       1.97   thorpej static dev_type_open(ccdopen);
    205       1.97   thorpej static dev_type_close(ccdclose);
    206       1.97   thorpej static dev_type_read(ccdread);
    207       1.97   thorpej static dev_type_write(ccdwrite);
    208       1.97   thorpej static dev_type_ioctl(ccdioctl);
    209       1.97   thorpej static dev_type_strategy(ccdstrategy);
    210       1.97   thorpej static dev_type_dump(ccddump);
    211       1.97   thorpej static dev_type_size(ccdsize);
    212       1.78   gehenna 
    213       1.78   gehenna const struct bdevsw ccd_bdevsw = {
    214       1.78   gehenna 	ccdopen, ccdclose, ccdstrategy, ccdioctl, ccddump, ccdsize, D_DISK
    215       1.78   gehenna };
    216       1.78   gehenna 
    217       1.78   gehenna const struct cdevsw ccd_cdevsw = {
    218       1.78   gehenna 	ccdopen, ccdclose, ccdread, ccdwrite, ccdioctl,
    219       1.79  jdolecek 	nostop, notty, nopoll, nommap, nokqfilter, D_DISK
    220       1.78   gehenna };
    221        1.3   hpeyerl 
    222       1.11   thorpej #ifdef DEBUG
    223       1.97   thorpej static	void printiinfo(struct ccdiinfo *);
    224       1.11   thorpej #endif
    225       1.11   thorpej 
    226      1.108     lukem /* Publically visible for the benefit of libkvm and ccdconfig(8). */
    227      1.108     lukem struct ccd_softc 	*ccd_softc;
    228      1.108     lukem const int		ccd_softc_elemsize = sizeof(struct ccd_softc);
    229      1.108     lukem int			numccd = 0;
    230        1.1   hpeyerl 
    231        1.3   hpeyerl /*
    232       1.11   thorpej  * Called by main() during pseudo-device attachment.  All we need
    233       1.11   thorpej  * to do is allocate enough space for devices to be configured later.
    234        1.1   hpeyerl  */
    235        1.1   hpeyerl void
    236       1.97   thorpej ccdattach(int num)
    237        1.3   hpeyerl {
    238       1.57   thorpej 	struct ccd_softc *cs;
    239  1.127.6.2       mjf 	int i, j, cmaj, bmaj;
    240       1.57   thorpej 
    241       1.11   thorpej 	if (num <= 0) {
    242       1.11   thorpej #ifdef DIAGNOSTIC
    243       1.11   thorpej 		panic("ccdattach: count <= 0");
    244       1.11   thorpej #endif
    245        1.3   hpeyerl 		return;
    246       1.11   thorpej 	}
    247       1.11   thorpej 
    248      1.108     lukem 	ccd_softc = (struct ccd_softc *)malloc(num * ccd_softc_elemsize,
    249       1.75   tsutsui 	    M_DEVBUF, M_NOWAIT|M_ZERO);
    250       1.57   thorpej 	if (ccd_softc == NULL) {
    251       1.35  christos 		printf("WARNING: no memory for concatenated disks\n");
    252        1.3   hpeyerl 		return;
    253        1.3   hpeyerl 	}
    254        1.3   hpeyerl 	numccd = num;
    255       1.57   thorpej 
    256       1.63   thorpej 	/* Initialize the component buffer pool. */
    257       1.63   thorpej 	pool_init(&ccd_cbufpool, sizeof(struct ccdbuf), 0,
    258      1.119        ad 	    0, 0, "ccdpl", NULL, IPL_BIO);
    259       1.63   thorpej 
    260  1.127.6.2       mjf 	bmaj = bdevsw_lookup_major(&ccd_bdevsw);
    261  1.127.6.2       mjf 	cmaj = cdevsw_lookup_major(&ccd_cdevsw);
    262  1.127.6.2       mjf 
    263       1.57   thorpej 	/* Initialize per-softc structures. */
    264       1.57   thorpej 	for (i = 0; i < num; i++) {
    265       1.57   thorpej 		cs = &ccd_softc[i];
    266       1.96    itojun 		snprintf(cs->sc_xname, sizeof(cs->sc_xname), "ccd%d", i);
    267      1.125        ad 		mutex_init(&cs->sc_lock, MUTEX_DEFAULT, IPL_NONE);
    268      1.123        ad 		disk_init(&cs->sc_dkdev, cs->sc_xname, NULL); /* XXX */
    269  1.127.6.2       mjf 		for (j = 0; j < MAXPARTITIONS; j++) {
    270  1.127.6.2       mjf 			device_register_name(MAKEDISKDEV(bmaj, i, j),
    271  1.127.6.2       mjf 			    NULL, false, DEV_DISK, "ccd%d%c", i, 'a' + j);
    272  1.127.6.2       mjf 			device_register_name(MAKEDISKDEV(cmaj, i, j),
    273  1.127.6.2       mjf 			    NULL, false, DEV_DISK, "rccd%d%c", i, 'a' + j);
    274  1.127.6.2       mjf 		}
    275       1.57   thorpej 	}
    276  1.127.6.2       mjf 
    277        1.1   hpeyerl }
    278        1.1   hpeyerl 
    279       1.11   thorpej static int
    280       1.97   thorpej ccdinit(struct ccd_softc *cs, char **cpaths, struct vnode **vpp,
    281      1.107  christos     struct lwp *l)
    282        1.1   hpeyerl {
    283       1.68  augustss 	struct ccdcinfo *ci = NULL;
    284       1.68  augustss 	size_t size;
    285       1.68  augustss 	int ix;
    286       1.11   thorpej 	struct vattr va;
    287        1.1   hpeyerl 	size_t minsize;
    288       1.11   thorpej 	int maxsecsize;
    289        1.7       cgd 	struct partinfo dpart;
    290       1.11   thorpej 	struct ccdgeom *ccg = &cs->sc_geom;
    291      1.111  christos 	char *tmppath;
    292       1.67     enami 	int error, path_alloced;
    293        1.1   hpeyerl 
    294        1.1   hpeyerl #ifdef DEBUG
    295        1.3   hpeyerl 	if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    296       1.59   thorpej 		printf("%s: ccdinit\n", cs->sc_xname);
    297        1.1   hpeyerl #endif
    298       1.11   thorpej 
    299       1.11   thorpej 	/* Allocate space for the component info. */
    300       1.11   thorpej 	cs->sc_cinfo = malloc(cs->sc_nccdisks * sizeof(struct ccdcinfo),
    301       1.11   thorpej 	    M_DEVBUF, M_WAITOK);
    302       1.11   thorpej 
    303      1.111  christos 	tmppath = malloc(MAXPATHLEN, M_TEMP, M_WAITOK);
    304      1.111  christos 
    305       1.57   thorpej 	cs->sc_size = 0;
    306       1.57   thorpej 
    307        1.1   hpeyerl 	/*
    308        1.1   hpeyerl 	 * Verify that each component piece exists and record
    309        1.1   hpeyerl 	 * relevant information about it.
    310        1.1   hpeyerl 	 */
    311       1.11   thorpej 	maxsecsize = 0;
    312        1.1   hpeyerl 	minsize = 0;
    313       1.67     enami 	for (ix = 0, path_alloced = 0; ix < cs->sc_nccdisks; ix++) {
    314        1.1   hpeyerl 		ci = &cs->sc_cinfo[ix];
    315       1.57   thorpej 		ci->ci_vp = vpp[ix];
    316       1.11   thorpej 
    317       1.11   thorpej 		/*
    318       1.11   thorpej 		 * Copy in the pathname of the component.
    319       1.11   thorpej 		 */
    320       1.72   thorpej 		memset(tmppath, 0, sizeof(tmppath));	/* sanity */
    321       1.29  christos 		error = copyinstr(cpaths[ix], tmppath,
    322       1.29  christos 		    MAXPATHLEN, &ci->ci_pathlen);
    323       1.29  christos 		if (error) {
    324       1.11   thorpej #ifdef DEBUG
    325       1.11   thorpej 			if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    326       1.35  christos 				printf("%s: can't copy path, error = %d\n",
    327       1.23   thorpej 				    cs->sc_xname, error);
    328       1.11   thorpej #endif
    329       1.67     enami 			goto out;
    330       1.11   thorpej 		}
    331       1.11   thorpej 		ci->ci_path = malloc(ci->ci_pathlen, M_DEVBUF, M_WAITOK);
    332       1.72   thorpej 		memcpy(ci->ci_path, tmppath, ci->ci_pathlen);
    333       1.67     enami 		path_alloced++;
    334       1.11   thorpej 
    335       1.11   thorpej 		/*
    336       1.11   thorpej 		 * XXX: Cache the component's dev_t.
    337       1.11   thorpej 		 */
    338      1.124     pooka 		if ((error = VOP_GETATTR(vpp[ix], &va, l->l_cred)) != 0) {
    339       1.11   thorpej #ifdef DEBUG
    340       1.11   thorpej 			if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    341       1.35  christos 				printf("%s: %s: getattr failed %s = %d\n",
    342       1.23   thorpej 				    cs->sc_xname, ci->ci_path,
    343       1.11   thorpej 				    "error", error);
    344       1.11   thorpej #endif
    345       1.67     enami 			goto out;
    346       1.11   thorpej 		}
    347       1.11   thorpej 		ci->ci_dev = va.va_rdev;
    348       1.11   thorpej 
    349        1.3   hpeyerl 		/*
    350       1.11   thorpej 		 * Get partition information for the component.
    351        1.3   hpeyerl 		 */
    352       1.84       dsl 		error = VOP_IOCTL(vpp[ix], DIOCGPART, &dpart,
    353      1.124     pooka 		    FREAD, l->l_cred);
    354       1.29  christos 		if (error) {
    355       1.11   thorpej #ifdef DEBUG
    356       1.11   thorpej 			if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    357       1.35  christos 				 printf("%s: %s: ioctl failed, error = %d\n",
    358       1.23   thorpej 				     cs->sc_xname, ci->ci_path, error);
    359       1.11   thorpej #endif
    360       1.67     enami 			goto out;
    361       1.11   thorpej 		}
    362       1.69     enami 
    363       1.69     enami /*
    364       1.69     enami  * This diagnostic test is disabled (for now?) since not all port supports
    365       1.69     enami  * on-disk BSD disklabel.
    366       1.69     enami  */
    367       1.69     enami #if 0 /* def DIAGNOSTIC */
    368       1.69     enami 		/* Check fstype field of component. */
    369       1.69     enami 		if (dpart.part->p_fstype != FS_CCD)
    370       1.69     enami 			printf("%s: WARNING: %s: fstype %d != FS_CCD\n",
    371       1.69     enami 			    cs->sc_xname, ci->ci_path, dpart.part->p_fstype);
    372       1.69     enami #endif
    373        1.7       cgd 
    374       1.11   thorpej 		/*
    375       1.11   thorpej 		 * Calculate the size, truncating to an interleave
    376       1.11   thorpej 		 * boundary if necessary.
    377       1.11   thorpej 		 */
    378       1.46   thorpej 		maxsecsize =
    379       1.46   thorpej 		    ((dpart.disklab->d_secsize > maxsecsize) ?
    380       1.46   thorpej 		    dpart.disklab->d_secsize : maxsecsize);
    381       1.46   thorpej 		size = dpart.part->p_size;
    382        1.1   hpeyerl 		if (cs->sc_ileave > 1)
    383        1.1   hpeyerl 			size -= size % cs->sc_ileave;
    384       1.11   thorpej 
    385        1.1   hpeyerl 		if (size == 0) {
    386       1.11   thorpej #ifdef DEBUG
    387       1.11   thorpej 			if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    388       1.35  christos 				printf("%s: %s: size == 0\n",
    389       1.23   thorpej 				    cs->sc_xname, ci->ci_path);
    390       1.11   thorpej #endif
    391       1.67     enami 			error = ENODEV;
    392       1.67     enami 			goto out;
    393        1.3   hpeyerl 		}
    394       1.11   thorpej 
    395        1.1   hpeyerl 		if (minsize == 0 || size < minsize)
    396        1.1   hpeyerl 			minsize = size;
    397        1.1   hpeyerl 		ci->ci_size = size;
    398        1.1   hpeyerl 		cs->sc_size += size;
    399        1.1   hpeyerl 	}
    400       1.11   thorpej 
    401       1.11   thorpej 	/*
    402       1.11   thorpej 	 * Don't allow the interleave to be smaller than
    403       1.11   thorpej 	 * the biggest component sector.
    404       1.11   thorpej 	 */
    405       1.11   thorpej 	if ((cs->sc_ileave > 0) &&
    406       1.11   thorpej 	    (cs->sc_ileave < (maxsecsize / DEV_BSIZE))) {
    407       1.11   thorpej #ifdef DEBUG
    408       1.11   thorpej 		if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    409       1.35  christos 			printf("%s: interleave must be at least %d\n",
    410       1.23   thorpej 			    cs->sc_xname, (maxsecsize / DEV_BSIZE));
    411       1.11   thorpej #endif
    412       1.67     enami 		error = EINVAL;
    413       1.67     enami 		goto out;
    414       1.11   thorpej 	}
    415       1.11   thorpej 
    416        1.1   hpeyerl 	/*
    417        1.1   hpeyerl 	 * If uniform interleave is desired set all sizes to that of
    418        1.1   hpeyerl 	 * the smallest component.
    419        1.1   hpeyerl 	 */
    420       1.57   thorpej 	if (cs->sc_flags & CCDF_UNIFORM) {
    421        1.1   hpeyerl 		for (ci = cs->sc_cinfo;
    422        1.1   hpeyerl 		     ci < &cs->sc_cinfo[cs->sc_nccdisks]; ci++)
    423        1.1   hpeyerl 			ci->ci_size = minsize;
    424       1.24   thorpej 
    425       1.53   thorpej 		cs->sc_size = cs->sc_nccdisks * minsize;
    426        1.1   hpeyerl 	}
    427       1.11   thorpej 
    428       1.11   thorpej 	/*
    429       1.11   thorpej 	 * Construct the interleave table.
    430       1.11   thorpej 	 */
    431       1.57   thorpej 	ccdinterleave(cs);
    432       1.11   thorpej 
    433        1.1   hpeyerl 	/*
    434       1.11   thorpej 	 * Create pseudo-geometry based on 1MB cylinders.  It's
    435       1.11   thorpej 	 * pretty close.
    436        1.1   hpeyerl 	 */
    437       1.11   thorpej 	ccg->ccg_secsize = DEV_BSIZE;
    438       1.19   thorpej 	ccg->ccg_ntracks = 1;
    439       1.11   thorpej 	ccg->ccg_nsectors = 1024 * (1024 / ccg->ccg_secsize);
    440       1.11   thorpej 	ccg->ccg_ncylinders = cs->sc_size / ccg->ccg_nsectors;
    441       1.11   thorpej 
    442       1.11   thorpej 	cs->sc_flags |= CCDF_INITED;
    443       1.23   thorpej 
    444      1.114  christos 	free(tmppath, M_TEMP);
    445      1.114  christos 
    446       1.11   thorpej 	return (0);
    447       1.67     enami 
    448       1.67     enami  out:
    449       1.67     enami 	for (ix = 0; ix < path_alloced; ix++)
    450       1.67     enami 		free(cs->sc_cinfo[ix].ci_path, M_DEVBUF);
    451       1.67     enami 	free(cs->sc_cinfo, M_DEVBUF);
    452      1.111  christos 	free(tmppath, M_TEMP);
    453       1.67     enami 	return (error);
    454        1.1   hpeyerl }
    455        1.1   hpeyerl 
    456       1.11   thorpej static void
    457       1.97   thorpej ccdinterleave(struct ccd_softc *cs)
    458        1.1   hpeyerl {
    459       1.68  augustss 	struct ccdcinfo *ci, *smallci;
    460       1.68  augustss 	struct ccdiinfo *ii;
    461       1.68  augustss 	daddr_t bn, lbn;
    462       1.68  augustss 	int ix;
    463        1.1   hpeyerl 	u_long size;
    464        1.1   hpeyerl 
    465        1.1   hpeyerl #ifdef DEBUG
    466        1.3   hpeyerl 	if (ccddebug & CCDB_INIT)
    467       1.35  christos 		printf("ccdinterleave(%p): ileave %d\n", cs, cs->sc_ileave);
    468        1.1   hpeyerl #endif
    469        1.1   hpeyerl 	/*
    470        1.1   hpeyerl 	 * Allocate an interleave table.
    471        1.1   hpeyerl 	 * Chances are this is too big, but we don't care.
    472        1.1   hpeyerl 	 */
    473        1.1   hpeyerl 	size = (cs->sc_nccdisks + 1) * sizeof(struct ccdiinfo);
    474       1.75   tsutsui 	cs->sc_itable = (struct ccdiinfo *)malloc(size, M_DEVBUF,
    475       1.75   tsutsui 	    M_WAITOK|M_ZERO);
    476       1.11   thorpej 
    477        1.1   hpeyerl 	/*
    478        1.1   hpeyerl 	 * Trivial case: no interleave (actually interleave of disk size).
    479       1.11   thorpej 	 * Each table entry represents a single component in its entirety.
    480        1.1   hpeyerl 	 */
    481        1.1   hpeyerl 	if (cs->sc_ileave == 0) {
    482        1.1   hpeyerl 		bn = 0;
    483        1.1   hpeyerl 		ii = cs->sc_itable;
    484       1.11   thorpej 
    485        1.1   hpeyerl 		for (ix = 0; ix < cs->sc_nccdisks; ix++) {
    486       1.19   thorpej 			/* Allocate space for ii_index. */
    487       1.19   thorpej 			ii->ii_index = malloc(sizeof(int), M_DEVBUF, M_WAITOK);
    488        1.1   hpeyerl 			ii->ii_ndisk = 1;
    489        1.1   hpeyerl 			ii->ii_startblk = bn;
    490        1.1   hpeyerl 			ii->ii_startoff = 0;
    491        1.1   hpeyerl 			ii->ii_index[0] = ix;
    492        1.1   hpeyerl 			bn += cs->sc_cinfo[ix].ci_size;
    493        1.1   hpeyerl 			ii++;
    494        1.1   hpeyerl 		}
    495        1.1   hpeyerl 		ii->ii_ndisk = 0;
    496        1.1   hpeyerl #ifdef DEBUG
    497        1.3   hpeyerl 		if (ccddebug & CCDB_INIT)
    498        1.1   hpeyerl 			printiinfo(cs->sc_itable);
    499        1.1   hpeyerl #endif
    500       1.11   thorpej 		return;
    501        1.1   hpeyerl 	}
    502       1.11   thorpej 
    503        1.1   hpeyerl 	/*
    504        1.1   hpeyerl 	 * The following isn't fast or pretty; it doesn't have to be.
    505        1.1   hpeyerl 	 */
    506        1.1   hpeyerl 	size = 0;
    507        1.1   hpeyerl 	bn = lbn = 0;
    508        1.1   hpeyerl 	for (ii = cs->sc_itable; ; ii++) {
    509       1.11   thorpej 		/* Allocate space for ii_index. */
    510       1.19   thorpej 		ii->ii_index = malloc((sizeof(int) * cs->sc_nccdisks),
    511       1.19   thorpej 		    M_DEVBUF, M_WAITOK);
    512       1.11   thorpej 
    513        1.1   hpeyerl 		/*
    514        1.1   hpeyerl 		 * Locate the smallest of the remaining components
    515        1.1   hpeyerl 		 */
    516        1.1   hpeyerl 		smallci = NULL;
    517        1.1   hpeyerl 		for (ci = cs->sc_cinfo;
    518        1.1   hpeyerl 		     ci < &cs->sc_cinfo[cs->sc_nccdisks]; ci++)
    519        1.1   hpeyerl 			if (ci->ci_size > size &&
    520        1.1   hpeyerl 			    (smallci == NULL ||
    521        1.1   hpeyerl 			     ci->ci_size < smallci->ci_size))
    522        1.1   hpeyerl 				smallci = ci;
    523       1.11   thorpej 
    524        1.1   hpeyerl 		/*
    525        1.1   hpeyerl 		 * Nobody left, all done
    526        1.1   hpeyerl 		 */
    527        1.1   hpeyerl 		if (smallci == NULL) {
    528        1.1   hpeyerl 			ii->ii_ndisk = 0;
    529        1.1   hpeyerl 			break;
    530        1.1   hpeyerl 		}
    531       1.11   thorpej 
    532        1.1   hpeyerl 		/*
    533        1.1   hpeyerl 		 * Record starting logical block and component offset
    534        1.1   hpeyerl 		 */
    535        1.1   hpeyerl 		ii->ii_startblk = bn / cs->sc_ileave;
    536        1.1   hpeyerl 		ii->ii_startoff = lbn;
    537       1.11   thorpej 
    538        1.1   hpeyerl 		/*
    539        1.1   hpeyerl 		 * Determine how many disks take part in this interleave
    540        1.1   hpeyerl 		 * and record their indices.
    541        1.1   hpeyerl 		 */
    542        1.1   hpeyerl 		ix = 0;
    543        1.1   hpeyerl 		for (ci = cs->sc_cinfo;
    544        1.1   hpeyerl 		     ci < &cs->sc_cinfo[cs->sc_nccdisks]; ci++)
    545        1.1   hpeyerl 			if (ci->ci_size >= smallci->ci_size)
    546        1.1   hpeyerl 				ii->ii_index[ix++] = ci - cs->sc_cinfo;
    547        1.1   hpeyerl 		ii->ii_ndisk = ix;
    548        1.1   hpeyerl 		bn += ix * (smallci->ci_size - size);
    549        1.1   hpeyerl 		lbn = smallci->ci_size / cs->sc_ileave;
    550        1.1   hpeyerl 		size = smallci->ci_size;
    551        1.1   hpeyerl 	}
    552        1.1   hpeyerl #ifdef DEBUG
    553        1.3   hpeyerl 	if (ccddebug & CCDB_INIT)
    554        1.1   hpeyerl 		printiinfo(cs->sc_itable);
    555        1.1   hpeyerl #endif
    556        1.1   hpeyerl }
    557        1.1   hpeyerl 
    558       1.11   thorpej /* ARGSUSED */
    559       1.97   thorpej static int
    560      1.116  christos ccdopen(dev_t dev, int flags, int fmt, struct lwp *l)
    561        1.1   hpeyerl {
    562        1.1   hpeyerl 	int unit = ccdunit(dev);
    563       1.11   thorpej 	struct ccd_softc *cs;
    564       1.11   thorpej 	struct disklabel *lp;
    565       1.15   thorpej 	int error = 0, part, pmask;
    566        1.1   hpeyerl 
    567        1.1   hpeyerl #ifdef DEBUG
    568        1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    569       1.43      fair 		printf("ccdopen(0x%x, 0x%x)\n", dev, flags);
    570        1.1   hpeyerl #endif
    571       1.11   thorpej 	if (unit >= numccd)
    572       1.11   thorpej 		return (ENXIO);
    573       1.11   thorpej 	cs = &ccd_softc[unit];
    574       1.15   thorpej 
    575      1.117        ad 	mutex_enter(&cs->sc_lock);
    576       1.15   thorpej 
    577       1.23   thorpej 	lp = cs->sc_dkdev.dk_label;
    578       1.11   thorpej 
    579       1.11   thorpej 	part = DISKPART(dev);
    580       1.11   thorpej 	pmask = (1 << part);
    581       1.11   thorpej 
    582       1.15   thorpej 	/*
    583       1.15   thorpej 	 * If we're initialized, check to see if there are any other
    584       1.15   thorpej 	 * open partitions.  If not, then it's safe to update
    585       1.87   thorpej 	 * the in-core disklabel.  Only read the disklabel if it is
    586       1.87   thorpej 	 * not already valid.
    587       1.15   thorpej 	 */
    588       1.87   thorpej 	if ((cs->sc_flags & (CCDF_INITED|CCDF_VLABEL)) == CCDF_INITED &&
    589       1.87   thorpej 	    cs->sc_dkdev.dk_openmask == 0)
    590       1.15   thorpej 		ccdgetdisklabel(dev);
    591       1.15   thorpej 
    592       1.11   thorpej 	/* Check that the partition exists. */
    593       1.27   thorpej 	if (part != RAW_PART) {
    594       1.27   thorpej 		if (((cs->sc_flags & CCDF_INITED) == 0) ||
    595       1.37   thorpej 		    ((part >= lp->d_npartitions) ||
    596       1.27   thorpej 		     (lp->d_partitions[part].p_fstype == FS_UNUSED))) {
    597       1.27   thorpej 			error = ENXIO;
    598       1.27   thorpej 			goto done;
    599       1.27   thorpej 		}
    600       1.15   thorpej 	}
    601       1.11   thorpej 
    602       1.11   thorpej 	/* Prevent our unit from being unconfigured while open. */
    603       1.11   thorpej 	switch (fmt) {
    604       1.11   thorpej 	case S_IFCHR:
    605       1.11   thorpej 		cs->sc_dkdev.dk_copenmask |= pmask;
    606       1.11   thorpej 		break;
    607       1.11   thorpej 
    608       1.11   thorpej 	case S_IFBLK:
    609       1.11   thorpej 		cs->sc_dkdev.dk_bopenmask |= pmask;
    610       1.11   thorpej 		break;
    611       1.11   thorpej 	}
    612       1.11   thorpej 	cs->sc_dkdev.dk_openmask =
    613       1.11   thorpej 	    cs->sc_dkdev.dk_copenmask | cs->sc_dkdev.dk_bopenmask;
    614       1.11   thorpej 
    615       1.15   thorpej  done:
    616      1.117        ad 	mutex_exit(&cs->sc_lock);
    617       1.33   thorpej 	return (error);
    618        1.7       cgd }
    619        1.7       cgd 
    620       1.11   thorpej /* ARGSUSED */
    621       1.97   thorpej static int
    622      1.116  christos ccdclose(dev_t dev, int flags, int fmt, struct lwp *l)
    623        1.7       cgd {
    624       1.11   thorpej 	int unit = ccdunit(dev);
    625       1.11   thorpej 	struct ccd_softc *cs;
    626      1.117        ad 	int part;
    627       1.11   thorpej 
    628        1.7       cgd #ifdef DEBUG
    629        1.7       cgd 	if (ccddebug & CCDB_FOLLOW)
    630       1.43      fair 		printf("ccdclose(0x%x, 0x%x)\n", dev, flags);
    631        1.7       cgd #endif
    632       1.11   thorpej 
    633       1.11   thorpej 	if (unit >= numccd)
    634       1.11   thorpej 		return (ENXIO);
    635       1.11   thorpej 	cs = &ccd_softc[unit];
    636       1.15   thorpej 
    637      1.117        ad 	mutex_enter(&cs->sc_lock);
    638       1.15   thorpej 
    639       1.11   thorpej 	part = DISKPART(dev);
    640       1.11   thorpej 
    641       1.11   thorpej 	/* ...that much closer to allowing unconfiguration... */
    642       1.11   thorpej 	switch (fmt) {
    643       1.11   thorpej 	case S_IFCHR:
    644       1.11   thorpej 		cs->sc_dkdev.dk_copenmask &= ~(1 << part);
    645       1.11   thorpej 		break;
    646       1.11   thorpej 
    647       1.11   thorpej 	case S_IFBLK:
    648       1.11   thorpej 		cs->sc_dkdev.dk_bopenmask &= ~(1 << part);
    649       1.11   thorpej 		break;
    650       1.11   thorpej 	}
    651       1.11   thorpej 	cs->sc_dkdev.dk_openmask =
    652       1.11   thorpej 	    cs->sc_dkdev.dk_copenmask | cs->sc_dkdev.dk_bopenmask;
    653       1.11   thorpej 
    654       1.87   thorpej 	if (cs->sc_dkdev.dk_openmask == 0) {
    655       1.87   thorpej 		if ((cs->sc_flags & CCDF_KLABEL) == 0)
    656       1.87   thorpej 			cs->sc_flags &= ~CCDF_VLABEL;
    657       1.87   thorpej 	}
    658       1.87   thorpej 
    659      1.117        ad 	mutex_exit(&cs->sc_lock);
    660        1.7       cgd 	return (0);
    661        1.1   hpeyerl }
    662        1.1   hpeyerl 
    663       1.97   thorpej static void
    664       1.97   thorpej ccdstrategy(struct buf *bp)
    665        1.1   hpeyerl {
    666       1.68  augustss 	int unit = ccdunit(bp->b_dev);
    667       1.68  augustss 	struct ccd_softc *cs = &ccd_softc[unit];
    668       1.88   thorpej 	daddr_t blkno;
    669       1.68  augustss 	int s;
    670       1.11   thorpej 	int wlabel;
    671       1.15   thorpej 	struct disklabel *lp;
    672        1.1   hpeyerl 
    673        1.1   hpeyerl #ifdef DEBUG
    674        1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    675       1.35  christos 		printf("ccdstrategy(%p): unit %d\n", bp, unit);
    676        1.1   hpeyerl #endif
    677        1.3   hpeyerl 	if ((cs->sc_flags & CCDF_INITED) == 0) {
    678       1.59   thorpej #ifdef DEBUG
    679       1.59   thorpej 		if (ccddebug & CCDB_FOLLOW)
    680       1.59   thorpej 			printf("ccdstrategy: unit %d: not inited\n", unit);
    681       1.59   thorpej #endif
    682        1.1   hpeyerl 		bp->b_error = ENXIO;
    683        1.1   hpeyerl 		goto done;
    684        1.1   hpeyerl 	}
    685       1.11   thorpej 
    686       1.11   thorpej 	/* If it's a nil transfer, wake up the top half now. */
    687       1.11   thorpej 	if (bp->b_bcount == 0)
    688       1.11   thorpej 		goto done;
    689       1.11   thorpej 
    690       1.23   thorpej 	lp = cs->sc_dkdev.dk_label;
    691       1.15   thorpej 
    692       1.11   thorpej 	/*
    693       1.17   thorpej 	 * Do bounds checking and adjust transfer.  If there's an
    694       1.88   thorpej 	 * error, the bounds check will flag that for us.  Convert
    695       1.88   thorpej 	 * the partition relative block number to an absolute.
    696       1.11   thorpej 	 */
    697       1.88   thorpej 	blkno = bp->b_blkno;
    698       1.11   thorpej 	wlabel = cs->sc_flags & (CCDF_WLABEL|CCDF_LABELLING);
    699       1.88   thorpej 	if (DISKPART(bp->b_dev) != RAW_PART) {
    700       1.86   thorpej 		if (bounds_check_with_label(&cs->sc_dkdev, bp, wlabel) <= 0)
    701        1.1   hpeyerl 			goto done;
    702       1.88   thorpej 		blkno += lp->d_partitions[DISKPART(bp->b_dev)].p_offset;
    703       1.88   thorpej 	}
    704       1.88   thorpej 	bp->b_rawblkno = blkno;
    705       1.11   thorpej 
    706       1.88   thorpej 	/* Place it in the queue and start I/O on the unit. */
    707        1.1   hpeyerl 	s = splbio();
    708      1.106      yamt 	BUFQ_PUT(cs->sc_bufq, bp);
    709       1.88   thorpej 	ccdstart(cs);
    710        1.1   hpeyerl 	splx(s);
    711        1.1   hpeyerl 	return;
    712       1.88   thorpej 
    713       1.88   thorpej  done:
    714       1.88   thorpej 	bp->b_resid = bp->b_bcount;
    715        1.1   hpeyerl 	biodone(bp);
    716        1.1   hpeyerl }
    717        1.1   hpeyerl 
    718       1.11   thorpej static void
    719       1.97   thorpej ccdstart(struct ccd_softc *cs)
    720        1.1   hpeyerl {
    721       1.68  augustss 	long bcount, rcount;
    722       1.88   thorpej 	struct buf *bp;
    723       1.55   thorpej 	struct ccdbuf *cbp;
    724      1.118  christos 	char *addr;
    725        1.1   hpeyerl 	daddr_t bn;
    726       1.56   thorpej 	SIMPLEQ_HEAD(, ccdbuf) cbufq;
    727        1.1   hpeyerl 
    728        1.1   hpeyerl #ifdef DEBUG
    729        1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    730       1.93       chs 		printf("ccdstart(%p)\n", cs);
    731        1.1   hpeyerl #endif
    732       1.11   thorpej 
    733       1.88   thorpej 	/* See if there is work for us to do. */
    734      1.106      yamt 	while ((bp = BUFQ_PEEK(cs->sc_bufq)) != NULL) {
    735       1.88   thorpej 		/* Instrumentation. */
    736       1.88   thorpej 		disk_busy(&cs->sc_dkdev);
    737       1.11   thorpej 
    738       1.88   thorpej 		bp->b_resid = bp->b_bcount;
    739       1.88   thorpej 		bn = bp->b_rawblkno;
    740       1.17   thorpej 
    741       1.88   thorpej 		/* Allocate the component buffers. */
    742       1.88   thorpej 		SIMPLEQ_INIT(&cbufq);
    743       1.88   thorpej 		addr = bp->b_data;
    744       1.88   thorpej 		for (bcount = bp->b_bcount; bcount > 0; bcount -= rcount) {
    745       1.88   thorpej 			cbp = ccdbuffer(cs, bp, bn, addr, bcount);
    746       1.88   thorpej 			if (cbp == NULL) {
    747       1.88   thorpej 				/*
    748       1.88   thorpej 				 * Can't allocate a component buffer; just
    749       1.88   thorpej 				 * defer the job until later.
    750       1.88   thorpej 				 *
    751       1.88   thorpej 				 * XXX We might consider a watchdog timer
    752       1.88   thorpej 				 * XXX to make sure we are kicked into action,
    753       1.88   thorpej 				 * XXX or consider a low-water mark for our
    754       1.88   thorpej 				 * XXX component buffer pool.
    755       1.88   thorpej 				 */
    756       1.88   thorpej 				while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
    757       1.88   thorpej 					SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
    758       1.88   thorpej 					CCD_PUTBUF(cbp);
    759       1.88   thorpej 				}
    760       1.88   thorpej 				disk_unbusy(&cs->sc_dkdev, 0, 0);
    761       1.88   thorpej 				return;
    762       1.56   thorpej 			}
    763       1.88   thorpej 			SIMPLEQ_INSERT_TAIL(&cbufq, cbp, cb_q);
    764       1.88   thorpej 			rcount = cbp->cb_buf.b_bcount;
    765       1.88   thorpej 			bn += btodb(rcount);
    766       1.88   thorpej 			addr += rcount;
    767       1.88   thorpej 		}
    768       1.88   thorpej 
    769       1.88   thorpej 		/* Transfer all set up, remove job from the queue. */
    770      1.106      yamt 		(void) BUFQ_GET(cs->sc_bufq);
    771       1.56   thorpej 
    772       1.88   thorpej 		/* Now fire off the requests. */
    773       1.88   thorpej 		while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
    774       1.88   thorpej 			SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
    775       1.88   thorpej 			if ((cbp->cb_buf.b_flags & B_READ) == 0)
    776       1.88   thorpej 				cbp->cb_buf.b_vp->v_numoutput++;
    777      1.121        ad 			bdev_strategy(&cbp->cb_buf);
    778       1.56   thorpej 		}
    779        1.1   hpeyerl 	}
    780        1.1   hpeyerl }
    781        1.1   hpeyerl 
    782        1.1   hpeyerl /*
    783        1.1   hpeyerl  * Build a component buffer header.
    784        1.1   hpeyerl  */
    785       1.55   thorpej static struct ccdbuf *
    786      1.118  christos ccdbuffer(struct ccd_softc *cs, struct buf *bp, daddr_t bn, void *addr,
    787       1.97   thorpej     long bcount)
    788        1.1   hpeyerl {
    789       1.68  augustss 	struct ccdcinfo *ci;
    790       1.68  augustss 	struct ccdbuf *cbp;
    791       1.68  augustss 	daddr_t cbn, cboff;
    792       1.68  augustss 	u_int64_t cbc;
    793       1.36   thorpej 	int ccdisk;
    794        1.1   hpeyerl 
    795        1.1   hpeyerl #ifdef DEBUG
    796        1.3   hpeyerl 	if (ccddebug & CCDB_IO)
    797       1.81    kleink 		printf("ccdbuffer(%p, %p, %" PRId64 ", %p, %ld)\n",
    798        1.1   hpeyerl 		       cs, bp, bn, addr, bcount);
    799        1.1   hpeyerl #endif
    800        1.1   hpeyerl 	/*
    801        1.1   hpeyerl 	 * Determine which component bn falls in.
    802        1.1   hpeyerl 	 */
    803        1.1   hpeyerl 	cbn = bn;
    804        1.1   hpeyerl 	cboff = 0;
    805       1.11   thorpej 
    806        1.1   hpeyerl 	/*
    807        1.1   hpeyerl 	 * Serially concatenated
    808        1.1   hpeyerl 	 */
    809        1.1   hpeyerl 	if (cs->sc_ileave == 0) {
    810       1.68  augustss 		daddr_t sblk;
    811        1.1   hpeyerl 
    812        1.1   hpeyerl 		sblk = 0;
    813       1.36   thorpej 		for (ccdisk = 0, ci = &cs->sc_cinfo[ccdisk];
    814       1.36   thorpej 		    cbn >= sblk + ci->ci_size;
    815       1.36   thorpej 		    ccdisk++, ci = &cs->sc_cinfo[ccdisk])
    816        1.1   hpeyerl 			sblk += ci->ci_size;
    817        1.1   hpeyerl 		cbn -= sblk;
    818        1.1   hpeyerl 	}
    819        1.1   hpeyerl 	/*
    820        1.1   hpeyerl 	 * Interleaved
    821        1.1   hpeyerl 	 */
    822        1.1   hpeyerl 	else {
    823       1.68  augustss 		struct ccdiinfo *ii;
    824       1.36   thorpej 		int off;
    825        1.1   hpeyerl 
    826        1.1   hpeyerl 		cboff = cbn % cs->sc_ileave;
    827        1.1   hpeyerl 		cbn /= cs->sc_ileave;
    828        1.1   hpeyerl 		for (ii = cs->sc_itable; ii->ii_ndisk; ii++)
    829        1.1   hpeyerl 			if (ii->ii_startblk > cbn)
    830        1.1   hpeyerl 				break;
    831        1.1   hpeyerl 		ii--;
    832        1.1   hpeyerl 		off = cbn - ii->ii_startblk;
    833        1.1   hpeyerl 		if (ii->ii_ndisk == 1) {
    834        1.1   hpeyerl 			ccdisk = ii->ii_index[0];
    835        1.1   hpeyerl 			cbn = ii->ii_startoff + off;
    836        1.1   hpeyerl 		} else {
    837       1.53   thorpej 			ccdisk = ii->ii_index[off % ii->ii_ndisk];
    838       1.53   thorpej 			cbn = ii->ii_startoff + off / ii->ii_ndisk;
    839        1.1   hpeyerl 		}
    840        1.1   hpeyerl 		cbn *= cs->sc_ileave;
    841        1.1   hpeyerl 		ci = &cs->sc_cinfo[ccdisk];
    842        1.1   hpeyerl 	}
    843       1.11   thorpej 
    844        1.1   hpeyerl 	/*
    845        1.1   hpeyerl 	 * Fill in the component buf structure.
    846        1.1   hpeyerl 	 */
    847       1.63   thorpej 	cbp = CCD_GETBUF();
    848       1.55   thorpej 	if (cbp == NULL)
    849       1.55   thorpej 		return (NULL);
    850      1.126        ad 	buf_init(&cbp->cb_buf);
    851      1.126        ad 	cbp->cb_buf.b_flags = bp->b_flags;
    852      1.126        ad 	cbp->cb_buf.b_oflags = bp->b_oflags;
    853      1.126        ad 	cbp->cb_buf.b_cflags = bp->b_cflags;
    854       1.29  christos 	cbp->cb_buf.b_iodone = ccdiodone;
    855        1.6       cgd 	cbp->cb_buf.b_proc = bp->b_proc;
    856       1.95   hannken 	cbp->cb_buf.b_dev = ci->ci_dev;
    857        1.6       cgd 	cbp->cb_buf.b_blkno = cbn + cboff;
    858        1.6       cgd 	cbp->cb_buf.b_data = addr;
    859       1.11   thorpej 	cbp->cb_buf.b_vp = ci->ci_vp;
    860      1.127   hannken 	cbp->cb_buf.b_objlock = &ci->ci_vp->v_interlock;
    861        1.1   hpeyerl 	if (cs->sc_ileave == 0)
    862       1.50   thorpej 		cbc = dbtob((u_int64_t)(ci->ci_size - cbn));
    863        1.1   hpeyerl 	else
    864       1.50   thorpej 		cbc = dbtob((u_int64_t)(cs->sc_ileave - cboff));
    865       1.50   thorpej 	cbp->cb_buf.b_bcount = cbc < bcount ? cbc : bcount;
    866        1.6       cgd 
    867        1.1   hpeyerl 	/*
    868        1.6       cgd 	 * context for ccdiodone
    869        1.1   hpeyerl 	 */
    870        1.6       cgd 	cbp->cb_obp = bp;
    871       1.59   thorpej 	cbp->cb_sc = cs;
    872       1.36   thorpej 	cbp->cb_comp = ccdisk;
    873        1.6       cgd 
    874       1.94      yamt 	BIO_COPYPRIO(&cbp->cb_buf, bp);
    875       1.94      yamt 
    876        1.1   hpeyerl #ifdef DEBUG
    877        1.3   hpeyerl 	if (ccddebug & CCDB_IO)
    878       1.81    kleink 		printf(" dev 0x%x(u%lu): cbp %p bn %" PRId64 " addr %p"
    879       1.99      yamt 		       " bcnt %d\n",
    880       1.62    mjacob 		    ci->ci_dev, (unsigned long) (ci-cs->sc_cinfo), cbp,
    881       1.62    mjacob 		    cbp->cb_buf.b_blkno, cbp->cb_buf.b_data,
    882       1.62    mjacob 		    cbp->cb_buf.b_bcount);
    883        1.1   hpeyerl #endif
    884       1.55   thorpej 
    885       1.55   thorpej 	return (cbp);
    886        1.1   hpeyerl }
    887        1.1   hpeyerl 
    888       1.11   thorpej static void
    889       1.97   thorpej ccdintr(struct ccd_softc *cs, struct buf *bp)
    890        1.1   hpeyerl {
    891        1.1   hpeyerl 
    892        1.1   hpeyerl #ifdef DEBUG
    893        1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    894       1.35  christos 		printf("ccdintr(%p, %p)\n", cs, bp);
    895        1.1   hpeyerl #endif
    896        1.1   hpeyerl 	/*
    897        1.1   hpeyerl 	 * Request is done for better or worse, wakeup the top half.
    898        1.1   hpeyerl 	 */
    899      1.122        ad 	if (bp->b_error != 0)
    900        1.1   hpeyerl 		bp->b_resid = bp->b_bcount;
    901       1.80       mrg 	disk_unbusy(&cs->sc_dkdev, (bp->b_bcount - bp->b_resid),
    902       1.80       mrg 	    (bp->b_flags & B_READ));
    903        1.1   hpeyerl 	biodone(bp);
    904        1.1   hpeyerl }
    905        1.1   hpeyerl 
    906        1.1   hpeyerl /*
    907       1.11   thorpej  * Called at interrupt time.
    908        1.1   hpeyerl  * Mark the component as done and if all components are done,
    909        1.1   hpeyerl  * take a ccd interrupt.
    910        1.1   hpeyerl  */
    911       1.97   thorpej static void
    912       1.97   thorpej ccdiodone(struct buf *vbp)
    913        1.1   hpeyerl {
    914       1.29  christos 	struct ccdbuf *cbp = (struct ccdbuf *) vbp;
    915       1.59   thorpej 	struct buf *bp = cbp->cb_obp;
    916       1.59   thorpej 	struct ccd_softc *cs = cbp->cb_sc;
    917       1.53   thorpej 	int count, s;
    918        1.1   hpeyerl 
    919        1.1   hpeyerl 	s = splbio();
    920        1.1   hpeyerl #ifdef DEBUG
    921        1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    922       1.35  christos 		printf("ccdiodone(%p)\n", cbp);
    923        1.3   hpeyerl 	if (ccddebug & CCDB_IO) {
    924       1.99      yamt 		printf("ccdiodone: bp %p bcount %d resid %d\n",
    925       1.53   thorpej 		       bp, bp->b_bcount, bp->b_resid);
    926       1.81    kleink 		printf(" dev 0x%x(u%d), cbp %p bn %" PRId64 " addr %p"
    927       1.99      yamt 		       " bcnt %d\n",
    928        1.6       cgd 		       cbp->cb_buf.b_dev, cbp->cb_comp, cbp,
    929        1.6       cgd 		       cbp->cb_buf.b_blkno, cbp->cb_buf.b_data,
    930        1.6       cgd 		       cbp->cb_buf.b_bcount);
    931        1.1   hpeyerl 	}
    932        1.1   hpeyerl #endif
    933        1.1   hpeyerl 
    934      1.122        ad 	if (cbp->cb_buf.b_error != 0) {
    935      1.122        ad 		bp->b_error = cbp->cb_buf.b_error;
    936       1.53   thorpej 		printf("%s: error %d on component %d\n",
    937       1.53   thorpej 		       cs->sc_xname, bp->b_error, cbp->cb_comp);
    938        1.1   hpeyerl 	}
    939        1.6       cgd 	count = cbp->cb_buf.b_bcount;
    940      1.126        ad 	buf_destroy(&cbp->cb_buf);
    941       1.63   thorpej 	CCD_PUTBUF(cbp);
    942        1.1   hpeyerl 
    943        1.1   hpeyerl 	/*
    944        1.1   hpeyerl 	 * If all done, "interrupt".
    945       1.53   thorpej 	 */
    946       1.53   thorpej 	bp->b_resid -= count;
    947       1.53   thorpej 	if (bp->b_resid < 0)
    948       1.53   thorpej 		panic("ccdiodone: count");
    949       1.53   thorpej 	if (bp->b_resid == 0)
    950       1.59   thorpej 		ccdintr(cs, bp);
    951        1.1   hpeyerl 	splx(s);
    952        1.1   hpeyerl }
    953        1.1   hpeyerl 
    954       1.11   thorpej /* ARGSUSED */
    955       1.97   thorpej static int
    956      1.116  christos ccdread(dev_t dev, struct uio *uio, int flags)
    957        1.3   hpeyerl {
    958       1.11   thorpej 	int unit = ccdunit(dev);
    959       1.11   thorpej 	struct ccd_softc *cs;
    960        1.3   hpeyerl 
    961        1.3   hpeyerl #ifdef DEBUG
    962        1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    963       1.43      fair 		printf("ccdread(0x%x, %p)\n", dev, uio);
    964        1.3   hpeyerl #endif
    965       1.11   thorpej 	if (unit >= numccd)
    966       1.11   thorpej 		return (ENXIO);
    967       1.11   thorpej 	cs = &ccd_softc[unit];
    968       1.11   thorpej 
    969       1.11   thorpej 	if ((cs->sc_flags & CCDF_INITED) == 0)
    970       1.11   thorpej 		return (ENXIO);
    971       1.11   thorpej 
    972       1.10   mycroft 	return (physio(ccdstrategy, NULL, dev, B_READ, minphys, uio));
    973        1.3   hpeyerl }
    974        1.3   hpeyerl 
    975       1.11   thorpej /* ARGSUSED */
    976       1.97   thorpej static int
    977      1.116  christos ccdwrite(dev_t dev, struct uio *uio, int flags)
    978        1.3   hpeyerl {
    979       1.11   thorpej 	int unit = ccdunit(dev);
    980       1.11   thorpej 	struct ccd_softc *cs;
    981        1.3   hpeyerl 
    982        1.3   hpeyerl #ifdef DEBUG
    983        1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    984       1.43      fair 		printf("ccdwrite(0x%x, %p)\n", dev, uio);
    985        1.3   hpeyerl #endif
    986       1.11   thorpej 	if (unit >= numccd)
    987       1.11   thorpej 		return (ENXIO);
    988       1.11   thorpej 	cs = &ccd_softc[unit];
    989       1.11   thorpej 
    990       1.11   thorpej 	if ((cs->sc_flags & CCDF_INITED) == 0)
    991       1.11   thorpej 		return (ENXIO);
    992       1.11   thorpej 
    993       1.10   mycroft 	return (physio(ccdstrategy, NULL, dev, B_WRITE, minphys, uio));
    994        1.3   hpeyerl }
    995        1.3   hpeyerl 
    996       1.97   thorpej static int
    997      1.118  christos ccdioctl(dev_t dev, u_long cmd, void *data, int flag, struct lwp *l)
    998        1.1   hpeyerl {
    999       1.11   thorpej 	int unit = ccdunit(dev);
   1000      1.117        ad 	int s, i, j, lookedup = 0, error = 0;
   1001       1.39   mycroft 	int part, pmask;
   1002       1.11   thorpej 	struct ccd_softc *cs;
   1003       1.11   thorpej 	struct ccd_ioctl *ccio = (struct ccd_ioctl *)data;
   1004      1.110      elad 	kauth_cred_t uc;
   1005       1.11   thorpej 	char **cpp;
   1006       1.11   thorpej 	struct vnode **vpp;
   1007       1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1008       1.70      fvdl 	struct disklabel newlabel;
   1009       1.70      fvdl #endif
   1010       1.11   thorpej 
   1011       1.11   thorpej 	if (unit >= numccd)
   1012       1.11   thorpej 		return (ENXIO);
   1013       1.11   thorpej 	cs = &ccd_softc[unit];
   1014       1.11   thorpej 
   1015      1.112        ad 	uc = (l != NULL) ? l->l_cred : NOCRED;
   1016      1.109       jld 
   1017       1.41   thorpej 	/* Must be open for writes for these commands... */
   1018       1.41   thorpej 	switch (cmd) {
   1019       1.41   thorpej 	case CCDIOCSET:
   1020       1.41   thorpej 	case CCDIOCCLR:
   1021       1.41   thorpej 	case DIOCSDINFO:
   1022       1.41   thorpej 	case DIOCWDINFO:
   1023       1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1024       1.70      fvdl 	case ODIOCSDINFO:
   1025       1.70      fvdl 	case ODIOCWDINFO:
   1026       1.70      fvdl #endif
   1027       1.87   thorpej 	case DIOCKLABEL:
   1028       1.41   thorpej 	case DIOCWLABEL:
   1029       1.41   thorpej 		if ((flag & FWRITE) == 0)
   1030       1.41   thorpej 			return (EBADF);
   1031       1.41   thorpej 	}
   1032       1.41   thorpej 
   1033      1.117        ad 	mutex_enter(&cs->sc_lock);
   1034       1.57   thorpej 
   1035       1.41   thorpej 	/* Must be initialized for these... */
   1036       1.41   thorpej 	switch (cmd) {
   1037       1.41   thorpej 	case CCDIOCCLR:
   1038       1.42    kleink 	case DIOCGDINFO:
   1039      1.100   thorpej 	case DIOCCACHESYNC:
   1040       1.42    kleink 	case DIOCSDINFO:
   1041       1.42    kleink 	case DIOCWDINFO:
   1042       1.42    kleink 	case DIOCGPART:
   1043       1.41   thorpej 	case DIOCWLABEL:
   1044       1.87   thorpej 	case DIOCKLABEL:
   1045       1.44   thorpej 	case DIOCGDEFLABEL:
   1046       1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1047       1.70      fvdl 	case ODIOCGDINFO:
   1048       1.70      fvdl 	case ODIOCSDINFO:
   1049       1.70      fvdl 	case ODIOCWDINFO:
   1050       1.70      fvdl 	case ODIOCGDEFLABEL:
   1051       1.70      fvdl #endif
   1052       1.57   thorpej 		if ((cs->sc_flags & CCDF_INITED) == 0) {
   1053       1.57   thorpej 			error = ENXIO;
   1054       1.57   thorpej 			goto out;
   1055       1.57   thorpej 		}
   1056       1.41   thorpej 	}
   1057       1.41   thorpej 
   1058       1.11   thorpej 	switch (cmd) {
   1059       1.11   thorpej 	case CCDIOCSET:
   1060       1.57   thorpej 		if (cs->sc_flags & CCDF_INITED) {
   1061       1.57   thorpej 			error = EBUSY;
   1062       1.57   thorpej 			goto out;
   1063       1.57   thorpej 		}
   1064       1.54   thorpej 
   1065       1.54   thorpej 		/* Validate the flags. */
   1066       1.57   thorpej 		if ((ccio->ccio_flags & CCDF_USERMASK) != ccio->ccio_flags) {
   1067       1.57   thorpej 			error = EINVAL;
   1068       1.57   thorpej 			goto out;
   1069       1.57   thorpej 		}
   1070       1.15   thorpej 
   1071       1.73  jdolecek 		if (ccio->ccio_ndisks > CCD_MAXNDISKS) {
   1072       1.73  jdolecek 			error = EINVAL;
   1073       1.73  jdolecek 			goto out;
   1074       1.73  jdolecek 		}
   1075      1.102     perry 
   1076       1.11   thorpej 		/* Fill in some important bits. */
   1077       1.57   thorpej 		cs->sc_ileave = ccio->ccio_ileave;
   1078       1.57   thorpej 		cs->sc_nccdisks = ccio->ccio_ndisks;
   1079       1.57   thorpej 		cs->sc_flags = ccio->ccio_flags & CCDF_USERMASK;
   1080       1.11   thorpej 
   1081       1.11   thorpej 		/*
   1082       1.11   thorpej 		 * Allocate space for and copy in the array of
   1083       1.11   thorpej 		 * componet pathnames and device numbers.
   1084       1.11   thorpej 		 */
   1085       1.11   thorpej 		cpp = malloc(ccio->ccio_ndisks * sizeof(char *),
   1086       1.11   thorpej 		    M_DEVBUF, M_WAITOK);
   1087       1.11   thorpej 		vpp = malloc(ccio->ccio_ndisks * sizeof(struct vnode *),
   1088       1.11   thorpej 		    M_DEVBUF, M_WAITOK);
   1089       1.11   thorpej 
   1090       1.84       dsl 		error = copyin(ccio->ccio_disks, cpp,
   1091       1.11   thorpej 		    ccio->ccio_ndisks * sizeof(char **));
   1092       1.11   thorpej 		if (error) {
   1093       1.11   thorpej 			free(vpp, M_DEVBUF);
   1094       1.11   thorpej 			free(cpp, M_DEVBUF);
   1095       1.57   thorpej 			goto out;
   1096       1.11   thorpej 		}
   1097       1.11   thorpej 
   1098       1.11   thorpej #ifdef DEBUG
   1099       1.11   thorpej 		if (ccddebug & CCDB_INIT)
   1100       1.11   thorpej 			for (i = 0; i < ccio->ccio_ndisks; ++i)
   1101      1.104  christos 				printf("ccdioctl: component %d: %p\n",
   1102       1.11   thorpej 				    i, cpp[i]);
   1103       1.11   thorpej #endif
   1104       1.11   thorpej 
   1105       1.11   thorpej 		for (i = 0; i < ccio->ccio_ndisks; ++i) {
   1106       1.11   thorpej #ifdef DEBUG
   1107       1.11   thorpej 			if (ccddebug & CCDB_INIT)
   1108       1.35  christos 				printf("ccdioctl: lookedup = %d\n", lookedup);
   1109       1.11   thorpej #endif
   1110      1.120      cube 			if ((error = dk_lookup(cpp[i], l, &vpp[i],
   1111      1.120      cube 			    UIO_USERSPACE)) != 0) {
   1112       1.11   thorpej 				for (j = 0; j < lookedup; ++j)
   1113       1.12   thorpej 					(void)vn_close(vpp[j], FREAD|FWRITE,
   1114  1.127.6.1       mjf 					    uc);
   1115       1.11   thorpej 				free(vpp, M_DEVBUF);
   1116       1.11   thorpej 				free(cpp, M_DEVBUF);
   1117       1.57   thorpej 				goto out;
   1118       1.11   thorpej 			}
   1119       1.11   thorpej 			++lookedup;
   1120       1.11   thorpej 		}
   1121       1.11   thorpej 
   1122       1.11   thorpej 		/*
   1123       1.11   thorpej 		 * Initialize the ccd.  Fills in the softc for us.
   1124       1.11   thorpej 		 */
   1125      1.107  christos 		if ((error = ccdinit(cs, cpp, vpp, l)) != 0) {
   1126       1.11   thorpej 			for (j = 0; j < lookedup; ++j)
   1127       1.18   thorpej 				(void)vn_close(vpp[j], FREAD|FWRITE,
   1128  1.127.6.1       mjf 				    uc);
   1129       1.11   thorpej 			free(vpp, M_DEVBUF);
   1130       1.11   thorpej 			free(cpp, M_DEVBUF);
   1131       1.57   thorpej 			goto out;
   1132       1.11   thorpej 		}
   1133       1.11   thorpej 
   1134       1.57   thorpej 		/* We can free the temporary variables now. */
   1135       1.57   thorpej 		free(vpp, M_DEVBUF);
   1136       1.57   thorpej 		free(cpp, M_DEVBUF);
   1137       1.57   thorpej 
   1138       1.11   thorpej 		/*
   1139       1.11   thorpej 		 * The ccd has been successfully initialized, so
   1140       1.23   thorpej 		 * we can place it into the array.  Don't try to
   1141       1.23   thorpej 		 * read the disklabel until the disk has been attached,
   1142       1.23   thorpej 		 * because space for the disklabel is allocated
   1143       1.23   thorpej 		 * in disk_attach();
   1144       1.11   thorpej 		 */
   1145       1.11   thorpej 		ccio->ccio_unit = unit;
   1146       1.11   thorpej 		ccio->ccio_size = cs->sc_size;
   1147       1.23   thorpej 
   1148      1.106      yamt 		bufq_alloc(&cs->sc_bufq, "fcfs", 0);
   1149       1.88   thorpej 
   1150       1.23   thorpej 		/* Attach the disk. */
   1151      1.123        ad 		disk_attach(&cs->sc_dkdev);
   1152       1.23   thorpej 
   1153       1.23   thorpej 		/* Try and read the disklabel. */
   1154       1.11   thorpej 		ccdgetdisklabel(dev);
   1155       1.11   thorpej 		break;
   1156       1.11   thorpej 
   1157       1.11   thorpej 	case CCDIOCCLR:
   1158       1.11   thorpej 		/*
   1159       1.11   thorpej 		 * Don't unconfigure if any other partitions are open
   1160       1.11   thorpej 		 * or if both the character and block flavors of this
   1161       1.11   thorpej 		 * partition are open.
   1162       1.11   thorpej 		 */
   1163       1.11   thorpej 		part = DISKPART(dev);
   1164       1.11   thorpej 		pmask = (1 << part);
   1165       1.11   thorpej 		if ((cs->sc_dkdev.dk_openmask & ~pmask) ||
   1166       1.11   thorpej 		    ((cs->sc_dkdev.dk_bopenmask & pmask) &&
   1167       1.15   thorpej 		    (cs->sc_dkdev.dk_copenmask & pmask))) {
   1168       1.57   thorpej 			error = EBUSY;
   1169       1.57   thorpej 			goto out;
   1170       1.15   thorpej 		}
   1171       1.88   thorpej 
   1172       1.88   thorpej 		/* Kill off any queued buffers. */
   1173       1.88   thorpej 		s = splbio();
   1174      1.106      yamt 		bufq_drain(cs->sc_bufq);
   1175       1.88   thorpej 		splx(s);
   1176       1.88   thorpej 
   1177      1.106      yamt 		bufq_free(cs->sc_bufq);
   1178       1.11   thorpej 
   1179       1.11   thorpej 		/*
   1180       1.11   thorpej 		 * Free ccd_softc information and clear entry.
   1181       1.11   thorpej 		 */
   1182       1.22   thorpej 
   1183       1.22   thorpej 		/* Close the components and free their pathnames. */
   1184       1.11   thorpej 		for (i = 0; i < cs->sc_nccdisks; ++i) {
   1185       1.11   thorpej 			/*
   1186       1.11   thorpej 			 * XXX: this close could potentially fail and
   1187       1.11   thorpej 			 * cause Bad Things.  Maybe we need to force
   1188       1.11   thorpej 			 * the close to happen?
   1189       1.11   thorpej 			 */
   1190       1.11   thorpej #ifdef DEBUG
   1191       1.11   thorpej 			if (ccddebug & CCDB_VNODE)
   1192       1.11   thorpej 				vprint("CCDIOCCLR: vnode info",
   1193       1.11   thorpej 				    cs->sc_cinfo[i].ci_vp);
   1194       1.11   thorpej #endif
   1195       1.11   thorpej 			(void)vn_close(cs->sc_cinfo[i].ci_vp, FREAD|FWRITE,
   1196  1.127.6.1       mjf 			    uc);
   1197       1.11   thorpej 			free(cs->sc_cinfo[i].ci_path, M_DEVBUF);
   1198       1.38   thorpej 		}
   1199       1.38   thorpej 
   1200       1.22   thorpej 		/* Free interleave index. */
   1201       1.22   thorpej 		for (i = 0; cs->sc_itable[i].ii_ndisk; ++i)
   1202       1.19   thorpej 			free(cs->sc_itable[i].ii_index, M_DEVBUF);
   1203       1.22   thorpej 
   1204       1.22   thorpej 		/* Free component info and interleave table. */
   1205       1.11   thorpej 		free(cs->sc_cinfo, M_DEVBUF);
   1206       1.11   thorpej 		free(cs->sc_itable, M_DEVBUF);
   1207       1.87   thorpej 		cs->sc_flags &= ~(CCDF_INITED|CCDF_VLABEL);
   1208       1.15   thorpej 
   1209       1.23   thorpej 		/* Detatch the disk. */
   1210      1.123        ad 		disk_detach(&cs->sc_dkdev);
   1211       1.11   thorpej 		break;
   1212       1.11   thorpej 
   1213       1.11   thorpej 	case DIOCGDINFO:
   1214       1.23   thorpej 		*(struct disklabel *)data = *(cs->sc_dkdev.dk_label);
   1215       1.11   thorpej 		break;
   1216       1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1217       1.70      fvdl 	case ODIOCGDINFO:
   1218       1.70      fvdl 		newlabel = *(cs->sc_dkdev.dk_label);
   1219       1.70      fvdl 		if (newlabel.d_npartitions > OLDMAXPARTITIONS)
   1220       1.71      fvdl 			return ENOTTY;
   1221       1.70      fvdl 		memcpy(data, &newlabel, sizeof (struct olddisklabel));
   1222       1.70      fvdl 		break;
   1223       1.70      fvdl #endif
   1224       1.11   thorpej 
   1225       1.11   thorpej 	case DIOCGPART:
   1226       1.23   thorpej 		((struct partinfo *)data)->disklab = cs->sc_dkdev.dk_label;
   1227       1.11   thorpej 		((struct partinfo *)data)->part =
   1228       1.23   thorpej 		    &cs->sc_dkdev.dk_label->d_partitions[DISKPART(dev)];
   1229       1.11   thorpej 		break;
   1230       1.11   thorpej 
   1231      1.100   thorpej 	case DIOCCACHESYNC:
   1232      1.100   thorpej 		/*
   1233      1.100   thorpej 		 * XXX Do we really need to care about having a writable
   1234      1.100   thorpej 		 * file descriptor here?
   1235      1.100   thorpej 		 */
   1236      1.100   thorpej 		if ((flag & FWRITE) == 0)
   1237      1.100   thorpej 			return (EBADF);
   1238      1.100   thorpej 
   1239      1.100   thorpej 		/*
   1240      1.100   thorpej 		 * We pass this call down to all components and report
   1241      1.100   thorpej 		 * the first error we encounter.
   1242      1.100   thorpej 		 */
   1243      1.100   thorpej 		for (error = 0, i = 0; i < cs->sc_nccdisks; i++) {
   1244      1.100   thorpej 			j = VOP_IOCTL(cs->sc_cinfo[i].ci_vp, cmd, data,
   1245      1.124     pooka 				      flag, uc);
   1246      1.100   thorpej 			if (j != 0 && error == 0)
   1247      1.100   thorpej 				error = j;
   1248      1.100   thorpej 		}
   1249      1.100   thorpej 		break;
   1250      1.100   thorpej 
   1251       1.11   thorpej 	case DIOCWDINFO:
   1252       1.11   thorpej 	case DIOCSDINFO:
   1253       1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1254       1.70      fvdl 	case ODIOCWDINFO:
   1255       1.70      fvdl 	case ODIOCSDINFO:
   1256       1.70      fvdl #endif
   1257       1.70      fvdl 	{
   1258       1.70      fvdl 		struct disklabel *lp;
   1259       1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1260       1.70      fvdl 		if (cmd == ODIOCSDINFO || cmd == ODIOCWDINFO) {
   1261       1.70      fvdl 			memset(&newlabel, 0, sizeof newlabel);
   1262       1.70      fvdl 			memcpy(&newlabel, data, sizeof (struct olddisklabel));
   1263       1.70      fvdl 			lp = &newlabel;
   1264       1.70      fvdl 		} else
   1265       1.70      fvdl #endif
   1266       1.70      fvdl 		lp = (struct disklabel *)data;
   1267       1.70      fvdl 
   1268       1.11   thorpej 		cs->sc_flags |= CCDF_LABELLING;
   1269       1.11   thorpej 
   1270       1.23   thorpej 		error = setdisklabel(cs->sc_dkdev.dk_label,
   1271       1.70      fvdl 		    lp, 0, cs->sc_dkdev.dk_cpulabel);
   1272       1.11   thorpej 		if (error == 0) {
   1273       1.70      fvdl 			if (cmd == DIOCWDINFO
   1274       1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1275       1.70      fvdl 			    || cmd == ODIOCWDINFO
   1276       1.70      fvdl #endif
   1277       1.70      fvdl 			   )
   1278       1.11   thorpej 				error = writedisklabel(CCDLABELDEV(dev),
   1279       1.23   thorpej 				    ccdstrategy, cs->sc_dkdev.dk_label,
   1280       1.23   thorpej 				    cs->sc_dkdev.dk_cpulabel);
   1281       1.11   thorpej 		}
   1282       1.11   thorpej 
   1283       1.11   thorpej 		cs->sc_flags &= ~CCDF_LABELLING;
   1284       1.11   thorpej 		break;
   1285       1.70      fvdl 	}
   1286       1.11   thorpej 
   1287       1.87   thorpej 	case DIOCKLABEL:
   1288       1.87   thorpej 		if (*(int *)data != 0)
   1289       1.87   thorpej 			cs->sc_flags |= CCDF_KLABEL;
   1290       1.87   thorpej 		else
   1291       1.87   thorpej 			cs->sc_flags &= ~CCDF_KLABEL;
   1292       1.87   thorpej 		break;
   1293       1.87   thorpej 
   1294       1.11   thorpej 	case DIOCWLABEL:
   1295       1.11   thorpej 		if (*(int *)data != 0)
   1296       1.11   thorpej 			cs->sc_flags |= CCDF_WLABEL;
   1297       1.11   thorpej 		else
   1298       1.11   thorpej 			cs->sc_flags &= ~CCDF_WLABEL;
   1299       1.11   thorpej 		break;
   1300       1.11   thorpej 
   1301       1.44   thorpej 	case DIOCGDEFLABEL:
   1302       1.44   thorpej 		ccdgetdefaultlabel(cs, (struct disklabel *)data);
   1303       1.44   thorpej 		break;
   1304       1.70      fvdl 
   1305       1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1306       1.70      fvdl 	case ODIOCGDEFLABEL:
   1307       1.70      fvdl 		ccdgetdefaultlabel(cs, &newlabel);
   1308       1.70      fvdl 		if (newlabel.d_npartitions > OLDMAXPARTITIONS)
   1309       1.71      fvdl 			return ENOTTY;
   1310       1.70      fvdl 		memcpy(data, &newlabel, sizeof (struct olddisklabel));
   1311       1.70      fvdl 		break;
   1312       1.70      fvdl #endif
   1313       1.44   thorpej 
   1314       1.11   thorpej 	default:
   1315       1.57   thorpej 		error = ENOTTY;
   1316       1.11   thorpej 	}
   1317       1.11   thorpej 
   1318       1.57   thorpej  out:
   1319      1.117        ad 	mutex_exit(&cs->sc_lock);
   1320       1.57   thorpej 	return (error);
   1321        1.1   hpeyerl }
   1322        1.1   hpeyerl 
   1323       1.97   thorpej static int
   1324       1.97   thorpej ccdsize(dev_t dev)
   1325        1.1   hpeyerl {
   1326       1.11   thorpej 	struct ccd_softc *cs;
   1327       1.40   thorpej 	struct disklabel *lp;
   1328       1.40   thorpej 	int part, unit, omask, size;
   1329       1.40   thorpej 
   1330       1.40   thorpej 	unit = ccdunit(dev);
   1331       1.40   thorpej 	if (unit >= numccd)
   1332       1.40   thorpej 		return (-1);
   1333       1.40   thorpej 	cs = &ccd_softc[unit];
   1334       1.11   thorpej 
   1335       1.40   thorpej 	if ((cs->sc_flags & CCDF_INITED) == 0)
   1336       1.11   thorpej 		return (-1);
   1337       1.11   thorpej 
   1338       1.11   thorpej 	part = DISKPART(dev);
   1339       1.40   thorpej 	omask = cs->sc_dkdev.dk_openmask & (1 << part);
   1340       1.40   thorpej 	lp = cs->sc_dkdev.dk_label;
   1341       1.11   thorpej 
   1342      1.107  christos 	if (omask == 0 && ccdopen(dev, 0, S_IFBLK, curlwp))
   1343       1.11   thorpej 		return (-1);
   1344       1.11   thorpej 
   1345       1.40   thorpej 	if (lp->d_partitions[part].p_fstype != FS_SWAP)
   1346       1.11   thorpej 		size = -1;
   1347       1.11   thorpej 	else
   1348       1.40   thorpej 		size = lp->d_partitions[part].p_size *
   1349       1.40   thorpej 		    (lp->d_secsize / DEV_BSIZE);
   1350       1.11   thorpej 
   1351      1.107  christos 	if (omask == 0 && ccdclose(dev, 0, S_IFBLK, curlwp))
   1352       1.11   thorpej 		return (-1);
   1353        1.1   hpeyerl 
   1354       1.11   thorpej 	return (size);
   1355        1.1   hpeyerl }
   1356        1.1   hpeyerl 
   1357       1.97   thorpej static int
   1358      1.118  christos ccddump(dev_t dev, daddr_t blkno, void *va,
   1359      1.116  christos     size_t size)
   1360        1.1   hpeyerl {
   1361        1.9       cgd 
   1362        1.9       cgd 	/* Not implemented. */
   1363        1.9       cgd 	return ENXIO;
   1364       1.11   thorpej }
   1365       1.11   thorpej 
   1366       1.11   thorpej static void
   1367       1.97   thorpej ccdgetdefaultlabel(struct ccd_softc *cs, struct disklabel *lp)
   1368       1.11   thorpej {
   1369       1.11   thorpej 	struct ccdgeom *ccg = &cs->sc_geom;
   1370       1.11   thorpej 
   1371       1.72   thorpej 	memset(lp, 0, sizeof(*lp));
   1372       1.11   thorpej 
   1373       1.11   thorpej 	lp->d_secperunit = cs->sc_size;
   1374       1.11   thorpej 	lp->d_secsize = ccg->ccg_secsize;
   1375       1.11   thorpej 	lp->d_nsectors = ccg->ccg_nsectors;
   1376       1.11   thorpej 	lp->d_ntracks = ccg->ccg_ntracks;
   1377       1.11   thorpej 	lp->d_ncylinders = ccg->ccg_ncylinders;
   1378       1.19   thorpej 	lp->d_secpercyl = lp->d_ntracks * lp->d_nsectors;
   1379       1.11   thorpej 
   1380       1.11   thorpej 	strncpy(lp->d_typename, "ccd", sizeof(lp->d_typename));
   1381       1.11   thorpej 	lp->d_type = DTYPE_CCD;
   1382       1.11   thorpej 	strncpy(lp->d_packname, "fictitious", sizeof(lp->d_packname));
   1383       1.11   thorpej 	lp->d_rpm = 3600;
   1384       1.11   thorpej 	lp->d_interleave = 1;
   1385       1.11   thorpej 	lp->d_flags = 0;
   1386       1.11   thorpej 
   1387       1.11   thorpej 	lp->d_partitions[RAW_PART].p_offset = 0;
   1388       1.11   thorpej 	lp->d_partitions[RAW_PART].p_size = cs->sc_size;
   1389       1.11   thorpej 	lp->d_partitions[RAW_PART].p_fstype = FS_UNUSED;
   1390       1.11   thorpej 	lp->d_npartitions = RAW_PART + 1;
   1391       1.11   thorpej 
   1392       1.11   thorpej 	lp->d_magic = DISKMAGIC;
   1393       1.11   thorpej 	lp->d_magic2 = DISKMAGIC;
   1394       1.23   thorpej 	lp->d_checksum = dkcksum(cs->sc_dkdev.dk_label);
   1395       1.44   thorpej }
   1396       1.44   thorpej 
   1397       1.44   thorpej /*
   1398       1.44   thorpej  * Read the disklabel from the ccd.  If one is not present, fake one
   1399       1.44   thorpej  * up.
   1400       1.44   thorpej  */
   1401       1.44   thorpej static void
   1402       1.97   thorpej ccdgetdisklabel(dev_t dev)
   1403       1.44   thorpej {
   1404       1.44   thorpej 	int unit = ccdunit(dev);
   1405       1.44   thorpej 	struct ccd_softc *cs = &ccd_softc[unit];
   1406       1.85       dsl 	const char *errstring;
   1407       1.44   thorpej 	struct disklabel *lp = cs->sc_dkdev.dk_label;
   1408       1.44   thorpej 	struct cpu_disklabel *clp = cs->sc_dkdev.dk_cpulabel;
   1409       1.44   thorpej 
   1410       1.72   thorpej 	memset(clp, 0, sizeof(*clp));
   1411       1.44   thorpej 
   1412       1.44   thorpej 	ccdgetdefaultlabel(cs, lp);
   1413       1.11   thorpej 
   1414       1.11   thorpej 	/*
   1415       1.11   thorpej 	 * Call the generic disklabel extraction routine.
   1416       1.11   thorpej 	 */
   1417       1.92     lukem 	if ((cs->sc_flags & CCDF_NOLABEL) != 0)
   1418       1.92     lukem 		errstring = "CCDF_NOLABEL set; ignoring on-disk label";
   1419       1.92     lukem 	else
   1420       1.92     lukem 		errstring = readdisklabel(CCDLABELDEV(dev), ccdstrategy,
   1421       1.92     lukem 		    cs->sc_dkdev.dk_label, cs->sc_dkdev.dk_cpulabel);
   1422       1.29  christos 	if (errstring)
   1423       1.11   thorpej 		ccdmakedisklabel(cs);
   1424       1.47     enami 	else {
   1425       1.47     enami 		int i;
   1426       1.47     enami 		struct partition *pp;
   1427       1.47     enami 
   1428       1.47     enami 		/*
   1429       1.47     enami 		 * Sanity check whether the found disklabel is valid.
   1430       1.47     enami 		 *
   1431       1.47     enami 		 * This is necessary since total size of ccd may vary
   1432       1.47     enami 		 * when an interleave is changed even though exactly
   1433       1.47     enami 		 * same componets are used, and old disklabel may used
   1434       1.47     enami 		 * if that is found.
   1435       1.47     enami 		 */
   1436       1.47     enami 		if (lp->d_secperunit != cs->sc_size)
   1437       1.47     enami 			printf("WARNING: %s: "
   1438       1.47     enami 			    "total sector size in disklabel (%d) != "
   1439       1.60   thorpej 			    "the size of ccd (%lu)\n", cs->sc_xname,
   1440       1.60   thorpej 			    lp->d_secperunit, (u_long)cs->sc_size);
   1441       1.47     enami 		for (i = 0; i < lp->d_npartitions; i++) {
   1442       1.47     enami 			pp = &lp->d_partitions[i];
   1443       1.47     enami 			if (pp->p_offset + pp->p_size > cs->sc_size)
   1444       1.48     enami 				printf("WARNING: %s: end of partition `%c' "
   1445       1.60   thorpej 				    "exceeds the size of ccd (%lu)\n",
   1446       1.60   thorpej 				    cs->sc_xname, 'a' + i, (u_long)cs->sc_size);
   1447       1.47     enami 		}
   1448       1.47     enami 	}
   1449       1.11   thorpej 
   1450       1.11   thorpej #ifdef DEBUG
   1451       1.11   thorpej 	/* It's actually extremely common to have unlabeled ccds. */
   1452       1.11   thorpej 	if (ccddebug & CCDB_LABEL)
   1453       1.11   thorpej 		if (errstring != NULL)
   1454       1.35  christos 			printf("%s: %s\n", cs->sc_xname, errstring);
   1455       1.11   thorpej #endif
   1456       1.87   thorpej 
   1457       1.87   thorpej 	/* In-core label now valid. */
   1458       1.87   thorpej 	cs->sc_flags |= CCDF_VLABEL;
   1459       1.11   thorpej }
   1460       1.11   thorpej 
   1461       1.11   thorpej /*
   1462       1.11   thorpej  * Take care of things one might want to take care of in the event
   1463       1.11   thorpej  * that a disklabel isn't present.
   1464       1.11   thorpej  */
   1465       1.11   thorpej static void
   1466       1.97   thorpej ccdmakedisklabel(struct ccd_softc *cs)
   1467       1.11   thorpej {
   1468       1.23   thorpej 	struct disklabel *lp = cs->sc_dkdev.dk_label;
   1469       1.11   thorpej 
   1470       1.11   thorpej 	/*
   1471       1.11   thorpej 	 * For historical reasons, if there's no disklabel present
   1472       1.11   thorpej 	 * the raw partition must be marked FS_BSDFFS.
   1473       1.11   thorpej 	 */
   1474       1.11   thorpej 	lp->d_partitions[RAW_PART].p_fstype = FS_BSDFFS;
   1475       1.11   thorpej 
   1476       1.11   thorpej 	strncpy(lp->d_packname, "default label", sizeof(lp->d_packname));
   1477       1.44   thorpej 
   1478       1.44   thorpej 	lp->d_checksum = dkcksum(lp);
   1479       1.11   thorpej }
   1480       1.11   thorpej 
   1481       1.11   thorpej #ifdef DEBUG
   1482       1.11   thorpej static void
   1483       1.97   thorpej printiinfo(struct ccdiinfo *ii)
   1484       1.11   thorpej {
   1485       1.68  augustss 	int ix, i;
   1486       1.11   thorpej 
   1487       1.11   thorpej 	for (ix = 0; ii->ii_ndisk; ix++, ii++) {
   1488       1.81    kleink 		printf(" itab[%d]: #dk %d sblk %" PRId64 " soff %" PRId64,
   1489       1.34  christos 		    ix, ii->ii_ndisk, ii->ii_startblk, ii->ii_startoff);
   1490       1.11   thorpej 		for (i = 0; i < ii->ii_ndisk; i++)
   1491       1.35  christos 			printf(" %d", ii->ii_index[i]);
   1492       1.35  christos 		printf("\n");
   1493       1.11   thorpej 	}
   1494        1.1   hpeyerl }
   1495        1.1   hpeyerl #endif
   1496