[sre][tests] Change the test code in order to fulfill the changes in …

…SpaceWithParticipants. see a17f520 Signed-off-by: Stéphane Galland <galland@arakhne.org>
sarl · Mar 25, 2020 · bcab488 · bcab488
1 parent eef1402
commit bcab488
Show file tree

Hide file tree

Showing 14 changed files with 60 additions and 51 deletions.
diff --git a/...project.tests/src/test/sarl/io/sarl/sre/tests/runtime/services/context/mocks/MySpace.sarl b/...project.tests/src/test/sarl/io/sarl/sre/tests/runtime/services/context/mocks/MySpace.sarl
@@ -42,14 +42,21 @@ class MySpace implements Space {
 	override getSpaceID : SpaceID {
 		this.id
 	}
-	
+
 	def forEachStrongParticipant(callback : (UUID)=>void) {
 	}
-	
+
 	def getNumberOfStrongParticipants : int {
 		0
 	}
-
+
+	def forEachWeakParticipant(callback : (UUID)=>void) {
+	}
+
+	def getNumberOfWeakParticipants : int {
+		0
+	}
+
 	def isPseudoEmpty(id : UUID) : boolean {
 		true
 	}

diff --git a/...t.tests/src/test/sarl/io/sarl/sre/tests/units/internal/AgentPlatformEventEmitterTest.sarl b/...t.tests/src/test/sarl/io/sarl/sre/tests/units/internal/AgentPlatformEventEmitterTest.sarl
@@ -39,6 +39,7 @@ import io.sarl.tests.api.Nullable
 import io.sarl.tests.api.extensions.ContextInitExtension
 import io.sarl.tests.api.extensions.JavaVersionCheckExtension
 import java.util.UUID
+import java.util.concurrent.ConcurrentLinkedDeque
 import java.util.logging.Logger
 import org.junit.jupiter.api.BeforeEach
 import org.junit.jupiter.api.DisplayName
@@ -157,7 +158,7 @@ class AgentEventEmitterTest {
 		when(ctx.ID).thenReturn(secondContext)
 		var ref2 = this.life2.addExternalContext(ctx, adr2)
 
-		var contexts = #[ref1, ref2]
+		var contexts = new ConcurrentLinkedDeque(#[ref1, ref2])
 
 		this.emitter.agentDestroyed(agent2, contexts)
 

diff --git a/...rc/test/sarl/io/sarl/sre/tests/units/services/lifecycle/AbstractLifecycleServiceTest.sarl b/...rc/test/sarl/io/sarl/sre/tests/units/services/lifecycle/AbstractLifecycleServiceTest.sarl
@@ -56,6 +56,7 @@ import io.sarl.tests.api.extensions.JavaVersionCheckExtension
 import java.util.ArrayList
 import java.util.List
 import java.util.UUID
+import java.util.concurrent.ConcurrentLinkedDeque
 import java.util.concurrent.Future
 import java.util.logging.Logger
 import javax.inject.Provider
@@ -148,7 +149,7 @@ abstract class AbstractLifecycleServiceTest<T extends AbstractLifecycleService>
 		when(agentProvider.apply(any)).thenReturn(this.^agent2)
 		this.agentCreatorProvider = typeof(AgentCreatorProvider).mock
 		when(this.agentCreatorProvider.getAgentCreator(typeof(Class).any,
-			typeof(UUID).any, anyInt, typeof(Iterable).any)).thenReturn(agentProvider)
+			typeof(UUID).any, anyInt, typeof(ConcurrentLinkedDeque).any)).thenReturn(agentProvider)
 
 		this.executor = typeof(ExecutorService).mock
 		// Execute the code synchronously only for testing purpose
@@ -404,7 +405,8 @@ abstract class AbstractLifecycleServiceTest<T extends AbstractLifecycleService>
 
 		// Agent destroy notification
 		capAgent = ArgumentCaptor::forClass(typeof(Agent))
-		var capContexts : ArgumentCaptor<Iterable<ContextReference>> = ArgumentCaptor::forClass(typeof(Iterable))
+		var capContexts : ArgumentCaptor<ConcurrentLinkedDeque<ContextReference>> = ArgumentCaptor::forClass(
+			typeof(ConcurrentLinkedDeque))
 		listener1.verify.agentDestroyed(capAgent.capture, capContexts.capture)
 		this.agent2.assertEquals(capAgent.value)
 		capContexts.value.map[it.getContext].assertContains(defaultContext, outerContext)

diff --git a/...src/test/sarl/io/sarl/sre/tests/units/services/lifecycle/XAbstractCreatorFactoryTest.sarl b/...src/test/sarl/io/sarl/sre/tests/units/services/lifecycle/XAbstractCreatorFactoryTest.sarl
@@ -29,6 +29,7 @@ import io.sarl.sre.tests.units.services.lifecycle.mocks.MyCap
 import io.sarl.sre.tests.units.services.lifecycle.mocks.XAbstractCreatorFactoryMock
 import io.sarl.tests.api.extensions.ContextInitExtension
 import io.sarl.tests.api.extensions.JavaVersionCheckExtension
+import java.util.concurrent.ConcurrentLinkedDeque
 import org.junit.jupiter.api.DisplayName
 import org.junit.jupiter.api.Test
 import org.junit.jupiter.api.^extension.ExtendWith
@@ -64,7 +65,7 @@ class XAbstractCreatorFactoryTest {
 	def mergeSkillProviders_0_emptyIterable : void {
 		var factory = new XAbstractCreatorFactoryMock
 		//
-		var provider = factory.mergeSkillProviders(emptyList)
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque)
 		//
 		provider.assertNull
 	}
@@ -75,7 +76,7 @@ class XAbstractCreatorFactoryTest {
 		var factory = new XAbstractCreatorFactoryMock
 		//
 		var subprovider0 = DynamicSkillProvider::EMPTY_PROVIDER
-		var provider = factory.mergeSkillProviders(#[subprovider0])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0]))
 		//
 		provider.assertNotNull
 		//
@@ -91,7 +92,7 @@ class XAbstractCreatorFactoryTest {
 		//
 		val expected0 = typeof(Skill).mock
 		var subprovider0 = new Provider(expected0)
-		var provider = factory.mergeSkillProviders(#[subprovider0])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0]))
 		//
 		provider.assertNotNull
 		//
@@ -109,7 +110,7 @@ class XAbstractCreatorFactoryTest {
 		var subprovider0 = new Provider(expected0)
 		val expected1 = typeof(Skill).mock
 		var subprovider1 = new Provider(expected1)
-		var provider = factory.mergeSkillProviders(#[subprovider0, subprovider1])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0, subprovider1]))
 		//
 		provider.assertNotNull
 		//
@@ -126,7 +127,7 @@ class XAbstractCreatorFactoryTest {
 		var subprovider0 = DynamicSkillProvider::EMPTY_PROVIDER
 		val expected1 = typeof(Skill).mock
 		var subprovider1 = new Provider(expected1)
-		var provider = factory.mergeSkillProviders(#[subprovider0, subprovider1])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0, subprovider1]))
 		//
 		provider.assertNotNull
 		//
@@ -142,7 +143,7 @@ class XAbstractCreatorFactoryTest {
 		//
 		var subprovider0 = DynamicSkillProvider::EMPTY_PROVIDER
 		var subprovider1 = DynamicSkillProvider::EMPTY_PROVIDER
-		var provider = factory.mergeSkillProviders(#[subprovider0, subprovider1])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0, subprovider1]))
 		//
 		provider.assertNotNull
 		//
@@ -172,7 +173,7 @@ class XAbstractCreatorFactoryTest {
 		var orig = DynamicSkillProvider::EMPTY_PROVIDER
 		var factory = new XAbstractCreatorFactoryMock(orig)
 		//
-		var provider = factory.mergeSkillProviders(emptyList)
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque)
 		//
 		var s = provider.createSkill(typeof(MyCap))
 		//
@@ -186,7 +187,7 @@ class XAbstractCreatorFactoryTest {
 		var factory = new XAbstractCreatorFactoryMock(orig)
 		//
 		var subprovider0 = DynamicSkillProvider::EMPTY_PROVIDER
-		var provider = factory.mergeSkillProviders(#[subprovider0])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0]))
 		//
 		provider.assertNotNull
 		//
@@ -203,7 +204,7 @@ class XAbstractCreatorFactoryTest {
 		//
 		val expected0 = typeof(Skill).mock
 		var subprovider0 = new Provider(expected0)
-		var provider = factory.mergeSkillProviders(#[subprovider0])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0]))
 		//
 		provider.assertNotNull
 		//
@@ -222,7 +223,7 @@ class XAbstractCreatorFactoryTest {
 		var subprovider0 = new Provider(expected0)
 		val expected1 = typeof(Skill).mock
 		var subprovider1 = new Provider(expected1)
-		var provider = factory.mergeSkillProviders(#[subprovider0, subprovider1])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0, subprovider1]))
 		//
 		provider.assertNotNull
 		//
@@ -240,7 +241,7 @@ class XAbstractCreatorFactoryTest {
 		var subprovider0 = DynamicSkillProvider::EMPTY_PROVIDER
 		val expected1 = typeof(Skill).mock
 		var subprovider1 = new Provider(expected1)
-		var provider = factory.mergeSkillProviders(#[subprovider0, subprovider1])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0, subprovider1]))
 		//
 		provider.assertNotNull
 		//
@@ -257,7 +258,7 @@ class XAbstractCreatorFactoryTest {
 		//
 		var subprovider0 = DynamicSkillProvider::EMPTY_PROVIDER
 		var subprovider1 = DynamicSkillProvider::EMPTY_PROVIDER
-		var provider = factory.mergeSkillProviders(#[subprovider0, subprovider1])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0, subprovider1]))
 		//
 		provider.assertNotNull
 		//
@@ -289,7 +290,7 @@ class XAbstractCreatorFactoryTest {
 		var orig = new Provider(expected)
 		var factory = new XAbstractCreatorFactoryMock(orig)
 		//
-		var provider = factory.mergeSkillProviders(emptyList)
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque)
 		//
 		provider.assertNotNull
 		//
@@ -306,7 +307,7 @@ class XAbstractCreatorFactoryTest {
 		var factory = new XAbstractCreatorFactoryMock(orig)
 		//
 		var subprovider0 = DynamicSkillProvider::EMPTY_PROVIDER
-		var provider = factory.mergeSkillProviders(#[subprovider0])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0]))
 		//
 		provider.assertNotNull
 		//
@@ -324,7 +325,7 @@ class XAbstractCreatorFactoryTest {
 		//
 		val expected0 = typeof(Skill).mock
 		var subprovider0 = new Provider(expected0)
-		var provider = factory.mergeSkillProviders(#[subprovider0])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0]))
 		//
 		provider.assertNotNull
 		//
@@ -344,7 +345,7 @@ class XAbstractCreatorFactoryTest {
 		var subprovider0 = new Provider(expected0)
 		val expected1 = typeof(Skill).mock
 		var subprovider1 = new Provider(expected1)
-		var provider = factory.mergeSkillProviders(#[subprovider0, subprovider1])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0, subprovider1]))
 		//
 		provider.assertNotNull
 		//
@@ -363,7 +364,7 @@ class XAbstractCreatorFactoryTest {
 		var subprovider0 = DynamicSkillProvider::EMPTY_PROVIDER
 		val expected1 = typeof(Skill).mock
 		var subprovider1 = new Provider(expected1)
-		var provider = factory.mergeSkillProviders(#[subprovider0, subprovider1])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0, subprovider1]))
 		//
 		provider.assertNotNull
 		//
@@ -381,7 +382,7 @@ class XAbstractCreatorFactoryTest {
 		//
 		var subprovider0 = DynamicSkillProvider::EMPTY_PROVIDER
 		var subprovider1 = DynamicSkillProvider::EMPTY_PROVIDER
-		var provider = factory.mergeSkillProviders(#[subprovider0, subprovider1])
+		var provider = factory.mergeSkillProviders(new ConcurrentLinkedDeque(#[subprovider0, subprovider1]))
 		//
 		provider.assertNotNull
 		//

diff --git a/...ject.tests/src/test/sarl/io/sarl/sre/tests/units/services/lifecycle/mocks/MyEventBus.sarl b/...ject.tests/src/test/sarl/io/sarl/sre/tests/units/services/lifecycle/mocks/MyEventBus.sarl
@@ -44,11 +44,13 @@ skill MyEventBus implements InternalEventBusCapacity {
 	override unregisterEventBusListener(type : Class<?>, callback : (Object)=>boolean) {
 	}
 
-	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean) : Iterable<Event> {
+	override fireEventAndWait(^event : Event, gatherEvents : boolean,
+		thrownExceptions : boolean) : ConcurrentLinkedDeque<Event> {
 		null
 	}
 
-	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean, listener : Object) : Iterable<Event> {
+	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean,
+		listener : Object) : ConcurrentLinkedDeque<Event> {
 		null
 	}
 

diff --git a/...project.tests/src/test/sarl/io/sarl/sre/tests/units/services/lifecycle/mocks/MySkill.sarl b/...project.tests/src/test/sarl/io/sarl/sre/tests/units/services/lifecycle/mocks/MySkill.sarl
@@ -52,16 +52,17 @@ skill MySkill implements InternalEventBusCapacity {
 	}
 
 	@SuppressWarnings("potential_field_synchronization_problem")
-	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean) : Iterable<Event> {
+	override fireEventAndWait(^event : Event, gatherEvents : boolean,
+		thrownExceptions : boolean) : ConcurrentLinkedDeque<Event> {
 		if (this.failure) {
 			throw new RuntimeException
 		}
-		emptyList
+		new ConcurrentLinkedDeque
 	}
 
 	@SuppressWarnings("potential_field_synchronization_problem")
 	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean,
-		listener : Object) : Iterable<Event> {
+		listener : Object) : ConcurrentLinkedDeque<Event> {
 		if (this.failure) {
 			throw new RuntimeException
 		}

diff --git a/...st/sarl/io/sarl/sre/tests/units/services/lifecycle/mocks/XAbstractCreatorFactoryMock.sarl b/...st/sarl/io/sarl/sre/tests/units/services/lifecycle/mocks/XAbstractCreatorFactoryMock.sarl
@@ -25,6 +25,7 @@ import io.sarl.lang.core.Agent
 import io.sarl.lang.core.DynamicSkillProvider
 import io.sarl.sre.services.lifecycle.AbstractCreatorFactory
 import java.util.UUID
+import java.util.concurrent.ConcurrentLinkedDeque
 
 /**
  * @author $Author: sgalland$
@@ -36,7 +37,7 @@ import java.util.UUID
 class XAbstractCreatorFactoryMock extends AbstractCreatorFactory {
 
 	def getAgentCreator(agentClazz : Class<? extends Agent>, parent : UUID, nbAgents : int,
-		skillProviders : Iterable<DynamicSkillProvider>) : (UUID)=>Agent {
+		skillProviders : ConcurrentLinkedDeque<DynamicSkillProvider>) : (UUID)=>Agent {
 		null
 	}
 

diff --git a/...ts/src/test/sarl/io/sarl/sre/tests/units/services/namespace/AgentNamespaceFinderTest.sarl b/...ts/src/test/sarl/io/sarl/sre/tests/units/services/namespace/AgentNamespaceFinderTest.sarl
@@ -111,8 +111,6 @@ class AgentNamespaceServiceTest {
 		map0b.put(UUID::randomUUID, typeof(Participant).mock)
 		map0b.put(UUID::randomUUID, typeof(Participant).mock)
 		var spc0 = typeof(MySpace).mock
-		when(spc0.internalStrongParticipantStructure).thenReturn(map0)
-		when(spc0.internalWeakParticipantStructure).thenReturn(map0b)
 		var ctx0 = typeof(Context).mock
 		when(ctx0.defaultSpace).thenReturn(spc0)
 
@@ -130,8 +128,6 @@ class AgentNamespaceServiceTest {
 		map1b.put(UUID::randomUUID, typeof(Participant).mock)
 		this.sid1 = UUID::randomUUID
 		var spc1 = typeof(MySpace).mock
-		when(spc1.internalStrongParticipantStructure).thenReturn(map1)
-		when(spc1.internalWeakParticipantStructure).thenReturn(map1b)
 		this.cid1 = UUID::randomUUID
 		var ctx1 = typeof(Context).mock
 		when(ctx1.getSpace(any(typeof(UUID)))).thenAnswer [

diff --git a/...src/test/sarl/io/sarl/sre/tests/units/services/namespace/BehaviorNamespaceFinderTest.sarl b/...src/test/sarl/io/sarl/sre/tests/units/services/namespace/BehaviorNamespaceFinderTest.sarl
@@ -136,8 +136,6 @@ class BehaviorNamespaceFinderTest {
 		map0b.put(UUID::randomUUID, typeof(Participant).mock)
 		map0b.put(UUID::randomUUID, typeof(Participant).mock)
 		var spc0 = typeof(MySpace).mock
-		when(spc0.internalStrongParticipantStructure).thenReturn(map0)
-		when(spc0.internalWeakParticipantStructure).thenReturn(map0b)
 		var ctx0 = typeof(Context).mock
 		when(ctx0.defaultSpace).thenReturn(spc0)
 
@@ -159,8 +157,6 @@ class BehaviorNamespaceFinderTest {
 		map1b.put(UUID::randomUUID, typeof(Participant).mock)
 		this.sid1 = UUID::randomUUID
 		var spc1 = typeof(MySpace).mock
-		when(spc1.internalStrongParticipantStructure).thenReturn(map1)
-		when(spc1.internalWeakParticipantStructure).thenReturn(map1b)
 		this.cid1 = UUID::randomUUID
 		var ctx1 = typeof(Context).mock
 		when(ctx1.getSpace(any(typeof(UUID)))).thenAnswer [

diff --git a/...ts/src/test/sarl/io/sarl/sre/tests/units/services/namespace/SkillNamespaceFinderTest.sarl b/...ts/src/test/sarl/io/sarl/sre/tests/units/services/namespace/SkillNamespaceFinderTest.sarl
@@ -117,12 +117,7 @@ class SkillNamespaceFinderTest {
 		when(participant0.participant).thenReturn(listener0)
 		var map0 = new ConcurrentHashMap
 		map0.put(this.aid0, participant0)
-		var map0b = new ConcurrentHashMap
-		map0b.put(UUID::randomUUID, typeof(Participant).mock)
-		map0b.put(UUID::randomUUID, typeof(Participant).mock)
 		var spc0 = typeof(MySpace).mock
-		when(spc0.internalStrongParticipantStructure).thenReturn(map0)
-		when(spc0.internalWeakParticipantStructure).thenReturn(map0)
 		var ctx0 = typeof(Context).mock
 		when(ctx0.defaultSpace).thenReturn(spc0)
 
@@ -141,8 +136,6 @@ class SkillNamespaceFinderTest {
 		map1b.put(UUID::randomUUID, typeof(Participant).mock)
 		this.sid1 = UUID::randomUUID
 		var spc1 = typeof(MySpace).mock
-		when(spc1.internalStrongParticipantStructure).thenReturn(map1)
-		when(spc1.internalWeakParticipantStructure).thenReturn(map1b)
 		this.cid1 = UUID::randomUUID
 		var ctx1 = typeof(Context).mock
 		when(ctx1.getSpace(any(typeof(UUID)))).thenAnswer [

diff --git a/...tests/src/test/sarl/io/sarl/sre/tests/units/skills/bic/mocks/MyInternalEventBusSkill.sarl b/...tests/src/test/sarl/io/sarl/sre/tests/units/skills/bic/mocks/MyInternalEventBusSkill.sarl
@@ -60,12 +60,13 @@ skill MyInternalEventBusSkill implements InternalEventBusCapacity {
 	override unregisterEventBusListener(type : Class<?>, callback : (Object)=>boolean) {
 	}
 
-	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean) : Iterable<Event> {
+	override fireEventAndWait(^event : Event, gatherEvents : boolean,
+		thrownExceptions : boolean) : ConcurrentLinkedDeque<Event> {
 		null
 	}
 
 	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean,
-	listener : Object) : Iterable<Event> {
+	listener : Object) : ConcurrentLinkedDeque<Event> {
 		null
 	}
 

diff --git a/...ests/src/test/sarl/io/sarl/sre/tests/units/skills/bic/mocks/MyInternalEventBusSkill2.sarl b/...ests/src/test/sarl/io/sarl/sre/tests/units/skills/bic/mocks/MyInternalEventBusSkill2.sarl
@@ -49,12 +49,13 @@ skill MyInternalEventBusSkill2 implements InternalEventBusCapacity {
 	override unregisterEventBusListener(type : Class<?>, callback : (Object)=>boolean) {
 	}
 
-	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean) : Iterable<Event> {
+	override fireEventAndWait(^event : Event, gatherEvents : boolean,
+		thrownExceptions : boolean) : ConcurrentLinkedDeque<Event> {
 		null
 	}
 
 	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean,
-				listener : Object) : Iterable<Event> {
+				listener : Object) : ConcurrentLinkedDeque<Event> {
 		null
 	}
 

diff --git a/...io.janusproject.tests/src/test/sarl/io/sarl/sre/tests/units/skills/bic/mocks/MySkill.sarl b/...io.janusproject.tests/src/test/sarl/io/sarl/sre/tests/units/skills/bic/mocks/MySkill.sarl
@@ -46,12 +46,13 @@ skill MySkill implements InternalEventBusCapacity {
 	override unregisterEventBusListener(type : Class<?>, callback : (Object)=>boolean) {
 	}
 
-	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean) : Iterable<Event> {
+	override fireEventAndWait(^event : Event, gatherEvents : boolean,
+		thrownExceptions : boolean) : ConcurrentLinkedDeque<Event> {
 		null
 	}
 
 	override fireEventAndWait(^event : Event, gatherEvents : boolean, thrownExceptions : boolean,
-		listener : Object) : Iterable<Event> {
+		listener : Object) : ConcurrentLinkedDeque<Event> {
 		null
 	}