| /webrtc/webrtc/src/stats/ |
| H A D | stats_collector.rs | 9 pub(crate) reports: Mutex<HashMap<String, StatsReportType>>, field
20 let mut reports = self.reports.lock(); in insert() localVariable
21 reports.insert(id, stats); in insert()
25 let mut reports = self.reports.lock(); in merge() localVariable
26 reports.extend(stats) in merge()
30 self.reports.into_inner() in into_reports()
|
| H A D | mod.rs | 118 pub reports: HashMap<String, StatsReportType>, field
124 reports: collector.into_reports(), in from()
134 self.reports.serialize(serializer) in serialize()
|
| /webrtc/rtcp/src/receiver_report/ |
| H A D | mod.rs | 25 pub reports: Vec<ReceptionReport>, field
35 for rep in &self.reports { in fmt()
53 count: self.reports.len() as u8, in header()
61 self.reports.iter().map(|x| x.ssrc).collect() in destination_ssrc()
66 for rep in &self.reports { in raw_size()
100 if self.reports.len() > COUNT_MAX { in marshal_to()
141 for report in &self.reports { in marshal_to()
203 let mut reports = Vec::with_capacity(header.count as usize); in unmarshal() localVariable
209 reports.push(reception_report); in unmarshal()
221 reports, in unmarshal()
|
| H A D | receiver_report_test.rs | 20 reports: vec![ReceptionReport { in test_receiver_report_unmarshal()
49 reports: vec![ReceptionReport { in test_receiver_report_unmarshal()
160 reports: vec![ in test_receiver_report_roundtrip()
180 reports: vec![ReceptionReport { in test_receiver_report_roundtrip()
197 reports: vec![ReceptionReport { in test_receiver_report_roundtrip()
209 reports: too_many_reports, in test_receiver_report_roundtrip()
|
| /webrtc/rtcp/src/extended_report/ |
| H A D | dlrr.rs | 39 pub reports: Vec<DLRRReport>, field
65 let mut ssrc = Vec::with_capacity(self.reports.len()); in destination_ssrc()
66 for r in &self.reports { in destination_ssrc()
73 XR_HEADER_LENGTH + self.reports.len() * 4 * 3 in raw_size()
107 for rep in &self.reports { in marshal_to()
136 let mut reports = vec![]; in unmarshal() localVariable
141 reports.push(DLRRReport { in unmarshal()
149 Ok(DLRRReportBlock { reports }) in unmarshal()
|
| H A D | mod.rs | 159 pub reports: Vec<Box<dyn Packet + Send + Sync>>, field
182 for p in &self.reports { in destination_ssrc()
190 for rep in &self.reports { in raw_size()
233 for report in &self.reports { in marshal_to()
266 let mut reports = vec![]; in unmarshal() localVariable
293 reports.push(report); in unmarshal()
298 reports, in unmarshal()
|
| H A D | extended_report_test.rs | 6 reports: vec![ in decoded_packet()
37 reports: vec![ in decoded_packet()
|
| /webrtc/rtcp/src/sender_report/ |
| H A D | mod.rs | 55 pub reports: Vec<ReceptionReport>, field
70 for rep in &self.reports { in fmt()
88 count: self.reports.len() as u8, in header()
96 let mut out: Vec<u32> = self.reports.iter().map(|x| x.ssrc).collect(); in destination_ssrc()
103 for rep in &self.reports { in raw_size()
137 if self.reports.len() > COUNT_MAX { in marshal_to()
192 for report in &self.reports { in marshal_to()
268 let mut reports = Vec::with_capacity(header.count as usize); in unmarshal() localVariable
274 reports.push(reception_report); in unmarshal()
290 reports, in unmarshal()
|
| H A D | sender_report_test.rs | 34 reports: vec![ReceptionReport { in test_sender_report_unmarshal()
104 reports: vec![], in test_sender_report_unmarshal()
164 reports: vec![ in test_sender_report_roundtrip()
184 reports: vec![ReceptionReport { in test_sender_report_roundtrip()
201 reports: vec![ReceptionReport { in test_sender_report_roundtrip()
219 reports: too_many_reports, in test_sender_report_roundtrip()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_test.rs | 40 rr.reports[0], in test_receiver_interceptor_before_any_packet()
103 rr.reports[0], in test_receiver_interceptor_after_rtp_packets()
186 rr.reports[0], in test_receiver_interceptor_after_rtp_and_rtcp_packets()
260 rr.reports[0], in test_receiver_interceptor_overflow()
364 rr.reports[0], in test_receiver_interceptor_overflow_five_pkts()
436 rr.reports[0], in test_receiver_interceptor_packet_loss()
477 rr.reports[0], in test_receiver_interceptor_packet_loss()
547 rr.reports[0], in test_receiver_interceptor_overflow_and_packet_loss()
609 rr.reports[0], in test_receiver_interceptor_reordered_packets()
689 rr.reports[0], in test_receiver_interceptor_jitter()
[all …]
|
| H A D | receiver_stream.rs | 119 reports: vec![rtcp::reception_report::ReceptionReport { in generate_report()
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_gatherer.rs | 292 let mut reports = HashMap::new(); in collect_stats() localVariable
296 reports.insert(stats.id.clone(), StatsReportType::CandidatePair(stats)); in collect_stats()
300 reports.insert( in collect_stats()
307 reports.insert( in collect_stats()
313 collector.merge(reports); in collect_stats()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_test.rs | 336 assert!(!offer_stats.reports.is_empty()); in test_get_stats()
338 match offer_stats.reports.get("ice_transport") { in test_get_stats()
347 .reports in test_get_stats()
361 .reports in test_get_stats()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 450 for recp in &rr.reports { in read()
506 let dlrrs = xr.reports.iter().flat_map(|report| { in read()
509 dlrr.map(|b| b.reports.iter()).into_iter().flatten() in read()
649 for rep in &sr.reports { in write()
960 reports: vec![ in test_stats_interceptor_rtcp()
980 reports: vec![ in test_stats_interceptor_rtcp()
1106 reports: vec![], in test_stats_interceptor_rtcp()
1114 reports: vec![], in test_stats_interceptor_rtcp()
1119 reports: vec![Box::new(DLRRReportBlock { in test_stats_interceptor_rtcp()
1120 reports: vec![DLRRReport { in test_stats_interceptor_rtcp()
[all …]
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | mod.rs | 384 let mut reports = HashMap::new(); in collect_stats() localVariable
387 reports.insert(peer_connection_id, PeerConnection(peer_connection_stats)); in collect_stats()
392 reports.insert(stats.id.clone(), SCTPTransport(stats)); in collect_stats()
395 collector.merge(reports); in collect_stats()
|
| /webrtc/webrtc/src/api/media_engine/ |
| H A D | mod.rs | 463 let mut reports = HashMap::new(); in collect_stats() localVariable
466 reports.insert(codec.stats_id.clone(), Codec(CodecStats::from(codec))); in collect_stats()
470 reports.insert(codec.stats_id.clone(), Codec(CodecStats::from(codec))); in collect_stats()
473 collector.merge(reports); in collect_stats()
|
| /webrtc/rtcp/src/ |
| H A D | packet.rs | 160 reports: vec![ReceptionReport { in test_packet_unmarshal()
|