Lines Matching refs:Arc
32 Arc, ArcBorrow, CondVar, CondVarTimeoutResult, Mutex, SpinLock, UniqueArc,
107 threads: RBTree<i32, Arc<Thread>>,
351 pub(crate) process: Arc<Process>,
360 fn new(node_ref: NodeRef, handle: u32, process: Arc<Process>) -> impl PinInit<Self> { in new()
428 pub(crate) ctx: Arc<Context>,
477 type Pointer = Arc<Process>;
479 fn run(me: Arc<Self>) { in run()
497 fn new(ctx: Arc<Context>, cred: ARef<Credential>) -> Result<Arc<Self>> { in new()
663 thread: &'a Arc<Thread>, in get_work_or_register()
675 fn get_current_thread(self: ArcBorrow<'_, Self>) -> Result<Arc<Thread>> { in get_current_thread()
694 let ta: Arc<Thread> = Thread::new(id, self.into())?; in get_current_thread()
997 self: &Arc<Self>, in buffer_alloc()
1058 pub(crate) fn buffer_get(self: &Arc<Self>, ptr: usize) -> Option<Allocation> { in buffer_get()
1131 fn remove_thread(&self, thread: Arc<Thread>) { in remove_thread()
1210 self: &Arc<Self>, in request_death()
1247 let death = Arc::from(death); in request_death()
1316 fn deferred_release(self: Arc<Self>) { in deferred_release()
1604 pub(crate) fn open(ctx: ArcBorrow<'_, Context>, file: &File) -> Result<Arc<Process>> { in open()
1608 pub(crate) fn release(this: Arc<Process>, _file: &File) { in release()
1638 let _ = workqueue::system().enqueue(Arc::from(this)); in flush()
1699 thread: &'a Arc<Thread>,
1703 fn new(thread: &'a Arc<Thread>, guard: &mut Guard<'_, ProcessInner, SpinLockBackend>) -> Self { in new()