unsigned int lost_count;
int ret = 0;
- if (recv->reply.offset > 0)
+ if (recv->msg.offset > 0)
return -EINVAL;
mutex_lock(&conn->lock);
* Only if no PEEK is specified, the FDs are installed and the message
* is dropped from internal queues.
*/
- ret = kdbus_queue_entry_install(entry, conn, &recv->reply.return_flags,
+ ret = kdbus_queue_entry_install(entry, conn, &recv->msg.return_flags,
install);
if (ret < 0)
goto exit_unlock;
/* Give the offset+size back to the caller. */
- kdbus_pool_slice_publish(entry->slice, &recv->reply.offset,
- &recv->reply.msg_size);
+ kdbus_pool_slice_publish(entry->slice, &recv->msg.offset,
+ &recv->msg.msg_size);
if (install) {
kdbus_queue_entry_remove(conn, entry);
cmd_recv->return_flags = 0;
cmd_recv->dropped_msgs = 0;
- cmd_recv->reply.offset = 0;
- cmd_recv->reply.msg_size = 0;
- cmd_recv->reply.return_flags = 0;
+ cmd_recv->msg.offset = 0;
+ cmd_recv->msg.msg_size = 0;
+ cmd_recv->msg.return_flags = 0;
ret = kdbus_items_validate(cmd_recv->items,
KDBUS_ITEMS_SIZE(cmd_recv, items));
if (kdbus_member_set_user(&cmd_recv->dropped_msgs, buf,
struct kdbus_cmd_recv,
dropped_msgs) ||
- kdbus_member_set_user(&cmd_recv->reply, buf,
- struct kdbus_cmd_recv, reply) ||
+ kdbus_member_set_user(&cmd_recv->msg, buf,
+ struct kdbus_cmd_recv, msg) ||
kdbus_member_set_user(&cmd_recv->return_flags, buf,
struct kdbus_cmd_recv,
return_flags))
__u64 return_flags;
__s64 priority;
__u64 dropped_msgs;
- struct kdbus_msg_info reply;
+ struct kdbus_msg_info msg;
struct kdbus_item items[0];
} __attribute__((aligned(8)));
return ret;
}
- msg = (struct kdbus_msg *)(conn->buf + recv.reply.offset);
+ msg = (struct kdbus_msg *)(conn->buf + recv.msg.offset);
ret = kdbus_msg_dump(conn, msg);
if (ret < 0) {
kdbus_msg_free(msg);
*msg_out = msg;
if (offset)
- *offset = recv.reply.offset;
+ *offset = recv.msg.offset;
} else {
kdbus_msg_free(msg);
- ret = kdbus_free(conn, recv.reply.offset);
+ ret = kdbus_free(conn, recv.msg.offset);
if (ret < 0)
return ret;
}
if (!use_memfd)
goto out;
- msg = (struct kdbus_msg *)(conn->buf + recv.reply.offset);
+ msg = (struct kdbus_msg *)(conn->buf + recv.msg.offset);
KDBUS_ITEM_FOREACH(item, msg, items) {
switch (item->type) {
if (!has_memfd)
add_stats(send_ns);
- ret = kdbus_free(conn, recv.reply.offset);
+ ret = kdbus_free(conn, recv.msg.offset);
ASSERT_RETURN_VAL(ret == 0, -errno);
return 0;
ret = ioctl(conn->fd, KDBUS_CMD_RECV, &recv);
ASSERT_RETURN(ret == 0);
- ret = kdbus_free(conn, recv.reply.offset);
+ ret = kdbus_free(conn, recv.msg.offset);
ASSERT_RETURN(ret == 0);
/* and try again */
return -errno;
}
- msg = (struct kdbus_msg *)(conn->buf + recv.reply.offset);
+ msg = (struct kdbus_msg *)(conn->buf + recv.msg.offset);
kdbus_msg_dump(conn, msg);
if (msg->priority != expected_prio) {
}
kdbus_msg_free(msg);
- ret = kdbus_free(conn, recv.reply.offset);
+ ret = kdbus_free(conn, recv.msg.offset);
if (ret < 0)
return ret;
return -errno;
}
- msg = (struct kdbus_msg *)(conn->buf + recv.reply.offset);
+ msg = (struct kdbus_msg *)(conn->buf + recv.msg.offset);
ASSERT_RETURN_VAL(msg->payload_type == KDBUS_PAYLOAD_KERNEL, -EINVAL);
ASSERT_RETURN_VAL(msg->src_id == KDBUS_SRC_ID_KERNEL, -EINVAL);
kdbus_printf("Got message timeout for cookie %llu\n",
msg->cookie_reply);
- ret = kdbus_free(conn, recv.reply.offset);
+ ret = kdbus_free(conn, recv.msg.offset);
if (ret < 0)
return ret;
return EXIT_FAILURE;
}
- msg = (struct kdbus_msg *)(conn->buf + recv.reply.offset);
+ msg = (struct kdbus_msg *)(conn->buf + recv.msg.offset);
item = msg->items;
size = msg->size;
}
cmd_free.size = sizeof(cmd_free);
- cmd_free.offset = recv.reply.offset;
+ cmd_free.offset = recv.msg.offset;
ret = ioctl(conn->fd, KDBUS_CMD_FREE, &cmd_free);
if (ret < 0) {
fprintf(stderr, "error free message: %d (%m)\n", ret);