119d16e2fSPawel Jakub Dawidek /*- 2e6890985SPawel Jakub Dawidek * Copyright (c) 2004-2005 Pawel Jakub Dawidek <pjd@FreeBSD.org> 319d16e2fSPawel Jakub Dawidek * All rights reserved. 419d16e2fSPawel Jakub Dawidek * 519d16e2fSPawel Jakub Dawidek * Redistribution and use in source and binary forms, with or without 619d16e2fSPawel Jakub Dawidek * modification, are permitted provided that the following conditions 719d16e2fSPawel Jakub Dawidek * are met: 819d16e2fSPawel Jakub Dawidek * 1. Redistributions of source code must retain the above copyright 919d16e2fSPawel Jakub Dawidek * notice, this list of conditions and the following disclaimer. 1019d16e2fSPawel Jakub Dawidek * 2. Redistributions in binary form must reproduce the above copyright 1119d16e2fSPawel Jakub Dawidek * notice, this list of conditions and the following disclaimer in the 1219d16e2fSPawel Jakub Dawidek * documentation and/or other materials provided with the distribution. 1319d16e2fSPawel Jakub Dawidek * 1419d16e2fSPawel Jakub Dawidek * THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND 1519d16e2fSPawel Jakub Dawidek * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 1619d16e2fSPawel Jakub Dawidek * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 1719d16e2fSPawel Jakub Dawidek * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE 1819d16e2fSPawel Jakub Dawidek * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 1919d16e2fSPawel Jakub Dawidek * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 2019d16e2fSPawel Jakub Dawidek * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 2119d16e2fSPawel Jakub Dawidek * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 2219d16e2fSPawel Jakub Dawidek * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 2319d16e2fSPawel Jakub Dawidek * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 2419d16e2fSPawel Jakub Dawidek * SUCH DAMAGE. 2519d16e2fSPawel Jakub Dawidek */ 2619d16e2fSPawel Jakub Dawidek 2719d16e2fSPawel Jakub Dawidek #include <sys/cdefs.h> 2819d16e2fSPawel Jakub Dawidek __FBSDID("$FreeBSD$"); 2919d16e2fSPawel Jakub Dawidek 3019d16e2fSPawel Jakub Dawidek #include <sys/param.h> 3119d16e2fSPawel Jakub Dawidek #include <sys/systm.h> 3219d16e2fSPawel Jakub Dawidek #include <sys/kernel.h> 3319d16e2fSPawel Jakub Dawidek #include <sys/module.h> 3419d16e2fSPawel Jakub Dawidek #include <sys/lock.h> 3519d16e2fSPawel Jakub Dawidek #include <sys/mutex.h> 3619d16e2fSPawel Jakub Dawidek #include <sys/bio.h> 3719d16e2fSPawel Jakub Dawidek #include <sys/sysctl.h> 3819d16e2fSPawel Jakub Dawidek #include <sys/malloc.h> 3919d16e2fSPawel Jakub Dawidek #include <geom/geom.h> 4019d16e2fSPawel Jakub Dawidek #include <geom/concat/g_concat.h> 4119d16e2fSPawel Jakub Dawidek 4219d16e2fSPawel Jakub Dawidek 435bb84bc8SRobert Watson static MALLOC_DEFINE(M_CONCAT, "concat_data", "GEOM_CONCAT Data"); 4419d16e2fSPawel Jakub Dawidek 45a88ae49fSPawel Jakub Dawidek SYSCTL_DECL(_kern_geom); 4619d16e2fSPawel Jakub Dawidek SYSCTL_NODE(_kern_geom, OID_AUTO, concat, CTLFLAG_RW, 0, "GEOM_CONCAT stuff"); 4719d16e2fSPawel Jakub Dawidek static u_int g_concat_debug = 0; 486d7b8aecSPawel Jakub Dawidek TUNABLE_INT("kern.geom.concat.debug", &g_concat_debug); 4919d16e2fSPawel Jakub Dawidek SYSCTL_UINT(_kern_geom_concat, OID_AUTO, debug, CTLFLAG_RW, &g_concat_debug, 0, 5019d16e2fSPawel Jakub Dawidek "Debug level"); 5119d16e2fSPawel Jakub Dawidek 5219d16e2fSPawel Jakub Dawidek static int g_concat_destroy(struct g_concat_softc *sc, boolean_t force); 5319d16e2fSPawel Jakub Dawidek static int g_concat_destroy_geom(struct gctl_req *req, struct g_class *mp, 5419d16e2fSPawel Jakub Dawidek struct g_geom *gp); 5519d16e2fSPawel Jakub Dawidek 5619d16e2fSPawel Jakub Dawidek static g_taste_t g_concat_taste; 5719d16e2fSPawel Jakub Dawidek static g_ctl_req_t g_concat_config; 5819d16e2fSPawel Jakub Dawidek static g_dumpconf_t g_concat_dumpconf; 5919d16e2fSPawel Jakub Dawidek 6019d16e2fSPawel Jakub Dawidek struct g_class g_concat_class = { 6119d16e2fSPawel Jakub Dawidek .name = G_CONCAT_CLASS_NAME, 625721c9c7SPoul-Henning Kamp .version = G_VERSION, 6319d16e2fSPawel Jakub Dawidek .ctlreq = g_concat_config, 6419d16e2fSPawel Jakub Dawidek .taste = g_concat_taste, 6519d16e2fSPawel Jakub Dawidek .destroy_geom = g_concat_destroy_geom 6619d16e2fSPawel Jakub Dawidek }; 6719d16e2fSPawel Jakub Dawidek 6819d16e2fSPawel Jakub Dawidek 6919d16e2fSPawel Jakub Dawidek /* 7048fbd94bSPawel Jakub Dawidek * Greatest Common Divisor. 7148fbd94bSPawel Jakub Dawidek */ 7248fbd94bSPawel Jakub Dawidek static u_int 7348fbd94bSPawel Jakub Dawidek gcd(u_int a, u_int b) 7448fbd94bSPawel Jakub Dawidek { 7548fbd94bSPawel Jakub Dawidek u_int c; 7648fbd94bSPawel Jakub Dawidek 7748fbd94bSPawel Jakub Dawidek while (b != 0) { 7848fbd94bSPawel Jakub Dawidek c = a; 7948fbd94bSPawel Jakub Dawidek a = b; 8048fbd94bSPawel Jakub Dawidek b = (c % b); 8148fbd94bSPawel Jakub Dawidek } 8248fbd94bSPawel Jakub Dawidek return (a); 8348fbd94bSPawel Jakub Dawidek } 8448fbd94bSPawel Jakub Dawidek 8548fbd94bSPawel Jakub Dawidek /* 8648fbd94bSPawel Jakub Dawidek * Least Common Multiple. 8748fbd94bSPawel Jakub Dawidek */ 8848fbd94bSPawel Jakub Dawidek static u_int 8948fbd94bSPawel Jakub Dawidek lcm(u_int a, u_int b) 9048fbd94bSPawel Jakub Dawidek { 9148fbd94bSPawel Jakub Dawidek 9248fbd94bSPawel Jakub Dawidek return ((a * b) / gcd(a, b)); 9348fbd94bSPawel Jakub Dawidek } 9448fbd94bSPawel Jakub Dawidek 9548fbd94bSPawel Jakub Dawidek /* 9619d16e2fSPawel Jakub Dawidek * Return the number of valid disks. 9719d16e2fSPawel Jakub Dawidek */ 9819d16e2fSPawel Jakub Dawidek static u_int 9919d16e2fSPawel Jakub Dawidek g_concat_nvalid(struct g_concat_softc *sc) 10019d16e2fSPawel Jakub Dawidek { 10119d16e2fSPawel Jakub Dawidek u_int i, no; 10219d16e2fSPawel Jakub Dawidek 10319d16e2fSPawel Jakub Dawidek no = 0; 10419d16e2fSPawel Jakub Dawidek for (i = 0; i < sc->sc_ndisks; i++) { 105a88ae49fSPawel Jakub Dawidek if (sc->sc_disks[i].d_consumer != NULL) 10619d16e2fSPawel Jakub Dawidek no++; 10719d16e2fSPawel Jakub Dawidek } 10819d16e2fSPawel Jakub Dawidek 10919d16e2fSPawel Jakub Dawidek return (no); 11019d16e2fSPawel Jakub Dawidek } 11119d16e2fSPawel Jakub Dawidek 11219d16e2fSPawel Jakub Dawidek static void 11319d16e2fSPawel Jakub Dawidek g_concat_remove_disk(struct g_concat_disk *disk) 11419d16e2fSPawel Jakub Dawidek { 11519d16e2fSPawel Jakub Dawidek struct g_consumer *cp; 11619d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 11719d16e2fSPawel Jakub Dawidek 118a88ae49fSPawel Jakub Dawidek KASSERT(disk->d_consumer != NULL, ("Non-valid disk in %s.", __func__)); 11919d16e2fSPawel Jakub Dawidek sc = disk->d_softc; 12019d16e2fSPawel Jakub Dawidek cp = disk->d_consumer; 12119d16e2fSPawel Jakub Dawidek 12202637cdcSPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Disk %s removed from %s.", cp->provider->name, 123ba385d00SPawel Jakub Dawidek sc->sc_name); 12419d16e2fSPawel Jakub Dawidek 125a88ae49fSPawel Jakub Dawidek disk->d_consumer = NULL; 12602637cdcSPawel Jakub Dawidek if (sc->sc_provider != NULL) { 1270499edf4SPawel Jakub Dawidek sc->sc_provider->flags |= G_PF_WITHER; 12802637cdcSPawel Jakub Dawidek g_orphan_provider(sc->sc_provider, ENXIO); 12902637cdcSPawel Jakub Dawidek sc->sc_provider = NULL; 130ba385d00SPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Device %s removed.", sc->sc_name); 13102637cdcSPawel Jakub Dawidek } 13219d16e2fSPawel Jakub Dawidek 13319d16e2fSPawel Jakub Dawidek if (cp->acr > 0 || cp->acw > 0 || cp->ace > 0) 13419d16e2fSPawel Jakub Dawidek g_access(cp, -cp->acr, -cp->acw, -cp->ace); 13519d16e2fSPawel Jakub Dawidek g_detach(cp); 13619d16e2fSPawel Jakub Dawidek g_destroy_consumer(cp); 13719d16e2fSPawel Jakub Dawidek } 13819d16e2fSPawel Jakub Dawidek 13919d16e2fSPawel Jakub Dawidek static void 14019d16e2fSPawel Jakub Dawidek g_concat_orphan(struct g_consumer *cp) 14119d16e2fSPawel Jakub Dawidek { 14219d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 14319d16e2fSPawel Jakub Dawidek struct g_concat_disk *disk; 14419d16e2fSPawel Jakub Dawidek struct g_geom *gp; 14519d16e2fSPawel Jakub Dawidek 14619d16e2fSPawel Jakub Dawidek g_topology_assert(); 14719d16e2fSPawel Jakub Dawidek gp = cp->geom; 14819d16e2fSPawel Jakub Dawidek sc = gp->softc; 14919d16e2fSPawel Jakub Dawidek if (sc == NULL) 15019d16e2fSPawel Jakub Dawidek return; 15119d16e2fSPawel Jakub Dawidek 15219d16e2fSPawel Jakub Dawidek disk = cp->private; 15319d16e2fSPawel Jakub Dawidek if (disk == NULL) /* Possible? */ 15419d16e2fSPawel Jakub Dawidek return; 15519d16e2fSPawel Jakub Dawidek g_concat_remove_disk(disk); 15619d16e2fSPawel Jakub Dawidek 15719d16e2fSPawel Jakub Dawidek /* If there are no valid disks anymore, remove device. */ 15819d16e2fSPawel Jakub Dawidek if (g_concat_nvalid(sc) == 0) 15919d16e2fSPawel Jakub Dawidek g_concat_destroy(sc, 1); 16019d16e2fSPawel Jakub Dawidek } 16119d16e2fSPawel Jakub Dawidek 16219d16e2fSPawel Jakub Dawidek static int 16319d16e2fSPawel Jakub Dawidek g_concat_access(struct g_provider *pp, int dr, int dw, int de) 16419d16e2fSPawel Jakub Dawidek { 16519d16e2fSPawel Jakub Dawidek struct g_consumer *cp1, *cp2; 16619d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 16719d16e2fSPawel Jakub Dawidek struct g_geom *gp; 16819d16e2fSPawel Jakub Dawidek int error; 16919d16e2fSPawel Jakub Dawidek 17019d16e2fSPawel Jakub Dawidek gp = pp->geom; 17119d16e2fSPawel Jakub Dawidek sc = gp->softc; 17219d16e2fSPawel Jakub Dawidek 17319d16e2fSPawel Jakub Dawidek if (sc == NULL) { 17419d16e2fSPawel Jakub Dawidek /* 17519d16e2fSPawel Jakub Dawidek * It looks like geom is being withered. 17619d16e2fSPawel Jakub Dawidek * In that case we allow only negative requests. 17719d16e2fSPawel Jakub Dawidek */ 17819d16e2fSPawel Jakub Dawidek KASSERT(dr <= 0 && dw <= 0 && de <= 0, 17919d16e2fSPawel Jakub Dawidek ("Positive access request (device=%s).", pp->name)); 18019d16e2fSPawel Jakub Dawidek if ((pp->acr + dr) == 0 && (pp->acw + dw) == 0 && 18119d16e2fSPawel Jakub Dawidek (pp->ace + de) == 0) { 18219d16e2fSPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Device %s definitely destroyed.", 18319d16e2fSPawel Jakub Dawidek gp->name); 18419d16e2fSPawel Jakub Dawidek } 18519d16e2fSPawel Jakub Dawidek return (0); 18619d16e2fSPawel Jakub Dawidek } 18719d16e2fSPawel Jakub Dawidek 18819d16e2fSPawel Jakub Dawidek /* On first open, grab an extra "exclusive" bit */ 18919d16e2fSPawel Jakub Dawidek if (pp->acr == 0 && pp->acw == 0 && pp->ace == 0) 19019d16e2fSPawel Jakub Dawidek de++; 19119d16e2fSPawel Jakub Dawidek /* ... and let go of it on last close */ 192be7695cfSPawel Jakub Dawidek if ((pp->acr + dr) == 0 && (pp->acw + dw) == 0 && (pp->ace + de) == 0) 19319d16e2fSPawel Jakub Dawidek de--; 19419d16e2fSPawel Jakub Dawidek 19519d16e2fSPawel Jakub Dawidek error = ENXIO; 19619d16e2fSPawel Jakub Dawidek LIST_FOREACH(cp1, &gp->consumer, consumer) { 19719d16e2fSPawel Jakub Dawidek error = g_access(cp1, dr, dw, de); 19819d16e2fSPawel Jakub Dawidek if (error == 0) 19919d16e2fSPawel Jakub Dawidek continue; 20019d16e2fSPawel Jakub Dawidek /* 20119d16e2fSPawel Jakub Dawidek * If we fail here, backout all previous changes. 20219d16e2fSPawel Jakub Dawidek */ 20319d16e2fSPawel Jakub Dawidek LIST_FOREACH(cp2, &gp->consumer, consumer) { 20419d16e2fSPawel Jakub Dawidek if (cp1 == cp2) 20519d16e2fSPawel Jakub Dawidek return (error); 20619d16e2fSPawel Jakub Dawidek g_access(cp2, -dr, -dw, -de); 20719d16e2fSPawel Jakub Dawidek } 20819d16e2fSPawel Jakub Dawidek /* NOTREACHED */ 20919d16e2fSPawel Jakub Dawidek } 21019d16e2fSPawel Jakub Dawidek 21119d16e2fSPawel Jakub Dawidek return (error); 21219d16e2fSPawel Jakub Dawidek } 21319d16e2fSPawel Jakub Dawidek 21419d16e2fSPawel Jakub Dawidek static void 215*659f684eSAlexander Motin g_concat_kernel_dump(struct bio *bp) 216*659f684eSAlexander Motin { 217*659f684eSAlexander Motin struct g_concat_softc *sc; 218*659f684eSAlexander Motin struct g_concat_disk *disk; 219*659f684eSAlexander Motin struct bio *cbp; 220*659f684eSAlexander Motin struct g_kerneldump *gkd; 221*659f684eSAlexander Motin u_int i; 222*659f684eSAlexander Motin 223*659f684eSAlexander Motin sc = bp->bio_to->geom->softc; 224*659f684eSAlexander Motin gkd = (struct g_kerneldump *)bp->bio_data; 225*659f684eSAlexander Motin for (i = 0; i < sc->sc_ndisks; i++) { 226*659f684eSAlexander Motin if (sc->sc_disks[i].d_start <= gkd->offset && 227*659f684eSAlexander Motin sc->sc_disks[i].d_end > gkd->offset) 228*659f684eSAlexander Motin break; 229*659f684eSAlexander Motin } 230*659f684eSAlexander Motin if (i == sc->sc_ndisks) 231*659f684eSAlexander Motin g_io_deliver(bp, EOPNOTSUPP); 232*659f684eSAlexander Motin disk = &sc->sc_disks[i]; 233*659f684eSAlexander Motin gkd->offset -= disk->d_start; 234*659f684eSAlexander Motin if (gkd->length > disk->d_end - disk->d_start - gkd->offset) 235*659f684eSAlexander Motin gkd->length = disk->d_end - disk->d_start - gkd->offset; 236*659f684eSAlexander Motin cbp = g_clone_bio(bp); 237*659f684eSAlexander Motin if (cbp == NULL) { 238*659f684eSAlexander Motin g_io_deliver(bp, ENOMEM); 239*659f684eSAlexander Motin return; 240*659f684eSAlexander Motin } 241*659f684eSAlexander Motin cbp->bio_done = g_std_done; 242*659f684eSAlexander Motin g_io_request(cbp, disk->d_consumer); 243*659f684eSAlexander Motin G_CONCAT_DEBUG(1, "Kernel dump will go to %s.", 244*659f684eSAlexander Motin disk->d_consumer->provider->name); 245*659f684eSAlexander Motin } 246*659f684eSAlexander Motin 247*659f684eSAlexander Motin static void 24842461fbaSPawel Jakub Dawidek g_concat_flush(struct g_concat_softc *sc, struct bio *bp) 24942461fbaSPawel Jakub Dawidek { 25042461fbaSPawel Jakub Dawidek struct bio_queue_head queue; 25142461fbaSPawel Jakub Dawidek struct g_consumer *cp; 25242461fbaSPawel Jakub Dawidek struct bio *cbp; 25342461fbaSPawel Jakub Dawidek u_int no; 25442461fbaSPawel Jakub Dawidek 25542461fbaSPawel Jakub Dawidek bioq_init(&queue); 25642461fbaSPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) { 25742461fbaSPawel Jakub Dawidek cbp = g_clone_bio(bp); 25842461fbaSPawel Jakub Dawidek if (cbp == NULL) { 25942461fbaSPawel Jakub Dawidek for (cbp = bioq_first(&queue); cbp != NULL; 26042461fbaSPawel Jakub Dawidek cbp = bioq_first(&queue)) { 26142461fbaSPawel Jakub Dawidek bioq_remove(&queue, cbp); 26242461fbaSPawel Jakub Dawidek g_destroy_bio(cbp); 26342461fbaSPawel Jakub Dawidek } 26442461fbaSPawel Jakub Dawidek if (bp->bio_error == 0) 26542461fbaSPawel Jakub Dawidek bp->bio_error = ENOMEM; 26642461fbaSPawel Jakub Dawidek g_io_deliver(bp, bp->bio_error); 26742461fbaSPawel Jakub Dawidek return; 26842461fbaSPawel Jakub Dawidek } 26942461fbaSPawel Jakub Dawidek bioq_insert_tail(&queue, cbp); 27042461fbaSPawel Jakub Dawidek cbp->bio_done = g_std_done; 27142461fbaSPawel Jakub Dawidek cbp->bio_caller1 = sc->sc_disks[no].d_consumer; 27242461fbaSPawel Jakub Dawidek cbp->bio_to = sc->sc_disks[no].d_consumer->provider; 27342461fbaSPawel Jakub Dawidek } 27442461fbaSPawel Jakub Dawidek for (cbp = bioq_first(&queue); cbp != NULL; cbp = bioq_first(&queue)) { 27542461fbaSPawel Jakub Dawidek bioq_remove(&queue, cbp); 27642461fbaSPawel Jakub Dawidek G_CONCAT_LOGREQ(cbp, "Sending request."); 27742461fbaSPawel Jakub Dawidek cp = cbp->bio_caller1; 27842461fbaSPawel Jakub Dawidek cbp->bio_caller1 = NULL; 27942461fbaSPawel Jakub Dawidek g_io_request(cbp, cp); 28042461fbaSPawel Jakub Dawidek } 28142461fbaSPawel Jakub Dawidek } 28242461fbaSPawel Jakub Dawidek 28342461fbaSPawel Jakub Dawidek static void 28419d16e2fSPawel Jakub Dawidek g_concat_start(struct bio *bp) 28519d16e2fSPawel Jakub Dawidek { 2867e0b3120SPawel Jakub Dawidek struct bio_queue_head queue; 28719d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 28819d16e2fSPawel Jakub Dawidek struct g_concat_disk *disk; 28919d16e2fSPawel Jakub Dawidek struct g_provider *pp; 29019d16e2fSPawel Jakub Dawidek off_t offset, end, length, off, len; 29119d16e2fSPawel Jakub Dawidek struct bio *cbp; 29219d16e2fSPawel Jakub Dawidek char *addr; 29319d16e2fSPawel Jakub Dawidek u_int no; 29419d16e2fSPawel Jakub Dawidek 29519d16e2fSPawel Jakub Dawidek pp = bp->bio_to; 29619d16e2fSPawel Jakub Dawidek sc = pp->geom->softc; 29719d16e2fSPawel Jakub Dawidek /* 29819d16e2fSPawel Jakub Dawidek * If sc == NULL, provider's error should be set and g_concat_start() 29919d16e2fSPawel Jakub Dawidek * should not be called at all. 30019d16e2fSPawel Jakub Dawidek */ 30119d16e2fSPawel Jakub Dawidek KASSERT(sc != NULL, 30219d16e2fSPawel Jakub Dawidek ("Provider's error should be set (error=%d)(device=%s).", 30319d16e2fSPawel Jakub Dawidek bp->bio_to->error, bp->bio_to->name)); 30419d16e2fSPawel Jakub Dawidek 30519d16e2fSPawel Jakub Dawidek G_CONCAT_LOGREQ(bp, "Request received."); 30619d16e2fSPawel Jakub Dawidek 30719d16e2fSPawel Jakub Dawidek switch (bp->bio_cmd) { 30819d16e2fSPawel Jakub Dawidek case BIO_READ: 30919d16e2fSPawel Jakub Dawidek case BIO_WRITE: 31019d16e2fSPawel Jakub Dawidek case BIO_DELETE: 31119d16e2fSPawel Jakub Dawidek break; 31242461fbaSPawel Jakub Dawidek case BIO_FLUSH: 31342461fbaSPawel Jakub Dawidek g_concat_flush(sc, bp); 31442461fbaSPawel Jakub Dawidek return; 31519d16e2fSPawel Jakub Dawidek case BIO_GETATTR: 316*659f684eSAlexander Motin if (strcmp("GEOM::kerneldump", bp->bio_attribute) == 0) { 317*659f684eSAlexander Motin g_concat_kernel_dump(bp); 318*659f684eSAlexander Motin return; 319*659f684eSAlexander Motin } 32019d16e2fSPawel Jakub Dawidek /* To which provider it should be delivered? */ 321*659f684eSAlexander Motin /* FALLTHROUGH */ 32219d16e2fSPawel Jakub Dawidek default: 32319d16e2fSPawel Jakub Dawidek g_io_deliver(bp, EOPNOTSUPP); 32419d16e2fSPawel Jakub Dawidek return; 32519d16e2fSPawel Jakub Dawidek } 32619d16e2fSPawel Jakub Dawidek 32719d16e2fSPawel Jakub Dawidek offset = bp->bio_offset; 32819d16e2fSPawel Jakub Dawidek length = bp->bio_length; 32919d16e2fSPawel Jakub Dawidek addr = bp->bio_data; 33019d16e2fSPawel Jakub Dawidek end = offset + length; 33119d16e2fSPawel Jakub Dawidek 3327e0b3120SPawel Jakub Dawidek bioq_init(&queue); 33319d16e2fSPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) { 33419d16e2fSPawel Jakub Dawidek disk = &sc->sc_disks[no]; 33519d16e2fSPawel Jakub Dawidek if (disk->d_end <= offset) 33619d16e2fSPawel Jakub Dawidek continue; 33719d16e2fSPawel Jakub Dawidek if (disk->d_start >= end) 33819d16e2fSPawel Jakub Dawidek break; 33919d16e2fSPawel Jakub Dawidek 34019d16e2fSPawel Jakub Dawidek off = offset - disk->d_start; 34119d16e2fSPawel Jakub Dawidek len = MIN(length, disk->d_end - offset); 34219d16e2fSPawel Jakub Dawidek length -= len; 34319d16e2fSPawel Jakub Dawidek offset += len; 34419d16e2fSPawel Jakub Dawidek 34519d16e2fSPawel Jakub Dawidek cbp = g_clone_bio(bp); 34619d16e2fSPawel Jakub Dawidek if (cbp == NULL) { 3477e0b3120SPawel Jakub Dawidek for (cbp = bioq_first(&queue); cbp != NULL; 3487e0b3120SPawel Jakub Dawidek cbp = bioq_first(&queue)) { 3497e0b3120SPawel Jakub Dawidek bioq_remove(&queue, cbp); 3507e0b3120SPawel Jakub Dawidek g_destroy_bio(cbp); 3517e0b3120SPawel Jakub Dawidek } 35219d16e2fSPawel Jakub Dawidek if (bp->bio_error == 0) 35319d16e2fSPawel Jakub Dawidek bp->bio_error = ENOMEM; 3547e0b3120SPawel Jakub Dawidek g_io_deliver(bp, bp->bio_error); 35519d16e2fSPawel Jakub Dawidek return; 35619d16e2fSPawel Jakub Dawidek } 3577e0b3120SPawel Jakub Dawidek bioq_insert_tail(&queue, cbp); 35819d16e2fSPawel Jakub Dawidek /* 35919d16e2fSPawel Jakub Dawidek * Fill in the component buf structure. 36019d16e2fSPawel Jakub Dawidek */ 36119d16e2fSPawel Jakub Dawidek cbp->bio_done = g_std_done; 36219d16e2fSPawel Jakub Dawidek cbp->bio_offset = off; 36319d16e2fSPawel Jakub Dawidek cbp->bio_data = addr; 36419d16e2fSPawel Jakub Dawidek addr += len; 36519d16e2fSPawel Jakub Dawidek cbp->bio_length = len; 36619d16e2fSPawel Jakub Dawidek cbp->bio_to = disk->d_consumer->provider; 3677e0b3120SPawel Jakub Dawidek cbp->bio_caller1 = disk; 36819d16e2fSPawel Jakub Dawidek 36919d16e2fSPawel Jakub Dawidek if (length == 0) 37019d16e2fSPawel Jakub Dawidek break; 37119d16e2fSPawel Jakub Dawidek } 37219d16e2fSPawel Jakub Dawidek KASSERT(length == 0, 37319d16e2fSPawel Jakub Dawidek ("Length is still greater than 0 (class=%s, name=%s).", 37419d16e2fSPawel Jakub Dawidek bp->bio_to->geom->class->name, bp->bio_to->geom->name)); 3757e0b3120SPawel Jakub Dawidek for (cbp = bioq_first(&queue); cbp != NULL; cbp = bioq_first(&queue)) { 3767e0b3120SPawel Jakub Dawidek bioq_remove(&queue, cbp); 3777e0b3120SPawel Jakub Dawidek G_CONCAT_LOGREQ(cbp, "Sending request."); 3787e0b3120SPawel Jakub Dawidek disk = cbp->bio_caller1; 3797e0b3120SPawel Jakub Dawidek cbp->bio_caller1 = NULL; 3807e0b3120SPawel Jakub Dawidek g_io_request(cbp, disk->d_consumer); 3817e0b3120SPawel Jakub Dawidek } 38219d16e2fSPawel Jakub Dawidek } 38319d16e2fSPawel Jakub Dawidek 38419d16e2fSPawel Jakub Dawidek static void 38519d16e2fSPawel Jakub Dawidek g_concat_check_and_run(struct g_concat_softc *sc) 38619d16e2fSPawel Jakub Dawidek { 38719d16e2fSPawel Jakub Dawidek struct g_concat_disk *disk; 3885f9b1143SAlexander Motin struct g_provider *pp; 38948fbd94bSPawel Jakub Dawidek u_int no, sectorsize = 0; 39019d16e2fSPawel Jakub Dawidek off_t start; 39119d16e2fSPawel Jakub Dawidek 39219d16e2fSPawel Jakub Dawidek if (g_concat_nvalid(sc) != sc->sc_ndisks) 39319d16e2fSPawel Jakub Dawidek return; 39419d16e2fSPawel Jakub Dawidek 3955f9b1143SAlexander Motin pp = g_new_providerf(sc->sc_geom, "concat/%s", sc->sc_name); 39619d16e2fSPawel Jakub Dawidek start = 0; 39719d16e2fSPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) { 39819d16e2fSPawel Jakub Dawidek disk = &sc->sc_disks[no]; 39919d16e2fSPawel Jakub Dawidek disk->d_start = start; 40019d16e2fSPawel Jakub Dawidek disk->d_end = disk->d_start + 40119d16e2fSPawel Jakub Dawidek disk->d_consumer->provider->mediasize; 40219d16e2fSPawel Jakub Dawidek if (sc->sc_type == G_CONCAT_TYPE_AUTOMATIC) 40319d16e2fSPawel Jakub Dawidek disk->d_end -= disk->d_consumer->provider->sectorsize; 40419d16e2fSPawel Jakub Dawidek start = disk->d_end; 40548fbd94bSPawel Jakub Dawidek if (no == 0) 40648fbd94bSPawel Jakub Dawidek sectorsize = disk->d_consumer->provider->sectorsize; 40748fbd94bSPawel Jakub Dawidek else { 40848fbd94bSPawel Jakub Dawidek sectorsize = lcm(sectorsize, 40948fbd94bSPawel Jakub Dawidek disk->d_consumer->provider->sectorsize); 41019d16e2fSPawel Jakub Dawidek } 41148fbd94bSPawel Jakub Dawidek } 4125f9b1143SAlexander Motin pp->sectorsize = sectorsize; 41319d16e2fSPawel Jakub Dawidek /* We have sc->sc_disks[sc->sc_ndisks - 1].d_end in 'start'. */ 4145f9b1143SAlexander Motin pp->mediasize = start; 4155f9b1143SAlexander Motin pp->stripesize = sc->sc_disks[0].d_consumer->provider->stripesize; 4165f9b1143SAlexander Motin pp->stripeoffset = sc->sc_disks[0].d_consumer->provider->stripeoffset; 4175f9b1143SAlexander Motin sc->sc_provider = pp; 4185f9b1143SAlexander Motin g_error_provider(pp, 0); 41919d16e2fSPawel Jakub Dawidek 420ba385d00SPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Device %s activated.", sc->sc_name); 42119d16e2fSPawel Jakub Dawidek } 42219d16e2fSPawel Jakub Dawidek 42319d16e2fSPawel Jakub Dawidek static int 42419d16e2fSPawel Jakub Dawidek g_concat_read_metadata(struct g_consumer *cp, struct g_concat_metadata *md) 42519d16e2fSPawel Jakub Dawidek { 42619d16e2fSPawel Jakub Dawidek struct g_provider *pp; 42719d16e2fSPawel Jakub Dawidek u_char *buf; 42819d16e2fSPawel Jakub Dawidek int error; 42919d16e2fSPawel Jakub Dawidek 43019d16e2fSPawel Jakub Dawidek g_topology_assert(); 43119d16e2fSPawel Jakub Dawidek 43219d16e2fSPawel Jakub Dawidek error = g_access(cp, 1, 0, 0); 43319d16e2fSPawel Jakub Dawidek if (error != 0) 43419d16e2fSPawel Jakub Dawidek return (error); 43519d16e2fSPawel Jakub Dawidek pp = cp->provider; 43619d16e2fSPawel Jakub Dawidek g_topology_unlock(); 43719d16e2fSPawel Jakub Dawidek buf = g_read_data(cp, pp->mediasize - pp->sectorsize, pp->sectorsize, 43819d16e2fSPawel Jakub Dawidek &error); 43919d16e2fSPawel Jakub Dawidek g_topology_lock(); 44019d16e2fSPawel Jakub Dawidek g_access(cp, -1, 0, 0); 44119d16e2fSPawel Jakub Dawidek if (buf == NULL) 44219d16e2fSPawel Jakub Dawidek return (error); 44319d16e2fSPawel Jakub Dawidek 44419d16e2fSPawel Jakub Dawidek /* Decode metadata. */ 44519d16e2fSPawel Jakub Dawidek concat_metadata_decode(buf, md); 44619d16e2fSPawel Jakub Dawidek g_free(buf); 44719d16e2fSPawel Jakub Dawidek 44819d16e2fSPawel Jakub Dawidek return (0); 44919d16e2fSPawel Jakub Dawidek } 45019d16e2fSPawel Jakub Dawidek 45119d16e2fSPawel Jakub Dawidek /* 45219d16e2fSPawel Jakub Dawidek * Add disk to given device. 45319d16e2fSPawel Jakub Dawidek */ 45419d16e2fSPawel Jakub Dawidek static int 45519d16e2fSPawel Jakub Dawidek g_concat_add_disk(struct g_concat_softc *sc, struct g_provider *pp, u_int no) 45619d16e2fSPawel Jakub Dawidek { 45719d16e2fSPawel Jakub Dawidek struct g_concat_disk *disk; 45802637cdcSPawel Jakub Dawidek struct g_consumer *cp, *fcp; 45919d16e2fSPawel Jakub Dawidek struct g_geom *gp; 46019d16e2fSPawel Jakub Dawidek int error; 46119d16e2fSPawel Jakub Dawidek 46219d16e2fSPawel Jakub Dawidek /* Metadata corrupted? */ 46319d16e2fSPawel Jakub Dawidek if (no >= sc->sc_ndisks) 46419d16e2fSPawel Jakub Dawidek return (EINVAL); 46519d16e2fSPawel Jakub Dawidek 46619d16e2fSPawel Jakub Dawidek disk = &sc->sc_disks[no]; 46719d16e2fSPawel Jakub Dawidek /* Check if disk is not already attached. */ 468a88ae49fSPawel Jakub Dawidek if (disk->d_consumer != NULL) 46919d16e2fSPawel Jakub Dawidek return (EEXIST); 47019d16e2fSPawel Jakub Dawidek 47102637cdcSPawel Jakub Dawidek gp = sc->sc_geom; 47202637cdcSPawel Jakub Dawidek fcp = LIST_FIRST(&gp->consumer); 47319d16e2fSPawel Jakub Dawidek 47419d16e2fSPawel Jakub Dawidek cp = g_new_consumer(gp); 47519d16e2fSPawel Jakub Dawidek error = g_attach(cp, pp); 47619d16e2fSPawel Jakub Dawidek if (error != 0) { 47719d16e2fSPawel Jakub Dawidek g_destroy_consumer(cp); 47819d16e2fSPawel Jakub Dawidek return (error); 47919d16e2fSPawel Jakub Dawidek } 48019d16e2fSPawel Jakub Dawidek 48102637cdcSPawel Jakub Dawidek if (fcp != NULL && (fcp->acr > 0 || fcp->acw > 0 || fcp->ace > 0)) { 48202637cdcSPawel Jakub Dawidek error = g_access(cp, fcp->acr, fcp->acw, fcp->ace); 48319d16e2fSPawel Jakub Dawidek if (error != 0) { 48419d16e2fSPawel Jakub Dawidek g_detach(cp); 48519d16e2fSPawel Jakub Dawidek g_destroy_consumer(cp); 48619d16e2fSPawel Jakub Dawidek return (error); 48719d16e2fSPawel Jakub Dawidek } 48819d16e2fSPawel Jakub Dawidek } 48919d16e2fSPawel Jakub Dawidek if (sc->sc_type == G_CONCAT_TYPE_AUTOMATIC) { 49019d16e2fSPawel Jakub Dawidek struct g_concat_metadata md; 49119d16e2fSPawel Jakub Dawidek 49248fbd94bSPawel Jakub Dawidek /* Re-read metadata. */ 49319d16e2fSPawel Jakub Dawidek error = g_concat_read_metadata(cp, &md); 49419d16e2fSPawel Jakub Dawidek if (error != 0) 49519d16e2fSPawel Jakub Dawidek goto fail; 49619d16e2fSPawel Jakub Dawidek 49719d16e2fSPawel Jakub Dawidek if (strcmp(md.md_magic, G_CONCAT_MAGIC) != 0 || 49819d16e2fSPawel Jakub Dawidek strcmp(md.md_name, sc->sc_name) != 0 || 49919d16e2fSPawel Jakub Dawidek md.md_id != sc->sc_id) { 50019d16e2fSPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Metadata on %s changed.", pp->name); 50119d16e2fSPawel Jakub Dawidek goto fail; 50219d16e2fSPawel Jakub Dawidek } 50319d16e2fSPawel Jakub Dawidek } 50419d16e2fSPawel Jakub Dawidek 50519d16e2fSPawel Jakub Dawidek cp->private = disk; 50619d16e2fSPawel Jakub Dawidek disk->d_consumer = cp; 50719d16e2fSPawel Jakub Dawidek disk->d_softc = sc; 50819d16e2fSPawel Jakub Dawidek disk->d_start = 0; /* not yet */ 50919d16e2fSPawel Jakub Dawidek disk->d_end = 0; /* not yet */ 51019d16e2fSPawel Jakub Dawidek 511ba385d00SPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Disk %s attached to %s.", pp->name, sc->sc_name); 51219d16e2fSPawel Jakub Dawidek 51319d16e2fSPawel Jakub Dawidek g_concat_check_and_run(sc); 51419d16e2fSPawel Jakub Dawidek 51519d16e2fSPawel Jakub Dawidek return (0); 51619d16e2fSPawel Jakub Dawidek fail: 51702637cdcSPawel Jakub Dawidek if (fcp != NULL && (fcp->acr > 0 || fcp->acw > 0 || fcp->ace > 0)) 51802637cdcSPawel Jakub Dawidek g_access(cp, -fcp->acr, -fcp->acw, -fcp->ace); 51919d16e2fSPawel Jakub Dawidek g_detach(cp); 52019d16e2fSPawel Jakub Dawidek g_destroy_consumer(cp); 52119d16e2fSPawel Jakub Dawidek return (error); 52219d16e2fSPawel Jakub Dawidek } 52319d16e2fSPawel Jakub Dawidek 52419d16e2fSPawel Jakub Dawidek static struct g_geom * 52519d16e2fSPawel Jakub Dawidek g_concat_create(struct g_class *mp, const struct g_concat_metadata *md, 52648fbd94bSPawel Jakub Dawidek u_int type) 52719d16e2fSPawel Jakub Dawidek { 52819d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 52919d16e2fSPawel Jakub Dawidek struct g_geom *gp; 53019d16e2fSPawel Jakub Dawidek u_int no; 53119d16e2fSPawel Jakub Dawidek 532ba385d00SPawel Jakub Dawidek G_CONCAT_DEBUG(1, "Creating device %s (id=%u).", md->md_name, 53319d16e2fSPawel Jakub Dawidek md->md_id); 53419d16e2fSPawel Jakub Dawidek 535aaf8e186SPawel Jakub Dawidek /* One disks is minimum. */ 536aaf8e186SPawel Jakub Dawidek if (md->md_all < 1) 53719d16e2fSPawel Jakub Dawidek return (NULL); 53819d16e2fSPawel Jakub Dawidek 53919d16e2fSPawel Jakub Dawidek /* Check for duplicate unit */ 54019d16e2fSPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) { 54119d16e2fSPawel Jakub Dawidek sc = gp->softc; 54219d16e2fSPawel Jakub Dawidek if (sc != NULL && strcmp(sc->sc_name, md->md_name) == 0) { 54302637cdcSPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Device %s already configured.", 54419d16e2fSPawel Jakub Dawidek gp->name); 54519d16e2fSPawel Jakub Dawidek return (NULL); 54619d16e2fSPawel Jakub Dawidek } 54719d16e2fSPawel Jakub Dawidek } 548ba385d00SPawel Jakub Dawidek gp = g_new_geomf(mp, "%s", md->md_name); 54919d16e2fSPawel Jakub Dawidek gp->softc = NULL; /* for a moment */ 55019d16e2fSPawel Jakub Dawidek 55175cc259dSPawel Jakub Dawidek sc = malloc(sizeof(*sc), M_CONCAT, M_WAITOK | M_ZERO); 55219d16e2fSPawel Jakub Dawidek gp->start = g_concat_start; 55319d16e2fSPawel Jakub Dawidek gp->spoiled = g_concat_orphan; 55419d16e2fSPawel Jakub Dawidek gp->orphan = g_concat_orphan; 55519d16e2fSPawel Jakub Dawidek gp->access = g_concat_access; 55619d16e2fSPawel Jakub Dawidek gp->dumpconf = g_concat_dumpconf; 55719d16e2fSPawel Jakub Dawidek 55819d16e2fSPawel Jakub Dawidek sc->sc_id = md->md_id; 55919d16e2fSPawel Jakub Dawidek sc->sc_ndisks = md->md_all; 56019d16e2fSPawel Jakub Dawidek sc->sc_disks = malloc(sizeof(struct g_concat_disk) * sc->sc_ndisks, 56119d16e2fSPawel Jakub Dawidek M_CONCAT, M_WAITOK | M_ZERO); 56219d16e2fSPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) 563a88ae49fSPawel Jakub Dawidek sc->sc_disks[no].d_consumer = NULL; 56419d16e2fSPawel Jakub Dawidek sc->sc_type = type; 56519d16e2fSPawel Jakub Dawidek 56619d16e2fSPawel Jakub Dawidek gp->softc = sc; 56702637cdcSPawel Jakub Dawidek sc->sc_geom = gp; 56802637cdcSPawel Jakub Dawidek sc->sc_provider = NULL; 56919d16e2fSPawel Jakub Dawidek 570ba385d00SPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Device %s created (id=%u).", sc->sc_name, sc->sc_id); 57119d16e2fSPawel Jakub Dawidek 57219d16e2fSPawel Jakub Dawidek return (gp); 57319d16e2fSPawel Jakub Dawidek } 57419d16e2fSPawel Jakub Dawidek 57519d16e2fSPawel Jakub Dawidek static int 57619d16e2fSPawel Jakub Dawidek g_concat_destroy(struct g_concat_softc *sc, boolean_t force) 57719d16e2fSPawel Jakub Dawidek { 57819d16e2fSPawel Jakub Dawidek struct g_provider *pp; 57919d16e2fSPawel Jakub Dawidek struct g_geom *gp; 58019d16e2fSPawel Jakub Dawidek u_int no; 58119d16e2fSPawel Jakub Dawidek 58219d16e2fSPawel Jakub Dawidek g_topology_assert(); 58319d16e2fSPawel Jakub Dawidek 58419d16e2fSPawel Jakub Dawidek if (sc == NULL) 58519d16e2fSPawel Jakub Dawidek return (ENXIO); 58619d16e2fSPawel Jakub Dawidek 58719d16e2fSPawel Jakub Dawidek pp = sc->sc_provider; 58802637cdcSPawel Jakub Dawidek if (pp != NULL && (pp->acr != 0 || pp->acw != 0 || pp->ace != 0)) { 58919d16e2fSPawel Jakub Dawidek if (force) { 59019d16e2fSPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Device %s is still open, so it " 59102637cdcSPawel Jakub Dawidek "can't be definitely removed.", pp->name); 59219d16e2fSPawel Jakub Dawidek } else { 59319d16e2fSPawel Jakub Dawidek G_CONCAT_DEBUG(1, 59402637cdcSPawel Jakub Dawidek "Device %s is still open (r%dw%de%d).", pp->name, 59502637cdcSPawel Jakub Dawidek pp->acr, pp->acw, pp->ace); 59619d16e2fSPawel Jakub Dawidek return (EBUSY); 59719d16e2fSPawel Jakub Dawidek } 59819d16e2fSPawel Jakub Dawidek } 59919d16e2fSPawel Jakub Dawidek 60019d16e2fSPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) { 601a88ae49fSPawel Jakub Dawidek if (sc->sc_disks[no].d_consumer != NULL) 60219d16e2fSPawel Jakub Dawidek g_concat_remove_disk(&sc->sc_disks[no]); 60319d16e2fSPawel Jakub Dawidek } 60419d16e2fSPawel Jakub Dawidek 60502637cdcSPawel Jakub Dawidek gp = sc->sc_geom; 60619d16e2fSPawel Jakub Dawidek gp->softc = NULL; 60702637cdcSPawel Jakub Dawidek KASSERT(sc->sc_provider == NULL, ("Provider still exists? (device=%s)", 60802637cdcSPawel Jakub Dawidek gp->name)); 60919d16e2fSPawel Jakub Dawidek free(sc->sc_disks, M_CONCAT); 61019d16e2fSPawel Jakub Dawidek free(sc, M_CONCAT); 61119d16e2fSPawel Jakub Dawidek 61202637cdcSPawel Jakub Dawidek pp = LIST_FIRST(&gp->provider); 61302637cdcSPawel Jakub Dawidek if (pp == NULL || (pp->acr == 0 && pp->acw == 0 && pp->ace == 0)) 61402637cdcSPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Device %s destroyed.", gp->name); 61502637cdcSPawel Jakub Dawidek 61619d16e2fSPawel Jakub Dawidek g_wither_geom(gp, ENXIO); 61719d16e2fSPawel Jakub Dawidek 61819d16e2fSPawel Jakub Dawidek return (0); 61919d16e2fSPawel Jakub Dawidek } 62019d16e2fSPawel Jakub Dawidek 62119d16e2fSPawel Jakub Dawidek static int 62248fbd94bSPawel Jakub Dawidek g_concat_destroy_geom(struct gctl_req *req __unused, 62348fbd94bSPawel Jakub Dawidek struct g_class *mp __unused, struct g_geom *gp) 62419d16e2fSPawel Jakub Dawidek { 62519d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 62619d16e2fSPawel Jakub Dawidek 62719d16e2fSPawel Jakub Dawidek sc = gp->softc; 62819d16e2fSPawel Jakub Dawidek return (g_concat_destroy(sc, 0)); 62919d16e2fSPawel Jakub Dawidek } 63019d16e2fSPawel Jakub Dawidek 63119d16e2fSPawel Jakub Dawidek static struct g_geom * 63219d16e2fSPawel Jakub Dawidek g_concat_taste(struct g_class *mp, struct g_provider *pp, int flags __unused) 63319d16e2fSPawel Jakub Dawidek { 63419d16e2fSPawel Jakub Dawidek struct g_concat_metadata md; 63519d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 63619d16e2fSPawel Jakub Dawidek struct g_consumer *cp; 63719d16e2fSPawel Jakub Dawidek struct g_geom *gp; 63819d16e2fSPawel Jakub Dawidek int error; 63919d16e2fSPawel Jakub Dawidek 64002637cdcSPawel Jakub Dawidek g_trace(G_T_TOPOLOGY, "%s(%s, %s)", __func__, mp->name, pp->name); 64119d16e2fSPawel Jakub Dawidek g_topology_assert(); 64219d16e2fSPawel Jakub Dawidek 643f8727e71SPawel Jakub Dawidek /* Skip providers that are already open for writing. */ 644f8727e71SPawel Jakub Dawidek if (pp->acw > 0) 645f8727e71SPawel Jakub Dawidek return (NULL); 646f8727e71SPawel Jakub Dawidek 64719d16e2fSPawel Jakub Dawidek G_CONCAT_DEBUG(3, "Tasting %s.", pp->name); 64819d16e2fSPawel Jakub Dawidek 64919d16e2fSPawel Jakub Dawidek gp = g_new_geomf(mp, "concat:taste"); 65019d16e2fSPawel Jakub Dawidek gp->start = g_concat_start; 65119d16e2fSPawel Jakub Dawidek gp->access = g_concat_access; 6520e2ff283SPawel Jakub Dawidek gp->orphan = g_concat_orphan; 65319d16e2fSPawel Jakub Dawidek cp = g_new_consumer(gp); 65419d16e2fSPawel Jakub Dawidek g_attach(cp, pp); 65519d16e2fSPawel Jakub Dawidek error = g_concat_read_metadata(cp, &md); 6567e72a708SPawel Jakub Dawidek g_detach(cp); 6577e72a708SPawel Jakub Dawidek g_destroy_consumer(cp); 6587e72a708SPawel Jakub Dawidek g_destroy_geom(gp); 65902637cdcSPawel Jakub Dawidek if (error != 0) 66019d16e2fSPawel Jakub Dawidek return (NULL); 66119d16e2fSPawel Jakub Dawidek gp = NULL; 66219d16e2fSPawel Jakub Dawidek 66319d16e2fSPawel Jakub Dawidek if (strcmp(md.md_magic, G_CONCAT_MAGIC) != 0) 66419d16e2fSPawel Jakub Dawidek return (NULL); 66519d16e2fSPawel Jakub Dawidek if (md.md_version > G_CONCAT_VERSION) { 66619d16e2fSPawel Jakub Dawidek printf("geom_concat.ko module is too old to handle %s.\n", 66719d16e2fSPawel Jakub Dawidek pp->name); 66819d16e2fSPawel Jakub Dawidek return (NULL); 66919d16e2fSPawel Jakub Dawidek } 6706c74f517SPawel Jakub Dawidek /* 6716c74f517SPawel Jakub Dawidek * Backward compatibility: 6726c74f517SPawel Jakub Dawidek */ 673e6890985SPawel Jakub Dawidek /* There was no md_provider field in earlier versions of metadata. */ 6746c74f517SPawel Jakub Dawidek if (md.md_version < 3) 6756c74f517SPawel Jakub Dawidek bzero(md.md_provider, sizeof(md.md_provider)); 676e6890985SPawel Jakub Dawidek /* There was no md_provsize field in earlier versions of metadata. */ 677e6890985SPawel Jakub Dawidek if (md.md_version < 4) 678e6890985SPawel Jakub Dawidek md.md_provsize = pp->mediasize; 6796c74f517SPawel Jakub Dawidek 6806c74f517SPawel Jakub Dawidek if (md.md_provider[0] != '\0' && strcmp(md.md_provider, pp->name) != 0) 6816c74f517SPawel Jakub Dawidek return (NULL); 682e6890985SPawel Jakub Dawidek if (md.md_provsize != pp->mediasize) 683e6890985SPawel Jakub Dawidek return (NULL); 68419d16e2fSPawel Jakub Dawidek 68519d16e2fSPawel Jakub Dawidek /* 68619d16e2fSPawel Jakub Dawidek * Let's check if device already exists. 68719d16e2fSPawel Jakub Dawidek */ 688c2496c87SPawel Jakub Dawidek sc = NULL; 68919d16e2fSPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) { 69019d16e2fSPawel Jakub Dawidek sc = gp->softc; 69119d16e2fSPawel Jakub Dawidek if (sc == NULL) 69219d16e2fSPawel Jakub Dawidek continue; 69319d16e2fSPawel Jakub Dawidek if (sc->sc_type != G_CONCAT_TYPE_AUTOMATIC) 69419d16e2fSPawel Jakub Dawidek continue; 69519d16e2fSPawel Jakub Dawidek if (strcmp(md.md_name, sc->sc_name) != 0) 69619d16e2fSPawel Jakub Dawidek continue; 69719d16e2fSPawel Jakub Dawidek if (md.md_id != sc->sc_id) 69819d16e2fSPawel Jakub Dawidek continue; 69919d16e2fSPawel Jakub Dawidek break; 70019d16e2fSPawel Jakub Dawidek } 70119d16e2fSPawel Jakub Dawidek if (gp != NULL) { 70219d16e2fSPawel Jakub Dawidek G_CONCAT_DEBUG(1, "Adding disk %s to %s.", pp->name, gp->name); 70319d16e2fSPawel Jakub Dawidek error = g_concat_add_disk(sc, pp, md.md_no); 70419d16e2fSPawel Jakub Dawidek if (error != 0) { 70502637cdcSPawel Jakub Dawidek G_CONCAT_DEBUG(0, 70602637cdcSPawel Jakub Dawidek "Cannot add disk %s to %s (error=%d).", pp->name, 70702637cdcSPawel Jakub Dawidek gp->name, error); 70819d16e2fSPawel Jakub Dawidek return (NULL); 70919d16e2fSPawel Jakub Dawidek } 71019d16e2fSPawel Jakub Dawidek } else { 71148fbd94bSPawel Jakub Dawidek gp = g_concat_create(mp, &md, G_CONCAT_TYPE_AUTOMATIC); 71219d16e2fSPawel Jakub Dawidek if (gp == NULL) { 713ba385d00SPawel Jakub Dawidek G_CONCAT_DEBUG(0, "Cannot create device %s.", 71419d16e2fSPawel Jakub Dawidek md.md_name); 71519d16e2fSPawel Jakub Dawidek return (NULL); 71619d16e2fSPawel Jakub Dawidek } 71719d16e2fSPawel Jakub Dawidek sc = gp->softc; 71819d16e2fSPawel Jakub Dawidek G_CONCAT_DEBUG(1, "Adding disk %s to %s.", pp->name, gp->name); 71919d16e2fSPawel Jakub Dawidek error = g_concat_add_disk(sc, pp, md.md_no); 72019d16e2fSPawel Jakub Dawidek if (error != 0) { 72102637cdcSPawel Jakub Dawidek G_CONCAT_DEBUG(0, 72202637cdcSPawel Jakub Dawidek "Cannot add disk %s to %s (error=%d).", pp->name, 72302637cdcSPawel Jakub Dawidek gp->name, error); 72419d16e2fSPawel Jakub Dawidek g_concat_destroy(sc, 1); 72519d16e2fSPawel Jakub Dawidek return (NULL); 72619d16e2fSPawel Jakub Dawidek } 72719d16e2fSPawel Jakub Dawidek } 72819d16e2fSPawel Jakub Dawidek 72919d16e2fSPawel Jakub Dawidek return (gp); 73019d16e2fSPawel Jakub Dawidek } 73119d16e2fSPawel Jakub Dawidek 73219d16e2fSPawel Jakub Dawidek static void 73319d16e2fSPawel Jakub Dawidek g_concat_ctl_create(struct gctl_req *req, struct g_class *mp) 73419d16e2fSPawel Jakub Dawidek { 73519d16e2fSPawel Jakub Dawidek u_int attached, no; 73602637cdcSPawel Jakub Dawidek struct g_concat_metadata md; 73719d16e2fSPawel Jakub Dawidek struct g_provider *pp; 73819d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 73919d16e2fSPawel Jakub Dawidek struct g_geom *gp; 74019d16e2fSPawel Jakub Dawidek struct sbuf *sb; 74102637cdcSPawel Jakub Dawidek const char *name; 74202637cdcSPawel Jakub Dawidek char param[16]; 74302637cdcSPawel Jakub Dawidek int *nargs; 74419d16e2fSPawel Jakub Dawidek 74519d16e2fSPawel Jakub Dawidek g_topology_assert(); 74602637cdcSPawel Jakub Dawidek nargs = gctl_get_paraml(req, "nargs", sizeof(*nargs)); 74702637cdcSPawel Jakub Dawidek if (nargs == NULL) { 74802637cdcSPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "nargs"); 74919d16e2fSPawel Jakub Dawidek return; 75019d16e2fSPawel Jakub Dawidek } 751aaf8e186SPawel Jakub Dawidek if (*nargs < 2) { 75202637cdcSPawel Jakub Dawidek gctl_error(req, "Too few arguments."); 75319d16e2fSPawel Jakub Dawidek return; 75419d16e2fSPawel Jakub Dawidek } 75519d16e2fSPawel Jakub Dawidek 75602637cdcSPawel Jakub Dawidek strlcpy(md.md_magic, G_CONCAT_MAGIC, sizeof(md.md_magic)); 75702637cdcSPawel Jakub Dawidek md.md_version = G_CONCAT_VERSION; 75802637cdcSPawel Jakub Dawidek name = gctl_get_asciiparam(req, "arg0"); 75902637cdcSPawel Jakub Dawidek if (name == NULL) { 76002637cdcSPawel Jakub Dawidek gctl_error(req, "No 'arg%u' argument.", 0); 76102637cdcSPawel Jakub Dawidek return; 76202637cdcSPawel Jakub Dawidek } 76302637cdcSPawel Jakub Dawidek strlcpy(md.md_name, name, sizeof(md.md_name)); 76402637cdcSPawel Jakub Dawidek md.md_id = arc4random(); 76502637cdcSPawel Jakub Dawidek md.md_no = 0; 76602637cdcSPawel Jakub Dawidek md.md_all = *nargs - 1; 7676c74f517SPawel Jakub Dawidek bzero(md.md_provider, sizeof(md.md_provider)); 768e6890985SPawel Jakub Dawidek /* This field is not important here. */ 769e6890985SPawel Jakub Dawidek md.md_provsize = 0; 77002637cdcSPawel Jakub Dawidek 77119d16e2fSPawel Jakub Dawidek /* Check all providers are valid */ 77202637cdcSPawel Jakub Dawidek for (no = 1; no < *nargs; no++) { 77302637cdcSPawel Jakub Dawidek snprintf(param, sizeof(param), "arg%u", no); 77402637cdcSPawel Jakub Dawidek name = gctl_get_asciiparam(req, param); 77502637cdcSPawel Jakub Dawidek if (name == NULL) { 77602637cdcSPawel Jakub Dawidek gctl_error(req, "No 'arg%u' argument.", no); 77702637cdcSPawel Jakub Dawidek return; 77802637cdcSPawel Jakub Dawidek } 77902637cdcSPawel Jakub Dawidek if (strncmp(name, "/dev/", strlen("/dev/")) == 0) 78002637cdcSPawel Jakub Dawidek name += strlen("/dev/"); 78102637cdcSPawel Jakub Dawidek pp = g_provider_by_name(name); 78219d16e2fSPawel Jakub Dawidek if (pp == NULL) { 78302637cdcSPawel Jakub Dawidek G_CONCAT_DEBUG(1, "Disk %s is invalid.", name); 78402637cdcSPawel Jakub Dawidek gctl_error(req, "Disk %s is invalid.", name); 78519d16e2fSPawel Jakub Dawidek return; 78619d16e2fSPawel Jakub Dawidek } 78719d16e2fSPawel Jakub Dawidek } 78819d16e2fSPawel Jakub Dawidek 78902637cdcSPawel Jakub Dawidek gp = g_concat_create(mp, &md, G_CONCAT_TYPE_MANUAL); 79019d16e2fSPawel Jakub Dawidek if (gp == NULL) { 791ba385d00SPawel Jakub Dawidek gctl_error(req, "Can't configure %s.", md.md_name); 79219d16e2fSPawel Jakub Dawidek return; 79319d16e2fSPawel Jakub Dawidek } 79419d16e2fSPawel Jakub Dawidek 79519d16e2fSPawel Jakub Dawidek sc = gp->softc; 7962616144eSDag-Erling Smørgrav sb = sbuf_new_auto(); 79719d16e2fSPawel Jakub Dawidek sbuf_printf(sb, "Can't attach disk(s) to %s:", gp->name); 79802637cdcSPawel Jakub Dawidek for (attached = 0, no = 1; no < *nargs; no++) { 79902637cdcSPawel Jakub Dawidek snprintf(param, sizeof(param), "arg%u", no); 80002637cdcSPawel Jakub Dawidek name = gctl_get_asciiparam(req, param); 801916cd41cSEdward Tomasz Napierala if (name == NULL) { 802916cd41cSEdward Tomasz Napierala gctl_error(req, "No 'arg%d' argument.", no); 803916cd41cSEdward Tomasz Napierala return; 804916cd41cSEdward Tomasz Napierala } 80502637cdcSPawel Jakub Dawidek if (strncmp(name, "/dev/", strlen("/dev/")) == 0) 80602637cdcSPawel Jakub Dawidek name += strlen("/dev/"); 80702637cdcSPawel Jakub Dawidek pp = g_provider_by_name(name); 80802637cdcSPawel Jakub Dawidek KASSERT(pp != NULL, ("Provider %s disappear?!", name)); 80902637cdcSPawel Jakub Dawidek if (g_concat_add_disk(sc, pp, no - 1) != 0) { 81019d16e2fSPawel Jakub Dawidek G_CONCAT_DEBUG(1, "Disk %u (%s) not attached to %s.", 81102637cdcSPawel Jakub Dawidek no, pp->name, gp->name); 81219d16e2fSPawel Jakub Dawidek sbuf_printf(sb, " %s", pp->name); 81319d16e2fSPawel Jakub Dawidek continue; 81419d16e2fSPawel Jakub Dawidek } 81519d16e2fSPawel Jakub Dawidek attached++; 81619d16e2fSPawel Jakub Dawidek } 81719d16e2fSPawel Jakub Dawidek sbuf_finish(sb); 81802637cdcSPawel Jakub Dawidek if (md.md_all != attached) { 81919d16e2fSPawel Jakub Dawidek g_concat_destroy(gp->softc, 1); 82019d16e2fSPawel Jakub Dawidek gctl_error(req, "%s", sbuf_data(sb)); 82119d16e2fSPawel Jakub Dawidek } 82219d16e2fSPawel Jakub Dawidek sbuf_delete(sb); 82319d16e2fSPawel Jakub Dawidek } 82419d16e2fSPawel Jakub Dawidek 82502637cdcSPawel Jakub Dawidek static struct g_concat_softc * 82602637cdcSPawel Jakub Dawidek g_concat_find_device(struct g_class *mp, const char *name) 82719d16e2fSPawel Jakub Dawidek { 82819d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 82902637cdcSPawel Jakub Dawidek struct g_geom *gp; 83002637cdcSPawel Jakub Dawidek 83102637cdcSPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) { 83202637cdcSPawel Jakub Dawidek sc = gp->softc; 83302637cdcSPawel Jakub Dawidek if (sc == NULL) 83402637cdcSPawel Jakub Dawidek continue; 835ba385d00SPawel Jakub Dawidek if (strcmp(sc->sc_name, name) == 0) 83602637cdcSPawel Jakub Dawidek return (sc); 83702637cdcSPawel Jakub Dawidek } 83802637cdcSPawel Jakub Dawidek return (NULL); 83902637cdcSPawel Jakub Dawidek } 84002637cdcSPawel Jakub Dawidek 84102637cdcSPawel Jakub Dawidek static void 84202637cdcSPawel Jakub Dawidek g_concat_ctl_destroy(struct gctl_req *req, struct g_class *mp) 84302637cdcSPawel Jakub Dawidek { 84402637cdcSPawel Jakub Dawidek struct g_concat_softc *sc; 84502637cdcSPawel Jakub Dawidek int *force, *nargs, error; 84602637cdcSPawel Jakub Dawidek const char *name; 84702637cdcSPawel Jakub Dawidek char param[16]; 84802637cdcSPawel Jakub Dawidek u_int i; 84919d16e2fSPawel Jakub Dawidek 85019d16e2fSPawel Jakub Dawidek g_topology_assert(); 85148fbd94bSPawel Jakub Dawidek 85202637cdcSPawel Jakub Dawidek nargs = gctl_get_paraml(req, "nargs", sizeof(*nargs)); 85302637cdcSPawel Jakub Dawidek if (nargs == NULL) { 85402637cdcSPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "nargs"); 85502637cdcSPawel Jakub Dawidek return; 85602637cdcSPawel Jakub Dawidek } 85702637cdcSPawel Jakub Dawidek if (*nargs <= 0) { 85802637cdcSPawel Jakub Dawidek gctl_error(req, "Missing device(s)."); 85902637cdcSPawel Jakub Dawidek return; 86002637cdcSPawel Jakub Dawidek } 86119d16e2fSPawel Jakub Dawidek force = gctl_get_paraml(req, "force", sizeof(*force)); 86219d16e2fSPawel Jakub Dawidek if (force == NULL) { 86348fbd94bSPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "force"); 86419d16e2fSPawel Jakub Dawidek return; 86519d16e2fSPawel Jakub Dawidek } 86602637cdcSPawel Jakub Dawidek 86702637cdcSPawel Jakub Dawidek for (i = 0; i < (u_int)*nargs; i++) { 86802637cdcSPawel Jakub Dawidek snprintf(param, sizeof(param), "arg%u", i); 86902637cdcSPawel Jakub Dawidek name = gctl_get_asciiparam(req, param); 87002637cdcSPawel Jakub Dawidek if (name == NULL) { 87102637cdcSPawel Jakub Dawidek gctl_error(req, "No 'arg%u' argument.", i); 87202637cdcSPawel Jakub Dawidek return; 87302637cdcSPawel Jakub Dawidek } 87402637cdcSPawel Jakub Dawidek sc = g_concat_find_device(mp, name); 87519d16e2fSPawel Jakub Dawidek if (sc == NULL) { 87602637cdcSPawel Jakub Dawidek gctl_error(req, "No such device: %s.", name); 87719d16e2fSPawel Jakub Dawidek return; 87819d16e2fSPawel Jakub Dawidek } 87919d16e2fSPawel Jakub Dawidek error = g_concat_destroy(sc, *force); 88019d16e2fSPawel Jakub Dawidek if (error != 0) { 88119d16e2fSPawel Jakub Dawidek gctl_error(req, "Cannot destroy device %s (error=%d).", 882ba385d00SPawel Jakub Dawidek sc->sc_name, error); 88319d16e2fSPawel Jakub Dawidek return; 88419d16e2fSPawel Jakub Dawidek } 88519d16e2fSPawel Jakub Dawidek } 88602637cdcSPawel Jakub Dawidek } 88719d16e2fSPawel Jakub Dawidek 88819d16e2fSPawel Jakub Dawidek static void 88919d16e2fSPawel Jakub Dawidek g_concat_config(struct gctl_req *req, struct g_class *mp, const char *verb) 89019d16e2fSPawel Jakub Dawidek { 89102637cdcSPawel Jakub Dawidek uint32_t *version; 89219d16e2fSPawel Jakub Dawidek 89319d16e2fSPawel Jakub Dawidek g_topology_assert(); 89419d16e2fSPawel Jakub Dawidek 89502637cdcSPawel Jakub Dawidek version = gctl_get_paraml(req, "version", sizeof(*version)); 89602637cdcSPawel Jakub Dawidek if (version == NULL) { 89702637cdcSPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "version"); 89802637cdcSPawel Jakub Dawidek return; 89902637cdcSPawel Jakub Dawidek } 90002637cdcSPawel Jakub Dawidek if (*version != G_CONCAT_VERSION) { 90102637cdcSPawel Jakub Dawidek gctl_error(req, "Userland and kernel parts are out of sync."); 90219d16e2fSPawel Jakub Dawidek return; 90319d16e2fSPawel Jakub Dawidek } 90419d16e2fSPawel Jakub Dawidek 90502637cdcSPawel Jakub Dawidek if (strcmp(verb, "create") == 0) { 90602637cdcSPawel Jakub Dawidek g_concat_ctl_create(req, mp); 90719d16e2fSPawel Jakub Dawidek return; 908a2e31b8bSPawel Jakub Dawidek } else if (strcmp(verb, "destroy") == 0 || 909a2e31b8bSPawel Jakub Dawidek strcmp(verb, "stop") == 0) { 91002637cdcSPawel Jakub Dawidek g_concat_ctl_destroy(req, mp); 91119d16e2fSPawel Jakub Dawidek return; 91219d16e2fSPawel Jakub Dawidek } 91348fbd94bSPawel Jakub Dawidek gctl_error(req, "Unknown verb."); 91419d16e2fSPawel Jakub Dawidek } 91519d16e2fSPawel Jakub Dawidek 91619d16e2fSPawel Jakub Dawidek static void 91719d16e2fSPawel Jakub Dawidek g_concat_dumpconf(struct sbuf *sb, const char *indent, struct g_geom *gp, 91819d16e2fSPawel Jakub Dawidek struct g_consumer *cp, struct g_provider *pp) 91919d16e2fSPawel Jakub Dawidek { 92019d16e2fSPawel Jakub Dawidek struct g_concat_softc *sc; 92119d16e2fSPawel Jakub Dawidek 9223fb17452SPawel Jakub Dawidek g_topology_assert(); 92319d16e2fSPawel Jakub Dawidek sc = gp->softc; 9241d723f1dSPawel Jakub Dawidek if (sc == NULL) 92519d16e2fSPawel Jakub Dawidek return; 9261d723f1dSPawel Jakub Dawidek if (pp != NULL) { 9271d723f1dSPawel Jakub Dawidek /* Nothing here. */ 9281d723f1dSPawel Jakub Dawidek } else if (cp != NULL) { 9291d723f1dSPawel Jakub Dawidek struct g_concat_disk *disk; 9301d723f1dSPawel Jakub Dawidek 9311d723f1dSPawel Jakub Dawidek disk = cp->private; 9321d723f1dSPawel Jakub Dawidek if (disk == NULL) 9331d723f1dSPawel Jakub Dawidek return; 9341d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "%s<End>%jd</End>\n", indent, 9351d723f1dSPawel Jakub Dawidek (intmax_t)disk->d_end); 9361d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "%s<Start>%jd</Start>\n", indent, 9371d723f1dSPawel Jakub Dawidek (intmax_t)disk->d_start); 9381d723f1dSPawel Jakub Dawidek } else { 9391d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "%s<ID>%u</ID>\n", indent, (u_int)sc->sc_id); 9401d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "%s<Type>", indent); 94119d16e2fSPawel Jakub Dawidek switch (sc->sc_type) { 94219d16e2fSPawel Jakub Dawidek case G_CONCAT_TYPE_AUTOMATIC: 9431d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "AUTOMATIC"); 94419d16e2fSPawel Jakub Dawidek break; 94519d16e2fSPawel Jakub Dawidek case G_CONCAT_TYPE_MANUAL: 9461d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "MANUAL"); 94719d16e2fSPawel Jakub Dawidek break; 94819d16e2fSPawel Jakub Dawidek default: 9491d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "UNKNOWN"); 95019d16e2fSPawel Jakub Dawidek break; 95119d16e2fSPawel Jakub Dawidek } 9521d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "</Type>\n"); 9531d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "%s<Status>Total=%u, Online=%u</Status>\n", 9541d723f1dSPawel Jakub Dawidek indent, sc->sc_ndisks, g_concat_nvalid(sc)); 9551d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "%s<State>", indent); 9561d723f1dSPawel Jakub Dawidek if (sc->sc_provider != NULL && sc->sc_provider->error == 0) 9571d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "UP"); 9583fb17452SPawel Jakub Dawidek else 9591d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "DOWN"); 9601d723f1dSPawel Jakub Dawidek sbuf_printf(sb, "</State>\n"); 9611d723f1dSPawel Jakub Dawidek } 96219d16e2fSPawel Jakub Dawidek } 96319d16e2fSPawel Jakub Dawidek 96419d16e2fSPawel Jakub Dawidek DECLARE_GEOM_CLASS(g_concat_class, g_concat); 965