DPL: reset the number of end of stream received before quitting

ktf · ktf · commit 3ca5c9d188ea · 2022-09-06T22:06:29.000+02:00
diff --git a/Framework/Core/src/ExternalFairMQDeviceProxy.cxx b/Framework/Core/src/ExternalFairMQDeviceProxy.cxx
@@ -502,6 +502,7 @@ DataProcessorSpec specifyExternalFairMQDeviceProxy(char const* name,
         for (auto& info : deviceState->inputChannelInfos) {
           info.state = InputChannelState::Completed;
         }
+        numberOfEoS = 0;
         control->endOfStream();
       }
     };

Original file line number	Diff line number	Diff line change
`@@ -502,6 +502,7 @@ DataProcessorSpec specifyExternalFairMQDeviceProxy(char const* name,`
`502`	`502`	`for (auto& info : deviceState->inputChannelInfos) {`
`503`	`503`	`info.state = InputChannelState::Completed;`
`504`	`504`	`}`
	`505`	`+ numberOfEoS = 0;`
`505`	`506`	`control->endOfStream();`
`506`	`507`	`}`
`507`	`508`	`};`