2004-12-07 Marcus Brinkmann <marcus@g10code.de>
[gpgme.git] / gpgme / wait.c
1 /* wait.c 
2    Copyright (C) 2000 Werner Koch (dd9jn)
3    Copyright (C) 2001, 2002, 2003, 2004 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 <stdlib.h>
26 #include <string.h>
27 #include <assert.h>
28 #include <errno.h>
29 #include <sys/types.h>
30
31 #include "util.h"
32 #include "context.h"
33 #include "ops.h"
34 #include "wait.h"
35 #include "sema.h"
36 #include "io.h"
37 #include "engine.h"
38 #include "debug.h"
39
40 \f
41 void
42 _gpgme_fd_table_init (fd_table_t fdt)
43 {
44   fdt->fds = NULL;
45   fdt->size = 0;
46 }
47
48 void
49 _gpgme_fd_table_deinit (fd_table_t fdt)
50 {
51   if (fdt->fds)
52     free (fdt->fds);
53 }
54
55
56 /* XXX We should keep a marker and roll over for speed.  */
57 static gpgme_error_t
58 fd_table_put (fd_table_t fdt, int fd, int dir, void *opaque, int *idx)
59 {
60   unsigned int i, j;
61   struct io_select_fd_s *new_fds;
62
63   for (i = 0; i < fdt->size; i++)
64     {
65       if (fdt->fds[i].fd == -1)
66         break;
67     }
68   if (i == fdt->size)
69     {
70 #define FDT_ALLOCSIZE 10
71       new_fds = realloc (fdt->fds, (fdt->size + FDT_ALLOCSIZE)
72                          * sizeof (*new_fds));
73       if (!new_fds)
74         return gpg_error_from_errno (errno);
75       
76       fdt->fds = new_fds;
77       fdt->size += FDT_ALLOCSIZE;
78       for (j = 0; j < FDT_ALLOCSIZE; j++)
79         fdt->fds[i + j].fd = -1;
80     }
81
82   fdt->fds[i].fd = fd;
83   fdt->fds[i].for_read = (dir == 1);
84   fdt->fds[i].for_write = (dir == 0);
85   fdt->fds[i].frozen = 0;
86   fdt->fds[i].signaled = 0;
87   fdt->fds[i].opaque = opaque;
88   *idx = i;
89   return 0;
90 }
91
92 \f
93 /* Register the file descriptor FD with the handler FNC (which gets
94    FNC_DATA as its first argument) for the direction DIR.  DATA should
95    be the context for which the fd is added.  R_TAG will hold the tag
96    that can be used to remove the fd.  */
97 gpgme_error_t
98 _gpgme_add_io_cb (void *data, int fd, int dir, gpgme_io_cb_t fnc,
99                   void *fnc_data, void **r_tag)
100 {
101   gpgme_error_t err;
102   gpgme_ctx_t ctx = (gpgme_ctx_t) data;
103   fd_table_t fdt;
104   struct wait_item_s *item;
105   struct tag *tag;
106
107   assert (fnc);
108   assert (ctx);
109
110   fdt = &ctx->fdt;
111   assert (fdt);
112
113   tag = malloc (sizeof *tag);
114   if (!tag)
115     return gpg_error_from_errno (errno);
116   tag->ctx = ctx;
117
118   /* Allocate a structure to hold information about the handler.  */
119   item = calloc (1, sizeof *item);
120   if (!item)
121     {
122       int saved_errno = errno;
123       free (tag);
124       return gpg_error_from_errno (saved_errno);
125     }
126   item->ctx = ctx;
127   item->dir = dir;
128   item->handler = fnc;
129   item->handler_value = fnc_data;
130
131   err = fd_table_put (fdt, fd, dir, item, &tag->idx);
132   if (err)
133     {
134       free (tag);
135       free (item);
136       return err;
137     }
138
139   *r_tag = tag;
140   return 0;
141 }
142
143
144 void
145 _gpgme_remove_io_cb (void *data)
146 {
147   struct tag *tag = data;
148   gpgme_ctx_t ctx;
149   fd_table_t fdt;
150   int idx;
151
152   assert (tag);
153   ctx = tag->ctx;
154   assert (ctx);
155   fdt = &ctx->fdt;
156   assert (fdt);
157   idx = tag->idx;
158
159   DEBUG2 ("setting fd %d (item=%p) done", fdt->fds[idx].fd,
160           fdt->fds[idx].opaque);
161   free (fdt->fds[idx].opaque);
162   free (tag);
163
164   /* Free the table entry.  */
165   fdt->fds[idx].fd = -1;
166   fdt->fds[idx].for_read = 0;
167   fdt->fds[idx].for_write = 0;
168   fdt->fds[idx].opaque = NULL;
169 }