import sys sys.path.append("../kernel/") sys.path.append("../state/") from modelverse_state.main import ModelverseState as MvS from modelverse_kernel.main import ModelverseKernel as MvK from pypdevs.DEVS import AtomicDEVS, CoupledDEVS from pypdevs.simulator import Simulator import json def translate(operation): return { "CN": "create_node", "CE": "create_edge", "CNV": "create_nodevalue", "CD": "create_dict", "RV": "read_value", "RO": "read_outgoing", "RI": "read_incoming", "RE": "read_edge", "RD": "read_dict", "RDN": "read_dict_node", "RDNE": "read_dict_node_edge", "RDE": "read_dict_edge", "RRD": "read_reverse_dict", "RR": "read_root", "RDK": "read_dict_keys", "DE": "delete_edge", "DN": "delete_node", }[operation] class MvSState(object): def __init__(self): self.queue = [] self.output = None self.mvs = MvS() self.timer = float("inf") class ModelverseState(AtomicDEVS): def __init__(self, read_root, create_node, create_edge, create_nodevalue, create_dict, read_value, read_outgoing, read_incoming, read_edge, read_dict, read_dict_keys, read_dict_edge, read_dict_node, read_dict_node_edge, read_reverse_dict, delete_node, delete_edge): AtomicDEVS.__init__(self, "MvS") self.timings = { "read_root": read_root, "create_node": create_node, "create_edge": create_edge, "create_nodevalue": create_nodevalue, "create_dict": create_dict, "read_value": read_value, "read_outgoing": read_outgoing, "read_incoming": read_incoming, "read_edge": read_edge, "read_dict": read_dict, "read_dict_keys": read_dict_keys, "read_dict_edge": read_dict_edge, "read_dict_node": read_dict_node, "read_dict_node_edge": read_dict_node_edge, "read_reverse_dict": read_reverse_dict, "delete_node": delete_node, "delete_edge": delete_edge, } self.state = MvSState() self.from_mvk = self.addInPort("from_MvK") self.to_mvk = self.addOutPort("to_MvK") def extTransition(self, inputs): self.state.timer -= self.elapsed empty = len(self.state.queue) == 0 self.state.queue.extend(inputs[self.from_mvk]) if empty: # First message, so set the timer # And already compute the result so it is ready to output self.state.output = [] self.state.timer = 0.0 print("Got input: " + str(inputs[self.from_mvk])) for v in self.state.queue[0]: self.state.output.append(getattr(self.state.mvs, translate(v[0]))(*v[1])[0]) self.state.timer += self.timings[translate(v[0])]() else: # Just append the message to process pass return self.state def outputFnc(self): return {self.to_mvk: [self.state.output]} def intTransition(self): self.state.queue.pop(0) self.state.output = [] if len(self.state.queue) > 0: self.state.timer = 0.0 # Value contains a list of operations to do # So do them and calculate how long it takes for v in self.state.queue[0]: self.state.output.append(getattr(self.state.mvs, translate(v[0]))(*v[1])[0]) self.state.timer += self.timings[translate(v[0])]() else: self.state.timer = float("inf") return self.state def timeAdvance(self): return self.state.timer class MvKState(object): def __init__(self): self.mvk = None self.waiting = False class ModelverseKernel(AtomicDEVS): def __init__(self): AtomicDEVS.__init__(self, "MvK") self.state = MvKState() self.from_mvi = self.addInPort("from_MvI") self.from_mvs = self.addInPort("from_MvS") self.to_mvi = self.addOutPort("to_MvI") self.to_mvs = self.addOutPort("to_MvS") def extTransition(self, inputs): if self.from_mvi in inputs: # Got input from MvI, so we queue it pass elif self.from_mvs in inputs: # Got input from MvS, so we can continue processing if self.state.mvk is None: # No MvK, so set it with the root we have just received (or should have received) self.state.mvk = MvK(inputs[self.from_mvs][0]) return self.state def intTransition(self): if self.state.mvk is None: self.state.waiting = True return self.state def outputFnc(self): if self.state.mvk is None: # Ask the root first return {self.to_mvs: [[("RR", [])]]} def timeAdvance(self): if self.state.waiting: return float("inf") elif self.state.mvk is None: return 0 else: return float("inf") class MvIState(): def __init__(self): self.operations = [] self.output = [] self.processing = [] self.memory = {} class ModelverseInterface(AtomicDEVS): def __init__(self, operations): AtomicDEVS.__init__(self, "MvI") self.state = MvIState() self.state.operations = operations self.to_mvk = self.addOutPort("to_MvK") self.from_mvk = self.addInPort("from_MvK") def intTransition(self): while self.state.operations: i = self.state.operations[0] if isinstance(i, int) and i not in self.memory: break self.state.operations.pop(0) return self.state def extTransition(self, inputs): for inp in inputs[self.from_mvk]: if inp["value"] == "None" and isinstance(self.state.processing[0], int) and self.state.processing[0] not in self.memory: self.state.memory[self.state.processing.pop(0)] = int(inp["id"]) else: self.state.output.append(inp) return self.state def outputFnc(self): send = [] for i in self.state.operations: if isinstance(i, int) and i not in self.memory: break elif isinstance(i, int) and i in self.memory: # Pass a reference! send.append(("R", self.memory[i])) elif not isinstance(i, int): send.append(("V", i)) return {self.to_mvk: [send]} def timeAdvance(self): if self.state.processing and (not isinstance(self.state.processing[0], int) or self.state.processing[0] in self.memory): return 0 else: return float("inf") class NetworkState(object): def __init__(self): self.processing = [] self.timer = float("inf") class Network(AtomicDEVS): def __init__(self, name, latency, bandwidth): AtomicDEVS.__init__(self, name) self.state = NetworkState() self.input_port = self.addInPort("input_port") self.output_port = self.addOutPort("output_port") self.latency = latency self.bandwidth = bandwidth def intTransition(self): self.state.processing.pop(0) if self.state.processing: self.state.timer = int(len(self.state.processing[0]) / float(self.bandwidth) + self.latency) else: self.state.timer = float("inf") return self.state def extTransition(self, inputs): self.state.timer -= self.elapsed if self.state.timer == float("inf"): self.state.timer = 0 for v in inputs[self.input_port]: self.state.processing.append(json.dumps(v)) if len(self.state.processing) > 0: self.state.timer = int(len(self.state.processing[0]) / float(self.bandwidth) + self.latency) return self.state def outputFnc(self): return {self.output_port: [json.loads(self.state.processing[0])]} def timeAdvance(self): return self.state.timer class System(CoupledDEVS): def __init__(self, operations, mvi2mvk_latency, mvi2mvk_bandwidth, mvk2mvs_latency, mvk2mvs_bandwidth, mvs2mvk_latency, mvs2mvk_bandwidth, mvk2mvi_latency, mvk2mvi_bandwidth, read_root, create_node, create_edge, create_nodevalue, create_dict, read_value, read_outgoing, read_incoming, read_edge, read_dict, read_dict_keys, read_dict_edge, read_dict_node, read_dict_node_edge, read_reverse_dict, delete_node, delete_edge): CoupledDEVS.__init__(self, "System") self.mvi = self.addSubModel(ModelverseInterface(\ operations = operations )) self.mvk = self.addSubModel(ModelverseKernel()) self.mvs = self.addSubModel(ModelverseState(\ read_root = read_root, create_node = create_node, create_edge = create_edge, create_nodevalue = create_nodevalue, create_dict = create_dict, read_value = read_value, read_outgoing = read_outgoing, read_incoming = read_incoming, read_edge = read_edge, read_dict = read_dict, read_dict_keys = read_dict_keys, read_dict_edge = read_dict_edge, read_dict_node = read_dict_node, read_dict_node_edge = read_dict_node_edge, read_reverse_dict = read_reverse_dict, delete_node = delete_node, delete_edge = delete_edge )) self.mvi2mvk = self.addSubModel(Network(\ name = "mvi2mvk", latency = mvi2mvk_latency, bandwidth = mvi2mvk_bandwidth )) self.mvk2mvs = self.addSubModel(Network(\ name = "mvk2mvs", latency = mvk2mvs_latency, bandwidth = mvk2mvs_bandwidth )) self.mvs2mvk = self.addSubModel(Network(\ name = "mvs2mvk", latency = mvs2mvk_latency, bandwidth = mvs2mvk_bandwidth )) self.mvk2mvi = self.addSubModel(Network(\ name = "mvk2mvi", latency = mvk2mvi_latency, bandwidth = mvk2mvi_bandwidth )) self.connectPorts(self.mvi.to_mvk, self.mvi2mvk.input_port) self.connectPorts(self.mvi2mvk.output_port, self.mvk.from_mvi) self.connectPorts(self.mvk.to_mvs, self.mvk2mvs.input_port) self.connectPorts(self.mvk2mvs.output_port, self.mvs.from_mvk) self.connectPorts(self.mvs.to_mvk, self.mvs2mvk.input_port) self.connectPorts(self.mvs2mvk.output_port, self.mvk.from_mvs) self.connectPorts(self.mvk.to_mvi, self.mvk2mvi.input_port) self.connectPorts(self.mvk2mvi.output_port, self.mvi.from_mvk) operations = [ "test", ] args = { "operations": operations, "mvi2mvk_latency": 1, "mvi2mvk_bandwidth": 2000, "mvk2mvs_latency": 1, "mvk2mvs_bandwidth": 2000, "mvs2mvk_latency": 1, "mvs2mvk_bandwidth": 2000, "mvk2mvi_latency": 1, "mvk2mvi_bandwidth": 2000, "read_root": lambda: 1, "create_node": lambda: 1, "create_edge": lambda: 1, "create_nodevalue": lambda: 1, "create_dict": lambda: 1, "read_value": lambda: 1, "read_outgoing": lambda: 1, "read_incoming": lambda: 1, "read_edge": lambda: 1, "read_dict": lambda: 1, "read_dict_keys": lambda: 1, "read_dict_node": lambda: 1, "read_dict_edge": lambda: 1, "read_dict_node_edge": lambda: 1, "read_reverse_dict": lambda: 1, "delete_node": lambda: 1, "delete_edge": lambda: 1, } model = System(**args) sim = Simulator(model) sim.setTerminationTime(10) sim.setVerbose() sim.simulate()