diff options
| author | Lennart Poettering <lennart@poettering.net> | 2019-01-17 18:31:59 +0100 |
|---|---|---|
| committer | Lennart Poettering <lennart@poettering.net> | 2019-03-01 15:37:39 +0100 |
| commit | c1757a70eac0382c4837a3833d683919f6a48ed7 (patch) | |
| tree | 5626f53e2d5fea8b98f011189452cb40da818bf0 /src/libsystemd/sd-bus/bus-socket.c | |
| parent | 1b3f9dd759ca0ea215e7b89f8ce66d1b724497b9 (diff) | |
| download | systemd-c1757a70eac0382c4837a3833d683919f6a48ed7.tar.gz | |
sd-bus: use "queue" message references for managing r/w message queues in connection objects
Let's make use of the new concept the previous commit added.
See: #4846
Diffstat (limited to 'src/libsystemd/sd-bus/bus-socket.c')
| -rw-r--r-- | src/libsystemd/sd-bus/bus-socket.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/libsystemd/sd-bus/bus-socket.c b/src/libsystemd/sd-bus/bus-socket.c index 441b4a816f..df9b2631fd 100644 --- a/src/libsystemd/sd-bus/bus-socket.c +++ b/src/libsystemd/sd-bus/bus-socket.c @@ -1110,8 +1110,10 @@ static int bus_socket_make_message(sd_bus *bus, size_t size) { bus->fds = NULL; bus->n_fds = 0; - if (t) - bus->rqueue[bus->rqueue_size++] = t; + if (t) { + bus->rqueue[bus->rqueue_size++] = bus_message_ref_queued(t, bus); + sd_bus_message_unref(t); + } return 1; } |