| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| __init__.py | 2 """Map job package."""
12 from .map_job_control import Job
|
| map_job_control.py | 2 """User API for controlling Map job execution."""
15 class Job(object):
16 """The job submitter's view of the job.
18 The class allows user to submit a job, control a submitted job,
30 """Init the job instance representing the job with id job_id.
46 """Gets the job instance representing the job with id job_id
[all...] |
| /external/chromium-trace/catapult/tracing/tracing/mre/ |
| job.py | 9 class Job(object):
34 return Job(
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/glacier/ |
| job.py | 31 class Job(object):
60 return 'Job(%s)' % self.arn
64 This operation downloads the output of the job. Depending on
65 the job type you specified when you initiated the job, the
69 You can download all the job output or download a portion of
71 archive retrieval job, depending on the byte range you
|
| vault.py | 26 from boto.glacier.job import Job
272 Initiate a archive retrieval job to download the data from an
281 :param description: An optional description for the job.
285 sends notification when the job is completed and the output
288 :rtype: :class:`boto.glacier.job.Job`
289 :return: A Job object representing the retrieval job.
306 Initiate a inventory retrieval job to list the items in th
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/glacier/ |
| test_job.py | 25 from boto.glacier.job import Job
36 self.job = Job(self.vault)
42 with mock.patch('boto.glacier.job.tree_hash_from_str') as t:
44 self.job.get_output(byte_range=(1, 1024), validate_checksum=True)
50 with mock.patch('boto.glacier.job.tree_hash_from_str') as t:
54 self.job.get_output(byte_range=(1, 1024), validate_checksum=True)
56 self.job.get_output(byte_range=(1, 1024), validate_checksum=False)
64 self.job.archive_size =
[all...] |
| test_vault.py | 29 from boto.glacier.job import Job
107 if key == 'x-amz-job-id':
124 "JobDescription": "My ArchiveRetrieval Job",
135 init_resp = GlacierResponse(raw_resp, [('x-amz-job-id', 'JobId')])
146 # The variant the returns a full ``Job`` object.
147 job = self.vault.retrieve_inventory_job()
148 self.assertTrue(isinstance(job, Job))
149 self.assertEqual(job.id, 'HkF9p6'
[all...] |
| test_layer2.py | 33 from boto.glacier.vault import Job
91 "JobDescription": "My ArchiveRetrieval Job",
222 self.mock_layer1.initiate_job.return_value = {'JobId': 'job-id'}
238 job = self.vault.get_job(
242 self.assertEqual(job.action, "ArchiveRetrieval")
303 self.job = Job(self.vault, FIXTURE_ARCHIVE_JOB)
307 self.job.get_output((0, 100))
|
| /external/v8/test/mjsunit/compiler/ |
| regress-8.js | 39 var Job = "";
70 c.append(gp,yE,W,LA+(a.Un+(zE+(Fp+(LA+(a.Im+Job))))),p);
|
| /external/jetty/src/java/org/eclipse/jetty/util/ |
| IO.java | 70 static class Job implements Runnable
77 Job(InputStream in,OutputStream out)
84 Job(Reader read,Writer write)
128 Job job=new Job(in,out); local
129 if (!Singleton.__pool.dispatch(job))
130 job.run();
155 Job job=new Job(in,out) local
[all...] |
| /external/regex-re2/re2/ |
| bitstate.cc | 25 struct Job {
66 Job *job_; // stack of text positions to explore
108 Job* newjob = new Job[maxjob_];
113 LOG(DFATAL) << "Job stack overflow.";
134 Job* j = &job_[njob_++];
148 // Pop job off stack.
168 // VLOG(0) << "Job: " << ip->id() << " "
326 job_ = new Job[maxjob_];
|
| /external/v8/tools/testrunner/local/ |
| execution.py | 117 class Job(object):
124 """Executes the job.
143 class TestJob(Job):
182 def RunTest(job, process_context):
183 return job.Run(process_context)
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/ |
| ThreadPool.java | 43 // A Job is like a Callable, but it has an addition JobContext parameter.
44 public interface Job<T> {
95 // Submit a job to the thread pool. The listener will be called when the
96 // job is finished (or cancelled).
97 public <T> Future<T> submit(Job<T> job, FutureListener<T> listener) {
98 Worker<T> w = new Worker<T>(job, listener);
103 public <T> Future<T> submit(Job<T> job) {
104 return submit(job, null)
[all...] |
| /external/autotest/frontend/afe/ |
| resources.py | 433 _job_fields = models.Job.get_field_dict()
460 'job'),
474 def execution_info_from_job(cls, job):
475 return {'control_file': job.control_file,
477 job.control_type == control_data.CONTROL_TYPE.SERVER,
479 in job.dependency_labels.all()],
480 'machines_per_execution': job.synch_count,
481 'run_verify': bool(job.run_verify),
482 'run_reset': bool(job.run_reset),
483 'timeout_mins': job.timeout_mins
[all...] |
| models.py | 27 # job options and user preferences
43 scheduled for a job at the same time as other hosts sharing that label.
49 The job.synch_count is considered the minimum.
72 def enqueue_job(self, job, is_template=False):
73 """Enqueue a job on an associated atomic group of hosts.
75 @param job: A job to enqueue.
78 queue_entry = HostQueueEntry.create(atomic_group=self, job=job,
105 label is requested by the job/test (either as the meta_host o
1112 def job(self): member in class:ParameterizedJob
1690 job = dbmodels.ForeignKey(Job) variable in class:JobKeyval
1733 job = dbmodels.ForeignKey(Job) variable in class:IneligibleHostQueue
1768 job = dbmodels.ForeignKey(Job) variable in class:HostQueueEntry
1988 job = dbmodels.ForeignKey(Job) variable in class:RecurringRun
[all...] |
| /frameworks/base/packages/DocumentsUI/src/com/android/documentsui/services/ |
| Job.java | 60 abstract public class Job implements Runnable {
61 private static final String TAG = "Job";
83 * A simple progressable job, much like an AsyncTask, but with support
87 * @param service The service context in which this job is running.
96 Job(Context service, Context appContext, Listener listener,
119 // handled within Job implementations. However, just in case catch them here.
278 .append("Job")
292 Job createCopy(Context service, Context appContext, Listener listener,
299 Job createMove(Context service, Context appContext, Listener listener,
307 Job createDelete(Context service, Context appContext, Listener listener
[all...] |
| /external/autotest/server/ |
| frontend.py | 44 Standard way to print out the frontend objects (eg job, host, acl, label)
142 """Get job test statuses from the database.
144 Retrieve a set of fields from a job that reflect the status of each test
145 run within a job.
149 @param job_id: The afe job id to look up.
177 def get_status_counts(self, job, **data):
180 job_tag__startswith='%s-' % job, **data)
186 reply_debug=False, job=None):
187 self.job = job
[all...] |
| /external/autotest/frontend/tko/ |
| models.py | 170 class Job(dbmodels.Model, model_logic.ModelExtensions):
171 """Models a job."""
185 """Metadata for class Job."""
190 """Models a job keyval."""
191 job = dbmodels.ForeignKey(Job) variable in class:JobKeyval
204 job = dbmodels.ForeignKey(Job, db_column='job_idx') variable in class:Test
530 query_set = Job.objects.join_custom_field(query_set, keyval_query,
564 * job_keyval_fields: list of job keyval names. Each value will b
[all...] |
| /external/autotest/scheduler/ |
| scheduler_models.py | 8 (particularly HostQueueEntry and Job) have considerable scheduler-specific logic
14 one of these statuses, an email will be sent to the job's email_list.
79 def get_job_metadata(job):
80 """Get a dictionary of the job information.
82 The return value is a dictionary that includes job information like id,
83 name and parent job information. The value will be stored in metadata
86 @param job: A Job object.
87 @return: A dictionary containing the job id, owner and name.
89 if not job
[all...] |
| /external/emma/core/java12/com/vladium/emma/instr/ |
| InstrProcessorST.java | 234 // class def modified: write it to an array and submit a write job
262 // clone the array and submit an entry write job
486 // class def modified: write it to an array and submit a write job
499 // clone the array and submit a file write job
577 // in overwrite mode, flush the job queue before going to the next directory:
702 // reset job queue position:
939 final Job job = m_jobs [j]; local
[all...] |
| /external/mksh/src/ |
| jobs.c | 54 #define JP_MEDIUM 2 /* print [job-num] -/+ command */
55 #define JP_LONG 3 /* print [job-num] -/+ pid command */
62 /* Job.flags values */
63 #define JF_STARTED 0x001 /* set when all processes in job are started */
64 #define JF_WAITING 0x002 /* set if j_waitj() is waiting on job */
76 typedef struct job Job;
77 struct job { struct
78 Job *next; /* next job in list *
85 int job; \/* job number: %n *\/ member in struct:job
1653 int job = 0; local
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.ddms/src/com/android/ide/eclipse/ddms/ |
| DdmsPlugin.java | 44 import org.eclipse.core.runtime.jobs.Job;
279 * in a Job to ensure that DDMS is loaded, so that the other plug-ins can load.
292 // get the other configElements and instantiante them in a Job.
293 new Job(Messages.DdmsPlugin_DDMS_Post_Create_Init) {
[all...] |
| /external/clang/lib/AST/ |
| ExprConstant.cpp | 7143 Job &job = Queue.back(); local
[all...] |
| /external/icu/tools/srcgen/currysrc/libs/ |
| org.eclipse.core.jobs_3.7.0.v20150330-2103.jar | |
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/ |
| org.eclipse.core.jobs_3.5.1.R36x_v20100824.jar | |
