/
fh.c
164 lines (128 loc) · 3.88 KB
/
fh.c
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
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
/* -*-Mode: C;-*-
* $Id: fh.c,v 1.1 2004/01/05 18:54:23 icculus Exp $
*
* Copyright (C) 1998, 1999, Josh MacDonald.
* All Rights Reserved.
*
* Author: Josh MacDonald <jmacd@CS.Berkeley.EDU>
*/
#include "edsio.h"
/* Handle source/sink impls
*/
typedef struct _HandleSerialSource HandleSerialSource;
typedef struct _HandleSerialSink HandleSerialSink;
struct _HandleSerialSource {
SerialSource source;
FileHandle* fh;
};
struct _HandleSerialSink {
SerialSink sink;
FileHandle* fh;
gpointer data1;
gpointer data2;
gpointer data3;
gboolean (* cont_onclose) (gpointer data1, gpointer data2, gpointer data3);
};
static SerialType handle_source_type (SerialSource* source, gboolean set_allocation);
static gboolean handle_source_close (SerialSource* source);
static gboolean handle_source_read (SerialSource* source, guint8 *ptr, guint32 len);
static void handle_source_free (SerialSource* source);
static gboolean handle_sink_type (SerialSink* sink, SerialType type, guint len, gboolean set_allocation);
static gboolean handle_sink_close (SerialSink* sink);
static gboolean handle_sink_write (SerialSink* sink, const guint8 *ptr, guint32 len);
static void handle_sink_free (SerialSink* sink);
SerialSource*
handle_source (FileHandle* fh)
{
HandleSerialSource* it = g_new0 (HandleSerialSource, 1);
serializeio_source_init (&it->source,
handle_source_type,
handle_source_close,
handle_source_read,
handle_source_free,
NULL,
NULL);
it->fh = fh;
return &it->source;
}
SerialSink*
handle_sink (FileHandle* fh, gpointer data1, gpointer data2, gpointer data3, gboolean (* cont_onclose) (gpointer data1, gpointer data2, gpointer data3))
{
HandleSerialSink* it = g_new0 (HandleSerialSink, 1);
serializeio_sink_init (&it->sink,
handle_sink_type,
handle_sink_close,
handle_sink_write,
handle_sink_free,
NULL);
it->fh = fh;
it->data1 = data1;
it->data2 = data2;
it->data3 = data3;
it->cont_onclose = cont_onclose;
return &it->sink;
}
SerialType
handle_source_type (SerialSource* source, gboolean set_allocation)
{
HandleSerialSource* ssource = (HandleSerialSource*) source;
guint32 x;
if (! ssource->fh->table->table_handle_getui (ssource->fh, &x))
return ST_Error;
if (set_allocation)
{
if (! ssource->fh->table->table_handle_getui (ssource->fh, &source->alloc_total))
return ST_Error;
}
return x;
}
gboolean
handle_source_close (SerialSource* source)
{
HandleSerialSource* ssource = (HandleSerialSource*) source;
return ssource->fh->table->table_handle_close (ssource->fh, 0);
}
gboolean
handle_source_read (SerialSource* source, guint8 *ptr, guint32 len)
{
HandleSerialSource* ssource = (HandleSerialSource*) source;
return ssource->fh->table->table_handle_read (ssource->fh, ptr, len) == len;
}
void
handle_source_free (SerialSource* source)
{
g_free (source);
}
gboolean
handle_sink_type (SerialSink* sink, SerialType type, guint len, gboolean set_allocation)
{
HandleSerialSink* ssink = (HandleSerialSink*) sink;
if (! ssink->fh->table->table_handle_putui (ssink->fh, type))
return FALSE;
if (set_allocation && ! ssink->fh->table->table_handle_putui (ssink->fh, len))
return FALSE;
return TRUE;
}
gboolean
handle_sink_close (SerialSink* sink)
{
HandleSerialSink* ssink = (HandleSerialSink*) sink;
if (ssink->fh->table->table_handle_close (ssink->fh, 0))
{
if (ssink->cont_onclose)
return ssink->cont_onclose (ssink->data1, ssink->data2, ssink->data3);
return TRUE;
}
return FALSE;
}
gboolean
handle_sink_write (SerialSink* sink, const guint8 *ptr, guint32 len)
{
HandleSerialSink* ssink = (HandleSerialSink*) sink;
return ssink->fh->table->table_handle_write (ssink->fh, ptr, len);
}
void
handle_sink_free (SerialSink* sink)
{
g_free (sink);
}