aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-07-07 20:37:48 -0700
committerChris Lu <chris.lu@gmail.com>2019-07-07 20:37:48 -0700
commit7872fc38ea674223d7568419479ff30fc5a71a13 (patch)
tree9ab070661ebef9431563a177a3b1aafe236b0921
parentfe2882ce7dd6a95dd70be5a1936251b5fb15768e (diff)
downloadseaweedfs-7872fc38ea674223d7568419479ff30fc5a71a13.tar.xz
seaweedfs-7872fc38ea674223d7568419479ff30fc5a71a13.zip
filer leveldb2: correct directory listing
fix https://github.com/chrislusf/seaweedfs/issues/1001
-rw-r--r--weed/filer2/leveldb2/leveldb2_store.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/filer2/leveldb2/leveldb2_store.go b/weed/filer2/leveldb2/leveldb2_store.go
index 4171131c1..bce81e357 100644
--- a/weed/filer2/leveldb2/leveldb2_store.go
+++ b/weed/filer2/leveldb2/leveldb2_store.go
@@ -138,8 +138,9 @@ func (store *LevelDB2Store) ListDirectoryEntries(ctx context.Context, fullpath f
limit int) (entries []*filer2.Entry, err error) {
directoryPrefix, partitionId := genDirectoryKeyPrefix(fullpath, "", store.dbCount)
+ lastFileStart, _ := genDirectoryKeyPrefix(fullpath, startFileName, store.dbCount)
- iter := store.dbs[partitionId].NewIterator(&leveldb_util.Range{Start: directoryPrefix}, nil)
+ iter := store.dbs[partitionId].NewIterator(&leveldb_util.Range{Start: lastFileStart}, nil)
for iter.Next() {
key := iter.Key()
if !bytes.HasPrefix(key, directoryPrefix) {