![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ox_launch.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM_contrib2 / asir2000 / io|
Return to ox_launch.c CVS log | Up to [local] / OpenXM_contrib2 / asir2000 / io |
1.1 noro 1: /* $OpenXM: OpenXM/src/asir99/io/ox_launch.c,v 1.1.1.1 1999/11/10 08:12:30 noro Exp $ */
2: #include "ca.h"
3: #include "com.h"
4: #include "ox.h"
5: #include <signal.h>
6: #include <setjmp.h>
7: #include <fcntl.h>
8: #if defined(VISUAL)
9: #include <windows.h>
10: #include <io.h>
11: #include <fcntl.h>
12: #include <process.h>
13: #else
14: #include <sys/file.h>
15: #include <sys/types.h>
16: #include <sys/stat.h>
17: #include <pwd.h>
18: #endif
19:
20: #if defined(SYSV)
21: #include <unistd.h>
22: #endif
23:
24: #if defined(VISUAL)
25: HANDLE hIntr,hReset,hKill;
26: #endif
27:
28: static void put_log(char *);
29: static int which_command(char *,char *);
30: static int search_command(char *);
31: static int ox_spawn(char *,int,char *);
32: static void launch_error(char *);
33: static int ox_io_init(int);
34: static void push_one(Obj);
35: static Obj pop_one();
36: static void do_cmd(int);
37:
38: static Obj *asir_OperandStack;
39: static int asir_OperandStackPtr;
40:
41: static char hostname[BUFSIZ];
42: static int sindex;
43: static struct sockaddr_in peer;
44: static int cpid;
45:
46: static void put_log(str)
47: char *str;
48: {
49: static FILE *logfile;
50:
51: if ( !logfile )
52: logfile = fopen("/tmp/ox_log","w");
53: fprintf(logfile,"%s\n",str);
54: fflush(logfile);
55: }
56:
57: #if !defined(VISUAL)
58: static int which_command(com,file)
59: char *com,*file;
60: {
61: char *c,*s;
62: int len;
63: char dir[BUFSIZ],path[BUFSIZ];
64:
65: for ( s = (char *)getenv("PATH"); s; ) {
66: c = (char *)index(s,':');
67: if ( c ) {
68: len = c-s;
69: strncpy(dir,s,len); s = c+1; dir[len] = 0;
70: } else {
71: strcpy(dir,s); s = 0;
72: }
73: sprintf(path,"%s/%s",dir,com);
74: if ( search_command(path) ) {
75: strcpy(file,path); return 1;
76: }
77: }
78: file[0] = 0; return 0;
79: }
80:
81: static int search_command(file)
82: char *file;
83: {
84: struct stat buf;
85:
86: if ( stat(file,&buf) || (buf.st_mode & S_IFDIR) )
87: return 0;
88: if ( access(file,X_OK) )
89: return 0;
90: else
91: return 1;
92: }
93: #endif
94:
95: /*
96: argv[1] : host to connect
97: argv[2] : if 1, call try_bind_listen and try_accept
98: if 0, call try_connect
99: argv[3] : control_port
100: argv[4] : server_port
101: argv[5] : server
102: argv[6] : display or "0"
103: */
104:
105: void launch_main(argc,argv)
106: int argc;
107: char **argv;
108: {
109: int id;
110: Obj p,obj;
111: char *name;
112: char buf[BUFSIZ];
113: int cs,ss;
114: unsigned int cmd;
115: int use_unix,accept_client;
116: char *control_port_str,*server_port_str;
117: char *rhost,*server,*dname;
118:
119: GC_init(); nglob_init();
120: gethostname(hostname,BUFSIZ);
121: rhost = argv[1];
122: use_unix = !strcmp(rhost,".") ? 1 : 0;
123: accept_client = atoi(argv[2]) ? 1 : 0;
124: control_port_str = argv[3];
125: server_port_str = argv[4];
126: server = argv[5];
127: dname = argv[6];
128:
129: #if defined(VISUAL)
130: init_socket();
131: #endif
132:
133: signal(SIGINT,SIG_IGN);
134: #if defined(SIGUSR1)
135: signal(SIGUSR1,SIG_IGN);
136: #endif
137:
138: if ( accept_client ) {
139: cs = try_bind_listen(use_unix,control_port_str);
140: ss = try_bind_listen(use_unix,server_port_str);
141: cs = try_accept(use_unix,cs);
142: ss = try_accept(use_unix,ss);
143: } else {
144: cs = try_connect(use_unix,rhost,control_port_str);
145: ss = try_connect(use_unix,rhost,server_port_str);
146: }
147: ox_io_init(cs);
148: if ( cs < 0 || ss < 0 )
149: launch_error("cannot connect to the client");
150: cpid = ox_spawn(server,ss,dname);
151:
152: while ( 1 ) {
153: ox_recv(sindex,&id,&obj);
154: switch ( id ) {
155: case OX_COMMAND:
156: cmd = ((USINT)obj)->body;
157: do_cmd(cmd);
158: break;
159: case OX_DATA:
160: push_one(obj);
161: break;
162: case OX_SYNC_BALL:
163: break;
164: default:
165: break;
166: }
167: }
168: }
169:
170: #if defined(VISUAL)
171: static void do_cmd(cmd)
172: int cmd;
173: {
174: USINT t;
175: int id,cindex;
176: int bport,sport;
177: int bs,bs0;
178: STRING prog,dname;
179:
180: switch ( cmd ) {
181: case SM_shutdown:
182: SetEvent(hKill);
183: exit(0); break;
184: case SM_control_intr:
185: SetEvent(hIntr);
186: break;
187: case SM_control_kill:
188: SetEvent(hKill);
189: break;
190: case SM_control_reset_connection:
191: MKUSINT(t,0);
192: ox_send_data(sindex,t);
193: SetEvent(hReset);
194: break;
195: default:
196: break;
197: }
198: }
199: #else
200: static void do_cmd(cmd)
201: int cmd;
202: {
203: USINT t;
204: int id,cindex;
205: int bport,sport;
206: int bs,bs0;
207: int status;
208: STRING prog,dname;
209:
210: switch ( cmd ) {
211: case SM_shutdown:
212: kill(cpid,SIGKILL);
213: exit(0); break;
214: case SM_control_intr:
215: kill(cpid,SIGINT);
216: break;
217: case SM_control_kill:
218: kill(cpid,SIGKILL);
219: break;
220: case SM_control_reset_connection:
221: MKUSINT(t,0);
222: ox_send_data(sindex,t);
223: kill(cpid,SIGUSR1);
224: break;
225: default:
226: break;
227: }
228: }
229: #endif
230:
231: static int ox_spawn(prog,bs,dname)
232: char *prog;
233: int bs;
234: char *dname;
235: {
236: #if defined(VISUAL)
237: char *av[BUFSIZ];
238: char sock_id[BUFSIZ],ox_intr[BUFSIZ],ox_reset[BUFSIZ],ox_kill[BUFSIZ];
239: char AsirExe[BUFSIZ];
240: HANDLE hProc;
241: STRING rootdir;
242: int mypid;
243:
244: mypid = GetCurrentProcessId();
245: sprintf(ox_intr,"ox_intr_%d",mypid);
246: sprintf(ox_reset,"ox_reset_%d",mypid);
247: sprintf(ox_kill,"ox_kill_%d",mypid);
248: hIntr = CreateEvent(NULL,TRUE,FALSE,ox_intr);
249: hReset = CreateEvent(NULL,TRUE,FALSE,ox_reset);
250: hKill = CreateEvent(NULL,TRUE,FALSE,ox_kill);
251: sprintf(sock_id,"%d",bs);
252: av[0] = prog;
253: av[1] = sock_id;
254: av[2] = ox_intr;
255: av[3] = ox_reset;
256: av[4] = ox_kill;
257: av[5] = NULL;
258: Pget_rootdir(&rootdir);
259: sprintf(AsirExe,"%s\\bin\\engine.exe",BDY(rootdir));
260: hProc = _spawnv(_P_NOWAIT,AsirExe,av);
261: return (int)hProc;
262: #else /* VISUAL */
263: int b,s,i;
264: struct hostent *hp;
265: int pid;
266: char wname[BUFSIZ];
267: char buf[BUFSIZ];
268:
269: pid = fork();
270: if ( pid )
271: return pid;
272: else {
273: setpgid(0,getpid());
274: if ( dup2(bs,3) != 3 )
275: exit(1);
276: if ( dup2(bs,4) != 4 )
277: exit(1);
278: {
279: #if defined(linux) || defined(__NeXT__) || defined(ultrix)
280: #include <sys/param.h>
281: close(0);
282: for ( i = 5; i < NOFILE; i++ )
283: close(i);
284: #else
285: #include <sys/resource.h>
286: struct rlimit rl;
287:
288: getrlimit(RLIMIT_NOFILE,&rl);
289: close(0);
290: for ( i = 5; i < rl.rlim_cur; i++ )
291: close(i);
292: #endif
293: }
294: if ( strcmp(dname,"0") )
295: execl(prog,prog,"-display",dname,0);
296: else {
297: FILE *null;
298:
299: null = fopen("/dev/null","wb");
300: dup2(fileno(null),1);
301: dup2(fileno(null),2);
302: putenv("DISPLAY=");
303: execl(prog,prog,0);
304: }
305: }
306: #endif
307: }
308:
309: static void launch_error(s)
310: char *s;
311: {
312: exit(0);
313: }
314:
315: static int ox_io_init(sock)
316: int sock;
317: {
318: endian_init();
319: /* server mode */
320: sindex = get_iofp(sock,0,1);
321: asir_OperandStack = (Obj *)CALLOC(BUFSIZ,sizeof(Obj));
322: asir_OperandStackPtr = -1;
323: }
324:
325: static void push_one(obj)
326: Obj obj;
327: {
328: if ( !obj || OID(obj) != O_VOID )
329: asir_OperandStack[++asir_OperandStackPtr] = obj;
330: }
331:
332: static Obj pop_one() {
333: if ( asir_OperandStackPtr >= 0 ) {
334: return asir_OperandStack[asir_OperandStackPtr--];
335: }
336: }
337: