diff options
| -rw-r--r-- | weed/filer/leveldb/leveldb_store_kv.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/weed/filer/leveldb/leveldb_store_kv.go b/weed/filer/leveldb/leveldb_store_kv.go index 7fe1d3356..f686cbf21 100644 --- a/weed/filer/leveldb/leveldb_store_kv.go +++ b/weed/filer/leveldb/leveldb_store_kv.go @@ -3,6 +3,8 @@ package leveldb import ( "context" "fmt" + "github.com/chrislusf/seaweedfs/weed/filer" + "github.com/syndtr/goleveldb/leveldb" ) func (store *LevelDBStore) KvPut(ctx context.Context, key []byte, value []byte) (err error) { @@ -20,6 +22,10 @@ func (store *LevelDBStore) KvGet(ctx context.Context, key []byte) (value []byte, value, err = store.db.Get(key, nil) + if err == leveldb.ErrNotFound { + return nil, filer.ErrKvNotFound + } + if err != nil { return nil, fmt.Errorf("kv get: %v", err) } |