Lines Matching defs:ConcurrentState
4335 state: &mut ConcurrentState, in qualify()
4396 fn new_implicit(state: &mut ConcurrentState, parent_task: TableId<GuestTask>) -> Result<Self> { in new_implicit()
4409 state: &mut ConcurrentState, in new_explicit()
4653 fn join(&self, state: &mut ConcurrentState, set: Option<TableId<WaitableSet>>) -> Result<()> { in join()
4695 fn set_event(&self, state: &mut ConcurrentState, event: Option<Event>) -> Result<()> { in set_event()
4862 pub struct ConcurrentState { struct
4864 current_thread: CurrentThread,
4870 futures: AlwaysMut<Option<FuturesUnordered<HostTaskFuture>>>,
4872 table: AlwaysMut<ResourceTable>,
4874 high_priority: Vec<WorkItem>,
4876 low_priority: VecDeque<WorkItem>,
4880 suspend_reason: Option<SuspendReason>,
4904 impl Default for ConcurrentState { implementation
4920 impl ConcurrentState { implementation