detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-06-12 21:07:13 +02:00
Code Issues Actions Packages Releases Activity

910/restream stop delay (#1093)

Browse Source 
* wait a bit for post processor to process the dummy

* refactoring

* minor
This commit is contained in:
maliakal_d
2025-02-11 11:02:32 +01:00
committed by GitHub
parent 84e83bf551
commit bf82aeee8d
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
slsDetectorSoftware/src/DetectorImpl.cpp
View File

@ -1177,12 +1177,21 @@ int DetectorImpl::acquire() {
if (dataReady == nullptr) { if (dataReady == nullptr) {
setJoinThreadFlag(true); setJoinThreadFlag(true);
} else if (receiver) { } else if (receiver) {
// wait for postprocessor to process dummies
if (dataReady != nullptr) {
// process dummy from stop receier
if (numZmqRunning != 0)
std::this_thread::sleep_for(std::chrono::milliseconds(200));
while (numZmqRunning != 0) { while (numZmqRunning != 0) {
Parallel(&Module::restreamStopFromReceiver, {}); Parallel(&Module::restreamStopFromReceiver, {});
// increase time for fewer dummy packets to process // time to process restream dummy
std::this_thread::sleep_for(std::chrono::milliseconds(200));
// increase time for fewer dummies and to catch up
if (numZmqRunning != 0)
std::this_thread::sleep_for(std::chrono::seconds(2)); std::this_thread::sleep_for(std::chrono::seconds(2));
} }
} }
}
dataProcessingThread.join(); dataProcessingThread.join();
if (acquisition_finished != nullptr) { if (acquisition_finished != nullptr) {