| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| 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) {
118 for (AsyncCall call : readyCalls) {
124 for (AsyncCall call : runningCalls) {
139 /** Used by {@code AsyncCall#run} to signal completion. */
140 synchronized void finished(AsyncCall call) {
141 if (!runningCalls.remove(call)) throw new AssertionError("AsyncCall wasn't running!");
149 for (Iterator<AsyncCall> i = readyCalls.iterator(); i.hasNext(); )
[all...] |
| Call.java | 114 client.getDispatcher().enqueue(new AsyncCall(responseCallback, forWebSocket));
138 final class AsyncCall extends NamedRunnable {
142 private AsyncCall(Callback responseCallback, boolean forWebSocket) {
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| DispatcherTest.java | 3 import com.squareup.okhttp.Call.AsyncCall;
126 private List<AsyncCall> calls = new ArrayList<>();
129 calls.add((AsyncCall) command);
134 for (AsyncCall call : calls) {
141 for (Iterator<AsyncCall> i = calls.iterator(); i.hasNext(); ) {
142 AsyncCall call = i.next();
|
| /external/python/cpython2/Lib/idlelib/ |
| rpc.py | 209 self.debug("remotecall:asynccall: ", oid, methodname)
210 seq = self.asynccall(oid, methodname, args, kwargs)
218 def asynccall(self, oid, methodname, args, kwargs): member in class:SocketIO
224 self.debug(("asynccall:%d:" % seq), oid, methodname, args, kwargs)
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/idlelib/ |
| rpc.py | 209 self.debug("remotecall:asynccall: ", oid, methodname)
210 seq = self.asynccall(oid, methodname, args, kwargs)
218 def asynccall(self, oid, methodname, args, kwargs): member in class:SocketIO
224 self.debug(("asynccall:%d:" % seq), oid, methodname, args, kwargs)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/idlelib/ |
| rpc.py | 209 self.debug("remotecall:asynccall: ", oid, methodname)
210 seq = self.asynccall(oid, methodname, args, kwargs)
218 def asynccall(self, oid, methodname, args, kwargs): member in class:SocketIO
224 self.debug(("asynccall:%d:" % seq), oid, methodname, args, kwargs)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/idlelib/ |
| rpc.py | 209 self.debug("remotecall:asynccall: ", oid, methodname)
210 seq = self.asynccall(oid, methodname, args, kwargs)
218 def asynccall(self, oid, methodname, args, kwargs): member in class:SocketIO
224 self.debug(("asynccall:%d:" % seq), oid, methodname, args, kwargs)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/idlelib/ |
| rpc.py | 209 self.debug("remotecall:asynccall: ", oid, methodname)
210 seq = self.asynccall(oid, methodname, args, kwargs)
218 def asynccall(self, oid, methodname, args, kwargs): member in class:SocketIO
224 self.debug(("asynccall:%d:" % seq), oid, methodname, args, kwargs)
|
| /prebuilts/tools/common/m2/repository/com/squareup/okhttp/okhttp/2.5.0/ |
| okhttp-2.5.0.jar | |
| /prebuilts/tools/common/m2/repository/com/squareup/okhttp/okhttp/2.7.2/ |
| okhttp-2.7.2.jar | |
| /prebuilts/tools/common/m2/repository/com/squareup/okhttp/okhttp/2.7.4/ |
| okhttp-2.7.4.jar | |
| /prebuilts/tools/common/m2/repository/com/squareup/okhttp3/okhttp/3.3.0/ |
| okhttp-3.3.0.jar | |
| /prebuilts/tools/common/m2/repository/com/squareup/okhttp3/okhttp/3.4.1/ |
| okhttp-3.4.1.jar | |
| /prebuilts/gcc/linux-x86/host/x86_64-w64-mingw32-4.8/x86_64-w64-mingw32/include/ |
| comsvcs.h | [all...] |
