diff options
Diffstat (limited to 'weed/filer/filechunk_manifest.go')
| -rw-r--r-- | weed/filer/filechunk_manifest.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/weed/filer/filechunk_manifest.go b/weed/filer/filechunk_manifest.go index 3a70e4fa3..8807e3e57 100644 --- a/weed/filer/filechunk_manifest.go +++ b/weed/filer/filechunk_manifest.go @@ -169,19 +169,19 @@ func retriedStreamFetchChunkData(writer io.Writer, urlStrings []string, cipherKe for waitTime := time.Second; waitTime < util.RetryWaitTime; waitTime += waitTime / 2 { for _, urlString := range urlStrings { - var localProcesed int + var localProcessed int shouldRetry, err = util.ReadUrlAsStream(urlString+"?readDeleted=true", cipherKey, isGzipped, isFullChunk, offset, size, func(data []byte) { - if totalWritten > localProcesed { - toBeSkipped := totalWritten - localProcesed + if totalWritten > localProcessed { + toBeSkipped := totalWritten - localProcessed if len(data) <= toBeSkipped { - localProcesed += len(data) + localProcessed += len(data) return // skip if already processed } data = data[toBeSkipped:] - localProcesed += toBeSkipped + localProcessed += toBeSkipped } writer.Write(data) - localProcesed += len(data) + localProcessed += len(data) totalWritten += len(data) }) if !shouldRetry { |