| /* |
| * Test that the sqthread goes to sleep around the specified time, and that |
| * the NEED_WAKEUP flag is then set. |
| */ |
| #include <errno.h> |
| #include <stdio.h> |
| #include <stdlib.h> |
| #include <unistd.h> |
| #include <sys/time.h> |
| #include "liburing.h" |
| |
| static unsigned long long mtime_since(const struct timeval *s, |
| const struct timeval *e) |
| { |
| long long sec, usec; |
| |
| sec = e->tv_sec - s->tv_sec; |
| usec = (e->tv_usec - s->tv_usec); |
| if (sec > 0 && usec < 0) { |
| sec--; |
| usec += 1000000; |
| } |
| |
| sec *= 1000; |
| usec /= 1000; |
| return sec + usec; |
| } |
| |
| static unsigned long long mtime_since_now(struct timeval *tv) |
| { |
| struct timeval end; |
| |
| gettimeofday(&end, NULL); |
| return mtime_since(tv, &end); |
| } |
| |
| int main(int argc, char *argv[]) |
| { |
| struct io_uring_params p = {}; |
| struct timeval tv; |
| struct io_uring ring; |
| int ret; |
| |
| if (argc > 1) |
| return 0; |
| |
| p.flags = IORING_SETUP_SQPOLL; |
| p.sq_thread_idle = 100; |
| |
| ret = io_uring_queue_init_params(1, &ring, &p); |
| if (ret) { |
| if (geteuid()) { |
| printf("%s: skipped, not root\n", argv[0]); |
| return 0; |
| } |
| fprintf(stderr, "queue_init=%d\n", ret); |
| return 1; |
| } |
| |
| gettimeofday(&tv, NULL); |
| do { |
| usleep(1000); |
| if ((*ring.sq.kflags) & IORING_SQ_NEED_WAKEUP) |
| return 0; |
| } while (mtime_since_now(&tv) < 1000); |
| |
| return 1; |
| } |