logos-blockchain/logos-blockchain-specs
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-specs.git synced 2026-02-23 22:53:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: update node state to RECEIVING only when it is not SENDING

Browse Source
This commit is contained in:
Youngjoon Lee 2024-05-21 19:55:34 +09:00
parent f82b93387b
commit 9e592bcc03
No known key found for this signature in database
GPG Key ID: 09B750B5BD6F08A2
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
mixnet/v2/sim/adversary.py
View File

@ -31,14 +31,13 @@ class Adversary:
def observe_incoming_message(self, node: "Node"):
self.mixed_msgs_per_window[-1][node] += 1
# TODO: check duplications. Two events at the same time?
self.node_states[self.env.now][node] = NodeState.RECEIVING
if node not in self.node_states[self.env.now]:
self.node_states[self.env.now][node] = NodeState.RECEIVING
def observe_outgoing_message(self, node: "Node"):
self.mixed_msgs_per_window[-1][node] -= 1
if self.is_around_message_interval(self.env.now):
self.senders_around_interval[node] += 1
# TODO: check duplications. Two events at the same time?
self.node_states[self.env.now][node] = NodeState.SENDING
def is_around_message_interval(self, time: SimTime):