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: rename to sampleDA 

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

8
das/das.nim
View File

@ -130,7 +130,7 @@ when isMainModule:
info "uploaded to DHT", by = 0, pass, time = Moment.now() - startTime
# sample
proc startSampling(n: discv5_protocol.Protocol): seq[Future[DiscResult[seq[byte]]]] =
proc startSamplingDA(n: discv5_protocol.Protocol): seq[Future[DiscResult[seq[byte]]]] =
## Generate random sample and start the sampling process
var futs = newSeq[Future[DiscResult[seq[byte]]]]()
@ -141,10 +141,10 @@ when isMainModule:
futs.add(fut)
return futs
proc sample(n: discv5_protocol.Protocol): Future[(bool, int, Duration)] {.async.} =
proc sampleDA(n: discv5_protocol.Protocol): Future[(bool, int, Duration)] {.async.} =
## Sample and return detailed results of sampling
let startTime = Moment.now()
var futs = startSampling(n)
var futs = startSamplingDA(n)
# test is passed if all segments are retrieved in time
let pass = await allFutures(futs).withTimeout(sampling_timeout)
@ -160,7 +160,7 @@ when isMainModule:
# all nodes start sampling in parallel
var samplings = newSeq[Future[(bool, int, Duration)]]()
for n in 1 ..< nodecount:
samplings.add(sample(nodes[n][0]))
samplings.add(sampleDA(nodes[n][0]))
await allFutures(samplings)
# print statistics