| /webrtc/rtp/src/packetizer/ |
| H A D | packetizer_test.rs | 16 let packets = packetizer.packetize(&multiple_payload, 2000)?; in test_packetizer() localVariable
18 if packets.len() != 2 { in test_packetizer()
21 for i in 0..packets.len() { in test_packetizer()
23 format!("Packet {} length {}\n", i, packets[i].payload.len()).as_str(); in test_packetizer()
27 packets.len(), in test_packetizer()
62 let packets = pktizer.packetize(&payload, 2000)?; in test_packetizer_abs_send_time() localVariable
84 if packets.len() != 1 { in test_packetizer_abs_send_time()
85 panic!("Generated {} packets instead of 1", packets.len()) in test_packetizer_abs_send_time()
88 assert_eq!(packets[0], expected); in test_packetizer_abs_send_time()
|
| H A D | mod.rs | 113 let mut packets = Vec::with_capacity(payloads_len); in packetize() localVariable
115 packets.push(Packet { in packetize()
144 packets[payloads_len - 1] in packetize()
149 Ok(packets) in packetize()
|
| /webrtc/media/ |
| H A D | CHANGELOG.md | 7 …packets in `SampleBuiler`. Prior to this `SampleBuilder` would sometimes, incorrectly, drop packet…
13 …r of observed padding only packets while building the Sample. This can be use to differentiate inc…
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | sender_stream.rs | 108 packets: u32, field
115 self.packets = self.packets.wrapping_add(1); in increment_packets()
130 self.packets in packet_count()
138 pub fn mock(packets: u32, octets: u32) -> Self { in mock()
139 Self { packets, octets } in mock()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_stream.rs | 14 packets: Vec<u64>, field
29 let pos = (seq as usize) % self.packets.len(); in set_received()
30 self.packets[pos / 64] |= 1 << (pos % 64); in set_received()
34 let pos = (seq as usize) % self.packets.len(); in del_received()
35 self.packets[pos / 64] &= u64::MAX ^ (1u64 << (pos % 64)); in del_received()
39 let pos = (seq as usize) % self.packets.len(); in get_received()
40 (self.packets[pos / 64] & (1 << (pos % 64))) != 0 in get_received()
172 packets: vec![0u64; 128], in new()
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_stream.rs | 10 packets: Vec<Option<rtp::packet::Packet>>, field
19 packets: vec![None; 1 << log2_size], in new()
29 self.packets[(seq % self.size) as usize] = Some(packet.clone()); in add()
41 self.packets[(i % self.size) as usize] = None; in add()
46 self.packets[(seq % self.size) as usize] = Some(packet.clone()); in add()
60 self.packets[(seq % self.size) as usize].as_ref() in get()
|
| /webrtc/interceptor/src/stats/ |
| H A D | mod.rs | 135 self.rtp_stats.packets in packets_received()
371 self.rtp_stats.packets in packets_sent()
491 packets: u64, field
505 fn update(&mut self, header_bytes: u64, payload_bytes: u64, packets: u64, now: SystemTime) { in update()
508 self.packets += packets; in update()
520 pub fn packets(&self) -> u64 { in packets() method
521 self.packets in packets()
578 (stats.header_bytes(), stats.payload_bytes(), stats.packets()), in test_rtp_stats()
585 (stats.header_bytes(), stats.payload_bytes(), stats.packets()), in test_rtp_stats()
|
| H A D | interceptor.rs | 45 packets: u64,
52 packets: u64,
219 packets, in handle_stats_update()
228 .update(header_bytes, payload_bytes, packets, last_packet_timestamp); in handle_stats_update()
232 packets, in handle_stats_update()
240 .update(header_bytes, payload_bytes, packets, last_packet_timestamp); in handle_stats_update()
736 packets: 1, in read()
776 packets: 1, in write()
|
| /webrtc/rtcp/src/ |
| H A D | packet.rs | 42 pub fn marshal(packets: &[Box<dyn Packet + Send + Sync>]) -> Result<Bytes> { in marshal()
44 for p in packets { in marshal()
61 let mut packets = vec![]; in unmarshal() localVariable
65 packets.push(p); in unmarshal()
68 match packets.len() { in unmarshal()
73 _ => Ok(packets), in unmarshal()
|
| /webrtc/media/src/io/sample_builder/ |
| H A D | sample_builder_test.rs | 15 packets: Vec<Packet>, field
109 packets: vec![ in test_sample_builder()
164 packets: vec![ in test_sample_builder()
251 packets: vec![ in test_sample_builder()
331 packets: vec![ in test_sample_builder()
429 packets: vec![ in test_sample_builder()
494 packets: vec![ in test_sample_builder()
536 packets: vec![ in test_sample_builder()
580 packets: vec![ in test_sample_builder()
624 packets: vec![ in test_sample_builder()
[all …]
|
| /webrtc/interceptor/ |
| H A D | CHANGELOG.md | 12 * When generating periodic TWCC feedback packets we no longer burst several packets in a row to cat…
13 * Don't generate empty TWCC packets that libWebRTC will ignore. [#324](https://github.com/webrtc-rs…
|
| /webrtc/rtcp/src/compound_packet/ |
| H A D | mod.rs | 104 let mut packets = vec![]; in unmarshal() localVariable
108 packets.push(p); in unmarshal()
111 let c = CompoundPacket(packets); in unmarshal()
|
| /webrtc/srtp/src/session/ |
| H A D | session_rtcp_test.rs | 175 let mut packets = vec![]; in test_session_srtcp_replay_protection() localVariable
189 packets.push(encrypted); in test_session_srtcp_replay_protection()
217 for packet in &packets { in test_session_srtcp_replay_protection()
223 for packet in &packets { in test_session_srtcp_replay_protection()
|
| H A D | session_rtp_test.rs | 235 let mut packets = vec![]; in test_session_srtp_replay_protection() localVariable
254 packets.push(encrypted); in test_session_srtp_replay_protection()
286 for packet in &packets { in test_session_srtp_replay_protection()
292 for packet in &packets { in test_session_srtp_replay_protection()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | generator_stream.rs | 9 packets: Vec<u64>, field
19 packets: vec![0u64; 1 << log2_size_minus_6], in new()
103 self.packets[pos / 64] |= 1u64 << (pos % 64); in set_received()
108 self.packets[pos / 64] &= u64::MAX ^ (1u64 << (pos % 64)); in del_received()
113 (self.packets[pos / 64] & (1u64 << (pos % 64))) != 0 in get_received()
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | track_local_static_sample.rs | 116 let packets = if let Some(packetizer) = &mut internal.packetizer { in write_sample_with_extensions() localVariable
127 for p in packets { in write_sample_with_extensions()
|
| /webrtc/examples/examples/reflect/ |
| H A D | README.md | 3 …how with one PeerConnection you can send video to webrtc-rs and have the packets sent back. This e…
|
| /webrtc/examples/examples/rtp-to-webrtc/ |
| H A D | README.md | 34 You can use any software to send VP8 packets to port 5004. We also have the pre made examples below
|
| /webrtc/sctp/ |
| H A D | CHANGELOG.md | 8 * Limit the bytes in the PendingQueue to avoid packets accumulating there uncontrollably [#367](htt…
|
| /webrtc/examples/examples/data-channels-flow-control/ |
| H A D | README.md | 47 1024-byte packets to responder, until you kill the process by Ctrl+С.
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 1918 let mut packets = vec![]; in bundle_data_chunks_into_packets() localVariable
1929 packets.push(self.create_packet(chunks_to_send)); in bundle_data_chunks_into_packets()
1939 packets.push(self.create_packet(chunks_to_send)); in bundle_data_chunks_into_packets()
1942 packets in bundle_data_chunks_into_packets()
2103 let packets = if let Some(c) = chunk_any.downcast_ref::<ChunkInit>() { in handle_chunk() localVariable
2198 if !packets.is_empty() { in handle_chunk()
2199 let mut buf: VecDeque<_> = packets.into_iter().collect(); in handle_chunk()
|
| H A D | mod.rs | 504 let (packets, continue_loop) = { in write_loop()
522 for raw in packets { in write_loop()
|
| /webrtc/examples/examples/ |
| H A D | README.md | 17 …](rtp-to-webrtc): The rtp-to-webrtc example demonstrates how to take RTP packets sent to a webrtc-…
|
| /webrtc/dtls/src/conn/ |
| H A D | conn_test.rs | 2264 let mut packets = vec![]; in test_multiple_hello_verify_request() localVariable
2287 packets.push(packet); in test_multiple_hello_verify_request()
2324 if packets.len() <= i { in test_multiple_hello_verify_request()
2328 cb.send(&packets[i]).await?; in test_multiple_hello_verify_request()
|