Searched refs:open_channels (Results 1 – 2 of 2) sorted by relevance
140 open_channels: Mutex::new(HashMap::default()), in txn_begin()233 open_channels: Mutex::new(HashMap::default()), in mut_txn_begin()277 pub(crate) open_channels: Mutex<HashMap<SmallString, ChannelRef<Self>>>, field1234 match self.open_channels.lock().entry(name.clone()) { in load_channel()1776 let result = match self.open_channels.lock().entry(name.clone()) { in open_or_create_channel()1868 self.open_channels.lock().insert(name, br.clone()); in fork()1895 self.open_channels in rename_channel()1901 self.open_channels.lock().insert(name, channel.clone()); in rename_channel()2049 let open_channels = in commit() localVariable2051 for (name, channel) in open_channels { in commit()[all …]
234 txn.open_channels.lock().insert(name, br.clone()); in restore_channel()