|
@@ -1,7 +1,7 @@
|
|
|
"""
|
|
|
Generated by Statechart compiler by Glenn De Jonghe, Joeri Exelmans, Simon Van Mierlo, and Yentl Van Tendeloo (for the inspiration)
|
|
|
|
|
|
-Date: Fri Feb 10 10:24:39 2017
|
|
|
+Date: Fri Feb 10 11:29:04 2017
|
|
|
|
|
|
Model author: Yentl Van Tendeloo
|
|
|
Model name: MvK Server
|
|
@@ -1317,7 +1317,7 @@ class UserStatechart(RuntimeClassBase):
|
|
|
def _running_execution_executing_0_exec(self, parameters):
|
|
|
source = parameters[0]
|
|
|
args = parameters[1]
|
|
|
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/to_mvi/' + source, Event("HTTP_input", None, [json.dumps({'user': self.username, 'state': 'paused', 'info': self.mvk.debug_info})])]))
|
|
|
+ self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/to_mvi/' + source, Event("HTTP_input", None, [json.dumps({'user': self.username, 'state': 'paused', 'info': self.mvk.debug_info[self.username]})])]))
|
|
|
|
|
|
def _init_0_exec(self, parameters):
|
|
|
returnpath = parameters[0]
|
|
@@ -1423,7 +1423,7 @@ class Executor(RuntimeClassBase):
|
|
|
|
|
|
def user_defined_constructor(self):
|
|
|
self.mvs = ModelverseState("../../bootstrap/bootstrap.m.gz")
|
|
|
- self.request_queue = [("", "", "load_primitives", [], None)]
|
|
|
+ self.request_queue = [("", "", "load_primitives", [], None, False)]
|
|
|
self.mvs.GC = True
|
|
|
self.mvk = ModelverseKernel(self.mvs.read_root()[0])
|
|
|
self.first = True
|
|
@@ -1516,6 +1516,10 @@ class Executor(RuntimeClassBase):
|
|
|
_init_queue_queue_0.setAction(self._init_queue_queue_0_exec)
|
|
|
_init_queue_queue_0.setTrigger(Event("execute", None))
|
|
|
self.states["/init/queue/queue"].addTransition(_init_queue_queue_0)
|
|
|
+ _init_queue_queue_1 = Transition(self, self.states["/init/queue/queue"], [self.states["/init/queue/queue"]])
|
|
|
+ _init_queue_queue_1.setAction(self._init_queue_queue_1_exec)
|
|
|
+ _init_queue_queue_1.setTrigger(Event("execute_debug", None))
|
|
|
+ self.states["/init/queue/queue"].addTransition(_init_queue_queue_1)
|
|
|
|
|
|
# transition /init/execute/idle
|
|
|
_init_execute_idle_0 = Transition(self, self.states["/init/execute/idle"], [self.states["/init/execute/execution"]])
|
|
@@ -1539,7 +1543,7 @@ class Executor(RuntimeClassBase):
|
|
|
self.mvk.success = True
|
|
|
self.first = True
|
|
|
|
|
|
- self.returnpath, username, operation, params, self.request_id = self.request_queue.pop(0)
|
|
|
+ self.returnpath, username, operation, params, self.request_id, self.mvk.allow_compiled = self.request_queue.pop(0)
|
|
|
reply = None
|
|
|
commands = []
|
|
|
while 1:
|
|
@@ -1564,7 +1568,15 @@ class Executor(RuntimeClassBase):
|
|
|
operation = parameters[2]
|
|
|
params = parameters[3]
|
|
|
request_id = parameters[4]
|
|
|
- self.request_queue.append((("/" + returnpath) if returnpath is not None else None, username, operation, params, request_id))
|
|
|
+ self.request_queue.append((("/" + returnpath) if returnpath is not None else None, username, operation, params, request_id, True))
|
|
|
+
|
|
|
+ def _init_queue_queue_1_exec(self, parameters):
|
|
|
+ returnpath = parameters[0]
|
|
|
+ username = parameters[1]
|
|
|
+ operation = parameters[2]
|
|
|
+ params = parameters[3]
|
|
|
+ request_id = parameters[4]
|
|
|
+ self.request_queue.append((("/" + returnpath) if returnpath is not None else None, username, operation, params, request_id, False))
|
|
|
|
|
|
def _init_execute_idle_0_guard(self, parameters):
|
|
|
return self.request_queue
|