comphelper/source/streaming/memorystream.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 <algorithm>
  21
  22 #include "comphelper_module.hxx"
  23 #include "comphelper_services.hxx"
  24
  25 #include <com/sun/star/io/XStream.hpp>
  26 #include <com/sun/star/io/XSeekableInputStream.hpp>
  27 #include <com/sun/star/io/XTruncate.hpp>
  28 #include <com/sun/star/uno/XComponentContext.hpp>
  29 #include <cppuhelper/implbase4.hxx>
  30 #include <osl/diagnose.h>
  31
  32 #include <string.h>
  33 #include <vector>
  34
  35 using ::cppu::OWeakObject;
  36 using ::cppu::WeakImplHelper4;
  37 using namespace ::com::sun::star::io;
  38 using namespace ::com::sun::star::uno;
  39 using namespace ::com::sun::star::lang;
  40 using namespace ::osl;
  41
  42 namespace comphelper
  43 {
  44
  45 class UNOMemoryStream : public WeakImplHelper4 < XStream, XSeekableInputStream, XOutputStream, XTruncate >
  46 {
  47 public:
  48     UNOMemoryStream();
  49     virtual ~UNOMemoryStream();
  50
  51     // XStream
  52     virtual Reference< XInputStream > SAL_CALL getInputStream(  ) throw (RuntimeException, std::exception) SAL_OVERRIDE;
  53     virtual Reference< XOutputStream > SAL_CALL getOutputStream(  ) throw (RuntimeException, std::exception) SAL_OVERRIDE;
  54
  55     // XInputStream
  56     virtual sal_Int32 SAL_CALL readBytes( Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  57     virtual sal_Int32 SAL_CALL readSomeBytes( Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  58     virtual void SAL_CALL skipBytes( sal_Int32 nBytesToSkip ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  59     virtual sal_Int32 SAL_CALL available() throw (NotConnectedException, IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  60     virtual void SAL_CALL closeInput() throw (NotConnectedException, IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  61
  62     // XSeekable
  63     virtual void SAL_CALL seek( sal_Int64 location ) throw (IllegalArgumentException, IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  64     virtual sal_Int64 SAL_CALL getPosition() throw (IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  65     virtual sal_Int64 SAL_CALL getLength() throw (IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  66
  67     // XOutputStream
  68     virtual void SAL_CALL writeBytes( const Sequence< sal_Int8 >& aData ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  69     virtual void SAL_CALL flush() throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  70     virtual void SAL_CALL closeOutput() throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception) SAL_OVERRIDE;
  71
  72     // XTruncate
  73     virtual void SAL_CALL truncate() throw (::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
  74
  75     // XServiceInfo - static versions (used for component registration)
  76     static OUString SAL_CALL getImplementationName_static();
  77     static Sequence< OUString > SAL_CALL getSupportedServiceNames_static();
  78     static Reference< XInterface > SAL_CALL Create( const Reference< ::com::sun::star::uno::XComponentContext >& );
  79
  80 private:
  81     std::vector< sal_Int8 > maData;
  82     sal_Int32 mnCursor;
  83 };
  84
  85 UNOMemoryStream::UNOMemoryStream()
  86 : mnCursor(0)
  87 {
  88 }
  89
  90 UNOMemoryStream::~UNOMemoryStream()
  91 {
  92 }
  93
  94 // XStream
  95 Reference< XInputStream > SAL_CALL UNOMemoryStream::getInputStream(  ) throw (RuntimeException, std::exception)
  96 {
  97     return this;
  98 }
  99
 100 Reference< XOutputStream > SAL_CALL UNOMemoryStream::getOutputStream(  ) throw (RuntimeException, std::exception)
 101 {
 102     return this;
 103 }
 104
 105 // XInputStream
 106 sal_Int32 SAL_CALL UNOMemoryStream::readBytes( Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception)
 107 {
 108     if( nBytesToRead < 0 )
 109         throw IOException();
 110
 111     nBytesToRead = std::min( nBytesToRead, available() );
 112     aData.realloc( nBytesToRead );
 113
 114     if( nBytesToRead )
 115     {
 116         sal_Int8* pData = static_cast<sal_Int8*>(&(*maData.begin()));
 117         sal_Int8* pCursor = &((pData)[mnCursor]);
 118         memcpy( (void*)aData.getArray(), (void*)pCursor, nBytesToRead );
 119
 120         mnCursor += nBytesToRead;
 121     }
 122
 123     return nBytesToRead;
 124 }
 125
 126 sal_Int32 SAL_CALL UNOMemoryStream::readSomeBytes( Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception)
 127 {
 128     return readBytes( aData, nMaxBytesToRead );
 129 }
 130
 131 void SAL_CALL UNOMemoryStream::skipBytes( sal_Int32 nBytesToSkip ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception)
 132 {
 133     if( nBytesToSkip < 0 )
 134         throw IOException();
 135
 136     mnCursor += std::min( nBytesToSkip, available() );
 137 }
 138
 139 sal_Int32 SAL_CALL UNOMemoryStream::available() throw (NotConnectedException, IOException, RuntimeException, std::exception)
 140 {
 141     return static_cast< sal_Int32 >( maData.size() ) - mnCursor;
 142 }
 143
 144 void SAL_CALL UNOMemoryStream::closeInput() throw (NotConnectedException, IOException, RuntimeException, std::exception)
 145 {
 146     mnCursor = 0;
 147 }
 148
 149 // XSeekable
 150 void SAL_CALL UNOMemoryStream::seek( sal_Int64 location ) throw (IllegalArgumentException, IOException, RuntimeException, std::exception)
 151 {
 152     if( (location < 0) || (location > SAL_MAX_INT32) )
 153         throw IllegalArgumentException("this implementation does not support more than 2GB!", static_cast<OWeakObject*>(this), 0 );
 154
 155     // seek operation should be able to resize the stream
 156     if ( location > static_cast< sal_Int64 >( maData.size() ) )
 157         maData.resize( static_cast< sal_Int32 >( location ) );
 158
 159     if ( location > static_cast< sal_Int64 >( maData.size() ) )
 160         maData.resize( static_cast< sal_Int32 >( location ) );
 161
 162     mnCursor = static_cast< sal_Int32 >( location );
 163 }
 164
 165 sal_Int64 SAL_CALL UNOMemoryStream::getPosition() throw (IOException, RuntimeException, std::exception)
 166 {
 167     return static_cast< sal_Int64 >( mnCursor );
 168 }
 169
 170 sal_Int64 SAL_CALL UNOMemoryStream::getLength() throw (IOException, RuntimeException, std::exception)
 171 {
 172     return static_cast< sal_Int64 >( maData.size() );
 173 }
 174
 175 // XOutputStream
 176 void SAL_CALL UNOMemoryStream::writeBytes( const Sequence< sal_Int8 >& aData ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception)
 177 {
 178     const sal_Int32 nBytesToWrite( aData.getLength() );
 179     if( nBytesToWrite )
 180     {
 181         sal_Int64 nNewSize = static_cast< sal_Int64 >( mnCursor + nBytesToWrite );
 182         if( nNewSize > SAL_MAX_INT32 )
 183         {
 184             OSL_ASSERT(false);
 185             throw IOException("this implementation does not support more than 2GB!", static_cast<OWeakObject*>(this) );
 186         }
 187
 188         if( static_cast< sal_Int32 >( nNewSize ) > static_cast< sal_Int32 >( maData.size() ) )
 189             maData.resize( static_cast< sal_Int32 >( nNewSize ) );
 190
 191         sal_Int8* pData = static_cast<sal_Int8*>(&(*maData.begin()));
 192         sal_Int8* pCursor = &(pData[mnCursor]);
 193         memcpy( (void*)pCursor, (void*)aData.getConstArray(), nBytesToWrite );
 194
 195         mnCursor += nBytesToWrite;
 196     }
 197 }
 198
 199 void SAL_CALL UNOMemoryStream::flush() throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception)
 200 {
 201 }
 202
 203 void SAL_CALL UNOMemoryStream::closeOutput() throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException, std::exception)
 204 {
 205     mnCursor = 0;
 206 }
 207
 208 //XTruncate
 209 void SAL_CALL UNOMemoryStream::truncate() throw (IOException, RuntimeException, std::exception)
 210 {
 211     maData.resize( 0 );
 212     mnCursor = 0;
 213 }
 214
 215 OUString SAL_CALL UNOMemoryStream::getImplementationName_static()
 216 {
 217     return OUString("com.sun.star.comp.MemoryStream");
 218 }
 219
 220 Sequence< OUString > SAL_CALL UNOMemoryStream::getSupportedServiceNames_static()
 221 {
 222     Sequence< OUString > aSeq(1);
 223     aSeq[0] = getImplementationName_static();
 224     return aSeq;
 225 }
 226
 227 Reference< XInterface > SAL_CALL UNOMemoryStream::Create(
 228     SAL_UNUSED_PARAMETER const Reference< XComponentContext >& )
 229 {
 230     return static_cast<OWeakObject*>(new UNOMemoryStream());
 231 }
 232
 233 } // namespace comphelper
 234
 235 void createRegistryInfo_UNOMemoryStream()
 236 {
 237     static ::comphelper::module::OAutoRegistration< ::comphelper::UNOMemoryStream > aAutoRegistration;
 238 }
 239
 240 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */