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

fix noise size

Browse Source
This commit is contained in:
Youngjoon Lee 2024-07-08 17:14:51 +09:00
parent d3e8b0223e
commit 36eeab05ed
No known key found for this signature in database
GPG Key ID: B4253AFBA618BF4D
1 changed files with 19 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
mixnet/node.py
View File

@ -5,7 +5,6 @@ import hashlib
from enum import Enum
from typing import Awaitable, Callable, TypeAlias
from pysphinx.payload import DEFAULT_PAYLOAD_SIZE
from pysphinx.sphinx import (
Payload,
ProcessedFinalHopPacket,
@ -27,6 +26,7 @@ class Node:
mixgossip_channel: MixGossipChannel
reconstructor: MessageReconstructor
broadcast_channel: BroadcastChannel
packet_size: int
def __init__(self, config: NodeConfig, global_config: GlobalConfig):
self.config = config
@ -37,6 +37,11 @@ class Node:
self.reconstructor = MessageReconstructor()
self.broadcast_channel = asyncio.Queue()
sample_packet, _ = PacketBuilder.build_real_packets(
bytes(1), global_config.membership
)[0]
self.packet_size = len(sample_packet.bytes())
async def __process_sphinx_packet(
self, packet: SphinxPacket
) -> SphinxPacket | None:
@ -61,12 +66,15 @@ class Node:
await self.broadcast_channel.put(msg)
def connect(self, peer: Node):
noise_msg = build_msg(MsgType.NOISE, bytes(self.packet_size))
inbound_conn, outbound_conn = asyncio.Queue(), asyncio.Queue()
self.mixgossip_channel.add_conn(
DuplexConnection(
inbound_conn,
MixOutboundConnection(
outbound_conn, self.global_config.transmission_rate_per_sec
outbound_conn,
self.global_config.transmission_rate_per_sec,
noise_msg,
),
)
)
@ -74,7 +82,9 @@ class Node:
DuplexConnection(
outbound_conn,
MixOutboundConnection(
inbound_conn, self.global_config.transmission_rate_per_sec
inbound_conn,
self.global_config.transmission_rate_per_sec,
noise_msg,
),
)
)
@ -163,11 +173,15 @@ class MixOutboundConnection:
queue: NetworkPacketQueue
conn: Connection
transmission_rate_per_sec: int
noise_msg: bytes
def __init__(self, conn: Connection, transmission_rate_per_sec: int):
def __init__(
self, conn: Connection, transmission_rate_per_sec: int, noise_msg: bytes
):
self.queue = asyncio.Queue()
self.conn = conn
self.transmission_rate_per_sec = transmission_rate_per_sec
self.noise_msg = noise_msg
self.task = asyncio.create_task(self.__run())
async def __run(self):
@ -175,7 +189,7 @@ class MixOutboundConnection:
await asyncio.sleep(1 / self.transmission_rate_per_sec)
# TODO: time mixing
if self.queue.empty():
elem = build_noise_packet()
elem = self.noise_msg
else:
elem = self.queue.get_nowait()
await self.conn.put(elem)
@ -197,7 +211,3 @@ def parse_msg(data: bytes) -> tuple[MsgType, bytes]:
if len(data) < 1:
raise ValueError("Invalid message format")
return (MsgType(data[:1]), data[1:])
def build_noise_packet() -> bytes:
return build_msg(MsgType.NOISE, bytes(DEFAULT_PAYLOAD_SIZE))