storage_backend_fs.c 48.7 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 285
    int retNFS = -1;
    int retGluster = 0;
286

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

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

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

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

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

307
    retNFS = virStorageBackendFileSystemNetFindNFSPoolSources(&state);
308

309 310
    retGluster = virStorageBackendFindGlusterPoolSources(state.host,
                                                         VIR_STORAGE_POOL_NETFS_GLUSTERFS,
311
                                                         &state.list, false);
312 313 314 315

    if (retGluster < 0)
        goto cleanup;

316
    /* If both fail, then we won't return an empty list - return an error */
317 318 319 320
    if (retNFS < 0 && retGluster == 0) {
        virReportError(VIR_ERR_OPERATION_FAILED,
                       _("no storage pools were found on host '%s'"),
                       state.host);
321
        goto cleanup;
322
    }
323

324
    if (!(ret = virStoragePoolSourceListFormat(&state.list)))
325 326 327
        goto cleanup;

 cleanup:
328
    for (i = 0; i < state.list.nsources; i++)
329 330
        virStoragePoolSourceClear(&state.list.sources[i]);
    VIR_FREE(state.list.sources);
331

332
    virStoragePoolSourceFree(source);
333
    return ret;
334 335
}

336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363
/**
 * @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) {
364 365 366 367 368 369 370
            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"));
371 372 373 374 375
            return -1;
        }
    }
    return 0;
}
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 404 405 406 407 408 409

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


410 411 412 413 414 415 416 417
/**
 * @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
418 419
virStorageBackendFileSystemIsMounted(virStoragePoolObjPtr pool)
{
420
    int ret = -1;
421
    char *src = NULL;
422
    FILE *mtab;
423 424
    struct mntent ent;
    char buf[1024];
425 426

    if ((mtab = fopen(_PATH_MOUNTED, "r")) == NULL) {
427
        virReportSystemError(errno,
428 429
                             _("cannot read mount list '%s'"),
                             _PATH_MOUNTED);
430
        goto cleanup;
431 432
    }

433
    while ((getmntent_r(mtab, &ent, buf, sizeof(buf))) != NULL) {
434 435 436 437 438
        if (!(src = virStorageBackendFileSystemGetPoolSource(pool)))
            goto cleanup;

        if (STREQ(ent.mnt_dir, pool->def->target.path) &&
            STREQ(ent.mnt_fsname, src)) {
439 440
            ret = 1;
            goto cleanup;
441
        }
442 443

        VIR_FREE(src);
444 445
    }

446 447 448
    ret = 0;

 cleanup:
449
    VIR_FORCE_FCLOSE(mtab);
450
    VIR_FREE(src);
451
    return ret;
452 453 454 455 456 457 458 459 460 461 462
}

/**
 * @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
463 464
virStorageBackendFileSystemMount(virStoragePoolObjPtr pool)
{
465
    char *src = NULL;
466 467 468
    /* '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 */
469 470 471 472
    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);
473 474
    bool cifsfs = (pool->def->type == VIR_STORAGE_POOL_NETFS &&
                   pool->def->source.format == VIR_STORAGE_POOL_NETFS_CIFS);
475 476
    virCommandPtr cmd = NULL;
    int ret = -1;
477
    int rc;
478

479 480
    if (virStorageBackendFileSystemIsValid(pool) < 0)
        return -1;
481

J
Jim Meyering 已提交
482
    /* Short-circuit if already mounted */
483 484 485 486 487 488
    if ((rc = virStorageBackendFileSystemIsMounted(pool)) != 0) {
        if (rc == 1) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("Target '%s' is already mounted"),
                           pool->def->target.path);
        }
489
        return -1;
490 491
    }

492 493
    if (!(src = virStorageBackendFileSystemGetPoolSource(pool)))
        return -1;
494

495 496 497 498 499 500
    if (netauto)
        cmd = virCommandNewArgList(MOUNT,
                                   src,
                                   pool->def->target.path,
                                   NULL);
    else if (glusterfs)
501 502
        cmd = virCommandNewArgList(MOUNT,
                                   "-t",
503
                                   virStoragePoolFormatFileSystemNetTypeToString(pool->def->source.format),
504 505 506 507 508
                                   src,
                                   "-o",
                                   "direct-io-mode=1",
                                   pool->def->target.path,
                                   NULL);
509 510 511 512 513 514 515 516 517
    else if (cifsfs)
        cmd = virCommandNewArgList(MOUNT,
                                   "-t",
                                   virStoragePoolFormatFileSystemNetTypeToString(pool->def->source.format),
                                   src,
                                   pool->def->target.path,
                                   "-o",
                                   "guest",
                                   NULL);
518 519 520 521 522 523 524 525 526 527 528 529 530 531
    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;
532
 cleanup:
533
    virCommandFree(cmd);
534
    VIR_FREE(src);
535
    return ret;
536 537 538 539 540 541
}

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

553 554
    if (virStorageBackendFileSystemIsValid(pool) < 0)
        return -1;
555 556

    /* Short-circuit if already unmounted */
557 558
    if ((rc = virStorageBackendFileSystemIsMounted(pool)) != 1)
        return rc;
559

560 561 562
    cmd = virCommandNewArgList(UMOUNT,
                               pool->def->target.path,
                               NULL);
563

564 565 566 567
    if (virCommandRun(cmd, NULL) < 0)
        goto cleanup;

    ret = 0;
568
 cleanup:
569 570
    virCommandFree(cmd);
    return ret;
571 572 573 574
}
#endif /* WITH_STORAGE_FS */


575
static int
576
virStorageBackendFileSystemCheck(virStoragePoolObjPtr pool,
577 578 579
                                 bool *isActive)
{
    if (pool->def->type == VIR_STORAGE_POOL_DIR) {
580
        *isActive = virFileExists(pool->def->target.path);
581 582 583
#if WITH_STORAGE_FS
    } else {
        int ret;
584
        *isActive = false;
585 586 587 588

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

589 590 591 592 593 594 595 596 597 598 599 600
        if ((ret = virStorageBackendFileSystemIsMounted(pool)) != 0) {
            if (ret < 0)
                return -1;
            *isActive = true;
        }
#endif /* WITH_STORAGE_FS */
    }

    return 0;
}

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

    return 0;
}
#endif /* WITH_STORAGE_FS */

O
Osier Yang 已提交
622

623 624
/* some platforms don't support mkfs */
#ifdef MKFS
O
Osier Yang 已提交
625 626 627 628 629 630 631
static int
virStorageBackendExecuteMKFS(const char *device,
                             const char *format)
{
    int ret = 0;
    virCommandPtr cmd = NULL;

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

634 635 636
    /* 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 已提交
637 638
    if (STREQ(format, "xfs"))
        virCommandAddArg(cmd, "-f");
639 640 641 642 643 644
    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 已提交
645 646

    virCommandAddArg(cmd, device);
O
Osier Yang 已提交
647 648 649 650 651 652 653 654

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

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

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) {
682 683 684
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("No source device specified when formatting pool '%s'"),
                       pool->def->name);
O
Osier Yang 已提交
685 686 687 688 689 690 691 692
        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)) {
693 694 695
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("Source device does not exist when formatting pool '%s'"),
                       pool->def->name);
O
Osier Yang 已提交
696 697 698 699 700 701
        goto error;
    }

    if (flags & VIR_STORAGE_POOL_BUILD_OVERWRITE) {
        ok_to_mkfs = true;
    } else if (flags & VIR_STORAGE_POOL_BUILD_NO_OVERWRITE &&
702
               virStorageBackendDeviceIsEmpty(device, format, true)) {
O
Osier Yang 已提交
703 704 705
        ok_to_mkfs = true;
    }

706
    if (ok_to_mkfs)
O
Osier Yang 已提交
707 708
        ret = virStorageBackendExecuteMKFS(device, format);

709
 error:
O
Osier Yang 已提交
710 711 712
    return ret;
}

713 714 715 716

/**
 * @conn connection to report errors against
 * @pool storage pool to build
E
Eric Blake 已提交
717
 * @flags controls the pool formatting behaviour
718 719 720
 *
 * Build a directory or FS based storage pool.
 *
721 722 723 724 725 726 727 728 729
 * 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 已提交
730
 *
731
 * The underlying source device is mounted for FS based pools.
732 733 734 735
 *
 * Returns 0 on success, -1 on error
 */
static int
736
virStorageBackendFileSystemBuild(virConnectPtr conn ATTRIBUTE_UNUSED,
737
                                 virStoragePoolObjPtr pool,
E
Eric Blake 已提交
738
                                 unsigned int flags)
739
{
740
    int ret = -1;
O
Osier Yang 已提交
741 742
    char *parent = NULL;
    char *p = NULL;
743
    mode_t mode;
744 745
    bool needs_create_as_uid;
    unsigned int dir_create_flags;
746

O
Osier Yang 已提交
747 748 749
    virCheckFlags(VIR_STORAGE_POOL_BUILD_OVERWRITE |
                  VIR_STORAGE_POOL_BUILD_NO_OVERWRITE, ret);

750 751 752
    VIR_EXCLUSIVE_FLAGS_GOTO(VIR_STORAGE_POOL_BUILD_OVERWRITE,
                             VIR_STORAGE_POOL_BUILD_NO_OVERWRITE,
                             error);
E
Eric Blake 已提交
753

754
    if (VIR_STRDUP(parent, pool->def->target.path) < 0)
755 756
        goto error;
    if (!(p = strrchr(parent, '/'))) {
757 758 759
        virReportError(VIR_ERR_INVALID_ARG,
                       _("path '%s' is not absolute"),
                       pool->def->target.path);
760
        goto error;
761 762
    }

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

774 775 776 777 778 779 780 781
    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)
782
        dir_create_flags |= VIR_DIR_CREATE_AS_UID;
783

784 785 786
    /* 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. */
787 788 789 790 791
    if (virDirCreate(pool->def->target.path,
                     mode,
                     pool->def->target.perms.uid,
                     pool->def->target.perms.gid,
                     dir_create_flags) < 0)
792
        goto error;
O
Osier Yang 已提交
793 794 795 796 797 798 799

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

800
 error:
801 802
    VIR_FREE(parent);
    return ret;
803 804 805 806 807 808 809 810
}


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

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

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

829 830 831 832 833 834
        if (virStringHasControlChars(ent->d_name)) {
            VIR_WARN("Ignoring file with control characters under '%s'",
                     pool->def->target.path);
            continue;
        }

835
        if (VIR_ALLOC(vol) < 0)
836
            goto cleanup;
837

838
        if (VIR_STRDUP(vol->name, ent->d_name) < 0)
839
            goto cleanup;
840

841
        vol->type = VIR_STORAGE_VOL_FILE;
842
        vol->target.format = VIR_STORAGE_FILE_RAW; /* Real value is filled in during probe */
843 844 845
        if (virAsprintf(&vol->target.path, "%s/%s",
                        pool->def->target.path,
                        vol->name) == -1)
846
            goto cleanup;
847

848
        if (VIR_STRDUP(vol->key, vol->target.path) < 0)
849
            goto cleanup;
850

851
        if ((err = virStorageBackendProbeTarget(&vol->target,
852
                                                &vol->target.encryption)) < 0) {
853
            if (err == -2) {
854
                /* Silently ignore non-regular files,
855
                 * eg 'lost+found', dangling symbolic link */
856 857
                virStorageVolDefFree(vol);
                vol = NULL;
858
                continue;
859
            } else if (err == -3) {
860 861 862 863 864
                /* 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='...'/>. */
865
            } else {
866
                goto cleanup;
867
            }
868 869
        }

870 871 872 873
        /* directory based volume */
        if (vol->target.format == VIR_STORAGE_FILE_DIR)
            vol->type = VIR_STORAGE_VOL_DIR;

874 875 876
        if (vol->target.format == VIR_STORAGE_FILE_PLOOP)
            vol->type = VIR_STORAGE_VOL_PLOOP;

877
        if (vol->target.backingStore) {
878 879
            ignore_value(virStorageBackendUpdateVolTargetInfo(VIR_STORAGE_VOL_FILE,
                                                              vol->target.backingStore,
880
                                                              false,
881
                                                              VIR_STORAGE_VOL_OPEN_DEFAULT, 0));
882 883 884
            /* 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. */
885 886
        }

887
        if (VIR_APPEND_ELEMENT(pool->volumes.objs, pool->volumes.count, vol) < 0)
888
            goto cleanup;
889
    }
E
Eric Blake 已提交
890
    if (direrr < 0)
891
        goto cleanup;
J
Ján Tomko 已提交
892
    VIR_DIR_CLOSE(dir);
893
    vol = NULL;
894

895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915
    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 */
916
    if (statvfs(pool->def->target.path, &sb) < 0) {
917
        virReportSystemError(errno,
918 919
                             _("cannot statvfs path '%s'"),
                             pool->def->target.path);
920
        goto cleanup;
921
    }
922

923 924 925
    pool->def->capacity = ((unsigned long long)sb.f_frsize *
                           (unsigned long long)sb.f_blocks);
    pool->def->available = ((unsigned long long)sb.f_bfree *
926
                            (unsigned long long)sb.f_frsize);
927 928
    pool->def->allocation = pool->def->capacity - pool->def->available;

929 930 931 932 933 934
    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;
935

936 937
    ret = 0;
 cleanup:
J
Ján Tomko 已提交
938
    VIR_DIR_CLOSE(dir);
939
    VIR_FORCE_CLOSE(fd);
940
    virStorageVolDefFree(vol);
941 942 943 944
    virStorageSourceFree(target);
    if (ret < 0)
        virStoragePoolObjClearVols(pool);
    return ret;
945 946 947 948 949
}


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

    return 0;
}
#endif /* WITH_STORAGE_FS */


/**
 * @conn connection to report errors against
972
 * @pool storage pool to delete
973
 *
974
 * Delete a directory based storage pool
975 976 977 978
 *
 * Returns 0 on success, -1 on error
 */
static int
979
virStorageBackendFileSystemDelete(virConnectPtr conn ATTRIBUTE_UNUSED,
980
                                  virStoragePoolObjPtr pool,
E
Eric Blake 已提交
981
                                  unsigned int flags)
982
{
E
Eric Blake 已提交
983 984
    virCheckFlags(0, -1);

985 986
    /* XXX delete all vols first ? */

987
    if (rmdir(pool->def->target.path) < 0) {
988
        virReportSystemError(errno,
989
                             _("failed to remove pool '%s'"),
990
                             pool->def->target.path);
991 992 993 994 995 996 997 998
        return -1;
    }

    return 0;
}


/**
999 1000 1001 1002
 * 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.
1003 1004
 */
static int
1005
virStorageBackendFileSystemVolCreate(virConnectPtr conn ATTRIBUTE_UNUSED,
1006 1007 1008 1009
                                     virStoragePoolObjPtr pool,
                                     virStorageVolDefPtr vol)
{

1010 1011
    if (vol->target.format == VIR_STORAGE_FILE_DIR)
        vol->type = VIR_STORAGE_VOL_DIR;
O
Olga Krishtal 已提交
1012 1013
    else if (vol->target.format == VIR_STORAGE_FILE_PLOOP)
        vol->type = VIR_STORAGE_VOL_PLOOP;
1014 1015
    else
        vol->type = VIR_STORAGE_VOL_FILE;
1016

1017 1018 1019 1020 1021 1022 1023 1024
    /* 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 已提交
1025
    VIR_FREE(vol->target.path);
1026 1027
    if (virAsprintf(&vol->target.path, "%s/%s",
                    pool->def->target.path,
1028
                    vol->name) == -1)
1029
        return -1;
1030

1031 1032 1033 1034 1035 1036 1037
    if (virFileExists(vol->target.path)) {
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("volume target path '%s' already exists"),
                       vol->target.path);
        return -1;
    }

R
Ryota Ozaki 已提交
1038
    VIR_FREE(vol->key);
1039
    return VIR_STRDUP(vol->key, vol->target.path);
1040 1041
}

1042
static int createFileDir(virConnectPtr conn ATTRIBUTE_UNUSED,
1043
                         virStoragePoolObjPtr pool,
1044
                         virStorageVolDefPtr vol,
1045
                         virStorageVolDefPtr inputvol,
E
Eric Blake 已提交
1046 1047
                         unsigned int flags)
{
1048 1049
    int err;

E
Eric Blake 已提交
1050 1051
    virCheckFlags(0, -1);

1052
    if (inputvol) {
1053 1054 1055
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s",
                       _("cannot copy from volume to a directory volume"));
1056 1057 1058
        return -1;
    }

1059 1060 1061 1062 1063 1064 1065
    if (vol->target.backingStore) {
        virReportError(VIR_ERR_NO_SUPPORT, "%s",
                       _("backing storage not supported for directories volumes"));
        return -1;
    }


1066 1067 1068 1069
    if ((err = virDirCreate(vol->target.path,
                            (vol->target.perms->mode == (mode_t) -1 ?
                             VIR_STORAGE_DEFAULT_VOL_PERM_MODE :
                             vol->target.perms->mode),
1070 1071
                            vol->target.perms->uid,
                            vol->target.perms->gid,
1072
                            (pool->def->type == VIR_STORAGE_POOL_NETFS
1073
                             ? VIR_DIR_CREATE_AS_UID : 0))) < 0) {
1074 1075
        return -1;
    }
1076

1077 1078
    return 0;
}
1079

1080
static int
1081
_virStorageBackendFileSystemVolBuild(virConnectPtr conn,
1082
                                     virStoragePoolObjPtr pool,
1083
                                     virStorageVolDefPtr vol,
1084 1085
                                     virStorageVolDefPtr inputvol,
                                     unsigned int flags)
1086
{
1087
    virStorageBackendBuildVolFrom create_func;
1088

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

1112
    if (create_func(conn, pool, vol, inputvol, flags) < 0)
1113
        return -1;
1114 1115 1116
    return 0;
}

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

    return _virStorageBackendFileSystemVolBuild(conn, pool, vol, NULL, flags);
1133 1134 1135 1136 1137 1138 1139
}

/*
 * Create a storage vol using 'inputvol' as input
 */
static int
virStorageBackendFileSystemVolBuildFrom(virConnectPtr conn,
1140
                                        virStoragePoolObjPtr pool,
1141 1142
                                        virStorageVolDefPtr vol,
                                        virStorageVolDefPtr inputvol,
E
Eric Blake 已提交
1143 1144
                                        unsigned int flags)
{
1145 1146 1147
    virCheckFlags(VIR_STORAGE_VOL_CREATE_PREALLOC_METADATA |
                  VIR_STORAGE_VOL_CREATE_REFLINK,
                  -1);
E
Eric Blake 已提交
1148

1149
    return _virStorageBackendFileSystemVolBuild(conn, pool, vol, inputvol, flags);
1150
}
1151 1152

/**
1153
 * Remove a volume - no support for BLOCK and NETWORK yet
1154 1155
 */
static int
1156
virStorageBackendFileSystemVolDelete(virConnectPtr conn ATTRIBUTE_UNUSED,
1157 1158
                                     virStoragePoolObjPtr pool ATTRIBUTE_UNUSED,
                                     virStorageVolDefPtr vol,
E
Eric Blake 已提交
1159
                                     unsigned int flags)
1160
{
E
Eric Blake 已提交
1161 1162
    virCheckFlags(0, -1);

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


1199 1200 1201 1202
/* virStorageBackendFileSystemLoadDefaultSecrets:
 * @conn: Connection pointer to fetch secret
 * @vol: volume being refreshed
 *
1203 1204
 * If the volume had a secret generated, we need to regenerate the
 * encryption secret information
1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215
 *
 * 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;

1216
    if (!vol->target.encryption || vol->target.encryption->nsecrets != 0)
1217 1218
        return 0;

1219 1220 1221 1222 1223 1224 1225
    /* 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. */
1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240
    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 已提交
1241 1242
    encsec->seclookupdef.type = VIR_SECRET_LOOKUP_TYPE_UUID;
    virSecretGetUUID(sec, encsec->seclookupdef.u.uuid);
1243 1244 1245 1246 1247 1248
    virObjectUnref(sec);

    return 0;
}


1249 1250 1251 1252 1253 1254 1255 1256
/**
 * Update info about a volume's capacity/allocation
 */
static int
virStorageBackendFileSystemVolRefresh(virConnectPtr conn,
                                      virStoragePoolObjPtr pool ATTRIBUTE_UNUSED,
                                      virStorageVolDefPtr vol)
{
1257 1258
    int ret;

1259
    /* Refresh allocation / capacity / permissions info in case its changed */
1260 1261 1262
    if ((ret = virStorageBackendUpdateVolInfo(vol, false,
                                              VIR_STORAGE_VOL_FS_OPEN_FLAGS,
                                              0)) < 0)
1263 1264
        return ret;

N
Nehal J Wani 已提交
1265
    /* Load any secrets if possible */
1266
    return virStorageBackendFileSystemLoadDefaultSecrets(conn, vol);
1267 1268
}

1269 1270 1271 1272 1273 1274 1275 1276
static int
virStorageBackendFilesystemResizeQemuImg(const char *path,
                                         unsigned long long capacity)
{
    int ret = -1;
    char *img_tool;
    virCommandPtr cmd = NULL;

1277
    img_tool = virFindFileInPath("qemu-img");
1278
    if (!img_tool) {
1279
        virReportError(VIR_ERR_INTERNAL_ERROR,
1280
                       "%s", _("unable to find qemu-img"));
1281 1282 1283
        return -1;
    }

1284 1285 1286 1287
    /* Round capacity as qemu-img resize errors out on sizes which are not
     * a multiple of 512 */
    capacity = VIR_ROUND_UP(capacity, 512);

1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309
    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)
{
1310 1311
    virCheckFlags(VIR_STORAGE_VOL_RESIZE_ALLOCATE |
                  VIR_STORAGE_VOL_RESIZE_SHRINK, -1);
1312 1313 1314 1315 1316

    bool pre_allocate = flags & VIR_STORAGE_VOL_RESIZE_ALLOCATE;

    if (vol->target.format == VIR_STORAGE_FILE_RAW) {
        return virStorageFileResize(vol->target.path, capacity,
1317
                                    vol->target.allocation, pre_allocate);
1318 1319
    } else if (vol->target.format == VIR_STORAGE_FILE_PLOOP) {
        return virStoragePloopResize(vol, capacity);
1320 1321 1322 1323 1324 1325 1326
    } else {
        if (pre_allocate) {
            virReportError(VIR_ERR_OPERATION_UNSUPPORTED, "%s",
                           _("preallocate is only supported for raw "
                             "type volume"));
            return -1;
        }
1327 1328 1329

        return virStorageBackendFilesystemResizeQemuImg(vol->target.path,
                                                        capacity);
1330
    }
1331 1332
}

1333

1334 1335 1336 1337
virStorageBackend virStorageBackendDirectory = {
    .type = VIR_STORAGE_POOL_DIR,

    .buildPool = virStorageBackendFileSystemBuild,
1338
    .checkPool = virStorageBackendFileSystemCheck,
1339 1340
    .refreshPool = virStorageBackendFileSystemRefresh,
    .deletePool = virStorageBackendFileSystemDelete,
1341
    .buildVol = virStorageBackendFileSystemVolBuild,
1342
    .buildVolFrom = virStorageBackendFileSystemVolBuildFrom,
1343 1344 1345
    .createVol = virStorageBackendFileSystemVolCreate,
    .refreshVol = virStorageBackendFileSystemVolRefresh,
    .deleteVol = virStorageBackendFileSystemVolDelete,
1346
    .resizeVol = virStorageBackendFileSystemVolResize,
1347 1348
    .uploadVol = virStorageBackendVolUploadLocal,
    .downloadVol = virStorageBackendVolDownloadLocal,
1349
    .wipeVol = virStorageBackendVolWipeLocal,
1350 1351 1352 1353 1354 1355 1356
};

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

    .buildPool = virStorageBackendFileSystemBuild,
1357
    .checkPool = virStorageBackendFileSystemCheck,
1358 1359 1360 1361
    .startPool = virStorageBackendFileSystemStart,
    .refreshPool = virStorageBackendFileSystemRefresh,
    .stopPool = virStorageBackendFileSystemStop,
    .deletePool = virStorageBackendFileSystemDelete,
1362
    .buildVol = virStorageBackendFileSystemVolBuild,
1363
    .buildVolFrom = virStorageBackendFileSystemVolBuildFrom,
1364 1365 1366
    .createVol = virStorageBackendFileSystemVolCreate,
    .refreshVol = virStorageBackendFileSystemVolRefresh,
    .deleteVol = virStorageBackendFileSystemVolDelete,
1367
    .resizeVol = virStorageBackendFileSystemVolResize,
1368 1369
    .uploadVol = virStorageBackendVolUploadLocal,
    .downloadVol = virStorageBackendVolDownloadLocal,
1370
    .wipeVol = virStorageBackendVolWipeLocal,
1371 1372 1373 1374 1375
};
virStorageBackend virStorageBackendNetFileSystem = {
    .type = VIR_STORAGE_POOL_NETFS,

    .buildPool = virStorageBackendFileSystemBuild,
1376
    .checkPool = virStorageBackendFileSystemCheck,
1377
    .startPool = virStorageBackendFileSystemStart,
1378
    .findPoolSources = virStorageBackendFileSystemNetFindPoolSources,
1379 1380 1381
    .refreshPool = virStorageBackendFileSystemRefresh,
    .stopPool = virStorageBackendFileSystemStop,
    .deletePool = virStorageBackendFileSystemDelete,
1382
    .buildVol = virStorageBackendFileSystemVolBuild,
1383
    .buildVolFrom = virStorageBackendFileSystemVolBuildFrom,
1384 1385 1386
    .createVol = virStorageBackendFileSystemVolCreate,
    .refreshVol = virStorageBackendFileSystemVolRefresh,
    .deleteVol = virStorageBackendFileSystemVolDelete,
1387
    .resizeVol = virStorageBackendFileSystemVolResize,
1388 1389
    .uploadVol = virStorageBackendVolUploadLocal,
    .downloadVol = virStorageBackendVolDownloadLocal,
1390
    .wipeVol = virStorageBackendVolWipeLocal,
1391
};
1392 1393


1394 1395 1396 1397 1398 1399 1400 1401
typedef struct _virStorageFileBackendFsPriv virStorageFileBackendFsPriv;
typedef virStorageFileBackendFsPriv *virStorageFileBackendFsPrivPtr;

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


1402 1403 1404 1405 1406 1407 1408
static void
virStorageFileBackendFileDeinit(virStorageSourcePtr src)
{
    VIR_DEBUG("deinitializing FS storage file %p (%s:%s)", src,
              virStorageTypeToString(virStorageSourceGetActualType(src)),
              src->path);

1409 1410 1411 1412
    virStorageFileBackendFsPrivPtr priv = src->drv->priv;

    VIR_FREE(priv->canonpath);
    VIR_FREE(priv);
1413 1414 1415
}


1416
static int
1417
virStorageFileBackendFileInit(virStorageSourcePtr src)
1418
{
1419 1420
    virStorageFileBackendFsPrivPtr priv = NULL;

1421
    VIR_DEBUG("initializing FS storage file %p (%s:%s)[%u:%u]", src,
1422
              virStorageTypeToString(virStorageSourceGetActualType(src)),
1423 1424
              src->path,
              (unsigned int)src->drv->uid, (unsigned int)src->drv->gid);
1425

1426 1427 1428 1429 1430
    if (VIR_ALLOC(priv) < 0)
        return -1;

    src->drv->priv = priv;

1431 1432
    return 0;
}
1433 1434


1435 1436 1437 1438
static int
virStorageFileBackendFileCreate(virStorageSourcePtr src)
{
    int fd = -1;
1439
    mode_t mode = S_IRUSR;
1440

1441 1442 1443 1444
    if (!src->readonly)
        mode |= S_IWUSR;

    if ((fd = virFileOpenAs(src->path, O_WRONLY | O_TRUNC | O_CREAT, mode,
1445 1446 1447 1448 1449 1450 1451 1452 1453 1454
                            src->drv->uid, src->drv->gid, 0)) < 0) {
        errno = -fd;
        return -1;
    }

    VIR_FORCE_CLOSE(fd);
    return 0;
}


1455 1456 1457 1458
static int
virStorageFileBackendFileUnlink(virStorageSourcePtr src)
{
    return unlink(src->path);
1459 1460 1461 1462
}


static int
1463
virStorageFileBackendFileStat(virStorageSourcePtr src,
1464 1465
                              struct stat *st)
{
1466
    return stat(src->path, st);
1467 1468 1469
}


1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497
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;
}


1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514
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;
}


1515 1516 1517 1518 1519 1520 1521 1522 1523
static int
virStorageFileBackendFileAccess(virStorageSourcePtr src,
                                int mode)
{
    return virFileAccessibleAs(src->path, mode,
                               src->drv->uid, src->drv->gid);
}


1524
static int
1525
virStorageFileBackendFileChown(const virStorageSource *src,
1526 1527 1528 1529 1530 1531 1532
                               uid_t uid,
                               gid_t gid)
{
    return chown(src->path, uid, gid);
}


1533
virStorageFileBackend virStorageFileBackendFile = {
E
Eric Blake 已提交
1534
    .type = VIR_STORAGE_TYPE_FILE,
1535

1536 1537 1538
    .backendInit = virStorageFileBackendFileInit,
    .backendDeinit = virStorageFileBackendFileDeinit,

1539
    .storageFileCreate = virStorageFileBackendFileCreate,
1540 1541
    .storageFileUnlink = virStorageFileBackendFileUnlink,
    .storageFileStat = virStorageFileBackendFileStat,
1542
    .storageFileReadHeader = virStorageFileBackendFileReadHeader,
1543
    .storageFileAccess = virStorageFileBackendFileAccess,
1544
    .storageFileChown = virStorageFileBackendFileChown,
1545 1546

    .storageFileGetUniqueIdentifier = virStorageFileBackendFileGetUniqueIdentifier,
1547 1548 1549 1550
};


virStorageFileBackend virStorageFileBackendBlock = {
E
Eric Blake 已提交
1551
    .type = VIR_STORAGE_TYPE_BLOCK,
1552

1553 1554 1555
    .backendInit = virStorageFileBackendFileInit,
    .backendDeinit = virStorageFileBackendFileDeinit,

1556
    .storageFileStat = virStorageFileBackendFileStat,
1557
    .storageFileReadHeader = virStorageFileBackendFileReadHeader,
1558
    .storageFileAccess = virStorageFileBackendFileAccess,
1559
    .storageFileChown = virStorageFileBackendFileChown,
1560 1561

    .storageFileGetUniqueIdentifier = virStorageFileBackendFileGetUniqueIdentifier,
1562 1563 1564
};


1565 1566 1567 1568 1569 1570
virStorageFileBackend virStorageFileBackendDir = {
    .type = VIR_STORAGE_TYPE_DIR,

    .backendInit = virStorageFileBackendFileInit,
    .backendDeinit = virStorageFileBackendFileDeinit,

1571
    .storageFileAccess = virStorageFileBackendFileAccess,
1572
    .storageFileChown = virStorageFileBackendFileChown,
1573

1574 1575 1576
    .storageFileGetUniqueIdentifier = virStorageFileBackendFileGetUniqueIdentifier,
};

1577
#endif /* WITH_STORAGE_FS */