Searched refs:ssn (Results 1 – 4 of 4) sorted by relevance
| /webrtc/sctp/src/queue/ |
| H A D | reassembly_queue.rs | 20 if sna16lt(a.ssn, b.ssn) { in sort_chunks_by_ssn()
32 pub(crate) ssn: u16, field
38 pub(crate) fn new(ssn: u16, ppi: PayloadProtocolIdentifier) -> Self { in new()
40 ssn, in new()
166 if s.ssn == chunk.stream_sequence_number { in push()
249 if cset.is_complete() && sna16lte(cset.ssn, self.next_ssn) { in is_readable()
266 if sna16gt(cset.ssn, self.next_ssn) { in read()
269 if cset.ssn == self.next_ssn { in read()
307 .filter(|s| sna16lte(s.ssn, last_ssn) && !s.is_complete()) in forward_tsn_for_ordered()
314 .retain(|s| !sna16lte(s.ssn, last_ssn) || s.is_complete()); in forward_tsn_for_ordered()
|
| H A D | queue_test.rs | 954 ssn: 0, in test_chunk_set_incomplete_chunk_set_no_beginning()
968 ssn: 0, in test_chunk_set_incomplete_chunk_set_no_contiguous_tsn()
|
| /webrtc/sctp/src/stream/ |
| H A D | mod.rs | 226 pub(crate) async fn handle_forward_tsn_for_ordered(&self, ssn: u16) { in handle_forward_tsn_for_ordered()
235 reassembly_queue.forward_tsn_for_ordered(ssn); in handle_forward_tsn_for_ordered()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 1569 if let Some(ssn) = stream_map.get(&c.stream_identifier) { in create_forward_tsn()
1570 if sna16lt(*ssn, c.stream_sequence_number) { in create_forward_tsn()
1590 for (si, ssn) in &stream_map { in create_forward_tsn()
1594 sequence: *ssn, in create_forward_tsn()
|