| /external/python/cpython2/Lib/test/ |
| D | test_poll.py | 15 select.poll
33 p = select.poll()
56 ready = p.poll()
63 ready = p.poll()
85 p = select.poll()
87 r = p.poll()
92 p = select.poll()
94 r = p.poll()
97 r = p.poll()
102 p = select.poll()
[all …]
|
| D | test_epoll.py | 134 events = ep.poll(1, 4)
135 events2 = ep2.poll(0.9, 4)
141 ep2.poll(1, 4)
157 events = ep.poll(1, 4)
168 events = ep.poll(timeout=2.1, maxevents=4)
175 events = ep.poll(1, 4)
189 events = ep.poll(1, 4)
208 events = ep.poll(1, 4)
|
| /external/python/cpython3/Lib/test/ |
| D | test_poll.py | 13 select.poll
31 p = select.poll()
54 ready = p.poll()
61 ready = p.poll()
81 p = select.poll()
83 r = p.poll()
88 p = select.poll()
90 r = p.poll()
92 r = p.poll()
97 p = select.poll()
[all …]
|
| D | test_devpoll.py | 51 ready = p.poll()
58 ready = p.poll()
79 pollster.poll(-1)
80 self.assertRaises(OverflowError, pollster.poll, -2)
81 self.assertRaises(OverflowError, pollster.poll, -1 << 31)
82 self.assertRaises(OverflowError, pollster.poll, -1 << 64)
84 pollster.poll(0)
85 pollster.poll(1)
86 pollster.poll(1 << 30)
87 self.assertRaises(OverflowError, pollster.poll, 1 << 31)
[all …]
|
| D | test_epoll.py | 150 events = ep.poll(1, 4)
151 events2 = ep2.poll(0.9, 4)
156 ep2.poll(1, 4)
172 events = ep.poll(1, 4)
183 events = ep.poll(timeout=2.1, maxevents=4)
190 events = ep.poll(1, 4)
204 events = ep.poll(1, 4)
223 events = ep.poll(1, 4)
250 self.assertRaises(ValueError, epoll.poll, 1.0)
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ConnectivityStateManagerTest.java | 75 assertEquals(TRANSIENT_FAILURE, sink.poll()); in registerCallbackBeforeStateChanged()
95 assertEquals(CONNECTING, sink.poll()); in registerCallbackAfterStateChanged()
126 assertEquals(CONNECTING, sink.poll()); in callbacksAreOneShot()
144 assertEquals(IDLE, sink.poll()); in callbacksAreOneShot()
177 assertEquals("callback3", callbackRuns.poll()); in multipleCallbacks()
179 assertEquals(IDLE, sink.poll()); in multipleCallbacks()
185 assertEquals("callback1", callbackRuns.poll()); in multipleCallbacks()
186 assertEquals("callback2", callbackRuns.poll()); in multipleCallbacks()
188 assertEquals(CONNECTING, sink.poll()); in multipleCallbacks()
189 assertEquals(CONNECTING, sink.poll()); in multipleCallbacks()
[all …]
|
| D | InternalSubchannelTest.java | 188 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in singleAddressReconnect()
213 transports.poll().listener.transportShutdown(Status.RESOURCE_EXHAUSTED); in singleAddressReconnect()
245 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in singleAddressReconnect()
284 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
297 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
322 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
333 transports.poll().listener.transportShutdown(Status.RESOURCE_EXHAUSTED); in twoAddressesReconnect()
364 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
377 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
386 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
[all …]
|
| /external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/util/ |
| D | TimedValueQueueTest.java | 41 assertThat(queue.poll(0)).isEqualTo("a"); in addAndPollValues()
42 assertThat(queue.poll(1)).isEqualTo("b"); in addAndPollValues()
43 assertThat(queue.poll(2)).isEqualTo("c"); in addAndPollValues()
52 assertThat(queue.poll(0)).isEqualTo("" + (i / 2)); in bufferCapacityIncreasesAutomatically()
64 assertThat(queue.poll(0)).isEqualTo("a"); in timeDiscontinuityClearsValues()
74 assertThat(queue.poll(2)).isEqualTo("a"); in timeDiscontinuityOnFullBufferClearsValues()
81 assertThat(queue.poll(2)).isEqualTo("b"); in pollReturnsClosestValue()
90 assertThat(queue.poll(1)).isEqualTo("b"); in pollRemovesPreviousValues()
|
| /external/skqp/tests/ |
| D | MessageBusTest.cpp | 39 inbox1.poll(&messages); in DEF_TEST()
47 inbox1.poll(&messages); in DEF_TEST()
52 inbox1.poll(&messages); in DEF_TEST()
56 inbox2.poll(&messages); in DEF_TEST()
90 inbox1.poll(&messages); in DEF_TEST()
96 inbox2.poll(&messages); in DEF_TEST()
|
| /external/skia/tests/ |
| D | MessageBusTest.cpp | 39 inbox1.poll(&messages); in DEF_TEST()
47 inbox1.poll(&messages); in DEF_TEST()
52 inbox1.poll(&messages); in DEF_TEST()
56 inbox2.poll(&messages); in DEF_TEST()
90 inbox1.poll(&messages); in DEF_TEST()
96 inbox2.poll(&messages); in DEF_TEST()
|
| /external/libusb/ |
| D | configure.ac | 140 AC_CHECK_HEADERS([poll.h])
141 AC_DEFINE([POLL_NFDS_TYPE],[nfds_t],[type of second poll() argument])
148 AC_CHECK_HEADERS([poll.h])
150 [AC_DEFINE([POLL_NFDS_TYPE],[nfds_t],[type of second poll() argument])],
151 [AC_DEFINE([POLL_NFDS_TYPE],[unsigned int],[type of second poll() argument])],
152 [#include <poll.h>])
159 AC_CHECK_HEADERS([poll.h])
160 AC_DEFINE([POLL_NFDS_TYPE],[nfds_t],[type of second poll() argument])
167 AC_CHECK_HEADERS([poll.h])
168 AC_DEFINE([POLL_NFDS_TYPE],[nfds_t],[type of second poll() argument])
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _cancel_many_calls_test.py | 75 first_event = self._completion_queue.poll()
77 self._completion_queue.poll()
90 self._completion_queue.poll()
91 self._completion_queue.poll()
99 rpc_event = server_completion_queue.poll()
105 server_completion_queue.poll()
121 event = self._completion_queue.poll()
|
| /external/autotest/client/tests/cgroup/ |
| D | cgroup.py | 147 while ps.poll() == None:
158 if (len(out) < 2) or (ps.poll() != 0):
160 "\nReturn: %d" % (out, ps.poll()))
179 while ps.poll() == None:
192 "\nReturn: %d" % (out, ps.poll()))
196 "output:\n%s", ps.poll(), out)
227 while ps.poll() == None:
240 "\nReturn: %d" % (out, ps.poll()))
326 if task.poll() != None:
|
| /external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MonitorBasedPriorityBlockingQueue.java | 217 public E poll() { in poll() method in MonitorBasedPriorityBlockingQueue
221 return q.poll(); in poll()
228 public E poll(long timeout, TimeUnit unit) throws InterruptedException { in poll() method in MonitorBasedPriorityBlockingQueue
232 return q.poll(); in poll()
246 return q.poll(); in take()
424 while ((e = q.poll()) != null) { in drainTo()
450 while (n < maxElements && (e = q.poll()) != null) { in drainTo()
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MonitorBasedPriorityBlockingQueue.java | 217 public E poll() { in poll() method in MonitorBasedPriorityBlockingQueue
221 return q.poll(); in poll()
228 public E poll(long timeout, TimeUnit unit) throws InterruptedException { in poll() method in MonitorBasedPriorityBlockingQueue
232 return q.poll(); in poll()
246 return q.poll(); in take()
424 while ((e = q.poll()) != null) { in drainTo()
450 while (n < maxElements && (e = q.poll()) != null) { in drainTo()
|
| /external/u-boot/test/py/ |
| D | u_boot_spawn.py | 65 self.poll = select.poll()
66 …self.poll.register(self.fd, select.POLLIN | select.POLLPRI | select.POLLERR | select.POLLHUP | sel…
168 events = self.poll.poll(poll_maxwait)
|
| /external/python/cpython3/Doc/library/ |
| D | select.rst | 9 This module provides access to the :c:func:`select` and :c:func:`poll` functions
39 (Only supported on Solaris and derivatives.) Returns a ``/dev/poll``
92 .. function:: poll()
96 for I/O events; see section :ref:`poll-objects` below for the methods supported
134 poll and never blocks.
171 :func:`poll` or another interface in this module. This doesn't apply
183 ``/dev/poll`` Polling Objects
186 Solaris and derivatives have ``/dev/poll``. While :c:func:`select` is
187 O(highest file descriptor) and :c:func:`poll` is O(number of file
188 descriptors), ``/dev/poll`` is O(active file descriptors).
[all …]
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/util/ |
| D | TimedValueQueue.java | 75 return poll(timestamp, /* onlyOlder= */ true); in pollFloor()
86 public synchronized @Nullable V poll(long timestamp) { in poll() method in TimedValueQueue
87 return poll(timestamp, /* onlyOlder= */ false); in poll()
101 private V poll(long timestamp, boolean onlyOlder) { in poll() method in TimedValueQueue
|
| /external/webrtc/webrtc/tools/loopback_test/ |
| D | stat_tracker.js | 62 function poll() { function in StatTracker
65 setTimeout(poll, pollInterval);
75 setTimeout(poll, pollInterval);
|
| /external/llvm/test/Transforms/PlaceSafepoints/ |
| D | call-in-loop.ll | 2 ; don't need a safepoint poll (since the callee must contain a
3 ; poll test).
23 ; This function is inlined when inserting a poll.
|
| /external/swiftshader/third_party/llvm-7.0/llvm/test/Transforms/PlaceSafepoints/ |
| D | call-in-loop.ll | 2 ; don't need a safepoint poll (since the callee must contain a
3 ; poll test).
23 ; This function is inlined when inserting a poll.
|
| /external/autotest/client/cros/cellular/ |
| D | mmtest.py | 119 self.modemmanager.poll()
129 self.fakenet_process.poll()
136 self.fakemodem_process.poll()
143 self.modemmanager.poll()
|
| /external/guava/android/guava-testlib/src/com/google/common/collect/testing/testers/ |
| D | QueuePollTester.java | 43 assertNull("emptyQueue.poll() should return null", getQueue().poll()); in testPoll_empty()
50 assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll()); in testPoll_size1()
57 assertEquals("sizeManyQueue.poll() should return first element", e0(), getQueue().poll()); in testPoll_sizeMany()
|
| /external/guava/guava-testlib/src/com/google/common/collect/testing/testers/ |
| D | QueuePollTester.java | 43 assertNull("emptyQueue.poll() should return null", getQueue().poll()); in testPoll_empty()
50 assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll()); in testPoll_size1()
57 assertEquals("sizeManyQueue.poll() should return first element", e0(), getQueue().poll()); in testPoll_sizeMany()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | TickerChannelCommonTest.kt | 51 assertFailsWith<CancellationException> { delayChannel.poll() } in invoke()
162 fun ReceiveChannel<Unit>.checkEmpty() = assertNull(poll()) in checkEmpty()
165 assertNotNull(poll()) in checkEmpty()
166 assertNull(poll()) in checkEmpty()
|