loic/esds
1
0
Fork 0
mirror of https://gitlab.com/manzerbredes/esds.git synced 2025-04-05 17:46:29 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Debug callbacks

Browse source
This commit is contained in:
Loic Guegan 2022-09-13 10:04:27 +02:00
parent a2c5db3882
commit 14feec9657
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
esds/simulator.py
View file

@ -397,12 +397,13 @@ class Simulator:
# Process events
while len(self.events) > 0 and self.events[0,1] == self.time:
event_type=int(self.events[0,0])
event=self.events[0]
event_type=int(event[0])
ts=self.events[0,1]
event=self.events[0,2]
content=self.events[0,2]
self.events=np.delete(self.events,0,0) # Consume events NOW! not at the end of the loop (event list may change in between)
if event_type == 0:
src_id,dst_id,interface, data, datasize,duration,datasize_remaining,start_at,perform_delivery,receiver_required=event
src_id,dst_id,interface, data, datasize,duration,datasize_remaining,start_at,perform_delivery,receiver_required=content
src=self.nodes[int(src_id)]
dst=self.nodes[int(dst_id)]
if self.netmat[interface]["is_wired"]:
@ -442,12 +443,12 @@ class Simulator:
self.sync_node_non_blocking(src,timeout_remove_only=True)
self.notify_node_plugins(src, "on_communication_end", event)
elif event_type == 1: # Timeout
node=self.nodes[int(event)]
node=self.nodes[int(content)]
node["state"]="running"
node.rqueue.put(("timeout",RCode.SUCCESS))
self.sync_node_non_blocking(node,timeout_remove_only=True)
elif event_type == 4:
node=self.nodes[int(event)]
node=self.nodes[int(content)]
node["state"]="running"
node.rqueue.put(("notify",RCode.SUCCESS))
self.sync_node_non_blocking(node,timeout_remove_only=True)