Searched refs:async_event (Results 1 – 9 of 9) sorted by relevance
14 let async_event = EventTokio::new(event.try_clone().unwrap()).unwrap(); in already_signaled() localVariable17 async_event.wait().await.unwrap(); in already_signaled()23 let async_event = EventTokio::new(event.try_clone().unwrap()).unwrap(); in signaled_after_delay() localVariable29 async_event.wait().await.unwrap(); in signaled_after_delay()
77 unsafe fn async_event(&self, event: RawHandle) -> Result<Box<dyn EventAsyncWrapper>>; in async_event() method110 unsafe fn async_event(&self, _event: RawHandle) -> Result<Box<dyn EventAsyncWrapper>> { in async_event() method
95 unsafe fn async_event(&self, event: RawHandle) -> Result<Box<dyn EventAsyncWrapper>> { in async_event() method
73 static void async_event(int pipe, time_t now);543 if (FD_ISSET(piperead, &rset)) async_event(piperead, now); in main()646 static void async_event(int pipe, time_t now) { in async_event() function
888 if let Ok(async_event) = EventAsync::new_without_reset(cloned_event, ex) { in handle_vsock_guest_data()889 let _ = async_event.next_val().await; in handle_vsock_guest_data()
605 __u64 async_event; member
1676 ex.async_event(ready_event.into_raw_descriptor()) in create_and_set_audio_client_event()
97805 uint8_t async_event; member