aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_fs_ls.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_ls.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_ls.go')
-rw-r--r--weed/shell/command_fs_ls.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/shell/command_fs_ls.go b/weed/shell/command_fs_ls.go
index 569b3bb9b..36133992f 100644
--- a/weed/shell/command_fs_ls.go
+++ b/weed/shell/command_fs_ls.go
@@ -62,10 +62,10 @@ func (c *commandFsLs) Do(args []string, commandEnv *CommandEnv, writer io.Writer
dir, name := util.FullPath(path).DirAndName()
entryCount := 0
- err = filer_pb.ReadDirAllEntries(commandEnv, util.FullPath(dir), name, func(entry *filer_pb.Entry, isLast bool) {
+ err = filer_pb.ReadDirAllEntries(commandEnv, util.FullPath(dir), name, func(entry *filer_pb.Entry, isLast bool) error {
if !showHidden && strings.HasPrefix(entry.Name, ".") {
- return
+ return nil
}
entryCount++
@@ -100,6 +100,7 @@ func (c *commandFsLs) Do(args []string, commandEnv *CommandEnv, writer io.Writer
fmt.Fprintf(writer, "%s\n", entry.Name)
}
+ return nil
})
if isLongFormat && err == nil {