| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerStream.java | 49 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()
|
| D | NettyClientStream.java | 57 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/ |
| D | NettyServerStreamTest.java | 111 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()
|
| D | NettyClientStreamTest.java | 153 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 …]
|
| D | NettyStreamTestBase.java | 82 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()
|
| D | NettyHandlerTestBase.java | 95 private WriteQueue writeQueue; field in NettyHandlerTestBase
124 writeQueue = initWriteQueue(); in initChannel()
328 ChannelFuture future = writeQueue.enqueue(command, true); in enqueue()
|
| /external/perfetto/ui/src/controller/ |
| D | adb.ts | 405 private writeQueue: Uint8Array[] = []; property in AdbStreamImpl
421 if (this.writeQueue.length > 0) {
423 this.writeQueue.length} queued messages due to stream closing.`);
424 this.writeQueue = [];
434 this.writeQueue.push(raw);
468 const queuedMsg = this.writeQueue.shift();
|
| /external/guava/android/guava-tests/test/com/google/common/cache/ |
| D | CacheTesting.java | 228 for (ReferenceEntry<?, ?> current : segment.writeQueue) { in checkExpiration()
243 assertTrue(segment.writeQueue.isEmpty()); in checkExpiration()
342 return segment.writeQueue.size();
472 assertTrue(segment.writeQueue.isEmpty());
|
| D | LocalCacheTest.java | 1681 assertFalse(segment.writeQueue.contains(entryOne)); in testReclaimKey()
1813 assertSame(entry, segment.writeQueue.peek()); in testClear()
1818 assertTrue(segment.writeQueue.isEmpty()); in testClear()
1850 assertSame(entry, segment.writeQueue.peek()); in testClear_notification()
1855 assertTrue(segment.writeQueue.isEmpty()); in testClear_notification()
1891 assertFalse(segment.writeQueue.contains(entry)); in testRemoveEntry()
1930 assertFalse(segment.writeQueue.contains(entry)); in testReclaimValue()
2214 assertSameEntries(writeOrder, ImmutableList.copyOf(segment.writeQueue)); in checkEvictionQueues()
2254 for (ReferenceEntry<K, V> e : segment.writeQueue) { in checkExpirationTimes()
2278 segment.writeQueue.add(entry); in testExpireAfterWrite()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| D | CacheTesting.java | 228 for (ReferenceEntry<?, ?> current : segment.writeQueue) { in checkExpiration()
243 assertTrue(segment.writeQueue.isEmpty()); in checkExpiration()
342 return segment.writeQueue.size();
472 assertTrue(segment.writeQueue.isEmpty());
|
| D | LocalCacheTest.java | 1694 assertFalse(segment.writeQueue.contains(entryOne)); in testReclaimKey()
1862 assertSame(entry, segment.writeQueue.peek()); in testClear()
1867 assertTrue(segment.writeQueue.isEmpty()); in testClear()
1899 assertSame(entry, segment.writeQueue.peek()); in testClear_notification()
1904 assertTrue(segment.writeQueue.isEmpty()); in testClear_notification()
1940 assertFalse(segment.writeQueue.contains(entry)); in testRemoveEntry()
1979 assertFalse(segment.writeQueue.contains(entry)); in testReclaimValue()
2263 assertSameEntries(writeOrder, ImmutableList.copyOf(segment.writeQueue)); in checkEvictionQueues()
2303 for (ReferenceEntry<K, V> e : segment.writeQueue) { in checkExpirationTimes()
2327 segment.writeQueue.add(entry); in testExpireAfterWrite()
[all …]
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| D | vktSynchronizationOperationMultiQueueTests.cpp | 204 const bool writeQueue = checkQueueFlags(it->second.flags, flagsWrite); in getQueuesPairs() local
207 if (!(writeQueue || readQueue)) in getQueuesPairs()
210 if (writeQueue && readQueue) in getQueuesPairs()
215 else if (writeQueue) in getQueuesPairs()
|
| /external/guava/guava/src/com/google/common/cache/ |
| D | LocalCache.java | 1923 final Queue<ReferenceEntry<K, V>> writeQueue; field in LocalCache.Segment
1954 writeQueue = in Segment()
2125 writeQueue.remove(e); in lockedGetOrLoad()
2223 writeQueue.remove(e); in compute()
2547 writeQueue.add(entry); in recordWrite()
2589 while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) { in expireEntries()
3208 writeQueue.clear(); in clear()
3232 writeQueue.remove(entry); in removeValueFromChain()
3270 writeQueue.remove(entry); in removeCollectedEntry()
|
| /external/guava/android/guava/src/com/google/common/cache/ |
| D | LocalCache.java | 1921 final Queue<ReferenceEntry<K, V>> writeQueue; field in LocalCache.Segment
1952 writeQueue = in Segment()
2123 writeQueue.remove(e); in lockedGetOrLoad()
2463 writeQueue.add(entry); in recordWrite()
2505 while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) { in expireEntries()
3124 writeQueue.clear(); in clear()
3148 writeQueue.remove(entry); in removeValueFromChain()
3186 writeQueue.remove(entry); in removeCollectedEntry()
|