From 0851b96958dbdfd67a6f3f25d4bb67d8c21e3a11 Mon Sep 17 00:00:00 2001
From: shahoian <ruben.shahoyan@cern.ch>
Date: Sat, 11 Apr 2020 19:23:36 +0200
Subject: [PATCH] Send endOfStream on readers job completion

---
 Detectors/TOF/workflow/src/ClusterReaderSpec.cxx | 1 +
 Detectors/TPC/workflow/src/TrackReaderSpec.cxx   | 1 +
 2 files changed, 2 insertions(+)

diff --git a/Detectors/TOF/workflow/src/ClusterReaderSpec.cxx b/Detectors/TOF/workflow/src/ClusterReaderSpec.cxx
index e565b335ffabb..c27b8c704b508 100644
--- a/Detectors/TOF/workflow/src/ClusterReaderSpec.cxx
+++ b/Detectors/TOF/workflow/src/ClusterReaderSpec.cxx
@@ -72,6 +72,7 @@ void ClusterReader::run(ProcessingContext& pc)
   }
 
   mState = 2;
+  pc.services().get<ControlService>().endOfStream();
   pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);
 }
 
diff --git a/Detectors/TPC/workflow/src/TrackReaderSpec.cxx b/Detectors/TPC/workflow/src/TrackReaderSpec.cxx
index ca75579c157fb..4fa81996cceb4 100644
--- a/Detectors/TPC/workflow/src/TrackReaderSpec.cxx
+++ b/Detectors/TPC/workflow/src/TrackReaderSpec.cxx
@@ -51,6 +51,7 @@ void TrackReader::run(ProcessingContext& pc)
   }
 
   mFinished = true;
+  pc.services().get<ControlService>().endOfStream();
   pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);
 }