Merge branch 'implicit-subscribe' into devel
This commit is contained in:
commit
4fe49bc6e2
|
@ -228,7 +228,7 @@ when networkBackend in [libp2p, libp2pDaemon]:
|
||||||
await node.start()
|
await node.start()
|
||||||
|
|
||||||
proc checkIfConnectedToBootstrapNode {.async.} =
|
proc checkIfConnectedToBootstrapNode {.async.} =
|
||||||
await sleepAsync(10.seconds)
|
await sleepAsync(30.seconds)
|
||||||
if bootstrapEnrs.len > 0 and libp2p_successful_dials.value == 0:
|
if bootstrapEnrs.len > 0 and libp2p_successful_dials.value == 0:
|
||||||
fatal "Failed to connect to any bootstrap node. Quitting", bootstrapEnrs
|
fatal "Failed to connect to any bootstrap node. Quitting", bootstrapEnrs
|
||||||
quit 1
|
quit 1
|
||||||
|
|
|
@ -192,10 +192,6 @@ proc dialPeer*(node: Eth2Node, peerInfo: PeerInfo) {.async.} =
|
||||||
debug "Initializing connection"
|
debug "Initializing connection"
|
||||||
await initializeConnection(peer)
|
await initializeConnection(peer)
|
||||||
|
|
||||||
# TODO: This should happen automatically in the future in nim-libp2p
|
|
||||||
debug "Subscribing to pubsub"
|
|
||||||
await peer.network.switch.subscribeToPeer(peer.info)
|
|
||||||
|
|
||||||
inc libp2p_successful_dials
|
inc libp2p_successful_dials
|
||||||
debug "Network handshakes completed"
|
debug "Network handshakes completed"
|
||||||
|
|
||||||
|
|
|
@ -1 +1 @@
|
||||||
Subproject commit cb156f3260d35c49b0039ee73c623cdf95658888
|
Subproject commit 6a7f9f058c04ecdfd26e5dbfd8df88221b8511e7
|
Loading…
Reference in New Issue