PE_CONSUMER
switch (safe_read(rst_event_pipe[PE_CONSUMER], &event,
clear_pollfd(rst_event_pipe[PE_CONSUMER]);
if (isset_pollfd(rst_event_pipe[PE_CONSUMER])) {
disable_blocking(rst_event_pipe[PE_CONSUMER]);
if ((set_pollfd(rst_event_pipe[PE_CONSUMER], POLLIN)) == -1)
(void) close(pipe_fds[PE_CONSUMER]);
if ((safe_read(pipe_fds[PE_CONSUMER], &i, sizeof (i)) != 0) ||
(void) close(pipe_fds[PE_CONSUMER]);
(void) close(pipe_fds[PE_CONSUMER]);
(void) close(pipe_fds[PE_CONSUMER]);
if (safe_write(rst_event_pipe[PE_CONSUMER], &processed,