| /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 | ConnectionReuseTest.java | 41 server.enqueue(new MockResponse().setBody("a")); in connectionsAreReused()
42 server.enqueue(new MockResponse().setBody("b")); in connectionsAreReused()
52 server.enqueue(new MockResponse().setBody("a")); in connectionsAreReusedWithHttp2()
53 server.enqueue(new MockResponse().setBody("b")); in connectionsAreReusedWithHttp2()
62 server.enqueue(new MockResponse().setBody("a")); in connectionsAreNotReusedWithRequestConnectionClose()
63 server.enqueue(new MockResponse().setBody("b")); in connectionsAreNotReusedWithRequestConnectionClose()
76 server.enqueue(new MockResponse() in connectionsAreNotReusedWithResponseConnectionClose()
79 server.enqueue(new MockResponse().setBody("b")); in connectionsAreNotReusedWithResponseConnectionClose()
91 server.enqueue(new MockResponse() in connectionsAreNotReusedWithUnknownLengthResponseBody()
95 server.enqueue(new MockResponse().setBody("b")); in connectionsAreNotReusedWithUnknownLengthResponseBody()
[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()
191 server.enqueue(new MockResponse() in repeatedHeaderNames()
220 server.enqueue(new MockResponse()); in getWithRequestBody()
230 server.enqueue(new MockResponse().addHeader("Content-Type: text/plain")); in head()
265 server.enqueue(new MockResponse().setBody("abc")); in post()
299 server.enqueue(new MockResponse().setBody("abc")); in postZeroLength()
372 server.enqueue(new MockResponse().setResponseCode(401)); in postBodyRetransmittedAfterAuthorizationFail()
373 server.enqueue(new MockResponse()); in postBodyRetransmittedAfterAuthorizationFail()
[all …]
|
| D | URLConnectionTest.java | 133 server.enqueue(new MockResponse()); in requestHeaders()
201 server.enqueue(new MockResponse().setStatus("HTTP/1.0 200 Fantastic") in responseHeaders()
235 server.enqueue(new MockResponse().setStatus("HTP/1.1 200 OK")); in serverSendsInvalidResponseHeaders()
246 server.enqueue(new MockResponse().setStatus("HTTP/1.1 2147483648 OK")); in serverSendsInvalidCodeTooLarge()
257 server.enqueue(new MockResponse().setStatus("HTTP/1.1 00a OK")); in serverSendsInvalidCodeNotANumber()
268 server.enqueue(new MockResponse().setStatus(" HTTP/1.1 2147483648 OK")); in serverSendsUnnecessaryWhitespace()
303 server.enqueue(new MockResponse().setBody("abc")); in testRequestBodySurvivesRetries()
321 server.enqueue(new MockResponse().setBody("A")); in getErrorStreamOnSuccessfulRequest()
328 server.enqueue(new MockResponse().setResponseCode(404).setBody("A")); in getErrorStreamOnUnsuccessfulRequest()
339 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()
214 server.enqueue(new MockResponse()); in networkInterceptorsCanChangeRequestMethodFromGetToPost()
251 server.enqueue(new MockResponse()); in rewriteRequestToServer()
287 server.enqueue(new MockResponse() in rewriteResponseFromServer()
320 server.enqueue(new MockResponse()); in multipleInterceptors()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | ListenerCallQueueTest.java | 57 queue.enqueue(incrementingEvent(counters, listener, 1)); in testEnqueueAndDispatch()
58 queue.enqueue(incrementingEvent(counters, listener, 2)); in testEnqueueAndDispatch()
59 queue.enqueue(incrementingEvent(counters, listener, 3)); in testEnqueueAndDispatch()
60 queue.enqueue(incrementingEvent(counters, listener, 4)); in testEnqueueAndDispatch()
72 queue.enqueue(incrementingEvent(counters, listener1, 1)); in testEnqueueAndDispatch_multipleListeners()
73 queue.enqueue(incrementingEvent(counters, listener1, 2)); in testEnqueueAndDispatch_multipleListeners()
77 queue.enqueue(incrementingEvent(counters, multiset(listener1, 3, listener2, 1))); in testEnqueueAndDispatch_multipleListeners()
78 queue.enqueue(incrementingEvent(counters, multiset(listener1, 4, listener2, 2))); in testEnqueueAndDispatch_multipleListeners()
90 queue.enqueue(incrementingEvent(counters, listener, 1)); in testEnqueueAndDispatch_withExceptions()
91 queue.enqueue(THROWING_EVENT); in testEnqueueAndDispatch_withExceptions()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ListenerCallQueueTest.java | 57 queue.enqueue(incrementingEvent(counters, listener, 1)); in testEnqueueAndDispatch()
58 queue.enqueue(incrementingEvent(counters, listener, 2)); in testEnqueueAndDispatch()
59 queue.enqueue(incrementingEvent(counters, listener, 3)); in testEnqueueAndDispatch()
60 queue.enqueue(incrementingEvent(counters, listener, 4)); in testEnqueueAndDispatch()
72 queue.enqueue(incrementingEvent(counters, listener1, 1)); in testEnqueueAndDispatch_multipleListeners()
73 queue.enqueue(incrementingEvent(counters, listener1, 2)); in testEnqueueAndDispatch_multipleListeners()
77 queue.enqueue(incrementingEvent(counters, multiset(listener1, 3, listener2, 1))); in testEnqueueAndDispatch_multipleListeners()
78 queue.enqueue(incrementingEvent(counters, multiset(listener1, 4, listener2, 2))); in testEnqueueAndDispatch_multipleListeners()
90 queue.enqueue(incrementingEvent(counters, listener, 1)); in testEnqueueAndDispatch_withExceptions()
91 queue.enqueue(THROWING_EVENT); in testEnqueueAndDispatch_withExceptions()
[all …]
|
| /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 | 55 server.enqueue(new MockResponse().setResponseCode(407)); in originServerSends407()
66 server.enqueue(new MockResponse().setBody("Isla Sorna")); in networkResponseSourceHeader()
74 server.enqueue(new MockResponse().setResponseCode(404)); in networkFailureResponseSourceHeader()
82 server.enqueue(new MockResponse() in conditionalCacheHitResponseSourceHeaders()
86 server.enqueue(new MockResponse().setResponseCode(304)); in conditionalCacheHitResponseSourceHeaders()
98 server.enqueue(new MockResponse() in conditionalCacheMissResponseSourceHeaders()
102 server.enqueue(new MockResponse().setBody("Isla Sorna")); in conditionalCacheMissResponseSourceHeaders()
114 server.enqueue(new MockResponse() in cacheResponseSourceHeaders()
128 server.enqueue(new MockResponse().setBody("Isla Nublar")); in noneResponseSourceHeaders()
141 server.enqueue(new MockResponse() in setInstanceFollowRedirectsFalse()
[all …]
|
| /external/tensorflow/tensorflow/compiler/tests/ |
| D | fifo_queue_test.py | 36 enqueue_op = q.enqueue((10.0,))
42 enqueue_correct_op = q.enqueue(([[1.0, 2.0], [3.0, 4.0], [5.0, 6.0]],))
45 q.enqueue(([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]],))
51 self.evaluate(q.enqueue([1]))
52 self.evaluate(q.enqueue([2]))
53 self.evaluate(q.enqueue([3]))
60 self.evaluate(q.enqueue(1))
62 self.evaluate(q2.enqueue(2))
70 q.enqueue({"a": 12.0})
76 enqueue_ops = [q.enqueue((x,)) for x in elems]
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/internal/ |
| D | SegmentQueueTest.kt | 18 q.enqueue(1) in testSimpleTest()
20 q.enqueue(2) in testSimpleTest()
32 q.enqueue(1) in testSegmentRemoving()
33 val s = q.enqueue(2) in testSegmentRemoving()
34 q.enqueue(3) in testSegmentRemoving()
46 q.enqueue(1) in testRemoveHeadSegment()
47 val s = q.enqueue(2) in testRemoveHeadSegment()
49 q.enqueue(3) in testRemoveHeadSegment()
58 q.enqueue(1) in testClose()
60 assertEquals(null, q.enqueue(2)) in testClose()
[all …]
|
| /external/skia/src/gpu/tessellate/ |
| D | GrStrokeIterator.h | 89 this->enqueue((Verb)verb, pts, w); in next()
106 this->enqueue(Verb::kLine, fClosePts.data(), nullptr); in next()
109 this->enqueue(fFirstVerbInContour, fFirstPtsInContour, fFirstWInContour); in next()
110 this->enqueue(Verb::kContourFinished, nullptr, nullptr); in next()
156 void enqueue(Verb verb, const SkPoint* pts, const float* w) { in enqueue() function
181 this->enqueue(Verb::kMoveWithinContour, fFirstPtsInContour, fFirstWInContour); in finishOpenContour()
188 this->enqueue(Verb::kCircle, this->backPts() + backIdx, nullptr); in finishOpenContour()
189 this->enqueue(Verb::kCircle, fFirstPtsInContour, fFirstWInContour); in finishOpenContour()
195 this->enqueue(Verb::kLine, fEndingCapPts.data(), nullptr); in finishOpenContour()
198 this->enqueue(Verb::kMoveWithinContour, fBeginningCapPts.data(), nullptr); in finishOpenContour()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| 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 …]
|
| /external/llvm-project/lld/wasm/ |
| D | MarkLive.cpp | 44 void enqueue(Symbol *sym);
55 void MarkLive::enqueue(Symbol *sym) { in enqueue() function in lld::wasm::MarkLive
84 enqueue(initSym); in enqueueInitFunctions()
91 enqueue(symtab->find(config->entry)); in run()
96 enqueue(sym); in run()
99 enqueue(WasmSym::callDtors); in run()
102 enqueue(WasmSym::applyRelocs); in run()
105 enqueue(WasmSym::initMemory); in run()
146 enqueue(sym); in mark()
|
| /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/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()
92 server.enqueue(new MockResponse()); in okButNotOk()
98 server.enqueue(new MockResponse().setStatus("HTTP/1.1 404 Not Found")); in notFound()
105 server.enqueue(new MockResponse() in missingConnectionHeader()
115 server.enqueue(new MockResponse() in wrongConnectionHeader()
126 server.enqueue(new MockResponse() in missingUpgradeHeader()
136 server.enqueue(new MockResponse() in wrongUpgradeHeader()
147 server.enqueue(new MockResponse() in missingMagicHeader()
[all …]
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | fifo_queue_test.py | 109 self.evaluate(q.enqueue((10.0,)))
113 self.evaluate(q.enqueue((10.0,)))
117 self.evaluate(q.enqueue(([[1.0, 2.0], [3.0, 4.0], [5.0, 6.0]],)))
119 q.enqueue(([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]],))
137 self.evaluate(q.enqueue(1))
139 self.evaluate(q2.enqueue(2))
155 self.q2.enqueue(x)
156 self.q2.enqueue(x + 3)
157 self.q1.enqueue(self.q2.dequeue())
182 q.enqueue({"a": 12.0})
[all …]
|
| /external/deqp/framework/platform/android/ |
| D | tcuAndroidRenderActivity.cpp | 98 enqueue(Message(MESSAGE_FINISH)); in stop()
106 void RenderThread::enqueue (const Message& message) in enqueue() function in tcu::Android::RenderThread
115 enqueue(Message(MESSAGE_PAUSE)); in pause()
120 enqueue(Message(MESSAGE_RESUME)); in resume()
126 enqueue(Message(MESSAGE_SYNC, &waitSem)); in sync()
358 m_thread->enqueue(Message(MESSAGE_WINDOW_CREATED, window)); in onNativeWindowCreated()
364 m_thread->enqueue(Message(MESSAGE_WINDOW_RESIZED, window)); in onNativeWindowResized()
375 m_thread->enqueue(Message(MESSAGE_WINDOW_DESTROYED, window)); in onNativeWindowDestroyed()
382 m_thread->enqueue(Message(MESSAGE_INPUT_QUEUE_CREATED, queue)); in onInputQueueCreated()
388 m_thread->enqueue(Message(MESSAGE_INPUT_QUEUE_DESTROYED, queue)); in onInputQueueDestroyed()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/test/ |
| D | MessageQueueTest.kt | 33 queue.enqueue(Box(10 + i)) in <lambda>()
40 queue.enqueue(Box(1)) in <lambda>()
43 queue.enqueue(Box(2)) in <lambda>()
54 queue.enqueue(ReBox(1)) in <lambda>()
57 queue.enqueue(ReBox(2)) in <lambda>()
72 queue.enqueue(Box(it)) in <lambda>()
|
| /external/mockwebserver/src/test/java/com/google/mockwebserver/ |
| D | MockWebServerTest.java | 107 server.enqueue(new MockResponse().setBody("hello world")); in testRegularResponse()
125 server.enqueue(new MockResponse() in testRedirect()
129 server.enqueue(new MockResponse().setBody("This is the new location!")); in testRedirect()
155 server.enqueue(new MockResponse().setBody("enqueued in the background")); in testDispatchBlocksWaitingForEnqueue()
166 server.enqueue(new MockResponse() in testNonHexadecimalChunkSize()
182 server.enqueue(new MockResponse() in testResponseTimeout()
186 server.enqueue(new MockResponse() in testResponseTimeout()
214 server.enqueue(new MockResponse().setSocketPolicy(SocketPolicy.DISCONNECT_AT_START)); in testDisconnectAtStart()
215 server.enqueue(new MockResponse()); // The jdk's HttpUrlConnection is a bastard. in testDisconnectAtStart()
216 server.enqueue(new MockResponse()); in testDisconnectAtStart()
[all …]
|
| /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| D | MockWebServerTest.java | 84 server.enqueue(new MockResponse().setBody("hello world")); in regularResponse()
100 server.enqueue(new MockResponse() in redirect()
104 server.enqueue(new MockResponse().setBody("This is the new location!")); in redirect()
128 server.enqueue(new MockResponse().setBody("enqueued in the background")); in dispatchBlocksWaitingForEnqueue()
139 server.enqueue(new MockResponse() in nonHexadecimalChunkSize()
154 server.enqueue(new MockResponse() in responseTimeout()
158 server.enqueue(new MockResponse().setBody("DEF")); in responseTimeout()
184 server.enqueue(new MockResponse().setSocketPolicy(SocketPolicy.DISCONNECT_AT_START)); in disconnectAtStart()
185 server.enqueue(new MockResponse()); // The jdk's HttpUrlConnection is a bastard. in disconnectAtStart()
186 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 __anona7df68170111::DFS
79 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anona7df68170111::BFS
117 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anona7df68170211::BFSBlockDFSContents
206 enqueue(DstBegin); in ExecuteWorkList()
332 enqueue(dstNodes); in HandleBlockEdge()
484 enqueue(Dst); in HandleBranch()
496 enqueue(Dst); in HandleCleanupTemporaryBranch()
507 enqueue(Dst); in HandleStaticInit()
541 if (IsNew) WList->enqueue(Node); in generateNode()
553 WList->enqueue(N, Block, Idx); 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()
|