diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-03-08 21:39:33 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-03-08 21:39:33 -0700 |
| commit | 2e3f6ad3a97bc7fad349e63289695547f92c1f8b (patch) | |
| tree | 036cbe846cb6387a3a22cc0a19a1d6d770b061e7 /weed/server/webdav_server.go | |
| parent | 5ac6297c685a3bd6c9b8a3d0f2328dde01f7013a (diff) | |
| download | seaweedfs-2e3f6ad3a97bc7fad349e63289695547f92c1f8b.tar.xz seaweedfs-2e3f6ad3a97bc7fad349e63289695547f92c1f8b.zip | |
filer: remember content is gzipped or not
Diffstat (limited to 'weed/server/webdav_server.go')
| -rw-r--r-- | weed/server/webdav_server.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/weed/server/webdav_server.go b/weed/server/webdav_server.go index 9451fdf99..1fb0912c5 100644 --- a/weed/server/webdav_server.go +++ b/weed/server/webdav_server.go @@ -1,7 +1,6 @@ package weed_server import ( - "bytes" "context" "fmt" "io" @@ -418,8 +417,7 @@ func (f *WebDavFile) Write(buf []byte) (int, error) { } fileUrl := fmt.Sprintf("http://%s/%s", host, fileId) - bufReader := bytes.NewReader(buf) - uploadResult, err := operation.Upload(fileUrl, f.name, f.fs.option.Cipher, bufReader, false, "", nil, auth) + uploadResult, err := operation.UploadData(fileUrl, f.name, f.fs.option.Cipher, buf, false, "", nil, auth) if err != nil { glog.V(0).Infof("upload data %v to %s: %v", f.name, fileUrl, err) return 0, fmt.Errorf("upload data: %v", err) @@ -436,6 +434,7 @@ func (f *WebDavFile) Write(buf []byte) (int, error) { Mtime: time.Now().UnixNano(), ETag: uploadResult.ETag, CipherKey: uploadResult.CipherKey, + IsGzipped: uploadResult.Gzip > 0, } f.entry.Chunks = append(f.entry.Chunks, chunk) |