From a9f79eb798c380db618916db427878cb430cebca Mon Sep 17 00:00:00 2001
From: Srecko <srecko.morovic@cern.ch>
Date: Tue, 14 May 2024 02:18:43 +0200
Subject: [PATCH] fix thread notification (was causing to wait 10ms which is
 detrimental with file rate beyond 10 Hz)

---
 EventFilter/Utilities/src/DAQSource.cc             | 1 +
 EventFilter/Utilities/src/FedRawDataInputSource.cc | 1 +
 2 files changed, 2 insertions(+)

diff --git a/EventFilter/Utilities/src/DAQSource.cc b/EventFilter/Utilities/src/DAQSource.cc
index dde1577ac4bb0..131c9d9443151 100644
--- a/EventFilter/Utilities/src/DAQSource.cc
+++ b/EventFilter/Utilities/src/DAQSource.cc
@@ -1079,6 +1079,7 @@ void DAQSource::readWorker(unsigned int tid) {
       init = false;
       startupCv_.notify_one();
     }
+    cvWakeup_.notify_all();
     cvReader_[tid]->wait(lk);
 
     if (thread_quit_signal[tid])
diff --git a/EventFilter/Utilities/src/FedRawDataInputSource.cc b/EventFilter/Utilities/src/FedRawDataInputSource.cc
index ad3b51661cd64..4b95f1a8df9c6 100644
--- a/EventFilter/Utilities/src/FedRawDataInputSource.cc
+++ b/EventFilter/Utilities/src/FedRawDataInputSource.cc
@@ -1303,6 +1303,7 @@ void FedRawDataInputSource::readWorker(unsigned int tid) {
       init = false;
       startupCv_.notify_one();
     }
+    cvWakeup_.notify_all();
     cvReader_[tid]->wait(lk);
 
     if (thread_quit_signal[tid])