We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5d4de32 commit ab00649Copy full SHA for ab00649
1 file changed
src/StfBuilder/StfBuilderInput.cxx
@@ -95,11 +95,22 @@ void StfInputInterface::DataHandlerThread()
95
96
// receive readout messages
97
const auto lRet = lInputChan.Receive(lReadoutMsgs);
98
- if (lRet < 0 && mRunning) {
+ if (lRet < 0 && !mAcceptingData) { // NOT in FMQ:running state
99
+ continue;
100
+ }
101
+
102
+ if (lRet >= 0 && !mAcceptingData) {
103
+ WDDLOG_RL(1000, "READOUT INTERFACE: Receive data but we are not in FMQ:RUNNING state.");
104
105
106
107
+ if (lRet < 0 && mRunning && mAcceptingData) {
108
WDDLOG_RL(1000, "READOUT INTERFACE: Receive failed . err={}", std::to_string(lRet));
109
continue;
110
}
111
112
+ assert (lRet >= 0 && mAcceptingData);
113
114
if (lReadoutMsgs.empty()) {
115
// nothing received?
116
0 commit comments