Lines Matching refs:job
42 bool WebSocketThrottle::PutInQueue(WebSocketJob* job) { in PutInQueue() argument
46 queue_.push_back(job); in PutInQueue()
47 const AddressList& address_list = job->address_list(); in PutInQueue()
61 new_queue->second.push_back(job); in PutInQueue()
64 iter->second.push_back(job); in PutInQueue()
65 job->SetWaiting(); in PutInQueue()
73 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { in RemoveFromQueue() argument
75 std::find(queue_.begin(), queue_.end(), job); in RemoveFromQueue()
82 const AddressList& resolved_address_list = job->address_list(); in RemoveFromQueue()
99 std::find(per_address_queue.begin(), per_address_queue.end(), job); in RemoveFromQueue()
121 WebSocketJob* job = *iter; in WakeupSocketIfNecessary() local
122 if (!job->IsWaiting()) in WakeupSocketIfNecessary()
126 const AddressList& resolved_address_list = job->address_list(); in WakeupSocketIfNecessary()
134 if (job != per_address_queue.front()) { in WakeupSocketIfNecessary()
140 job->Wakeup(); in WakeupSocketIfNecessary()