]>
Commit | Line | Data |
---|---|---|
70a5db58 LP |
1 | /* SPDX-License-Identifier: LGPL-2.1+ */ |
2 | ||
3 | #include "fd-util.h" | |
4 | #include "homed-operation.h" | |
5 | ||
6 | Operation *operation_new(OperationType type, sd_bus_message *m) { | |
7 | Operation *o; | |
8 | ||
9 | assert(type >= 0); | |
10 | assert(type < _OPERATION_MAX); | |
11 | ||
12 | o = new(Operation, 1); | |
13 | if (!o) | |
14 | return NULL; | |
15 | ||
16 | *o = (Operation) { | |
17 | .type = type, | |
18 | .n_ref = 1, | |
19 | .message = sd_bus_message_ref(m), | |
20 | .send_fd = -1, | |
21 | .result = -1, | |
22 | }; | |
23 | ||
24 | return o; | |
25 | } | |
26 | ||
27 | static Operation *operation_free(Operation *o) { | |
28 | int r; | |
29 | ||
30 | if (!o) | |
31 | return NULL; | |
32 | ||
33 | if (o->message && o->result >= 0) { | |
34 | ||
35 | if (o->result) { | |
36 | /* Propagate success */ | |
37 | if (o->send_fd < 0) | |
38 | r = sd_bus_reply_method_return(o->message, NULL); | |
39 | else | |
40 | r = sd_bus_reply_method_return(o->message, "h", o->send_fd); | |
41 | ||
42 | } else { | |
43 | /* Propagate failure */ | |
44 | if (sd_bus_error_is_set(&o->error)) | |
45 | r = sd_bus_reply_method_error(o->message, &o->error); | |
46 | else | |
47 | r = sd_bus_reply_method_errnof(o->message, o->ret, "Failed to execute operation: %m"); | |
48 | } | |
49 | if (r < 0) | |
80ace4f2 | 50 | log_warning_errno(r, "Failed to reply to %s method call, ignoring: %m", sd_bus_message_get_member(o->message)); |
70a5db58 LP |
51 | } |
52 | ||
53 | sd_bus_message_unref(o->message); | |
54 | user_record_unref(o->secret); | |
55 | safe_close(o->send_fd); | |
56 | sd_bus_error_free(&o->error); | |
57 | ||
58 | return mfree(o); | |
59 | } | |
60 | ||
61 | DEFINE_TRIVIAL_REF_UNREF_FUNC(Operation, operation, operation_free); | |
62 | ||
63 | void operation_result(Operation *o, int ret, const sd_bus_error *error) { | |
64 | assert(o); | |
65 | ||
66 | if (ret >= 0) | |
67 | o->result = true; | |
68 | else { | |
69 | o->ret = ret; | |
70 | ||
71 | sd_bus_error_free(&o->error); | |
72 | sd_bus_error_copy(&o->error, error); | |
73 | ||
74 | o->result = false; | |
75 | } | |
76 | } |