15#define do_read(fd, buffer, size) io_read(fd, buffer, size)
16#define do_write(fd, buffer, size) io_write(fd, buffer, size)
17#define do_warn(fmt, ...) mos_warn(fmt, ##__VA_ARGS__)
20#define do_read(fd, buffer, size) read(fd, buffer, size)
21#define do_write(fd, buffer, size) write(fd, buffer, size)
22#define do_warn(fmt, ...) fprintf(stderr, fmt __VA_OPT__(, ) __VA_ARGS__)
50 if (read_size !=
sizeof(
size))
52 do_warn(
"failed to read size from ipc channel");
58 if (read_size !=
size)
60 do_warn(
"failed to read data from ipc channel");
71 if (written !=
sizeof(
buffer->size))
73 do_warn(
"failed to write size to ipc channel");
78 if (written !=
buffer->size)
80 do_warn(
"failed to write data to ipc channel");
93 do_warn(
"failed to write size to ipc channel");
99 do_warn(
"failed to write data to ipc channel");
109 size_t data_size = 0;
113 do_warn(
"failed to read size from ipc channel");
117 if (
unlikely(data_size > buffer_size))
126 do_warn(
"failed to read data from ipc channel");
ipc_msg_t * ipc_read_msg(ipcfd_t fd)
Read an IPC message.
bool ipc_write_as_msg(ipcfd_t fd, const char *data, size_t size)
bool ipc_write_msg(ipcfd_t fd, ipc_msg_t *buffer)
Write an IPC message.
ipc_msg_t * ipc_msg_create(size_t size)
Create a new IPC message.
#define do_read(fd, buffer, size)
#define do_write(fd, buffer, size)
size_t ipc_read_as_msg(ipcfd_t fd, char *buffer, size_t buffer_size)
void ipc_msg_destroy(ipc_msg_t *buffer)
Destroy an IPC message.
#define MOS_STATIC_ASSERT