Home
last modified time | relevance | path

Searched refs:SchedEntity (Results 1 – 15 of 15) sorted by relevance

/DADK/dadk-user/src/scheduler/
H A Dmod.rs43 children: Vec<Arc<SchedEntity>>,
48 pub struct SchedEntity { struct
52 impl PartialEq for SchedEntity { implementation
58 impl SchedEntity { implementation
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
[all …]
H A Dmod.rs43 children: Vec<Arc<SchedEntity>>,
48 pub struct SchedEntity {
52 impl PartialEq for SchedEntity {
58 impl SchedEntity { in eq()
86 pub fn add_child(&self, entity: Arc<SchedEntity>) { in sub_indegree()
104 pub fn sub_children_indegree(&self) -> Vec<Arc<SchedEntity>> {
122 id2entity: RwLock<BTreeMap<i32, Arc<SchedEntity>>>,
132 pub fn add(&mut self, entity: Arc<SchedEntity>) {
140 pub fn get(&self, id: i32) -> Option<Arc<SchedEntity>> { in add() argument
144 pub fn get_by_name_version(&self, name: &str, version: &str) -> Option<Arc<SchedEntity>> { in add()
51 pub struct SchedEntity { global() struct
55 impl PartialEq for SchedEntity { global() implementation
61 impl SchedEntity { global() implementation
89 add_child(&self, entity: Arc<SchedEntity>) add_child() argument
112 sub_children_indegree(&self) -> Vec<Arc<SchedEntity>> sub_children_indegree() argument
148 get(&self, id: i32) -> Option<Arc<SchedEntity>> get() argument
152 get_by_name_version(&self, name: &str, version: &str) -> Option<Arc<SchedEntity>> get_by_name_version() argument
161 entities(&self) -> Vec<Arc<SchedEntity>> entities() argument
169 id2entity(&self) -> BTreeMap<i32, Arc<SchedEntity>> id2entity() argument
188 topo_sort(&self) -> Vec<Arc<SchedEntity>> topo_sort() argument
208 dfs( &self, entity: &Arc<SchedEntity>, visited: &mut BTreeMap<i32, bool>, result: &mut Vec<Arc<SchedEntity>>, ) -> Result<(), DependencyCycleError> dfs() argument
210 dfs( &self, entity: &Arc<SchedEntity>, visited: &mut BTreeMap<i32, bool>, result: &mut Vec<Arc<SchedEntity>>, ) -> Result<(), DependencyCycleError> dfs() argument
359 add_task( &mut self, path: PathBuf, task: DADKTask, ) -> Result<Arc<SchedEntity>, SchedulerError> add_task() argument
502 execute(action: Action, dragonos_dir: PathBuf, entity: Arc<SchedEntity>) execute() argument
543 build_install_daemon( action: Action, dragonos_dir: PathBuf, id2entity: BTreeMap<i32, Arc<SchedEntity>>, mut count: usize, r: &Vec<Arc<SchedEntity>>, ) build_install_daemon() argument
545 build_install_daemon( action: Action, dragonos_dir: PathBuf, id2entity: BTreeMap<i32, Arc<SchedEntity>>, mut count: usize, r: &Vec<Arc<SchedEntity>>, ) build_install_daemon() argument
598 clean_daemon(action: Action, dragonos_dir: PathBuf, r: &mut Vec<Arc<SchedEntity>>) clean_daemon() argument
665 add(&mut self, current: Arc<SchedEntity>, dependency: Arc<SchedEntity>) add() argument
674 dependencies(&self) -> &Vec<(Arc<SchedEntity>, Arc<SchedEntity>)> dependencies() argument
[all...]
H A Dmod.rs43 children: Vec<Arc<SchedEntity>>,
48 pub struct SchedEntity {
52 impl PartialEq for SchedEntity {
58 impl SchedEntity { in eq()
86 pub fn add_child(&self, entity: Arc<SchedEntity>) { in sub_indegree()
104 pub fn sub_children_indegree(&self) -> Vec<Arc<SchedEntity>> {
122 id2entity: RwLock<BTreeMap<i32, Arc<SchedEntity>>>,
132 pub fn add(&mut self, entity: Arc<SchedEntity>) {
140 pub fn get(&self, id: i32) -> Option<Arc<SchedEntity>> { in add() argument
144 pub fn get_by_name_version(&self, name: &str, version: &str) -> Option<Arc<SchedEntity>> { in add()
51 pub struct SchedEntity { global() struct
55 impl PartialEq for SchedEntity { global() implementation
61 impl SchedEntity { global() implementation
89 add_child(&self, entity: Arc<SchedEntity>) add_child() argument
112 sub_children_indegree(&self) -> Vec<Arc<SchedEntity>> sub_children_indegree() argument
148 get(&self, id: i32) -> Option<Arc<SchedEntity>> get() argument
152 get_by_name_version(&self, name: &str, version: &str) -> Option<Arc<SchedEntity>> get_by_name_version() argument
161 entities(&self) -> Vec<Arc<SchedEntity>> entities() argument
169 id2entity(&self) -> BTreeMap<i32, Arc<SchedEntity>> id2entity() argument
188 topo_sort(&self) -> Vec<Arc<SchedEntity>> topo_sort() argument
208 dfs( &self, entity: &Arc<SchedEntity>, visited: &mut BTreeMap<i32, bool>, result: &mut Vec<Arc<SchedEntity>>, ) -> Result<(), DependencyCycleError> dfs() argument
210 dfs( &self, entity: &Arc<SchedEntity>, visited: &mut BTreeMap<i32, bool>, result: &mut Vec<Arc<SchedEntity>>, ) -> Result<(), DependencyCycleError> dfs() argument
359 add_task( &mut self, path: PathBuf, task: DADKTask, ) -> Result<Arc<SchedEntity>, SchedulerError> add_task() argument
502 execute(action: Action, dragonos_dir: PathBuf, entity: Arc<SchedEntity>) execute() argument
543 build_install_daemon( action: Action, dragonos_dir: PathBuf, id2entity: BTreeMap<i32, Arc<SchedEntity>>, mut count: usize, r: &Vec<Arc<SchedEntity>>, ) build_install_daemon() argument
545 build_install_daemon( action: Action, dragonos_dir: PathBuf, id2entity: BTreeMap<i32, Arc<SchedEntity>>, mut count: usize, r: &Vec<Arc<SchedEntity>>, ) build_install_daemon() argument
598 clean_daemon(action: Action, dragonos_dir: PathBuf, r: &mut Vec<Arc<SchedEntity>>) clean_daemon() argument
665 add(&mut self, current: Arc<SchedEntity>, dependency: Arc<SchedEntity>) add() argument
674 dependencies(&self) -> &Vec<(Arc<SchedEntity>, Arc<SchedEntity>)> dependencies() argument
[all...]
H A Dmod.rs43 children: Vec<Arc<SchedEntity>>,
48 pub struct SchedEntity {
52 impl PartialEq for SchedEntity {
58 impl SchedEntity {
86 pub fn add_child(&self, entity: Arc<SchedEntity>) {
104 pub fn sub_children_indegree(&self) -> Vec<Arc<SchedEntity>> {
122 id2entity: RwLock<BTreeMap<i32, Arc<SchedEntity>>>,
132 pub fn add(&mut self, entity: Arc<SchedEntity>) {
140 pub fn get(&self, id: i32) -> Option<Arc<SchedEntity>> { in add()
144 pub fn get_by_name_version(&self, name: &str, version: &str) -> Option<Arc<SchedEntity>> { in add()
50 pub struct SchedEntity { global() struct
54 impl PartialEq for SchedEntity { global() implementation
60 impl SchedEntity { global() implementation
88 add_child(&self, entity: Arc<SchedEntity>) add_child() argument
111 sub_children_indegree(&self) -> Vec<Arc<SchedEntity>> sub_children_indegree() argument
139 add(&mut self, entity: Arc<SchedEntity>) add() argument
147 get(&self, id: i32) -> Option<Arc<SchedEntity>> get() argument
151 get_by_name_version(&self, name: &str, version: &str) -> Option<Arc<SchedEntity>> get_by_name_version() argument
160 entities(&self) -> Vec<Arc<SchedEntity>> entities() argument
168 id2entity(&self) -> BTreeMap<i32, Arc<SchedEntity>> id2entity() argument
187 topo_sort(&self) -> Vec<Arc<SchedEntity>> topo_sort() argument
207 dfs( &self, entity: &Arc<SchedEntity>, visited: &mut BTreeMap<i32, bool>, result: &mut Vec<Arc<SchedEntity>>, ) -> Result<(), DependencyCycleError> dfs() argument
209 dfs( &self, entity: &Arc<SchedEntity>, visited: &mut BTreeMap<i32, bool>, result: &mut Vec<Arc<SchedEntity>>, ) -> Result<(), DependencyCycleError> dfs() argument
358 add_task( &mut self, path: PathBuf, task: DADKTask, ) -> Result<Arc<SchedEntity>, SchedulerError> add_task() argument
500 execute(action: Action, dragonos_dir: PathBuf, entity: Arc<SchedEntity>) execute() argument
541 build_install_daemon( action: Action, dragonos_dir: PathBuf, id2entity: BTreeMap<i32, Arc<SchedEntity>>, mut count: usize, r: &Vec<Arc<SchedEntity>>, ) build_install_daemon() argument
543 build_install_daemon( action: Action, dragonos_dir: PathBuf, id2entity: BTreeMap<i32, Arc<SchedEntity>>, mut count: usize, r: &Vec<Arc<SchedEntity>>, ) build_install_daemon() argument
596 clean_daemon(action: Action, dragonos_dir: PathBuf, r: &mut Vec<Arc<SchedEntity>>) clean_daemon() argument
663 add(&mut self, current: Arc<SchedEntity>, dependency: Arc<SchedEntity>) add() argument
672 dependencies(&self) -> &Vec<(Arc<SchedEntity>, Arc<SchedEntity>)> dependencies() argument
[all...]
H A Dtask_deque.rs9 use super::{SchedEntity, Scheduler};
47 entity: Arc<SchedEntity>, in build_install_task() argument
73 pub fn clean_task(&mut self, action: Action, dragonos_dir: PathBuf, entity: Arc<SchedEntity>) { in clean_task() argument
H A Dtask_deque.rs9 use super::{SchedEntity, Scheduler};
47 entity: Arc<SchedEntity>, in build_install_task() argument
73 pub fn clean_task(&mut self, action: Action, dragonos_dir: PathBuf, entity: Arc<SchedEntity>) { in clean_task() argument
/DADK/dadk-user/src/executor/
H A Dcache.rs13 scheduler::SchedEntity,
105 entity: Arc<SchedEntity>,
113 pub fn new(entity: Arc<SchedEntity>, cache_type: CacheDirType) -> Result<Self, ExecutorError> { in new() argument
149 pub fn build_dir(entity: Arc<SchedEntity>) -> Result<PathBuf, ExecutorError> {
153 pub fn source_dir(entity: Arc<SchedEntity>) -> Result<PathBuf, ExecutorError> {
157 pub fn build_dir_env_key(entity: &Arc<SchedEntity>) -> Result<String, ExecutorError> {
166 pub fn source_dir_env_key(entity: &Arc<SchedEntity>) -> Result<String, ExecutorError> {
175 pub fn need_source_cache(entity: &Arc<SchedEntity>) -> bool {
249 pub fn new(entity: Arc<SchedEntity>) -> Result<Self, ExecutorError> {
H A Dcache.rs13 scheduler::SchedEntity,
105 entity: Arc<SchedEntity>,
113 pub fn new(entity: Arc<SchedEntity>, cache_type: CacheDirType) -> Result<Self, ExecutorError> { in new() argument
149 pub fn build_dir(entity: Arc<SchedEntity>) -> Result<PathBuf, ExecutorError> { in build_dir()
153 pub fn source_dir(entity: Arc<SchedEntity>) -> Result<PathBuf, ExecutorError> { in source_dir()
157 pub fn build_dir_env_key(entity: &Arc<SchedEntity>) -> Result<String, ExecutorError> { in build_dir_env_key()
166 pub fn source_dir_env_key(entity: &Arc<SchedEntity>) -> Result<String, ExecutorError> { in source_dir_env_key()
175 pub fn need_source_cache(entity: &Arc<SchedEntity>) -> bool { in need_source_cache()
249 pub fn new(entity: Arc<SchedEntity>) -> Result<Self, ExecutorError> { in new()
H A Dmod.rs21 scheduler::{SchedEntities, SchedEntity},
41 entity: Arc<SchedEntity>,
68 entity: Arc<SchedEntity>, in new()
65 new( entity: Arc<SchedEntity>, action: Action, dragonos_sysroot: PathBuf, ) -> Result<Self, ExecutorError> new() argument
H A Dmod.rs21 scheduler::{SchedEntities, SchedEntity},
41 entity: Arc<SchedEntity>,
68 entity: Arc<SchedEntity>, in new()
65 new( entity: Arc<SchedEntity>, action: Action, dragonos_sysroot: PathBuf, ) -> Result<Self, ExecutorError> new() argument
H A Dmod.rs21 scheduler::{SchedEntities, SchedEntity},
41 entity: Arc<SchedEntity>,
68 entity: Arc<SchedEntity>, in new()
65 new( entity: Arc<SchedEntity>, action: Action, dragonos_sysroot: PathBuf, ) -> Result<Self, ExecutorError> new() argument
H A Dmod.rs21 scheduler::{SchedEntities, SchedEntity},
41 entity: Arc<SchedEntity>,
68 entity: Arc<SchedEntity>, in new() argument
H A Dmod.rs21 scheduler::{SchedEntities, SchedEntity},
41 entity: Arc<SchedEntity>,
68 entity: Arc<SchedEntity>, in new() argument
H A Dmod.rs21 scheduler::{SchedEntities, SchedEntity},
41 entity: Arc<SchedEntity>,
68 entity: Arc<SchedEntity>, in new() argument
H A Dmod.rs21 scheduler::{SchedEntities, SchedEntity},
41 entity: Arc<SchedEntity>,
68 entity: Arc<SchedEntity>, in new() argument