Lines Matching refs:lock
124 let permissions = self.permissions.lock().await; in has_permission()
133 let permissions = self.permissions.lock().await; in add_permission()
144 let mut permissions = self.permissions.lock().await; in add_permission()
151 let mut permissions = self.permissions.lock().await; in remove_permission()
173 let channel_bindings = self.channel_bindings.lock().await; in add_channel_bind()
191 let mut channel_bindings = self.channel_bindings.lock().await; in add_channel_bind()
203 let mut channel_bindings = self.channel_bindings.lock().await; in remove_channel_bind()
209 let channel_bindings = self.channel_bindings.lock().await; in get_channel_addr()
215 let channel_bindings = self.channel_bindings.lock().await; in get_channel_number()
234 let mut permissions = self.permissions.lock().await; in close()
241 let mut channel_bindings = self.channel_bindings.lock().await; in close()
268 self.reset_tx.lock().replace(reset_tx); in start()
283 let mut alls = allocs.lock().await; in start()
305 let reset_tx = self.reset_tx.lock().take(); in stop()
311 let reset_tx = self.reset_tx.lock().clone(); in refresh()
359 let mut alls = allocs.lock().await; in packet_handler()
381 let cbs = channel_bindings.lock().await; in packet_handler()
411 let ps = permissions.lock().await; in packet_handler()