dm_dev.c revision 1.2.2.2
1 1.2.2.2 mjf /* $NetBSD: dm_dev.c,v 1.2.2.2 2009/01/17 13:28:53 mjf Exp $ */ 2 1.2.2.2 mjf 3 1.2.2.2 mjf /* 4 1.2.2.2 mjf * Copyright (c) 2008 The NetBSD Foundation, Inc. 5 1.2.2.2 mjf * All rights reserved. 6 1.2.2.2 mjf * 7 1.2.2.2 mjf * This code is derived from software contributed to The NetBSD Foundation 8 1.2.2.2 mjf * by Adam Hamsik. 9 1.2.2.2 mjf * 10 1.2.2.2 mjf * Redistribution and use in source and binary forms, with or without 11 1.2.2.2 mjf * modification, are permitted provided that the following conditions 12 1.2.2.2 mjf * are met: 13 1.2.2.2 mjf * 1. Redistributions of source code must retain the above copyright 14 1.2.2.2 mjf * notice, this list of conditions and the following disclaimer. 15 1.2.2.2 mjf * 2. Redistributions in binary form must reproduce the above copyright 16 1.2.2.2 mjf * notice, this list of conditions and the following disclaimer in the 17 1.2.2.2 mjf * documentation and/or other materials provided with the distribution. 18 1.2.2.2 mjf * 19 1.2.2.2 mjf * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS 20 1.2.2.2 mjf * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 21 1.2.2.2 mjf * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 22 1.2.2.2 mjf * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS 23 1.2.2.2 mjf * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 24 1.2.2.2 mjf * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 25 1.2.2.2 mjf * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 26 1.2.2.2 mjf * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 27 1.2.2.2 mjf * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 28 1.2.2.2 mjf * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 29 1.2.2.2 mjf * POSSIBILITY OF SUCH DAMAGE. 30 1.2.2.2 mjf */ 31 1.2.2.2 mjf 32 1.2.2.2 mjf #include <sys/types.h> 33 1.2.2.2 mjf #include <sys/param.h> 34 1.2.2.2 mjf 35 1.2.2.2 mjf #include <sys/disklabel.h> 36 1.2.2.2 mjf #include <sys/ioctl.h> 37 1.2.2.2 mjf #include <sys/ioccom.h> 38 1.2.2.2 mjf #include <sys/kmem.h> 39 1.2.2.2 mjf 40 1.2.2.2 mjf #include "netbsd-dm.h" 41 1.2.2.2 mjf #include "dm.h" 42 1.2.2.2 mjf 43 1.2.2.2 mjf static dm_dev_t* dm_dev_lookup_name(const char *); 44 1.2.2.2 mjf static dm_dev_t* dm_dev_lookup_uuid(const char *); 45 1.2.2.2 mjf static dm_dev_t* dm_dev_lookup_minor(int); 46 1.2.2.2 mjf 47 1.2.2.2 mjf static struct dm_dev_head dm_dev_list = 48 1.2.2.2 mjf TAILQ_HEAD_INITIALIZER(dm_dev_list); 49 1.2.2.2 mjf 50 1.2.2.2 mjf kmutex_t dm_dev_mutex; 51 1.2.2.2 mjf 52 1.2.2.2 mjf __inline static void 53 1.2.2.2 mjf disable_dev(dm_dev_t *dmv) 54 1.2.2.2 mjf { 55 1.2.2.2 mjf TAILQ_REMOVE(&dm_dev_list, dmv, next_devlist); 56 1.2.2.2 mjf mutex_enter(&dmv->dev_mtx); 57 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 58 1.2.2.2 mjf while(dmv->ref_cnt != 0) 59 1.2.2.2 mjf cv_wait(&dmv->dev_cv, &dmv->dev_mtx); 60 1.2.2.2 mjf mutex_exit(&dmv->dev_mtx); 61 1.2.2.2 mjf } 62 1.2.2.2 mjf 63 1.2.2.2 mjf /* 64 1.2.2.2 mjf * Generic function used to lookup dm_dev_t. Calling with dm_dev_name 65 1.2.2.2 mjf * and dm_dev_uuid NULL is allowed. 66 1.2.2.2 mjf */ 67 1.2.2.2 mjf dm_dev_t* 68 1.2.2.2 mjf dm_dev_lookup(const char *dm_dev_name, const char *dm_dev_uuid, 69 1.2.2.2 mjf int dm_dev_minor) 70 1.2.2.2 mjf { 71 1.2.2.2 mjf dm_dev_t *dmv; 72 1.2.2.2 mjf 73 1.2.2.2 mjf dmv = NULL; 74 1.2.2.2 mjf mutex_enter(&dm_dev_mutex); 75 1.2.2.2 mjf 76 1.2.2.2 mjf /* KASSERT(dm_dev_name != NULL && dm_dev_uuid != NULL && dm_dev_minor > 0); */ 77 1.2.2.2 mjf if (dm_dev_minor > 0) 78 1.2.2.2 mjf if ((dmv = dm_dev_lookup_minor(dm_dev_minor)) != NULL){ 79 1.2.2.2 mjf dm_dev_busy(dmv); 80 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 81 1.2.2.2 mjf return dmv; 82 1.2.2.2 mjf } 83 1.2.2.2 mjf 84 1.2.2.2 mjf if (dm_dev_name != NULL) 85 1.2.2.2 mjf if ((dmv = dm_dev_lookup_name(dm_dev_name)) != NULL){ 86 1.2.2.2 mjf dm_dev_busy(dmv); 87 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 88 1.2.2.2 mjf return dmv; 89 1.2.2.2 mjf } 90 1.2.2.2 mjf 91 1.2.2.2 mjf if (dm_dev_uuid != NULL) 92 1.2.2.2 mjf if ((dmv = dm_dev_lookup_name(dm_dev_uuid)) != NULL){ 93 1.2.2.2 mjf dm_dev_busy(dmv); 94 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 95 1.2.2.2 mjf return dmv; 96 1.2.2.2 mjf } 97 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 98 1.2.2.2 mjf return NULL; 99 1.2.2.2 mjf } 100 1.2.2.2 mjf 101 1.2.2.2 mjf 102 1.2.2.2 mjf /* 103 1.2.2.2 mjf * Lookup device with its minor number. 104 1.2.2.2 mjf */ 105 1.2.2.2 mjf static dm_dev_t* 106 1.2.2.2 mjf dm_dev_lookup_minor(int dm_dev_minor) 107 1.2.2.2 mjf { 108 1.2.2.2 mjf dm_dev_t *dmv; 109 1.2.2.2 mjf 110 1.2.2.2 mjf TAILQ_FOREACH(dmv, &dm_dev_list, next_devlist){ 111 1.2.2.2 mjf if (dm_dev_minor == dmv->minor) 112 1.2.2.2 mjf return dmv; 113 1.2.2.2 mjf } 114 1.2.2.2 mjf 115 1.2.2.2 mjf return NULL; 116 1.2.2.2 mjf } 117 1.2.2.2 mjf 118 1.2.2.2 mjf /* 119 1.2.2.2 mjf * Lookup device with it's device name. 120 1.2.2.2 mjf */ 121 1.2.2.2 mjf static dm_dev_t* 122 1.2.2.2 mjf dm_dev_lookup_name(const char *dm_dev_name) 123 1.2.2.2 mjf { 124 1.2.2.2 mjf dm_dev_t *dmv; 125 1.2.2.2 mjf int dlen; int slen; 126 1.2.2.2 mjf 127 1.2.2.2 mjf slen = strlen(dm_dev_name); 128 1.2.2.2 mjf 129 1.2.2.2 mjf if (slen == 0) 130 1.2.2.2 mjf return NULL; 131 1.2.2.2 mjf 132 1.2.2.2 mjf TAILQ_FOREACH(dmv, &dm_dev_list, next_devlist){ 133 1.2.2.2 mjf 134 1.2.2.2 mjf dlen = strlen(dmv->name); 135 1.2.2.2 mjf 136 1.2.2.2 mjf if(slen != dlen) 137 1.2.2.2 mjf continue; 138 1.2.2.2 mjf 139 1.2.2.2 mjf if (strncmp(dm_dev_name, dmv->name, slen) == 0) 140 1.2.2.2 mjf return dmv; 141 1.2.2.2 mjf } 142 1.2.2.2 mjf 143 1.2.2.2 mjf return NULL; 144 1.2.2.2 mjf } 145 1.2.2.2 mjf 146 1.2.2.2 mjf /* 147 1.2.2.2 mjf * Lookup device with it's device uuid. Used mostly by LVM2tools. 148 1.2.2.2 mjf */ 149 1.2.2.2 mjf static dm_dev_t* 150 1.2.2.2 mjf dm_dev_lookup_uuid(const char *dm_dev_uuid) 151 1.2.2.2 mjf { 152 1.2.2.2 mjf dm_dev_t *dmv; 153 1.2.2.2 mjf size_t len; 154 1.2.2.2 mjf 155 1.2.2.2 mjf len = 0; 156 1.2.2.2 mjf len = strlen(dm_dev_uuid); 157 1.2.2.2 mjf 158 1.2.2.2 mjf if (len == 0) 159 1.2.2.2 mjf return NULL; 160 1.2.2.2 mjf 161 1.2.2.2 mjf TAILQ_FOREACH(dmv, &dm_dev_list, next_devlist){ 162 1.2.2.2 mjf 163 1.2.2.2 mjf if (strlen(dmv->uuid) != len) 164 1.2.2.2 mjf continue; 165 1.2.2.2 mjf 166 1.2.2.2 mjf if (strncmp(dm_dev_uuid, dmv->uuid, strlen(dmv->uuid)) == 0) 167 1.2.2.2 mjf return dmv; 168 1.2.2.2 mjf } 169 1.2.2.2 mjf 170 1.2.2.2 mjf return NULL; 171 1.2.2.2 mjf } 172 1.2.2.2 mjf 173 1.2.2.2 mjf /* 174 1.2.2.2 mjf * Insert new device to the global list of devices. 175 1.2.2.2 mjf */ 176 1.2.2.2 mjf int 177 1.2.2.2 mjf dm_dev_insert(dm_dev_t *dev) 178 1.2.2.2 mjf { 179 1.2.2.2 mjf dm_dev_t *dmv; 180 1.2.2.2 mjf int r; 181 1.2.2.2 mjf 182 1.2.2.2 mjf dmv = NULL; 183 1.2.2.2 mjf r = 0; 184 1.2.2.2 mjf 185 1.2.2.2 mjf KASSERT(dev != NULL); 186 1.2.2.2 mjf mutex_enter(&dm_dev_mutex); 187 1.2.2.2 mjf if (((dmv = dm_dev_lookup_uuid(dev->uuid)) == NULL) && 188 1.2.2.2 mjf ((dmv = dm_dev_lookup_name(dev->name)) == NULL) && 189 1.2.2.2 mjf ((dmv = dm_dev_lookup_minor(dev->minor)) == NULL)){ 190 1.2.2.2 mjf 191 1.2.2.2 mjf TAILQ_INSERT_TAIL(&dm_dev_list, dev, next_devlist); 192 1.2.2.2 mjf 193 1.2.2.2 mjf } else 194 1.2.2.2 mjf r = EEXIST; 195 1.2.2.2 mjf 196 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 197 1.2.2.2 mjf return r; 198 1.2.2.2 mjf } 199 1.2.2.2 mjf 200 1.2.2.2 mjf #ifdef notyet 201 1.2.2.2 mjf /* 202 1.2.2.2 mjf * Lookup device with its minor number. 203 1.2.2.2 mjf */ 204 1.2.2.2 mjf int 205 1.2.2.2 mjf dm_dev_test_minor(int dm_dev_minor) 206 1.2.2.2 mjf { 207 1.2.2.2 mjf dm_dev_t *dmv; 208 1.2.2.2 mjf 209 1.2.2.2 mjf mutex_enter(&dm_dev_mutex); 210 1.2.2.2 mjf TAILQ_FOREACH(dmv, &dm_dev_list, next_devlist){ 211 1.2.2.2 mjf if (dm_dev_minor == dmv->minor){ 212 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 213 1.2.2.2 mjf return 1; 214 1.2.2.2 mjf } 215 1.2.2.2 mjf } 216 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 217 1.2.2.2 mjf 218 1.2.2.2 mjf return 0; 219 1.2.2.2 mjf } 220 1.2.2.2 mjf #endif 221 1.2.2.2 mjf 222 1.2.2.2 mjf /* 223 1.2.2.2 mjf * Remove device selected with dm_dev from global list of devices. 224 1.2.2.2 mjf */ 225 1.2.2.2 mjf dm_dev_t* 226 1.2.2.2 mjf dm_dev_rem(const char *dm_dev_name, const char *dm_dev_uuid, 227 1.2.2.2 mjf int dm_dev_minor) 228 1.2.2.2 mjf { 229 1.2.2.2 mjf dm_dev_t *dmv; 230 1.2.2.2 mjf dmv = NULL; 231 1.2.2.2 mjf 232 1.2.2.2 mjf mutex_enter(&dm_dev_mutex); 233 1.2.2.2 mjf 234 1.2.2.2 mjf if (dm_dev_minor > 0) 235 1.2.2.2 mjf if ((dmv = dm_dev_lookup_minor(dm_dev_minor)) != NULL){ 236 1.2.2.2 mjf disable_dev(dmv); 237 1.2.2.2 mjf return dmv; 238 1.2.2.2 mjf } 239 1.2.2.2 mjf 240 1.2.2.2 mjf if (dm_dev_name != NULL) 241 1.2.2.2 mjf if ((dmv = dm_dev_lookup_name(dm_dev_name)) != NULL){ 242 1.2.2.2 mjf disable_dev(dmv); 243 1.2.2.2 mjf return dmv; 244 1.2.2.2 mjf } 245 1.2.2.2 mjf 246 1.2.2.2 mjf if (dm_dev_uuid != NULL) 247 1.2.2.2 mjf if ((dmv = dm_dev_lookup_name(dm_dev_uuid)) != NULL){ 248 1.2.2.2 mjf disable_dev(dmv); 249 1.2.2.2 mjf return dmv; 250 1.2.2.2 mjf } 251 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 252 1.2.2.2 mjf 253 1.2.2.2 mjf return NULL; 254 1.2.2.2 mjf } 255 1.2.2.2 mjf 256 1.2.2.2 mjf /* 257 1.2.2.2 mjf * Destroy all devices created in device-mapper. Remove all tables 258 1.2.2.2 mjf * free all allocated memmory. 259 1.2.2.2 mjf */ 260 1.2.2.2 mjf int 261 1.2.2.2 mjf dm_dev_destroy(void) 262 1.2.2.2 mjf { 263 1.2.2.2 mjf dm_dev_t *dmv; 264 1.2.2.2 mjf mutex_enter(&dm_dev_mutex); 265 1.2.2.2 mjf 266 1.2.2.2 mjf while (TAILQ_FIRST(&dm_dev_list) != NULL){ 267 1.2.2.2 mjf 268 1.2.2.2 mjf dmv = TAILQ_FIRST(&dm_dev_list); 269 1.2.2.2 mjf 270 1.2.2.2 mjf TAILQ_REMOVE(&dm_dev_list, TAILQ_FIRST(&dm_dev_list), 271 1.2.2.2 mjf next_devlist); 272 1.2.2.2 mjf 273 1.2.2.2 mjf mutex_enter(&dmv->dev_mtx); 274 1.2.2.2 mjf 275 1.2.2.2 mjf while (dmv->ref_cnt != 0) 276 1.2.2.2 mjf cv_wait(&dmv->dev_cv, &dmv->dev_mtx); 277 1.2.2.2 mjf 278 1.2.2.2 mjf /* Destroy active table first. */ 279 1.2.2.2 mjf dm_table_destroy(&dmv->table_head, DM_TABLE_ACTIVE); 280 1.2.2.2 mjf 281 1.2.2.2 mjf /* Destroy inactive table if exits, too. */ 282 1.2.2.2 mjf dm_table_destroy(&dmv->table_head, DM_TABLE_INACTIVE); 283 1.2.2.2 mjf 284 1.2.2.2 mjf dm_table_head_destroy(&dmv->table_head); 285 1.2.2.2 mjf 286 1.2.2.2 mjf mutex_exit(&dmv->dev_mtx); 287 1.2.2.2 mjf mutex_destroy(&dmv->dev_mtx); 288 1.2.2.2 mjf cv_destroy(&dmv->dev_cv); 289 1.2.2.2 mjf 290 1.2.2.2 mjf (void)kmem_free(dmv, sizeof(dm_dev_t)); 291 1.2.2.2 mjf } 292 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 293 1.2.2.2 mjf 294 1.2.2.2 mjf mutex_destroy(&dm_dev_mutex); 295 1.2.2.2 mjf return 0; 296 1.2.2.2 mjf } 297 1.2.2.2 mjf 298 1.2.2.2 mjf /* 299 1.2.2.2 mjf * Allocate new device entry. 300 1.2.2.2 mjf */ 301 1.2.2.2 mjf dm_dev_t* 302 1.2.2.2 mjf dm_dev_alloc() 303 1.2.2.2 mjf { 304 1.2.2.2 mjf dm_dev_t *dmv; 305 1.2.2.2 mjf 306 1.2.2.2 mjf dmv = kmem_zalloc(sizeof(dm_dev_t), KM_NOSLEEP); 307 1.2.2.2 mjf dmv->dk_label = kmem_zalloc(sizeof(struct disklabel), KM_NOSLEEP); 308 1.2.2.2 mjf 309 1.2.2.2 mjf return dmv; 310 1.2.2.2 mjf } 311 1.2.2.2 mjf 312 1.2.2.2 mjf /* 313 1.2.2.2 mjf * Freed device entry. 314 1.2.2.2 mjf */ 315 1.2.2.2 mjf int 316 1.2.2.2 mjf dm_dev_free(dm_dev_t *dmv) 317 1.2.2.2 mjf { 318 1.2.2.2 mjf KASSERT(dmv != NULL); 319 1.2.2.2 mjf 320 1.2.2.2 mjf if (dmv->dk_label != NULL) 321 1.2.2.2 mjf (void)kmem_free(dmv->dk_label, sizeof(struct disklabel)); 322 1.2.2.2 mjf 323 1.2.2.2 mjf (void)kmem_free(dmv, sizeof(dm_dev_t)); 324 1.2.2.2 mjf 325 1.2.2.2 mjf return 0; 326 1.2.2.2 mjf } 327 1.2.2.2 mjf 328 1.2.2.2 mjf void 329 1.2.2.2 mjf dm_dev_busy(dm_dev_t *dmv) 330 1.2.2.2 mjf { 331 1.2.2.2 mjf mutex_enter(&dmv->dev_mtx); 332 1.2.2.2 mjf dmv->ref_cnt++; 333 1.2.2.2 mjf mutex_exit(&dmv->dev_mtx); 334 1.2.2.2 mjf } 335 1.2.2.2 mjf 336 1.2.2.2 mjf void 337 1.2.2.2 mjf dm_dev_unbusy(dm_dev_t *dmv) 338 1.2.2.2 mjf { 339 1.2.2.2 mjf KASSERT(dmv->ref_cnt != 0); 340 1.2.2.2 mjf 341 1.2.2.2 mjf mutex_enter(&dmv->dev_mtx); 342 1.2.2.2 mjf if (--dmv->ref_cnt == 0) 343 1.2.2.2 mjf cv_broadcast(&dmv->dev_cv); 344 1.2.2.2 mjf mutex_exit(&dmv->dev_mtx); 345 1.2.2.2 mjf } 346 1.2.2.2 mjf 347 1.2.2.2 mjf /* 348 1.2.2.2 mjf * Return prop_array of dm_targer_list dictionaries. 349 1.2.2.2 mjf */ 350 1.2.2.2 mjf prop_array_t 351 1.2.2.2 mjf dm_dev_prop_list(void) 352 1.2.2.2 mjf { 353 1.2.2.2 mjf dm_dev_t *dmv; 354 1.2.2.2 mjf prop_array_t dev_array; 355 1.2.2.2 mjf prop_dictionary_t dev_dict; 356 1.2.2.2 mjf 357 1.2.2.2 mjf dev_array = prop_array_create(); 358 1.2.2.2 mjf 359 1.2.2.2 mjf mutex_enter(&dm_dev_mutex); 360 1.2.2.2 mjf 361 1.2.2.2 mjf TAILQ_FOREACH(dmv, &dm_dev_list, next_devlist) { 362 1.2.2.2 mjf dev_dict = prop_dictionary_create(); 363 1.2.2.2 mjf 364 1.2.2.2 mjf prop_dictionary_set_cstring(dev_dict, DM_DEV_NAME, dmv->name); 365 1.2.2.2 mjf prop_dictionary_set_uint32(dev_dict, DM_DEV_DEV, dmv->minor); 366 1.2.2.2 mjf 367 1.2.2.2 mjf prop_array_add(dev_array, dev_dict); 368 1.2.2.2 mjf prop_object_release(dev_dict); 369 1.2.2.2 mjf } 370 1.2.2.2 mjf 371 1.2.2.2 mjf mutex_exit(&dm_dev_mutex); 372 1.2.2.2 mjf return dev_array; 373 1.2.2.2 mjf } 374 1.2.2.2 mjf 375 1.2.2.2 mjf /* 376 1.2.2.2 mjf * Initialize global device mutex. 377 1.2.2.2 mjf */ 378 1.2.2.2 mjf int 379 1.2.2.2 mjf dm_dev_init() 380 1.2.2.2 mjf { 381 1.2.2.2 mjf TAILQ_INIT(&dm_dev_list); /* initialize global dev list */ 382 1.2.2.2 mjf mutex_init(&dm_dev_mutex, MUTEX_DEFAULT, IPL_NONE); 383 1.2.2.2 mjf return 0; 384 1.2.2.2 mjf } 385
Indexes created Tue Sep 30 11:09:46 GMT 2025