spawn.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983
  1. /**
  2. * \file spawn.c
  3. *
  4. * \brief GIS Library - Handles process spawning.
  5. *
  6. * (C) 2001-2008 by the GRASS Development Team
  7. *
  8. * This program is free software under the GNU General Public License
  9. * (>=v2). Read the file COPYING that comes with GRASS for details.
  10. *
  11. * \author Glynn Clements
  12. *
  13. * \date 2004-2006
  14. */
  15. #include <stdio.h>
  16. #include <stdlib.h>
  17. #include <string.h>
  18. #include <signal.h>
  19. #include <stdarg.h>
  20. #include <unistd.h>
  21. #include <fcntl.h>
  22. #include <errno.h>
  23. #include <sys/types.h>
  24. #ifndef __MINGW32__
  25. #include <sys/wait.h>
  26. #else
  27. #include <windows.h>
  28. #endif
  29. #include <grass/config.h>
  30. #include <grass/gis.h>
  31. #include <grass/glocale.h>
  32. #include <grass/spawn.h>
  33. /** \def MAX_ARGS Maximum number of arguments */
  34. /** \def MAX_BINDINGS Maximum number of bindings */
  35. /** \def MAX_SIGNALS Maximum number of signals */
  36. /** \def MAX_REDIRECTS Maximum number of redirects */
  37. #define MAX_ARGS 256
  38. #define MAX_BINDINGS 256
  39. #define MAX_SIGNALS 32
  40. #define MAX_REDIRECTS 32
  41. /**
  42. * \brief Spawns a new process.
  43. *
  44. * A more useful alternative to G_system(), which takes the
  45. * arguments of <b>command</b> as parameters.
  46. *
  47. * \param[in] command command to execute
  48. * \return -1 on error
  49. * \return process status on success
  50. */
  51. struct redirect
  52. {
  53. int dst_fd;
  54. int src_fd;
  55. const char *file;
  56. int mode;
  57. };
  58. struct signal
  59. {
  60. int which;
  61. int action;
  62. int signum;
  63. int valid;
  64. #ifndef __MINGW32__
  65. struct sigaction old_act;
  66. sigset_t old_mask;
  67. #endif
  68. };
  69. struct binding
  70. {
  71. const char *var;
  72. const char *val;
  73. };
  74. struct spawn
  75. {
  76. const char *args[MAX_ARGS];
  77. int num_args;
  78. struct redirect redirects[MAX_REDIRECTS];
  79. int num_redirects;
  80. struct signal signals[MAX_SIGNALS];
  81. int num_signals;
  82. struct binding bindings[MAX_BINDINGS];
  83. int num_bindings;
  84. int background;
  85. const char *directory;
  86. };
  87. static void parse_arglist(struct spawn *sp, va_list va);
  88. static void parse_argvec(struct spawn *sp, const char **va);
  89. #ifdef __MINGW32__
  90. struct buffer {
  91. char *str;
  92. size_t len;
  93. size_t size;
  94. };
  95. static const int INCREMENT = 50;
  96. static void clear(struct buffer *b)
  97. {
  98. b->len = 0;
  99. b->str[b->len] = '\0';
  100. }
  101. static void init(struct buffer *b)
  102. {
  103. b->str = G_malloc(1);
  104. b->size = 1;
  105. clear(b);
  106. }
  107. static char *release(struct buffer *b)
  108. {
  109. char *p = b->str;
  110. b->str = NULL;
  111. b->size = 0;
  112. b->len = 0;
  113. return p;
  114. }
  115. static void finish(struct buffer *b)
  116. {
  117. if (b->str)
  118. G_free(b->str);
  119. release(b);
  120. }
  121. static void ensure(struct buffer *b, size_t n)
  122. {
  123. if (b->size <= b->len + n + 1) {
  124. b->size = b->len + n + INCREMENT;
  125. b->str = G_realloc(b->str, b->size);
  126. }
  127. }
  128. static void append(struct buffer *b, const char *str)
  129. {
  130. size_t n = strlen(str);
  131. ensure(b, n);
  132. memcpy(&b->str[b->len], str, n);
  133. b->len += n;
  134. b->str[b->len] = '\0';
  135. }
  136. static void append_char(struct buffer *b, char c)
  137. {
  138. ensure(b, 1);
  139. b->str[b->len] = c;
  140. b->len++;
  141. b->str[b->len] = '\0';
  142. }
  143. static void escape_arg(struct buffer *result, const char *arg)
  144. {
  145. struct buffer buf;
  146. int quote, j;
  147. init(&buf);
  148. quote = arg[0] == '\0' || strchr(arg, ' ') || strchr(arg, '\t');
  149. if (quote)
  150. append_char(result, '\"');
  151. for (j = 0; arg[j]; j++) {
  152. int c = arg[j];
  153. int k;
  154. switch (c) {
  155. case '\\':
  156. append_char(&buf, '\\');
  157. break;
  158. case '\"':
  159. for (k = 0; k < buf.len; k++)
  160. append(result, "\\\\");
  161. clear(&buf);
  162. append(result, "\\\"");
  163. break;
  164. default:
  165. if (buf.len > 0) {
  166. append(result, buf.str);
  167. clear(&buf);
  168. }
  169. append_char(result, c);
  170. }
  171. }
  172. if (buf.len > 0)
  173. append(result, buf.str);
  174. if (quote) {
  175. append(result, buf.str);
  176. append_char(result, '\"');
  177. }
  178. finish(&buf);
  179. }
  180. static char *check_program(const char *pgm, const char *dir, const char *ext)
  181. {
  182. char pathname[GPATH_MAX];
  183. sprintf(pathname, "%s%s%s%s", dir, *dir ? "\\" : "", pgm, ext);
  184. return access(pathname, 0) == 0
  185. ? G_store(pathname)
  186. : NULL;
  187. }
  188. static char *find_program_ext(const char *pgm, const char *dir, char **pathext)
  189. {
  190. char *result;
  191. int i;
  192. if (result = check_program(pgm, dir, ""), result)
  193. return result;
  194. for (i = 0; pathext[i]; i++) {
  195. const char *ext = pathext[i];
  196. if (result = check_program(pgm, dir, ext), result)
  197. return result;
  198. }
  199. return NULL;
  200. }
  201. static char *find_program_dir_ext(const char *pgm, char **path, char **pathext)
  202. {
  203. char *result = NULL;
  204. int i;
  205. if (strchr(pgm, '\\') || strchr(pgm, '/')) {
  206. if (result = find_program_ext(pgm, "", pathext), result)
  207. return result;
  208. }
  209. else {
  210. if (result = find_program_ext(pgm, ".", pathext), result)
  211. return result;
  212. for (i = 0; path[i]; i++) {
  213. const char *dir = path[i];
  214. if (result = find_program_ext(pgm, dir, pathext), result)
  215. return result;
  216. }
  217. }
  218. return NULL;
  219. }
  220. static char *find_program(const char *pgm)
  221. {
  222. char **path = G_tokenize(getenv("PATH"), ";");
  223. char **pathext = G_tokenize(getenv("PATHEXT"), ";");
  224. char *result = find_program_dir_ext(pgm, path, pathext);
  225. G_free_tokens(path);
  226. G_free_tokens(pathext);
  227. return result;
  228. }
  229. static char *make_command_line(int shell, const char *cmd, const char **argv)
  230. {
  231. struct buffer result;
  232. int i;
  233. init(&result);
  234. if (shell) {
  235. const char *comspec = getenv("COMSPEC");
  236. append(&result, comspec ? comspec : "cmd.exe");
  237. append(&result, " /c \"");
  238. escape_arg(&result, cmd);
  239. }
  240. for (i = shell ? 1 : 0; argv[i]; i++) {
  241. if (result.len > 0)
  242. append_char(&result, ' ');
  243. escape_arg(&result, argv[i]);
  244. }
  245. append(&result, "\"");
  246. return release(&result);
  247. }
  248. static char *make_environment(const char **envp)
  249. {
  250. struct buffer result;
  251. int i;
  252. init(&result);
  253. for (i = 0; envp[i]; i++) {
  254. const char *env = envp[i];
  255. append(&result, env);
  256. append_char(&result, '\0');
  257. }
  258. return release(&result);
  259. }
  260. static HANDLE get_handle(int fd)
  261. {
  262. HANDLE h1, h2;
  263. if (fd < 0)
  264. return INVALID_HANDLE_VALUE;
  265. h1 = (HANDLE) _get_osfhandle(fd);
  266. if (!DuplicateHandle(GetCurrentProcess(), h1,
  267. GetCurrentProcess(), &h2,
  268. 0, TRUE, DUPLICATE_SAME_ACCESS))
  269. return INVALID_HANDLE_VALUE;
  270. return h2;
  271. }
  272. static int win_spawn(const char *cmd, const char **argv, const char **envp,
  273. const char *cwd, HANDLE handles[3], int background,
  274. int shell)
  275. {
  276. char *args = make_command_line(shell, cmd, argv);
  277. char *env = make_environment(envp);
  278. char *program = shell ? NULL : find_program(cmd);
  279. STARTUPINFO si;
  280. PROCESS_INFORMATION pi;
  281. BOOL result;
  282. DWORD exitcode;
  283. if (!shell) {
  284. G_debug(3, "win_spawn: program = %s", program);
  285. if (!program) {
  286. G_free(args);
  287. G_free(env);
  288. return -1;
  289. }
  290. }
  291. G_debug(3, "win_spawn: args = %s", args);
  292. memset(&si, 0, sizeof(si));
  293. si.cb = sizeof(si);
  294. si.dwFlags |= STARTF_USESTDHANDLES;
  295. si.hStdInput = handles[0];
  296. si.hStdOutput = handles[1];
  297. si.hStdError = handles[2];
  298. result = CreateProcess(
  299. program, /* lpApplicationName */
  300. args, /* lpCommandLine */
  301. NULL, /* lpProcessAttributes */
  302. NULL, /* lpThreadAttributes */
  303. 1, /* bInheritHandles */
  304. 0, /* dwCreationFlags */
  305. env, /* lpEnvironment */
  306. cwd, /* lpCurrentDirectory */
  307. &si, /* lpStartupInfo */
  308. &pi /* lpProcessInformation */
  309. );
  310. G_free(args);
  311. G_free(env);
  312. G_free(program);
  313. if (!result) {
  314. G_warning(_("CreateProcess() failed: error = %d"), GetLastError());
  315. return -1;
  316. }
  317. CloseHandle(pi.hThread);
  318. if (!background) {
  319. WaitForSingleObject(pi.hProcess, INFINITE);
  320. if (!GetExitCodeProcess(pi.hProcess, &exitcode))
  321. return -1;
  322. CloseHandle(pi.hProcess);
  323. return (int) exitcode;
  324. }
  325. CloseHandle(pi.hProcess);
  326. return pi.dwProcessId;
  327. }
  328. static void do_redirects(struct redirect *redirects, int num_redirects, HANDLE handles[3])
  329. {
  330. int i;
  331. for (i = 0; i < 3; i++)
  332. handles[i] = get_handle(i);
  333. for (i = 0; i < num_redirects; i++) {
  334. struct redirect *r = &redirects[i];
  335. if (r->dst_fd < 0 || r->dst_fd > 2) {
  336. G_warning(_("G_spawn: unable to redirect descriptor %d"), r->dst_fd);
  337. continue;
  338. }
  339. if (r->file) {
  340. r->src_fd = open(r->file, r->mode, 0666);
  341. if (r->src_fd < 0) {
  342. G_warning(_("G_spawn: unable to open file %s"), r->file);
  343. _exit(127);
  344. }
  345. handles[r->dst_fd] = get_handle(r->src_fd);
  346. close(r->src_fd);
  347. }
  348. else if (r->src_fd >= 0) {
  349. handles[r->dst_fd] = get_handle(r->src_fd);
  350. }
  351. else
  352. handles[r->dst_fd] = INVALID_HANDLE_VALUE;
  353. }
  354. }
  355. static void add_binding(const char **env, int *pnum, const struct binding *b)
  356. {
  357. char *str = G_malloc(strlen(b->var) + strlen(b->val) + 2);
  358. int n = *pnum;
  359. int i;
  360. sprintf(str, "%s=%s", b->var, b->val);
  361. for (i = 0; i < n; i++)
  362. if (G_strcasecmp(env[i], b->var) == 0) {
  363. env[i] = str;
  364. return;
  365. }
  366. env[n++] = str;
  367. *pnum = n;
  368. }
  369. static const char **do_bindings(const struct binding *bindings, int num_bindings)
  370. {
  371. const char **newenv;
  372. int i, n;
  373. for (i = 0; _environ[i]; i++)
  374. ;
  375. n = i;
  376. newenv = G_malloc((num_bindings + n + 1) * sizeof(char *));
  377. for (i = 0; i < n; i++)
  378. newenv[i] = _environ[i];
  379. for (i = 0; i < num_bindings; i++)
  380. add_binding(newenv, &n, &bindings[i]);
  381. newenv[num_bindings + n] = NULL;
  382. return newenv;
  383. }
  384. static int do_spawn(struct spawn *sp, const char *command)
  385. {
  386. HANDLE handles[3];
  387. const char **env;
  388. int status;
  389. do_redirects(sp->redirects, sp->num_redirects, handles);
  390. env = do_bindings(sp->bindings, sp->num_bindings);
  391. status = win_spawn(command, sp->args, env, sp->directory, handles, sp->background, 1);
  392. if (!sp->background && status < 0)
  393. G_warning(_("Unable to execute command"));
  394. return status;
  395. }
  396. #else /* __MINGW32__ */
  397. static int undo_signals(const struct signal *signals, int num_signals, int which)
  398. {
  399. int error = 0;
  400. int i;
  401. for (i = num_signals - 1; i >= 0; i--) {
  402. const struct signal *s = &signals[i];
  403. if (s->which != which)
  404. continue;
  405. if (!s->valid)
  406. continue;
  407. switch (s->action) {
  408. case SSA_IGNORE:
  409. case SSA_DEFAULT:
  410. if (sigaction(s->signum, &s->old_act, NULL) < 0) {
  411. G_warning(_("G_spawn: unable to restore signal %d"),
  412. s->signum);
  413. error = 1;
  414. }
  415. break;
  416. case SSA_BLOCK:
  417. case SSA_UNBLOCK:
  418. if (sigprocmask(SIG_UNBLOCK, &s->old_mask, NULL) < 0) {
  419. G_warning(_("G_spawn: unable to restore signal %d"),
  420. s->signum);
  421. error = 1;
  422. }
  423. break;
  424. }
  425. }
  426. return !error;
  427. }
  428. static int do_signals(struct signal *signals, int num_signals, int which)
  429. {
  430. struct sigaction act;
  431. sigset_t mask;
  432. int error = 0;
  433. int i;
  434. sigemptyset(&act.sa_mask);
  435. act.sa_flags = SA_RESTART;
  436. for (i = 0; i < num_signals; i++) {
  437. struct signal *s = &signals[i];
  438. if (s->which != which)
  439. continue;
  440. switch (s->action) {
  441. case SSA_IGNORE:
  442. act.sa_handler = SIG_IGN;
  443. if (sigaction(s->signum, &act, &s->old_act) < 0) {
  444. G_warning(_("G_spawn: unable to reset signal %d"), s->signum);
  445. error = 1;
  446. }
  447. else
  448. s->valid = 1;
  449. break;
  450. case SSA_DEFAULT:
  451. act.sa_handler = SIG_DFL;
  452. if (sigaction(s->signum, &act, &s->old_act) < 0) {
  453. G_warning(_("G_spawn: unable to ignore signal %d"),
  454. s->signum);
  455. error = 1;
  456. }
  457. else
  458. s->valid = 1;
  459. break;
  460. case SSA_BLOCK:
  461. sigemptyset(&mask);
  462. sigaddset(&mask, s->signum);
  463. if (sigprocmask(SIG_BLOCK, &mask, &s->old_mask) < 0) {
  464. G_warning(_("G_spawn: unable to block signal %d"), s->signum);
  465. error = 1;
  466. }
  467. break;
  468. case SSA_UNBLOCK:
  469. sigemptyset(&mask);
  470. sigaddset(&mask, s->signum);
  471. if (sigprocmask(SIG_UNBLOCK, &mask, &s->old_mask) < 0) {
  472. G_warning(_("G_spawn: unable to unblock signal %d"),
  473. s->signum);
  474. error = 1;
  475. }
  476. else
  477. s->valid = 1;
  478. break;
  479. }
  480. }
  481. return !error;
  482. }
  483. static void do_redirects(struct redirect *redirects, int num_redirects)
  484. {
  485. int i;
  486. for (i = 0; i < num_redirects; i++) {
  487. struct redirect *r = &redirects[i];
  488. if (r->file) {
  489. r->src_fd = open(r->file, r->mode, 0666);
  490. if (r->src_fd < 0) {
  491. G_warning(_("G_spawn: unable to open file %s"), r->file);
  492. _exit(127);
  493. }
  494. if (dup2(r->src_fd, r->dst_fd) < 0) {
  495. G_warning(_("G_spawn: unable to duplicate descriptor %d to %d"),
  496. r->src_fd, r->dst_fd);
  497. _exit(127);
  498. }
  499. close(r->src_fd);
  500. }
  501. else if (r->src_fd >= 0) {
  502. if (dup2(r->src_fd, r->dst_fd) < 0) {
  503. G_warning(_("G_spawn: unable to duplicate descriptor %d to %d"),
  504. r->src_fd, r->dst_fd);
  505. _exit(127);
  506. }
  507. }
  508. else
  509. close(r->dst_fd);
  510. }
  511. }
  512. static void do_bindings(const struct binding *bindings, int num_bindings)
  513. {
  514. int i;
  515. for (i = 0; i < num_bindings; i++) {
  516. const struct binding *b = &bindings[i];
  517. char *str = G_malloc(strlen(b->var) + strlen(b->val) + 2);
  518. sprintf(str, "%s=%s", b->var, b->val);
  519. putenv(str);
  520. }
  521. }
  522. static int do_spawn(struct spawn *sp, const char *command)
  523. {
  524. int status = -1;
  525. pid_t pid;
  526. if (!do_signals(sp->signals, sp->num_signals, SST_PRE))
  527. return status;
  528. pid = fork();
  529. if (pid < 0) {
  530. G_warning(_("Unable to create a new process"));
  531. undo_signals(sp->signals, sp->num_signals, SST_PRE);
  532. return status;
  533. }
  534. if (pid == 0) {
  535. if (!undo_signals(sp->signals, sp->num_signals, SST_PRE))
  536. _exit(127);
  537. if (!do_signals(sp->signals, sp->num_signals, SST_CHILD))
  538. _exit(127);
  539. if (sp->directory)
  540. if (chdir(sp->directory) < 0) {
  541. G_warning(_("Unable to change directory to %s"), sp->directory);
  542. _exit(127);
  543. }
  544. do_redirects(sp->redirects, sp->num_redirects);
  545. do_bindings(sp->bindings, sp->num_bindings);
  546. execvp(command, (char **)sp->args);
  547. G_warning(_("Unable to execute command"));
  548. _exit(127);
  549. }
  550. do_signals(sp->signals, sp->num_signals, SST_POST);
  551. if (sp->background)
  552. status = (int)pid;
  553. else {
  554. pid_t n;
  555. do
  556. n = waitpid(pid, &status, 0);
  557. while (n == (pid_t) - 1 && errno == EINTR);
  558. if (n != pid)
  559. status = -1;
  560. else {
  561. if (WIFEXITED(status))
  562. status = WEXITSTATUS(status);
  563. else if (WIFSIGNALED(status))
  564. status = WTERMSIG(status);
  565. else
  566. status = -0x100;
  567. }
  568. }
  569. undo_signals(sp->signals, sp->num_signals, SST_POST);
  570. undo_signals(sp->signals, sp->num_signals, SST_PRE);
  571. return status;
  572. }
  573. #endif /* __MINGW32__ */
  574. static void begin_spawn(struct spawn *sp)
  575. {
  576. sp->num_args = 0;
  577. sp->num_redirects = 0;
  578. sp->num_signals = 0;
  579. sp->num_bindings = 0;
  580. sp->background = 0;
  581. sp->directory = NULL;
  582. }
  583. #define NEXT_ARG(var, type) ((type) *(var)++)
  584. static void parse_argvec(struct spawn *sp, const char **va)
  585. {
  586. for (;;) {
  587. const char *arg = NEXT_ARG(va, const char *);
  588. const char *var, *val;
  589. if (!arg) {
  590. sp->args[sp->num_args++] = NULL;
  591. break;
  592. }
  593. else if (arg == SF_REDIRECT_FILE) {
  594. sp->redirects[sp->num_redirects].dst_fd = NEXT_ARG(va, int);
  595. sp->redirects[sp->num_redirects].src_fd = -1;
  596. sp->redirects[sp->num_redirects].mode = NEXT_ARG(va, int);
  597. sp->redirects[sp->num_redirects].file = NEXT_ARG(va, const char *);
  598. sp->num_redirects++;
  599. }
  600. else if (arg == SF_REDIRECT_DESCRIPTOR) {
  601. sp->redirects[sp->num_redirects].dst_fd = NEXT_ARG(va, int);
  602. sp->redirects[sp->num_redirects].src_fd = NEXT_ARG(va, int);
  603. sp->redirects[sp->num_redirects].file = NULL;
  604. sp->num_redirects++;
  605. }
  606. else if (arg == SF_CLOSE_DESCRIPTOR) {
  607. sp->redirects[sp->num_redirects].dst_fd = NEXT_ARG(va, int);
  608. sp->redirects[sp->num_redirects].src_fd = -1;
  609. sp->redirects[sp->num_redirects].file = NULL;
  610. sp->num_redirects++;
  611. }
  612. else if (arg == SF_SIGNAL) {
  613. sp->signals[sp->num_signals].which = NEXT_ARG(va, int);
  614. sp->signals[sp->num_signals].action = NEXT_ARG(va, int);
  615. sp->signals[sp->num_signals].signum = NEXT_ARG(va, int);
  616. sp->signals[sp->num_signals].valid = 0;
  617. sp->num_signals++;
  618. }
  619. else if (arg == SF_VARIABLE) {
  620. var = NEXT_ARG(va, const char *);
  621. val = getenv(var);
  622. sp->args[sp->num_args++] = val ? val : "";
  623. }
  624. else if (arg == SF_BINDING) {
  625. sp->bindings[sp->num_bindings].var = NEXT_ARG(va, const char *);
  626. sp->bindings[sp->num_bindings].val = NEXT_ARG(va, const char *);
  627. sp->num_bindings++;
  628. }
  629. else if (arg == SF_BACKGROUND) {
  630. sp->background = 1;
  631. }
  632. else if (arg == SF_DIRECTORY) {
  633. sp->directory = NEXT_ARG(va, const char *);
  634. }
  635. else if (arg == SF_ARGVEC) {
  636. parse_argvec(sp, NEXT_ARG(va, const char **));
  637. }
  638. else
  639. sp->args[sp->num_args++] = arg;
  640. }
  641. }
  642. static void parse_arglist(struct spawn *sp, va_list va)
  643. {
  644. for (;;) {
  645. const char *arg = va_arg(va, const char *);
  646. const char *var, *val;
  647. if (!arg) {
  648. sp->args[sp->num_args++] = NULL;
  649. break;
  650. }
  651. else if (arg == SF_REDIRECT_FILE) {
  652. sp->redirects[sp->num_redirects].dst_fd = va_arg(va, int);
  653. sp->redirects[sp->num_redirects].src_fd = -1;
  654. sp->redirects[sp->num_redirects].mode = va_arg(va, int);
  655. sp->redirects[sp->num_redirects].file = va_arg(va, const char *);
  656. sp->num_redirects++;
  657. }
  658. else if (arg == SF_REDIRECT_DESCRIPTOR) {
  659. sp->redirects[sp->num_redirects].dst_fd = va_arg(va, int);
  660. sp->redirects[sp->num_redirects].src_fd = va_arg(va, int);
  661. sp->redirects[sp->num_redirects].file = NULL;
  662. sp->num_redirects++;
  663. }
  664. else if (arg == SF_CLOSE_DESCRIPTOR) {
  665. sp->redirects[sp->num_redirects].dst_fd = va_arg(va, int);
  666. sp->redirects[sp->num_redirects].src_fd = -1;
  667. sp->redirects[sp->num_redirects].file = NULL;
  668. sp->num_redirects++;
  669. }
  670. else if (arg == SF_SIGNAL) {
  671. sp->signals[sp->num_signals].which = va_arg(va, int);
  672. sp->signals[sp->num_signals].action = va_arg(va, int);
  673. sp->signals[sp->num_signals].signum = va_arg(va, int);
  674. sp->signals[sp->num_signals].valid = 0;
  675. sp->num_signals++;
  676. }
  677. else if (arg == SF_VARIABLE) {
  678. var = va_arg(va, char *);
  679. val = getenv(var);
  680. sp->args[sp->num_args++] = val ? val : "";
  681. }
  682. else if (arg == SF_BINDING) {
  683. sp->bindings[sp->num_bindings].var = va_arg(va, const char *);
  684. sp->bindings[sp->num_bindings].val = va_arg(va, const char *);
  685. sp->num_bindings++;
  686. }
  687. else if (arg == SF_BACKGROUND) {
  688. sp->background = 1;
  689. }
  690. else if (arg == SF_DIRECTORY) {
  691. sp->directory = va_arg(va, const char *);
  692. }
  693. else if (arg == SF_ARGVEC) {
  694. parse_argvec(sp, va_arg(va, const char **));
  695. }
  696. else
  697. sp->args[sp->num_args++] = arg;
  698. }
  699. }
  700. /**
  701. * \brief Spawn new process based on <b>command</b>.
  702. *
  703. * This is a more advanced version of G_spawn().
  704. *
  705. * \param[in] command
  706. * \param[in] args arguments
  707. * \return -1 on error
  708. * \return process status on success
  709. */
  710. int G_vspawn_ex(const char *command, const char **args)
  711. {
  712. struct spawn sp;
  713. begin_spawn(&sp);
  714. parse_argvec(&sp, args);
  715. return do_spawn(&sp, command);
  716. }
  717. /**
  718. * \brief Spawn new process based on <b>command</b>.
  719. *
  720. * This is a more advanced version of G_spawn().
  721. *
  722. * \param[in] command
  723. * \return -1 on error
  724. * \return process status on success
  725. */
  726. int G_spawn_ex(const char *command, ...)
  727. {
  728. struct spawn sp;
  729. va_list va;
  730. begin_spawn(&sp);
  731. va_start(va, command);
  732. parse_arglist(&sp, va);
  733. va_end(va);
  734. return do_spawn(&sp, command);
  735. }
  736. /**
  737. * \brief Spawn new process based on <b>command</b>.
  738. *
  739. * \param[in] command
  740. * \return -1 on error
  741. * \return process status on success
  742. */
  743. int G_spawn(const char *command, ...)
  744. {
  745. const char *args[MAX_ARGS];
  746. int num_args = 0, i;
  747. va_list va;
  748. int status = -1;
  749. va_start(va, command);
  750. for (i = 0; ; i++) {
  751. const char *arg = va_arg(va, const char *);
  752. args[num_args++] = arg;
  753. if (!arg)
  754. break;
  755. }
  756. va_end(va);
  757. status = G_spawn_ex(
  758. command,
  759. #ifndef __MINGW32__
  760. SF_SIGNAL, SST_PRE, SSA_IGNORE, SIGINT,
  761. SF_SIGNAL, SST_PRE, SSA_IGNORE, SIGQUIT,
  762. SF_SIGNAL, SST_PRE, SSA_BLOCK, SIGCHLD,
  763. #endif
  764. SF_ARGVEC, args,
  765. NULL);
  766. return status;
  767. }
  768. int G_wait(int i_pid)
  769. {
  770. #ifdef __MINGW32__
  771. DWORD rights = PROCESS_QUERY_INFORMATION | SYNCHRONIZE;
  772. HANDLE hProcess = OpenProcess(rights, FALSE, (DWORD) i_pid);
  773. DWORD exitcode;
  774. if (!hProcess)
  775. return -1;
  776. WaitForSingleObject(hProcess, INFINITE);
  777. if (!GetExitCodeProcess(hProcess, &exitcode))
  778. exitcode = (DWORD) -1;
  779. CloseHandle(hProcess);
  780. return (int) exitcode;
  781. #else
  782. pid_t pid = (pid_t) i_pid;
  783. int status = -1;
  784. pid_t n;
  785. do
  786. n = waitpid(pid, &status, 0);
  787. while (n == (pid_t) - 1 && errno == EINTR);
  788. if (n != pid)
  789. return -1;
  790. else {
  791. if (WIFEXITED(status))
  792. return WEXITSTATUS(status);
  793. else if (WIFSIGNALED(status))
  794. return WTERMSIG(status);
  795. else
  796. return -0x100;
  797. }
  798. #endif
  799. }