Home
last modified time | relevance | path

Searched refs:pop (Results 1 – 12 of 12) sorted by relevance

/webrtc/dtls/src/fragment_buffer/
H A Dfragment_buffer_test.rs134 let (out, epoch) = fragment_buffer.pop()?; in test_fragment_buffer()
146 let result = fragment_buffer.pop(); in test_fragment_buffer()
H A Dmod.rs88 pub fn pop(&mut self) -> Result<(Vec<u8>, u16)> { in pop() method
/webrtc/util/src/vnet/chunk_queue/
H A Dchunk_queue_test.rs25 let d = q.pop().await; in test_chunk_queue()
31 let d = q.pop().await; in test_chunk_queue()
/webrtc/sctp/src/queue/
H A Dqueue_test.rs40 let c = pq.pop(i); in test_payload_queue_push_no_check()
58 let c = pq.pop(i); in test_payload_queue_push_no_check()
292 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_push_and_pop()
310 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_push_and_pop()
337 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_unordered_wins()
345 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_unordered_wins()
353 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_unordered_wins()
361 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_unordered_wins()
387 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_fragments()
406 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_selection_persistence()
[all …]
H A Dpayload_queue.rs76 pub(crate) fn pop(&mut self, tsn: u32) -> Option<ChunkPayloadData> { in pop() method
H A Dpending_queue.rs190 pub(crate) fn pop( in pop() method
/webrtc/util/src/vnet/
H A Dchunk_queue.rs34 pub(crate) async fn pop(&self) -> Option<Box<dyn Chunk + Send + Sync>> { in pop() method
H A Drouter.rs475 if let Some(c) = queue.pop().await { in process_chunks()
/webrtc/media/src/io/sample_builder/
H A Dsample_builder_test.rs1212 while let Some(sample) = s.pop() { in test_sample_builder()
1218 while let Some(sample) = s.pop() { in test_sample_builder()
1258 s.pop(), in test_sample_builder_max_late()
1294 s.pop(), in test_sample_builder_max_late()
1303 assert_eq!(None, s.pop(), "Failed to build samples after large gap"); in test_sample_builder_max_late()
1314 s.pop(), in test_sample_builder_max_late()
1325 s.pop(), in test_sample_builder_max_late()
1465 assert!(s.pop().is_some(), "Should expect a popped sample.") in test_sample_builder_push_max_zero()
H A Dmod.rs370 pub fn pop(&mut self) -> Option<Sample> { in pop() method
388 if let Some(sample) = self.pop() { in pop_with_timestamp()
/webrtc/sctp/src/association/
H A Dassociation_internal.rs963 while self.payload_queue.pop(self.peer_last_tsn + 1).is_some() { in handle_peer_last_tsn_and_acknowledgement()
1091 if let Some(c) = self.inflight_queue.pop(i) { in process_selective_ack()
1694 self.payload_queue.pop(self.peer_last_tsn + 1); // may not exist in handle_forward_tsn()
1806 if let Some(mut c) = self.pending_queue.pop(beginning_fragment, unordered) { in move_pending_data_chunk_to_inflight_queue()
1870 .pop(beginning_fragment, unordered) in pop_pending_data_chunks_to_send()
/webrtc/dtls/src/conn/
H A Dmod.rs988 while let Ok((out, epoch)) = ctx.fragment_buffer.pop() { in handle_incoming_packet()