MCPcopy Create free account
hub / github.com/axboe/liburing / io_uring_wait_cqes

Function io_uring_wait_cqes

src/queue.c:354–370  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

352}
353
354int io_uring_wait_cqes(struct io_uring *ring, struct io_uring_cqe **cqe_ptr,
355 unsigned wait_nr, struct __kernel_timespec *ts,
356 sigset_t *sigmask)
357{
358 int to_submit = 0;
359
360 if (ts) {
361 if (ring->features & IORING_FEAT_EXT_ARG)
362 return io_uring_wait_cqes_new(ring, cqe_ptr, wait_nr,
363 ts, 0, sigmask);
364 to_submit = __io_uring_submit_timeout(ring, wait_nr, ts);
365 if (to_submit < 0)
366 return to_submit;
367 }
368
369 return __io_uring_get_cqe(ring, cqe_ptr, to_submit, wait_nr, sigmask);
370}
371
372int io_uring_wait_cqes_min_timeout(struct io_uring *ring,
373 struct io_uring_cqe **cqe_ptr,

Callers 10

do_mkdiratFunction · 0.85
do_symlinkatFunction · 0.85
connect_clientFunction · 0.85
setup_srvFunction · 0.85
test_single_timeout_waitFunction · 0.85
do_linkatFunction · 0.85
testFunction · 0.85
test_enobufFunction · 0.85
mainFunction · 0.85

Calls 3

io_uring_wait_cqes_newFunction · 0.85
__io_uring_get_cqeFunction · 0.85

Tested by 2

test_single_timeout_waitFunction · 0.68
test_enobufFunction · 0.68