From 3b3325f761b09ebbfef04c44eed546cc4fdeb329 Mon Sep 17 00:00:00 2001 From: Kacper Date: Mon, 15 Dec 2025 02:01:33 +0100 Subject: Added aio and eventfd support, along with sleep and yes utilities --- lib/libc/aio/aio_cancel.c | 47 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 47 insertions(+) create mode 100644 lib/libc/aio/aio_cancel.c (limited to 'lib/libc/aio/aio_cancel.c') diff --git a/lib/libc/aio/aio_cancel.c b/lib/libc/aio/aio_cancel.c new file mode 100644 index 00000000..b4d373bf --- /dev/null +++ b/lib/libc/aio/aio_cancel.c @@ -0,0 +1,47 @@ +#include <__aio.h> +#include +#include +#include +#include +#include +#include +#include + +int aio_cancel(int __unused fildes, struct aiocb *aiocbp) +{ + unsigned tail; + struct aio_request *req; + struct io_uring_sqe sqe; + + if (aiocbp == NULL) { + errno = EINVAL; + return -1; + } + + req = __aio_lookup(aiocbp); + + if (req == NULL) { + errno = EINVAL; + return -1; + } + + if (req->status == AIO_REQUEST_STATUS_COMPLETED) { + return AIO_ALLDONE; + } + + memset(&sqe, 0, sizeof(sqe)); + sqe.opcode = IORING_OP_ASYNC_CANCEL; + sqe.user_data = (uint64_t)req; + + tail = *__io_uring.sq.tail; + __io_uring.sq.sqes[tail % IO_URING_ENTRIES] = sqe; + __io_uring.sq.array[tail % IO_URING_ENTRIES] = tail % IO_URING_ENTRIES; + *__io_uring.sq.tail = tail + 1; + + io_uring_enter(__io_uring.fd, 1, 0, IORING_ENTER_GETEVENTS, NULL, 0); + + __aio_remove(aiocbp); + free(req); + + return AIO_CANCELED; +} -- cgit v1.2.3