You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
106 lines
2.3 KiB
106 lines
2.3 KiB
/*
|
|
* Revision Control Information
|
|
*
|
|
* $Source: /home/staff/fabio/src/util/RCS/pipefork.c,v $
|
|
* $Author: fabio $
|
|
* $Revision: 1.5 $
|
|
* $Date: 2003/12/30 16:59:31 $
|
|
*
|
|
*/
|
|
/* LINTLIBRARY */
|
|
|
|
#ifndef HAVE_SYS_WAIT_H
|
|
#define HAVE_SYS_WAIT_H 1
|
|
#endif
|
|
|
|
#if HAVE_SYS_WAIT_H == 1
|
|
#include <sys/wait.h>
|
|
#endif
|
|
#include "util.h"
|
|
|
|
/*
|
|
* util_pipefork - fork a command and set up pipes to and from
|
|
*
|
|
* Rick L Spickelmier, 3/23/86
|
|
* Richard Rudell, 4/6/86
|
|
* Rick L Spickelmier, 4/30/90, got rid of slimey vfork semantics
|
|
*
|
|
* Returns:
|
|
* 1 for success, with toCommand and fromCommand pointing to the streams
|
|
* 0 for failure
|
|
*/
|
|
|
|
/* ARGSUSED */
|
|
int
|
|
util_pipefork(
|
|
char **argv, /* normal argv argument list */
|
|
FILE **toCommand, /* pointer to the sending stream */
|
|
FILE **fromCommand, /* pointer to the reading stream */
|
|
int *pid)
|
|
{
|
|
#ifdef UNIX
|
|
int forkpid, waitPid;
|
|
int topipe[2], frompipe[2];
|
|
char buffer[1024];
|
|
#if (defined __hpux) || (defined __osf__) || (defined _IBMR2) || (defined __SVR4) || (defined __CYGWIN32__)
|
|
int status;
|
|
#else
|
|
union wait status;
|
|
#endif
|
|
|
|
/* create the PIPES...
|
|
* fildes[0] for reading from command
|
|
* fildes[1] for writing to command
|
|
*/
|
|
(void) pipe(topipe);
|
|
(void) pipe(frompipe);
|
|
|
|
#ifdef __CYGWIN32__
|
|
if ((forkpid = fork()) == 0) {
|
|
#else
|
|
if ((forkpid = vfork()) == 0) {
|
|
#endif
|
|
/* child here, connect the pipes */
|
|
(void) dup2(topipe[0], fileno(stdin));
|
|
(void) dup2(frompipe[1], fileno(stdout));
|
|
|
|
(void) close(topipe[0]);
|
|
(void) close(topipe[1]);
|
|
(void) close(frompipe[0]);
|
|
(void) close(frompipe[1]);
|
|
|
|
(void) execvp(argv[0], argv);
|
|
(void) sprintf(buffer, "util_pipefork: can not exec %s", argv[0]);
|
|
perror(buffer);
|
|
(void) _exit(1);
|
|
}
|
|
|
|
if (pid) {
|
|
*pid = forkpid;
|
|
}
|
|
|
|
#ifdef __CYGWIN32__
|
|
waitPid = waitpid(-1, &status, WNOHANG);
|
|
#else
|
|
waitPid = wait3(&status, WNOHANG, NULL);
|
|
#endif
|
|
|
|
/* parent here, use slimey vfork() semantics to get return status */
|
|
if (waitPid == forkpid && WIFEXITED(status)) {
|
|
return 0;
|
|
}
|
|
if ((*toCommand = fdopen(topipe[1], "w")) == NULL) {
|
|
return 0;
|
|
}
|
|
if ((*fromCommand = fdopen(frompipe[0], "r")) == NULL) {
|
|
return 0;
|
|
}
|
|
(void) close(topipe[0]);
|
|
(void) close(frompipe[1]);
|
|
return 1;
|
|
#else
|
|
(void) fprintf(stderr,
|
|
"util_pipefork: not implemented on your operating system\n");
|
|
return 0;
|
|
#endif
|
|
}
|