Lines Matching refs:channel_bindings
79 channel_bindings: Arc<Mutex<HashMap<ChannelNumber, ChannelBind>>>, field
111 channel_bindings: Arc::new(Mutex::new(HashMap::new())), in new()
173 let channel_bindings = self.channel_bindings.lock().await; in add_channel_bind() localVariable
174 if let Some(cb) = channel_bindings.get(&c.number) { in add_channel_bind()
187 c.channel_bindings = Some(Arc::clone(&self.channel_bindings)); in add_channel_bind()
191 let mut channel_bindings = self.channel_bindings.lock().await; in add_channel_bind() localVariable
192 channel_bindings.insert(c.number, c); in add_channel_bind()
203 let mut channel_bindings = self.channel_bindings.lock().await; in remove_channel_bind() localVariable
204 channel_bindings.remove(&number).is_some() in remove_channel_bind()
209 let channel_bindings = self.channel_bindings.lock().await; in get_channel_addr() localVariable
210 channel_bindings.get(number).map(|cb| cb.peer) in get_channel_addr()
215 let channel_bindings = self.channel_bindings.lock().await; in get_channel_number() localVariable
216 for cb in channel_bindings.values() { in get_channel_number()
241 let mut channel_bindings = self.channel_bindings.lock().await; in close() localVariable
242 for c in channel_bindings.values_mut() { in close()
342 let channel_bindings = Arc::clone(&self.channel_bindings); in packet_handler() localVariable
381 let cbs = channel_bindings.lock().await; in packet_handler()