unotools/source/streaming/streamwrap.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include <unotools/streamwrap.hxx>
  21 #include <tools/stream.hxx>
  22 #include <tools/debug.hxx>
  23
  24 namespace utl
  25 {
  26
  27 using namespace ::com::sun::star::uno;
  28 using namespace ::com::sun::star::io;
  29 using namespace ::com::sun::star::lang;
  30
  31 OInputStreamWrapper::OInputStreamWrapper( SvStream& _rStream )
  32                  :m_pSvStream(&_rStream)
  33                  ,m_bSvStreamOwner(false)
  34 {
  35 }
  36
  37 OInputStreamWrapper::OInputStreamWrapper( SvStream* pStream, bool bOwner )
  38                  :m_pSvStream( pStream )
  39                  ,m_bSvStreamOwner( bOwner )
  40 {
  41 }
  42
  43 OInputStreamWrapper::~OInputStreamWrapper()
  44 {
  45     if( m_bSvStreamOwner )
  46         delete m_pSvStream;
  47 }
  48
  49 sal_Int32 SAL_CALL OInputStreamWrapper::readBytes(staruno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead)
  50                 throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException, std::exception )
  51 {
  52     checkConnected();
  53
  54     if (nBytesToRead < 0)
  55         throw stario::BufferSizeExceededException(OUString(),static_cast<staruno::XWeak*>(this));
  56
  57     ::osl::MutexGuard aGuard( m_aMutex );
  58
  59     aData.realloc(nBytesToRead);
  60
  61     sal_uInt32 nRead = m_pSvStream->Read((void*)aData.getArray(), nBytesToRead);
  62     checkError();
  63
  64     // Wenn gelesene Zeichen < MaxLength, staruno::Sequence anpassen
  65     if (nRead < (sal_uInt32)nBytesToRead)
  66         aData.realloc( nRead );
  67
  68     return nRead;
  69 }
  70
  71 sal_Int32 SAL_CALL OInputStreamWrapper::readSomeBytes(staruno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException, std::exception )
  72 {
  73     checkError();
  74
  75     if (nMaxBytesToRead < 0)
  76         throw stario::BufferSizeExceededException(OUString(),static_cast<staruno::XWeak*>(this));
  77
  78     if (m_pSvStream->IsEof())
  79     {
  80         aData.realloc(0);
  81         return 0;
  82     }
  83     else
  84         return readBytes(aData, nMaxBytesToRead);
  85 }
  86
  87 void SAL_CALL OInputStreamWrapper::skipBytes(sal_Int32 nBytesToSkip) throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException, std::exception )
  88 {
  89     ::osl::MutexGuard aGuard( m_aMutex );
  90     checkError();
  91
  92     m_pSvStream->SeekRel(nBytesToSkip);
  93     checkError();
  94 }
  95
  96 sal_Int32 SAL_CALL OInputStreamWrapper::available() throw( stario::NotConnectedException, staruno::RuntimeException, std::exception )
  97 {
  98     ::osl::MutexGuard aGuard( m_aMutex );
  99     checkConnected();
 100
 101     sal_uInt32 nPos = m_pSvStream->Tell();
 102     checkError();
 103
 104     m_pSvStream->Seek(STREAM_SEEK_TO_END);
 105     checkError();
 106
 107     sal_Int32 nAvailable = (sal_Int32)m_pSvStream->Tell() - nPos;
 108     m_pSvStream->Seek(nPos);
 109     checkError();
 110
 111     return nAvailable;
 112 }
 113
 114 void SAL_CALL OInputStreamWrapper::closeInput() throw( stario::NotConnectedException, staruno::RuntimeException, std::exception )
 115 {
 116     ::osl::MutexGuard aGuard( m_aMutex );
 117     checkConnected();
 118
 119     if (m_bSvStreamOwner)
 120         delete m_pSvStream;
 121
 122     m_pSvStream = NULL;
 123 }
 124
 125 void OInputStreamWrapper::checkConnected() const
 126 {
 127     if (!m_pSvStream)
 128         throw stario::NotConnectedException(OUString(), const_cast<staruno::XWeak*>(static_cast<const staruno::XWeak*>(this)));
 129 }
 130
 131 void OInputStreamWrapper::checkError() const
 132 {
 133     checkConnected();
 134
 135     if (m_pSvStream->SvStream::GetError() != ERRCODE_NONE)
 136         // TODO: really evaluate the error
 137         throw stario::NotConnectedException(OUString(), const_cast<staruno::XWeak*>(static_cast<const staruno::XWeak*>(this)));
 138 }
 139
 140 //= OSeekableInputStreamWrapper
 141
 142 OSeekableInputStreamWrapper::OSeekableInputStreamWrapper(SvStream& _rStream)
 143 {
 144     SetStream( &_rStream, false );
 145 }
 146
 147 OSeekableInputStreamWrapper::OSeekableInputStreamWrapper(SvStream* _pStream, bool _bOwner)
 148 {
 149     SetStream( _pStream, _bOwner );
 150 }
 151
 152 void SAL_CALL OSeekableInputStreamWrapper::seek( sal_Int64 _nLocation ) throw (IllegalArgumentException, IOException, RuntimeException, std::exception)
 153 {
 154     ::osl::MutexGuard aGuard( m_aMutex );
 155     checkConnected();
 156
 157     m_pSvStream->Seek((sal_uInt32)_nLocation);
 158     checkError();
 159 }
 160
 161 sal_Int64 SAL_CALL OSeekableInputStreamWrapper::getPosition(  ) throw (IOException, RuntimeException, std::exception)
 162 {
 163     ::osl::MutexGuard aGuard( m_aMutex );
 164     checkConnected();
 165
 166     sal_uInt32 nPos = m_pSvStream->Tell();
 167     checkError();
 168     return (sal_Int64)nPos;
 169 }
 170
 171 sal_Int64 SAL_CALL OSeekableInputStreamWrapper::getLength(  ) throw (IOException, RuntimeException, std::exception)
 172 {
 173     ::osl::MutexGuard aGuard( m_aMutex );
 174     checkConnected();
 175
 176     sal_uInt32 nCurrentPos = m_pSvStream->Tell();
 177     checkError();
 178
 179     m_pSvStream->Seek(STREAM_SEEK_TO_END);
 180     sal_uInt32 nEndPos = m_pSvStream->Tell();
 181     m_pSvStream->Seek(nCurrentPos);
 182
 183     checkError();
 184
 185     return (sal_Int64)nEndPos;
 186 }
 187
 188 //= OOutputStreamWrapper
 189
 190 OOutputStreamWrapper::OOutputStreamWrapper(SvStream& _rStream):
 191     rStream(_rStream)
 192 {}
 193
 194 OOutputStreamWrapper::~OOutputStreamWrapper() {}
 195
 196 void SAL_CALL OOutputStreamWrapper::writeBytes(const staruno::Sequence< sal_Int8 >& aData) throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException, std::exception )
 197 {
 198     sal_uInt32 nWritten = rStream.Write(aData.getConstArray(),aData.getLength());
 199     ErrCode err = rStream.GetError();
 200     if  (   (ERRCODE_NONE != err)
 201         ||  (nWritten != (sal_uInt32)aData.getLength())
 202         )
 203     {
 204         throw stario::BufferSizeExceededException(OUString(),static_cast<staruno::XWeak*>(this));
 205     }
 206 }
 207
 208 void SAL_CALL OOutputStreamWrapper::flush() throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException, std::exception )
 209 {
 210     rStream.Flush();
 211     checkError();
 212 }
 213
 214 void SAL_CALL OOutputStreamWrapper::closeOutput() throw( stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException, std::exception )
 215 {
 216 }
 217
 218 void OOutputStreamWrapper::checkError() const
 219 {
 220     if (rStream.GetError() != ERRCODE_NONE)
 221         // TODO: really evaluate the error
 222         throw stario::NotConnectedException(OUString(), const_cast<staruno::XWeak*>(static_cast<const staruno::XWeak*>(this)));
 223 }
 224
 225 //= OSeekableOutputStreamWrapper
 226
 227 OSeekableOutputStreamWrapper::OSeekableOutputStreamWrapper(SvStream& _rStream)
 228     :OOutputStreamWrapper(_rStream)
 229 {
 230 }
 231
 232 OSeekableOutputStreamWrapper::~OSeekableOutputStreamWrapper() {}
 233
 234 Any SAL_CALL OSeekableOutputStreamWrapper::queryInterface( const Type& _rType ) throw (RuntimeException, std::exception)
 235 {
 236     Any aReturn = OOutputStreamWrapper::queryInterface(_rType);
 237     if (!aReturn.hasValue())
 238         aReturn = OSeekableOutputStreamWrapper_Base::queryInterface(_rType);
 239     return aReturn;
 240 }
 241
 242 void SAL_CALL OSeekableOutputStreamWrapper::acquire(  ) throw ()
 243 {
 244     OOutputStreamWrapper::acquire();
 245 }
 246
 247 void SAL_CALL OSeekableOutputStreamWrapper::release(  ) throw ()
 248 {
 249     OOutputStreamWrapper::release();
 250 }
 251
 252 void SAL_CALL OSeekableOutputStreamWrapper::seek( sal_Int64 _nLocation ) throw (IllegalArgumentException, IOException, RuntimeException, std::exception)
 253 {
 254     rStream.Seek((sal_uInt32)_nLocation);
 255     checkError();
 256 }
 257
 258 sal_Int64 SAL_CALL OSeekableOutputStreamWrapper::getPosition(  ) throw (IOException, RuntimeException, std::exception)
 259 {
 260     sal_uInt32 nPos = rStream.Tell();
 261     checkError();
 262     return (sal_Int64)nPos;
 263 }
 264
 265 sal_Int64 SAL_CALL OSeekableOutputStreamWrapper::getLength(  ) throw (IOException, RuntimeException, std::exception)
 266 {
 267     sal_uInt32 nCurrentPos = rStream.Tell();
 268     checkError();
 269
 270     rStream.Seek(STREAM_SEEK_TO_END);
 271     sal_uInt32 nEndPos = rStream.Tell();
 272     rStream.Seek(nCurrentPos);
 273
 274     checkError();
 275
 276     return (sal_Int64)nEndPos;
 277 }
 278
 279 OStreamWrapper::OStreamWrapper(SvStream& _rStream)
 280 {
 281     SetStream( &_rStream, false );
 282 }
 283
 284 ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream > SAL_CALL OStreamWrapper::getInputStream(  ) throw (::com::sun::star::uno::RuntimeException, std::exception)
 285 {
 286     return this;
 287 }
 288
 289 ::com::sun::star::uno::Reference< ::com::sun::star::io::XOutputStream > SAL_CALL OStreamWrapper::getOutputStream(  ) throw (::com::sun::star::uno::RuntimeException, std::exception)
 290 {
 291     return this;
 292 }
 293
 294 void SAL_CALL OStreamWrapper::writeBytes(const staruno::Sequence< sal_Int8 >& aData) throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException, std::exception)
 295 {
 296     sal_uInt32 nWritten = m_pSvStream->Write(aData.getConstArray(),aData.getLength());
 297     ErrCode err = m_pSvStream->GetError();
 298     if  (   (ERRCODE_NONE != err)
 299         ||  (nWritten != (sal_uInt32)aData.getLength())
 300         )
 301     {
 302         throw stario::BufferSizeExceededException(OUString(),static_cast<staruno::XWeak*>(this));
 303     }
 304 }
 305
 306 void SAL_CALL OStreamWrapper::flush() throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException, std::exception)
 307 {
 308     m_pSvStream->Flush();
 309     if (m_pSvStream->GetError() != ERRCODE_NONE)
 310         throw stario::NotConnectedException(OUString(),static_cast<staruno::XWeak*>(this));
 311 }
 312
 313 void SAL_CALL OStreamWrapper::closeOutput() throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException, std::exception)
 314 {
 315 }
 316
 317 void SAL_CALL OStreamWrapper::truncate() throw(::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException, std::exception)
 318 {
 319     m_pSvStream->SetStreamSize(0);
 320 }
 321
 322 } // namespace utl
 323
 324 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */