diff options
| author | chrislu <chris.lu@gmail.com> | 2024-10-30 20:30:51 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-10-30 20:30:51 -0700 |
| commit | ad6240f066f09eb7cbae9b0df99ab1a2101a6f46 (patch) | |
| tree | 520279d05eac374041dc7cdb500f0644a8ec19cb | |
| parent | 8802843511ef84b6e218076ba7223f3088dac685 (diff) | |
| download | seaweedfs-ad6240f066f09eb7cbae9b0df99ab1a2101a6f46.tar.xz seaweedfs-ad6240f066f09eb7cbae9b0df99ab1a2101a6f46.zip | |
fix parameter
| -rw-r--r-- | weed/server/filer_server_handlers_write_upload.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/filer_server_handlers_write_upload.go b/weed/server/filer_server_handlers_write_upload.go index cb16eadc3..fce2a6413 100644 --- a/weed/server/filer_server_handlers_write_upload.go +++ b/weed/server/filer_server_handlers_write_upload.go @@ -102,12 +102,12 @@ func (fs *FilerServer) uploadReaderToChunks(reader io.Reader, startOffset int64, wg.Add(1) go func(offset int64, buf *bytes.Buffer) { defer func() { - bufPool.Put(bytesBuffer) + bufPool.Put(buf) <-bytesBufferLimitChan wg.Done() }() - chunks, toChunkErr := fs.dataToChunk(fileName, contentType, bytesBuffer.Bytes(), offset, so) + chunks, toChunkErr := fs.dataToChunk(fileName, contentType, buf.Bytes(), offset, so) if toChunkErr != nil { uploadErrLock.Lock() if uploadErr == nil { |