aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_fs_tree.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-04-29 17:40:08 -0700
committerChris Lu <chris.lu@gmail.com>2020-04-29 17:40:08 -0700
commit9e72e9e4b8d58e0f6f99088f0e449d1c9c55e562 (patch)
tree4b3b24e0bc17b9597010ce18892a5cb8264476d7 /weed/shell/command_fs_tree.go
parented3cf811f576e2dd9fd1c1fb0df967d7fb9e6f1c (diff)
downloadseaweedfs-9e72e9e4b8d58e0f6f99088f0e449d1c9c55e562.tar.xz
seaweedfs-9e72e9e4b8d58e0f6f99088f0e449d1c9c55e562.zip
able to subscribe any topic from any point of time
Diffstat (limited to 'weed/shell/command_fs_tree.go')
-rw-r--r--weed/shell/command_fs_tree.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/shell/command_fs_tree.go b/weed/shell/command_fs_tree.go
index b0752ea03..a8c5b2018 100644
--- a/weed/shell/command_fs_tree.go
+++ b/weed/shell/command_fs_tree.go
@@ -51,10 +51,10 @@ func treeTraverseDirectory(writer io.Writer, filerClient filer_pb.FilerClient, d
prefix.addMarker(level)
- err = filer_pb.ReadDirAllEntries(filerClient, dir, name, func(entry *filer_pb.Entry, isLast bool) {
+ err = filer_pb.ReadDirAllEntries(filerClient, dir, name, func(entry *filer_pb.Entry, isLast bool) error {
if level < 0 && name != "" {
if entry.Name != name {
- return
+ return nil
}
}
@@ -70,7 +70,7 @@ func treeTraverseDirectory(writer io.Writer, filerClient filer_pb.FilerClient, d
} else {
fileCount++
}
-
+ return nil
})
return
}