| /external/deqp/executor/ |
| xeCallQueue.cpp | 78 // \note Enqueue lock is not held during call so it is possible to enqueue more work from dispatched call.
133 void CallQueue::enqueue (Call* call) function in class:xe::CallQueue
240 void CallWriter::enqueue (void) function in class:xe::CallWriter
243 m_queue->enqueue(m_call);
|
| /external/deqp/framework/platform/android/ |
| tcuAndroidRenderActivity.cpp | 98 enqueue(Message(MESSAGE_FINISH));
106 void RenderThread::enqueue (const Message& message) function in class:tcu::Android::RenderThread
115 enqueue(Message(MESSAGE_PAUSE));
120 enqueue(Message(MESSAGE_RESUME));
126 enqueue(Message(MESSAGE_SYNC, &waitSem));
358 m_thread->enqueue(Message(MESSAGE_WINDOW_CREATED, window));
364 m_thread->enqueue(Message(MESSAGE_WINDOW_RESIZED, window));
375 m_thread->enqueue(Message(MESSAGE_WINDOW_DESTROYED, window));
382 m_thread->enqueue(Message(MESSAGE_INPUT_QUEUE_CREATED, queue));
388 m_thread->enqueue(Message(MESSAGE_INPUT_QUEUE_DESTROYED, queue))
[all...] |
| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| NettyHttpClient.java | 91 @Override public void enqueue(HttpUrl url) throws Exception { method in class:NettyHttpClient
99 backlog.add(url); // Enqueue this for later, to be picked up when another request completes.
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| Dispatcher.java | 107 synchronized void enqueue(AsyncCall call) { method in class:Dispatcher
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| SocksProxyTest.java | 48 server.enqueue(new MockResponse().setBody("abc"));
49 server.enqueue(new MockResponse().setBody("def"));
67 server.enqueue(new MockResponse().setBody("abc"));
91 server.enqueue(new MockResponse().setBody("abc"));
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| HttpOverHttp2Test.java | 42 server.enqueue(response);
66 server.enqueue(response);
92 server.enqueue(new MockResponse().withSettings(settings));
96 server.enqueue(new MockResponse().setBody("ABC"));
97 server.enqueue(new MockResponse().setBody("DEF"));
98 server.enqueue(new MockResponse().setBody("GHI"));
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| DisconnectTest.java | 77 server.enqueue(new MockResponse()
103 server.enqueue(new MockResponse()
|
| ThreadInterruptTest.java | 79 server.enqueue(new MockResponse()
105 server.enqueue(new MockResponse()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/tls/ |
| CertificatePinnerChainValidationTest.java | 77 server.enqueue(new MockResponse()
87 server.enqueue(new MockResponse()
132 server.enqueue(new MockResponse()
142 server.enqueue(new MockResponse()
204 server.enqueue(new MockResponse()
278 server.enqueue(new MockResponse()
|
| /external/tensorflow/tensorflow/java/src/test/java/org/tensorflow/ |
| OperationBuilderTest.java | 204 Operation enqueue = local
205 g.opBuilder("QueueEnqueue", "enqueue")
209 assertTrue(hasNode(g, "enqueue"));
211 s.runner().addTarget(enqueue).run();
|
| /frameworks/base/core/java/android/speech/tts/ |
| AudioPlaybackHandler.java | 49 public void enqueue(PlaybackQueueItem item) { method in class:AudioPlaybackHandler
|
| /frameworks/support/asynclayoutinflater/src/main/java/androidx/asynclayoutinflater/view/ |
| AsyncLayoutInflater.java | 92 mInflateThread.enqueue(request);
223 public void enqueue(InflateRequest request) { method in class:AsyncLayoutInflater.InflateThread
228 "Failed to enqueue async inflate request", e);
|
| /frameworks/support/work/workmanager/src/androidTest/java/androidx/work/impl/ |
| WorkManagerImplLargeExecutorTest.java | 174 continuation.enqueue();
|
| /libcore/luni/src/test/java/libcore/java/lang/ref/ |
| ReferenceQueueTest.java | 65 enqueue(referenceQueue);
71 enqueue(referenceQueue);
132 enqueue(queue);
137 private void enqueue(ReferenceQueue<Object> queue) { method in class:ReferenceQueueTest
138 new WeakReference<Object>(new Object(), queue).enqueue();
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| OldCookieHandlerTest.java | 58 server.enqueue(new MockResponse().addHeader("Set-Cookie2: a=\"android\"; "
|
| /libcore/ojluni/src/main/java/java/lang/ref/ |
| ReferenceQueue.java | 57 * Enqueue the given reference onto this queue.
104 * Enqueue the reference object on the receiver.
110 boolean enqueue(Reference<? extends T> reference) { method in class:ReferenceQueue
213 * Enqueue the given list of currently pending (unenqueued) references.
231 // synchronization on the same queue by batching enqueue of
|
| /prebuilts/go/darwin-x86/src/runtime/ |
| chan.go | 196 // Space is available in the channel buffer. Enqueue the element to send.
233 c.sendq.enqueue(mysg)
517 c.recvq.enqueue(mysg)
559 // head of the queue. Make the sender enqueue
688 func (q *waitq) enqueue(sgp *sudog) { func
|
| /prebuilts/go/linux-x86/src/runtime/ |
| chan.go | 196 // Space is available in the channel buffer. Enqueue the element to send.
233 c.sendq.enqueue(mysg)
517 c.recvq.enqueue(mysg)
559 // head of the queue. Make the sender enqueue
688 func (q *waitq) enqueue(sgp *sudog) { func
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ref/ |
| ReferenceTest.java | 52 public boolean enqueue() { method in class:ReferenceTest.TestWeakReference
54 return super.enqueue();
86 * java.lang.ref.Reference#enqueue()
92 assertTrue("Enqueue failed.", (!ref.isEnqueued())
93 && ((ref.enqueue()) && (ref.isEnqueued())));
97 assertTrue("Can not enqueue twice.", (!ref.enqueue())
104 assertTrue("Enqueue failed2.", (!ref.isEnqueued())
105 && ((ref.enqueue()) && (ref.isEnqueued())));
109 assertTrue("Can not enqueue twice2.", (!ref.enqueue()
[all...] |
| /cts/hostsidetests/appsecurity/test-apps/ExternalStorageApp/src/com/android/cts/externalstorageapp/ |
| ExternalStorageTest.java | 110 dm.enqueue(new Request(source).setDestinationUri(Uri.fromFile(target)));
130 final long id = dm.enqueue(new Request(source).setDestinationUri(Uri.fromFile(target)));
|
| /cts/tests/JobSchedulerSharedUid/src/android/jobscheduler/cts/shareduidtests/ |
| EnqueueJobWorkTest.java | 32 * Schedules jobs with the {@link android.app.job.JobScheduler} by enqueue work in to
113 mJobScheduler.enqueue(mBuilder.setOverrideDeadline(0).build(), new JobWorkItem(work1));
142 mJobScheduler.enqueue(ji, new JobWorkItem(work1));
143 mJobScheduler.enqueue(ji, new JobWorkItem(work2));
144 mJobScheduler.enqueue(ji, new JobWorkItem(work3));
145 mJobScheduler.enqueue(ji, new JobWorkItem(work4));
146 mJobScheduler.enqueue(ji, new JobWorkItem(work5));
147 mJobScheduler.enqueue(ji, new JobWorkItem(work6));
148 mJobScheduler.enqueue(ji, new JobWorkItem(work7));
149 mJobScheduler.enqueue(ji, new JobWorkItem(work8))
[all...] |
| /cts/tests/tests/net/src/android/net/http/cts/ |
| HttpResponseCacheTest.java | 132 server.enqueue(new MockResponse()
|
| /external/clang/lib/StaticAnalyzer/Core/ |
| CoreEngine.cpp | 51 void enqueue(const WorkListUnit& U) override {
79 void enqueue(const WorkListUnit& U) override {
117 void enqueue(const WorkListUnit& U) override {
206 enqueue(DstBegin);
316 // This path is done. Don't enqueue any more nodes.
331 // Enqueue nodes onto the worklist.
332 enqueue(dstNodes);
483 // Enqueue the new frontier onto the worklist.
484 enqueue(Dst);
495 // Enqueue the new frontier onto the worklist
608 void CoreEngine::enqueue(ExplodedNodeSet &Set) { function in class:CoreEngine
615 void CoreEngine::enqueue(ExplodedNodeSet &Set, function in class:CoreEngine
[all...] |
| /external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
| TensorDeviceThreadPool.h | 152 EIGEN_STRONG_INLINE Notification* enqueue(Function&& f, Args&&... args) const { function in struct:Eigen::ThreadPoolDevice
|
| /external/guava/guava/src/com/google/common/base/ |
| FinalizableReferenceQueue.java | 98 * will reclaim it and enqueue the phantom reference. The enqueued reference will trigger the
178 frqRef.enqueue();
|
