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)
|
strWrp := newgRPCClientStream(str, desc, finished, done)
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
defer close(finished)
|
|
||||||
defer close(done)
|
defer close(done)
|
||||||
defer span.End()
|
defer span.End()
|
||||||
|
|
||||||
|
|
|
@ -6,7 +6,6 @@ import (
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
"google.golang.org/grpc/credentials/insecure"
|
"google.golang.org/grpc/credentials/insecure"
|
||||||
"google.golang.org/grpc/keepalive"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
@ -30,9 +29,8 @@ type cfg struct {
|
||||||
}
|
}
|
||||||
|
|
||||||
const (
|
const (
|
||||||
defaultDialTimeout = 5 * time.Second
|
defaultDialTimeout = 5 * time.Second
|
||||||
defaultKeepAliveTimeout = 5 * time.Second
|
defaultRWTimeout = 1 * time.Minute
|
||||||
defaultRWTimeout = 1 * time.Minute
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func (c *cfg) initDefault() {
|
func (c *cfg) initDefault() {
|
||||||
|
@ -41,9 +39,6 @@ func (c *cfg) initDefault() {
|
||||||
c.grpcDialOpts = []grpc.DialOption{
|
c.grpcDialOpts = []grpc.DialOption{
|
||||||
grpc.WithBlock(),
|
grpc.WithBlock(),
|
||||||
grpc.WithTransportCredentials(insecure.NewCredentials()),
|
grpc.WithTransportCredentials(insecure.NewCredentials()),
|
||||||
grpc.WithKeepaliveParams(keepalive.ClientParameters{
|
|
||||||
Timeout: defaultKeepAliveTimeout,
|
|
||||||
}),
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -2,7 +2,7 @@ package signature
|
||||||
|
|
||||||
import "sync"
|
import "sync"
|
||||||
|
|
||||||
const poolSliceMaxSize = 64 * 1024
|
const poolSliceMaxSize = 128 * 1024
|
||||||
|
|
||||||
var buffersPool = sync.Pool{
|
var buffersPool = sync.Pool{
|
||||||
New: func() any {
|
New: func() any {
|
||||||
|
|
Loading…
Reference in a new issue