diff options
Diffstat (limited to 'weed/filesys/page_writer/upload_pipeline.go')
| -rw-r--r-- | weed/filesys/page_writer/upload_pipeline.go | 4 |
1 files 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 { |