summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/server/PreProcessor.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/server/PreProcessor.cpp b/src/server/PreProcessor.cpp
index 6c514f00..e26ebcdc 100644
--- a/src/server/PreProcessor.cpp
+++ b/src/server/PreProcessor.cpp
@@ -114,7 +114,11 @@ void
PreProcessor::run()
{
ThreadManager::set_flag(THREAD_PRE_PROCESS);
- while (_sem.wait() && !_exit_flag) {
+ while (!_exit_flag) {
+ if (!_sem.timed_wait(1000)) {
+ continue;
+ }
+
Event* const ev = _prepared_back.load();
if (!ev) {
return;