/external/chromium_org/net/http/ |
H A D | http_stream_factory_impl_request_unittest.cc | 78 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 D | 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/chromium_org/tools/gyp/test/mac/ |
H A D | gyptest-xctest.py | 20 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 D | gyptest-postbuild-fail.py | 36 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 D | socket_stream_job_manager.cc | 27 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 D | aw_url_request_job_factory.cc | 44 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 D | test_automation_resource_message_filter.cc | 19 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 D | test_automation_provider.cc | 35 // AutomationResourceMessageFilter registers the automation job factory to 95 URLRequestAutomationJob* job = new URLRequestAutomationJob( local 100 return job;
|
/external/chromium_org/net/socket_stream/ |
H A D | socket_stream_job_manager.cc | 27 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 D | protocol_intercept_job_factory.cc | 25 URLRequestJob* job = protocol_handler_->MaybeCreateJob(request, local 27 if (job) 28 return job;
|
H A D | url_request_job_manager.cc | 83 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 D | url_request_job_tracker.cc | 26 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 D | url_request_filter.cc | 122 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 D | url_request_job_manager.cc | 72 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 D | websocket_throttle.cc | 62 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 D | job_unittest.cc | 5 // 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 D | integration_tests_test.cc | 68 // 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 D | print_job_manager.cc | 47 // 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 D | syncer_thread2_whitebox_unittest.cc | 68 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 D | print_job_manager.cc | 30 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 D | prioritized_dispatcher.cc | 27 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 D | websocket_throttle.cc | 42 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 D | Dispatcher.java | 39 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 D | url_request_slow_download_job.cc | 51 URLRequestSlowDownloadJob* job = new URLRequestSlowDownloadJob(request); local 53 URLRequestSlowDownloadJob::kPendingRequests.push_back(job); 54 return job;
|
/external/chromium/chrome/browser/policy/ |
H A D | device_management_service.cc | 131 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...] |