Lines Matching refs:ipc_fd
203 WorkerProcess(struct ev_loop *loop, pid_t worker_pid, int ipc_fd
213 ipc_fd(ipc_fd)
235 if (ipc_fd != -1) {
236 shutdown(ipc_fd, SHUT_WR);
237 close(ipc_fd);
244 int ipc_fd;
642 while ((nwrite = write(wp->ipc_fd, &ipc_event, 1)) == -1 && errno == EINTR)
1350 // messages to the worker process. On success, ipc_fd[0] is for
1351 // reading, and ipc_fd[1] for writing, just like pipe(2).
1352 int create_ipc_socket(std::array<int, 2> &ipc_fd) {
1356 rv = pipe(ipc_fd.data());
1365 auto fd = ipc_fd[i];
1375 int create_worker_process_ready_ipc_socket(std::array<int, 2> &ipc_fd) {
1379 rv = socketpair(AF_UNIX, SOCK_DGRAM, 0, ipc_fd.data());
1388 for (auto fd : ipc_fd) {
1392 util::make_socket_nonblocking(ipc_fd[0]);
1618 std::array<int, 2> ipc_fd;
1620 rv = create_ipc_socket(ipc_fd);
1640 close(ipc_fd[0]);
1641 close(ipc_fd[1]);
1707 close(ipc_fd[1]);
1714 .ipc_fd = ipc_fd[0],
1760 close(ipc_fd[0]);
1761 close(ipc_fd[1]);
1770 close(ipc_fd[0]);
1775 main_ipc_fd = ipc_fd[1];
1832 int ipc_fd = 0;
1852 auto pid = fork_worker_process(ipc_fd
1872 worker_process_add(std::make_unique<WorkerProcess>(loop, pid, ipc_fd
3999 int ipc_fd = 0;
4018 auto pid = fork_worker_process(ipc_fd
4043 worker_process_add(std::make_unique<WorkerProcess>(loop, pid, ipc_fd