
* util.h (mk_error): Remove macro. * conversion.c, data.c, data-compat.c, decrypt.c, delete.c, edit.c, encrypt.c, encrypt-sign.c, engine.c, engine-gpgsm.c, export.c, genkey.c, gpgme.c, import.c, key.c, keylist.c, passphrase.c, progress.c, recipient.c, rungpg.c, sign.c, signers.c, trustlist.c, verify.c, wait.c, wait-global.c, wait-private (literally everywhere): Expand the mk_error macro.
167 lines
3.6 KiB
C
167 lines
3.6 KiB
C
/* wait.c
|
||
Copyright (C) 2000 Werner Koch (dd9jn)
|
||
Copyright (C) 2001, 2002, 2003 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 General Public License as published by
|
||
the Free Software Foundation; either version 2 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
|
||
General Public License for more details.
|
||
|
||
You should have received a copy of the GNU General Public License
|
||
along with GPGME; if not, write to the Free Software Foundation,
|
||
Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. */
|
||
|
||
#if HAVE_CONFIG_H
|
||
#include <config.h>
|
||
#endif
|
||
#include <stdlib.h>
|
||
#include <string.h>
|
||
#include <assert.h>
|
||
#include <errno.h>
|
||
#include <sys/types.h>
|
||
|
||
#include "util.h"
|
||
#include "context.h"
|
||
#include "ops.h"
|
||
#include "wait.h"
|
||
#include "sema.h"
|
||
#include "io.h"
|
||
#include "engine.h"
|
||
|
||
|
||
void
|
||
_gpgme_fd_table_init (fd_table_t fdt)
|
||
{
|
||
fdt->fds = NULL;
|
||
fdt->size = 0;
|
||
}
|
||
|
||
void
|
||
_gpgme_fd_table_deinit (fd_table_t fdt)
|
||
{
|
||
if (fdt->fds)
|
||
free (fdt->fds);
|
||
}
|
||
|
||
|
||
/* XXX We should keep a marker and roll over for speed. */
|
||
static GpgmeError
|
||
fd_table_put (fd_table_t fdt, int fd, int dir, void *opaque, int *idx)
|
||
{
|
||
int i, j;
|
||
struct io_select_fd_s *new_fds;
|
||
|
||
for (i = 0; i < fdt->size; i++)
|
||
{
|
||
if (fdt->fds[i].fd == -1)
|
||
break;
|
||
}
|
||
if (i == fdt->size)
|
||
{
|
||
#define FDT_ALLOCSIZE 10
|
||
new_fds = realloc (fdt->fds, (fdt->size + FDT_ALLOCSIZE)
|
||
* sizeof (*new_fds));
|
||
if (!new_fds)
|
||
return GPGME_Out_Of_Core;
|
||
|
||
fdt->fds = new_fds;
|
||
fdt->size += FDT_ALLOCSIZE;
|
||
for (j = 0; j < FDT_ALLOCSIZE; j++)
|
||
fdt->fds[i + j].fd = -1;
|
||
}
|
||
|
||
fdt->fds[i].fd = fd;
|
||
fdt->fds[i].for_read = (dir == 1);
|
||
fdt->fds[i].for_write = (dir == 0);
|
||
fdt->fds[i].frozen = 0;
|
||
fdt->fds[i].signaled = 0;
|
||
fdt->fds[i].opaque = opaque;
|
||
*idx = i;
|
||
return 0;
|
||
}
|
||
|
||
|
||
/* Register the file descriptor FD with the handler FNC (which gets
|
||
FNC_DATA as its first argument) for the direction DIR. DATA should
|
||
be the context for which the fd is added. R_TAG will hold the tag
|
||
that can be used to remove the fd. */
|
||
GpgmeError
|
||
_gpgme_add_io_cb (void *data, int fd, int dir, GpgmeIOCb fnc, void *fnc_data,
|
||
void **r_tag)
|
||
{
|
||
GpgmeError err;
|
||
GpgmeCtx ctx = (GpgmeCtx) data;
|
||
fd_table_t fdt;
|
||
struct wait_item_s *item;
|
||
struct tag *tag;
|
||
|
||
assert (fnc);
|
||
assert (ctx);
|
||
|
||
fdt = &ctx->fdt;
|
||
assert (fdt);
|
||
|
||
tag = malloc (sizeof *tag);
|
||
if (!tag)
|
||
return GPGME_Out_Of_Core;
|
||
tag->ctx = ctx;
|
||
|
||
/* Allocate a structure to hold information about the handler. */
|
||
item = calloc (1, sizeof *item);
|
||
if (!item)
|
||
{
|
||
free (tag);
|
||
return GPGME_Out_Of_Core;
|
||
}
|
||
item->ctx = ctx;
|
||
item->dir = dir;
|
||
item->handler = fnc;
|
||
item->handler_value = fnc_data;
|
||
|
||
err = fd_table_put (fdt, fd, dir, item, &tag->idx);
|
||
if (err)
|
||
{
|
||
free (tag);
|
||
free (item);
|
||
return err;
|
||
}
|
||
|
||
*r_tag = tag;
|
||
return 0;
|
||
}
|
||
|
||
|
||
void
|
||
_gpgme_remove_io_cb (void *data)
|
||
{
|
||
struct tag *tag = data;
|
||
GpgmeCtx ctx;
|
||
fd_table_t fdt;
|
||
int idx;
|
||
|
||
assert (tag);
|
||
ctx = tag->ctx;
|
||
assert (ctx);
|
||
fdt = &ctx->fdt;
|
||
assert (fdt);
|
||
idx = tag->idx;
|
||
|
||
DEBUG2 ("setting fd %d (item=%p) done", fdt->fds[idx].fd,
|
||
fdt->fds[idx].opaque);
|
||
free (fdt->fds[idx].opaque);
|
||
free (tag);
|
||
|
||
/* Free the table entry. */
|
||
fdt->fds[idx].fd = -1;
|
||
fdt->fds[idx].for_read = 0;
|
||
fdt->fds[idx].for_write = 0;
|
||
fdt->fds[idx].opaque = NULL;
|
||
}
|