diff options
| -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 { |