ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/radiance/ray/src/hd/rhdisp.c
Revision: 3.28
Committed: Fri Jul 31 16:53:47 1998 UTC (25 years, 8 months ago) by gwlarson
Content type: text/plain
Branch: MAIN
Changes since 3.27: +10 -9 lines
Log Message:
simplified error checking logic

File Contents

# User Rev Content
1 gregl 3.23 /* Copyright (c) 1998 Silicon Graphics, Inc. */
2 gregl 3.1
3     #ifndef lint
4     static char SCCSid[] = "$SunId$ SGI";
5     #endif
6    
7     /*
8     * Holodeck display process.
9     */
10    
11     #include "rholo.h"
12     #include "rhdisp.h"
13     #include "rhdriver.h"
14     #include "selcall.h"
15 gregl 3.10 #include <ctype.h>
16 gregl 3.1
17 gregl 3.12 #ifndef VIEWHISTLEN
18 gregl 3.16 #define VIEWHISTLEN 4 /* number of remembered views */
19 gregl 3.12 #endif
20    
21 gregl 3.1 HOLO *hdlist[HDMAX+1]; /* global holodeck list */
22    
23 gregl 3.10 char cmdlist[DC_NCMDS][8] = DC_INIT;
24    
25 gregl 3.1 int imm_mode = 0; /* bundles are being delivered immediately */
26    
27 gregl 3.20 int do_outside = 0; /* render from outside sections */
28    
29 gwlarson 3.25 double eyesepdist = 1; /* eye separation distance */
30    
31 gregl 3.1 char *progname; /* global argv[0] */
32    
33 gregl 3.10 FILE *sstdin, *sstdout; /* server's standard input and output */
34 gregl 3.1
35 gregl 3.21 #ifdef DEBUG
36     #include <sys/types.h>
37     extern time_t time();
38     static time_t tmodesw;
39     static time_t timm, tadd;
40     static long nimmrays, naddrays;
41     #endif
42    
43 gregl 3.10 #define RDY_SRV 01
44     #define RDY_DEV 02
45     #define RDY_SIN 04
46 gregl 3.1
47 gregl 3.10
48 gregl 3.1 main(argc, argv)
49     int argc;
50     char *argv[];
51     {
52 gregl 3.10 extern int eputs();
53 gregl 3.3 int rdy, inp, res = 0, pause = 0;
54 gregl 3.1
55     progname = argv[0];
56 gregl 3.10 if (argc < 3)
57 gregl 3.1 error(USER, "bad command line arguments");
58     /* open our device */
59     dev_open(argv[1]);
60 gregl 3.10 /* open server process i/o */
61     sstdout = fdopen(atoi(argv[2]), "w");
62     if (argc < 4 || (inp = atoi(argv[3])) < 0)
63     sstdin = NULL;
64     else
65     sstdin = fdopen(inp, "r");
66     /* set command error vector */
67     erract[COMMAND].pf = eputs;
68 gregl 3.21 #ifdef DEBUG
69     tmodesw = time(NULL);
70     #endif
71 gregl 3.1 /* enter main loop */
72     do {
73     rdy = disp_wait();
74 gregl 3.19 if (rdy & RDY_SRV) { /* process server result */
75     res = serv_result();
76     if (pause && res != DS_SHUTDOWN) {
77     serv_request(DR_ATTEN, 0, NULL);
78     while ((res = serv_result()) != DS_ACKNOW &&
79     res != DS_SHUTDOWN)
80     ;
81     }
82     }
83 gregl 3.10 if (rdy & RDY_DEV) { /* user input from driver */
84 gregl 3.3 inp = dev_input();
85 gregl 3.13 if (inp & DFL(DC_SETVIEW))
86     new_view(&odev.v);
87     if (inp & DFL(DC_GETVIEW))
88 gregl 3.10 printview();
89 gregl 3.13 if (inp & DFL(DC_LASTVIEW))
90 gregl 3.12 new_view(NULL);
91 gregl 3.13 if (inp & DFL(DC_RESUME)) {
92 gregl 3.3 serv_request(DR_NOOP, 0, NULL);
93     pause = 0;
94     }
95 gregl 3.15 if (inp & DFL(DC_PAUSE))
96     pause = 1;
97 gregl 3.13 if (inp & DFL(DC_REDRAW))
98 gwlarson 3.24 imm_mode = beam_sync(1) > 0;
99 gregl 3.15 if (inp & DFL(DC_KILL)) {
100 gregl 3.14 serv_request(DR_KILL, 0, NULL);
101 gregl 3.15 pause = 0;
102     }
103 gregl 3.14 if (inp & DFL(DC_CLOBBER))
104     serv_request(DR_CLOBBER, 0, NULL);
105 gregl 3.15 if (inp & DFL(DC_RESTART)) {
106 gregl 3.14 serv_request(DR_RESTART, 0, NULL);
107 gregl 3.15 pause = 0;
108     }
109 gregl 3.13 if (inp & DFL(DC_QUIT))
110     serv_request(DR_SHUTDOWN, 0, NULL);
111 gregl 3.3 }
112 gregl 3.10 if (rdy & RDY_SIN) /* user input from sstdin */
113     switch (usr_input()) {
114     case DC_PAUSE:
115     pause = 1;
116     break;
117     case DC_RESUME:
118     serv_request(DR_NOOP, 0, NULL);
119 gregl 3.15 /* fall through */
120     case DC_KILL:
121     case DC_RESTART:
122 gregl 3.10 pause = 0;
123     break;
124     }
125 gregl 3.1 } while (res != DS_SHUTDOWN);
126 gregl 3.21 #ifdef DEBUG
127     if (timm && nimmrays)
128     fprintf(stderr,
129     "%s: %.1f rays recalled/second (%ld rays total)\n",
130     progname, (double)nimmrays/timm, nimmrays);
131     if (tadd && naddrays)
132     fprintf(stderr,
133     "%s: %.1f rays calculated/second (%ld rays total)\n",
134     progname, (double)naddrays/tadd, naddrays);
135     #endif
136 gregl 3.1 /* all done */
137     quit(0);
138     }
139    
140    
141     int
142     disp_wait() /* wait for more input */
143     {
144     fd_set readset, errset;
145     int flgs;
146     int n;
147     register int i;
148     /* see if we can avoid select call */
149     if (imm_mode || stdin->_cnt > 0)
150 gregl 3.4 return(RDY_SRV);
151 gregl 3.10 if (sstdin != NULL && sstdin->_cnt > 0)
152     return(RDY_SIN);
153 gregl 3.1 if (dev_flush())
154 gregl 3.4 return(RDY_DEV);
155 gregl 3.1 /* make the call */
156     FD_ZERO(&readset); FD_ZERO(&errset);
157     FD_SET(0, &readset);
158     FD_SET(0, &errset);
159     FD_SET(odev.ifd, &readset);
160     FD_SET(odev.ifd, &errset);
161 gregl 3.10 n = odev.ifd+1;
162     if (sstdin != NULL) {
163     FD_SET(fileno(sstdin), &readset);
164 gregl 3.23 FD_SET(fileno(sstdin), &errset);
165 gregl 3.10 if (fileno(sstdin) >= n)
166     n = fileno(sstdin) + 1;
167     }
168 gregl 3.1 n = select(n, &readset, NULL, &errset, NULL);
169     if (n < 0) {
170     if (errno == EINTR)
171     return(0);
172     error(SYSTEM, "select call failure in disp_wait");
173     }
174     flgs = 0; /* flag what's ready */
175     if (FD_ISSET(0, &readset) || FD_ISSET(0, &errset))
176 gregl 3.4 flgs |= RDY_SRV;
177 gregl 3.1 if (FD_ISSET(odev.ifd, &readset) || FD_ISSET(odev.ifd, &errset))
178 gregl 3.4 flgs |= RDY_DEV;
179 gregl 3.23 if (sstdin != NULL && (FD_ISSET(fileno(sstdin), &readset) ||
180     FD_ISSET(fileno(sstdin), &errset)))
181 gregl 3.10 flgs |= RDY_SIN;
182 gregl 3.1 return(flgs);
183     }
184    
185    
186     add_holo(hdg) /* register a new holodeck section */
187     HDGRID *hdg;
188     {
189     VIEW nv;
190 gregl 3.20 double d;
191 gregl 3.1 register int hd;
192    
193     for (hd = 0; hd < HDMAX && hdlist[hd] != NULL; hd++)
194     ;
195     if (hd >= HDMAX)
196     error(INTERNAL, "too many holodeck sections in add_holo");
197     hdlist[hd] = (HOLO *)malloc(sizeof(HOLO));
198     if (hdlist[hd] == NULL)
199     error(SYSTEM, "out of memory in add_holo");
200     bcopy((char *)hdg, (char *)hdlist[hd], sizeof(HDGRID));
201     hdcompgrid(hdlist[hd]);
202     if (hd)
203     return;
204     /* set initial viewpoint */
205     copystruct(&nv, &odev.v);
206     VSUM(nv.vp, hdlist[0]->orig, hdlist[0]->xv[0], 0.5);
207     VSUM(nv.vp, nv.vp, hdlist[0]->xv[1], 0.5);
208     VSUM(nv.vp, nv.vp, hdlist[0]->xv[2], 0.5);
209     fcross(nv.vdir, hdlist[0]->xv[1], hdlist[0]->xv[2]);
210     VCOPY(nv.vup, hdlist[0]->xv[2]);
211 gregl 3.20 if (do_outside) {
212     normalize(nv.vdir);
213     d = VLEN(hdlist[0]->xv[1]);
214     d += VLEN(hdlist[0]->xv[2]);
215     VSUM(nv.vp, nv.vp, nv.vdir, -d);
216     }
217 gregl 3.1 new_view(&nv);
218     }
219    
220    
221     disp_bundle(p) /* display a ray bundle */
222     register PACKHEAD *p;
223     {
224     GCOORD gc[2];
225     FVECT ro, rd, wp;
226     double d;
227     register int i;
228     /* get beam coordinates */
229     if (p->hd < 0 | p->hd >= HDMAX || hdlist[p->hd] == NULL)
230     error(INTERNAL, "bad holodeck number in disp_bundle");
231     if (!hdbcoord(gc, hdlist[p->hd], p->bi))
232     error(INTERNAL, "bad beam index in disp_bundle");
233     /* display each ray */
234     for (i = p->nr; i--; ) {
235     hdray(ro, rd, hdlist[p->hd], gc, packra(p)[i].r);
236     d = hddepth(hdlist[p->hd], packra(p)[i].d);
237     VSUM(wp, ro, rd, d); /* might be behind viewpoint */
238 gregl 3.9 dev_value(packra(p)[i].v, wp, rd);
239 gregl 3.1 }
240 gregl 3.21 #ifdef DEBUG
241     if (imm_mode) nimmrays += p->nr;
242     else naddrays += p->nr;
243     #endif
244 gregl 3.1 }
245    
246    
247     new_view(v) /* change view parameters */
248 gregl 3.12 register VIEW *v;
249 gregl 3.1 {
250 gregl 3.12 static VIEW viewhist[VIEWHISTLEN];
251     static unsigned nhist;
252 gwlarson 3.24 VIEW *dv;
253     int i, res[2];
254 gregl 3.1 char *err;
255 gregl 3.12 /* restore previous view? */
256     if (v == NULL) {
257 gregl 3.16 if (nhist > 1) /* get one before last setting */
258     nhist--;
259     else /* else go to end of list */
260     while (nhist < VIEWHISTLEN && viewhist[nhist].type)
261     nhist++;
262 gregl 3.12 v = viewhist + ((nhist-1)%VIEWHISTLEN);
263 gregl 3.17 } else
264     again:
265     if ((err = setview(v)) != NULL) {
266 gregl 3.12 error(COMMAND, err);
267     return;
268     }
269     if (v->type == VT_PAR) {
270     error(COMMAND, "cannot handle parallel views");
271     return;
272     }
273 gwlarson 3.24 if (!dev_view(v)) /* notify display driver */
274 gregl 3.12 goto again;
275     dev_flush(); /* update screen */
276 gwlarson 3.27 beam_init(0); /* compute new beam set */
277 gwlarson 3.24 for (i = 0; (dv = dev_auxview(i, res)) != NULL; i++)
278     if (!beam_view(dv, res[0], res[1])) {
279     if (!nhist) {
280     error(COMMAND, "invalid starting view");
281     return;
282     }
283     copystruct(v, viewhist + ((nhist-1)%VIEWHISTLEN));
284     goto again;
285     }
286     beam_sync(0); /* update server */
287 gregl 3.12 /* record new view */
288     if (v < viewhist || v >= viewhist+VIEWHISTLEN) {
289     copystruct(viewhist + (nhist%VIEWHISTLEN), v);
290     nhist++;
291     }
292 gregl 3.10 }
293    
294    
295     int
296     usr_input() /* get user input and process it */
297     {
298     VIEW vparams;
299 gregl 3.23 char cmd[256];
300 gregl 3.10 register char *args;
301 gregl 3.11 register int i;
302 gregl 3.10
303 gregl 3.23 if (fgets(cmd, sizeof(cmd), sstdin) == NULL) {
304     fclose(sstdin);
305     sstdin = NULL;
306 gwlarson 3.26 return(-1);
307 gregl 3.23 }
308 gwlarson 3.26 if (!*cmd)
309     return(DC_RESUME);
310 gregl 3.10 for (args = cmd; *args && !isspace(*args); args++)
311     ;
312     while (isspace(*args))
313     *args++ = '\0';
314 gregl 3.11 if (*args && args[i=strlen(args)-1] == '\n')
315     args[i] = '\0';
316     for (i = 0; i < DC_NCMDS; i++)
317     if (!strcmp(cmd, cmdlist[i]))
318 gregl 3.10 break;
319 gregl 3.11 if (i >= DC_NCMDS) {
320 gwlarson 3.26 dev_auxcom(cmd, args);
321 gregl 3.10 return(-1);
322     }
323 gregl 3.11 switch (i) {
324 gregl 3.10 case DC_SETVIEW: /* set the view */
325     copystruct(&vparams, &odev.v);
326     if (!sscanview(&vparams, args))
327     error(COMMAND, "missing view options");
328     else
329     new_view(&vparams);
330     break;
331     case DC_GETVIEW: /* print the current view */
332     printview();
333 gregl 3.12 break;
334     case DC_LASTVIEW: /* restore previous view */
335     new_view(NULL);
336 gregl 3.10 break;
337     case DC_PAUSE: /* pause the current calculation */
338     case DC_RESUME: /* resume the calculation */
339     /* handled in main() */
340 gregl 3.13 break;
341     case DC_REDRAW: /* redraw from server */
342 gwlarson 3.24 imm_mode = beam_sync(1) > 0;
343 gregl 3.22 dev_clear();
344 gregl 3.14 break;
345     case DC_KILL: /* kill rtrace process(es) */
346     serv_request(DR_KILL, 0, NULL);
347     break;
348     case DC_CLOBBER: /* clobber holodeck */
349     serv_request(DR_CLOBBER, 0, NULL);
350     break;
351     case DC_RESTART: /* restart rtrace */
352     serv_request(DR_RESTART, 0, NULL);
353 gregl 3.10 break;
354     case DC_QUIT: /* quit request */
355     serv_request(DR_SHUTDOWN, 0, NULL);
356     break;
357     default:
358     error(CONSISTENCY, "bad command id in usr_input");
359     }
360 gregl 3.11 return(i);
361 gregl 3.10 }
362    
363    
364     printview() /* print our current view to server stdout */
365     {
366     fputs(VIEWSTR, sstdout);
367     fprintview(&odev.v, sstdout);
368     fputc('\n', sstdout);
369     fflush(sstdout);
370 gregl 3.1 }
371    
372    
373     int
374     serv_result() /* get next server result and process it */
375     {
376     static char *buf = NULL;
377     static int bufsiz = 0;
378     MSGHEAD msg;
379     int n;
380     /* read message header */
381     if (fread((char *)&msg, sizeof(MSGHEAD), 1, stdin) != 1)
382     goto readerr;
383     if (msg.nbytes > 0) { /* get the message body */
384     if (msg.nbytes > bufsiz) {
385     if (buf == NULL)
386     buf = (char *)malloc(bufsiz=msg.nbytes);
387     else
388     buf = (char *)realloc(buf, bufsiz=msg.nbytes);
389     if (buf == NULL)
390     error(SYSTEM, "out of memory in serv_result");
391     }
392     if (fread(buf, 1, msg.nbytes, stdin) != msg.nbytes)
393     goto readerr;
394     }
395     switch (msg.type) { /* process results */
396     case DS_BUNDLE:
397     if (msg.nbytes < sizeof(PACKHEAD) ||
398     msg.nbytes != packsiz(((PACKHEAD *)buf)->nr))
399     error(INTERNAL, "bad display packet from server");
400     disp_bundle((PACKHEAD *)buf);
401     break;
402     case DS_ADDHOLO:
403     if (msg.nbytes != sizeof(HDGRID))
404     error(INTERNAL, "bad holodeck record from server");
405     add_holo((HDGRID *)buf);
406 gregl 3.20 break;
407     case DS_OUTSECT:
408     do_outside = 1;
409 gwlarson 3.28 goto noargs;
410 gwlarson 3.25 case DS_EYESEP:
411     if (msg.nbytes <= 1 || (eyesepdist = atof(buf)) <= FTINY)
412     error(INTERNAL, "bad eye separation from server");
413 gregl 3.1 break;
414     case DS_STARTIMM:
415     case DS_ENDIMM:
416 gregl 3.21 #ifdef DEBUG
417     if (imm_mode != (msg.type==DS_STARTIMM)) {
418     time_t tnow = time(NULL);
419     if (imm_mode) timm += tnow - tmodesw;
420     else tadd += tnow - tmodesw;
421     tmodesw = tnow;
422     }
423     #endif
424 gregl 3.1 imm_mode = msg.type==DS_STARTIMM;
425 gwlarson 3.28 goto noargs;
426 gregl 3.1 case DS_ACKNOW:
427     case DS_SHUTDOWN:
428 gwlarson 3.28 goto noargs;
429 gregl 3.1 default:
430     error(INTERNAL, "unrecognized result from server process");
431     }
432     return(msg.type); /* return message type */
433 gwlarson 3.28 noargs:
434     if (msg.nbytes) {
435     sprintf(errmsg, "unexpected body with server message %d",
436     msg.type);
437     error(INTERNAL, errmsg);
438     }
439     return(msg.type);
440 gregl 3.1 readerr:
441     if (feof(stdin))
442     error(SYSTEM, "server process died");
443     error(SYSTEM, "error reading from server process");
444     }
445    
446    
447     serv_request(type, nbytes, p) /* send a request to the server process */
448     int type, nbytes;
449     char *p;
450     {
451     MSGHEAD msg;
452     int m;
453     /* get server's attention for big request */
454     if (nbytes >= BIGREQSIZ-sizeof(MSGHEAD)) {
455     serv_request(DR_ATTEN, 0, NULL);
456     while ((m = serv_result()) != DS_ACKNOW)
457     if (m == DS_SHUTDOWN) /* the bugger quit on us */
458     quit(0);
459     }
460     msg.type = type; /* write and flush the message */
461     msg.nbytes = nbytes;
462     fwrite((char *)&msg, sizeof(MSGHEAD), 1, stdout);
463     if (nbytes > 0)
464     fwrite(p, 1, nbytes, stdout);
465     if (fflush(stdout) < 0)
466     error(SYSTEM, "write error in serv_request");
467 gregl 3.2 }
468    
469    
470     eputs(s) /* put error message to stderr */
471     register char *s;
472     {
473     static int midline = 0;
474    
475     if (!*s)
476     return;
477     if (!midline++) { /* prepend line with program name */
478     fputs(progname, stderr);
479     fputs(": ", stderr);
480     }
481     fputs(s, stderr);
482     if (s[strlen(s)-1] == '\n') {
483     fflush(stderr);
484     midline = 0;
485     }
486 gregl 3.1 }
487    
488    
489     quit(code) /* clean up and exit */
490     int code;
491     {
492     if (odev.v.type)
493     dev_close();
494     exit(code);
495     }