diff options
author | Lexxy Fox <lexxyfox@gmail.com> | 2023-09-26 13:30:14 -0500 |
---|---|---|
committer | William Hubbs <w.d.hubbs@gmail.com> | 2023-10-03 16:43:39 -0500 |
commit | cf9286d2d84f7aef237ec0d363c692ef5035aa85 (patch) | |
tree | 7827b9bf3f477c3de0d5f225acc0818d020f0c57 /src/shared/pipes.c | |
parent | 9934e9f96ea91995dfab382bf05b47d43c1ac4f9 (diff) |
Relocate pipes.c and pipes.h file to shared directory.
With the addition of logger process redirect in supervise-daemon,
pipes.c and pipes.h are now included in both s-s-d and supervise-daemon.
Thus it makes sense to move the source files to the src/shared dir.
Diffstat (limited to 'src/shared/pipes.c')
-rw-r--r-- | src/shared/pipes.c | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/src/shared/pipes.c b/src/shared/pipes.c new file mode 100644 index 00000000..5251a4f0 --- /dev/null +++ b/src/shared/pipes.c @@ -0,0 +1,56 @@ +/* + * pipes.c + * Helper to handle spawning processes and connecting them to pipes. + */ + +/* + * Copyright (c) 2018 The OpenRC Authors. + * See the Authors file at the top-level directory of this distribution and + * https://github.com/OpenRC/openrc/blob/HEAD/AUTHORS + * + * This file is part of OpenRC. It is subject to the license terms in + * the LICENSE file found in the top-level directory of this + * distribution and at https://github.com/OpenRC/openrc/blob/HEAD/LICENSE + * This file may not be copied, modified, propagated, or distributed + * except according to the terms contained in the LICENSE file. + */ + +#include <stdlib.h> +#include <sys/types.h> +#include <unistd.h> + +#include "pipes.h" + +static const int pipe_read_end = 0; +static const int pipe_write_end = 1; + +/* + * Starts a command with stdin redirected from a pipe + * Returns the write end of the pipe or -1 + */ +int rc_pipe_command(char *cmd) +{ + int pfd[2]; + pid_t pid; + + if (pipe(pfd) < 0) + return -1; + + pid = fork(); + if (pid > 0) { + /* parent */ + close(pfd[pipe_read_end]); + return pfd[pipe_write_end]; + } else if (pid == 0) { + /* child */ + close(pfd[pipe_write_end]); + if (pfd[pipe_read_end] != STDIN_FILENO) { + if (dup2(pfd[pipe_read_end], STDIN_FILENO) < 0) + exit(1); + close(pfd[pipe_read_end]); + } + execl("/bin/sh", "sh", "-c", cmd, NULL); + exit(1); + } + return -1; +} |