/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ref/ |
D | ReferenceQueueTest.java | 70 assertNull(rq.poll()); in test_poll() 76 assertTrue("Remove failed.", ((Boolean) rq.poll().get()) in test_poll() 83 assertEquals("Remove failed.", obj, (rq.poll().get())); in test_poll() 89 assertNull("Remove failed.", rq.poll().get()); in test_poll() 94 assertNull(rq.poll()); in test_poll() 101 assertNull(rq.poll()); in test_poll() 121 assertNull(rq.poll()); in test_remove() 148 assertNull(rq.poll()); in test_remove() 156 assertNull("Queue should be empty. (poll)", rq.poll()); in test_removeJ() 195 assertNull(rq.poll()); in test_removeJ() [all …]
|
D | ReferenceTest.java | 94 assertTrue("Not properly enqueued.", rq.poll().get() == obj); in test_enqueue() 98 && (rq.poll() == null)); in test_enqueue() 106 assertTrue("Not properly enqueued2.", rq.poll().get() == obj); in test_enqueue() 110 && (rq.poll() == null)); in test_enqueue() 115 assertNull("Not properly enqueued3.", rq.poll().get()); in test_enqueue() 119 && (rq.poll() == null)); in test_enqueue() 140 ref = queue.poll(); in test_get_WeakReference() 250 rq.poll(); in test_isEnqueued()
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
D | LinkedTransferQueueTest.java | 127 assertEquals(ints[i], q.poll()); in testConstructor5() 187 assertEquals(ints[i], q.poll()); in testAddAll5() 252 assertEquals(i, (int) q.poll()); in testPoll() 254 assertNull(q.poll()); in testPoll() 264 assertEquals(i, (int) q.poll(0, MILLISECONDS)); in testTimedPoll0() 266 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0() 277 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll() 281 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll() 297 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll() 300 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll() [all …]
|
D | PriorityBlockingQueueTest.java | 144 assertEquals(ints[i], q.poll()); in testConstructor6() 159 assertEquals(ints[i], q.poll()); in testConstructor7() 264 assertEquals(ints[i], q.poll()); in testAddAll5() 362 assertEquals(i, q.poll()); in testPoll() 364 assertNull(q.poll()); in testPoll() 373 assertEquals(i, q.poll(0, MILLISECONDS)); in testTimedPoll0() 375 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0() 385 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll() 389 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll() 405 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll() [all …]
|
D | DelayQueueTest.java | 201 assertEquals(ints[i], q.poll()); in testConstructor6() 294 assertEquals(ints[i], q.poll()); in testAddAll5() 392 assertEquals(new PDelay(i), q.poll()); in testPoll() 394 assertNull(q.poll()); in testPoll() 403 assertEquals(new PDelay(i), q.poll(0, MILLISECONDS)); in testTimedPoll0() 405 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0() 415 assertEquals(new PDelay(i), q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll() 419 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll() 436 ((PDelay)q.poll(LONG_DELAY_MS, MILLISECONDS))); in testInterruptedTimedPoll() 441 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll() [all …]
|
D | ExecutorCompletionServiceTest.java | 125 assertNull(ecs.poll()); in testPoll1() 131 while ((f = ecs.poll()) == null) { in testPoll1() 148 assertNull(ecs.poll()); in testPoll2() 151 Future f = ecs.poll(SHORT_DELAY_MS, MILLISECONDS); in testPoll2() 177 assertNull(ecs.poll()); in testNewTaskForCallable() 208 assertNull(ecs.poll()); in testNewTaskForRunnable()
|
D | LinkedBlockingQueueTest.java | 136 assertEquals(ints[i], q.poll()); in testConstructor6() 248 assertEquals(ints[i], q.poll()); in testAddAll5() 409 assertEquals(i, q.poll()); in testPoll() 411 assertNull(q.poll()); in testPoll() 420 assertEquals(i, q.poll(0, MILLISECONDS)); in testTimedPoll0() 422 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0() 432 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll() 436 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll() 452 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll() 456 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll() [all …]
|
D | BlockingQueueTest.java | 206 assertSame(one, q.poll()); 222 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPollWithOffer() 227 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer() 231 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer() 238 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer() 308 q.poll(2 * LONG_DELAY_MS, MILLISECONDS); 330 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
|
D | ArrayBlockingQueueTest.java | 147 assertEquals(ints[i], q.poll()); in testConstructor7() 258 assertEquals(ints[i], q.poll()); in testAddAll5() 419 assertEquals(i, q.poll()); in testPoll() 421 assertNull(q.poll()); in testPoll() 430 assertEquals(i, q.poll(0, MILLISECONDS)); in testTimedPoll0() 432 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0() 443 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll() 447 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll() 463 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll() 467 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll() [all …]
|
D | PriorityQueueTest.java | 114 assertEquals(ints[i], q.poll()); in testConstructor6() 129 assertEquals(ints[i], q.poll()); in testConstructor7() 264 assertEquals(new Integer(i), q.poll()); in testAddAll5() 273 assertEquals(i, q.poll()); in testPoll() 275 assertNull(q.poll()); in testPoll() 285 assertEquals(i, q.poll()); in testPeek() 299 assertEquals(i, q.poll()); in testElement() 349 q.poll(); in testContains() 425 assertSame(o[i], q.poll()); in testToArray() 438 assertSame(ints[i], q.poll()); in testToArray2()
|
D | ConcurrentLinkedQueueTest.java | 96 assertEquals(ints[i], q.poll()); in testConstructor6() 230 assertEquals(ints[i], q.poll()); in testAddAll5() 239 assertEquals(i, q.poll()); in testPoll() 241 assertNull(q.poll()); in testPoll() 251 assertEquals(i, q.poll()); in testPeek() 265 assertEquals(i, q.poll()); in testElement() 315 q.poll(); in testContains() 390 assertSame(o[i], q.poll()); in testToArray() 402 assertSame(ints[i], q.poll()); in testToArray2()
|
D | SynchronousQueueTest.java | 221 assertNull(q.poll()); in testPoll() 231 try { assertNull(q.poll(0, MILLISECONDS)); } in testTimedPoll0() 243 try { assertNull(q.poll(timeoutMillis(), MILLISECONDS)); } in testTimedPoll() 261 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPollWithOffer() 266 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer() 270 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer() 277 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer() 512 assertNull(q.poll()); 514 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
|
D | LinkedListTest.java | 71 assertEquals(ints[i], q.poll()); in testConstructor6() 156 assertEquals(ints[i], q.poll()); in testAddAll5() 193 assertEquals(i, q.poll()); in testPoll() 195 assertNull(q.poll()); in testPoll() 205 assertEquals(i, q.poll()); in testPeek() 219 assertEquals(i, q.poll()); in testElement() 269 q.poll(); in testContains() 344 assertSame(o[i], q.poll()); in testToArray() 356 assertSame(ints[i], q.poll()); in testToArray2()
|
D | AbstractQueueTest.java | 36 public Integer poll() { return one; } in poll() method in AbstractQueueTest.Succeed 47 public Integer poll() { return null; } in poll() method in AbstractQueueTest.Fail
|
D | LinkedBlockingDequeTest.java | 392 assertEquals(ints[i], q.poll()); in testConstructor6() 556 assertEquals(ints[i], q.poll()); in testAddAll5() 717 assertEquals(i, q.poll()); in testPoll() 719 assertNull(q.poll()); in testPoll() 728 assertEquals(i, q.poll(0, MILLISECONDS)); in testTimedPoll0() 730 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0() 740 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll() 744 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll() 760 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll() 764 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll() [all …]
|
/libcore/luni/src/main/java/java/util/concurrent/ |
D | ExecutorCompletionService.java | 169 public Future<V> poll() { in poll() method in ExecutorCompletionService 170 return completionQueue.poll(); in poll() 173 public Future<V> poll(long timeout, TimeUnit unit) in poll() method in ExecutorCompletionService 175 return completionQueue.poll(timeout, unit); in poll()
|
D | CompletionService.java | 78 Future<V> poll(); in poll() method 94 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; in poll() method
|
D | DelayQueue.java | 160 public E poll() { in poll() method in DelayQueue 167 : q.poll(); in poll() 191 return q.poll(); in take() 224 public E poll(long timeout, TimeUnit unit) throws InterruptedException { in poll() method in DelayQueue 239 return q.poll(); in poll() 323 q.poll(); in drainTo() 351 q.poll(); in drainTo()
|
D | BlockingDeque.java | 509 E poll(); in poll() method 535 E poll(long timeout, TimeUnit unit) in poll() method
|
/libcore/ojluni/src/main/java/java/util/ |
D | AbstractQueue.java | 112 E x = poll(); in remove() 146 while (poll() != null) in clear()
|
D | Queue.java | 189 E poll(); in poll() method
|
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/ |
D | PriorityQueueTest.java | 137 assertEquals(newArray[i], integerQueue.poll()); in test_iterator_remove() 278 assertEquals(array[i], integerQueue.poll()); in test_ConstructorLjava_util_Colleciton() 327 assertEquals(queue.poll(), constructedQueue.poll()); in test_ConstructorLjava_util_Colleciton_from_priorityqueue() 346 assertEquals(iter.next(), queue.poll()); in test_ConstructorLjava_util_Colleciton_from_sortedset() 367 assertEquals(array[i], objectQueue.poll()); in test_ConstructorLjava_util_PriorityQueue() 396 assertEquals(iter.next(), queue.poll()); in test_ConstructorLjava_util_SortedSet() 424 assertEquals(sortedArray[i], queue.poll()); in test_offerLjava_lang_Object() 427 assertNull(queue.poll()); in test_offerLjava_lang_Object() 477 assertEquals(array[i], stringQueue.poll()); in test_poll() 480 assertNull(stringQueue.poll()); in test_poll() [all …]
|
/libcore/ojluni/src/main/native/ |
D | PollArrayWrapper.c | 57 int res = poll(fds, nfds, remaining); in ipoll() 86 RESTARTABLE (poll(a, numfds, timeout), err); in Java_sun_nio_ch_PollArrayWrapper_poll0()
|
/libcore/ojluni/src/main/java/sun/net/www/http/ |
D | KeepAliveStreamCleaner.java | 100 while ((kace = poll()) == null) { in run() 107 kace = poll(); in run()
|
/libcore/luni/src/test/java/libcore/java/util/ |
D | OldPriorityQueueTest.java | 118 assertEquals(i, (int) q.poll()); in test_removeAt_siftUp() 120 assertNull(q.poll()); in test_removeAt_siftUp()
|