Searched refs:stream_identifier (Results 1 – 11 of 11) sorted by relevance
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_payload_data.rs | 99 pub(crate) stream_identifier: u16, field
131 stream_identifier: 0, in default()
196 let stream_identifier = reader.get_u16(); in unmarshal() localVariable
210 stream_identifier, in unmarshal()
228 writer.put_u16(self.stream_identifier); in marshal_to()
|
| /webrtc/sctp/src/stream/ |
| H A D | mod.rs | 74 pub(crate) stream_identifier: u16, field
97 .field("stream_identifier", &self.stream_identifier) in fmt()
116 stream_identifier: u16, in new()
130 stream_identifier, in new()
148 pub fn stream_identifier(&self) -> u16 { in stream_identifier() method
149 self.stream_identifier in stream_identifier()
330 stream_identifier: self.stream_identifier, in packetize()
398 self.send_reset_request(self.stream_identifier).await?; in shutdown()
512 stream_identifier, in send_reset_request()
629 pub fn stream_identifier(&self) -> u16 { in stream_identifier() method
[all …]
|
| H A D | stream_test.rs | 87 assert_eq!(s.stream_identifier(), 0); in test_stream()
162 assert_eq!(poll_stream.stream_identifier(), 0); in test_poll_stream()
210 assert_eq!(clone.stream_identifier(), poll_stream.stream_identifier()); in test_poll_stream()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 301 let s = self.streams.remove(&stream_identifier); in unregister_stream()
1019 stream_identifier: u16, in open_stream()
1022 if self.streams.contains_key(&stream_identifier) { in open_stream()
1038 stream_identifier, in create_stream()
1052 stream_identifier in create_stream()
1073 self.streams.get(&stream_identifier).cloned() in get_or_create_stream()
1075 self.create_stream(stream_identifier, true) in get_or_create_stream()
1729 stream_identifier, in send_reset_request()
1775 let stream_identifier = s.stream_identifier; in reset_streams_if_any() localVariable
1863 c.stream_identifier, in pop_pending_data_chunks_to_send()
[all …]
|
| H A D | mod.rs | 577 stream_identifier: u16, in open_stream()
581 ai.open_stream(stream_identifier, default_payload_type) in open_stream()
|
| H A D | association_test.rs | 198 if s0.stream_identifier != s1.stream_identifier { in establish_session_pair()
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 76 stream_identifier: 1, in test_create_forward_tsn_forward_one_abandoned()
106 stream_identifier: 1, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
117 stream_identifier: 1, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
128 stream_identifier: 2, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
213 stream_identifier: 0, in test_handle_forward_tsn_forward_1for1_missing()
263 stream_identifier: 0, in test_handle_forward_tsn_forward_1for2_missing()
333 let result = a.streams.get(&s.stream_identifier); in test_assoc_create_new_stream()
350 stream_identifier: new_si, in test_assoc_create_new_stream()
|
| /webrtc/data/src/data_channel/ |
| H A D | mod.rs | 89 if channel.stream_identifier() == stream.stream_identifier() { in accept()
232 pub fn stream_identifier(&self) -> u16 { in stream_identifier() method
233 self.stream.stream_identifier() in stream_identifier()
459 pub fn stream_identifier(&self) -> u16 { in stream_identifier() method
460 self.data_channel.stream_identifier() in stream_identifier()
|
| /webrtc/sctp/src/queue/ |
| H A D | reassembly_queue.rs | 137 if chunk.stream_identifier != self.si { in push()
|
| H A D | queue_test.rs | 680 stream_identifier: 124, in test_reassembly_queue_ignores_chunk_with_wrong_si()
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | mod.rs | 280 Some(dc.stream_identifier()) in accept_data_channels()
|