Searched refs:work_queue_ (Results 1 – 6 of 6) sorted by relevance
412 if (!work_queue_.empty()) in ReloadWorkQueue()420 incoming_queue_.Swap(&work_queue_); // Constant time in ReloadWorkQueue()426 bool did_work = !work_queue_.empty(); in DeletePendingTasks()427 while (!work_queue_.empty()) { in DeletePendingTasks()428 PendingTask pending_task = work_queue_.front(); in DeletePendingTasks()429 work_queue_.pop(); in DeletePendingTasks()565 if (work_queue_.empty()) in DoWork()570 PendingTask pending_task = work_queue_.front(); in DoWork()571 work_queue_.pop(); in DoWork()581 } while (!work_queue_.empty()); in DoWork()
451 TaskQueue work_queue_; variable
480 work_queue_.Push(url, motivation); in AppendToResolutionQueue()488 while (!work_queue_.IsEmpty() && in StartSomeQueuedResolutions()490 const GURL url(work_queue_.Pop()); in StartSomeQueuedResolutions()496 DCHECK(work_queue_.IsEmpty()); in StartSomeQueuedResolutions()527 if (work_queue_.IsEmpty()) in CongestionControlPerformed()529 info = &results_[work_queue_.Pop()]; in CongestionControlPerformed()568 while (!work_queue_.IsEmpty()) { in DiscardAllResults()570 GURL url = work_queue_.Pop(); in DiscardAllResults()
279 HostNameQueue work_queue_; variable
280 DCHECK(work_queue_.empty()) << "queue has to be empty prior to init"; in InitWorkQueue()283 work_queue_.push(readers_[i]); in InitWorkQueue()576 if (work_queue_.empty()) { in ScheduleArchive()590 DCHECK(!work_queue_.empty()) << "queue has to be non-empty"; in DoArchiveIteration()592 const ExpiringVisitsReader* reader = work_queue_.front(); in DoArchiveIteration()596 work_queue_.pop(); in DoArchiveIteration()600 work_queue_.push(reader); in DoArchiveIteration()
273 std::queue<const ExpiringVisitsReader*> work_queue_; variable