Home
last modified time | relevance | path

Searched refs:m (Results 1 – 25 of 118) sorted by relevance

12345

/webrtc/stun/benches/
H A Dbench.rs40 m.reset(); in benchmark_addr()
51 m.reset(); in benchmark_addr()
122 m.reset(); in benchmark_error_code()
136 m.reset(); in benchmark_error_code()
171 m.raw.drain(m.length as usize + MESSAGE_HEADER_SIZE..); in benchmark_fingerprint()
172 m.attributes.0.drain(m.attributes.0.len() - 1..); in benchmark_fingerprint()
186 m.write_header(); in benchmark_fingerprint()
188 m.write_header(); in benchmark_fingerprint()
237 m.write_header(); in benchmark_message_integrity()
447 m.build(&[ in benchmark_message()
[all …]
/webrtc/stun/src/fingerprint/
H A Dfingerprint_test.rs8 let mut m = Message::new(); in fingerprint_uses_crc_32_iso_hdlc() localVariable
14 a.add_to(&mut m)?; in fingerprint_uses_crc_32_iso_hdlc()
15 m.write_header(); in fingerprint_uses_crc_32_iso_hdlc()
18 m.write_header(); in fingerprint_uses_crc_32_iso_hdlc()
22 assert_eq!(m.raw[m.raw.len() - 4..], [0xe4, 0x4c, 0x33, 0xd9]); in fingerprint_uses_crc_32_iso_hdlc()
34 a.add_to(&mut m)?; in test_fingerprint_check()
35 m.write_header(); in test_fingerprint_check()
38 m.write_header(); in test_fingerprint_check()
40 m.raw[3] += 1; in test_fingerprint_check()
55 a.add_to(&mut m)?; in test_fingerprint_check_bad()
[all …]
/webrtc/webrtc/src/api/media_engine/
H A Dmedia_engine_test.rs11 m.register_default_codecs()?; in test_opus_case()
234 m.register_codec( in test_media_engine_remote_description()
273 m.register_codec( in test_media_engine_remote_description()
289 assert!(m in test_media_engine_remote_description()
307 m.register_codec( in test_media_engine_remote_description()
340 m.register_codec( in test_media_engine_remote_description()
377 m.register_codec( in test_media_engine_remote_description()
603 m.register_codec( in test_media_engine_double_register()
618 m.register_codec( in test_media_engine_double_register()
658 m.register_codec( in test_update_header_extenstion_to_cloned_media_engine()
[all …]
/webrtc/stun/src/integrity/
H A Dintegrity_test.rs23 m.write_header(); in test_message_integrity_add_to_simple()
30 m.write_header(); in test_message_integrity_add_to_simple()
50 m.write_header(); in test_message_integrity_with_fingerprint()
55 a.add_to(&mut m)?; in test_message_integrity_with_fingerprint()
62 i.add_to(&mut m)?; in test_message_integrity_with_fingerprint()
64 i.check(&mut m)?; in test_message_integrity_with_fingerprint()
65 m.raw[24] = 33; in test_message_integrity_with_fingerprint()
66 m.decode()?; in test_message_integrity_with_fingerprint()
77 m.write_header(); in test_message_integrity()
78 i.add_to(&mut m)?; in test_message_integrity()
[all …]
/webrtc/ice/src/external_ip_mapper/
H A Dexternal_ip_mapper_test.rs23 assert!(m.is_none(), "should be none"); in test_external_ip_mapper_new_external_ip_mapper()
28 assert!(m.ipv4_mapping.ip_sole.is_some()); in test_external_ip_mapper_new_external_ip_mapper()
29 assert!(m.ipv6_mapping.ip_sole.is_none()); in test_external_ip_mapper_new_external_ip_mapper()
34 let m = in test_external_ip_mapper_new_external_ip_mapper() localVariable
38 m.candidate_type, in test_external_ip_mapper_new_external_ip_mapper()
41 assert!(m.ipv4_mapping.ip_sole.is_some()); in test_external_ip_mapper_new_external_ip_mapper()
42 assert!(m.ipv6_mapping.ip_sole.is_none()); in test_external_ip_mapper_new_external_ip_mapper()
50 assert!(m.ipv4_mapping.ip_sole.is_none()); in test_external_ip_mapper_new_external_ip_mapper()
56 let m = ExternalIpMapper::new( in test_external_ip_mapper_new_external_ip_mapper() localVariable
172 let m = ExternalIpMapper::new( in test_external_ip_mapper_find_external_ip_without_explicit_local_ip() localVariable
[all …]
/webrtc/stun/src/message/
H A Dmessage_test.rs18 m.write_header(); in test_message_buffer()
223 m.encode(); in test_message_attr_length_less_than_header()
560 assert!(m.raw.len() >= 20, "Bad length {}", m.raw.len()); in test_message_grow_smaller()
619 m.build(&[ in test_message_full_size()
631 m.raw = m.raw[..l - 10].to_vec(); in test_message_full_size()
645 m.build(&[ in test_message_clone_to()
656 m.encode(); in test_message_clone_to()
675 m.build(&[ in test_message_add_to()
680 m.encode(); in test_message_add_to()
720 m.build(&[ in test_message_marshal_binary()
[all …]
/webrtc/stun/src/textattrs/
H A Dtextattrs_test.rs9 let mut m = Message::new(); in test_software_get_from() localVariable
12 m.write_header(); in test_software_get_from()
69 let mut m = Message { in test_software_add_to_regression() localVariable
77 s.add_to(&mut m)?; in test_software_add_to_regression()
90 m.write_header(); in test_username()
109 u.add_to(&mut m)?; in test_username()
135 m.write_header(); in test_username()
142 m.reset(); in test_username()
153 m.write_header(); in test_realm_get_from()
226 m.write_header(); in test_nonce_get_from()
[all …]
/webrtc/turn/src/client/binding/
H A Dbinding_test.rs8 let mut m = BindingManager::new(); in test_binding_manager_number_assignment() localVariable
11 n = m.assign_channel_number(); in test_binding_manager_number_assignment()
15 m.next = 0x7ff0; in test_binding_manager_number_assignment()
17 n = m.assign_channel_number(); in test_binding_manager_number_assignment()
21 n = m.assign_channel_number(); in test_binding_manager_number_assignment()
31 let mut m = BindingManager::new(); in test_binding_manager_method() localVariable
35 let b = m.create(addr); in test_binding_manager_method()
38 let b1 = m.find_by_addr(&addr); in test_binding_manager_method()
73 let b = m.find_by_addr(&addr); in test_binding_manager_failure()
75 let b = m.find_by_number(5555); in test_binding_manager_failure()
[all …]
/webrtc/stun/src/xoraddr/
H A Dxoraddr_test.rs38 let mut m = Message::new(); in test_xormapped_address_get_from() localVariable
47 addr.get_from(&m)?; in test_xormapped_address_get_from()
82 m.add( in test_xormapped_address_get_from()
120 addr.add_to(&mut m)?; in test_xormapped_address_get_from_invalid()
121 m.write_header(); in test_xormapped_address_get_from_invalid()
125 m.decode()?; in test_xormapped_address_get_from_invalid()
145 addr.add_to(&mut m)?; in test_xormapped_address_add_to()
146 m.write_header(); in test_xormapped_address_add_to()
149 m_res.write(&m.raw)?; in test_xormapped_address_add_to()
177 addr.add_to(&mut m)?; in test_xormapped_address_add_to_ipv6()
[all …]
/webrtc/stun/src/
H A Dintegrity.rs40 fn add_to(&self, m: &mut Message) -> Result<()> { in add_to()
41 for a in &m.attributes.0 { in add_to()
51 let length = m.length; in add_to()
58 m.add(ATTR_MESSAGE_INTEGRITY, &v); in add_to()
88 let v = m.get(ATTR_MESSAGE_INTEGRITY)?; in check()
93 let length = m.length as usize; in check()
97 for a in &m.attributes.0 { in check()
106 m.length -= size_reduced as u32; in check()
107 m.write_length(); in check()
113 m.length = length as u32; in check()
[all …]
H A Dfingerprint.rs40 fn add_to(&self, m: &mut Message) -> Result<()> { in add_to()
41 let l = m.length; in add_to()
43 m.length += (FINGERPRINT_SIZE + ATTRIBUTE_HEADER_SIZE) as u32; // increasing length in add_to()
44 m.write_length(); // writing Length to Raw in add_to()
45 let val = fingerprint_value(&m.raw); in add_to()
47 m.length = l; in add_to()
48 m.add(ATTR_FINGERPRINT, &b); in add_to()
56 pub fn check(&self, m: &Message) -> Result<()> { in check()
57 let b = m.get(ATTR_FINGERPRINT)?; in check()
60 let attr_start = m.raw.len() - (FINGERPRINT_SIZE + ATTRIBUTE_HEADER_SIZE); in check()
[all …]
/webrtc/turn/src/proto/evenport/
H A Devenport_test.rs24 let mut m = Message::new(); in test_even_port_false() localVariable
28 p.add_to(&mut m)?; in test_even_port_false()
29 m.write_header(); in test_even_port_false()
33 decoded.write(&m.raw)?; in test_even_port_false()
34 port.get_from(&m)?; in test_even_port_false()
42 let mut m = Message::new(); in test_even_port_add_to() localVariable
44 p.add_to(&mut m)?; in test_even_port_add_to()
45 m.write_header(); in test_even_port_add_to()
49 decoded.write(&m.raw)?; in test_even_port_add_to()
56 let mut m = Message::new(); in test_even_port_add_to() localVariable
[all …]
/webrtc/ice/src/control/
H A Dmod.rs21 m.add(t, &v); in add_to_as()
27 let v = m.get(t)?; in get_from_as()
39 fn add_to(&self, m: &mut Message) -> Result<(), stun::Error> { in add_to()
40 TieBreaker(self.0).add_to_as(m, ATTR_ICE_CONTROLLED) in add_to()
48 t.get_from_as(m, ATTR_ICE_CONTROLLED)?; in get_from()
61 TieBreaker(self.0).add_to_as(m, ATTR_ICE_CONTROLLING) in add_to()
69 t.get_from_as(m, ATTR_ICE_CONTROLLING)?; in get_from()
86 self.tie_breaker.add_to_as(m, ATTR_ICE_CONTROLLING) in add_to()
88 self.tie_breaker.add_to_as(m, ATTR_ICE_CONTROLLED) in add_to()
96 if m.contains(ATTR_ICE_CONTROLLING) { in get_from()
[all …]
H A Dcontrol_test.rs6 let mut m = Message::new(); in test_controlled_get_from() localVariable
8 let result = c.get_from(&m); in test_controlled_get_from()
18 m1.write(&m.raw)?; in test_controlled_get_from()
43 let mut m = Message::new(); in test_controlling_get_from() localVariable
45 let result = c.get_from(&m); in test_controlling_get_from()
55 m1.write(&m.raw)?; in test_controlling_get_from()
82 let m = Message::new(); in test_control_get_from() localVariable
84 let result = c.get_from(&m); in test_control_get_from()
93 let mut m = Message::new(); in test_control_get_from() localVariable
108 m1.write(&m.raw)?; in test_control_get_from()
[all …]
/webrtc/turn/src/proto/reqfamily/
H A Dreqfamily_test.rs32 let mut m = Message::new(); in test_requested_address_family_add_to() localVariable
34 r.add_to(&mut m)?; in test_requested_address_family_add_to()
35 m.write_header(); in test_requested_address_family_add_to()
40 decoded.write(&m.raw)?; in test_requested_address_family_add_to()
47 let mut m = Message::new(); in test_requested_address_family_add_to() localVariable
49 if let Err(err) = handle.get_from(&m) { in test_requested_address_family_add_to()
58 m.add(ATTR_REQUESTED_ADDRESS_FAMILY, &[1, 2, 3]); in test_requested_address_family_add_to()
59 if let Err(err) = handle.get_from(&m) { in test_requested_address_family_add_to()
67 m.reset(); in test_requested_address_family_add_to()
68 m.add(ATTR_REQUESTED_ADDRESS_FAMILY, &[5, 0, 0, 0]); in test_requested_address_family_add_to()
[all …]
/webrtc/turn/benches/
H A Dbench.rs55 let mut m = Message::new(); in benchmark_chan() localVariable
60 m.reset(); in benchmark_chan()
66 let mut m = Message::new(); in benchmark_chan() localVariable
81 let mut m = Message::new(); in benchmark_data() localVariable
86 m.reset(); in benchmark_data()
92 let mut m = Message::new(); in benchmark_data() localVariable
96 m.add(ATTR_DATA, &d.0); in benchmark_data()
97 m.reset(); in benchmark_data()
105 let mut m = Message::new(); in benchmark_lifetime() localVariable
110 m.reset(); in benchmark_lifetime()
[all …]
/webrtc/turn/src/proto/dontfrag/
H A Ddontfrag_test.rs7 let mut m = Message::new(); in test_dont_fragment_false() localVariable
8 m.write_header(); in test_dont_fragment_false()
9 assert!(dont_fragment.get_from(&m).is_err(), "should not be set"); in test_dont_fragment_false()
18 let mut m = Message::new(); in test_dont_fragment_add_to() localVariable
19 dont_fragment.add_to(&mut m)?; in test_dont_fragment_add_to()
20 m.write_header(); in test_dont_fragment_add_to()
23 decoded.write(&m.raw)?; in test_dont_fragment_add_to()
24 assert!(dont_fragment.get_from(&m).is_ok(), "should be set"); in test_dont_fragment_add_to()
/webrtc/turn/src/proto/rsrvtoken/
H A Drsrvtoken_test.rs5 let mut m = Message::new(); in test_reservation_token() localVariable
10 tk.add_to(&mut m)?; in test_reservation_token()
11 m.write_header(); in test_reservation_token()
16 if let Err(err) = bad_tk.add_to(&mut m) { in test_reservation_token()
29 decoded.write(&m.raw)?; in test_reservation_token()
36 let mut m = Message::new(); in test_reservation_token() localVariable
38 if let Err(err) = handle.get_from(&m) { in test_reservation_token()
47 m.add(ATTR_RESERVATION_TOKEN, &[1, 2, 3]); in test_reservation_token()
48 if let Err(err) = handle.get_from(&m) { in test_reservation_token()
/webrtc/turn/src/proto/channum/
H A Dchannnum_test.rs39 let mut m = Message::new(); in test_channel_number_add_to() localVariable
41 n.add_to(&mut m)?; in test_channel_number_add_to()
42 m.write_header(); in test_channel_number_add_to()
47 decoded.write(&m.raw)?; in test_channel_number_add_to()
55 let mut m = Message::new(); in test_channel_number_add_to() localVariable
57 if let Err(err) = n_handle.get_from(&m) { in test_channel_number_add_to()
67 m.add(ATTR_CHANNEL_NUMBER, &[1, 2, 3]); in test_channel_number_add_to()
69 if let Err(err) = n_handle.get_from(&m) { in test_channel_number_add_to()
/webrtc/turn/src/proto/lifetime/
H A Dlifetime_test.rs13 let mut m = Message::new(); in test_lifetime_add_to() localVariable
15 l.add_to(&mut m)?; in test_lifetime_add_to()
16 m.write_header(); in test_lifetime_add_to()
21 decoded.write(&m.raw)?; in test_lifetime_add_to()
29 let mut m = Message::new(); in test_lifetime_add_to() localVariable
31 if let Err(err) = n_handle.get_from(&m) { in test_lifetime_add_to()
40 m.add(ATTR_LIFETIME, &[1, 2, 3]); in test_lifetime_add_to()
42 if let Err(err) = n_handle.get_from(&m) { in test_lifetime_add_to()
/webrtc/stun/src/addr/
H A Daddr_test.rs6 let mut m = Message::new(); in test_mapped_address() localVariable
15 addr.add_to(&mut m)?; in test_mapped_address()
20 got.get_from(&m)?; in test_mapped_address()
41 got.get_from(&m)? in test_mapped_address()
68 let mut m = Message::new(); in test_mapped_address_v6() localVariable
76 addr.add_to(&mut m)?; in test_mapped_address_v6()
81 got.get_from(&m)?; in test_mapped_address_v6()
115 addr.add_to(&mut m)?; in test_alternate_server()
120 got.get_from(&m)?; in test_alternate_server()
155 addr.add_to(&mut m)?; in test_other_address()
[all …]
/webrtc/turn/src/proto/reqtrans/
H A Dreqtrans_test.rs31 let mut m = Message::new(); in test_requested_transport_add_to() localVariable
35 r.add_to(&mut m)?; in test_requested_transport_add_to()
36 m.write_header(); in test_requested_transport_add_to()
41 decoded.write(&m.raw)?; in test_requested_transport_add_to()
50 let mut m = Message::new(); in test_requested_transport_add_to() localVariable
52 if let Err(err) = handle.get_from(&m) { in test_requested_transport_add_to()
62 m.add(ATTR_REQUESTED_TRANSPORT, &[1, 2, 3]); in test_requested_transport_add_to()
63 if let Err(err) = handle.get_from(&m) { in test_requested_transport_add_to()
/webrtc/turn/src/server/
H A Drequest.rs112 let mut m = Message { in handle_turn_packet() localVariable
116 m.decode()?; in handle_turn_packet()
123 match m.typ.method { in process_message_handler()
128 match m.typ.method { in process_message_handler()
143 m: &Message, in authenticate_request()
156 m.transaction_id, in authenticate_request()
232 m: &Message, in respond_with_nonce()
248 m.transaction_id, in respond_with_nonce()
269 m.transaction_id, in handle_binding_request()
315 m.transaction_id, in handle_allocate_request()
[all …]
/webrtc/turn/src/proto/data/
H A Ddata_test.rs5 let mut m = Message::new(); in test_data_add_to() localVariable
7 d.add_to(&mut m)?; in test_data_add_to()
8 m.write_header(); in test_data_add_to()
13 decoded.write(&m.raw)?; in test_data_add_to()
21 let m = Message::new(); in test_data_add_to() localVariable
23 if let Err(err) = handle.get_from(&m) { in test_data_add_to()
/webrtc/stun/src/attributes/
H A Dattributes_test.rs7 let mut m = Message::new(); in test_raw_attribute_add_to() localVariable
13 m.build(&[ra])?; in test_raw_attribute_add_to()
14 let got_v = m.get(ATTR_DATA)?; in test_raw_attribute_add_to()
22 let mut m = Message::new(); in test_message_get_no_allocs() localVariable
27 a.add_to(&mut m)?; in test_message_get_no_allocs()
28 m.write_header(); in test_message_get_no_allocs()
32 m.get(ATTR_SOFTWARE)?; in test_message_get_no_allocs()
36 let result = m.get(ATTR_ORIGIN); in test_message_get_no_allocs()

12345