diff options
author | Lennart Poettering <lennart@poettering.net> | 2013-04-05 03:55:58 +0200 |
---|---|---|
committer | Lennart Poettering <lennart@poettering.net> | 2013-04-05 03:55:58 +0200 |
commit | 7286037fd438e93137571fa68a741cc894d8e549 (patch) | |
tree | f34cbc20ec29ca10e1d866859c0f0289ed14fb72 /src/libsystemd-bus/bus-internal.h | |
parent | 6807947e56d7d1b40ec4e984a5f631fb6d5a6834 (diff) |
bus: properly detect and handle if a callback is installed/removed from within a callback
Diffstat (limited to 'src/libsystemd-bus/bus-internal.h')
-rw-r--r-- | src/libsystemd-bus/bus-internal.h | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/libsystemd-bus/bus-internal.h b/src/libsystemd-bus/bus-internal.h index 9cc1c9c899..6ff3163cfd 100644 --- a/src/libsystemd-bus/bus-internal.h +++ b/src/libsystemd-bus/bus-internal.h @@ -46,6 +46,8 @@ struct filter_callback { sd_bus_message_handler_t callback; void *userdata; + unsigned last_iteration; + LIST_FIELDS(struct filter_callback, callbacks); }; @@ -55,6 +57,8 @@ struct object_callback { char *path; bool is_fallback; + + unsigned last_iteration; }; enum bus_state { @@ -86,6 +90,9 @@ struct sd_bus { bool prefer_readv:1; bool prefer_writev:1; bool processing:1; + bool match_callbacks_modified:1; + bool filter_callbacks_modified:1; + bool object_callbacks_modified:1; void *rbuffer; size_t rbuffer_size; @@ -139,6 +146,7 @@ struct sd_bus { char **exec_argv; uint64_t hello_serial; + unsigned iteration_counter; }; static inline void bus_unrefp(sd_bus **b) { |