1 files changed, 144 insertions, 0 deletions
diff --git a/xmerge/java/org/openoffice/xmerge/xmergebridge/FlatXml/java/streamwrap.hxx b/xmerge/java/org/openoffice/xmerge/xmergebridge/FlatXml/java/streamwrap.hxx
new file mode 100755
index 000000000000..e3d8f3b3ed86
--- /dev/null
+++ b/xmerge/java/org/openoffice/xmerge/xmergebridge/FlatXml/java/streamwrap.hxx
@@ -0,0 +1,144 @@
+/*************************************************************************
+ *
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
+ *
+ * Copyright 2008 by Sun Microsystems, Inc.
+ *
+ * OpenOffice.org - a multi-platform office productivity suite
+ *
+ * $RCSfile: streamwrap.hxx,v $
+ * $Revision: 1.3 $
+ *
+ * This file is part of OpenOffice.org.
+ *
+ * OpenOffice.org is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License version 3
+ * only, as published by the Free Software Foundation.
+ *
+ * OpenOffice.org 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 version 3 for more details
+ * (a copy is included in the LICENSE file that accompanied this code).
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * version 3 along with OpenOffice.org.  If not, see
+ * <http://www.openoffice.org/license.html>
+ * for a copy of the LGPLv3 License.
+ *
+ ************************************************************************/
+#ifndef _OSL_FILE_WRAPPER_HXX_
+#define _OSL_FILE_WRAPPER_HXX_
+
+#include <osl/mutex.hxx>
+#include <com/sun/star/io/XOutputStream.hpp>
+#include <com/sun/star/io/XInputStream.hpp>
+#include <com/sun/star/io/XSeekable.hpp>
+#include <cppuhelper/implbase1.hxx>
+
+#define DECLARE_UNO3_AGG_DEFAULTS(classname, baseclass) \
+virtual void            SAL_CALL acquire() throw() { baseclass::acquire(); } \
+virtual void            SAL_CALL release() throw() { baseclass::release(); }    \
+virtual ::com::sun::star::uno::Any  SAL_CALL queryInterface(const ::com::sun::star::uno::Type& _rType) throw (::com::sun::star::uno::RuntimeException) \
+{ return baseclass::queryInterface(_rType); } \
+void            SAL_CALL PUT_SEMICOLON_AT_THE_END()
+
+namespace osl
+{
+    class File;
+}
+
+namespace foo
+{
+    namespace stario    = ::com::sun::star::io;
+    namespace staruno   = ::com::sun::star::uno;
+
+//==================================================================
+//= OInputFileWrapper
+//==================================================================
+typedef ::cppu::WeakImplHelper1 <   stario::XInputStream
+                                > InputStreamWrapper_Base;
+    // needed for some compilers
+/// helper class for wrapping a File into an <type scope="com.sun.star.io">XInputStream</type>
+class OInputStreamWrapper : public InputStreamWrapper_Base
+{
+protected:
+    ::osl::Mutex    m_aMutex;
+    ::osl::File*        m_pSvStream;
+    sal_Bool        m_bSvStreamOwner : 1;
+
+public:
+    OInputStreamWrapper(::osl::File& _rStream);
+    OInputStreamWrapper(::osl::File* pStream, sal_Bool bOwner=sal_False);
+    virtual ~OInputStreamWrapper();
+
+// UNO Anbindung
+    DECLARE_UNO3_AGG_DEFAULTS(OInputStreamWrapper, InputStreamWrapper_Base);
+
+// stario::XInputStream
+    virtual sal_Int32   SAL_CALL    readBytes(staruno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException);
+    virtual sal_Int32   SAL_CALL    readSomeBytes(staruno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException);
+    virtual void        SAL_CALL    skipBytes(sal_Int32 nBytesToSkip) throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException);
+    virtual sal_Int32   SAL_CALL    available() throw(stario::NotConnectedException, staruno::RuntimeException);
+    virtual void        SAL_CALL    closeInput() throw(stario::NotConnectedException, staruno::RuntimeException);
+
+protected:
+    /// throws a NotConnectedException if the object is not connected anymore
+    void checkConnected() const;
+    /// throws an exception according to the error flag of m_pSvStream
+    void checkError() const;
+};
+
+//==================================================================
+//= OSeekableInputFIleWrapper
+//==================================================================
+typedef ::cppu::ImplHelper1 <   ::com::sun::star::io::XSeekable
+                            >   OSeekableInputStreamWrapper_Base;
+/** helper class for wrapping an File into an <type scope="com.sun.star.io">XInputStream</type>
+    which is seekable (i.e. supports the <type scope="com.sun.star.io">XSeekable</type> interface).
+*/
+class OSeekableInputStreamWrapper
+                :public OInputStreamWrapper
+                ,public OSeekableInputStreamWrapper_Base
+{
+public:
+    OSeekableInputStreamWrapper(::osl::File& _rStream);
+    OSeekableInputStreamWrapper(::osl::File* _pStream, sal_Bool _bOwner = sal_False);
+
+    // disambiguate XInterface
+    virtual ::com::sun::star::uno::Any SAL_CALL queryInterface( const ::com::sun::star::uno::Type& _rType ) throw (::com::sun::star::uno::RuntimeException);
+    virtual void SAL_CALL acquire(  ) throw ();
+    virtual void SAL_CALL release(  ) throw ();
+
+    // XSeekable
+    virtual void SAL_CALL seek( sal_Int64 _nLocation ) throw (::com::sun::star::lang::IllegalArgumentException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException);
+    virtual sal_Int64 SAL_CALL getPosition(  ) throw (::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException);
+    virtual sal_Int64 SAL_CALL getLength(  ) throw (::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException);
+};
+
+//==================================================================
+//= OOutputStreamWrapper
+//==================================================================
+typedef ::cppu::WeakImplHelper1<stario::XOutputStream> OutputStreamWrapper_Base;
+    // needed for some compilers
+class OOutputStreamWrapper : public OutputStreamWrapper_Base
+{
+    ::osl::File&        rStream;
+
+public:
+    OOutputStreamWrapper(::osl::File& _rStream) :rStream(_rStream) { }
+
+// UNO Anbindung
+    DECLARE_UNO3_AGG_DEFAULTS(OOutputStreamWrapper, OutputStreamWrapper_Base);
+
+// stario::XOutputStream
+    virtual void SAL_CALL writeBytes(const staruno::Sequence< sal_Int8 >& aData) throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException);
+    virtual void SAL_CALL flush() throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException);
+    virtual void SAL_CALL closeOutput() throw(stario::NotConnectedException, stario::BufferSizeExceededException, staruno::RuntimeException);
+};
+
+}   // namespace utl
+
+
+#endif // _UTL_STREAM_WRAPPER_HXX_
+