gitlab-com-seaweedfs/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-01-19 02:48:24 +00:00
Code Issues Projects Releases Wiki Activity

fix https://github.com/chrislusf/seaweedfs/issues/2046

Browse source
This commit is contained in:
Konstantin Lebedev 2021-05-20 13:19:35 +05:00
parent 03d1199d5f
commit 42f631f549
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
weed/filer/stream.go
View file

@ -68,9 +68,12 @@ func StreamContent(masterClient wdclient.HasLookupFileIdFunction, w io.Writer, c
func CheckAllChunkViews(chunkViews []*ChunkView, fileId2Url *map[string][]string, gErr *errgroup.Group) { func CheckAllChunkViews(chunkViews []*ChunkView, fileId2Url *map[string][]string, gErr *errgroup.Group) {
for _, chunkView := range chunkViews { for _, chunkView := range chunkViews {
urlStrings := (*fileId2Url)[chunkView.FileId] urlStrings := (*fileId2Url)[chunkView.FileId]
glog.V(9).Infof("Check chunk: %+v\n url: %v", chunkView, urlStrings) glog.V(9).Infof("Check chunk: %+v\n url: %+v", chunkView, urlStrings)
if !chunkView.IsFullChunk() {
continue
}
gErr.Go(func() error { gErr.Go(func() error {
_, err := retriedFetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, chunkView.IsFullChunk(), chunkView.Offset, int(chunkView.Size)) _, err := retriedFetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, false, 0, 2)
return err return err
}) })
} }