Home
last modified time | relevance | path

Searched refs:len (Results 1 – 25 of 240) sorted by relevance

12345678910

/webrtc/util/src/marshal/
H A Dexact_size_buf.rs13 fn len(&self) -> usize; in len() method
21 self.len() == 0 in is_empty()
27 fn len(&self) -> usize { in len() method
28 Bytes::len(self) in len()
39 fn len(&self) -> usize { in len() method
40 BytesMut::len(self) in len()
51 fn len(&self) -> usize { in len() method
52 <[u8]>::len(self) in len()
66 fn len(&self) -> usize { in len() function
70 first_ref.len() + last_ref.len() in len()
[all …]
/webrtc/dtls/src/handshake/
H A Dhandshake_message_client_hello.rs40 && self.cipher_suites.len() == other.cipher_suites.len()) in eq()
81 let mut len = 0; in size() localVariable
83 len += 2; // version.major+minor in size()
84 len += self.random.size(); in size()
87 len += 1; in size()
89 len += 1 + self.cookie.len(); in size()
91 len += 2 + 2 * self.cipher_suites.len(); in size()
95 len += 2; in size()
97 len += extension.size(); in size()
100 len in size()
[all …]
H A Dhandshake_message_server_key_exchange.rs31 2 + self.identity_hint.len() in size()
33 1 + 2 + 1 + self.public_key.len() + 2 + 2 + self.signature.len() in size()
47 writer.write_u8(self.public_key.len() as u8)?; in marshal()
65 if data.len() == psk_length as usize + 2 { in unmarshal()
81 if data[1..].len() < 2 { in unmarshal()
86 if data.len() < 4 { in unmarshal()
92 if data.len() < offset { in unmarshal()
96 if data.len() <= offset { in unmarshal()
102 if data.len() <= offset { in unmarshal()
108 if data.len() < offset + 2 { in unmarshal()
[all …]
H A Dhandshake_message_certificate.rs22 let mut len = 3; in size() localVariable
25 len += HANDSHAKE_MESSAGE_CERTIFICATE_LENGTH_FIELD_SIZE + r.len(); in size()
28 len in size()
34 payload_size += HANDSHAKE_MESSAGE_CERTIFICATE_LENGTH_FIELD_SIZE + r.len(); in marshal()
42 writer.write_u24::<BigEndian>(r.len() as u32)?; in marshal()
H A Dhandshake_message_client_key_exchange.rs22 1 + self.public_key.len() in size()
24 2 + self.identity_hint.len() in size()
36 writer.write_u8(self.public_key.len() as u8)?; in marshal()
39 writer.write_u16::<BigEndian>(self.identity_hint.len() as u16)?; in marshal()
52 if data.len() == psk_length as usize + 2 { in unmarshal()
60 if data.len() != public_key_length + 1 { in unmarshal()
H A Dhandshake_message_server_hello.rs60 let mut len = 2 + self.random.size(); in size() localVariable
63 len += 1; in size()
65 len += 2; in size()
67 len += 1; in size()
69 len += 2; in size()
71 len += extension.size(); in size()
74 len in size()
97 writer.write_u16::<BigEndian>(extension_buffer.len() as u16)?; in marshal()
/webrtc/util/src/buffer/
H A Dmod.rs46 2 * self.data.len() in grow()
48 5 * self.data.len() / 4 in grow()
63 if newsize <= self.data.len() { in grow()
127 if packet.len() >= 0x10000 { in write()
144 while !b.available(packet.len()) { in write()
152 if b.tail >= b.data.len() { in write()
159 if b.tail >= b.data.len() { in write()
164 let end = std::cmp::min(b.data.len(), b.tail + packet.len()); in write()
169 if b.tail >= b.data.len() { in write()
171 let m = packet.len() - n; in write()
[all …]
/webrtc/util/src/conn/
H A Dconn_bridge_test.rs17 assert_eq!(n, MSG1.len(), "unexpected length"); in test_bridge_normal()
31 assert_eq!(n, MSG1.len(), "unexpected length"); in test_bridge_normal()
41 assert_eq!(n, MSG1.len(), "unexpected length"); in test_bridge_drop_1st_packet_from_conn0()
43 assert_eq!(n, MSG2.len(), "unexpected length"); in test_bridge_drop_1st_packet_from_conn0()
58 assert_eq!(n, MSG2.len(), "unexpected length"); in test_bridge_drop_1st_packet_from_conn0()
68 assert_eq!(n, MSG1.len(), "unexpected length"); in test_bridge_drop_2nd_packet_from_conn0()
70 assert_eq!(n, MSG2.len(), "unexpected length"); in test_bridge_drop_2nd_packet_from_conn0()
85 assert_eq!(n, MSG1.len(), "unexpected length"); in test_bridge_drop_2nd_packet_from_conn0()
95 assert_eq!(n, MSG1.len(), "unexpected length"); in test_bridge_drop_1st_packet_from_conn1()
97 assert_eq!(n, MSG2.len(), "unexpected length"); in test_bridge_drop_1st_packet_from_conn1()
[all …]
/webrtc/sctp/src/
H A Derror_cause.rs91 if buf.len() < ERROR_CAUSE_HEADER_LENGTH { in unmarshal()
98 let len = reader.get_u16(); in unmarshal() localVariable
100 if len < ERROR_CAUSE_HEADER_LENGTH as u16 { in unmarshal()
103 if buf.len() < len as usize { in unmarshal()
107 let value_length = len as usize - ERROR_CAUSE_HEADER_LENGTH; in unmarshal()
121 let len = self.raw.len() + ERROR_CAUSE_HEADER_LENGTH; in marshal_to() localVariable
123 writer.put_u16(len as u16); in marshal_to()
125 writer.len() in marshal_to()
129 self.raw.len() + ERROR_CAUSE_HEADER_LENGTH in length()
/webrtc/media/src/audio/buffer/
H A Dlayout.rs47 assert_eq!(input.len(), output.len()); in deinterleaved_by()
48 assert_eq!(input.len() % channels, 0); in deinterleaved_by()
50 let frames = input.len() / channels; in deinterleaved_by()
77 assert_eq!(input.len(), output.len()); in interleaved_by()
78 assert_eq!(input.len() % channels, 0); in interleaved_by()
80 let frames = input.len() / channels; in interleaved_by()
99 let mut output = vec![0; input.len()]; in interleaved_1_channel()
113 let mut output = vec![0; input.len()]; in deinterleaved_1_channel()
127 let mut output = vec![0; input.len()]; in interleaved_2_channel()
141 let mut output = vec![0; input.len()]; in deinterleaved_2_channel()
[all …]
/webrtc/sctp/src/param/
H A Dparam_header.rs27 if raw.len() < PARAM_HEADER_LENGTH { in unmarshal()
35 let len = reader.get_u16() as usize; in unmarshal() localVariable
36 if len < PARAM_HEADER_LENGTH || raw.len() < len { in unmarshal()
42 value_length: (len - PARAM_HEADER_LENGTH) as u16, in unmarshal()
49 Ok(writer.len()) in marshal_to()
/webrtc/turn/src/proto/
H A Dchandata.rs50 let padded = nearest_padded_value_length(self.raw.len()); in encode()
51 let bytes_to_add = padded - self.raw.len(); in encode()
60 if buf.len() < CHANNEL_DATA_HEADER_SIZE { in decode()
72 if l > buf[CHANNEL_DATA_HEADER_SIZE..].len() { in decode()
82 if self.raw.len() < CHANNEL_DATA_HEADER_SIZE { in write_header()
86 .resize(self.raw.len() + CHANNEL_DATA_HEADER_SIZE, 0); in write_header()
90 .copy_from_slice(&(self.data.len() as u16).to_be_bytes()); in write_header()
95 if buf.len() < CHANNEL_DATA_HEADER_SIZE { in is_channel_data()
102 ]) > buf[CHANNEL_DATA_HEADER_SIZE..].len() as u16 in is_channel_data()
/webrtc/media/src/audio/
H A Dbuffer.rs50 let frames = samples.len() / channels; in new()
68 let frames = samples.len() / channels; in new()
82 let samples_len = range.len(); in sub_range()
187 assert_eq!(bytes.len() % STRIDE, 0); in from_bytes()
210 assert_eq!(bytes.len() % STRIDE, 0); in from_bytes()
227 init_vec(chunks.len(), |samples| { in from_bytes()
247 assert_eq!(bytes.len() % STRIDE, 0); in from_bytes()
270 assert_eq!(bytes.len() % STRIDE, 0); in from_bytes()
287 init_vec(chunks.len(), |samples| { in from_bytes()
323 let len = manually_drop.len(); in init_vec() localVariable
[all …]
/webrtc/mdns/src/message/
H A Dname.rs24 if data.len() > NAME_LEN { in new()
49 if data.is_empty() || data[data.len() - 1] != b'.' { in pack()
54 if data.len() == 1 && data[0] == b'.' { in pack()
61 for i in 0..data.len() { in pack()
99 if msg.len() <= 0x3FFF { in pack()
136 if curr_off >= msg.len() { in unpack_compressed()
149 if end_off > msg.len() { in unpack_compressed()
161 if curr_off >= msg.len() { in unpack_compressed()
185 if name.len() > NAME_LEN { in unpack_compressed()
202 if new_off >= msg.len() { in skip()
[all …]
H A Dpacker.rs11 let new_off = off + field.len(); in unpack_bytes()
12 if new_off > msg.len() { in unpack_bytes()
26 if off + UINT16LEN > msg.len() { in unpack_uint16()
37 if off + UINT16LEN > msg.len() { in skip_uint16()
50 if off + UINT32LEN > msg.len() { in unpack_uint32()
61 if off + UINT32LEN > msg.len() { in skip_uint32()
69 let l = field.len(); in pack_str()
79 if off >= msg.len() { in unpack_str()
84 if end_off > msg.len() { in unpack_str()
/webrtc/srtp/src/cipher/
H A Dcipher_aes_cm_hmac_sha1.rs38 master_key.len(), in new()
45 master_key.len(), in new()
53 master_salt.len(), in new()
60 master_salt.len(), in new()
209 if encrypted.len() < self.auth_tag_len() { in decrypt_rtp()
216 let actual_tag = &encrypted[encrypted.len() - self.auth_tag_len()..]; in decrypt_rtp()
217 let cipher_text = &encrypted[..encrypted.len() - self.auth_tag_len()]; in decrypt_rtp()
283 if encrypted.len() < self.auth_tag_len() + SRTCP_INDEX_SIZE { in decrypt_rtcp()
285 encrypted.len(), in decrypt_rtcp()
302 let actual_tag = &encrypted[encrypted.len() - self.auth_tag_len()..]; in decrypt_rtcp()
[all …]
H A Dcipher_aead_aes_gcm.rs65 if ciphertext.len() < self.auth_tag_len() { in decrypt_rtp()
79 let mut writer = BytesMut::with_capacity(payload_offset + decrypted_msg.len()); in decrypt_rtp()
98 let mut writer = BytesMut::with_capacity(encrypted_data.len() + aad.len()); in encrypt_rtcp()
107 if encrypted.len() < self.auth_tag_len() + SRTCP_INDEX_SIZE { in decrypt_rtcp()
117 msg: &encrypted[8..(encrypted.len() - SRTCP_INDEX_SIZE)], in decrypt_rtcp()
122 let mut writer = BytesMut::with_capacity(8 + decrypted_data.len()); in decrypt_rtcp()
130 let pos = input.len() - 4; in get_rtcp_index()
145 master_key.len(), in new()
157 master_key.len(), in new()
169 master_key.len(), in new()
[all …]
/webrtc/rtp/src/
H A Dheader.rs141 curr_offset += len; in unmarshal()
158 let len = raw_packet.get_u8() as usize; in unmarshal() localVariable
165 curr_offset += len; in unmarshal()
204 let mut head_size = 12 + (self.csrc.len() * CSRC_LENGTH); in marshal_size()
295 if self.extensions.len() != 1 { in marshal_to()
300 let ext_len = extension.payload.len(); in marshal_to()
325 .map(|extension| extension.payload.len()) in get_extension_payload_len()
328 let profile_len = self.extensions.len() in get_extension_payload_len()
346 if payload.len() > 16 { in set_extension()
354 if payload.len() > 255 { in set_extension()
[all …]
/webrtc/rtp/src/codecs/h264/
H A Dmod.rs73 let sps_len = (sps_nalu.len() as u16).to_be_bytes(); in emit()
74 let pps_len = (pps_nalu.len() as u16).to_be_bytes(); in emit()
76 let mut stap_a_nalu = Vec::with_capacity(1 + 2 + sps_nalu.len() + 2 + pps_nalu.len()); in emit()
82 if stap_a_nalu.len() <= mtu { in emit()
93 if nalu.len() <= mtu { in emit()
211 if packet.len() <= 2 { in depacketize()
225 payload.put_u32(packet.len() as u32); in depacketize()
234 while curr_offset < packet.len() { in depacketize()
242 packet.len() - curr_offset, in depacketize()
258 if packet.len() < FUA_HEADER_SIZE { in depacketize()
[all …]
/webrtc/dtls/src/crypto/
H A Dcrypto_gcm.rs64 let additional_data = generate_aead_additional_data(pkt_rlh, payload.len()); in encrypt()
73 let mut r = Vec::with_capacity(raw.len() + nonce.len() + buffer.len()); in encrypt()
79 let r_len = (r.len() - RECORD_LAYER_HEADER_SIZE) as u16; in encrypt()
94 if r.len() <= (RECORD_LAYER_HEADER_SIZE + 8) { in decrypt()
105 let additional_data = generate_aead_additional_data(&h, out.len() - CRYPTO_GCM_TAG_LENGTH); in decrypt()
114 let mut d = Vec::with_capacity(RECORD_LAYER_HEADER_SIZE + buffer.len()); in decrypt()
/webrtc/sctp/src/chunk/
H A Dchunk_heartbeat_ack.rs63 if raw.len() <= CHUNK_HEADER_SIZE { in unmarshal()
78 if self.params.len() != 1 { in marshal_to()
88 let pp_len = pp.len(); in marshal_to()
98 if idx != self.params.len() - 1 { in marshal_to()
103 Ok(buf.len()) in marshal_to()
115 if idx != self.params.len() - 1 { in value_length()
/webrtc/rtp/src/packet/
H A Dmod.rs28 out += format!("\tPayload Length: {}\n", self.payload.len()).as_str(); in fmt()
67 let payload_len = self.payload.len(); in marshal_size()
93 let mut padding_len = get_padding(self.payload.len()); in marshal_to()
109 Ok(n + self.payload.len() + padding_len) in marshal_to()
114 fn get_padding(len: usize) -> usize { in get_padding()
115 if len % 4 == 0 { in get_padding()
118 4 - (len % 4) in get_padding()
/webrtc/rtp/src/packetizer/
H A Dpacketizer_test.rs18 if packets.len() != 2 { in test_packetizer()
21 for i in 0..packets.len() { in test_packetizer()
23 format!("Packet {} length {}\n", i, packets[i].payload.len()).as_str(); in test_packetizer()
27 packets.len(), in test_packetizer()
84 if packets.len() != 1 { in test_packetizer_abs_send_time()
85 panic!("Generated {} packets instead of 1", packets.len()) in test_packetizer_abs_send_time()
/webrtc/sctp/src/association/
H A Dassociation_test.rs207 if n != hello_msg.len() { in establish_session_pair()
314 for i in 0..sbuf.len() { in test_assoc_reliable_ordered_reordered()
318 for i in 0..sbufl.len() { in test_assoc_reliable_ordered_reordered()
409 for i in 0..sbuf.len() { in test_assoc_reliable_ordered_fragmented_then_defragmented()
413 for i in 0..sbufl.len() { in test_assoc_reliable_ordered_fragmented_then_defragmented()
476 for i in 0..sbuf.len() { in test_assoc_reliable_unordered_fragmented_then_defragmented()
543 for i in 0..sbuf.len() { in test_assoc_reliable_unordered_ordered()
788 for i in 0..sbuf.len() { in test_assoc_unreliable_rexmit_ordered_no_fragment()
873 for i in 0..sbuf.len() { in test_assoc_unreliable_rexmit_ordered_fragment()
2153 let l = std::cmp::min(v.len(), b.len()); in recv()
[all …]
/webrtc/rtp/src/codecs/g7xx/
H A Dg7xx_test.rs24 payloads.len(), in test_g7xx_payload()
26 payloads.len(), in test_g7xx_payload()
43 assert_eq!(result.len(), 0, "Generated payload should be empty"); in test_g7xx_payload()
47 assert_eq!(result.len(), 1, "Generated payload should be the 1"); in test_g7xx_payload()

12345678910