mode = UNIT(n)->manager->running_as == SYSTEMD_SYSTEM ? "system" : "user";
n->starter_fd = bus_kernel_open_bus_fd(mode, &path);
- if (n->starter_fd < 0) {
- log_unit_warning(UNIT(n)->id, "Failed to open %s: %s", path ?: "kdbus", strerror(-n->starter_fd));
- return n->starter_fd;
- }
+ if (n->starter_fd < 0)
+ return log_unit_warning_errno(UNIT(n)->id, n->starter_fd, "Failed to open %s: %m", path ?: "kdbus");
return 0;
}
static int busname_peek_message(BusName *n) {
struct kdbus_cmd_recv cmd_recv = {
+ .size = sizeof(cmd_recv),
.flags = KDBUS_RECV_PEEK,
};
struct kdbus_cmd_free cmd_free = {};
if (log_get_max_level() < LOG_DEBUG)
return 0;
- r = ioctl(n->starter_fd, KDBUS_CMD_MSG_RECV, &cmd_recv);
+ r = ioctl(n->starter_fd, KDBUS_CMD_RECV, &cmd_recv);
if (r < 0) {
if (errno == EINTR || errno == EAGAIN)
return 0;
* longer than necessary. */
ps = page_size();
- start = (cmd_recv.offset / ps) * ps;
- delta = cmd_recv.offset - start;
- sz = PAGE_ALIGN(delta + cmd_recv.msg_size);
+ start = (cmd_recv.reply.offset / ps) * ps;
+ delta = cmd_recv.reply.offset - start;
+ sz = PAGE_ALIGN(delta + cmd_recv.reply.msg_size);
p = mmap(NULL, sz, PROT_READ, MAP_SHARED, n->starter_fd, start);
if (p == MAP_FAILED) {
if (p)
(void) munmap(p, sz);
- cmd_free.offset = cmd_recv.offset;
+ cmd_free.offset = cmd_recv.reply.offset;
if (ioctl(n->starter_fd, KDBUS_CMD_FREE, &cmd_free) < 0)
log_unit_warning(UNIT(n)->id, "Failed to free peeked message, ignoring: %m");