123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259 |
- """
- Generated by Statechart compiler by Glenn De Jonghe, Joeri Exelmans, Simon Van Mierlo, and Yentl Van Tendeloo (for the inspiration) and Sam Pieters (DEVS)
- Model author: Sam Pieters
- Model name: Timer (Eventloop Version)
- """
- from sccd.runtime.DEVS_statecharts_core import *
- from sccd.runtime.libs.ui import ui
- import time
- CANVAS_DIMS = (350, 300)
- # package "Timer (Eventloop Version)"
- class MainAppInstance(RuntimeClassBase):
- def __init__(self, atomdevs, id, start_port_id):
- RuntimeClassBase.__init__(self, atomdevs, id)
-
- self.semantics.big_step_maximality = StatechartSemantics.TakeMany
- self.semantics.internal_event_lifeline = StatechartSemantics.Queue
- self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
- self.semantics.priority = StatechartSemantics.SourceParent
- self.semantics.concurrency = StatechartSemantics.Single
-
- # build Statechart structure
- self.build_statechart_structure()
-
- # user defined attributes
- self.window_id = None
- self.canvas_id = None
- self.clock_id = None
- self.actual_clock_id = None
- self.button_id = None
- self.starting_time = None
-
- # call user defined constructor
- MainAppInstance.user_defined_constructor(self)
- port_name = addInputPort("ui", start_port_id, True)
- atomdevs.state.port_mappings[port_name] = None
- port_name = addInputPort("<narrow_cast>", start_port_id)
- atomdevs.state.port_mappings[port_name] = id
- port_name = addInputPort("field_ui", start_port_id + 1)
- atomdevs.state.port_mappings[port_name] = id
- self.inports["field_ui"] = port_name
-
- def user_defined_constructor(self):
- pass
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, "", self)
-
- # state /creating_window
- self.states["/creating_window"] = State(1, "/creating_window", self)
- self.states["/creating_window"].setEnter(self._creating_window_enter)
-
- # state /creating_canvas
- self.states["/creating_canvas"] = State(2, "/creating_canvas", self)
- self.states["/creating_canvas"].setEnter(self._creating_canvas_enter)
-
- # state /creating_clock_text
- self.states["/creating_clock_text"] = State(3, "/creating_clock_text", self)
- self.states["/creating_clock_text"].setEnter(self._creating_clock_text_enter)
-
- # state /creating_actual_clock_text
- self.states["/creating_actual_clock_text"] = State(4, "/creating_actual_clock_text", self)
- self.states["/creating_actual_clock_text"].setEnter(self._creating_actual_clock_text_enter)
-
- # state /creating_interrupt_button
- self.states["/creating_interrupt_button"] = State(5, "/creating_interrupt_button", self)
- self.states["/creating_interrupt_button"].setEnter(self._creating_interrupt_button_enter)
-
- # state /running
- self.states["/running"] = State(6, "/running", self)
- self.states["/running"].setEnter(self._running_enter)
- self.states["/running"].setExit(self._running_exit)
-
- # state /interrupted
- self.states["/interrupted"] = State(7, "/interrupted", self)
-
- # add children
- self.states[""].addChild(self.states["/creating_window"])
- self.states[""].addChild(self.states["/creating_canvas"])
- self.states[""].addChild(self.states["/creating_clock_text"])
- self.states[""].addChild(self.states["/creating_actual_clock_text"])
- self.states[""].addChild(self.states["/creating_interrupt_button"])
- self.states[""].addChild(self.states["/running"])
- self.states[""].addChild(self.states["/interrupted"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/creating_window"]
-
- # transition /creating_window
- _creating_window_0 = Transition(self, self.states["/creating_window"], [self.states["/creating_canvas"]])
- _creating_window_0.setAction(self._creating_window_0_exec)
- _creating_window_0.setTrigger(Event("window_created", None))
- self.states["/creating_window"].addTransition(_creating_window_0)
-
- # transition /creating_canvas
- _creating_canvas_0 = Transition(self, self.states["/creating_canvas"], [self.states["/creating_clock_text"]])
- _creating_canvas_0.setAction(self._creating_canvas_0_exec)
- _creating_canvas_0.setTrigger(Event("canvas_created", None))
- self.states["/creating_canvas"].addTransition(_creating_canvas_0)
-
- # transition /creating_clock_text
- _creating_clock_text_0 = Transition(self, self.states["/creating_clock_text"], [self.states["/creating_actual_clock_text"]])
- _creating_clock_text_0.setAction(self._creating_clock_text_0_exec)
- _creating_clock_text_0.setTrigger(Event("text_created", None))
- self.states["/creating_clock_text"].addTransition(_creating_clock_text_0)
-
- # transition /creating_actual_clock_text
- _creating_actual_clock_text_0 = Transition(self, self.states["/creating_actual_clock_text"], [self.states["/creating_interrupt_button"]])
- _creating_actual_clock_text_0.setAction(self._creating_actual_clock_text_0_exec)
- _creating_actual_clock_text_0.setTrigger(Event("text_created", None))
- self.states["/creating_actual_clock_text"].addTransition(_creating_actual_clock_text_0)
-
- # transition /creating_interrupt_button
- _creating_interrupt_button_0 = Transition(self, self.states["/creating_interrupt_button"], [self.states["/running"]])
- _creating_interrupt_button_0.setAction(self._creating_interrupt_button_0_exec)
- _creating_interrupt_button_0.setTrigger(Event("button_created", None))
- self.states["/creating_interrupt_button"].addTransition(_creating_interrupt_button_0)
-
- # transition /running
- _running_0 = Transition(self, self.states["/running"], [self.states["/running"]])
- _running_0.setAction(self._running_0_exec)
- _running_0.setTrigger(Event("_0after"))
- self.states["/running"].addTransition(_running_0)
- _running_1 = Transition(self, self.states["/running"], [self.states["/interrupted"]])
- _running_1.setTrigger(Event("mouse_click", self.getInPortName("field_ui")))
- _running_1.setGuard(self._running_1_guard)
- self.states["/running"].addTransition(_running_1)
-
- # transition /interrupted
- _interrupted_0 = Transition(self, self.states["/interrupted"], [self.states["/running"]])
- _interrupted_0.setTrigger(Event("mouse_click", self.getInPortName("field_ui")))
- _interrupted_0.setGuard(self._interrupted_0_guard)
- self.states["/interrupted"].addTransition(_interrupted_0)
-
- def _creating_window_enter(self):
- self.big_step.outputEvent(Event("create_window", self.getOutPortName("ui"), [CANVAS_DIMS[0], CANVAS_DIMS[1], "Timer", self.inports['field_ui']]))
-
- def _creating_canvas_enter(self):
- self.big_step.outputEvent(Event("create_canvas", self.getOutPortName("ui"), [self.window_id, CANVAS_DIMS[0], CANVAS_DIMS[1] - 200, {'background':'#222222'}, self.inports['field_ui']]))
-
- def _creating_clock_text_enter(self):
- self.big_step.outputEvent(Event("create_text", self.getOutPortName("ui"), [self.canvas_id, 50, 50, '', self.inports['field_ui']]))
-
- def _creating_actual_clock_text_enter(self):
- self.big_step.outputEvent(Event("create_text", self.getOutPortName("ui"), [self.canvas_id, 50, 100, '', self.inports['field_ui']]))
-
- def _creating_interrupt_button_enter(self):
- self.big_step.outputEvent(Event("create_button", self.getOutPortName("ui"), [self.window_id, 'INTERRUPT/CONTINUE', self.inports['field_ui']]))
-
- def _running_enter(self):
- self.addTimer(0, 0.05)
-
- def _running_exit(self):
- self.removeTimer(0)
-
- def _creating_window_0_exec(self, parameters):
- window_id = parameters[0]
- self.window_id = window_id
- self.starting_time = time.time()
- self.big_step.outputEvent(Event("bind_event", self.getOutPortName("ui"), [window_id, ui.EVENTS.WINDOW_CLOSE, 'window_close', self.inports['field_ui']]))
- self.big_step.outputEvent(Event("bind_event", self.getOutPortName("ui"), [window_id, ui.EVENTS.KEY_PRESS, 'key_press', self.inports['field_ui']]))
-
- def _creating_canvas_0_exec(self, parameters):
- canvas_id = parameters[0]
- self.canvas_id = canvas_id
-
- def _creating_clock_text_0_exec(self, parameters):
- canvas_id = parameters[0]
- text_id = parameters[1]
- self.clock_id = text_id
-
- def _creating_actual_clock_text_0_exec(self, parameters):
- canvas_id = parameters[0]
- text_id = parameters[1]
- self.actual_clock_id = text_id
-
- def _creating_interrupt_button_0_exec(self, parameters):
- button_id = parameters[0]
- self.button_id = button_id
- self.big_step.outputEvent(Event("bind_event", self.getOutPortName("ui"), [button_id, ui.EVENTS.MOUSE_CLICK, "mouse_click", self.inports['field_ui']]))
-
- def _running_0_exec(self, parameters):
- self.big_step.outputEvent(Event("update_text", self.getOutPortName("ui"), [self.canvas_id, self.clock_id, str('%.2f' % (self.getSimulatedTime() / 1000.0)), self.inports['field_ui']]))
- self.big_step.outputEvent(Event("update_text", self.getOutPortName("ui"), [self.canvas_id, self.actual_clock_id, str('%.2f' % (time.time() - self.starting_time)), self.inports['field_ui']]))
-
- def _running_1_guard(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- return button == ui.MOUSE_BUTTONS.LEFT
-
- def _interrupted_0_guard(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- return button == ui.MOUSE_BUTTONS.LEFT
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/creating_window"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class MainApp(ClassBase):
- def __init__(self, name):
- ClassBase.__init__(self, name)
- self.input = self.addInPort("input")
- self.glob_outputs["ui"] = self.addOutPort("ui")
- self.field_ui = self.addInPort("field_ui")
- new_instance = self.constructObject(0, 0, [])
- self.state.instances[new_instance.instance_id] = new_instance
- new_instance.start()
- self.state.next_time = 0
-
- def constructObject(self, id, start_port_id, parameters):
- new_instance = MainAppInstance(self, id, start_port_id)
- return new_instance
- def instantiate(self, class_name):
- instance = {}
- instance["name"] = class_name
- if class_name == "MainApp":
- self.narrow_cast_id = self.narrow_cast_id + 1
- instance["associations"] = {}
- else:
- raise Exception("Cannot instantiate class " + class_name)
- return instance
- ObjectManagerState.instantiate = instantiate
- class ObjectManager(ObjectManagerBase):
- def __init__(self, name):
- ObjectManagerBase.__init__(self, name)
- self.state = ObjectManagerState()
- self.input = self.addInPort("input")
- self.output["MainApp"] = self.addOutPort()
- self.state.createInstance("MainApp")
- class Controller(CoupledDEVS):
- def __init__(self, name):
- CoupledDEVS.__init__(self, name)
- self.in_ui = self.addInPort("ui")
- self.out_ui = self.addOutPort("ui")
- self.objectmanager = self.addSubModel(ObjectManager("ObjectManager"))
- self.atomics = []
- self.atomics.append(self.addSubModel(MainApp("MainApp")))
- self.connectPorts(self.atomics[0].obj_manager_out, self.objectmanager.input)
- self.connectPorts(self.objectmanager.output["MainApp"], self.atomics[0].obj_manager_in)
- self.connectPorts(self.atomics[0].glob_outputs["ui"], self.out_ui)
- self.connectPorts(self.in_ui, self.atomics[0].input)
|