Home
last modified time | relevance | path

Searched refs:chunks (Results 1 – 19 of 19) sorted by relevance

/webrtc/util/src/vnet/
H A Dchunk_queue.rs11 chunks: RwLock<VecDeque<Box<dyn Chunk + Send + Sync>>>, field
18 chunks: RwLock::new(VecDeque::new()), in new()
24 let mut chunks = self.chunks.write().await; in push() localVariable
26 if self.max_size > 0 && chunks.len() >= self.max_size { in push()
29 chunks.push_back(c); in push()
35 let mut chunks = self.chunks.write().await; in pop() localVariable
36 chunks.pop_front() in pop()
40 let chunks = self.chunks.read().await; in peek() localVariable
41 chunks.front().map(|chunk| chunk.clone_to()) in peek()
/webrtc/sctp/src/queue/
H A Dreassembly_queue.rs34 pub(crate) chunks: Vec<ChunkPayloadData>, field
42 chunks: vec![], in new()
48 for c in &self.chunks { in push()
55 self.chunks.push(chunk); in push()
56 sort_chunks_by_tsn(&mut self.chunks); in push()
70 let n_chunks = self.chunks.len(); in is_complete()
76 if !self.chunks[0].beginning_fragment { in is_complete()
87 for (i, c) in self.chunks.iter().enumerate() { in is_complete()
228 let chunks: Vec<ChunkPayloadData> = self in find_complete_unordered_chunk_set() localVariable
234 chunk_set.chunks = chunks; in find_complete_unordered_chunk_set()
[all …]
H A Dpending_queue.rs95 if chunks.is_empty() { in append()
102 self.append_large(chunks).await in append()
111 self.append_unlimited(chunks, total_user_data_len); in append()
116 async fn append_large(&self, chunks: Vec<ChunkPayloadData>) { in append_large()
120 for chunk in chunks.into_iter() { in append_large()
140 let chunks_len = chunks.len(); in append_unlimited()
141 let unordered = chunks in append_unlimited()
148 chunks.iter().all(|c| c.unordered), in append_unlimited()
151 unordered_queue.extend(chunks); in append_unlimited()
155 chunks.iter().all(|c| !c.unordered), in append_unlimited()
[all …]
H A Dqueue_test.rs947 assert_eq!(cset.chunks.len(), 1, "chunk with dup TSN should be ignored"); in test_chunk_set_push_dup_chunks_to_chunk_set()
956 chunks: vec![], in test_chunk_set_incomplete_chunk_set_no_beginning()
970 chunks: vec![ in test_chunk_set_incomplete_chunk_set_no_contiguous_tsn()
/webrtc/rtcp/src/source_description/
H A Dsource_description_test.rs85 chunks: vec![SourceDescriptionChunk { in test_source_description_unmarshal()
122 chunks: vec![SourceDescriptionChunk { in test_source_description_unmarshal()
143 chunks: vec![SourceDescriptionChunk { in test_source_description_unmarshal()
175 chunks: vec![ in test_source_description_unmarshal()
237 chunks: vec![ in test_source_description_roundtrip()
265 chunks: vec![SourceDescriptionChunk { in test_source_description_roundtrip()
278 chunks: vec![SourceDescriptionChunk { in test_source_description_roundtrip()
288 chunks: vec![SourceDescriptionChunk { in test_source_description_roundtrip()
301 chunks: vec![SourceDescriptionChunk { in test_source_description_roundtrip()
314 chunks: vec![SourceDescriptionChunk { in test_source_description_roundtrip()
[all …]
H A Dmod.rs274 pub chunks: Vec<SourceDescriptionChunk>, field
280 for c in &self.chunks { in fmt()
295 count: self.chunks.len() as u8, in header()
303 self.chunks.iter().map(|x| x.source).collect() in destination_ssrc()
308 for c in &self.chunks { in raw_size()
342 if self.chunks.len() > COUNT_MAX { in marshal_to()
372 for c in &self.chunks { in marshal_to()
417 let mut chunks = vec![]; in unmarshal() localVariable
421 chunks.push(chunk); in unmarshal()
424 if chunks.len() != h.count as usize { in unmarshal()
[all …]
/webrtc/rtcp/src/extended_report/
H A Drle.rs115 pub chunks: Vec<Chunk>, field
159 XR_HEADER_LENGTH + RLE_REPORT_BLOCK_MIN_LENGTH as usize + self.chunks.len() * 2 in raw_size()
196 for chunk in &self.chunks { in marshal_to()
232 let mut chunks = vec![]; in unmarshal() localVariable
234 chunks.push(Chunk(raw_packet.get_u16())); in unmarshal()
243 chunks, in unmarshal()
H A Dextended_report_test.rs14 chunks: vec![Chunk(0x4006), Chunk(0x0006), Chunk(0x8765), Chunk(0x0000)], in decoded_packet()
23 chunks: vec![Chunk(0x4123), Chunk(0x3FFF), Chunk(0xFFFF), Chunk(0x0000)], in decoded_packet()
/webrtc/sctp/src/
H A Dpacket.rs60 pub(crate) chunks: Vec<Box<dyn Chunk + Send + Sync>>, field
74 for chunk in &self.chunks { in fmt()
106 let mut chunks = vec![]; in unmarshal() localVariable
139 chunks.push(c); in unmarshal()
146 chunks, in unmarshal()
162 for c in &self.chunks { in marshal_to()
213 for c in &self.chunks { in check_packet()
219 if self.chunks.len() != 1 { in check_packet()
/webrtc/sctp/src/chunk/
H A Dchunk_test.rs484 if let Some(c) = pkt.chunks[0].as_any().downcast_ref::<ChunkInit>() { in test_init_chunk()
518 pkt.chunks[0].as_any().downcast_ref::<ChunkInit>().is_some(), in test_init_ack()
588 chunks: vec![], in test_init_marshal_unmarshal()
604 p.chunks.push(Box::new(init_ack)); in test_init_marshal_unmarshal()
609 if let Some(c) = pkt.chunks[0].as_any().downcast_ref::<ChunkInit>() { in test_init_marshal_unmarshal()
646 pkt.chunks[1] in test_payload_data_marshal_unmarshal()
664 pkt.chunks[0] in test_select_ack_chunk()
681 if let Some(c) = pkt.chunks[0].as_any().downcast_ref::<ChunkReconfig>() { in test_reconfig_chunk()
711 if let Some(c) = pkt.chunks[0].as_any().downcast_ref::<ChunkForwardTsn>() { in test_forward_tsn_chunk()
738 pkt.chunks[0] in test_select_ack_chunk_followed_by_a_payload_data_chunk()
[all …]
/webrtc/media/src/audio/
H A Dbuffer.rs189 let chunks = { in from_bytes() localVariable
195 let samples: Vec<_> = chunks.iter().map(|chunk| B::read_i16(&chunk[..])).collect(); in from_bytes()
212 let chunks = { in from_bytes() localVariable
227 init_vec(chunks.len(), |samples| { in from_bytes()
228 layout::interleaved_by(chunks, samples, channels, |chunk| { in from_bytes()
249 let chunks = { in from_bytes() localVariable
255 let samples: Vec<_> = chunks.iter().map(|chunk| B::read_i16(&chunk[..])).collect(); in from_bytes()
272 let chunks = { in from_bytes() localVariable
287 init_vec(chunks.len(), |samples| { in from_bytes()
288 layout::deinterleaved_by(chunks, samples, channels, |chunk| { in from_bytes()
/webrtc/interceptor/src/twcc/
H A Dmod.rs103 chunks: Vec<PacketStatusChunk>, field
132 self.chunks.push(self.last_chunk.encode()); in get_rtcp()
134 self.rtcp.packet_chunks.extend_from_slice(&self.chunks); in get_rtcp()
153 self.chunks.push(self.last_chunk.encode()); in add_received()
169 self.chunks.push(self.last_chunk.encode()); in add_received()
/webrtc/sctp/src/association/
H A Dassociation_internal.rs328 for c in &p.chunks { in handle_inbound()
351 if !chunks.is_empty() { in gather_outbound_data_and_reconfig_packets()
1615 chunks, in create_packet()
1844 let mut chunks = vec![]; in pop_pending_data_chunks_to_send() localVariable
1848 return (chunks, sis_to_reset); in pop_pending_data_chunks_to_send()
1892 chunks.push(chunk); in pop_pending_data_chunks_to_send()
1906 chunks.push(chunk); in pop_pending_data_chunks_to_send()
1911 (chunks, sis_to_reset) in pop_pending_data_chunks_to_send()
1922 for c in chunks { in bundle_data_chunks_into_packets()
1999 let mut chunks = vec![]; in get_data_packets_to_retransmit() localVariable
[all …]
H A Dassociation_test.rs2472 chunks: vec![Box::new(ChunkInit { in test_association_handle_packet_before_init()
2488 chunks: vec![Box::<ChunkAbort>::default()], in test_association_handle_packet_before_init()
2497 chunks: vec![Box::<ChunkCookieEcho>::default()], in test_association_handle_packet_before_init()
2506 chunks: vec![Box::<ChunkHeartbeat>::default()], in test_association_handle_packet_before_init()
2515 chunks: vec![Box::<ChunkPayloadData>::default()], in test_association_handle_packet_before_init()
2524 chunks: vec![Box::new(ChunkSelectiveAck { in test_association_handle_packet_before_init()
2541 chunks: vec![Box::new(ChunkReconfig { in test_association_handle_packet_before_init()
2553 chunks: vec![Box::new(ChunkForwardTsn { in test_association_handle_packet_before_init()
2565 chunks: vec![Box::<ChunkError>::default()], in test_association_handle_packet_before_init()
2574 chunks: vec![Box::<ChunkShutdown>::default()], in test_association_handle_packet_before_init()
[all …]
/webrtc/rtcp/src/compound_packet/
H A Dcompound_packet_test.rs92 chunks: vec![SourceDescriptionChunk { in test_valid_packet()
172 chunks: vec![SourceDescriptionChunk { in test_cname()
274 chunks: vec![SourceDescriptionChunk { in test_compound_packet_roundtrip()
H A Dmod.rs145 for c in &e.chunks { in validate()
177 for c in &sdes.chunks { in cname()
/webrtc/sctp/src/stream/
H A Dmod.rs276 let chunks = self.prepare_write(p, ppi)?; in write_sctp() localVariable
277 self.send_payload_data(chunks).await?; in write_sctp()
318 let mut chunks = vec![]; in packetize() localVariable
343 chunks.push(chunk); in packetize()
360 chunks in packetize()
490 async fn send_payload_data(&self, chunks: Vec<ChunkPayloadData>) -> Result<()> { in send_payload_data()
497 self.pending_queue.append(chunks).await; in send_payload_data()
/webrtc/sctp/
H A DCHANGELOG.md22 * Fixed a possible bug when adding chunks to pending queue [#345](https://github.com/webrtc-rs/webr…
/webrtc/rtcp/src/
H A Dpacket.rs173 chunks: vec![SourceDescriptionChunk { in test_packet_unmarshal()