Searched refs:resp_read_pipe (Results 1 – 6 of 6) sorted by relevance
| /freebsd/contrib/ntp/libntp/ |
| H A D | work_fork.c | 228 if (-1 != c->resp_read_pipe) { in cleanup_after_child()
229 (*addremove_io_fd)(c->resp_read_pipe, c->ispipe, TRUE); in cleanup_after_child()
230 close(c->resp_read_pipe); in cleanup_after_child()
231 c->resp_read_pipe = -1; in cleanup_after_child()
380 DEBUG_REQUIRE(c->resp_read_pipe != -1); in receive_blocking_resp_internal()
383 rc = netread(c->resp_read_pipe, &hdr, sizeof(hdr)); in receive_blocking_resp_internal()
399 rc = netread(c->resp_read_pipe, (char *)(resp + 1), in receive_blocking_resp_internal()
486 c->resp_read_pipe = move_fd(blocking_pipes[2]); in fork_blocking_child()
532 (*addremove_io_fd)(c->resp_read_pipe, is_pipe, FALSE); in fork_blocking_child()
|
| H A D | work_thread.c | 450 rc = read(c->resp_read_pipe, scratch, sizeof(scratch)); in receive_blocking_resp_internal()
569 c->resp_read_pipe = move_fd(pipe_ends[0]);
572 flags = fcntl(c->resp_read_pipe, F_GETFL, 0);
577 rc = fcntl(c->resp_read_pipe, F_SETFL, O_NONBLOCK | flags);
583 (*addremove_io_fd)(c->resp_read_pipe, c->ispipe, FALSE);
922 DEBUG_INSIST(-1 != c->resp_read_pipe); in cleanup_after_child()
924 (*addremove_io_fd)(c->resp_read_pipe, c->ispipe, TRUE); in cleanup_after_child()
926 close(c->resp_read_pipe); in cleanup_after_child()
928 c->resp_read_pipe = -1; in cleanup_after_child()
|
| H A D | ntp_worker.c | 202 c->resp_read_pipe = -1; in queue_blocking_request()
|
| /freebsd/contrib/ntp/include/ |
| H A D | ntp_worker.h | 66 int resp_read_pipe; member
118 int resp_read_pipe; /* parent */ member
|
| /freebsd/contrib/ntp/sntp/ |
| H A D | main.c | 970 if (fd == c->resp_read_pipe) in sntp_addremove_fd()
1025 * worker_resp_cb() is invoked when resp_read_pipe is readable.
1038 INSIST(fd == c->resp_read_pipe); in worker_resp_cb()
|
| /freebsd/contrib/ntp/ntpd/ |
| H A D | ntp_io.c | 3924 if (NULL == c || -1 == c->resp_read_pipe)
3926 if (FD_ISSET(c->resp_read_pipe, pfds)) {
|