1080361d6SPawel Jakub Dawidek /*- 24d846d26SWarner Losh * SPDX-License-Identifier: BSD-2-Clause 33728855aSPedro F. Giffuni * 499394c59SPawel Jakub Dawidek * Copyright (c) 2005 Pawel Jakub Dawidek <pjd@FreeBSD.org> 5080361d6SPawel Jakub Dawidek * All rights reserved. 6080361d6SPawel Jakub Dawidek * 7080361d6SPawel Jakub Dawidek * Redistribution and use in source and binary forms, with or without 8080361d6SPawel Jakub Dawidek * modification, are permitted provided that the following conditions 9080361d6SPawel Jakub Dawidek * are met: 10080361d6SPawel Jakub Dawidek * 1. Redistributions of source code must retain the above copyright 11080361d6SPawel Jakub Dawidek * notice, this list of conditions and the following disclaimer. 12080361d6SPawel Jakub Dawidek * 2. Redistributions in binary form must reproduce the above copyright 13080361d6SPawel Jakub Dawidek * notice, this list of conditions and the following disclaimer in the 14080361d6SPawel Jakub Dawidek * documentation and/or other materials provided with the distribution. 15080361d6SPawel Jakub Dawidek * 16080361d6SPawel Jakub Dawidek * THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND 17080361d6SPawel Jakub Dawidek * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 18080361d6SPawel Jakub Dawidek * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 19080361d6SPawel Jakub Dawidek * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE 20080361d6SPawel Jakub Dawidek * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 21080361d6SPawel Jakub Dawidek * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 22080361d6SPawel Jakub Dawidek * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 23080361d6SPawel Jakub Dawidek * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 24080361d6SPawel Jakub Dawidek * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 25080361d6SPawel Jakub Dawidek * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 26080361d6SPawel Jakub Dawidek * SUCH DAMAGE. 27080361d6SPawel Jakub Dawidek */ 28080361d6SPawel Jakub Dawidek 29080361d6SPawel Jakub Dawidek #include <sys/cdefs.h> 30080361d6SPawel Jakub Dawidek __FBSDID("$FreeBSD$"); 31080361d6SPawel Jakub Dawidek 32080361d6SPawel Jakub Dawidek #include <sys/param.h> 33080361d6SPawel Jakub Dawidek #include <sys/systm.h> 34080361d6SPawel Jakub Dawidek #include <sys/kernel.h> 35080361d6SPawel Jakub Dawidek #include <sys/module.h> 36080361d6SPawel Jakub Dawidek #include <sys/lock.h> 37080361d6SPawel Jakub Dawidek #include <sys/mutex.h> 38080361d6SPawel Jakub Dawidek #include <sys/bio.h> 395d807a0eSAndrey V. Elsukov #include <sys/sbuf.h> 40080361d6SPawel Jakub Dawidek #include <sys/sysctl.h> 41080361d6SPawel Jakub Dawidek #include <sys/malloc.h> 42080361d6SPawel Jakub Dawidek #include <vm/uma.h> 43080361d6SPawel Jakub Dawidek #include <geom/geom.h> 44ac03832eSConrad Meyer #include <geom/geom_dbg.h> 45080361d6SPawel Jakub Dawidek #include <geom/shsec/g_shsec.h> 46080361d6SPawel Jakub Dawidek 47cb08c2ccSAlexander Leidinger FEATURE(geom_shsec, "GEOM shared secret device support"); 48080361d6SPawel Jakub Dawidek 495bb84bc8SRobert Watson static MALLOC_DEFINE(M_SHSEC, "shsec_data", "GEOM_SHSEC Data"); 50080361d6SPawel Jakub Dawidek 51080361d6SPawel Jakub Dawidek static uma_zone_t g_shsec_zone; 52080361d6SPawel Jakub Dawidek 53080361d6SPawel Jakub Dawidek static int g_shsec_destroy(struct g_shsec_softc *sc, boolean_t force); 54080361d6SPawel Jakub Dawidek static int g_shsec_destroy_geom(struct gctl_req *req, struct g_class *mp, 55080361d6SPawel Jakub Dawidek struct g_geom *gp); 56080361d6SPawel Jakub Dawidek 57080361d6SPawel Jakub Dawidek static g_taste_t g_shsec_taste; 58080361d6SPawel Jakub Dawidek static g_ctl_req_t g_shsec_config; 59080361d6SPawel Jakub Dawidek static g_dumpconf_t g_shsec_dumpconf; 60080361d6SPawel Jakub Dawidek static g_init_t g_shsec_init; 61080361d6SPawel Jakub Dawidek static g_fini_t g_shsec_fini; 62080361d6SPawel Jakub Dawidek 63080361d6SPawel Jakub Dawidek struct g_class g_shsec_class = { 64080361d6SPawel Jakub Dawidek .name = G_SHSEC_CLASS_NAME, 65080361d6SPawel Jakub Dawidek .version = G_VERSION, 66080361d6SPawel Jakub Dawidek .ctlreq = g_shsec_config, 67080361d6SPawel Jakub Dawidek .taste = g_shsec_taste, 68080361d6SPawel Jakub Dawidek .destroy_geom = g_shsec_destroy_geom, 69080361d6SPawel Jakub Dawidek .init = g_shsec_init, 70080361d6SPawel Jakub Dawidek .fini = g_shsec_fini 71080361d6SPawel Jakub Dawidek }; 72080361d6SPawel Jakub Dawidek 73080361d6SPawel Jakub Dawidek SYSCTL_DECL(_kern_geom); 747029da5cSPawel Biernacki static SYSCTL_NODE(_kern_geom, OID_AUTO, shsec, CTLFLAG_RW | CTLFLAG_MPSAFE, 0, 756472ac3dSEd Schouten "GEOM_SHSEC stuff"); 76cd853791SKonstantin Belousov static u_int g_shsec_debug; 77af3b2549SHans Petter Selasky SYSCTL_UINT(_kern_geom_shsec, OID_AUTO, debug, CTLFLAG_RWTUN, &g_shsec_debug, 0, 78080361d6SPawel Jakub Dawidek "Debug level"); 79cd853791SKonstantin Belousov static u_long g_shsec_maxmem; 80cd853791SKonstantin Belousov SYSCTL_ULONG(_kern_geom_shsec, OID_AUTO, maxmem, 81cd853791SKonstantin Belousov CTLFLAG_RDTUN | CTLFLAG_NOFETCH, &g_shsec_maxmem, 82080361d6SPawel Jakub Dawidek 0, "Maximum memory that can be allocated for I/O (in bytes)"); 83080361d6SPawel Jakub Dawidek static u_int g_shsec_alloc_failed = 0; 84080361d6SPawel Jakub Dawidek SYSCTL_UINT(_kern_geom_shsec, OID_AUTO, alloc_failed, CTLFLAG_RD, 85080361d6SPawel Jakub Dawidek &g_shsec_alloc_failed, 0, "How many times I/O allocation failed"); 86080361d6SPawel Jakub Dawidek 87080361d6SPawel Jakub Dawidek /* 88080361d6SPawel Jakub Dawidek * Greatest Common Divisor. 89080361d6SPawel Jakub Dawidek */ 90080361d6SPawel Jakub Dawidek static u_int 91080361d6SPawel Jakub Dawidek gcd(u_int a, u_int b) 92080361d6SPawel Jakub Dawidek { 93080361d6SPawel Jakub Dawidek u_int c; 94080361d6SPawel Jakub Dawidek 95080361d6SPawel Jakub Dawidek while (b != 0) { 96080361d6SPawel Jakub Dawidek c = a; 97080361d6SPawel Jakub Dawidek a = b; 98080361d6SPawel Jakub Dawidek b = (c % b); 99080361d6SPawel Jakub Dawidek } 100080361d6SPawel Jakub Dawidek return (a); 101080361d6SPawel Jakub Dawidek } 102080361d6SPawel Jakub Dawidek 103080361d6SPawel Jakub Dawidek /* 104080361d6SPawel Jakub Dawidek * Least Common Multiple. 105080361d6SPawel Jakub Dawidek */ 106080361d6SPawel Jakub Dawidek static u_int 107080361d6SPawel Jakub Dawidek lcm(u_int a, u_int b) 108080361d6SPawel Jakub Dawidek { 109080361d6SPawel Jakub Dawidek 110080361d6SPawel Jakub Dawidek return ((a * b) / gcd(a, b)); 111080361d6SPawel Jakub Dawidek } 112080361d6SPawel Jakub Dawidek 113080361d6SPawel Jakub Dawidek static void 114080361d6SPawel Jakub Dawidek g_shsec_init(struct g_class *mp __unused) 115080361d6SPawel Jakub Dawidek { 116080361d6SPawel Jakub Dawidek 117cd853791SKonstantin Belousov g_shsec_maxmem = maxphys * 100; 118cd853791SKonstantin Belousov TUNABLE_ULONG_FETCH("kern.geom.shsec.maxmem,", &g_shsec_maxmem); 119cd853791SKonstantin Belousov g_shsec_zone = uma_zcreate("g_shsec_zone", maxphys, NULL, NULL, NULL, 120080361d6SPawel Jakub Dawidek NULL, 0, 0); 121cd853791SKonstantin Belousov g_shsec_maxmem -= g_shsec_maxmem % maxphys; 122cd853791SKonstantin Belousov uma_zone_set_max(g_shsec_zone, g_shsec_maxmem / maxphys); 123080361d6SPawel Jakub Dawidek } 124080361d6SPawel Jakub Dawidek 125080361d6SPawel Jakub Dawidek static void 126080361d6SPawel Jakub Dawidek g_shsec_fini(struct g_class *mp __unused) 127080361d6SPawel Jakub Dawidek { 128080361d6SPawel Jakub Dawidek 129080361d6SPawel Jakub Dawidek uma_zdestroy(g_shsec_zone); 130080361d6SPawel Jakub Dawidek } 131080361d6SPawel Jakub Dawidek 132080361d6SPawel Jakub Dawidek /* 133080361d6SPawel Jakub Dawidek * Return the number of valid disks. 134080361d6SPawel Jakub Dawidek */ 135080361d6SPawel Jakub Dawidek static u_int 136080361d6SPawel Jakub Dawidek g_shsec_nvalid(struct g_shsec_softc *sc) 137080361d6SPawel Jakub Dawidek { 138080361d6SPawel Jakub Dawidek u_int i, no; 139080361d6SPawel Jakub Dawidek 140080361d6SPawel Jakub Dawidek no = 0; 141080361d6SPawel Jakub Dawidek for (i = 0; i < sc->sc_ndisks; i++) { 142080361d6SPawel Jakub Dawidek if (sc->sc_disks[i] != NULL) 143080361d6SPawel Jakub Dawidek no++; 144080361d6SPawel Jakub Dawidek } 145080361d6SPawel Jakub Dawidek 146080361d6SPawel Jakub Dawidek return (no); 147080361d6SPawel Jakub Dawidek } 148080361d6SPawel Jakub Dawidek 149080361d6SPawel Jakub Dawidek static void 150080361d6SPawel Jakub Dawidek g_shsec_remove_disk(struct g_consumer *cp) 151080361d6SPawel Jakub Dawidek { 152080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 153080361d6SPawel Jakub Dawidek u_int no; 154080361d6SPawel Jakub Dawidek 155080361d6SPawel Jakub Dawidek KASSERT(cp != NULL, ("Non-valid disk in %s.", __func__)); 156080361d6SPawel Jakub Dawidek sc = (struct g_shsec_softc *)cp->private; 157080361d6SPawel Jakub Dawidek KASSERT(sc != NULL, ("NULL sc in %s.", __func__)); 158080361d6SPawel Jakub Dawidek no = cp->index; 159080361d6SPawel Jakub Dawidek 160080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Disk %s removed from %s.", cp->provider->name, 161080361d6SPawel Jakub Dawidek sc->sc_name); 162080361d6SPawel Jakub Dawidek 163080361d6SPawel Jakub Dawidek sc->sc_disks[no] = NULL; 164080361d6SPawel Jakub Dawidek if (sc->sc_provider != NULL) { 1658b64f3caSAlexander Motin g_wither_provider(sc->sc_provider, ENXIO); 166080361d6SPawel Jakub Dawidek sc->sc_provider = NULL; 167080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s removed.", sc->sc_name); 168080361d6SPawel Jakub Dawidek } 169080361d6SPawel Jakub Dawidek 170080361d6SPawel Jakub Dawidek if (cp->acr > 0 || cp->acw > 0 || cp->ace > 0) 1716a8eef35SAlexander Motin return; 172080361d6SPawel Jakub Dawidek g_detach(cp); 173080361d6SPawel Jakub Dawidek g_destroy_consumer(cp); 174080361d6SPawel Jakub Dawidek } 175080361d6SPawel Jakub Dawidek 176080361d6SPawel Jakub Dawidek static void 177080361d6SPawel Jakub Dawidek g_shsec_orphan(struct g_consumer *cp) 178080361d6SPawel Jakub Dawidek { 179080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 180080361d6SPawel Jakub Dawidek struct g_geom *gp; 181080361d6SPawel Jakub Dawidek 182080361d6SPawel Jakub Dawidek g_topology_assert(); 183080361d6SPawel Jakub Dawidek gp = cp->geom; 184080361d6SPawel Jakub Dawidek sc = gp->softc; 185080361d6SPawel Jakub Dawidek if (sc == NULL) 186080361d6SPawel Jakub Dawidek return; 187080361d6SPawel Jakub Dawidek 188080361d6SPawel Jakub Dawidek g_shsec_remove_disk(cp); 189080361d6SPawel Jakub Dawidek /* If there are no valid disks anymore, remove device. */ 190cfdb9185SAlexander Motin if (LIST_EMPTY(&gp->consumer)) 191080361d6SPawel Jakub Dawidek g_shsec_destroy(sc, 1); 192080361d6SPawel Jakub Dawidek } 193080361d6SPawel Jakub Dawidek 194080361d6SPawel Jakub Dawidek static int 195080361d6SPawel Jakub Dawidek g_shsec_access(struct g_provider *pp, int dr, int dw, int de) 196080361d6SPawel Jakub Dawidek { 1976a8eef35SAlexander Motin struct g_consumer *cp1, *cp2, *tmp; 198080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 199080361d6SPawel Jakub Dawidek struct g_geom *gp; 200080361d6SPawel Jakub Dawidek int error; 201080361d6SPawel Jakub Dawidek 202080361d6SPawel Jakub Dawidek gp = pp->geom; 203080361d6SPawel Jakub Dawidek sc = gp->softc; 204080361d6SPawel Jakub Dawidek 205080361d6SPawel Jakub Dawidek /* On first open, grab an extra "exclusive" bit */ 206080361d6SPawel Jakub Dawidek if (pp->acr == 0 && pp->acw == 0 && pp->ace == 0) 207080361d6SPawel Jakub Dawidek de++; 208080361d6SPawel Jakub Dawidek /* ... and let go of it on last close */ 209080361d6SPawel Jakub Dawidek if ((pp->acr + dr) == 0 && (pp->acw + dw) == 0 && (pp->ace + de) == 0) 210080361d6SPawel Jakub Dawidek de--; 211080361d6SPawel Jakub Dawidek 212080361d6SPawel Jakub Dawidek error = ENXIO; 2136a8eef35SAlexander Motin LIST_FOREACH_SAFE(cp1, &gp->consumer, consumer, tmp) { 214080361d6SPawel Jakub Dawidek error = g_access(cp1, dr, dw, de); 2156a8eef35SAlexander Motin if (error != 0) 2166a8eef35SAlexander Motin goto fail; 2176a8eef35SAlexander Motin if (cp1->acr == 0 && cp1->acw == 0 && cp1->ace == 0 && 2186a8eef35SAlexander Motin cp1->flags & G_CF_ORPHAN) { 2196a8eef35SAlexander Motin g_detach(cp1); 2206a8eef35SAlexander Motin g_destroy_consumer(cp1); 2216a8eef35SAlexander Motin } 2226a8eef35SAlexander Motin } 223cfdb9185SAlexander Motin 224cfdb9185SAlexander Motin /* If there are no valid disks anymore, remove device. */ 225cfdb9185SAlexander Motin if (LIST_EMPTY(&gp->consumer)) 226cfdb9185SAlexander Motin g_shsec_destroy(sc, 1); 227cfdb9185SAlexander Motin 2286a8eef35SAlexander Motin return (error); 2296a8eef35SAlexander Motin 2306a8eef35SAlexander Motin fail: 2316a8eef35SAlexander Motin /* If we fail here, backout all previous changes. */ 232080361d6SPawel Jakub Dawidek LIST_FOREACH(cp2, &gp->consumer, consumer) { 233080361d6SPawel Jakub Dawidek if (cp1 == cp2) 2346a8eef35SAlexander Motin break; 235080361d6SPawel Jakub Dawidek g_access(cp2, -dr, -dw, -de); 236080361d6SPawel Jakub Dawidek } 237080361d6SPawel Jakub Dawidek return (error); 238080361d6SPawel Jakub Dawidek } 239080361d6SPawel Jakub Dawidek 240080361d6SPawel Jakub Dawidek static void 241080361d6SPawel Jakub Dawidek g_shsec_xor1(uint32_t *src, uint32_t *dst, ssize_t len) 242080361d6SPawel Jakub Dawidek { 243080361d6SPawel Jakub Dawidek 244080361d6SPawel Jakub Dawidek for (; len > 0; len -= sizeof(uint32_t), dst++) 245080361d6SPawel Jakub Dawidek *dst = *dst ^ *src++; 246080361d6SPawel Jakub Dawidek KASSERT(len == 0, ("len != 0 (len=%zd)", len)); 247080361d6SPawel Jakub Dawidek } 248080361d6SPawel Jakub Dawidek 249080361d6SPawel Jakub Dawidek static void 250080361d6SPawel Jakub Dawidek g_shsec_done(struct bio *bp) 251080361d6SPawel Jakub Dawidek { 252080361d6SPawel Jakub Dawidek struct bio *pbp; 253080361d6SPawel Jakub Dawidek 254080361d6SPawel Jakub Dawidek pbp = bp->bio_parent; 255080361d6SPawel Jakub Dawidek if (bp->bio_error == 0) 256080361d6SPawel Jakub Dawidek G_SHSEC_LOGREQ(2, bp, "Request done."); 257080361d6SPawel Jakub Dawidek else { 258080361d6SPawel Jakub Dawidek G_SHSEC_LOGREQ(0, bp, "Request failed (error=%d).", 259080361d6SPawel Jakub Dawidek bp->bio_error); 260080361d6SPawel Jakub Dawidek if (pbp->bio_error == 0) 261080361d6SPawel Jakub Dawidek pbp->bio_error = bp->bio_error; 262080361d6SPawel Jakub Dawidek } 263080361d6SPawel Jakub Dawidek if (pbp->bio_cmd == BIO_READ) { 264080361d6SPawel Jakub Dawidek if ((pbp->bio_pflags & G_SHSEC_BFLAG_FIRST) != 0) { 265080361d6SPawel Jakub Dawidek bcopy(bp->bio_data, pbp->bio_data, pbp->bio_length); 266080361d6SPawel Jakub Dawidek pbp->bio_pflags = 0; 267080361d6SPawel Jakub Dawidek } else { 268080361d6SPawel Jakub Dawidek g_shsec_xor1((uint32_t *)bp->bio_data, 269080361d6SPawel Jakub Dawidek (uint32_t *)pbp->bio_data, 270080361d6SPawel Jakub Dawidek (ssize_t)pbp->bio_length); 271080361d6SPawel Jakub Dawidek } 272080361d6SPawel Jakub Dawidek } 273a2dfffb9SMark Johnston if (bp->bio_data != NULL) { 2746572e5ffSJohn Baldwin explicit_bzero(bp->bio_data, bp->bio_length); 275080361d6SPawel Jakub Dawidek uma_zfree(g_shsec_zone, bp->bio_data); 276a2dfffb9SMark Johnston } 277080361d6SPawel Jakub Dawidek g_destroy_bio(bp); 278080361d6SPawel Jakub Dawidek pbp->bio_inbed++; 279080361d6SPawel Jakub Dawidek if (pbp->bio_children == pbp->bio_inbed) { 280080361d6SPawel Jakub Dawidek pbp->bio_completed = pbp->bio_length; 281080361d6SPawel Jakub Dawidek g_io_deliver(pbp, pbp->bio_error); 282080361d6SPawel Jakub Dawidek } 283080361d6SPawel Jakub Dawidek } 284080361d6SPawel Jakub Dawidek 285080361d6SPawel Jakub Dawidek static void 286080361d6SPawel Jakub Dawidek g_shsec_xor2(uint32_t *rand, uint32_t *dst, ssize_t len) 287080361d6SPawel Jakub Dawidek { 288080361d6SPawel Jakub Dawidek 289080361d6SPawel Jakub Dawidek for (; len > 0; len -= sizeof(uint32_t), dst++) { 290080361d6SPawel Jakub Dawidek *rand = arc4random(); 291080361d6SPawel Jakub Dawidek *dst = *dst ^ *rand++; 292080361d6SPawel Jakub Dawidek } 293080361d6SPawel Jakub Dawidek KASSERT(len == 0, ("len != 0 (len=%zd)", len)); 294080361d6SPawel Jakub Dawidek } 295080361d6SPawel Jakub Dawidek 296080361d6SPawel Jakub Dawidek static void 297080361d6SPawel Jakub Dawidek g_shsec_start(struct bio *bp) 298080361d6SPawel Jakub Dawidek { 299080361d6SPawel Jakub Dawidek TAILQ_HEAD(, bio) queue = TAILQ_HEAD_INITIALIZER(queue); 300080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 301080361d6SPawel Jakub Dawidek struct bio *cbp; 302080361d6SPawel Jakub Dawidek uint32_t *dst; 303080361d6SPawel Jakub Dawidek ssize_t len; 304080361d6SPawel Jakub Dawidek u_int no; 305080361d6SPawel Jakub Dawidek int error; 306080361d6SPawel Jakub Dawidek 307080361d6SPawel Jakub Dawidek sc = bp->bio_to->geom->softc; 308080361d6SPawel Jakub Dawidek /* 309080361d6SPawel Jakub Dawidek * If sc == NULL, provider's error should be set and g_shsec_start() 310080361d6SPawel Jakub Dawidek * should not be called at all. 311080361d6SPawel Jakub Dawidek */ 312080361d6SPawel Jakub Dawidek KASSERT(sc != NULL, 313080361d6SPawel Jakub Dawidek ("Provider's error should be set (error=%d)(device=%s).", 314080361d6SPawel Jakub Dawidek bp->bio_to->error, bp->bio_to->name)); 315080361d6SPawel Jakub Dawidek 316080361d6SPawel Jakub Dawidek G_SHSEC_LOGREQ(2, bp, "Request received."); 317080361d6SPawel Jakub Dawidek 318080361d6SPawel Jakub Dawidek switch (bp->bio_cmd) { 319080361d6SPawel Jakub Dawidek case BIO_READ: 320080361d6SPawel Jakub Dawidek case BIO_WRITE: 321118c814eSPawel Jakub Dawidek case BIO_FLUSH: 3228b522bdaSWarner Losh case BIO_SPEEDUP: 323080361d6SPawel Jakub Dawidek /* 324080361d6SPawel Jakub Dawidek * Only those requests are supported. 325080361d6SPawel Jakub Dawidek */ 326080361d6SPawel Jakub Dawidek break; 327080361d6SPawel Jakub Dawidek case BIO_DELETE: 328080361d6SPawel Jakub Dawidek case BIO_GETATTR: 329080361d6SPawel Jakub Dawidek /* To which provider it should be delivered? */ 330080361d6SPawel Jakub Dawidek default: 331080361d6SPawel Jakub Dawidek g_io_deliver(bp, EOPNOTSUPP); 332080361d6SPawel Jakub Dawidek return; 333080361d6SPawel Jakub Dawidek } 334080361d6SPawel Jakub Dawidek 335080361d6SPawel Jakub Dawidek /* 336080361d6SPawel Jakub Dawidek * Allocate all bios first and calculate XOR. 337080361d6SPawel Jakub Dawidek */ 338080361d6SPawel Jakub Dawidek dst = NULL; 339080361d6SPawel Jakub Dawidek len = bp->bio_length; 340080361d6SPawel Jakub Dawidek if (bp->bio_cmd == BIO_READ) 341080361d6SPawel Jakub Dawidek bp->bio_pflags = G_SHSEC_BFLAG_FIRST; 342080361d6SPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) { 343080361d6SPawel Jakub Dawidek cbp = g_clone_bio(bp); 344080361d6SPawel Jakub Dawidek if (cbp == NULL) { 345080361d6SPawel Jakub Dawidek error = ENOMEM; 346080361d6SPawel Jakub Dawidek goto failure; 347080361d6SPawel Jakub Dawidek } 348080361d6SPawel Jakub Dawidek TAILQ_INSERT_TAIL(&queue, cbp, bio_queue); 349080361d6SPawel Jakub Dawidek 350080361d6SPawel Jakub Dawidek /* 351080361d6SPawel Jakub Dawidek * Fill in the component buf structure. 352080361d6SPawel Jakub Dawidek */ 353080361d6SPawel Jakub Dawidek cbp->bio_done = g_shsec_done; 354a2dfffb9SMark Johnston cbp->bio_caller2 = sc->sc_disks[no]; 355a2dfffb9SMark Johnston if (bp->bio_cmd == BIO_READ || bp->bio_cmd == BIO_WRITE) { 356080361d6SPawel Jakub Dawidek cbp->bio_data = uma_zalloc(g_shsec_zone, M_NOWAIT); 357080361d6SPawel Jakub Dawidek if (cbp->bio_data == NULL) { 358080361d6SPawel Jakub Dawidek g_shsec_alloc_failed++; 359080361d6SPawel Jakub Dawidek error = ENOMEM; 360080361d6SPawel Jakub Dawidek goto failure; 361080361d6SPawel Jakub Dawidek } 362080361d6SPawel Jakub Dawidek if (bp->bio_cmd == BIO_WRITE) { 363080361d6SPawel Jakub Dawidek if (no == 0) { 364080361d6SPawel Jakub Dawidek dst = (uint32_t *)cbp->bio_data; 365080361d6SPawel Jakub Dawidek bcopy(bp->bio_data, dst, len); 366080361d6SPawel Jakub Dawidek } else { 367a2dfffb9SMark Johnston g_shsec_xor2((uint32_t *)cbp->bio_data, 368a2dfffb9SMark Johnston dst, len); 369a2dfffb9SMark Johnston } 370080361d6SPawel Jakub Dawidek } 371080361d6SPawel Jakub Dawidek } 372080361d6SPawel Jakub Dawidek } 373080361d6SPawel Jakub Dawidek /* 374080361d6SPawel Jakub Dawidek * Fire off all allocated requests! 375080361d6SPawel Jakub Dawidek */ 376080361d6SPawel Jakub Dawidek while ((cbp = TAILQ_FIRST(&queue)) != NULL) { 377080361d6SPawel Jakub Dawidek struct g_consumer *cp; 378080361d6SPawel Jakub Dawidek 379080361d6SPawel Jakub Dawidek TAILQ_REMOVE(&queue, cbp, bio_queue); 380080361d6SPawel Jakub Dawidek cp = cbp->bio_caller2; 381080361d6SPawel Jakub Dawidek cbp->bio_caller2 = NULL; 382080361d6SPawel Jakub Dawidek cbp->bio_to = cp->provider; 383080361d6SPawel Jakub Dawidek G_SHSEC_LOGREQ(2, cbp, "Sending request."); 384080361d6SPawel Jakub Dawidek g_io_request(cbp, cp); 385080361d6SPawel Jakub Dawidek } 386080361d6SPawel Jakub Dawidek return; 387080361d6SPawel Jakub Dawidek failure: 388080361d6SPawel Jakub Dawidek while ((cbp = TAILQ_FIRST(&queue)) != NULL) { 389080361d6SPawel Jakub Dawidek TAILQ_REMOVE(&queue, cbp, bio_queue); 390080361d6SPawel Jakub Dawidek bp->bio_children--; 391080361d6SPawel Jakub Dawidek if (cbp->bio_data != NULL) { 3926572e5ffSJohn Baldwin explicit_bzero(cbp->bio_data, cbp->bio_length); 393080361d6SPawel Jakub Dawidek uma_zfree(g_shsec_zone, cbp->bio_data); 394080361d6SPawel Jakub Dawidek } 395080361d6SPawel Jakub Dawidek g_destroy_bio(cbp); 396080361d6SPawel Jakub Dawidek } 397080361d6SPawel Jakub Dawidek if (bp->bio_error == 0) 398080361d6SPawel Jakub Dawidek bp->bio_error = error; 399080361d6SPawel Jakub Dawidek g_io_deliver(bp, bp->bio_error); 400080361d6SPawel Jakub Dawidek } 401080361d6SPawel Jakub Dawidek 402080361d6SPawel Jakub Dawidek static void 403080361d6SPawel Jakub Dawidek g_shsec_check_and_run(struct g_shsec_softc *sc) 404080361d6SPawel Jakub Dawidek { 405080361d6SPawel Jakub Dawidek off_t mediasize, ms; 406080361d6SPawel Jakub Dawidek u_int no, sectorsize = 0; 407080361d6SPawel Jakub Dawidek 408080361d6SPawel Jakub Dawidek if (g_shsec_nvalid(sc) != sc->sc_ndisks) 409080361d6SPawel Jakub Dawidek return; 410080361d6SPawel Jakub Dawidek 411080361d6SPawel Jakub Dawidek sc->sc_provider = g_new_providerf(sc->sc_geom, "shsec/%s", sc->sc_name); 412080361d6SPawel Jakub Dawidek /* 413080361d6SPawel Jakub Dawidek * Find the smallest disk. 414080361d6SPawel Jakub Dawidek */ 415080361d6SPawel Jakub Dawidek mediasize = sc->sc_disks[0]->provider->mediasize; 416080361d6SPawel Jakub Dawidek mediasize -= sc->sc_disks[0]->provider->sectorsize; 417080361d6SPawel Jakub Dawidek sectorsize = sc->sc_disks[0]->provider->sectorsize; 418080361d6SPawel Jakub Dawidek for (no = 1; no < sc->sc_ndisks; no++) { 419080361d6SPawel Jakub Dawidek ms = sc->sc_disks[no]->provider->mediasize; 420080361d6SPawel Jakub Dawidek ms -= sc->sc_disks[no]->provider->sectorsize; 421080361d6SPawel Jakub Dawidek if (ms < mediasize) 422080361d6SPawel Jakub Dawidek mediasize = ms; 423080361d6SPawel Jakub Dawidek sectorsize = lcm(sectorsize, 424080361d6SPawel Jakub Dawidek sc->sc_disks[no]->provider->sectorsize); 425080361d6SPawel Jakub Dawidek } 426080361d6SPawel Jakub Dawidek sc->sc_provider->sectorsize = sectorsize; 427080361d6SPawel Jakub Dawidek sc->sc_provider->mediasize = mediasize; 428080361d6SPawel Jakub Dawidek g_error_provider(sc->sc_provider, 0); 429080361d6SPawel Jakub Dawidek 430080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s activated.", sc->sc_name); 431080361d6SPawel Jakub Dawidek } 432080361d6SPawel Jakub Dawidek 433080361d6SPawel Jakub Dawidek static int 434080361d6SPawel Jakub Dawidek g_shsec_read_metadata(struct g_consumer *cp, struct g_shsec_metadata *md) 435080361d6SPawel Jakub Dawidek { 436080361d6SPawel Jakub Dawidek struct g_provider *pp; 437080361d6SPawel Jakub Dawidek u_char *buf; 438080361d6SPawel Jakub Dawidek int error; 439080361d6SPawel Jakub Dawidek 440080361d6SPawel Jakub Dawidek g_topology_assert(); 441080361d6SPawel Jakub Dawidek 442080361d6SPawel Jakub Dawidek error = g_access(cp, 1, 0, 0); 443080361d6SPawel Jakub Dawidek if (error != 0) 444080361d6SPawel Jakub Dawidek return (error); 445080361d6SPawel Jakub Dawidek pp = cp->provider; 446080361d6SPawel Jakub Dawidek g_topology_unlock(); 447080361d6SPawel Jakub Dawidek buf = g_read_data(cp, pp->mediasize - pp->sectorsize, pp->sectorsize, 448080361d6SPawel Jakub Dawidek &error); 449080361d6SPawel Jakub Dawidek g_topology_lock(); 450080361d6SPawel Jakub Dawidek g_access(cp, -1, 0, 0); 451080361d6SPawel Jakub Dawidek if (buf == NULL) 452080361d6SPawel Jakub Dawidek return (error); 453080361d6SPawel Jakub Dawidek 454080361d6SPawel Jakub Dawidek /* Decode metadata. */ 455080361d6SPawel Jakub Dawidek shsec_metadata_decode(buf, md); 456080361d6SPawel Jakub Dawidek g_free(buf); 457080361d6SPawel Jakub Dawidek 458080361d6SPawel Jakub Dawidek return (0); 459080361d6SPawel Jakub Dawidek } 460080361d6SPawel Jakub Dawidek 461080361d6SPawel Jakub Dawidek /* 462080361d6SPawel Jakub Dawidek * Add disk to given device. 463080361d6SPawel Jakub Dawidek */ 464080361d6SPawel Jakub Dawidek static int 465080361d6SPawel Jakub Dawidek g_shsec_add_disk(struct g_shsec_softc *sc, struct g_provider *pp, u_int no) 466080361d6SPawel Jakub Dawidek { 467080361d6SPawel Jakub Dawidek struct g_consumer *cp, *fcp; 468080361d6SPawel Jakub Dawidek struct g_geom *gp; 469080361d6SPawel Jakub Dawidek struct g_shsec_metadata md; 470080361d6SPawel Jakub Dawidek int error; 471080361d6SPawel Jakub Dawidek 472080361d6SPawel Jakub Dawidek /* Metadata corrupted? */ 473080361d6SPawel Jakub Dawidek if (no >= sc->sc_ndisks) 474080361d6SPawel Jakub Dawidek return (EINVAL); 475080361d6SPawel Jakub Dawidek 476080361d6SPawel Jakub Dawidek /* Check if disk is not already attached. */ 477080361d6SPawel Jakub Dawidek if (sc->sc_disks[no] != NULL) 478080361d6SPawel Jakub Dawidek return (EEXIST); 479080361d6SPawel Jakub Dawidek 480080361d6SPawel Jakub Dawidek gp = sc->sc_geom; 481080361d6SPawel Jakub Dawidek fcp = LIST_FIRST(&gp->consumer); 482080361d6SPawel Jakub Dawidek 483080361d6SPawel Jakub Dawidek cp = g_new_consumer(gp); 484080361d6SPawel Jakub Dawidek error = g_attach(cp, pp); 485080361d6SPawel Jakub Dawidek if (error != 0) { 486080361d6SPawel Jakub Dawidek g_destroy_consumer(cp); 487080361d6SPawel Jakub Dawidek return (error); 488080361d6SPawel Jakub Dawidek } 489080361d6SPawel Jakub Dawidek 490080361d6SPawel Jakub Dawidek if (fcp != NULL && (fcp->acr > 0 || fcp->acw > 0 || fcp->ace > 0)) { 491080361d6SPawel Jakub Dawidek error = g_access(cp, fcp->acr, fcp->acw, fcp->ace); 492080361d6SPawel Jakub Dawidek if (error != 0) { 493080361d6SPawel Jakub Dawidek g_detach(cp); 494080361d6SPawel Jakub Dawidek g_destroy_consumer(cp); 495080361d6SPawel Jakub Dawidek return (error); 496080361d6SPawel Jakub Dawidek } 497080361d6SPawel Jakub Dawidek } 498080361d6SPawel Jakub Dawidek 499080361d6SPawel Jakub Dawidek /* Reread metadata. */ 500080361d6SPawel Jakub Dawidek error = g_shsec_read_metadata(cp, &md); 501080361d6SPawel Jakub Dawidek if (error != 0) 502080361d6SPawel Jakub Dawidek goto fail; 503080361d6SPawel Jakub Dawidek 504080361d6SPawel Jakub Dawidek if (strcmp(md.md_magic, G_SHSEC_MAGIC) != 0 || 505080361d6SPawel Jakub Dawidek strcmp(md.md_name, sc->sc_name) != 0 || md.md_id != sc->sc_id) { 506080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Metadata on %s changed.", pp->name); 507080361d6SPawel Jakub Dawidek goto fail; 508080361d6SPawel Jakub Dawidek } 509080361d6SPawel Jakub Dawidek 510080361d6SPawel Jakub Dawidek cp->private = sc; 511080361d6SPawel Jakub Dawidek cp->index = no; 512080361d6SPawel Jakub Dawidek sc->sc_disks[no] = cp; 513080361d6SPawel Jakub Dawidek 514080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Disk %s attached to %s.", pp->name, sc->sc_name); 515080361d6SPawel Jakub Dawidek 516080361d6SPawel Jakub Dawidek g_shsec_check_and_run(sc); 517080361d6SPawel Jakub Dawidek 518080361d6SPawel Jakub Dawidek return (0); 519080361d6SPawel Jakub Dawidek fail: 520080361d6SPawel Jakub Dawidek if (fcp != NULL && (fcp->acr > 0 || fcp->acw > 0 || fcp->ace > 0)) 521080361d6SPawel Jakub Dawidek g_access(cp, -fcp->acr, -fcp->acw, -fcp->ace); 522080361d6SPawel Jakub Dawidek g_detach(cp); 523080361d6SPawel Jakub Dawidek g_destroy_consumer(cp); 524080361d6SPawel Jakub Dawidek return (error); 525080361d6SPawel Jakub Dawidek } 526080361d6SPawel Jakub Dawidek 527080361d6SPawel Jakub Dawidek static struct g_geom * 528080361d6SPawel Jakub Dawidek g_shsec_create(struct g_class *mp, const struct g_shsec_metadata *md) 529080361d6SPawel Jakub Dawidek { 530080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 531080361d6SPawel Jakub Dawidek struct g_geom *gp; 532080361d6SPawel Jakub Dawidek u_int no; 533080361d6SPawel Jakub Dawidek 534080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(1, "Creating device %s (id=%u).", md->md_name, md->md_id); 535080361d6SPawel Jakub Dawidek 536080361d6SPawel Jakub Dawidek /* Two disks is minimum. */ 537080361d6SPawel Jakub Dawidek if (md->md_all < 2) { 538080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Too few disks defined for %s.", md->md_name); 539080361d6SPawel Jakub Dawidek return (NULL); 540080361d6SPawel Jakub Dawidek } 541080361d6SPawel Jakub Dawidek 542080361d6SPawel Jakub Dawidek /* Check for duplicate unit */ 543080361d6SPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) { 544080361d6SPawel Jakub Dawidek sc = gp->softc; 545080361d6SPawel Jakub Dawidek if (sc != NULL && strcmp(sc->sc_name, md->md_name) == 0) { 546080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s already configured.", 547080361d6SPawel Jakub Dawidek sc->sc_name); 548080361d6SPawel Jakub Dawidek return (NULL); 549080361d6SPawel Jakub Dawidek } 550080361d6SPawel Jakub Dawidek } 551080361d6SPawel Jakub Dawidek gp = g_new_geomf(mp, "%s", md->md_name); 552080361d6SPawel Jakub Dawidek sc = malloc(sizeof(*sc), M_SHSEC, M_WAITOK | M_ZERO); 553080361d6SPawel Jakub Dawidek gp->start = g_shsec_start; 554080361d6SPawel Jakub Dawidek gp->spoiled = g_shsec_orphan; 555080361d6SPawel Jakub Dawidek gp->orphan = g_shsec_orphan; 556080361d6SPawel Jakub Dawidek gp->access = g_shsec_access; 557080361d6SPawel Jakub Dawidek gp->dumpconf = g_shsec_dumpconf; 558080361d6SPawel Jakub Dawidek 559080361d6SPawel Jakub Dawidek sc->sc_id = md->md_id; 560080361d6SPawel Jakub Dawidek sc->sc_ndisks = md->md_all; 561080361d6SPawel Jakub Dawidek sc->sc_disks = malloc(sizeof(struct g_consumer *) * sc->sc_ndisks, 562080361d6SPawel Jakub Dawidek M_SHSEC, M_WAITOK | M_ZERO); 563080361d6SPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) 564080361d6SPawel Jakub Dawidek sc->sc_disks[no] = NULL; 565080361d6SPawel Jakub Dawidek 566080361d6SPawel Jakub Dawidek gp->softc = sc; 567080361d6SPawel Jakub Dawidek sc->sc_geom = gp; 568080361d6SPawel Jakub Dawidek sc->sc_provider = NULL; 569080361d6SPawel Jakub Dawidek 570080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s created (id=%u).", sc->sc_name, sc->sc_id); 571080361d6SPawel Jakub Dawidek 572080361d6SPawel Jakub Dawidek return (gp); 573080361d6SPawel Jakub Dawidek } 574080361d6SPawel Jakub Dawidek 575080361d6SPawel Jakub Dawidek static int 576080361d6SPawel Jakub Dawidek g_shsec_destroy(struct g_shsec_softc *sc, boolean_t force) 577080361d6SPawel Jakub Dawidek { 578080361d6SPawel Jakub Dawidek struct g_provider *pp; 579080361d6SPawel Jakub Dawidek struct g_geom *gp; 580080361d6SPawel Jakub Dawidek u_int no; 581080361d6SPawel Jakub Dawidek 582080361d6SPawel Jakub Dawidek g_topology_assert(); 583080361d6SPawel Jakub Dawidek 584080361d6SPawel Jakub Dawidek if (sc == NULL) 585080361d6SPawel Jakub Dawidek return (ENXIO); 586080361d6SPawel Jakub Dawidek 587080361d6SPawel Jakub Dawidek pp = sc->sc_provider; 588080361d6SPawel Jakub Dawidek if (pp != NULL && (pp->acr != 0 || pp->acw != 0 || pp->ace != 0)) { 589080361d6SPawel Jakub Dawidek if (force) { 590080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s is still open, so it " 591080361d6SPawel Jakub Dawidek "can't be definitely removed.", pp->name); 592080361d6SPawel Jakub Dawidek } else { 593080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(1, 594080361d6SPawel Jakub Dawidek "Device %s is still open (r%dw%de%d).", pp->name, 595080361d6SPawel Jakub Dawidek pp->acr, pp->acw, pp->ace); 596080361d6SPawel Jakub Dawidek return (EBUSY); 597080361d6SPawel Jakub Dawidek } 598080361d6SPawel Jakub Dawidek } 599080361d6SPawel Jakub Dawidek 600080361d6SPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) { 601080361d6SPawel Jakub Dawidek if (sc->sc_disks[no] != NULL) 602080361d6SPawel Jakub Dawidek g_shsec_remove_disk(sc->sc_disks[no]); 603080361d6SPawel Jakub Dawidek } 604080361d6SPawel Jakub Dawidek 605080361d6SPawel Jakub Dawidek gp = sc->sc_geom; 606080361d6SPawel Jakub Dawidek gp->softc = NULL; 607080361d6SPawel Jakub Dawidek KASSERT(sc->sc_provider == NULL, ("Provider still exists? (device=%s)", 608080361d6SPawel Jakub Dawidek gp->name)); 609080361d6SPawel Jakub Dawidek free(sc->sc_disks, M_SHSEC); 610080361d6SPawel Jakub Dawidek free(sc, M_SHSEC); 611080361d6SPawel Jakub Dawidek 612080361d6SPawel Jakub Dawidek pp = LIST_FIRST(&gp->provider); 613080361d6SPawel Jakub Dawidek if (pp == NULL || (pp->acr == 0 && pp->acw == 0 && pp->ace == 0)) 614080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s destroyed.", gp->name); 615080361d6SPawel Jakub Dawidek 616080361d6SPawel Jakub Dawidek g_wither_geom(gp, ENXIO); 617080361d6SPawel Jakub Dawidek 618080361d6SPawel Jakub Dawidek return (0); 619080361d6SPawel Jakub Dawidek } 620080361d6SPawel Jakub Dawidek 621080361d6SPawel Jakub Dawidek static int 622080361d6SPawel Jakub Dawidek g_shsec_destroy_geom(struct gctl_req *req __unused, struct g_class *mp __unused, 623080361d6SPawel Jakub Dawidek struct g_geom *gp) 624080361d6SPawel Jakub Dawidek { 625080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 626080361d6SPawel Jakub Dawidek 627080361d6SPawel Jakub Dawidek sc = gp->softc; 628080361d6SPawel Jakub Dawidek return (g_shsec_destroy(sc, 0)); 629080361d6SPawel Jakub Dawidek } 630080361d6SPawel Jakub Dawidek 631080361d6SPawel Jakub Dawidek static struct g_geom * 632080361d6SPawel Jakub Dawidek g_shsec_taste(struct g_class *mp, struct g_provider *pp, int flags __unused) 633080361d6SPawel Jakub Dawidek { 634080361d6SPawel Jakub Dawidek struct g_shsec_metadata md; 635080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 636080361d6SPawel Jakub Dawidek struct g_consumer *cp; 637080361d6SPawel Jakub Dawidek struct g_geom *gp; 638080361d6SPawel Jakub Dawidek int error; 639080361d6SPawel Jakub Dawidek 640080361d6SPawel Jakub Dawidek g_trace(G_T_TOPOLOGY, "%s(%s, %s)", __func__, mp->name, pp->name); 641080361d6SPawel Jakub Dawidek g_topology_assert(); 642080361d6SPawel 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 647080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(3, "Tasting %s.", pp->name); 648080361d6SPawel Jakub Dawidek 649080361d6SPawel Jakub Dawidek gp = g_new_geomf(mp, "shsec:taste"); 650080361d6SPawel Jakub Dawidek gp->start = g_shsec_start; 651080361d6SPawel Jakub Dawidek gp->access = g_shsec_access; 652080361d6SPawel Jakub Dawidek gp->orphan = g_shsec_orphan; 653080361d6SPawel Jakub Dawidek cp = g_new_consumer(gp); 65410ae42ccSAlexander Motin cp->flags |= G_CF_DIRECT_SEND | G_CF_DIRECT_RECEIVE; 655d22ff249SEdward Tomasz Napierala error = g_attach(cp, pp); 656d22ff249SEdward Tomasz Napierala if (error == 0) { 657080361d6SPawel Jakub Dawidek error = g_shsec_read_metadata(cp, &md); 658080361d6SPawel Jakub Dawidek g_detach(cp); 659d22ff249SEdward Tomasz Napierala } 660080361d6SPawel Jakub Dawidek g_destroy_consumer(cp); 661080361d6SPawel Jakub Dawidek g_destroy_geom(gp); 662080361d6SPawel Jakub Dawidek if (error != 0) 663080361d6SPawel Jakub Dawidek return (NULL); 664080361d6SPawel Jakub Dawidek gp = NULL; 665080361d6SPawel Jakub Dawidek 666080361d6SPawel Jakub Dawidek if (strcmp(md.md_magic, G_SHSEC_MAGIC) != 0) 667080361d6SPawel Jakub Dawidek return (NULL); 668080361d6SPawel Jakub Dawidek if (md.md_version > G_SHSEC_VERSION) { 669080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Kernel module is too old to handle %s.\n", 670080361d6SPawel Jakub Dawidek pp->name); 671080361d6SPawel Jakub Dawidek return (NULL); 672080361d6SPawel Jakub Dawidek } 673e6890985SPawel Jakub Dawidek /* 674e6890985SPawel Jakub Dawidek * Backward compatibility: 675e6890985SPawel Jakub Dawidek */ 676e6890985SPawel Jakub Dawidek /* There was no md_provsize field in earlier versions of metadata. */ 677e6890985SPawel Jakub Dawidek if (md.md_version < 1) 678e6890985SPawel Jakub Dawidek md.md_provsize = pp->mediasize; 679e6890985SPawel Jakub Dawidek 68090f2be24SAlexander Motin if (md.md_provider[0] != '\0' && 68190f2be24SAlexander Motin !g_compare_names(md.md_provider, pp->name)) 682080361d6SPawel Jakub Dawidek return (NULL); 683e6890985SPawel Jakub Dawidek if (md.md_provsize != pp->mediasize) 684e6890985SPawel Jakub Dawidek return (NULL); 685080361d6SPawel Jakub Dawidek 686080361d6SPawel Jakub Dawidek /* 687080361d6SPawel Jakub Dawidek * Let's check if device already exists. 688080361d6SPawel Jakub Dawidek */ 689080361d6SPawel Jakub Dawidek sc = NULL; 690080361d6SPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) { 691080361d6SPawel Jakub Dawidek sc = gp->softc; 692080361d6SPawel Jakub Dawidek if (sc == NULL) 693080361d6SPawel Jakub Dawidek continue; 694080361d6SPawel Jakub Dawidek if (strcmp(md.md_name, sc->sc_name) != 0) 695080361d6SPawel Jakub Dawidek continue; 696080361d6SPawel Jakub Dawidek if (md.md_id != sc->sc_id) 697080361d6SPawel Jakub Dawidek continue; 698080361d6SPawel Jakub Dawidek break; 699080361d6SPawel Jakub Dawidek } 700080361d6SPawel Jakub Dawidek if (gp != NULL) { 701080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(1, "Adding disk %s to %s.", pp->name, gp->name); 702080361d6SPawel Jakub Dawidek error = g_shsec_add_disk(sc, pp, md.md_no); 703080361d6SPawel Jakub Dawidek if (error != 0) { 704080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Cannot add disk %s to %s (error=%d).", 705080361d6SPawel Jakub Dawidek pp->name, gp->name, error); 706080361d6SPawel Jakub Dawidek return (NULL); 707080361d6SPawel Jakub Dawidek } 708080361d6SPawel Jakub Dawidek } else { 709080361d6SPawel Jakub Dawidek gp = g_shsec_create(mp, &md); 710080361d6SPawel Jakub Dawidek if (gp == NULL) { 711080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Cannot create device %s.", md.md_name); 712080361d6SPawel Jakub Dawidek return (NULL); 713080361d6SPawel Jakub Dawidek } 714080361d6SPawel Jakub Dawidek sc = gp->softc; 715080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(1, "Adding disk %s to %s.", pp->name, gp->name); 716080361d6SPawel Jakub Dawidek error = g_shsec_add_disk(sc, pp, md.md_no); 717080361d6SPawel Jakub Dawidek if (error != 0) { 718080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Cannot add disk %s to %s (error=%d).", 719080361d6SPawel Jakub Dawidek pp->name, gp->name, error); 720080361d6SPawel Jakub Dawidek g_shsec_destroy(sc, 1); 721080361d6SPawel Jakub Dawidek return (NULL); 722080361d6SPawel Jakub Dawidek } 723080361d6SPawel Jakub Dawidek } 724080361d6SPawel Jakub Dawidek return (gp); 725080361d6SPawel Jakub Dawidek } 726080361d6SPawel Jakub Dawidek 727080361d6SPawel Jakub Dawidek static struct g_shsec_softc * 728080361d6SPawel Jakub Dawidek g_shsec_find_device(struct g_class *mp, const char *name) 729080361d6SPawel Jakub Dawidek { 730080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 731080361d6SPawel Jakub Dawidek struct g_geom *gp; 732080361d6SPawel Jakub Dawidek 733080361d6SPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) { 734080361d6SPawel Jakub Dawidek sc = gp->softc; 735080361d6SPawel Jakub Dawidek if (sc == NULL) 736080361d6SPawel Jakub Dawidek continue; 737080361d6SPawel Jakub Dawidek if (strcmp(sc->sc_name, name) == 0) 738080361d6SPawel Jakub Dawidek return (sc); 739080361d6SPawel Jakub Dawidek } 740080361d6SPawel Jakub Dawidek return (NULL); 741080361d6SPawel Jakub Dawidek } 742080361d6SPawel Jakub Dawidek 743080361d6SPawel Jakub Dawidek static void 744080361d6SPawel Jakub Dawidek g_shsec_ctl_destroy(struct gctl_req *req, struct g_class *mp) 745080361d6SPawel Jakub Dawidek { 746080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 747080361d6SPawel Jakub Dawidek int *force, *nargs, error; 748080361d6SPawel Jakub Dawidek const char *name; 749080361d6SPawel Jakub Dawidek char param[16]; 750080361d6SPawel Jakub Dawidek u_int i; 751080361d6SPawel Jakub Dawidek 752080361d6SPawel Jakub Dawidek g_topology_assert(); 753080361d6SPawel Jakub Dawidek 754080361d6SPawel Jakub Dawidek nargs = gctl_get_paraml(req, "nargs", sizeof(*nargs)); 755080361d6SPawel Jakub Dawidek if (nargs == NULL) { 756080361d6SPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "nargs"); 757080361d6SPawel Jakub Dawidek return; 758080361d6SPawel Jakub Dawidek } 759080361d6SPawel Jakub Dawidek if (*nargs <= 0) { 760080361d6SPawel Jakub Dawidek gctl_error(req, "Missing device(s)."); 761080361d6SPawel Jakub Dawidek return; 762080361d6SPawel Jakub Dawidek } 763080361d6SPawel Jakub Dawidek force = gctl_get_paraml(req, "force", sizeof(*force)); 764080361d6SPawel Jakub Dawidek if (force == NULL) { 765080361d6SPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "force"); 766080361d6SPawel Jakub Dawidek return; 767080361d6SPawel Jakub Dawidek } 768080361d6SPawel Jakub Dawidek 769080361d6SPawel Jakub Dawidek for (i = 0; i < (u_int)*nargs; i++) { 770080361d6SPawel Jakub Dawidek snprintf(param, sizeof(param), "arg%u", i); 771080361d6SPawel Jakub Dawidek name = gctl_get_asciiparam(req, param); 772080361d6SPawel Jakub Dawidek if (name == NULL) { 773080361d6SPawel Jakub Dawidek gctl_error(req, "No 'arg%u' argument.", i); 774080361d6SPawel Jakub Dawidek return; 775080361d6SPawel Jakub Dawidek } 776080361d6SPawel Jakub Dawidek sc = g_shsec_find_device(mp, name); 777080361d6SPawel Jakub Dawidek if (sc == NULL) { 778080361d6SPawel Jakub Dawidek gctl_error(req, "No such device: %s.", name); 779080361d6SPawel Jakub Dawidek return; 780080361d6SPawel Jakub Dawidek } 781080361d6SPawel Jakub Dawidek error = g_shsec_destroy(sc, *force); 782080361d6SPawel Jakub Dawidek if (error != 0) { 783080361d6SPawel Jakub Dawidek gctl_error(req, "Cannot destroy device %s (error=%d).", 784080361d6SPawel Jakub Dawidek sc->sc_name, error); 785080361d6SPawel Jakub Dawidek return; 786080361d6SPawel Jakub Dawidek } 787080361d6SPawel Jakub Dawidek } 788080361d6SPawel Jakub Dawidek } 789080361d6SPawel Jakub Dawidek 790080361d6SPawel Jakub Dawidek static void 791080361d6SPawel Jakub Dawidek g_shsec_config(struct gctl_req *req, struct g_class *mp, const char *verb) 792080361d6SPawel Jakub Dawidek { 793080361d6SPawel Jakub Dawidek uint32_t *version; 794080361d6SPawel Jakub Dawidek 795080361d6SPawel Jakub Dawidek g_topology_assert(); 796080361d6SPawel Jakub Dawidek 797080361d6SPawel Jakub Dawidek version = gctl_get_paraml(req, "version", sizeof(*version)); 798080361d6SPawel Jakub Dawidek if (version == NULL) { 799080361d6SPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "version"); 800080361d6SPawel Jakub Dawidek return; 801080361d6SPawel Jakub Dawidek } 802080361d6SPawel Jakub Dawidek if (*version != G_SHSEC_VERSION) { 803080361d6SPawel Jakub Dawidek gctl_error(req, "Userland and kernel parts are out of sync."); 804080361d6SPawel Jakub Dawidek return; 805080361d6SPawel Jakub Dawidek } 806080361d6SPawel Jakub Dawidek 807080361d6SPawel Jakub Dawidek if (strcmp(verb, "stop") == 0) { 808080361d6SPawel Jakub Dawidek g_shsec_ctl_destroy(req, mp); 809080361d6SPawel Jakub Dawidek return; 810080361d6SPawel Jakub Dawidek } 811080361d6SPawel Jakub Dawidek 812080361d6SPawel Jakub Dawidek gctl_error(req, "Unknown verb."); 813080361d6SPawel Jakub Dawidek } 814080361d6SPawel Jakub Dawidek 815080361d6SPawel Jakub Dawidek static void 816080361d6SPawel Jakub Dawidek g_shsec_dumpconf(struct sbuf *sb, const char *indent, struct g_geom *gp, 817080361d6SPawel Jakub Dawidek struct g_consumer *cp, struct g_provider *pp) 818080361d6SPawel Jakub Dawidek { 819080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc; 820080361d6SPawel Jakub Dawidek 821080361d6SPawel Jakub Dawidek sc = gp->softc; 822080361d6SPawel Jakub Dawidek if (sc == NULL) 823080361d6SPawel Jakub Dawidek return; 824080361d6SPawel Jakub Dawidek if (pp != NULL) { 825080361d6SPawel Jakub Dawidek /* Nothing here. */ 826080361d6SPawel Jakub Dawidek } else if (cp != NULL) { 827080361d6SPawel Jakub Dawidek sbuf_printf(sb, "%s<Number>%u</Number>\n", indent, 828080361d6SPawel Jakub Dawidek (u_int)cp->index); 829080361d6SPawel Jakub Dawidek } else { 830080361d6SPawel Jakub Dawidek sbuf_printf(sb, "%s<ID>%u</ID>\n", indent, (u_int)sc->sc_id); 831080361d6SPawel Jakub Dawidek sbuf_printf(sb, "%s<Status>Total=%u, Online=%u</Status>\n", 832080361d6SPawel Jakub Dawidek indent, sc->sc_ndisks, g_shsec_nvalid(sc)); 833080361d6SPawel Jakub Dawidek sbuf_printf(sb, "%s<State>", indent); 834080361d6SPawel Jakub Dawidek if (sc->sc_provider != NULL && sc->sc_provider->error == 0) 835080361d6SPawel Jakub Dawidek sbuf_printf(sb, "UP"); 836080361d6SPawel Jakub Dawidek else 837080361d6SPawel Jakub Dawidek sbuf_printf(sb, "DOWN"); 838080361d6SPawel Jakub Dawidek sbuf_printf(sb, "</State>\n"); 839080361d6SPawel Jakub Dawidek } 840080361d6SPawel Jakub Dawidek } 841080361d6SPawel Jakub Dawidek 842080361d6SPawel Jakub Dawidek DECLARE_GEOM_CLASS(g_shsec_class, g_shsec); 84374d6c131SKyle Evans MODULE_VERSION(geom_shsec, 0); 844