| /webrtc/util/src/vnet/conn_map/ |
| H A D | conn_map_test.rs | 38 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_insert_remove()
77 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_insert_0_remove()
116 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_find_0()
151 conn_map.insert(Arc::clone(&conn_in1)).await?; in test_udp_conn_map_insert_many_ips_with_same_port()
152 conn_map.insert(Arc::clone(&conn_in2)).await?; in test_udp_conn_map_insert_many_ips_with_same_port()
197 conn_map.insert(Arc::clone(&conn_in1)).await?; in test_udp_conn_map_already_inuse_when_insert_0()
222 conn_map.insert(Arc::clone(&conn_in1)).await?; in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
247 conn_map.insert(Arc::clone(&conn_in1)).await?; in test_udp_conn_map_already_inuse_when_insert_same_specified_ip()
267 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_find_failure_1()
289 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_find_failure_2()
[all …]
|
| /webrtc/webrtc/src/stats/ |
| H A D | stats_collector.rs | 19 pub(crate) fn insert(&self, id: String, stats: StatsReportType) { in insert() method
21 reports.insert(id, stats); in insert()
|
| /webrtc/util/src/vnet/ |
| H A D | conn_map.rs | 27 pub(crate) async fn insert(&self, conn: Arc<UdpConn>) -> Result<()> { in insert() method
47 port_map.insert(addr.port(), vec![conn]); in insert()
105 port_map.insert(addr.port(), new_conns); in delete()
|
| H A D | nat.rs | 210 filters.insert(filter_key); in translate_outbound()
240 outbound_map.insert(o_key.clone(), Arc::new(m.clone())); in translate_outbound()
260 filters.insert(filter_key); in translate_outbound()
266 inbound_map.insert(i_key, Arc::new(m)); in translate_outbound()
|
| H A D | resolver.rs | 42 self.hosts.insert(name, ip); in add_host()
|
| /webrtc/turn/src/client/ |
| H A D | permission.rs | 50 pub(crate) fn insert(&mut self, addr: &SocketAddr, p: Arc<Permission>) { in insert() method
51 self.perm_map.insert(addr.ip().to_string(), p); in insert()
|
| H A D | binding.rs | 86 self.chan_map.insert(b.number, b.addr.to_string()); in create()
87 self.addr_map.insert(b.addr.to_string(), b); in create()
|
| H A D | transaction.rs | 248 pub fn insert(&mut self, key: String, tr: Transaction) -> bool { in insert() method
249 self.tr_map.insert(key, tr); in insert()
|
| /webrtc/turn/src/allocation/ |
| H A D | allocation_manager.rs | 60 infos.insert( in get_allocations_info()
119 allocations.insert(five_tuple, Arc::clone(&a)); in create_allocation()
182 reservations.insert(reservation_token, port); in create_reservation()
|
| /webrtc/constraints/src/algorithms/fitness_distance/ |
| H A D | settings.rs | 36 setting_errors.insert(property, error); in fitness_distance()
|
| /webrtc/constraints/src/ |
| H A D | supported_constraints.rs | 138 set.insert(key); in visit_map()
194 subject.insert(DEVICE_ID.clone()); in deref_and_deref_mut()
|
| /webrtc/webrtc/src/rtp_transceiver/fmtp/ |
| H A D | mod.rs | 46 parameters.insert(key, value); in parse()
|
| /webrtc/stun/src/ |
| H A D | client.rs | 249 fn insert(&mut self, ct: ClientTransaction) -> Result<()> { in insert() method
296 t.insert(ct.id, ct); in start()
326 t.insert(ct.id, ct); in start()
447 self.insert(t)?; in send()
|
| /webrtc/sctp/src/queue/ |
| H A D | payload_queue.rs | 34 self.chunk_map.insert(tsn, p); in push_no_check()
56 self.sorted.insert(pos, tsn); in push_no_check()
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_cache.rs | 127 ci.insert(r.typ, c); in full_pull_map()
145 out.insert(t, raw_handshake.handshake_message); in full_pull_map()
|
| /webrtc/webrtc/src/peer_connection/policy/ |
| H A D | sdp_semantics.rs | 100 ssrcs.insert(*ssrc); in extract_ssrc_list()
|
| /webrtc/rtp/src/packet/ |
| H A D | packet_test.rs | 1143 cases.insert( in test_unmarshal_error_handling()
1154 cases.insert( in test_unmarshal_error_handling()
1165 cases.insert( in test_unmarshal_error_handling()
1176 cases.insert( in test_unmarshal_error_handling()
1188 cases.insert( in test_unmarshal_error_handling()
|
| /webrtc/examples/examples/rtp-forwarder/ |
| H A D | rtp-forwarder.rs | 150 udp_conns.insert( in main()
161 udp_conns.insert( in main()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | mod.rs | 102 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream()
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | mod.rs | 387 reports.insert(peer_connection_id, PeerConnection(peer_connection_stats)); in collect_stats()
392 reports.insert(stats.id.clone(), SCTPTransport(stats)); in collect_stats()
412 ids_map.insert(dc.id()); in generate_and_set_data_channel_id()
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_gatherer.rs | 296 reports.insert(stats.id.clone(), StatsReportType::CandidatePair(stats)); in collect_stats()
300 reports.insert( in collect_stats()
307 reports.insert( in collect_stats()
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 196 streams.insert(ssrc, Arc::clone(&stream)); in get_or_create_stream()
270 ssrc_set.insert(ssrc); in destination_ssrc()
|
| /webrtc/dtls/examples/hub/src/ |
| H A D | lib.rs | 36 conns.insert(remote_addr.to_string(), Arc::clone(&conn)); in register()
|
| /webrtc/webrtc/src/api/media_engine/ |
| H A D | mod.rs | 466 reports.insert(codec.stats_id.clone(), Codec(CodecStats::from(codec))); in collect_stats()
470 reports.insert(codec.stats_id.clone(), Codec(CodecStats::from(codec))); in collect_stats()
571 negotiated_header_extensions.insert(id, h); in update_header_extension()
741 proposed_header_extensions.insert( in get_rtp_parameters_by_kind()
|
| /webrtc/turn/src/server/request/ |
| H A D | request_test.rs | 79 nonces.insert(STATIC_KEY.to_owned(), Instant::now()); in test_allocation_lifetime_deletion_zero_lifetime()
|