status-im
/
go-libp2p-daemon
mirror of https://github.com/status-im/go-libp2p-daemon.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

add configuration parameters for gossipsub timing

This commit is contained in:
vyzo 2018-12-07 11:27:33 +02:00
parent e5f5d177fc
commit adb3cdec4f
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
p2pd/main.go
View File

@ -10,6 +10,7 @@ import (
libp2p "github.com/libp2p/go-libp2p" libp2p "github.com/libp2p/go-libp2p"
connmgr "github.com/libp2p/go-libp2p-connmgr" connmgr "github.com/libp2p/go-libp2p-connmgr"
p2pd "github.com/libp2p/go-libp2p-daemon" p2pd "github.com/libp2p/go-libp2p-daemon"
ps "github.com/libp2p/go-libp2p-pubsub"
quic "github.com/libp2p/go-libp2p-quic-transport" quic "github.com/libp2p/go-libp2p-quic-transport"
identify "github.com/libp2p/go-libp2p/p2p/protocol/identify" identify "github.com/libp2p/go-libp2p/p2p/protocol/identify"
) )
@ -34,6 +35,8 @@ func main() {
pubsubRouter := flag.String("pubsubRouter", "gossipsub", "Specifies the pubsub router implementation") pubsubRouter := flag.String("pubsubRouter", "gossipsub", "Specifies the pubsub router implementation")
pubsubSign := flag.Bool("pubsubSign", true, "Enables pubsub message signing") pubsubSign := flag.Bool("pubsubSign", true, "Enables pubsub message signing")
pubsubSignStrict := flag.Bool("pubsubSignStrict", false, "Enables pubsub strict signature verification") pubsubSignStrict := flag.Bool("pubsubSignStrict", false, "Enables pubsub strict signature verification")
gossipsubHeartbeatInterval := flag.Duration("gossipsubHeartbeatInterval", 0, "Specifies the gossipsub heartbeat interval")
gossipsubHeartbeatInitialDelay := flag.Duration("gossipsubHeartbeatInitialDelay", 0, "Specifies the gossipsub initial heartbeat delay")
flag.Parse() flag.Parse()
var opts []libp2p.Option var opts []libp2p.Option
@ -74,6 +77,14 @@ func main() {
} }
if *pubsub { if *pubsub {
if *gossipsubHeartbeatInterval > 0 {
ps.GossipSubHeartbeatInterval = *gossipsubHeartbeatInterval
}
if *gossipsubHeartbeatInitialDelay > 0 {
ps.GossipSubHeartbeatInitialDelay = *gossipsubHeartbeatInitialDelay
}
err = d.EnablePubsub(*pubsubRouter, *pubsubSign, *pubsubSignStrict) err = d.EnablePubsub(*pubsubRouter, *pubsubSign, *pubsubSignStrict)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)