| /development/samples/training/threadsample/src/com/example/android/threadsample/ |
| PhotoManager.java | 444 mPhotoTaskWorkQueue.offer(downloadTask);
|
| /external/guava/guava/src/com/google/common/collect/ |
| MinMaxPriorityQueue.java | 74 * <li>The enqueing and dequeing operations ({@link #offer}, {@link #add}, and
208 queue.offer(element);
251 offer(element);
258 offer(element);
270 @Override public boolean offer(E element) { method in class:MinMaxPriorityQueue
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| LinkedListTest.java | 28 assertTrue(q.offer(new Integer(i)));
93 * offer(null) succeeds
97 q.offer(null);
101 * Offer succeeds
105 assertTrue(q.offer(new Integer(0)));
106 assertTrue(q.offer(new Integer(1)));
|
| DelayQueueTest.java | 119 assertTrue(q.offer(new PDelay(i)));
121 assertTrue(q.offer(new PDelay(i)));
215 * offer non-null succeeds
219 assertTrue(q.offer(new PDelay(0)));
220 assertTrue(q.offer(new PDelay(1)));
306 * timed offer does not time out
314 assertTrue(q.offer(new PDelay(0), SHORT_DELAY_MS, MILLISECONDS));
315 assertTrue(q.offer(new PDelay(0), LONG_DELAY_MS, MILLISECONDS));
|
| LinkedBlockingDequeTest.java | 35 assertTrue(q.offer(new Integer(i)));
380 assertFalse(q.offer(three));
453 * Offer succeeds if not full; fails if full
457 assertTrue(q.offer(zero));
458 assertFalse(q.offer(one));
616 * timed offer times out if full and elements not taken
626 assertFalse(q.offer(new Object(), timeoutMillis(), MILLISECONDS));
630 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
[all...] |
| /packages/apps/Email/tests/src/com/android/email/ |
| ThrottleTest.java | 193 mTasks.offer(e);
|
| /external/chromium_org/third_party/libjingle/source/talk/session/media/ |
| call.h | 205 void IncomingSession(Session* session, const SessionDescription* offer);
207 bool AddSession(Session* session, const SessionDescription* offer);
|
| mediasession.h | 434 const SessionDescription* offer,
450 SessionDescription* offer) const;
|
| /external/chromium_org/third_party/libjingle/source/talk/session/tunnel/ |
| securetunnelsessionclient.cc | 290 const SessionDescription* offer) {
293 if (!FindSecureTunnelContent(offer, &content_name, &offer_tunnel))
|
| /frameworks/base/core/java/android/view/textservice/ |
| SpellCheckerSession.java | 408 mPendingTasks.offer(scp);
410 mPendingTasks.offer(closeTask);
|
| /packages/screensavers/PhotoTable/src/com/android/dreams/phototable/ |
| PhotoCarousel.java | 151 mBitmapQueue.offer(photo);
170 mBitmapLoaders.offer(task);
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/ |
| ArrayDequeTest.java | 411 * {@link java.util.ArrayDeque#offer(Object)}
414 assertTrue(testQue.offer(testObjOne));
415 assertTrue(testQue.offer(testObjTwo));
416 assertTrue(testQue.offer(testObjOne));
417 assertTrue(testQue.offer(testObjThree));
421 testQue.offer(null);
[all...] |
| /frameworks/wilhelm/tests/sandbox/ |
| playbq.c | 560 android::NBAIO_Format offer = nbaio_format; local
562 ssize_t neg = pipeWriter->negotiate(&offer, 1, NULL, numCounterOffers);
566 neg = pipeReader->negotiate(&offer, 1, NULL, numCounterOffers);
|
| playbq.cpp | 560 android::NBAIO_Format offer = nbaio_format; local
562 ssize_t neg = pipeWriter->negotiate(&offer, 1, NULL, numCounterOffers);
566 neg = pipeReader->negotiate(&offer, 1, NULL, numCounterOffers);
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| LinkedTransferQueue.java | 246 * of offer, put, poll, take, or transfer (each possibly with
270 * poll/offer, (argument "how" is NOW) return.
555 private static final int ASYNC = 1; // for offer, put, add
1021 public boolean offer(E e, long timeout, TimeUnit unit) { method in class:LinkedTransferQueue
1033 public boolean offer(E e) { method in class:LinkedTransferQueue
[all...] |
| ConcurrentLinkedQueue.java | 265 return offer(e);
291 * @return {@code true} (as specified by {@link Queue#offer})
294 public boolean offer(E e) { method in class:ConcurrentLinkedQueue
|
| LinkedBlockingQueue.java | 54 * entry to put (and offer), and has an associated condition for
128 /** Lock held by put, offer, etc */
135 * Signals a waiting take. Called only from put/offer (which do not
340 public boolean offer(E e, long timeout, TimeUnit unit) method in class:LinkedBlockingQueue
378 public boolean offer(E e) { method in class:LinkedBlockingQueue
|
| /external/google-tv-pairing-protocol/java/src/com/google/polo/pairing/ |
| PairingSession.java | 465 return mMessageQueue.offer(new QueueMessage(secret));
483 mMessageQueue.offer(new QueueMessage(exception));
|
| /external/smack/src/org/jivesoftware/smackx/bytestreams/ibb/ |
| InBandBytestreamSession.java | 470 dataQueue.offer(data);
525 dataQueue.offer(data);
|
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/security/ |
| CAInstallNotificationVerifierActivity.java | 75 sDeletedQueue.offer(intent.getAction());
|
| /cts/tests/tests/accessibilityservice/src/android/accessibilityservice/cts/ |
| AccessibilityFocusAndInputFocusSyncTest.java | 224 workQueue.offer(child);
|
| /developers/build/prebuilts/gradle/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/ |
| AsyncTask.java | 253 mTasks.offer(new Runnable() {
|
| /developers/samples/android/ui/graphics/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/ |
| AsyncTask.java | 253 mTasks.offer(new Runnable() {
|
| /development/samples/browseable/DisplayingBitmaps/src/com.example.android.displayingbitmaps/util/ |
| AsyncTask.java | 253 mTasks.offer(new Runnable() {
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| transport.cc | 321 // As Transport must know TD is offer or answer and cricket::Transport
775 // session renegotiation, the new offer will have the google-ice ICE option,
809 const TransportDescription* offer; local
813 offer = local_description_.get();
816 offer = remote_description_.get();
820 TransportProtocol offer_proto = TransportProtocolFromDescription(offer);
835 desc << "Offer and answer protocol mismatch: "
|
