Home
last modified time | relevance | path

Searched refs:ConnectionState (Results 1 – 9 of 9) sorted by relevance

/webrtc/webrtc/src/ice_transport/
H A Dice_transport_state.rs1 use ice::state::ConnectionState;
108 impl From<ConnectionState> for RTCIceTransportState {
109 fn from(raw: ConnectionState) -> Self { in from()
111 ConnectionState::New => RTCIceTransportState::New, in from()
115 ConnectionState::Failed => RTCIceTransportState::Failed, in from()
124 pub(crate) fn to_ice(self) -> ConnectionState { in to_ice() argument
126 RTCIceTransportState::New => ConnectionState::New, in to_ice()
133 _ => ConnectionState::Unspecified, in to_ice()
165 ConnectionState::Unspecified, in test_ice_transport_state_convert()
167 (RTCIceTransportState::New, ConnectionState::New), in test_ice_transport_state_convert()
[all …]
H A Dmod.rs8 use ice::state::ConnectionState;
112 agent.on_connection_state_change(Box::new(move |ice_state: ConnectionState| { in start()
/webrtc/ice/src/state/
H A Dstate_test.rs7 (ConnectionState::Unspecified, "Unspecified"), in test_connected_state_string()
8 (ConnectionState::New, "New"), in test_connected_state_string()
9 (ConnectionState::Checking, "Checking"), in test_connected_state_string()
10 (ConnectionState::Connected, "Connected"), in test_connected_state_string()
11 (ConnectionState::Completed, "Completed"), in test_connected_state_string()
12 (ConnectionState::Failed, "Failed"), in test_connected_state_string()
13 (ConnectionState::Disconnected, "Disconnected"), in test_connected_state_string()
14 (ConnectionState::Closed, "Closed"), in test_connected_state_string()
H A Dmod.rs8 pub enum ConnectionState { enum
33 impl Default for ConnectionState { implementation
39 impl fmt::Display for ConnectionState { implementation
55 impl From<u8> for ConnectionState { implementation
/webrtc/ice/src/agent/
H A Dagent_internal.rs35 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
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()
306 if new_state == ConnectionState::Failed { in update_connection_state()
340 self.update_connection_state(ConnectionState::Connected) in set_selected_pair()
629 self.update_connection_state(ConnectionState::Closed).await; in close()
[all …]
H A Dagent_test.rs468 if s == ConnectionState::Checking { in test_connectivity_on_startup()
978 ConnectionState::Checking => { in test_connection_state_callback()
983 ConnectionState::Connected => { in test_connection_state_callback()
993 ConnectionState::Failed => { in test_connection_state_callback()
998 ConnectionState::Closed => { in test_connection_state_callback()
1661 if c == ConnectionState::Failed { in test_connection_state_failed_delete_all_candidates()
1726 } else if c == ConnectionState::Connected || c == ConnectionState::Completed { in test_connection_state_connecting_to_failed()
1828 if c == ConnectionState::Failed || c == ConnectionState::Disconnected { in test_agent_restart_one_side()
1986 if c == ConnectionState::Connected { in test_close_in_connection_state_callback()
2040 if c == ConnectionState::Connected { in test_run_task_in_connection_state_callback()
[all …]
H A Dagent_vnet_test.rs347 if state == ConnectionState::Connected { in on_connected()
733 expected_state: ConnectionState, in block_until_state_seen() argument
734 state_queue: &mut mpsc::Receiver<ConnectionState>, in block_until_state_seen() argument
819 mpsc::channel::<ConnectionState>(100); in test_disconnected_to_connected()
821 controlling_agent.on_connection_state_change(Box::new(move |c: ConnectionState| { in test_disconnected_to_connected()
829 mpsc::channel::<ConnectionState>(100); in test_disconnected_to_connected()
831 controlled_agent.on_connection_state_change(Box::new(move |c: ConnectionState| { in test_disconnected_to_connected()
842 ConnectionState::Connected, in test_disconnected_to_connected()
851 ConnectionState::Disconnected, in test_disconnected_to_connected()
856 ConnectionState::Disconnected, in test_disconnected_to_connected()
[all …]
H A Dmod.rs67 dyn (FnMut(ConnectionState) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>>)
89 chan_state_rx: mpsc::Receiver<ConnectionState>,
422 if self.internal.connection_state.load(Ordering::SeqCst) != ConnectionState::New as u8 { in restart()
424 .update_connection_state(ConnectionState::Checking) in restart()
/webrtc/ice/examples/
H A Dping_pong.rs239 ice_agent.on_connection_state_change(Box::new(move |c: ConnectionState| { in main()
241 if c == ConnectionState::Failed { in main()