Searched defs:job (Results 1 - 25 of 143) sorted by relevance

123456

/external/chromium_org/net/http/
H A Dhttp_stream_factory_impl_request_unittest.cc78 HttpStreamFactoryImpl::Job* job = local
86 request.AttachJob(job);
87 EXPECT_EQ(DEFAULT_PRIORITY, job->priority());
90 EXPECT_EQ(MEDIUM, job->priority());
92 // Make |job| the bound job.
93 request.OnStreamFailed(job, ERR_FAILED, SSLConfig());
96 EXPECT_EQ(IDLE, job->priority());
/external/chromium_org/third_party/npapi/npspy/extern/nspr/
H A Dprtpool.h66 /* 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/chromium_org/tools/gyp/test/mac/
H A Dgyptest-xctest.py20 job = subprocess.Popen(['xcodebuild', '-version'], variable
23 out, err = job.communicate()
24 if job.returncode != 0:
25 raise Exception('Error %d running xcodebuild' % job.returncode)
H A Dgyptest-postbuild-fail.py36 job = subprocess.Popen(['xcodebuild', '-version'], variable
39 out, err = job.communicate()
40 if job.returncode != 0:
42 raise Exception('Error %d running xcodebuild' % job.returncode)
/external/chromium/net/socket_stream/
H A Dsocket_stream_job_manager.cc27 SocketStreamJob* job = new SocketStreamJob(); local
28 job->InitSocketStream(new SocketStream(url, delegate));
29 return job;
37 SocketStreamJob* job = found->second(url, delegate); local
38 if (job)
39 return job;
41 SocketStreamJob* job = new SocketStreamJob(); local
42 job->InitSocketStream(new SocketStream(url, delegate));
43 return job;
/external/chromium_org/android_webview/browser/net/
H A Daw_url_request_job_factory.cc44 URLRequestJob* job = next_factory_->MaybeCreateJobWithProtocolHandler( local
47 if (job)
48 return job;
51 // In that case the built in handlers will then be used to create the job.
/external/chromium_org/chrome_frame/test/net/
H A Dtest_automation_resource_message_filter.cc19 URLRequestAutomationJob* job, IPC::Message* msg) {
20 job->OnMessage(*msg);
37 RequestJob& job = it->second; local
46 // URLRequestAutomationJob was created on, we could destroy the job on
49 // on the correct thread here since we post to job.loop_ which is set as
52 job.loop_->PostTask(FROM_HERE,
53 base::Bind(OnRequestMessage, job.job_, msg));
63 URLRequestAutomationJob* job) {
68 DCHECK(requests_.end() == requests_.find(job->id()));
69 RequestJob request_job = { base::MessageLoop::current(), job };
18 OnRequestMessage( URLRequestAutomationJob* job, IPC::Message* msg) argument
62 RegisterRequest( URLRequestAutomationJob* job) argument
75 UnRegisterRequest( URLRequestAutomationJob* job) argument
[all...]
H A Dtest_automation_provider.cc35 // AutomationResourceMessageFilter registers the automation job factory to
95 URLRequestAutomationJob* job = new URLRequestAutomationJob( local
100 return job;
/external/chromium_org/net/socket_stream/
H A Dsocket_stream_job_manager.cc27 SocketStreamJob* job = new SocketStreamJob(); local
28 job->InitSocketStream(new SocketStream(url, delegate));
29 return job;
37 SocketStreamJob* job = found->second(url, delegate); local
38 if (job)
39 return job;
41 SocketStreamJob* job = new SocketStreamJob(); local
42 job->InitSocketStream(new SocketStream(url, delegate));
43 return job;
/external/chromium_org/net/url_request/
H A Dprotocol_intercept_job_factory.cc25 URLRequestJob* job = protocol_handler_->MaybeCreateJob(request, local
27 if (job)
28 return job;
H A Durl_request_job_manager.cc83 URLRequestJob* job = (*i)->MaybeIntercept(request, network_delegate); local
84 if (job)
85 return job;
90 URLRequestJob* job = job_factory->MaybeCreateJobWithProtocolHandler( local
92 if (job)
93 return job;
103 URLRequestJob* job = i->second(request, network_delegate, scheme); local
104 if (job)
105 return job;
111 URLRequestJob* job local
150 URLRequestJob* job = (*i)->MaybeInterceptRedirect(request, local
182 URLRequestJob* job = (*i)->MaybeInterceptResponse(request, local
[all...]
/external/chromium/net/url_request/
H A Durl_request_job_tracker.cc26 void URLRequestJobTracker::AddNewJob(URLRequestJob* job) { argument
27 active_jobs_.push_back(job);
28 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobAdded(job));
31 void URLRequestJobTracker::RemoveJob(URLRequestJob* job) { argument
33 job);
35 NOTREACHED() << "Removing a non-active job";
40 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobRemoved(job));
43 void URLRequestJobTracker::OnJobDone(URLRequestJob* job, argument
45 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobDone(job, status));
48 void URLRequestJobTracker::OnJobRedirect(URLRequestJob* job, argument
55 OnBytesRead(URLRequestJob* job, const char* buf, int byte_count) argument
[all...]
H A Durl_request_filter.cc122 URLRequestJob* job = NULL; local
130 job = i->second(request, scheme);
132 if (!job) {
137 job = i->second(request, scheme);
140 if (job) {
144 return job;
H A Durl_request_job_manager.cc72 URLRequestJob* job = (*i)->MaybeIntercept(request); local
73 if (job)
74 return job;
83 URLRequestJob* job = i->second(request, scheme); local
84 if (job)
85 return job;
91 URLRequestJob* job = (kBuiltinFactories[i].factory)(request, scheme); local
92 DCHECK(job); // The built-in factories are not expected to fail!
93 return job;
118 URLRequestJob* job local
138 URLRequestJob* job = (*i)->MaybeInterceptResponse(request); local
[all...]
/external/chromium/net/websockets/
H A Dwebsocket_throttle.cc62 void WebSocketThrottle::PutInQueue(WebSocketJob* job) { argument
63 queue_.push_back(job);
64 const AddressList& address_list = job->address_list();
79 queue->push_back(job);
82 iter->second->push_back(job);
83 job->SetWaiting();
89 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { argument
94 if (*iter == job) {
102 const AddressList& address_list = job->address_list();
117 // Job may not be front of queue when job i
137 WebSocketJob* job = *iter; local
[all...]
/external/chromium_org/sandbox/win/src/
H A Djob_unittest.cc5 // This file contains unit tests for the job object.
8 #include "sandbox/win/src/job.h"
13 // Tests the creation and destruction of the job.
17 // Create the job.
18 Job job; local
19 ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", 0));
21 // check if the job exists.
30 // Check if the job is destroyed when the object goes out of scope.
41 // Create the job.
42 Job job; local
74 Job job; local
95 Job job; local
117 Job job; local
125 Job job; local
160 Job job; local
[all...]
/external/chromium_org/sandbox/win/tests/integration_tests/
H A Dintegration_tests_test.cc68 // Creates a job and tries to run a process inside it. The function can be
72 // JOB_OBJECT_LIMIT_BREAKAWAY_OK flag should be set on the job object created
77 HANDLE job = ::CreateJobObject(NULL, NULL); local
78 if (!job)
82 if (!::QueryInformationJobObject(job, JobObjectExtendedLimitInformation,
95 if (!::SetInformationJobObject(job, JobObjectExtendedLimitInformation,
99 if (!::AssignProcessToJobObject(job, ::GetCurrentProcess()))
112 // Terminate the job now.
113 ::TerminateJobObject(job, SBOX_TEST_SUCCEEDED);
267 // Running from inside job tha
[all...]
/external/chromium/chrome/browser/printing/
H A Dprint_job_manager.cc47 // Wait for each job to finish.
49 PrintJob* job = current_jobs[i]; local
50 if (!job)
52 // Wait for 120 seconds for the print job to be spooled.
54 job->FlushJob(120000);
55 job->Stop();
61 void PrintJobManager::QueuePrinterQuery(PrinterQuery* job) { argument
63 DCHECK(job);
64 queued_queries_.push_back(make_scoped_refptr(job));
65 DCHECK(job
68 PopPrinterQuery(int document_cookie, scoped_refptr<PrinterQuery>* job) argument
[all...]
/external/chromium/chrome/browser/sync/engine/
H A Dsyncer_thread2_whitebox_unittest.cc68 const SyncerThread::SyncSessionJob& job) {
69 return syncer_thread_->DecideOnJob(job);
81 struct SyncerThread::SyncSessionJob job; local
82 job.purpose = purpose;
83 job.scheduled_start = TimeTicks::Now();
84 return DecideOnJob(job);
218 struct SyncerThread::SyncSessionJob job; local
219 job.purpose = SyncerThread::SyncSessionJob::CONFIGURATION;
220 job.scheduled_start = TimeTicks::Now();
221 job
67 DecideOnJob( const SyncerThread::SyncSessionJob& job) argument
[all...]
/external/chromium_org/chrome/browser/printing/
H A Dprint_job_manager.cc30 void PrintQueriesQueue::QueuePrinterQuery(PrinterQuery* job) { argument
32 DCHECK(job);
33 queued_queries_.push_back(make_scoped_refptr(job));
34 DCHECK(job->is_valid());
53 scoped_refptr<PrinterQuery> job = new printing::PrinterQuery; local
55 job->SetWorkerDestination(destination_);
56 return job;
97 for (PrintJobs::const_iterator job = to_stop.begin(); job != to_stop.end();
98 ++job) {
[all...]
/external/chromium_org/net/base/
H A Dprioritized_dispatcher.cc27 Job* job, Priority priority) {
28 DCHECK(job);
32 job->Start();
35 return queue_.Insert(job, priority);
39 Job* job, Priority priority) {
40 DCHECK(job);
44 job->Start();
47 return queue_.InsertAtFront(job, priority);
58 Job* job = handle.value();
60 return job;
26 Add( Job* job, Priority priority) argument
38 AddAtHead( Job* job, Priority priority) argument
[all...]
/external/chromium_org/net/websockets/
H A Dwebsocket_throttle.cc42 bool WebSocketThrottle::PutInQueue(WebSocketJob* job) { argument
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) { argument
75 std::find(queue_.begin(), queue_.end(), job);
82 const AddressList& resolved_address_list = job->address_list();
99 std::find(per_address_queue.begin(), per_address_queue.end(), job);
121 WebSocketJob* job = *iter; local
[all...]
/external/okhttp/src/main/java/com/squareup/okhttp/internal/http/
H A DDispatcher.java39 Job job = new Job(this, connection, request, responseReceiver);
45 jobsForTag.add(job);
46 executorService.execute(job);
52 for (Job job : jobs) {
53 executorService.remove(job);
57 synchronized void finished(Job job) { argument
58 List<Job> jobs = enqueuedJobs.get(job.request.tag());
59 if (jobs != null) jobs.remove(job);
/external/chromium/chrome/browser/net/
H A Durl_request_slow_download_job.cc51 URLRequestSlowDownloadJob* job = new URLRequestSlowDownloadJob(request); local
53 URLRequestSlowDownloadJob::kPendingRequests.push_back(job);
54 return job;
/external/chromium/chrome/browser/policy/
H A Ddevice_management_service.cc131 for (JobFetcherMap::iterator job(pending_jobs_.begin());
132 job != pending_jobs_.end();
133 ++job) {
134 delete job->first;
135 queued_jobs_.push_back(job->second);
145 void DeviceManagementService::AddJob(DeviceManagementJob* job) { argument
147 StartJob(job);
149 queued_jobs_.push_back(job);
152 void DeviceManagementService::RemoveJob(DeviceManagementJob* job) { argument
156 if (entry->second == job) {
169 StartJob(DeviceManagementJob* job) argument
190 DeviceManagementJob* job = entry->second; local
[all...]

Completed in 820 milliseconds

123456