Lines Matching refs:delayed_q_
145 if (wq->delayed_q_.size() == 0) {
149 // delayed_q_ is not empty, move any
152 while((wq->delayed_q_.size() != 0) &&
153 ((wq->delayed_q_.top()->time - now) <= 0)) {
154 struct WorkerQueue::Record *r = wq->delayed_q_.top();
157 wq->delayed_q_.pop();
161 if ((wq->q_.size() == 0) && (wq->delayed_q_.size() != 0)) {
165 struct WorkerQueue::Record *r = wq->delayed_q_.top();
212 while(delayed_q_.size() != 0) {
213 r = delayed_q_.top();
214 delayed_q_.pop();
215 DBG("WorkerQueue::~WorkerQueue delete delayed_q_ r=%p", r);
285 delayed_q_.push(r);
291 p, delay_in_ms, now, delayed_q_.top()->p,
292 delayed_q_.top()->time, delayed_q_.top()->time - now);
294 if ((q_.size() == 0) && (delayed_q_.top() == r)) {
295 // q_ is empty and the new record is at delayed_q_.top
