[sre] Remove the use of parallel stream when synchronizing the probes.

Signed-off-by: Stéphane Galland <galland@arakhne.org>
sarl · Oct 23, 2020 · 41705d4 · 41705d4
1 parent 9f94c0a
commit 41705d4
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 1 deletion.
diff --git a/....janusproject.plugin/src/main/sarl/io/sarl/sre/services/probing/AbstractProbeService.sarl b/....janusproject.plugin/src/main/sarl/io/sarl/sre/services/probing/AbstractProbeService.sarl
@@ -155,7 +155,7 @@ abstract class AbstractProbeService extends AbstractSreService implements ProbeS
 	}
 
 	override sync {
-		this.probes.values.parallelStream.forEach [
+		this.probes.values.forEach [
 			it.sync
 		]
 	}

diff --git a/...ts/src/test/sarl/io/sarl/sre/tests/runtime/services/probing/AbstractProbeServiceTest.sarl b/...ts/src/test/sarl/io/sarl/sre/tests/runtime/services/probing/AbstractProbeServiceTest.sarl
@@ -108,6 +108,8 @@ abstract class AbstractProbeServiceTest {
 
 		waitForTheKernel(STANDARD_TIMEOUT)
 
+		service.runTestCase_afterShutdown(probe)
+
 		return probe
 	}
 
@@ -151,4 +153,6 @@ abstract class AbstractProbeServiceTest {
 
 	protected abstract def runTestCase_afterStopTest(service : ProbeService, probe : Probe<Integer>)
 
+	protected abstract def runTestCase_afterShutdown(service : ProbeService, probe : Probe<Integer>)
+
 }
diff --git a/...rc/test/sarl/io/sarl/sre/tests/runtime/services/probing/AsynchronousProbeServiceTest.sarl b/...rc/test/sarl/io/sarl/sre/tests/runtime/services/probing/AsynchronousProbeServiceTest.sarl
@@ -53,4 +53,8 @@ class AsynchronousProbeServiceTest extends AbstractProbeServiceTest {
 	protected def runTestCase_afterStopTest(service : ProbeService, probe : Probe<Integer>) {
 	}
 
+	protected def runTestCase_afterShutdown(service : ProbeService, probe : Probe<Integer>) {
+		probe.sync
+	}
+
 }
diff --git a/...src/test/sarl/io/sarl/sre/tests/runtime/services/probing/SynchronousProbeServiceTest.sarl b/...src/test/sarl/io/sarl/sre/tests/runtime/services/probing/SynchronousProbeServiceTest.sarl
@@ -56,4 +56,8 @@ class SynchronousProbeServiceTest extends AbstractProbeServiceTest {
 		service.sync
 	}
 
+	protected def runTestCase_afterShutdown(service : ProbeService, probe : Probe<Integer>) {
+		service.sync
+	}
+
 }