logos-storage/logos-storage-nim-dht
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim-dht.git synced 2026-01-08 00:13:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

add recvFrom to fake DatagramTransport

Browse Source 
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2023-05-10 22:12:56 +02:00
parent cd1303f6c0
commit 3e0c2839b5
No known key found for this signature in database
GPG Key ID: 0FE274EE8C95166E
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
libp2pdht/private/eth/p2p/discoveryv5/transport.nim
View File

@ -37,14 +37,19 @@ when(true): #enable network emulator
proc `$`*(transp: DatagramTransport): string = proc `$`*(transp: DatagramTransport): string =
$transp.local $transp.local
proc recvFrom[T](transp: DatagramTransport, remote: TransportAddress,
msg: sink seq[T], msglen = -1) =
#echo "recv from ", remote
{.gcsafe.}:
transp.ingress.addLast(msg)
# call the callback on remote
asyncCheck transp.callback(transp, remote)
proc sendTo*[T](transp: DatagramTransport, remote: TransportAddress, proc sendTo*[T](transp: DatagramTransport, remote: TransportAddress,
msg: sink seq[T], msglen = -1) {.async.} = msg: sink seq[T], msglen = -1) {.async.} =
#echo "sending to ", remote #echo "sending to ", remote
{.gcsafe.}: {.gcsafe.}:
network[remote.port].ingress.addLast(msg) network[remote.port].recvFrom(transp.local, msg)
# call the callback on remote
asyncCheck network[remote.port].function(network[remote.port], transp.local)
proc getMessage*(t: DatagramTransport,): seq[byte] {. proc getMessage*(t: DatagramTransport,): seq[byte] {.
raises: [Defect, CatchableError].} = raises: [Defect, CatchableError].} =