Move --pipe handling to cliutils helpers

1 files changed, 38 insertions, 0 deletions

diff --git a/cliutils.c b/cliutils.c
index f022803dd..23c632372 100644
--- a/cliutils.c
+++ b/cliutils.c
@@ -2,6 +2,8 @@
 #if HAVE_MCHECK_H
 #include <mcheck.h>
 #endif
+#include <sys/wait.h>
+
 #include <rpm/rpmlog.h>
 #include <rpm/rpmlib.h>
 #include <rpm/rpmfileutil.h>
@@ -10,6 +12,8 @@
 #include "cliutils.h"
 #include "debug.h"
 
+static pid_t pipeChild = 0;
+
 RPM_GNUC_NORETURN
 void argerror(const char * desc)
 {
@@ -110,3 +114,37 @@ int finishCli(poptContext optCon, int rc)
     /* XXX Avoid exit status overflow. Status 255 is special to xargs(1) */
     return (rc > 254) ? 254 : rc;
 }
+
+int initPipe(void)
+{
+    int p[2];
+
+    if (pipe(p) < 0) {
+	fprintf(stderr, _("creating a pipe for --pipe failed: %m\n"));
+	return -1;
+    }
+
+    if (!(pipeChild = fork())) {
+	(void) signal(SIGPIPE, SIG_DFL);
+	(void) close(p[1]);
+	(void) dup2(p[0], STDIN_FILENO);
+	(void) close(p[0]);
+	(void) execl("/bin/sh", "/bin/sh", "-c", rpmcliPipeOutput, NULL);
+	fprintf(stderr, _("exec failed\n"));
+	exit(EXIT_FAILURE);
+    }
+
+    (void) close(p[0]);
+    (void) dup2(p[1], STDOUT_FILENO);
+    (void) close(p[1]);
+    return 0;
+}
+
+void finishPipe(void)
+{
+    int status;
+    if (pipeChild) {
+	(void) fclose(stdout);
+	(void) waitpid(pipeChild, &status, 0);
+    }
+}