| /webrtc/stun/src/ |
| H A D | integrity.rs | 51 let length = m.length; in add_to() localVariable
53 m.length += (MESSAGE_INTEGRITY_SIZE + ATTRIBUTE_HEADER_SIZE) as u32; in add_to()
56 m.length = length; // changing m.Length back in add_to()
93 let length = m.length as usize; in check() localVariable
99 size_reduced += nearest_padded_value_length(a.length as usize); in check()
106 m.length -= size_reduced as u32; in check()
109 let start_of_hmac = MESSAGE_HEADER_SIZE + m.length as usize in check()
113 m.length = length as u32; in check()
|
| H A D | message.rs | 59 pub length: u32, // len(Raw) not including header field
72 self.length, in fmt()
89 if self.length != other.length { in eq()
151 self.length = 0; in reset()
184 self.length += alloc_size as u32; // rendering length change in add()
196 length: v.len() as u16, // L in add()
201 if attr.length as usize % PADDING != 0 { in add()
213 self.length += bytes_to_add as u32; // rendering length change in add()
267 self.length = 0; in encode()
299 self.length = size as u32; in decode()
[all …]
|
| H A D | fingerprint.rs | 41 let l = m.length; in add_to()
43 m.length += (FINGERPRINT_SIZE + ATTRIBUTE_HEADER_SIZE) as u32; // increasing length in add_to()
47 m.length = l; in add_to()
|
| /webrtc/webrtc/src/peer_connection/operation/ |
| H A D | mod.rs | 41 length: Arc<AtomicUsize>, field
48 let length = Arc::new(AtomicUsize::new(0)); in new() localVariable
51 let l = Arc::clone(&length); in new()
59 length, in new()
69 return Operations::enqueue_inner(op, ops_tx, &self.length); in enqueue()
78 length: &Arc<AtomicUsize>, in enqueue_inner()
80 length.fetch_add(1, Ordering::SeqCst); in enqueue_inner()
88 self.length.load(Ordering::SeqCst) == 0 in is_empty()
109 length: Arc<AtomicUsize>, in start()
121 length.fetch_sub(1, Ordering::SeqCst); in start()
[all …]
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_header.rs | 51 let length = reader.get_u16(); in unmarshal() localVariable
53 if length < CHUNK_HEADER_SIZE as u16 { in unmarshal()
56 if (length as usize) > raw.len() { in unmarshal()
61 let value_length = length as isize - CHUNK_HEADER_SIZE as isize; in unmarshal()
63 let length_after_value = raw.len() as isize - length as isize; in unmarshal()
87 value_length: length - CHUNK_HEADER_SIZE as u16, in unmarshal()
|
| H A D | chunk_error.rs | 68 offset += e.length(); in unmarshal()
90 .fold(0, |length, ec| length + ec.length()) in value_length()
|
| H A D | chunk_abort.rs | 66 offset += e.length(); in unmarshal()
88 .fold(0, |length, ec| length + ec.length()) in value_length()
|
| H A D | chunk_heartbeat.rs | 88 self.params.iter().fold(0, |length, p| { in value_length()
89 length + PARAM_HEADER_LENGTH + p.value_length() in value_length()
|
| /webrtc/stun/src/message/ |
| H A D | message_test.rs | 190 length: 4, in test_message_bad_length()
212 length: 2, in test_message_attr_length_less_than_header()
242 length: 4, in test_message_attr_size_less_than_length()
346 length: 2, in test_attribute_equal()
351 length: 2, in test_attribute_equal()
397 length: 2, in test_message_equal()
404 length: 4 + 2, in test_message_equal()
409 length: 4 + 2, in test_message_equal()
438 length: 3, in test_message_equal()
445 length: 1, in test_message_equal()
[all …]
|
| /webrtc/rtcp/src/ |
| H A D | header.rs | 98 pub length: u16, field
130 buf.put_u16(self.length); in marshal_to()
163 let length = raw_packet.get_u16(); in unmarshal() localVariable
169 length, in unmarshal()
192 length: 7, in test_header_unmarshal()
206 length: 7, in test_header_unmarshal()
220 length: 0, in test_header_unmarshal()
261 length: 4, in test_header_roundtrip()
271 length: 65535, in test_header_roundtrip()
281 length: 0, in test_header_roundtrip()
|
| H A D | packet.rs | 85 let length = (h.length as usize) * 4; in unmarshaller() localVariable
86 if length > raw_data.remaining() { in unmarshaller()
90 let mut in_packet = h.marshal()?.chain(raw_data.take(length)); in unmarshaller()
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_header.rs | 13 pub(crate) length: u32, // uint24 in spec field
26 writer.write_u24::<BigEndian>(self.length)?; in marshal()
36 let length = reader.read_u24::<BigEndian>()?; in unmarshal() localVariable
43 length, in unmarshal()
|
| H A D | handshake_test.rs | 22 length: 0x29, in test_handshake_message()
|
| /webrtc/mdns/src/message/resource/ |
| H A D | mod.rs | 85 unpack_resource_body(self.header.typ, msg, off, self.header.length as usize)?; in unpack()
95 let (length, mut new_off) = unpack_uint16(msg, new_off)?; in skip()
96 new_off += length as usize; in skip()
128 pub length: u16, field
136 self.name, self.typ, self.class, self.ttl, self.length, in fmt()
156 msg = pack_uint16(msg, self.length); in pack()
168 self.length = l; in unpack()
189 self.length = con_len as u16; in fix_len()
247 fn unpack(&mut self, msg: &[u8], off: usize, length: usize) -> Result<usize>; in unpack()
254 length: usize, in unpack_resource_body()
[all …]
|
| H A D | txt.rs | 39 fn unpack(&mut self, msg: &[u8], mut off: usize, length: usize) -> Result<usize> { in unpack()
42 while n < length { in unpack()
46 if length < n + t.as_bytes().len() + 1 { in unpack()
|
| H A D | opt.rs | 61 fn unpack(&mut self, msg: &[u8], mut off: usize, length: usize) -> Result<usize> { in unpack()
64 while off < old_off + length { in unpack()
|
| /webrtc/util/src/ifaces/ffi/windows/ |
| H A D | mod.rs | 54 pub length: ULONG, field
110 pub length: ULONG, field
125 length: ULONG, field
133 length: ULONG, field
141 length: ULONG, field
149 length: ULONG, field
158 length: ULONG, field
166 length: ULONG, field
287 &mut length, in local_ifaces_with_buffer()
376 if unicast_addr.length != 0 { in is_ipv4_enabled()
[all …]
|
| /webrtc/sctp/src/queue/ |
| H A D | payload_queue.rs | 11 pub(crate) length: Arc<AtomicUsize>, field
19 pub(crate) fn new(length: Arc<AtomicUsize>) -> Self { in new()
20 length.store(0, Ordering::SeqCst); in new()
22 length, in new()
35 self.length.fetch_add(1, Ordering::SeqCst); in push_no_check()
80 self.length.fetch_sub(1, Ordering::SeqCst); in pop()
175 assert_eq!(self.chunk_map.len(), self.length.load(Ordering::SeqCst)); in len()
|
| /webrtc/dtls/src/fragment_buffer/ |
| H A D | mod.rs | 67 let mut end = HANDSHAKE_HEADER_LENGTH + handshake_header.length as usize; in push()
103 first_header.fragment_length = first_header.length; in pop()
144 if fragment_end != f.handshake_header.length in append_message()
|
| /webrtc/rtcp/src/payload_feedbacks/full_intra_request/ |
| H A D | mod.rs | 48 length: ((self.marshal_size() / 4) - 1) as u16, in header()
132 if raw_packet_len < (HEADER_LENGTH + (4 * h.length) as usize) { in unmarshal()
145 while i < HEADER_LENGTH + (h.length * 4) as usize { in unmarshal()
|
| /webrtc/rtcp/src/payload_feedbacks/slice_loss_indication/ |
| H A D | mod.rs | 56 length: ((self.marshal_size() / 4) - 1) as u16, in header()
140 if raw_packet_len < (HEADER_LENGTH + (4 * h.length as usize)) { in unmarshal()
153 while i < HEADER_LENGTH + h.length as usize * 4 { in unmarshal()
|
| /webrtc/mdns/src/message/ |
| H A D | parser.rs | 64 unpack_resource_body(header.typ, self.msg, self.off, header.length as usize)?; in resource()
89 let new_off = self.off + self.res_header.length as usize; in skip_resource()
340 self.res_header.length as usize, in resource_body()
342 self.off += self.res_header.length as usize; in resource_body()
|
| /webrtc/sctp/src/ |
| H A D | error_cause.rs | 115 let mut buf = BytesMut::with_capacity(self.length()); in marshal()
128 pub(crate) fn length(&self) -> usize { in length() method
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_nack/ |
| H A D | mod.rs | 132 length: ((self.marshal_size() / 4) - 1) as u16, in header()
213 if raw_packet_len < (HEADER_LENGTH + (4 * h.length) as usize) { in unmarshal()
225 for _i in 0..(h.length as i32 - NACK_OFFSET as i32 / 4) { in unmarshal()
|
| /webrtc/util/src/ |
| H A D | lib.rs | 30 length: usize, in export_keying_material()
|