35     pub(crate) chan_state_tx: Mutex<Option<mpsc::Sender<ConnectionState>>>,
120             connection_state: AtomicU8::new(ConnectionState::New as u8),  in new()
195         self.update_connection_state(ConnectionState::Checking)  in start_connectivity_checks()
207         last_connection_state: &mut ConnectionState,  in contact()  argument
210         if self.connection_state.load(Ordering::SeqCst) == ConnectionState::Failed as u8 {  in contact()
216         if self.connection_state.load(Ordering::SeqCst) == ConnectionState::Checking as u8 {  in contact()
228                 self.update_connection_state(ConnectionState::Failed).await;  in contact()
241         let mut last_connection_state = ConnectionState::Unspecified;  in connectivity_checks()
271                         ConnectionState::New | ConnectionState::Checking => {  in connectivity_checks()
275                         ConnectionState::Connected | ConnectionState::Disconnected => {  in connectivity_checks()
303     pub(crate) async fn update_connection_state(&self, new_state: ConnectionState) {  in update_connection_state()  argument
306             if new_state == ConnectionState::Failed {  in update_connection_state()
340             self.update_connection_state(ConnectionState::Connected)  in set_selected_pair()
462                 self.update_connection_state(ConnectionState::Failed).await;  in validate_selected_pair()
466                 self.update_connection_state(ConnectionState::Disconnected)  in validate_selected_pair()
469                 self.update_connection_state(ConnectionState::Connected)  in validate_selected_pair()
629         self.update_connection_state(ConnectionState::Closed).await;  in close()
1054         mut chan_state_rx: mpsc::Receiver<ConnectionState>,  in start_on_connection_state_change_routine()  argument