HomeSort by relevance Sort by last modified time
    Searched defs:enqueue (Results 101 - 125 of 283) sorted by null

1 2 3 45 6 7 8 91011>>

  /external/vogar/src/vogar/
Driver.java 81 run.taskQueue.enqueue(prepareTargetTask);
156 run.taskQueue.enqueue(build);
160 run.taskQueue.enqueue(prepareUserDir);
173 run.taskQueue.enqueue(execute);
176 run.taskQueue.enqueue(retrieveFiles);
179 run.taskQueue.enqueue(new RmTask(run.rm, run.localFile(action))
  /frameworks/base/core/tests/coretests/src/android/net/http/
AbstractProxyTest.java 63 server.enqueue(new MockResponse()
116 server.enqueue(mockResponse);
152 server.enqueue(new MockResponse()
155 server.enqueue(new MockResponse()
191 server.enqueue(new MockResponse().setBody("Via request parameter proxy!"));
207 server.enqueue(new MockResponse().setBody("Via the origin server!"));
224 server.enqueue(new MockResponse()
  /frameworks/support/samples/Support7Demos/src/main/java/com/example/android/supportv7/media/
RemotePlayer.java 282 // enqueue & remove are only supported if isQueuingSupported() returns true
284 public void enqueue(final PlaylistItem item) { method in class:RemotePlayer
363 Log.d(TAG, "enqueue: item=" + item);
365 mClient.enqueue(item.getUri(), "video/mp4", null, 0, null, new ItemActionCallback() {
369 logStatus("enqueue: succeeded", sessionId, sessionStatus, itemId, itemStatus);
393 logError("enqueue: failed", error, code);
  /libcore/support/src/test/java/tests/http/
MockWebServer.java 144 public void enqueue(MockResponse response) { method in class:MockWebServer
  /packages/services/Telephony/src/com/android/phone/vvm/
RemoteVvmTaskManager.java 285 public void enqueue(Message message) { method in class:RemoteVvmTaskManager.RemoteServiceConnection
355 mConnection.enqueue(message);
  /cts/tests/JobScheduler/src/android/jobscheduler/
MockJobService.java 213 js.enqueue(ji, new JobWorkItem(sub[subi].intent));
  /cts/tests/JobSchedulerSharedUid/src/android/jobscheduler/
MockJobService.java 213 js.enqueue(ji, new JobWorkItem(sub[subi].intent));
  /external/mockwebserver/src/main/java/com/google/mockwebserver/
MockWebServer.java 190 public void enqueue(MockResponse response) { method in class:MockWebServer
585 * a {@link #enqueue(MockResponse) queue}; custom dispatchers can vary the
  /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/
MockWebServerTest.java 83 server.enqueue(new MockResponse().setBody("hello world"));
99 server.enqueue(new MockResponse()
103 server.enqueue(new MockResponse().setBody("This is the new location!"));
117 * Test that MockWebServer blocks for a call to enqueue() if a request
127 server.enqueue(new MockResponse().setBody("enqueued in the background"));
138 server.enqueue(new MockResponse()
153 server.enqueue(new MockResponse()
157 server.enqueue(new MockResponse().setBody("DEF"));
183 server.enqueue(new MockResponse().setSocketPolicy(SocketPolicy.DISCONNECT_AT_START));
184 server.enqueue(new MockResponse()); // The jdk's HttpUrlConnection is a bastard
    [all...]
  /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
CallTest.java 111 server.enqueue(new MockResponse().setBody("abc").addHeader("Content-Type: text/plain"));
132 server.enqueue(new MockResponse());
164 server.enqueue(new MockResponse().setResponseCode(500));
191 server.enqueue(new MockResponse()
220 server.enqueue(new MockResponse());
230 server.enqueue(new MockResponse().addHeader("Content-Type: text/plain"));
265 server.enqueue(new MockResponse().setBody("abc"));
299 server.enqueue(new MockResponse().setBody("abc"));
372 server.enqueue(new MockResponse().setResponseCode(401));
373 server.enqueue(new MockResponse())
    [all...]
  /external/python/cpython3/Lib/logging/
handlers.py 1329 def enqueue(self, record): member in class:QueueHandler
    [all...]
  /external/swiftshader/third_party/LLVM/lib/CodeGen/
RegAllocGreedy.cpp 240 virtual void enqueue(LiveInterval *LI);
376 enqueue(&LI);
400 void RAGreedy::enqueue(LiveInterval *LI) { function in class:RAGreedy
406 "Can only enqueue virtual registers");
489 /// defined by enqueue() decides which registers ultimately end up being split
    [all...]
  /external/tensorflow/tensorflow/python/kernel_tests/
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 in function:FIFOQueueTest.testParallelEnqueue
156 target=enqueue, args=(e,)) for e in enqueue_ops
173 enqueue_ops = [q.enqueue((x,)) for x in elems]
176 # Enqueue every element using a single thread
228 def enqueue(): function in function:FIFOQueueTest.testEnqueueAndBlockingDequeue
521 def enqueue(): function in function:FIFOQueueTest.testParallelEnqueueMany
587 def enqueue(): function in function:FIFOQueueTest.testParallelEnqueueAndDequeue
655 def enqueue(): function in function:FIFOQueueTest.testMixtureOfDequeueAndDequeueMany
690 def enqueue(): function in function:FIFOQueueTest.testBlockingDequeueMany
717 def enqueue(): function in function:FIFOQueueTest.testBlockingDequeueUpTo
905 def enqueue(): function in function:FIFOQueueTest.testEnqueueManyLargerThanCapacityWithConcurrentDequeueMany
    [all...]
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 in function:PaddingFIFOQueueTest.testParallelEnqueue
133 target=enqueue, args=(e,)) for e in enqueue_ops
150 enqueue_ops = [q.enqueue((x,)) for x in elems]
153 # Enqueue every element using a single thread.
174 enqueue_ops = [q.enqueue((x,)) for x in elems]
188 enqueue_ops = [q.enqueue((x,)) for x in elems
191 def enqueue(): function in function:PaddingFIFOQueueTest.testEnqueueAndBlockingDequeue
635 def enqueue(): function in function:PaddingFIFOQueueTest.testParallelEnqueueMany
701 def enqueue(): function in function:PaddingFIFOQueueTest.testParallelEnqueueAndDequeue
769 def enqueue(): function in function:PaddingFIFOQueueTest.testMixtureOfDequeueAndDequeueMany
804 def enqueue(): function in function:PaddingFIFOQueueTest.testBlockingDequeueMany
831 def enqueue(): function in function:PaddingFIFOQueueTest.testBlockingDequeueUpTo
1019 def enqueue(): function in function:PaddingFIFOQueueTest.testEnqueueManyLargerThanCapacityWithConcurrentDequeueMany
    [all...]
  /frameworks/av/packages/MediaComponents/src/com/android/support/mediarouter/media/
RemotePlaybackClient.java 128 * at a time and the {@link #enqueue} method will not be available.
132 * {@link MediaControlIntent#ACTION_ENQUEUE enqueue},
200 * {@link #play}, {@link #enqueue}, and {@link #startSession}.
292 * Sends a request to enqueue a media item.
304 * @param contentUri The content Uri to enqueue.
320 public void enqueue(Uri contentUri, String mimeType, Bundle metadata, method in class:RemotePlaybackClient
    [all...]
  /frameworks/support/compat/src/main/java/androidx/core/app/
JobIntentService.java 44 * as a job via {@link android.app.job.JobScheduler#enqueue JobScheduler.enqueue}. When running
52 * <p>Use {@link #enqueueWork(Context, Class, int, Intent)} to enqueue new work to be
59 * you enqueue work until the job has been dispatched and while it is running). When running
343 mJobScheduler.enqueue(mJobInfo, new JobWorkItem(work));
486 * Call this to enqueue work for your subclass of {@link JobIntentService}. This will
487 * either directly start the service (when running on pre-O platforms) or enqueue work
489 * held for you to ensure you continue running. The work you enqueue will ultimately
497 * @param work The Intent of work to enqueue.
513 * @param work The Intent of work to enqueue
    [all...]
  /frameworks/support/mediarouter/src/main/java/androidx/mediarouter/media/
RemotePlaybackClient.java 129 * at a time and the {@link #enqueue} method will not be available.
133 * {@link MediaControlIntent#ACTION_ENQUEUE enqueue},
201 * {@link #play}, {@link #enqueue}, and {@link #startSession}.
293 * Sends a request to enqueue a media item.
305 * @param contentUri The content Uri to enqueue.
321 public void enqueue(Uri contentUri, String mimeType, Bundle metadata, method in class:RemotePlaybackClient
    [all...]
  /libcore/ojluni/src/main/java/java/util/concurrent/
LinkedBlockingQueue.java 198 private void enqueue(Node<E> node) { method in class:LinkedBlockingQueue
287 enqueue(new Node<E>(e)); method
352 enqueue(node);
387 enqueue(new Node<E>(e)); method
421 enqueue(node);
    [all...]
  /packages/apps/KeyChain/tests/src/com/android/keychain/tests/
KeyChainTestActivity.java 203 server.enqueue(new MockResponse().setBody("this response comes via HTTPS"));
  /external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/
ResponseCacheTest.java 195 server.enqueue(mockResponse);
236 server.enqueue(mockResponse);
260 server.enqueue(new MockResponse()
290 server.enqueue(new MockResponse()
295 server.enqueue(new MockResponse()
299 server.enqueue(new MockResponse()
310 server.enqueue(new MockResponse()
313 server.enqueue(new MockResponse()
316 server.enqueue(new MockResponse()
338 server.enqueue(new MockResponse(
    [all...]
  /libcore/luni/src/test/java/libcore/java/net/
SocketTest.java 276 server.enqueue(new byte[]{5, 3}, 0);
298 server.enqueue(new byte[0], 3);
494 public Future<byte[]> enqueue(final byte[] sendBytes, final int receiveByteCount) method in class:SocketTest.MockServer
  /cts/apps/CtsVerifier/src/com/android/cts/verifier/security/
KeyChainTest.java 327 server.enqueue(new MockResponse().setBody("this response comes via HTTPS"));
  /developers/build/prebuilts/gradle/MediaRouter/Application/src/main/java/com/example/android/mediarouter/player/
LocalPlayer.java 203 public void enqueue(final PlaylistItem item) { method in class:LocalPlayer
204 throw new UnsupportedOperationException("LocalPlayer doesn't support enqueue!");
  /developers/samples/android/media/MediaRouter/Application/src/main/java/com/example/android/mediarouter/player/
LocalPlayer.java 203 public void enqueue(final PlaylistItem item) { method in class:LocalPlayer
204 throw new UnsupportedOperationException("LocalPlayer doesn't support enqueue!");
  /development/samples/browseable/MediaRouter/src/com.example.android.mediarouter/player/
LocalPlayer.java 203 public void enqueue(final PlaylistItem item) { method in class:LocalPlayer
204 throw new UnsupportedOperationException("LocalPlayer doesn't support enqueue!");

Completed in 1122 milliseconds

1 2 3 45 6 7 8 91011>>