loic/esds
1
0
Fork 0
mirror of https://gitlab.com/manzerbredes/esds.git synced 2025-04-06 01:56:27 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Debug node state update that should be performed before node queue update

Browse source
This commit is contained in:
Loic Guegan 2022-06-21 19:41:44 +02:00
parent dc7f062517
commit a2cd1b1fdc
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
esds/esds.py
View file

@ -446,8 +446,8 @@ class Simulator:
interface=node.rargs
if node["interfaces_queue_size"][interface] > 0:
node["interfaces_queue_size"][interface]-=1
node.rqueue.put(("receive",0))
node["state"]="running"
node.rqueue.put(("receive",0))
# Do not forget to collect the next event. This is the only request which is processed here
self.sync_node(node)
self.sync_event(node)
@ -533,8 +533,8 @@ class Simulator:
# Notify nodes that wait for the end of the simulation
# Note that we do not allow them to create new events (even if they try, they will not be processed)
for node_id in self.wait_end_nodes:
self.nodes[node_id].rqueue.put(("sim_end",0))
self.nodes[node_id]["state"]="running"
self.nodes[node_id].rqueue.put(("sim_end",0))
self.sync_node(self.nodes[node_id]) # Allow them for make call requests (printing logs for example)
break # End the event processing loop
@ -560,8 +560,8 @@ class Simulator:
# If node is receiving makes it consume (this way if there is a timeout, it will be removed!)
if dst["state"] == "request" and dst["request"] == "receive":
dst["interfaces_queue_size"][interface]-=1
dst.rqueue.put(("receive",0))
dst["state"]="running"
dst.rqueue.put(("receive",0))
self.sync_node(dst)
src["state"]="running"
src.rqueue.put(("send",0))
@ -573,8 +573,8 @@ class Simulator:
# If node is receiving makes it consume (this way if there is a timeout, it will be removed!)
if dst["state"] == "request" and dst["request"] == "receive":
dst["interfaces_queue_size"][interface]-=1
dst.rqueue.put(("receive",0))
dst["state"]="running"
dst.rqueue.put(("receive",0))
self.sync_node(dst)
else:
src["state"]="running"