xref: /freebsd/sys/geom/geom_ccd.c (revision 2616144e4345e4cdab56fd7c673fbb69074a9ce2)
1fa521b03SWarner Losh /*-
23b1746dfSPoul-Henning Kamp  * Copyright (c) 2003 Poul-Henning Kamp.
3a56bb8a5SSatoshi Asami  * Copyright (c) 1995 Jason R. Thorpe.
4a56bb8a5SSatoshi Asami  * Copyright (c) 1990, 1993
5a56bb8a5SSatoshi Asami  *	The Regents of the University of California.  All rights reserved.
63b1746dfSPoul-Henning Kamp  * All rights reserved.
73b1746dfSPoul-Henning Kamp  * Copyright (c) 1988 University of Utah.
8a56bb8a5SSatoshi Asami  *
9a56bb8a5SSatoshi Asami  * This code is derived from software contributed to Berkeley by
10a56bb8a5SSatoshi Asami  * the Systems Programming Group of the University of Utah Computer
11a56bb8a5SSatoshi Asami  * Science Department.
12a56bb8a5SSatoshi Asami  *
13a56bb8a5SSatoshi Asami  * Redistribution and use in source and binary forms, with or without
14a56bb8a5SSatoshi Asami  * modification, are permitted provided that the following conditions
15a56bb8a5SSatoshi Asami  * are met:
16a56bb8a5SSatoshi Asami  * 1. Redistributions of source code must retain the above copyright
17a56bb8a5SSatoshi Asami  *    notice, this list of conditions and the following disclaimer.
18a56bb8a5SSatoshi Asami  * 2. Redistributions in binary form must reproduce the above copyright
19a56bb8a5SSatoshi Asami  *    notice, this list of conditions and the following disclaimer in the
20a56bb8a5SSatoshi Asami  *    documentation and/or other materials provided with the distribution.
21a56bb8a5SSatoshi Asami  * 3. All advertising materials mentioning features or use of this software
22a56bb8a5SSatoshi Asami  *    must display the following acknowledgement:
233b1746dfSPoul-Henning Kamp  *	This product includes software developed for the NetBSD Project
243b1746dfSPoul-Henning Kamp  *	by Jason R. Thorpe.
253b1746dfSPoul-Henning Kamp  * 4. The names of the authors may not be used to endorse or promote products
263b1746dfSPoul-Henning Kamp  *    derived from this software without specific prior written permission.
27a56bb8a5SSatoshi Asami  *
283b1746dfSPoul-Henning Kamp  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
293b1746dfSPoul-Henning Kamp  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
303b1746dfSPoul-Henning Kamp  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
313b1746dfSPoul-Henning Kamp  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
323b1746dfSPoul-Henning Kamp  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
333b1746dfSPoul-Henning Kamp  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
343b1746dfSPoul-Henning Kamp  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
353b1746dfSPoul-Henning Kamp  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
363b1746dfSPoul-Henning Kamp  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
37a56bb8a5SSatoshi Asami  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
38a56bb8a5SSatoshi Asami  * SUCH DAMAGE.
39a56bb8a5SSatoshi Asami  *
40a56bb8a5SSatoshi Asami  * Dynamic configuration and disklabel support by:
41a56bb8a5SSatoshi Asami  *	Jason R. Thorpe <thorpej@nas.nasa.gov>
42a56bb8a5SSatoshi Asami  *	Numerical Aerodynamic Simulation Facility
43a56bb8a5SSatoshi Asami  *	Mail Stop 258-6
44a56bb8a5SSatoshi Asami  *	NASA Ames Research Center
45a56bb8a5SSatoshi Asami  *	Moffett Field, CA 94035
463b1746dfSPoul-Henning Kamp  *
473b1746dfSPoul-Henning Kamp  * from: Utah $Hdr: cd.c 1.6 90/11/28$
483b1746dfSPoul-Henning Kamp  *	@(#)cd.c	8.2 (Berkeley) 11/16/93
493b1746dfSPoul-Henning Kamp  *	$NetBSD: ccd.c,v 1.22 1995/12/08 19:13:26 thorpej Exp $
50a56bb8a5SSatoshi Asami  */
51a56bb8a5SSatoshi Asami 
5250b1faefSDavid E. O'Brien #include <sys/cdefs.h>
5350b1faefSDavid E. O'Brien __FBSDID("$FreeBSD$");
5450b1faefSDavid E. O'Brien 
55a56bb8a5SSatoshi Asami #include <sys/param.h>
56a56bb8a5SSatoshi Asami #include <sys/systm.h>
57e2a13e8cSSatoshi Asami #include <sys/kernel.h>
58b7b98418SPeter Wemm #include <sys/module.h>
599626b608SPoul-Henning Kamp #include <sys/bio.h>
60a56bb8a5SSatoshi Asami #include <sys/malloc.h>
61189337d8SPoul-Henning Kamp #include <geom/geom.h>
62a56bb8a5SSatoshi Asami 
630f557e0aSPoul-Henning Kamp /*
643a3fcd72SPoul-Henning Kamp  * Number of blocks to untouched in front of a component partition.
653a3fcd72SPoul-Henning Kamp  * This is to avoid violating its disklabel area when it starts at the
663a3fcd72SPoul-Henning Kamp  * beginning of the slice.
670f557e0aSPoul-Henning Kamp  */
683a3fcd72SPoul-Henning Kamp #if !defined(CCD_OFFSET)
693a3fcd72SPoul-Henning Kamp #define CCD_OFFSET 16
703a3fcd72SPoul-Henning Kamp #endif
713a3fcd72SPoul-Henning Kamp 
723a3fcd72SPoul-Henning Kamp /* sc_flags */
733a3fcd72SPoul-Henning Kamp #define CCDF_UNIFORM	0x02	/* use LCCD of sizes for uniform interleave */
743a3fcd72SPoul-Henning Kamp #define CCDF_MIRROR	0x04	/* use mirroring */
753f4f4a14SMartin Cracauer #define CCDF_NO_OFFSET	0x08	/* do not leave space in front */
763f4f4a14SMartin Cracauer #define CCDF_LINUX	0x10	/* use Linux compatibility mode */
773a3fcd72SPoul-Henning Kamp 
783a3fcd72SPoul-Henning Kamp /* Mask of user-settable ccd flags. */
793a3fcd72SPoul-Henning Kamp #define CCDF_USERMASK	(CCDF_UNIFORM|CCDF_MIRROR)
800f557e0aSPoul-Henning Kamp 
810f557e0aSPoul-Henning Kamp /*
820f557e0aSPoul-Henning Kamp  * Interleave description table.
830f557e0aSPoul-Henning Kamp  * Computed at boot time to speed irregular-interleave lookups.
840f557e0aSPoul-Henning Kamp  * The idea is that we interleave in "groups".  First we interleave
850f557e0aSPoul-Henning Kamp  * evenly over all component disks up to the size of the smallest
860f557e0aSPoul-Henning Kamp  * component (the first group), then we interleave evenly over all
870f557e0aSPoul-Henning Kamp  * remaining disks up to the size of the next-smallest (second group),
880f557e0aSPoul-Henning Kamp  * and so on.
890f557e0aSPoul-Henning Kamp  *
900f557e0aSPoul-Henning Kamp  * Each table entry describes the interleave characteristics of one
910f557e0aSPoul-Henning Kamp  * of these groups.  For example if a concatenated disk consisted of
920f557e0aSPoul-Henning Kamp  * three components of 5, 3, and 7 DEV_BSIZE blocks interleaved at
930f557e0aSPoul-Henning Kamp  * DEV_BSIZE (1), the table would have three entries:
940f557e0aSPoul-Henning Kamp  *
950f557e0aSPoul-Henning Kamp  *	ndisk	startblk	startoff	dev
960f557e0aSPoul-Henning Kamp  *	3	0		0		0, 1, 2
970f557e0aSPoul-Henning Kamp  *	2	9		3		0, 2
980f557e0aSPoul-Henning Kamp  *	1	13		5		2
990f557e0aSPoul-Henning Kamp  *	0	-		-		-
1000f557e0aSPoul-Henning Kamp  *
1010f557e0aSPoul-Henning Kamp  * which says that the first nine blocks (0-8) are interleaved over
1020f557e0aSPoul-Henning Kamp  * 3 disks (0, 1, 2) starting at block offset 0 on any component disk,
1030f557e0aSPoul-Henning Kamp  * the next 4 blocks (9-12) are interleaved over 2 disks (0, 2) starting
1040f557e0aSPoul-Henning Kamp  * at component block 3, and the remaining blocks (13-14) are on disk
1050f557e0aSPoul-Henning Kamp  * 2 starting at offset 5.
1060f557e0aSPoul-Henning Kamp  */
1070f557e0aSPoul-Henning Kamp struct ccdiinfo {
1080f557e0aSPoul-Henning Kamp 	int	ii_ndisk;	/* # of disks range is interleaved over */
1090f557e0aSPoul-Henning Kamp 	daddr_t	ii_startblk;	/* starting scaled block # for range */
1100f557e0aSPoul-Henning Kamp 	daddr_t	ii_startoff;	/* starting component offset (block #) */
1110f557e0aSPoul-Henning Kamp 	int	*ii_index;	/* ordered list of components in range */
1120f557e0aSPoul-Henning Kamp };
1130f557e0aSPoul-Henning Kamp 
1140f557e0aSPoul-Henning Kamp /*
1153a3fcd72SPoul-Henning Kamp  * Component info table.
1163a3fcd72SPoul-Henning Kamp  * Describes a single component of a concatenated disk.
1170f557e0aSPoul-Henning Kamp  */
1183a3fcd72SPoul-Henning Kamp struct ccdcinfo {
119e65b2137SPaul Saab 	daddr_t		ci_size; 		/* size */
1203a3fcd72SPoul-Henning Kamp 	struct g_provider *ci_provider;		/* provider */
1213a3fcd72SPoul-Henning Kamp 	struct g_consumer *ci_consumer;		/* consumer */
1220f557e0aSPoul-Henning Kamp };
1230f557e0aSPoul-Henning Kamp 
1240f557e0aSPoul-Henning Kamp /*
1250f557e0aSPoul-Henning Kamp  * A concatenated disk is described by this structure.
1260f557e0aSPoul-Henning Kamp  */
1273a3fcd72SPoul-Henning Kamp 
1280f557e0aSPoul-Henning Kamp struct ccd_s {
1290f557e0aSPoul-Henning Kamp 	LIST_ENTRY(ccd_s) list;
1300f557e0aSPoul-Henning Kamp 
1310f557e0aSPoul-Henning Kamp 	int		 sc_unit;		/* logical unit number */
1320f557e0aSPoul-Henning Kamp 	int		 sc_flags;		/* flags */
133e65b2137SPaul Saab 	daddr_t		 sc_size;		/* size of ccd */
1340f557e0aSPoul-Henning Kamp 	int		 sc_ileave;		/* interleave */
1353a3fcd72SPoul-Henning Kamp 	u_int		 sc_ndisks;		/* number of components */
1360f557e0aSPoul-Henning Kamp 	struct ccdcinfo	 *sc_cinfo;		/* component info */
1370f557e0aSPoul-Henning Kamp 	struct ccdiinfo	 *sc_itable;		/* interleave table */
1383a3fcd72SPoul-Henning Kamp 	u_int32_t	 sc_secsize;		/* # bytes per sector */
1390f557e0aSPoul-Henning Kamp 	int		 sc_pick;		/* side of mirror picked */
1400f557e0aSPoul-Henning Kamp 	daddr_t		 sc_blk[2];		/* mirror localization */
1413f4f4a14SMartin Cracauer 	u_int32_t	 sc_offset;		/* actual offset used */
1420f557e0aSPoul-Henning Kamp };
1430f557e0aSPoul-Henning Kamp 
1443a3fcd72SPoul-Henning Kamp static g_start_t g_ccd_start;
14501706d20SPoul-Henning Kamp static void ccdiodone(struct bio *bp);
1463a3fcd72SPoul-Henning Kamp static void ccdinterleave(struct ccd_s *);
1473a3fcd72SPoul-Henning Kamp static int ccdinit(struct gctl_req *req, struct ccd_s *);
1483a3fcd72SPoul-Henning Kamp static int ccdbuffer(struct bio **ret, struct ccd_s *,
14901706d20SPoul-Henning Kamp 		      struct bio *, daddr_t, caddr_t, long);
150a56bb8a5SSatoshi Asami 
151e2738b4fSPoul-Henning Kamp static void
1523a3fcd72SPoul-Henning Kamp g_ccd_orphan(struct g_consumer *cp)
153a56bb8a5SSatoshi Asami {
154c44c213fSPoul-Henning Kamp 	/*
155c44c213fSPoul-Henning Kamp 	 * XXX: We don't do anything here.  It is not obvious
156c44c213fSPoul-Henning Kamp 	 * XXX: what DTRT would be, so we do what the previous
157c44c213fSPoul-Henning Kamp 	 * XXX: code did: ignore it and let the user cope.
158c44c213fSPoul-Henning Kamp 	 */
159b7b98418SPeter Wemm }
160d8594dfbSSatoshi Asami 
161b7b98418SPeter Wemm static int
1623a3fcd72SPoul-Henning Kamp g_ccd_access(struct g_provider *pp, int dr, int dw, int de)
163b7b98418SPeter Wemm {
1643a3fcd72SPoul-Henning Kamp 	struct g_geom *gp;
1653a3fcd72SPoul-Henning Kamp 	struct g_consumer *cp1, *cp2;
1663a3fcd72SPoul-Henning Kamp 	int error;
167b7b98418SPeter Wemm 
1683a3fcd72SPoul-Henning Kamp 	de += dr;
1693a3fcd72SPoul-Henning Kamp 	de += dw;
1703a3fcd72SPoul-Henning Kamp 
1713a3fcd72SPoul-Henning Kamp 	gp = pp->geom;
1723a3fcd72SPoul-Henning Kamp 	error = ENXIO;
1733a3fcd72SPoul-Henning Kamp 	LIST_FOREACH(cp1, &gp->consumer, consumer) {
174d2bae332SPoul-Henning Kamp 		error = g_access(cp1, dr, dw, de);
1753a3fcd72SPoul-Henning Kamp 		if (error) {
1763a3fcd72SPoul-Henning Kamp 			LIST_FOREACH(cp2, &gp->consumer, consumer) {
1773a3fcd72SPoul-Henning Kamp 				if (cp1 == cp2)
178b7b98418SPeter Wemm 					break;
179d2bae332SPoul-Henning Kamp 				g_access(cp2, -dr, -dw, -de);
1803a3fcd72SPoul-Henning Kamp 			}
181b7b98418SPeter Wemm 			break;
1823a3fcd72SPoul-Henning Kamp 		}
183e2a13e8cSSatoshi Asami 	}
184b7b98418SPeter Wemm 	return (error);
185e2a13e8cSSatoshi Asami }
186b7b98418SPeter Wemm 
1873a3fcd72SPoul-Henning Kamp /*
1883a3fcd72SPoul-Henning Kamp  * Free the softc and its substructures.
1893a3fcd72SPoul-Henning Kamp  */
1903a3fcd72SPoul-Henning Kamp static void
1913a3fcd72SPoul-Henning Kamp g_ccd_freesc(struct ccd_s *sc)
1923a3fcd72SPoul-Henning Kamp {
1933a3fcd72SPoul-Henning Kamp 	struct ccdiinfo *ii;
1943a3fcd72SPoul-Henning Kamp 
1953a3fcd72SPoul-Henning Kamp 	g_free(sc->sc_cinfo);
1963a3fcd72SPoul-Henning Kamp 	if (sc->sc_itable != NULL) {
1973a3fcd72SPoul-Henning Kamp 		for (ii = sc->sc_itable; ii->ii_ndisk > 0; ii++)
1983a3fcd72SPoul-Henning Kamp 			if (ii->ii_index != NULL)
1993a3fcd72SPoul-Henning Kamp 				g_free(ii->ii_index);
2003a3fcd72SPoul-Henning Kamp 		g_free(sc->sc_itable);
2013a3fcd72SPoul-Henning Kamp 	}
2023a3fcd72SPoul-Henning Kamp 	g_free(sc);
2033a3fcd72SPoul-Henning Kamp }
2043a3fcd72SPoul-Henning Kamp 
205a56bb8a5SSatoshi Asami 
206a56bb8a5SSatoshi Asami static int
2073a3fcd72SPoul-Henning Kamp ccdinit(struct gctl_req *req, struct ccd_s *cs)
208a56bb8a5SSatoshi Asami {
2093a3fcd72SPoul-Henning Kamp 	struct ccdcinfo *ci;
210e65b2137SPaul Saab 	daddr_t size;
2111464240eSMatthew Dillon 	int ix;
212e65b2137SPaul Saab 	daddr_t minsize;
213a56bb8a5SSatoshi Asami 	int maxsecsize;
214ffee6e99SPoul-Henning Kamp 	off_t mediasize;
215ffee6e99SPoul-Henning Kamp 	u_int sectorsize;
216a56bb8a5SSatoshi Asami 
217a56bb8a5SSatoshi Asami 	cs->sc_size = 0;
218a56bb8a5SSatoshi Asami 
219a56bb8a5SSatoshi Asami 	maxsecsize = 0;
220a56bb8a5SSatoshi Asami 	minsize = 0;
2213f4f4a14SMartin Cracauer 
2223f4f4a14SMartin Cracauer 	if (cs->sc_flags & CCDF_LINUX) {
2233f4f4a14SMartin Cracauer 		cs->sc_offset = 0;
2243f4f4a14SMartin Cracauer 		cs->sc_ileave *= 2;
2253f4f4a14SMartin Cracauer 		if (cs->sc_flags & CCDF_MIRROR && cs->sc_ndisks != 2)
2263f4f4a14SMartin Cracauer 			gctl_error(req, "Mirror mode for Linux raids is "
2273f4f4a14SMartin Cracauer 			                "only supported with 2 devices");
2283f4f4a14SMartin Cracauer 	} else {
2293f4f4a14SMartin Cracauer 		if (cs->sc_flags & CCDF_NO_OFFSET)
2303f4f4a14SMartin Cracauer 			cs->sc_offset = 0;
2313f4f4a14SMartin Cracauer 		else
2323f4f4a14SMartin Cracauer 			cs->sc_offset = CCD_OFFSET;
2333f4f4a14SMartin Cracauer 
2343f4f4a14SMartin Cracauer 	}
2353a3fcd72SPoul-Henning Kamp 	for (ix = 0; ix < cs->sc_ndisks; ix++) {
236a56bb8a5SSatoshi Asami 		ci = &cs->sc_cinfo[ix];
237a56bb8a5SSatoshi Asami 
2383a3fcd72SPoul-Henning Kamp 		mediasize = ci->ci_provider->mediasize;
2393a3fcd72SPoul-Henning Kamp 		sectorsize = ci->ci_provider->sectorsize;
240ffee6e99SPoul-Henning Kamp 		if (sectorsize > maxsecsize)
241ffee6e99SPoul-Henning Kamp 			maxsecsize = sectorsize;
2423f4f4a14SMartin Cracauer 		size = mediasize / DEV_BSIZE - cs->sc_offset;
243a56bb8a5SSatoshi Asami 
2443a3fcd72SPoul-Henning Kamp 		/* Truncate to interleave boundary */
245a56bb8a5SSatoshi Asami 
246a56bb8a5SSatoshi Asami 		if (cs->sc_ileave > 1)
247a56bb8a5SSatoshi Asami 			size -= size % cs->sc_ileave;
248a56bb8a5SSatoshi Asami 
249a56bb8a5SSatoshi Asami 		if (size == 0) {
2503a3fcd72SPoul-Henning Kamp 			gctl_error(req, "Component %s has effective size zero",
2513a3fcd72SPoul-Henning Kamp 			    ci->ci_provider->name);
2523a3fcd72SPoul-Henning Kamp 			return(ENODEV);
253a56bb8a5SSatoshi Asami 		}
254a56bb8a5SSatoshi Asami 
255a56bb8a5SSatoshi Asami 		if (minsize == 0 || size < minsize)
256a56bb8a5SSatoshi Asami 			minsize = size;
257a56bb8a5SSatoshi Asami 		ci->ci_size = size;
258a56bb8a5SSatoshi Asami 		cs->sc_size += size;
259a56bb8a5SSatoshi Asami 	}
260a56bb8a5SSatoshi Asami 
261a56bb8a5SSatoshi Asami 	/*
262a56bb8a5SSatoshi Asami 	 * Don't allow the interleave to be smaller than
263a56bb8a5SSatoshi Asami 	 * the biggest component sector.
264a56bb8a5SSatoshi Asami 	 */
265a56bb8a5SSatoshi Asami 	if ((cs->sc_ileave > 0) &&
266a56bb8a5SSatoshi Asami 	    (cs->sc_ileave < (maxsecsize / DEV_BSIZE))) {
2673a3fcd72SPoul-Henning Kamp 		gctl_error(req, "Interleave to small for sector size");
2683a3fcd72SPoul-Henning Kamp 		return(EINVAL);
269a56bb8a5SSatoshi Asami 	}
270a56bb8a5SSatoshi Asami 
271a56bb8a5SSatoshi Asami 	/*
272a56bb8a5SSatoshi Asami 	 * If uniform interleave is desired set all sizes to that of
2731464240eSMatthew Dillon 	 * the smallest component.  This will guarentee that a single
2741464240eSMatthew Dillon 	 * interleave table is generated.
2751464240eSMatthew Dillon 	 *
2761464240eSMatthew Dillon 	 * Lost space must be taken into account when calculating the
2771464240eSMatthew Dillon 	 * overall size.  Half the space is lost when CCDF_MIRROR is
278ddbf51afSPoul-Henning Kamp 	 * specified.
279a56bb8a5SSatoshi Asami 	 */
28001706d20SPoul-Henning Kamp 	if (cs->sc_flags & CCDF_UNIFORM) {
2813a3fcd72SPoul-Henning Kamp 		for (ix = 0; ix < cs->sc_ndisks; ix++) {
2823a3fcd72SPoul-Henning Kamp 			ci = &cs->sc_cinfo[ix];
283a56bb8a5SSatoshi Asami 			ci->ci_size = minsize;
2841464240eSMatthew Dillon 		}
2853a3fcd72SPoul-Henning Kamp 		cs->sc_size = cs->sc_ndisks * minsize;
2863a3fcd72SPoul-Henning Kamp 	}
2873a3fcd72SPoul-Henning Kamp 
28801706d20SPoul-Henning Kamp 	if (cs->sc_flags & CCDF_MIRROR) {
28934f35216SSatoshi Asami 		/*
29034f35216SSatoshi Asami 		 * Check to see if an even number of components
2911464240eSMatthew Dillon 		 * have been specified.  The interleave must also
2921464240eSMatthew Dillon 		 * be non-zero in order for us to be able to
2931464240eSMatthew Dillon 		 * guarentee the topology.
29434f35216SSatoshi Asami 		 */
2953a3fcd72SPoul-Henning Kamp 		if (cs->sc_ndisks % 2) {
2963a3fcd72SPoul-Henning Kamp 			gctl_error(req,
2973a3fcd72SPoul-Henning Kamp 			      "Mirroring requires an even number of disks");
2983a3fcd72SPoul-Henning Kamp 			return(EINVAL);
29934f35216SSatoshi Asami 		}
3001464240eSMatthew Dillon 		if (cs->sc_ileave == 0) {
3013a3fcd72SPoul-Henning Kamp 			gctl_error(req,
3023a3fcd72SPoul-Henning Kamp 			     "An interleave must be specified when mirroring");
3033a3fcd72SPoul-Henning Kamp 			return(EINVAL);
30409b59204SSatoshi Asami 		}
3053a3fcd72SPoul-Henning Kamp 		cs->sc_size = (cs->sc_ndisks/2) * minsize;
3061464240eSMatthew Dillon 	}
307a56bb8a5SSatoshi Asami 
308a56bb8a5SSatoshi Asami 	/*
309a56bb8a5SSatoshi Asami 	 * Construct the interleave table.
310a56bb8a5SSatoshi Asami 	 */
3113a3fcd72SPoul-Henning Kamp 	ccdinterleave(cs);
312a56bb8a5SSatoshi Asami 
313a56bb8a5SSatoshi Asami 	/*
314a56bb8a5SSatoshi Asami 	 * Create pseudo-geometry based on 1MB cylinders.  It's
315a56bb8a5SSatoshi Asami 	 * pretty close.
316a56bb8a5SSatoshi Asami 	 */
3173a3fcd72SPoul-Henning Kamp 	cs->sc_secsize = maxsecsize;
318a56bb8a5SSatoshi Asami 
319a56bb8a5SSatoshi Asami 	return (0);
320a56bb8a5SSatoshi Asami }
321a56bb8a5SSatoshi Asami 
322a56bb8a5SSatoshi Asami static void
3233a3fcd72SPoul-Henning Kamp ccdinterleave(struct ccd_s *cs)
324a56bb8a5SSatoshi Asami {
3251464240eSMatthew Dillon 	struct ccdcinfo *ci, *smallci;
3261464240eSMatthew Dillon 	struct ccdiinfo *ii;
3271464240eSMatthew Dillon 	daddr_t bn, lbn;
3281464240eSMatthew Dillon 	int ix;
329e65b2137SPaul Saab 	daddr_t size;
330a56bb8a5SSatoshi Asami 
3311464240eSMatthew Dillon 
332a56bb8a5SSatoshi Asami 	/*
3331464240eSMatthew Dillon 	 * Allocate an interleave table.  The worst case occurs when each
3341464240eSMatthew Dillon 	 * of N disks is of a different size, resulting in N interleave
3351464240eSMatthew Dillon 	 * tables.
3361464240eSMatthew Dillon 	 *
337a56bb8a5SSatoshi Asami 	 * Chances are this is too big, but we don't care.
338a56bb8a5SSatoshi Asami 	 */
3393a3fcd72SPoul-Henning Kamp 	size = (cs->sc_ndisks + 1) * sizeof(struct ccdiinfo);
3403a3fcd72SPoul-Henning Kamp 	cs->sc_itable = g_malloc(size, M_WAITOK | M_ZERO);
341a56bb8a5SSatoshi Asami 
342a56bb8a5SSatoshi Asami 	/*
343a56bb8a5SSatoshi Asami 	 * Trivial case: no interleave (actually interleave of disk size).
344a56bb8a5SSatoshi Asami 	 * Each table entry represents a single component in its entirety.
3451464240eSMatthew Dillon 	 *
346ddbf51afSPoul-Henning Kamp 	 * An interleave of 0 may not be used with a mirror setup.
347a56bb8a5SSatoshi Asami 	 */
348a56bb8a5SSatoshi Asami 	if (cs->sc_ileave == 0) {
349a56bb8a5SSatoshi Asami 		bn = 0;
350a56bb8a5SSatoshi Asami 		ii = cs->sc_itable;
351a56bb8a5SSatoshi Asami 
3523a3fcd72SPoul-Henning Kamp 		for (ix = 0; ix < cs->sc_ndisks; ix++) {
353a56bb8a5SSatoshi Asami 			/* Allocate space for ii_index. */
3543a3fcd72SPoul-Henning Kamp 			ii->ii_index = g_malloc(sizeof(int), M_WAITOK);
355a56bb8a5SSatoshi Asami 			ii->ii_ndisk = 1;
356a56bb8a5SSatoshi Asami 			ii->ii_startblk = bn;
357a56bb8a5SSatoshi Asami 			ii->ii_startoff = 0;
358a56bb8a5SSatoshi Asami 			ii->ii_index[0] = ix;
359a56bb8a5SSatoshi Asami 			bn += cs->sc_cinfo[ix].ci_size;
360a56bb8a5SSatoshi Asami 			ii++;
361a56bb8a5SSatoshi Asami 		}
362a56bb8a5SSatoshi Asami 		ii->ii_ndisk = 0;
363a56bb8a5SSatoshi Asami 		return;
364a56bb8a5SSatoshi Asami 	}
365a56bb8a5SSatoshi Asami 
366a56bb8a5SSatoshi Asami 	/*
367a56bb8a5SSatoshi Asami 	 * The following isn't fast or pretty; it doesn't have to be.
368a56bb8a5SSatoshi Asami 	 */
369a56bb8a5SSatoshi Asami 	size = 0;
370a56bb8a5SSatoshi Asami 	bn = lbn = 0;
371a56bb8a5SSatoshi Asami 	for (ii = cs->sc_itable; ; ii++) {
3721464240eSMatthew Dillon 		/*
3731464240eSMatthew Dillon 		 * Allocate space for ii_index.  We might allocate more then
3741464240eSMatthew Dillon 		 * we use.
3751464240eSMatthew Dillon 		 */
3763a3fcd72SPoul-Henning Kamp 		ii->ii_index = g_malloc((sizeof(int) * cs->sc_ndisks),
3773a3fcd72SPoul-Henning Kamp 		    M_WAITOK);
378a56bb8a5SSatoshi Asami 
379a56bb8a5SSatoshi Asami 		/*
380a56bb8a5SSatoshi Asami 		 * Locate the smallest of the remaining components
381a56bb8a5SSatoshi Asami 		 */
382a56bb8a5SSatoshi Asami 		smallci = NULL;
3833a3fcd72SPoul-Henning Kamp 		for (ci = cs->sc_cinfo; ci < &cs->sc_cinfo[cs->sc_ndisks];
3841464240eSMatthew Dillon 		    ci++) {
385a56bb8a5SSatoshi Asami 			if (ci->ci_size > size &&
386a56bb8a5SSatoshi Asami 			    (smallci == NULL ||
3871464240eSMatthew Dillon 			     ci->ci_size < smallci->ci_size)) {
388a56bb8a5SSatoshi Asami 				smallci = ci;
3891464240eSMatthew Dillon 			}
3901464240eSMatthew Dillon 		}
391a56bb8a5SSatoshi Asami 
392a56bb8a5SSatoshi Asami 		/*
393a56bb8a5SSatoshi Asami 		 * Nobody left, all done
394a56bb8a5SSatoshi Asami 		 */
395a56bb8a5SSatoshi Asami 		if (smallci == NULL) {
396a56bb8a5SSatoshi Asami 			ii->ii_ndisk = 0;
3973a3fcd72SPoul-Henning Kamp 			g_free(ii->ii_index);
3983a3fcd72SPoul-Henning Kamp 			ii->ii_index = NULL;
399a56bb8a5SSatoshi Asami 			break;
400a56bb8a5SSatoshi Asami 		}
401a56bb8a5SSatoshi Asami 
402a56bb8a5SSatoshi Asami 		/*
4031464240eSMatthew Dillon 		 * Record starting logical block using an sc_ileave blocksize.
404a56bb8a5SSatoshi Asami 		 */
405a56bb8a5SSatoshi Asami 		ii->ii_startblk = bn / cs->sc_ileave;
4061464240eSMatthew Dillon 
4071464240eSMatthew Dillon 		/*
4083a3fcd72SPoul-Henning Kamp 		 * Record starting component block using an sc_ileave
4091464240eSMatthew Dillon 		 * blocksize.  This value is relative to the beginning of
4101464240eSMatthew Dillon 		 * a component disk.
4111464240eSMatthew Dillon 		 */
412a56bb8a5SSatoshi Asami 		ii->ii_startoff = lbn;
413a56bb8a5SSatoshi Asami 
414a56bb8a5SSatoshi Asami 		/*
415a56bb8a5SSatoshi Asami 		 * Determine how many disks take part in this interleave
416a56bb8a5SSatoshi Asami 		 * and record their indices.
417a56bb8a5SSatoshi Asami 		 */
418a56bb8a5SSatoshi Asami 		ix = 0;
419a56bb8a5SSatoshi Asami 		for (ci = cs->sc_cinfo;
4203a3fcd72SPoul-Henning Kamp 		    ci < &cs->sc_cinfo[cs->sc_ndisks]; ci++) {
4211464240eSMatthew Dillon 			if (ci->ci_size >= smallci->ci_size) {
422a56bb8a5SSatoshi Asami 				ii->ii_index[ix++] = ci - cs->sc_cinfo;
4231464240eSMatthew Dillon 			}
4241464240eSMatthew Dillon 		}
425a56bb8a5SSatoshi Asami 		ii->ii_ndisk = ix;
426a56bb8a5SSatoshi Asami 		bn += ix * (smallci->ci_size - size);
427a56bb8a5SSatoshi Asami 		lbn = smallci->ci_size / cs->sc_ileave;
428a56bb8a5SSatoshi Asami 		size = smallci->ci_size;
429a56bb8a5SSatoshi Asami 	}
430a56bb8a5SSatoshi Asami }
431a56bb8a5SSatoshi Asami 
432e2738b4fSPoul-Henning Kamp static void
4333a3fcd72SPoul-Henning Kamp g_ccd_start(struct bio *bp)
434a56bb8a5SSatoshi Asami {
4351464240eSMatthew Dillon 	long bcount, rcount;
4363a3fcd72SPoul-Henning Kamp 	struct bio *cbp[2];
437a56bb8a5SSatoshi Asami 	caddr_t addr;
438a56bb8a5SSatoshi Asami 	daddr_t bn;
4390f76d6d8SPoul-Henning Kamp 	int err;
4403a3fcd72SPoul-Henning Kamp 	struct ccd_s *cs;
4413a3fcd72SPoul-Henning Kamp 
4423a3fcd72SPoul-Henning Kamp 	cs = bp->bio_to->geom->softc;
443a56bb8a5SSatoshi Asami 
444a56bb8a5SSatoshi Asami 	/*
445e30b2edaSPoul-Henning Kamp 	 * Block all GETATTR requests, we wouldn't know which of our
446e30b2edaSPoul-Henning Kamp 	 * subdevices we should ship it off to.
447e30b2edaSPoul-Henning Kamp 	 * XXX: this may not be the right policy.
448e30b2edaSPoul-Henning Kamp 	 */
449e30b2edaSPoul-Henning Kamp 	if(bp->bio_cmd == BIO_GETATTR) {
450e30b2edaSPoul-Henning Kamp 		g_io_deliver(bp, EINVAL);
451e30b2edaSPoul-Henning Kamp 		return;
452e30b2edaSPoul-Henning Kamp 	}
453e30b2edaSPoul-Henning Kamp 
454e30b2edaSPoul-Henning Kamp 	/*
455a56bb8a5SSatoshi Asami 	 * Translate the partition-relative block number to an absolute.
456a56bb8a5SSatoshi Asami 	 */
4573a3fcd72SPoul-Henning Kamp 	bn = bp->bio_offset / cs->sc_secsize;
458a56bb8a5SSatoshi Asami 
459a56bb8a5SSatoshi Asami 	/*
460a56bb8a5SSatoshi Asami 	 * Allocate component buffers and fire off the requests
461a56bb8a5SSatoshi Asami 	 */
4629d7f7369SPoul-Henning Kamp 	addr = bp->bio_data;
4633a3fcd72SPoul-Henning Kamp 	for (bcount = bp->bio_length; bcount > 0; bcount -= rcount) {
4640f76d6d8SPoul-Henning Kamp 		err = ccdbuffer(cbp, cs, bp, bn, addr, bcount);
4650f76d6d8SPoul-Henning Kamp 		if (err) {
466ec421aecSPoul-Henning Kamp 			bp->bio_completed += bcount;
467c12ec49eSPoul-Henning Kamp 			if (bp->bio_error == 0)
46877154759SPoul-Henning Kamp 				bp->bio_error = err;
469ec421aecSPoul-Henning Kamp 			if (bp->bio_completed == bp->bio_length)
470ec421aecSPoul-Henning Kamp 				g_io_deliver(bp, bp->bio_error);
4710f76d6d8SPoul-Henning Kamp 			return;
4720f76d6d8SPoul-Henning Kamp 		}
4733a3fcd72SPoul-Henning Kamp 		rcount = cbp[0]->bio_length;
4741464240eSMatthew Dillon 
4753a3fcd72SPoul-Henning Kamp 		if (cs->sc_flags & CCDF_MIRROR) {
4761464240eSMatthew Dillon 			/*
4771464240eSMatthew Dillon 			 * Mirroring.  Writes go to both disks, reads are
4781464240eSMatthew Dillon 			 * taken from whichever disk seems most appropriate.
4791464240eSMatthew Dillon 			 *
4801464240eSMatthew Dillon 			 * We attempt to localize reads to the disk whos arm
4811464240eSMatthew Dillon 			 * is nearest the read request.  We ignore seeks due
4821464240eSMatthew Dillon 			 * to writes when making this determination and we
4831464240eSMatthew Dillon 			 * also try to avoid hogging.
4841464240eSMatthew Dillon 			 */
4853a3fcd72SPoul-Henning Kamp 			if (cbp[0]->bio_cmd != BIO_READ) {
4863a3fcd72SPoul-Henning Kamp 				g_io_request(cbp[0], cbp[0]->bio_from);
4873a3fcd72SPoul-Henning Kamp 				g_io_request(cbp[1], cbp[1]->bio_from);
4881464240eSMatthew Dillon 			} else {
4891464240eSMatthew Dillon 				int pick = cs->sc_pick;
4901464240eSMatthew Dillon 				daddr_t range = cs->sc_size / 16;
4911464240eSMatthew Dillon 
4921464240eSMatthew Dillon 				if (bn < cs->sc_blk[pick] - range ||
4931464240eSMatthew Dillon 				    bn > cs->sc_blk[pick] + range
4941464240eSMatthew Dillon 				) {
4951464240eSMatthew Dillon 					cs->sc_pick = pick = 1 - pick;
4961464240eSMatthew Dillon 				}
4971464240eSMatthew Dillon 				cs->sc_blk[pick] = bn + btodb(rcount);
4983a3fcd72SPoul-Henning Kamp 				g_io_request(cbp[pick], cbp[pick]->bio_from);
4991464240eSMatthew Dillon 			}
5001464240eSMatthew Dillon 		} else {
5011464240eSMatthew Dillon 			/*
5021464240eSMatthew Dillon 			 * Not mirroring
5031464240eSMatthew Dillon 			 */
5043a3fcd72SPoul-Henning Kamp 			g_io_request(cbp[0], cbp[0]->bio_from);
5053bc746beSSatoshi Asami 		}
506a56bb8a5SSatoshi Asami 		bn += btodb(rcount);
507a56bb8a5SSatoshi Asami 		addr += rcount;
508a56bb8a5SSatoshi Asami 	}
509a56bb8a5SSatoshi Asami }
510a56bb8a5SSatoshi Asami 
511a56bb8a5SSatoshi Asami /*
512a56bb8a5SSatoshi Asami  * Build a component buffer header.
513a56bb8a5SSatoshi Asami  */
5140f76d6d8SPoul-Henning Kamp static int
5153a3fcd72SPoul-Henning Kamp ccdbuffer(struct bio **cb, struct ccd_s *cs, struct bio *bp, daddr_t bn, caddr_t addr, long bcount)
516a56bb8a5SSatoshi Asami {
517ec421aecSPoul-Henning Kamp 	struct ccdcinfo *ci, *ci2 = NULL;
5183a3fcd72SPoul-Henning Kamp 	struct bio *cbp;
5191464240eSMatthew Dillon 	daddr_t cbn, cboff;
5201464240eSMatthew Dillon 	off_t cbc;
521a56bb8a5SSatoshi Asami 
522a56bb8a5SSatoshi Asami 	/*
523a56bb8a5SSatoshi Asami 	 * Determine which component bn falls in.
524a56bb8a5SSatoshi Asami 	 */
525a56bb8a5SSatoshi Asami 	cbn = bn;
526a56bb8a5SSatoshi Asami 	cboff = 0;
527a56bb8a5SSatoshi Asami 
528a56bb8a5SSatoshi Asami 	if (cs->sc_ileave == 0) {
5291464240eSMatthew Dillon 		/*
5301464240eSMatthew Dillon 		 * Serially concatenated and neither a mirror nor a parity
5311464240eSMatthew Dillon 		 * config.  This is a special case.
5321464240eSMatthew Dillon 		 */
5331464240eSMatthew Dillon 		daddr_t sblk;
534a56bb8a5SSatoshi Asami 
535a56bb8a5SSatoshi Asami 		sblk = 0;
536a56bb8a5SSatoshi Asami 		for (ci = cs->sc_cinfo; cbn >= sblk + ci->ci_size; ci++)
537a56bb8a5SSatoshi Asami 			sblk += ci->ci_size;
538a56bb8a5SSatoshi Asami 		cbn -= sblk;
5391464240eSMatthew Dillon 	} else {
5401464240eSMatthew Dillon 		struct ccdiinfo *ii;
541a56bb8a5SSatoshi Asami 		int ccdisk, off;
542a56bb8a5SSatoshi Asami 
5431464240eSMatthew Dillon 		/*
5441464240eSMatthew Dillon 		 * Calculate cbn, the logical superblock (sc_ileave chunks),
5451464240eSMatthew Dillon 		 * and cboff, a normal block offset (DEV_BSIZE chunks) relative
5461464240eSMatthew Dillon 		 * to cbn.
5471464240eSMatthew Dillon 		 */
5481464240eSMatthew Dillon 		cboff = cbn % cs->sc_ileave;	/* DEV_BSIZE gran */
5491464240eSMatthew Dillon 		cbn = cbn / cs->sc_ileave;	/* DEV_BSIZE * ileave gran */
5501464240eSMatthew Dillon 
5511464240eSMatthew Dillon 		/*
5521464240eSMatthew Dillon 		 * Figure out which interleave table to use.
5531464240eSMatthew Dillon 		 */
5541464240eSMatthew Dillon 		for (ii = cs->sc_itable; ii->ii_ndisk; ii++) {
555a56bb8a5SSatoshi Asami 			if (ii->ii_startblk > cbn)
556a56bb8a5SSatoshi Asami 				break;
5571464240eSMatthew Dillon 		}
558a56bb8a5SSatoshi Asami 		ii--;
5591464240eSMatthew Dillon 
5601464240eSMatthew Dillon 		/*
5611464240eSMatthew Dillon 		 * off is the logical superblock relative to the beginning
5621464240eSMatthew Dillon 		 * of this interleave block.
5631464240eSMatthew Dillon 		 */
564a56bb8a5SSatoshi Asami 		off = cbn - ii->ii_startblk;
5651464240eSMatthew Dillon 
5661464240eSMatthew Dillon 		/*
5671464240eSMatthew Dillon 		 * We must calculate which disk component to use (ccdisk),
5681464240eSMatthew Dillon 		 * and recalculate cbn to be the superblock relative to
5691464240eSMatthew Dillon 		 * the beginning of the component.  This is typically done by
5701464240eSMatthew Dillon 		 * adding 'off' and ii->ii_startoff together.  However, 'off'
5711464240eSMatthew Dillon 		 * must typically be divided by the number of components in
5721464240eSMatthew Dillon 		 * this interleave array to be properly convert it from a
5731464240eSMatthew Dillon 		 * CCD-relative logical superblock number to a
5741464240eSMatthew Dillon 		 * component-relative superblock number.
5751464240eSMatthew Dillon 		 */
576a56bb8a5SSatoshi Asami 		if (ii->ii_ndisk == 1) {
5771464240eSMatthew Dillon 			/*
5781464240eSMatthew Dillon 			 * When we have just one disk, it can't be a mirror
5791464240eSMatthew Dillon 			 * or a parity config.
5801464240eSMatthew Dillon 			 */
581a56bb8a5SSatoshi Asami 			ccdisk = ii->ii_index[0];
582a56bb8a5SSatoshi Asami 			cbn = ii->ii_startoff + off;
583a56bb8a5SSatoshi Asami 		} else {
5843a3fcd72SPoul-Henning Kamp 			if (cs->sc_flags & CCDF_MIRROR) {
5851464240eSMatthew Dillon 				/*
5861464240eSMatthew Dillon 				 * We have forced a uniform mapping, resulting
5871464240eSMatthew Dillon 				 * in a single interleave array.  We double
5881464240eSMatthew Dillon 				 * up on the first half of the available
5891464240eSMatthew Dillon 				 * components and our mirror is in the second
5901464240eSMatthew Dillon 				 * half.  This only works with a single
5911464240eSMatthew Dillon 				 * interleave array because doubling up
5921464240eSMatthew Dillon 				 * doubles the number of sectors, so there
5931464240eSMatthew Dillon 				 * cannot be another interleave array because
5941464240eSMatthew Dillon 				 * the next interleave array's calculations
5951464240eSMatthew Dillon 				 * would be off.
5961464240eSMatthew Dillon 				 */
5971464240eSMatthew Dillon 				int ndisk2 = ii->ii_ndisk / 2;
5981464240eSMatthew Dillon 				ccdisk = ii->ii_index[off % ndisk2];
5991464240eSMatthew Dillon 				cbn = ii->ii_startoff + off / ndisk2;
6001464240eSMatthew Dillon 				ci2 = &cs->sc_cinfo[ccdisk + ndisk2];
6011464240eSMatthew Dillon 			} else {
602a56bb8a5SSatoshi Asami 				ccdisk = ii->ii_index[off % ii->ii_ndisk];
603a56bb8a5SSatoshi Asami 				cbn = ii->ii_startoff + off / ii->ii_ndisk;
604a56bb8a5SSatoshi Asami 			}
6057ecb65faSSatoshi Asami 		}
6061464240eSMatthew Dillon 
607a56bb8a5SSatoshi Asami 		ci = &cs->sc_cinfo[ccdisk];
6081464240eSMatthew Dillon 
6091464240eSMatthew Dillon 		/*
6101464240eSMatthew Dillon 		 * Convert cbn from a superblock to a normal block so it
6111464240eSMatthew Dillon 		 * can be used to calculate (along with cboff) the normal
6121464240eSMatthew Dillon 		 * block index into this particular disk.
6131464240eSMatthew Dillon 		 */
6141464240eSMatthew Dillon 		cbn *= cs->sc_ileave;
615a56bb8a5SSatoshi Asami 	}
616a56bb8a5SSatoshi Asami 
617a56bb8a5SSatoshi Asami 	/*
618a56bb8a5SSatoshi Asami 	 * Fill in the component buf structure.
619a56bb8a5SSatoshi Asami 	 */
6203a3fcd72SPoul-Henning Kamp 	cbp = g_clone_bio(bp);
621ec421aecSPoul-Henning Kamp 	if (cbp == NULL)
622ec421aecSPoul-Henning Kamp 		return (ENOMEM);
6233a3fcd72SPoul-Henning Kamp 	cbp->bio_done = g_std_done;
6243f4f4a14SMartin Cracauer 	cbp->bio_offset = dbtob(cbn + cboff + cs->sc_offset);
6253a3fcd72SPoul-Henning Kamp 	cbp->bio_data = addr;
626a56bb8a5SSatoshi Asami 	if (cs->sc_ileave == 0)
62740969e38SDavid Greenman               cbc = dbtob((off_t)(ci->ci_size - cbn));
628a56bb8a5SSatoshi Asami 	else
62940969e38SDavid Greenman               cbc = dbtob((off_t)(cs->sc_ileave - cboff));
6303a3fcd72SPoul-Henning Kamp 	cbp->bio_length = (cbc < bcount) ? cbc : bcount;
631c0b89506SJohn Dyson 
6323a3fcd72SPoul-Henning Kamp 	cbp->bio_from = ci->ci_consumer;
6333bc746beSSatoshi Asami 	cb[0] = cbp;
6341464240eSMatthew Dillon 
6353a3fcd72SPoul-Henning Kamp 	if (cs->sc_flags & CCDF_MIRROR) {
6363a3fcd72SPoul-Henning Kamp 		cbp = g_clone_bio(bp);
637ec421aecSPoul-Henning Kamp 		if (cbp == NULL)
638ec421aecSPoul-Henning Kamp 			return (ENOMEM);
6393a3fcd72SPoul-Henning Kamp 		cbp->bio_done = cb[0]->bio_done = ccdiodone;
6403a3fcd72SPoul-Henning Kamp 		cbp->bio_offset = cb[0]->bio_offset;
6413a3fcd72SPoul-Henning Kamp 		cbp->bio_data = cb[0]->bio_data;
6423a3fcd72SPoul-Henning Kamp 		cbp->bio_length = cb[0]->bio_length;
6433a3fcd72SPoul-Henning Kamp 		cbp->bio_from = ci2->ci_consumer;
6443a3fcd72SPoul-Henning Kamp 		cbp->bio_caller1 = cb[0];
6453a3fcd72SPoul-Henning Kamp 		cb[0]->bio_caller1 = cbp;
6463bc746beSSatoshi Asami 		cb[1] = cbp;
6473bc746beSSatoshi Asami 	}
6480f76d6d8SPoul-Henning Kamp 	return (0);
649a56bb8a5SSatoshi Asami }
650a56bb8a5SSatoshi Asami 
651a56bb8a5SSatoshi Asami /*
652c44c213fSPoul-Henning Kamp  * Called only for mirrored operations.
653a56bb8a5SSatoshi Asami  */
654e2738b4fSPoul-Henning Kamp static void
6553a3fcd72SPoul-Henning Kamp ccdiodone(struct bio *cbp)
656a56bb8a5SSatoshi Asami {
6573a3fcd72SPoul-Henning Kamp 	struct bio *mbp, *pbp;
658a56bb8a5SSatoshi Asami 
6593a3fcd72SPoul-Henning Kamp 	mbp = cbp->bio_caller1;
6603a3fcd72SPoul-Henning Kamp 	pbp = cbp->bio_parent;
661a56bb8a5SSatoshi Asami 
6623a3fcd72SPoul-Henning Kamp 	if (pbp->bio_cmd == BIO_READ) {
6633a3fcd72SPoul-Henning Kamp 		if (cbp->bio_error == 0) {
664c44c213fSPoul-Henning Kamp 			/* We will not be needing the partner bio */
665c44c213fSPoul-Henning Kamp 			if (mbp != NULL) {
6663a3fcd72SPoul-Henning Kamp 				pbp->bio_inbed++;
6673a3fcd72SPoul-Henning Kamp 				g_destroy_bio(mbp);
668c44c213fSPoul-Henning Kamp 			}
669c44c213fSPoul-Henning Kamp 			g_std_done(cbp);
670e7322872SSatoshi Asami 			return;
671e7322872SSatoshi Asami 		}
6723a3fcd72SPoul-Henning Kamp 		if (mbp != NULL) {
673c44c213fSPoul-Henning Kamp 			/* Try partner the bio instead */
6743a3fcd72SPoul-Henning Kamp 			mbp->bio_caller1 = NULL;
6753a3fcd72SPoul-Henning Kamp 			pbp->bio_inbed++;
6763a3fcd72SPoul-Henning Kamp 			g_destroy_bio(cbp);
6773a3fcd72SPoul-Henning Kamp 			g_io_request(mbp, mbp->bio_from);
678c44c213fSPoul-Henning Kamp 			/*
679c44c213fSPoul-Henning Kamp 			 * XXX: If this comes back OK, we should actually
680c44c213fSPoul-Henning Kamp 			 * try to write the good data on the failed mirror
681c44c213fSPoul-Henning Kamp 			 */
6821464240eSMatthew Dillon 			return;
6831464240eSMatthew Dillon 		}
6843a3fcd72SPoul-Henning Kamp 		g_std_done(cbp);
685114ebb2fSPoul-Henning Kamp 		return;
6861464240eSMatthew Dillon 	}
6873a3fcd72SPoul-Henning Kamp 	if (mbp != NULL) {
6883a3fcd72SPoul-Henning Kamp 		mbp->bio_caller1 = NULL;
6893a3fcd72SPoul-Henning Kamp 		pbp->bio_inbed++;
690c44c213fSPoul-Henning Kamp 		if (cbp->bio_error != 0 && pbp->bio_error == 0)
6913a3fcd72SPoul-Henning Kamp 			pbp->bio_error = cbp->bio_error;
692114ebb2fSPoul-Henning Kamp 		g_destroy_bio(cbp);
6933a3fcd72SPoul-Henning Kamp 		return;
6941464240eSMatthew Dillon 	}
6953a3fcd72SPoul-Henning Kamp 	g_std_done(cbp);
6961464240eSMatthew Dillon }
697e7322872SSatoshi Asami 
698a56bb8a5SSatoshi Asami static void
6993a3fcd72SPoul-Henning Kamp g_ccd_create(struct gctl_req *req, struct g_class *mp)
700a56bb8a5SSatoshi Asami {
7013a3fcd72SPoul-Henning Kamp 	int *unit, *ileave, *nprovider;
7023a3fcd72SPoul-Henning Kamp 	struct g_geom *gp;
7033a3fcd72SPoul-Henning Kamp 	struct g_consumer *cp;
7043a3fcd72SPoul-Henning Kamp 	struct g_provider *pp;
7053a3fcd72SPoul-Henning Kamp 	struct ccd_s *sc;
706189337d8SPoul-Henning Kamp 	struct sbuf *sb;
7073a3fcd72SPoul-Henning Kamp 	char buf[20];
7083a3fcd72SPoul-Henning Kamp 	int i, error;
7093a3fcd72SPoul-Henning Kamp 
7103a3fcd72SPoul-Henning Kamp 	g_topology_assert();
7113a3fcd72SPoul-Henning Kamp 	unit = gctl_get_paraml(req, "unit", sizeof (*unit));
7123a3fcd72SPoul-Henning Kamp 	ileave = gctl_get_paraml(req, "ileave", sizeof (*ileave));
7133a3fcd72SPoul-Henning Kamp 	nprovider = gctl_get_paraml(req, "nprovider", sizeof (*nprovider));
7143a3fcd72SPoul-Henning Kamp 
7153a3fcd72SPoul-Henning Kamp 	/* Check for duplicate unit */
7163a3fcd72SPoul-Henning Kamp 	LIST_FOREACH(gp, &mp->geom, geom) {
7173a3fcd72SPoul-Henning Kamp 		sc = gp->softc;
71892b5e86eSPoul-Henning Kamp 		if (sc != NULL && sc->sc_unit == *unit) {
7193a3fcd72SPoul-Henning Kamp 			gctl_error(req, "Unit %d already configured", *unit);
7203a3fcd72SPoul-Henning Kamp 			return;
7213a3fcd72SPoul-Henning Kamp 		}
7223a3fcd72SPoul-Henning Kamp 	}
7233a3fcd72SPoul-Henning Kamp 
7243a3fcd72SPoul-Henning Kamp 	if (*nprovider <= 0) {
7253a3fcd72SPoul-Henning Kamp 		gctl_error(req, "Bogus nprovider argument (= %d)", *nprovider);
7263a3fcd72SPoul-Henning Kamp 		return;
7273a3fcd72SPoul-Henning Kamp 	}
7283a3fcd72SPoul-Henning Kamp 
7293a3fcd72SPoul-Henning Kamp 	/* Check all providers are valid */
7303a3fcd72SPoul-Henning Kamp 	for (i = 0; i < *nprovider; i++) {
7313a3fcd72SPoul-Henning Kamp 		sprintf(buf, "provider%d", i);
7323a3fcd72SPoul-Henning Kamp 		pp = gctl_get_provider(req, buf);
7333a3fcd72SPoul-Henning Kamp 		if (pp == NULL)
7343a3fcd72SPoul-Henning Kamp 			return;
7353a3fcd72SPoul-Henning Kamp 	}
7363a3fcd72SPoul-Henning Kamp 
7373a3fcd72SPoul-Henning Kamp 	gp = g_new_geomf(mp, "ccd%d", *unit);
7383a3fcd72SPoul-Henning Kamp 	sc = g_malloc(sizeof *sc, M_WAITOK | M_ZERO);
7393a3fcd72SPoul-Henning Kamp 	gp->softc = sc;
7403a3fcd72SPoul-Henning Kamp 	sc->sc_ndisks = *nprovider;
7413a3fcd72SPoul-Henning Kamp 
7423a3fcd72SPoul-Henning Kamp 	/* Allocate space for the component info. */
7433a3fcd72SPoul-Henning Kamp 	sc->sc_cinfo = g_malloc(sc->sc_ndisks * sizeof(struct ccdcinfo),
7443a3fcd72SPoul-Henning Kamp 	    M_WAITOK | M_ZERO);
7453a3fcd72SPoul-Henning Kamp 
7463a3fcd72SPoul-Henning Kamp 	/* Create consumers and attach to all providers */
7473a3fcd72SPoul-Henning Kamp 	for (i = 0; i < *nprovider; i++) {
7483a3fcd72SPoul-Henning Kamp 		sprintf(buf, "provider%d", i);
7493a3fcd72SPoul-Henning Kamp 		pp = gctl_get_provider(req, buf);
7503a3fcd72SPoul-Henning Kamp 		cp = g_new_consumer(gp);
7513a3fcd72SPoul-Henning Kamp 		error = g_attach(cp, pp);
7523a3fcd72SPoul-Henning Kamp 		KASSERT(error == 0, ("attach to %s failed", pp->name));
7533a3fcd72SPoul-Henning Kamp 		sc->sc_cinfo[i].ci_consumer = cp;
7543a3fcd72SPoul-Henning Kamp 		sc->sc_cinfo[i].ci_provider = pp;
7553a3fcd72SPoul-Henning Kamp 	}
7563a3fcd72SPoul-Henning Kamp 
7573a3fcd72SPoul-Henning Kamp 	sc->sc_unit = *unit;
7583a3fcd72SPoul-Henning Kamp 	sc->sc_ileave = *ileave;
7593a3fcd72SPoul-Henning Kamp 
7603f4f4a14SMartin Cracauer 	if (gctl_get_param(req, "no_offset", NULL))
7613f4f4a14SMartin Cracauer 		sc->sc_flags |= CCDF_NO_OFFSET;
7623f4f4a14SMartin Cracauer 	if (gctl_get_param(req, "linux", NULL))
7633f4f4a14SMartin Cracauer 		sc->sc_flags |= CCDF_LINUX;
7643f4f4a14SMartin Cracauer 
7653a3fcd72SPoul-Henning Kamp 	if (gctl_get_param(req, "uniform", NULL))
7663a3fcd72SPoul-Henning Kamp 		sc->sc_flags |= CCDF_UNIFORM;
7673a3fcd72SPoul-Henning Kamp 	if (gctl_get_param(req, "mirror", NULL))
7683a3fcd72SPoul-Henning Kamp 		sc->sc_flags |= CCDF_MIRROR;
7693a3fcd72SPoul-Henning Kamp 
7703a3fcd72SPoul-Henning Kamp 	if (sc->sc_ileave == 0 && (sc->sc_flags & CCDF_MIRROR)) {
7713a3fcd72SPoul-Henning Kamp 		printf("%s: disabling mirror, interleave is 0\n", gp->name);
7723a3fcd72SPoul-Henning Kamp 		sc->sc_flags &= ~(CCDF_MIRROR);
7733a3fcd72SPoul-Henning Kamp 	}
7743a3fcd72SPoul-Henning Kamp 
7753a3fcd72SPoul-Henning Kamp 	if ((sc->sc_flags & CCDF_MIRROR) && !(sc->sc_flags & CCDF_UNIFORM)) {
7763a3fcd72SPoul-Henning Kamp 		printf("%s: mirror/parity forces uniform flag\n", gp->name);
7773a3fcd72SPoul-Henning Kamp 		sc->sc_flags |= CCDF_UNIFORM;
7783a3fcd72SPoul-Henning Kamp 	}
7793a3fcd72SPoul-Henning Kamp 
7803a3fcd72SPoul-Henning Kamp 	error = ccdinit(req, sc);
7813a3fcd72SPoul-Henning Kamp 	if (error != 0) {
7823a3fcd72SPoul-Henning Kamp 		g_ccd_freesc(sc);
7833a3fcd72SPoul-Henning Kamp 		gp->softc = NULL;
7843a3fcd72SPoul-Henning Kamp 		g_wither_geom(gp, ENXIO);
7853a3fcd72SPoul-Henning Kamp 		return;
7863a3fcd72SPoul-Henning Kamp 	}
7873a3fcd72SPoul-Henning Kamp 
7883a3fcd72SPoul-Henning Kamp 	pp = g_new_providerf(gp, "%s", gp->name);
7893a3fcd72SPoul-Henning Kamp 	pp->mediasize = sc->sc_size * (off_t)sc->sc_secsize;
7903a3fcd72SPoul-Henning Kamp 	pp->sectorsize = sc->sc_secsize;
7913a3fcd72SPoul-Henning Kamp 	g_error_provider(pp, 0);
792189337d8SPoul-Henning Kamp 
7932616144eSDag-Erling Smørgrav 	sb = sbuf_new_auto();
7943a3fcd72SPoul-Henning Kamp 	sbuf_printf(sb, "ccd%d: %d components ", sc->sc_unit, *nprovider);
7953a3fcd72SPoul-Henning Kamp 	for (i = 0; i < *nprovider; i++) {
7963a3fcd72SPoul-Henning Kamp 		sbuf_printf(sb, "%s%s",
7973a3fcd72SPoul-Henning Kamp 		    i == 0 ? "(" : ", ",
7983a3fcd72SPoul-Henning Kamp 		    sc->sc_cinfo[i].ci_provider->name);
7993a3fcd72SPoul-Henning Kamp 	}
8003a3fcd72SPoul-Henning Kamp 	sbuf_printf(sb, "), %jd blocks ", (off_t)pp->mediasize / DEV_BSIZE);
8013a3fcd72SPoul-Henning Kamp 	if (sc->sc_ileave != 0)
8023a3fcd72SPoul-Henning Kamp 		sbuf_printf(sb, "interleaved at %d blocks\n",
8033a3fcd72SPoul-Henning Kamp 			sc->sc_ileave);
8043a3fcd72SPoul-Henning Kamp 	else
8053a3fcd72SPoul-Henning Kamp 		sbuf_printf(sb, "concatenated\n");
8063a3fcd72SPoul-Henning Kamp 	sbuf_finish(sb);
80741063f93SMarcel Moolenaar 	gctl_set_param_err(req, "output", sbuf_data(sb), sbuf_len(sb) + 1);
8083a3fcd72SPoul-Henning Kamp 	sbuf_delete(sb);
8093a3fcd72SPoul-Henning Kamp }
8103a3fcd72SPoul-Henning Kamp 
811f6367971SPoul-Henning Kamp static int
812f6367971SPoul-Henning Kamp g_ccd_destroy_geom(struct gctl_req *req, struct g_class *mp, struct g_geom *gp)
8133a3fcd72SPoul-Henning Kamp {
8143a3fcd72SPoul-Henning Kamp 	struct g_provider *pp;
8153a3fcd72SPoul-Henning Kamp 	struct ccd_s *sc;
8163a3fcd72SPoul-Henning Kamp 
8173a3fcd72SPoul-Henning Kamp 	g_topology_assert();
8183a3fcd72SPoul-Henning Kamp 	sc = gp->softc;
8193a3fcd72SPoul-Henning Kamp 	pp = LIST_FIRST(&gp->provider);
820f6367971SPoul-Henning Kamp 	if (sc == NULL || pp == NULL)
821f6367971SPoul-Henning Kamp 		return (EBUSY);
8223a3fcd72SPoul-Henning Kamp 	if (pp->acr != 0 || pp->acw != 0 || pp->ace != 0) {
8233a3fcd72SPoul-Henning Kamp 		gctl_error(req, "%s is open(r%dw%de%d)", gp->name,
8243a3fcd72SPoul-Henning Kamp 		    pp->acr, pp->acw, pp->ace);
825f6367971SPoul-Henning Kamp 		return (EBUSY);
8263a3fcd72SPoul-Henning Kamp 	}
8273a3fcd72SPoul-Henning Kamp 	g_ccd_freesc(sc);
8283a3fcd72SPoul-Henning Kamp 	gp->softc = NULL;
8293a3fcd72SPoul-Henning Kamp 	g_wither_geom(gp, ENXIO);
830f6367971SPoul-Henning Kamp 	return (0);
8313a3fcd72SPoul-Henning Kamp }
8323a3fcd72SPoul-Henning Kamp 
8333a3fcd72SPoul-Henning Kamp static void
8343a3fcd72SPoul-Henning Kamp g_ccd_list(struct gctl_req *req, struct g_class *mp)
8353a3fcd72SPoul-Henning Kamp {
8363a3fcd72SPoul-Henning Kamp 	struct sbuf *sb;
8373a3fcd72SPoul-Henning Kamp 	struct ccd_s *cs;
8383a3fcd72SPoul-Henning Kamp 	struct g_geom *gp;
8393a3fcd72SPoul-Henning Kamp 	int i, unit, *up;
8403a3fcd72SPoul-Henning Kamp 
8413a3fcd72SPoul-Henning Kamp 	up = gctl_get_paraml(req, "unit", sizeof (int));
8423a3fcd72SPoul-Henning Kamp 	unit = *up;
8432616144eSDag-Erling Smørgrav 	sb = sbuf_new_auto();
8443a3fcd72SPoul-Henning Kamp 	LIST_FOREACH(gp, &mp->geom, geom) {
8453a3fcd72SPoul-Henning Kamp 		cs = gp->softc;
84692b5e86eSPoul-Henning Kamp 		if (cs == NULL || (unit >= 0 && unit != cs->sc_unit))
8470f557e0aSPoul-Henning Kamp 			continue;
848189337d8SPoul-Henning Kamp 		sbuf_printf(sb, "ccd%d\t\t%d\t%d\t",
8493a3fcd72SPoul-Henning Kamp 		    cs->sc_unit, cs->sc_ileave, cs->sc_flags & CCDF_USERMASK);
850189337d8SPoul-Henning Kamp 
8513a3fcd72SPoul-Henning Kamp 		for (i = 0; i < cs->sc_ndisks; ++i) {
8523a3fcd72SPoul-Henning Kamp 			sbuf_printf(sb, "%s/dev/%s", i == 0 ? "" : " ",
8533a3fcd72SPoul-Henning Kamp 			    cs->sc_cinfo[i].ci_provider->name);
854189337d8SPoul-Henning Kamp 		}
855189337d8SPoul-Henning Kamp 		sbuf_printf(sb, "\n");
856189337d8SPoul-Henning Kamp 	}
857189337d8SPoul-Henning Kamp 	sbuf_finish(sb);
85841063f93SMarcel Moolenaar 	gctl_set_param_err(req, "output", sbuf_data(sb), sbuf_len(sb) + 1);
8593a3fcd72SPoul-Henning Kamp 	sbuf_delete(sb);
860189337d8SPoul-Henning Kamp }
861189337d8SPoul-Henning Kamp 
862189337d8SPoul-Henning Kamp static void
863189337d8SPoul-Henning Kamp g_ccd_config(struct gctl_req *req, struct g_class *mp, char const *verb)
864189337d8SPoul-Henning Kamp {
865f6367971SPoul-Henning Kamp 	struct g_geom *gp;
866189337d8SPoul-Henning Kamp 
867189337d8SPoul-Henning Kamp 	g_topology_assert();
868189337d8SPoul-Henning Kamp 	if (!strcmp(verb, "create geom")) {
8693a3fcd72SPoul-Henning Kamp 		g_ccd_create(req, mp);
870189337d8SPoul-Henning Kamp 	} else if (!strcmp(verb, "destroy geom")) {
871f6367971SPoul-Henning Kamp 		gp = gctl_get_geom(req, mp, "geom");
872f6367971SPoul-Henning Kamp 		if (gp != NULL)
873f6367971SPoul-Henning Kamp 		g_ccd_destroy_geom(req, mp, gp);
874189337d8SPoul-Henning Kamp 	} else if (!strcmp(verb, "list")) {
8753a3fcd72SPoul-Henning Kamp 		g_ccd_list(req, mp);
876189337d8SPoul-Henning Kamp 	} else {
877189337d8SPoul-Henning Kamp 		gctl_error(req, "unknown verb");
878189337d8SPoul-Henning Kamp 	}
879189337d8SPoul-Henning Kamp }
880189337d8SPoul-Henning Kamp 
881189337d8SPoul-Henning Kamp static struct g_class g_ccd_class = {
882189337d8SPoul-Henning Kamp 	.name = "CCD",
8835721c9c7SPoul-Henning Kamp 	.version = G_VERSION,
884189337d8SPoul-Henning Kamp 	.ctlreq = g_ccd_config,
885f6367971SPoul-Henning Kamp 	.destroy_geom = g_ccd_destroy_geom,
886650ee351SPoul-Henning Kamp 	.start = g_ccd_start,
887650ee351SPoul-Henning Kamp 	.orphan = g_ccd_orphan,
888650ee351SPoul-Henning Kamp 	.access = g_ccd_access,
889189337d8SPoul-Henning Kamp };
890189337d8SPoul-Henning Kamp 
891189337d8SPoul-Henning Kamp DECLARE_GEOM_CLASS(g_ccd_class, g_ccd);
892