Annotation of parser3/src/main/pa_exec.C, revision 1.42
1.1 paf 1: /** @file
2: Parser: program executing for different OS-es.
3:
1.24 paf 4: Copyright(c) 2000,2001, 2002 ArtLebedev Group(http://www.artlebedev.com)
1.25 paf 5: Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
1.1 paf 6:
1.18 paf 7: @todo setrlimit
1.1 paf 8: */
1.38 paf 9:
1.42 ! paf 10: static const char* IDENT_EXEC_C="$Date: 2002/11/20 10:04:36 $";
1.1 paf 11:
12: #include "pa_config_includes.h"
13:
1.19 paf 14: #include "pa_exec.h"
15: #include "pa_exception.h"
16: #include "pa_common.h"
17:
1.1 paf 18: #ifdef WIN32
19: # include <windows.h>
20: #else
21: # include <signal.h>
22: # include <sys/types.h>
23: # include <sys/wait.h>
24: #endif
25:
26: #ifdef WIN32
27:
28: /// this func from http://www.ccas.ru/~posp/popov/spawn.htm
1.36 paf 29: static DWORD CreateHiddenConsoleProcess(LPCTSTR szCmdLine,
1.1 paf 30: char *szEnv,
31: PROCESS_INFORMATION* ppi,
32: LPHANDLE phInWrite,
33: LPHANDLE phOutRead,
1.9 parser 34: LPHANDLE phErrRead)
1.1 paf 35: {
1.36 paf 36: DWORD result=0;
37: BOOL fCreated;
1.1 paf 38: STARTUPINFO si;
39: SECURITY_ATTRIBUTES sa={0};
40: HANDLE hInRead;
41: HANDLE hOutWrite;
42: HANDLE hErrWrite;
43:
44: // Create pipes
45: // initialize security attributes for handle inheritance (for WinNT)
1.9 parser 46: sa.nLength=sizeof(sa);
47: sa.bInheritHandle=TRUE;
48: sa.lpSecurityDescriptor=NULL;
1.1 paf 49:
50: // create STDIN pipe
1.9 parser 51: if(!CreatePipe(&hInRead, phInWrite, &sa, 0))
1.1 paf 52: goto error;
53:
54: // create STDOUT pipe
1.9 parser 55: if(!CreatePipe(phOutRead, &hOutWrite, &sa, 0))
1.1 paf 56: goto error;
57:
58: // create STDERR pipe
1.9 parser 59: if(!CreatePipe(phErrRead, &hErrWrite, &sa, 0))
1.1 paf 60: goto error;
61:
62: // process startup information
1.9 parser 63: memset(&si, 0, sizeof(si));
64: si.cb=sizeof(si);
65: si.dwFlags=STARTF_USESHOWWINDOW | STARTF_USESTDHANDLES;
1.1 paf 66: // child process' console must be hidden for Win95 compatibility
1.9 parser 67: si.wShowWindow=SW_HIDE;
1.1 paf 68: // assign "other" sides of pipes
1.9 parser 69: si.hStdInput=hInRead;
70: si.hStdOutput=hOutWrite;
71: si.hStdError=hErrWrite;
1.1 paf 72:
1.31 paf 73: // calculating script's directory
74: char dir[MAX_STRING];
75: strncpy(dir, szCmdLine, MAX_STRING-1); dir[MAX_STRING-1]=0;
1.33 paf 76: lsplit(dir,' '); // trim arguments
1.31 paf 77: rsplit(dir,'/'); rsplit(dir,'\\'); // trim filename
78: chdir(dir);
79:
1.1 paf 80: // Create a child process (suspended)
1.9 parser 81: fCreated=CreateProcess(NULL,
1.26 paf 82: (LPTSTR)szCmdLine,
1.1 paf 83: NULL,
84: NULL,
85: TRUE,
1.30 paf 86: CREATE_NO_WINDOW,
1.1 paf 87: szEnv,
1.31 paf 88: dir,
1.1 paf 89: &si,
1.9 parser 90: ppi);
1.36 paf 91: if(!fCreated)
92: result=GetLastError();
1.1 paf 93:
1.9 parser 94: CloseHandle(hInRead);
95: CloseHandle(hOutWrite);
96: CloseHandle(hErrWrite);
1.1 paf 97:
1.9 parser 98: if(!fCreated)
1.1 paf 99: goto error;
100:
1.36 paf 101: return result;
1.1 paf 102:
103: error:
1.36 paf 104: if(!result/*yet*/)
105: result=GetLastError(); // get it
106:
1.9 parser 107: CloseHandle(*phInWrite);
108: CloseHandle(*phOutRead);
109: CloseHandle(*phErrRead);
1.1 paf 110:
1.36 paf 111: return result;
1.1 paf 112: }
113:
1.35 paf 114: static void read_pipe(String& result, HANDLE hOutRead, const char *file_spec,
115: String::Untaint_lang lang){
1.1 paf 116: while(true) {
117: char *buf=(char *)result.pool().malloc(MAX_STRING);
118: unsigned long size;
1.30 paf 119: if(!ReadFile(hOutRead, buf, MAX_STRING, &size, NULL) || !size)
1.1 paf 120: break;
1.35 paf 121: result.APPEND(buf, size, lang, file_spec, 0);
1.1 paf 122: }
123: }
124:
125:
126: static const char *buildCommand(Pool& pool,
127: const String& origin_string,
128: const char *file_spec_cstr, const Array *argv) {
1.8 parser 129: const char *result=file_spec_cstr;
1.4 paf 130: if(FILE *f=fopen(file_spec_cstr, "r")) {
1.1 paf 131: char buf[MAX_STRING];
132: size_t size=fread(buf, 1, MAX_STRING-1, f);
133: if(size>2) {
134: buf[size]=0;
135: if(strncmp(buf, "#!", 2)==0) {
1.4 paf 136: const char *begin=buf+2;
137: if(*begin==' ') // alx: were an old magic for some linux-es
138: begin++;
139: if(char *end=strchr(begin, '\n')) {
1.1 paf 140: String string(pool);
1.4 paf 141: string.APPEND_AS_IS(begin, end-begin,
1.1 paf 142: origin_string.origin().file, 0);
143: string << " " << file_spec_cstr;
1.8 parser 144: result=string.cstr();
1.1 paf 145: }
146: }
147: }
148: fclose(f);
149: }
1.8 parser 150: if(argv) {
151: String buf(pool);
152: buf << result;
153: for(int i=0; i<argv->size(); i++) {
154: buf << " ";
155: buf << *argv->get_string(i);
156: }
157:
1.16 paf 158: result=buf.cstr();
1.8 parser 159: }
160:
161: return result;
1.1 paf 162: }
163:
164: #else
165:
1.31 paf 166: static int execve_piped(const char *file_spec_cstr,
1.27 paf 167: char * const argv[], char * const env[],
168: int *pipe_in, int *pipe_out, int *pipe_err) {
1.1 paf 169: int pid;
170: int in_fds[2];
171: int out_fds[2];
172: int err_fds[2];
173: int save_errno;
174:
175: if(pipe_in && pipe(in_fds)<0) {
176: save_errno=errno;
177: errno=save_errno;
178: return 0;
179: }
180:
181: if(pipe_out && pipe(out_fds)<0) {
182: save_errno=errno;
183: if(pipe_in) {
184: close(in_fds[0]); close(in_fds[1]);
185: }
186: errno=save_errno;
187: return 0;
188: }
189:
190: if(pipe_err && pipe(err_fds)<0) {
191: save_errno=errno;
192: if(pipe_in) {
193: close(in_fds[0]); close(in_fds[1]);
194: }
195: if(pipe_out) {
196: close(out_fds[0]); close(out_fds[1]);
197: }
198: errno=save_errno;
199: return 0;
200: }
201:
202: if((pid=fork())<0) {
203: save_errno=errno;
204: if(pipe_in) {
205: close(in_fds[0]); close(in_fds[1]);
206: }
207: if(pipe_out) {
208: close(out_fds[0]); close(out_fds[1]);
209: }
210: if(pipe_err) {
211: close(err_fds[0]); close(err_fds[1]);
212: }
213: errno=save_errno;
214: return 0;
215: }
216:
217: if(!pid) {
218: /* Child process */
219:
220: if(pipe_out) {
221: close(out_fds[0]);
222: dup2(out_fds[1], STDOUT_FILENO);
223: close(out_fds[1]);
224: }
225:
226: if(pipe_in) {
227: close(in_fds[1]);
228: dup2(in_fds[0], STDIN_FILENO);
229: close(in_fds[0]);
230: }
231:
232: if(pipe_err) {
233: close(err_fds[0]);
234: dup2(err_fds[1], STDERR_FILENO);
235: close(err_fds[1]);
236: }
237:
1.42 ! paf 238: /* grabbed this from Apache source: */
! 239: /* HP-UX SIGCHLD fix goes here, if someone will remind me what it is... */
1.1 paf 240: signal(SIGCHLD, SIG_DFL); /* Was that it? */
241:
1.31 paf 242: // chdir to script's directory
243: char dir[MAX_STRING];
244: strncpy(dir, file_spec_cstr, MAX_STRING-1); dir[MAX_STRING-1]=0;
245: rsplit(dir,'/'); // trim filename
246: chdir(dir);
247:
248: // execute
249: execve(file_spec_cstr, argv, env);
1.1 paf 250: exit(-errno);
251: }
252:
253: /* Parent process */
254:
255: if(pipe_out) {
256: close(out_fds[1]);
257: *pipe_out=out_fds[0];
258: }
259:
260: if(pipe_in) {
261: close(in_fds[0]);
262: *pipe_in=in_fds[1];
263: }
264:
265: if(pipe_err) {
266: close(err_fds[1]);
267: *pipe_err=err_fds[0];
268: }
269:
270: return pid;
271: }
272:
273: static int get_exit_status(int pid) {
274: int status;
275: if(!waitpid(pid, &status, 0))
276: return -1;
277: return WIFEXITED(status) ?
278: WEXITSTATUS(status) : -2;
279: }
280:
1.35 paf 281: static void read_pipe(String& result, int file, const char *file_spec, String::Untaint_lang lang){
1.1 paf 282: while(true) {
1.2 paf 283: char *buf=(char *)result.pool().malloc(MAX_STRING);
1.40 paf 284: ssize_t size=read(file, buf, MAX_STRING);
285: if(size<=0)
1.1 paf 286: break;
1.35 paf 287: result.APPEND(buf, size, lang, file_spec, 0);
1.1 paf 288: }
289: }
290:
291: #endif
292:
1.30 paf 293: ///@test maybe here and at argv construction --- cstr(String::UL_UNSPECIFIED
1.1 paf 294: static void append_env_pair(const Hash::Key& key, Hash::Val *value, void *info) {
295: #ifdef WIN32
296: String& string=*static_cast<String *>(info);
297:
298: string << key << "=" << *static_cast<String *>(value);
1.3 paf 299: string.APPEND_AS_IS("", 1, 0, 0); // zero byte
1.1 paf 300: #else
301: String string(key.pool());
302: string << key << "=" << *static_cast<String *>(value);
303:
1.2 paf 304: char ***env_ref=static_cast<char ***>(info);
1.40 paf 305: **env_ref=string.cstr(String::UL_PASSAPPENED); (*env_ref)++;
1.1 paf 306: #endif
307: }
1.31 paf 308:
1.32 paf 309: int pa_exec(
310: bool forced_allow,
311: const String& file_spec,
1.1 paf 312: const Hash *env,
313: const Array *argv,
314: const String& in, String& out, String& err) {
315: Pool& pool=file_spec.pool();
316:
1.28 paf 317: #ifdef NO_PA_EXECS
1.32 paf 318: if(!forced_allow)
1.34 paf 319: throw Exception("parser.runtime",
1.32 paf 320: &file_spec,
321: "parser execs are disabled [recompile parser without --disable-execs configure option]");
322: #endif
1.28 paf 323:
1.1 paf 324: #ifdef WIN32
325:
326: PROCESS_INFORMATION pi;
327: HANDLE hInWrite, hOutRead, hErrRead;
1.12 parser 328: char *file_spec_cstr=file_spec.cstr(String::UL_FILE_SPEC);
1.1 paf 329: const char *cmd=buildCommand(file_spec.pool(), file_spec, file_spec_cstr, argv);
330: char *env_cstr=0;
331: if(env) {
332: String string(env->pool());
333: env->for_each(append_env_pair, &string);
1.16 paf 334: env_cstr=string.cstr();
1.1 paf 335: }
1.36 paf 336: if(DWORD error=CreateHiddenConsoleProcess(cmd, env_cstr, &pi, &hInWrite, &hOutRead, &hErrRead)) {
337: char szErrorDesc[MAX_STRING];
338: char *param="the file you tried to run";
339: size_t error_size=FormatMessage(
340: FORMAT_MESSAGE_FROM_SYSTEM|FORMAT_MESSAGE_ARGUMENT_ARRAY , NULL, error,
341: MAKELANGID(LANG_NEUTRAL, SUBLANG_NEUTRAL),
342: szErrorDesc, sizeof(szErrorDesc), ¶m);
343: if(error_size>3) // ".\r\n"
344: szErrorDesc[error_size-3]=0;
345:
346: throw Exception(0,
347: &file_spec,
348: "exec failed - %s (%ld). Consider adding shbang line (#!x:\\interpreter\\command line)",
349: error_size?szErrorDesc:"<unknown>", (long)error);
350: } else {
1.16 paf 351: const char *in_cstr=in.cstr();
1.5 paf 352: DWORD written_size;
353: WriteFile(hInWrite, in_cstr, in.size(), &written_size, NULL);
354: // EOF for stupid text reads
355: // normally they should read CONTENT_LENGTH bytes,
356: // without this char
357: WriteFile(hInWrite, "\x1A", 1, &written_size, NULL);
1.9 parser 358: CloseHandle(hInWrite);
1.35 paf 359: read_pipe(out, hOutRead, file_spec_cstr, String::UL_AS_IS);
1.9 parser 360: CloseHandle(hOutRead);
1.35 paf 361: read_pipe(err, hErrRead, file_spec_cstr, String::UL_TAINTED);
1.9 parser 362: CloseHandle(hErrRead);
1.1 paf 363: /*
364: from http://www.apache.org/websrc/cvsweb.cgi/apache-1.3/src/main/util_script.c?rev=1.151&content-type=text/vnd.viewcvs-markup
365:
366: * We must close the handles to the new process and its main thread
367: * to prevent handle and memory leaks.
368: */
369: CloseHandle(pi.hProcess);
370: CloseHandle(pi.hThread);
371: }
372:
373: #else
374:
375: int pipe_write, pipe_read, pipe_err;
1.27 paf 376: char *file_spec_cstr=file_spec.cstr(String::UL_FILE_SPEC);
1.31 paf 377:
378: #ifdef NO_FOREIGN_GROUP_FILES
1.32 paf 379: if(!forced_allow) {
380: struct stat finfo;
381: if(stat(file_spec_cstr, &finfo)!=0)
1.34 paf 382: throw Exception("file.missing",
1.32 paf 383: &file_spec,
384: "stat failed: %s (%d), actual filename '%s'",
385: strerror(errno), errno, file_spec_cstr);
1.31 paf 386:
1.32 paf 387: if(finfo.st_gid/*foreign?*/!=getegid())
1.34 paf 388: throw Exception("parser.runtime",
1.32 paf 389: &file_spec,
390: "parser executing files of foreign group is disabled [recompile parser without --disable-foreign-group-files configure option], actual filename '%s'",
391: file_spec_cstr);
392: }
1.31 paf 393: #endif
394:
1.27 paf 395: char *argv_cstrs[1+10+1]={file_spec_cstr, 0};
1.1 paf 396: if(argv) {
1.20 paf 397: const int argv_size=argv->size();
1.27 paf 398: const int argv_max=sizeof(argv_cstrs)/sizeof(argv_cstrs[0])-1-1;
1.20 paf 399: if(argv_size>argv_max)
1.34 paf 400: throw Exception("parser.runtime",
1.20 paf 401: &file_spec,
402: "too many arguments (%d > max %d)", argv_size, argv_max);
403: for(int i=0; i<argv_size; i++)
1.27 paf 404: argv_cstrs[1+i]=argv->get_string(i)->cstr();
405: argv_cstrs[1+argv_size]=0;
1.1 paf 406: }
1.2 paf 407: char **env_cstrs=0;
1.1 paf 408: if(env) {
1.2 paf 409: env_cstrs=
1.1 paf 410: (char **)env->pool().malloc(sizeof(char *)*(env->size()+1/*0*/));
1.2 paf 411: char **env_ref=env_cstrs;
412: env->for_each(append_env_pair, &env_ref);
413: *env_ref=0;
1.1 paf 414: }
1.31 paf 415:
1.27 paf 416: int pid=execve_piped(
1.1 paf 417: file_spec_cstr,
1.27 paf 418: argv_cstrs, env_cstrs,
1.22 paf 419: &pipe_write, &pipe_read, &pipe_err);
1.21 paf 420: if(pid) {
421: // in child
1.16 paf 422: const char *in_cstr=in.cstr();
1.41 paf 423: if(*in) // there is some in data
424: write(pipe_write, in_cstr, in.size());
1.1 paf 425: close(pipe_write);
1.35 paf 426: read_pipe(out, pipe_read, file_spec_cstr, String::UL_AS_IS);
1.5 paf 427: close(pipe_read);
1.35 paf 428: read_pipe(err, pipe_err, file_spec_cstr, String::UL_TAINTED);
1.1 paf 429: close(pipe_err);
430:
431: return get_exit_status(pid); // negative may mean "-errno[execl()]"
432: } else
1.34 paf 433: throw Exception(0,
1.2 paf 434: &file_spec,
1.1 paf 435: "pipe error");
436: #endif
437:
438: return 0;
439: }
E-mail:
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to pa_exec.C CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [parser3project] / parser3 / src / main