Logo Search packages:      
Sourcecode: qemu version File versions

misc.c

/*
 * Copyright (c) 1995 Danny Gasparovski.
 *
 * Please read the file COPYRIGHT for the
 * terms and conditions of the copyright.
 */

#define WANT_SYS_IOCTL_H
#include <slirp.h>

u_int curtime, time_fasttimo, last_slowtimo;

#if 0
int x_port = -1;
int x_display = 0;
int x_screen = 0;

int
show_x(buff, inso)
      char *buff;
      struct socket *inso;
{
      if (x_port < 0) {
            lprint("X Redir: X not being redirected.\r\n");
      } else {
            lprint("X Redir: In sh/bash/zsh/etc. type: DISPLAY=%s:%d.%d; export DISPLAY\r\n",
                  inet_ntoa(our_addr), x_port, x_screen);
            lprint("X Redir: In csh/tcsh/etc. type:    setenv DISPLAY %s:%d.%d\r\n",
                  inet_ntoa(our_addr), x_port, x_screen);
            if (x_display)
               lprint("X Redir: Redirecting to display %d\r\n", x_display);
      }

      return CFG_OK;
}


/*
 * XXX Allow more than one X redirection?
 */
void
redir_x(inaddr, start_port, display, screen)
      u_int32_t inaddr;
      int start_port;
      int display;
      int screen;
{
      int i;

      if (x_port >= 0) {
            lprint("X Redir: X already being redirected.\r\n");
            show_x(0, 0);
      } else {
            for (i = 6001 + (start_port-1); i <= 6100; i++) {
                  if (solisten(htons(i), inaddr, htons(6000 + display), 0)) {
                        /* Success */
                        x_port = i - 6000;
                        x_display = display;
                        x_screen = screen;
                        show_x(0, 0);
                        return;
                  }
            }
            lprint("X Redir: Error: Couldn't redirect a port for X. Weird.\r\n");
      }
}
#endif

/*
 * Get our IP address and put it in our_addr
 */
void
getouraddr()
{
      char buff[256];
      struct hostent *he = NULL;

      if (gethostname(buff,256) == 0)
            he = gethostbyname(buff);
        if (he)
            our_addr = *(struct in_addr *)he->h_addr;
        if (our_addr.s_addr == 0)
            our_addr.s_addr = loopback_addr.s_addr;
}

#if SIZEOF_CHAR_P == 8

struct quehead_32 {
      u_int32_t qh_link;
      u_int32_t qh_rlink;
};

inline void
insque_32(a, b)
      void *a;
      void *b;
{
      register struct quehead_32 *element = (struct quehead_32 *) a;
      register struct quehead_32 *head = (struct quehead_32 *) b;
      element->qh_link = head->qh_link;
      head->qh_link = (u_int32_t)element;
      element->qh_rlink = (u_int32_t)head;
      ((struct quehead_32 *)(element->qh_link))->qh_rlink
      = (u_int32_t)element;
}

inline void
remque_32(a)
      void *a;
{
      register struct quehead_32 *element = (struct quehead_32 *) a;
      ((struct quehead_32 *)(element->qh_link))->qh_rlink = element->qh_rlink;
      ((struct quehead_32 *)(element->qh_rlink))->qh_link = element->qh_link;
      element->qh_rlink = 0;
}

#endif /* SIZEOF_CHAR_P == 8 */

struct quehead {
      struct quehead *qh_link;
      struct quehead *qh_rlink;
};

inline void
insque(a, b)
      void *a, *b;
{
      register struct quehead *element = (struct quehead *) a;
      register struct quehead *head = (struct quehead *) b;
      element->qh_link = head->qh_link;
      head->qh_link = (struct quehead *)element;
      element->qh_rlink = (struct quehead *)head;
      ((struct quehead *)(element->qh_link))->qh_rlink
      = (struct quehead *)element;
}

inline void
remque(a)
     void *a;
{
  register struct quehead *element = (struct quehead *) a;
  ((struct quehead *)(element->qh_link))->qh_rlink = element->qh_rlink;
  ((struct quehead *)(element->qh_rlink))->qh_link = element->qh_link;
  element->qh_rlink = NULL;
  /*  element->qh_link = NULL;  TCP FIN1 crashes if you do this.  Why ? */
}

/* #endif */


int
add_exec(ex_ptr, do_pty, exec, addr, port)
      struct ex_list **ex_ptr;
      int do_pty;
      char *exec;
      int addr;
      int port;
{
      struct ex_list *tmp_ptr;

      /* First, check if the port is "bound" */
      for (tmp_ptr = *ex_ptr; tmp_ptr; tmp_ptr = tmp_ptr->ex_next) {
            if (port == tmp_ptr->ex_fport && addr == tmp_ptr->ex_addr)
               return -1;
      }

      tmp_ptr = *ex_ptr;
      *ex_ptr = (struct ex_list *)malloc(sizeof(struct ex_list));
      (*ex_ptr)->ex_fport = port;
      (*ex_ptr)->ex_addr = addr;
      (*ex_ptr)->ex_pty = do_pty;
      (*ex_ptr)->ex_exec = strdup(exec);
      (*ex_ptr)->ex_next = tmp_ptr;
      return 0;
}

#ifndef HAVE_STRERROR

/*
 * For systems with no strerror
 */

extern int sys_nerr;
extern char *sys_errlist[];

char *
strerror(error)
      int error;
{
      if (error < sys_nerr)
         return sys_errlist[error];
      else
         return "Unknown error.";
}

#endif


#ifdef _WIN32

int
fork_exec(struct socket *so, const char *ex, int do_pty)
{
    /* not implemented */
    return 0;
}

#else

#ifndef CONFIG_QEMU
int
slirp_openpty(amaster, aslave)
     int *amaster, *aslave;
{
      register int master, slave;

#ifdef HAVE_GRANTPT
      char *ptr;

      if ((master = open("/dev/ptmx", O_RDWR)) < 0 ||
          grantpt(master) < 0 ||
          unlockpt(master) < 0 ||
          (ptr = ptsname(master)) == NULL)  {
            close(master);
            return -1;
      }

      if ((slave = open(ptr, O_RDWR)) < 0 ||
          ioctl(slave, I_PUSH, "ptem") < 0 ||
          ioctl(slave, I_PUSH, "ldterm") < 0 ||
          ioctl(slave, I_PUSH, "ttcompat") < 0) {
            close(master);
            close(slave);
            return -1;
      }

      *amaster = master;
      *aslave = slave;
      return 0;

#else

      static char line[] = "/dev/ptyXX";
      register const char *cp1, *cp2;

      for (cp1 = "pqrsPQRS"; *cp1; cp1++) {
            line[8] = *cp1;
            for (cp2 = "0123456789abcdefghijklmnopqrstuv"; *cp2; cp2++) {
                  line[9] = *cp2;
                  if ((master = open(line, O_RDWR, 0)) == -1) {
                        if (errno == ENOENT)
                           return (-1);    /* out of ptys */
                  } else {
                        line[5] = 't';
                        /* These will fail */
                        (void) chown(line, getuid(), 0);
                        (void) chmod(line, S_IRUSR|S_IWUSR|S_IWGRP);
#ifdef HAVE_REVOKE
                        (void) revoke(line);
#endif
                        if ((slave = open(line, O_RDWR, 0)) != -1) {
                              *amaster = master;
                              *aslave = slave;
                              return 0;
                        }
                        (void) close(master);
                        line[5] = 'p';
                  }
            }
      }
      errno = ENOENT; /* out of ptys */
      return (-1);
#endif
}
#endif

/*
 * XXX This is ugly
 * We create and bind a socket, then fork off to another
 * process, which connects to this socket, after which we
 * exec the wanted program.  If something (strange) happens,
 * the accept() call could block us forever.
 *
 * do_pty = 0   Fork/exec inetd style
 * do_pty = 1   Fork/exec using slirp.telnetd
 * do_ptr = 2   Fork/exec using pty
 */
int
fork_exec(struct socket *so, const char *ex, int do_pty)
{
      int s;
      struct sockaddr_in addr;
      socklen_t addrlen = sizeof(addr);
      int opt;
        int master = -1;
      const char *argv[256];
#if 0
      char buff[256];
#endif
      /* don't want to clobber the original */
      char *bptr;
      const char *curarg;
      int c, i, ret;

      DEBUG_CALL("fork_exec");
      DEBUG_ARG("so = %lx", (long)so);
      DEBUG_ARG("ex = %lx", (long)ex);
      DEBUG_ARG("do_pty = %lx", (long)do_pty);

      if (do_pty == 2) {
#if 0
            if (slirp_openpty(&master, &s) == -1) {
                  lprint("Error: openpty failed: %s\n", strerror(errno));
                  return 0;
            }
#else
                return 0;
#endif
      } else {
            addr.sin_family = AF_INET;
            addr.sin_port = 0;
            addr.sin_addr.s_addr = INADDR_ANY;

            if ((s = socket(AF_INET, SOCK_STREAM, 0)) < 0 ||
                bind(s, (struct sockaddr *)&addr, addrlen) < 0 ||
                listen(s, 1) < 0) {
                  lprint("Error: inet socket: %s\n", strerror(errno));
                  closesocket(s);

                  return 0;
            }
      }

      switch(fork()) {
       case -1:
            lprint("Error: fork failed: %s\n", strerror(errno));
            close(s);
            if (do_pty == 2)
               close(master);
            return 0;

       case 0:
            /* Set the DISPLAY */
            if (do_pty == 2) {
                  (void) close(master);
#ifdef TIOCSCTTY /* XXXXX */
                  (void) setsid();
                  ioctl(s, TIOCSCTTY, (char *)NULL);
#endif
            } else {
                  getsockname(s, (struct sockaddr *)&addr, &addrlen);
                  close(s);
                  /*
                   * Connect to the socket
                   * XXX If any of these fail, we're in trouble!
                   */
                  s = socket(AF_INET, SOCK_STREAM, 0);
                  addr.sin_addr = loopback_addr;
                        do {
                            ret = connect(s, (struct sockaddr *)&addr, addrlen);
                        } while (ret < 0 && errno == EINTR);
            }

#if 0
            if (x_port >= 0) {
#ifdef HAVE_SETENV
                  sprintf(buff, "%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
                  setenv("DISPLAY", buff, 1);
#else
                  sprintf(buff, "DISPLAY=%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
                  putenv(buff);
#endif
            }
#endif
            dup2(s, 0);
            dup2(s, 1);
            dup2(s, 2);
            for (s = getdtablesize() - 1; s >= 3; s--)
               close(s);

            i = 0;
            bptr = strdup(ex); /* No need to free() this */
            if (do_pty == 1) {
                  /* Setup "slirp.telnetd -x" */
                  argv[i++] = "slirp.telnetd";
                  argv[i++] = "-x";
                  argv[i++] = bptr;
            } else
               do {
                  /* Change the string into argv[] */
                  curarg = bptr;
                  while (*bptr != ' ' && *bptr != (char)0)
                     bptr++;
                  c = *bptr;
                  *bptr++ = (char)0;
                  argv[i++] = strdup(curarg);
               } while (c);

            argv[i] = 0;
            execvp(argv[0], (char **)argv);

            /* Ooops, failed, let's tell the user why */
              {
                    char buff[256];

                    snprintf(buff, sizeof(buff),
                                   "Error: execvp of %s failed: %s\n",
                                   argv[0], strerror(errno));
                    write(2, buff, strlen(buff)+1);
              }
            close(0); close(1); close(2); /* XXX */
            exit(1);

       default:
            if (do_pty == 2) {
                  close(s);
                  so->s = master;
            } else {
                  /*
                   * XXX this could block us...
                   * XXX Should set a timer here, and if accept() doesn't
                   * return after X seconds, declare it a failure
                   * The only reason this will block forever is if socket()
                   * of connect() fail in the child process
                   */
                        do {
                            so->s = accept(s, (struct sockaddr *)&addr, &addrlen);
                        } while (so->s < 0 && errno == EINTR);
                        closesocket(s);
                  opt = 1;
                  setsockopt(so->s,SOL_SOCKET,SO_REUSEADDR,(char *)&opt,sizeof(int));
                  opt = 1;
                  setsockopt(so->s,SOL_SOCKET,SO_OOBINLINE,(char *)&opt,sizeof(int));
            }
            fd_nonblock(so->s);

            /* Append the telnet options now */
            if (so->so_m != 0 && do_pty == 1)  {
                  sbappend(so, so->so_m);
                  so->so_m = 0;
            }

            return 1;
      }
}
#endif

#ifndef HAVE_STRDUP
char *
strdup(str)
      const char *str;
{
      char *bptr;

      bptr = (char *)malloc(strlen(str)+1);
      strcpy(bptr, str);

      return bptr;
}
#endif

#if 0
void
snooze_hup(num)
      int num;
{
      int s, ret;
#ifndef NO_UNIX_SOCKETS
      struct sockaddr_un sock_un;
#endif
      struct sockaddr_in sock_in;
      char buff[256];

      ret = -1;
      if (slirp_socket_passwd) {
            s = socket(AF_INET, SOCK_STREAM, 0);
            if (s < 0)
               slirp_exit(1);
            sock_in.sin_family = AF_INET;
            sock_in.sin_addr.s_addr = slirp_socket_addr;
            sock_in.sin_port = htons(slirp_socket_port);
            if (connect(s, (struct sockaddr *)&sock_in, sizeof(sock_in)) != 0)
               slirp_exit(1); /* just exit...*/
            sprintf(buff, "kill %s:%d", slirp_socket_passwd, slirp_socket_unit);
            write(s, buff, strlen(buff)+1);
      }
#ifndef NO_UNIX_SOCKETS
        else {
            s = socket(AF_UNIX, SOCK_STREAM, 0);
            if (s < 0)
               slirp_exit(1);
            sock_un.sun_family = AF_UNIX;
            strcpy(sock_un.sun_path, socket_path);
            if (connect(s, (struct sockaddr *)&sock_un,
                        sizeof(sock_un.sun_family) + sizeof(sock_un.sun_path)) != 0)
               slirp_exit(1);
            sprintf(buff, "kill none:%d", slirp_socket_unit);
            write(s, buff, strlen(buff)+1);
      }
#endif
      slirp_exit(0);
}


void
snooze()
{
      sigset_t s;
      int i;

      /* Don't need our data anymore */
      /* XXX This makes SunOS barf */
/*    brk(0); */

      /* Close all fd's */
      for (i = 255; i >= 0; i--)
         close(i);

      signal(SIGQUIT, slirp_exit);
      signal(SIGHUP, snooze_hup);
      sigemptyset(&s);

      /* Wait for any signal */
      sigsuspend(&s);

      /* Just in case ... */
      exit(255);
}

void
relay(s)
      int s;
{
      char buf[8192];
      int n;
      fd_set readfds;
      struct ttys *ttyp;

      /* Don't need our data anymore */
      /* XXX This makes SunOS barf */
/*    brk(0); */

      signal(SIGQUIT, slirp_exit);
      signal(SIGHUP, slirp_exit);
        signal(SIGINT, slirp_exit);
      signal(SIGTERM, slirp_exit);

      /* Fudge to get term_raw and term_restore to work */
      if (NULL == (ttyp = tty_attach (0, slirp_tty))) {
         lprint ("Error: tty_attach failed in misc.c:relay()\r\n");
         slirp_exit (1);
    }
      ttyp->fd = 0;
      ttyp->flags |= TTY_CTTY;
      term_raw(ttyp);

      while (1) {
            FD_ZERO(&readfds);

            FD_SET(0, &readfds);
            FD_SET(s, &readfds);

            n = select(s+1, &readfds, (fd_set *)0, (fd_set *)0, (struct timeval *)0);

            if (n <= 0)
               slirp_exit(0);

            if (FD_ISSET(0, &readfds)) {
                  n = read(0, buf, 8192);
                  if (n <= 0)
                     slirp_exit(0);
                  n = writen(s, buf, n);
                  if (n <= 0)
                     slirp_exit(0);
            }

            if (FD_ISSET(s, &readfds)) {
                  n = read(s, buf, 8192);
                  if (n <= 0)
                     slirp_exit(0);
                  n = writen(0, buf, n);
                  if (n <= 0)
                     slirp_exit(0);
            }
      }

      /* Just in case.... */
      exit(1);
}
#endif

#ifdef CONFIG_QEMU
extern void term_vprintf(const char *fmt, va_list ap);

void lprint(const char *format, ...)
{
    va_list args;

    va_start(args, format);
    term_vprintf(format, args);
    va_end(args);
}
#else
int (*lprint_print) _P((void *, const char *, va_list));
char *lprint_ptr, *lprint_ptr2, **lprint_arg;

void
#ifdef __STDC__
lprint(const char *format, ...)
#else
lprint(va_alist) va_dcl
#endif
{
      va_list args;

#ifdef __STDC__
        va_start(args, format);
#else
        char *format;
        va_start(args);
        format = va_arg(args, char *);
#endif
#if 0
      /* If we're printing to an sbuf, make sure there's enough room */
      /* XXX +100? */
      if (lprint_sb) {
            if ((lprint_ptr - lprint_sb->sb_wptr) >=
                (lprint_sb->sb_datalen - (strlen(format) + 100))) {
                  int deltaw = lprint_sb->sb_wptr - lprint_sb->sb_data;
                  int deltar = lprint_sb->sb_rptr - lprint_sb->sb_data;
                  int deltap = lprint_ptr -         lprint_sb->sb_data;

                  lprint_sb->sb_data = (char *)realloc(lprint_sb->sb_data,
                                               lprint_sb->sb_datalen + TCP_SNDSPACE);

                  /* Adjust all values */
                  lprint_sb->sb_wptr = lprint_sb->sb_data + deltaw;
                  lprint_sb->sb_rptr = lprint_sb->sb_data + deltar;
                  lprint_ptr =         lprint_sb->sb_data + deltap;

                  lprint_sb->sb_datalen += TCP_SNDSPACE;
            }
      }
#endif
      if (lprint_print)
         lprint_ptr += (*lprint_print)(*lprint_arg, format, args);

      /* Check if they want output to be logged to file as well */
      if (lfd) {
            /*
             * Remove \r's
             * otherwise you'll get ^M all over the file
             */
            int len = strlen(format);
            char *bptr1, *bptr2;

            bptr1 = bptr2 = strdup(format);

            while (len--) {
                  if (*bptr1 == '\r')
                     memcpy(bptr1, bptr1+1, len+1);
                  else
                     bptr1++;
            }
            vfprintf(lfd, bptr2, args);
            free(bptr2);
      }
      va_end(args);
}

void
add_emu(buff)
      char *buff;
{
      u_int lport, fport;
      u_int8_t tos = 0, emu = 0;
      char buff1[256], buff2[256], buff4[128];
      char *buff3 = buff4;
      struct emu_t *emup;
      struct socket *so;

      if (sscanf(buff, "%256s %256s", buff2, buff1) != 2) {
            lprint("Error: Bad arguments\r\n");
            return;
      }

      if (sscanf(buff1, "%d:%d", &lport, &fport) != 2) {
            lport = 0;
            if (sscanf(buff1, "%d", &fport) != 1) {
                  lprint("Error: Bad first argument\r\n");
                  return;
            }
      }

      if (sscanf(buff2, "%128[^:]:%128s", buff1, buff3) != 2) {
            buff3 = 0;
            if (sscanf(buff2, "%256s", buff1) != 1) {
                  lprint("Error: Bad second argument\r\n");
                  return;
            }
      }

      if (buff3) {
            if (strcmp(buff3, "lowdelay") == 0)
               tos = IPTOS_LOWDELAY;
            else if (strcmp(buff3, "throughput") == 0)
               tos = IPTOS_THROUGHPUT;
            else {
                  lprint("Error: Expecting \"lowdelay\"/\"throughput\"\r\n");
                  return;
            }
      }

      if (strcmp(buff1, "ftp") == 0)
         emu = EMU_FTP;
      else if (strcmp(buff1, "irc") == 0)
         emu = EMU_IRC;
      else if (strcmp(buff1, "none") == 0)
         emu = EMU_NONE; /* ie: no emulation */
      else {
            lprint("Error: Unknown service\r\n");
            return;
      }

      /* First, check that it isn't already emulated */
      for (emup = tcpemu; emup; emup = emup->next) {
            if (emup->lport == lport && emup->fport == fport) {
                  lprint("Error: port already emulated\r\n");
                  return;
            }
      }

      /* link it */
      emup = (struct emu_t *)malloc(sizeof (struct emu_t));
      emup->lport = (u_int16_t)lport;
      emup->fport = (u_int16_t)fport;
      emup->tos = tos;
      emup->emu = emu;
      emup->next = tcpemu;
      tcpemu = emup;

      /* And finally, mark all current sessions, if any, as being emulated */
      for (so = tcb.so_next; so != &tcb; so = so->so_next) {
            if ((lport && lport == ntohs(so->so_lport)) ||
                (fport && fport == ntohs(so->so_fport))) {
                  if (emu)
                     so->so_emu = emu;
                  if (tos)
                     so->so_iptos = tos;
            }
      }

      lprint("Adding emulation for %s to port %d/%d\r\n", buff1, emup->lport, emup->fport);
}
#endif

#ifdef BAD_SPRINTF

#undef vsprintf
#undef sprintf

/*
 * Some BSD-derived systems have a sprintf which returns char *
 */

int
vsprintf_len(string, format, args)
      char *string;
      const char *format;
      va_list args;
{
      vsprintf(string, format, args);
      return strlen(string);
}

int
#ifdef __STDC__
sprintf_len(char *string, const char *format, ...)
#else
sprintf_len(va_alist) va_dcl
#endif
{
      va_list args;
#ifdef __STDC__
      va_start(args, format);
#else
      char *string;
      char *format;
      va_start(args);
      string = va_arg(args, char *);
      format = va_arg(args, char *);
#endif
      vsprintf(string, format, args);
      return strlen(string);
}

#endif

void
u_sleep(usec)
      int usec;
{
      struct timeval t;
      fd_set fdset;

      FD_ZERO(&fdset);

      t.tv_sec = 0;
      t.tv_usec = usec * 1000;

      select(0, &fdset, &fdset, &fdset, &t);
}

/*
 * Set fd blocking and non-blocking
 */

void
fd_nonblock(fd)
      int fd;
{
#ifdef FIONBIO
      int opt = 1;

      ioctlsocket(fd, FIONBIO, &opt);
#else
      int opt;

      opt = fcntl(fd, F_GETFL, 0);
      opt |= O_NONBLOCK;
      fcntl(fd, F_SETFL, opt);
#endif
}

void
fd_block(fd)
      int fd;
{
#ifdef FIONBIO
      int opt = 0;

      ioctlsocket(fd, FIONBIO, &opt);
#else
      int opt;

      opt = fcntl(fd, F_GETFL, 0);
      opt &= ~O_NONBLOCK;
      fcntl(fd, F_SETFL, opt);
#endif
}


#if 0
/*
 * invoke RSH
 */
int
rsh_exec(so,ns, user, host, args)
      struct socket *so;
      struct socket *ns;
      char *user;
      char *host;
      char *args;
{
      int fd[2];
      int fd0[2];
      int s;
      char buff[256];

      DEBUG_CALL("rsh_exec");
      DEBUG_ARG("so = %lx", (long)so);

      if (pipe(fd)<0) {
          lprint("Error: pipe failed: %s\n", strerror(errno));
          return 0;
      }
/* #ifdef HAVE_SOCKETPAIR */
#if 1
        if (socketpair(PF_UNIX,SOCK_STREAM,0, fd0) == -1) {
          close(fd[0]);
          close(fd[1]);
          lprint("Error: openpty failed: %s\n", strerror(errno));
          return 0;
        }
#else
        if (slirp_openpty(&fd0[0], &fd0[1]) == -1) {
          close(fd[0]);
          close(fd[1]);
          lprint("Error: openpty failed: %s\n", strerror(errno));
          return 0;
        }
#endif

      switch(fork()) {
       case -1:
           lprint("Error: fork failed: %s\n", strerror(errno));
           close(fd[0]);
           close(fd[1]);
           close(fd0[0]);
           close(fd0[1]);
           return 0;

       case 0:
           close(fd[0]);
           close(fd0[0]);

            /* Set the DISPLAY */
           if (x_port >= 0) {
#ifdef HAVE_SETENV
             sprintf(buff, "%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
             setenv("DISPLAY", buff, 1);
#else
             sprintf(buff, "DISPLAY=%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
             putenv(buff);
#endif
           }

           dup2(fd0[1], 0);
           dup2(fd0[1], 1);
           dup2(fd[1], 2);
           for (s = 3; s <= 255; s++)
             close(s);

           execlp("rsh","rsh","-l", user, host, args, NULL);

           /* Ooops, failed, let's tell the user why */

           sprintf(buff, "Error: execlp of %s failed: %s\n",
                   "rsh", strerror(errno));
           write(2, buff, strlen(buff)+1);
           close(0); close(1); close(2); /* XXX */
           exit(1);

        default:
          close(fd[1]);
          close(fd0[1]);
          ns->s=fd[0];
          so->s=fd0[0];

          return 1;
      }
}
#endif

Generated by  Doxygen 1.6.0   Back to index