fyrchik/frostfs-sdk-go
1
0
Fork 0
forked from TrueCloudLab/frostfs-sdk-go
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#358] pool: Don't init session with dead node

Browse source 
Signed-off-by: Denis Kirillov <denis@nspcc.ru>
This commit is contained in:
Denis Kirillov 2022-11-08 12:50:23 +03:00 committed by Alex Vanin
parent 2eefdab0e4
commit 5f9d846fb4
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
pool/pool.go
View file

@ -1543,27 +1543,27 @@ func (p *Pool) Dial(ctx context.Context) error {
for i, params := range p.rebalanceParams.nodesParams { for i, params := range p.rebalanceParams.nodesParams {
clients := make([]client, len(params.weights)) clients := make([]client, len(params.weights))
for j, addr := range params.addresses { for j, addr := range params.addresses {
c := p.clientBuilder(addr) clients[j] = p.clientBuilder(addr)
if err := c.dial(ctx); err != nil { if err := clients[j].dial(ctx); err != nil {
if p.logger != nil { if p.logger != nil {
p.logger.Warn("failed to build client", zap.String("address", addr), zap.Error(err)) p.logger.Warn("failed to build client", zap.String("address", addr), zap.Error(err))
} }
continue
} }
var st session.Object var st session.Object
err := initSessionForDuration(ctx, &st, c, p.rebalanceParams.sessionExpirationDuration, *p.key) err := initSessionForDuration(ctx, &st, clients[j], p.rebalanceParams.sessionExpirationDuration, *p.key)
if err != nil { if err != nil {
c.setUnhealthy() clients[j].setUnhealthy()
if p.logger != nil { if p.logger != nil {
p.logger.Warn("failed to create neofs session token for client", p.logger.Warn("failed to create neofs session token for client",
zap.String("address", addr), zap.Error(err)) zap.String("address", addr), zap.Error(err))
} }
} else { continue
atLeastOneHealthy = true
_ = p.cache.Put(formCacheKey(addr, p.key), st)
} }
clients[j] = c _ = p.cache.Put(formCacheKey(addr, p.key), st)
atLeastOneHealthy = true
} }
source := rand.NewSource(time.Now().UnixNano()) source := rand.NewSource(time.Now().UnixNano())
sampl := newSampler(params.weights, source) sampl := newSampler(params.weights, source)