Skip to content

Commit b184f69

Browse files
authored
DPL: do not sleep when no dangling outputs available (#2990)
This actually fills the FairMQ queue in any case, so we must avoid it. One more reason to do the adaptive rate.
1 parent 78b4c54 commit b184f69

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

Framework/Core/src/CommonDataProcessors.cxx

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -479,7 +479,6 @@ DataProcessorSpec
479479
LOG(DEBUG) << "No dangling output to be saved.";
480480
once = true;
481481
}
482-
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
483482
});
484483
}
485484

@@ -615,13 +614,10 @@ DataProcessorSpec
615614
if (hasOutputsToWrite == false) {
616615
return std::move([](ProcessingContext& pc) mutable -> void {
617616
static bool once = false;
618-
/// We do it like this until we can use the interruptible sleep
619-
/// provided by recent FairMQ releases.
620617
if (!once) {
621618
LOG(DEBUG) << "No dangling output to be dumped.";
622619
once = true;
623620
}
624-
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
625621
});
626622
}
627623
auto output = std::make_shared<std::ofstream>(filename.c_str(), std::ios_base::binary);

0 commit comments

Comments
 (0)