From 36a5093b3aad75f941c748ec80d389e6e1b53cb1 Mon Sep 17 00:00:00 2001
From: Prem Chaitanya Prathi <chaitanyaprem@gmail.com>
Date: Thu, 5 Sep 2024 12:04:33 +0530
Subject: [PATCH] feat: increase outbound q size for pubsub

---
 waku/v2/protocol/relay/config.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/waku/v2/protocol/relay/config.go b/waku/v2/protocol/relay/config.go
index f0f41f80..bc1ea933 100644
--- a/waku/v2/protocol/relay/config.go
+++ b/waku/v2/protocol/relay/config.go
@@ -13,6 +13,10 @@ import (
 
 var DefaultRelaySubscriptionBufferSize int = 1024
 
+// trying to match value here https://github.com/vacp2p/nim-libp2p/pull/1077
+// note that nim-libp2p has 2 peer queues 1 for priority and other non-priority, whereas go-libp2p seems to have single peer-queue
+var DefaultPeerOutboundQSize int = 1024
+
 type RelaySubscribeParameters struct {
 	dontConsume bool
 	cacheSize   uint
@@ -109,6 +113,7 @@ func (w *WakuRelay) defaultPubsubOptions() []pubsub.Option {
 		pubsub.WithSeenMessagesTTL(2 * time.Minute),
 		pubsub.WithPeerScore(w.peerScoreParams, w.peerScoreThresholds),
 		pubsub.WithPeerScoreInspect(w.peerScoreInspector, 6*time.Second),
+		pubsub.WithPeerOutboundQueueSize(DefaultPeerOutboundQSize),
 	}
 }