diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-09-06 16:20:49 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-09-06 16:20:49 -0700 |
| commit | 6923af7280ed341ce90313df5e8eabaaf8e7aa47 (patch) | |
| tree | 57db6d3e15db9b85a966c84a51e78c3b590163e2 /weed/server/webdav_server.go | |
| parent | 64f6532fbeb5e35028a19717186f712a14cbd13e (diff) | |
| download | seaweedfs-6923af7280ed341ce90313df5e8eabaaf8e7aa47.tar.xz seaweedfs-6923af7280ed341ce90313df5e8eabaaf8e7aa47.zip | |
refactoring
Diffstat (limited to 'weed/server/webdav_server.go')
| -rw-r--r-- | weed/server/webdav_server.go | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/weed/server/webdav_server.go b/weed/server/webdav_server.go index 68c1f3233..e99d4a358 100644 --- a/weed/server/webdav_server.go +++ b/weed/server/webdav_server.go @@ -413,7 +413,16 @@ func (f *WebDavFile) saveDataAsChunk(reader io.Reader, name string, offset int64 } fileUrl := fmt.Sprintf("http://%s/%s", host, fileId) - uploadResult, flushErr, _ := operation.Upload(fileUrl, f.name, f.fs.option.Cipher, reader, false, "", nil, auth) + uploadOption := &operation.UploadOption{ + UploadUrl: fileUrl, + Filename: f.name, + Cipher: f.fs.option.Cipher, + IsInputCompressed: false, + MimeType: "", + PairMap: nil, + Jwt: auth, + } + uploadResult, flushErr, _ := operation.Upload(reader, uploadOption) if flushErr != nil { glog.V(0).Infof("upload data %v to %s: %v", f.name, fileUrl, flushErr) return nil, f.collection, f.replication, fmt.Errorf("upload data: %v", flushErr) |