summaryrefslogtreecommitdiff
path: root/tools/unix/process.c
diff options
context:
space:
mode:
Diffstat (limited to 'tools/unix/process.c')
-rw-r--r--tools/unix/process.c56
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;
}