| /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 | CacheTest.java | 172 server.enqueue(mockResponse); in assertCached()
216 server.enqueue(mockResponse); in testResponseCaching()
248 server.enqueue(new MockResponse() in secureResponseCaching()
283 server.enqueue(new MockResponse() in responseCachingAndRedirects()
288 server.enqueue(new MockResponse() in responseCachingAndRedirects()
292 server.enqueue(new MockResponse() in responseCachingAndRedirects()
308 server.enqueue(new MockResponse() in redirectToCachedResult()
311 server.enqueue(new MockResponse() in redirectToCachedResult()
314 server.enqueue(new MockResponse() in redirectToCachedResult()
342 server.enqueue(new MockResponse() in secureResponseCachingAndRedirects()
[all …]
|
| D | CallTest.java | 111 server.enqueue(new MockResponse().setBody("abc").addHeader("Content-Type: text/plain")); in get()
132 server.enqueue(new MockResponse()); in buildRequestUsingHttpUrl()
164 server.enqueue(new MockResponse().setResponseCode(500)); in getReturns500()
186 server.enqueue(new MockResponse()); in getWithRequestBody()
196 server.enqueue(new MockResponse().addHeader("Content-Type: text/plain")); in head()
226 server.enqueue(new MockResponse().setBody("abc")); in post()
255 server.enqueue(new MockResponse().setBody("abc")); in postZeroLength()
313 server.enqueue(new MockResponse().setResponseCode(401)); in postBodyRetransmittedAfterAuthorizationFail()
314 server.enqueue(new MockResponse()); in postBodyRetransmittedAfterAuthorizationFail()
340 server.enqueue(new MockResponse().setResponseCode(401)); in attemptAuthorization20Times()
[all …]
|
| D | URLConnectionTest.java | 131 server.enqueue(new MockResponse()); in requestHeaders()
199 server.enqueue(new MockResponse().setStatus("HTTP/1.0 200 Fantastic") in responseHeaders()
232 server.enqueue(new MockResponse().setStatus("HTP/1.1 200 OK")); in serverSendsInvalidResponseHeaders()
243 server.enqueue(new MockResponse().setStatus("HTTP/1.1 2147483648 OK")); in serverSendsInvalidCodeTooLarge()
254 server.enqueue(new MockResponse().setStatus("HTTP/1.1 00a OK")); in serverSendsInvalidCodeNotANumber()
265 server.enqueue(new MockResponse().setStatus(" HTTP/1.1 2147483648 OK")); in serverSendsUnnecessaryWhitespace()
300 server.enqueue(new MockResponse().setBody("abc")); in testRequestBodySurvivesRetries()
318 server.enqueue(new MockResponse().setBody("A")); in getErrorStreamOnSuccessfulRequest()
324 server.enqueue(new MockResponse().setResponseCode(404).setBody("A")); in getErrorStreamOnUnsuccessfulRequest()
335 server.enqueue(response); in bug2939()
[all …]
|
| D | InterceptorTest.java | 79 server.enqueue(new MockResponse().setResponseCode(500)); in networkInterceptorsCannotShortCircuitResponses()
108 server.enqueue(new MockResponse()); in networkInterceptorsCannotCallProceedMultipleTimes()
109 server.enqueue(new MockResponse()); in networkInterceptorsCannotCallProceedMultipleTimes()
133 server.enqueue(new MockResponse().setResponseCode(500)); in networkInterceptorsCannotChangeServerAddress()
161 server.enqueue(new MockResponse()); in networkInterceptorsHaveConnectionAccess()
178 server.enqueue(new MockResponse() in networkInterceptorsObserveNetworkHeaders()
222 server.enqueue(new MockResponse()); in rewriteRequestToServer()
258 server.enqueue(new MockResponse() in rewriteResponseFromServer()
291 server.enqueue(new MockResponse()); in multipleInterceptors()
338 server.enqueue(new MockResponse()); in asyncInterceptors()
[all …]
|
| D | SocksProxyTest.java | 48 server.enqueue(new MockResponse().setBody("abc")); in proxy()
49 server.enqueue(new MockResponse().setBody("def")); in proxy()
67 server.enqueue(new MockResponse().setBody("abc")); in proxySelector()
|
| /external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/ |
| D | ResponseCacheTest.java | 195 server.enqueue(mockResponse); in assertCached()
236 server.enqueue(mockResponse); in testResponseCaching()
260 server.enqueue(new MockResponse() in secureResponseCaching()
290 server.enqueue(new MockResponse() in responseCachingAndRedirects()
295 server.enqueue(new MockResponse() in responseCachingAndRedirects()
299 server.enqueue(new MockResponse() in responseCachingAndRedirects()
310 server.enqueue(new MockResponse() in redirectToCachedResult()
313 server.enqueue(new MockResponse() in redirectToCachedResult()
316 server.enqueue(new MockResponse() in redirectToCachedResult()
338 server.enqueue(new MockResponse() in secureResponseCachingAndRedirects()
[all …]
|
| /external/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/ |
| D | UrlConnectionCacheTest.java | 178 server.enqueue(response); in assertCached()
220 server.enqueue(response); in testResponseCaching()
250 server.enqueue(new MockResponse().addHeader("Last-Modified: " + formatDate(-1, TimeUnit.HOURS)) in secureResponseCaching()
283 server.enqueue(new MockResponse().addHeader("Last-Modified: " + formatDate(-1, TimeUnit.HOURS)) in responseCachingAndRedirects()
287 server.enqueue(new MockResponse().addHeader("Last-Modified: " + formatDate(-1, TimeUnit.HOURS)) in responseCachingAndRedirects()
290 server.enqueue(new MockResponse().setBody("DEF")); in responseCachingAndRedirects()
304 server.enqueue(new MockResponse().addHeader("Cache-Control: max-age=60").setBody("ABC")); in redirectToCachedResult()
305 server.enqueue(new MockResponse().setResponseCode(HttpURLConnection.HTTP_MOVED_PERM) in redirectToCachedResult()
307 server.enqueue(new MockResponse().setBody("DEF")); in redirectToCachedResult()
328 server.enqueue(new MockResponse().addHeader("Last-Modified: " + formatDate(-1, TimeUnit.HOURS)) in secureResponseCachingAndRedirects()
[all …]
|
| D | OkUrlFactoryTest.java | 46 server.enqueue(new MockResponse().setResponseCode(407)); in originServerSends407()
57 server.enqueue(new MockResponse().setBody("Isla Sorna")); in networkResponseSourceHeader()
65 server.enqueue(new MockResponse().setResponseCode(404)); in networkFailureResponseSourceHeader()
72 server.enqueue(new MockResponse() in conditionalCacheHitResponseSourceHeaders()
76 server.enqueue(new MockResponse().setResponseCode(304)); in conditionalCacheHitResponseSourceHeaders()
88 server.enqueue(new MockResponse() in conditionalCacheMissResponseSourceHeaders()
92 server.enqueue(new MockResponse().setBody("Isla Sorna")); in conditionalCacheMissResponseSourceHeaders()
104 server.enqueue(new MockResponse() in cacheResponseSourceHeaders()
118 server.enqueue(new MockResponse().setBody("Isla Nublar")); in noneResponseSourceHeaders()
131 server.enqueue(new MockResponse() in setInstanceFollowRedirectsFalse()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| D | HttpOverSpdyTest.java | 98 server.enqueue(response); in get()
112 server.enqueue(new MockResponse()); in emptyResponse()
121 server.enqueue(new MockResponse().setBody("ABCDE")); in noDefaultContentLengthOnStreamingPost()
136 server.enqueue(new MockResponse().setBody("ABCDE")); in userSuppliedContentLengthHeader()
151 server.enqueue(new MockResponse().setBody("ABCDE")); in closeAfterFlush()
168 server.enqueue(new MockResponse().setBody("ABCDE")); in setFixedLengthStreamingModeSetsContentLength()
183 server.enqueue(new MockResponse().setBody("ABCDEF")); in spdyConnectionReuse()
184 server.enqueue(new MockResponse().setBody("GHIJKL")); in spdyConnectionReuse()
197 server.enqueue(new MockResponse().setBody("A")); in synchronousSpdyRequest()
198 server.enqueue(new MockResponse().setBody("A")); in synchronousSpdyRequest()
[all …]
|
| D | CookiesTest.java | 69 server.enqueue(new MockResponse().addHeader("Set-Cookie: a=android; " in testNetscapeResponse()
97 server.enqueue(new MockResponse().addHeader("Set-Cookie: a=android; " in testRfc2109Response()
127 server.enqueue(new MockResponse().addHeader("Set-Cookie2: a=android; " in testRfc2965Response()
161 server.enqueue(new MockResponse().addHeader("Set-Cookie2: a=\"android\"; " in testQuotedAttributeValues()
191 server.enqueue(new MockResponse()); in testSendingCookiesFromStore()
219 redirectTarget.enqueue(new MockResponse().setBody("A")); in testRedirectsDoNotIncludeTooManyCookies()
223 redirectSource.enqueue(new MockResponse() in testRedirectsDoNotIncludeTooManyCookies()
276 server.enqueue(new MockResponse()); in testHeadersSentToCookieHandler()
327 server. enqueue(new MockResponse()); in testCookiesSentIgnoresCase()
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
| D | WebSocketCallTest.java | 55 server.enqueue(new MockResponse().withWebSocketUpgrade(serverListener)); in clientPingPong()
64 server.enqueue(new MockResponse().withWebSocketUpgrade(serverListener)); in clientMessage()
85 server.enqueue(new MockResponse().withWebSocketUpgrade(serverListener)); in serverMessage()
93 server.enqueue(new MockResponse().withWebSocketUpgrade(serverListener)); in clientStreamingMessage()
121 server.enqueue(new MockResponse().withWebSocketUpgrade(serverListener)); in serverStreamingMessage()
128 server.enqueue(new MockResponse()); in okButNotOk()
134 server.enqueue(new MockResponse().setStatus("HTTP/1.1 404 Not Found")); in notFound()
141 server.enqueue(new MockResponse() in missingConnectionHeader()
151 server.enqueue(new MockResponse() in wrongConnectionHeader()
162 server.enqueue(new MockResponse() in missingUpgradeHeader()
[all …]
|
| D | AutobahnTester.java | 68 .enqueue(new WebSocketListener() { in runTest()
119 newWebSocket("/getCaseCount").enqueue(new WebSocketListener() { in getTestCount()
157 newWebSocket("/updateReports?agent=" + Version.userAgent()).enqueue(new WebSocketListener() { in updateReports()
|
| /external/okhttp/okhttp-apache/src/test/java/com/squareup/okhttp/apache/ |
| D | OkApacheClientTest.java | 48 server.enqueue(new MockResponse().setBody("Hello, World!")); in success()
57 server.enqueue(new MockResponse().setResponseCode(302).addHeader("Location", "/foo")); in redirect()
58 server.enqueue(new MockResponse().setBody("Hello, Redirect!")); in redirect()
67 server.enqueue(new MockResponse().setResponseCode(422)); in sessionExpired()
75 server.enqueue(new MockResponse().addHeader("Foo", "Bar")); in headers()
76 server.enqueue(new MockResponse().addHeader("Foo", "Bar").addHeader("Foo", "Baz")); in headers()
93 server.enqueue(new MockResponse()); in postByteEntity()
106 server.enqueue(new MockResponse()); in postInputStreamEntity()
118 server.enqueue(new MockResponse()); in postEmptyEntity()
127 server.enqueue(new MockResponse()); in putEmptyEntity()
[all …]
|
| /external/deqp/framework/platform/android/ |
| D | tcuAndroidRenderActivity.cpp | 97 enqueue(Message(MESSAGE_FINISH)); in stop()
105 void RenderThread::enqueue (const Message& message) in enqueue() function in tcu::Android::RenderThread
114 enqueue(Message(MESSAGE_PAUSE)); in pause()
119 enqueue(Message(MESSAGE_RESUME)); in resume()
125 enqueue(Message(MESSAGE_SYNC, &waitSem)); in sync()
331 m_thread->enqueue(Message(MESSAGE_WINDOW_CREATED, window)); in onNativeWindowCreated()
337 m_thread->enqueue(Message(MESSAGE_WINDOW_RESIZED, window)); in onNativeWindowResized()
348 m_thread->enqueue(Message(MESSAGE_WINDOW_DESTROYED, window)); in onNativeWindowDestroyed()
355 m_thread->enqueue(Message(MESSAGE_INPUT_QUEUE_CREATED, queue)); in onInputQueueCreated()
361 m_thread->enqueue(Message(MESSAGE_INPUT_QUEUE_DESTROYED, queue)); in onInputQueueDestroyed()
|
| /external/mockwebserver/src/test/java/com/google/mockwebserver/ |
| D | MockWebServerTest.java | 101 server.enqueue(new MockResponse().setBody("hello world")); in testRegularResponse()
119 server.enqueue(new MockResponse() in testRedirect()
123 server.enqueue(new MockResponse().setBody("This is the new location!")); in testRedirect()
149 server.enqueue(new MockResponse().setBody("enqueued in the background")); in testDispatchBlocksWaitingForEnqueue()
160 server.enqueue(new MockResponse() in testNonHexadecimalChunkSize()
176 server.enqueue(new MockResponse() in testResponseTimeout()
180 server.enqueue(new MockResponse() in testResponseTimeout()
208 server.enqueue(new MockResponse().setSocketPolicy(SocketPolicy.DISCONNECT_AT_START)); in testDisconnectAtStart()
209 server.enqueue(new MockResponse()); // The jdk's HttpUrlConnection is a bastard. in testDisconnectAtStart()
210 server.enqueue(new MockResponse()); in testDisconnectAtStart()
[all …]
|
| /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| D | MockWebServerTest.java | 82 server.enqueue(new MockResponse().setBody("hello world")); in regularResponse()
98 server.enqueue(new MockResponse() in redirect()
102 server.enqueue(new MockResponse().setBody("This is the new location!")); in redirect()
126 server.enqueue(new MockResponse().setBody("enqueued in the background")); in dispatchBlocksWaitingForEnqueue()
137 server.enqueue(new MockResponse() in nonHexadecimalChunkSize()
152 server.enqueue(new MockResponse() in responseTimeout()
156 server.enqueue(new MockResponse().setBody("DEF")); in responseTimeout()
182 server.enqueue(new MockResponse().setSocketPolicy(SocketPolicy.DISCONNECT_AT_START)); in disconnectAtStart()
183 server.enqueue(new MockResponse()); // The jdk's HttpUrlConnection is a bastard. in disconnectAtStart()
184 server.enqueue(new MockResponse()); in disconnectAtStart()
[all …]
|
| /external/clang/lib/StaticAnalyzer/Core/ |
| D | CoreEngine.cpp | 51 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anonc6354d350111::DFS
79 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anonc6354d350111::BFS
117 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anonc6354d350211::BFSBlockDFSContents
320 enqueue(dstNodes); in HandleBlockEdge()
467 enqueue(Dst); in HandleBranch()
479 enqueue(Dst); in HandleCleanupTemporaryBranch()
490 enqueue(Dst); in HandleStaticInit()
524 if (IsNew) WList->enqueue(Node); in generateNode()
536 WList->enqueue(N, Block, Idx); in enqueueStmtNode()
543 WList->enqueue(N, Block, Idx+1); in enqueueStmtNode()
[all …]
|
| /external/clang/include/clang/StaticAnalyzer/Core/PathSensitive/ |
| D | WorkList.h | 67 virtual void enqueue(const WorkListUnit& U) = 0;
69 void enqueue(ExplodedNode *N, const CFGBlock *B, unsigned idx) { in enqueue() function
70 enqueue(WorkListUnit(N, CurrentCounter, B, idx)); in enqueue()
73 void enqueue(ExplodedNode *N) { in enqueue() function
75 enqueue(WorkListUnit(N, CurrentCounter)); in enqueue()
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ |
| D | EventFacade.java | 106 …nts be added to the event queue or only dispatched") @RpcDefault(value = "true") Boolean enqueue) { in eventRegisterForBroadcast()
111 BroadcastListener b = new BroadcastListener(this, enqueue.booleanValue()); in eventRegisterForBroadcast()
283 …e added to the event queue, just dispatched.") @RpcOptional @RpcDefault("false") Boolean enqueue) { in eventPost() argument
284 postEvent(name, data, enqueue.booleanValue()); in eventPost()
297 public void postEvent(String name, Object data, boolean enqueue) { in postEvent() argument
299 if (enqueue != false) { in postEvent()
415 public BroadcastListener(EventFacade parent, boolean enqueue) { in BroadcastListener() argument
417 mEnQueue = enqueue; in BroadcastListener()
|
| /external/vogar/src/vogar/ |
| D | Driver.java | 81 run.taskQueue.enqueue(prepareTargetTask); in buildAndRun()
161 run.taskQueue.enqueue(build); in enqueueActionTasks()
165 run.taskQueue.enqueue(prepareUserDir); in enqueueActionTasks()
178 run.taskQueue.enqueue(execute); in enqueueActionTasks()
181 run.taskQueue.enqueue(retrieveFiles); in enqueueActionTasks()
184 run.taskQueue.enqueue(new RmTask(run.rm, run.localFile(action)) in enqueueActionTasks()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | Call.java | 104 public void enqueue(Callback responseCallback) { in enqueue() method in Call
105 enqueue(responseCallback, false); in enqueue()
108 void enqueue(Callback responseCallback, boolean forWebSocket) { in enqueue() method in Call
113 client.getDispatcher().enqueue(new AsyncCall(responseCallback, forWebSocket)); in enqueue()
|
| /external/okhttp/okhttp-ws/ |
| D | README.md | 14 Start the web socket by calling `enqueue` on `WebSocketCall` with the `WebSocketListener`.
16 call.enqueue(new WebSocketListener() {
|
| /external/deqp/executor/ |
| D | xeCallQueue.cpp | 133 void CallQueue::enqueue (Call* call) in enqueue() function in xe::CallQueue
240 void CallWriter::enqueue (void) in enqueue() function in xe::CallWriter
243 m_queue->enqueue(m_call); in enqueue()
|
| /external/jetty/src/java/org/eclipse/jetty/util/ |
| D | ArrayQueue.java | 95 return enqueue(e); in offer()
100 private boolean enqueue(E e) in enqueue() method in ArrayQueue
122 if (!enqueue(e)) in addUnsafe()
|