End of response marker in response from wsh/wproto to wcgi.
[egate.git] / util / gip.c
1 /*
2  * Copyright (c) 1995, the EUROPAGATE consortium (see below).
3  *
4  * The EUROPAGATE consortium members are:
5  *
6  *    University College Dublin
7  *    Danmarks Teknologiske Videnscenter
8  *    An Chomhairle Leabharlanna
9  *    Consejo Superior de Investigaciones Cientificas
10  *
11  * Permission to use, copy, modify, distribute, and sell this software and
12  * its documentation, in whole or in part, for any purpose, is hereby granted,
13  * provided that:
14  *
15  * 1. This copyright and permission notice appear in all copies of the
16  * software and its documentation. Notices of copyright or attribution
17  * which appear at the beginning of any file must remain unchanged.
18  *
19  * 2. The names of EUROPAGATE or the project partners may not be used to
20  * endorse or promote products derived from this software without specific
21  * prior written permission.
22  *
23  * 3. Users of this software (implementors and gateway operators) agree to
24  * inform the EUROPAGATE consortium of their use of the software. This
25  * information will be used to evaluate the EUROPAGATE project and the
26  * software, and to plan further developments. The consortium may use
27  * the information in later publications.
28  * 
29  * 4. Users of this software agree to make their best efforts, when
30  * documenting their use of the software, to acknowledge the EUROPAGATE
31  * consortium, and the role played by the software in their work.
32  *
33  * THIS SOFTWARE IS PROVIDED "AS IS" AND WITHOUT WARRANTY OF ANY KIND,
34  * EXPRESS, IMPLIED, OR OTHERWISE, INCLUDING WITHOUT LIMITATION, ANY
35  * WARRANTY OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE.
36  * IN NO EVENT SHALL THE EUROPAGATE CONSORTIUM OR ITS MEMBERS BE LIABLE
37  * FOR ANY SPECIAL, INCIDENTAL, INDIRECT OR CONSEQUENTIAL DAMAGES OF
38  * ANY KIND, OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA
39  * OR PROFITS, WHETHER OR NOT ADVISED OF THE POSSIBILITY OF DAMAGE, AND
40  * ON ANY THEORY OF LIABILITY, ARISING OUT OF OR IN CONNECTION WITH THE
41  * USE OR PERFORMANCE OF THIS SOFTWARE.
42  *
43  */
44 /* Gateway kernel
45  * Europagate, 1995
46  *
47  * $Log: gip.c,v $
48  * Revision 1.8  1995/05/22 09:03:41  adam
49  * New argument, block, to cs_open.
50  *
51  * Revision 1.7  1995/05/16  09:40:52  adam
52  * LICENSE.
53  *
54  * Revision 1.6  1995/05/02  15:26:52  adam
55  * EINTR obvserved on reads and writes.
56  *
57  * Revision 1.5  1995/05/01  16:27:28  adam
58  * Various improvements. Close-on-exec and close on failure on either
59  * read or write FIFO.
60  *
61  * Revision 1.4  1995/04/21  16:38:07  adam
62  * Added more debugging logs.
63  *
64  * Revision 1.3  1995/04/20  15:12:42  adam
65  * Minor hacks really.
66  *
67  * Revision 1.2  1995/03/27  12:52:18  adam
68  * A little more verbose in marc dump.
69  *
70  * Revision 1.1  1995/03/27  08:24:58  adam
71  * New module gip: Gateway IPc module.
72  * New module gw-db: Gateway hash-db module (user information table).
73  *
74  */
75
76 #include <stdio.h>
77 #include <stdlib.h>
78 #include <assert.h>
79 #include <string.h>
80 #include <unistd.h>
81 #include <fcntl.h>
82 #include <sys/file.h>
83 #include <sys/stat.h>
84 #include <errno.h>
85
86 #include <gw-log.h>
87
88 #include <gip.h>
89
90 GIP gip_initialize (const char *name)
91 {
92     GIP gip = malloc (sizeof(*gip));
93
94     if (!gip)
95         return NULL;
96     if (!(gip->name = malloc (strlen(name)+1)))
97     {
98         free (gip);
99         return NULL;
100     }
101     strcpy (gip->name, name);
102     gip->ret = mknod (gip->name, S_IFIFO|0666, 0);
103     gip->errno = errno;
104     gip->rfd = gip->wfd = -1;
105     gw_log (GW_LOG_DEBUG, "gip", "Creating %s", gip->name);
106     return gip;
107 }
108
109 int gip_destroy (GIP gip)
110 {
111     assert (gip);
112
113     unlink (gip->name);
114     free (gip->name);
115     free (gip);
116     return 0;
117 }
118
119 int gip_infileno (GIP gip)
120 {
121     return gip->rfd;
122 }
123
124 int gip_outfileno (GIP gip)
125 {
126     return gip->wfd;
127 }
128
129 int gip_errno (GIP gip)
130 {
131     return gip->errno;
132 }
133
134 int gip_read (GIP gip, char *buf, size_t count)
135 {
136     int r, no = 0;
137     while (no < count)
138     {
139         while (1)
140         {
141             r = read (gip->rfd, buf+no, count-no);
142             if (r != -1)
143                 break;
144             if (errno != EINTR)
145             {
146                 gip->errno = errno;
147                 return -1;
148             }
149         }
150         no += r;
151     }
152     return 0;
153 }
154
155 int gip_write (GIP gip, const char *buf, size_t count)
156 {
157     int r, no = 0;
158     while (no < count)
159     {
160         while (1)
161         {
162             r = write (gip->wfd, buf+no, count-no);
163             if (r != -1)
164                 break;
165             if (errno != EINTR)
166             {
167                 gip->errno = errno;
168                 return -1;
169             }
170         }
171         no += r;
172     }
173     return 0;
174 }
175
176 int gip_wline (GIP gip, const char *buf)
177 {
178     return gip_write (gip, buf, strlen(buf));
179 }
180