| /external/autotest/client/tests/aiostress/ |
| aiostress.py | 11 self.job.require_gcc()
12 self.job.setup_dep(['libaio'])
|
| /external/autotest/client/tests/dbt2/ |
| dbt2.py | 12 self.job.require_gcc()
19 self.job.setup_dep(['pgsql', 'pgpool', 'mysql'])
|
| /external/autotest/frontend/afe/feeds/ |
| feed.py | 58 # bits[0] should be a job status
67 return '%s/%s-%s' % (self.full_link, obj.job.id, obj.job.owner)
|
| /external/autotest/scheduler/shard/ |
| shard_client.py | 71 - Find objects that the Host/Job objects depend on: Labels, AclGroups, Users,
82 3. Once a job is finished, it's shard_id is set to NULL
165 self._deserialize_many(jobs_serialized, models.Job, 'job')
180 # heartbeat or job is silently dropped, as the next heartbeat will
183 job_models = models.Job.objects.filter(
187 job_ids_repr = ', '.join([str(job.id) for job in job_models])
213 # The scheduler sets shard to None upon completion of the job.
215 # models.Job.shard. We need to be careful to wait for both th
[all...] |
| /external/autotest/server/control_segments/ |
| get_network_stats | 57 job.parallel_simple(get_network_stats, machines)
|
| /external/autotest/server/cros/clique_lib/ |
| clique_runner.py | 75 def _collect_dut_pool_logs(dut_objects, job):
81 @param job: Autotest job object to be used for log collection.
86 log_collector.collect_logs(dut_objects, job)
161 def _are_all_conn_workers_healthy(workers, aps, assoc_params_list, job):
170 @param job: the Autotest job object.
176 if not utils.is_conn_worker_healthy(worker, ap, assoc_params, job):
201 def run(self, job, tries=10, capturer_hostname=None,
206 @param job: an Autotest job object
[all...] |
| /external/autotest/server/tests/netperf2/ |
| netperf2.py | 31 # job, let the forked tests record their entries, then restore the
33 self.job._indenter.decrement()
38 template = ''.join(["job.run_test('netperf2', server_ip='%s', ",
63 # Restore indent level of main job.
64 self.job._indenter.increment()
|
| /external/autotest/server/tests/netpipe/ |
| netpipe.py | 30 # job, let the forked tests record their entries, then restore the
32 self.job._indenter.decrement()
37 template = ''.join(["job.run_test('netpipe', server_ip='%s', ",
64 # Restore indent level of main job.
65 self.job._indenter.increment()
|
| /external/autotest/tko/ |
| plotgraph | 14 # First column must be kernel count, second kernel version, third is job number
31 ($count, my $version, my $job) = split (/\s+/, $data);
33 $short_ver =~ s/\+.*/+p$job/;
|
| /external/ltp/testcases/kernel/controllers/cpuacct/ |
| cpuacct.sh | 100 for job in `jobs -p`; do
101 wait $job
|
| /packages/apps/StorageManager/robotests/src/com/android/storagemanager/automatic/ |
| AutomaticStorageBroadcastReceiverTest.java | 19 import android.app.job.JobInfo;
20 import android.app.job.JobScheduler;
|
| /packages/providers/DownloadProvider/src/com/android/providers/downloads/ |
| DownloadJobService.java | 23 import android.app.job.JobParameters;
24 import android.app.job.JobService;
30 * Service that hosts download jobs. Each active download job is handled as a
34 * given download isn't able to finish in the normal job timeout (10 minutes),
35 * we just reschedule the job and resume again in the future.
100 // Update notifications one last time while job is protecting us
|
| DownloadIdleService.java | 23 import android.app.job.JobInfo;
24 import android.app.job.JobParameters;
25 import android.app.job.JobScheduler;
26 import android.app.job.JobService;
89 final JobInfo job = new JobInfo.Builder(IDLE_JOB_ID, local
95 scheduler.schedule(job);
|
| /external/autotest/server/hosts/ |
| remote.py | 60 is created for a specific host after a job starts.
207 if self.job:
208 self.job.profilers.handle_reboot(self)
248 if self.job:
249 keyval_path = os.path.join(self.job.resultdir, 'host_keyvals',
261 if self.job:
262 keyval_path = os.path.join(self.job.resultdir, 'host_keyvals',
|
| /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/action/ |
| KlpActionLabelTests.java | 78 final RunInLocale<Void> job = new RunInLocale<Void>() { local
80 public Void job(final Resources res) {
86 job.runInLocale(getContext().getResources(), systemLocale);
136 final RunInLocale<Void> job = new RunInLocale<Void>() { local
138 public Void job(final Resources res) {
144 job.runInLocale(getContext().getResources(), systemLocale);
|
| /packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/job/ |
| JobSchedulerFragment.java | 16 package com.google.android.car.kitchensink.job;
18 import android.app.job.JobInfo;
19 import android.app.job.JobScheduler;
107 for (JobInfo job : jobs) {
109 sb.append(job.getId());
111 sb.append(job.getExtras().getInt(DishService.EXTRA_DISH_COUNT, 0));
158 Log.d(TAG, "Scheduled a job: " + jobInfo);
|
| /external/autotest/frontend/afe/ |
| rpc_interface_unittest.py | 129 job = self._create_job(hosts=xrange(1, 4))
130 entries = list(job.hostqueueentry_set.all())
142 job_summaries = rpc_interface.get_jobs_summary(id=job.id)
152 set(job.id for job in expected_jobs))
159 def set_hqe_statuses(job, first_status, second_status):
160 entries = job.hostqueueentry_set.all()
218 job = self._create_job_helper(one_time_hosts=['testhost'])
237 job = models.Job.objects.get(pk=job_id
[all...] |
| /external/autotest/scheduler/ |
| rdb_testing_utils.py | 164 def add_deps_to_job(cls, job, dep_names=set([])):
168 job.dependency_labels.add(*label_objects)
173 """Assign a job to a shard.
175 @param job: A job object without a shard.
176 @param shard_hostname: The hostname of a shard to assign the job.
178 @raises ValueError: If the job already has a shard.
180 job_filter = models.Job.objects.filter(id=job_id, shard__isnull=True)
182 raise ValueError('Failed to assign job %s to shard %s' %
212 deps: The labels on the host that match job deps
[all...] |
| /external/v8/src/ |
| compiler.cc | 359 // job.
407 CompilationJob::Status FinalizeUnoptimizedCompilationJob(CompilationJob* job) {
408 CompilationJob::Status status = job->FinalizeJob();
410 InstallUnoptimizedCode(job->info());
411 job->RecordUnoptimizedCompilationStats();
430 std::unique_ptr<CompilationJob> job(GetUnoptimizedCompilationJob(info));
431 if (job->PrepareJob() != CompilationJob::SUCCEEDED) return false;
432 if (job->ExecuteJob() != CompilationJob::SUCCEEDED) return false;
433 if (FinalizeUnoptimizedCompilationJob(job.get()) !=
527 bool GetOptimizedCodeNow(CompilationJob* job) {
[all...] |
| /external/autotest/client/common_lib/ |
| test_unittest.py | 26 self.job = MockJob()
27 self.job.default_profile_only = False
28 self.job.profilers = MockProfilerManager()
29 self.job.test_retry = 0
106 self.god.stub_function(self.test.job, 'record')
115 if run != self.test.job.test_retry and isinstance(error,
117 self.test.job.record.expect_call('INFO', None, None, info_str)
124 self.test.job.test_retry = 5
132 self._setup_failed_test_calls(self.test.job.test_retry+1, error)
147 self.test.job.test_retry =
[all...] |
| /external/autotest/server/ |
| site_crashcollect.py | 68 @param resultdir: server job's result directory.
96 @param host_resultdir: server job's result directory.
184 host.job.record('INFO', None, None,
190 host.job.record('INFO', None, None,
243 return getattr(getattr(host, 'job', None), 'resultdir', None)
269 # Record all crashdumps in status.log of the job:
270 # - If one server job runs several client jobs we will only record
271 # crashdumps in the status.log of the high level server job.
274 if host.job and minidumps or orphans:
275 host.job.record('INFO', None, None, 'Start crashcollection record'
[all...] |
| /tools/test/connectivity/acts/framework/acts/controllers/utils_lib/ssh/ |
| connection.py | 27 from acts.libs.proc import job
76 for use with the background job.
132 self._master_ssh_proc = job.run_async(master_cmd)
166 A job.Result containing the results of the ssh command.
169 job.TimeoutError: When the remote command took to long to execute.
194 result = job.run(terminal_command,
207 result = job.Result(
216 raise job.Error(result)
253 raise Error('The job failed for unkown reasons.', result)
268 The result of the command to launch the background job
[all...] |
| /external/autotest/server/cros/chaos_lib/ |
| static_runner.py | 47 def run(self, job, batch_size=10, tries=10, capturer_hostname=None,
52 @param job: an Autotest job object.
140 batch_locker, job)
156 ap, capturer, job, self._ap_spec)
178 conn_worker, ap, assoc_params, job):
201 result = job.run_test(self._test,
|
| /external/toolchain-utils/automation/clients/helper/ |
| crosstool.py | 11 from automation.common import job
22 checkout_dir_dep = job.FolderDependency(new_job,
24 manifests_dir_dep = job.FolderDependency(
32 build_tree_dep = job.FolderDependency(new_job,
42 testrun_dir_dep = job.FolderDependency(
148 env={'REMOTE_TMPDIR': 'job-$JOB_ID'})
|
| /device/huawei/angler/camera/QCamera2/HAL/ |
| QCameraPostProc.cpp | 382 // dataProc Thread need to process "stop" as sync call because abort jpeg job should be a sync call
407 * DESCRIPTION: function to prepare encoding job information
793 ALOGE("%s: No memory for pproc job", __func__);
833 ALOGE("%s: No memory for jpeg job", __func__);
906 * NOTE : This event will also trigger DataProc thread to move to next job
907 * processing (i.e., send a new jpeg encoding job to mm-jpeg-interfac
1074 qcamera_pp_data_t *job = (qcamera_pp_data_t *)m_ongoingPPQ.dequeue(); local
1231 qcamera_jpeg_data_t * job = NULL; local
1492 qcamera_jpeg_data_t *job = pme->findJpegJobByJobId(job_data->jobId); local
2921 qcamera_jpeg_data_t * job = (qcamera_jpeg_data_t *) data; local
[all...] |
