Searched refs:reassembly_queue (Results 1 – 4 of 4) sorted by relevance
193 let mut reassembly_queue = self.reassembly_queue.lock().await; in read_sctp() localVariable194 reassembly_queue.read(p) in read_sctp()209 let mut reassembly_queue = self.reassembly_queue.lock().await; in handle_data() localVariable210 if reassembly_queue.push(pd) { in handle_data()234 let mut reassembly_queue = self.reassembly_queue.lock().await; in handle_forward_tsn_for_ordered() localVariable236 reassembly_queue.is_readable() in handle_forward_tsn_for_ordered()253 let mut reassembly_queue = self.reassembly_queue.lock().await; in handle_forward_tsn_for_unordered() localVariable474 let reassembly_queue = self.reassembly_queue.lock().await; in get_num_bytes_in_reassembly_queue() localVariable475 reassembly_queue.get_num_bytes() in get_num_bytes_in_reassembly_queue()648 let reassembly_queue = self.stream.reassembly_queue.lock().await; in get_num_bytes_in_reassembly_queue() localVariable[all …]
7 pub(crate) mod reassembly_queue; module
446 use super::reassembly_queue::*;
276 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_simple()379 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_ordered_reordered()446 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_ordered_fragmented_then_defragmented()513 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_unordered_fragmented_then_defragmented()606 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_unordered_ordered()687 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_retransmission()753 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_short_buffer()843 let q = s0.reassembly_queue.lock().await; in test_assoc_unreliable_rexmit_ordered_no_fragment()933 let q = s0.reassembly_queue.lock().await; in test_assoc_unreliable_rexmit_ordered_fragment()1018 let q = s0.reassembly_queue.lock().await; in test_assoc_unreliable_rexmit_unordered_no_fragment()[all …]