Lines Matching full:guard

10     sync::lock::{spinlock::SpinLockBackend, Guard},
326 guard: &mut Guard<'_, ProcessInner, SpinLockBackend>, in add_death()
328 self.inner.access_mut(guard).death_list.push_back(death); in add_death()
481 guard: &Guard<'_, ProcessInner, SpinLockBackend>, in populate_counts()
483 let inner = self.inner.access(guard); in populate_counts()
491 guard: &Guard<'_, ProcessInner, SpinLockBackend>, in populate_debug_info()
495 let inner = self.inner.access(guard); in populate_debug_info()
504 pub(crate) fn force_has_count(&self, guard: &mut Guard<'_, ProcessInner, SpinLockBackend>) { in force_has_count()
505 let inner = self.inner.access_mut(guard); in force_has_count()
520 guard: &mut Guard<'_, ProcessInner, SpinLockBackend>, in submit_oneway()
522 if guard.is_dead { in submit_oneway()
526 let inner = self.inner.access_mut(guard); in submit_oneway()
531 guard.push_work(transaction)?; in submit_oneway()
537 let mut guard = self.owner.inner.lock(); in release() localVariable
538 while let Some(work) = self.inner.access_mut(&mut guard).oneway_todo.pop_front() { in release()
539 drop(guard); in release()
541 guard = self.owner.inner.lock(); in release()
544 while let Some(death) = self.inner.access_mut(&mut guard).death_list.pop_front() { in release()
545 drop(guard); in release()
547 guard = self.owner.inner.lock(); in release()
552 let mut guard = self.owner.inner.lock(); in pending_oneway_finished() localVariable
553 if guard.is_dead { in pending_oneway_finished()
558 let inner = self.inner.access_mut(&mut guard); in pending_oneway_finished()
563 match guard.push_work(transaction) { in pending_oneway_finished()
569 drop(guard); in pending_oneway_finished()
582 guard: &mut Guard<'_, ProcessInner, SpinLockBackend>, in take_outdated_transaction()
584 let inner = self.inner.access_mut(guard); in take_outdated_transaction()
600 mut guard: Guard<'_, ProcessInner, SpinLockBackend>, in do_work_locked()
602 let inner = self.inner.access_mut(&mut guard); in do_work_locked()
629 guard.remove_node(self.ptr); in do_work_locked()
631 drop(guard); in do_work_locked()
656 let mut guard = self.owner.inner.lock(); in add_freeze_listener() localVariable
657 // Do not check for `guard.dead`. The `dead` flag that matters here is the owner of the in add_freeze_listener()
659 let inner = self.inner.access_mut(&mut guard); in add_freeze_listener()
663 drop(guard); in add_freeze_listener()
679 let mut guard = self.owner.inner.lock(); in remove_freeze_listener() localVariable
680 let inner = self.inner.access_mut(&mut guard); in remove_freeze_listener()
694 pub(crate) fn freeze_list<'a>(&'a self, guard: &'a ProcessInner) -> &'a [Arc<Process>] { in freeze_list()
695 &self.inner.access(guard).freeze_list in freeze_list()
791 let mut guard = self.node.owner.inner.lock(); in absorb() localVariable
792 let inner = self.node.inner.access_mut(&mut guard); in absorb()