aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--weed/filer2/abstract_sql/abstract_sql_store.go5
-rw-r--r--weed/filer2/leveldb/leveldb_store.go5
2 files changed, 8 insertions, 2 deletions
diff --git a/weed/filer2/abstract_sql/abstract_sql_store.go b/weed/filer2/abstract_sql/abstract_sql_store.go
index bfc76fbc0..e924fa16a 100644
--- a/weed/filer2/abstract_sql/abstract_sql_store.go
+++ b/weed/filer2/abstract_sql/abstract_sql_store.go
@@ -79,7 +79,10 @@ func (store *AbstractSqlStore) FindEntry(fullpath filer2.FullPath) (*filer2.Entr
func (store *AbstractSqlStore) DeleteEntry(fullpath filer2.FullPath) (*filer2.Entry, error) {
- entry, _ := store.FindEntry(fullpath)
+ entry, err := store.FindEntry(fullpath)
+ if err != nil {
+ return nil, nil
+ }
dir, name := fullpath.DirAndName()
diff --git a/weed/filer2/leveldb/leveldb_store.go b/weed/filer2/leveldb/leveldb_store.go
index 00fb44d36..8b2df93ac 100644
--- a/weed/filer2/leveldb/leveldb_store.go
+++ b/weed/filer2/leveldb/leveldb_store.go
@@ -96,7 +96,10 @@ func (store *LevelDBStore) FindEntry(fullpath filer2.FullPath) (entry *filer2.En
func (store *LevelDBStore) DeleteEntry(fullpath filer2.FullPath) (entry *filer2.Entry, err error) {
key := genKey(fullpath.DirAndName())
- entry, _ = store.FindEntry(fullpath)
+ entry, err = store.FindEntry(fullpath)
+ if err != nil {
+ return nil, nil
+ }
err = store.db.Delete(key, nil)
if err != nil {