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