LCOV - code coverage report
Current view: top level - src - wait-private.c (source / functions) Hit Total Coverage
Test: coverage.info Lines: 49 55 89.1 %
Date: 2018-11-14 16:53:58 Functions: 4 4 100.0 %

          Line data    Source code
       1             : /* wait-private.c
       2             :    Copyright (C) 2000 Werner Koch (dd9jn)
       3             :    Copyright (C) 2001, 2002, 2003, 2004, 2005 g10 Code GmbH
       4             : 
       5             :    This file is part of GPGME.
       6             : 
       7             :    GPGME is free software; you can redistribute it and/or modify it
       8             :    under the terms of the GNU Lesser General Public License as
       9             :    published by the Free Software Foundation; either version 2.1 of
      10             :    the License, or (at your option) any later version.
      11             : 
      12             :    GPGME is distributed in the hope that it will be useful, but
      13             :    WITHOUT ANY WARRANTY; without even the implied warranty of
      14             :    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
      15             :    Lesser General Public License for more details.
      16             : 
      17             :    You should have received a copy of the GNU Lesser General Public
      18             :    License along with this program; if not, write to the Free Software
      19             :    Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
      20             :    02111-1307, USA.  */
      21             : 
      22             : #if HAVE_CONFIG_H
      23             : #include <config.h>
      24             : #endif
      25             : #include <assert.h>
      26             : #include <errno.h>
      27             : 
      28             : #include "gpgme.h"
      29             : #include "context.h"
      30             : #include "wait.h"
      31             : #include "ops.h"
      32             : #include "priv-io.h"
      33             : #include "util.h"
      34             : #include "debug.h"
      35             : 
      36             : 
      37             : /* The private event loops are used for all blocking operations, and
      38             :    for the key and trust item listing operations.  They are completely
      39             :    separated from each other.  */
      40             : 
      41             : 
      42             : /* Internal I/O callback functions.  */
      43             : 
      44             : /* The add_io_cb and remove_io_cb handlers are shared with the global
      45             :    event loops.  */
      46             : 
      47             : void
      48        2904 : _gpgme_wait_private_event_cb (void *data, gpgme_event_io_t type,
      49             :                               void *type_data)
      50             : {
      51        2904 :   switch (type)
      52             :     {
      53             :     case GPGME_EVENT_START:
      54             :       /* Nothing to do here, as the wait routine is called after the
      55             :          initialization is finished.  */
      56         760 :       break;
      57             : 
      58             :     case GPGME_EVENT_DONE:
      59        1093 :       break;
      60             : 
      61             :     case GPGME_EVENT_NEXT_KEY:
      62        1052 :       _gpgme_op_keylist_event_cb (data, type, type_data);
      63        1052 :       break;
      64             : 
      65             :     case GPGME_EVENT_NEXT_TRUSTITEM:
      66           0 :       _gpgme_op_trustlist_event_cb (data, type, type_data);
      67           0 :       break;
      68             :     }
      69        2904 : }
      70             : 
      71             : 
      72             : /* If COND is a null pointer, wait until the blocking operation in CTX
      73             :    finished and return its error value.  Otherwise, wait until COND is
      74             :    satisfied or the operation finished.  */
      75             : gpgme_error_t
      76        1410 : _gpgme_wait_on_condition (gpgme_ctx_t ctx, volatile int *cond,
      77             :                           gpgme_error_t *op_err_p)
      78             : {
      79        1410 :   gpgme_error_t err = 0;
      80        1410 :   int hang = 1;
      81             : 
      82        1410 :   if (op_err_p)
      83          16 :     *op_err_p = 0;
      84             : 
      85             :   do
      86             :     {
      87        7919 :       int nr = _gpgme_io_select (ctx->fdt.fds, ctx->fdt.size, 0);
      88             :       unsigned int i;
      89             : 
      90        7914 :       if (nr < 0)
      91             :         {
      92             :           /* An error occurred.  Close all fds in this context, and
      93             :              signal it.  */
      94           0 :           err = gpg_error_from_syserror ();
      95           0 :           _gpgme_cancel_with_err (ctx, err, 0);
      96             : 
      97           0 :           return err;
      98             :         }
      99             : 
     100       22027 :       for (i = 0; i < ctx->fdt.size && nr; i++)
     101             :         {
     102       14141 :           if (ctx->fdt.fds[i].fd != -1 && ctx->fdt.fds[i].signaled)
     103             :             {
     104        9271 :               gpgme_error_t op_err = 0;
     105             : 
     106        9271 :               ctx->fdt.fds[i].signaled = 0;
     107        9271 :               assert (nr);
     108        9271 :               nr--;
     109             : 
     110        9271 :               LOCK (ctx->lock);
     111        9273 :               if (ctx->canceled)
     112           0 :                 err = gpg_error (GPG_ERR_CANCELED);
     113        9273 :               UNLOCK (ctx->lock);
     114             : 
     115        9273 :               if (!err)
     116        9273 :                 err = _gpgme_run_io_cb (&ctx->fdt.fds[i], 0, &op_err);
     117        9272 :               if (err)
     118             :                 {
     119             :                   /* An error occurred.  Close all fds in this context,
     120             :                      and signal it.  */
     121          27 :                   _gpgme_cancel_with_err (ctx, err, 0);
     122             : 
     123          56 :                   return err;
     124             :                 }
     125        9245 :               else if (op_err)
     126             :                 {
     127             :                   /* An operational error occurred.  Cancel the current
     128             :                      operation but not the session, and signal it.  */
     129           2 :                   _gpgme_cancel_with_err (ctx, 0, op_err);
     130             : 
     131             :                   /* NOTE: This relies on the operational error being
     132             :                      generated after the operation really has
     133             :                      completed, for example after no further status
     134             :                      line output is generated.  Otherwise the
     135             :                      following I/O will spill over into the next
     136             :                      operation.  */
     137           2 :                   if (op_err_p)
     138           2 :                     *op_err_p = op_err;
     139           2 :                   return 0;
     140             :                 }
     141             :             }
     142             :         }
     143             : 
     144       18665 :       for (i = 0; i < ctx->fdt.size; i++)
     145       17601 :         if (ctx->fdt.fds[i].fd != -1)
     146        6822 :           break;
     147        7886 :       if (i == ctx->fdt.size)
     148             :         {
     149             :           struct gpgme_io_event_done_data data;
     150        1064 :           data.err = 0;
     151        1064 :           data.op_err = 0;
     152        1064 :           _gpgme_engine_io_event (ctx->engine, GPGME_EVENT_DONE, &data);
     153        1064 :           hang = 0;
     154             :         }
     155        7886 :       if (cond && *cond)
     156         629 :         hang = 0;
     157             :     }
     158        7886 :   while (hang);
     159             : 
     160        1377 :   return 0;
     161             : }
     162             : 
     163             : 
     164             : /* Wait until the blocking operation in context CTX has finished and
     165             :    return the error value.  This variant can not be used for
     166             :    session-based protocols.  */
     167             : gpgme_error_t
     168         433 : _gpgme_wait_one (gpgme_ctx_t ctx)
     169             : {
     170         433 :   return _gpgme_wait_on_condition (ctx, NULL, NULL);
     171             : }
     172             : 
     173             : /* Wait until the blocking operation in context CTX has finished and
     174             :    return the error value.  This is the right variant to use for
     175             :    sesion-based protocols.  */
     176             : gpgme_error_t
     177          16 : _gpgme_wait_one_ext (gpgme_ctx_t ctx, gpgme_error_t *op_err)
     178             : {
     179          16 :   return _gpgme_wait_on_condition (ctx, NULL, op_err);
     180             : }

Generated by: LCOV version 1.13