Skip to content
Snippets Groups Projects

[IoContext] die when the completer threads reaps new work notifications

1 file
+ 4
1
Compare changes
  • Side-by-side
  • Inline
+ 4
1
@@ -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);
Loading