Lines Matching refs:Event

143 enum Event {
167 impl Event {
181             Event::None => (EVENT_NONE, 0),
182             Event::Cancelled => (EVENT_CANCELLED, 0),
183             Event::Subtask { status } => (EVENT_SUBTASK, status as u32),
184             Event::StreamRead { code, .. } => (EVENT_STREAM_READ, code.encode()),
185             Event::StreamWrite { code, .. } => (EVENT_STREAM_WRITE, code.encode()),
186             Event::FutureRead { code, .. } => (EVENT_FUTURE_READ, code.encode()),
187             Event::FutureWrite { code, .. } => (EVENT_FUTURE_WRITE, code.encode()),
764                 Some(Event::Subtask {
1364                                 Some(Event::Subtask {
1902     ) -> Result<Option<(Event, Option<(Waitable, u32)>)>> {
1907             && (cancellable || !matches!(ev, Event::Cancelled))
1992                 // If an `Event::Cancelled` is pending, we'll deliver that;
1993                 // otherwise, we'll deliver `Event::None`.  Note that
1995                 // `Event` variants.
1997                     assert!(matches!(event, Event::None | Event::Cancelled));
1999                     task.event = Some(Event::None);
2087             if let Some(Event::Subtask {
2495                     Some(Event::Subtask {
2592         event: Event,
2725             let Some(Event::Subtask { status }) = event else {
2874                 Waitable::Host(task).set_event(state, Some(Event::Subtask { status }))?;
3020             Waitable::Guest(guest_task).set_event(state, Some(Event::Subtask { status }))?;
3488                     || (matches!(task.event, Some(Event::Cancelled)) && !cancellable))
3540                     let (ordinal, result) = Event::None.parts();
3667                 // (e.g. `Event::None` if the task is yielding, or
3668                 // `Event::Cancelled` if it was already cancelled), but that's
3670                 task.event = Some(Event::Cancelled);
3736         if let Some(Event::Subtask {
4291 type CallbackFn = Box<dyn Fn(&mut dyn VMStore, Event, u32) -> Result<u32> + Send + Sync + 'static>;
4495     /// If present, a pending `Event::None` or `Event::Cancelled` to be
4497     event: Option<Event>,
4526             Some(Event::Subtask {
4602     event: Option<Event>,
4695     fn set_event(&self, state: &mut ConcurrentState, event: Option<Event>) -> Result<()> {
4702     fn take_event(&self, state: &mut ConcurrentState) -> Result<Option<Event>> {
5128             assert!(matches!(event, Event::Cancelled));