Mercurial > dnft
view pipes.cpp @ 0:4171b2d4684b default tip
initial commit
| author | Yasuri <linuxoverwindows@charliesmp.net> |
|---|---|
| date | Sat, 05 Sep 2026 15:35:48 -0500 |
| parents | |
| children |
line wrap: on
line source
#include <iostream> #include <unistd.h> #include <spawn.h> #include <cstring> #include <string> #include <sys/wait.h> extern char** environ; std::string run_piped(const char* path, char* const argv[], const std::string& input) { int status; pid_t pid; int pipeA[2]; int pipeB[2]; pipe(pipeA); pipe(pipeB); posix_spawn_file_actions_t actions; posix_spawn_file_actions_init(&actions); // initialize actions posix_spawn_file_actions_adddup2(&actions, pipeA[0], STDIN_FILENO); posix_spawn_file_actions_adddup2(&actions, pipeB[1], STDOUT_FILENO); posix_spawn_file_actions_addclose(&actions, pipeA[1]); // closes write end in child posix_spawn_file_actions_addclose(&actions, pipeB[0]); // makes sure child doesn't read its own output pipe posix_spawn_file_actions_addclose(&actions, pipeA[0]); // close read fd in child posix_spawn_file_actions_addclose(&actions, pipeB[1]); // close read fd in child, part 2 std::cout << "Running posix_spawn()..." << std::endl; status = posix_spawn(&pid, path, &actions, NULL, const_cast<char* const*>(argv), environ); close(pipeA[0]); close(pipeB[1]); if (status != 0) { posix_spawn_file_actions_destroy(&actions); close(pipeA[1]); close(pipeB[0]); std::cerr << "posix_spawn failed: " << strerror(status) << std::endl; return "error"; } write(pipeA[1],input.c_str(), input.size()); close(pipeA[1]); char buf[256]; std::string result; ssize_t n; while ((n = read(pipeB[0], buf, sizeof(buf))) > 0) { result.append(buf, n); } close(pipeB[0]); if (waitpid(pid, &status, 0) == -1) { posix_spawn_file_actions_destroy(&actions); close(pipeA[1]); close(pipeB[0]); perror("waitpid"); return "error"; } return result; }
