cvs/os2/popen.c

13571821Stholo/* popen.c -- popen/pclose for OS/2. */
13571821Stholo
13571821Stholo/* Set to 0 for distribution.
13571821Stholo   Search for "DIAGNOSTIC" in the code to see what it's for. */
13571821Stholo#define DIAGNOSTIC 0
13571821Stholo
13571821Stholo#include    <process.h>
13571821Stholo
13571821Stholo#include    <stdio.h>
13571821Stholo#include    <stdlib.h>
13571821Stholo#include    <sys/types.h>
13571821Stholo#include    <sys/stat.h>
13571821Stholo#include    <ctype.h>
13571821Stholo#include    <string.h>
13571821Stholo#include    <fcntl.h>
13571821Stholo
*461cc63eStholo#include    "config.h"
*461cc63eStholo#include    "os2inc.h"
*461cc63eStholo
13571821Stholo#define LL_VAL ULONG
13571821Stholo#define LL_KEY PID    /* also ULONG, really */
13571821Stholo
13571821Stholo#define STDIN       0
13571821Stholo#define STDOUT      1
13571821Stholo#define STDERR      2
13571821Stholo
13571821Stholo/* ********************************************************************* *
13571821Stholo *                                                                       *
13571821Stholo *   First, a little linked-list library to help keep track of pipes:    *
13571821Stholo *                                                                       *
13571821Stholo * ********************************************************************* */
13571821Stholo
13571821Stholo/* Map integer PID's onto integer termination codes. */
13571821Stholostruct pid_list
13571821Stholo{
13571821Stholo  HFILE pid;              /* key */
13571821Stholo  ULONG term_code;        /* val */
13571821Stholo  struct pid_list *next;  /* duh */
13571821Stholo};
13571821Stholo
13571821Stholostatic struct pid_list *pid_ll = (struct pid_list *) NULL;
13571821Stholo
13571821Stholo/* The ll_*() functions all make use of the global var `pid_ll'. */
13571821Stholo
13571821Stholovoid
13571821Sthololl_insert (HFILE key, ULONG val)
13571821Stholo{
13571821Stholo  struct pid_list *new;
13571821Stholo  new = (struct pid_list *) malloc (sizeof (*new));
13571821Stholo
13571821Stholo  new->pid       = key;
13571821Stholo  new->term_code = val;
13571821Stholo  new->next      = pid_ll;
13571821Stholo
13571821Stholo  pid_ll = new;
13571821Stholo}
13571821Stholo
13571821Stholo
13571821Stholovoid
13571821Sthololl_delete (int key)
13571821Stholo{
13571821Stholo  struct pid_list *this, *last;
13571821Stholo
13571821Stholo  this = pid_ll;
13571821Stholo  last = (struct pid_list *) NULL;
13571821Stholo
13571821Stholo  while (this)
13571821Stholo    {
13571821Stholo      if (this->pid == key)
13571821Stholo        {
13571821Stholo          /* Delete this node and leave. */
13571821Stholo          if (last)
13571821Stholo            last->next = this->next;
13571821Stholo          else
13571821Stholo            pid_ll = this->next;
13571821Stholo          free (this);
13571821Stholo          return;
13571821Stholo        }
13571821Stholo
13571821Stholo      /* Else no match, so try the next one. */
13571821Stholo      last = this;
13571821Stholo      this = this->next;
13571821Stholo    }
13571821Stholo}
13571821Stholo
13571821StholoULONG
13571821Sthololl_lookup (HFILE key)
13571821Stholo{
13571821Stholo  struct pid_list *this = pid_ll;
13571821Stholo
13571821Stholo  while (this)
13571821Stholo    {
13571821Stholo      if (this->pid == key)
13571821Stholo        return this->term_code;
13571821Stholo
13571821Stholo      /* Else no match, so try the next one. */
13571821Stholo      this = this->next;
13571821Stholo    }
13571821Stholo
13571821Stholo  /* Zero is special in this context anyway. */
13571821Stholo  return 0;
13571821Stholo}
13571821Stholo
13571821Stholo#if DIAGNOSTIC
13571821StholoULONG
13571821Sthololl_length ()
13571821Stholo{
13571821Stholo  struct pid_list *this = pid_ll;
13571821Stholo  unsigned long int len;
13571821Stholo
13571821Stholo  for (len = 0; this; len++)
13571821Stholo    this = this->next;
13571821Stholo
13571821Stholo  return len;
13571821Stholo}
13571821Stholo
13571821StholoULONG
13571821Sthololl_print ()
13571821Stholo{
13571821Stholo  struct pid_list *this = pid_ll;
13571821Stholo  unsigned long int i;
13571821Stholo
13571821Stholo  for (i = 0; this; i++)
13571821Stholo    {
13571821Stholo      printf ("pid_ll[%d] == (%5d --> %5d)\n",
13571821Stholo			  i, this->pid, this->term_code);
13571821Stholo      this = this->next;
13571821Stholo    }
13571821Stholo
13571821Stholo  if (i == 0)
13571821Stholo    printf ("No entries.\n");
13571821Stholo
13571821Stholo  return i;
13571821Stholo}
13571821Stholo#endif /* DIAGNOSTIC */
13571821Stholo
13571821Stholo/* ********************************************************************* *
13571821Stholo *                                                                       *
13571821Stholo *       End of linked-list library, beginning of popen/pclose:          *
13571821Stholo *                                                                       *
13571821Stholo * ********************************************************************* */
13571821Stholo
13571821Stholo/*
13571821Stholo *  Routine: popen
13571821Stholo *  Returns: FILE pointer to pipe.
13571821Stholo *  Action : Exec program connected via pipe, connect a FILE * to the
13571821Stholo *           pipe and return it.
13571821Stholo *  Params : Command - Program to run
13571821Stholo *           Mode    - Mode to open pipe.  "r" implies pipe is connected
13571821Stholo *                     to the programs stdout, "w" connects to stdin.
13571821Stholo */
13571821StholoFILE *
13571821Stholopopen (const char *Command, const char *Mode)
13571821Stholo{
13571821Stholo    HFILE End1, End2, Std, Old1, Old2, Tmp;
13571821Stholo
13571821Stholo    FILE *File;
13571821Stholo
13571821Stholo    char    Fail[256],
13571821Stholo            *Args,
13571821Stholo            CmdLine[256],
13571821Stholo            *CmdExe;
13571821Stholo
13571821Stholo    RESULTCODES
13571821Stholo            Result;
13571821Stholo
13571821Stholo    int     Rc;
13571821Stholo
13571821Stholo    if (DosCreatePipe (&End1, &End2, 4096))
13571821Stholo        return NULL;
13571821Stholo
13571821Stholo    Std = (*Mode == 'w') ? STDIN : STDOUT ;
13571821Stholo    if (Std == STDIN)
13571821Stholo    {
13571821Stholo        Tmp = End1; End1 = End2; End2 = Tmp;
13571821Stholo    }
13571821Stholo
13571821Stholo    Old1 = -1; /* save stdin or stdout */
13571821Stholo    DosDupHandle (Std, &Old1);
13571821Stholo    DosSetFHState (Old1, OPEN_FLAGS_NOINHERIT);
13571821Stholo    Tmp = Std; /* redirect stdin or stdout */
13571821Stholo    DosDupHandle (End2, &Tmp);
13571821Stholo
13571821Stholo    if (Std == 1)
13571821Stholo    {
13571821Stholo        Old2 = -1; /* save stderr */
13571821Stholo        DosDupHandle (STDERR, &Old2);
13571821Stholo        DosSetFHState (Old2, OPEN_FLAGS_NOINHERIT);
13571821Stholo        Tmp = STDERR;
13571821Stholo        DosDupHandle (End2, &Tmp);
13571821Stholo    }
13571821Stholo
13571821Stholo    DosClose (End2);
13571821Stholo    DosSetFHState (End1, OPEN_FLAGS_NOINHERIT);
13571821Stholo
13571821Stholo    if ((CmdExe = getenv ("COMSPEC")) == NULL )
13571821Stholo        CmdExe = "cmd.exe";
13571821Stholo
13571821Stholo    strcpy (CmdLine, CmdExe);
13571821Stholo    Args = CmdLine + strlen (CmdLine) + 1; /* skip zero */
13571821Stholo    strcpy (Args, "/c ");
13571821Stholo    strcat (Args, Command);
13571821Stholo    Args[strlen (Args) + 1] = '\0'; /* two zeroes */
13571821Stholo    Rc = DosExecPgm (Fail, sizeof (Fail), EXEC_ASYNCRESULT,
13571821Stholo                     (unsigned char *) CmdLine, 0, &Result,
13571821Stholo                     (unsigned char *) CmdExe);
13571821Stholo
13571821Stholo    Tmp = Std; /* restore stdin or stdout */
13571821Stholo    DosDupHandle (Old1, &Tmp);
13571821Stholo    DosClose (Old1);
13571821Stholo
13571821Stholo    if (Std == STDOUT)
13571821Stholo    {
13571821Stholo        Tmp = STDERR;   /* restore stderr */
13571821Stholo        DosDupHandle (Old2, &Tmp);
13571821Stholo        DosClose (Old2);
13571821Stholo    }
13571821Stholo
13571821Stholo    if (Rc)
13571821Stholo    {
13571821Stholo        DosClose (End1);
13571821Stholo        return NULL;
13571821Stholo    }
13571821Stholo
*461cc63eStholo#ifdef __WATCOMC__
*461cc63eStholo    /* Watcom does not allow mixing operating system handles and
*461cc63eStholo     * C library handles, so we have to convert.
*461cc63eStholo     */
*461cc63eStholo    File = fdopen (_hdopen (End1, *Mode == 'w'? O_WRONLY : O_RDONLY), Mode);
*461cc63eStholo#else
13571821Stholo    File = fdopen (End1, Mode);
*461cc63eStholo#endif
13571821Stholo    ll_insert ((LL_KEY) End1, (LL_VAL) Result.codeTerminate);
13571821Stholo
13571821Stholo    return File;
13571821Stholo}
13571821Stholo
13571821Stholo
13571821Stholo/*
13571821Stholo *  Routine: popenRW
13571821Stholo *  Returns: PID of child process
13571821Stholo *  Action : Exec program connected via pipe, connect int fd's to
13571821Stholo *           both the stdin and stdout of the process.
13571821Stholo *  Params : Command - Program to run
13571821Stholo *           Pipes   - Array of 2 ints to store the pipe descriptors
13571821Stholo *                     Pipe[0] writes to child's stdin,
13571821Stholo *                     Pipe[1] reads from child's stdout/stderr
13571821Stholo */
13571821Stholoint
13571821StholopopenRW (const char **argv, int *pipes)
13571821Stholo{
13571821Stholo    HFILE Out1, Out2, In1, In2;
13571821Stholo    HFILE Old0 = -1, Old1 = -1, Old2 = -1, Tmp;
13571821Stholo
*461cc63eStholo    int pid;
13571821Stholo
13571821Stholo    if (DosCreatePipe (&Out2, &Out1, 4096))
13571821Stholo        return FALSE;
13571821Stholo
13571821Stholo    if (DosCreatePipe (&In1, &In2, 4096))
13571821Stholo    {
13571821Stholo        DosClose (Out1);
13571821Stholo        DosClose (Out2);
13571821Stholo        return FALSE;
13571821Stholo    }
13571821Stholo
13571821Stholo    /* Save std{in,out,err} */
13571821Stholo    DosDupHandle (STDIN, &Old0);
13571821Stholo    DosSetFHState (Old1, OPEN_FLAGS_NOINHERIT);
13571821Stholo    DosDupHandle (STDOUT, &Old1);
13571821Stholo    DosSetFHState (Old2, OPEN_FLAGS_NOINHERIT);
13571821Stholo    DosDupHandle (STDERR, &Old2);
13571821Stholo    DosSetFHState (Old2, OPEN_FLAGS_NOINHERIT);
13571821Stholo
13571821Stholo    /* Redirect std{in,out,err} */
13571821Stholo    Tmp = STDIN;
13571821Stholo    DosDupHandle (In1, &Tmp);
13571821Stholo    Tmp = STDOUT;
13571821Stholo    DosDupHandle (Out1, &Tmp);
13571821Stholo    Tmp = STDERR;
13571821Stholo    DosDupHandle (Out1, &Tmp);
13571821Stholo
13571821Stholo    /* Close file handles not needed in child */
13571821Stholo
13571821Stholo    DosClose (In1);
13571821Stholo    DosClose (Out1);
13571821Stholo    DosSetFHState (In2, OPEN_FLAGS_NOINHERIT);
13571821Stholo    DosSetFHState (Out2, OPEN_FLAGS_NOINHERIT);
13571821Stholo
13571821Stholo    /* Spawn we now our hoary brood. */
13571821Stholo    pid = spawnvp (P_NOWAIT, argv[0], argv);
13571821Stholo
13571821Stholo    /* Restore std{in,out,err} */
13571821Stholo    Tmp = STDIN;
13571821Stholo    DosDupHandle (Old0, &Tmp);
13571821Stholo    DosClose (Old0);
13571821Stholo    Tmp = STDOUT;
13571821Stholo    DosDupHandle (Old1, &Tmp);
13571821Stholo    DosClose (Old1);
13571821Stholo    Tmp = STDERR;
13571821Stholo    DosDupHandle (Old2, &Tmp);
13571821Stholo    DosClose (Old2);
13571821Stholo
13571821Stholo    if(pid < 0)
13571821Stholo      {
13571821Stholo        DosClose (In2);
13571821Stholo        DosClose (Out2);
13571821Stholo        return -1;
13571821Stholo      }
13571821Stholo
13571821Stholo    pipes[0] = In2;
13571821Stholo    _setmode (pipes[0], O_BINARY);
13571821Stholo    pipes[1] = Out2;
13571821Stholo    _setmode (pipes[1], O_BINARY);
13571821Stholo
13571821Stholo    /* Save ID of write-to-child pipe for pclose() */
13571821Stholo    ll_insert ((LL_KEY) In2, (LL_VAL) pid);
13571821Stholo
13571821Stholo    return pid;
13571821Stholo}
13571821Stholo
13571821Stholo
13571821Stholo/*
13571821Stholo *  Routine: pclose
13571821Stholo *  Returns: TRUE on success
13571821Stholo *  Action : Close a pipe opened with popen();
13571821Stholo *  Params : Pipe - pipe to close
13571821Stholo */
13571821Stholoint
13571821Stholopclose (FILE *Pipe)
13571821Stholo{
13571821Stholo    RESULTCODES rc;
13571821Stholo    PID pid, pid1;
13571821Stholo    int Handle = fileno (Pipe);
13571821Stholo
13571821Stholo    fclose (Pipe);
13571821Stholo
13571821Stholo    rc.codeTerminate = -1;
13571821Stholo
13571821Stholo    pid1 = (PID) ll_lookup ((LL_KEY) Handle);
13571821Stholo    /* if pid1 is zero, something's seriously wrong */
13571821Stholo    if (pid1 != 0)
13571821Stholo      {
13571821Stholo        DosWaitChild (DCWA_PROCESSTREE, DCWW_WAIT, &rc, &pid, pid1);
13571821Stholo        ll_delete ((LL_KEY) Handle);
13571821Stholo      }
13571821Stholo    return rc.codeTerminate == 0 ? rc.codeResult : -1;
13571821Stholo}
13571821Stholo
13571821Stholo
13571821Stholo#if DIAGNOSTIC
13571821Stholovoid
13571821Stholomain ()
13571821Stholo{
13571821Stholo  FILE *fp1, *fp2, *fp3;
13571821Stholo  int c;
13571821Stholo
13571821Stholo  ll_print ();
13571821Stholo  fp1 = popen ("gcc --version", "r");
13571821Stholo  ll_print ();
13571821Stholo  fp2 = popen ("link386 /?", "r");
13571821Stholo  ll_print ();
13571821Stholo  fp3 = popen ("dir", "r");
13571821Stholo  ll_print ();
13571821Stholo
13571821Stholo  while ((c = getc (fp1)) != EOF)
13571821Stholo    printf ("%c", c);
13571821Stholo
13571821Stholo  while ((c = getc (fp2)) != EOF)
13571821Stholo    printf ("%c", c);
13571821Stholo
13571821Stholo  while ((c = getc (fp3)) != EOF)
13571821Stholo    printf ("%c", c);
13571821Stholo
13571821Stholo  pclose (fp1);
13571821Stholo  ll_print ();
13571821Stholo  pclose (fp2);
13571821Stholo  ll_print ();
13571821Stholo  pclose (fp3);
13571821Stholo  ll_print ();
13571821Stholo
13571821Stholo  return;
13571821Stholo}
13571821Stholo
13571821Stholo#endif /* DIAGNOSTIC */