Searched refs:tsn (Results 1 – 6 of 6) sorted by relevance
| /webrtc/sctp/src/queue/ |
| H A D | payload_queue.rs | 28 !(self.chunk_map.contains_key(&p.tsn) || sna32lte(p.tsn, cumulative_tsn)) in can_push()
32 let tsn = p.tsn; in push_no_check() localVariable
34 self.chunk_map.insert(tsn, p); in push_no_check()
38 self.sorted.push_back(tsn); in push_no_check()
40 self.sorted.push_front(tsn); in push_no_check()
56 self.sorted.insert(pos, tsn); in push_no_check()
67 self.dup_tsn.push(p.tsn); in push()
77 if Some(&tsn) == self.sorted.front() { in pop()
91 self.chunk_map.get(&tsn) in get()
94 self.chunk_map.get_mut(&tsn) in get_mut()
[all …]
|
| H A D | queue_test.rs | 14 tsn, in make_payload()
218 tsn, in make_data_chunk()
459 tsn: 1, in test_reassembly_queue_ordered_fragments()
472 tsn: 2, in test_reassembly_queue_ordered_fragments()
503 tsn: 1, in test_reassembly_queue_unordered_fragments()
516 tsn: 2, in test_reassembly_queue_unordered_fragments()
530 tsn: 3, in test_reassembly_queue_unordered_fragments()
559 tsn: 1, in test_reassembly_queue_ordered_and_unordered_fragments()
574 tsn: 2, in test_reassembly_queue_ordered_and_unordered_fragments()
617 tsn: 10, in test_reassembly_queue_unordered_complete_skips_incomplete()
[all …]
|
| H A D | reassembly_queue.rs | 10 if sna32lt(a.tsn, b.tsn) { in sort_chunks_by_tsn()
49 if c.tsn == chunk.tsn { in push()
95 if c.tsn != last_tsn + 1 { in is_complete()
101 last_tsn = c.tsn; in is_complete()
195 last_tsn = c.tsn; in find_complete_unordered_chunk_set()
209 if c.tsn != last_tsn + 1 { in find_complete_unordered_chunk_set()
214 last_tsn = c.tsn; in find_complete_unordered_chunk_set()
330 if sna32gt(c.tsn, new_cumulative_tsn) { in forward_tsn_for_unordered()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_payload_data.rs | 98 pub(crate) tsn: u32, field
130 tsn: 0, in default()
149 write!(f, "{}\n{}", self.header(), self.tsn) in fmt()
195 let tsn = reader.get_u32(); in unmarshal() localVariable
209 tsn, in unmarshal()
227 writer.put_u32(self.tsn); in marshal_to()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 117 if tsn == 0 { in new()
118 tsn += 1; in new()
135 my_next_tsn: tsn, in new()
136 my_next_rsn: tsn, in new()
459 c.tsn, in gather_outbound_fast_retransmission_packets()
898 d.tsn, in handle_data()
1344 tsn += 1; in process_fast_retransmission()
1824 c.tsn, in move_pending_data_chunk_to_inflight_queue()
1971 c.tsn, in check_partial_reliability_status()
2034 c.tsn, in get_data_packets_to_retransmit()
[all …]
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 75 tsn: 10, in test_create_forward_tsn_forward_one_abandoned()
105 tsn: 10, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
116 tsn: 11, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
127 tsn: 12, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
212 tsn: a.peer_last_tsn + 2, in test_handle_forward_tsn_forward_1for1_missing()
262 tsn: a.peer_last_tsn + 3, in test_handle_forward_tsn_forward_1for2_missing()
349 tsn: a.peer_last_tsn + 1, in test_assoc_create_new_stream()
|