Searched refs:channel_bindings (Results 1 – 3 of 3) sorted by relevance
173 let channel_bindings = self.channel_bindings.lock().await; in add_channel_bind() localVariable187 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() localVariable192 channel_bindings.insert(c.number, c); in add_channel_bind()203 let mut channel_bindings = self.channel_bindings.lock().await; in remove_channel_bind() localVariable204 channel_bindings.remove(&number).is_some() in remove_channel_bind()209 let channel_bindings = self.channel_bindings.lock().await; in get_channel_addr() localVariable215 let channel_bindings = self.channel_bindings.lock().await; in get_channel_number() localVariable216 for cb in channel_bindings.values() { in get_channel_number()241 let mut channel_bindings = self.channel_bindings.lock().await; in close() localVariable[all …]
17 pub(crate) channel_bindings: Option<Arc<Mutex<HashMap<ChannelNumber, ChannelBind>>>>, field28 channel_bindings: None, in new()38 let channel_bindings = self.channel_bindings.clone(); in start() localVariable50 if let Some(cbs) = &channel_bindings{ in start()
62 let channel_bindings = a.channel_bindings.lock().await; in test_channel_bind_reset() localVariable63 if let Some(c) = channel_bindings.get(&ChannelNumber(MIN_CHANNEL_NUMBER)) { in test_channel_bind_reset()