unotools/source/streaming/streamwrap.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: streamwrap.cxx,v $
  10  * $Revision: 1.8 $
  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 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_unotools.hxx"
  33 #include <unotools/streamwrap.hxx>
  34 #include <tools/stream.hxx>
  35 #include <tools/debug.hxx>
  36
  37 namespace utl
  38 {
  39
  40 using namespace ::com::sun::star::uno;
  41 using namespace ::com::sun::star::io;
  42 using namespace ::com::sun::star::lang;
  43
  44 //==================================================================
  45 //= OInputStreamWrapper
  46 //==================================================================
  47 DBG_NAME(OInputStreamWrapper)
  48 //------------------------------------------------------------------
  49 OInputStreamWrapper::OInputStreamWrapper( SvStream& _rStream )
  50                  :m_pSvStream(&_rStream)
  51                  ,m_bSvStreamOwner(sal_False)
  52 {
  53     DBG_CTOR(OInputStreamWrapper,NULL);
  54
  55 }
  56
  57 //------------------------------------------------------------------
  58 OInputStreamWrapper::OInputStreamWrapper( SvStream* pStream, sal_Bool bOwner )
  59                  :m_pSvStream( pStream )
  60                  ,m_bSvStreamOwner( bOwner )
  61 {
  62     DBG_CTOR(OInputStreamWrapper,NULL);
  63
  64 }
  65
  66 //------------------------------------------------------------------
  67 OInputStreamWrapper::~OInputStreamWrapper()
  68 {
  69     if( m_bSvStreamOwner )
  70         delete m_pSvStream;
  71
  72     DBG_DTOR(OInputStreamWrapper,NULL);
  73 }
  74
  75 //------------------------------------------------------------------------------
  76 sal_Int32 SAL_CALL OInputStreamWrapper::readBytes(staruno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead)
  77                 throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException )
  78 {
  79     checkConnected();
  80
  81     if (nBytesToRead < 0)
  82         throw stario::BufferSizeExceededException(::rtl::OUString(),static_cast<staruno::XWeak*>(this));
  83
  84     ::osl::MutexGuard aGuard( m_aMutex );
  85
  86     aData.realloc(nBytesToRead);
  87
  88     sal_uInt32 nRead = m_pSvStream->Read((void*)aData.getArray(), nBytesToRead);
  89     checkError();
  90
  91     // Wenn gelesene Zeichen < MaxLength, staruno::Sequence anpassen
  92     if (nRead < (sal_uInt32)nBytesToRead)
  93         aData.realloc( nRead );
  94
  95     return nRead;
  96 }
  97
  98 //------------------------------------------------------------------------------
  99 sal_Int32 SAL_CALL OInputStreamWrapper::readSomeBytes(staruno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException )
 100 {
 101     checkError();
 102
 103     if (nMaxBytesToRead < 0)
 104         throw stario::BufferSizeExceededException(::rtl::OUString(),static_cast<staruno::XWeak*>(this));
 105
 106     if (m_pSvStream->IsEof())
 107     {
 108         aData.realloc(0);
 109         return 0;
 110     }
 111     else
 112         return readBytes(aData, nMaxBytesToRead);
 113 }
 114
 115 //------------------------------------------------------------------------------
 116 void SAL_CALL OInputStreamWrapper::skipBytes(sal_Int32 nBytesToSkip) throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException )
 117 {
 118     ::osl::MutexGuard aGuard( m_aMutex );
 119     checkError();
 120
 121 #ifdef DBG_UTIL
 122     sal_uInt32 nCurrentPos = m_pSvStream->Tell();
 123 #endif
 124
 125     m_pSvStream->SeekRel(nBytesToSkip);
 126     checkError();
 127
 128 #ifdef DBG_UTIL
 129     nCurrentPos = m_pSvStream->Tell();
 130 #endif
 131 }
 132
 133 //------------------------------------------------------------------------------
 134 sal_Int32 SAL_CALL OInputStreamWrapper::available() throw( stario::NotConnectedException, staruno::RuntimeException )
 135 {
 136     ::osl::MutexGuard aGuard( m_aMutex );
 137     checkConnected();
 138
 139     sal_uInt32 nPos = m_pSvStream->Tell();
 140     checkError();
 141
 142     m_pSvStream->Seek(STREAM_SEEK_TO_END);
 143     checkError();
 144
 145     sal_Int32 nAvailable = (sal_Int32)m_pSvStream->Tell() - nPos;
 146     m_pSvStream->Seek(nPos);
 147     checkError();
 148
 149     return nAvailable;
 150 }
 151
 152 //------------------------------------------------------------------------------
 153 void SAL_CALL OInputStreamWrapper::closeInput() throw( stario::NotConnectedException, staruno::RuntimeException )
 154 {
 155     ::osl::MutexGuard aGuard( m_aMutex );
 156     checkConnected();
 157
 158     if (m_bSvStreamOwner)
 159         delete m_pSvStream;
 160
 161     m_pSvStream = NULL;
 162 }
 163
 164 //------------------------------------------------------------------------------
 165 void OInputStreamWrapper::checkConnected() const
 166 {
 167     if (!m_pSvStream)
 168         throw stario::NotConnectedException(::rtl::OUString(), const_cast<staruno::XWeak*>(static_cast<const staruno::XWeak*>(this)));
 169 }
 170
 171 //------------------------------------------------------------------------------
 172 void OInputStreamWrapper::checkError() const
 173 {
 174     checkConnected();
 175
 176     if (m_pSvStream->SvStream::GetError() != ERRCODE_NONE)
 177         // TODO: really evaluate the error
 178         throw stario::NotConnectedException(::rtl::OUString(), const_cast<staruno::XWeak*>(static_cast<const staruno::XWeak*>(this)));
 179 }
 180
 181 //==================================================================
 182 //= OSeekableInputStreamWrapper
 183 //==================================================================
 184 //------------------------------------------------------------------------------
 185 OSeekableInputStreamWrapper::OSeekableInputStreamWrapper(SvStream& _rStream)
 186 {
 187     SetStream( &_rStream, FALSE );
 188 }
 189
 190 //------------------------------------------------------------------------------
 191 OSeekableInputStreamWrapper::OSeekableInputStreamWrapper(SvStream* _pStream, sal_Bool _bOwner)
 192 {
 193     SetStream( _pStream, _bOwner );
 194 }
 195
 196 //------------------------------------------------------------------------------
 197 void SAL_CALL OSeekableInputStreamWrapper::seek( sal_Int64 _nLocation ) throw (IllegalArgumentException, IOException, RuntimeException)
 198 {
 199     ::osl::MutexGuard aGuard( m_aMutex );
 200     checkConnected();
 201
 202     m_pSvStream->Seek((sal_uInt32)_nLocation);
 203     checkError();
 204 }
 205
 206 //------------------------------------------------------------------------------
 207 sal_Int64 SAL_CALL OSeekableInputStreamWrapper::getPosition(  ) throw (IOException, RuntimeException)
 208 {
 209     ::osl::MutexGuard aGuard( m_aMutex );
 210     checkConnected();
 211
 212     sal_uInt32 nPos = m_pSvStream->Tell();
 213     checkError();
 214     return (sal_Int64)nPos;
 215 }
 216
 217 //------------------------------------------------------------------------------
 218 sal_Int64 SAL_CALL OSeekableInputStreamWrapper::getLength(  ) throw (IOException, RuntimeException)
 219 {
 220     ::osl::MutexGuard aGuard( m_aMutex );
 221     checkConnected();
 222
 223     sal_uInt32 nCurrentPos = m_pSvStream->Tell();
 224     checkError();
 225
 226     m_pSvStream->Seek(STREAM_SEEK_TO_END);
 227     sal_uInt32 nEndPos = m_pSvStream->Tell();
 228     m_pSvStream->Seek(nCurrentPos);
 229
 230     checkError();
 231
 232     return (sal_Int64)nEndPos;
 233 }
 234
 235 //==================================================================
 236 //= OOutputStreamWrapper
 237 //==================================================================
 238 //------------------------------------------------------------------------------
 239 void SAL_CALL OOutputStreamWrapper::writeBytes(const staruno::Sequence< sal_Int8 >& aData) throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException )
 240 {
 241     sal_uInt32 nWritten = rStream.Write(aData.getConstArray(),aData.getLength());
 242     ErrCode err = rStream.GetError();
 243     if  (       (ERRCODE_NONE != err)
 244         ||      (nWritten != (sal_uInt32)aData.getLength())
 245         )
 246     {
 247         throw stario::BufferSizeExceededException(::rtl::OUString(),static_cast<staruno::XWeak*>(this));
 248     }
 249 }
 250
 251 //------------------------------------------------------------------
 252 void SAL_CALL OOutputStreamWrapper::flush() throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException )
 253 {
 254     rStream.Flush();
 255     checkError();
 256 }
 257
 258 //------------------------------------------------------------------
 259 void SAL_CALL OOutputStreamWrapper::closeOutput() throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException )
 260 {
 261 }
 262
 263 //------------------------------------------------------------------------------
 264 void OOutputStreamWrapper::checkError() const
 265 {
 266     if (rStream.GetError() != ERRCODE_NONE)
 267         // TODO: really evaluate the error
 268         throw stario::NotConnectedException(::rtl::OUString(), const_cast<staruno::XWeak*>(static_cast<const staruno::XWeak*>(this)));
 269 }
 270
 271 //==================================================================
 272 //= OSeekableOutputStreamWrapper
 273 //==================================================================
 274 //------------------------------------------------------------------------------
 275 OSeekableOutputStreamWrapper::OSeekableOutputStreamWrapper(SvStream& _rStream)
 276     :OOutputStreamWrapper(_rStream)
 277 {
 278 }
 279
 280 //------------------------------------------------------------------------------
 281 Any SAL_CALL OSeekableOutputStreamWrapper::queryInterface( const Type& _rType ) throw (RuntimeException)
 282 {
 283     Any aReturn = OOutputStreamWrapper::queryInterface(_rType);
 284     if (!aReturn.hasValue())
 285         aReturn = OSeekableOutputStreamWrapper_Base::queryInterface(_rType);
 286     return aReturn;
 287 }
 288
 289 //------------------------------------------------------------------------------
 290 void SAL_CALL OSeekableOutputStreamWrapper::acquire(  ) throw ()
 291 {
 292     OOutputStreamWrapper::acquire();
 293 }
 294
 295 //------------------------------------------------------------------------------
 296 void SAL_CALL OSeekableOutputStreamWrapper::release(  ) throw ()
 297 {
 298     OOutputStreamWrapper::release();
 299 }
 300
 301 //------------------------------------------------------------------------------
 302 void SAL_CALL OSeekableOutputStreamWrapper::seek( sal_Int64 _nLocation ) throw (IllegalArgumentException, IOException, RuntimeException)
 303 {
 304     rStream.Seek((sal_uInt32)_nLocation);
 305     checkError();
 306 }
 307
 308 //------------------------------------------------------------------------------
 309 sal_Int64 SAL_CALL OSeekableOutputStreamWrapper::getPosition(  ) throw (IOException, RuntimeException)
 310 {
 311     sal_uInt32 nPos = rStream.Tell();
 312     checkError();
 313     return (sal_Int64)nPos;
 314 }
 315
 316 //------------------------------------------------------------------------------
 317 sal_Int64 SAL_CALL OSeekableOutputStreamWrapper::getLength(  ) throw (IOException, RuntimeException)
 318 {
 319     sal_uInt32 nCurrentPos = rStream.Tell();
 320     checkError();
 321
 322     rStream.Seek(STREAM_SEEK_TO_END);
 323     sal_uInt32 nEndPos = rStream.Tell();
 324     rStream.Seek(nCurrentPos);
 325
 326     checkError();
 327
 328     return (sal_Int64)nEndPos;
 329 }
 330
 331 //------------------------------------------------------------------------------
 332 OStreamWrapper::OStreamWrapper(SvStream& _rStream)
 333 {
 334     SetStream( &_rStream, FALSE );
 335 }
 336
 337 //------------------------------------------------------------------------------
 338 ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream > SAL_CALL OStreamWrapper::getInputStream(  ) throw (::com::sun::star::uno::RuntimeException)
 339 {
 340     return this;
 341 }
 342
 343 //------------------------------------------------------------------------------
 344 ::com::sun::star::uno::Reference< ::com::sun::star::io::XOutputStream > SAL_CALL OStreamWrapper::getOutputStream(  ) throw (::com::sun::star::uno::RuntimeException)
 345 {
 346     return this;
 347 }
 348
 349 //------------------------------------------------------------------------------
 350 void SAL_CALL OStreamWrapper::writeBytes(const staruno::Sequence< sal_Int8 >& aData) throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException)
 351 {
 352     sal_uInt32 nWritten = m_pSvStream->Write(aData.getConstArray(),aData.getLength());
 353     ErrCode err = m_pSvStream->GetError();
 354     if  (       (ERRCODE_NONE != err)
 355         ||      (nWritten != (sal_uInt32)aData.getLength())
 356         )
 357     {
 358         throw stario::BufferSizeExceededException(::rtl::OUString(),static_cast<staruno::XWeak*>(this));
 359     }
 360 }
 361
 362 //------------------------------------------------------------------------------
 363 void SAL_CALL OStreamWrapper::flush() throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException)
 364 {
 365     m_pSvStream->Flush();
 366     if (m_pSvStream->GetError() != ERRCODE_NONE)
 367         throw stario::NotConnectedException(::rtl::OUString(),static_cast<staruno::XWeak*>(this));
 368 }
 369
 370 //------------------------------------------------------------------------------
 371 void SAL_CALL OStreamWrapper::closeOutput() throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException)
 372 {
 373 }
 374
 375 //------------------------------------------------------------------------------
 376 void SAL_CALL OStreamWrapper::truncate() throw(::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
 377 {
 378     m_pSvStream->SetStreamSize(0);
 379 }
 380
 381 } // namespace utl
 382