status-im
/
libp2p-dht
mirror of https://github.com/status-im/libp2p-dht.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

DAS: introduce the sample async procedure 

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

12
das/das.nim
View File

@ -155,9 +155,10 @@ when isMainModule:
futs.add(fut) futs.add(fut)
return futs return futs
for n in 1 ..< nodecount: proc sample(n: discv5_protocol.Protocol): Future[(bool, int, Duration)] {.async.} =
## Sample and return detailed results of sampling
let startTime = Moment.now() let startTime = Moment.now()
var futs = startSampling(nodes[n][0]) var futs = startSampling(n)
# test is passed if all segments are retrieved in time # test is passed if all segments are retrieved in time
let pass = await allFutures(futs).withTimeout(sampling_timeout) let pass = await allFutures(futs).withTimeout(sampling_timeout)
@ -166,7 +167,12 @@ when isMainModule:
if f.finished(): if f.finished():
passcount += 1 passcount += 1
info "sample", by = n, pass, cnt = passcount, time = Moment.now() - startTime let time = Moment.now() - startTime
info "sample", by = n.localNode, pass, cnt = passcount, time
return (pass, passcount, time)
for n in 1 ..< nodecount:
discard await sample(nodes[n][0])
waitfor main() waitfor main()