ucb/source/ucp/gio/gio_seekable.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: gio_seekable.cxx,v $
  10  * $Revision: 1.2 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 #include <rtl/memory.h>
  32 #include <com/sun/star/ucb/InteractiveAugmentedIOException.hpp>
  33 #include <ucbhelper/cancelcommandexecution.hxx>
  34 #include <string.h>
  35
  36 #include "gio_seekable.hxx"
  37 #include "gio_content.hxx"
  38
  39 using namespace com::sun::star;
  40
  41 namespace gio
  42 {
  43
  44 Seekable::Seekable(GSeekable *pStream) : mpStream(pStream)
  45 {
  46     if (!mpStream)
  47         throw io::NotConnectedException();
  48 }
  49
  50 Seekable::~Seekable( void )
  51 {
  52 }
  53
  54 void SAL_CALL Seekable::truncate( void )
  55     throw( io::IOException, uno::RuntimeException )
  56 {
  57     if (!mpStream)
  58         throw io::NotConnectedException();
  59
  60     if (!g_seekable_can_truncate(mpStream))
  61         throw io::IOException(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("Truncate unsupported")),
  62             static_cast< cppu::OWeakObject * >(this));
  63
  64     GError *pError=NULL;
  65     if (!g_seekable_truncate(mpStream, 0, NULL, &pError))
  66         convertToException(pError, static_cast< cppu::OWeakObject * >(this));
  67 }
  68
  69 void SAL_CALL Seekable::seek( sal_Int64 location )
  70     throw( lang::IllegalArgumentException, io::IOException, uno::RuntimeException )
  71 {
  72     if (!mpStream)
  73         throw io::NotConnectedException();
  74
  75     if (!g_seekable_can_seek(mpStream))
  76         throw io::IOException(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("Seek unsupported")),
  77             static_cast< cppu::OWeakObject * >(this));
  78
  79     GError *pError=NULL;
  80     if (!g_seekable_seek(mpStream, location, G_SEEK_SET, NULL, &pError))
  81         convertToException(pError, static_cast< cppu::OWeakObject * >(this));
  82 }
  83
  84 sal_Int64 SAL_CALL Seekable::getPosition() throw( io::IOException, uno::RuntimeException )
  85 {
  86     if (!mpStream)
  87         throw io::NotConnectedException();
  88
  89     return g_seekable_tell(mpStream);
  90 }
  91
  92 sal_Int64 SAL_CALL Seekable::getLength() throw( io::IOException, uno::RuntimeException )
  93 {
  94     if (!mpStream)
  95         throw io::NotConnectedException();
  96
  97     bool bOk = false;
  98     sal_uInt64 nSize = 0;
  99
 100     GFileInfo* pInfo = G_IS_FILE_INPUT_STREAM(mpStream)
 101         ? g_file_input_stream_query_info(G_FILE_INPUT_STREAM(mpStream), const_cast<char*>(G_FILE_ATTRIBUTE_STANDARD_SIZE), NULL, NULL)
 102         : g_file_output_stream_query_info(G_FILE_OUTPUT_STREAM(mpStream), const_cast<char*>(G_FILE_ATTRIBUTE_STANDARD_SIZE), NULL, NULL);
 103
 104     if (pInfo)
 105     {
 106         if (g_file_info_has_attribute(pInfo, G_FILE_ATTRIBUTE_STANDARD_SIZE))
 107         {
 108             nSize = g_file_info_get_size(pInfo);
 109             bOk = true;
 110         }
 111         g_object_unref(pInfo);
 112     }
 113
 114     if (!bOk)
 115     {
 116         GError *pError=NULL;
 117         sal_Int64 nCurr = getPosition();
 118         if (!g_seekable_seek(mpStream, 0, G_SEEK_END, NULL, &pError))
 119             convertToException(pError, static_cast< cppu::OWeakObject * >(this));
 120         nSize = getPosition();
 121         seek(nCurr);
 122         bOk = true;
 123     }
 124
 125     if (!bOk)
 126         throw io::IOException(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("Getting size unsupported")),
 127             static_cast< cppu::OWeakObject * >(this));
 128
 129     return nSize;
 130 }
 131
 132 uno::Any Seekable::queryInterface( const uno::Type &type ) throw( uno::RuntimeException )
 133 {
 134     uno::Any aRet = ::cppu::queryInterface ( type,
 135         static_cast< XSeekable * >( this ) );
 136
 137     if (!aRet.hasValue() && g_seekable_can_truncate(mpStream))
 138         aRet = ::cppu::queryInterface ( type, static_cast< XTruncate * >( this ) );
 139
 140     return aRet.hasValue() ? aRet : OWeakObject::queryInterface( type );
 141 }
 142
 143 }