Home
last modified time | relevance | path

Searched refs:stats (Results 1 – 24 of 24) sorted by relevance

/webrtc/webrtc/src/stats/
H A Dmod.rs82 match stats { in from()
99 StatsReportType::CandidatePair(stats) => stats.serialize(serializer), in serialize()
101 StatsReportType::Codec(stats) => stats.serialize(serializer), in serialize()
102 StatsReportType::DataChannel(stats) => stats.serialize(serializer), in serialize()
103 StatsReportType::LocalCandidate(stats) => stats.serialize(serializer), in serialize()
104 StatsReportType::PeerConnection(stats) => stats.serialize(serializer), in serialize()
105 StatsReportType::RemoteCandidate(stats) => stats.serialize(serializer), in serialize()
106 StatsReportType::SCTPTransport(stats) => stats.serialize(serializer), in serialize()
107 StatsReportType::Transport(stats) => stats.serialize(serializer), in serialize()
108 StatsReportType::InboundRTP(stats) => stats.serialize(serializer), in serialize()
[all …]
H A Dstats_collector.rs19 pub(crate) fn insert(&self, id: String, stats: StatsReportType) { in insert()
21 reports.insert(id, stats); in insert()
24 pub(crate) fn merge(&self, stats: HashMap<String, StatsReportType>) { in merge()
26 reports.extend(stats) in merge()
/webrtc/interceptor/src/stats/
H A Dmod.rs576 let mut stats: RTPStats = Default::default(); in test_rtp_stats() localVariable
578 (stats.header_bytes(), stats.payload_bytes(), stats.packets()), in test_rtp_stats()
582 stats.update(24, 960, 1, SystemTime::now()); in test_rtp_stats()
585 (stats.header_bytes(), stats.payload_bytes(), stats.packets()), in test_rtp_stats()
592 let mut stats: RTCPStats = Default::default(); in test_rtcp_stats() localVariable
594 (stats.fir_count(), stats.pli_count(), stats.nack_count()), in test_rtcp_stats()
598 stats.update(Some(1), Some(2), Some(3)); in test_rtcp_stats()
601 (stats.fir_count(), stats.pli_count(), stats.nack_count()), in test_rtcp_stats()
H A Dinterceptor.rs226 stats in handle_stats_update()
229 stats.mark_updated(); in handle_stats_update()
238 stats in handle_stats_update()
241 stats.mark_updated(); in handle_stats_update()
250 stats.mark_updated(); in handle_stats_update()
259 stats.mark_updated(); in handle_stats_update()
263 stats.record_sr_ext_seq_num(seq_num); in handle_stats_update()
264 stats.mark_updated(); in handle_stats_update()
278 stats.update_remote_jitter(jitter); in handle_stats_update()
280 stats.mark_updated(); in handle_stats_update()
[all …]
/webrtc/webrtc/src/ice_transport/
H A Dice_gatherer.rs9 use crate::stats::stats_collector::StatsCollector;
10 use crate::stats::SourceStatsType::*;
11 use crate::stats::{ICECandidatePairStats, StatsReportType};
294 for stats in agent.get_candidate_pairs_stats().await { in collect_stats()
295 let stats: ICECandidatePairStats = stats.into(); in collect_stats() localVariable
296 reports.insert(stats.id.clone(), StatsReportType::CandidatePair(stats)); in collect_stats()
299 for stats in agent.get_local_candidates_stats().await { in collect_stats()
301 stats.id.clone(), in collect_stats()
302 StatsReportType::from(LocalCandidate(stats)), in collect_stats()
308 stats.id.clone(), in collect_stats()
[all …]
H A Dmod.rs23 use crate::stats::stats_collector::StatsCollector;
24 use crate::stats::ICETransportStats;
25 use crate::stats::StatsReportType::Transport;
326 let stats = ICETransportStats::new("ice_transport".to_string(), agent); in collect_stats() localVariable
328 collector.insert("ice_transport".to_string(), Transport(stats)); in collect_stats()
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_internal.rs6 use crate::stats::stats_collector::StatsCollector;
7 use crate::stats::{
1237 for (stats, info) in in collect_inbound_stats()
1257 stats.packets_received(), in collect_inbound_stats()
1261 stats.nacks_sent(), in collect_inbound_stats()
1263 stats.remote_bytes_sent(), in collect_inbound_stats()
1367 for (stats, info) in stream_stats in collect_outbound_stats()
1390 stats.packets_sent(), in collect_outbound_stats()
1392 stats.header_bytes_sent(), in collect_outbound_stats()
1393 stats.nacks_received(), in collect_outbound_stats()
[all …]
H A Dcertificate.rs12 use crate::stats::stats_collector::StatsCollector;
13 use crate::stats::{CertificateStats, StatsReportType};
208 let stats = CertificateStats::new(self, fingerprint); in collect_stats() localVariable
211 StatsReportType::CertificateStats(stats), in collect_stats()
H A Dpeer_connection_test.rs7 use crate::stats::StatsReportType;
H A Dmod.rs66 use crate::stats::StatsReport;
76 use interceptor::{stats, Attributes, Interceptor, RTCPWriter};
226 let stats_interceptor = stats::make_stats_interceptor(""); in new()
/webrtc/interceptor/
H A DCHANGELOG.md11 * Further extended stats interceptors to collect stats for `RemoteOutoundRTPStats` and improve `Rem…
21 * Add stats interceptor. Contributed by [@k0nserv](https://github.com/k0nserv) in [#277](https://gi…
/webrtc/ice/src/
H A Dlib.rs14 pub mod stats; module
/webrtc/webrtc/src/sctp_transport/
H A Dmod.rs17 use crate::stats::stats_collector::StatsCollector;
18 use crate::stats::StatsReportType::{PeerConnection, SCTPTransport};
19 use crate::stats::{ICETransportStats, PeerConnectionStats};
391 let stats = ICETransportStats::new("sctp_transport".to_owned(), agent); in collect_stats() localVariable
392 reports.insert(stats.id.clone(), SCTPTransport(stats)); in collect_stats()
/webrtc/webrtc/src/
H A Dlib.rs29 pub mod stats; module
/webrtc/ice/src/agent/
H A Dagent_test.rs1156 for cps in stats { in test_candidate_pair_stats()
1259 for stats in local_stats { in test_local_candidate_stats()
1261 host_local_stat = stats.clone(); in test_local_candidate_stats()
1264 srflx_local_stat = stats.clone(); in test_local_candidate_stats()
1271 stats.candidate_type, in test_local_candidate_stats()
1276 stats.priority, in test_local_candidate_stats()
1390 for stats in remote_stats { in test_remote_candidate_stats()
1392 relay_remote_stat = stats.clone(); in test_remote_candidate_stats()
1401 host_remote_stat = stats.clone(); in test_remote_candidate_stats()
1408 stats.candidate_type, in test_remote_candidate_stats()
[all …]
/webrtc/rtcp/
H A DCHANGELOG.md17 …ithout requiring the allocation of a Vec. Added in [#225 Add RTP Stats to stats report](https://gi…
/webrtc/examples/examples/ice-restart/
H A DREADME.md17 …This will automatically start a PeerConnection. This page will now prints stats about the PeerConn…
/webrtc/webrtc/src/data_channel/
H A Dmod.rs34 use crate::stats::stats_collector::StatsCollector;
35 use crate::stats::{DataChannelStats, StatsReportType};
554 let stats = DataChannelStats::from(self).await; in collect_stats() localVariable
555 collector.insert(self.stats_id.clone(), StatsReportType::DataChannel(stats)); in collect_stats()
/webrtc/sctp/src/association/
H A Dassociation_test.rs1391 log::debug!("nDATAs : {}", b.stats.get_num_datas()); in test_assoc_congestion_control_fast_retransmission()
1392 log::debug!("nSACKs : {}", a.stats.get_num_sacks()); in test_assoc_congestion_control_fast_retransmission()
1396 assert_eq!(a.stats.get_num_fast_retrans(), 1, "should be 1"); in test_assoc_congestion_control_fast_retransmission()
1448 a.stats.reset(); in test_assoc_congestion_control_congestion_avoidance()
1449 b.stats.reset(); in test_assoc_congestion_control_congestion_avoidance()
1525 log::debug!("nDATAs : {}", b.stats.get_num_datas()); in test_assoc_congestion_control_congestion_avoidance()
1526 log::debug!("nSACKs : {}", a.stats.get_num_sacks()); in test_assoc_congestion_control_congestion_avoidance()
1530 b.stats.get_num_datas(), in test_assoc_congestion_control_congestion_avoidance()
1535 a.stats.get_num_sacks() <= N_PACKETS_TO_SEND as u64 / 2, in test_assoc_congestion_control_congestion_avoidance()
1666 log::debug!("nDATAs : {}", b.stats.get_num_datas()); in test_assoc_congestion_control_slow_reader()
[all …]
H A Dassociation_internal.rs89 pub(crate) stats: Arc<AssociationStats>, field
242 self.stats.get_num_datas() in close()
247 self.stats.get_num_sacks() in close()
252 self.stats.get_num_t3timeouts() in close()
257 self.stats.get_num_ack_timeouts() in close()
262 self.stats.get_num_fast_retrans() in close()
447 self.stats.inc_fast_retrans(); in gather_outbound_fast_retransmission_packets()
902 self.stats.inc_datas(); in handle_data()
1371 self.stats.inc_sacks(); in handle_sack()
2222 self.stats.inc_ack_timeouts(); in on_ack_timeout()
[all …]
/webrtc/webrtc/
H A DCHANGELOG.md65 * Added more stats to `RemoteInboundRTPStats` and `RemoteOutboundRTPStats` [#282](https://github.co…
71 * Fixed a panic that would sometimes happen when collecting stats. [#327](https://github.com/webrtc…
155 * We now provide stats reporting via the standardized `RTCPeerConnection::get_stats` method.
157 …* [#220 Make stats types pub so they can be used directly](https://github.com/webrtc-rs/webrtc/pul…
158 …* [#225 Add RTP Stats to stats report](https://github.com/webrtc-rs/webrtc/pull/225) contributed b…
159 …* [#189 Serialize stats](https://github.com/webrtc-rs/webrtc/pull/189) contributed by [sax](https:…
160 …* [#180 Get stats from peer connection](https://github.com/webrtc-rs/webrtc/pull/180) contributed …
/webrtc/webrtc/src/api/media_engine/
H A Dmod.rs16 use crate::stats::stats_collector::StatsCollector;
17 use crate::stats::CodecStats;
18 use crate::stats::StatsReportType::Codec;
/webrtc/interceptor/src/
H A Dlib.rs20 pub mod stats; module
/webrtc/webrtc/src/dtls_transport/
H A Dmod.rs34 use crate::stats::stats_collector::StatsCollector;