Home
last modified time | relevance | path

Searched refs:stream_sequence_number (Results 1 – 6 of 6) sorted by relevance

/webrtc/sctp/src/queue/
H A Dqueue_test.rs460 stream_sequence_number: 0, in test_reassembly_queue_ordered_fragments()
473 stream_sequence_number: 0, in test_reassembly_queue_ordered_fragments()
504 stream_sequence_number: 0, in test_reassembly_queue_unordered_fragments()
517 stream_sequence_number: 0, in test_reassembly_queue_unordered_fragments()
531 stream_sequence_number: 0, in test_reassembly_queue_unordered_fragments()
560 stream_sequence_number: 0, in test_reassembly_queue_ordered_and_unordered_fragments()
575 stream_sequence_number: 1, in test_reassembly_queue_ordered_and_unordered_fragments()
618 stream_sequence_number: 0, in test_reassembly_queue_unordered_complete_skips_incomplete()
632 stream_sequence_number: 1, in test_reassembly_queue_unordered_complete_skips_incomplete()
647 stream_sequence_number: 1, in test_reassembly_queue_unordered_complete_skips_incomplete()
[all …]
H A Dreassembly_queue.rs158 if sna16lt(chunk.stream_sequence_number, self.next_ssn) { in push()
166 if s.ssn == chunk.stream_sequence_number { in push()
172 let mut cset = ChunkSet::new(chunk.stream_sequence_number, chunk.payload_type); in push()
/webrtc/sctp/src/chunk/
H A Dchunk_payload_data.rs100 pub(crate) stream_sequence_number: u16, field
132 stream_sequence_number: 0, in default()
197 let stream_sequence_number = reader.get_u16(); in unmarshal() localVariable
211 stream_sequence_number, in unmarshal()
229 writer.put_u16(self.stream_sequence_number); in marshal_to()
/webrtc/sctp/src/association/association_internal/
H A Dassociation_internal_test.rs77 stream_sequence_number: 2, in test_create_forward_tsn_forward_one_abandoned()
107 stream_sequence_number: 2, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
118 stream_sequence_number: 3, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
129 stream_sequence_number: 1, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
214 stream_sequence_number: 1, in test_handle_forward_tsn_forward_1for1_missing()
264 stream_sequence_number: 1, in test_handle_forward_tsn_forward_1for2_missing()
/webrtc/sctp/src/association/
H A Dassociation_internal.rs916 …cepted as this is a missing chunk with tsn={} ssn={}", self.name, d.tsn, d.stream_sequence_number); in handle_data()
925 d.stream_sequence_number in handle_data()
932 log::debug!("discard {}", d.stream_sequence_number); in handle_data()
1570 if sna16lt(*ssn, c.stream_sequence_number) { in create_forward_tsn()
1572 stream_map.insert(c.stream_identifier, c.stream_sequence_number); in create_forward_tsn()
1575 stream_map.insert(c.stream_identifier, c.stream_sequence_number); in create_forward_tsn()
1825 c.stream_sequence_number, in move_pending_data_chunk_to_inflight_queue()
2035 c.stream_sequence_number, in get_data_packets_to_retransmit()
/webrtc/sctp/src/stream/
H A Dmod.rs337 stream_sequence_number: self.sequence_number.load(Ordering::SeqCst), in packetize()