From 9e2397571df145ca404e71d9d4ee77ea56a4eed9 Mon Sep 17 00:00:00 2001
From: Marcus Brinkmann <mb@g10code.com>
Date: Tue, 20 Oct 2009 16:05:21 +0000
Subject: [PATCH] Really add file.

---
 src/assuan-support.c | 208 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 208 insertions(+)
 create mode 100644 src/assuan-support.c

diff --git a/src/assuan-support.c b/src/assuan-support.c
new file mode 100644
index 00000000..cd9cbc41
--- /dev/null
+++ b/src/assuan-support.c
@@ -0,0 +1,208 @@
+#if HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#include <assert.h>
+#include <stdlib.h>
+
+#include "assuan.h"
+
+#include "gpgme.h"
+#include "ath.h"
+#include "priv-io.h"
+#include "debug.h"
+
+
+struct assuan_malloc_hooks _gpgme_assuan_malloc_hooks =
+  {
+    malloc,
+    realloc,
+    free
+  };
+
+
+int
+_gpgme_assuan_log_cb (assuan_context_t ctx, void *hook,
+		      unsigned int cat, const char *msg)
+{
+  if (msg == NULL)
+    return 1;
+
+  _gpgme_debug (DEBUG_ASSUAN, "%s", msg);
+  return 0;
+}
+
+
+static void
+my_usleep (assuan_context_t ctx, unsigned int usec)
+{
+  /* FIXME: Add to ath.  */
+  __assuan_usleep (ctx, usec);
+}
+
+/* Create a pipe with an inheritable end.  */
+static int
+my_pipe (assuan_context_t ctx, assuan_fd_t fds[2], int inherit_idx)
+{
+  return _gpgme_io_pipe (fds, inherit_idx);
+}
+
+
+/* Close the given file descriptor, created with _assuan_pipe or one
+   of the socket functions.  */
+static int
+my_close (assuan_context_t ctx, assuan_fd_t fd)
+{
+  return _gpgme_io_close (fd);
+}
+
+
+static ssize_t
+my_read (assuan_context_t ctx, assuan_fd_t fd, void *buffer, size_t size)
+{
+  return _gpgme_io_read (fd, buffer, size);
+}
+
+
+static ssize_t
+my_write (assuan_context_t ctx, assuan_fd_t fd, const void *buffer, size_t size)
+{
+  return _gpgme_io_write (fd, buffer, size);
+}
+
+
+static int
+my_recvmsg (assuan_context_t ctx, assuan_fd_t fd, assuan_msghdr_t msg,
+	    int flags)
+{
+#ifdef HAVE_W32_SYSTEM
+  return gpg_error (GPG_ERR_NOT_IMPLEMENTED);
+#else
+  return _gpgme_io_recvmsg (fd, msg, flags);
+#endif
+}
+
+
+
+static int
+my_sendmsg (assuan_context_t ctx, assuan_fd_t fd, const assuan_msghdr_t msg,
+	    int flags)
+{
+#ifdef HAVE_W32_SYSTEM
+  return gpg_error (GPG_ERR_NOT_IMPLEMENTED);
+#else
+  return _gpgme_io_sendmsg (fd, msg, flags);
+#endif
+}
+
+
+/* If NAME is NULL, don't exec, just fork.  FD_CHILD_LIST is modified
+   to reflect the value of the FD in the peer process (on
+   Windows).  */
+static int
+my_spawn (assuan_context_t ctx, pid_t *r_pid, const char *name,
+	  const char **argv,
+	  assuan_fd_t fd_in, assuan_fd_t fd_out,
+	  assuan_fd_t *fd_child_list,
+	  void (*atfork) (void *opaque, int reserved),
+	  void *atforkvalue, unsigned int flags)
+{
+  gpg_error_t err;
+  struct spawn_fd_item_s *fd_items;
+  int i;
+
+  assert (name);
+
+  if (! name)
+    return gpg_error (GPG_ERR_NOT_IMPLEMENTED);
+
+  i = 0;
+  while (fd_child_list[i] != ASSUAN_INVALID_FD)
+    i++;
+  /* fd_in, fd_out, terminator */
+  i += 3;
+  fd_items = malloc (sizeof (struct spawn_fd_item_s) * i);
+  if (! fd_items)
+    return gpg_error_from_syserror ();
+  i = 0;
+  while (fd_child_list[i] != ASSUAN_INVALID_FD)
+    {
+      fd_items[i].fd = fd_child_list[i];
+      fd_items[i].dup_to = -1;
+      i++;
+    }
+  if (fd_in != ASSUAN_INVALID_FD)
+    {
+      fd_items[i].fd = fd_in;
+      fd_items[i].dup_to = 0;
+      i++;
+    }
+  if (fd_out != ASSUAN_INVALID_FD)
+    {
+      fd_items[i].fd = fd_out;
+      fd_items[i].dup_to = 1;
+      i++;
+    }
+  fd_items[i].fd = -1;
+  fd_items[i].dup_to = -1;
+
+  err = _gpgme_io_spawn (name, argv, 0, fd_items, r_pid);
+  if (! err)
+    {
+      i = 0;
+
+      while (fd_child_list[i] != ASSUAN_INVALID_FD)
+	{
+	  fd_child_list[i] = fd_items[i].peer_name;
+	  i++;
+	}
+    }
+  free (fd_items);
+  return err;
+}
+
+
+/* If action is 0, like waitpid.  If action is 1, just release the PID?  */
+static pid_t
+my_waitpid (assuan_context_t ctx, pid_t pid,
+	    int nowait, int *status, int options)
+{
+#ifdef HAVE_W32_SYSTEM
+  CloseHandle ((HANDLE) pid);
+#else
+  /* We can't just release the PID, a waitpid is mandatory.  But
+     NOWAIT in POSIX systems just means the caller already did the
+     waitpid for this child.  */
+  if (! nowait)
+    return _gpgme_ath_waitpid (pid, status, options); 
+#endif
+  return 0;
+}
+
+
+
+
+static int
+my_socketpair (assuan_context_t ctx, int namespace, int style,
+	       int protocol, assuan_fd_t filedes[2])
+{
+  assert ("Should never happen.");
+  return gpg_error (GPG_ERR_NOT_IMPLEMENTED);
+}
+
+
+struct assuan_system_hooks _gpgme_assuan_system_hooks =
+  {
+    ASSUAN_SYSTEM_HOOKS_VERSION,
+    my_usleep,
+    my_pipe,
+    my_close,
+    my_read,
+    my_write,
+    my_recvmsg,
+    my_sendmsg,
+    my_spawn,
+    my_waitpid,
+    my_socketpair
+  };
+