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