Home
last modified time | relevance | path

Searched refs:poll (Results 1 – 25 of 98) sorted by relevance

1234

/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ref/
DReferenceQueueTest.java70 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 …]
DReferenceTest.java94 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/ojluni/src/main/java/sun/nio/fs/
DAbstractWatchService.java96 public final WatchKey poll() { in poll() method in AbstractWatchService
98 WatchKey key = pendingKeys.poll(); in poll()
104 public final WatchKey poll(long timeout, TimeUnit unit) in poll() method in AbstractWatchService
108 WatchKey key = pendingKeys.poll(timeout, unit); in poll()
/libcore/jsr166-tests/src/test/java/jsr166/
DLinkedTransferQueueTest.java128 assertEquals(ints[i], q.poll()); in testConstructor5()
188 assertEquals(ints[i], q.poll()); in testAddAll5()
253 assertEquals(i, (int) q.poll()); in testPoll()
255 assertNull(q.poll()); in testPoll()
265 assertEquals(i, (int) q.poll(0, MILLISECONDS)); in testTimedPoll0()
267 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0()
278 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
282 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll()
298 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
301 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
[all …]
DPriorityBlockingQueueTest.java144 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 …]
DDelayQueueTest.java201 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 …]
DExecutorCompletionServiceTest.java125 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()
DLinkedBlockingQueueTest.java136 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 …]
DBlockingQueueTest.java206 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);
DArrayBlockingQueueTest.java147 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 …]
DPriorityQueueTest.java114 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()
DConcurrentLinkedQueueTest.java96 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()
DSynchronousQueueTest.java221 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));
DLinkedListTest.java71 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()
/libcore/luni/src/test/java/libcore/java/nio/file/
DWatchServiceTest.java88 WatchKey watchKey = watchService.poll(2, TimeUnit.SECONDS); in assertWatchServiceEvent()
118 assertNull(watchService.poll()); in test_singleFile()
130 WatchKey doubleModifyKey = watchService.poll(); in test_singleFile()
136 assertNull(watchService.poll()); in test_singleFile()
144 assertNull(watchService.poll()); in test_singleFile()
167 assertNull(watchService.poll()); in test_EventMask()
194 assertNull(watchService.poll()); in test_singleDirectory()
226 assertNull(watchService.poll()); in test_cancel()
256 assertNull(watchService.poll()); in test_removeTarget()
292 assertNull(watchService1.poll()); in test_multipleKeys()
[all …]
/libcore/ojluni/src/main/java/java/util/concurrent/
DExecutorCompletionService.java198 public Future<V> poll() { in poll() method in ExecutorCompletionService
199 return completionQueue.poll(); in poll()
202 public Future<V> poll(long timeout, TimeUnit unit) in poll() method in ExecutorCompletionService
204 return completionQueue.poll(timeout, unit); in poll()
DCompletionService.java107 Future<V> poll(); in poll() method
123 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; in poll() method
DDelayQueue.java189 public E poll() { in poll() method in DelayQueue
196 : q.poll(); in poll()
220 return q.poll(); in take()
253 public E poll(long timeout, TimeUnit unit) throws InterruptedException { in poll() method in DelayQueue
268 return q.poll(); in poll()
352 q.poll(); in drainTo()
380 q.poll(); in drainTo()
DBlockingDeque.java538 E poll(); in poll() method
564 E poll(long timeout, TimeUnit unit) in poll() method
/libcore/ojluni/src/main/java/java/nio/file/
DWatchService.java139 WatchKey poll(); in poll() method
159 WatchKey poll(long timeout, TimeUnit unit) in poll() method
/libcore/ojluni/src/main/java/java/util/
DAbstractQueue.java113 E x = poll(); in remove()
147 while (poll() != null) in clear()
DQueue.java190 E poll(); in poll() method
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/
DPriorityQueueTest.java137 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/
DPollArrayWrapper.c53 int res = poll(fds, nfds, remaining); in ipoll()
82 RESTARTABLE (poll(a, numfds, timeout), err); in Java_sun_nio_ch_PollArrayWrapper_poll0()
/libcore/luni/src/test/java/libcore/java/util/
DOldPriorityQueueTest.java118 assertEquals(i, (int) q.poll()); in test_removeAt_siftUp()
120 assertNull(q.poll()); in test_removeAt_siftUp()

1234