| /DADK/dadk-config/src/boot/ |
| H A D | metadata.rs | 133 let r = parse_boot_metadata(toml_str); in test_parse_missing_boot_protocol() localVariable
134 assert!(r.is_err()); in test_parse_missing_boot_protocol()
135 let r = r.unwrap_err(); in test_parse_missing_boot_protocol() localVariable
136 assert_missing_field(&r.to_string(), "boot-protocol"); in test_parse_missing_boot_protocol()
146 let r = parse_boot_metadata(toml_str); in test_parse_missing_boot_mode() localVariable
147 assert!(r.is_err()); in test_parse_missing_boot_mode()
148 let r = r.unwrap_err(); in test_parse_missing_boot_mode() localVariable
149 assert_missing_field(&r.to_string(), "boot-mode"); in test_parse_missing_boot_mode()
158 let r = parse_boot_metadata(toml_str); in test_parse_invalid_boot_protocol() localVariable
159 assert!(r.is_err()); in test_parse_invalid_boot_protocol()
[all …]
|
| /DADK/dadk-config/src/rootfs/ |
| H A D | fstype.rs | 35 let r = deserialize_fs_type("fat32"); in test_deserialize_fat32_lowercase()
36 assert_eq!(r.is_ok(), true); in test_deserialize_fat32_lowercase()
37 let fs_type = r.unwrap(); in test_deserialize_fat32_lowercase()
43 let r = deserialize_fs_type("FAT32"); in test_deserialize_fat32_mixed_case()
44 assert_eq!(r.is_ok(), true); in test_deserialize_fat32_mixed_case()
45 let fs_type = r.unwrap(); in test_deserialize_fat32_mixed_case()
34 let r = deserialize_fs_type("fat32"); test_deserialize_fat32_lowercase() localVariable
42 let r = deserialize_fs_type("FAT32"); test_deserialize_fat32_mixed_case() localVariable
|
| H A D | fstype.rs | 35 let r = deserialize_fs_type("fat32"); in test_deserialize_fat32_lowercase() localVariable
36 assert_eq!(r.is_ok(), true); in test_deserialize_fat32_lowercase()
37 let fs_type = r.unwrap(); in test_deserialize_fat32_lowercase()
43 let r = deserialize_fs_type("FAT32"); in test_deserialize_fat32_mixed_case() localVariable
44 assert_eq!(r.is_ok(), true); in test_deserialize_fat32_mixed_case()
45 let fs_type = r.unwrap(); in test_deserialize_fat32_mixed_case()
|
| /DADK/dadk-user/src/ |
| H A D | lib.rs | 137 let r = parser.parse(); in dadk_user_main()
138 if r.is_err() { in dadk_user_main()
141 let tasks: Vec<(PathBuf, DADKTask)> = r.unwrap(); in dadk_user_main()
154 let r = scheduler.unwrap().run(); in dadk_user_main()
155 if r.is_err() { in dadk_user_main()
156 let r = InteractiveConsole::new( dadk_user_main() localVariable
172 let r = parser.parse(); dadk_user_main() localVariable
189 let r = scheduler.unwrap().run(); dadk_user_main() localVariable
|
| H A D | lib.rs | 137 let r = parser.parse(); in dadk_user_main()
138 if r.is_err() { in dadk_user_main() localVariable
141 let tasks: Vec<(PathBuf, DADKTask)> = r.unwrap(); in dadk_user_main()
154 let r = scheduler.unwrap().run(); in dadk_user_main()
155 if r.is_err() { in dadk_user_main() localVariable
|
| H A D | lib.rs | 137 let r = parser.parse(); in dadk_user_main() localVariable
138 if r.is_err() { in dadk_user_main()
141 let tasks: Vec<(PathBuf, DADKTask)> = r.unwrap(); in dadk_user_main()
154 let r = scheduler.unwrap().run(); in dadk_user_main() localVariable
155 if r.is_err() { in dadk_user_main()
|
| H A D | lib.rs | 137 let r = parser.parse(); in dadk_user_main()
138 if r.is_err() { in dadk_user_main()
141 let tasks: Vec<(PathBuf, DADKTask)> = r.unwrap(); in dadk_user_main()
154 let r = scheduler.unwrap().run(); in dadk_user_main()
155 if r.is_err() { in dadk_user_main()
153 let r = parser.parse(); dadk_user_main() localVariable
170 let r = scheduler.unwrap().run(); dadk_user_main() localVariable
|
| H A D | lib.rs | 137 let r = parser.parse(); in dadk_user_main()
138 if r.is_err() { in dadk_user_main()
141 let tasks: Vec<(PathBuf, DADKTask)> = r.unwrap(); in dadk_user_main()
154 let r = scheduler.unwrap().run(); in dadk_user_main()
155 if r.is_err() { in dadk_user_main()
148 let r = parser.parse(); dadk_user_main() localVariable
165 let r = scheduler.unwrap().run(); dadk_user_main() localVariable
|
| /DADK/dadk-user/src/scheduler/ |
| H A D | mod.rs | 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()
[all …]
|
| H A D | mod.rs | 186 let r = self.dfs(entity.1, &mut visited, &mut result); in clear()
187 if r.is_err() {
188 let err = r.unwrap_err(); in topo_sort()
221 let r = self.dfs(&dep_entity, visited, result); in dfs()
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()
314 if r.is_err() { in new()
315 error!("Error while adding tasks: {:?}", r); in new()
316 return Err(r in new()
194 let r = self.dfs(entity.1, &mut visited, &mut result); topo_sort() localVariable
229 let r = self.dfs(&dep_entity, visited, result); dfs() localVariable
321 let r = scheduler.add_tasks(tasks); new() localVariable
464 let r = self.check_not_exists_dependency(); run_with_topo_sort() localVariable
471 let r: Vec<Arc<SchedEntity>> = self.target.topo_sort(); run_with_topo_sort() localVariable
493 let mut r = self.target.entities(); run_without_topo_sort() localVariable
[all...] |
| H A D | mod.rs | 186 let r = self.dfs(entity.1, &mut visited, &mut result); in clear()
187 if r.is_err() {
188 let err = r.unwrap_err(); in topo_sort()
221 let r = self.dfs(&dep_entity, visited, result); in dfs()
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()
314 if r.is_err() { in new()
315 error!("Error while adding tasks: {:?}", r); in new()
316 return Err(r in new()
194 let r = self.dfs(entity.1, &mut visited, &mut result); topo_sort() localVariable
229 let r = self.dfs(&dep_entity, visited, result); dfs() localVariable
321 let r = scheduler.add_tasks(tasks); new() localVariable
464 let r = self.check_not_exists_dependency(); run_with_topo_sort() localVariable
471 let r: Vec<Arc<SchedEntity>> = self.target.topo_sort(); run_with_topo_sort() localVariable
493 let mut r = self.target.entities(); run_without_topo_sort() localVariable
[all...] |
| H A D | mod.rs | 186 let r = self.dfs(entity.1, &mut visited, &mut result);
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()
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()
314 if r.is_err() { in new()
315 error!("Error while adding tasks: {:?}", r); in new()
316 return Err(r in new()
193 let r = self.dfs(entity.1, &mut visited, &mut result); topo_sort() localVariable
228 let r = self.dfs(&dep_entity, visited, result); dfs() localVariable
320 let r = scheduler.add_tasks(tasks); new() localVariable
462 let r = self.check_not_exists_dependency(); run_with_topo_sort() localVariable
469 let r: Vec<Arc<SchedEntity>> = self.target.topo_sort(); run_with_topo_sort() localVariable
491 let mut r = self.target.entities(); run_without_topo_sort() localVariable
[all...] |
| /DADK/dadk-user/tests/ |
| H A D | test_parse_dadk_user_config.rs | |
| H A D | test_parse_dadk_user_config.rs | |
| /DADK/dadk-user/src/executor/ |
| H A D | tests.rs | 55 let r = executor.prepare_local_env(); in set_local_env() localVariable
56 assert!(r.is_ok(), "Prepare local env error: {:?}", r); in set_local_env()
77 let r = executor.prepare_local_env(); in execute_should_capture_error() localVariable
78 assert!(r.is_ok(), "Prepare local env error: {:?}", r); in execute_should_capture_error()
|
| H A D | tests.rs | 55 let r = executor.prepare_local_env(); in set_local_env() localVariable
56 assert!(r.is_ok(), "Prepare local env error: {:?}", r); in set_local_env()
77 let r = executor.prepare_local_env(); in execute_should_capture_error() localVariable
78 assert!(r.is_ok(), "Prepare local env error: {:?}", r); in execute_should_capture_error()
|
| H A D | tests.rs | 55 let r = executor.prepare_local_env(); in set_local_env() localVariable
56 assert!(r.is_ok(), "Prepare local env error: {:?}", r); in set_local_env()
77 let r = executor.prepare_local_env(); in execute_should_capture_error() localVariable
78 assert!(r.is_ok(), "Prepare local env error: {:?}", r); in execute_should_capture_error()
|
| H A D | mod.rs | 107 let r = self.do_execute(); in execute()
108 self.save_task_data(r.clone()); in execute()
110 return r;
114 fn save_task_data(&self, r: Result<(), ExecutorError>) { in save_task_data()
118 if r.is_ok() { in save_task_data()
128 if r.is_ok() { in save_task_data()
166 let r = self.clean(); in do_execute()
167 if let Err(e) = r { in do_execute()
338 let r: Result<(), ExecutorError> = match level { in clean_cache()
347 if let Err(e) = r { in src_work_dir()
104 let r = self.do_execute(); execute() localVariable
160 let r = self.clean(); do_execute() localVariable
272 let r: Result<(), ExecutorError> = match level { clean() localVariable
488 let r = child run_command() localVariable
493 let r = r.unwrap(); run_command() localVariable
[all...] |
| H A D | mod.rs | 107 let r = self.do_execute(); in execute()
108 self.save_task_data(r.clone()); in execute()
110 return r;
114 fn save_task_data(&self, r: Result<(), ExecutorError>) { in save_task_data()
118 if r.is_ok() { in save_task_data()
128 if r.is_ok() { in save_task_data()
166 let r = self.clean(); in do_execute()
167 if let Err(e) = r { in do_execute()
338 let r: Result<(), ExecutorError> = match level { in clean_cache()
347 if let Err(e) = r { in src_work_dir()
104 let r = self.do_execute(); execute() localVariable
158 let r = self.clean(); do_execute() localVariable
267 let r: Result<(), ExecutorError> = match level { clean() localVariable
485 let r = child run_command() localVariable
490 let r = r.unwrap(); run_command() localVariable
[all...] |
| H A D | mod.rs | 107 let r = self.do_execute(); in execute()
108 self.save_task_data(r.clone()); in execute()
110 return r;
114 fn save_task_data(&self, r: Result<(), ExecutorError>) { in save_task_data()
118 if r.is_ok() { in save_task_data()
128 if r.is_ok() { in save_task_data()
166 let r = self.clean(); in do_execute()
167 if let Err(e) = r { in do_execute()
338 let r: Result<(), ExecutorError> = match level { in src_work_dir()
347 if let Err(e) = r {
104 let r = self.do_execute(); execute() localVariable
158 let r = self.clean(); do_execute() localVariable
260 let r: Result<(), ExecutorError> = match level { clean() localVariable
475 let r = child run_command() localVariable
480 let r = r.unwrap(); run_command() localVariable
[all...] |
| H A D | mod.rs | 107 let r = self.do_execute(); in execute() localVariable
108 self.save_task_data(r.clone()); in execute()
110 return r; in execute()
114 fn save_task_data(&self, r: Result<(), ExecutorError>) { in save_task_data()
118 if r.is_ok() { in save_task_data()
128 if r.is_ok() { in save_task_data()
166 let r = self.clean(); in do_execute()
167 if let Err(e) = r { in do_execute()
338 let r: Result<(), ExecutorError> = match level { in clean_target()
347 if let Err(e) = r { in clean_cache()
161 let r = self.clean(); do_execute() localVariable
281 let r: Result<(), ExecutorError> = match level { clean() localVariable
496 let r = child run_command() localVariable
501 let r = r.unwrap(); run_command() localVariable
[all...] |
| H A D | mod.rs | 107 let r = self.do_execute(); in execute() localVariable
108 self.save_task_data(r.clone()); in execute()
110 return r; in execute()
114 fn save_task_data(&self, r: Result<(), ExecutorError>) { in save_task_data()
118 if r.is_ok() { in save_task_data()
128 if r.is_ok() { in save_task_data()
166 let r = self.clean(); in do_execute()
167 if let Err(e) = r { in do_execute()
338 let r: Result<(), ExecutorError> = match level { in clean_src()
347 if let Err(e) = r { in clean_target()
162 let r = self.clean(); do_execute() localVariable
296 let r: Result<(), ExecutorError> = match level { clean() localVariable
511 let r = child run_command() localVariable
516 let r = r.unwrap(); run_command() localVariable
[all...] |
| H A D | mod.rs | 107 let r = self.do_execute(); in execute() localVariable
108 self.save_task_data(r.clone()); in execute()
110 return r; in execute()
114 fn save_task_data(&self, r: Result<(), ExecutorError>) { in save_task_data()
118 if r.is_ok() { in save_task_data()
128 if r.is_ok() { in save_task_data()
166 let r = self.clean(); in do_execute()
167 if let Err(e) = r { in do_execute()
338 let r: Result<(), ExecutorError> = match level { in clean_src()
347 if let Err(e) = r { in clean_target()
162 let r = self.clean(); do_execute() localVariable
293 let r: Result<(), ExecutorError> = match level { clean() localVariable
508 let r = child run_command() localVariable
513 let r = r.unwrap(); run_command() localVariable
[all...] |
| H A D | mod.rs | 107 let r = self.do_execute(); in execute() localVariable
108 self.save_task_data(r.clone()); in execute()
110 return r; in execute()
114 fn save_task_data(&self, r: Result<(), ExecutorError>) { in save_task_data()
118 if r.is_ok() { in save_task_data()
128 if r.is_ok() { in save_task_data()
166 let r = self.clean(); in do_execute() localVariable
167 if let Err(e) = r { in do_execute()
338 let r: Result<(), ExecutorError> = match level { in clean() localVariable
347 if let Err(e) = r { in clean()
[all …]
|
| /DADK/crates/test_base/src/ |
| H A D | global.rs | 75 let r = BaseGlobalTestContext { project_base_path }; in setup() localVariable
76 r.ensure_fake_dragonos_dir_exist(); in setup()
77 r.ensure_fake_dadk_cache_root_exist(); in setup()
78 r in setup()
|