| /external/chromium/net/http/ |
| D | http_stream_factory_impl_request.cc | 34 DCHECK(jobs_.empty()); in ~Request()
36 DCHECK(!jobs_.empty()); in ~Request()
40 for (std::set<Job*>::iterator it = jobs_.begin(); it != jobs_.end(); ++it) in ~Request()
43 STLDeleteElements(&jobs_); in ~Request()
60 jobs_.insert(job); in AttachJob()
90 DCHECK(!jobs_.empty()); in OnStreamReady()
104 DCHECK(jobs_.empty()); in OnStreamReady()
117 if (jobs_.size() > 1) { in OnStreamFailed()
118 jobs_.erase(job); in OnStreamFailed()
124 jobs_.erase(job); in OnStreamFailed()
[all …]
|
| D | http_stream_factory_impl_request.h | 103 std::set<HttpStreamFactoryImpl::Job*> jobs_; variable
|
| /external/chromium_org/net/http/ |
| D | http_stream_factory_impl_request.cc | 41 DCHECK(jobs_.empty()); in ~Request()
43 DCHECK(!jobs_.empty()); in ~Request()
47 for (std::set<Job*>::iterator it = jobs_.begin(); it != jobs_.end(); ++it) in ~Request()
53 STLDeleteElements(&jobs_); in ~Request()
80 jobs_.insert(job); in AttachJob()
139 DCHECK(!jobs_.empty()); in OnStreamFailed()
146 if (jobs_.size() > 1) { in OnStreamFailed()
147 jobs_.erase(job); in OnStreamFailed()
153 jobs_.erase(job); in OnStreamFailed()
154 DCHECK(jobs_.empty()); in OnStreamFailed()
[all …]
|
| D | http_stream_factory_impl_request.h | 136 std::set<HttpStreamFactoryImpl::Job*> jobs_; variable
|
| /external/chromium_org/components/policy/core/common/cloud/ |
| D | external_policy_data_fetcher.cc | 89 for (JobSet::iterator it = jobs_.begin(); it != jobs_.end(); ++it) in ~ExternalPolicyDataFetcher()
105 jobs_.insert(job); in StartJob()
114 DCHECK(jobs_.find(job) != jobs_.end()); in CancelJob()
115 jobs_.erase(job); in CancelJob()
137 JobSet::iterator it = jobs_.find(job); in OnJobFinished()
138 if (it == jobs_.end()) { in OnJobFinished()
145 jobs_.erase(it); in OnJobFinished()
|
| D | external_policy_data_fetcher_unittest.cc | 57 std::map<int, ExternalPolicyDataFetcher::Job*> jobs_; // Not owned. member in policy::ExternalPolicyDataFetcherTest
86 jobs_[index] = fetcher_->StartJob( in StartJob()
96 jobs_.find(index); in CancelJob()
97 ASSERT_TRUE(it != jobs_.end()); in CancelJob()
99 jobs_.erase(it); in CancelJob()
111 jobs_.erase(job_index); in OnJobFinished()
|
| D | external_policy_data_fetcher.h | 113 JobSet jobs_; variable
|
| /external/chromium_org/chrome/browser/chromeos/login/ |
| D | user_image_manager_impl.cc | 523 if (IsUserImageManaged(user_id) && ContainsKey(jobs_, user_id)) in LoadUserImages()
562 linked_ptr<Job>& job = jobs_[user_id]; in LoadUserImages()
589 linked_ptr<Job>& job = jobs_[user_id]; in UserLoggedIn()
642 linked_ptr<Job>& job = jobs_[user_id]; in SaveUserDefaultImageIndex()
651 linked_ptr<Job>& job = jobs_[user_id]; in SaveUserImage()
660 linked_ptr<Job>& job = jobs_[user_id]; in SaveUserImageFromFile()
671 linked_ptr<Job>& job = jobs_[user_id]; in SaveUserImageFromProfileImage()
684 jobs_.erase(user_id); in DeleteUserImage()
715 jobs_.erase(user_id); in OnExternalDataSet()
737 linked_ptr<Job>& job = jobs_[user_id]; in OnExternalDataFetched()
[all …]
|
| D | user_image_manager_impl.h | 222 std::map<std::string, linked_ptr<Job> > jobs_; variable
|
| D | user_image_manager_browsertest.cc | 277 UserManager::Get()->GetUserImageManager())->jobs_; in CompleteProfileImageDownload()
|
| /external/chromium/net/socket/ |
| D | client_socket_pool_base.h | 350 jobs_.empty() && pending_requests_.empty(); in IsEmpty()
358 return active_socket_count_ + static_cast<int>(jobs_.size()) + in NumActiveSocketSlots()
364 pending_requests_.size() > jobs_.size(); in IsStalled()
385 void AddJob(ConnectJob* job) { jobs_.insert(job); } in AddJob()
386 void RemoveJob(ConnectJob* job) { jobs_.erase(job); } in RemoveJob()
392 const std::set<ConnectJob*>& jobs() const { return jobs_; } in jobs()
406 std::set<ConnectJob*> jobs_; variable
|
| D | client_socket_pool_base.cc | 1077 for (std::set<ConnectJob*>::iterator it = jobs_.begin(); in TryToUsePreconnectConnectJob()
1078 it != jobs_.end(); ++it) { in TryToUsePreconnectConnectJob()
1093 if (jobs_.empty()) { in OnBackupSocketTimerFired()
1102 (*jobs_.begin())->GetLoadState() == LOAD_STATE_RESOLVING_HOST) { in OnBackupSocketTimerFired()
1125 STLDeleteElements(&jobs_); in RemoveAllJobs()
|
| /external/chromium/chrome/browser/sync/glue/ |
| D | ui_model_worker_unittest.cc | 80 : syncer_thread_(syncer_thread), worker_(worker), jobs_(jobs), in FakeSyncapiShutdownTask()
90 all_jobs_done_.WaitMany(jobs_, job_count_); in Run()
99 base::WaitableEvent** jobs_; member in FakeSyncapiShutdownTask
|
| /external/chromium/net/base/ |
| D | host_resolver_impl.cc | 965 CHECK(jobs_.empty()) << "Can only set constraints during setup"; in SetPoolConstraints()
1176 scoped_refptr<Job>& found_job = jobs_[job->key()]; in AddOutstandingJob()
1185 JobMap::iterator it = jobs_.find(key); in FindOutstandingJob()
1186 if (it != jobs_.end()) in FindOutstandingJob()
1192 JobMap::iterator it = jobs_.find(job->key()); in RemoveOutstandingJob()
1193 DCHECK(it != jobs_.end()); in RemoveOutstandingJob()
1195 jobs_.erase(it); in RemoveOutstandingJob()
1345 DCHECK_LE(jobs_.size(), max_jobs_); in CanCreateJobForPool()
1348 if (jobs_.size() + 1 > max_jobs_) in CanCreateJobForPool()
1438 jobs.swap(jobs_); in CancelAllJobs()
[all …]
|
| D | host_resolver_impl.h | 233 JobMap jobs_; variable
|
| /external/chromium_org/net/socket/ |
| D | client_socket_pool_base.cc | 1178 jobs_.insert(job.release()); in AddJob()
1185 std::set<ConnectJob*>::iterator it = jobs_.find(job); in RemoveJob()
1186 if (it != jobs_.end()) { in RemoveJob()
1187 jobs_.erase(it); in RemoveJob()
1191 size_t job_count = jobs_.size(); in RemoveJob()
1197 if (jobs_.empty()) in RemoveJob()
1206 if (jobs_.empty()) { in OnBackupJobTimerFired()
1215 (*jobs_.begin())->GetLoadState() == LOAD_STATE_RESOLVING_HOST) { in OnBackupJobTimerFired()
1237 DCHECK_LE(unassigned_job_count_, jobs_.size()); in SanityCheck()
1244 STLDeleteElements(&jobs_); in RemoveAllJobs()
[all …]
|
| D | client_socket_pool_base.h | 368 jobs_.empty() && pending_requests_.empty(); in IsEmpty()
376 return active_socket_count_ + static_cast<int>(jobs_.size()) + in NumActiveSocketSlots()
382 pending_requests_.size() > jobs_.size(); in IsStalledOnPoolMaxSockets()
445 const std::set<ConnectJob*>& jobs() const { return jobs_; } in jobs()
474 std::set<ConnectJob*> jobs_; variable
|
| /external/chromium_org/net/dns/ |
| D | host_resolver_impl.cc | 1848 STLDeleteValues(&jobs_); in ~HostResolverImpl()
1895 JobMap::iterator jobit = jobs_.find(key); in Resolve()
1897 if (jobit == jobs_.end()) { in Resolve()
1913 jobs_.insert(jobit, std::make_pair(key, job)); in Resolve()
2130 JobMap::iterator it = jobs_.find(job->key()); in RemoveJob()
2131 if (it != jobs_.end() && it->second == job) in RemoveJob()
2132 jobs_.erase(it); in RemoveJob()
2186 for (JobMap::iterator it = jobs_.begin(); it != jobs_.end(); ) { in AbortAllInProgressJobs()
2190 jobs_.erase(it++); in AbortAllInProgressJobs()
2226 for (JobMap::iterator it = jobs_.begin(); it != jobs_.end(); ++it) in AbortDnsTasks()
[all …]
|
| D | host_resolver_impl.h | 248 JobMap jobs_; variable
|
| /external/chromium_org/net/base/ |
| D | prioritized_dispatcher_unittest.cc | 146 jobs_.push_back(job); in AddJob()
153 jobs_.push_back(job); in AddJobAtHead()
167 ScopedVector<TestJob> jobs_; member in net::__anon4787b9030111::PrioritizedDispatcherTest
|