X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Fcore%2Fbusname.c;fp=src%2Fcore%2Fbusname.c;h=8926c6bd946cd24c68d796d0f7d6a10191489366;hb=dcc2fc01fa850e9ee36c549dc2691e7e5c71bebf;hp=1583d57416e56241fbe1eee815fd2d78e3bd72f6;hpb=e0312f4db08c7100bd00299614e87bedc759b366;p=elogind.git 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; }