machinectl: port machinectl to new verbs logic
This commit is contained in:
parent
7eeeb28e45
commit
56159e0d91
|
@ -50,6 +50,7 @@
|
||||||
#include "path-util.h"
|
#include "path-util.h"
|
||||||
#include "mkdir.h"
|
#include "mkdir.h"
|
||||||
#include "copy.h"
|
#include "copy.h"
|
||||||
|
#include "verbs.h"
|
||||||
|
|
||||||
static char **arg_property = NULL;
|
static char **arg_property = NULL;
|
||||||
static bool arg_all = false;
|
static bool arg_all = false;
|
||||||
|
@ -72,13 +73,17 @@ static void pager_open_if_enabled(void) {
|
||||||
pager_open(false);
|
pager_open(false);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int list_machines(sd_bus *bus, char **args, unsigned n) {
|
static int list_machines(int argc, char *argv[], void *userdata) {
|
||||||
|
|
||||||
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
|
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
|
||||||
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
||||||
const char *name, *class, *service, *object;
|
const char *name, *class, *service, *object;
|
||||||
|
sd_bus *bus = userdata;
|
||||||
unsigned k = 0;
|
unsigned k = 0;
|
||||||
int r;
|
int r;
|
||||||
|
|
||||||
|
assert(bus);
|
||||||
|
|
||||||
pager_open_if_enabled();
|
pager_open_if_enabled();
|
||||||
|
|
||||||
r = sd_bus_call_method(
|
r = sd_bus_call_method(
|
||||||
|
@ -132,7 +137,7 @@ static int compare_image_info(const void *a, const void *b) {
|
||||||
return strcmp(x->name, y->name);
|
return strcmp(x->name, y->name);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int list_images(sd_bus *bus, char **args, unsigned n) {
|
static int list_images(int argc, char *argv[], void *userdata) {
|
||||||
|
|
||||||
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
||||||
size_t max_name = strlen("NAME"), max_type = strlen("TYPE");
|
size_t max_name = strlen("NAME"), max_type = strlen("TYPE");
|
||||||
|
@ -140,9 +145,12 @@ static int list_images(sd_bus *bus, char **args, unsigned n) {
|
||||||
_cleanup_free_ ImageInfo *images = NULL;
|
_cleanup_free_ ImageInfo *images = NULL;
|
||||||
size_t n_images = 0, n_allocated = 0, j;
|
size_t n_images = 0, n_allocated = 0, j;
|
||||||
const char *name, *type, *object;
|
const char *name, *type, *object;
|
||||||
|
sd_bus *bus = userdata;
|
||||||
int read_only;
|
int read_only;
|
||||||
int r;
|
int r;
|
||||||
|
|
||||||
|
assert(bus);
|
||||||
|
|
||||||
pager_open_if_enabled();
|
pager_open_if_enabled();
|
||||||
|
|
||||||
r = sd_bus_call_method(
|
r = sd_bus_call_method(
|
||||||
|
@ -389,6 +397,7 @@ static void print_machine_status_info(sd_bus *bus, MachineStatusInfo *i) {
|
||||||
char since2[FORMAT_TIMESTAMP_MAX], *s2;
|
char since2[FORMAT_TIMESTAMP_MAX], *s2;
|
||||||
int ifi = -1;
|
int ifi = -1;
|
||||||
|
|
||||||
|
assert(bus);
|
||||||
assert(i);
|
assert(i);
|
||||||
|
|
||||||
fputs(strna(i->name), stdout);
|
fputs(strna(i->name), stdout);
|
||||||
|
@ -505,6 +514,8 @@ static int show_info(const char *verb, sd_bus *bus, const char *path, bool *new_
|
||||||
MachineStatusInfo info = {};
|
MachineStatusInfo info = {};
|
||||||
int r;
|
int r;
|
||||||
|
|
||||||
|
assert(verb);
|
||||||
|
assert(bus);
|
||||||
assert(path);
|
assert(path);
|
||||||
assert(new_line);
|
assert(new_line);
|
||||||
|
|
||||||
|
@ -535,6 +546,10 @@ static int show_info(const char *verb, sd_bus *bus, const char *path, bool *new_
|
||||||
static int show_properties(sd_bus *bus, const char *path, bool *new_line) {
|
static int show_properties(sd_bus *bus, const char *path, bool *new_line) {
|
||||||
int r;
|
int r;
|
||||||
|
|
||||||
|
assert(bus);
|
||||||
|
assert(path);
|
||||||
|
assert(new_line);
|
||||||
|
|
||||||
if (*new_line)
|
if (*new_line)
|
||||||
printf("\n");
|
printf("\n");
|
||||||
|
|
||||||
|
@ -547,21 +562,21 @@ static int show_properties(sd_bus *bus, const char *path, bool *new_line) {
|
||||||
return r;
|
return r;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int show(sd_bus *bus, char **args, unsigned n) {
|
static int show(int argc, char *argv[], void *userdata) {
|
||||||
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
|
|
||||||
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
||||||
int r = 0;
|
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
|
||||||
unsigned i;
|
|
||||||
bool properties, new_line = false;
|
bool properties, new_line = false;
|
||||||
|
sd_bus *bus = userdata;
|
||||||
|
int r = 0, i;
|
||||||
|
|
||||||
assert(bus);
|
assert(bus);
|
||||||
assert(args);
|
|
||||||
|
|
||||||
properties = !strstr(args[0], "status");
|
properties = !strstr(argv[0], "status");
|
||||||
|
|
||||||
pager_open_if_enabled();
|
pager_open_if_enabled();
|
||||||
|
|
||||||
if (properties && n <= 1) {
|
if (properties && argc <= 1) {
|
||||||
|
|
||||||
/* If no argument is specified, inspect the manager
|
/* If no argument is specified, inspect the manager
|
||||||
* itself */
|
* itself */
|
||||||
|
@ -570,7 +585,7 @@ static int show(sd_bus *bus, char **args, unsigned n) {
|
||||||
return r;
|
return r;
|
||||||
}
|
}
|
||||||
|
|
||||||
for (i = 1; i < n; i++) {
|
for (i = 1; i < argc; i++) {
|
||||||
const char *path = NULL;
|
const char *path = NULL;
|
||||||
|
|
||||||
r = sd_bus_call_method(
|
r = sd_bus_call_method(
|
||||||
|
@ -581,7 +596,7 @@ static int show(sd_bus *bus, char **args, unsigned n) {
|
||||||
"GetMachine",
|
"GetMachine",
|
||||||
&error,
|
&error,
|
||||||
&reply,
|
&reply,
|
||||||
"s", args[i]);
|
"s", argv[i]);
|
||||||
if (r < 0) {
|
if (r < 0) {
|
||||||
log_error("Could not get path to machine: %s", bus_error_message(&error, -r));
|
log_error("Could not get path to machine: %s", bus_error_message(&error, -r));
|
||||||
return r;
|
return r;
|
||||||
|
@ -594,22 +609,23 @@ static int show(sd_bus *bus, char **args, unsigned n) {
|
||||||
if (properties)
|
if (properties)
|
||||||
r = show_properties(bus, path, &new_line);
|
r = show_properties(bus, path, &new_line);
|
||||||
else
|
else
|
||||||
r = show_info(args[0], bus, path, &new_line);
|
r = show_info(argv[0], bus, path, &new_line);
|
||||||
}
|
}
|
||||||
|
|
||||||
return r;
|
return r;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int kill_machine(sd_bus *bus, char **args, unsigned n) {
|
static int kill_machine(int argc, char *argv[], void *userdata) {
|
||||||
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
||||||
unsigned i;
|
sd_bus *bus = userdata;
|
||||||
|
int i;
|
||||||
|
|
||||||
assert(args);
|
assert(bus);
|
||||||
|
|
||||||
if (!arg_kill_who)
|
if (!arg_kill_who)
|
||||||
arg_kill_who = "all";
|
arg_kill_who = "all";
|
||||||
|
|
||||||
for (i = 1; i < n; i++) {
|
for (i = 1; i < argc; i++) {
|
||||||
int r;
|
int r;
|
||||||
|
|
||||||
r = sd_bus_call_method(
|
r = sd_bus_call_method(
|
||||||
|
@ -620,7 +636,7 @@ static int kill_machine(sd_bus *bus, char **args, unsigned n) {
|
||||||
"KillMachine",
|
"KillMachine",
|
||||||
&error,
|
&error,
|
||||||
NULL,
|
NULL,
|
||||||
"ssi", args[i], arg_kill_who, arg_signal);
|
"ssi", argv[i], arg_kill_who, arg_signal);
|
||||||
if (r < 0) {
|
if (r < 0) {
|
||||||
log_error("Could not kill machine: %s", bus_error_message(&error, -r));
|
log_error("Could not kill machine: %s", bus_error_message(&error, -r));
|
||||||
return r;
|
return r;
|
||||||
|
@ -630,27 +646,28 @@ static int kill_machine(sd_bus *bus, char **args, unsigned n) {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int reboot_machine(sd_bus *bus, char **args, unsigned n) {
|
static int reboot_machine(int argc, char *argv[], void *userdata) {
|
||||||
arg_kill_who = "leader";
|
arg_kill_who = "leader";
|
||||||
arg_signal = SIGINT; /* sysvinit + systemd */
|
arg_signal = SIGINT; /* sysvinit + systemd */
|
||||||
|
|
||||||
return kill_machine(bus, args, n);
|
return kill_machine(argc, argv, userdata);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int poweroff_machine(sd_bus *bus, char **args, unsigned n) {
|
static int poweroff_machine(int argc, char *argv[], void *userdata) {
|
||||||
arg_kill_who = "leader";
|
arg_kill_who = "leader";
|
||||||
arg_signal = SIGRTMIN+4; /* only systemd */
|
arg_signal = SIGRTMIN+4; /* only systemd */
|
||||||
|
|
||||||
return kill_machine(bus, args, n);
|
return kill_machine(argc, argv, userdata);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int terminate_machine(sd_bus *bus, char **args, unsigned n) {
|
static int terminate_machine(int argc, char *argv[], void *userdata) {
|
||||||
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
||||||
unsigned i;
|
sd_bus *bus = userdata;
|
||||||
|
int i;
|
||||||
|
|
||||||
assert(args);
|
assert(bus);
|
||||||
|
|
||||||
for (i = 1; i < n; i++) {
|
for (i = 1; i < argc; i++) {
|
||||||
int r;
|
int r;
|
||||||
|
|
||||||
r = sd_bus_call_method(
|
r = sd_bus_call_method(
|
||||||
|
@ -661,7 +678,7 @@ static int terminate_machine(sd_bus *bus, char **args, unsigned n) {
|
||||||
"TerminateMachine",
|
"TerminateMachine",
|
||||||
&error,
|
&error,
|
||||||
NULL,
|
NULL,
|
||||||
"s", args[i]);
|
"s", argv[i]);
|
||||||
if (r < 0) {
|
if (r < 0) {
|
||||||
log_error("Could not terminate machine: %s", bus_error_message(&error, -r));
|
log_error("Could not terminate machine: %s", bus_error_message(&error, -r));
|
||||||
return r;
|
return r;
|
||||||
|
@ -720,23 +737,21 @@ static int machine_get_leader(sd_bus *bus, const char *name, pid_t *ret) {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int copy_files(sd_bus *bus, char **args, unsigned n) {
|
static int copy_files(int argc, char *argv[], void *userdata) {
|
||||||
char *dest, *host_path, *container_path, *host_dirname, *host_basename, *container_dirname, *container_basename, *t;
|
char *dest, *host_path, *container_path, *host_dirname, *host_basename, *container_dirname, *container_basename, *t;
|
||||||
_cleanup_close_ int hostfd = -1;
|
_cleanup_close_ int hostfd = -1;
|
||||||
|
sd_bus *bus = userdata;
|
||||||
pid_t child, leader;
|
pid_t child, leader;
|
||||||
bool copy_from;
|
bool copy_from;
|
||||||
siginfo_t si;
|
siginfo_t si;
|
||||||
int r;
|
int r;
|
||||||
|
|
||||||
if (n > 4) {
|
assert(bus);
|
||||||
log_error("Too many arguments.");
|
|
||||||
return -EINVAL;
|
|
||||||
}
|
|
||||||
|
|
||||||
copy_from = streq(args[0], "copy-from");
|
copy_from = streq(argv[0], "copy-from");
|
||||||
dest = args[3] ?: args[2];
|
dest = argv[3] ?: argv[2];
|
||||||
host_path = strdupa(copy_from ? dest : args[2]);
|
host_path = strdupa(copy_from ? dest : argv[2]);
|
||||||
container_path = strdupa(copy_from ? args[2] : dest);
|
container_path = strdupa(copy_from ? argv[2] : dest);
|
||||||
|
|
||||||
if (!path_is_absolute(container_path)) {
|
if (!path_is_absolute(container_path)) {
|
||||||
log_error("Container path not absolute.");
|
log_error("Container path not absolute.");
|
||||||
|
@ -751,7 +766,7 @@ static int copy_files(sd_bus *bus, char **args, unsigned n) {
|
||||||
container_basename = basename(t);
|
container_basename = basename(t);
|
||||||
container_dirname = dirname(container_path);
|
container_dirname = dirname(container_path);
|
||||||
|
|
||||||
r = machine_get_leader(bus, args[1], &leader);
|
r = machine_get_leader(bus, argv[1], &leader);
|
||||||
if (r < 0)
|
if (r < 0)
|
||||||
return r;
|
return r;
|
||||||
|
|
||||||
|
@ -811,8 +826,9 @@ static int copy_files(sd_bus *bus, char **args, unsigned n) {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int bind_mount(sd_bus *bus, char **args, unsigned n) {
|
static int bind_mount(int argc, char *argv[], void *userdata) {
|
||||||
char mount_slave[] = "/tmp/propagate.XXXXXX", *mount_tmp, *mount_outside, *p;
|
char mount_slave[] = "/tmp/propagate.XXXXXX", *mount_tmp, *mount_outside, *p;
|
||||||
|
sd_bus *bus = userdata;
|
||||||
pid_t child, leader;
|
pid_t child, leader;
|
||||||
const char *dest;
|
const char *dest;
|
||||||
siginfo_t si;
|
siginfo_t si;
|
||||||
|
@ -821,28 +837,25 @@ static int bind_mount(sd_bus *bus, char **args, unsigned n) {
|
||||||
mount_outside_created = false, mount_outside_mounted = false;
|
mount_outside_created = false, mount_outside_mounted = false;
|
||||||
int r;
|
int r;
|
||||||
|
|
||||||
|
assert(bus);
|
||||||
|
|
||||||
/* One day, when bind mounting /proc/self/fd/n works across
|
/* One day, when bind mounting /proc/self/fd/n works across
|
||||||
* namespace boundaries we should rework this logic to make
|
* namespace boundaries we should rework this logic to make
|
||||||
* use of it... */
|
* use of it... */
|
||||||
|
|
||||||
if (n > 4) {
|
dest = argv[3] ?: argv[2];
|
||||||
log_error("Too many arguments.");
|
|
||||||
return -EINVAL;
|
|
||||||
}
|
|
||||||
|
|
||||||
dest = args[3] ?: args[2];
|
|
||||||
if (!path_is_absolute(dest)) {
|
if (!path_is_absolute(dest)) {
|
||||||
log_error("Destination path not absolute.");
|
log_error("Destination path not absolute.");
|
||||||
return -EINVAL;
|
return -EINVAL;
|
||||||
}
|
}
|
||||||
|
|
||||||
p = strappenda("/run/systemd/nspawn/propagate/", args[1], "/");
|
p = strappenda("/run/systemd/nspawn/propagate/", argv[1], "/");
|
||||||
if (access(p, F_OK) < 0) {
|
if (access(p, F_OK) < 0) {
|
||||||
log_error("Container does not allow propagation of mount points.");
|
log_error("Container does not allow propagation of mount points.");
|
||||||
return -ENOTSUP;
|
return -ENOTSUP;
|
||||||
}
|
}
|
||||||
|
|
||||||
r = machine_get_leader(bus, args[1], &leader);
|
r = machine_get_leader(bus, argv[1], &leader);
|
||||||
if (r < 0)
|
if (r < 0)
|
||||||
return r;
|
return r;
|
||||||
|
|
||||||
|
@ -882,7 +895,7 @@ static int bind_mount(sd_bus *bus, char **args, unsigned n) {
|
||||||
|
|
||||||
mount_tmp_created = true;
|
mount_tmp_created = true;
|
||||||
|
|
||||||
if (mount(args[2], mount_tmp, NULL, MS_BIND, NULL) < 0) {
|
if (mount(argv[2], mount_tmp, NULL, MS_BIND, NULL) < 0) {
|
||||||
r = log_error_errno(errno, "Failed to overmount: %m");
|
r = log_error_errno(errno, "Failed to overmount: %m");
|
||||||
goto finish;
|
goto finish;
|
||||||
}
|
}
|
||||||
|
@ -900,7 +913,7 @@ static int bind_mount(sd_bus *bus, char **args, unsigned n) {
|
||||||
* directory. This way it will appear there read-only
|
* directory. This way it will appear there read-only
|
||||||
* right-away. */
|
* right-away. */
|
||||||
|
|
||||||
mount_outside = strappenda("/run/systemd/nspawn/propagate/", args[1], "/XXXXXX");
|
mount_outside = strappenda("/run/systemd/nspawn/propagate/", argv[1], "/XXXXXX");
|
||||||
if (!mkdtemp(mount_outside)) {
|
if (!mkdtemp(mount_outside)) {
|
||||||
r = log_error_errno(errno, "Cannot create propagation directory: %m");
|
r = log_error_errno(errno, "Cannot create propagation directory: %m");
|
||||||
goto finish;
|
goto finish;
|
||||||
|
@ -1013,6 +1026,8 @@ static int openpt_in_namespace(pid_t pid, int flags) {
|
||||||
pid_t child;
|
pid_t child;
|
||||||
siginfo_t si;
|
siginfo_t si;
|
||||||
|
|
||||||
|
assert(pid > 0);
|
||||||
|
|
||||||
r = namespace_open(pid, &pidnsfd, &mntnsfd, NULL, &rootfd);
|
r = namespace_open(pid, &pidnsfd, &mntnsfd, NULL, &rootfd);
|
||||||
if (r < 0)
|
if (r < 0)
|
||||||
return r;
|
return r;
|
||||||
|
@ -1082,7 +1097,7 @@ static int openpt_in_namespace(pid_t pid, int flags) {
|
||||||
return master;
|
return master;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int login_machine(sd_bus *bus, char **args, unsigned n) {
|
static int login_machine(int argc, char *argv[], void *userdata) {
|
||||||
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
|
||||||
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
|
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
|
||||||
_cleanup_bus_close_unref_ sd_bus *container_bus = NULL;
|
_cleanup_bus_close_unref_ sd_bus *container_bus = NULL;
|
||||||
|
@ -1090,13 +1105,13 @@ static int login_machine(sd_bus *bus, char **args, unsigned n) {
|
||||||
_cleanup_event_unref_ sd_event *event = NULL;
|
_cleanup_event_unref_ sd_event *event = NULL;
|
||||||
_cleanup_close_ int master = -1;
|
_cleanup_close_ int master = -1;
|
||||||
_cleanup_free_ char *getty = NULL;
|
_cleanup_free_ char *getty = NULL;
|
||||||
|
sd_bus *bus = userdata;
|
||||||
const char *pty, *p;
|
const char *pty, *p;
|
||||||
pid_t leader;
|
pid_t leader;
|
||||||
sigset_t mask;
|
sigset_t mask;
|
||||||
int r, ret = 0;
|
int r, ret = 0;
|
||||||
|
|
||||||
assert(bus);
|
assert(bus);
|
||||||
assert(args);
|
|
||||||
|
|
||||||
if (arg_transport != BUS_TRANSPORT_LOCAL) {
|
if (arg_transport != BUS_TRANSPORT_LOCAL) {
|
||||||
log_error("Login only supported on local machines.");
|
log_error("Login only supported on local machines.");
|
||||||
|
@ -1111,7 +1126,7 @@ static int login_machine(sd_bus *bus, char **args, unsigned n) {
|
||||||
if (r < 0)
|
if (r < 0)
|
||||||
return log_error_errno(r, "Failed to attach bus to event loop: %m");
|
return log_error_errno(r, "Failed to attach bus to event loop: %m");
|
||||||
|
|
||||||
r = machine_get_leader(bus, args[1], &leader);
|
r = machine_get_leader(bus, argv[1], &leader);
|
||||||
if (r < 0)
|
if (r < 0)
|
||||||
return r;
|
return r;
|
||||||
|
|
||||||
|
@ -1129,7 +1144,7 @@ static int login_machine(sd_bus *bus, char **args, unsigned n) {
|
||||||
return -EIO;
|
return -EIO;
|
||||||
}
|
}
|
||||||
|
|
||||||
r = sd_bus_open_system_container(&container_bus, args[1]);
|
r = sd_bus_open_system_container(&container_bus, argv[1]);
|
||||||
if (r < 0)
|
if (r < 0)
|
||||||
return log_error_errno(r, "Failed to get container bus: %m");
|
return log_error_errno(r, "Failed to get container bus: %m");
|
||||||
|
|
||||||
|
@ -1158,7 +1173,7 @@ static int login_machine(sd_bus *bus, char **args, unsigned n) {
|
||||||
sigset_add_many(&mask, SIGWINCH, SIGTERM, SIGINT, -1);
|
sigset_add_many(&mask, SIGWINCH, SIGTERM, SIGINT, -1);
|
||||||
assert_se(sigprocmask(SIG_BLOCK, &mask, NULL) == 0);
|
assert_se(sigprocmask(SIG_BLOCK, &mask, NULL) == 0);
|
||||||
|
|
||||||
log_info("Connected to container %s. Press ^] three times within 1s to exit session.", args[1]);
|
log_info("Connected to container %s. Press ^] three times within 1s to exit session.", argv[1]);
|
||||||
|
|
||||||
sd_event_add_signal(event, NULL, SIGINT, NULL, NULL);
|
sd_event_add_signal(event, NULL, SIGINT, NULL, NULL);
|
||||||
sd_event_add_signal(event, NULL, SIGTERM, NULL, NULL);
|
sd_event_add_signal(event, NULL, SIGTERM, NULL, NULL);
|
||||||
|
@ -1175,13 +1190,14 @@ static int login_machine(sd_bus *bus, char **args, unsigned n) {
|
||||||
|
|
||||||
fputc('\n', stdout);
|
fputc('\n', stdout);
|
||||||
|
|
||||||
log_info("Connection to container %s terminated.", args[1]);
|
log_info("Connection to container %s terminated.", argv[1]);
|
||||||
|
|
||||||
sd_event_get_exit_code(event, &ret);
|
sd_event_get_exit_code(event, &ret);
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
static void help(void) {
|
static int help(int argc, char *argv[], void *userdata) {
|
||||||
|
|
||||||
printf("%s [OPTIONS...] {COMMAND} ...\n\n"
|
printf("%s [OPTIONS...] {COMMAND} ...\n\n"
|
||||||
"Send control commands to or query the virtual machine and container\n"
|
"Send control commands to or query the virtual machine and container\n"
|
||||||
"registration manager.\n\n"
|
"registration manager.\n\n"
|
||||||
|
@ -1213,6 +1229,8 @@ static void help(void) {
|
||||||
"Image commands:\n"
|
"Image commands:\n"
|
||||||
" list-images Show available images\n",
|
" list-images Show available images\n",
|
||||||
program_invocation_short_name);
|
program_invocation_short_name);
|
||||||
|
|
||||||
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int parse_argv(int argc, char *argv[]) {
|
static int parse_argv(int argc, char *argv[]) {
|
||||||
|
@ -1253,8 +1271,7 @@ static int parse_argv(int argc, char *argv[]) {
|
||||||
switch (c) {
|
switch (c) {
|
||||||
|
|
||||||
case 'h':
|
case 'h':
|
||||||
help();
|
return help(0, NULL, NULL);
|
||||||
return 0;
|
|
||||||
|
|
||||||
case ARG_VERSION:
|
case ARG_VERSION:
|
||||||
puts(PACKAGE_STRING);
|
puts(PACKAGE_STRING);
|
||||||
|
@ -1328,90 +1345,26 @@ static int parse_argv(int argc, char *argv[]) {
|
||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int machinectl_main(sd_bus *bus, int argc, char *argv[]) {
|
static int machinectl_main(int argc, char *argv[], sd_bus *bus) {
|
||||||
|
|
||||||
static const struct {
|
static const Verb verbs[] = {
|
||||||
const char* verb;
|
{ "help", VERB_ANY, VERB_ANY, 0, help },
|
||||||
const enum {
|
{ "list", VERB_ANY, 1, VERB_DEFAULT, list_machines },
|
||||||
MORE,
|
{ "list-images", VERB_ANY, 1, 0, list_images },
|
||||||
LESS,
|
{ "status", 2, VERB_ANY, 0, show },
|
||||||
EQUAL
|
{ "show", VERB_ANY, VERB_ANY, 0, show },
|
||||||
} argc_cmp;
|
{ "terminate", 2, VERB_ANY, 0, terminate_machine },
|
||||||
const int argc;
|
{ "reboot", 2, VERB_ANY, 0, reboot_machine },
|
||||||
int (* const dispatch)(sd_bus *bus, char **args, unsigned n);
|
{ "poweroff", 2, VERB_ANY, 0, poweroff_machine },
|
||||||
} verbs[] = {
|
{ "kill", 2, VERB_ANY, 0, kill_machine },
|
||||||
{ "list", LESS, 1, list_machines },
|
{ "login", 2, 2, 0, login_machine },
|
||||||
{ "list-images", LESS, 1, list_images },
|
{ "bind", 3, 4, 0, bind_mount },
|
||||||
{ "status", MORE, 2, show },
|
{ "copy-to", 3, 4, 0, copy_files },
|
||||||
{ "show", MORE, 1, show },
|
{ "copy-from", 3, 4, 0, copy_files },
|
||||||
{ "terminate", MORE, 2, terminate_machine },
|
{}
|
||||||
{ "reboot", MORE, 2, reboot_machine },
|
|
||||||
{ "poweroff", MORE, 2, poweroff_machine },
|
|
||||||
{ "kill", MORE, 2, kill_machine },
|
|
||||||
{ "login", MORE, 2, login_machine },
|
|
||||||
{ "bind", MORE, 3, bind_mount },
|
|
||||||
{ "copy-to", MORE, 3, copy_files },
|
|
||||||
{ "copy-from", MORE, 3, copy_files },
|
|
||||||
};
|
};
|
||||||
|
|
||||||
int left;
|
return dispatch_verb(argc, argv, verbs, bus);
|
||||||
unsigned i;
|
|
||||||
|
|
||||||
assert(argc >= 0);
|
|
||||||
assert(argv);
|
|
||||||
|
|
||||||
left = argc - optind;
|
|
||||||
|
|
||||||
if (left <= 0)
|
|
||||||
/* Special rule: no arguments means "list" */
|
|
||||||
i = 0;
|
|
||||||
else {
|
|
||||||
if (streq(argv[optind], "help")) {
|
|
||||||
help();
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
for (i = 0; i < ELEMENTSOF(verbs); i++)
|
|
||||||
if (streq(argv[optind], verbs[i].verb))
|
|
||||||
break;
|
|
||||||
|
|
||||||
if (i >= ELEMENTSOF(verbs)) {
|
|
||||||
log_error("Unknown operation %s", argv[optind]);
|
|
||||||
return -EINVAL;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
switch (verbs[i].argc_cmp) {
|
|
||||||
|
|
||||||
case EQUAL:
|
|
||||||
if (left != verbs[i].argc) {
|
|
||||||
log_error("Invalid number of arguments.");
|
|
||||||
return -EINVAL;
|
|
||||||
}
|
|
||||||
|
|
||||||
break;
|
|
||||||
|
|
||||||
case MORE:
|
|
||||||
if (left < verbs[i].argc) {
|
|
||||||
log_error("Too few arguments.");
|
|
||||||
return -EINVAL;
|
|
||||||
}
|
|
||||||
|
|
||||||
break;
|
|
||||||
|
|
||||||
case LESS:
|
|
||||||
if (left > verbs[i].argc) {
|
|
||||||
log_error("Too many arguments.");
|
|
||||||
return -EINVAL;
|
|
||||||
}
|
|
||||||
|
|
||||||
break;
|
|
||||||
|
|
||||||
default:
|
|
||||||
assert_not_reached("Unknown comparison operator.");
|
|
||||||
}
|
|
||||||
|
|
||||||
return verbs[i].dispatch(bus, argv + optind, left);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
int main(int argc, char*argv[]) {
|
int main(int argc, char*argv[]) {
|
||||||
|
@ -1432,7 +1385,7 @@ int main(int argc, char*argv[]) {
|
||||||
goto finish;
|
goto finish;
|
||||||
}
|
}
|
||||||
|
|
||||||
r = machinectl_main(bus, argc, argv);
|
r = machinectl_main(argc, argv, bus);
|
||||||
|
|
||||||
finish:
|
finish:
|
||||||
pager_close();
|
pager_close();
|
||||||
|
|
Loading…
Reference in a new issue