Searched refs:pending_binding_requests (Results 1 – 3 of 3) sorted by relevance
60 pub(crate) pending_binding_requests: Mutex<Vec<BindingRequest>>, field154 pending_binding_requests: Mutex::new(vec![]), in new()723 let mut pending_binding_requests = self.pending_binding_requests.lock().await; in send_binding_request() localVariable724 pending_binding_requests.push(BindingRequest { in send_binding_request()778 let mut pending_binding_requests = self.pending_binding_requests.lock().await; in invalidate_pending_binding_requests() localVariable779 let initial_size = pending_binding_requests.len(); in invalidate_pending_binding_requests()782 for binding_request in pending_binding_requests.drain(..) { in invalidate_pending_binding_requests()792 *pending_binding_requests = temp; in invalidate_pending_binding_requests()812 let mut pending_binding_requests = self.pending_binding_requests.lock().await; in handle_inbound_binding_success() localVariable813 for i in 0..pending_binding_requests.len() { in handle_inbound_binding_success()[all …]
333 let mut pending_binding_requests = a.internal.pending_binding_requests.lock().await; in test_handle_peer_reflexive_unknown_remote() localVariable334 *pending_binding_requests = vec![BindingRequest { in test_handle_peer_reflexive_unknown_remote()1555 let mut pending_binding_requests = a.internal.pending_binding_requests.lock().await; in test_binding_request_timeout() localVariable1556 pending_binding_requests.push(BindingRequest { in test_binding_request_timeout()1560 pending_binding_requests.push(BindingRequest { in test_binding_request_timeout()1564 pending_binding_requests.push(BindingRequest { in test_binding_request_timeout()1568 pending_binding_requests.push(BindingRequest { in test_binding_request_timeout()1576 let pending_binding_requests = a.internal.pending_binding_requests.lock().await; in test_binding_request_timeout() localVariable1577 …assert_eq!(pending_binding_requests.len(), EXPECTED_REMOVAL_COUNT, "Binding invalidation due to ti… in test_binding_request_timeout()
407 let mut pending_binding_requests = self.internal.pending_binding_requests.lock().await; in restart() localVariable408 *pending_binding_requests = vec![]; in restart()