Lines Matching refs:q_
144 while (isRunning() && wq->q_.size() == 0) {
150 // timed out records to q_.
158 wq->q_.push_back(r);
161 if ((wq->q_.size() == 0) && (wq->delayed_q_.size() != 0)) {
179 struct WorkerQueue::Record *r = wq->q_.front();
180 wq->q_.pop_front();
264 * Add a record to processing queue q_
270 q_.push_back(r);
271 if (q_.size() == 1) {
294 if ((q_.size() == 0) && (delayed_q_.top() == r)) {
295 // q_ is empty and the new record is at delayed_q_.top
