json: Deduplicate input handling code
[gpgme.git] / src / wait-user.c
index 995657f..c7bc80f 100644 (file)
@@ -1,19 +1,19 @@
-/* wait-user.c 
+/* wait-user.c
    Copyright (C) 2000 Werner Koch (dd9jn)
    Copyright (C) 2001, 2002, 2003, 2004, 2005 g10 Code GmbH
+
    This file is part of GPGME.
+
    GPGME is free software; you can redistribute it and/or modify it
    under the terms of the GNU Lesser General Public License as
    published by the Free Software Foundation; either version 2.1 of
    the License, or (at your option) any later version.
-   
+
    GPGME 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
    Lesser General Public License for more details.
-   
+
    You should have received a copy of the GNU Lesser General Public
    License along with this program; if not, write to the Free Software
    Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
@@ -29,6 +29,7 @@
 #include "priv-io.h"
 #include "wait.h"
 #include "ops.h"
+#include "debug.h"
 
 \f
 /* The user event loops are used for all asynchronous operations for
@@ -41,9 +42,12 @@ gpgme_error_t
 _gpgme_user_io_cb_handler (void *data, int fd)
 {
   gpgme_error_t err = 0;
+  gpgme_error_t op_err = 0;
   struct tag *tag = (struct tag *) data;
   gpgme_ctx_t ctx;
 
+  (void)fd;
+
   assert (data);
   ctx = tag->ctx;
   assert (ctx);
@@ -54,9 +58,9 @@ _gpgme_user_io_cb_handler (void *data, int fd)
   UNLOCK (ctx->lock);
 
   if (! err)
-    err = _gpgme_run_io_cb (&ctx->fdt.fds[tag->idx], 0);
-  if (err)
-    _gpgme_cancel_with_err (ctx, err);
+    err = _gpgme_run_io_cb (&ctx->fdt.fds[tag->idx], 0, &op_err);
+  if (err || op_err)
+    _gpgme_cancel_with_err (ctx, err, op_err);
   else
     {
       unsigned int i;
@@ -64,8 +68,15 @@ _gpgme_user_io_cb_handler (void *data, int fd)
       for (i = 0; i < ctx->fdt.size; i++)
        if (ctx->fdt.fds[i].fd != -1)
          break;
+
       if (i == ctx->fdt.size)
-       _gpgme_engine_io_event (ctx->engine, GPGME_EVENT_DONE, &err);
+       {
+         struct gpgme_io_event_done_data done_data;
+
+         done_data.err = 0;
+         done_data.op_err = 0;
+         _gpgme_engine_io_event (ctx->engine, GPGME_EVENT_DONE, &done_data);
+       }
     }
   return 0;
 }