vacp2p/nim-libp2p
1
0
Fork 0
mirror of https://github.com/vacp2p/nim-libp2p.git synced 2025-03-01 08:30:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

don't forget to init the proto

Browse Source
This commit is contained in:
Dmitriy Ryajov 2020-02-21 18:01:20 -06:00
parent 8809af9c9d
commit 5d21451d93
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
libp2p/protocols/discovery/bootstrap.nim
View File

@ -30,7 +30,7 @@ type
running: bool running: bool
sentPeers: TimedCache[PeerInfo] sentPeers: TimedCache[PeerInfo]
proc encode(msg: seq[PeerInfo]): ProtoBuffer = proc encode*(msg: seq[PeerInfo]): ProtoBuffer =
result = initProtoBuffer() result = initProtoBuffer()
var peerMsg: ProtoBuffer var peerMsg: ProtoBuffer
for m in msg: for m in msg:
@ -45,7 +45,7 @@ proc encode(msg: seq[PeerInfo]): ProtoBuffer =
result.finish() result.finish()
proc decode(msg: seq[byte]): seq[PeerInfo] = proc decode*(msg: seq[byte]): seq[PeerInfo] =
var pb = initProtoBuffer(msg) var pb = initProtoBuffer(msg)
while pb.enterSubMessage() > 0: while pb.enterSubMessage() > 0:
var pubKey: PublicKey var pubKey: PublicKey
@ -78,12 +78,13 @@ proc newBootstrap*(b: type[Bootstrap],
interval: Duration = DefaultDiscoveryInterval, interval: Duration = DefaultDiscoveryInterval,
peersTimeout: Duration = DefaultPeersTimeout, peersTimeout: Duration = DefaultPeersTimeout,
maxPeers: int = MaxPeers): b = maxPeers: int = MaxPeers): b =
Bootstrap(switch: switch, result = Bootstrap(switch: switch,
bootstrapPeers: bootstrapPeers, bootstrapPeers: bootstrapPeers,
interval: interval, interval: interval,
onNewPeers: onNewPeers, onNewPeers: onNewPeers,
peersTimeout: peersTimeout, peersTimeout: peersTimeout,
maxPeers: maxPeers) maxPeers: maxPeers)
result.init()
proc getNewPeers(b: Bootstrap) {.async.} = proc getNewPeers(b: Bootstrap) {.async.} =
await b.switch.onStarted.wait() # wait for the switch to start await b.switch.onStarted.wait() # wait for the switch to start