Lines Matching full:let

90         let _removed_listener;  in do_work()
91 let mut node_refs = thread.process.node_refs.lock(); in do_work()
92 let Some(mut freeze_entry) = node_refs.freeze_listeners.find_mut(&self.cookie) else { in do_work()
95 let freeze = freeze_entry.get_mut(); in do_work()
124 let is_frozen = freeze.node.owner.inner.lock().is_frozen.is_fully_frozen(); in do_work()
129 let mut state_info = BinderFrozenStateInfo::default(); in do_work()
169 let hc = reader.read::<BinderHandleCookie>()?; in request_freeze_notif()
170 let handle = hc.handle; in request_freeze_notif()
171 let cookie = FreezeCookie(hc.cookie); in request_freeze_notif()
173 let msg = FreezeMessage::new(GFP_KERNEL)?; in request_freeze_notif()
174 let alloc = RBTreeNodeReservation::new(GFP_KERNEL)?; in request_freeze_notif()
176 let mut node_refs_guard = self.node_refs.lock(); in request_freeze_notif()
177 let node_refs = &mut *node_refs_guard; in request_freeze_notif()
178 let Some(info) = node_refs.by_handle.get_mut(&handle) else { in request_freeze_notif()
186 let node_ref = info.node_ref(); in request_freeze_notif()
187 let freeze_entry = node_refs.freeze_listeners.entry(cookie); in request_freeze_notif()
189 if let rbtree::Entry::Occupied(ref dupe) = freeze_entry { in request_freeze_notif()
216 let dupe = dupe.get_mut(); in request_freeze_notif()
229 let msg = FreezeMessage::init(msg, cookie); in request_freeze_notif()
231 let _ = self.push_work(msg); in request_freeze_notif()
236 let cookie = FreezeCookie(reader.read()?); in freeze_notif_done()
237 let alloc = FreezeMessage::new(GFP_KERNEL)?; in freeze_notif_done()
238 let mut node_refs_guard = self.node_refs.lock(); in freeze_notif_done()
239 let node_refs = &mut *node_refs_guard; in freeze_notif_done()
240 let Some(freeze) = node_refs.freeze_listeners.get_mut(&cookie) else { in freeze_notif_done()
244 let mut clear_msg = None; in freeze_notif_done()
257 let is_frozen = freeze.node.owner.inner.lock().is_frozen.is_fully_frozen(); in freeze_notif_done()
265 if let Some(clear_msg) = clear_msg { in freeze_notif_done()
266 let _ = self.push_work(clear_msg); in freeze_notif_done()
272 let hc = reader.read::<BinderHandleCookie>()?; in clear_freeze_notif()
273 let handle = hc.handle; in clear_freeze_notif()
274 let cookie = FreezeCookie(hc.cookie); in clear_freeze_notif()
276 let alloc = FreezeMessage::new(GFP_KERNEL)?; in clear_freeze_notif()
277 let mut node_refs_guard = self.node_refs.lock(); in clear_freeze_notif()
278 let node_refs = &mut *node_refs_guard; in clear_freeze_notif()
279 let Some(info) = node_refs.by_handle.get_mut(&handle) else { in clear_freeze_notif()
283 let Some(info_cookie) = info.freeze() else { in clear_freeze_notif()
291 let Some(listener) = node_refs.freeze_listeners.get_mut(&cookie) else { in clear_freeze_notif()
298 let mut msg = None; in clear_freeze_notif()
304 if let Some(msg) = msg { in clear_freeze_notif()
305 let _ = self.push_work(msg); in clear_freeze_notif()
311 let node_refs = &mut *self.node_refs.lock(); in get_freeze_cookie()
312 let handle = node_refs.by_node.get(&node.global_id())?; in get_freeze_cookie()
313 let node_ref = node_refs.by_handle.get_mut(handle)?; in get_freeze_cookie()
324 let mut node_proc_pair; in find_freeze_recipients()
330 let mut recipients = in find_freeze_recipients()
333 let mut inner = self.lock_with_nodes(); in find_freeze_recipients()
334 let mut curr = inner.nodes.cursor_front_mut(); in find_freeze_recipients()
335 while let Some(cursor) = curr { in find_freeze_recipients()
336 let (key, node) = cursor.current(); in find_freeze_recipients()
337 let key = *key; in find_freeze_recipients()
338 let list = node.freeze_list(&inner.inner); in find_freeze_recipients()
339 let len = list.len(); in find_freeze_recipients()
371 let recipients = self.find_freeze_recipients()?; in prepare_freeze_messages()
372 let mut batch = KVVec::with_capacity(recipients.len(), GFP_KERNEL)?; in prepare_freeze_messages()
374 let Some(cookie) = proc.get_freeze_cookie(&node) else { in prepare_freeze_messages()
379 let msg_alloc = FreezeMessage::new(GFP_KERNEL)?; in prepare_freeze_messages()
380 let msg = FreezeMessage::init(msg_alloc, cookie); in prepare_freeze_messages()
395 let _ = proc.push_work(msg); in send_messages()