Searched refs:OpStatus (Results 1 – 2 of 2) sorted by relevance
| /external/crosvm/cros_async/src/ |
| D | uring_executor.rs | 245 enum OpStatus { enum
252 ops: Slab<OpStatus>,
289 entry.insert(OpStatus::Nop); in wake()
395 match mem::replace(op, OpStatus::Completed(Some(result))) { in run()
397 OpStatus::Nop => mem::drop(ring.ops.remove(token)), in run()
398 OpStatus::Pending(data) => { in run()
408 OpStatus::Completed(_) => panic!("uring operation completed more than once"), in run()
422 OpStatus::Nop => panic!("`get_result` called on nop"), in get_result()
423 OpStatus::Pending(data) => { in get_result()
430 OpStatus::Completed(res) => { in get_result()
[all …]
|
| D | fd_executor.rs | 71 enum OpStatus { enum
237 ops: Mutex<Slab<OpStatus>>,
265 entry.insert(OpStatus::Pending(OpData { in add_operation()
356 let (file, waker) = match mem::replace(op, OpStatus::Completed) { in run()
357 OpStatus::Pending(OpData { file, waker }) => (file, waker), in run()
358 OpStatus::Completed => panic!("poll operation completed more than once"), in run()
382 OpStatus::Pending(data) => { in is_ready()
386 OpStatus::Completed => { in is_ready()
396 OpStatus::Pending(data) => self in cancel_operation()
400 OpStatus::Completed => Ok(()), in cancel_operation()
[all …]
|