cache: Pre-allocated buffer for SDK client

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

cmd/neofs-node/config.go

@@ -84,6 +84,9 @@ const maxMsgSize = 4 << 20 // transport msg limit 4 MiB
 // for each contract listener.
 const notificationHandlerPoolSize = 10
 
+// max GRPC message size.
+const defaultBufferSize = 4 * 1024 * 1024 // 4MB
+
 // applicationConfiguration reads and stores component-specific configuration
 // values. It should not store any application helpers structs (pointers to shared
 // structs).
@@ -545,11 +548,18 @@ func initCfg(appCfg *config.Config) *cfg {
 	)
 	fatalOnErr(err)
 
+	var buffers sync.Pool
+	buffers.New = func() any {
+		b := make([]byte, defaultBufferSize)
+		return &b
+	}
+
 	cacheOpts := cache.ClientCacheOpts{
 		DialTimeout:      apiclientconfig.DialTimeout(appCfg),
 		StreamTimeout:    apiclientconfig.StreamTimeout(appCfg),
 		AllowExternal:    apiclientconfig.AllowExternal(appCfg),
 		ReconnectTimeout: apiclientconfig.ReconnectTimeout(appCfg),
+		Buffers:          &buffers,
 	}
 	c.shared = shared{
 		key:            key,

pkg/network/cache/client.go

@@ -23,6 +23,7 @@ type (
 		ReconnectTimeout time.Duration
 		ResponseCallback func(client.ResponseMetaInfo) error
 		AllowExternal    bool
+		Buffers          *sync.Pool
 	}
 )
 

pkg/network/cache/multi.go

@@ -58,6 +58,8 @@ func (x *multiClient) createForAddress(addr network.Address) (clientcore.Client,
 		prmDial client.PrmDial
 	)
 
+	prmInit.SetSignMessageBuffers(x.opts.Buffers)
+
 	prmDial.SetServerURI(addr.URIAddr())
 
 	if x.opts.DialTimeout > 0 {