Lines Matching refs:pq
26 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_push_no_check() localVariable
28 pq.push_no_check(make_payload(0, 10)); in test_payload_queue_push_no_check()
29 assert_eq!(pq.get_num_bytes(), 10, "total bytes mismatch"); in test_payload_queue_push_no_check()
30 assert_eq!(pq.len(), 1, "item count mismatch"); in test_payload_queue_push_no_check()
31 pq.push_no_check(make_payload(1, 11)); in test_payload_queue_push_no_check()
32 assert_eq!(pq.get_num_bytes(), 21, "total bytes mismatch"); in test_payload_queue_push_no_check()
33 assert_eq!(pq.len(), 2, "item count mismatch"); in test_payload_queue_push_no_check()
34 pq.push_no_check(make_payload(2, 12)); in test_payload_queue_push_no_check()
35 assert_eq!(pq.get_num_bytes(), 33, "total bytes mismatch"); in test_payload_queue_push_no_check()
36 assert_eq!(pq.len(), 3, "item count mismatch"); in test_payload_queue_push_no_check()
39 assert!(!pq.sorted.is_empty(), "should not be empty"); in test_payload_queue_push_no_check()
40 let c = pq.pop(i); in test_payload_queue_push_no_check()
47 assert_eq!(pq.get_num_bytes(), 0, "total bytes mismatch"); in test_payload_queue_push_no_check()
48 assert_eq!(pq.len(), 0, "item count mismatch"); in test_payload_queue_push_no_check()
50 assert!(pq.sorted.is_empty(), "should be empty"); in test_payload_queue_push_no_check()
51 pq.push_no_check(make_payload(3, 13)); in test_payload_queue_push_no_check()
52 assert_eq!(pq.get_num_bytes(), 13, "total bytes mismatch"); in test_payload_queue_push_no_check()
53 pq.push_no_check(make_payload(4, 14)); in test_payload_queue_push_no_check()
54 assert_eq!(pq.get_num_bytes(), 27, "total bytes mismatch"); in test_payload_queue_push_no_check()
57 assert!(!pq.sorted.is_empty(), "should not be empty"); in test_payload_queue_push_no_check()
58 let c = pq.pop(i); in test_payload_queue_push_no_check()
65 assert_eq!(pq.get_num_bytes(), 0, "total bytes mismatch"); in test_payload_queue_push_no_check()
66 assert_eq!(pq.len(), 0, "item count mismatch"); in test_payload_queue_push_no_check()
73 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_get_gap_ack_block() localVariable
75 pq.push(make_payload(1, 0), 0); in test_payload_queue_get_gap_ack_block()
76 pq.push(make_payload(2, 0), 0); in test_payload_queue_get_gap_ack_block()
77 pq.push(make_payload(3, 0), 0); in test_payload_queue_get_gap_ack_block()
78 pq.push(make_payload(4, 0), 0); in test_payload_queue_get_gap_ack_block()
79 pq.push(make_payload(5, 0), 0); in test_payload_queue_get_gap_ack_block()
80 pq.push(make_payload(6, 0), 0); in test_payload_queue_get_gap_ack_block()
83 let gab2 = pq.get_gap_ack_blocks(0); in test_payload_queue_get_gap_ack_block()
90 pq.push(make_payload(8, 0), 0); in test_payload_queue_get_gap_ack_block()
91 pq.push(make_payload(9, 0), 0); in test_payload_queue_get_gap_ack_block()
97 let gab2 = pq.get_gap_ack_blocks(0); in test_payload_queue_get_gap_ack_block()
111 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_get_last_tsn_received() localVariable
114 let ok = pq.get_last_tsn_received(); in test_payload_queue_get_last_tsn_received()
117 let ok = pq.push(make_payload(20, 0), 0); in test_payload_queue_get_last_tsn_received()
119 let tsn = pq.get_last_tsn_received(); in test_payload_queue_get_last_tsn_received()
124 let ok = pq.push(make_payload(21, 0), 0); in test_payload_queue_get_last_tsn_received()
126 let tsn = pq.get_last_tsn_received(); in test_payload_queue_get_last_tsn_received()
131 let ok = pq.push(make_payload(19, 0), 0); in test_payload_queue_get_last_tsn_received()
133 let tsn = pq.get_last_tsn_received(); in test_payload_queue_get_last_tsn_received()
142 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_mark_all_to_retrasmit() localVariable
145 pq.push(make_payload(i + 1, 10), 0); in test_payload_queue_mark_all_to_retrasmit()
147 pq.mark_as_acked(2); in test_payload_queue_mark_all_to_retrasmit()
148 pq.mark_all_to_retrasmit(); in test_payload_queue_mark_all_to_retrasmit()
150 let c = pq.get(1); in test_payload_queue_mark_all_to_retrasmit()
153 let c = pq.get(2); in test_payload_queue_mark_all_to_retrasmit()
156 let c = pq.get(3); in test_payload_queue_mark_all_to_retrasmit()
165 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_reset_retransmit_flag_on_ack() localVariable
168 pq.push(make_payload(i + 1, 10), 0); in test_payload_queue_reset_retransmit_flag_on_ack()
171 pq.mark_all_to_retrasmit(); in test_payload_queue_reset_retransmit_flag_on_ack()
172 pq.mark_as_acked(2); // should cancel retransmission for TSN 2 in test_payload_queue_reset_retransmit_flag_on_ack()
173 pq.mark_as_acked(4); // should cancel retransmission for TSN 4 in test_payload_queue_reset_retransmit_flag_on_ack()
175 let c = pq.get(1); in test_payload_queue_reset_retransmit_flag_on_ack()
178 let c = pq.get(2); in test_payload_queue_reset_retransmit_flag_on_ack()
181 let c = pq.get(3); in test_payload_queue_reset_retransmit_flag_on_ack()
184 let c = pq.get(4); in test_payload_queue_reset_retransmit_flag_on_ack()
233 let mut pq = PendingBaseQueue::new(); in test_pending_base_queue_push_and_pop() localVariable
234 pq.push_back(make_data_chunk(0, false, NO_FRAGMENT)); in test_pending_base_queue_push_and_pop()
235 pq.push_back(make_data_chunk(1, false, NO_FRAGMENT)); in test_pending_base_queue_push_and_pop()
236 pq.push_back(make_data_chunk(2, false, NO_FRAGMENT)); in test_pending_base_queue_push_and_pop()
239 let c = pq.get(i); in test_pending_base_queue_push_and_pop()
245 let c = pq.pop_front(); in test_pending_base_queue_push_and_pop()
250 pq.push_back(make_data_chunk(3, false, NO_FRAGMENT)); in test_pending_base_queue_push_and_pop()
251 pq.push_back(make_data_chunk(4, false, NO_FRAGMENT)); in test_pending_base_queue_push_and_pop()
254 let c = pq.pop_front(); in test_pending_base_queue_push_and_pop()
263 let mut pq = PendingBaseQueue::new(); in test_pending_base_queue_out_of_bounce() localVariable
264 assert!(pq.pop_front().is_none(), "should be none"); in test_pending_base_queue_out_of_bounce()
265 assert!(pq.get(0).is_none(), "should be none"); in test_pending_base_queue_out_of_bounce()
267 pq.push_back(make_data_chunk(0, false, NO_FRAGMENT)); in test_pending_base_queue_out_of_bounce()
268 assert!(pq.get(1).is_none(), "should be none"); in test_pending_base_queue_out_of_bounce()
277 let pq = PendingQueue::new(); in test_pending_queue_push_and_pop() localVariable
278 pq.push(make_data_chunk(0, false, NO_FRAGMENT)).await; in test_pending_queue_push_and_pop()
279 assert_eq!(pq.get_num_bytes(), 10, "total bytes mismatch"); in test_pending_queue_push_and_pop()
280 pq.push(make_data_chunk(1, false, NO_FRAGMENT)).await; in test_pending_queue_push_and_pop()
281 assert_eq!(pq.get_num_bytes(), 20, "total bytes mismatch"); in test_pending_queue_push_and_pop()
282 pq.push(make_data_chunk(2, false, NO_FRAGMENT)).await; in test_pending_queue_push_and_pop()
283 assert_eq!(pq.get_num_bytes(), 30, "total bytes mismatch"); in test_pending_queue_push_and_pop()
286 let c = pq.peek(); in test_pending_queue_push_and_pop()
292 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_push_and_pop()
296 assert_eq!(pq.get_num_bytes(), 0, "total bytes mismatch"); in test_pending_queue_push_and_pop()
298 pq.push(make_data_chunk(3, false, NO_FRAGMENT)).await; in test_pending_queue_push_and_pop()
299 assert_eq!(pq.get_num_bytes(), 10, "total bytes mismatch"); in test_pending_queue_push_and_pop()
300 pq.push(make_data_chunk(4, false, NO_FRAGMENT)).await; in test_pending_queue_push_and_pop()
301 assert_eq!(pq.get_num_bytes(), 20, "total bytes mismatch"); in test_pending_queue_push_and_pop()
304 let c = pq.peek(); in test_pending_queue_push_and_pop()
310 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_push_and_pop()
314 assert_eq!(pq.get_num_bytes(), 0, "total bytes mismatch"); in test_pending_queue_push_and_pop()
321 let pq = PendingQueue::new(); in test_pending_queue_unordered_wins() localVariable
323 pq.push(make_data_chunk(0, false, NO_FRAGMENT)).await; in test_pending_queue_unordered_wins()
324 assert_eq!(10, pq.get_num_bytes(), "total bytes mismatch"); in test_pending_queue_unordered_wins()
325 pq.push(make_data_chunk(1, true, NO_FRAGMENT)).await; in test_pending_queue_unordered_wins()
326 assert_eq!(20, pq.get_num_bytes(), "total bytes mismatch"); in test_pending_queue_unordered_wins()
327 pq.push(make_data_chunk(2, false, NO_FRAGMENT)).await; in test_pending_queue_unordered_wins()
328 assert_eq!(30, pq.get_num_bytes(), "total bytes mismatch"); in test_pending_queue_unordered_wins()
329 pq.push(make_data_chunk(3, true, NO_FRAGMENT)).await; in test_pending_queue_unordered_wins()
330 assert_eq!(40, pq.get_num_bytes(), "total bytes mismatch"); in test_pending_queue_unordered_wins()
332 let c = pq.peek(); in test_pending_queue_unordered_wins()
337 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_unordered_wins()
340 let c = pq.peek(); in test_pending_queue_unordered_wins()
345 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_unordered_wins()
348 let c = pq.peek(); in test_pending_queue_unordered_wins()
353 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_unordered_wins()
356 let c = pq.peek(); in test_pending_queue_unordered_wins()
361 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_unordered_wins()
364 assert_eq!(pq.get_num_bytes(), 0, "total bytes mismatch"); in test_pending_queue_unordered_wins()
371 let pq = PendingQueue::new(); in test_pending_queue_fragments() localVariable
372 pq.push(make_data_chunk(0, false, FRAG_BEGIN)).await; in test_pending_queue_fragments()
373 pq.push(make_data_chunk(1, false, FRAG_MIDDLE)).await; in test_pending_queue_fragments()
374 pq.push(make_data_chunk(2, false, FRAG_END)).await; in test_pending_queue_fragments()
375 pq.push(make_data_chunk(3, true, FRAG_BEGIN)).await; in test_pending_queue_fragments()
376 pq.push(make_data_chunk(4, true, FRAG_MIDDLE)).await; in test_pending_queue_fragments()
377 pq.push(make_data_chunk(5, true, FRAG_END)).await; in test_pending_queue_fragments()
382 let c = pq.peek(); in test_pending_queue_fragments()
387 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_fragments()
398 let pq = PendingQueue::new(); in test_pending_queue_selection_persistence() localVariable
399 pq.push(make_data_chunk(0, false, FRAG_BEGIN)).await; in test_pending_queue_selection_persistence()
401 let c = pq.peek(); in test_pending_queue_selection_persistence()
406 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_selection_persistence()
409 pq.push(make_data_chunk(1, true, NO_FRAGMENT)).await; in test_pending_queue_selection_persistence()
410 pq.push(make_data_chunk(2, false, FRAG_MIDDLE)).await; in test_pending_queue_selection_persistence()
411 pq.push(make_data_chunk(3, false, FRAG_END)).await; in test_pending_queue_selection_persistence()
416 let c = pq.peek(); in test_pending_queue_selection_persistence()
421 let result = pq.pop(beginning_fragment, unordered); in test_pending_queue_selection_persistence()
430 let pq = PendingQueue::new(); in test_pending_queue_append() localVariable
431 pq.append(vec![ in test_pending_queue_append()
437 assert_eq!(pq.get_num_bytes(), 30, "total bytes mismatch"); in test_pending_queue_append()
438 assert_eq!(pq.len(), 3, "len mismatch"); in test_pending_queue_append()