300 lines
7.0 KiB
C
300 lines
7.0 KiB
C
/* A GInputStream that links to a VipsSource under the hood.
|
|
*
|
|
* 10/11/19 kleisauke
|
|
*/
|
|
|
|
/*
|
|
|
|
This file is part of VIPS.
|
|
|
|
VIPS is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU Lesser General Public License as published by
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU Lesser General Public License for more details.
|
|
|
|
You should have received a copy of the GNU Lesser General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
|
|
02110-1301 USA
|
|
|
|
*/
|
|
|
|
/*
|
|
|
|
These files are distributed with VIPS - http://www.vips.ecs.soton.ac.uk
|
|
|
|
*/
|
|
|
|
/*
|
|
#define DEBUG
|
|
*/
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
#include <config.h>
|
|
#endif /*HAVE_CONFIG_H*/
|
|
#include <glib/gi18n-lib.h>
|
|
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <errno.h>
|
|
#include <ctype.h>
|
|
|
|
#include <vips/vips.h>
|
|
#include <vips/internal.h>
|
|
#include <vips/debug.h>
|
|
|
|
#include <gio/gio.h>
|
|
|
|
static void vips_g_input_stream_seekable_iface_init( GSeekableIface *iface );
|
|
|
|
G_DEFINE_TYPE_WITH_CODE( VipsGInputStream, vips_g_input_stream,
|
|
G_TYPE_INPUT_STREAM, G_IMPLEMENT_INTERFACE( G_TYPE_SEEKABLE,
|
|
vips_g_input_stream_seekable_iface_init ) )
|
|
|
|
enum {
|
|
PROP_0,
|
|
PROP_STREAM
|
|
};
|
|
|
|
static void
|
|
vips_g_input_stream_get_property( GObject *object, guint prop_id,
|
|
GValue *value, GParamSpec *pspec )
|
|
{
|
|
VipsGInputStream *gstream = VIPS_G_INPUT_STREAM( object );
|
|
|
|
switch( prop_id ) {
|
|
case PROP_STREAM:
|
|
g_value_set_object( value, gstream->source );
|
|
break;
|
|
|
|
default:
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID( object, prop_id, pspec );
|
|
}
|
|
}
|
|
|
|
static void
|
|
vips_g_input_stream_set_property( GObject *object, guint prop_id,
|
|
const GValue *value, GParamSpec *pspec )
|
|
{
|
|
VipsGInputStream *gstream = VIPS_G_INPUT_STREAM( object );
|
|
|
|
switch( prop_id ) {
|
|
case PROP_STREAM:
|
|
gstream->source = g_value_dup_object( value );
|
|
break;
|
|
|
|
default:
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID( object, prop_id, pspec );
|
|
}
|
|
}
|
|
|
|
static void
|
|
vips_g_input_stream_finalize( GObject *object )
|
|
{
|
|
VipsGInputStream *gstream = VIPS_G_INPUT_STREAM( object );
|
|
|
|
VIPS_UNREF( gstream->source );
|
|
|
|
G_OBJECT_CLASS( vips_g_input_stream_parent_class )->finalize( object );
|
|
}
|
|
|
|
static goffset
|
|
vips_g_input_stream_tell( GSeekable *seekable )
|
|
{
|
|
VipsGInputStream *gstream = VIPS_G_INPUT_STREAM( seekable );
|
|
|
|
goffset pos;
|
|
|
|
VIPS_DEBUG_MSG( "vips_g_input_stream_tell:\n" );
|
|
|
|
pos = vips_source_seek( gstream->source, 0, SEEK_CUR );
|
|
if( pos == -1 )
|
|
return( 0 );
|
|
|
|
return( pos );
|
|
}
|
|
|
|
static gboolean
|
|
vips_g_input_stream_can_seek( GSeekable *seekable )
|
|
{
|
|
VipsGInputStream *gstream = VIPS_G_INPUT_STREAM( seekable );
|
|
|
|
VIPS_DEBUG_MSG( "vips_g_input_stream_can_seek: %d\n",
|
|
!gstream->source->is_pipe );
|
|
|
|
return( !gstream->source->is_pipe );
|
|
}
|
|
|
|
static int
|
|
seek_type_to_lseek( GSeekType type )
|
|
{
|
|
switch( type ) {
|
|
default:
|
|
case G_SEEK_CUR:
|
|
return( SEEK_CUR );
|
|
case G_SEEK_SET:
|
|
return( SEEK_SET );
|
|
case G_SEEK_END:
|
|
return( SEEK_END );
|
|
}
|
|
}
|
|
|
|
static gboolean
|
|
vips_g_input_stream_seek( GSeekable *seekable, goffset offset,
|
|
GSeekType type, GCancellable *cancellable, GError **error )
|
|
{
|
|
VipsGInputStream *gstream = VIPS_G_INPUT_STREAM( seekable );
|
|
|
|
VIPS_DEBUG_MSG( "vips_g_input_stream_seek: offset = %" G_GINT64_FORMAT
|
|
", type = %d\n", offset, type );
|
|
|
|
if( vips_source_seek( gstream->source, offset,
|
|
seek_type_to_lseek( type ) ) == -1 ) {
|
|
g_set_error( error, G_IO_ERROR,
|
|
G_IO_ERROR_FAILED,
|
|
_( "Error while seeking: %s" ),
|
|
vips_error_buffer() );
|
|
return( FALSE );
|
|
}
|
|
|
|
|
|
return( TRUE );
|
|
}
|
|
|
|
static gboolean
|
|
vips_g_input_stream_can_truncate( GSeekable *seekable )
|
|
{
|
|
return( FALSE );
|
|
}
|
|
|
|
static gboolean
|
|
vips_g_input_stream_truncate( GSeekable *seekable, goffset offset,
|
|
GCancellable *cancellable, GError **error )
|
|
{
|
|
g_set_error_literal( error,
|
|
G_IO_ERROR,
|
|
G_IO_ERROR_NOT_SUPPORTED,
|
|
_( "Cannot truncate VipsGInputStream" ) );
|
|
|
|
return( FALSE );
|
|
}
|
|
|
|
static gssize
|
|
vips_g_input_stream_read( GInputStream *stream, void *buffer, gsize count,
|
|
GCancellable *cancellable, GError **error )
|
|
{
|
|
VipsGInputStream *gstream = VIPS_G_INPUT_STREAM( stream );
|
|
|
|
gssize res;
|
|
|
|
VIPS_DEBUG_MSG( "vips_g_input_stream_read: count: %zd\n", count );
|
|
|
|
if( g_cancellable_set_error_if_cancelled( cancellable, error ) )
|
|
return( -1 );
|
|
|
|
if( (res = vips_source_read( gstream->source, buffer, count )) == -1 )
|
|
g_set_error( error, G_IO_ERROR,
|
|
G_IO_ERROR_FAILED,
|
|
_( "Error while reading: %s" ),
|
|
vips_error_buffer() );
|
|
|
|
return( res );
|
|
}
|
|
|
|
static gssize
|
|
vips_g_input_stream_skip( GInputStream *stream, gsize count,
|
|
GCancellable *cancellable, GError **error )
|
|
{
|
|
VipsGInputStream *gstream = VIPS_G_INPUT_STREAM( stream );
|
|
|
|
gssize position;
|
|
|
|
VIPS_DEBUG_MSG( "vips_g_input_stream_skip: count: %zd\n", count );
|
|
|
|
if( g_cancellable_set_error_if_cancelled( cancellable, error ) )
|
|
return( -1 );
|
|
|
|
position = vips_source_seek( gstream->source, count, SEEK_CUR );
|
|
if( position == -1 ) {
|
|
g_set_error( error, G_IO_ERROR,
|
|
G_IO_ERROR_FAILED,
|
|
_( "Error while seeking: %s" ),
|
|
vips_error_buffer() );
|
|
return( -1 );
|
|
}
|
|
|
|
return( position );
|
|
}
|
|
|
|
static gboolean
|
|
vips_g_input_stream_close( GInputStream *stream,
|
|
GCancellable *cancellable, GError **error )
|
|
{
|
|
VipsGInputStream *gstream = VIPS_G_INPUT_STREAM( stream );
|
|
|
|
vips_source_minimise( gstream->source );
|
|
|
|
return( TRUE );
|
|
}
|
|
|
|
static void
|
|
vips_g_input_stream_seekable_iface_init( GSeekableIface *iface )
|
|
{
|
|
iface->tell = vips_g_input_stream_tell;
|
|
iface->can_seek = vips_g_input_stream_can_seek;
|
|
iface->seek = vips_g_input_stream_seek;
|
|
iface->can_truncate = vips_g_input_stream_can_truncate;
|
|
iface->truncate_fn = vips_g_input_stream_truncate;
|
|
}
|
|
|
|
static void
|
|
vips_g_input_stream_class_init( VipsGInputStreamClass *class )
|
|
{
|
|
GObjectClass *gobject_class = G_OBJECT_CLASS( class );
|
|
GInputStreamClass *istream_class = G_INPUT_STREAM_CLASS( class );
|
|
|
|
gobject_class->finalize = vips_g_input_stream_finalize;
|
|
gobject_class->get_property = vips_g_input_stream_get_property;
|
|
gobject_class->set_property = vips_g_input_stream_set_property;
|
|
|
|
istream_class->read_fn = vips_g_input_stream_read;
|
|
istream_class->skip = vips_g_input_stream_skip;
|
|
istream_class->close_fn = vips_g_input_stream_close;
|
|
|
|
g_object_class_install_property( gobject_class, PROP_STREAM,
|
|
g_param_spec_object( "input",
|
|
_( "Input" ),
|
|
_( "Stream to wrap" ),
|
|
VIPS_TYPE_SOURCE, G_PARAM_CONSTRUCT_ONLY |
|
|
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS ) );
|
|
|
|
}
|
|
|
|
static void
|
|
vips_g_input_stream_init( VipsGInputStream *gstream )
|
|
{
|
|
}
|
|
|
|
/**
|
|
* vips_g_input_stream_new_from_source:
|
|
* @source: vips source to wrap
|
|
*
|
|
* Create a new #GInputStream wrapping a #VipsSource. This is useful for
|
|
* loaders like SVG and PDF which support GInput methods.
|
|
*
|
|
* Returns: a new #GInputStream
|
|
*/
|
|
GInputStream *
|
|
vips_g_input_stream_new_from_source( VipsSource *source )
|
|
{
|
|
return( g_object_new( VIPS_TYPE_G_INPUT_STREAM,
|
|
"input", source,
|
|
NULL ) );
|
|
}
|