Home
last modified time | relevance | path

Searched refs:state (Results 1 – 25 of 71) sorted by relevance

123

/webrtc/dtls/src/flight/
H A Dflight0.rs30 state: &mut State, in parse()
50 state.handshake_recv_sequence = seq; in parse()
77 state.remote_random = client_hello.random.clone(); in parse()
85 srv_cli_str(state.is_client), in parse()
144 && !state.extended_master_secret in parse()
155 if state.local_keypair.is_none() { in parse()
156 state.local_keypair = match state.named_curve.generate_keypair() { in parse()
184 state: &mut State, in generate()
189 state.cookie = vec![0; COOKIE_LENGTH]; in generate()
197 state.named_curve = DEFAULT_NAMED_CURVE; in generate()
[all …]
H A Dflight4.rs48 state: &mut State, in parse()
54 state.handshake_recv_sequence, in parse()
113 state.peer_certificates.len() in parse()
216 &state.peer_certificates, in parse()
379 &state.master_secret, in parse()
427 state.handshake_recv_sequence = seq; in parse()
459 if !state.peer_certificates.is_empty() && !state.peer_certificates_verified { in parse()
499 state: &mut State, in generate()
508 && state.extended_master_secret in generate()
622 state.named_curve, in generate()
[all …]
H A Dflight3.rs44 state: &mut State, in parse()
53 state.handshake_recv_sequence, in parse()
91 state.cookie = h.cookie.clone(); in parse()
100 state.handshake_recv_sequence, in parse()
126 state.handshake_recv_sequence, in parse()
168 state.handshake_recv_sequence = seq; in parse()
224 && !state.extended_master_secret in parse()
248 srv_cli_str(state.is_client), in parse()
282 srv_cli_str(state.is_client), in parse()
348 state: &mut State, in generate()
[all …]
H A Dflight1.rs40 state: &mut State, in parse()
48 state.handshake_recv_sequence, in parse()
75 return flight3.parse(tx, state, cache, cfg).await; in parse()
104 state.cookie = h.cookie.clone(); in parse()
105 state.handshake_recv_sequence = seq; in parse()
120 state: &mut State, in generate()
128 state.named_curve = DEFAULT_NAMED_CURVE; in generate()
129 state.cookie = vec![]; in generate()
130 state.local_random.populate(); in generate()
179 random: state.local_random.clone(), in generate()
[all …]
H A Dflight2.rs31 state: &mut State, in parse()
37 state.handshake_recv_sequence, in parse()
52 Err(_) => return Flight0 {}.parse(tx, state, cache, cfg).await, in parse()
55 state.handshake_recv_sequence = seq; in parse()
86 if state.cookie != client_hello.cookie { in parse()
110 state: &mut State, in generate()
114 state.handshake_send_sequence = 0; in generate()
122 cookie: state.cookie.clone(), in generate()
H A Dflight5.rs42 state: &mut State, in parse()
48 state.handshake_recv_sequence, in parse()
144 &state.master_secret, in parse()
177 state: &mut State, in generate()
566 &state.master_secret, in generate()
602 state: &mut State, in initalize_cipher_suite()
628 if state.extended_master_secret { in initalize_cipher_suite()
650 &state.pre_master_secret, in initalize_cipher_suite()
667 &state.pre_master_secret, in initalize_cipher_suite()
711 &state.peer_certificates, in initalize_cipher_suite()
[all …]
H A Dflight6.rs30 state: &mut State, in parse()
36 state.handshake_recv_sequence - 1, in parse()
72 state: &mut State, in generate()
86 if state.local_verify_data.is_empty() { in generate()
152 let cipher_suite = state.cipher_suite.lock().await; in generate()
154 state.local_verify_data = match prf_verify_data_server( in generate()
155 &state.master_secret, in generate()
179 verify_data: state.local_verify_data.clone(), in generate()
H A Dmod.rs14 use crate::state::*;
75 state: &mut State, in parse()
82 state: &mut State, in generate()
/webrtc/srtp/src/context/
H A Dsrtcp.rs17 if let Some(state) = self.get_srtcp_ssrc_state(ssrc) { in decrypt_rtcp()
18 if let Some(replay_detector) = &mut state.replay_detector { in decrypt_rtcp()
31 if let Some(state) = self.get_srtcp_ssrc_state(ssrc) { in decrypt_rtcp()
32 if let Some(replay_detector) = &mut state.replay_detector { in decrypt_rtcp()
51 if let Some(state) = self.get_srtcp_ssrc_state(ssrc) { in encrypt_rtcp()
52 state.srtcp_index += 1; in encrypt_rtcp()
53 if state.srtcp_index > MAX_SRTCP_INDEX { in encrypt_rtcp()
54 state.srtcp_index = 0; in encrypt_rtcp()
56 index = state.srtcp_index; in encrypt_rtcp()
H A Dsrtp.rs15 if let Some(state) = self.get_srtp_ssrc_state(header.ssrc) { in decrypt_rtp_with_header()
16 if let Some(replay_detector) = &mut state.replay_detector { in decrypt_rtp_with_header()
25 roc = state.next_rollover_count(header.sequence_number); in decrypt_rtp_with_header()
33 if let Some(state) = self.get_srtp_ssrc_state(header.ssrc) { in decrypt_rtp_with_header()
34 if let Some(replay_detector) = &mut state.replay_detector { in decrypt_rtp_with_header()
37 state.update_rollover_count(header.sequence_number); in decrypt_rtp_with_header()
58 if let Some(state) = self.get_srtp_ssrc_state(header.ssrc) { in encrypt_rtp_with_header()
59 roc = state.next_rollover_count(header.sequence_number); in encrypt_rtp_with_header()
70 if let Some(state) = self.get_srtp_ssrc_state(header.ssrc) { in encrypt_rtp_with_header()
71 state.update_rollover_count(header.sequence_number); in encrypt_rtp_with_header()
/webrtc/dtls/src/
H A Dhandshaker.rs200 pub(crate) async fn handshake(&mut self, mut state: HandshakeState) -> Result<()> { in handshake()
204 srv_cli_str(self.state.is_client), in handshake()
206 state.to_string() in handshake()
209 if state == HandshakeState::Finished && !self.is_handshake_completed_successfully() { in handshake()
215 state = match state { in handshake()
233 .generate(&mut self.state, &self.cache, &self.cfg) in prepare()
278 h.handshake_header.message_sequence = self.state.handshake_send_sequence as u16; in prepare()
279 self.state.handshake_send_sequence += 1; in prepare()
286 srv_cli_str(self.state.is_client), in prepare()
324 srv_cli_str(self.state.is_client), in wait()
[all …]
/webrtc/turn/src/client/
H A Dpermission.rs28 pub(crate) fn set_state(&self, state: PermState) { in set_state()
29 self.st.store(state as u8, Ordering::SeqCst); in set_state()
32 pub(crate) fn state(&self) -> PermState { in state() method
H A Dbinding.rs33 pub(crate) fn set_state(&mut self, state: BindingState) { in set_state()
35 self.st = state; in set_state()
38 pub(crate) fn state(&self) -> BindingState { in state() method
/webrtc/webrtc/src/ice_transport/
H A Dmod.rs8 use ice::state::ConnectionState;
72 state: Arc<AtomicU8>, // ICETransportState field
80 state: Arc::new(AtomicU8::new(RTCIceTransportState::New as u8)), in new()
101 if self.state() != RTCIceTransportState::New { in start()
108 let state = Arc::clone(&self.state); in start() localVariable
116 state.store(s as u8, Ordering::SeqCst); in start()
299 pub fn state(&self) -> RTCIceTransportState { in state() method
300 RTCIceTransportState::from(self.state.load(Ordering::SeqCst)) in state()
304 self.state.store(s as u8, Ordering::SeqCst) in set_state()
H A Dice_gatherer.rs57 pub(crate) state: Arc<AtomicU8>, //ICEGathererState, field
77 state: Arc::new(AtomicU8::new(RTCIceGathererState::New as u8)), in new()
89 if agent.is_some() || self.state() != RTCIceGathererState::New { in create_agent()
158 let state = Arc::clone(&self.state); in gather() localVariable
165 let state_clone = Arc::clone(&state); in gather()
272 pub fn state(&self) -> RTCIceGathererState { in state() method
273 self.state.load(Ordering::SeqCst).into() in state()
277 self.state.store(s as u8, Ordering::SeqCst); in set_state()
339 gatherer.state(), in test_new_ice_gatherer_success()
H A Dice_gathering_state.rs79 for (state, expected_string) in tests { in test_ice_gathering_state_string()
80 assert_eq!(state.to_string(), expected_string); in test_ice_gathering_state_string()
H A Dice_gatherer_state.rs84 for (state, expected_string) in tests { in test_ice_gatherer_state_string()
85 assert_eq!(state.to_string(), expected_string); in test_ice_gatherer_state_string()
H A Dice_transport_state.rs1 use ice::state::ConnectionState;
155 for (state, expected_string) in tests { in test_ice_transport_state_string()
156 assert_eq!(state.to_string(), expected_string); in test_ice_transport_state_string()
/webrtc/sctp/src/association/
H A Dassociation_internal.rs14 pub(crate) state: Arc<AtomicU8>, field
561 let state = self.get_state(); in gather_outbound() localVariable
562 match state { in gather_outbound()
607 let state = self.get_state(); in handle_init() localVariable
713 let state = self.get_state(); in handle_init_ack() localVariable
823 let state = self.get_state(); in handle_cookie_echo() localVariable
827 match state { in handle_cookie_echo()
1041 Arc::clone(&self.state), in create_stream()
1484 state: AssociationState, in postprocess_sack()
1537 if state == AssociationState::ShutdownSent || state == AssociationState::ShutdownAckSent { in handle_shutdown_ack()
[all …]
/webrtc/ice/src/agent/
H A Dagent_stats.rs20 pub state: CandidatePairState, field
121 state: CandidatePairState::default(), in default()
224 state: cp.state.load(Ordering::SeqCst).into(), in get_candidate_pairs_stats()
/webrtc/webrtc/src/sctp_transport/
H A Dsctp_transport_state.rs95 for (state, expected_string) in tests { in test_sctp_transport_state_string()
96 assert_eq!(state.to_string(), expected_string) in test_sctp_transport_state_string()
H A Dmod.rs68 state: AtomicU8, // RTCSctpTransportState field
106 state: AtomicU8::new(RTCSctpTransportState::Connecting as u8), in new()
155 … if self.state.load(Ordering::SeqCst) == RTCSctpTransportState::Closed as u8 { in start()
174 self.state in start()
207 self.state in stop()
358 pub fn state(&self) -> RTCSctpTransportState { in state() method
359 self.state.load(Ordering::SeqCst).into() in state()
/webrtc/webrtc/src/dtls_transport/
H A Dmod.rs69 pub(crate) state: AtomicU8, //DTLSTransportState, field
102 state: AtomicU8::new(RTCDtlsTransportState::New as u8), in new()
120 async fn state_change(&self, state: RTCDtlsTransportState) { in state_change()
121 self.state.store(state as u8, Ordering::SeqCst); in state_change()
124 f(state).await; in state_change()
136 pub fn state(&self) -> RTCDtlsTransportState { in state() method
137 self.state.load(Ordering::SeqCst).into() in state()
322 if self.state() != RTCDtlsTransportState::New { in prepare_transport()
562 if self.ice_transport.state() == RTCIceTransportState::New { in ensure_ice_conn()
/webrtc/sctp/src/stream/
H A Dmod.rs70 pub(crate) state: Arc<AtomicU8>, // clone from association field
95 .field("state", &self.state) in fmt()
119 state: Arc<AtomicU8>, in new()
126 state, in new()
296 let state: AssociationState = self.state.load(Ordering::SeqCst).into(); in prepare_write() localVariable
297 match state { in prepare_write()
480 self.state.load(Ordering::SeqCst).into() in get_state()
491 let state = self.get_state(); in send_payload_data() localVariable
492 if state != AssociationState::Established { in send_payload_data()
504 let state = self.get_state(); in send_reset_request() localVariable
[all …]
/webrtc/webrtc/src/data_channel/
H A Ddata_channel_state.rs108 for (state, expected_string) in tests { in test_data_channel_state_string()
109 assert_eq!(state.to_string(), expected_string) in test_data_channel_state_string()

123