parallel_history.py 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198
  1. """
  2. Generated by Statechart compiler by Glenn De Jonghe, Joeri Exelmans, Simon Van Mierlo, and Yentl Van Tendeloo (for the inspiration)
  3. Date: Mon Aug 08 09:49:25 2016
  4. Model author: Glenn De Jonghe
  5. Model name: TestParallelHistory
  6. Model description:
  7. Testing history in parallel.
  8. """
  9. from sccd.runtime.statecharts_core import *
  10. # package "TestParallelHistory"
  11. class TestClass(RuntimeClassBase):
  12. def __init__(self, controller):
  13. RuntimeClassBase.__init__(self, controller)
  14. self.semantics.big_step_maximality = StatechartSemantics.TakeMany
  15. self.semantics.internal_event_lifeline = StatechartSemantics.Queue
  16. self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
  17. self.semantics.priority = StatechartSemantics.SourceParent
  18. self.semantics.concurrency = StatechartSemantics.Single
  19. # build Statechart structure
  20. self.build_statechart_structure()
  21. # call user defined constructor
  22. TestClass.user_defined_constructor(self)
  23. def user_defined_constructor(self):
  24. pass
  25. def user_defined_destructor(self):
  26. pass
  27. # builds Statechart structure
  28. def build_statechart_structure(self):
  29. # state <root>
  30. self.states[""] = State(0, self)
  31. # state /parallel
  32. self.states["/parallel"] = ParallelState(1, self)
  33. # state /parallel/orthogonal_1
  34. self.states["/parallel/orthogonal_1"] = State(2, self)
  35. # state /parallel/orthogonal_1/orthogonal_inner_1
  36. self.states["/parallel/orthogonal_1/orthogonal_inner_1"] = State(3, self)
  37. # state /parallel/orthogonal_1/orthogonal_inner_1/state_1
  38. self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_1"] = State(4, self)
  39. self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_1"].setEnter(self._parallel_orthogonal_1_orthogonal_inner_1_state_1_enter)
  40. # state /parallel/orthogonal_1/orthogonal_inner_1/state_2
  41. self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_2"] = State(5, self)
  42. self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_2"].setEnter(self._parallel_orthogonal_1_orthogonal_inner_1_state_2_enter)
  43. # state /parallel/orthogonal_1/orthogonal_inner_1/history_1
  44. self.states["/parallel/orthogonal_1/orthogonal_inner_1/history_1"] = ShallowHistoryState(6, self)
  45. # state /parallel/orthogonal_1/outer_1
  46. self.states["/parallel/orthogonal_1/outer_1"] = State(7, self)
  47. self.states["/parallel/orthogonal_1/outer_1"].setEnter(self._parallel_orthogonal_1_outer_1_enter)
  48. # state /parallel/orthogonal_2
  49. self.states["/parallel/orthogonal_2"] = State(8, self)
  50. # state /parallel/orthogonal_2/orthogonal_inner_2
  51. self.states["/parallel/orthogonal_2/orthogonal_inner_2"] = State(9, self)
  52. # state /parallel/orthogonal_2/orthogonal_inner_2/state_3
  53. self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_3"] = State(10, self)
  54. self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_3"].setEnter(self._parallel_orthogonal_2_orthogonal_inner_2_state_3_enter)
  55. # state /parallel/orthogonal_2/orthogonal_inner_2/state_4
  56. self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_4"] = State(11, self)
  57. self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_4"].setEnter(self._parallel_orthogonal_2_orthogonal_inner_2_state_4_enter)
  58. # state /parallel/orthogonal_2/orthogonal_inner_2/history_2
  59. self.states["/parallel/orthogonal_2/orthogonal_inner_2/history_2"] = ShallowHistoryState(12, self)
  60. # state /parallel/orthogonal_2/outer_2
  61. self.states["/parallel/orthogonal_2/outer_2"] = State(13, self)
  62. self.states["/parallel/orthogonal_2/outer_2"].setEnter(self._parallel_orthogonal_2_outer_2_enter)
  63. # add children
  64. self.states[""].addChild(self.states["/parallel"])
  65. self.states["/parallel"].addChild(self.states["/parallel/orthogonal_1"])
  66. self.states["/parallel"].addChild(self.states["/parallel/orthogonal_2"])
  67. self.states["/parallel/orthogonal_1"].addChild(self.states["/parallel/orthogonal_1/orthogonal_inner_1"])
  68. self.states["/parallel/orthogonal_1"].addChild(self.states["/parallel/orthogonal_1/outer_1"])
  69. self.states["/parallel/orthogonal_1/orthogonal_inner_1"].addChild(self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_1"])
  70. self.states["/parallel/orthogonal_1/orthogonal_inner_1"].addChild(self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_2"])
  71. self.states["/parallel/orthogonal_1/orthogonal_inner_1"].addChild(self.states["/parallel/orthogonal_1/orthogonal_inner_1/history_1"])
  72. self.states["/parallel/orthogonal_2"].addChild(self.states["/parallel/orthogonal_2/orthogonal_inner_2"])
  73. self.states["/parallel/orthogonal_2"].addChild(self.states["/parallel/orthogonal_2/outer_2"])
  74. self.states["/parallel/orthogonal_2/orthogonal_inner_2"].addChild(self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_3"])
  75. self.states["/parallel/orthogonal_2/orthogonal_inner_2"].addChild(self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_4"])
  76. self.states["/parallel/orthogonal_2/orthogonal_inner_2"].addChild(self.states["/parallel/orthogonal_2/orthogonal_inner_2/history_2"])
  77. self.states[""].fixTree()
  78. self.states[""].default_state = self.states["/parallel"]
  79. self.states["/parallel/orthogonal_1"].default_state = self.states["/parallel/orthogonal_1/orthogonal_inner_1"]
  80. self.states["/parallel/orthogonal_1/orthogonal_inner_1"].default_state = self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_1"]
  81. self.states["/parallel/orthogonal_2"].default_state = self.states["/parallel/orthogonal_2/orthogonal_inner_2"]
  82. self.states["/parallel/orthogonal_2/orthogonal_inner_2"].default_state = self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_3"]
  83. # transition /parallel/orthogonal_1/orthogonal_inner_1/state_1
  84. _parallel_orthogonal_1_orthogonal_inner_1_state_1_0 = Transition(self, self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_1"], [self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_2"]])
  85. _parallel_orthogonal_1_orthogonal_inner_1_state_1_0.setTrigger(Event("to_state_2", "test_input"))
  86. self.states["/parallel/orthogonal_1/orthogonal_inner_1/state_1"].addTransition(_parallel_orthogonal_1_orthogonal_inner_1_state_1_0)
  87. # transition /parallel/orthogonal_1/outer_1
  88. _parallel_orthogonal_1_outer_1_0 = Transition(self, self.states["/parallel/orthogonal_1/outer_1"], [self.states["/parallel/orthogonal_1/orthogonal_inner_1/history_1"]])
  89. _parallel_orthogonal_1_outer_1_0.setTrigger(Event("to_history_1", "test_input"))
  90. self.states["/parallel/orthogonal_1/outer_1"].addTransition(_parallel_orthogonal_1_outer_1_0)
  91. # transition /parallel/orthogonal_2/orthogonal_inner_2/state_3
  92. _parallel_orthogonal_2_orthogonal_inner_2_state_3_0 = Transition(self, self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_3"], [self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_4"]])
  93. _parallel_orthogonal_2_orthogonal_inner_2_state_3_0.setTrigger(Event("to_state_4", "test_input"))
  94. self.states["/parallel/orthogonal_2/orthogonal_inner_2/state_3"].addTransition(_parallel_orthogonal_2_orthogonal_inner_2_state_3_0)
  95. # transition /parallel/orthogonal_2/outer_2
  96. _parallel_orthogonal_2_outer_2_0 = Transition(self, self.states["/parallel/orthogonal_2/outer_2"], [self.states["/parallel/orthogonal_2/orthogonal_inner_2/history_2"]])
  97. _parallel_orthogonal_2_outer_2_0.setTrigger(Event("to_history_2", "test_input"))
  98. self.states["/parallel/orthogonal_2/outer_2"].addTransition(_parallel_orthogonal_2_outer_2_0)
  99. # transition /parallel/orthogonal_1/orthogonal_inner_1
  100. _parallel_orthogonal_1_orthogonal_inner_1_0 = Transition(self, self.states["/parallel/orthogonal_1/orthogonal_inner_1"], [self.states["/parallel/orthogonal_1/outer_1"]])
  101. _parallel_orthogonal_1_orthogonal_inner_1_0.setTrigger(Event("to_outer_1", "test_input"))
  102. self.states["/parallel/orthogonal_1/orthogonal_inner_1"].addTransition(_parallel_orthogonal_1_orthogonal_inner_1_0)
  103. # transition /parallel/orthogonal_2/orthogonal_inner_2
  104. _parallel_orthogonal_2_orthogonal_inner_2_0 = Transition(self, self.states["/parallel/orthogonal_2/orthogonal_inner_2"], [self.states["/parallel/orthogonal_2/outer_2"]])
  105. _parallel_orthogonal_2_orthogonal_inner_2_0.setTrigger(Event("to_outer_2", "test_input"))
  106. self.states["/parallel/orthogonal_2/orthogonal_inner_2"].addTransition(_parallel_orthogonal_2_orthogonal_inner_2_0)
  107. def _parallel_orthogonal_1_orthogonal_inner_1_state_1_enter(self):
  108. self.big_step.outputEvent(Event("in_state_1", "test_output", []))
  109. def _parallel_orthogonal_1_orthogonal_inner_1_state_2_enter(self):
  110. self.big_step.outputEvent(Event("in_state_2", "test_output", []))
  111. def _parallel_orthogonal_1_outer_1_enter(self):
  112. self.big_step.outputEvent(Event("in_outer_1", "test_output", []))
  113. def _parallel_orthogonal_2_orthogonal_inner_2_state_3_enter(self):
  114. self.big_step.outputEvent(Event("in_state_3", "test_output", []))
  115. def _parallel_orthogonal_2_orthogonal_inner_2_state_4_enter(self):
  116. self.big_step.outputEvent(Event("in_state_4", "test_output", []))
  117. def _parallel_orthogonal_2_outer_2_enter(self):
  118. self.big_step.outputEvent(Event("in_outer_2", "test_output", []))
  119. def initializeStatechart(self):
  120. # enter default state
  121. states = self.states["/parallel"].getEffectiveTargetStates()
  122. self.updateConfiguration(states)
  123. for state in states:
  124. if state.enter:
  125. state.enter()
  126. class ObjectManager(ObjectManagerBase):
  127. def __init__(self, controller):
  128. ObjectManagerBase.__init__(self, controller)
  129. def instantiate(self, class_name, construct_params):
  130. if class_name == "TestClass":
  131. instance = TestClass(self.controller)
  132. instance.associations = {}
  133. else:
  134. raise Exception("Cannot instantiate class " + class_name)
  135. return instance
  136. class Controller(ThreadsControllerBase):
  137. def __init__(self, keep_running = None):
  138. if keep_running == None: keep_running = True
  139. ThreadsControllerBase.__init__(self, ObjectManager(self), keep_running)
  140. self.addInputPort("test_input")
  141. self.addOutputPort("test_output")
  142. self.object_manager.createInstance("TestClass", [])
  143. class InputEvent:
  144. def __init__(self, name, port, parameters, time_offset):
  145. self.name = name
  146. self.port = port
  147. self.parameters = parameters
  148. self.time_offset = time_offset
  149. class Test:
  150. def __init__(self):
  151. pass
  152. input_events = [InputEvent("to_state_2", "test_input", [], 0.0), InputEvent("to_state_4", "test_input", [], 0.0), InputEvent("to_outer_1", "test_input", [], 0.0), InputEvent("to_outer_2", "test_input", [], 0.0), InputEvent("to_history_1", "test_input", [], 0.0), InputEvent("to_history_2", "test_input", [], 0.0)]
  153. expected_events = [[Event("in_state_1", "test_output", []), Event("in_state_3", "test_output", [])], [Event("in_state_2", "test_output", [])], [Event("in_state_4", "test_output", [])], [Event("in_outer_1", "test_output", [])], [Event("in_outer_2", "test_output", [])], [Event("in_state_2", "test_output", [])], [Event("in_state_4", "test_output", [])]]