diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-03-24 00:16:12 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-03-24 00:16:12 -0700 |
| commit | 0f10833e0b1485b39f328af10d7a972e1c72601f (patch) | |
| tree | 0ef94005627a15883849fca96ffecf28d18d3fab /weed/shell/command_fs_meta_save.go | |
| parent | 3794f2721f55f17dfb47f5c4291808ab14f6d5f8 (diff) | |
| download | seaweedfs-0f10833e0b1485b39f328af10d7a972e1c72601f.tar.xz seaweedfs-0f10833e0b1485b39f328af10d7a972e1c72601f.zip | |
fix compilation
Diffstat (limited to 'weed/shell/command_fs_meta_save.go')
| -rw-r--r-- | weed/shell/command_fs_meta_save.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/shell/command_fs_meta_save.go b/weed/shell/command_fs_meta_save.go index e10e0dd3a..65d79da94 100644 --- a/weed/shell/command_fs_meta_save.go +++ b/weed/shell/command_fs_meta_save.go @@ -69,7 +69,7 @@ func (c *commandFsMetaSave) Do(args []string, commandEnv *CommandEnv, writer io. } defer dst.Close() - return doTraverseBfsAndSaving(commandEnv, writer, path, *verbose, func(dst io.Writer, outputChan chan []byte) { + return doTraverseBfsAndSaving(commandEnv, writer, path, *verbose, func(outputChan chan []byte) { sizeBuf := make([]byte, 4) for b := range outputChan { util.Uint32toBytes(sizeBuf, uint32(len(b))) @@ -96,7 +96,7 @@ func (c *commandFsMetaSave) Do(args []string, commandEnv *CommandEnv, writer io. } defer dst.Close() - return doTraverseBfsAndSaving(commandEnv, writer, path, *verbose, func(dst io.Writer, outputChan chan []byte) { + return doTraverseBfsAndSaving(commandEnv, writer, path, *verbose, func(outputChan chan []byte) { for b := range outputChan { dst.Write(b) } @@ -117,13 +117,13 @@ func (c *commandFsMetaSave) Do(args []string, commandEnv *CommandEnv, writer io. } -func doTraverseBfsAndSaving(commandEnv *CommandEnv, writer io.Writer, path string, verbose bool, saveFn func(dst io.Writer, outputChan chan []byte), genFn func(entry *filer_pb.FullEntry, outputChan chan []byte) error) error { +func doTraverseBfsAndSaving(commandEnv *CommandEnv, writer io.Writer, path string, verbose bool, saveFn func(outputChan chan []byte), genFn func(entry *filer_pb.FullEntry, outputChan chan []byte) error) error { var wg sync.WaitGroup wg.Add(1) outputChan := make(chan []byte, 1024) go func() { - saveFn(dst, outputChan) + saveFn(outputChan) wg.Done() }() |
