diff options
| author | Aleksey Kosov <rusyak777@list.ru> | 2025-05-28 21:34:02 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-05-28 11:34:02 -0700 |
| commit | 283d9e0079d5deb57aefe9a7b30e8b9869ba8685 (patch) | |
| tree | 87b09bebed2ee4afc9c2a4f711ac8598fe2949b7 /weed/operation/submit.go | |
| parent | 62aaaa18f3ea8b7600d28934580dc220ca95164a (diff) | |
| download | seaweedfs-283d9e0079d5deb57aefe9a7b30e8b9869ba8685.tar.xz seaweedfs-283d9e0079d5deb57aefe9a7b30e8b9869ba8685.zip | |
Add context with request (#6824)
Diffstat (limited to 'weed/operation/submit.go')
| -rw-r--r-- | weed/operation/submit.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/weed/operation/submit.go b/weed/operation/submit.go index 9470afced..1efa42b2f 100644 --- a/weed/operation/submit.go +++ b/weed/operation/submit.go @@ -62,7 +62,7 @@ func SubmitFiles(masterFn GetMasterFn, grpcDialOption grpc.DialOption, files []* Ttl: pref.Ttl, DiskType: pref.DiskType, } - ret, err := Assign(masterFn, grpcDialOption, ar) + ret, err := Assign(context.Background(), masterFn, grpcDialOption, ar) if err != nil { for index := range files { results[index].Error = err.Error() @@ -155,7 +155,7 @@ func (fi *FilePart) Upload(maxMB int, masterFn GetMasterFn, usePublicUrl bool, j Ttl: fi.Pref.Ttl, DiskType: fi.Pref.DiskType, } - ret, err = Assign(masterFn, grpcDialOption, ar) + ret, err = Assign(context.Background(), masterFn, grpcDialOption, ar) if err != nil { return } @@ -169,7 +169,7 @@ func (fi *FilePart) Upload(maxMB int, masterFn GetMasterFn, usePublicUrl bool, j Ttl: fi.Pref.Ttl, DiskType: fi.Pref.DiskType, } - ret, err = Assign(masterFn, grpcDialOption, ar) + ret, err = Assign(context.Background(), masterFn, grpcDialOption, ar) if err != nil { // delete all uploaded chunks cm.DeleteChunks(masterFn, usePublicUrl, grpcDialOption) @@ -223,7 +223,7 @@ func (fi *FilePart) Upload(maxMB int, masterFn GetMasterFn, usePublicUrl bool, j return 0, e } - ret, e, _ := uploader.Upload(fi.Reader, uploadOption) + ret, e, _ := uploader.Upload(context.Background(), fi.Reader, uploadOption) if e != nil { return 0, e } @@ -267,7 +267,7 @@ func uploadOneChunk(filename string, reader io.Reader, masterFn GetMasterFn, return 0, uploaderError } - uploadResult, uploadError, _ := uploader.Upload(reader, uploadOption) + uploadResult, uploadError, _ := uploader.Upload(context.Background(), reader, uploadOption) if uploadError != nil { return 0, uploadError } @@ -299,6 +299,6 @@ func uploadChunkedFileManifest(fileUrl string, manifest *ChunkManifest, jwt secu return e } - _, e = uploader.UploadData(buf, uploadOption) + _, e = uploader.UploadData(context.Background(), buf, uploadOption) return e } |