aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/dir.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-12-12 09:11:10 -0800
committerChris Lu <chris.lu@gmail.com>2019-12-12 09:11:10 -0800
commitd0b423bbc07368bc53a08aec47618924851725a1 (patch)
tree0bf4e88650fda349fd4441f08d802600e1aec708 /weed/filesys/dir.go
parentbf4b13612d48a204646b12e1add74f7f3ec6a34a (diff)
downloadseaweedfs-d0b423bbc07368bc53a08aec47618924851725a1.tar.xz
seaweedfs-d0b423bbc07368bc53a08aec47618924851725a1.zip
filer: increase directory listing pagination size
Diffstat (limited to 'weed/filesys/dir.go')
-rw-r--r--weed/filesys/dir.go5
1 files changed, 2 insertions, 3 deletions
diff --git a/weed/filesys/dir.go b/weed/filesys/dir.go
index 7c19cbe1d..abbc9288e 100644
--- a/weed/filesys/dir.go
+++ b/weed/filesys/dir.go
@@ -214,7 +214,6 @@ func (dir *Dir) ReadDirAll(ctx context.Context) (ret []fuse.Dirent, err error) {
err = dir.wfs.WithFilerClient(ctx, func(client filer_pb.SeaweedFilerClient) error {
- paginationLimit := 1024 * 256
remaining := dir.wfs.option.DirListingLimit
lastEntryName := ""
@@ -224,7 +223,7 @@ func (dir *Dir) ReadDirAll(ctx context.Context) (ret []fuse.Dirent, err error) {
request := &filer_pb.ListEntriesRequest{
Directory: dir.Path,
StartFromFileName: lastEntryName,
- Limit: uint32(paginationLimit),
+ Limit: filer2.PaginationSize,
}
glog.V(4).Infof("read directory: %v", request)
@@ -250,7 +249,7 @@ func (dir *Dir) ReadDirAll(ctx context.Context) (ret []fuse.Dirent, err error) {
remaining -= len(resp.Entries)
- if len(resp.Entries) < paginationLimit {
+ if len(resp.Entries) < filer2.PaginationSize {
break
}