From 3f7d1d1bf146eaeac3ddcd96e3d8de088bdf97ce Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Tue, 13 Oct 2020 00:29:46 -0700 Subject: Only wait on retryable requests --- weed/replication/repl_util/replication_utli.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'weed/replication') diff --git a/weed/replication/repl_util/replication_utli.go b/weed/replication/repl_util/replication_utli.go index 9b18275b5..42777f4ad 100644 --- a/weed/replication/repl_util/replication_utli.go +++ b/weed/replication/repl_util/replication_utli.go @@ -19,7 +19,7 @@ func CopyFromChunkViews(chunkViews []*filer.ChunkView, filerSource *source.Filer var writeErr error for _, fileUrl := range fileUrls { - err = util.ReadUrlAsStream(fileUrl+"?readDeleted=true", nil, false, chunk.IsFullChunk(), chunk.Offset, int(chunk.Size), func(data []byte) { + _, err = util.ReadUrlAsStream(fileUrl+"?readDeleted=true", nil, false, chunk.IsFullChunk(), chunk.Offset, int(chunk.Size), func(data []byte) { writeErr = writeFunc(data) }) if err != nil { -- cgit v1.2.3