spawn.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981
  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. return newenv;
  382. }
  383. static int do_spawn(struct spawn *sp, const char *command)
  384. {
  385. HANDLE handles[3];
  386. const char **env;
  387. int status;
  388. do_redirects(sp->redirects, sp->num_redirects, handles);
  389. env = do_bindings(sp->bindings, sp->num_bindings);
  390. status = win_spawn(command, sp->args, env, sp->directory, handles, sp->background, 1);
  391. if (!sp->background && status < 0)
  392. G_warning(_("Unable to execute command"));
  393. return status;
  394. }
  395. #else /* __MINGW32__ */
  396. static int undo_signals(const struct signal *signals, int num_signals, int which)
  397. {
  398. int error = 0;
  399. int i;
  400. for (i = num_signals - 1; i >= 0; i--) {
  401. const struct signal *s = &signals[i];
  402. if (s->which != which)
  403. continue;
  404. if (!s->valid)
  405. continue;
  406. switch (s->action) {
  407. case SSA_IGNORE:
  408. case SSA_DEFAULT:
  409. if (sigaction(s->signum, &s->old_act, NULL) < 0) {
  410. G_warning(_("G_spawn: unable to restore signal %d"),
  411. s->signum);
  412. error = 1;
  413. }
  414. break;
  415. case SSA_BLOCK:
  416. case SSA_UNBLOCK:
  417. if (sigprocmask(SIG_UNBLOCK, &s->old_mask, NULL) < 0) {
  418. G_warning(_("G_spawn: unable to restore signal %d"),
  419. s->signum);
  420. error = 1;
  421. }
  422. break;
  423. }
  424. }
  425. return !error;
  426. }
  427. static int do_signals(struct signal *signals, int num_signals, int which)
  428. {
  429. struct sigaction act;
  430. sigset_t mask;
  431. int error = 0;
  432. int i;
  433. sigemptyset(&act.sa_mask);
  434. act.sa_flags = SA_RESTART;
  435. for (i = 0; i < num_signals; i++) {
  436. struct signal *s = &signals[i];
  437. if (s->which != which)
  438. continue;
  439. switch (s->action) {
  440. case SSA_IGNORE:
  441. act.sa_handler = SIG_IGN;
  442. if (sigaction(s->signum, &act, &s->old_act) < 0) {
  443. G_warning(_("G_spawn: unable to reset signal %d"), s->signum);
  444. error = 1;
  445. }
  446. else
  447. s->valid = 1;
  448. break;
  449. case SSA_DEFAULT:
  450. act.sa_handler = SIG_DFL;
  451. if (sigaction(s->signum, &act, &s->old_act) < 0) {
  452. G_warning(_("G_spawn: unable to ignore signal %d"),
  453. s->signum);
  454. error = 1;
  455. }
  456. else
  457. s->valid = 1;
  458. break;
  459. case SSA_BLOCK:
  460. sigemptyset(&mask);
  461. sigaddset(&mask, s->signum);
  462. if (sigprocmask(SIG_BLOCK, &mask, &s->old_mask) < 0) {
  463. G_warning(_("G_spawn: unable to block signal %d"), s->signum);
  464. error = 1;
  465. }
  466. break;
  467. case SSA_UNBLOCK:
  468. sigemptyset(&mask);
  469. sigaddset(&mask, s->signum);
  470. if (sigprocmask(SIG_UNBLOCK, &mask, &s->old_mask) < 0) {
  471. G_warning(_("G_spawn: unable to unblock signal %d"),
  472. s->signum);
  473. error = 1;
  474. }
  475. else
  476. s->valid = 1;
  477. break;
  478. }
  479. }
  480. return !error;
  481. }
  482. static void do_redirects(struct redirect *redirects, int num_redirects)
  483. {
  484. int i;
  485. for (i = 0; i < num_redirects; i++) {
  486. struct redirect *r = &redirects[i];
  487. if (r->file) {
  488. r->src_fd = open(r->file, r->mode, 0666);
  489. if (r->src_fd < 0) {
  490. G_warning(_("G_spawn: unable to open file %s"), r->file);
  491. _exit(127);
  492. }
  493. if (dup2(r->src_fd, r->dst_fd) < 0) {
  494. G_warning(_("G_spawn: unable to duplicate descriptor %d to %d"),
  495. r->src_fd, r->dst_fd);
  496. _exit(127);
  497. }
  498. close(r->src_fd);
  499. }
  500. else if (r->src_fd >= 0) {
  501. if (dup2(r->src_fd, r->dst_fd) < 0) {
  502. G_warning(_("G_spawn: unable to duplicate descriptor %d to %d"),
  503. r->src_fd, r->dst_fd);
  504. _exit(127);
  505. }
  506. }
  507. else
  508. close(r->dst_fd);
  509. }
  510. }
  511. static void do_bindings(const struct binding *bindings, int num_bindings)
  512. {
  513. int i;
  514. for (i = 0; i < num_bindings; i++) {
  515. const struct binding *b = &bindings[i];
  516. char *str = G_malloc(strlen(b->var) + strlen(b->val) + 2);
  517. sprintf(str, "%s=%s", b->var, b->val);
  518. putenv(str);
  519. }
  520. }
  521. static int do_spawn(struct spawn *sp, const char *command)
  522. {
  523. int status = -1;
  524. pid_t pid;
  525. if (!do_signals(sp->signals, sp->num_signals, SST_PRE))
  526. return status;
  527. pid = fork();
  528. if (pid < 0) {
  529. G_warning(_("Unable to create a new process"));
  530. undo_signals(sp->signals, sp->num_signals, SST_PRE);
  531. return status;
  532. }
  533. if (pid == 0) {
  534. if (!undo_signals(sp->signals, sp->num_signals, SST_PRE))
  535. _exit(127);
  536. if (!do_signals(sp->signals, sp->num_signals, SST_CHILD))
  537. _exit(127);
  538. if (sp->directory)
  539. if (chdir(sp->directory) < 0) {
  540. G_warning(_("Unable to change directory to %s"), sp->directory);
  541. _exit(127);
  542. }
  543. do_redirects(sp->redirects, sp->num_redirects);
  544. do_bindings(sp->bindings, sp->num_bindings);
  545. execvp(command, (char **)sp->args);
  546. G_warning(_("Unable to execute command"));
  547. _exit(127);
  548. }
  549. do_signals(sp->signals, sp->num_signals, SST_POST);
  550. if (sp->background)
  551. status = (int)pid;
  552. else {
  553. pid_t n;
  554. do
  555. n = waitpid(pid, &status, 0);
  556. while (n == (pid_t) - 1 && errno == EINTR);
  557. if (n != pid)
  558. status = -1;
  559. else {
  560. if (WIFEXITED(status))
  561. status = WEXITSTATUS(status);
  562. else if (WIFSIGNALED(status))
  563. status = WTERMSIG(status);
  564. else
  565. status = -0x100;
  566. }
  567. }
  568. undo_signals(sp->signals, sp->num_signals, SST_POST);
  569. undo_signals(sp->signals, sp->num_signals, SST_PRE);
  570. return status;
  571. }
  572. #endif /* __MINGW32__ */
  573. static void begin_spawn(struct spawn *sp)
  574. {
  575. sp->num_args = 0;
  576. sp->num_redirects = 0;
  577. sp->num_signals = 0;
  578. sp->num_bindings = 0;
  579. sp->background = 0;
  580. sp->directory = NULL;
  581. }
  582. #define NEXT_ARG(var, type) ((type) *(var)++)
  583. static void parse_argvec(struct spawn *sp, const char **va)
  584. {
  585. for (;;) {
  586. const char *arg = NEXT_ARG(va, const char *);
  587. const char *var, *val;
  588. if (!arg) {
  589. sp->args[sp->num_args++] = NULL;
  590. break;
  591. }
  592. else if (arg == SF_REDIRECT_FILE) {
  593. sp->redirects[sp->num_redirects].dst_fd = NEXT_ARG(va, int);
  594. sp->redirects[sp->num_redirects].src_fd = -1;
  595. sp->redirects[sp->num_redirects].mode = NEXT_ARG(va, int);
  596. sp->redirects[sp->num_redirects].file = NEXT_ARG(va, const char *);
  597. sp->num_redirects++;
  598. }
  599. else if (arg == SF_REDIRECT_DESCRIPTOR) {
  600. sp->redirects[sp->num_redirects].dst_fd = NEXT_ARG(va, int);
  601. sp->redirects[sp->num_redirects].src_fd = NEXT_ARG(va, int);
  602. sp->redirects[sp->num_redirects].file = NULL;
  603. sp->num_redirects++;
  604. }
  605. else if (arg == SF_CLOSE_DESCRIPTOR) {
  606. sp->redirects[sp->num_redirects].dst_fd = NEXT_ARG(va, int);
  607. sp->redirects[sp->num_redirects].src_fd = -1;
  608. sp->redirects[sp->num_redirects].file = NULL;
  609. sp->num_redirects++;
  610. }
  611. else if (arg == SF_SIGNAL) {
  612. sp->signals[sp->num_signals].which = NEXT_ARG(va, int);
  613. sp->signals[sp->num_signals].action = NEXT_ARG(va, int);
  614. sp->signals[sp->num_signals].signum = NEXT_ARG(va, int);
  615. sp->signals[sp->num_signals].valid = 0;
  616. sp->num_signals++;
  617. }
  618. else if (arg == SF_VARIABLE) {
  619. var = NEXT_ARG(va, const char *);
  620. val = getenv(var);
  621. sp->args[sp->num_args++] = val ? val : "";
  622. }
  623. else if (arg == SF_BINDING) {
  624. sp->bindings[sp->num_bindings].var = NEXT_ARG(va, const char *);
  625. sp->bindings[sp->num_bindings].val = NEXT_ARG(va, const char *);
  626. sp->num_bindings++;
  627. }
  628. else if (arg == SF_BACKGROUND) {
  629. sp->background = 1;
  630. }
  631. else if (arg == SF_DIRECTORY) {
  632. sp->directory = NEXT_ARG(va, const char *);
  633. }
  634. else if (arg == SF_ARGVEC) {
  635. parse_argvec(sp, NEXT_ARG(va, const char **));
  636. }
  637. else
  638. sp->args[sp->num_args++] = arg;
  639. }
  640. }
  641. static void parse_arglist(struct spawn *sp, va_list va)
  642. {
  643. for (;;) {
  644. const char *arg = va_arg(va, const char *);
  645. const char *var, *val;
  646. if (!arg) {
  647. sp->args[sp->num_args++] = NULL;
  648. break;
  649. }
  650. else if (arg == SF_REDIRECT_FILE) {
  651. sp->redirects[sp->num_redirects].dst_fd = va_arg(va, int);
  652. sp->redirects[sp->num_redirects].src_fd = -1;
  653. sp->redirects[sp->num_redirects].mode = va_arg(va, int);
  654. sp->redirects[sp->num_redirects].file = va_arg(va, const char *);
  655. sp->num_redirects++;
  656. }
  657. else if (arg == SF_REDIRECT_DESCRIPTOR) {
  658. sp->redirects[sp->num_redirects].dst_fd = va_arg(va, int);
  659. sp->redirects[sp->num_redirects].src_fd = va_arg(va, int);
  660. sp->redirects[sp->num_redirects].file = NULL;
  661. sp->num_redirects++;
  662. }
  663. else if (arg == SF_CLOSE_DESCRIPTOR) {
  664. sp->redirects[sp->num_redirects].dst_fd = va_arg(va, int);
  665. sp->redirects[sp->num_redirects].src_fd = -1;
  666. sp->redirects[sp->num_redirects].file = NULL;
  667. sp->num_redirects++;
  668. }
  669. else if (arg == SF_SIGNAL) {
  670. sp->signals[sp->num_signals].which = va_arg(va, int);
  671. sp->signals[sp->num_signals].action = va_arg(va, int);
  672. sp->signals[sp->num_signals].signum = va_arg(va, int);
  673. sp->signals[sp->num_signals].valid = 0;
  674. sp->num_signals++;
  675. }
  676. else if (arg == SF_VARIABLE) {
  677. var = va_arg(va, char *);
  678. val = getenv(var);
  679. sp->args[sp->num_args++] = val ? val : "";
  680. }
  681. else if (arg == SF_BINDING) {
  682. sp->bindings[sp->num_bindings].var = va_arg(va, const char *);
  683. sp->bindings[sp->num_bindings].val = va_arg(va, const char *);
  684. sp->num_bindings++;
  685. }
  686. else if (arg == SF_BACKGROUND) {
  687. sp->background = 1;
  688. }
  689. else if (arg == SF_DIRECTORY) {
  690. sp->directory = va_arg(va, const char *);
  691. }
  692. else if (arg == SF_ARGVEC) {
  693. parse_argvec(sp, va_arg(va, const char **));
  694. }
  695. else
  696. sp->args[sp->num_args++] = arg;
  697. }
  698. }
  699. /**
  700. * \brief Spawn new process based on <b>command</b>.
  701. *
  702. * This is a more advanced version of G_spawn().
  703. *
  704. * \param[in] command
  705. * \param[in] args arguments
  706. * \return -1 on error
  707. * \return process status on success
  708. */
  709. int G_vspawn_ex(const char *command, const char **args)
  710. {
  711. struct spawn sp;
  712. begin_spawn(&sp);
  713. parse_argvec(&sp, args);
  714. return do_spawn(&sp, command);
  715. }
  716. /**
  717. * \brief Spawn new process based on <b>command</b>.
  718. *
  719. * This is a more advanced version of G_spawn().
  720. *
  721. * \param[in] command
  722. * \return -1 on error
  723. * \return process status on success
  724. */
  725. int G_spawn_ex(const char *command, ...)
  726. {
  727. struct spawn sp;
  728. va_list va;
  729. begin_spawn(&sp);
  730. va_start(va, command);
  731. parse_arglist(&sp, va);
  732. va_end(va);
  733. return do_spawn(&sp, command);
  734. }
  735. /**
  736. * \brief Spawn new process based on <b>command</b>.
  737. *
  738. * \param[in] command
  739. * \return -1 on error
  740. * \return process status on success
  741. */
  742. int G_spawn(const char *command, ...)
  743. {
  744. const char *args[MAX_ARGS];
  745. int num_args = 0, i;
  746. va_list va;
  747. int status = -1;
  748. va_start(va, command);
  749. for (i = 0; ; i++) {
  750. const char *arg = va_arg(va, const char *);
  751. args[num_args++] = arg;
  752. if (!arg)
  753. break;
  754. }
  755. va_end(va);
  756. status = G_spawn_ex(
  757. command,
  758. #ifndef __MINGW32__
  759. SF_SIGNAL, SST_PRE, SSA_IGNORE, SIGINT,
  760. SF_SIGNAL, SST_PRE, SSA_IGNORE, SIGQUIT,
  761. SF_SIGNAL, SST_PRE, SSA_BLOCK, SIGCHLD,
  762. #endif
  763. SF_ARGVEC, args,
  764. NULL);
  765. return status;
  766. }
  767. int G_wait(int i_pid)
  768. {
  769. #ifdef __MINGW32__
  770. DWORD rights = PROCESS_QUERY_INFORMATION | SYNCHRONIZE;
  771. HANDLE hProcess = OpenProcess(rights, FALSE, (DWORD) i_pid);
  772. DWORD exitcode;
  773. if (!hProcess)
  774. return -1;
  775. WaitForSingleObject(hProcess, INFINITE);
  776. if (!GetExitCodeProcess(hProcess, &exitcode))
  777. exitcode = (DWORD) -1;
  778. CloseHandle(hProcess);
  779. return (int) exitcode;
  780. #else
  781. pid_t pid = (pid_t) i_pid;
  782. int status = -1;
  783. pid_t n;
  784. do
  785. n = waitpid(pid, &status, 0);
  786. while (n == (pid_t) - 1 && errno == EINTR);
  787. if (n != pid)
  788. return -1;
  789. else {
  790. if (WIFEXITED(status))
  791. return WEXITSTATUS(status);
  792. else if (WIFSIGNALED(status))
  793. return WTERMSIG(status);
  794. else
  795. return -0x100;
  796. }
  797. #endif
  798. }