../src/run/run.c

Bug Summary

File:	build-scan/../src/run/run.c
Warning:	line 1336, column 40 Potential leak of memory pointed to by 'trigger'
Annotated Source Code

Press '?' to see keyboard shortcuts
Show analyzer invocation
clang -cc1 -cc1 -triple x86_64-unknown-linux-gnu -analyze -disable-free -disable-llvm-verifier -discard-value-names -main-file-name run.c -analyzer-store=region -analyzer-opt-analyze-nested-blocks -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -setup-static-analyzer -mrelocation-model static -mframe-pointer=all -relaxed-aliasing -menable-no-infs -menable-no-nans -menable-unsafe-fp-math -fno-signed-zeros -mreassociate -freciprocal-math -fdenormal-fp-math=preserve-sign,preserve-sign -ffp-contract=fast -fno-rounding-math -ffast-math -ffinite-math-only -mconstructor-aliases -munwind-tables -target-cpu x86-64 -tune-cpu generic -fno-split-dwarf-inlining -debugger-tuning=gdb -resource-dir /usr/lib64/clang/12.0.0 -include config.h -I systemd-run.p -I . -I .. -I src/basic -I ../src/basic -I src/shared -I ../src/shared -I src/systemd -I ../src/systemd -I src/journal -I ../src/journal -I src/journal-remote -I ../src/journal-remote -I src/nspawn -I ../src/nspawn -I src/resolve -I ../src/resolve -I src/timesync -I ../src/timesync -I ../src/time-wait-sync -I src/login -I ../src/login -I src/udev -I ../src/udev -I src/libudev -I ../src/libudev -I src/core -I ../src/core -I ../src/libsystemd/sd-bus -I ../src/libsystemd/sd-device -I ../src/libsystemd/sd-hwdb -I ../src/libsystemd/sd-id128 -I ../src/libsystemd/sd-netlink -I ../src/libsystemd/sd-network -I src/libsystemd-network -I ../src/libsystemd-network -D _FILE_OFFSET_BITS=64 -internal-isystem /usr/local/include -internal-isystem /usr/lib64/clang/12.0.0/include -internal-externc-isystem /include -internal-externc-isystem /usr/include -Wwrite-strings -Wno-unused-parameter -Wno-missing-field-initializers -Wno-unused-result -Wno-format-signedness -Wno-error=nonnull -std=gnu99 -fconst-strings -fdebug-compilation-dir /home/mrc0mmand/repos/@redhat-plumbers/systemd-rhel8/build-scan -ferror-limit 19 -fvisibility hidden -stack-protector 2 -fgnuc-version=4.2.1 -fcolor-diagnostics -analyzer-output=html -faddrsig -o /tmp/scan-build-2021-07-16-221226-1465241-1 -x c ../src/run/run.c
1/* SPDX-License-Identifier: LGPL-2.1+ */

3#include <getopt.h>
4#include <stdio.h>

6#include "sd-bus.h"
7#include "sd-event.h"

9#include "alloc-util.h"
10#include "bus-error.h"
11#include "bus-unit-util.h"
12#include "bus-util.h"
13#include "calendarspec.h"
14#include "env-util.h"
15#include "fd-util.h"
16#include "format-util.h"
17#include "parse-util.h"
18#include "path-util.h"
19#include "process-util.h"
20#include "ptyfwd.h"
21#include "signal-util.h"
22#include "spawn-polkit-agent.h"
23#include "strv.h"
24#include "terminal-util.h"
25#include "unit-def.h"
26#include "unit-name.h"
27#include "user-util.h"

29static bool_Bool arg_ask_password = true1;
30static bool_Bool arg_scope = false0;
31static bool_Bool arg_remain_after_exit = false0;
32static bool_Bool arg_no_block = false0;
33static bool_Bool arg_wait = false0;
34static const char *arg_unit = NULL((void*)0);
35static const char *arg_description = NULL((void*)0);
36static const char *arg_slice = NULL((void*)0);
37static bool_Bool arg_send_sighup = false0;
38static BusTransport arg_transport = BUS_TRANSPORT_LOCAL;
39static const char *arg_host = NULL((void*)0);
40static bool_Bool arg_user = false0;
41static const char *arg_service_type = NULL((void*)0);
42static const char *arg_exec_user = NULL((void*)0);
43static const char *arg_exec_group = NULL((void*)0);
44static int arg_nice = 0;
45static bool_Bool arg_nice_set = false0;
46static char **arg_environment = NULL((void*)0);
47static char **arg_property = NULL((void*)0);
48static enum {
      ARG_STDIO_NONE,      /* The default, as it is for normal services, stdin connected to /dev/null, and stdout+stderr to the journal */
      ARG_STDIO_PTY,       /* Interactive behaviour, requested by --pty: we allocate a pty and connect it to the TTY we are invoked from */
      ARG_STDIO_DIRECT,    /* Directly pass our stdin/stdout/stderr to the activated service, useful for usage in shell pipelines, requested by --pipe */
      ARG_STDIO_AUTO,      /* If --pipe and --pty are used together we use --pty when invoked on a TTY, and --pipe otherwise */
53} arg_stdio = ARG_STDIO_NONE;
54static char **arg_path_property = NULL((void*)0);
55static char **arg_socket_property = NULL((void*)0);
56static char **arg_timer_property = NULL((void*)0);
57static bool_Bool with_timer = false0;
58static bool_Bool arg_quiet = false0;
59static bool_Bool arg_aggressive_gc = false0;

61static void help(void) {
      printf("%s [OPTIONS...] {COMMAND} [ARGS...]\n\n"
             "Run the specified command in a transient scope or service.\n\n"
             "  -h --help                       Show this help\n"
             "     --version                    Show package version\n"
             "     --no-ask-password            Do not prompt for password\n"
             "     --user                       Run as user unit\n"
             "  -H --host=[USER@]HOST           Operate on remote host\n"
             "  -M --machine=CONTAINER          Operate on local container\n"
             "     --scope                      Run this as scope rather than service\n"
             "     --unit=UNIT                  Run under the specified unit name\n"
             "  -p --property=NAME=VALUE        Set service or scope unit property\n"
             "     --description=TEXT           Description for unit\n"
             "     --slice=SLICE                Run in the specified slice\n"
             "     --no-block                   Do not wait until operation finished\n"
             "  -r --remain-after-exit          Leave service around until explicitly stopped\n"
             "     --wait                       Wait until service stopped again\n"
             "     --send-sighup                Send SIGHUP when terminating\n"
             "     --service-type=TYPE          Service type\n"
             "     --uid=USER                   Run as system user\n"
             "     --gid=GROUP                  Run as system group\n"
             "     --nice=NICE                  Nice level\n"
             "  -E --setenv=NAME=VALUE          Set environment\n"
             "  -t --pty                        Run service on pseudo TTY as STDIN/STDOUT/\n"
             "                                  STDERR\n"
             "  -P --pipe                       Pass STDIN/STDOUT/STDERR directly to service\n"
             "  -q --quiet                      Suppress information messages during runtime\n"
             "  -G --collect                    Unload unit after it ran, even when failed\n\n"
             "Path options:\n"
             "     --path-property=NAME=VALUE   Set path unit property\n\n"
             "Socket options:\n"
             "     --socket-property=NAME=VALUE Set socket unit property\n\n"
             "Timer options:\n"
             "     --on-active=SECONDS          Run after SECONDS delay\n"
             "     --on-boot=SECONDS            Run SECONDS after machine was booted up\n"
             "     --on-startup=SECONDS         Run SECONDS after systemd activation\n"
             "     --on-unit-active=SECONDS     Run SECONDS after the last activation\n"
             "     --on-unit-inactive=SECONDS   Run SECONDS after the last deactivation\n"
             "     --on-calendar=SPEC           Realtime timer\n"
             "     --timer-property=NAME=VALUE  Set timer unit property\n"
             , program_invocation_short_name);
102}

104static int add_timer_property(const char *name, const char *val) {
      char *p;

      assert(name)do { if ((__builtin_expect(!!(!(name)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("name"), "../src/run/run.c", 107, __PRETTY_FUNCTION__
); } while (0);
      assert(val)do { if ((__builtin_expect(!!(!(val)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("val"), "../src/run/run.c", 108, __PRETTY_FUNCTION__
); } while (0);

      p = strjoin(name, "=", val)strjoin_real((name), "=", val, ((void*)0));
      if (!p)
              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 112, __func__
);

      if (strv_consume(&arg_timer_property, p) < 0)
              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 115, __func__
);

      return 0;
118}

120static int parse_argv(int argc, char *argv[]) {

      enum {
              ARG_VERSION = 0x100,
              ARG_USER,
              ARG_SYSTEM,
              ARG_SCOPE,
              ARG_UNIT,
              ARG_DESCRIPTION,
              ARG_SLICE,
              ARG_SEND_SIGHUP,
              ARG_SERVICE_TYPE,
              ARG_EXEC_USER,
              ARG_EXEC_GROUP,
              ARG_NICE,
              ARG_ON_ACTIVE,
              ARG_ON_BOOT,
              ARG_ON_STARTUP,
              ARG_ON_UNIT_ACTIVE,
              ARG_ON_UNIT_INACTIVE,
              ARG_ON_CALENDAR,
              ARG_TIMER_PROPERTY,
              ARG_PATH_PROPERTY,
              ARG_SOCKET_PROPERTY,
              ARG_NO_BLOCK,
              ARG_NO_ASK_PASSWORD,
              ARG_WAIT,
      };

      static const struct option options[] = {
              { "help",              no_argument0,       NULL((void*)0), 'h'                  },
              { "version",           no_argument0,       NULL((void*)0), ARG_VERSION          },
              { "user",              no_argument0,       NULL((void*)0), ARG_USER             },
              { "system",            no_argument0,       NULL((void*)0), ARG_SYSTEM           },
              { "scope",             no_argument0,       NULL((void*)0), ARG_SCOPE            },
              { "unit",              required_argument1, NULL((void*)0), ARG_UNIT             },
              { "description",       required_argument1, NULL((void*)0), ARG_DESCRIPTION      },
              { "slice",             required_argument1, NULL((void*)0), ARG_SLICE            },
              { "remain-after-exit", no_argument0,       NULL((void*)0), 'r'                  },
              { "send-sighup",       no_argument0,       NULL((void*)0), ARG_SEND_SIGHUP      },
              { "host",              required_argument1, NULL((void*)0), 'H'                  },
              { "machine",           required_argument1, NULL((void*)0), 'M'                  },
              { "service-type",      required_argument1, NULL((void*)0), ARG_SERVICE_TYPE     },
              { "wait",              no_argument0,       NULL((void*)0), ARG_WAIT             },
              { "uid",               required_argument1, NULL((void*)0), ARG_EXEC_USER        },
              { "gid",               required_argument1, NULL((void*)0), ARG_EXEC_GROUP       },
              { "nice",              required_argument1, NULL((void*)0), ARG_NICE             },
              { "setenv",            required_argument1, NULL((void*)0), 'E'                  },
              { "property",          required_argument1, NULL((void*)0), 'p'                  },
              { "tty",               no_argument0,       NULL((void*)0), 't'                  }, /* deprecated alias */
              { "pty",               no_argument0,       NULL((void*)0), 't'                  },
              { "pipe",              no_argument0,       NULL((void*)0), 'P'                  },
              { "quiet",             no_argument0,       NULL((void*)0), 'q'                  },
              { "on-active",         required_argument1, NULL((void*)0), ARG_ON_ACTIVE        },
              { "on-boot",           required_argument1, NULL((void*)0), ARG_ON_BOOT          },
              { "on-startup",        required_argument1, NULL((void*)0), ARG_ON_STARTUP       },
              { "on-unit-active",    required_argument1, NULL((void*)0), ARG_ON_UNIT_ACTIVE   },
              { "on-unit-inactive",  required_argument1, NULL((void*)0), ARG_ON_UNIT_INACTIVE },
              { "on-calendar",       required_argument1, NULL((void*)0), ARG_ON_CALENDAR      },
              { "timer-property",    required_argument1, NULL((void*)0), ARG_TIMER_PROPERTY   },
              { "path-property",     required_argument1, NULL((void*)0), ARG_PATH_PROPERTY    },
              { "socket-property",   required_argument1, NULL((void*)0), ARG_SOCKET_PROPERTY  },
              { "no-block",          no_argument0,       NULL((void*)0), ARG_NO_BLOCK         },
              { "no-ask-password",   no_argument0,       NULL((void*)0), ARG_NO_ASK_PASSWORD  },
              { "collect",           no_argument0,       NULL((void*)0), 'G'                  },
              {},
      };

      bool_Bool with_trigger = false0;
      int r, c;

      assert(argc >= 0)do { if ((__builtin_expect(!!(!(argc >= 0)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("argc >= 0"), "../src/run/run.c", 191
, __PRETTY_FUNCTION__); } while (0);
      assert(argv)do { if ((__builtin_expect(!!(!(argv)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("argv"), "../src/run/run.c", 192, __PRETTY_FUNCTION__
); } while (0);

      while ((c = getopt_long(argc, argv, "+hrH:M:E:p:tPqG", options, NULL((void*)0))) >= 0)

              switch (c) {

              case 'h':
                      help();
                      return 0;

              case ARG_VERSION:
                      return version();

              case ARG_NO_ASK_PASSWORD:
                      arg_ask_password = false0;
                      break;

              case ARG_USER:
                      arg_user = true1;
                      break;

              case ARG_SYSTEM:
                      arg_user = false0;
                      break;

              case ARG_SCOPE:
                      arg_scope = true1;
                      break;

              case ARG_UNIT:
                      arg_unit = optarg;
                      break;

              case ARG_DESCRIPTION:
                      arg_description = optarg;
                      break;

              case ARG_SLICE:
                      arg_slice = optarg;
                      break;

              case ARG_SEND_SIGHUP:
                      arg_send_sighup = true1;
                      break;

              case 'r':
                      arg_remain_after_exit = true1;
                      break;

              case 'H':
                      arg_transport = BUS_TRANSPORT_REMOTE;
                      arg_host = optarg;
                      break;

              case 'M':
                      arg_transport = BUS_TRANSPORT_MACHINE;
                      arg_host = optarg;
                      break;

              case ARG_SERVICE_TYPE:
                      arg_service_type = optarg;
                      break;

              case ARG_EXEC_USER:
                      arg_exec_user = optarg;
                      break;

              case ARG_EXEC_GROUP:
                      arg_exec_group = optarg;
                      break;

              case ARG_NICE:
                      r = parse_nice(optarg, &arg_nice);
                      if (r < 0)
                              return log_error_errno(r, "Failed to parse nice value: %s", optarg)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 266, __func__, "Failed to parse nice value: %s"
, optarg) : -abs(_e); });

                      arg_nice_set = true1;
                      break;

              case 'E':
                      if (strv_extend(&arg_environment, optarg) < 0)
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 273, __func__
);

                      break;

              case 'p':
                      if (strv_extend(&arg_property, optarg) < 0)
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 279, __func__
);

                      break;

              case 't': /* --pty */
                      if (IN_SET(arg_stdio, ARG_STDIO_DIRECT, ARG_STDIO_AUTO)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){ARG_STDIO_DIRECT, ARG_STDIO_AUTO})/sizeof
(int)]; switch(arg_stdio) { case ARG_STDIO_DIRECT: case ARG_STDIO_AUTO
: _found = 1; break; default: break; } _found; })) /* if --pipe is already used, upgrade to auto mode */
                              arg_stdio = ARG_STDIO_AUTO;
                      else
                              arg_stdio = ARG_STDIO_PTY;
                      break;

              case 'P': /* --pipe */
                      if (IN_SET(arg_stdio, ARG_STDIO_PTY, ARG_STDIO_AUTO)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){ARG_STDIO_PTY, ARG_STDIO_AUTO})/sizeof(int
)]; switch(arg_stdio) { case ARG_STDIO_PTY: case ARG_STDIO_AUTO
: _found = 1; break; default: break; } _found; })) /* If --pty is already used, upgrade to auto mode */
                              arg_stdio = ARG_STDIO_AUTO;
                      else
                              arg_stdio = ARG_STDIO_DIRECT;
                      break;

              case 'q':
                      arg_quiet = true1;
                      break;

              case ARG_ON_ACTIVE:
                      r = add_timer_property("OnActiveSec", optarg);
                      if (r < 0)
                              return r;

                      with_timer = true1;
                      break;

              case ARG_ON_BOOT:
                      r = add_timer_property("OnBootSec", optarg);
                      if (r < 0)
                              return r;

                      with_timer = true1;
                      break;

              case ARG_ON_STARTUP:
                      r = add_timer_property("OnStartupSec", optarg);
                      if (r < 0)
                              return r;

                      with_timer = true1;
                      break;

              case ARG_ON_UNIT_ACTIVE:
                      r = add_timer_property("OnUnitActiveSec", optarg);
                      if (r < 0)
                              return r;

                      with_timer = true1;
                      break;

              case ARG_ON_UNIT_INACTIVE:
                      r = add_timer_property("OnUnitInactiveSec", optarg);
                      if (r < 0)
                              return r;

                      with_timer = true1;
                      break;

              case ARG_ON_CALENDAR:
                      r = add_timer_property("OnCalendar", optarg);
                      if (r < 0)
                              return r;

                      with_timer = true1;
                      break;

              case ARG_TIMER_PROPERTY:

                      if (strv_extend(&arg_timer_property, optarg) < 0)
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 352, __func__
);

                      with_timer = with_timer ||
                              !!startswith(optarg, "OnActiveSec=") ||
                              !!startswith(optarg, "OnBootSec=") ||
                              !!startswith(optarg, "OnStartupSec=") ||
                              !!startswith(optarg, "OnUnitActiveSec=") ||
                              !!startswith(optarg, "OnUnitInactiveSec=") ||
                              !!startswith(optarg, "OnCalendar=");
                      break;

              case ARG_PATH_PROPERTY:

                      if (strv_extend(&arg_path_property, optarg) < 0)
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 366, __func__
);

                      break;

              case ARG_SOCKET_PROPERTY:

                      if (strv_extend(&arg_socket_property, optarg) < 0)
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 373, __func__
);

                      break;

              case ARG_NO_BLOCK:
                      arg_no_block = true1;
                      break;

              case ARG_WAIT:
                      arg_wait = true1;
                      break;

              case 'G':
                      arg_aggressive_gc = true1;
                      break;

              case '?':
                      return -EINVAL22;

              default:
                      assert_not_reached("Unhandled option")do { log_assert_failed_unreachable_realm(LOG_REALM_SYSTEMD, (
"Unhandled option"), "../src/run/run.c", 393, __PRETTY_FUNCTION__
); } while (0);
              }

      with_trigger = !!arg_path_property || !!arg_socket_property || with_timer;

      /* currently, only single trigger (path, socket, timer) unit can be created simultaneously */
      if ((int) !!arg_path_property + (int) !!arg_socket_property + (int) with_timer > 1) {
              log_error("Only single trigger (path, socket, timer) unit can be created.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 400, __func__, "Only single trigger (path, socket, timer) unit can be created."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_stdio == ARG_STDIO_AUTO) {
              /* If we both --pty and --pipe are specified we'll automatically pick --pty if we are connected fully
               * to a TTY and pick direct fd passing otherwise. This way, we automatically adapt to usage in a shell
               * pipeline, but we are neatly interactive with tty-level isolation otherwise. */
              arg_stdio = isatty(STDIN_FILENO0) && isatty(STDOUT_FILENO1) && isatty(STDERR_FILENO2) ?
                      ARG_STDIO_PTY :
                      ARG_STDIO_DIRECT;
      }

      if ((optind >= argc) && (!arg_unit || !with_trigger)) {
              log_error("Command line to execute required.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 414, __func__, "Command line to execute required."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_user && arg_transport != BUS_TRANSPORT_LOCAL) {
              log_error("Execution in user context is not supported on non-local systems.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 419, __func__, "Execution in user context is not supported on non-local systems."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_scope && arg_transport != BUS_TRANSPORT_LOCAL) {
              log_error("Scope execution is not supported on non-local systems.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 424, __func__, "Scope execution is not supported on non-local systems."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_scope && (arg_remain_after_exit || arg_service_type)) {
              log_error("--remain-after-exit and --service-type= are not supported in --scope mode.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 429, __func__, "--remain-after-exit and --service-type= are not supported in --scope mode."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_stdio != ARG_STDIO_NONE && (with_trigger || arg_scope)) {
              log_error("--pty/--pipe is not compatible in timer or --scope mode.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 434, __func__, "--pty/--pipe is not compatible in timer or --scope mode."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_stdio != ARG_STDIO_NONE && arg_transport == BUS_TRANSPORT_REMOTE) {
              log_error("--pty/--pipe is only supported when connecting to the local system or containers.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 439, __func__, "--pty/--pipe is only supported when connecting to the local system or containers."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_stdio != ARG_STDIO_NONE && arg_no_block) {
              log_error("--pty/--pipe is not compatible with --no-block.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 444, __func__, "--pty/--pipe is not compatible with --no-block."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_scope && with_trigger) {
              log_error("Path, socket or timer options are not supported in --scope mode.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 449, __func__, "Path, socket or timer options are not supported in --scope mode."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_timer_property && !with_timer) {
              log_error("--timer-property= has no effect without any other timer options.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 454, __func__, "--timer-property= has no effect without any other timer options."
) : -abs(_e); });
              return -EINVAL22;
      }

      if (arg_wait) {
              if (arg_no_block) {
                      log_error("--wait may not be combined with --no-block.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 460, __func__, "--wait may not be combined with --no-block."
) : -abs(_e); });
                      return -EINVAL22;
              }

              if (with_trigger) {
                      log_error("--wait may not be combined with path, socket or timer operations.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 465, __func__, "--wait may not be combined with path, socket or timer operations."
) : -abs(_e); });
                      return -EINVAL22;
              }

              if (arg_scope) {
                      log_error("--wait may not be combined with --scope.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 470, __func__, "--wait may not be combined with --scope."
) : -abs(_e); });
                      return -EINVAL22;
              }
      }

      return 1;
476}

478static int transient_unit_set_properties(sd_bus_message *m, UnitType t, char **properties) {
      int r;

      r = sd_bus_message_append(m, "(sv)", "Description", "s", arg_description);
      if (r < 0)
              return bus_log_create_error(r);

      if (arg_aggressive_gc) {
              r = sd_bus_message_append(m, "(sv)", "CollectMode", "s", "inactive-or-failed");
              if (r < 0)
                      return bus_log_create_error(r);
      }

      r = bus_append_unit_property_assignment_many(m, t, properties);
      if (r < 0)
              return r;

      return 0;
496}

498static int transient_cgroup_set_properties(sd_bus_message *m) {
      int r;
      assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/run/run.c", 500, __PRETTY_FUNCTION__
); } while (0);

      if (!isempty(arg_slice)) {
              _cleanup_free___attribute__((cleanup(freep))) char *slice = NULL((void*)0);

              r = unit_name_mangle_with_suffix(arg_slice, arg_quiet ? 0 : UNIT_NAME_MANGLE_WARN, ".slice", &slice);
              if (r < 0)
                      return log_error_errno(r, "Failed to mangle name '%s': %m", arg_slice)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 507, __func__, "Failed to mangle name '%s': %m"
, arg_slice) : -abs(_e); });

              r = sd_bus_message_append(m, "(sv)", "Slice", "s", slice);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      return 0;
515}

517static int transient_kill_set_properties(sd_bus_message *m) {
      int r;

      assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/run/run.c", 520, __PRETTY_FUNCTION__
); } while (0);

      if (arg_send_sighup) {
              r = sd_bus_message_append(m, "(sv)", "SendSIGHUP", "b", arg_send_sighup);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      return 0;
529}

531static int transient_service_set_properties(sd_bus_message *m, char **argv, const char *pty_path) {
      bool_Bool send_term = false0;
      int r;

      assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/run/run.c", 535, __PRETTY_FUNCTION__
); } while (0);

      r = transient_unit_set_properties(m, UNIT_SERVICE, arg_property);
      if (r < 0)
              return r;

      r = transient_kill_set_properties(m);
      if (r < 0)
              return r;

      r = transient_cgroup_set_properties(m);
      if (r < 0)
              return r;

      if (arg_wait || arg_stdio != ARG_STDIO_NONE) {
              r = sd_bus_message_append(m, "(sv)", "AddRef", "b", 1);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      if (arg_remain_after_exit) {
              r = sd_bus_message_append(m, "(sv)", "RemainAfterExit", "b", arg_remain_after_exit);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      if (arg_service_type) {
              r = sd_bus_message_append(m, "(sv)", "Type", "s", arg_service_type);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      if (arg_exec_user) {
              r = sd_bus_message_append(m, "(sv)", "User", "s", arg_exec_user);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      if (arg_exec_group) {
              r = sd_bus_message_append(m, "(sv)", "Group", "s", arg_exec_group);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      if (arg_nice_set) {
              r = sd_bus_message_append(m, "(sv)", "Nice", "i", arg_nice);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      if (pty_path) {
              r = sd_bus_message_append(m,
                                        "(sv)(sv)(sv)(sv)",
                                        "StandardInput", "s", "tty",
                                        "StandardOutput", "s", "tty",
                                        "StandardError", "s", "tty",
                                        "TTYPath", "s", pty_path);
              if (r < 0)
                      return bus_log_create_error(r);

              send_term = true1;

      } else if (arg_stdio == ARG_STDIO_DIRECT) {
              r = sd_bus_message_append(m,
                                        "(sv)(sv)(sv)",
                                        "StandardInputFileDescriptor", "h", STDIN_FILENO0,
                                        "StandardOutputFileDescriptor", "h", STDOUT_FILENO1,
                                        "StandardErrorFileDescriptor", "h", STDERR_FILENO2);
              if (r < 0)
                      return bus_log_create_error(r);

              send_term = isatty(STDIN_FILENO0) || isatty(STDOUT_FILENO1) || isatty(STDERR_FILENO2);
      }

      if (send_term) {
              const char *e;

              e = getenv("TERM");
              if (e) {
                      char *n;

                      n = strjoina("TERM=", e)({ const char *_appendees_[] = { "TERM=", e }; char *_d_, *_p_
; size_t _len_ = 0; size_t _i_; for (_i_ = 0; _i_ < __extension__
 (__builtin_choose_expr( !__builtin_types_compatible_p(typeof
(_appendees_), typeof(&*(_appendees_))), sizeof(_appendees_
)/sizeof((_appendees_)[0]), ((void)0))) && _appendees_
[_i_]; _i_++) _len_ += strlen(_appendees_[_i_]); _p_ = _d_ = __builtin_alloca
 (_len_ + 1); for (_i_ = 0; _i_ < __extension__ (__builtin_choose_expr
( !__builtin_types_compatible_p(typeof(_appendees_), typeof(&
*(_appendees_))), sizeof(_appendees_)/sizeof((_appendees_)[0]
), ((void)0))) && _appendees_[_i_]; _i_++) _p_ = stpcpy
(_p_, _appendees_[_i_]); *_p_ = 0; _d_; });
                      r = sd_bus_message_append(m,
                                                "(sv)",
                                                "Environment", "as", 1, n);
                      if (r < 0)
                              return bus_log_create_error(r);
              }
      }

      if (!strv_isempty(arg_environment)) {
              r = sd_bus_message_open_container(m, 'r', "sv");
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_append(m, "s", "Environment");
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_open_container(m, 'v', "as");
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_append_strv(m, arg_environment);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_close_container(m);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_close_container(m);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      /* Exec container */
      {
              r = sd_bus_message_open_container(m, 'r', "sv");
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_append(m, "s", "ExecStart");
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_open_container(m, 'v', "a(sasb)");
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_open_container(m, 'a', "(sasb)");
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_open_container(m, 'r', "sasb");
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_append(m, "s", argv[0]);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_append_strv(m, argv);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_append(m, "b", false0);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_close_container(m);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_close_container(m);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_close_container(m);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_close_container(m);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      return 0;
703}

705static int transient_scope_set_properties(sd_bus_message *m) {
      int r;

      assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/run/run.c", 708, __PRETTY_FUNCTION__
); } while (0);

      r = transient_unit_set_properties(m, UNIT_SCOPE, arg_property);
      if (r < 0)
              return r;

      r = transient_kill_set_properties(m);
      if (r < 0)
              return r;

      r = transient_cgroup_set_properties(m);
      if (r < 0)
              return r;

      r = sd_bus_message_append(m, "(sv)", "PIDs", "au", 1, (uint32_t) getpid_cached());
      if (r < 0)
              return bus_log_create_error(r);

      return 0;
727}

729static int transient_timer_set_properties(sd_bus_message *m) {
      int r;

      assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/run/run.c", 732, __PRETTY_FUNCTION__
); } while (0);

      r = transient_unit_set_properties(m, UNIT_TIMER, arg_timer_property);
      if (r < 0)
              return r;

      /* Automatically clean up our transient timers */
      r = sd_bus_message_append(m, "(sv)", "RemainAfterElapse", "b", false0);
      if (r < 0)
              return bus_log_create_error(r);

      return 0;
744}

746static int make_unit_name(sd_bus *bus, UnitType t, char **ret) {
      const char *unique, *id;
      char *p;
      int r;

      assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/run/run.c", 751, __PRETTY_FUNCTION__
); } while (0);
      assert(t >= 0)do { if ((__builtin_expect(!!(!(t >= 0)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("t >= 0"), "../src/run/run.c", 752, __PRETTY_FUNCTION__
); } while (0);
      assert(t < _UNIT_TYPE_MAX)do { if ((__builtin_expect(!!(!(t < _UNIT_TYPE_MAX)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("t < _UNIT_TYPE_MAX"), "../src/run/run.c"
, 753, __PRETTY_FUNCTION__); } while (0);

      r = sd_bus_get_unique_name(bus, &unique);
      if (r < 0) {
              sd_id128_t rnd;

              /* We couldn't get the unique name, which is a pretty
               * common case if we are connected to systemd
               * directly. In that case, just pick a random uuid as
               * name */

              r = sd_id128_randomize(&rnd);
              if (r < 0)
                      return log_error_errno(r, "Failed to generate random run unit name: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 766, __func__, "Failed to generate random run unit name: %m"
) : -abs(_e); });

              if (asprintf(ret, "run-r" SD_ID128_FORMAT_STR"%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x" ".%s", SD_ID128_FORMAT_VAL(rnd)(rnd).bytes[0], (rnd).bytes[1], (rnd).bytes[2], (rnd).bytes[3
], (rnd).bytes[4], (rnd).bytes[5], (rnd).bytes[6], (rnd).bytes
[7], (rnd).bytes[8], (rnd).bytes[9], (rnd).bytes[10], (rnd).bytes
[11], (rnd).bytes[12], (rnd).bytes[13], (rnd).bytes[14], (rnd
).bytes[15], unit_type_to_string(t)) < 0)
                      return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 769, __func__
);

              return 0;
      }

      /* We managed to get the unique name, then let's use that to
       * name our transient units. */

      id = startswith(unique, ":1.");
      if (!id) {
              log_error("Unique name %s has unexpected format.", unique)({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 779, __func__, "Unique name %s has unexpected format."
, unique) : -abs(_e); });
              return -EINVAL22;
      }

      p = strjoin("run-u", id, ".", unit_type_to_string(t))strjoin_real(("run-u"), id, ".", unit_type_to_string(t), ((void
*)0));
      if (!p)
              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 785, __func__
);

      *ret = p;
      return 0;
789}

791typedef struct RunContext {
      sd_bus *bus;
      sd_event *event;
      PTYForward *forward;
      sd_bus_slot *match;

      /* The exit data of the unit */
      char *active_state;
      uint64_t inactive_exit_usec;
      uint64_t inactive_enter_usec;
      char *result;
      uint64_t cpu_usage_nsec;
      uint64_t ip_ingress_bytes;
      uint64_t ip_egress_bytes;
      uint32_t exit_code;
      uint32_t exit_status;
807} RunContext;

809static void run_context_free(RunContext *c) {
      assert(c)do { if ((__builtin_expect(!!(!(c)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("c"), "../src/run/run.c", 810, __PRETTY_FUNCTION__
); } while (0);

      c->forward = pty_forward_free(c->forward);
      c->match = sd_bus_slot_unref(c->match);
      c->bus = sd_bus_unref(c->bus);
      c->event = sd_event_unref(c->event);

      free(c->active_state);
      free(c->result);
819}

821static void run_context_check_done(RunContext *c) {
      bool_Bool done;

      assert(c)do { if ((__builtin_expect(!!(!(c)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("c"), "../src/run/run.c", 824, __PRETTY_FUNCTION__
); } while (0);

      if (c->match)
              done = STRPTR_IN_SET(c->active_state, "inactive", "failed")({ const char* _x = (c->active_state); _x && (!!strv_find
((((char**) ((const char*[]) { "inactive", "failed", ((void*)
0) }))), (_x))); });
      else
              done = true1;

      if (c->forward && done) /* If the service is gone, it's time to drain the output */
              done = pty_forward_drain(c->forward);

      if (done)
              sd_event_exit(c->event, EXIT_SUCCESS0);
836}

838static int run_context_update(RunContext *c, const char *path) {

      static const struct bus_properties_map map[] = {
              { "ActiveState",                      "s", NULL((void*)0), offsetof(RunContext, active_state)__builtin_offsetof(RunContext, active_state)        },
              { "InactiveExitTimestampMonotonic",   "t", NULL((void*)0), offsetof(RunContext, inactive_exit_usec)__builtin_offsetof(RunContext, inactive_exit_usec)  },
              { "InactiveEnterTimestampMonotonic",  "t", NULL((void*)0), offsetof(RunContext, inactive_enter_usec)__builtin_offsetof(RunContext, inactive_enter_usec) },
              { "Result",                           "s", NULL((void*)0), offsetof(RunContext, result)__builtin_offsetof(RunContext, result)              },
              { "ExecMainCode",                     "i", NULL((void*)0), offsetof(RunContext, exit_code)__builtin_offsetof(RunContext, exit_code)           },
              { "ExecMainStatus",                   "i", NULL((void*)0), offsetof(RunContext, exit_status)__builtin_offsetof(RunContext, exit_status)         },
              { "CPUUsageNSec",                     "t", NULL((void*)0), offsetof(RunContext, cpu_usage_nsec)__builtin_offsetof(RunContext, cpu_usage_nsec)      },
              { "IPIngressBytes",                   "t", NULL((void*)0), offsetof(RunContext, ip_ingress_bytes)__builtin_offsetof(RunContext, ip_ingress_bytes)    },
              { "IPEgressBytes",                    "t", NULL((void*)0), offsetof(RunContext, ip_egress_bytes)__builtin_offsetof(RunContext, ip_egress_bytes)     },
              {}
      };

      _cleanup_(sd_bus_error_free)__attribute__((cleanup(sd_bus_error_free))) sd_bus_error error = SD_BUS_ERROR_NULL((const sd_bus_error) {(((void*)0)), (((void*)0)), 0});
      int r;

      r = bus_map_all_properties(c->bus,
                                 "org.freedesktop.systemd1",
                                 path,
                                 map,
                                 BUS_MAP_STRDUP,
                                 &error,
                                 NULL((void*)0),
                                 c);
      if (r < 0) {
              sd_event_exit(c->event, EXIT_FAILURE1);
              return log_error_errno(r, "Failed to query unit state: %s", bus_error_message(&error, r))({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 866, __func__, "Failed to query unit state: %s"
, bus_error_message(&error, r)) : -abs(_e); });
      }

      run_context_check_done(c);
      return 0;
871}

873static int on_properties_changed(sd_bus_message *m, void *userdata, sd_bus_error *error) {
      RunContext *c = userdata;

      assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/run/run.c", 876, __PRETTY_FUNCTION__
); } while (0);
      assert(c)do { if ((__builtin_expect(!!(!(c)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("c"), "../src/run/run.c", 877, __PRETTY_FUNCTION__
); } while (0);

      return run_context_update(c, sd_bus_message_get_path(m));
880}

882static int pty_forward_handler(PTYForward *f, int rcode, void *userdata) {
      RunContext *c = userdata;

      assert(f)do { if ((__builtin_expect(!!(!(f)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("f"), "../src/run/run.c", 885, __PRETTY_FUNCTION__
); } while (0);

      if (rcode < 0) {
              sd_event_exit(c->event, EXIT_FAILURE1);
              return log_error_errno(rcode, "Error on PTY forwarding logic: %m")({ int _level = ((3)), _e = ((rcode)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 889, __func__, "Error on PTY forwarding logic: %m"
) : -abs(_e); });
      }

      run_context_check_done(c);
      return 0;
894}

896static int start_transient_service(
              sd_bus *bus,
              char **argv,
              int *retval) {

      _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = NULL((void*)0), *reply = NULL((void*)0);
      _cleanup_(sd_bus_error_free)__attribute__((cleanup(sd_bus_error_free))) sd_bus_error error = SD_BUS_ERROR_NULL((const sd_bus_error) {(((void*)0)), (((void*)0)), 0});
      _cleanup_(bus_wait_for_jobs_freep)__attribute__((cleanup(bus_wait_for_jobs_freep))) BusWaitForJobs *w = NULL((void*)0);
      _cleanup_free___attribute__((cleanup(freep))) char *service = NULL((void*)0), *pty_path = NULL((void*)0);
      _cleanup_close___attribute__((cleanup(closep))) int master = -1;
      int r;

      assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/run/run.c", 908, __PRETTY_FUNCTION__
); } while (0);
      assert(argv)do { if ((__builtin_expect(!!(!(argv)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("argv"), "../src/run/run.c", 909, __PRETTY_FUNCTION__
); } while (0);
      assert(retval)do { if ((__builtin_expect(!!(!(retval)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("retval"), "../src/run/run.c", 910, __PRETTY_FUNCTION__
); } while (0);

      if (arg_stdio == ARG_STDIO_PTY) {

              if (arg_transport == BUS_TRANSPORT_LOCAL) {
                      master = posix_openpt(O_RDWR02|O_NOCTTY0400|O_CLOEXEC02000000|O_NONBLOCK04000);
                      if (master < 0)
                              return log_error_errno(errno, "Failed to acquire pseudo tty: %m")({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
 = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
 ((_level) & 0x07)) ? log_internal_realm(((_realm) <<
| (_level)), _e, "../src/run/run.c", 917, __func__, "Failed to acquire pseudo tty: %m"
) : -abs(_e); });

                      r = ptsname_malloc(master, &pty_path);
                      if (r < 0)
                              return log_error_errno(r, "Failed to determine tty name: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 921, __func__, "Failed to determine tty name: %m"
) : -abs(_e); });

                      if (unlockpt(master) < 0)
                              return log_error_errno(errno, "Failed to unlock tty: %m")({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
 = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
 ((_level) & 0x07)) ? log_internal_realm(((_realm) <<
| (_level)), _e, "../src/run/run.c", 924, __func__, "Failed to unlock tty: %m"
) : -abs(_e); });

              } else if (arg_transport == BUS_TRANSPORT_MACHINE) {
                      _cleanup_(sd_bus_unrefp)__attribute__((cleanup(sd_bus_unrefp))) sd_bus *system_bus = NULL((void*)0);
                      _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *pty_reply = NULL((void*)0);
                      const char *s;

                      r = sd_bus_default_system(&system_bus);
                      if (r < 0)
                              return log_error_errno(r, "Failed to connect to system bus: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 933, __func__, "Failed to connect to system bus: %m"
) : -abs(_e); });

                      r = sd_bus_call_method(system_bus,
                                             "org.freedesktop.machine1",
                                             "/org/freedesktop/machine1",
                                             "org.freedesktop.machine1.Manager",
                                             "OpenMachinePTY",
                                             &error,
                                             &pty_reply,
                                             "s", arg_host);
                      if (r < 0)
                              return log_error_errno(r, "Failed to get machine PTY: %s", bus_error_message(&error, -r))({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 944, __func__, "Failed to get machine PTY: %s"
, bus_error_message(&error, -r)) : -abs(_e); });

                      r = sd_bus_message_read(pty_reply, "hs", &master, &s);
                      if (r < 0)
                              return bus_log_parse_error(r);

                      master = fcntl(master, F_DUPFD_CLOEXEC1030, 3);
                      if (master < 0)
                              return log_error_errno(errno, "Failed to duplicate master fd: %m")({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
 = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
 ((_level) & 0x07)) ? log_internal_realm(((_realm) <<
| (_level)), _e, "../src/run/run.c", 952, __func__, "Failed to duplicate master fd: %m"
) : -abs(_e); });

                      pty_path = strdup(s);
                      if (!pty_path)
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 956, __func__
);
              } else
                      assert_not_reached("Can't allocate tty via ssh")do { log_assert_failed_unreachable_realm(LOG_REALM_SYSTEMD, (
"Can't allocate tty via ssh"), "../src/run/run.c", 958, __PRETTY_FUNCTION__
); } while (0);
      }

      if (!arg_no_block) {
              r = bus_wait_for_jobs_new(bus, &w);
              if (r < 0)
                      return log_error_errno(r, "Could not watch jobs: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 964, __func__, "Could not watch jobs: %m"
) : -abs(_e); });
      }

      if (arg_unit) {
              r = unit_name_mangle_with_suffix(arg_unit, arg_quiet ? 0 : UNIT_NAME_MANGLE_WARN, ".service", &service);
              if (r < 0)
                      return log_error_errno(r, "Failed to mangle unit name: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 970, __func__, "Failed to mangle unit name: %m"
) : -abs(_e); });
      } else {
              r = make_unit_name(bus, UNIT_SERVICE, &service);
              if (r < 0)
                      return r;
      }

      r = sd_bus_message_new_method_call(
                      bus,
                      &m,
                      "org.freedesktop.systemd1",
                      "/org/freedesktop/systemd1",
                      "org.freedesktop.systemd1.Manager",
                      "StartTransientUnit");
      if (r < 0)
              return bus_log_create_error(r);

      r = sd_bus_message_set_allow_interactive_authorization(m, arg_ask_password);
      if (r < 0)
              return bus_log_create_error(r);

      /* Name and mode */
      r = sd_bus_message_append(m, "ss", service, "fail");
      if (r < 0)
              return bus_log_create_error(r);

      /* Properties */
      r = sd_bus_message_open_container(m, 'a', "(sv)");
      if (r < 0)
              return bus_log_create_error(r);

      r = transient_service_set_properties(m, argv, pty_path);
      if (r < 0)
              return r;

      r = sd_bus_message_close_container(m);
      if (r < 0)
              return bus_log_create_error(r);

      /* Auxiliary units */
      r = sd_bus_message_append(m, "a(sa(sv))", 0);
      if (r < 0)
              return bus_log_create_error(r);

      polkit_agent_open_if_enabled(arg_transport, arg_ask_password);

      r = sd_bus_call(bus, m, 0, &error, &reply);
      if (r < 0)
              return log_error_errno(r, "Failed to start transient service unit: %s", bus_error_message(&error, r))({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1018, __func__, "Failed to start transient service unit: %s"
, bus_error_message(&error, r)) : -abs(_e); });

      if (w) {
              const char *object;

              r = sd_bus_message_read(reply, "o", &object);
              if (r < 0)
                      return bus_log_parse_error(r);

              r = bus_wait_for_jobs_one(w, object, arg_quiet);
              if (r < 0)
                      return r;
      }

      if (!arg_quiet)
              log_info("Running as unit: %s", service)({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1033, __func__, "Running as unit: %s", service
) : -abs(_e); });

      if (arg_wait || arg_stdio != ARG_STDIO_NONE) {
              _cleanup_(run_context_free)__attribute__((cleanup(run_context_free))) RunContext c = {
                      .cpu_usage_nsec = NSEC_INFINITY((nsec_t) -1),
                      .ip_ingress_bytes = UINT64_MAX(18446744073709551615UL),
                      .ip_egress_bytes = UINT64_MAX(18446744073709551615UL),
                      .inactive_exit_usec = USEC_INFINITY((usec_t) -1),
                      .inactive_enter_usec = USEC_INFINITY((usec_t) -1),
              };
              _cleanup_free___attribute__((cleanup(freep))) char *path = NULL((void*)0);

              c.bus = sd_bus_ref(bus);

              r = sd_event_default(&c.event);
              if (r < 0)
                      return log_error_errno(r, "Failed to get event loop: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1049, __func__, "Failed to get event loop: %m"
) : -abs(_e); });

              if (master >= 0) {
                      assert_se(sigprocmask_many(SIG_BLOCK, NULL, SIGWINCH, SIGTERM, SIGINT, -1) >= 0)do { if ((__builtin_expect(!!(!(sigprocmask_many(0, ((void*)0
), 28, 15, 2, -1) >= 0)),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD
, ("sigprocmask_many(SIG_BLOCK, NULL, SIGWINCH, SIGTERM, SIGINT, -1) >= 0"
), "../src/run/run.c", 1052, __PRETTY_FUNCTION__); } while (0
);
                      (void) sd_event_add_signal(c.event, NULL((void*)0), SIGINT2, NULL((void*)0), NULL((void*)0));
                      (void) sd_event_add_signal(c.event, NULL((void*)0), SIGTERM15, NULL((void*)0), NULL((void*)0));

                      if (!arg_quiet)
                              log_info("Press ^] three times within 1s to disconnect TTY.")({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1057, __func__, "Press ^] three times within 1s to disconnect TTY."
) : -abs(_e); });

                      r = pty_forward_new(c.event, master, PTY_FORWARD_IGNORE_INITIAL_VHANGUP, &c.forward);
                      if (r < 0)
                              return log_error_errno(r, "Failed to create PTY forwarder: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1061, __func__, "Failed to create PTY forwarder: %m"
) : -abs(_e); });

                      pty_forward_set_handler(c.forward, pty_forward_handler, &c);

                      /* Make sure to process any TTY events before we process bus events */
                      (void) pty_forward_set_priority(c.forward, SD_EVENT_PRIORITY_IMPORTANT);
              }

              path = unit_dbus_path_from_name(service);
              if (!path)
                      return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1071,
 __func__);

              r = sd_bus_match_signal_async(
                              bus,
                              &c.match,
                              "org.freedesktop.systemd1",
                              path,
                              "org.freedesktop.DBus.Properties",
                              "PropertiesChanged",
                              on_properties_changed, NULL((void*)0), &c);
              if (r < 0)
                      return log_error_errno(r, "Failed to request properties changed signal match: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1082, __func__, "Failed to request properties changed signal match: %m"
) : -abs(_e); });

              r = sd_bus_attach_event(bus, c.event, SD_EVENT_PRIORITY_NORMAL);
              if (r < 0)
                      return log_error_errno(r, "Failed to attach bus to event loop: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1086, __func__, "Failed to attach bus to event loop: %m"
) : -abs(_e); });

              r = run_context_update(&c, path);
              if (r < 0)
                      return r;

              r = sd_event_loop(c.event);
              if (r < 0)
                      return log_error_errno(r, "Failed to run event loop: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1094, __func__, "Failed to run event loop: %m"
) : -abs(_e); });

              if (c.forward) {
                      char last_char = 0;

                      r = pty_forward_get_last_char(c.forward, &last_char);
                      if (r >= 0 && !arg_quiet && last_char != '\n')
                              fputc('\n', stdoutstdout);
              }

              if (arg_wait && !arg_quiet) {

                      /* Explicitly destroy the PTY forwarder, so that the PTY device is usable again, in its
                       * original settings (i.e. proper line breaks), so that we can show the summary in a pretty
                       * way. */
                      c.forward = pty_forward_free(c.forward);

                      if (!isempty(c.result))
                              log_info("Finished with result: %s", strna(c.result))({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1112, __func__, "Finished with result: %s"
, strna(c.result)) : -abs(_e); });

                      if (c.exit_code == CLD_EXITEDCLD_EXITED)
                              log_info("Main processes terminated with: code=%s/status=%i", sigchld_code_to_string(c.exit_code), c.exit_status)({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1115, __func__, "Main processes terminated with: code=%s/status=%i"
, sigchld_code_to_string(c.exit_code), c.exit_status) : -abs(
_e); });
                      else if (c.exit_code > 0)
                              log_info("Main processes terminated with: code=%s/status=%s", sigchld_code_to_string(c.exit_code), signal_to_string(c.exit_status))({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1117, __func__, "Main processes terminated with: code=%s/status=%s"
, sigchld_code_to_string(c.exit_code), signal_to_string(c.exit_status
)) : -abs(_e); });

                      if (c.inactive_enter_usec > 0 && c.inactive_enter_usec != USEC_INFINITY((usec_t) -1) &&
                          c.inactive_exit_usec > 0 && c.inactive_exit_usec != USEC_INFINITY((usec_t) -1) &&
                          c.inactive_enter_usec > c.inactive_exit_usec) {
                              char ts[FORMAT_TIMESPAN_MAX64];
                              log_info("Service runtime: %s", format_timespan(ts, sizeof(ts), c.inactive_enter_usec - c.inactive_exit_usec, USEC_PER_MSEC))({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1123, __func__, "Service runtime: %s", format_timespan
(ts, sizeof(ts), c.inactive_enter_usec - c.inactive_exit_usec
, ((usec_t) 1000ULL))) : -abs(_e); });
                      }

                      if (c.cpu_usage_nsec != NSEC_INFINITY((nsec_t) -1)) {
                              char ts[FORMAT_TIMESPAN_MAX64];
                              log_info("CPU time consumed: %s", format_timespan(ts, sizeof(ts), (c.cpu_usage_nsec + NSEC_PER_USEC - 1) / NSEC_PER_USEC, USEC_PER_MSEC))({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1128, __func__, "CPU time consumed: %s"
, format_timespan(ts, sizeof(ts), (c.cpu_usage_nsec + ((nsec_t
) 1000ULL) - 1) / ((nsec_t) 1000ULL), ((usec_t) 1000ULL))) : -
abs(_e); });
                      }

                      if (c.ip_ingress_bytes != UINT64_MAX(18446744073709551615UL)) {
                              char bytes[FORMAT_BYTES_MAX8];
                              log_info("IP traffic received: %s", format_bytes(bytes, sizeof(bytes), c.ip_ingress_bytes))({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1133, __func__, "IP traffic received: %s"
, format_bytes(bytes, sizeof(bytes), c.ip_ingress_bytes)) : -
abs(_e); });
                      }
                      if (c.ip_egress_bytes != UINT64_MAX(18446744073709551615UL)) {
                              char bytes[FORMAT_BYTES_MAX8];
                              log_info("IP traffic sent: %s", format_bytes(bytes, sizeof(bytes), c.ip_egress_bytes))({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1137, __func__, "IP traffic sent: %s", format_bytes
(bytes, sizeof(bytes), c.ip_egress_bytes)) : -abs(_e); });
                      }
              }

              /* Try to propagate the service's return value */
              if (c.result && STR_IN_SET(c.result, "success", "exit-code")(!!strv_find((((char**) ((const char*[]) { "success", "exit-code"
, ((void*)0) }))), (c.result))) && c.exit_code == CLD_EXITEDCLD_EXITED)
                      *retval = c.exit_status;
              else
                      *retval = EXIT_FAILURE1;
      }

      return 0;
1149}

1151static int start_transient_scope(
              sd_bus *bus,
              char **argv) {

      _cleanup_(sd_bus_error_free)__attribute__((cleanup(sd_bus_error_free))) sd_bus_error error = SD_BUS_ERROR_NULL((const sd_bus_error) {(((void*)0)), (((void*)0)), 0});
      _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = NULL((void*)0), *reply = NULL((void*)0);
      _cleanup_(bus_wait_for_jobs_freep)__attribute__((cleanup(bus_wait_for_jobs_freep))) BusWaitForJobs *w = NULL((void*)0);
      _cleanup_strv_free___attribute__((cleanup(strv_freep))) char **env = NULL((void*)0), **user_env = NULL((void*)0);
      _cleanup_free___attribute__((cleanup(freep))) char *scope = NULL((void*)0);
      const char *object = NULL((void*)0);
      int r;

      assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/run/run.c", 1163, __PRETTY_FUNCTION__
); } while (0);
      assert(argv)do { if ((__builtin_expect(!!(!(argv)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("argv"), "../src/run/run.c", 1164, __PRETTY_FUNCTION__
); } while (0);

      r = bus_wait_for_jobs_new(bus, &w);
      if (r < 0)
              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1168,
 __func__);

      if (arg_unit) {
              r = unit_name_mangle_with_suffix(arg_unit, arg_quiet ? 0 : UNIT_NAME_MANGLE_WARN, ".scope", &scope);
              if (r < 0)
                      return log_error_errno(r, "Failed to mangle scope name: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1173, __func__, "Failed to mangle scope name: %m"
) : -abs(_e); });
      } else {
              r = make_unit_name(bus, UNIT_SCOPE, &scope);
              if (r < 0)
                      return r;
      }

      r = sd_bus_message_new_method_call(
                      bus,
                      &m,
                      "org.freedesktop.systemd1",
                      "/org/freedesktop/systemd1",
                      "org.freedesktop.systemd1.Manager",
                      "StartTransientUnit");
      if (r < 0)
              return bus_log_create_error(r);

      r = sd_bus_message_set_allow_interactive_authorization(m, arg_ask_password);
      if (r < 0)
              return bus_log_create_error(r);

      /* Name and Mode */
      r = sd_bus_message_append(m, "ss", scope, "fail");
      if (r < 0)
              return bus_log_create_error(r);

      /* Properties */
      r = sd_bus_message_open_container(m, 'a', "(sv)");
      if (r < 0)
              return bus_log_create_error(r);

      r = transient_scope_set_properties(m);
      if (r < 0)
              return r;

      r = sd_bus_message_close_container(m);
      if (r < 0)
              return bus_log_create_error(r);

      /* Auxiliary units */
      r = sd_bus_message_append(m, "a(sa(sv))", 0);
      if (r < 0)
              return bus_log_create_error(r);

      polkit_agent_open_if_enabled(arg_transport, arg_ask_password);

      r = sd_bus_call(bus, m, 0, &error, &reply);
      if (r < 0)
              return log_error_errno(r, "Failed to start transient scope unit: %s", bus_error_message(&error, -r))({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1221, __func__, "Failed to start transient scope unit: %s"
, bus_error_message(&error, -r)) : -abs(_e); });

      if (arg_nice_set) {
              if (setpriority(PRIO_PROCESSPRIO_PROCESS, 0, arg_nice) < 0)
                      return log_error_errno(errno, "Failed to set nice level: %m")({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
 = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
 ((_level) & 0x07)) ? log_internal_realm(((_realm) <<
| (_level)), _e, "../src/run/run.c", 1225, __func__, "Failed to set nice level: %m"
) : -abs(_e); });
      }

      if (arg_exec_group) {
              gid_t gid;

              r = get_group_creds(&arg_exec_group, &gid);
              if (r < 0)
                      return log_error_errno(r, "Failed to resolve group %s: %m", arg_exec_group)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1233, __func__, "Failed to resolve group %s: %m"
, arg_exec_group) : -abs(_e); });

              if (setresgid(gid, gid, gid) < 0)
                      return log_error_errno(errno, "Failed to change GID to " GID_FMT ": %m", gid)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
 = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
 ((_level) & 0x07)) ? log_internal_realm(((_realm) <<
| (_level)), _e, "../src/run/run.c", 1236, __func__, "Failed to change GID to "
 "%" "u" ": %m", gid) : -abs(_e); });
      }

      if (arg_exec_user) {
              const char *home, *shell;
              uid_t uid;
              gid_t gid;

              r = get_user_creds_clean(&arg_exec_user, &uid, &gid, &home, &shell);
              if (r < 0)
                      return log_error_errno(r, "Failed to resolve user %s: %m", arg_exec_user)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1246, __func__, "Failed to resolve user %s: %m"
, arg_exec_user) : -abs(_e); });

              if (home) {
                      r = strv_extendf(&user_env, "HOME=%s", home);
                      if (r < 0)
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1251,
 __func__);
              }

              if (shell) {
                      r = strv_extendf(&user_env, "SHELL=%s", shell);
                      if (r < 0)
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1257,
 __func__);
              }

              r = strv_extendf(&user_env, "USER=%s", arg_exec_user);
              if (r < 0)
                      return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1262,
 __func__);

              r = strv_extendf(&user_env, "LOGNAME=%s", arg_exec_user);
              if (r < 0)
                      return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1266,
 __func__);

              if (!arg_exec_group) {
                      if (setresgid(gid, gid, gid) < 0)
                              return log_error_errno(errno, "Failed to change GID to " GID_FMT ": %m", gid)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
 = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
 ((_level) & 0x07)) ? log_internal_realm(((_realm) <<
| (_level)), _e, "../src/run/run.c", 1270, __func__, "Failed to change GID to "
 "%" "u" ": %m", gid) : -abs(_e); });
              }

              if (setresuid(uid, uid, uid) < 0)
                      return log_error_errno(errno, "Failed to change UID to " UID_FMT ": %m", uid)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
 = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
 ((_level) & 0x07)) ? log_internal_realm(((_realm) <<
| (_level)), _e, "../src/run/run.c", 1274, __func__, "Failed to change UID to "
 "%" "u" ": %m", uid) : -abs(_e); });
      }

      env = strv_env_merge(3, environ, user_env, arg_environment);
      if (!env)
              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1279,
 __func__);

      r = sd_bus_message_read(reply, "o", &object);
      if (r < 0)
              return bus_log_parse_error(r);

      r = bus_wait_for_jobs_one(w, object, arg_quiet);
      if (r < 0)
              return r;

      if (!arg_quiet)
              log_info("Running scope as unit: %s", scope)({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1290, __func__, "Running scope as unit: %s"
, scope) : -abs(_e); });

      execvpe(argv[0], argv, env);

      return log_error_errno(errno, "Failed to execute: %m")({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
 = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
 ((_level) & 0x07)) ? log_internal_realm(((_realm) <<
| (_level)), _e, "../src/run/run.c", 1294, __func__, "Failed to execute: %m"
) : -abs(_e); });
1295}

1297static int start_transient_trigger(
              sd_bus *bus,
              char **argv,
              const char *suffix) {

      _cleanup_(sd_bus_error_free)__attribute__((cleanup(sd_bus_error_free))) sd_bus_error error = SD_BUS_ERROR_NULL((const sd_bus_error) {(((void*)0)), (((void*)0)), 0});
      _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = NULL((void*)0), *reply = NULL((void*)0);
      _cleanup_(bus_wait_for_jobs_freep)__attribute__((cleanup(bus_wait_for_jobs_freep))) BusWaitForJobs *w = NULL((void*)0);
      _cleanup_free___attribute__((cleanup(freep))) char *trigger = NULL((void*)0), *service = NULL((void*)0);
      const char *object = NULL((void*)0);
      int r;

      assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/run/run.c", 1309, __PRETTY_FUNCTION__
); } while (0);
1
Assuming 'bus' is non-null→
2
←
Taking false branch→
3
←
Loop condition is false.  Exiting loop→
      assert(argv)do { if ((__builtin_expect(!!(!(argv)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("argv"), "../src/run/run.c", 1310, __PRETTY_FUNCTION__
); } while (0);
4
←
Assuming 'argv' is non-null→
5
←
Taking false branch→
6
←
Loop condition is false.  Exiting loop→

      r = bus_wait_for_jobs_new(bus, &w);
      if (r < 0)
7
←
Assuming 'r' is >= 0→
8
←
Taking false branch→
              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1314,
 __func__);

      if (arg_unit) {
9
←
Assuming 'arg_unit' is non-null→
10
←
Taking true branch→
              switch (unit_name_to_type(arg_unit)) {
11
←
Control jumps to 'case UNIT_TIMER:'  at line 1329→

              case UNIT_SERVICE:
                      service = strdup(arg_unit);
                      if (!service)
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1322,
 __func__);

                      r = unit_name_change_suffix(service, suffix, &trigger);
                      if (r < 0)
                              return log_error_errno(r, "Failed to change unit suffix: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1326, __func__, "Failed to change unit suffix: %m"
) : -abs(_e); });
                      break;

              case UNIT_TIMER:
                      trigger = strdup(arg_unit);
12
←
Memory is allocated→
                      if (!trigger)
13
←
Assuming 'trigger' is non-null→
14
←
Taking false branch→
                              return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1332,
 __func__);

                      r = unit_name_change_suffix(trigger, ".service", &service);
                      if (r < 0)
15
←
Assuming 'r' is < 0→
16
←
Taking true branch→
                              return log_error_errno(r, "Failed to change unit suffix: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1336, __func__, "Failed to change unit suffix: %m"
) : -abs(_e); });
17
←
Potential leak of memory pointed to by 'trigger'
                      break;

              default:
                      r = unit_name_mangle_with_suffix(arg_unit, arg_quiet ? 0 : UNIT_NAME_MANGLE_WARN, ".service", &service);
                      if (r < 0)
                              return log_error_errno(r, "Failed to mangle unit name: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1342, __func__, "Failed to mangle unit name: %m"
) : -abs(_e); });

                      r = unit_name_mangle_with_suffix(arg_unit, arg_quiet ? 0 : UNIT_NAME_MANGLE_WARN, suffix, &trigger);
                      if (r < 0)
                              return log_error_errno(r, "Failed to mangle unit name: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1346, __func__, "Failed to mangle unit name: %m"
) : -abs(_e); });

                      break;
              }
      } else {
              r = make_unit_name(bus, UNIT_SERVICE, &service);
              if (r < 0)
                      return r;

              r = unit_name_change_suffix(service, suffix, &trigger);
              if (r < 0)
                      return log_error_errno(r, "Failed to change unit suffix: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1357, __func__, "Failed to change unit suffix: %m"
) : -abs(_e); });
      }

      r = sd_bus_message_new_method_call(
                      bus,
                      &m,
                      "org.freedesktop.systemd1",
                      "/org/freedesktop/systemd1",
                      "org.freedesktop.systemd1.Manager",
                      "StartTransientUnit");
      if (r < 0)
              return bus_log_create_error(r);

      r = sd_bus_message_set_allow_interactive_authorization(m, arg_ask_password);
      if (r < 0)
              return bus_log_create_error(r);

      /* Name and Mode */
      r = sd_bus_message_append(m, "ss", trigger, "fail");
      if (r < 0)
              return bus_log_create_error(r);

      /* Properties */
      r = sd_bus_message_open_container(m, 'a', "(sv)");
      if (r < 0)
              return bus_log_create_error(r);

      if (streq(suffix, ".path")(strcmp((suffix),(".path")) == 0))
              r = transient_unit_set_properties(m, UNIT_PATH, arg_path_property);
      else if (streq(suffix, ".socket")(strcmp((suffix),(".socket")) == 0))
              r = transient_unit_set_properties(m, UNIT_SOCKET, arg_socket_property);
      else if (streq(suffix, ".timer")(strcmp((suffix),(".timer")) == 0))
              r = transient_timer_set_properties(m);
      else
              assert_not_reached("Invalid suffix")do { log_assert_failed_unreachable_realm(LOG_REALM_SYSTEMD, (
"Invalid suffix"), "../src/run/run.c", 1391, __PRETTY_FUNCTION__
); } while (0);
      if (r < 0)
              return r;

      r = sd_bus_message_close_container(m);
      if (r < 0)
              return bus_log_create_error(r);

      r = sd_bus_message_open_container(m, 'a', "(sa(sv))");
      if (r < 0)
              return bus_log_create_error(r);

      if (!strv_isempty(argv)) {
              r = sd_bus_message_open_container(m, 'r', "sa(sv)");
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_append(m, "s", service);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_open_container(m, 'a', "(sv)");
              if (r < 0)
                      return bus_log_create_error(r);

              r = transient_service_set_properties(m, argv, NULL((void*)0));
              if (r < 0)
                      return r;

              r = sd_bus_message_close_container(m);
              if (r < 0)
                      return bus_log_create_error(r);

              r = sd_bus_message_close_container(m);
              if (r < 0)
                      return bus_log_create_error(r);
      }

      r = sd_bus_message_close_container(m);
      if (r < 0)
              return bus_log_create_error(r);

      polkit_agent_open_if_enabled(arg_transport, arg_ask_password);

      r = sd_bus_call(bus, m, 0, &error, &reply);
      if (r < 0)
              return log_error_errno(r, "Failed to start transient %s unit: %s", suffix + 1, bus_error_message(&error, -r))({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1437, __func__, "Failed to start transient %s unit: %s"
, suffix + 1, bus_error_message(&error, -r)) : -abs(_e); }
);

      r = sd_bus_message_read(reply, "o", &object);
      if (r < 0)
              return bus_log_parse_error(r);

      r = bus_wait_for_jobs_one(w, object, arg_quiet);
      if (r < 0)
              return r;

      if (!arg_quiet) {
              log_info("Running %s as unit: %s", suffix + 1, trigger)({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1448, __func__, "Running %s as unit: %s"
, suffix + 1, trigger) : -abs(_e); });
              if (argv[0])
                      log_info("Will run service as unit: %s", service)({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1450, __func__, "Will run service as unit: %s"
, service) : -abs(_e); });
      }

      return 0;
1454}

1456int main(int argc, char* argv[]) {
      _cleanup_(sd_bus_flush_close_unrefp)__attribute__((cleanup(sd_bus_flush_close_unrefp))) sd_bus *bus = NULL((void*)0);
      _cleanup_free___attribute__((cleanup(freep))) char *description = NULL((void*)0), *command = NULL((void*)0);
      int r, retval = EXIT_SUCCESS0;

      log_parse_environment()log_parse_environment_realm(LOG_REALM_SYSTEMD);
      log_open();

      r = parse_argv(argc, argv);
      if (r <= 0)
              goto finish;

      if (argc > optind && arg_transport == BUS_TRANSPORT_LOCAL) {
              /* Patch in an absolute path */

              r = find_binary(argv[optind], &command);
              if (r < 0) {
                      log_error_errno(r, "Failed to find executable %s: %m", argv[optind])({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1473, __func__, "Failed to find executable %s: %m"
, argv[optind]) : -abs(_e); });
                      goto finish;
              }

              argv[optind] = command;
      }

      if (!arg_description) {
              description = strv_join(argv + optind, " ");
              if (!description) {
                      r = log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/run/run.c", 1483,
 __func__);
                      goto finish;
              }

              if (arg_unit && isempty(description)) {
                      r = free_and_strdup(&description, arg_unit);
                      if (r < 0)
                              goto finish;
              }

              arg_description = description;
      }

      /* If --wait is used connect via the bus, unconditionally, as ref/unref is not supported via the limited direct
       * connection */
      if (arg_wait || arg_stdio != ARG_STDIO_NONE)
              r = bus_connect_transport(arg_transport, arg_host, arg_user, &bus);
      else
              r = bus_connect_transport_systemd(arg_transport, arg_host, arg_user, &bus);
      if (r < 0) {
              log_error_errno(r, "Failed to create bus connection: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/run/run.c", 1503, __func__, "Failed to create bus connection: %m"
) : -abs(_e); });
              goto finish;
      }

      if (arg_scope)
              r = start_transient_scope(bus, argv + optind);
      else if (arg_path_property)
              r = start_transient_trigger(bus, argv + optind, ".path");
      else if (arg_socket_property)
              r = start_transient_trigger(bus, argv + optind, ".socket");
      else if (with_timer)
              r = start_transient_trigger(bus, argv + optind, ".timer");
      else
              r = start_transient_service(bus, argv + optind, &retval);

1518finish:
      strv_free(arg_environment);
      strv_free(arg_property);
      strv_free(arg_path_property);
      strv_free(arg_socket_property);
      strv_free(arg_timer_property);

      return r < 0 ? EXIT_FAILURE1 : retval;
1526}