diff --git a/CHANGELOG.md b/CHANGELOG.md index 188effb5a9..ef2c7872b7 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -12,6 +12,7 @@ Changelog for NeoFS Node ### Changed - Local object PUT op with copies number set to 1 is allowed now (#3042) +- 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: