diff --git a/emper/io/IoContext.cpp b/emper/io/IoContext.cpp index e8b62ec4922fae02df973609ebfbad42e6decd72..7a7030a5437afff9e28cbdd5ed3c54d51ede65dc 100644 --- a/emper/io/IoContext.cpp +++ b/emper/io/IoContext.cpp @@ -213,9 +213,6 @@ template void IoContext::submitAndWait<CallerEnvironment::ANYWHERE>(Future &futu template <CallerEnvironment callerEnvironment> auto IoContext::reapCompletions(ContinuationBuffer &continuationFibers) -> unsigned { - // Should not be more than the uring_entries count. - const unsigned CQE_BATCH_COUNT = EMPER_IO_WORKER_URING_ENTRIES; - unsigned reReapCount = 0; uint32_t maxRaceFreeCompleterAttempts = 1; diff --git a/emper/io/IoContext.hpp b/emper/io/IoContext.hpp index 88f5ba9e74eb38b8e63153967cb47a0d32c2eb05..ec9c8eaff646dc1b1d67e805fa9135a040dac91b 100644 --- a/emper/io/IoContext.hpp +++ b/emper/io/IoContext.hpp @@ -300,6 +300,7 @@ class IoContext : public Logger<LogSubsystem::IO> { reapAndScheduleCompletions(); } + // Should not be more than the uring_entries count. static const unsigned CQE_BATCH_COUNT = EMPER_IO_WORKER_URING_ENTRIES; using ContinuationBuffer = std::array<Fiber *, CQE_BATCH_COUNT>;