Searched refs:WakerToken (Results 1 – 3 of 3) sorted by relevance
| /external/crosvm/cros_async/src/ |
| D | uring_executor.rs | 78 use crate::waker::{new_waker, WakerToken, WeakWake};
414 fn get_result(&self, token: &WakerToken, cx: &mut Context) -> Option<io::Result<u32>> { in get_result() argument
439 fn cancel_operation(&self, token: WakerToken) { in cancel_operation() argument
479 ) -> Result<WakerToken> { in submit_poll() argument
499 Ok(WakerToken(next_op_token)) in submit_poll()
508 ) -> Result<WakerToken> { in submit_fallocate() argument
534 Ok(WakerToken(next_op_token)) in submit_fallocate()
537 fn submit_fsync(&self, source: &RegisteredSource) -> Result<WakerToken> { in submit_fsync() argument
557 Ok(WakerToken(next_op_token)) in submit_fsync()
566 ) -> Result<WakerToken> { in submit_read_to_vectored() argument
[all …]
|
| D | fd_executor.rs | 30 use crate::waker::{new_waker, WakerToken, WeakWake};
136 token: Option<WakerToken>,
253 fn add_operation(&self, fd: RawFd, events: WatchingEvents) -> Result<WakerToken> { in add_operation() argument
269 Ok(WakerToken(next_token)) in add_operation()
375 fn is_ready(&self, token: &WakerToken, cx: &mut Context) -> bool { in is_ready() argument
394 fn cancel_operation(&self, token: WakerToken) -> Result<()> { in cancel_operation()
|
| D | waker.rs | 11 pub(crate) struct WakerToken(pub(crate) usize); struct
|