diff --git a/node/modules/lp2p/pubsub.go b/node/modules/lp2p/pubsub.go index 19cd67906..c44d3dab8 100644 --- a/node/modules/lp2p/pubsub.go +++ b/node/modules/lp2p/pubsub.go @@ -277,6 +277,9 @@ func GossipSub(in GossipIn) (service *pubsub.PubSub, err error) { options = append(options, pubsub.WithDirectPeers(directPeerInfo)) } + // validation queue RED + options = append(options, pubsub.WithPeerGater(pubsub.DefaultPeerGaterParams())) + // tracer if in.Cfg.RemoteTracer != "" { a, err := ma.NewMultiaddr(in.Cfg.RemoteTracer)