g_concat.c revision 134528
1126007Spjd/*- 2126589Spjd * Copyright (c) 2004 Pawel Jakub Dawidek <pjd@FreeBSD.org> 3126007Spjd * All rights reserved. 4126007Spjd * 5126007Spjd * Redistribution and use in source and binary forms, with or without 6126007Spjd * modification, are permitted provided that the following conditions 7126007Spjd * are met: 8126007Spjd * 1. Redistributions of source code must retain the above copyright 9126007Spjd * notice, this list of conditions and the following disclaimer. 10126007Spjd * 2. Redistributions in binary form must reproduce the above copyright 11126007Spjd * notice, this list of conditions and the following disclaimer in the 12126007Spjd * documentation and/or other materials provided with the distribution. 13126007Spjd * 14126007Spjd * THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND 15126007Spjd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 16126007Spjd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 17126007Spjd * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE 18126007Spjd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 19126007Spjd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 20126007Spjd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 21126007Spjd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 22126007Spjd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 23126007Spjd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 24126007Spjd * SUCH DAMAGE. 25126007Spjd */ 26126007Spjd 27126007Spjd#include <sys/cdefs.h> 28126007Spjd__FBSDID("$FreeBSD: head/sys/geom/concat/g_concat.c 134528 2004-08-30 18:50:06Z pjd $"); 29126007Spjd 30126007Spjd#include <sys/param.h> 31126007Spjd#include <sys/systm.h> 32126007Spjd#include <sys/kernel.h> 33126007Spjd#include <sys/module.h> 34126007Spjd#include <sys/lock.h> 35126007Spjd#include <sys/mutex.h> 36126007Spjd#include <sys/bio.h> 37126007Spjd#include <sys/sysctl.h> 38126007Spjd#include <sys/malloc.h> 39126007Spjd#include <geom/geom.h> 40126007Spjd#include <geom/concat/g_concat.h> 41126007Spjd 42126007Spjd 43126007Spjdstatic MALLOC_DEFINE(M_CONCAT, "concat data", "GEOM_CONCAT Data"); 44126007Spjd 45126565SpjdSYSCTL_DECL(_kern_geom); 46126007SpjdSYSCTL_NODE(_kern_geom, OID_AUTO, concat, CTLFLAG_RW, 0, "GEOM_CONCAT stuff"); 47126007Spjdstatic u_int g_concat_debug = 0; 48134528SpjdTUNABLE_INT("kern.geom.concat.debug", &g_concat_debug); 49126007SpjdSYSCTL_UINT(_kern_geom_concat, OID_AUTO, debug, CTLFLAG_RW, &g_concat_debug, 0, 50126007Spjd "Debug level"); 51126007Spjd 52126007Spjdstatic int g_concat_destroy(struct g_concat_softc *sc, boolean_t force); 53126007Spjdstatic int g_concat_destroy_geom(struct gctl_req *req, struct g_class *mp, 54126007Spjd struct g_geom *gp); 55126007Spjd 56126007Spjdstatic g_taste_t g_concat_taste; 57126007Spjdstatic g_ctl_req_t g_concat_config; 58126007Spjdstatic g_dumpconf_t g_concat_dumpconf; 59126007Spjd 60126007Spjdstruct g_class g_concat_class = { 61126007Spjd .name = G_CONCAT_CLASS_NAME, 62133318Sphk .version = G_VERSION, 63126007Spjd .ctlreq = g_concat_config, 64126007Spjd .taste = g_concat_taste, 65126007Spjd .destroy_geom = g_concat_destroy_geom 66126007Spjd}; 67126007Spjd 68126007Spjd 69126007Spjd/* 70126773Spjd * Greatest Common Divisor. 71126773Spjd */ 72126773Spjdstatic u_int 73126773Spjdgcd(u_int a, u_int b) 74126773Spjd{ 75126773Spjd u_int c; 76126773Spjd 77126773Spjd while (b != 0) { 78126773Spjd c = a; 79126773Spjd a = b; 80126773Spjd b = (c % b); 81126773Spjd } 82126773Spjd return (a); 83126773Spjd} 84126773Spjd 85126773Spjd/* 86126773Spjd * Least Common Multiple. 87126773Spjd */ 88126773Spjdstatic u_int 89126773Spjdlcm(u_int a, u_int b) 90126773Spjd{ 91126773Spjd 92126773Spjd return ((a * b) / gcd(a, b)); 93126773Spjd} 94126773Spjd 95126773Spjd/* 96126007Spjd * Return the number of valid disks. 97126007Spjd */ 98126007Spjdstatic u_int 99126007Spjdg_concat_nvalid(struct g_concat_softc *sc) 100126007Spjd{ 101126007Spjd u_int i, no; 102126007Spjd 103126007Spjd no = 0; 104126007Spjd for (i = 0; i < sc->sc_ndisks; i++) { 105126565Spjd if (sc->sc_disks[i].d_consumer != NULL) 106126007Spjd no++; 107126007Spjd } 108126007Spjd 109126007Spjd return (no); 110126007Spjd} 111126007Spjd 112126007Spjdstatic void 113126007Spjdg_concat_remove_disk(struct g_concat_disk *disk) 114126007Spjd{ 115126007Spjd struct g_consumer *cp; 116126007Spjd struct g_concat_softc *sc; 117126007Spjd 118126565Spjd KASSERT(disk->d_consumer != NULL, ("Non-valid disk in %s.", __func__)); 119126007Spjd sc = disk->d_softc; 120126007Spjd cp = disk->d_consumer; 121126007Spjd 122129478Spjd G_CONCAT_DEBUG(0, "Disk %s removed from %s.", cp->provider->name, 123132663Spjd sc->sc_name); 124126007Spjd 125126565Spjd disk->d_consumer = NULL; 126129478Spjd if (sc->sc_provider != NULL) { 127129478Spjd g_orphan_provider(sc->sc_provider, ENXIO); 128129478Spjd sc->sc_provider = NULL; 129132663Spjd G_CONCAT_DEBUG(0, "Device %s removed.", sc->sc_name); 130129478Spjd } 131126007Spjd 132126007Spjd if (cp->acr > 0 || cp->acw > 0 || cp->ace > 0) 133126007Spjd g_access(cp, -cp->acr, -cp->acw, -cp->ace); 134126007Spjd g_detach(cp); 135126007Spjd g_destroy_consumer(cp); 136126007Spjd} 137126007Spjd 138126007Spjdstatic void 139126007Spjdg_concat_orphan(struct g_consumer *cp) 140126007Spjd{ 141126007Spjd struct g_concat_softc *sc; 142126007Spjd struct g_concat_disk *disk; 143126007Spjd struct g_geom *gp; 144126007Spjd 145126007Spjd g_topology_assert(); 146126007Spjd gp = cp->geom; 147126007Spjd sc = gp->softc; 148126007Spjd if (sc == NULL) 149126007Spjd return; 150126007Spjd 151126007Spjd disk = cp->private; 152126007Spjd if (disk == NULL) /* Possible? */ 153126007Spjd return; 154126007Spjd g_concat_remove_disk(disk); 155126007Spjd 156126007Spjd /* If there are no valid disks anymore, remove device. */ 157126007Spjd if (g_concat_nvalid(sc) == 0) 158126007Spjd g_concat_destroy(sc, 1); 159126007Spjd} 160126007Spjd 161126007Spjdstatic int 162126007Spjdg_concat_access(struct g_provider *pp, int dr, int dw, int de) 163126007Spjd{ 164126007Spjd struct g_consumer *cp1, *cp2; 165126007Spjd struct g_concat_softc *sc; 166126007Spjd struct g_geom *gp; 167126007Spjd int error; 168126007Spjd 169126007Spjd gp = pp->geom; 170126007Spjd sc = gp->softc; 171126007Spjd 172126007Spjd if (sc == NULL) { 173126007Spjd /* 174126007Spjd * It looks like geom is being withered. 175126007Spjd * In that case we allow only negative requests. 176126007Spjd */ 177126007Spjd KASSERT(dr <= 0 && dw <= 0 && de <= 0, 178126007Spjd ("Positive access request (device=%s).", pp->name)); 179126007Spjd if ((pp->acr + dr) == 0 && (pp->acw + dw) == 0 && 180126007Spjd (pp->ace + de) == 0) { 181126007Spjd G_CONCAT_DEBUG(0, "Device %s definitely destroyed.", 182126007Spjd gp->name); 183126007Spjd } 184126007Spjd return (0); 185126007Spjd } 186126007Spjd 187126007Spjd /* On first open, grab an extra "exclusive" bit */ 188126007Spjd if (pp->acr == 0 && pp->acw == 0 && pp->ace == 0) 189126007Spjd de++; 190126007Spjd /* ... and let go of it on last close */ 191132342Spjd if ((pp->acr + dr) == 0 && (pp->acw + dw) == 0 && (pp->ace + de) == 0) 192126007Spjd de--; 193126007Spjd 194126007Spjd error = ENXIO; 195126007Spjd LIST_FOREACH(cp1, &gp->consumer, consumer) { 196126007Spjd error = g_access(cp1, dr, dw, de); 197126007Spjd if (error == 0) 198126007Spjd continue; 199126007Spjd /* 200126007Spjd * If we fail here, backout all previous changes. 201126007Spjd */ 202126007Spjd LIST_FOREACH(cp2, &gp->consumer, consumer) { 203126007Spjd if (cp1 == cp2) 204126007Spjd return (error); 205126007Spjd g_access(cp2, -dr, -dw, -de); 206126007Spjd } 207126007Spjd /* NOTREACHED */ 208126007Spjd } 209126007Spjd 210126007Spjd return (error); 211126007Spjd} 212126007Spjd 213126007Spjdstatic void 214126007Spjdg_concat_start(struct bio *bp) 215126007Spjd{ 216126007Spjd struct g_concat_softc *sc; 217126007Spjd struct g_concat_disk *disk; 218126007Spjd struct g_provider *pp; 219126007Spjd off_t offset, end, length, off, len; 220126007Spjd struct bio *cbp; 221126007Spjd char *addr; 222126007Spjd u_int no; 223126007Spjd 224126007Spjd pp = bp->bio_to; 225126007Spjd sc = pp->geom->softc; 226126007Spjd /* 227126007Spjd * If sc == NULL, provider's error should be set and g_concat_start() 228126007Spjd * should not be called at all. 229126007Spjd */ 230126007Spjd KASSERT(sc != NULL, 231126007Spjd ("Provider's error should be set (error=%d)(device=%s).", 232126007Spjd bp->bio_to->error, bp->bio_to->name)); 233126007Spjd 234126007Spjd G_CONCAT_LOGREQ(bp, "Request received."); 235126007Spjd 236126007Spjd switch (bp->bio_cmd) { 237126007Spjd case BIO_READ: 238126007Spjd case BIO_WRITE: 239126007Spjd case BIO_DELETE: 240126007Spjd break; 241126007Spjd case BIO_GETATTR: 242126007Spjd /* To which provider it should be delivered? */ 243126007Spjd default: 244126007Spjd g_io_deliver(bp, EOPNOTSUPP); 245126007Spjd return; 246126007Spjd } 247126007Spjd 248126007Spjd offset = bp->bio_offset; 249126007Spjd length = bp->bio_length; 250126007Spjd addr = bp->bio_data; 251126007Spjd end = offset + length; 252126007Spjd 253126007Spjd for (no = 0; no < sc->sc_ndisks; no++) { 254126007Spjd disk = &sc->sc_disks[no]; 255126007Spjd if (disk->d_end <= offset) 256126007Spjd continue; 257126007Spjd if (disk->d_start >= end) 258126007Spjd break; 259126007Spjd 260126007Spjd off = offset - disk->d_start; 261126007Spjd len = MIN(length, disk->d_end - offset); 262126007Spjd length -= len; 263126007Spjd offset += len; 264126007Spjd 265126007Spjd cbp = g_clone_bio(bp); 266126007Spjd if (cbp == NULL) { 267126007Spjd if (bp->bio_error == 0) 268126007Spjd bp->bio_error = ENOMEM; 269126007Spjd return; 270126007Spjd } 271126007Spjd /* 272126007Spjd * Fill in the component buf structure. 273126007Spjd */ 274126007Spjd cbp->bio_done = g_std_done; 275126007Spjd cbp->bio_offset = off; 276126007Spjd cbp->bio_data = addr; 277126007Spjd addr += len; 278126007Spjd cbp->bio_length = len; 279126007Spjd cbp->bio_to = disk->d_consumer->provider; 280126007Spjd G_CONCAT_LOGREQ(cbp, "Sending request."); 281126007Spjd g_io_request(cbp, disk->d_consumer); 282126007Spjd 283126007Spjd if (length == 0) 284126007Spjd break; 285126007Spjd } 286126007Spjd 287126007Spjd KASSERT(length == 0, 288126007Spjd ("Length is still greater than 0 (class=%s, name=%s).", 289126007Spjd bp->bio_to->geom->class->name, bp->bio_to->geom->name)); 290126007Spjd} 291126007Spjd 292126007Spjdstatic void 293126007Spjdg_concat_check_and_run(struct g_concat_softc *sc) 294126007Spjd{ 295126007Spjd struct g_concat_disk *disk; 296126773Spjd u_int no, sectorsize = 0; 297126007Spjd off_t start; 298126007Spjd 299126007Spjd if (g_concat_nvalid(sc) != sc->sc_ndisks) 300126007Spjd return; 301126007Spjd 302132663Spjd sc->sc_provider = g_new_providerf(sc->sc_geom, "concat/%s", 303132663Spjd sc->sc_name); 304126007Spjd start = 0; 305126007Spjd for (no = 0; no < sc->sc_ndisks; no++) { 306126007Spjd disk = &sc->sc_disks[no]; 307126007Spjd disk->d_start = start; 308126007Spjd disk->d_end = disk->d_start + 309126007Spjd disk->d_consumer->provider->mediasize; 310126007Spjd if (sc->sc_type == G_CONCAT_TYPE_AUTOMATIC) 311126007Spjd disk->d_end -= disk->d_consumer->provider->sectorsize; 312126007Spjd start = disk->d_end; 313126773Spjd if (no == 0) 314126773Spjd sectorsize = disk->d_consumer->provider->sectorsize; 315126773Spjd else { 316126773Spjd sectorsize = lcm(sectorsize, 317126773Spjd disk->d_consumer->provider->sectorsize); 318126773Spjd } 319126007Spjd } 320126773Spjd sc->sc_provider->sectorsize = sectorsize; 321126007Spjd /* We have sc->sc_disks[sc->sc_ndisks - 1].d_end in 'start'. */ 322126007Spjd sc->sc_provider->mediasize = start; 323126007Spjd g_error_provider(sc->sc_provider, 0); 324126007Spjd 325132663Spjd G_CONCAT_DEBUG(0, "Device %s activated.", sc->sc_name); 326126007Spjd} 327126007Spjd 328126007Spjdstatic int 329126007Spjdg_concat_read_metadata(struct g_consumer *cp, struct g_concat_metadata *md) 330126007Spjd{ 331126007Spjd struct g_provider *pp; 332126007Spjd u_char *buf; 333126007Spjd int error; 334126007Spjd 335126007Spjd g_topology_assert(); 336126007Spjd 337126007Spjd error = g_access(cp, 1, 0, 0); 338126007Spjd if (error != 0) 339126007Spjd return (error); 340126007Spjd pp = cp->provider; 341126007Spjd g_topology_unlock(); 342126007Spjd buf = g_read_data(cp, pp->mediasize - pp->sectorsize, pp->sectorsize, 343126007Spjd &error); 344126007Spjd g_topology_lock(); 345126007Spjd g_access(cp, -1, 0, 0); 346126007Spjd if (buf == NULL) 347126007Spjd return (error); 348126007Spjd 349126007Spjd /* Decode metadata. */ 350126007Spjd concat_metadata_decode(buf, md); 351126007Spjd g_free(buf); 352126007Spjd 353126007Spjd return (0); 354126007Spjd} 355126007Spjd 356126007Spjd/* 357126007Spjd * Add disk to given device. 358126007Spjd */ 359126007Spjdstatic int 360126007Spjdg_concat_add_disk(struct g_concat_softc *sc, struct g_provider *pp, u_int no) 361126007Spjd{ 362126007Spjd struct g_concat_disk *disk; 363129478Spjd struct g_consumer *cp, *fcp; 364126007Spjd struct g_geom *gp; 365126007Spjd int error; 366126007Spjd 367126007Spjd /* Metadata corrupted? */ 368126007Spjd if (no >= sc->sc_ndisks) 369126007Spjd return (EINVAL); 370126007Spjd 371126007Spjd disk = &sc->sc_disks[no]; 372126007Spjd /* Check if disk is not already attached. */ 373126565Spjd if (disk->d_consumer != NULL) 374126007Spjd return (EEXIST); 375126007Spjd 376129478Spjd gp = sc->sc_geom; 377129478Spjd fcp = LIST_FIRST(&gp->consumer); 378126007Spjd 379126007Spjd cp = g_new_consumer(gp); 380126007Spjd error = g_attach(cp, pp); 381126007Spjd if (error != 0) { 382126007Spjd g_destroy_consumer(cp); 383126007Spjd return (error); 384126007Spjd } 385126007Spjd 386129478Spjd if (fcp != NULL && (fcp->acr > 0 || fcp->acw > 0 || fcp->ace > 0)) { 387129478Spjd error = g_access(cp, fcp->acr, fcp->acw, fcp->ace); 388126007Spjd if (error != 0) { 389126007Spjd g_detach(cp); 390126007Spjd g_destroy_consumer(cp); 391126007Spjd return (error); 392126007Spjd } 393126007Spjd } 394126007Spjd if (sc->sc_type == G_CONCAT_TYPE_AUTOMATIC) { 395126007Spjd struct g_concat_metadata md; 396126007Spjd 397126773Spjd /* Re-read metadata. */ 398126007Spjd error = g_concat_read_metadata(cp, &md); 399126007Spjd if (error != 0) 400126007Spjd goto fail; 401126007Spjd 402126007Spjd if (strcmp(md.md_magic, G_CONCAT_MAGIC) != 0 || 403126007Spjd strcmp(md.md_name, sc->sc_name) != 0 || 404126007Spjd md.md_id != sc->sc_id) { 405126007Spjd G_CONCAT_DEBUG(0, "Metadata on %s changed.", pp->name); 406126007Spjd goto fail; 407126007Spjd } 408126007Spjd } 409126007Spjd 410126007Spjd cp->private = disk; 411126007Spjd disk->d_consumer = cp; 412126007Spjd disk->d_softc = sc; 413126007Spjd disk->d_start = 0; /* not yet */ 414126007Spjd disk->d_end = 0; /* not yet */ 415126007Spjd 416132663Spjd G_CONCAT_DEBUG(0, "Disk %s attached to %s.", pp->name, sc->sc_name); 417126007Spjd 418126007Spjd g_concat_check_and_run(sc); 419126007Spjd 420126007Spjd return (0); 421126007Spjdfail: 422129478Spjd if (fcp != NULL && (fcp->acr > 0 || fcp->acw > 0 || fcp->ace > 0)) 423129478Spjd g_access(cp, -fcp->acr, -fcp->acw, -fcp->ace); 424126007Spjd g_detach(cp); 425126007Spjd g_destroy_consumer(cp); 426126007Spjd return (error); 427126007Spjd} 428126007Spjd 429126007Spjdstatic struct g_geom * 430126007Spjdg_concat_create(struct g_class *mp, const struct g_concat_metadata *md, 431126773Spjd u_int type) 432126007Spjd{ 433126007Spjd struct g_concat_softc *sc; 434126007Spjd struct g_geom *gp; 435126007Spjd u_int no; 436126007Spjd 437132663Spjd G_CONCAT_DEBUG(1, "Creating device %s (id=%u).", md->md_name, 438126007Spjd md->md_id); 439126007Spjd 440126007Spjd /* Two disks is minimum. */ 441126007Spjd if (md->md_all <= 1) 442126007Spjd return (NULL); 443126007Spjd 444126007Spjd /* Check for duplicate unit */ 445126007Spjd LIST_FOREACH(gp, &mp->geom, geom) { 446126007Spjd sc = gp->softc; 447126007Spjd if (sc != NULL && strcmp(sc->sc_name, md->md_name) == 0) { 448129478Spjd G_CONCAT_DEBUG(0, "Device %s already configured.", 449126007Spjd gp->name); 450126007Spjd return (NULL); 451126007Spjd } 452126007Spjd } 453132663Spjd gp = g_new_geomf(mp, "%s", md->md_name); 454126007Spjd gp->softc = NULL; /* for a moment */ 455126007Spjd 456132661Spjd sc = malloc(sizeof(*sc), M_CONCAT, M_WAITOK | M_ZERO); 457126007Spjd gp->start = g_concat_start; 458126007Spjd gp->spoiled = g_concat_orphan; 459126007Spjd gp->orphan = g_concat_orphan; 460126007Spjd gp->access = g_concat_access; 461126007Spjd gp->dumpconf = g_concat_dumpconf; 462126007Spjd 463126007Spjd sc->sc_id = md->md_id; 464126007Spjd sc->sc_ndisks = md->md_all; 465126007Spjd sc->sc_disks = malloc(sizeof(struct g_concat_disk) * sc->sc_ndisks, 466126007Spjd M_CONCAT, M_WAITOK | M_ZERO); 467126007Spjd for (no = 0; no < sc->sc_ndisks; no++) 468126565Spjd sc->sc_disks[no].d_consumer = NULL; 469126007Spjd sc->sc_type = type; 470126007Spjd 471126007Spjd gp->softc = sc; 472129478Spjd sc->sc_geom = gp; 473129478Spjd sc->sc_provider = NULL; 474126007Spjd 475132663Spjd G_CONCAT_DEBUG(0, "Device %s created (id=%u).", sc->sc_name, sc->sc_id); 476126007Spjd 477126007Spjd return (gp); 478126007Spjd} 479126007Spjd 480126007Spjdstatic int 481126007Spjdg_concat_destroy(struct g_concat_softc *sc, boolean_t force) 482126007Spjd{ 483126007Spjd struct g_provider *pp; 484126007Spjd struct g_geom *gp; 485126007Spjd u_int no; 486126007Spjd 487126007Spjd g_topology_assert(); 488126007Spjd 489126007Spjd if (sc == NULL) 490126007Spjd return (ENXIO); 491126007Spjd 492126007Spjd pp = sc->sc_provider; 493129478Spjd if (pp != NULL && (pp->acr != 0 || pp->acw != 0 || pp->ace != 0)) { 494126007Spjd if (force) { 495126007Spjd G_CONCAT_DEBUG(0, "Device %s is still open, so it " 496129478Spjd "can't be definitely removed.", pp->name); 497126007Spjd } else { 498126007Spjd G_CONCAT_DEBUG(1, 499129478Spjd "Device %s is still open (r%dw%de%d).", pp->name, 500129478Spjd pp->acr, pp->acw, pp->ace); 501126007Spjd return (EBUSY); 502126007Spjd } 503126007Spjd } 504126007Spjd 505126007Spjd for (no = 0; no < sc->sc_ndisks; no++) { 506126565Spjd if (sc->sc_disks[no].d_consumer != NULL) 507126007Spjd g_concat_remove_disk(&sc->sc_disks[no]); 508126007Spjd } 509126007Spjd 510129478Spjd gp = sc->sc_geom; 511126007Spjd gp->softc = NULL; 512129478Spjd KASSERT(sc->sc_provider == NULL, ("Provider still exists? (device=%s)", 513129478Spjd gp->name)); 514126007Spjd free(sc->sc_disks, M_CONCAT); 515126007Spjd free(sc, M_CONCAT); 516126007Spjd 517129478Spjd pp = LIST_FIRST(&gp->provider); 518129478Spjd if (pp == NULL || (pp->acr == 0 && pp->acw == 0 && pp->ace == 0)) 519129478Spjd G_CONCAT_DEBUG(0, "Device %s destroyed.", gp->name); 520129478Spjd 521126007Spjd g_wither_geom(gp, ENXIO); 522126007Spjd 523126007Spjd return (0); 524126007Spjd} 525126007Spjd 526126007Spjdstatic int 527126773Spjdg_concat_destroy_geom(struct gctl_req *req __unused, 528126773Spjd struct g_class *mp __unused, struct g_geom *gp) 529126007Spjd{ 530126007Spjd struct g_concat_softc *sc; 531126007Spjd 532126007Spjd sc = gp->softc; 533126007Spjd return (g_concat_destroy(sc, 0)); 534126007Spjd} 535126007Spjd 536126007Spjdstatic struct g_geom * 537126007Spjdg_concat_taste(struct g_class *mp, struct g_provider *pp, int flags __unused) 538126007Spjd{ 539126007Spjd struct g_concat_metadata md; 540126007Spjd struct g_concat_softc *sc; 541126007Spjd struct g_consumer *cp; 542126007Spjd struct g_geom *gp; 543126007Spjd int error; 544126007Spjd 545129478Spjd g_trace(G_T_TOPOLOGY, "%s(%s, %s)", __func__, mp->name, pp->name); 546126007Spjd g_topology_assert(); 547126007Spjd 548126007Spjd G_CONCAT_DEBUG(3, "Tasting %s.", pp->name); 549134344Spjd /* Skip providers with 0 sectorsize. */ 550134344Spjd if (pp->sectorsize == 0) 551134344Spjd return (NULL); 552126007Spjd 553126007Spjd gp = g_new_geomf(mp, "concat:taste"); 554126007Spjd gp->start = g_concat_start; 555126315Spjd gp->access = g_concat_access; 556126315Spjd gp->orphan = g_concat_orphan; 557126007Spjd cp = g_new_consumer(gp); 558126007Spjd g_attach(cp, pp); 559126007Spjd error = g_concat_read_metadata(cp, &md); 560133371Spjd g_detach(cp); 561133371Spjd g_destroy_consumer(cp); 562133371Spjd g_destroy_geom(gp); 563129478Spjd if (error != 0) 564126007Spjd return (NULL); 565126007Spjd gp = NULL; 566126007Spjd 567126007Spjd if (strcmp(md.md_magic, G_CONCAT_MAGIC) != 0) 568126007Spjd return (NULL); 569126007Spjd if (md.md_version > G_CONCAT_VERSION) { 570126007Spjd printf("geom_concat.ko module is too old to handle %s.\n", 571126007Spjd pp->name); 572126007Spjd return (NULL); 573126007Spjd } 574133373Spjd /* 575133373Spjd * Backward compatibility: 576133373Spjd * There was no md_provider field in earlier versions of metadata. 577133373Spjd */ 578133373Spjd if (md.md_version < 3) 579133373Spjd bzero(md.md_provider, sizeof(md.md_provider)); 580126007Spjd 581133373Spjd if (md.md_provider[0] != '\0' && strcmp(md.md_provider, pp->name) != 0) 582133373Spjd return (NULL); 583133373Spjd 584126007Spjd /* 585126007Spjd * Let's check if device already exists. 586126007Spjd */ 587128913Spjd sc = NULL; 588126007Spjd LIST_FOREACH(gp, &mp->geom, geom) { 589126007Spjd sc = gp->softc; 590126007Spjd if (sc == NULL) 591126007Spjd continue; 592126007Spjd if (sc->sc_type != G_CONCAT_TYPE_AUTOMATIC) 593126007Spjd continue; 594126007Spjd if (strcmp(md.md_name, sc->sc_name) != 0) 595126007Spjd continue; 596126007Spjd if (md.md_id != sc->sc_id) 597126007Spjd continue; 598126007Spjd break; 599126007Spjd } 600126007Spjd if (gp != NULL) { 601126007Spjd G_CONCAT_DEBUG(1, "Adding disk %s to %s.", pp->name, gp->name); 602126007Spjd error = g_concat_add_disk(sc, pp, md.md_no); 603126007Spjd if (error != 0) { 604129478Spjd G_CONCAT_DEBUG(0, 605129478Spjd "Cannot add disk %s to %s (error=%d).", pp->name, 606129478Spjd gp->name, error); 607126007Spjd return (NULL); 608126007Spjd } 609126007Spjd } else { 610126773Spjd gp = g_concat_create(mp, &md, G_CONCAT_TYPE_AUTOMATIC); 611126007Spjd if (gp == NULL) { 612132663Spjd G_CONCAT_DEBUG(0, "Cannot create device %s.", 613126007Spjd md.md_name); 614126007Spjd return (NULL); 615126007Spjd } 616126007Spjd sc = gp->softc; 617126007Spjd G_CONCAT_DEBUG(1, "Adding disk %s to %s.", pp->name, gp->name); 618126007Spjd error = g_concat_add_disk(sc, pp, md.md_no); 619126007Spjd if (error != 0) { 620129478Spjd G_CONCAT_DEBUG(0, 621129478Spjd "Cannot add disk %s to %s (error=%d).", pp->name, 622129478Spjd gp->name, error); 623126007Spjd g_concat_destroy(sc, 1); 624126007Spjd return (NULL); 625126007Spjd } 626126007Spjd } 627126007Spjd 628126007Spjd return (gp); 629126007Spjd} 630126007Spjd 631126007Spjdstatic void 632126007Spjdg_concat_ctl_create(struct gctl_req *req, struct g_class *mp) 633126007Spjd{ 634126007Spjd u_int attached, no; 635129478Spjd struct g_concat_metadata md; 636126007Spjd struct g_provider *pp; 637126007Spjd struct g_concat_softc *sc; 638126007Spjd struct g_geom *gp; 639126007Spjd struct sbuf *sb; 640129478Spjd const char *name; 641129478Spjd char param[16]; 642129478Spjd int *nargs; 643126007Spjd 644126007Spjd g_topology_assert(); 645129478Spjd nargs = gctl_get_paraml(req, "nargs", sizeof(*nargs)); 646129478Spjd if (nargs == NULL) { 647129478Spjd gctl_error(req, "No '%s' argument.", "nargs"); 648126007Spjd return; 649126007Spjd } 650129478Spjd if (*nargs <= 2) { 651129478Spjd gctl_error(req, "Too few arguments."); 652126007Spjd return; 653126007Spjd } 654126007Spjd 655129478Spjd strlcpy(md.md_magic, G_CONCAT_MAGIC, sizeof(md.md_magic)); 656129478Spjd md.md_version = G_CONCAT_VERSION; 657129478Spjd name = gctl_get_asciiparam(req, "arg0"); 658129478Spjd if (name == NULL) { 659129478Spjd gctl_error(req, "No 'arg%u' argument.", 0); 660129478Spjd return; 661129478Spjd } 662129478Spjd strlcpy(md.md_name, name, sizeof(md.md_name)); 663129478Spjd md.md_id = arc4random(); 664129478Spjd md.md_no = 0; 665129478Spjd md.md_all = *nargs - 1; 666133373Spjd bzero(md.md_provider, sizeof(md.md_provider)); 667129478Spjd 668126007Spjd /* Check all providers are valid */ 669129478Spjd for (no = 1; no < *nargs; no++) { 670129478Spjd snprintf(param, sizeof(param), "arg%u", no); 671129478Spjd name = gctl_get_asciiparam(req, param); 672129478Spjd if (name == NULL) { 673129478Spjd gctl_error(req, "No 'arg%u' argument.", no); 674129478Spjd return; 675129478Spjd } 676129478Spjd if (strncmp(name, "/dev/", strlen("/dev/")) == 0) 677129478Spjd name += strlen("/dev/"); 678129478Spjd pp = g_provider_by_name(name); 679126007Spjd if (pp == NULL) { 680129478Spjd G_CONCAT_DEBUG(1, "Disk %s is invalid.", name); 681129478Spjd gctl_error(req, "Disk %s is invalid.", name); 682126007Spjd return; 683126007Spjd } 684126007Spjd } 685126007Spjd 686129478Spjd gp = g_concat_create(mp, &md, G_CONCAT_TYPE_MANUAL); 687126007Spjd if (gp == NULL) { 688132663Spjd gctl_error(req, "Can't configure %s.", md.md_name); 689126007Spjd return; 690126007Spjd } 691126007Spjd 692126007Spjd sc = gp->softc; 693126007Spjd sb = sbuf_new(NULL, NULL, 0, SBUF_AUTOEXTEND); 694126007Spjd sbuf_printf(sb, "Can't attach disk(s) to %s:", gp->name); 695129478Spjd for (attached = 0, no = 1; no < *nargs; no++) { 696129478Spjd snprintf(param, sizeof(param), "arg%u", no); 697129478Spjd name = gctl_get_asciiparam(req, param); 698129478Spjd if (strncmp(name, "/dev/", strlen("/dev/")) == 0) 699129478Spjd name += strlen("/dev/"); 700129478Spjd pp = g_provider_by_name(name); 701129478Spjd KASSERT(pp != NULL, ("Provider %s disappear?!", name)); 702129478Spjd if (g_concat_add_disk(sc, pp, no - 1) != 0) { 703126007Spjd G_CONCAT_DEBUG(1, "Disk %u (%s) not attached to %s.", 704129478Spjd no, pp->name, gp->name); 705126007Spjd sbuf_printf(sb, " %s", pp->name); 706126007Spjd continue; 707126007Spjd } 708126007Spjd attached++; 709126007Spjd } 710126007Spjd sbuf_finish(sb); 711129478Spjd if (md.md_all != attached) { 712126007Spjd g_concat_destroy(gp->softc, 1); 713126007Spjd gctl_error(req, "%s", sbuf_data(sb)); 714126007Spjd } 715126007Spjd sbuf_delete(sb); 716126007Spjd} 717126007Spjd 718129478Spjdstatic struct g_concat_softc * 719129478Spjdg_concat_find_device(struct g_class *mp, const char *name) 720129478Spjd{ 721129478Spjd struct g_concat_softc *sc; 722129478Spjd struct g_geom *gp; 723129478Spjd 724129478Spjd LIST_FOREACH(gp, &mp->geom, geom) { 725129478Spjd sc = gp->softc; 726129478Spjd if (sc == NULL) 727129478Spjd continue; 728132663Spjd if (strcmp(sc->sc_name, name) == 0) 729129478Spjd return (sc); 730129478Spjd } 731129478Spjd return (NULL); 732129478Spjd} 733129478Spjd 734126007Spjdstatic void 735129478Spjdg_concat_ctl_destroy(struct gctl_req *req, struct g_class *mp) 736126007Spjd{ 737126007Spjd struct g_concat_softc *sc; 738129478Spjd int *force, *nargs, error; 739129478Spjd const char *name; 740129478Spjd char param[16]; 741129478Spjd u_int i; 742126007Spjd 743126007Spjd g_topology_assert(); 744126773Spjd 745129478Spjd nargs = gctl_get_paraml(req, "nargs", sizeof(*nargs)); 746129478Spjd if (nargs == NULL) { 747129478Spjd gctl_error(req, "No '%s' argument.", "nargs"); 748129478Spjd return; 749129478Spjd } 750129478Spjd if (*nargs <= 0) { 751129478Spjd gctl_error(req, "Missing device(s)."); 752129478Spjd return; 753129478Spjd } 754126007Spjd force = gctl_get_paraml(req, "force", sizeof(*force)); 755126007Spjd if (force == NULL) { 756126773Spjd gctl_error(req, "No '%s' argument.", "force"); 757126007Spjd return; 758126007Spjd } 759129478Spjd 760129478Spjd for (i = 0; i < (u_int)*nargs; i++) { 761129478Spjd snprintf(param, sizeof(param), "arg%u", i); 762129478Spjd name = gctl_get_asciiparam(req, param); 763129478Spjd if (name == NULL) { 764129478Spjd gctl_error(req, "No 'arg%u' argument.", i); 765129478Spjd return; 766129478Spjd } 767129478Spjd sc = g_concat_find_device(mp, name); 768129478Spjd if (sc == NULL) { 769129478Spjd gctl_error(req, "No such device: %s.", name); 770129478Spjd return; 771129478Spjd } 772129478Spjd error = g_concat_destroy(sc, *force); 773129478Spjd if (error != 0) { 774129478Spjd gctl_error(req, "Cannot destroy device %s (error=%d).", 775132663Spjd sc->sc_name, error); 776129478Spjd return; 777129478Spjd } 778126007Spjd } 779126007Spjd} 780126007Spjd 781126007Spjdstatic void 782126007Spjdg_concat_config(struct gctl_req *req, struct g_class *mp, const char *verb) 783126007Spjd{ 784129478Spjd uint32_t *version; 785126007Spjd 786126007Spjd g_topology_assert(); 787126007Spjd 788129478Spjd version = gctl_get_paraml(req, "version", sizeof(*version)); 789129478Spjd if (version == NULL) { 790129478Spjd gctl_error(req, "No '%s' argument.", "version"); 791126007Spjd return; 792126007Spjd } 793129478Spjd if (*version != G_CONCAT_VERSION) { 794129478Spjd gctl_error(req, "Userland and kernel parts are out of sync."); 795126007Spjd return; 796126007Spjd } 797129478Spjd 798129478Spjd if (strcmp(verb, "create") == 0) { 799129478Spjd g_concat_ctl_create(req, mp); 800126007Spjd return; 801131649Spjd } else if (strcmp(verb, "destroy") == 0 || 802131649Spjd strcmp(verb, "stop") == 0) { 803129478Spjd g_concat_ctl_destroy(req, mp); 804129478Spjd return; 805126007Spjd } 806126773Spjd gctl_error(req, "Unknown verb."); 807126007Spjd} 808126007Spjd 809126007Spjdstatic void 810126007Spjdg_concat_dumpconf(struct sbuf *sb, const char *indent, struct g_geom *gp, 811126007Spjd struct g_consumer *cp, struct g_provider *pp) 812126007Spjd{ 813128486Spjd struct g_concat_softc *sc; 814126007Spjd 815129747Spjd g_topology_assert(); 816128486Spjd sc = gp->softc; 817132665Spjd if (sc == NULL) 818128486Spjd return; 819132665Spjd if (pp != NULL) { 820132665Spjd /* Nothing here. */ 821132665Spjd } else if (cp != NULL) { 822132665Spjd struct g_concat_disk *disk; 823132665Spjd 824132665Spjd disk = cp->private; 825132665Spjd if (disk == NULL) 826132665Spjd return; 827132665Spjd sbuf_printf(sb, "%s<End>%jd</End>\n", indent, 828132665Spjd (intmax_t)disk->d_end); 829132665Spjd sbuf_printf(sb, "%s<Start>%jd</Start>\n", indent, 830132665Spjd (intmax_t)disk->d_start); 831132665Spjd } else { 832132665Spjd sbuf_printf(sb, "%s<ID>%u</ID>\n", indent, (u_int)sc->sc_id); 833132665Spjd sbuf_printf(sb, "%s<Type>", indent); 834132665Spjd switch (sc->sc_type) { 835132665Spjd case G_CONCAT_TYPE_AUTOMATIC: 836132665Spjd sbuf_printf(sb, "AUTOMATIC"); 837132665Spjd break; 838132665Spjd case G_CONCAT_TYPE_MANUAL: 839132665Spjd sbuf_printf(sb, "MANUAL"); 840132665Spjd break; 841132665Spjd default: 842132665Spjd sbuf_printf(sb, "UNKNOWN"); 843132665Spjd break; 844132665Spjd } 845132665Spjd sbuf_printf(sb, "</Type>\n"); 846132665Spjd sbuf_printf(sb, "%s<Status>Total=%u, Online=%u</Status>\n", 847132665Spjd indent, sc->sc_ndisks, g_concat_nvalid(sc)); 848132665Spjd sbuf_printf(sb, "%s<State>", indent); 849132665Spjd if (sc->sc_provider != NULL && sc->sc_provider->error == 0) 850132665Spjd sbuf_printf(sb, "UP"); 851132665Spjd else 852132665Spjd sbuf_printf(sb, "DOWN"); 853132665Spjd sbuf_printf(sb, "</State>\n"); 854128486Spjd } 855126007Spjd} 856126007Spjd 857126007SpjdDECLARE_GEOM_CLASS(g_concat_class, g_concat); 858