Extending local repository for providing new feature to hazelcast net…

…work repository
sarl · Oct 22, 2020 · eb08545 · eb08545
1 parent ac1acba
commit eb08545
Showing 1 changed file with 23 additions and 1 deletion.
diff --git a/....janusproject.plugin/src/main/sarl/io/sarl/sre/services/context/LocalSpaceRepository.sarl b/....janusproject.plugin/src/main/sarl/io/sarl/sre/services/context/LocalSpaceRepository.sarl
@@ -21,13 +21,14 @@
 package io.sarl.sre.services.context
 
 import com.google.inject.Injector
+import io.sarl.lang.core.Space
 import io.sarl.sre.boot.configs.SreConfig
 import io.sarl.sre.internal.SmartListenerCollection
 import io.sarl.sre.services.executor.ExecutorService
+import io.sarl.sre.spaces.SreSpaceSpecificationFactory
 import java.util.UUID
 import java.util.concurrent.ConcurrentHashMap
 import javax.inject.Inject
-import io.sarl.sre.spaces.SreSpaceSpecificationFactory
 
 /** 
  * A repository of spaces specific to a given context.
@@ -89,4 +90,25 @@ class LocalSpaceRepository extends SpaceRepository {
 		this.spaces
 	}
 
+	def existsSpace(spaceUUID : UUID) : boolean {
+		this.spaces.contains(spaceUUID)
+	}
+
+	def removeSpaceIfEmpty(spaceUUID : UUID) {
+		var spaceToRemove: Space = this.spaces.get(spaceUUID).^space
+		if (spaceToRemove.isPseudoEmpty) {
+			super.removeSpace(spaceToRemove)
+		} 		
+	}
+
+	def removeAllSpacesIfEmpty() {
+		var spaceToRemove: Space
+		for (spaceDesc : this.spaces.values) {
+			spaceToRemove = spaceDesc.^space
+			if (spaceToRemove.isPseudoEmpty) {
+				super.removeSpace(spaceToRemove)
+			} 
+		}
+	}
+
 }