From 46e4e1fc4d77345a1c49cbd767945357b32606f4 Mon Sep 17 00:00:00 2001 From: Roman Khimov Date: Tue, 24 Dec 2024 22:45:31 +0300 Subject: [PATCH] ir: increase fschain pool size Similar to 19c72bfe0b5d322e4de8019df5c1431af35ca5f6, but for IR. We've got neofs-ir[1394797]: warn event/listener.go:248 listener worker pool drained {"chain": "fschain", "capacity": 10} in testnet. Signed-off-by: Roman Khimov --- CHANGELOG.md | 1 + pkg/innerring/innerring.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index a36c625601..bc642e9e9c 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,6 +9,7 @@ Changelog for NeoFS Node ### Fixed ### Changed +- Number of cuncurrenly handled notifications from the chain was increased from 10 to 300 for IR (#3068) ### Removed diff --git a/pkg/innerring/innerring.go b/pkg/innerring/innerring.go index 51a7e014b5..efc6f3c7d0 100644 --- a/pkg/innerring/innerring.go +++ b/pkg/innerring/innerring.go @@ -1067,7 +1067,7 @@ func createListener(cli *client.Client, p chainParams) (event.Listener, error) { // the client cannot make RPC requests if // the notification channel is not being // read by another goroutine. - const listenerPoolCap = 10 + const listenerPoolCap = 300 listener, err := event.NewListener(event.ListenerParams{ Logger: p.log.With(zap.String("chain", p.name)),