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 608
                                 virStoragePoolObjPtr pool)
{
    if (pool->def->type != VIR_STORAGE_POOL_DIR &&
609
        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)) {
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.
 *
O
Osier Yang 已提交
715 716 717 718 719 720 721
 * If no flag is set, it only makes the directory; If
 * VIR_STORAGE_POOL_BUILD_NO_OVERWRITE set, it probes to determine if
 * filesystem already exists on the target device, renurning an error
 * if exists, or using mkfs to format the target device if not; If
 * VIR_STORAGE_POOL_BUILD_OVERWRITE is set, mkfs is always executed,
 * any existed data on the target device is overwritten unconditionally.
 *
722
 * The underlying source device is mounted for FS based pools.
723 724 725 726
 *
 * Returns 0 on success, -1 on error
 */
static int
727
virStorageBackendFileSystemBuild(virConnectPtr conn ATTRIBUTE_UNUSED,
728
                                 virStoragePoolObjPtr pool,
E
Eric Blake 已提交
729
                                 unsigned int flags)
730
{
731
    int ret = -1;
O
Osier Yang 已提交
732 733
    char *parent = NULL;
    char *p = NULL;
734
    mode_t mode;
735 736
    bool needs_create_as_uid;
    unsigned int dir_create_flags;
737

O
Osier Yang 已提交
738 739 740
    virCheckFlags(VIR_STORAGE_POOL_BUILD_OVERWRITE |
                  VIR_STORAGE_POOL_BUILD_NO_OVERWRITE, ret);

741 742 743
    VIR_EXCLUSIVE_FLAGS_GOTO(VIR_STORAGE_POOL_BUILD_OVERWRITE,
                             VIR_STORAGE_POOL_BUILD_NO_OVERWRITE,
                             error);
E
Eric Blake 已提交
744

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

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

765 766 767 768 769 770 771 772
    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)
773
        dir_create_flags |= VIR_DIR_CREATE_AS_UID;
774

775 776 777
    /* 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. */
778 779 780 781 782
    if (virDirCreate(pool->def->target.path,
                     mode,
                     pool->def->target.perms.uid,
                     pool->def->target.perms.gid,
                     dir_create_flags) < 0)
783
        goto error;
O
Osier Yang 已提交
784 785 786 787 788 789 790

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

791
 error:
792 793
    VIR_FREE(parent);
    return ret;
794 795 796 797 798 799 800 801
}


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

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

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

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

826
        if (VIR_ALLOC(vol) < 0)
827
            goto cleanup;
828

829
        if (VIR_STRDUP(vol->name, ent->d_name) < 0)
830
            goto cleanup;
831

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

839
        if (VIR_STRDUP(vol->key, vol->target.path) < 0)
840
            goto cleanup;
841

842
        if ((err = virStorageBackendProbeTarget(&vol->target,
843
                                                &vol->target.encryption)) < 0) {
844
            if (err == -2) {
845
                /* Silently ignore non-regular files,
846
                 * eg 'lost+found', dangling symbolic link */
847 848
                virStorageVolDefFree(vol);
                vol = NULL;
849
                continue;
850
            } else if (err == -3) {
851 852 853 854 855
                /* 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='...'/>. */
856
            } else {
857
                goto cleanup;
858
            }
859 860
        }

861 862 863 864
        /* directory based volume */
        if (vol->target.format == VIR_STORAGE_FILE_DIR)
            vol->type = VIR_STORAGE_VOL_DIR;

865 866 867
        if (vol->target.format == VIR_STORAGE_FILE_PLOOP)
            vol->type = VIR_STORAGE_VOL_PLOOP;

868
        if (vol->target.backingStore) {
869
            ignore_value(virStorageBackendUpdateVolTargetInfo(vol->target.backingStore,
870
                                                              false,
871
                                                              VIR_STORAGE_VOL_OPEN_DEFAULT, 0));
872 873 874
            /* 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. */
875 876
        }

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

885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905
    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 */
906
    if (statvfs(pool->def->target.path, &sb) < 0) {
907
        virReportSystemError(errno,
908 909
                             _("cannot statvfs path '%s'"),
                             pool->def->target.path);
910
        goto cleanup;
911
    }
912

913 914 915
    pool->def->capacity = ((unsigned long long)sb.f_frsize *
                           (unsigned long long)sb.f_blocks);
    pool->def->available = ((unsigned long long)sb.f_bfree *
916
                            (unsigned long long)sb.f_frsize);
917 918
    pool->def->allocation = pool->def->capacity - pool->def->available;

919 920 921 922 923 924
    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;
925

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


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

    return 0;
}
#endif /* WITH_STORAGE_FS */


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

975 976
    /* XXX delete all vols first ? */

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

    return 0;
}


/**
989 990 991 992
 * 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.
993 994
 */
static int
995
virStorageBackendFileSystemVolCreate(virConnectPtr conn ATTRIBUTE_UNUSED,
996 997 998 999
                                     virStoragePoolObjPtr pool,
                                     virStorageVolDefPtr vol)
{

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

1007 1008 1009 1010 1011 1012 1013 1014
    /* 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 已提交
1015
    VIR_FREE(vol->target.path);
1016 1017
    if (virAsprintf(&vol->target.path, "%s/%s",
                    pool->def->target.path,
1018
                    vol->name) == -1)
1019
        return -1;
1020

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

R
Ryota Ozaki 已提交
1028
    VIR_FREE(vol->key);
1029
    return VIR_STRDUP(vol->key, vol->target.path);
1030 1031
}

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

E
Eric Blake 已提交
1040 1041
    virCheckFlags(0, -1);

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

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


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

1067 1068
    return 0;
}
1069

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

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

1102
    if (create_func(conn, pool, vol, inputvol, flags) < 0)
1103
        return -1;
1104 1105 1106
    return 0;
}

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

    return _virStorageBackendFileSystemVolBuild(conn, pool, vol, NULL, flags);
1123 1124 1125 1126 1127 1128 1129
}

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

1139
    return _virStorageBackendFileSystemVolBuild(conn, pool, vol, inputvol, flags);
1140
}
1141 1142

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

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


1189 1190 1191 1192
/* virStorageBackendFileSystemLoadDefaultSecrets:
 * @conn: Connection pointer to fetch secret
 * @vol: volume being refreshed
 *
1193 1194
 * If the volume had a secret generated, we need to regenerate the
 * encryption secret information
1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205
 *
 * 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;

1206
    if (!vol->target.encryption || vol->target.encryption->nsecrets != 0)
1207 1208
        return 0;

1209 1210 1211 1212 1213 1214 1215
    /* 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. */
1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230
    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 已提交
1231 1232
    encsec->seclookupdef.type = VIR_SECRET_LOOKUP_TYPE_UUID;
    virSecretGetUUID(sec, encsec->seclookupdef.u.uuid);
1233 1234 1235 1236 1237 1238
    virObjectUnref(sec);

    return 0;
}


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

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

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

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

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

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

1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299
    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)
{
1300 1301
    virCheckFlags(VIR_STORAGE_VOL_RESIZE_ALLOCATE |
                  VIR_STORAGE_VOL_RESIZE_SHRINK, -1);
1302 1303 1304 1305 1306

    bool pre_allocate = flags & VIR_STORAGE_VOL_RESIZE_ALLOCATE;

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

        return virStorageBackendFilesystemResizeQemuImg(vol->target.path,
                                                        capacity);
1320
    }
1321 1322
}

1323

1324 1325 1326 1327
virStorageBackend virStorageBackendDirectory = {
    .type = VIR_STORAGE_POOL_DIR,

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

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

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

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


1384 1385 1386 1387 1388 1389 1390 1391
typedef struct _virStorageFileBackendFsPriv virStorageFileBackendFsPriv;
typedef virStorageFileBackendFsPriv *virStorageFileBackendFsPrivPtr;

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


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

1399 1400 1401 1402
    virStorageFileBackendFsPrivPtr priv = src->drv->priv;

    VIR_FREE(priv->canonpath);
    VIR_FREE(priv);
1403 1404 1405
}


1406
static int
1407
virStorageFileBackendFileInit(virStorageSourcePtr src)
1408
{
1409 1410
    virStorageFileBackendFsPrivPtr priv = NULL;

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

1416 1417 1418 1419 1420
    if (VIR_ALLOC(priv) < 0)
        return -1;

    src->drv->priv = priv;

1421 1422
    return 0;
}
1423 1424


1425 1426 1427 1428
static int
virStorageFileBackendFileCreate(virStorageSourcePtr src)
{
    int fd = -1;
1429
    mode_t mode = S_IRUSR;
1430

1431 1432 1433 1434
    if (!src->readonly)
        mode |= S_IWUSR;

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

    VIR_FORCE_CLOSE(fd);
    return 0;
}


1445 1446 1447 1448
static int
virStorageFileBackendFileUnlink(virStorageSourcePtr src)
{
    return unlink(src->path);
1449 1450 1451 1452
}


static int
1453
virStorageFileBackendFileStat(virStorageSourcePtr src,
1454 1455
                              struct stat *st)
{
1456
    return stat(src->path, st);
1457 1458 1459
}


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
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;
}


1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504
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;
}


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


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


1523
virStorageFileBackend virStorageFileBackendFile = {
E
Eric Blake 已提交
1524
    .type = VIR_STORAGE_TYPE_FILE,
1525

1526 1527 1528
    .backendInit = virStorageFileBackendFileInit,
    .backendDeinit = virStorageFileBackendFileDeinit,

1529
    .storageFileCreate = virStorageFileBackendFileCreate,
1530 1531
    .storageFileUnlink = virStorageFileBackendFileUnlink,
    .storageFileStat = virStorageFileBackendFileStat,
1532
    .storageFileReadHeader = virStorageFileBackendFileReadHeader,
1533
    .storageFileAccess = virStorageFileBackendFileAccess,
1534
    .storageFileChown = virStorageFileBackendFileChown,
1535 1536

    .storageFileGetUniqueIdentifier = virStorageFileBackendFileGetUniqueIdentifier,
1537 1538 1539 1540
};


virStorageFileBackend virStorageFileBackendBlock = {
E
Eric Blake 已提交
1541
    .type = VIR_STORAGE_TYPE_BLOCK,
1542

1543 1544 1545
    .backendInit = virStorageFileBackendFileInit,
    .backendDeinit = virStorageFileBackendFileDeinit,

1546
    .storageFileStat = virStorageFileBackendFileStat,
1547
    .storageFileReadHeader = virStorageFileBackendFileReadHeader,
1548
    .storageFileAccess = virStorageFileBackendFileAccess,
1549
    .storageFileChown = virStorageFileBackendFileChown,
1550 1551

    .storageFileGetUniqueIdentifier = virStorageFileBackendFileGetUniqueIdentifier,
1552 1553 1554
};


1555 1556 1557 1558 1559 1560
virStorageFileBackend virStorageFileBackendDir = {
    .type = VIR_STORAGE_TYPE_DIR,

    .backendInit = virStorageFileBackendFileInit,
    .backendDeinit = virStorageFileBackendFileDeinit,

1561
    .storageFileAccess = virStorageFileBackendFileAccess,
1562
    .storageFileChown = virStorageFileBackendFileChown,
1563

1564 1565 1566
    .storageFileGetUniqueIdentifier = virStorageFileBackendFileGetUniqueIdentifier,
};

1567
#endif /* WITH_STORAGE_FS */