From f596c4350f0dbfc725b4bc3566b38b31860414d8 Mon Sep 17 00:00:00 2001
From: Matej Kafka <git@a-n.cc>
Date: Sat, 24 Apr 2021 21:08:00 +0200
Subject: [PATCH] #31 Suffix cgroup names with DEmOS process PID to allow
 running multiple instances in parallel

TODO: cleanup_crash.sh
---
 src/main.cpp | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/src/main.cpp b/src/main.cpp
index 0b305cd7..641d98d9 100644
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -7,7 +7,7 @@
 
 using namespace std;
 
-static string opt_demos_cg_name = "demos";
+static const string CGROUP_NAME_PREFIX = "demos-";
 
 static string pluralize(unsigned long count, const string &noun)
 {
@@ -59,7 +59,7 @@ static void print_help()
             "                         <POWER_POLICY> has the following form: <NAME>[:ARG1[,ARG2[,...]]]; \n"
             "                         if multiple instances of DEmOS are running in parallel, this parameter \n"
             "                         must not be passed to more than a single one\n"
-            "  [-g <CGROUP_NAME>]    name of root cgroups, default \"" << opt_demos_cg_name << "\"\n"
+            "  [-g <CGROUP_NAME>]    name of root cgroups, default \"" << CGROUP_NAME_PREFIX << "<process_pid>\"\n"
             "                         NOTE: this name must be unique for each running instance of DEmOS\n"
             "  [-m <WINDOW_MESSAGE>] print WINDOW_MESSAGE to stdout at the beginning of each window;\n"
             "                         this may be useful for external synchronization with scheduler windows\n"
@@ -87,6 +87,9 @@ int main(int argc, char *argv[])
     bool dump_config = false;
     bool systemd_run = false;
     std::optional<std::chrono::milliseconds> scheduler_timeout{};
+    // to support multiple instances of DEmOS running at once (primarily for testing),
+    //  default root cgroup name includes the scheduler process PID
+    string root_cgroup_name = CGROUP_NAME_PREFIX + to_string(getpid());
 
     while ((opt = getopt(argc, argv, "c:C:p:g:m:M:t:sdh")) != -1) {
         switch (opt) {
@@ -100,7 +103,7 @@ int main(int argc, char *argv[])
                 power_policy_name = optarg;
                 break;
             case 'g': // custom root cgroup name
-                opt_demos_cg_name = optarg;
+                root_cgroup_name = optarg;
                 break;
             case 'm': // window start sync message
                 window_sync_message = optarg;
@@ -167,7 +170,7 @@ int main(int argc, char *argv[])
         logger->trace("Creating top-level cgroups");
         Cgroup unified_root, freezer_root, cpuset_root;
         if (!cgroup_setup::create_toplevel_cgroups(
-              unified_root, freezer_root, cpuset_root, opt_demos_cg_name)) {
+              unified_root, freezer_root, cpuset_root, root_cgroup_name)) {
             // cgroup creation failed
             return 1;
         }