| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DispatcherTest.java | 44 client.newCall(newRequest("http://a/1")).enqueue(callback); in enqueuedJobsRunImmediately()
50 client.newCall(newRequest("http://a/1")).enqueue(callback); in maxRequestsEnforced()
51 client.newCall(newRequest("http://a/2")).enqueue(callback); in maxRequestsEnforced()
52 client.newCall(newRequest("http://b/1")).enqueue(callback); in maxRequestsEnforced()
53 client.newCall(newRequest("http://b/2")).enqueue(callback); in maxRequestsEnforced()
59 client.newCall(newRequest("http://a/1")).enqueue(callback); in maxPerHostEnforced()
60 client.newCall(newRequest("http://a/2")).enqueue(callback); in maxPerHostEnforced()
61 client.newCall(newRequest("http://a/3")).enqueue(callback); in maxPerHostEnforced()
67 client.newCall(newRequest("http://a/1")).enqueue(callback); in increasingMaxRequestsPromotesJobsImmediately()
68 client.newCall(newRequest("http://b/1")).enqueue(callback); in increasingMaxRequestsPromotesJobsImmediately()
[all …]
|
| D | ConnectionReuseTest.java | 125 Response response = client.newCall(request).execute(); in connectionsReusedWithRedirectEvenIfPoolIsSizeZero()
143 Response response = client.newCall(request).execute(); in connectionsNotReusedWithRedirectIfDiscardingResponseIsSlow()
158 Response responseA = client.newCall(request).execute(); in silentRetryWhenIdempotentRequestFailsOnReusedConnection()
162 Response responseB = client.newCall(request).execute(); in silentRetryWhenIdempotentRequestFailsOnReusedConnection()
176 Response responseA = client.newCall(requestA).execute(); in staleConnectionNotReusedForNonIdempotentRequest()
184 Response responseB = client.newCall(requestB).execute(); in staleConnectionNotReusedForNonIdempotentRequest()
197 Response response1 = client.newCall(request).execute(); in http2ConnectionsAreSharedBeforeResponseIsConsumed()
198 Response response2 = client.newCall(request).execute(); in http2ConnectionsAreSharedBeforeResponseIsConsumed()
214 Response response1 = client.newCall(request).execute(); in connectionsAreEvicted()
220 Response response2 = client.newCall(request).execute(); in connectionsAreEvicted()
[all …]
|
| D | InterceptorTest.java | 74 Response response = client.newCall(request).execute(); in applicationInterceptorsCanShortCircuitResponses()
99 client.newCall(request).execute(); in networkInterceptorsCannotShortCircuitResponses()
124 client.newCall(request).execute(); in networkInterceptorsCannotCallProceedMultipleTimes()
152 client.newCall(request).execute(); in networkInterceptorsCannotChangeServerAddress()
174 client.newCall(request).execute(); in networkInterceptorsHaveConnectionAccess()
208 Response response = client.newCall(request).execute(); in networkInterceptorsObserveNetworkHeaders()
235 client.newCall(request).execute(); in networkInterceptorsCanChangeRequestMethodFromGetToPost()
269 client.newCall(request).execute(); in rewriteRequestToServer()
305 Response response = client.newCall(request).execute(); in rewriteResponseFromServer()
349 Response response = client.newCall(request).execute(); in multipleInterceptors()
[all …]
|
| D | CallTest.java | 383 Response response = client.newCall(request).execute(); in postBodyRetransmittedAfterAuthorizationFail()
421 client.newCall(new Request.Builder().url(server.url("/0")).build()).execute(); in doesNotAttemptAuthorization21Times()
573 Call call = client.newCall(request); in illegalToExecuteTwice()
604 Call call = client.newCall(request); in illegalToExecuteTwice_Async()
633 client.newCall(request).enqueue(callback); in get_Async()
650 client.newCall(request).enqueue(new Callback() { in exceptionThrownByOnResponseIsRedactedAndLogged()
688 client.newCall(new Request.Builder().url(server.url("/a")).build()).enqueue(callback); in connectionPooling_Async()
691 client.newCall(new Request.Builder().url(server.url("/b")).build()).enqueue(callback); in connectionPooling_Async()
694 client.newCall(new Request.Builder().url(server.url("/c")).build()).enqueue(callback); in connectionPooling_Async()
707 client.newCall(request).enqueue(new Callback() { in connectionReuseWhenResponseBodyConsumed_Async()
[all …]
|
| D | CacheTest.java | 178 Response response = client.newCall(request).execute(); in assertCached()
220 Response response1 = client.newCall(request).execute(); in testResponseCaching()
231 Response response2 = client.newCall(request).execute(); in testResponseCaching()
257 Response response1 = client.newCall(request).execute(); in secureResponseCaching()
268 Response response2 = client.newCall(request).execute(); // Cached! in secureResponseCaching()
296 Response response1 = client.newCall(request).execute(); in responseCachingAndRedirects()
299 Response response2 = client.newCall(request).execute(); // Cached! in responseCachingAndRedirects()
318 Response response1 = client.newCall(request1).execute(); in redirectToCachedResult()
325 Response response2 = client.newCall(request2).execute(); in redirectToCachedResult()
333 Response response3 = client.newCall(request3).execute(); in redirectToCachedResult()
[all …]
|
| D | SocksProxyTest.java | 55 Response response1 = client.newCall(request1).execute(); in proxy()
59 Response response2 = client.newCall(request2).execute(); in proxy()
83 Response response = client.newCall(request).execute(); in proxySelector()
102 Response response1 = client.newCall(request).execute(); in checkRemoteDNSResolve()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ClientInterceptorsTest.java | 68 when(channel.newCall( in setUp()
100 assertSame(call, intercepted.newCall(method, callOptions)); in channelAndInterceptorCalled()
101 verify(channel).newCall(same(method), same(callOptions)); in channelAndInterceptorCalled()
105 assertSame(call, intercepted.newCall(method, callOptions)); in channelAndInterceptorCalled()
106 verify(channel, times(2)).newCall(same(method), same(callOptions)); in channelAndInterceptorCalled()
121 assertSame(call, next.newCall(method, callOptions)); in callNextTwice()
122 return next.newCall(method, callOptions); in callNextTwice()
126 assertSame(call, intercepted.newCall(method, CallOptions.DEFAULT)); in callNextTwice()
127 verify(channel, times(2)).newCall(same(method), same(CallOptions.DEFAULT)); in callNextTwice()
137 public <ReqT, RespT> ClientCall<ReqT, RespT> newCall( in ordered()
[all …]
|
| /external/okhttp/okhttp-logging-interceptor/src/test/java/com/squareup/okhttp/logging/ |
| D | HttpLoggingInterceptorTest.java | 101 client.newCall(request().build()).execute(); in none()
111 client.newCall(request().build()).execute(); in basicGet()
128 client.newCall(request().post(RequestBody.create(PLAIN, "Hi?")).build()).execute(); in basicPost()
147 Response response = client.newCall(request().build()).execute(); in basicResponseBody()
165 Response response = client.newCall(request().build()).execute(); in headersGet()
198 Response response = client.newCall(request).execute(); in headersPost()
235 Response response = client.newCall(request).execute(); in headersPostNoContentType()
278 Response response = client.newCall(request().post(body).build()).execute(); in headersPostNoLength()
315 Response response = client.newCall(request().build()).execute(); in headersResponseBody()
349 Response response = client.newCall(request().build()).execute(); in bodyGet()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplIdlenessTest.java | 178 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in newCallExitsIdleness()
193 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in newCallRefreshesIdlenessTimer()
207 call = channel.newCall(method, CallOptions.DEFAULT); in newCallRefreshesIdlenessTimer()
230 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in delayedTransportHoldsOffIdleness()
255 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in realTransportsHoldsOffIdleness()
299 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in updateSubchannelAddresses_newAddressConnects()
319 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in updateSubchannelAddresses_existingAddressDoesNotConnect()
341 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in oobTransportDoesNotAffectIdleness()
368 ClientCall<String, Integer> oobCall = oob.newCall(method, CallOptions.DEFAULT); in oobTransportDoesNotAffectIdleness()
389 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in updateOobChannelAddresses_newAddressConnects()
[all …]
|
| D | ServiceConfigInterceptorTest.java | 100 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in withWaitForReady()
108 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in handleUpdateNotCalledBeforeInterceptCall()
126 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in withMaxRequestSize()
141 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in withMaxRequestSize_pickSmallerExisting()
156 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in withMaxRequestSize_pickSmallerNew()
170 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in withMaxResponseSize()
185 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in withMaxResponseSize_pickSmallerExisting()
200 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in withMaxResponseSize_pickSmallerNew()
214 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in withoutWaitForReady()
233 verify(channel).newCall(eq(methodDescriptor), callOptionsCap.capture()); in fullMethodMatched()
[all …]
|
| D | ForwardingManagedChannelTest.java | 88 public void newCall() { in newCall() method in ForwardingManagedChannelTest
92 when(mock.newCall(same(method), same(callOptions))).thenReturn(clientCall); in newCall()
93 assertSame(clientCall, forward.newCall(method, callOptions)); in newCall()
|
| D | ManagedChannelImplTest.java | 302 channel.newCall(method, CallOptions.DEFAULT.withDeadlineAfter(0, TimeUnit.NANOSECONDS)); in immediateDeadlineExceeded()
459 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in subtestCallsAndShutdown()
468 ClientCall<String, Integer> call2 = channel.newCall(method, CallOptions.DEFAULT); in subtestCallsAndShutdown()
490 ClientCall<String, Integer> call3 = channel.newCall(method, CallOptions.DEFAULT); in subtestCallsAndShutdown()
614 return next.newCall(method, callOptions); in interceptor()
618 assertNotNull(channel.newCall(method, CallOptions.DEFAULT)); in interceptor()
632 ClientCall<String, Integer> call = channel.newCall(method, options); in callOptionsExecutor()
739 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
843 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in firstResolvedServerFailedToConnect()
926 ClientCall<String, Integer> call1 = channel.newCall(method, callOptions); in subtestFailRpcFromBalancer()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/tls/ |
| D | CertificatePinnerChainValidationTest.java | 80 Call call1 = client.newCall(new Request.Builder() in pinRootNotPresentInChain()
90 Call call2 = client.newCall(new Request.Builder() in pinRootNotPresentInChain()
135 Call call1 = client.newCall(new Request.Builder() in pinIntermediatePresentInChain()
145 Call call2 = client.newCall(new Request.Builder() in pinIntermediatePresentInChain()
213 Call call = client.newCall(request); in unrelatedPinnedLeafCertificateInChain()
287 Call call = client.newCall(request); in unrelatedPinnedIntermediateCertificateInChain()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/ |
| D | StubConfigTest.java | 64 when(channel.newCall( in setUp()
89 verify(channel).newCall(same(TestServiceGrpc.getUnaryCallMethod()), same(options1)); in testStubCallOptionsPopulatedToNewCall()
94 verify(channel).newCall(same(TestServiceGrpc.getUnaryCallMethod()), same(options2)); in testStubCallOptionsPopulatedToNewCall()
|
| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| D | PerCallSettings.java | 36 Response response = cloned.newCall(request).execute(); in run()
46 Response response = cloned.newCall(request).execute(); in run()
|
| D | CacheResponse.java | 41 Response response1 = client.newCall(request).execute(); in run()
49 Response response2 = client.newCall(request).execute(); in run()
|
| /external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/ |
| D | ChannelzGrpc.java | 397 … getChannel().newCall(getGetTopChannelsMethod(), getCallOptions()), request, responseObserver); in getTopChannels()
408 getChannel().newCall(getGetServersMethod(), getCallOptions()), request, responseObserver); in getServers()
419 … getChannel().newCall(getGetServerSocketsMethod(), getCallOptions()), request, responseObserver); in getServerSockets()
430 getChannel().newCall(getGetChannelMethod(), getCallOptions()), request, responseObserver); in getChannel()
441 … getChannel().newCall(getGetSubchannelMethod(), getCallOptions()), request, responseObserver); in getSubchannel()
452 getChannel().newCall(getGetSocketMethod(), getCallOptions()), request, responseObserver); in getSocket()
571 getChannel().newCall(getGetTopChannelsMethod(), getCallOptions()), request); in getTopChannels()
582 getChannel().newCall(getGetServersMethod(), getCallOptions()), request); in getServers()
593 getChannel().newCall(getGetServerSocketsMethod(), getCallOptions()), request); in getServerSockets()
604 getChannel().newCall(getGetChannelMethod(), getCallOptions()), request); in getChannel()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ForwardingManagedChannel.java | 61 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall() method in ForwardingManagedChannel
63 return delegate.newCall(methodDescriptor, callOptions); in newCall()
|
| /external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ |
| D | TestServiceGrpc.java | 503 getChannel().newCall(getEmptyCallMethod(), getCallOptions()), request, responseObserver); in emptyCall()
514 getChannel().newCall(getUnaryCallMethod(), getCallOptions()), request, responseObserver); in unaryCall()
527 … getChannel().newCall(getCacheableUnaryCallMethod(), getCallOptions()), request, responseObserver); in cacheableUnaryCall()
539 …getChannel().newCall(getStreamingOutputCallMethod(), getCallOptions()), request, responseObserver); in streamingOutputCall()
551 getChannel().newCall(getStreamingInputCallMethod(), getCallOptions()), responseObserver); in streamingInputCall()
564 getChannel().newCall(getFullDuplexCallMethod(), getCallOptions()), responseObserver); in fullDuplexCall()
578 getChannel().newCall(getHalfDuplexCallMethod(), getCallOptions()), responseObserver); in halfDuplexCall()
590 … getChannel().newCall(getUnimplementedCallMethod(), getCallOptions()), request, responseObserver); in unimplementedCall()
702 getChannel().newCall(getEmptyCallMethod(), getCallOptions()), request); in emptyCall()
713 getChannel().newCall(getUnaryCallMethod(), getCallOptions()), request); in unaryCall()
[all …]
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | BinaryLogProviderTest.java | 104 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in wrapChannel_methodDescriptor()
116 ClientCall<String, Integer> unusedClientCall = wChannel.newCall(method, CallOptions.DEFAULT); in wrapChannel_methodDescriptor()
127 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in wrapChannel_handler()
148 ClientCall<String, Integer> clientCall = wChannel.newCall(method, CallOptions.DEFAULT); in wrapChannel_handler()
312 return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { in interceptCall()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | MetadataUtils.java | 74 return new HeaderAttachingClientCall<ReqT, RespT>(next.newCall(method, callOptions)); in interceptCall()
138 return new MetadataCapturingClientCall<ReqT, RespT>(next.newCall(method, callOptions)); in interceptCall()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | Channel.java | 46 public abstract <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall() method in Channel
|
| /external/llvm-project/mlir/lib/Transforms/ |
| D | BufferResultsToOutParams.cpp | 112 auto newCall = builder.create<CallOp>(op.getLoc(), op.calleeAttr(), in updateCalls() local
114 for (auto t : llvm::zip(replaceWithNewCallResults, newCall.getResults())) in updateCalls()
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorageGrpc.java | 309 getChannel().newCall(getStoreMethod(), getCallOptions()), request, responseObserver); in store()
317 getChannel().newCall(getRetrieveMethod(), getCallOptions()), request, responseObserver); in retrieve()
325 getChannel().newCall(getGetMaxHitPointMethod(), getCallOptions()), responseObserver); in getMaxHitPoint()
333 getChannel().newCall(getGetMinMaxHitPointsMethod(), getCallOptions()), responseObserver); in getMinMaxHitPoints()
394 getChannel().newCall(getStoreMethod(), getCallOptions()), request); in store()
|
| /external/grpc-grpc-java/gae-interop-testing/gae-jdk8/ |
| D | build.gradle | 130 def result1 = client.newCall(request).execute()
131 def result2 = client.newCall(request).execute()
148 def response = client.newCall(interopRequest).execute()
|