| /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()
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 | 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 | 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/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/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 …]
|
| D | HttpOverHttp2Test.java | 42 server.enqueue(response); in serverSendsPushPromise_GET()
66 server.enqueue(response); in serverSendsPushPromise_HEAD()
92 server.enqueue(new MockResponse().withSettings(settings)); in settingsLimitsMaxConcurrentStreams()
96 server.enqueue(new MockResponse().setBody("ABC")); in settingsLimitsMaxConcurrentStreams()
97 server.enqueue(new MockResponse().setBody("DEF")); in settingsLimitsMaxConcurrentStreams()
98 server.enqueue(new MockResponse().setBody("GHI")); in settingsLimitsMaxConcurrentStreams()
|
| /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 | 103 enqueue_op = q.enqueue((10.0,))
109 enqueue_op = q.enqueue((10.0,))
115 enqueue_correct_op = q.enqueue(([[1.0, 2.0], [3.0, 4.0], [5.0, 6.0]],))
118 q.enqueue(([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]],))
139 q.enqueue({"a": 12.0})
147 enqueue_ops = [q.enqueue((x,)) for x in elems]
151 def enqueue(enqueue_op): function
156 target=enqueue, args=(e,)) for e in enqueue_ops
173 enqueue_ops = [q.enqueue((x,)) for x in elems]
197 enqueue_ops = [q.enqueue((x,)) for x in elems]
[all …]
|
| D | padding_fifo_queue_test.py | 100 enqueue_op = q.enqueue((10.0,))
107 enqueue_correct_op = q.enqueue(([[1.0, 2.0], [3.0, 4.0], [5.0, 6.0]],))
110 q.enqueue(([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]],))
124 enqueue_ops = [q.enqueue((x,)) for x in elems]
128 def enqueue(enqueue_op): function
133 target=enqueue, args=(e,)) for e in enqueue_ops
150 enqueue_ops = [q.enqueue((x,)) for x in elems]
174 enqueue_ops = [q.enqueue((x,)) for x in elems]
188 enqueue_ops = [q.enqueue((x,)) for x in elems]
191 def enqueue(): function
[all …]
|
| D | priority_queue_test.py | 46 q.enqueue((e, constant_op.constant(v0), constant_op.constant(v1)))
78 q.enqueue((e, constant_op.constant(v0), constant_op.constant(v1)))
83 def enqueue(enqueue_op): function
90 target=enqueue, args=(op,)) for op in enqueue_ops
134 def enqueue(enqueue_op): function
146 target=enqueue, args=(op,)) for op in enqueue_ops
186 def enqueue(enqueue_op): function
199 target=enqueue, args=(op,)) for op in enqueue_ops
238 def enqueue(enqueue_op): function
245 target=enqueue, args=(op,)) for op in enqueue_ops
[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/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/clang/lib/StaticAnalyzer/Core/ |
| D | CoreEngine.cpp | 51 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anonc05d90ad0111::DFS
79 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anonc05d90ad0111::BFS
117 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anonc05d90ad0211::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/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| D | MockWebServerTest.java | 83 server.enqueue(new MockResponse().setBody("hello world")); in regularResponse()
99 server.enqueue(new MockResponse() in redirect()
103 server.enqueue(new MockResponse().setBody("This is the new location!")); in redirect()
127 server.enqueue(new MockResponse().setBody("enqueued in the background")); in dispatchBlocksWaitingForEnqueue()
138 server.enqueue(new MockResponse() in nonHexadecimalChunkSize()
153 server.enqueue(new MockResponse() in responseTimeout()
157 server.enqueue(new MockResponse().setBody("DEF")); in responseTimeout()
183 server.enqueue(new MockResponse().setSocketPolicy(SocketPolicy.DISCONNECT_AT_START)); in disconnectAtStart()
184 server.enqueue(new MockResponse()); // The jdk's HttpUrlConnection is a bastard. in disconnectAtStart()
185 server.enqueue(new MockResponse()); in disconnectAtStart()
[all …]
|
| /external/okhttp/okhttp-logging-interceptor/src/test/java/com/squareup/okhttp/logging/ |
| D | HttpLoggingInterceptorTest.java | 100 server.enqueue(new MockResponse()); in none()
110 server.enqueue(new MockResponse()); in basicGet()
127 server.enqueue(new MockResponse()); in basicPost()
144 server.enqueue(new MockResponse() in basicResponseBody()
164 server.enqueue(new MockResponse()); in headersGet()
196 server.enqueue(new MockResponse()); in headersPost()
233 server.enqueue(new MockResponse()); in headersPostNoContentType()
268 server.enqueue(new MockResponse()); in headersPostNoLength()
312 server.enqueue(new MockResponse() in headersResponseBody()
348 server.enqueue(new MockResponse()); in bodyGet()
[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/tensorflow/tensorflow/python/kernel_tests/random/ |
| D | random_shuffle_queue_test.py | 51 enqueue_op = q.enqueue((10.0,))
60 enqueue_correct_op = q.enqueue(([[1.0, 2.0], [3.0, 4.0], [5.0, 6.0]],))
64 q.enqueue(([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]],))
75 q2.enqueue(([1, 2, 3],))
83 q.enqueue([9, [10]]).run()
99 enqueue_ops = [q.enqueue((x,)) for x in elems]
103 def enqueue(enqueue_op): function
108 target=enqueue, args=(e,)) for e in enqueue_ops
125 enqueue_ops = [q.enqueue((x,)) for x in elems]
149 enqueue_ops = [q.enqueue((x,)) for x in elems]
[all …]
|
| /external/clang/test/SemaOpenCL/ |
| D | cl20-device-side-enqueue.cl | 33 …drange, ^(int i) { // expected-error{{blocks in this form of device side enqueue call are expected…
87 …nge, block_B, 1024, 1024); // expected-error{{blocks used in device side enqueue are expected to h…
144 …up_size(^(local int *a) { // expected-error {{blocks used in device side enqueue are expected to h…
147 …rk_group_size(block_B); // expected-error {{blocks used in device side enqueue are expected to h…
148 …rk_group_size(block_D); // expected-error {{blocks used in device side enqueue are expected to h…
149 …rk_group_size(^(int a) { // expected-error {{blocks used in device side enqueue are expected to h…
161 …ultiple(^(local int *a) { // expected-error {{blocks used in device side enqueue are expected to h…
164 …size_multiple(^(int a) { // expected-error {{blocks used in device side enqueue are expected to h…
167 …size_multiple(block_B); // expected-error {{blocks used in device side enqueue are expected to h…
168 …size_multiple(block_D); // expected-error {{blocks used in device side enqueue are expected to h…
|
| /external/tensorflow/tensorflow/docs_src/api_guides/python/ |
| D | threading_and_queues.md | 19 enqueue new items in to the queue, or dequeue existing items from the
22 when it is empty, or enqueue to it when it is full. When that condition no
40 created by calling methods on a queue object (e.g. `q.enqueue(...)`).
42 Note: Queue methods (such as `q.enqueue(...)`) *must* run on the same device
58 * Multiple threads prepare training examples and enqueue them.
80 # Create an op to enqueue one item.
81 enqueue = queue.enqueue(source)
84 # that enqueue op.
86 qr = tf.train.QueueRunner(queue, [enqueue] * num_threads)
147 enqueue tensors in the same queue.
[all …]
|