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-04 06:23:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

upload to DHT in parallel

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

10
das/das.nim
View File

@ -90,6 +90,7 @@ when isMainModule:
blocksize = 16
segmentsize = 10
samplesize = 3
upload_timeout = 5.seconds
sampling_timeout = 5.seconds
var
@ -112,6 +113,9 @@ when isMainModule:
await sleepAsync(chronos.milliseconds(delay_init))
# generate block and push data
info "starting upload to DHT"
let startTime = Moment.now()
var futs = newSeq[Future[seq[Node]]]()
for s in 0 ..< blocksize:
let
segment = segmentData(s, segmentsize)
@ -119,8 +123,10 @@ when isMainModule:
segmentIDs[s] = key
let addedTo = await node0.addValue(key, segment)
debug "Value added to: ", addedTo
futs.add(node0.addValue(key, segment))
let pass = await allFutures(futs).withTimeout(upload_timeout)
info "uploaded to DHT", by = 0, pass, time = Moment.now() - startTime
# sample
for n in 1 ..< nodecount: