Searched refs:obs (Results 1 – 7 of 7) sorted by relevance
| /webrtc/util/src/vnet/conn_map/ |
| H A D | conn_map_test.rs | 35 obs, in test_udp_conn_map_insert_remove()
74 obs, in test_udp_conn_map_insert_0_remove()
113 obs, in test_udp_conn_map_find_0()
142 Arc::clone(&obs), in test_udp_conn_map_insert_many_ips_with_same_port()
148 Arc::clone(&obs), in test_udp_conn_map_insert_many_ips_with_same_port()
189 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_0()
194 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_0()
214 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
219 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
264 obs, in test_udp_conn_map_find_failure_1()
[all …]
|
| /webrtc/util/src/vnet/ |
| H A D | conn.rs | 36 obs: Arc<Mutex<dyn ConnObserver + Send + Sync>>, field
43 obs: Arc<Mutex<dyn ConnObserver + Send + Sync>>, in new()
53 obs, in new()
115 let obs = self.obs.lock().await; in send_to() localVariable
116 match obs.determine_source_ip(self.loc_addr.ip(), target.ip()) { in send_to()
128 let obs = self.obs.lock().await; in send_to() localVariable
129 obs.write(c).await? in send_to()
153 let obs = self.obs.lock().await; in close() localVariable
154 obs.on_closed(self.loc_addr).await; in close()
|
| /webrtc/turn/src/client/ |
| H A D | relay_conn.rs | 64 obs: Arc<Mutex<T>>, field
197 obs, in new()
304 let obs = self.obs.lock().await; in send_to() localVariable
386 let obs = self.obs.lock().await; in send_channel_data() localVariable
387 Ok(obs.write_to(&ch_data.raw, &obs.turn_server_addr()).await?) in send_channel_data()
393 let obs = self.obs.lock().await; in create_permissions() localVariable
414 let mut obs = self.obs.lock().await; in create_permissions() localVariable
418 let tr_res = obs in create_permissions()
465 let mut obs = self.obs.lock().await; in refresh_allocation() localVariable
473 Box::new(obs.realm()), in refresh_allocation()
[all …]
|
| /webrtc/sctp/src/timer/ |
| H A D | timer_test.rs | 40 let mut rt = AckTimer::new(Arc::downgrade(&obs), ACK_INTERVAL); in test_ack_timer_start_and_stop()
227 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_callback_interval() localVariable
254 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_last_start_wins() localVariable
282 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_stop_right_after_start() localVariable
307 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_start_stop_then_start() localVariable
336 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_start_and_stop_in_atight_loop() localVariable
362 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_should_stop_after_rtx_failure() localVariable
412 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_should_not_stop_if_max_retrans_is_zero() localVariable
421 let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, 0); in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
463 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_stop_timer_that_is_not_running_is_noop() localVariable
[all …]
|
| /webrtc/turn/src/client/relay_conn/ |
| H A D | relay_conn_test.rs | 42 let obs = DummyRelayConnObserver { in test_relay_conn() localVariable
59 let rc = RelayConn::new(Arc::new(Mutex::new(obs)), config).await; in test_relay_conn()
71 let rc_obs = Arc::clone(&rci.obs); in test_relay_conn()
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 62 let obs = dummy_obs2 as Arc<Mutex<dyn ConnObserver + Send + Sync>>; in test_udp_conn_send_to_recv_from() localVariable
64 let conn = Arc::new(UdpConn::new(src_addr, None, obs)); in test_udp_conn_send_to_recv_from()
149 let obs = dummy_obs2 as Arc<Mutex<dyn ConnObserver + Send + Sync>>; in test_udp_conn_send_recv() localVariable
151 let conn = Arc::new(UdpConn::new(src_addr, Some(dst_addr), obs)); in test_udp_conn_send_recv()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 298 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_net_virtual_assign_port() localVariable
301 let conn = Arc::new(UdpConn::new(SocketAddr::new(ip, port), None, obs)); in test_net_virtual_assign_port()
|