Lines Matching refs:pipe

185     nxt_event_engine_pipe_t  *pipe;  in nxt_event_engine_signal_pipe_create()  local
187 pipe = nxt_zalloc(sizeof(nxt_event_engine_pipe_t)); in nxt_event_engine_signal_pipe_create()
188 if (pipe == NULL) { in nxt_event_engine_signal_pipe_create()
192 engine->pipe = pipe; in nxt_event_engine_signal_pipe_create()
199 if (nxt_pipe_create(&engine->task, pipe->fds, 1, 0) != NXT_OK) { in nxt_event_engine_signal_pipe_create()
200 nxt_free(pipe); in nxt_event_engine_signal_pipe_create()
204 pipe->event.fd = pipe->fds[0]; in nxt_event_engine_signal_pipe_create()
205 pipe->event.task = &engine->task; in nxt_event_engine_signal_pipe_create()
206 pipe->event.read_work_queue = &engine->fast_work_queue; in nxt_event_engine_signal_pipe_create()
207 pipe->event.read_handler = nxt_event_engine_signal_pipe; in nxt_event_engine_signal_pipe_create()
208 pipe->event.write_work_queue = &engine->fast_work_queue; in nxt_event_engine_signal_pipe_create()
209 pipe->event.error_handler = nxt_event_engine_signal_pipe_error; in nxt_event_engine_signal_pipe_create()
210 pipe->event.log = engine->task.log; in nxt_event_engine_signal_pipe_create()
212 nxt_fd_event_enable_read(engine, &pipe->event); in nxt_event_engine_signal_pipe_create()
221 nxt_event_engine_pipe_t *pipe; in nxt_event_engine_signal_pipe_free() local
223 pipe = engine->pipe; in nxt_event_engine_signal_pipe_free()
225 if (pipe != NULL) { in nxt_event_engine_signal_pipe_free()
227 if (pipe->event.read_work_queue != NULL) { in nxt_event_engine_signal_pipe_free()
228 nxt_fd_event_close(engine, &pipe->event); in nxt_event_engine_signal_pipe_free()
229 nxt_pipe_close(pipe->event.task, pipe->fds); in nxt_event_engine_signal_pipe_free()
232 nxt_free(pipe); in nxt_event_engine_signal_pipe_free()
240 nxt_event_engine_pipe_t *pipe; in nxt_event_engine_signal_pipe_close() local
242 pipe = obj; in nxt_event_engine_signal_pipe_close()
244 nxt_pipe_close(pipe->event.task, pipe->fds); in nxt_event_engine_signal_pipe_close()
245 nxt_free(pipe); in nxt_event_engine_signal_pipe_close()
284 (void) nxt_fd_write(engine->pipe->fds[1], &buf, 1); in nxt_event_engine_signal()
347 nxt_event_engine_pipe_t *pipe; in nxt_event_engine_signal_pipe_error() local
350 pipe = engine->pipe; in nxt_event_engine_signal_pipe_error()
353 pipe->fds[0], pipe->fds[1]); in nxt_event_engine_signal_pipe_error()
355 nxt_fd_event_close(engine, &pipe->event); in nxt_event_engine_signal_pipe_error()
356 nxt_pipe_close(pipe->event.task, pipe->fds); in nxt_event_engine_signal_pipe_error()
401 nxt_event_engine_signal_pipe(&engine->task, &engine->pipe->event, NULL); in nxt_event_engine_change()
404 if (engine->pipe != NULL && interface->enable_post != NULL) { in nxt_event_engine_change()
411 &engine->task, engine->pipe, NULL); in nxt_event_engine_change()
413 engine->pipe = NULL; in nxt_event_engine_change()