Searched defs:obs (Results 1 – 7 of 7) sorted by relevance
29 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_insert_remove() localVariable68 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_insert_0_remove() localVariable107 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_find_0() localVariable136 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_insert_many_ips_with_same_port() localVariable183 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_already_inuse_when_insert_0() localVariable208 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_already_inuse_when_insert_a_specified_ip() localVariable233 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_already_inuse_when_insert_same_specified_ip() localVariable258 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_find_failure_1() localVariable280 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_find_failure_2() localVariable302 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_insert_two_on_same_port_then_remove() localVariable
38 let obs = Arc::new(Mutex::new(TestAckTimerObserver { ncbs: ncbs.clone() })); in test_ack_timer_start_and_stop() localVariable227 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_callback_interval() localVariable254 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_last_start_wins() localVariable282 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_stop_right_after_start() localVariable307 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_start_stop_then_start() localVariable336 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_start_and_stop_in_atight_loop() localVariable362 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_should_stop_after_rtx_failure() localVariable412 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_should_not_stop_if_max_retrans_is_zero() localVariable463 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_stop_timer_that_is_not_running_is_noop() localVariable490 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_closed_timer_wont_start() localVariable
36 obs: Arc<Mutex<dyn ConnObserver + Send + Sync>>, field115 let obs = self.obs.lock().await; in send_to() localVariable128 let obs = self.obs.lock().await; in send_to() localVariable153 let obs = self.obs.lock().await; in close() localVariable
64 obs: Arc<Mutex<T>>, field304 let obs = self.obs.lock().await; in send_to() localVariable386 let obs = self.obs.lock().await; in send_channel_data() localVariable393 let obs = self.obs.lock().await; in create_permissions() localVariable414 let mut obs = self.obs.lock().await; in create_permissions() localVariable465 let mut obs = self.obs.lock().await; in refresh_allocation() localVariable543 let obs = rc_obs.lock().await; in bind() localVariable565 let mut obs = rc_obs.lock().await; in bind() localVariable
62 let obs = dummy_obs2 as Arc<Mutex<dyn ConnObserver + Send + Sync>>; in test_udp_conn_send_to_recv_from() localVariable149 let obs = dummy_obs2 as Arc<Mutex<dyn ConnObserver + Send + Sync>>; in test_udp_conn_send_recv() localVariable
42 let obs = DummyRelayConnObserver { in test_relay_conn() localVariable
298 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_net_virtual_assign_port() localVariable