Lines Matching refs:job
62 void WebSocketThrottle::PutInQueue(WebSocketJob* job) { in PutInQueue() argument
63 queue_.push_back(job); in PutInQueue()
64 const AddressList& address_list = job->address_list(); in PutInQueue()
79 queue->push_back(job); in PutInQueue()
82 iter->second->push_back(job); in PutInQueue()
83 job->SetWaiting(); in PutInQueue()
89 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { in RemoveFromQueue() argument
94 if (*iter == job) { in RemoveFromQueue()
102 const AddressList& address_list = job->address_list(); in RemoveFromQueue()
121 if (*iter == job) { in RemoveFromQueue()
137 WebSocketJob* job = *iter; in WakeupSocketIfNecessary() local
138 if (!job->IsWaiting()) in WakeupSocketIfNecessary()
142 const AddressList& address_list = job->address_list(); in WakeupSocketIfNecessary()
150 if (job != queue->front()) { in WakeupSocketIfNecessary()
156 job->Wakeup(); in WakeupSocketIfNecessary()