| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerStream.java | 52 private final WriteQueue writeQueue; field in NettyServerStream
67 this.writeQueue = state.handler.getWriteQueue(); in NettyServerStream()
99 writeQueue.enqueue( in writeHeaders()
113 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, false), flush) in writeFrameInternal()
138 writeQueue.enqueue( in writeTrailers()
147 writeQueue.enqueue(new CancelServerStreamCommand(transportState(), status), true); in cancel()
|
| D | NettyClientStream.java | 64 private final WriteQueue writeQueue; field in NettyClientStream
90 this.writeQueue = state.handler.getWriteQueue(); in NettyClientStream()
171 writeQueue.enqueue( in writeHeadersInternal()
185 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, endOfStream), flush) in writeFrameInternal()
201 writeQueue.enqueue( in writeFrameInternal()
217 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()
286 when(handler.getWriteQueue()).thenReturn(writeQueue); in createStream()
|
| D | NettyClientStreamTest.java | 156 verify(writeQueue).enqueue(commandCaptor.capture(), eq(true)); in cancelShouldSendCommand()
167 verify(writeQueue).enqueue(commandCaptor.capture(), eq(true)); in deadlineExceededCancelShouldSendCommand()
174 verify(writeQueue).enqueue(isA(CancelClientStreamCommand.class), eq(true)); in cancelShouldStillSendCommandIfStreamNotCreatedToCancelCreation()
184 verify(writeQueue).enqueue( in writeMessageShouldSendRequest()
198 verify(writeQueue).enqueue( in writeMessageShouldSendRequestUnknownLength()
202 verify(writeQueue).enqueue( in writeMessageShouldSendRequestUnknownLength()
273 verify(writeQueue).enqueue(captor.capture(), eq(true)); in inboundTrailersBeforeHalfCloseSendsRstStream()
283 verify(writeQueue, never()).enqueue(isA(CancelClientStreamCommand.class), eq(true)); in inboundTrailersAfterHalfCloseDoesNotSendRstStream()
319 verify(writeQueue).enqueue(isA(CancelClientStreamCommand.class), eq(true)); in invalidInboundHeadersCancelStream()
441 Mockito.reset(writeQueue); in removeUserAgentFromApplicationHeaders()
[all …]
|
| D | NettyStreamTestBase.java | 87 protected WriteQueue writeQueue; field in NettyStreamTestBase
103 when(writeQueue.enqueue(any(QueuedCommand.class), anyBoolean())).thenReturn(completedPromise); in setUp()
162 when(writeQueue.enqueue(any(QueuedCommand.class), anyBoolean())).thenReturn(uncompletedPromise); in shouldBeReadyForDataAfterWritingSmallMessage()
177 when(writeQueue.enqueue(any(QueuedCommand.class), anyBoolean())).thenReturn(uncompletedPromise); in shouldNotBeReadyForDataAfterWritingLargeMessage()
|
| D | NettyHandlerTestBase.java | 99 private WriteQueue writeQueue; field in NettyHandlerTestBase
129 writeQueue = initWriteQueue(); in initChannel()
211 protected final WriteQueue writeQueue() { in writeQueue() method in NettyHandlerTestBase
212 return writeQueue; in writeQueue()
339 ChannelFuture future = writeQueue.enqueue(command, true); in enqueue()
|
| D | NettyClientHandlerTest.java | 388 ChannelFuture future = writeQueue().enqueue( in receivedGoAwayShouldNotAffectRacingQueuedStreamId()
399 ChannelFuture future = writeQueue().enqueue( in receivedAbruptGoAwayShouldFailRacingQueuedStreamid()
431 ChannelFuture future1 = writeQueue().enqueue( in receivedGoAway_shouldFailBufferedStreamsExceedingMaxConcurrentStreams()
433 ChannelFuture future2 = writeQueue().enqueue( in receivedGoAway_shouldFailBufferedStreamsExceedingMaxConcurrentStreams()
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| D | CacheTesting.java | 227 for (ReferenceEntry<?, ?> current : segment.writeQueue) { in checkExpiration()
242 assertTrue(segment.writeQueue.isEmpty()); in checkExpiration()
341 return segment.writeQueue.size();
471 assertTrue(segment.writeQueue.isEmpty());
|
| D | LocalCacheTest.java | 1771 assertFalse(segment.writeQueue.contains(entryOne)); in testReclaimKey()
1939 assertSame(entry, segment.writeQueue.peek()); in testClear()
1944 assertTrue(segment.writeQueue.isEmpty()); in testClear()
1976 assertSame(entry, segment.writeQueue.peek()); in testClear_notification()
1981 assertTrue(segment.writeQueue.isEmpty()); in testClear_notification()
2017 assertFalse(segment.writeQueue.contains(entry)); in testRemoveEntry()
2056 assertFalse(segment.writeQueue.contains(entry)); in testReclaimValue()
2339 assertSameEntries(writeOrder, ImmutableList.copyOf(segment.writeQueue)); in checkEvictionQueues()
2379 for (ReferenceEntry<K, V> e : segment.writeQueue) { in checkExpirationTimes()
2403 segment.writeQueue.add(entry); in testExpireAfterWrite()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/cache/ |
| D | CacheTesting.java | 227 for (ReferenceEntry<?, ?> current : segment.writeQueue) { in checkExpiration()
242 assertTrue(segment.writeQueue.isEmpty()); in checkExpiration()
341 return segment.writeQueue.size();
471 assertTrue(segment.writeQueue.isEmpty());
|
| D | LocalCacheTest.java | 1755 assertFalse(segment.writeQueue.contains(entryOne)); in testReclaimKey()
1887 assertSame(entry, segment.writeQueue.peek()); in testClear()
1892 assertTrue(segment.writeQueue.isEmpty()); in testClear()
1924 assertSame(entry, segment.writeQueue.peek()); in testClear_notification()
1929 assertTrue(segment.writeQueue.isEmpty()); in testClear_notification()
1965 assertFalse(segment.writeQueue.contains(entry)); in testRemoveEntry()
2004 assertFalse(segment.writeQueue.contains(entry)); in testReclaimValue()
2287 assertSameEntries(writeOrder, ImmutableList.copyOf(segment.writeQueue)); in checkEvictionQueues()
2327 for (ReferenceEntry<K, V> e : segment.writeQueue) { in checkExpirationTimes()
2351 segment.writeQueue.add(entry); in testExpireAfterWrite()
[all …]
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| D | vktSynchronizationOperationMultiQueueTests.cpp | 280 const bool writeQueue = checkQueueFlags(it->second.flags, flagsWrite); in getQueuesPairs() local
283 if (!(writeQueue || readQueue)) in getQueuesPairs()
286 if (writeQueue && readQueue) in getQueuesPairs()
291 else if (writeQueue) in getQueuesPairs()
|
| /external/guava/guava/src/com/google/common/cache/ |
| D | LocalCache.java | 1962 final Queue<ReferenceEntry<K, V>> writeQueue; field in LocalCache.Segment
1991 writeQueue = map.usesWriteQueue() ? new WriteQueue<>() : LocalCache.discardingQueue(); in Segment()
2159 writeQueue.remove(e); in lockedGetOrLoad()
2261 writeQueue.remove(e); in compute()
2584 writeQueue.add(entry); in recordWrite()
2626 while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) { in expireEntries()
3247 writeQueue.clear(); in clear()
3271 writeQueue.remove(entry); in removeValueFromChain()
3309 writeQueue.remove(entry); in removeCollectedEntry()
|
| /external/guava/android/guava/src/com/google/common/cache/ |
| D | LocalCache.java | 1958 final Queue<ReferenceEntry<K, V>> writeQueue; field in LocalCache.Segment
1987 writeQueue = map.usesWriteQueue() ? new WriteQueue<>() : LocalCache.discardingQueue(); in Segment()
2155 writeQueue.remove(e); in lockedGetOrLoad()
2494 writeQueue.add(entry); in recordWrite()
2536 while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) { in expireEntries()
3157 writeQueue.clear(); in clear()
3181 writeQueue.remove(entry); in removeValueFromChain()
3219 writeQueue.remove(entry); in removeCollectedEntry()
|