diff options
author | Lennart Poettering <lennart@poettering.net> | 2013-03-21 22:50:25 +0100 |
---|---|---|
committer | Lennart Poettering <lennart@poettering.net> | 2013-03-21 22:53:29 +0100 |
commit | e3017af97310da024ffb378ed155bc1676922ce7 (patch) | |
tree | a09b0a555b89f7ec00d0ab62294770db99c5642a /src/libsystemd-bus/sd-bus.h | |
parent | 43b4c9aaf56aefdc55c4b6c1df78e30cdcf3988f (diff) |
bus: implement full method call timeout logic
Diffstat (limited to 'src/libsystemd-bus/sd-bus.h')
-rw-r--r-- | src/libsystemd-bus/sd-bus.h | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/src/libsystemd-bus/sd-bus.h b/src/libsystemd-bus/sd-bus.h index 03ea4b8848..ce92ee7df6 100644 --- a/src/libsystemd-bus/sd-bus.h +++ b/src/libsystemd-bus/sd-bus.h @@ -33,11 +33,14 @@ * - add page donation logic * - api for appending/reading fixed arrays * - always verify container depth - * - implement method timeout logic * - implicitly set no_reply when a message-call is sent an the serial number ignored - * - reduce number of ppoll()s if we can avoid it * - handle NULL strings nicer when appending * - merge busctl into systemctl or so? + * - add object handlers + * - add peer message handlers + * - verify object paths + * - when reading a message, verify its size + * - add limits to wqueue and rqueue alike */ typedef struct sd_bus sd_bus; @@ -49,7 +52,7 @@ typedef struct { int need_free; } sd_bus_error; -typedef int (*sd_message_handler_t)(sd_bus *bus, sd_bus_message *m, void *userdata); +typedef int (*sd_message_handler_t)(sd_bus *bus, int ret, sd_bus_message *m, void *userdata); /* Connections */ @@ -62,6 +65,7 @@ void sd_bus_close(sd_bus *bus); sd_bus *sd_bus_ref(sd_bus *bus); sd_bus *sd_bus_unref(sd_bus *bus); +int sd_bus_is_open(sd_bus *bus); int sd_bus_is_running(sd_bus *bus); int sd_bus_can_send(sd_bus *bus, char type); @@ -72,6 +76,7 @@ int sd_bus_send_with_reply_and_block(sd_bus *bus, sd_bus_message *m, uint64_t us int sd_bus_get_fd(sd_bus *bus); int sd_bus_get_events(sd_bus *bus); +int sd_bus_get_timeout(sd_bus *bus, uint64_t *timeout_usec); int sd_bus_process(sd_bus *bus, sd_bus_message **r); int sd_bus_wait(sd_bus *bus, uint64_t timeout_usec); int sd_bus_flush(sd_bus *bus); |