/external/toolchain-utils/automation/server/ |
D | job_executer.py | 9 from automation.common import job 22 self.job = job_to_execute 27 self.name = '%s-%s' % (self.__class__.__name__, self.job.id) 30 self._executer = LoggingCommandExecuter(self.job.dry_run) 35 self.job.primary_machine.hostname, 36 self.job.primary_machine.username, 40 raise job.JobFailure(fail_msg, exit_code) 47 raise job.JobFailure(fail_msg, exit_code) 53 self._logger.debug('Cleaning up %r work directory.', self.job) 54 self._RunRemotely(cmd.RmTree(self.job.work_dir), 'Cleanup workdir failed.') [all …]
|
/external/autotest/client/bin/ |
D | job_unittest.py | 12 from autotest_lib.client.bin import job, sysinfo, harness 24 job_class = job.base_client_job 28 self.god.stub_with(job.base_client_job, '_get_environ_autodir', 30 self.job = self.job_class.__new__(self.job_class) 31 self.job._job_directory = base_job_unittest.stub_job_directory 43 autodir, clientdir, _ = self.job._find_base_directories() 49 _, _, serverdir = self.job._find_base_directories() 65 self.god.stub_function_to_return(job.os, 'mkdir', None) 66 self.god.stub_function_to_return(job.os.path, 'exists', True) 67 self.god.stub_function_to_return(self.job, '_load_state', None) [all …]
|
/external/autotest/client/site_tests/suite_HWQual/ |
D | control.auto | 16 job.run_test('power_Resume', 20 job.run_test('platform_HighResTimers') 21 job.run_test('platform_KernelVersion') 24 job.run_test('platform_AesThroughput') 27 job.run_test('firmware_RomSize', 35 # job.run_test('firmware_VbootCrypto', suite='benchmarks', tag='benchmarks') 38 job.run_test('hardware_MemoryTotalSize') 39 job.run_test('hardware_MemoryThroughput', num_iteration=2500, test_list='21') 42 job.run_test('hardware_StorageFio', 56 job.run_test('hardware_DiskSize', [all …]
|
/external/syslinux/gpxe/src/include/gpxe/ |
D | job.h | 43 void ( * done ) ( struct job_interface *job, int rc ); 48 void ( * kill ) ( struct job_interface *job ); 54 void ( * progress ) ( struct job_interface *job, 69 extern void job_done ( struct job_interface *job, int rc ); 70 extern void job_kill ( struct job_interface *job ); 71 extern void job_progress ( struct job_interface *job, 74 extern void ignore_job_done ( struct job_interface *job, int rc ); 75 extern void ignore_job_kill ( struct job_interface *job ); 76 extern void ignore_job_progress ( struct job_interface *job, 86 static inline void job_init ( struct job_interface *job, in job_init() argument [all …]
|
/external/toybox/toys/pending/ |
D | crond.c | 53 struct double_list *job, *var; member 280 dlist_add_nomalloc((struct double_list **)&cfile->job, (struct double_list *)j); in parse_line() 329 JOB *jstart, *jlist = (JOB *)list->job; in remove_completed_jobs() 348 list->job = (struct double_list *)jlist; in remove_completed_jobs() 396 if (!cfile->job) { in scan_cronfiles() 423 static void do_fork(CRONFILE *cfile, JOB *job, int fd, char *prog) in do_fork() argument 459 execlp(file, file, (prog ? "-ti" : "-c"), (prog ? NULL : job->cmd), (char *) NULL); in do_fork() 462 if (!prog) dprintf(1, "Exec failed: %s -c %s\n", file, job->cmd); in do_fork() 471 job->pid = pid; in do_fork() 475 static void sendmail(CRONFILE *cfile, JOB *job) in sendmail() argument [all …]
|
/external/autotest/frontend/health/ |
D | utils_unittest.py | 62 job = models.Job(job_idx=1) 66 early_pass = models.Test(job=job, status=GOOD_STATUS, 71 late_pass = models.Test(job=job, status=GOOD_STATUS, 84 job = models.Job(job_idx=1) 88 passing_test = models.Test(job=job, status=GOOD_STATUS, 93 failing_test = models.Test(job=job, status=FAIL_STATUS, 107 job = models.Job(job_idx=1) 111 test1 = models.Test(job=job, status=GOOD_STATUS, 116 test2 = models.Test(job=job, status=GOOD_STATUS, 147 job = models.Job(job_idx=1) [all …]
|
/external/autotest/frontend/afe/doctests/ |
D | 003_misc_rpc_features.txt | 18 job.next_step('step0') 19 job.next_step('step1') 20 job.next_step('step2') 21 job.next_step('step3') 22 job.next_step('step4') 25 job.profilers.add('oprofile') 28 job.profilers.add('iostat') 36 job.profilers.delete('oprofile') 39 job.profilers.delete('iostat') 48 job.next_step('step0') [all …]
|
/external/autotest/tko/parsers/ |
D | version_0_unittest.py | 22 self.god.stub_function(models.job, 'read_keyval') 23 self.god.stub_function(version_0.job, 'find_hostname') 42 models.job.read_keyval.expect_call('.').and_return( 45 job = version_0.job.load_from_dir('.') 46 self.assertEqual('janet', job['user']) 47 self.assertEqual('steeltown', job['label']) 48 self.assertEqual('abc123', job['machine']) 49 self.assertEqual('my_platform', job['machine_group']) 56 models.job.read_keyval.expect_call('.').and_return(raw_keyval) 61 version_0.job.find_hostname.expect_call('.').and_raises( [all …]
|
/external/autotest/server/cros/dynamic_suite/ |
D | job_status_unittest.py | 47 def expect_result_gathering(self, job): argument 48 self.afe.get_jobs(id=job.id, finished=True).AndReturn(job) 49 self.expect_yield_job_entries(job) 52 def expect_yield_job_entries(self, job): argument 53 entries = [s.entry for s in job.statuses] 55 job=job.id).AndReturn(entries) 57 self.tko.get_job_test_statuses_from_db(job.id).AndReturn( 58 job.statuses) 88 for job in jobs[1:]: 89 self.expect_result_gathering(job) [all …]
|
D | job_status.py | 80 for job in jobs: 82 job.id, timeout_mins) 83 afe.run('abort_host_queue_entries', job=job.id) 118 def _yield_job_results(afe, tko, job): argument 130 entries = afe.run('get_host_queue_entries', job=job.id) 141 statuses = tko.get_job_test_statuses_from_db(job.id) 143 yield Status('ABORT', job.name) 162 job.id, job.owner, s.hostname, job.name, 170 s.test_finished_time, job.id, 171 job.owner, s.hostname, job.name, [all …]
|
/external/v8/src/compiler-dispatcher/ |
D | optimizing-compile-dispatcher.cc | 20 void DisposeCompilationJob(CompilationJob* job, bool restore_function_code) { in DisposeCompilationJob() argument 22 Handle<JSFunction> function = job->info()->closure(); in DisposeCompilationJob() 29 delete job; in DisposeCompilationJob() 94 CompilationJob* job = input_queue_[InputQueueIndex(0)]; in NextInput() local 95 DCHECK_NOT_NULL(job); in NextInput() 101 DisposeCompilationJob(job, true); in NextInput() 105 return job; in NextInput() 108 void OptimizingCompileDispatcher::CompileNext(CompilationJob* job) { in CompileNext() argument 109 if (!job) return; in CompileNext() 112 CompilationJob::Status status = job->ExecuteJob(); in CompileNext() [all …]
|
/external/autotest/client/site_tests/suite_HWConfig/ |
D | control | 19 job.run_test('firmware_RomSize', 24 job.run_test('platform_HighResTimers') 25 job.run_test('power_Resume') 28 job.run_test('hardware_MemoryTotalSize') 31 job.run_test('power_CPUFreq') 32 job.run_test('power_CPUIdle') 35 job.run_test('hardware_Backlight') 38 job.run_test('hardware_DiskSize', 40 job.run_test('hardware_SsdDetection') 43 job.run_test('hardware_SAT', seconds=20) [all …]
|
/external/autotest/client/samples/ |
D | control.oprofile_power5 | 18 job.profilers.add('oprofile') 19 job.run_test('sleeptest', seconds=5, tag='default') 20 job.profilers.delete('oprofile') 23 job.profilers.add('oprofile', '/boot/vmlinux-autotest') 24 job.run_test('sleeptest', seconds=5, tag='vmlinux') 25 job.profilers.delete('oprofile') 28 job.profilers.add('oprofile', None, ['PM_RUN_CYC_GRP153:100000']) 29 job.run_test('sleeptest', seconds=5, tag='one') 30 job.profilers.delete('oprofile') 33 job.profilers.add('oprofile', None, [all …]
|
D | control.fs_options | 10 features of the job.partition method, such as creating loopback partitions 14 partition = job.partition(device='/tmp/looped', loop_size=1024, 15 mountpoint=job.tmpdir) 18 #partition = job.partition('/dev/sdb1', job.tmpdir) 31 job.run_test('fsx', dir=job.tmpdir, tag=tag) 32 job.run_test('iozone', dir=job.tmpdir, iterations=iters, tag=tag) 33 job.run_test('dbench', iterations=iters, dir=job.tmpdir, tag=tag) 34 job.run_test('tiobench', dir=job.tmpdir, tag=tag)
|
/external/toolchain-utils/automation/server/monitor/ |
D | dashboard.py | 44 job = self._job 46 group = [Link('/job-group/%d' % job.group.id, job.group.label)] 49 for pred in job.predecessors] 52 for succ in job.successors] 55 for mach in job.machines] 57 logs = [Link('/job/%d/log' % job.id, 'Log')] 59 commands = enumerate(job.PrettyFormatCommand().split('\n'), start=1) 61 return {'text': [('Label', job.label), ('Directory', job.work_dir)], 119 def _GetJobStatus(self, job): argument 121 return status_map.get(str(job.status), None) [all …]
|
/external/syslinux/gpxe/src/core/ |
D | job.c | 31 void job_done ( struct job_interface *job, int rc ) { in job_done() argument 32 struct job_interface *dest = job_get_dest ( job ); in job_done() 34 job_unplug ( job ); in job_done() 39 void job_kill ( struct job_interface *job ) { in job_kill() argument 40 struct job_interface *dest = job_get_dest ( job ); in job_kill() 42 job_unplug ( job ); in job_kill() 47 void job_progress ( struct job_interface *job, in job_progress() argument 49 struct job_interface *dest = job_get_dest ( job ); in job_progress() 64 void ignore_job_done ( struct job_interface *job __unused, int rc __unused ) { in ignore_job_done() 68 void ignore_job_kill ( struct job_interface *job __unused ) { in ignore_job_kill() [all …]
|
/external/autotest/site_utils/sponge_lib/ |
D | sponge_utils_functional_test.py | 97 test.job = self.mox.CreateMockAnything() 98 test.job.user = 'debug_user' 99 test.job.machines = ['host1'] 117 job = self.mox.CreateMockAnything() 118 job.started_time = datetime.datetime(2016, 8, 15, 0, 0, 0) 119 job.finished_time = datetime.datetime(2016, 8, 15, 1, 0, 0) 120 job.keyval_dict = {'drone': 'server1', 131 job.dir = os.path.join(self.tmp_dir, '123-debug_user/host1') 132 job.label = 'dummy_PassServer' 134 job.tests = [] [all …]
|
/external/autotest/client/site_tests/platform_CryptohomeTPMReOwn/ |
D | platform_CryptohomeTPMReOwn.py | 30 self.job.set_state("client_status", "Success") 33 self.job.set_state("client_status", "Success") 47 self.job.set_state("client_status", error_msg) 54 self.job.set_state("client_status", error_msg) 63 self.job.set_state("client_status", error_msg) 65 self.job.set_state("client_status", "Success") 77 self.job.set_state("client_status", error_msg) 84 self.job.set_state("client_status", error_msg) 90 self.job.set_state("client_status", error_msg) 93 self.job.set_state("client_status", "Success") [all …]
|
/external/autotest/tko/ |
D | db.py | 442 def insert_job(self, tag, job, parent_job_id=None, commit=None): argument 452 job.machine_idx = self.lookup_machine(job.machine) 453 if not job.machine_idx: 454 job.machine_idx = self.insert_machine(job, commit=commit) 455 elif job.machine: 458 self.update_machine_information(job, commit=commit) 463 'label': job.label, 464 'username': job.user, 465 'machine_idx': job.machine_idx, 466 'queued_time': job.queued_time, [all …]
|
/external/autotest/contrib/ |
D | compare_suite.py | 110 def __init__(self, job, suite_start_time=None, suite_end_time=None): argument 114 self.id = job.id 116 self.job = job 118 self.name = job.name.split('/')[-1] 135 self.log = JOB_URL % {'job_id': job.id, 'owner': job.owner, 229 for job in self.test_jobs: 230 tasks += [task for task in job.get_all_tasks() 251 for job in self.test_jobs: 252 tasks += [task for task in job.get_all_tasks() 329 parent_jobs = [job.parent_job_id for job in [all …]
|
/external/autotest/client/common_lib/ |
D | test.py | 32 def __init__(self, job, bindir, outputdir): argument 33 self.job = job 34 self.pkgmgr = job.pkgmgr 35 self.autodir = job.autodir 54 dir=job.tmpdir) 81 tap_report=self.job._tap) 222 tap_report=self.job._tap) 227 tap_report=self.job._tap) 325 if self.job.drop_caches_between_iterations: 339 if self.job.test_retry != 0: [all …]
|
D | base_job_unittest.py | 108 public_attributes = set(attr for attr in dir(self.job) 110 and not callable(getattr(self.job, attr))) 128 self.assertNotEqual(getattr(self.job, attribute, None), None, 143 auto, client, server = self.job._find_base_directories() 148 auto, client, server = self.job._find_base_directories() 154 job = base_job.base_job.__new__(base_job.base_job) 155 job._job_directory = stub_job_directory 156 job._autodir = stub_job_directory(autodir) 158 job._clientdir = stub_job_directory( 160 job._serverdir = stub_job_directory( [all …]
|
/external/autotest/scheduler/ |
D | monitor_db_functional_test.py | 433 job, queue_entry = self._make_job_and_queue_entry() 444 job, queue_entry = self._make_job_and_queue_entry() 445 job.reboot_before = model_attributes.RebootBefore.ALWAYS 446 job.save() 507 job, queue_entry = self._make_job_and_queue_entry() 508 job.reboot_after = model_attributes.RebootAfter.ALWAYS 509 job.save() 605 job, queue_entry = self._make_job_and_queue_entry() 619 queue_entry.job.reboot_before = model_attributes.RebootBefore.ALWAYS 620 queue_entry.job.save() [all …]
|
D | scheduler_models_unittest.py | 222 job = self._create_job(**create_job_kwargs) 224 job.dependency_labels.add(label) 225 hqes = list(scheduler_models.HostQueueEntry.fetch(where='job_id=%d' % job.id)) 302 hqe.job.update_field('shard_id', 3) 307 self.assertIsNone(hqe.job.shard_id) 310 self.assertEquals(hqe.job.shard_id, 3) 332 queue_entry.job.reboot_before = reboot_before 339 job = scheduler_models.Job(django_job.id) 340 job.request_abort() 341 django_hqes = list(models.HostQueueEntry.objects.filter(job=job.id)) [all …]
|
/external/autotest/server/ |
D | autoserv_utils.py | 25 results_directory=None, extra_args=[], job=None, 97 if job or queue_entry: 98 if not job: 99 job = queue_entry.job 101 owner = getattr(job, 'owner', None) 102 name = getattr(job, 'name', None) 103 test_retry = getattr(job, 'test_retry', None) 104 control_type = getattr(job, 'control_type', None) 140 def _autoserv_command_line(machines, extra_args, job=None, queue_entry=None, argument 163 extra_args=extra_args, job=job, queue_entry=queue_entry,
|