Home
last modified time | relevance | path

Searched refs:t (Results 1 – 25 of 69) sorted by relevance

123

/webrtc/ice/src/control/
H A Dmod.rs18 pub fn add_to_as(self, m: &mut Message, t: AttrType) -> Result<(), stun::Error> { in add_to_as()
21 m.add(t, &v); in add_to_as()
26 pub fn get_from_as(&mut self, m: &Message, t: AttrType) -> Result<(), stun::Error> { in get_from_as()
27 let v = m.get(t)?; in get_from_as()
28 check_size(t, v.len(), TIE_BREAKER_SIZE)?; in get_from_as()
47 let mut t = TieBreaker::default(); in get_from() localVariable
48 t.get_from_as(m, ATTR_ICE_CONTROLLED)?; in get_from()
49 self.0 = t.0; in get_from()
68 let mut t = TieBreaker::default(); in get_from() localVariable
69 t.get_from_as(m, ATTR_ICE_CONTROLLING)?; in get_from()
[all …]
/webrtc/webrtc/src/rtp_transceiver/rtp_sender/
H A Dmod.rs223 if let Some(t) = rtp_transceiver.as_ref().and_then(|t| t.upgrade()) { in set_rtp_transceiver()
246 t.kind() in get_parameters()
267 if let Some(t) = &tr { in get_parameters()
268 if let Some(t) = t.upgrade() { in get_parameters()
295 if let Some(t) = &track { in replace_track()
311 let t = { in replace_track() localVariable
313 t.clone() in replace_track()
315 if let Some(t) = t { in replace_track()
323 *t = track; in replace_track()
369 *t = track; in replace_track()
[all …]
/webrtc/webrtc/src/rtp_transceiver/rtp_receiver/
H A Dmod.rs201 for t in &*tracks { in read_simulcast()
265 for t in &*tracks { in read_rtp()
490 tracks.first().map(|t| Arc::clone(&t.track)) in track()
498 tracks.iter().map(|t| Arc::clone(&t.track)).collect() in tracks()
551 let t = TrackStreams { in receive() localVariable
580 tracks.push(t); in receive()
692 for t in &*tracks { in stop()
750 for t in &mut *tracks { in receive_for_rid()
757 t.track in receive_for_rid()
759 t.stream = stream; in receive_for_rid()
[all …]
/webrtc/stun/src/
H A Duattrs.rs21 for t in &self.0 { in fmt()
22 s.push(t.to_string()); in fmt()
37 for t in &self.0 { in add_to()
38 v.extend_from_slice(&t.value().to_be_bytes()); in add_to()
H A Dclient.rs283 mut t: HashMap<TransactionId, ClientTransaction>, in start()
293 if t.contains_key(&ct.id) { in start()
296 t.insert(ct.id, ct); in start()
299 t.remove(&id); in start()
303 t.remove(&id).unwrap() in start()
326 t.insert(ct.id, ct); in start()
334 let ct = t.remove(&id).unwrap(); in start()
407 t, in run()
437 let t = ClientTransaction { in send() localVariable
446 let d = t.next_timeout(t.start); in send()
[all …]
H A Dxoraddr.rs117 pub fn add_to_as(&self, m: &mut Message, t: AttrType) -> Result<()> { in add_to_as()
131 m.add(t, &value[..4 + ip_len]); in add_to_as()
137 pub fn get_from_as(&mut self, m: &Message, t: AttrType) -> Result<()> { in get_from_as()
138 let v = m.get(t)?; in get_from_as()
149 t, in get_from_as()
H A Daddr.rs66 pub fn get_from_as(&mut self, m: &Message, t: AttrType) -> Result<()> { in get_from_as()
67 let v = m.get(t)?; in get_from_as()
94 pub fn add_to_as(&self, m: &mut Message, t: AttrType) -> Result<()> { in add_to_as()
110 m.add(t, &value); in add_to_as()
H A Dmessage.rs170 pub fn add(&mut self, t: AttrType, v: &[u8]) { in add()
188 buf[0..2].copy_from_slice(&t.value().to_be_bytes()); // T in add()
195 typ: t, // T in add()
258 pub fn set_type(&mut self, t: MessageType) { in set_type()
259 self.typ = t; in set_type()
279 let t = u16::from_be_bytes([buf[0], buf[1]]); // first 2 bytes in decode() localVariable
298 self.typ.read_value(t); in decode()
385 pub fn contains(&self, t: AttrType) -> bool { in contains()
387 if a.typ == t { in contains()
397 pub fn get(&self, t: AttrType) -> Result<Vec<u8>> { in get()
[all …]
H A Dagent.rs133 if let Some(t) = v { in stop_with_error()
136 event_type: EventType::Callback(t.id), in stop_with_error()
232 for (id, t) in &self.transactions { in collect()
233 if t.deadline < deadline { in collect()
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_internal.rs177 for t in tracks { in start_rtp()
374 Arc::clone(t), in start_rtp_receivers()
484 Ok(t) in add_transceiver_from_kind()
539 rtp_transceivers.push(t); in add_rtp_transceiver()
879 let t = self in handle_undeclared_ssrc() localVariable
889 let receiver = t.receiver(); in handle_undeclared_ssrc()
894 t, in handle_undeclared_ssrc()
1044 Arc::clone(t), in handle_incoming_ssrc()
1067 if t.ssrc() == 0 { in start_receiver()
1234 .fetch_inbound_stats(track_infos.iter().map(|t| t.ssrc).collect()) in collect_inbound_stats()
[all …]
H A Dmod.rs450 for t in &*transceivers { in check_negotiation_needed()
456 let mid = t.mid(); in check_negotiation_needed()
781 if t.mid().is_some() { in create_offer()
798 t.set_mid(mid)?; in create_offer()
1246 Some(t) => t, in set_local_description()
1350 let t = if let Some(t) = in set_remote_description() localVariable
1353 Some(t) in set_remote_description()
1359 if let Some(t) = t { in set_remote_description()
1680 if !t.stopped.load(Ordering::SeqCst) && t.kind == track.kind() { in add_track()
1774 let t = self in add_transceiver_from_track() localVariable
[all …]
/webrtc/webrtc/src/track/track_local/
H A Dtrack_local_static_rtp.rs141 async fn bind(&self, t: &TrackLocalContext) -> Result<RTCRtpCodecParameters> { in bind()
147 let (codec, match_type) = codec_parameters_fuzzy_search(&parameters, t.codec_parameters()); in bind()
152 ssrc: t.ssrc(), in bind()
154 write_stream: t.write_stream(), in bind()
155 params: t.params.clone(), in bind()
156 id: t.id(), in bind()
157 sender_paused: t.paused.clone(), in bind()
169 async fn unbind(&self, t: &TrackLocalContext) -> Result<()> { in unbind()
173 if binding.id == t.id() { in unbind()
H A Dtrack_local_static_sample.rs184 async fn bind(&self, t: &TrackLocalContext) -> Result<RTCRtpCodecParameters> { in bind()
185 let codec = self.rtp_track.bind(t).await?; in bind()
213 async fn unbind(&self, t: &TrackLocalContext) -> Result<()> { in unbind()
214 self.rtp_track.unbind(t).await in unbind()
/webrtc/mdns/src/message/resource/
H A Dtxt.rs43 let (t, new_off) = unpack_str(msg, off)?; in unpack()
46 if length < n + t.as_bytes().len() + 1 { in unpack()
49 n += t.len() + 1; in unpack()
50 txts.push(t); in unpack()
/webrtc/webrtc/src/api/setting_engine/
H A Dmod.rs120 pub fn set_host_acceptance_min_wait(&mut self, t: Option<Duration>) { in set_host_acceptance_min_wait()
121 self.timeout.ice_host_acceptance_min_wait = t; in set_host_acceptance_min_wait()
125 pub fn set_srflx_acceptance_min_wait(&mut self, t: Option<Duration>) { in set_srflx_acceptance_min_wait()
126 self.timeout.ice_srflx_acceptance_min_wait = t; in set_srflx_acceptance_min_wait()
130 pub fn set_prflx_acceptance_min_wait(&mut self, t: Option<Duration>) { in set_prflx_acceptance_min_wait()
131 self.timeout.ice_prflx_acceptance_min_wait = t; in set_prflx_acceptance_min_wait()
135 pub fn set_relay_acceptance_min_wait(&mut self, t: Option<Duration>) { in set_relay_acceptance_min_wait()
136 self.timeout.ice_relay_acceptance_min_wait = t; in set_relay_acceptance_min_wait()
/webrtc/turn/src/auth/
H A Dmod.rs21 let t = SystemTime::now().duration_since(UNIX_EPOCH)? + duration; in generate_long_term_credentials() localVariable
22 let username = format!("{}", t.as_secs()); in generate_long_term_credentials()
58 let t = Duration::from_secs(username.parse::<u64>()?); in auth_handle() localVariable
59 if t < SystemTime::now().duration_since(UNIX_EPOCH)? { in auth_handle()
/webrtc/rtp/src/codecs/vp8/
H A Dvp8_test.rs34 assert_eq!(pck.t, 0, "T must be 0"); in test_vp8_unmarshal()
44 assert_eq!(pck.t, 0, "T must be 0"); in test_vp8_unmarshal()
54 assert_eq!(pck.t, 0, "T must be 0"); in test_vp8_unmarshal()
64 assert_eq!(pck.t, 1, "T must be 1"); in test_vp8_unmarshal()
74 assert_eq!(pck.t, 0, "T must be 0"); in test_vp8_unmarshal()
86 assert_eq!(pck.t, 1, "T must be 1"); in test_vp8_unmarshal()
98 assert_eq!(pck.t, 1, "T must be 1"); in test_vp8_unmarshal()
H A Dmod.rs132 pub t: u8, field
187 self.t = (b & 0x20) >> 5; in depacketize()
217 if self.t == 1 || self.k == 1 { in depacketize()
219 if self.t == 1 { in depacketize()
/webrtc/rtp/src/extension/abs_send_time_extension/
H A Dabs_send_time_extension_test.rs36 for (t, n) in &tests { in test_ntp_conversion()
38 .checked_add(Duration::from_nanos(t.timestamp_nanos() as u64)) in test_ntp_conversion()
54 for (t, n) in &tests { in test_ntp_conversion()
57 .checked_add(Duration::from_nanos(t.timestamp_nanos() as u64)) in test_ntp_conversion()
H A Dmod.rs98 pub fn ntp2unix(t: u64) -> SystemTime { in ntp2unix()
99 let mut s = t >> 32; in ntp2unix()
100 let mut f = t & 0xFFFFFFFF; in ntp2unix()
/webrtc/rtcp/src/extended_report/
H A Dprt.rs28 pub t: u8, field
47 type_specific: self.t & 0x0F, in xr_header()
129 let t = xr_header.type_specific & 0x0F; in unmarshal() localVariable
142 t, in unmarshal()
H A Dextended_report_test.rs9 t: 12, in decoded_packet()
18 t: 6, in decoded_packet()
26 t: 3, in decoded_packet()
H A Drle.rs109 pub t: u8, field
136 type_specific: self.t & 0x0F, in xr_header()
225 let t = xr_header.type_specific & 0x0F; in unmarshal() localVariable
239 t, in unmarshal()
/webrtc/webrtc/src/rtp_transceiver/
H A Dmod.rs207 let t = Arc::new(RTCRtpTransceiver { in new() localVariable
221 t.sender().set_rtp_transceiver(Some(Arc::downgrade(&t))); in new()
223 t in new()
481 for (i, t) in local_transceivers.iter().enumerate() { in find_by_mid()
482 if t.mid().as_deref() == Some(mid) { in find_by_mid()
514 for (i, t) in local_transceivers.iter().enumerate() { in satisfy_type_and_direction()
515 if t.mid().is_none() && t.kind == remote_kind && possible_direction == t.direction() { in satisfy_type_and_direction()
/webrtc/constraints/src/algorithms/fitness_distance/
H A Dempty_constraint.rs27 settings: $t:ty => $s:expr,
30 let settings: &[Option<$t>] = $s;

123