From ab34637c063c0b245aa0561a006ce4d1ba1d086e Mon Sep 17 00:00:00 2001
From: Dmitrii Stepanov <d.stepanov@yadro.com>
Date: Wed, 18 Sep 2024 18:10:32 +0300
Subject: [PATCH] [#9999] evacuate: Add read timeout

Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
---
 go.sum                                      | Bin 42408 -> 42133 bytes
 pkg/local_object_storage/engine/evacuate.go |  23 +++++++++++++++++++-
 2 files changed, 22 insertions(+), 1 deletion(-)

diff --git a/go.sum b/go.sum
index 3a8a710beb941f88aa9276e3d69192c8f2c8de0f..045c4e23ae960078fe401adb4d1eb9e637a3ae0d 100644
GIT binary patch
delta 17
ZcmZ2+nrZ4urU}m`*E5N2=4YC@7ywA|2X+7e

delta 169
zcmbPwl4-?hrU}nnjSNi<jZ91o40X+nO;U|a5|a|m4NVm?46R&UN_;H+y^>Q>Q_I5i
zvvU1>OFT-`OLH6p3yM<w^Rn~&0?K@xjD3RAT_?-4XiPjS>5bhm{q%gj-24=fnWd2i
zj*+>}Re4!aDd`z5d5+oUAs%j?sfJ-W>88epo)w|VrN!n^X`x<|<ybT~o;|S`0Nxrl
A+5i9m

diff --git a/pkg/local_object_storage/engine/evacuate.go b/pkg/local_object_storage/engine/evacuate.go
index 81fe47e65..ea63cf3aa 100644
--- a/pkg/local_object_storage/engine/evacuate.go
+++ b/pkg/local_object_storage/engine/evacuate.go
@@ -7,6 +7,7 @@ import (
 	"strings"
 	"sync"
 	"sync/atomic"
+	"time"
 
 	"git.frostfs.info/TrueCloudLab/frostfs-node/internal/logs"
 	"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/core/object"
@@ -642,7 +643,27 @@ func (e *StorageEngine) evacuateObjects(ctx context.Context, sh *shard.Shard, to
 		var getPrm shard.GetPrm
 		getPrm.SetAddress(addr)
 
-		getRes, err := sh.Get(ctx, getPrm)
+		var getRes shard.GetRes
+		var err error
+		done := make(chan interface{})
+
+		go func() {
+			defer func() {
+				close(done)
+			}()
+
+			getRes, err = sh.Get(ctx, getPrm)
+		}()
+
+		timer := time.NewTimer(30 * time.Second)
+		select {
+		case <-ctx.Done():
+			return ctx.Err()
+		case <-timer.C:
+			err = errors.New("failed to read object by timeout")
+		case <-done:
+		}
+
 		if err != nil {
 			if prm.IgnoreErrors {
 				res.objFailed.Add(1)