Home | History | Annotate | Line # | Download | only in dev
ccd.c revision 1.128
      1  1.128        ad /*	$NetBSD: ccd.c,v 1.128 2008/03/21 21:54:59 ad 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.128        ad __KERNEL_RCSID(0, "$NetBSD: ccd.c,v 1.128 2008/03/21 21:54:59 ad 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.57   thorpej 	int i;
    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.57   thorpej 	/* Initialize per-softc structures. */
    261   1.57   thorpej 	for (i = 0; i < num; i++) {
    262   1.57   thorpej 		cs = &ccd_softc[i];
    263   1.96    itojun 		snprintf(cs->sc_xname, sizeof(cs->sc_xname), "ccd%d", i);
    264  1.125        ad 		mutex_init(&cs->sc_lock, MUTEX_DEFAULT, IPL_NONE);
    265  1.123        ad 		disk_init(&cs->sc_dkdev, cs->sc_xname, NULL); /* XXX */
    266   1.57   thorpej 	}
    267    1.1   hpeyerl }
    268    1.1   hpeyerl 
    269   1.11   thorpej static int
    270   1.97   thorpej ccdinit(struct ccd_softc *cs, char **cpaths, struct vnode **vpp,
    271  1.107  christos     struct lwp *l)
    272    1.1   hpeyerl {
    273   1.68  augustss 	struct ccdcinfo *ci = NULL;
    274   1.68  augustss 	size_t size;
    275   1.68  augustss 	int ix;
    276   1.11   thorpej 	struct vattr va;
    277    1.1   hpeyerl 	size_t minsize;
    278   1.11   thorpej 	int maxsecsize;
    279    1.7       cgd 	struct partinfo dpart;
    280   1.11   thorpej 	struct ccdgeom *ccg = &cs->sc_geom;
    281  1.111  christos 	char *tmppath;
    282   1.67     enami 	int error, path_alloced;
    283    1.1   hpeyerl 
    284    1.1   hpeyerl #ifdef DEBUG
    285    1.3   hpeyerl 	if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    286   1.59   thorpej 		printf("%s: ccdinit\n", cs->sc_xname);
    287    1.1   hpeyerl #endif
    288   1.11   thorpej 
    289   1.11   thorpej 	/* Allocate space for the component info. */
    290   1.11   thorpej 	cs->sc_cinfo = malloc(cs->sc_nccdisks * sizeof(struct ccdcinfo),
    291   1.11   thorpej 	    M_DEVBUF, M_WAITOK);
    292   1.11   thorpej 
    293  1.111  christos 	tmppath = malloc(MAXPATHLEN, M_TEMP, M_WAITOK);
    294  1.111  christos 
    295   1.57   thorpej 	cs->sc_size = 0;
    296   1.57   thorpej 
    297    1.1   hpeyerl 	/*
    298    1.1   hpeyerl 	 * Verify that each component piece exists and record
    299    1.1   hpeyerl 	 * relevant information about it.
    300    1.1   hpeyerl 	 */
    301   1.11   thorpej 	maxsecsize = 0;
    302    1.1   hpeyerl 	minsize = 0;
    303   1.67     enami 	for (ix = 0, path_alloced = 0; ix < cs->sc_nccdisks; ix++) {
    304    1.1   hpeyerl 		ci = &cs->sc_cinfo[ix];
    305   1.57   thorpej 		ci->ci_vp = vpp[ix];
    306   1.11   thorpej 
    307   1.11   thorpej 		/*
    308   1.11   thorpej 		 * Copy in the pathname of the component.
    309   1.11   thorpej 		 */
    310   1.72   thorpej 		memset(tmppath, 0, sizeof(tmppath));	/* sanity */
    311   1.29  christos 		error = copyinstr(cpaths[ix], tmppath,
    312   1.29  christos 		    MAXPATHLEN, &ci->ci_pathlen);
    313   1.29  christos 		if (error) {
    314   1.11   thorpej #ifdef DEBUG
    315   1.11   thorpej 			if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    316   1.35  christos 				printf("%s: can't copy path, error = %d\n",
    317   1.23   thorpej 				    cs->sc_xname, error);
    318   1.11   thorpej #endif
    319   1.67     enami 			goto out;
    320   1.11   thorpej 		}
    321   1.11   thorpej 		ci->ci_path = malloc(ci->ci_pathlen, M_DEVBUF, M_WAITOK);
    322   1.72   thorpej 		memcpy(ci->ci_path, tmppath, ci->ci_pathlen);
    323   1.67     enami 		path_alloced++;
    324   1.11   thorpej 
    325   1.11   thorpej 		/*
    326   1.11   thorpej 		 * XXX: Cache the component's dev_t.
    327   1.11   thorpej 		 */
    328  1.124     pooka 		if ((error = VOP_GETATTR(vpp[ix], &va, l->l_cred)) != 0) {
    329   1.11   thorpej #ifdef DEBUG
    330   1.11   thorpej 			if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    331   1.35  christos 				printf("%s: %s: getattr failed %s = %d\n",
    332   1.23   thorpej 				    cs->sc_xname, ci->ci_path,
    333   1.11   thorpej 				    "error", error);
    334   1.11   thorpej #endif
    335   1.67     enami 			goto out;
    336   1.11   thorpej 		}
    337   1.11   thorpej 		ci->ci_dev = va.va_rdev;
    338   1.11   thorpej 
    339    1.3   hpeyerl 		/*
    340   1.11   thorpej 		 * Get partition information for the component.
    341    1.3   hpeyerl 		 */
    342   1.84       dsl 		error = VOP_IOCTL(vpp[ix], DIOCGPART, &dpart,
    343  1.124     pooka 		    FREAD, l->l_cred);
    344   1.29  christos 		if (error) {
    345   1.11   thorpej #ifdef DEBUG
    346   1.11   thorpej 			if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    347   1.35  christos 				 printf("%s: %s: ioctl failed, error = %d\n",
    348   1.23   thorpej 				     cs->sc_xname, ci->ci_path, error);
    349   1.11   thorpej #endif
    350   1.67     enami 			goto out;
    351   1.11   thorpej 		}
    352   1.69     enami 
    353   1.69     enami /*
    354   1.69     enami  * This diagnostic test is disabled (for now?) since not all port supports
    355   1.69     enami  * on-disk BSD disklabel.
    356   1.69     enami  */
    357   1.69     enami #if 0 /* def DIAGNOSTIC */
    358   1.69     enami 		/* Check fstype field of component. */
    359   1.69     enami 		if (dpart.part->p_fstype != FS_CCD)
    360   1.69     enami 			printf("%s: WARNING: %s: fstype %d != FS_CCD\n",
    361   1.69     enami 			    cs->sc_xname, ci->ci_path, dpart.part->p_fstype);
    362   1.69     enami #endif
    363    1.7       cgd 
    364   1.11   thorpej 		/*
    365   1.11   thorpej 		 * Calculate the size, truncating to an interleave
    366   1.11   thorpej 		 * boundary if necessary.
    367   1.11   thorpej 		 */
    368   1.46   thorpej 		maxsecsize =
    369   1.46   thorpej 		    ((dpart.disklab->d_secsize > maxsecsize) ?
    370   1.46   thorpej 		    dpart.disklab->d_secsize : maxsecsize);
    371   1.46   thorpej 		size = dpart.part->p_size;
    372    1.1   hpeyerl 		if (cs->sc_ileave > 1)
    373    1.1   hpeyerl 			size -= size % cs->sc_ileave;
    374   1.11   thorpej 
    375    1.1   hpeyerl 		if (size == 0) {
    376   1.11   thorpej #ifdef DEBUG
    377   1.11   thorpej 			if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    378   1.35  christos 				printf("%s: %s: size == 0\n",
    379   1.23   thorpej 				    cs->sc_xname, ci->ci_path);
    380   1.11   thorpej #endif
    381   1.67     enami 			error = ENODEV;
    382   1.67     enami 			goto out;
    383    1.3   hpeyerl 		}
    384   1.11   thorpej 
    385    1.1   hpeyerl 		if (minsize == 0 || size < minsize)
    386    1.1   hpeyerl 			minsize = size;
    387    1.1   hpeyerl 		ci->ci_size = size;
    388    1.1   hpeyerl 		cs->sc_size += size;
    389    1.1   hpeyerl 	}
    390   1.11   thorpej 
    391   1.11   thorpej 	/*
    392   1.11   thorpej 	 * Don't allow the interleave to be smaller than
    393   1.11   thorpej 	 * the biggest component sector.
    394   1.11   thorpej 	 */
    395   1.11   thorpej 	if ((cs->sc_ileave > 0) &&
    396   1.11   thorpej 	    (cs->sc_ileave < (maxsecsize / DEV_BSIZE))) {
    397   1.11   thorpej #ifdef DEBUG
    398   1.11   thorpej 		if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
    399   1.35  christos 			printf("%s: interleave must be at least %d\n",
    400   1.23   thorpej 			    cs->sc_xname, (maxsecsize / DEV_BSIZE));
    401   1.11   thorpej #endif
    402   1.67     enami 		error = EINVAL;
    403   1.67     enami 		goto out;
    404   1.11   thorpej 	}
    405   1.11   thorpej 
    406    1.1   hpeyerl 	/*
    407    1.1   hpeyerl 	 * If uniform interleave is desired set all sizes to that of
    408    1.1   hpeyerl 	 * the smallest component.
    409    1.1   hpeyerl 	 */
    410   1.57   thorpej 	if (cs->sc_flags & CCDF_UNIFORM) {
    411    1.1   hpeyerl 		for (ci = cs->sc_cinfo;
    412    1.1   hpeyerl 		     ci < &cs->sc_cinfo[cs->sc_nccdisks]; ci++)
    413    1.1   hpeyerl 			ci->ci_size = minsize;
    414   1.24   thorpej 
    415   1.53   thorpej 		cs->sc_size = cs->sc_nccdisks * minsize;
    416    1.1   hpeyerl 	}
    417   1.11   thorpej 
    418   1.11   thorpej 	/*
    419   1.11   thorpej 	 * Construct the interleave table.
    420   1.11   thorpej 	 */
    421   1.57   thorpej 	ccdinterleave(cs);
    422   1.11   thorpej 
    423    1.1   hpeyerl 	/*
    424   1.11   thorpej 	 * Create pseudo-geometry based on 1MB cylinders.  It's
    425   1.11   thorpej 	 * pretty close.
    426    1.1   hpeyerl 	 */
    427   1.11   thorpej 	ccg->ccg_secsize = DEV_BSIZE;
    428   1.19   thorpej 	ccg->ccg_ntracks = 1;
    429   1.11   thorpej 	ccg->ccg_nsectors = 1024 * (1024 / ccg->ccg_secsize);
    430   1.11   thorpej 	ccg->ccg_ncylinders = cs->sc_size / ccg->ccg_nsectors;
    431   1.11   thorpej 
    432   1.11   thorpej 	cs->sc_flags |= CCDF_INITED;
    433   1.23   thorpej 
    434  1.114  christos 	free(tmppath, M_TEMP);
    435  1.114  christos 
    436   1.11   thorpej 	return (0);
    437   1.67     enami 
    438   1.67     enami  out:
    439   1.67     enami 	for (ix = 0; ix < path_alloced; ix++)
    440   1.67     enami 		free(cs->sc_cinfo[ix].ci_path, M_DEVBUF);
    441   1.67     enami 	free(cs->sc_cinfo, M_DEVBUF);
    442  1.111  christos 	free(tmppath, M_TEMP);
    443   1.67     enami 	return (error);
    444    1.1   hpeyerl }
    445    1.1   hpeyerl 
    446   1.11   thorpej static void
    447   1.97   thorpej ccdinterleave(struct ccd_softc *cs)
    448    1.1   hpeyerl {
    449   1.68  augustss 	struct ccdcinfo *ci, *smallci;
    450   1.68  augustss 	struct ccdiinfo *ii;
    451   1.68  augustss 	daddr_t bn, lbn;
    452   1.68  augustss 	int ix;
    453    1.1   hpeyerl 	u_long size;
    454    1.1   hpeyerl 
    455    1.1   hpeyerl #ifdef DEBUG
    456    1.3   hpeyerl 	if (ccddebug & CCDB_INIT)
    457   1.35  christos 		printf("ccdinterleave(%p): ileave %d\n", cs, cs->sc_ileave);
    458    1.1   hpeyerl #endif
    459    1.1   hpeyerl 	/*
    460    1.1   hpeyerl 	 * Allocate an interleave table.
    461    1.1   hpeyerl 	 * Chances are this is too big, but we don't care.
    462    1.1   hpeyerl 	 */
    463    1.1   hpeyerl 	size = (cs->sc_nccdisks + 1) * sizeof(struct ccdiinfo);
    464   1.75   tsutsui 	cs->sc_itable = (struct ccdiinfo *)malloc(size, M_DEVBUF,
    465   1.75   tsutsui 	    M_WAITOK|M_ZERO);
    466   1.11   thorpej 
    467    1.1   hpeyerl 	/*
    468    1.1   hpeyerl 	 * Trivial case: no interleave (actually interleave of disk size).
    469   1.11   thorpej 	 * Each table entry represents a single component in its entirety.
    470    1.1   hpeyerl 	 */
    471    1.1   hpeyerl 	if (cs->sc_ileave == 0) {
    472    1.1   hpeyerl 		bn = 0;
    473    1.1   hpeyerl 		ii = cs->sc_itable;
    474   1.11   thorpej 
    475    1.1   hpeyerl 		for (ix = 0; ix < cs->sc_nccdisks; ix++) {
    476   1.19   thorpej 			/* Allocate space for ii_index. */
    477   1.19   thorpej 			ii->ii_index = malloc(sizeof(int), M_DEVBUF, M_WAITOK);
    478    1.1   hpeyerl 			ii->ii_ndisk = 1;
    479    1.1   hpeyerl 			ii->ii_startblk = bn;
    480    1.1   hpeyerl 			ii->ii_startoff = 0;
    481    1.1   hpeyerl 			ii->ii_index[0] = ix;
    482    1.1   hpeyerl 			bn += cs->sc_cinfo[ix].ci_size;
    483    1.1   hpeyerl 			ii++;
    484    1.1   hpeyerl 		}
    485    1.1   hpeyerl 		ii->ii_ndisk = 0;
    486    1.1   hpeyerl #ifdef DEBUG
    487    1.3   hpeyerl 		if (ccddebug & CCDB_INIT)
    488    1.1   hpeyerl 			printiinfo(cs->sc_itable);
    489    1.1   hpeyerl #endif
    490   1.11   thorpej 		return;
    491    1.1   hpeyerl 	}
    492   1.11   thorpej 
    493    1.1   hpeyerl 	/*
    494    1.1   hpeyerl 	 * The following isn't fast or pretty; it doesn't have to be.
    495    1.1   hpeyerl 	 */
    496    1.1   hpeyerl 	size = 0;
    497    1.1   hpeyerl 	bn = lbn = 0;
    498    1.1   hpeyerl 	for (ii = cs->sc_itable; ; ii++) {
    499   1.11   thorpej 		/* Allocate space for ii_index. */
    500   1.19   thorpej 		ii->ii_index = malloc((sizeof(int) * cs->sc_nccdisks),
    501   1.19   thorpej 		    M_DEVBUF, M_WAITOK);
    502   1.11   thorpej 
    503    1.1   hpeyerl 		/*
    504    1.1   hpeyerl 		 * Locate the smallest of the remaining components
    505    1.1   hpeyerl 		 */
    506    1.1   hpeyerl 		smallci = NULL;
    507    1.1   hpeyerl 		for (ci = cs->sc_cinfo;
    508    1.1   hpeyerl 		     ci < &cs->sc_cinfo[cs->sc_nccdisks]; ci++)
    509    1.1   hpeyerl 			if (ci->ci_size > size &&
    510    1.1   hpeyerl 			    (smallci == NULL ||
    511    1.1   hpeyerl 			     ci->ci_size < smallci->ci_size))
    512    1.1   hpeyerl 				smallci = ci;
    513   1.11   thorpej 
    514    1.1   hpeyerl 		/*
    515    1.1   hpeyerl 		 * Nobody left, all done
    516    1.1   hpeyerl 		 */
    517    1.1   hpeyerl 		if (smallci == NULL) {
    518    1.1   hpeyerl 			ii->ii_ndisk = 0;
    519    1.1   hpeyerl 			break;
    520    1.1   hpeyerl 		}
    521   1.11   thorpej 
    522    1.1   hpeyerl 		/*
    523    1.1   hpeyerl 		 * Record starting logical block and component offset
    524    1.1   hpeyerl 		 */
    525    1.1   hpeyerl 		ii->ii_startblk = bn / cs->sc_ileave;
    526    1.1   hpeyerl 		ii->ii_startoff = lbn;
    527   1.11   thorpej 
    528    1.1   hpeyerl 		/*
    529    1.1   hpeyerl 		 * Determine how many disks take part in this interleave
    530    1.1   hpeyerl 		 * and record their indices.
    531    1.1   hpeyerl 		 */
    532    1.1   hpeyerl 		ix = 0;
    533    1.1   hpeyerl 		for (ci = cs->sc_cinfo;
    534    1.1   hpeyerl 		     ci < &cs->sc_cinfo[cs->sc_nccdisks]; ci++)
    535    1.1   hpeyerl 			if (ci->ci_size >= smallci->ci_size)
    536    1.1   hpeyerl 				ii->ii_index[ix++] = ci - cs->sc_cinfo;
    537    1.1   hpeyerl 		ii->ii_ndisk = ix;
    538    1.1   hpeyerl 		bn += ix * (smallci->ci_size - size);
    539    1.1   hpeyerl 		lbn = smallci->ci_size / cs->sc_ileave;
    540    1.1   hpeyerl 		size = smallci->ci_size;
    541    1.1   hpeyerl 	}
    542    1.1   hpeyerl #ifdef DEBUG
    543    1.3   hpeyerl 	if (ccddebug & CCDB_INIT)
    544    1.1   hpeyerl 		printiinfo(cs->sc_itable);
    545    1.1   hpeyerl #endif
    546    1.1   hpeyerl }
    547    1.1   hpeyerl 
    548   1.11   thorpej /* ARGSUSED */
    549   1.97   thorpej static int
    550  1.116  christos ccdopen(dev_t dev, int flags, int fmt, struct lwp *l)
    551    1.1   hpeyerl {
    552    1.1   hpeyerl 	int unit = ccdunit(dev);
    553   1.11   thorpej 	struct ccd_softc *cs;
    554   1.11   thorpej 	struct disklabel *lp;
    555   1.15   thorpej 	int error = 0, part, pmask;
    556    1.1   hpeyerl 
    557    1.1   hpeyerl #ifdef DEBUG
    558    1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    559   1.43      fair 		printf("ccdopen(0x%x, 0x%x)\n", dev, flags);
    560    1.1   hpeyerl #endif
    561   1.11   thorpej 	if (unit >= numccd)
    562   1.11   thorpej 		return (ENXIO);
    563   1.11   thorpej 	cs = &ccd_softc[unit];
    564   1.15   thorpej 
    565  1.117        ad 	mutex_enter(&cs->sc_lock);
    566   1.15   thorpej 
    567   1.23   thorpej 	lp = cs->sc_dkdev.dk_label;
    568   1.11   thorpej 
    569   1.11   thorpej 	part = DISKPART(dev);
    570   1.11   thorpej 	pmask = (1 << part);
    571   1.11   thorpej 
    572   1.15   thorpej 	/*
    573   1.15   thorpej 	 * If we're initialized, check to see if there are any other
    574   1.15   thorpej 	 * open partitions.  If not, then it's safe to update
    575   1.87   thorpej 	 * the in-core disklabel.  Only read the disklabel if it is
    576   1.87   thorpej 	 * not already valid.
    577   1.15   thorpej 	 */
    578   1.87   thorpej 	if ((cs->sc_flags & (CCDF_INITED|CCDF_VLABEL)) == CCDF_INITED &&
    579   1.87   thorpej 	    cs->sc_dkdev.dk_openmask == 0)
    580   1.15   thorpej 		ccdgetdisklabel(dev);
    581   1.15   thorpej 
    582   1.11   thorpej 	/* Check that the partition exists. */
    583   1.27   thorpej 	if (part != RAW_PART) {
    584   1.27   thorpej 		if (((cs->sc_flags & CCDF_INITED) == 0) ||
    585   1.37   thorpej 		    ((part >= lp->d_npartitions) ||
    586   1.27   thorpej 		     (lp->d_partitions[part].p_fstype == FS_UNUSED))) {
    587   1.27   thorpej 			error = ENXIO;
    588   1.27   thorpej 			goto done;
    589   1.27   thorpej 		}
    590   1.15   thorpej 	}
    591   1.11   thorpej 
    592   1.11   thorpej 	/* Prevent our unit from being unconfigured while open. */
    593   1.11   thorpej 	switch (fmt) {
    594   1.11   thorpej 	case S_IFCHR:
    595   1.11   thorpej 		cs->sc_dkdev.dk_copenmask |= pmask;
    596   1.11   thorpej 		break;
    597   1.11   thorpej 
    598   1.11   thorpej 	case S_IFBLK:
    599   1.11   thorpej 		cs->sc_dkdev.dk_bopenmask |= pmask;
    600   1.11   thorpej 		break;
    601   1.11   thorpej 	}
    602   1.11   thorpej 	cs->sc_dkdev.dk_openmask =
    603   1.11   thorpej 	    cs->sc_dkdev.dk_copenmask | cs->sc_dkdev.dk_bopenmask;
    604   1.11   thorpej 
    605   1.15   thorpej  done:
    606  1.117        ad 	mutex_exit(&cs->sc_lock);
    607   1.33   thorpej 	return (error);
    608    1.7       cgd }
    609    1.7       cgd 
    610   1.11   thorpej /* ARGSUSED */
    611   1.97   thorpej static int
    612  1.116  christos ccdclose(dev_t dev, int flags, int fmt, struct lwp *l)
    613    1.7       cgd {
    614   1.11   thorpej 	int unit = ccdunit(dev);
    615   1.11   thorpej 	struct ccd_softc *cs;
    616  1.117        ad 	int part;
    617   1.11   thorpej 
    618    1.7       cgd #ifdef DEBUG
    619    1.7       cgd 	if (ccddebug & CCDB_FOLLOW)
    620   1.43      fair 		printf("ccdclose(0x%x, 0x%x)\n", dev, flags);
    621    1.7       cgd #endif
    622   1.11   thorpej 
    623   1.11   thorpej 	if (unit >= numccd)
    624   1.11   thorpej 		return (ENXIO);
    625   1.11   thorpej 	cs = &ccd_softc[unit];
    626   1.15   thorpej 
    627  1.117        ad 	mutex_enter(&cs->sc_lock);
    628   1.15   thorpej 
    629   1.11   thorpej 	part = DISKPART(dev);
    630   1.11   thorpej 
    631   1.11   thorpej 	/* ...that much closer to allowing unconfiguration... */
    632   1.11   thorpej 	switch (fmt) {
    633   1.11   thorpej 	case S_IFCHR:
    634   1.11   thorpej 		cs->sc_dkdev.dk_copenmask &= ~(1 << part);
    635   1.11   thorpej 		break;
    636   1.11   thorpej 
    637   1.11   thorpej 	case S_IFBLK:
    638   1.11   thorpej 		cs->sc_dkdev.dk_bopenmask &= ~(1 << part);
    639   1.11   thorpej 		break;
    640   1.11   thorpej 	}
    641   1.11   thorpej 	cs->sc_dkdev.dk_openmask =
    642   1.11   thorpej 	    cs->sc_dkdev.dk_copenmask | cs->sc_dkdev.dk_bopenmask;
    643   1.11   thorpej 
    644   1.87   thorpej 	if (cs->sc_dkdev.dk_openmask == 0) {
    645   1.87   thorpej 		if ((cs->sc_flags & CCDF_KLABEL) == 0)
    646   1.87   thorpej 			cs->sc_flags &= ~CCDF_VLABEL;
    647   1.87   thorpej 	}
    648   1.87   thorpej 
    649  1.117        ad 	mutex_exit(&cs->sc_lock);
    650    1.7       cgd 	return (0);
    651    1.1   hpeyerl }
    652    1.1   hpeyerl 
    653   1.97   thorpej static void
    654   1.97   thorpej ccdstrategy(struct buf *bp)
    655    1.1   hpeyerl {
    656   1.68  augustss 	int unit = ccdunit(bp->b_dev);
    657   1.68  augustss 	struct ccd_softc *cs = &ccd_softc[unit];
    658   1.88   thorpej 	daddr_t blkno;
    659   1.68  augustss 	int s;
    660   1.11   thorpej 	int wlabel;
    661   1.15   thorpej 	struct disklabel *lp;
    662    1.1   hpeyerl 
    663    1.1   hpeyerl #ifdef DEBUG
    664    1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    665   1.35  christos 		printf("ccdstrategy(%p): unit %d\n", bp, unit);
    666    1.1   hpeyerl #endif
    667    1.3   hpeyerl 	if ((cs->sc_flags & CCDF_INITED) == 0) {
    668   1.59   thorpej #ifdef DEBUG
    669   1.59   thorpej 		if (ccddebug & CCDB_FOLLOW)
    670   1.59   thorpej 			printf("ccdstrategy: unit %d: not inited\n", unit);
    671   1.59   thorpej #endif
    672    1.1   hpeyerl 		bp->b_error = ENXIO;
    673    1.1   hpeyerl 		goto done;
    674    1.1   hpeyerl 	}
    675   1.11   thorpej 
    676   1.11   thorpej 	/* If it's a nil transfer, wake up the top half now. */
    677   1.11   thorpej 	if (bp->b_bcount == 0)
    678   1.11   thorpej 		goto done;
    679   1.11   thorpej 
    680   1.23   thorpej 	lp = cs->sc_dkdev.dk_label;
    681   1.15   thorpej 
    682   1.11   thorpej 	/*
    683   1.17   thorpej 	 * Do bounds checking and adjust transfer.  If there's an
    684   1.88   thorpej 	 * error, the bounds check will flag that for us.  Convert
    685   1.88   thorpej 	 * the partition relative block number to an absolute.
    686   1.11   thorpej 	 */
    687   1.88   thorpej 	blkno = bp->b_blkno;
    688   1.11   thorpej 	wlabel = cs->sc_flags & (CCDF_WLABEL|CCDF_LABELLING);
    689   1.88   thorpej 	if (DISKPART(bp->b_dev) != RAW_PART) {
    690   1.86   thorpej 		if (bounds_check_with_label(&cs->sc_dkdev, bp, wlabel) <= 0)
    691    1.1   hpeyerl 			goto done;
    692   1.88   thorpej 		blkno += lp->d_partitions[DISKPART(bp->b_dev)].p_offset;
    693   1.88   thorpej 	}
    694   1.88   thorpej 	bp->b_rawblkno = blkno;
    695   1.11   thorpej 
    696   1.88   thorpej 	/* Place it in the queue and start I/O on the unit. */
    697    1.1   hpeyerl 	s = splbio();
    698  1.106      yamt 	BUFQ_PUT(cs->sc_bufq, bp);
    699   1.88   thorpej 	ccdstart(cs);
    700    1.1   hpeyerl 	splx(s);
    701    1.1   hpeyerl 	return;
    702   1.88   thorpej 
    703   1.88   thorpej  done:
    704   1.88   thorpej 	bp->b_resid = bp->b_bcount;
    705    1.1   hpeyerl 	biodone(bp);
    706    1.1   hpeyerl }
    707    1.1   hpeyerl 
    708   1.11   thorpej static void
    709   1.97   thorpej ccdstart(struct ccd_softc *cs)
    710    1.1   hpeyerl {
    711   1.68  augustss 	long bcount, rcount;
    712   1.88   thorpej 	struct buf *bp;
    713   1.55   thorpej 	struct ccdbuf *cbp;
    714  1.118  christos 	char *addr;
    715    1.1   hpeyerl 	daddr_t bn;
    716   1.56   thorpej 	SIMPLEQ_HEAD(, ccdbuf) cbufq;
    717    1.1   hpeyerl 
    718    1.1   hpeyerl #ifdef DEBUG
    719    1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    720   1.93       chs 		printf("ccdstart(%p)\n", cs);
    721    1.1   hpeyerl #endif
    722   1.11   thorpej 
    723   1.88   thorpej 	/* See if there is work for us to do. */
    724  1.106      yamt 	while ((bp = BUFQ_PEEK(cs->sc_bufq)) != NULL) {
    725   1.88   thorpej 		/* Instrumentation. */
    726   1.88   thorpej 		disk_busy(&cs->sc_dkdev);
    727   1.11   thorpej 
    728   1.88   thorpej 		bp->b_resid = bp->b_bcount;
    729   1.88   thorpej 		bn = bp->b_rawblkno;
    730   1.17   thorpej 
    731   1.88   thorpej 		/* Allocate the component buffers. */
    732   1.88   thorpej 		SIMPLEQ_INIT(&cbufq);
    733   1.88   thorpej 		addr = bp->b_data;
    734   1.88   thorpej 		for (bcount = bp->b_bcount; bcount > 0; bcount -= rcount) {
    735   1.88   thorpej 			cbp = ccdbuffer(cs, bp, bn, addr, bcount);
    736   1.88   thorpej 			if (cbp == NULL) {
    737   1.88   thorpej 				/*
    738   1.88   thorpej 				 * Can't allocate a component buffer; just
    739   1.88   thorpej 				 * defer the job until later.
    740   1.88   thorpej 				 *
    741   1.88   thorpej 				 * XXX We might consider a watchdog timer
    742   1.88   thorpej 				 * XXX to make sure we are kicked into action,
    743   1.88   thorpej 				 * XXX or consider a low-water mark for our
    744   1.88   thorpej 				 * XXX component buffer pool.
    745   1.88   thorpej 				 */
    746   1.88   thorpej 				while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
    747   1.88   thorpej 					SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
    748   1.88   thorpej 					CCD_PUTBUF(cbp);
    749   1.88   thorpej 				}
    750   1.88   thorpej 				disk_unbusy(&cs->sc_dkdev, 0, 0);
    751   1.88   thorpej 				return;
    752   1.56   thorpej 			}
    753   1.88   thorpej 			SIMPLEQ_INSERT_TAIL(&cbufq, cbp, cb_q);
    754   1.88   thorpej 			rcount = cbp->cb_buf.b_bcount;
    755   1.88   thorpej 			bn += btodb(rcount);
    756   1.88   thorpej 			addr += rcount;
    757   1.88   thorpej 		}
    758   1.88   thorpej 
    759   1.88   thorpej 		/* Transfer all set up, remove job from the queue. */
    760  1.106      yamt 		(void) BUFQ_GET(cs->sc_bufq);
    761   1.56   thorpej 
    762   1.88   thorpej 		/* Now fire off the requests. */
    763   1.88   thorpej 		while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
    764   1.88   thorpej 			SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
    765   1.88   thorpej 			if ((cbp->cb_buf.b_flags & B_READ) == 0)
    766   1.88   thorpej 				cbp->cb_buf.b_vp->v_numoutput++;
    767  1.121        ad 			bdev_strategy(&cbp->cb_buf);
    768   1.56   thorpej 		}
    769    1.1   hpeyerl 	}
    770    1.1   hpeyerl }
    771    1.1   hpeyerl 
    772    1.1   hpeyerl /*
    773    1.1   hpeyerl  * Build a component buffer header.
    774    1.1   hpeyerl  */
    775   1.55   thorpej static struct ccdbuf *
    776  1.118  christos ccdbuffer(struct ccd_softc *cs, struct buf *bp, daddr_t bn, void *addr,
    777   1.97   thorpej     long bcount)
    778    1.1   hpeyerl {
    779   1.68  augustss 	struct ccdcinfo *ci;
    780   1.68  augustss 	struct ccdbuf *cbp;
    781   1.68  augustss 	daddr_t cbn, cboff;
    782   1.68  augustss 	u_int64_t cbc;
    783   1.36   thorpej 	int ccdisk;
    784    1.1   hpeyerl 
    785    1.1   hpeyerl #ifdef DEBUG
    786    1.3   hpeyerl 	if (ccddebug & CCDB_IO)
    787   1.81    kleink 		printf("ccdbuffer(%p, %p, %" PRId64 ", %p, %ld)\n",
    788    1.1   hpeyerl 		       cs, bp, bn, addr, bcount);
    789    1.1   hpeyerl #endif
    790    1.1   hpeyerl 	/*
    791    1.1   hpeyerl 	 * Determine which component bn falls in.
    792    1.1   hpeyerl 	 */
    793    1.1   hpeyerl 	cbn = bn;
    794    1.1   hpeyerl 	cboff = 0;
    795   1.11   thorpej 
    796    1.1   hpeyerl 	/*
    797    1.1   hpeyerl 	 * Serially concatenated
    798    1.1   hpeyerl 	 */
    799    1.1   hpeyerl 	if (cs->sc_ileave == 0) {
    800   1.68  augustss 		daddr_t sblk;
    801    1.1   hpeyerl 
    802    1.1   hpeyerl 		sblk = 0;
    803   1.36   thorpej 		for (ccdisk = 0, ci = &cs->sc_cinfo[ccdisk];
    804   1.36   thorpej 		    cbn >= sblk + ci->ci_size;
    805   1.36   thorpej 		    ccdisk++, ci = &cs->sc_cinfo[ccdisk])
    806    1.1   hpeyerl 			sblk += ci->ci_size;
    807    1.1   hpeyerl 		cbn -= sblk;
    808    1.1   hpeyerl 	}
    809    1.1   hpeyerl 	/*
    810    1.1   hpeyerl 	 * Interleaved
    811    1.1   hpeyerl 	 */
    812    1.1   hpeyerl 	else {
    813   1.68  augustss 		struct ccdiinfo *ii;
    814   1.36   thorpej 		int off;
    815    1.1   hpeyerl 
    816    1.1   hpeyerl 		cboff = cbn % cs->sc_ileave;
    817    1.1   hpeyerl 		cbn /= cs->sc_ileave;
    818    1.1   hpeyerl 		for (ii = cs->sc_itable; ii->ii_ndisk; ii++)
    819    1.1   hpeyerl 			if (ii->ii_startblk > cbn)
    820    1.1   hpeyerl 				break;
    821    1.1   hpeyerl 		ii--;
    822    1.1   hpeyerl 		off = cbn - ii->ii_startblk;
    823    1.1   hpeyerl 		if (ii->ii_ndisk == 1) {
    824    1.1   hpeyerl 			ccdisk = ii->ii_index[0];
    825    1.1   hpeyerl 			cbn = ii->ii_startoff + off;
    826    1.1   hpeyerl 		} else {
    827   1.53   thorpej 			ccdisk = ii->ii_index[off % ii->ii_ndisk];
    828   1.53   thorpej 			cbn = ii->ii_startoff + off / ii->ii_ndisk;
    829    1.1   hpeyerl 		}
    830    1.1   hpeyerl 		cbn *= cs->sc_ileave;
    831    1.1   hpeyerl 		ci = &cs->sc_cinfo[ccdisk];
    832    1.1   hpeyerl 	}
    833   1.11   thorpej 
    834    1.1   hpeyerl 	/*
    835    1.1   hpeyerl 	 * Fill in the component buf structure.
    836    1.1   hpeyerl 	 */
    837   1.63   thorpej 	cbp = CCD_GETBUF();
    838   1.55   thorpej 	if (cbp == NULL)
    839   1.55   thorpej 		return (NULL);
    840  1.126        ad 	buf_init(&cbp->cb_buf);
    841  1.126        ad 	cbp->cb_buf.b_flags = bp->b_flags;
    842  1.126        ad 	cbp->cb_buf.b_oflags = bp->b_oflags;
    843  1.126        ad 	cbp->cb_buf.b_cflags = bp->b_cflags;
    844   1.29  christos 	cbp->cb_buf.b_iodone = ccdiodone;
    845    1.6       cgd 	cbp->cb_buf.b_proc = bp->b_proc;
    846   1.95   hannken 	cbp->cb_buf.b_dev = ci->ci_dev;
    847    1.6       cgd 	cbp->cb_buf.b_blkno = cbn + cboff;
    848    1.6       cgd 	cbp->cb_buf.b_data = addr;
    849   1.11   thorpej 	cbp->cb_buf.b_vp = ci->ci_vp;
    850  1.127   hannken 	cbp->cb_buf.b_objlock = &ci->ci_vp->v_interlock;
    851    1.1   hpeyerl 	if (cs->sc_ileave == 0)
    852   1.50   thorpej 		cbc = dbtob((u_int64_t)(ci->ci_size - cbn));
    853    1.1   hpeyerl 	else
    854   1.50   thorpej 		cbc = dbtob((u_int64_t)(cs->sc_ileave - cboff));
    855   1.50   thorpej 	cbp->cb_buf.b_bcount = cbc < bcount ? cbc : bcount;
    856    1.6       cgd 
    857    1.1   hpeyerl 	/*
    858    1.6       cgd 	 * context for ccdiodone
    859    1.1   hpeyerl 	 */
    860    1.6       cgd 	cbp->cb_obp = bp;
    861   1.59   thorpej 	cbp->cb_sc = cs;
    862   1.36   thorpej 	cbp->cb_comp = ccdisk;
    863    1.6       cgd 
    864   1.94      yamt 	BIO_COPYPRIO(&cbp->cb_buf, bp);
    865   1.94      yamt 
    866    1.1   hpeyerl #ifdef DEBUG
    867    1.3   hpeyerl 	if (ccddebug & CCDB_IO)
    868   1.81    kleink 		printf(" dev 0x%x(u%lu): cbp %p bn %" PRId64 " addr %p"
    869   1.99      yamt 		       " bcnt %d\n",
    870   1.62    mjacob 		    ci->ci_dev, (unsigned long) (ci-cs->sc_cinfo), cbp,
    871   1.62    mjacob 		    cbp->cb_buf.b_blkno, cbp->cb_buf.b_data,
    872   1.62    mjacob 		    cbp->cb_buf.b_bcount);
    873    1.1   hpeyerl #endif
    874   1.55   thorpej 
    875   1.55   thorpej 	return (cbp);
    876    1.1   hpeyerl }
    877    1.1   hpeyerl 
    878   1.11   thorpej static void
    879   1.97   thorpej ccdintr(struct ccd_softc *cs, struct buf *bp)
    880    1.1   hpeyerl {
    881    1.1   hpeyerl 
    882    1.1   hpeyerl #ifdef DEBUG
    883    1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    884   1.35  christos 		printf("ccdintr(%p, %p)\n", cs, bp);
    885    1.1   hpeyerl #endif
    886    1.1   hpeyerl 	/*
    887    1.1   hpeyerl 	 * Request is done for better or worse, wakeup the top half.
    888    1.1   hpeyerl 	 */
    889  1.122        ad 	if (bp->b_error != 0)
    890    1.1   hpeyerl 		bp->b_resid = bp->b_bcount;
    891   1.80       mrg 	disk_unbusy(&cs->sc_dkdev, (bp->b_bcount - bp->b_resid),
    892   1.80       mrg 	    (bp->b_flags & B_READ));
    893    1.1   hpeyerl 	biodone(bp);
    894    1.1   hpeyerl }
    895    1.1   hpeyerl 
    896    1.1   hpeyerl /*
    897   1.11   thorpej  * Called at interrupt time.
    898    1.1   hpeyerl  * Mark the component as done and if all components are done,
    899    1.1   hpeyerl  * take a ccd interrupt.
    900    1.1   hpeyerl  */
    901   1.97   thorpej static void
    902   1.97   thorpej ccdiodone(struct buf *vbp)
    903    1.1   hpeyerl {
    904   1.29  christos 	struct ccdbuf *cbp = (struct ccdbuf *) vbp;
    905   1.59   thorpej 	struct buf *bp = cbp->cb_obp;
    906   1.59   thorpej 	struct ccd_softc *cs = cbp->cb_sc;
    907   1.53   thorpej 	int count, s;
    908    1.1   hpeyerl 
    909    1.1   hpeyerl 	s = splbio();
    910    1.1   hpeyerl #ifdef DEBUG
    911    1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    912   1.35  christos 		printf("ccdiodone(%p)\n", cbp);
    913    1.3   hpeyerl 	if (ccddebug & CCDB_IO) {
    914   1.99      yamt 		printf("ccdiodone: bp %p bcount %d resid %d\n",
    915   1.53   thorpej 		       bp, bp->b_bcount, bp->b_resid);
    916   1.81    kleink 		printf(" dev 0x%x(u%d), cbp %p bn %" PRId64 " addr %p"
    917   1.99      yamt 		       " bcnt %d\n",
    918    1.6       cgd 		       cbp->cb_buf.b_dev, cbp->cb_comp, cbp,
    919    1.6       cgd 		       cbp->cb_buf.b_blkno, cbp->cb_buf.b_data,
    920    1.6       cgd 		       cbp->cb_buf.b_bcount);
    921    1.1   hpeyerl 	}
    922    1.1   hpeyerl #endif
    923    1.1   hpeyerl 
    924  1.122        ad 	if (cbp->cb_buf.b_error != 0) {
    925  1.122        ad 		bp->b_error = cbp->cb_buf.b_error;
    926   1.53   thorpej 		printf("%s: error %d on component %d\n",
    927   1.53   thorpej 		       cs->sc_xname, bp->b_error, cbp->cb_comp);
    928    1.1   hpeyerl 	}
    929    1.6       cgd 	count = cbp->cb_buf.b_bcount;
    930  1.126        ad 	buf_destroy(&cbp->cb_buf);
    931   1.63   thorpej 	CCD_PUTBUF(cbp);
    932    1.1   hpeyerl 
    933    1.1   hpeyerl 	/*
    934    1.1   hpeyerl 	 * If all done, "interrupt".
    935   1.53   thorpej 	 */
    936   1.53   thorpej 	bp->b_resid -= count;
    937   1.53   thorpej 	if (bp->b_resid < 0)
    938   1.53   thorpej 		panic("ccdiodone: count");
    939   1.53   thorpej 	if (bp->b_resid == 0)
    940   1.59   thorpej 		ccdintr(cs, bp);
    941    1.1   hpeyerl 	splx(s);
    942    1.1   hpeyerl }
    943    1.1   hpeyerl 
    944   1.11   thorpej /* ARGSUSED */
    945   1.97   thorpej static int
    946  1.116  christos ccdread(dev_t dev, struct uio *uio, int flags)
    947    1.3   hpeyerl {
    948   1.11   thorpej 	int unit = ccdunit(dev);
    949   1.11   thorpej 	struct ccd_softc *cs;
    950    1.3   hpeyerl 
    951    1.3   hpeyerl #ifdef DEBUG
    952    1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    953   1.43      fair 		printf("ccdread(0x%x, %p)\n", dev, uio);
    954    1.3   hpeyerl #endif
    955   1.11   thorpej 	if (unit >= numccd)
    956   1.11   thorpej 		return (ENXIO);
    957   1.11   thorpej 	cs = &ccd_softc[unit];
    958   1.11   thorpej 
    959   1.11   thorpej 	if ((cs->sc_flags & CCDF_INITED) == 0)
    960   1.11   thorpej 		return (ENXIO);
    961   1.11   thorpej 
    962   1.10   mycroft 	return (physio(ccdstrategy, NULL, dev, B_READ, minphys, uio));
    963    1.3   hpeyerl }
    964    1.3   hpeyerl 
    965   1.11   thorpej /* ARGSUSED */
    966   1.97   thorpej static int
    967  1.116  christos ccdwrite(dev_t dev, struct uio *uio, int flags)
    968    1.3   hpeyerl {
    969   1.11   thorpej 	int unit = ccdunit(dev);
    970   1.11   thorpej 	struct ccd_softc *cs;
    971    1.3   hpeyerl 
    972    1.3   hpeyerl #ifdef DEBUG
    973    1.3   hpeyerl 	if (ccddebug & CCDB_FOLLOW)
    974   1.43      fair 		printf("ccdwrite(0x%x, %p)\n", dev, uio);
    975    1.3   hpeyerl #endif
    976   1.11   thorpej 	if (unit >= numccd)
    977   1.11   thorpej 		return (ENXIO);
    978   1.11   thorpej 	cs = &ccd_softc[unit];
    979   1.11   thorpej 
    980   1.11   thorpej 	if ((cs->sc_flags & CCDF_INITED) == 0)
    981   1.11   thorpej 		return (ENXIO);
    982   1.11   thorpej 
    983   1.10   mycroft 	return (physio(ccdstrategy, NULL, dev, B_WRITE, minphys, uio));
    984    1.3   hpeyerl }
    985    1.3   hpeyerl 
    986   1.97   thorpej static int
    987  1.118  christos ccdioctl(dev_t dev, u_long cmd, void *data, int flag, struct lwp *l)
    988    1.1   hpeyerl {
    989   1.11   thorpej 	int unit = ccdunit(dev);
    990  1.117        ad 	int s, i, j, lookedup = 0, error = 0;
    991   1.39   mycroft 	int part, pmask;
    992   1.11   thorpej 	struct ccd_softc *cs;
    993   1.11   thorpej 	struct ccd_ioctl *ccio = (struct ccd_ioctl *)data;
    994  1.110      elad 	kauth_cred_t uc;
    995   1.11   thorpej 	char **cpp;
    996   1.11   thorpej 	struct vnode **vpp;
    997   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
    998   1.70      fvdl 	struct disklabel newlabel;
    999   1.70      fvdl #endif
   1000   1.11   thorpej 
   1001   1.11   thorpej 	if (unit >= numccd)
   1002   1.11   thorpej 		return (ENXIO);
   1003   1.11   thorpej 	cs = &ccd_softc[unit];
   1004   1.11   thorpej 
   1005  1.112        ad 	uc = (l != NULL) ? l->l_cred : NOCRED;
   1006  1.109       jld 
   1007   1.41   thorpej 	/* Must be open for writes for these commands... */
   1008   1.41   thorpej 	switch (cmd) {
   1009   1.41   thorpej 	case CCDIOCSET:
   1010   1.41   thorpej 	case CCDIOCCLR:
   1011   1.41   thorpej 	case DIOCSDINFO:
   1012   1.41   thorpej 	case DIOCWDINFO:
   1013   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1014   1.70      fvdl 	case ODIOCSDINFO:
   1015   1.70      fvdl 	case ODIOCWDINFO:
   1016   1.70      fvdl #endif
   1017   1.87   thorpej 	case DIOCKLABEL:
   1018   1.41   thorpej 	case DIOCWLABEL:
   1019   1.41   thorpej 		if ((flag & FWRITE) == 0)
   1020   1.41   thorpej 			return (EBADF);
   1021   1.41   thorpej 	}
   1022   1.41   thorpej 
   1023  1.117        ad 	mutex_enter(&cs->sc_lock);
   1024   1.57   thorpej 
   1025   1.41   thorpej 	/* Must be initialized for these... */
   1026   1.41   thorpej 	switch (cmd) {
   1027   1.41   thorpej 	case CCDIOCCLR:
   1028   1.42    kleink 	case DIOCGDINFO:
   1029  1.100   thorpej 	case DIOCCACHESYNC:
   1030   1.42    kleink 	case DIOCSDINFO:
   1031   1.42    kleink 	case DIOCWDINFO:
   1032   1.42    kleink 	case DIOCGPART:
   1033   1.41   thorpej 	case DIOCWLABEL:
   1034   1.87   thorpej 	case DIOCKLABEL:
   1035   1.44   thorpej 	case DIOCGDEFLABEL:
   1036   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1037   1.70      fvdl 	case ODIOCGDINFO:
   1038   1.70      fvdl 	case ODIOCSDINFO:
   1039   1.70      fvdl 	case ODIOCWDINFO:
   1040   1.70      fvdl 	case ODIOCGDEFLABEL:
   1041   1.70      fvdl #endif
   1042   1.57   thorpej 		if ((cs->sc_flags & CCDF_INITED) == 0) {
   1043   1.57   thorpej 			error = ENXIO;
   1044   1.57   thorpej 			goto out;
   1045   1.57   thorpej 		}
   1046   1.41   thorpej 	}
   1047   1.41   thorpej 
   1048   1.11   thorpej 	switch (cmd) {
   1049   1.11   thorpej 	case CCDIOCSET:
   1050   1.57   thorpej 		if (cs->sc_flags & CCDF_INITED) {
   1051   1.57   thorpej 			error = EBUSY;
   1052   1.57   thorpej 			goto out;
   1053   1.57   thorpej 		}
   1054   1.54   thorpej 
   1055   1.54   thorpej 		/* Validate the flags. */
   1056   1.57   thorpej 		if ((ccio->ccio_flags & CCDF_USERMASK) != ccio->ccio_flags) {
   1057   1.57   thorpej 			error = EINVAL;
   1058   1.57   thorpej 			goto out;
   1059   1.57   thorpej 		}
   1060   1.15   thorpej 
   1061   1.73  jdolecek 		if (ccio->ccio_ndisks > CCD_MAXNDISKS) {
   1062   1.73  jdolecek 			error = EINVAL;
   1063   1.73  jdolecek 			goto out;
   1064   1.73  jdolecek 		}
   1065  1.102     perry 
   1066   1.11   thorpej 		/* Fill in some important bits. */
   1067   1.57   thorpej 		cs->sc_ileave = ccio->ccio_ileave;
   1068   1.57   thorpej 		cs->sc_nccdisks = ccio->ccio_ndisks;
   1069   1.57   thorpej 		cs->sc_flags = ccio->ccio_flags & CCDF_USERMASK;
   1070   1.11   thorpej 
   1071   1.11   thorpej 		/*
   1072   1.11   thorpej 		 * Allocate space for and copy in the array of
   1073   1.11   thorpej 		 * componet pathnames and device numbers.
   1074   1.11   thorpej 		 */
   1075   1.11   thorpej 		cpp = malloc(ccio->ccio_ndisks * sizeof(char *),
   1076   1.11   thorpej 		    M_DEVBUF, M_WAITOK);
   1077   1.11   thorpej 		vpp = malloc(ccio->ccio_ndisks * sizeof(struct vnode *),
   1078   1.11   thorpej 		    M_DEVBUF, M_WAITOK);
   1079   1.11   thorpej 
   1080   1.84       dsl 		error = copyin(ccio->ccio_disks, cpp,
   1081   1.11   thorpej 		    ccio->ccio_ndisks * sizeof(char **));
   1082   1.11   thorpej 		if (error) {
   1083   1.11   thorpej 			free(vpp, M_DEVBUF);
   1084   1.11   thorpej 			free(cpp, M_DEVBUF);
   1085   1.57   thorpej 			goto out;
   1086   1.11   thorpej 		}
   1087   1.11   thorpej 
   1088   1.11   thorpej #ifdef DEBUG
   1089   1.11   thorpej 		if (ccddebug & CCDB_INIT)
   1090   1.11   thorpej 			for (i = 0; i < ccio->ccio_ndisks; ++i)
   1091  1.104  christos 				printf("ccdioctl: component %d: %p\n",
   1092   1.11   thorpej 				    i, cpp[i]);
   1093   1.11   thorpej #endif
   1094   1.11   thorpej 
   1095   1.11   thorpej 		for (i = 0; i < ccio->ccio_ndisks; ++i) {
   1096   1.11   thorpej #ifdef DEBUG
   1097   1.11   thorpej 			if (ccddebug & CCDB_INIT)
   1098   1.35  christos 				printf("ccdioctl: lookedup = %d\n", lookedup);
   1099   1.11   thorpej #endif
   1100  1.120      cube 			if ((error = dk_lookup(cpp[i], l, &vpp[i],
   1101  1.120      cube 			    UIO_USERSPACE)) != 0) {
   1102   1.11   thorpej 				for (j = 0; j < lookedup; ++j)
   1103   1.12   thorpej 					(void)vn_close(vpp[j], FREAD|FWRITE,
   1104  1.128        ad 					    uc);
   1105   1.11   thorpej 				free(vpp, M_DEVBUF);
   1106   1.11   thorpej 				free(cpp, M_DEVBUF);
   1107   1.57   thorpej 				goto out;
   1108   1.11   thorpej 			}
   1109   1.11   thorpej 			++lookedup;
   1110   1.11   thorpej 		}
   1111   1.11   thorpej 
   1112   1.11   thorpej 		/*
   1113   1.11   thorpej 		 * Initialize the ccd.  Fills in the softc for us.
   1114   1.11   thorpej 		 */
   1115  1.107  christos 		if ((error = ccdinit(cs, cpp, vpp, l)) != 0) {
   1116   1.11   thorpej 			for (j = 0; j < lookedup; ++j)
   1117   1.18   thorpej 				(void)vn_close(vpp[j], FREAD|FWRITE,
   1118  1.128        ad 				    uc);
   1119   1.11   thorpej 			free(vpp, M_DEVBUF);
   1120   1.11   thorpej 			free(cpp, M_DEVBUF);
   1121   1.57   thorpej 			goto out;
   1122   1.11   thorpej 		}
   1123   1.11   thorpej 
   1124   1.57   thorpej 		/* We can free the temporary variables now. */
   1125   1.57   thorpej 		free(vpp, M_DEVBUF);
   1126   1.57   thorpej 		free(cpp, M_DEVBUF);
   1127   1.57   thorpej 
   1128   1.11   thorpej 		/*
   1129   1.11   thorpej 		 * The ccd has been successfully initialized, so
   1130   1.23   thorpej 		 * we can place it into the array.  Don't try to
   1131   1.23   thorpej 		 * read the disklabel until the disk has been attached,
   1132   1.23   thorpej 		 * because space for the disklabel is allocated
   1133   1.23   thorpej 		 * in disk_attach();
   1134   1.11   thorpej 		 */
   1135   1.11   thorpej 		ccio->ccio_unit = unit;
   1136   1.11   thorpej 		ccio->ccio_size = cs->sc_size;
   1137   1.23   thorpej 
   1138  1.106      yamt 		bufq_alloc(&cs->sc_bufq, "fcfs", 0);
   1139   1.88   thorpej 
   1140   1.23   thorpej 		/* Attach the disk. */
   1141  1.123        ad 		disk_attach(&cs->sc_dkdev);
   1142   1.23   thorpej 
   1143   1.23   thorpej 		/* Try and read the disklabel. */
   1144   1.11   thorpej 		ccdgetdisklabel(dev);
   1145   1.11   thorpej 		break;
   1146   1.11   thorpej 
   1147   1.11   thorpej 	case CCDIOCCLR:
   1148   1.11   thorpej 		/*
   1149   1.11   thorpej 		 * Don't unconfigure if any other partitions are open
   1150   1.11   thorpej 		 * or if both the character and block flavors of this
   1151   1.11   thorpej 		 * partition are open.
   1152   1.11   thorpej 		 */
   1153   1.11   thorpej 		part = DISKPART(dev);
   1154   1.11   thorpej 		pmask = (1 << part);
   1155   1.11   thorpej 		if ((cs->sc_dkdev.dk_openmask & ~pmask) ||
   1156   1.11   thorpej 		    ((cs->sc_dkdev.dk_bopenmask & pmask) &&
   1157   1.15   thorpej 		    (cs->sc_dkdev.dk_copenmask & pmask))) {
   1158   1.57   thorpej 			error = EBUSY;
   1159   1.57   thorpej 			goto out;
   1160   1.15   thorpej 		}
   1161   1.88   thorpej 
   1162   1.88   thorpej 		/* Kill off any queued buffers. */
   1163   1.88   thorpej 		s = splbio();
   1164  1.106      yamt 		bufq_drain(cs->sc_bufq);
   1165   1.88   thorpej 		splx(s);
   1166   1.88   thorpej 
   1167  1.106      yamt 		bufq_free(cs->sc_bufq);
   1168   1.11   thorpej 
   1169   1.11   thorpej 		/*
   1170   1.11   thorpej 		 * Free ccd_softc information and clear entry.
   1171   1.11   thorpej 		 */
   1172   1.22   thorpej 
   1173   1.22   thorpej 		/* Close the components and free their pathnames. */
   1174   1.11   thorpej 		for (i = 0; i < cs->sc_nccdisks; ++i) {
   1175   1.11   thorpej 			/*
   1176   1.11   thorpej 			 * XXX: this close could potentially fail and
   1177   1.11   thorpej 			 * cause Bad Things.  Maybe we need to force
   1178   1.11   thorpej 			 * the close to happen?
   1179   1.11   thorpej 			 */
   1180   1.11   thorpej #ifdef DEBUG
   1181   1.11   thorpej 			if (ccddebug & CCDB_VNODE)
   1182   1.11   thorpej 				vprint("CCDIOCCLR: vnode info",
   1183   1.11   thorpej 				    cs->sc_cinfo[i].ci_vp);
   1184   1.11   thorpej #endif
   1185   1.11   thorpej 			(void)vn_close(cs->sc_cinfo[i].ci_vp, FREAD|FWRITE,
   1186  1.128        ad 			    uc);
   1187   1.11   thorpej 			free(cs->sc_cinfo[i].ci_path, M_DEVBUF);
   1188   1.38   thorpej 		}
   1189   1.38   thorpej 
   1190   1.22   thorpej 		/* Free interleave index. */
   1191   1.22   thorpej 		for (i = 0; cs->sc_itable[i].ii_ndisk; ++i)
   1192   1.19   thorpej 			free(cs->sc_itable[i].ii_index, M_DEVBUF);
   1193   1.22   thorpej 
   1194   1.22   thorpej 		/* Free component info and interleave table. */
   1195   1.11   thorpej 		free(cs->sc_cinfo, M_DEVBUF);
   1196   1.11   thorpej 		free(cs->sc_itable, M_DEVBUF);
   1197   1.87   thorpej 		cs->sc_flags &= ~(CCDF_INITED|CCDF_VLABEL);
   1198   1.15   thorpej 
   1199   1.23   thorpej 		/* Detatch the disk. */
   1200  1.123        ad 		disk_detach(&cs->sc_dkdev);
   1201   1.11   thorpej 		break;
   1202   1.11   thorpej 
   1203   1.11   thorpej 	case DIOCGDINFO:
   1204   1.23   thorpej 		*(struct disklabel *)data = *(cs->sc_dkdev.dk_label);
   1205   1.11   thorpej 		break;
   1206   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1207   1.70      fvdl 	case ODIOCGDINFO:
   1208   1.70      fvdl 		newlabel = *(cs->sc_dkdev.dk_label);
   1209   1.70      fvdl 		if (newlabel.d_npartitions > OLDMAXPARTITIONS)
   1210   1.71      fvdl 			return ENOTTY;
   1211   1.70      fvdl 		memcpy(data, &newlabel, sizeof (struct olddisklabel));
   1212   1.70      fvdl 		break;
   1213   1.70      fvdl #endif
   1214   1.11   thorpej 
   1215   1.11   thorpej 	case DIOCGPART:
   1216   1.23   thorpej 		((struct partinfo *)data)->disklab = cs->sc_dkdev.dk_label;
   1217   1.11   thorpej 		((struct partinfo *)data)->part =
   1218   1.23   thorpej 		    &cs->sc_dkdev.dk_label->d_partitions[DISKPART(dev)];
   1219   1.11   thorpej 		break;
   1220   1.11   thorpej 
   1221  1.100   thorpej 	case DIOCCACHESYNC:
   1222  1.100   thorpej 		/*
   1223  1.100   thorpej 		 * XXX Do we really need to care about having a writable
   1224  1.100   thorpej 		 * file descriptor here?
   1225  1.100   thorpej 		 */
   1226  1.100   thorpej 		if ((flag & FWRITE) == 0)
   1227  1.100   thorpej 			return (EBADF);
   1228  1.100   thorpej 
   1229  1.100   thorpej 		/*
   1230  1.100   thorpej 		 * We pass this call down to all components and report
   1231  1.100   thorpej 		 * the first error we encounter.
   1232  1.100   thorpej 		 */
   1233  1.100   thorpej 		for (error = 0, i = 0; i < cs->sc_nccdisks; i++) {
   1234  1.100   thorpej 			j = VOP_IOCTL(cs->sc_cinfo[i].ci_vp, cmd, data,
   1235  1.124     pooka 				      flag, uc);
   1236  1.100   thorpej 			if (j != 0 && error == 0)
   1237  1.100   thorpej 				error = j;
   1238  1.100   thorpej 		}
   1239  1.100   thorpej 		break;
   1240  1.100   thorpej 
   1241   1.11   thorpej 	case DIOCWDINFO:
   1242   1.11   thorpej 	case DIOCSDINFO:
   1243   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1244   1.70      fvdl 	case ODIOCWDINFO:
   1245   1.70      fvdl 	case ODIOCSDINFO:
   1246   1.70      fvdl #endif
   1247   1.70      fvdl 	{
   1248   1.70      fvdl 		struct disklabel *lp;
   1249   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1250   1.70      fvdl 		if (cmd == ODIOCSDINFO || cmd == ODIOCWDINFO) {
   1251   1.70      fvdl 			memset(&newlabel, 0, sizeof newlabel);
   1252   1.70      fvdl 			memcpy(&newlabel, data, sizeof (struct olddisklabel));
   1253   1.70      fvdl 			lp = &newlabel;
   1254   1.70      fvdl 		} else
   1255   1.70      fvdl #endif
   1256   1.70      fvdl 		lp = (struct disklabel *)data;
   1257   1.70      fvdl 
   1258   1.11   thorpej 		cs->sc_flags |= CCDF_LABELLING;
   1259   1.11   thorpej 
   1260   1.23   thorpej 		error = setdisklabel(cs->sc_dkdev.dk_label,
   1261   1.70      fvdl 		    lp, 0, cs->sc_dkdev.dk_cpulabel);
   1262   1.11   thorpej 		if (error == 0) {
   1263   1.70      fvdl 			if (cmd == DIOCWDINFO
   1264   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1265   1.70      fvdl 			    || cmd == ODIOCWDINFO
   1266   1.70      fvdl #endif
   1267   1.70      fvdl 			   )
   1268   1.11   thorpej 				error = writedisklabel(CCDLABELDEV(dev),
   1269   1.23   thorpej 				    ccdstrategy, cs->sc_dkdev.dk_label,
   1270   1.23   thorpej 				    cs->sc_dkdev.dk_cpulabel);
   1271   1.11   thorpej 		}
   1272   1.11   thorpej 
   1273   1.11   thorpej 		cs->sc_flags &= ~CCDF_LABELLING;
   1274   1.11   thorpej 		break;
   1275   1.70      fvdl 	}
   1276   1.11   thorpej 
   1277   1.87   thorpej 	case DIOCKLABEL:
   1278   1.87   thorpej 		if (*(int *)data != 0)
   1279   1.87   thorpej 			cs->sc_flags |= CCDF_KLABEL;
   1280   1.87   thorpej 		else
   1281   1.87   thorpej 			cs->sc_flags &= ~CCDF_KLABEL;
   1282   1.87   thorpej 		break;
   1283   1.87   thorpej 
   1284   1.11   thorpej 	case DIOCWLABEL:
   1285   1.11   thorpej 		if (*(int *)data != 0)
   1286   1.11   thorpej 			cs->sc_flags |= CCDF_WLABEL;
   1287   1.11   thorpej 		else
   1288   1.11   thorpej 			cs->sc_flags &= ~CCDF_WLABEL;
   1289   1.11   thorpej 		break;
   1290   1.11   thorpej 
   1291   1.44   thorpej 	case DIOCGDEFLABEL:
   1292   1.44   thorpej 		ccdgetdefaultlabel(cs, (struct disklabel *)data);
   1293   1.44   thorpej 		break;
   1294   1.70      fvdl 
   1295   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1296   1.70      fvdl 	case ODIOCGDEFLABEL:
   1297   1.70      fvdl 		ccdgetdefaultlabel(cs, &newlabel);
   1298   1.70      fvdl 		if (newlabel.d_npartitions > OLDMAXPARTITIONS)
   1299   1.71      fvdl 			return ENOTTY;
   1300   1.70      fvdl 		memcpy(data, &newlabel, sizeof (struct olddisklabel));
   1301   1.70      fvdl 		break;
   1302   1.70      fvdl #endif
   1303   1.44   thorpej 
   1304   1.11   thorpej 	default:
   1305   1.57   thorpej 		error = ENOTTY;
   1306   1.11   thorpej 	}
   1307   1.11   thorpej 
   1308   1.57   thorpej  out:
   1309  1.117        ad 	mutex_exit(&cs->sc_lock);
   1310   1.57   thorpej 	return (error);
   1311    1.1   hpeyerl }
   1312    1.1   hpeyerl 
   1313   1.97   thorpej static int
   1314   1.97   thorpej ccdsize(dev_t dev)
   1315    1.1   hpeyerl {
   1316   1.11   thorpej 	struct ccd_softc *cs;
   1317   1.40   thorpej 	struct disklabel *lp;
   1318   1.40   thorpej 	int part, unit, omask, size;
   1319   1.40   thorpej 
   1320   1.40   thorpej 	unit = ccdunit(dev);
   1321   1.40   thorpej 	if (unit >= numccd)
   1322   1.40   thorpej 		return (-1);
   1323   1.40   thorpej 	cs = &ccd_softc[unit];
   1324   1.11   thorpej 
   1325   1.40   thorpej 	if ((cs->sc_flags & CCDF_INITED) == 0)
   1326   1.11   thorpej 		return (-1);
   1327   1.11   thorpej 
   1328   1.11   thorpej 	part = DISKPART(dev);
   1329   1.40   thorpej 	omask = cs->sc_dkdev.dk_openmask & (1 << part);
   1330   1.40   thorpej 	lp = cs->sc_dkdev.dk_label;
   1331   1.11   thorpej 
   1332  1.107  christos 	if (omask == 0 && ccdopen(dev, 0, S_IFBLK, curlwp))
   1333   1.11   thorpej 		return (-1);
   1334   1.11   thorpej 
   1335   1.40   thorpej 	if (lp->d_partitions[part].p_fstype != FS_SWAP)
   1336   1.11   thorpej 		size = -1;
   1337   1.11   thorpej 	else
   1338   1.40   thorpej 		size = lp->d_partitions[part].p_size *
   1339   1.40   thorpej 		    (lp->d_secsize / DEV_BSIZE);
   1340   1.11   thorpej 
   1341  1.107  christos 	if (omask == 0 && ccdclose(dev, 0, S_IFBLK, curlwp))
   1342   1.11   thorpej 		return (-1);
   1343    1.1   hpeyerl 
   1344   1.11   thorpej 	return (size);
   1345    1.1   hpeyerl }
   1346    1.1   hpeyerl 
   1347   1.97   thorpej static int
   1348  1.118  christos ccddump(dev_t dev, daddr_t blkno, void *va,
   1349  1.116  christos     size_t size)
   1350    1.1   hpeyerl {
   1351    1.9       cgd 
   1352    1.9       cgd 	/* Not implemented. */
   1353    1.9       cgd 	return ENXIO;
   1354   1.11   thorpej }
   1355   1.11   thorpej 
   1356   1.11   thorpej static void
   1357   1.97   thorpej ccdgetdefaultlabel(struct ccd_softc *cs, struct disklabel *lp)
   1358   1.11   thorpej {
   1359   1.11   thorpej 	struct ccdgeom *ccg = &cs->sc_geom;
   1360   1.11   thorpej 
   1361   1.72   thorpej 	memset(lp, 0, sizeof(*lp));
   1362   1.11   thorpej 
   1363   1.11   thorpej 	lp->d_secperunit = cs->sc_size;
   1364   1.11   thorpej 	lp->d_secsize = ccg->ccg_secsize;
   1365   1.11   thorpej 	lp->d_nsectors = ccg->ccg_nsectors;
   1366   1.11   thorpej 	lp->d_ntracks = ccg->ccg_ntracks;
   1367   1.11   thorpej 	lp->d_ncylinders = ccg->ccg_ncylinders;
   1368   1.19   thorpej 	lp->d_secpercyl = lp->d_ntracks * lp->d_nsectors;
   1369   1.11   thorpej 
   1370   1.11   thorpej 	strncpy(lp->d_typename, "ccd", sizeof(lp->d_typename));
   1371   1.11   thorpej 	lp->d_type = DTYPE_CCD;
   1372   1.11   thorpej 	strncpy(lp->d_packname, "fictitious", sizeof(lp->d_packname));
   1373   1.11   thorpej 	lp->d_rpm = 3600;
   1374   1.11   thorpej 	lp->d_interleave = 1;
   1375   1.11   thorpej 	lp->d_flags = 0;
   1376   1.11   thorpej 
   1377   1.11   thorpej 	lp->d_partitions[RAW_PART].p_offset = 0;
   1378   1.11   thorpej 	lp->d_partitions[RAW_PART].p_size = cs->sc_size;
   1379   1.11   thorpej 	lp->d_partitions[RAW_PART].p_fstype = FS_UNUSED;
   1380   1.11   thorpej 	lp->d_npartitions = RAW_PART + 1;
   1381   1.11   thorpej 
   1382   1.11   thorpej 	lp->d_magic = DISKMAGIC;
   1383   1.11   thorpej 	lp->d_magic2 = DISKMAGIC;
   1384   1.23   thorpej 	lp->d_checksum = dkcksum(cs->sc_dkdev.dk_label);
   1385   1.44   thorpej }
   1386   1.44   thorpej 
   1387   1.44   thorpej /*
   1388   1.44   thorpej  * Read the disklabel from the ccd.  If one is not present, fake one
   1389   1.44   thorpej  * up.
   1390   1.44   thorpej  */
   1391   1.44   thorpej static void
   1392   1.97   thorpej ccdgetdisklabel(dev_t dev)
   1393   1.44   thorpej {
   1394   1.44   thorpej 	int unit = ccdunit(dev);
   1395   1.44   thorpej 	struct ccd_softc *cs = &ccd_softc[unit];
   1396   1.85       dsl 	const char *errstring;
   1397   1.44   thorpej 	struct disklabel *lp = cs->sc_dkdev.dk_label;
   1398   1.44   thorpej 	struct cpu_disklabel *clp = cs->sc_dkdev.dk_cpulabel;
   1399   1.44   thorpej 
   1400   1.72   thorpej 	memset(clp, 0, sizeof(*clp));
   1401   1.44   thorpej 
   1402   1.44   thorpej 	ccdgetdefaultlabel(cs, lp);
   1403   1.11   thorpej 
   1404   1.11   thorpej 	/*
   1405   1.11   thorpej 	 * Call the generic disklabel extraction routine.
   1406   1.11   thorpej 	 */
   1407   1.92     lukem 	if ((cs->sc_flags & CCDF_NOLABEL) != 0)
   1408   1.92     lukem 		errstring = "CCDF_NOLABEL set; ignoring on-disk label";
   1409   1.92     lukem 	else
   1410   1.92     lukem 		errstring = readdisklabel(CCDLABELDEV(dev), ccdstrategy,
   1411   1.92     lukem 		    cs->sc_dkdev.dk_label, cs->sc_dkdev.dk_cpulabel);
   1412   1.29  christos 	if (errstring)
   1413   1.11   thorpej 		ccdmakedisklabel(cs);
   1414   1.47     enami 	else {
   1415   1.47     enami 		int i;
   1416   1.47     enami 		struct partition *pp;
   1417   1.47     enami 
   1418   1.47     enami 		/*
   1419   1.47     enami 		 * Sanity check whether the found disklabel is valid.
   1420   1.47     enami 		 *
   1421   1.47     enami 		 * This is necessary since total size of ccd may vary
   1422   1.47     enami 		 * when an interleave is changed even though exactly
   1423   1.47     enami 		 * same componets are used, and old disklabel may used
   1424   1.47     enami 		 * if that is found.
   1425   1.47     enami 		 */
   1426   1.47     enami 		if (lp->d_secperunit != cs->sc_size)
   1427   1.47     enami 			printf("WARNING: %s: "
   1428   1.47     enami 			    "total sector size in disklabel (%d) != "
   1429   1.60   thorpej 			    "the size of ccd (%lu)\n", cs->sc_xname,
   1430   1.60   thorpej 			    lp->d_secperunit, (u_long)cs->sc_size);
   1431   1.47     enami 		for (i = 0; i < lp->d_npartitions; i++) {
   1432   1.47     enami 			pp = &lp->d_partitions[i];
   1433   1.47     enami 			if (pp->p_offset + pp->p_size > cs->sc_size)
   1434   1.48     enami 				printf("WARNING: %s: end of partition `%c' "
   1435   1.60   thorpej 				    "exceeds the size of ccd (%lu)\n",
   1436   1.60   thorpej 				    cs->sc_xname, 'a' + i, (u_long)cs->sc_size);
   1437   1.47     enami 		}
   1438   1.47     enami 	}
   1439   1.11   thorpej 
   1440   1.11   thorpej #ifdef DEBUG
   1441   1.11   thorpej 	/* It's actually extremely common to have unlabeled ccds. */
   1442   1.11   thorpej 	if (ccddebug & CCDB_LABEL)
   1443   1.11   thorpej 		if (errstring != NULL)
   1444   1.35  christos 			printf("%s: %s\n", cs->sc_xname, errstring);
   1445   1.11   thorpej #endif
   1446   1.87   thorpej 
   1447   1.87   thorpej 	/* In-core label now valid. */
   1448   1.87   thorpej 	cs->sc_flags |= CCDF_VLABEL;
   1449   1.11   thorpej }
   1450   1.11   thorpej 
   1451   1.11   thorpej /*
   1452   1.11   thorpej  * Take care of things one might want to take care of in the event
   1453   1.11   thorpej  * that a disklabel isn't present.
   1454   1.11   thorpej  */
   1455   1.11   thorpej static void
   1456   1.97   thorpej ccdmakedisklabel(struct ccd_softc *cs)
   1457   1.11   thorpej {
   1458   1.23   thorpej 	struct disklabel *lp = cs->sc_dkdev.dk_label;
   1459   1.11   thorpej 
   1460   1.11   thorpej 	/*
   1461   1.11   thorpej 	 * For historical reasons, if there's no disklabel present
   1462   1.11   thorpej 	 * the raw partition must be marked FS_BSDFFS.
   1463   1.11   thorpej 	 */
   1464   1.11   thorpej 	lp->d_partitions[RAW_PART].p_fstype = FS_BSDFFS;
   1465   1.11   thorpej 
   1466   1.11   thorpej 	strncpy(lp->d_packname, "default label", sizeof(lp->d_packname));
   1467   1.44   thorpej 
   1468   1.44   thorpej 	lp->d_checksum = dkcksum(lp);
   1469   1.11   thorpej }
   1470   1.11   thorpej 
   1471   1.11   thorpej #ifdef DEBUG
   1472   1.11   thorpej static void
   1473   1.97   thorpej printiinfo(struct ccdiinfo *ii)
   1474   1.11   thorpej {
   1475   1.68  augustss 	int ix, i;
   1476   1.11   thorpej 
   1477   1.11   thorpej 	for (ix = 0; ii->ii_ndisk; ix++, ii++) {
   1478   1.81    kleink 		printf(" itab[%d]: #dk %d sblk %" PRId64 " soff %" PRId64,
   1479   1.34  christos 		    ix, ii->ii_ndisk, ii->ii_startblk, ii->ii_startoff);
   1480   1.11   thorpej 		for (i = 0; i < ii->ii_ndisk; i++)
   1481   1.35  christos 			printf(" %d", ii->ii_index[i]);
   1482   1.35  christos 		printf("\n");
   1483   1.11   thorpej 	}
   1484    1.1   hpeyerl }
   1485    1.1   hpeyerl #endif
   1486