lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-02-09 09:17:28 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

avoid dead loop

Browse Source
This commit is contained in:
Chris Lu
2020-04-09 21:43:26 -07:00
parent 56ec8c4513
commit eb39df2704
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
weed/filesys/dirty_page.go
View File

@@ -130,10 +130,10 @@ func (pages *ContinuousDirtyPages) saveExistingLargestPageToStorage() (chunk *fi
if err == nil { if err == nil {
hasSavedData = true hasSavedData = true
glog.V(3).Infof("%s saveToStorage [%d,%d) %s", pages.f.fullpath(), maxList.Offset(), maxList.Offset()+maxList.Size(), chunk.FileId) glog.V(3).Infof("%s saveToStorage [%d,%d) %s", pages.f.fullpath(), maxList.Offset(), maxList.Offset()+maxList.Size(), chunk.FileId)
time.Sleep(5 * time.Second) return
} else { } else {
glog.V(0).Infof("%s saveToStorage [%d,%d): %v", pages.f.fullpath(), maxList.Offset(), maxList.Offset()+maxList.Size(), err) glog.V(0).Infof("%s saveToStorage [%d,%d): %v", pages.f.fullpath(), maxList.Offset(), maxList.Offset()+maxList.Size(), err)
return time.Sleep(5 * time.Second)
} }
} }