Lines Matching refs:wq
41 static QUEUE wq; variable
71 while (QUEUE_EMPTY(&wq) || in worker()
72 (QUEUE_HEAD(&wq) == &run_slow_work_message && in worker()
73 QUEUE_NEXT(&run_slow_work_message) == &wq && in worker()
80 q = QUEUE_HEAD(&wq); in worker()
95 QUEUE_INSERT_TAIL(&wq, q); in worker()
113 QUEUE_INSERT_TAIL(&wq, &run_slow_work_message); in worker()
121 w = QUEUE_DATA(q, struct uv__work, wq); in worker()
127 QUEUE_INSERT_TAIL(&w->loop->wq, &w->wq); in worker()
156 QUEUE_INSERT_TAIL(&wq, q); in post()
222 QUEUE_INIT(&wq); in init_threads()
270 post(&w->wq, kind); in uv__work_submit()
280 cancelled = !QUEUE_EMPTY(&w->wq) && w->work != NULL; in uv__work_cancel()
282 QUEUE_REMOVE(&w->wq); in uv__work_cancel()
292 QUEUE_INSERT_TAIL(&loop->wq, &w->wq); in uv__work_cancel()
304 QUEUE wq; in uv__work_done() local
309 QUEUE_MOVE(&loop->wq, &wq); in uv__work_done()
312 while (!QUEUE_EMPTY(&wq)) { in uv__work_done()
313 q = QUEUE_HEAD(&wq); in uv__work_done()
316 w = container_of(q, struct uv__work, wq); in uv__work_done()