Home
last modified time | relevance | path

Searched defs:WakerToken (Results 1 – 4 of 4) sorted by relevance

/external/crosvm/cros_async/src/sys/linux/
During_executor.rs368 fn get_result(&self, token: &WakerToken, cx: &mut Context) -> Option<io::Result<u32>> { in get_result()
393 fn cancel_operation(&self, token: WakerToken) { in cancel_operation()
460 ) -> Result<WakerToken> { in submit_poll()
488 ) -> Result<WakerToken> { in submit_fallocate()
517 fn submit_cancel_async(&self, token: usize) -> Result<WakerToken> { in submit_cancel_async()
530 fn submit_fsync(&self, source: &RegisteredSource) -> Result<WakerToken> { in submit_fsync()
558 ) -> Result<WakerToken> { in submit_read_to_vectored()
614 ) -> Result<WakerToken> { in submit_write_from_vectored()
Dfd_executor.rs249 ) -> Result<WakerToken> { in add_operation()
260 fn is_ready(&self, token: &WakerToken, cx: &mut Context) -> bool { in is_ready()
/external/crosvm/cros_async/src/sys/windows/
Dhandle_executor.rs113 pub(crate) fn register_overlapped_op(&self, token: &WakerToken) { in register_overlapped_op()
133 token: &WakerToken, in get_overlapped_op_if_ready()
154 fn remove_overlapped_op(&self, token: &WakerToken) { in remove_overlapped_op()
305 pub fn get_token(&self) -> WakerToken { in get_token()
/external/crosvm/cros_async/src/
Dwaker.rs14 pub(crate) struct WakerToken(pub(crate) usize); struct