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; 2741b2cb2b3SDag-Erling Smørgrav if (g_shutdown || g_notaste) 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 44050199fa0SAlexander Motin * withered bits at present. 4411b464bd8SPoul-Henning Kamp */ 44250199fa0SAlexander Motin void 4431b464bd8SPoul-Henning Kamp g_wither_washer() 4441b464bd8SPoul-Henning Kamp { 4451b464bd8SPoul-Henning Kamp struct g_class *mp; 4461b464bd8SPoul-Henning Kamp struct g_geom *gp, *gp2; 4471b464bd8SPoul-Henning Kamp struct g_provider *pp, *pp2; 4481b464bd8SPoul-Henning Kamp struct g_consumer *cp, *cp2; 4491b464bd8SPoul-Henning Kamp 4501b464bd8SPoul-Henning Kamp g_topology_assert(); 4511b464bd8SPoul-Henning Kamp LIST_FOREACH(mp, &g_classes, class) { 4521b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(gp, &mp->geom, geom, gp2) { 4531b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(pp, &gp->provider, provider, pp2) { 4541b464bd8SPoul-Henning Kamp if (!(pp->flags & G_PF_WITHER)) 455d6227ae7SPoul-Henning Kamp continue; 4561b464bd8SPoul-Henning Kamp if (LIST_EMPTY(&pp->consumers)) 4571b464bd8SPoul-Henning Kamp g_destroy_provider(pp); 4581b464bd8SPoul-Henning Kamp } 4591b464bd8SPoul-Henning Kamp if (!(gp->flags & G_GEOM_WITHER)) 4601b464bd8SPoul-Henning Kamp continue; 4611b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(pp, &gp->provider, provider, pp2) { 4621b464bd8SPoul-Henning Kamp if (LIST_EMPTY(&pp->consumers)) 4631b464bd8SPoul-Henning Kamp g_destroy_provider(pp); 4641b464bd8SPoul-Henning Kamp } 4651b464bd8SPoul-Henning Kamp LIST_FOREACH_SAFE(cp, &gp->consumer, consumer, cp2) { 46650199fa0SAlexander Motin if (cp->acr || cp->acw || cp->ace) 4671b464bd8SPoul-Henning Kamp continue; 468539bec40SPoul-Henning Kamp if (cp->provider != NULL) 469d6227ae7SPoul-Henning Kamp g_detach(cp); 470d6227ae7SPoul-Henning Kamp g_destroy_consumer(cp); 471d6227ae7SPoul-Henning Kamp } 4721b464bd8SPoul-Henning Kamp if (LIST_EMPTY(&gp->provider) && 4731b464bd8SPoul-Henning Kamp LIST_EMPTY(&gp->consumer)) 474d6227ae7SPoul-Henning Kamp g_destroy_geom(gp); 4751b464bd8SPoul-Henning Kamp } 4761b464bd8SPoul-Henning Kamp } 477d6227ae7SPoul-Henning Kamp } 478d6227ae7SPoul-Henning Kamp 479dd84a43cSPoul-Henning Kamp struct g_consumer * 480dd84a43cSPoul-Henning Kamp g_new_consumer(struct g_geom *gp) 481dd84a43cSPoul-Henning Kamp { 482dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 483dd84a43cSPoul-Henning Kamp 484dd84a43cSPoul-Henning Kamp g_topology_assert(); 4853d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 486799426f8SPoul-Henning Kamp KASSERT(!(gp->flags & G_GEOM_WITHER), 487799426f8SPoul-Henning Kamp ("g_new_consumer on WITHERing geom(%s) (class %s)", 488799426f8SPoul-Henning Kamp gp->name, gp->class->name)); 48907d77fc6SPoul-Henning Kamp KASSERT(gp->orphan != NULL, 49007d77fc6SPoul-Henning Kamp ("g_new_consumer on geom(%s) (class %s) without orphan", 49107d77fc6SPoul-Henning Kamp gp->name, gp->class->name)); 492dd84a43cSPoul-Henning Kamp 493a163d034SWarner Losh cp = g_malloc(sizeof *cp, M_WAITOK | M_ZERO); 494dd84a43cSPoul-Henning Kamp cp->geom = gp; 495e24cbd90SPoul-Henning Kamp cp->stat = devstat_new_entry(cp, -1, 0, DEVSTAT_ALL_SUPPORTED, 496e24cbd90SPoul-Henning Kamp DEVSTAT_TYPE_DIRECT, DEVSTAT_PRIORITY_MAX); 497dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&gp->consumer, cp, consumer); 498dd84a43cSPoul-Henning Kamp return(cp); 499dd84a43cSPoul-Henning Kamp } 500dd84a43cSPoul-Henning Kamp 501dd84a43cSPoul-Henning Kamp void 502dd84a43cSPoul-Henning Kamp g_destroy_consumer(struct g_consumer *cp) 503dd84a43cSPoul-Henning Kamp { 504d6227ae7SPoul-Henning Kamp struct g_geom *gp; 505dd84a43cSPoul-Henning Kamp 506dd84a43cSPoul-Henning Kamp g_topology_assert(); 5073d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 5083d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_destroy_consumer(%p)", cp); 509dd84a43cSPoul-Henning Kamp KASSERT (cp->provider == NULL, ("g_destroy_consumer but attached")); 510dd84a43cSPoul-Henning Kamp KASSERT (cp->acr == 0, ("g_destroy_consumer with acr")); 511dd84a43cSPoul-Henning Kamp KASSERT (cp->acw == 0, ("g_destroy_consumer with acw")); 512dd84a43cSPoul-Henning Kamp KASSERT (cp->ace == 0, ("g_destroy_consumer with ace")); 513afcbcfaeSPoul-Henning Kamp g_cancel_event(cp); 514d6227ae7SPoul-Henning Kamp gp = cp->geom; 515dd84a43cSPoul-Henning Kamp LIST_REMOVE(cp, consumer); 516e24cbd90SPoul-Henning Kamp devstat_remove_entry(cp->stat); 517dd84a43cSPoul-Henning Kamp g_free(cp); 518d6227ae7SPoul-Henning Kamp if (gp->flags & G_GEOM_WITHER) 5191b464bd8SPoul-Henning Kamp g_do_wither(); 520dd84a43cSPoul-Henning Kamp } 521dd84a43cSPoul-Henning Kamp 5229ab3ea78SPoul-Henning Kamp static void 5239ab3ea78SPoul-Henning Kamp g_new_provider_event(void *arg, int flag) 5249ab3ea78SPoul-Henning Kamp { 5259ab3ea78SPoul-Henning Kamp struct g_class *mp; 5269ab3ea78SPoul-Henning Kamp struct g_provider *pp; 5273631c638SAlexander Motin struct g_consumer *cp, *next_cp; 5289ab3ea78SPoul-Henning Kamp 5299ab3ea78SPoul-Henning Kamp g_topology_assert(); 5309ab3ea78SPoul-Henning Kamp if (flag == EV_CANCEL) 5319ab3ea78SPoul-Henning Kamp return; 5329ab3ea78SPoul-Henning Kamp if (g_shutdown) 5339ab3ea78SPoul-Henning Kamp return; 5349ab3ea78SPoul-Henning Kamp pp = arg; 5353d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 5369097a8e6SPawel Jakub Dawidek KASSERT(!(pp->flags & G_PF_WITHER), 5379097a8e6SPawel Jakub Dawidek ("g_new_provider_event but withered")); 5383631c638SAlexander Motin LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, next_cp) { 5393631c638SAlexander Motin if ((cp->flags & G_CF_ORPHAN) == 0 && 5403631c638SAlexander Motin cp->geom->attrchanged != NULL) 5413631c638SAlexander Motin cp->geom->attrchanged(cp, "GEOM::media"); 5423631c638SAlexander Motin } 5431b2cb2b3SDag-Erling Smørgrav if (g_notaste) 5441b2cb2b3SDag-Erling Smørgrav return; 5459ab3ea78SPoul-Henning Kamp LIST_FOREACH(mp, &g_classes, class) { 5469ab3ea78SPoul-Henning Kamp if (mp->taste == NULL) 5479ab3ea78SPoul-Henning Kamp continue; 5489ab3ea78SPoul-Henning Kamp LIST_FOREACH(cp, &pp->consumers, consumers) 5493631c638SAlexander Motin if (cp->geom->class == mp && 5503631c638SAlexander Motin (cp->flags & G_CF_ORPHAN) == 0) 551cb9b72ceSPawel Jakub Dawidek break; 552cb9b72ceSPawel Jakub Dawidek if (cp != NULL) 5539ab3ea78SPoul-Henning Kamp continue; 554c4da4e46SPoul-Henning Kamp mp->taste(mp, pp, 0); 5559ab3ea78SPoul-Henning Kamp g_topology_assert(); 5569ab3ea78SPoul-Henning Kamp } 5579ab3ea78SPoul-Henning Kamp } 5589ab3ea78SPoul-Henning Kamp 5599ab3ea78SPoul-Henning Kamp 560dd84a43cSPoul-Henning Kamp struct g_provider * 5610f9d3dbaSPoul-Henning Kamp g_new_providerf(struct g_geom *gp, const char *fmt, ...) 562dd84a43cSPoul-Henning Kamp { 563dd84a43cSPoul-Henning Kamp struct g_provider *pp; 564dd84a43cSPoul-Henning Kamp struct sbuf *sb; 565dd84a43cSPoul-Henning Kamp va_list ap; 566dd84a43cSPoul-Henning Kamp 567dd84a43cSPoul-Henning Kamp g_topology_assert(); 5683d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 569e26bafdcSPoul-Henning Kamp KASSERT(gp->access != NULL, 570e26bafdcSPoul-Henning Kamp ("new provider on geom(%s) without ->access (class %s)", 571e26bafdcSPoul-Henning Kamp gp->name, gp->class->name)); 572799426f8SPoul-Henning Kamp KASSERT(gp->start != NULL, 573cff2ddaeSPawel Jakub Dawidek ("new provider on geom(%s) without ->start (class %s)", 574cff2ddaeSPawel Jakub Dawidek gp->name, gp->class->name)); 575799426f8SPoul-Henning Kamp KASSERT(!(gp->flags & G_GEOM_WITHER), 576cff2ddaeSPawel Jakub Dawidek ("new provider on WITHERing geom(%s) (class %s)", 577cff2ddaeSPawel Jakub Dawidek gp->name, gp->class->name)); 5782616144eSDag-Erling Smørgrav sb = sbuf_new_auto(); 579a1a9b445SPoul-Henning Kamp va_start(ap, fmt); 580dd84a43cSPoul-Henning Kamp sbuf_vprintf(sb, fmt, ap); 581a1a9b445SPoul-Henning Kamp va_end(ap); 582dd84a43cSPoul-Henning Kamp sbuf_finish(sb); 583a163d034SWarner Losh pp = g_malloc(sizeof *pp + sbuf_len(sb) + 1, M_WAITOK | M_ZERO); 584dd84a43cSPoul-Henning Kamp pp->name = (char *)(pp + 1); 585dd84a43cSPoul-Henning Kamp strcpy(pp->name, sbuf_data(sb)); 586dd84a43cSPoul-Henning Kamp sbuf_delete(sb); 587dd84a43cSPoul-Henning Kamp LIST_INIT(&pp->consumers); 588dd84a43cSPoul-Henning Kamp pp->error = ENXIO; 589dd84a43cSPoul-Henning Kamp pp->geom = gp; 590e24cbd90SPoul-Henning Kamp pp->stat = devstat_new_entry(pp, -1, 0, DEVSTAT_ALL_SUPPORTED, 591e24cbd90SPoul-Henning Kamp DEVSTAT_TYPE_DIRECT, DEVSTAT_PRIORITY_MAX); 592dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&gp->provider, pp, provider); 593e26bafdcSPoul-Henning Kamp g_post_event(g_new_provider_event, pp, M_WAITOK, pp, gp, NULL); 594dd84a43cSPoul-Henning Kamp return (pp); 595dd84a43cSPoul-Henning Kamp } 596dd84a43cSPoul-Henning Kamp 597dd84a43cSPoul-Henning Kamp void 598dd84a43cSPoul-Henning Kamp g_error_provider(struct g_provider *pp, int error) 599dd84a43cSPoul-Henning Kamp { 600dd84a43cSPoul-Henning Kamp 6013d1d5bc3SPoul-Henning Kamp /* G_VALID_PROVIDER(pp); We may not have g_topology */ 602dd84a43cSPoul-Henning Kamp pp->error = error; 603dd84a43cSPoul-Henning Kamp } 604dd84a43cSPoul-Henning Kamp 605245899ccSEdward Tomasz Napierala static void 606245899ccSEdward Tomasz Napierala g_resize_provider_event(void *arg, int flag) 607245899ccSEdward Tomasz Napierala { 608245899ccSEdward Tomasz Napierala struct g_hh00 *hh; 609245899ccSEdward Tomasz Napierala struct g_class *mp; 610245899ccSEdward Tomasz Napierala struct g_geom *gp; 611245899ccSEdward Tomasz Napierala struct g_provider *pp; 612245899ccSEdward Tomasz Napierala struct g_consumer *cp, *cp2; 613245899ccSEdward Tomasz Napierala off_t size; 614245899ccSEdward Tomasz Napierala 615245899ccSEdward Tomasz Napierala g_topology_assert(); 616245899ccSEdward Tomasz Napierala if (g_shutdown) 617245899ccSEdward Tomasz Napierala return; 618245899ccSEdward Tomasz Napierala 619245899ccSEdward Tomasz Napierala hh = arg; 620245899ccSEdward Tomasz Napierala pp = hh->pp; 621245899ccSEdward Tomasz Napierala size = hh->size; 6223a3ef28eSEdward Tomasz Napierala g_free(hh); 623245899ccSEdward Tomasz Napierala 624245899ccSEdward Tomasz Napierala G_VALID_PROVIDER(pp); 625245899ccSEdward Tomasz Napierala g_trace(G_T_TOPOLOGY, "g_resize_provider_event(%p)", pp); 626245899ccSEdward Tomasz Napierala 627245899ccSEdward Tomasz Napierala LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, cp2) { 628245899ccSEdward Tomasz Napierala gp = cp->geom; 6293631c638SAlexander Motin if (gp->resize == NULL && size < pp->mediasize) { 6303631c638SAlexander Motin cp->flags |= G_CF_ORPHAN; 631245899ccSEdward Tomasz Napierala cp->geom->orphan(cp); 632245899ccSEdward Tomasz Napierala } 6333631c638SAlexander Motin } 634245899ccSEdward Tomasz Napierala 635245899ccSEdward Tomasz Napierala pp->mediasize = size; 636245899ccSEdward Tomasz Napierala 637245899ccSEdward Tomasz Napierala LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, cp2) { 638245899ccSEdward Tomasz Napierala gp = cp->geom; 639245899ccSEdward Tomasz Napierala if (gp->resize != NULL) 640245899ccSEdward Tomasz Napierala gp->resize(cp); 641245899ccSEdward Tomasz Napierala } 642245899ccSEdward Tomasz Napierala 643245899ccSEdward Tomasz Napierala /* 644245899ccSEdward Tomasz Napierala * After resizing, the previously invalid GEOM class metadata 645245899ccSEdward Tomasz Napierala * might become valid. This means we should retaste. 646245899ccSEdward Tomasz Napierala */ 647245899ccSEdward Tomasz Napierala LIST_FOREACH(mp, &g_classes, class) { 648245899ccSEdward Tomasz Napierala if (mp->taste == NULL) 649245899ccSEdward Tomasz Napierala continue; 650245899ccSEdward Tomasz Napierala LIST_FOREACH(cp, &pp->consumers, consumers) 6513631c638SAlexander Motin if (cp->geom->class == mp && 6523631c638SAlexander Motin (cp->flags & G_CF_ORPHAN) == 0) 653245899ccSEdward Tomasz Napierala break; 654245899ccSEdward Tomasz Napierala if (cp != NULL) 655245899ccSEdward Tomasz Napierala continue; 656245899ccSEdward Tomasz Napierala mp->taste(mp, pp, 0); 657245899ccSEdward Tomasz Napierala g_topology_assert(); 658245899ccSEdward Tomasz Napierala } 659245899ccSEdward Tomasz Napierala } 660245899ccSEdward Tomasz Napierala 661245899ccSEdward Tomasz Napierala void 662245899ccSEdward Tomasz Napierala g_resize_provider(struct g_provider *pp, off_t size) 663245899ccSEdward Tomasz Napierala { 664245899ccSEdward Tomasz Napierala struct g_hh00 *hh; 665245899ccSEdward Tomasz Napierala 666245899ccSEdward Tomasz Napierala G_VALID_PROVIDER(pp); 667245899ccSEdward Tomasz Napierala 668245899ccSEdward Tomasz Napierala if (size == pp->mediasize) 669245899ccSEdward Tomasz Napierala return; 670245899ccSEdward Tomasz Napierala 671245899ccSEdward Tomasz Napierala hh = g_malloc(sizeof *hh, M_WAITOK | M_ZERO); 672245899ccSEdward Tomasz Napierala hh->pp = pp; 673245899ccSEdward Tomasz Napierala hh->size = size; 674245899ccSEdward Tomasz Napierala g_post_event(g_resize_provider_event, hh, M_WAITOK, NULL); 675245899ccSEdward Tomasz Napierala } 676245899ccSEdward Tomasz Napierala 677769afdc7SPawel Jakub Dawidek #ifndef _PATH_DEV 678769afdc7SPawel Jakub Dawidek #define _PATH_DEV "/dev/" 679769afdc7SPawel Jakub Dawidek #endif 680769afdc7SPawel Jakub Dawidek 681d6c5e716SPoul-Henning Kamp struct g_provider * 682d6c5e716SPoul-Henning Kamp g_provider_by_name(char const *arg) 683d6c5e716SPoul-Henning Kamp { 684d6c5e716SPoul-Henning Kamp struct g_class *cp; 685d6c5e716SPoul-Henning Kamp struct g_geom *gp; 686ba772028SAlexander Motin struct g_provider *pp, *wpp; 687d6c5e716SPoul-Henning Kamp 688769afdc7SPawel Jakub Dawidek if (strncmp(arg, _PATH_DEV, sizeof(_PATH_DEV) - 1) == 0) 689769afdc7SPawel Jakub Dawidek arg += sizeof(_PATH_DEV) - 1; 690769afdc7SPawel Jakub Dawidek 691ba772028SAlexander Motin wpp = NULL; 692d6c5e716SPoul-Henning Kamp LIST_FOREACH(cp, &g_classes, class) { 693d6c5e716SPoul-Henning Kamp LIST_FOREACH(gp, &cp->geom, geom) { 694d6c5e716SPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) { 695ba772028SAlexander Motin if (strcmp(arg, pp->name) != 0) 696ba772028SAlexander Motin continue; 697ba772028SAlexander Motin if ((gp->flags & G_GEOM_WITHER) == 0 && 698ba772028SAlexander Motin (pp->flags & G_PF_WITHER) == 0) 699d6c5e716SPoul-Henning Kamp return (pp); 700ba772028SAlexander Motin else 701ba772028SAlexander Motin wpp = pp; 702d6c5e716SPoul-Henning Kamp } 703d6c5e716SPoul-Henning Kamp } 704d6c5e716SPoul-Henning Kamp } 705769afdc7SPawel Jakub Dawidek 706ba772028SAlexander Motin return (wpp); 707d6c5e716SPoul-Henning Kamp } 708dd84a43cSPoul-Henning Kamp 709dd84a43cSPoul-Henning Kamp void 710dd84a43cSPoul-Henning Kamp g_destroy_provider(struct g_provider *pp) 711dd84a43cSPoul-Henning Kamp { 712dd84a43cSPoul-Henning Kamp struct g_geom *gp; 713dd84a43cSPoul-Henning Kamp 714dd84a43cSPoul-Henning Kamp g_topology_assert(); 7153d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 716dd84a43cSPoul-Henning Kamp KASSERT(LIST_EMPTY(&pp->consumers), 717dd84a43cSPoul-Henning Kamp ("g_destroy_provider but attached")); 718dd84a43cSPoul-Henning Kamp KASSERT (pp->acr == 0, ("g_destroy_provider with acr")); 719dd84a43cSPoul-Henning Kamp KASSERT (pp->acw == 0, ("g_destroy_provider with acw")); 7209097a8e6SPawel Jakub Dawidek KASSERT (pp->ace == 0, ("g_destroy_provider with ace")); 721afcbcfaeSPoul-Henning Kamp g_cancel_event(pp); 722dd84a43cSPoul-Henning Kamp LIST_REMOVE(pp, provider); 723dd84a43cSPoul-Henning Kamp gp = pp->geom; 724e24cbd90SPoul-Henning Kamp devstat_remove_entry(pp->stat); 725c3fb2891SKenneth D. Merry /* 726c3fb2891SKenneth D. Merry * If a callback was provided, send notification that the provider 727c3fb2891SKenneth D. Merry * is now gone. 728c3fb2891SKenneth D. Merry */ 729c3fb2891SKenneth D. Merry if (gp->providergone != NULL) 730c3fb2891SKenneth D. Merry gp->providergone(pp); 731c3fb2891SKenneth D. Merry 732dd84a43cSPoul-Henning Kamp g_free(pp); 733d6227ae7SPoul-Henning Kamp if ((gp->flags & G_GEOM_WITHER)) 7341b464bd8SPoul-Henning Kamp g_do_wither(); 735dd84a43cSPoul-Henning Kamp } 736dd84a43cSPoul-Henning Kamp 737dd84a43cSPoul-Henning Kamp /* 738dd84a43cSPoul-Henning Kamp * We keep the "geoms" list sorted by topological order (== increasing 739dd84a43cSPoul-Henning Kamp * numerical rank) at all times. 740dd84a43cSPoul-Henning Kamp * When an attach is done, the attaching geoms rank is invalidated 741dd84a43cSPoul-Henning Kamp * and it is moved to the tail of the list. 742dd84a43cSPoul-Henning Kamp * All geoms later in the sequence has their ranks reevaluated in 743dd84a43cSPoul-Henning Kamp * sequence. If we cannot assign rank to a geom because it's 744dd84a43cSPoul-Henning Kamp * prerequisites do not have rank, we move that element to the tail 745dd84a43cSPoul-Henning Kamp * of the sequence with invalid rank as well. 746dd84a43cSPoul-Henning Kamp * At some point we encounter our original geom and if we stil fail 747dd84a43cSPoul-Henning Kamp * to assign it a rank, there must be a loop and we fail back to 748503abe45SPoul-Henning Kamp * g_attach() which detach again and calls redo_rank again 749dd84a43cSPoul-Henning Kamp * to fix up the damage. 750dd84a43cSPoul-Henning Kamp * It would be much simpler code wise to do it recursively, but we 751dd84a43cSPoul-Henning Kamp * can't risk that on the kernel stack. 752dd84a43cSPoul-Henning Kamp */ 753dd84a43cSPoul-Henning Kamp 754dd84a43cSPoul-Henning Kamp static int 755dd84a43cSPoul-Henning Kamp redo_rank(struct g_geom *gp) 756dd84a43cSPoul-Henning Kamp { 757dd84a43cSPoul-Henning Kamp struct g_consumer *cp; 758dd84a43cSPoul-Henning Kamp struct g_geom *gp1, *gp2; 759dd84a43cSPoul-Henning Kamp int n, m; 760dd84a43cSPoul-Henning Kamp 761dd84a43cSPoul-Henning Kamp g_topology_assert(); 7623d1d5bc3SPoul-Henning Kamp G_VALID_GEOM(gp); 763dd84a43cSPoul-Henning Kamp 764dd84a43cSPoul-Henning Kamp /* Invalidate this geoms rank and move it to the tail */ 765dd84a43cSPoul-Henning Kamp gp1 = TAILQ_NEXT(gp, geoms); 766dd84a43cSPoul-Henning Kamp if (gp1 != NULL) { 767dd84a43cSPoul-Henning Kamp gp->rank = 0; 768dd84a43cSPoul-Henning Kamp TAILQ_REMOVE(&geoms, gp, geoms); 769dd84a43cSPoul-Henning Kamp TAILQ_INSERT_TAIL(&geoms, gp, geoms); 770dd84a43cSPoul-Henning Kamp } else { 771dd84a43cSPoul-Henning Kamp gp1 = gp; 772dd84a43cSPoul-Henning Kamp } 773dd84a43cSPoul-Henning Kamp 774dd84a43cSPoul-Henning Kamp /* re-rank the rest of the sequence */ 775dd84a43cSPoul-Henning Kamp for (; gp1 != NULL; gp1 = gp2) { 776dd84a43cSPoul-Henning Kamp gp1->rank = 0; 777dd84a43cSPoul-Henning Kamp m = 1; 778dd84a43cSPoul-Henning Kamp LIST_FOREACH(cp, &gp1->consumer, consumer) { 779dd84a43cSPoul-Henning Kamp if (cp->provider == NULL) 780dd84a43cSPoul-Henning Kamp continue; 781dd84a43cSPoul-Henning Kamp n = cp->provider->geom->rank; 782dd84a43cSPoul-Henning Kamp if (n == 0) { 783dd84a43cSPoul-Henning Kamp m = 0; 784dd84a43cSPoul-Henning Kamp break; 785dd84a43cSPoul-Henning Kamp } else if (n >= m) 786dd84a43cSPoul-Henning Kamp m = n + 1; 787dd84a43cSPoul-Henning Kamp } 788dd84a43cSPoul-Henning Kamp gp1->rank = m; 789dd84a43cSPoul-Henning Kamp gp2 = TAILQ_NEXT(gp1, geoms); 790dd84a43cSPoul-Henning Kamp 791dd84a43cSPoul-Henning Kamp /* got a rank, moving on */ 792dd84a43cSPoul-Henning Kamp if (m != 0) 793dd84a43cSPoul-Henning Kamp continue; 794dd84a43cSPoul-Henning Kamp 795dd84a43cSPoul-Henning Kamp /* no rank to original geom means loop */ 79650d866ceSPoul-Henning Kamp if (gp == gp1) 797dd84a43cSPoul-Henning Kamp return (ELOOP); 798dd84a43cSPoul-Henning Kamp 799dd84a43cSPoul-Henning Kamp /* no rank, put it at the end move on */ 800dd84a43cSPoul-Henning Kamp TAILQ_REMOVE(&geoms, gp1, geoms); 801dd84a43cSPoul-Henning Kamp TAILQ_INSERT_TAIL(&geoms, gp1, geoms); 802dd84a43cSPoul-Henning Kamp } 803dd84a43cSPoul-Henning Kamp return (0); 804dd84a43cSPoul-Henning Kamp } 805dd84a43cSPoul-Henning Kamp 806dd84a43cSPoul-Henning Kamp int 807dd84a43cSPoul-Henning Kamp g_attach(struct g_consumer *cp, struct g_provider *pp) 808dd84a43cSPoul-Henning Kamp { 809dd84a43cSPoul-Henning Kamp int error; 810dd84a43cSPoul-Henning Kamp 811dd84a43cSPoul-Henning Kamp g_topology_assert(); 8123d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 8133d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 814e5131ab4SPawel Jakub Dawidek g_trace(G_T_TOPOLOGY, "g_attach(%p, %p)", cp, pp); 815dd84a43cSPoul-Henning Kamp KASSERT(cp->provider == NULL, ("attach but attached")); 816dd84a43cSPoul-Henning Kamp cp->provider = pp; 817dd84a43cSPoul-Henning Kamp LIST_INSERT_HEAD(&pp->consumers, cp, consumers); 818dd84a43cSPoul-Henning Kamp error = redo_rank(cp->geom); 819dd84a43cSPoul-Henning Kamp if (error) { 820dd84a43cSPoul-Henning Kamp LIST_REMOVE(cp, consumers); 821dd84a43cSPoul-Henning Kamp cp->provider = NULL; 822dd84a43cSPoul-Henning Kamp redo_rank(cp->geom); 823dd84a43cSPoul-Henning Kamp } 824dd84a43cSPoul-Henning Kamp return (error); 825dd84a43cSPoul-Henning Kamp } 826dd84a43cSPoul-Henning Kamp 827dd84a43cSPoul-Henning Kamp void 828503abe45SPoul-Henning Kamp g_detach(struct g_consumer *cp) 829dd84a43cSPoul-Henning Kamp { 830dd84a43cSPoul-Henning Kamp struct g_provider *pp; 831dd84a43cSPoul-Henning Kamp 832dd84a43cSPoul-Henning Kamp g_topology_assert(); 8333d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 8343d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_detach(%p)", cp); 835503abe45SPoul-Henning Kamp KASSERT(cp->provider != NULL, ("detach but not attached")); 836503abe45SPoul-Henning Kamp KASSERT(cp->acr == 0, ("detach but nonzero acr")); 837503abe45SPoul-Henning Kamp KASSERT(cp->acw == 0, ("detach but nonzero acw")); 838503abe45SPoul-Henning Kamp KASSERT(cp->ace == 0, ("detach but nonzero ace")); 8390e6be472SPoul-Henning Kamp KASSERT(cp->nstart == cp->nend, 8404ec35300SPoul-Henning Kamp ("detach with active requests")); 841dd84a43cSPoul-Henning Kamp pp = cp->provider; 842dd84a43cSPoul-Henning Kamp LIST_REMOVE(cp, consumers); 843dd84a43cSPoul-Henning Kamp cp->provider = NULL; 84450199fa0SAlexander Motin if ((cp->geom->flags & G_GEOM_WITHER) || 84550199fa0SAlexander Motin (pp->geom->flags & G_GEOM_WITHER) || 84650199fa0SAlexander Motin (pp->flags & G_PF_WITHER)) 8471b464bd8SPoul-Henning Kamp g_do_wither(); 848dd84a43cSPoul-Henning Kamp redo_rank(cp->geom); 849dd84a43cSPoul-Henning Kamp } 850dd84a43cSPoul-Henning Kamp 851dd84a43cSPoul-Henning Kamp /* 852d2bae332SPoul-Henning Kamp * g_access() 853dd84a43cSPoul-Henning Kamp * 854dd84a43cSPoul-Henning Kamp * Access-check with delta values. The question asked is "can provider 855dd84a43cSPoul-Henning Kamp * "cp" change the access counters by the relative amounts dc[rwe] ?" 856dd84a43cSPoul-Henning Kamp */ 857dd84a43cSPoul-Henning Kamp 858dd84a43cSPoul-Henning Kamp int 859d2bae332SPoul-Henning Kamp g_access(struct g_consumer *cp, int dcr, int dcw, int dce) 860dd84a43cSPoul-Henning Kamp { 861dd84a43cSPoul-Henning Kamp struct g_provider *pp; 862dd84a43cSPoul-Henning Kamp int pr,pw,pe; 863dd84a43cSPoul-Henning Kamp int error; 864dd84a43cSPoul-Henning Kamp 8653d1d5bc3SPoul-Henning Kamp g_topology_assert(); 8663d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 867dd84a43cSPoul-Henning Kamp pp = cp->provider; 868950124e3SPawel Jakub Dawidek KASSERT(pp != NULL, ("access but not attached")); 8693d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 870dd84a43cSPoul-Henning Kamp 871d2bae332SPoul-Henning Kamp g_trace(G_T_ACCESS, "g_access(%p(%s), %d, %d, %d)", 872dd84a43cSPoul-Henning Kamp cp, pp->name, dcr, dcw, dce); 873dd84a43cSPoul-Henning Kamp 874dd84a43cSPoul-Henning Kamp KASSERT(cp->acr + dcr >= 0, ("access resulting in negative acr")); 875dd84a43cSPoul-Henning Kamp KASSERT(cp->acw + dcw >= 0, ("access resulting in negative acw")); 876dd84a43cSPoul-Henning Kamp KASSERT(cp->ace + dce >= 0, ("access resulting in negative ace")); 877cfa35456SPoul-Henning Kamp KASSERT(dcr != 0 || dcw != 0 || dce != 0, ("NOP access request")); 87807d77fc6SPoul-Henning Kamp KASSERT(pp->geom->access != NULL, ("NULL geom->access")); 879dd84a43cSPoul-Henning Kamp 880dd84a43cSPoul-Henning Kamp /* 881e805e8f0SPoul-Henning Kamp * If our class cares about being spoiled, and we have been, we 882dd84a43cSPoul-Henning Kamp * are probably just ahead of the event telling us that. Fail 883dd84a43cSPoul-Henning Kamp * now rather than having to unravel this later. 884dd84a43cSPoul-Henning Kamp */ 8853631c638SAlexander Motin if (cp->geom->spoiled != NULL && (cp->flags & G_CF_SPOILED) && 8864fa0290fSPoul-Henning Kamp (dcr > 0 || dcw > 0 || dce > 0)) 8874fa0290fSPoul-Henning Kamp return (ENXIO); 888dd84a43cSPoul-Henning Kamp 889dd84a43cSPoul-Henning Kamp /* 890dd84a43cSPoul-Henning Kamp * Figure out what counts the provider would have had, if this 891dd84a43cSPoul-Henning Kamp * consumer had (r0w0e0) at this time. 892dd84a43cSPoul-Henning Kamp */ 893dd84a43cSPoul-Henning Kamp pr = pp->acr - cp->acr; 894dd84a43cSPoul-Henning Kamp pw = pp->acw - cp->acw; 895dd84a43cSPoul-Henning Kamp pe = pp->ace - cp->ace; 896dd84a43cSPoul-Henning Kamp 897dd84a43cSPoul-Henning Kamp g_trace(G_T_ACCESS, 898dd84a43cSPoul-Henning Kamp "open delta:[r%dw%de%d] old:[r%dw%de%d] provider:[r%dw%de%d] %p(%s)", 899dd84a43cSPoul-Henning Kamp dcr, dcw, dce, 900dd84a43cSPoul-Henning Kamp cp->acr, cp->acw, cp->ace, 901dd84a43cSPoul-Henning Kamp pp->acr, pp->acw, pp->ace, 902dd84a43cSPoul-Henning Kamp pp, pp->name); 903dd84a43cSPoul-Henning Kamp 9048ebd558fSPoul-Henning Kamp /* If foot-shooting is enabled, any open on rank#1 is OK */ 9058ebd558fSPoul-Henning Kamp if ((g_debugflags & 16) && pp->geom->rank == 1) 9068ebd558fSPoul-Henning Kamp ; 907dd84a43cSPoul-Henning Kamp /* If we try exclusive but already write: fail */ 9088ebd558fSPoul-Henning Kamp else if (dce > 0 && pw > 0) 909dd84a43cSPoul-Henning Kamp return (EPERM); 910dd84a43cSPoul-Henning Kamp /* If we try write but already exclusive: fail */ 9118ebd558fSPoul-Henning Kamp else if (dcw > 0 && pe > 0) 912dd84a43cSPoul-Henning Kamp return (EPERM); 913dd84a43cSPoul-Henning Kamp /* If we try to open more but provider is error'ed: fail */ 9148ebd558fSPoul-Henning Kamp else if ((dcr > 0 || dcw > 0 || dce > 0) && pp->error != 0) 915dd84a43cSPoul-Henning Kamp return (pp->error); 916dd84a43cSPoul-Henning Kamp 917dd84a43cSPoul-Henning Kamp /* Ok then... */ 918dd84a43cSPoul-Henning Kamp 9198f6da0e4SPoul-Henning Kamp error = pp->geom->access(pp, dcr, dcw, dce); 920bfc37a51SPoul-Henning Kamp KASSERT(dcr > 0 || dcw > 0 || dce > 0 || error == 0, 92187bc328dSBryan Drewery ("Geom provider %s::%s dcr=%d dcw=%d dce=%d error=%d failed " 92287bc328dSBryan Drewery "closing ->access()", pp->geom->class->name, pp->name, dcr, dcw, 92387bc328dSBryan Drewery dce, error)); 9248f6da0e4SPoul-Henning Kamp if (!error) { 925dd84a43cSPoul-Henning Kamp /* 926dd84a43cSPoul-Henning Kamp * If we open first write, spoil any partner consumers. 927a7e69e8bSJohn Polstra * If we close last write and provider is not errored, 928a7e69e8bSJohn Polstra * trigger re-taste. 929dd84a43cSPoul-Henning Kamp */ 930dd84a43cSPoul-Henning Kamp if (pp->acw == 0 && dcw != 0) 931dd84a43cSPoul-Henning Kamp g_spoil(pp, cp); 932a7e69e8bSJohn Polstra else if (pp->acw != 0 && pp->acw == -dcw && pp->error == 0 && 933a9ed5e11SPoul-Henning Kamp !(pp->geom->flags & G_GEOM_WITHER)) 9348cd1535aSPoul-Henning Kamp g_post_event(g_new_provider_event, pp, M_WAITOK, 9358cd1535aSPoul-Henning Kamp pp, NULL); 936dd84a43cSPoul-Henning Kamp 937dd84a43cSPoul-Henning Kamp pp->acr += dcr; 938dd84a43cSPoul-Henning Kamp pp->acw += dcw; 939dd84a43cSPoul-Henning Kamp pp->ace += dce; 940dd84a43cSPoul-Henning Kamp cp->acr += dcr; 941dd84a43cSPoul-Henning Kamp cp->acw += dcw; 942dd84a43cSPoul-Henning Kamp cp->ace += dce; 9435ae652c0SPoul-Henning Kamp if (pp->acr != 0 || pp->acw != 0 || pp->ace != 0) 9445ae652c0SPoul-Henning Kamp KASSERT(pp->sectorsize > 0, 9455ae652c0SPoul-Henning Kamp ("Provider %s lacks sectorsize", pp->name)); 94650199fa0SAlexander Motin if ((cp->geom->flags & G_GEOM_WITHER) && 94750199fa0SAlexander Motin cp->acr == 0 && cp->acw == 0 && cp->ace == 0) 94850199fa0SAlexander Motin g_do_wither(); 949dd84a43cSPoul-Henning Kamp } 950dd84a43cSPoul-Henning Kamp return (error); 951dd84a43cSPoul-Henning Kamp } 952dd84a43cSPoul-Henning Kamp 953dd84a43cSPoul-Henning Kamp int 9540f9d3dbaSPoul-Henning Kamp g_handleattr_int(struct bio *bp, const char *attribute, int val) 955dd84a43cSPoul-Henning Kamp { 956dd84a43cSPoul-Henning Kamp 957503abe45SPoul-Henning Kamp return (g_handleattr(bp, attribute, &val, sizeof val)); 958dd84a43cSPoul-Henning Kamp } 959dd84a43cSPoul-Henning Kamp 960dd84a43cSPoul-Henning Kamp int 961c28078e9SSteven Hartland g_handleattr_uint16_t(struct bio *bp, const char *attribute, uint16_t val) 962c28078e9SSteven Hartland { 963c28078e9SSteven Hartland 964c28078e9SSteven Hartland return (g_handleattr(bp, attribute, &val, sizeof val)); 965c28078e9SSteven Hartland } 966c28078e9SSteven Hartland 967c28078e9SSteven Hartland int 9680f9d3dbaSPoul-Henning Kamp g_handleattr_off_t(struct bio *bp, const char *attribute, off_t val) 969dd84a43cSPoul-Henning Kamp { 970dd84a43cSPoul-Henning Kamp 971503abe45SPoul-Henning Kamp return (g_handleattr(bp, attribute, &val, sizeof val)); 972dd84a43cSPoul-Henning Kamp } 973dd84a43cSPoul-Henning Kamp 974dd84a43cSPoul-Henning Kamp int 975709a6266SMarcel Moolenaar g_handleattr_str(struct bio *bp, const char *attribute, const char *str) 976d19dbf4aSPawel Jakub Dawidek { 977d19dbf4aSPawel Jakub Dawidek 978d19dbf4aSPawel Jakub Dawidek return (g_handleattr(bp, attribute, str, 0)); 979d19dbf4aSPawel Jakub Dawidek } 980d19dbf4aSPawel Jakub Dawidek 981d19dbf4aSPawel Jakub Dawidek int 982709a6266SMarcel Moolenaar g_handleattr(struct bio *bp, const char *attribute, const void *val, int len) 983dd84a43cSPoul-Henning Kamp { 984d19dbf4aSPawel Jakub Dawidek int error = 0; 985dd84a43cSPoul-Henning Kamp 986dd84a43cSPoul-Henning Kamp if (strcmp(bp->bio_attribute, attribute)) 987dd84a43cSPoul-Henning Kamp return (0); 988d19dbf4aSPawel Jakub Dawidek if (len == 0) { 989d19dbf4aSPawel Jakub Dawidek bzero(bp->bio_data, bp->bio_length); 990d19dbf4aSPawel Jakub Dawidek if (strlcpy(bp->bio_data, val, bp->bio_length) >= 991d19dbf4aSPawel Jakub Dawidek bp->bio_length) { 992d19dbf4aSPawel Jakub Dawidek printf("%s: %s bio_length %jd len %zu -> EFAULT\n", 993d19dbf4aSPawel Jakub Dawidek __func__, bp->bio_to->name, 994d19dbf4aSPawel Jakub Dawidek (intmax_t)bp->bio_length, strlen(val)); 995dd84a43cSPoul-Henning Kamp error = EFAULT; 996d19dbf4aSPawel Jakub Dawidek } 997d19dbf4aSPawel Jakub Dawidek } else if (bp->bio_length == len) { 998dd84a43cSPoul-Henning Kamp bcopy(val, bp->bio_data, len); 999d19dbf4aSPawel Jakub Dawidek } else { 1000d19dbf4aSPawel Jakub Dawidek printf("%s: %s bio_length %jd len %d -> EFAULT\n", __func__, 1001d19dbf4aSPawel Jakub Dawidek bp->bio_to->name, (intmax_t)bp->bio_length, len); 1002d19dbf4aSPawel Jakub Dawidek error = EFAULT; 1003dd84a43cSPoul-Henning Kamp } 1004da3ee909SMarcel Moolenaar if (error == 0) 1005da3ee909SMarcel Moolenaar bp->bio_completed = bp->bio_length; 100672840432SPoul-Henning Kamp g_io_deliver(bp, error); 1007dd84a43cSPoul-Henning Kamp return (1); 1008dd84a43cSPoul-Henning Kamp } 1009dd84a43cSPoul-Henning Kamp 1010dd84a43cSPoul-Henning Kamp int 10113d1d5bc3SPoul-Henning Kamp g_std_access(struct g_provider *pp, 1012dd84a43cSPoul-Henning Kamp int dr __unused, int dw __unused, int de __unused) 1013dd84a43cSPoul-Henning Kamp { 1014dd84a43cSPoul-Henning Kamp 10153d1d5bc3SPoul-Henning Kamp g_topology_assert(); 10163d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 1017dd84a43cSPoul-Henning Kamp return (0); 1018dd84a43cSPoul-Henning Kamp } 1019dd84a43cSPoul-Henning Kamp 1020dd84a43cSPoul-Henning Kamp void 1021dd84a43cSPoul-Henning Kamp g_std_done(struct bio *bp) 1022dd84a43cSPoul-Henning Kamp { 1023dd84a43cSPoul-Henning Kamp struct bio *bp2; 1024dd84a43cSPoul-Henning Kamp 1025936cc461SPoul-Henning Kamp bp2 = bp->bio_parent; 10263f521b60SPoul-Henning Kamp if (bp2->bio_error == 0) 10273f521b60SPoul-Henning Kamp bp2->bio_error = bp->bio_error; 10283f521b60SPoul-Henning Kamp bp2->bio_completed += bp->bio_completed; 1029dd84a43cSPoul-Henning Kamp g_destroy_bio(bp); 1030801bb689SPoul-Henning Kamp bp2->bio_inbed++; 1031801bb689SPoul-Henning Kamp if (bp2->bio_children == bp2->bio_inbed) 10323f521b60SPoul-Henning Kamp g_io_deliver(bp2, bp2->bio_error); 1033dd84a43cSPoul-Henning Kamp } 1034dd84a43cSPoul-Henning Kamp 1035dd84a43cSPoul-Henning Kamp /* XXX: maybe this is only g_slice_spoiled */ 1036dd84a43cSPoul-Henning Kamp 1037dd84a43cSPoul-Henning Kamp void 1038dd84a43cSPoul-Henning Kamp g_std_spoiled(struct g_consumer *cp) 1039dd84a43cSPoul-Henning Kamp { 1040c4da4e46SPoul-Henning Kamp struct g_geom *gp; 1041c4da4e46SPoul-Henning Kamp struct g_provider *pp; 1042dd84a43cSPoul-Henning Kamp 1043dd84a43cSPoul-Henning Kamp g_topology_assert(); 10443d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 10453d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_std_spoiled(%p)", cp); 10463631c638SAlexander Motin cp->flags |= G_CF_ORPHAN; 1047c4da4e46SPoul-Henning Kamp g_detach(cp); 1048c4da4e46SPoul-Henning Kamp gp = cp->geom; 1049c4da4e46SPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) 1050c4da4e46SPoul-Henning Kamp g_orphan_provider(pp, ENXIO); 1051c4da4e46SPoul-Henning Kamp g_destroy_consumer(cp); 1052c4da4e46SPoul-Henning Kamp if (LIST_EMPTY(&gp->provider) && LIST_EMPTY(&gp->consumer)) 1053c4da4e46SPoul-Henning Kamp g_destroy_geom(gp); 1054c4da4e46SPoul-Henning Kamp else 1055c4da4e46SPoul-Henning Kamp gp->flags |= G_GEOM_WITHER; 1056dd84a43cSPoul-Henning Kamp } 1057dd84a43cSPoul-Henning Kamp 1058dd84a43cSPoul-Henning Kamp /* 1059dd84a43cSPoul-Henning Kamp * Spoiling happens when a provider is opened for writing, but consumers 1060dd84a43cSPoul-Henning Kamp * which are configured by in-band data are attached (slicers for instance). 1061dd84a43cSPoul-Henning Kamp * Since the write might potentially change the in-band data, such consumers 1062dd84a43cSPoul-Henning Kamp * need to re-evaluate their existence after the writing session closes. 1063dd84a43cSPoul-Henning Kamp * We do this by (offering to) tear them down when the open for write happens 1064dd84a43cSPoul-Henning Kamp * in return for a re-taste when it closes again. 1065dd84a43cSPoul-Henning Kamp * Together with the fact that such consumers grab an 'e' bit whenever they 1066dd84a43cSPoul-Henning Kamp * are open, regardless of mode, this ends up DTRT. 1067dd84a43cSPoul-Henning Kamp */ 1068dd84a43cSPoul-Henning Kamp 1069f2e9a094SPoul-Henning Kamp static void 1070f2e9a094SPoul-Henning Kamp g_spoil_event(void *arg, int flag) 1071f2e9a094SPoul-Henning Kamp { 1072f2e9a094SPoul-Henning Kamp struct g_provider *pp; 1073f2e9a094SPoul-Henning Kamp struct g_consumer *cp, *cp2; 1074f2e9a094SPoul-Henning Kamp 1075f2e9a094SPoul-Henning Kamp g_topology_assert(); 1076f2e9a094SPoul-Henning Kamp if (flag == EV_CANCEL) 1077f2e9a094SPoul-Henning Kamp return; 1078f2e9a094SPoul-Henning Kamp pp = arg; 10793d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 108017e0c433SAndrey V. Elsukov g_trace(G_T_TOPOLOGY, "%s %p(%s:%s:%s)", __func__, pp, 108117e0c433SAndrey V. Elsukov pp->geom->class->name, pp->geom->name, pp->name); 1082f2e9a094SPoul-Henning Kamp for (cp = LIST_FIRST(&pp->consumers); cp != NULL; cp = cp2) { 1083f2e9a094SPoul-Henning Kamp cp2 = LIST_NEXT(cp, consumers); 10843631c638SAlexander Motin if ((cp->flags & G_CF_SPOILED) == 0) 1085f2e9a094SPoul-Henning Kamp continue; 10863631c638SAlexander Motin cp->flags &= ~G_CF_SPOILED; 1087f2e9a094SPoul-Henning Kamp if (cp->geom->spoiled == NULL) 1088f2e9a094SPoul-Henning Kamp continue; 1089f2e9a094SPoul-Henning Kamp cp->geom->spoiled(cp); 1090f2e9a094SPoul-Henning Kamp g_topology_assert(); 1091f2e9a094SPoul-Henning Kamp } 1092f2e9a094SPoul-Henning Kamp } 1093f2e9a094SPoul-Henning Kamp 1094dd84a43cSPoul-Henning Kamp void 1095dd84a43cSPoul-Henning Kamp g_spoil(struct g_provider *pp, struct g_consumer *cp) 1096dd84a43cSPoul-Henning Kamp { 1097dd84a43cSPoul-Henning Kamp struct g_consumer *cp2; 1098dd84a43cSPoul-Henning Kamp 1099dd84a43cSPoul-Henning Kamp g_topology_assert(); 11003d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp); 11013d1d5bc3SPoul-Henning Kamp G_VALID_CONSUMER(cp); 1102dd84a43cSPoul-Henning Kamp 1103dd84a43cSPoul-Henning Kamp LIST_FOREACH(cp2, &pp->consumers, consumers) { 1104dd84a43cSPoul-Henning Kamp if (cp2 == cp) 1105dd84a43cSPoul-Henning Kamp continue; 1106dd84a43cSPoul-Henning Kamp /* 1107dd84a43cSPoul-Henning Kamp KASSERT(cp2->acr == 0, ("spoiling cp->acr = %d", cp2->acr)); 1108dd84a43cSPoul-Henning Kamp KASSERT(cp2->acw == 0, ("spoiling cp->acw = %d", cp2->acw)); 1109dd84a43cSPoul-Henning Kamp */ 1110dd84a43cSPoul-Henning Kamp KASSERT(cp2->ace == 0, ("spoiling cp->ace = %d", cp2->ace)); 11113631c638SAlexander Motin cp2->flags |= G_CF_SPOILED; 1112dd84a43cSPoul-Henning Kamp } 11138cd1535aSPoul-Henning Kamp g_post_event(g_spoil_event, pp, M_WAITOK, pp, NULL); 1114dd84a43cSPoul-Henning Kamp } 1115dd84a43cSPoul-Henning Kamp 11163631c638SAlexander Motin static void 11173631c638SAlexander Motin g_media_changed_event(void *arg, int flag) 11183631c638SAlexander Motin { 11193631c638SAlexander Motin struct g_provider *pp; 11203631c638SAlexander Motin int retaste; 11213631c638SAlexander Motin 11223631c638SAlexander Motin g_topology_assert(); 11233631c638SAlexander Motin if (flag == EV_CANCEL) 11243631c638SAlexander Motin return; 11253631c638SAlexander Motin pp = arg; 11263631c638SAlexander Motin G_VALID_PROVIDER(pp); 11273631c638SAlexander Motin 11283631c638SAlexander Motin /* 11293631c638SAlexander Motin * If provider was not open for writing, queue retaste after spoiling. 11303631c638SAlexander Motin * If it was, retaste will happen automatically on close. 11313631c638SAlexander Motin */ 11323631c638SAlexander Motin retaste = (pp->acw == 0 && pp->error == 0 && 11333631c638SAlexander Motin !(pp->geom->flags & G_GEOM_WITHER)); 11343631c638SAlexander Motin g_spoil_event(arg, flag); 11353631c638SAlexander Motin if (retaste) 11363631c638SAlexander Motin g_post_event(g_new_provider_event, pp, M_WAITOK, pp, NULL); 11373631c638SAlexander Motin } 11383631c638SAlexander Motin 11393631c638SAlexander Motin int 11403631c638SAlexander Motin g_media_changed(struct g_provider *pp, int flag) 11413631c638SAlexander Motin { 11423631c638SAlexander Motin struct g_consumer *cp; 11433631c638SAlexander Motin 11443631c638SAlexander Motin LIST_FOREACH(cp, &pp->consumers, consumers) 11453631c638SAlexander Motin cp->flags |= G_CF_SPOILED; 11463631c638SAlexander Motin return (g_post_event(g_media_changed_event, pp, flag, pp, NULL)); 11473631c638SAlexander Motin } 11483631c638SAlexander Motin 11493631c638SAlexander Motin int 11503631c638SAlexander Motin g_media_gone(struct g_provider *pp, int flag) 11513631c638SAlexander Motin { 11523631c638SAlexander Motin struct g_consumer *cp; 11533631c638SAlexander Motin 11543631c638SAlexander Motin LIST_FOREACH(cp, &pp->consumers, consumers) 11553631c638SAlexander Motin cp->flags |= G_CF_SPOILED; 11563631c638SAlexander Motin return (g_post_event(g_spoil_event, pp, flag, pp, NULL)); 11573631c638SAlexander Motin } 11583631c638SAlexander Motin 1159a4ef1c5fSPoul-Henning Kamp int 1160a4ef1c5fSPoul-Henning Kamp g_getattr__(const char *attr, struct g_consumer *cp, void *var, int len) 1161a4ef1c5fSPoul-Henning Kamp { 1162a4ef1c5fSPoul-Henning Kamp int error, i; 1163a4ef1c5fSPoul-Henning Kamp 1164a4ef1c5fSPoul-Henning Kamp i = len; 1165a4ef1c5fSPoul-Henning Kamp error = g_io_getattr(attr, cp, &i, var); 1166a4ef1c5fSPoul-Henning Kamp if (error) 1167a4ef1c5fSPoul-Henning Kamp return (error); 1168a4ef1c5fSPoul-Henning Kamp if (i != len) 1169a4ef1c5fSPoul-Henning Kamp return (EINVAL); 1170a4ef1c5fSPoul-Henning Kamp return (0); 1171a4ef1c5fSPoul-Henning Kamp } 11727d590cc4SPoul-Henning Kamp 117390f2be24SAlexander Motin static int 117490f2be24SAlexander Motin g_get_device_prefix_len(const char *name) 117590f2be24SAlexander Motin { 117690f2be24SAlexander Motin int len; 117790f2be24SAlexander Motin 117890f2be24SAlexander Motin if (strncmp(name, "ada", 3) == 0) 117990f2be24SAlexander Motin len = 3; 118090f2be24SAlexander Motin else if (strncmp(name, "ad", 2) == 0) 118190f2be24SAlexander Motin len = 2; 118290f2be24SAlexander Motin else 118390f2be24SAlexander Motin return (0); 118490f2be24SAlexander Motin if (name[len] < '0' || name[len] > '9') 118590f2be24SAlexander Motin return (0); 118690f2be24SAlexander Motin do { 118790f2be24SAlexander Motin len++; 118890f2be24SAlexander Motin } while (name[len] >= '0' && name[len] <= '9'); 118990f2be24SAlexander Motin return (len); 119090f2be24SAlexander Motin } 119190f2be24SAlexander Motin 119290f2be24SAlexander Motin int 119390f2be24SAlexander Motin g_compare_names(const char *namea, const char *nameb) 119490f2be24SAlexander Motin { 119590f2be24SAlexander Motin int deva, devb; 119690f2be24SAlexander Motin 119790f2be24SAlexander Motin if (strcmp(namea, nameb) == 0) 119890f2be24SAlexander Motin return (1); 119990f2be24SAlexander Motin deva = g_get_device_prefix_len(namea); 120090f2be24SAlexander Motin if (deva == 0) 120190f2be24SAlexander Motin return (0); 120290f2be24SAlexander Motin devb = g_get_device_prefix_len(nameb); 120390f2be24SAlexander Motin if (devb == 0) 120490f2be24SAlexander Motin return (0); 120590f2be24SAlexander Motin if (strcmp(namea + deva, nameb + devb) == 0) 120690f2be24SAlexander Motin return (1); 120790f2be24SAlexander Motin return (0); 120890f2be24SAlexander Motin } 120990f2be24SAlexander Motin 1210679f8b7eSPawel Jakub Dawidek #if defined(DIAGNOSTIC) || defined(DDB) 12117d590cc4SPoul-Henning Kamp /* 1212002d1d1cSJaakko Heinonen * This function walks the mesh and returns a non-zero integer if it 1213002d1d1cSJaakko Heinonen * finds the argument pointer is an object. The return value indicates 1214002d1d1cSJaakko Heinonen * which type of object it is believed to be. If topology is not locked, 1215002d1d1cSJaakko Heinonen * this function is potentially dangerous, but we don't assert that the 1216002d1d1cSJaakko Heinonen * topology lock is held when called from debugger. 1217b3ecca4dSPoul-Henning Kamp */ 12183d1d5bc3SPoul-Henning Kamp int 1219b3ecca4dSPoul-Henning Kamp g_valid_obj(void const *ptr) 1220b3ecca4dSPoul-Henning Kamp { 1221b3ecca4dSPoul-Henning Kamp struct g_class *mp; 1222b3ecca4dSPoul-Henning Kamp struct g_geom *gp; 1223b3ecca4dSPoul-Henning Kamp struct g_consumer *cp; 1224b3ecca4dSPoul-Henning Kamp struct g_provider *pp; 1225b3ecca4dSPoul-Henning Kamp 1226002d1d1cSJaakko Heinonen #ifdef KDB 1227002d1d1cSJaakko Heinonen if (kdb_active == 0) 1228002d1d1cSJaakko Heinonen #endif 12298edfe76aSEdward Tomasz Napierala g_topology_assert(); 12308edfe76aSEdward Tomasz Napierala 1231b3ecca4dSPoul-Henning Kamp LIST_FOREACH(mp, &g_classes, class) { 1232b3ecca4dSPoul-Henning Kamp if (ptr == mp) 1233b3ecca4dSPoul-Henning Kamp return (1); 1234b3ecca4dSPoul-Henning Kamp LIST_FOREACH(gp, &mp->geom, geom) { 1235b3ecca4dSPoul-Henning Kamp if (ptr == gp) 12363d1d5bc3SPoul-Henning Kamp return (2); 1237b3ecca4dSPoul-Henning Kamp LIST_FOREACH(cp, &gp->consumer, consumer) 1238b3ecca4dSPoul-Henning Kamp if (ptr == cp) 12393d1d5bc3SPoul-Henning Kamp return (3); 1240b3ecca4dSPoul-Henning Kamp LIST_FOREACH(pp, &gp->provider, provider) 1241b3ecca4dSPoul-Henning Kamp if (ptr == pp) 12423d1d5bc3SPoul-Henning Kamp return (4); 1243b3ecca4dSPoul-Henning Kamp } 1244b3ecca4dSPoul-Henning Kamp } 1245b3ecca4dSPoul-Henning Kamp return(0); 1246b3ecca4dSPoul-Henning Kamp } 12473d1d5bc3SPoul-Henning Kamp #endif 1248679f8b7eSPawel Jakub Dawidek 1249679f8b7eSPawel Jakub Dawidek #ifdef DDB 1250679f8b7eSPawel Jakub Dawidek 1251679f8b7eSPawel Jakub Dawidek #define gprintf(...) do { \ 12526d66da20SUlf Lilleengen db_printf("%*s", indent, ""); \ 12536d66da20SUlf Lilleengen db_printf(__VA_ARGS__); \ 1254679f8b7eSPawel Jakub Dawidek } while (0) 1255679f8b7eSPawel Jakub Dawidek #define gprintln(...) do { \ 1256679f8b7eSPawel Jakub Dawidek gprintf(__VA_ARGS__); \ 12576d66da20SUlf Lilleengen db_printf("\n"); \ 1258679f8b7eSPawel Jakub Dawidek } while (0) 1259679f8b7eSPawel Jakub Dawidek 1260679f8b7eSPawel Jakub Dawidek #define ADDFLAG(obj, flag, sflag) do { \ 1261679f8b7eSPawel Jakub Dawidek if ((obj)->flags & (flag)) { \ 1262679f8b7eSPawel Jakub Dawidek if (comma) \ 1263679f8b7eSPawel Jakub Dawidek strlcat(str, ",", size); \ 1264679f8b7eSPawel Jakub Dawidek strlcat(str, (sflag), size); \ 1265679f8b7eSPawel Jakub Dawidek comma = 1; \ 1266679f8b7eSPawel Jakub Dawidek } \ 1267679f8b7eSPawel Jakub Dawidek } while (0) 1268679f8b7eSPawel Jakub Dawidek 1269679f8b7eSPawel Jakub Dawidek static char * 1270679f8b7eSPawel Jakub Dawidek provider_flags_to_string(struct g_provider *pp, char *str, size_t size) 1271679f8b7eSPawel Jakub Dawidek { 1272679f8b7eSPawel Jakub Dawidek int comma = 0; 1273679f8b7eSPawel Jakub Dawidek 1274679f8b7eSPawel Jakub Dawidek bzero(str, size); 1275679f8b7eSPawel Jakub Dawidek if (pp->flags == 0) { 1276679f8b7eSPawel Jakub Dawidek strlcpy(str, "NONE", size); 1277679f8b7eSPawel Jakub Dawidek return (str); 1278679f8b7eSPawel Jakub Dawidek } 1279679f8b7eSPawel Jakub Dawidek ADDFLAG(pp, G_PF_WITHER, "G_PF_WITHER"); 1280679f8b7eSPawel Jakub Dawidek ADDFLAG(pp, G_PF_ORPHAN, "G_PF_ORPHAN"); 1281679f8b7eSPawel Jakub Dawidek return (str); 1282679f8b7eSPawel Jakub Dawidek } 1283679f8b7eSPawel Jakub Dawidek 1284679f8b7eSPawel Jakub Dawidek static char * 1285679f8b7eSPawel Jakub Dawidek geom_flags_to_string(struct g_geom *gp, char *str, size_t size) 1286679f8b7eSPawel Jakub Dawidek { 1287679f8b7eSPawel Jakub Dawidek int comma = 0; 1288679f8b7eSPawel Jakub Dawidek 1289679f8b7eSPawel Jakub Dawidek bzero(str, size); 1290679f8b7eSPawel Jakub Dawidek if (gp->flags == 0) { 1291679f8b7eSPawel Jakub Dawidek strlcpy(str, "NONE", size); 1292679f8b7eSPawel Jakub Dawidek return (str); 1293679f8b7eSPawel Jakub Dawidek } 1294679f8b7eSPawel Jakub Dawidek ADDFLAG(gp, G_GEOM_WITHER, "G_GEOM_WITHER"); 1295679f8b7eSPawel Jakub Dawidek return (str); 1296679f8b7eSPawel Jakub Dawidek } 1297679f8b7eSPawel Jakub Dawidek static void 1298679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(int indent, struct g_consumer *cp) 1299679f8b7eSPawel Jakub Dawidek { 1300679f8b7eSPawel Jakub Dawidek 1301679f8b7eSPawel Jakub Dawidek if (indent == 0) { 1302679f8b7eSPawel Jakub Dawidek gprintln("consumer: %p", cp); 1303679f8b7eSPawel Jakub Dawidek gprintln(" class: %s (%p)", cp->geom->class->name, 1304679f8b7eSPawel Jakub Dawidek cp->geom->class); 1305679f8b7eSPawel Jakub Dawidek gprintln(" geom: %s (%p)", cp->geom->name, cp->geom); 1306679f8b7eSPawel Jakub Dawidek if (cp->provider == NULL) 1307679f8b7eSPawel Jakub Dawidek gprintln(" provider: none"); 1308679f8b7eSPawel Jakub Dawidek else { 1309679f8b7eSPawel Jakub Dawidek gprintln(" provider: %s (%p)", cp->provider->name, 1310679f8b7eSPawel Jakub Dawidek cp->provider); 1311679f8b7eSPawel Jakub Dawidek } 1312679f8b7eSPawel Jakub Dawidek gprintln(" access: r%dw%de%d", cp->acr, cp->acw, cp->ace); 13133631c638SAlexander Motin gprintln(" flags: 0x%04x", cp->flags); 1314679f8b7eSPawel Jakub Dawidek gprintln(" nstart: %u", cp->nstart); 1315679f8b7eSPawel Jakub Dawidek gprintln(" nend: %u", cp->nend); 1316679f8b7eSPawel Jakub Dawidek } else { 1317679f8b7eSPawel Jakub Dawidek gprintf("consumer: %p (%s), access=r%dw%de%d", cp, 1318679f8b7eSPawel Jakub Dawidek cp->provider != NULL ? cp->provider->name : "none", 1319679f8b7eSPawel Jakub Dawidek cp->acr, cp->acw, cp->ace); 13203631c638SAlexander Motin if (cp->flags) 13213631c638SAlexander Motin db_printf(", flags=0x%04x", cp->flags); 13226d66da20SUlf Lilleengen db_printf("\n"); 1323679f8b7eSPawel Jakub Dawidek } 1324679f8b7eSPawel Jakub Dawidek } 1325679f8b7eSPawel Jakub Dawidek 1326679f8b7eSPawel Jakub Dawidek static void 1327679f8b7eSPawel Jakub Dawidek db_show_geom_provider(int indent, struct g_provider *pp) 1328679f8b7eSPawel Jakub Dawidek { 1329679f8b7eSPawel Jakub Dawidek struct g_consumer *cp; 1330679f8b7eSPawel Jakub Dawidek char flags[64]; 1331679f8b7eSPawel Jakub Dawidek 1332679f8b7eSPawel Jakub Dawidek if (indent == 0) { 1333679f8b7eSPawel Jakub Dawidek gprintln("provider: %s (%p)", pp->name, pp); 1334679f8b7eSPawel Jakub Dawidek gprintln(" class: %s (%p)", pp->geom->class->name, 1335679f8b7eSPawel Jakub Dawidek pp->geom->class); 1336679f8b7eSPawel Jakub Dawidek gprintln(" geom: %s (%p)", pp->geom->name, pp->geom); 1337679f8b7eSPawel Jakub Dawidek gprintln(" mediasize: %jd", (intmax_t)pp->mediasize); 1338679f8b7eSPawel Jakub Dawidek gprintln(" sectorsize: %u", pp->sectorsize); 1339679f8b7eSPawel Jakub Dawidek gprintln(" stripesize: %u", pp->stripesize); 1340679f8b7eSPawel Jakub Dawidek gprintln(" stripeoffset: %u", pp->stripeoffset); 1341679f8b7eSPawel Jakub Dawidek gprintln(" access: r%dw%de%d", pp->acr, pp->acw, 1342679f8b7eSPawel Jakub Dawidek pp->ace); 1343679f8b7eSPawel Jakub Dawidek gprintln(" flags: %s (0x%04x)", 1344679f8b7eSPawel Jakub Dawidek provider_flags_to_string(pp, flags, sizeof(flags)), 1345679f8b7eSPawel Jakub Dawidek pp->flags); 1346679f8b7eSPawel Jakub Dawidek gprintln(" error: %d", pp->error); 1347679f8b7eSPawel Jakub Dawidek gprintln(" nstart: %u", pp->nstart); 1348679f8b7eSPawel Jakub Dawidek gprintln(" nend: %u", pp->nend); 1349679f8b7eSPawel Jakub Dawidek if (LIST_EMPTY(&pp->consumers)) 1350679f8b7eSPawel Jakub Dawidek gprintln(" consumers: none"); 1351679f8b7eSPawel Jakub Dawidek } else { 1352679f8b7eSPawel Jakub Dawidek gprintf("provider: %s (%p), access=r%dw%de%d", 1353679f8b7eSPawel Jakub Dawidek pp->name, pp, pp->acr, pp->acw, pp->ace); 1354679f8b7eSPawel Jakub Dawidek if (pp->flags != 0) { 13556d66da20SUlf Lilleengen db_printf(", flags=%s (0x%04x)", 1356679f8b7eSPawel Jakub Dawidek provider_flags_to_string(pp, flags, sizeof(flags)), 1357679f8b7eSPawel Jakub Dawidek pp->flags); 1358679f8b7eSPawel Jakub Dawidek } 13596d66da20SUlf Lilleengen db_printf("\n"); 1360679f8b7eSPawel Jakub Dawidek } 1361679f8b7eSPawel Jakub Dawidek if (!LIST_EMPTY(&pp->consumers)) { 1362f02642d7SPawel Jakub Dawidek LIST_FOREACH(cp, &pp->consumers, consumers) { 1363679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(indent + 2, cp); 1364f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1365f02642d7SPawel Jakub Dawidek break; 1366f02642d7SPawel Jakub Dawidek } 1367679f8b7eSPawel Jakub Dawidek } 1368679f8b7eSPawel Jakub Dawidek } 1369679f8b7eSPawel Jakub Dawidek 1370679f8b7eSPawel Jakub Dawidek static void 1371679f8b7eSPawel Jakub Dawidek db_show_geom_geom(int indent, struct g_geom *gp) 1372679f8b7eSPawel Jakub Dawidek { 1373679f8b7eSPawel Jakub Dawidek struct g_provider *pp; 1374679f8b7eSPawel Jakub Dawidek struct g_consumer *cp; 1375679f8b7eSPawel Jakub Dawidek char flags[64]; 1376679f8b7eSPawel Jakub Dawidek 1377679f8b7eSPawel Jakub Dawidek if (indent == 0) { 1378679f8b7eSPawel Jakub Dawidek gprintln("geom: %s (%p)", gp->name, gp); 1379679f8b7eSPawel Jakub Dawidek gprintln(" class: %s (%p)", gp->class->name, gp->class); 1380679f8b7eSPawel Jakub Dawidek gprintln(" flags: %s (0x%04x)", 1381679f8b7eSPawel Jakub Dawidek geom_flags_to_string(gp, flags, sizeof(flags)), gp->flags); 1382679f8b7eSPawel Jakub Dawidek gprintln(" rank: %d", gp->rank); 1383679f8b7eSPawel Jakub Dawidek if (LIST_EMPTY(&gp->provider)) 1384679f8b7eSPawel Jakub Dawidek gprintln(" providers: none"); 1385679f8b7eSPawel Jakub Dawidek if (LIST_EMPTY(&gp->consumer)) 1386679f8b7eSPawel Jakub Dawidek gprintln(" consumers: none"); 1387679f8b7eSPawel Jakub Dawidek } else { 1388679f8b7eSPawel Jakub Dawidek gprintf("geom: %s (%p), rank=%d", gp->name, gp, gp->rank); 1389679f8b7eSPawel Jakub Dawidek if (gp->flags != 0) { 13906d66da20SUlf Lilleengen db_printf(", flags=%s (0x%04x)", 1391679f8b7eSPawel Jakub Dawidek geom_flags_to_string(gp, flags, sizeof(flags)), 1392679f8b7eSPawel Jakub Dawidek gp->flags); 1393679f8b7eSPawel Jakub Dawidek } 13946d66da20SUlf Lilleengen db_printf("\n"); 1395679f8b7eSPawel Jakub Dawidek } 1396679f8b7eSPawel Jakub Dawidek if (!LIST_EMPTY(&gp->provider)) { 1397f02642d7SPawel Jakub Dawidek LIST_FOREACH(pp, &gp->provider, provider) { 1398679f8b7eSPawel Jakub Dawidek db_show_geom_provider(indent + 2, pp); 1399f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1400f02642d7SPawel Jakub Dawidek break; 1401f02642d7SPawel Jakub Dawidek } 1402679f8b7eSPawel Jakub Dawidek } 1403679f8b7eSPawel Jakub Dawidek if (!LIST_EMPTY(&gp->consumer)) { 1404f02642d7SPawel Jakub Dawidek LIST_FOREACH(cp, &gp->consumer, consumer) { 1405679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(indent + 2, cp); 1406f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1407f02642d7SPawel Jakub Dawidek break; 1408f02642d7SPawel Jakub Dawidek } 1409679f8b7eSPawel Jakub Dawidek } 1410679f8b7eSPawel Jakub Dawidek } 1411679f8b7eSPawel Jakub Dawidek 1412679f8b7eSPawel Jakub Dawidek static void 1413679f8b7eSPawel Jakub Dawidek db_show_geom_class(struct g_class *mp) 1414679f8b7eSPawel Jakub Dawidek { 1415679f8b7eSPawel Jakub Dawidek struct g_geom *gp; 1416679f8b7eSPawel Jakub Dawidek 14176d66da20SUlf Lilleengen db_printf("class: %s (%p)\n", mp->name, mp); 1418f02642d7SPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) { 1419679f8b7eSPawel Jakub Dawidek db_show_geom_geom(2, gp); 1420f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1421f02642d7SPawel Jakub Dawidek break; 1422f02642d7SPawel Jakub Dawidek } 1423679f8b7eSPawel Jakub Dawidek } 1424679f8b7eSPawel Jakub Dawidek 1425679f8b7eSPawel Jakub Dawidek /* 1426679f8b7eSPawel Jakub Dawidek * Print the GEOM topology or the given object. 1427679f8b7eSPawel Jakub Dawidek */ 1428679f8b7eSPawel Jakub Dawidek DB_SHOW_COMMAND(geom, db_show_geom) 1429679f8b7eSPawel Jakub Dawidek { 1430679f8b7eSPawel Jakub Dawidek struct g_class *mp; 1431679f8b7eSPawel Jakub Dawidek 1432679f8b7eSPawel Jakub Dawidek if (!have_addr) { 1433679f8b7eSPawel Jakub Dawidek /* No address given, print the entire topology. */ 1434679f8b7eSPawel Jakub Dawidek LIST_FOREACH(mp, &g_classes, class) { 1435679f8b7eSPawel Jakub Dawidek db_show_geom_class(mp); 14366d66da20SUlf Lilleengen db_printf("\n"); 1437f02642d7SPawel Jakub Dawidek if (db_pager_quit) 1438f02642d7SPawel Jakub Dawidek break; 1439679f8b7eSPawel Jakub Dawidek } 1440679f8b7eSPawel Jakub Dawidek } else { 1441679f8b7eSPawel Jakub Dawidek switch (g_valid_obj((void *)addr)) { 1442679f8b7eSPawel Jakub Dawidek case 1: 1443679f8b7eSPawel Jakub Dawidek db_show_geom_class((struct g_class *)addr); 1444679f8b7eSPawel Jakub Dawidek break; 1445679f8b7eSPawel Jakub Dawidek case 2: 1446679f8b7eSPawel Jakub Dawidek db_show_geom_geom(0, (struct g_geom *)addr); 1447679f8b7eSPawel Jakub Dawidek break; 1448679f8b7eSPawel Jakub Dawidek case 3: 1449679f8b7eSPawel Jakub Dawidek db_show_geom_consumer(0, (struct g_consumer *)addr); 1450679f8b7eSPawel Jakub Dawidek break; 1451679f8b7eSPawel Jakub Dawidek case 4: 1452679f8b7eSPawel Jakub Dawidek db_show_geom_provider(0, (struct g_provider *)addr); 1453679f8b7eSPawel Jakub Dawidek break; 1454679f8b7eSPawel Jakub Dawidek default: 14556d66da20SUlf Lilleengen db_printf("Not a GEOM object.\n"); 1456679f8b7eSPawel Jakub Dawidek break; 1457679f8b7eSPawel Jakub Dawidek } 1458679f8b7eSPawel Jakub Dawidek } 1459679f8b7eSPawel Jakub Dawidek } 1460679f8b7eSPawel Jakub Dawidek 1461bf7d2c17SUlf Lilleengen static void 1462bf7d2c17SUlf Lilleengen db_print_bio_cmd(struct bio *bp) 1463bf7d2c17SUlf Lilleengen { 14646d66da20SUlf Lilleengen db_printf(" cmd: "); 1465bf7d2c17SUlf Lilleengen switch (bp->bio_cmd) { 14666d66da20SUlf Lilleengen case BIO_READ: db_printf("BIO_READ"); break; 14676d66da20SUlf Lilleengen case BIO_WRITE: db_printf("BIO_WRITE"); break; 14686d66da20SUlf Lilleengen case BIO_DELETE: db_printf("BIO_DELETE"); break; 14696d66da20SUlf Lilleengen case BIO_GETATTR: db_printf("BIO_GETATTR"); break; 14706d66da20SUlf Lilleengen case BIO_FLUSH: db_printf("BIO_FLUSH"); break; 14716d66da20SUlf Lilleengen case BIO_CMD0: db_printf("BIO_CMD0"); break; 14726d66da20SUlf Lilleengen case BIO_CMD1: db_printf("BIO_CMD1"); break; 14736d66da20SUlf Lilleengen case BIO_CMD2: db_printf("BIO_CMD2"); break; 1474*9a6844d5SKenneth D. Merry case BIO_ZONE: db_printf("BIO_ZONE"); break; 14756d66da20SUlf Lilleengen default: db_printf("UNKNOWN"); break; 1476bf7d2c17SUlf Lilleengen } 14776d66da20SUlf Lilleengen db_printf("\n"); 1478bf7d2c17SUlf Lilleengen } 1479bf7d2c17SUlf Lilleengen 1480bf7d2c17SUlf Lilleengen static void 1481bf7d2c17SUlf Lilleengen db_print_bio_flags(struct bio *bp) 1482bf7d2c17SUlf Lilleengen { 1483bf7d2c17SUlf Lilleengen int comma; 1484bf7d2c17SUlf Lilleengen 1485bf7d2c17SUlf Lilleengen comma = 0; 14866d66da20SUlf Lilleengen db_printf(" flags: "); 1487bf7d2c17SUlf Lilleengen if (bp->bio_flags & BIO_ERROR) { 14886d66da20SUlf Lilleengen db_printf("BIO_ERROR"); 1489bf7d2c17SUlf Lilleengen comma = 1; 1490bf7d2c17SUlf Lilleengen } 1491bf7d2c17SUlf Lilleengen if (bp->bio_flags & BIO_DONE) { 14926d66da20SUlf Lilleengen db_printf("%sBIO_DONE", (comma ? ", " : "")); 1493bf7d2c17SUlf Lilleengen comma = 1; 1494bf7d2c17SUlf Lilleengen } 1495bf7d2c17SUlf Lilleengen if (bp->bio_flags & BIO_ONQUEUE) 14966d66da20SUlf Lilleengen db_printf("%sBIO_ONQUEUE", (comma ? ", " : "")); 14976d66da20SUlf Lilleengen db_printf("\n"); 1498bf7d2c17SUlf Lilleengen } 1499bf7d2c17SUlf Lilleengen 1500bf7d2c17SUlf Lilleengen /* 1501bf7d2c17SUlf Lilleengen * Print useful information in a BIO 1502bf7d2c17SUlf Lilleengen */ 1503bf7d2c17SUlf Lilleengen DB_SHOW_COMMAND(bio, db_show_bio) 1504bf7d2c17SUlf Lilleengen { 1505bf7d2c17SUlf Lilleengen struct bio *bp; 1506bf7d2c17SUlf Lilleengen 1507bf7d2c17SUlf Lilleengen if (have_addr) { 1508bf7d2c17SUlf Lilleengen bp = (struct bio *)addr; 15096d66da20SUlf Lilleengen db_printf("BIO %p\n", bp); 1510bf7d2c17SUlf Lilleengen db_print_bio_cmd(bp); 1511bf7d2c17SUlf Lilleengen db_print_bio_flags(bp); 15129a8fa125SWarner Losh db_printf(" cflags: 0x%hx\n", bp->bio_cflags); 15139a8fa125SWarner Losh db_printf(" pflags: 0x%hx\n", bp->bio_pflags); 15144147dd02SUlf Lilleengen db_printf(" offset: %jd\n", (intmax_t)bp->bio_offset); 15154147dd02SUlf Lilleengen db_printf(" length: %jd\n", (intmax_t)bp->bio_length); 15166d66da20SUlf Lilleengen db_printf(" bcount: %ld\n", bp->bio_bcount); 15176d66da20SUlf Lilleengen db_printf(" resid: %ld\n", bp->bio_resid); 15184147dd02SUlf Lilleengen db_printf(" completed: %jd\n", (intmax_t)bp->bio_completed); 15196d66da20SUlf Lilleengen db_printf(" children: %u\n", bp->bio_children); 15206d66da20SUlf Lilleengen db_printf(" inbed: %u\n", bp->bio_inbed); 15216d66da20SUlf Lilleengen db_printf(" error: %d\n", bp->bio_error); 15226d66da20SUlf Lilleengen db_printf(" parent: %p\n", bp->bio_parent); 15236d66da20SUlf Lilleengen db_printf(" driver1: %p\n", bp->bio_driver1); 15246d66da20SUlf Lilleengen db_printf(" driver2: %p\n", bp->bio_driver2); 15256d66da20SUlf Lilleengen db_printf(" caller1: %p\n", bp->bio_caller1); 15266d66da20SUlf Lilleengen db_printf(" caller2: %p\n", bp->bio_caller2); 15276d66da20SUlf Lilleengen db_printf(" bio_from: %p\n", bp->bio_from); 15286d66da20SUlf Lilleengen db_printf(" bio_to: %p\n", bp->bio_to); 1529bf7d2c17SUlf Lilleengen } 1530bf7d2c17SUlf Lilleengen } 1531bf7d2c17SUlf Lilleengen 1532679f8b7eSPawel Jakub Dawidek #undef gprintf 1533679f8b7eSPawel Jakub Dawidek #undef gprintln 1534679f8b7eSPawel Jakub Dawidek #undef ADDFLAG 1535679f8b7eSPawel Jakub Dawidek 1536679f8b7eSPawel Jakub Dawidek #endif /* DDB */ 1537