Lines Matching refs:ipc_fd
184 WorkerProcess(struct ev_loop *loop, pid_t worker_pid, int ipc_fd) in WorkerProcess()
185 : loop(loop), worker_pid(worker_pid), ipc_fd(ipc_fd) { in WorkerProcess()
214 if (ipc_fd != -1) { in ~WorkerProcess()
215 shutdown(ipc_fd, SHUT_WR); in ~WorkerProcess()
216 close(ipc_fd); in ~WorkerProcess()
234 int ipc_fd; member
532 while ((nwrite = write(wp->ipc_fd, &ipc_event, 1)) == -1 && errno == EINTR) in ipc_send()
1161 int create_ipc_socket(std::array<int, 2> &ipc_fd) { in create_ipc_socket() argument
1165 rv = pipe(ipc_fd.data()); in create_ipc_socket()
1174 auto fd = ipc_fd[i]; in create_ipc_socket()
1195 std::array<int, 2> ipc_fd; in fork_worker_process() local
1197 rv = create_ipc_socket(ipc_fd); in fork_worker_process()
1208 close(ipc_fd[0]); in fork_worker_process()
1209 close(ipc_fd[1]); in fork_worker_process()
1251 close(ipc_fd[1]); in fork_worker_process()
1254 WorkerProcessConfig wpconf{ipc_fd[0]}; in fork_worker_process()
1293 close(ipc_fd[0]); in fork_worker_process()
1294 close(ipc_fd[1]); in fork_worker_process()
1299 close(ipc_fd[0]); in fork_worker_process()
1301 main_ipc_fd = ipc_fd[1]; in fork_worker_process()
1350 int ipc_fd = 0; in event_loop() local
1352 auto pid = fork_worker_process(ipc_fd, {}); in event_loop()
1358 worker_process_add(std::make_unique<WorkerProcess>(loop, pid, ipc_fd)); in event_loop()
3212 int ipc_fd = 0; in reload_config() local
3219 auto pid = fork_worker_process(ipc_fd, iaddrs); in reload_config()
3238 worker_process_add(std::make_unique<WorkerProcess>(loop, pid, ipc_fd)); in reload_config()