X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?p=elogind.git;a=blobdiff_plain;f=src%2Flibsystemd-bus%2Fbus-internal.h;h=4881e0427c9ae8bbec29377db6e325512f56bc27;hp=faed183990ac77dc895f524f08bea9d3afc83a52;hb=c0a0913218f900e76984179ab959d8fb12bef1fb;hpb=d7726e578a1e4218c769d436c1a23174d1aed92d diff --git a/src/libsystemd-bus/bus-internal.h b/src/libsystemd-bus/bus-internal.h index faed18399..4881e0427 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 { @@ -155,7 +156,6 @@ 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; @@ -166,7 +166,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 +175,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 +183,6 @@ struct sd_bus { LIST_HEAD(struct filter_callback, filter_callbacks); Hashmap *nodes; - - Hashmap *vtable_methods; Hashmap *vtable_properties; @@ -215,6 +214,8 @@ struct sd_bus { struct ucred ucred; char label[NAME_MAX]; + uint64_t creds_mask; + int *fds; unsigned n_fds; @@ -239,6 +240,7 @@ struct sd_bus { pid_t original_pid; uint64_t hello_flags; + uint64_t attach_flags; uint64_t match_cookie; @@ -274,7 +276,6 @@ struct sd_bus { bool interface_name_is_valid(const char *p); bool service_name_is_valid(const char *p); -bool sender_name_is_valid(const char *p); bool member_name_is_valid(const char *p); bool object_path_is_valid(const char *p); char *object_path_startswith(const char *a, const char *b); @@ -294,6 +295,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);