Home
last modified time | relevance | path

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

/tools/tradefederation/core/tests/src/com/android/tradefed/util/
DConditionPriorityBlockingQueueTest.java45 assertNull(mQueue.poll()); in testPoll_empty()
55 assertNull(mQueue.poll()); in testTake()
69 assertNull(mQueue.poll()); in testTake_priority()
84 assertNull(fifoQueue.poll()); in testTake_fifo()
98 assertNull(mQueue.poll()); in testTake_priorityReverse()
119 assertNull(mQueue.poll()); in testTake_delayedAdd()
143 assertNull(mQueue.poll(new OneMatcher())); in testTake_matcher_delayedAdd()
144 assertEquals(two, mQueue.poll()); in testTake_matcher_delayedAdd()
207 assertNull(mQueue.poll()); in testTake_multiple_matchers()
214 assertNull(mQueue.poll(new OneMatcher())); in testPoll_condition_empty()
[all …]
/tools/tradefederation/core/src/com/android/tradefed/util/
DConditionPriorityBlockingQueue.java123 public T poll() { in poll() method in ConditionPriorityBlockingQueue
124 return poll(new AlwaysMatch<T>()); in poll()
134 public T poll(IMatcher<T> matcher) { in poll() method in ConditionPriorityBlockingQueue
165 public T poll(long timeout, TimeUnit unit) throws InterruptedException { in poll() method in ConditionPriorityBlockingQueue
166 return poll(timeout, unit, new AlwaysMatch<T>()); in poll()
180 public T poll(long timeout, TimeUnit unit, IMatcher<T> matcher) throws InterruptedException { in poll() method in ConditionPriorityBlockingQueue
207 while ((matchedObj = poll(matcher)) == null && (nanos == null || nanos > 0)) { in blockingPoll()
392 T removedObj = poll(matcher); in addUnique()
/tools/tradefederation/core/tests/src/com/android/tradefed/invoker/shard/
DTestsPoolPollerTest.java77 assertNotNull(poller1.poll()); in testMultiPolling()
79 assertNotNull(poller2.poll()); in testMultiPolling()
81 assertNotNull(poller1.poll()); in testMultiPolling()
82 assertNotNull(poller1.poll()); in testMultiPolling()
83 assertNotNull(poller2.poll()); in testMultiPolling()
86 assertNull(poller1.poll()); in testMultiPolling()
87 assertNull(poller2.poll()); in testMultiPolling()
/tools/repohooks/rh/
Dutils.py185 while proc.poll() is None and int_timeout >= 0:
190 while proc.poll() is None and kill_timeout >= 0:
194 if proc.poll() is None:
249 self.poll()
255 self.poll()
/tools/tradefederation/core/src/com/android/tradefed/util/sl4a/
DSl4aEventDispatcher.java123 EventSl4aObject res = mEventQueue.get(name).poll(); in popEvent()
149 EventSl4aObject res = mEventQueue.get(name).poll(); in waitForEvent()
/tools/tradefederation/core/atest/
Datest_utils.py86 while proc.poll() is None:
/tools/test/connectivity/acts/framework/acts/controllers/utils_lib/ssh/
Dconnection.py111 self._master_ssh_proc.poll() is not None):
/tools/tradefederation/core/src/com/android/tradefed/testtype/suite/
DModuleDefinition.java163 IRemoteTest poll() { in poll() method in ModuleDefinition
355 IRemoteTest test = poll(); in run()
/tools/tradefederation/core/src/com/android/tradefed/testtype/testdefs/
DXmlDefsTest.java410 XmlDefsTest shard = (XmlDefsTest)shardQueue.poll(); in split()
/tools/tradefederation/core/tests/src/com/android/tradefed/device/
DMockDeviceManager.java258 ITestDevice d = mAvailableDeviceQueue.poll(new TestDeviceMatcher(options)); in allocateDevice()