| /tools/tradefederation/core/tests/src/com/android/tradefed/util/ |
| D | ConditionPriorityBlockingQueueTest.java | 45 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/ |
| D | ConditionPriorityBlockingQueue.java | 123 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()
|
| D | LogcatEventParser.java | 148 return mEventQueue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForEvent()
157 return mEventQueue.poll(); in pollForEvent()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/util/ |
| D | BatchProcessor.kt | 58 next = workArray.poll() in <lambda>()
63 next = workArray.poll() in <lambda>()
74 remaining = workArray.poll() in <lambda>()
|
| /tools/tradefederation/core/src/com/android/tradefed/invoker/shard/ |
| D | TestsPoolPoller.java | 111 IRemoteTest poll() { in poll() method in TestsPoolPoller
112 return poll(false); in poll()
116 private IRemoteTest poll(boolean reportNotExecuted) { in poll() method in TestsPoolPoller
184 IRemoteTest test = poll(); in run()
316 IRemoteTest test = poll(true); in reportNotExecuted()
325 test = poll(true); in reportNotExecuted()
|
| /tools/test/graphicsbenchmark/functional_tests/java/src/com/android/game/qualification/tests/ |
| D | SurfaceFlingerTestActivity.java | 121 getReadyTimes().poll(); in run()
122 getLatchTimes().poll(); in run()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/invoker/shard/ |
| D | TestsPoolPollerTest.java | 103 assertNotNull(poller1.poll()); in testMultiPolling()
105 assertNotNull(poller2.poll()); in testMultiPolling()
107 assertNotNull(poller1.poll()); in testMultiPolling()
108 assertNotNull(poller1.poll()); in testMultiPolling()
109 assertNotNull(poller2.poll()); in testMultiPolling()
112 assertNull(poller1.poll()); in testMultiPolling()
113 assertNull(poller2.poll()); in testMultiPolling()
|
| /tools/acloud/create/ |
| D | goldfish_local_image_local_instance_test.py | 45 self._mock_proc.poll.side_effect = (
164 self._mock_proc.poll.assert_called()
206 self._mock_proc.poll.assert_called()
320 self._mock_proc.poll.assert_called()
|
| D | goldfish_local_image_local_instance.py | 223 if proc.poll() is None:
500 utils.PollAndWait(func=lambda: (proc.poll() is None and
506 if proc.poll() is not None:
|
| /tools/tradefederation/core/src/com/android/tradefed/util/sl4a/ |
| D | Sl4aEventDispatcher.java | 123 EventSl4aObject res = mEventQueue.get(name).poll(); in popEvent()
149 EventSl4aObject res = mEventQueue.get(name).poll(); in waitForEvent()
|
| /tools/tradefederation/core/src/com/android/tradefed/cluster/ |
| D | ClusterEventUploader.java | 106 events.add(mEventQueue.poll()); in uploadEvents()
|
| /tools/acloud/internal/lib/ |
| D | ota_tools_test.py | 110 popen.poll.return_value = return_value
120 popen.poll.return_value = None
|
| D | ota_tools.py | 128 if proc and proc.poll() is None:
|
| D | ssh_test.py | 44 self.created_subprocess.poll = mock.MagicMock(return_value=0)
|
| D | cvd_compute_client_multi_stage_test.py | 161 created_subprocess.poll = mock.MagicMock(return_value=0)
|
| /tools/test/connectivity/acts/framework/tests/libs/proc/ |
| D | process_test.py | 156 process._process.poll.return_value = None
240 process._process.poll.return_value = None
|
| /tools/repohooks/rh/ |
| D | utils.py | 234 self.poll()
257 return self._lock_breaker(self.poll, *args, **kwargs)
|
| /tools/tradefederation/core/atest/test_runners/ |
| D | atest_tf_test_runner_unittest.py | 206 mock_subproc.poll.side_effect = [True, True, None]
226 mock_subproc.poll.side_effect = None
252 mock_subproc.poll.side_effect = [None, None, None, None,
282 mock_subproc.poll.side_effect = [None, None, True, True,
|
| D | robolectric_test_runner.py | 166 if robo_proc.poll() is not None:
|
| /tools/asuite/atest/test_runners/ |
| D | atest_tf_test_runner_unittest.py | 206 mock_subproc.poll.side_effect = [True, True, None]
226 mock_subproc.poll.side_effect = None
252 mock_subproc.poll.side_effect = [None, None, None, None,
282 mock_subproc.poll.side_effect = [None, None, True, True,
|
| D | robolectric_test_runner.py | 172 if robo_proc.poll() is not None:
|
| /tools/test/connectivity/acts/framework/acts/controllers/utils_lib/ssh/ |
| D | connection.py | 116 or self._master_ssh_proc.poll() is not None):
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/device/ |
| D | MockDeviceManager.java | 264 ITestDevice d = mAvailableDeviceQueue.poll(new TestDeviceMatcher(options)); in allocateDevice()
|
| /tools/asuite/atest/ |
| D | atest_utils.py | 136 while proc.poll() is None:
|
| /tools/tradefederation/core/atest/ |
| D | atest_utils.py | 125 while proc.poll() is None:
|