job 44 android_webview/browser/net/aw_url_request_job_factory.cc URLRequestJob* job = next_factory_->MaybeCreateJobWithProtocolHandler( job 47 android_webview/browser/net/aw_url_request_job_factory.cc if (job) job 48 android_webview/browser/net/aw_url_request_job_factory.cc return job; job 689 base/message_loop/message_loop.cc bool MessageLoopForIO::RegisterJobObject(HANDLE job, IOHandler* handler) { job 690 base/message_loop/message_loop.cc return pump_io()->RegisterJobObject(job, handler); job 676 base/message_loop/message_loop.h bool RegisterJobObject(HANDLE job, IOHandler* handler); job 251 chrome/browser/captive_portal/captive_portal_browsertest.cc URLRequestTimeoutOnDemandJob** job = &job_list_; job 252 chrome/browser/captive_portal/captive_portal_browsertest.cc while (*job) { job 253 chrome/browser/captive_portal/captive_portal_browsertest.cc if (*job == this) { job 254 chrome/browser/captive_portal/captive_portal_browsertest.cc *job = next_job_; job 258 chrome/browser/captive_portal/captive_portal_browsertest.cc job = &next_job_; job 309 chrome/browser/captive_portal/captive_portal_browsertest.cc URLRequestTimeoutOnDemandJob* job = job_list_; job 312 chrome/browser/captive_portal/captive_portal_browsertest.cc EXPECT_TRUE(job->RemoveFromList()); job 314 chrome/browser/captive_portal/captive_portal_browsertest.cc job->NotifyStartError(net::URLRequestStatus( job 214 chrome/browser/chromeos/drive/job_scheduler.cc JobEntry* job = job_map_.Lookup(job_id); job 215 chrome/browser/chromeos/drive/job_scheduler.cc if (job) { job 216 chrome/browser/chromeos/drive/job_scheduler.cc if (job->job_info.state == STATE_RUNNING) { job 220 chrome/browser/chromeos/drive/job_scheduler.cc if (!job->cancel_callback.is_null()) job 221 chrome/browser/chromeos/drive/job_scheduler.cc job->cancel_callback.Run(); job 223 chrome/browser/chromeos/drive/job_scheduler.cc AbortNotRunningJob(job, google_apis::GDATA_CANCELLED); job 721 chrome/browser/chromeos/drive/job_scheduler.cc JobEntry* job = new JobEntry(type); job 722 chrome/browser/chromeos/drive/job_scheduler.cc job->job_info.job_id = job_map_.Add(job); // Takes the ownership of |job|. job 723 chrome/browser/chromeos/drive/job_scheduler.cc return job; job 726 chrome/browser/chromeos/drive/job_scheduler.cc void JobScheduler::StartJob(JobEntry* job) { job 727 chrome/browser/chromeos/drive/job_scheduler.cc DCHECK(!job->task.is_null()); job 729 chrome/browser/chromeos/drive/job_scheduler.cc QueueJob(job->job_info.job_id); job 730 chrome/browser/chromeos/drive/job_scheduler.cc NotifyJobAdded(job->job_info); job 731 chrome/browser/chromeos/drive/job_scheduler.cc DoJobLoop(GetJobQueueType(job->job_info.job_type)); job 763 chrome/browser/chromeos/drive/job_scheduler.cc JobEntry* job = job_map_.Lookup(jobs[i]); job 764 chrome/browser/chromeos/drive/job_scheduler.cc DCHECK(job); job 765 chrome/browser/chromeos/drive/job_scheduler.cc AbortNotRunningJob(job, google_apis::GDATA_NO_CONNECTION); job 1097 chrome/browser/chromeos/drive/job_scheduler.cc void JobScheduler::AbortNotRunningJob(JobEntry* job, job 1101 chrome/browser/chromeos/drive/job_scheduler.cc const base::TimeDelta elapsed = base::Time::Now() - job->job_info.start_time; job 1102 chrome/browser/chromeos/drive/job_scheduler.cc const QueueType queue_type = GetJobQueueType(job->job_info.job_type); job 1105 chrome/browser/chromeos/drive/job_scheduler.cc job->job_info.ToString().c_str(), job 1111 chrome/browser/chromeos/drive/job_scheduler.cc job->abort_callback; job 1112 chrome/browser/chromeos/drive/job_scheduler.cc queue_[GetJobQueueType(job->job_info.job_type)]->Remove(job->job_info.job_id); job 1113 chrome/browser/chromeos/drive/job_scheduler.cc NotifyJobDone(job->job_info, error); job 1114 chrome/browser/chromeos/drive/job_scheduler.cc job_map_.Remove(job->job_info.job_id); job 260 chrome/browser/chromeos/drive/job_scheduler.h void StartJob(JobEntry* job); job 357 chrome/browser/chromeos/drive/job_scheduler.h void AbortNotRunningJob(JobEntry* job, google_apis::GDataErrorCode error); job 130 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc void ServerWillReplyAsync(MockDeviceManagementJob** job) { job 133 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc .WillOnce(service_->CreateAsyncJob(job)); job 398 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc MockDeviceManagementJob* job = NULL; job 399 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc ServerWillReplyAsync(&job); job 400 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc EXPECT_FALSE(job); job 402 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc ASSERT_TRUE(job); job 411 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc job->SendResponse(DM_STATUS_TEMPORARY_UNAVAILABLE, job 419 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc MockDeviceManagementJob* job = NULL; job 420 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc ServerWillReplyAsync(&job); job 421 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc EXPECT_FALSE(job); job 423 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc ASSERT_TRUE(job); job 437 chrome/browser/chromeos/policy/auto_enrollment_client_unittest.cc job->SendResponse(DM_STATUS_TEMPORARY_UNAVAILABLE, job 140 chrome/browser/component_updater/background_downloader_win.cc HRESULT GetFilesInJob(IBackgroundCopyJob* job, job 143 chrome/browser/component_updater/background_downloader_win.cc HRESULT hr = job->EnumFiles(enum_files.Receive()); job 199 chrome/browser/component_updater/background_downloader_win.cc HRESULT GetJobByteCount(IBackgroundCopyJob* job, job 205 chrome/browser/component_updater/background_downloader_win.cc if (!job) job 209 chrome/browser/component_updater/background_downloader_win.cc HRESULT hr = job->GetProgress(&job_progress); job 223 chrome/browser/component_updater/background_downloader_win.cc HRESULT GetJobDescription(IBackgroundCopyJob* job, const base::string16* name) { job 225 chrome/browser/component_updater/background_downloader_win.cc return job->GetDescription(&description); job 231 chrome/browser/component_updater/background_downloader_win.cc HRESULT GetJobError(IBackgroundCopyJob* job, HRESULT* error_code_out) { job 234 chrome/browser/component_updater/background_downloader_win.cc HRESULT hr = job->GetError(copy_error.Receive()); job 285 chrome/browser/component_updater/background_downloader_win.cc bool operator()(IBackgroundCopyJob* job, int num_days) const; job 288 chrome/browser/component_updater/background_downloader_win.cc bool JobCreationOlderThanDays::operator()(IBackgroundCopyJob* job, job 291 chrome/browser/component_updater/background_downloader_win.cc HRESULT hr = job->GetTimes(×); job 306 chrome/browser/component_updater/background_downloader_win.cc bool operator()(IBackgroundCopyJob* job, job 310 chrome/browser/component_updater/background_downloader_win.cc bool JobFileUrlEqual::operator()(IBackgroundCopyJob* job, job 313 chrome/browser/component_updater/background_downloader_win.cc HRESULT hr = GetFilesInJob(job, &files); job 340 chrome/browser/component_updater/background_downloader_win.cc void CleanupJobFiles(IBackgroundCopyJob* job) { job 342 chrome/browser/component_updater/background_downloader_win.cc if (FAILED(GetFilesInJob(job, &files))) job 695 chrome/browser/component_updater/background_downloader_win.cc ScopedComPtr<IBackgroundCopyJob> job; job 699 chrome/browser/component_updater/background_downloader_win.cc job.Receive()); job 703 chrome/browser/component_updater/background_downloader_win.cc job_ = job; job 186 chrome/browser/custom_handlers/protocol_handler_registry.cc net::URLRequestJob* job = io_thread_delegate_->MaybeCreateJob( job 188 chrome/browser/custom_handlers/protocol_handler_registry.cc if (job) job 189 chrome/browser/custom_handlers/protocol_handler_registry.cc return job; job 39 chrome/browser/custom_handlers/protocol_handler_registry_unittest.cc scoped_refptr<net::URLRequestJob> job = job 42 chrome/browser/custom_handlers/protocol_handler_registry_unittest.cc ASSERT_TRUE(job.get() != NULL); job 109 chrome/browser/geolocation/chrome_access_token_store.cc scoped_refptr<TokenLoadingJob> job(new TokenLoadingJob(callback)); job 110 chrome/browser/geolocation/chrome_access_token_store.cc job->Run(); job 243 chrome/browser/net/dns_probe_browsertest.cc DelayableURLRequestFailedJob* job = job 248 chrome/browser/net/dns_probe_browsertest.cc delayed_requests_.insert(job); job 249 chrome/browser/net/dns_probe_browsertest.cc return job; job 251 chrome/browser/net/dns_probe_browsertest.cc DelayableURLRequestMockHTTPJob* job = job 256 chrome/browser/net/dns_probe_browsertest.cc delayed_requests_.insert(job); job 257 chrome/browser/net/dns_probe_browsertest.cc return job; job 132 chrome/browser/policy/cloud/device_management_service_browsertest.cc scoped_ptr<DeviceManagementRequestJob> job( job 135 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetGaiaToken("gaia_auth_token"); job 136 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetOAuthToken("oauth_token"); job 137 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetClientID("testid"); job 138 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->GetRequest()->mutable_register_request(); job 139 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->Start(base::Bind(&DeviceManagementServiceIntegrationTest::OnJobDone, job 193 chrome/browser/policy/cloud/device_management_service_browsertest.cc scoped_ptr<DeviceManagementRequestJob> job(service_->CreateJob( job 196 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetDMToken(token_); job 197 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetClientID("testid"); job 199 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->GetRequest()->mutable_service_api_access_request(); job 202 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->Start(base::Bind(&DeviceManagementServiceIntegrationTest::OnJobDone, job 215 chrome/browser/policy/cloud/device_management_service_browsertest.cc scoped_ptr<DeviceManagementRequestJob> job( job 218 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetDMToken(token_); job 219 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetUserAffiliation(USER_AFFILIATION_NONE); job 220 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetClientID("testid"); job 222 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->GetRequest()->mutable_policy_request(); job 224 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->Start(base::Bind(&DeviceManagementServiceIntegrationTest::OnJobDone, job 236 chrome/browser/policy/cloud/device_management_service_browsertest.cc scoped_ptr<DeviceManagementRequestJob> job( job 239 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetDMToken(token_); job 240 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetClientID("testid"); job 241 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->GetRequest()->mutable_unregister_request(); job 242 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->Start(base::Bind(&DeviceManagementServiceIntegrationTest::OnJobDone, job 252 chrome/browser/policy/cloud/device_management_service_browsertest.cc scoped_ptr<DeviceManagementRequestJob> job( job 255 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->SetClientID("testid"); job 256 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->GetRequest()->mutable_auto_enrollment_request()->set_remainder(0); job 257 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->GetRequest()->mutable_auto_enrollment_request()->set_modulus(1); job 258 chrome/browser/policy/cloud/device_management_service_browsertest.cc job->Start(base::Bind(&DeviceManagementServiceIntegrationTest::OnJobDone, job 881 chrome/browser/prerender/prerender_browsertest.cc MockHTTPJob* job = new MockHTTPJob(request, network_delegate, file_); job 882 chrome/browser/prerender/prerender_browsertest.cc job->set_start_callback(base::Bind(&CountingProtocolHandler::RequestStarted, job 884 chrome/browser/prerender/prerender_browsertest.cc return job; job 59 chrome/browser/printing/print_job.cc void PrintJob::Initialize(PrintJobWorkerOwner* job, job 68 chrome/browser/printing/print_job.cc worker_.reset(job->DetachWorker(this)); job 69 chrome/browser/printing/print_job.cc settings_ = job->settings(); job 72 chrome/browser/printing/print_job.cc new PrintedDocument(settings_, source_, job->cookie()); job 45 chrome/browser/printing/print_job.h void Initialize(PrintJobWorkerOwner* job, PrintedPagesSource* source, job 30 chrome/browser/printing/print_job_manager.cc void PrintQueriesQueue::QueuePrinterQuery(PrinterQuery* job) { job 32 chrome/browser/printing/print_job_manager.cc DCHECK(job); job 33 chrome/browser/printing/print_job_manager.cc queued_queries_.push_back(make_scoped_refptr(job)); job 34 chrome/browser/printing/print_job_manager.cc DCHECK(job->is_valid()); job 53 chrome/browser/printing/print_job_manager.cc scoped_refptr<PrinterQuery> job = new printing::PrinterQuery; job 55 chrome/browser/printing/print_job_manager.cc job->SetWorkerDestination(destination_); job 56 chrome/browser/printing/print_job_manager.cc return job; job 97 chrome/browser/printing/print_job_manager.cc for (PrintJobs::const_iterator job = to_stop.begin(); job != to_stop.end(); job 98 chrome/browser/printing/print_job_manager.cc ++job) { job 101 chrome/browser/printing/print_job_manager.cc (*job)->FlushJob(base::TimeDelta::FromMinutes(2)); job 102 chrome/browser/printing/print_job_manager.cc (*job)->Stop(); job 35 chrome/browser/printing/print_job_manager.h void QueuePrinterQuery(PrinterQuery* job); job 103 chrome/browser/printing/print_job_unittest.cc scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check)); job 104 chrome/browser/printing/print_job_unittest.cc EXPECT_EQ(base::MessageLoop::current(), job->message_loop()); job 107 chrome/browser/printing/print_job_unittest.cc job->Initialize(owner.get(), &source, 1); job 108 chrome/browser/printing/print_job_unittest.cc job->Stop(); job 109 chrome/browser/printing/print_job_unittest.cc while (job->document()) { job 112 chrome/browser/printing/print_job_unittest.cc EXPECT_FALSE(job->document()); job 113 chrome/browser/printing/print_job_unittest.cc job = NULL; job 123 chrome/browser/printing/print_job_unittest.cc scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check)); job 124 chrome/browser/printing/print_job_unittest.cc job = NULL; job 344 chrome/browser/printing/print_view_manager_base.cc bool PrintViewManagerBase::CreateNewPrintJob(PrintJobWorkerOwner* job) { job 359 chrome/browser/printing/print_view_manager_base.cc DCHECK(job); job 360 chrome/browser/printing/print_view_manager_base.cc if (!job) job 364 chrome/browser/printing/print_view_manager_base.cc print_job_->Initialize(job, this, number_pages_); job 100 chrome/browser/printing/print_view_manager_base.h bool CreateNewPrintJob(PrintJobWorkerOwner* job); job 211 cloud_print/gcp20/prototype/cloud_print_requester.cc void CloudPrintRequester::RequestPrintJob(const Job& job) { job 213 cloud_print/gcp20/prototype/cloud_print_requester.cc current_print_job_.reset(new Job(job)); job 79 cloud_print/gcp20/prototype/cloud_print_requester.h const cloud_print_response_parser::Job& job) = 0; job 121 cloud_print/gcp20/prototype/cloud_print_requester.h void RequestPrintJob(const cloud_print_response_parser::Job& job); job 189 cloud_print/gcp20/prototype/cloud_print_response_parser.cc base::DictionaryValue* job = NULL; job 190 cloud_print/gcp20/prototype/cloud_print_response_parser.cc jobs->GetDictionary(idx, &job); job 191 cloud_print/gcp20/prototype/cloud_print_response_parser.cc if (!job->GetString("id", &job_list[idx].job_id) || job 192 cloud_print/gcp20/prototype/cloud_print_response_parser.cc !job->GetString("createTime", &create_time_str) || job 193 cloud_print/gcp20/prototype/cloud_print_response_parser.cc !job->GetString("fileUrl", &job_list[idx].file_url) || job 194 cloud_print/gcp20/prototype/cloud_print_response_parser.cc !job->GetString("ticketUrl", &job_list[idx].ticket_url) || job 195 cloud_print/gcp20/prototype/cloud_print_response_parser.cc !job->GetString("title", &job_list[idx].title)) { job 43 cloud_print/gcp20/prototype/print_job_handler.cc LocalPrintJobExtended(const LocalPrintJob& job, const std::string& ticket) job 44 cloud_print/gcp20/prototype/print_job_handler.cc : data(job), job 114 cloud_print/gcp20/prototype/print_job_handler.cc const LocalPrintJob& job, job 136 cloud_print/gcp20/prototype/print_job_handler.cc return CompleteLocalPrintJob(job, id, expires_in_out, job 146 cloud_print/gcp20/prototype/print_job_handler.cc const LocalPrintJob& job, job 159 cloud_print/gcp20/prototype/print_job_handler.cc if (job.content_type == "application/pdf") { job 161 cloud_print/gcp20/prototype/print_job_handler.cc } else if (job.content_type == "image/pwg-raster") { job 163 cloud_print/gcp20/prototype/print_job_handler.cc } else if (job.content_type == "image/jpeg") { job 169 cloud_print/gcp20/prototype/print_job_handler.cc CompleteDraft(job_id, job); job 200 cloud_print/gcp20/prototype/print_job_handler.cc std::map<std::string, LocalPrintJobExtended>::iterator job = jobs.find(id); job 201 cloud_print/gcp20/prototype/print_job_handler.cc if (job != jobs.end()) { job 202 cloud_print/gcp20/prototype/print_job_handler.cc info_out->state = job->second.state; job 262 cloud_print/gcp20/prototype/print_job_handler.cc std::map<std::string, LocalPrintJobExtended>::iterator job = jobs.find(id); job 263 cloud_print/gcp20/prototype/print_job_handler.cc DCHECK(job != jobs.end()); job 264 cloud_print/gcp20/prototype/print_job_handler.cc job->second.state = state; job 271 cloud_print/gcp20/prototype/print_job_handler.cc job->second.expiration = job 285 cloud_print/gcp20/prototype/print_job_handler.cc const LocalPrintJob& job) { job 288 cloud_print/gcp20/prototype/print_job_handler.cc jobs[id] = LocalPrintJobExtended(job, draft->second.ticket); job 39 cloud_print/gcp20/prototype/print_job_handler.h const LocalPrintJob& job, job 47 cloud_print/gcp20/prototype/print_job_handler.h const LocalPrintJob& job, job 81 cloud_print/gcp20/prototype/print_job_handler.h void CompleteDraft(const std::string& id, const LocalPrintJob& job); job 407 cloud_print/gcp20/prototype/printer.cc LocalPrintJob::SaveResult Printer::SubmitDoc(const LocalPrintJob& job, job 412 cloud_print/gcp20/prototype/printer.cc return print_job_handler_->SaveLocalPrintJob(job, job_id, expires_in, job 417 cloud_print/gcp20/prototype/printer.cc const LocalPrintJob& job, job 422 cloud_print/gcp20/prototype/printer.cc return print_job_handler_->CompleteLocalPrintJob(job, job_id, expires_in, job 505 cloud_print/gcp20/prototype/printer.cc void Printer::OnPrintJobDownloaded(const Job& job) { job 507 cloud_print/gcp20/prototype/printer.cc print_job_handler_->SavePrintJob(job.file, job.ticket, job.create_time, job 508 cloud_print/gcp20/prototype/printer.cc job.job_id, job.title, "pdf"); job 509 cloud_print/gcp20/prototype/printer.cc requester_->SendPrintJobDone(job.job_id); job 81 cloud_print/gcp20/prototype/printer.h const LocalPrintJob& job, job 87 cloud_print/gcp20/prototype/printer.h const LocalPrintJob& job, job 115 cloud_print/gcp20/prototype/printer.h const cloud_print_response_parser::Job& job) OVERRIDE; job 332 cloud_print/gcp20/prototype/privet_http_server.cc LocalPrintJob job; job 335 cloud_print/gcp20/prototype/privet_http_server.cc bool job_name_present = GetValueForKeyInQuery(url, "job_name", &job.job_name); job 337 cloud_print/gcp20/prototype/privet_http_server.cc GetValueForKeyInQuery(url, "client_name", &job.client_name); job 338 cloud_print/gcp20/prototype/privet_http_server.cc GetValueForKeyInQuery(url, "user_name", &job.user_name); job 340 cloud_print/gcp20/prototype/privet_http_server.cc job.offline = (offline == "1"); job 341 cloud_print/gcp20/prototype/privet_http_server.cc job.content_type = info.GetHeaderValue("content-type"); job 342 cloud_print/gcp20/prototype/privet_http_server.cc job.content = info.data; job 350 cloud_print/gcp20/prototype/privet_http_server.cc ? delegate_->SubmitDocWithId(job, job_id, &expires_in, job 352 cloud_print/gcp20/prototype/privet_http_server.cc : delegate_->SubmitDoc(job, &job_id, &expires_in, job 362 cloud_print/gcp20/prototype/privet_http_server.cc response->SetString("job_type", job.content_type); job 365 cloud_print/gcp20/prototype/privet_http_server.cc base::StringPrintf("%u", static_cast<uint32>(job.content.size()))); job 367 cloud_print/gcp20/prototype/privet_http_server.cc response->SetString("job_name", job.job_name); job 111 cloud_print/gcp20/prototype/privet_http_server.h const LocalPrintJob& job, job 119 cloud_print/gcp20/prototype/privet_http_server.h const LocalPrintJob& job, job 315 components/policy/core/common/cloud/cloud_policy_client.cc void CloudPolicyClient::OnRetryRegister(DeviceManagementRequestJob* job) { job 316 components/policy/core/common/cloud/cloud_policy_client.cc DCHECK_EQ(request_job_.get(), job); job 322 components/policy/core/common/cloud/cloud_policy_client.cc job->GetRequest()->mutable_register_request()->set_reregister(true); job 226 components/policy/core/common/cloud/cloud_policy_client.h void OnRetryRegister(DeviceManagementRequestJob* job); job 447 components/policy/core/common/cloud/device_management_service.cc for (JobFetcherMap::iterator job(pending_jobs_.begin()); job 448 components/policy/core/common/cloud/device_management_service.cc job != pending_jobs_.end(); job 449 components/policy/core/common/cloud/device_management_service.cc ++job) { job 450 components/policy/core/common/cloud/device_management_service.cc delete job->first; job 451 components/policy/core/common/cloud/device_management_service.cc queued_jobs_.push_back(job->second); job 464 components/policy/core/common/cloud/device_management_service.cc void DeviceManagementService::StartJob(DeviceManagementRequestJobImpl* job) { job 467 components/policy/core/common/cloud/device_management_service.cc kURLFetcherID, job->GetURL(server_url), net::URLFetcher::POST, this); job 468 components/policy/core/common/cloud/device_management_service.cc job->ConfigureRequest(fetcher); job 469 components/policy/core/common/cloud/device_management_service.cc pending_jobs_[fetcher] = job; job 485 components/policy/core/common/cloud/device_management_service.cc DeviceManagementRequestJobImpl* job = entry->second; job 488 components/policy/core/common/cloud/device_management_service.cc if (job->ShouldRetry(source)) { job 490 components/policy/core/common/cloud/device_management_service.cc job->PrepareRetry(); job 491 components/policy/core/common/cloud/device_management_service.cc StartJob(job); job 495 components/policy/core/common/cloud/device_management_service.cc job->HandleResponse(source->GetStatus(), source->GetResponseCode(), job 501 components/policy/core/common/cloud/device_management_service.cc void DeviceManagementService::AddJob(DeviceManagementRequestJobImpl* job) { job 503 components/policy/core/common/cloud/device_management_service.cc StartJob(job); job 505 components/policy/core/common/cloud/device_management_service.cc queued_jobs_.push_back(job); job 508 components/policy/core/common/cloud/device_management_service.cc void DeviceManagementService::RemoveJob(DeviceManagementRequestJobImpl* job) { job 512 components/policy/core/common/cloud/device_management_service.cc if (entry->second == job) { job 520 components/policy/core/common/cloud/device_management_service.cc std::find(queued_jobs_.begin(), queued_jobs_.end(), job); job 160 components/policy/core/common/cloud/device_management_service.h void StartJob(DeviceManagementRequestJobImpl* job); job 164 components/policy/core/common/cloud/device_management_service.h void AddJob(DeviceManagementRequestJobImpl* job); job 168 components/policy/core/common/cloud/device_management_service.h void RemoveJob(DeviceManagementRequestJobImpl* job); job 80 components/policy/core/common/cloud/device_management_service_unittest.cc DeviceManagementRequestJob* job = job 83 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetGaiaToken(kGaiaAuthToken); job 84 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetOAuthToken(kOAuthToken); job 85 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetClientID(kClientID); job 86 components/policy/core/common/cloud/device_management_service_unittest.cc job->GetRequest()->mutable_register_request(); job 87 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetRetryCallback(base::Bind( job 89 components/policy/core/common/cloud/device_management_service_unittest.cc job->Start(base::Bind(&DeviceManagementServiceTestBase::OnJobDone, job 91 components/policy/core/common/cloud/device_management_service_unittest.cc return job; job 95 components/policy/core/common/cloud/device_management_service_unittest.cc DeviceManagementRequestJob* job = service_->CreateJob( job 98 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetGaiaToken(kGaiaAuthToken); job 99 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetOAuthToken(kOAuthToken); job 100 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetClientID(kClientID); job 101 components/policy/core/common/cloud/device_management_service_unittest.cc job->GetRequest()->mutable_service_api_access_request(); job 102 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetRetryCallback(base::Bind( job 104 components/policy/core/common/cloud/device_management_service_unittest.cc job->Start(base::Bind(&DeviceManagementServiceTestBase::OnJobDone, job 106 components/policy/core/common/cloud/device_management_service_unittest.cc return job; job 110 components/policy/core/common/cloud/device_management_service_unittest.cc DeviceManagementRequestJob* job = job 113 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetDMToken(kDMToken); job 114 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetClientID(kClientID); job 115 components/policy/core/common/cloud/device_management_service_unittest.cc job->GetRequest()->mutable_unregister_request(); job 116 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetRetryCallback(base::Bind( job 118 components/policy/core/common/cloud/device_management_service_unittest.cc job->Start(base::Bind(&DeviceManagementServiceTestBase::OnJobDone, job 120 components/policy/core/common/cloud/device_management_service_unittest.cc return job; job 124 components/policy/core/common/cloud/device_management_service_unittest.cc DeviceManagementRequestJob* job = job 127 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetGaiaToken(kGaiaAuthToken); job 128 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetOAuthToken(kOAuthToken); job 129 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetClientID(kClientID); job 131 components/policy/core/common/cloud/device_management_service_unittest.cc job->GetRequest()->mutable_policy_request()->add_request(); job 133 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetRetryCallback(base::Bind( job 135 components/policy/core/common/cloud/device_management_service_unittest.cc job->Start(base::Bind(&DeviceManagementServiceTestBase::OnJobDone, job 137 components/policy/core/common/cloud/device_management_service_unittest.cc return job; job 141 components/policy/core/common/cloud/device_management_service_unittest.cc DeviceManagementRequestJob* job = job 144 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetClientID(kClientID); job 146 components/policy/core/common/cloud/device_management_service_unittest.cc job->GetRequest()->mutable_auto_enrollment_request(); job 149 components/policy/core/common/cloud/device_management_service_unittest.cc job->SetRetryCallback(base::Bind( job 151 components/policy/core/common/cloud/device_management_service_unittest.cc job->Start(base::Bind(&DeviceManagementServiceTestBase::OnJobDone, job 153 components/policy/core/common/cloud/device_management_service_unittest.cc return job; job 29 components/policy/core/common/cloud/external_policy_data_fetcher.cc ExternalPolicyDataFetcher::Job* job, job 33 components/policy/core/common/cloud/external_policy_data_fetcher.cc base::Bind(callback, job, result, base::Passed(&data))); job 50 components/policy/core/common/cloud/external_policy_data_fetcher.cc void DoNothing(ExternalPolicyDataFetcher::Job* job) { job 98 components/policy/core/common/cloud/external_policy_data_fetcher.cc Job* job = new Job( job 105 components/policy/core/common/cloud/external_policy_data_fetcher.cc jobs_.insert(job); job 108 components/policy/core/common/cloud/external_policy_data_fetcher.cc base::Bind(&ExternalPolicyDataFetcherBackend::StartJob, backend_, job)); job 109 components/policy/core/common/cloud/external_policy_data_fetcher.cc return job; job 112 components/policy/core/common/cloud/external_policy_data_fetcher.cc void ExternalPolicyDataFetcher::CancelJob(Job* job) { job 114 components/policy/core/common/cloud/external_policy_data_fetcher.cc DCHECK(jobs_.find(job) != jobs_.end()); job 115 components/policy/core/common/cloud/external_policy_data_fetcher.cc jobs_.erase(job); job 126 components/policy/core/common/cloud/external_policy_data_fetcher.cc job, job 129 components/policy/core/common/cloud/external_policy_data_fetcher.cc base::Bind(&DoNothing, base::Owned(job))))); job 133 components/policy/core/common/cloud/external_policy_data_fetcher.cc Job* job, job 137 components/policy/core/common/cloud/external_policy_data_fetcher.cc JobSet::iterator it = jobs_.find(job); job 146 components/policy/core/common/cloud/external_policy_data_fetcher.cc delete job; job 171 components/policy/core/common/cloud/external_policy_data_fetcher.cc ExternalPolicyDataFetcher::Job* job) { job 174 components/policy/core/common/cloud/external_policy_data_fetcher.cc ++last_fetch_id_, job->url, net::URLFetcher::GET, this); job 182 components/policy/core/common/cloud/external_policy_data_fetcher.cc job_map_[fetcher] = job; job 186 components/policy/core/common/cloud/external_policy_data_fetcher.cc ExternalPolicyDataFetcher::Job* job, job 190 components/policy/core/common/cloud/external_policy_data_fetcher.cc if (it->second == job) { job 239 components/policy/core/common/cloud/external_policy_data_fetcher.cc ExternalPolicyDataFetcher::Job* job = it->second; job 242 components/policy/core/common/cloud/external_policy_data_fetcher.cc job->callback.Run(job, result, data.Pass()); job 258 components/policy/core/common/cloud/external_policy_data_fetcher.cc ExternalPolicyDataFetcher::Job* job = it->second; job 261 components/policy/core/common/cloud/external_policy_data_fetcher.cc job->callback.Run(job, job 91 components/policy/core/common/cloud/external_policy_data_fetcher.h void CancelJob(Job* job); job 96 components/policy/core/common/cloud/external_policy_data_fetcher.h Job* job, job 152 components/policy/core/common/cloud/external_policy_data_fetcher.h void StartJob(ExternalPolicyDataFetcher::Job* job); job 155 components/policy/core/common/cloud/external_policy_data_fetcher.h void CancelJob(ExternalPolicyDataFetcher::Job* job, job 98 components/policy/core/common/cloud/external_policy_data_fetcher_unittest.cc ExternalPolicyDataFetcher::Job* job = it->second; job 100 components/policy/core/common/cloud/external_policy_data_fetcher_unittest.cc fetcher_->CancelJob(job); job 319 components/policy/core/common/cloud/external_policy_data_updater.cc FetchJob* job = job_map_[key]; job 320 components/policy/core/common/cloud/external_policy_data_updater.cc if (job) { job 323 components/policy/core/common/cloud/external_policy_data_updater.cc if (job->request() == request) job 329 components/policy/core/common/cloud/external_policy_data_updater.cc delete job; job 334 components/policy/core/common/cloud/external_policy_data_updater.cc job = new FetchJob(this, key, request, callback); job 335 components/policy/core/common/cloud/external_policy_data_updater.cc job_map_[key] = job; job 336 components/policy/core/common/cloud/external_policy_data_updater.cc ScheduleJob(job); job 346 components/policy/core/common/cloud/external_policy_data_updater.cc std::map<std::string, FetchJob*>::iterator job = job_map_.find(key); job 347 components/policy/core/common/cloud/external_policy_data_updater.cc if (job != job_map_.end()) { job 348 components/policy/core/common/cloud/external_policy_data_updater.cc delete job->second; job 349 components/policy/core/common/cloud/external_policy_data_updater.cc job_map_.erase(job); job 358 components/policy/core/common/cloud/external_policy_data_updater.cc FetchJob* job = job_queue_.front().get(); job 362 components/policy/core/common/cloud/external_policy_data_updater.cc if (job) { job 365 components/policy/core/common/cloud/external_policy_data_updater.cc job->Start(); job 370 components/policy/core/common/cloud/external_policy_data_updater.cc void ExternalPolicyDataUpdater::ScheduleJob(FetchJob* job) { job 371 components/policy/core/common/cloud/external_policy_data_updater.cc DCHECK_EQ(job_map_[job->key()], job); job 373 components/policy/core/common/cloud/external_policy_data_updater.cc job_queue_.push(job->AsWeakPtr()); job 378 components/policy/core/common/cloud/external_policy_data_updater.cc void ExternalPolicyDataUpdater::OnJobSucceeded(FetchJob* job) { job 380 components/policy/core/common/cloud/external_policy_data_updater.cc DCHECK_EQ(job_map_[job->key()], job); job 383 components/policy/core/common/cloud/external_policy_data_updater.cc job_map_.erase(job->key()); job 384 components/policy/core/common/cloud/external_policy_data_updater.cc delete job; job 389 components/policy/core/common/cloud/external_policy_data_updater.cc void ExternalPolicyDataUpdater::OnJobFailed(FetchJob* job) { job 391 components/policy/core/common/cloud/external_policy_data_updater.cc DCHECK_EQ(job_map_[job->key()], job); job 93 components/policy/core/common/cloud/external_policy_data_updater.h void ScheduleJob(FetchJob* job); job 96 components/policy/core/common/cloud/external_policy_data_updater.h void OnJobSucceeded(FetchJob* job); job 99 components/policy/core/common/cloud/external_policy_data_updater.h void OnJobFailed(FetchJob* job); job 117 components/policy/core/common/cloud/mock_device_management_service.cc AsyncRequestJob* job = new AsyncRequestJob(arg0, service); job 118 components/policy/core/common/cloud/mock_device_management_service.cc *mock_job = job; job 119 components/policy/core/common/cloud/mock_device_management_service.cc return job; job 166 components/policy/core/common/cloud/mock_device_management_service.cc MockDeviceManagementService::CreateAsyncJob(MockDeviceManagementJob** job) { job 167 components/policy/core/common/cloud/mock_device_management_service.cc return CreateAsyncMockDeviceManagementJob(this, job); job 73 components/policy/core/common/cloud/mock_device_management_service.h MockDeviceManagementJob** job); job 179 content/browser/download/mhtml_generation_manager.cc Job* job = iter->second; job 180 content/browser/download/mhtml_generation_manager.cc job->set_browser_file(browser_file.Pass()); job 183 content/browser/download/mhtml_generation_manager.cc job->process_id(), job->routing_id()); job 202 content/browser/download/mhtml_generation_manager.cc Job* job = iter->second; job 203 content/browser/download/mhtml_generation_manager.cc job->callback().Run(file_size); job 207 content/browser/download/mhtml_generation_manager.cc base::Passed(job->browser_file()))); job 210 content/browser/download/mhtml_generation_manager.cc delete job; job 222 content/browser/download/mhtml_generation_manager.cc Job* job = new Job(); job 223 content/browser/download/mhtml_generation_manager.cc id_to_job_[job_id] = job; job 224 content/browser/download/mhtml_generation_manager.cc job->SetWebContents(web_contents); job 225 content/browser/download/mhtml_generation_manager.cc job->set_callback(callback); job 229 content/browser/download/mhtml_generation_manager.cc void MHTMLGenerationManager::RenderProcessExited(Job* job) { job 233 content/browser/download/mhtml_generation_manager.cc if (it->second == job) { job 78 content/browser/download/mhtml_generation_manager.h void RenderProcessExited(Job* job); job 283 content/browser/loader/resource_dispatcher_host_unittest.cc for (URLRequestTestDelayedStartJob* job = list_head_; job 284 content/browser/loader/resource_dispatcher_host_unittest.cc job; job 285 content/browser/loader/resource_dispatcher_host_unittest.cc job = job->next_) { job 286 content/browser/loader/resource_dispatcher_host_unittest.cc if (job->request() == request) { job 287 content/browser/loader/resource_dispatcher_host_unittest.cc job->net::URLRequestTestJob::Start(); job 309 content/browser/loader/resource_dispatcher_host_unittest.cc for (URLRequestTestDelayedStartJob** job = &list_head_; *job; job 310 content/browser/loader/resource_dispatcher_host_unittest.cc job = &(*job)->next_) { job 311 content/browser/loader/resource_dispatcher_host_unittest.cc if (*job == this) { job 312 content/browser/loader/resource_dispatcher_host_unittest.cc *job = (*job)->next_; job 22 content/browser/service_worker/service_worker_job_coordinator.cc scoped_ptr<ServiceWorkerRegisterJobBase> job) { job 24 content/browser/service_worker/service_worker_job_coordinator.cc job->Start(); job 25 content/browser/service_worker/service_worker_job_coordinator.cc jobs_.push_back(job.release()); job 26 content/browser/service_worker/service_worker_job_coordinator.cc } else if (!job->Equals(jobs_.back())) { job 27 content/browser/service_worker/service_worker_job_coordinator.cc jobs_.push_back(job.release()); job 36 content/browser/service_worker/service_worker_job_coordinator.cc ServiceWorkerRegisterJobBase* job) { job 37 content/browser/service_worker/service_worker_job_coordinator.cc DCHECK(job == jobs_.front()); job 39 content/browser/service_worker/service_worker_job_coordinator.cc delete job; job 59 content/browser/service_worker/service_worker_job_coordinator.cc scoped_ptr<ServiceWorkerRegisterJobBase> job( job 62 content/browser/service_worker/service_worker_job_coordinator.cc static_cast<ServiceWorkerRegisterJob*>(jobs_[pattern].Push(job.Pass())); job 70 content/browser/service_worker/service_worker_job_coordinator.cc scoped_ptr<ServiceWorkerRegisterJobBase> job( job 73 content/browser/service_worker/service_worker_job_coordinator.cc static_cast<ServiceWorkerUnregisterJob*>(jobs_[pattern].Push(job.Pass())); job 78 content/browser/service_worker/service_worker_job_coordinator.cc ServiceWorkerRegisterJobBase* job) { job 81 content/browser/service_worker/service_worker_job_coordinator.cc pending_jobs->second.Pop(job); job 40 content/browser/service_worker/service_worker_job_coordinator.h void FinishJob(const GURL& pattern, ServiceWorkerRegisterJobBase* job); job 52 content/browser/service_worker/service_worker_job_coordinator.h scoped_ptr<ServiceWorkerRegisterJobBase> job); job 55 content/browser/service_worker/service_worker_job_coordinator.h void Pop(ServiceWorkerRegisterJobBase* job); job 50 content/browser/service_worker/service_worker_register_job.cc bool ServiceWorkerRegisterJob::Equals(ServiceWorkerRegisterJobBase* job) { job 51 content/browser/service_worker/service_worker_register_job.cc if (job->GetType() != GetType()) job 54 content/browser/service_worker/service_worker_register_job.cc static_cast<ServiceWorkerRegisterJob*>(job); job 53 content/browser/service_worker/service_worker_register_job.h virtual bool Equals(ServiceWorkerRegisterJobBase* job) OVERRIDE; job 25 content/browser/service_worker/service_worker_register_job_base.h virtual bool Equals(ServiceWorkerRegisterJobBase* job) = 0; job 37 content/browser/service_worker/service_worker_unregister_job.cc bool ServiceWorkerUnregisterJob::Equals(ServiceWorkerRegisterJobBase* job) { job 38 content/browser/service_worker/service_worker_unregister_job.cc if (job->GetType() != GetType()) job 40 content/browser/service_worker/service_worker_unregister_job.cc return static_cast<ServiceWorkerUnregisterJob*>(job)->pattern_ == pattern_; job 43 content/browser/service_worker/service_worker_unregister_job.h virtual bool Equals(ServiceWorkerRegisterJobBase* job) OVERRIDE; job 73 content/browser/service_worker/service_worker_url_request_job_unittest.cc ServiceWorkerURLRequestJob* job = new ServiceWorkerURLRequestJob( job 75 content/browser/service_worker/service_worker_url_request_job_unittest.cc job->ForwardToServiceWorker(); job 76 content/browser/service_worker/service_worker_url_request_job_unittest.cc return job; job 172 content/browser/webui/url_data_manager_backend.cc const base::WeakPtr<URLRequestChromeJob>& job); job 357 content/browser/webui/url_data_manager_backend.cc const base::WeakPtr<URLRequestChromeJob>& job) { job 386 content/browser/webui/url_data_manager_backend.cc base::Bind(&URLRequestChromeJob::StartAsync, job, allowed)); job 407 content/browser/webui/url_data_manager_backend.cc const base::WeakPtr<URLRequestChromeJob>& job) { job 412 content/browser/webui/url_data_manager_backend.cc base::Bind(&URLRequestChromeJob::MimeTypeAvailable, job, mime_type)); job 536 content/browser/webui/url_data_manager_backend.cc URLRequestChromeJob* job) const { job 539 content/browser/webui/url_data_manager_backend.cc if (i->second == job) job 546 content/browser/webui/url_data_manager_backend.cc URLRequestChromeJob* job) { job 563 content/browser/webui/url_data_manager_backend.cc pending_requests_.insert(std::make_pair(request_id, job)); job 565 content/browser/webui/url_data_manager_backend.cc job->set_allow_caching(source->source()->AllowCaching()); job 566 content/browser/webui/url_data_manager_backend.cc job->set_add_content_security_policy( job 568 content/browser/webui/url_data_manager_backend.cc job->set_content_security_policy_object_source( job 570 content/browser/webui/url_data_manager_backend.cc job->set_content_security_policy_frame_source( job 572 content/browser/webui/url_data_manager_backend.cc job->set_deny_xframe_options( job 574 content/browser/webui/url_data_manager_backend.cc job->set_send_content_type_header( job 588 content/browser/webui/url_data_manager_backend.cc job->MimeTypeAvailable(source->source()->GetMimeType(path)); job 590 content/browser/webui/url_data_manager_backend.cc job = NULL; job 607 content/browser/webui/url_data_manager_backend.cc path, job->AsWeakPtr())); job 660 content/browser/webui/url_data_manager_backend.cc void URLDataManagerBackend::RemoveRequest(URLRequestChromeJob* job) { job 666 content/browser/webui/url_data_manager_backend.cc if (i->second == job) { job 678 content/browser/webui/url_data_manager_backend.cc URLRequestChromeJob* job(i->second); job 680 content/browser/webui/url_data_manager_backend.cc job->DataAvailable(bytes); job 72 content/browser/webui/url_data_manager_backend.h bool StartRequest(const net::URLRequest* request, URLRequestChromeJob* job); job 84 content/browser/webui/url_data_manager_backend.h void RemoveRequest(URLRequestChromeJob* job); job 89 content/browser/webui/url_data_manager_backend.h bool HasPendingJob(URLRequestChromeJob* job) const; job 65 content/test/net/url_request_slow_download_job.cc URLRequestSlowDownloadJob* job = new URLRequestSlowDownloadJob( job 69 content/test/net/url_request_slow_download_job.cc pending_requests_.Get().insert(job); job 70 content/test/net/url_request_slow_download_job.cc return job; job 67 mojo/shell/loader.cc scoped_ptr<Job> job(new Job(app_url, delegate)); job 68 mojo/shell/loader.cc job->fetcher_->SetRequestContext(url_request_context_getter_.get()); job 74 mojo/shell/loader.cc job->fetcher_->SaveResponseToFileAtPath( job 78 mojo/shell/loader.cc job->fetcher_->SaveResponseToTemporaryFile(file_runner_.get()); job 81 mojo/shell/loader.cc job->fetcher_->SetLoadFlags(net::LOAD_DISABLE_CACHE); job 82 mojo/shell/loader.cc job->fetcher_->Start(); job 83 mojo/shell/loader.cc return job.Pass(); job 27 net/base/prioritized_dispatcher.cc Job* job, Priority priority) { job 28 net/base/prioritized_dispatcher.cc DCHECK(job); job 32 net/base/prioritized_dispatcher.cc job->Start(); job 35 net/base/prioritized_dispatcher.cc return queue_.Insert(job, priority); job 39 net/base/prioritized_dispatcher.cc Job* job, Priority priority) { job 40 net/base/prioritized_dispatcher.cc DCHECK(job); job 44 net/base/prioritized_dispatcher.cc job->Start(); job 47 net/base/prioritized_dispatcher.cc return queue_.InsertAtFront(job, priority); job 58 net/base/prioritized_dispatcher.cc Job* job = handle.value(); job 60 net/base/prioritized_dispatcher.cc return job; job 75 net/base/prioritized_dispatcher.cc Job* job = handle.value(); job 77 net/base/prioritized_dispatcher.cc return queue_.Insert(job, priority); job 129 net/base/prioritized_dispatcher.cc Job* job = handle.value(); job 132 net/base/prioritized_dispatcher.cc job->Start(); job 79 net/base/prioritized_dispatcher.h Handle Add(Job* job, Priority priority); job 83 net/base/prioritized_dispatcher.h Handle AddAtHead(Job* job, Priority priority); job 145 net/base/prioritized_dispatcher_unittest.cc TestJob* job = new TestJob(dispatcher_.get(), data, priority, &log_); job 146 net/base/prioritized_dispatcher_unittest.cc jobs_.push_back(job); job 147 net/base/prioritized_dispatcher_unittest.cc job->Add(false); job 148 net/base/prioritized_dispatcher_unittest.cc return job; job 152 net/base/prioritized_dispatcher_unittest.cc TestJob* job = new TestJob(dispatcher_.get(), data, priority, &log_); job 153 net/base/prioritized_dispatcher_unittest.cc jobs_.push_back(job); job 154 net/base/prioritized_dispatcher_unittest.cc job->Add(true); job 155 net/base/prioritized_dispatcher_unittest.cc return job; job 447 net/cert/multi_threaded_cert_verifier.cc CertVerifierJob* job; job 454 net/cert/multi_threaded_cert_verifier.cc job = j->second; job 465 net/cert/multi_threaded_cert_verifier.cc job = new CertVerifierJob( job 469 net/cert/multi_threaded_cert_verifier.cc delete job; job 476 net/cert/multi_threaded_cert_verifier.cc inflight_.insert(std::make_pair(key, job)); job 481 net/cert/multi_threaded_cert_verifier.cc job->AddRequest(request); job 552 net/cert/multi_threaded_cert_verifier.cc CertVerifierJob* job = j->second; job 555 net/cert/multi_threaded_cert_verifier.cc job->HandleResult(cached_result); job 556 net/cert/multi_threaded_cert_verifier.cc delete job; job 36 net/dns/address_sorter_win.cc scoped_refptr<Job> job = new Job(list, callback); job 488 net/dns/host_resolver_impl.cc void set_job(Job* job) { job 489 net/dns/host_resolver_impl.cc DCHECK(job); job 491 net/dns/host_resolver_impl.cc job_ = job; job 1249 net/dns/host_resolver_impl.cc DCHECK_EQ(this, req->job()); job 1700 net/dns/host_resolver_impl.cc DCHECK_EQ(this, req->job()); job 1896 net/dns/host_resolver_impl.cc Job* job; job 1898 net/dns/host_resolver_impl.cc job = job 1900 net/dns/host_resolver_impl.cc job->Schedule(false); job 1907 net/dns/host_resolver_impl.cc if (evicted == job) { job 1913 net/dns/host_resolver_impl.cc jobs_.insert(jobit, std::make_pair(key, job)); job 1915 net/dns/host_resolver_impl.cc job = jobit->second; job 1924 net/dns/host_resolver_impl.cc job->AddRequest(req.Pass()); job 1979 net/dns/host_resolver_impl.cc Job* job = req->job(); job 1980 net/dns/host_resolver_impl.cc DCHECK(job); job 1981 net/dns/host_resolver_impl.cc job->CancelRequest(req); job 2128 net/dns/host_resolver_impl.cc void HostResolverImpl::RemoveJob(Job* job) { job 2129 net/dns/host_resolver_impl.cc DCHECK(job); job 2130 net/dns/host_resolver_impl.cc JobMap::iterator it = jobs_.find(job->key()); job 2131 net/dns/host_resolver_impl.cc if (it != jobs_.end() && it->second == job) job 2192 net/dns/host_resolver_impl.cc Job* job = it->second; job 2193 net/dns/host_resolver_impl.cc if (job->is_running()) { job 2194 net/dns/host_resolver_impl.cc jobs_to_abort.push_back(job); job 2197 net/dns/host_resolver_impl.cc DCHECK(job->is_queued()); job 2247 net/dns/host_resolver_impl.cc Job* job = it->second; job 2250 net/dns/host_resolver_impl.cc job->ServeFromHosts(); job 209 net/dns/host_resolver_impl.h void RemoveJob(Job* job); job 137 net/http/http_stream_factory_impl.cc Job* job = new Job(this, session_, request_info, priority, job 139 net/http/http_stream_factory_impl.cc request->AttachJob(job); job 144 net/http/http_stream_factory_impl.cc job->WaitFor(alternate_job); job 153 net/http/http_stream_factory_impl.cc job->Start(request); job 167 net/http/http_stream_factory_impl.cc Job* job = NULL; job 171 net/http/http_stream_factory_impl.cc job = new Job(this, session_, alternate_request_info, priority, job 173 net/http/http_stream_factory_impl.cc job->MarkAsAlternate(request_info.url, alternate); job 175 net/http/http_stream_factory_impl.cc job = new Job(this, session_, request_info, priority, job 178 net/http/http_stream_factory_impl.cc preconnect_job_set_.insert(job); job 179 net/http/http_stream_factory_impl.cc job->Preconnect(num_streams); job 255 net/http/http_stream_factory_impl.cc void HttpStreamFactoryImpl::OrphanJob(Job* job, const Request* request) { job 256 net/http/http_stream_factory_impl.cc DCHECK(ContainsKey(request_map_, job)); job 257 net/http/http_stream_factory_impl.cc DCHECK_EQ(request_map_[job], request); job 258 net/http/http_stream_factory_impl.cc DCHECK(!ContainsKey(orphaned_job_set_, job)); job 260 net/http/http_stream_factory_impl.cc request_map_.erase(job); job 262 net/http/http_stream_factory_impl.cc orphaned_job_set_.insert(job); job 263 net/http/http_stream_factory_impl.cc job->Orphan(request); job 309 net/http/http_stream_factory_impl.cc void HttpStreamFactoryImpl::OnOrphanedJobComplete(const Job* job) { job 310 net/http/http_stream_factory_impl.cc orphaned_job_set_.erase(job); job 311 net/http/http_stream_factory_impl.cc delete job; job 314 net/http/http_stream_factory_impl.cc void HttpStreamFactoryImpl::OnPreconnectsComplete(const Job* job) { job 315 net/http/http_stream_factory_impl.cc preconnect_job_set_.erase(job); job 316 net/http/http_stream_factory_impl.cc delete job; job 343 net/http/http_stream_factory_impl.cc const Job* job, const HttpPipelinedHost::Key& key, int status, job 349 net/http/http_stream_factory_impl.cc if (request == request_map_[job]) { job 96 net/http/http_stream_factory_impl.h void OrphanJob(Job* job, const Request* request); job 116 net/http/http_stream_factory_impl.h void OnOrphanedJobComplete(const Job* job); job 119 net/http/http_stream_factory_impl.h void OnPreconnectsComplete(const Job* job); job 124 net/http/http_stream_factory_impl.h void AbortPipelinedRequestsWithKey(const Job* job, job 187 net/http/http_stream_factory_impl_job.cc void HttpStreamFactoryImpl::Job::WaitFor(Job* job) { job 189 net/http/http_stream_factory_impl_job.cc DCHECK_EQ(STATE_NONE, job->next_state_); job 191 net/http/http_stream_factory_impl_job.cc DCHECK(!job->waiting_job_); job 192 net/http/http_stream_factory_impl_job.cc blocking_job_ = job; job 193 net/http/http_stream_factory_impl_job.cc job->waiting_job_ = this; job 196 net/http/http_stream_factory_impl_job.cc void HttpStreamFactoryImpl::Job::Resume(Job* job) { job 197 net/http/http_stream_factory_impl_job.cc DCHECK_EQ(blocking_job_, job); job 67 net/http/http_stream_factory_impl_job.h void WaitFor(Job* job); job 72 net/http/http_stream_factory_impl_job.h void Resume(Job* job); job 78 net/http/http_stream_factory_impl_request.cc void HttpStreamFactoryImpl::Request::AttachJob(Job* job) { job 79 net/http/http_stream_factory_impl_request.cc DCHECK(job); job 80 net/http/http_stream_factory_impl_request.cc jobs_.insert(job); job 81 net/http/http_stream_factory_impl_request.cc factory_->request_map_[job] = this; job 103 net/http/http_stream_factory_impl_request.cc Job* job, job 111 net/http/http_stream_factory_impl_request.cc OnJobSucceeded(job); job 116 net/http/http_stream_factory_impl_request.cc Job* job, job 124 net/http/http_stream_factory_impl_request.cc OnJobSucceeded(job); job 130 net/http/http_stream_factory_impl_request.cc Job* job, job 137 net/http/http_stream_factory_impl_request.cc if (!job) { job 147 net/http/http_stream_factory_impl_request.cc jobs_.erase(job); job 148 net/http/http_stream_factory_impl_request.cc factory_->request_map_.erase(job); job 149 net/http/http_stream_factory_impl_request.cc delete job; job 152 net/http/http_stream_factory_impl_request.cc bound_job_.reset(job); job 153 net/http/http_stream_factory_impl_request.cc jobs_.erase(job); job 155 net/http/http_stream_factory_impl_request.cc factory_->request_map_.erase(job); job 164 net/http/http_stream_factory_impl_request.cc Job* job, job 170 net/http/http_stream_factory_impl_request.cc OrphanJobsExcept(job); job 177 net/http/http_stream_factory_impl_request.cc Job* job, job 183 net/http/http_stream_factory_impl_request.cc OrphanJobsExcept(job); job 191 net/http/http_stream_factory_impl_request.cc Job* job, job 195 net/http/http_stream_factory_impl_request.cc OrphanJobsExcept(job); job 202 net/http/http_stream_factory_impl_request.cc Job *job, job 208 net/http/http_stream_factory_impl_request.cc OrphanJobsExcept(job); job 293 net/http/http_stream_factory_impl_request.cc Job* job, job 297 net/http/http_stream_factory_impl_request.cc DCHECK(job); job 298 net/http/http_stream_factory_impl_request.cc DCHECK(job->using_spdy()); job 306 net/http/http_stream_factory_impl_request.cc OrphanJobsExcept(job); job 308 net/http/http_stream_factory_impl_request.cc DCHECK_EQ(bound_job_.get(), job); job 313 net/http/http_stream_factory_impl_request.cc const SSLConfig used_ssl_config = job->server_ssl_config(); job 314 net/http/http_stream_factory_impl_request.cc const ProxyInfo used_proxy_info = job->proxy_info(); job 315 net/http/http_stream_factory_impl_request.cc const bool was_npn_negotiated = job->was_npn_negotiated(); job 317 net/http/http_stream_factory_impl_request.cc job->protocol_negotiated(); job 318 net/http/http_stream_factory_impl_request.cc const bool using_spdy = job->using_spdy(); job 319 net/http/http_stream_factory_impl_request.cc const BoundNetLog net_log = job->net_log(); job 330 net/http/http_stream_factory_impl_request.cc delegate_->OnStreamReady(job->server_ssl_config(), job->proxy_info(), job 346 net/http/http_stream_factory_impl_request.cc void HttpStreamFactoryImpl::Request::OrphanJobsExcept(Job* job) { job 347 net/http/http_stream_factory_impl_request.cc DCHECK(job); job 349 net/http/http_stream_factory_impl_request.cc DCHECK(ContainsKey(jobs_, job)); job 350 net/http/http_stream_factory_impl_request.cc bound_job_.reset(job); job 351 net/http/http_stream_factory_impl_request.cc jobs_.erase(job); job 352 net/http/http_stream_factory_impl_request.cc factory_->request_map_.erase(job); job 368 net/http/http_stream_factory_impl_request.cc void HttpStreamFactoryImpl::Request::OnJobSucceeded(Job* job) { job 372 net/http/http_stream_factory_impl_request.cc if (!job) { job 386 net/http/http_stream_factory_impl_request.cc OrphanJobsExcept(job); job 49 net/http/http_stream_factory_impl_request.h void AttachJob(HttpStreamFactoryImpl::Job* job); job 67 net/http/http_stream_factory_impl_request.h void OnNewSpdySessionReady(Job* job, job 80 net/http/http_stream_factory_impl_request.h void OnStreamReady(Job* job, job 84 net/http/http_stream_factory_impl_request.h void OnWebSocketHandshakeStreamReady(Job* job, job 88 net/http/http_stream_factory_impl_request.h void OnStreamFailed(Job* job, int status, const SSLConfig& used_ssl_config); job 89 net/http/http_stream_factory_impl_request.h void OnCertificateError(Job* job, job 93 net/http/http_stream_factory_impl_request.h void OnNeedsProxyAuth(Job* job, job 98 net/http/http_stream_factory_impl_request.h void OnNeedsClientAuth(Job* job, job 102 net/http/http_stream_factory_impl_request.h Job *job, job 121 net/http/http_stream_factory_impl_request.h void OrphanJobsExcept(Job* job); job 127 net/http/http_stream_factory_impl_request.h void OnJobSucceeded(Job* job); job 78 net/http/http_stream_factory_impl_request_unittest.cc HttpStreamFactoryImpl::Job* job = job 86 net/http/http_stream_factory_impl_request_unittest.cc request.AttachJob(job); job 87 net/http/http_stream_factory_impl_request_unittest.cc EXPECT_EQ(DEFAULT_PRIORITY, job->priority()); job 90 net/http/http_stream_factory_impl_request_unittest.cc EXPECT_EQ(MEDIUM, job->priority()); job 93 net/http/http_stream_factory_impl_request_unittest.cc request.OnStreamFailed(job, ERR_FAILED, SSLConfig()); job 96 net/http/http_stream_factory_impl_request_unittest.cc EXPECT_EQ(IDLE, job->priority()); job 41 net/proxy/multi_threaded_proxy_resolver.cc void StartJob(Job* job); job 44 net/proxy/multi_threaded_proxy_resolver.cc void OnJobCompleted(Job* job); job 325 net/proxy/multi_threaded_proxy_resolver.cc void MultiThreadedProxyResolver::Executor::StartJob(Job* job) { job 327 net/proxy/multi_threaded_proxy_resolver.cc outstanding_job_ = job; job 331 net/proxy/multi_threaded_proxy_resolver.cc job->set_executor(this); job 332 net/proxy/multi_threaded_proxy_resolver.cc job->FinishedWaitingForThread(); job 335 net/proxy/multi_threaded_proxy_resolver.cc base::Bind(&Job::Run, job, base::MessageLoopProxy::current())); job 338 net/proxy/multi_threaded_proxy_resolver.cc void MultiThreadedProxyResolver::Executor::OnJobCompleted(Job* job) { job 339 net/proxy/multi_threaded_proxy_resolver.cc DCHECK_EQ(job, outstanding_job_.get()); job 405 net/proxy/multi_threaded_proxy_resolver.cc scoped_refptr<GetProxyForURLJob> job( job 411 net/proxy/multi_threaded_proxy_resolver.cc *request = reinterpret_cast<RequestHandle>(job.get()); job 417 net/proxy/multi_threaded_proxy_resolver.cc executor->StartJob(job.get()); job 423 net/proxy/multi_threaded_proxy_resolver.cc job->WaitingForThread(); job 424 net/proxy/multi_threaded_proxy_resolver.cc pending_jobs_.push_back(job); job 441 net/proxy/multi_threaded_proxy_resolver.cc Job* job = reinterpret_cast<Job*>(req); job 442 net/proxy/multi_threaded_proxy_resolver.cc DCHECK_EQ(Job::TYPE_GET_PROXY_FOR_URL, job->type()); job 444 net/proxy/multi_threaded_proxy_resolver.cc if (job->executor()) { job 447 net/proxy/multi_threaded_proxy_resolver.cc job->Cancel(); job 451 net/proxy/multi_threaded_proxy_resolver.cc std::find(pending_jobs_.begin(), pending_jobs_.end(), job); job 507 net/proxy/multi_threaded_proxy_resolver.cc Job* job = executor->outstanding_job(); job 514 net/proxy/multi_threaded_proxy_resolver.cc CHECK(!job || job->was_cancelled() || !job->has_user_callback()); job 560 net/proxy/multi_threaded_proxy_resolver.cc scoped_refptr<Job> job = pending_jobs_.front(); job 562 net/proxy/multi_threaded_proxy_resolver.cc executor->StartJob(job.get()); job 1130 net/proxy/proxy_resolver_v8_tracing.cc scoped_refptr<Job> job = new Job(this); job 1133 net/proxy/proxy_resolver_v8_tracing.cc *request = job.get(); job 1135 net/proxy/proxy_resolver_v8_tracing.cc job->StartGetProxyForURL(url, results, net_log, callback); job 1140 net/proxy/proxy_resolver_v8_tracing.cc Job* job = reinterpret_cast<Job*>(request); job 1141 net/proxy/proxy_resolver_v8_tracing.cc job->Cancel(); job 1145 net/proxy/proxy_resolver_v8_tracing.cc Job* job = reinterpret_cast<Job*>(request); job 1146 net/proxy/proxy_resolver_v8_tracing.cc return job->GetLoadState(); job 335 net/quic/crypto/proof_verifier_chromium.cc scoped_ptr<Job> job(new Job(this, cert_verifier_, chromium_context->net_log)); job 336 net/quic/crypto/proof_verifier_chromium.cc Status status = job->VerifyProof(hostname, server_config, certs, signature, job 339 net/quic/crypto/proof_verifier_chromium.cc active_jobs_.insert(job.release()); job 344 net/quic/crypto/proof_verifier_chromium.cc void ProofVerifierChromium::OnJobComplete(Job* job) { job 345 net/quic/crypto/proof_verifier_chromium.cc active_jobs_.erase(job); job 346 net/quic/crypto/proof_verifier_chromium.cc delete job; job 63 net/quic/crypto/proof_verifier_chromium.h void OnJobComplete(Job* job); job 441 net/quic/quic_stream_factory.cc Job* job = active_jobs_[server_id]; job 442 net/quic/quic_stream_factory.cc active_requests_[request] = job; job 443 net/quic/quic_stream_factory.cc job_requests_map_[job].insert(request); job 456 net/quic/quic_stream_factory.cc scoped_ptr<Job> job(new Job(this, host_resolver_, host_port_pair, is_https, job 458 net/quic/quic_stream_factory.cc int rv = job->Run(base::Bind(&QuicStreamFactory::OnJobComplete, job 459 net/quic/quic_stream_factory.cc base::Unretained(this), job.get())); job 462 net/quic/quic_stream_factory.cc active_requests_[request] = job.get(); job 463 net/quic/quic_stream_factory.cc job_requests_map_[job.get()].insert(request); job 464 net/quic/quic_stream_factory.cc active_jobs_[server_id] = job.release(); job 497 net/quic/quic_stream_factory.cc void QuicStreamFactory::OnJobComplete(Job* job, int rv) { job 502 net/quic/quic_stream_factory.cc for (RequestSet::iterator it = job_requests_map_[job].begin(); job 503 net/quic/quic_stream_factory.cc it != job_requests_map_[job].end() ; ++it) { job 504 net/quic/quic_stream_factory.cc DCHECK(HasActiveSession(job->server_id())); job 505 net/quic/quic_stream_factory.cc (*it)->set_stream(CreateIfSessionExists(job->server_id(), job 509 net/quic/quic_stream_factory.cc while (!job_requests_map_[job].empty()) { job 510 net/quic/quic_stream_factory.cc RequestSet::iterator it = job_requests_map_[job].begin(); job 512 net/quic/quic_stream_factory.cc job_requests_map_[job].erase(it); job 519 net/quic/quic_stream_factory.cc active_jobs_.erase(job->server_id()); job 520 net/quic/quic_stream_factory.cc job_requests_map_.erase(job); job 521 net/quic/quic_stream_factory.cc delete job; job 612 net/quic/quic_stream_factory.cc Job* job = active_requests_[request]; job 613 net/quic/quic_stream_factory.cc job_requests_map_[job].erase(request); job 202 net/quic/quic_stream_factory.h void OnJobComplete(Job* job, int rv); job 632 net/socket/client_socket_pool_base.cc std::set<ConnectJob*>::const_iterator job = group->jobs().begin(); job 633 net/socket/client_socket_pool_base.cc for (job = group->jobs().begin(); job != group->jobs().end(); job++) { job 634 net/socket/client_socket_pool_base.cc int source_id = (*job)->net_log().source().id; job 867 net/socket/client_socket_pool_base.cc int result, ConnectJob* job) { job 869 net/socket/client_socket_pool_base.cc const std::string group_name = job->group_name(); job 874 net/socket/client_socket_pool_base.cc scoped_ptr<StreamSocket> socket = job->PassSocket(); job 878 net/socket/client_socket_pool_base.cc BoundNetLog job_log = job->net_log(); job 879 net/socket/client_socket_pool_base.cc LoadTimingInfo::ConnectTiming connect_timing = job->connect_timing(); job 886 net/socket/client_socket_pool_base.cc RemoveConnectJob(job, group); job 907 net/socket/client_socket_pool_base.cc job->GetAdditionalErrorState(request->handle()); job 908 net/socket/client_socket_pool_base.cc RemoveConnectJob(job, group); job 919 net/socket/client_socket_pool_base.cc RemoveConnectJob(job, group); job 939 net/socket/client_socket_pool_base.cc void ClientSocketPoolBaseHelper::RemoveConnectJob(ConnectJob* job, job 945 net/socket/client_socket_pool_base.cc group->RemoveJob(job); job 1182 net/socket/client_socket_pool_base.cc void ClientSocketPoolBaseHelper::Group::AddJob(scoped_ptr<ConnectJob> job, job 1188 net/socket/client_socket_pool_base.cc jobs_.insert(job.release()); job 1191 net/socket/client_socket_pool_base.cc void ClientSocketPoolBaseHelper::Group::RemoveJob(ConnectJob* job) { job 1192 net/socket/client_socket_pool_base.cc scoped_ptr<ConnectJob> owned_job(job); job 1195 net/socket/client_socket_pool_base.cc std::set<ConnectJob*>::iterator it = jobs_.find(job); job 71 net/socket/client_socket_pool_base.h ConnectJob* job) = 0; job 330 net/socket/client_socket_pool_base.h virtual void OnConnectJobComplete(int result, ConnectJob* job) OVERRIDE; job 413 net/socket/client_socket_pool_base.h void AddJob(scoped_ptr<ConnectJob> job, bool is_preconnect); job 415 net/socket/client_socket_pool_base.h void RemoveJob(ConnectJob* job); job 527 net/socket/client_socket_pool_base.h void RemoveConnectJob(ConnectJob* job, Group* group); job 795 net/socket/client_socket_pool_base.h virtual void OnConnectJobComplete(int result, ConnectJob* job) { job 796 net/socket/client_socket_pool_base.h return helper_.OnConnectJobComplete(result, job); job 236 net/socket/client_socket_pool_base_unittest.cc void WaitForSignal(TestConnectJob* job) { waiting_jobs_.push_back(job); } job 240 net/socket/client_socket_pool_base_unittest.cc void SignalJob(size_t job); job 242 net/socket/client_socket_pool_base_unittest.cc void SetJobLoadState(size_t job, LoadState load_state); job 638 net/socket/client_socket_pool_base_unittest.cc void MockClientSocketFactory::SignalJob(size_t job) { job 639 net/socket/client_socket_pool_base_unittest.cc ASSERT_LT(job, waiting_jobs_.size()); job 640 net/socket/client_socket_pool_base_unittest.cc waiting_jobs_[job]->Signal(); job 641 net/socket/client_socket_pool_base_unittest.cc waiting_jobs_.erase(waiting_jobs_.begin() + job); job 644 net/socket/client_socket_pool_base_unittest.cc void MockClientSocketFactory::SetJobLoadState(size_t job, job 646 net/socket/client_socket_pool_base_unittest.cc ASSERT_LT(job, waiting_jobs_.size()); job 647 net/socket/client_socket_pool_base_unittest.cc waiting_jobs_[job]->set_load_state(load_state); job 656 net/socket/client_socket_pool_base_unittest.cc virtual void OnConnectJobComplete(int result, ConnectJob* job) OVERRIDE { job 658 net/socket/client_socket_pool_base_unittest.cc scoped_ptr<ConnectJob> owned_job(job); job 775 net/socket/client_socket_pool_base_unittest.cc scoped_ptr<TestConnectJob> job( job 783 net/socket/client_socket_pool_base_unittest.cc EXPECT_EQ(OK, job->Connect()); job 796 net/socket/client_socket_pool_base_unittest.cc TestConnectJob* job = job 804 net/socket/client_socket_pool_base_unittest.cc ASSERT_EQ(ERR_IO_PENDING, job->Connect()); job 1766 net/socket/socket_test_util.cc MockConnectJob* job = new MockConnectJob(socket.Pass(), handle, callback); job 1767 net/socket/socket_test_util.cc job_list_.push_back(job); job 1769 net/socket/socket_test_util.cc return job->Connect(); job 28 net/socket_stream/socket_stream_job_manager.cc SocketStreamJob* job = new SocketStreamJob(); job 29 net/socket_stream/socket_stream_job_manager.cc job->InitSocketStream(new SocketStream(url, delegate, context, job 31 net/socket_stream/socket_stream_job_manager.cc return job; job 39 net/socket_stream/socket_stream_job_manager.cc SocketStreamJob* job = found->second(url, delegate, context, cookie_store); job 40 net/socket_stream/socket_stream_job_manager.cc if (job) job 41 net/socket_stream/socket_stream_job_manager.cc return job; job 43 net/socket_stream/socket_stream_job_manager.cc SocketStreamJob* job = new SocketStreamJob(); job 44 net/socket_stream/socket_stream_job_manager.cc job->InitSocketStream(new SocketStream(url, delegate, context, cookie_store)); job 45 net/socket_stream/socket_stream_job_manager.cc return job; job 443 net/ssl/server_bound_cert_service.cc ServerBoundCertServiceJob* job = job 445 net/ssl/server_bound_cert_service.cc inflight_[domain] = job; job 453 net/ssl/server_bound_cert_service.cc job->AddRequest(request); job 585 net/ssl/server_bound_cert_service.cc ServerBoundCertServiceJob* job = j->second; job 588 net/ssl/server_bound_cert_service.cc job->HandleResult(error, private_key, cert); job 589 net/ssl/server_bound_cert_service.cc delete job; job 600 net/ssl/server_bound_cert_service.cc ServerBoundCertServiceJob* job = NULL; job 606 net/ssl/server_bound_cert_service.cc job = j->second; job 615 net/ssl/server_bound_cert_service.cc job->AddRequest(request, create_if_missing); job 654 net/ssl/server_bound_cert_service.cc ServerBoundCertServiceJob* job = job 656 net/ssl/server_bound_cert_service.cc inflight_[domain] = job; job 664 net/ssl/server_bound_cert_service.cc job->AddRequest(request); job 25 net/url_request/protocol_intercept_job_factory.cc URLRequestJob* job = protocol_handler_->MaybeCreateJob(request, job 27 net/url_request/protocol_intercept_job_factory.cc if (job) job 28 net/url_request/protocol_intercept_job_factory.cc return job; job 680 net/url_request/url_request.cc URLRequestRedirectJob* job = new URLRequestRedirectJob( job 684 net/url_request/url_request.cc StartJob(job); job 691 net/url_request/url_request.cc void URLRequest::StartJob(URLRequestJob* job) { job 701 net/url_request/url_request.cc job_ = job; job 741 net/url_request/url_request.cc void URLRequest::RestartWithJob(URLRequestJob *job) { job 742 net/url_request/url_request.cc DCHECK(job->request() == this); job 744 net/url_request/url_request.cc StartJob(job); job 843 net/url_request/url_request.cc URLRequestJob* job = job 846 net/url_request/url_request.cc if (job) { job 847 net/url_request/url_request.cc RestartWithJob(job); job 880 net/url_request/url_request.cc URLRequestJob* job = job 883 net/url_request/url_request.cc if (job) { job 884 net/url_request/url_request.cc RestartWithJob(job); job 761 net/url_request/url_request.h void StartJob(URLRequestJob* job); job 765 net/url_request/url_request.h void RestartWithJob(URLRequestJob* job); job 168 net/url_request/url_request_filter.cc URLRequestJob* job = NULL; job 176 net/url_request/url_request_filter.cc job = i->second->MaybeCreateJob(request, network_delegate); job 178 net/url_request/url_request_filter.cc if (!job) { job 183 net/url_request/url_request_filter.cc job = i->second->MaybeCreateJob(request, network_delegate); job 186 net/url_request/url_request_filter.cc if (job) { job 190 net/url_request/url_request_filter.cc return job; job 147 net/url_request/url_request_ftp_job_unittest.cc scoped_refptr<TestURLRequestFtpJob> job(new TestURLRequestFtpJob( job 149 net/url_request/url_request_ftp_job_unittest.cc EXPECT_EQ(DEFAULT_PRIORITY, job->priority()); job 151 net/url_request/url_request_ftp_job_unittest.cc job->SetPriority(LOWEST); job 152 net/url_request/url_request_ftp_job_unittest.cc EXPECT_EQ(LOWEST, job->priority()); job 154 net/url_request/url_request_ftp_job_unittest.cc job->SetPriority(LOW); job 155 net/url_request/url_request_ftp_job_unittest.cc EXPECT_EQ(LOW, job->priority()); job 157 net/url_request/url_request_ftp_job_unittest.cc job->Start(); job 158 net/url_request/url_request_ftp_job_unittest.cc EXPECT_EQ(LOW, job->priority()); job 160 net/url_request/url_request_ftp_job_unittest.cc job->SetPriority(MEDIUM); job 161 net/url_request/url_request_ftp_job_unittest.cc EXPECT_EQ(MEDIUM, job->priority()); job 167 net/url_request/url_request_ftp_job_unittest.cc scoped_refptr<TestURLRequestFtpJob> job(new TestURLRequestFtpJob( job 169 net/url_request/url_request_ftp_job_unittest.cc job->SetPriority(LOW); job 173 net/url_request/url_request_ftp_job_unittest.cc job->Start(); job 182 net/url_request/url_request_ftp_job_unittest.cc scoped_refptr<TestURLRequestFtpJob> job(new TestURLRequestFtpJob( job 184 net/url_request/url_request_ftp_job_unittest.cc job->SetPriority(LOW); job 185 net/url_request/url_request_ftp_job_unittest.cc job->Start(); job 189 net/url_request/url_request_ftp_job_unittest.cc job->SetPriority(HIGHEST); job 196 net/url_request/url_request_ftp_job_unittest.cc scoped_refptr<TestURLRequestFtpJob> job(new TestURLRequestFtpJob( job 198 net/url_request/url_request_ftp_job_unittest.cc job->Start(); job 200 net/url_request/url_request_ftp_job_unittest.cc job->SetPriority(LOW); job 204 net/url_request/url_request_ftp_job_unittest.cc job->Kill(); job 208 net/url_request/url_request_ftp_job_unittest.cc job->Start(); job 56 net/url_request/url_request_http_job.cc explicit HttpFilterContext(URLRequestHttpJob* job); job 81 net/url_request/url_request_http_job.cc URLRequestHttpJob::HttpFilterContext::HttpFilterContext(URLRequestHttpJob* job) job 82 net/url_request/url_request_http_job.cc : job_(job) { job 66 net/url_request/url_request_http_job_unittest.cc scoped_refptr<TestURLRequestHttpJob> job(new TestURLRequestHttpJob(&req_)); job 67 net/url_request/url_request_http_job_unittest.cc EXPECT_EQ(DEFAULT_PRIORITY, job->priority()); job 69 net/url_request/url_request_http_job_unittest.cc job->SetPriority(LOWEST); job 70 net/url_request/url_request_http_job_unittest.cc EXPECT_EQ(LOWEST, job->priority()); job 72 net/url_request/url_request_http_job_unittest.cc job->SetPriority(LOW); job 73 net/url_request/url_request_http_job_unittest.cc EXPECT_EQ(LOW, job->priority()); job 75 net/url_request/url_request_http_job_unittest.cc job->Start(); job 76 net/url_request/url_request_http_job_unittest.cc EXPECT_EQ(LOW, job->priority()); job 78 net/url_request/url_request_http_job_unittest.cc job->SetPriority(MEDIUM); job 79 net/url_request/url_request_http_job_unittest.cc EXPECT_EQ(MEDIUM, job->priority()); job 85 net/url_request/url_request_http_job_unittest.cc scoped_refptr<TestURLRequestHttpJob> job(new TestURLRequestHttpJob(&req_)); job 86 net/url_request/url_request_http_job_unittest.cc job->SetPriority(LOW); job 90 net/url_request/url_request_http_job_unittest.cc job->Start(); job 99 net/url_request/url_request_http_job_unittest.cc scoped_refptr<TestURLRequestHttpJob> job(new TestURLRequestHttpJob(&req_)); job 100 net/url_request/url_request_http_job_unittest.cc job->SetPriority(LOW); job 101 net/url_request/url_request_http_job_unittest.cc job->Start(); job 105 net/url_request/url_request_http_job_unittest.cc job->SetPriority(HIGHEST); job 112 net/url_request/url_request_http_job_unittest.cc scoped_refptr<TestURLRequestHttpJob> job(new TestURLRequestHttpJob(&req_)); job 113 net/url_request/url_request_http_job_unittest.cc job->Start(); job 115 net/url_request/url_request_http_job_unittest.cc job->SetPriority(LOW); job 119 net/url_request/url_request_http_job_unittest.cc job->Kill(); job 123 net/url_request/url_request_http_job_unittest.cc job->Start(); job 269 net/url_request/url_request_http_job_unittest.cc scoped_refptr<TestURLRequestHttpJob> job(new TestURLRequestHttpJob(&req_)); job 270 net/url_request/url_request_http_job_unittest.cc job->Start(); job 277 net/url_request/url_request_http_job_unittest.cc scoped_refptr<TestURLRequestHttpJob> job(new TestURLRequestHttpJob(&req_)); job 289 net/url_request/url_request_http_job_unittest.cc job->Start(); job 83 net/url_request/url_request_job_manager.cc URLRequestJob* job = (*i)->MaybeIntercept(request, network_delegate); job 84 net/url_request/url_request_job_manager.cc if (job) job 85 net/url_request/url_request_job_manager.cc return job; job 90 net/url_request/url_request_job_manager.cc URLRequestJob* job = job_factory->MaybeCreateJobWithProtocolHandler( job 92 net/url_request/url_request_job_manager.cc if (job) job 93 net/url_request/url_request_job_manager.cc return job; job 103 net/url_request/url_request_job_manager.cc URLRequestJob* job = i->second(request, network_delegate, scheme); job 104 net/url_request/url_request_job_manager.cc if (job) job 105 net/url_request/url_request_job_manager.cc return job; job 111 net/url_request/url_request_job_manager.cc URLRequestJob* job = (kBuiltinFactories[i].factory)( job 113 net/url_request/url_request_job_manager.cc DCHECK(job); // The built-in factories are not expected to fail! job 114 net/url_request/url_request_job_manager.cc return job; job 150 net/url_request/url_request_job_manager.cc URLRequestJob* job = (*i)->MaybeInterceptRedirect(request, job 153 net/url_request/url_request_job_manager.cc if (job) job 154 net/url_request/url_request_job_manager.cc return job; job 182 net/url_request/url_request_job_manager.cc URLRequestJob* job = (*i)->MaybeInterceptResponse(request, job 184 net/url_request/url_request_job_manager.cc if (job) job 185 net/url_request/url_request_job_manager.cc return job; job 630 net/url_request/url_request_test_util.cc URLRequestJob* job = main_intercept_job_; job 632 net/url_request/url_request_test_util.cc return job; job 635 net/url_request/url_request_test_util.cc void TestJobInterceptor::set_main_intercept_job(URLRequestJob* job) { job 636 net/url_request/url_request_test_util.cc main_intercept_job_ = job; job 381 net/url_request/url_request_test_util.h void set_main_intercept_job(URLRequestJob* job); job 1152 net/url_request/url_request_unittest.cc URLRequestTestJob* job = new URLRequestTestJob(request, job 1157 net/url_request/url_request_unittest.cc job->set_load_timing_info(main_request_load_timing_info_); job 1158 net/url_request/url_request_unittest.cc return job; job 1902 net/url_request/url_request_unittest.cc scoped_refptr<URLRequestTestJob> job = job 1904 net/url_request/url_request_unittest.cc AddTestInterceptor()->set_main_intercept_job(job.get()); job 1905 net/url_request/url_request_unittest.cc EXPECT_EQ(DEFAULT_PRIORITY, job->priority()); job 1910 net/url_request/url_request_unittest.cc EXPECT_EQ(LOW, job->priority()); job 1922 net/url_request/url_request_unittest.cc scoped_refptr<URLRequestTestJob> job = job 1924 net/url_request/url_request_unittest.cc AddTestInterceptor()->set_main_intercept_job(job.get()); job 1928 net/url_request/url_request_unittest.cc EXPECT_EQ(LOW, job->priority()); job 1932 net/url_request/url_request_unittest.cc EXPECT_EQ(MEDIUM, job->priority()); job 1945 net/url_request/url_request_unittest.cc scoped_refptr<URLRequestTestJob> job = job 1947 net/url_request/url_request_unittest.cc AddTestInterceptor()->set_main_intercept_job(job.get()); job 1957 net/url_request/url_request_unittest.cc EXPECT_EQ(MAXIMUM_PRIORITY, job->priority()); job 5427 net/url_request/url_request_unittest.cc URLRequestRedirectJob* job = new URLRequestRedirectJob( job 5430 net/url_request/url_request_unittest.cc AddTestInterceptor()->set_main_intercept_job(job); job 6058 net/url_request/url_request_unittest.cc URLRequestRedirectJob* job = new URLRequestRedirectJob( job 6061 net/url_request/url_request_unittest.cc AddTestInterceptor()->set_main_intercept_job(job); job 6085 net/url_request/url_request_unittest.cc URLRequestRedirectJob* job = new URLRequestRedirectJob( job 6089 net/url_request/url_request_unittest.cc AddTestInterceptor()->set_main_intercept_job(job); job 6299 net/url_request/url_request_unittest.cc scoped_refptr<URLRequestTestJob> job = job 6301 net/url_request/url_request_unittest.cc AddTestInterceptor()->set_main_intercept_job(job.get()); job 6305 net/url_request/url_request_unittest.cc EXPECT_EQ(LOW, job->priority()); job 41 net/websockets/websocket_job.cc net::WebSocketJob* job = new net::WebSocketJob(delegate); job 42 net/websockets/websocket_job.cc job->InitSocketStream(new net::SocketStream(url, job, context, cookie_store)); job 43 net/websockets/websocket_job.cc return job; job 329 net/websockets/websocket_job_test.cc void set_job(WebSocketJob* job) { job_ = job; } job 491 net/websockets/websocket_job_test.cc SocketStream* GetSocket(SocketStreamJob* job) { job 492 net/websockets/websocket_job_test.cc return job->socket_.get(); job 571 net/websockets/websocket_job_test.cc WebSocketJob* job() { return delegate_->job(); } job 841 net/websockets/websocket_job_test.cc scoped_refptr<SocketStreamJob> job = job 845 net/websockets/websocket_job_test.cc EXPECT_TRUE(GetSocket(job.get())->is_secure()); job 846 net/websockets/websocket_job_test.cc job->DetachDelegate(); job 849 net/websockets/websocket_job_test.cc job = SocketStreamJob::CreateSocketStreamJob( job 852 net/websockets/websocket_job_test.cc EXPECT_FALSE(GetSocket(job.get())->is_secure()); job 853 net/websockets/websocket_job_test.cc job->DetachDelegate(); job 1095 net/websockets/websocket_job_test.cc scoped_refptr<WebSocketJob> job = new WebSocketJob(NULL); job 1096 net/websockets/websocket_job_test.cc job->addresses_ = AddressList(AddressList::CreateFromIPAddress(ip, 80)); job 1098 net/websockets/websocket_job_test.cc EXPECT_FALSE(WebSocketThrottle::GetInstance()->PutInQueue(job)); job 1100 net/websockets/websocket_job_test.cc EXPECT_TRUE(WebSocketThrottle::GetInstance()->PutInQueue(job)); job 1101 net/websockets/websocket_job_test.cc jobs.push_back(job); job 1110 net/websockets/websocket_job_test.cc WebSocketJob* job = (*iter).get(); job 1111 net/websockets/websocket_job_test.cc job->state_ = WebSocketJob::CLOSED; job 1112 net/websockets/websocket_job_test.cc WebSocketThrottle::GetInstance()->RemoveFromQueue(job); job 1223 net/websockets/websocket_job_test.cc job()->OnClose(socket_.get()); job 1230 net/websockets/websocket_job_test.cc EXPECT_FALSE(job()); job 1235 net/websockets/websocket_job_test.cc job()->OnAuthRequired(socket_.get(), NULL); job 1236 net/websockets/websocket_job_test.cc EXPECT_FALSE(job()); job 1242 net/websockets/websocket_job_test.cc job()->OnSSLCertificateError(socket_.get(), ssl_info, true); job 1243 net/websockets/websocket_job_test.cc EXPECT_FALSE(job()); job 1248 net/websockets/websocket_job_test.cc job()->OnError(socket_.get(), ERR_CONNECTION_RESET); job 1249 net/websockets/websocket_job_test.cc EXPECT_FALSE(job()); job 1253 net/websockets/websocket_job_test.cc job()->Connect(); job 1255 net/websockets/websocket_job_test.cc job()->OnSentSpdyHeaders(); job 1256 net/websockets/websocket_job_test.cc EXPECT_FALSE(job()); job 1270 net/websockets/websocket_job_test.cc job()->Connect(); job 1271 net/websockets/websocket_job_test.cc job()->SendData(kMinimalRequest, kMinimalRequestSize); job 1273 net/websockets/websocket_job_test.cc job()->OnSentData(socket_.get(), kMinimalRequestSize); job 1274 net/websockets/websocket_job_test.cc EXPECT_FALSE(job()); job 1284 net/websockets/websocket_job_test.cc job()->Connect(); job 1286 net/websockets/websocket_job_test.cc job()->OnReceivedData( job 1288 net/websockets/websocket_job_test.cc EXPECT_FALSE(job()); job 42 net/websockets/websocket_throttle.cc bool WebSocketThrottle::PutInQueue(WebSocketJob* job) { job 46 net/websockets/websocket_throttle.cc queue_.push_back(job); job 47 net/websockets/websocket_throttle.cc const AddressList& address_list = job->address_list(); job 61 net/websockets/websocket_throttle.cc new_queue->second.push_back(job); job 64 net/websockets/websocket_throttle.cc iter->second.push_back(job); job 65 net/websockets/websocket_throttle.cc job->SetWaiting(); job 73 net/websockets/websocket_throttle.cc void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { job 75 net/websockets/websocket_throttle.cc std::find(queue_.begin(), queue_.end(), job); job 82 net/websockets/websocket_throttle.cc const AddressList& resolved_address_list = job->address_list(); job 99 net/websockets/websocket_throttle.cc std::find(per_address_queue.begin(), per_address_queue.end(), job); job 121 net/websockets/websocket_throttle.cc WebSocketJob* job = *iter; job 122 net/websockets/websocket_throttle.cc if (!job->IsWaiting()) job 126 net/websockets/websocket_throttle.cc const AddressList& resolved_address_list = job->address_list(); job 134 net/websockets/websocket_throttle.cc if (job != per_address_queue.front()) { job 140 net/websockets/websocket_throttle.cc job->Wakeup(); job 42 net/websockets/websocket_throttle.h bool PutInQueue(WebSocketJob* job); job 47 net/websockets/websocket_throttle.h void RemoveFromQueue(WebSocketJob* job); job 90 remoting/host/win/wts_session_process_delegate.cc void InitializeJob(scoped_ptr<base::win::ScopedHandle> job); job 93 remoting/host/win/wts_session_process_delegate.cc void InitializeJobCompleted(scoped_ptr<base::win::ScopedHandle> job); job 176 remoting/host/win/wts_session_process_delegate.cc ScopedHandle job; job 177 remoting/host/win/wts_session_process_delegate.cc job.Set(CreateJobObject(NULL, NULL)); job 178 remoting/host/win/wts_session_process_delegate.cc if (!job.IsValid()) { job 191 remoting/host/win/wts_session_process_delegate.cc if (!SetInformationJobObject(job, job 202 remoting/host/win/wts_session_process_delegate.cc *job_wrapper = job.Pass(); job 458 remoting/host/win/wts_session_process_delegate.cc scoped_ptr<base::win::ScopedHandle> job) { job 462 remoting/host/win/wts_session_process_delegate.cc if (!base::MessageLoopForIO::current()->RegisterJobObject(job->Get(), this)) { job 470 remoting/host/win/wts_session_process_delegate.cc &Core::InitializeJobCompleted, this, base::Passed(&job))); job 474 remoting/host/win/wts_session_process_delegate.cc scoped_ptr<ScopedHandle> job) { job 478 remoting/host/win/wts_session_process_delegate.cc job_ = job->Pass(); job 25 sandbox/win/src/broker_services.cc bool AssociateCompletionPort(HANDLE job, HANDLE port, void* key) { job 27 sandbox/win/src/broker_services.cc return ::SetInformationJobObject(job, job 56 sandbox/win/src/broker_services.cc HANDLE job; job 59 sandbox/win/src/broker_services.cc : job(cjob), policy(cpolicy) { job 166 sandbox/win/src/broker_services.cc BOOL res = ::TerminateJobObject(tracker->job, SBOX_ALL_OK); job 170 sandbox/win/src/broker_services.cc res = ::CloseHandle(tracker->job); job 173 sandbox/win/src/broker_services.cc tracker->policy->OnJobEmpty(tracker->job); job 315 sandbox/win/src/broker_services.cc base::win::ScopedHandle job(job_temp); job 396 sandbox/win/src/broker_services.cc job, job 412 sandbox/win/src/broker_services.cc if (job.IsValid()) { job 413 sandbox/win/src/broker_services.cc scoped_ptr<JobTracker> tracker(new JobTracker(job.Take(), policy_base)); job 414 sandbox/win/src/broker_services.cc if (!AssociateCompletionPort(tracker->job, job_port_, tracker.get())) job 18 sandbox/win/src/job_unittest.cc Job job; job 19 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", 0)); job 42 sandbox/win/src/job_unittest.cc Job job; job 43 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", 0)); job 45 sandbox/win/src/job_unittest.cc job_handle = job.Detach(); job 74 sandbox/win/src/job_unittest.cc Job job; job 75 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", job 78 sandbox/win/src/job_unittest.cc job_handle = job.Detach(); job 95 sandbox/win/src/job_unittest.cc Job job; job 96 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", 0)); job 98 sandbox/win/src/job_unittest.cc job_handle = job.Detach(); job 117 sandbox/win/src/job_unittest.cc Job job; job 118 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", 0)); job 119 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_ALREADY_INITIALIZED, job.Init(JOB_LOCKDOWN, L"test", 0)); job 125 sandbox/win/src/job_unittest.cc Job job; job 126 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_NO_DATA, job.UserHandleGrantAccess(NULL)); job 127 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_NO_DATA, job.AssignProcessToJob(NULL)); job 128 sandbox/win/src/job_unittest.cc ASSERT_TRUE(job.Detach() == NULL); job 160 sandbox/win/src/job_unittest.cc Job job; job 161 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_UNPROTECTED, L"job_test_process", 0)); job 172 sandbox/win/src/job_unittest.cc ASSERT_EQ(ERROR_SUCCESS, job.AssignProcessToJob(pi.process_handle())); job 175 sandbox/win/src/job_unittest.cc HANDLE job_handle = job.Detach(); job 148 sandbox/win/src/restricted_token_utils.cc Job job; job 149 sandbox/win/src/restricted_token_utils.cc DWORD err_code = job.Init(job_level, NULL, 0); job 156 sandbox/win/src/restricted_token_utils.cc err_code = job.UserHandleGrantAccess(GetDesktopWindow()); job 221 sandbox/win/src/restricted_token_utils.cc err_code = job.AssignProcessToJob(process_info.process_handle()); job 231 sandbox/win/src/restricted_token_utils.cc (*job_handle_ret) = job.Detach(); job 458 sandbox/win/src/sandbox_policy_base.cc ResultCode PolicyBase::MakeJobObject(HANDLE* job) { job 466 sandbox/win/src/sandbox_policy_base.cc *job = job_obj.Detach(); job 468 sandbox/win/src/sandbox_policy_base.cc *job = NULL; job 557 sandbox/win/src/sandbox_policy_base.cc bool PolicyBase::OnJobEmpty(HANDLE job) { job 561 sandbox/win/src/sandbox_policy_base.cc if ((*it)->Job() == job) job 77 sandbox/win/src/sandbox_policy_base.h ResultCode MakeJobObject(HANDLE* job); job 92 sandbox/win/src/sandbox_policy_base.h bool OnJobEmpty(HANDLE job); job 68 sandbox/win/src/target_process.cc HANDLE job, ThreadProvider* thread_pool) job 74 sandbox/win/src/target_process.cc job_(job), job 36 sandbox/win/src/target_process.h TargetProcess(HANDLE initial_token, HANDLE lockdown_token, HANDLE job, job 77 sandbox/win/tests/integration_tests/integration_tests_test.cc HANDLE job = ::CreateJobObject(NULL, NULL); job 78 sandbox/win/tests/integration_tests/integration_tests_test.cc if (!job) job 82 sandbox/win/tests/integration_tests/integration_tests_test.cc if (!::QueryInformationJobObject(job, JobObjectExtendedLimitInformation, job 95 sandbox/win/tests/integration_tests/integration_tests_test.cc if (!::SetInformationJobObject(job, JobObjectExtendedLimitInformation, job 99 sandbox/win/tests/integration_tests/integration_tests_test.cc if (!::AssignProcessToJobObject(job, ::GetCurrentProcess())) job 113 sandbox/win/tests/integration_tests/integration_tests_test.cc ::TerminateJobObject(job, SBOX_TEST_SUCCEEDED); job 403 third_party/libwebp/enc/analysis.c static int DoSegmentsJob(SegmentJob* const job, VP8EncIterator* const it) { job 411 third_party/libwebp/enc/analysis.c MBAnalyze(it, job->alphas, &job->alpha, &job->uv_alpha); job 412 third_party/libwebp/enc/analysis.c ok = VP8IteratorProgress(it, job->delta_progress); job 426 third_party/libwebp/enc/analysis.c static void InitSegmentJob(VP8Encoder* const enc, SegmentJob* const job, job 428 third_party/libwebp/enc/analysis.c WebPWorkerInit(&job->worker); job 429 third_party/libwebp/enc/analysis.c job->worker.data1 = job; job 430 third_party/libwebp/enc/analysis.c job->worker.data2 = &job->it; job 431 third_party/libwebp/enc/analysis.c job->worker.hook = (WebPWorkerHook)DoSegmentsJob; job 432 third_party/libwebp/enc/analysis.c VP8IteratorInit(enc, &job->it); job 433 third_party/libwebp/enc/analysis.c VP8IteratorSetRow(&job->it, start_row); job 434 third_party/libwebp/enc/analysis.c VP8IteratorSetCountDown(&job->it, (end_row - start_row) * enc->mb_w_); job 435 third_party/libwebp/enc/analysis.c memset(job->alphas, 0, sizeof(job->alphas)); job 436 third_party/libwebp/enc/analysis.c job->alpha = 0; job 437 third_party/libwebp/enc/analysis.c job->uv_alpha = 0; job 440 third_party/libwebp/enc/analysis.c job->delta_progress = (start_row == 0) ? 20 : 0; job 96 third_party/npapi/npspy/extern/nspr/prtpool.h PR_CancelJob(PRJob *job); job 100 third_party/npapi/npspy/extern/nspr/prtpool.h PR_JoinJob(PRJob *job); job 108 webkit/browser/appcache/appcache_update_job.cc AppCacheUpdateJob* job) job 110 webkit/browser/appcache/appcache_update_job.cc job_(job), job 114 webkit/browser/appcache/appcache_update_job.cc request_(job->service_->request_context() job 113 webkit/browser/appcache/appcache_update_job.h AppCacheUpdateJob* job); job 382 webkit/browser/appcache/appcache_url_request_job_unittest.cc scoped_refptr<AppCacheURLRequestJob> job; job 386 webkit/browser/appcache/appcache_url_request_job_unittest.cc job = new AppCacheURLRequestJob( job 388 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_TRUE(job->is_waiting()); job 389 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->is_delivering_appcache_response()); job 390 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->is_delivering_network_response()); job 391 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->is_delivering_error_response()); job 392 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->has_been_started()); job 393 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->has_been_killed()); job 394 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_EQ(GURL(), job->manifest_url()); job 395 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_EQ(kNoCacheId, job->cache_id()); job 396 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->entry().has_response_id()); job 406 webkit/browser/appcache/appcache_url_request_job_unittest.cc scoped_refptr<AppCacheURLRequestJob> job; job 411 webkit/browser/appcache/appcache_url_request_job_unittest.cc job = new AppCacheURLRequestJob(&request, NULL, storage, NULL, false); job 412 webkit/browser/appcache/appcache_url_request_job_unittest.cc job->DeliverErrorResponse(); job 413 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_TRUE(job->is_delivering_error_response()); job 414 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->has_been_started()); job 416 webkit/browser/appcache/appcache_url_request_job_unittest.cc job = new AppCacheURLRequestJob(&request, NULL, storage, NULL, false); job 417 webkit/browser/appcache/appcache_url_request_job_unittest.cc job->DeliverNetworkResponse(); job 418 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_TRUE(job->is_delivering_network_response()); job 419 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->has_been_started()); job 421 webkit/browser/appcache/appcache_url_request_job_unittest.cc job = new AppCacheURLRequestJob(&request, NULL, storage, NULL, false); job 426 webkit/browser/appcache/appcache_url_request_job_unittest.cc job->DeliverAppCachedResponse(kManifestUrl, kCacheId, kGroupId, job 428 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->is_waiting()); job 429 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_TRUE(job->is_delivering_appcache_response()); job 430 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->has_been_started()); job 431 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_EQ(kManifestUrl, job->manifest_url()); job 432 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_EQ(kCacheId, job->cache_id()); job 433 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_EQ(kGroupId, job->group_id()); job 434 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_EQ(kEntry.types(), job->entry().types()); job 435 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_EQ(kEntry.response_id(), job->entry().response_id()); job 543 webkit/browser/appcache/appcache_url_request_job_unittest.cc scoped_refptr<AppCacheURLRequestJob> job(new AppCacheURLRequestJob( job 547 webkit/browser/appcache/appcache_url_request_job_unittest.cc job->DeliverAppCachedResponse( job 551 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_TRUE(job->is_delivering_appcache_response()); job 555 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->has_been_started()); job 556 webkit/browser/appcache/appcache_url_request_job_unittest.cc mock_factory_job_ = job.get(); job 559 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_TRUE(job->has_been_started()); job 562 webkit/browser/appcache/appcache_url_request_job_unittest.cc job->DeliverAppCachedResponse( job 566 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_TRUE(job->is_delivering_appcache_response()); job 662 webkit/browser/appcache/appcache_url_request_job_unittest.cc scoped_refptr<AppCacheURLRequestJob> job(new AppCacheURLRequestJob( job 664 webkit/browser/appcache/appcache_url_request_job_unittest.cc job->DeliverAppCachedResponse( job 668 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_TRUE(job->is_delivering_appcache_response()); job 671 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_FALSE(job->has_been_started()); job 672 webkit/browser/appcache/appcache_url_request_job_unittest.cc mock_factory_job_ = job.get(); job 675 webkit/browser/appcache/appcache_url_request_job_unittest.cc EXPECT_TRUE(job->has_been_started());