2 * Amanda, The Advanced Maryland Automatic Network Disk Archiver
3 * Copyright (c) 2008-2012 Zmanda, Inc. All Rights Reserved.
5 * This program is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU General Public License
7 * as published by the Free Software Foundation; either version 2
8 * of the License, or (at your option) any later version.
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
12 * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
15 * You should have received a copy of the GNU General Public License along
16 * with this program; if not, write to the Free Software Foundation, Inc.,
17 * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19 * Contact information: Zmanda Inc., 465 S. Mathilda Ave., Suite 300
20 * Sunnyvale, CA 94085, USA, or: http://www.zmanda.com
26 /* parent class for XferElement */
27 static GObjectClass *parent_class = NULL;
29 /* parent class for XferDest, XferFilter, and XferSource */
30 static XferElementClass *xfer_element_class = NULL;
32 /***********************
40 xe->output_mech = XFER_MECH_NONE;
41 xe->input_mech = XFER_MECH_NONE;
42 xe->upstream = xe->downstream = NULL;
43 xe->_input_fd = xe->_output_fd = -1;
48 xfer_element_setup_impl(
49 XferElement *elt G_GNUC_UNUSED)
51 return TRUE; /* success */
55 xfer_element_set_size_impl(
56 XferElement *elt G_GNUC_UNUSED,
57 gint64 size G_GNUC_UNUSED)
61 return TRUE; /* success */
65 xfer_element_start_impl(
66 XferElement *elt G_GNUC_UNUSED)
68 return FALSE; /* will not send XMSG_DONE */
72 xfer_element_cancel_impl(
76 elt->cancelled = TRUE;
77 elt->expect_eof = expect_eof;
78 return elt->can_generate_eof;
82 xfer_element_pull_buffer_impl(
83 XferElement *elt G_GNUC_UNUSED,
84 size_t *size G_GNUC_UNUSED)
90 xfer_element_push_buffer_impl(
91 XferElement *elt G_GNUC_UNUSED,
92 gpointer buf G_GNUC_UNUSED,
93 size_t size G_GNUC_UNUSED)
97 static xfer_element_mech_pair_t *
98 xfer_element_get_mech_pairs_impl(
101 return XFER_ELEMENT_GET_CLASS(elt)->mech_pairs;
105 xfer_element_repr_impl(
109 elt->repr = newvstrallocf(elt->repr, "<%s@%p>",
110 G_OBJECT_TYPE_NAME(G_OBJECT(elt)),
118 xfer_element_finalize(
121 XferElement *elt = XFER_ELEMENT(obj_self);
124 /* free the repr cache */
125 if (elt->repr) g_free(elt->repr);
127 /* close up the input/output file descriptors, being careful to do so
128 * atomically, and making any errors doing so into mere warnings */
129 fd = xfer_element_swap_input_fd(elt, -1);
130 if (fd != -1 && close(fd) != 0)
131 g_warning("error closing fd %d: %s", fd, strerror(errno));
132 fd = xfer_element_swap_output_fd(elt, -1);
133 if (fd != -1 && close(fd) != 0)
134 g_warning("error closing fd %d: %s", fd, strerror(errno));
137 G_OBJECT_CLASS(parent_class)->finalize(obj_self);
141 xfer_element_class_init(
142 XferElementClass * klass)
144 GObjectClass *goc = (GObjectClass*) klass;
146 klass->repr = xfer_element_repr_impl;
147 klass->setup = xfer_element_setup_impl;
148 klass->set_size = xfer_element_set_size_impl;
149 klass->start = xfer_element_start_impl;
150 klass->cancel = xfer_element_cancel_impl;
151 klass->pull_buffer = xfer_element_pull_buffer_impl;
152 klass->push_buffer = xfer_element_push_buffer_impl;
153 klass->get_mech_pairs = xfer_element_get_mech_pairs_impl;
155 goc->finalize = xfer_element_finalize;
157 klass->perl_class = NULL;
159 parent_class = g_type_class_peek_parent(klass);
160 xfer_element_class = klass;
164 xfer_element_get_type(void)
166 static GType type = 0;
168 if G_UNLIKELY(type == 0) {
169 static const GTypeInfo info = {
170 sizeof (XferElementClass),
171 (GBaseInitFunc) NULL,
172 (GBaseFinalizeFunc) NULL,
173 (GClassInitFunc) xfer_element_class_init,
174 (GClassFinalizeFunc) NULL,
175 NULL /* class_data */,
176 sizeof (XferElement),
178 (GInstanceInitFunc) xfer_element_init,
182 type = g_type_register_static (G_TYPE_OBJECT, "XferElement", &info,
183 (GTypeFlags)G_TYPE_FLAG_ABSTRACT);
197 if (elt) g_object_unref(elt);
204 return XFER_ELEMENT_GET_CLASS(elt)->repr(elt);
211 return XFER_ELEMENT_GET_CLASS(elt)->setup(elt);
215 xfer_element_set_size(
219 return XFER_ELEMENT_GET_CLASS(elt)->set_size(elt, size);
226 return XFER_ELEMENT_GET_CLASS(elt)->start(elt);
234 return XFER_ELEMENT_GET_CLASS(elt)->cancel(elt, expect_eof);
238 xfer_element_pull_buffer(
243 /* Make sure that the xfer is running before calling upstream's
244 * pull_buffer method; this avoids a race condition where upstream
245 * hasn't finished its xfer_element_start yet, and isn't ready for
247 g_mutex_lock(elt->xfer->status_mutex);
248 status = elt->xfer->status;
249 g_mutex_unlock(elt->xfer->status_mutex);
250 if (status == XFER_START)
251 wait_until_xfer_running(elt->xfer);
253 return XFER_ELEMENT_GET_CLASS(elt)->pull_buffer(elt, size);
257 xfer_element_push_buffer(
262 /* There is no race condition with push_buffer, because downstream
263 * elements are started first. */
264 XFER_ELEMENT_GET_CLASS(elt)->push_buffer(elt, buf, size);
267 xfer_element_mech_pair_t *
268 xfer_element_get_mech_pairs(
271 return XFER_ELEMENT_GET_CLASS(elt)->get_mech_pairs(elt);
279 xfer_element_drain_buffers(
280 XferElement *upstream)
285 while ((buf =xfer_element_pull_buffer(upstream, &size))) {
291 xfer_element_drain_fd(
298 len = full_read(fd, buf, sizeof(buf));
299 if (len < sizeof(buf))