Lines Matching refs:writer_put_pipe
73 int writer_put_pipe[2]; /**< Notification pipe from writer */
211 shm_channel->writer_put_pipe[0] = shm_channel->writer_put_pipe[1] = -1;
223 if (pipe (shm_channel->writer_put_pipe) == -1)
241 shm_channel_fd_set_close_on_exec (shm_channel->writer_put_pipe[0]);
242 shm_channel_fd_set_close_on_exec (shm_channel->writer_put_pipe[1]);
314 shm_channel_fd_safe_close (&shm_channel->writer_put_pipe[0]);
315 shm_channel_fd_safe_close (&shm_channel->writer_put_pipe[1]);
332 shm_channel_fd_safe_close (&shm_channel->writer_put_pipe[0]);
422 bytes_written = write (shm_channel->writer_put_pipe[1], &buf_index, 1);
440 shm_channel_fd_safe_close (&shm_channel->writer_put_pipe[1]);
458 shm_channel_fd_safe_close (&shm_channel->writer_put_pipe[1]);
486 return shm_channel_fd_set_non_blocking (shm_channel->writer_put_pipe[0],
509 *fd_return = shm_channel->writer_put_pipe[0];
588 bytes_read = read (shm_channel->writer_put_pipe[0], &buf_index, 1);