1 /* GIO - GLib Input, Output and Streaming Library
3 * Copyright (C) 2009 Red Hat, Inc.
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2 of the License, or (at your option) any later version.
10 * This library is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Lesser General Public License for more details.
15 * You should have received a copy of the GNU Lesser General
16 * Public License along with this library; if not, write to the
17 * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
18 * Boston, MA 02111-1307, USA.
20 * Author: Alexander Larsson <alexl@redhat.com>
29 #include "gzlibdecompressor.h"
34 #include "gioenumtypes.h"
44 * SECTION:gzdecompressor
45 * @short_description: Zlib decompressor
48 * #GZlibDecompressor is an implementation of #GDecompressor that
49 * decompresses data compressed with zlib.
52 static void g_zlib_decompressor_iface_init (GConverterIface *iface);
59 struct _GZlibDecompressor
61 GObject parent_instance;
63 GZlibCompressorFormat format;
67 G_DEFINE_TYPE_WITH_CODE (GZlibDecompressor, g_zlib_decompressor, G_TYPE_OBJECT,
68 G_IMPLEMENT_INTERFACE (G_TYPE_CONVERTER,
69 g_zlib_decompressor_iface_init))
72 g_zlib_decompressor_finalize (GObject *object)
74 GZlibDecompressor *decompressor;
76 decompressor = G_ZLIB_DECOMPRESSOR (object);
78 inflateEnd (&decompressor->zstream);
80 G_OBJECT_CLASS (g_zlib_decompressor_parent_class)->finalize (object);
85 g_zlib_decompressor_set_property (GObject *object,
90 GZlibDecompressor *decompressor;
92 decompressor = G_ZLIB_DECOMPRESSOR (object);
97 decompressor->format = g_value_get_enum (value);
101 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
108 g_zlib_decompressor_get_property (GObject *object,
113 GZlibDecompressor *decompressor;
115 decompressor = G_ZLIB_DECOMPRESSOR (object);
120 g_value_set_enum (value, decompressor->format);
124 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
130 g_zlib_decompressor_init (GZlibDecompressor *decompressor)
135 g_zlib_decompressor_constructed (GObject *object)
137 GZlibDecompressor *decompressor;
140 decompressor = G_ZLIB_DECOMPRESSOR (object);
142 if (decompressor->format == G_ZLIB_COMPRESSOR_FORMAT_GZIP)
145 res = inflateInit2 (&decompressor->zstream, MAX_WBITS + 16);
148 res = inflateInit (&decompressor->zstream);
150 if (res == Z_MEM_ERROR )
151 g_error ("GZlibDecompressor: Not enough memory for zlib use");
154 g_warning ("unexpected zlib error: %s\n", decompressor->zstream.msg);
158 g_zlib_decompressor_class_init (GZlibDecompressorClass *klass)
160 GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
162 gobject_class->finalize = g_zlib_decompressor_finalize;
163 gobject_class->constructed = g_zlib_decompressor_constructed;
164 gobject_class->get_property = g_zlib_decompressor_get_property;
165 gobject_class->set_property = g_zlib_decompressor_set_property;
167 g_object_class_install_property (gobject_class,
169 g_param_spec_enum ("format",
170 P_("compression format"),
171 P_("The format of the compressed data"),
172 G_TYPE_ZLIB_COMPRESSOR_FORMAT,
173 G_ZLIB_COMPRESSOR_FORMAT_RAW,
174 G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
175 G_PARAM_STATIC_STRINGS));
179 * g_zlib_decompressor_new:
180 * @format: The format to use for the compressed data
182 * Creates a new #GZlibDecompressor.
184 * Returns: a new #GZlibDecompressor
189 g_zlib_decompressor_new (GZlibCompressorFormat format)
191 GZlibDecompressor *decompressor;
193 decompressor = g_object_new (G_TYPE_ZLIB_DECOMPRESSOR,
201 g_zlib_decompressor_reset (GConverter *converter)
203 GZlibDecompressor *decompressor = G_ZLIB_DECOMPRESSOR (converter);
206 res = inflateReset (&decompressor->zstream);
208 g_warning ("unexpected zlib error: %s\n", decompressor->zstream.msg);
211 static GConverterResult
212 g_zlib_decompressor_convert (GConverter *converter,
217 GConverterFlags flags,
219 gsize *bytes_written,
222 GZlibDecompressor *decompressor;
226 decompressor = G_ZLIB_DECOMPRESSOR (converter);
228 decompressor->zstream.next_in = (void *)inbuf;
229 decompressor->zstream.avail_in = inbuf_size;
231 decompressor->zstream.next_out = outbuf;
232 decompressor->zstream.avail_out = outbuf_size;
234 res = inflate (&decompressor->zstream, Z_NO_FLUSH);
236 if (res == Z_DATA_ERROR || res == Z_NEED_DICT)
238 g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_INVALID_DATA,
239 _("Invalid compressed data"));
240 return G_CONVERTER_ERROR;
243 if (res == Z_MEM_ERROR)
245 g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_FAILED,
246 _("Not enough memory"));
247 return G_CONVERTER_ERROR;
250 if (res == Z_STREAM_ERROR)
252 g_set_error (error, G_IO_ERROR, G_IO_ERROR_FAILED,
253 _("Internal error: %s"), decompressor->zstream.msg);
254 return G_CONVERTER_ERROR;
257 if (res == Z_BUF_ERROR)
259 if (flags & G_CONVERTER_FLUSH)
260 return G_CONVERTER_FLUSHED;
262 /* Z_FINISH not set, so this means no progress could be made */
263 /* We do have output space, so this should only happen if we
264 have no input but need some */
266 g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_PARTIAL_INPUT,
267 _("Need more input"));
268 return G_CONVERTER_ERROR;
271 if (res == Z_OK || res == Z_STREAM_END)
273 *bytes_read = inbuf_size - decompressor->zstream.avail_in;
274 *bytes_written = outbuf_size - decompressor->zstream.avail_out;
276 if (res == Z_STREAM_END)
277 return G_CONVERTER_FINISHED;
278 return G_CONVERTER_CONVERTED;
281 g_assert_not_reached ();
285 g_zlib_decompressor_iface_init (GConverterIface *iface)
287 iface->convert = g_zlib_decompressor_convert;
288 iface->reset = g_zlib_decompressor_reset;
291 #define __G_ZLIB_DECOMPRESSOR_C__
292 #include "gioaliasdef.c"