Home
last modified time | relevance | path

Searched refs:Packet (Results 1 – 25 of 93) sorted by relevance

1234

/webrtc/media/src/io/sample_builder/
H A Dsample_builder_test.rs15 packets: Vec<Packet>,
110 Packet { in test_sample_builder()
120 Packet { in test_sample_builder()
130 Packet { in test_sample_builder()
1233 s.push(Packet { in test_sample_builder_max_late()
1241 s.push(Packet { in test_sample_builder_max_late()
1249 s.push(Packet { in test_sample_builder_max_late()
1268 s.push(Packet { in test_sample_builder_max_late()
1276 s.push(Packet { in test_sample_builder_max_late()
1284 s.push(Packet { in test_sample_builder_max_late()
[all …]
/webrtc/rtp/src/packet/
H A Dpacket_test.rs100 let packet = Packet { in test_extension()
145 let pkt = Packet { in test_packet_marshal_unmarshal()
182 let p = Packet { in test_rfc_8285_one_byte_extension()
242 let p = Packet { in test_rfc_8285_one_byte_two_extension_of_two_bytes()
373 let p = Packet { in test_rfc_8285_one_byte_multiple_extension()
422 let p = Packet { in test_rfc_8285_two_byte_extension()
523 let p = Packet { in test_rfc8285_two_byte_multiple_extension_with_large_extension()
571 let p = Packet { in test_rfc8285_get_extension_returns_nil_when_extension_disabled()
599 let mut p = Packet { in test_rfc8285_del_extension()
639 let p = Packet { in test_rfc8285_get_extension_ids()
[all …]
H A Dmod.rs13 pub struct Packet { struct
18 impl fmt::Display for Packet { argument
34 impl Unmarshal for Packet { implementation
48 Ok(Packet { in unmarshal()
59 Ok(Packet { header, payload }) in unmarshal()
64 impl MarshalSize for Packet { implementation
82 impl Marshal for Packet { implementation
/webrtc/interceptor/src/mock/
H A Dmock_stream.rs10 type RTCPPackets = Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>;
20 rtp_out_modified_tx: mpsc::Sender<rtp::packet::Packet>,
22 rtp_in_rx: Mutex<mpsc::Receiver<rtp::packet::Packet>>,
25 rtp_out_modified_rx: Mutex<mpsc::Receiver<rtp::packet::Packet>>,
27 rtp_in_tx: Mutex<Option<mpsc::Sender<rtp::packet::Packet>>>,
153 pkt: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write_rtcp()
184 pub async fn receive_rtp(&self, pkt: rtp::packet::Packet) { in receive_rtp() argument
202 ) -> Option<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>> { in last_written_rtcp()
251 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
328 s.write_rtp(&rtp::packet::Packet::default()).await?; in test_mock_stream()
[all …]
/webrtc/rtcp/src/
H A Dpacket.rs20 pub trait Packet: Marshal + Unmarshal + fmt::Display + fmt::Debug { interface
25 fn equal(&self, other: &(dyn Packet + Send + Sync)) -> bool; in equal()
26 fn cloned(&self) -> Box<dyn Packet + Send + Sync>; in cloned()
29 impl PartialEq for dyn Packet + Send + Sync {
35 impl Clone for Box<dyn Packet + Send + Sync> {
36 fn clone(&self) -> Box<dyn Packet + Send + Sync> { in clone()
42 pub fn marshal(packets: &[Box<dyn Packet + Send + Sync>]) -> Result<Bytes> { in marshal()
57 pub fn unmarshal<B>(raw_data: &mut B) -> Result<Vec<Box<dyn Packet + Send + Sync>>> in unmarshal()
79 pub(crate) fn unmarshaller<B>(raw_data: &mut B) -> Result<Box<dyn Packet + Send + Sync>> in unmarshaller()
92 let p: Box<dyn Packet + Send + Sync> = match h.packet_type { in unmarshaller()
[all …]
H A Draw_packet.rs1 use crate::{error::Error, header::*, packet::Packet, util::*};
20 impl Packet for RawPacket {
42 fn equal(&self, other: &(dyn Packet + Send + Sync)) -> bool { in equal()
49 fn cloned(&self) -> Box<dyn Packet + Send + Sync> { in cloned()
/webrtc/interceptor/src/twcc/receiver/
H A Dreceiver_stream.rs7 packet_chan_tx: mpsc::Sender<Packet>,
17 packet_chan_tx: mpsc::Sender<Packet>, in new() argument
37 let p = rtp::packet::Packet::unmarshal(&mut b)?; in read()
44 .send(Packet { in read()
/webrtc/interceptor/src/nack/responder/
H A Dresponder_stream.rs10 packets: Vec<Option<rtp::packet::Packet>>,
26 fn add(&mut self, packet: &rtp::packet::Packet) { in add() argument
50 fn get(&self, seq: u16) -> Option<&rtp::packet::Packet> { in get() argument
77 async fn add(&self, pkt: &rtp::packet::Packet) { in add() argument
82 pub(super) async fn get(&self, seq: u16) -> Option<rtp::packet::Packet> { in get() argument
92 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write() argument
115 sb.add(&rtp::packet::Packet { in test_responder_stream()
/webrtc/sctp/src/queue/
H A Dcontrol_queue.rs1 use crate::packet::Packet;
6 pub(crate) type ControlQueue = VecDeque<Packet>;
/webrtc/sctp/src/
H A Dpacket.rs56 pub(crate) struct Packet { struct
64 impl fmt::Display for Packet { argument
83 impl Packet { implementation
142 Ok(Packet { in unmarshal()
191 impl Packet { impl
242 let result = Packet::unmarshal(&Bytes::new()); in test_packet_unmarshal()
251 let pkt = Packet::unmarshal(&header_only)?; in test_packet_unmarshal()
280 Packet::unmarshal(&raw_chunk)?; in test_packet_unmarshal()
290 let pkt = Packet::unmarshal(&header_only)?; in test_packet_marshal()
/webrtc/sctp/fuzz/fuzz_targets/
H A Dpacket.rs4 use webrtc_sctp::packet::Packet;
9 Packet::unmarshal(&bytes);
/webrtc/rtp/benches/
H A Dpacket_bench.rs10 let pkt = Packet { in benchmark_packet()
32 let p = Packet::unmarshal(buf).unwrap(); in benchmark_packet()
55 let _ = Packet::unmarshal(buf).unwrap(); in benchmark_packet()
/webrtc/sctp/src/association/
H A Dassociation_internal.rs336 fn gather_data_packets_to_retransmit(&mut self, mut raw_packets: Vec<Packet>) -> Vec<Packet> { in gather_data_packets_to_retransmit() argument
347 ) -> Vec<Packet> { in gather_outbound_data_and_reconfig_packets() argument
415 ) -> Vec<Packet> { in gather_outbound_fast_retransmission_packets() argument
512 ) -> (Vec<Packet>, bool) { in gather_outbound_shutdown_packets() argument
606 async fn handle_init(&mut self, p: &Packet, i: &ChunkInit) -> Result<Vec<Packet>> { in handle_init() argument
712 async fn handle_init_ack(&mut self, p: &Packet, i: &ChunkInit) -> Result<Vec<Packet>> { in handle_init_ack() argument
862 Ok(vec![Packet { in handle_cookie_echo()
952 ) -> Result<Vec<Packet>> { in handle_peer_last_tsn_and_acknowledgement() argument
1611 Packet { in create_packet()
2070 fn pack(p: Packet) -> Vec<Packet> { in pack() argument
[all …]
/webrtc/interceptor/src/
H A Dlib.rs82 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize>; in write() argument
87 &rtp::packet::Packet,
98 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize> { in write() argument
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()
/webrtc/interceptor/src/report/receiver/
H A Dreceiver_test.rs233 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_overflow()
243 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_overflow()
307 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_overflow_five_pkts()
317 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_overflow_five_pkts()
327 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_overflow_five_pkts()
337 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_overflow_five_pkts()
347 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_overflow_five_pkts()
409 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_packet_loss()
419 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_packet_loss()
520 .receive_rtp(rtp::packet::Packet { in test_receiver_interceptor_overflow_and_packet_loss()
[all …]
/webrtc/interceptor/src/twcc/sender/
H A Dsender_test.rs4 use rtp::packet::Packet;
16 let (p_chan_tx, mut p_chan_rx) = mpsc::channel::<Packet>(10 * 5); in test_twcc_sender_interceptor()
42 .write_rtp(&rtp::packet::Packet { in test_twcc_sender_interceptor()
/webrtc/rtcp/src/extended_report/
H A Dunknown.rs26 impl Packet for UnknownReportBlock {
43 fn equal(&self, other: &(dyn Packet + Send + Sync)) -> bool { in equal()
49 fn cloned(&self) -> Box<dyn Packet + Send + Sync> { in cloned()
H A Drrt.rs38 impl Packet for ReceiverReferenceTimeReportBlock {
55 fn equal(&self, other: &(dyn Packet + Send + Sync)) -> bool { in equal()
61 fn cloned(&self) -> Box<dyn Packet + Send + Sync> { in cloned()
H A Dmod.rs22 use crate::packet::Packet;
159 pub reports: Vec<Box<dyn Packet + Send + Sync>>,
168 impl Packet for ExtendedReport {
200 fn equal(&self, other: &(dyn Packet + Send + Sync)) -> bool { in equal()
207 fn cloned(&self) -> Box<dyn Packet + Send + Sync> { in cloned()
273 let report: Box<dyn Packet + Send + Sync> = match block_type { in unmarshal()
/webrtc/sctp/src/chunk/
H A Dchunk_test.rs482 let pkt = Packet::unmarshal(&raw_pkt)?; in test_init_chunk()
516 let pkt = Packet::unmarshal(&raw_pkt)?; in test_init_ack()
536 let pkt = Packet::unmarshal(&raw_pkt)?; in test_chrome_chunk1_init()
575 let pkt = Packet::unmarshal(&raw_pkt)?; in test_chrome_chunk2_init_ack()
584 let mut p = Packet { in test_init_marshal_unmarshal()
607 let pkt = Packet::unmarshal(&raw_pkt)?; in test_init_marshal_unmarshal()
644 let pkt = Packet::unmarshal(&raw_pkt)?; in test_payload_data_marshal_unmarshal()
662 let pkt = Packet::unmarshal(&raw_pkt)?; in test_select_ack_chunk()
680 let pkt = Packet::unmarshal(&raw_pkt)?; in test_reconfig_chunk()
709 let pkt = Packet::unmarshal(&raw_pkt)?; in test_forward_tsn_chunk()
[all …]
/webrtc/rtcp/src/compound_packet/
H A Dmod.rs29 pub struct CompoundPacket(pub Vec<Box<dyn Packet + Send + Sync>>);
37 impl Packet for CompoundPacket {
64 fn equal(&self, other: &(dyn Packet + Send + Sync)) -> bool { in equal()
71 fn cloned(&self) -> Box<dyn Packet + Send + Sync> { in cloned()
/webrtc/media/src/io/ivf_writer/
H A Divf_writer_test.rs13 let mut valid_packet = rtp::packet::Packet { in test_ivf_writer_add_packet_and_close()
40 let mut mid_part_packet = rtp::packet::Packet { in test_ivf_writer_add_packet_and_close()
67 let mut keyframe_packet = rtp::packet::Packet { in test_ivf_writer_add_packet_and_close()
118 rtp::packet::Packet::default(), in test_ivf_writer_add_packet_and_close()
/webrtc/interceptor/src/report/sender/
H A Dsender_test.rs85 .write_rtp(&rtp::packet::Packet { in test_sender_interceptor_after_rtp_packets()
148 .write_rtp(&rtp::packet::Packet { in test_sender_interceptor_after_rtp_packets_overflow()
158 .write_rtp(&rtp::packet::Packet { in test_sender_interceptor_after_rtp_packets_overflow()
168 .write_rtp(&rtp::packet::Packet { in test_sender_interceptor_after_rtp_packets_overflow()
178 .write_rtp(&rtp::packet::Packet { in test_sender_interceptor_after_rtp_packets_overflow()
188 .write_rtp(&rtp::packet::Packet { in test_sender_interceptor_after_rtp_packets_overflow()
/webrtc/media/src/io/ogg_writer/
H A Dogg_writer_test.rs12 let mut valid_packet = rtp::packet::Packet { in test_ogg_writer_add_packet_and_close()
39 rtp::packet::Packet::default(), in test_ogg_writer_add_packet_and_close()
/webrtc/dtls/src/flight/
H A Dmod.rs54 pub(crate) struct Packet { struct
85 ) -> Result<Vec<Packet>, (Option<Alert>, Option<Error>)>; in generate() argument

1234