mirror/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-11-25 19:49:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

error if urls not found

Browse Source
This commit is contained in:
Konstantin Lebedev 2021-03-11 23:34:36 +05:00
parent 4db21012c1
commit 58cdcc6d6e
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
weed/filer/stream.go
View File

@ -26,6 +26,9 @@ func StreamContent(masterClient wdclient.HasLookupFileIdFunction, w io.Writer, c
if err != nil { if err != nil {
glog.V(1).Infof("operation LookupFileId %s failed, err: %v", chunkView.FileId, err) glog.V(1).Infof("operation LookupFileId %s failed, err: %v", chunkView.FileId, err)
return err return err
} else if len(urlStrings) == 0 {
glog.Errorf("operation LookupFileId %s failed, err: urls not found", chunkView.FileId)
return fmt.Errorf("operation LookupFileId %s failed, err: urls not found", chunkView.FileId)
} }
fileId2Url[chunkView.FileId] = urlStrings fileId2Url[chunkView.FileId] = urlStrings
} }
@ -38,12 +41,6 @@ func StreamContent(masterClient wdclient.HasLookupFileIdFunction, w io.Writer, c
if err != nil { if err != nil {
glog.Errorf("read chunk: %v", err) glog.Errorf("read chunk: %v", err)
return fmt.Errorf("read chunk: %v", err) return fmt.Errorf("read chunk: %v", err)
} else if len(data) == 0 {
glog.Errorf("data size zero read chunk: %s", urlStrings)
return fmt.Errorf("data size zero read chunk: %s", urlStrings)
} else if len(chunkViews) == 1 && int64(len(data)) != size {
glog.Errorf("data size not eq %i read chunk: %s", size, urlStrings)
return fmt.Errorf("data size not eq %i read chunk: %s", size, urlStrings)
} }
_, err = w.Write(data) _, err = w.Write(data)