Lines Matching refs:thread
50 thread::{PushWorkRes, Thread},
150 if let Some(thread) = self.ready_threads.pop_front() { in push_work()
151 work.on_thread_selected(&thread); in push_work()
155 match thread.push_work(work) { in push_work()
179 for thread in self.threads.values() { in push_work()
180 thread.notify_if_poll_ready(sync); in push_work()
205 if let Some(thread) = othread { in update_node_refcount()
206 thread.push_work_deferred(node); in update_node_refcount()
219 thread: Option<&Thread>, in new_node_ref()
221 self.update_node_refcount(&node, true, strong, 1, thread); in new_node_ref()
230 thread: &Thread, in new_node_ref_with_thread()
240 thread.push_work_deferred(node); in new_node_ref_with_thread()
302 for thread in self.threads.values() { in txns_pending_locked()
303 if thread.has_current_transaction() { in txns_pending_locked()
580 for thread in inner.threads.values() { in debug_print()
582 let _ = all_threads.push(thread.clone(), GFP_ATOMIC); in debug_print()
593 for thread in all_threads { in debug_print()
594 thread.debug_print(m, print_all)?; in debug_print()
651 thread: &'a Arc<Thread>, in get_work_or_register()
660 Either::Right(Registration::new(thread, &mut inner)) in get_work_or_register()
675 if let Some(thread) = inner.threads.get(&id) { in get_current_thread()
676 return Ok(thread.clone()); in get_current_thread()
712 thread: &Thread, in set_as_manager()
725 let node_ref = self.get_node(ptr, cookie, flags as _, true, thread)?; in set_as_manager()
742 thread: &Thread, in get_node_inner()
749 return Ok(inner.new_node_ref_with_thread(node, strong, thread, wrapper)); in get_node_inner()
758 return Ok(inner.new_node_ref_with_thread(node, strong, thread, wrapper)); in get_node_inner()
765 .new_node_ref_with_thread(node, strong, thread, wrapper) in get_node_inner()
777 thread: &Thread, in get_node()
781 match self.get_node_inner(ptr, cookie, flags, strong, thread, wrapper) { in get_node()
1093 fn remove_thread(&self, thread: Arc<Thread>) { in remove_thread()
1094 self.inner.lock().threads.remove(&thread.id); in remove_thread()
1095 thread.release(); in remove_thread()
1174 thread: &Thread, in request_death()
1181 thread.push_return_work(BR_ERROR); in request_death()
1223 pub(crate) fn clear_death(&self, reader: &mut UserSliceReader, thread: &Thread) -> Result { in clear_death()
1247 let _ = thread.push_work_if_looper(death); in clear_death()
1254 pub(crate) fn dead_binder_done(&self, cookie: u64, thread: &Thread) { in dead_binder_done()
1256 death.set_notification_done(thread); in dead_binder_done()
1274 for thread in inner.threads.values() { in deferred_flush()
1275 thread.exit_looper(); in deferred_flush()
1306 for thread in threads.values() { in deferred_release()
1307 thread.release(); in deferred_release()
1523 let thread = this.get_current_thread()?; in ioctl_write_only() localVariable
1526 uapi::BINDER_THREAD_EXIT => this.remove_thread(thread), in ioctl_write_only()
1527 uapi::BINDER_SET_CONTEXT_MGR => this.set_as_manager(None, &thread)?, in ioctl_write_only()
1529 this.set_as_manager(Some(reader.read()?), &thread)? in ioctl_write_only()
1549 let thread = this.get_current_thread()?; in ioctl_write_read() localVariable
1552 uapi::BINDER_WRITE_READ => thread.write_read(data, blocking)?, in ioctl_write_read()
1557 uapi::BINDER_GET_EXTENDED_ERROR => thread.get_extended_error(data)?, in ioctl_write_read()
1660 let thread = this.get_current_thread()?; in poll() localVariable
1661 let (from_proc, mut mask) = thread.poll(file, table); in poll()
1673 thread: &'a Arc<Thread>, field
1677 fn new(thread: &'a Arc<Thread>, guard: &mut Guard<'_, ProcessInner, SpinLockBackend>) -> Self { in new()
1678 assert!(core::ptr::eq(&thread.process.inner, guard.lock_ref())); in new()
1680 if let Ok(list_arc) = ListArc::try_from_arc(thread.clone()) { in new()
1688 Self { thread } in new()
1694 let mut inner = self.thread.process.inner.lock(); in drop()
1698 unsafe { inner.ready_threads.remove(self.thread) }; in drop()