diff options
Diffstat (limited to 'tools/unix/process.c')
-rw-r--r-- | tools/unix/process.c | 56 |
1 files changed, 30 insertions, 26 deletions
diff --git a/tools/unix/process.c b/tools/unix/process.c index a714928..249fba3 100644 --- a/tools/unix/process.c +++ b/tools/unix/process.c @@ -47,41 +47,45 @@ extern char **environ; void pipeline(const char *const *argv, struct pipeline *pl) { - posix_spawn_file_actions_t file_acts; + posix_spawn_file_actions_t file_acts; - int pipefds[2]; - if (pipe(pipefds)) - die_errno(errno, "pipe"); + int pipefds[2]; + if (pipe(pipefds)) { + die_errno(errno, "pipe"); + } - die_errno(posix_spawn_file_actions_init(&file_acts), - "posix_spawn_file_actions_init"); - die_errno(posix_spawn_file_actions_adddup2(&file_acts, pipefds[0], 0), - "posix_spawn_file_actions_adddup2"); - die_errno(posix_spawn_file_actions_addclose(&file_acts, pipefds[0]), - "posix_spawn_file_actions_addclose"); - die_errno(posix_spawn_file_actions_addclose(&file_acts, pipefds[1]), - "posix_spawn_file_actions_addclose"); + die_errno(posix_spawn_file_actions_init(&file_acts), + "posix_spawn_file_actions_init"); + die_errno(posix_spawn_file_actions_adddup2(&file_acts, pipefds[0], 0), + "posix_spawn_file_actions_adddup2"); + die_errno(posix_spawn_file_actions_addclose(&file_acts, pipefds[0]), + "posix_spawn_file_actions_addclose"); + die_errno(posix_spawn_file_actions_addclose(&file_acts, pipefds[1]), + "posix_spawn_file_actions_addclose"); - die_errno(posix_spawnp(&pl->pid, argv[0], &file_acts, NULL, - (char * const *)argv, environ), - "posix_spawnp: %s", argv[0]); + die_errno(posix_spawnp(&pl->pid, argv[0], &file_acts, NULL, + (char * const *)argv, environ), + "posix_spawnp: %s", argv[0]); - die_errno(posix_spawn_file_actions_destroy(&file_acts), - "posix_spawn_file_actions_destroy"); + die_errno(posix_spawn_file_actions_destroy(&file_acts), + "posix_spawn_file_actions_destroy"); - if (close(pipefds[0])) - die_errno(errno, "close"); + if (close(pipefds[0])) { + die_errno(errno, "close"); + } - pl->infd = pipefds[1]; + pl->infd = pipefds[1]; } int finish_pipeline(struct pipeline *pl) { - int status; + int status; - if (close(pl->infd)) - die_errno(errno, "close"); - if (waitpid(pl->pid, &status, 0) < 0) - die_errno(errno, "waitpid"); - return WIFEXITED(status) && WEXITSTATUS(status) == 0; + if (close(pl->infd)) { + die_errno(errno, "close"); + } + if (waitpid(pl->pid, &status, 0) < 0) { + die_errno(errno, "waitpid"); + } + return WIFEXITED(status) && WEXITSTATUS(status) == 0; } |