| /webrtc/rtcp/ |
| H A D | README.md | 6 <a href="https://github.com/webrtc-rs/rtcp/actions">
7 <img src="https://github.com/webrtc-rs/rtcp/workflows/cargo/badge.svg">
9 <a href="https://codecov.io/gh/webrtc-rs/rtcp">
10 <img src="https://codecov.io/gh/webrtc-rs/rtcp/branch/main/graph/badge.svg">
12 <a href="https://deps.rs/repo/github/webrtc-rs/rtcp">
13 <img src="https://deps.rs/repo/github/webrtc-rs/rtcp/status.svg">
15 <a href="https://crates.io/crates/rtcp">
16 <img src="https://img.shields.io/crates/v/rtcp.svg">
18 <a href="https://docs.rs/rtcp">
19 <img src="https://docs.rs/rtcp/badge.svg">
[all …]
|
| H A D | Cargo.toml | 2 name = "rtcp"
8 documentation = "https://docs.rs/rtcp"
10 repository = "https://github.com/webrtc-rs/rtcp"
|
| H A D | CHANGELOG.md | 1 # rtcp changelog
16 * [#14 Prevent crash in RTCP NACK writing](https://github.com/webrtc-rs/rtcp/pull/14) by [@pthatche…
22 …es, but not always, available in the [GitHub Releases](https://github.com/webrtc-rs/rtcp/releases).
|
| /webrtc/interceptor/src/twcc/ |
| H A D | mod.rs | 7 use rtcp::transport_feedbacks::transport_layer_cc::{
58 pub fn build_feedback_packet(&mut self) -> Vec<Box<dyn rtcp::packet::Packet + Send + Sync>> { in build_feedback_packet()
87 let p: Box<dyn rtcp::packet::Packet + Send + Sync> = Box::new(feedback.get_rtcp()); in build_feedback_packet()
95 rtcp: TransportLayerCc, field
110 rtcp: TransportLayerCc { in new()
128 self.rtcp.packet_status_count = self.sequence_number_count; in get_rtcp()
129 self.rtcp.reference_time = self.ref_timestamp64ms as u32; in get_rtcp()
130 self.rtcp.base_sequence_number = self.base_sequence_number; in get_rtcp()
134 self.rtcp.packet_chunks.extend_from_slice(&self.chunks); in get_rtcp()
135 self.rtcp.recv_deltas = self.deltas.clone(); in get_rtcp()
[all …]
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_test.rs | 41 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_before_any_packet()
104 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_after_rtp_packets()
187 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_after_rtp_and_rtcp_packets()
261 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_overflow()
365 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_overflow_five_pkts()
437 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_packet_loss()
478 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_packet_loss()
548 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_overflow_and_packet_loss()
610 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_reordered_packets()
690 rtcp::reception_report::ReceptionReport { in test_receiver_interceptor_jitter()
[all …]
|
| H A D | receiver_stream.rs | 84 fn process_sender_report(&mut self, now: SystemTime, sr: &rtcp::sender_report::SenderReport) { in process_sender_report()
89 fn generate_report(&mut self, now: SystemTime) -> rtcp::receiver_report::ReceiverReport { in generate_report()
117 let r = rtcp::receiver_report::ReceiverReport { in generate_report()
119 reports: vec![rtcp::reception_report::ReceptionReport { in generate_report()
195 sr: &rtcp::sender_report::SenderReport, in process_sender_report()
201 pub(crate) fn generate_report(&self, now: SystemTime) -> rtcp::receiver_report::ReceiverReport { in generate_report()
|
| H A D | mod.rs | 33 let pkts = rtcp::packet::unmarshal(&mut b)?; in read()
44 .downcast_ref::<rtcp::sender_report::SenderReport>() in read()
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 10 type RTCPPackets = Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>;
102 let pkt = match rtcp::packet::unmarshal(&mut b) { in new()
153 pkt: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write_rtcp()
176 pub async fn receive_rtcp(&self, pkts: Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>) { in receive_rtcp()
192 pub async fn written_rtcp(&self) -> Option<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>> { in written_rtcp()
202 ) -> Option<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>> { in last_written_rtcp()
222 ) -> Option<Result<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>>> { in read_rtcp()
251 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
268 let marshaled = rtcp::packet::marshal(&pkts)?; in read()
315 use rtcp::payload_feedbacks::picture_loss_indication::PictureLossIndication; in test_mock_stream()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | sender_test.rs | 38 .downcast_ref::<rtcp::sender_report::SenderReport>() in test_sender_interceptor_before_any_packet()
42 &rtcp::sender_report::SenderReport { in test_sender_interceptor_before_any_packet()
102 .downcast_ref::<rtcp::sender_report::SenderReport>() in test_sender_interceptor_after_rtp_packets()
106 &rtcp::sender_report::SenderReport { in test_sender_interceptor_after_rtp_packets()
204 .downcast_ref::<rtcp::sender_report::SenderReport>() in test_sender_interceptor_after_rtp_packets_overflow()
208 &rtcp::sender_report::SenderReport { in test_sender_interceptor_after_rtp_packets_overflow()
|
| H A D | sender_stream.rs | 31 fn generate_report(&mut self, now: SystemTime) -> rtcp::sender_report::SenderReport { in generate_report()
32 rtcp::sender_report::SenderReport { in generate_report()
84 ) -> rtcp::sender_report::SenderReport { in generate_report()
|
| /webrtc/interceptor/ |
| H A D | Cargo.toml | 16 rtcp = { version = "0.8.0", path = "../rtcp" }
|
| /webrtc/srtp/ |
| H A D | Cargo.toml | 20 rtcp = { version = "0.8.0", path = "../rtcp" }
|
| /webrtc/srtp/src/context/ |
| H A D | srtcp.rs | 11 rtcp::header::Header::unmarshal(&mut buf)?; in decrypt_rtcp()
45 rtcp::header::Header::unmarshal(&mut buf)?; in encrypt_rtcp()
|
| /webrtc/srtp/src/ |
| H A D | stream.rs | 69 pub async fn read_rtcp(&self, buf: &mut [u8]) -> Result<(usize, rtcp::header::Header)> { in read_rtcp()
76 let header = rtcp::header::Header::unmarshal(&mut b)?; in read_rtcp()
|
| /webrtc/ |
| H A D | Cargo.toml | 11 "rtcp",
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 8 use rtcp::extended_report::{DLRRReportBlock, ExtendedReport};
9 use rtcp::payload_feedbacks::full_intra_request::FullIntraRequest;
10 use rtcp::payload_feedbacks::picture_loss_indication::PictureLossIndication;
11 use rtcp::receiver_report::ReceiverReport;
12 use rtcp::sender_report::SenderReport;
13 use rtcp::transport_feedbacks::transport_layer_nack::TransportLayerNack;
399 let pkts = rtcp::packet::unmarshal(&mut b)?; in read()
622 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
842 use rtcp::receiver_report::ReceiverReport;
843 use rtcp::reception_report::ReceptionReport;
[all …]
|
| /webrtc/interceptor/src/ |
| H A D | lib.rs | 134 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
141 &[Box<dyn rtcp::packet::Packet + Send + Sync>],
155 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
|
| H A D | error.rs | 28 Rtcp(#[from] rtcp::Error),
|
| /webrtc/webrtc/src/ |
| H A D | lib.rs | 11 pub use rtcp;
|
| /webrtc/srtp/src/cipher/ |
| H A D | cipher_aes_cm_hmac_sha1.rs | 269 &mut writer[rtcp::header::HEADER_LENGTH + rtcp::header::SSRC_LENGTH..], in encrypt_rtcp()
327 &mut writer[rtcp::header::HEADER_LENGTH + rtcp::header::SSRC_LENGTH..], in decrypt_rtcp()
|
| /webrtc/webrtc/ |
| H A D | Cargo.toml | 23 rtcp = { version = "0.8.0", path = "../rtcp" }
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 153 let pkts = rtcp::packet::unmarshal(&mut buf)?; in incoming()
257 pkt: &(dyn rtcp::packet::Packet + Send + Sync), in write_rtcp()
266 fn destination_ssrc(pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>]) -> Vec<u32> { in destination_ssrc()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | generator_test.rs | 6 use rtcp::transport_feedbacks::transport_layer_nack::TransportLayerNack;
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | mod.rs | 15 use rtcp::transport_feedbacks::transport_layer_nack::TransportLayerNack;
109 let pkts = rtcp::packet::unmarshal(&mut b)?; in read()
|
| H A D | responder_test.rs | 7 use rtcp::transport_feedbacks::transport_layer_nack::{NackPair, TransportLayerNack};
|