Searched refs:QUEUE_INIT (Results 1 – 21 of 21) sorted by relevance
50 QUEUE_INIT(&loop->wq); in uv_loop_init()51 QUEUE_INIT(&loop->idle_handles); in uv_loop_init()52 QUEUE_INIT(&loop->async_handles); in uv_loop_init()53 QUEUE_INIT(&loop->check_handles); in uv_loop_init()54 QUEUE_INIT(&loop->prepare_handles); in uv_loop_init()55 QUEUE_INIT(&loop->handle_queue); in uv_loop_init()62 QUEUE_INIT(&loop->pending_queue); in uv_loop_init()63 QUEUE_INIT(&loop->watcher_queue); in uv_loop_init()88 QUEUE_INIT(&loop->process_handles); in uv_loop_init()
103 QUEUE_INIT(&tmp_watcher_list.watchers); in uv__inotify_fork()290 QUEUE_INIT(&w->watchers); in uv_fs_event_start()
245 QUEUE_INIT(&head); in uv__fsevents_event_cb()620 QUEUE_INIT(&loop->cf_signals); in uv__fsevents_loop_init()630 QUEUE_INIT(&state->fsevent_handles); in uv__fsevents_loop_init()821 QUEUE_INIT(&handle->cf_events); in uv__fsevents_init()
95 QUEUE_INIT(&pending); in uv__wait_children()142 QUEUE_INIT(&process->queue); in uv__wait_children()963 QUEUE_INIT(&process->queue); in uv_spawn()
795 QUEUE_INIT(q); in uv__run_pending()853 QUEUE_INIT(&w->pending_queue); in uv__io_init()854 QUEUE_INIT(&w->watcher_queue); in uv__io_init()912 QUEUE_INIT(&w->watcher_queue); in uv__io_stop()
146 QUEUE_INIT(q); in uv__io_poll()
159 QUEUE_INIT(q); in uv__io_poll()
231 QUEUE_INIT(&req->queue); in uv_pipe_connect()
86 QUEUE_INIT(&stream->write_queue); in uv__stream_init()87 QUEUE_INIT(&stream->write_completed_queue); in uv__stream_init()1467 QUEUE_INIT(&req->queue); in uv_write2()
258 QUEUE_INIT(&req->queue); in uv__tcp_connect()
204 QUEUE_INIT(&global_epoll_queue); in epoll_init()
1047 QUEUE_INIT(&handle->write_queue); in uv__udp_init_ex()1048 QUEUE_INIT(&handle->write_completed_queue); in uv__udp_init_ex()
675 QUEUE_INIT(q); in uv__io_poll()
177 QUEUE_INIT(q); in uv__io_poll()
160 QUEUE_INIT(q); in uv__io_poll()
19 #define QUEUE_INIT "/init_mqueue" macro198 fd3 = SAFE_MQ_OPEN(QUEUE_INIT, O_CREAT | O_EXCL | O_RDWR, S_IRWXU, NULL); in setup()210 tst_res(TWARN | TERRNO, "mq_close(%s) failed", QUEUE_INIT); in cleanup()212 if (mq_unlink(QUEUE_INIT)) in cleanup()213 tst_res(TWARN | TERRNO, "mq_unlink(%s) failed", QUEUE_INIT); in cleanup()
88 QUEUE_INIT(q); /* Signal uv_cancel() that the work req is executing. */ in worker()109 QUEUE_INIT(q); in worker()222 QUEUE_INIT(&wq); in init_threads()223 QUEUE_INIT(&slow_io_pending_wq); in init_threads()224 QUEUE_INIT(&run_slow_work_message); in init_threads()
45 #define QUEUE_INIT(q) \ macro75 QUEUE_INIT(n); \
255 QUEUE_INIT(&loop->wq); in uv_loop_init()256 QUEUE_INIT(&loop->handle_queue); in uv_loop_init()
114 QUEUE_INIT(&handle->pipe.conn.ipc_xfer_queue); in uv_pipe_init()