Searched refs:next_state (Results 1 – 3 of 3) sorted by relevance
447 next_state |= CANCELED; in ut_task_state_turning_to_idle()448 next_state |= RUNNING; in ut_task_state_turning_to_idle()463 next_state |= RUNNING; in ut_task_state_turning_to_idle()475 next_state |= RUNNING; in ut_task_state_turning_to_idle()476 next_state |= SCHEDULING; in ut_task_state_turning_to_idle()519 next_state |= FINISHED; in ut_task_state_turn_to_un_set_waker()527 next_state &= !FINISHED; in ut_task_state_turn_to_un_set_waker()555 next_state |= FINISHED; in ut_task_state_turn_to_set_waker()563 next_state &= !FINISHED; in ut_task_state_turn_to_set_waker()578 next_state |= FINISHED; in ut_task_state_turn_to_un_join_handle()[all …]
45 next_state: DecodeState, field72 next_state: DecodeState::Read, in new()106 self.next_state = DecodeState::Read; in poll_read_frame()116 self.next_state = DecodeState::Read; in poll_read_frame()126 self.state = self.next_state; in poll_read_frame()128 self.next_state = DecodeState::Read; in poll_read_frame()202 self.next_state = DecodeState::Exit(exit_err); in transmit_error()
41 next_state: ManagerState, field134 next_state: ManagerState::Receive, in new()546 self.next_state = ManagerState::Exit(other); in manage_resp_error()587 self.next_state = ManagerState::Receive; in manage_stream_error()635 self.next_state = ManagerState::Exit(H2Error::ConnectionError(code).into()); in manage_conn_error()702 self.next_state = ManagerState::Receive; in poll_recv_message()715 self.next_state = ManagerState::Exit(DispatchErrorKind::ChannelClosed); in poll_channel_closed_exit()725 self.state = self.next_state; in poll_blocked_frames()727 self.next_state = ManagerState::Receive; in poll_blocked_frames()