Home
last modified time | relevance | path

Searched refs:job (Results 1 – 25 of 320) sorted by relevance

12345678910>>...13

/external/chromium/net/http/
Dhttp_stream_factory_impl_request.cc58 void HttpStreamFactoryImpl::Request::AttachJob(Job* job) { in AttachJob() argument
59 DCHECK(job); in AttachJob()
60 jobs_.insert(job); in AttachJob()
61 factory_->request_map_[job] = this; in AttachJob()
79 Job* job, in OnStreamReady() argument
88 if (!job) { in OnStreamReady()
102 OrphanJobsExcept(job); in OnStreamReady()
110 Job* job, in OnStreamFailed() argument
118 jobs_.erase(job); in OnStreamFailed()
119 factory_->request_map_.erase(job); in OnStreamFailed()
[all …]
Dhttp_stream_factory_impl.cc72 Job* job = new Job(this, session_, request_info, ssl_config, net_log); in RequestStream() local
73 request->AttachJob(job); in RequestStream()
75 job->WaitFor(alternate_job); in RequestStream()
84 job->Start(request); in RequestStream()
96 Job* job = NULL; in PreconnectStreams() local
100 job = new Job(this, session_, alternate_request_info, ssl_config, net_log); in PreconnectStreams()
101 job->MarkAsAlternate(request_info.url); in PreconnectStreams()
103 job = new Job(this, session_, request_info, ssl_config, net_log); in PreconnectStreams()
105 preconnect_job_set_.insert(job); in PreconnectStreams()
106 job->Preconnect(num_streams); in PreconnectStreams()
[all …]
/external/chromium_org/net/http/
Dhttp_stream_factory_impl_request.cc78 void HttpStreamFactoryImpl::Request::AttachJob(Job* job) { in AttachJob() argument
79 DCHECK(job); in AttachJob()
80 jobs_.insert(job); in AttachJob()
81 factory_->request_map_[job] = this; in AttachJob()
103 Job* job, in OnStreamReady() argument
111 OnJobSucceeded(job); in OnStreamReady()
116 Job* job, in OnWebSocketHandshakeStreamReady() argument
124 OnJobSucceeded(job); in OnWebSocketHandshakeStreamReady()
130 Job* job, in OnStreamFailed() argument
137 if (!job) { in OnStreamFailed()
[all …]
Dhttp_stream_factory_impl.cc136 Job* job = new Job(this, session_, request_info, priority, in RequestStreamInternal() local
138 request->AttachJob(job); in RequestStreamInternal()
143 job->WaitFor(alternate_job); in RequestStreamInternal()
152 job->Start(request); in RequestStreamInternal()
166 Job* job = NULL; in PreconnectStreams() local
170 job = new Job(this, session_, alternate_request_info, priority, in PreconnectStreams()
172 job->MarkAsAlternate(request_info.url, alternate); in PreconnectStreams()
174 job = new Job(this, session_, request_info, priority, in PreconnectStreams()
177 preconnect_job_set_.insert(job); in PreconnectStreams()
178 job->Preconnect(num_streams); in PreconnectStreams()
[all …]
/external/chromium_org/net/url_request/
Durl_request_http_job_unittest.cc66 scoped_refptr<TestURLRequestHttpJob> job(new TestURLRequestHttpJob(&req_)); in TEST_F() local
67 EXPECT_EQ(DEFAULT_PRIORITY, job->priority()); in TEST_F()
69 job->SetPriority(LOWEST); in TEST_F()
70 EXPECT_EQ(LOWEST, job->priority()); in TEST_F()
72 job->SetPriority(LOW); in TEST_F()
73 EXPECT_EQ(LOW, job->priority()); in TEST_F()
75 job->Start(); in TEST_F()
76 EXPECT_EQ(LOW, job->priority()); in TEST_F()
78 job->SetPriority(MEDIUM); in TEST_F()
79 EXPECT_EQ(MEDIUM, job->priority()); in TEST_F()
[all …]
Durl_request_job_manager.cc83 URLRequestJob* job = (*i)->MaybeIntercept(request, network_delegate); in CreateJob() local
84 if (job) in CreateJob()
85 return job; in CreateJob()
90 URLRequestJob* job = job_factory->MaybeCreateJobWithProtocolHandler( in CreateJob() local
92 if (job) in CreateJob()
93 return job; in CreateJob()
103 URLRequestJob* job = i->second(request, network_delegate, scheme); in CreateJob() local
104 if (job) in CreateJob()
105 return job; in CreateJob()
111 URLRequestJob* job = (kBuiltinFactories[i].factory)( in CreateJob() local
[all …]
/external/chromium_org/sandbox/win/src/
Djob_unittest.cc18 Job job; in TEST() local
19 ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", 0)); in TEST()
42 Job job; in TEST() local
43 ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", 0)); in TEST()
45 job_handle = job.Detach(); in TEST()
74 Job job; in TEST() local
75 ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", in TEST()
78 job_handle = job.Detach(); in TEST()
95 Job job; in TEST() local
96 ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", 0)); in TEST()
[all …]
/external/chromium_org/components/policy/core/common/cloud/
Dexternal_policy_data_updater.cc319 FetchJob* job = job_map_[key]; in FetchExternalData() local
320 if (job) { in FetchExternalData()
323 if (job->request() == request) in FetchExternalData()
329 delete job; in FetchExternalData()
334 job = new FetchJob(this, key, request, callback); in FetchExternalData()
335 job_map_[key] = job; in FetchExternalData()
336 ScheduleJob(job); in FetchExternalData()
346 std::map<std::string, FetchJob*>::iterator job = job_map_.find(key); in CancelExternalDataFetch() local
347 if (job != job_map_.end()) { in CancelExternalDataFetch()
348 delete job->second; in CancelExternalDataFetch()
[all …]
Dexternal_policy_data_fetcher.cc29 ExternalPolicyDataFetcher::Job* job, in ForwardJobFinished() argument
33 base::Bind(callback, job, result, base::Passed(&data))); in ForwardJobFinished()
50 void DoNothing(ExternalPolicyDataFetcher::Job* job) { in DoNothing() argument
98 Job* job = new Job( in StartJob() local
105 jobs_.insert(job); in StartJob()
108 base::Bind(&ExternalPolicyDataFetcherBackend::StartJob, backend_, job)); in StartJob()
109 return job; in StartJob()
112 void ExternalPolicyDataFetcher::CancelJob(Job* job) { in CancelJob() argument
114 DCHECK(jobs_.find(job) != jobs_.end()); in CancelJob()
115 jobs_.erase(job); in CancelJob()
[all …]
/external/chromium_org/chrome/browser/automation/
Dautomation_resource_message_filter.cc102 URLRequestAutomationJob* job = it->second; in OnMessageReceived() local
103 DCHECK(job); in OnMessageReceived()
104 if (job) { in OnMessageReceived()
105 job->OnMessage(message); in OnMessageReceived()
133 URLRequestAutomationJob* job) { in RegisterRequest() argument
134 if (!job) { in RegisterRequest()
141 if (job->is_pending()) { in RegisterRequest()
142 DCHECK(!ContainsKey(pending_request_map_, job->id())); in RegisterRequest()
143 DCHECK(!ContainsKey(request_map_, job->id())); in RegisterRequest()
144 pending_request_map_[job->id()] = job; in RegisterRequest()
[all …]
/external/chromium_org/v8/src/
Doptimizing-compiler-thread.cc112 RecompileJob* job = input_queue_[InputQueueIndex(0)]; in NextInput() local
113 ASSERT_NE(NULL, job); in NextInput()
116 return job; in NextInput()
121 RecompileJob* job = NextInput(); in CompileNext() local
122 ASSERT_NE(NULL, job); in CompileNext()
125 RecompileJob::Status status = job->OptimizeGraph(); in CompileNext()
132 output_queue_.Enqueue(job); in CompileNext()
137 static void DisposeRecompileJob(RecompileJob* job, in DisposeRecompileJob() argument
140 CompilationInfo* info = job->info(); in DisposeRecompileJob()
143 if (!job->IsWaitingForInstall()) BackEdgeTable::RemoveStackCheck(info); in DisposeRecompileJob()
[all …]
/external/chromium/net/url_request/
Durl_request_job_tracker.cc26 void URLRequestJobTracker::AddNewJob(URLRequestJob* job) { in AddNewJob() argument
27 active_jobs_.push_back(job); in AddNewJob()
28 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobAdded(job)); in AddNewJob()
31 void URLRequestJobTracker::RemoveJob(URLRequestJob* job) { in RemoveJob() argument
33 job); in RemoveJob()
40 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobRemoved(job)); in RemoveJob()
43 void URLRequestJobTracker::OnJobDone(URLRequestJob* job, in OnJobDone() argument
45 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobDone(job, status)); in OnJobDone()
48 void URLRequestJobTracker::OnJobRedirect(URLRequestJob* job, in OnJobRedirect() argument
52 OnJobRedirect(job, location, status_code)); in OnJobRedirect()
[all …]
Durl_request_job_tracker.h38 virtual void OnJobAdded(URLRequestJob* job) = 0;
41 virtual void OnJobRemoved(URLRequestJob* job) = 0;
44 virtual void OnJobDone(URLRequestJob* job,
49 virtual void OnJobRedirect(URLRequestJob* job, const GURL& location,
57 virtual void OnBytesRead(URLRequestJob* job, const char* buf,
76 void AddNewJob(URLRequestJob* job);
77 void RemoveJob(URLRequestJob* job);
80 void OnJobDone(URLRequestJob* job, const URLRequestStatus& status);
81 void OnJobRedirect(URLRequestJob* job, const GURL& location,
85 void OnBytesRead(URLRequestJob* job, const char* buf, int byte_count);
Durl_request_job_manager.cc72 URLRequestJob* job = (*i)->MaybeIntercept(request); in CreateJob() local
73 if (job) in CreateJob()
74 return job; in CreateJob()
83 URLRequestJob* job = i->second(request, scheme); in CreateJob() local
84 if (job) in CreateJob()
85 return job; in CreateJob()
91 URLRequestJob* job = (kBuiltinFactories[i].factory)(request, scheme); in CreateJob() local
92 DCHECK(job); // The built-in factories are not expected to fail! in CreateJob()
93 return job; in CreateJob()
118 URLRequestJob* job = (*i)->MaybeInterceptRedirect(request, location); in MaybeInterceptRedirect() local
[all …]
/external/chromium_org/chrome/browser/policy/cloud/
Ddevice_management_service_browsertest.cc132 scoped_ptr<DeviceManagementRequestJob> job( in PerformRegistration() local
135 job->SetGaiaToken("gaia_auth_token"); in PerformRegistration()
136 job->SetOAuthToken("oauth_token"); in PerformRegistration()
137 job->SetClientID("testid"); in PerformRegistration()
138 job->GetRequest()->mutable_register_request(); in PerformRegistration()
139 job->Start(base::Bind(&DeviceManagementServiceIntegrationTest::OnJobDone, in PerformRegistration()
193 scoped_ptr<DeviceManagementRequestJob> job(service_->CreateJob( in IN_PROC_BROWSER_TEST_P() local
196 job->SetDMToken(token_); in IN_PROC_BROWSER_TEST_P()
197 job->SetClientID("testid"); in IN_PROC_BROWSER_TEST_P()
199 job->GetRequest()->mutable_service_api_access_request(); in IN_PROC_BROWSER_TEST_P()
[all …]
/external/chromium/chrome/browser/sync/engine/
Dsyncer_thread.cc170 const SyncSessionJob& job) { in DecideWhileInWaitInterval() argument
173 DCHECK_NE(job.purpose, SyncSessionJob::CLEAR_USER_DATA); in DecideWhileInWaitInterval()
178 << job.is_canary_job; in DecideWhileInWaitInterval()
180 if (job.purpose == SyncSessionJob::POLL) in DecideWhileInWaitInterval()
183 DCHECK(job.purpose == SyncSessionJob::NUDGE || in DecideWhileInWaitInterval()
184 job.purpose == SyncSessionJob::CONFIGURATION); in DecideWhileInWaitInterval()
189 if (job.purpose == SyncSessionJob::NUDGE) { in DecideWhileInWaitInterval()
198 return job.is_canary_job ? CONTINUE : SAVE; in DecideWhileInWaitInterval()
202 const SyncSessionJob& job) { in DecideOnJob() argument
203 if (job.purpose == SyncSessionJob::CLEAR_USER_DATA) in DecideOnJob()
[all …]
/external/chromium/chrome/browser/policy/
Ddevice_management_service.cc131 for (JobFetcherMap::iterator job(pending_jobs_.begin()); in Shutdown() local
132 job != pending_jobs_.end(); in Shutdown()
133 ++job) { in Shutdown()
134 delete job->first; in Shutdown()
135 queued_jobs_.push_back(job->second); in Shutdown()
145 void DeviceManagementService::AddJob(DeviceManagementJob* job) { in AddJob() argument
147 StartJob(job); in AddJob()
149 queued_jobs_.push_back(job); in AddJob()
152 void DeviceManagementService::RemoveJob(DeviceManagementJob* job) { in RemoveJob() argument
156 if (entry->second == job) { in RemoveJob()
[all …]
/external/chromium_org/chrome_frame/test/net/
Dtest_automation_resource_message_filter.cc19 URLRequestAutomationJob* job, IPC::Message* msg) { in OnRequestMessage() argument
20 job->OnMessage(*msg); in OnRequestMessage()
37 RequestJob& job = it->second; in OnMessageReceived() local
52 job.loop_->PostTask(FROM_HERE, in OnMessageReceived()
53 base::Bind(OnRequestMessage, job.job_, msg)); in OnMessageReceived()
63 URLRequestAutomationJob* job) { in RegisterRequest() argument
68 DCHECK(requests_.end() == requests_.find(job->id())); in RegisterRequest()
69 RequestJob request_job = { base::MessageLoop::current(), job }; in RegisterRequest()
70 requests_[job->id()] = request_job; in RegisterRequest()
76 URLRequestAutomationJob* job) { in UnRegisterRequest() argument
[all …]
/external/chromium_org/net/websockets/
Dwebsocket_throttle.cc42 bool WebSocketThrottle::PutInQueue(WebSocketJob* job) { in PutInQueue() argument
46 queue_.push_back(job); in PutInQueue()
47 const AddressList& address_list = job->address_list(); in PutInQueue()
61 new_queue->second.push_back(job); in PutInQueue()
64 iter->second.push_back(job); in PutInQueue()
65 job->SetWaiting(); in PutInQueue()
73 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { in RemoveFromQueue() argument
75 std::find(queue_.begin(), queue_.end(), job); in RemoveFromQueue()
82 const AddressList& resolved_address_list = job->address_list(); in RemoveFromQueue()
99 std::find(per_address_queue.begin(), per_address_queue.end(), job); in RemoveFromQueue()
[all …]
/external/chromium_org/chrome/browser/printing/
Dprint_job_unittest.cc103 scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check)); in TEST_F() local
104 EXPECT_EQ(base::MessageLoop::current(), job->message_loop()); in TEST_F()
107 job->Initialize(owner.get(), &source, 1); in TEST_F()
108 job->Stop(); in TEST_F()
109 EXPECT_FALSE(job->is_stopped()); in TEST_F()
110 EXPECT_TRUE(job->is_stopping()); in TEST_F()
111 while (!job->is_stopped()) in TEST_F()
115 EXPECT_TRUE(job->is_stopped()); in TEST_F()
116 EXPECT_FALSE(job->is_stopping()); in TEST_F()
117 job = NULL; in TEST_F()
[all …]
/external/chromium/net/websockets/
Dwebsocket_throttle.cc62 void WebSocketThrottle::PutInQueue(WebSocketJob* job) { in PutInQueue() argument
63 queue_.push_back(job); in PutInQueue()
64 const AddressList& address_list = job->address_list(); in PutInQueue()
79 queue->push_back(job); in PutInQueue()
82 iter->second->push_back(job); in PutInQueue()
83 job->SetWaiting(); in PutInQueue()
89 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { in RemoveFromQueue() argument
94 if (*iter == job) { in RemoveFromQueue()
102 const AddressList& address_list = job->address_list(); in RemoveFromQueue()
121 if (*iter == job) { in RemoveFromQueue()
[all …]
/external/chromium_org/net/base/
Dprioritized_dispatcher.cc27 Job* job, Priority priority) { in Add() argument
28 DCHECK(job); in Add()
32 job->Start(); in Add()
35 return queue_.Insert(job, priority); in Add()
39 Job* job, Priority priority) { in AddAtHead() argument
40 DCHECK(job); in AddAtHead()
44 job->Start(); in AddAtHead()
47 return queue_.InsertAtFront(job, priority); in AddAtHead()
58 Job* job = handle.value(); in EvictOldestLowest() local
60 return job; in EvictOldestLowest()
[all …]
/external/chromium_org/net/socket_stream/
Dsocket_stream_job_manager.cc27 SocketStreamJob* job = new SocketStreamJob(); in CreateJob() local
28 job->InitSocketStream(new SocketStream(url, delegate)); in CreateJob()
29 return job; in CreateJob()
37 SocketStreamJob* job = found->second(url, delegate); in CreateJob() local
38 if (job) in CreateJob()
39 return job; in CreateJob()
41 SocketStreamJob* job = new SocketStreamJob(); in CreateJob() local
42 job->InitSocketStream(new SocketStream(url, delegate)); in CreateJob()
43 return job; in CreateJob()
/external/chromium/net/socket_stream/
Dsocket_stream_job_manager.cc27 SocketStreamJob* job = new SocketStreamJob(); in CreateJob() local
28 job->InitSocketStream(new SocketStream(url, delegate)); in CreateJob()
29 return job; in CreateJob()
37 SocketStreamJob* job = found->second(url, delegate); in CreateJob() local
38 if (job) in CreateJob()
39 return job; in CreateJob()
41 SocketStreamJob* job = new SocketStreamJob(); in CreateJob() local
42 job->InitSocketStream(new SocketStream(url, delegate)); in CreateJob()
43 return job; in CreateJob()
/external/chromium_org/webkit/browser/appcache/
Dappcache_url_request_job_unittest.cc382 scoped_refptr<AppCacheURLRequestJob> job; in Basic() local
386 job = new AppCacheURLRequestJob( in Basic()
388 EXPECT_TRUE(job->is_waiting()); in Basic()
389 EXPECT_FALSE(job->is_delivering_appcache_response()); in Basic()
390 EXPECT_FALSE(job->is_delivering_network_response()); in Basic()
391 EXPECT_FALSE(job->is_delivering_error_response()); in Basic()
392 EXPECT_FALSE(job->has_been_started()); in Basic()
393 EXPECT_FALSE(job->has_been_killed()); in Basic()
394 EXPECT_EQ(GURL(), job->manifest_url()); in Basic()
395 EXPECT_EQ(kNoCacheId, job->cache_id()); in Basic()
[all …]

12345678910>>...13