1dd84a43cSPoul-Henning Kamp /*- 2dd84a43cSPoul-Henning Kamp * Copyright (c) 2002 Poul-Henning Kamp 3dd84a43cSPoul-Henning Kamp * Copyright (c) 2002 Networks Associates Technology, Inc. 4dd84a43cSPoul-Henning Kamp * All rights reserved. 5dd84a43cSPoul-Henning Kamp * 6dd84a43cSPoul-Henning Kamp * This software was developed for the FreeBSD Project by Poul-Henning Kamp 7dd84a43cSPoul-Henning Kamp * and NAI Labs, the Security Research Division of Network Associates, Inc. 8dd84a43cSPoul-Henning Kamp * under DARPA/SPAWAR contract N66001-01-C-8035 ("CBOSS"), as part of the 9dd84a43cSPoul-Henning Kamp * DARPA CHATS research program. 10dd84a43cSPoul-Henning Kamp * 11dd84a43cSPoul-Henning Kamp * Redistribution and use in source and binary forms, with or without 12dd84a43cSPoul-Henning Kamp * modification, are permitted provided that the following conditions 13dd84a43cSPoul-Henning Kamp * are met: 14dd84a43cSPoul-Henning Kamp * 1. Redistributions of source code must retain the above copyright 15dd84a43cSPoul-Henning Kamp * notice, this list of conditions and the following disclaimer. 16dd84a43cSPoul-Henning Kamp * 2. Redistributions in binary form must reproduce the above copyright 17dd84a43cSPoul-Henning Kamp * notice, this list of conditions and the following disclaimer in the 18dd84a43cSPoul-Henning Kamp * documentation and/or other materials provided with the distribution. 19dd84a43cSPoul-Henning Kamp * 3. The names of the authors may not be used to endorse or promote 20dd84a43cSPoul-Henning Kamp * products derived from this software without specific prior written 21dd84a43cSPoul-Henning Kamp * permission. 22dd84a43cSPoul-Henning Kamp * 23dd84a43cSPoul-Henning Kamp * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 24dd84a43cSPoul-Henning Kamp * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 25dd84a43cSPoul-Henning Kamp * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 26dd84a43cSPoul-Henning Kamp * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 27dd84a43cSPoul-Henning Kamp * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 28dd84a43cSPoul-Henning Kamp * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 29dd84a43cSPoul-Henning Kamp * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 30dd84a43cSPoul-Henning Kamp * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 31dd84a43cSPoul-Henning Kamp * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 32dd84a43cSPoul-Henning Kamp * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 33dd84a43cSPoul-Henning Kamp * SUCH DAMAGE. 34dd84a43cSPoul-Henning Kamp */ 35dd84a43cSPoul-Henning Kamp 3650b1faefSDavid E. O'Brien #include <sys/cdefs.h> 3750b1faefSDavid E. O'Brien __FBSDID("$FreeBSD$"); 3850b1faefSDavid E. O'Brien 39dd84a43cSPoul-Henning Kamp #include <sys/param.h> 40dd84a43cSPoul-Henning Kamp #include <sys/systm.h> 41dd84a43cSPoul-Henning Kamp #include <sys/malloc.h> 42dd84a43cSPoul-Henning Kamp #include <sys/kernel.h> 43dd84a43cSPoul-Henning Kamp #include <sys/conf.h> 44416494d7SJustin T. Gibbs #include <sys/ctype.h> 45dd84a43cSPoul-Henning Kamp #include <sys/bio.h> 463631c638SAlexander Motin #include <sys/bus.h> 47dd84a43cSPoul-Henning Kamp #include <sys/lock.h> 48dd84a43cSPoul-Henning Kamp #include <sys/mutex.h> 49fc6c63b4SPoul-Henning Kamp #include <sys/proc.h> 50dd84a43cSPoul-Henning Kamp #include <sys/errno.h> 51dd84a43cSPoul-Henning Kamp #include <sys/time.h> 52dd84a43cSPoul-Henning Kamp #include <sys/disk.h> 53dd84a43cSPoul-Henning Kamp #include <sys/fcntl.h> 54104a9b7eSAlexander Kabaev #include <sys/limits.h> 556f926c0bSSteven Hartland #include <sys/sysctl.h> 56dd84a43cSPoul-Henning Kamp #include <geom/geom.h> 5753705e35SPoul-Henning Kamp #include <geom/geom_int.h> 58416494d7SJustin T. Gibbs #include <machine/stdarg.h> 59416494d7SJustin T. Gibbs 603c330affSAlexander Motin struct g_dev_softc { 613c330affSAlexander Motin struct mtx sc_mtx; 623c330affSAlexander Motin struct cdev *sc_dev; 633c330affSAlexander Motin struct cdev *sc_alias; 643c330affSAlexander Motin int sc_open; 653c330affSAlexander Motin int sc_active; 663c330affSAlexander Motin }; 67dd84a43cSPoul-Henning Kamp 68dd84a43cSPoul-Henning Kamp static d_open_t g_dev_open; 69dd84a43cSPoul-Henning Kamp static d_close_t g_dev_close; 70dd84a43cSPoul-Henning Kamp static d_strategy_t g_dev_strategy; 71dd84a43cSPoul-Henning Kamp static d_ioctl_t g_dev_ioctl; 72dd84a43cSPoul-Henning Kamp 73dd84a43cSPoul-Henning Kamp static struct cdevsw g_dev_cdevsw = { 74dc08ffecSPoul-Henning Kamp .d_version = D_VERSION, 757ac40f5fSPoul-Henning Kamp .d_open = g_dev_open, 767ac40f5fSPoul-Henning Kamp .d_close = g_dev_close, 777ac40f5fSPoul-Henning Kamp .d_read = physread, 787ac40f5fSPoul-Henning Kamp .d_write = physwrite, 797ac40f5fSPoul-Henning Kamp .d_ioctl = g_dev_ioctl, 807ac40f5fSPoul-Henning Kamp .d_strategy = g_dev_strategy, 817ac40f5fSPoul-Henning Kamp .d_name = "g_dev", 82ce625ec7SKenneth D. Merry .d_flags = D_DISK | D_TRACKCLOSE, 83dd84a43cSPoul-Henning Kamp }; 84dd84a43cSPoul-Henning Kamp 850478dc0cSAndrey V. Elsukov static g_init_t g_dev_init; 860478dc0cSAndrey V. Elsukov static g_fini_t g_dev_fini; 87dd84a43cSPoul-Henning Kamp static g_taste_t g_dev_taste; 88dd84a43cSPoul-Henning Kamp static g_orphan_t g_dev_orphan; 89416494d7SJustin T. Gibbs static g_attrchanged_t g_dev_attrchanged; 90dd84a43cSPoul-Henning Kamp 91e805e8f0SPoul-Henning Kamp static struct g_class g_dev_class = { 92c138fec0SPoul-Henning Kamp .name = "DEV", 935721c9c7SPoul-Henning Kamp .version = G_VERSION, 940478dc0cSAndrey V. Elsukov .init = g_dev_init, 950478dc0cSAndrey V. Elsukov .fini = g_dev_fini, 96c138fec0SPoul-Henning Kamp .taste = g_dev_taste, 97650ee351SPoul-Henning Kamp .orphan = g_dev_orphan, 98416494d7SJustin T. Gibbs .attrchanged = g_dev_attrchanged 99dd84a43cSPoul-Henning Kamp }; 100dd84a43cSPoul-Henning Kamp 1016f926c0bSSteven Hartland /* 1026f926c0bSSteven Hartland * We target 262144 (8 x 32768) sectors by default as this significantly 1036f926c0bSSteven Hartland * increases the throughput on commonly used SSD's with a marginal 1046f926c0bSSteven Hartland * increase in non-interruptible request latency. 1056f926c0bSSteven Hartland */ 1066f926c0bSSteven Hartland static uint64_t g_dev_del_max_sectors = 262144; 1076f926c0bSSteven Hartland SYSCTL_DECL(_kern_geom); 1086f926c0bSSteven Hartland SYSCTL_NODE(_kern_geom, OID_AUTO, dev, CTLFLAG_RW, 0, "GEOM_DEV stuff"); 1096f926c0bSSteven Hartland SYSCTL_QUAD(_kern_geom_dev, OID_AUTO, delete_max_sectors, CTLFLAG_RW, 1106f926c0bSSteven Hartland &g_dev_del_max_sectors, 0, "Maximum number of sectors in a single " 1116f926c0bSSteven Hartland "delete request sent to the provider. Larger requests are chunked " 1126f926c0bSSteven Hartland "so they can be interrupted. (0 = disable chunking)"); 1136f926c0bSSteven Hartland 1140478dc0cSAndrey V. Elsukov static char *dumpdev = NULL; 1150478dc0cSAndrey V. Elsukov static void 1160478dc0cSAndrey V. Elsukov g_dev_init(struct g_class *mp) 1170478dc0cSAndrey V. Elsukov { 1180478dc0cSAndrey V. Elsukov 1192be111bfSDavide Italiano dumpdev = kern_getenv("dumpdev"); 1200478dc0cSAndrey V. Elsukov } 1210478dc0cSAndrey V. Elsukov 1220478dc0cSAndrey V. Elsukov static void 1230478dc0cSAndrey V. Elsukov g_dev_fini(struct g_class *mp) 1240478dc0cSAndrey V. Elsukov { 1250478dc0cSAndrey V. Elsukov 1260478dc0cSAndrey V. Elsukov freeenv(dumpdev); 127*b4d72907SConrad Meyer dumpdev = NULL; 1280478dc0cSAndrey V. Elsukov } 1290478dc0cSAndrey V. Elsukov 1300478dc0cSAndrey V. Elsukov static int 1315ebb15b9SPawel Jakub Dawidek g_dev_setdumpdev(struct cdev *dev, struct thread *td) 1320478dc0cSAndrey V. Elsukov { 1330478dc0cSAndrey V. Elsukov struct g_kerneldump kd; 1340478dc0cSAndrey V. Elsukov struct g_consumer *cp; 1350478dc0cSAndrey V. Elsukov int error, len; 1360478dc0cSAndrey V. Elsukov 1370478dc0cSAndrey V. Elsukov if (dev == NULL) 1385ebb15b9SPawel Jakub Dawidek return (set_dumper(NULL, NULL, td)); 1390478dc0cSAndrey V. Elsukov 1400478dc0cSAndrey V. Elsukov cp = dev->si_drv2; 1410478dc0cSAndrey V. Elsukov len = sizeof(kd); 1420478dc0cSAndrey V. Elsukov kd.offset = 0; 1430478dc0cSAndrey V. Elsukov kd.length = OFF_MAX; 1440478dc0cSAndrey V. Elsukov error = g_io_getattr("GEOM::kerneldump", cp, &len, &kd); 1450478dc0cSAndrey V. Elsukov if (error == 0) { 1465ebb15b9SPawel Jakub Dawidek error = set_dumper(&kd.di, devtoname(dev), td); 1470478dc0cSAndrey V. Elsukov if (error == 0) 1480478dc0cSAndrey V. Elsukov dev->si_flags |= SI_DUMPDEV; 1490478dc0cSAndrey V. Elsukov } 1500478dc0cSAndrey V. Elsukov return (error); 1510478dc0cSAndrey V. Elsukov } 1520478dc0cSAndrey V. Elsukov 1530478dc0cSAndrey V. Elsukov static void 1540478dc0cSAndrey V. Elsukov init_dumpdev(struct cdev *dev) 1550478dc0cSAndrey V. Elsukov { 156*b4d72907SConrad Meyer const char *devprefix = "/dev/", *devname; 157*b4d72907SConrad Meyer size_t len; 1580478dc0cSAndrey V. Elsukov 1590478dc0cSAndrey V. Elsukov if (dumpdev == NULL) 1600478dc0cSAndrey V. Elsukov return; 161*b4d72907SConrad Meyer len = strlen(devprefix); 162*b4d72907SConrad Meyer devname = devtoname(dev); 163*b4d72907SConrad Meyer if (strcmp(devname, dumpdev) != 0 && 164*b4d72907SConrad Meyer (strncmp(dumpdev, devprefix, len) != 0 || 165*b4d72907SConrad Meyer strcmp(devname, dumpdev + len) != 0)) 1660478dc0cSAndrey V. Elsukov return; 1675ebb15b9SPawel Jakub Dawidek if (g_dev_setdumpdev(dev, curthread) == 0) { 1680478dc0cSAndrey V. Elsukov freeenv(dumpdev); 1690478dc0cSAndrey V. Elsukov dumpdev = NULL; 1700478dc0cSAndrey V. Elsukov } 1710478dc0cSAndrey V. Elsukov } 1720478dc0cSAndrey V. Elsukov 1733c330affSAlexander Motin static void 1743c330affSAlexander Motin g_dev_destroy(void *arg, int flags __unused) 1753c330affSAlexander Motin { 1763c330affSAlexander Motin struct g_consumer *cp; 1773c330affSAlexander Motin struct g_geom *gp; 1783c330affSAlexander Motin struct g_dev_softc *sc; 17901de1a06SEdward Tomasz Napierala char buf[SPECNAMELEN + 6]; 1803c330affSAlexander Motin 1813c330affSAlexander Motin g_topology_assert(); 1823c330affSAlexander Motin cp = arg; 1833c330affSAlexander Motin gp = cp->geom; 1843c330affSAlexander Motin sc = cp->private; 1853c330affSAlexander Motin g_trace(G_T_TOPOLOGY, "g_dev_destroy(%p(%s))", cp, gp->name); 18601de1a06SEdward Tomasz Napierala snprintf(buf, sizeof(buf), "cdev=%s", gp->name); 18701de1a06SEdward Tomasz Napierala devctl_notify_f("GEOM", "DEV", "DESTROY", buf, M_WAITOK); 1883c330affSAlexander Motin if (cp->acr > 0 || cp->acw > 0 || cp->ace > 0) 1893c330affSAlexander Motin g_access(cp, -cp->acr, -cp->acw, -cp->ace); 1903c330affSAlexander Motin g_detach(cp); 1913c330affSAlexander Motin g_destroy_consumer(cp); 1923c330affSAlexander Motin g_destroy_geom(gp); 1933c330affSAlexander Motin mtx_destroy(&sc->sc_mtx); 1943c330affSAlexander Motin g_free(sc); 1953c330affSAlexander Motin } 1963c330affSAlexander Motin 19784c080a8SPoul-Henning Kamp void 198ce225127SPoul-Henning Kamp g_dev_print(void) 199ce225127SPoul-Henning Kamp { 200ce225127SPoul-Henning Kamp struct g_geom *gp; 20184c080a8SPoul-Henning Kamp char const *p = ""; 202ce225127SPoul-Henning Kamp 20384c080a8SPoul-Henning Kamp LIST_FOREACH(gp, &g_dev_class.geom, geom) { 20484c080a8SPoul-Henning Kamp printf("%s%s", p, gp->name); 20584c080a8SPoul-Henning Kamp p = " "; 20684c080a8SPoul-Henning Kamp } 207ce225127SPoul-Henning Kamp printf("\n"); 208ce225127SPoul-Henning Kamp } 209ce225127SPoul-Henning Kamp 210416494d7SJustin T. Gibbs static void 211416494d7SJustin T. Gibbs g_dev_attrchanged(struct g_consumer *cp, const char *attr) 212416494d7SJustin T. Gibbs { 2133c330affSAlexander Motin struct g_dev_softc *sc; 2143631c638SAlexander Motin struct cdev *dev; 2153631c638SAlexander Motin char buf[SPECNAMELEN + 6]; 2163631c638SAlexander Motin 2173c330affSAlexander Motin sc = cp->private; 2183631c638SAlexander Motin if (strcmp(attr, "GEOM::media") == 0) { 2193c330affSAlexander Motin dev = sc->sc_dev; 2203631c638SAlexander Motin snprintf(buf, sizeof(buf), "cdev=%s", dev->si_name); 2213631c638SAlexander Motin devctl_notify_f("DEVFS", "CDEV", "MEDIACHANGE", buf, M_WAITOK); 22201de1a06SEdward Tomasz Napierala devctl_notify_f("GEOM", "DEV", "MEDIACHANGE", buf, M_WAITOK); 2233c330affSAlexander Motin dev = sc->sc_alias; 2243631c638SAlexander Motin if (dev != NULL) { 2253631c638SAlexander Motin snprintf(buf, sizeof(buf), "cdev=%s", dev->si_name); 2263631c638SAlexander Motin devctl_notify_f("DEVFS", "CDEV", "MEDIACHANGE", buf, 2273631c638SAlexander Motin M_WAITOK); 22801de1a06SEdward Tomasz Napierala devctl_notify_f("GEOM", "DEV", "MEDIACHANGE", buf, 22901de1a06SEdward Tomasz Napierala M_WAITOK); 2303631c638SAlexander Motin } 2313631c638SAlexander Motin return; 2323631c638SAlexander Motin } 233416494d7SJustin T. Gibbs 234416494d7SJustin T. Gibbs if (strcmp(attr, "GEOM::physpath") != 0) 235416494d7SJustin T. Gibbs return; 236416494d7SJustin T. Gibbs 237416494d7SJustin T. Gibbs if (g_access(cp, 1, 0, 0) == 0) { 238416494d7SJustin T. Gibbs char *physpath; 239416494d7SJustin T. Gibbs int error, physpath_len; 240416494d7SJustin T. Gibbs 241416494d7SJustin T. Gibbs physpath_len = MAXPATHLEN; 242416494d7SJustin T. Gibbs physpath = g_malloc(physpath_len, M_WAITOK|M_ZERO); 243416494d7SJustin T. Gibbs error = 244416494d7SJustin T. Gibbs g_io_getattr("GEOM::physpath", cp, &physpath_len, physpath); 245416494d7SJustin T. Gibbs g_access(cp, -1, 0, 0); 246416494d7SJustin T. Gibbs if (error == 0 && strlen(physpath) != 0) { 247416494d7SJustin T. Gibbs struct cdev *old_alias_dev; 248416494d7SJustin T. Gibbs struct cdev **alias_devp; 249416494d7SJustin T. Gibbs 2503c330affSAlexander Motin dev = sc->sc_dev; 2513c330affSAlexander Motin old_alias_dev = sc->sc_alias; 2523c330affSAlexander Motin alias_devp = (struct cdev **)&sc->sc_alias; 253416494d7SJustin T. Gibbs make_dev_physpath_alias(MAKEDEV_WAITOK, alias_devp, 254416494d7SJustin T. Gibbs dev, old_alias_dev, physpath); 2553c330affSAlexander Motin } else if (sc->sc_alias) { 2563c330affSAlexander Motin destroy_dev((struct cdev *)sc->sc_alias); 2573c330affSAlexander Motin sc->sc_alias = NULL; 258416494d7SJustin T. Gibbs } 259416494d7SJustin T. Gibbs g_free(physpath); 260416494d7SJustin T. Gibbs } 261416494d7SJustin T. Gibbs } 262416494d7SJustin T. Gibbs 263bff1e299SPoul-Henning Kamp struct g_provider * 26489c9c53dSPoul-Henning Kamp g_dev_getprovider(struct cdev *dev) 265bff1e299SPoul-Henning Kamp { 266bff1e299SPoul-Henning Kamp struct g_consumer *cp; 267bff1e299SPoul-Henning Kamp 268a7830346SPoul-Henning Kamp g_topology_assert(); 269bff1e299SPoul-Henning Kamp if (dev == NULL) 270bff1e299SPoul-Henning Kamp return (NULL); 271a7830346SPoul-Henning Kamp if (dev->si_devsw != &g_dev_cdevsw) 272b3b21113SPoul-Henning Kamp return (NULL); 273bff1e299SPoul-Henning Kamp cp = dev->si_drv2; 274bff1e299SPoul-Henning Kamp return (cp->provider); 275bff1e299SPoul-Henning Kamp } 276bff1e299SPoul-Henning Kamp 277dd84a43cSPoul-Henning Kamp static struct g_geom * 278b1876192SPoul-Henning Kamp g_dev_taste(struct g_class *mp, struct g_provider *pp, int insist __unused) 279dd84a43cSPoul-Henning Kamp { 280dd84a43cSPoul-Henning Kamp struct g_geom *gp; 281dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 2823c330affSAlexander Motin struct g_dev_softc *sc; 2830d307e09SAlexander Motin int error, len; 2840d307e09SAlexander Motin struct cdev *dev, *adev; 28501de1a06SEdward Tomasz Napierala char buf[SPECNAMELEN + 6], *val; 286dd84a43cSPoul-Henning Kamp 287dd84a43cSPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "dev_taste(%s,%s)", mp->name, pp->name); 288dd84a43cSPoul-Henning Kamp g_topology_assert(); 28902c62349SJaakko Heinonen gp = g_new_geomf(mp, "%s", pp->name); 2903c330affSAlexander Motin sc = g_malloc(sizeof(*sc), M_WAITOK | M_ZERO); 2913c330affSAlexander Motin mtx_init(&sc->sc_mtx, "g_dev", NULL, MTX_DEF); 292dd84a43cSPoul-Henning Kamp cp = g_new_consumer(gp); 2933c330affSAlexander Motin cp->private = sc; 29440ea77a0SAlexander Motin cp->flags |= G_CF_DIRECT_SEND | G_CF_DIRECT_RECEIVE; 2954b8374a7SPoul-Henning Kamp error = g_attach(cp, pp); 2964b8374a7SPoul-Henning Kamp KASSERT(error == 0, 2974b8374a7SPoul-Henning Kamp ("g_dev_taste(%s) failed to g_attach, err=%d", pp->name, error)); 298bc2589f5SJaakko Heinonen error = make_dev_p(MAKEDEV_CHECKNAME | MAKEDEV_WAITOK, &dev, 299bc2589f5SJaakko Heinonen &g_dev_cdevsw, NULL, UID_ROOT, GID_OPERATOR, 0640, "%s", gp->name); 300bc2589f5SJaakko Heinonen if (error != 0) { 301bc2589f5SJaakko Heinonen printf("%s: make_dev_p() failed (gp->name=%s, error=%d)\n", 302bc2589f5SJaakko Heinonen __func__, gp->name, error); 303bc2589f5SJaakko Heinonen g_detach(cp); 304bc2589f5SJaakko Heinonen g_destroy_consumer(cp); 305bc2589f5SJaakko Heinonen g_destroy_geom(gp); 3063c330affSAlexander Motin mtx_destroy(&sc->sc_mtx); 3073c330affSAlexander Motin g_free(sc); 308bc2589f5SJaakko Heinonen return (NULL); 309bc2589f5SJaakko Heinonen } 310ce625ec7SKenneth D. Merry dev->si_flags |= SI_UNMAPPED; 3113c330affSAlexander Motin sc->sc_dev = dev; 3120d307e09SAlexander Motin 3130d307e09SAlexander Motin /* Search for device alias name and create it if found. */ 3140d307e09SAlexander Motin adev = NULL; 3150d307e09SAlexander Motin for (len = MIN(strlen(gp->name), sizeof(buf) - 15); len > 0; len--) { 3160d307e09SAlexander Motin snprintf(buf, sizeof(buf), "kern.devalias.%s", gp->name); 3170d307e09SAlexander Motin buf[14 + len] = 0; 3182be111bfSDavide Italiano val = kern_getenv(buf); 3190d307e09SAlexander Motin if (val != NULL) { 3200d307e09SAlexander Motin snprintf(buf, sizeof(buf), "%s%s", 3210d307e09SAlexander Motin val, gp->name + len); 3220d307e09SAlexander Motin freeenv(val); 323274919e9SScott Long if ((make_dev_alias_p(MAKEDEV_CHECKNAME|MAKEDEV_WAITOK, 324274919e9SScott Long &adev, dev, "%s", buf)) != 0) 325274919e9SScott Long printf("Warning: unable to create device " 326274919e9SScott Long "alias %s\n", buf); 3270d307e09SAlexander Motin break; 3280d307e09SAlexander Motin } 3290d307e09SAlexander Motin } 3300d307e09SAlexander Motin 3310364fe2cSPoul-Henning Kamp dev->si_iosize_max = MAXPHYS; 332dd84a43cSPoul-Henning Kamp dev->si_drv2 = cp; 3330478dc0cSAndrey V. Elsukov init_dumpdev(dev); 3340d307e09SAlexander Motin if (adev != NULL) { 3350d307e09SAlexander Motin adev->si_iosize_max = MAXPHYS; 3360d307e09SAlexander Motin adev->si_drv2 = cp; 337274919e9SScott Long adev->si_flags |= SI_UNMAPPED; 3380478dc0cSAndrey V. Elsukov init_dumpdev(adev); 3390d307e09SAlexander Motin } 340416494d7SJustin T. Gibbs 341416494d7SJustin T. Gibbs g_dev_attrchanged(cp, "GEOM::physpath"); 34201de1a06SEdward Tomasz Napierala snprintf(buf, sizeof(buf), "cdev=%s", gp->name); 34301de1a06SEdward Tomasz Napierala devctl_notify_f("GEOM", "DEV", "CREATE", buf, M_WAITOK); 344416494d7SJustin T. Gibbs 345dd84a43cSPoul-Henning Kamp return (gp); 346dd84a43cSPoul-Henning Kamp } 347dd84a43cSPoul-Henning Kamp 348dd84a43cSPoul-Henning Kamp static int 34989c9c53dSPoul-Henning Kamp g_dev_open(struct cdev *dev, int flags, int fmt, struct thread *td) 350dd84a43cSPoul-Henning Kamp { 351dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 3523c330affSAlexander Motin struct g_dev_softc *sc; 353dd84a43cSPoul-Henning Kamp int error, r, w, e; 354dd84a43cSPoul-Henning Kamp 355dd84a43cSPoul-Henning Kamp cp = dev->si_drv2; 3563c330affSAlexander Motin if (cp == NULL) 357c7e1925cSPoul-Henning Kamp return (ENXIO); /* g_dev_taste() not done yet */ 358dd84a43cSPoul-Henning Kamp g_trace(G_T_ACCESS, "g_dev_open(%s, %d, %d, %p)", 3593c330affSAlexander Motin cp->geom->name, flags, fmt, td); 360fc6c63b4SPoul-Henning Kamp 361dd84a43cSPoul-Henning Kamp r = flags & FREAD ? 1 : 0; 362dd84a43cSPoul-Henning Kamp w = flags & FWRITE ? 1 : 0; 36302945fefSPoul-Henning Kamp #ifdef notyet 364dd84a43cSPoul-Henning Kamp e = flags & O_EXCL ? 1 : 0; 36502945fefSPoul-Henning Kamp #else 36602945fefSPoul-Henning Kamp e = 0; 36702945fefSPoul-Henning Kamp #endif 36872800098SEdward Tomasz Napierala 36972800098SEdward Tomasz Napierala /* 37072800098SEdward Tomasz Napierala * This happens on attempt to open a device node with O_EXEC. 37172800098SEdward Tomasz Napierala */ 37272800098SEdward Tomasz Napierala if (r + w + e == 0) 37372800098SEdward Tomasz Napierala return (EINVAL); 37472800098SEdward Tomasz Napierala 375fc6c63b4SPoul-Henning Kamp if (w) { 376fc6c63b4SPoul-Henning Kamp /* 377fc6c63b4SPoul-Henning Kamp * When running in very secure mode, do not allow 378fc6c63b4SPoul-Henning Kamp * opens for writing of any disks. 379fc6c63b4SPoul-Henning Kamp */ 380fc6c63b4SPoul-Henning Kamp error = securelevel_ge(td->td_ucred, 2); 381fc6c63b4SPoul-Henning Kamp if (error) 382fc6c63b4SPoul-Henning Kamp return (error); 383fc6c63b4SPoul-Henning Kamp } 384c7e1925cSPoul-Henning Kamp g_topology_lock(); 385d2bae332SPoul-Henning Kamp error = g_access(cp, r, w, e); 386dd84a43cSPoul-Henning Kamp g_topology_unlock(); 3873c330affSAlexander Motin if (error == 0) { 3883c330affSAlexander Motin sc = cp->private; 3893c330affSAlexander Motin mtx_lock(&sc->sc_mtx); 3903c330affSAlexander Motin if (sc->sc_open == 0 && sc->sc_active != 0) 3913c330affSAlexander Motin wakeup(&sc->sc_active); 3923c330affSAlexander Motin sc->sc_open += r + w + e; 3933c330affSAlexander Motin mtx_unlock(&sc->sc_mtx); 3943c330affSAlexander Motin } 395dd84a43cSPoul-Henning Kamp return (error); 396dd84a43cSPoul-Henning Kamp } 397dd84a43cSPoul-Henning Kamp 398dd84a43cSPoul-Henning Kamp static int 39989c9c53dSPoul-Henning Kamp g_dev_close(struct cdev *dev, int flags, int fmt, struct thread *td) 400dd84a43cSPoul-Henning Kamp { 401dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 4023c330affSAlexander Motin struct g_dev_softc *sc; 4033c330affSAlexander Motin int error, r, w, e; 404dd84a43cSPoul-Henning Kamp 405dd84a43cSPoul-Henning Kamp cp = dev->si_drv2; 4063c330affSAlexander Motin if (cp == NULL) 407dd84a43cSPoul-Henning Kamp return (ENXIO); 408dd84a43cSPoul-Henning Kamp g_trace(G_T_ACCESS, "g_dev_close(%s, %d, %d, %p)", 4093c330affSAlexander Motin cp->geom->name, flags, fmt, td); 4103c330affSAlexander Motin 411dd84a43cSPoul-Henning Kamp r = flags & FREAD ? -1 : 0; 412dd84a43cSPoul-Henning Kamp w = flags & FWRITE ? -1 : 0; 41302945fefSPoul-Henning Kamp #ifdef notyet 414dd84a43cSPoul-Henning Kamp e = flags & O_EXCL ? -1 : 0; 41502945fefSPoul-Henning Kamp #else 41602945fefSPoul-Henning Kamp e = 0; 41702945fefSPoul-Henning Kamp #endif 418d6cc35b2SEdward Tomasz Napierala 419d6cc35b2SEdward Tomasz Napierala /* 420d6cc35b2SEdward Tomasz Napierala * The vgonel(9) - caused by eg. forced unmount of devfs - calls 421d6cc35b2SEdward Tomasz Napierala * VOP_CLOSE(9) on devfs vnode without any FREAD or FWRITE flags, 422d6cc35b2SEdward Tomasz Napierala * which would result in zero deltas, which in turn would cause 423d6cc35b2SEdward Tomasz Napierala * panic in g_access(9). 424d6cc35b2SEdward Tomasz Napierala * 425d6cc35b2SEdward Tomasz Napierala * Note that we cannot zero the counters (ie. do "r = cp->acr" 426d6cc35b2SEdward Tomasz Napierala * etc) instead, because the consumer might be opened in another 427d6cc35b2SEdward Tomasz Napierala * devfs instance. 428d6cc35b2SEdward Tomasz Napierala */ 429d6cc35b2SEdward Tomasz Napierala if (r + w + e == 0) 430d6cc35b2SEdward Tomasz Napierala return (EINVAL); 431d6cc35b2SEdward Tomasz Napierala 4323c330affSAlexander Motin sc = cp->private; 4333c330affSAlexander Motin mtx_lock(&sc->sc_mtx); 4343c330affSAlexander Motin sc->sc_open += r + w + e; 4353c330affSAlexander Motin while (sc->sc_open == 0 && sc->sc_active != 0) 4363c330affSAlexander Motin msleep(&sc->sc_active, &sc->sc_mtx, 0, "PRIBIO", 0); 4373c330affSAlexander Motin mtx_unlock(&sc->sc_mtx); 438c7e1925cSPoul-Henning Kamp g_topology_lock(); 439d2bae332SPoul-Henning Kamp error = g_access(cp, r, w, e); 440dd84a43cSPoul-Henning Kamp g_topology_unlock(); 441dd84a43cSPoul-Henning Kamp return (error); 442dd84a43cSPoul-Henning Kamp } 443dd84a43cSPoul-Henning Kamp 444c7e1925cSPoul-Henning Kamp /* 445c7e1925cSPoul-Henning Kamp * XXX: Until we have unmessed the ioctl situation, there is a race against 446c7e1925cSPoul-Henning Kamp * XXX: a concurrent orphanization. We cannot close it by holding topology 447c7e1925cSPoul-Henning Kamp * XXX: since that would prevent us from doing our job, and stalling events 448c7e1925cSPoul-Henning Kamp * XXX: will break (actually: stall) the BSD disklabel hacks. 449c7e1925cSPoul-Henning Kamp */ 450dd84a43cSPoul-Henning Kamp static int 45189c9c53dSPoul-Henning Kamp g_dev_ioctl(struct cdev *dev, u_long cmd, caddr_t data, int fflag, struct thread *td) 452dd84a43cSPoul-Henning Kamp { 453dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 454f805f204SUlf Lilleengen struct g_provider *pp; 455015a11e6SPoul-Henning Kamp off_t offset, length, chunk; 456dd84a43cSPoul-Henning Kamp int i, error; 457dd84a43cSPoul-Henning Kamp 458dd84a43cSPoul-Henning Kamp cp = dev->si_drv2; 459f805f204SUlf Lilleengen pp = cp->provider; 460dd84a43cSPoul-Henning Kamp 461dd84a43cSPoul-Henning Kamp error = 0; 462c7e1925cSPoul-Henning Kamp KASSERT(cp->acr || cp->acw, 463c7e1925cSPoul-Henning Kamp ("Consumer with zero access count in g_dev_ioctl")); 464a5b2e75dSPoul-Henning Kamp 46500dcdc8dSPoul-Henning Kamp i = IOCPARM_LEN(cmd); 46600dcdc8dSPoul-Henning Kamp switch (cmd) { 46700dcdc8dSPoul-Henning Kamp case DIOCGSECTORSIZE: 4683f12caa1SPoul-Henning Kamp *(u_int *)data = cp->provider->sectorsize; 4693f12caa1SPoul-Henning Kamp if (*(u_int *)data == 0) 47002fcfac0SNate Lawson error = ENOENT; 47100dcdc8dSPoul-Henning Kamp break; 47200dcdc8dSPoul-Henning Kamp case DIOCGMEDIASIZE: 4733f12caa1SPoul-Henning Kamp *(off_t *)data = cp->provider->mediasize; 4743f12caa1SPoul-Henning Kamp if (*(off_t *)data == 0) 47502fcfac0SNate Lawson error = ENOENT; 47600dcdc8dSPoul-Henning Kamp break; 47700dcdc8dSPoul-Henning Kamp case DIOCGFWSECTORS: 478b1876192SPoul-Henning Kamp error = g_io_getattr("GEOM::fwsectors", cp, &i, data); 47902fcfac0SNate Lawson if (error == 0 && *(u_int *)data == 0) 48002fcfac0SNate Lawson error = ENOENT; 48100dcdc8dSPoul-Henning Kamp break; 48200dcdc8dSPoul-Henning Kamp case DIOCGFWHEADS: 483b1876192SPoul-Henning Kamp error = g_io_getattr("GEOM::fwheads", cp, &i, data); 48402fcfac0SNate Lawson if (error == 0 && *(u_int *)data == 0) 48502fcfac0SNate Lawson error = ENOENT; 48600dcdc8dSPoul-Henning Kamp break; 4871bdb20a6SPoul-Henning Kamp case DIOCGFRONTSTUFF: 4881bdb20a6SPoul-Henning Kamp error = g_io_getattr("GEOM::frontstuff", cp, &i, data); 4891bdb20a6SPoul-Henning Kamp break; 49095c24b31SPoul-Henning Kamp case DIOCSKERNELDUMP: 4910478dc0cSAndrey V. Elsukov if (*(u_int *)data == 0) 4925ebb15b9SPawel Jakub Dawidek error = g_dev_setdumpdev(NULL, td); 4930478dc0cSAndrey V. Elsukov else 4945ebb15b9SPawel Jakub Dawidek error = g_dev_setdumpdev(dev, td); 49595c24b31SPoul-Henning Kamp break; 4960589353aSPawel Jakub Dawidek case DIOCGFLUSH: 4970589353aSPawel Jakub Dawidek error = g_io_flush(cp); 4980589353aSPawel Jakub Dawidek break; 4990589353aSPawel Jakub Dawidek case DIOCGDELETE: 5000589353aSPawel Jakub Dawidek offset = ((off_t *)data)[0]; 5010589353aSPawel Jakub Dawidek length = ((off_t *)data)[1]; 5020589353aSPawel Jakub Dawidek if ((offset % cp->provider->sectorsize) != 0 || 503eed6cda9SPoul-Henning Kamp (length % cp->provider->sectorsize) != 0 || length <= 0) { 5040589353aSPawel Jakub Dawidek printf("%s: offset=%jd length=%jd\n", __func__, offset, 5050589353aSPawel Jakub Dawidek length); 5060589353aSPawel Jakub Dawidek error = EINVAL; 5070589353aSPawel Jakub Dawidek break; 5080589353aSPawel Jakub Dawidek } 509015a11e6SPoul-Henning Kamp while (length > 0) { 510015a11e6SPoul-Henning Kamp chunk = length; 5116f926c0bSSteven Hartland if (g_dev_del_max_sectors != 0 && chunk > 5126f926c0bSSteven Hartland g_dev_del_max_sectors * cp->provider->sectorsize) { 5136f926c0bSSteven Hartland chunk = g_dev_del_max_sectors * 5146f926c0bSSteven Hartland cp->provider->sectorsize; 5156f926c0bSSteven Hartland } 516015a11e6SPoul-Henning Kamp error = g_delete_data(cp, offset, chunk); 517015a11e6SPoul-Henning Kamp length -= chunk; 518015a11e6SPoul-Henning Kamp offset += chunk; 519015a11e6SPoul-Henning Kamp if (error) 520015a11e6SPoul-Henning Kamp break; 521015a11e6SPoul-Henning Kamp /* 5226f926c0bSSteven Hartland * Since the request size can be large, the service 5236f926c0bSSteven Hartland * time can be is likewise. We make this ioctl 5246f926c0bSSteven Hartland * interruptible by checking for signals for each bio. 525015a11e6SPoul-Henning Kamp */ 526015a11e6SPoul-Henning Kamp if (SIGPENDING(td)) 527015a11e6SPoul-Henning Kamp break; 528015a11e6SPoul-Henning Kamp } 5290589353aSPawel Jakub Dawidek break; 5300589353aSPawel Jakub Dawidek case DIOCGIDENT: 5310589353aSPawel Jakub Dawidek error = g_io_getattr("GEOM::ident", cp, &i, data); 5320589353aSPawel Jakub Dawidek break; 533f805f204SUlf Lilleengen case DIOCGPROVIDERNAME: 534f805f204SUlf Lilleengen if (pp == NULL) 535f805f204SUlf Lilleengen return (ENOENT); 536f805f204SUlf Lilleengen strlcpy(data, pp->name, i); 537f805f204SUlf Lilleengen break; 5388b303238SAlexander Motin case DIOCGSTRIPESIZE: 5398b303238SAlexander Motin *(off_t *)data = cp->provider->stripesize; 5408b303238SAlexander Motin break; 5418b303238SAlexander Motin case DIOCGSTRIPEOFFSET: 5428b303238SAlexander Motin *(off_t *)data = cp->provider->stripeoffset; 5438b303238SAlexander Motin break; 544416494d7SJustin T. Gibbs case DIOCGPHYSPATH: 545416494d7SJustin T. Gibbs error = g_io_getattr("GEOM::physpath", cp, &i, data); 546416494d7SJustin T. Gibbs if (error == 0 && *(char *)data == '\0') 547416494d7SJustin T. Gibbs error = ENOENT; 548416494d7SJustin T. Gibbs break; 549c3e7ba3eSAlexander Motin case DIOCGATTR: { 550c3e7ba3eSAlexander Motin struct diocgattr_arg *arg = (struct diocgattr_arg *)data; 551c3e7ba3eSAlexander Motin 552c3e7ba3eSAlexander Motin if (arg->len > sizeof(arg->value)) { 553c3e7ba3eSAlexander Motin error = EINVAL; 554c3e7ba3eSAlexander Motin break; 555c3e7ba3eSAlexander Motin } 556c3e7ba3eSAlexander Motin error = g_io_getattr(arg->name, cp, &arg->len, &arg->value); 557c3e7ba3eSAlexander Motin break; 558c3e7ba3eSAlexander Motin } 55900dcdc8dSPoul-Henning Kamp default: 560497c3347SPoul-Henning Kamp if (cp->provider->geom->ioctl != NULL) { 5612221dbebSPoul-Henning Kamp error = cp->provider->geom->ioctl(cp->provider, cmd, data, fflag, td); 562f03bec94SPoul-Henning Kamp } else { 563f03bec94SPoul-Henning Kamp error = ENOIOCTL; 564497c3347SPoul-Henning Kamp } 56500dcdc8dSPoul-Henning Kamp } 566a5b2e75dSPoul-Henning Kamp 567dd84a43cSPoul-Henning Kamp return (error); 568dd84a43cSPoul-Henning Kamp } 569dd84a43cSPoul-Henning Kamp 570dd84a43cSPoul-Henning Kamp static void 571dd84a43cSPoul-Henning Kamp g_dev_done(struct bio *bp2) 572dd84a43cSPoul-Henning Kamp { 5733c330affSAlexander Motin struct g_consumer *cp; 5743c330affSAlexander Motin struct g_dev_softc *sc; 575dd84a43cSPoul-Henning Kamp struct bio *bp; 5763c330affSAlexander Motin int destroy; 577dd84a43cSPoul-Henning Kamp 5783c330affSAlexander Motin cp = bp2->bio_from; 5793c330affSAlexander Motin sc = cp->private; 580936cc461SPoul-Henning Kamp bp = bp2->bio_parent; 581dd84a43cSPoul-Henning Kamp bp->bio_error = bp2->bio_error; 58221d0712cSAlexander Motin bp->bio_completed = bp2->bio_completed; 5832634da8cSAlexander Motin bp->bio_resid = bp->bio_length - bp2->bio_completed; 58421d0712cSAlexander Motin if (bp2->bio_error != 0) { 585dd84a43cSPoul-Henning Kamp g_trace(G_T_BIO, "g_dev_done(%p) had error %d", 58621d0712cSAlexander Motin bp2, bp2->bio_error); 587dd84a43cSPoul-Henning Kamp bp->bio_flags |= BIO_ERROR; 588dd84a43cSPoul-Henning Kamp } else { 58914ac6812SPoul-Henning Kamp g_trace(G_T_BIO, "g_dev_done(%p/%p) resid %ld completed %jd", 59021d0712cSAlexander Motin bp2, bp, bp2->bio_resid, (intmax_t)bp2->bio_completed); 591dd84a43cSPoul-Henning Kamp } 592dd84a43cSPoul-Henning Kamp g_destroy_bio(bp2); 5933c330affSAlexander Motin destroy = 0; 5943c330affSAlexander Motin mtx_lock(&sc->sc_mtx); 5953c330affSAlexander Motin if ((--sc->sc_active) == 0) { 5963c330affSAlexander Motin if (sc->sc_open == 0) 5973c330affSAlexander Motin wakeup(&sc->sc_active); 5983c330affSAlexander Motin if (sc->sc_dev == NULL) 5993c330affSAlexander Motin destroy = 1; 6003c330affSAlexander Motin } 6013c330affSAlexander Motin mtx_unlock(&sc->sc_mtx); 6023c330affSAlexander Motin if (destroy) 6030ada3afcSAlexander Motin g_post_event(g_dev_destroy, cp, M_NOWAIT, NULL); 604dd84a43cSPoul-Henning Kamp biodone(bp); 605dd84a43cSPoul-Henning Kamp } 606dd84a43cSPoul-Henning Kamp 607dd84a43cSPoul-Henning Kamp static void 608dd84a43cSPoul-Henning Kamp g_dev_strategy(struct bio *bp) 609dd84a43cSPoul-Henning Kamp { 610dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 611dd84a43cSPoul-Henning Kamp struct bio *bp2; 61289c9c53dSPoul-Henning Kamp struct cdev *dev; 6133c330affSAlexander Motin struct g_dev_softc *sc; 614dd84a43cSPoul-Henning Kamp 615b630d83fSPoul-Henning Kamp KASSERT(bp->bio_cmd == BIO_READ || 616b630d83fSPoul-Henning Kamp bp->bio_cmd == BIO_WRITE || 61716fac6c9SEdward Tomasz Napierala bp->bio_cmd == BIO_DELETE || 61816fac6c9SEdward Tomasz Napierala bp->bio_cmd == BIO_FLUSH, 619b630d83fSPoul-Henning Kamp ("Wrong bio_cmd bio=%p cmd=%d", bp, bp->bio_cmd)); 620dd84a43cSPoul-Henning Kamp dev = bp->bio_dev; 621dd84a43cSPoul-Henning Kamp cp = dev->si_drv2; 6223c330affSAlexander Motin sc = cp->private; 623c7e1925cSPoul-Henning Kamp KASSERT(cp->acr || cp->acw, 624c7e1925cSPoul-Henning Kamp ("Consumer with zero access count in g_dev_strategy")); 62518e42503SAlexander Motin #ifdef INVARIANTS 6266c252337SPawel Jakub Dawidek if ((bp->bio_offset % cp->provider->sectorsize) != 0 || 6276c252337SPawel Jakub Dawidek (bp->bio_bcount % cp->provider->sectorsize) != 0) { 628274ede62SSimon L. B. Nielsen bp->bio_resid = bp->bio_bcount; 6296c252337SPawel Jakub Dawidek biofinish(bp, NULL, EINVAL); 6306c252337SPawel Jakub Dawidek return; 6316c252337SPawel Jakub Dawidek } 63218e42503SAlexander Motin #endif 6333c330affSAlexander Motin mtx_lock(&sc->sc_mtx); 6343c330affSAlexander Motin KASSERT(sc->sc_open > 0, ("Closed device in g_dev_strategy")); 6353c330affSAlexander Motin sc->sc_active++; 6363c330affSAlexander Motin mtx_unlock(&sc->sc_mtx); 6373c330affSAlexander Motin 6384ba5a129SPoul-Henning Kamp for (;;) { 6394ba5a129SPoul-Henning Kamp /* 6404ba5a129SPoul-Henning Kamp * XXX: This is not an ideal solution, but I belive it to 6414ba5a129SPoul-Henning Kamp * XXX: deadlock safe, all things considered. 6424ba5a129SPoul-Henning Kamp */ 643dd84a43cSPoul-Henning Kamp bp2 = g_clone_bio(bp); 6444ba5a129SPoul-Henning Kamp if (bp2 != NULL) 6454ba5a129SPoul-Henning Kamp break; 6464d70511aSJohn Baldwin pause("gdstrat", hz / 10); 6474ba5a129SPoul-Henning Kamp } 648cc0163a3SPoul-Henning Kamp KASSERT(bp2 != NULL, ("XXX: ENOMEM in a bad place")); 649dd84a43cSPoul-Henning Kamp bp2->bio_done = g_dev_done; 650dd84a43cSPoul-Henning Kamp g_trace(G_T_BIO, 65114ac6812SPoul-Henning Kamp "g_dev_strategy(%p/%p) offset %jd length %jd data %p cmd %d", 65214ac6812SPoul-Henning Kamp bp, bp2, (intmax_t)bp->bio_offset, (intmax_t)bp2->bio_length, 65314ac6812SPoul-Henning Kamp bp2->bio_data, bp2->bio_cmd); 654dd84a43cSPoul-Henning Kamp g_io_request(bp2, cp); 655c7e1925cSPoul-Henning Kamp KASSERT(cp->acr || cp->acw, 656c7e1925cSPoul-Henning Kamp ("g_dev_strategy raced with g_dev_close and lost")); 657c7e1925cSPoul-Henning Kamp 658dd84a43cSPoul-Henning Kamp } 659dd84a43cSPoul-Henning Kamp 6604b8374a7SPoul-Henning Kamp /* 6613c330affSAlexander Motin * g_dev_callback() 6623c330affSAlexander Motin * 6633c330affSAlexander Motin * Called by devfs when asynchronous device destruction is completed. 6643c330affSAlexander Motin * - Mark that we have no attached device any more. 6653c330affSAlexander Motin * - If there are no outstanding requests, schedule geom destruction. 6663c330affSAlexander Motin * Otherwise destruction will be scheduled later by g_dev_done(). 6673c330affSAlexander Motin */ 6683c330affSAlexander Motin 6693c330affSAlexander Motin static void 6703c330affSAlexander Motin g_dev_callback(void *arg) 6713c330affSAlexander Motin { 6723c330affSAlexander Motin struct g_consumer *cp; 6733c330affSAlexander Motin struct g_dev_softc *sc; 6743c330affSAlexander Motin int destroy; 6753c330affSAlexander Motin 6763c330affSAlexander Motin cp = arg; 6773c330affSAlexander Motin sc = cp->private; 6783c330affSAlexander Motin g_trace(G_T_TOPOLOGY, "g_dev_callback(%p(%s))", cp, cp->geom->name); 6793c330affSAlexander Motin 6803c330affSAlexander Motin mtx_lock(&sc->sc_mtx); 6813c330affSAlexander Motin sc->sc_dev = NULL; 6823c330affSAlexander Motin sc->sc_alias = NULL; 6833c330affSAlexander Motin destroy = (sc->sc_active == 0); 6843c330affSAlexander Motin mtx_unlock(&sc->sc_mtx); 6853c330affSAlexander Motin if (destroy) 6863c330affSAlexander Motin g_post_event(g_dev_destroy, cp, M_WAITOK, NULL); 6873c330affSAlexander Motin } 6883c330affSAlexander Motin 6893c330affSAlexander Motin /* 6904b8374a7SPoul-Henning Kamp * g_dev_orphan() 6914b8374a7SPoul-Henning Kamp * 692df6c9fe9SPoul-Henning Kamp * Called from below when the provider orphaned us. 693df6c9fe9SPoul-Henning Kamp * - Clear any dump settings. 6943c330affSAlexander Motin * - Request asynchronous device destruction to prevent any more requests 6953c330affSAlexander Motin * from coming in. The provider is already marked with an error, so 6963c330affSAlexander Motin * anything which comes in in the interrim will be returned immediately. 6974b8374a7SPoul-Henning Kamp */ 698dd84a43cSPoul-Henning Kamp 699dd84a43cSPoul-Henning Kamp static void 700b1876192SPoul-Henning Kamp g_dev_orphan(struct g_consumer *cp) 701dd84a43cSPoul-Henning Kamp { 70289c9c53dSPoul-Henning Kamp struct cdev *dev; 7033c330affSAlexander Motin struct g_dev_softc *sc; 704dd84a43cSPoul-Henning Kamp 705dd84a43cSPoul-Henning Kamp g_topology_assert(); 7063c330affSAlexander Motin sc = cp->private; 7073c330affSAlexander Motin dev = sc->sc_dev; 7083c330affSAlexander Motin g_trace(G_T_TOPOLOGY, "g_dev_orphan(%p(%s))", cp, cp->geom->name); 709df6c9fe9SPoul-Henning Kamp 710df6c9fe9SPoul-Henning Kamp /* Reset any dump-area set on this device */ 71195c24b31SPoul-Henning Kamp if (dev->si_flags & SI_DUMPDEV) 7125ebb15b9SPawel Jakub Dawidek (void)set_dumper(NULL, NULL, curthread); 713df6c9fe9SPoul-Henning Kamp 71489c9c53dSPoul-Henning Kamp /* Destroy the struct cdev *so we get no more requests */ 7153c330affSAlexander Motin destroy_dev_sched_cb(dev, g_dev_callback, cp); 716dd84a43cSPoul-Henning Kamp } 717dd84a43cSPoul-Henning Kamp 7184b8374a7SPoul-Henning Kamp DECLARE_GEOM_CLASS(g_dev_class, g_dev); 719