diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-10-08 23:31:26 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-10-08 23:31:26 -0700 |
| commit | 8d34eb005087f6cb305b8934d8614a88b62cff99 (patch) | |
| tree | 260ac298e35a40052acb6a1d4b094e6a172b54a1 /weed/filer/stream.go | |
| parent | 6e1f936efd5b28ef15c2f3b388f07c34bbdb527b (diff) | |
| download | seaweedfs-8d34eb005087f6cb305b8934d8614a88b62cff99.tar.xz seaweedfs-8d34eb005087f6cb305b8934d8614a88b62cff99.zip | |
mount:exponentially backoff if read error for about 10 minutes
Diffstat (limited to 'weed/filer/stream.go')
| -rw-r--r-- | weed/filer/stream.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/filer/stream.go b/weed/filer/stream.go index e1be18f69..f6e2a7643 100644 --- a/weed/filer/stream.go +++ b/weed/filer/stream.go @@ -33,7 +33,7 @@ func StreamContent(masterClient *wdclient.MasterClient, w io.Writer, chunks []*f urlStrings := fileId2Url[chunkView.FileId] - data, err := fetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, chunkView.IsFullChunk(), chunkView.Offset, int(chunkView.Size)) + data, err := retriedFetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, chunkView.IsFullChunk(), chunkView.Offset, int(chunkView.Size)) if err == nil { return err } @@ -64,7 +64,7 @@ func ReadAll(masterClient *wdclient.MasterClient, chunks []*filer_pb.FileChunk) return nil, err } - data, err := fetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, chunkView.IsFullChunk(), chunkView.Offset, int(chunkView.Size)) + data, err := retriedFetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, chunkView.IsFullChunk(), chunkView.Offset, int(chunkView.Size)) if err != nil { return nil, err } |