Each segment has its own yakindu message topic, each node of the distributed yakindu statecharts subscribes only for those yakindu topics in which it is interested in (controlled sections + turnout + neighbour segment topics), yakindu messages are moved to the common messages package and sending yakindu message is also possible using the communication lib.

Author: benedekh

src/java/components/barrier/src/main/java/hu/bme/mit/inf/modes3/components/barrier/app/Main.xtend

@@ -20,11 +20,11 @@ class Main {
 
 		registry.parseArguments(args)
 
-		val occupancyTopics = TopicFactory::createSegmentTopics(#{SegmentOccupancyMessage}).toSet
+		val supervisedSections = #{15, 24}
+		val occupancyTopics = TopicFactory::createSegmentTopics(supervisedSections, #{SegmentOccupancyMessage}).toSet
 		val railwayTrackCommunicationStack = MessagingServiceFactory::createStackForTopics(registry, loggerFactory, occupancyTopics)
 
 		val barrierCommunicationStack = JsonDispatcherFactory::createMQTTStackWithJSON(registry, loggerFactory)
-		val supervisedSections = #{15, 24}
 
 		val component = new TrackSupervisor(supervisedSections)
 		val componentWrapper = new TrackSupervisorBridge(component, railwayTrackCommunicationStack, barrierCommunicationStack, loggerFactory)

src/java/components/safetylogic/componentlevel.sc/src/main/java/hu/bme/mit/inf/modes3/components/safetylogic/componentlevel/sc/SafetyLogicInitializer.xtend

@@ -7,7 +7,6 @@ import hu.bme.mit.gamma.impl.async_t4.AsyncT4Component
 import hu.bme.mit.gamma.impl.async_t5.AsyncT5Component
 import hu.bme.mit.gamma.impl.async_t6.AsyncT6Component
 import hu.bme.mit.gamma.impl.interfaces.ProtocolInterface
-import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.comm.dispatcher.IYakinduMessageSender
 import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.wrapper.IYakinduProtocolDispatcher
 import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.wrapper.IYakinduProtocolRestarter
 import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.wrapper.PortWithDirection
@@ -17,10 +16,11 @@ import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.wrapper.Tu
 import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.wrapper.YakinduProtocolAdapter
 import hu.bme.mit.inf.modes3.messaging.communication.command.trackelement.interfaces.ITrackElementCommander
 import hu.bme.mit.inf.modes3.messaging.communication.state.trackelement.interfaces.ITrackElementStateRegistry
+import hu.bme.mit.inf.modes3.messaging.communication.yakindu.interfaces.IYakinduMessageSender
 import org.slf4j.ILoggerFactory
 import org.slf4j.Logger
 
-import static hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.ConnectionDirection.*
+import static hu.bme.mit.inf.modes3.messaging.messages.enums.ConnectionDirection.*
 
 class SafetyLogicInitializer {
 	val Logger logger

src/java/components/safetylogic/componentlevel.sc/src/main/java/hu/bme/mit/inf/modes3/components/safetylogic/componentlevel/sc/app/Main.xtend

@@ -7,9 +7,9 @@ import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.comm.dispa
 import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.wrapper.YakinduProtocolDispatcher
 import hu.bme.mit.inf.modes3.messaging.communication.factory.MessagingServiceFactory
 import hu.bme.mit.inf.modes3.messaging.communication.factory.TopicFactory
+import hu.bme.mit.inf.modes3.messaging.communication.factory.YakinduTopicFactory
 import hu.bme.mit.inf.modes3.messaging.messages.command.SegmentCommand
 import hu.bme.mit.inf.modes3.messaging.messages.status.SegmentOccupancyMessage
-import hu.bme.mit.inf.modes3.messaging.messages.status.SegmentStateMessage
 import hu.bme.mit.inf.modes3.utils.common.jopt.ArgumentDescriptorWithParameter
 import hu.bme.mit.inf.modes3.utils.common.jopt.ArgumentRegistry
 import hu.bme.mit.inf.modes3.utils.conf.layout.LayoutConfiguration
@@ -20,27 +20,27 @@ class Main {
 
 	def static void main(String[] args) {
 		System.setProperty(SimpleLogger.LOG_FILE_KEY, "System.out")
-		//System.setProperty(SimpleLogger.DEFAULT_LOG_LEVEL_KEY, "trace")
+		System.setProperty(SimpleLogger.DEFAULT_LOG_LEVEL_KEY, "info")
 
 		val loggerFactory = new SimpleLoggerFactory
 		val logger = loggerFactory.getLogger(Main.name)
+		val layout = LayoutConfiguration.INSTANCE
 
 		val registry = new ArgumentRegistry(loggerFactory)
 		registry.registerArgumentWithOptions(new ArgumentDescriptorWithParameter("id", "ID of the turnout", String))
 		registry.registerArgumentWithOptions(new ArgumentDescriptorWithParameter("address", "The address of the transport server", String))
 		registry.registerArgumentWithOptions(new ArgumentDescriptorWithParameter("port", "The port used by the transport server", Integer))
 
-		registry.parseArguments(args);
+		registry.parseArguments(args)
 
 		val hostname = registry.getParameterStringValue("id")
 		val turnoutID = Integer.valueOf(hostname.split("\\.").head.replace('t', ''))
 
-		val controlledSections = LayoutConfiguration.INSTANCE.getControlledSections(turnoutID)
-		val turnoutSegmentItself = LayoutConfiguration.INSTANCE.getSegmentIdsOfTurnout(turnoutID)
-
-		val sectionTopics = controlledSections.map[TopicFactory::createSegmentTopics(it, #{SegmentCommand, SegmentStateMessage, SegmentOccupancyMessage})].flatten.toSet
-		val turnoutOccupancyTopic = turnoutSegmentItself.map[TopicFactory::createSegmentTopics(it, #{SegmentOccupancyMessage})].flatten.toSet
+		val controlledSections = layout.getControlledSections(turnoutID)
+		val turnoutSegmentItself = layout.getSegmentIdsOfTurnout(turnoutID)
 
+		val sectionTopics = TopicFactory::createSegmentTopics(controlledSections, #{SegmentCommand, SegmentOccupancyMessage})
+		val turnoutOccupancyTopic = TopicFactory::createSegmentTopics(turnoutSegmentItself, #{SegmentOccupancyMessage})
 		val turnoutTopics = TopicFactory::createTurnoutTopics(turnoutID)
 
 		val topics = newHashSet
@@ -51,7 +51,21 @@ class Main {
 		val communicationStack = MessagingServiceFactory::createStackForTopics(registry, loggerFactory, topics)
 		logger.debug('''Subscribed for railway track topics: «topics»''')
 
-		val yakinduStack = JsonDispatcherFactory::createMQTTStackWithJSON(registry, loggerFactory)
+		val neighbourSections = controlledSections.map[layout.getNeighbourSectionIds(it)].flatten.toSet
+		val turnoutSegments = layout.getSegmentIdsOfTurnout(turnoutID)
+
+		val neighbourSectionYakinduTopics = YakinduTopicFactory::createYakinduTopics(neighbourSections)
+		val controlledSectionsYakinduTopics = YakinduTopicFactory::createYakinduTopics(controlledSections)
+		val turnoutYakinduTopics = YakinduTopicFactory::createYakinduTopics(turnoutSegments)
+
+		val yakinduTopics = newHashSet
+		yakinduTopics.addAll(neighbourSectionYakinduTopics)
+		yakinduTopics.addAll(controlledSectionsYakinduTopics)
+		yakinduTopics.addAll(turnoutYakinduTopics)
+
+		val yakinduStack = JsonDispatcherFactory::createMQTTStackWithJSON(registry, loggerFactory, yakinduTopics)
+		logger.debug('''Subscribed for yakindu topics: «yakinduTopics»''')
+
 		val yakinduDispatcher = (yakinduStack.dispatcher as JsonMessageDispatcher)
 		val yakinduProtocolDispatcher = new YakinduProtocolDispatcher(loggerFactory)
 		yakinduDispatcher.canGoToListener = yakinduProtocolDispatcher

src/java/components/safetylogic/componentlevel.sc/src/main/java/hu/bme/mit/inf/modes3/components/safetylogic/componentlevel/sc/bridge/ISafetyLogicBridge.xtend

@@ -1,9 +1,9 @@
 package hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.bridge
 
-import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.comm.dispatcher.IYakinduMessageSender
 import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.wrapper.IYakinduProtocolDispatcher
 import hu.bme.mit.inf.modes3.messaging.communication.command.trackelement.interfaces.ITrackElementCommander
 import hu.bme.mit.inf.modes3.messaging.communication.state.trackelement.interfaces.ITrackElementStateRegistry
+import hu.bme.mit.inf.modes3.messaging.communication.yakindu.interfaces.IYakinduMessageSender
 
 interface ISafetyLogicBridge extends IYakinduMessageSender, IYakinduProtocolDispatcher {
 

src/java/components/safetylogic/componentlevel.sc/src/main/java/hu/bme/mit/inf/modes3/components/safetylogic/componentlevel/sc/bridge/SafetyLogicBridge.xtend

@@ -1,12 +1,12 @@
 package hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.bridge
 
-import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.ConnectionDirection
 import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.ISafetyLogic
-import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.comm.dispatcher.IYakinduMessageSender
-import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.comm.dispatcher.YakinduMessageSender
 import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.wrapper.IYakinduProtocolDispatcher
 import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.wrapper.PortWithDirection
 import hu.bme.mit.inf.modes3.messaging.communication.common.AbstractCommunicationComponent
+import hu.bme.mit.inf.modes3.messaging.communication.yakindu.YakinduMessageSender
+import hu.bme.mit.inf.modes3.messaging.communication.yakindu.interfaces.IYakinduMessageSender
+import hu.bme.mit.inf.modes3.messaging.messages.enums.ConnectionDirection
 import hu.bme.mit.inf.modes3.messaging.mms.MessagingService
 import org.eclipse.xtend.lib.annotations.Accessors
 import org.slf4j.ILoggerFactory

src/java/components/safetylogic/componentlevel.sc/src/main/java/hu/bme/mit/inf/modes3/components/safetylogic/componentlevel/sc/comm/dispatcher/ICanGoToListener.xtend

@@ -1,21 +1,13 @@
 package hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.comm.dispatcher
 
-import hu.bme.mit.inf.modes3.components.safetylogic.componentlevel.sc.comm.messages.YakinduProtocolMessage
 import hu.bme.mit.inf.modes3.messaging.communication.factory.MessagingServiceFactory
-import hu.bme.mit.inf.modes3.messaging.messages.core.InternalMessageToTopicMapper
 import hu.bme.mit.inf.modes3.utils.common.jopt.ArgumentRegistry
+import java.util.Set
 import org.slf4j.ILoggerFactory
 
 class JsonDispatcherFactory {
 
-	def static createMQTTStackWithJSON(ArgumentRegistry argumentRegistry, ILoggerFactory factory) {
-		val topics = InternalMessageToTopicMapper.INSTANCE.getTopics(YakinduProtocolMessage.simpleName)
-		val dispatcher = new JsonMessageDispatcher(factory)
-		val communicationStack = MessagingServiceFactory::createStackForTopics(argumentRegistry, factory, topics, dispatcher)
-
-		val logger = factory.getLogger(JsonDispatcherFactory.name)
-		logger.debug('''Subscribed for Yakindu topics: «topics»''')
-
-		return communicationStack
+	def static createMQTTStackWithJSON(ArgumentRegistry argumentRegistry, ILoggerFactory factory, Set<String> topics) {
+		return MessagingServiceFactory::createStackForTopics(argumentRegistry, factory, topics, new JsonMessageDispatcher(factory))
 	}
 }