From dcc2fc01fa850e9ee36c549dc2691e7e5c71bebf Mon Sep 17 00:00:00 2001 From: Lennart Poettering Date: Wed, 26 Nov 2014 15:54:53 +0100 Subject: [PATCH] sd-bus: update peeking into receieved messages, with recent kernel change we need to FREE them after all --- src/core/busname.c | 19 +++++++++++++------ 1 file changed, 13 insertions(+), 6 deletions(-) diff --git a/src/core/busname.c b/src/core/busname.c index 1583d5741..8926c6bd9 100644 --- a/src/core/busname.c +++ b/src/core/busname.c @@ -731,6 +731,7 @@ static int busname_peek_message(BusName *n) { struct kdbus_cmd_recv cmd_recv = { .flags = KDBUS_RECV_PEEK, }; + struct kdbus_cmd_free cmd_free = {}; const char *comm = NULL; struct kdbus_item *d; struct kdbus_msg *k; @@ -739,11 +740,17 @@ static int busname_peek_message(BusName *n) { pid_t pid = 0; int r; + /* Generate a friendly debug log message about which process + * caused triggering of this bus name. This simply peeks the + * metadata of the first queued message and logs it. */ + assert(n); - /* Generate a friendly log message about which process caused - * triggering of this bus name. This simply peeks the metadata - * of the first queued message and logs it. */ + /* Let's shortcut things a bit, if debug logging is turned off + * anyway. */ + + if (log_get_max_level() < LOG_DEBUG) + return 0; r = ioctl(n->starter_fd, KDBUS_CMD_MSG_RECV, &cmd_recv); if (r < 0) { @@ -795,9 +802,9 @@ finish: if (p) (void) munmap(p, sz); - /* Hint: we don't invoke KDBUS_CMD_MSG_FREE here, as we only - * PEEKed the message, and didn't ask for it to be dropped - * from the queue. */ + cmd_free.offset = cmd_recv.offset; + if (ioctl(n->starter_fd, KDBUS_CMD_FREE, &cmd_free) < 0) + log_warning_unit(UNIT(n)->id, "Failed to free peeked message, ignoring: %m"); return r; } -- 2.30.2