mirror of
https://github.com/waku-org/nwaku.git
synced 2025-01-13 16:25:00 +00:00
Fails with SIGSERV
This commit is contained in:
parent
5e50c6a225
commit
550556bb97
@ -44,8 +44,8 @@ proc newStandardSwitch*(privKey = none(PrivateKey),
|
|||||||
# XXX: Hacky test, hijacking WakuSub here
|
# XXX: Hacky test, hijacking WakuSub here
|
||||||
# XXX: If I use WakuSub here I get a SIGSERV
|
# XXX: If I use WakuSub here I get a SIGSERV
|
||||||
#echo "Using WakuSub here"
|
#echo "Using WakuSub here"
|
||||||
PubSub newPubSub(FloodSub, peerInfo, triggerSelf)
|
#PubSub newPubSub(FloodSub, peerInfo, triggerSelf)
|
||||||
#PubSub newPubSub(WakuSub, peerInfo, triggerSelf)
|
PubSub newPubSub(WakuSub, peerInfo, triggerSelf)
|
||||||
|
|
||||||
result = newSwitch(peerInfo,
|
result = newSwitch(peerInfo,
|
||||||
transports,
|
transports,
|
||||||
|
@ -29,7 +29,8 @@ proc waitSub(sender, receiver: auto; key: string) {.async, gcsafe.} =
|
|||||||
# turn things deterministic
|
# turn things deterministic
|
||||||
# this is for testing purposes only
|
# this is for testing purposes only
|
||||||
var ceil = 15
|
var ceil = 15
|
||||||
let fsub = cast[FloodSub](sender.pubSub.get())
|
#echo "isa thing", repr(sender.pubSub.get())
|
||||||
|
let fsub = cast[WakuSub](sender.pubSub.get())
|
||||||
while not fsub.floodsub.hasKey(key) or
|
while not fsub.floodsub.hasKey(key) or
|
||||||
not fsub.floodsub[key].contains(receiver.peerInfo.id):
|
not fsub.floodsub[key].contains(receiver.peerInfo.id):
|
||||||
await sleepAsync(100.millis)
|
await sleepAsync(100.millis)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user