logos-blockchain/logos-blockchain-specs
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-specs.git synced 2026-01-09 08:33:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: gossiping ingress measurement

Browse Source
This commit is contained in:
Youngjoon Lee 2024-05-25 14:26:09 +09:00
parent 4a9c58f06f
commit 53bb8b1bde
No known key found for this signature in database
GPG Key ID: 09B750B5BD6F08A2
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
mixnet/v2/sim/p2p.py
View File

@ -73,8 +73,9 @@ class NaiveBroadcastP2P(P2P):
def receive(self, msg: SphinxPacket | bytes, sender: "Node", receiver: "Node"):
yield from super().receive(msg, sender, receiver)
# Measurement and adversary
# Measurement
self.measurement.measure_ingress(receiver, msg)
# Adversary
self.adversary.observe_incoming_message(receiver)
self.env.process(receiver.receive_message(msg))
@ -133,16 +134,17 @@ class GossipP2P(P2P):
def receive(self, msg: SphinxPacket | bytes, sender: "Node", receiver: "Node"):
yield from super().receive(msg, sender, receiver)
# Measure ingress regardless of whether the message has been received before,
# because the node doesn't know if the message is a duplicate before receiving it from the network.
self.measurement.measure_ingress(receiver, msg)
# Adversary
self.adversary.observe_incoming_message(receiver)
# Receive/gossip the msg only if it hasn't been received before. If not, just ignore the msg.
# i.e. each message is received/gossiped at most once by each node.
msg_hash = hashlib.sha256(bytes(msg)).digest()
if msg_hash not in self.message_cache[receiver]:
self.message_cache[receiver][msg_hash] = sender
# Measurement and adversary
self.measurement.measure_ingress(receiver, msg)
self.adversary.observe_incoming_message(receiver)
# Receive and gossip
self.env.process(receiver.receive_message(msg))
self.env.process(self.broadcast(receiver, msg))