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