Lines Matching defs:wq
54 static struct uv__queue wq;
92 w = uv__queue_data(q, struct uv__statistic_work, wq);
112 struct uv_work_dump_info* info = uv__queue_data(q, struct uv_work_dump_info, wq);
124 uv__queue_insert_head(&dump_queue, &work->info->wq);
177 uv__queue_init(&dump_work->wq);
178 post_statistic_work(&dump_work->wq);
218 uv__queue_init(&info->wq);
231 uv__queue_init(&dump_work->wq);
232 post_statistic_work(&dump_work->wq);
247 struct uv_work_dump_info* info = uv__queue_data(q, struct uv_work_dump_info, wq);
356 while (uv__queue_empty(&wq) ||
357 (uv__queue_head(&wq) == &run_slow_work_message &&
358 uv__queue_next(&run_slow_work_message) == &wq &&
365 q = uv__queue_head(&wq);
380 uv__queue_insert_tail(&wq, q);
398 uv__queue_insert_tail(&wq, &run_slow_work_message);
406 w = uv__queue_data(q, struct uv__work, wq);
421 uv__queue_insert_tail(&w->loop->wq, &w->wq);
451 uv__queue_insert_tail(&wq, q);
525 uv__queue_init(&wq);
580 post(&w->wq, kind);
609 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL;
611 uv__queue_remove(&w->wq);
617 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL
630 uv__queue_insert_tail(&loop->wq, &w->wq);
642 uv__queue_insert_tail(&(lfields->wq_sub[qos]), &w->wq);
657 struct uv__queue wq;
671 uv__queue_move(&loop->wq, &wq);
675 uv__queue_init(&wq);
678 uv__queue_append(&lfields->wq_sub[i], &wq);
686 while (!uv__queue_empty(&wq)) {
687 q = uv__queue_head(&wq);
690 w = container_of(q, struct uv__work, wq);
711 QUEUE_INIT(&dump_work->wq);
712 post_statistic_work(&dump_work->wq);
791 uv__queue_insert_tail(&(lfields->wq_sub[qos]), &w->wq);