From 6b648df964c2a9ba36ed4f46cc10fed897dbbcd2 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 --- CHANGELOG.md | 1 + cmd/neofs-node/morph.go | 2 +- pkg/morph/event/listener.go | 2 +- 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 82fe70989a..a2a7343111 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,6 +9,7 @@ Changelog for NeoFS Node - Fail gracefully on error from config validation (#3037) ### Changed +- Number of cuncurrenly handled notifications from the chain was increased from 10 to 100 (#3043) ### Removed 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: