diff --git a/src/core/reactor_backend.cc b/src/core/reactor_backend.cc index ff098591c4d..d5b5e2e64dc 100644 --- a/src/core/reactor_backend.cc +++ b/src/core/reactor_backend.cc @@ -1441,21 +1441,25 @@ class reactor_backend_uring final : public reactor_backend { case o::recv: { const auto& op = req.as(); ::io_uring_prep_recv(sqe, op.fd, op.addr, op.size, op.flags); + sqe->ioprio |= IORING_RECVSEND_POLL_FIRST; break; } case o::recvmsg: { const auto& op = req.as(); ::io_uring_prep_recvmsg(sqe, op.fd, op.msghdr, op.flags); + sqe->ioprio |= IORING_RECVSEND_POLL_FIRST; break; } case o::send: { const auto& op = req.as(); ::io_uring_prep_send(sqe, op.fd, op.addr, op.size, op.flags); + sqe->ioprio |= IORING_RECVSEND_POLL_FIRST; break; } case o::sendmsg: { const auto& op = req.as(); ::io_uring_prep_sendmsg(sqe, op.fd, op.msghdr, op.flags); + sqe->ioprio |= IORING_RECVSEND_POLL_FIRST; break; } case o::accept: {