diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-11-26 11:21:58 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-11-26 11:21:58 -0800 |
| commit | effa00ed0861a9f6b774e4413a44fd96b6604667 (patch) | |
| tree | df0755246251a29424394e13f210cbed3694f0a3 | |
| parent | 513bcd6e0d3d4a423b4519398e3d1198088f553a (diff) | |
| download | seaweedfs-effa00ed0861a9f6b774e4413a44fd96b6604667.tar.xz seaweedfs-effa00ed0861a9f6b774e4413a44fd96b6604667.zip | |
refactor
| -rw-r--r-- | weed/filer/filer.go | 8 | ||||
| -rw-r--r-- | weed/filer/filer_deletion.go | 9 |
2 files changed, 9 insertions, 8 deletions
diff --git a/weed/filer/filer.go b/weed/filer/filer.go index 5510645cd..2dec1afbf 100644 --- a/weed/filer/filer.go +++ b/weed/filer/filer.go @@ -317,11 +317,3 @@ func (f *Filer) Shutdown() { f.LocalMetaLogBuffer.Shutdown() f.Store.Shutdown() } - -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 9eee38277..b87d88d0b 100644 --- a/weed/filer/filer_deletion.go +++ b/weed/filer/filer_deletion.go @@ -1,6 +1,7 @@ package filer import ( + "context" "strings" "time" @@ -151,3 +152,11 @@ 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) + } + } +} |
