Send endOfStream on readers job completion

shahor02 · shahor02 · commit a0f76c0489b9 · 2020-04-11T20:54:28.000+02:00
diff --git 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
@@ -51,6 +51,7 @@ void TrackReader::run(ProcessingContext& pc)
   }
 
   mFinished = true;
+  pc.services().get<ControlService>().endOfStream();
   pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);
 }
 

Original file line number	Diff line number	Diff line change
`@@ -72,6 +72,7 @@ void ClusterReader::run(ProcessingContext& pc)`
`72`	`72`	`}`
`73`	`73`
`74`	`74`	`mState = 2;`
	`75`	`+ pc.services().get<ControlService>().endOfStream();`
`75`	`76`	`pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);`
`76`	`77`	`}`
`77`	`78`
Original file line number	Diff line number	Diff line change
`@@ -51,6 +51,7 @@ void TrackReader::run(ProcessingContext& pc)`
`51`	`51`	`}`
`52`	`52`
`53`	`53`	`mFinished = true;`
	`54`	`+ pc.services().get<ControlService>().endOfStream();`
`54`	`55`	`pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);`
`55`	`56`	`}`
`56`	`57`