From 4acfc098e9d9e31dbfae9c6b846315b6011cbfdd Mon Sep 17 00:00:00 2001 From: chrislu Date: Sat, 22 Jan 2022 01:43:14 -0800 Subject: [PATCH] re-order --- weed/filesys/page_writer/upload_pipeline.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/weed/filesys/page_writer/upload_pipeline.go b/weed/filesys/page_writer/upload_pipeline.go index 13ee3caec..47664ed55 100644 --- a/weed/filesys/page_writer/upload_pipeline.go +++ b/weed/filesys/page_writer/upload_pipeline.go @@ -15,16 +15,16 @@ type LogicChunkIndex int type UploadPipeline struct { filepath util.FullPath ChunkSize int64 - writers *util.LimitedConcurrentExecutor writableChunks map[LogicChunkIndex]*MemChunk writableChunksLock sync.Mutex sealedChunks map[LogicChunkIndex]*SealedChunk sealedChunksLock sync.Mutex + writers *util.LimitedConcurrentExecutor activeWriterCond *sync.Cond activeWriterCount int32 + saveToStorageFn SaveToStorageFunc activeReadChunks map[LogicChunkIndex]int activeReadChunksLock sync.Mutex - saveToStorageFn SaveToStorageFunc } type SealedChunk struct {