Lines Matching refs:concurrent_state

673         let state = store.instance_state(instance).concurrent_state();  in is_ready()
1374 .concurrent_state() in handle_work_item()
1702 .concurrent_state() in enter_instance()
1712 .concurrent_state() in exit_instance()
1723 mem::take(&mut self.instance_state(instance).concurrent_state().pending).into_iter() in partition_pending()
1731 .concurrent_state() in partition_pending()
1746 let state = self.instance_state(caller_instance).concurrent_state(); in backpressure_modify()
3118 let concurrent_state = store.concurrent_state_mut(); in subtask_drop() localVariable
3121 let task = concurrent_state.get_mut(id)?; in subtask_drop()
3132 let task = concurrent_state.get_mut(id)?; in subtask_drop()
3140 concurrent_state.get_mut(id)?.exited, in subtask_drop()
3147 waitable.common(concurrent_state)?.handle = None; in subtask_drop()
3151 if waitable.take_event(concurrent_state)?.is_some() { in subtask_drop()
3156 waitable.delete_from(concurrent_state)?; in subtask_drop()
3162 debug_assert_eq!(expected_caller, concurrent_state.current_guest_thread()?); in subtask_drop()
3595 let concurrent_state = store.concurrent_state_mut(); in subtask_cancel() localVariable
3596 debug_assert_eq!(expected_caller, concurrent_state.current_guest_thread()?); in subtask_cancel()
3602 let state = &mut concurrent_state.get_mut(host_task)?.state; in subtask_cancel()
3634 let caller = concurrent_state.current_guest_thread()?; in subtask_cancel()
3636 let task = concurrent_state.get_mut(guest_task)?; in subtask_cancel()
3649 let concurrent_state = store.concurrent_state_mut(); in subtask_cancel() localVariable
3650 concurrent_state.delete(thread)?; in subtask_cancel()
3651 assert!(concurrent_state.get_mut(guest_task)?.ready_to_delete()); in subtask_cancel()
3654 let pending = &mut store.instance_state(instance).concurrent_state().pending; in subtask_cancel()
3677 if let Some(set) = concurrent_state in subtask_cancel()
3682 let item = match concurrent_state.get_mut(set)?.waiting.remove(&thread) { in subtask_cancel()
3696 concurrent_state.push_high_priority(item); in subtask_cancel()