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