From 2d9af4d01814963517cd5d9e02e13d319c57ed22 Mon Sep 17 00:00:00 2001 From: Ben Guidarelli Date: Tue, 11 Jul 2023 13:55:50 -0400 Subject: [PATCH] Node: Increase subscription buffer size from 32 to 1024 (#3185) --- node/pkg/p2p/p2p.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/node/pkg/p2p/p2p.go b/node/pkg/p2p/p2p.go index d6a5f6e26..92a592549 100644 --- a/node/pkg/p2p/p2p.go +++ b/node/pkg/p2p/p2p.go @@ -248,7 +248,9 @@ func Run( return fmt.Errorf("failed to join topic: %w", err) } - sub, err := th.Subscribe() + // Increase the buffer size to prevent failed delivery + // to slower subscribers + sub, err := th.Subscribe(pubsub.WithBufferSize(1024)) if err != nil { return fmt.Errorf("failed to subscribe topic: %w", err) }