diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-03-20 23:38:24 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-03-20 23:38:24 -0700 |
| commit | 3505b06023fa82322a614bb303d4aaeae08d228c (patch) | |
| tree | 81b90a3871b15619d363fb3866342ba4169268fc | |
| parent | 4bc19f1e523b50080fca894a469662bd704b2639 (diff) | |
| download | seaweedfs-3505b06023fa82322a614bb303d4aaeae08d228c.tar.xz seaweedfs-3505b06023fa82322a614bb303d4aaeae08d228c.zip | |
report deletion error in the log
| -rw-r--r-- | weed/filer2/filer_deletion.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/filer2/filer_deletion.go b/weed/filer2/filer_deletion.go index 3a64f636e..8c0e159b5 100644 --- a/weed/filer2/filer_deletion.go +++ b/weed/filer2/filer_deletion.go @@ -34,12 +34,15 @@ func (f *Filer) loopProcessingDeletion() { deletionCount = 0 f.fileIdDeletionQueue.Consume(func(fileIds []string) { deletionCount = len(fileIds) - _, err := operation.DeleteFilesWithLookupVolumeId(f.GrpcDialOption, fileIds, lookupFunc) + deleteResults, err := operation.DeleteFilesWithLookupVolumeId(f.GrpcDialOption, fileIds, lookupFunc) if err != nil { glog.V(0).Infof("deleting fileIds len=%d error: %v", deletionCount, err) } else { 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 { |