--- ray/src/util/netproc.c 1996/02/20 15:55:01 2.3 +++ ray/src/util/netproc.c 2003/10/27 10:32:06 2.12 @@ -1,43 +1,28 @@ -/* Copyright (c) 1996 Regents of the University of California */ - #ifndef lint -static char SCCSid[] = "$SunId$ LBL"; +static const char RCSid[] = "$Id: netproc.c,v 2.12 2003/10/27 10:32:06 schorsch Exp $"; #endif - /* * Parallel network process handling routines */ +#include #include -#include +#include #include #include +#include + +#include "selcall.h" #include "netproc.h" +#include "paths.h" #include "vfork.h" - /* select call compatibility stuff */ -#ifndef FD_SETSIZE -#include -#define FD_SETSIZE NOFILE /* maximum # select file descriptors */ -#endif -#ifndef FD_SET -#ifndef NFDBITS -#define NFDBITS (8*sizeof(int)) /* number of bits per fd_mask */ -#endif -#define FD_SET(n, p) ((p)->fds_bits[(n)/NFDBITS] |= (1 << ((n) % NFDBITS))) -#define FD_CLR(n, p) ((p)->fds_bits[(n)/NFDBITS] &= ~(1 << ((n) % NFDBITS))) -#define FD_ISSET(n, p) ((p)->fds_bits[(n)/NFDBITS] & (1 << ((n) % NFDBITS))) -#ifndef BSD -#define bzero(d,n) (void)memset(d,0,n) -#endif -#define FD_ZERO(p) bzero((char *)(p), sizeof(*(p))) -#endif PSERVER *pslist = NULL; /* global process server list */ -static PROC *pindex[FD_SETSIZE]; /* process index table */ +static NETPROC *pindex[FD_SETSIZE]; /* process index table */ static char ourhost[64]; /* this host name */ -static char ourdir[128]; /* our working directory */ +static char ourdir[PATH_MAX]; /* our working directory */ static char ouruser[32]; /* our user name */ static char *ourshell; /* our user's shell */ @@ -46,10 +31,7 @@ static int maxfd; /* maximum assigned descriptor */ extern char *remsh; /* externally defined remote shell program */ -extern char *malloc(), *realloc(); -extern char *getenv(); - PSERVER * addpserver(host, dir, usr, np) /* add a new process server */ char *host, *dir, *usr; @@ -59,11 +41,11 @@ int np; /* allocate the struct */ if (np < 1) return(NULL); - ps = (PSERVER *)malloc(sizeof(PSERVER)+(np-1)*sizeof(PROC)); + ps = (PSERVER *)malloc(sizeof(PSERVER)+(np-1)*sizeof(NETPROC)); if (ps == NULL) return(NULL); if (!ourhost[0]) { /* initialize */ - char dirtmp[128]; + char dirtmp[PATH_MAX]; register char *cp; register int len; @@ -142,7 +124,7 @@ PSERVER *ps; /* remove server from list */ psp->next = ps->next; pslist = pstart.next; - free((char *)ps); /* free associated memory */ + free((void *)ps); /* free associated memory */ } @@ -169,7 +151,7 @@ register PSERVER *ps; char *command; int (*compf)(); { - char udirt[128]; + char udirt[PATH_MAX]; char *av[16]; int pfd[2], pid; register int i; @@ -250,7 +232,7 @@ int fd; { char errbuf[BUFSIZ]; int nr; - register PROC *pp; + register NETPROC *pp; /* look up associated process */ if ((pp = pindex[fd]) == NULL) abort(); /* serious consistency error */ @@ -265,7 +247,7 @@ int fd; if (pp->elen == 0) pp->errs = (char *)malloc(nr+1); else - pp->errs = (char *)realloc(pp->errs, pp->elen+nr+1); + pp->errs = (char *)realloc((void *)pp->errs, pp->elen+nr+1); if (pp->errs == NULL) { perror("malloc failed"); exit(1); @@ -304,7 +286,7 @@ PSERVER *ps; int pn; int status; { - register PROC *pp; + register NETPROC *pp; pp = ps->proc + pn; if (pp->cf != NULL) /* client cleanup */ @@ -312,7 +294,7 @@ int status; close(pp->efd); /* close error stream */ pindex[pp->efd] = NULL; FD_CLR(pp->efd, &errdesc); - free((char *)pp->errs); + free((void *)pp->errs); pp->com = NULL; /* clear settings */ pp->pid = -1; pp->efd = -1;