2 * Amanda, The Advanced Maryland Automatic Network Disk Archiver
3 * Copyright (c) 2008, 2009, 2010 Zmanda, Inc. All Rights Reserved.
5 * This program is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 as published
7 * by the Free Software Foundation.
9 * This program is distributed in the hope that it will be useful, but
10 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
11 * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
14 * You should have received a copy of the GNU General Public License along
15 * with this program; if not, write to the Free Software Foundation, Inc.,
16 * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
18 * Contact information: Zmanda Inc., 465 S. Mathilda Ave., Suite 300
19 * Sunnyvale, CA 94085, USA, or: http://www.zmanda.com
25 /* parent class for XferElement */
26 static GObjectClass *parent_class = NULL;
28 /* parent class for XferDest, XferFilter, and XferSource */
29 static XferElementClass *xfer_element_class = NULL;
31 /***********************
39 xe->output_mech = XFER_MECH_NONE;
40 xe->input_mech = XFER_MECH_NONE;
41 xe->upstream = xe->downstream = NULL;
42 xe->input_fd = xe->output_fd = -1;
47 xfer_element_setup_impl(
48 XferElement *elt G_GNUC_UNUSED)
50 return TRUE; /* success */
54 xfer_element_start_impl(
55 XferElement *elt G_GNUC_UNUSED)
57 return FALSE; /* will not send XMSG_DONE */
61 xfer_element_cancel_impl(
65 elt->cancelled = TRUE;
66 elt->expect_eof = expect_eof;
67 return elt->can_generate_eof;
71 xfer_element_pull_buffer_impl(
72 XferElement *elt G_GNUC_UNUSED,
73 size_t *size G_GNUC_UNUSED)
79 xfer_element_push_buffer_impl(
80 XferElement *elt G_GNUC_UNUSED,
81 gpointer buf G_GNUC_UNUSED,
82 size_t size G_GNUC_UNUSED)
86 static xfer_element_mech_pair_t *
87 xfer_element_get_mech_pairs_impl(
90 return XFER_ELEMENT_GET_CLASS(elt)->mech_pairs;
94 xfer_element_repr_impl(
98 elt->repr = newvstrallocf(elt->repr, "<%s@%p>",
99 G_OBJECT_TYPE_NAME(G_OBJECT(elt)),
107 xfer_element_finalize(
110 XferElement *elt = XFER_ELEMENT(obj_self);
112 /* free the repr cache */
113 if (elt->repr) g_free(elt->repr);
116 G_OBJECT_CLASS(parent_class)->finalize(obj_self);
120 xfer_element_class_init(
121 XferElementClass * klass)
123 GObjectClass *goc = (GObjectClass*) klass;
125 klass->repr = xfer_element_repr_impl;
126 klass->setup = xfer_element_setup_impl;
127 klass->start = xfer_element_start_impl;
128 klass->cancel = xfer_element_cancel_impl;
129 klass->pull_buffer = xfer_element_pull_buffer_impl;
130 klass->push_buffer = xfer_element_push_buffer_impl;
131 klass->get_mech_pairs = xfer_element_get_mech_pairs_impl;
133 goc->finalize = xfer_element_finalize;
135 klass->perl_class = NULL;
137 parent_class = g_type_class_peek_parent(klass);
138 xfer_element_class = klass;
142 xfer_element_get_type(void)
144 static GType type = 0;
146 if G_UNLIKELY(type == 0) {
147 static const GTypeInfo info = {
148 sizeof (XferElementClass),
149 (GBaseInitFunc) NULL,
150 (GBaseFinalizeFunc) NULL,
151 (GClassInitFunc) xfer_element_class_init,
152 (GClassFinalizeFunc) NULL,
153 NULL /* class_data */,
154 sizeof (XferElement),
156 (GInstanceInitFunc) xfer_element_init,
160 type = g_type_register_static (G_TYPE_OBJECT, "XferElement", &info,
161 (GTypeFlags)G_TYPE_FLAG_ABSTRACT);
175 if (elt) g_object_unref(elt);
182 return XFER_ELEMENT_GET_CLASS(elt)->repr(elt);
189 return XFER_ELEMENT_GET_CLASS(elt)->setup(elt);
196 return XFER_ELEMENT_GET_CLASS(elt)->start(elt);
204 return XFER_ELEMENT_GET_CLASS(elt)->cancel(elt, expect_eof);
208 xfer_element_pull_buffer(
212 /* Make sure that the xfer is running before calling upstream's
213 * pull_buffer method; this avoids a race condition where upstream
214 * hasn't finished its xfer_element_start yet, and isn't ready for
216 if (elt->xfer->status == XFER_START)
217 wait_until_xfer_running(elt->xfer);
219 return XFER_ELEMENT_GET_CLASS(elt)->pull_buffer(elt, size);
223 xfer_element_push_buffer(
228 /* There is no race condition with push_buffer, because downstream
229 * elements are started first. */
230 XFER_ELEMENT_GET_CLASS(elt)->push_buffer(elt, buf, size);
233 xfer_element_mech_pair_t *
234 xfer_element_get_mech_pairs(
237 return XFER_ELEMENT_GET_CLASS(elt)->get_mech_pairs(elt);
245 xfer_element_drain_by_pulling(
246 XferElement *upstream)
251 while ((buf =xfer_element_pull_buffer(upstream, &size))) {
257 xfer_element_drain_by_reading(
264 len = full_read(fd, buf, sizeof(buf));
265 if (len < sizeof(buf))