From a683051b05930d1dd2766b98494bbd124817a6dd Mon Sep 17 00:00:00 2001
From: David Härdeman <david@hardeman.nu>
Date: Fri, 5 Jun 2020 19:34:52 +0200
Subject: Implement more proxy functionality

---
 uring.c | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

(limited to 'uring.c')

diff --git a/uring.c b/uring.c
index c43a8fb..96e3a67 100644
--- a/uring.c
+++ b/uring.c
@@ -141,6 +141,25 @@ uring_close(struct cfg *cfg, struct uring_task *task, int fd, callback_t callbac
 	fprintf(stderr, "%s: done\n", __func__);
 }
 
+void
+uring_write(struct cfg *cfg, struct uring_task *task, void *buf, size_t len, callback_t callback)
+{
+	struct io_uring_sqe *sqe = io_uring_get_sqe(&cfg->uev->uring);
+
+	if (!sqe)
+		perrordie("io_uring_sqe");
+
+	if (task->fd < 0) {
+		error("uring_write called with no fd set\n");
+		return;
+	}
+
+	uring_task_get(cfg, task);
+	task->callback = callback;
+	io_uring_prep_write(sqe, task->fd, buf, len, 0);
+	io_uring_sqe_set_data(sqe, task);
+}
+
 void
 uring_read(struct cfg *cfg, struct uring_task *task, void *buf, size_t len, off_t offset, callback_t callback)
 {
-- 
cgit v1.2.3