xref: /freebsd/sys/geom/geom_dev.c (revision b4d7290796e8cebb03d59e0f753e6f0d57a72389)
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