/*
* io_ring_enter(2) flags
*/
-#ifndef IORING_FLAG_SUBMIT
-#define IORING_FLAG_SUBMIT (1 << 0)
-#endif
#ifndef IORING_FLAG_GETEVENTS
-#define IORING_FLAG_GETEVENTS (1 << 1)
+#define IORING_FLAG_GETEVENTS (1 << 0)
#endif
typedef uint64_t u64;
struct aio_sq_ring *ring = ld->sq_ring;
if (ring->kflags & IORING_SQ_NEED_WAKEUP)
- io_ring_enter(ld->aio_ctx, ld->queued, 0, IORING_FLAG_SUBMIT);
+ io_ring_enter(ld->aio_ctx, ld->queued, 0, 0);
ld->queued = 0;
return 0;
}
unsigned start = ld->sq_ring->head;
long nr = ld->queued;
- ret = io_ring_enter(ld->aio_ctx, nr, 0, IORING_FLAG_SUBMIT |
- IORING_FLAG_GETEVENTS);
+ ret = io_ring_enter(ld->aio_ctx, nr, 0, IORING_FLAG_GETEVENTS);
if (ret > 0) {
fio_aioring_queued(td, start, ret);
io_u_mark_submit(td, ret);
struct io_event events[0];
};
-#define IORING_FLAG_SUBMIT (1 << 0)
-#define IORING_FLAG_GETEVENTS (1 << 1)
+#define IORING_FLAG_GETEVENTS (1 << 0)
#define DEPTH 32
prepped = 0;
do {
- int to_wait, flags, to_submit, this_reap;
+ int to_wait, to_submit, this_reap;
if (!prepped && s->inflight < DEPTH)
prepped = prep_more_ios(s, fd, min(DEPTH - s->inflight, BATCH_SUBMIT));
else
to_wait = min(s->inflight + to_submit, BATCH_COMPLETE);
- flags = IORING_FLAG_GETEVENTS;
- if (to_submit)
- flags |= IORING_FLAG_SUBMIT;
-
- ret = io_ring_enter(s->ioc, to_submit, to_wait, flags);
+ ret = io_ring_enter(s->ioc, to_submit, to_wait,
+ IORING_FLAG_GETEVENTS);
s->calls++;
this_reap = reap_events(s);