| /webrtc/sctp/src/chunk/ |
| H A D | chunk_selective_ack.rs | 41 pub(crate) end: u16, field
47 write!(f, "{} - {}", self.start, self.end) in fmt()
120 let end = reader.get_u16(); in unmarshal() localVariable
121 gap_ack_blocks.push(GapAckBlock { start, end }); in unmarshal()
144 writer.put_u16(g.end); in marshal_to()
|
| /webrtc/dtls/src/fragment_buffer/ |
| H A D | mod.rs | 67 let mut end = HANDSHAKE_HEADER_LENGTH + handshake_header.length as usize; in push() localVariable
68 if end > buf.len() { in push()
69 end = buf.len(); in push()
73 let data = buf[HANDSHAKE_HEADER_LENGTH..end].to_vec(); in push()
82 buf = &buf[end..]; in push()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | generator_stream.rs | 11 end: u16, field
21 end: 0, in new()
30 self.end = seq; in add()
37 let diff = seq.wrapping_sub(self.end); in add()
42 let mut i = self.end.wrapping_add(1); in add()
48 self.end = seq; in add()
68 let diff = self.end.wrapping_sub(seq); in get()
81 let until = self.end.wrapping_sub(skip_last_n); in missing_seq_numbers()
118 while i != self.end.wrapping_add(1) && self.get_received(i) { in fix_last_consecutive()
|
| /webrtc/sctp/src/queue/ |
| H A D | payload_queue.rs | 118 b.end = b.start; in get_gap_ack_blocks()
119 } else if b.end + 1 == diff { in get_gap_ack_blocks()
120 b.end += 1; in get_gap_ack_blocks()
125 b.end = diff; in get_gap_ack_blocks()
137 s += format!(",{}-{}", b.start, b.end).as_str(); in get_gap_ack_blocks_string()
|
| H A D | queue_test.rs | 82 let gab1 = vec![GapAckBlock { start: 1, end: 6 }]; in test_payload_queue_get_gap_ack_block()
88 assert_eq!(gab2[0].end, gab1[0].end); in test_payload_queue_get_gap_ack_block()
94 GapAckBlock { start: 1, end: 6 }, in test_payload_queue_get_gap_ack_block()
95 GapAckBlock { start: 8, end: 9 }, in test_payload_queue_get_gap_ack_block()
102 assert_eq!(gab2[0].end, gab1[0].end); in test_payload_queue_get_gap_ack_block()
104 assert_eq!(gab2[1].end, gab1[1].end); in test_payload_queue_get_gap_ack_block()
|
| /webrtc/rtp/src/ |
| H A D | header.rs | 120 let end = curr_offset + extension_length; in unmarshal() localVariable
121 while curr_offset < end { in unmarshal()
146 let end = curr_offset + extension_length; in unmarshal() localVariable
147 while curr_offset < end { in unmarshal()
|
| /webrtc/util/src/buffer/ |
| H A D | mod.rs | 164 let end = std::cmp::min(b.data.len(), b.tail + packet.len()); in write() localVariable
165 let n = end - b.tail; in write()
167 b.data[tail..end].copy_from_slice(&packet[..n]); in write()
|
| /webrtc/examples/examples/insertable-streams/ |
| H A D | README.md | 48 …n your browser above the input boxes. `insertable-streams` will exit when the file reaches the end.
|
| /webrtc/constraints/src/capability/ |
| H A D | value_range.rs | 71 max: Some(range.end), in from()
|
| /webrtc/constraints/ |
| H A D | .gitignore | 62 # Icon must end with two \r
|
| /webrtc/examples/examples/play-from-disk-h264/ |
| H A D | README.md | 43 …n your browser above the input boxes. `play-from-disk-h264` will exit when the file reaches the end
|
| /webrtc/examples/examples/rtp-forwarder/ |
| H A D | README.md | 52 …p://live.twitch.tv/app/$STREAM_KEY` Make sure to replace `$STREAM_KEY` at the end of the URL first.
|
| /webrtc/util/src/vnet/ |
| H A D | net.rs | 254 pub(crate) async fn assign_port(&self, ip: IpAddr, start: u16, end: u16) -> Result<u16> { in assign_port()
256 if end < start { in assign_port()
260 let space = end + 1 - start; in assign_port()
|
| /webrtc/constraints/src/ |
| H A D | supported_constraints.rs | 116 map.end() in serialize()
|
| /webrtc/examples/examples/play-from-disk-vpx/ |
| H A D | README.md | 46 …in your browser above the input boxes. `play-from-disk-vpx` will exit when the file reaches the end
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 274 let end = 1002u16; in test_net_virtual_assign_port() localVariable
275 let space = end + 1 - start; in test_net_virtual_assign_port()
295 let port = vnet.assign_port(ip, start, end).await?; in test_net_virtual_assign_port()
317 let result = vnet.assign_port(ip, start, end).await; in test_net_virtual_assign_port()
|
| /webrtc/webrtc/src/api/media_engine/ |
| H A D | mod.rs | 361 if self.header_extensions.len() > VALID_EXT_IDS.end as usize { in register_header_extension()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 1155 for i in g.start..=g.end { in process_selective_ack()
|
| H A D | association_test.rs | 2529 end: 200, in test_association_handle_packet_before_init()
|