diff --git a/emper/Common.hpp b/emper/Common.hpp index 9dd9c61af99f85cfa2a9d1d370c9bc556f8f695d..c404def401bf4619a7fc466e468748b47155efdb 100644 --- a/emper/Common.hpp +++ b/emper/Common.hpp @@ -5,6 +5,8 @@ #include <functional> #include <sstream> // IWYU pragma: keep +#include "emper-config.h" // IWYU pragma: keep + using func_t = std::function<void()>; #define STRINGIFY(x) #x diff --git a/emper/io/IoContext.cpp b/emper/io/IoContext.cpp index 4a4e20930b5a9368f62df06541adb650a78dcfd6..9ec288ea91d00bcee96384efed67b72df719080e 100644 --- a/emper/io/IoContext.cpp +++ b/emper/io/IoContext.cpp @@ -99,12 +99,11 @@ auto IoContext::submitPreparedSqes() -> unsigned { // in worker thread -> reapCompletions // in globalCompleter thread -> TODO: deterministically handle global full CQ // for now hope a jam does not happen or will solve itself - LOGGER_LOGI("io_submit returned EBUSY trying to submit " - << io_uring_sq_ready(&ring) << " in addition to " << reqs_in_uring); + LOGD("io_submit returned EBUSY trying to submit " << io_uring_sq_ready(&ring) + << " in addition to " << reqs_in_uring); if constexpr (callerEnvironment == CallerEnvironment::ANYWHERE) { // we are not busy looping in the globalIo - stats.record_io_submit_full_cq(); DIE_MSG("Future dropped because global completer SQ is full"); } diff --git a/emper/io/Stats.hpp b/emper/io/Stats.hpp index dbb15383729fc03f0493b4a6f616a213c7d83fe5..84da03ad617d1a3c971de48b556e98957db2ef0f 100644 --- a/emper/io/Stats.hpp +++ b/emper/io/Stats.hpp @@ -203,7 +203,7 @@ class Stats { // running mean calculation taken from // https://math.stackexchange.com/questions/106700/incremental-averageing - inline void record_io_submit_full_cq(nanoseconds ns = std::chrono::nanoseconds(0)) { + inline void record_io_submit_full_cq(nanoseconds ns) { RETURN_IF_NO_STATS(); io_submit_full_cq++;