aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-03-07 12:46:00 -0800
committerChris Lu <chris.lu@gmail.com>2020-03-07 12:46:00 -0800
commit936e7cdbfb02e719058fa341772f2f8afee2a9f1 (patch)
tree1629ab9615f8257c18d557f458f625e82da1c3a4
parent9228ff192cb5c28833cfd4c3a9bb7828924425ee (diff)
downloadseaweedfs-936e7cdbfb02e719058fa341772f2f8afee2a9f1.tar.xz
seaweedfs-936e7cdbfb02e719058fa341772f2f8afee2a9f1.zip
pass in filer.copy cipher option
-rw-r--r--weed/command/filer_copy.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/command/filer_copy.go b/weed/command/filer_copy.go
index fa948249a..50a120875 100644
--- a/weed/command/filer_copy.go
+++ b/weed/command/filer_copy.go
@@ -413,7 +413,7 @@ func (worker *FileCopyWorker) uploadFileInChunks(task FileCopyTask, f *os.File,
replication = assignResult.Replication
}
- uploadResult, err := operation.Upload(targetUrl, fileName+"-"+strconv.FormatInt(i+1, 10), false, io.NewSectionReader(f, i*chunkSize, chunkSize), false, "", nil, security.EncodedJwt(assignResult.Auth))
+ uploadResult, err := operation.Upload(targetUrl, fileName+"-"+strconv.FormatInt(i+1, 10), worker.options.cipher, io.NewSectionReader(f, i*chunkSize, chunkSize), false, "", nil, security.EncodedJwt(assignResult.Auth))
if err != nil {
uploadError = fmt.Errorf("upload data %v to %s: %v\n", fileName, targetUrl, err)
return