[28ed0d9] | 1 | /*
|
---|
[4285f384] | 2 | * Copyright (c) 2025 Jiri Svoboda
|
---|
[28ed0d9] | 3 | * All rights reserved.
|
---|
| 4 | *
|
---|
| 5 | * Redistribution and use in source and binary forms, with or without
|
---|
| 6 | * modification, are permitted provided that the following conditions
|
---|
| 7 | * are met:
|
---|
| 8 | *
|
---|
| 9 | * - Redistributions of source code must retain the above copyright
|
---|
| 10 | * notice, this list of conditions and the following disclaimer.
|
---|
| 11 | * - Redistributions in binary form must reproduce the above copyright
|
---|
| 12 | * notice, this list of conditions and the following disclaimer in the
|
---|
| 13 | * documentation and/or other materials provided with the distribution.
|
---|
| 14 | * - The name of the author may not be used to endorse or promote products
|
---|
| 15 | * derived from this software without specific prior written permission.
|
---|
| 16 | *
|
---|
| 17 | * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
|
---|
| 18 | * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
---|
| 19 | * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
|
---|
| 20 | * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
|
---|
| 21 | * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
|
---|
| 22 | * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
---|
| 23 | * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
---|
| 24 | * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
---|
| 25 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
|
---|
| 26 | * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
---|
| 27 | */
|
---|
| 28 |
|
---|
| 29 | /** @addtogroup vbd
|
---|
| 30 | * @{
|
---|
| 31 | */
|
---|
| 32 | /**
|
---|
| 33 | * @file
|
---|
| 34 | */
|
---|
| 35 |
|
---|
| 36 | #include <adt/list.h>
|
---|
[4285f384] | 37 | #include <bd.h>
|
---|
[78d50bd] | 38 | #include <bd_srv.h>
|
---|
| 39 | #include <block.h>
|
---|
[28ed0d9] | 40 | #include <errno.h>
|
---|
[c1694b6b] | 41 | #include <str_error.h>
|
---|
[28ed0d9] | 42 | #include <io/log.h>
|
---|
[5772aa1] | 43 | #include <label/empty.h>
|
---|
| 44 | #include <label/label.h>
|
---|
[78d50bd] | 45 | #include <loc.h>
|
---|
| 46 | #include <stdio.h>
|
---|
[28ed0d9] | 47 | #include <stdlib.h>
|
---|
| 48 | #include <task.h>
|
---|
[6a0d4ce2] | 49 | #include <vbd.h>
|
---|
[28ed0d9] | 50 |
|
---|
| 51 | #include "disk.h"
|
---|
| 52 | #include "types/vbd.h"
|
---|
| 53 |
|
---|
[4c6fd56] | 54 | loc_srv_t *vbds_srv;
|
---|
| 55 |
|
---|
[372df8f] | 56 | static fibril_mutex_t vbds_disks_lock;
|
---|
[28ed0d9] | 57 | static list_t vbds_disks; /* of vbds_disk_t */
|
---|
[e11c527] | 58 | static fibril_mutex_t vbds_parts_lock;
|
---|
[78d50bd] | 59 | static list_t vbds_parts; /* of vbds_part_t */
|
---|
| 60 |
|
---|
[372df8f] | 61 | static category_id_t part_cid;
|
---|
| 62 |
|
---|
[b7fd2a0] | 63 | static errno_t vbds_disk_parts_add(vbds_disk_t *, label_t *);
|
---|
| 64 | static errno_t vbds_disk_parts_remove(vbds_disk_t *, vbds_rem_flag_t);
|
---|
| 65 |
|
---|
| 66 | static errno_t vbds_bd_open(bd_srvs_t *, bd_srv_t *);
|
---|
| 67 | static errno_t vbds_bd_close(bd_srv_t *);
|
---|
| 68 | static errno_t vbds_bd_read_blocks(bd_srv_t *, aoff64_t, size_t, void *, size_t);
|
---|
| 69 | static errno_t vbds_bd_sync_cache(bd_srv_t *, aoff64_t, size_t);
|
---|
| 70 | static errno_t vbds_bd_write_blocks(bd_srv_t *, aoff64_t, size_t, const void *,
|
---|
[78d50bd] | 71 | size_t);
|
---|
[b7fd2a0] | 72 | static errno_t vbds_bd_get_block_size(bd_srv_t *, size_t *);
|
---|
| 73 | static errno_t vbds_bd_get_num_blocks(bd_srv_t *, aoff64_t *);
|
---|
[4285f384] | 74 | static errno_t vbds_bd_eject(bd_srv_t *);
|
---|
[78d50bd] | 75 |
|
---|
[b7fd2a0] | 76 | static errno_t vbds_bsa_translate(vbds_part_t *, aoff64_t, size_t, aoff64_t *);
|
---|
[78d50bd] | 77 |
|
---|
[b7fd2a0] | 78 | static errno_t vbds_part_svc_register(vbds_part_t *);
|
---|
| 79 | static errno_t vbds_part_svc_unregister(vbds_part_t *);
|
---|
| 80 | static errno_t vbds_part_indices_update(vbds_disk_t *);
|
---|
[6439741] | 81 |
|
---|
[c43db5f] | 82 | static vbd_part_id_t vbds_part_id = 1;
|
---|
| 83 |
|
---|
[b7fd2a0] | 84 | static errno_t vbds_label_get_bsize(void *, size_t *);
|
---|
| 85 | static errno_t vbds_label_get_nblocks(void *, aoff64_t *);
|
---|
| 86 | static errno_t vbds_label_read(void *, aoff64_t, size_t, void *);
|
---|
| 87 | static errno_t vbds_label_write(void *, aoff64_t, size_t, const void *);
|
---|
[deacc58d] | 88 |
|
---|
| 89 | /** Block device operations provided by VBD */
|
---|
[78d50bd] | 90 | static bd_ops_t vbds_bd_ops = {
|
---|
| 91 | .open = vbds_bd_open,
|
---|
| 92 | .close = vbds_bd_close,
|
---|
| 93 | .read_blocks = vbds_bd_read_blocks,
|
---|
| 94 | .sync_cache = vbds_bd_sync_cache,
|
---|
| 95 | .write_blocks = vbds_bd_write_blocks,
|
---|
| 96 | .get_block_size = vbds_bd_get_block_size,
|
---|
[4285f384] | 97 | .get_num_blocks = vbds_bd_get_num_blocks,
|
---|
| 98 | .eject = vbds_bd_eject
|
---|
[78d50bd] | 99 | };
|
---|
| 100 |
|
---|
[deacc58d] | 101 | /** Provide disk access to liblabel */
|
---|
| 102 | static label_bd_ops_t vbds_label_bd_ops = {
|
---|
| 103 | .get_bsize = vbds_label_get_bsize,
|
---|
| 104 | .get_nblocks = vbds_label_get_nblocks,
|
---|
| 105 | .read = vbds_label_read,
|
---|
| 106 | .write = vbds_label_write
|
---|
| 107 | };
|
---|
| 108 |
|
---|
[78d50bd] | 109 | static vbds_part_t *bd_srv_part(bd_srv_t *bd)
|
---|
| 110 | {
|
---|
| 111 | return (vbds_part_t *)bd->srvs->sarg;
|
---|
| 112 | }
|
---|
[28ed0d9] | 113 |
|
---|
[3a9cf35] | 114 | static vbds_disk_t *vbds_disk_first(void)
|
---|
| 115 | {
|
---|
| 116 | link_t *link;
|
---|
| 117 |
|
---|
| 118 | link = list_first(&vbds_disks);
|
---|
| 119 | if (link == NULL)
|
---|
| 120 | return NULL;
|
---|
| 121 |
|
---|
| 122 | return list_get_instance(link, vbds_disk_t, ldisks);
|
---|
| 123 | }
|
---|
| 124 |
|
---|
| 125 | static vbds_disk_t *vbds_disk_next(vbds_disk_t *disk)
|
---|
| 126 | {
|
---|
| 127 | link_t *link;
|
---|
| 128 |
|
---|
| 129 | if (disk == NULL)
|
---|
| 130 | return NULL;
|
---|
| 131 |
|
---|
| 132 | link = list_next(&disk->ldisks, &vbds_disks);
|
---|
| 133 | if (link == NULL)
|
---|
| 134 | return NULL;
|
---|
| 135 |
|
---|
| 136 | return list_get_instance(link, vbds_disk_t, ldisks);
|
---|
| 137 | }
|
---|
| 138 |
|
---|
[b7fd2a0] | 139 | errno_t vbds_disks_init(void)
|
---|
[28ed0d9] | 140 | {
|
---|
[b7fd2a0] | 141 | errno_t rc;
|
---|
[372df8f] | 142 |
|
---|
| 143 | fibril_mutex_initialize(&vbds_disks_lock);
|
---|
[28ed0d9] | 144 | list_initialize(&vbds_disks);
|
---|
[e11c527] | 145 | fibril_mutex_initialize(&vbds_parts_lock);
|
---|
[78d50bd] | 146 | list_initialize(&vbds_parts);
|
---|
[372df8f] | 147 |
|
---|
| 148 | rc = loc_category_get_id("partition", &part_cid, 0);
|
---|
| 149 | if (rc != EOK) {
|
---|
| 150 | log_msg(LOG_DEFAULT, LVL_ERROR, "Error looking up partition "
|
---|
| 151 | "category.");
|
---|
| 152 | return EIO;
|
---|
| 153 | }
|
---|
| 154 |
|
---|
| 155 | return EOK;
|
---|
| 156 | }
|
---|
| 157 |
|
---|
[3a9cf35] | 158 | /** Check for new/removed disk devices */
|
---|
[b7fd2a0] | 159 | static errno_t vbds_disks_check_new(void)
|
---|
[372df8f] | 160 | {
|
---|
| 161 | bool already_known;
|
---|
| 162 | category_id_t disk_cat;
|
---|
| 163 | service_id_t *svcs;
|
---|
| 164 | size_t count, i;
|
---|
[3a9cf35] | 165 | vbds_disk_t *cur, *next;
|
---|
[b7fd2a0] | 166 | errno_t rc;
|
---|
[372df8f] | 167 |
|
---|
[3a9cf35] | 168 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_disks_check_new()");
|
---|
| 169 |
|
---|
[372df8f] | 170 | fibril_mutex_lock(&vbds_disks_lock);
|
---|
| 171 |
|
---|
| 172 | rc = loc_category_get_id("disk", &disk_cat, IPC_FLAG_BLOCKING);
|
---|
| 173 | if (rc != EOK) {
|
---|
| 174 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed resolving category 'disk'.");
|
---|
| 175 | fibril_mutex_unlock(&vbds_disks_lock);
|
---|
| 176 | return ENOENT;
|
---|
| 177 | }
|
---|
| 178 |
|
---|
| 179 | rc = loc_category_get_svcs(disk_cat, &svcs, &count);
|
---|
| 180 | if (rc != EOK) {
|
---|
| 181 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed getting list of disk "
|
---|
| 182 | "devices.");
|
---|
| 183 | fibril_mutex_unlock(&vbds_disks_lock);
|
---|
| 184 | return EIO;
|
---|
| 185 | }
|
---|
| 186 |
|
---|
[3a9cf35] | 187 | list_foreach(vbds_disks, ldisks, vbds_disk_t, disk)
|
---|
[774aa332] | 188 | disk->present = false;
|
---|
[3a9cf35] | 189 |
|
---|
[372df8f] | 190 | for (i = 0; i < count; i++) {
|
---|
| 191 | already_known = false;
|
---|
| 192 |
|
---|
| 193 | list_foreach(vbds_disks, ldisks, vbds_disk_t, disk) {
|
---|
| 194 | if (disk->svc_id == svcs[i]) {
|
---|
| 195 | already_known = true;
|
---|
[3a9cf35] | 196 | disk->present = true;
|
---|
[372df8f] | 197 | break;
|
---|
| 198 | }
|
---|
| 199 | }
|
---|
| 200 |
|
---|
| 201 | if (!already_known) {
|
---|
| 202 | log_msg(LOG_DEFAULT, LVL_NOTE, "Found disk '%lu'",
|
---|
| 203 | (unsigned long) svcs[i]);
|
---|
| 204 | rc = vbds_disk_add(svcs[i]);
|
---|
| 205 | if (rc != EOK) {
|
---|
| 206 | log_msg(LOG_DEFAULT, LVL_ERROR, "Could not add "
|
---|
| 207 | "disk.");
|
---|
| 208 | }
|
---|
[3a9cf35] | 209 | } else {
|
---|
| 210 | log_msg(LOG_DEFAULT, LVL_DEBUG, "Disk %lu already known",
|
---|
| 211 | (unsigned long) svcs[i]);
|
---|
[372df8f] | 212 | }
|
---|
| 213 | }
|
---|
| 214 |
|
---|
[3a9cf35] | 215 | cur = vbds_disk_first();
|
---|
| 216 | while (cur != NULL) {
|
---|
| 217 | next = vbds_disk_next(cur);
|
---|
| 218 | if (!cur->present) {
|
---|
| 219 | log_msg(LOG_DEFAULT, LVL_NOTE, "Disk '%lu' is gone",
|
---|
| 220 | (unsigned long) cur->svc_id);
|
---|
| 221 | rc = vbds_disk_remove(cur->svc_id);
|
---|
| 222 | if (rc != EOK) {
|
---|
| 223 | log_msg(LOG_DEFAULT, LVL_ERROR, "Could not "
|
---|
| 224 | "remove disk.");
|
---|
| 225 | }
|
---|
| 226 | }
|
---|
| 227 |
|
---|
| 228 | cur = next;
|
---|
| 229 | }
|
---|
| 230 |
|
---|
[372df8f] | 231 | fibril_mutex_unlock(&vbds_disks_lock);
|
---|
| 232 | return EOK;
|
---|
[28ed0d9] | 233 | }
|
---|
| 234 |
|
---|
[b7fd2a0] | 235 | static errno_t vbds_disk_by_svcid(service_id_t sid, vbds_disk_t **rdisk)
|
---|
[28ed0d9] | 236 | {
|
---|
| 237 | list_foreach(vbds_disks, ldisks, vbds_disk_t, disk) {
|
---|
| 238 | if (disk->svc_id == sid) {
|
---|
| 239 | *rdisk = disk;
|
---|
| 240 | return EOK;
|
---|
| 241 | }
|
---|
| 242 | }
|
---|
| 243 |
|
---|
| 244 | return ENOENT;
|
---|
| 245 | }
|
---|
| 246 |
|
---|
[e11c527] | 247 | static void vbds_part_add_ref(vbds_part_t *part)
|
---|
| 248 | {
|
---|
| 249 | log_msg(LOG_DEFAULT, LVL_DEBUG2, "vbds_part_add_ref");
|
---|
[498ced1] | 250 | refcount_up(&part->refcnt);
|
---|
[e11c527] | 251 | }
|
---|
| 252 |
|
---|
| 253 | static void vbds_part_del_ref(vbds_part_t *part)
|
---|
| 254 | {
|
---|
| 255 | log_msg(LOG_DEFAULT, LVL_DEBUG2, "vbds_part_del_ref");
|
---|
[498ced1] | 256 | if (refcount_down(&part->refcnt)) {
|
---|
[e11c527] | 257 | log_msg(LOG_DEFAULT, LVL_DEBUG2, " - free part");
|
---|
| 258 | free(part);
|
---|
| 259 | }
|
---|
| 260 | }
|
---|
| 261 |
|
---|
[b7fd2a0] | 262 | static errno_t vbds_part_by_pid(vbds_part_id_t partid, vbds_part_t **rpart)
|
---|
[c43db5f] | 263 | {
|
---|
[55f8c6e7] | 264 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_part_by_pid(%zu)", partid);
|
---|
[c43db5f] | 265 |
|
---|
[e11c527] | 266 | fibril_mutex_lock(&vbds_parts_lock);
|
---|
| 267 |
|
---|
[c43db5f] | 268 | list_foreach(vbds_parts, lparts, vbds_part_t, part) {
|
---|
[55f8c6e7] | 269 | log_msg(LOG_DEFAULT, LVL_DEBUG, "%zu == %zu ?", part->pid, partid);
|
---|
[c43db5f] | 270 | if (part->pid == partid) {
|
---|
[55f8c6e7] | 271 | log_msg(LOG_DEFAULT, LVL_DEBUG, "Found match.");
|
---|
[e11c527] | 272 | vbds_part_add_ref(part);
|
---|
| 273 | fibril_mutex_unlock(&vbds_parts_lock);
|
---|
[c43db5f] | 274 | *rpart = part;
|
---|
| 275 | return EOK;
|
---|
| 276 | }
|
---|
| 277 | }
|
---|
| 278 |
|
---|
[e11c527] | 279 | fibril_mutex_unlock(&vbds_parts_lock);
|
---|
[55f8c6e7] | 280 | log_msg(LOG_DEFAULT, LVL_DEBUG, "No match.");
|
---|
[c43db5f] | 281 | return ENOENT;
|
---|
| 282 | }
|
---|
| 283 |
|
---|
[b7fd2a0] | 284 | static errno_t vbds_part_by_svcid(service_id_t svcid, vbds_part_t **rpart)
|
---|
[78d50bd] | 285 | {
|
---|
[55f8c6e7] | 286 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_part_by_svcid(%zu)", svcid);
|
---|
[3faa03d] | 287 |
|
---|
[e11c527] | 288 | fibril_mutex_lock(&vbds_parts_lock);
|
---|
| 289 |
|
---|
[78d50bd] | 290 | list_foreach(vbds_parts, lparts, vbds_part_t, part) {
|
---|
[55f8c6e7] | 291 | log_msg(LOG_DEFAULT, LVL_DEBUG, "%zu == %zu ?", part->svc_id, svcid);
|
---|
[c43db5f] | 292 | if (part->svc_id == svcid) {
|
---|
[55f8c6e7] | 293 | log_msg(LOG_DEFAULT, LVL_DEBUG, "Found match.");
|
---|
[e11c527] | 294 | vbds_part_add_ref(part);
|
---|
| 295 | fibril_mutex_unlock(&vbds_parts_lock);
|
---|
[78d50bd] | 296 | *rpart = part;
|
---|
| 297 | return EOK;
|
---|
| 298 | }
|
---|
| 299 | }
|
---|
| 300 |
|
---|
[e11c527] | 301 | fibril_mutex_unlock(&vbds_parts_lock);
|
---|
[55f8c6e7] | 302 | log_msg(LOG_DEFAULT, LVL_DEBUG, "No match.");
|
---|
[78d50bd] | 303 | return ENOENT;
|
---|
| 304 | }
|
---|
| 305 |
|
---|
[99c23405] | 306 | /** Add partition to our inventory based on liblabel partition structure */
|
---|
[b7fd2a0] | 307 | static errno_t vbds_part_add(vbds_disk_t *disk, label_part_t *lpart,
|
---|
[6bc542b] | 308 | vbds_part_t **rpart)
|
---|
[28ed0d9] | 309 | {
|
---|
| 310 | vbds_part_t *part;
|
---|
[c43db5f] | 311 | service_id_t psid = 0;
|
---|
[78d50bd] | 312 | label_part_info_t lpinfo;
|
---|
[b7fd2a0] | 313 | errno_t rc;
|
---|
[28ed0d9] | 314 |
|
---|
[55f8c6e7] | 315 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_part_add(%s, %p)",
|
---|
[78d50bd] | 316 | disk->svc_name, lpart);
|
---|
[28ed0d9] | 317 |
|
---|
[b7a4d06] | 318 | label_part_get_info(lpart, &lpinfo);
|
---|
| 319 |
|
---|
[28ed0d9] | 320 | part = calloc(1, sizeof(vbds_part_t));
|
---|
| 321 | if (part == NULL) {
|
---|
| 322 | log_msg(LOG_DEFAULT, LVL_ERROR, "Out of memory.");
|
---|
| 323 | return ENOMEM;
|
---|
| 324 | }
|
---|
| 325 |
|
---|
[e11c527] | 326 | fibril_rwlock_initialize(&part->lock);
|
---|
| 327 |
|
---|
[28ed0d9] | 328 | part->lpart = lpart;
|
---|
| 329 | part->disk = disk;
|
---|
[c43db5f] | 330 | part->pid = ++vbds_part_id;
|
---|
| 331 | part->svc_id = psid;
|
---|
[78d50bd] | 332 | part->block0 = lpinfo.block0;
|
---|
| 333 | part->nblocks = lpinfo.nblocks;
|
---|
[498ced1] | 334 | refcount_init(&part->refcnt);
|
---|
[78d50bd] | 335 |
|
---|
| 336 | bd_srvs_init(&part->bds);
|
---|
| 337 | part->bds.ops = &vbds_bd_ops;
|
---|
| 338 | part->bds.sarg = part;
|
---|
| 339 |
|
---|
[6439741] | 340 | if (lpinfo.pkind != lpk_extended) {
|
---|
| 341 | rc = vbds_part_svc_register(part);
|
---|
[e11c527] | 342 | if (rc != EOK) {
|
---|
| 343 | free(part);
|
---|
[6439741] | 344 | return EIO;
|
---|
[e11c527] | 345 | }
|
---|
[6439741] | 346 | }
|
---|
| 347 |
|
---|
[28ed0d9] | 348 | list_append(&part->ldisk, &disk->parts);
|
---|
[e11c527] | 349 | fibril_mutex_lock(&vbds_parts_lock);
|
---|
[78d50bd] | 350 | list_append(&part->lparts, &vbds_parts);
|
---|
[e11c527] | 351 | fibril_mutex_unlock(&vbds_parts_lock);
|
---|
[28ed0d9] | 352 |
|
---|
[55f8c6e7] | 353 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_part_add -> %p", part);
|
---|
[3a43785] | 354 |
|
---|
[6bc542b] | 355 | if (rpart != NULL)
|
---|
| 356 | *rpart = part;
|
---|
[28ed0d9] | 357 | return EOK;
|
---|
| 358 | }
|
---|
| 359 |
|
---|
[99c23405] | 360 | /** Remove partition from our inventory leaving only the underlying liblabel
|
---|
| 361 | * partition structure.
|
---|
[e11c527] | 362 | *
|
---|
[58563585] | 363 | * @param part Partition
|
---|
| 364 | * @param flag If set to @c vrf_force, force removal even if partition is in use
|
---|
[e11c527] | 365 | * @param rlpart Place to store pointer to liblabel partition
|
---|
[58563585] | 366 | *
|
---|
[99c23405] | 367 | */
|
---|
[b7fd2a0] | 368 | static errno_t vbds_part_remove(vbds_part_t *part, vbds_rem_flag_t flag,
|
---|
[e11c527] | 369 | label_part_t **rlpart)
|
---|
[99c23405] | 370 | {
|
---|
| 371 | label_part_t *lpart;
|
---|
[b7fd2a0] | 372 | errno_t rc;
|
---|
[99c23405] | 373 |
|
---|
[55f8c6e7] | 374 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_part_remove(%p)", part);
|
---|
[99c23405] | 375 |
|
---|
[e11c527] | 376 | fibril_rwlock_write_lock(&part->lock);
|
---|
[99c23405] | 377 | lpart = part->lpart;
|
---|
| 378 |
|
---|
[e11c527] | 379 | if ((flag & vrf_force) == 0 && part->open_cnt > 0) {
|
---|
| 380 | fibril_rwlock_write_unlock(&part->lock);
|
---|
[55f8c6e7] | 381 | log_msg(LOG_DEFAULT, LVL_DEBUG, "part->open_cnt = %d",
|
---|
[3a43785] | 382 | part->open_cnt);
|
---|
[99c23405] | 383 | return EBUSY;
|
---|
[3a43785] | 384 | }
|
---|
[99c23405] | 385 |
|
---|
[c43db5f] | 386 | if (part->svc_id != 0) {
|
---|
[6439741] | 387 | rc = vbds_part_svc_unregister(part);
|
---|
[e11c527] | 388 | if (rc != EOK) {
|
---|
| 389 | fibril_rwlock_write_unlock(&part->lock);
|
---|
[c43db5f] | 390 | return EIO;
|
---|
[e11c527] | 391 | }
|
---|
[c43db5f] | 392 | }
|
---|
[99c23405] | 393 |
|
---|
| 394 | list_remove(&part->ldisk);
|
---|
[e11c527] | 395 | fibril_mutex_lock(&vbds_parts_lock);
|
---|
[99c23405] | 396 | list_remove(&part->lparts);
|
---|
[e11c527] | 397 | fibril_mutex_unlock(&vbds_parts_lock);
|
---|
| 398 |
|
---|
| 399 | vbds_part_del_ref(part);
|
---|
| 400 | part->lpart = NULL;
|
---|
| 401 | fibril_rwlock_write_unlock(&part->lock);
|
---|
[99c23405] | 402 |
|
---|
| 403 | if (rlpart != NULL)
|
---|
| 404 | *rlpart = lpart;
|
---|
| 405 | return EOK;
|
---|
| 406 | }
|
---|
| 407 |
|
---|
[3a43785] | 408 | /** Remove all disk partitions from our inventory leaving only the underlying
|
---|
[7c3fb9b] | 409 | * liblabel partition structures.
|
---|
| 410 | */
|
---|
[b7fd2a0] | 411 | static errno_t vbds_disk_parts_add(vbds_disk_t *disk, label_t *label)
|
---|
[3a43785] | 412 | {
|
---|
| 413 | label_part_t *part;
|
---|
[b7fd2a0] | 414 | errno_t rc;
|
---|
[3a43785] | 415 |
|
---|
| 416 | part = label_part_first(label);
|
---|
| 417 | while (part != NULL) {
|
---|
| 418 | rc = vbds_part_add(disk, part, NULL);
|
---|
| 419 | if (rc != EOK) {
|
---|
| 420 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed adding partition "
|
---|
| 421 | "(disk %s)", disk->svc_name);
|
---|
| 422 | return rc;
|
---|
| 423 | }
|
---|
| 424 |
|
---|
| 425 | part = label_part_next(part);
|
---|
| 426 | }
|
---|
| 427 |
|
---|
| 428 | return EOK;
|
---|
| 429 | }
|
---|
| 430 |
|
---|
| 431 | /** Remove all disk partitions from our inventory leaving only the underlying
|
---|
[7c3fb9b] | 432 | * liblabel partition structures.
|
---|
| 433 | */
|
---|
[b7fd2a0] | 434 | static errno_t vbds_disk_parts_remove(vbds_disk_t *disk, vbds_rem_flag_t flag)
|
---|
[3a43785] | 435 | {
|
---|
| 436 | link_t *link;
|
---|
| 437 | vbds_part_t *part;
|
---|
[b7fd2a0] | 438 | errno_t rc;
|
---|
[3a43785] | 439 |
|
---|
| 440 | link = list_first(&disk->parts);
|
---|
| 441 | while (link != NULL) {
|
---|
| 442 | part = list_get_instance(link, vbds_part_t, ldisk);
|
---|
[e11c527] | 443 | rc = vbds_part_remove(part, flag, NULL);
|
---|
[3a43785] | 444 | if (rc != EOK)
|
---|
| 445 | return rc;
|
---|
| 446 |
|
---|
| 447 | link = list_first(&disk->parts);
|
---|
| 448 | }
|
---|
| 449 |
|
---|
| 450 | return EOK;
|
---|
| 451 | }
|
---|
| 452 |
|
---|
[e89a06a] | 453 | static void vbds_disk_cat_change_cb(void *arg)
|
---|
[372df8f] | 454 | {
|
---|
| 455 | (void) vbds_disks_check_new();
|
---|
| 456 | }
|
---|
| 457 |
|
---|
[b7fd2a0] | 458 | errno_t vbds_disk_discovery_start(void)
|
---|
[372df8f] | 459 | {
|
---|
[b7fd2a0] | 460 | errno_t rc;
|
---|
[372df8f] | 461 |
|
---|
[e89a06a] | 462 | rc = loc_register_cat_change_cb(vbds_disk_cat_change_cb, NULL);
|
---|
[372df8f] | 463 | if (rc != EOK) {
|
---|
| 464 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed registering callback "
|
---|
[c1694b6b] | 465 | "for disk discovery: %s.", str_error(rc));
|
---|
[372df8f] | 466 | return rc;
|
---|
| 467 | }
|
---|
| 468 |
|
---|
| 469 | return vbds_disks_check_new();
|
---|
| 470 | }
|
---|
| 471 |
|
---|
[b7fd2a0] | 472 | errno_t vbds_disk_add(service_id_t sid)
|
---|
[28ed0d9] | 473 | {
|
---|
[3faa03d] | 474 | label_t *label = NULL;
|
---|
[deacc58d] | 475 | label_bd_t lbd;
|
---|
[78d50bd] | 476 | vbds_disk_t *disk = NULL;
|
---|
| 477 | bool block_inited = false;
|
---|
| 478 | size_t block_size;
|
---|
[53e3950] | 479 | aoff64_t nblocks;
|
---|
[b7fd2a0] | 480 | errno_t rc;
|
---|
[28ed0d9] | 481 |
|
---|
[55f8c6e7] | 482 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_disk_add(%zu)", sid);
|
---|
[28ed0d9] | 483 |
|
---|
| 484 | /* Check for duplicates */
|
---|
| 485 | rc = vbds_disk_by_svcid(sid, &disk);
|
---|
| 486 | if (rc == EOK)
|
---|
[ff381a7] | 487 | return EEXIST;
|
---|
[28ed0d9] | 488 |
|
---|
| 489 | disk = calloc(1, sizeof(vbds_disk_t));
|
---|
| 490 | if (disk == NULL)
|
---|
| 491 | return ENOMEM;
|
---|
| 492 |
|
---|
[deacc58d] | 493 | /* Must be set before calling label_open */
|
---|
| 494 | disk->svc_id = sid;
|
---|
| 495 |
|
---|
[78d50bd] | 496 | rc = loc_service_get_name(sid, &disk->svc_name);
|
---|
| 497 | if (rc != EOK) {
|
---|
| 498 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed getting disk service name.");
|
---|
| 499 | rc = EIO;
|
---|
| 500 | goto error;
|
---|
| 501 | }
|
---|
| 502 |
|
---|
[55f8c6e7] | 503 | log_msg(LOG_DEFAULT, LVL_DEBUG, "block_init(%zu)", sid);
|
---|
[7ae01d5] | 504 | rc = block_init(sid);
|
---|
[78d50bd] | 505 | if (rc != EOK) {
|
---|
| 506 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed opening block device %s.",
|
---|
| 507 | disk->svc_name);
|
---|
| 508 | rc = EIO;
|
---|
| 509 | goto error;
|
---|
| 510 | }
|
---|
| 511 |
|
---|
| 512 | rc = block_get_bsize(sid, &block_size);
|
---|
| 513 | if (rc != EOK) {
|
---|
| 514 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed getting block size of %s.",
|
---|
| 515 | disk->svc_name);
|
---|
| 516 | rc = EIO;
|
---|
| 517 | goto error;
|
---|
| 518 | }
|
---|
| 519 |
|
---|
[53e3950] | 520 | rc = block_get_nblocks(sid, &nblocks);
|
---|
| 521 | if (rc != EOK) {
|
---|
| 522 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed getting number of "
|
---|
| 523 | "blocks of %s.", disk->svc_name);
|
---|
| 524 | rc = EIO;
|
---|
| 525 | goto error;
|
---|
| 526 | }
|
---|
| 527 |
|
---|
[78d50bd] | 528 | block_inited = true;
|
---|
| 529 |
|
---|
[deacc58d] | 530 | lbd.ops = &vbds_label_bd_ops;
|
---|
| 531 | lbd.arg = (void *) disk;
|
---|
| 532 |
|
---|
| 533 | rc = label_open(&lbd, &label);
|
---|
[78d50bd] | 534 | if (rc != EOK) {
|
---|
[55f8c6e7] | 535 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed to open label in disk %s.",
|
---|
[3faa03d] | 536 | disk->svc_name);
|
---|
[78d50bd] | 537 | rc = EIO;
|
---|
[28ed0d9] | 538 | goto error;
|
---|
[78d50bd] | 539 | }
|
---|
[28ed0d9] | 540 |
|
---|
| 541 | disk->label = label;
|
---|
[78d50bd] | 542 | disk->block_size = block_size;
|
---|
[53e3950] | 543 | disk->nblocks = nblocks;
|
---|
[3a9cf35] | 544 | disk->present = true;
|
---|
[78d50bd] | 545 |
|
---|
[28ed0d9] | 546 | list_initialize(&disk->parts);
|
---|
| 547 | list_append(&disk->ldisks, &vbds_disks);
|
---|
| 548 |
|
---|
[3faa03d] | 549 | log_msg(LOG_DEFAULT, LVL_NOTE, "Recognized disk label. Adding partitions.");
|
---|
| 550 |
|
---|
[3a43785] | 551 | (void) vbds_disk_parts_add(disk, label);
|
---|
[28ed0d9] | 552 | return EOK;
|
---|
| 553 | error:
|
---|
[78d50bd] | 554 | label_close(label);
|
---|
[603c1d1f] | 555 | if (block_inited) {
|
---|
[55f8c6e7] | 556 | log_msg(LOG_DEFAULT, LVL_DEBUG, "block_fini(%zu)", sid);
|
---|
[78d50bd] | 557 | block_fini(sid);
|
---|
[603c1d1f] | 558 | }
|
---|
[78d50bd] | 559 | if (disk != NULL)
|
---|
| 560 | free(disk->svc_name);
|
---|
[28ed0d9] | 561 | free(disk);
|
---|
| 562 | return rc;
|
---|
| 563 | }
|
---|
| 564 |
|
---|
[b7fd2a0] | 565 | errno_t vbds_disk_remove(service_id_t sid)
|
---|
[28ed0d9] | 566 | {
|
---|
| 567 | vbds_disk_t *disk;
|
---|
[b7fd2a0] | 568 | errno_t rc;
|
---|
[28ed0d9] | 569 |
|
---|
[55f8c6e7] | 570 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_disk_remove(%zu)", sid);
|
---|
[28ed0d9] | 571 |
|
---|
| 572 | rc = vbds_disk_by_svcid(sid, &disk);
|
---|
| 573 | if (rc != EOK)
|
---|
| 574 | return rc;
|
---|
| 575 |
|
---|
[e11c527] | 576 | rc = vbds_disk_parts_remove(disk, vrf_force);
|
---|
[3a43785] | 577 | if (rc != EOK) {
|
---|
| 578 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed removing disk.");
|
---|
| 579 | return rc;
|
---|
| 580 | }
|
---|
| 581 |
|
---|
[28ed0d9] | 582 | list_remove(&disk->ldisks);
|
---|
| 583 | label_close(disk->label);
|
---|
[55f8c6e7] | 584 | log_msg(LOG_DEFAULT, LVL_DEBUG, "block_fini(%zu)", sid);
|
---|
[603c1d1f] | 585 | block_fini(sid);
|
---|
[ddfe233] | 586 | free(disk->svc_name);
|
---|
[28ed0d9] | 587 | free(disk);
|
---|
| 588 | return EOK;
|
---|
| 589 | }
|
---|
| 590 |
|
---|
[372df8f] | 591 | /** Get list of disks as array of service IDs. */
|
---|
[b7fd2a0] | 592 | errno_t vbds_disk_get_ids(service_id_t *id_buf, size_t buf_size, size_t *act_size)
|
---|
[372df8f] | 593 | {
|
---|
| 594 | size_t act_cnt;
|
---|
| 595 | size_t buf_cnt;
|
---|
| 596 |
|
---|
| 597 | fibril_mutex_lock(&vbds_disks_lock);
|
---|
| 598 |
|
---|
| 599 | buf_cnt = buf_size / sizeof(service_id_t);
|
---|
| 600 |
|
---|
| 601 | act_cnt = list_count(&vbds_disks);
|
---|
| 602 | *act_size = act_cnt * sizeof(service_id_t);
|
---|
| 603 |
|
---|
| 604 | if (buf_size % sizeof(service_id_t) != 0) {
|
---|
| 605 | fibril_mutex_unlock(&vbds_disks_lock);
|
---|
| 606 | return EINVAL;
|
---|
| 607 | }
|
---|
| 608 |
|
---|
| 609 | size_t pos = 0;
|
---|
| 610 | list_foreach(vbds_disks, ldisks, vbds_disk_t, disk) {
|
---|
| 611 | if (pos < buf_cnt)
|
---|
| 612 | id_buf[pos] = disk->svc_id;
|
---|
| 613 | pos++;
|
---|
| 614 | }
|
---|
| 615 |
|
---|
| 616 | fibril_mutex_unlock(&vbds_disks_lock);
|
---|
| 617 | return EOK;
|
---|
| 618 | }
|
---|
| 619 |
|
---|
[b7fd2a0] | 620 | errno_t vbds_disk_info(service_id_t sid, vbd_disk_info_t *info)
|
---|
[28ed0d9] | 621 | {
|
---|
[1626cd4] | 622 | vbds_disk_t *disk;
|
---|
| 623 | label_info_t linfo;
|
---|
[b7fd2a0] | 624 | errno_t rc;
|
---|
[1626cd4] | 625 |
|
---|
[55f8c6e7] | 626 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_disk_info(%zu)", sid);
|
---|
[1626cd4] | 627 |
|
---|
| 628 | rc = vbds_disk_by_svcid(sid, &disk);
|
---|
| 629 | if (rc != EOK)
|
---|
| 630 | return rc;
|
---|
| 631 |
|
---|
| 632 | rc = label_get_info(disk->label, &linfo);
|
---|
[6a0db524] | 633 | if (rc != EOK)
|
---|
| 634 | return rc;
|
---|
[1626cd4] | 635 |
|
---|
| 636 | info->ltype = linfo.ltype;
|
---|
[b7a4d06] | 637 | info->flags = linfo.flags;
|
---|
[1626cd4] | 638 | info->ablock0 = linfo.ablock0;
|
---|
| 639 | info->anblocks = linfo.anblocks;
|
---|
| 640 | info->block_size = disk->block_size;
|
---|
[53e3950] | 641 | info->nblocks = disk->nblocks;
|
---|
[55f8c6e7] | 642 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_disk_info - block_size=%zu",
|
---|
[c02d098] | 643 | info->block_size);
|
---|
[1626cd4] | 644 | return EOK;
|
---|
| 645 | }
|
---|
| 646 |
|
---|
[b7fd2a0] | 647 | errno_t vbds_get_parts(service_id_t sid, service_id_t *id_buf, size_t buf_size,
|
---|
[1626cd4] | 648 | size_t *act_size)
|
---|
| 649 | {
|
---|
| 650 | vbds_disk_t *disk;
|
---|
| 651 | size_t act_cnt;
|
---|
| 652 | size_t buf_cnt;
|
---|
[b7fd2a0] | 653 | errno_t rc;
|
---|
[1626cd4] | 654 |
|
---|
| 655 | rc = vbds_disk_by_svcid(sid, &disk);
|
---|
| 656 | if (rc != EOK)
|
---|
| 657 | return rc;
|
---|
| 658 |
|
---|
| 659 | buf_cnt = buf_size / sizeof(service_id_t);
|
---|
| 660 |
|
---|
| 661 | act_cnt = list_count(&disk->parts);
|
---|
| 662 | *act_size = act_cnt * sizeof(service_id_t);
|
---|
| 663 |
|
---|
| 664 | if (buf_size % sizeof(service_id_t) != 0)
|
---|
| 665 | return EINVAL;
|
---|
| 666 |
|
---|
| 667 | size_t pos = 0;
|
---|
| 668 | list_foreach(disk->parts, ldisk, vbds_part_t, part) {
|
---|
| 669 | if (pos < buf_cnt)
|
---|
[c43db5f] | 670 | id_buf[pos] = part->pid;
|
---|
[1626cd4] | 671 | pos++;
|
---|
| 672 | }
|
---|
| 673 |
|
---|
[28ed0d9] | 674 | return EOK;
|
---|
| 675 | }
|
---|
| 676 |
|
---|
[b7fd2a0] | 677 | errno_t vbds_label_create(service_id_t sid, label_type_t ltype)
|
---|
[28ed0d9] | 678 | {
|
---|
| 679 | label_t *label;
|
---|
[deacc58d] | 680 | label_bd_t lbd;
|
---|
[6a0db524] | 681 | label_info_t linfo;
|
---|
[28ed0d9] | 682 | vbds_disk_t *disk;
|
---|
[b7fd2a0] | 683 | errno_t rc, rc2;
|
---|
[28ed0d9] | 684 |
|
---|
[55f8c6e7] | 685 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_label_create(%zu)", sid);
|
---|
[28ed0d9] | 686 |
|
---|
[3a43785] | 687 | /* Find disk */
|
---|
[28ed0d9] | 688 | rc = vbds_disk_by_svcid(sid, &disk);
|
---|
[3a43785] | 689 | if (rc != EOK)
|
---|
| 690 | return rc;
|
---|
[28ed0d9] | 691 |
|
---|
[55f8c6e7] | 692 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_label_create(%zu) - label_close", sid);
|
---|
[603c1d1f] | 693 |
|
---|
[6a0db524] | 694 | /* Verify that current label is a dummy label */
|
---|
| 695 | rc = label_get_info(disk->label, &linfo);
|
---|
| 696 | if (rc != EOK)
|
---|
| 697 | return rc;
|
---|
| 698 |
|
---|
| 699 | if (linfo.ltype != lt_none) {
|
---|
| 700 | log_msg(LOG_DEFAULT, LVL_ERROR, "Label already exists.");
|
---|
| 701 | return EEXIST;
|
---|
| 702 | }
|
---|
| 703 |
|
---|
[3a43785] | 704 | /* Close dummy label first */
|
---|
[e11c527] | 705 | rc = vbds_disk_parts_remove(disk, vrf_none);
|
---|
[603c1d1f] | 706 | if (rc != EOK) {
|
---|
[3a43785] | 707 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed removing disk.");
|
---|
| 708 | return rc;
|
---|
[603c1d1f] | 709 | }
|
---|
| 710 |
|
---|
[3a43785] | 711 | label_close(disk->label);
|
---|
| 712 | disk->label = NULL;
|
---|
[603c1d1f] | 713 |
|
---|
[55f8c6e7] | 714 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_label_create(%zu) - label_create", sid);
|
---|
[603c1d1f] | 715 |
|
---|
[deacc58d] | 716 | lbd.ops = &vbds_label_bd_ops;
|
---|
| 717 | lbd.arg = (void *) disk;
|
---|
| 718 |
|
---|
| 719 | rc = label_create(&lbd, ltype, &label);
|
---|
[28ed0d9] | 720 | if (rc != EOK)
|
---|
| 721 | goto error;
|
---|
| 722 |
|
---|
[3a43785] | 723 | (void) vbds_disk_parts_add(disk, label);
|
---|
[28ed0d9] | 724 | disk->label = label;
|
---|
[603c1d1f] | 725 |
|
---|
[55f8c6e7] | 726 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_label_create(%zu) - success", sid);
|
---|
[28ed0d9] | 727 | return EOK;
|
---|
| 728 | error:
|
---|
[55f8c6e7] | 729 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_label_create(%zu) - failure", sid);
|
---|
[3a43785] | 730 | if (disk->label == NULL) {
|
---|
[deacc58d] | 731 | lbd.ops = &vbds_label_bd_ops;
|
---|
| 732 | lbd.arg = (void *) disk;
|
---|
| 733 |
|
---|
| 734 | rc2 = label_open(&lbd, &label);
|
---|
[f63a0073] | 735 | if (rc2 != EOK) {
|
---|
[55f8c6e7] | 736 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed to open label in disk %s.",
|
---|
[3a43785] | 737 | disk->svc_name);
|
---|
[f63a0073] | 738 | return rc2;
|
---|
[3a43785] | 739 | }
|
---|
[f63a0073] | 740 |
|
---|
| 741 | disk->label = label;
|
---|
| 742 | (void) vbds_disk_parts_add(disk, label);
|
---|
[603c1d1f] | 743 | }
|
---|
[3a43785] | 744 |
|
---|
[28ed0d9] | 745 | return rc;
|
---|
| 746 | }
|
---|
| 747 |
|
---|
[b7fd2a0] | 748 | errno_t vbds_label_delete(service_id_t sid)
|
---|
[28ed0d9] | 749 | {
|
---|
| 750 | vbds_disk_t *disk;
|
---|
[3a43785] | 751 | label_t *label;
|
---|
[deacc58d] | 752 | label_bd_t lbd;
|
---|
[b7fd2a0] | 753 | errno_t rc;
|
---|
[28ed0d9] | 754 |
|
---|
[55f8c6e7] | 755 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_label_delete(%zu)", sid);
|
---|
[28ed0d9] | 756 |
|
---|
| 757 | rc = vbds_disk_by_svcid(sid, &disk);
|
---|
| 758 | if (rc != EOK)
|
---|
| 759 | return rc;
|
---|
| 760 |
|
---|
[e11c527] | 761 | rc = vbds_disk_parts_remove(disk, vrf_none);
|
---|
[3a43785] | 762 | if (rc != EOK) {
|
---|
| 763 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed deleting label.");
|
---|
| 764 | return rc;
|
---|
| 765 | }
|
---|
| 766 |
|
---|
[28ed0d9] | 767 | rc = label_destroy(disk->label);
|
---|
| 768 | if (rc != EOK) {
|
---|
| 769 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed deleting label.");
|
---|
| 770 | return rc;
|
---|
| 771 | }
|
---|
| 772 |
|
---|
[3a43785] | 773 | disk->label = NULL;
|
---|
| 774 |
|
---|
[deacc58d] | 775 | lbd.ops = &vbds_label_bd_ops;
|
---|
| 776 | lbd.arg = (void *) disk;
|
---|
| 777 |
|
---|
| 778 | rc = label_open(&lbd, &label);
|
---|
[3a43785] | 779 | if (rc != EOK) {
|
---|
[55f8c6e7] | 780 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed to open label in disk %s.",
|
---|
[3a43785] | 781 | disk->svc_name);
|
---|
| 782 | return EIO;
|
---|
| 783 | }
|
---|
| 784 |
|
---|
| 785 | (void) vbds_disk_parts_add(disk, label);
|
---|
| 786 | disk->label = label;
|
---|
[28ed0d9] | 787 | return EOK;
|
---|
| 788 | }
|
---|
| 789 |
|
---|
[b7fd2a0] | 790 | errno_t vbds_part_get_info(vbds_part_id_t partid, vbd_part_info_t *pinfo)
|
---|
[28ed0d9] | 791 | {
|
---|
[78d50bd] | 792 | vbds_part_t *part;
|
---|
[1626cd4] | 793 | label_part_info_t lpinfo;
|
---|
[b7fd2a0] | 794 | errno_t rc;
|
---|
[78d50bd] | 795 |
|
---|
[c43db5f] | 796 | rc = vbds_part_by_pid(partid, &part);
|
---|
[78d50bd] | 797 | if (rc != EOK)
|
---|
| 798 | return rc;
|
---|
| 799 |
|
---|
[e11c527] | 800 | fibril_rwlock_read_lock(&part->lock);
|
---|
| 801 | if (part->lpart == NULL) {
|
---|
| 802 | fibril_rwlock_read_unlock(&part->lock);
|
---|
| 803 | return ENOENT;
|
---|
| 804 | }
|
---|
| 805 |
|
---|
[1626cd4] | 806 | label_part_get_info(part->lpart, &lpinfo);
|
---|
| 807 |
|
---|
| 808 | pinfo->index = lpinfo.index;
|
---|
[b7a4d06] | 809 | pinfo->pkind = lpinfo.pkind;
|
---|
[1626cd4] | 810 | pinfo->block0 = lpinfo.block0;
|
---|
| 811 | pinfo->nblocks = lpinfo.nblocks;
|
---|
[4b6635a7] | 812 | pinfo->svc_id = part->svc_id;
|
---|
[e11c527] | 813 | vbds_part_del_ref(part);
|
---|
| 814 | fibril_rwlock_read_unlock(&part->lock);
|
---|
| 815 |
|
---|
[28ed0d9] | 816 | return EOK;
|
---|
| 817 | }
|
---|
| 818 |
|
---|
[b7fd2a0] | 819 | errno_t vbds_part_create(service_id_t sid, vbd_part_spec_t *pspec,
|
---|
[6bc542b] | 820 | vbds_part_id_t *rpart)
|
---|
[28ed0d9] | 821 | {
|
---|
[78d50bd] | 822 | vbds_disk_t *disk;
|
---|
| 823 | vbds_part_t *part;
|
---|
[6bc542b] | 824 | label_part_spec_t lpspec;
|
---|
[78d50bd] | 825 | label_part_t *lpart;
|
---|
[b7fd2a0] | 826 | errno_t rc;
|
---|
[78d50bd] | 827 |
|
---|
[55f8c6e7] | 828 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_part_create(%zu)", sid);
|
---|
[44fe800] | 829 |
|
---|
[78d50bd] | 830 | rc = vbds_disk_by_svcid(sid, &disk);
|
---|
| 831 | if (rc != EOK) {
|
---|
[55f8c6e7] | 832 | log_msg(LOG_DEFAULT, LVL_ERROR, "Disk %zu not found",
|
---|
[78d50bd] | 833 | sid);
|
---|
| 834 | goto error;
|
---|
| 835 | }
|
---|
| 836 |
|
---|
[55f8c6e7] | 837 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_part_crate(%zu): "
|
---|
[b598460a] | 838 | "index=%d block0=%" PRIu64 " nblocks=%" PRIu64
|
---|
| 839 | " hdr_blocks=%" PRIu64 " pkind=%d",
|
---|
| 840 | sid, pspec->index, pspec->block0, pspec->nblocks, pspec->hdr_blocks,
|
---|
| 841 | pspec->pkind);
|
---|
| 842 |
|
---|
[6bc542b] | 843 | label_pspec_init(&lpspec);
|
---|
| 844 | lpspec.index = pspec->index;
|
---|
| 845 | lpspec.block0 = pspec->block0;
|
---|
| 846 | lpspec.nblocks = pspec->nblocks;
|
---|
[c02d098] | 847 | lpspec.hdr_blocks = pspec->hdr_blocks;
|
---|
[b7a4d06] | 848 | lpspec.pkind = pspec->pkind;
|
---|
[6bc542b] | 849 | lpspec.ptype = pspec->ptype;
|
---|
| 850 |
|
---|
| 851 | rc = label_part_create(disk->label, &lpspec, &lpart);
|
---|
[78d50bd] | 852 | if (rc != EOK) {
|
---|
| 853 | log_msg(LOG_DEFAULT, LVL_ERROR, "Error creating partition.");
|
---|
[5772aa1] | 854 | goto error;
|
---|
| 855 | }
|
---|
| 856 |
|
---|
| 857 | rc = label_part_empty(lpart);
|
---|
| 858 | if (rc != EOK) {
|
---|
| 859 | log_msg(LOG_DEFAULT, LVL_ERROR, "Error emptying partition.");
|
---|
[78d50bd] | 860 | goto error;
|
---|
| 861 | }
|
---|
| 862 |
|
---|
[6439741] | 863 | rc = vbds_part_indices_update(disk);
|
---|
| 864 | if (rc != EOK) {
|
---|
| 865 | log_msg(LOG_DEFAULT, LVL_ERROR, "Error updating partition indices");
|
---|
| 866 | goto error;
|
---|
| 867 | }
|
---|
| 868 |
|
---|
[6bc542b] | 869 | rc = vbds_part_add(disk, lpart, &part);
|
---|
[78d50bd] | 870 | if (rc != EOK) {
|
---|
| 871 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed while creating "
|
---|
| 872 | "partition.");
|
---|
| 873 | rc = label_part_destroy(lpart);
|
---|
| 874 | if (rc != EOK)
|
---|
| 875 | log_msg(LOG_DEFAULT, LVL_ERROR,
|
---|
| 876 | "Cannot roll back partition creation.");
|
---|
| 877 | rc = EIO;
|
---|
| 878 | goto error;
|
---|
| 879 | }
|
---|
| 880 |
|
---|
[6bc542b] | 881 | if (rpart != NULL)
|
---|
[c43db5f] | 882 | *rpart = part->pid;
|
---|
[28ed0d9] | 883 | return EOK;
|
---|
[78d50bd] | 884 | error:
|
---|
| 885 | return rc;
|
---|
[28ed0d9] | 886 | }
|
---|
| 887 |
|
---|
[b7fd2a0] | 888 | errno_t vbds_part_delete(vbds_part_id_t partid)
|
---|
[28ed0d9] | 889 | {
|
---|
[78d50bd] | 890 | vbds_part_t *part;
|
---|
[99c23405] | 891 | vbds_disk_t *disk;
|
---|
| 892 | label_part_t *lpart;
|
---|
[b7fd2a0] | 893 | errno_t rc;
|
---|
[78d50bd] | 894 |
|
---|
[c43db5f] | 895 | rc = vbds_part_by_pid(partid, &part);
|
---|
[78d50bd] | 896 | if (rc != EOK)
|
---|
| 897 | return rc;
|
---|
| 898 |
|
---|
[99c23405] | 899 | disk = part->disk;
|
---|
| 900 |
|
---|
[e11c527] | 901 | rc = vbds_part_remove(part, vrf_none, &lpart);
|
---|
[78d50bd] | 902 | if (rc != EOK)
|
---|
| 903 | return rc;
|
---|
| 904 |
|
---|
[99c23405] | 905 | rc = label_part_destroy(lpart);
|
---|
[e11c527] | 906 | vbds_part_del_ref(part);
|
---|
[99c23405] | 907 | if (rc != EOK) {
|
---|
| 908 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed deleting partition");
|
---|
| 909 |
|
---|
| 910 | /* Try rolling back */
|
---|
| 911 | rc = vbds_part_add(disk, lpart, NULL);
|
---|
| 912 | if (rc != EOK)
|
---|
| 913 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed rolling back.");
|
---|
| 914 |
|
---|
| 915 | return EIO;
|
---|
| 916 | }
|
---|
| 917 |
|
---|
[6439741] | 918 | rc = vbds_part_indices_update(disk);
|
---|
| 919 | if (rc != EOK) {
|
---|
| 920 | log_msg(LOG_DEFAULT, LVL_ERROR, "Error updating partition indices");
|
---|
| 921 | return EIO;
|
---|
| 922 | }
|
---|
| 923 |
|
---|
[78d50bd] | 924 | return EOK;
|
---|
| 925 | }
|
---|
| 926 |
|
---|
[b7fd2a0] | 927 | errno_t vbds_suggest_ptype(service_id_t sid, label_pcnt_t pcnt,
|
---|
[f57ccb5] | 928 | label_ptype_t *ptype)
|
---|
| 929 | {
|
---|
| 930 | vbds_disk_t *disk;
|
---|
[b7fd2a0] | 931 | errno_t rc;
|
---|
[f57ccb5] | 932 |
|
---|
| 933 | rc = vbds_disk_by_svcid(sid, &disk);
|
---|
| 934 | if (rc != EOK) {
|
---|
[55f8c6e7] | 935 | log_msg(LOG_DEFAULT, LVL_DEBUG, "Disk %zu not found",
|
---|
[f57ccb5] | 936 | sid);
|
---|
| 937 | goto error;
|
---|
| 938 | }
|
---|
| 939 |
|
---|
| 940 | rc = label_suggest_ptype(disk->label, pcnt, ptype);
|
---|
| 941 | if (rc != EOK) {
|
---|
[55f8c6e7] | 942 | log_msg(LOG_DEFAULT, LVL_DEBUG, "label_suggest_ptype() failed");
|
---|
[f57ccb5] | 943 | goto error;
|
---|
| 944 | }
|
---|
| 945 |
|
---|
| 946 | return EOK;
|
---|
| 947 | error:
|
---|
| 948 | return rc;
|
---|
| 949 | }
|
---|
| 950 |
|
---|
[b7fd2a0] | 951 | static errno_t vbds_bd_open(bd_srvs_t *bds, bd_srv_t *bd)
|
---|
[78d50bd] | 952 | {
|
---|
| 953 | vbds_part_t *part = bd_srv_part(bd);
|
---|
| 954 |
|
---|
[55f8c6e7] | 955 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_bd_open()");
|
---|
[e11c527] | 956 | fibril_rwlock_write_lock(&part->lock);
|
---|
[78d50bd] | 957 | part->open_cnt++;
|
---|
[e11c527] | 958 | fibril_rwlock_write_unlock(&part->lock);
|
---|
[78d50bd] | 959 | return EOK;
|
---|
| 960 | }
|
---|
| 961 |
|
---|
[b7fd2a0] | 962 | static errno_t vbds_bd_close(bd_srv_t *bd)
|
---|
[78d50bd] | 963 | {
|
---|
| 964 | vbds_part_t *part = bd_srv_part(bd);
|
---|
| 965 |
|
---|
[55f8c6e7] | 966 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_bd_close()");
|
---|
[e11c527] | 967 |
|
---|
| 968 | /* Grabbing writer lock also forces all I/O to complete */
|
---|
| 969 |
|
---|
| 970 | fibril_rwlock_write_lock(&part->lock);
|
---|
[78d50bd] | 971 | part->open_cnt--;
|
---|
[e11c527] | 972 | fibril_rwlock_write_unlock(&part->lock);
|
---|
[78d50bd] | 973 | return EOK;
|
---|
| 974 | }
|
---|
| 975 |
|
---|
[b7fd2a0] | 976 | static errno_t vbds_bd_read_blocks(bd_srv_t *bd, aoff64_t ba, size_t cnt,
|
---|
[78d50bd] | 977 | void *buf, size_t size)
|
---|
| 978 | {
|
---|
| 979 | vbds_part_t *part = bd_srv_part(bd);
|
---|
| 980 | aoff64_t gba;
|
---|
[b7fd2a0] | 981 | errno_t rc;
|
---|
[78d50bd] | 982 |
|
---|
[55f8c6e7] | 983 | log_msg(LOG_DEFAULT, LVL_DEBUG2, "vbds_bd_read_blocks()");
|
---|
[e11c527] | 984 | fibril_rwlock_read_lock(&part->lock);
|
---|
[78d50bd] | 985 |
|
---|
[e11c527] | 986 | if (cnt * part->disk->block_size < size) {
|
---|
| 987 | fibril_rwlock_read_unlock(&part->lock);
|
---|
[78d50bd] | 988 | return EINVAL;
|
---|
[e11c527] | 989 | }
|
---|
[78d50bd] | 990 |
|
---|
[e11c527] | 991 | if (vbds_bsa_translate(part, ba, cnt, &gba) != EOK) {
|
---|
| 992 | fibril_rwlock_read_unlock(&part->lock);
|
---|
[78d50bd] | 993 | return ELIMIT;
|
---|
[e11c527] | 994 | }
|
---|
| 995 |
|
---|
| 996 | rc = block_read_direct(part->disk->svc_id, gba, cnt, buf);
|
---|
| 997 | fibril_rwlock_read_unlock(&part->lock);
|
---|
[78d50bd] | 998 |
|
---|
[e11c527] | 999 | return rc;
|
---|
[78d50bd] | 1000 | }
|
---|
| 1001 |
|
---|
[b7fd2a0] | 1002 | static errno_t vbds_bd_sync_cache(bd_srv_t *bd, aoff64_t ba, size_t cnt)
|
---|
[78d50bd] | 1003 | {
|
---|
| 1004 | vbds_part_t *part = bd_srv_part(bd);
|
---|
| 1005 | aoff64_t gba;
|
---|
[b7fd2a0] | 1006 | errno_t rc;
|
---|
[78d50bd] | 1007 |
|
---|
[55f8c6e7] | 1008 | log_msg(LOG_DEFAULT, LVL_DEBUG2, "vbds_bd_sync_cache()");
|
---|
[e11c527] | 1009 | fibril_rwlock_read_lock(&part->lock);
|
---|
[78d50bd] | 1010 |
|
---|
| 1011 | /* XXX Allow full-disk sync? */
|
---|
| 1012 | if (ba != 0 || cnt != 0) {
|
---|
[e11c527] | 1013 | if (vbds_bsa_translate(part, ba, cnt, &gba) != EOK) {
|
---|
| 1014 | fibril_rwlock_read_unlock(&part->lock);
|
---|
[78d50bd] | 1015 | return ELIMIT;
|
---|
[e11c527] | 1016 | }
|
---|
[78d50bd] | 1017 | } else {
|
---|
| 1018 | gba = 0;
|
---|
| 1019 | }
|
---|
| 1020 |
|
---|
[e11c527] | 1021 | rc = block_sync_cache(part->disk->svc_id, gba, cnt);
|
---|
| 1022 | fibril_rwlock_read_unlock(&part->lock);
|
---|
| 1023 | return rc;
|
---|
[78d50bd] | 1024 | }
|
---|
| 1025 |
|
---|
[b7fd2a0] | 1026 | static errno_t vbds_bd_write_blocks(bd_srv_t *bd, aoff64_t ba, size_t cnt,
|
---|
[78d50bd] | 1027 | const void *buf, size_t size)
|
---|
| 1028 | {
|
---|
| 1029 | vbds_part_t *part = bd_srv_part(bd);
|
---|
| 1030 | aoff64_t gba;
|
---|
[b7fd2a0] | 1031 | errno_t rc;
|
---|
[78d50bd] | 1032 |
|
---|
[55f8c6e7] | 1033 | log_msg(LOG_DEFAULT, LVL_DEBUG2, "vbds_bd_write_blocks()");
|
---|
[e11c527] | 1034 | fibril_rwlock_read_lock(&part->lock);
|
---|
[78d50bd] | 1035 |
|
---|
[e11c527] | 1036 | if (cnt * part->disk->block_size < size) {
|
---|
| 1037 | fibril_rwlock_read_unlock(&part->lock);
|
---|
[78d50bd] | 1038 | return EINVAL;
|
---|
[e11c527] | 1039 | }
|
---|
[78d50bd] | 1040 |
|
---|
[e11c527] | 1041 | if (vbds_bsa_translate(part, ba, cnt, &gba) != EOK) {
|
---|
| 1042 | fibril_rwlock_read_unlock(&part->lock);
|
---|
[78d50bd] | 1043 | return ELIMIT;
|
---|
[e11c527] | 1044 | }
|
---|
[78d50bd] | 1045 |
|
---|
[e11c527] | 1046 | rc = block_write_direct(part->disk->svc_id, gba, cnt, buf);
|
---|
| 1047 | fibril_rwlock_read_unlock(&part->lock);
|
---|
| 1048 | return rc;
|
---|
[78d50bd] | 1049 | }
|
---|
| 1050 |
|
---|
[b7fd2a0] | 1051 | static errno_t vbds_bd_get_block_size(bd_srv_t *bd, size_t *rsize)
|
---|
[78d50bd] | 1052 | {
|
---|
[3faa03d] | 1053 | vbds_part_t *part = bd_srv_part(bd);
|
---|
| 1054 |
|
---|
[55f8c6e7] | 1055 | log_msg(LOG_DEFAULT, LVL_DEBUG2, "vbds_bd_get_block_size()");
|
---|
[e11c527] | 1056 |
|
---|
| 1057 | fibril_rwlock_read_lock(&part->lock);
|
---|
[3faa03d] | 1058 | *rsize = part->disk->block_size;
|
---|
[e11c527] | 1059 | fibril_rwlock_read_unlock(&part->lock);
|
---|
| 1060 |
|
---|
[78d50bd] | 1061 | return EOK;
|
---|
| 1062 | }
|
---|
| 1063 |
|
---|
[b7fd2a0] | 1064 | static errno_t vbds_bd_get_num_blocks(bd_srv_t *bd, aoff64_t *rnb)
|
---|
[78d50bd] | 1065 | {
|
---|
[3faa03d] | 1066 | vbds_part_t *part = bd_srv_part(bd);
|
---|
| 1067 |
|
---|
[55f8c6e7] | 1068 | log_msg(LOG_DEFAULT, LVL_DEBUG2, "vbds_bd_get_num_blocks()");
|
---|
[e11c527] | 1069 |
|
---|
| 1070 | fibril_rwlock_read_lock(&part->lock);
|
---|
[3faa03d] | 1071 | *rnb = part->nblocks;
|
---|
[e11c527] | 1072 | fibril_rwlock_read_unlock(&part->lock);
|
---|
| 1073 |
|
---|
[78d50bd] | 1074 | return EOK;
|
---|
| 1075 | }
|
---|
| 1076 |
|
---|
[4285f384] | 1077 | static errno_t vbds_bd_eject(bd_srv_t *bd)
|
---|
| 1078 | {
|
---|
| 1079 | vbds_part_t *part = bd_srv_part(bd);
|
---|
| 1080 | async_sess_t *sess;
|
---|
| 1081 | bd_t *bdc;
|
---|
| 1082 | errno_t rc;
|
---|
| 1083 |
|
---|
| 1084 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_bd_eject()");
|
---|
| 1085 |
|
---|
| 1086 | fibril_rwlock_read_lock(&part->lock);
|
---|
| 1087 |
|
---|
| 1088 | sess = loc_service_connect(part->disk->svc_id, INTERFACE_BLOCK, 0);
|
---|
| 1089 | if (sess == NULL) {
|
---|
| 1090 | log_msg(LOG_DEFAULT, LVL_WARN,
|
---|
| 1091 | "vbds_bd_eject() - failed connect");
|
---|
| 1092 | fibril_rwlock_read_unlock(&part->lock);
|
---|
| 1093 | return EIO;
|
---|
| 1094 | }
|
---|
| 1095 |
|
---|
| 1096 | rc = bd_open(sess, &bdc);
|
---|
| 1097 | if (rc != EOK) {
|
---|
| 1098 | log_msg(LOG_DEFAULT, LVL_WARN,
|
---|
| 1099 | "vbds_bd_eject() - failed open");
|
---|
| 1100 | async_hangup(sess);
|
---|
| 1101 | fibril_rwlock_read_unlock(&part->lock);
|
---|
| 1102 | return EIO;
|
---|
| 1103 | }
|
---|
| 1104 |
|
---|
| 1105 | rc = bd_eject(bdc);
|
---|
| 1106 |
|
---|
| 1107 | bd_close(bdc);
|
---|
| 1108 | async_hangup(sess);
|
---|
| 1109 |
|
---|
| 1110 | fibril_rwlock_read_unlock(&part->lock);
|
---|
| 1111 | return rc;
|
---|
| 1112 | }
|
---|
| 1113 |
|
---|
[984a9ba] | 1114 | void vbds_bd_conn(ipc_call_t *icall, void *arg)
|
---|
[78d50bd] | 1115 | {
|
---|
| 1116 | vbds_part_t *part;
|
---|
[b7fd2a0] | 1117 | errno_t rc;
|
---|
[c43db5f] | 1118 | service_id_t svcid;
|
---|
[78d50bd] | 1119 |
|
---|
[55f8c6e7] | 1120 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_bd_conn()");
|
---|
[3faa03d] | 1121 |
|
---|
[fafb8e5] | 1122 | svcid = ipc_get_arg2(icall);
|
---|
[78d50bd] | 1123 |
|
---|
[55f8c6e7] | 1124 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_bd_conn() - svcid=%zu", svcid);
|
---|
[3faa03d] | 1125 |
|
---|
[c43db5f] | 1126 | rc = vbds_part_by_svcid(svcid, &part);
|
---|
[78d50bd] | 1127 | if (rc != EOK) {
|
---|
[55f8c6e7] | 1128 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbd_bd_conn() - partition "
|
---|
[3faa03d] | 1129 | "not found.");
|
---|
[984a9ba] | 1130 | async_answer_0(icall, EINVAL);
|
---|
[78d50bd] | 1131 | return;
|
---|
| 1132 | }
|
---|
| 1133 |
|
---|
[55f8c6e7] | 1134 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_bd_conn() - call bd_conn");
|
---|
[984a9ba] | 1135 | bd_conn(icall, &part->bds);
|
---|
[e11c527] | 1136 | vbds_part_del_ref(part);
|
---|
[78d50bd] | 1137 | }
|
---|
| 1138 |
|
---|
| 1139 | /** Translate block segment address with range checking. */
|
---|
[b7fd2a0] | 1140 | static errno_t vbds_bsa_translate(vbds_part_t *part, aoff64_t ba, size_t cnt,
|
---|
[78d50bd] | 1141 | aoff64_t *gba)
|
---|
| 1142 | {
|
---|
| 1143 | if (ba + cnt > part->nblocks)
|
---|
| 1144 | return ELIMIT;
|
---|
| 1145 |
|
---|
| 1146 | *gba = part->block0 + ba;
|
---|
[28ed0d9] | 1147 | return EOK;
|
---|
| 1148 | }
|
---|
| 1149 |
|
---|
[6439741] | 1150 | /** Register service for partition */
|
---|
[b7fd2a0] | 1151 | static errno_t vbds_part_svc_register(vbds_part_t *part)
|
---|
[6439741] | 1152 | {
|
---|
| 1153 | char *name;
|
---|
| 1154 | service_id_t psid;
|
---|
| 1155 | int idx;
|
---|
[b7fd2a0] | 1156 | errno_t rc;
|
---|
[6439741] | 1157 |
|
---|
| 1158 | idx = part->lpart->index;
|
---|
| 1159 |
|
---|
[d5c1051] | 1160 | if (asprintf(&name, "%sp%u", part->disk->svc_name, idx) < 0) {
|
---|
[6439741] | 1161 | log_msg(LOG_DEFAULT, LVL_ERROR, "Out of memory.");
|
---|
| 1162 | return ENOMEM;
|
---|
| 1163 | }
|
---|
| 1164 |
|
---|
[55f8c6e7] | 1165 | log_msg(LOG_DEFAULT, LVL_DEBUG, "loc_service_register('%s')",
|
---|
[edebb4a1] | 1166 | name);
|
---|
[ca48672] | 1167 | rc = loc_service_register(vbds_srv, name, fallback_port_id, &psid);
|
---|
[6439741] | 1168 | if (rc != EOK) {
|
---|
| 1169 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failed registering "
|
---|
[c1694b6b] | 1170 | "service %s: %s.", name, str_error(rc));
|
---|
[6439741] | 1171 | free(name);
|
---|
| 1172 | free(part);
|
---|
| 1173 | return EIO;
|
---|
| 1174 | }
|
---|
| 1175 |
|
---|
[4c6fd56] | 1176 | rc = loc_service_add_to_cat(vbds_srv, psid, part_cid);
|
---|
[372df8f] | 1177 | if (rc != EOK) {
|
---|
| 1178 | log_msg(LOG_DEFAULT, LVL_ERROR, "Failled adding partition "
|
---|
| 1179 | "service %s to partition category.", name);
|
---|
| 1180 | free(name);
|
---|
| 1181 | free(part);
|
---|
| 1182 |
|
---|
[4c6fd56] | 1183 | rc = loc_service_unregister(vbds_srv, psid);
|
---|
[372df8f] | 1184 | if (rc != EOK) {
|
---|
| 1185 | log_msg(LOG_DEFAULT, LVL_ERROR, "Error unregistering "
|
---|
| 1186 | "service. Rollback failed.");
|
---|
| 1187 | }
|
---|
| 1188 | return EIO;
|
---|
| 1189 | }
|
---|
| 1190 |
|
---|
[6439741] | 1191 | free(name);
|
---|
| 1192 | part->svc_id = psid;
|
---|
| 1193 | part->reg_idx = idx;
|
---|
| 1194 | return EOK;
|
---|
| 1195 | }
|
---|
| 1196 |
|
---|
| 1197 | /** Unregister service for partition */
|
---|
[b7fd2a0] | 1198 | static errno_t vbds_part_svc_unregister(vbds_part_t *part)
|
---|
[6439741] | 1199 | {
|
---|
[b7fd2a0] | 1200 | errno_t rc;
|
---|
[6439741] | 1201 |
|
---|
[55f8c6e7] | 1202 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_part_svc_unregister("
|
---|
[3a43785] | 1203 | "disk->svc_name='%s', id=%zu)", part->disk->svc_name, part->svc_id);
|
---|
| 1204 |
|
---|
[4c6fd56] | 1205 | rc = loc_service_unregister(vbds_srv, part->svc_id);
|
---|
[6439741] | 1206 | if (rc != EOK)
|
---|
| 1207 | return EIO;
|
---|
| 1208 |
|
---|
| 1209 | part->svc_id = 0;
|
---|
| 1210 | part->reg_idx = 0;
|
---|
| 1211 | return EOK;
|
---|
| 1212 | }
|
---|
| 1213 |
|
---|
| 1214 | /** Update service names for any partition whose index has changed. */
|
---|
[b7fd2a0] | 1215 | static errno_t vbds_part_indices_update(vbds_disk_t *disk)
|
---|
[6439741] | 1216 | {
|
---|
| 1217 | label_part_info_t lpinfo;
|
---|
[b7fd2a0] | 1218 | errno_t rc;
|
---|
[6439741] | 1219 |
|
---|
[55f8c6e7] | 1220 | log_msg(LOG_DEFAULT, LVL_DEBUG, "vbds_part_indices_update()");
|
---|
[6439741] | 1221 |
|
---|
[e11c527] | 1222 | fibril_mutex_lock(&vbds_parts_lock);
|
---|
| 1223 |
|
---|
[6439741] | 1224 | /* First unregister services for partitions whose index has changed */
|
---|
| 1225 | list_foreach(disk->parts, ldisk, vbds_part_t, part) {
|
---|
[e11c527] | 1226 | fibril_rwlock_write_lock(&part->lock);
|
---|
[6439741] | 1227 | if (part->svc_id != 0 && part->lpart->index != part->reg_idx) {
|
---|
| 1228 | rc = vbds_part_svc_unregister(part);
|
---|
| 1229 | if (rc != EOK) {
|
---|
[e11c527] | 1230 | fibril_rwlock_write_unlock(&part->lock);
|
---|
| 1231 | fibril_mutex_unlock(&vbds_parts_lock);
|
---|
[55f8c6e7] | 1232 | log_msg(LOG_DEFAULT, LVL_ERROR, "Error "
|
---|
[6439741] | 1233 | "un-registering partition.");
|
---|
| 1234 | return EIO;
|
---|
| 1235 | }
|
---|
| 1236 | }
|
---|
[e11c527] | 1237 |
|
---|
| 1238 | fibril_rwlock_write_unlock(&part->lock);
|
---|
[6439741] | 1239 | }
|
---|
| 1240 |
|
---|
| 1241 | /* Now re-register those services under the new indices */
|
---|
| 1242 | list_foreach(disk->parts, ldisk, vbds_part_t, part) {
|
---|
[e11c527] | 1243 | fibril_rwlock_write_lock(&part->lock);
|
---|
[6439741] | 1244 | label_part_get_info(part->lpart, &lpinfo);
|
---|
| 1245 | if (part->svc_id == 0 && lpinfo.pkind != lpk_extended) {
|
---|
| 1246 | rc = vbds_part_svc_register(part);
|
---|
| 1247 | if (rc != EOK) {
|
---|
[e11c527] | 1248 | fibril_rwlock_write_unlock(&part->lock);
|
---|
| 1249 | fibril_mutex_unlock(&vbds_parts_lock);
|
---|
[55f8c6e7] | 1250 | log_msg(LOG_DEFAULT, LVL_ERROR, "Error "
|
---|
[6439741] | 1251 | "re-registering partition.");
|
---|
| 1252 | return EIO;
|
---|
| 1253 | }
|
---|
| 1254 | }
|
---|
[e11c527] | 1255 |
|
---|
| 1256 | fibril_rwlock_write_unlock(&part->lock);
|
---|
[6439741] | 1257 | }
|
---|
| 1258 |
|
---|
[e11c527] | 1259 | fibril_mutex_unlock(&vbds_parts_lock);
|
---|
| 1260 |
|
---|
[6439741] | 1261 | return EOK;
|
---|
| 1262 | }
|
---|
| 1263 |
|
---|
[deacc58d] | 1264 | /** Get block size wrapper for liblabel */
|
---|
[b7fd2a0] | 1265 | static errno_t vbds_label_get_bsize(void *arg, size_t *bsize)
|
---|
[deacc58d] | 1266 | {
|
---|
| 1267 | vbds_disk_t *disk = (vbds_disk_t *)arg;
|
---|
| 1268 | return block_get_bsize(disk->svc_id, bsize);
|
---|
| 1269 | }
|
---|
| 1270 |
|
---|
| 1271 | /** Get number of blocks wrapper for liblabel */
|
---|
[b7fd2a0] | 1272 | static errno_t vbds_label_get_nblocks(void *arg, aoff64_t *nblocks)
|
---|
[deacc58d] | 1273 | {
|
---|
| 1274 | vbds_disk_t *disk = (vbds_disk_t *)arg;
|
---|
| 1275 | return block_get_nblocks(disk->svc_id, nblocks);
|
---|
| 1276 | }
|
---|
| 1277 |
|
---|
| 1278 | /** Read blocks wrapper for liblabel */
|
---|
[b7fd2a0] | 1279 | static errno_t vbds_label_read(void *arg, aoff64_t ba, size_t cnt, void *buf)
|
---|
[deacc58d] | 1280 | {
|
---|
| 1281 | vbds_disk_t *disk = (vbds_disk_t *)arg;
|
---|
| 1282 | return block_read_direct(disk->svc_id, ba, cnt, buf);
|
---|
| 1283 | }
|
---|
| 1284 |
|
---|
| 1285 | /** Write blocks wrapper for liblabel */
|
---|
[b7fd2a0] | 1286 | static errno_t vbds_label_write(void *arg, aoff64_t ba, size_t cnt, const void *data)
|
---|
[deacc58d] | 1287 | {
|
---|
| 1288 | vbds_disk_t *disk = (vbds_disk_t *)arg;
|
---|
| 1289 | return block_write_direct(disk->svc_id, ba, cnt, data);
|
---|
| 1290 | }
|
---|
| 1291 |
|
---|
[28ed0d9] | 1292 | /** @}
|
---|
| 1293 | */
|
---|