enable pubsub RED

filecoin-project · Sep 5, 2020 · f83d7d6 · f83d7d6
1 parent 8e0c57f
commit f83d7d6
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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)