aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-06-17 13:02:22 -0700
committerChris Lu <chris.lu@gmail.com>2018-06-17 13:02:22 -0700
commitdb0c25b3d8f4bc14c584c381b6fcdf300be4678d (patch)
tree9e2599ec5540668f4d6c9a78c95f24453fa0bd0e
parenteb2acd11c229839cd8e955a70e4c0f61ead53777 (diff)
downloadseaweedfs-db0c25b3d8f4bc14c584c381b6fcdf300be4678d.tar.xz
seaweedfs-db0c25b3d8f4bc14c584c381b6fcdf300be4678d.zip
delete old entry only after successful insert
-rw-r--r--weed/filer2/filer.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/filer2/filer.go b/weed/filer2/filer.go
index cf6b4ba28..53de5bea3 100644
--- a/weed/filer2/filer.go
+++ b/weed/filer2/filer.go
@@ -104,14 +104,14 @@ func (f *Filer) CreateEntry(entry *Entry) error {
}
*/
- if oldEntry, err := f.FindEntry(entry.FullPath); err == nil {
- f.deleteChunks(oldEntry)
- }
+ oldEntry, _ := f.FindEntry(entry.FullPath)
if err := f.store.InsertEntry(entry); err != nil {
return fmt.Errorf("insert entry %s: %v", entry.FullPath, err)
}
+ f.deleteChunks(oldEntry)
+
return nil
}