aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-11-26 11:25:56 -0800
committerChris Lu <chris.lu@gmail.com>2020-11-26 11:25:56 -0800
commitcc2bd97ad95ffc22af1d9faaee90a05e6e0fb015 (patch)
tree70e12f552ab6c06cc0b06c771e4d5ab32553e8f7
parent0da7ecfd2925ca1f1f6217235b88c2c9def9d3ef (diff)
downloadseaweedfs-cc2bd97ad95ffc22af1d9faaee90a05e6e0fb015.tar.xz
seaweedfs-cc2bd97ad95ffc22af1d9faaee90a05e6e0fb015.zip
refactor
-rw-r--r--weed/filer/filer_delete_entry.go8
-rw-r--r--weed/filer/filer_deletion.go8
2 files changed, 8 insertions, 8 deletions
diff --git a/weed/filer/filer_delete_entry.go b/weed/filer/filer_delete_entry.go
index 22580dbe4..0848088ef 100644
--- a/weed/filer/filer_delete_entry.go
+++ b/weed/filer/filer_delete_entry.go
@@ -145,3 +145,11 @@ func (f *Filer) doDeleteCollection(collectionName string) (err error) {
})
}
+
+func (f *Filer) maybeDeleteHardLinks(hardLinkIds []HardLinkId) {
+ for _, hardLinkId := range hardLinkIds {
+ if err := f.Store.DeleteHardLink(context.Background(), hardLinkId); err != nil {
+ glog.Errorf("delete hard link id %d : %v", hardLinkId, err)
+ }
+ }
+}
diff --git a/weed/filer/filer_deletion.go b/weed/filer/filer_deletion.go
index b87d88d0b..09af80b42 100644
--- a/weed/filer/filer_deletion.go
+++ b/weed/filer/filer_deletion.go
@@ -1,7 +1,6 @@
package filer
import (
- "context"
"strings"
"time"
@@ -153,10 +152,3 @@ func (f *Filer) deleteChunksIfNotNew(oldEntry, newEntry *Entry) {
f.DeleteChunks(toDelete)
}
-func (f *Filer) maybeDeleteHardLinks(hardLinkIds []HardLinkId) {
- for _, hardLinkId := range hardLinkIds {
- if err := f.Store.DeleteHardLink(context.Background(), hardLinkId); err != nil {
- glog.Errorf("delete hard link id %d : %v", hardLinkId, err)
- }
- }
-}