| /external/chromium_org/content/browser/download/ |
| mhtml_generation_manager.cc | 19 MHTMLGenerationManager::Job::Job()
26 MHTMLGenerationManager::Job::~Job() {
47 Job job; local
48 job.file_path = file;
49 job.process_id = web_contents->GetRenderProcessHost()->GetID();
50 job.routing_id = web_contents->GetRenderViewHost()->GetRoutingID();
51 job.callback = callback
110 Job& job = iter->second; local
133 Job& job = iter->second; local
[all...] |
| /external/chromium_org/net/url_request/ |
| url_request_filter.cc | 170 URLRequestJob* job = NULL; local
178 job = i->second->MaybeCreateJob(request, network_delegate);
180 if (!job) {
185 job = i->second->MaybeCreateJob(request, network_delegate);
188 if (job) {
192 return job;
|
| /external/chromium_org/net/websockets/ |
| websocket_throttle.cc | 42 bool WebSocketThrottle::PutInQueue(WebSocketJob* job) {
46 queue_.push_back(job);
47 const AddressList& address_list = job->address_list();
61 new_queue->second.push_back(job);
64 iter->second.push_back(job);
65 job->SetWaiting();
73 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) {
75 std::find(queue_.begin(), queue_.end(), job);
82 const AddressList& resolved_address_list = job->address_list();
97 // Job may not be front of the queue if the socket is closed while waiting
121 WebSocketJob* job = *iter; local
[all...] |
| /external/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| Dispatcher.java | 35 private final Map<Object, List<Job>> enqueuedJobs = new LinkedHashMap<Object, List<Job>>();
39 Job job = new Job(this, connection, request, responseReceiver); local
40 List<Job> jobsForTag = enqueuedJobs.get(request.tag());
42 jobsForTag = new ArrayList<Job>(2);
45 jobsForTag.add(job);
46 executorService.execute(job);
50 List<Job> jobs = enqueuedJobs.remove(tag)
[all...] |
| /hardware/qcom/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...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/launch/junit/ |
| AndroidJUnitLaunchConfigDelegate.java | 40 import org.eclipse.core.runtime.jobs.Job;
104 Job job = new Job("Junit Launch") { //$NON-NLS-1$ local
114 job.setPriority(Job.INTERACTIVE);
115 job.schedule();
|
| /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...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/actions/ |
| AddSupportJarAction.java | 54 import org.eclipse.core.runtime.jobs.Job;
415 * @param waitForFinish whether this method should wait for the job to
426 // Run an Eclipse asynchronous job to update the project
427 Job job = new Job("Add Support Library Dependency to Project") { local
472 Job fix = FixProjectAction.createFixProjectJob(libraryProject);
489 job.schedule();
493 job.join();
494 return job.getState() == IStatus.OK
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/launch/junit/runtime/ |
| RemoteAdtTestRunner.java | 33 import org.eclipse.core.runtime.jobs.Job;
95 * <li> First, a separate job per device is run to collect test tree data. A per device
100 * <li> A job per device is again launched to do the actual test run. A per device
154 TestTreeCollectorJob job = new TestTreeCollectorJob( local
157 job.setPriority(Job.INTERACTIVE);
158 job.schedule();
160 collectorJobs.add(job);
165 for (TestTreeCollectorJob job : collectorJobs) {
167 job.join()
203 InstrumentationRunJob job = new InstrumentationRunJob( local
[all...] |
| /device/asus/flo/camera/QCamera2/stack/mm-jpeg-interface/test/ |
| mm_jpeg_test.c | 79 mm_jpeg_job_t job; member in struct:__anon1822
171 mm_jpeg_encode_job_t *p_job_params = &p_obj->job.encode_job;
275 &jpeg_obj.job.encode_job.session_id);
276 if (jpeg_obj.job.encode_job.session_id == 0) {
282 jpeg_obj.job.job_type = JPEG_JOB_TYPE_ENCODE;
283 rc = jpeg_obj.ops.start_job(&jpeg_obj.job, &jpeg_obj.job_id[i]);
298 jpeg_obj.ops.destroy_session(jpeg_obj.job.encode_job.session_id);
|
| /external/chromium_org/chrome/browser/chromeos/policy/ |
| auto_enrollment_client_unittest.cc | 104 void ServerWillReplyAsync(MockDeviceManagementJob** job) {
107 .WillOnce(service_->CreateAsyncJob(job));
375 MockDeviceManagementJob* job = NULL; local
376 ServerWillReplyAsync(&job);
377 EXPECT_FALSE(job);
379 ASSERT_TRUE(job);
388 job->SendResponse(DM_STATUS_TEMPORARY_UNAVAILABLE,
396 MockDeviceManagementJob* job = NULL; local
397 ServerWillReplyAsync(&job);
398 EXPECT_FALSE(job);
[all...] |
| /external/chromium_org/chrome/browser/policy/cloud/ |
| external_policy_data_updater.cc | 152 // If |fetcher_| exists, the job is currently running and must call back to
203 // This job is currently running. Inform the updater that it was canceled.
308 // This function may have been invoked because the job was obsoleted and is
349 // Check whether a job exists for this |key| already.
350 FetchJob* job = job_map_[key]; local
351 if (job) {
352 // If the current |job| is handling the given |request| already, nothing
354 if (job->request() == request)
357 // Otherwise, the current |job| is obsolete. If the |job| is on the queue
377 std::map<std::string, FetchJob*>::iterator job = job_map_.find(key); local
389 FetchJob* job = job_queue_.front().get(); local
[all...] |
| mock_device_management_service.cc | 17 // Common mock request job functionality.
55 // Synchronous mock request job that immediately completes on calling Run().
80 // Asynchronous job that allows the test to delay job completion.
112 AsyncRequestJob* job = new AsyncRequestJob(arg0, service); local
113 *mock_job = job;
114 return job;
137 MockDeviceManagementService::CreateAsyncJob(MockDeviceManagementJob** job) {
138 return CreateAsyncMockDeviceManagementJob(this, job);
|
| /external/chromium_org/content/test/net/ |
| url_request_slow_download_job.cc | 65 URLRequestSlowDownloadJob* job = new URLRequestSlowDownloadJob( local
69 pending_requests_.Get().insert(job);
70 return job;
|
| /external/chromium_org/net/base/ |
| prioritized_dispatcher_unittest.cc | 32 // A job that appends |tag| to |log| when started and '.' when finished.
35 class TestJob : public PrioritizedDispatcher::Job {
115 // PriorityDispatch::Job interface
141 TestJob* job = new TestJob(dispatcher_.get(), data, priority, &log_); local
142 jobs_.push_back(job);
143 job->Add();
144 return job;
160 // Allow only one running job.
|
| /external/chromium_org/net/dns/ |
| address_sorter_win.cc | 36 scoped_refptr<Job> job = new Job(list, callback); variable
42 class Job : public base::RefCountedThreadSafe<Job> {
44 Job(const AddressList& list, const CallbackType& callback)
76 base::Bind(&Job::Run, this),
77 base::Bind(&Job::OnComplete, this),
85 friend class base::RefCountedThreadSafe<Job>;
86 ~Job() {}
[all...] |
| /external/chromium_org/net/http/ |
| http_stream_factory_impl.cc | 57 std::set<const Job*> tmp_job_set;
121 Job* alternate_job = NULL;
129 new Job(this, session_, alternate_request_info, priority,
135 Job* job = new Job(this, session_, request_info, priority, local
137 request->AttachJob(job);
142 job->WaitFor(alternate_job);
144 // |alternate_job|, otherwise |alternate_job| will not notify |job|
150 // so starting |job| is always safe
165 Job* job = NULL; local
[all...] |
| /external/chromium_org/sandbox/win/src/ |
| restricted_token_utils.cc | 15 #include "sandbox/win/src/job.h"
148 Job job; local
149 DWORD err_code = job.Init(job_level, NULL, 0);
156 err_code = job.UserHandleGrantAccess(GetDesktopWindow());
191 // break out of any job we're in to enforce our restrictions.
220 err_code = job.AssignProcessToJob(process_info.process_handle());
230 (*job_handle_ret) = job.Detach();
|
| /hardware/qcom/camera/QCamera2/stack/mm-jpeg-interface/test/ |
| mm_jpeg_test.c | 79 mm_jpeg_job_t job; member in struct:__anon33278
171 mm_jpeg_encode_job_t *p_job_params = &p_obj->job.encode_job;
275 &jpeg_obj.job.encode_job.session_id);
276 if (jpeg_obj.job.encode_job.session_id == 0) {
282 jpeg_obj.job.job_type = JPEG_JOB_TYPE_ENCODE;
283 rc = jpeg_obj.ops.start_job(&jpeg_obj.job, &jpeg_obj.job_id[i]);
298 jpeg_obj.ops.destroy_session(jpeg_obj.job.encode_job.session_id);
|
| /prebuilts/gcc/linux-x86/host/i686-linux-glibc2.7-4.4.3/i686-linux/include/c++/4.4.3/parallel/ |
| workstealing.h | 52 /** @brief One job for a certain thread. */
54 struct Job
77 * Uses O(1) additional memory. Synchronization at job lists is
120 const int stride = __s.cache_line_size * 10 / sizeof(Job<difference_type>) + 1;
125 Job<difference_type> *job; local
145 // Create job description array.
146 job = new Job<difference_type>[num_threads * stride];
157 // This job
[all...] |
| /system/core/sh/ |
| jobs.h | 50 #define SHOW_ISSIG 0x20 /* job was signalled */
51 #define SHOW_NO_FREE 0x40 /* do not free job */
55 * A job structure contains information about a job. A job is either a
68 struct job { struct
72 pid_t pgrp; /* process group of this job */
80 char jobctl; /* job running under job control */
81 int prev_job; /* previous job index *
[all...] |
| /build/tools/droiddoc/templates-sac/assets/js/ |
| android_3p-bundle.js | 760 var job = {
764 langHandler(job);
765 out.push.apply(out, job.decorations);
[all...] |
| /build/tools/droiddoc/templates-sdk/assets/js/ |
| android_3p-bundle.js | 760 var job = {
764 langHandler(job);
765 out.push.apply(out, job.decorations);
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/editors/layout/gle2/ |
| LayoutMetadata.java | 195 WorkbenchJob job = new WorkbenchJob(display, "Update alternate views") { local
227 job.setSystem(true);
228 job.schedule();
|
| /sdk/eclipse/plugins/com.android.ide.eclipse.gldebugger/src/com/android/ide/eclipse/gltrace/editors/ |
| StateViewPage.java | 34 import org.eclipse.core.runtime.jobs.Job;
75 private static final ILock sGlStateLock = Job.getJobManager().newLock();
216 // the update task as an Eclipse job.
217 Job job = new Job("Updating GL State") { local
252 job.setPriority(Job.SHORT);
253 job.schedule();
|
