1*cdf0e10cSrcweir /************************************************************************* 2*cdf0e10cSrcweir * 3*cdf0e10cSrcweir * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4*cdf0e10cSrcweir * 5*cdf0e10cSrcweir * Copyright 2000, 2010 Oracle and/or its affiliates. 6*cdf0e10cSrcweir * 7*cdf0e10cSrcweir * OpenOffice.org - a multi-platform office productivity suite 8*cdf0e10cSrcweir * 9*cdf0e10cSrcweir * This file is part of OpenOffice.org. 10*cdf0e10cSrcweir * 11*cdf0e10cSrcweir * OpenOffice.org is free software: you can redistribute it and/or modify 12*cdf0e10cSrcweir * it under the terms of the GNU Lesser General Public License version 3 13*cdf0e10cSrcweir * only, as published by the Free Software Foundation. 14*cdf0e10cSrcweir * 15*cdf0e10cSrcweir * OpenOffice.org is distributed in the hope that it will be useful, 16*cdf0e10cSrcweir * but WITHOUT ANY WARRANTY; without even the implied warranty of 17*cdf0e10cSrcweir * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 18*cdf0e10cSrcweir * GNU Lesser General Public License version 3 for more details 19*cdf0e10cSrcweir * (a copy is included in the LICENSE file that accompanied this code). 20*cdf0e10cSrcweir * 21*cdf0e10cSrcweir * You should have received a copy of the GNU Lesser General Public License 22*cdf0e10cSrcweir * version 3 along with OpenOffice.org. If not, see 23*cdf0e10cSrcweir * <http://www.openoffice.org/license.html> 24*cdf0e10cSrcweir * for a copy of the LGPLv3 License. 25*cdf0e10cSrcweir * 26*cdf0e10cSrcweir ************************************************************************/ 27*cdf0e10cSrcweir 28*cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove 29*cdf0e10cSrcweir #include "precompiled_comphelper.hxx" 30*cdf0e10cSrcweir #include <com/sun/star/io/XOutputStream.hpp> 31*cdf0e10cSrcweir 32*cdf0e10cSrcweir 33*cdf0e10cSrcweir #include <comphelper/seekableinput.hxx> 34*cdf0e10cSrcweir 35*cdf0e10cSrcweir using namespace ::com::sun::star; 36*cdf0e10cSrcweir 37*cdf0e10cSrcweir namespace comphelper 38*cdf0e10cSrcweir { 39*cdf0e10cSrcweir 40*cdf0e10cSrcweir const sal_Int32 nConstBufferSize = 32000; 41*cdf0e10cSrcweir 42*cdf0e10cSrcweir //--------------------------------------------------------------------------- 43*cdf0e10cSrcweir void copyInputToOutput_Impl( const uno::Reference< io::XInputStream >& xIn, 44*cdf0e10cSrcweir const uno::Reference< io::XOutputStream >& xOut ) 45*cdf0e10cSrcweir { 46*cdf0e10cSrcweir sal_Int32 nRead; 47*cdf0e10cSrcweir uno::Sequence< sal_Int8 > aSequence( nConstBufferSize ); 48*cdf0e10cSrcweir 49*cdf0e10cSrcweir do 50*cdf0e10cSrcweir { 51*cdf0e10cSrcweir nRead = xIn->readBytes( aSequence, nConstBufferSize ); 52*cdf0e10cSrcweir if ( nRead < nConstBufferSize ) 53*cdf0e10cSrcweir { 54*cdf0e10cSrcweir uno::Sequence< sal_Int8 > aTempBuf( aSequence.getConstArray(), nRead ); 55*cdf0e10cSrcweir xOut->writeBytes( aTempBuf ); 56*cdf0e10cSrcweir } 57*cdf0e10cSrcweir else 58*cdf0e10cSrcweir xOut->writeBytes( aSequence ); 59*cdf0e10cSrcweir } 60*cdf0e10cSrcweir while ( nRead == nConstBufferSize ); 61*cdf0e10cSrcweir } 62*cdf0e10cSrcweir 63*cdf0e10cSrcweir //--------------------------------------------------------------------------- 64*cdf0e10cSrcweir OSeekableInputWrapper::OSeekableInputWrapper( 65*cdf0e10cSrcweir const uno::Reference< io::XInputStream >& xInStream, 66*cdf0e10cSrcweir const uno::Reference< lang::XMultiServiceFactory >& xFactory ) 67*cdf0e10cSrcweir : m_xFactory( xFactory ) 68*cdf0e10cSrcweir , m_xOriginalStream( xInStream ) 69*cdf0e10cSrcweir { 70*cdf0e10cSrcweir if ( !m_xFactory.is() ) 71*cdf0e10cSrcweir throw uno::RuntimeException(); 72*cdf0e10cSrcweir } 73*cdf0e10cSrcweir 74*cdf0e10cSrcweir //--------------------------------------------------------------------------- 75*cdf0e10cSrcweir OSeekableInputWrapper::~OSeekableInputWrapper() 76*cdf0e10cSrcweir { 77*cdf0e10cSrcweir } 78*cdf0e10cSrcweir 79*cdf0e10cSrcweir //--------------------------------------------------------------------------- 80*cdf0e10cSrcweir uno::Reference< io::XInputStream > OSeekableInputWrapper::CheckSeekableCanWrap( 81*cdf0e10cSrcweir const uno::Reference< io::XInputStream >& xInStream, 82*cdf0e10cSrcweir const uno::Reference< lang::XMultiServiceFactory >& xFactory ) 83*cdf0e10cSrcweir { 84*cdf0e10cSrcweir // check that the stream is seekable and just wrap it if it is not 85*cdf0e10cSrcweir uno::Reference< io::XSeekable > xSeek( xInStream, uno::UNO_QUERY ); 86*cdf0e10cSrcweir if ( xSeek.is() ) 87*cdf0e10cSrcweir return xInStream; 88*cdf0e10cSrcweir 89*cdf0e10cSrcweir uno::Reference< io::XInputStream > xNewStream( 90*cdf0e10cSrcweir static_cast< io::XInputStream* >( 91*cdf0e10cSrcweir new OSeekableInputWrapper( xInStream, xFactory ) ) ); 92*cdf0e10cSrcweir return xNewStream; 93*cdf0e10cSrcweir } 94*cdf0e10cSrcweir 95*cdf0e10cSrcweir //--------------------------------------------------------------------------- 96*cdf0e10cSrcweir void OSeekableInputWrapper::PrepareCopy_Impl() 97*cdf0e10cSrcweir { 98*cdf0e10cSrcweir if ( !m_xCopyInput.is() ) 99*cdf0e10cSrcweir { 100*cdf0e10cSrcweir if ( !m_xFactory.is() ) 101*cdf0e10cSrcweir throw uno::RuntimeException(); 102*cdf0e10cSrcweir 103*cdf0e10cSrcweir uno::Reference< io::XOutputStream > xTempOut( 104*cdf0e10cSrcweir m_xFactory->createInstance( ::rtl::OUString::createFromAscii( "com.sun.star.io.TempFile" ) ), 105*cdf0e10cSrcweir uno::UNO_QUERY ); 106*cdf0e10cSrcweir 107*cdf0e10cSrcweir if ( xTempOut.is() ) 108*cdf0e10cSrcweir { 109*cdf0e10cSrcweir copyInputToOutput_Impl( m_xOriginalStream, xTempOut ); 110*cdf0e10cSrcweir xTempOut->closeOutput(); 111*cdf0e10cSrcweir 112*cdf0e10cSrcweir uno::Reference< io::XSeekable > xTempSeek( xTempOut, uno::UNO_QUERY ); 113*cdf0e10cSrcweir if ( xTempSeek.is() ) 114*cdf0e10cSrcweir { 115*cdf0e10cSrcweir xTempSeek->seek( 0 ); 116*cdf0e10cSrcweir m_xCopyInput = uno::Reference< io::XInputStream >( xTempOut, uno::UNO_QUERY ); 117*cdf0e10cSrcweir if ( m_xCopyInput.is() ) 118*cdf0e10cSrcweir m_xCopySeek = xTempSeek; 119*cdf0e10cSrcweir } 120*cdf0e10cSrcweir } 121*cdf0e10cSrcweir } 122*cdf0e10cSrcweir 123*cdf0e10cSrcweir if ( !m_xCopyInput.is() ) 124*cdf0e10cSrcweir throw io::IOException(); 125*cdf0e10cSrcweir } 126*cdf0e10cSrcweir 127*cdf0e10cSrcweir // XInputStream 128*cdf0e10cSrcweir //--------------------------------------------------------------------------- 129*cdf0e10cSrcweir sal_Int32 SAL_CALL OSeekableInputWrapper::readBytes( uno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead ) 130*cdf0e10cSrcweir throw ( io::NotConnectedException, 131*cdf0e10cSrcweir io::BufferSizeExceededException, 132*cdf0e10cSrcweir io::IOException, 133*cdf0e10cSrcweir uno::RuntimeException ) 134*cdf0e10cSrcweir { 135*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 136*cdf0e10cSrcweir 137*cdf0e10cSrcweir if ( !m_xOriginalStream.is() ) 138*cdf0e10cSrcweir throw io::NotConnectedException(); 139*cdf0e10cSrcweir 140*cdf0e10cSrcweir PrepareCopy_Impl(); 141*cdf0e10cSrcweir 142*cdf0e10cSrcweir return m_xCopyInput->readBytes( aData, nBytesToRead ); 143*cdf0e10cSrcweir } 144*cdf0e10cSrcweir 145*cdf0e10cSrcweir //--------------------------------------------------------------------------- 146*cdf0e10cSrcweir sal_Int32 SAL_CALL OSeekableInputWrapper::readSomeBytes( uno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead ) 147*cdf0e10cSrcweir throw ( io::NotConnectedException, 148*cdf0e10cSrcweir io::BufferSizeExceededException, 149*cdf0e10cSrcweir io::IOException, 150*cdf0e10cSrcweir uno::RuntimeException ) 151*cdf0e10cSrcweir { 152*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 153*cdf0e10cSrcweir 154*cdf0e10cSrcweir if ( !m_xOriginalStream.is() ) 155*cdf0e10cSrcweir throw io::NotConnectedException(); 156*cdf0e10cSrcweir 157*cdf0e10cSrcweir PrepareCopy_Impl(); 158*cdf0e10cSrcweir 159*cdf0e10cSrcweir return m_xCopyInput->readSomeBytes( aData, nMaxBytesToRead ); 160*cdf0e10cSrcweir } 161*cdf0e10cSrcweir 162*cdf0e10cSrcweir //--------------------------------------------------------------------------- 163*cdf0e10cSrcweir void SAL_CALL OSeekableInputWrapper::skipBytes( sal_Int32 nBytesToSkip ) 164*cdf0e10cSrcweir throw ( io::NotConnectedException, 165*cdf0e10cSrcweir io::BufferSizeExceededException, 166*cdf0e10cSrcweir io::IOException, 167*cdf0e10cSrcweir uno::RuntimeException ) 168*cdf0e10cSrcweir { 169*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 170*cdf0e10cSrcweir 171*cdf0e10cSrcweir if ( !m_xOriginalStream.is() ) 172*cdf0e10cSrcweir throw io::NotConnectedException(); 173*cdf0e10cSrcweir 174*cdf0e10cSrcweir PrepareCopy_Impl(); 175*cdf0e10cSrcweir 176*cdf0e10cSrcweir m_xCopyInput->skipBytes( nBytesToSkip ); 177*cdf0e10cSrcweir } 178*cdf0e10cSrcweir 179*cdf0e10cSrcweir //--------------------------------------------------------------------------- 180*cdf0e10cSrcweir sal_Int32 SAL_CALL OSeekableInputWrapper::available() 181*cdf0e10cSrcweir throw ( io::NotConnectedException, 182*cdf0e10cSrcweir io::IOException, 183*cdf0e10cSrcweir uno::RuntimeException ) 184*cdf0e10cSrcweir { 185*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 186*cdf0e10cSrcweir 187*cdf0e10cSrcweir if ( !m_xOriginalStream.is() ) 188*cdf0e10cSrcweir throw io::NotConnectedException(); 189*cdf0e10cSrcweir 190*cdf0e10cSrcweir PrepareCopy_Impl(); 191*cdf0e10cSrcweir 192*cdf0e10cSrcweir return m_xCopyInput->available(); 193*cdf0e10cSrcweir } 194*cdf0e10cSrcweir 195*cdf0e10cSrcweir //--------------------------------------------------------------------------- 196*cdf0e10cSrcweir void SAL_CALL OSeekableInputWrapper::closeInput() 197*cdf0e10cSrcweir throw ( io::NotConnectedException, 198*cdf0e10cSrcweir io::IOException, 199*cdf0e10cSrcweir uno::RuntimeException ) 200*cdf0e10cSrcweir { 201*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 202*cdf0e10cSrcweir 203*cdf0e10cSrcweir if ( !m_xOriginalStream.is() ) 204*cdf0e10cSrcweir throw io::NotConnectedException(); 205*cdf0e10cSrcweir 206*cdf0e10cSrcweir m_xOriginalStream->closeInput(); 207*cdf0e10cSrcweir m_xOriginalStream = uno::Reference< io::XInputStream >(); 208*cdf0e10cSrcweir 209*cdf0e10cSrcweir if ( m_xCopyInput.is() ) 210*cdf0e10cSrcweir { 211*cdf0e10cSrcweir m_xCopyInput->closeInput(); 212*cdf0e10cSrcweir m_xCopyInput = uno::Reference< io::XInputStream >(); 213*cdf0e10cSrcweir } 214*cdf0e10cSrcweir 215*cdf0e10cSrcweir m_xCopySeek = uno::Reference< io::XSeekable >(); 216*cdf0e10cSrcweir } 217*cdf0e10cSrcweir 218*cdf0e10cSrcweir 219*cdf0e10cSrcweir // XSeekable 220*cdf0e10cSrcweir //--------------------------------------------------------------------------- 221*cdf0e10cSrcweir void SAL_CALL OSeekableInputWrapper::seek( sal_Int64 location ) 222*cdf0e10cSrcweir throw ( lang::IllegalArgumentException, 223*cdf0e10cSrcweir io::IOException, 224*cdf0e10cSrcweir uno::RuntimeException ) 225*cdf0e10cSrcweir { 226*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 227*cdf0e10cSrcweir 228*cdf0e10cSrcweir if ( !m_xOriginalStream.is() ) 229*cdf0e10cSrcweir throw io::NotConnectedException(); 230*cdf0e10cSrcweir 231*cdf0e10cSrcweir PrepareCopy_Impl(); 232*cdf0e10cSrcweir 233*cdf0e10cSrcweir m_xCopySeek->seek( location ); 234*cdf0e10cSrcweir } 235*cdf0e10cSrcweir 236*cdf0e10cSrcweir //--------------------------------------------------------------------------- 237*cdf0e10cSrcweir sal_Int64 SAL_CALL OSeekableInputWrapper::getPosition() 238*cdf0e10cSrcweir throw ( io::IOException, 239*cdf0e10cSrcweir uno::RuntimeException ) 240*cdf0e10cSrcweir { 241*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 242*cdf0e10cSrcweir 243*cdf0e10cSrcweir if ( !m_xOriginalStream.is() ) 244*cdf0e10cSrcweir throw io::NotConnectedException(); 245*cdf0e10cSrcweir 246*cdf0e10cSrcweir PrepareCopy_Impl(); 247*cdf0e10cSrcweir 248*cdf0e10cSrcweir return m_xCopySeek->getPosition(); 249*cdf0e10cSrcweir } 250*cdf0e10cSrcweir 251*cdf0e10cSrcweir //--------------------------------------------------------------------------- 252*cdf0e10cSrcweir sal_Int64 SAL_CALL OSeekableInputWrapper::getLength() 253*cdf0e10cSrcweir throw ( io::IOException, 254*cdf0e10cSrcweir uno::RuntimeException ) 255*cdf0e10cSrcweir { 256*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 257*cdf0e10cSrcweir 258*cdf0e10cSrcweir if ( !m_xOriginalStream.is() ) 259*cdf0e10cSrcweir throw io::NotConnectedException(); 260*cdf0e10cSrcweir 261*cdf0e10cSrcweir PrepareCopy_Impl(); 262*cdf0e10cSrcweir 263*cdf0e10cSrcweir return m_xCopySeek->getLength(); 264*cdf0e10cSrcweir } 265*cdf0e10cSrcweir 266*cdf0e10cSrcweir } // namespace comphelper 267*cdf0e10cSrcweir 268