storage_backend_fs.c 48.4 KB
Newer Older
1 2 3
/*
 * storage_backend_fs.c: storage backend for FS and directory handling
 *
4
 * Copyright (C) 2007-2015 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 25 26 27 28 29 30 31 32 33 34 35
 *
 * Author: Daniel P. Berrange <berrange@redhat.com>
 */

#include <config.h>

#include <sys/statvfs.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <dirent.h>
#include <errno.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>

36 37 38 39
#include <libxml/parser.h>
#include <libxml/tree.h>
#include <libxml/xpath.h>

40
#include "virerror.h"
41 42
#include "storage_backend_fs.h"
#include "storage_conf.h"
43
#include "virstoragefile.h"
44
#include "vircommand.h"
45
#include "viralloc.h"
46
#include "virxml.h"
E
Eric Blake 已提交
47
#include "virfile.h"
48
#include "virlog.h"
49
#include "virstring.h"
50

51
#define VIR_FROM_THIS VIR_FROM_STORAGE
52

53 54
VIR_LOG_INIT("storage.storage_backend_fs");

55 56 57 58
#define VIR_STORAGE_VOL_FS_OPEN_FLAGS    (VIR_STORAGE_VOL_OPEN_DEFAULT | \
                                          VIR_STORAGE_VOL_OPEN_DIR)
#define VIR_STORAGE_VOL_FS_PROBE_FLAGS   (VIR_STORAGE_VOL_FS_OPEN_FLAGS | \
                                          VIR_STORAGE_VOL_OPEN_NOERROR)
59

60
static int
61
virStorageBackendProbeTarget(virStorageSourcePtr target,
62 63
                             virStorageEncryptionPtr *encryption)
{
64
    int backingStoreFormat;
65 66
    int fd = -1;
    int ret = -1;
67
    int rc;
68
    virStorageSourcePtr meta = NULL;
E
Eric Blake 已提交
69
    struct stat sb;
70 71 72 73

    if (encryption)
        *encryption = NULL;

74 75 76 77
    if ((rc = virStorageBackendVolOpen(target->path, &sb,
                                       VIR_STORAGE_VOL_FS_PROBE_FLAGS)) < 0)
        return rc; /* Take care to propagate rc, it is not always -1 */
    fd = rc;
78

79
    if (virStorageBackendUpdateVolTargetInfoFD(target, fd, &sb) < 0)
80
        goto cleanup;
81

82
    if (S_ISDIR(sb.st_mode)) {
83 84 85 86 87 88 89 90 91
        if (virStorageBackendIsPloopDir(target->path)) {
            if (virStorageBackendRedoPloopUpdate(target, &sb, &fd,
                                                 VIR_STORAGE_VOL_FS_PROBE_FLAGS) < 0)
                goto cleanup;
        } else {
            target->format = VIR_STORAGE_FILE_DIR;
            ret = 0;
            goto cleanup;
        }
92
    }
93

94 95 96
    if (!(meta = virStorageFileGetMetadataFromFD(target->path,
                                                 fd,
                                                 VIR_STORAGE_FILE_AUTO,
97
                                                 &backingStoreFormat)))
98
        goto cleanup;
99

100
    if (meta->backingStoreRaw) {
101
        if (!(target->backingStore = virStorageSourceNewFromBacking(meta)))
102 103 104 105
            goto cleanup;

        target->backingStore->format = backingStoreFormat;

106 107 108 109 110 111 112 113 114 115 116 117 118 119 120
        /* XXX: Remote storage doesn't play nicely with volumes backed by
         * remote storage. To avoid trouble, just fake the backing store is RAW
         * and put the string from the metadata as the path of the target. */
        if (!virStorageSourceIsLocalStorage(target->backingStore)) {
            virStorageSourceFree(target->backingStore);

            if (VIR_ALLOC(target->backingStore) < 0)
                goto cleanup;

            target->backingStore->type = VIR_STORAGE_TYPE_NETWORK;
            target->backingStore->path = meta->backingStoreRaw;
            meta->backingStoreRaw = NULL;
            target->backingStore->format = VIR_STORAGE_FILE_RAW;
        }

121
        if (target->backingStore->format == VIR_STORAGE_FILE_AUTO) {
122
            if ((rc = virStorageFileProbeFormat(target->backingStore->path,
123 124 125 126 127 128 129 130 131 132 133 134 135 136 137
                                                -1, -1)) < 0) {
                /* If the backing file is currently unavailable or is
                 * accessed via remote protocol only log an error, fake the
                 * format as RAW and continue. Returning -1 here would
                 * disable the whole storage pool, making it unavailable for
                 * even maintenance. */
                target->backingStore->format = VIR_STORAGE_FILE_RAW;
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("cannot probe backing volume format: %s"),
                               target->backingStore->path);
            } else {
                target->backingStore->format = rc;
            }
        }
    }
138

J
Ján Tomko 已提交
139 140
    target->format = meta->format;

141 142
    /* Default to success below this point */
    ret = 0;
143

144
    if (meta->capacity)
145
        target->capacity = meta->capacity;
146

147
    if (encryption && meta->encryption) {
148 149
        *encryption = meta->encryption;
        meta->encryption = NULL;
150 151

        /* XXX ideally we'd fill in secret UUID here
E
Eric Blake 已提交
152
         * but we cannot guarantee 'conn' is non-NULL
153 154 155 156 157
         * at this point in time :-(  So we only fill
         * in secrets when someone first queries a vol
         */
    }

158
    virBitmapFree(target->features);
159 160
    target->features = meta->features;
    meta->features = NULL;
161

162
    if (meta->compat) {
163 164 165 166 167
        VIR_FREE(target->compat);
        target->compat = meta->compat;
        meta->compat = NULL;
    }

168
 cleanup:
169
    VIR_FORCE_CLOSE(fd);
170
    virStorageSourceFree(meta);
171 172
    return ret;

173 174 175
}

#if WITH_STORAGE_FS
176

177
# include <mntent.h>
178

179 180
struct _virNetfsDiscoverState {
    const char *host;
181
    virStoragePoolSourceList list;
182 183 184 185 186
};

typedef struct _virNetfsDiscoverState virNetfsDiscoverState;

static int
187
virStorageBackendFileSystemNetFindPoolSourcesFunc(char **const groups,
188 189 190 191
                                                  void *data)
{
    virNetfsDiscoverState *state = data;
    const char *name, *path;
192 193
    virStoragePoolSource *src = NULL;
    int ret = -1;
194 195 196

    path = groups[0];

197
    if (!(name = strrchr(path, '/'))) {
198 199
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("invalid netfs path (no /): %s"), path);
200
        goto cleanup;
201 202 203
    }
    name += 1;
    if (*name == '\0') {
204 205
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("invalid netfs path (ends in /): %s"), path);
206
        goto cleanup;
207 208
    }

209
    if (!(src = virStoragePoolSourceListNewSource(&state->list)))
210
        goto cleanup;
211

212
    if (VIR_ALLOC_N(src->hosts, 1) < 0)
213
        goto cleanup;
214
    src->nhost = 1;
215

216 217
    if (VIR_STRDUP(src->hosts[0].name, state->host) < 0 ||
        VIR_STRDUP(src->dir, path) < 0)
218
        goto cleanup;
219
    src->format = VIR_STORAGE_POOL_NETFS_NFS;
220

221
    ret = 0;
222
 cleanup:
223
    return ret;
224 225
}

226

227
static int
228
virStorageBackendFileSystemNetFindNFSPoolSources(virNetfsDiscoverState *state)
229
{
230 231
    int ret = -1;

232 233 234 235 236 237 238 239 240 241 242 243 244 245
    /*
     *  # showmount --no-headers -e HOSTNAME
     *  /tmp   *
     *  /A dir demo1.foo.bar,demo2.foo.bar
     *
     * Extract directory name (including possible interior spaces ...).
     */

    const char *regexes[] = {
        "^(/.*\\S) +\\S+$"
    };
    int vars[] = {
        1
    };
246 247 248 249 250 251 252 253 254 255 256

    virCommandPtr cmd = NULL;

    cmd = virCommandNewArgList(SHOWMOUNT,
                               "--no-headers",
                               "--exports",
                               state->host,
                               NULL);

    if (virCommandRunRegex(cmd, 1, regexes, vars,
                           virStorageBackendFileSystemNetFindPoolSourcesFunc,
257
                           state, NULL, NULL) < 0)
258
        goto cleanup;
259

260 261 262
    ret = 0;

 cleanup:
263
    virCommandFree(cmd);
264
    return ret;
265 266 267 268 269 270 271 272
}


static char *
virStorageBackendFileSystemNetFindPoolSources(virConnectPtr conn ATTRIBUTE_UNUSED,
                                              const char *srcSpec,
                                              unsigned int flags)
{
273 274 275 276 277 278 279 280
    virNetfsDiscoverState state = {
        .host = NULL,
        .list = {
            .type = VIR_STORAGE_POOL_NETFS,
            .nsources = 0,
            .sources = NULL
        }
    };
281
    virStoragePoolSourcePtr source = NULL;
282
    char *ret = NULL;
283
    size_t i;
284
    int retNFS = -1, retGluster = -1;
285

E
Eric Blake 已提交
286 287
    virCheckFlags(0, NULL);

288
    if (!srcSpec) {
289 290
        virReportError(VIR_ERR_INVALID_ARG, "%s",
                       _("hostname must be specified for netfs sources"));
291 292 293 294 295 296
        return NULL;
    }

    if (!(source = virStoragePoolDefParseSourceString(srcSpec,
                                                      VIR_STORAGE_POOL_NETFS)))
        return NULL;
297

298
    if (source->nhost != 1) {
299 300
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                       _("Expected exactly 1 host for the storage pool"));
301 302 303 304
        goto cleanup;
    }

    state.host = source->hosts[0].name;
305

306
    retNFS = virStorageBackendFileSystemNetFindNFSPoolSources(&state);
307

308 309 310
# ifdef GLUSTER_CLI
    retGluster =
        virStorageBackendFindGlusterPoolSources(state.host,
311
                                                VIR_STORAGE_POOL_NETFS_GLUSTERFS,
312 313 314 315
                                                &state.list);
# endif
    /* If both fail, then we won't return an empty list - return an error */
    if (retNFS < 0 && retGluster < 0)
316 317
        goto cleanup;

318
    if (!(ret = virStoragePoolSourceListFormat(&state.list)))
319 320 321
        goto cleanup;

 cleanup:
322
    for (i = 0; i < state.list.nsources; i++)
323 324
        virStoragePoolSourceClear(&state.list.sources[i]);
    VIR_FREE(state.list.sources);
325

326
    virStoragePoolSourceFree(source);
327
    return ret;
328 329
}

330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357
/**
 * @pool storage pool to check FS types
 *
 * Determine if storage pool FS types are properly set up
 *
 * Return 0 if everything's OK, -1 on error
 */
static int
virStorageBackendFileSystemIsValid(virStoragePoolObjPtr pool)
{
    if (pool->def->type == VIR_STORAGE_POOL_NETFS) {
        if (pool->def->source.nhost != 1) {
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("expected exactly 1 host for the storage pool"));
            return -1;
        }
        if (pool->def->source.hosts[0].name == NULL) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing source host"));
            return -1;
        }
        if (pool->def->source.dir == NULL) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing source path"));
            return -1;
        }
    } else {
        if (pool->def->source.ndevice != 1) {
358 359 360 361 362 363 364
            if (pool->def->source.ndevice == 0)
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("missing source device"));
            else
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                               _("expected exactly 1 device for the "
                                 "storage pool"));
365 366 367 368 369
            return -1;
        }
    }
    return 0;
}
370

371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403

/**
 * virStorageBackendFileSystemGetPoolSource
 * @pool: storage pool object pointer
 *
 * Allocate/return a string representing the FS storage pool source.
 * It is up to the caller to VIR_FREE the allocated string
 */
static char *
virStorageBackendFileSystemGetPoolSource(virStoragePoolObjPtr pool)
{
    char *src = NULL;

    if (pool->def->type == VIR_STORAGE_POOL_NETFS) {
        if (pool->def->source.format == VIR_STORAGE_POOL_NETFS_CIFS) {
            if (virAsprintf(&src, "//%s/%s",
                            pool->def->source.hosts[0].name,
                            pool->def->source.dir) < 0)
                return NULL;
        } else {
            if (virAsprintf(&src, "%s:%s",
                            pool->def->source.hosts[0].name,
                            pool->def->source.dir) < 0)
                return NULL;
        }
    } else {
        if (VIR_STRDUP(src, pool->def->source.devices[0].path) < 0)
            return NULL;
    }
    return src;
}


404 405 406 407 408 409 410 411
/**
 * @pool storage pool to check for status
 *
 * Determine if a storage pool is already mounted
 *
 * Return 0 if not mounted, 1 if mounted, -1 on error
 */
static int
412 413
virStorageBackendFileSystemIsMounted(virStoragePoolObjPtr pool)
{
414
    int ret = -1;
415
    char *src = NULL;
416
    FILE *mtab;
417 418
    struct mntent ent;
    char buf[1024];
419 420

    if ((mtab = fopen(_PATH_MOUNTED, "r")) == NULL) {
421
        virReportSystemError(errno,
422 423
                             _("cannot read mount list '%s'"),
                             _PATH_MOUNTED);
424
        goto cleanup;
425 426
    }

427
    while ((getmntent_r(mtab, &ent, buf, sizeof(buf))) != NULL) {
428 429 430 431 432
        if (!(src = virStorageBackendFileSystemGetPoolSource(pool)))
            goto cleanup;

        if (STREQ(ent.mnt_dir, pool->def->target.path) &&
            STREQ(ent.mnt_fsname, src)) {
433 434
            ret = 1;
            goto cleanup;
435
        }
436 437

        VIR_FREE(src);
438 439
    }

440 441 442
    ret = 0;

 cleanup:
443
    VIR_FORCE_FCLOSE(mtab);
444
    VIR_FREE(src);
445
    return ret;
446 447 448 449 450 451 452 453 454 455 456
}

/**
 * @pool storage pool to mount
 *
 * Ensure that a FS storage pool is mounted on its target location.
 * If already mounted, this is a no-op
 *
 * Returns 0 if successfully mounted, -1 on error
 */
static int
457 458
virStorageBackendFileSystemMount(virStoragePoolObjPtr pool)
{
459
    char *src = NULL;
460 461 462
    /* 'mount -t auto' doesn't seem to auto determine nfs (or cifs),
     *  while plain 'mount' does. We have to craft separate argvs to
     *  accommodate this */
463 464 465 466
    bool netauto = (pool->def->type == VIR_STORAGE_POOL_NETFS &&
                    pool->def->source.format == VIR_STORAGE_POOL_NETFS_AUTO);
    bool glusterfs = (pool->def->type == VIR_STORAGE_POOL_NETFS &&
                      pool->def->source.format == VIR_STORAGE_POOL_NETFS_GLUSTERFS);
467 468
    bool cifsfs = (pool->def->type == VIR_STORAGE_POOL_NETFS &&
                   pool->def->source.format == VIR_STORAGE_POOL_NETFS_CIFS);
469 470
    virCommandPtr cmd = NULL;
    int ret = -1;
471
    int rc;
472

473 474
    if (virStorageBackendFileSystemIsValid(pool) < 0)
        return -1;
475

J
Jim Meyering 已提交
476
    /* Short-circuit if already mounted */
477 478 479 480 481 482
    if ((rc = virStorageBackendFileSystemIsMounted(pool)) != 0) {
        if (rc == 1) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("Target '%s' is already mounted"),
                           pool->def->target.path);
        }
483
        return -1;
484 485
    }

486 487
    if (!(src = virStorageBackendFileSystemGetPoolSource(pool)))
        return -1;
488

489 490 491 492 493 494
    if (netauto)
        cmd = virCommandNewArgList(MOUNT,
                                   src,
                                   pool->def->target.path,
                                   NULL);
    else if (glusterfs)
495 496
        cmd = virCommandNewArgList(MOUNT,
                                   "-t",
497
                                   virStoragePoolFormatFileSystemNetTypeToString(pool->def->source.format),
498 499 500 501 502
                                   src,
                                   "-o",
                                   "direct-io-mode=1",
                                   pool->def->target.path,
                                   NULL);
503 504 505 506 507 508 509 510 511
    else if (cifsfs)
        cmd = virCommandNewArgList(MOUNT,
                                   "-t",
                                   virStoragePoolFormatFileSystemNetTypeToString(pool->def->source.format),
                                   src,
                                   pool->def->target.path,
                                   "-o",
                                   "guest",
                                   NULL);
512 513 514 515 516 517 518 519 520 521 522 523 524 525
    else
        cmd = virCommandNewArgList(MOUNT,
                                   "-t",
                                   (pool->def->type == VIR_STORAGE_POOL_FS ?
                                    virStoragePoolFormatFileSystemTypeToString(pool->def->source.format) :
                                    virStoragePoolFormatFileSystemNetTypeToString(pool->def->source.format)),
                                   src,
                                   pool->def->target.path,
                                   NULL);

    if (virCommandRun(cmd, NULL) < 0)
        goto cleanup;

    ret = 0;
526
 cleanup:
527
    virCommandFree(cmd);
528
    VIR_FREE(src);
529
    return ret;
530 531 532 533 534 535
}

/**
 * @pool storage pool to unmount
 *
 * Ensure that a FS storage pool is not mounted on its target location.
536
 * If already unmounted, this is a no-op.
537 538 539 540
 *
 * Returns 0 if successfully unmounted, -1 on error
 */
static int
541 542
virStorageBackendFileSystemUnmount(virStoragePoolObjPtr pool)
{
543 544
    virCommandPtr cmd = NULL;
    int ret = -1;
545
    int rc;
546

547 548
    if (virStorageBackendFileSystemIsValid(pool) < 0)
        return -1;
549 550

    /* Short-circuit if already unmounted */
551 552
    if ((rc = virStorageBackendFileSystemIsMounted(pool)) != 1)
        return rc;
553

554 555 556
    cmd = virCommandNewArgList(UMOUNT,
                               pool->def->target.path,
                               NULL);
557

558 559 560 561
    if (virCommandRun(cmd, NULL) < 0)
        goto cleanup;

    ret = 0;
562
 cleanup:
563 564
    virCommandFree(cmd);
    return ret;
565 566 567 568
}
#endif /* WITH_STORAGE_FS */


569
static int
570
virStorageBackendFileSystemCheck(virStoragePoolObjPtr pool,
571 572 573
                                 bool *isActive)
{
    if (pool->def->type == VIR_STORAGE_POOL_DIR) {
574
        *isActive = virFileExists(pool->def->target.path);
575 576 577
#if WITH_STORAGE_FS
    } else {
        int ret;
578
        *isActive = false;
579 580 581 582

        if (virStorageBackendFileSystemIsValid(pool) < 0)
            return -1;

583 584 585 586 587 588 589 590 591 592 593 594
        if ((ret = virStorageBackendFileSystemIsMounted(pool)) != 0) {
            if (ret < 0)
                return -1;
            *isActive = true;
        }
#endif /* WITH_STORAGE_FS */
    }

    return 0;
}

#if WITH_STORAGE_FS
595 596 597 598
/**
 * @conn connection to report errors against
 * @pool storage pool to start
 *
599 600
 * Starts a directory or FS based storage pool.  The underlying source
 * device will be mounted for FS based pools.
601 602 603 604
 *
 * Returns 0 on success, -1 on error
 */
static int
605
virStorageBackendFileSystemStart(virConnectPtr conn ATTRIBUTE_UNUSED,
606 607
                                 virStoragePoolObjPtr pool)
{
608 609
    if (pool->def->type != VIR_STORAGE_POOL_DIR &&
        virStorageBackendFileSystemMount(pool) < 0)
610 611 612 613 614 615
        return -1;

    return 0;
}
#endif /* WITH_STORAGE_FS */

O
Osier Yang 已提交
616

617 618
/* some platforms don't support mkfs */
#ifdef MKFS
O
Osier Yang 已提交
619 620 621 622 623 624 625
static int
virStorageBackendExecuteMKFS(const char *device,
                             const char *format)
{
    int ret = 0;
    virCommandPtr cmd = NULL;

J
Ján Tomko 已提交
626 627
    cmd = virCommandNewArgList(MKFS, "-t", format, NULL);

628 629 630
    /* use the force, otherwise mkfs.xfs won't overwrite existing fs.
     * Similarly mkfs.ext2, mkfs.ext3, and mkfs.ext4 require supplying -F
     * and mkfs.vfat uses -I */
J
Ján Tomko 已提交
631 632
    if (STREQ(format, "xfs"))
        virCommandAddArg(cmd, "-f");
633 634 635 636 637 638
    else if (STREQ(format, "ext2") ||
             STREQ(format, "ext3") ||
             STREQ(format, "ext4"))
        virCommandAddArg(cmd, "-F");
    else if (STREQ(format, "vfat"))
        virCommandAddArg(cmd, "-I");
J
Ján Tomko 已提交
639 640

    virCommandAddArg(cmd, device);
O
Osier Yang 已提交
641 642 643 644 645 646 647 648

    if (virCommandRun(cmd, NULL) < 0) {
        virReportSystemError(errno,
                             _("Failed to make filesystem of "
                               "type '%s' on device '%s'"),
                             format, device);
        ret = -1;
    }
649 650

    virCommandFree(cmd);
O
Osier Yang 已提交
651 652
    return ret;
}
653 654 655 656 657
#else /* #ifdef MKFS */
static int
virStorageBackendExecuteMKFS(const char *device ATTRIBUTE_UNUSED,
                             const char *format ATTRIBUTE_UNUSED)
{
658 659 660 661 662
    virReportError(VIR_ERR_INTERNAL_ERROR,
                   _("mkfs is not supported on this platform: "
                     "Failed to make filesystem of "
                     "type '%s' on device '%s'"),
                   format, device);
663 664 665
    return -1;
}
#endif /* #ifdef MKFS */
O
Osier Yang 已提交
666 667 668 669 670 671 672 673 674 675

static int
virStorageBackendMakeFileSystem(virStoragePoolObjPtr pool,
                                unsigned int flags)
{
    const char *device = NULL, *format = NULL;
    bool ok_to_mkfs = false;
    int ret = -1;

    if (pool->def->source.devices == NULL) {
676 677 678
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("No source device specified when formatting pool '%s'"),
                       pool->def->name);
O
Osier Yang 已提交
679 680 681 682 683 684 685 686
        goto error;
    }

    device = pool->def->source.devices[0].path;
    format = virStoragePoolFormatFileSystemTypeToString(pool->def->source.format);
    VIR_DEBUG("source device: '%s' format: '%s'", device, format);

    if (!virFileExists(device)) {
687 688 689
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("Source device does not exist when formatting pool '%s'"),
                       pool->def->name);
O
Osier Yang 已提交
690 691 692 693 694 695
        goto error;
    }

    if (flags & VIR_STORAGE_POOL_BUILD_OVERWRITE) {
        ok_to_mkfs = true;
    } else if (flags & VIR_STORAGE_POOL_BUILD_NO_OVERWRITE &&
696
               virStorageBackendDeviceIsEmpty(device, format, true)) {
O
Osier Yang 已提交
697 698 699
        ok_to_mkfs = true;
    }

700
    if (ok_to_mkfs)
O
Osier Yang 已提交
701 702
        ret = virStorageBackendExecuteMKFS(device, format);

703
 error:
O
Osier Yang 已提交
704 705 706
    return ret;
}

707 708 709 710

/**
 * @conn connection to report errors against
 * @pool storage pool to build
E
Eric Blake 已提交
711
 * @flags controls the pool formatting behaviour
712 713 714
 *
 * Build a directory or FS based storage pool.
 *
715 716 717 718 719 720 721 722 723
 * If no flag is set, it only makes the directory.
 *
 * If VIR_STORAGE_POOL_BUILD_NO_OVERWRITE set, it probes to determine if
 * any filesystem already exists on the target device, returning an error
 * if one exists. If no filesystem already exists, use mkfs to format the
 * target device.
 *
 * If VIR_STORAGE_POOL_BUILD_OVERWRITE is set, mkfs is always executed and
 * any existing data on the target device is overwritten unconditionally.
O
Osier Yang 已提交
724
 *
725
 * The underlying source device is mounted for FS based pools.
726 727 728 729
 *
 * Returns 0 on success, -1 on error
 */
static int
730
virStorageBackendFileSystemBuild(virConnectPtr conn ATTRIBUTE_UNUSED,
731
                                 virStoragePoolObjPtr pool,
E
Eric Blake 已提交
732
                                 unsigned int flags)
733
{
734
    int ret = -1;
O
Osier Yang 已提交
735 736
    char *parent = NULL;
    char *p = NULL;
737
    mode_t mode;
738 739
    bool needs_create_as_uid;
    unsigned int dir_create_flags;
740

O
Osier Yang 已提交
741 742 743
    virCheckFlags(VIR_STORAGE_POOL_BUILD_OVERWRITE |
                  VIR_STORAGE_POOL_BUILD_NO_OVERWRITE, ret);

744 745 746
    VIR_EXCLUSIVE_FLAGS_GOTO(VIR_STORAGE_POOL_BUILD_OVERWRITE,
                             VIR_STORAGE_POOL_BUILD_NO_OVERWRITE,
                             error);
E
Eric Blake 已提交
747

748
    if (VIR_STRDUP(parent, pool->def->target.path) < 0)
749 750
        goto error;
    if (!(p = strrchr(parent, '/'))) {
751 752 753
        virReportError(VIR_ERR_INVALID_ARG,
                       _("path '%s' is not absolute"),
                       pool->def->target.path);
754
        goto error;
755 756
    }

757 758 759 760
    if (p != parent) {
        /* assure all directories in the path prior to the final dir
         * exist, with default uid/gid/mode. */
        *p = '\0';
761 762
        if (virFileMakePath(parent) < 0) {
            virReportSystemError(errno, _("cannot create path '%s'"),
763 764 765 766 767
                                 parent);
            goto error;
        }
    }

768 769 770 771 772 773 774 775
    dir_create_flags = VIR_DIR_CREATE_ALLOW_EXIST;
    needs_create_as_uid = (pool->def->type == VIR_STORAGE_POOL_NETFS);
    mode = pool->def->target.perms.mode;

    if (mode == (mode_t) -1 &&
        (needs_create_as_uid || !virFileExists(pool->def->target.path)))
        mode = VIR_STORAGE_DEFAULT_POOL_PERM_MODE;
    if (needs_create_as_uid)
776
        dir_create_flags |= VIR_DIR_CREATE_AS_UID;
777

778 779 780
    /* Now create the final dir in the path with the uid/gid/mode
     * requested in the config. If the dir already exists, just set
     * the perms. */
781 782 783 784 785
    if (virDirCreate(pool->def->target.path,
                     mode,
                     pool->def->target.perms.uid,
                     pool->def->target.perms.gid,
                     dir_create_flags) < 0)
786
        goto error;
O
Osier Yang 已提交
787 788 789 790 791 792 793

    if (flags != 0) {
        ret = virStorageBackendMakeFileSystem(pool, flags);
    } else {
        ret = 0;
    }

794
 error:
795 796
    VIR_FREE(parent);
    return ret;
797 798 799 800 801 802 803 804
}


/**
 * Iterate over the pool's directory and enumerate all disk images
 * within it. This is non-recursive.
 */
static int
805
virStorageBackendFileSystemRefresh(virConnectPtr conn ATTRIBUTE_UNUSED,
806 807 808 809 810
                                   virStoragePoolObjPtr pool)
{
    DIR *dir;
    struct dirent *ent;
    struct statvfs sb;
811
    struct stat statbuf;
812
    virStorageVolDefPtr vol = NULL;
813
    virStorageSourcePtr target = NULL;
E
Eric Blake 已提交
814
    int direrr;
815
    int fd = -1, ret = -1;
816

J
Ján Tomko 已提交
817
    if (virDirOpen(&dir, pool->def->target.path) < 0)
818
        goto cleanup;
819

E
Eric Blake 已提交
820
    while ((direrr = virDirRead(dir, &ent, pool->def->target.path)) > 0) {
821
        int err;
822

823 824 825 826 827 828
        if (virStringHasControlChars(ent->d_name)) {
            VIR_WARN("Ignoring file with control characters under '%s'",
                     pool->def->target.path);
            continue;
        }

829
        if (VIR_ALLOC(vol) < 0)
830
            goto cleanup;
831

832
        if (VIR_STRDUP(vol->name, ent->d_name) < 0)
833
            goto cleanup;
834

835
        vol->type = VIR_STORAGE_VOL_FILE;
836
        vol->target.format = VIR_STORAGE_FILE_RAW; /* Real value is filled in during probe */
837 838 839
        if (virAsprintf(&vol->target.path, "%s/%s",
                        pool->def->target.path,
                        vol->name) == -1)
840
            goto cleanup;
841

842
        if (VIR_STRDUP(vol->key, vol->target.path) < 0)
843
            goto cleanup;
844

845
        if ((err = virStorageBackendProbeTarget(&vol->target,
846
                                                &vol->target.encryption)) < 0) {
847
            if (err == -2) {
848
                /* Silently ignore non-regular files,
849
                 * eg 'lost+found', dangling symbolic link */
850 851
                virStorageVolDefFree(vol);
                vol = NULL;
852
                continue;
853
            } else if (err == -3) {
854 855 856 857 858
                /* The backing file is currently unavailable, its format is not
                 * explicitly specified, the probe to auto detect the format
                 * failed: continue with faked RAW format, since AUTO will
                 * break virStorageVolTargetDefFormat() generating the line
                 * <format type='...'/>. */
859
            } else {
860
                goto cleanup;
861
            }
862 863
        }

864 865 866 867
        /* directory based volume */
        if (vol->target.format == VIR_STORAGE_FILE_DIR)
            vol->type = VIR_STORAGE_VOL_DIR;

868 869 870
        if (vol->target.format == VIR_STORAGE_FILE_PLOOP)
            vol->type = VIR_STORAGE_VOL_PLOOP;

871
        if (vol->target.backingStore) {
872
            ignore_value(virStorageBackendUpdateVolTargetInfo(vol->target.backingStore,
873
                                                              false,
874
                                                              VIR_STORAGE_VOL_OPEN_DEFAULT, 0));
875 876 877
            /* If this failed, the backing file is currently unavailable,
             * the capacity, allocation, owner, group and mode are unknown.
             * An error message was raised, but we just continue. */
878 879
        }

880
        if (VIR_APPEND_ELEMENT(pool->volumes.objs, pool->volumes.count, vol) < 0)
881
            goto cleanup;
882
    }
E
Eric Blake 已提交
883
    if (direrr < 0)
884
        goto cleanup;
J
Ján Tomko 已提交
885
    VIR_DIR_CLOSE(dir);
886
    vol = NULL;
887

888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908
    if (VIR_ALLOC(target))
        goto cleanup;

    if ((fd = open(pool->def->target.path, O_RDONLY)) < 0) {
        virReportSystemError(errno,
                             _("cannot open path '%s'"),
                             pool->def->target.path);
        goto cleanup;
    }

    if (fstat(fd, &statbuf) < 0) {
        virReportSystemError(errno,
                             _("cannot stat path '%s'"),
                             pool->def->target.path);
        goto cleanup;
    }

    if (virStorageBackendUpdateVolTargetInfoFD(target, fd, &statbuf) < 0)
        goto cleanup;

    /* VolTargetInfoFD doesn't update capacity correctly for the pool case */
909
    if (statvfs(pool->def->target.path, &sb) < 0) {
910
        virReportSystemError(errno,
911 912
                             _("cannot statvfs path '%s'"),
                             pool->def->target.path);
913
        goto cleanup;
914
    }
915

916 917 918
    pool->def->capacity = ((unsigned long long)sb.f_frsize *
                           (unsigned long long)sb.f_blocks);
    pool->def->available = ((unsigned long long)sb.f_bfree *
919
                            (unsigned long long)sb.f_frsize);
920 921
    pool->def->allocation = pool->def->capacity - pool->def->available;

922 923 924 925 926 927
    pool->def->target.perms.mode = target->perms->mode;
    pool->def->target.perms.uid = target->perms->uid;
    pool->def->target.perms.gid = target->perms->gid;
    VIR_FREE(pool->def->target.perms.label);
    if (VIR_STRDUP(pool->def->target.perms.label, target->perms->label) < 0)
        goto cleanup;
928

929 930
    ret = 0;
 cleanup:
J
Ján Tomko 已提交
931
    VIR_DIR_CLOSE(dir);
932
    VIR_FORCE_CLOSE(fd);
933
    virStorageVolDefFree(vol);
934 935 936 937
    virStorageSourceFree(target);
    if (ret < 0)
        virStoragePoolObjClearVols(pool);
    return ret;
938 939 940 941 942
}


/**
 * @conn connection to report errors against
943
 * @pool storage pool to stop
944
 *
945 946
 * Stops a file storage pool.  The underlying source device is unmounted
 * for FS based pools.  Any cached data about volumes is released.
947
 *
948
 * Returns 0 on success, -1 on error.
949 950 951
 */
#if WITH_STORAGE_FS
static int
952
virStorageBackendFileSystemStop(virConnectPtr conn ATTRIBUTE_UNUSED,
953 954
                                virStoragePoolObjPtr pool)
{
955
    if (virStorageBackendFileSystemUnmount(pool) < 0)
956 957 958 959 960 961 962 963 964
        return -1;

    return 0;
}
#endif /* WITH_STORAGE_FS */


/**
 * @conn connection to report errors against
965
 * @pool storage pool to delete
966
 *
967
 * Delete a directory based storage pool
968 969 970 971
 *
 * Returns 0 on success, -1 on error
 */
static int
972
virStorageBackendFileSystemDelete(virConnectPtr conn ATTRIBUTE_UNUSED,
973
                                  virStoragePoolObjPtr pool,
E
Eric Blake 已提交
974
                                  unsigned int flags)
975
{
E
Eric Blake 已提交
976 977
    virCheckFlags(0, -1);

978 979
    /* XXX delete all vols first ? */

980
    if (rmdir(pool->def->target.path) < 0) {
981
        virReportSystemError(errno,
982
                             _("failed to remove pool '%s'"),
983
                             pool->def->target.path);
984 985 986 987 988 989 990 991
        return -1;
    }

    return 0;
}


/**
992 993 994 995
 * Set up a volume definition to be added to a pool's volume list, but
 * don't do any file creation or allocation. By separating the two processes,
 * we allow allocation progress reporting (by polling the volume's 'info'
 * function), and can drop the parent pool lock during the (slow) allocation.
996 997
 */
static int
998
virStorageBackendFileSystemVolCreate(virConnectPtr conn ATTRIBUTE_UNUSED,
999 1000 1001 1002
                                     virStoragePoolObjPtr pool,
                                     virStorageVolDefPtr vol)
{

1003 1004
    if (vol->target.format == VIR_STORAGE_FILE_DIR)
        vol->type = VIR_STORAGE_VOL_DIR;
O
Olga Krishtal 已提交
1005 1006
    else if (vol->target.format == VIR_STORAGE_FILE_PLOOP)
        vol->type = VIR_STORAGE_VOL_PLOOP;
1007 1008
    else
        vol->type = VIR_STORAGE_VOL_FILE;
1009

1010 1011 1012 1013 1014 1015 1016 1017
    /* Volumes within a directory pools are not recursive; do not
     * allow escape to ../ or a subdir */
    if (strchr(vol->name, '/')) {
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("volume name '%s' cannot contain '/'"), vol->name);
        return -1;
    }

R
Ryota Ozaki 已提交
1018
    VIR_FREE(vol->target.path);
1019 1020
    if (virAsprintf(&vol->target.path, "%s/%s",
                    pool->def->target.path,
1021
                    vol->name) == -1)
1022
        return -1;
1023

1024 1025 1026 1027 1028 1029 1030
    if (virFileExists(vol->target.path)) {
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("volume target path '%s' already exists"),
                       vol->target.path);
        return -1;
    }

R
Ryota Ozaki 已提交
1031
    VIR_FREE(vol->key);
1032
    return VIR_STRDUP(vol->key, vol->target.path);
1033 1034
}

1035
static int createFileDir(virConnectPtr conn ATTRIBUTE_UNUSED,
1036
                         virStoragePoolObjPtr pool,
1037
                         virStorageVolDefPtr vol,
1038
                         virStorageVolDefPtr inputvol,
E
Eric Blake 已提交
1039 1040
                         unsigned int flags)
{
1041 1042
    int err;

E
Eric Blake 已提交
1043 1044
    virCheckFlags(0, -1);

1045
    if (inputvol) {
1046 1047 1048
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s",
                       _("cannot copy from volume to a directory volume"));
1049 1050 1051
        return -1;
    }

1052 1053 1054 1055 1056 1057 1058
    if (vol->target.backingStore) {
        virReportError(VIR_ERR_NO_SUPPORT, "%s",
                       _("backing storage not supported for directories volumes"));
        return -1;
    }


1059 1060 1061 1062
    if ((err = virDirCreate(vol->target.path,
                            (vol->target.perms->mode == (mode_t) -1 ?
                             VIR_STORAGE_DEFAULT_VOL_PERM_MODE :
                             vol->target.perms->mode),
1063 1064
                            vol->target.perms->uid,
                            vol->target.perms->gid,
1065
                            (pool->def->type == VIR_STORAGE_POOL_NETFS
1066
                             ? VIR_DIR_CREATE_AS_UID : 0))) < 0) {
1067 1068
        return -1;
    }
1069

1070 1071
    return 0;
}
1072

1073
static int
1074
_virStorageBackendFileSystemVolBuild(virConnectPtr conn,
1075
                                     virStoragePoolObjPtr pool,
1076
                                     virStorageVolDefPtr vol,
1077 1078
                                     virStorageVolDefPtr inputvol,
                                     unsigned int flags)
1079
{
1080
    virStorageBackendBuildVolFrom create_func;
1081

1082
    if (inputvol) {
1083
        if (vol->target.encryption != NULL) {
1084 1085 1086 1087
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           "%s", _("storage pool does not support "
                                   "building encrypted volumes from "
                                   "other volumes"));
1088 1089
            return -1;
        }
1090
        create_func = virStorageBackendGetBuildVolFromFunction(vol,
1091
                                                               inputvol);
1092 1093
        if (!create_func)
            return -1;
1094 1095
    } else if (vol->target.format == VIR_STORAGE_FILE_RAW &&
               vol->target.encryption == NULL) {
1096
        create_func = virStorageBackendCreateRaw;
1097
    } else if (vol->target.format == VIR_STORAGE_FILE_DIR) {
1098
        create_func = createFileDir;
1099 1100
    } else if (vol->target.format == VIR_STORAGE_FILE_PLOOP) {
        create_func = virStorageBackendCreatePloop;
1101
    } else {
1102
        create_func = virStorageBackendCreateQemuImg;
1103 1104
    }

1105
    if (create_func(conn, pool, vol, inputvol, flags) < 0)
1106
        return -1;
1107 1108 1109
    return 0;
}

1110 1111
/**
 * Allocate a new file as a volume. This is either done directly
1112
 * for raw/sparse files, or by calling qemu-img for
1113 1114 1115 1116
 * special kinds of files
 */
static int
virStorageBackendFileSystemVolBuild(virConnectPtr conn,
1117
                                    virStoragePoolObjPtr pool,
1118
                                    virStorageVolDefPtr vol,
1119 1120
                                    unsigned int flags)
{
1121 1122 1123
    virCheckFlags(VIR_STORAGE_VOL_CREATE_PREALLOC_METADATA |
                  VIR_STORAGE_VOL_CREATE_REFLINK,
                  -1);
1124 1125

    return _virStorageBackendFileSystemVolBuild(conn, pool, vol, NULL, flags);
1126 1127 1128 1129 1130 1131 1132
}

/*
 * Create a storage vol using 'inputvol' as input
 */
static int
virStorageBackendFileSystemVolBuildFrom(virConnectPtr conn,
1133
                                        virStoragePoolObjPtr pool,
1134 1135
                                        virStorageVolDefPtr vol,
                                        virStorageVolDefPtr inputvol,
E
Eric Blake 已提交
1136 1137
                                        unsigned int flags)
{
1138 1139 1140
    virCheckFlags(VIR_STORAGE_VOL_CREATE_PREALLOC_METADATA |
                  VIR_STORAGE_VOL_CREATE_REFLINK,
                  -1);
E
Eric Blake 已提交
1141

1142
    return _virStorageBackendFileSystemVolBuild(conn, pool, vol, inputvol, flags);
1143
}
1144 1145

/**
1146
 * Remove a volume - no support for BLOCK and NETWORK yet
1147 1148
 */
static int
1149
virStorageBackendFileSystemVolDelete(virConnectPtr conn ATTRIBUTE_UNUSED,
1150 1151
                                     virStoragePoolObjPtr pool ATTRIBUTE_UNUSED,
                                     virStorageVolDefPtr vol,
E
Eric Blake 已提交
1152
                                     unsigned int flags)
1153
{
E
Eric Blake 已提交
1154 1155
    virCheckFlags(0, -1);

1156
    switch ((virStorageVolType) vol->type) {
1157
    case VIR_STORAGE_VOL_FILE:
1158 1159
    case VIR_STORAGE_VOL_DIR:
        if (virFileRemove(vol->target.path, vol->target.perms->uid,
J
John Ferlan 已提交
1160
                          vol->target.perms->gid) < 0) {
1161 1162
            /* Silently ignore failures where the vol has already gone away */
            if (errno != ENOENT) {
1163 1164 1165 1166 1167 1168 1169 1170
                if (vol->type == VIR_STORAGE_VOL_FILE)
                    virReportSystemError(errno,
                                         _("cannot unlink file '%s'"),
                                         vol->target.path);
                else
                    virReportSystemError(errno,
                                         _("cannot remove directory '%s'"),
                                         vol->target.path);
1171 1172 1173 1174
                return -1;
            }
        }
        break;
O
Olga Krishtal 已提交
1175
    case VIR_STORAGE_VOL_PLOOP:
1176 1177 1178
        if (virFileDeleteTree(vol->target.path) < 0)
            return -1;
        break;
1179 1180
    case VIR_STORAGE_VOL_BLOCK:
    case VIR_STORAGE_VOL_NETWORK:
1181 1182
    case VIR_STORAGE_VOL_NETDIR:
    case VIR_STORAGE_VOL_LAST:
1183 1184 1185
        virReportError(VIR_ERR_NO_SUPPORT,
                       _("removing block or network volumes is not supported: %s"),
                       vol->target.path);
1186
        return -1;
1187 1188 1189 1190 1191
    }
    return 0;
}


1192 1193 1194 1195
/* virStorageBackendFileSystemLoadDefaultSecrets:
 * @conn: Connection pointer to fetch secret
 * @vol: volume being refreshed
 *
1196 1197
 * If the volume had a secret generated, we need to regenerate the
 * encryption secret information
1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208
 *
 * Returns 0 if no secret or secret setup was successful,
 * -1 on failures w/ error message set
 */
static int
virStorageBackendFileSystemLoadDefaultSecrets(virConnectPtr conn,
                                              virStorageVolDefPtr vol)
{
    virSecretPtr sec;
    virStorageEncryptionSecretPtr encsec = NULL;

1209
    if (!vol->target.encryption || vol->target.encryption->nsecrets != 0)
1210 1211
        return 0;

1212 1213 1214 1215 1216 1217 1218
    /* The encryption secret for qcow2 and luks volumes use the path
     * to the volume, so look for a secret with the path. If not found,
     * then we cannot generate the secret after a refresh (or restart).
     * This may be the case if someone didn't follow instructions and created
     * a usage string that although matched with the secret usage string,
     * didn't contain the path to the volume. We won't error in that case,
     * but we also cannot find the secret. */
1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233
    if (!(sec = virSecretLookupByUsage(conn, VIR_SECRET_USAGE_TYPE_VOLUME,
                                       vol->target.path)))
        return 0;

    if (VIR_ALLOC_N(vol->target.encryption->secrets, 1) < 0 ||
        VIR_ALLOC(encsec) < 0) {
        VIR_FREE(vol->target.encryption->secrets);
        virObjectUnref(sec);
        return -1;
    }

    vol->target.encryption->nsecrets = 1;
    vol->target.encryption->secrets[0] = encsec;

    encsec->type = VIR_STORAGE_ENCRYPTION_SECRET_TYPE_PASSPHRASE;
J
John Ferlan 已提交
1234 1235
    encsec->seclookupdef.type = VIR_SECRET_LOOKUP_TYPE_UUID;
    virSecretGetUUID(sec, encsec->seclookupdef.u.uuid);
1236 1237 1238 1239 1240 1241
    virObjectUnref(sec);

    return 0;
}


1242 1243 1244 1245 1246 1247 1248 1249
/**
 * Update info about a volume's capacity/allocation
 */
static int
virStorageBackendFileSystemVolRefresh(virConnectPtr conn,
                                      virStoragePoolObjPtr pool ATTRIBUTE_UNUSED,
                                      virStorageVolDefPtr vol)
{
1250 1251
    int ret;

1252
    /* Refresh allocation / capacity / permissions info in case its changed */
1253 1254 1255
    if ((ret = virStorageBackendUpdateVolInfo(vol, false,
                                              VIR_STORAGE_VOL_FS_OPEN_FLAGS,
                                              0)) < 0)
1256 1257
        return ret;

N
Nehal J Wani 已提交
1258
    /* Load any secrets if possible */
1259
    return virStorageBackendFileSystemLoadDefaultSecrets(conn, vol);
1260 1261
}

1262 1263 1264 1265 1266 1267 1268 1269
static int
virStorageBackendFilesystemResizeQemuImg(const char *path,
                                         unsigned long long capacity)
{
    int ret = -1;
    char *img_tool;
    virCommandPtr cmd = NULL;

1270
    img_tool = virFindFileInPath("qemu-img");
1271
    if (!img_tool) {
1272
        virReportError(VIR_ERR_INTERNAL_ERROR,
1273
                       "%s", _("unable to find qemu-img"));
1274 1275 1276
        return -1;
    }

1277 1278 1279 1280
    /* Round capacity as qemu-img resize errors out on sizes which are not
     * a multiple of 512 */
    capacity = VIR_ROUND_UP(capacity, 512);

1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302
    cmd = virCommandNew(img_tool);
    virCommandAddArgList(cmd, "resize", path, NULL);
    virCommandAddArgFormat(cmd, "%llu", capacity);

    ret = virCommandRun(cmd, NULL);

    VIR_FREE(img_tool);
    virCommandFree(cmd);

    return ret;
}

/**
 * Resize a volume
 */
static int
virStorageBackendFileSystemVolResize(virConnectPtr conn ATTRIBUTE_UNUSED,
                                     virStoragePoolObjPtr pool ATTRIBUTE_UNUSED,
                                     virStorageVolDefPtr vol,
                                     unsigned long long capacity,
                                     unsigned int flags)
{
1303 1304
    virCheckFlags(VIR_STORAGE_VOL_RESIZE_ALLOCATE |
                  VIR_STORAGE_VOL_RESIZE_SHRINK, -1);
1305 1306 1307 1308 1309

    bool pre_allocate = flags & VIR_STORAGE_VOL_RESIZE_ALLOCATE;

    if (vol->target.format == VIR_STORAGE_FILE_RAW) {
        return virStorageFileResize(vol->target.path, capacity,
1310
                                    vol->target.allocation, pre_allocate);
1311 1312
    } else if (vol->target.format == VIR_STORAGE_FILE_PLOOP) {
        return virStoragePloopResize(vol, capacity);
1313 1314 1315 1316 1317 1318 1319
    } else {
        if (pre_allocate) {
            virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
                           _("preallocate is only supported for raw "
                             "type volume"));
            return -1;
        }
1320 1321 1322

        return virStorageBackendFilesystemResizeQemuImg(vol->target.path,
                                                        capacity);
1323
    }
1324 1325
}

1326

1327 1328 1329 1330
virStorageBackend virStorageBackendDirectory = {
    .type = VIR_STORAGE_POOL_DIR,

    .buildPool = virStorageBackendFileSystemBuild,
1331
    .checkPool = virStorageBackendFileSystemCheck,
1332 1333
    .refreshPool = virStorageBackendFileSystemRefresh,
    .deletePool = virStorageBackendFileSystemDelete,
1334
    .buildVol = virStorageBackendFileSystemVolBuild,
1335
    .buildVolFrom = virStorageBackendFileSystemVolBuildFrom,
1336 1337 1338
    .createVol = virStorageBackendFileSystemVolCreate,
    .refreshVol = virStorageBackendFileSystemVolRefresh,
    .deleteVol = virStorageBackendFileSystemVolDelete,
1339
    .resizeVol = virStorageBackendFileSystemVolResize,
1340 1341
    .uploadVol = virStorageBackendVolUploadLocal,
    .downloadVol = virStorageBackendVolDownloadLocal,
1342
    .wipeVol = virStorageBackendVolWipeLocal,
1343 1344 1345 1346 1347 1348 1349
};

#if WITH_STORAGE_FS
virStorageBackend virStorageBackendFileSystem = {
    .type = VIR_STORAGE_POOL_FS,

    .buildPool = virStorageBackendFileSystemBuild,
1350
    .checkPool = virStorageBackendFileSystemCheck,
1351 1352 1353 1354
    .startPool = virStorageBackendFileSystemStart,
    .refreshPool = virStorageBackendFileSystemRefresh,
    .stopPool = virStorageBackendFileSystemStop,
    .deletePool = virStorageBackendFileSystemDelete,
1355
    .buildVol = virStorageBackendFileSystemVolBuild,
1356
    .buildVolFrom = virStorageBackendFileSystemVolBuildFrom,
1357 1358 1359
    .createVol = virStorageBackendFileSystemVolCreate,
    .refreshVol = virStorageBackendFileSystemVolRefresh,
    .deleteVol = virStorageBackendFileSystemVolDelete,
1360
    .resizeVol = virStorageBackendFileSystemVolResize,
1361 1362
    .uploadVol = virStorageBackendVolUploadLocal,
    .downloadVol = virStorageBackendVolDownloadLocal,
1363
    .wipeVol = virStorageBackendVolWipeLocal,
1364 1365 1366 1367 1368
};
virStorageBackend virStorageBackendNetFileSystem = {
    .type = VIR_STORAGE_POOL_NETFS,

    .buildPool = virStorageBackendFileSystemBuild,
1369
    .checkPool = virStorageBackendFileSystemCheck,
1370
    .startPool = virStorageBackendFileSystemStart,
1371
    .findPoolSources = virStorageBackendFileSystemNetFindPoolSources,
1372 1373 1374
    .refreshPool = virStorageBackendFileSystemRefresh,
    .stopPool = virStorageBackendFileSystemStop,
    .deletePool = virStorageBackendFileSystemDelete,
1375
    .buildVol = virStorageBackendFileSystemVolBuild,
1376
    .buildVolFrom = virStorageBackendFileSystemVolBuildFrom,
1377 1378 1379
    .createVol = virStorageBackendFileSystemVolCreate,
    .refreshVol = virStorageBackendFileSystemVolRefresh,
    .deleteVol = virStorageBackendFileSystemVolDelete,
1380
    .resizeVol = virStorageBackendFileSystemVolResize,
1381 1382
    .uploadVol = virStorageBackendVolUploadLocal,
    .downloadVol = virStorageBackendVolDownloadLocal,
1383
    .wipeVol = virStorageBackendVolWipeLocal,
1384
};
1385 1386


1387 1388 1389 1390 1391 1392 1393 1394
typedef struct _virStorageFileBackendFsPriv virStorageFileBackendFsPriv;
typedef virStorageFileBackendFsPriv *virStorageFileBackendFsPrivPtr;

struct _virStorageFileBackendFsPriv {
    char *canonpath; /* unique file identifier (canonical path) */
};


1395 1396 1397 1398 1399 1400 1401
static void
virStorageFileBackendFileDeinit(virStorageSourcePtr src)
{
    VIR_DEBUG("deinitializing FS storage file %p (%s:%s)", src,
              virStorageTypeToString(virStorageSourceGetActualType(src)),
              src->path);

1402 1403 1404 1405
    virStorageFileBackendFsPrivPtr priv = src->drv->priv;

    VIR_FREE(priv->canonpath);
    VIR_FREE(priv);
1406 1407 1408
}


1409
static int
1410
virStorageFileBackendFileInit(virStorageSourcePtr src)
1411
{
1412 1413
    virStorageFileBackendFsPrivPtr priv = NULL;

1414
    VIR_DEBUG("initializing FS storage file %p (%s:%s)[%u:%u]", src,
1415
              virStorageTypeToString(virStorageSourceGetActualType(src)),
1416 1417
              src->path,
              (unsigned int)src->drv->uid, (unsigned int)src->drv->gid);
1418

1419 1420 1421 1422 1423
    if (VIR_ALLOC(priv) < 0)
        return -1;

    src->drv->priv = priv;

1424 1425
    return 0;
}
1426 1427


1428 1429 1430 1431
static int
virStorageFileBackendFileCreate(virStorageSourcePtr src)
{
    int fd = -1;
1432
    mode_t mode = S_IRUSR;
1433

1434 1435 1436 1437
    if (!src->readonly)
        mode |= S_IWUSR;

    if ((fd = virFileOpenAs(src->path, O_WRONLY | O_TRUNC | O_CREAT, mode,
1438 1439 1440 1441 1442 1443 1444 1445 1446 1447
                            src->drv->uid, src->drv->gid, 0)) < 0) {
        errno = -fd;
        return -1;
    }

    VIR_FORCE_CLOSE(fd);
    return 0;
}


1448 1449 1450 1451
static int
virStorageFileBackendFileUnlink(virStorageSourcePtr src)
{
    return unlink(src->path);
1452 1453 1454 1455
}


static int
1456
virStorageFileBackendFileStat(virStorageSourcePtr src,
1457 1458
                              struct stat *st)
{
1459
    return stat(src->path, st);
1460 1461 1462
}


1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490
static ssize_t
virStorageFileBackendFileReadHeader(virStorageSourcePtr src,
                                    ssize_t max_len,
                                    char **buf)
{
    int fd = -1;
    ssize_t ret = -1;

    if ((fd = virFileOpenAs(src->path, O_RDONLY, 0,
                            src->drv->uid, src->drv->gid, 0)) < 0) {
        virReportSystemError(-fd, _("Failed to open file '%s'"),
                             src->path);
        return -1;
    }

    if ((ret = virFileReadHeaderFD(fd, max_len, buf)) < 0) {
        virReportSystemError(errno,
                             _("cannot read header '%s'"), src->path);
        goto cleanup;
    }

 cleanup:
    VIR_FORCE_CLOSE(fd);

    return ret;
}


1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507
static const char *
virStorageFileBackendFileGetUniqueIdentifier(virStorageSourcePtr src)
{
    virStorageFileBackendFsPrivPtr priv = src->drv->priv;

    if (!priv->canonpath) {
        if (!(priv->canonpath = canonicalize_file_name(src->path))) {
            virReportSystemError(errno, _("can't canonicalize path '%s'"),
                                 src->path);
            return NULL;
        }
    }

    return priv->canonpath;
}


1508 1509 1510 1511 1512 1513 1514 1515 1516
static int
virStorageFileBackendFileAccess(virStorageSourcePtr src,
                                int mode)
{
    return virFileAccessibleAs(src->path, mode,
                               src->drv->uid, src->drv->gid);
}


1517
static int
1518
virStorageFileBackendFileChown(const virStorageSource *src,
1519 1520 1521 1522 1523 1524 1525
                               uid_t uid,
                               gid_t gid)
{
    return chown(src->path, uid, gid);
}


1526
virStorageFileBackend virStorageFileBackendFile = {
E
Eric Blake 已提交
1527
    .type = VIR_STORAGE_TYPE_FILE,
1528

1529 1530 1531
    .backendInit = virStorageFileBackendFileInit,
    .backendDeinit = virStorageFileBackendFileDeinit,

1532
    .storageFileCreate = virStorageFileBackendFileCreate,
1533 1534
    .storageFileUnlink = virStorageFileBackendFileUnlink,
    .storageFileStat = virStorageFileBackendFileStat,
1535
    .storageFileReadHeader = virStorageFileBackendFileReadHeader,
1536
    .storageFileAccess = virStorageFileBackendFileAccess,
1537
    .storageFileChown = virStorageFileBackendFileChown,
1538 1539

    .storageFileGetUniqueIdentifier = virStorageFileBackendFileGetUniqueIdentifier,
1540 1541 1542 1543
};


virStorageFileBackend virStorageFileBackendBlock = {
E
Eric Blake 已提交
1544
    .type = VIR_STORAGE_TYPE_BLOCK,
1545

1546 1547 1548
    .backendInit = virStorageFileBackendFileInit,
    .backendDeinit = virStorageFileBackendFileDeinit,

1549
    .storageFileStat = virStorageFileBackendFileStat,
1550
    .storageFileReadHeader = virStorageFileBackendFileReadHeader,
1551
    .storageFileAccess = virStorageFileBackendFileAccess,
1552
    .storageFileChown = virStorageFileBackendFileChown,
1553 1554

    .storageFileGetUniqueIdentifier = virStorageFileBackendFileGetUniqueIdentifier,
1555 1556 1557
};


1558 1559 1560 1561 1562 1563
virStorageFileBackend virStorageFileBackendDir = {
    .type = VIR_STORAGE_TYPE_DIR,

    .backendInit = virStorageFileBackendFileInit,
    .backendDeinit = virStorageFileBackendFileDeinit,

1564
    .storageFileAccess = virStorageFileBackendFileAccess,
1565
    .storageFileChown = virStorageFileBackendFileChown,
1566

1567 1568 1569
    .storageFileGetUniqueIdentifier = virStorageFileBackendFileGetUniqueIdentifier,
};

1570
#endif /* WITH_STORAGE_FS */