ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/radiance/ray/src/hd/rholo4.c
Revision: 3.9
Committed: Wed Nov 26 21:34:28 1997 UTC (26 years, 4 months ago) by gregl
Content type: text/plain
Branch: MAIN
Changes since 3.8: +8 -0 lines
Log Message:
eliminated queue flushing in sortbeamlist()
added DS_ADJSET request for adjusting set quantities

File Contents

# User Rev Content
1 gregl 3.1 /* Copyright (c) 1997 Silicon Graphics, Inc. */
2    
3     #ifndef lint
4     static char SCCSid[] = "$SunId$ SGI";
5     #endif
6    
7     /*
8     * Holodeck display process communication
9     */
10    
11     #include "rholo.h"
12     #include "rhdisp.h"
13 gregl 3.2 #include <sys/uio.h>
14 gregl 3.1
15 gregl 3.2 #ifndef HDSUF
16     #define HDSUF ".hdisp"
17     #endif
18 gregl 3.1
19 gregl 3.2 static int inp_flags;
20     static int dpd[3];
21 gregl 3.5 static FILE *dpout;
22 gregl 3.2
23    
24     disp_open(dname) /* open the named display driver */
25 gregl 3.1 char *dname;
26     {
27 gregl 3.5 char dpath[128], *com[3];
28 gregl 3.2 int i;
29    
30     #ifdef DEVPATH
31     sprintf(dpath, "%s/%s%s", DEVPATH, dname, HDSUF);
32     #else
33     sprintf(dpath, "dev/%s%s", dname, HDSUF);
34     #endif
35 gregl 3.5 com[0] = dpath; com[1] = froot; com[2] = NULL;
36 gregl 3.6 i = open_process(dpd, com);
37     if (i <= 0)
38 gregl 3.2 error(USER, "cannot start display process");
39 gregl 3.5 if ((dpout = fdopen(dup(dpd[1]), "w")) == NULL)
40     error(SYSTEM, "cannot associate FILE with display pipe");
41 gregl 3.2 inp_flags = 0;
42     /* write out hologram grids */
43     for (i = 0; hdlist[i] != NULL; i++)
44     disp_result(DS_ADDHOLO, sizeof(HDGRID), (char *)hdlist[i]);
45 gregl 3.5 disp_flush();
46 gregl 3.1 }
47    
48    
49 gregl 3.2 disp_packet(p) /* display a packet */
50 gregl 3.4 register PACKHEAD *p;
51 gregl 3.2 {
52 gregl 3.4 disp_result(DS_BUNDLE, packsiz(p->nr), (char *)p);
53 gregl 3.2 }
54    
55    
56 gregl 3.1 disp_check(block) /* check display process */
57     int block;
58     {
59 gregl 3.2 MSGHEAD msg;
60     int n;
61     char *buf = NULL;
62    
63 gregl 3.6 if (dpout == NULL)
64 gregl 3.2 return(-1);
65 gregl 3.5 /* flush display output */
66     disp_flush();
67 gregl 3.3 /* check read blocking */
68 gregl 3.2 if (block != (inp_flags == 0)) {
69     inp_flags = block ? 0 : FNONBLK;
70     if (fcntl(dpd[0], F_SETFL, inp_flags) < 0)
71     goto fcntlerr;
72     }
73     /* read message header */
74     n = read(dpd[0], (char *)&msg, sizeof(MSGHEAD));
75     if (n != sizeof(MSGHEAD)) {
76     if (n >= 0)
77     error(USER, "display process died");
78     if (errno != EAGAIN & errno != EINTR)
79     goto readerr;
80 gregl 3.3 return(2); /* acceptable failure */
81 gregl 3.2 }
82     if (msg.nbytes) { /* get the message body */
83     buf = (char *)malloc(msg.nbytes);
84     if (buf == NULL)
85     error(SYSTEM, "out of memory in disp_check");
86     if (fcntl(dpd[0], F_SETFL, inp_flags=0) < 0)
87     goto fcntlerr;
88     if (readbuf(dpd[0], buf, msg.nbytes) != msg.nbytes)
89     goto readerr;
90     }
91     switch (msg.type) { /* take appropriate action */
92     case DR_BUNDLE:
93     if (msg.nbytes != sizeof(PACKHEAD))
94     error(INTERNAL, "bad DR_BUNDLE from display process");
95     bundle_set(BS_ADD, (PACKHEAD *)buf, 1);
96     break;
97     case DR_NEWSET:
98     if (msg.nbytes % sizeof(PACKHEAD))
99     error(INTERNAL, "bad DR_NEWSET from display process");
100     disp_result(DS_STARTIMM, 0, NULL);
101     bundle_set(BS_NEW, (PACKHEAD *)buf, msg.nbytes/sizeof(PACKHEAD));
102     disp_result(DS_ENDIMM, 0, NULL);
103 gregl 3.5 disp_flush();
104 gregl 3.2 break;
105     case DR_ADDSET:
106     if (msg.nbytes % sizeof(PACKHEAD))
107     error(INTERNAL, "bad DR_ADDSET from display process");
108     disp_result(DS_STARTIMM, 0, NULL);
109     bundle_set(BS_ADD, (PACKHEAD *)buf, msg.nbytes/sizeof(PACKHEAD));
110     disp_result(DS_ENDIMM, 0, NULL);
111 gregl 3.8 disp_check(0); /* hack -- delete usu. follows add */
112 gregl 3.2 break;
113 gregl 3.9 case DR_ADJSET:
114     if (msg.nbytes % sizeof(PACKHEAD))
115     error(INTERNAL, "bad DR_ADJSET from display process");
116     disp_result(DS_STARTIMM, 0, NULL);
117     bundle_set(BS_ADJ, (PACKHEAD *)buf, msg.nbytes/sizeof(PACKHEAD));
118     disp_result(DS_ENDIMM, 0, NULL);
119     disp_flush();
120     break;
121 gregl 3.2 case DR_DELSET:
122     if (msg.nbytes % sizeof(PACKHEAD))
123     error(INTERNAL, "bad DR_DELSET from display process");
124     bundle_set(BS_DEL, (PACKHEAD *)buf, msg.nbytes/sizeof(PACKHEAD));
125     break;
126     case DR_ATTEN:
127     if (msg.nbytes)
128     error(INTERNAL, "bad DR_ATTEN from display process");
129     /* send acknowledgement */
130     disp_result(DS_ACKNOW, 0, NULL);
131 gregl 3.3 return(disp_check(1)); /* block on following request */
132 gregl 3.2 case DR_SHUTDOWN:
133     if (msg.nbytes)
134     error(INTERNAL, "bad DR_SHUTDOWN from display process");
135     return(0); /* zero return signals shutdown */
136 gregl 3.7 case DR_NOOP:
137     break;
138 gregl 3.2 default:
139     error(INTERNAL, "unrecognized request from display process");
140     }
141 gregl 3.3 if (msg.nbytes) /* clean up */
142 gregl 3.2 free(buf);
143     return(1); /* normal return value */
144     fcntlerr:
145     error(SYSTEM, "cannot change display blocking mode");
146     readerr:
147     error(SYSTEM, "error reading from display process");
148 gregl 3.1 }
149    
150    
151 gregl 3.2 int
152     disp_close() /* close our display process */
153 gregl 3.1 {
154 gregl 3.2 int rval;
155    
156 gregl 3.6 if (dpout == NULL)
157 gregl 3.2 return(-1);
158     disp_result(DS_SHUTDOWN, 0, NULL);
159 gregl 3.5 fclose(dpout);
160     dpout = NULL;
161 gregl 3.2 return(close_process(dpd));
162     }
163    
164    
165 gregl 3.5 disp_result(type, nbytes, p) /* queue result message to display process */
166 gregl 3.2 int type, nbytes;
167     char *p;
168     {
169     MSGHEAD msg;
170    
171 gregl 3.6 if (dpout == NULL)
172     return;
173 gregl 3.2 msg.type = type;
174     msg.nbytes = nbytes;
175 gregl 3.5 fwrite((char *)&msg, sizeof(MSGHEAD), 1, dpout);
176     if (nbytes > 0)
177     fwrite(p, 1, nbytes, dpout);
178     }
179    
180    
181     disp_flush() /* flush output to display */
182     {
183     if (fflush(dpout) < 0)
184     error(SYSTEM, "error writing to the display process");
185 gregl 3.1 }