diff options
Diffstat (limited to 'test/poll-cancel-ton.c')
-rw-r--r-- | test/poll-cancel-ton.c | 14 |
1 files changed, 5 insertions, 9 deletions
diff --git a/test/poll-cancel-ton.c b/test/poll-cancel-ton.c index e9d612e..b023394 100644 --- a/test/poll-cancel-ton.c +++ b/test/poll-cancel-ton.c @@ -9,9 +9,9 @@ #include <stdlib.h> #include <string.h> #include <inttypes.h> -#include <sys/poll.h> +#include <poll.h> #include <sys/wait.h> -#include <sys/signal.h> +#include <signal.h> #include "liburing.h" @@ -55,7 +55,7 @@ static int del_polls(struct io_uring *ring, int fd, int nr) sqe = io_uring_get_sqe(ring); data = sqe_index[lrand48() % nr]; - io_uring_prep_poll_remove(sqe, data); + io_uring_prep_poll_remove(sqe, (__u64)(uintptr_t)data); } ret = io_uring_submit(ring); @@ -71,10 +71,10 @@ static int del_polls(struct io_uring *ring, int fd, int nr) static int add_polls(struct io_uring *ring, int fd, int nr) { - int pending, batch, i, count, ret; + int batch, i, count, ret; struct io_uring_sqe *sqe; - pending = count = 0; + count = 0; while (nr) { batch = 1024; if (batch > nr) @@ -93,7 +93,6 @@ static int add_polls(struct io_uring *ring, int fd, int nr) return 1; } nr -= batch; - pending += batch; reap_events(ring, batch, 1); } return 0; @@ -129,9 +128,6 @@ int main(int argc, char *argv[]) } add_polls(&ring, pipe1[0], 30000); -#if 0 - usleep(1000); -#endif del_polls(&ring, pipe1[0], 30000); io_uring_queue_exit(&ring); |