Searched refs:concurrent_state (Results 1 – 4 of 4) sorted by relevance
1405 let future = concurrent_state.get_mut(id)?; in lift_index_to_future()1409 if concurrent_state.get_mut(state)?.done { in lift_index_to_future()1428 let state = concurrent_state.get_mut(id)?.state; in lower_future_to_index()1805 let state = concurrent_state.get_mut(id)?.state; in lower_stream_to_index()3568 set_guest_ready(concurrent_state)?; in guest_write()3593 set_guest_ready(concurrent_state)?; in guest_write()3600 set_guest_ready(concurrent_state)?; in guest_write()3774 concurrent_state.send_write_result( in guest_read()3799 set_guest_ready(concurrent_state)?; in guest_read()3821 set_guest_ready(concurrent_state)?; in guest_read()[all …]
1374 .concurrent_state() in handle_work_item()1702 .concurrent_state() in enter_instance()1712 .concurrent_state() in exit_instance()1731 .concurrent_state() in partition_pending()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()3156 waitable.delete_from(concurrent_state)?; in subtask_drop()3650 concurrent_state.delete(thread)?; in subtask_cancel()[all …]
161 && state.concurrent_state().pending_is_empty()) in assert_instance_states_empty()
54 concurrent_state: ConcurrentInstanceState, field73 pub fn concurrent_state(&mut self) -> &mut ConcurrentInstanceState { in concurrent_state() method74 &mut self.concurrent_state in concurrent_state()