| /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/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/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/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/tensorflow/tensorflow/python/kernel_tests/ |
| D | fifo_queue_test.py | 105 enqueue_op = q.enqueue((10.0,))
111 enqueue_op = q.enqueue((10.0,))
117 enqueue_correct_op = q.enqueue(([[1.0, 2.0], [3.0, 4.0], [5.0, 6.0]],))
120 q.enqueue(([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]],))
140 self.evaluate(q.enqueue(1))
142 self.evaluate(q2.enqueue(2))
150 q.enqueue({"a": 12.0})
158 enqueue_ops = [q.enqueue((x,)) for x in elems]
162 def enqueue(enqueue_op): function
167 target=enqueue, args=(e,)) for e in enqueue_ops
[all …]
|
| D | padding_fifo_queue_test.py | 102 enqueue_op = q.enqueue((10.0,))
109 enqueue_correct_op = q.enqueue(([[1.0, 2.0], [3.0, 4.0], [5.0, 6.0]],))
112 q.enqueue(([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]],))
126 enqueue_ops = [q.enqueue((x,)) for x in elems]
130 def enqueue(enqueue_op): function
135 target=enqueue, args=(e,)) for e in enqueue_ops
152 enqueue_ops = [q.enqueue((x,)) for x in elems]
176 enqueue_ops = [q.enqueue((x,)) for x in elems]
190 enqueue_ops = [q.enqueue((x,)) for x in elems]
193 def enqueue(): function
[all …]
|
| /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 __anon193623b90111::DFS
79 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anon193623b90111::BFS
117 void enqueue(const WorkListUnit& U) override { in enqueue() function in __anon193623b90211::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 | 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/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/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientHandlerTest.java | 195 ChannelFuture createFuture = enqueue( in cancelBufferedStreamShouldChangeClientStreamStatus()
284 = enqueue(new SendGrpcFrameCommand(streamTransportState, content(), true)); in sendFrameShouldSucceed()
296 = enqueue(new SendGrpcFrameCommand(streamTransportState, content(), true)); in sendForUnknownStreamShouldFail()
331 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldCancelBufferedStream()
342 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldRefuseLaterStreamId()
350 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldNotAffectEarlyStreamId()
361 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedResetWithRefuseCode()
369 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedResetWithCanceCode()
377 enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldFailUnknownStreams()
392 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldFailUnknownBufferedStreams()
[all …]
|
| /external/tensorflow/tensorflow/python/kernel_tests/random/ |
| D | random_shuffle_queue_test.py | 53 enqueue_op = q.enqueue((10.0,))
62 enqueue_correct_op = q.enqueue(([[1.0, 2.0], [3.0, 4.0], [5.0, 6.0]],))
66 q.enqueue(([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]],))
77 q2.enqueue(([1, 2, 3],))
85 q.enqueue([9, [10]]).run()
101 enqueue_ops = [q.enqueue((x,)) for x in elems]
105 def enqueue(enqueue_op): function
110 target=enqueue, args=(e,)) for e in enqueue_ops
127 enqueue_ops = [q.enqueue((x,)) for x in elems]
151 enqueue_ops = [q.enqueue((x,)) for x in elems]
[all …]
|
| /external/opencensus-java/impl/src/main/java/io/opencensus/impl/internal/ |
| D | DisruptorEventQueue.java | 139 public void enqueue(Entry entry) { in create()
167 public void enqueue(Entry entry) { in enqueue() method in DisruptorEventQueue
168 enqueuer.enqueue(entry); in enqueue()
179 public void enqueue(Entry entry) { in shutdown()
192 public abstract void enqueue(Entry entry); in enqueue() method in DisruptorEventQueue.DisruptorEnqueuer
|