| /external/autotest/tko/parsers/ |
| 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
[all...] |
| /external/autotest/client/bin/ |
| harness.py | 19 job
20 The job object for this job
23 def __init__(self, job):
25 job
26 The job object for this job
28 self.setup(job)
31 def setup(self, job):
33 job
[all...] |
| job_unittest.py | 12 from autotest_lib.client.bin import job, sysinfo, harness
21 """Generic job TestCase class that defines a standard job setUp and
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()
54 """Generic client job mixin used when defining variations on th
[all...] |
| harness_simple.py | 14 job
15 The job object for this job
18 def __init__(self, job, harness_args):
20 job
21 The job object for this job
23 self.setup(job)
29 """A test within this job is completing"""
|
| /external/autotest/server/cros/dynamic_suite/ |
| job_status_unittest.py | 47 def expect_result_gathering(self, job):
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):
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
[all...] |
| /external/autotest/server/ |
| autoserv_utils.py | 25 results_directory=None, extra_args=[], job=None,
36 Construct an autoserv command from a job or host queue entry.
41 job on. Leave as None or empty string for hostless job
47 @param job: Job object. If supplied, -u owner, -l name, and --test-retry,
49 @param queue_entry: HostQueueEntry object. If supplied and no job
50 was supplied, this will be used to lookup the job.
97 if job or queue_entry:
98 if not job
[all...] |
| /packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/job/ |
| DishService.java | 16 package com.google.android.car.kitchensink.job;
18 import android.app.job.JobParameters;
19 import android.app.job.JobService;
42 JobParameters job = (JobParameters) msg.obj;
45 Log.d(TAG, "Job done! " + job.getJobId());
46 mTaskMap.remove(job.getJobId());
47 jobFinished(job, false);
50 DishWasherTask task = new DishWasherTask(this, job, msg.arg1);
52 mTaskMap.put(job.getJobId(), job)
[all...] |
| /packages/apps/DocumentsUI/src/com/android/documentsui/services/ |
| FileOperationService.java | 50 public class FileOperationService extends Service implements Job.Listener {
97 // The executor and job factory are visible for testing and non-final
120 // The job whose notification is used to keep the service in foreground mode.
121 private final AtomicReference<Job> mForegroundJob = new AtomicReference<>();
220 Log.w(TAG, "Duplicate job id: " + jobId
221 + ". Ignoring job request for operation: " + operation + ".");
225 Job job = operation.createJob(this, this, jobId, features); local
227 if (job == null) {
231 assert (job != null)
430 private final Job job; field in class:FileOperationService.JobRecord
[all...] |
| /external/autotest/server/cros/ |
| provision_actionables.py | 17 def execute(self, job, host, *args, **kwargs):
20 @param job: A job object from a control file.
45 def execute(self, job, host, *args, **kwargs):
48 @param job: A job object from a control file.
56 return job.run_test(self.test, host=host, *args, **kwargs)
62 def execute(self, job, host, *args, **kwargs):
65 @param job: A job object from a control file
[all...] |
| /external/autotest/server/hosts/ |
| base_classes.py | 59 if self.job:
60 self.job.hosts.add(self)
73 if self.job:
74 self.job.hosts.discard(self)
|
| /external/syslinux/gpxe/src/include/gpxe/ |
| downloader.h | 15 extern int create_downloader ( struct job_interface *job, struct image *image,
|
| /packages/apps/StorageManager/src/com/android/storagemanager/automatic/ |
| AutomaticStorageBroadcastReceiver.java | 19 import android.app.job.JobInfo;
20 import android.app.job.JobScheduler;
29 * schedule an automatic storage management job. Automatic storage management jobs are only
45 JobInfo job = new JobInfo.Builder(AUTOMATIC_STORAGE_JOB_ID, component) local
50 jobScheduler.schedule(job);
|
| /external/autotest/client/tests/fio/ |
| fio.py | 11 job = os.path.join(self.bindir, 'fio-mixed.job')
12 utils.system(' '.join(['fio', '--output', log, job]))
|
| /external/v8/src/heap/ |
| incremental-marking-job.h | 16 // The incremental marking job uses platform tasks to perform incremental
17 // marking steps. The job posts a foreground task that makes a small (~1ms)
23 explicit Task(Isolate* isolate, IncrementalMarkingJob* job)
24 : CancelableTask(isolate), job_(job) {}
|
| /frameworks/ex/camera2/portability/src/com/android/ex/camera2/portability/ |
| DispatchThread.java | 38 super("Camera Job Dispatch Thread");
46 * Queues up the job.
48 * @param job The job to run.
50 public void runJob(Runnable job) {
53 "Trying to run job on interrupted dispatcher thread");
57 throw new RuntimeException("Camera master thread job queue full");
60 mJobQueue.add(job);
66 * Queues up the job and wait for it to be done.
68 * @param job The job to run
112 Runnable job = null; local
[all...] |
| /external/autotest/client/tests/profiler_sync/ |
| profiler_sync.py | 26 profilers = self.job.profilers
29 b0 = self.job.barrier(hostid, "sync_profilers", timeout_start,
33 b1 = self.job.barrier(hostid, "start_profilers", timeout_start,
37 b2 = self.job.barrier(hostid, "local_sync_profilers", timeout_sync)
42 b3 = self.job.barrier(hostid, "stop_profilers", timeout_stop,
49 b4 = self.job.barrier(hostid, "finish_profilers", timeout_stop,
|
| /external/v8/src/compiler-dispatcher/ |
| optimizing-compile-dispatcher.cc | 20 void DisposeCompilationJob(CompilationJob* job, bool restore_function_code) {
22 Handle<JSFunction> function = job->info()->closure();
29 delete job;
94 CompilationJob* job = input_queue_[InputQueueIndex(0)];
95 DCHECK_NOT_NULL(job);
101 DisposeCompilationJob(job, true);
105 return job;
108 void OptimizingCompileDispatcher::CompileNext(CompilationJob* job) {
109 if (!job) return;
112 CompilationJob::Status status = job->ExecuteJob()
125 CompilationJob* job = NULL; local
142 CompilationJob* job = input_queue_[InputQueueIndex(0)]; local
190 CompilationJob* job = NULL; local
[all...] |
| /frameworks/base/services/core/java/com/android/server/job/controllers/ |
| JobStatus.java | 17 package com.android.server.job.controllers;
21 import android.app.job.JobInfo;
22 import android.app.job.JobWorkItem;
33 import com.android.server.job.GrantedUriPermissions;
40 * Uniquely identifies a job internally.
41 * Created from the public {@link android.app.job.JobInfo} object when it lands on the scheduler.
42 * Contains current state of the requirements of the job, as well as a function to evaluate
91 final JobInfo job; field in class:JobStatus
92 /** Uid of the package requesting this job. */
110 * Earliest point in the future at which this job will be eligible to run. A value of
[all...] |
| StateController.java | 17 package com.android.server.job.controllers;
21 import com.android.server.job.JobSchedulerService;
22 import com.android.server.job.StateChangedListener;
45 * Implement the logic here to decide whether a job should be tracked by this controller.
52 * Optionally implement logic here to prepare the job to be executed.
62 * Called when a new job is being created to reschedule an old failed job.
|
| /external/autotest/site_utils/sponge_lib/ |
| 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/syslinux/gpxe/src/core/ |
| downloader.c | 26 #include <gpxe/job.h>
43 /** Job control interface */
44 struct job_interface job; member in struct:downloader
78 job_nullify ( &downloader->job );
83 job_done ( &downloader->job, rc );
119 * Job control interface
124 * Handle kill() event received via job control interface
126 * @v job Downloader job control interface
128 static void downloader_job_kill ( struct job_interface *job ) {
[all...] |
| /external/autotest/client/tests/barriertest/ |
| barriertest.py | 17 self.job.barrier(our_addr, 'First', timeout=timeout,
23 self.job.barrier(our_addr, 'Second', timeout=timeout,
31 self.job.barrier(our_addr, 'WillAbort', timeout=timeout,
39 self.job.record('WARN', None, 'barriertest',
47 self.job.barrier(our_addr, 'FinalSync', timeout=timeout,
55 self.job.barrier(our_addr, 'WillAbortServers', timeout=timeout,
63 self.job.record('WARN', None, 'barriertest',
|
| /external/toolchain-utils/automation/common/ |
| job_group.py | 42 for job in jobs:
43 self.AddJob(job)
55 return os.path.join(self.HOMEDIR_PREFIX, 'job-group-%d' % self.id)
68 return '\n'.join(['Job-Group:', 'ID: %s' % self.id] + [str(
69 job) for job in self.jobs])
71 def AddJob(self, job):
72 self.jobs.append(job)
73 job.group = self
|
| /external/autotest/scheduler/ |
| only_if_needed_unittests.py | 24 job = self._setup_test_only_if_needed_labels()
25 # if the job doesn't depend on label3, there should be no scheduling
31 job = self._setup_test_only_if_needed_labels()
32 job.dependency_labels.add(self.label3)
39 job = self._setup_test_only_if_needed_labels()
40 job.dependency_labels.add(self.label3)
52 that job.
|
| /external/autotest/client/site_tests/platform_DaemonsRespawn/ |
| test_respawn.sh | 12 # Verifies that the given job is running and returns the pid.
26 echo "Job $upstart_job is not running."
30 # Now make sure that upstart has the pid that we would expect for this job
33 echo "Upstart not able to track pid for job: $upstart_job"
38 echo "Unable to find running job for daemon: $daemon"
54 for job in $UPSTART_JOBS_TO_TEST ; do
56 JOB=$(echo "$job" | awk -F':' '{ print $1 }')
57 DAEMON=$(echo "$job" | awk -F':' '{ print $2 }')
59 get_job_pid "$JOB" "$DAEMON
[all...] |
