Home
last modified time | relevance | path

Searched refs:pkt (Results 1 – 25 of 35) sorted by relevance

12

/webrtc/rtp/benches/
H A Dpacket_bench.rs10 let pkt = Packet { in benchmark_packet() localVariable
30 let raw = pkt.marshal().unwrap(); in benchmark_packet()
33 if pkt != p { in benchmark_packet()
38 let mut buf = BytesMut::with_capacity(pkt.marshal_size()); in benchmark_packet()
39 buf.resize(pkt.marshal_size(), 0); in benchmark_packet()
42 let _ = pkt.marshal_to(&mut buf).unwrap(); in benchmark_packet()
48 let _ = pkt.marshal().unwrap(); in benchmark_packet()
/webrtc/interceptor/src/report/receiver/
H A Dreceiver_stream.rs43 fn process_rtp(&mut self, now: SystemTime, pkt: &rtp::packet::Packet) { in process_rtp()
47 self.set_received(pkt.header.sequence_number); in process_rtp()
48 self.last_seq_num = pkt.header.sequence_number as i32; in process_rtp()
49 self.last_report_seq_num = pkt.header.sequence_number as i32 - 1; in process_rtp()
52 self.set_received(pkt.header.sequence_number); in process_rtp()
54 let diff = pkt.header.sequence_number as i32 - self.last_seq_num; in process_rtp()
66 self.last_seq_num = pkt.header.sequence_number as i32; in process_rtp()
80 self.last_rtp_time_rtp = pkt.header.timestamp; in process_rtp()
189 internal.process_rtp(now, pkt); in process_rtp()
215 let pkt = rtp::packet::Packet::unmarshal(&mut b)?; in read() localVariable
[all …]
/webrtc/interceptor/src/twcc/sender/
H A Dsender_stream.rs27 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write()
35 let mut pkt = pkt.clone(); in write() localVariable
36 pkt.header.set_extension(self.hdr_ext_id, tcc_payload)?; in write()
38 self.next_rtp_writer.write(&pkt, a).await in write()
/webrtc/interceptor/src/report/sender/
H A Dsender_stream.rs22 fn process_rtp(&mut self, now: SystemTime, pkt: &rtp::packet::Packet) { in process_rtp()
24 self.last_rtp_time_rtp = pkt.header.timestamp; in process_rtp()
28 self.counters.count_octets(pkt.payload.len()); in process_rtp()
76 async fn process_rtp(&self, now: SystemTime, pkt: &rtp::packet::Packet) { in process_rtp()
78 internal.process_rtp(now, pkt); in process_rtp()
94 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write()
100 self.process_rtp(now, pkt).await; in write()
102 self.next_rtp_writer.write(pkt, a).await in write()
H A Dmod.rs72 let pkt = stream.generate_report(now).await; in run() localVariable
75 if let Err(err) = rtcp_writer.write(&[Box::new(pkt)], &a).await{ in run()
/webrtc/sctp/src/chunk/
H A Dchunk_test.rs482 let pkt = Packet::unmarshal(&raw_pkt)?; in test_init_chunk() localVariable
516 let pkt = Packet::unmarshal(&raw_pkt)?; in test_init_ack() localVariable
536 let pkt = Packet::unmarshal(&raw_pkt)?; in test_chrome_chunk1_init() localVariable
537 let raw_pkt2 = pkt.marshal()?; in test_chrome_chunk1_init()
575 let pkt = Packet::unmarshal(&raw_pkt)?; in test_chrome_chunk2_init_ack() localVariable
576 let raw_pkt2 = pkt.marshal()?; in test_chrome_chunk2_init_ack()
607 let pkt = Packet::unmarshal(&raw_pkt)?; in test_init_marshal_unmarshal() localVariable
646 pkt.chunks[1] in test_payload_data_marshal_unmarshal()
664 pkt.chunks[0] in test_select_ack_chunk()
738 pkt.chunks[0] in test_select_ack_chunk_followed_by_a_payload_data_chunk()
[all …]
/webrtc/interceptor/src/twcc/
H A Dtwcc_test.rs234 let pkt = f.get_rtcp(); in test_feedback() localVariable
236 assert!(pkt.header().padding); in test_feedback()
240 assert_eq!(pkt.reference_time, 5); in test_feedback()
241 assert_eq!(pkt.fb_pkt_count, 0); in test_feedback()
258 pkt.packet_chunks in test_feedback()
299 let pkt = f.get_rtcp(); in test_feedback() localVariable
301 assert!(pkt.header().padding); in test_feedback()
306 assert_eq!(pkt.fb_pkt_count, 0); in test_feedback()
337 pkt.packet_chunks in test_feedback()
397 for pkt in pkts { in marshal_all()
[all …]
H A Dmod.rs75 for pkt in &self.received_packets { in build_feedback_packet()
77 feedback.add_received((pkt.sequence_number & 0xffff) as u16, pkt.arrival_time); in build_feedback_packet()
83 feedback.add_received((pkt.sequence_number & 0xffff) as u16, pkt.arrival_time); in build_feedback_packet()
/webrtc/interceptor/src/mock/
H A Dmock_stream.rs103 Ok(pkt) => pkt, in new()
110 let _ = rtcp_in_modified_tx.send(Ok(pkt)).await; in new()
136 Ok(pkt) => pkt, in new()
143 let _ = rtp_in_modified_tx.send(Ok(pkt)).await; in new()
153 pkt: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write_rtcp()
158 writer.write(pkt, &a).await in write_rtcp()
169 writer.write(pkt, &a).await in write_rtp()
184 pub async fn receive_rtp(&self, pkt: rtp::packet::Packet) { in receive_rtp()
187 let _ = tx.send(pkt).await; in receive_rtp()
290 let pkt = { in read() localVariable
[all …]
/webrtc/rtp/src/codecs/h264/
H A Dh264_test.rs115 let mut pkt = H264Packet::default(); in test_h264_packet_unmarshal() localVariable
122 let result = pkt.depacketize(&data); in test_h264_packet_unmarshal()
126 let result = pkt.depacketize(&data); in test_h264_packet_unmarshal()
133 let result = pkt.depacketize(&data); in test_h264_packet_unmarshal()
139 let result = pkt.depacketize(&incomplete_single_payload_multi_nalu); in test_h264_packet_unmarshal()
145 let payload = pkt.depacketize(&single_payload)?; in test_h264_packet_unmarshal()
159 let payload = pkt.depacketize(p)?; in test_h264_packet_unmarshal()
179 let payload = pkt.depacketize(&single_payload_multi_nalu)?; in test_h264_packet_unmarshal()
/webrtc/rtcp/src/compound_packet/
H A Dmod.rs136 for pkt in &self.0[1..] { in validate()
139 if pkt.as_any().downcast_ref::<ReceiverReport>().is_some() { in validate()
143 } else if let Some(e) = pkt.as_any().downcast_ref::<SourceDescription>() { in validate()
175 for pkt in &self.0[1..] { in cname()
176 if let Some(sdes) = pkt.as_any().downcast_ref::<SourceDescription>() { in cname()
184 } else if pkt.as_any().downcast_ref::<ReceiverReport>().is_none() { in cname()
/webrtc/sctp/src/
H A Dpacket.rs251 let pkt = Packet::unmarshal(&header_only)?; in test_packet_unmarshal() localVariable
254 pkt.source_port, 5000, in test_packet_unmarshal()
256 5000, pkt.source_port in test_packet_unmarshal()
259 pkt.destination_port, 5000, in test_packet_unmarshal()
261 5000, pkt.destination_port in test_packet_unmarshal()
264 pkt.verification_tag, 0, in test_packet_unmarshal()
266 0, pkt.verification_tag in test_packet_unmarshal()
290 let pkt = Packet::unmarshal(&header_only)?; in test_packet_marshal() localVariable
291 let header_only_marshaled = pkt.marshal()?; in test_packet_marshal()
/webrtc/webrtc/src/track/track_local/
H A Dtrack_local_static_rtp.rs69 let mut pkt = p.clone(); in write_rtp_with_extensions() localVariable
99 pkt.header.ssrc = b.ssrc; in write_rtp_with_extensions()
100 pkt.header.payload_type = b.payload_type; in write_rtp_with_extensions()
110 if let Err(err) = pkt.header.set_extension(id as u8, data.clone()) { in write_rtp_with_extensions()
118 match write_stream.write_rtp(&pkt).await { in write_rtp_with_extensions()
234 let pkt = rtp::packet::Packet::unmarshal(&mut b)?; in write() localVariable
235 self.write_rtp(&pkt).await?; in write()
H A Dmod.rs144 async fn write_rtp(&self, pkt: &rtp::packet::Packet) -> Result<usize> { in write_rtp()
152 Ok(writer.write(pkt, &a).await?) in write_rtp()
159 let pkt = rtp::packet::Packet::unmarshal(&mut b)?; in write() localVariable
160 self.write_rtp(&pkt).await in write()
H A Dtrack_local_static_test.rs324 let pkt = rtp::packet::Packet { in test_track_local_static_mutate_input() localVariable
333 v.write_rtp(&pkt).await?; in test_track_local_static_mutate_input()
338 assert_eq!(pkt.header.ssrc, 1); in test_track_local_static_mutate_input()
339 assert_eq!(pkt.header.payload_type, 1); in test_track_local_static_mutate_input()
/webrtc/interceptor/src/nack/responder/
H A Dresponder_stream.rs77 async fn add(&self, pkt: &rtp::packet::Packet) { in add()
79 internal.add(pkt); in add()
92 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write()
93 self.add(pkt).await; in write()
95 self.next_rtp_writer.write(pkt, a).await in write()
/webrtc/webrtc/src/rtp_transceiver/
H A Dsrtp_writer_future.rs206 pub async fn write_rtp(&self, pkt: &rtp::packet::Packet) -> Result<usize> { in write_rtp()
213 return Ok(rtp_write_session.write_rtp(pkt).await?); in write_rtp()
225 return Ok(rtp_write_session.write_rtp(pkt).await?); in write_rtp()
270 async fn write(&self, pkt: &rtp::packet::Packet, _a: &Attributes) -> IResult<usize> { in write()
272 match self.seq_trans.seq_number(pkt.header.sequence_number) { in write()
274 let mut new_pkt = pkt.clone(); in write()
278 None => self.write_rtp(pkt).await?, in write()
/webrtc/rtcp/src/
H A Draw_packet.rs129 for (name, pkt, unmarshal_error) in tests { in test_raw_packet_roundtrip()
130 let result = pkt.marshal(); in test_raw_packet_roundtrip()
158 decoded, pkt, in test_raw_packet_roundtrip()
/webrtc/media/src/io/
H A Dmod.rs17 fn write_rtp(&mut self, pkt: &rtp::packet::Packet) -> Result<()>; in write_rtp()
/webrtc/webrtc/src/rtp_transceiver/rtp_sender/
H A Drtp_sender_test.rs66 let pkt = match track.read_rtp().await { in test_rtp_sender_replace_track() localVariable
67 Ok((pkt, _)) => pkt, in test_rtp_sender_replace_track()
75 let last = pkt.payload[pkt.payload.len() - 1]; in test_rtp_sender_replace_track()
/webrtc/dtls/src/conn/
H A Dmod.rs298 let (pkt, result_tx) = r; in new()
302 pkt, in new()
757 for pkt in pkts { in read_and_buffer()
882 mut pkt: Vec<u8>, in handle_incoming_packet()
885 let mut reader = BufReader::new(pkt.as_slice()); in handle_incoming_packet()
917 ctx.encrypted_packets.push(pkt); in handle_incoming_packet()
960 ctx.encrypted_packets.push(pkt); in handle_incoming_packet()
967 pkt = match cipher_suite.decrypt(&pkt) { in handle_incoming_packet()
968 Ok(pkt) => pkt, in handle_incoming_packet()
1026 let mut reader = BufReader::new(pkt.as_slice()); in handle_incoming_packet()
[all …]
/webrtc/interceptor/src/
H A Dlib.rs82 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize>; in write()
98 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize> { in write()
99 self.0(pkt, attributes).await in write()
/webrtc/srtp/src/session/
H A Dmod.rs250 pub async fn write_rtp(&self, pkt: &rtp::packet::Packet) -> Result<usize> { in write_rtp()
251 let raw = pkt.marshal()?; in write_rtp()
257 pkt: &(dyn rtcp::packet::Packet + Send + Sync), in write_rtcp()
259 let raw = pkt.marshal()?; in write_rtcp()
/webrtc/srtp/src/context/
H A Dsrtp_test.rs98 let pkt = rtp::packet::Packet { in test_rtp_invalid_auth() localVariable
106 let pkt_raw = pkt.marshal()?; in test_rtp_invalid_auth()
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_test.rs310 while let Ok((pkt, _)) = track.read_rtp().await { in test_get_stats()
311 dbg!(&pkt); in test_get_stats()
312 let last = pkt.payload[pkt.payload.len() - 1]; in test_get_stats()

12