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

report deletion error in the log

Browse Source
This commit is contained in:
Chris Lu
2020-03-20 23:38:24 -07:00
parent 4bc19f1e52
commit 3505b06023
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
weed/filer2/filer_deletion.go
View File

@@ -34,12 +34,15 @@ func (f *Filer) loopProcessingDeletion() {
deletionCount = 0 deletionCount = 0
f.fileIdDeletionQueue.Consume(func(fileIds []string) { f.fileIdDeletionQueue.Consume(func(fileIds []string) {
deletionCount = len(fileIds) deletionCount = len(fileIds)
_, err := operation.DeleteFilesWithLookupVolumeId(f.GrpcDialOption, fileIds, lookupFunc) deleteResults, err := operation.DeleteFilesWithLookupVolumeId(f.GrpcDialOption, fileIds, lookupFunc)
if err != nil { if err != nil {
glog.V(0).Infof("deleting fileIds len=%d error: %v", deletionCount, err) glog.V(0).Infof("deleting fileIds len=%d error: %v", deletionCount, err)
} else { } else {
glog.V(1).Infof("deleting fileIds len=%d", deletionCount) glog.V(1).Infof("deleting fileIds len=%d", deletionCount)
} }
if len(deleteResults) != deletionCount {
glog.V(0).Infof("delete %d fileIds actual %d", deletionCount, len(deleteResults))
}
}) })
if deletionCount == 0 { if deletionCount == 0 {