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$"); 38dd84a43cSPoul-Henning Kamp 39679f8b7eSPawel Jakub Dawidek #include "opt_ddb.h" 40679f8b7eSPawel Jakub Dawidek 41dd84a43cSPoul-Henning Kamp #include <sys/param.h> 42dd84a43cSPoul-Henning Kamp #include <sys/systm.h> 43e24cbd90SPoul-Henning Kamp #include <sys/devicestat.h> 44dd84a43cSPoul-Henning Kamp #include <sys/kernel.h> 45dd84a43cSPoul-Henning Kamp #include <sys/malloc.h> 46dd84a43cSPoul-Henning Kamp #include <sys/bio.h> 47dd84a43cSPoul-Henning Kamp #include <sys/sysctl.h> 48dd84a43cSPoul-Henning Kamp #include <sys/proc.h> 49dd84a43cSPoul-Henning Kamp #include <sys/kthread.h> 50dd84a43cSPoul-Henning Kamp #include <sys/lock.h> 51dd84a43cSPoul-Henning Kamp #include <sys/mutex.h> 52dd84a43cSPoul-Henning Kamp #include <sys/errno.h> 53dd84a43cSPoul-Henning Kamp #include <sys/sbuf.h> 54dd84a43cSPoul-Henning Kamp #include <geom/geom.h> 55b1876192SPoul-Henning Kamp #include <geom/geom_int.h> 56dd84a43cSPoul-Henning Kamp #include <machine/stdarg.h> 57dd84a43cSPoul-Henning Kamp 58679f8b7eSPawel Jakub Dawidek #ifdef DDB 59679f8b7eSPawel Jakub Dawidek #include <ddb/ddb.h> 60679f8b7eSPawel Jakub Dawidek #endif 61679f8b7eSPawel Jakub Dawidek 62002d1d1cSJaakko Heinonen #ifdef KDB 63002d1d1cSJaakko Heinonen #include <sys/kdb.h> 64002d1d1cSJaakko Heinonen #endif 65002d1d1cSJaakko Heinonen 662654e1fcSPoul-Henning Kamp struct class_list_head g_classes = LIST_HEAD_INITIALIZER(g_classes); 67dd84a43cSPoul-Henning Kamp static struct g_tailq_head geoms = TAILQ_HEAD_INITIALIZER(geoms); 68dd84a43cSPoul-Henning Kamp char *g_wait_event, *g_wait_up, *g_wait_down, *g_wait_sim; 69dd84a43cSPoul-Henning Kamp 706c87f8d5SPoul-Henning Kamp struct g_hh00 { 716c87f8d5SPoul-Henning Kamp struct g_class *mp; 72245899ccSEdward Tomasz Napierala struct g_provider *pp; 73245899ccSEdward Tomasz Napierala off_t size; 746c87f8d5SPoul-Henning Kamp int error; 75f96c8ef1SAndrew R. Reiter int post; 766c87f8d5SPoul-Henning Kamp }; 779972896cSPoul-Henning Kamp 789972896cSPoul-Henning Kamp /* 799972896cSPoul-Henning Kamp * This event offers a new class a chance to taste all preexisting providers. 809972896cSPoul-Henning Kamp */ 819972896cSPoul-Henning Kamp static void 826c87f8d5SPoul-Henning Kamp g_load_class(void *arg, int flag) 839972896cSPoul-Henning Kamp { 846c87f8d5SPoul-Henning Kamp struct g_hh00 *hh; 859972896cSPoul-Henning Kamp struct g_class *mp2, *mp; 869972896cSPoul-Henning Kamp struct g_geom *gp; 879972896cSPoul-Henning Kamp struct g_provider *pp; 889972896cSPoul-Henning Kamp 899972896cSPoul-Henning Kamp g_topology_assert(); 906c87f8d5SPoul-Henning Kamp if (flag == EV_CANCEL) /* XXX: can't happen ? */ 919972896cSPoul-Henning Kamp return; 929972896cSPoul-Henning Kamp if (g_shutdown) 939972896cSPoul-Henning Kamp return; 946c87f8d5SPoul-Henning Kamp 956c87f8d5SPoul-Henning Kamp hh = arg; 966c87f8d5SPoul-Henning Kamp mp = hh->mp; 97f96c8ef1SAndrew R. Reiter hh->error = 0; 989bb329f4SPoul-Henning Kamp if (hh->post) { 999bb329f4SPoul-Henning Kamp g_free(hh); 1009bb329f4SPoul-Henning Kamp hh = NULL; 1019bb329f4SPoul-Henning Kamp } 1026c87f8d5SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_load_class(%s)", mp->name); 103799426f8SPoul-Henning Kamp KASSERT(mp->name != NULL && *mp->name != '\0', 104799426f8SPoul-Henning Kamp ("GEOM class has no name")); 105ce64e0f2SPoul-Henning Kamp LIST_FOREACH(mp2, &g_classes, class) { 106f96c8ef1SAndrew R. Reiter if (mp2 == mp) { 107f96c8ef1SAndrew R. Reiter printf("The GEOM class %s is already loaded.\n", 108f96c8ef1SAndrew R. Reiter mp2->name); 1099bb329f4SPoul-Henning Kamp if (hh != NULL) 110f96c8ef1SAndrew R. Reiter hh->error = EEXIST; 111f96c8ef1SAndrew R. Reiter return; 112f96c8ef1SAndrew R. Reiter } else if (strcmp(mp2->name, mp->name) == 0) { 113f96c8ef1SAndrew R. Reiter printf("A GEOM class %s is already loaded.\n", 114f96c8ef1SAndrew R. Reiter mp2->name); 1159bb329f4SPoul-Henning Kamp if (hh != NULL) 116f96c8ef1SAndrew R. Reiter hh->error = EEXIST; 117f96c8ef1SAndrew R. Reiter return; 118f96c8ef1SAndrew R. Reiter } 119ce64e0f2SPoul-Henning Kamp } 1206c87f8d5SPoul-Henning Kamp 1216c87f8d5SPoul-Henning Kamp LIST_INIT(&mp->geom); 1226c87f8d5SPoul-Henning Kamp LIST_INSERT_HEAD(&g_classes, mp, class); 1230ecc7670SPoul-Henning Kamp if (mp->init != NULL) 1240ecc7670SPoul-Henning Kamp mp->init(mp); 1256c87f8d5SPoul-Henning Kamp if (mp->taste == NULL) 1269972896cSPoul-Henning Kamp return; 1276c87f8d5SPoul-Henning Kamp LIST_FOREACH(mp2, &g_classes, class) { 1286c87f8d5SPoul-Henning Kamp if (mp == mp2) 1299972896cSPoul-Henning Kamp continue; 1306c87f8d5SPoul-Henning Kamp LIST_FOREACH(gp, &mp2->geom, geom) { 1319972896cSPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) { 1326c87f8d5SPoul-Henning Kamp mp->taste(mp, pp, 0); 1339972896cSPoul-Henning Kamp g_topology_assert(); 1349972896cSPoul-Henning Kamp } 1359972896cSPoul-Henning Kamp } 1369972896cSPoul-Henning Kamp } 1379972896cSPoul-Henning Kamp } 1389972896cSPoul-Henning Kamp 1399061251fSJaakko Heinonen static int 1409061251fSJaakko Heinonen g_unload_class(struct g_class *mp) 141dd84a43cSPoul-Henning Kamp { 1426c87f8d5SPoul-Henning Kamp struct g_geom *gp; 1436c87f8d5SPoul-Henning Kamp struct g_provider *pp; 1446c87f8d5SPoul-Henning Kamp struct g_consumer *cp; 1456c87f8d5SPoul-Henning Kamp int error; 1466c87f8d5SPoul-Henning Kamp 1479061251fSJaakko Heinonen g_topology_lock(); 1486c87f8d5SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_unload_class(%s)", mp->name); 1499061251fSJaakko Heinonen retry: 1509061251fSJaakko Heinonen G_VALID_CLASS(mp); 1519061251fSJaakko Heinonen LIST_FOREACH(gp, &mp->geom, geom) { 1529061251fSJaakko Heinonen /* We refuse to unload if anything is open */ 1539061251fSJaakko Heinonen LIST_FOREACH(pp, &gp->provider, provider) 1549061251fSJaakko Heinonen if (pp->acr || pp->acw || pp->ace) { 1559061251fSJaakko Heinonen g_topology_unlock(); 1569061251fSJaakko Heinonen return (EBUSY); 1579061251fSJaakko Heinonen } 1589061251fSJaakko Heinonen LIST_FOREACH(cp, &gp->consumer, consumer) 1599061251fSJaakko Heinonen if (cp->acr || cp->acw || cp->ace) { 1609061251fSJaakko Heinonen g_topology_unlock(); 1619061251fSJaakko Heinonen return (EBUSY); 1629061251fSJaakko Heinonen } 1639061251fSJaakko Heinonen /* If the geom is withering, wait for it to finish. */ 1649061251fSJaakko Heinonen if (gp->flags & G_GEOM_WITHER) { 1659061251fSJaakko Heinonen g_topology_sleep(mp, 1); 1669061251fSJaakko Heinonen goto retry; 1679061251fSJaakko Heinonen } 1689061251fSJaakko Heinonen } 1690ed4f6a1SPoul-Henning Kamp 1700ed4f6a1SPoul-Henning Kamp /* 1710ed4f6a1SPoul-Henning Kamp * We allow unloading if we have no geoms, or a class 1720ed4f6a1SPoul-Henning Kamp * method we can use to get rid of them. 1730ed4f6a1SPoul-Henning Kamp */ 1740ed4f6a1SPoul-Henning Kamp if (!LIST_EMPTY(&mp->geom) && mp->destroy_geom == NULL) { 1759061251fSJaakko Heinonen g_topology_unlock(); 1769061251fSJaakko Heinonen return (EOPNOTSUPP); 1776c87f8d5SPoul-Henning Kamp } 1786c87f8d5SPoul-Henning Kamp 1796c87f8d5SPoul-Henning Kamp /* Bar new entries */ 1806c87f8d5SPoul-Henning Kamp mp->taste = NULL; 1816c87f8d5SPoul-Henning Kamp mp->config = NULL; 1826c87f8d5SPoul-Henning Kamp 1839061251fSJaakko Heinonen LIST_FOREACH(gp, &mp->geom, geom) { 1849061251fSJaakko Heinonen error = mp->destroy_geom(NULL, mp, gp); 1859061251fSJaakko Heinonen if (error != 0) { 1869061251fSJaakko Heinonen g_topology_unlock(); 1879061251fSJaakko Heinonen return (error); 1889061251fSJaakko Heinonen } 1899061251fSJaakko Heinonen } 1909061251fSJaakko Heinonen /* Wait for withering to finish. */ 191e26bafdcSPoul-Henning Kamp for (;;) { 192e26bafdcSPoul-Henning Kamp gp = LIST_FIRST(&mp->geom); 193e26bafdcSPoul-Henning Kamp if (gp == NULL) 194e26bafdcSPoul-Henning Kamp break; 1959061251fSJaakko Heinonen KASSERT(gp->flags & G_GEOM_WITHER, 1969061251fSJaakko Heinonen ("Non-withering geom in class %s", mp->name)); 1979061251fSJaakko Heinonen g_topology_sleep(mp, 1); 1986c87f8d5SPoul-Henning Kamp } 1999061251fSJaakko Heinonen G_VALID_CLASS(mp); 2006c87f8d5SPoul-Henning Kamp if (mp->fini != NULL) 2016c87f8d5SPoul-Henning Kamp mp->fini(mp); 2020ecc7670SPoul-Henning Kamp LIST_REMOVE(mp, class); 2039061251fSJaakko Heinonen g_topology_unlock(); 2049061251fSJaakko Heinonen 2059061251fSJaakko Heinonen return (0); 2066c87f8d5SPoul-Henning Kamp } 2076c87f8d5SPoul-Henning Kamp 2086c87f8d5SPoul-Henning Kamp int 2096c87f8d5SPoul-Henning Kamp g_modevent(module_t mod, int type, void *data) 2106c87f8d5SPoul-Henning Kamp { 2116c87f8d5SPoul-Henning Kamp struct g_hh00 *hh; 2126c87f8d5SPoul-Henning Kamp int error; 2136c87f8d5SPoul-Henning Kamp static int g_ignition; 214dd66958eSPoul-Henning Kamp struct g_class *mp; 215dd84a43cSPoul-Henning Kamp 216dd66958eSPoul-Henning Kamp mp = data; 21707f076feSPoul-Henning Kamp if (mp->version != G_VERSION) { 218dd66958eSPoul-Henning Kamp printf("GEOM class %s has Wrong version %x\n", 219dd66958eSPoul-Henning Kamp mp->name, mp->version); 220dd66958eSPoul-Henning Kamp return (EINVAL); 221dd66958eSPoul-Henning Kamp } 222dd84a43cSPoul-Henning Kamp if (!g_ignition) { 223dd84a43cSPoul-Henning Kamp g_ignition++; 224dd84a43cSPoul-Henning Kamp g_init(); 225dd84a43cSPoul-Henning Kamp } 2266c87f8d5SPoul-Henning Kamp error = EOPNOTSUPP; 2276c87f8d5SPoul-Henning Kamp switch (type) { 2286c87f8d5SPoul-Henning Kamp case MOD_LOAD: 2299061251fSJaakko Heinonen g_trace(G_T_TOPOLOGY, "g_modevent(%s, LOAD)", mp->name); 2309061251fSJaakko Heinonen hh = g_malloc(sizeof *hh, M_WAITOK | M_ZERO); 2319061251fSJaakko Heinonen hh->mp = mp; 2326f299fa3SBrian Feldman /* 2336f299fa3SBrian Feldman * Once the system is not cold, MOD_LOAD calls will be 2346f299fa3SBrian Feldman * from the userland and the g_event thread will be able 2356f299fa3SBrian Feldman * to acknowledge their completion. 2366f299fa3SBrian Feldman */ 237f96c8ef1SAndrew R. Reiter if (cold) { 238f96c8ef1SAndrew R. Reiter hh->post = 1; 239f96c8ef1SAndrew R. Reiter error = g_post_event(g_load_class, hh, M_WAITOK, NULL); 240f96c8ef1SAndrew R. Reiter } else { 241f96c8ef1SAndrew R. Reiter error = g_waitfor_event(g_load_class, hh, M_WAITOK, 242f96c8ef1SAndrew R. Reiter NULL); 243f96c8ef1SAndrew R. Reiter if (error == 0) 244f96c8ef1SAndrew R. Reiter error = hh->error; 245f96c8ef1SAndrew R. Reiter g_free(hh); 246f96c8ef1SAndrew R. Reiter } 2476c87f8d5SPoul-Henning Kamp break; 2486c87f8d5SPoul-Henning Kamp case MOD_UNLOAD: 2499061251fSJaakko Heinonen g_trace(G_T_TOPOLOGY, "g_modevent(%s, UNLOAD)", mp->name); 2509061251fSJaakko Heinonen error = g_unload_class(mp); 2511f75de94SPoul-Henning Kamp if (error == 0) { 2529061251fSJaakko Heinonen KASSERT(LIST_EMPTY(&mp->geom), 2539061251fSJaakko Heinonen ("Unloaded class (%s) still has geom", mp->name)); 2541f75de94SPoul-Henning Kamp } 255f5b34814SPoul-Henning Kamp break; 2566c87f8d5SPoul-Henning Kamp } 2576c87f8d5SPoul-Henning Kamp return (error); 258dd84a43cSPoul-Henning Kamp } 259dd84a43cSPoul-Henning Kamp 2608a8fcb00SMarcel Moolenaar static void 2618a8fcb00SMarcel Moolenaar g_retaste_event(void *arg, int flag) 2628a8fcb00SMarcel Moolenaar { 2633631c638SAlexander Motin struct g_class *mp, *mp2; 2643631c638SAlexander Motin struct g_geom *gp; 2658a8fcb00SMarcel Moolenaar struct g_hh00 *hh; 2668a8fcb00SMarcel Moolenaar struct g_provider *pp; 2673631c638SAlexander Motin struct g_consumer *cp; 2688a8fcb00SMarcel Moolenaar 2698a8fcb00SMarcel Moolenaar g_topology_assert(); 2708a8fcb00SMarcel Moolenaar if (flag == EV_CANCEL) /* XXX: can't happen ? */ 2718a8fcb00SMarcel Moolenaar return; 2721b2cb2b3SDag-Erling Smørgrav if (g_shutdown || g_notaste) 2738a8fcb00SMarcel Moolenaar return; 2748a8fcb00SMarcel Moolenaar 2758a8fcb00SMarcel Moolenaar hh = arg; 2768a8fcb00SMarcel Moolenaar mp = hh->mp; 2778a8fcb00SMarcel Moolenaar hh->error = 0; 2788a8fcb00SMarcel Moolenaar if (hh->post) { 2798a8fcb00SMarcel Moolenaar g_free(hh); 2808a8fcb00SMarcel Moolenaar hh = NULL; 2818a8fcb00SMarcel Moolenaar } 2828a8fcb00SMarcel Moolenaar g_trace(G_T_TOPOLOGY, "g_retaste(%s)", mp->name); 2838a8fcb00SMarcel Moolenaar 2843631c638SAlexander Motin LIST_FOREACH(mp2, &g_classes, class) { 2853631c638SAlexander Motin LIST_FOREACH(gp, &mp2->geom, geom) { 2868a8fcb00SMarcel Moolenaar LIST_FOREACH(pp, &gp->provider, provider) { 2878a8fcb00SMarcel Moolenaar if (pp->acr || pp->acw || pp->ace) 2888a8fcb00SMarcel Moolenaar continue; 2893631c638SAlexander Motin LIST_FOREACH(cp, &pp->consumers, consumers) { 2903631c638SAlexander Motin if (cp->geom->class == mp && 2913631c638SAlexander Motin (cp->flags & G_CF_ORPHAN) == 0) 292856744baSMarcel Moolenaar break; 293856744baSMarcel Moolenaar } 2943631c638SAlexander Motin if (cp != NULL) { 2953631c638SAlexander Motin cp->flags |= G_CF_ORPHAN; 2963631c638SAlexander Motin g_wither_geom(cp->geom, ENXIO); 2973631c638SAlexander Motin } 2988a8fcb00SMarcel Moolenaar mp->taste(mp, pp, 0); 2998a8fcb00SMarcel Moolenaar g_topology_assert(); 3008a8fcb00SMarcel Moolenaar } 3018a8fcb00SMarcel Moolenaar } 3028a8fcb00SMarcel Moolenaar } 3038a8fcb00SMarcel Moolenaar } 3048a8fcb00SMarcel Moolenaar 3058a8fcb00SMarcel Moolenaar int 3068a8fcb00SMarcel Moolenaar g_retaste(struct g_class *mp) 3078a8fcb00SMarcel Moolenaar { 3088a8fcb00SMarcel Moolenaar struct g_hh00 *hh; 3098a8fcb00SMarcel Moolenaar int error; 3108a8fcb00SMarcel Moolenaar 3118a8fcb00SMarcel Moolenaar if (mp->taste == NULL) 3128a8fcb00SMarcel Moolenaar return (EINVAL); 3138a8fcb00SMarcel Moolenaar 3148a8fcb00SMarcel Moolenaar hh = g_malloc(sizeof *hh, M_WAITOK | M_ZERO); 3158a8fcb00SMarcel Moolenaar hh->mp = mp; 3168a8fcb00SMarcel Moolenaar 3178a8fcb00SMarcel Moolenaar if (cold) { 3188a8fcb00SMarcel Moolenaar hh->post = 1; 3198a8fcb00SMarcel Moolenaar error = g_post_event(g_retaste_event, hh, M_WAITOK, NULL); 3208a8fcb00SMarcel Moolenaar } else { 3218a8fcb00SMarcel Moolenaar error = g_waitfor_event(g_retaste_event, hh, M_WAITOK, NULL); 3228a8fcb00SMarcel Moolenaar if (error == 0) 3238a8fcb00SMarcel Moolenaar error = hh->error; 3248a8fcb00SMarcel Moolenaar g_free(hh); 3258a8fcb00SMarcel Moolenaar } 3268a8fcb00SMarcel Moolenaar 3278a8fcb00SMarcel Moolenaar return (error); 3288a8fcb00SMarcel Moolenaar } 3298a8fcb00SMarcel Moolenaar 330dd84a43cSPoul-Henning Kamp struct g_geom * 3310f9d3dbaSPoul-Henning Kamp g_new_geomf(struct g_class *mp, const char *fmt, ...) 332dd84a43cSPoul-Henning Kamp { 333dd84a43cSPoul-Henning Kamp struct g_geom *gp; 334dd84a43cSPoul-Henning Kamp va_list ap; 335dd84a43cSPoul-Henning Kamp struct sbuf *sb; 336dd84a43cSPoul-Henning Kamp 337dd84a43cSPoul-Henning Kamp g_topology_assert(); 3383d1d5bc3SPoul-Henning Kamp G_VALID_CLASS(mp); 3392616144eSDag-Erling Smørgrav sb = sbuf_new_auto(); 340a1a9b445SPoul-Henning Kamp va_start(ap, fmt); 341dd84a43cSPoul-Henning Kamp sbuf_vprintf(sb, fmt, ap); 342a1a9b445SPoul-Henning Kamp va_end(ap); 343dd84a43cSPoul-Henning Kamp sbuf_finish(sb); 344a163d034SWarner Losh gp = g_malloc(sizeof *gp, M_WAITOK | M_ZERO); 345a163d034SWarner Losh gp->name = g_malloc(sbuf_len(sb) + 1, M_WAITOK | M_ZERO); 346e805e8f0SPoul-Henning Kamp gp->class = mp; 347dd84a43cSPoul-Henning Kamp gp->rank = 1; 348dd84a43cSPoul-Henning Kamp LIST_INIT(&gp->consumer); 349dd84a43cSPoul-Henning Kamp LIST_INIT(&gp->provider); 350c624eb25SWarner Losh LIST_INIT(&gp->aliases); 351dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&mp->geom, gp, geom); 352dd84a43cSPoul-Henning Kamp TAILQ_INSERT_HEAD(&geoms, gp, geoms); 353dd84a43cSPoul-Henning Kamp strcpy(gp->name, sbuf_data(sb)); 354dd84a43cSPoul-Henning Kamp sbuf_delete(sb); 355dd66958eSPoul-Henning Kamp /* Fill in defaults from class */ 356dd66958eSPoul-Henning Kamp gp->start = mp->start; 357dd66958eSPoul-Henning Kamp gp->spoiled = mp->spoiled; 358416494d7SJustin T. Gibbs gp->attrchanged = mp->attrchanged; 359c3fb2891SKenneth D. Merry gp->providergone = mp->providergone; 360dd66958eSPoul-Henning Kamp gp->dumpconf = mp->dumpconf; 361dd66958eSPoul-Henning Kamp gp->access = mp->access; 362dd66958eSPoul-Henning Kamp gp->orphan = mp->orphan; 363dd66958eSPoul-Henning Kamp gp->ioctl = mp->ioctl; 364245899ccSEdward Tomasz Napierala gp->resize = mp->resize; 365dd84a43cSPoul-Henning Kamp return (gp); 366dd84a43cSPoul-Henning Kamp } 367dd84a43cSPoul-Henning Kamp 368dd84a43cSPoul-Henning Kamp void 369dd84a43cSPoul-Henning Kamp g_destroy_geom(struct g_geom *gp) 370dd84a43cSPoul-Henning Kamp { 371c624eb25SWarner Losh struct g_geom_alias *gap, *gaptmp; 372dd84a43cSPoul-Henning Kamp 373dd84a43cSPoul-Henning Kamp g_topology_assert(); 3743d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 3753d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_destroy_geom(%p(%s))", gp, gp->name); 376dd84a43cSPoul-Henning Kamp KASSERT(LIST_EMPTY(&gp->consumer), 377dd84a43cSPoul-Henning Kamp ("g_destroy_geom(%s) with consumer(s) [%p]", 378dd84a43cSPoul-Henning Kamp gp->name, LIST_FIRST(&gp->consumer))); 379dd84a43cSPoul-Henning Kamp KASSERT(LIST_EMPTY(&gp->provider), 380dd84a43cSPoul-Henning Kamp ("g_destroy_geom(%s) with provider(s) [%p]", 381cbb65040SPoul-Henning Kamp gp->name, LIST_FIRST(&gp->provider))); 382afcbcfaeSPoul-Henning Kamp g_cancel_event(gp); 383dd84a43cSPoul-Henning Kamp LIST_REMOVE(gp, geom); 384dd84a43cSPoul-Henning Kamp TAILQ_REMOVE(&geoms, gp, geoms); 385c624eb25SWarner Losh LIST_FOREACH_SAFE(gap, &gp->aliases, ga_next, gaptmp) 386c624eb25SWarner Losh g_free(gap); 3877d590cc4SPoul-Henning Kamp g_free(gp->name); 388dd84a43cSPoul-Henning Kamp g_free(gp); 389dd84a43cSPoul-Henning Kamp } 390dd84a43cSPoul-Henning Kamp 391d6227ae7SPoul-Henning Kamp /* 392fa13e9bbSUlf Lilleengen * This function is called (repeatedly) until the geom has withered away. 393d6227ae7SPoul-Henning Kamp */ 394d6227ae7SPoul-Henning Kamp void 395d6227ae7SPoul-Henning Kamp g_wither_geom(struct g_geom *gp, int error) 396d6227ae7SPoul-Henning Kamp { 3971b464bd8SPoul-Henning Kamp struct g_provider *pp; 398d6227ae7SPoul-Henning Kamp 3993d1d5bc3SPoul-Henning Kamp g_topology_assert(); 4003d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 401d6227ae7SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_wither_geom(%p(%s))", gp, gp->name); 402d6227ae7SPoul-Henning Kamp if (!(gp->flags & G_GEOM_WITHER)) { 403d6227ae7SPoul-Henning Kamp gp->flags |= G_GEOM_WITHER; 404d6227ae7SPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) 405b07ef6c2SPoul-Henning Kamp if (!(pp->flags & G_PF_ORPHAN)) 406d6227ae7SPoul-Henning Kamp g_orphan_provider(pp, error); 407d6227ae7SPoul-Henning Kamp } 4081b464bd8SPoul-Henning Kamp g_do_wither(); 409d6227ae7SPoul-Henning Kamp } 4101b464bd8SPoul-Henning Kamp 4111b464bd8SPoul-Henning Kamp /* 412d99c1559SMarcel Moolenaar * Convenience function to destroy a particular provider. 413d99c1559SMarcel Moolenaar */ 414d99c1559SMarcel Moolenaar void 415d99c1559SMarcel Moolenaar g_wither_provider(struct g_provider *pp, int error) 416d99c1559SMarcel Moolenaar { 417d99c1559SMarcel Moolenaar 418d99c1559SMarcel Moolenaar pp->flags |= G_PF_WITHER; 419d99c1559SMarcel Moolenaar if (!(pp->flags & G_PF_ORPHAN)) 420d99c1559SMarcel Moolenaar g_orphan_provider(pp, error); 421d99c1559SMarcel Moolenaar } 422d99c1559SMarcel Moolenaar 423d99c1559SMarcel Moolenaar /* 424725419afSPoul-Henning Kamp * This function is called (repeatedly) until the has withered away. 425725419afSPoul-Henning Kamp */ 426725419afSPoul-Henning Kamp void 427725419afSPoul-Henning Kamp g_wither_geom_close(struct g_geom *gp, int error) 428725419afSPoul-Henning Kamp { 429725419afSPoul-Henning Kamp struct g_consumer *cp; 430725419afSPoul-Henning Kamp 431725419afSPoul-Henning Kamp g_topology_assert(); 432725419afSPoul-Henning Kamp G_VALID_GEOM(gp); 433725419afSPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_wither_geom_close(%p(%s))", gp, gp->name); 434725419afSPoul-Henning Kamp LIST_FOREACH(cp, &gp->consumer, consumer) 435725419afSPoul-Henning Kamp if (cp->acr || cp->acw || cp->ace) 436725419afSPoul-Henning Kamp g_access(cp, -cp->acr, -cp->acw, -cp->ace); 437725419afSPoul-Henning Kamp g_wither_geom(gp, error); 438725419afSPoul-Henning Kamp } 439725419afSPoul-Henning Kamp 440725419afSPoul-Henning Kamp /* 4411b464bd8SPoul-Henning Kamp * This function is called (repeatedly) until we cant wash away more 44250199fa0SAlexander Motin * withered bits at present. 4431b464bd8SPoul-Henning Kamp */ 44450199fa0SAlexander Motin void 4451b464bd8SPoul-Henning Kamp g_wither_washer() 4461b464bd8SPoul-Henning Kamp { 4471b464bd8SPoul-Henning Kamp struct g_class *mp; 4481b464bd8SPoul-Henning Kamp struct g_geom *gp, *gp2; 4491b464bd8SPoul-Henning Kamp struct g_provider *pp, *pp2; 4501b464bd8SPoul-Henning Kamp struct g_consumer *cp, *cp2; 4511b464bd8SPoul-Henning Kamp 4521b464bd8SPoul-Henning Kamp g_topology_assert(); 4531b464bd8SPoul-Henning Kamp LIST_FOREACH(mp, &g_classes, class) { 4541b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(gp, &mp->geom, geom, gp2) { 4551b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(pp, &gp->provider, provider, pp2) { 4561b464bd8SPoul-Henning Kamp if (!(pp->flags & G_PF_WITHER)) 457d6227ae7SPoul-Henning Kamp continue; 4581b464bd8SPoul-Henning Kamp if (LIST_EMPTY(&pp->consumers)) 4591b464bd8SPoul-Henning Kamp g_destroy_provider(pp); 4601b464bd8SPoul-Henning Kamp } 4611b464bd8SPoul-Henning Kamp if (!(gp->flags & G_GEOM_WITHER)) 4621b464bd8SPoul-Henning Kamp continue; 4631b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(pp, &gp->provider, provider, pp2) { 4641b464bd8SPoul-Henning Kamp if (LIST_EMPTY(&pp->consumers)) 4651b464bd8SPoul-Henning Kamp g_destroy_provider(pp); 4661b464bd8SPoul-Henning Kamp } 4671b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(cp, &gp->consumer, consumer, cp2) { 46850199fa0SAlexander Motin if (cp->acr || cp->acw || cp->ace) 4691b464bd8SPoul-Henning Kamp continue; 470539bec40SPoul-Henning Kamp if (cp->provider != NULL) 471d6227ae7SPoul-Henning Kamp g_detach(cp); 472d6227ae7SPoul-Henning Kamp g_destroy_consumer(cp); 473d6227ae7SPoul-Henning Kamp } 4741b464bd8SPoul-Henning Kamp if (LIST_EMPTY(&gp->provider) && 4751b464bd8SPoul-Henning Kamp LIST_EMPTY(&gp->consumer)) 476d6227ae7SPoul-Henning Kamp g_destroy_geom(gp); 4771b464bd8SPoul-Henning Kamp } 4781b464bd8SPoul-Henning Kamp } 479d6227ae7SPoul-Henning Kamp } 480d6227ae7SPoul-Henning Kamp 481dd84a43cSPoul-Henning Kamp struct g_consumer * 482dd84a43cSPoul-Henning Kamp g_new_consumer(struct g_geom *gp) 483dd84a43cSPoul-Henning Kamp { 484dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 485dd84a43cSPoul-Henning Kamp 486dd84a43cSPoul-Henning Kamp g_topology_assert(); 4873d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 488799426f8SPoul-Henning Kamp KASSERT(!(gp->flags & G_GEOM_WITHER), 489799426f8SPoul-Henning Kamp ("g_new_consumer on WITHERing geom(%s) (class %s)", 490799426f8SPoul-Henning Kamp gp->name, gp->class->name)); 49107d77fc6SPoul-Henning Kamp KASSERT(gp->orphan != NULL, 49207d77fc6SPoul-Henning Kamp ("g_new_consumer on geom(%s) (class %s) without orphan", 49307d77fc6SPoul-Henning Kamp gp->name, gp->class->name)); 494dd84a43cSPoul-Henning Kamp 495a163d034SWarner Losh cp = g_malloc(sizeof *cp, M_WAITOK | M_ZERO); 496dd84a43cSPoul-Henning Kamp cp->geom = gp; 497e24cbd90SPoul-Henning Kamp cp->stat = devstat_new_entry(cp, -1, 0, DEVSTAT_ALL_SUPPORTED, 498e24cbd90SPoul-Henning Kamp DEVSTAT_TYPE_DIRECT, DEVSTAT_PRIORITY_MAX); 499dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&gp->consumer, cp, consumer); 500dd84a43cSPoul-Henning Kamp return(cp); 501dd84a43cSPoul-Henning Kamp } 502dd84a43cSPoul-Henning Kamp 503dd84a43cSPoul-Henning Kamp void 504dd84a43cSPoul-Henning Kamp g_destroy_consumer(struct g_consumer *cp) 505dd84a43cSPoul-Henning Kamp { 506d6227ae7SPoul-Henning Kamp struct g_geom *gp; 507dd84a43cSPoul-Henning Kamp 508dd84a43cSPoul-Henning Kamp g_topology_assert(); 5093d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 5103d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_destroy_consumer(%p)", cp); 511dd84a43cSPoul-Henning Kamp KASSERT (cp->provider == NULL, ("g_destroy_consumer but attached")); 512dd84a43cSPoul-Henning Kamp KASSERT (cp->acr == 0, ("g_destroy_consumer with acr")); 513dd84a43cSPoul-Henning Kamp KASSERT (cp->acw == 0, ("g_destroy_consumer with acw")); 514dd84a43cSPoul-Henning Kamp KASSERT (cp->ace == 0, ("g_destroy_consumer with ace")); 515afcbcfaeSPoul-Henning Kamp g_cancel_event(cp); 516d6227ae7SPoul-Henning Kamp gp = cp->geom; 517dd84a43cSPoul-Henning Kamp LIST_REMOVE(cp, consumer); 518e24cbd90SPoul-Henning Kamp devstat_remove_entry(cp->stat); 519dd84a43cSPoul-Henning Kamp g_free(cp); 520d6227ae7SPoul-Henning Kamp if (gp->flags & G_GEOM_WITHER) 5211b464bd8SPoul-Henning Kamp g_do_wither(); 522dd84a43cSPoul-Henning Kamp } 523dd84a43cSPoul-Henning Kamp 5249ab3ea78SPoul-Henning Kamp static void 5259ab3ea78SPoul-Henning Kamp g_new_provider_event(void *arg, int flag) 5269ab3ea78SPoul-Henning Kamp { 5279ab3ea78SPoul-Henning Kamp struct g_class *mp; 5289ab3ea78SPoul-Henning Kamp struct g_provider *pp; 5293631c638SAlexander Motin struct g_consumer *cp, *next_cp; 5309ab3ea78SPoul-Henning Kamp 5319ab3ea78SPoul-Henning Kamp g_topology_assert(); 5329ab3ea78SPoul-Henning Kamp if (flag == EV_CANCEL) 5339ab3ea78SPoul-Henning Kamp return; 5349ab3ea78SPoul-Henning Kamp if (g_shutdown) 5359ab3ea78SPoul-Henning Kamp return; 5369ab3ea78SPoul-Henning Kamp pp = arg; 5373d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 5389097a8e6SPawel Jakub Dawidek KASSERT(!(pp->flags & G_PF_WITHER), 5399097a8e6SPawel Jakub Dawidek ("g_new_provider_event but withered")); 5403631c638SAlexander Motin LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, next_cp) { 5413631c638SAlexander Motin if ((cp->flags & G_CF_ORPHAN) == 0 && 5423631c638SAlexander Motin cp->geom->attrchanged != NULL) 5433631c638SAlexander Motin cp->geom->attrchanged(cp, "GEOM::media"); 5443631c638SAlexander Motin } 5451b2cb2b3SDag-Erling Smørgrav if (g_notaste) 5461b2cb2b3SDag-Erling Smørgrav return; 5479ab3ea78SPoul-Henning Kamp LIST_FOREACH(mp, &g_classes, class) { 5489ab3ea78SPoul-Henning Kamp if (mp->taste == NULL) 5499ab3ea78SPoul-Henning Kamp continue; 5509ab3ea78SPoul-Henning Kamp LIST_FOREACH(cp, &pp->consumers, consumers) 5513631c638SAlexander Motin if (cp->geom->class == mp && 5523631c638SAlexander Motin (cp->flags & G_CF_ORPHAN) == 0) 553cb9b72ceSPawel Jakub Dawidek break; 554cb9b72ceSPawel Jakub Dawidek if (cp != NULL) 5559ab3ea78SPoul-Henning Kamp continue; 556c4da4e46SPoul-Henning Kamp mp->taste(mp, pp, 0); 5579ab3ea78SPoul-Henning Kamp g_topology_assert(); 5589ab3ea78SPoul-Henning Kamp } 5599ab3ea78SPoul-Henning Kamp } 5609ab3ea78SPoul-Henning Kamp 5619ab3ea78SPoul-Henning Kamp 562dd84a43cSPoul-Henning Kamp struct g_provider * 5630f9d3dbaSPoul-Henning Kamp g_new_providerf(struct g_geom *gp, const char *fmt, ...) 564dd84a43cSPoul-Henning Kamp { 565dd84a43cSPoul-Henning Kamp struct g_provider *pp; 566dd84a43cSPoul-Henning Kamp struct sbuf *sb; 567dd84a43cSPoul-Henning Kamp va_list ap; 568dd84a43cSPoul-Henning Kamp 569dd84a43cSPoul-Henning Kamp g_topology_assert(); 5703d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 571e26bafdcSPoul-Henning Kamp KASSERT(gp->access != NULL, 572e26bafdcSPoul-Henning Kamp ("new provider on geom(%s) without ->access (class %s)", 573e26bafdcSPoul-Henning Kamp gp->name, gp->class->name)); 574799426f8SPoul-Henning Kamp KASSERT(gp->start != NULL, 575cff2ddaeSPawel Jakub Dawidek ("new provider on geom(%s) without ->start (class %s)", 576cff2ddaeSPawel Jakub Dawidek gp->name, gp->class->name)); 577799426f8SPoul-Henning Kamp KASSERT(!(gp->flags & G_GEOM_WITHER), 578cff2ddaeSPawel Jakub Dawidek ("new provider on WITHERing geom(%s) (class %s)", 579cff2ddaeSPawel Jakub Dawidek gp->name, gp->class->name)); 5802616144eSDag-Erling Smørgrav sb = sbuf_new_auto(); 581a1a9b445SPoul-Henning Kamp va_start(ap, fmt); 582dd84a43cSPoul-Henning Kamp sbuf_vprintf(sb, fmt, ap); 583a1a9b445SPoul-Henning Kamp va_end(ap); 584dd84a43cSPoul-Henning Kamp sbuf_finish(sb); 585a163d034SWarner Losh pp = g_malloc(sizeof *pp + sbuf_len(sb) + 1, M_WAITOK | M_ZERO); 586dd84a43cSPoul-Henning Kamp pp->name = (char *)(pp + 1); 587dd84a43cSPoul-Henning Kamp strcpy(pp->name, sbuf_data(sb)); 588dd84a43cSPoul-Henning Kamp sbuf_delete(sb); 589dd84a43cSPoul-Henning Kamp LIST_INIT(&pp->consumers); 590dd84a43cSPoul-Henning Kamp pp->error = ENXIO; 591dd84a43cSPoul-Henning Kamp pp->geom = gp; 592e24cbd90SPoul-Henning Kamp pp->stat = devstat_new_entry(pp, -1, 0, DEVSTAT_ALL_SUPPORTED, 593e24cbd90SPoul-Henning Kamp DEVSTAT_TYPE_DIRECT, DEVSTAT_PRIORITY_MAX); 594dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&gp->provider, pp, provider); 595e26bafdcSPoul-Henning Kamp g_post_event(g_new_provider_event, pp, M_WAITOK, pp, gp, NULL); 596dd84a43cSPoul-Henning Kamp return (pp); 597dd84a43cSPoul-Henning Kamp } 598dd84a43cSPoul-Henning Kamp 599dd84a43cSPoul-Henning Kamp void 600dd84a43cSPoul-Henning Kamp g_error_provider(struct g_provider *pp, int error) 601dd84a43cSPoul-Henning Kamp { 602dd84a43cSPoul-Henning Kamp 6033d1d5bc3SPoul-Henning Kamp /* G_VALID_PROVIDER(pp); We may not have g_topology */ 604dd84a43cSPoul-Henning Kamp pp->error = error; 605dd84a43cSPoul-Henning Kamp } 606dd84a43cSPoul-Henning Kamp 607245899ccSEdward Tomasz Napierala static void 608245899ccSEdward Tomasz Napierala g_resize_provider_event(void *arg, int flag) 609245899ccSEdward Tomasz Napierala { 610245899ccSEdward Tomasz Napierala struct g_hh00 *hh; 611245899ccSEdward Tomasz Napierala struct g_class *mp; 612245899ccSEdward Tomasz Napierala struct g_geom *gp; 613245899ccSEdward Tomasz Napierala struct g_provider *pp; 614245899ccSEdward Tomasz Napierala struct g_consumer *cp, *cp2; 615245899ccSEdward Tomasz Napierala off_t size; 616245899ccSEdward Tomasz Napierala 617245899ccSEdward Tomasz Napierala g_topology_assert(); 618245899ccSEdward Tomasz Napierala if (g_shutdown) 619245899ccSEdward Tomasz Napierala return; 620245899ccSEdward Tomasz Napierala 621245899ccSEdward Tomasz Napierala hh = arg; 622245899ccSEdward Tomasz Napierala pp = hh->pp; 623245899ccSEdward Tomasz Napierala size = hh->size; 6243a3ef28eSEdward Tomasz Napierala g_free(hh); 625245899ccSEdward Tomasz Napierala 626245899ccSEdward Tomasz Napierala G_VALID_PROVIDER(pp); 627e5616d65SKenneth D. Merry KASSERT(!(pp->flags & G_PF_WITHER), 628e5616d65SKenneth D. Merry ("g_resize_provider_event but withered")); 629245899ccSEdward Tomasz Napierala g_trace(G_T_TOPOLOGY, "g_resize_provider_event(%p)", pp); 630245899ccSEdward Tomasz Napierala 631245899ccSEdward Tomasz Napierala LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, cp2) { 632245899ccSEdward Tomasz Napierala gp = cp->geom; 6333631c638SAlexander Motin if (gp->resize == NULL && size < pp->mediasize) { 6343631c638SAlexander Motin cp->flags |= G_CF_ORPHAN; 635245899ccSEdward Tomasz Napierala cp->geom->orphan(cp); 636245899ccSEdward Tomasz Napierala } 6373631c638SAlexander Motin } 638245899ccSEdward Tomasz Napierala 639245899ccSEdward Tomasz Napierala pp->mediasize = size; 640245899ccSEdward Tomasz Napierala 641245899ccSEdward Tomasz Napierala LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, cp2) { 642245899ccSEdward Tomasz Napierala gp = cp->geom; 6431f353a23SAndrey V. Elsukov if ((gp->flags & G_GEOM_WITHER) == 0 && gp->resize != NULL) 644245899ccSEdward Tomasz Napierala gp->resize(cp); 645245899ccSEdward Tomasz Napierala } 646245899ccSEdward Tomasz Napierala 647245899ccSEdward Tomasz Napierala /* 648245899ccSEdward Tomasz Napierala * After resizing, the previously invalid GEOM class metadata 649245899ccSEdward Tomasz Napierala * might become valid. This means we should retaste. 650245899ccSEdward Tomasz Napierala */ 651245899ccSEdward Tomasz Napierala LIST_FOREACH(mp, &g_classes, class) { 652245899ccSEdward Tomasz Napierala if (mp->taste == NULL) 653245899ccSEdward Tomasz Napierala continue; 654245899ccSEdward Tomasz Napierala LIST_FOREACH(cp, &pp->consumers, consumers) 6553631c638SAlexander Motin if (cp->geom->class == mp && 6563631c638SAlexander Motin (cp->flags & G_CF_ORPHAN) == 0) 657245899ccSEdward Tomasz Napierala break; 658245899ccSEdward Tomasz Napierala if (cp != NULL) 659245899ccSEdward Tomasz Napierala continue; 660245899ccSEdward Tomasz Napierala mp->taste(mp, pp, 0); 661245899ccSEdward Tomasz Napierala g_topology_assert(); 662245899ccSEdward Tomasz Napierala } 663245899ccSEdward Tomasz Napierala } 664245899ccSEdward Tomasz Napierala 665245899ccSEdward Tomasz Napierala void 666245899ccSEdward Tomasz Napierala g_resize_provider(struct g_provider *pp, off_t size) 667245899ccSEdward Tomasz Napierala { 668245899ccSEdward Tomasz Napierala struct g_hh00 *hh; 669245899ccSEdward Tomasz Napierala 670245899ccSEdward Tomasz Napierala G_VALID_PROVIDER(pp); 671e5616d65SKenneth D. Merry if (pp->flags & G_PF_WITHER) 672e5616d65SKenneth D. Merry return; 673245899ccSEdward Tomasz Napierala 674245899ccSEdward Tomasz Napierala if (size == pp->mediasize) 675245899ccSEdward Tomasz Napierala return; 676245899ccSEdward Tomasz Napierala 677245899ccSEdward Tomasz Napierala hh = g_malloc(sizeof *hh, M_WAITOK | M_ZERO); 678245899ccSEdward Tomasz Napierala hh->pp = pp; 679245899ccSEdward Tomasz Napierala hh->size = size; 680245899ccSEdward Tomasz Napierala g_post_event(g_resize_provider_event, hh, M_WAITOK, NULL); 681245899ccSEdward Tomasz Napierala } 682245899ccSEdward Tomasz Napierala 683769afdc7SPawel Jakub Dawidek #ifndef _PATH_DEV 684769afdc7SPawel Jakub Dawidek #define _PATH_DEV "/dev/" 685769afdc7SPawel Jakub Dawidek #endif 686769afdc7SPawel Jakub Dawidek 687d6c5e716SPoul-Henning Kamp struct g_provider * 688d6c5e716SPoul-Henning Kamp g_provider_by_name(char const *arg) 689d6c5e716SPoul-Henning Kamp { 690d6c5e716SPoul-Henning Kamp struct g_class *cp; 691d6c5e716SPoul-Henning Kamp struct g_geom *gp; 692ba772028SAlexander Motin struct g_provider *pp, *wpp; 693d6c5e716SPoul-Henning Kamp 694769afdc7SPawel Jakub Dawidek if (strncmp(arg, _PATH_DEV, sizeof(_PATH_DEV) - 1) == 0) 695769afdc7SPawel Jakub Dawidek arg += sizeof(_PATH_DEV) - 1; 696769afdc7SPawel Jakub Dawidek 697ba772028SAlexander Motin wpp = NULL; 698d6c5e716SPoul-Henning Kamp LIST_FOREACH(cp, &g_classes, class) { 699d6c5e716SPoul-Henning Kamp LIST_FOREACH(gp, &cp->geom, geom) { 700d6c5e716SPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) { 701ba772028SAlexander Motin if (strcmp(arg, pp->name) != 0) 702ba772028SAlexander Motin continue; 703ba772028SAlexander Motin if ((gp->flags & G_GEOM_WITHER) == 0 && 704ba772028SAlexander Motin (pp->flags & G_PF_WITHER) == 0) 705d6c5e716SPoul-Henning Kamp return (pp); 706ba772028SAlexander Motin else 707ba772028SAlexander Motin wpp = pp; 708d6c5e716SPoul-Henning Kamp } 709d6c5e716SPoul-Henning Kamp } 710d6c5e716SPoul-Henning Kamp } 711769afdc7SPawel Jakub Dawidek 712ba772028SAlexander Motin return (wpp); 713d6c5e716SPoul-Henning Kamp } 714dd84a43cSPoul-Henning Kamp 715dd84a43cSPoul-Henning Kamp void 716dd84a43cSPoul-Henning Kamp g_destroy_provider(struct g_provider *pp) 717dd84a43cSPoul-Henning Kamp { 718dd84a43cSPoul-Henning Kamp struct g_geom *gp; 719dd84a43cSPoul-Henning Kamp 720dd84a43cSPoul-Henning Kamp g_topology_assert(); 7213d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 722dd84a43cSPoul-Henning Kamp KASSERT(LIST_EMPTY(&pp->consumers), 723dd84a43cSPoul-Henning Kamp ("g_destroy_provider but attached")); 724dd84a43cSPoul-Henning Kamp KASSERT (pp->acr == 0, ("g_destroy_provider with acr")); 725dd84a43cSPoul-Henning Kamp KASSERT (pp->acw == 0, ("g_destroy_provider with acw")); 7269097a8e6SPawel Jakub Dawidek KASSERT (pp->ace == 0, ("g_destroy_provider with ace")); 727afcbcfaeSPoul-Henning Kamp g_cancel_event(pp); 728dd84a43cSPoul-Henning Kamp LIST_REMOVE(pp, provider); 729dd84a43cSPoul-Henning Kamp gp = pp->geom; 730e24cbd90SPoul-Henning Kamp devstat_remove_entry(pp->stat); 731c3fb2891SKenneth D. Merry /* 732c3fb2891SKenneth D. Merry * If a callback was provided, send notification that the provider 733c3fb2891SKenneth D. Merry * is now gone. 734c3fb2891SKenneth D. Merry */ 735c3fb2891SKenneth D. Merry if (gp->providergone != NULL) 736c3fb2891SKenneth D. Merry gp->providergone(pp); 737c3fb2891SKenneth D. Merry 738dd84a43cSPoul-Henning Kamp g_free(pp); 739d6227ae7SPoul-Henning Kamp if ((gp->flags & G_GEOM_WITHER)) 7401b464bd8SPoul-Henning Kamp g_do_wither(); 741dd84a43cSPoul-Henning Kamp } 742dd84a43cSPoul-Henning Kamp 743dd84a43cSPoul-Henning Kamp /* 744dd84a43cSPoul-Henning Kamp * We keep the "geoms" list sorted by topological order (== increasing 745dd84a43cSPoul-Henning Kamp * numerical rank) at all times. 746dd84a43cSPoul-Henning Kamp * When an attach is done, the attaching geoms rank is invalidated 747dd84a43cSPoul-Henning Kamp * and it is moved to the tail of the list. 748dd84a43cSPoul-Henning Kamp * All geoms later in the sequence has their ranks reevaluated in 749dd84a43cSPoul-Henning Kamp * sequence. If we cannot assign rank to a geom because it's 750dd84a43cSPoul-Henning Kamp * prerequisites do not have rank, we move that element to the tail 751dd84a43cSPoul-Henning Kamp * of the sequence with invalid rank as well. 752dd84a43cSPoul-Henning Kamp * At some point we encounter our original geom and if we stil fail 753dd84a43cSPoul-Henning Kamp * to assign it a rank, there must be a loop and we fail back to 754503abe45SPoul-Henning Kamp * g_attach() which detach again and calls redo_rank again 755dd84a43cSPoul-Henning Kamp * to fix up the damage. 756dd84a43cSPoul-Henning Kamp * It would be much simpler code wise to do it recursively, but we 757dd84a43cSPoul-Henning Kamp * can't risk that on the kernel stack. 758dd84a43cSPoul-Henning Kamp */ 759dd84a43cSPoul-Henning Kamp 760dd84a43cSPoul-Henning Kamp static int 761dd84a43cSPoul-Henning Kamp redo_rank(struct g_geom *gp) 762dd84a43cSPoul-Henning Kamp { 763dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 764dd84a43cSPoul-Henning Kamp struct g_geom *gp1, *gp2; 765dd84a43cSPoul-Henning Kamp int n, m; 766dd84a43cSPoul-Henning Kamp 767dd84a43cSPoul-Henning Kamp g_topology_assert(); 7683d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 769dd84a43cSPoul-Henning Kamp 770dd84a43cSPoul-Henning Kamp /* Invalidate this geoms rank and move it to the tail */ 771dd84a43cSPoul-Henning Kamp gp1 = TAILQ_NEXT(gp, geoms); 772dd84a43cSPoul-Henning Kamp if (gp1 != NULL) { 773dd84a43cSPoul-Henning Kamp gp->rank = 0; 774dd84a43cSPoul-Henning Kamp TAILQ_REMOVE(&geoms, gp, geoms); 775dd84a43cSPoul-Henning Kamp TAILQ_INSERT_TAIL(&geoms, gp, geoms); 776dd84a43cSPoul-Henning Kamp } else { 777dd84a43cSPoul-Henning Kamp gp1 = gp; 778dd84a43cSPoul-Henning Kamp } 779dd84a43cSPoul-Henning Kamp 780dd84a43cSPoul-Henning Kamp /* re-rank the rest of the sequence */ 781dd84a43cSPoul-Henning Kamp for (; gp1 != NULL; gp1 = gp2) { 782dd84a43cSPoul-Henning Kamp gp1->rank = 0; 783dd84a43cSPoul-Henning Kamp m = 1; 784dd84a43cSPoul-Henning Kamp LIST_FOREACH(cp, &gp1->consumer, consumer) { 785dd84a43cSPoul-Henning Kamp if (cp->provider == NULL) 786dd84a43cSPoul-Henning Kamp continue; 787dd84a43cSPoul-Henning Kamp n = cp->provider->geom->rank; 788dd84a43cSPoul-Henning Kamp if (n == 0) { 789dd84a43cSPoul-Henning Kamp m = 0; 790dd84a43cSPoul-Henning Kamp break; 791dd84a43cSPoul-Henning Kamp } else if (n >= m) 792dd84a43cSPoul-Henning Kamp m = n + 1; 793dd84a43cSPoul-Henning Kamp } 794dd84a43cSPoul-Henning Kamp gp1->rank = m; 795dd84a43cSPoul-Henning Kamp gp2 = TAILQ_NEXT(gp1, geoms); 796dd84a43cSPoul-Henning Kamp 797dd84a43cSPoul-Henning Kamp /* got a rank, moving on */ 798dd84a43cSPoul-Henning Kamp if (m != 0) 799dd84a43cSPoul-Henning Kamp continue; 800dd84a43cSPoul-Henning Kamp 801dd84a43cSPoul-Henning Kamp /* no rank to original geom means loop */ 80250d866ceSPoul-Henning Kamp if (gp == gp1) 803dd84a43cSPoul-Henning Kamp return (ELOOP); 804dd84a43cSPoul-Henning Kamp 805dd84a43cSPoul-Henning Kamp /* no rank, put it at the end move on */ 806dd84a43cSPoul-Henning Kamp TAILQ_REMOVE(&geoms, gp1, geoms); 807dd84a43cSPoul-Henning Kamp TAILQ_INSERT_TAIL(&geoms, gp1, geoms); 808dd84a43cSPoul-Henning Kamp } 809dd84a43cSPoul-Henning Kamp return (0); 810dd84a43cSPoul-Henning Kamp } 811dd84a43cSPoul-Henning Kamp 812dd84a43cSPoul-Henning Kamp int 813dd84a43cSPoul-Henning Kamp g_attach(struct g_consumer *cp, struct g_provider *pp) 814dd84a43cSPoul-Henning Kamp { 815dd84a43cSPoul-Henning Kamp int error; 816dd84a43cSPoul-Henning Kamp 817dd84a43cSPoul-Henning Kamp g_topology_assert(); 8183d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 8193d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 820e5131ab4SPawel Jakub Dawidek g_trace(G_T_TOPOLOGY, "g_attach(%p, %p)", cp, pp); 821dd84a43cSPoul-Henning Kamp KASSERT(cp->provider == NULL, ("attach but attached")); 822dd84a43cSPoul-Henning Kamp cp->provider = pp; 823dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&pp->consumers, cp, consumers); 824dd84a43cSPoul-Henning Kamp error = redo_rank(cp->geom); 825dd84a43cSPoul-Henning Kamp if (error) { 826dd84a43cSPoul-Henning Kamp LIST_REMOVE(cp, consumers); 827dd84a43cSPoul-Henning Kamp cp->provider = NULL; 828dd84a43cSPoul-Henning Kamp redo_rank(cp->geom); 829dd84a43cSPoul-Henning Kamp } 830dd84a43cSPoul-Henning Kamp return (error); 831dd84a43cSPoul-Henning Kamp } 832dd84a43cSPoul-Henning Kamp 833dd84a43cSPoul-Henning Kamp void 834503abe45SPoul-Henning Kamp g_detach(struct g_consumer *cp) 835dd84a43cSPoul-Henning Kamp { 836dd84a43cSPoul-Henning Kamp struct g_provider *pp; 837dd84a43cSPoul-Henning Kamp 838dd84a43cSPoul-Henning Kamp g_topology_assert(); 8393d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 8403d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_detach(%p)", cp); 841503abe45SPoul-Henning Kamp KASSERT(cp->provider != NULL, ("detach but not attached")); 842503abe45SPoul-Henning Kamp KASSERT(cp->acr == 0, ("detach but nonzero acr")); 843503abe45SPoul-Henning Kamp KASSERT(cp->acw == 0, ("detach but nonzero acw")); 844503abe45SPoul-Henning Kamp KASSERT(cp->ace == 0, ("detach but nonzero ace")); 8450e6be472SPoul-Henning Kamp KASSERT(cp->nstart == cp->nend, 8464ec35300SPoul-Henning Kamp ("detach with active requests")); 847dd84a43cSPoul-Henning Kamp pp = cp->provider; 848dd84a43cSPoul-Henning Kamp LIST_REMOVE(cp, consumers); 849dd84a43cSPoul-Henning Kamp cp->provider = NULL; 85050199fa0SAlexander Motin if ((cp->geom->flags & G_GEOM_WITHER) || 85150199fa0SAlexander Motin (pp->geom->flags & G_GEOM_WITHER) || 85250199fa0SAlexander Motin (pp->flags & G_PF_WITHER)) 8531b464bd8SPoul-Henning Kamp g_do_wither(); 854dd84a43cSPoul-Henning Kamp redo_rank(cp->geom); 855dd84a43cSPoul-Henning Kamp } 856dd84a43cSPoul-Henning Kamp 857dd84a43cSPoul-Henning Kamp /* 858d2bae332SPoul-Henning Kamp * g_access() 859dd84a43cSPoul-Henning Kamp * 860dd84a43cSPoul-Henning Kamp * Access-check with delta values. The question asked is "can provider 861dd84a43cSPoul-Henning Kamp * "cp" change the access counters by the relative amounts dc[rwe] ?" 862dd84a43cSPoul-Henning Kamp */ 863dd84a43cSPoul-Henning Kamp 864dd84a43cSPoul-Henning Kamp int 865d2bae332SPoul-Henning Kamp g_access(struct g_consumer *cp, int dcr, int dcw, int dce) 866dd84a43cSPoul-Henning Kamp { 867dd84a43cSPoul-Henning Kamp struct g_provider *pp; 868dd84a43cSPoul-Henning Kamp int pr,pw,pe; 869dd84a43cSPoul-Henning Kamp int error; 870dd84a43cSPoul-Henning Kamp 8713d1d5bc3SPoul-Henning Kamp g_topology_assert(); 8723d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 873dd84a43cSPoul-Henning Kamp pp = cp->provider; 874950124e3SPawel Jakub Dawidek KASSERT(pp != NULL, ("access but not attached")); 8753d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 876dd84a43cSPoul-Henning Kamp 877d2bae332SPoul-Henning Kamp g_trace(G_T_ACCESS, "g_access(%p(%s), %d, %d, %d)", 878dd84a43cSPoul-Henning Kamp cp, pp->name, dcr, dcw, dce); 879dd84a43cSPoul-Henning Kamp 880dd84a43cSPoul-Henning Kamp KASSERT(cp->acr + dcr >= 0, ("access resulting in negative acr")); 881dd84a43cSPoul-Henning Kamp KASSERT(cp->acw + dcw >= 0, ("access resulting in negative acw")); 882dd84a43cSPoul-Henning Kamp KASSERT(cp->ace + dce >= 0, ("access resulting in negative ace")); 883cfa35456SPoul-Henning Kamp KASSERT(dcr != 0 || dcw != 0 || dce != 0, ("NOP access request")); 88407d77fc6SPoul-Henning Kamp KASSERT(pp->geom->access != NULL, ("NULL geom->access")); 885dd84a43cSPoul-Henning Kamp 886dd84a43cSPoul-Henning Kamp /* 887e805e8f0SPoul-Henning Kamp * If our class cares about being spoiled, and we have been, we 888dd84a43cSPoul-Henning Kamp * are probably just ahead of the event telling us that. Fail 889dd84a43cSPoul-Henning Kamp * now rather than having to unravel this later. 890dd84a43cSPoul-Henning Kamp */ 8913631c638SAlexander Motin if (cp->geom->spoiled != NULL && (cp->flags & G_CF_SPOILED) && 8924fa0290fSPoul-Henning Kamp (dcr > 0 || dcw > 0 || dce > 0)) 8934fa0290fSPoul-Henning Kamp return (ENXIO); 894dd84a43cSPoul-Henning Kamp 895dd84a43cSPoul-Henning Kamp /* 896dd84a43cSPoul-Henning Kamp * Figure out what counts the provider would have had, if this 897dd84a43cSPoul-Henning Kamp * consumer had (r0w0e0) at this time. 898dd84a43cSPoul-Henning Kamp */ 899dd84a43cSPoul-Henning Kamp pr = pp->acr - cp->acr; 900dd84a43cSPoul-Henning Kamp pw = pp->acw - cp->acw; 901dd84a43cSPoul-Henning Kamp pe = pp->ace - cp->ace; 902dd84a43cSPoul-Henning Kamp 903dd84a43cSPoul-Henning Kamp g_trace(G_T_ACCESS, 904dd84a43cSPoul-Henning Kamp "open delta:[r%dw%de%d] old:[r%dw%de%d] provider:[r%dw%de%d] %p(%s)", 905dd84a43cSPoul-Henning Kamp dcr, dcw, dce, 906dd84a43cSPoul-Henning Kamp cp->acr, cp->acw, cp->ace, 907dd84a43cSPoul-Henning Kamp pp->acr, pp->acw, pp->ace, 908dd84a43cSPoul-Henning Kamp pp, pp->name); 909dd84a43cSPoul-Henning Kamp 9108ebd558fSPoul-Henning Kamp /* If foot-shooting is enabled, any open on rank#1 is OK */ 9118ebd558fSPoul-Henning Kamp if ((g_debugflags & 16) && pp->geom->rank == 1) 9128ebd558fSPoul-Henning Kamp ; 913dd84a43cSPoul-Henning Kamp /* If we try exclusive but already write: fail */ 9148ebd558fSPoul-Henning Kamp else if (dce > 0 && pw > 0) 915dd84a43cSPoul-Henning Kamp return (EPERM); 916dd84a43cSPoul-Henning Kamp /* If we try write but already exclusive: fail */ 9178ebd558fSPoul-Henning Kamp else if (dcw > 0 && pe > 0) 918dd84a43cSPoul-Henning Kamp return (EPERM); 919dd84a43cSPoul-Henning Kamp /* If we try to open more but provider is error'ed: fail */ 920e5616d65SKenneth D. Merry else if ((dcr > 0 || dcw > 0 || dce > 0) && pp->error != 0) { 921*58d8f357SKonstantin Belousov printf("%s(%d): provider %s has error %d set\n", 922*58d8f357SKonstantin Belousov __func__, __LINE__, pp->name, pp->error); 923dd84a43cSPoul-Henning Kamp return (pp->error); 924e5616d65SKenneth D. Merry } 925dd84a43cSPoul-Henning Kamp 926dd84a43cSPoul-Henning Kamp /* Ok then... */ 927dd84a43cSPoul-Henning Kamp 9288f6da0e4SPoul-Henning Kamp error = pp->geom->access(pp, dcr, dcw, dce); 929bfc37a51SPoul-Henning Kamp KASSERT(dcr > 0 || dcw > 0 || dce > 0 || error == 0, 93087bc328dSBryan Drewery ("Geom provider %s::%s dcr=%d dcw=%d dce=%d error=%d failed " 93187bc328dSBryan Drewery "closing ->access()", pp->geom->class->name, pp->name, dcr, dcw, 93287bc328dSBryan Drewery dce, error)); 9338f6da0e4SPoul-Henning Kamp if (!error) { 934dd84a43cSPoul-Henning Kamp /* 935dd84a43cSPoul-Henning Kamp * If we open first write, spoil any partner consumers. 936a7e69e8bSJohn Polstra * If we close last write and provider is not errored, 937a7e69e8bSJohn Polstra * trigger re-taste. 938dd84a43cSPoul-Henning Kamp */ 939dd84a43cSPoul-Henning Kamp if (pp->acw == 0 && dcw != 0) 940dd84a43cSPoul-Henning Kamp g_spoil(pp, cp); 941a7e69e8bSJohn Polstra else if (pp->acw != 0 && pp->acw == -dcw && pp->error == 0 && 942a9ed5e11SPoul-Henning Kamp !(pp->geom->flags & G_GEOM_WITHER)) 9438cd1535aSPoul-Henning Kamp g_post_event(g_new_provider_event, pp, M_WAITOK, 9448cd1535aSPoul-Henning Kamp pp, NULL); 945dd84a43cSPoul-Henning Kamp 946dd84a43cSPoul-Henning Kamp pp->acr += dcr; 947dd84a43cSPoul-Henning Kamp pp->acw += dcw; 948dd84a43cSPoul-Henning Kamp pp->ace += dce; 949dd84a43cSPoul-Henning Kamp cp->acr += dcr; 950dd84a43cSPoul-Henning Kamp cp->acw += dcw; 951dd84a43cSPoul-Henning Kamp cp->ace += dce; 9525ae652c0SPoul-Henning Kamp if (pp->acr != 0 || pp->acw != 0 || pp->ace != 0) 9535ae652c0SPoul-Henning Kamp KASSERT(pp->sectorsize > 0, 9545ae652c0SPoul-Henning Kamp ("Provider %s lacks sectorsize", pp->name)); 95550199fa0SAlexander Motin if ((cp->geom->flags & G_GEOM_WITHER) && 95650199fa0SAlexander Motin cp->acr == 0 && cp->acw == 0 && cp->ace == 0) 95750199fa0SAlexander Motin g_do_wither(); 958dd84a43cSPoul-Henning Kamp } 959dd84a43cSPoul-Henning Kamp return (error); 960dd84a43cSPoul-Henning Kamp } 961dd84a43cSPoul-Henning Kamp 962dd84a43cSPoul-Henning Kamp int 9630f9d3dbaSPoul-Henning Kamp g_handleattr_int(struct bio *bp, const char *attribute, int val) 964dd84a43cSPoul-Henning Kamp { 965dd84a43cSPoul-Henning Kamp 966503abe45SPoul-Henning Kamp return (g_handleattr(bp, attribute, &val, sizeof val)); 967dd84a43cSPoul-Henning Kamp } 968dd84a43cSPoul-Henning Kamp 969dd84a43cSPoul-Henning Kamp int 970c28078e9SSteven Hartland g_handleattr_uint16_t(struct bio *bp, const char *attribute, uint16_t val) 971c28078e9SSteven Hartland { 972c28078e9SSteven Hartland 973c28078e9SSteven Hartland return (g_handleattr(bp, attribute, &val, sizeof val)); 974c28078e9SSteven Hartland } 975c28078e9SSteven Hartland 976c28078e9SSteven Hartland int 9770f9d3dbaSPoul-Henning Kamp g_handleattr_off_t(struct bio *bp, const char *attribute, off_t val) 978dd84a43cSPoul-Henning Kamp { 979dd84a43cSPoul-Henning Kamp 980503abe45SPoul-Henning Kamp return (g_handleattr(bp, attribute, &val, sizeof val)); 981dd84a43cSPoul-Henning Kamp } 982dd84a43cSPoul-Henning Kamp 983dd84a43cSPoul-Henning Kamp int 984709a6266SMarcel Moolenaar g_handleattr_str(struct bio *bp, const char *attribute, const char *str) 985d19dbf4aSPawel Jakub Dawidek { 986d19dbf4aSPawel Jakub Dawidek 987d19dbf4aSPawel Jakub Dawidek return (g_handleattr(bp, attribute, str, 0)); 988d19dbf4aSPawel Jakub Dawidek } 989d19dbf4aSPawel Jakub Dawidek 990d19dbf4aSPawel Jakub Dawidek int 991709a6266SMarcel Moolenaar g_handleattr(struct bio *bp, const char *attribute, const void *val, int len) 992dd84a43cSPoul-Henning Kamp { 993d19dbf4aSPawel Jakub Dawidek int error = 0; 994dd84a43cSPoul-Henning Kamp 995dd84a43cSPoul-Henning Kamp if (strcmp(bp->bio_attribute, attribute)) 996dd84a43cSPoul-Henning Kamp return (0); 997d19dbf4aSPawel Jakub Dawidek if (len == 0) { 998d19dbf4aSPawel Jakub Dawidek bzero(bp->bio_data, bp->bio_length); 999d19dbf4aSPawel Jakub Dawidek if (strlcpy(bp->bio_data, val, bp->bio_length) >= 1000d19dbf4aSPawel Jakub Dawidek bp->bio_length) { 1001d19dbf4aSPawel Jakub Dawidek printf("%s: %s bio_length %jd len %zu -> EFAULT\n", 1002d19dbf4aSPawel Jakub Dawidek __func__, bp->bio_to->name, 1003d19dbf4aSPawel Jakub Dawidek (intmax_t)bp->bio_length, strlen(val)); 1004dd84a43cSPoul-Henning Kamp error = EFAULT; 1005d19dbf4aSPawel Jakub Dawidek } 1006d19dbf4aSPawel Jakub Dawidek } else if (bp->bio_length == len) { 1007dd84a43cSPoul-Henning Kamp bcopy(val, bp->bio_data, len); 1008d19dbf4aSPawel Jakub Dawidek } else { 1009d19dbf4aSPawel Jakub Dawidek printf("%s: %s bio_length %jd len %d -> EFAULT\n", __func__, 1010d19dbf4aSPawel Jakub Dawidek bp->bio_to->name, (intmax_t)bp->bio_length, len); 1011d19dbf4aSPawel Jakub Dawidek error = EFAULT; 1012dd84a43cSPoul-Henning Kamp } 1013da3ee909SMarcel Moolenaar if (error == 0) 1014da3ee909SMarcel Moolenaar bp->bio_completed = bp->bio_length; 101572840432SPoul-Henning Kamp g_io_deliver(bp, error); 1016dd84a43cSPoul-Henning Kamp return (1); 1017dd84a43cSPoul-Henning Kamp } 1018dd84a43cSPoul-Henning Kamp 1019dd84a43cSPoul-Henning Kamp int 10203d1d5bc3SPoul-Henning Kamp g_std_access(struct g_provider *pp, 1021dd84a43cSPoul-Henning Kamp int dr __unused, int dw __unused, int de __unused) 1022dd84a43cSPoul-Henning Kamp { 1023dd84a43cSPoul-Henning Kamp 10243d1d5bc3SPoul-Henning Kamp g_topology_assert(); 10253d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 1026dd84a43cSPoul-Henning Kamp return (0); 1027dd84a43cSPoul-Henning Kamp } 1028dd84a43cSPoul-Henning Kamp 1029dd84a43cSPoul-Henning Kamp void 1030dd84a43cSPoul-Henning Kamp g_std_done(struct bio *bp) 1031dd84a43cSPoul-Henning Kamp { 1032dd84a43cSPoul-Henning Kamp struct bio *bp2; 1033dd84a43cSPoul-Henning Kamp 1034936cc461SPoul-Henning Kamp bp2 = bp->bio_parent; 10353f521b60SPoul-Henning Kamp if (bp2->bio_error == 0) 10363f521b60SPoul-Henning Kamp bp2->bio_error = bp->bio_error; 10373f521b60SPoul-Henning Kamp bp2->bio_completed += bp->bio_completed; 1038dd84a43cSPoul-Henning Kamp g_destroy_bio(bp); 1039801bb689SPoul-Henning Kamp bp2->bio_inbed++; 1040801bb689SPoul-Henning Kamp if (bp2->bio_children == bp2->bio_inbed) 10413f521b60SPoul-Henning Kamp g_io_deliver(bp2, bp2->bio_error); 1042dd84a43cSPoul-Henning Kamp } 1043dd84a43cSPoul-Henning Kamp 1044dd84a43cSPoul-Henning Kamp /* XXX: maybe this is only g_slice_spoiled */ 1045dd84a43cSPoul-Henning Kamp 1046dd84a43cSPoul-Henning Kamp void 1047dd84a43cSPoul-Henning Kamp g_std_spoiled(struct g_consumer *cp) 1048dd84a43cSPoul-Henning Kamp { 1049c4da4e46SPoul-Henning Kamp struct g_geom *gp; 1050c4da4e46SPoul-Henning Kamp struct g_provider *pp; 1051dd84a43cSPoul-Henning Kamp 1052dd84a43cSPoul-Henning Kamp g_topology_assert(); 10533d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 10543d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_std_spoiled(%p)", cp); 10553631c638SAlexander Motin cp->flags |= G_CF_ORPHAN; 1056c4da4e46SPoul-Henning Kamp g_detach(cp); 1057c4da4e46SPoul-Henning Kamp gp = cp->geom; 1058c4da4e46SPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) 1059c4da4e46SPoul-Henning Kamp g_orphan_provider(pp, ENXIO); 1060c4da4e46SPoul-Henning Kamp g_destroy_consumer(cp); 1061c4da4e46SPoul-Henning Kamp if (LIST_EMPTY(&gp->provider) && LIST_EMPTY(&gp->consumer)) 1062c4da4e46SPoul-Henning Kamp g_destroy_geom(gp); 1063c4da4e46SPoul-Henning Kamp else 1064c4da4e46SPoul-Henning Kamp gp->flags |= G_GEOM_WITHER; 1065dd84a43cSPoul-Henning Kamp } 1066dd84a43cSPoul-Henning Kamp 1067dd84a43cSPoul-Henning Kamp /* 1068dd84a43cSPoul-Henning Kamp * Spoiling happens when a provider is opened for writing, but consumers 1069dd84a43cSPoul-Henning Kamp * which are configured by in-band data are attached (slicers for instance). 1070dd84a43cSPoul-Henning Kamp * Since the write might potentially change the in-band data, such consumers 1071dd84a43cSPoul-Henning Kamp * need to re-evaluate their existence after the writing session closes. 1072dd84a43cSPoul-Henning Kamp * We do this by (offering to) tear them down when the open for write happens 1073dd84a43cSPoul-Henning Kamp * in return for a re-taste when it closes again. 1074dd84a43cSPoul-Henning Kamp * Together with the fact that such consumers grab an 'e' bit whenever they 1075dd84a43cSPoul-Henning Kamp * are open, regardless of mode, this ends up DTRT. 1076dd84a43cSPoul-Henning Kamp */ 1077dd84a43cSPoul-Henning Kamp 1078f2e9a094SPoul-Henning Kamp static void 1079f2e9a094SPoul-Henning Kamp g_spoil_event(void *arg, int flag) 1080f2e9a094SPoul-Henning Kamp { 1081f2e9a094SPoul-Henning Kamp struct g_provider *pp; 1082f2e9a094SPoul-Henning Kamp struct g_consumer *cp, *cp2; 1083f2e9a094SPoul-Henning Kamp 1084f2e9a094SPoul-Henning Kamp g_topology_assert(); 1085f2e9a094SPoul-Henning Kamp if (flag == EV_CANCEL) 1086f2e9a094SPoul-Henning Kamp return; 1087f2e9a094SPoul-Henning Kamp pp = arg; 10883d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 108917e0c433SAndrey V. Elsukov g_trace(G_T_TOPOLOGY, "%s %p(%s:%s:%s)", __func__, pp, 109017e0c433SAndrey V. Elsukov pp->geom->class->name, pp->geom->name, pp->name); 1091f2e9a094SPoul-Henning Kamp for (cp = LIST_FIRST(&pp->consumers); cp != NULL; cp = cp2) { 1092f2e9a094SPoul-Henning Kamp cp2 = LIST_NEXT(cp, consumers); 10933631c638SAlexander Motin if ((cp->flags & G_CF_SPOILED) == 0) 1094f2e9a094SPoul-Henning Kamp continue; 10953631c638SAlexander Motin cp->flags &= ~G_CF_SPOILED; 1096f2e9a094SPoul-Henning Kamp if (cp->geom->spoiled == NULL) 1097f2e9a094SPoul-Henning Kamp continue; 1098f2e9a094SPoul-Henning Kamp cp->geom->spoiled(cp); 1099f2e9a094SPoul-Henning Kamp g_topology_assert(); 1100f2e9a094SPoul-Henning Kamp } 1101f2e9a094SPoul-Henning Kamp } 1102f2e9a094SPoul-Henning Kamp 1103dd84a43cSPoul-Henning Kamp void 1104dd84a43cSPoul-Henning Kamp g_spoil(struct g_provider *pp, struct g_consumer *cp) 1105dd84a43cSPoul-Henning Kamp { 1106dd84a43cSPoul-Henning Kamp struct g_consumer *cp2; 1107dd84a43cSPoul-Henning Kamp 1108dd84a43cSPoul-Henning Kamp g_topology_assert(); 11093d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 11103d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 1111dd84a43cSPoul-Henning Kamp 1112dd84a43cSPoul-Henning Kamp LIST_FOREACH(cp2, &pp->consumers, consumers) { 1113dd84a43cSPoul-Henning Kamp if (cp2 == cp) 1114dd84a43cSPoul-Henning Kamp continue; 1115dd84a43cSPoul-Henning Kamp /* 1116dd84a43cSPoul-Henning Kamp KASSERT(cp2->acr == 0, ("spoiling cp->acr = %d", cp2->acr)); 1117dd84a43cSPoul-Henning Kamp KASSERT(cp2->acw == 0, ("spoiling cp->acw = %d", cp2->acw)); 1118dd84a43cSPoul-Henning Kamp */ 1119dd84a43cSPoul-Henning Kamp KASSERT(cp2->ace == 0, ("spoiling cp->ace = %d", cp2->ace)); 11203631c638SAlexander Motin cp2->flags |= G_CF_SPOILED; 1121dd84a43cSPoul-Henning Kamp } 11228cd1535aSPoul-Henning Kamp g_post_event(g_spoil_event, pp, M_WAITOK, pp, NULL); 1123dd84a43cSPoul-Henning Kamp } 1124dd84a43cSPoul-Henning Kamp 11253631c638SAlexander Motin static void 11263631c638SAlexander Motin g_media_changed_event(void *arg, int flag) 11273631c638SAlexander Motin { 11283631c638SAlexander Motin struct g_provider *pp; 11293631c638SAlexander Motin int retaste; 11303631c638SAlexander Motin 11313631c638SAlexander Motin g_topology_assert(); 11323631c638SAlexander Motin if (flag == EV_CANCEL) 11333631c638SAlexander Motin return; 11343631c638SAlexander Motin pp = arg; 11353631c638SAlexander Motin G_VALID_PROVIDER(pp); 11363631c638SAlexander Motin 11373631c638SAlexander Motin /* 11383631c638SAlexander Motin * If provider was not open for writing, queue retaste after spoiling. 11393631c638SAlexander Motin * If it was, retaste will happen automatically on close. 11403631c638SAlexander Motin */ 11413631c638SAlexander Motin retaste = (pp->acw == 0 && pp->error == 0 && 11423631c638SAlexander Motin !(pp->geom->flags & G_GEOM_WITHER)); 11433631c638SAlexander Motin g_spoil_event(arg, flag); 11443631c638SAlexander Motin if (retaste) 11453631c638SAlexander Motin g_post_event(g_new_provider_event, pp, M_WAITOK, pp, NULL); 11463631c638SAlexander Motin } 11473631c638SAlexander Motin 11483631c638SAlexander Motin int 11493631c638SAlexander Motin g_media_changed(struct g_provider *pp, int flag) 11503631c638SAlexander Motin { 11513631c638SAlexander Motin struct g_consumer *cp; 11523631c638SAlexander Motin 11533631c638SAlexander Motin LIST_FOREACH(cp, &pp->consumers, consumers) 11543631c638SAlexander Motin cp->flags |= G_CF_SPOILED; 11553631c638SAlexander Motin return (g_post_event(g_media_changed_event, pp, flag, pp, NULL)); 11563631c638SAlexander Motin } 11573631c638SAlexander Motin 11583631c638SAlexander Motin int 11593631c638SAlexander Motin g_media_gone(struct g_provider *pp, int flag) 11603631c638SAlexander Motin { 11613631c638SAlexander Motin struct g_consumer *cp; 11623631c638SAlexander Motin 11633631c638SAlexander Motin LIST_FOREACH(cp, &pp->consumers, consumers) 11643631c638SAlexander Motin cp->flags |= G_CF_SPOILED; 11653631c638SAlexander Motin return (g_post_event(g_spoil_event, pp, flag, pp, NULL)); 11663631c638SAlexander Motin } 11673631c638SAlexander Motin 1168a4ef1c5fSPoul-Henning Kamp int 1169a4ef1c5fSPoul-Henning Kamp g_getattr__(const char *attr, struct g_consumer *cp, void *var, int len) 1170a4ef1c5fSPoul-Henning Kamp { 1171a4ef1c5fSPoul-Henning Kamp int error, i; 1172a4ef1c5fSPoul-Henning Kamp 1173a4ef1c5fSPoul-Henning Kamp i = len; 1174a4ef1c5fSPoul-Henning Kamp error = g_io_getattr(attr, cp, &i, var); 1175a4ef1c5fSPoul-Henning Kamp if (error) 1176a4ef1c5fSPoul-Henning Kamp return (error); 1177a4ef1c5fSPoul-Henning Kamp if (i != len) 1178a4ef1c5fSPoul-Henning Kamp return (EINVAL); 1179a4ef1c5fSPoul-Henning Kamp return (0); 1180a4ef1c5fSPoul-Henning Kamp } 11817d590cc4SPoul-Henning Kamp 118290f2be24SAlexander Motin static int 118390f2be24SAlexander Motin g_get_device_prefix_len(const char *name) 118490f2be24SAlexander Motin { 118590f2be24SAlexander Motin int len; 118690f2be24SAlexander Motin 118790f2be24SAlexander Motin if (strncmp(name, "ada", 3) == 0) 118890f2be24SAlexander Motin len = 3; 118990f2be24SAlexander Motin else if (strncmp(name, "ad", 2) == 0) 119090f2be24SAlexander Motin len = 2; 119190f2be24SAlexander Motin else 119290f2be24SAlexander Motin return (0); 119390f2be24SAlexander Motin if (name[len] < '0' || name[len] > '9') 119490f2be24SAlexander Motin return (0); 119590f2be24SAlexander Motin do { 119690f2be24SAlexander Motin len++; 119790f2be24SAlexander Motin } while (name[len] >= '0' && name[len] <= '9'); 119890f2be24SAlexander Motin return (len); 119990f2be24SAlexander Motin } 120090f2be24SAlexander Motin 120190f2be24SAlexander Motin int 120290f2be24SAlexander Motin g_compare_names(const char *namea, const char *nameb) 120390f2be24SAlexander Motin { 120490f2be24SAlexander Motin int deva, devb; 120590f2be24SAlexander Motin 120690f2be24SAlexander Motin if (strcmp(namea, nameb) == 0) 120790f2be24SAlexander Motin return (1); 120890f2be24SAlexander Motin deva = g_get_device_prefix_len(namea); 120990f2be24SAlexander Motin if (deva == 0) 121090f2be24SAlexander Motin return (0); 121190f2be24SAlexander Motin devb = g_get_device_prefix_len(nameb); 121290f2be24SAlexander Motin if (devb == 0) 121390f2be24SAlexander Motin return (0); 121490f2be24SAlexander Motin if (strcmp(namea + deva, nameb + devb) == 0) 121590f2be24SAlexander Motin return (1); 121690f2be24SAlexander Motin return (0); 121790f2be24SAlexander Motin } 121890f2be24SAlexander Motin 1219c624eb25SWarner Losh void 1220c624eb25SWarner Losh g_geom_add_alias(struct g_geom *gp, const char *alias) 1221c624eb25SWarner Losh { 1222c624eb25SWarner Losh struct g_geom_alias *gap; 1223c624eb25SWarner Losh 1224c624eb25SWarner Losh gap = (struct g_geom_alias *)g_malloc( 1225c624eb25SWarner Losh sizeof(struct g_geom_alias) + strlen(alias) + 1, M_WAITOK); 1226c624eb25SWarner Losh strcpy((char *)(gap + 1), alias); 1227c624eb25SWarner Losh gap->ga_alias = (const char *)(gap + 1); 1228c624eb25SWarner Losh LIST_INSERT_HEAD(&gp->aliases, gap, ga_next); 1229c624eb25SWarner Losh } 1230c624eb25SWarner Losh 1231679f8b7eSPawel Jakub Dawidek #if defined(DIAGNOSTIC) || defined(DDB) 12327d590cc4SPoul-Henning Kamp /* 1233002d1d1cSJaakko Heinonen * This function walks the mesh and returns a non-zero integer if it 1234002d1d1cSJaakko Heinonen * finds the argument pointer is an object. The return value indicates 1235002d1d1cSJaakko Heinonen * which type of object it is believed to be. If topology is not locked, 1236002d1d1cSJaakko Heinonen * this function is potentially dangerous, but we don't assert that the 1237002d1d1cSJaakko Heinonen * topology lock is held when called from debugger. 1238b3ecca4dSPoul-Henning Kamp */ 12393d1d5bc3SPoul-Henning Kamp int 1240b3ecca4dSPoul-Henning Kamp g_valid_obj(void const *ptr) 1241b3ecca4dSPoul-Henning Kamp { 1242b3ecca4dSPoul-Henning Kamp struct g_class *mp; 1243b3ecca4dSPoul-Henning Kamp struct g_geom *gp; 1244b3ecca4dSPoul-Henning Kamp struct g_consumer *cp; 1245b3ecca4dSPoul-Henning Kamp struct g_provider *pp; 1246b3ecca4dSPoul-Henning Kamp 1247002d1d1cSJaakko Heinonen #ifdef KDB 1248002d1d1cSJaakko Heinonen if (kdb_active == 0) 1249002d1d1cSJaakko Heinonen #endif 12508edfe76aSEdward Tomasz Napierala g_topology_assert(); 12518edfe76aSEdward Tomasz Napierala 1252b3ecca4dSPoul-Henning Kamp LIST_FOREACH(mp, &g_classes, class) { 1253b3ecca4dSPoul-Henning Kamp if (ptr == mp) 1254b3ecca4dSPoul-Henning Kamp return (1); 1255b3ecca4dSPoul-Henning Kamp LIST_FOREACH(gp, &mp->geom, geom) { 1256b3ecca4dSPoul-Henning Kamp if (ptr == gp) 12573d1d5bc3SPoul-Henning Kamp return (2); 1258b3ecca4dSPoul-Henning Kamp LIST_FOREACH(cp, &gp->consumer, consumer) 1259b3ecca4dSPoul-Henning Kamp if (ptr == cp) 12603d1d5bc3SPoul-Henning Kamp return (3); 1261b3ecca4dSPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) 1262b3ecca4dSPoul-Henning Kamp if (ptr == pp) 12633d1d5bc3SPoul-Henning Kamp return (4); 1264b3ecca4dSPoul-Henning Kamp } 1265b3ecca4dSPoul-Henning Kamp } 1266b3ecca4dSPoul-Henning Kamp return(0); 1267b3ecca4dSPoul-Henning Kamp } 12683d1d5bc3SPoul-Henning Kamp #endif 1269679f8b7eSPawel Jakub Dawidek 1270679f8b7eSPawel Jakub Dawidek #ifdef DDB 1271679f8b7eSPawel Jakub Dawidek 1272679f8b7eSPawel Jakub Dawidek #define gprintf(...) do { \ 12736d66da20SUlf Lilleengen db_printf("%*s", indent, ""); \ 12746d66da20SUlf Lilleengen db_printf(__VA_ARGS__); \ 1275679f8b7eSPawel Jakub Dawidek } while (0) 1276679f8b7eSPawel Jakub Dawidek #define gprintln(...) do { \ 1277679f8b7eSPawel Jakub Dawidek gprintf(__VA_ARGS__); \ 12786d66da20SUlf Lilleengen db_printf("\n"); \ 1279679f8b7eSPawel Jakub Dawidek } while (0) 1280679f8b7eSPawel Jakub Dawidek 1281679f8b7eSPawel Jakub Dawidek #define ADDFLAG(obj, flag, sflag) do { \ 1282679f8b7eSPawel Jakub Dawidek if ((obj)->flags & (flag)) { \ 1283679f8b7eSPawel Jakub Dawidek if (comma) \ 1284679f8b7eSPawel Jakub Dawidek strlcat(str, ",", size); \ 1285679f8b7eSPawel Jakub Dawidek strlcat(str, (sflag), size); \ 1286679f8b7eSPawel Jakub Dawidek comma = 1; \ 1287679f8b7eSPawel Jakub Dawidek } \ 1288679f8b7eSPawel Jakub Dawidek } while (0) 1289679f8b7eSPawel Jakub Dawidek 1290679f8b7eSPawel Jakub Dawidek static char * 1291679f8b7eSPawel Jakub Dawidek provider_flags_to_string(struct g_provider *pp, char *str, size_t size) 1292679f8b7eSPawel Jakub Dawidek { 1293679f8b7eSPawel Jakub Dawidek int comma = 0; 1294679f8b7eSPawel Jakub Dawidek 1295679f8b7eSPawel Jakub Dawidek bzero(str, size); 1296679f8b7eSPawel Jakub Dawidek if (pp->flags == 0) { 1297679f8b7eSPawel Jakub Dawidek strlcpy(str, "NONE", size); 1298679f8b7eSPawel Jakub Dawidek return (str); 1299679f8b7eSPawel Jakub Dawidek } 1300679f8b7eSPawel Jakub Dawidek ADDFLAG(pp, G_PF_WITHER, "G_PF_WITHER"); 1301679f8b7eSPawel Jakub Dawidek ADDFLAG(pp, G_PF_ORPHAN, "G_PF_ORPHAN"); 1302679f8b7eSPawel Jakub Dawidek return (str); 1303679f8b7eSPawel Jakub Dawidek } 1304679f8b7eSPawel Jakub Dawidek 1305679f8b7eSPawel Jakub Dawidek static char * 1306679f8b7eSPawel Jakub Dawidek geom_flags_to_string(struct g_geom *gp, char *str, size_t size) 1307679f8b7eSPawel Jakub Dawidek { 1308679f8b7eSPawel Jakub Dawidek int comma = 0; 1309679f8b7eSPawel Jakub Dawidek 1310679f8b7eSPawel Jakub Dawidek bzero(str, size); 1311679f8b7eSPawel Jakub Dawidek if (gp->flags == 0) { 1312679f8b7eSPawel Jakub Dawidek strlcpy(str, "NONE", size); 1313679f8b7eSPawel Jakub Dawidek return (str); 1314679f8b7eSPawel Jakub Dawidek } 1315679f8b7eSPawel Jakub Dawidek ADDFLAG(gp, G_GEOM_WITHER, "G_GEOM_WITHER"); 1316679f8b7eSPawel Jakub Dawidek return (str); 1317679f8b7eSPawel Jakub Dawidek } 1318679f8b7eSPawel Jakub Dawidek static void 1319679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(int indent, struct g_consumer *cp) 1320679f8b7eSPawel Jakub Dawidek { 1321679f8b7eSPawel Jakub Dawidek 1322679f8b7eSPawel Jakub Dawidek if (indent == 0) { 1323679f8b7eSPawel Jakub Dawidek gprintln("consumer: %p", cp); 1324679f8b7eSPawel Jakub Dawidek gprintln(" class: %s (%p)", cp->geom->class->name, 1325679f8b7eSPawel Jakub Dawidek cp->geom->class); 1326679f8b7eSPawel Jakub Dawidek gprintln(" geom: %s (%p)", cp->geom->name, cp->geom); 1327679f8b7eSPawel Jakub Dawidek if (cp->provider == NULL) 1328679f8b7eSPawel Jakub Dawidek gprintln(" provider: none"); 1329679f8b7eSPawel Jakub Dawidek else { 1330679f8b7eSPawel Jakub Dawidek gprintln(" provider: %s (%p)", cp->provider->name, 1331679f8b7eSPawel Jakub Dawidek cp->provider); 1332679f8b7eSPawel Jakub Dawidek } 1333679f8b7eSPawel Jakub Dawidek gprintln(" access: r%dw%de%d", cp->acr, cp->acw, cp->ace); 13343631c638SAlexander Motin gprintln(" flags: 0x%04x", cp->flags); 1335679f8b7eSPawel Jakub Dawidek gprintln(" nstart: %u", cp->nstart); 1336679f8b7eSPawel Jakub Dawidek gprintln(" nend: %u", cp->nend); 1337679f8b7eSPawel Jakub Dawidek } else { 1338679f8b7eSPawel Jakub Dawidek gprintf("consumer: %p (%s), access=r%dw%de%d", cp, 1339679f8b7eSPawel Jakub Dawidek cp->provider != NULL ? cp->provider->name : "none", 1340679f8b7eSPawel Jakub Dawidek cp->acr, cp->acw, cp->ace); 13413631c638SAlexander Motin if (cp->flags) 13423631c638SAlexander Motin db_printf(", flags=0x%04x", cp->flags); 13436d66da20SUlf Lilleengen db_printf("\n"); 1344679f8b7eSPawel Jakub Dawidek } 1345679f8b7eSPawel Jakub Dawidek } 1346679f8b7eSPawel Jakub Dawidek 1347679f8b7eSPawel Jakub Dawidek static void 1348679f8b7eSPawel Jakub Dawidek db_show_geom_provider(int indent, struct g_provider *pp) 1349679f8b7eSPawel Jakub Dawidek { 1350679f8b7eSPawel Jakub Dawidek struct g_consumer *cp; 1351679f8b7eSPawel Jakub Dawidek char flags[64]; 1352679f8b7eSPawel Jakub Dawidek 1353679f8b7eSPawel Jakub Dawidek if (indent == 0) { 1354679f8b7eSPawel Jakub Dawidek gprintln("provider: %s (%p)", pp->name, pp); 1355679f8b7eSPawel Jakub Dawidek gprintln(" class: %s (%p)", pp->geom->class->name, 1356679f8b7eSPawel Jakub Dawidek pp->geom->class); 1357679f8b7eSPawel Jakub Dawidek gprintln(" geom: %s (%p)", pp->geom->name, pp->geom); 1358679f8b7eSPawel Jakub Dawidek gprintln(" mediasize: %jd", (intmax_t)pp->mediasize); 1359679f8b7eSPawel Jakub Dawidek gprintln(" sectorsize: %u", pp->sectorsize); 1360679f8b7eSPawel Jakub Dawidek gprintln(" stripesize: %u", pp->stripesize); 1361679f8b7eSPawel Jakub Dawidek gprintln(" stripeoffset: %u", pp->stripeoffset); 1362679f8b7eSPawel Jakub Dawidek gprintln(" access: r%dw%de%d", pp->acr, pp->acw, 1363679f8b7eSPawel Jakub Dawidek pp->ace); 1364679f8b7eSPawel Jakub Dawidek gprintln(" flags: %s (0x%04x)", 1365679f8b7eSPawel Jakub Dawidek provider_flags_to_string(pp, flags, sizeof(flags)), 1366679f8b7eSPawel Jakub Dawidek pp->flags); 1367679f8b7eSPawel Jakub Dawidek gprintln(" error: %d", pp->error); 1368679f8b7eSPawel Jakub Dawidek gprintln(" nstart: %u", pp->nstart); 1369679f8b7eSPawel Jakub Dawidek gprintln(" nend: %u", pp->nend); 1370679f8b7eSPawel Jakub Dawidek if (LIST_EMPTY(&pp->consumers)) 1371679f8b7eSPawel Jakub Dawidek gprintln(" consumers: none"); 1372679f8b7eSPawel Jakub Dawidek } else { 1373679f8b7eSPawel Jakub Dawidek gprintf("provider: %s (%p), access=r%dw%de%d", 1374679f8b7eSPawel Jakub Dawidek pp->name, pp, pp->acr, pp->acw, pp->ace); 1375679f8b7eSPawel Jakub Dawidek if (pp->flags != 0) { 13766d66da20SUlf Lilleengen db_printf(", flags=%s (0x%04x)", 1377679f8b7eSPawel Jakub Dawidek provider_flags_to_string(pp, flags, sizeof(flags)), 1378679f8b7eSPawel Jakub Dawidek pp->flags); 1379679f8b7eSPawel Jakub Dawidek } 13806d66da20SUlf Lilleengen db_printf("\n"); 1381679f8b7eSPawel Jakub Dawidek } 1382679f8b7eSPawel Jakub Dawidek if (!LIST_EMPTY(&pp->consumers)) { 1383f02642d7SPawel Jakub Dawidek LIST_FOREACH(cp, &pp->consumers, consumers) { 1384679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(indent + 2, cp); 1385f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1386f02642d7SPawel Jakub Dawidek break; 1387f02642d7SPawel Jakub Dawidek } 1388679f8b7eSPawel Jakub Dawidek } 1389679f8b7eSPawel Jakub Dawidek } 1390679f8b7eSPawel Jakub Dawidek 1391679f8b7eSPawel Jakub Dawidek static void 1392679f8b7eSPawel Jakub Dawidek db_show_geom_geom(int indent, struct g_geom *gp) 1393679f8b7eSPawel Jakub Dawidek { 1394679f8b7eSPawel Jakub Dawidek struct g_provider *pp; 1395679f8b7eSPawel Jakub Dawidek struct g_consumer *cp; 1396679f8b7eSPawel Jakub Dawidek char flags[64]; 1397679f8b7eSPawel Jakub Dawidek 1398679f8b7eSPawel Jakub Dawidek if (indent == 0) { 1399679f8b7eSPawel Jakub Dawidek gprintln("geom: %s (%p)", gp->name, gp); 1400679f8b7eSPawel Jakub Dawidek gprintln(" class: %s (%p)", gp->class->name, gp->class); 1401679f8b7eSPawel Jakub Dawidek gprintln(" flags: %s (0x%04x)", 1402679f8b7eSPawel Jakub Dawidek geom_flags_to_string(gp, flags, sizeof(flags)), gp->flags); 1403679f8b7eSPawel Jakub Dawidek gprintln(" rank: %d", gp->rank); 1404679f8b7eSPawel Jakub Dawidek if (LIST_EMPTY(&gp->provider)) 1405679f8b7eSPawel Jakub Dawidek gprintln(" providers: none"); 1406679f8b7eSPawel Jakub Dawidek if (LIST_EMPTY(&gp->consumer)) 1407679f8b7eSPawel Jakub Dawidek gprintln(" consumers: none"); 1408679f8b7eSPawel Jakub Dawidek } else { 1409679f8b7eSPawel Jakub Dawidek gprintf("geom: %s (%p), rank=%d", gp->name, gp, gp->rank); 1410679f8b7eSPawel Jakub Dawidek if (gp->flags != 0) { 14116d66da20SUlf Lilleengen db_printf(", flags=%s (0x%04x)", 1412679f8b7eSPawel Jakub Dawidek geom_flags_to_string(gp, flags, sizeof(flags)), 1413679f8b7eSPawel Jakub Dawidek gp->flags); 1414679f8b7eSPawel Jakub Dawidek } 14156d66da20SUlf Lilleengen db_printf("\n"); 1416679f8b7eSPawel Jakub Dawidek } 1417679f8b7eSPawel Jakub Dawidek if (!LIST_EMPTY(&gp->provider)) { 1418f02642d7SPawel Jakub Dawidek LIST_FOREACH(pp, &gp->provider, provider) { 1419679f8b7eSPawel Jakub Dawidek db_show_geom_provider(indent + 2, pp); 1420f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1421f02642d7SPawel Jakub Dawidek break; 1422f02642d7SPawel Jakub Dawidek } 1423679f8b7eSPawel Jakub Dawidek } 1424679f8b7eSPawel Jakub Dawidek if (!LIST_EMPTY(&gp->consumer)) { 1425f02642d7SPawel Jakub Dawidek LIST_FOREACH(cp, &gp->consumer, consumer) { 1426679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(indent + 2, cp); 1427f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1428f02642d7SPawel Jakub Dawidek break; 1429f02642d7SPawel Jakub Dawidek } 1430679f8b7eSPawel Jakub Dawidek } 1431679f8b7eSPawel Jakub Dawidek } 1432679f8b7eSPawel Jakub Dawidek 1433679f8b7eSPawel Jakub Dawidek static void 1434679f8b7eSPawel Jakub Dawidek db_show_geom_class(struct g_class *mp) 1435679f8b7eSPawel Jakub Dawidek { 1436679f8b7eSPawel Jakub Dawidek struct g_geom *gp; 1437679f8b7eSPawel Jakub Dawidek 14386d66da20SUlf Lilleengen db_printf("class: %s (%p)\n", mp->name, mp); 1439f02642d7SPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) { 1440679f8b7eSPawel Jakub Dawidek db_show_geom_geom(2, gp); 1441f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1442f02642d7SPawel Jakub Dawidek break; 1443f02642d7SPawel Jakub Dawidek } 1444679f8b7eSPawel Jakub Dawidek } 1445679f8b7eSPawel Jakub Dawidek 1446679f8b7eSPawel Jakub Dawidek /* 1447679f8b7eSPawel Jakub Dawidek * Print the GEOM topology or the given object. 1448679f8b7eSPawel Jakub Dawidek */ 1449679f8b7eSPawel Jakub Dawidek DB_SHOW_COMMAND(geom, db_show_geom) 1450679f8b7eSPawel Jakub Dawidek { 1451679f8b7eSPawel Jakub Dawidek struct g_class *mp; 1452679f8b7eSPawel Jakub Dawidek 1453679f8b7eSPawel Jakub Dawidek if (!have_addr) { 1454679f8b7eSPawel Jakub Dawidek /* No address given, print the entire topology. */ 1455679f8b7eSPawel Jakub Dawidek LIST_FOREACH(mp, &g_classes, class) { 1456679f8b7eSPawel Jakub Dawidek db_show_geom_class(mp); 14576d66da20SUlf Lilleengen db_printf("\n"); 1458f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1459f02642d7SPawel Jakub Dawidek break; 1460679f8b7eSPawel Jakub Dawidek } 1461679f8b7eSPawel Jakub Dawidek } else { 1462679f8b7eSPawel Jakub Dawidek switch (g_valid_obj((void *)addr)) { 1463679f8b7eSPawel Jakub Dawidek case 1: 1464679f8b7eSPawel Jakub Dawidek db_show_geom_class((struct g_class *)addr); 1465679f8b7eSPawel Jakub Dawidek break; 1466679f8b7eSPawel Jakub Dawidek case 2: 1467679f8b7eSPawel Jakub Dawidek db_show_geom_geom(0, (struct g_geom *)addr); 1468679f8b7eSPawel Jakub Dawidek break; 1469679f8b7eSPawel Jakub Dawidek case 3: 1470679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(0, (struct g_consumer *)addr); 1471679f8b7eSPawel Jakub Dawidek break; 1472679f8b7eSPawel Jakub Dawidek case 4: 1473679f8b7eSPawel Jakub Dawidek db_show_geom_provider(0, (struct g_provider *)addr); 1474679f8b7eSPawel Jakub Dawidek break; 1475679f8b7eSPawel Jakub Dawidek default: 14766d66da20SUlf Lilleengen db_printf("Not a GEOM object.\n"); 1477679f8b7eSPawel Jakub Dawidek break; 1478679f8b7eSPawel Jakub Dawidek } 1479679f8b7eSPawel Jakub Dawidek } 1480679f8b7eSPawel Jakub Dawidek } 1481679f8b7eSPawel Jakub Dawidek 1482bf7d2c17SUlf Lilleengen static void 1483bf7d2c17SUlf Lilleengen db_print_bio_cmd(struct bio *bp) 1484bf7d2c17SUlf Lilleengen { 14856d66da20SUlf Lilleengen db_printf(" cmd: "); 1486bf7d2c17SUlf Lilleengen switch (bp->bio_cmd) { 14876d66da20SUlf Lilleengen case BIO_READ: db_printf("BIO_READ"); break; 14886d66da20SUlf Lilleengen case BIO_WRITE: db_printf("BIO_WRITE"); break; 14896d66da20SUlf Lilleengen case BIO_DELETE: db_printf("BIO_DELETE"); break; 14906d66da20SUlf Lilleengen case BIO_GETATTR: db_printf("BIO_GETATTR"); break; 14916d66da20SUlf Lilleengen case BIO_FLUSH: db_printf("BIO_FLUSH"); break; 14926d66da20SUlf Lilleengen case BIO_CMD0: db_printf("BIO_CMD0"); break; 14936d66da20SUlf Lilleengen case BIO_CMD1: db_printf("BIO_CMD1"); break; 14946d66da20SUlf Lilleengen case BIO_CMD2: db_printf("BIO_CMD2"); break; 14959a6844d5SKenneth D. Merry case BIO_ZONE: db_printf("BIO_ZONE"); break; 14966d66da20SUlf Lilleengen default: db_printf("UNKNOWN"); break; 1497bf7d2c17SUlf Lilleengen } 14986d66da20SUlf Lilleengen db_printf("\n"); 1499bf7d2c17SUlf Lilleengen } 1500bf7d2c17SUlf Lilleengen 1501bf7d2c17SUlf Lilleengen static void 1502bf7d2c17SUlf Lilleengen db_print_bio_flags(struct bio *bp) 1503bf7d2c17SUlf Lilleengen { 1504bf7d2c17SUlf Lilleengen int comma; 1505bf7d2c17SUlf Lilleengen 1506bf7d2c17SUlf Lilleengen comma = 0; 15076d66da20SUlf Lilleengen db_printf(" flags: "); 1508bf7d2c17SUlf Lilleengen if (bp->bio_flags & BIO_ERROR) { 15096d66da20SUlf Lilleengen db_printf("BIO_ERROR"); 1510bf7d2c17SUlf Lilleengen comma = 1; 1511bf7d2c17SUlf Lilleengen } 1512bf7d2c17SUlf Lilleengen if (bp->bio_flags & BIO_DONE) { 15136d66da20SUlf Lilleengen db_printf("%sBIO_DONE", (comma ? ", " : "")); 1514bf7d2c17SUlf Lilleengen comma = 1; 1515bf7d2c17SUlf Lilleengen } 1516bf7d2c17SUlf Lilleengen if (bp->bio_flags & BIO_ONQUEUE) 15176d66da20SUlf Lilleengen db_printf("%sBIO_ONQUEUE", (comma ? ", " : "")); 15186d66da20SUlf Lilleengen db_printf("\n"); 1519bf7d2c17SUlf Lilleengen } 1520bf7d2c17SUlf Lilleengen 1521bf7d2c17SUlf Lilleengen /* 1522bf7d2c17SUlf Lilleengen * Print useful information in a BIO 1523bf7d2c17SUlf Lilleengen */ 1524bf7d2c17SUlf Lilleengen DB_SHOW_COMMAND(bio, db_show_bio) 1525bf7d2c17SUlf Lilleengen { 1526bf7d2c17SUlf Lilleengen struct bio *bp; 1527bf7d2c17SUlf Lilleengen 1528bf7d2c17SUlf Lilleengen if (have_addr) { 1529bf7d2c17SUlf Lilleengen bp = (struct bio *)addr; 15306d66da20SUlf Lilleengen db_printf("BIO %p\n", bp); 1531bf7d2c17SUlf Lilleengen db_print_bio_cmd(bp); 1532bf7d2c17SUlf Lilleengen db_print_bio_flags(bp); 15339a8fa125SWarner Losh db_printf(" cflags: 0x%hx\n", bp->bio_cflags); 15349a8fa125SWarner Losh db_printf(" pflags: 0x%hx\n", bp->bio_pflags); 15354147dd02SUlf Lilleengen db_printf(" offset: %jd\n", (intmax_t)bp->bio_offset); 15364147dd02SUlf Lilleengen db_printf(" length: %jd\n", (intmax_t)bp->bio_length); 15376d66da20SUlf Lilleengen db_printf(" bcount: %ld\n", bp->bio_bcount); 15386d66da20SUlf Lilleengen db_printf(" resid: %ld\n", bp->bio_resid); 15394147dd02SUlf Lilleengen db_printf(" completed: %jd\n", (intmax_t)bp->bio_completed); 15406d66da20SUlf Lilleengen db_printf(" children: %u\n", bp->bio_children); 15416d66da20SUlf Lilleengen db_printf(" inbed: %u\n", bp->bio_inbed); 15426d66da20SUlf Lilleengen db_printf(" error: %d\n", bp->bio_error); 15436d66da20SUlf Lilleengen db_printf(" parent: %p\n", bp->bio_parent); 15446d66da20SUlf Lilleengen db_printf(" driver1: %p\n", bp->bio_driver1); 15456d66da20SUlf Lilleengen db_printf(" driver2: %p\n", bp->bio_driver2); 15466d66da20SUlf Lilleengen db_printf(" caller1: %p\n", bp->bio_caller1); 15476d66da20SUlf Lilleengen db_printf(" caller2: %p\n", bp->bio_caller2); 15486d66da20SUlf Lilleengen db_printf(" bio_from: %p\n", bp->bio_from); 15496d66da20SUlf Lilleengen db_printf(" bio_to: %p\n", bp->bio_to); 15508532d381SConrad Meyer 15518532d381SConrad Meyer #if defined(BUF_TRACKING) || defined(FULL_BUF_TRACKING) 15528532d381SConrad Meyer db_printf(" bio_track_bp: %p\n", bp->bio_track_bp); 15538532d381SConrad Meyer #endif 1554bf7d2c17SUlf Lilleengen } 1555bf7d2c17SUlf Lilleengen } 1556bf7d2c17SUlf Lilleengen 1557679f8b7eSPawel Jakub Dawidek #undef gprintf 1558679f8b7eSPawel Jakub Dawidek #undef gprintln 1559679f8b7eSPawel Jakub Dawidek #undef ADDFLAG 1560679f8b7eSPawel Jakub Dawidek 1561679f8b7eSPawel Jakub Dawidek #endif /* DDB */ 1562