Lines Matching refs:inner
415 inner: SpinLock<InnerThread>, field
440 let inner = InnerThread::new()?; in new() localVariable
447 inner <- kernel::new_spinlock!(inner, "Thread::inner"), in new()
458 let inner = self.inner.lock(); in debug_print() localVariable
460 if print_all || inner.current_transaction.is_some() || !inner.work_list.is_empty() { in debug_print()
465 inner.looper_flags, in debug_print()
466 inner.looper_need_return, in debug_print()
470 let mut t_opt = inner.current_transaction.as_ref(); in debug_print()
484 for work in &inner.work_list { in debug_print()
492 let ee = self.inner.lock().extended_error; in get_extended_error()
498 self.inner.lock().current_transaction = Some(transaction); in set_current_transaction()
502 self.inner.lock().current_transaction.is_some() in has_current_transaction()
510 let mut inner = self.inner.lock(); in get_work_local() localVariable
511 if inner.looper_need_return { in get_work_local()
512 return Ok(inner.pop_work()); in get_work_local()
518 return self.inner.lock().pop_work().ok_or(EAGAIN).map(Some); in get_work_local()
522 let mut inner = self.inner.lock(); in get_work_local() localVariable
524 if let Some(work) = inner.pop_work() { in get_work_local()
528 inner.looper_flags |= LOOPER_WAITING; in get_work_local()
529 let signal_pending = self.work_condvar.wait_interruptible_freezable(&mut inner); in get_work_local()
530 inner.looper_flags &= !LOOPER_WAITING; in get_work_local()
535 if inner.looper_need_return { in get_work_local()
549 let mut inner = self.inner.lock(); in get_work() localVariable
550 if let Some(work) = inner.pop_work() { in get_work()
553 if inner.looper_need_return { in get_work()
554 drop(inner); in get_work()
573 let mut inner = self.inner.lock(); in get_work() localVariable
575 if let Some(work) = inner.pop_work() { in get_work()
579 inner.looper_flags |= LOOPER_WAITING | LOOPER_WAITING_PROC; in get_work()
580 let signal_pending = self.work_condvar.wait_interruptible_freezable(&mut inner); in get_work()
581 inner.looper_flags &= !(LOOPER_WAITING | LOOPER_WAITING_PROC); in get_work()
583 if signal_pending || inner.looper_need_return { in get_work()
588 drop(inner); in get_work()
591 let res = match self.inner.lock().pop_work() { in get_work()
607 let res = self.inner.lock().push_work(work); in push_work()
623 let mut inner = self.inner.lock(); in push_work_if_looper() localVariable
624 if inner.is_looper() && !inner.is_dead { in push_work_if_looper()
625 inner.push_work(work); in push_work_if_looper()
628 drop(inner); in push_work_if_looper()
634 self.inner.lock().push_work_deferred(work); in push_work_deferred()
638 self.inner.lock().push_return_work(reply); in push_return_work()
1087 let mut inner = thread.inner.lock(); in unwind_transaction_stack() localVariable
1088 inner.pop_transaction_to_reply(thread.as_ref()) in unwind_transaction_stack()
1120 transaction.set_outstanding(&mut self.process.inner.lock()); in deliver_single_reply()
1124 let mut inner = self.inner.lock(); in deliver_single_reply() localVariable
1125 if !inner.pop_transaction_replied(transaction) { in deliver_single_reply()
1129 if inner.is_dead { in deliver_single_reply()
1135 inner.push_work(work); in deliver_single_reply()
1137 Err(code) => inner.push_reply_work(code), in deliver_single_reply()
1148 let inner = self.inner.lock(); in is_current_transaction() localVariable
1149 match &inner.current_transaction { in is_current_transaction()
1159 let inner = self.inner.lock(); in top_of_transaction_stack() localVariable
1160 if let Some(cur) = &inner.current_transaction { in top_of_transaction_stack()
1171 fn transaction<T>(self: &Arc<Self>, tr: &BinderTransactionDataSg, inner: T) in transaction()
1175 if let Err(err) = inner(self, tr) { in transaction()
1177 let mut ee = self.inner.lock().extended_error; in transaction()
1206 let mut inner = self.inner.lock(); in transaction_inner() localVariable
1207 if !transaction.is_stacked_on(&inner.current_transaction) { in transaction_inner()
1211 inner.current_transaction = Some(transaction.clone_arc()); in transaction_inner()
1214 inner.push_work_deferred(list_completion); in transaction_inner()
1221 let mut inner = self.inner.lock(); in transaction_inner() localVariable
1222 transaction = inner.current_transaction.take().unwrap(); in transaction_inner()
1223 inner.current_transaction = transaction.clone_next(); in transaction_inner()
1231 let orig = self.inner.lock().pop_transaction_to_reply(self)?; in reply_inner()
1242 self.inner.lock().push_work(completion); in reply_inner()
1278 self.inner.lock().push_work(list_completion); in oneway_transaction_inner()
1294 while reader.len() >= size_of::<u32>() && self.inner.lock().return_work.is_unused() { in write()
1328 self.inner.lock().looper_need_return = true; in write()
1360 self.inner.lock().looper_register(valid); in write()
1362 BC_ENTER_LOOPER => self.inner.lock().looper_enter(), in write()
1363 BC_EXIT_LOOPER => self.inner.lock().looper_exit(), in write()
1387 let inner = self.inner.lock(); in read() localVariable
1388 (inner.is_looper(), inner.should_use_process_work_queue()) in read()
1464 self.inner.lock().looper_need_return = false; in write_read()
1484 self.inner.lock().looper_need_return = false; in write_read()
1491 let mut inner = self.inner.lock(); in poll() localVariable
1492 (inner.should_use_process_work_queue(), inner.poll()) in poll()
1497 let mut inner = self.inner.lock(); in exit_looper() localVariable
1498 let should_notify = inner.looper_flags & LOOPER_WAITING != 0; in exit_looper()
1500 inner.looper_need_return = true; in exit_looper()
1502 drop(inner); in exit_looper()
1511 let inner = self.inner.lock(); in notify_if_poll_ready() localVariable
1512 let notify = inner.looper_flags & LOOPER_POLL != 0 && inner.should_use_process_work_queue(); in notify_if_poll_ready()
1513 drop(inner); in notify_if_poll_ready()
1526 self.inner.lock().is_dead = true; in release()