aboutsummaryrefslogtreecommitdiffstats
path: root/camel/camel-process.c
diff options
context:
space:
mode:
authorJeffrey Stedfast <fejj@ximian.com>2003-03-04 06:53:15 +0800
committerJeffrey Stedfast <fejj@src.gnome.org>2003-03-04 06:53:15 +0800
commita11414daf66216c29aa64147de4b4327176a06ad (patch)
treea3ac85bece6fc89f4cb47c256378dcc77a16d19c /camel/camel-process.c
parent53457a736667fad6397ec6cf9f163ff5c64423c0 (diff)
downloadgsoc2013-evolution-a11414daf66216c29aa64147de4b4327176a06ad.tar
gsoc2013-evolution-a11414daf66216c29aa64147de4b4327176a06ad.tar.gz
gsoc2013-evolution-a11414daf66216c29aa64147de4b4327176a06ad.tar.bz2
gsoc2013-evolution-a11414daf66216c29aa64147de4b4327176a06ad.tar.lz
gsoc2013-evolution-a11414daf66216c29aa64147de4b4327176a06ad.tar.xz
gsoc2013-evolution-a11414daf66216c29aa64147de4b4327176a06ad.tar.zst
gsoc2013-evolution-a11414daf66216c29aa64147de4b4327176a06ad.zip
Updated to use the new API from a fe commits ago for the NSS stream. This
2003-03-03 Jeffrey Stedfast <fejj@ximian.com> * camel-tcp-stream-openssl.c (camel_tcp_stream_ssl_new): Updated to use the new API from a fe commits ago for the NSS stream. This is just to make it compile, but does not update the behaviour to act like the NSS stream. Note that people shouldn't be using OpenSSL anyway. (camel_tcp_stream_ssl_new_raw): Same. * camel-process.[c,h]: New source file containing convenience functions for process creation/termination mainly for use with Pipe filters but should be usable for anything we want. * camel-io.[c,h]: New source files implementing read/write system calls with proper error checking and cancellation (ie. StreamFs::read/write and CamelTcpStreamRaw::read/write). No sense duplicating the same code over and over. Now I can use this same code easily in other i/o code (such as Pipe filters and gpg code?). svn path=/trunk/; revision=20132
Diffstat (limited to 'camel/camel-process.c')
-rw-r--r--camel/camel-process.c153
1 files changed, 153 insertions, 0 deletions
diff --git a/camel/camel-process.c b/camel/camel-process.c
new file mode 100644
index 0000000000..01c1e3be3d
--- /dev/null
+++ b/camel/camel-process.c
@@ -0,0 +1,153 @@
+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
+/*
+ * Authors: Jeffrey Stedfast <fejj@ximian.com>
+ *
+ * Copyright 2003 Ximian, Inc. (www.ximian.com)
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Street #330, Boston, MA 02111-1307, USA.
+ *
+ */
+
+
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#include <unistd.h>
+#include <fcntl.h>
+#include <errno.h>
+
+#include "camel-process.h"
+
+
+pid_t
+camel_process_fork (const char *path, char **argv, int *infd, int *outfd, int *errfd, CamelException *ex)
+{
+ int errnosav, fd[6], i;
+ pid_t pid;
+
+ for (i = 0; i < 6; i++)
+ fds[i] = -1;
+
+ for (i = 0; i < 6; i += 2) {
+ if (pipe (fd + i) == -1) {
+ errnosav = errno;
+ camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM,
+ _("Failed to create pipe to '%s': %s"),
+ argv[0], strerror (errno));
+
+ for (i = 0; i < 6; i++) {
+ if (fd[i] == -1)
+ break;
+ close (fd[i]);
+ }
+
+ errno = errnosav;
+
+ return -1;
+ }
+ }
+
+ if (!(pid = fork ())) {
+ /* child process */
+ int maxfd, nullfd = -1;
+
+ if (!outfd || !errfd)
+ nullfd = open ("/dev/null", O_WRONLY);
+
+ if (dup2 (fd[0], STDIN_FILENO) == -1)
+ _exit (255);
+
+ if (dup2 (outfd ? fd[3] : nullfd, STDOUT_FILENO) == -1)
+ _exit (255);
+
+ if (dup2 (errfd ? fd[5] : nullfd, STDERR_FILENO) == -1)
+ _exit (255);
+
+ setsid ();
+
+ if ((maxfd = sysconf (_SC_OPEN_MAX)) > 0) {
+ for (i = 0; i < maxfd; i++) {
+ if (i != STDIN_FILENO && i != STDOUT_FILENO && i != STDERR_FILENO)
+ close (i);
+ }
+ }
+
+ execv (path, argv);
+ _exit (255);
+ } else if (pid == -1) {
+ camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM,
+ _("Failed to create create child process '%s': %s"),
+ argv[0], strerror (errno));
+ return -1;
+ }
+
+ /* parent process */
+ close (fd[0]);
+ close (fd[3]);
+ close (fd[5]);
+
+ if (infd)
+ *infd = fd[1];
+ else
+ close (fd[1]);
+
+ if (outfd)
+ *outfd = fd[2];
+ else
+ close (fd[2]);
+
+ if (errfd)
+ *errfd = fd[4];
+ else
+ close (fd[4]);
+
+ return pid;
+}
+
+
+int
+camel_process_wait (pid_t pid)
+{
+ sigset_t mask, omask;
+ int status;
+ pid_t r;
+
+ sigemptyset (&mask);
+ sigaddset (&mask, SIGALRM);
+ sigprocmask (SIG_BLOCK, &mask, &omask);
+ alarm (1);
+
+ r = waitpid (pid, &status, 0);
+
+ alarm (0);
+ sigprocmask (SIG_SETMASK, &omask, NULL);
+
+ if (r == (pid_t) -1 && errno == EINTR) {
+ kill (pid, SIGTERM);
+ sleep (1);
+ r = waitpid (pid, &status, WNOHANG);
+ if (r == (pid_t) 0) {
+ kill (pid, SIGKILL);
+ sleep (1);
+ r = waitpid (pid, &status, WNOHANG);
+ }
+ }
+
+ if (r != (pid_t) -1 && WIFEXITED (status))
+ return WEXITSTATUS (status);
+ else
+ return -1;
+}