aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_volume_copy.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-10-24 02:52:56 -0700
committerChris Lu <chris.lu@gmail.com>2021-10-24 02:52:56 -0700
commit5435027ff0906097c312bb1dde126ad03a05fc18 (patch)
treeee1076db4523d7efc77fd65cd6eb6d379b0bc71c /weed/shell/command_volume_copy.go
parent3be3c17f59bc409b15b0dcb687e14c4af10f94c4 (diff)
downloadseaweedfs-5435027ff0906097c312bb1dde126ad03a05fc18.tar.xz
seaweedfs-5435027ff0906097c312bb1dde126ad03a05fc18.zip
volume copy: stream out copying progress and avoid grpc request timeout
fix https://github.com/chrislusf/seaweedfs/issues/2386
Diffstat (limited to 'weed/shell/command_volume_copy.go')
-rw-r--r--weed/shell/command_volume_copy.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/shell/command_volume_copy.go b/weed/shell/command_volume_copy.go
index 8d34acf8f..b4dfbb78a 100644
--- a/weed/shell/command_volume_copy.go
+++ b/weed/shell/command_volume_copy.go
@@ -53,6 +53,6 @@ func (c *commandVolumeCopy) Do(args []string, commandEnv *CommandEnv, writer io.
return fmt.Errorf("source and target volume servers are the same!")
}
- _, err = copyVolume(commandEnv.option.GrpcDialOption, volumeId, sourceVolumeServer, targetVolumeServer, "")
+ _, err = copyVolume(commandEnv.option.GrpcDialOption, writer, volumeId, sourceVolumeServer, targetVolumeServer, "")
return
}