diff --git a/src/shared/io-glib.c b/src/shared/io-glib.c
index 882ebd6..a2ada66 100644
--- a/src/shared/io-glib.c
+++ b/src/shared/io-glib.c
return true;
}
+ssize_t io_send(struct io *io, const struct iovec *iov, int iovcnt)
+{
+ int fd;
+ ssize_t ret;
+
+ if (!io || !io->channel)
+ return -ENOTCONN;
+
+ fd = io_get_fd(io);
+
+ do {
+ ret = writev(fd, iov, iovcnt);
+ } while (ret < 0 && errno == EINTR);
+
+ if (ret < 0)
+ return -errno;
+
+ return ret;
+}
+
bool io_shutdown(struct io *io)
{
if (!io || !io->channel)
diff --git a/src/shared/io-mainloop.c b/src/shared/io-mainloop.c
index b7e0f5f..7f80d8f 100644
--- a/src/shared/io-mainloop.c
+++ b/src/shared/io-mainloop.c
return true;
}
+ssize_t io_send(struct io *io, const struct iovec *iov, int iovcnt)
+{
+ ssize_t ret;
+
+ if (!io || io->fd < 0)
+ return -ENOTCONN;
+
+ do {
+ ret = writev(io->fd, iov, iovcnt);
+ } while (ret < 0 && errno == EINTR);
+
+ if (ret < 0)
+ return -errno;
+
+ return ret;
+}
+
bool io_shutdown(struct io *io)
{
if (!io || io->fd < 0)
diff --git a/src/shared/io.h b/src/shared/io.h
index 8897964..8bc1111 100644
--- a/src/shared/io.h
+++ b/src/shared/io.h
*/
#include <stdbool.h>
+#include <sys/uio.h>
typedef void (*io_destroy_func_t)(void *data);
int io_get_fd(struct io *io);
bool io_set_close_on_destroy(struct io *io, bool do_close);
+ssize_t io_send(struct io *io, const struct iovec *iov, int iovcnt);
bool io_shutdown(struct io *io);
typedef bool (*io_callback_func_t)(struct io *io, void *user_data);