mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/chrislusf/seaweedfs synced 2024-06-24 11:32:04 +02:00
Code Issues Projects Releases Wiki Activity

clean up

Browse source
This commit is contained in:
Chris Lu 2020-03-08 21:54:47 -07:00
parent 2e3f6ad3a9
commit 3934c69757
1 changed files with 2 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
weed/operation/upload_content.go
View file

@ -158,8 +158,6 @@ func doUpload(uploadUrl string, filename string, cipher bool, reader io.Reader,
}
}
println("data size", clearDataLen)
if cipher {
// encrypt(gzip(data))
@ -170,12 +168,10 @@ func doUpload(uploadUrl string, filename string, cipher bool, reader io.Reader,
err = fmt.Errorf("encrypt input: %v", encryptionErr)
return
}
println("encrypted data size", len(encryptedData))
// upload data
uploadResult, err = upload_content(uploadUrl, func(w io.Writer) (err error) {
n, err := w.Write(encryptedData)
println("writtern data size", n)
_, err = w.Write(encryptedData)
return
}, "", false, "", nil, jwt)
if uploadResult != nil {
@ -187,8 +183,7 @@ func doUpload(uploadUrl string, filename string, cipher bool, reader io.Reader,
} else {
// upload data
uploadResult, err = upload_content(uploadUrl, func(w io.Writer) (err error) {
n, err := w.Write(data)
println("written data size", n)
_, err = w.Write(data)
return
}, filename, contentIsGzipped, mtype, pairMap, jwt)
}