From 4bbeefd0470b75fc6db41afc9d2487cb4f5f0b98 Mon Sep 17 00:00:00 2001 From: Pavel Karpy Date: Thu, 5 Dec 2024 19:14:41 +0300 Subject: [PATCH] morph: increase buffer for notification handling routines 10 is too low value for practice. It is not mind-blowing to receive tens of notifications per block and, moreover, it was already seen in real networks. Refs #3007. Signed-off-by: Pavel Karpy --- cmd/neofs-node/morph.go | 2 +- pkg/morph/event/listener.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/neofs-node/morph.go b/cmd/neofs-node/morph.go index b03f57955d..cc40c1331a 100644 --- a/cmd/neofs-node/morph.go +++ b/cmd/neofs-node/morph.go @@ -66,7 +66,7 @@ func listenMorphNotifications(c *cfg) { // the client cannot make RPC requests if // the notification channel is not being // read by another goroutine. - const listenerPoolCap = 10 + const listenerPoolCap = 100 lis, err := event.NewListener(event.ListenerParams{ Logger: c.log, diff --git a/pkg/morph/event/listener.go b/pkg/morph/event/listener.go index 02347b44e0..872c607eb9 100644 --- a/pkg/morph/event/listener.go +++ b/pkg/morph/event/listener.go @@ -575,7 +575,7 @@ func NewListener(p ListenerParams) (Listener, error) { // defaultPoolCap is a default worker // pool capacity if it was not specified // via params - const defaultPoolCap = 10 + const defaultPoolCap = 100 switch { case p.Logger == nil: