logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-08 15:53:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

use a configurable variable for direct peer reconnect ticks

Browse Source
This commit is contained in:
vyzo 2020-04-10 13:54:14 +03:00
parent f97d151aec
commit 8e969ba29e
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
gossipsub.go
View File

@ -59,6 +59,10 @@ var (
// timeout for connection attempts // timeout for connection attempts
GossipSubConnectionTimeout = 30 * time.Second GossipSubConnectionTimeout = 30 * time.Second
// Number of heartbeat ticks for attempting to reconnect direct peers that are not
// currently connected
GossipSubDirectConnectTicks uint64 = 300
) )
// NewGossipSub returns a new PubSub object using GossipSubRouter as the router. // NewGossipSub returns a new PubSub object using GossipSubRouter as the router.
@ -983,9 +987,9 @@ func (gs *GossipSubRouter) clearBackoff() {
} }
func (gs *GossipSubRouter) directConnect() { func (gs *GossipSubRouter) directConnect() {
// we donly do this every 150 ticks to allow pending connections to complete and account // we donly do this every some ticks to allow pending connections to complete and account
// for restarts/downtime // for restarts/downtime
if gs.heartbeatTicks%150 != 0 { if gs.heartbeatTicks%GossipSubDirectConnectTicks != 0 {
return return
} }