Annotation of OpenXM_contrib2/asir2000/builtin/batch.c, Revision 1.1.1.1
1.1 noro 1: /* $OpenXM: OpenXM/src/asir99/builtin/batch.c,v 1.1.1.1 1999/11/10 08:12:25 noro Exp $ */
2: #if !defined(VISUAL)
3:
4: #include <stdio.h>
5: #include <stdlib.h>
6:
7: int exec_file(char *bindir,char *fname) {
8: char command[BUFSIZ*5];
9: int status;
10:
11: sprintf(command,"%s/asir -f %s",bindir,fname);
12: status = system(command);
13: return status;
14: }
15:
16: #else
17:
18: #include <windows.h>
19: #include <stdlib.h>
20: #include <stdio.h>
21: #include <io.h>
22: #include <fcntl.h>
23: #include <process.h>
24:
25: static void read_until_eof();
26:
27: static HANDLE hRead,hWrite,hNotify,hNotify_Ack,hIntr,hIntr_Ack,hKill,hProc;
28:
29: int exec_file(char *bindir,char *fname) {
30: int i;
31: char *av[BUFSIZ];
32: char AsirExe[BUFSIZ];
33: DWORD tid,mypid,pid,len;
34: HANDLE hR0,hW0,hR1,hW1;
35: SECURITY_ATTRIBUTES SecurityAttributes;
36: char remread[10],remwrite[10];
37: char notify[100],notify_ack[100],intr[100],intr_ack[100],kill[100];
38:
39: mypid = GetCurrentProcessId();
40: sprintf(notify,"asir_notify_%d",mypid);
41: sprintf(notify_ack,"asir_ack_%d",mypid);
42: sprintf(intr,"asir_intr_%d",mypid);
43: sprintf(intr_ack,"asir_intr_ack_%d",mypid);
44: sprintf(kill,"asir_kill_%d",mypid);
45: hNotify = CreateEvent(NULL,TRUE,FALSE,notify);
46: hNotify_Ack = CreateEvent(NULL,TRUE,FALSE,notify_ack);
47: hIntr = CreateEvent(NULL,TRUE,FALSE,intr);
48: hIntr_Ack = CreateEvent(NULL,TRUE,FALSE,intr_ack);
49: hKill = CreateEvent(NULL,TRUE,FALSE,kill);
50:
51: SecurityAttributes.nLength = sizeof(SecurityAttributes);
52: SecurityAttributes.lpSecurityDescriptor = NULL;
53: SecurityAttributes.bInheritHandle = TRUE;
54: CreatePipe(&hR0, &hW0, &SecurityAttributes, 65536);
55: CreatePipe(&hR1, &hW1, &SecurityAttributes, 65536);
56:
57: hRead = hR0;
58: hWrite = hW1;
59: sprintf(remread,"%d",(DWORD)hR1);
60: sprintf(remwrite,"%d",(DWORD)hW0);
61:
62: sprintf(AsirExe,"%s\\engine.exe",bindir);
63: _setargv();
64: av[0] = "asir";
65: av[1] = remread;
66: av[2] = remwrite;
67: av[3] = notify;
68: av[4] = notify_ack;
69: av[5] = intr;
70: av[6] = intr_ack;
71: av[7] = kill;
72: av[8] = "-norc";
73: av[9] = "-f";
74: av[10] = fname;
75: av[11] = NULL;
76: hProc = (HANDLE)_spawnv(_P_NOWAIT,AsirExe,av);
77: if ( hProc == (HANDLE)-1 ) {
78: fprintf(stderr,"%s がありません",AsirExe);
79: return 0;
80: }
81: read_until_eof();
82: return 1;
83: }
84:
85: int doing_batch = 0;
86: static char insert_buf[BUFSIZ*10];
87: static int insert_buf_len = 0;
88:
89: static void read_until_eof()
90: {
91: char *p;
92: DWORD len;
93: unsigned int cmdsize,cmd,size;
94:
95: doing_batch = 1;
96: while ( 1 ) {
97: WaitForSingleObject(hNotify,(DWORD)-1);
98: ResetEvent(hNotify);
99: SetEvent(hNotify_Ack);
100: ReadFile(hRead,&cmdsize,sizeof(unsigned int),&len,NULL);
101: cmd = cmdsize>>16;
102: size = cmdsize&0xffff;
103: if ( !cmd ) {
104: doing_batch = 0;
105: return;
106: } else if ( size )
107: ReadFile(hRead,insert_buf,size,&len,NULL);
108: }
109: }
110:
111: void send_intr() {
112: PulseEvent(hIntr);
113: }
114:
115: void terminate_batch() {
116: TerminateProcess(hProc,0);
117: }
118: #endif /* VISUAL */
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>