Lines Matching refs:wq
41 static struct uv__queue wq; variable
71 while (uv__queue_empty(&wq) || in worker()
72 (uv__queue_head(&wq) == &run_slow_work_message && in worker()
73 uv__queue_next(&run_slow_work_message) == &wq && in worker()
80 q = uv__queue_head(&wq); in worker()
95 uv__queue_insert_tail(&wq, q); in worker()
113 uv__queue_insert_tail(&wq, &run_slow_work_message); in worker()
121 w = uv__queue_data(q, struct uv__work, wq); in worker()
127 uv__queue_insert_tail(&w->loop->wq, &w->wq); in worker()
156 uv__queue_insert_tail(&wq, q); in post()
223 uv__queue_init(&wq); in init_threads()
274 post(&w->wq, kind); in uv__work_submit()
288 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL; in uv__work_cancel()
290 uv__queue_remove(&w->wq); in uv__work_cancel()
300 uv__queue_insert_tail(&loop->wq, &w->wq); in uv__work_cancel()
312 struct uv__queue wq; in uv__work_done() local
318 uv__queue_move(&loop->wq, &wq); in uv__work_done()
323 while (!uv__queue_empty(&wq)) { in uv__work_done()
324 q = uv__queue_head(&wq); in uv__work_done()
327 w = container_of(q, struct uv__work, wq); in uv__work_done()