Searched refs:responseQueue (Results 1 – 6 of 6) sorted by relevance
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| D | QueueDispatcher.java | 27 protected final BlockingQueue<MockResponse> responseQueue field in QueueDispatcher
40 if (failFastResponse != null && responseQueue.peek() == null) { in dispatch()
45 return responseQueue.take(); in dispatch()
49 MockResponse peek = responseQueue.peek(); in peek()
56 responseQueue.add(response); in enqueueResponse()
|
| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
| D | QueueDispatcher.java | 29 protected final BlockingQueue<MockResponse> responseQueue = new LinkedBlockingQueue<>(); field in QueueDispatcher
40 if (failFastResponse != null && responseQueue.peek() == null) { in dispatch()
45 return responseQueue.take(); in dispatch()
49 MockResponse peek = responseQueue.peek(); in peek()
56 responseQueue.add(response); in enqueueResponse()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStub.java | 33 private final ArrayBlockingQueue<Optional<HandshakerResp>> responseQueue = field in AltsHandshakerStub
59 if (!responseQueue.isEmpty()) { in send()
63 Optional<HandshakerResp> result = responseQueue.take(); in send()
87 AltsHandshakerStub.this.responseQueue.add(Optional.of(resp)); in onNext()
102 AltsHandshakerStub.this.responseQueue.offer(result); in onError()
111 AltsHandshakerStub.this.responseQueue.offer(result); in onCompleted()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | TestThread.java | 59 private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<>(); field in TestThread
146 assertNull(responseQueue.poll()); in callAndAssertBlocks()
164 assertNull(responseQueue.poll()); in callAndAssertWaits()
206 Response response = responseQueue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in getResponse()
246 responseQueue.put(new Response(request.methodName, null, exception.getTargetException())); in run()
249 responseQueue.put(new Response(request.methodName, null, throwable)); in run()
252 responseQueue.put(new Response(request.methodName, result, null)); in run()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | TestThread.java | 59 private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<>(); field in TestThread
146 assertNull(responseQueue.poll()); in callAndAssertBlocks()
164 assertNull(responseQueue.poll()); in callAndAssertWaits()
206 Response response = responseQueue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in getResponse()
246 responseQueue.put(new Response(request.methodName, null, exception.getTargetException())); in run()
249 responseQueue.put(new Response(request.methodName, null, throwable)); in run()
252 responseQueue.put(new Response(request.methodName, result, null)); in run()
|
| /external/bcc/examples/usdt_sample/usdt_sample_app1/ |
| D | main.cpp | 100 std::queue<std::shared_future<OperationResponse>> responseQueue; in main() local
107 empty = responseQueue.empty(); in main()
115 responseQueue.front().get(); in main()
119 responseQueue.pop(); in main()
136 responseQueue.push(responseFuture); in main()
|