Home
last modified time | relevance | path

Searched refs:v (Results 1 – 25 of 112) sorted by relevance

12345

/webrtc/ice/src/priority/
H A Dmod.rs17 let mut v = vec![0_u8; PRIORITY_SIZE]; in add_to() localVariable
18 v.copy_from_slice(&self.0.to_be_bytes()); in add_to()
19 m.add(ATTR_PRIORITY, &v); in add_to()
27 let v = m.get(ATTR_PRIORITY)?; in get_from() localVariable
29 check_size(ATTR_PRIORITY, v.len(), PRIORITY_SIZE)?; in get_from()
31 let p = u32::from_be_bytes([v[0], v[1], v[2], v[3]]); in get_from()
/webrtc/turn/src/proto/
H A Dlifetime.rs39 let mut v = vec![0; LIFETIME_SIZE]; in add_to() localVariable
40 v.copy_from_slice(&(self.0.as_secs() as u32).to_be_bytes()); in add_to()
41 m.add(ATTR_LIFETIME, &v); in add_to()
49 let v = m.get(ATTR_LIFETIME)?; in get_from() localVariable
51 check_size(ATTR_LIFETIME, v.len(), LIFETIME_SIZE)?; in get_from()
53 let seconds = u32::from_be_bytes([v[0], v[1], v[2], v[3]]); in get_from()
H A Dreqfamily.rs35 let mut v = vec![0; REQUESTED_FAMILY_SIZE]; in add_to() localVariable
36 v[0] = self.0; in add_to()
40 m.add(ATTR_REQUESTED_ADDRESS_FAMILY, &v); in add_to()
48 let v = m.get(ATTR_REQUESTED_ADDRESS_FAMILY)?; in get_from() localVariable
51 v.len(), in get_from()
55 if v[0] != REQUESTED_FAMILY_IPV4.0 && v[0] != REQUESTED_FAMILY_IPV6.0 { in get_from()
58 self.0 = v[0]; in get_from()
H A Dchannum.rs37 let mut v = vec![0; CHANNEL_NUMBER_SIZE]; in add_to() localVariable
38 v[..2].copy_from_slice(&self.0.to_be_bytes()); in add_to()
40 m.add(ATTR_CHANNEL_NUMBER, &v); in add_to()
48 let v = m.get(ATTR_CHANNEL_NUMBER)?; in get_from() localVariable
50 check_size(ATTR_CHANNEL_NUMBER, v.len(), CHANNEL_NUMBER_SIZE)?; in get_from()
53 self.0 = u16::from_be_bytes([v[0], v[1]]); in get_from()
H A Dreqtrans.rs34 let mut v = vec![0; REQUESTED_TRANSPORT_SIZE]; in add_to() localVariable
35 v[0] = self.protocol.0; in add_to()
39 m.add(ATTR_REQUESTED_TRANSPORT, &v); in add_to()
47 let v = m.get(ATTR_REQUESTED_TRANSPORT)?; in get_from() localVariable
49 check_size(ATTR_REQUESTED_TRANSPORT, v.len(), REQUESTED_TRANSPORT_SIZE)?; in get_from()
50 self.protocol = Protocol(v[0]); in get_from()
H A Devenport.rs40 let mut v = vec![0; EVEN_PORT_SIZE]; in add_to() localVariable
43 v[0] = FIRST_BIT_SET; in add_to()
45 m.add(ATTR_EVEN_PORT, &v); in add_to()
53 let v = m.get(ATTR_EVEN_PORT)?; in get_from() localVariable
55 check_size(ATTR_EVEN_PORT, v.len(), EVEN_PORT_SIZE)?; in get_from()
57 if v[0] & FIRST_BIT_SET > 0 { in get_from()
H A Drsrvtoken.rs35 let v = m.get(ATTR_RESERVATION_TOKEN)?; in get_from() localVariable
36 check_size(ATTR_RESERVATION_TOKEN, v.len(), RESERVATION_TOKEN_SIZE)?; in get_from()
37 self.0 = v; in get_from()
/webrtc/stun/src/
H A Duattrs.rs35 let mut v = Vec::with_capacity(ATTR_TYPE_SIZE * 20); // 20 should be enough in add_to() localVariable
38 v.extend_from_slice(&t.value().to_be_bytes()); in add_to()
40 m.add(ATTR_UNKNOWN_ATTRIBUTES, &v); in add_to()
48 let v = m.get(ATTR_UNKNOWN_ATTRIBUTES)?; in get_from() localVariable
49 if v.len() % ATTR_TYPE_SIZE != 0 { in get_from()
54 while first < v.len() { in get_from()
57 .push(AttrType(u16::from_be_bytes([v[first], v[first + 1]]))); in get_from()
H A Daddr.rs67 let v = m.get(t)?; in get_from_as() localVariable
68 if v.len() <= 4 { in get_from_as()
72 let family = u16::from_be_bytes([v[0], v[1]]); in get_from_as()
76 self.port = u16::from_be_bytes([v[2], v[3]]); in get_from_as()
80 let l = std::cmp::min(ip.len(), v[4..].len()); in get_from_as()
81 ip[..l].copy_from_slice(&v[4..4 + l]); in get_from_as()
85 let l = std::cmp::min(ip.len(), v[4..].len()); in get_from_as()
86 ip[..l].copy_from_slice(&v[4..4 + l]); in get_from_as()
H A Dxoraddr.rs138 let v = m.get(t)?; in get_from_as() localVariable
139 if v.len() <= 4 { in get_from_as()
143 let family = u16::from_be_bytes([v[0], v[1]]); in get_from_as()
150 v[4..].len(), in get_from_as()
157 self.port = u16::from_be_bytes([v[2], v[3]]) ^ (MAGIC_COOKIE >> 16) as u16; in get_from_as()
164 xor_bytes(&mut ip, &v[4..], &xor_value); in get_from_as()
168 xor_bytes(&mut ip, &v[4..], &xor_value); in get_from_as()
H A Derror_code.rs63 let v = m.get(ATTR_ERROR_CODE)?; in get_from() localVariable
65 if v.len() < ERROR_CODE_REASON_START { in get_from()
69 let class = v[ERROR_CODE_CLASS_BYTE] as u16; in get_from()
70 let number = v[ERROR_CODE_NUMBER_BYTE] as u16; in get_from()
73 self.reason = v[ERROR_CODE_REASON_START..].to_vec(); in get_from()
H A Dintegrity.rs55 let v = new_hmac(&self.0, &m.raw); // calculating HMAC for adjusted m.Raw in add_to() localVariable
58 m.add(ATTR_MESSAGE_INTEGRITY, &v); in add_to()
88 let v = m.get(ATTR_MESSAGE_INTEGRITY)?; in check() localVariable
115 check_hmac(&v, &expected) in check()
/webrtc/ice/src/control/
H A Dmod.rs19 let mut v = vec![0; TIE_BREAKER_SIZE]; in add_to_as() localVariable
20 v.copy_from_slice(&self.0.to_be_bytes()); in add_to_as()
21 m.add(t, &v); in add_to_as()
27 let v = m.get(t)?; in get_from_as() localVariable
28 check_size(t, v.len(), TIE_BREAKER_SIZE)?; in get_from_as()
29 self.0 = u64::from_be_bytes([v[0], v[1], v[2], v[3], v[4], v[5], v[6], v[7]]); in get_from_as()
/webrtc/dtls/src/handshake/
H A Dhandshake_message_certificate_request.rs37 for v in &self.certificate_types { in marshal()
38 writer.write_u8(*v as u8)?; in marshal()
42 for v in &self.signature_hash_algorithms { in marshal()
43 writer.write_u8(v.hash as u8)?; in marshal()
44 writer.write_u8(v.signature as u8)?; in marshal()
/webrtc/turn/src/proto/rsrvtoken/
H A Drsrvtoken_test.rs6 let mut v = vec![0; 8]; in test_reservation_token() localVariable
7 v[2] = 33; in test_reservation_token()
8 v[7] = 1; in test_reservation_token()
9 let tk = ReservationToken(v); in test_reservation_token()
/webrtc/stun/src/textattrs/
H A Dtextattrs_test.rs10 let v = "Client v0.0.1".to_owned(); in test_software_get_from() localVariable
11 m.add(ATTR_SOFTWARE, v.as_bytes()); in test_software_get_from()
22 assert_eq!(software.to_string(), v, "Expected {v}, got {software}."); in test_software_get_from()
151 let v = "realm".to_owned(); in test_realm_get_from() localVariable
152 m.add(ATTR_REALM, v.as_bytes()); in test_realm_get_from()
177 assert_eq!(r.to_string(), v, "Expected {v}, got {r}."); in test_realm_get_from()
224 let v = "example.org".to_owned(); in test_nonce_get_from() localVariable
225 m.add(ATTR_NONCE, v.as_bytes()); in test_nonce_get_from()
250 assert_eq!(r.to_string(), v, "Expected {v}, got {r}."); in test_nonce_get_from()
303 let v = m.get(ATTR_NONCE)?; in test_nonce_add_to() localVariable
[all …]
/webrtc/webrtc/src/rtp_transceiver/fmtp/generic/
H A Dmod.rs9 for (k, v) in a { in fmtp_consist()
11 if vb.to_uppercase() != v.to_uppercase() { in fmtp_consist()
16 for (k, v) in b { in fmtp_consist()
18 if va.to_uppercase() != v.to_uppercase() { in fmtp_consist()
/webrtc/ice/src/state/
H A Dmod.rs56 fn from(v: u8) -> Self { in from()
57 match v { in from()
86 fn from(v: u8) -> Self { in from()
87 match v { in from()
/webrtc/media/src/io/ogg_reader/
H A Dmod.rs141 for (index, v) in h.iter().enumerate() { in parse_next_page()
147 sum = self.update_checksum(*v, sum); in parse_next_page()
150 for v in &size_buffer { in parse_next_page()
151 sum = self.update_checksum(*v, sum); in parse_next_page()
153 for v in &payload[..] { in parse_next_page()
154 sum = self.update_checksum(*v, sum); in parse_next_page()
182 fn update_checksum(&self, v: u8, sum: u32) -> u32 { in update_checksum()
183 (sum << 8) ^ self.checksum_table[(((sum >> 24) as u8) ^ v) as usize] in update_checksum()
/webrtc/mdns/src/message/
H A Dmod.rs51 fn from(v: u16) -> Self { in from()
52 match v { in from()
179 fn from(v: u8) -> Self { in from()
180 match v { in from()
249 let v: Vec<String> = self.questions.iter().map(|q| q.to_string()).collect(); in fmt() localVariable
250 s += &v.join(", "); in fmt()
253 let v: Vec<String> = self.answers.iter().map(|q| q.to_string()).collect(); in fmt() localVariable
254 s += &v.join(", "); in fmt()
257 let v: Vec<String> = self.authorities.iter().map(|q| q.to_string()).collect(); in fmt() localVariable
258 s += &v.join(", "); in fmt()
[all …]
/webrtc/util/src/conn/
H A Dconn_pipe.rs37 let v = match rd_rx.recv().await { in recv() localVariable
38 Some(v) => v, in recv()
41 let l = std::cmp::min(v.len(), b.len()); in recv()
42 b[..l].copy_from_slice(&v[..l]); in recv()
/webrtc/dtls/src/extension/
H A Dextension_supported_signature_algorithms.rs27 for v in &self.signature_hash_algorithms { in marshal()
28 writer.write_u8(v.hash as u8)?; in marshal()
29 writer.write_u8(v.signature as u8)?; in marshal()
/webrtc/webrtc/src/track/track_local/
H A Dtrack_local_static_test.rs145 if let Some(v) = vp8writer.as_any().downcast_ref::<TrackLocalStaticRTP>() { in test_track_local_static_closed()
146 let bindings = v.bindings.lock().await; in test_track_local_static_closed()
158 if let Some(v) = vp8writer.as_any().downcast_ref::<TrackLocalStaticRTP>() { in test_track_local_static_closed()
159 let bindings = v.bindings.lock().await; in test_track_local_static_closed()
167 if let Some(v) = vp8writer.as_any().downcast_ref::<TrackLocalStaticRTP>() { in test_track_local_static_closed()
168 let bindings = v.bindings.lock().await; in test_track_local_static_closed()
332 if let Some(v) = vp8writer.as_any().downcast_ref::<TrackLocalStaticRTP>() { in test_track_local_static_mutate_input()
333 v.write_rtp(&pkt).await?; in test_track_local_static_mutate_input()
395 if let Some(v) = vp8writer.as_any().downcast_ref::<TrackLocalStaticRTP>() { in test_track_local_static_binding_non_blocking()
396 v.write(&[0u8; 20]).await?; in test_track_local_static_binding_non_blocking()
/webrtc/stun/src/attributes/
H A Dattributes_test.rs6 let v = vec![1, 2, 3, 4]; in test_raw_attribute_add_to() localVariable
10 value: v.clone(), in test_raw_attribute_add_to()
15 assert_eq!(got_v, v, "value mismatch"); in test_raw_attribute_add_to()
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_state.rs61 fn from(v: u8) -> Self { in from()
62 match v { in from()
101 fn from(v: u8) -> Self { in from()
102 match v { in from()

12345