| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| __init__.py | 2 """Map job package."""
12 from .map_job_control import Job
|
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/project/ |
| BaseClasspathContainerInitializer.java | 29 import org.eclipse.core.runtime.jobs.Job;
54 // Use a job to prevent requiring a workspace lock in this thread.
56 Job markerJob = new Job("Android SDK: Resolving error markers") {
66 // Don't return e2.getStatus(); the job control will then produce
76 markerJob.setPriority(Job.BUILD);
80 // Use a job to prevent requiring a workspace lock in this thread.
81 Job markerJob = new Job("Android SDK: Resolving error markers") {
98 markerJob.setPriority(Job.BUILD)
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| SnailItem.java | 23 import com.android.gallery3d.util.ThreadPool.Job;
39 public Job<Bitmap> requestImage(int type) {
41 return new Job<Bitmap>() {
50 public Job<BitmapRegionDecoder> requestLargeImage() {
52 return new Job<BitmapRegionDecoder>() {
|
| PanoramaMetadataJob.java | 24 import com.android.gallery3d.util.ThreadPool.Job;
27 public class PanoramaMetadataJob implements Job<PanoramaMetadata> {
|
| ActionImage.java | 27 import com.android.gallery3d.util.ThreadPool.Job;
43 public Job<Bitmap> requestImage(int type) {
48 public Job<BitmapRegionDecoder> requestLargeImage() {
52 private class BitmapJob implements Job<Bitmap> {
|
| MediaItem.java | 24 import com.android.gallery3d.util.ThreadPool.Job;
53 public abstract Job<Bitmap> requestImage(int type);
54 public abstract Job<BitmapRegionDecoder> requestLargeImage();
|
| /frameworks/base/packages/DocumentsUI/tests/src/com/android/documentsui/services/ |
| TestJobListener.java | 31 public class TestJobListener implements Job.Listener {
34 private final List<Job> progress = new ArrayList<>();
35 @Nullable private Job started;
36 @Nullable private Job finished;
39 public void onStart(Job job) {
40 started = job;
44 public void onFinished(Job job) {
45 this.finished = job;
[all...] |
| /external/chromium-trace/catapult/tracing/tracing/mre/ |
| job.py | 9 class Job(object):
34 return Job(
|
| failure_unittest.py | 9 from tracing.mre import job as job_module
22 job = job_module.Job(map_function_handle, '1')
23 failure = failure_module.Failure(job, 'foo.html:Foo',
38 job = job_module.Job(map_function_handle, '1')
49 failure = failure_module.Failure.FromDict(failure_dict, job)
51 self.assertEquals(failure.job.guid, '1')
|
| /sdk/eclipse/plugins/com.android.ide.eclipse.monitor/src/com/android/ide/eclipse/monitor/ |
| MonitorStartup.java | 25 import org.eclipse.core.runtime.jobs.Job;
37 Job pingJob = new Job("Android SDK Ping") {
51 pingJob.setPriority(Job.DECORATE); // lowest priority
|
| /packages/apps/Gallery2/src/com/android/gallery3d/util/ |
| JobLimiter.java | 20 import com.android.gallery3d.util.ThreadPool.Job;
41 private static class JobWrapper<T> implements Future<T>, Job<T> {
43 private Job<T> mJob;
48 public JobWrapper(Job<T> job, FutureListener<T> listener) {
49 mJob = job;
105 Job<T> job = null; local
108 job = mJob;
112 result = job.run(jc)
[all...] |
| /external/autotest/frontend/ |
| django_lite_unittest.py | 24 self.assertEqual(1, models.Job.objects.all().count())
|
| /prebuilts/go/darwin-x86/test/bench/shootout/ |
| fannkuch-parallel.go | 49 type Job struct {
63 in chan Job
71 in: make(chan Job),
108 for job := range k.in {
110 copy(k.perm, job.start)
130 if !k.permute(job.n) {
142 jobs []Job
148 func NewFanner(jobs []Job, workers []*Kucher) *Fanner {
194 jobs := make([]Job, njobs)
201 jobs[jobsind] = Job{base, firstN
[all...] |
| /prebuilts/go/linux-x86/test/bench/shootout/ |
| fannkuch-parallel.go | 49 type Job struct {
63 in chan Job
71 in: make(chan Job),
108 for job := range k.in {
110 copy(k.perm, job.start)
130 if !k.permute(job.n) {
142 jobs []Job
148 func NewFanner(jobs []Job, workers []*Kucher) *Fanner {
194 jobs := make([]Job, njobs)
201 jobs[jobsind] = Job{base, firstN
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.hierarchyviewer/src/com/android/ide/eclipse/hierarchyviewer/ |
| HierarchyViewerPluginDirector.java | 29 import org.eclipse.core.runtime.jobs.Job;
43 Job job = new Job(taskName) { local
50 job.setPriority(Job.SHORT);
51 job.setRule(mSchedulingRule);
52 job.schedule();
|
| /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...] |
| /external/autotest/server/cros/ |
| repair_utils_unittest.py | 43 """Test that we properly find the last ran job."""
64 """Test that, for a given host, we get the last job ran on that host."""
69 old_job = models.Job(owner='me', name='old_job',
73 job=old_job, host=host, status='test',
77 new_job = models.Job(owner='me', name='new_job',
81 job=new_job, host=host, status='test',
94 self.assertEqual(result['job']['name'], 'new_job')
98 """Test that we only get a job that is for the given host."""
100 correct_job = models.Job(owner='me', name='correct_job',
106 job=correct_job, host=correct_host, status='test'
[all...] |
| /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/health/ |
| 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
[all...] |
| /frameworks/base/packages/DocumentsUI/src/com/android/documentsui/services/ |
| FileOperationService.java | 34 import com.android.documentsui.services.Job.Factory;
48 public class FileOperationService extends Service implements Job.Listener {
87 // The executor and job factory are visible for testing and non-final
110 jobFactory = Job.Factory.instance;
154 Job job = null; local
164 job = createJob(operationType, jobId, srcs, srcParent, stack);
166 if (job == null) {
173 assert(job != null);
177 TAG, "Scheduling job " + job.id + " to run in " + delay + " milliseconds.")
335 private final Job job; field in class:FileOperationService.JobRecord
[all...] |
| 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/site_utils/ |
| count_jobs.py | 25 return models.Job.objects.filter(created_on__gt=cutoff).count()
|
| /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_];
|
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/lint/ |
| EclipseLintRunner.java | 29 import org.eclipse.core.runtime.jobs.Job;
62 LintJob job = (LintJob) startLint(resources, source, doc, fatalOnly, local
65 job.join();
66 boolean fatal = job.isFatal();
81 * Runs lint and updates the markers. Does not wait for the job to finish -
95 * @return the job running lint in the background.
97 public static Job startLint(
109 * Runs lint and updates the markers. Does not wait for the job to finish -
122 * @return the job running lint in the background.
124 public static Job startLint
136 LintJob job = new LintJob(client, resources, source); local
[all...] |
| /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...] |
