ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/radiance/ray/src/hd/rhdisp.c
Revision: 3.24
Committed: Thu May 14 13:06:32 1998 UTC (25 years, 10 months ago) by gwlarson
Content type: text/plain
Branch: MAIN
Changes since 3.23: +16 -5 lines
Log Message:
added multiple device view capability

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