specify topic delivery weights, with priority for blocks

filecoin-project · Sep 5, 2020 · e55b9b4 · e55b9b4
1 parent f83d7d6
commit e55b9b4
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/node/modules/lp2p/pubsub.go b/node/modules/lp2p/pubsub.go
@@ -278,7 +278,12 @@ func GossipSub(in GossipIn) (service *pubsub.PubSub, err error) {
 	}
 
 	// validation queue RED
-	options = append(options, pubsub.WithPeerGater(pubsub.DefaultPeerGaterParams()))
+	options = append(options, pubsub.WithPeerGater(
+		pubsub.DefaultPeerGaterParams().WithTopicDeliveryWeights(map[string]float64{
+			drandTopic:                 5,
+			build.BlocksTopic(in.Nn):   10,
+			build.MessagesTopic(in.Nn): 1,
+		})))
 
 	// tracer
 	if in.Cfg.RemoteTracer != "" {