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 <comphelper/oslfile2streamwrap.hxx> 31*cdf0e10cSrcweir 32*cdf0e10cSrcweir #include <algorithm> 33*cdf0e10cSrcweir 34*cdf0e10cSrcweir namespace comphelper 35*cdf0e10cSrcweir { 36*cdf0e10cSrcweir using namespace osl; 37*cdf0e10cSrcweir 38*cdf0e10cSrcweir //------------------------------------------------------------------ 39*cdf0e10cSrcweir OSLInputStreamWrapper::OSLInputStreamWrapper( File& _rFile ) 40*cdf0e10cSrcweir :m_pFile(&_rFile) 41*cdf0e10cSrcweir ,m_bFileOwner(sal_False) 42*cdf0e10cSrcweir { 43*cdf0e10cSrcweir } 44*cdf0e10cSrcweir 45*cdf0e10cSrcweir //------------------------------------------------------------------ 46*cdf0e10cSrcweir OSLInputStreamWrapper::OSLInputStreamWrapper( File* pStream, sal_Bool bOwner ) 47*cdf0e10cSrcweir :m_pFile( pStream ) 48*cdf0e10cSrcweir ,m_bFileOwner( bOwner ) 49*cdf0e10cSrcweir { 50*cdf0e10cSrcweir } 51*cdf0e10cSrcweir 52*cdf0e10cSrcweir //------------------------------------------------------------------ 53*cdf0e10cSrcweir OSLInputStreamWrapper::~OSLInputStreamWrapper() 54*cdf0e10cSrcweir { 55*cdf0e10cSrcweir if( m_bFileOwner ) 56*cdf0e10cSrcweir delete m_pFile; 57*cdf0e10cSrcweir } 58*cdf0e10cSrcweir 59*cdf0e10cSrcweir //------------------------------------------------------------------------------ 60*cdf0e10cSrcweir sal_Int32 SAL_CALL OSLInputStreamWrapper::readBytes(staruno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) 61*cdf0e10cSrcweir throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException ) 62*cdf0e10cSrcweir { 63*cdf0e10cSrcweir if (!m_pFile) 64*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(), static_cast<staruno::XWeak*>(this)); 65*cdf0e10cSrcweir 66*cdf0e10cSrcweir if (nBytesToRead < 0) 67*cdf0e10cSrcweir throw stario::BufferSizeExceededException(::rtl::OUString(),static_cast<staruno::XWeak*>(this)); 68*cdf0e10cSrcweir 69*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 70*cdf0e10cSrcweir 71*cdf0e10cSrcweir aData.realloc(nBytesToRead); 72*cdf0e10cSrcweir 73*cdf0e10cSrcweir sal_uInt64 nRead = 0; 74*cdf0e10cSrcweir FileBase::RC eError = m_pFile->read((void*)aData.getArray(), nBytesToRead, nRead); 75*cdf0e10cSrcweir if (eError != FileBase::E_None) 76*cdf0e10cSrcweir throw stario::BufferSizeExceededException(::rtl::OUString(),static_cast<staruno::XWeak*>(this)); 77*cdf0e10cSrcweir 78*cdf0e10cSrcweir // Wenn gelesene Zeichen < MaxLength, staruno::Sequence anpassen 79*cdf0e10cSrcweir if (nRead < (sal_uInt32)nBytesToRead) 80*cdf0e10cSrcweir aData.realloc( sal::static_int_cast< sal_Int32 >(nRead) ); 81*cdf0e10cSrcweir 82*cdf0e10cSrcweir return sal::static_int_cast< sal_Int32 >(nRead); 83*cdf0e10cSrcweir } 84*cdf0e10cSrcweir 85*cdf0e10cSrcweir //------------------------------------------------------------------------------ 86*cdf0e10cSrcweir sal_Int32 SAL_CALL OSLInputStreamWrapper::readSomeBytes(staruno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException ) 87*cdf0e10cSrcweir { 88*cdf0e10cSrcweir if (!m_pFile) 89*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(), static_cast<staruno::XWeak*>(this)); 90*cdf0e10cSrcweir 91*cdf0e10cSrcweir if (nMaxBytesToRead < 0) 92*cdf0e10cSrcweir throw stario::BufferSizeExceededException(::rtl::OUString(),static_cast<staruno::XWeak*>(this)); 93*cdf0e10cSrcweir 94*cdf0e10cSrcweir /* 95*cdf0e10cSrcweir if (m_pFile->IsEof()) 96*cdf0e10cSrcweir { 97*cdf0e10cSrcweir aData.realloc(0); 98*cdf0e10cSrcweir return 0; 99*cdf0e10cSrcweir } 100*cdf0e10cSrcweir else 101*cdf0e10cSrcweir */ 102*cdf0e10cSrcweir return readBytes(aData, nMaxBytesToRead); 103*cdf0e10cSrcweir } 104*cdf0e10cSrcweir 105*cdf0e10cSrcweir //------------------------------------------------------------------------------ 106*cdf0e10cSrcweir void SAL_CALL OSLInputStreamWrapper::skipBytes(sal_Int32 nBytesToSkip) throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException ) 107*cdf0e10cSrcweir { 108*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 109*cdf0e10cSrcweir if (!m_pFile) 110*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(), static_cast<staruno::XWeak*>(this)); 111*cdf0e10cSrcweir 112*cdf0e10cSrcweir sal_uInt64 nCurrentPos; 113*cdf0e10cSrcweir m_pFile->getPos(nCurrentPos); 114*cdf0e10cSrcweir 115*cdf0e10cSrcweir sal_uInt64 nNewPos = nCurrentPos + nBytesToSkip; 116*cdf0e10cSrcweir FileBase::RC eError = m_pFile->setPos(osl_Pos_Absolut, nNewPos); 117*cdf0e10cSrcweir if (eError != FileBase::E_None) 118*cdf0e10cSrcweir { 119*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(), static_cast<staruno::XWeak*>(this)); 120*cdf0e10cSrcweir } 121*cdf0e10cSrcweir 122*cdf0e10cSrcweir #ifdef DBG_UTIL 123*cdf0e10cSrcweir m_pFile->getPos(nCurrentPos); 124*cdf0e10cSrcweir // volatile int dummy = 0; // to take a look at last changes ;-) 125*cdf0e10cSrcweir #endif 126*cdf0e10cSrcweir } 127*cdf0e10cSrcweir 128*cdf0e10cSrcweir //------------------------------------------------------------------------------ 129*cdf0e10cSrcweir sal_Int32 SAL_CALL OSLInputStreamWrapper::available() throw( stario::NotConnectedException, staruno::RuntimeException ) 130*cdf0e10cSrcweir { 131*cdf0e10cSrcweir ::osl::MutexGuard aGuard( m_aMutex ); 132*cdf0e10cSrcweir if (!m_pFile) 133*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(), static_cast<staruno::XWeak*>(this)); 134*cdf0e10cSrcweir 135*cdf0e10cSrcweir sal_uInt64 nPos; 136*cdf0e10cSrcweir FileBase::RC eError = m_pFile->getPos(nPos); 137*cdf0e10cSrcweir if (eError != FileBase::E_None) 138*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(), static_cast<staruno::XWeak*>(this)); 139*cdf0e10cSrcweir 140*cdf0e10cSrcweir sal_uInt64 nDummy = 0; 141*cdf0e10cSrcweir eError = m_pFile->setPos(Pos_End, nDummy); 142*cdf0e10cSrcweir if (eError != FileBase::E_None) 143*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(),static_cast<staruno::XWeak*>(this)); 144*cdf0e10cSrcweir 145*cdf0e10cSrcweir sal_uInt64 nAvailable; 146*cdf0e10cSrcweir eError = m_pFile->getPos(nAvailable); 147*cdf0e10cSrcweir if (eError != FileBase::E_None) 148*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(),static_cast<staruno::XWeak*>(this)); 149*cdf0e10cSrcweir 150*cdf0e10cSrcweir nAvailable = nAvailable - nPos; 151*cdf0e10cSrcweir eError = m_pFile->setPos(Pos_Absolut, nPos); 152*cdf0e10cSrcweir if (eError != FileBase::E_None) 153*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(),static_cast<staruno::XWeak*>(this)); 154*cdf0e10cSrcweir return sal::static_int_cast< sal_Int32 >( 155*cdf0e10cSrcweir std::max(nAvailable, sal::static_int_cast< sal_uInt64 >(SAL_MAX_INT32))); 156*cdf0e10cSrcweir } 157*cdf0e10cSrcweir 158*cdf0e10cSrcweir //------------------------------------------------------------------------------ 159*cdf0e10cSrcweir void SAL_CALL OSLInputStreamWrapper::closeInput() throw( stario::NotConnectedException, staruno::RuntimeException ) 160*cdf0e10cSrcweir { 161*cdf0e10cSrcweir if (!m_pFile) 162*cdf0e10cSrcweir throw stario::NotConnectedException(::rtl::OUString(), static_cast<staruno::XWeak*>(this)); 163*cdf0e10cSrcweir 164*cdf0e10cSrcweir m_pFile->close(); 165*cdf0e10cSrcweir if (m_bFileOwner) 166*cdf0e10cSrcweir delete m_pFile; 167*cdf0e10cSrcweir 168*cdf0e10cSrcweir m_pFile = NULL; 169*cdf0e10cSrcweir } 170*cdf0e10cSrcweir 171*cdf0e10cSrcweir /*************************************************************************/ 172*cdf0e10cSrcweir // stario::XOutputStream 173*cdf0e10cSrcweir //------------------------------------------------------------------------------ 174*cdf0e10cSrcweir void SAL_CALL OSLOutputStreamWrapper::writeBytes(const staruno::Sequence< sal_Int8 >& aData) throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException ) 175*cdf0e10cSrcweir { 176*cdf0e10cSrcweir sal_uInt64 nWritten; 177*cdf0e10cSrcweir FileBase::RC eError = rFile.write(aData.getConstArray(),aData.getLength(), nWritten); 178*cdf0e10cSrcweir if (eError != FileBase::E_None 179*cdf0e10cSrcweir || nWritten != sal::static_int_cast< sal_uInt32 >(aData.getLength())) 180*cdf0e10cSrcweir { 181*cdf0e10cSrcweir throw stario::BufferSizeExceededException(::rtl::OUString(),static_cast<staruno::XWeak*>(this)); 182*cdf0e10cSrcweir } 183*cdf0e10cSrcweir } 184*cdf0e10cSrcweir 185*cdf0e10cSrcweir //------------------------------------------------------------------ 186*cdf0e10cSrcweir void SAL_CALL OSLOutputStreamWrapper::flush() throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException ) 187*cdf0e10cSrcweir { 188*cdf0e10cSrcweir } 189*cdf0e10cSrcweir 190*cdf0e10cSrcweir //------------------------------------------------------------------ 191*cdf0e10cSrcweir void SAL_CALL OSLOutputStreamWrapper::closeOutput() throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException ) 192*cdf0e10cSrcweir { 193*cdf0e10cSrcweir rFile.close(); 194*cdf0e10cSrcweir } 195*cdf0e10cSrcweir 196*cdf0e10cSrcweir } // namespace comphelper 197*cdf0e10cSrcweir 198*cdf0e10cSrcweir 199