Lines Matching full:pool
325 // The resolve job (running in worker pool) that this request is dependent on.
344 // This class represents a request to the worker pool for a "getaddrinfo()"
474 // WARNING: This code runs inside a worker pool. The shutdown code cannot
642 // This class represents a request to the worker pool for a "probe for IPv6
762 // Sets the constraints for this pool. See SetPoolConstraints() for the
771 // Returns the number of pending requests enqueued to this pool.
784 // Enqueues a request to this pool. As a result of enqueing this request,
847 // Keeps track of a job that was just added/removed, and belongs to this pool.
857 // Returns true if a new job can be created for this pool.
886 // belonging to this pool.
890 // belonging to this pool.
894 // for this pool.
897 // The requests which are waiting to be started for this pool.
966 JobPool* pool = job_pools_[pool_index];
967 pool->SetConstraints(max_outstanding_jobs, max_pending_requests);
1086 JobPool* pool = GetPoolForRequest(req);
1087 if (CanCreateJobForPool(*pool)) {
1090 return EnqueueRequest(pool, req);
1117 // enqueued into a pool. Remove it from that pool's queue.
1120 JobPool* pool = GetPoolForRequest(req);
1121 pool->RemovePendingRequest(req);
1180 JobPool* pool = GetPoolForRequest(job->initial_request());
1181 pool->AdjustNumOutstandingJobs(1);
1197 JobPool* pool = GetPoolForRequest(job->initial_request());
1198 pool->AdjustNumOutstandingJobs(-1);
1344 bool HostResolverImpl::CanCreateJobForPool(const JobPool& pool) const {
1351 // Check whether the pool's constraints are met.
1352 return pool.CanCreateJob();
1365 JobPool* pool = job_pools_[i];
1366 if (pool->HasPendingRequests() && CanCreateJobForPool(*pool)) {
1367 top_req = pool->RemoveTopPendingRequest();
1379 JobPool* pool = job_pools_[pool_i];
1380 pool->MoveRequestsToJob(job);
1414 int HostResolverImpl::EnqueueRequest(JobPool* pool, Request* req) {
1416 pool->InsertPendingRequest(req));
