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 DROP_GIANT(); 2519061251fSJaakko Heinonen error = g_unload_class(mp); 2529061251fSJaakko Heinonen PICKUP_GIANT(); 2531f75de94SPoul-Henning Kamp if (error == 0) { 2549061251fSJaakko Heinonen KASSERT(LIST_EMPTY(&mp->geom), 2559061251fSJaakko Heinonen ("Unloaded class (%s) still has geom", mp->name)); 2561f75de94SPoul-Henning Kamp } 257f5b34814SPoul-Henning Kamp break; 2586c87f8d5SPoul-Henning Kamp } 2596c87f8d5SPoul-Henning Kamp return (error); 260dd84a43cSPoul-Henning Kamp } 261dd84a43cSPoul-Henning Kamp 2628a8fcb00SMarcel Moolenaar static void 2638a8fcb00SMarcel Moolenaar g_retaste_event(void *arg, int flag) 2648a8fcb00SMarcel Moolenaar { 2653631c638SAlexander Motin struct g_class *mp, *mp2; 2663631c638SAlexander Motin struct g_geom *gp; 2678a8fcb00SMarcel Moolenaar struct g_hh00 *hh; 2688a8fcb00SMarcel Moolenaar struct g_provider *pp; 2693631c638SAlexander Motin struct g_consumer *cp; 2708a8fcb00SMarcel Moolenaar 2718a8fcb00SMarcel Moolenaar g_topology_assert(); 2728a8fcb00SMarcel Moolenaar if (flag == EV_CANCEL) /* XXX: can't happen ? */ 2738a8fcb00SMarcel Moolenaar return; 2748a8fcb00SMarcel Moolenaar if (g_shutdown) 2758a8fcb00SMarcel Moolenaar return; 2768a8fcb00SMarcel Moolenaar 2778a8fcb00SMarcel Moolenaar hh = arg; 2788a8fcb00SMarcel Moolenaar mp = hh->mp; 2798a8fcb00SMarcel Moolenaar hh->error = 0; 2808a8fcb00SMarcel Moolenaar if (hh->post) { 2818a8fcb00SMarcel Moolenaar g_free(hh); 2828a8fcb00SMarcel Moolenaar hh = NULL; 2838a8fcb00SMarcel Moolenaar } 2848a8fcb00SMarcel Moolenaar g_trace(G_T_TOPOLOGY, "g_retaste(%s)", mp->name); 2858a8fcb00SMarcel Moolenaar 2863631c638SAlexander Motin LIST_FOREACH(mp2, &g_classes, class) { 2873631c638SAlexander Motin LIST_FOREACH(gp, &mp2->geom, geom) { 2888a8fcb00SMarcel Moolenaar LIST_FOREACH(pp, &gp->provider, provider) { 2898a8fcb00SMarcel Moolenaar if (pp->acr || pp->acw || pp->ace) 2908a8fcb00SMarcel Moolenaar continue; 2913631c638SAlexander Motin LIST_FOREACH(cp, &pp->consumers, consumers) { 2923631c638SAlexander Motin if (cp->geom->class == mp && 2933631c638SAlexander Motin (cp->flags & G_CF_ORPHAN) == 0) 294856744baSMarcel Moolenaar break; 295856744baSMarcel Moolenaar } 2963631c638SAlexander Motin if (cp != NULL) { 2973631c638SAlexander Motin cp->flags |= G_CF_ORPHAN; 2983631c638SAlexander Motin g_wither_geom(cp->geom, ENXIO); 2993631c638SAlexander Motin } 3008a8fcb00SMarcel Moolenaar mp->taste(mp, pp, 0); 3018a8fcb00SMarcel Moolenaar g_topology_assert(); 3028a8fcb00SMarcel Moolenaar } 3038a8fcb00SMarcel Moolenaar } 3048a8fcb00SMarcel Moolenaar } 3058a8fcb00SMarcel Moolenaar } 3068a8fcb00SMarcel Moolenaar 3078a8fcb00SMarcel Moolenaar int 3088a8fcb00SMarcel Moolenaar g_retaste(struct g_class *mp) 3098a8fcb00SMarcel Moolenaar { 3108a8fcb00SMarcel Moolenaar struct g_hh00 *hh; 3118a8fcb00SMarcel Moolenaar int error; 3128a8fcb00SMarcel Moolenaar 3138a8fcb00SMarcel Moolenaar if (mp->taste == NULL) 3148a8fcb00SMarcel Moolenaar return (EINVAL); 3158a8fcb00SMarcel Moolenaar 3168a8fcb00SMarcel Moolenaar hh = g_malloc(sizeof *hh, M_WAITOK | M_ZERO); 3178a8fcb00SMarcel Moolenaar hh->mp = mp; 3188a8fcb00SMarcel Moolenaar 3198a8fcb00SMarcel Moolenaar if (cold) { 3208a8fcb00SMarcel Moolenaar hh->post = 1; 3218a8fcb00SMarcel Moolenaar error = g_post_event(g_retaste_event, hh, M_WAITOK, NULL); 3228a8fcb00SMarcel Moolenaar } else { 3238a8fcb00SMarcel Moolenaar error = g_waitfor_event(g_retaste_event, hh, M_WAITOK, NULL); 3248a8fcb00SMarcel Moolenaar if (error == 0) 3258a8fcb00SMarcel Moolenaar error = hh->error; 3268a8fcb00SMarcel Moolenaar g_free(hh); 3278a8fcb00SMarcel Moolenaar } 3288a8fcb00SMarcel Moolenaar 3298a8fcb00SMarcel Moolenaar return (error); 3308a8fcb00SMarcel Moolenaar } 3318a8fcb00SMarcel Moolenaar 332dd84a43cSPoul-Henning Kamp struct g_geom * 3330f9d3dbaSPoul-Henning Kamp g_new_geomf(struct g_class *mp, const char *fmt, ...) 334dd84a43cSPoul-Henning Kamp { 335dd84a43cSPoul-Henning Kamp struct g_geom *gp; 336dd84a43cSPoul-Henning Kamp va_list ap; 337dd84a43cSPoul-Henning Kamp struct sbuf *sb; 338dd84a43cSPoul-Henning Kamp 339dd84a43cSPoul-Henning Kamp g_topology_assert(); 3403d1d5bc3SPoul-Henning Kamp G_VALID_CLASS(mp); 3412616144eSDag-Erling Smørgrav sb = sbuf_new_auto(); 342a1a9b445SPoul-Henning Kamp va_start(ap, fmt); 343dd84a43cSPoul-Henning Kamp sbuf_vprintf(sb, fmt, ap); 344a1a9b445SPoul-Henning Kamp va_end(ap); 345dd84a43cSPoul-Henning Kamp sbuf_finish(sb); 346a163d034SWarner Losh gp = g_malloc(sizeof *gp, M_WAITOK | M_ZERO); 347a163d034SWarner Losh gp->name = g_malloc(sbuf_len(sb) + 1, M_WAITOK | M_ZERO); 348e805e8f0SPoul-Henning Kamp gp->class = mp; 349dd84a43cSPoul-Henning Kamp gp->rank = 1; 350dd84a43cSPoul-Henning Kamp LIST_INIT(&gp->consumer); 351dd84a43cSPoul-Henning Kamp LIST_INIT(&gp->provider); 352dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&mp->geom, gp, geom); 353dd84a43cSPoul-Henning Kamp TAILQ_INSERT_HEAD(&geoms, gp, geoms); 354dd84a43cSPoul-Henning Kamp strcpy(gp->name, sbuf_data(sb)); 355dd84a43cSPoul-Henning Kamp sbuf_delete(sb); 356dd66958eSPoul-Henning Kamp /* Fill in defaults from class */ 357dd66958eSPoul-Henning Kamp gp->start = mp->start; 358dd66958eSPoul-Henning Kamp gp->spoiled = mp->spoiled; 359416494d7SJustin T. Gibbs gp->attrchanged = mp->attrchanged; 360c3fb2891SKenneth D. Merry gp->providergone = mp->providergone; 361dd66958eSPoul-Henning Kamp gp->dumpconf = mp->dumpconf; 362dd66958eSPoul-Henning Kamp gp->access = mp->access; 363dd66958eSPoul-Henning Kamp gp->orphan = mp->orphan; 364dd66958eSPoul-Henning Kamp gp->ioctl = mp->ioctl; 365245899ccSEdward Tomasz Napierala gp->resize = mp->resize; 366dd84a43cSPoul-Henning Kamp return (gp); 367dd84a43cSPoul-Henning Kamp } 368dd84a43cSPoul-Henning Kamp 369dd84a43cSPoul-Henning Kamp void 370dd84a43cSPoul-Henning Kamp g_destroy_geom(struct g_geom *gp) 371dd84a43cSPoul-Henning Kamp { 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); 3857d590cc4SPoul-Henning Kamp g_free(gp->name); 386dd84a43cSPoul-Henning Kamp g_free(gp); 387dd84a43cSPoul-Henning Kamp } 388dd84a43cSPoul-Henning Kamp 389d6227ae7SPoul-Henning Kamp /* 390fa13e9bbSUlf Lilleengen * This function is called (repeatedly) until the geom has withered away. 391d6227ae7SPoul-Henning Kamp */ 392d6227ae7SPoul-Henning Kamp void 393d6227ae7SPoul-Henning Kamp g_wither_geom(struct g_geom *gp, int error) 394d6227ae7SPoul-Henning Kamp { 3951b464bd8SPoul-Henning Kamp struct g_provider *pp; 396d6227ae7SPoul-Henning Kamp 3973d1d5bc3SPoul-Henning Kamp g_topology_assert(); 3983d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 399d6227ae7SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_wither_geom(%p(%s))", gp, gp->name); 400d6227ae7SPoul-Henning Kamp if (!(gp->flags & G_GEOM_WITHER)) { 401d6227ae7SPoul-Henning Kamp gp->flags |= G_GEOM_WITHER; 402d6227ae7SPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) 403b07ef6c2SPoul-Henning Kamp if (!(pp->flags & G_PF_ORPHAN)) 404d6227ae7SPoul-Henning Kamp g_orphan_provider(pp, error); 405d6227ae7SPoul-Henning Kamp } 4061b464bd8SPoul-Henning Kamp g_do_wither(); 407d6227ae7SPoul-Henning Kamp } 4081b464bd8SPoul-Henning Kamp 4091b464bd8SPoul-Henning Kamp /* 410d99c1559SMarcel Moolenaar * Convenience function to destroy a particular provider. 411d99c1559SMarcel Moolenaar */ 412d99c1559SMarcel Moolenaar void 413d99c1559SMarcel Moolenaar g_wither_provider(struct g_provider *pp, int error) 414d99c1559SMarcel Moolenaar { 415d99c1559SMarcel Moolenaar 416d99c1559SMarcel Moolenaar pp->flags |= G_PF_WITHER; 417d99c1559SMarcel Moolenaar if (!(pp->flags & G_PF_ORPHAN)) 418d99c1559SMarcel Moolenaar g_orphan_provider(pp, error); 419d99c1559SMarcel Moolenaar } 420d99c1559SMarcel Moolenaar 421d99c1559SMarcel Moolenaar /* 422725419afSPoul-Henning Kamp * This function is called (repeatedly) until the has withered away. 423725419afSPoul-Henning Kamp */ 424725419afSPoul-Henning Kamp void 425725419afSPoul-Henning Kamp g_wither_geom_close(struct g_geom *gp, int error) 426725419afSPoul-Henning Kamp { 427725419afSPoul-Henning Kamp struct g_consumer *cp; 428725419afSPoul-Henning Kamp 429725419afSPoul-Henning Kamp g_topology_assert(); 430725419afSPoul-Henning Kamp G_VALID_GEOM(gp); 431725419afSPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_wither_geom_close(%p(%s))", gp, gp->name); 432725419afSPoul-Henning Kamp LIST_FOREACH(cp, &gp->consumer, consumer) 433725419afSPoul-Henning Kamp if (cp->acr || cp->acw || cp->ace) 434725419afSPoul-Henning Kamp g_access(cp, -cp->acr, -cp->acw, -cp->ace); 435725419afSPoul-Henning Kamp g_wither_geom(gp, error); 436725419afSPoul-Henning Kamp } 437725419afSPoul-Henning Kamp 438725419afSPoul-Henning Kamp /* 4391b464bd8SPoul-Henning Kamp * This function is called (repeatedly) until we cant wash away more 4401b464bd8SPoul-Henning Kamp * withered bits at present. Return value contains two bits. Bit 0 4411b464bd8SPoul-Henning Kamp * set means "withering stuff we can't wash now", bit 1 means "call 4421b464bd8SPoul-Henning Kamp * me again, there may be stuff I didn't get the first time around. 4431b464bd8SPoul-Henning Kamp */ 4441b464bd8SPoul-Henning Kamp int 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 int result; 4521b464bd8SPoul-Henning Kamp 4531b464bd8SPoul-Henning Kamp result = 0; 4541b464bd8SPoul-Henning Kamp g_topology_assert(); 4551b464bd8SPoul-Henning Kamp LIST_FOREACH(mp, &g_classes, class) { 4561b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(gp, &mp->geom, geom, gp2) { 4571b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(pp, &gp->provider, provider, pp2) { 4581b464bd8SPoul-Henning Kamp if (!(pp->flags & G_PF_WITHER)) 459d6227ae7SPoul-Henning Kamp continue; 4601b464bd8SPoul-Henning Kamp if (LIST_EMPTY(&pp->consumers)) 4611b464bd8SPoul-Henning Kamp g_destroy_provider(pp); 4621b464bd8SPoul-Henning Kamp else 4631b464bd8SPoul-Henning Kamp result |= 1; 4641b464bd8SPoul-Henning Kamp } 4651b464bd8SPoul-Henning Kamp if (!(gp->flags & G_GEOM_WITHER)) 4661b464bd8SPoul-Henning Kamp continue; 4671b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(pp, &gp->provider, provider, pp2) { 4681b464bd8SPoul-Henning Kamp if (LIST_EMPTY(&pp->consumers)) 4691b464bd8SPoul-Henning Kamp g_destroy_provider(pp); 4701b464bd8SPoul-Henning Kamp else 4711b464bd8SPoul-Henning Kamp result |= 1; 4721b464bd8SPoul-Henning Kamp } 4731b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(cp, &gp->consumer, consumer, cp2) { 4741b464bd8SPoul-Henning Kamp if (cp->acr || cp->acw || cp->ace) { 4751b464bd8SPoul-Henning Kamp result |= 1; 4761b464bd8SPoul-Henning Kamp continue; 4771b464bd8SPoul-Henning Kamp } 478539bec40SPoul-Henning Kamp if (cp->provider != NULL) 479d6227ae7SPoul-Henning Kamp g_detach(cp); 480d6227ae7SPoul-Henning Kamp g_destroy_consumer(cp); 4811b464bd8SPoul-Henning Kamp result |= 2; 482d6227ae7SPoul-Henning Kamp } 4831b464bd8SPoul-Henning Kamp if (LIST_EMPTY(&gp->provider) && 4841b464bd8SPoul-Henning Kamp LIST_EMPTY(&gp->consumer)) 485d6227ae7SPoul-Henning Kamp g_destroy_geom(gp); 4861b464bd8SPoul-Henning Kamp else 4871b464bd8SPoul-Henning Kamp result |= 1; 4881b464bd8SPoul-Henning Kamp } 4891b464bd8SPoul-Henning Kamp } 4901b464bd8SPoul-Henning Kamp return (result); 491d6227ae7SPoul-Henning Kamp } 492d6227ae7SPoul-Henning Kamp 493dd84a43cSPoul-Henning Kamp struct g_consumer * 494dd84a43cSPoul-Henning Kamp g_new_consumer(struct g_geom *gp) 495dd84a43cSPoul-Henning Kamp { 496dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 497dd84a43cSPoul-Henning Kamp 498dd84a43cSPoul-Henning Kamp g_topology_assert(); 4993d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 500799426f8SPoul-Henning Kamp KASSERT(!(gp->flags & G_GEOM_WITHER), 501799426f8SPoul-Henning Kamp ("g_new_consumer on WITHERing geom(%s) (class %s)", 502799426f8SPoul-Henning Kamp gp->name, gp->class->name)); 50307d77fc6SPoul-Henning Kamp KASSERT(gp->orphan != NULL, 50407d77fc6SPoul-Henning Kamp ("g_new_consumer on geom(%s) (class %s) without orphan", 50507d77fc6SPoul-Henning Kamp gp->name, gp->class->name)); 506dd84a43cSPoul-Henning Kamp 507a163d034SWarner Losh cp = g_malloc(sizeof *cp, M_WAITOK | M_ZERO); 508dd84a43cSPoul-Henning Kamp cp->geom = gp; 509e24cbd90SPoul-Henning Kamp cp->stat = devstat_new_entry(cp, -1, 0, DEVSTAT_ALL_SUPPORTED, 510e24cbd90SPoul-Henning Kamp DEVSTAT_TYPE_DIRECT, DEVSTAT_PRIORITY_MAX); 511dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&gp->consumer, cp, consumer); 512dd84a43cSPoul-Henning Kamp return(cp); 513dd84a43cSPoul-Henning Kamp } 514dd84a43cSPoul-Henning Kamp 515dd84a43cSPoul-Henning Kamp void 516dd84a43cSPoul-Henning Kamp g_destroy_consumer(struct g_consumer *cp) 517dd84a43cSPoul-Henning Kamp { 518d6227ae7SPoul-Henning Kamp struct g_geom *gp; 519dd84a43cSPoul-Henning Kamp 520dd84a43cSPoul-Henning Kamp g_topology_assert(); 5213d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 5223d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_destroy_consumer(%p)", cp); 523dd84a43cSPoul-Henning Kamp KASSERT (cp->provider == NULL, ("g_destroy_consumer but attached")); 524dd84a43cSPoul-Henning Kamp KASSERT (cp->acr == 0, ("g_destroy_consumer with acr")); 525dd84a43cSPoul-Henning Kamp KASSERT (cp->acw == 0, ("g_destroy_consumer with acw")); 526dd84a43cSPoul-Henning Kamp KASSERT (cp->ace == 0, ("g_destroy_consumer with ace")); 527afcbcfaeSPoul-Henning Kamp g_cancel_event(cp); 528d6227ae7SPoul-Henning Kamp gp = cp->geom; 529dd84a43cSPoul-Henning Kamp LIST_REMOVE(cp, consumer); 530e24cbd90SPoul-Henning Kamp devstat_remove_entry(cp->stat); 531dd84a43cSPoul-Henning Kamp g_free(cp); 532d6227ae7SPoul-Henning Kamp if (gp->flags & G_GEOM_WITHER) 5331b464bd8SPoul-Henning Kamp g_do_wither(); 534dd84a43cSPoul-Henning Kamp } 535dd84a43cSPoul-Henning Kamp 5369ab3ea78SPoul-Henning Kamp static void 5379ab3ea78SPoul-Henning Kamp g_new_provider_event(void *arg, int flag) 5389ab3ea78SPoul-Henning Kamp { 5399ab3ea78SPoul-Henning Kamp struct g_class *mp; 5409ab3ea78SPoul-Henning Kamp struct g_provider *pp; 5413631c638SAlexander Motin struct g_consumer *cp, *next_cp; 5429ab3ea78SPoul-Henning Kamp 5439ab3ea78SPoul-Henning Kamp g_topology_assert(); 5449ab3ea78SPoul-Henning Kamp if (flag == EV_CANCEL) 5459ab3ea78SPoul-Henning Kamp return; 5469ab3ea78SPoul-Henning Kamp if (g_shutdown) 5479ab3ea78SPoul-Henning Kamp return; 5489ab3ea78SPoul-Henning Kamp pp = arg; 5493d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 5509097a8e6SPawel Jakub Dawidek KASSERT(!(pp->flags & G_PF_WITHER), 5519097a8e6SPawel Jakub Dawidek ("g_new_provider_event but withered")); 5523631c638SAlexander Motin LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, next_cp) { 5533631c638SAlexander Motin if ((cp->flags & G_CF_ORPHAN) == 0 && 5543631c638SAlexander Motin cp->geom->attrchanged != NULL) 5553631c638SAlexander Motin cp->geom->attrchanged(cp, "GEOM::media"); 5563631c638SAlexander Motin } 5579ab3ea78SPoul-Henning Kamp LIST_FOREACH(mp, &g_classes, class) { 5589ab3ea78SPoul-Henning Kamp if (mp->taste == NULL) 5599ab3ea78SPoul-Henning Kamp continue; 5609ab3ea78SPoul-Henning Kamp LIST_FOREACH(cp, &pp->consumers, consumers) 5613631c638SAlexander Motin if (cp->geom->class == mp && 5623631c638SAlexander Motin (cp->flags & G_CF_ORPHAN) == 0) 563cb9b72ceSPawel Jakub Dawidek break; 564cb9b72ceSPawel Jakub Dawidek if (cp != NULL) 5659ab3ea78SPoul-Henning Kamp continue; 566c4da4e46SPoul-Henning Kamp mp->taste(mp, pp, 0); 5679ab3ea78SPoul-Henning Kamp g_topology_assert(); 5689ab3ea78SPoul-Henning Kamp } 5699ab3ea78SPoul-Henning Kamp } 5709ab3ea78SPoul-Henning Kamp 5719ab3ea78SPoul-Henning Kamp 572dd84a43cSPoul-Henning Kamp struct g_provider * 5730f9d3dbaSPoul-Henning Kamp g_new_providerf(struct g_geom *gp, const char *fmt, ...) 574dd84a43cSPoul-Henning Kamp { 575dd84a43cSPoul-Henning Kamp struct g_provider *pp; 576dd84a43cSPoul-Henning Kamp struct sbuf *sb; 577dd84a43cSPoul-Henning Kamp va_list ap; 578dd84a43cSPoul-Henning Kamp 579dd84a43cSPoul-Henning Kamp g_topology_assert(); 5803d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 581e26bafdcSPoul-Henning Kamp KASSERT(gp->access != NULL, 582e26bafdcSPoul-Henning Kamp ("new provider on geom(%s) without ->access (class %s)", 583e26bafdcSPoul-Henning Kamp gp->name, gp->class->name)); 584799426f8SPoul-Henning Kamp KASSERT(gp->start != NULL, 585cff2ddaeSPawel Jakub Dawidek ("new provider on geom(%s) without ->start (class %s)", 586cff2ddaeSPawel Jakub Dawidek gp->name, gp->class->name)); 587799426f8SPoul-Henning Kamp KASSERT(!(gp->flags & G_GEOM_WITHER), 588cff2ddaeSPawel Jakub Dawidek ("new provider on WITHERing geom(%s) (class %s)", 589cff2ddaeSPawel Jakub Dawidek gp->name, gp->class->name)); 5902616144eSDag-Erling Smørgrav sb = sbuf_new_auto(); 591a1a9b445SPoul-Henning Kamp va_start(ap, fmt); 592dd84a43cSPoul-Henning Kamp sbuf_vprintf(sb, fmt, ap); 593a1a9b445SPoul-Henning Kamp va_end(ap); 594dd84a43cSPoul-Henning Kamp sbuf_finish(sb); 595a163d034SWarner Losh pp = g_malloc(sizeof *pp + sbuf_len(sb) + 1, M_WAITOK | M_ZERO); 596dd84a43cSPoul-Henning Kamp pp->name = (char *)(pp + 1); 597dd84a43cSPoul-Henning Kamp strcpy(pp->name, sbuf_data(sb)); 598dd84a43cSPoul-Henning Kamp sbuf_delete(sb); 599dd84a43cSPoul-Henning Kamp LIST_INIT(&pp->consumers); 600dd84a43cSPoul-Henning Kamp pp->error = ENXIO; 601dd84a43cSPoul-Henning Kamp pp->geom = gp; 602e24cbd90SPoul-Henning Kamp pp->stat = devstat_new_entry(pp, -1, 0, DEVSTAT_ALL_SUPPORTED, 603e24cbd90SPoul-Henning Kamp DEVSTAT_TYPE_DIRECT, DEVSTAT_PRIORITY_MAX); 604dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&gp->provider, pp, provider); 605e26bafdcSPoul-Henning Kamp g_post_event(g_new_provider_event, pp, M_WAITOK, pp, gp, NULL); 606dd84a43cSPoul-Henning Kamp return (pp); 607dd84a43cSPoul-Henning Kamp } 608dd84a43cSPoul-Henning Kamp 609dd84a43cSPoul-Henning Kamp void 610dd84a43cSPoul-Henning Kamp g_error_provider(struct g_provider *pp, int error) 611dd84a43cSPoul-Henning Kamp { 612dd84a43cSPoul-Henning Kamp 6133d1d5bc3SPoul-Henning Kamp /* G_VALID_PROVIDER(pp); We may not have g_topology */ 614dd84a43cSPoul-Henning Kamp pp->error = error; 615dd84a43cSPoul-Henning Kamp } 616dd84a43cSPoul-Henning Kamp 617245899ccSEdward Tomasz Napierala static void 618245899ccSEdward Tomasz Napierala g_resize_provider_event(void *arg, int flag) 619245899ccSEdward Tomasz Napierala { 620245899ccSEdward Tomasz Napierala struct g_hh00 *hh; 621245899ccSEdward Tomasz Napierala struct g_class *mp; 622245899ccSEdward Tomasz Napierala struct g_geom *gp; 623245899ccSEdward Tomasz Napierala struct g_provider *pp; 624245899ccSEdward Tomasz Napierala struct g_consumer *cp, *cp2; 625245899ccSEdward Tomasz Napierala off_t size; 626245899ccSEdward Tomasz Napierala 627245899ccSEdward Tomasz Napierala g_topology_assert(); 628245899ccSEdward Tomasz Napierala if (g_shutdown) 629245899ccSEdward Tomasz Napierala return; 630245899ccSEdward Tomasz Napierala 631245899ccSEdward Tomasz Napierala hh = arg; 632245899ccSEdward Tomasz Napierala pp = hh->pp; 633245899ccSEdward Tomasz Napierala size = hh->size; 6343a3ef28eSEdward Tomasz Napierala g_free(hh); 635245899ccSEdward Tomasz Napierala 636245899ccSEdward Tomasz Napierala G_VALID_PROVIDER(pp); 637245899ccSEdward Tomasz Napierala g_trace(G_T_TOPOLOGY, "g_resize_provider_event(%p)", pp); 638245899ccSEdward Tomasz Napierala 639245899ccSEdward Tomasz Napierala LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, cp2) { 640245899ccSEdward Tomasz Napierala gp = cp->geom; 6413631c638SAlexander Motin if (gp->resize == NULL && size < pp->mediasize) { 6423631c638SAlexander Motin cp->flags |= G_CF_ORPHAN; 643245899ccSEdward Tomasz Napierala cp->geom->orphan(cp); 644245899ccSEdward Tomasz Napierala } 6453631c638SAlexander Motin } 646245899ccSEdward Tomasz Napierala 647245899ccSEdward Tomasz Napierala pp->mediasize = size; 648245899ccSEdward Tomasz Napierala 649245899ccSEdward Tomasz Napierala LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, cp2) { 650245899ccSEdward Tomasz Napierala gp = cp->geom; 651245899ccSEdward Tomasz Napierala if (gp->resize != NULL) 652245899ccSEdward Tomasz Napierala gp->resize(cp); 653245899ccSEdward Tomasz Napierala } 654245899ccSEdward Tomasz Napierala 655245899ccSEdward Tomasz Napierala /* 656245899ccSEdward Tomasz Napierala * After resizing, the previously invalid GEOM class metadata 657245899ccSEdward Tomasz Napierala * might become valid. This means we should retaste. 658245899ccSEdward Tomasz Napierala */ 659245899ccSEdward Tomasz Napierala LIST_FOREACH(mp, &g_classes, class) { 660245899ccSEdward Tomasz Napierala if (mp->taste == NULL) 661245899ccSEdward Tomasz Napierala continue; 662245899ccSEdward Tomasz Napierala LIST_FOREACH(cp, &pp->consumers, consumers) 6633631c638SAlexander Motin if (cp->geom->class == mp && 6643631c638SAlexander Motin (cp->flags & G_CF_ORPHAN) == 0) 665245899ccSEdward Tomasz Napierala break; 666245899ccSEdward Tomasz Napierala if (cp != NULL) 667245899ccSEdward Tomasz Napierala continue; 668245899ccSEdward Tomasz Napierala mp->taste(mp, pp, 0); 669245899ccSEdward Tomasz Napierala g_topology_assert(); 670245899ccSEdward Tomasz Napierala } 671245899ccSEdward Tomasz Napierala } 672245899ccSEdward Tomasz Napierala 673245899ccSEdward Tomasz Napierala void 674245899ccSEdward Tomasz Napierala g_resize_provider(struct g_provider *pp, off_t size) 675245899ccSEdward Tomasz Napierala { 676245899ccSEdward Tomasz Napierala struct g_hh00 *hh; 677245899ccSEdward Tomasz Napierala 678245899ccSEdward Tomasz Napierala G_VALID_PROVIDER(pp); 679245899ccSEdward Tomasz Napierala 680245899ccSEdward Tomasz Napierala if (size == pp->mediasize) 681245899ccSEdward Tomasz Napierala return; 682245899ccSEdward Tomasz Napierala 683245899ccSEdward Tomasz Napierala hh = g_malloc(sizeof *hh, M_WAITOK | M_ZERO); 684245899ccSEdward Tomasz Napierala hh->pp = pp; 685245899ccSEdward Tomasz Napierala hh->size = size; 686245899ccSEdward Tomasz Napierala g_post_event(g_resize_provider_event, hh, M_WAITOK, NULL); 687245899ccSEdward Tomasz Napierala } 688245899ccSEdward Tomasz Napierala 689*769afdc7SPawel Jakub Dawidek #ifndef _PATH_DEV 690*769afdc7SPawel Jakub Dawidek #define _PATH_DEV "/dev/" 691*769afdc7SPawel Jakub Dawidek #endif 692*769afdc7SPawel Jakub Dawidek 693d6c5e716SPoul-Henning Kamp struct g_provider * 694d6c5e716SPoul-Henning Kamp g_provider_by_name(char const *arg) 695d6c5e716SPoul-Henning Kamp { 696d6c5e716SPoul-Henning Kamp struct g_class *cp; 697d6c5e716SPoul-Henning Kamp struct g_geom *gp; 698d6c5e716SPoul-Henning Kamp struct g_provider *pp; 699d6c5e716SPoul-Henning Kamp 700*769afdc7SPawel Jakub Dawidek if (strncmp(arg, _PATH_DEV, sizeof(_PATH_DEV) - 1) == 0) 701*769afdc7SPawel Jakub Dawidek arg += sizeof(_PATH_DEV) - 1; 702*769afdc7SPawel Jakub Dawidek 703d6c5e716SPoul-Henning Kamp LIST_FOREACH(cp, &g_classes, class) { 704d6c5e716SPoul-Henning Kamp LIST_FOREACH(gp, &cp->geom, geom) { 705d6c5e716SPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) { 706d6c5e716SPoul-Henning Kamp if (!strcmp(arg, pp->name)) 707d6c5e716SPoul-Henning Kamp return (pp); 708d6c5e716SPoul-Henning Kamp } 709d6c5e716SPoul-Henning Kamp } 710d6c5e716SPoul-Henning Kamp } 711*769afdc7SPawel Jakub Dawidek 712d6c5e716SPoul-Henning Kamp return (NULL); 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; 850dd84a43cSPoul-Henning Kamp if (pp->geom->flags & G_GEOM_WITHER) 8511b464bd8SPoul-Henning Kamp g_do_wither(); 85290916ef7SPoul-Henning Kamp else if (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 */ 9208ebd558fSPoul-Henning Kamp else if ((dcr > 0 || dcw > 0 || dce > 0) && pp->error != 0) 921dd84a43cSPoul-Henning Kamp return (pp->error); 922dd84a43cSPoul-Henning Kamp 923dd84a43cSPoul-Henning Kamp /* Ok then... */ 924dd84a43cSPoul-Henning Kamp 9258f6da0e4SPoul-Henning Kamp error = pp->geom->access(pp, dcr, dcw, dce); 926bfc37a51SPoul-Henning Kamp KASSERT(dcr > 0 || dcw > 0 || dce > 0 || error == 0, 927bfc37a51SPoul-Henning Kamp ("Geom provider %s::%s failed closing ->access()", 928bfc37a51SPoul-Henning Kamp pp->geom->class->name, pp->name)); 9298f6da0e4SPoul-Henning Kamp if (!error) { 930dd84a43cSPoul-Henning Kamp /* 931dd84a43cSPoul-Henning Kamp * If we open first write, spoil any partner consumers. 932a7e69e8bSJohn Polstra * If we close last write and provider is not errored, 933a7e69e8bSJohn Polstra * trigger re-taste. 934dd84a43cSPoul-Henning Kamp */ 935dd84a43cSPoul-Henning Kamp if (pp->acw == 0 && dcw != 0) 936dd84a43cSPoul-Henning Kamp g_spoil(pp, cp); 937a7e69e8bSJohn Polstra else if (pp->acw != 0 && pp->acw == -dcw && pp->error == 0 && 938a9ed5e11SPoul-Henning Kamp !(pp->geom->flags & G_GEOM_WITHER)) 9398cd1535aSPoul-Henning Kamp g_post_event(g_new_provider_event, pp, M_WAITOK, 9408cd1535aSPoul-Henning Kamp pp, NULL); 941dd84a43cSPoul-Henning Kamp 942dd84a43cSPoul-Henning Kamp pp->acr += dcr; 943dd84a43cSPoul-Henning Kamp pp->acw += dcw; 944dd84a43cSPoul-Henning Kamp pp->ace += dce; 945dd84a43cSPoul-Henning Kamp cp->acr += dcr; 946dd84a43cSPoul-Henning Kamp cp->acw += dcw; 947dd84a43cSPoul-Henning Kamp cp->ace += dce; 9485ae652c0SPoul-Henning Kamp if (pp->acr != 0 || pp->acw != 0 || pp->ace != 0) 9495ae652c0SPoul-Henning Kamp KASSERT(pp->sectorsize > 0, 9505ae652c0SPoul-Henning Kamp ("Provider %s lacks sectorsize", pp->name)); 951dd84a43cSPoul-Henning Kamp } 952dd84a43cSPoul-Henning Kamp return (error); 953dd84a43cSPoul-Henning Kamp } 954dd84a43cSPoul-Henning Kamp 955dd84a43cSPoul-Henning Kamp int 9560f9d3dbaSPoul-Henning Kamp g_handleattr_int(struct bio *bp, const char *attribute, int val) 957dd84a43cSPoul-Henning Kamp { 958dd84a43cSPoul-Henning Kamp 959503abe45SPoul-Henning Kamp return (g_handleattr(bp, attribute, &val, sizeof val)); 960dd84a43cSPoul-Henning Kamp } 961dd84a43cSPoul-Henning Kamp 962dd84a43cSPoul-Henning Kamp int 9630f9d3dbaSPoul-Henning Kamp g_handleattr_off_t(struct bio *bp, const char *attribute, off_t 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 970709a6266SMarcel Moolenaar g_handleattr_str(struct bio *bp, const char *attribute, const char *str) 971d19dbf4aSPawel Jakub Dawidek { 972d19dbf4aSPawel Jakub Dawidek 973d19dbf4aSPawel Jakub Dawidek return (g_handleattr(bp, attribute, str, 0)); 974d19dbf4aSPawel Jakub Dawidek } 975d19dbf4aSPawel Jakub Dawidek 976d19dbf4aSPawel Jakub Dawidek int 977709a6266SMarcel Moolenaar g_handleattr(struct bio *bp, const char *attribute, const void *val, int len) 978dd84a43cSPoul-Henning Kamp { 979d19dbf4aSPawel Jakub Dawidek int error = 0; 980dd84a43cSPoul-Henning Kamp 981dd84a43cSPoul-Henning Kamp if (strcmp(bp->bio_attribute, attribute)) 982dd84a43cSPoul-Henning Kamp return (0); 983d19dbf4aSPawel Jakub Dawidek if (len == 0) { 984d19dbf4aSPawel Jakub Dawidek bzero(bp->bio_data, bp->bio_length); 985d19dbf4aSPawel Jakub Dawidek if (strlcpy(bp->bio_data, val, bp->bio_length) >= 986d19dbf4aSPawel Jakub Dawidek bp->bio_length) { 987d19dbf4aSPawel Jakub Dawidek printf("%s: %s bio_length %jd len %zu -> EFAULT\n", 988d19dbf4aSPawel Jakub Dawidek __func__, bp->bio_to->name, 989d19dbf4aSPawel Jakub Dawidek (intmax_t)bp->bio_length, strlen(val)); 990dd84a43cSPoul-Henning Kamp error = EFAULT; 991d19dbf4aSPawel Jakub Dawidek } 992d19dbf4aSPawel Jakub Dawidek } else if (bp->bio_length == len) { 993dd84a43cSPoul-Henning Kamp bcopy(val, bp->bio_data, len); 994d19dbf4aSPawel Jakub Dawidek } else { 995d19dbf4aSPawel Jakub Dawidek printf("%s: %s bio_length %jd len %d -> EFAULT\n", __func__, 996d19dbf4aSPawel Jakub Dawidek bp->bio_to->name, (intmax_t)bp->bio_length, len); 997d19dbf4aSPawel Jakub Dawidek error = EFAULT; 998dd84a43cSPoul-Henning Kamp } 999da3ee909SMarcel Moolenaar if (error == 0) 1000da3ee909SMarcel Moolenaar bp->bio_completed = bp->bio_length; 100172840432SPoul-Henning Kamp g_io_deliver(bp, error); 1002dd84a43cSPoul-Henning Kamp return (1); 1003dd84a43cSPoul-Henning Kamp } 1004dd84a43cSPoul-Henning Kamp 1005dd84a43cSPoul-Henning Kamp int 10063d1d5bc3SPoul-Henning Kamp g_std_access(struct g_provider *pp, 1007dd84a43cSPoul-Henning Kamp int dr __unused, int dw __unused, int de __unused) 1008dd84a43cSPoul-Henning Kamp { 1009dd84a43cSPoul-Henning Kamp 10103d1d5bc3SPoul-Henning Kamp g_topology_assert(); 10113d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 1012dd84a43cSPoul-Henning Kamp return (0); 1013dd84a43cSPoul-Henning Kamp } 1014dd84a43cSPoul-Henning Kamp 1015dd84a43cSPoul-Henning Kamp void 1016dd84a43cSPoul-Henning Kamp g_std_done(struct bio *bp) 1017dd84a43cSPoul-Henning Kamp { 1018dd84a43cSPoul-Henning Kamp struct bio *bp2; 1019dd84a43cSPoul-Henning Kamp 1020936cc461SPoul-Henning Kamp bp2 = bp->bio_parent; 10213f521b60SPoul-Henning Kamp if (bp2->bio_error == 0) 10223f521b60SPoul-Henning Kamp bp2->bio_error = bp->bio_error; 10233f521b60SPoul-Henning Kamp bp2->bio_completed += bp->bio_completed; 1024dd84a43cSPoul-Henning Kamp g_destroy_bio(bp); 1025801bb689SPoul-Henning Kamp bp2->bio_inbed++; 1026801bb689SPoul-Henning Kamp if (bp2->bio_children == bp2->bio_inbed) 10273f521b60SPoul-Henning Kamp g_io_deliver(bp2, bp2->bio_error); 1028dd84a43cSPoul-Henning Kamp } 1029dd84a43cSPoul-Henning Kamp 1030dd84a43cSPoul-Henning Kamp /* XXX: maybe this is only g_slice_spoiled */ 1031dd84a43cSPoul-Henning Kamp 1032dd84a43cSPoul-Henning Kamp void 1033dd84a43cSPoul-Henning Kamp g_std_spoiled(struct g_consumer *cp) 1034dd84a43cSPoul-Henning Kamp { 1035c4da4e46SPoul-Henning Kamp struct g_geom *gp; 1036c4da4e46SPoul-Henning Kamp struct g_provider *pp; 1037dd84a43cSPoul-Henning Kamp 1038dd84a43cSPoul-Henning Kamp g_topology_assert(); 10393d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 10403d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_std_spoiled(%p)", cp); 10413631c638SAlexander Motin cp->flags |= G_CF_ORPHAN; 1042c4da4e46SPoul-Henning Kamp g_detach(cp); 1043c4da4e46SPoul-Henning Kamp gp = cp->geom; 1044c4da4e46SPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) 1045c4da4e46SPoul-Henning Kamp g_orphan_provider(pp, ENXIO); 1046c4da4e46SPoul-Henning Kamp g_destroy_consumer(cp); 1047c4da4e46SPoul-Henning Kamp if (LIST_EMPTY(&gp->provider) && LIST_EMPTY(&gp->consumer)) 1048c4da4e46SPoul-Henning Kamp g_destroy_geom(gp); 1049c4da4e46SPoul-Henning Kamp else 1050c4da4e46SPoul-Henning Kamp gp->flags |= G_GEOM_WITHER; 1051dd84a43cSPoul-Henning Kamp } 1052dd84a43cSPoul-Henning Kamp 1053dd84a43cSPoul-Henning Kamp /* 1054dd84a43cSPoul-Henning Kamp * Spoiling happens when a provider is opened for writing, but consumers 1055dd84a43cSPoul-Henning Kamp * which are configured by in-band data are attached (slicers for instance). 1056dd84a43cSPoul-Henning Kamp * Since the write might potentially change the in-band data, such consumers 1057dd84a43cSPoul-Henning Kamp * need to re-evaluate their existence after the writing session closes. 1058dd84a43cSPoul-Henning Kamp * We do this by (offering to) tear them down when the open for write happens 1059dd84a43cSPoul-Henning Kamp * in return for a re-taste when it closes again. 1060dd84a43cSPoul-Henning Kamp * Together with the fact that such consumers grab an 'e' bit whenever they 1061dd84a43cSPoul-Henning Kamp * are open, regardless of mode, this ends up DTRT. 1062dd84a43cSPoul-Henning Kamp */ 1063dd84a43cSPoul-Henning Kamp 1064f2e9a094SPoul-Henning Kamp static void 1065f2e9a094SPoul-Henning Kamp g_spoil_event(void *arg, int flag) 1066f2e9a094SPoul-Henning Kamp { 1067f2e9a094SPoul-Henning Kamp struct g_provider *pp; 1068f2e9a094SPoul-Henning Kamp struct g_consumer *cp, *cp2; 1069f2e9a094SPoul-Henning Kamp 1070f2e9a094SPoul-Henning Kamp g_topology_assert(); 1071f2e9a094SPoul-Henning Kamp if (flag == EV_CANCEL) 1072f2e9a094SPoul-Henning Kamp return; 1073f2e9a094SPoul-Henning Kamp pp = arg; 10743d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 1075f2e9a094SPoul-Henning Kamp for (cp = LIST_FIRST(&pp->consumers); cp != NULL; cp = cp2) { 1076f2e9a094SPoul-Henning Kamp cp2 = LIST_NEXT(cp, consumers); 10773631c638SAlexander Motin if ((cp->flags & G_CF_SPOILED) == 0) 1078f2e9a094SPoul-Henning Kamp continue; 10793631c638SAlexander Motin cp->flags &= ~G_CF_SPOILED; 1080f2e9a094SPoul-Henning Kamp if (cp->geom->spoiled == NULL) 1081f2e9a094SPoul-Henning Kamp continue; 1082f2e9a094SPoul-Henning Kamp cp->geom->spoiled(cp); 1083f2e9a094SPoul-Henning Kamp g_topology_assert(); 1084f2e9a094SPoul-Henning Kamp } 1085f2e9a094SPoul-Henning Kamp } 1086f2e9a094SPoul-Henning Kamp 1087dd84a43cSPoul-Henning Kamp void 1088dd84a43cSPoul-Henning Kamp g_spoil(struct g_provider *pp, struct g_consumer *cp) 1089dd84a43cSPoul-Henning Kamp { 1090dd84a43cSPoul-Henning Kamp struct g_consumer *cp2; 1091dd84a43cSPoul-Henning Kamp 1092dd84a43cSPoul-Henning Kamp g_topology_assert(); 10933d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 10943d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 1095dd84a43cSPoul-Henning Kamp 1096dd84a43cSPoul-Henning Kamp LIST_FOREACH(cp2, &pp->consumers, consumers) { 1097dd84a43cSPoul-Henning Kamp if (cp2 == cp) 1098dd84a43cSPoul-Henning Kamp continue; 1099dd84a43cSPoul-Henning Kamp /* 1100dd84a43cSPoul-Henning Kamp KASSERT(cp2->acr == 0, ("spoiling cp->acr = %d", cp2->acr)); 1101dd84a43cSPoul-Henning Kamp KASSERT(cp2->acw == 0, ("spoiling cp->acw = %d", cp2->acw)); 1102dd84a43cSPoul-Henning Kamp */ 1103dd84a43cSPoul-Henning Kamp KASSERT(cp2->ace == 0, ("spoiling cp->ace = %d", cp2->ace)); 11043631c638SAlexander Motin cp2->flags |= G_CF_SPOILED; 1105dd84a43cSPoul-Henning Kamp } 11068cd1535aSPoul-Henning Kamp g_post_event(g_spoil_event, pp, M_WAITOK, pp, NULL); 1107dd84a43cSPoul-Henning Kamp } 1108dd84a43cSPoul-Henning Kamp 11093631c638SAlexander Motin static void 11103631c638SAlexander Motin g_media_changed_event(void *arg, int flag) 11113631c638SAlexander Motin { 11123631c638SAlexander Motin struct g_provider *pp; 11133631c638SAlexander Motin int retaste; 11143631c638SAlexander Motin 11153631c638SAlexander Motin g_topology_assert(); 11163631c638SAlexander Motin if (flag == EV_CANCEL) 11173631c638SAlexander Motin return; 11183631c638SAlexander Motin pp = arg; 11193631c638SAlexander Motin G_VALID_PROVIDER(pp); 11203631c638SAlexander Motin 11213631c638SAlexander Motin /* 11223631c638SAlexander Motin * If provider was not open for writing, queue retaste after spoiling. 11233631c638SAlexander Motin * If it was, retaste will happen automatically on close. 11243631c638SAlexander Motin */ 11253631c638SAlexander Motin retaste = (pp->acw == 0 && pp->error == 0 && 11263631c638SAlexander Motin !(pp->geom->flags & G_GEOM_WITHER)); 11273631c638SAlexander Motin g_spoil_event(arg, flag); 11283631c638SAlexander Motin if (retaste) 11293631c638SAlexander Motin g_post_event(g_new_provider_event, pp, M_WAITOK, pp, NULL); 11303631c638SAlexander Motin } 11313631c638SAlexander Motin 11323631c638SAlexander Motin int 11333631c638SAlexander Motin g_media_changed(struct g_provider *pp, int flag) 11343631c638SAlexander Motin { 11353631c638SAlexander Motin struct g_consumer *cp; 11363631c638SAlexander Motin 11373631c638SAlexander Motin LIST_FOREACH(cp, &pp->consumers, consumers) 11383631c638SAlexander Motin cp->flags |= G_CF_SPOILED; 11393631c638SAlexander Motin return (g_post_event(g_media_changed_event, pp, flag, pp, NULL)); 11403631c638SAlexander Motin } 11413631c638SAlexander Motin 11423631c638SAlexander Motin int 11433631c638SAlexander Motin g_media_gone(struct g_provider *pp, int flag) 11443631c638SAlexander Motin { 11453631c638SAlexander Motin struct g_consumer *cp; 11463631c638SAlexander Motin 11473631c638SAlexander Motin LIST_FOREACH(cp, &pp->consumers, consumers) 11483631c638SAlexander Motin cp->flags |= G_CF_SPOILED; 11493631c638SAlexander Motin return (g_post_event(g_spoil_event, pp, flag, pp, NULL)); 11503631c638SAlexander Motin } 11513631c638SAlexander Motin 1152a4ef1c5fSPoul-Henning Kamp int 1153a4ef1c5fSPoul-Henning Kamp g_getattr__(const char *attr, struct g_consumer *cp, void *var, int len) 1154a4ef1c5fSPoul-Henning Kamp { 1155a4ef1c5fSPoul-Henning Kamp int error, i; 1156a4ef1c5fSPoul-Henning Kamp 1157a4ef1c5fSPoul-Henning Kamp i = len; 1158a4ef1c5fSPoul-Henning Kamp error = g_io_getattr(attr, cp, &i, var); 1159a4ef1c5fSPoul-Henning Kamp if (error) 1160a4ef1c5fSPoul-Henning Kamp return (error); 1161a4ef1c5fSPoul-Henning Kamp if (i != len) 1162a4ef1c5fSPoul-Henning Kamp return (EINVAL); 1163a4ef1c5fSPoul-Henning Kamp return (0); 1164a4ef1c5fSPoul-Henning Kamp } 11657d590cc4SPoul-Henning Kamp 116690f2be24SAlexander Motin static int 116790f2be24SAlexander Motin g_get_device_prefix_len(const char *name) 116890f2be24SAlexander Motin { 116990f2be24SAlexander Motin int len; 117090f2be24SAlexander Motin 117190f2be24SAlexander Motin if (strncmp(name, "ada", 3) == 0) 117290f2be24SAlexander Motin len = 3; 117390f2be24SAlexander Motin else if (strncmp(name, "ad", 2) == 0) 117490f2be24SAlexander Motin len = 2; 117590f2be24SAlexander Motin else 117690f2be24SAlexander Motin return (0); 117790f2be24SAlexander Motin if (name[len] < '0' || name[len] > '9') 117890f2be24SAlexander Motin return (0); 117990f2be24SAlexander Motin do { 118090f2be24SAlexander Motin len++; 118190f2be24SAlexander Motin } while (name[len] >= '0' && name[len] <= '9'); 118290f2be24SAlexander Motin return (len); 118390f2be24SAlexander Motin } 118490f2be24SAlexander Motin 118590f2be24SAlexander Motin int 118690f2be24SAlexander Motin g_compare_names(const char *namea, const char *nameb) 118790f2be24SAlexander Motin { 118890f2be24SAlexander Motin int deva, devb; 118990f2be24SAlexander Motin 119090f2be24SAlexander Motin if (strcmp(namea, nameb) == 0) 119190f2be24SAlexander Motin return (1); 119290f2be24SAlexander Motin deva = g_get_device_prefix_len(namea); 119390f2be24SAlexander Motin if (deva == 0) 119490f2be24SAlexander Motin return (0); 119590f2be24SAlexander Motin devb = g_get_device_prefix_len(nameb); 119690f2be24SAlexander Motin if (devb == 0) 119790f2be24SAlexander Motin return (0); 119890f2be24SAlexander Motin if (strcmp(namea + deva, nameb + devb) == 0) 119990f2be24SAlexander Motin return (1); 120090f2be24SAlexander Motin return (0); 120190f2be24SAlexander Motin } 120290f2be24SAlexander Motin 1203679f8b7eSPawel Jakub Dawidek #if defined(DIAGNOSTIC) || defined(DDB) 12047d590cc4SPoul-Henning Kamp /* 1205002d1d1cSJaakko Heinonen * This function walks the mesh and returns a non-zero integer if it 1206002d1d1cSJaakko Heinonen * finds the argument pointer is an object. The return value indicates 1207002d1d1cSJaakko Heinonen * which type of object it is believed to be. If topology is not locked, 1208002d1d1cSJaakko Heinonen * this function is potentially dangerous, but we don't assert that the 1209002d1d1cSJaakko Heinonen * topology lock is held when called from debugger. 1210b3ecca4dSPoul-Henning Kamp */ 12113d1d5bc3SPoul-Henning Kamp int 1212b3ecca4dSPoul-Henning Kamp g_valid_obj(void const *ptr) 1213b3ecca4dSPoul-Henning Kamp { 1214b3ecca4dSPoul-Henning Kamp struct g_class *mp; 1215b3ecca4dSPoul-Henning Kamp struct g_geom *gp; 1216b3ecca4dSPoul-Henning Kamp struct g_consumer *cp; 1217b3ecca4dSPoul-Henning Kamp struct g_provider *pp; 1218b3ecca4dSPoul-Henning Kamp 1219002d1d1cSJaakko Heinonen #ifdef KDB 1220002d1d1cSJaakko Heinonen if (kdb_active == 0) 1221002d1d1cSJaakko Heinonen #endif 12228edfe76aSEdward Tomasz Napierala g_topology_assert(); 12238edfe76aSEdward Tomasz Napierala 1224b3ecca4dSPoul-Henning Kamp LIST_FOREACH(mp, &g_classes, class) { 1225b3ecca4dSPoul-Henning Kamp if (ptr == mp) 1226b3ecca4dSPoul-Henning Kamp return (1); 1227b3ecca4dSPoul-Henning Kamp LIST_FOREACH(gp, &mp->geom, geom) { 1228b3ecca4dSPoul-Henning Kamp if (ptr == gp) 12293d1d5bc3SPoul-Henning Kamp return (2); 1230b3ecca4dSPoul-Henning Kamp LIST_FOREACH(cp, &gp->consumer, consumer) 1231b3ecca4dSPoul-Henning Kamp if (ptr == cp) 12323d1d5bc3SPoul-Henning Kamp return (3); 1233b3ecca4dSPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) 1234b3ecca4dSPoul-Henning Kamp if (ptr == pp) 12353d1d5bc3SPoul-Henning Kamp return (4); 1236b3ecca4dSPoul-Henning Kamp } 1237b3ecca4dSPoul-Henning Kamp } 1238b3ecca4dSPoul-Henning Kamp return(0); 1239b3ecca4dSPoul-Henning Kamp } 12403d1d5bc3SPoul-Henning Kamp #endif 1241679f8b7eSPawel Jakub Dawidek 1242679f8b7eSPawel Jakub Dawidek #ifdef DDB 1243679f8b7eSPawel Jakub Dawidek 1244679f8b7eSPawel Jakub Dawidek #define gprintf(...) do { \ 12456d66da20SUlf Lilleengen db_printf("%*s", indent, ""); \ 12466d66da20SUlf Lilleengen db_printf(__VA_ARGS__); \ 1247679f8b7eSPawel Jakub Dawidek } while (0) 1248679f8b7eSPawel Jakub Dawidek #define gprintln(...) do { \ 1249679f8b7eSPawel Jakub Dawidek gprintf(__VA_ARGS__); \ 12506d66da20SUlf Lilleengen db_printf("\n"); \ 1251679f8b7eSPawel Jakub Dawidek } while (0) 1252679f8b7eSPawel Jakub Dawidek 1253679f8b7eSPawel Jakub Dawidek #define ADDFLAG(obj, flag, sflag) do { \ 1254679f8b7eSPawel Jakub Dawidek if ((obj)->flags & (flag)) { \ 1255679f8b7eSPawel Jakub Dawidek if (comma) \ 1256679f8b7eSPawel Jakub Dawidek strlcat(str, ",", size); \ 1257679f8b7eSPawel Jakub Dawidek strlcat(str, (sflag), size); \ 1258679f8b7eSPawel Jakub Dawidek comma = 1; \ 1259679f8b7eSPawel Jakub Dawidek } \ 1260679f8b7eSPawel Jakub Dawidek } while (0) 1261679f8b7eSPawel Jakub Dawidek 1262679f8b7eSPawel Jakub Dawidek static char * 1263679f8b7eSPawel Jakub Dawidek provider_flags_to_string(struct g_provider *pp, char *str, size_t size) 1264679f8b7eSPawel Jakub Dawidek { 1265679f8b7eSPawel Jakub Dawidek int comma = 0; 1266679f8b7eSPawel Jakub Dawidek 1267679f8b7eSPawel Jakub Dawidek bzero(str, size); 1268679f8b7eSPawel Jakub Dawidek if (pp->flags == 0) { 1269679f8b7eSPawel Jakub Dawidek strlcpy(str, "NONE", size); 1270679f8b7eSPawel Jakub Dawidek return (str); 1271679f8b7eSPawel Jakub Dawidek } 1272679f8b7eSPawel Jakub Dawidek ADDFLAG(pp, G_PF_WITHER, "G_PF_WITHER"); 1273679f8b7eSPawel Jakub Dawidek ADDFLAG(pp, G_PF_ORPHAN, "G_PF_ORPHAN"); 1274679f8b7eSPawel Jakub Dawidek return (str); 1275679f8b7eSPawel Jakub Dawidek } 1276679f8b7eSPawel Jakub Dawidek 1277679f8b7eSPawel Jakub Dawidek static char * 1278679f8b7eSPawel Jakub Dawidek geom_flags_to_string(struct g_geom *gp, char *str, size_t size) 1279679f8b7eSPawel Jakub Dawidek { 1280679f8b7eSPawel Jakub Dawidek int comma = 0; 1281679f8b7eSPawel Jakub Dawidek 1282679f8b7eSPawel Jakub Dawidek bzero(str, size); 1283679f8b7eSPawel Jakub Dawidek if (gp->flags == 0) { 1284679f8b7eSPawel Jakub Dawidek strlcpy(str, "NONE", size); 1285679f8b7eSPawel Jakub Dawidek return (str); 1286679f8b7eSPawel Jakub Dawidek } 1287679f8b7eSPawel Jakub Dawidek ADDFLAG(gp, G_GEOM_WITHER, "G_GEOM_WITHER"); 1288679f8b7eSPawel Jakub Dawidek return (str); 1289679f8b7eSPawel Jakub Dawidek } 1290679f8b7eSPawel Jakub Dawidek static void 1291679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(int indent, struct g_consumer *cp) 1292679f8b7eSPawel Jakub Dawidek { 1293679f8b7eSPawel Jakub Dawidek 1294679f8b7eSPawel Jakub Dawidek if (indent == 0) { 1295679f8b7eSPawel Jakub Dawidek gprintln("consumer: %p", cp); 1296679f8b7eSPawel Jakub Dawidek gprintln(" class: %s (%p)", cp->geom->class->name, 1297679f8b7eSPawel Jakub Dawidek cp->geom->class); 1298679f8b7eSPawel Jakub Dawidek gprintln(" geom: %s (%p)", cp->geom->name, cp->geom); 1299679f8b7eSPawel Jakub Dawidek if (cp->provider == NULL) 1300679f8b7eSPawel Jakub Dawidek gprintln(" provider: none"); 1301679f8b7eSPawel Jakub Dawidek else { 1302679f8b7eSPawel Jakub Dawidek gprintln(" provider: %s (%p)", cp->provider->name, 1303679f8b7eSPawel Jakub Dawidek cp->provider); 1304679f8b7eSPawel Jakub Dawidek } 1305679f8b7eSPawel Jakub Dawidek gprintln(" access: r%dw%de%d", cp->acr, cp->acw, cp->ace); 13063631c638SAlexander Motin gprintln(" flags: 0x%04x", cp->flags); 1307679f8b7eSPawel Jakub Dawidek gprintln(" nstart: %u", cp->nstart); 1308679f8b7eSPawel Jakub Dawidek gprintln(" nend: %u", cp->nend); 1309679f8b7eSPawel Jakub Dawidek } else { 1310679f8b7eSPawel Jakub Dawidek gprintf("consumer: %p (%s), access=r%dw%de%d", cp, 1311679f8b7eSPawel Jakub Dawidek cp->provider != NULL ? cp->provider->name : "none", 1312679f8b7eSPawel Jakub Dawidek cp->acr, cp->acw, cp->ace); 13133631c638SAlexander Motin if (cp->flags) 13143631c638SAlexander Motin db_printf(", flags=0x%04x", cp->flags); 13156d66da20SUlf Lilleengen db_printf("\n"); 1316679f8b7eSPawel Jakub Dawidek } 1317679f8b7eSPawel Jakub Dawidek } 1318679f8b7eSPawel Jakub Dawidek 1319679f8b7eSPawel Jakub Dawidek static void 1320679f8b7eSPawel Jakub Dawidek db_show_geom_provider(int indent, struct g_provider *pp) 1321679f8b7eSPawel Jakub Dawidek { 1322679f8b7eSPawel Jakub Dawidek struct g_consumer *cp; 1323679f8b7eSPawel Jakub Dawidek char flags[64]; 1324679f8b7eSPawel Jakub Dawidek 1325679f8b7eSPawel Jakub Dawidek if (indent == 0) { 1326679f8b7eSPawel Jakub Dawidek gprintln("provider: %s (%p)", pp->name, pp); 1327679f8b7eSPawel Jakub Dawidek gprintln(" class: %s (%p)", pp->geom->class->name, 1328679f8b7eSPawel Jakub Dawidek pp->geom->class); 1329679f8b7eSPawel Jakub Dawidek gprintln(" geom: %s (%p)", pp->geom->name, pp->geom); 1330679f8b7eSPawel Jakub Dawidek gprintln(" mediasize: %jd", (intmax_t)pp->mediasize); 1331679f8b7eSPawel Jakub Dawidek gprintln(" sectorsize: %u", pp->sectorsize); 1332679f8b7eSPawel Jakub Dawidek gprintln(" stripesize: %u", pp->stripesize); 1333679f8b7eSPawel Jakub Dawidek gprintln(" stripeoffset: %u", pp->stripeoffset); 1334679f8b7eSPawel Jakub Dawidek gprintln(" access: r%dw%de%d", pp->acr, pp->acw, 1335679f8b7eSPawel Jakub Dawidek pp->ace); 1336679f8b7eSPawel Jakub Dawidek gprintln(" flags: %s (0x%04x)", 1337679f8b7eSPawel Jakub Dawidek provider_flags_to_string(pp, flags, sizeof(flags)), 1338679f8b7eSPawel Jakub Dawidek pp->flags); 1339679f8b7eSPawel Jakub Dawidek gprintln(" error: %d", pp->error); 1340679f8b7eSPawel Jakub Dawidek gprintln(" nstart: %u", pp->nstart); 1341679f8b7eSPawel Jakub Dawidek gprintln(" nend: %u", pp->nend); 1342679f8b7eSPawel Jakub Dawidek if (LIST_EMPTY(&pp->consumers)) 1343679f8b7eSPawel Jakub Dawidek gprintln(" consumers: none"); 1344679f8b7eSPawel Jakub Dawidek } else { 1345679f8b7eSPawel Jakub Dawidek gprintf("provider: %s (%p), access=r%dw%de%d", 1346679f8b7eSPawel Jakub Dawidek pp->name, pp, pp->acr, pp->acw, pp->ace); 1347679f8b7eSPawel Jakub Dawidek if (pp->flags != 0) { 13486d66da20SUlf Lilleengen db_printf(", flags=%s (0x%04x)", 1349679f8b7eSPawel Jakub Dawidek provider_flags_to_string(pp, flags, sizeof(flags)), 1350679f8b7eSPawel Jakub Dawidek pp->flags); 1351679f8b7eSPawel Jakub Dawidek } 13526d66da20SUlf Lilleengen db_printf("\n"); 1353679f8b7eSPawel Jakub Dawidek } 1354679f8b7eSPawel Jakub Dawidek if (!LIST_EMPTY(&pp->consumers)) { 1355f02642d7SPawel Jakub Dawidek LIST_FOREACH(cp, &pp->consumers, consumers) { 1356679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(indent + 2, cp); 1357f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1358f02642d7SPawel Jakub Dawidek break; 1359f02642d7SPawel Jakub Dawidek } 1360679f8b7eSPawel Jakub Dawidek } 1361679f8b7eSPawel Jakub Dawidek } 1362679f8b7eSPawel Jakub Dawidek 1363679f8b7eSPawel Jakub Dawidek static void 1364679f8b7eSPawel Jakub Dawidek db_show_geom_geom(int indent, struct g_geom *gp) 1365679f8b7eSPawel Jakub Dawidek { 1366679f8b7eSPawel Jakub Dawidek struct g_provider *pp; 1367679f8b7eSPawel Jakub Dawidek struct g_consumer *cp; 1368679f8b7eSPawel Jakub Dawidek char flags[64]; 1369679f8b7eSPawel Jakub Dawidek 1370679f8b7eSPawel Jakub Dawidek if (indent == 0) { 1371679f8b7eSPawel Jakub Dawidek gprintln("geom: %s (%p)", gp->name, gp); 1372679f8b7eSPawel Jakub Dawidek gprintln(" class: %s (%p)", gp->class->name, gp->class); 1373679f8b7eSPawel Jakub Dawidek gprintln(" flags: %s (0x%04x)", 1374679f8b7eSPawel Jakub Dawidek geom_flags_to_string(gp, flags, sizeof(flags)), gp->flags); 1375679f8b7eSPawel Jakub Dawidek gprintln(" rank: %d", gp->rank); 1376679f8b7eSPawel Jakub Dawidek if (LIST_EMPTY(&gp->provider)) 1377679f8b7eSPawel Jakub Dawidek gprintln(" providers: none"); 1378679f8b7eSPawel Jakub Dawidek if (LIST_EMPTY(&gp->consumer)) 1379679f8b7eSPawel Jakub Dawidek gprintln(" consumers: none"); 1380679f8b7eSPawel Jakub Dawidek } else { 1381679f8b7eSPawel Jakub Dawidek gprintf("geom: %s (%p), rank=%d", gp->name, gp, gp->rank); 1382679f8b7eSPawel Jakub Dawidek if (gp->flags != 0) { 13836d66da20SUlf Lilleengen db_printf(", flags=%s (0x%04x)", 1384679f8b7eSPawel Jakub Dawidek geom_flags_to_string(gp, flags, sizeof(flags)), 1385679f8b7eSPawel Jakub Dawidek gp->flags); 1386679f8b7eSPawel Jakub Dawidek } 13876d66da20SUlf Lilleengen db_printf("\n"); 1388679f8b7eSPawel Jakub Dawidek } 1389679f8b7eSPawel Jakub Dawidek if (!LIST_EMPTY(&gp->provider)) { 1390f02642d7SPawel Jakub Dawidek LIST_FOREACH(pp, &gp->provider, provider) { 1391679f8b7eSPawel Jakub Dawidek db_show_geom_provider(indent + 2, pp); 1392f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1393f02642d7SPawel Jakub Dawidek break; 1394f02642d7SPawel Jakub Dawidek } 1395679f8b7eSPawel Jakub Dawidek } 1396679f8b7eSPawel Jakub Dawidek if (!LIST_EMPTY(&gp->consumer)) { 1397f02642d7SPawel Jakub Dawidek LIST_FOREACH(cp, &gp->consumer, consumer) { 1398679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(indent + 2, cp); 1399f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1400f02642d7SPawel Jakub Dawidek break; 1401f02642d7SPawel Jakub Dawidek } 1402679f8b7eSPawel Jakub Dawidek } 1403679f8b7eSPawel Jakub Dawidek } 1404679f8b7eSPawel Jakub Dawidek 1405679f8b7eSPawel Jakub Dawidek static void 1406679f8b7eSPawel Jakub Dawidek db_show_geom_class(struct g_class *mp) 1407679f8b7eSPawel Jakub Dawidek { 1408679f8b7eSPawel Jakub Dawidek struct g_geom *gp; 1409679f8b7eSPawel Jakub Dawidek 14106d66da20SUlf Lilleengen db_printf("class: %s (%p)\n", mp->name, mp); 1411f02642d7SPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) { 1412679f8b7eSPawel Jakub Dawidek db_show_geom_geom(2, gp); 1413f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1414f02642d7SPawel Jakub Dawidek break; 1415f02642d7SPawel Jakub Dawidek } 1416679f8b7eSPawel Jakub Dawidek } 1417679f8b7eSPawel Jakub Dawidek 1418679f8b7eSPawel Jakub Dawidek /* 1419679f8b7eSPawel Jakub Dawidek * Print the GEOM topology or the given object. 1420679f8b7eSPawel Jakub Dawidek */ 1421679f8b7eSPawel Jakub Dawidek DB_SHOW_COMMAND(geom, db_show_geom) 1422679f8b7eSPawel Jakub Dawidek { 1423679f8b7eSPawel Jakub Dawidek struct g_class *mp; 1424679f8b7eSPawel Jakub Dawidek 1425679f8b7eSPawel Jakub Dawidek if (!have_addr) { 1426679f8b7eSPawel Jakub Dawidek /* No address given, print the entire topology. */ 1427679f8b7eSPawel Jakub Dawidek LIST_FOREACH(mp, &g_classes, class) { 1428679f8b7eSPawel Jakub Dawidek db_show_geom_class(mp); 14296d66da20SUlf Lilleengen db_printf("\n"); 1430f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1431f02642d7SPawel Jakub Dawidek break; 1432679f8b7eSPawel Jakub Dawidek } 1433679f8b7eSPawel Jakub Dawidek } else { 1434679f8b7eSPawel Jakub Dawidek switch (g_valid_obj((void *)addr)) { 1435679f8b7eSPawel Jakub Dawidek case 1: 1436679f8b7eSPawel Jakub Dawidek db_show_geom_class((struct g_class *)addr); 1437679f8b7eSPawel Jakub Dawidek break; 1438679f8b7eSPawel Jakub Dawidek case 2: 1439679f8b7eSPawel Jakub Dawidek db_show_geom_geom(0, (struct g_geom *)addr); 1440679f8b7eSPawel Jakub Dawidek break; 1441679f8b7eSPawel Jakub Dawidek case 3: 1442679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(0, (struct g_consumer *)addr); 1443679f8b7eSPawel Jakub Dawidek break; 1444679f8b7eSPawel Jakub Dawidek case 4: 1445679f8b7eSPawel Jakub Dawidek db_show_geom_provider(0, (struct g_provider *)addr); 1446679f8b7eSPawel Jakub Dawidek break; 1447679f8b7eSPawel Jakub Dawidek default: 14486d66da20SUlf Lilleengen db_printf("Not a GEOM object.\n"); 1449679f8b7eSPawel Jakub Dawidek break; 1450679f8b7eSPawel Jakub Dawidek } 1451679f8b7eSPawel Jakub Dawidek } 1452679f8b7eSPawel Jakub Dawidek } 1453679f8b7eSPawel Jakub Dawidek 1454bf7d2c17SUlf Lilleengen static void 1455bf7d2c17SUlf Lilleengen db_print_bio_cmd(struct bio *bp) 1456bf7d2c17SUlf Lilleengen { 14576d66da20SUlf Lilleengen db_printf(" cmd: "); 1458bf7d2c17SUlf Lilleengen switch (bp->bio_cmd) { 14596d66da20SUlf Lilleengen case BIO_READ: db_printf("BIO_READ"); break; 14606d66da20SUlf Lilleengen case BIO_WRITE: db_printf("BIO_WRITE"); break; 14616d66da20SUlf Lilleengen case BIO_DELETE: db_printf("BIO_DELETE"); break; 14626d66da20SUlf Lilleengen case BIO_GETATTR: db_printf("BIO_GETATTR"); break; 14636d66da20SUlf Lilleengen case BIO_FLUSH: db_printf("BIO_FLUSH"); break; 14646d66da20SUlf Lilleengen case BIO_CMD0: db_printf("BIO_CMD0"); break; 14656d66da20SUlf Lilleengen case BIO_CMD1: db_printf("BIO_CMD1"); break; 14666d66da20SUlf Lilleengen case BIO_CMD2: db_printf("BIO_CMD2"); break; 14676d66da20SUlf Lilleengen default: db_printf("UNKNOWN"); break; 1468bf7d2c17SUlf Lilleengen } 14696d66da20SUlf Lilleengen db_printf("\n"); 1470bf7d2c17SUlf Lilleengen } 1471bf7d2c17SUlf Lilleengen 1472bf7d2c17SUlf Lilleengen static void 1473bf7d2c17SUlf Lilleengen db_print_bio_flags(struct bio *bp) 1474bf7d2c17SUlf Lilleengen { 1475bf7d2c17SUlf Lilleengen int comma; 1476bf7d2c17SUlf Lilleengen 1477bf7d2c17SUlf Lilleengen comma = 0; 14786d66da20SUlf Lilleengen db_printf(" flags: "); 1479bf7d2c17SUlf Lilleengen if (bp->bio_flags & BIO_ERROR) { 14806d66da20SUlf Lilleengen db_printf("BIO_ERROR"); 1481bf7d2c17SUlf Lilleengen comma = 1; 1482bf7d2c17SUlf Lilleengen } 1483bf7d2c17SUlf Lilleengen if (bp->bio_flags & BIO_DONE) { 14846d66da20SUlf Lilleengen db_printf("%sBIO_DONE", (comma ? ", " : "")); 1485bf7d2c17SUlf Lilleengen comma = 1; 1486bf7d2c17SUlf Lilleengen } 1487bf7d2c17SUlf Lilleengen if (bp->bio_flags & BIO_ONQUEUE) 14886d66da20SUlf Lilleengen db_printf("%sBIO_ONQUEUE", (comma ? ", " : "")); 14896d66da20SUlf Lilleengen db_printf("\n"); 1490bf7d2c17SUlf Lilleengen } 1491bf7d2c17SUlf Lilleengen 1492bf7d2c17SUlf Lilleengen /* 1493bf7d2c17SUlf Lilleengen * Print useful information in a BIO 1494bf7d2c17SUlf Lilleengen */ 1495bf7d2c17SUlf Lilleengen DB_SHOW_COMMAND(bio, db_show_bio) 1496bf7d2c17SUlf Lilleengen { 1497bf7d2c17SUlf Lilleengen struct bio *bp; 1498bf7d2c17SUlf Lilleengen 1499bf7d2c17SUlf Lilleengen if (have_addr) { 1500bf7d2c17SUlf Lilleengen bp = (struct bio *)addr; 15016d66da20SUlf Lilleengen db_printf("BIO %p\n", bp); 1502bf7d2c17SUlf Lilleengen db_print_bio_cmd(bp); 1503bf7d2c17SUlf Lilleengen db_print_bio_flags(bp); 15046d66da20SUlf Lilleengen db_printf(" cflags: 0x%hhx\n", bp->bio_cflags); 15056d66da20SUlf Lilleengen db_printf(" pflags: 0x%hhx\n", bp->bio_pflags); 15064147dd02SUlf Lilleengen db_printf(" offset: %jd\n", (intmax_t)bp->bio_offset); 15074147dd02SUlf Lilleengen db_printf(" length: %jd\n", (intmax_t)bp->bio_length); 15086d66da20SUlf Lilleengen db_printf(" bcount: %ld\n", bp->bio_bcount); 15096d66da20SUlf Lilleengen db_printf(" resid: %ld\n", bp->bio_resid); 15104147dd02SUlf Lilleengen db_printf(" completed: %jd\n", (intmax_t)bp->bio_completed); 15116d66da20SUlf Lilleengen db_printf(" children: %u\n", bp->bio_children); 15126d66da20SUlf Lilleengen db_printf(" inbed: %u\n", bp->bio_inbed); 15136d66da20SUlf Lilleengen db_printf(" error: %d\n", bp->bio_error); 15146d66da20SUlf Lilleengen db_printf(" parent: %p\n", bp->bio_parent); 15156d66da20SUlf Lilleengen db_printf(" driver1: %p\n", bp->bio_driver1); 15166d66da20SUlf Lilleengen db_printf(" driver2: %p\n", bp->bio_driver2); 15176d66da20SUlf Lilleengen db_printf(" caller1: %p\n", bp->bio_caller1); 15186d66da20SUlf Lilleengen db_printf(" caller2: %p\n", bp->bio_caller2); 15196d66da20SUlf Lilleengen db_printf(" bio_from: %p\n", bp->bio_from); 15206d66da20SUlf Lilleengen db_printf(" bio_to: %p\n", bp->bio_to); 1521bf7d2c17SUlf Lilleengen } 1522bf7d2c17SUlf Lilleengen } 1523bf7d2c17SUlf Lilleengen 1524679f8b7eSPawel Jakub Dawidek #undef gprintf 1525679f8b7eSPawel Jakub Dawidek #undef gprintln 1526679f8b7eSPawel Jakub Dawidek #undef ADDFLAG 1527679f8b7eSPawel Jakub Dawidek 1528679f8b7eSPawel Jakub Dawidek #endif /* DDB */ 1529