storage_backend_disk.c 25.8 KB
Newer Older
1 2 3
/*
 * storage_backend_disk.c: storage backend for disk handling
 *
4
 * Copyright (C) 2007-2008, 2010-2013 Red Hat, Inc.
5 6 7 8 9 10 11 12 13 14 15 16 17
 * Copyright (C) 2007-2008 Daniel P. Berrange
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
18
 * License along with this library.  If not, see
O
Osier Yang 已提交
19
 * <http://www.gnu.org/licenses/>.
20 21 22 23 24
 *
 * Author: Daniel P. Berrange <berrange@redhat.com>
 */

#include <config.h>
C
Cole Robinson 已提交
25
#include <string.h>
26
#include <unistd.h>
27
#include <stdio.h>
28

29
#include "dirname.h"
30
#include "virerror.h"
31
#include "virlog.h"
32
#include "storage_backend_disk.h"
33
#include "viralloc.h"
34
#include "vircommand.h"
35
#include "virfile.h"
36
#include "configmake.h"
37
#include "virstring.h"
38

39 40
#define VIR_FROM_THIS VIR_FROM_STORAGE

41
#define PARTHELPER LIBEXECDIR "/libvirt_parthelper"
42

43 44
#define SECTOR_SIZE 512

45
static int
46
virStorageBackendDiskMakeDataVol(virStoragePoolObjPtr pool,
47 48 49 50 51 52
                                 char **const groups,
                                 virStorageVolDefPtr vol)
{
    char *tmp, *devpath;

    if (vol == NULL) {
53
        if (VIR_ALLOC(vol) < 0)
54 55
            return -1;

56 57 58 59 60 61
        if (VIR_REALLOC_N(pool->volumes.objs,
                          pool->volumes.count+1) < 0) {
            virStorageVolDefFree(vol);
            return -1;
        }
        pool->volumes.objs[pool->volumes.count++] = vol;
62 63 64 65 66

        /* Prepended path will be same for all partitions, so we can
         * strip the path to form a reasonable pool-unique name
         */
        tmp = strrchr(groups[0], '/');
67
        if (VIR_STRDUP(vol->name, tmp ? tmp + 1 : groups[0]) < 0)
68 69 70 71
            return -1;
    }

    if (vol->target.path == NULL) {
72
        if (VIR_STRDUP(devpath, groups[0]) < 0)
73 74 75 76 77 78 79 80
            return -1;

        /* Now figure out the stable path
         *
         * XXX this method is O(N) because it scans the pool target
         * dir every time its run. Should figure out a more efficient
         * way of doing this...
         */
81
        vol->target.path = virStorageBackendStablePath(pool, devpath, true);
82
        VIR_FREE(devpath);
83 84
        if (vol->target.path == NULL)
            return -1;
85 86 87 88
    }

    if (vol->key == NULL) {
        /* XXX base off a unique key of the underlying disk */
89
        if (VIR_STRDUP(vol->key, vol->target.path) < 0)
90 91 92 93
            return -1;
    }

    if (vol->source.extents == NULL) {
94
        if (VIR_ALLOC(vol->source.extents) < 0)
95 96 97 98 99
            return -1;
        vol->source.nextent = 1;

        if (virStrToLong_ull(groups[3], NULL, 10,
                             &vol->source.extents[0].start) < 0) {
100 101
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("cannot parse device start location"));
102 103 104 105 106
            return -1;
        }

        if (virStrToLong_ull(groups[4], NULL, 10,
                             &vol->source.extents[0].end) < 0) {
107 108
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("cannot parse device end location"));
109 110 111
            return -1;
        }

112 113
        if (VIR_STRDUP(vol->source.extents[0].path,
                       pool->def->source.devices[0].path) < 0)
114 115 116 117
            return -1;
    }

    /* Refresh allocation/capacity/perms */
118
    if (virStorageBackendUpdateVolInfo(vol, 1) < 0)
119 120
        return -1;

121
    /* set partition type */
E
Eric Blake 已提交
122
    if (STREQ(groups[1], "normal"))
123
       vol->target.type = VIR_STORAGE_VOL_DISK_TYPE_PRIMARY;
E
Eric Blake 已提交
124
    else if (STREQ(groups[1], "logical"))
125
       vol->target.type = VIR_STORAGE_VOL_DISK_TYPE_LOGICAL;
E
Eric Blake 已提交
126
    else if (STREQ(groups[1], "extended"))
127 128 129 130
       vol->target.type = VIR_STORAGE_VOL_DISK_TYPE_EXTENDED;
    else
       vol->target.type = VIR_STORAGE_VOL_DISK_TYPE_NONE;

131 132
    vol->type = VIR_STORAGE_VOL_BLOCK;

133 134 135 136 137 138 139 140 141 142 143 144 145 146
    /* The above gets allocation wrong for
     * extended partitions, so overwrite it */
    vol->allocation = vol->capacity =
        (vol->source.extents[0].end - vol->source.extents[0].start);

    if (STRNEQ(groups[2], "metadata"))
        pool->def->allocation += vol->allocation;
    if (vol->source.extents[0].end > pool->def->capacity)
        pool->def->capacity = vol->source.extents[0].end;

    return 0;
}

static int
147
virStorageBackendDiskMakeFreeExtent(virStoragePoolObjPtr pool,
148 149 150 151
                                    char **const groups)
{
    virStoragePoolSourceDevicePtr dev = &pool->def->source.devices[0];

152 153
    if (VIR_REALLOC_N(dev->freeExtents,
                      dev->nfreeExtent + 1) < 0)
154 155 156
        return -1;

    memset(dev->freeExtents +
157 158
           dev->nfreeExtent, 0,
           sizeof(dev->freeExtents[0]));
159

160
    /* set type of free area */
E
Eric Blake 已提交
161
    if (STREQ(groups[1], "logical")) {
162 163 164 165 166 167
        dev->freeExtents[dev->nfreeExtent].type = VIR_STORAGE_FREE_LOGICAL;
    } else {
        dev->freeExtents[dev->nfreeExtent].type = VIR_STORAGE_FREE_NORMAL;
    }


168 169 170 171 172 173 174 175
    if (virStrToLong_ull(groups[3], NULL, 10,
                         &dev->freeExtents[dev->nfreeExtent].start) < 0)
        return -1; /* Don't bother to re-alloc freeExtents - it'll be free'd shortly */

    if (virStrToLong_ull(groups[4], NULL, 10,
                         &dev->freeExtents[dev->nfreeExtent].end) < 0)
        return -1; /* Don't bother to re-alloc freeExtents - it'll be free'd shortly */

176 177 178 179 180
    /* first block reported as free, even if it is not */
    if (dev->freeExtents[dev->nfreeExtent].start == 0) {
        dev->freeExtents[dev->nfreeExtent].start = SECTOR_SIZE;
    }

181 182 183 184 185 186 187 188 189 190 191 192 193
    pool->def->available +=
        (dev->freeExtents[dev->nfreeExtent].end -
         dev->freeExtents[dev->nfreeExtent].start);
    if (dev->freeExtents[dev->nfreeExtent].end > pool->def->capacity)
        pool->def->capacity = dev->freeExtents[dev->nfreeExtent].end;

    dev->nfreeExtent++;

    return 0;
}


static int
194
virStorageBackendDiskMakeVol(virStoragePoolObjPtr pool,
195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210
                             size_t ntok ATTRIBUTE_UNUSED,
                             char **const groups,
                             void *data)
{
    /*
     * Ignore normal+metadata, and logical+metadata partitions
     * since they're basically internal book-keeping regions
     * we have no control over. Do keep extended+metadata though
     * because that's the MS-DOS extended partition region we
     * need to be able to view/create/delete
     */
    if ((STREQ(groups[1], "normal") ||
         STREQ(groups[1], "logical")) &&
        STREQ(groups[2], "metadata"))
        return 0;

R
Richard W.M. Jones 已提交
211
    /* Remaining data / metadata parts get turn into volumes... */
212 213 214
    if (STREQ(groups[2], "metadata") ||
        STREQ(groups[2], "data")) {
        virStorageVolDefPtr vol = data;
215 216 217 218 219 220 221 222 223 224 225 226

        if (vol) {
            /* We're searching for a specific vol only */
            if (vol->key) {
                if (STRNEQ(vol->key, groups[0]))
                    return 0;
            } else if (virStorageVolDefFindByKey(pool, groups[0]) != NULL) {
                /* If no key, the volume must be newly created. If groups[0]
                 * isn't already a volume, assume it's the path we want */
                return 0;
            }
        }
227

228
        return virStorageBackendDiskMakeDataVol(pool, groups, vol);
229 230
    } else if (STREQ(groups[2], "free")) {
        /* ....or free space extents */
231
        return virStorageBackendDiskMakeFreeExtent(pool, groups);
232
    } else {
R
Richard W.M. Jones 已提交
233
        /* This code path should never happen unless someone changed
234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250
         * libvirt_parthelper forgot to change this code */
        return -1;
    }
}


/* To get a list of partitions we run an external helper
 * tool which then uses parted APIs. This is because
 * parted's API is not compatible with libvirt's license
 * but we really really want to use parted because the
 * other options all suck :-)
 *
 * All the other storage backends run an external tool for
 * listing volumes so this really isn't too much of a pain,
 * and we can even ensure the output is friendly.
 */
static int
251
virStorageBackendDiskReadPartitions(virStoragePoolObjPtr pool,
252 253 254 255 256 257 258 259 260
                                    virStorageVolDefPtr vol)
{
    /*
     *  # libvirt_parthelper DEVICE
     * /dev/sda1      normal       data        32256    106928128    106896384
     * /dev/sda2      normal       data    106928640 100027629568  99920701440
     * -              normal   metadata 100027630080 100030242304      2612736
     *
     */
261 262 263 264
    virCommandPtr cmd = virCommandNewArgList(PARTHELPER,
                                             pool->def->source.devices[0].path,
                                             NULL);
    int ret;
265 266 267

    pool->def->allocation = pool->def->capacity = pool->def->available = 0;

268 269 270 271 272 273 274
    ret = virStorageBackendRunProgNul(pool,
                                      cmd,
                                      6,
                                      virStorageBackendDiskMakeVol,
                                      vol);
    virCommandFree(cmd);
    return ret;
275 276
}

277
static int
278 279 280 281
virStorageBackendDiskMakePoolGeometry(virStoragePoolObjPtr pool,
                                      size_t ntok ATTRIBUTE_UNUSED,
                                      char **const groups,
                                      void *data ATTRIBUTE_UNUSED)
282
{
P
Peter Krempa 已提交
283 284 285 286 287 288 289 290
    virStoragePoolSourceDevicePtr device = &(pool->def->source.devices[0]);
    if (virStrToLong_i(groups[0], NULL, 0, &device->geometry.cylinders) < 0 ||
        virStrToLong_i(groups[1], NULL, 0, &device->geometry.heads) < 0 ||
        virStrToLong_i(groups[2], NULL, 0, &device->geometry.sectors) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("Failed to create disk pool geometry"));
        return -1;
    }
291

P
Peter Krempa 已提交
292
    return 0;
293 294 295
}

static int
296
virStorageBackendDiskReadGeometry(virStoragePoolObjPtr pool)
297
{
298 299 300 301 302 303 304 305 306 307 308 309 310
    virCommandPtr cmd = virCommandNewArgList(PARTHELPER,
                                             pool->def->source.devices[0].path,
                                             "-g",
                                             NULL);
    int ret;

    ret = virStorageBackendRunProgNul(pool,
                                      cmd,
                                      3,
                                      virStorageBackendDiskMakePoolGeometry,
                                      NULL);
    virCommandFree(cmd);
    return ret;
311
}
312 313

static int
314
virStorageBackendDiskRefreshPool(virConnectPtr conn ATTRIBUTE_UNUSED,
315 316
                                 virStoragePoolObjPtr pool)
{
317
    VIR_FREE(pool->def->source.devices[0].freeExtents);
318 319
    pool->def->source.devices[0].nfreeExtent = 0;

320
    virFileWaitForDevices();
321

322
    if (!virFileExists(pool->def->source.devices[0].path)) {
323 324 325
        virReportError(VIR_ERR_INVALID_ARG,
                       _("device path '%s' doesn't exist"),
                       pool->def->source.devices[0].path);
326 327 328
        return -1;
    }

329
    if (virStorageBackendDiskReadGeometry(pool) != 0) {
330 331 332
        return -1;
    }

333
    return virStorageBackendDiskReadPartitions(pool, NULL);
334 335 336
}


337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360
/**
 * Check for a valid disk label (partition table) on device
 *
 * return: 0 - valid disk label found
 *        >0 - no or unrecognized disk label
 *        <0 - error finding the disk label
 */
static int
virStorageBackendDiskFindLabel(const char* device)
{
    const char *const args[] = {
        device, "print", "--script", NULL,
    };
    virCommandPtr cmd = virCommandNew(PARTED);
    char *output = NULL;
    int ret = -1;

    virCommandAddArgSet(cmd, args);
    virCommandAddEnvString(cmd, "LC_ALL=C");
    virCommandSetOutputBuffer(cmd, &output);

    /* if parted succeeds we have a valid partition table */
    ret = virCommandRun(cmd, NULL);
    if (ret < 0) {
361
        if (strstr(output, "unrecognised disk label"))
362 363 364 365 366 367 368 369 370
            ret = 1;
    }

    virCommandFree(cmd);
    VIR_FREE(output);
    return ret;
}


371 372 373 374
/**
 * Write a new partition table header
 */
static int
375
virStorageBackendDiskBuildPool(virConnectPtr conn ATTRIBUTE_UNUSED,
376
                               virStoragePoolObjPtr pool,
E
Eric Blake 已提交
377
                               unsigned int flags)
378
{
379 380
    bool ok_to_mklabel = false;
    int ret = -1;
381
    virCommandPtr cmd = NULL;
382

383 384
    virCheckFlags(VIR_STORAGE_POOL_BUILD_OVERWRITE |
                  VIR_STORAGE_POOL_BUILD_NO_OVERWRITE, ret);
E
Eric Blake 已提交
385

386 387
    if (flags == (VIR_STORAGE_POOL_BUILD_OVERWRITE |
                  VIR_STORAGE_POOL_BUILD_NO_OVERWRITE)) {
388
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
389 390
                       _("Overwrite and no overwrite flags"
                         " are mutually exclusive"));
391 392
        goto error;
    }
393

394 395 396 397 398
    if (flags & VIR_STORAGE_POOL_BUILD_OVERWRITE)
        ok_to_mklabel = true;
    else {
        int check;

399
        check = virStorageBackendDiskFindLabel(
400 401 402 403
                    pool->def->source.devices[0].path);
        if (check > 0) {
            ok_to_mklabel = true;
        } else if (check < 0) {
404
            virReportError(VIR_ERR_OPERATION_FAILED, "%s",
405
                           _("Error checking for disk label"));
406
        } else {
407
            virReportError(VIR_ERR_OPERATION_INVALID, "%s",
408
                           _("Disk label already present"));
409 410 411
        }
    }

412 413 414 415 416 417 418 419 420
    if (ok_to_mklabel) {
        /* eg parted /dev/sda mklabel msdos */
        cmd = virCommandNewArgList(PARTED,
                                   pool->def->source.devices[0].path,
                                   "mklabel",
                                   "--script",
                                   ((pool->def->source.format == VIR_STORAGE_POOL_DISK_DOS) ? "msdos" :
                                   virStoragePoolFormatDiskTypeToString(pool->def->source.format)),
                                   NULL);
421
        ret = virCommandRun(cmd, NULL);
422
    }
423 424

error:
425
    virCommandFree(cmd);
426
    return ret;
427 428
}

429 430 431 432
/**
 * Decides what kind of partition type that should be created.
 * Important when the partition table is of msdos type
 */
433
static int
434 435 436 437 438
virStorageBackendDiskPartTypeToCreate(virStoragePoolObjPtr pool)
{
    if (pool->def->source.format == VIR_STORAGE_POOL_DISK_DOS) {
        /* count primary and extended paritions,
           can't be more than 3 to create a new primary partition */
439
        size_t i;
440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456
        int count = 0;
        for (i = 0; i < pool->volumes.count; i++) {
             if (pool->volumes.objs[i]->target.type == VIR_STORAGE_VOL_DISK_TYPE_PRIMARY ||
                 pool->volumes.objs[i]->target.type == VIR_STORAGE_VOL_DISK_TYPE_EXTENDED) {
                     count++;
             }
        }
        if (count >= 4) {
            return VIR_STORAGE_VOL_DISK_TYPE_LOGICAL;
        }
    }

    /* for all other cases, all partitions are primary */
    return VIR_STORAGE_VOL_DISK_TYPE_PRIMARY;
}

static int
457
virStorageBackendDiskPartFormat(virStoragePoolObjPtr pool,
458
                                virStorageVolDefPtr vol,
E
Eric Blake 已提交
459
                                char** partFormat)
460
{
461
    size_t i;
462
    if (pool->def->source.format == VIR_STORAGE_POOL_DISK_DOS) {
E
Eric Blake 已提交
463 464 465
        const char *partedFormat;
        partedFormat = virStoragePartedFsTypeTypeToString(vol->target.format);
        if (partedFormat == NULL) {
466 467
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("Invalid partition type"));
E
Eric Blake 已提交
468
            return -1;
469 470 471 472
        }
        if (vol->target.format == VIR_STORAGE_VOL_DISK_EXTENDED) {
            /* make sure we don't have a extended partition already */
            for (i = 0; i < pool->volumes.count; i++) {
E
Eric Blake 已提交
473 474
                if (pool->volumes.objs[i]->target.format ==
                    VIR_STORAGE_VOL_DISK_EXTENDED) {
475 476
                    virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                                   _("extended partition already exists"));
E
Eric Blake 已提交
477 478
                    return -1;
                }
479
            }
480
            if (VIR_STRDUP(*partFormat, partedFormat) < 0)
E
Eric Blake 已提交
481
                return -1;
482 483 484 485 486 487
        } else {
            /* create primary partition as long as it is possible
               and after that check if an extended partition exists
               to create logical partitions. */
            /* XXX Only support one extended partition */
            switch (virStorageBackendDiskPartTypeToCreate(pool)) {
E
Eric Blake 已提交
488
            case VIR_STORAGE_VOL_DISK_TYPE_PRIMARY:
489
                if (virAsprintf(partFormat, "primary %s", partedFormat) < 0)
E
Eric Blake 已提交
490
                    return -1;
E
Eric Blake 已提交
491 492 493 494 495 496
                break;
            case VIR_STORAGE_VOL_DISK_TYPE_LOGICAL:
                /* make sure we have a extended partition */
                for (i = 0; i < pool->volumes.count; i++) {
                    if (pool->volumes.objs[i]->target.format ==
                        VIR_STORAGE_VOL_DISK_EXTENDED) {
E
Eric Blake 已提交
497
                        if (virAsprintf(partFormat, "logical %s",
498
                                        partedFormat) < 0)
E
Eric Blake 已提交
499
                            return -1;
E
Eric Blake 已提交
500 501 502 503
                        break;
                    }
                }
                if (i == pool->volumes.count) {
504 505
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   "%s", _("no extended partition found and no primary partition available"));
E
Eric Blake 已提交
506 507 508 509
                    return -1;
                }
                break;
            default:
510 511
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               "%s", _("unknown partition type"));
E
Eric Blake 已提交
512
                return -1;
513 514 515
            }
        }
    } else {
516
        if (VIR_STRDUP(*partFormat, "primary") < 0)
E
Eric Blake 已提交
517
            return -1;
518 519 520 521 522
    }
    return 0;
}

/**
J
Ján Tomko 已提交
523
 * Aligns a new partition to nearest cylinder boundary
E
Eric Blake 已提交
524
 * when having a msdos partition table type
J
Ján Tomko 已提交
525
 * to avoid any problem with already existing
526 527 528
 * partitions
 */
static int
529
virStorageBackendDiskPartBoundries(virStoragePoolObjPtr pool,
530 531 532
                                   unsigned long long *start,
                                   unsigned long long *end,
                                   unsigned long long allocation)
533
{
534
    size_t i;
535
    int smallestExtent = -1;
536 537 538
    unsigned long long smallestSize = 0;
    unsigned long long extraBytes = 0;
    unsigned long long alignedAllocation = allocation;
539
    virStoragePoolSourceDevicePtr dev = &pool->def->source.devices[0];
540 541 542
    unsigned long long cylinderSize = dev->geometry.heads *
                                      dev->geometry.sectors * SECTOR_SIZE;

543
    VIR_DEBUG("find free area: allocation %llu, cyl size %llu", allocation,
E
Eric Blake 已提交
544
          cylinderSize);
545 546 547
    int partType = virStorageBackendDiskPartTypeToCreate(pool);

    /* how many extra bytes we have since we allocate
J
Ján Tomko 已提交
548
       aligned to the cylinder boundary */
549 550
    extraBytes = cylinderSize - (allocation % cylinderSize);

551
    for (i = 0; i < dev->nfreeExtent; i++) {
552 553 554 555 556 557
         unsigned long long size =
             dev->freeExtents[i].end -
             dev->freeExtents[i].start;
         unsigned long long neededSize = allocation;

         if (pool->def->source.format == VIR_STORAGE_POOL_DISK_DOS) {
J
Ján Tomko 已提交
558
             /* align to cylinder boundary */
559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580
             neededSize += extraBytes;
             if ((*start % cylinderSize) > extraBytes) {
                 /* add an extra cylinder if the offset can't fit within
                    the extra bytes we have */
                 neededSize += cylinderSize;
             }
             /* if we are creating a logical patition, we need one extra
                block between partitions (or actually move start one block) */
             if (partType == VIR_STORAGE_VOL_DISK_TYPE_LOGICAL) {
                 size -= SECTOR_SIZE;
             }
         }
         if (size > neededSize &&
             (smallestSize == 0 ||
             size < smallestSize)) {
             /* for logical partition, the free extent
                must be within a logical free area */
             if (partType == VIR_STORAGE_VOL_DISK_TYPE_LOGICAL &&
                 dev->freeExtents[i].type != VIR_STORAGE_FREE_LOGICAL) {
                 continue;
                 /* for primary partition, the free extent
                    must not be within a logical free area */
E
Eric Blake 已提交
581 582 583
             } else if (partType == VIR_STORAGE_VOL_DISK_TYPE_PRIMARY &&
                        dev->freeExtents[i].type != VIR_STORAGE_FREE_NORMAL) {
                 continue;
584 585 586 587 588 589 590 591
             }
             smallestSize = size;
             smallestExtent = i;
             alignedAllocation = neededSize;
         }
    }

    if (smallestExtent == -1) {
592 593
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("no large enough free extent"));
594 595 596
        return -1;
    }

597
    VIR_DEBUG("aligned alloc %llu", alignedAllocation);
598 599 600 601 602 603 604 605 606
    *start = dev->freeExtents[smallestExtent].start;

    if (partType == VIR_STORAGE_VOL_DISK_TYPE_LOGICAL) {
        /* for logical partition, skip one block */
        *start += SECTOR_SIZE;
    }

    *end = *start + alignedAllocation;
    if (pool->def->source.format == VIR_STORAGE_POOL_DISK_DOS) {
J
Ján Tomko 已提交
607
        /* adjust our allocation if start is not at a cylinder boundary */
608 609 610 611 612
        *end -= (*start % cylinderSize);
    }

    /* counting in byte, we want the last byte of the current sector */
    *end -= 1;
613
    VIR_DEBUG("final aligned start %llu, end %llu", *start, *end);
614 615 616 617 618
    return 0;
}


static int
619
virStorageBackendDiskCreateVol(virConnectPtr conn ATTRIBUTE_UNUSED,
620 621 622
                               virStoragePoolObjPtr pool,
                               virStorageVolDefPtr vol)
{
E
Eric Blake 已提交
623
    int res = -1;
624
    char *partFormat = NULL;
625
    unsigned long long startOffset = 0, endOffset = 0;
626 627 628 629 630
    virCommandPtr cmd = virCommandNewArgList(PARTED,
                                             pool->def->source.devices[0].path,
                                             "mkpart",
                                             "--script",
                                             NULL);
631

632
    if (vol->target.encryption != NULL) {
633 634 635
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       "%s", _("storage pool does not support encrypted "
                               "volumes"));
636
        goto cleanup;
637 638
    }

E
Eric Blake 已提交
639
    if (virStorageBackendDiskPartFormat(pool, vol, &partFormat) != 0) {
640
        goto cleanup;
641
    }
642
    virCommandAddArg(cmd, partFormat);
643

644
    if (virStorageBackendDiskPartBoundries(pool, &startOffset,
645
                                           &endOffset,
646
                                           vol->capacity) != 0) {
E
Eric Blake 已提交
647
        goto cleanup;
648 649
    }

650 651
    virCommandAddArgFormat(cmd, "%lluB", startOffset);
    virCommandAddArgFormat(cmd, "%lluB", endOffset);
652

653
    if (virCommandRun(cmd, NULL) < 0)
E
Eric Blake 已提交
654
        goto cleanup;
655

656
    /* wait for device node to show up */
657
    virFileWaitForDevices();
658

659
    /* Blow away free extent info, as we're about to re-populate it */
660
    VIR_FREE(pool->def->source.devices[0].freeExtents);
661 662
    pool->def->source.devices[0].nfreeExtent = 0;

663 664 665 666
    /* Specifying a target path is meaningless */
    VIR_FREE(vol->target.path);

    /* Fetch actual extent info, generate key */
667
    if (virStorageBackendDiskReadPartitions(pool, vol) < 0)
E
Eric Blake 已提交
668
        goto cleanup;
669

E
Eric Blake 已提交
670 671 672 673
    res = 0;

cleanup:
    VIR_FREE(partFormat);
674
    virCommandFree(cmd);
E
Eric Blake 已提交
675
    return res;
676 677
}

678 679
static int
virStorageBackendDiskBuildVolFrom(virConnectPtr conn,
680
                                  virStoragePoolObjPtr pool,
681 682 683 684 685 686
                                  virStorageVolDefPtr vol,
                                  virStorageVolDefPtr inputvol,
                                  unsigned int flags)
{
    virStorageBackendBuildVolFrom build_func;

687
    build_func = virStorageBackendGetBuildVolFromFunction(vol, inputvol);
688 689 690
    if (!build_func)
        return -1;

691
    return build_func(conn, pool, vol, inputvol, flags);
692
}
693 694

static int
695
virStorageBackendDiskDeleteVol(virConnectPtr conn ATTRIBUTE_UNUSED,
C
Cole Robinson 已提交
696 697
                               virStoragePoolObjPtr pool,
                               virStorageVolDefPtr vol,
E
Eric Blake 已提交
698
                               unsigned int flags)
699
{
C
Cole Robinson 已提交
700
    char *part_num = NULL;
D
Daniel P. Berrange 已提交
701
    char *devpath = NULL;
702
    char *dev_name, *srcname;
703 704
    virCommandPtr cmd = NULL;
    bool isDevMapperDevice;
D
Daniel P. Berrange 已提交
705
    int rc = -1;
C
Cole Robinson 已提交
706

E
Eric Blake 已提交
707 708
    virCheckFlags(0, -1);

709 710
    if (virFileResolveLink(vol->target.path, &devpath) < 0) {
        virReportSystemError(errno,
711 712
                             _("Couldn't read volume target path '%s'"),
                             vol->target.path);
D
Daniel P. Berrange 已提交
713
        goto cleanup;
C
Cole Robinson 已提交
714 715
    }

716 717
    dev_name = last_component(devpath);
    srcname = last_component(pool->def->source.devices[0].path);
718
    VIR_DEBUG("dev_name=%s, srcname=%s", dev_name, srcname);
C
Cole Robinson 已提交
719

720 721
    isDevMapperDevice = virIsDevMapperDevice(devpath);

722
    if (!isDevMapperDevice && !STRPREFIX(dev_name, srcname)) {
723 724 725
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Volume path '%s' did not start with parent "
                         "pool source device name."), dev_name);
D
Daniel P. Berrange 已提交
726
        goto cleanup;
C
Cole Robinson 已提交
727 728
    }

729
    if (!isDevMapperDevice) {
730
        part_num = dev_name + strlen(srcname);
C
Cole Robinson 已提交
731

732
        if (*part_num == 0) {
733 734 735
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("cannot parse partition number from target "
                             "'%s'"), dev_name);
736 737
            goto cleanup;
        }
C
Cole Robinson 已提交
738

739 740 741 742 743 744 745 746 747 748 749
        /* eg parted /dev/sda rm 2 */
        cmd = virCommandNewArgList(PARTED,
                                   pool->def->source.devices[0].path,
                                   "rm",
                                   "--script",
                                   part_num,
                                   NULL);
        if (virCommandRun(cmd, NULL) < 0)
            goto cleanup;
    } else {
        cmd = virCommandNewArgList(DMSETUP, "remove", "--force", devpath, NULL);
C
Cole Robinson 已提交
750

751 752 753
        if (virCommandRun(cmd, NULL) < 0)
            goto cleanup;
    }
C
Cole Robinson 已提交
754

D
Daniel P. Berrange 已提交
755 756 757
    rc = 0;
cleanup:
    VIR_FREE(devpath);
758
    virCommandFree(cmd);
D
Daniel P. Berrange 已提交
759
    return rc;
760 761 762 763 764 765 766 767 768 769 770
}


virStorageBackend virStorageBackendDisk = {
    .type = VIR_STORAGE_POOL_DISK,

    .buildPool = virStorageBackendDiskBuildPool,
    .refreshPool = virStorageBackendDiskRefreshPool,

    .createVol = virStorageBackendDiskCreateVol,
    .deleteVol = virStorageBackendDiskDeleteVol,
771
    .buildVolFrom = virStorageBackendDiskBuildVolFrom,
772
};