Searched refs:beginning_fragment (Results 1 – 8 of 8) sorted by relevance
| /webrtc/sctp/src/queue/ |
| H A D | queue_test.rs | 220 beginning_fragment: b, in make_data_chunk() 290 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_push_and_pop() 308 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_push_and_pop() 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() 386 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_fragments() 405 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_selection_persistence() 420 let (beginning_fragment, unordered) = (c.beginning_fragment, c.unordered); in test_pending_queue_selection_persistence() [all …]
|
| H A D | pending_queue.rs | 192 beginning_fragment: bool, in pop() 210 if !beginning_fragment { in pop()
|
| H A D | reassembly_queue.rs | 76 if !self.chunks[0].beginning_fragment { in is_complete() 192 if c.beginning_fragment { in find_complete_unordered_chunk_set()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_payload_data.rs | 94 pub(crate) beginning_fragment: bool, field 127 beginning_fragment: false, in default() 159 if self.beginning_fragment { in header() 185 let beginning_fragment = (header.flags & PAYLOAD_DATA_BEGINING_FRAGMENT_BITMASK) != 0; in unmarshal() localVariable 205 beginning_fragment, in unmarshal()
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 73 beginning_fragment: true, in test_create_forward_tsn_forward_one_abandoned() 103 beginning_fragment: true, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si() 114 beginning_fragment: true, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si() 125 beginning_fragment: true, in test_create_forward_tsn_forward_two_abandoned_with_the_same_si() 210 beginning_fragment: true, in test_handle_forward_tsn_forward_1for1_missing() 260 beginning_fragment: true, in test_handle_forward_tsn_forward_1for2_missing() 347 beginning_fragment: true, in test_assoc_create_new_stream()
|
| /webrtc/sctp/src/stream/ |
| H A D | stream_test.rs | 110 beginning_fragment: true, in test_stream() 129 beginning_fragment: true, in test_stream() 178 beginning_fragment: true, in test_poll_stream() 197 beginning_fragment: true, in test_poll_stream()
|
| H A D | mod.rs | 333 beginning_fragment: i == 0, in packetize() 513 beginning_fragment: true, in send_reset_request()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 1730 beginning_fragment: true, in send_reset_request() 1803 beginning_fragment: 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() 1828 c.beginning_fragment, in move_pending_data_chunk_to_inflight_queue() 1859 let (beginning_fragment, unordered, data_len, stream_identifier) = ( in pop_pending_data_chunks_to_send() 1860 c.beginning_fragment, 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()
|