Github-Mirror/seaweedfs
1
0 Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-10-11 00:37:52 +02:00
Code Issues Packages Projects Releases Wiki Activity

Only wait on retryable requests

Browse Source
This commit is contained in:
Chris Lu committed 2020-10-13 00:29:46 -07:00
1 parent b18f21cce1
commit 3f7d1d1bf1
6 files changed
+34 -24
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

weed/replication/repl_util/replication_utli.go
+1 -1
View File
@@ -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 {