diff options
| author | Lennart Poettering <lennart@poettering.net> | 2013-04-14 17:46:41 +0200 |
|---|---|---|
| committer | Lennart Poettering <lennart@poettering.net> | 2013-04-14 17:46:41 +0200 |
| commit | 88fe224c8c3cf80ad48bb2b5ddd6e455b0a112d4 (patch) | |
| tree | 2bbc99b26a8548db5f8e73c2b09267bb5674b377 /src/libsystemd-bus/sd-bus.c | |
| parent | 42c5aaf3ba3eb9e11a1a2cad105e0dd956ac9763 (diff) | |
bus: always explicitly rewind read index before passing message to caller or callback
Diffstat (limited to 'src/libsystemd-bus/sd-bus.c')
| -rw-r--r-- | src/libsystemd-bus/sd-bus.c | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/src/libsystemd-bus/sd-bus.c b/src/libsystemd-bus/sd-bus.c index f40958a26..f2dd81235 100644 --- a/src/libsystemd-bus/sd-bus.c +++ b/src/libsystemd-bus/sd-bus.c @@ -1584,6 +1584,10 @@ static int process_reply(sd_bus *bus, sd_bus_message *m) { if (c->timeout != 0) prioq_remove(bus->reply_callbacks_prioq, c, &c->prioq_idx); + r = sd_bus_message_rewind(m, true); + if (r < 0) + return r; + r = c->callback(bus, 0, m, c->userdata); free(c); @@ -1611,6 +1615,10 @@ static int process_filter(sd_bus *bus, sd_bus_message *m) { l->last_iteration = bus->iteration_counter; + r = sd_bus_message_rewind(m, true); + if (r < 0) + return r; + r = l->callback(bus, 0, m, l->userdata); if (r != 0) return r; @@ -1720,6 +1728,10 @@ static int process_object(sd_bus *bus, sd_bus_message *m) { c->last_iteration = bus->iteration_counter; + r = sd_bus_message_rewind(m, true); + if (r < 0) + return r; + r = c->callback(bus, 0, m, c->userdata); if (r != 0) return r; @@ -1746,6 +1758,10 @@ static int process_object(sd_bus *bus, sd_bus_message *m) { c->last_iteration = bus->iteration_counter; + r = sd_bus_message_rewind(m, true); + if (r < 0) + return r; + r = c->callback(bus, 0, m, c->userdata); if (r != 0) return r; @@ -1930,6 +1946,10 @@ static int process_running(sd_bus *bus, sd_bus_message **ret) { goto null_message; if (ret) { + r = sd_bus_message_rewind(m, true); + if (r < 0) + return r; + *ret = m; m = NULL; return 1; |