| /webrtc/sctp/src/queue/ |
| H A D | queue_test.rs | 219 unordered, in make_data_chunk()
336 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_unordered_wins()
344 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_unordered_wins()
352 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_unordered_wins()
360 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_unordered_wins()
405 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_selection_persistence()
501 unordered: true, in test_reassembly_queue_unordered_fragments()
515 unordered: true, in test_reassembly_queue_unordered_fragments()
528 unordered: true, in test_reassembly_queue_unordered_fragments()
571 unordered: true, in test_reassembly_queue_ordered_and_unordered_fragments()
[all …]
|
| H A D | reassembly_queue.rs | 114 pub(crate) unordered: Vec<ChunkSet>, field
130 unordered: vec![], in new()
141 if chunk.unordered { in push()
151 self.unordered.push(cset); in push()
173 let unordered = chunk.unordered; in push() localVariable
176 if !unordered { in push()
241 if !self.unordered.is_empty() { in is_readable()
258 let cset = if !self.unordered.is_empty() { in read()
259 self.unordered.remove(0) in read()
|
| H A D | pending_queue.rs | 76 if c.unordered { in push()
126 if chunk.unordered { in append_large()
141 let unordered = chunks in append_unlimited() localVariable
144 .unordered; in append_unlimited()
145 if unordered { in append_unlimited()
148 chunks.iter().all(|c| c.unordered), in append_unlimited()
155 chunks.iter().all(|c| !c.unordered), in append_unlimited()
193 unordered: bool, in pop()
213 if unordered { in pop()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_payload_data.rs | 93 pub(crate) unordered: bool, field
126 unordered: false, in default()
162 if self.unordered { in header()
184 let unordered = (header.flags & PAYLOAD_DATA_UNORDERED_BITMASK) != 0; in unmarshal() localVariable
204 unordered, in unmarshal()
|
| /webrtc/sctp/src/stream/ |
| H A D | mod.rs | 81 pub(crate) unordered: AtomicBool, field
103 .field("unordered", &self.unordered) in fmt()
137 unordered: AtomicBool::new(false), in new()
163 !unordered, in set_reliability_params()
167 self.unordered.store(unordered, Ordering::SeqCst); in set_reliability_params()
227 if self.unordered.load(Ordering::SeqCst) { in handle_forward_tsn_for_ordered()
246 if !self.unordered.load(Ordering::SeqCst) { in handle_forward_tsn_for_unordered()
315 let unordered = in packetize() localVariable
316 ppi != PayloadProtocolIdentifier::Dcep && self.unordered.load(Ordering::SeqCst); in packetize()
332 unordered, in packetize()
[all …]
|
| H A D | stream_test.rs | 109 unordered: true, in test_stream()
128 unordered: true, in test_stream()
177 unordered: true, in test_poll_stream()
196 unordered: true, in test_poll_stream()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 1804 unordered: bool, in move_pending_data_chunk_to_inflight_queue()
1806 if let Some(mut c) = self.pending_queue.pop(beginning_fragment, unordered) { in move_pending_data_chunk_to_inflight_queue()
1859 let (beginning_fragment, unordered, data_len, stream_identifier) = ( in pop_pending_data_chunks_to_send()
1861 c.unordered, in pop_pending_data_chunks_to_send()
1870 .pop(beginning_fragment, unordered) in pop_pending_data_chunks_to_send()
1889 .move_pending_data_chunk_to_inflight_queue(beginning_fragment, unordered) in pop_pending_data_chunks_to_send()
1900 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in pop_pending_data_chunks_to_send()
1903 .move_pending_data_chunk_to_inflight_queue(beginning_fragment, unordered) in pop_pending_data_chunks_to_send()
|
| H A D | association_test.rs | 1109 q.unordered.len(), in test_assoc_unreliable_rexmit_unordered_fragment()
1289 q.unordered.len(), in test_assoc_unreliable_rexmit_timed_unordered()
|
| /webrtc/data/src/data_channel/ |
| H A D | mod.rs | 346 let (unordered, reliability_type) = match self.config.channel_type { in commit_reliability_params()
356 unordered, in commit_reliability_params()
|