Searched refs:wait_until (Results 1 – 8 of 8) sorted by relevance
| /system/bt/gd/cert/ |
| D | cert_self_test.py | 33 from cert.behavior import when, wait_until
581 wait_until(thing).test_request(is_a).times(1)
593 wait_until(thing).test_request(lambda obj: obj == "A").times(1)
605 wait_until(thing).test_request(anything()).times(1)
617 assertThat(wait_until(thing).test_request(lambda obj: obj == "A").times(1)).isFalse()
627 wait_until(thing).test_request(anything()).times(1)
641 wait_until(thing).test_request(lambda obj: obj == "A").times(2)
656 wait_until(thing).test_request(anything()).times(2)
670 assertThat(wait_until(thing).test_request(lambda obj: obj == "A").times(2)).isFalse()
|
| D | behavior.py | 172 def wait_until(i_has_behaviors, timeout=timedelta(seconds=3)): function
|
| /system/core/logd/ |
| D | LogReaderThread.cpp | 56 if (thread_triggered_condition_.wait_until(lock, deadline_) == in ThreadFunction()
|
| /system/bt/vendor_libs/test_vendor_lib/model/setup/ |
| D | async_manager.cc | 465 internal_cond_var_.wait_until(guard, (*task_queue_.begin())->time); in ThreadRoutine()
|
| /system/core/trusty/confirmationui/ |
| D | TrustyConfirmationUI.cpp | 337 listener_state_condv_.wait_until(stateLock, then, [&]() { return abort_called_; }); in promptUserConfirmation_()
|
| /system/core/adb/client/ |
| D | usb_linux.cpp | 329 if (h->cv.wait_until(lock, now + 5s) == std::cv_status::timeout || h->dead) { in usb_bulk_write()
|
| /system/bt/gd/l2cap/classic/cert/ |
| D | l2cap_test.py | 27 from cert.behavior import when, anything, wait_until
105 wait_until(self.cert_l2cap).on_config_req(request_matcher).times(1)
|
| /system/core/adb/ |
| D | transport.cpp | 197 reconnect_cv_.wait_until(lock, reconnect_queue_.begin()->reconnect_time); in Run()
|