Searched refs:ReassemblyQueue (Results 1 – 3 of 3) sorted by relevance
452 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_ordered_fragments()495 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_unordered_fragments()553 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_ordered_and_unordered_fragments()609 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_unordered_complete_skips_incomplete()674 let mut rq = ReassemblyQueue::new(123); in test_reassembly_queue_ignores_chunk_with_wrong_si()697 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_ignores_chunk_with_stale_ssn()721 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_should_fail_to_read_incomplete_chunk()748 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_should_fail_to_read_if_the_nex_ssn_is_not_ready()776 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_detect_buffer_too_short()807 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_forward_tsn_for_ordered_framents()[all …]
109 pub(crate) struct ReassemblyQueue { struct119 impl ReassemblyQueue { implementation126 ReassemblyQueue { in new()
8 use crate::queue::reassembly_queue::ReassemblyQueue;76 pub(crate) reassembly_queue: Mutex<ReassemblyQueue>,132 reassembly_queue: Mutex::new(ReassemblyQueue::new(stream_identifier)), in new()