Skip to content
Snippets Groups Projects
Commit b2e09c44 authored by Florian Schmaus's avatar Florian Schmaus
Browse files

Merge branch 'pipe-sleep-die-on-broken-invariant' into 'master'

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

See merge request !245
parents 012817ce f5906cb6
No related branches found
No related tags found
1 merge request!245[IoContext] die when the completer threads reaps new work notifications
Pipeline #67589 passed
......@@ -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);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment