/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | ExecutionList.java | 134 runnables.poll().execute();
|
/external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/ |
H A D | AbstractKernel.java | 108 return endpointEvents.poll();
|
/external/libnl-headers/netlink/ |
H A D | netlink.h | 19 #include <sys/poll.h>
|
/external/qemu/hw/ |
H A D | goldfish_pipe.h | 87 /* Called when guest wants to poll the read/write status for the pipe. 90 unsigned (*poll)( void* pipe ); member in struct:__anon10973 165 #define PIPE_CMD_POLL 3 /* poll read/write status */
|
H A D | i8259.c | 44 uint8_t poll; member in struct:PicState 275 s->poll = 0; 308 s->poll = 1; 408 if (s->poll) { 410 s->poll = 0; 465 qemu_put_8s(f, &s->poll); 490 qemu_get_8s(f, &s->poll);
|
/external/webkit/Tools/Scripts/webkitpy/layout_tests/port/ |
H A D | server_process_unittest.py | 56 def poll(self): member in class:MockProc
|
H A D | dryrun.py | 116 def poll(self): member in class:DryrunDriver
|
H A D | chromium.py | 397 def poll(self): member in class:ChromiumDriver 398 # poll() is not threadsafe and can throw OSError due to: 400 return self._proc.poll() 474 if line == '' and self.poll() is not None: 533 while self._proc.poll() is None and time.time() < timeout: 535 if self._proc.poll() is None: 539 # FIXME: This is sometime none. What is wrong? assert self._proc.poll() is not None 540 if self._proc.poll() is not None:
|
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/util/ |
H A D | PriorityQueueTest.java | 133 assertEquals(newArray[i], integerQueue.poll()); 274 assertEquals(array[i], integerQueue.poll()); 323 assertEquals(queue.poll(), constructedQueue.poll()); 342 assertEquals(iter.next(), queue.poll()); 363 assertEquals(array[i], objectQueue.poll()); 392 assertEquals(iter.next(), queue.poll()); 420 assertEquals(sortedArray[i], queue.poll()); 423 assertNull(queue.poll()); 463 * @tests java.util.PriorityQueue#poll() [all...] |
/external/chromium/chrome/browser/sync/engine/ |
H A D | syncer_thread2_unittest.cc | 524 // Test that the short poll interval is used. 584 TimeDelta poll(TimeDelta::FromMilliseconds(5)); 586 syncer_thread()->OnReceivedLongPollIntervalUpdate(poll); 603 TimeDelta poll(TimeDelta::FromMilliseconds(15)); 606 syncer_thread()->OnReceivedLongPollIntervalUpdate(poll); 616 TimeTicks optimal_start = TimeTicks::Now() + poll + throttle1; 621 AnalyzePollRun(records, kMinNumSamples, optimal_start, poll); 626 TimeDelta poll(TimeDelta::FromMilliseconds(15)); 630 syncer_thread()->OnReceivedLongPollIntervalUpdate(poll); 699 TimeDelta poll(TimeDelt [all...] |
/external/tcpdump/ |
H A D | print-pgm.c | 283 struct pgm_poll *poll; local 285 poll = (struct pgm_poll *)(pgm + 1); 286 TCHECK(*poll); 288 EXTRACT_32BITS(&poll->pgmp_seq), 289 EXTRACT_16BITS(&poll->pgmp_round)); 290 bp = (u_char *) (poll + 1);
|
/external/chromium/net/test/ |
H A D | test_server_posix.cc | 7 #include <poll.h> 70 int rv = HANDLE_EINTR(poll(poll_fds, 1, 73 LOG(ERROR) << "Failed to poll for the child file descriptor.";
|
/external/chromium/third_party/libjingle/source/talk/p2p/client/ |
H A D | socketmonitor.cc | 112 void SocketMonitor::PollSocket(bool poll) { argument 147 // Signal the monitoring thread, start another poll timer 150 if (poll)
|
/external/guava/guava/src/com/google/common/collect/ |
H A D | Queues.java | 214 // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple 217 if (added < numElements) { // not enough elements immediately available; will have to poll 218 E e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS); 250 // we could rely solely on #poll, but #drainTo might be more efficient when there are 253 if (added < numElements) { // not enough elements immediately available; will have to poll 254 E e; // written exactly once, by a successful (uninterrupted) invocation of #poll 257 e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS);
|
/external/guava/guava-tests/test/com/google/common/collect/ |
H A D | ForwardingQueueTest.java | 101 @Override public T poll() { method in class:ForwardingQueueTest.StandardImplForwardingQueue 196 forward.poll(); 197 assertEquals("[poll]", getCalls());
|
/external/qemu/android/ |
H A D | looper.h | 218 unsigned (*poll)(void* impl); member in struct:LoopIoClass 262 return io->clazz->poll(io->impl);
|
/external/jmonkeyengine/engine/src/core/com/jme3/util/ |
H A D | NativeObjectManager.java | 95 NativeObjectRef ref = (NativeObjectRef) refQueue.poll();
|
/external/jmonkeyengine/engine/src/lwjgl/com/jme3/input/lwjgl/ |
H A D | LwjglKeyInput.java | 79 Keyboard.poll();
|
/external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/tcp/ |
H A D | NioEndpoint.java | 158 return outbound.poll();
|
/external/kernel-headers/original/linux/ |
H A D | ipmi_smi.h | 114 /* Called to poll for work to do. This is so upper layers can 115 poll for operations during things like crash dumps. */ 116 void (*poll)(void *send_info); member in struct:ipmi_smi_handlers
|
H A D | poll.h | 4 #include <asm/poll.h> 26 * structures and helpers for f_op->poll implementations
|
H A D | net.h | 142 unsigned int (*poll) (struct file *file, struct socket *sock, member in struct:proto_ops 252 SOCKCALL_UWRAP(name, poll, (struct file *file, struct socket *sock, struct poll_table_struct *wait), \ 280 .poll = __lock_##name##_poll, \
|
/external/valgrind/main/auxprogs/ |
H A D | valgrind-listener.c | 52 #include <sys/poll.h> 302 /* enquire, using poll, whether there is any activity available on 310 res = poll(&ufd, 1, 0); 355 res = poll(conn_pollfd, j, 0 /* return immediately. */ ); 357 perror("poll(main) failed"); 358 panic("poll(main) failed");
|
/external/jmonkeyengine/engine/src/core/com/jme3/app/ |
H A D | Application.java | 578 AppTask<?> task = taskQueue.poll();
582 task = taskQueue.poll();
586 } while (((task = taskQueue.poll()) != null));
590 while( (task = taskQueue.poll()) != null ) {
|
/external/chromium-trace/ |
H A D | update.py | 28 while p.poll() is None:
|