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