forked from TrueCloudLab/frostfs-api-go
Compare commits
3 commits
master
...
support/v2
Author | SHA1 | Date | |
---|---|---|---|
4cb0068dde | |||
c3f61e7c85 | |||
1d691fed57 |
3 changed files with 3 additions and 9 deletions
|
@ -51,7 +51,6 @@ func NewGRPCStreamClientInterceptor() grpc.StreamClientInterceptor {
|
|||
strWrp := newgRPCClientStream(str, desc, finished, done)
|
||||
|
||||
go func() {
|
||||
defer close(finished)
|
||||
defer close(done)
|
||||
defer span.End()
|
||||
|
||||
|
|
|
@ -6,7 +6,6 @@ import (
|
|||
|
||||
"google.golang.org/grpc"
|
||||
"google.golang.org/grpc/credentials/insecure"
|
||||
"google.golang.org/grpc/keepalive"
|
||||
)
|
||||
|
||||
const (
|
||||
|
@ -31,7 +30,6 @@ type cfg struct {
|
|||
|
||||
const (
|
||||
defaultDialTimeout = 5 * time.Second
|
||||
defaultKeepAliveTimeout = 5 * time.Second
|
||||
defaultRWTimeout = 1 * time.Minute
|
||||
)
|
||||
|
||||
|
@ -41,9 +39,6 @@ func (c *cfg) initDefault() {
|
|||
c.grpcDialOpts = []grpc.DialOption{
|
||||
grpc.WithBlock(),
|
||||
grpc.WithTransportCredentials(insecure.NewCredentials()),
|
||||
grpc.WithKeepaliveParams(keepalive.ClientParameters{
|
||||
Timeout: defaultKeepAliveTimeout,
|
||||
}),
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -2,7 +2,7 @@ package signature
|
|||
|
||||
import "sync"
|
||||
|
||||
const poolSliceMaxSize = 64 * 1024
|
||||
const poolSliceMaxSize = 128 * 1024
|
||||
|
||||
var buffersPool = sync.Pool{
|
||||
New: func() any {
|
||||
|
|
Loading…
Reference in a new issue