1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
| | #define _GNU_SOURCE
#include "stdio_impl.h"
#include <stdlib.h>
#include <sys/ioctl.h>
#include <fcntl.h>
#include <errno.h>
#include <string.h>
struct fcookie {
void *cookie;
cookie_io_functions_t iofuncs;
};
static size_t cookieread(FILE *f, unsigned char *buf, size_t len)
{
struct fcookie *fc = f->cookie;
size_t ret;
if (fc->iofuncs.read == NULL) return -1;
ret = fc->iofuncs.read(fc->cookie, (char *) buf, len);
if (ret == 0) f->flags |= F_EOF;
f->rpos = f->buf;
f->rend = f->buf + ret;
return ret;
}
static size_t cookiewrite(FILE *f, const unsigned char *buf, size_t len)
{
struct fcookie *fc = f->cookie;
size_t ret;
size_t len2 = f->wpos - f->wbase;
if (fc->iofuncs.write == NULL) return -1;
if (len2) {
f->wpos = f->wbase;
if (cookiewrite(f, f->wpos, len2) < len2) return 0;
}
return fc->iofuncs.write(fc->cookie, (const char *) buf, len);
}
static off_t cookieseek(FILE *f, off_t off, int whence)
{
struct fcookie *fc = f->cookie;
if (fc->iofuncs.seek) return fc->iofuncs.seek(fc->cookie, &off, whence);
return -1;
}
static int cookieclose(FILE *f)
{
struct fcookie *fc = f->cookie;
if (fc->iofuncs.close) return fc->iofuncs.close(fc->cookie);
return 0;
}
FILE *fopencookie(void *cookie, const char *mode, cookie_io_functions_t iofuncs)
{
FILE *f;
struct winsize wsz;
struct fcookie *fc;
/* Check for valid initial mode character */
if (!strchr("rwa", *mode)) {
errno = EINVAL;
return 0;
}
/* Allocate FILE+fcookie+buffer or fail */
if (!(f=malloc(sizeof *f + sizeof *fc + UNGET + BUFSIZ))) return 0;
/* Zero-fill only the struct, not the buffer */
memset(f, 0, sizeof *f);
/* Impose mode restrictions */
if (!strchr(mode, '+')) f->flags = (*mode == 'r') ? F_NOWR : F_NORD;
/* Set up our fcookie */
fc = (void *)(f + 1);
fc->cookie = cookie;
fc->iofuncs.read = iofuncs.read;
fc->iofuncs.write = iofuncs.write;
fc->iofuncs.seek = iofuncs.seek;
fc->iofuncs.close = iofuncs.close;
f->fd = -1;
f->cookie = fc;
f->buf = (unsigned char *)f + sizeof *f + sizeof *fc + UNGET;
f->buf_size = BUFSIZ;
f->lbf = EOF;
/* Initialize op ptrs. No problem if some are unneeded. */
f->read = cookieread;
f->write = cookiewrite;
f->seek = cookieseek;
f->close = cookieclose;
if (!libc.threaded) f->lock = -1;
/* Add new FILE to open file list */
return __ofl_add(f);
}
|