INTEGRATION: CWS impresstables2 (1.1.2); FILE ADDED

2008/03/06 17:09:25 cl 1.1.2.3: #i68103# added missing header for mac build
2008/01/30 16:07:08 cl 1.1.2.2: fixed merge conflict
2008/01/03 10:14:35 cl 1.1.2.1: new memory stream service

1 files changed, 225 insertions, 0 deletions

diff --git a/comphelper/source/streaming/memorystream.cxx b/comphelper/source/streaming/memorystream.cxx
new file mode 100644
index 000000000000..b8de8a01915a
--- /dev/null
+++ b/comphelper/source/streaming/memorystream.cxx
@@ -0,0 +1,225 @@
+/*************************************************************************
+ *
+ *  OpenOffice.org - a multi-platform office productivity suite
+ *
+ *  $RCSfile: memorystream.cxx,v $
+ *
+ *  $Revision: 1.2 $
+ *
+ *  last change: $Author: rt $ $Date: 2008-03-12 13:24:50 $
+ *
+ *  The Contents of this file are made available subject to
+ *  the terms of GNU Lesser General Public License Version 2.1.
+ *
+ *
+ *    GNU Lesser General Public License Version 2.1
+ *    =============================================
+ *    Copyright 2005 by Sun Microsystems, Inc.
+ *    901 San Antonio Road, Palo Alto, CA 94303, USA
+ *
+ *    This library is free software; you can redistribute it and/or
+ *    modify it under the terms of the GNU Lesser General Public
+ *    License version 2.1, as published by the Free Software Foundation.
+ *
+ *    This library is distributed in the hope that it will be useful,
+ *    but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ *    Lesser General Public License for more details.
+ *
+ *    You should have received a copy of the GNU Lesser General Public
+ *    License along with this library; if not, write to the Free Software
+ *    Foundation, Inc., 59 Temple Place, Suite 330, Boston,
+ *    MA  02111-1307  USA
+ *
+ ************************************************************************/
+
+// MARKER(update_precomp.py): autogen include statement, do not remove
+#include "precompiled_comphelper.hxx"
+
+#include <com/sun/star/io/XStream.hpp>
+#include <com/sun/star/io/XSeekableInputStream.hpp>
+#include <com/sun/star/uno/XComponentContext.hpp>
+#include <cppuhelper/implbase3.hxx>
+
+#include <string.h>
+#include <vector>
+
+using ::rtl::OUString;
+using ::cppu::OWeakObject;
+using ::cppu::WeakImplHelper3;
+using namespace ::com::sun::star::io;
+using namespace ::com::sun::star::uno;
+using namespace ::com::sun::star::lang;
+using namespace ::osl;
+
+namespace comphelper
+{
+
+class UNOMemoryStream : public WeakImplHelper3 < XStream, XSeekableInputStream, XOutputStream >
+{
+public:
+    UNOMemoryStream();
+    virtual ~UNOMemoryStream();
+
+    // XStream
+    virtual Reference< XInputStream > SAL_CALL getInputStream(  ) throw (RuntimeException);
+    virtual Reference< XOutputStream > SAL_CALL getOutputStream(  ) throw (RuntimeException);
+
+    // XInputStream
+    virtual sal_Int32 SAL_CALL readBytes( Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException);
+    virtual sal_Int32 SAL_CALL readSomeBytes( Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException);
+    virtual void SAL_CALL skipBytes( sal_Int32 nBytesToSkip ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException);
+    virtual sal_Int32 SAL_CALL available() throw (NotConnectedException, IOException, RuntimeException);
+    virtual void SAL_CALL closeInput() throw (NotConnectedException, IOException, RuntimeException);
+
+    // XSeekable
+    virtual void SAL_CALL seek( sal_Int64 location ) throw (IllegalArgumentException, IOException, RuntimeException);
+    virtual sal_Int64 SAL_CALL getPosition() throw (IOException, RuntimeException);
+    virtual sal_Int64 SAL_CALL getLength() throw (IOException, RuntimeException);
+
+    // XOutputStream
+    virtual void SAL_CALL writeBytes( const Sequence< sal_Int8 >& aData ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException);
+    virtual void SAL_CALL flush() throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException);
+    virtual void SAL_CALL closeOutput() throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException);
+
+private:
+    std::vector< sal_Int8 > maData;
+    sal_Int32 mnCursor;
+};
+
+UNOMemoryStream::UNOMemoryStream()
+: mnCursor(0)
+{
+}
+
+UNOMemoryStream::~UNOMemoryStream()
+{
+}
+
+// XStream
+Reference< XInputStream > SAL_CALL UNOMemoryStream::getInputStream(  ) throw (RuntimeException)
+{
+    return this;
+}
+
+Reference< XOutputStream > SAL_CALL UNOMemoryStream::getOutputStream(  ) throw (RuntimeException)
+{
+    return this;
+}
+
+// XInputStream
+sal_Int32 SAL_CALL UNOMemoryStream::readBytes( Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
+{
+    if( nBytesToRead < 0 )
+        throw IOException();
+
+    nBytesToRead = std::min( nBytesToRead, available() );
+    if( aData.getLength() < nBytesToRead )
+        aData.realloc( nBytesToRead );
+
+    if( nBytesToRead )
+    {
+        sal_Int8* pData = static_cast<sal_Int8*>(&(*maData.begin()));
+        sal_Int8* pCursor = &((pData)[mnCursor]);
+        memcpy( (void*)aData.getArray(), (void*)pCursor, nBytesToRead );
+
+        mnCursor += nBytesToRead;
+    }
+
+    return nBytesToRead;
+}
+
+sal_Int32 SAL_CALL UNOMemoryStream::readSomeBytes( Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
+{
+    return readBytes( aData, nMaxBytesToRead );
+}
+
+void SAL_CALL UNOMemoryStream::skipBytes( sal_Int32 nBytesToSkip ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
+{
+    if( nBytesToSkip < 0 )
+        throw IOException();
+
+    mnCursor += std::min( nBytesToSkip, available() );
+}
+
+sal_Int32 SAL_CALL UNOMemoryStream::available() throw (NotConnectedException, IOException, RuntimeException)
+{
+    return static_cast< sal_Int32 >( maData.size() ) - mnCursor;
+}
+
+void SAL_CALL UNOMemoryStream::closeInput() throw (NotConnectedException, IOException, RuntimeException)
+{
+    mnCursor = 0;
+}
+
+// XSeekable
+void SAL_CALL UNOMemoryStream::seek( sal_Int64 location ) throw (IllegalArgumentException, IOException, RuntimeException)
+{
+    if( (location < 0) || (location > SAL_MAX_INT32) || (location > static_cast< sal_Int64 >( maData.size() )) )
+        throw IllegalArgumentException( OUString(RTL_CONSTASCII_USTRINGPARAM("this implementation does not support more than 2GB!")), Reference< XInterface >(static_cast<OWeakObject*>(this)), 0 );
+
+    mnCursor = static_cast< sal_Int32 >( location );
+}
+
+sal_Int64 SAL_CALL UNOMemoryStream::getPosition() throw (IOException, RuntimeException)
+{
+    return static_cast< sal_Int64 >( mnCursor );
+}
+
+sal_Int64 SAL_CALL UNOMemoryStream::getLength() throw (IOException, RuntimeException)
+{
+    return static_cast< sal_Int64 >( maData.size() );
+}
+
+// XOutputStream
+void SAL_CALL UNOMemoryStream::writeBytes( const Sequence< sal_Int8 >& aData ) throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
+{
+    const sal_Int32 nBytesToWrite( aData.getLength() );
+    if( nBytesToWrite )
+    {
+        sal_Int64 nNewSize = static_cast< sal_Int64 >( mnCursor + nBytesToWrite );
+        if( nNewSize > SAL_MAX_INT32 )
+        {
+            OSL_ASSERT(false);
+            throw IOException( OUString(RTL_CONSTASCII_USTRINGPARAM("this implementation does not support more than 2GB!")), Reference< XInterface >(static_cast<OWeakObject*>(this)) );
+        }
+
+        if( static_cast< sal_Int32 >( nNewSize ) > static_cast< sal_Int32 >( maData.size() ) )
+            maData.resize( static_cast< sal_Int32 >( nNewSize ) );
+
+        sal_Int8* pData = static_cast<sal_Int8*>(&(*maData.begin()));
+        sal_Int8* pCursor = &(pData[mnCursor]);
+        memcpy( (void*)pCursor, (void*)aData.getConstArray(), nBytesToWrite );
+
+        mnCursor += nBytesToWrite;
+    }
+}
+
+void SAL_CALL UNOMemoryStream::flush() throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
+{
+}
+
+void SAL_CALL UNOMemoryStream::closeOutput() throw (NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
+{
+    mnCursor = 0;
+}
+
+OUString SAL_CALL UNOMemoryStream_getImplementationName() throw()
+{
+    static const OUString sImplName( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.MemoryStream" ) );
+    return sImplName;
+}
+
+Sequence< OUString > SAL_CALL UNOMemoryStream_getSupportedServiceNames() throw()
+{
+    Sequence< OUString > aSeq(1);
+    aSeq[0] = UNOMemoryStream_getImplementationName();
+    return aSeq;
+}
+
+Reference< XInterface > SAL_CALL UNOMemoryStream_createInstance(const Reference< XComponentContext > & ) throw( Exception )
+{
+    return static_cast<OWeakObject*>(new UNOMemoryStream());
+}
+
+} // namespace comphelper