aboutsummaryrefslogtreecommitdiff
path: root/weed/replication
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-03-28 13:41:58 -0700
committerChris Lu <chris.lu@gmail.com>2020-03-28 13:41:58 -0700
commiteedd33dda32e2725c333f25d414231a8c7688485 (patch)
tree7d9b4e1976e45462170a51a899a1cada6c409766 /weed/replication
parent005b4ab3fe57913025865745dc41d67bb3597611 (diff)
downloadseaweedfs-eedd33dda32e2725c333f25d414231a8c7688485.tar.xz
seaweedfs-eedd33dda32e2725c333f25d414231a8c7688485.zip
refactoring
Diffstat (limited to 'weed/replication')
-rw-r--r--weed/replication/sink/filersink/fetch_write.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/replication/sink/filersink/fetch_write.go b/weed/replication/sink/filersink/fetch_write.go
index 07b091073..3c7a36fa0 100644
--- a/weed/replication/sink/filersink/fetch_write.go
+++ b/weed/replication/sink/filersink/fetch_write.go
@@ -100,7 +100,7 @@ func (fs *FilerSink) fetchAndWrite(sourceChunk *filer_pb.FileChunk, dir string)
glog.V(4).Infof("replicating %s to %s header:%+v", filename, fileUrl, header)
// fetch data as is, regardless whether it is encrypted or not
- uploadResult, err := operation.Upload(fileUrl, filename, false, readCloser, "gzip" == header.Get("Content-Encoding"), header.Get("Content-Type"), nil, auth)
+ uploadResult, err, _ := operation.Upload(fileUrl, filename, false, readCloser, "gzip" == header.Get("Content-Encoding"), header.Get("Content-Type"), nil, auth)
if err != nil {
glog.V(0).Infof("upload data %v to %s: %v", filename, fileUrl, err)
return "", fmt.Errorf("upload data: %v", err)