Home
last modified time | relevance | path

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

/external/oss-fuzz/infra/build/functions/
Dtest_utils.py62 def _read_thread(proc, ready_event): argument
71 ready_event.set()
74 ready_event = threading.Event()
75 thread = threading.Thread(target=_read_thread, args=(proc, ready_event))
78 if not ready_event.wait(timeout):
/external/libchrome/mojo/public/cpp/system/tests/
Dwait_set_unittest.cc264 base::WaitableEvent* ready_event = nullptr; in TEST_F() local
268 wait_set.Wait(&ready_event, &num_ready_handles, &ready_handle, &ready_result); in TEST_F()
270 EXPECT_EQ(&event, ready_event); in TEST_F()
286 base::WaitableEvent* ready_event = nullptr; in TEST_F() local
290 wait_set.Wait(&ready_event, &num_ready_handles, &ready_handle, &ready_result); in TEST_F()
292 EXPECT_EQ(nullptr, ready_event); in TEST_F()
307 wait_set.Wait(&ready_event, &num_ready_handles, &ready_handle, &ready_result); in TEST_F()
309 EXPECT_EQ(&event, ready_event); in TEST_F()
350 base::WaitableEvent* ready_event = nullptr; in TEST_F() local
354 wait_set.Wait(&ready_event, &num_ready_handles, &ready_handle, in TEST_F()
[all …]
/external/python/oauth2client/tests/contrib/
Dtest_multiprocess_file_storage.py38 ready_event = multiprocessing.Event()
40 target=target, args=(die_event, ready_event), kwargs=kwargs)
43 ready_event.wait()
141 die_event, ready_event, check_event): # pragma: NO COVER argument
153 ready_event.set()
186 def child_process(die_event, ready_event): # pragma: NO COVER argument
190 ready_event.set()
/external/libchrome/mojo/public/cpp/bindings/lib/
Dsync_handle_registry.cc138 base::WaitableEvent* ready_event = nullptr; in Wait() local
140 wait_set_.Wait(&ready_event, &num_ready_handles, &ready_handle, in Wait()
148 if (ready_event) { in Wait()
149 const auto iter = events_.find(ready_event); in Wait()
/external/libchrome/mojo/public/cpp/system/
Dwait_set.cc131 void Wait(base::WaitableEvent** ready_event, in Wait() argument
221 if (ready_event) { in Wait()
223 *ready_event = nullptr; in Wait()
225 *ready_event = events.container()[index]; in Wait()
356 void WaitSet::Wait(base::WaitableEvent** ready_event, in Wait() argument
361 state_->Wait(ready_event, num_ready_handles, ready_handles, ready_results, in Wait()
Dwait_set.h107 void Wait(base::WaitableEvent** ready_event,
DREADME.md375 base::WaitableEvent* ready_event = nullptr;
379 wait_set.Wait(&ready_event, &num_ready_handles, &ready_handle, &ready_result);
384 if (ready_event) {
/external/rust/crates/tokio/src/io/driver/
Dregistration.rs193 let ev = self.shared.ready_event(interest); in try_io()
Dscheduled_io.rs281 pub(super) fn ready_event(&self, interest: Interest) -> ReadyEvent { in ready_event() method
/external/rust/crates/tokio/docs/
Dreactor-refactor.md54 async fn clear_readiness(&self, ready_event: ReadyEvent);