Lines Matching refs:r
186 let r = self.dfs(entity.1, &mut visited, &mut result); in topo_sort() localVariable
187 if r.is_err() { in topo_sort()
188 let err = r.unwrap_err(); in topo_sort()
221 let r = self.dfs(&dep_entity, visited, result); in dfs() localVariable
222 if r.is_err() { in dfs()
223 let mut err: DependencyCycleError = r.unwrap_err(); in dfs()
313 let r = scheduler.add_tasks(tasks); in new() localVariable
314 if r.is_err() { in new()
315 error!("Error while adding tasks: {:?}", r); in new()
316 return Err(r.err().unwrap()); in new()
419 let r = self.check_not_exists_dependency(); in run_with_topo_sort() localVariable
420 if r.is_err() { in run_with_topo_sort()
421 error!("Error while checking tasks: {:?}", r); in run_with_topo_sort()
422 return r; in run_with_topo_sort()
426 let r: Vec<Arc<SchedEntity>> = self.target.topo_sort(); in run_with_topo_sort() localVariable
431 let count = r.len(); in run_with_topo_sort()
435 Self::build_install_daemon(action, dragonos_dir, id2entity, count, &r) in run_with_topo_sort()
448 let mut r = self.target.entities(); in run_without_topo_sort() localVariable
450 Self::clean_daemon(action, dragonos_dir, &mut r); in run_without_topo_sort()
500 r: &Vec<Arc<SchedEntity>>, in build_install_daemon()
505 for e in r.iter() { in build_install_daemon()
553 pub fn clean_daemon(action: Action, dragonos_dir: PathBuf, r: &mut Vec<Arc<SchedEntity>>) { in clean_daemon()
555 while !guard.queue().is_empty() && !r.is_empty() { in clean_daemon()
556 guard.clean_task(action, dragonos_dir.clone(), r.pop().unwrap().clone()); in clean_daemon()