Lines Matching defs:loop
49 static void uv__signal_event(uv_loop_t* loop, uv__io_t* w, unsigned int events);
191 lookup.loop = NULL;
228 r = write(handle->loop->signal_pipefd[1], &msg, sizeof msg);
280 static int uv__signal_loop_once_init(uv_loop_t* loop) {
284 if (loop->signal_pipefd[0] != -1)
287 err = uv__make_pipe(loop->signal_pipefd, UV_NONBLOCK_PIPE);
291 uv__io_init(&loop->signal_io_watcher,
293 loop->signal_pipefd[0]);
294 uv__io_start(loop, &loop->signal_io_watcher, POLLIN);
300 int uv__signal_loop_fork(uv_loop_t* loop) {
303 if (loop->signal_pipefd[0] == -1)
305 uv__io_stop(loop, &loop->signal_io_watcher, POLLIN);
306 uv__close(loop->signal_pipefd[0]);
307 uv__close(loop->signal_pipefd[1]);
308 loop->signal_pipefd[0] = -1;
309 loop->signal_pipefd[1] = -1;
311 uv__queue_foreach(q, &loop->handle_queue) {
323 return uv__signal_loop_once_init(loop);
327 void uv__signal_loop_cleanup(uv_loop_t* loop) {
330 /* Stop all the signal watchers that are still attached to this loop. This
336 uv__queue_foreach(q, &loop->handle_queue) {
343 if (loop->signal_pipefd[0] != -1) {
344 uv__close(loop->signal_pipefd[0]);
345 loop->signal_pipefd[0] = -1;
348 if (loop->signal_pipefd[1] != -1) {
349 uv__close(loop->signal_pipefd[1]);
350 loop->signal_pipefd[1] = -1;
355 int uv_signal_init(uv_loop_t* loop, uv_signal_t* handle) {
358 err = uv__signal_loop_once_init(loop);
362 uv__handle_init(loop, (uv_handle_t*) handle, UV_SIGNAL);
452 static void uv__signal_event(uv_loop_t* loop,
465 r = read(loop->signal_pipefd[0], buf + bytes, sizeof(buf) - bytes);
485 UV_LOGF("errno:%{public}d, sig_pfd[0]:%{public}d", errno, loop->signal_pipefd[0]);
542 /* Sort by loop pointer, so we can easily look up the first item after
543 * { .signum = x, .loop = NULL }.
545 if (w1->loop < w2->loop) return -1;
546 if (w1->loop > w2->loop) return 1;