server.py 80 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554
  1. """
  2. Generated by Statechart compiler by Glenn De Jonghe, Joeri Exelmans, Simon Van Mierlo, and Yentl Van Tendeloo (for the inspiration)
  3. Date: Thu Feb 9 14:45:08 2017
  4. Model author: Yentl Van Tendeloo
  5. Model name: MvK Server
  6. Model description:
  7. Modelverse Kernel server. Server for the MvI, client of the MvS.
  8. """
  9. from sccd.runtime.statecharts_core import *
  10. import time
  11. import os
  12. import urllib
  13. import sys
  14. import json
  15. from modelverse_kernel.main import ModelverseKernel
  16. sys.path.append("../../state")
  17. from modelverse_state.main import ModelverseState
  18. # package "MvK Server"
  19. class MvKController(RuntimeClassBase):
  20. def __init__(self, controller, params):
  21. RuntimeClassBase.__init__(self, controller)
  22. self.semantics.big_step_maximality = StatechartSemantics.TakeMany
  23. self.semantics.internal_event_lifeline = StatechartSemantics.Queue
  24. self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
  25. self.semantics.priority = StatechartSemantics.SourceParent
  26. self.semantics.concurrency = StatechartSemantics.Single
  27. # build Statechart structure
  28. self.build_statechart_structure()
  29. # call user defined constructor
  30. MvKController.user_defined_constructor(self, params)
  31. def user_defined_constructor(self, params):
  32. self.users = []
  33. self.user_statecharts = {"__hierarchy": None}
  34. self.input_queue = []
  35. self.user_queue = {}
  36. self.source = None
  37. self.root = None
  38. self.params = params
  39. def user_defined_destructor(self):
  40. pass
  41. # builds Statechart structure
  42. def build_statechart_structure(self):
  43. # state <root>
  44. self.states[""] = State(0, self)
  45. # state /init_server
  46. self.states["/init_server"] = State(1, self)
  47. self.states["/init_server"].setEnter(self._init_server_enter)
  48. # state /init_executor
  49. self.states["/init_executor"] = State(2, self)
  50. self.states["/init_executor"].setEnter(self._init_executor_enter)
  51. # state /read_root
  52. self.states["/read_root"] = State(3, self)
  53. self.states["/read_root"].setEnter(self._read_root_enter)
  54. # state /running
  55. self.states["/running"] = ParallelState(4, self)
  56. # state /running/wait_for_requests
  57. self.states["/running/wait_for_requests"] = State(5, self)
  58. # state /running/wait_for_requests/wait
  59. self.states["/running/wait_for_requests/wait"] = State(6, self)
  60. # state /running/push
  61. self.states["/running/push"] = State(7, self)
  62. # state /running/push/wait
  63. self.states["/running/push/wait"] = State(8, self)
  64. # state /running/push/process
  65. self.states["/running/push/process"] = State(9, self)
  66. # state /running/find_users
  67. self.states["/running/find_users"] = State(10, self)
  68. # state /running/find_users/get_all_links
  69. self.states["/running/find_users/get_all_links"] = State(11, self)
  70. self.states["/running/find_users/get_all_links"].setEnter(self._running_find_users_get_all_links_enter)
  71. # state /running/find_users/retrieve_users
  72. self.states["/running/find_users/retrieve_users"] = State(12, self)
  73. # state /running/find_users/got_usernames
  74. self.states["/running/find_users/got_usernames"] = State(13, self)
  75. # state /running/find_users/process_users
  76. self.states["/running/find_users/process_users"] = State(14, self)
  77. # state /running/find_users/creating_user
  78. self.states["/running/find_users/creating_user"] = State(15, self)
  79. # state /running/find_users/wait
  80. self.states["/running/find_users/wait"] = State(16, self)
  81. self.states["/running/find_users/wait"].setEnter(self._running_find_users_wait_enter)
  82. self.states["/running/find_users/wait"].setExit(self._running_find_users_wait_exit)
  83. # add children
  84. self.states[""].addChild(self.states["/init_server"])
  85. self.states[""].addChild(self.states["/init_executor"])
  86. self.states[""].addChild(self.states["/read_root"])
  87. self.states[""].addChild(self.states["/running"])
  88. self.states["/running"].addChild(self.states["/running/wait_for_requests"])
  89. self.states["/running"].addChild(self.states["/running/push"])
  90. self.states["/running"].addChild(self.states["/running/find_users"])
  91. self.states["/running/wait_for_requests"].addChild(self.states["/running/wait_for_requests/wait"])
  92. self.states["/running/push"].addChild(self.states["/running/push/wait"])
  93. self.states["/running/push"].addChild(self.states["/running/push/process"])
  94. self.states["/running/find_users"].addChild(self.states["/running/find_users/get_all_links"])
  95. self.states["/running/find_users"].addChild(self.states["/running/find_users/retrieve_users"])
  96. self.states["/running/find_users"].addChild(self.states["/running/find_users/got_usernames"])
  97. self.states["/running/find_users"].addChild(self.states["/running/find_users/process_users"])
  98. self.states["/running/find_users"].addChild(self.states["/running/find_users/creating_user"])
  99. self.states["/running/find_users"].addChild(self.states["/running/find_users/wait"])
  100. self.states[""].fixTree()
  101. self.states[""].default_state = self.states["/init_server"]
  102. self.states["/running/wait_for_requests"].default_state = self.states["/running/wait_for_requests/wait"]
  103. self.states["/running/push"].default_state = self.states["/running/push/wait"]
  104. self.states["/running/find_users"].default_state = self.states["/running/find_users/get_all_links"]
  105. # transition /init_server
  106. _init_server_0 = Transition(self, self.states["/init_server"], [self.states["/init_executor"]])
  107. _init_server_0.setAction(self._init_server_0_exec)
  108. _init_server_0.setTrigger(Event("instance_created", None))
  109. self.states["/init_server"].addTransition(_init_server_0)
  110. # transition /init_executor
  111. _init_executor_0 = Transition(self, self.states["/init_executor"], [self.states["/read_root"]])
  112. _init_executor_0.setAction(self._init_executor_0_exec)
  113. _init_executor_0.setTrigger(Event("instance_created", None))
  114. self.states["/init_executor"].addTransition(_init_executor_0)
  115. # transition /read_root
  116. _read_root_0 = Transition(self, self.states["/read_root"], [self.states["/running"]])
  117. _read_root_0.setAction(self._read_root_0_exec)
  118. _read_root_0.setTrigger(Event("raw_exec_reply", None))
  119. self.states["/read_root"].addTransition(_read_root_0)
  120. # transition /running/wait_for_requests/wait
  121. _running_wait_for_requests_wait_0 = Transition(self, self.states["/running/wait_for_requests/wait"], [self.states["/running/wait_for_requests/wait"]])
  122. _running_wait_for_requests_wait_0.setAction(self._running_wait_for_requests_wait_0_exec)
  123. _running_wait_for_requests_wait_0.setTrigger(Event("from_mvi", None))
  124. self.states["/running/wait_for_requests/wait"].addTransition(_running_wait_for_requests_wait_0)
  125. # transition /running/push/wait
  126. _running_push_wait_0 = Transition(self, self.states["/running/push/wait"], [self.states["/running/push/process"]])
  127. _running_push_wait_0.setTrigger(None)
  128. _running_push_wait_0.setGuard(self._running_push_wait_0_guard)
  129. self.states["/running/push/wait"].addTransition(_running_push_wait_0)
  130. _running_push_wait_1 = Transition(self, self.states["/running/push/wait"], [self.states["/running/push/wait"]])
  131. _running_push_wait_1.setAction(self._running_push_wait_1_exec)
  132. _running_push_wait_1.setTrigger(None)
  133. _running_push_wait_1.setGuard(self._running_push_wait_1_guard)
  134. self.states["/running/push/wait"].addTransition(_running_push_wait_1)
  135. # transition /running/push/process
  136. _running_push_process_0 = Transition(self, self.states["/running/push/process"], [self.states["/running/push/wait"]])
  137. _running_push_process_0.setAction(self._running_push_process_0_exec)
  138. _running_push_process_0.setTrigger(None)
  139. _running_push_process_0.setGuard(self._running_push_process_0_guard)
  140. self.states["/running/push/process"].addTransition(_running_push_process_0)
  141. _running_push_process_1 = Transition(self, self.states["/running/push/process"], [self.states["/running/push/wait"]])
  142. _running_push_process_1.setAction(self._running_push_process_1_exec)
  143. _running_push_process_1.setTrigger(None)
  144. _running_push_process_1.setGuard(self._running_push_process_1_guard)
  145. self.states["/running/push/process"].addTransition(_running_push_process_1)
  146. # transition /running/find_users/get_all_links
  147. _running_find_users_get_all_links_0 = Transition(self, self.states["/running/find_users/get_all_links"], [self.states["/running/find_users/retrieve_users"]])
  148. _running_find_users_get_all_links_0.setAction(self._running_find_users_get_all_links_0_exec)
  149. _running_find_users_get_all_links_0.setTrigger(Event("raw_exec_reply", None))
  150. self.states["/running/find_users/get_all_links"].addTransition(_running_find_users_get_all_links_0)
  151. # transition /running/find_users/retrieve_users
  152. _running_find_users_retrieve_users_0 = Transition(self, self.states["/running/find_users/retrieve_users"], [self.states["/running/find_users/got_usernames"]])
  153. _running_find_users_retrieve_users_0.setAction(self._running_find_users_retrieve_users_0_exec)
  154. _running_find_users_retrieve_users_0.setTrigger(None)
  155. _running_find_users_retrieve_users_0.setGuard(self._running_find_users_retrieve_users_0_guard)
  156. self.states["/running/find_users/retrieve_users"].addTransition(_running_find_users_retrieve_users_0)
  157. _running_find_users_retrieve_users_1 = Transition(self, self.states["/running/find_users/retrieve_users"], [self.states["/running/find_users/wait"]])
  158. _running_find_users_retrieve_users_1.setTrigger(None)
  159. _running_find_users_retrieve_users_1.setGuard(self._running_find_users_retrieve_users_1_guard)
  160. self.states["/running/find_users/retrieve_users"].addTransition(_running_find_users_retrieve_users_1)
  161. # transition /running/find_users/got_usernames
  162. _running_find_users_got_usernames_0 = Transition(self, self.states["/running/find_users/got_usernames"], [self.states["/running/find_users/process_users"]])
  163. _running_find_users_got_usernames_0.setAction(self._running_find_users_got_usernames_0_exec)
  164. _running_find_users_got_usernames_0.setTrigger(Event("raw_exec_reply", None))
  165. self.states["/running/find_users/got_usernames"].addTransition(_running_find_users_got_usernames_0)
  166. # transition /running/find_users/process_users
  167. _running_find_users_process_users_0 = Transition(self, self.states["/running/find_users/process_users"], [self.states["/running/find_users/wait"]])
  168. _running_find_users_process_users_0.setTrigger(None)
  169. _running_find_users_process_users_0.setGuard(self._running_find_users_process_users_0_guard)
  170. self.states["/running/find_users/process_users"].addTransition(_running_find_users_process_users_0)
  171. _running_find_users_process_users_1 = Transition(self, self.states["/running/find_users/process_users"], [self.states["/running/find_users/creating_user"]])
  172. _running_find_users_process_users_1.setAction(self._running_find_users_process_users_1_exec)
  173. _running_find_users_process_users_1.setTrigger(None)
  174. _running_find_users_process_users_1.setGuard(self._running_find_users_process_users_1_guard)
  175. self.states["/running/find_users/process_users"].addTransition(_running_find_users_process_users_1)
  176. _running_find_users_process_users_2 = Transition(self, self.states["/running/find_users/process_users"], [self.states["/running/find_users/process_users"]])
  177. _running_find_users_process_users_2.setAction(self._running_find_users_process_users_2_exec)
  178. _running_find_users_process_users_2.setTrigger(None)
  179. _running_find_users_process_users_2.setGuard(self._running_find_users_process_users_2_guard)
  180. self.states["/running/find_users/process_users"].addTransition(_running_find_users_process_users_2)
  181. # transition /running/find_users/creating_user
  182. _running_find_users_creating_user_0 = Transition(self, self.states["/running/find_users/creating_user"], [self.states["/running/find_users/retrieve_users"]])
  183. _running_find_users_creating_user_0.setAction(self._running_find_users_creating_user_0_exec)
  184. _running_find_users_creating_user_0.setTrigger(Event("instance_created", None))
  185. self.states["/running/find_users/creating_user"].addTransition(_running_find_users_creating_user_0)
  186. # transition /running/find_users/wait
  187. _running_find_users_wait_0 = Transition(self, self.states["/running/find_users/wait"], [self.states["/running/find_users/get_all_links"]])
  188. _running_find_users_wait_0.setTrigger(Event("_0after"))
  189. self.states["/running/find_users/wait"].addTransition(_running_find_users_wait_0)
  190. _running_find_users_wait_1 = Transition(self, self.states["/running/find_users/wait"], [self.states["/running/find_users/get_all_links"]])
  191. _running_find_users_wait_1.setTrigger(Event("force_user_refresh", None))
  192. self.states["/running/find_users/wait"].addTransition(_running_find_users_wait_1)
  193. def _init_server_enter(self):
  194. self.big_step.outputEventOM(Event("create_instance", None, [self, 'to_mvi', 'Server', '', 8001]))
  195. def _init_executor_enter(self):
  196. self.big_step.outputEventOM(Event("create_instance", None, [self, 'executor', 'Executor']))
  197. def _read_root_enter(self):
  198. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'executor', Event("raw_exec", None, [[['RR', []]], 'parent'])]))
  199. def _running_find_users_get_all_links_enter(self):
  200. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'executor', Event("raw_exec", None, [[['RDK', [self.root]]], 'parent'])]))
  201. def _running_find_users_wait_enter(self):
  202. self.addTimer(0, 1.0)
  203. def _running_find_users_wait_exit(self):
  204. self.removeTimer(0)
  205. def _init_server_0_exec(self, parameters):
  206. instancename = parameters[0]
  207. self.big_step.outputEventOM(Event("start_instance", None, [self, instancename]))
  208. def _init_executor_0_exec(self, parameters):
  209. instancename = parameters[0]
  210. self.big_step.outputEventOM(Event("start_instance", None, [self, instancename]))
  211. def _read_root_0_exec(self, parameters):
  212. data = parameters[0]
  213. self.root = data[0][0]
  214. def _running_wait_for_requests_wait_0_exec(self, parameters):
  215. source = parameters[0]
  216. data = parameters[1]
  217. # No JSON encoding necessary, as it is not complex
  218. try:
  219. args = None
  220. if data["op"] == "set_input":
  221. if "value" in data:
  222. value = [json.loads(data["value"])]
  223. else:
  224. value = json.loads(data["data"])
  225. for v in value[:-1]:
  226. self.input_queue.append((None, data["op"], [v], data["username"]))
  227. self.input_queue.append((source, data["op"], [value[-1]], data["username"]))
  228. else:
  229. self.input_queue.append((source, data["op"], args, data["username"]))
  230. except ValueError:
  231. print("Error when deserializing request: " + str(data))
  232. raise
  233. def _running_push_wait_0_guard(self, parameters):
  234. return self.input_queue and self.input_queue[0][3] in self.user_statecharts
  235. def _running_push_wait_1_exec(self, parameters):
  236. self.user_queue.setdefault(self.input_queue[0][3], []).append(self.input_queue.pop(0))
  237. self.raiseInternalEvent(Event("force_user_refresh", None, []))
  238. def _running_push_wait_1_guard(self, parameters):
  239. return self.input_queue and self.input_queue[0][3] not in self.user_statecharts
  240. def _running_push_process_0_exec(self, parameters):
  241. source, op, args, username = self.input_queue.pop(0)
  242. self.big_step.outputEventOM(Event("narrow_cast", None, [self, self.user_statecharts[username], Event("set_input", None, [source, args])]))
  243. def _running_push_process_0_guard(self, parameters):
  244. return self.input_queue[0][1] == 'set_input'
  245. def _running_push_process_1_exec(self, parameters):
  246. source, op, args, username = self.input_queue.pop(0)
  247. self.big_step.outputEventOM(Event("narrow_cast", None, [self, self.user_statecharts[username], Event("get_output", None, [source, args])]))
  248. def _running_push_process_1_guard(self, parameters):
  249. return self.input_queue[0][1] == 'get_output'
  250. def _running_find_users_get_all_links_0_exec(self, parameters):
  251. data = parameters[0]
  252. self.users = data[0][0]
  253. def _running_find_users_retrieve_users_0_exec(self, parameters):
  254. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'executor', Event("raw_exec", None, [[['RV', [user]] for user in self.users], 'parent'])]))
  255. def _running_find_users_retrieve_users_0_guard(self, parameters):
  256. return self.users
  257. def _running_find_users_retrieve_users_1_guard(self, parameters):
  258. return not self.users
  259. def _running_find_users_got_usernames_0_exec(self, parameters):
  260. data = parameters[0]
  261. data = set([v[0] for v in data])
  262. self.add_users = [v for v in data if v not in self.user_statecharts]
  263. self.delete_users = [v for v in self.user_statecharts if v not in data]
  264. def _running_find_users_process_users_0_guard(self, parameters):
  265. return not self.add_users and not self.delete_users
  266. def _running_find_users_process_users_1_exec(self, parameters):
  267. self.big_step.outputEventOM(Event("create_instance", None, [self, 'users', 'UserStatechart', self.add_users[0]]))
  268. def _running_find_users_process_users_1_guard(self, parameters):
  269. return self.add_users and not self.delete_users
  270. def _running_find_users_process_users_2_exec(self, parameters):
  271. self.big_step.outputEventOM(Event("delete_instance", None, [self, self.user_statecharts.pop(self.delete_users.pop(0))]))
  272. def _running_find_users_process_users_2_guard(self, parameters):
  273. return self.delete_users
  274. def _running_find_users_creating_user_0_exec(self, parameters):
  275. instancename = parameters[0]
  276. self.big_step.outputEventOM(Event("start_instance", None, [self, instancename]))
  277. self.big_step.outputEventOM(Event("narrow_cast", None, [self, instancename, Event("set_returnpath", None, [instancename])]))
  278. self.user_statecharts[self.add_users[0]] = instancename
  279. # Repush all this user's messages in the input queue
  280. self.input_queue.extend(self.user_queue.pop(self.add_users[0], []))
  281. self.add_users.pop(0)
  282. def initializeStatechart(self):
  283. # enter default state
  284. self.default_targets = self.states["/init_server"].getEffectiveTargetStates()
  285. RuntimeClassBase.initializeStatechart(self)
  286. class Server(RuntimeClassBase):
  287. def __init__(self, controller, address, port):
  288. RuntimeClassBase.__init__(self, controller)
  289. self.semantics.big_step_maximality = StatechartSemantics.TakeMany
  290. self.semantics.internal_event_lifeline = StatechartSemantics.Queue
  291. self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
  292. self.semantics.priority = StatechartSemantics.SourceParent
  293. self.semantics.concurrency = StatechartSemantics.Single
  294. # build Statechart structure
  295. self.build_statechart_structure()
  296. # call user defined constructor
  297. Server.user_defined_constructor(self, address, port)
  298. def user_defined_constructor(self, address, port):
  299. self.socket = None
  300. self.address = address
  301. self.port = port
  302. def user_defined_destructor(self):
  303. pass
  304. # builds Statechart structure
  305. def build_statechart_structure(self):
  306. # state <root>
  307. self.states[""] = State(0, self)
  308. # state /main
  309. self.states["/main"] = ParallelState(1, self)
  310. # state /main/forward
  311. self.states["/main/forward"] = State(2, self)
  312. # state /main/forward/forward
  313. self.states["/main/forward/forward"] = State(3, self)
  314. # state /main/server
  315. self.states["/main/server"] = State(4, self)
  316. # state /main/server/init
  317. self.states["/main/server/init"] = State(5, self)
  318. self.states["/main/server/init"].setEnter(self._main_server_init_enter)
  319. # state /main/server/binding
  320. self.states["/main/server/binding"] = State(6, self)
  321. self.states["/main/server/binding"].setEnter(self._main_server_binding_enter)
  322. # state /main/server/listening
  323. self.states["/main/server/listening"] = State(7, self)
  324. self.states["/main/server/listening"].setEnter(self._main_server_listening_enter)
  325. # state /main/server/accepting
  326. self.states["/main/server/accepting"] = State(8, self)
  327. self.states["/main/server/accepting"].setEnter(self._main_server_accepting_enter)
  328. self.states["/main/server/accepting"].setExit(self._main_server_accepting_exit)
  329. # state /main/close_socket
  330. self.states["/main/close_socket"] = State(9, self)
  331. # state /main/close_socket/close
  332. self.states["/main/close_socket/close"] = State(10, self)
  333. # add children
  334. self.states[""].addChild(self.states["/main"])
  335. self.states["/main"].addChild(self.states["/main/forward"])
  336. self.states["/main"].addChild(self.states["/main/server"])
  337. self.states["/main"].addChild(self.states["/main/close_socket"])
  338. self.states["/main/forward"].addChild(self.states["/main/forward/forward"])
  339. self.states["/main/server"].addChild(self.states["/main/server/init"])
  340. self.states["/main/server"].addChild(self.states["/main/server/binding"])
  341. self.states["/main/server"].addChild(self.states["/main/server/listening"])
  342. self.states["/main/server"].addChild(self.states["/main/server/accepting"])
  343. self.states["/main/close_socket"].addChild(self.states["/main/close_socket/close"])
  344. self.states[""].fixTree()
  345. self.states[""].default_state = self.states["/main"]
  346. self.states["/main/forward"].default_state = self.states["/main/forward/forward"]
  347. self.states["/main/server"].default_state = self.states["/main/server/init"]
  348. self.states["/main/close_socket"].default_state = self.states["/main/close_socket/close"]
  349. # transition /main/forward/forward
  350. _main_forward_forward_0 = Transition(self, self.states["/main/forward/forward"], [self.states["/main/forward/forward"]])
  351. _main_forward_forward_0.setAction(self._main_forward_forward_0_exec)
  352. _main_forward_forward_0.setTrigger(Event("HTTP_output", None))
  353. self.states["/main/forward/forward"].addTransition(_main_forward_forward_0)
  354. # transition /main/server/init
  355. _main_server_init_0 = Transition(self, self.states["/main/server/init"], [self.states["/main/server/binding"]])
  356. _main_server_init_0.setAction(self._main_server_init_0_exec)
  357. _main_server_init_0.setTrigger(Event("created_socket", "socket_in"))
  358. self.states["/main/server/init"].addTransition(_main_server_init_0)
  359. # transition /main/server/binding
  360. _main_server_binding_0 = Transition(self, self.states["/main/server/binding"], [self.states["/main/server/listening"]])
  361. _main_server_binding_0.setTrigger(Event("bound_socket", "socket_in"))
  362. _main_server_binding_0.setGuard(self._main_server_binding_0_guard)
  363. self.states["/main/server/binding"].addTransition(_main_server_binding_0)
  364. # transition /main/server/listening
  365. _main_server_listening_0 = Transition(self, self.states["/main/server/listening"], [self.states["/main/server/accepting"]])
  366. _main_server_listening_0.setAction(self._main_server_listening_0_exec)
  367. _main_server_listening_0.setTrigger(Event("listened_socket", "socket_in"))
  368. _main_server_listening_0.setGuard(self._main_server_listening_0_guard)
  369. self.states["/main/server/listening"].addTransition(_main_server_listening_0)
  370. # transition /main/server/accepting
  371. _main_server_accepting_0 = Transition(self, self.states["/main/server/accepting"], [self.states["/main/server/accepting"]])
  372. _main_server_accepting_0.setAction(self._main_server_accepting_0_exec)
  373. _main_server_accepting_0.setTrigger(Event("accepted_socket", "socket_in"))
  374. self.states["/main/server/accepting"].addTransition(_main_server_accepting_0)
  375. _main_server_accepting_1 = Transition(self, self.states["/main/server/accepting"], [self.states["/main/server/accepting"]])
  376. _main_server_accepting_1.setAction(self._main_server_accepting_1_exec)
  377. _main_server_accepting_1.setTrigger(Event("instance_created", None))
  378. self.states["/main/server/accepting"].addTransition(_main_server_accepting_1)
  379. _main_server_accepting_2 = Transition(self, self.states["/main/server/accepting"], [self.states["/main/server/accepting"]])
  380. _main_server_accepting_2.setTrigger(Event("_0after"))
  381. self.states["/main/server/accepting"].addTransition(_main_server_accepting_2)
  382. # transition /main/close_socket/close
  383. _main_close_socket_close_0 = Transition(self, self.states["/main/close_socket/close"], [self.states["/main/close_socket/close"]])
  384. _main_close_socket_close_0.setAction(self._main_close_socket_close_0_exec)
  385. _main_close_socket_close_0.setTrigger(Event("close_socket", None))
  386. self.states["/main/close_socket/close"].addTransition(_main_close_socket_close_0)
  387. def _main_server_init_enter(self):
  388. self.big_step.outputEvent(Event("create_socket", "socket_out", []))
  389. def _main_server_binding_enter(self):
  390. self.big_step.outputEvent(Event("bind_socket", "socket_out", [self.socket, (self.address, self.port)]))
  391. def _main_server_listening_enter(self):
  392. self.big_step.outputEvent(Event("listen_socket", "socket_out", [self.socket]))
  393. def _main_server_accepting_enter(self):
  394. self.addTimer(0, 1.0)
  395. def _main_server_accepting_exit(self):
  396. self.removeTimer(0)
  397. def _main_forward_forward_0_exec(self, parameters):
  398. association_name = parameters[0]
  399. data = parameters[1]
  400. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("from_mvi", None, [association_name, data])]))
  401. def _main_server_init_0_exec(self, parameters):
  402. socket = parameters[0]
  403. self.socket = socket
  404. def _main_server_binding_0_guard(self, parameters):
  405. socket = parameters[0]
  406. return self.socket == socket
  407. def _main_server_listening_0_exec(self, parameters):
  408. socket = parameters[0]
  409. self.big_step.outputEvent(Event("accept_socket", "socket_out", [self.socket]))
  410. def _main_server_listening_0_guard(self, parameters):
  411. socket = parameters[0]
  412. return self.socket == socket
  413. def _main_server_accepting_0_exec(self, parameters):
  414. socket = parameters[0]
  415. connected_socket = parameters[1]
  416. self.big_step.outputEventOM(Event("create_instance", None, [self, 'sockets', 'Socket', connected_socket]))
  417. self.big_step.outputEvent(Event("accept_socket", "socket_out", [self.socket]))
  418. def _main_server_accepting_1_exec(self, parameters):
  419. instancename = parameters[0]
  420. self.big_step.outputEventOM(Event("start_instance", None, [self, instancename]))
  421. self.big_step.outputEventOM(Event("narrow_cast", None, [self, instancename, Event("set_association_name", None, [instancename])]))
  422. def _main_close_socket_close_0_exec(self, parameters):
  423. association_name = parameters[0]
  424. self.big_step.outputEventOM(Event("delete_instance", None, [self, association_name]))
  425. def initializeStatechart(self):
  426. # enter default state
  427. self.default_targets = self.states["/main"].getEffectiveTargetStates()
  428. RuntimeClassBase.initializeStatechart(self)
  429. class Socket(RuntimeClassBase):
  430. def __init__(self, controller, my_socket):
  431. RuntimeClassBase.__init__(self, controller)
  432. self.semantics.big_step_maximality = StatechartSemantics.TakeMany
  433. self.semantics.internal_event_lifeline = StatechartSemantics.Queue
  434. self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
  435. self.semantics.priority = StatechartSemantics.SourceParent
  436. self.semantics.concurrency = StatechartSemantics.Single
  437. # build Statechart structure
  438. self.build_statechart_structure()
  439. # call user defined constructor
  440. Socket.user_defined_constructor(self, my_socket)
  441. def user_defined_constructor(self, my_socket):
  442. self.socket = my_socket
  443. self.received_data = ""
  444. self.send_data = ""
  445. self.closed = False
  446. self.association_name = None
  447. def user_defined_destructor(self):
  448. pass
  449. # builds Statechart structure
  450. def build_statechart_structure(self):
  451. # state <root>
  452. self.states[""] = State(0, self)
  453. # state /init
  454. self.states["/init"] = State(1, self)
  455. # state /connected
  456. self.states["/connected"] = ParallelState(2, self)
  457. # state /connected/listening
  458. self.states["/connected/listening"] = State(3, self)
  459. # state /connected/listening/listen
  460. self.states["/connected/listening/listen"] = State(4, self)
  461. self.states["/connected/listening/listen"].setEnter(self._connected_listening_listen_enter)
  462. # state /connected/listening/closed
  463. self.states["/connected/listening/closed"] = State(5, self)
  464. self.states["/connected/listening/closed"].setEnter(self._connected_listening_closed_enter)
  465. # state /connected/sending
  466. self.states["/connected/sending"] = State(6, self)
  467. # state /connected/sending/waiting_for_data
  468. self.states["/connected/sending/waiting_for_data"] = State(7, self)
  469. # state /connected/sending/transferring
  470. self.states["/connected/sending/transferring"] = State(8, self)
  471. # state /connected/queueing
  472. self.states["/connected/queueing"] = State(9, self)
  473. # state /connected/queueing/queueing
  474. self.states["/connected/queueing/queueing"] = State(10, self)
  475. # state /connected/parsing
  476. self.states["/connected/parsing"] = State(11, self)
  477. # state /connected/parsing/wait_for_header
  478. self.states["/connected/parsing/wait_for_header"] = State(12, self)
  479. # state /connected/parsing/closing
  480. self.states["/connected/parsing/closing"] = State(13, self)
  481. self.states["/connected/parsing/closing"].setEnter(self._connected_parsing_closing_enter)
  482. self.states["/connected/parsing/closing"].setExit(self._connected_parsing_closing_exit)
  483. # state /connected/parsing/wait_for_payload
  484. self.states["/connected/parsing/wait_for_payload"] = State(14, self)
  485. # state /close
  486. self.states["/close"] = State(15, self)
  487. self.states["/close"].setEnter(self._close_enter)
  488. # add children
  489. self.states[""].addChild(self.states["/init"])
  490. self.states[""].addChild(self.states["/connected"])
  491. self.states[""].addChild(self.states["/close"])
  492. self.states["/connected"].addChild(self.states["/connected/listening"])
  493. self.states["/connected"].addChild(self.states["/connected/sending"])
  494. self.states["/connected"].addChild(self.states["/connected/queueing"])
  495. self.states["/connected"].addChild(self.states["/connected/parsing"])
  496. self.states["/connected/listening"].addChild(self.states["/connected/listening/listen"])
  497. self.states["/connected/listening"].addChild(self.states["/connected/listening/closed"])
  498. self.states["/connected/sending"].addChild(self.states["/connected/sending/waiting_for_data"])
  499. self.states["/connected/sending"].addChild(self.states["/connected/sending/transferring"])
  500. self.states["/connected/queueing"].addChild(self.states["/connected/queueing/queueing"])
  501. self.states["/connected/parsing"].addChild(self.states["/connected/parsing/wait_for_header"])
  502. self.states["/connected/parsing"].addChild(self.states["/connected/parsing/closing"])
  503. self.states["/connected/parsing"].addChild(self.states["/connected/parsing/wait_for_payload"])
  504. self.states[""].fixTree()
  505. self.states[""].default_state = self.states["/init"]
  506. self.states["/connected/listening"].default_state = self.states["/connected/listening/listen"]
  507. self.states["/connected/sending"].default_state = self.states["/connected/sending/waiting_for_data"]
  508. self.states["/connected/queueing"].default_state = self.states["/connected/queueing/queueing"]
  509. self.states["/connected/parsing"].default_state = self.states["/connected/parsing/wait_for_header"]
  510. # transition /init
  511. _init_0 = Transition(self, self.states["/init"], [self.states["/connected"]])
  512. _init_0.setAction(self._init_0_exec)
  513. _init_0.setTrigger(Event("set_association_name", None))
  514. self.states["/init"].addTransition(_init_0)
  515. # transition /connected/listening/listen
  516. _connected_listening_listen_0 = Transition(self, self.states["/connected/listening/listen"], [self.states["/connected/listening/listen"]])
  517. _connected_listening_listen_0.setAction(self._connected_listening_listen_0_exec)
  518. _connected_listening_listen_0.setTrigger(Event("received_socket", "socket_in"))
  519. _connected_listening_listen_0.setGuard(self._connected_listening_listen_0_guard)
  520. self.states["/connected/listening/listen"].addTransition(_connected_listening_listen_0)
  521. _connected_listening_listen_1 = Transition(self, self.states["/connected/listening/listen"], [self.states["/connected/listening/closed"]])
  522. _connected_listening_listen_1.setAction(self._connected_listening_listen_1_exec)
  523. _connected_listening_listen_1.setTrigger(Event("received_socket", "socket_in"))
  524. _connected_listening_listen_1.setGuard(self._connected_listening_listen_1_guard)
  525. self.states["/connected/listening/listen"].addTransition(_connected_listening_listen_1)
  526. # transition /connected/sending/waiting_for_data
  527. _connected_sending_waiting_for_data_0 = Transition(self, self.states["/connected/sending/waiting_for_data"], [self.states["/connected/sending/transferring"]])
  528. _connected_sending_waiting_for_data_0.setAction(self._connected_sending_waiting_for_data_0_exec)
  529. _connected_sending_waiting_for_data_0.setTrigger(None)
  530. _connected_sending_waiting_for_data_0.setGuard(self._connected_sending_waiting_for_data_0_guard)
  531. self.states["/connected/sending/waiting_for_data"].addTransition(_connected_sending_waiting_for_data_0)
  532. # transition /connected/sending/transferring
  533. _connected_sending_transferring_0 = Transition(self, self.states["/connected/sending/transferring"], [self.states["/connected/sending/waiting_for_data"]])
  534. _connected_sending_transferring_0.setAction(self._connected_sending_transferring_0_exec)
  535. _connected_sending_transferring_0.setTrigger(Event("sent_socket", "socket_in"))
  536. _connected_sending_transferring_0.setGuard(self._connected_sending_transferring_0_guard)
  537. self.states["/connected/sending/transferring"].addTransition(_connected_sending_transferring_0)
  538. # transition /connected/queueing/queueing
  539. _connected_queueing_queueing_0 = Transition(self, self.states["/connected/queueing/queueing"], [self.states["/connected/queueing/queueing"]])
  540. _connected_queueing_queueing_0.setAction(self._connected_queueing_queueing_0_exec)
  541. _connected_queueing_queueing_0.setTrigger(Event("HTTP_input", None))
  542. self.states["/connected/queueing/queueing"].addTransition(_connected_queueing_queueing_0)
  543. # transition /connected/parsing/wait_for_header
  544. _connected_parsing_wait_for_header_0 = Transition(self, self.states["/connected/parsing/wait_for_header"], [self.states["/connected/parsing/wait_for_payload"]])
  545. _connected_parsing_wait_for_header_0.setAction(self._connected_parsing_wait_for_header_0_exec)
  546. _connected_parsing_wait_for_header_0.setTrigger(None)
  547. _connected_parsing_wait_for_header_0.setGuard(self._connected_parsing_wait_for_header_0_guard)
  548. self.states["/connected/parsing/wait_for_header"].addTransition(_connected_parsing_wait_for_header_0)
  549. _connected_parsing_wait_for_header_1 = Transition(self, self.states["/connected/parsing/wait_for_header"], [self.states["/connected/parsing/closing"]])
  550. _connected_parsing_wait_for_header_1.setTrigger(None)
  551. _connected_parsing_wait_for_header_1.setGuard(self._connected_parsing_wait_for_header_1_guard)
  552. self.states["/connected/parsing/wait_for_header"].addTransition(_connected_parsing_wait_for_header_1)
  553. # transition /connected/parsing/closing
  554. _connected_parsing_closing_0 = Transition(self, self.states["/connected/parsing/closing"], [self.states["/connected/parsing/closing"]])
  555. _connected_parsing_closing_0.setAction(self._connected_parsing_closing_0_exec)
  556. _connected_parsing_closing_0.setTrigger(Event("_0after"))
  557. self.states["/connected/parsing/closing"].addTransition(_connected_parsing_closing_0)
  558. # transition /connected/parsing/wait_for_payload
  559. _connected_parsing_wait_for_payload_0 = Transition(self, self.states["/connected/parsing/wait_for_payload"], [self.states["/connected/parsing/wait_for_header"]])
  560. _connected_parsing_wait_for_payload_0.setAction(self._connected_parsing_wait_for_payload_0_exec)
  561. _connected_parsing_wait_for_payload_0.setTrigger(None)
  562. _connected_parsing_wait_for_payload_0.setGuard(self._connected_parsing_wait_for_payload_0_guard)
  563. self.states["/connected/parsing/wait_for_payload"].addTransition(_connected_parsing_wait_for_payload_0)
  564. # transition /connected
  565. _connected_0 = Transition(self, self.states["/connected"], [self.states["/close"]])
  566. _connected_0.setTrigger(Event("close", None))
  567. self.states["/connected"].addTransition(_connected_0)
  568. def _connected_listening_listen_enter(self):
  569. self.big_step.outputEvent(Event("recv_socket", "socket_out", [self.socket]))
  570. def _connected_listening_closed_enter(self):
  571. self.closed = True
  572. def _connected_parsing_closing_enter(self):
  573. self.addTimer(0, 0.0)
  574. def _connected_parsing_closing_exit(self):
  575. self.removeTimer(0)
  576. def _close_enter(self):
  577. self.big_step.outputEvent(Event("close_socket", "socket_out", [self.socket]))
  578. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("close_socket", None, [self.association_name])]))
  579. def _init_0_exec(self, parameters):
  580. association_name = parameters[0]
  581. self.association_name = association_name
  582. def _connected_listening_listen_0_exec(self, parameters):
  583. socket = parameters[0]
  584. data = parameters[1]
  585. self.received_data += data
  586. self.raiseInternalEvent(Event("received_data", None, []))
  587. def _connected_listening_listen_0_guard(self, parameters):
  588. socket = parameters[0]
  589. data = parameters[1]
  590. return (self.socket == socket) and (len(data) > 0)
  591. def _connected_listening_listen_1_exec(self, parameters):
  592. socket = parameters[0]
  593. data = parameters[1]
  594. self.raiseInternalEvent(Event("received_data", None, []))
  595. def _connected_listening_listen_1_guard(self, parameters):
  596. socket = parameters[0]
  597. data = parameters[1]
  598. return (self.socket == socket) and (len(data) == 0)
  599. def _connected_sending_waiting_for_data_0_exec(self, parameters):
  600. self.big_step.outputEvent(Event("send_socket", "socket_out", [self.socket, self.send_data]))
  601. def _connected_sending_waiting_for_data_0_guard(self, parameters):
  602. return len(self.send_data) > 0
  603. def _connected_sending_transferring_0_exec(self, parameters):
  604. socket = parameters[0]
  605. sent_bytes = parameters[1]
  606. self.send_data = self.send_data[sent_bytes:]
  607. def _connected_sending_transferring_0_guard(self, parameters):
  608. socket = parameters[0]
  609. sent_bytes = parameters[1]
  610. return self.socket == socket
  611. def _connected_queueing_queueing_0_exec(self, parameters):
  612. data = parameters[0]
  613. #post_data = "&".join(["%s=%s" % (urllib.quote(k), urllib.quote(v)) for k, v in data.iteritems()])
  614. #post_data = "&".join(["%s=%s" % (k, v) for k, v in data.iteritems()])
  615. post_data = data
  616. self.send_data += "HTTP/1.0 200 OK\r\n"
  617. self.send_data += "Content-Length: %s\r\n" % len(post_data)
  618. self.send_data += "Content-Type: %s; charset=UTF-8\r\n" % "text/plain"
  619. self.send_data += "\r\n"
  620. self.send_data += str(post_data)
  621. def _connected_parsing_wait_for_header_0_exec(self, parameters):
  622. header, self.received_data = self.received_data.split("\r\n\r\n", 1)
  623. header = header.lower()
  624. if "content-length" in header:
  625. _, after = header.split("content-length:", 1)
  626. after = after.split("\r\n", 1)[0]
  627. after = after.strip()
  628. self.length = int(after)
  629. else:
  630. self.length = float('inf')
  631. def _connected_parsing_wait_for_header_0_guard(self, parameters):
  632. return '\r\n\r\n' in self.received_data and self.received_data.startswith('POST')
  633. def _connected_parsing_wait_for_header_1_guard(self, parameters):
  634. return self.closed and len(self.received_data) == 0
  635. def _connected_parsing_closing_0_exec(self, parameters):
  636. self.raiseInternalEvent(Event("close", None, []))
  637. def _connected_parsing_wait_for_payload_0_exec(self, parameters):
  638. if self.length == float('inf'):
  639. data = self.received_data
  640. self.received_data = ""
  641. else:
  642. data = self.received_data[:self.length]
  643. self.received_data = self.received_data[self.length:]
  644. # We support POST data only, so everything is in the data
  645. try:
  646. params = dict([p.split('=') for p in data.split('&')])
  647. data = {k: urllib.unquote_plus(v) for k, v in params.iteritems()}
  648. except:
  649. data = {}
  650. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("HTTP_output", None, [self.association_name, data])]))
  651. def _connected_parsing_wait_for_payload_0_guard(self, parameters):
  652. return len(self.received_data) >= self.length or self.closed
  653. def initializeStatechart(self):
  654. # enter default state
  655. self.default_targets = self.states["/init"].getEffectiveTargetStates()
  656. RuntimeClassBase.initializeStatechart(self)
  657. class HTTPClient(RuntimeClassBase):
  658. def __init__(self, controller, hostname, port):
  659. RuntimeClassBase.__init__(self, controller)
  660. self.semantics.big_step_maximality = StatechartSemantics.TakeMany
  661. self.semantics.internal_event_lifeline = StatechartSemantics.Queue
  662. self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
  663. self.semantics.priority = StatechartSemantics.SourceParent
  664. self.semantics.concurrency = StatechartSemantics.Single
  665. # build Statechart structure
  666. self.build_statechart_structure()
  667. # call user defined constructor
  668. HTTPClient.user_defined_constructor(self, hostname, port)
  669. def user_defined_constructor(self, hostname, port):
  670. self.socket = None
  671. self.destination = (hostname, port)
  672. self.received_data = ""
  673. self.send_data = ""
  674. self.queue = []
  675. self.destinations = []
  676. def user_defined_destructor(self):
  677. pass
  678. # builds Statechart structure
  679. def build_statechart_structure(self):
  680. # state <root>
  681. self.states[""] = State(0, self)
  682. # state /init
  683. self.states["/init"] = State(1, self)
  684. self.states["/init"].setEnter(self._init_enter)
  685. # state /connecting
  686. self.states["/connecting"] = State(2, self)
  687. self.states["/connecting"].setEnter(self._connecting_enter)
  688. # state /connected
  689. self.states["/connected"] = ParallelState(3, self)
  690. # state /connected/listening
  691. self.states["/connected/listening"] = State(4, self)
  692. # state /connected/listening/listen
  693. self.states["/connected/listening/listen"] = State(5, self)
  694. self.states["/connected/listening/listen"].setEnter(self._connected_listening_listen_enter)
  695. # state /connected/listening/close
  696. self.states["/connected/listening/close"] = State(6, self)
  697. # state /connected/sending
  698. self.states["/connected/sending"] = State(7, self)
  699. # state /connected/sending/waiting_for_data
  700. self.states["/connected/sending/waiting_for_data"] = State(8, self)
  701. # state /connected/sending/transferring
  702. self.states["/connected/sending/transferring"] = State(9, self)
  703. # state /connected/queueing
  704. self.states["/connected/queueing"] = State(10, self)
  705. # state /connected/queueing/queueing
  706. self.states["/connected/queueing/queueing"] = State(11, self)
  707. self.states["/connected/queueing/queueing"].setEnter(self._connected_queueing_queueing_enter)
  708. # state /connected/parsing
  709. self.states["/connected/parsing"] = State(12, self)
  710. # state /connected/parsing/wait_for_header
  711. self.states["/connected/parsing/wait_for_header"] = State(13, self)
  712. # state /connected/parsing/wait_for_payload
  713. self.states["/connected/parsing/wait_for_payload"] = State(14, self)
  714. # add children
  715. self.states[""].addChild(self.states["/init"])
  716. self.states[""].addChild(self.states["/connecting"])
  717. self.states[""].addChild(self.states["/connected"])
  718. self.states["/connected"].addChild(self.states["/connected/listening"])
  719. self.states["/connected"].addChild(self.states["/connected/sending"])
  720. self.states["/connected"].addChild(self.states["/connected/queueing"])
  721. self.states["/connected"].addChild(self.states["/connected/parsing"])
  722. self.states["/connected/listening"].addChild(self.states["/connected/listening/listen"])
  723. self.states["/connected/listening"].addChild(self.states["/connected/listening/close"])
  724. self.states["/connected/sending"].addChild(self.states["/connected/sending/waiting_for_data"])
  725. self.states["/connected/sending"].addChild(self.states["/connected/sending/transferring"])
  726. self.states["/connected/queueing"].addChild(self.states["/connected/queueing/queueing"])
  727. self.states["/connected/parsing"].addChild(self.states["/connected/parsing/wait_for_header"])
  728. self.states["/connected/parsing"].addChild(self.states["/connected/parsing/wait_for_payload"])
  729. self.states[""].fixTree()
  730. self.states[""].default_state = self.states["/init"]
  731. self.states["/connected/listening"].default_state = self.states["/connected/listening/listen"]
  732. self.states["/connected/sending"].default_state = self.states["/connected/sending/waiting_for_data"]
  733. self.states["/connected/queueing"].default_state = self.states["/connected/queueing/queueing"]
  734. self.states["/connected/parsing"].default_state = self.states["/connected/parsing/wait_for_header"]
  735. # transition /init
  736. _init_0 = Transition(self, self.states["/init"], [self.states["/connecting"]])
  737. _init_0.setAction(self._init_0_exec)
  738. _init_0.setTrigger(Event("created_socket", "socket_in"))
  739. self.states["/init"].addTransition(_init_0)
  740. # transition /connecting
  741. _connecting_0 = Transition(self, self.states["/connecting"], [self.states["/connected"]])
  742. _connecting_0.setAction(self._connecting_0_exec)
  743. _connecting_0.setTrigger(Event("connected_socket", "socket_in"))
  744. _connecting_0.setGuard(self._connecting_0_guard)
  745. self.states["/connecting"].addTransition(_connecting_0)
  746. # transition /connected/listening/listen
  747. _connected_listening_listen_0 = Transition(self, self.states["/connected/listening/listen"], [self.states["/connected/listening/listen"]])
  748. _connected_listening_listen_0.setAction(self._connected_listening_listen_0_exec)
  749. _connected_listening_listen_0.setTrigger(Event("received_socket", "socket_in"))
  750. _connected_listening_listen_0.setGuard(self._connected_listening_listen_0_guard)
  751. self.states["/connected/listening/listen"].addTransition(_connected_listening_listen_0)
  752. _connected_listening_listen_1 = Transition(self, self.states["/connected/listening/listen"], [self.states["/connected/listening/close"]])
  753. _connected_listening_listen_1.setTrigger(Event("received_socket", "socket_in"))
  754. _connected_listening_listen_1.setGuard(self._connected_listening_listen_1_guard)
  755. self.states["/connected/listening/listen"].addTransition(_connected_listening_listen_1)
  756. # transition /connected/sending/waiting_for_data
  757. _connected_sending_waiting_for_data_0 = Transition(self, self.states["/connected/sending/waiting_for_data"], [self.states["/connected/sending/transferring"]])
  758. _connected_sending_waiting_for_data_0.setAction(self._connected_sending_waiting_for_data_0_exec)
  759. _connected_sending_waiting_for_data_0.setTrigger(None)
  760. _connected_sending_waiting_for_data_0.setGuard(self._connected_sending_waiting_for_data_0_guard)
  761. self.states["/connected/sending/waiting_for_data"].addTransition(_connected_sending_waiting_for_data_0)
  762. # transition /connected/sending/transferring
  763. _connected_sending_transferring_0 = Transition(self, self.states["/connected/sending/transferring"], [self.states["/connected/sending/waiting_for_data"]])
  764. _connected_sending_transferring_0.setAction(self._connected_sending_transferring_0_exec)
  765. _connected_sending_transferring_0.setTrigger(Event("sent_socket", "socket_in"))
  766. _connected_sending_transferring_0.setGuard(self._connected_sending_transferring_0_guard)
  767. self.states["/connected/sending/transferring"].addTransition(_connected_sending_transferring_0)
  768. # transition /connected/queueing/queueing
  769. _connected_queueing_queueing_0 = Transition(self, self.states["/connected/queueing/queueing"], [self.states["/connected/queueing/queueing"]])
  770. _connected_queueing_queueing_0.setAction(self._connected_queueing_queueing_0_exec)
  771. _connected_queueing_queueing_0.setTrigger(Event("HTTP_input", None))
  772. self.states["/connected/queueing/queueing"].addTransition(_connected_queueing_queueing_0)
  773. # transition /connected/parsing/wait_for_header
  774. _connected_parsing_wait_for_header_0 = Transition(self, self.states["/connected/parsing/wait_for_header"], [self.states["/connected/parsing/wait_for_payload"]])
  775. _connected_parsing_wait_for_header_0.setAction(self._connected_parsing_wait_for_header_0_exec)
  776. _connected_parsing_wait_for_header_0.setTrigger(None)
  777. _connected_parsing_wait_for_header_0.setGuard(self._connected_parsing_wait_for_header_0_guard)
  778. self.states["/connected/parsing/wait_for_header"].addTransition(_connected_parsing_wait_for_header_0)
  779. # transition /connected/parsing/wait_for_payload
  780. _connected_parsing_wait_for_payload_0 = Transition(self, self.states["/connected/parsing/wait_for_payload"], [self.states["/connected/parsing/wait_for_header"]])
  781. _connected_parsing_wait_for_payload_0.setAction(self._connected_parsing_wait_for_payload_0_exec)
  782. _connected_parsing_wait_for_payload_0.setTrigger(None)
  783. _connected_parsing_wait_for_payload_0.setGuard(self._connected_parsing_wait_for_payload_0_guard)
  784. self.states["/connected/parsing/wait_for_payload"].addTransition(_connected_parsing_wait_for_payload_0)
  785. def _init_enter(self):
  786. self.big_step.outputEvent(Event("create_socket", "", []))
  787. def _connecting_enter(self):
  788. self.big_step.outputEvent(Event("connect_socket", "", [self.socket, self.destination]))
  789. def _connected_listening_listen_enter(self):
  790. self.big_step.outputEvent(Event("recv_socket", "socket_out", [self.socket]))
  791. def _connected_queueing_queueing_enter(self):
  792. pass
  793. def _init_0_exec(self, parameters):
  794. socket = parameters[0]
  795. self.socket = socket
  796. def _connecting_0_exec(self, parameters):
  797. socket = parameters[0]
  798. self.big_step.outputEventOM(Event("broad_cast", None, [Event("http_client_ready", None, [])]))
  799. def _connecting_0_guard(self, parameters):
  800. socket = parameters[0]
  801. return self.socket == socket
  802. def _connected_listening_listen_0_exec(self, parameters):
  803. socket = parameters[0]
  804. data = parameters[1]
  805. self.received_data += data
  806. def _connected_listening_listen_0_guard(self, parameters):
  807. socket = parameters[0]
  808. data = parameters[1]
  809. return (self.socket == socket) and (len(data) > 0)
  810. def _connected_listening_listen_1_guard(self, parameters):
  811. socket = parameters[0]
  812. data = parameters[1]
  813. return (self.socket == socket) and (len(data) == 0)
  814. def _connected_sending_waiting_for_data_0_exec(self, parameters):
  815. self.big_step.outputEvent(Event("send_socket", "socket_out", [self.socket, self.send_data]))
  816. def _connected_sending_waiting_for_data_0_guard(self, parameters):
  817. return len(self.send_data) > 0
  818. def _connected_sending_transferring_0_exec(self, parameters):
  819. socket = parameters[0]
  820. sent_bytes = parameters[1]
  821. self.send_data = self.send_data[sent_bytes:]
  822. def _connected_sending_transferring_0_guard(self, parameters):
  823. socket = parameters[0]
  824. sent_bytes = parameters[1]
  825. return self.socket == socket
  826. def _connected_queueing_queueing_0_exec(self, parameters):
  827. data = parameters[0]
  828. destination = parameters[1]
  829. self.send_data += "POST / HTTP/1.0\r\n"
  830. self.send_data += "Content-Length: %i\r\n" % len(str(data))
  831. self.send_data += "\r\n"
  832. self.send_data += data
  833. self.destinations.append(destination)
  834. def _connected_parsing_wait_for_header_0_exec(self, parameters):
  835. header, self.received_data = self.received_data.split("\r\n\r\n", 1)
  836. header = header.lower()
  837. if "content-length" in header:
  838. _, after = header.split("content-length:", 1)
  839. after, _ = after.split("\r\n", 1)
  840. after = after.strip()
  841. self.length = int(after)
  842. else:
  843. self.length = float('inf')
  844. def _connected_parsing_wait_for_header_0_guard(self, parameters):
  845. return '\r\n\r\n' in self.received_data
  846. def _connected_parsing_wait_for_payload_0_exec(self, parameters):
  847. data = self.received_data[:self.length]
  848. self.received_data = self.received_data[self.length:]
  849. params = dict([p.split('=') for p in data.split('&')])
  850. data = {k: urllib.unquote_plus(v) for k, v in params.iteritems()}
  851. self.big_step.outputEventOM(Event("narrow_cast", None, [self, self.destinations.pop(0), Event("HTTP_output", None, [data])]))
  852. def _connected_parsing_wait_for_payload_0_guard(self, parameters):
  853. return len(self.received_data) >= self.length
  854. def initializeStatechart(self):
  855. # enter default state
  856. self.default_targets = self.states["/init"].getEffectiveTargetStates()
  857. RuntimeClassBase.initializeStatechart(self)
  858. class UserStatechart(RuntimeClassBase):
  859. def __init__(self, controller, username):
  860. RuntimeClassBase.__init__(self, controller)
  861. self.semantics.big_step_maximality = StatechartSemantics.TakeMany
  862. self.semantics.internal_event_lifeline = StatechartSemantics.Queue
  863. self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
  864. self.semantics.priority = StatechartSemantics.SourceParent
  865. self.semantics.concurrency = StatechartSemantics.Single
  866. # build Statechart structure
  867. self.build_statechart_structure()
  868. # call user defined constructor
  869. UserStatechart.user_defined_constructor(self, username)
  870. def user_defined_constructor(self, username):
  871. self.username = username
  872. self.output_queue = []
  873. self.source_execution = None
  874. self.request_id = 0
  875. self.outstanding_execution = None
  876. self.outstanding_input = {}
  877. self.outstanding_output = None
  878. def user_defined_destructor(self):
  879. pass
  880. # builds Statechart structure
  881. def build_statechart_structure(self):
  882. # state <root>
  883. self.states[""] = State(0, self)
  884. # state /init
  885. self.states["/init"] = State(1, self)
  886. # state /running
  887. self.states["/running"] = ParallelState(2, self)
  888. # state /running/execution
  889. self.states["/running/execution"] = State(3, self)
  890. # state /running/execution/init
  891. self.states["/running/execution/init"] = State(4, self)
  892. self.states["/running/execution/init"].setEnter(self._running_execution_init_enter)
  893. # state /running/execution/timeout
  894. self.states["/running/execution/timeout"] = State(5, self)
  895. self.states["/running/execution/timeout"].setEnter(self._running_execution_timeout_enter)
  896. self.states["/running/execution/timeout"].setExit(self._running_execution_timeout_exit)
  897. # state /running/set_input
  898. self.states["/running/set_input"] = State(6, self)
  899. # state /running/set_input/fetch
  900. self.states["/running/set_input/fetch"] = State(7, self)
  901. # state /running/get_output_queue
  902. self.states["/running/get_output_queue"] = State(8, self)
  903. # state /running/get_output_queue/waiting
  904. self.states["/running/get_output_queue/waiting"] = State(9, self)
  905. # state /running/get_output
  906. self.states["/running/get_output"] = State(10, self)
  907. # state /running/get_output/try_execute
  908. self.states["/running/get_output/try_execute"] = State(11, self)
  909. # state /running/get_output/waiting
  910. self.states["/running/get_output/waiting"] = State(12, self)
  911. self.states["/running/get_output/waiting"].setEnter(self._running_get_output_waiting_enter)
  912. self.states["/running/get_output/waiting"].setExit(self._running_get_output_waiting_exit)
  913. # add children
  914. self.states[""].addChild(self.states["/init"])
  915. self.states[""].addChild(self.states["/running"])
  916. self.states["/running"].addChild(self.states["/running/execution"])
  917. self.states["/running"].addChild(self.states["/running/set_input"])
  918. self.states["/running"].addChild(self.states["/running/get_output_queue"])
  919. self.states["/running"].addChild(self.states["/running/get_output"])
  920. self.states["/running/execution"].addChild(self.states["/running/execution/init"])
  921. self.states["/running/execution"].addChild(self.states["/running/execution/timeout"])
  922. self.states["/running/set_input"].addChild(self.states["/running/set_input/fetch"])
  923. self.states["/running/get_output_queue"].addChild(self.states["/running/get_output_queue/waiting"])
  924. self.states["/running/get_output"].addChild(self.states["/running/get_output/try_execute"])
  925. self.states["/running/get_output"].addChild(self.states["/running/get_output/waiting"])
  926. self.states[""].fixTree()
  927. self.states[""].default_state = self.states["/init"]
  928. self.states["/running/execution"].default_state = self.states["/running/execution/init"]
  929. self.states["/running/set_input"].default_state = self.states["/running/set_input/fetch"]
  930. self.states["/running/get_output_queue"].default_state = self.states["/running/get_output_queue/waiting"]
  931. self.states["/running/get_output"].default_state = self.states["/running/get_output/try_execute"]
  932. # transition /init
  933. _init_0 = Transition(self, self.states["/init"], [self.states["/running"]])
  934. _init_0.setAction(self._init_0_exec)
  935. _init_0.setTrigger(Event("set_returnpath", None))
  936. self.states["/init"].addTransition(_init_0)
  937. # transition /running/execution/init
  938. _running_execution_init_0 = Transition(self, self.states["/running/execution/init"], [self.states["/running/execution/init"]])
  939. _running_execution_init_0.setTrigger(Event("executed", None))
  940. _running_execution_init_0.setGuard(self._running_execution_init_0_guard)
  941. self.states["/running/execution/init"].addTransition(_running_execution_init_0)
  942. _running_execution_init_1 = Transition(self, self.states["/running/execution/init"], [self.states["/running/execution/timeout"]])
  943. _running_execution_init_1.setTrigger(Event("executed", None))
  944. _running_execution_init_1.setGuard(self._running_execution_init_1_guard)
  945. self.states["/running/execution/init"].addTransition(_running_execution_init_1)
  946. # transition /running/execution/timeout
  947. _running_execution_timeout_0 = Transition(self, self.states["/running/execution/timeout"], [self.states["/running/execution/init"]])
  948. _running_execution_timeout_0.setTrigger(Event("_0after"))
  949. self.states["/running/execution/timeout"].addTransition(_running_execution_timeout_0)
  950. _running_execution_timeout_1 = Transition(self, self.states["/running/execution/timeout"], [self.states["/running/execution/init"]])
  951. _running_execution_timeout_1.setTrigger(Event("set_input_done", None))
  952. self.states["/running/execution/timeout"].addTransition(_running_execution_timeout_1)
  953. # transition /running/set_input/fetch
  954. _running_set_input_fetch_0 = Transition(self, self.states["/running/set_input/fetch"], [self.states["/running/set_input/fetch"]])
  955. _running_set_input_fetch_0.setAction(self._running_set_input_fetch_0_exec)
  956. _running_set_input_fetch_0.setTrigger(Event("set_input", None))
  957. self.states["/running/set_input/fetch"].addTransition(_running_set_input_fetch_0)
  958. _running_set_input_fetch_1 = Transition(self, self.states["/running/set_input/fetch"], [self.states["/running/set_input/fetch"]])
  959. _running_set_input_fetch_1.setAction(self._running_set_input_fetch_1_exec)
  960. _running_set_input_fetch_1.setTrigger(Event("executed", None))
  961. _running_set_input_fetch_1.setGuard(self._running_set_input_fetch_1_guard)
  962. self.states["/running/set_input/fetch"].addTransition(_running_set_input_fetch_1)
  963. # transition /running/get_output_queue/waiting
  964. _running_get_output_queue_waiting_0 = Transition(self, self.states["/running/get_output_queue/waiting"], [self.states["/running/get_output_queue/waiting"]])
  965. _running_get_output_queue_waiting_0.setAction(self._running_get_output_queue_waiting_0_exec)
  966. _running_get_output_queue_waiting_0.setTrigger(Event("get_output", None))
  967. self.states["/running/get_output_queue/waiting"].addTransition(_running_get_output_queue_waiting_0)
  968. # transition /running/get_output/try_execute
  969. _running_get_output_try_execute_0 = Transition(self, self.states["/running/get_output/try_execute"], [self.states["/running/get_output/try_execute"]])
  970. _running_get_output_try_execute_0.setAction(self._running_get_output_try_execute_0_exec)
  971. _running_get_output_try_execute_0.setTrigger(None)
  972. _running_get_output_try_execute_0.setGuard(self._running_get_output_try_execute_0_guard)
  973. self.states["/running/get_output/try_execute"].addTransition(_running_get_output_try_execute_0)
  974. _running_get_output_try_execute_1 = Transition(self, self.states["/running/get_output/try_execute"], [self.states["/running/get_output/try_execute"]])
  975. _running_get_output_try_execute_1.setAction(self._running_get_output_try_execute_1_exec)
  976. _running_get_output_try_execute_1.setTrigger(Event("executed", None))
  977. _running_get_output_try_execute_1.setGuard(self._running_get_output_try_execute_1_guard)
  978. self.states["/running/get_output/try_execute"].addTransition(_running_get_output_try_execute_1)
  979. _running_get_output_try_execute_2 = Transition(self, self.states["/running/get_output/try_execute"], [self.states["/running/get_output/waiting"]])
  980. _running_get_output_try_execute_2.setAction(self._running_get_output_try_execute_2_exec)
  981. _running_get_output_try_execute_2.setTrigger(Event("executed", None))
  982. _running_get_output_try_execute_2.setGuard(self._running_get_output_try_execute_2_guard)
  983. self.states["/running/get_output/try_execute"].addTransition(_running_get_output_try_execute_2)
  984. # transition /running/get_output/waiting
  985. _running_get_output_waiting_0 = Transition(self, self.states["/running/get_output/waiting"], [self.states["/running/get_output/try_execute"]])
  986. _running_get_output_waiting_0.setTrigger(Event("_1after"))
  987. self.states["/running/get_output/waiting"].addTransition(_running_get_output_waiting_0)
  988. def _running_execution_init_enter(self):
  989. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/executor', Event("execute", None, [self.returnpath, self.username, 'execute_rule', [], self.request_id])]))
  990. self.outstanding_execution = self.request_id
  991. self.request_id += 1
  992. def _running_execution_timeout_enter(self):
  993. self.addTimer(0, 1.0)
  994. def _running_execution_timeout_exit(self):
  995. self.removeTimer(0)
  996. def _running_get_output_waiting_enter(self):
  997. self.addTimer(1, 1.0)
  998. def _running_get_output_waiting_exit(self):
  999. self.removeTimer(1)
  1000. def _init_0_exec(self, parameters):
  1001. returnpath = parameters[0]
  1002. self.returnpath = returnpath
  1003. def _running_execution_init_0_guard(self, parameters):
  1004. returnvalue = parameters[0]
  1005. success = parameters[1]
  1006. request_id = parameters[2]
  1007. return success and self.outstanding_execution == request_id
  1008. def _running_execution_init_1_guard(self, parameters):
  1009. returnvalue = parameters[0]
  1010. success = parameters[1]
  1011. request_id = parameters[2]
  1012. return not success and self.outstanding_execution == request_id
  1013. def _running_set_input_fetch_0_exec(self, parameters):
  1014. source = parameters[0]
  1015. args = parameters[1]
  1016. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/executor', Event("execute", None, [self.returnpath, self.username, 'set_input', args, self.request_id])]))
  1017. if source is not None:
  1018. self.outstanding_input[self.request_id] = source
  1019. self.request_id += 1
  1020. def _running_set_input_fetch_1_exec(self, parameters):
  1021. returnvalue = parameters[0]
  1022. success = parameters[1]
  1023. request_id = parameters[2]
  1024. source = self.outstanding_input.pop(request_id)
  1025. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/to_mvi/' + source, Event("HTTP_input", None, [json.dumps(returnvalue)])]))
  1026. self.raiseInternalEvent(Event("set_input_done", None, []))
  1027. def _running_set_input_fetch_1_guard(self, parameters):
  1028. returnvalue = parameters[0]
  1029. success = parameters[1]
  1030. request_id = parameters[2]
  1031. return request_id in self.outstanding_input
  1032. def _running_get_output_queue_waiting_0_exec(self, parameters):
  1033. source = parameters[0]
  1034. args = parameters[1]
  1035. self.output_queue.append(source)
  1036. def _running_get_output_try_execute_0_exec(self, parameters):
  1037. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/executor', Event("execute", None, [self.returnpath, self.username, 'get_output', [], self.request_id])]))
  1038. self.outstanding_output = self.request_id
  1039. self.request_id += 1
  1040. def _running_get_output_try_execute_0_guard(self, parameters):
  1041. return self.outstanding_output is None and self.output_queue
  1042. def _running_get_output_try_execute_1_exec(self, parameters):
  1043. returnvalue = parameters[0]
  1044. success = parameters[1]
  1045. request_id = parameters[2]
  1046. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/to_mvi/' + self.output_queue.pop(0), Event("HTTP_input", None, [json.dumps(returnvalue)])]))
  1047. self.outstanding_output = None
  1048. def _running_get_output_try_execute_1_guard(self, parameters):
  1049. returnvalue = parameters[0]
  1050. success = parameters[1]
  1051. request_id = parameters[2]
  1052. return success and request_id == self.outstanding_output
  1053. def _running_get_output_try_execute_2_exec(self, parameters):
  1054. returnvalue = parameters[0]
  1055. success = parameters[1]
  1056. request_id = parameters[2]
  1057. self.outstanding_output = None
  1058. def _running_get_output_try_execute_2_guard(self, parameters):
  1059. returnvalue = parameters[0]
  1060. success = parameters[1]
  1061. request_id = parameters[2]
  1062. return not success and request_id == self.outstanding_output
  1063. def initializeStatechart(self):
  1064. # enter default state
  1065. self.default_targets = self.states["/init"].getEffectiveTargetStates()
  1066. RuntimeClassBase.initializeStatechart(self)
  1067. class Executor(RuntimeClassBase):
  1068. def __init__(self, controller):
  1069. RuntimeClassBase.__init__(self, controller)
  1070. self.semantics.big_step_maximality = StatechartSemantics.TakeMany
  1071. self.semantics.internal_event_lifeline = StatechartSemantics.Queue
  1072. self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
  1073. self.semantics.priority = StatechartSemantics.SourceParent
  1074. self.semantics.concurrency = StatechartSemantics.Single
  1075. # build Statechart structure
  1076. self.build_statechart_structure()
  1077. # call user defined constructor
  1078. Executor.user_defined_constructor(self)
  1079. def user_defined_constructor(self):
  1080. self.mvs = ModelverseState("../../bootstrap/bootstrap.m.gz")
  1081. self.request_queue = [("", "", "load_primitives", [], None)]
  1082. self.mvs.GC = True
  1083. self.mvk = ModelverseKernel(self.mvs.read_root()[0])
  1084. self.first = True
  1085. self.mvs_response = None
  1086. self.mvs_operations = {
  1087. "CN": self.mvs.create_node,
  1088. "CE": self.mvs.create_edge,
  1089. "CNV": self.mvs.create_nodevalue,
  1090. "CD": self.mvs.create_dict,
  1091. "RV": self.mvs.read_value,
  1092. "RO": self.mvs.read_outgoing,
  1093. "RI": self.mvs.read_incoming,
  1094. "RE": self.mvs.read_edge,
  1095. "RD": self.mvs.read_dict,
  1096. "RDN": self.mvs.read_dict_node,
  1097. "RDNE": self.mvs.read_dict_node_edge,
  1098. "RDE": self.mvs.read_dict_edge,
  1099. "RRD": self.mvs.read_reverse_dict,
  1100. "RR": self.mvs.read_root,
  1101. "RDK": self.mvs.read_dict_keys,
  1102. "DE": self.mvs.delete_edge,
  1103. "DN": self.mvs.delete_node,
  1104. }
  1105. def user_defined_destructor(self):
  1106. pass
  1107. # builds Statechart structure
  1108. def build_statechart_structure(self):
  1109. # state <root>
  1110. self.states[""] = State(0, self)
  1111. # state /init
  1112. self.states["/init"] = ParallelState(1, self)
  1113. # state /init/raw_exec
  1114. self.states["/init/raw_exec"] = State(2, self)
  1115. # state /init/raw_exec/raw_exec
  1116. self.states["/init/raw_exec/raw_exec"] = State(3, self)
  1117. # state /init/queue
  1118. self.states["/init/queue"] = State(4, self)
  1119. # state /init/queue/queue
  1120. self.states["/init/queue/queue"] = State(5, self)
  1121. # state /init/execute
  1122. self.states["/init/execute"] = State(6, self)
  1123. # state /init/execute/idle
  1124. self.states["/init/execute/idle"] = State(7, self)
  1125. # state /init/execute/execution
  1126. self.states["/init/execute/execution"] = State(8, self)
  1127. self.states["/init/execute/execution"].setEnter(self._init_execute_execution_enter)
  1128. # add children
  1129. self.states[""].addChild(self.states["/init"])
  1130. self.states["/init"].addChild(self.states["/init/raw_exec"])
  1131. self.states["/init"].addChild(self.states["/init/queue"])
  1132. self.states["/init"].addChild(self.states["/init/execute"])
  1133. self.states["/init/raw_exec"].addChild(self.states["/init/raw_exec/raw_exec"])
  1134. self.states["/init/queue"].addChild(self.states["/init/queue/queue"])
  1135. self.states["/init/execute"].addChild(self.states["/init/execute/idle"])
  1136. self.states["/init/execute"].addChild(self.states["/init/execute/execution"])
  1137. self.states[""].fixTree()
  1138. self.states[""].default_state = self.states["/init"]
  1139. self.states["/init/raw_exec"].default_state = self.states["/init/raw_exec/raw_exec"]
  1140. self.states["/init/queue"].default_state = self.states["/init/queue/queue"]
  1141. self.states["/init/execute"].default_state = self.states["/init/execute/idle"]
  1142. # transition /init/raw_exec/raw_exec
  1143. _init_raw_exec_raw_exec_0 = Transition(self, self.states["/init/raw_exec/raw_exec"], [self.states["/init/raw_exec/raw_exec"]])
  1144. _init_raw_exec_raw_exec_0.setAction(self._init_raw_exec_raw_exec_0_exec)
  1145. _init_raw_exec_raw_exec_0.setTrigger(Event("raw_exec", None))
  1146. self.states["/init/raw_exec/raw_exec"].addTransition(_init_raw_exec_raw_exec_0)
  1147. # transition /init/queue/queue
  1148. _init_queue_queue_0 = Transition(self, self.states["/init/queue/queue"], [self.states["/init/queue/queue"]])
  1149. _init_queue_queue_0.setAction(self._init_queue_queue_0_exec)
  1150. _init_queue_queue_0.setTrigger(Event("execute", None))
  1151. self.states["/init/queue/queue"].addTransition(_init_queue_queue_0)
  1152. # transition /init/execute/idle
  1153. _init_execute_idle_0 = Transition(self, self.states["/init/execute/idle"], [self.states["/init/execute/execution"]])
  1154. _init_execute_idle_0.setTrigger(None)
  1155. _init_execute_idle_0.setGuard(self._init_execute_idle_0_guard)
  1156. self.states["/init/execute/idle"].addTransition(_init_execute_idle_0)
  1157. # transition /init/execute/execution
  1158. _init_execute_execution_0 = Transition(self, self.states["/init/execute/execution"], [self.states["/init/execute/idle"]])
  1159. _init_execute_execution_0.setAction(self._init_execute_execution_0_exec)
  1160. _init_execute_execution_0.setTrigger(None)
  1161. _init_execute_execution_0.setGuard(self._init_execute_execution_0_guard)
  1162. self.states["/init/execute/execution"].addTransition(_init_execute_execution_0)
  1163. _init_execute_execution_1 = Transition(self, self.states["/init/execute/execution"], [self.states["/init/execute/idle"]])
  1164. _init_execute_execution_1.setTrigger(None)
  1165. _init_execute_execution_1.setGuard(self._init_execute_execution_1_guard)
  1166. self.states["/init/execute/execution"].addTransition(_init_execute_execution_1)
  1167. def _init_execute_execution_enter(self):
  1168. self.mvk.returnvalue = None
  1169. self.mvk.success = True
  1170. self.first = True
  1171. self.returnpath, username, operation, params, self.request_id = self.request_queue.pop(0)
  1172. reply = None
  1173. commands = []
  1174. while 1:
  1175. commands = self.mvk.execute_yields(username, operation, params, reply)
  1176. if commands is None:
  1177. break
  1178. reply = [self.mvs_operations[command[0]](*(command[1]))[0] for command in commands]
  1179. def _init_raw_exec_raw_exec_0_exec(self, parameters):
  1180. operations = parameters[0]
  1181. source = parameters[1]
  1182. reply = [self.mvs_operations[command[0]](*command[1]) for command in operations]
  1183. self.big_step.outputEventOM(Event("narrow_cast", None, [self, source, Event("raw_exec_reply", None, [reply])]))
  1184. def _init_queue_queue_0_exec(self, parameters):
  1185. returnpath = parameters[0]
  1186. username = parameters[1]
  1187. operation = parameters[2]
  1188. params = parameters[3]
  1189. request_id = parameters[4]
  1190. self.request_queue.append((("/" + returnpath) if returnpath is not None else None, username, operation, params, request_id))
  1191. def _init_execute_idle_0_guard(self, parameters):
  1192. return self.request_queue
  1193. def _init_execute_execution_0_exec(self, parameters):
  1194. self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent' + self.returnpath, Event("executed", None, [self.mvk.returnvalue, self.mvk.success, self.request_id])]))
  1195. def _init_execute_execution_0_guard(self, parameters):
  1196. return self.returnpath is not None
  1197. def _init_execute_execution_1_guard(self, parameters):
  1198. return self.returnpath is None
  1199. def initializeStatechart(self):
  1200. # enter default state
  1201. self.default_targets = self.states["/init"].getEffectiveTargetStates()
  1202. RuntimeClassBase.initializeStatechart(self)
  1203. class ObjectManager(ObjectManagerBase):
  1204. def __init__(self, controller):
  1205. ObjectManagerBase.__init__(self, controller)
  1206. def instantiate(self, class_name, construct_params):
  1207. if class_name == "MvKController":
  1208. instance = MvKController(self.controller, construct_params[0])
  1209. instance.associations = {}
  1210. instance.associations["to_mvs"] = Association("HTTPClient", 1, 1)
  1211. instance.associations["to_mvi"] = Association("Server", 1, 1)
  1212. instance.associations["users"] = Association("UserStatechart", 0, -1)
  1213. instance.associations["executor"] = Association("Executor", 1, 1)
  1214. elif class_name == "Server":
  1215. instance = Server(self.controller, construct_params[0], construct_params[1])
  1216. instance.associations = {}
  1217. instance.associations["sockets"] = Association("Socket", 0, -1)
  1218. instance.associations["parent"] = Association("MvKController", 1, 1)
  1219. elif class_name == "Socket":
  1220. instance = Socket(self.controller, construct_params[0])
  1221. instance.associations = {}
  1222. instance.associations["parent"] = Association("Server", 1, 1)
  1223. elif class_name == "HTTPClient":
  1224. instance = HTTPClient(self.controller, construct_params[0], construct_params[1])
  1225. instance.associations = {}
  1226. instance.associations["parent"] = Association("MvKController", 1, 1)
  1227. elif class_name == "UserStatechart":
  1228. instance = UserStatechart(self.controller, construct_params[0])
  1229. instance.associations = {}
  1230. instance.associations["parent"] = Association("MvKController", 1, 1)
  1231. elif class_name == "Executor":
  1232. instance = Executor(self.controller)
  1233. instance.associations = {}
  1234. instance.associations["parent"] = Association("MvKController", 1, 1)
  1235. else:
  1236. raise Exception("Cannot instantiate class " + class_name)
  1237. return instance
  1238. class Controller(ThreadsControllerBase):
  1239. def __init__(self, params, keep_running = None, behind_schedule_callback = None):
  1240. if keep_running == None: keep_running = True
  1241. if behind_schedule_callback == None: behind_schedule_callback = None
  1242. ThreadsControllerBase.__init__(self, ObjectManager(self), keep_running, behind_schedule_callback)
  1243. self.addInputPort("socket_in")
  1244. self.addOutputPort("socket_out")
  1245. self.object_manager.createInstance("MvKController", [params])