diff --git a/emper/io/IoContext.cpp b/emper/io/IoContext.cpp index b0585437aa2a76eb39064c4d6a8e532cdb67ff60..44cff730eff2a243738e2f4d842af00eed9fe420 100644 --- a/emper/io/IoContext.cpp +++ b/emper/io/IoContext.cpp @@ -318,8 +318,11 @@ reap_cqes: switch (tag) { case PointerTags::NewWorkWsq: case PointerTags::NewWorkAq: { - LOGD("Got new work notification"); + if constexpr (callerEnvironment == CallerEnvironment::ANYWHERE) { + DIE_MSG("Completer reaping new work notification"); + } + LOGD("Got new work notification"); auto *pipeSleepStrategy = reinterpret_cast<PipeSleepStrategy *>(&runtime.getWorkerSleepStrategy()); statsIncr(pipeSleepStrategy->stats->wakeupDueToNotify);