1 /* SPDX-License-Identifier: GPL-2.0 */ 2 3 #define _GNU_SOURCE 4 #include <linux/limits.h> 5 #include <linux/sched.h> 6 #include <sys/types.h> 7 #include <sys/mman.h> 8 #include <sys/wait.h> 9 #include <unistd.h> 10 #include <fcntl.h> 11 #include <sched.h> 12 #include <stdio.h> 13 #include <errno.h> 14 #include <signal.h> 15 #include <string.h> 16 #include <pthread.h> 17 18 #include "../kselftest.h" 19 #include "cgroup_util.h" 20 21 static int touch_anon(char *buf, size_t size) 22 { 23 int fd; 24 char *pos = buf; 25 26 fd = open("/dev/urandom", O_RDONLY); 27 if (fd < 0) 28 return -1; 29 30 while (size > 0) { 31 ssize_t ret = read(fd, pos, size); 32 33 if (ret < 0) { 34 if (errno != EINTR) { 35 close(fd); 36 return -1; 37 } 38 } else { 39 pos += ret; 40 size -= ret; 41 } 42 } 43 close(fd); 44 45 return 0; 46 } 47 48 static int alloc_and_touch_anon_noexit(const char *cgroup, void *arg) 49 { 50 int ppid = getppid(); 51 size_t size = (size_t)arg; 52 void *buf; 53 54 buf = mmap(NULL, size, PROT_READ | PROT_WRITE, MAP_PRIVATE | MAP_ANON, 55 0, 0); 56 if (buf == MAP_FAILED) 57 return -1; 58 59 if (touch_anon((char *)buf, size)) { 60 munmap(buf, size); 61 return -1; 62 } 63 64 while (getppid() == ppid) 65 sleep(1); 66 67 munmap(buf, size); 68 return 0; 69 } 70 71 /* 72 * Create a child process that allocates and touches 100MB, then waits to be 73 * killed. Wait until the child is attached to the cgroup, kill all processes 74 * in that cgroup and wait until "cgroup.procs" is empty. At this point try to 75 * destroy the empty cgroup. The test helps detect race conditions between 76 * dying processes leaving the cgroup and cgroup destruction path. 77 */ 78 static int test_cgcore_destroy(const char *root) 79 { 80 int ret = KSFT_FAIL; 81 char *cg_test = NULL; 82 int child_pid; 83 char buf[PAGE_SIZE]; 84 85 cg_test = cg_name(root, "cg_test"); 86 87 if (!cg_test) 88 goto cleanup; 89 90 for (int i = 0; i < 10; i++) { 91 if (cg_create(cg_test)) 92 goto cleanup; 93 94 child_pid = cg_run_nowait(cg_test, alloc_and_touch_anon_noexit, 95 (void *) MB(100)); 96 97 if (child_pid < 0) 98 goto cleanup; 99 100 /* wait for the child to enter cgroup */ 101 if (cg_wait_for_proc_count(cg_test, 1)) 102 goto cleanup; 103 104 if (cg_killall(cg_test)) 105 goto cleanup; 106 107 /* wait for cgroup to be empty */ 108 while (1) { 109 if (cg_read(cg_test, "cgroup.procs", buf, sizeof(buf))) 110 goto cleanup; 111 if (buf[0] == '\0') 112 break; 113 usleep(1000); 114 } 115 116 if (rmdir(cg_test)) 117 goto cleanup; 118 119 if (waitpid(child_pid, NULL, 0) < 0) 120 goto cleanup; 121 } 122 ret = KSFT_PASS; 123 cleanup: 124 if (cg_test) 125 cg_destroy(cg_test); 126 free(cg_test); 127 return ret; 128 } 129 130 /* 131 * A(0) - B(0) - C(1) 132 * \ D(0) 133 * 134 * A, B and C's "populated" fields would be 1 while D's 0. 135 * test that after the one process in C is moved to root, 136 * A,B and C's "populated" fields would flip to "0" and file 137 * modified events will be generated on the 138 * "cgroup.events" files of both cgroups. 139 */ 140 static int test_cgcore_populated(const char *root) 141 { 142 int ret = KSFT_FAIL; 143 int err; 144 char *cg_test_a = NULL, *cg_test_b = NULL; 145 char *cg_test_c = NULL, *cg_test_d = NULL; 146 int cgroup_fd = -EBADF; 147 pid_t pid; 148 149 cg_test_a = cg_name(root, "cg_test_a"); 150 cg_test_b = cg_name(root, "cg_test_a/cg_test_b"); 151 cg_test_c = cg_name(root, "cg_test_a/cg_test_b/cg_test_c"); 152 cg_test_d = cg_name(root, "cg_test_a/cg_test_b/cg_test_d"); 153 154 if (!cg_test_a || !cg_test_b || !cg_test_c || !cg_test_d) 155 goto cleanup; 156 157 if (cg_create(cg_test_a)) 158 goto cleanup; 159 160 if (cg_create(cg_test_b)) 161 goto cleanup; 162 163 if (cg_create(cg_test_c)) 164 goto cleanup; 165 166 if (cg_create(cg_test_d)) 167 goto cleanup; 168 169 if (cg_enter_current(cg_test_c)) 170 goto cleanup; 171 172 if (cg_read_strcmp(cg_test_a, "cgroup.events", "populated 1\n")) 173 goto cleanup; 174 175 if (cg_read_strcmp(cg_test_b, "cgroup.events", "populated 1\n")) 176 goto cleanup; 177 178 if (cg_read_strcmp(cg_test_c, "cgroup.events", "populated 1\n")) 179 goto cleanup; 180 181 if (cg_read_strcmp(cg_test_d, "cgroup.events", "populated 0\n")) 182 goto cleanup; 183 184 if (cg_enter_current(root)) 185 goto cleanup; 186 187 if (cg_read_strcmp(cg_test_a, "cgroup.events", "populated 0\n")) 188 goto cleanup; 189 190 if (cg_read_strcmp(cg_test_b, "cgroup.events", "populated 0\n")) 191 goto cleanup; 192 193 if (cg_read_strcmp(cg_test_c, "cgroup.events", "populated 0\n")) 194 goto cleanup; 195 196 if (cg_read_strcmp(cg_test_d, "cgroup.events", "populated 0\n")) 197 goto cleanup; 198 199 /* Test that we can directly clone into a new cgroup. */ 200 cgroup_fd = dirfd_open_opath(cg_test_d); 201 if (cgroup_fd < 0) 202 goto cleanup; 203 204 pid = clone_into_cgroup(cgroup_fd); 205 if (pid < 0) { 206 if (errno == ENOSYS) 207 goto cleanup_pass; 208 goto cleanup; 209 } 210 211 if (pid == 0) { 212 if (raise(SIGSTOP)) 213 exit(EXIT_FAILURE); 214 exit(EXIT_SUCCESS); 215 } 216 217 err = cg_read_strcmp(cg_test_d, "cgroup.events", "populated 1\n"); 218 219 (void)clone_reap(pid, WSTOPPED); 220 (void)kill(pid, SIGCONT); 221 (void)clone_reap(pid, WEXITED); 222 223 if (err) 224 goto cleanup; 225 226 if (cg_read_strcmp(cg_test_d, "cgroup.events", "populated 0\n")) 227 goto cleanup; 228 229 /* Remove cgroup. */ 230 if (cg_test_d) { 231 cg_destroy(cg_test_d); 232 free(cg_test_d); 233 cg_test_d = NULL; 234 } 235 236 pid = clone_into_cgroup(cgroup_fd); 237 if (pid < 0) 238 goto cleanup_pass; 239 if (pid == 0) 240 exit(EXIT_SUCCESS); 241 (void)clone_reap(pid, WEXITED); 242 goto cleanup; 243 244 cleanup_pass: 245 ret = KSFT_PASS; 246 247 cleanup: 248 if (cg_test_d) 249 cg_destroy(cg_test_d); 250 if (cg_test_c) 251 cg_destroy(cg_test_c); 252 if (cg_test_b) 253 cg_destroy(cg_test_b); 254 if (cg_test_a) 255 cg_destroy(cg_test_a); 256 free(cg_test_d); 257 free(cg_test_c); 258 free(cg_test_b); 259 free(cg_test_a); 260 if (cgroup_fd >= 0) 261 close(cgroup_fd); 262 return ret; 263 } 264 265 /* 266 * A (domain threaded) - B (threaded) - C (domain) 267 * 268 * test that C can't be used until it is turned into a 269 * threaded cgroup. "cgroup.type" file will report "domain (invalid)" in 270 * these cases. Operations which fail due to invalid topology use 271 * EOPNOTSUPP as the errno. 272 */ 273 static int test_cgcore_invalid_domain(const char *root) 274 { 275 int ret = KSFT_FAIL; 276 char *grandparent = NULL, *parent = NULL, *child = NULL; 277 278 grandparent = cg_name(root, "cg_test_grandparent"); 279 parent = cg_name(root, "cg_test_grandparent/cg_test_parent"); 280 child = cg_name(root, "cg_test_grandparent/cg_test_parent/cg_test_child"); 281 if (!parent || !child || !grandparent) 282 goto cleanup; 283 284 if (cg_create(grandparent)) 285 goto cleanup; 286 287 if (cg_create(parent)) 288 goto cleanup; 289 290 if (cg_create(child)) 291 goto cleanup; 292 293 if (cg_write(parent, "cgroup.type", "threaded")) 294 goto cleanup; 295 296 if (cg_read_strcmp(child, "cgroup.type", "domain invalid\n")) 297 goto cleanup; 298 299 if (!cg_enter_current(child)) 300 goto cleanup; 301 302 if (errno != EOPNOTSUPP) 303 goto cleanup; 304 305 if (!clone_into_cgroup_run_wait(child)) 306 goto cleanup; 307 308 if (errno == ENOSYS) 309 goto cleanup_pass; 310 311 if (errno != EOPNOTSUPP) 312 goto cleanup; 313 314 cleanup_pass: 315 ret = KSFT_PASS; 316 317 cleanup: 318 cg_enter_current(root); 319 if (child) 320 cg_destroy(child); 321 if (parent) 322 cg_destroy(parent); 323 if (grandparent) 324 cg_destroy(grandparent); 325 free(child); 326 free(parent); 327 free(grandparent); 328 return ret; 329 } 330 331 /* 332 * Test that when a child becomes threaded 333 * the parent type becomes domain threaded. 334 */ 335 static int test_cgcore_parent_becomes_threaded(const char *root) 336 { 337 int ret = KSFT_FAIL; 338 char *parent = NULL, *child = NULL; 339 340 parent = cg_name(root, "cg_test_parent"); 341 child = cg_name(root, "cg_test_parent/cg_test_child"); 342 if (!parent || !child) 343 goto cleanup; 344 345 if (cg_create(parent)) 346 goto cleanup; 347 348 if (cg_create(child)) 349 goto cleanup; 350 351 if (cg_write(child, "cgroup.type", "threaded")) 352 goto cleanup; 353 354 if (cg_read_strcmp(parent, "cgroup.type", "domain threaded\n")) 355 goto cleanup; 356 357 ret = KSFT_PASS; 358 359 cleanup: 360 if (child) 361 cg_destroy(child); 362 if (parent) 363 cg_destroy(parent); 364 free(child); 365 free(parent); 366 return ret; 367 368 } 369 370 /* 371 * Test that there's no internal process constrain on threaded cgroups. 372 * You can add threads/processes on a parent with a controller enabled. 373 */ 374 static int test_cgcore_no_internal_process_constraint_on_threads(const char *root) 375 { 376 int ret = KSFT_FAIL; 377 char *parent = NULL, *child = NULL; 378 379 if (cg_read_strstr(root, "cgroup.controllers", "cpu") || 380 cg_write(root, "cgroup.subtree_control", "+cpu")) { 381 ret = KSFT_SKIP; 382 goto cleanup; 383 } 384 385 parent = cg_name(root, "cg_test_parent"); 386 child = cg_name(root, "cg_test_parent/cg_test_child"); 387 if (!parent || !child) 388 goto cleanup; 389 390 if (cg_create(parent)) 391 goto cleanup; 392 393 if (cg_create(child)) 394 goto cleanup; 395 396 if (cg_write(parent, "cgroup.type", "threaded")) 397 goto cleanup; 398 399 if (cg_write(child, "cgroup.type", "threaded")) 400 goto cleanup; 401 402 if (cg_write(parent, "cgroup.subtree_control", "+cpu")) 403 goto cleanup; 404 405 if (cg_enter_current(parent)) 406 goto cleanup; 407 408 ret = KSFT_PASS; 409 410 cleanup: 411 cg_enter_current(root); 412 cg_enter_current(root); 413 if (child) 414 cg_destroy(child); 415 if (parent) 416 cg_destroy(parent); 417 free(child); 418 free(parent); 419 return ret; 420 } 421 422 /* 423 * Test that you can't enable a controller on a child if it's not enabled 424 * on the parent. 425 */ 426 static int test_cgcore_top_down_constraint_enable(const char *root) 427 { 428 int ret = KSFT_FAIL; 429 char *parent = NULL, *child = NULL; 430 431 parent = cg_name(root, "cg_test_parent"); 432 child = cg_name(root, "cg_test_parent/cg_test_child"); 433 if (!parent || !child) 434 goto cleanup; 435 436 if (cg_create(parent)) 437 goto cleanup; 438 439 if (cg_create(child)) 440 goto cleanup; 441 442 if (!cg_write(child, "cgroup.subtree_control", "+memory")) 443 goto cleanup; 444 445 ret = KSFT_PASS; 446 447 cleanup: 448 if (child) 449 cg_destroy(child); 450 if (parent) 451 cg_destroy(parent); 452 free(child); 453 free(parent); 454 return ret; 455 } 456 457 /* 458 * Test that you can't disable a controller on a parent 459 * if it's enabled in a child. 460 */ 461 static int test_cgcore_top_down_constraint_disable(const char *root) 462 { 463 int ret = KSFT_FAIL; 464 char *parent = NULL, *child = NULL; 465 466 parent = cg_name(root, "cg_test_parent"); 467 child = cg_name(root, "cg_test_parent/cg_test_child"); 468 if (!parent || !child) 469 goto cleanup; 470 471 if (cg_create(parent)) 472 goto cleanup; 473 474 if (cg_create(child)) 475 goto cleanup; 476 477 if (cg_write(parent, "cgroup.subtree_control", "+memory")) 478 goto cleanup; 479 480 if (cg_write(child, "cgroup.subtree_control", "+memory")) 481 goto cleanup; 482 483 if (!cg_write(parent, "cgroup.subtree_control", "-memory")) 484 goto cleanup; 485 486 ret = KSFT_PASS; 487 488 cleanup: 489 if (child) 490 cg_destroy(child); 491 if (parent) 492 cg_destroy(parent); 493 free(child); 494 free(parent); 495 return ret; 496 } 497 498 /* 499 * Test internal process constraint. 500 * You can't add a pid to a domain parent if a controller is enabled. 501 */ 502 static int test_cgcore_internal_process_constraint(const char *root) 503 { 504 int ret = KSFT_FAIL; 505 char *parent = NULL, *child = NULL; 506 507 parent = cg_name(root, "cg_test_parent"); 508 child = cg_name(root, "cg_test_parent/cg_test_child"); 509 if (!parent || !child) 510 goto cleanup; 511 512 if (cg_create(parent)) 513 goto cleanup; 514 515 if (cg_create(child)) 516 goto cleanup; 517 518 if (cg_write(parent, "cgroup.subtree_control", "+memory")) 519 goto cleanup; 520 521 if (!cg_enter_current(parent)) 522 goto cleanup; 523 524 if (!clone_into_cgroup_run_wait(parent)) 525 goto cleanup; 526 527 ret = KSFT_PASS; 528 529 cleanup: 530 if (child) 531 cg_destroy(child); 532 if (parent) 533 cg_destroy(parent); 534 free(child); 535 free(parent); 536 return ret; 537 } 538 539 static void *dummy_thread_fn(void *arg) 540 { 541 return (void *)(size_t)pause(); 542 } 543 544 /* 545 * Test threadgroup migration. 546 * All threads of a process are migrated together. 547 */ 548 static int test_cgcore_proc_migration(const char *root) 549 { 550 int ret = KSFT_FAIL; 551 int t, c_threads = 0, n_threads = 13; 552 char *src = NULL, *dst = NULL; 553 pthread_t threads[n_threads]; 554 555 src = cg_name(root, "cg_src"); 556 dst = cg_name(root, "cg_dst"); 557 if (!src || !dst) 558 goto cleanup; 559 560 if (cg_create(src)) 561 goto cleanup; 562 if (cg_create(dst)) 563 goto cleanup; 564 565 if (cg_enter_current(src)) 566 goto cleanup; 567 568 for (c_threads = 0; c_threads < n_threads; ++c_threads) { 569 if (pthread_create(&threads[c_threads], NULL, dummy_thread_fn, NULL)) 570 goto cleanup; 571 } 572 573 cg_enter_current(dst); 574 if (cg_read_lc(dst, "cgroup.threads") != n_threads + 1) 575 goto cleanup; 576 577 ret = KSFT_PASS; 578 579 cleanup: 580 for (t = 0; t < c_threads; ++t) { 581 pthread_cancel(threads[t]); 582 } 583 584 for (t = 0; t < c_threads; ++t) { 585 pthread_join(threads[t], NULL); 586 } 587 588 cg_enter_current(root); 589 590 if (dst) 591 cg_destroy(dst); 592 if (src) 593 cg_destroy(src); 594 free(dst); 595 free(src); 596 return ret; 597 } 598 599 static void *migrating_thread_fn(void *arg) 600 { 601 int g, i, n_iterations = 1000; 602 char **grps = arg; 603 char lines[3][PATH_MAX]; 604 605 for (g = 1; g < 3; ++g) 606 snprintf(lines[g], sizeof(lines[g]), "0::%s", grps[g] + strlen(grps[0])); 607 608 for (i = 0; i < n_iterations; ++i) { 609 cg_enter_current_thread(grps[(i % 2) + 1]); 610 611 if (proc_read_strstr(0, 1, "cgroup", lines[(i % 2) + 1])) 612 return (void *)-1; 613 } 614 return NULL; 615 } 616 617 /* 618 * Test single thread migration. 619 * Threaded cgroups allow successful migration of a thread. 620 */ 621 static int test_cgcore_thread_migration(const char *root) 622 { 623 int ret = KSFT_FAIL; 624 char *dom = NULL; 625 char line[PATH_MAX]; 626 char *grps[3] = { (char *)root, NULL, NULL }; 627 pthread_t thr; 628 void *retval; 629 630 dom = cg_name(root, "cg_dom"); 631 grps[1] = cg_name(root, "cg_dom/cg_src"); 632 grps[2] = cg_name(root, "cg_dom/cg_dst"); 633 if (!grps[1] || !grps[2] || !dom) 634 goto cleanup; 635 636 if (cg_create(dom)) 637 goto cleanup; 638 if (cg_create(grps[1])) 639 goto cleanup; 640 if (cg_create(grps[2])) 641 goto cleanup; 642 643 if (cg_write(grps[1], "cgroup.type", "threaded")) 644 goto cleanup; 645 if (cg_write(grps[2], "cgroup.type", "threaded")) 646 goto cleanup; 647 648 if (cg_enter_current(grps[1])) 649 goto cleanup; 650 651 if (pthread_create(&thr, NULL, migrating_thread_fn, grps)) 652 goto cleanup; 653 654 if (pthread_join(thr, &retval)) 655 goto cleanup; 656 657 if (retval) 658 goto cleanup; 659 660 snprintf(line, sizeof(line), "0::%s", grps[1] + strlen(grps[0])); 661 if (proc_read_strstr(0, 1, "cgroup", line)) 662 goto cleanup; 663 664 ret = KSFT_PASS; 665 666 cleanup: 667 cg_enter_current(root); 668 if (grps[2]) 669 cg_destroy(grps[2]); 670 if (grps[1]) 671 cg_destroy(grps[1]); 672 if (dom) 673 cg_destroy(dom); 674 free(grps[2]); 675 free(grps[1]); 676 free(dom); 677 return ret; 678 } 679 680 /* 681 * cgroup migration permission check should be performed based on the 682 * credentials at the time of open instead of write. 683 */ 684 static int test_cgcore_lesser_euid_open(const char *root) 685 { 686 const uid_t test_euid = 65534; /* usually nobody, any !root is fine */ 687 int ret = KSFT_FAIL; 688 char *cg_test_a = NULL, *cg_test_b = NULL; 689 char *cg_test_a_procs = NULL, *cg_test_b_procs = NULL; 690 int cg_test_b_procs_fd = -1; 691 uid_t saved_uid; 692 693 cg_test_a = cg_name(root, "cg_test_a"); 694 cg_test_b = cg_name(root, "cg_test_b"); 695 696 if (!cg_test_a || !cg_test_b) 697 goto cleanup; 698 699 cg_test_a_procs = cg_name(cg_test_a, "cgroup.procs"); 700 cg_test_b_procs = cg_name(cg_test_b, "cgroup.procs"); 701 702 if (!cg_test_a_procs || !cg_test_b_procs) 703 goto cleanup; 704 705 if (cg_create(cg_test_a) || cg_create(cg_test_b)) 706 goto cleanup; 707 708 if (cg_enter_current(cg_test_a)) 709 goto cleanup; 710 711 if (chown(cg_test_a_procs, test_euid, -1) || 712 chown(cg_test_b_procs, test_euid, -1)) 713 goto cleanup; 714 715 saved_uid = geteuid(); 716 if (seteuid(test_euid)) 717 goto cleanup; 718 719 cg_test_b_procs_fd = open(cg_test_b_procs, O_RDWR); 720 721 if (seteuid(saved_uid)) 722 goto cleanup; 723 724 if (cg_test_b_procs_fd < 0) 725 goto cleanup; 726 727 if (write(cg_test_b_procs_fd, "0", 1) >= 0 || errno != EACCES) 728 goto cleanup; 729 730 ret = KSFT_PASS; 731 732 cleanup: 733 cg_enter_current(root); 734 if (cg_test_b_procs_fd >= 0) 735 close(cg_test_b_procs_fd); 736 if (cg_test_b) 737 cg_destroy(cg_test_b); 738 if (cg_test_a) 739 cg_destroy(cg_test_a); 740 free(cg_test_b_procs); 741 free(cg_test_a_procs); 742 free(cg_test_b); 743 free(cg_test_a); 744 return ret; 745 } 746 747 struct lesser_ns_open_thread_arg { 748 const char *path; 749 int fd; 750 int err; 751 }; 752 753 static int lesser_ns_open_thread_fn(void *arg) 754 { 755 struct lesser_ns_open_thread_arg *targ = arg; 756 757 targ->fd = open(targ->path, O_RDWR); 758 targ->err = errno; 759 return 0; 760 } 761 762 /* 763 * cgroup migration permission check should be performed based on the cgroup 764 * namespace at the time of open instead of write. 765 */ 766 static int test_cgcore_lesser_ns_open(const char *root) 767 { 768 static char stack[65536]; 769 const uid_t test_euid = 65534; /* usually nobody, any !root is fine */ 770 int ret = KSFT_FAIL; 771 char *cg_test_a = NULL, *cg_test_b = NULL; 772 char *cg_test_a_procs = NULL, *cg_test_b_procs = NULL; 773 int cg_test_b_procs_fd = -1; 774 struct lesser_ns_open_thread_arg targ = { .fd = -1 }; 775 pid_t pid; 776 int status; 777 778 cg_test_a = cg_name(root, "cg_test_a"); 779 cg_test_b = cg_name(root, "cg_test_b"); 780 781 if (!cg_test_a || !cg_test_b) 782 goto cleanup; 783 784 cg_test_a_procs = cg_name(cg_test_a, "cgroup.procs"); 785 cg_test_b_procs = cg_name(cg_test_b, "cgroup.procs"); 786 787 if (!cg_test_a_procs || !cg_test_b_procs) 788 goto cleanup; 789 790 if (cg_create(cg_test_a) || cg_create(cg_test_b)) 791 goto cleanup; 792 793 if (cg_enter_current(cg_test_b)) 794 goto cleanup; 795 796 if (chown(cg_test_a_procs, test_euid, -1) || 797 chown(cg_test_b_procs, test_euid, -1)) 798 goto cleanup; 799 800 targ.path = cg_test_b_procs; 801 pid = clone(lesser_ns_open_thread_fn, stack + sizeof(stack), 802 CLONE_NEWCGROUP | CLONE_FILES | CLONE_VM | SIGCHLD, 803 &targ); 804 if (pid < 0) 805 goto cleanup; 806 807 if (waitpid(pid, &status, 0) < 0) 808 goto cleanup; 809 810 if (!WIFEXITED(status)) 811 goto cleanup; 812 813 cg_test_b_procs_fd = targ.fd; 814 if (cg_test_b_procs_fd < 0) 815 goto cleanup; 816 817 if (cg_enter_current(cg_test_a)) 818 goto cleanup; 819 820 if ((status = write(cg_test_b_procs_fd, "0", 1)) >= 0 || errno != ENOENT) 821 goto cleanup; 822 823 ret = KSFT_PASS; 824 825 cleanup: 826 cg_enter_current(root); 827 if (cg_test_b_procs_fd >= 0) 828 close(cg_test_b_procs_fd); 829 if (cg_test_b) 830 cg_destroy(cg_test_b); 831 if (cg_test_a) 832 cg_destroy(cg_test_a); 833 free(cg_test_b_procs); 834 free(cg_test_a_procs); 835 free(cg_test_b); 836 free(cg_test_a); 837 return ret; 838 } 839 840 #define T(x) { x, #x } 841 struct corecg_test { 842 int (*fn)(const char *root); 843 const char *name; 844 } tests[] = { 845 T(test_cgcore_internal_process_constraint), 846 T(test_cgcore_top_down_constraint_enable), 847 T(test_cgcore_top_down_constraint_disable), 848 T(test_cgcore_no_internal_process_constraint_on_threads), 849 T(test_cgcore_parent_becomes_threaded), 850 T(test_cgcore_invalid_domain), 851 T(test_cgcore_populated), 852 T(test_cgcore_proc_migration), 853 T(test_cgcore_thread_migration), 854 T(test_cgcore_destroy), 855 T(test_cgcore_lesser_euid_open), 856 T(test_cgcore_lesser_ns_open), 857 }; 858 #undef T 859 860 int main(int argc, char *argv[]) 861 { 862 char root[PATH_MAX]; 863 int i, ret = EXIT_SUCCESS; 864 865 if (cg_find_unified_root(root, sizeof(root))) 866 ksft_exit_skip("cgroup v2 isn't mounted\n"); 867 868 if (cg_read_strstr(root, "cgroup.subtree_control", "memory")) 869 if (cg_write(root, "cgroup.subtree_control", "+memory")) 870 ksft_exit_skip("Failed to set memory controller\n"); 871 872 for (i = 0; i < ARRAY_SIZE(tests); i++) { 873 switch (tests[i].fn(root)) { 874 case KSFT_PASS: 875 ksft_test_result_pass("%s\n", tests[i].name); 876 break; 877 case KSFT_SKIP: 878 ksft_test_result_skip("%s\n", tests[i].name); 879 break; 880 default: 881 ret = EXIT_FAILURE; 882 ksft_test_result_fail("%s\n", tests[i].name); 883 break; 884 } 885 } 886 887 return ret; 888 } 889