Lines Matching refs:wakeup_pipe
31 apr_file_t **wakeup_pipe)
35 if ((rv = apr_file_socket_pipe_create(&wakeup_pipe[0], &wakeup_pipe[1],
41 pfd->desc.f = wakeup_pipe[0];
45 apr_status_t apr_poll_close_wakeup_pipe(apr_file_t **wakeup_pipe)
51 if (wakeup_pipe[0]) {
52 rv0 = apr_file_socket_pipe_close(wakeup_pipe[0]);
53 wakeup_pipe[0] = NULL;
55 if (wakeup_pipe[1]) {
56 rv1 = apr_file_socket_pipe_close(wakeup_pipe[1]);
57 wakeup_pipe[1] = NULL;
64 apr_status_t apr_poll_create_wakeup_pipe(apr_pollfd_t *pfd, apr_file_t **wakeup_pipe)
69 apr_status_t apr_poll_close_wakeup_pipe(apr_file_t **wakeup_pipe)
79 apr_file_t **wakeup_pipe)
83 if ((rv = apr_file_pipe_create(&wakeup_pipe[0], &wakeup_pipe[1],
90 pfd->desc.f = wakeup_pipe[0];
95 if ((flags = fcntl(wakeup_pipe[0]->filedes, F_GETFD)) == -1)
99 if (fcntl(wakeup_pipe[0]->filedes, F_SETFD, flags) == -1)
105 if ((flags = fcntl(wakeup_pipe[1]->filedes, F_GETFD)) == -1)
109 if (fcntl(wakeup_pipe[1]->filedes, F_SETFD, flags) == -1)
116 apr_status_t apr_poll_close_wakeup_pipe(apr_file_t **wakeup_pipe)
122 if (wakeup_pipe[0]) {
123 rv0 = apr_file_close(wakeup_pipe[0]);
124 wakeup_pipe[0] = NULL;
126 if (wakeup_pipe[1]) {
127 rv1 = apr_file_close(wakeup_pipe[1]);
128 wakeup_pipe[1] = NULL;
137 void apr_poll_drain_wakeup_pipe(apr_file_t **wakeup_pipe)
142 while (apr_file_read(wakeup_pipe[0], rb, &nr) == APR_SUCCESS) {