Searched defs:writeQueue (Results 1 – 7 of 7) sorted by relevance
178 type writeQueue struct { struct179 s []FrameWriteRequest182 func (q *writeQueue) empty() bool { return len(q.s) == 0 }184 func (q *writeQueue) push(wr FrameWriteRequest) {188 func (q *writeQueue) shift() FrameWriteRequest {204 func (q *writeQueue) consume(n int32) (FrameWriteRequest, bool) {223 func (p *writeQueuePool) put(q *writeQueue) {
82 protected WriteQueue writeQueue; field in NettyStreamTestBase
95 private WriteQueue writeQueue; field in NettyHandlerTestBase
49 private final WriteQueue writeQueue; field in NettyServerStream
57 private final WriteQueue writeQueue; field in NettyClientStream
163 const bool writeQueue = checkQueueFlags(it->second.flags, flagsWrite); in getQueuesPairs() local
2077 final Queue<ReferenceEntry<K, V>> writeQueue; field in LocalCache.Segment