aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_fs_meta_notify.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-12-06 22:20:59 -0800
committerChris Lu <chris.lu@gmail.com>2019-12-06 22:20:59 -0800
commitf81d43442b11b0471db00a77ad8bc9b462977474 (patch)
tree1d0ad3566947cd4c9e5ba3a6374490197bdf3c8b /weed/shell/command_fs_meta_notify.go
parentf38f90b7ea546373076c69d3b93069ea8fa46755 (diff)
downloadseaweedfs-f81d43442b11b0471db00a77ad8bc9b462977474.tar.xz
seaweedfs-f81d43442b11b0471db00a77ad8bc9b462977474.zip
filer: speed up filer.meta.save by parallelizing
Diffstat (limited to 'weed/shell/command_fs_meta_notify.go')
-rw-r--r--weed/shell/command_fs_meta_notify.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/shell/command_fs_meta_notify.go b/weed/shell/command_fs_meta_notify.go
index 13b272fbf..4fe0e45a9 100644
--- a/weed/shell/command_fs_meta_notify.go
+++ b/weed/shell/command_fs_meta_notify.go
@@ -50,7 +50,7 @@ func (c *commandFsMetaNotify) Do(args []string, commandEnv *CommandEnv, writer i
var dirCount, fileCount uint64
- err = doTraverse(ctx, writer, client, filer2.FullPath(path), func(parentPath filer2.FullPath, entry *filer_pb.Entry) error {
+ err = doTraverseBFS(ctx, writer, client, filer2.FullPath(path), func(parentPath filer2.FullPath, entry *filer_pb.Entry) error {
if entry.IsDirectory {
dirCount++