13 PrioritizedDispatcher::Limits::Limits(Priority num_priorities,  in Limits()  function in net::PrioritizedDispatcher::Limits
17 PrioritizedDispatcher::Limits::Limits(const Limits& other) = default;
19 PrioritizedDispatcher::Limits::~Limits() = default;
21 PrioritizedDispatcher::PrioritizedDispatcher(const Limits& limits)  in PrioritizedDispatcher()  argument
22     : queue_(limits.reserved_slots.size()),  in PrioritizedDispatcher()
23       max_running_jobs_(limits.reserved_slots.size()) {  in PrioritizedDispatcher()
24   SetLimits(limits);  in PrioritizedDispatcher()
71       "Job should not be in queue when limits permit it to start.";  in ChangePriority()
89 PrioritizedDispatcher::Limits PrioritizedDispatcher::GetLimits() const {  in GetLimits()
91   Limits limits(num_priorities, max_running_jobs_.back());  in GetLimits()  local
96     limits.reserved_slots[i] = max_running_jobs_[i] - max_running_jobs_[i - 1];  in GetLimits()
99   return limits;  in GetLimits()
102 void PrioritizedDispatcher::SetLimits(const Limits& limits) {  in SetLimits()  argument
103   DCHECK_EQ(queue_.num_priorities(), limits.reserved_slots.size());  in SetLimits()
105   for (size_t i = 0; i < limits.reserved_slots.size(); ++i) {  in SetLimits()
106     total += limits.reserved_slots[i];  in SetLimits()
110   DCHECK_LE(total, limits.total_jobs) << "sum(reserved_slots) <= total_jobs";  in SetLimits()
111   size_t spare = limits.total_jobs - total;  in SetLimits()
112   for (size_t i = limits.reserved_slots.size(); i > 0; --i) {  in SetLimits()
116   // Start pending jobs, if limits permit.  in SetLimits()
124   SetLimits(Limits(queue_.num_priorities(), 0));  in SetLimitsToZero()