aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-08-15 17:06:16 -0700
committerChris Lu <chris.lu@gmail.com>2020-08-15 17:06:16 -0700
commit3e1395b767f1ec4e5c12362342f5a34bde827012 (patch)
treeda630a6d376cb9f0c04836b6d0abc9eb40b7bb52
parenta22ee3059687237dfe4d645313a3907cd5f13fcd (diff)
downloadseaweedfs-3e1395b767f1ec4e5c12362342f5a34bde827012.tar.xz
seaweedfs-3e1395b767f1ec4e5c12362342f5a34bde827012.zip
adjust log message
-rw-r--r--weed/filer2/filer_deletion.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/weed/filer2/filer_deletion.go b/weed/filer2/filer_deletion.go
index a6b229771..2ff9dac63 100644
--- a/weed/filer2/filer_deletion.go
+++ b/weed/filer2/filer_deletion.go
@@ -1,6 +1,7 @@
package filer2
import (
+ "strings"
"time"
"github.com/chrislusf/seaweedfs/weed/glog"
@@ -50,15 +51,14 @@ func (f *Filer) loopProcessingDeletion() {
fileIds = fileIds[:0]
}
deletionCount = len(toDeleteFileIds)
- deleteResults, err := operation.DeleteFilesWithLookupVolumeId(f.GrpcDialOption, toDeleteFileIds, lookupFunc)
+ _, err := operation.DeleteFilesWithLookupVolumeId(f.GrpcDialOption, toDeleteFileIds, lookupFunc)
if err != nil {
- glog.V(0).Infof("deleting fileIds len=%d error: %v", deletionCount, err)
+ if !strings.Contains(err.Error(), "already deleted") {
+ 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))
- }
}
})