Home
last modified time | relevance | path

Searched refs:writeQueue (Results 1 – 22 of 22) sorted by relevance

/external/syzkaller/vendor/golang.org/x/net/http2/
Dwritesched.go178 type writeQueue struct { struct
182 func (q *writeQueue) empty() bool { return len(q.s) == 0 } argument
184 func (q *writeQueue) push(wr FrameWriteRequest) { argument
188 func (q *writeQueue) shift() FrameWriteRequest { argument
204 func (q *writeQueue) consume(n int32) (FrameWriteRequest, bool) { argument
220 type writeQueuePool []*writeQueue
223 func (p *writeQueuePool) put(q *writeQueue) { argument
232 func (p *writeQueuePool) get() *writeQueue {
235 return new(writeQueue)
Dwritesched_random.go14 return &randomWriteScheduler{sq: make(map[uint32]*writeQueue)}
19 zero writeQueue
23 sq map[uint32]*writeQueue
Dwritesched_priority.go96 q writeQueue // queue of pending frames to write
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerStream.java49 private final WriteQueue writeQueue; field in NettyServerStream
64 this.writeQueue = state.handler.getWriteQueue(); in NettyServerStream()
108 writeQueue.enqueue( in writeHeaders()
119 writeQueue.scheduleFlush(); in writeFrame()
126 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, false), flush) in writeFrame()
143 writeQueue.enqueue( in writeTrailers()
150 writeQueue.enqueue(new CancelServerStreamCommand(transportState(), status), true); in cancel()
DNettyClientStream.java57 private final WriteQueue writeQueue; field in NettyClientStream
81 this.writeQueue = state.handler.getWriteQueue(); in NettyClientStream()
155 writeQueue.enqueue(new CreateStreamCommand(http2Headers, transportState(), get), in writeHeaders()
168 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, endOfStream), flush) in writeFrame()
184 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, endOfStream), flush); in writeFrame()
205 writeQueue.enqueue(new CancelClientStreamCommand(transportState(), status), true); in cancel()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerStreamTest.java111 verify(writeQueue).enqueue(sendHeadersCap.capture(), eq(true)); in writeMessageShouldSendResponse()
122 verify(writeQueue).enqueue( in writeMessageShouldSendResponse()
137 verify(writeQueue).enqueue(sendHeadersCap.capture(), eq(true)); in writeHeadersShouldSendHeaders()
157 verify(writeQueue).enqueue(sendHeadersCap.capture(), eq(true)); in closeBeforeClientHalfCloseShouldSucceed()
185 verify(writeQueue).enqueue(sendHeadersCap.capture(), eq(true)); in closeWithErrorBeforeClientHalfCloseShouldSucceed()
219 verify(writeQueue).enqueue(cmdCap.capture(), eq(true)); in closeAfterClientHalfCloseShouldSucceed()
267 verify(writeQueue).enqueue(cmdCap.capture(), eq(true)); in emptyFramerShouldSendNoPayload()
278 verify(writeQueue).enqueue( in cancelStreamShouldSucceed()
285 when(handler.getWriteQueue()).thenReturn(writeQueue); in createStream()
DNettyClientStreamTest.java153 verify(writeQueue).enqueue(commandCaptor.capture(), eq(true)); in cancelShouldSendCommand()
164 verify(writeQueue).enqueue(commandCaptor.capture(), eq(true)); in deadlineExceededCancelShouldSendCommand()
171 verify(writeQueue).enqueue(isA(CancelClientStreamCommand.class), eq(true)); in cancelShouldStillSendCommandIfStreamNotCreatedToCancelCreation()
181 verify(writeQueue).enqueue( in writeMessageShouldSendRequest()
195 verify(writeQueue).enqueue( in writeMessageShouldSendRequestUnknownLength()
199 verify(writeQueue).enqueue( in writeMessageShouldSendRequestUnknownLength()
270 verify(writeQueue).enqueue(captor.capture(), eq(true)); in inboundTrailersBeforeHalfCloseSendsRstStream()
280 verify(writeQueue, never()).enqueue(isA(CancelClientStreamCommand.class), eq(true)); in inboundTrailersAfterHalfCloseDoesNotSendRstStream()
315 verify(writeQueue).enqueue(isA(CancelClientStreamCommand.class), eq(true)); in invalidInboundHeadersCancelStream()
435 Mockito.reset(writeQueue); in removeUserAgentFromApplicationHeaders()
[all …]
DNettyStreamTestBase.java82 protected WriteQueue writeQueue; field in NettyStreamTestBase
100 when(writeQueue.enqueue(any(QueuedCommand.class), anyBoolean())).thenReturn(completedPromise); in setUp()
166 when(writeQueue.enqueue(any(QueuedCommand.class), anyBoolean())).thenReturn(uncompletedPromise); in shouldBeReadyForDataAfterWritingSmallMessage()
181 when(writeQueue.enqueue(any(QueuedCommand.class), anyBoolean())).thenReturn(uncompletedPromise); in shouldNotBeReadyForDataAfterWritingLargeMessage()
DNettyHandlerTestBase.java95 private WriteQueue writeQueue; field in NettyHandlerTestBase
124 writeQueue = initWriteQueue(); in initChannel()
328 ChannelFuture future = writeQueue.enqueue(command, true); in enqueue()
/external/guava/guava-tests/test/com/google/common/cache/
DCacheTesting.java230 for (ReferenceEntry<?, ?> current : segment.writeQueue) { in checkExpiration()
245 assertTrue(segment.writeQueue.isEmpty()); in checkExpiration()
343 return segment.writeQueue.size();
473 assertTrue(segment.writeQueue.isEmpty());
DLocalCacheTest.java1554 assertFalse(segment.writeQueue.contains(entryOne)); in testReclaimKey()
1684 assertSame(entry, segment.writeQueue.peek()); in testClear()
1689 assertTrue(segment.writeQueue.isEmpty()); in testClear()
1719 assertSame(entry, segment.writeQueue.peek()); in testClear_notification()
1724 assertTrue(segment.writeQueue.isEmpty()); in testClear_notification()
1758 assertFalse(segment.writeQueue.contains(entry)); in testRemoveEntry()
1796 assertFalse(segment.writeQueue.contains(entry)); in testReclaimValue()
2076 assertSameEntries(writeOrder, ImmutableList.copyOf(segment.writeQueue)); in checkEvictionQueues()
2116 for (ReferenceEntry<K, V> e : segment.writeQueue) { in checkExpirationTimes()
2138 segment.writeQueue.add(entry); in testExpireAfterWrite()
[all …]
/external/deqp/external/vulkancts/modules/vulkan/synchronization/
DvktSynchronizationOperationMultiQueueTests.cpp163 const bool writeQueue = checkQueueFlags(it->second.flags, flagsWrite); in getQueuesPairs() local
166 if (!(writeQueue || readQueue)) in getQueuesPairs()
169 if (writeQueue && readQueue) in getQueuesPairs()
174 else if (writeQueue) in getQueuesPairs()
/external/guava/guava/src/com/google/common/cache/
DLocalCache.java2077 final Queue<ReferenceEntry<K, V>> writeQueue; field in LocalCache.Segment
2106 writeQueue = map.usesWriteQueue() in Segment()
2252 writeQueue.remove(e); in lockedGetOrLoad()
2579 writeQueue.add(entry); in recordWrite()
2623 while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) { in expireEntries()
3233 writeQueue.clear(); in clear()
3252 writeQueue.remove(entry); in removeValueFromChain()
3285 writeQueue.remove(entry); in removeCollectedEntry()
/external/owasp/sanitizer/distrib/lib/
Dguava.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...
/external/owasp/sanitizer/lib/guava-libraries/
Dguava.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...
/external/guice/lib/
Dguava-19.0.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META- ...
/external/grpc-grpc-java/netty/shaded/
Dgrpc-netty-shaded-1.14.0.jarMETA-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...
/external/cldr/tools/java/libs/
Dguava.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META- ...
/external/v8/src/inspector/build/closure-compiler/
Dclosure-compiler.jarMETA-INF/MANIFEST.MF META-INF/ com/ com/google/ com/ ...
/external/conscrypt/benchmark-android/
Dvogar.jarMETA-INF/ META-INF/MANIFEST.MF vogar/ vogar/TestProperties.class TestProperties ...
/external/error_prone/error_prone/
Derror_prone_core-2.3.2-with-dependencies.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/services/ META- ...
/external/dagger2/lib/
Dgoogle-java-format-0.1-20151017.042846-2.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...