source: filterproc.c @ 9b3167b

release-1.10release-1.9
Last change on this file since 9b3167b was 97cdbaf5, checked in by David Benjamin <davidben@mit.edu>, 13 years ago
Rewrite call_filter to use g_spawn_async_with_pipes This simplifies the error-handling code. Also fixes a bug where file descriptors get double-closed in call_filter. Also adds a unit test. The separate prog argument is removed to avoid having to deal with G_SPAWN_FILE_AND_ARGV_ZERO, and since we don't really use it anyway.
  • Property mode set to 100644
File size: 2.1 KB
RevLine 
[f271129]1#include "owl.h"
[d564c3d]2#include <sys/wait.h>
3#include <poll.h>
4
[97cdbaf5]5/* Even in case of error, send_receive is responsible for closing wfd
6 * (to EOF the child) and rfd (for consistency). */
7static int send_receive(int rfd, int wfd, const char *out, char **in)
[d564c3d]8{
9  GString *str = g_string_new("");
10  char buf[1024];
11  nfds_t nfds;
12  int err = 0;
13  struct pollfd fds[2];
14
15  fcntl(rfd, F_SETFL, O_NONBLOCK | fcntl(rfd, F_GETFL));
16  fcntl(wfd, F_SETFL, O_NONBLOCK | fcntl(wfd, F_GETFL));
17
18  fds[0].fd = rfd;
19  fds[0].events = POLLIN;
20  fds[1].fd = wfd;
21  fds[1].events = POLLOUT;
22
[1f39ded]23  if(!out || !*out) {
24    /* Nothing to write. Close our end so the child doesn't hang waiting. */
[97cdbaf5]25    close(wfd); wfd = -1;
[1f39ded]26    out = NULL;
27  }
28
[d564c3d]29  while(1) {
30    if(out && *out) {
31      nfds = 2;
32    } else {
33      nfds = 1;
34    }
35    err = poll(fds, nfds, -1);
36    if(err < 0) {
37      break;
38    }
39    if(out && *out) {
40      if(fds[1].revents & POLLOUT) {
41        err = write(wfd, out, strlen(out));
42        if(err > 0) {
43          out += err;
44        }
45        if(err < 0) {
46          out = NULL;
47        }
48      }
49      if(!out || !*out || fds[1].revents & (POLLERR | POLLHUP)) {
[97cdbaf5]50        close(wfd); wfd = -1;
[d564c3d]51        out = NULL;
52      }
53    }
54    if(fds[0].revents & POLLIN) {
55      err = read(rfd, buf, sizeof(buf));
56      if(err <= 0) {
57        break;
58      }
59      g_string_append_len(str, buf, err);
60    } else if(fds[0].revents & (POLLHUP | POLLERR)) {
61      err = 0;
62      break;
63    }
64  }
65
[97cdbaf5]66  if (wfd >= 0) close(wfd);
67  close(rfd);
[d564c3d]68  *in = g_string_free(str, err < 0);
69  return err;
70}
71
[97cdbaf5]72int call_filter(const char *const *argv, const char *in, char **out, int *status)
[d564c3d]73{
[97cdbaf5]74  int err;
75  GPid child_pid;
76  int child_stdin, child_stdout;
[d564c3d]77
[97cdbaf5]78  if (!g_spawn_async_with_pipes(NULL, (char**)argv, NULL,
79                                G_SPAWN_SEARCH_PATH | G_SPAWN_DO_NOT_REAP_CHILD,
80                                NULL, NULL,
81                                &child_pid, &child_stdin, &child_stdout, NULL,
82                                NULL)) {
83    return 1;
[d564c3d]84  }
85
[97cdbaf5]86  err = send_receive(child_stdout, child_stdin, in, out);
87  if (err == 0) {
88    waitpid(child_pid, status, 0);
[d564c3d]89  }
90  return err;
91}
Note: See TracBrowser for help on using the repository browser.