Searched refs:cv (Results 1 – 13 of 13) sorted by relevance
77 std::condition_variable cv; in TEST() local91 worker.schedule(Callable::from([&mut, &cv, &finished] { in TEST()94 cv.notify_one(); in TEST()98 cv.wait(lock, [&finished] { return finished; }); in TEST()
37 cv.notify_one(); in notify()47 status = cv.wait_until(lock, now + std::chrono::seconds(TIMEOUT_PERIOD)); in wait()
82 cv.notify_one(); in notify()92 status = cv.wait_until(lock, now + std::chrono::seconds(sec)); in wait()
86 std::condition_variable cv; variable
533 std::condition_variable cv; variable
163 cv.notify_all(); in stop()182 cv.notify_all(); in notify_histogram_event()191 cv.wait(lk, [this] { return !started || work_available; }); in blob_processing_thread()
65 std::condition_variable cv; variable
159 cv.notify_all(); in stop()178 cv.notify_all(); in notify_histogram_event()187 cv.wait(lk, [this] { return !started || work_available; }); in blob_processing_thread()
61 std::condition_variable cv; variable
79 cv.notify_one(); in notify()89 status = cv.wait_until(lock, now + std::chrono::seconds(sec)); in wait()
553 std::condition_variable cv; variable
468 for (const HalClientValues& cv : clientValues) { in onBatchHalEvent() local469 auto vecSize = cv.values.size(); in onBatchHalEvent()478 for (VehiclePropValue* pValue : cv.values) { in onBatchHalEvent()481 auto status = cv.client->getCallback()->onPropertyEvent(vec); in onBatchHalEvent()484 toString(cv.client->getCallback()).c_str(), in onBatchHalEvent()
695 …o��"f�w��_���h�g֓���*�q���i>I��zr����u����|�p�gao&@e��0����I��o�cv�r�����.}��+�7��]A��…1741 …�!a-7�yp�8�E��?Gž������������{ hv`j@������j�ށN��a8������/AT�uJ�!cv"Sgyn��lM�+�c�+�0A…2407 �cv������OQ3�2pc��X\h4566 ���cv�f���7���䔓G�%��_��A��a'�x}>�}���b�*M����1�������θ����;��Cz���{�����f_�?F