X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Flibsystemd-bus%2Fbus-message.h;h=2cd1ef257d9f52cf75ce8bb37f6138d9c549313b;hb=4a875b6133c9ef0e984547f7ce3b09356be4f7bc;hp=0184d18dd9a0afca1195073c0e94adeafdb57411;hpb=89ffcd2ad5bf87866314e96c4179ba622851cd6e;p=elogind.git diff --git a/src/libsystemd-bus/bus-message.h b/src/libsystemd-bus/bus-message.h index 0184d18dd..2cd1ef257 100644 --- a/src/libsystemd-bus/bus-message.h +++ b/src/libsystemd-bus/bus-message.h @@ -23,9 +23,12 @@ #include #include +#include #include "macro.h" #include "sd-bus.h" +#include "kdbus.h" +#include "time-util.h" struct bus_container { char enclosing; @@ -37,7 +40,7 @@ struct bus_container { size_t begin; }; -_packed_ struct bus_header { +struct bus_header { uint8_t endian; uint8_t type; uint8_t flags; @@ -45,7 +48,7 @@ _packed_ struct bus_header { uint32_t body_size; uint32_t serial; uint32_t fields_size; -}; +} _packed_; struct sd_bus_message { unsigned n_ref; @@ -64,18 +67,27 @@ struct sd_bus_message { gid_t gid; pid_t pid; pid_t tid; + usec_t pid_starttime; + usec_t monotonic; + usec_t realtime; bool sealed:1; + bool dont_send:1; + bool allow_fds:1; bool uid_valid:1; bool gid_valid:1; bool free_header:1; bool free_fields:1; bool free_body:1; - bool dont_send:1; + bool free_kdbus:1; + bool free_fds:1; struct bus_header *header; void *fields; void *body; + struct kdbus_msg *kdbus; + + char *label; size_t rindex; @@ -85,10 +97,24 @@ struct sd_bus_message { struct bus_container root_container, *containers; unsigned n_containers; - struct iovec iovec[4]; + struct iovec iovec[3]; unsigned n_iovec; char *peeked_signature; + + usec_t timeout; + + char sender_buffer[3 + DECIMAL_STR_MAX(uint64_t) + 1]; + char destination_buffer[3 + DECIMAL_STR_MAX(uint64_t) + 1]; + + const char *exe; + const char *comm; + const char *tid_comm; + const char *cgroup; + + const char *cmdline; + size_t cmdline_length; + char **cmdline_array; }; #define BUS_MESSAGE_NEED_BSWAP(m) ((m)->header->endian != SD_BUS_NATIVE_ENDIAN) @@ -117,6 +143,13 @@ static inline uint32_t BUS_MESSAGE_FIELDS_SIZE(sd_bus_message *m) { return BUS_MESSAGE_BSWAP32(m, m->header->fields_size); } +static inline uint32_t BUS_MESSAGE_SIZE(sd_bus_message *m) { + return + sizeof(struct bus_header) + + ALIGN8(BUS_MESSAGE_FIELDS_SIZE(m)) + + BUS_MESSAGE_BODY_SIZE(m); +} + static inline void bus_message_unrefp(sd_bus_message **m) { sd_bus_message_unref(*m); } @@ -126,5 +159,31 @@ static inline void bus_message_unrefp(sd_bus_message **m) { int bus_message_seal(sd_bus_message *m, uint64_t serial); int bus_message_dump(sd_bus_message *m); int bus_message_get_blob(sd_bus_message *m, void **buffer, size_t *sz); -int bus_message_from_malloc(void *buffer, size_t length, sd_bus_message **ret); int bus_message_read_strv_extend(sd_bus_message *m, char ***l); + +int bus_message_from_header( + void *header, + size_t length, + int *fds, + unsigned n_fds, + const struct ucred *ucred, + const char *label, + size_t extra, + sd_bus_message **ret); + +int bus_message_from_malloc( + void *buffer, + size_t length, + int *fds, + unsigned n_fds, + const struct ucred *ucred, + const char *label, + sd_bus_message **ret); + +const char* bus_message_get_arg(sd_bus_message *m, unsigned i); + +int bus_message_append_ap(sd_bus_message *m, const char *types, va_list ap); + +int bus_message_parse_fields(sd_bus_message *m); + +int bus_header_size(struct bus_header *h, size_t *sum);