| /external/chromium_org/net/url_request/ |
| url_request_job_factory_impl.cc | 54 URLRequestJob* job = g_interceptor_for_testing->MaybeInterceptRequest( local
56 if (job)
57 return job;
|
| url_request_ftp_job_unittest.cc | 149 scoped_refptr<TestURLRequestFtpJob> job(new TestURLRequestFtpJob(
151 EXPECT_EQ(DEFAULT_PRIORITY, job->priority());
153 job->SetPriority(LOWEST);
154 EXPECT_EQ(LOWEST, job->priority());
156 job->SetPriority(LOW);
157 EXPECT_EQ(LOW, job->priority());
159 job->Start();
160 EXPECT_EQ(LOW, job->priority());
162 job->SetPriority(MEDIUM);
163 EXPECT_EQ(MEDIUM, job->priority())
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.tests/src/com/android/ide/eclipse/adt/internal/wizards/exportgradle/ |
| ExportGradleTest.java | 40 import org.eclipse.core.runtime.jobs.Job;
71 Job job = new Job("Validate project") { local
123 job.schedule(1000);
124 job.join();
125 Object property = job.getProperty(ERROR_KEY);
143 Job job = new Job("Validate project") local
217 Job job = new Job("Validate project") { local
[all...] |
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/ |
| org.eclipse.core.jobs_3.5.1.R36x_v20100824.jar | |
| /device/moto/shamu/camera/QCamera/stack/mm-jpeg-interface/src/ |
| mm_jpeg_interface.c | 48 void static mm_jpeg_dump_job(mm_jpeg_job* job )
53 buf_info = &job->encode_job.encode_parm.buf_info;
54 CDBG_ERROR("*****Dump job************");
56 job->encode_job.encode_parm.rotation, job->encode_job.encode_parm.exif_numEntries,
57 job->encode_job.encode_parm.buf_info.src_imgs.is_video_frame);
97 static int32_t mm_jpeg_intf_start_job(uint32_t client_hdl, mm_jpeg_job* job, uint32_t* jobId)
102 NULL == job ||
104 CDBG_ERROR("%s: invalid parameters for client_hdl, job or jobId", __func__);
115 mm_jpeg_dump_job(job);
[all...] |
| mm_jpeg.c | 67 /* special queue functions for job queue */
141 /* clean omx job */
281 int32_t mm_jpeg_omx_config_user_preference(mm_jpeg_obj* my_obj, mm_jpeg_encode_job* job)
289 map_jpeg_format(job->encode_parm.buf_info.src_imgs.src_img[JPEG_SRC_IMAGE_TYPE_MAIN].color_format);
290 if (job->encode_parm.buf_info.src_imgs.src_img_num > 1) {
292 map_jpeg_format(job->encode_parm.buf_info.src_imgs.src_img[JPEG_SRC_IMAGE_TYPE_THUMB].color_format);
300 if (job->encode_parm.buf_info.src_imgs.is_video_frame != 0) {
310 int32_t mm_jpeg_omx_config_thumbnail(mm_jpeg_obj* my_obj, mm_jpeg_encode_job* job)
317 if (job->encode_parm.buf_info.src_imgs.src_img_num < 2) {
322 &(job->encode_parm.buf_info.src_imgs.src_img[JPEG_SRC_IMAGE_TYPE_THUMB])
583 mm_jpeg_encode_job* job = &job_entry->job.encode_job; local
[all...] |
| /external/chromium_org/components/policy/core/common/cloud/ |
| external_policy_data_fetcher.h | 44 // The result of a fetch job.
62 // Encapsulates the metadata for a fetch job.
63 struct Job;
65 // Callback invoked when a fetch job finishes. If the fetch was successful,
83 // StartJob() again. Returns an opaque job identifier. Ownership of the job
85 Job* StartJob(const GURL& url,
89 // Cancel the fetch job identified by |job|. The job is canceled silently
[all...] |
| mock_device_management_service.cc | 22 // Common mock request job functionality.
60 // Synchronous mock request job that immediately completes on calling Run().
85 // Asynchronous job that allows the test to delay job completion.
117 AsyncRequestJob* job = new AsyncRequestJob(arg0, service); local
118 *mock_job = job;
119 return job;
166 MockDeviceManagementService::CreateAsyncJob(MockDeviceManagementJob** job) {
167 return CreateAsyncMockDeviceManagementJob(this, job);
|
| /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/chromium_org/content/browser/webui/ |
| url_data_manager_backend.cc | 102 // |is_incognito| set when job is generated from an incognito profile.
155 // Returns true when job was generated from an incognito profile.
171 const base::WeakPtr<URLRequestChromeJob>& job);
205 // True when job is generated from an incognito profile.
361 const base::WeakPtr<URLRequestChromeJob>& job) {
390 base::Bind(&URLRequestChromeJob::StartAsync, job, allowed));
406 // After that, notifies |job| that mime type is available. This method
411 const base::WeakPtr<URLRequestChromeJob>& job) {
416 base::Bind(&URLRequestChromeJob::MimeTypeAvailable, job, mime_type));
442 // Check for chrome://view-http-cache/*, which uses its own job type
[all...] |
| /device/asus/flo/camera/QCamera2/stack/mm-camera-test/src/ |
| mm_qcamera_snapshot.c | 48 CDBG_ERROR("%s: NULL current job frames or not matching job ID (%d, %d)",
54 CDBG_ERROR("%s: job %d, status=%d", __func__, jobId, status);
81 mm_jpeg_job_t job; local
92 memset(&job, 0, sizeof(job));
93 job.job_type = JPEG_JOB_TYPE_ENCODE;
94 job.encode_job.session_id = test_obj->current_jpeg_sess_id;
96 job.encode_job.rotation = 0;
99 job.encode_job.rotation = 90
[all...] |
| /device/lge/hammerhead/camera/QCamera2/stack/mm-camera-test/src/ |
| mm_qcamera_snapshot.c | 48 CDBG_ERROR("%s: NULL current job frames or not matching job ID (%d, %d)",
54 CDBG_ERROR("%s: job %d, status=%d", __func__, jobId, status);
81 mm_jpeg_job_t job; local
92 memset(&job, 0, sizeof(job));
93 job.job_type = JPEG_JOB_TYPE_ENCODE;
94 job.encode_job.session_id = test_obj->current_jpeg_sess_id;
96 job.encode_job.rotation = 0;
99 job.encode_job.rotation = 90
[all...] |
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/jobscheduler/ |
| MockJobService.java | 20 import android.app.job.JobParameters;
21 import android.app.job.JobService;
28 * Handles callback from the framework {@link android.app.job.JobScheduler}. The behaviour of this
47 Log.i(TAG, "Test job executing: " + params.getJobId());
80 * job on this service.
97 Log.d(TAG, "Job executed:" + jobId);
|
| /cts/tests/JobScheduler/src/android/jobscheduler/ |
| MockJobService.java | 20 import android.app.job.JobParameters;
21 import android.app.job.JobService;
28 * Handles callback from the framework {@link android.app.job.JobScheduler}. The behaviour of this
47 Log.i(TAG, "Test job executing: " + params.getJobId());
80 * job on this service.
97 Log.d(TAG, "Job executed:" + jobId);
|
| /external/chromium_org/net/base/ |
| prioritized_dispatcher.h | 17 // jobs. It never revokes a job once started. The job must call OnJobFinished
23 // Job::Start.
27 class Job;
28 typedef PriorityQueue<Job*>::Priority Priority;
35 // jobs at priority 1 or below can start. After one more job starts, no jobs
49 // An interface to the job dispatched by PrioritizedDispatcher. The dispatcher
50 // does not own the Job but expects it to live as long as the Job is queued.
51 // Use Cancel to remove Job from queue before it is dispatched. The Job can b
[all...] |
| /external/chromium_org/third_party/npapi/npspy/extern/nspr/ |
| prtpool.h | 66 /* queue a job */
70 /* queue a job, when a socket is readable */
75 /* queue a job, when a socket is writeable */
80 /* queue a job, when a socket has a pending connection */
85 /* queue a job, when the socket connection to addr succeeds or fails */
90 /* queue a job, when a timer exipres */
94 /* cancel a job */
96 PR_CancelJob(PRJob *job); variable
98 /* join a job */
100 PR_JoinJob(PRJob *job); variable
[all...] |
| /external/compiler-rt/test/tsan/ |
| test_output.sh | 57 for job in `jobs -p`; do
58 wait $job || exit 1
|
| /external/chromium_org/components/component_updater/ |
| background_downloader_win.cc | 34 // client. For every url to download, a BITS job is created, unless there is
35 // already an existing job for that url, in which case, the downloader
36 // connects to it. Once a job is associated with the url, the code looks for
37 // changes in the BITS job state. The checks are triggered by a timer.
38 // The BITS job contains just one file to download. There could only be one
40 // complete, the BITS job remains active and finishes in the background, without
41 // any intervention. The job can be completed next time the code runs, if the
46 // "bitsadmin /info" and provide the job id returned by the previous /list
50 // job state machine implemented by BITS is something like this:
65 // The job is created in the "suspended" state. Once |Resume| is called
689 ScopedComPtr<IBackgroundCopyJob> job; local
[all...] |
| /external/chromium_org/third_party/libwebp/enc/ |
| analysis.c | 388 // struct used to collect job result
398 static int DoSegmentsJob(SegmentJob* const job, VP8EncIterator* const it) {
406 MBAnalyze(it, job->alphas, &job->alpha, &job->uv_alpha);
407 ok = VP8IteratorProgress(it, job->delta_progress);
420 // initialize the job struct with some TODOs
421 static void InitSegmentJob(VP8Encoder* const enc, SegmentJob* const job,
423 WebPGetWorkerInterface()->Init(&job->worker);
424 job->worker.data1 = job
[all...] |
| /external/webp/src/enc/ |
| analysis.c | 388 // struct used to collect job result
398 static int DoSegmentsJob(SegmentJob* const job, VP8EncIterator* const it) {
406 MBAnalyze(it, job->alphas, &job->alpha, &job->uv_alpha);
407 ok = VP8IteratorProgress(it, job->delta_progress);
420 // initialize the job struct with some TODOs
421 static void InitSegmentJob(VP8Encoder* const enc, SegmentJob* const job,
423 WebPGetWorkerInterface()->Init(&job->worker);
424 job->worker.data1 = job
[all...] |
| /external/chromium_org/v8/tools/testrunner/local/ |
| execution.py | 39 class Job(object):
48 def RunTest(job):
50 if job.dep_command is not None:
51 dep_output = commands.Execute(job.dep_command, job.verbose, job.timeout)
57 return (job.id, dep_output, time.time() - start_time)
58 output = commands.Execute(job.command, job.verbose, job.timeout
[all...] |
| /external/chromium_org/net/websockets/ |
| websocket_job_test.cc | 332 WebSocketJob* job() { return job_.get(); } function in class:net::__anon14465::DeletingSocketStreamDelegate
334 void set_job(WebSocketJob* job) { job_ = job; }
499 SocketStream* GetSocket(SocketStreamJob* job) {
500 return job->socket_.get();
582 WebSocketJob* job() { return delegate_->job(); } function in class:net::WebSocketJobDeleteTest
851 scoped_refptr<SocketStreamJob> job = local
855 EXPECT_TRUE(GetSocket(job.get())->is_secure());
856 job->DetachDelegate()
1105 scoped_refptr<WebSocketJob> job = new WebSocketJob(NULL); local
1120 WebSocketJob* job = (*iter).get(); local
[all...] |
| /external/chromium_org/sandbox/win/src/ |
| broker_services.cc | 26 // Utility function to associate a completion port to a job object.
27 bool AssociateCompletionPort(HANDLE job, HANDLE port, void* key) {
29 return ::SetInformationJobObject(job,
55 // Helper structure that allows the Broker to associate a job notification
56 // with a job object and with a policy.
58 HANDLE job; member in struct:__anon15219::JobTracker
61 : job(cjob), policy(cpolicy) {
117 // The broker uses a dedicated worker thread that services the job completion
149 // Closing the port causes, that no more Job notifications are delivered to
198 BOOL res = ::TerminateJobObject(tracker->job, SBOX_ALL_OK)
[all...] |
| /external/chromium_org/cloud_print/gcp20/prototype/ |
| cloud_print_response_parser.cc | 15 Job::Job() {
18 Job::~Job() {
164 std::vector<Job>* list) {
186 std::vector<Job> job_list(jobs->GetSize());
189 base::DictionaryValue* job = NULL; local
190 jobs->GetDictionary(idx, &job);
191 if (!job->GetString("id", &job_list[idx].job_id) ||
192 !job->GetString("createTime", &create_time_str) |
[all...] |
| /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/utils/ |
| CapsModeUtilsTests.java | 56 final RunInLocale<SpacingAndPunctuations> job = new RunInLocale<SpacingAndPunctuations>() { local
58 protected SpacingAndPunctuations job(final Resources res) {
63 SpacingAndPunctuations sp = job.runInLocale(res, Locale.ENGLISH);
94 sp = job.runInLocale(res, Locale.FRENCH);
101 sp = job.runInLocale(res, Locale.GERMAN);
107 sp = job.runInLocale(res, Locale.ENGLISH);
115 sp = job.runInLocale(res, LocaleUtils.constructLocaleFromString("hy_AM"));
|
