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 <sal/config.h>
  21
  22 #include <com/sun/star/io/BufferSizeExceededException.hpp>
  23 #include <com/sun/star/io/NotConnectedException.hpp>
  24 #include <unotools/streamwrap.hxx>
  25 #include <tools/stream.hxx>
  26
  27 namespace utl
  28 {
  29
  30 using namespace ::com::sun::star::uno;
  31 using namespace ::com::sun::star::io;
  32 using namespace ::com::sun::star::lang;
  33
  34 OInputStreamWrapper::OInputStreamWrapper( SvStream& _rStream )
  35                  :m_pSvStream(&_rStream)
  36                  ,m_bSvStreamOwner(false)
  37 {
  38 }
  39
  40 OInputStreamWrapper::OInputStreamWrapper( SvStream* pStream, bool bOwner )
  41                  :m_pSvStream( pStream )
  42                  ,m_bSvStreamOwner( bOwner )
  43 {
  44 }
  45
  46 OInputStreamWrapper::OInputStreamWrapper( std::unique_ptr<SvStream> pStream )
  47                  :m_pSvStream( pStream.release() )
  48                  ,m_bSvStreamOwner( true )
  49 {
  50 }
  51
  52 OInputStreamWrapper::~OInputStreamWrapper()
  53 {
  54     if( m_bSvStreamOwner )
  55         delete m_pSvStream;
  56 }
  57
  58 sal_Int32 SAL_CALL OInputStreamWrapper::readBytes(css::uno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead)
  59 {
  60     checkConnected();
  61
  62     if (nBytesToRead < 0)
  63         throw css::io::BufferSizeExceededException(OUString(),static_cast<css::uno::XWeak*>(this));
  64
  65     ::osl::MutexGuard aGuard( m_aMutex );
  66
  67     if (aData.getLength() < nBytesToRead)
  68         aData.realloc(nBytesToRead);
  69
  70     sal_uInt32 nRead = m_pSvStream->ReadBytes(static_cast<void*>(aData.getArray()), nBytesToRead);
  71     checkError();
  72
  73     // If read characters < MaxLength, adjust css::uno::Sequence
  74     if (nRead < static_cast<std::size_t>(aData.getLength()))
  75         aData.realloc( nRead );
  76
  77     return nRead;
  78 }
  79
  80 sal_Int32 SAL_CALL OInputStreamWrapper::readSomeBytes(css::uno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead)
  81 {
  82     checkError();
  83
  84     if (nMaxBytesToRead < 0)
  85         throw css::io::BufferSizeExceededException(OUString(),static_cast<css::uno::XWeak*>(this));
  86
  87     if (m_pSvStream->eof())
  88     {
  89         aData.realloc(0);
  90         return 0;
  91     }
  92     else
  93         return readBytes(aData, nMaxBytesToRead);
  94 }
  95
  96 void SAL_CALL OInputStreamWrapper::skipBytes(sal_Int32 nBytesToSkip)
  97 {
  98     ::osl::MutexGuard aGuard( m_aMutex );
  99     checkError();
 100
 101     m_pSvStream->SeekRel(nBytesToSkip);
 102     checkError();
 103 }
 104
 105 sal_Int32 SAL_CALL OInputStreamWrapper::available()
 106 {
 107     ::osl::MutexGuard aGuard( m_aMutex );
 108     checkConnected();
 109
 110     sal_Int64 nAvailable = m_pSvStream->remainingSize();
 111     checkError();
 112
 113     return std::min<sal_Int64>(SAL_MAX_INT32, nAvailable);
 114 }
 115
 116 void SAL_CALL OInputStreamWrapper::closeInput()
 117 {
 118     ::osl::MutexGuard aGuard( m_aMutex );
 119     checkConnected();
 120
 121     if (m_bSvStreamOwner)
 122         delete m_pSvStream;
 123
 124     m_pSvStream = nullptr;
 125 }
 126
 127 void OInputStreamWrapper::checkConnected() const
 128 {
 129     if (!m_pSvStream)
 130         throw css::io::NotConnectedException(OUString(), const_cast<css::uno::XWeak*>(static_cast<const css::uno::XWeak*>(this)));
 131 }
 132
 133 void OInputStreamWrapper::checkError() const
 134 {
 135     checkConnected();
 136
 137     if (m_pSvStream->SvStream::GetError() != ERRCODE_NONE)
 138         // TODO: really evaluate the error
 139         throw css::io::NotConnectedException(OUString(), const_cast<css::uno::XWeak*>(static_cast<const css::uno::XWeak*>(this)));
 140 }
 141
 142 //= OSeekableInputStreamWrapper
 143
 144 OSeekableInputStreamWrapper::~OSeekableInputStreamWrapper() = default;
 145
 146 OSeekableInputStreamWrapper::OSeekableInputStreamWrapper(SvStream& _rStream)
 147 {
 148     SetStream( &_rStream, false );
 149 }
 150
 151 OSeekableInputStreamWrapper::OSeekableInputStreamWrapper(SvStream* _pStream, bool _bOwner)
 152 {
 153     SetStream( _pStream, _bOwner );
 154 }
 155
 156 void SAL_CALL OSeekableInputStreamWrapper::seek( sal_Int64 _nLocation )
 157 {
 158     ::osl::MutexGuard aGuard( m_aMutex );
 159     checkConnected();
 160
 161     m_pSvStream->Seek(static_cast<sal_uInt32>(_nLocation));
 162     checkError();
 163 }
 164
 165 sal_Int64 SAL_CALL OSeekableInputStreamWrapper::getPosition(  )
 166 {
 167     ::osl::MutexGuard aGuard( m_aMutex );
 168     checkConnected();
 169
 170     sal_uInt32 nPos = m_pSvStream->Tell();
 171     checkError();
 172     return static_cast<sal_Int64>(nPos);
 173 }
 174
 175 sal_Int64 SAL_CALL OSeekableInputStreamWrapper::getLength(  )
 176 {
 177     ::osl::MutexGuard aGuard( m_aMutex );
 178     checkConnected();
 179
 180     checkError();
 181
 182     sal_Int64 nEndPos = m_pSvStream->TellEnd();
 183
 184     return nEndPos;
 185 }
 186
 187 //= OOutputStreamWrapper
 188
 189 OOutputStreamWrapper::OOutputStreamWrapper(SvStream& _rStream):
 190     rStream(_rStream)
 191 {}
 192
 193 OOutputStreamWrapper::~OOutputStreamWrapper() {}
 194
 195 void SAL_CALL OOutputStreamWrapper::writeBytes(const css::uno::Sequence< sal_Int8 >& aData)
 196 {
 197     sal_uInt32 nWritten = rStream.WriteBytes(aData.getConstArray(), aData.getLength());
 198     ErrCode err = rStream.GetError();
 199     if  (   (ERRCODE_NONE != err)
 200         ||  (nWritten != static_cast<sal_uInt32>(aData.getLength()))
 201         )
 202     {
 203         throw css::io::BufferSizeExceededException(OUString(),static_cast<css::uno::XWeak*>(this));
 204     }
 205 }
 206
 207 void SAL_CALL OOutputStreamWrapper::flush()
 208 {
 209     rStream.Flush();
 210     checkError();
 211 }
 212
 213 void SAL_CALL OOutputStreamWrapper::closeOutput()
 214 {
 215 }
 216
 217 void OOutputStreamWrapper::checkError() const
 218 {
 219     if (rStream.GetError() != ERRCODE_NONE)
 220         // TODO: really evaluate the error
 221         throw css::io::NotConnectedException(OUString(), const_cast<css::uno::XWeak*>(static_cast<const css::uno::XWeak*>(this)));
 222 }
 223
 224 //= OSeekableOutputStreamWrapper
 225
 226 OSeekableOutputStreamWrapper::OSeekableOutputStreamWrapper(SvStream& _rStream)
 227     :OOutputStreamWrapper(_rStream)
 228 {
 229 }
 230
 231 OSeekableOutputStreamWrapper::~OSeekableOutputStreamWrapper() {}
 232
 233 Any SAL_CALL OSeekableOutputStreamWrapper::queryInterface( const Type& _rType )
 234 {
 235     Any aReturn = OOutputStreamWrapper::queryInterface(_rType);
 236     if (!aReturn.hasValue())
 237         aReturn = OSeekableOutputStreamWrapper_Base::queryInterface(_rType);
 238     return aReturn;
 239 }
 240
 241 void SAL_CALL OSeekableOutputStreamWrapper::acquire(  ) throw ()
 242 {
 243     OOutputStreamWrapper::acquire();
 244 }
 245
 246 void SAL_CALL OSeekableOutputStreamWrapper::release(  ) throw ()
 247 {
 248     OOutputStreamWrapper::release();
 249 }
 250
 251 void SAL_CALL OSeekableOutputStreamWrapper::seek( sal_Int64 _nLocation )
 252 {
 253     rStream.Seek(static_cast<sal_uInt32>(_nLocation));
 254     checkError();
 255 }
 256
 257 sal_Int64 SAL_CALL OSeekableOutputStreamWrapper::getPosition(  )
 258 {
 259     sal_uInt32 nPos = rStream.Tell();
 260     checkError();
 261     return static_cast<sal_Int64>(nPos);
 262 }
 263
 264 sal_Int64 SAL_CALL OSeekableOutputStreamWrapper::getLength(  )
 265 {
 266     checkError();
 267
 268     sal_Int64 nEndPos = rStream.TellEnd();
 269
 270     return nEndPos;
 271 }
 272
 273 OStreamWrapper::~OStreamWrapper() = default;
 274
 275 OStreamWrapper::OStreamWrapper(SvStream& _rStream)
 276 {
 277     SetStream( &_rStream, false );
 278 }
 279
 280 OStreamWrapper::OStreamWrapper(std::unique_ptr<SvStream> pStream)
 281 {
 282     SetStream( pStream.release(), true );
 283 }
 284
 285 css::uno::Reference< css::io::XInputStream > SAL_CALL OStreamWrapper::getInputStream(  )
 286 {
 287     return this;
 288 }
 289
 290 css::uno::Reference< css::io::XOutputStream > SAL_CALL OStreamWrapper::getOutputStream(  )
 291 {
 292     return this;
 293 }
 294
 295 void SAL_CALL OStreamWrapper::writeBytes(const css::uno::Sequence< sal_Int8 >& aData)
 296 {
 297     sal_uInt32 nWritten = m_pSvStream->WriteBytes(aData.getConstArray(), aData.getLength());
 298     ErrCode err = m_pSvStream->GetError();
 299     if  (   (ERRCODE_NONE != err)
 300         ||  (nWritten != static_cast<sal_uInt32>(aData.getLength()))
 301         )
 302     {
 303         throw css::io::BufferSizeExceededException(OUString(),static_cast<css::uno::XWeak*>(this));
 304     }
 305 }
 306
 307 void SAL_CALL OStreamWrapper::flush()
 308 {
 309     m_pSvStream->Flush();
 310     if (m_pSvStream->GetError() != ERRCODE_NONE)
 311         throw css::io::NotConnectedException(OUString(),static_cast<css::uno::XWeak*>(this));
 312 }
 313
 314 void SAL_CALL OStreamWrapper::closeOutput()
 315 {
 316 }
 317
 318 void SAL_CALL OStreamWrapper::truncate()
 319 {
 320     m_pSvStream->SetStreamSize(0);
 321 }
 322
 323 } // namespace utl
 324
 325 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */