enable pubsub RED

2020-09-07 13:40:48 +03:00
parent 7fdab46729
commit 453ab95e54
1 changed files with 3 additions and 0 deletions
@@ -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)