From dcb6c244c803f17ccf60ee03929462c7d6e0a83f Mon Sep 17 00:00:00 2001 From: Csaba Kiraly Date: Thu, 11 May 2023 01:36:24 +0200 Subject: [PATCH] generalize p2p delay Signed-off-by: Csaba Kiraly --- libp2pdht/private/eth/p2p/discoveryv5/transport.nim | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/libp2pdht/private/eth/p2p/discoveryv5/transport.nim b/libp2pdht/private/eth/p2p/discoveryv5/transport.nim index 080cc82..ebf3451 100644 --- a/libp2pdht/private/eth/p2p/discoveryv5/transport.nim +++ b/libp2pdht/private/eth/p2p/discoveryv5/transport.nim @@ -45,10 +45,13 @@ when(true): #enable network emulator # call the callback on remote asyncCheck transp.callback(transp, remote) + proc getLatency(src: TransportAddress, dst: TransportAddress) : Duration = + 50.milliseconds + proc sendTo*[T](transp: DatagramTransport, remote: TransportAddress, msg: sink seq[T], msglen = -1) {.async.} = #echo "sending to ", remote - await sleepAsync(50.milliseconds) + await sleepAsync(getLatency(transp.local, remote)) {.gcsafe.}: network[remote.port].recvFrom(transp.local, msg)