From ff975efb2e88dcd5221a2f0d76c4c87e85b821a8 Mon Sep 17 00:00:00 2001 From: Lennart Poettering Date: Wed, 22 Jan 2014 23:36:06 +0100 Subject: bus: when we cannot bus activate a service because we go down, drop one message from the queue --- src/libsystemd/sd-bus/bus-kernel.c | 13 +++++++++++++ src/libsystemd/sd-bus/bus-kernel.h | 2 ++ 2 files changed, 15 insertions(+) (limited to 'src/libsystemd/sd-bus') diff --git a/src/libsystemd/sd-bus/bus-kernel.c b/src/libsystemd/sd-bus/bus-kernel.c index a33e7a323c..b46cada648 100644 --- a/src/libsystemd/sd-bus/bus-kernel.c +++ b/src/libsystemd/sd-bus/bus-kernel.c @@ -1476,3 +1476,16 @@ int bus_kernel_try_close(sd_bus *bus) { return 0; } + +int bus_kernel_drop_one(int fd) { + struct kdbus_cmd_recv recv = { + .flags = KDBUS_RECV_DROP + }; + + assert(fd >= 0); + + if (ioctl(fd, KDBUS_CMD_MSG_RECV, &recv) < 0) + return -errno; + + return 0; +} diff --git a/src/libsystemd/sd-bus/bus-kernel.h b/src/libsystemd/sd-bus/bus-kernel.h index e9f776d9fd..de02b84f88 100644 --- a/src/libsystemd/sd-bus/bus-kernel.h +++ b/src/libsystemd/sd-bus/bus-kernel.h @@ -79,3 +79,5 @@ int kdbus_translate_request_name_flags(uint64_t sd_bus_flags, uint64_t *kdbus_fl int kdbus_translate_attach_flags(uint64_t sd_bus_flags, uint64_t *kdbus_flags); int bus_kernel_try_close(sd_bus *bus); + +int bus_kernel_drop_one(int fd); -- cgit v1.2.3-54-g00ecf