Lines Matching refs:SchedEntity

43     children: Vec<Arc<SchedEntity>>,
48 pub struct SchedEntity { struct
52 impl PartialEq for SchedEntity { argument
58 impl SchedEntity { impl
86 pub fn add_child(&self, entity: Arc<SchedEntity>) { in add_child() argument
104 pub fn sub_children_indegree(&self) -> Vec<Arc<SchedEntity>> { in sub_children_indegree() argument
122 id2entity: RwLock<BTreeMap<i32, Arc<SchedEntity>>>,
132 pub fn add(&mut self, entity: Arc<SchedEntity>) { in add() argument
140 pub fn get(&self, id: i32) -> Option<Arc<SchedEntity>> { in get() argument
144 pub fn get_by_name_version(&self, name: &str, version: &str) -> Option<Arc<SchedEntity>> { in get_by_name_version() argument
153 pub fn entities(&self) -> Vec<Arc<SchedEntity>> { in entities() argument
161 pub fn id2entity(&self) -> BTreeMap<i32, Arc<SchedEntity>> { in id2entity() argument
180 pub fn topo_sort(&self) -> Vec<Arc<SchedEntity>> { in topo_sort() argument
200 entity: &Arc<SchedEntity>, in dfs() argument
202 result: &mut Vec<Arc<SchedEntity>>, in dfs() argument
268 DependencyNotFound(Arc<SchedEntity>, String),
351 ) -> Result<Arc<SchedEntity>, SchedulerError> { in add_task() argument
363 let entity = Arc::new(SchedEntity { in add_task()
426 let r: Vec<Arc<SchedEntity>> = self.target.topo_sort(); in run_with_topo_sort()
457 pub fn execute(action: Action, dragonos_dir: PathBuf, entity: Arc<SchedEntity>) { in execute() argument
498 id2entity: BTreeMap<i32, Arc<SchedEntity>>, in build_install_daemon() argument
500 r: &Vec<Arc<SchedEntity>>, in build_install_daemon() argument
504 let mut zero_entity: Vec<Arc<SchedEntity>> = Vec::new(); in build_install_daemon()
553 pub fn clean_daemon(action: Action, dragonos_dir: PathBuf, r: &mut Vec<Arc<SchedEntity>>) { in clean_daemon() argument
604 head_entity: Arc<SchedEntity>,
608 dependencies: Vec<(Arc<SchedEntity>, Arc<SchedEntity>)>,
612 pub fn new(head_entity: Arc<SchedEntity>) -> Self { in new()
620 pub fn add(&mut self, current: Arc<SchedEntity>, dependency: Arc<SchedEntity>) { in add() argument
629 pub fn dependencies(&self) -> &Vec<(Arc<SchedEntity>, Arc<SchedEntity>)> { in dependencies() argument