diff options
| author | Chris Lu <chris.lu@uber.com> | 2021-04-04 18:37:56 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@uber.com> | 2021-04-04 18:38:33 -0700 |
| commit | 8251d1140ee8077f6b17d960000928b1d791fd18 (patch) | |
| tree | 1e87cc32357eabf6581054012878509858e5efe9 | |
| parent | 7cf7e05cbbdd24e3708f5370dc57a38859e88795 (diff) | |
| download | seaweedfs-8251d1140ee8077f6b17d960000928b1d791fd18.tar.xz seaweedfs-8251d1140ee8077f6b17d960000928b1d791fd18.zip | |
refactor
| -rw-r--r-- | weed/server/filer_server_handlers_write_upload.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/server/filer_server_handlers_write_upload.go b/weed/server/filer_server_handlers_write_upload.go index 748079d97..28aad8c5a 100644 --- a/weed/server/filer_server_handlers_write_upload.go +++ b/weed/server/filer_server_handlers_write_upload.go @@ -62,7 +62,7 @@ func (fs *FilerServer) uploadReaderToChunks(w http.ResponseWriter, r *http.Reque for readErr == nil { wg.Add(1) - limitedUploadProcessor.Execute(func() { + request := func() { defer wg.Done() var localOffset int64 @@ -105,7 +105,8 @@ func (fs *FilerServer) uploadReaderToChunks(w http.ResponseWriter, r *http.Reque chunk: uploadResult.ToPbFileChunk(fileId, localOffset), } - }) + } + limitedUploadProcessor.Execute(request) } go func() { |