Searched refs:jobs_ (Results 1 – 7 of 7) sorted by relevance
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 …]
103 std::set<HttpStreamFactoryImpl::Job*> jobs_; variable
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
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()
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
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 …]
233 JobMap jobs_; variable