Home
last modified time | relevance | path

Searched refs:s (Results 1 – 25 of 174) sorted by relevance

1234567

/webrtc/sctp/src/stream/
H A Dstream_test.rs9 let s = Stream::default(); in test_stream_buffered_amount() localVariable
11 assert_eq!(s.buffered_amount(), 0); in test_stream_buffered_amount()
28 let s = Stream::default(); in test_stream_amount_on_buffered_amount_low() localVariable
76 let s = Stream::new( in test_stream() localVariable
100 let n = s in test_stream()
108 s.handle_data(ChunkPayloadData { in test_stream()
119 s.read(&mut buf).await?; in test_stream()
127 s.handle_data(ChunkPayloadData { in test_stream()
137 s.read(&mut buf).await?; in test_stream()
150 let s = Arc::new(Stream::new( in test_poll_stream() localVariable
[all …]
/webrtc/webrtc/src/api/setting_engine/
H A Dsetting_engine_test.rs10 let mut s = SettingEngine::default(); in test_set_connection_timeout() localVariable
16 s.set_ice_timeouts( in test_set_connection_timeout()
39 !s.detach.data_channels, in test_detach_data_channels()
43 s.detach_data_channels(); in test_detach_data_channels()
46 s.detach.data_channels, in test_detach_data_channels()
68 s.set_nat_1to1_ips(ips, typ); in test_set_nat_1to1_ips()
70 !(s.candidates.nat_1to1_ips.len() != 1 || s.candidates.nat_1to1_ips[0] != "1.2.3.4"), in test_set_nat_1to1_ips()
112 !(s.replay_protection.dtls == 0 || s.replay_protection.dtls != 128), in test_set_replay_protection()
116 !(s.replay_protection.srtp == 0 || s.replay_protection.srtp != 64), in test_set_replay_protection()
120 !(s.replay_protection.srtcp == 0 || s.replay_protection.srtcp != 32), in test_set_replay_protection()
[all …]
/webrtc/srtp/src/context/
H A Dcontext_test.rs108 let s = SrtpSsrcState { in test_valid_packet_counter() localVariable
116 let counter = generate_counter(32846, s.rollover_counter, s.ssrc, &srtp_session_salt)?; in test_valid_packet_counter()
127 let mut s = SrtpSsrcState { in test_rollover_count() localVariable
138 s.next_rollover_count(0); in test_rollover_count()
142 s.next_rollover_count(0); in test_rollover_count()
147 s.update_rollover_count(0); in test_rollover_count()
161 s.update_rollover_count(5); in test_rollover_count()
163 s.next_rollover_count(6); in test_rollover_count()
164 s.update_rollover_count(6); in test_rollover_count()
166 s.next_rollover_count(7); in test_rollover_count()
[all …]
H A Dmod.rs162 let s = SrtpSsrcState { in get_srtp_ssrc_state() localVariable
168 self.srtp_ssrc_states.entry(ssrc).or_insert(s); in get_srtp_ssrc_state()
173 let s = SrtcpSsrcState { in get_srtcp_ssrc_state() localVariable
178 self.srtcp_ssrc_states.entry(ssrc).or_insert(s); in get_srtcp_ssrc_state()
184 self.srtp_ssrc_states.get(&ssrc).map(|s| s.rollover_counter) in get_roc()
189 if let Some(s) = self.get_srtp_ssrc_state(ssrc) { in set_roc()
190 s.rollover_counter = roc; in set_roc()
196 self.srtcp_ssrc_states.get(&ssrc).map(|s| s.srtcp_index) in get_index()
201 if let Some(s) = self.get_srtcp_ssrc_state(ssrc) { in set_index()
202 s.srtcp_index = index; in set_index()
/webrtc/webrtc/src/rtp_transceiver/fmtp/h264/
H A Dmod.rs56 Some(s) => s, in match_fmtp()
60 Some(s) => s, in match_fmtp()
70 Some(s) => s, in match_fmtp()
74 Some(s) => s, in match_fmtp()
/webrtc/constraints/src/algorithms/fitness_distance/
H A Dvalue_constraint.rs10 (setting: $s:ty, constraint: $c:ty) => {
11 impl<'a> FitnessDistance<Option<&'a $s>> for ResolvedValueConstraint<$c>
13 $s: PartialEq<$c>,
17 fn fitness_distance(&self, setting: Option<&'a $s>) -> Result<f64, Self::Error> {
88 (setting: $s:ty, constraint: $c:ty) => {
89 impl<'a> FitnessDistance<Option<&'a $s>> for ResolvedValueConstraint<$c> {
92 fn fitness_distance(&self, setting: Option<&'a $s>) -> Result<f64, Self::Error> {
168 (settings: [$($s:ty),+], constraint: bool) => {
169 $(impl_exists_value_constraint!(setting: $s, constraint: bool);)+
171 (setting: $s:ty, constraint: bool) => {
[all …]
H A Dvalue_range_constraint.rs8 (setting: $s:ty, constraint: $c:ty) => {
9 impl<'a> FitnessDistance<Option<&'a $s>> for ResolvedValueRangeConstraint<$c> {
12 fn fitness_distance(&self, setting: Option<&'a $s>) -> Result<f64, Self::Error> {
150 (settings: [$($s:ty),+], constraint: $c:ty) => {
151 $(impl_ignored_value_range_constraint!(setting: $s, constraint: $c);)+
153 (setting: $s:ty, constraint: $c:ty) => {
154 impl<'a> FitnessDistance<Option<&'a $s>> for ResolvedValueRangeConstraint<$c> {
157 fn fitness_distance(&self, _setting: Option<&'a $s>) -> Result<f64, Self::Error> {
H A Dvalue_sequence_constraint.rs8 (setting: $s:ty, constraint: $c:ty) => {
9 impl<'a> FitnessDistance<Option<&'a $s>> for ResolvedValueSequenceConstraint<$c>
11 $s: PartialEq<$c>,
15 fn fitness_distance(&self, setting: Option<&'a $s>) -> Result<f64, Self::Error> {
82 (setting: $s:ty, constraint: $c:ty) => {
83 impl<'a> FitnessDistance<Option<&'a $s>> for ResolvedValueSequenceConstraint<$c> {
86 fn fitness_distance(&self, setting: Option<&'a $s>) -> Result<f64, Self::Error> {
/webrtc/sctp/src/chunk/
H A Dchunk_forward_tsn.rs42 for s in &self.streams { in fmt()
43 res.push(format!(" - si={}, ssn={}", s.identifier, s.sequence)); in fmt()
77 let s = ChunkForwardTsnStream::unmarshal( in unmarshal() localVariable
80 offset += s.value_length(); in unmarshal()
81 remaining -= s.value_length(); in unmarshal()
82 streams.push(s); in unmarshal()
96 for s in &self.streams { in marshal_to()
97 writer.extend(s.marshal()?); in marshal_to()
/webrtc/stun/src/textattrs/
H A Dtextattrs_test.rs27 let s = s_attr.to_string(); in test_software_get_from() localVariable
36 let s = TextAttribute { in test_software_add_to_invalid() localVariable
40 let result = s.add_to(&mut m); in test_software_add_to_invalid()
73 let s = TextAttribute { in test_software_add_to_regression() localVariable
77 s.add_to(&mut m)?; in test_software_add_to_regression()
182 let s = r_attr.to_string(); in test_realm_get_from() localVariable
191 let s = TextAttribute { in test_realm_add_to_invalid() localVariable
195 let result = s.add_to(&mut m); in test_realm_add_to_invalid()
255 let s = r_attr.to_string(); in test_nonce_get_from() localVariable
264 let s = TextAttribute { in test_nonce_add_to_invalid() localVariable
[all …]
/webrtc/rtp/src/extension/abs_send_time_extension/
H A Dmod.rs88 let mut s = u / 1_000_000_000; in unix2ntp() localVariable
89 s += 0x83AA7E80; //offset in seconds between unix epoch and ntp epoch in unix2ntp()
93 s <<= 32; in unix2ntp()
95 s | f in unix2ntp()
99 let mut s = t >> 32; in ntp2unix() localVariable
103 s -= 0x83AA7E80; in ntp2unix()
104 let u = s * 1_000_000_000 + f; in ntp2unix()
/webrtc/sdp/src/
H A Derror.rs37 …#[error("{} --> {} <-- {}", .s.substring(0,*.p), .s.substring(*.p, *.p+1), .s.substring(*.p+1, .s.…
38 SyntaxError { s: String, p: usize },
/webrtc/webrtc/src/api/
H A Dapi_test.rs5 let mut s = SettingEngine::default(); in test_new_api() localVariable
6 s.detach_data_channels(); in test_new_api()
11 .with_setting_engine(s) in test_new_api()
/webrtc/examples/examples/signal/src/
H A Dlib.rs28 Ok(s) => s.to_owned(), in remote_handler()
100 pub fn decode(s: &str) -> Result<String> { in decode()
101 let b = base64::decode(s)?; in decode()
107 let s = String::from_utf8(b)?; in decode() localVariable
108 Ok(s) in decode()
/webrtc/mdns/src/message/
H A Dmod.rs78 let s = match *self { in fmt() localVariable
132 let s = match *self { in fmt() localVariable
194 let s = match *self { in fmt() localVariable
248 s += ", Questions: "; in fmt()
250 s += &v.join(", "); in fmt()
252 s += ", Answers: "; in fmt()
254 s += &v.join(", "); in fmt()
256 s += ", Authorities: "; in fmt()
258 s += &v.join(", "); in fmt()
260 s += ", Additionals: "; in fmt()
[all …]
/webrtc/sctp/src/queue/
H A Dreassembly_queue.rs165 for s in &mut self.ordered { in push()
166 if s.ssn == chunk.stream_sequence_number { in push()
167 return s.push(chunk); in push()
307 .filter(|s| sna16lte(s.ssn, last_ssn) && !s.is_complete()) in forward_tsn_for_ordered()
308 .fold(0, |n, s| { in forward_tsn_for_ordered()
309 n + s.chunks.iter().fold(0, |acc, c| acc + c.user_data.len()) in forward_tsn_for_ordered()
314 .retain(|s| !sna16lte(s.ssn, last_ssn) || s.is_complete()); in forward_tsn_for_ordered()
/webrtc/sctp/src/association/association_internal/
H A Dassociation_internal_test.rs143 for s in &fwdtsn.streams { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
144 match s.identifier { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
146 assert_eq!(3, s.sequence, "ssn should be 3"); in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
150 assert_eq!(1, s.sequence, "ssn should be 1"); in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
331 let s = a.create_stream(i as u16, true); in test_assoc_create_new_stream() localVariable
332 if let Some(s) = s { in test_assoc_create_new_stream()
333 let result = a.streams.get(&s.stream_identifier); in test_assoc_create_new_stream()
341 let s = a.create_stream(new_si, true); in test_assoc_create_new_stream() localVariable
342 assert!(s.is_none(), "should be none"); in test_assoc_create_new_stream()
467 if let Some(s) = stream { in test_assoc_max_message_size_default()
[all …]
/webrtc/webrtc/src/peer_connection/sdp/
H A Dsdp_test.rs18 let s = SessionDescription { in test_extract_fingerprint() localVariable
33 let s = SessionDescription { in test_extract_fingerprint() localVariable
62 let s = SessionDescription { in test_extract_fingerprint() localVariable
79 let s = SessionDescription { in test_extract_fingerprint() localVariable
111 let s = SessionDescription { in test_extract_ice_details() localVariable
131 let s = SessionDescription { in test_extract_ice_details() localVariable
151 let s = SessionDescription { in test_extract_ice_details() localVariable
173 let s = SessionDescription { in test_extract_ice_details() localVariable
541 let s = populate_sdp( in fingerprint_test() localVariable
542 s, in fingerprint_test()
[all …]
/webrtc/turn/src/client/
H A Dbinding.rs100 if let Some(s) = self.chan_map.get(&number) { in find_by_number()
101 self.addr_map.get(s) in find_by_number()
108 if let Some(s) = self.chan_map.get(&number) { in get_by_number()
109 self.addr_map.get_mut(s) in get_by_number()
125 if let Some(s) = self.chan_map.remove(&number) { in delete_by_number()
126 self.addr_map.remove(&s); in delete_by_number()
/webrtc/media/src/io/sample_builder/
H A Dsample_builder_test.rs1233 s.push(Packet { in test_sample_builder_max_late()
1241 s.push(Packet { in test_sample_builder_max_late()
1249 s.push(Packet { in test_sample_builder_max_late()
1258 s.pop(), in test_sample_builder_max_late()
1268 s.push(Packet { in test_sample_builder_max_late()
1276 s.push(Packet { in test_sample_builder_max_late()
1284 s.push(Packet { in test_sample_builder_max_late()
1294 s.pop(), in test_sample_builder_max_late()
1314 s.pop(), in test_sample_builder_max_late()
1325 s.pop(), in test_sample_builder_max_late()
[all …]
/webrtc/util/src/vnet/chunk/
H A Dchunk_test.rs29 let s = c.to_string(); in test_chunk_udp() localVariable
30 log::debug!("chunk: {}", s); in test_chunk_udp()
32 assert!(s.contains(&src.to_string()), "should include address"); in test_chunk_udp()
33 assert!(s.contains(&dst.to_string()), "should include address"); in test_chunk_udp()
/webrtc/interceptor/src/mock/
H A Dmock_stream.rs317 let s = MockStream::new(&StreamInfo::default(), Arc::new(NoOp)).await; in test_mock_stream() localVariable
319 s.write_rtcp(&[Box::<PictureLossIndication>::default()]) in test_mock_stream()
321 timeout_or_fail(Duration::from_millis(10), s.written_rtcp()).await; in test_mock_stream()
328 s.write_rtp(&rtp::packet::Packet::default()).await?; in test_mock_stream()
329 timeout_or_fail(Duration::from_millis(10), s.written_rtp()).await; in test_mock_stream()
336 s.receive_rtcp(vec![Box::<PictureLossIndication>::default()]) in test_mock_stream()
339 timeout_or_fail(Duration::from_millis(10), s.read_rtcp()) in test_mock_stream()
350 s.receive_rtp(rtp::packet::Packet::default()).await; in test_mock_stream()
352 timeout_or_fail(Duration::from_millis(10), s.read_rtp()) in test_mock_stream()
357 let result = tokio::time::timeout(Duration::from_millis(10), s.read_rtp()).await; in test_mock_stream()
[all …]
/webrtc/stun/src/
H A Duattrs.rs20 let mut s = vec![]; in fmt() localVariable
22 s.push(t.to_string()); in fmt()
24 write!(f, "{}", s.join(", ")) in fmt()
/webrtc/sdp/src/extmap/
H A Dextmap_test.rs66 let s = e.marshal(); in test_transport_cc_extmap() localVariable
67 if s == "3 http://www.ietf.org/id/draft-holmer-rmcat-transport-wide-cc-extensions-01" { in test_transport_cc_extmap()
71 s, in test_transport_cc_extmap()
/webrtc/turn/src/server/
H A Dmod.rs44 let mut s = Server { in new() localVariable
52 if s.channel_bind_timeout == Duration::from_secs(0) { in new()
53 s.channel_bind_timeout = DEFAULT_LIFETIME; in new()
57 let nonces = Arc::clone(&s.nonces); in new()
58 let auth_handler = Arc::clone(&s.auth_handler); in new()
59 let realm = s.realm.clone(); in new()
60 let channel_bind_timeout = s.channel_bind_timeout; in new()
79 Ok(s) in new()

1234567