diff options
| author | chrislu <chris.lu@gmail.com> | 2022-01-22 01:43:14 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-01-22 01:43:14 -0800 |
| commit | 4acfc098e9d9e31dbfae9c6b846315b6011cbfdd (patch) | |
| tree | 58d16533977f117a3da1a90e47d3d3757da2e87d | |
| parent | e71dcfb3a6dc2e450de6ff9dbd68cf905b3a63ff (diff) | |
| download | seaweedfs-4acfc098e9d9e31dbfae9c6b846315b6011cbfdd.tar.xz seaweedfs-4acfc098e9d9e31dbfae9c6b846315b6011cbfdd.zip | |
re-order
| -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 { |