123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554 |
- """
- Generated by Statechart compiler by Glenn De Jonghe, Joeri Exelmans, Simon Van Mierlo, and Yentl Van Tendeloo (for the inspiration)
- Date: Thu Feb 9 14:45:08 2017
- Model author: Yentl Van Tendeloo
- Model name: MvK Server
- Model description:
- Modelverse Kernel server. Server for the MvI, client of the MvS.
- """
- from sccd.runtime.statecharts_core import *
- import time
- import os
- import urllib
- import sys
- import json
- from modelverse_kernel.main import ModelverseKernel
- sys.path.append("../../state")
- from modelverse_state.main import ModelverseState
- # package "MvK Server"
- class MvKController(RuntimeClassBase):
- def __init__(self, controller, params):
- RuntimeClassBase.__init__(self, controller)
-
- 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()
-
- # call user defined constructor
- MvKController.user_defined_constructor(self, params)
-
- def user_defined_constructor(self, params):
- self.users = []
- self.user_statecharts = {"__hierarchy": None}
- self.input_queue = []
- self.user_queue = {}
- self.source = None
- self.root = None
-
- self.params = params
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, self)
-
- # state /init_server
- self.states["/init_server"] = State(1, self)
- self.states["/init_server"].setEnter(self._init_server_enter)
-
- # state /init_executor
- self.states["/init_executor"] = State(2, self)
- self.states["/init_executor"].setEnter(self._init_executor_enter)
-
- # state /read_root
- self.states["/read_root"] = State(3, self)
- self.states["/read_root"].setEnter(self._read_root_enter)
-
- # state /running
- self.states["/running"] = ParallelState(4, self)
-
- # state /running/wait_for_requests
- self.states["/running/wait_for_requests"] = State(5, self)
-
- # state /running/wait_for_requests/wait
- self.states["/running/wait_for_requests/wait"] = State(6, self)
-
- # state /running/push
- self.states["/running/push"] = State(7, self)
-
- # state /running/push/wait
- self.states["/running/push/wait"] = State(8, self)
-
- # state /running/push/process
- self.states["/running/push/process"] = State(9, self)
-
- # state /running/find_users
- self.states["/running/find_users"] = State(10, self)
-
- # state /running/find_users/get_all_links
- self.states["/running/find_users/get_all_links"] = State(11, self)
- self.states["/running/find_users/get_all_links"].setEnter(self._running_find_users_get_all_links_enter)
-
- # state /running/find_users/retrieve_users
- self.states["/running/find_users/retrieve_users"] = State(12, self)
-
- # state /running/find_users/got_usernames
- self.states["/running/find_users/got_usernames"] = State(13, self)
-
- # state /running/find_users/process_users
- self.states["/running/find_users/process_users"] = State(14, self)
-
- # state /running/find_users/creating_user
- self.states["/running/find_users/creating_user"] = State(15, self)
-
- # state /running/find_users/wait
- self.states["/running/find_users/wait"] = State(16, self)
- self.states["/running/find_users/wait"].setEnter(self._running_find_users_wait_enter)
- self.states["/running/find_users/wait"].setExit(self._running_find_users_wait_exit)
-
- # add children
- self.states[""].addChild(self.states["/init_server"])
- self.states[""].addChild(self.states["/init_executor"])
- self.states[""].addChild(self.states["/read_root"])
- self.states[""].addChild(self.states["/running"])
- self.states["/running"].addChild(self.states["/running/wait_for_requests"])
- self.states["/running"].addChild(self.states["/running/push"])
- self.states["/running"].addChild(self.states["/running/find_users"])
- self.states["/running/wait_for_requests"].addChild(self.states["/running/wait_for_requests/wait"])
- self.states["/running/push"].addChild(self.states["/running/push/wait"])
- self.states["/running/push"].addChild(self.states["/running/push/process"])
- self.states["/running/find_users"].addChild(self.states["/running/find_users/get_all_links"])
- self.states["/running/find_users"].addChild(self.states["/running/find_users/retrieve_users"])
- self.states["/running/find_users"].addChild(self.states["/running/find_users/got_usernames"])
- self.states["/running/find_users"].addChild(self.states["/running/find_users/process_users"])
- self.states["/running/find_users"].addChild(self.states["/running/find_users/creating_user"])
- self.states["/running/find_users"].addChild(self.states["/running/find_users/wait"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/init_server"]
- self.states["/running/wait_for_requests"].default_state = self.states["/running/wait_for_requests/wait"]
- self.states["/running/push"].default_state = self.states["/running/push/wait"]
- self.states["/running/find_users"].default_state = self.states["/running/find_users/get_all_links"]
-
- # transition /init_server
- _init_server_0 = Transition(self, self.states["/init_server"], [self.states["/init_executor"]])
- _init_server_0.setAction(self._init_server_0_exec)
- _init_server_0.setTrigger(Event("instance_created", None))
- self.states["/init_server"].addTransition(_init_server_0)
-
- # transition /init_executor
- _init_executor_0 = Transition(self, self.states["/init_executor"], [self.states["/read_root"]])
- _init_executor_0.setAction(self._init_executor_0_exec)
- _init_executor_0.setTrigger(Event("instance_created", None))
- self.states["/init_executor"].addTransition(_init_executor_0)
-
- # transition /read_root
- _read_root_0 = Transition(self, self.states["/read_root"], [self.states["/running"]])
- _read_root_0.setAction(self._read_root_0_exec)
- _read_root_0.setTrigger(Event("raw_exec_reply", None))
- self.states["/read_root"].addTransition(_read_root_0)
-
- # transition /running/wait_for_requests/wait
- _running_wait_for_requests_wait_0 = Transition(self, self.states["/running/wait_for_requests/wait"], [self.states["/running/wait_for_requests/wait"]])
- _running_wait_for_requests_wait_0.setAction(self._running_wait_for_requests_wait_0_exec)
- _running_wait_for_requests_wait_0.setTrigger(Event("from_mvi", None))
- self.states["/running/wait_for_requests/wait"].addTransition(_running_wait_for_requests_wait_0)
-
- # transition /running/push/wait
- _running_push_wait_0 = Transition(self, self.states["/running/push/wait"], [self.states["/running/push/process"]])
- _running_push_wait_0.setTrigger(None)
- _running_push_wait_0.setGuard(self._running_push_wait_0_guard)
- self.states["/running/push/wait"].addTransition(_running_push_wait_0)
- _running_push_wait_1 = Transition(self, self.states["/running/push/wait"], [self.states["/running/push/wait"]])
- _running_push_wait_1.setAction(self._running_push_wait_1_exec)
- _running_push_wait_1.setTrigger(None)
- _running_push_wait_1.setGuard(self._running_push_wait_1_guard)
- self.states["/running/push/wait"].addTransition(_running_push_wait_1)
-
- # transition /running/push/process
- _running_push_process_0 = Transition(self, self.states["/running/push/process"], [self.states["/running/push/wait"]])
- _running_push_process_0.setAction(self._running_push_process_0_exec)
- _running_push_process_0.setTrigger(None)
- _running_push_process_0.setGuard(self._running_push_process_0_guard)
- self.states["/running/push/process"].addTransition(_running_push_process_0)
- _running_push_process_1 = Transition(self, self.states["/running/push/process"], [self.states["/running/push/wait"]])
- _running_push_process_1.setAction(self._running_push_process_1_exec)
- _running_push_process_1.setTrigger(None)
- _running_push_process_1.setGuard(self._running_push_process_1_guard)
- self.states["/running/push/process"].addTransition(_running_push_process_1)
-
- # transition /running/find_users/get_all_links
- _running_find_users_get_all_links_0 = Transition(self, self.states["/running/find_users/get_all_links"], [self.states["/running/find_users/retrieve_users"]])
- _running_find_users_get_all_links_0.setAction(self._running_find_users_get_all_links_0_exec)
- _running_find_users_get_all_links_0.setTrigger(Event("raw_exec_reply", None))
- self.states["/running/find_users/get_all_links"].addTransition(_running_find_users_get_all_links_0)
-
- # transition /running/find_users/retrieve_users
- _running_find_users_retrieve_users_0 = Transition(self, self.states["/running/find_users/retrieve_users"], [self.states["/running/find_users/got_usernames"]])
- _running_find_users_retrieve_users_0.setAction(self._running_find_users_retrieve_users_0_exec)
- _running_find_users_retrieve_users_0.setTrigger(None)
- _running_find_users_retrieve_users_0.setGuard(self._running_find_users_retrieve_users_0_guard)
- self.states["/running/find_users/retrieve_users"].addTransition(_running_find_users_retrieve_users_0)
- _running_find_users_retrieve_users_1 = Transition(self, self.states["/running/find_users/retrieve_users"], [self.states["/running/find_users/wait"]])
- _running_find_users_retrieve_users_1.setTrigger(None)
- _running_find_users_retrieve_users_1.setGuard(self._running_find_users_retrieve_users_1_guard)
- self.states["/running/find_users/retrieve_users"].addTransition(_running_find_users_retrieve_users_1)
-
- # transition /running/find_users/got_usernames
- _running_find_users_got_usernames_0 = Transition(self, self.states["/running/find_users/got_usernames"], [self.states["/running/find_users/process_users"]])
- _running_find_users_got_usernames_0.setAction(self._running_find_users_got_usernames_0_exec)
- _running_find_users_got_usernames_0.setTrigger(Event("raw_exec_reply", None))
- self.states["/running/find_users/got_usernames"].addTransition(_running_find_users_got_usernames_0)
-
- # transition /running/find_users/process_users
- _running_find_users_process_users_0 = Transition(self, self.states["/running/find_users/process_users"], [self.states["/running/find_users/wait"]])
- _running_find_users_process_users_0.setTrigger(None)
- _running_find_users_process_users_0.setGuard(self._running_find_users_process_users_0_guard)
- self.states["/running/find_users/process_users"].addTransition(_running_find_users_process_users_0)
- _running_find_users_process_users_1 = Transition(self, self.states["/running/find_users/process_users"], [self.states["/running/find_users/creating_user"]])
- _running_find_users_process_users_1.setAction(self._running_find_users_process_users_1_exec)
- _running_find_users_process_users_1.setTrigger(None)
- _running_find_users_process_users_1.setGuard(self._running_find_users_process_users_1_guard)
- self.states["/running/find_users/process_users"].addTransition(_running_find_users_process_users_1)
- _running_find_users_process_users_2 = Transition(self, self.states["/running/find_users/process_users"], [self.states["/running/find_users/process_users"]])
- _running_find_users_process_users_2.setAction(self._running_find_users_process_users_2_exec)
- _running_find_users_process_users_2.setTrigger(None)
- _running_find_users_process_users_2.setGuard(self._running_find_users_process_users_2_guard)
- self.states["/running/find_users/process_users"].addTransition(_running_find_users_process_users_2)
-
- # transition /running/find_users/creating_user
- _running_find_users_creating_user_0 = Transition(self, self.states["/running/find_users/creating_user"], [self.states["/running/find_users/retrieve_users"]])
- _running_find_users_creating_user_0.setAction(self._running_find_users_creating_user_0_exec)
- _running_find_users_creating_user_0.setTrigger(Event("instance_created", None))
- self.states["/running/find_users/creating_user"].addTransition(_running_find_users_creating_user_0)
-
- # transition /running/find_users/wait
- _running_find_users_wait_0 = Transition(self, self.states["/running/find_users/wait"], [self.states["/running/find_users/get_all_links"]])
- _running_find_users_wait_0.setTrigger(Event("_0after"))
- self.states["/running/find_users/wait"].addTransition(_running_find_users_wait_0)
- _running_find_users_wait_1 = Transition(self, self.states["/running/find_users/wait"], [self.states["/running/find_users/get_all_links"]])
- _running_find_users_wait_1.setTrigger(Event("force_user_refresh", None))
- self.states["/running/find_users/wait"].addTransition(_running_find_users_wait_1)
-
- def _init_server_enter(self):
- self.big_step.outputEventOM(Event("create_instance", None, [self, 'to_mvi', 'Server', '', 8001]))
-
- def _init_executor_enter(self):
- self.big_step.outputEventOM(Event("create_instance", None, [self, 'executor', 'Executor']))
-
- def _read_root_enter(self):
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'executor', Event("raw_exec", None, [[['RR', []]], 'parent'])]))
-
- def _running_find_users_get_all_links_enter(self):
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'executor', Event("raw_exec", None, [[['RDK', [self.root]]], 'parent'])]))
-
- def _running_find_users_wait_enter(self):
- self.addTimer(0, 1.0)
-
- def _running_find_users_wait_exit(self):
- self.removeTimer(0)
-
- def _init_server_0_exec(self, parameters):
- instancename = parameters[0]
- self.big_step.outputEventOM(Event("start_instance", None, [self, instancename]))
-
- def _init_executor_0_exec(self, parameters):
- instancename = parameters[0]
- self.big_step.outputEventOM(Event("start_instance", None, [self, instancename]))
-
- def _read_root_0_exec(self, parameters):
- data = parameters[0]
- self.root = data[0][0]
-
- def _running_wait_for_requests_wait_0_exec(self, parameters):
- source = parameters[0]
- data = parameters[1]
- # No JSON encoding necessary, as it is not complex
- try:
- args = None
- if data["op"] == "set_input":
- if "value" in data:
- value = [json.loads(data["value"])]
- else:
- value = json.loads(data["data"])
- for v in value[:-1]:
- self.input_queue.append((None, data["op"], [v], data["username"]))
- self.input_queue.append((source, data["op"], [value[-1]], data["username"]))
- else:
- self.input_queue.append((source, data["op"], args, data["username"]))
- except ValueError:
- print("Error when deserializing request: " + str(data))
- raise
-
- def _running_push_wait_0_guard(self, parameters):
- return self.input_queue and self.input_queue[0][3] in self.user_statecharts
-
- def _running_push_wait_1_exec(self, parameters):
- self.user_queue.setdefault(self.input_queue[0][3], []).append(self.input_queue.pop(0))
- self.raiseInternalEvent(Event("force_user_refresh", None, []))
-
- def _running_push_wait_1_guard(self, parameters):
- return self.input_queue and self.input_queue[0][3] not in self.user_statecharts
-
- def _running_push_process_0_exec(self, parameters):
- source, op, args, username = self.input_queue.pop(0)
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, self.user_statecharts[username], Event("set_input", None, [source, args])]))
-
- def _running_push_process_0_guard(self, parameters):
- return self.input_queue[0][1] == 'set_input'
-
- def _running_push_process_1_exec(self, parameters):
- source, op, args, username = self.input_queue.pop(0)
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, self.user_statecharts[username], Event("get_output", None, [source, args])]))
-
- def _running_push_process_1_guard(self, parameters):
- return self.input_queue[0][1] == 'get_output'
-
- def _running_find_users_get_all_links_0_exec(self, parameters):
- data = parameters[0]
- self.users = data[0][0]
-
- def _running_find_users_retrieve_users_0_exec(self, parameters):
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'executor', Event("raw_exec", None, [[['RV', [user]] for user in self.users], 'parent'])]))
-
- def _running_find_users_retrieve_users_0_guard(self, parameters):
- return self.users
-
- def _running_find_users_retrieve_users_1_guard(self, parameters):
- return not self.users
-
- def _running_find_users_got_usernames_0_exec(self, parameters):
- data = parameters[0]
- data = set([v[0] for v in data])
- self.add_users = [v for v in data if v not in self.user_statecharts]
- self.delete_users = [v for v in self.user_statecharts if v not in data]
-
- def _running_find_users_process_users_0_guard(self, parameters):
- return not self.add_users and not self.delete_users
-
- def _running_find_users_process_users_1_exec(self, parameters):
- self.big_step.outputEventOM(Event("create_instance", None, [self, 'users', 'UserStatechart', self.add_users[0]]))
-
- def _running_find_users_process_users_1_guard(self, parameters):
- return self.add_users and not self.delete_users
-
- def _running_find_users_process_users_2_exec(self, parameters):
- self.big_step.outputEventOM(Event("delete_instance", None, [self, self.user_statecharts.pop(self.delete_users.pop(0))]))
-
- def _running_find_users_process_users_2_guard(self, parameters):
- return self.delete_users
-
- def _running_find_users_creating_user_0_exec(self, parameters):
- instancename = parameters[0]
- self.big_step.outputEventOM(Event("start_instance", None, [self, instancename]))
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, instancename, Event("set_returnpath", None, [instancename])]))
- self.user_statecharts[self.add_users[0]] = instancename
- # Repush all this user's messages in the input queue
- self.input_queue.extend(self.user_queue.pop(self.add_users[0], []))
- self.add_users.pop(0)
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/init_server"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class Server(RuntimeClassBase):
- def __init__(self, controller, address, port):
- RuntimeClassBase.__init__(self, controller)
-
- 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()
-
- # call user defined constructor
- Server.user_defined_constructor(self, address, port)
-
- def user_defined_constructor(self, address, port):
- self.socket = None
- self.address = address
- self.port = port
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, self)
-
- # state /main
- self.states["/main"] = ParallelState(1, self)
-
- # state /main/forward
- self.states["/main/forward"] = State(2, self)
-
- # state /main/forward/forward
- self.states["/main/forward/forward"] = State(3, self)
-
- # state /main/server
- self.states["/main/server"] = State(4, self)
-
- # state /main/server/init
- self.states["/main/server/init"] = State(5, self)
- self.states["/main/server/init"].setEnter(self._main_server_init_enter)
-
- # state /main/server/binding
- self.states["/main/server/binding"] = State(6, self)
- self.states["/main/server/binding"].setEnter(self._main_server_binding_enter)
-
- # state /main/server/listening
- self.states["/main/server/listening"] = State(7, self)
- self.states["/main/server/listening"].setEnter(self._main_server_listening_enter)
-
- # state /main/server/accepting
- self.states["/main/server/accepting"] = State(8, self)
- self.states["/main/server/accepting"].setEnter(self._main_server_accepting_enter)
- self.states["/main/server/accepting"].setExit(self._main_server_accepting_exit)
-
- # state /main/close_socket
- self.states["/main/close_socket"] = State(9, self)
-
- # state /main/close_socket/close
- self.states["/main/close_socket/close"] = State(10, self)
-
- # add children
- self.states[""].addChild(self.states["/main"])
- self.states["/main"].addChild(self.states["/main/forward"])
- self.states["/main"].addChild(self.states["/main/server"])
- self.states["/main"].addChild(self.states["/main/close_socket"])
- self.states["/main/forward"].addChild(self.states["/main/forward/forward"])
- self.states["/main/server"].addChild(self.states["/main/server/init"])
- self.states["/main/server"].addChild(self.states["/main/server/binding"])
- self.states["/main/server"].addChild(self.states["/main/server/listening"])
- self.states["/main/server"].addChild(self.states["/main/server/accepting"])
- self.states["/main/close_socket"].addChild(self.states["/main/close_socket/close"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/main"]
- self.states["/main/forward"].default_state = self.states["/main/forward/forward"]
- self.states["/main/server"].default_state = self.states["/main/server/init"]
- self.states["/main/close_socket"].default_state = self.states["/main/close_socket/close"]
-
- # transition /main/forward/forward
- _main_forward_forward_0 = Transition(self, self.states["/main/forward/forward"], [self.states["/main/forward/forward"]])
- _main_forward_forward_0.setAction(self._main_forward_forward_0_exec)
- _main_forward_forward_0.setTrigger(Event("HTTP_output", None))
- self.states["/main/forward/forward"].addTransition(_main_forward_forward_0)
-
- # transition /main/server/init
- _main_server_init_0 = Transition(self, self.states["/main/server/init"], [self.states["/main/server/binding"]])
- _main_server_init_0.setAction(self._main_server_init_0_exec)
- _main_server_init_0.setTrigger(Event("created_socket", "socket_in"))
- self.states["/main/server/init"].addTransition(_main_server_init_0)
-
- # transition /main/server/binding
- _main_server_binding_0 = Transition(self, self.states["/main/server/binding"], [self.states["/main/server/listening"]])
- _main_server_binding_0.setTrigger(Event("bound_socket", "socket_in"))
- _main_server_binding_0.setGuard(self._main_server_binding_0_guard)
- self.states["/main/server/binding"].addTransition(_main_server_binding_0)
-
- # transition /main/server/listening
- _main_server_listening_0 = Transition(self, self.states["/main/server/listening"], [self.states["/main/server/accepting"]])
- _main_server_listening_0.setAction(self._main_server_listening_0_exec)
- _main_server_listening_0.setTrigger(Event("listened_socket", "socket_in"))
- _main_server_listening_0.setGuard(self._main_server_listening_0_guard)
- self.states["/main/server/listening"].addTransition(_main_server_listening_0)
-
- # transition /main/server/accepting
- _main_server_accepting_0 = Transition(self, self.states["/main/server/accepting"], [self.states["/main/server/accepting"]])
- _main_server_accepting_0.setAction(self._main_server_accepting_0_exec)
- _main_server_accepting_0.setTrigger(Event("accepted_socket", "socket_in"))
- self.states["/main/server/accepting"].addTransition(_main_server_accepting_0)
- _main_server_accepting_1 = Transition(self, self.states["/main/server/accepting"], [self.states["/main/server/accepting"]])
- _main_server_accepting_1.setAction(self._main_server_accepting_1_exec)
- _main_server_accepting_1.setTrigger(Event("instance_created", None))
- self.states["/main/server/accepting"].addTransition(_main_server_accepting_1)
- _main_server_accepting_2 = Transition(self, self.states["/main/server/accepting"], [self.states["/main/server/accepting"]])
- _main_server_accepting_2.setTrigger(Event("_0after"))
- self.states["/main/server/accepting"].addTransition(_main_server_accepting_2)
-
- # transition /main/close_socket/close
- _main_close_socket_close_0 = Transition(self, self.states["/main/close_socket/close"], [self.states["/main/close_socket/close"]])
- _main_close_socket_close_0.setAction(self._main_close_socket_close_0_exec)
- _main_close_socket_close_0.setTrigger(Event("close_socket", None))
- self.states["/main/close_socket/close"].addTransition(_main_close_socket_close_0)
-
- def _main_server_init_enter(self):
- self.big_step.outputEvent(Event("create_socket", "socket_out", []))
-
- def _main_server_binding_enter(self):
- self.big_step.outputEvent(Event("bind_socket", "socket_out", [self.socket, (self.address, self.port)]))
-
- def _main_server_listening_enter(self):
- self.big_step.outputEvent(Event("listen_socket", "socket_out", [self.socket]))
-
- def _main_server_accepting_enter(self):
- self.addTimer(0, 1.0)
-
- def _main_server_accepting_exit(self):
- self.removeTimer(0)
-
- def _main_forward_forward_0_exec(self, parameters):
- association_name = parameters[0]
- data = parameters[1]
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("from_mvi", None, [association_name, data])]))
-
- def _main_server_init_0_exec(self, parameters):
- socket = parameters[0]
- self.socket = socket
-
- def _main_server_binding_0_guard(self, parameters):
- socket = parameters[0]
- return self.socket == socket
-
- def _main_server_listening_0_exec(self, parameters):
- socket = parameters[0]
- self.big_step.outputEvent(Event("accept_socket", "socket_out", [self.socket]))
-
- def _main_server_listening_0_guard(self, parameters):
- socket = parameters[0]
- return self.socket == socket
-
- def _main_server_accepting_0_exec(self, parameters):
- socket = parameters[0]
- connected_socket = parameters[1]
- self.big_step.outputEventOM(Event("create_instance", None, [self, 'sockets', 'Socket', connected_socket]))
- self.big_step.outputEvent(Event("accept_socket", "socket_out", [self.socket]))
-
- def _main_server_accepting_1_exec(self, parameters):
- instancename = parameters[0]
- self.big_step.outputEventOM(Event("start_instance", None, [self, instancename]))
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, instancename, Event("set_association_name", None, [instancename])]))
-
- def _main_close_socket_close_0_exec(self, parameters):
- association_name = parameters[0]
- self.big_step.outputEventOM(Event("delete_instance", None, [self, association_name]))
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/main"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class Socket(RuntimeClassBase):
- def __init__(self, controller, my_socket):
- RuntimeClassBase.__init__(self, controller)
-
- 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()
-
- # call user defined constructor
- Socket.user_defined_constructor(self, my_socket)
-
- def user_defined_constructor(self, my_socket):
- self.socket = my_socket
- self.received_data = ""
- self.send_data = ""
- self.closed = False
- self.association_name = None
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, self)
-
- # state /init
- self.states["/init"] = State(1, self)
-
- # state /connected
- self.states["/connected"] = ParallelState(2, self)
-
- # state /connected/listening
- self.states["/connected/listening"] = State(3, self)
-
- # state /connected/listening/listen
- self.states["/connected/listening/listen"] = State(4, self)
- self.states["/connected/listening/listen"].setEnter(self._connected_listening_listen_enter)
-
- # state /connected/listening/closed
- self.states["/connected/listening/closed"] = State(5, self)
- self.states["/connected/listening/closed"].setEnter(self._connected_listening_closed_enter)
-
- # state /connected/sending
- self.states["/connected/sending"] = State(6, self)
-
- # state /connected/sending/waiting_for_data
- self.states["/connected/sending/waiting_for_data"] = State(7, self)
-
- # state /connected/sending/transferring
- self.states["/connected/sending/transferring"] = State(8, self)
-
- # state /connected/queueing
- self.states["/connected/queueing"] = State(9, self)
-
- # state /connected/queueing/queueing
- self.states["/connected/queueing/queueing"] = State(10, self)
-
- # state /connected/parsing
- self.states["/connected/parsing"] = State(11, self)
-
- # state /connected/parsing/wait_for_header
- self.states["/connected/parsing/wait_for_header"] = State(12, self)
-
- # state /connected/parsing/closing
- self.states["/connected/parsing/closing"] = State(13, self)
- self.states["/connected/parsing/closing"].setEnter(self._connected_parsing_closing_enter)
- self.states["/connected/parsing/closing"].setExit(self._connected_parsing_closing_exit)
-
- # state /connected/parsing/wait_for_payload
- self.states["/connected/parsing/wait_for_payload"] = State(14, self)
-
- # state /close
- self.states["/close"] = State(15, self)
- self.states["/close"].setEnter(self._close_enter)
-
- # add children
- self.states[""].addChild(self.states["/init"])
- self.states[""].addChild(self.states["/connected"])
- self.states[""].addChild(self.states["/close"])
- self.states["/connected"].addChild(self.states["/connected/listening"])
- self.states["/connected"].addChild(self.states["/connected/sending"])
- self.states["/connected"].addChild(self.states["/connected/queueing"])
- self.states["/connected"].addChild(self.states["/connected/parsing"])
- self.states["/connected/listening"].addChild(self.states["/connected/listening/listen"])
- self.states["/connected/listening"].addChild(self.states["/connected/listening/closed"])
- self.states["/connected/sending"].addChild(self.states["/connected/sending/waiting_for_data"])
- self.states["/connected/sending"].addChild(self.states["/connected/sending/transferring"])
- self.states["/connected/queueing"].addChild(self.states["/connected/queueing/queueing"])
- self.states["/connected/parsing"].addChild(self.states["/connected/parsing/wait_for_header"])
- self.states["/connected/parsing"].addChild(self.states["/connected/parsing/closing"])
- self.states["/connected/parsing"].addChild(self.states["/connected/parsing/wait_for_payload"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/init"]
- self.states["/connected/listening"].default_state = self.states["/connected/listening/listen"]
- self.states["/connected/sending"].default_state = self.states["/connected/sending/waiting_for_data"]
- self.states["/connected/queueing"].default_state = self.states["/connected/queueing/queueing"]
- self.states["/connected/parsing"].default_state = self.states["/connected/parsing/wait_for_header"]
-
- # transition /init
- _init_0 = Transition(self, self.states["/init"], [self.states["/connected"]])
- _init_0.setAction(self._init_0_exec)
- _init_0.setTrigger(Event("set_association_name", None))
- self.states["/init"].addTransition(_init_0)
-
- # transition /connected/listening/listen
- _connected_listening_listen_0 = Transition(self, self.states["/connected/listening/listen"], [self.states["/connected/listening/listen"]])
- _connected_listening_listen_0.setAction(self._connected_listening_listen_0_exec)
- _connected_listening_listen_0.setTrigger(Event("received_socket", "socket_in"))
- _connected_listening_listen_0.setGuard(self._connected_listening_listen_0_guard)
- self.states["/connected/listening/listen"].addTransition(_connected_listening_listen_0)
- _connected_listening_listen_1 = Transition(self, self.states["/connected/listening/listen"], [self.states["/connected/listening/closed"]])
- _connected_listening_listen_1.setAction(self._connected_listening_listen_1_exec)
- _connected_listening_listen_1.setTrigger(Event("received_socket", "socket_in"))
- _connected_listening_listen_1.setGuard(self._connected_listening_listen_1_guard)
- self.states["/connected/listening/listen"].addTransition(_connected_listening_listen_1)
-
- # transition /connected/sending/waiting_for_data
- _connected_sending_waiting_for_data_0 = Transition(self, self.states["/connected/sending/waiting_for_data"], [self.states["/connected/sending/transferring"]])
- _connected_sending_waiting_for_data_0.setAction(self._connected_sending_waiting_for_data_0_exec)
- _connected_sending_waiting_for_data_0.setTrigger(None)
- _connected_sending_waiting_for_data_0.setGuard(self._connected_sending_waiting_for_data_0_guard)
- self.states["/connected/sending/waiting_for_data"].addTransition(_connected_sending_waiting_for_data_0)
-
- # transition /connected/sending/transferring
- _connected_sending_transferring_0 = Transition(self, self.states["/connected/sending/transferring"], [self.states["/connected/sending/waiting_for_data"]])
- _connected_sending_transferring_0.setAction(self._connected_sending_transferring_0_exec)
- _connected_sending_transferring_0.setTrigger(Event("sent_socket", "socket_in"))
- _connected_sending_transferring_0.setGuard(self._connected_sending_transferring_0_guard)
- self.states["/connected/sending/transferring"].addTransition(_connected_sending_transferring_0)
-
- # transition /connected/queueing/queueing
- _connected_queueing_queueing_0 = Transition(self, self.states["/connected/queueing/queueing"], [self.states["/connected/queueing/queueing"]])
- _connected_queueing_queueing_0.setAction(self._connected_queueing_queueing_0_exec)
- _connected_queueing_queueing_0.setTrigger(Event("HTTP_input", None))
- self.states["/connected/queueing/queueing"].addTransition(_connected_queueing_queueing_0)
-
- # transition /connected/parsing/wait_for_header
- _connected_parsing_wait_for_header_0 = Transition(self, self.states["/connected/parsing/wait_for_header"], [self.states["/connected/parsing/wait_for_payload"]])
- _connected_parsing_wait_for_header_0.setAction(self._connected_parsing_wait_for_header_0_exec)
- _connected_parsing_wait_for_header_0.setTrigger(None)
- _connected_parsing_wait_for_header_0.setGuard(self._connected_parsing_wait_for_header_0_guard)
- self.states["/connected/parsing/wait_for_header"].addTransition(_connected_parsing_wait_for_header_0)
- _connected_parsing_wait_for_header_1 = Transition(self, self.states["/connected/parsing/wait_for_header"], [self.states["/connected/parsing/closing"]])
- _connected_parsing_wait_for_header_1.setTrigger(None)
- _connected_parsing_wait_for_header_1.setGuard(self._connected_parsing_wait_for_header_1_guard)
- self.states["/connected/parsing/wait_for_header"].addTransition(_connected_parsing_wait_for_header_1)
-
- # transition /connected/parsing/closing
- _connected_parsing_closing_0 = Transition(self, self.states["/connected/parsing/closing"], [self.states["/connected/parsing/closing"]])
- _connected_parsing_closing_0.setAction(self._connected_parsing_closing_0_exec)
- _connected_parsing_closing_0.setTrigger(Event("_0after"))
- self.states["/connected/parsing/closing"].addTransition(_connected_parsing_closing_0)
-
- # transition /connected/parsing/wait_for_payload
- _connected_parsing_wait_for_payload_0 = Transition(self, self.states["/connected/parsing/wait_for_payload"], [self.states["/connected/parsing/wait_for_header"]])
- _connected_parsing_wait_for_payload_0.setAction(self._connected_parsing_wait_for_payload_0_exec)
- _connected_parsing_wait_for_payload_0.setTrigger(None)
- _connected_parsing_wait_for_payload_0.setGuard(self._connected_parsing_wait_for_payload_0_guard)
- self.states["/connected/parsing/wait_for_payload"].addTransition(_connected_parsing_wait_for_payload_0)
-
- # transition /connected
- _connected_0 = Transition(self, self.states["/connected"], [self.states["/close"]])
- _connected_0.setTrigger(Event("close", None))
- self.states["/connected"].addTransition(_connected_0)
-
- def _connected_listening_listen_enter(self):
- self.big_step.outputEvent(Event("recv_socket", "socket_out", [self.socket]))
-
- def _connected_listening_closed_enter(self):
- self.closed = True
-
- def _connected_parsing_closing_enter(self):
- self.addTimer(0, 0.0)
-
- def _connected_parsing_closing_exit(self):
- self.removeTimer(0)
-
- def _close_enter(self):
- self.big_step.outputEvent(Event("close_socket", "socket_out", [self.socket]))
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("close_socket", None, [self.association_name])]))
-
- def _init_0_exec(self, parameters):
- association_name = parameters[0]
- self.association_name = association_name
-
- def _connected_listening_listen_0_exec(self, parameters):
- socket = parameters[0]
- data = parameters[1]
- self.received_data += data
- self.raiseInternalEvent(Event("received_data", None, []))
-
- def _connected_listening_listen_0_guard(self, parameters):
- socket = parameters[0]
- data = parameters[1]
- return (self.socket == socket) and (len(data) > 0)
-
- def _connected_listening_listen_1_exec(self, parameters):
- socket = parameters[0]
- data = parameters[1]
- self.raiseInternalEvent(Event("received_data", None, []))
-
- def _connected_listening_listen_1_guard(self, parameters):
- socket = parameters[0]
- data = parameters[1]
- return (self.socket == socket) and (len(data) == 0)
-
- def _connected_sending_waiting_for_data_0_exec(self, parameters):
- self.big_step.outputEvent(Event("send_socket", "socket_out", [self.socket, self.send_data]))
-
- def _connected_sending_waiting_for_data_0_guard(self, parameters):
- return len(self.send_data) > 0
-
- def _connected_sending_transferring_0_exec(self, parameters):
- socket = parameters[0]
- sent_bytes = parameters[1]
- self.send_data = self.send_data[sent_bytes:]
-
- def _connected_sending_transferring_0_guard(self, parameters):
- socket = parameters[0]
- sent_bytes = parameters[1]
- return self.socket == socket
-
- def _connected_queueing_queueing_0_exec(self, parameters):
- data = parameters[0]
- #post_data = "&".join(["%s=%s" % (urllib.quote(k), urllib.quote(v)) for k, v in data.iteritems()])
- #post_data = "&".join(["%s=%s" % (k, v) for k, v in data.iteritems()])
- post_data = data
- self.send_data += "HTTP/1.0 200 OK\r\n"
- self.send_data += "Content-Length: %s\r\n" % len(post_data)
- self.send_data += "Content-Type: %s; charset=UTF-8\r\n" % "text/plain"
- self.send_data += "\r\n"
- self.send_data += str(post_data)
-
- def _connected_parsing_wait_for_header_0_exec(self, parameters):
- header, self.received_data = self.received_data.split("\r\n\r\n", 1)
- header = header.lower()
- if "content-length" in header:
- _, after = header.split("content-length:", 1)
- after = after.split("\r\n", 1)[0]
- after = after.strip()
- self.length = int(after)
- else:
- self.length = float('inf')
-
- def _connected_parsing_wait_for_header_0_guard(self, parameters):
- return '\r\n\r\n' in self.received_data and self.received_data.startswith('POST')
-
- def _connected_parsing_wait_for_header_1_guard(self, parameters):
- return self.closed and len(self.received_data) == 0
-
- def _connected_parsing_closing_0_exec(self, parameters):
- self.raiseInternalEvent(Event("close", None, []))
-
- def _connected_parsing_wait_for_payload_0_exec(self, parameters):
- if self.length == float('inf'):
- data = self.received_data
- self.received_data = ""
- else:
- data = self.received_data[:self.length]
- self.received_data = self.received_data[self.length:]
-
- # We support POST data only, so everything is in the data
- try:
- params = dict([p.split('=') for p in data.split('&')])
- data = {k: urllib.unquote_plus(v) for k, v in params.iteritems()}
- except:
- data = {}
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("HTTP_output", None, [self.association_name, data])]))
-
- def _connected_parsing_wait_for_payload_0_guard(self, parameters):
- return len(self.received_data) >= self.length or self.closed
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/init"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class HTTPClient(RuntimeClassBase):
- def __init__(self, controller, hostname, port):
- RuntimeClassBase.__init__(self, controller)
-
- 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()
-
- # call user defined constructor
- HTTPClient.user_defined_constructor(self, hostname, port)
-
- def user_defined_constructor(self, hostname, port):
- self.socket = None
- self.destination = (hostname, port)
- self.received_data = ""
- self.send_data = ""
- self.queue = []
- self.destinations = []
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, self)
-
- # state /init
- self.states["/init"] = State(1, self)
- self.states["/init"].setEnter(self._init_enter)
-
- # state /connecting
- self.states["/connecting"] = State(2, self)
- self.states["/connecting"].setEnter(self._connecting_enter)
-
- # state /connected
- self.states["/connected"] = ParallelState(3, self)
-
- # state /connected/listening
- self.states["/connected/listening"] = State(4, self)
-
- # state /connected/listening/listen
- self.states["/connected/listening/listen"] = State(5, self)
- self.states["/connected/listening/listen"].setEnter(self._connected_listening_listen_enter)
-
- # state /connected/listening/close
- self.states["/connected/listening/close"] = State(6, self)
-
- # state /connected/sending
- self.states["/connected/sending"] = State(7, self)
-
- # state /connected/sending/waiting_for_data
- self.states["/connected/sending/waiting_for_data"] = State(8, self)
-
- # state /connected/sending/transferring
- self.states["/connected/sending/transferring"] = State(9, self)
-
- # state /connected/queueing
- self.states["/connected/queueing"] = State(10, self)
-
- # state /connected/queueing/queueing
- self.states["/connected/queueing/queueing"] = State(11, self)
- self.states["/connected/queueing/queueing"].setEnter(self._connected_queueing_queueing_enter)
-
- # state /connected/parsing
- self.states["/connected/parsing"] = State(12, self)
-
- # state /connected/parsing/wait_for_header
- self.states["/connected/parsing/wait_for_header"] = State(13, self)
-
- # state /connected/parsing/wait_for_payload
- self.states["/connected/parsing/wait_for_payload"] = State(14, self)
-
- # add children
- self.states[""].addChild(self.states["/init"])
- self.states[""].addChild(self.states["/connecting"])
- self.states[""].addChild(self.states["/connected"])
- self.states["/connected"].addChild(self.states["/connected/listening"])
- self.states["/connected"].addChild(self.states["/connected/sending"])
- self.states["/connected"].addChild(self.states["/connected/queueing"])
- self.states["/connected"].addChild(self.states["/connected/parsing"])
- self.states["/connected/listening"].addChild(self.states["/connected/listening/listen"])
- self.states["/connected/listening"].addChild(self.states["/connected/listening/close"])
- self.states["/connected/sending"].addChild(self.states["/connected/sending/waiting_for_data"])
- self.states["/connected/sending"].addChild(self.states["/connected/sending/transferring"])
- self.states["/connected/queueing"].addChild(self.states["/connected/queueing/queueing"])
- self.states["/connected/parsing"].addChild(self.states["/connected/parsing/wait_for_header"])
- self.states["/connected/parsing"].addChild(self.states["/connected/parsing/wait_for_payload"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/init"]
- self.states["/connected/listening"].default_state = self.states["/connected/listening/listen"]
- self.states["/connected/sending"].default_state = self.states["/connected/sending/waiting_for_data"]
- self.states["/connected/queueing"].default_state = self.states["/connected/queueing/queueing"]
- self.states["/connected/parsing"].default_state = self.states["/connected/parsing/wait_for_header"]
-
- # transition /init
- _init_0 = Transition(self, self.states["/init"], [self.states["/connecting"]])
- _init_0.setAction(self._init_0_exec)
- _init_0.setTrigger(Event("created_socket", "socket_in"))
- self.states["/init"].addTransition(_init_0)
-
- # transition /connecting
- _connecting_0 = Transition(self, self.states["/connecting"], [self.states["/connected"]])
- _connecting_0.setAction(self._connecting_0_exec)
- _connecting_0.setTrigger(Event("connected_socket", "socket_in"))
- _connecting_0.setGuard(self._connecting_0_guard)
- self.states["/connecting"].addTransition(_connecting_0)
-
- # transition /connected/listening/listen
- _connected_listening_listen_0 = Transition(self, self.states["/connected/listening/listen"], [self.states["/connected/listening/listen"]])
- _connected_listening_listen_0.setAction(self._connected_listening_listen_0_exec)
- _connected_listening_listen_0.setTrigger(Event("received_socket", "socket_in"))
- _connected_listening_listen_0.setGuard(self._connected_listening_listen_0_guard)
- self.states["/connected/listening/listen"].addTransition(_connected_listening_listen_0)
- _connected_listening_listen_1 = Transition(self, self.states["/connected/listening/listen"], [self.states["/connected/listening/close"]])
- _connected_listening_listen_1.setTrigger(Event("received_socket", "socket_in"))
- _connected_listening_listen_1.setGuard(self._connected_listening_listen_1_guard)
- self.states["/connected/listening/listen"].addTransition(_connected_listening_listen_1)
-
- # transition /connected/sending/waiting_for_data
- _connected_sending_waiting_for_data_0 = Transition(self, self.states["/connected/sending/waiting_for_data"], [self.states["/connected/sending/transferring"]])
- _connected_sending_waiting_for_data_0.setAction(self._connected_sending_waiting_for_data_0_exec)
- _connected_sending_waiting_for_data_0.setTrigger(None)
- _connected_sending_waiting_for_data_0.setGuard(self._connected_sending_waiting_for_data_0_guard)
- self.states["/connected/sending/waiting_for_data"].addTransition(_connected_sending_waiting_for_data_0)
-
- # transition /connected/sending/transferring
- _connected_sending_transferring_0 = Transition(self, self.states["/connected/sending/transferring"], [self.states["/connected/sending/waiting_for_data"]])
- _connected_sending_transferring_0.setAction(self._connected_sending_transferring_0_exec)
- _connected_sending_transferring_0.setTrigger(Event("sent_socket", "socket_in"))
- _connected_sending_transferring_0.setGuard(self._connected_sending_transferring_0_guard)
- self.states["/connected/sending/transferring"].addTransition(_connected_sending_transferring_0)
-
- # transition /connected/queueing/queueing
- _connected_queueing_queueing_0 = Transition(self, self.states["/connected/queueing/queueing"], [self.states["/connected/queueing/queueing"]])
- _connected_queueing_queueing_0.setAction(self._connected_queueing_queueing_0_exec)
- _connected_queueing_queueing_0.setTrigger(Event("HTTP_input", None))
- self.states["/connected/queueing/queueing"].addTransition(_connected_queueing_queueing_0)
-
- # transition /connected/parsing/wait_for_header
- _connected_parsing_wait_for_header_0 = Transition(self, self.states["/connected/parsing/wait_for_header"], [self.states["/connected/parsing/wait_for_payload"]])
- _connected_parsing_wait_for_header_0.setAction(self._connected_parsing_wait_for_header_0_exec)
- _connected_parsing_wait_for_header_0.setTrigger(None)
- _connected_parsing_wait_for_header_0.setGuard(self._connected_parsing_wait_for_header_0_guard)
- self.states["/connected/parsing/wait_for_header"].addTransition(_connected_parsing_wait_for_header_0)
-
- # transition /connected/parsing/wait_for_payload
- _connected_parsing_wait_for_payload_0 = Transition(self, self.states["/connected/parsing/wait_for_payload"], [self.states["/connected/parsing/wait_for_header"]])
- _connected_parsing_wait_for_payload_0.setAction(self._connected_parsing_wait_for_payload_0_exec)
- _connected_parsing_wait_for_payload_0.setTrigger(None)
- _connected_parsing_wait_for_payload_0.setGuard(self._connected_parsing_wait_for_payload_0_guard)
- self.states["/connected/parsing/wait_for_payload"].addTransition(_connected_parsing_wait_for_payload_0)
-
- def _init_enter(self):
- self.big_step.outputEvent(Event("create_socket", "", []))
-
- def _connecting_enter(self):
- self.big_step.outputEvent(Event("connect_socket", "", [self.socket, self.destination]))
-
- def _connected_listening_listen_enter(self):
- self.big_step.outputEvent(Event("recv_socket", "socket_out", [self.socket]))
-
- def _connected_queueing_queueing_enter(self):
- pass
-
- def _init_0_exec(self, parameters):
- socket = parameters[0]
- self.socket = socket
-
- def _connecting_0_exec(self, parameters):
- socket = parameters[0]
- self.big_step.outputEventOM(Event("broad_cast", None, [Event("http_client_ready", None, [])]))
-
- def _connecting_0_guard(self, parameters):
- socket = parameters[0]
- return self.socket == socket
-
- def _connected_listening_listen_0_exec(self, parameters):
- socket = parameters[0]
- data = parameters[1]
- self.received_data += data
-
- def _connected_listening_listen_0_guard(self, parameters):
- socket = parameters[0]
- data = parameters[1]
- return (self.socket == socket) and (len(data) > 0)
-
- def _connected_listening_listen_1_guard(self, parameters):
- socket = parameters[0]
- data = parameters[1]
- return (self.socket == socket) and (len(data) == 0)
-
- def _connected_sending_waiting_for_data_0_exec(self, parameters):
- self.big_step.outputEvent(Event("send_socket", "socket_out", [self.socket, self.send_data]))
-
- def _connected_sending_waiting_for_data_0_guard(self, parameters):
- return len(self.send_data) > 0
-
- def _connected_sending_transferring_0_exec(self, parameters):
- socket = parameters[0]
- sent_bytes = parameters[1]
- self.send_data = self.send_data[sent_bytes:]
-
- def _connected_sending_transferring_0_guard(self, parameters):
- socket = parameters[0]
- sent_bytes = parameters[1]
- return self.socket == socket
-
- def _connected_queueing_queueing_0_exec(self, parameters):
- data = parameters[0]
- destination = parameters[1]
- self.send_data += "POST / HTTP/1.0\r\n"
- self.send_data += "Content-Length: %i\r\n" % len(str(data))
- self.send_data += "\r\n"
- self.send_data += data
- self.destinations.append(destination)
-
- def _connected_parsing_wait_for_header_0_exec(self, parameters):
- header, self.received_data = self.received_data.split("\r\n\r\n", 1)
- header = header.lower()
- if "content-length" in header:
- _, after = header.split("content-length:", 1)
- after, _ = after.split("\r\n", 1)
- after = after.strip()
- self.length = int(after)
- else:
- self.length = float('inf')
-
- def _connected_parsing_wait_for_header_0_guard(self, parameters):
- return '\r\n\r\n' in self.received_data
-
- def _connected_parsing_wait_for_payload_0_exec(self, parameters):
- data = self.received_data[:self.length]
- self.received_data = self.received_data[self.length:]
- params = dict([p.split('=') for p in data.split('&')])
- data = {k: urllib.unquote_plus(v) for k, v in params.iteritems()}
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, self.destinations.pop(0), Event("HTTP_output", None, [data])]))
-
- def _connected_parsing_wait_for_payload_0_guard(self, parameters):
- return len(self.received_data) >= self.length
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/init"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class UserStatechart(RuntimeClassBase):
- def __init__(self, controller, username):
- RuntimeClassBase.__init__(self, controller)
-
- 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()
-
- # call user defined constructor
- UserStatechart.user_defined_constructor(self, username)
-
- def user_defined_constructor(self, username):
- self.username = username
-
- self.output_queue = []
- self.source_execution = None
-
- self.request_id = 0
- self.outstanding_execution = None
- self.outstanding_input = {}
- self.outstanding_output = None
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, self)
-
- # state /init
- self.states["/init"] = State(1, self)
-
- # state /running
- self.states["/running"] = ParallelState(2, self)
-
- # state /running/execution
- self.states["/running/execution"] = State(3, self)
-
- # state /running/execution/init
- self.states["/running/execution/init"] = State(4, self)
- self.states["/running/execution/init"].setEnter(self._running_execution_init_enter)
-
- # state /running/execution/timeout
- self.states["/running/execution/timeout"] = State(5, self)
- self.states["/running/execution/timeout"].setEnter(self._running_execution_timeout_enter)
- self.states["/running/execution/timeout"].setExit(self._running_execution_timeout_exit)
-
- # state /running/set_input
- self.states["/running/set_input"] = State(6, self)
-
- # state /running/set_input/fetch
- self.states["/running/set_input/fetch"] = State(7, self)
-
- # state /running/get_output_queue
- self.states["/running/get_output_queue"] = State(8, self)
-
- # state /running/get_output_queue/waiting
- self.states["/running/get_output_queue/waiting"] = State(9, self)
-
- # state /running/get_output
- self.states["/running/get_output"] = State(10, self)
-
- # state /running/get_output/try_execute
- self.states["/running/get_output/try_execute"] = State(11, self)
-
- # state /running/get_output/waiting
- self.states["/running/get_output/waiting"] = State(12, self)
- self.states["/running/get_output/waiting"].setEnter(self._running_get_output_waiting_enter)
- self.states["/running/get_output/waiting"].setExit(self._running_get_output_waiting_exit)
-
- # add children
- self.states[""].addChild(self.states["/init"])
- self.states[""].addChild(self.states["/running"])
- self.states["/running"].addChild(self.states["/running/execution"])
- self.states["/running"].addChild(self.states["/running/set_input"])
- self.states["/running"].addChild(self.states["/running/get_output_queue"])
- self.states["/running"].addChild(self.states["/running/get_output"])
- self.states["/running/execution"].addChild(self.states["/running/execution/init"])
- self.states["/running/execution"].addChild(self.states["/running/execution/timeout"])
- self.states["/running/set_input"].addChild(self.states["/running/set_input/fetch"])
- self.states["/running/get_output_queue"].addChild(self.states["/running/get_output_queue/waiting"])
- self.states["/running/get_output"].addChild(self.states["/running/get_output/try_execute"])
- self.states["/running/get_output"].addChild(self.states["/running/get_output/waiting"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/init"]
- self.states["/running/execution"].default_state = self.states["/running/execution/init"]
- self.states["/running/set_input"].default_state = self.states["/running/set_input/fetch"]
- self.states["/running/get_output_queue"].default_state = self.states["/running/get_output_queue/waiting"]
- self.states["/running/get_output"].default_state = self.states["/running/get_output/try_execute"]
-
- # transition /init
- _init_0 = Transition(self, self.states["/init"], [self.states["/running"]])
- _init_0.setAction(self._init_0_exec)
- _init_0.setTrigger(Event("set_returnpath", None))
- self.states["/init"].addTransition(_init_0)
-
- # transition /running/execution/init
- _running_execution_init_0 = Transition(self, self.states["/running/execution/init"], [self.states["/running/execution/init"]])
- _running_execution_init_0.setTrigger(Event("executed", None))
- _running_execution_init_0.setGuard(self._running_execution_init_0_guard)
- self.states["/running/execution/init"].addTransition(_running_execution_init_0)
- _running_execution_init_1 = Transition(self, self.states["/running/execution/init"], [self.states["/running/execution/timeout"]])
- _running_execution_init_1.setTrigger(Event("executed", None))
- _running_execution_init_1.setGuard(self._running_execution_init_1_guard)
- self.states["/running/execution/init"].addTransition(_running_execution_init_1)
-
- # transition /running/execution/timeout
- _running_execution_timeout_0 = Transition(self, self.states["/running/execution/timeout"], [self.states["/running/execution/init"]])
- _running_execution_timeout_0.setTrigger(Event("_0after"))
- self.states["/running/execution/timeout"].addTransition(_running_execution_timeout_0)
- _running_execution_timeout_1 = Transition(self, self.states["/running/execution/timeout"], [self.states["/running/execution/init"]])
- _running_execution_timeout_1.setTrigger(Event("set_input_done", None))
- self.states["/running/execution/timeout"].addTransition(_running_execution_timeout_1)
-
- # transition /running/set_input/fetch
- _running_set_input_fetch_0 = Transition(self, self.states["/running/set_input/fetch"], [self.states["/running/set_input/fetch"]])
- _running_set_input_fetch_0.setAction(self._running_set_input_fetch_0_exec)
- _running_set_input_fetch_0.setTrigger(Event("set_input", None))
- self.states["/running/set_input/fetch"].addTransition(_running_set_input_fetch_0)
- _running_set_input_fetch_1 = Transition(self, self.states["/running/set_input/fetch"], [self.states["/running/set_input/fetch"]])
- _running_set_input_fetch_1.setAction(self._running_set_input_fetch_1_exec)
- _running_set_input_fetch_1.setTrigger(Event("executed", None))
- _running_set_input_fetch_1.setGuard(self._running_set_input_fetch_1_guard)
- self.states["/running/set_input/fetch"].addTransition(_running_set_input_fetch_1)
-
- # transition /running/get_output_queue/waiting
- _running_get_output_queue_waiting_0 = Transition(self, self.states["/running/get_output_queue/waiting"], [self.states["/running/get_output_queue/waiting"]])
- _running_get_output_queue_waiting_0.setAction(self._running_get_output_queue_waiting_0_exec)
- _running_get_output_queue_waiting_0.setTrigger(Event("get_output", None))
- self.states["/running/get_output_queue/waiting"].addTransition(_running_get_output_queue_waiting_0)
-
- # transition /running/get_output/try_execute
- _running_get_output_try_execute_0 = Transition(self, self.states["/running/get_output/try_execute"], [self.states["/running/get_output/try_execute"]])
- _running_get_output_try_execute_0.setAction(self._running_get_output_try_execute_0_exec)
- _running_get_output_try_execute_0.setTrigger(None)
- _running_get_output_try_execute_0.setGuard(self._running_get_output_try_execute_0_guard)
- self.states["/running/get_output/try_execute"].addTransition(_running_get_output_try_execute_0)
- _running_get_output_try_execute_1 = Transition(self, self.states["/running/get_output/try_execute"], [self.states["/running/get_output/try_execute"]])
- _running_get_output_try_execute_1.setAction(self._running_get_output_try_execute_1_exec)
- _running_get_output_try_execute_1.setTrigger(Event("executed", None))
- _running_get_output_try_execute_1.setGuard(self._running_get_output_try_execute_1_guard)
- self.states["/running/get_output/try_execute"].addTransition(_running_get_output_try_execute_1)
- _running_get_output_try_execute_2 = Transition(self, self.states["/running/get_output/try_execute"], [self.states["/running/get_output/waiting"]])
- _running_get_output_try_execute_2.setAction(self._running_get_output_try_execute_2_exec)
- _running_get_output_try_execute_2.setTrigger(Event("executed", None))
- _running_get_output_try_execute_2.setGuard(self._running_get_output_try_execute_2_guard)
- self.states["/running/get_output/try_execute"].addTransition(_running_get_output_try_execute_2)
-
- # transition /running/get_output/waiting
- _running_get_output_waiting_0 = Transition(self, self.states["/running/get_output/waiting"], [self.states["/running/get_output/try_execute"]])
- _running_get_output_waiting_0.setTrigger(Event("_1after"))
- self.states["/running/get_output/waiting"].addTransition(_running_get_output_waiting_0)
-
- def _running_execution_init_enter(self):
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/executor', Event("execute", None, [self.returnpath, self.username, 'execute_rule', [], self.request_id])]))
- self.outstanding_execution = self.request_id
- self.request_id += 1
-
- def _running_execution_timeout_enter(self):
- self.addTimer(0, 1.0)
-
- def _running_execution_timeout_exit(self):
- self.removeTimer(0)
-
- def _running_get_output_waiting_enter(self):
- self.addTimer(1, 1.0)
-
- def _running_get_output_waiting_exit(self):
- self.removeTimer(1)
-
- def _init_0_exec(self, parameters):
- returnpath = parameters[0]
- self.returnpath = returnpath
-
- def _running_execution_init_0_guard(self, parameters):
- returnvalue = parameters[0]
- success = parameters[1]
- request_id = parameters[2]
- return success and self.outstanding_execution == request_id
-
- def _running_execution_init_1_guard(self, parameters):
- returnvalue = parameters[0]
- success = parameters[1]
- request_id = parameters[2]
- return not success and self.outstanding_execution == request_id
-
- def _running_set_input_fetch_0_exec(self, parameters):
- source = parameters[0]
- args = parameters[1]
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/executor', Event("execute", None, [self.returnpath, self.username, 'set_input', args, self.request_id])]))
- if source is not None:
- self.outstanding_input[self.request_id] = source
- self.request_id += 1
-
- def _running_set_input_fetch_1_exec(self, parameters):
- returnvalue = parameters[0]
- success = parameters[1]
- request_id = parameters[2]
- source = self.outstanding_input.pop(request_id)
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/to_mvi/' + source, Event("HTTP_input", None, [json.dumps(returnvalue)])]))
- self.raiseInternalEvent(Event("set_input_done", None, []))
-
- def _running_set_input_fetch_1_guard(self, parameters):
- returnvalue = parameters[0]
- success = parameters[1]
- request_id = parameters[2]
- return request_id in self.outstanding_input
-
- def _running_get_output_queue_waiting_0_exec(self, parameters):
- source = parameters[0]
- args = parameters[1]
- self.output_queue.append(source)
-
- def _running_get_output_try_execute_0_exec(self, parameters):
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/executor', Event("execute", None, [self.returnpath, self.username, 'get_output', [], self.request_id])]))
- self.outstanding_output = self.request_id
- self.request_id += 1
-
- def _running_get_output_try_execute_0_guard(self, parameters):
- return self.outstanding_output is None and self.output_queue
-
- def _running_get_output_try_execute_1_exec(self, parameters):
- returnvalue = parameters[0]
- success = parameters[1]
- request_id = parameters[2]
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent/to_mvi/' + self.output_queue.pop(0), Event("HTTP_input", None, [json.dumps(returnvalue)])]))
- self.outstanding_output = None
-
- def _running_get_output_try_execute_1_guard(self, parameters):
- returnvalue = parameters[0]
- success = parameters[1]
- request_id = parameters[2]
- return success and request_id == self.outstanding_output
-
- def _running_get_output_try_execute_2_exec(self, parameters):
- returnvalue = parameters[0]
- success = parameters[1]
- request_id = parameters[2]
- self.outstanding_output = None
-
- def _running_get_output_try_execute_2_guard(self, parameters):
- returnvalue = parameters[0]
- success = parameters[1]
- request_id = parameters[2]
- return not success and request_id == self.outstanding_output
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/init"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class Executor(RuntimeClassBase):
- def __init__(self, controller):
- RuntimeClassBase.__init__(self, controller)
-
- 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()
-
- # call user defined constructor
- Executor.user_defined_constructor(self)
-
- def user_defined_constructor(self):
- self.mvs = ModelverseState("../../bootstrap/bootstrap.m.gz")
- self.request_queue = [("", "", "load_primitives", [], None)]
- self.mvs.GC = True
- self.mvk = ModelverseKernel(self.mvs.read_root()[0])
- self.first = True
- self.mvs_response = None
-
- self.mvs_operations = {
- "CN": self.mvs.create_node,
- "CE": self.mvs.create_edge,
- "CNV": self.mvs.create_nodevalue,
- "CD": self.mvs.create_dict,
-
- "RV": self.mvs.read_value,
- "RO": self.mvs.read_outgoing,
- "RI": self.mvs.read_incoming,
- "RE": self.mvs.read_edge,
- "RD": self.mvs.read_dict,
- "RDN": self.mvs.read_dict_node,
- "RDNE": self.mvs.read_dict_node_edge,
- "RDE": self.mvs.read_dict_edge,
- "RRD": self.mvs.read_reverse_dict,
- "RR": self.mvs.read_root,
- "RDK": self.mvs.read_dict_keys,
-
- "DE": self.mvs.delete_edge,
- "DN": self.mvs.delete_node,
- }
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, self)
-
- # state /init
- self.states["/init"] = ParallelState(1, self)
-
- # state /init/raw_exec
- self.states["/init/raw_exec"] = State(2, self)
-
- # state /init/raw_exec/raw_exec
- self.states["/init/raw_exec/raw_exec"] = State(3, self)
-
- # state /init/queue
- self.states["/init/queue"] = State(4, self)
-
- # state /init/queue/queue
- self.states["/init/queue/queue"] = State(5, self)
-
- # state /init/execute
- self.states["/init/execute"] = State(6, self)
-
- # state /init/execute/idle
- self.states["/init/execute/idle"] = State(7, self)
-
- # state /init/execute/execution
- self.states["/init/execute/execution"] = State(8, self)
- self.states["/init/execute/execution"].setEnter(self._init_execute_execution_enter)
-
- # add children
- self.states[""].addChild(self.states["/init"])
- self.states["/init"].addChild(self.states["/init/raw_exec"])
- self.states["/init"].addChild(self.states["/init/queue"])
- self.states["/init"].addChild(self.states["/init/execute"])
- self.states["/init/raw_exec"].addChild(self.states["/init/raw_exec/raw_exec"])
- self.states["/init/queue"].addChild(self.states["/init/queue/queue"])
- self.states["/init/execute"].addChild(self.states["/init/execute/idle"])
- self.states["/init/execute"].addChild(self.states["/init/execute/execution"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/init"]
- self.states["/init/raw_exec"].default_state = self.states["/init/raw_exec/raw_exec"]
- self.states["/init/queue"].default_state = self.states["/init/queue/queue"]
- self.states["/init/execute"].default_state = self.states["/init/execute/idle"]
-
- # transition /init/raw_exec/raw_exec
- _init_raw_exec_raw_exec_0 = Transition(self, self.states["/init/raw_exec/raw_exec"], [self.states["/init/raw_exec/raw_exec"]])
- _init_raw_exec_raw_exec_0.setAction(self._init_raw_exec_raw_exec_0_exec)
- _init_raw_exec_raw_exec_0.setTrigger(Event("raw_exec", None))
- self.states["/init/raw_exec/raw_exec"].addTransition(_init_raw_exec_raw_exec_0)
-
- # transition /init/queue/queue
- _init_queue_queue_0 = Transition(self, self.states["/init/queue/queue"], [self.states["/init/queue/queue"]])
- _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)
-
- # transition /init/execute/idle
- _init_execute_idle_0 = Transition(self, self.states["/init/execute/idle"], [self.states["/init/execute/execution"]])
- _init_execute_idle_0.setTrigger(None)
- _init_execute_idle_0.setGuard(self._init_execute_idle_0_guard)
- self.states["/init/execute/idle"].addTransition(_init_execute_idle_0)
-
- # transition /init/execute/execution
- _init_execute_execution_0 = Transition(self, self.states["/init/execute/execution"], [self.states["/init/execute/idle"]])
- _init_execute_execution_0.setAction(self._init_execute_execution_0_exec)
- _init_execute_execution_0.setTrigger(None)
- _init_execute_execution_0.setGuard(self._init_execute_execution_0_guard)
- self.states["/init/execute/execution"].addTransition(_init_execute_execution_0)
- _init_execute_execution_1 = Transition(self, self.states["/init/execute/execution"], [self.states["/init/execute/idle"]])
- _init_execute_execution_1.setTrigger(None)
- _init_execute_execution_1.setGuard(self._init_execute_execution_1_guard)
- self.states["/init/execute/execution"].addTransition(_init_execute_execution_1)
-
- def _init_execute_execution_enter(self):
- self.mvk.returnvalue = None
- self.mvk.success = True
- self.first = True
-
- self.returnpath, username, operation, params, self.request_id = self.request_queue.pop(0)
- reply = None
- commands = []
- while 1:
- commands = self.mvk.execute_yields(username, operation, params, reply)
- if commands is None:
- break
- reply = [self.mvs_operations[command[0]](*(command[1]))[0] for command in commands]
-
- def _init_raw_exec_raw_exec_0_exec(self, parameters):
- operations = parameters[0]
- source = parameters[1]
- reply = [self.mvs_operations[command[0]](*command[1]) for command in operations]
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, source, Event("raw_exec_reply", None, [reply])]))
-
- def _init_queue_queue_0_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))
-
- def _init_execute_idle_0_guard(self, parameters):
- return self.request_queue
-
- def _init_execute_execution_0_exec(self, parameters):
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent' + self.returnpath, Event("executed", None, [self.mvk.returnvalue, self.mvk.success, self.request_id])]))
-
- def _init_execute_execution_0_guard(self, parameters):
- return self.returnpath is not None
-
- def _init_execute_execution_1_guard(self, parameters):
- return self.returnpath is None
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/init"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class ObjectManager(ObjectManagerBase):
- def __init__(self, controller):
- ObjectManagerBase.__init__(self, controller)
-
- def instantiate(self, class_name, construct_params):
- if class_name == "MvKController":
- instance = MvKController(self.controller, construct_params[0])
- instance.associations = {}
- instance.associations["to_mvs"] = Association("HTTPClient", 1, 1)
- instance.associations["to_mvi"] = Association("Server", 1, 1)
- instance.associations["users"] = Association("UserStatechart", 0, -1)
- instance.associations["executor"] = Association("Executor", 1, 1)
- elif class_name == "Server":
- instance = Server(self.controller, construct_params[0], construct_params[1])
- instance.associations = {}
- instance.associations["sockets"] = Association("Socket", 0, -1)
- instance.associations["parent"] = Association("MvKController", 1, 1)
- elif class_name == "Socket":
- instance = Socket(self.controller, construct_params[0])
- instance.associations = {}
- instance.associations["parent"] = Association("Server", 1, 1)
- elif class_name == "HTTPClient":
- instance = HTTPClient(self.controller, construct_params[0], construct_params[1])
- instance.associations = {}
- instance.associations["parent"] = Association("MvKController", 1, 1)
- elif class_name == "UserStatechart":
- instance = UserStatechart(self.controller, construct_params[0])
- instance.associations = {}
- instance.associations["parent"] = Association("MvKController", 1, 1)
- elif class_name == "Executor":
- instance = Executor(self.controller)
- instance.associations = {}
- instance.associations["parent"] = Association("MvKController", 1, 1)
- else:
- raise Exception("Cannot instantiate class " + class_name)
- return instance
- class Controller(ThreadsControllerBase):
- def __init__(self, params, keep_running = None, behind_schedule_callback = None):
- if keep_running == None: keep_running = True
- if behind_schedule_callback == None: behind_schedule_callback = None
- ThreadsControllerBase.__init__(self, ObjectManager(self), keep_running, behind_schedule_callback)
- self.addInputPort("socket_in")
- self.addOutputPort("socket_out")
- self.object_manager.createInstance("MvKController", [params])
|