| /webrtc/util/src/conn/ |
| H A D | conn_bridge.rs | 17 id: usize, field
49 self.br.push(b, self.id).await in send()
100 id: 0, in new()
106 id: 1, in new()
116 pub async fn len(&self, id: usize) -> usize { in len()
117 let q = self.queue[id].lock().await; in len()
155 pub async fn reorder(&self, id: usize) -> bool { in reorder()
156 let mut queue = self.queue[id].lock().await; in reorder()
163 let mut queue = self.queue[id].lock().await; in drop_offset()
180 for id in 0..2 { in clear()
[all …]
|
| /webrtc/stun/src/ |
| H A D | agent.rs | 75 id: TransactionId, field
132 let v = self.transactions.remove(&id); in stop_with_error()
173 for id in self.transactions.keys() { in close()
197 if self.transactions.contains_key(&id) { in start()
202 .insert(id, AgentTransaction { id, deadline }); in start()
232 for (id, t) in &self.transactions { in collect()
234 to_remove.push(*id); in collect()
238 for id in &to_remove { in collect()
239 self.transactions.remove(id); in collect()
242 for id in to_remove { in collect()
[all …]
|
| H A D | client.rs | 82 id: TransactionId, field
271 event_type: EventType::Remove(id), in remove()
293 if t.contains_key(&ct.id) { in start()
296 t.insert(ct.id, ct); in start()
298 EventType::Remove(id) => { in start()
299 t.remove(&id); in start()
301 EventType::Callback(id) => { in start()
303 t.remove(&id).unwrap() in start()
323 let id = ct.id; in start() localVariable
326 t.insert(ct.id, ct); in start()
[all …]
|
| /webrtc/rtp/src/ |
| H A D | header.rs | 31 pub id: u8, field
138 id: extid, in unmarshal()
162 id: extid, in unmarshal()
174 id: 0, in unmarshal()
288 buf.put_u8(extension.id); in marshal_to()
343 if !(1..=14).contains(&id) { in set_extension()
351 if id < 1 { in set_extension()
359 if id != 0 { in set_extension()
369 .find(|extension| extension.id == id) in set_extension()
404 .find(|extension| extension.id == id) in get_extension()
[all …]
|
| /webrtc/mdns/src/message/ |
| H A D | header.rs | 6 pub id: u16, field
21 self.id, in fmt()
35 let id = self.id; in pack() localVariable
53 (id, bits) in pack()
101 pub id: u16, field
122 msg = pack_uint16(msg, self.id); in pack()
132 let (id, off) = unpack_uint16(msg, off)?; in unpack()
133 self.id = id; in unpack()
155 id: self.id, in header()
|
| /webrtc/turn/src/client/ |
| H A D | periodic_timer.rs | 21 async fn on_timeout(&mut self, id: TimerIdRefresh); in on_timeout()
27 id: TimerIdRefresh, field
34 pub fn new(id: TimerIdRefresh, interval: Duration) -> Self { in new()
36 id, in new()
57 let id = self.id; in start() localVariable
67 handler.on_timeout(id).await; in start()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | sender_test.rs | 30 id: 1, in test_twcc_sender_interceptor()
38 let id = i + 1; in test_twcc_sender_interceptor() localVariable
40 for seq_num in [id * 1, id * 2, id * 3, id * 4, id * 5] { in test_twcc_sender_interceptor()
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | track_local_static_rtp.rs | 16 id: String, field
22 pub fn new(codec: RTCRtpCodecCapability, id: String, stream_id: String) -> Self { in new()
26 id, in new()
103 if let Some(id) = b in write_rtp_with_extensions()
108 .map(|ext| ext.id) in write_rtp_with_extensions()
110 if let Err(err) = pkt.header.set_extension(id as u8, data.clone()) { in write_rtp_with_extensions()
156 id: t.id(), in bind()
173 if binding.id == t.id() { in unbind()
189 fn id(&self) -> &str { in id() method
190 self.id.as_str() in id()
|
| H A D | mod.rs | 34 pub(crate) id: String, field
67 pub fn id(&self) -> String { in id() method
68 self.id.clone() in id()
88 fn id(&self) -> &str; in id() method
104 id: String, field
|
| /webrtc/dtls/src/ |
| H A D | compression_methods.rs | 34 for id in &self.ids { in marshal()
35 writer.write_u8(*id as u8)?; in marshal()
45 let id = reader.read_u8()?.into(); in unmarshal() localVariable
46 if id != CompressionMethodId::Unsupported { in unmarshal()
47 ids.push(id); in unmarshal()
|
| /webrtc/webrtc/src/api/media_engine/ |
| H A D | mod.rs | 533 id: isize, in update_header_extension()
550 if *n_ext.0 == id { in update_header_extension()
641 for (extension, id) in extensions { in update_from_remote_description()
686 id: *id, in get_rtp_parameters_by_kind()
714 id: *id, in get_rtp_parameters_by_kind()
727 id: *id, in get_rtp_parameters_by_kind()
735 let id = VALID_EXT_IDS.clone().find(|id| { in get_rtp_parameters_by_kind() localVariable
740 if let Some(id) = id { in get_rtp_parameters_by_kind()
742 id, in get_rtp_parameters_by_kind()
752 id, in get_rtp_parameters_by_kind()
[all …]
|
| /webrtc/dtls/src/cipher_suite/ |
| H A D | cipher_suite_aes_128_ccm.rs | 10 id: CipherSuiteId, field
22 id: CipherSuiteId, in new()
29 id, in new()
38 format!("{}", self.id) in to_string()
41 fn id(&self) -> CipherSuiteId { in id() method
42 self.id in id()
|
| /webrtc/webrtc/src/stats/ |
| H A D | mod.rs | 146 pub id: String, field
227 pub id: String, field
245 id: stats.id, in new()
266 pub id: String, field
276 id, in new()
293 pub id: String, field
323 pub id: String, field
357 pub id: String, field
412 pub id: String, field
445 pub id: String, field
[all …]
|
| H A D | stats_collector.rs | 19 pub(crate) fn insert(&self, id: String, stats: StatsReportType) { in insert()
21 reports.insert(id, stats); in insert()
|
| /webrtc/interceptor/src/ |
| H A D | registry.rs | 25 pub fn build(&self, id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build()
30 self.build_chain(id) in build()
35 pub fn build_chain(&self, id: &str) -> Result<Chain> { in build_chain()
40 let interceptors: Result<Vec<_>> = self.builders.iter().map(|b| b.build(id)).collect(); in build_chain()
|
| H A D | stream_info.rs | 7 pub id: isize, field
13 pub id: String, field
|
| /webrtc/stun/src/agent/ |
| H A D | agent_test.rs | 74 let id = TransactionId::new(); in test_agent_start() localVariable
76 a.start(id, deadline)?; in test_agent_start()
78 let result = a.start(id, deadline); in test_agent_start()
92 let id = TransactionId::new(); in test_agent_start() localVariable
93 let result = a.start(id, deadline); in test_agent_start()
140 let id = TransactionId::new(); in test_agent_stop() localVariable
142 a.start(id, deadline)?; in test_agent_stop()
143 a.stop(id)?; in test_agent_stop()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_stats.rs | 156 pub id: String, field
201 id: String::new(), in default()
222 local_candidate_id: cp.local.id(), in get_candidate_pairs_stats()
223 remote_candidate_id: cp.remote.id(), in get_candidate_pairs_stats()
241 id: c.id(), in get_local_candidates_stats()
266 id: c.id(), in get_remote_candidates_stats()
|
| /webrtc/sctp/src/timer/ |
| H A D | rtx_timer.rs | 108 pub(crate) id: RtxTimerId, field
119 id: RtxTimerId, in new()
124 id, in new()
149 let id = self.id; in start() localVariable
170 observer.on_retransmission_timeout(id, n_rtos).await; in start()
173 observer.on_retransmission_failure(id).await; in start()
|
| /webrtc/webrtc/src/mux/ |
| H A D | mod.rs | 32 id: Arc<AtomicUsize>, field
43 id: Arc::new(AtomicUsize::new(0)), in new()
64 let id = self.id.fetch_add(1, Ordering::SeqCst); in new_endpoint() localVariable
69 id, in new_endpoint()
76 endpoints.insert(e.id, Arc::clone(&e)); in new_endpoint()
84 endpoints.remove(&e.id); in remove_endpoint()
|
| /webrtc/rtp/src/packet/ |
| H A D | packet_test.rs | 34 id: 0, in test_basic()
105 id: 0, in test_extension()
188 id: 5, in test_rfc_8285_one_byte_extension()
428 id: 5, in test_rfc_8285_two_byte_extension()
605 id: 1, in test_rfc8285_del_extension()
676 for id in ids { in test_rfc8285_get_extension_ids()
809 id: 1, in test_rfc8285_set_extension_should_update_existing_extension()
850 id: 1, in test_rfc8285_one_byte_set_extension_should_error_when_invalid_id_provided()
908 id: 1, in test_rfc8285_one_byte_set_extension_should_error_when_payload_too_large()
990 id: 1, in test_rfc8285_two_byte_set_extension_should_update_existing_extension()
[all …]
|
| /webrtc/webrtc/src/track/track_remote/ |
| H A D | mod.rs | 44 id: SyncMutex<String>, field
67 .field("id", &self.id) in fmt()
91 id: Default::default(), in new()
116 pub fn id(&self) -> String { in id() method
117 let id = self.id.lock(); in id() localVariable
118 id.clone() in id()
122 let mut id = self.id.lock(); in set_id() localVariable
123 *id = s; in set_id()
173 format!("{} {}", self.stream_id(), self.id()) in msid()
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | sctp_transport_test.rs | 8 for id in ids { in test_generate_data_channel_id()
10 id: AtomicU16::new(*id), in test_generate_data_channel_id()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 104 pub(crate) id: String, field
126 .field("id", &self.id) in fmt()
140 let id = generate_crypto_random_string( in new() localVariable
198 id, in new()
336 id: context.id.clone(), in replace_track()
387 id: self.id.clone(), in send()
412 self.id.clone(), in send()
519 *lock = Some(id); in set_initial_track_id()
524 pub(crate) fn associate_media_stream_id(&self, id: String) -> bool { in associate_media_stream_id()
527 if lock.contains(&id) { in associate_media_stream_id()
[all …]
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_builder.rs | 19 fn build(&self, id: &str) -> MockBuilderResult { in build()
20 (self.build)(id) in build()
|