~ubuntu-branches/ubuntu/lucid/nfs-utils/lucid

« back to all changes in this revision

Viewing changes to utils/svcgssd/cacheio.c

  • Committer: Bazaar Package Importer
  • Author(s): Anibal Monsalve Salazar
  • Date: 2006-07-03 10:36:59 UTC
  • mto: (12.1.1 feisty)
  • mto: This revision was merged to the branch mainline in revision 6.
  • Revision ID: james.westby@ubuntu.com-20060703103659-71qzs6f21zzmjmhx
Tags: upstream-1.0.8
ImportĀ upstreamĀ versionĀ 1.0.8

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
/*
2
 
  Copyright (c) 2004 The Regents of the University of Michigan.
3
 
  All rights reserved.
4
 
 
5
 
  Redistribution and use in source and binary forms, with or without
6
 
  modification, are permitted provided that the following conditions
7
 
  are met:
8
 
 
9
 
  1. Redistributions of source code must retain the above copyright
10
 
     notice, this list of conditions and the following disclaimer.
11
 
  2. Redistributions in binary form must reproduce the above copyright
12
 
     notice, this list of conditions and the following disclaimer in the
13
 
     documentation and/or other materials provided with the distribution.
14
 
  3. Neither the name of the University nor the names of its
15
 
     contributors may be used to endorse or promote products derived
16
 
     from this software without specific prior written permission.
17
 
 
18
 
  THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED
19
 
  WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
20
 
  MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
21
 
  DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
22
 
  FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
23
 
  CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
24
 
  SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
25
 
  BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
26
 
  LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
27
 
  NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
28
 
  SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
29
 
*/
30
 
 
31
 
/*
32
 
 * support/nfs/cacheio.c
33
 
 * support IO on the cache channel files in 2.5 and beyond.
34
 
 * These use 'qwords' which are like words, but with a little quoting.
35
 
 *
36
 
 */
37
 
 
38
 
 
39
 
/*
40
 
 * Support routines for text-based upcalls.
41
 
 * Fields are separated by spaces.
42
 
 * Fields are either mangled to quote space tab newline slosh with slosh
43
 
 * or a hexified with a leading \x
44
 
 * Record is terminated with newline.
45
 
 *
46
 
 */
47
 
 
48
 
#include "cacheio.h"
49
 
#include <stdio.h>
50
 
#include <ctype.h>
51
 
#include <unistd.h>
52
 
#include <sys/types.h>
53
 
#include <sys/stat.h>
54
 
#include <fcntl.h>
55
 
#include <time.h>
56
 
#include <stdlib.h>
57
 
#include <string.h>
58
 
#include "err_util.h"
59
 
 
60
 
void qword_add(char **bpp, int *lp, char *str)
61
 
{
62
 
        char *bp = *bpp;
63
 
        int len = *lp;
64
 
        char c;
65
 
 
66
 
        if (len < 0) return;
67
 
 
68
 
        while ((c=*str++) && len)
69
 
                switch(c) {
70
 
                case ' ':
71
 
                case '\t':
72
 
                case '\n':
73
 
                case '\\':
74
 
                        if (len >= 4) {
75
 
                                *bp++ = '\\';
76
 
                                *bp++ = '0' + ((c & 0300)>>6);
77
 
                                *bp++ = '0' + ((c & 0070)>>3);
78
 
                                *bp++ = '0' + ((c & 0007)>>0);
79
 
                        }
80
 
                        len -= 4;
81
 
                        break;
82
 
                default:
83
 
                        *bp++ = c;
84
 
                        len--;
85
 
                }
86
 
        if (c || len <1) len = -1;
87
 
        else {
88
 
                *bp++ = ' ';
89
 
                len--;
90
 
        }
91
 
        *bpp = bp;
92
 
        *lp = len;
93
 
}
94
 
 
95
 
void qword_addhex(char **bpp, int *lp, char *buf, int blen)
96
 
{
97
 
        char *bp = *bpp;
98
 
        int len = *lp;
99
 
 
100
 
        if (len < 0) return;
101
 
 
102
 
        if (len > 2) {
103
 
                *bp++ = '\\';
104
 
                *bp++ = 'x';
105
 
                len -= 2;
106
 
                while (blen && len >= 2) {
107
 
                        unsigned char c = *buf++;
108
 
                        *bp++ = '0' + ((c&0xf0)>>4) + (c>=0xa0)*('a'-'9'-1);
109
 
                        *bp++ = '0' + (c&0x0f) + ((c&0x0f)>=0x0a)*('a'-'9'-1);
110
 
                        len -= 2;
111
 
                        blen--;
112
 
                }
113
 
        }
114
 
        if (blen || len<1) len = -1;
115
 
        else {
116
 
                *bp++ = ' ';
117
 
                len--;
118
 
        }
119
 
        *bpp = bp;
120
 
        *lp = len;
121
 
}
122
 
 
123
 
void qword_addint(char **bpp, int *lp, int n)
124
 
{
125
 
        int len;
126
 
 
127
 
        len = snprintf(*bpp, *lp, "%d ", n);
128
 
        if (len > *lp)
129
 
                len = *lp;
130
 
        *bpp += len;
131
 
        *lp -= len;
132
 
}
133
 
 
134
 
void qword_addeol(char **bpp, int *lp)
135
 
{
136
 
        if (*lp <= 0)
137
 
                return;
138
 
        **bpp = '\n';
139
 
        (*bpp)++;
140
 
        (*lp)--;
141
 
}
142
 
 
143
 
static char qword_buf[8192];
144
 
static char tmp_buf[8192];
145
 
void qword_print(FILE *f, char *str)
146
 
{
147
 
        char *bp = qword_buf;
148
 
        int len = sizeof(qword_buf);
149
 
        qword_add(&bp, &len, str);
150
 
        fwrite(qword_buf, bp-qword_buf, 1, f);
151
 
        /* XXX: */
152
 
        memcpy(tmp_buf, qword_buf, bp-qword_buf);
153
 
        tmp_buf[bp-qword_buf] = '\0';
154
 
        printerr(2, "%s", tmp_buf);
155
 
}
156
 
 
157
 
void qword_printhex(FILE *f, char *str, int slen)
158
 
{
159
 
        char *bp = qword_buf;
160
 
        int len = sizeof(qword_buf);
161
 
        qword_addhex(&bp, &len, str, slen);
162
 
        fwrite(qword_buf, bp-qword_buf, 1, f);
163
 
        /* XXX: */
164
 
        memcpy(tmp_buf, qword_buf, bp-qword_buf);
165
 
        tmp_buf[bp-qword_buf] = '\0';
166
 
        printerr(2, "%s", tmp_buf);
167
 
}
168
 
 
169
 
void qword_printint(FILE *f, int num)
170
 
{
171
 
        fprintf(f, "%d ", num);
172
 
        printerr(2, "%d ", num);
173
 
}
174
 
 
175
 
void qword_eol(FILE *f)
176
 
{
177
 
        fprintf(f,"\n");
178
 
        fflush(f);
179
 
        printerr(2, "\n");
180
 
}
181
 
 
182
 
 
183
 
 
184
 
#define isodigit(c) (isdigit(c) && c <= '7')
185
 
int qword_get(char **bpp, char *dest, int bufsize)
186
 
{
187
 
        /* return bytes copied, or -1 on error */
188
 
        char *bp = *bpp;
189
 
        int len = 0;
190
 
 
191
 
        while (*bp == ' ') bp++;
192
 
 
193
 
        if (bp[0] == '\\' && bp[1] == 'x') {
194
 
                /* HEX STRING */
195
 
                bp += 2;
196
 
                while (isxdigit(bp[0]) && isxdigit(bp[1]) && len < bufsize) {
197
 
                        int byte = isdigit(*bp) ? *bp-'0' : toupper(*bp)-'A'+10;
198
 
                        bp++;
199
 
                        byte <<= 4;
200
 
                        byte |= isdigit(*bp) ? *bp-'0' : toupper(*bp)-'A'+10;
201
 
                        *dest++ = byte;
202
 
                        bp++;
203
 
                        len++;
204
 
                }
205
 
        } else {
206
 
                /* text with \nnn octal quoting */
207
 
                while (*bp != ' ' && *bp != '\n' && *bp && len < bufsize-1) {
208
 
                        if (*bp == '\\' &&
209
 
                            isodigit(bp[1]) && (bp[1] <= '3') &&
210
 
                            isodigit(bp[2]) &&
211
 
                            isodigit(bp[3])) {
212
 
                                int byte = (*++bp -'0');
213
 
                                bp++;
214
 
                                byte = (byte << 3) | (*bp++ - '0');
215
 
                                byte = (byte << 3) | (*bp++ - '0');
216
 
                                *dest++ = byte;
217
 
                                len++;
218
 
                        } else {
219
 
                                *dest++ = *bp++;
220
 
                                len++;
221
 
                        }
222
 
                }
223
 
        }
224
 
 
225
 
        if (*bp != ' ' && *bp != '\n' && *bp != '\0')
226
 
                return -1;
227
 
        while (*bp == ' ') bp++;
228
 
        *bpp = bp;
229
 
        *dest = '\0';
230
 
        return len;
231
 
}
232
 
 
233
 
int qword_get_int(char **bpp, int *anint)
234
 
{
235
 
        char buf[50];
236
 
        char *ep;
237
 
        int rv;
238
 
        int len = qword_get(bpp, buf, 50);
239
 
        if (len < 0) return -1;
240
 
        if (len ==0) return -1;
241
 
        rv = strtol(buf, &ep, 0);
242
 
        if (*ep) return -1;
243
 
        *anint = rv;
244
 
        return 0;
245
 
}
246
 
 
247
 
int readline(int fd, char **buf, int *lenp)
248
 
{
249
 
        /* read a line into *buf, which is malloced *len long
250
 
         * realloc if needed until we find a \n
251
 
         * nul out the \n and return
252
 
         * 0 of eof, 1 of success
253
 
         */
254
 
        int len;
255
 
 
256
 
        if (*lenp == 0) {
257
 
                char *b = malloc(128);
258
 
                if (b == NULL)
259
 
                        return 0;
260
 
                *buf = b;
261
 
                *lenp = 128;
262
 
        }
263
 
        len = read(fd, *buf, *lenp);
264
 
        if (len <= 0) {
265
 
                printerr(2, "read error in readline: %d\n", len);
266
 
                return 0;
267
 
        }
268
 
        while ((*buf)[len-1] != '\n') {
269
 
        /* now the less common case.  There was no newline,
270
 
         * so we have to keep reading after re-alloc
271
 
         */
272
 
                char *new;
273
 
                int nl;
274
 
                *lenp += 128;
275
 
                new = realloc(*buf, *lenp);
276
 
                if (new == NULL)
277
 
                        return 0;
278
 
                *buf = new;
279
 
                nl = read(fd, *buf +len, *lenp - len);
280
 
                if (nl <= 0 ) {
281
 
                        printerr(2, "read error in readline: %d\n", nl);
282
 
                        return 0;
283
 
                }
284
 
                len += nl;
285
 
        }
286
 
        (*buf)[len-1] = 0;
287
 
        printerr(1, "read line with %d characters:\n%s\n", *lenp, *buf);
288
 
        return 1;
289
 
}