Searched defs:randomWriteScheduler (Results 1 – 1 of 1) sorted by relevance
17 type randomWriteScheduler struct { struct19 zero writeQueue23 sq map[uint32]*writeQueue26 queuePool writeQueuePool29 func (ws *randomWriteScheduler) OpenStream(streamID uint32, options OpenStreamOptions) {33 func (ws *randomWriteScheduler) CloseStream(streamID uint32) {42 func (ws *randomWriteScheduler) AdjustStream(streamID uint32, priority PriorityParam) {46 func (ws *randomWriteScheduler) Push(wr FrameWriteRequest) {60 func (ws *randomWriteScheduler) Pop() (FrameWriteRequest, bool) {