| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | Dispatcher.java | 18 import com.squareup.okhttp.Call.AsyncCall;
44 private final Deque<AsyncCall> readyCalls = new ArrayDeque<>();
47 private final Deque<AsyncCall> runningCalls = new ArrayDeque<>();
107 synchronized void enqueue(AsyncCall call) { in enqueue()
118 for (AsyncCall call : readyCalls) { in cancel()
124 for (AsyncCall call : runningCalls) { in cancel()
140 synchronized void finished(AsyncCall call) { in finished()
149 for (Iterator<AsyncCall> i = readyCalls.iterator(); i.hasNext(); ) { in promoteCalls()
150 AsyncCall call = i.next(); in promoteCalls()
163 private int runningCallsForHost(AsyncCall call) { in runningCallsForHost()
[all …]
|
| D | Call.java | 114 client.getDispatcher().enqueue(new AsyncCall(responseCallback, forWebSocket)); in enqueue()
138 final class AsyncCall extends NamedRunnable { class in Call
142 private AsyncCall(Callback responseCallback, boolean forWebSocket) { in AsyncCall() method in Call.AsyncCall
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| D | Dispatcher.java | 19 import com.android.okhttp.Call.AsyncCall;
46 private final Deque<AsyncCall> readyCalls = new ArrayDeque<>();
49 private final Deque<AsyncCall> runningCalls = new ArrayDeque<>();
109 synchronized void enqueue(AsyncCall call) { in enqueue()
120 for (AsyncCall call : readyCalls) { in cancel()
126 for (AsyncCall call : runningCalls) { in cancel()
142 synchronized void finished(AsyncCall call) { in finished()
151 for (Iterator<AsyncCall> i = readyCalls.iterator(); i.hasNext(); ) { in promoteCalls()
152 AsyncCall call = i.next(); in promoteCalls()
165 private int runningCallsForHost(AsyncCall call) { in runningCallsForHost()
[all …]
|
| D | Call.java | 116 client.getDispatcher().enqueue(new AsyncCall(responseCallback, forWebSocket)); in enqueue()
140 final class AsyncCall extends NamedRunnable { class in Call
144 private AsyncCall(Callback responseCallback, boolean forWebSocket) { in AsyncCall() method in Call.AsyncCall
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | Calls.cs | 44 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
60 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
78 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
96 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
115 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DispatcherTest.java | 3 import com.squareup.okhttp.Call.AsyncCall;
126 private List<AsyncCall> calls = new ArrayList<>();
129 calls.add((AsyncCall) command); in execute()
134 for (AsyncCall call : calls) { in assertJobs()
141 for (Iterator<AsyncCall> i = calls.iterator(); i.hasNext(); ) { in finishJob()
142 AsyncCall call = i.next(); in finishJob()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ClientRequestStream.cs | 27 readonly AsyncCall<TRequest, TResponse> call;
30 public ClientRequestStream(AsyncCall<TRequest, TResponse> call) in ClientRequestStream()
|
| D | ClientResponseStream.cs | 30 readonly AsyncCall<TRequest, TResponse> call;
33 public ClientResponseStream(AsyncCall<TRequest, TResponse> call) in ClientResponseStream()
|
| D | AsyncCall.cs | 31 …internal class AsyncCall<TRequest, TResponse> : AsyncCallBase<TRequest, TResponse>, IUnaryResponse… class
33 … static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<AsyncCall<TRequest, TResponse>>();
56 public AsyncCall(CallInvocationDetails<TRequest, TResponse> callDetails) in AsyncCall() method in Grpc.Core.Internal.AsyncCall
66 …public AsyncCall(CallInvocationDetails<TRequest, TResponse> callDetails, INativeCall injectedNativ… in AsyncCall() method in Grpc.Core.Internal.AsyncCall
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | AsyncCallTest.cs | 35 AsyncCall<string, string> asyncCall;
45 asyncCall = new AsyncCall<string, string>(callDetails, fakeCall); in Init()
646 …static void AssertUnaryResponseSuccess(AsyncCall<string, string> asyncCall, FakeNativeCall fakeCal… in AssertUnaryResponseSuccess()
657 …static void AssertStreamingResponseSuccess(AsyncCall<string, string> asyncCall, FakeNativeCall fak… in AssertStreamingResponseSuccess()
667 …static void AssertUnaryResponseError(AsyncCall<string, string> asyncCall, FakeNativeCall fakeCall,… in AssertUnaryResponseError()
679 …static void AssertStreamingResponseError(AsyncCall<string, string> asyncCall, FakeNativeCall fakeC… in AssertStreamingResponseError()
|