62 use std::sync::{Arc, Weak};
149         mem: Arc<dyn BackingMemory + Send + Sync>,  in start_read_to_mem()
165         mem: Arc<dyn BackingMemory + Send + Sync>,  in start_write_from_mem()
238     _file: Arc<File>,
239     _mem: Option<Arc<dyn BackingMemory + Send + Sync>>,
253     registered_sources: Slab<Arc<File>>,
302     fn spawn<F>(self: &Arc<Self>, f: F) -> Task<F::Output>  in spawn()
307         let raw = Arc::downgrade(self);  in spawn()
319     fn spawn_local<F>(self: &Arc<Self>, f: F) -> Task<F::Output>  in spawn_local()
324         let raw = Arc::downgrade(self);  in spawn_local()
464     fn register_source(&self, f: Arc<File>) -> usize {  in register_source()
484             .map(Arc::clone)  in submit_poll()
513             .map(Arc::clone)  in submit_fallocate()
542             .map(Arc::clone)  in submit_fsync()
563         mem: Arc<dyn BackingMemory + Send + Sync>,  in submit_read_to_vectored()
578             .map(Arc::clone)  in submit_read_to_vectored()
613         mem: Arc<dyn BackingMemory + Send + Sync>,  in submit_write_from_vectored()
628             .map(Arc::clone)  in submit_write_from_vectored()
712     raw: Arc<RawExecutor>,
717         let raw = RawExecutor::new().map(Arc::new)?;  in new()
739         let waker = new_waker(Arc::downgrade(&self.raw));  in run()
746         let waker = new_waker(Arc::downgrade(&self.raw));  in run_until()
760             tag: self.raw.register_source(Arc::new(duped_fd)),  in register_source()
761             ex: Arc::downgrade(&self.raw),  in register_source()
868             Arc::new(VecIoWrapper::from(vec![0u8; 4096])) as Arc<dyn BackingMemory + Send + Sync>;  in dont_drop_backing_mem_read()
882             .start_read_to_mem(0, Arc::clone(&bm), &[MemRegion { offset: 0, len: 8 }])  in dont_drop_backing_mem_read()
887         assert_eq!(Arc::strong_count(&bm), 2);  in dont_drop_backing_mem_read()
892         assert_eq!(Arc::strong_count(&bm), 2);  in dont_drop_backing_mem_read()
900         assert_eq!(Arc::strong_count(&bm), 1);  in dont_drop_backing_mem_read()
908             Arc::new(VecIoWrapper::from(vec![0u8; 4096])) as Arc<dyn BackingMemory + Send + Sync>;  in dont_drop_backing_mem_write()
922             .start_write_from_mem(0, Arc::clone(&bm), &[MemRegion { offset: 0, len: 8 }])  in dont_drop_backing_mem_write()
927         assert_eq!(Arc::strong_count(&bm), 2);  in dont_drop_backing_mem_write()
932         assert_eq!(Arc::strong_count(&bm), 2);  in dont_drop_backing_mem_write()
941         assert_eq!(Arc::strong_count(&bm), 1);  in dont_drop_backing_mem_write()
956             Arc::new(VecIoWrapper::from(vec![0u8; 16])) as Arc<dyn BackingMemory + Send + Sync>;  in canceled_before_completion()
966             .start_read_to_mem(0, Arc::clone(&bm), &[MemRegion { offset: 0, len: 8 }])  in canceled_before_completion()
973             Arc::new(VecIoWrapper::from(vec![0xc2u8; 16])) as Arc<dyn BackingMemory + Send + Sync>;  in canceled_before_completion()
975             .start_write_from_mem(0, Arc::clone(&buf), &[MemRegion { offset: 0, len: 8 }])  in canceled_before_completion()
999         let bm = Arc::new(VecIoWrapper::from(VALUE.to_ne_bytes().to_vec()));  in drop_before_completion()
1040         let bm = Arc::new(VecIoWrapper::from(0xf2e96u64.to_ne_bytes().to_vec()));  in drop_on_different_thread()