Lines Matching refs:rq

452     let mut rq = ReassemblyQueue::new(0);  in test_reassembly_queue_ordered_fragments()  localVariable
465 let complete = rq.push(chunk); in test_reassembly_queue_ordered_fragments()
467 assert_eq!(rq.get_num_bytes(), 3, "num bytes mismatch"); in test_reassembly_queue_ordered_fragments()
478 let complete = rq.push(chunk); in test_reassembly_queue_ordered_fragments()
480 assert_eq!(7, rq.get_num_bytes(), "num bytes mismatch"); in test_reassembly_queue_ordered_fragments()
484 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_ordered_fragments()
486 assert_eq!(rq.get_num_bytes(), 0, "num bytes mismatch"); in test_reassembly_queue_ordered_fragments()
495 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_unordered_fragments() localVariable
509 let complete = rq.push(chunk); in test_reassembly_queue_unordered_fragments()
511 assert_eq!(rq.get_num_bytes(), 3, "num bytes mismatch"); in test_reassembly_queue_unordered_fragments()
522 let complete = rq.push(chunk); in test_reassembly_queue_unordered_fragments()
524 assert_eq!(rq.get_num_bytes(), 7, "num bytes mismatch"); in test_reassembly_queue_unordered_fragments()
536 let complete = rq.push(chunk); in test_reassembly_queue_unordered_fragments()
538 assert_eq!(rq.get_num_bytes(), 8, "num bytes mismatch"); in test_reassembly_queue_unordered_fragments()
542 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_unordered_fragments()
544 assert_eq!(rq.get_num_bytes(), 0, "num bytes mismatch"); in test_reassembly_queue_unordered_fragments()
553 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_ordered_and_unordered_fragments() localVariable
565 let complete = rq.push(chunk); in test_reassembly_queue_ordered_and_unordered_fragments()
567 assert_eq!(rq.get_num_bytes(), 3, "num bytes mismatch"); in test_reassembly_queue_ordered_and_unordered_fragments()
580 let complete = rq.push(chunk); in test_reassembly_queue_ordered_and_unordered_fragments()
582 assert_eq!(rq.get_num_bytes(), 6, "num bytes mismatch"); in test_reassembly_queue_ordered_and_unordered_fragments()
591 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_ordered_and_unordered_fragments()
593 assert_eq!(rq.get_num_bytes(), 3, "num bytes mismatch"); in test_reassembly_queue_ordered_and_unordered_fragments()
598 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_ordered_and_unordered_fragments()
600 assert_eq!(rq.get_num_bytes(), 0, "num bytes mismatch"); in test_reassembly_queue_ordered_and_unordered_fragments()
609 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_unordered_complete_skips_incomplete() localVariable
623 let complete = rq.push(chunk); in test_reassembly_queue_unordered_complete_skips_incomplete()
625 assert_eq!(2, rq.get_num_bytes(), "num bytes mismatch"); in test_reassembly_queue_unordered_complete_skips_incomplete()
637 let complete = rq.push(chunk); in test_reassembly_queue_unordered_complete_skips_incomplete()
639 assert_eq!(rq.get_num_bytes(), 10, "num bytes mismatch"); in test_reassembly_queue_unordered_complete_skips_incomplete()
652 let complete = rq.push(chunk); in test_reassembly_queue_unordered_complete_skips_incomplete()
654 assert_eq!(rq.get_num_bytes(), 14, "num bytes mismatch"); in test_reassembly_queue_unordered_complete_skips_incomplete()
663 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_unordered_complete_skips_incomplete()
665 assert_eq!(rq.get_num_bytes(), 10, "num bytes mismatch"); in test_reassembly_queue_unordered_complete_skips_incomplete()
674 let mut rq = ReassemblyQueue::new(123); in test_reassembly_queue_ignores_chunk_with_wrong_si() localVariable
689 let complete = rq.push(chunk); in test_reassembly_queue_ignores_chunk_with_wrong_si()
691 assert_eq!(rq.get_num_bytes(), 0, "num bytes mismatch"); 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() localVariable
698 rq.next_ssn = 7; // forcibly set expected SSN to 7 in test_reassembly_queue_ignores_chunk_with_stale_ssn()
712 let complete = rq.push(chunk); in test_reassembly_queue_ignores_chunk_with_stale_ssn()
714 assert_eq!(rq.get_num_bytes(), 0, "num bytes mismatch"); 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() localVariable
734 let complete = rq.push(chunk); in test_reassembly_queue_should_fail_to_read_incomplete_chunk()
736 assert_eq!(rq.get_num_bytes(), 2, "num bytes mismatch"); in test_reassembly_queue_should_fail_to_read_incomplete_chunk()
739 let result = rq.read(&mut buf); in test_reassembly_queue_should_fail_to_read_incomplete_chunk()
741 assert_eq!(rq.get_num_bytes(), 2, "num bytes mismatch"); 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() localVariable
762 let complete = rq.push(chunk); in test_reassembly_queue_should_fail_to_read_if_the_nex_ssn_is_not_ready()
764 assert_eq!(rq.get_num_bytes(), 2, "num bytes mismatch"); in test_reassembly_queue_should_fail_to_read_if_the_nex_ssn_is_not_ready()
767 let result = rq.read(&mut buf); in test_reassembly_queue_should_fail_to_read_if_the_nex_ssn_is_not_ready()
769 assert_eq!(rq.get_num_bytes(), 2, "num bytes mismatch"); 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() localVariable
790 let complete = rq.push(chunk); in test_reassembly_queue_detect_buffer_too_short()
792 assert_eq!(rq.get_num_bytes(), 10, "num bytes mismatch"); in test_reassembly_queue_detect_buffer_too_short()
795 let result = rq.read(&mut buf); in test_reassembly_queue_detect_buffer_too_short()
800 assert_eq!(rq.get_num_bytes(), 0, "num bytes mismatch"); in test_reassembly_queue_detect_buffer_too_short()
807 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_forward_tsn_for_ordered_framents() localVariable
824 let complete = rq.push(chunk); in test_reassembly_queue_forward_tsn_for_ordered_framents()
826 assert_eq!(rq.get_num_bytes(), 3, "num bytes mismatch"); in test_reassembly_queue_forward_tsn_for_ordered_framents()
837 let complete = rq.push(chunk); in test_reassembly_queue_forward_tsn_for_ordered_framents()
839 assert_eq!(rq.get_num_bytes(), 6, "num bytes mismatch"); in test_reassembly_queue_forward_tsn_for_ordered_framents()
849 let complete = rq.push(chunk); in test_reassembly_queue_forward_tsn_for_ordered_framents()
851 assert_eq!(rq.get_num_bytes(), 9, "num bytes mismatch"); in test_reassembly_queue_forward_tsn_for_ordered_framents()
853 rq.forward_tsn_for_ordered(ssn_dropped); in test_reassembly_queue_forward_tsn_for_ordered_framents()
855 assert_eq!(rq.ordered.len(), 1, "there should be one chunk left"); in test_reassembly_queue_forward_tsn_for_ordered_framents()
856 assert_eq!(rq.get_num_bytes(), 3, "num bytes mismatch"); in test_reassembly_queue_forward_tsn_for_ordered_framents()
863 let mut rq = ReassemblyQueue::new(0); in test_reassembly_queue_forward_tsn_for_unordered_framents() localVariable
880 let complete = rq.push(chunk); in test_reassembly_queue_forward_tsn_for_unordered_framents()
882 assert_eq!(rq.get_num_bytes(), 3, "num bytes mismatch"); in test_reassembly_queue_forward_tsn_for_unordered_framents()
893 let complete = rq.push(chunk); in test_reassembly_queue_forward_tsn_for_unordered_framents()
895 assert_eq!(rq.get_num_bytes(), 6, "num bytes mismatch"); in test_reassembly_queue_forward_tsn_for_unordered_framents()
907 let complete = rq.push(chunk); in test_reassembly_queue_forward_tsn_for_unordered_framents()
909 assert_eq!(rq.get_num_bytes(), 9, "num bytes mismatch"); in test_reassembly_queue_forward_tsn_for_unordered_framents()
913 rq.forward_tsn_for_unordered(13); in test_reassembly_queue_forward_tsn_for_unordered_framents()
917 rq.unordered_chunks.len(), in test_reassembly_queue_forward_tsn_for_unordered_framents()
921 assert_eq!(rq.get_num_bytes(), 3, "num bytes mismatch"); in test_reassembly_queue_forward_tsn_for_unordered_framents()