Lines Matching refs:worker
42 struct child_worker *worker = &workers[round_robin_counter]; in on_new_connection() local
43 … uv_write2(write_req, (uv_stream_t*) &worker->pipe, &dummy_buf, 1, (uv_stream_t*) client, NULL); in on_new_connection()
75 struct child_worker *worker = &workers[cpu_count]; in setup_workers() local
76 uv_pipe_init(loop, &worker->pipe, 1); in setup_workers()
80 child_stdio[0].data.stream = (uv_stream_t*) &worker->pipe; in setup_workers()
85 worker->options.stdio = child_stdio; in setup_workers()
86 worker->options.stdio_count = 3; in setup_workers()
88 worker->options.exit_cb = close_process_handle; in setup_workers()
89 worker->options.file = args[0]; in setup_workers()
90 worker->options.args = args; in setup_workers()
92 uv_spawn(loop, &worker->req, &worker->options); in setup_workers()
93 fprintf(stderr, "Started worker %d\n", worker->req.pid); in setup_workers()