| 123456789101112131415161718192021222324252627282930313233343536373839404142 |
- from pypdevs.simulator import Simulator
- import re
- def get_port(text):
- match = re.search(r'private_\d+_(\w+)', text)
- if match:
- result = match.group(1)
- return result
- else:
- return text
- class DEVSSimulator(Simulator):
- def __init__(self, model, inputs={}):
- super().__init__(model)
- # TODO: Add the input ports here so it works without manually adding them
- inputs ={}
- # Add global inports
- for global_in in model.IPorts:
- inputs[global_in.name] = global_in
- # Add private ports (can't send to it unless it knows the id)
- for aclass in model.atomics:
- pass
- self.setRealTimePorts(inputs)
-
- def addInput(self, event):
- port_name = get_port(event.port)
- event_string = f"Event(\"{event.name}\",\"{event.port}\",{event.parameters})"
- event_string = event_string.replace(" ", "")
- interrupt_string = f"{port_name} {event_string}"
- #event_string = f"Event(\"{event.name}\",\"{"ui"}\",{event.parameters})"
- #interrupt_string = f"ui {event_string}"
- self.realtime_interrupt(interrupt_string)
|
