--- ray/src/rt/devcomm.c 1989/06/02 17:21:24 1.4 +++ ray/src/rt/devcomm.c 2008/05/01 15:50:28 2.14 @@ -1,154 +1,199 @@ -/* Copyright (c) 1988 Regents of the University of California */ - #ifndef lint -static char SCCSid[] = "$SunId$ LBL"; +static const char RCSid[] = "$Id: devcomm.c,v 2.14 2008/05/01 15:50:28 greg Exp $"; #endif - /* * devcomm.c - communication routines for separate drivers. * - * 10/5/88 + * External symbols declared in driver.h */ -#include +#include "copyright.h" -#include +#include +#include /* XXX platform specific */ -#include "color.h" - +#include "platform.h" +#include "standard.h" #include "driver.h" #ifndef DEVPATH #define DEVPATH getenv("PATH") /* device search path */ #endif -#ifndef BSD -#define vfork fork -#endif +FILE *devin, *devout; +int devchild; -#ifndef WFLUSH -#define WFLUSH 50 /* flush after this many rays */ -#endif +static struct driver * final_connect(void); +static void mygets(char *s, FILE *fp); +static void myputs(char *s, FILE *fp); +static void reply_error(char *routine); +static void getstate(void); -extern char *getpath(), *getenv(); +static dr_closef_t comm_close; +static dr_clearf_t comm_clear; +static dr_paintrf_t comm_paintr; +static dr_getcurf_t comm_getcur; +static dr_comoutf_t comm_comout; +static dr_cominf_t comm_comin; +static dr_flushf_t comm_flush; -int onsigio(); - -int comm_close(), comm_clear(), comm_paintr(), comm_errout(), - comm_getcur(), comm_comout(), comm_comin(); - -struct driver comm_driver, comm_default = { +struct driver comm_driver = { comm_close, comm_clear, comm_paintr, comm_getcur, - comm_comout, comm_comin, - MAXRES, MAXRES, 0 + comm_comout, comm_comin, comm_flush }; -FILE *devin, *devout; -int devchild; +static struct driver * +final_connect(void) /* verify and initialize connection */ +{ + putw(COM_SENDM, devout); + fflush(devout); + if (getw(devin) != COM_RECVM) + return(NULL); + /* get driver parameters */ + getstate(); + /* set error vectors */ + erract[COMMAND].pf = comm_comout; + if (erract[WARNING].pf != NULL) + erract[WARNING].pf = comm_comout; + return(&comm_driver); +} -struct driver * -comm_init(argv) /* set up and execute driver */ -char *argv[]; +extern struct driver * +slave_init( /* run rview in slave mode */ + char *dname, + char *id +) { - char *devname; - int p1[2], p2[2]; + devchild = -1; /* we're the slave here */ + devout = stdout; /* use standard input */ + devin = stdin; /* and standard output */ + return(final_connect()); /* verify initialization */ +} - if ((devname = getpath(argv[0], DEVPATH)) == NULL) { - stderr_v(argv[0]); - stderr_v(": not found\n"); + +extern struct driver * +comm_init( /* set up and execute driver */ + char *dname, + char *id +) +{ + char *dvcname; + int p1[2], p2[2]; + char pin[16], pout[16]; + /* find driver program */ + if ((dvcname = getpath(dname, DEVPATH, X_OK)) == NULL) { + eputs(dname); + eputs(": not found\n"); return(NULL); } +#ifdef RHAS_FORK_EXEC + /* open communication pipes */ if (pipe(p1) == -1 || pipe(p2) == -1) goto syserr; - if ((devchild = vfork()) == 0) { + if ((devchild = fork()) == 0) { /* fork driver process */ close(p1[1]); close(p2[0]); - if (p1[0] != 0) { - dup2(p1[0], 0); - close(p1[0]); - } - if (p2[1] != 1) { - dup2(p2[1], 1); - close(p2[1]); - } - execv(devname, argv); - stderr_v(devname); - stderr_v(": cannot execute\n"); + sprintf(pin, "%d", p1[0]); + sprintf(pout, "%d", p2[1]); + execl(dvcname, dname, pin, pout, id, NULL); + perror(dvcname); _exit(127); } if (devchild == -1) goto syserr; close(p1[0]); close(p2[1]); + /* + * Close write stream on exec to avoid multiprocessing deadlock. + * No use in read stream without it, so set flag there as well. + */ + fcntl(p1[1], F_SETFD, FD_CLOEXEC); + fcntl(p2[0], F_SETFD, FD_CLOEXEC); if ((devout = fdopen(p1[1], "w")) == NULL) goto syserr; if ((devin = fdopen(p2[0], "r")) == NULL) goto syserr; - bcopy(&comm_default, &comm_driver, sizeof(comm_driver)); - signal(SIGIO, onsigio); - cmdvec = comm_comout; /* set error vectors */ - if (wrnvec != NULL) - wrnvec = comm_comout; - return(&comm_driver); + return(final_connect()); /* verify initialization */ syserr: - perror(argv[0]); + perror(dname); return(NULL); + +#else /* ! RHAS_FORK_EXEC */ + + eputs(dname); + eputs(": no fork/exec\n"); + return(NULL); + +#endif /* ! RHAS_FORK_EXEC */ } -static -comm_close() /* done with driver */ +static void +comm_close(void) /* done with driver */ { int pid; - cmdvec = NULL; /* reset error vectors */ - if (wrnvec != NULL) - wrnvec = stderr_v; - signal(SIGIO, SIG_DFL); + erract[COMMAND].pf = NULL; /* reset error vectors */ + if (erract[WARNING].pf != NULL) + erract[WARNING].pf = wputs; fclose(devout); fclose(devin); + if (devchild < 0) + return; while ((pid = wait(0)) != -1 && pid != devchild) ; } -static -comm_clear(xres, yres) /* clear screen */ -int xres, yres; +static void +comm_clear( /* clear screen */ + int xres, + int yres +) { putc(COM_CLEAR, devout); - fwrite(&xres, sizeof(xres), 1, devout); - fwrite(&yres, sizeof(yres), 1, devout); + putw(xres, devout); + putw(yres, devout); fflush(devout); } -static -comm_paintr(col, xmin, ymin, xmax, ymax) /* paint a rectangle */ -COLOR col; -int xmin, ymin, xmax, ymax; +static void +comm_paintr( /* paint a rectangle */ + COLOR col, + int xmin, + int ymin, + int xmax, + int ymax +) { - extern long nrays; /* number of rays traced */ - static long lastflush = 0; /* ray count at last flush */ - putc(COM_PAINTR, devout); - fwrite(col, sizeof(COLOR), 1, devout); - fwrite(&xmin, sizeof(xmin), 1, devout); - fwrite(&ymin, sizeof(ymin), 1, devout); - fwrite(&xmax, sizeof(xmax), 1, devout); - fwrite(&ymax, sizeof(ymax), 1, devout); - if (nrays - lastflush >= WFLUSH) { - fflush(devout); - lastflush = nrays; - } + fwrite((char *)col, sizeof(COLOR), 1, devout); + putw(xmin, devout); + putw(ymin, devout); + putw(xmax, devout); + putw(ymax, devout); } +static void +comm_flush(void) /* flush output to driver */ +{ + putc(COM_FLUSH, devout); + fflush(devout); + if (getc(devin) != COM_FLUSH) + reply_error("flush"); + getstate(); +} + + static int -comm_getcur(xp, yp) /* get and return cursor position */ -int *xp, *yp; +comm_getcur( /* get and return cursor position */ + int *xp, + int *yp +) { int c; @@ -157,49 +202,51 @@ int *xp, *yp; if (getc(devin) != COM_GETCUR) reply_error("getcur"); c = getc(devin); - fread(xp, sizeof(*xp), 1, devin); - fread(yp, sizeof(*yp), 1, devin); + *xp = getw(devin); + *yp = getw(devin); return(c); } -static -comm_comout(str) /* print string to command line */ -char *str; +static void +comm_comout( /* print string to command line */ + char *str +) { putc(COM_COMOUT, devout); myputs(str, devout); - fflush(devout); + if (str[strlen(str)-1] == '\n') + fflush(devout); } -static -comm_comin(buf) /* read string from command line */ -char *buf; +static void +comm_comin( /* read string from command line */ + char *buf, + char *prompt +) { putc(COM_COMIN, devout); + if (prompt == NULL) + putc(0, devout); + else { + putc(1, devout); + myputs(prompt, devout); + } fflush(devout); if (getc(devin) != COM_COMIN) reply_error("comin"); mygets(buf, devin); - comm_driver.inpready = 0; + getstate(); } -static -comm_errout(str) /* display an error message */ -char *str; +static void +mygets( /* get string from file (with nul) */ + register char *s, + register FILE *fp +) { - comm_comout(str); - stderr_v(str); /* send to standard error also */ -} - - -static -mygets(s, fp) /* get string from file (with nul) */ -register char *s; -register FILE *fp; -{ register int c; while ((c = getc(fp)) != EOF) @@ -209,10 +256,11 @@ register FILE *fp; } -static -myputs(s, fp) /* put string to file (with nul) */ -register char *s; -register FILE *fp; +static void +myputs( /* put string to file (with nul) */ + register char *s, + register FILE *fp +) { do putc(*s, fp); @@ -220,18 +268,23 @@ register FILE *fp; } -static -reply_error(routine) /* what should we do here? */ -char *routine; +static void +reply_error( /* what should we do here? */ + char *routine +) { - stderr_v(routine); - stderr_v(": driver reply error\n"); + eputs(routine); + eputs(": driver reply error\n"); quit(1); } -static -onsigio() /* input ready */ +static void +getstate(void) /* get driver state variables */ { - comm_driver.inpready++; + fread((char *)&comm_driver.pixaspect, + sizeof(comm_driver.pixaspect), 1, devin); + comm_driver.xsiz = getw(devin); + comm_driver.ysiz = getw(devin); + comm_driver.inpready = getw(devin); }