Searched refs:resp_read_pipe (Results 1 – 6 of 6) sorted by relevance
| /freebsd-13.1/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 | 456 rc = read(c->resp_read_pipe, scratch, sizeof(scratch)); in receive_blocking_resp_internal()
572 c->resp_read_pipe = move_fd(pipe_ends[0]);
575 flags = fcntl(c->resp_read_pipe, F_GETFL, 0);
580 rc = fcntl(c->resp_read_pipe, F_SETFL, O_NONBLOCK | flags);
586 (*addremove_io_fd)(c->resp_read_pipe, c->ispipe, FALSE);
912 DEBUG_INSIST(-1 != c->resp_read_pipe); in cleanup_after_child()
914 (*addremove_io_fd)(c->resp_read_pipe, c->ispipe, TRUE); in cleanup_after_child()
916 close(c->resp_read_pipe); in cleanup_after_child()
918 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-13.1/contrib/ntp/include/ |
| H A D | ntp_worker.h | 66 int resp_read_pipe; member
118 int resp_read_pipe; /* parent */ member
|
| /freebsd-13.1/contrib/ntp/sntp/ |
| H A D | main.c | 969 if (fd == c->resp_read_pipe) in sntp_addremove_fd()
1037 DEBUG_INSIST(fd == c->resp_read_pipe); in worker_resp_cb()
|
| /freebsd-13.1/contrib/ntp/ntpd/ |
| H A D | ntp_io.c | 3895 if (NULL == c || -1 == c->resp_read_pipe)
3897 if (FD_ISSET(c->resp_read_pipe, pfds)) {
|