Searched refs:WakerToken (Results 1 – 4 of 4) sorted by relevance
| /external/crosvm/cros_async/src/sys/windows/ |
| D | handle_executor.rs | 33 use crate::waker::WakerToken;
146 overlapped_ops: Mutex<HashMap<WakerToken, OpStatus>>,
222 if let Some(op) = overlapped_ops.get_mut(&WakerToken(pkt.overlapped_ptr)) { in run()
260 pub(crate) fn register_overlapped_op(&self, token: &WakerToken) { in register_overlapped_op() argument
269 token: &WakerToken, in get_overlapped_op_if_ready() argument
290 fn remove_overlapped_op(&self, token: &WakerToken) { in remove_overlapped_op() argument
373 pub fn get_token(&self) -> WakerToken { in get_token() argument
374 WakerToken((&*self.overlapped) as *const _ as usize) in get_token()
|
| /external/crosvm/cros_async/src/sys/unix/ |
| D | uring_executor.rs | 95 use crate::waker::WakerToken;
527 fn get_result(&self, token: &WakerToken, cx: &mut Context) -> Option<io::Result<u32>> { in get_result() argument
552 fn cancel_operation(&self, token: WakerToken) { in cancel_operation() argument
603 ) -> Result<WakerToken> { in submit_poll() argument
622 Ok(WakerToken(next_op_token)) in submit_poll()
631 ) -> Result<WakerToken> { in submit_fallocate() argument
657 Ok(WakerToken(next_op_token)) in submit_fallocate()
660 fn submit_cancel_async(&self, token: usize) -> Result<WakerToken> { in submit_cancel_async() argument
670 Ok(WakerToken(next_op_token)) in submit_cancel_async()
673 fn submit_fsync(&self, source: &RegisteredSource) -> Result<WakerToken> { in submit_fsync() argument
[all …]
|
| D | fd_executor.rs | 45 use crate::waker::WakerToken;
170 token: Option<WakerToken>,
299 fn add_operation(&self, fd: RawFd, event_type: EventType) -> Result<WakerToken> { in add_operation() argument
315 Ok(WakerToken(next_token)) in add_operation()
435 fn is_ready(&self, token: &WakerToken, cx: &mut Context) -> bool { in is_ready() argument
454 fn cancel_operation(&self, token: WakerToken) -> Result<()> { in cancel_operation()
|
| /external/crosvm/cros_async/src/ |
| D | waker.rs | 14 pub(crate) struct WakerToken(pub(crate) usize); struct
|