33     pub(crate) fn new(shared_data: Arc<Mutex<BackendData>>) -> Arc<Self> {  in new()  method
56             threads: Mutex::new(Vec::new()),  in new()
57             stop_child_threads: AtomicBool::new(false),  in new()
58             self_ref: Weak::new(),  in new()
59             mm_log_receiver: Mutex::new(mm_log_worker_mpsc.1),  in new()
63         let r = Arc::new(r);  in new()
79             LogSet::<usize, ObjectWrapper<AllocatorLog>>::new("mm_allocator_log".to_string(), None);  in run()
125             let mut monitor_thread = MMMonitorThread::new(monitor_weak, PathBuf::from(km));  in create_threads()
146     pub fn new(mm_log_monitor: Weak<MMLogMonitor>, kmem_path: PathBuf) -> Self {  in new()  method
202             let mut logs = Vec::new();  in process_logs()
207                         ObjectWrapper::new(&chunck[0..channel_header.element_size as usize]);  in process_logs()
224                 sender.send(MMLogWorkerResult::new(logs)).unwrap();  in process_logs()
230         std::fs::OpenOptions::new().read(true).open(&self.kmem_path)  in open_kmem_file()
247                 ObjectWrapper::new(&buf).expect("Failed to parse MMLogChannel header.");  in load_header()
296     pub fn new(logs: Vec<ObjectWrapper<AllocatorLog>>) -> Self {  in new()  method