src/test/test-engine.c

   1 /* SPDX-License-Identifier: LGPL-2.1+ */
   2 /***
   3   This file is part of systemd.
   4
   5   Copyright 2010 Lennart Poettering
   6
   7   systemd is free software; you can redistribute it and/or modify it
   8   under the terms of the GNU Lesser General Public License as published by
   9   the Free Software Foundation; either version 2.1 of the License, or
  10   (at your option) any later version.
  11
  12   systemd is distributed in the hope that it will be useful, but
  13   WITHOUT ANY WARRANTY; without even the implied warranty of
  14   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  15   Lesser General Public License for more details.
  16
  17   You should have received a copy of the GNU Lesser General Public License
  18   along with systemd; If not, see <http://www.gnu.org/licenses/>.
  19 ***/
  20
  21 #include <errno.h>
  22 #include <stdio.h>
  23 #include <string.h>
  24
  25 #include "bus-util.h"
  26 #include "manager.h"
  27 #include "rm-rf.h"
  28 #include "test-helper.h"
  29 #include "tests.h"
  30
  31 int main(int argc, char *argv[]) {
  32         _cleanup_(rm_rf_physical_and_freep) char *runtime_dir = NULL;
  33         _cleanup_(sd_bus_error_free) sd_bus_error err = SD_BUS_ERROR_NULL;
  34         Manager *m = NULL;
  35         Unit *a = NULL, *b = NULL, *c = NULL, *d = NULL, *e = NULL, *g = NULL, *h = NULL;
  36         FILE *serial = NULL;
  37         FDSet *fdset = NULL;
  38         Job *j;
  39         int r;
  40
  41         r = enter_cgroup_subroot();
  42         if (r == -ENOMEDIUM) {
  43                 log_notice_errno(r, "Skipping test: cgroupfs not available");
  44                 return EXIT_TEST_SKIP;
  45         }
  46
  47         /* prepare the test */
  48         assert_se(set_unit_path(get_testdata_dir("")) >= 0);
  49         assert_se(runtime_dir = setup_fake_runtime_dir());
  50         r = manager_new(UNIT_FILE_USER, MANAGER_TEST_RUN_MINIMAL, &m);
  51         if (MANAGER_SKIP_TEST(r)) {
  52                 log_notice_errno(r, "Skipping test: manager_new: %m");
  53                 return EXIT_TEST_SKIP;
  54         }
  55         assert_se(r >= 0);
  56         assert_se(manager_startup(m, serial, fdset) >= 0);
  57
  58         printf("Load1:\n");
  59         assert_se(manager_load_unit(m, "a.service", NULL, NULL, &a) >= 0);
  60         assert_se(manager_load_unit(m, "b.service", NULL, NULL, &b) >= 0);
  61         assert_se(manager_load_unit(m, "c.service", NULL, NULL, &c) >= 0);
  62         manager_dump_units(m, stdout, "\t");
  63
  64         printf("Test1: (Trivial)\n");
  65         r = manager_add_job(m, JOB_START, c, JOB_REPLACE, &err, &j);
  66         if (sd_bus_error_is_set(&err))
  67                 log_error("error: %s: %s", err.name, err.message);
  68         assert_se(r == 0);
  69         manager_dump_jobs(m, stdout, "\t");
  70
  71         printf("Load2:\n");
  72         manager_clear_jobs(m);
  73         assert_se(manager_load_unit(m, "d.service", NULL, NULL, &d) >= 0);
  74         assert_se(manager_load_unit(m, "e.service", NULL, NULL, &e) >= 0);
  75         manager_dump_units(m, stdout, "\t");
  76
  77         printf("Test2: (Cyclic Order, Unfixable)\n");
  78         assert_se(manager_add_job(m, JOB_START, d, JOB_REPLACE, NULL, &j) == -EDEADLK);
  79         manager_dump_jobs(m, stdout, "\t");
  80
  81         printf("Test3: (Cyclic Order, Fixable, Garbage Collector)\n");
  82         assert_se(manager_add_job(m, JOB_START, e, JOB_REPLACE, NULL, &j) == 0);
  83         manager_dump_jobs(m, stdout, "\t");
  84
  85         printf("Test4: (Identical transaction)\n");
  86         assert_se(manager_add_job(m, JOB_START, e, JOB_FAIL, NULL, &j) == 0);
  87         manager_dump_jobs(m, stdout, "\t");
  88
  89         printf("Load3:\n");
  90         assert_se(manager_load_unit(m, "g.service", NULL, NULL, &g) >= 0);
  91         manager_dump_units(m, stdout, "\t");
  92
  93         printf("Test5: (Colliding transaction, fail)\n");
  94         assert_se(manager_add_job(m, JOB_START, g, JOB_FAIL, NULL, &j) == -EDEADLK);
  95
  96         printf("Test6: (Colliding transaction, replace)\n");
  97         assert_se(manager_add_job(m, JOB_START, g, JOB_REPLACE, NULL, &j) == 0);
  98         manager_dump_jobs(m, stdout, "\t");
  99
 100         printf("Test7: (Unmergeable job type, fail)\n");
 101         assert_se(manager_add_job(m, JOB_STOP, g, JOB_FAIL, NULL, &j) == -EDEADLK);
 102
 103         printf("Test8: (Mergeable job type, fail)\n");
 104         assert_se(manager_add_job(m, JOB_RESTART, g, JOB_FAIL, NULL, &j) == 0);
 105         manager_dump_jobs(m, stdout, "\t");
 106
 107         printf("Test9: (Unmergeable job type, replace)\n");
 108         assert_se(manager_add_job(m, JOB_STOP, g, JOB_REPLACE, NULL, &j) == 0);
 109         manager_dump_jobs(m, stdout, "\t");
 110
 111         printf("Load4:\n");
 112         assert_se(manager_load_unit(m, "h.service", NULL, NULL, &h) >= 0);
 113         manager_dump_units(m, stdout, "\t");
 114
 115         printf("Test10: (Unmergeable job type of auxiliary job, fail)\n");
 116         assert_se(manager_add_job(m, JOB_START, h, JOB_FAIL, NULL, &j) == 0);
 117         manager_dump_jobs(m, stdout, "\t");
 118
 119         assert_se(!hashmap_get(a->dependencies[UNIT_PROPAGATES_RELOAD_TO], b));
 120         assert_se(!hashmap_get(b->dependencies[UNIT_RELOAD_PROPAGATED_FROM], a));
 121         assert_se(!hashmap_get(a->dependencies[UNIT_PROPAGATES_RELOAD_TO], c));
 122         assert_se(!hashmap_get(c->dependencies[UNIT_RELOAD_PROPAGATED_FROM], a));
 123
 124         assert_se(unit_add_dependency(a, UNIT_PROPAGATES_RELOAD_TO, b, true, UNIT_DEPENDENCY_UDEV) == 0);
 125         assert_se(unit_add_dependency(a, UNIT_PROPAGATES_RELOAD_TO, c, true, UNIT_DEPENDENCY_PROC_SWAP) == 0);
 126
 127         assert_se(hashmap_get(a->dependencies[UNIT_PROPAGATES_RELOAD_TO], b));
 128         assert_se(hashmap_get(b->dependencies[UNIT_RELOAD_PROPAGATED_FROM], a));
 129         assert_se(hashmap_get(a->dependencies[UNIT_PROPAGATES_RELOAD_TO], c));
 130         assert_se(hashmap_get(c->dependencies[UNIT_RELOAD_PROPAGATED_FROM], a));
 131
 132         unit_remove_dependencies(a, UNIT_DEPENDENCY_UDEV);
 133
 134         assert_se(!hashmap_get(a->dependencies[UNIT_PROPAGATES_RELOAD_TO], b));
 135         assert_se(!hashmap_get(b->dependencies[UNIT_RELOAD_PROPAGATED_FROM], a));
 136         assert_se(hashmap_get(a->dependencies[UNIT_PROPAGATES_RELOAD_TO], c));
 137         assert_se(hashmap_get(c->dependencies[UNIT_RELOAD_PROPAGATED_FROM], a));
 138
 139         unit_remove_dependencies(a, UNIT_DEPENDENCY_PROC_SWAP);
 140
 141         assert_se(!hashmap_get(a->dependencies[UNIT_PROPAGATES_RELOAD_TO], b));
 142         assert_se(!hashmap_get(b->dependencies[UNIT_RELOAD_PROPAGATED_FROM], a));
 143         assert_se(!hashmap_get(a->dependencies[UNIT_PROPAGATES_RELOAD_TO], c));
 144         assert_se(!hashmap_get(c->dependencies[UNIT_RELOAD_PROPAGATED_FROM], a));
 145
 146         manager_free(m);
 147
 148         return 0;
 149 }