Lines Matching refs:pending_binding_requests
60 pub(crate) pending_binding_requests: Mutex<Vec<BindingRequest>>, field
154 pending_binding_requests: Mutex::new(vec![]), in new()
723 let mut pending_binding_requests = self.pending_binding_requests.lock().await; in send_binding_request() localVariable
724 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() localVariable
779 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()
793 let bind_requests_removed = initial_size - pending_binding_requests.len(); in invalidate_pending_binding_requests()
812 let mut pending_binding_requests = self.pending_binding_requests.lock().await; in handle_inbound_binding_success() localVariable
813 for i in 0..pending_binding_requests.len() { in handle_inbound_binding_success()
814 if pending_binding_requests[i].transaction_id == id { in handle_inbound_binding_success()
815 let valid_binding_request = pending_binding_requests.remove(i); in handle_inbound_binding_success()