chiark
/
gitweb
/
~ianmdlvl
/
elogind.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
bus: update bus_map_all_properties()
[elogind.git]
/
src
/
machine
/
machine.c
diff --git
a/src/machine/machine.c
b/src/machine/machine.c
index 8e03ff2ec1eaa5942ffdb5426325f94989617e0c..a33a111043c586b81c1eb9edd0149d16ae35a96a 100644
(file)
--- a/
src/machine/machine.c
+++ b/
src/machine/machine.c
@@
-23,7
+23,7
@@
#include <unistd.h>
#include <errno.h>
#include <unistd.h>
#include <errno.h>
-#include
<systemd/sd-messages.h>
+#include
"sd-messages.h"
#include "util.h"
#include "mkdir.h"
#include "util.h"
#include "mkdir.h"
@@
-32,8
+32,9
@@
#include "fileio.h"
#include "special.h"
#include "unit-name.h"
#include "fileio.h"
#include "special.h"
#include "unit-name.h"
-#include "dbus-common.h"
#include "machine.h"
#include "machine.h"
+#include "bus-util.h"
+#include "bus-error.h"
Machine* machine_new(Manager *manager, const char *name) {
Machine *m;
Machine* machine_new(Manager *manager, const char *name) {
Machine *m;
@@
-73,7
+74,7
@@
void machine_free(Machine *m) {
assert(m);
if (m->in_gc_queue)
assert(m);
if (m->in_gc_queue)
- LIST_REMOVE(
Machine,
gc_queue, m->manager->machine_gc_queue, m);
+ LIST_REMOVE(gc_queue, m->manager->machine_gc_queue, m);
if (m->scope) {
hashmap_remove(m->manager->machine_units, m->scope);
if (m->scope) {
hashmap_remove(m->manager->machine_units, m->scope);
@@
-84,8
+85,7
@@
void machine_free(Machine *m) {
hashmap_remove(m->manager->machines, m->name);
hashmap_remove(m->manager->machines, m->name);
- if (m->create_message)
- dbus_message_unref(m->create_message);
+ sd_bus_message_unref(m->create_message);
free(m->name);
free(m->state_file);
free(m->name);
free(m->state_file);
@@
-217,36
+217,30
@@
int machine_load(Machine *m) {
return r;
}
return r;
}
-static int machine_start_scope(Machine *m) {
- _cleanup_free_ char *description = NULL;
- DBusError error;
- char *job;
- int r;
+static int machine_start_scope(Machine *m, sd_bus_message *properties, sd_bus_error *error) {
+ int r = 0;
assert(m);
assert(m);
- dbus_error_init(&error);
-
if (!m->scope) {
_cleanup_free_ char *escaped = NULL;
if (!m->scope) {
_cleanup_free_ char *escaped = NULL;
- char *scope;
+ char *scope
, *description, *job
;
escaped = unit_name_escape(m->name);
if (!escaped)
return log_oom();
scope = strjoin("machine-", escaped, ".scope", NULL);
escaped = unit_name_escape(m->name);
if (!escaped)
return log_oom();
scope = strjoin("machine-", escaped, ".scope", NULL);
- if (scope)
+ if (
!
scope)
return log_oom();
return log_oom();
- description = strappend(m->class == MACHINE_VM ? "Virtual Machine " : "Container ", m->name);
+ description = strappend
a
(m->class == MACHINE_VM ? "Virtual Machine " : "Container ", m->name);
- r = manager_start_scope(m->manager,
m->scope, m->leader, SPECIAL_MACHINE_SLICE, description, &
error, &job);
+ r = manager_start_scope(m->manager,
scope, m->leader, SPECIAL_MACHINE_SLICE, description, properties,
error, &job);
if (r < 0) {
if (r < 0) {
- log_error("Failed to start machine scope: %s", bus_error(&error, r));
- dbus_error_free(&error);
-
+ log_error("Failed to start machine scope: %s", bus_error_message(error, r));
free(scope);
free(scope);
+ return r;
} else {
m->scope = scope;
} else {
m->scope = scope;
@@
-261,7
+255,7
@@
static int machine_start_scope(Machine *m) {
return r;
}
return r;
}
-int machine_start(Machine *m) {
+int machine_start(Machine *m
, sd_bus_message *properties, sd_bus_error *error
) {
int r;
assert(m);
int r;
assert(m);
@@
-270,7
+264,7
@@
int machine_start(Machine *m) {
return 0;
/* Create cgroup */
return 0;
/* Create cgroup */
- r = machine_start_scope(m);
+ r = machine_start_scope(m
, properties, error
);
if (r < 0)
return r;
if (r < 0)
return r;
@@
-295,21
+289,18
@@
int machine_start(Machine *m) {
}
static int machine_stop_scope(Machine *m) {
}
static int machine_stop_scope(Machine *m) {
-
DBusError error
;
+
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL
;
char *job;
int r;
assert(m);
char *job;
int r;
assert(m);
- dbus_error_init(&error);
-
if (!m->scope)
return 0;
r = manager_stop_unit(m->manager, m->scope, &error, &job);
if (r < 0) {
if (!m->scope)
return 0;
r = manager_stop_unit(m->manager, m->scope, &error, &job);
if (r < 0) {
- log_error("Failed to stop machine scope: %s", bus_error(&error, r));
- dbus_error_free(&error);
+ log_error("Failed to stop machine scope: %s", bus_error_message(&error, r));
return r;
}
return r;
}
@@
-347,19
+338,19
@@
int machine_stop(Machine *m) {
return r;
}
return r;
}
-
int
machine_check_gc(Machine *m, bool drop_not_started) {
+
bool
machine_check_gc(Machine *m, bool drop_not_started) {
assert(m);
if (drop_not_started && !m->started)
assert(m);
if (drop_not_started && !m->started)
- return
0
;
+ return
false
;
- if (m->scope_job)
- return
1
;
+ if (m->scope_job
&& manager_job_is_active(m->manager, m->scope_job)
)
+ return
true
;
- if (m->scope)
- return
manager_unit_is_active(m->manager, m->scope) != 0
;
+ if (m->scope
&& manager_unit_is_active(m->manager, m->scope)
)
+ return
true
;
- return
0
;
+ return
false
;
}
void machine_add_to_gc_queue(Machine *m) {
}
void machine_add_to_gc_queue(Machine *m) {
@@
-368,7
+359,7
@@
void machine_add_to_gc_queue(Machine *m) {
if (m->in_gc_queue)
return;
if (m->in_gc_queue)
return;
- LIST_PREPEND(
Machine,
gc_queue, m->manager->machine_gc_queue, m);
+ LIST_PREPEND(gc_queue, m->manager->machine_gc_queue, m);
m->in_gc_queue = true;
}
m->in_gc_queue = true;
}