diff options
| author | chrislu <chris.lu@gmail.com> | 2022-01-22 08:11:01 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-01-22 08:11:01 -0800 |
| commit | 18ed06b420780bdbbd8e5d4faf1fe51302895d44 (patch) | |
| tree | d57ed8a919d6e74c8df29ef32608edcd5c896dc9 | |
| parent | 8e80f3cd65112ee3970b74880f2b022356fccdad (diff) | |
| download | seaweedfs-18ed06b420780bdbbd8e5d4faf1fe51302895d44.tar.xz seaweedfs-18ed06b420780bdbbd8e5d4faf1fe51302895d44.zip | |
use memory when under 16 chunks
| -rw-r--r-- | weed/filesys/page_writer/upload_pipeline.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filesys/page_writer/upload_pipeline.go b/weed/filesys/page_writer/upload_pipeline.go index a46c13c4b..47693c235 100644 --- a/weed/filesys/page_writer/upload_pipeline.go +++ b/weed/filesys/page_writer/upload_pipeline.go @@ -62,7 +62,7 @@ func (up *UploadPipeline) SaveDataAt(p []byte, off int64) (n int) { memChunk, found := up.writableChunks[logicChunkIndex] if !found { - if len(up.writableChunks) < 0 { + if len(up.writableChunks) < 16 { memChunk = NewMemChunk(logicChunkIndex, up.ChunkSize) } else { memChunk = up.swapFile.NewTempFileChunk(logicChunkIndex) |