| /webrtc/webrtc/src/rtp_transceiver/fmtp/h264/ |
| H A D | mod.rs | 55 let hpmode = match self.parameters.get("packetization-mode") { in match_fmtp() 59 let cpmode = match c.parameters.get("packetization-mode") { in match_fmtp() 69 let hplid = match self.parameters.get("profile-level-id") { in match_fmtp() 73 let cplid = match c.parameters.get("profile-level-id") { in match_fmtp() 89 self.parameters.get(key) in parameter()
|
| H A D | h264_test.rs | 143 consist_string.get(&consist), in test_h264_fmtp_compare() 144 consist_string.get(&c), in test_h264_fmtp_compare() 156 consist_string.get(&consist), in test_h264_fmtp_compare() 157 consist_string.get(&c), in test_h264_fmtp_compare()
|
| /webrtc/webrtc/src/rtp_transceiver/fmtp/generic/ |
| H A D | generic_test.rs | 129 consist_string.get(&consist), in test_generic_fmtp_compare() 130 consist_string.get(&c), in test_generic_fmtp_compare() 142 consist_string.get(&consist), in test_generic_fmtp_compare() 143 consist_string.get(&c), in test_generic_fmtp_compare()
|
| H A D | mod.rs | 10 if let Some(vb) = b.get(k) { in fmtp_consist() 17 if let Some(va) = a.get(k) { in fmtp_consist() 52 self.parameters.get(key) in parameter()
|
| /webrtc/turn/src/client/ |
| H A D | binding.rs | 88 self.addr_map.get(&addr.to_string()) in create() 92 self.addr_map.get(&addr.to_string()) in find_by_addr() 100 if let Some(s) = self.chan_map.get(&number) { in find_by_number() 101 self.addr_map.get(s) in find_by_number() 108 if let Some(s) = self.chan_map.get(&number) { in get_by_number()
|
| /webrtc/stun/src/attributes/ |
| H A D | attributes_test.rs | 14 let got_v = m.get(ATTR_DATA)?; in test_raw_attribute_add_to() 32 m.get(ATTR_SOFTWARE)?; in test_message_get_no_allocs() 36 let result = m.get(ATTR_ORIGIN); in test_message_get_no_allocs()
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_stream.rs | 50 fn get(&self, seq: u16) -> Option<&rtp::packet::Packet> { in get() method 82 pub(super) async fn get(&self, seq: u16) -> Option<rtp::packet::Packet> { in get() method 84 internal.get(seq).cloned() in get() 128 if let Some(packet) = sb.get(seq) { in test_responder_stream() 143 if let Some(packet) = sb.get(seq) { in test_responder_stream()
|
| /webrtc/util/src/vnet/ |
| H A D | conn_map.rs | 31 if let Some(conns) = port_map.get(&addr.port()) { in insert() 54 if let Some(conns) = port_map.get(&addr.port()) { in find() 83 if let Some(conns) = port_map.get(&addr.port()) { in delete()
|
| H A D | nat.rs | 141 return self.mapped_ips.get(i); in get_paired_mapped_ip() 150 return self.local_ips.get(i); in get_paired_local_ip() 370 if let Some(m) = outbound_map.get(o_key) { in find_outbound_mapping() 403 outbound_map.get(o_key).map(Arc::clone) in find_outbound_mapping() 411 if let Some(m) = inbound_map.get(i_key) { in find_inbound_mapping() 442 inbound_map.get(i_key).map(Arc::clone) in find_inbound_mapping()
|
| /webrtc/sctp/src/queue/ |
| H A D | pending_queue.rs | 170 return unordered_queue.get(0).cloned(); in peek() 173 return ordered_queue.get(0).cloned(); in peek() 179 unordered_queue.get(0).cloned() in peek() 187 ordered_queue.get(0).cloned() in peek()
|
| H A D | queue_test.rs | 150 let c = pq.get(1); in test_payload_queue_mark_all_to_retrasmit() 153 let c = pq.get(2); in test_payload_queue_mark_all_to_retrasmit() 156 let c = pq.get(3); in test_payload_queue_mark_all_to_retrasmit() 175 let c = pq.get(1); in test_payload_queue_reset_retransmit_flag_on_ack() 178 let c = pq.get(2); in test_payload_queue_reset_retransmit_flag_on_ack() 181 let c = pq.get(3); in test_payload_queue_reset_retransmit_flag_on_ack() 184 let c = pq.get(4); in test_payload_queue_reset_retransmit_flag_on_ack() 239 let c = pq.get(i); in test_pending_base_queue_push_and_pop() 265 assert!(pq.get(0).is_none(), "should be none"); in test_pending_base_queue_out_of_bounce() 268 assert!(pq.get(1).is_none(), "should be none"); in test_pending_base_queue_out_of_bounce()
|
| /webrtc/stun/src/textattrs/ |
| H A D | textattrs_test.rs | 24 let (s_attr, ok) = m.attributes.get(ATTR_SOFTWARE); in test_software_get_from() 179 let (r_attr, ok) = m.attributes.get(ATTR_REALM); in test_realm_get_from() 252 let (r_attr, ok) = m.attributes.get(ATTR_NONCE); in test_nonce_get_from() 303 let v = m.get(ATTR_NONCE)?; in test_nonce_add_to()
|
| /webrtc/turn/src/proto/ |
| H A D | dontfrag.rs | 22 let _ = m.get(ATTR_DONT_FRAGMENT)?; in get_from()
|
| H A D | data.rs | 30 self.0 = m.get(ATTR_DATA)?; in get_from()
|
| H A D | rsrvtoken.rs | 35 let v = m.get(ATTR_RESERVATION_TOKEN)?; in get_from()
|
| H A D | reqtrans.rs | 47 let v = m.get(ATTR_REQUESTED_TRANSPORT)?; in get_from()
|
| H A D | evenport.rs | 53 let v = m.get(ATTR_EVEN_PORT)?; in get_from()
|
| H A D | channum.rs | 48 let v = m.get(ATTR_CHANNEL_NUMBER)?; in get_from()
|
| /webrtc/ice/src/use_candidate/ |
| H A D | mod.rs | 28 let result = m.get(ATTR_USE_CANDIDATE); in is_set()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | mod.rs | 132 let (attr, found) = message.attributes.get(ATTR_USERNAME); in conn_from_stun_message() 155 .and_then(|ufrag| conns.get(ufrag)) in conn_from_stun_message() 181 address_map.get(&addr).map(Clone::clone) in start_conn_worker() 264 if let Some(conn) = conns.get(ufrag) { in get_conn()
|
| /webrtc/turn/src/allocation/ |
| H A D | mod.rs | 125 permissions.get(&addr2ipfingerprint(addr)).is_some() in has_permission() 134 if let Some(existed_permission) = permissions.get(&fingerprint) { in add_permission() 174 if let Some(cb) = channel_bindings.get(&c.number) { in add_channel_bind() 210 channel_bindings.get(number).map(|cb| cb.peer) in get_channel_addr() 412 ps.get(&addr2ipfingerprint(&src_addr)).is_some() in packet_handler()
|
| /webrtc/dtls/src/flight/ |
| H A D | flight3.rs | 63 if let Some(message) = msgs.get(&HandshakeType::HelloVerifyRequest) { in parse() 170 if let Some(message) = msgs.get(&HandshakeType::ServerHello) { in parse() 292 if let Some(message) = msgs.get(&HandshakeType::Certificate) { in parse() 308 if let Some(message) = msgs.get(&HandshakeType::ServerKeyExchange) { in parse() 327 if let Some(message) = msgs.get(&HandshakeType::CertificateRequest) { in parse()
|
| /webrtc/ice/src/priority/ |
| H A D | mod.rs | 27 let v = m.get(ATTR_PRIORITY)?; in get_from()
|
| /webrtc/stun/src/ |
| H A D | error_code.rs | 63 let v = m.get(ATTR_ERROR_CODE)?; in get_from() 87 if let Some(reason) = ERROR_REASONS.get(self) { in add_to()
|
| /webrtc/constraints/src/algorithms/fitness_distance/ |
| H A D | settings.rs | 21 let setting = settings.get(property); in fitness_distance()
|