X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Flibsystemd-bus%2Fbus-internal.h;h=a599e5ab81b95177acfc305643ddff58082513c2;hb=49cf4ece205bf23c39c30a633a20e22260fc1706;hp=5fc3a2472ec91689b26f0154d73d41d0ff1ad498;hpb=7a4a210539396ac5c9b9469fb03866ddb6d09fb2;p=elogind.git diff --git a/src/libsystemd-bus/bus-internal.h b/src/libsystemd-bus/bus-internal.h index 5fc3a2472..a599e5ab8 100644 --- a/src/libsystemd-bus/bus-internal.h +++ b/src/libsystemd-bus/bus-internal.h @@ -119,11 +119,12 @@ enum bus_state { BUS_AUTHENTICATING, BUS_HELLO, BUS_RUNNING, + BUS_CLOSING, BUS_CLOSED }; static inline bool BUS_IS_OPEN(enum bus_state state) { - return state > BUS_UNSET && state < BUS_CLOSED; + return state > BUS_UNSET && state < BUS_CLOSING; } enum bus_auth { @@ -146,6 +147,7 @@ struct sd_bus { enum bus_state state; int input_fd, output_fd; int message_version; + int message_endian; bool is_kernel:1; bool can_fds:1; @@ -155,10 +157,10 @@ struct sd_bus { bool anonymous_auth:1; bool prefer_readv:1; bool prefer_writev:1; - bool processing:1; bool match_callbacks_modified:1; bool filter_callbacks_modified:1; bool nodes_modified:1; + bool trusted:1; int use_memfd; @@ -166,7 +168,7 @@ struct sd_bus { size_t rbuffer_size; sd_bus_message **rqueue; - unsigned rqueue_size; + unsigned rqueue_size, rqueue_allocated; sd_bus_message **wqueue; unsigned wqueue_size; @@ -175,6 +177,7 @@ struct sd_bus { uint64_t serial; char *unique_name; + uint64_t unique_id; struct bus_match_node match_callbacks; Prioq *reply_callbacks_prioq; @@ -182,8 +185,6 @@ struct sd_bus { LIST_HEAD(struct filter_callback, filter_callbacks); Hashmap *nodes; - - Hashmap *vtable_methods; Hashmap *vtable_properties; @@ -215,6 +216,8 @@ struct sd_bus { struct ucred ucred; char label[NAME_MAX]; + uint64_t creds_mask; + int *fds; unsigned n_fds; @@ -239,6 +242,7 @@ struct sd_bus { pid_t original_pid; uint64_t hello_flags; + uint64_t attach_flags; uint64_t match_cookie; @@ -247,8 +251,12 @@ struct sd_bus { sd_event_source *time_event_source; sd_event_source *quit_event_source; sd_event *event; + int event_priority; sd_bus_message *current; + + sd_bus **default_bus_ptr; + pid_t tid; }; #define BUS_DEFAULT_TIMEOUT ((usec_t) (25 * USEC_PER_SEC)) @@ -290,6 +298,10 @@ int bus_ensure_running(sd_bus *bus); int bus_start_running(sd_bus *bus); int bus_next_address(sd_bus *bus); +int bus_seal_synthetic_message(sd_bus *b, sd_bus_message *m); + +int bus_rqueue_make_room(sd_bus *bus); + bool bus_pid_changed(sd_bus *bus); char *bus_address_escape(const char *v); @@ -303,4 +315,4 @@ char *bus_address_escape(const char *v); * bus from the callback doesn't destroy the object we are working * on */ #define BUS_DONT_DESTROY(bus) \ - _cleanup_bus_unref_ sd_bus *_dont_destroy_##bus = sd_bus_ref(bus) + _cleanup_bus_unref_ _unused_ sd_bus *_dont_destroy_##bus = sd_bus_ref(bus)