diff options
| -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() { |