From 5386694a1a7ddbf29f7bebf3454b0184767c1457 Mon Sep 17 00:00:00 2001
From: Denis Kirillov <denis@nspcc.ru>
Date: Mon, 21 Feb 2022 09:13:07 +0300
Subject: [PATCH] [#142] Drop retry for container operations

Signed-off-by: Denis Kirillov <denis@nspcc.ru>
---
 pool/pool.go | 34 ----------------------------------
 1 file changed, 34 deletions(-)

diff --git a/pool/pool.go b/pool/pool.go
index e0639f0..9419357 100644
--- a/pool/pool.go
+++ b/pool/pool.go
@@ -1079,12 +1079,6 @@ func (p *pool) PutContainer(ctx context.Context, cnr *container.Container, opts
 	}
 
 	res, err := cp.client.ContainerPut(ctx, cliPrm)
-
-	if p.checkSessionTokenErr(err, cp.address) && !cfg.isRetry {
-		opts = append(opts, retry())
-		return p.PutContainer(ctx, cnr, opts...)
-	}
-
 	if err != nil { // here err already carries both status and client errors
 		return nil, err
 	}
@@ -1106,12 +1100,6 @@ func (p *pool) GetContainer(ctx context.Context, cid *cid.ID, opts ...CallOption
 	}
 
 	res, err := cp.client.ContainerGet(ctx, cliPrm)
-
-	if p.checkSessionTokenErr(err, cp.address) && !cfg.isRetry {
-		opts = append(opts, retry())
-		return p.GetContainer(ctx, cid, opts...)
-	}
-
 	if err != nil { // here err already carries both status and client errors
 		return nil, err
 	}
@@ -1133,12 +1121,6 @@ func (p *pool) ListContainers(ctx context.Context, ownerID *owner.ID, opts ...Ca
 	}
 
 	res, err := cp.client.ContainerList(ctx, cliPrm)
-
-	if p.checkSessionTokenErr(err, cp.address) && !cfg.isRetry {
-		opts = append(opts, retry())
-		return p.ListContainers(ctx, ownerID, opts...)
-	}
-
 	if err != nil { // here err already carries both status and client errors
 		return nil, err
 	}
@@ -1165,11 +1147,6 @@ func (p *pool) DeleteContainer(ctx context.Context, cid *cid.ID, opts ...CallOpt
 
 	_, err = cp.client.ContainerDelete(ctx, cliPrm)
 
-	if p.checkSessionTokenErr(err, cp.address) && !cfg.isRetry {
-		opts = append(opts, retry())
-		return p.DeleteContainer(ctx, cid, opts...)
-	}
-
 	// here err already carries both status and client errors
 
 	return err
@@ -1189,12 +1166,6 @@ func (p *pool) GetEACL(ctx context.Context, cid *cid.ID, opts ...CallOption) (*e
 	}
 
 	res, err := cp.client.ContainerEACL(ctx, cliPrm)
-
-	if p.checkSessionTokenErr(err, cp.address) && !cfg.isRetry {
-		opts = append(opts, retry())
-		return p.GetEACL(ctx, cid, opts...)
-	}
-
 	if err != nil { // here err already carries both status and client errors
 		return nil, err
 	}
@@ -1217,11 +1188,6 @@ func (p *pool) SetEACL(ctx context.Context, table *eacl.Table, opts ...CallOptio
 
 	_, err = cp.client.ContainerSetEACL(ctx, cliPrm)
 
-	if p.checkSessionTokenErr(err, cp.address) && !cfg.isRetry {
-		opts = append(opts, retry())
-		return p.SetEACL(ctx, table, opts...)
-	}
-
 	// here err already carries both status and client errors
 
 	return err