diff --git a/emper/sleep_strategy/AbstractIoSleepStrategy.cpp b/emper/sleep_strategy/AbstractIoSleepStrategy.cpp index 9bcb0a36371a587948558f3c5bd0ba321ba946dd..818bb06ac06da8852c37495fe84428033684f977 100644 --- a/emper/sleep_strategy/AbstractIoSleepStrategy.cpp +++ b/emper/sleep_strategy/AbstractIoSleepStrategy.cpp @@ -111,7 +111,11 @@ void AbstractIoSleepStrategy::sendSpecificNotification(workerid_t workerId) { io_uring_prep_msg_ring(sqe, runtime.ioContexts[workerId]->ring.ring_fd, tag, 0); - io.trackReqsInUring(1); + // Do not generate a cqe on the submiting io_uring + sqe->flags = IOSQE_CQE_SKIP_SUCCESS; + + // The sent message will create a cqes one on the messaged io_uring + runtime.ioContexts[workerId]->trackReqsInUring(1); io.submitPreparedSqesAndWait<CallerEnvironment::EMPER>(0); }