specify topic delivery weights, with priority for blocks

2020-09-05 23:46:49 +03:00 · 2020-09-05 23:46:49 +03:00 · c616958557
commit c616958557
parent 453ab95e54
1 changed files with 6 additions and 1 deletions
--- 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 != "" {