Home
last modified time | relevance | path

Searched refs:connection_state (Results 1 – 16 of 16) sorted by relevance

/webrtc/ice/src/state/
H A Dstate_test.rs17 for (connection_state, expected_string) in tests { in test_connected_state_string()
19 connection_state.to_string(), in test_connected_state_string()
/webrtc/ice/src/agent/
H A Dagent_internal.rs49 pub(crate) connection_state: AtomicU8, //ConnectionState, field
120 connection_state: AtomicU8::new(ConnectionState::New as u8), in new()
210 if self.connection_state.load(Ordering::SeqCst) == ConnectionState::Failed as u8 { in contact()
213 *last_connection_state = self.connection_state.load(Ordering::SeqCst).into(); in contact()
216 if self.connection_state.load(Ordering::SeqCst) == ConnectionState::Checking as u8 { in contact()
218 if *last_connection_state as u8 != self.connection_state.load(Ordering::SeqCst) { in contact()
229 *last_connection_state = self.connection_state.load(Ordering::SeqCst).into(); in contact()
236 *last_connection_state = self.connection_state.load(Ordering::SeqCst).into(); in contact()
304 if self.connection_state.load(Ordering::SeqCst) != new_state as u8 { in update_connection_state()
315 self.connection_state in update_connection_state()
H A Dmod.rs422 if self.internal.connection_state.load(Ordering::SeqCst) != ConnectionState::New as u8 { in restart()
/webrtc/examples/examples/save-to-disk-h264/
H A Dsave-to-disk-h264.rs257 move |connection_state: RTCIceConnectionState| { in main()
260 if connection_state == RTCIceConnectionState::Connected { in main()
262 } else if connection_state == RTCIceConnectionState::Failed { in main()
/webrtc/examples/examples/save-to-disk-vpx/
H A Dsave-to-disk-vpx.rs287 move |connection_state: RTCIceConnectionState| { in main()
290 if connection_state == RTCIceConnectionState::Connected { in main()
292 } else if connection_state == RTCIceConnectionState::Failed { in main()
/webrtc/examples/examples/rtp-to-webrtc/
H A Drtp-to-webrtc.rs129 move |connection_state: RTCIceConnectionState| { in main()
131 if connection_state == RTCIceConnectionState::Failed { in main()
/webrtc/examples/examples/insertable-streams/
H A Dinsertable-streams.rs200 move |connection_state: RTCIceConnectionState| { in main()
202 if connection_state == RTCIceConnectionState::Connected { in main()
/webrtc/examples/examples/rtp-forwarder/
H A Drtp-forwarder.rs251 move |connection_state: RTCIceConnectionState| { in main()
253 if connection_state == RTCIceConnectionState::Connected { in main()
/webrtc/examples/examples/play-from-disk-h264/
H A Dplay-from-disk-h264.rs292 move |connection_state: RTCIceConnectionState| { in main()
294 if connection_state == RTCIceConnectionState::Connected { in main()
/webrtc/examples/examples/play-from-disk-vpx/
H A Dplay-from-disk-vpx.rs303 move |connection_state: RTCIceConnectionState| { in main()
305 if connection_state == RTCIceConnectionState::Connected { in main()
/webrtc/webrtc/src/dtls_transport/
H A Dmod.rs196 let conn_state = conn.connection_state().await; in start_srtp()
236 let conn_state = conn.connection_state().await; in start_srtp()
432 let remote_certs = &dtls_conn.connection_state().await.peer_certificates; in start()
/webrtc/examples/examples/play-from-disk-renegotiation/
H A Dplay-from-disk-renegotiation.rs152 if pc.connection_state() != RTCPeerConnectionState::New { in create_peer_connection()
155 pc.connection_state() in create_peer_connection()
/webrtc/dtls/src/conn/
H A Dconn_test.rs441 let state = c.connection_state().await; in test_export_keying_material()
455 let state = c.connection_state().await; in test_export_keying_material()
469 let state = c.connection_state().await; in test_export_keying_material()
483 let state = c.connection_state().await; in test_export_keying_material()
492 let state = c.connection_state().await; in test_export_keying_material()
554 let actual_psk_identity_hint = &server.connection_state().await.identity_hint; in test_psk()
1061 let actual_client_cert = &server.connection_state().await.peer_certificates; in test_client_certificate()
1084 let actual_server_cert = &client.connection_state().await.peer_certificates; in test_client_certificate()
H A Dmod.rs486 pub async fn connection_state(&self) -> State { in connection_state() method
/webrtc/webrtc/src/peer_connection/
H A Dmod.rs867 let connection_state = in update_connection_state() localVariable
890 if peer_connection_state.load(Ordering::SeqCst) == connection_state as u8 { in update_connection_state()
894 log::info!("peer connection state changed: {}", connection_state); in update_connection_state()
895 peer_connection_state.store(connection_state as u8, Ordering::SeqCst); in update_connection_state()
899 connection_state, in update_connection_state()
2024 pub fn connection_state(&self) -> RTCPeerConnectionState { in connection_state() method
/webrtc/examples/examples/ice-restart/
H A Dice-restart.rs113 |connection_state: RTCIceConnectionState| { in do_signaling()