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