diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-03-07 06:06:58 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-03-07 06:08:08 -0800 |
| commit | ea1169dc8021172a5d14e618b041efb56db98de5 (patch) | |
| tree | c94b032402d2c7726b4992d3621f671d5758482c /weed/operation/upload_content.go | |
| parent | e3b8bf5588835621db05d4572d0960ac7c9d3976 (diff) | |
| download | seaweedfs-ea1169dc8021172a5d14e618b041efb56db98de5.tar.xz seaweedfs-ea1169dc8021172a5d14e618b041efb56db98de5.zip | |
filer cipher: single chunk http POST and PUT and read
Diffstat (limited to 'weed/operation/upload_content.go')
| -rw-r--r-- | weed/operation/upload_content.go | 12 |
1 files changed, 3 insertions, 9 deletions
diff --git a/weed/operation/upload_content.go b/weed/operation/upload_content.go index ba15aea78..884933f18 100644 --- a/weed/operation/upload_content.go +++ b/weed/operation/upload_content.go @@ -69,18 +69,12 @@ func doUpload(uploadUrl string, filename string, cipher bool, reader io.Reader, // encrypt data var cipherKey util.CipherKey var clearDataLen int + var err error if cipher { - clearData, err := ioutil.ReadAll(reader) + cipherKey, reader, clearDataLen, _, err = util.EncryptReader(reader) if err != nil { - return nil, fmt.Errorf("read raw input: %v", err) + return nil, err } - clearDataLen = len(clearData) - cipherKey = util.GenCipherKey() - encryptedData, err := util.Encrypt(clearData, cipherKey) - if err != nil { - return nil, fmt.Errorf("encrypt input: %v", err) - } - reader = bytes.NewReader(encryptedData) } // upload data |