Searched refs:runningCalls (Results 1 – 2 of 2) sorted by relevance
47 private final Deque<AsyncCall> runningCalls = new ArrayDeque<>(); field in Dispatcher108 if (runningCalls.size() < maxRequests && runningCallsForHost(call) < maxRequestsPerHost) { in enqueue()109 runningCalls.add(call); in enqueue()124 for (AsyncCall call : runningCalls) { in cancel()141 if (!runningCalls.remove(call)) throw new AssertionError("AsyncCall wasn't running!"); in finished()146 if (runningCalls.size() >= maxRequests) return; // Already running max capacity. in promoteCalls()154 runningCalls.add(call); in promoteCalls()158 if (runningCalls.size() >= maxRequests) return; // Reached max capacity. in promoteCalls()165 for (AsyncCall c : runningCalls) { in runningCallsForHost()182 return runningCalls.size(); in getRunningCallCount()
49 private final Deque<AsyncCall> runningCalls = new ArrayDeque<>(); field in Dispatcher110 if (runningCalls.size() < maxRequests && runningCallsForHost(call) < maxRequestsPerHost) { in enqueue()111 runningCalls.add(call); in enqueue()126 for (AsyncCall call : runningCalls) { in cancel()143 if (!runningCalls.remove(call)) throw new AssertionError("AsyncCall wasn't running!"); in finished()148 if (runningCalls.size() >= maxRequests) return; // Already running max capacity. in promoteCalls()156 runningCalls.add(call); in promoteCalls()160 if (runningCalls.size() >= maxRequests) return; // Reached max capacity. in promoteCalls()167 for (AsyncCall c : runningCalls) { in runningCallsForHost()184 return runningCalls.size(); in getRunningCallCount()