innerring: Pre-allocated buffer for SDK client

Signed-off-by: Evgenii Baidakov <evgenii@nspcc.io>

pkg/innerring/innerring.go

@@ -7,6 +7,7 @@ import (
 	"fmt"
 	"io"
 	"net"
+	"sync"
 	"sync/atomic"
 
 	"github.com/nspcc-dev/neo-go/pkg/core/block"
@@ -57,6 +58,9 @@ import (
 	"google.golang.org/grpc"
 )
 
+// max GRPC message size.
+const defaultBufferSize = 4 * 1024 * 1024 // 4MB
+
 type (
 	// Server is the inner ring application structure that contains all event
 	// processors, shared variables and event handlers.
@@ -593,13 +597,20 @@ func New(ctx context.Context, log *zap.Logger, cfg *viper.Viper, errChan chan<-
 		cfg.GetDuration("indexer.cache_timeout"),
 	)
 
+	var buffers sync.Pool
+	buffers.New = func() any {
+		b := make([]byte, defaultBufferSize)
+		return &b
+	}
+
 	clientCache := newClientCache(&clientCacheParams{
 		Log:           log,
 		Key:           &server.key.PrivateKey,
 		SGTimeout:     cfg.GetDuration("audit.timeout.get"),
 		HeadTimeout:   cfg.GetDuration("audit.timeout.head"),
 		RangeTimeout:  cfg.GetDuration("audit.timeout.rangehash"),
 		AllowExternal: cfg.GetBool("audit.allow_external"),
+		Buffers:       &buffers,
 	})
 
 	server.registerNoErrCloser(clientCache.cache.CloseAll)

pkg/innerring/rpc.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/ecdsa"
 	"fmt"
+	"sync"
 	"time"
 
 	clientcore "github.com/nspcc-dev/neofs-node/pkg/core/client"
@@ -40,13 +41,15 @@ type (
 		AllowExternal bool
 
 		SGTimeout, HeadTimeout, RangeTimeout time.Duration
+
+		Buffers *sync.Pool
 	}
 )
 
 func newClientCache(p *clientCacheParams) *ClientCache {
 	return &ClientCache{
 		log:          p.Log,
-		cache:        cache.NewSDKClientCache(cache.ClientCacheOpts{AllowExternal: p.AllowExternal}),
+		cache:        cache.NewSDKClientCache(cache.ClientCacheOpts{AllowExternal: p.AllowExternal, Buffers: p.Buffers}),
 		key:          p.Key,
 		sgTimeout:    p.SGTimeout,
 		headTimeout:  p.HeadTimeout,