vircgroup.c 94.1 KB
Newer Older
1
/*
2
 * vircgroup.c: methods for managing control cgroups
3
 *
4
 * Copyright (C) 2010-2015 Red Hat, Inc.
5 6
 * Copyright IBM Corp. 2008
 *
O
Osier Yang 已提交
7 8 9 10 11 12 13 14 15 16 17
 * 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
 */
#include <config.h>

23
#ifdef __linux__
24
# include <mntent.h>
25
# include <sys/mount.h>
26 27
# include <fcntl.h>
# include <sys/stat.h>
28

29 30 31 32 33
# ifdef MAJOR_IN_MKDEV
#  include <sys/mkdev.h>
# elif MAJOR_IN_SYSMACROS
#  include <sys/sysmacros.h>
# endif
34

35 36 37 38 39
# include <sys/types.h>
# include <signal.h>
# include <dirent.h>
# include <unistd.h>
#endif /* __linux__ */
40

41
#define LIBVIRT_VIRCGROUPPRIV_H_ALLOW
42 43
#include "vircgrouppriv.h"

44
#include "virutil.h"
45
#include "viralloc.h"
46
#include "vircgroupbackend.h"
47
#include "virerror.h"
48
#include "virlog.h"
E
Eric Blake 已提交
49
#include "virfile.h"
50
#include "virhash.h"
51
#include "virhashcode.h"
52
#include "virstring.h"
53
#include "virsystemd.h"
54
#include "virtypedparam.h"
55
#include "virhostcpu.h"
56
#include "virthread.h"
57

58 59
VIR_LOG_INIT("util.cgroup");

60 61
#define VIR_FROM_THIS VIR_FROM_CGROUP

62
#define CGROUP_NB_TOTAL_CPU_STAT_PARAM 3
63
#define CGROUP_NB_PER_CPU_STAT_PARAM   1
64

65
VIR_ENUM_IMPL(virCgroupController, VIR_CGROUP_CONTROLLER_LAST,
R
Ryota Ozaki 已提交
66
              "cpu", "cpuacct", "cpuset", "memory", "devices",
67 68
              "freezer", "blkio", "net_cls", "perf_event",
              "name=systemd");
69

E
Eric Blake 已提交
70

71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108
/**
 * virCgroupGetDevicePermsString:
 *
 * @perms: Bitwise or of VIR_CGROUP_DEVICE permission bits
 *
 * Returns string corresponding to the appropriate bits set.
 */
const char *
virCgroupGetDevicePermsString(int perms)
{
    if (perms & VIR_CGROUP_DEVICE_READ) {
        if (perms & VIR_CGROUP_DEVICE_WRITE) {
            if (perms & VIR_CGROUP_DEVICE_MKNOD)
                return "rwm";
            else
                return "rw";
        } else {
            if (perms & VIR_CGROUP_DEVICE_MKNOD)
                return "rm";
            else
                return "r";
        }
    } else {
        if (perms & VIR_CGROUP_DEVICE_WRITE) {
            if (perms & VIR_CGROUP_DEVICE_MKNOD)
                return "wm";
            else
                return "w";
        } else {
            if (perms & VIR_CGROUP_DEVICE_MKNOD)
                return "m";
            else
                return "";
        }
    }
}


109
#ifdef __linux__
E
Eric Blake 已提交
110 111
bool
virCgroupAvailable(void)
112
{
113 114
    size_t i;
    virCgroupBackendPtr *backends = virCgroupBackendGetAll();
115

116
    if (!backends)
117 118
        return false;

119 120 121
    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (backends[i] && backends[i]->available())
            return true;
122 123
    }

124
    return false;
125 126
}

E
Eric Blake 已提交
127 128 129 130 131 132

static int
virCgroupPartitionNeedsEscaping(const char *path)
{
    FILE *fp = NULL;
    int ret = 0;
133
    VIR_AUTOFREE(char *) line = NULL;
E
Eric Blake 已提交
134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191
    size_t buflen;

    /* If it starts with 'cgroup.' or a '_' of any
     * of the controller names from /proc/cgroups,
     * then we must prefix a '_'
     */
    if (STRPREFIX(path, "cgroup."))
        return 1;

    if (path[0] == '_' ||
        path[0] == '.')
        return 1;

    if (!(fp = fopen("/proc/cgroups", "r"))) {
        /* The API contract is that we return ENXIO
         * if cgroups are not available on a host */
        if (errno == ENOENT)
            errno = ENXIO;
        virReportSystemError(errno, "%s",
                             _("Cannot open /proc/cgroups"));
        return -1;
    }

    /*
     * Data looks like this:
     * #subsys_name hierarchy num_cgroups enabled
     * cpuset  2 4  1
     * cpu     3 48 1
     * cpuacct 3 48 1
     * memory  4 4  1
     * devices 5 4  1
     * freezer 6 4  1
     * net_cls 7 1  1
     */
    while (getline(&line, &buflen, fp) > 0) {
        char *tmp;
        size_t len;

        if (STRPREFIX(line, "#subsys_name"))
            continue;

        tmp = strchrnul(line, ' ');
        *tmp = '\0';
        len = tmp - line;

        if (STRPREFIX(path, line) &&
            path[len] == '.') {
            ret = 1;
            goto cleanup;
        }
    }

    if (ferror(fp)) {
        virReportSystemError(errno, "%s",
                             _("Error while reading /proc/cgroups"));
        goto cleanup;
    }

192
 cleanup:
E
Eric Blake 已提交
193 194 195 196 197
    VIR_FORCE_FCLOSE(fp);
    return ret;
}


198
int
E
Eric Blake 已提交
199 200 201
virCgroupPartitionEscape(char **path)
{
    int rc;
202
    char *newstr = NULL;
E
Eric Blake 已提交
203 204 205 206

    if ((rc = virCgroupPartitionNeedsEscaping(*path)) <= 0)
        return rc;

207
    if (virAsprintf(&newstr, "_%s", *path) < 0)
E
Eric Blake 已提交
208 209
        return -1;

210 211 212
    VIR_FREE(*path);
    *path = newstr;

E
Eric Blake 已提交
213 214
    return 0;
}
E
Eric Blake 已提交
215 216


217 218 219 220
/*
 * Process /proc/mounts figuring out what controllers are
 * mounted and where
 */
221
static int
222
virCgroupDetectMounts(virCgroupPtr group)
223
{
224
    FILE *mounts = NULL;
225 226
    struct mntent entry;
    char buf[CGROUP_MAX_VAL];
227
    int ret = -1;
228
    size_t i;
229

230
    mounts = fopen("/proc/mounts", "r");
231
    if (mounts == NULL) {
232
        virReportSystemError(errno, "%s", _("Unable to open /proc/mounts"));
233
        return -1;
234 235 236
    }

    while (getmntent_r(mounts, &entry, buf, sizeof(buf)) != NULL) {
237 238 239 240 241 242 243 244
        for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
            if (group->backends[i] &&
                group->backends[i]->detectMounts(group,
                                                 entry.mnt_type,
                                                 entry.mnt_opts,
                                                 entry.mnt_dir) < 0) {
                goto cleanup;
            }
245
        }
246 247
    }

248 249
    ret = 0;
 cleanup:
250
    VIR_FORCE_FCLOSE(mounts);
251
    return ret;
252 253
}

254 255

/*
256 257 258 259
 * virCgroupDetectPlacement:
 * @group: the group to process
 * @path: the relative path to append, not starting with '/'
 *
260 261
 * Process /proc/self/cgroup figuring out what cgroup
 * sub-path the current process is assigned to. ie not
262 263 264 265 266 267 268 269 270 271 272 273 274 275
 * necessarily in the root. The contents of this file
 * looks like
 *
 * 9:perf_event:/
 * 8:blkio:/
 * 7:net_cls:/
 * 6:freezer:/
 * 5:devices:/
 * 4:memory:/
 * 3:cpuacct,cpu:/
 * 2:cpuset:/
 * 1:name=systemd:/user/berrange/2
 *
 * It then appends @path to each detected path.
276
 */
E
Eric Blake 已提交
277 278 279 280
static int
virCgroupDetectPlacement(virCgroupPtr group,
                         pid_t pid,
                         const char *path)
281
{
282 283
    FILE *mapping  = NULL;
    char line[1024];
284
    int ret = -1;
285
    VIR_AUTOFREE(char *) procfile = NULL;
286

287
    VIR_DEBUG("Detecting placement for pid %lld path %s",
M
Michal Privoznik 已提交
288
              (long long) pid, path);
289 290 291 292
    if (pid == -1) {
        if (VIR_STRDUP(procfile, "/proc/self/cgroup") < 0)
            goto cleanup;
    } else {
M
Michal Privoznik 已提交
293 294
        if (virAsprintf(&procfile, "/proc/%lld/cgroup",
                        (long long) pid) < 0)
295 296 297 298
            goto cleanup;
    }

    mapping = fopen(procfile, "r");
299
    if (mapping == NULL) {
300 301 302 303
        virReportSystemError(errno,
                             _("Unable to open '%s'"),
                             procfile);
        goto cleanup;
304 305
    }

306
    while (fgets(line, sizeof(line), mapping) != NULL) {
307
        size_t i;
308
        char *controllers = strchr(line, ':');
309 310
        char *selfpath = controllers ? strchr(controllers + 1, ':') : NULL;
        char *nl = selfpath ? strchr(selfpath, '\n') : NULL;
311

312
        if (!controllers || !selfpath)
313 314 315 316 317
            continue;

        if (nl)
            *nl = '\0';

318
        *selfpath = '\0';
319
        controllers++;
320
        selfpath++;
321

322 323 324 325 326 327
        for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
            if (group->backends[i] &&
                group->backends[i]->detectPlacement(group, path, controllers,
                                                    selfpath) < 0) {
                goto cleanup;
            }
328 329 330
        }
    }

331
    ret = 0;
332

333
 cleanup:
334
    VIR_FORCE_FCLOSE(mapping);
335
    return ret;
336 337
}

E
Eric Blake 已提交
338

339 340 341 342 343 344 345
static int
virCgroupDetect(virCgroupPtr group,
                pid_t pid,
                int controllers,
                const char *path,
                virCgroupPtr parent)
{
346
    size_t i;
347 348
    bool backendAvailable = false;
    int controllersAvailable = 0;
349
    virCgroupBackendPtr *backends = virCgroupBackendGetAll();
350 351 352 353

    VIR_DEBUG("group=%p controllers=%d path=%s parent=%p",
              group, controllers, path, parent);

354 355 356 357 358
    if (!backends)
        return -1;

    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (backends[i] && backends[i]->available()) {
359 360
            group->backends[i] = backends[i];
            backendAvailable = true;
361 362 363
        }
    }

364
    if (!backendAvailable) {
365 366 367 368 369
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("no cgroup backend available"));
        return -1;
    }

370
    if (parent) {
371 372 373 374 375 376
        for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
            if (group->backends[i] &&
                group->backends[i]->copyMounts(group, parent) < 0) {
                return -1;
            }
        }
377 378 379 380 381
    } else {
        if (virCgroupDetectMounts(group) < 0)
            return -1;
    }

382 383 384 385 386 387 388 389
    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (group->backends[i]) {
            int rc = group->backends[i]->detectControllers(group, controllers);
            if (rc < 0)
                return -1;
            controllersAvailable |= rc;
        }
    }
390

391
    /* Check that at least 1 controller is available */
392
    if (controllersAvailable == 0) {
393 394 395
        virReportSystemError(ENXIO, "%s",
                             _("At least one cgroup controller is required"));
        return -1;
396
    }
397

398 399 400
    /* In some cases we can copy part of the placement info
     * based on the parent cgroup...
     */
401 402 403 404 405 406 407 408
    if (parent || path[0] == '/') {
        for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
            if (group->backends[i] &&
                group->backends[i]->copyPlacement(group, path, parent) < 0) {
                return -1;
            }
        }
    }
409 410 411 412

    /* ... but use /proc/cgroups to fill in the rest */
    if (virCgroupDetectPlacement(group, pid, path) < 0)
        return -1;
413

414
    /* Check that for every mounted controller, we found our placement */
415 416 417 418 419 420
    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (group->backends[i] &&
            group->backends[i]->validatePlacement(group, pid) < 0) {
            return -1;
        }
    }
421

422
    return 0;
423 424
}

425

426
char *
427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454
virCgroupGetBlockDevString(const char *path)
{
    char *ret = NULL;
    struct stat sb;

    if (stat(path, &sb) < 0) {
        virReportSystemError(errno,
                             _("Path '%s' is not accessible"),
                             path);
        return NULL;
    }

    if (!S_ISBLK(sb.st_mode)) {
        virReportSystemError(EINVAL,
                             _("Path '%s' must be a block device"),
                             path);
        return NULL;
    }

    /* Automatically append space after the string since all callers
     * use it anyway */
    if (virAsprintf(&ret, "%d:%d ", major(sb.st_rdev), minor(sb.st_rdev)) < 0)
        return NULL;

    return ret;
}


455
int
E
Eric Blake 已提交
456 457 458 459
virCgroupSetValueStr(virCgroupPtr group,
                     int controller,
                     const char *key,
                     const char *value)
460
{
461
    VIR_AUTOFREE(char *) keypath = NULL;
462
    char *tmp = NULL;
463

464 465
    if (virCgroupPathOfController(group, controller, key, &keypath) < 0)
        return -1;
466

467
    VIR_DEBUG("Set value '%s' to '%s'", keypath, value);
468
    if (virFileWriteStr(keypath, value, 0) < 0) {
469 470 471 472 473
        if (errno == EINVAL &&
            (tmp = strrchr(keypath, '/'))) {
            virReportSystemError(errno,
                                 _("Invalid value '%s' for '%s'"),
                                 value, tmp + 1);
474
            return -1;
475
        }
476 477
        virReportSystemError(errno,
                             _("Unable to write to '%s'"), keypath);
478
        return -1;
479 480
    }

481
    return 0;
482 483
}

E
Eric Blake 已提交
484

485
int
E
Eric Blake 已提交
486 487 488 489
virCgroupGetValueStr(virCgroupPtr group,
                     int controller,
                     const char *key,
                     char **value)
490
{
491 492
    VIR_AUTOFREE(char *) keypath = NULL;
    int rc;
493

494
    *value = NULL;
495

496 497
    if (virCgroupPathOfController(group, controller, key, &keypath) < 0)
        return -1;
498

499
    VIR_DEBUG("Get value %s", keypath);
500

501 502 503
    if ((rc = virFileReadAll(keypath, 1024*1024, value)) < 0) {
        virReportSystemError(errno,
                             _("Unable to read from '%s'"), keypath);
504
        return -1;
505 506
    }

507 508 509
    /* Terminated with '\n' has sometimes harmful effects to the caller */
    if (rc > 0 && (*value)[rc - 1] == '\n')
        (*value)[rc - 1] = '\0';
510

511
    return 0;
512 513
}

E
Eric Blake 已提交
514

515
int
516 517 518 519 520 521
virCgroupGetValueForBlkDev(virCgroupPtr group,
                           int controller,
                           const char *key,
                           const char *path,
                           char **value)
{
522 523
    VIR_AUTOFREE(char *) prefix = NULL;
    VIR_AUTOFREE(char *) str = NULL;
524 525
    char **lines = NULL;
    int ret = -1;
526 527

    if (virCgroupGetValueStr(group, controller, key, &str) < 0)
528
        goto error;
529 530

    if (!(prefix = virCgroupGetBlockDevString(path)))
531
        goto error;
532 533

    if (!(lines = virStringSplit(str, "\n", -1)))
534
        goto error;
535

536
    if (VIR_STRDUP(*value, virStringListGetFirstWithPrefix(lines, prefix)) < 0)
537
        goto error;
538

539 540 541 542
    ret = 0;
 error:
    virStringListFree(lines);
    return ret;
543 544 545
}


546
int
E
Eric Blake 已提交
547 548 549 550
virCgroupSetValueU64(virCgroupPtr group,
                     int controller,
                     const char *key,
                     unsigned long long int value)
551
{
552
    VIR_AUTOFREE(char *) strval = NULL;
553

554 555
    if (virAsprintf(&strval, "%llu", value) < 0)
        return -1;
556

557
    return virCgroupSetValueStr(group, controller, key, strval);
558 559 560
}


561
int
E
Eric Blake 已提交
562 563 564 565
virCgroupSetValueI64(virCgroupPtr group,
                     int controller,
                     const char *key,
                     long long int value)
566
{
567
    VIR_AUTOFREE(char *) strval = NULL;
568

569 570
    if (virAsprintf(&strval, "%lld", value) < 0)
        return -1;
571

572
    return virCgroupSetValueStr(group, controller, key, strval);
573 574
}

E
Eric Blake 已提交
575

576
int
E
Eric Blake 已提交
577 578 579 580
virCgroupGetValueI64(virCgroupPtr group,
                     int controller,
                     const char *key,
                     long long int *value)
581
{
582
    VIR_AUTOFREE(char *) strval = NULL;
583

584
    if (virCgroupGetValueStr(group, controller, key, &strval) < 0)
585
        return -1;
586

587 588 589 590
    if (virStrToLong_ll(strval, NULL, 10, value) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Unable to parse '%s' as an integer"),
                       strval);
591
        return -1;
592
    }
593

594
    return 0;
595 596
}

E
Eric Blake 已提交
597

598
int
E
Eric Blake 已提交
599 600 601 602
virCgroupGetValueU64(virCgroupPtr group,
                     int controller,
                     const char *key,
                     unsigned long long int *value)
603
{
604
    VIR_AUTOFREE(char *) strval = NULL;
605

606
    if (virCgroupGetValueStr(group, controller, key, &strval) < 0)
607
        return -1;
608

609 610 611 612
    if (virStrToLong_ull(strval, NULL, 10, value) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Unable to parse '%s' as an integer"),
                       strval);
613
        return -1;
614
    }
615

616
    return 0;
617 618 619
}


E
Eric Blake 已提交
620 621 622 623 624
static int
virCgroupMakeGroup(virCgroupPtr parent,
                   virCgroupPtr group,
                   bool create,
                   unsigned int flags)
625
{
626 627 628 629 630 631 632 633
    size_t i;

    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (group->backends[i] &&
            group->backends[i]->makeGroup(parent, group, create, flags) < 0) {
            virCgroupRemove(group);
            return -1;
        }
634 635
    }

636
    return 0;
637 638
}

639

640 641 642 643 644 645 646 647 648 649 650 651 652 653
/**
 * virCgroupNew:
 * @path: path for the new group
 * @parent: parent group, or NULL
 * @controllers: bitmask of controllers to activate
 *
 * Create a new cgroup storing it in @group.
 *
 * If @path starts with a '/' it is treated as an
 * absolute path, and @parent is ignored. Otherwise
 * it is treated as being relative to @parent. If
 * @parent is NULL, then the placement of the current
 * process is used.
 *
654
 * Returns 0 on success, -1 on error
655
 */
656
int
E
Eric Blake 已提交
657 658 659 660 661
virCgroupNew(pid_t pid,
             const char *path,
             virCgroupPtr parent,
             int controllers,
             virCgroupPtr *group)
662
{
663 664
    VIR_DEBUG("pid=%lld path=%s parent=%p controllers=%d group=%p",
              (long long) pid, path, parent, controllers, group);
665
    *group = NULL;
666

667 668
    if (VIR_ALLOC((*group)) < 0)
        goto error;
669

670
    if (path[0] == '/' || !parent) {
671 672
        if (VIR_STRDUP((*group)->path, path) < 0)
            goto error;
673 674 675 676
    } else {
        if (virAsprintf(&(*group)->path, "%s%s%s",
                        parent->path,
                        STREQ(parent->path, "") ? "" : "/",
677 678
                        path) < 0)
            goto error;
679 680
    }

681
    if (virCgroupDetect(*group, pid, controllers, path, parent) < 0)
682
        goto error;
683

684 685
    return 0;

686
 error:
687
    virCgroupFree(group);
688
    *group = NULL;
689

690
    return -1;
691
}
692

693

694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711
static int
virCgroupAddTaskInternal(virCgroupPtr group,
                         pid_t pid,
                         unsigned int flags)
{
    size_t i;

    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (group->backends[i] &&
            group->backends[i]->addTask(group, pid, flags) < 0) {
            return -1;
        }
    }

    return 0;
}


712
/**
713
 * virCgroupAddProcess:
714
 *
715 716
 * @group: The cgroup to add a process to
 * @pid: The pid of the process to add
717
 *
718
 * Will add the process to all controllers, except the
719 720 721 722 723
 * systemd unit controller.
 *
 * Returns: 0 on success, -1 on error
 */
int
724
virCgroupAddProcess(virCgroupPtr group, pid_t pid)
725
{
726
    return virCgroupAddTaskInternal(group, pid, VIR_CGROUP_TASK_PROCESS);
727 728 729
}

/**
730
 * virCgroupAddMachineProcess:
731
 *
732 733
 * @group: The cgroup to add a process to
 * @pid: The pid of the process to add
734
 *
735
 * Will add the process to all controllers, including the
736 737 738 739 740
 * systemd unit controller.
 *
 * Returns: 0 on success, -1 on error
 */
int
741
virCgroupAddMachineProcess(virCgroupPtr group, pid_t pid)
742
{
743 744 745
    return virCgroupAddTaskInternal(group, pid,
                                    VIR_CGROUP_TASK_PROCESS |
                                    VIR_CGROUP_TASK_SYSTEMD);
746 747
}

748 749 750 751 752 753 754 755 756 757 758 759 760 761 762
/**
 * virCgroupAddThread:
 *
 * @group: The cgroup to add a thread to
 * @pid: The pid of the thread to add
 *
 * Will add the thread to all controllers, except the
 * systemd unit controller.
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupAddThread(virCgroupPtr group,
                   pid_t pid)
{
763
    return virCgroupAddTaskInternal(group, pid, VIR_CGROUP_TASK_THREAD);
764 765
}

E
Eric Blake 已提交
766 767 768

static int
virCgroupSetPartitionSuffix(const char *path, char **res)
769
{
770
    char **tokens;
771
    size_t i;
772
    int ret = -1;
773

774
    if (!(tokens = virStringSplit(path, "/", 0)))
775
        return ret;
776

777
    for (i = 0; tokens[i] != NULL; i++) {
778 779 780 781 782 783 784 785 786 787 788 789 790 791 792
        /* Whitelist the 3 top level fixed dirs
         * NB i == 0 is "", since we have leading '/'
         */
        if (i == 1 &&
            (STREQ(tokens[i], "machine") ||
             STREQ(tokens[i], "system") ||
             STREQ(tokens[i], "user"))) {
            continue;
        }
        /* If there is no suffix set already, then
         * add ".partition"
         */
        if (STRNEQ(tokens[i], "") &&
            !strchr(tokens[i], '.')) {
            if (VIR_REALLOC_N(tokens[i],
793
                              strlen(tokens[i]) + strlen(".partition") + 1) < 0)
794
                goto cleanup;
795 796
            strcat(tokens[i], ".partition");
        }
797

798
        if (virCgroupPartitionEscape(&(tokens[i])) < 0)
799
            goto cleanup;
800 801
    }

802
    if (!(*res = virStringListJoin((const char **)tokens, "/")))
803
        goto cleanup;
804

805 806 807 808 809
    ret = 0;

 cleanup:
    virStringListFree(tokens);
    return ret;
810 811
}

E
Eric Blake 已提交
812

813 814 815 816 817 818 819
/**
 * virCgroupNewPartition:
 * @path: path for the partition
 * @create: true to create the cgroup tree
 * @controllers: mask of controllers to create
 *
 * Creates a new cgroup to represent the resource
820
 * partition path identified by @path.
821
 *
822
 * Returns 0 on success, -1 on failure
823
 */
E
Eric Blake 已提交
824 825 826 827 828
int
virCgroupNewPartition(const char *path,
                      bool create,
                      int controllers,
                      virCgroupPtr *group)
829
{
830
    int ret = -1;
831 832
    VIR_AUTOFREE(char *) parentPath = NULL;
    VIR_AUTOFREE(char *) newPath = NULL;
833
    virCgroupPtr parent = NULL;
834 835 836
    VIR_DEBUG("path=%s create=%d controllers=%x",
              path, create, controllers);

837 838 839 840 841 842
    if (path[0] != '/') {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Partition path '%s' must start with '/'"),
                       path);
        return -1;
    }
843

844
    if (virCgroupSetPartitionSuffix(path, &newPath) < 0)
845
        goto cleanup;
846

847 848
    if (virCgroupNew(-1, newPath, NULL, controllers, group) < 0)
        goto cleanup;
849

850
    if (STRNEQ(newPath, "/")) {
851
        char *tmp;
852
        if (VIR_STRDUP(parentPath, newPath) < 0)
853
            goto cleanup;
854 855 856 857 858

        tmp = strrchr(parentPath, '/');
        tmp++;
        *tmp = '\0';

859
        if (virCgroupNew(-1, parentPath, NULL, controllers, &parent) < 0)
860
            goto cleanup;
861

862
        if (virCgroupMakeGroup(parent, *group, create, VIR_CGROUP_NONE) < 0)
863
            goto cleanup;
864 865
    }

866 867 868
    ret = 0;
 cleanup:
    if (ret != 0)
869 870
        virCgroupFree(group);
    virCgroupFree(&parent);
871
    return ret;
872 873
}

874

G
Gao feng 已提交
875
/**
876
* virCgroupNewSelf:
G
Gao feng 已提交
877 878 879
*
* @group: Pointer to returned virCgroupPtr
*
880 881 882
* Obtain a cgroup representing the config of the
* current process
*
883
* Returns 0 on success, or -1 on error
G
Gao feng 已提交
884
*/
E
Eric Blake 已提交
885 886
int
virCgroupNewSelf(virCgroupPtr *group)
G
Gao feng 已提交
887
{
888
    return virCgroupNewDetect(-1, -1, group);
G
Gao feng 已提交
889
}
890

891

892 893 894 895 896 897 898 899
/**
 * virCgroupNewDomainPartition:
 *
 * @partition: partition holding the domain
 * @driver: name of the driver
 * @name: name of the domain
 * @group: Pointer to returned virCgroupPtr
 *
900
 * Returns 0 on success, or -1 on error
901
 */
E
Eric Blake 已提交
902 903 904 905 906 907
int
virCgroupNewDomainPartition(virCgroupPtr partition,
                            const char *driver,
                            const char *name,
                            bool create,
                            virCgroupPtr *group)
908
{
909
    VIR_AUTOFREE(char *)grpname = NULL;
910

911
    if (virAsprintf(&grpname, "%s.libvirt-%s",
912
                    name, driver) < 0)
913
        return -1;
914

915
    if (virCgroupPartitionEscape(&grpname) < 0)
916
        return -1;
917

918
    if (virCgroupNew(-1, grpname, partition, -1, group) < 0)
919
        return -1;
920 921 922 923 924 925 926 927 928 929 930

    /*
     * Create a cgroup with memory.use_hierarchy enabled to
     * surely account memory usage of lxc with ns subsystem
     * enabled. (To be exact, memory and ns subsystems are
     * enabled at the same time.)
     *
     * The reason why doing it here, not a upper group, say
     * a group for driver, is to avoid overhead to track
     * cumulative usage that we don't need.
     */
E
Eric Blake 已提交
931 932
    if (virCgroupMakeGroup(partition, *group, create,
                           VIR_CGROUP_MEM_HIERACHY) < 0) {
933
        virCgroupFree(group);
934
        return -1;
935 936
    }

937
    return 0;
938
}
939

E
Eric Blake 已提交
940

941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958
/**
 * virCgroupNewThread:
 *
 * @domain: group for the domain
 * @name: enum to generate the name for the new thread
 * @id: id of the vcpu or iothread
 * @create: true to create if not already existing
 * @group: Pointer to returned virCgroupPtr
 *
 * Returns 0 on success, or -1 on error
 */
int
virCgroupNewThread(virCgroupPtr domain,
                   virCgroupThreadName nameval,
                   int id,
                   bool create,
                   virCgroupPtr *group)
{
959
    VIR_AUTOFREE(char *) name = NULL;
960 961 962 963 964
    int controllers;

    switch (nameval) {
    case VIR_CGROUP_THREAD_VCPU:
        if (virAsprintf(&name, "vcpu%d", id) < 0)
965
            return -1;
966 967 968
        break;
    case VIR_CGROUP_THREAD_EMULATOR:
        if (VIR_STRDUP(name, "emulator") < 0)
969
            return -1;
970 971 972
        break;
    case VIR_CGROUP_THREAD_IOTHREAD:
        if (virAsprintf(&name, "iothread%d", id) < 0)
973
            return -1;
974 975 976 977
        break;
    case VIR_CGROUP_THREAD_LAST:
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected name value %d"), nameval);
978
        return -1;
979 980 981 982 983 984 985
    }

    controllers = ((1 << VIR_CGROUP_CONTROLLER_CPU) |
                   (1 << VIR_CGROUP_CONTROLLER_CPUACCT) |
                   (1 << VIR_CGROUP_CONTROLLER_CPUSET));

    if (virCgroupNew(-1, name, domain, controllers, group) < 0)
986
        return -1;
987

988
    if (virCgroupMakeGroup(domain, *group, create, VIR_CGROUP_THREAD) < 0) {
989
        virCgroupFree(group);
990
        return -1;
991 992
    }

993
    return 0;
994 995 996
}


E
Eric Blake 已提交
997 998 999 1000
int
virCgroupNewDetect(pid_t pid,
                   int controllers,
                   virCgroupPtr *group)
1001
{
1002
    return virCgroupNew(pid, "", NULL, controllers, group);
1003 1004
}

E
Eric Blake 已提交
1005

1006 1007 1008
/*
 * Returns 0 on success (but @group may be NULL), -1 on fatal error
 */
E
Eric Blake 已提交
1009 1010 1011 1012 1013
int
virCgroupNewDetectMachine(const char *name,
                          const char *drivername,
                          pid_t pid,
                          int controllers,
1014
                          char *machinename,
E
Eric Blake 已提交
1015
                          virCgroupPtr *group)
1016
{
1017 1018
    size_t i;

1019
    if (virCgroupNewDetect(pid, controllers, group) < 0) {
1020 1021 1022 1023 1024
        if (virCgroupNewIgnoreError())
            return 0;
        return -1;
    }

1025 1026 1027 1028 1029 1030 1031 1032 1033 1034
    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if ((*group)->backends[i] &&
            !(*group)->backends[i]->validateMachineGroup(*group, name,
                                                         drivername,
                                                         machinename)) {
            VIR_DEBUG("Failed to validate machine name for '%s' driver '%s'",
                      name, drivername);
            virCgroupFree(group);
            return 0;
        }
1035 1036 1037 1038 1039
    }

    return 0;
}

E
Eric Blake 已提交
1040

1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051
static int
virCgroupEnableMissingControllers(char *path,
                                  pid_t pidleader,
                                  int controllers,
                                  virCgroupPtr *group)
{
    virCgroupPtr parent = NULL;
    char *offset = path;
    int ret = -1;

    if (virCgroupNew(pidleader,
1052
                     "/",
1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092
                     NULL,
                     controllers,
                     &parent) < 0)
        return ret;

    for (;;) {
        virCgroupPtr tmp;
        char *t = strchr(offset + 1, '/');
        if (t)
            *t = '\0';

        if (virCgroupNew(pidleader,
                         path,
                         parent,
                         controllers,
                         &tmp) < 0)
            goto cleanup;

        if (virCgroupMakeGroup(parent, tmp, true, VIR_CGROUP_NONE) < 0) {
            virCgroupFree(&tmp);
            goto cleanup;
        }
        if (t) {
            *t = '/';
            offset = t;
            virCgroupFree(&parent);
            parent = tmp;
        } else {
            *group = tmp;
            break;
        }
    }

    ret = 0;
 cleanup:
    virCgroupFree(&parent);
    return ret;
}


1093 1094 1095 1096 1097 1098 1099 1100 1101 1102
/*
 * Returns 0 on success, -1 on fatal error, -2 on systemd not available
 */
static int
virCgroupNewMachineSystemd(const char *name,
                           const char *drivername,
                           const unsigned char *uuid,
                           const char *rootdir,
                           pid_t pidleader,
                           bool isContainer,
1103 1104
                           size_t nnicindexes,
                           int *nicindexes,
1105 1106 1107
                           const char *partition,
                           int controllers,
                           virCgroupPtr *group)
1108
{
1109
    int rv;
1110
    virCgroupPtr init;
1111
    VIR_AUTOFREE(char *) path = NULL;
1112
    size_t i;
1113 1114 1115 1116 1117 1118 1119 1120

    VIR_DEBUG("Trying to setup machine '%s' via systemd", name);
    if ((rv = virSystemdCreateMachine(name,
                                      drivername,
                                      uuid,
                                      rootdir,
                                      pidleader,
                                      isContainer,
1121 1122
                                      nnicindexes,
                                      nicindexes,
1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133
                                      partition)) < 0)
        return rv;

    if (controllers != -1)
        controllers |= (1 << VIR_CGROUP_CONTROLLER_SYSTEMD);

    VIR_DEBUG("Detecting systemd placement");
    if (virCgroupNewDetect(pidleader,
                           controllers,
                           &init) < 0)
        return -1;
1134

1135 1136 1137 1138 1139 1140
    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (init->backends[i] &&
            (path = init->backends[i]->stealPlacement(init))) {
            break;
        }
    }
1141
    virCgroupFree(&init);
1142 1143 1144

    if (!path || STREQ(path, "/") || path[0] != '/') {
        VIR_DEBUG("Systemd didn't setup its controller");
1145
        return -2;
1146 1147
    }

1148 1149
    if (virCgroupEnableMissingControllers(path, pidleader,
                                          controllers, group) < 0) {
1150
        return -1;
1151 1152
    }

1153 1154 1155 1156 1157 1158 1159 1160
    if (virCgroupAddProcess(*group, pidleader) < 0) {
        virErrorPtr saved = virSaveLastError();
        virCgroupRemove(*group);
        virCgroupFree(group);
        if (saved) {
            virSetError(saved);
            virFreeError(saved);
        }
1161 1162
    }

1163
    return 0;
1164
}
1165

E
Eric Blake 已提交
1166

1167 1168 1169
/*
 * Returns 0 on success, -1 on fatal error
 */
1170
int virCgroupTerminateMachine(const char *name)
1171
{
1172
    return virSystemdTerminateMachine(name);
1173 1174 1175
}


1176 1177 1178
static int
virCgroupNewMachineManual(const char *name,
                          const char *drivername,
1179
                          pid_t pidleader,
1180 1181 1182 1183
                          const char *partition,
                          int controllers,
                          virCgroupPtr *group)
{
1184 1185
    virCgroupPtr parent = NULL;
    int ret = -1;
1186 1187

    VIR_DEBUG("Fallback to non-systemd setup");
1188 1189 1190 1191 1192
    if (virCgroupNewPartition(partition,
                              STREQ(partition, "/machine"),
                              controllers,
                              &parent) < 0) {
        if (virCgroupNewIgnoreError())
1193
            goto done;
1194

1195
        goto cleanup;
1196 1197 1198 1199 1200 1201 1202
    }

    if (virCgroupNewDomainPartition(parent,
                                    drivername,
                                    name,
                                    true,
                                    group) < 0)
1203
        goto cleanup;
1204

1205
    if (virCgroupAddProcess(*group, pidleader) < 0) {
1206 1207
        virErrorPtr saved = virSaveLastError();
        virCgroupRemove(*group);
1208
        virCgroupFree(group);
1209 1210 1211 1212 1213 1214
        if (saved) {
            virSetError(saved);
            virFreeError(saved);
        }
    }

1215 1216 1217 1218
 done:
    ret = 0;

 cleanup:
1219
    virCgroupFree(&parent);
1220
    return ret;
1221 1222
}

E
Eric Blake 已提交
1223 1224 1225 1226 1227 1228 1229 1230

int
virCgroupNewMachine(const char *name,
                    const char *drivername,
                    const unsigned char *uuid,
                    const char *rootdir,
                    pid_t pidleader,
                    bool isContainer,
1231 1232
                    size_t nnicindexes,
                    int *nicindexes,
E
Eric Blake 已提交
1233 1234 1235
                    const char *partition,
                    int controllers,
                    virCgroupPtr *group)
1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246
{
    int rv;

    *group = NULL;

    if ((rv = virCgroupNewMachineSystemd(name,
                                         drivername,
                                         uuid,
                                         rootdir,
                                         pidleader,
                                         isContainer,
1247 1248
                                         nnicindexes,
                                         nicindexes,
1249 1250 1251 1252 1253 1254 1255 1256 1257 1258
                                         partition,
                                         controllers,
                                         group)) == 0)
        return 0;

    if (rv == -1)
        return -1;

    return virCgroupNewMachineManual(name,
                                     drivername,
1259
                                     pidleader,
1260 1261 1262 1263 1264
                                     partition,
                                     controllers,
                                     group);
}

E
Eric Blake 已提交
1265 1266 1267

bool
virCgroupNewIgnoreError(void)
1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278
{
    if (virLastErrorIsSystemErrno(ENXIO) ||
        virLastErrorIsSystemErrno(EPERM) ||
        virLastErrorIsSystemErrno(EACCES)) {
        virResetLastError();
        VIR_DEBUG("No cgroups present/configured/accessible, ignoring error");
        return true;
    }
    return false;
}

E
Eric Blake 已提交
1279

E
Eric Blake 已提交
1280 1281 1282 1283 1284 1285
/**
 * virCgroupFree:
 *
 * @group: The group structure to free
 */
void
1286
virCgroupFree(virCgroupPtr *group)
E
Eric Blake 已提交
1287 1288 1289
{
    size_t i;

1290
    if (*group == NULL)
E
Eric Blake 已提交
1291 1292 1293
        return;

    for (i = 0; i < VIR_CGROUP_CONTROLLER_LAST; i++) {
1294 1295 1296
        VIR_FREE((*group)->legacy[i].mountPoint);
        VIR_FREE((*group)->legacy[i].linkPoint);
        VIR_FREE((*group)->legacy[i].placement);
E
Eric Blake 已提交
1297 1298
    }

P
Pavel Hrdina 已提交
1299 1300 1301
    VIR_FREE((*group)->unified.mountPoint);
    VIR_FREE((*group)->unified.placement);

1302 1303
    VIR_FREE((*group)->path);
    VIR_FREE(*group);
E
Eric Blake 已提交
1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318
}


/**
 * virCgroupHasController: query whether a cgroup controller is present
 *
 * @cgroup: The group structure to be queried, or NULL
 * @controller: cgroup subsystem id
 *
 * Returns true if a cgroup controller is mounted and is associated
 * with this cgroup object.
 */
bool
virCgroupHasController(virCgroupPtr cgroup, int controller)
{
1319 1320
    size_t i;

E
Eric Blake 已提交
1321 1322 1323 1324
    if (!cgroup)
        return false;
    if (controller < 0 || controller >= VIR_CGROUP_CONTROLLER_LAST)
        return false;
1325

1326 1327 1328 1329 1330 1331 1332 1333
    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (cgroup->backends[i] &&
            cgroup->backends[i]->hasController(cgroup, controller)) {
            return true;
        }
    }

    return false;
E
Eric Blake 已提交
1334 1335 1336 1337 1338
}


int
virCgroupPathOfController(virCgroupPtr group,
1339
                          unsigned int controller,
E
Eric Blake 已提交
1340 1341 1342
                          const char *key,
                          char **path)
{
1343 1344 1345
    if (controller >= VIR_CGROUP_CONTROLLER_LAST) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Invalid controller id '%d'"), controller);
E
Eric Blake 已提交
1346 1347 1348
        return -1;
    }

1349 1350
    VIR_CGROUP_BACKEND_CALL(group, controller, pathOfController, -1,
                            controller, key, path);
E
Eric Blake 已提交
1351 1352 1353
}


1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370 1371
/**
 * virCgroupGetBlkioIoServiced:
 *
 * @group: The cgroup to get throughput for
 * @bytes_read: Pointer to returned bytes read
 * @bytes_write: Pointer to returned bytes written
 * @requests_read: Pointer to returned read io ops
 * @requests_write: Pointer to returned write io ops
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupGetBlkioIoServiced(virCgroupPtr group,
                            long long *bytes_read,
                            long long *bytes_write,
                            long long *requests_read,
                            long long *requests_write)
{
1372 1373
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            getBlkioIoServiced, -1,
1374 1375
                            bytes_read, bytes_write,
                            requests_read, requests_write);
1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398
}


/**
 * virCgroupGetBlkioIoDeviceServiced:
 *
 * @group: The cgroup to get throughput for
 * @path: The device to get throughput for
 * @bytes_read: Pointer to returned bytes read
 * @bytes_write: Pointer to returned bytes written
 * @requests_read: Pointer to returned read io ops
 * @requests_write: Pointer to returned write io ops
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupGetBlkioIoDeviceServiced(virCgroupPtr group,
                                  const char *path,
                                  long long *bytes_read,
                                  long long *bytes_write,
                                  long long *requests_read,
                                  long long *requests_write)
{
1399 1400
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            getBlkioIoDeviceServiced, -1,
1401 1402
                            path, bytes_read, bytes_write,
                            requests_read, requests_write);
1403 1404 1405
}


1406 1407 1408 1409 1410 1411
/**
 * virCgroupSetBlkioWeight:
 *
 * @group: The cgroup to change io weight for
 * @weight: The Weight for this cgroup
 *
1412
 * Returns: 0 on success, -1 on error
1413
 */
E
Eric Blake 已提交
1414 1415
int
virCgroupSetBlkioWeight(virCgroupPtr group, unsigned int weight)
1416
{
1417 1418
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            setBlkioWeight, -1, weight);
1419 1420
}

E
Eric Blake 已提交
1421

1422 1423 1424 1425 1426 1427
/**
 * virCgroupGetBlkioWeight:
 *
 * @group: The cgroup to get weight for
 * @Weight: Pointer to returned weight
 *
1428
 * Returns: 0 on success, -1 on error
1429
 */
E
Eric Blake 已提交
1430 1431
int
virCgroupGetBlkioWeight(virCgroupPtr group, unsigned int *weight)
1432
{
1433 1434
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            getBlkioWeight, -1, weight);
1435 1436
}

1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449
/**
 * virCgroupSetBlkioDeviceReadIops:
 * @group: The cgroup to change block io setting for
 * @path: The path of device
 * @riops: The new device read iops throttle, or 0 to clear
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupSetBlkioDeviceReadIops(virCgroupPtr group,
                                const char *path,
                                unsigned int riops)
{
1450 1451
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            setBlkioDeviceReadIops, -1, path, riops);
1452 1453
}

E
Eric Blake 已提交
1454

1455
/**
1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467
 * virCgroupSetBlkioDeviceWriteIops:
 * @group: The cgroup to change block io setting for
 * @path: The path of device
 * @wiops: The new device write iops throttle, or 0 to clear
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupSetBlkioDeviceWriteIops(virCgroupPtr group,
                                 const char *path,
                                 unsigned int wiops)
{
1468 1469
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            setBlkioDeviceWriteIops, -1, path, wiops);
1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485
}


/**
 * virCgroupSetBlkioDeviceReadBps:
 * @group: The cgroup to change block io setting for
 * @path: The path of device
 * @rbps: The new device read bps throttle, or 0 to clear
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupSetBlkioDeviceReadBps(virCgroupPtr group,
                               const char *path,
                               unsigned long long rbps)
{
1486 1487
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            setBlkioDeviceReadBps, -1, path, rbps);
1488 1489 1490 1491 1492 1493 1494
}

/**
 * virCgroupSetBlkioDeviceWriteBps:
 * @group: The cgroup to change block io setting for
 * @path: The path of device
 * @wbps: The new device write bps throttle, or 0 to clear
1495
 *
1496 1497 1498 1499 1500 1501 1502
 * Returns: 0 on success, -1 on error
 */
int
virCgroupSetBlkioDeviceWriteBps(virCgroupPtr group,
                                const char *path,
                                unsigned long long wbps)
{
1503 1504
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            setBlkioDeviceWriteBps, -1, path, wbps);
1505 1506 1507 1508 1509 1510 1511
}


/**
 * virCgroupSetBlkioDeviceWeight:
 * @group: The cgroup to change block io setting for
 * @path: The path of device
1512 1513
 * @weight: The new device weight (100-1000),
 * (10-1000) after kernel 2.6.39, or 0 to clear
1514
 *
1515
 * Returns: 0 on success, -1 on error
1516
 */
E
Eric Blake 已提交
1517 1518 1519 1520
int
virCgroupSetBlkioDeviceWeight(virCgroupPtr group,
                              const char *path,
                              unsigned int weight)
1521
{
1522 1523
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            setBlkioDeviceWeight, -1, path, weight);
1524
}
1525

1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538
/**
 * virCgroupGetBlkioDeviceReadIops:
 * @group: The cgroup to gather block io setting for
 * @path: The path of device
 * @riops: Returned device read iops throttle, 0 if there is none
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupGetBlkioDeviceReadIops(virCgroupPtr group,
                                const char *path,
                                unsigned int *riops)
{
1539 1540
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            getBlkioDeviceReadIops, -1, path, riops);
1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555
}

/**
 * virCgroupGetBlkioDeviceWriteIops:
 * @group: The cgroup to gather block io setting for
 * @path: The path of device
 * @wiops: Returned device write iops throttle, 0 if there is none
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupGetBlkioDeviceWriteIops(virCgroupPtr group,
                                 const char *path,
                                 unsigned int *wiops)
{
1556 1557
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            getBlkioDeviceWriteIops, -1, path, wiops);
1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572
}

/**
 * virCgroupGetBlkioDeviceReadBps:
 * @group: The cgroup to gather block io setting for
 * @path: The path of device
 * @rbps: Returned device read bps throttle, 0 if there is none
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupGetBlkioDeviceReadBps(virCgroupPtr group,
                               const char *path,
                               unsigned long long *rbps)
{
1573 1574
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            getBlkioDeviceReadBps, -1, path, rbps);
1575 1576 1577 1578 1579 1580 1581 1582 1583 1584 1585 1586 1587 1588 1589
}

/**
 * virCgroupGetBlkioDeviceWriteBps:
 * @group: The cgroup to gather block io setting for
 * @path: The path of device
 * @wbps: Returned device write bps throttle, 0 if there is none
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupGetBlkioDeviceWriteBps(virCgroupPtr group,
                                const char *path,
                                unsigned long long *wbps)
{
1590 1591
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            getBlkioDeviceWriteBps, -1, path, wbps);
1592 1593 1594 1595 1596 1597 1598 1599 1600 1601 1602 1603 1604 1605 1606
}

/**
 * virCgroupGetBlkioDeviceWeight:
 * @group: The cgroup to gather block io setting for
 * @path: The path of device
 * @weight: Returned device weight, 0 if there is none
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupGetBlkioDeviceWeight(virCgroupPtr group,
                              const char *path,
                              unsigned int *weight)
{
1607 1608
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_BLKIO,
                            getBlkioDeviceWeight, -1, path, weight);
1609 1610
}

1611

1612 1613 1614 1615 1616 1617 1618 1619
/**
 * virCgroupSetMemory:
 *
 * @group: The cgroup to change memory for
 * @kb: The memory amount in kilobytes
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1620 1621
int
virCgroupSetMemory(virCgroupPtr group, unsigned long long kb)
1622
{
1623 1624
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            setMemory, -1, kb);
1625 1626
}

E
Eric Blake 已提交
1627

1628 1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648 1649
/**
 * virCgroupGetMemoryStat:
 *
 * @group: The cgroup to change memory for
 * @cache: page cache memory in KiB
 * @activeAnon: anonymous and swap cache memory in KiB
 * @inactiveAnon: anonymous and swap cache memory in KiB
 * @activeFile: file-backed memory in KiB
 * @inactiveFile: file-backed memory in KiB
 * @unevictable: memory that cannot be reclaimed KiB
 *
 * Returns: 0 on success, -1 on error
 */
int
virCgroupGetMemoryStat(virCgroupPtr group,
                       unsigned long long *cache,
                       unsigned long long *activeAnon,
                       unsigned long long *inactiveAnon,
                       unsigned long long *activeFile,
                       unsigned long long *inactiveFile,
                       unsigned long long *unevictable)
{
1650 1651
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            getMemoryStat, -1, cache,
1652 1653 1654
                            activeAnon, inactiveAnon,
                            activeFile, inactiveFile,
                            unevictable);
1655 1656 1657
}


R
Ryota Ozaki 已提交
1658 1659 1660 1661 1662 1663 1664 1665
/**
 * virCgroupGetMemoryUsage:
 *
 * @group: The cgroup to change memory for
 * @kb: Pointer to returned used memory in kilobytes
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1666 1667
int
virCgroupGetMemoryUsage(virCgroupPtr group, unsigned long *kb)
R
Ryota Ozaki 已提交
1668
{
1669 1670
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            getMemoryUsage, -1, kb);
R
Ryota Ozaki 已提交
1671 1672
}

E
Eric Blake 已提交
1673

1674 1675 1676 1677 1678 1679 1680 1681
/**
 * virCgroupSetMemoryHardLimit:
 *
 * @group: The cgroup to change memory hard limit for
 * @kb: The memory amount in kilobytes
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1682 1683
int
virCgroupSetMemoryHardLimit(virCgroupPtr group, unsigned long long kb)
1684
{
1685 1686
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            setMemoryHardLimit, -1, kb);
1687 1688
}

E
Eric Blake 已提交
1689

1690 1691 1692 1693 1694 1695 1696 1697
/**
 * virCgroupGetMemoryHardLimit:
 *
 * @group: The cgroup to get the memory hard limit for
 * @kb: The memory amount in kilobytes
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1698 1699
int
virCgroupGetMemoryHardLimit(virCgroupPtr group, unsigned long long *kb)
1700
{
1701 1702
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            getMemoryHardLimit, -1, kb);
1703 1704
}

E
Eric Blake 已提交
1705

1706 1707 1708 1709 1710 1711 1712 1713
/**
 * virCgroupSetMemorySoftLimit:
 *
 * @group: The cgroup to change memory soft limit for
 * @kb: The memory amount in kilobytes
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1714 1715
int
virCgroupSetMemorySoftLimit(virCgroupPtr group, unsigned long long kb)
1716
{
1717 1718
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            setMemorySoftLimit, -1, kb);
1719 1720 1721 1722 1723 1724 1725 1726 1727 1728 1729
}


/**
 * virCgroupGetMemorySoftLimit:
 *
 * @group: The cgroup to get the memory soft limit for
 * @kb: The memory amount in kilobytes
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1730 1731
int
virCgroupGetMemorySoftLimit(virCgroupPtr group, unsigned long long *kb)
1732
{
1733 1734
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            getMemorySoftLimit, -1, kb);
1735 1736
}

E
Eric Blake 已提交
1737

1738
/**
1739
 * virCgroupSetMemSwapHardLimit:
1740
 *
1741 1742
 * @group: The cgroup to change mem+swap hard limit for
 * @kb: The mem+swap amount in kilobytes
1743 1744 1745
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1746 1747
int
virCgroupSetMemSwapHardLimit(virCgroupPtr group, unsigned long long kb)
1748
{
1749 1750
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            setMemSwapHardLimit, -1, kb);
1751 1752
}

E
Eric Blake 已提交
1753

1754
/**
1755
 * virCgroupGetMemSwapHardLimit:
1756
 *
1757 1758
 * @group: The cgroup to get mem+swap hard limit for
 * @kb: The mem+swap amount in kilobytes
1759 1760 1761
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1762 1763
int
virCgroupGetMemSwapHardLimit(virCgroupPtr group, unsigned long long *kb)
1764
{
1765 1766
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            getMemSwapHardLimit, -1, kb);
1767 1768
}

E
Eric Blake 已提交
1769

G
Gao feng 已提交
1770 1771 1772 1773 1774 1775 1776 1777
/**
 * virCgroupGetMemSwapUsage:
 *
 * @group: The cgroup to get mem+swap usage for
 * @kb: The mem+swap amount in kilobytes
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1778 1779
int
virCgroupGetMemSwapUsage(virCgroupPtr group, unsigned long long *kb)
G
Gao feng 已提交
1780
{
1781 1782
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_MEMORY,
                            getMemSwapUsage, -1, kb);
G
Gao feng 已提交
1783 1784
}

E
Eric Blake 已提交
1785

1786 1787 1788 1789 1790 1791 1792 1793
/**
 * virCgroupSetCpusetMems:
 *
 * @group: The cgroup to set cpuset.mems for
 * @mems: the numa nodes to set
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1794 1795
int
virCgroupSetCpusetMems(virCgroupPtr group, const char *mems)
1796
{
1797 1798
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPUSET,
                            setCpusetMems, -1, mems);
1799 1800
}

E
Eric Blake 已提交
1801

1802 1803 1804 1805 1806 1807 1808 1809
/**
 * virCgroupGetCpusetMems:
 *
 * @group: The cgroup to get cpuset.mems for
 * @mems: the numa nodes to get
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1810 1811
int
virCgroupGetCpusetMems(virCgroupPtr group, char **mems)
1812
{
1813 1814
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPUSET,
                            getCpusetMems, -1, mems);
1815 1816
}

E
Eric Blake 已提交
1817

1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828
/**
 * virCgroupSetCpusetMemoryMigrate:
 *
 * @group: The cgroup to set cpuset.memory_migrate for
 * @migrate: Whether to migrate the memory on change or not
 *
 * Returns: 0 on success
 */
int
virCgroupSetCpusetMemoryMigrate(virCgroupPtr group, bool migrate)
{
1829 1830
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPUSET,
                            setCpusetMemoryMigrate, -1, migrate);
1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844
}


/**
 * virCgroupGetCpusetMemoryMigrate:
 *
 * @group: The cgroup to get cpuset.memory_migrate for
 * @migrate: Migration setting
 *
 * Returns: 0 on success
 */
int
virCgroupGetCpusetMemoryMigrate(virCgroupPtr group, bool *migrate)
{
1845 1846
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPUSET,
                            getCpusetMemoryMigrate, -1, migrate);
1847 1848 1849
}


1850 1851 1852 1853 1854 1855
/**
 * virCgroupSetCpusetCpus:
 *
 * @group: The cgroup to set cpuset.cpus for
 * @cpus: the cpus to set
 *
N
Nitesh Konkar 已提交
1856
 * Returns: 0 on success
1857
 */
E
Eric Blake 已提交
1858 1859
int
virCgroupSetCpusetCpus(virCgroupPtr group, const char *cpus)
1860
{
1861 1862
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPUSET,
                            setCpusetCpus, -1, cpus);
1863 1864
}

E
Eric Blake 已提交
1865

1866 1867 1868 1869 1870 1871
/**
 * virCgroupGetCpusetCpus:
 *
 * @group: The cgroup to get cpuset.cpus for
 * @cpus: the cpus to get
 *
N
Nitesh Konkar 已提交
1872
 * Returns: 0 on success
1873
 */
E
Eric Blake 已提交
1874 1875
int
virCgroupGetCpusetCpus(virCgroupPtr group, char **cpus)
1876
{
1877 1878
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPUSET,
                            getCpusetCpus, -1, cpus);
1879 1880
}

E
Eric Blake 已提交
1881

1882 1883 1884
/**
 * virCgroupDenyAllDevices:
 *
1885
 * @group: The cgroup to deny all permissions, for all devices
1886 1887 1888
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1889 1890
int
virCgroupDenyAllDevices(virCgroupPtr group)
1891
{
1892 1893
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_DEVICES,
                            denyAllDevices, -1);
1894 1895
}

1896 1897 1898
/**
 * virCgroupAllowAllDevices:
 *
1899
 * Allows the permission for all devices by setting lines similar
1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912
 * to these ones (obviously the 'm' permission is an example):
 *
 * 'b *:* m'
 * 'c *:* m'
 *
 * @group: The cgroup to allow devices for
 * @perms: Bitwise or of VIR_CGROUP_DEVICE permission bits to allow
 *
 * Returns: 0 on success
 */
int
virCgroupAllowAllDevices(virCgroupPtr group, int perms)
{
1913 1914
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_DEVICES,
                            allowAllDevices, -1, perms);
1915 1916
}

E
Eric Blake 已提交
1917

1918 1919 1920 1921 1922
/**
 * virCgroupAllowDevice:
 *
 * @group: The cgroup to allow a device for
 * @type: The device type (i.e., 'c' or 'b')
1923 1924
 * @major: The major number of the device, a negative value means '*'
 * @minor: The minor number of the device, a negative value means '*'
1925
 * @perms: Bitwise or of VIR_CGROUP_DEVICE permission bits to allow
1926 1927 1928
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1929 1930 1931
int
virCgroupAllowDevice(virCgroupPtr group, char type, int major, int minor,
                     int perms)
1932
{
1933 1934
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_DEVICES,
                            allowDevice, -1, type, major, minor, perms);
1935
}
1936

E
Eric Blake 已提交
1937

1938 1939 1940 1941 1942
/**
 * virCgroupAllowDevicePath:
 *
 * @group: The cgroup to allow the device for
 * @path: the device to allow
1943
 * @perms: Bitwise or of VIR_CGROUP_DEVICE permission bits to allow
1944
 * @ignoreEacces: Ignore lack of permission (mostly for NFS mounts)
1945 1946 1947 1948
 *
 * Queries the type of device and its major/minor number, and
 * adds that to the cgroup ACL
 *
1949
 * Returns: 0 on success, 1 if path exists but is not a device or is not
1950
 * accessible, or * -1 on error
1951
 */
E
Eric Blake 已提交
1952
int
1953 1954 1955 1956
virCgroupAllowDevicePath(virCgroupPtr group,
                         const char *path,
                         int perms,
                         bool ignoreEacces)
1957 1958 1959
{
    struct stat sb;

1960
    if (stat(path, &sb) < 0) {
1961 1962 1963
        if (errno == EACCES && ignoreEacces)
            return 1;

1964 1965 1966 1967 1968
        virReportSystemError(errno,
                             _("Path '%s' is not accessible"),
                             path);
        return -1;
    }
1969 1970

    if (!S_ISCHR(sb.st_mode) && !S_ISBLK(sb.st_mode))
1971
        return 1;
1972

1973 1974
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_DEVICES,
                            allowDevice, -1,
1975 1976 1977 1978
                            S_ISCHR(sb.st_mode) ? 'c' : 'b',
                            major(sb.st_rdev),
                            minor(sb.st_rdev),
                            perms);
1979
}
D
Daniel P. Berrange 已提交
1980

1981 1982 1983 1984 1985 1986

/**
 * virCgroupDenyDevice:
 *
 * @group: The cgroup to deny a device for
 * @type: The device type (i.e., 'c' or 'b')
1987 1988
 * @major: The major number of the device, a negative value means '*'
 * @minor: The minor number of the device, a negative value means '*'
1989
 * @perms: Bitwise or of VIR_CGROUP_DEVICE permission bits to deny
1990 1991 1992
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
1993 1994 1995
int
virCgroupDenyDevice(virCgroupPtr group, char type, int major, int minor,
                    int perms)
1996
{
1997 1998
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_DEVICES,
                            denyDevice, -1, type, major, minor, perms);
1999 2000
}

E
Eric Blake 已提交
2001

2002 2003 2004 2005 2006 2007 2008 2009 2010 2011 2012 2013 2014 2015
/**
 * virCgroupDenyDevicePath:
 *
 * @group: The cgroup to deny the device for
 * @path: the device to deny
 * @perms: Bitwise or of VIR_CGROUP_DEVICE permission bits to allow
 * @ignoreEacces: Ignore lack of permission (mostly for NFS mounts)
 *
 * Queries the type of device and its major/minor number, and
 * removes it from the cgroup ACL
 *
 * Returns: 0 on success, 1 if path exists but is not a device or is not
 * accessible, or -1 on error.
 */
E
Eric Blake 已提交
2016
int
2017 2018 2019 2020
virCgroupDenyDevicePath(virCgroupPtr group,
                        const char *path,
                        int perms,
                        bool ignoreEacces)
2021 2022 2023
{
    struct stat sb;

2024
    if (stat(path, &sb) < 0) {
2025 2026 2027
        if (errno == EACCES && ignoreEacces)
            return 1;

2028 2029 2030 2031 2032
        virReportSystemError(errno,
                             _("Path '%s' is not accessible"),
                             path);
        return -1;
    }
2033 2034

    if (!S_ISCHR(sb.st_mode) && !S_ISBLK(sb.st_mode))
2035
        return 1;
2036

2037 2038
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_DEVICES,
                            denyDevice, -1,
2039 2040 2041 2042
                            S_ISCHR(sb.st_mode) ? 'c' : 'b',
                            major(sb.st_rdev),
                            minor(sb.st_rdev),
                            perms);
2043 2044
}

E
Eric Blake 已提交
2045

2046 2047 2048 2049 2050 2051 2052 2053 2054 2055 2056 2057 2058 2059 2060 2061
/* This function gets the sums of cpu time consumed by all vcpus.
 * For example, if there are 4 physical cpus, and 2 vcpus in a domain,
 * then for each vcpu, the cpuacct.usage_percpu looks like this:
 *   t0 t1 t2 t3
 * and we have 2 groups of such data:
 *   v\p   0   1   2   3
 *   0   t00 t01 t02 t03
 *   1   t10 t11 t12 t13
 * for each pcpu, the sum is cpu time consumed by all vcpus.
 *   s0 = t00 + t10
 *   s1 = t01 + t11
 *   s2 = t02 + t12
 *   s3 = t03 + t13
 */
static int
virCgroupGetPercpuVcpuSum(virCgroupPtr group,
2062
                          virBitmapPtr guestvcpus,
2063
                          unsigned long long *sum_cpu_time,
2064 2065
                          size_t nsum,
                          virBitmapPtr cpumap)
2066
{
2067
    int ret = -1;
2068
    ssize_t i = -1;
2069
    virCgroupPtr group_vcpu = NULL;
2070

2071
    while ((i = virBitmapNextSetBit(guestvcpus, i)) >= 0) {
2072
        VIR_AUTOFREE(char *) buf = NULL;
2073 2074
        char *pos;
        unsigned long long tmp;
2075
        ssize_t j;
2076

J
John Ferlan 已提交
2077 2078
        if (virCgroupNewThread(group, VIR_CGROUP_THREAD_VCPU, i,
                               false, &group_vcpu) < 0)
2079
            goto cleanup;
2080 2081

        if (virCgroupGetCpuacctPercpuUsage(group_vcpu, &buf) < 0)
2082
            goto cleanup;
2083 2084

        pos = buf;
2085 2086 2087
        for (j = virBitmapNextSetBit(cpumap, -1);
             j >= 0 && j < nsum;
             j = virBitmapNextSetBit(cpumap, j)) {
2088 2089 2090
            if (virStrToLong_ull(pos, &pos, 10, &tmp) < 0) {
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("cpuacct parse error"));
2091
                goto cleanup;
2092 2093 2094
            }
            sum_cpu_time[j] += tmp;
        }
2095

2096
        virCgroupFree(&group_vcpu);
2097 2098
    }

2099 2100
    ret = 0;
 cleanup:
2101
    virCgroupFree(&group_vcpu);
2102
    return ret;
2103 2104 2105
}


2106 2107 2108 2109 2110 2111 2112 2113 2114 2115 2116 2117 2118 2119 2120 2121 2122 2123 2124 2125
/**
 * virCgroupGetPercpuStats:
 * @cgroup: cgroup data structure
 * @params: typed parameter array where data is returned
 * @nparams: cardinality of @params
 * @start_cpu: offset of physical CPU to get data for
 * @ncpus: number of physical CPUs to get data for
 * @nvcpupids: number of vCPU threads for a domain (actual number of vcpus)
 *
 * This function is the worker that retrieves data in the appropriate format
 * for the terribly designed 'virDomainGetCPUStats' API. Sharing semantics with
 * the API, this function has two modes of operation depending on magic settings
 * of the input arguments. Please refer to docs of 'virDomainGetCPUStats' for
 * the usage patterns of the similarly named arguments.
 *
 * @nvcpupids determines the count of active vcpu threads for the vm. If the
 * threads could not be detected the percpu data is skipped.
 *
 * Please DON'T use this function anywhere else.
 */
2126 2127 2128 2129 2130
int
virCgroupGetPercpuStats(virCgroupPtr group,
                        virTypedParameterPtr params,
                        unsigned int nparams,
                        int start_cpu,
2131
                        unsigned int ncpus,
2132
                        virBitmapPtr guestvcpus)
2133
{
2134
    int ret = -1;
2135
    size_t i;
2136
    int need_cpus, total_cpus;
2137
    char *pos;
2138 2139
    VIR_AUTOFREE(char *) buf = NULL;
    VIR_AUTOFREE(unsigned long long *) sum_cpu_time = NULL;
2140 2141 2142
    virTypedParameterPtr ent;
    int param_idx;
    unsigned long long cpu_time;
2143
    virBitmapPtr cpumap = NULL;
2144 2145

    /* return the number of supported params */
2146
    if (nparams == 0 && ncpus != 0) {
2147
        if (!guestvcpus)
2148 2149 2150 2151
            return CGROUP_NB_PER_CPU_STAT_PARAM;
        else
            return CGROUP_NB_PER_CPU_STAT_PARAM + 1;
    }
2152 2153

    /* To parse account file, we need to know how many cpus are present.  */
2154
    if (!(cpumap = virHostCPUGetPresentBitmap()))
2155
        return -1;
2156

2157 2158
    total_cpus = virBitmapSize(cpumap);

2159
    /* return total number of cpus */
2160 2161 2162 2163
    if (ncpus == 0) {
        ret = total_cpus;
        goto cleanup;
    }
2164

2165
    if (start_cpu >= total_cpus) {
2166 2167
        virReportError(VIR_ERR_INVALID_ARG,
                       _("start_cpu %d larger than maximum of %d"),
2168
                       start_cpu, total_cpus - 1);
2169
        goto cleanup;
2170 2171 2172 2173
    }

    /* we get percpu cputime accounting info. */
    if (virCgroupGetCpuacctPercpuUsage(group, &buf))
2174
        goto cleanup;
2175 2176 2177 2178 2179 2180
    pos = buf;

    /* return percpu cputime in index 0 */
    param_idx = 0;

    /* number of cpus to compute */
J
Ján Tomko 已提交
2181
    need_cpus = MIN(total_cpus, start_cpu + ncpus);
2182

J
Ján Tomko 已提交
2183
    for (i = 0; i < need_cpus; i++) {
J
Ján Tomko 已提交
2184
        if (!virBitmapIsBitSet(cpumap, i)) {
2185 2186
            cpu_time = 0;
        } else if (virStrToLong_ull(pos, &pos, 10, &cpu_time) < 0) {
2187 2188
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("cpuacct parse error"));
2189
            goto cleanup;
2190 2191 2192 2193 2194 2195
        }
        if (i < start_cpu)
            continue;
        ent = &params[(i - start_cpu) * nparams + param_idx];
        if (virTypedParameterAssign(ent, VIR_DOMAIN_CPU_STATS_CPUTIME,
                                    VIR_TYPED_PARAM_ULLONG, cpu_time) < 0)
2196
            goto cleanup;
2197 2198
    }

2199
    /* return percpu vcputime in index 1 */
2200
    param_idx = 1;
2201

2202
    if (guestvcpus && param_idx < nparams) {
2203
        if (VIR_ALLOC_N(sum_cpu_time, need_cpus) < 0)
2204
            goto cleanup;
2205 2206
        if (virCgroupGetPercpuVcpuSum(group, guestvcpus, sum_cpu_time,
                                      need_cpus, cpumap) < 0)
2207
            goto cleanup;
2208 2209

        for (i = start_cpu; i < need_cpus; i++) {
2210 2211
            int idx = (i - start_cpu) * nparams + param_idx;
            if (virTypedParameterAssign(&params[idx],
2212 2213 2214
                                        VIR_DOMAIN_CPU_STATS_VCPUTIME,
                                        VIR_TYPED_PARAM_ULLONG,
                                        sum_cpu_time[i]) < 0)
2215
                goto cleanup;
2216 2217 2218
        }

        param_idx++;
2219 2220
    }

2221 2222 2223 2224 2225
    ret = param_idx;

 cleanup:
    virBitmapFree(cpumap);
    return ret;
2226 2227
}

2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 2255 2256 2257 2258 2259 2260 2261 2262 2263 2264 2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277

int
virCgroupGetDomainTotalCpuStats(virCgroupPtr group,
                                virTypedParameterPtr params,
                                int nparams)
{
    unsigned long long cpu_time;
    int ret;

    if (nparams == 0) /* return supported number of params */
        return CGROUP_NB_TOTAL_CPU_STAT_PARAM;
    /* entry 0 is cputime */
    ret = virCgroupGetCpuacctUsage(group, &cpu_time);
    if (ret < 0) {
        virReportSystemError(-ret, "%s", _("unable to get cpu account"));
        return -1;
    }

    if (virTypedParameterAssign(&params[0], VIR_DOMAIN_CPU_STATS_CPUTIME,
                                VIR_TYPED_PARAM_ULLONG, cpu_time) < 0)
        return -1;

    if (nparams > 1) {
        unsigned long long user;
        unsigned long long sys;

        ret = virCgroupGetCpuacctStat(group, &user, &sys);
        if (ret < 0) {
            virReportSystemError(-ret, "%s", _("unable to get cpu account"));
            return -1;
        }

        if (virTypedParameterAssign(&params[1],
                                    VIR_DOMAIN_CPU_STATS_USERTIME,
                                    VIR_TYPED_PARAM_ULLONG, user) < 0)
            return -1;
        if (nparams > 2 &&
            virTypedParameterAssign(&params[2],
                                    VIR_DOMAIN_CPU_STATS_SYSTEMTIME,
                                    VIR_TYPED_PARAM_ULLONG, sys) < 0)
            return -1;

        if (nparams > CGROUP_NB_TOTAL_CPU_STAT_PARAM)
            nparams = CGROUP_NB_TOTAL_CPU_STAT_PARAM;
    }

    return nparams;
}


E
Eric Blake 已提交
2278 2279
int
virCgroupSetCpuShares(virCgroupPtr group, unsigned long long shares)
2280
{
2281 2282
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPU,
                            setCpuShares, -1, shares);
2283 2284
}

E
Eric Blake 已提交
2285 2286 2287

int
virCgroupGetCpuShares(virCgroupPtr group, unsigned long long *shares)
2288
{
2289 2290
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPU,
                            getCpuShares, -1, shares);
2291
}
2292

E
Eric Blake 已提交
2293

2294 2295 2296 2297 2298 2299 2300 2301
/**
 * virCgroupSetCpuCfsPeriod:
 *
 * @group: The cgroup to change cpu.cfs_period_us for
 * @cfs_period: The bandwidth period in usecs
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
2302 2303
int
virCgroupSetCpuCfsPeriod(virCgroupPtr group, unsigned long long cfs_period)
2304
{
2305 2306
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPU,
                            setCpuCfsPeriod, -1, cfs_period);
2307 2308
}

E
Eric Blake 已提交
2309

2310 2311 2312 2313 2314 2315 2316 2317
/**
 * virCgroupGetCpuCfsPeriod:
 *
 * @group: The cgroup to get cpu.cfs_period_us for
 * @cfs_period: Pointer to the returned bandwidth period in usecs
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
2318 2319
int
virCgroupGetCpuCfsPeriod(virCgroupPtr group, unsigned long long *cfs_period)
2320
{
2321 2322
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPU,
                            getCpuCfsPeriod, -1, cfs_period);
2323 2324
}

E
Eric Blake 已提交
2325

2326 2327 2328 2329 2330 2331 2332 2333 2334
/**
 * virCgroupSetCpuCfsQuota:
 *
 * @group: The cgroup to change cpu.cfs_quota_us for
 * @cfs_quota: the cpu bandwidth (in usecs) that this tg will be allowed to
 *             consume over period
 *
 * Returns: 0 on success
 */
E
Eric Blake 已提交
2335 2336
int
virCgroupSetCpuCfsQuota(virCgroupPtr group, long long cfs_quota)
2337
{
2338 2339
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPU,
                            setCpuCfsQuota, -1, cfs_quota);
2340 2341
}

E
Eric Blake 已提交
2342 2343 2344

int
virCgroupGetCpuacctPercpuUsage(virCgroupPtr group, char **usage)
2345
{
2346 2347
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPUACCT,
                            getCpuacctPercpuUsage, -1, usage);
2348 2349
}

E
Eric Blake 已提交
2350

2351
int
E
Eric Blake 已提交
2352 2353 2354 2355 2356
virCgroupRemoveRecursively(char *grppath)
{
    DIR *grpdir;
    struct dirent *ent;
    int rc = 0;
E
Eric Blake 已提交
2357
    int direrr;
E
Eric Blake 已提交
2358

J
Ján Tomko 已提交
2359
    if (virDirOpenQuiet(&grpdir, grppath) < 0) {
E
Eric Blake 已提交
2360 2361 2362 2363 2364 2365 2366
        if (errno == ENOENT)
            return 0;
        rc = -errno;
        VIR_ERROR(_("Unable to open %s (%d)"), grppath, errno);
        return rc;
    }

E
Eric Blake 已提交
2367 2368 2369
    /* This is best-effort cleanup: we want to log failures with just
     * VIR_ERROR instead of normal virReportError */
    while ((direrr = virDirRead(grpdir, &ent, NULL)) > 0) {
2370
        VIR_AUTOFREE(char *) path = NULL;
E
Eric Blake 已提交
2371 2372 2373 2374 2375 2376 2377 2378 2379 2380 2381

        if (ent->d_type != DT_DIR) continue;

        if (virAsprintf(&path, "%s/%s", grppath, ent->d_name) == -1) {
            rc = -ENOMEM;
            break;
        }
        rc = virCgroupRemoveRecursively(path);
        if (rc != 0)
            break;
    }
E
Eric Blake 已提交
2382 2383 2384 2385 2386
    if (direrr < 0) {
        rc = -errno;
        VIR_ERROR(_("Failed to readdir for %s (%d)"), grppath, errno);
    }

J
Ján Tomko 已提交
2387
    VIR_DIR_CLOSE(grpdir);
E
Eric Blake 已提交
2388 2389 2390 2391 2392 2393 2394 2395 2396 2397 2398 2399 2400 2401 2402 2403 2404 2405 2406 2407 2408 2409 2410 2411 2412 2413

    VIR_DEBUG("Removing cgroup %s", grppath);
    if (rmdir(grppath) != 0 && errno != ENOENT) {
        rc = -errno;
        VIR_ERROR(_("Unable to remove %s (%d)"), grppath, errno);
    }

    return rc;
}


/**
 * virCgroupRemove:
 *
 * @group: The group to be removed
 *
 * It first removes all child groups recursively
 * in depth first order and then removes @group
 * because the presence of the child groups
 * prevents removing @group.
 *
 * Returns: 0 on success
 */
int
virCgroupRemove(virCgroupPtr group)
{
2414 2415 2416 2417 2418 2419 2420 2421 2422 2423
    size_t i;

    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (group->backends[i] &&
            group->backends[i]->remove(group) < 0) {
            return -1;
        }
    }

    return 0;
E
Eric Blake 已提交
2424 2425 2426
}


2427 2428 2429
/*
 * Returns 1 if some PIDs are killed, 0 if none are killed, or -1 on error
 */
E
Eric Blake 已提交
2430
static int
2431 2432 2433 2434 2435
virCgroupKillInternal(virCgroupPtr group,
                      int signum,
                      virHashTablePtr pids,
                      int controller,
                      const char *taskFile)
2436
{
2437
    int ret = -1;
2438
    bool killedAny = false;
2439
    VIR_AUTOFREE(char *) keypath = NULL;
2440
    bool done = false;
E
Eric Blake 已提交
2441 2442 2443
    FILE *fp = NULL;
    VIR_DEBUG("group=%p path=%s signum=%d pids=%p",
              group, group->path, signum, pids);
2444

2445
    if (virCgroupPathOfController(group, controller, taskFile, &keypath) < 0)
2446
        return -1;
2447 2448 2449 2450 2451 2452 2453

    /* PIDs may be forking as we kill them, so loop
     * until there are no new PIDs found
     */
    while (!done) {
        done = true;
        if (!(fp = fopen(keypath, "r"))) {
2454 2455 2456 2457 2458 2459
            if (errno == ENOENT) {
                VIR_DEBUG("No file %s, assuming done", keypath);
                killedAny = false;
                goto done;
            }

2460 2461 2462
            virReportSystemError(errno,
                                 _("Failed to read %s"),
                                 keypath);
2463 2464 2465
            goto cleanup;
        } else {
            while (!feof(fp)) {
M
Michal Privoznik 已提交
2466 2467
                long pid_value;
                if (fscanf(fp, "%ld", &pid_value) != 1) {
2468 2469
                    if (feof(fp))
                        break;
2470 2471 2472
                    virReportSystemError(errno,
                                         _("Failed to read %s"),
                                         keypath);
E
Eric Blake 已提交
2473
                    goto cleanup;
2474
                }
2475
                if (virHashLookup(pids, (void*)pid_value))
2476 2477
                    continue;

M
Michal Privoznik 已提交
2478
                VIR_DEBUG("pid=%ld", pid_value);
2479 2480
                /* Cgroups is a Linux concept, so this cast is safe.  */
                if (kill((pid_t)pid_value, signum) < 0) {
2481
                    if (errno != ESRCH) {
2482
                        virReportSystemError(errno,
M
Michal Privoznik 已提交
2483
                                             _("Failed to kill process %ld"),
2484
                                             pid_value);
2485 2486 2487 2488
                        goto cleanup;
                    }
                    /* Leave RC == 0 since we didn't kill one */
                } else {
2489
                    killedAny = true;
2490 2491 2492
                    done = false;
                }

2493
                ignore_value(virHashAddEntry(pids, (void*)pid_value, (void*)1));
2494 2495 2496 2497 2498
            }
            VIR_FORCE_FCLOSE(fp);
        }
    }

2499
 done:
2500
    ret = killedAny ? 1 : 0;
2501

2502
 cleanup:
E
Eric Blake 已提交
2503
    VIR_FORCE_FCLOSE(fp);
2504

2505
    return ret;
2506 2507 2508
}


E
Eric Blake 已提交
2509 2510
static uint32_t
virCgroupPidCode(const void *name, uint32_t seed)
2511
{
M
Michal Privoznik 已提交
2512
    long pid_value = (long)(intptr_t)name;
2513
    return virHashCodeGen(&pid_value, sizeof(pid_value), seed);
2514
}
E
Eric Blake 已提交
2515 2516 2517 2518


static bool
virCgroupPidEqual(const void *namea, const void *nameb)
2519 2520 2521
{
    return namea == nameb;
}
E
Eric Blake 已提交
2522 2523 2524 2525


static void *
virCgroupPidCopy(const void *name)
2526 2527 2528 2529
{
    return (void*)name;
}

E
Eric Blake 已提交
2530

2531
int
E
Eric Blake 已提交
2532 2533 2534
virCgroupKillRecursiveInternal(virCgroupPtr group,
                               int signum,
                               virHashTablePtr pids,
2535 2536
                               int controller,
                               const char *taskFile,
E
Eric Blake 已提交
2537
                               bool dormdir)
2538
{
2539
    int ret = -1;
2540
    int rc;
2541
    bool killedAny = false;
2542
    VIR_AUTOFREE(char *) keypath = NULL;
2543
    DIR *dp = NULL;
2544
    virCgroupPtr subgroup = NULL;
2545
    struct dirent *ent;
E
Eric Blake 已提交
2546
    int direrr;
E
Eric Blake 已提交
2547 2548
    VIR_DEBUG("group=%p path=%s signum=%d pids=%p",
              group, group->path, signum, pids);
2549

2550
    if (virCgroupPathOfController(group, controller, "", &keypath) < 0)
2551
        return -1;
2552

2553 2554
    if ((rc = virCgroupKillInternal(group, signum, pids,
                                    controller, taskFile)) < 0) {
2555
        goto cleanup;
2556
    }
2557 2558
    if (rc == 1)
        killedAny = true;
2559

2560
    VIR_DEBUG("Iterate over children of %s (killedAny=%d)", keypath, killedAny);
J
Ján Tomko 已提交
2561
    if ((rc = virDirOpenIfExists(&dp, keypath)) < 0)
2562
        goto cleanup;
J
Ján Tomko 已提交
2563 2564 2565 2566 2567

    if (rc == 0) {
        VIR_DEBUG("Path %s does not exist, assuming done", keypath);
        killedAny = false;
        goto done;
2568 2569
    }

E
Eric Blake 已提交
2570
    while ((direrr = virDirRead(dp, &ent, keypath)) > 0) {
2571 2572 2573 2574 2575
        if (ent->d_type != DT_DIR)
            continue;

        VIR_DEBUG("Process subdir %s", ent->d_name);

2576
        if (virCgroupNew(-1, ent->d_name, group, -1, &subgroup) < 0)
2577 2578
            goto cleanup;

E
Eric Blake 已提交
2579
        if ((rc = virCgroupKillRecursiveInternal(subgroup, signum, pids,
2580
                                                 controller, taskFile, true)) < 0)
2581 2582
            goto cleanup;
        if (rc == 1)
2583
            killedAny = true;
2584 2585 2586

        if (dormdir)
            virCgroupRemove(subgroup);
2587

2588
        virCgroupFree(&subgroup);
2589
    }
E
Eric Blake 已提交
2590 2591
    if (direrr < 0)
        goto cleanup;
2592

2593
 done:
2594
    ret = killedAny ? 1 : 0;
2595

2596
 cleanup:
2597
    virCgroupFree(&subgroup);
J
Ján Tomko 已提交
2598
    VIR_DIR_CLOSE(dp);
2599
    return ret;
2600 2601
}

E
Eric Blake 已提交
2602 2603 2604

int
virCgroupKillRecursive(virCgroupPtr group, int signum)
2605
{
2606 2607 2608 2609
    int ret = 0;
    int rc;
    size_t i;
    virCgroupBackendPtr *backends = virCgroupBackendGetAll();
2610 2611 2612 2613 2614 2615
    virHashTablePtr pids = virHashCreateFull(100,
                                             NULL,
                                             virCgroupPidCode,
                                             virCgroupPidEqual,
                                             virCgroupPidCopy,
                                             NULL);
2616

2617
    VIR_DEBUG("group=%p path=%s signum=%d", group, group->path, signum);
2618

2619 2620 2621 2622
    if (!backends) {
        ret = -1;
        goto cleanup;
    }
2623

2624 2625 2626 2627 2628 2629 2630 2631 2632 2633 2634 2635 2636 2637
    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (backends[i]) {
            rc = backends[i]->killRecursive(group, signum, pids);
            if (rc < 0) {
                ret = -1;
                goto cleanup;
            }
            if (rc > 0)
                ret = rc;
        }
    }

 cleanup:
    virHashFree(pids);
2638
    return ret;
2639 2640 2641
}


E
Eric Blake 已提交
2642 2643
int
virCgroupKillPainfully(virCgroupPtr group)
2644
{
2645
    size_t i;
2646
    int ret;
2647
    VIR_DEBUG("cgroup=%p path=%s", group, group->path);
2648
    for (i = 0; i < 15; i++) {
2649 2650 2651 2652 2653 2654
        int signum;
        if (i == 0)
            signum = SIGTERM;
        else if (i == 8)
            signum = SIGKILL;
        else
J
Ján Tomko 已提交
2655
            signum = 0; /* Just check for existence */
2656

2657 2658 2659 2660
        ret = virCgroupKillRecursive(group, signum);
        VIR_DEBUG("Iteration %zu rc=%d", i, ret);
        /* If ret == -1 we hit error, if 0 we ran out of PIDs */
        if (ret <= 0)
2661 2662 2663 2664
            break;

        usleep(200 * 1000);
    }
2665 2666
    VIR_DEBUG("Complete %d", ret);
    return ret;
2667
}
2668

E
Eric Blake 已提交
2669

2670 2671 2672 2673 2674 2675 2676 2677 2678 2679 2680 2681
/**
 * virCgroupGetCpuCfsQuota:
 *
 * @group: The cgroup to get cpu.cfs_quota_us for
 * @cfs_quota: Pointer to the returned cpu bandwidth (in usecs) that this tg
 *             will be allowed to consume over period
 *
 * Returns: 0 on success
 */
int
virCgroupGetCpuCfsQuota(virCgroupPtr group, long long *cfs_quota)
{
2682 2683
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPU,
                            getCpuCfsQuota, -1, cfs_quota);
2684 2685 2686 2687 2688 2689
}


int
virCgroupGetCpuacctUsage(virCgroupPtr group, unsigned long long *usage)
{
2690 2691
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPUACCT,
                            getCpuacctUsage, -1, usage);
2692 2693 2694 2695 2696 2697 2698
}


int
virCgroupGetCpuacctStat(virCgroupPtr group, unsigned long long *user,
                        unsigned long long *sys)
{
2699 2700
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_CPUACCT,
                            getCpuacctStat, -1, user, sys);
2701 2702 2703 2704 2705 2706
}


int
virCgroupSetFreezerState(virCgroupPtr group, const char *state)
{
2707 2708
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_FREEZER,
                            setFreezerState, -1, state);
2709 2710 2711 2712 2713 2714
}


int
virCgroupGetFreezerState(virCgroupPtr group, char **state)
{
2715 2716
    VIR_CGROUP_BACKEND_CALL(group, VIR_CGROUP_CONTROLLER_FREEZER,
                            getFreezerState, -1, state);
2717 2718 2719
}


E
Eric Blake 已提交
2720
int
2721 2722
virCgroupBindMount(virCgroupPtr group, const char *oldroot,
                   const char *mountopts)
2723
{
2724 2725 2726 2727 2728 2729 2730 2731 2732 2733
    size_t i;

    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (group->backends[i] &&
            group->backends[i]->bindMount(group, oldroot, mountopts) < 0) {
            return -1;
        }
    }

    return 0;
2734
}
2735 2736


2737 2738 2739 2740 2741
int virCgroupSetOwner(virCgroupPtr cgroup,
                      uid_t uid,
                      gid_t gid,
                      int controllers)
{
2742 2743 2744 2745 2746 2747 2748 2749 2750 2751
    size_t i;

    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (cgroup->backends[i] &&
            cgroup->backends[i]->setOwner(cgroup, uid, gid, controllers) < 0) {
            return -1;
        }
    }

    return 0;
2752 2753 2754
}


2755 2756 2757 2758 2759 2760 2761 2762 2763 2764
/**
 * virCgroupSupportsCpuBW():
 * Check whether the host supports CFS bandwidth.
 *
 * Return true when CFS bandwidth is supported,
 * false when CFS bandwidth is not supported.
 */
bool
virCgroupSupportsCpuBW(virCgroupPtr cgroup)
{
2765 2766
    VIR_CGROUP_BACKEND_CALL(cgroup, VIR_CGROUP_CONTROLLER_CPU,
                            supportsCpuBW, false);
2767 2768
}

2769 2770 2771
int
virCgroupHasEmptyTasks(virCgroupPtr cgroup, int controller)
{
2772 2773 2774 2775 2776 2777 2778 2779 2780 2781 2782
    size_t i;

    for (i = 0; i < VIR_CGROUP_BACKEND_TYPE_LAST; i++) {
        if (cgroup->backends[i]) {
            int rc = cgroup->backends[i]->hasEmptyTasks(cgroup, controller);
            if (rc <= 0)
                return rc;
        }
    }

    return 1;
2783
}
2784

2785 2786 2787
bool
virCgroupControllerAvailable(int controller)
{
2788 2789
    virCgroupPtr cgroup;
    bool ret = false;
2790 2791

    if (virCgroupNewSelf(&cgroup) < 0)
2792
        return ret;
2793

2794
    ret = virCgroupHasController(cgroup, controller);
2795
    virCgroupFree(&cgroup);
2796
    return ret;
2797 2798
}

2799
#else /* !__linux__ */
2800

2801 2802 2803 2804 2805 2806 2807
bool
virCgroupAvailable(void)
{
    return false;
}


2808 2809 2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820 2821 2822 2823 2824 2825 2826 2827 2828 2829 2830 2831 2832 2833 2834 2835 2836 2837 2838 2839 2840 2841
int
virCgroupNewPartition(const char *path ATTRIBUTE_UNUSED,
                      bool create ATTRIBUTE_UNUSED,
                      int controllers ATTRIBUTE_UNUSED,
                      virCgroupPtr *group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupNewSelf(virCgroupPtr *group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupNewDomainPartition(virCgroupPtr partition ATTRIBUTE_UNUSED,
                            const char *driver ATTRIBUTE_UNUSED,
                            const char *name ATTRIBUTE_UNUSED,
                            bool create ATTRIBUTE_UNUSED,
                            virCgroupPtr *group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


2842 2843 2844 2845 2846 2847 2848 2849 2850 2851 2852 2853 2854
int
virCgroupNewThread(virCgroupPtr domain ATTRIBUTE_UNUSED,
                   virCgroupThreadName nameval ATTRIBUTE_UNUSED,
                   int id ATTRIBUTE_UNUSED,
                   bool create ATTRIBUTE_UNUSED,
                   virCgroupPtr *group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


2855 2856 2857 2858 2859 2860 2861 2862 2863 2864 2865
int
virCgroupNewDetect(pid_t pid ATTRIBUTE_UNUSED,
                   int controllers ATTRIBUTE_UNUSED,
                   virCgroupPtr *group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


2866 2867 2868 2869 2870
int
virCgroupNewDetectMachine(const char *name ATTRIBUTE_UNUSED,
                          const char *drivername ATTRIBUTE_UNUSED,
                          pid_t pid ATTRIBUTE_UNUSED,
                          int controllers ATTRIBUTE_UNUSED,
2871
                          char *machinename ATTRIBUTE_UNUSED,
2872 2873 2874 2875 2876 2877 2878
                          virCgroupPtr *group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

J
Ján Tomko 已提交
2879

2880
int virCgroupTerminateMachine(const char *name ATTRIBUTE_UNUSED)
J
Ján Tomko 已提交
2881 2882 2883 2884 2885 2886 2887
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


2888 2889 2890 2891 2892 2893 2894
int
virCgroupNewMachine(const char *name ATTRIBUTE_UNUSED,
                    const char *drivername ATTRIBUTE_UNUSED,
                    const unsigned char *uuid ATTRIBUTE_UNUSED,
                    const char *rootdir ATTRIBUTE_UNUSED,
                    pid_t pidleader ATTRIBUTE_UNUSED,
                    bool isContainer ATTRIBUTE_UNUSED,
2895 2896
                    size_t nnicindexes ATTRIBUTE_UNUSED,
                    int *nicindexes ATTRIBUTE_UNUSED,
2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909 2910 2911 2912 2913
                    const char *partition ATTRIBUTE_UNUSED,
                    int controllers ATTRIBUTE_UNUSED,
                    virCgroupPtr *group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


bool
virCgroupNewIgnoreError(void)
{
    VIR_DEBUG("No cgroups present/configured/accessible, ignoring error");
    return true;
}

2914 2915

void
2916
virCgroupFree(virCgroupPtr *group ATTRIBUTE_UNUSED)
2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928 2929 2930
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
}


bool
virCgroupHasController(virCgroupPtr cgroup ATTRIBUTE_UNUSED,
                       int controller ATTRIBUTE_UNUSED)
{
    return false;
}


2931 2932
int
virCgroupPathOfController(virCgroupPtr group ATTRIBUTE_UNUSED,
2933
                          unsigned int controller ATTRIBUTE_UNUSED,
2934 2935 2936 2937 2938 2939 2940 2941 2942
                          const char *key ATTRIBUTE_UNUSED,
                          char **path ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


2943
int
2944 2945
virCgroupAddProcess(virCgroupPtr group ATTRIBUTE_UNUSED,
                    pid_t pid ATTRIBUTE_UNUSED)
2946 2947 2948 2949 2950 2951 2952
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


2953
int
2954 2955
virCgroupAddMachineProcess(virCgroupPtr group ATTRIBUTE_UNUSED,
                           pid_t pid ATTRIBUTE_UNUSED)
2956 2957 2958 2959 2960 2961 2962
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


2963 2964 2965 2966 2967 2968 2969 2970 2971 2972
int
virCgroupAddThread(virCgroupPtr group ATTRIBUTE_UNUSED,
                   pid_t pid ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


2973 2974 2975 2976 2977 2978 2979 2980 2981 2982 2983 2984 2985 2986 2987 2988 2989 2990 2991 2992 2993 2994 2995 2996 2997 2998 2999
int
virCgroupGetBlkioIoServiced(virCgroupPtr group ATTRIBUTE_UNUSED,
                            long long *bytes_read ATTRIBUTE_UNUSED,
                            long long *bytes_write ATTRIBUTE_UNUSED,
                            long long *requests_read ATTRIBUTE_UNUSED,
                            long long *requests_write ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetBlkioIoDeviceServiced(virCgroupPtr group ATTRIBUTE_UNUSED,
                                  const char *path ATTRIBUTE_UNUSED,
                                  long long *bytes_read ATTRIBUTE_UNUSED,
                                  long long *bytes_write ATTRIBUTE_UNUSED,
                                  long long *requests_read ATTRIBUTE_UNUSED,
                                  long long *requests_write ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3000 3001 3002 3003 3004 3005 3006 3007 3008 3009 3010 3011 3012 3013 3014 3015 3016 3017 3018 3019
int
virCgroupSetBlkioWeight(virCgroupPtr group ATTRIBUTE_UNUSED,
                        unsigned int weight ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetBlkioWeight(virCgroupPtr group ATTRIBUTE_UNUSED,
                        unsigned int *weight ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3020 3021 3022 3023 3024 3025 3026 3027 3028 3029
int
virCgroupSetBlkioDeviceWeight(virCgroupPtr group ATTRIBUTE_UNUSED,
                              const char *path ATTRIBUTE_UNUSED,
                              unsigned int weight ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

3030 3031 3032 3033 3034 3035 3036 3037 3038 3039 3040 3041 3042 3043 3044 3045 3046 3047 3048 3049 3050 3051 3052 3053 3054 3055 3056 3057 3058 3059 3060 3061 3062 3063 3064 3065 3066 3067 3068 3069
int
virCgroupSetBlkioDeviceReadIops(virCgroupPtr group ATTRIBUTE_UNUSED,
                                const char *path ATTRIBUTE_UNUSED,
                                unsigned int riops ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

int
virCgroupSetBlkioDeviceWriteIops(virCgroupPtr group ATTRIBUTE_UNUSED,
                                 const char *path ATTRIBUTE_UNUSED,
                                 unsigned int wiops ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

int
virCgroupSetBlkioDeviceReadBps(virCgroupPtr group ATTRIBUTE_UNUSED,
                               const char *path ATTRIBUTE_UNUSED,
                               unsigned long long rbps ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

int
virCgroupSetBlkioDeviceWriteBps(virCgroupPtr group ATTRIBUTE_UNUSED,
                                const char *path ATTRIBUTE_UNUSED,
                                unsigned long long wbps ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

3070 3071 3072
int
virCgroupGetBlkioDeviceWeight(virCgroupPtr group ATTRIBUTE_UNUSED,
                              const char *path ATTRIBUTE_UNUSED,
3073
                              unsigned int *weight ATTRIBUTE_UNUSED)
3074 3075 3076 3077 3078 3079 3080 3081 3082
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

int
virCgroupGetBlkioDeviceReadIops(virCgroupPtr group ATTRIBUTE_UNUSED,
                                const char *path ATTRIBUTE_UNUSED,
3083
                                unsigned int *riops ATTRIBUTE_UNUSED)
3084 3085 3086 3087 3088 3089 3090 3091 3092
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

int
virCgroupGetBlkioDeviceWriteIops(virCgroupPtr group ATTRIBUTE_UNUSED,
                                 const char *path ATTRIBUTE_UNUSED,
3093
                                 unsigned int *wiops ATTRIBUTE_UNUSED)
3094 3095 3096 3097 3098 3099 3100 3101 3102
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

int
virCgroupGetBlkioDeviceReadBps(virCgroupPtr group ATTRIBUTE_UNUSED,
                               const char *path ATTRIBUTE_UNUSED,
3103
                               unsigned long long *rbps ATTRIBUTE_UNUSED)
3104 3105 3106 3107 3108 3109 3110 3111 3112
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

int
virCgroupGetBlkioDeviceWriteBps(virCgroupPtr group ATTRIBUTE_UNUSED,
                                const char *path ATTRIBUTE_UNUSED,
3113
                                unsigned long long *wbps ATTRIBUTE_UNUSED)
3114 3115 3116 3117 3118
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}
3119

3120 3121 3122 3123 3124 3125 3126 3127 3128 3129
int
virCgroupSetMemory(virCgroupPtr group ATTRIBUTE_UNUSED,
                   unsigned long long kb ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


P
Pavel Hrdina 已提交
3130 3131 3132 3133 3134 3135 3136 3137 3138 3139 3140 3141 3142 3143 3144
int
virCgroupGetMemoryStat(virCgroupPtr group ATTRIBUTE_UNUSED,
                       unsigned long long *cache ATTRIBUTE_UNUSED,
                       unsigned long long *activeAnon ATTRIBUTE_UNUSED,
                       unsigned long long *inactiveAnon ATTRIBUTE_UNUSED,
                       unsigned long long *activeFile ATTRIBUTE_UNUSED,
                       unsigned long long *inactiveFile ATTRIBUTE_UNUSED,
                       unsigned long long *unevictable ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3145 3146 3147 3148 3149 3150 3151 3152 3153 3154 3155 3156 3157 3158 3159 3160 3161 3162 3163 3164 3165 3166 3167 3168 3169 3170 3171 3172 3173 3174 3175 3176 3177 3178 3179 3180 3181 3182 3183 3184 3185 3186 3187 3188 3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199 3200 3201 3202 3203 3204 3205 3206 3207 3208 3209 3210 3211 3212 3213 3214 3215 3216 3217 3218 3219 3220 3221 3222 3223 3224 3225 3226 3227 3228 3229 3230 3231 3232 3233 3234 3235 3236 3237 3238 3239 3240 3241 3242 3243
int
virCgroupGetMemoryUsage(virCgroupPtr group ATTRIBUTE_UNUSED,
                        unsigned long *kb ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupSetMemoryHardLimit(virCgroupPtr group ATTRIBUTE_UNUSED,
                            unsigned long long kb ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetMemoryHardLimit(virCgroupPtr group ATTRIBUTE_UNUSED,
                            unsigned long long *kb ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupSetMemorySoftLimit(virCgroupPtr group ATTRIBUTE_UNUSED,
                            unsigned long long kb ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetMemorySoftLimit(virCgroupPtr group ATTRIBUTE_UNUSED,
                            unsigned long long *kb ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupSetMemSwapHardLimit(virCgroupPtr group ATTRIBUTE_UNUSED,
                             unsigned long long kb ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetMemSwapHardLimit(virCgroupPtr group ATTRIBUTE_UNUSED,
                             unsigned long long *kb ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetMemSwapUsage(virCgroupPtr group ATTRIBUTE_UNUSED,
                         unsigned long long *kb ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupSetCpusetMems(virCgroupPtr group ATTRIBUTE_UNUSED,
                       const char *mems ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetCpusetMems(virCgroupPtr group ATTRIBUTE_UNUSED,
                       char **mems ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

3244 3245 3246 3247 3248 3249 3250 3251 3252 3253 3254 3255 3256 3257 3258 3259 3260 3261 3262 3263

int
virCgroupSetCpusetMemoryMigrate(virCgroupPtr group ATTRIBUTE_UNUSED,
                                bool migrate ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetCpusetMemoryMigrate(virCgroupPtr group ATTRIBUTE_UNUSED,
                                bool *migrate ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

3264 3265 3266 3267 3268 3269 3270 3271 3272 3273 3274 3275 3276 3277 3278 3279 3280 3281 3282 3283

int
virCgroupSetCpusetCpus(virCgroupPtr group ATTRIBUTE_UNUSED,
                       const char *cpus ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetCpusetCpus(virCgroupPtr group ATTRIBUTE_UNUSED,
                       char **cpus ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

3284 3285 3286 3287 3288 3289 3290 3291
int
virCgroupAllowAllDevices(virCgroupPtr group ATTRIBUTE_UNUSED,
                         int perms ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}
3292 3293 3294 3295 3296 3297 3298 3299 3300 3301 3302 3303 3304 3305 3306 3307 3308 3309 3310 3311 3312 3313 3314

int
virCgroupDenyAllDevices(virCgroupPtr group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupAllowDevice(virCgroupPtr group ATTRIBUTE_UNUSED,
                     char type ATTRIBUTE_UNUSED,
                     int major ATTRIBUTE_UNUSED,
                     int minor ATTRIBUTE_UNUSED,
                     int perms ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3315 3316 3317
int
virCgroupAllowDevicePath(virCgroupPtr group ATTRIBUTE_UNUSED,
                         const char *path ATTRIBUTE_UNUSED,
3318 3319
                         int perms ATTRIBUTE_UNUSED,
                         bool ignoreEaccess ATTRIBUTE_UNUSED)
3320 3321 3322 3323 3324 3325 3326
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3327 3328 3329 3330 3331 3332 3333 3334 3335 3336 3337 3338 3339
int
virCgroupDenyDevice(virCgroupPtr group ATTRIBUTE_UNUSED,
                    char type ATTRIBUTE_UNUSED,
                    int major ATTRIBUTE_UNUSED,
                    int minor ATTRIBUTE_UNUSED,
                    int perms ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3340 3341 3342
int
virCgroupDenyDevicePath(virCgroupPtr group ATTRIBUTE_UNUSED,
                        const char *path ATTRIBUTE_UNUSED,
3343 3344
                        int perms ATTRIBUTE_UNUSED,
                        bool ignoreEacces ATTRIBUTE_UNUSED)
3345 3346 3347 3348 3349 3350 3351
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3352 3353 3354 3355 3356 3357 3358 3359 3360 3361 3362 3363 3364 3365 3366 3367 3368 3369 3370 3371 3372 3373 3374 3375 3376 3377 3378 3379 3380 3381 3382 3383 3384 3385 3386 3387 3388 3389 3390 3391 3392 3393 3394 3395 3396 3397 3398 3399 3400 3401 3402 3403 3404 3405 3406 3407 3408 3409 3410
int
virCgroupSetCpuShares(virCgroupPtr group ATTRIBUTE_UNUSED,
                      unsigned long long shares ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetCpuShares(virCgroupPtr group ATTRIBUTE_UNUSED,
                      unsigned long long *shares ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupSetCpuCfsPeriod(virCgroupPtr group ATTRIBUTE_UNUSED,
                         unsigned long long cfs_period ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetCpuCfsPeriod(virCgroupPtr group ATTRIBUTE_UNUSED,
                         unsigned long long *cfs_period ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupSetCpuCfsQuota(virCgroupPtr group ATTRIBUTE_UNUSED,
                        long long cfs_quota ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupRemove(virCgroupPtr group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENXIO, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3411 3412 3413 3414 3415 3416 3417 3418 3419 3420 3421 3422 3423 3424 3425 3426 3427 3428 3429
int
virCgroupKillRecursive(virCgroupPtr group ATTRIBUTE_UNUSED,
                       int signum ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupKillPainfully(virCgroupPtr group ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3430 3431 3432 3433 3434 3435 3436 3437 3438 3439 3440 3441 3442 3443 3444 3445 3446 3447 3448 3449 3450 3451 3452 3453 3454 3455 3456 3457 3458 3459 3460 3461 3462 3463 3464 3465 3466 3467 3468 3469 3470
int
virCgroupGetCpuCfsQuota(virCgroupPtr group ATTRIBUTE_UNUSED,
                        long long *cfs_quota ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetCpuacctUsage(virCgroupPtr group ATTRIBUTE_UNUSED,
                         unsigned long long *usage ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetCpuacctPercpuUsage(virCgroupPtr group ATTRIBUTE_UNUSED,
                               char **usage ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetCpuacctStat(virCgroupPtr group ATTRIBUTE_UNUSED,
                        unsigned long long *user ATTRIBUTE_UNUSED,
                        unsigned long long *sys ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3471 3472 3473 3474 3475 3476 3477 3478 3479 3480 3481
int
virCgroupGetDomainTotalCpuStats(virCgroupPtr group ATTRIBUTE_UNUSED,
                                virTypedParameterPtr params ATTRIBUTE_UNUSED,
                                int nparams ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


3482 3483 3484 3485 3486 3487 3488 3489 3490 3491 3492 3493 3494 3495 3496 3497 3498 3499 3500 3501
int
virCgroupSetFreezerState(virCgroupPtr group ATTRIBUTE_UNUSED,
                         const char *state ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupGetFreezerState(virCgroupPtr group ATTRIBUTE_UNUSED,
                         char **state ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


E
Eric Blake 已提交
3502
int
3503 3504 3505
virCgroupBindMount(virCgroupPtr group ATTRIBUTE_UNUSED,
                   const char *oldroot ATTRIBUTE_UNUSED,
                   const char *mountopts ATTRIBUTE_UNUSED)
3506
{
3507 3508 3509
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
3510
}
3511

3512 3513 3514 3515 3516 3517 3518 3519

bool
virCgroupSupportsCpuBW(virCgroupPtr cgroup ATTRIBUTE_UNUSED)
{
    VIR_DEBUG("Control groups not supported on this platform");
    return false;
}

E
Eric Blake 已提交
3520 3521 3522 3523 3524 3525

int
virCgroupGetPercpuStats(virCgroupPtr group ATTRIBUTE_UNUSED,
                        virTypedParameterPtr params ATTRIBUTE_UNUSED,
                        unsigned int nparams ATTRIBUTE_UNUSED,
                        int start_cpu ATTRIBUTE_UNUSED,
J
Ján Tomko 已提交
3526
                        unsigned int ncpus ATTRIBUTE_UNUSED,
3527
                        virBitmapPtr guestvcpus ATTRIBUTE_UNUSED)
E
Eric Blake 已提交
3528 3529 3530 3531 3532 3533 3534 3535 3536 3537 3538 3539 3540 3541 3542 3543 3544 3545
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}


int
virCgroupSetOwner(virCgroupPtr cgroup ATTRIBUTE_UNUSED,
                  uid_t uid ATTRIBUTE_UNUSED,
                  gid_t gid ATTRIBUTE_UNUSED,
                  int controllers ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

3546 3547 3548 3549 3550 3551 3552 3553 3554
int
virCgroupHasEmptyTasks(virCgroupPtr cgroup ATTRIBUTE_UNUSED,
                       int controller ATTRIBUTE_UNUSED)
{
    virReportSystemError(ENOSYS, "%s",
                         _("Control groups not supported on this platform"));
    return -1;
}

3555 3556 3557 3558 3559
bool
virCgroupControllerAvailable(int controller ATTRIBUTE_UNUSED)
{
    return false;
}
3560
#endif /* !__linux__ */
3561 3562 3563 3564 3565 3566 3567


int
virCgroupDelThread(virCgroupPtr cgroup,
                   virCgroupThreadName nameval,
                   int idx)
{
3568
    virCgroupPtr new_cgroup = NULL;
3569 3570 3571 3572 3573 3574 3575

    if (cgroup) {
        if (virCgroupNewThread(cgroup, nameval, idx, false, &new_cgroup) < 0)
            return -1;

        /* Remove the offlined cgroup */
        virCgroupRemove(new_cgroup);
3576
        virCgroupFree(&new_cgroup);
3577 3578 3579 3580
    }

    return 0;
}