diff options
Diffstat (limited to 'io/source/stm')
-rw-r--r-- | io/source/stm/factreg.cxx | 128 | ||||
-rw-r--r-- | io/source/stm/factreg.hxx | 69 | ||||
-rw-r--r-- | io/source/stm/makefile.mk | 77 | ||||
-rw-r--r-- | io/source/stm/odata.cxx | 1667 | ||||
-rw-r--r-- | io/source/stm/omark.cxx | 1018 | ||||
-rw-r--r-- | io/source/stm/opipe.cxx | 494 | ||||
-rw-r--r-- | io/source/stm/opump.cxx | 506 | ||||
-rw-r--r-- | io/source/stm/stm.xml | 278 | ||||
-rw-r--r-- | io/source/stm/streamhelper.cxx | 247 | ||||
-rw-r--r-- | io/source/stm/streamhelper.hxx | 165 |
10 files changed, 4649 insertions, 0 deletions
diff --git a/io/source/stm/factreg.cxx b/io/source/stm/factreg.cxx new file mode 100644 index 000000000000..9b9a8a68384b --- /dev/null +++ b/io/source/stm/factreg.cxx @@ -0,0 +1,128 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * 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. + * + ************************************************************************/ + +// MARKER(update_precomp.py): autogen include statement, do not remove +#include "precompiled_io.hxx" + +#include <osl/diagnose.h> +#include <cppuhelper/factory.hxx> +#include <cppuhelper/implementationentry.hxx> + +#include <com/sun/star/registry/XRegistryKey.hpp> + +using namespace ::rtl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::registry; + +#include "factreg.hxx" + +namespace io_stm +{ + rtl_StandardModuleCount g_moduleCount = MODULE_COUNT_INIT; +} + +using namespace io_stm; + +static struct ImplementationEntry g_entries[] = +{ + { + OPipeImpl_CreateInstance, OPipeImpl_getImplementationName , + OPipeImpl_getSupportedServiceNames, createSingleComponentFactory , + &g_moduleCount.modCnt , 0 + }, + { + OPumpImpl_CreateInstance, OPumpImpl_getImplementationName , + OPumpImpl_getSupportedServiceNames, createSingleComponentFactory , + &g_moduleCount.modCnt , 0 + }, + { + ODataInputStream_CreateInstance, ODataInputStream_getImplementationName, + ODataInputStream_getSupportedServiceNames, createSingleComponentFactory, + &g_moduleCount.modCnt, 0 + }, + { + ODataOutputStream_CreateInstance, ODataOutputStream_getImplementationName, + ODataOutputStream_getSupportedServiceNames, createSingleComponentFactory, + &g_moduleCount.modCnt, 0 + }, + { + OObjectInputStream_CreateInstance, OObjectInputStream_getImplementationName, + OObjectInputStream_getSupportedServiceNames, createSingleComponentFactory, + &g_moduleCount.modCnt, 0 + }, + { + OObjectOutputStream_CreateInstance, OObjectOutputStream_getImplementationName, + OObjectOutputStream_getSupportedServiceNames, createSingleComponentFactory, + &g_moduleCount.modCnt, 0 + }, + { + OMarkableInputStream_CreateInstance, OMarkableInputStream_getImplementationName, + OMarkableInputStream_getSupportedServiceNames, createSingleComponentFactory, + &g_moduleCount.modCnt, 0 + }, + { + OMarkableOutputStream_CreateInstance, OMarkableOutputStream_getImplementationName, + OMarkableOutputStream_getSupportedServiceNames, createSingleComponentFactory, + &g_moduleCount.modCnt, 0 + }, + { 0, 0, 0, 0, 0, 0 } + +}; + +extern "C" +{ + +sal_Bool SAL_CALL component_canUnload( TimeValue *pTime ) +{ + return g_moduleCount.canUnload( &g_moduleCount , pTime ); +} + +//================================================================================================== +void SAL_CALL component_getImplementationEnvironment( + const sal_Char ** ppEnvTypeName, uno_Environment ** ) +{ + *ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME; +} +//================================================================================================== +sal_Bool SAL_CALL component_writeInfo( + void * pServiceManager, void * pRegistryKey ) +{ + return component_writeInfoHelper( pServiceManager, pRegistryKey, g_entries ); +} +//================================================================================================== +void * SAL_CALL component_getFactory( + const sal_Char * pImplName, void * pServiceManager, void * pRegistryKey ) +{ + return component_getFactoryHelper( pImplName, pServiceManager, pRegistryKey , g_entries ); +} + +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/source/stm/factreg.hxx b/io/source/stm/factreg.hxx new file mode 100644 index 000000000000..56c097671c89 --- /dev/null +++ b/io/source/stm/factreg.hxx @@ -0,0 +1,69 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * 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. + * + ************************************************************************/ +#include <rtl/unload.h> + +namespace io_stm { + +extern rtl_StandardModuleCount g_moduleCount; + +// OPipeImpl +Reference< XInterface > SAL_CALL OPipeImpl_CreateInstance( const Reference< XComponentContext > & rSMgr ) throw (Exception); +OUString OPipeImpl_getImplementationName(); +Sequence<OUString> OPipeImpl_getSupportedServiceNames(void); + +Reference< XInterface > SAL_CALL ODataInputStream_CreateInstance( const Reference< XComponentContext > & rSMgr ) throw (Exception); +OUString ODataInputStream_getImplementationName(); +Sequence<OUString> ODataInputStream_getSupportedServiceNames(void); + +Reference< XInterface > SAL_CALL ODataOutputStream_CreateInstance( const Reference< XComponentContext > & rSMgr ) throw (Exception); +OUString ODataOutputStream_getImplementationName(); +Sequence<OUString> ODataOutputStream_getSupportedServiceNames(void); + +Reference< XInterface > SAL_CALL OMarkableOutputStream_CreateInstance( const Reference< XComponentContext > & rSMgr ) throw (Exception); +OUString OMarkableOutputStream_getImplementationName(); +Sequence<OUString> OMarkableOutputStream_getSupportedServiceNames(void); + +Reference< XInterface > SAL_CALL OMarkableInputStream_CreateInstance( const Reference< XComponentContext > & rSMgr ) throw (Exception); +OUString OMarkableInputStream_getImplementationName() ; +Sequence<OUString> OMarkableInputStream_getSupportedServiceNames(void); + +Reference< XInterface > SAL_CALL OObjectOutputStream_CreateInstance( const Reference< XComponentContext > & rSMgr ) throw(Exception); +OUString OObjectOutputStream_getImplementationName(); +Sequence<OUString> OObjectOutputStream_getSupportedServiceNames(void); + +Reference< XInterface > SAL_CALL OObjectInputStream_CreateInstance( const Reference< XComponentContext > & rSMgr ) throw(Exception); +OUString OObjectInputStream_getImplementationName() ; +Sequence<OUString> OObjectInputStream_getSupportedServiceNames(void); + +Reference< XInterface > SAL_CALL OPumpImpl_CreateInstance( const Reference< XComponentContext > & rSMgr ) throw (Exception); +OUString OPumpImpl_getImplementationName(); +Sequence<OUString> OPumpImpl_getSupportedServiceNames(void); + +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/source/stm/makefile.mk b/io/source/stm/makefile.mk new file mode 100644 index 000000000000..a6a163eca4e2 --- /dev/null +++ b/io/source/stm/makefile.mk @@ -0,0 +1,77 @@ +#************************************************************************* +# +# DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. +# +# Copyright 2000, 2010 Oracle and/or its affiliates. +# +# OpenOffice.org - a multi-platform office productivity suite +# +# 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. +# +#************************************************************************* +PRJ=..$/.. + +PRJNAME=io +TARGET = streams.uno + +ENABLE_EXCEPTIONS=TRUE +NO_BSYMBOLIC=TRUE +COMP1TYPELIST = stm +COMPRDB=$(SOLARBINDIR)$/udkapi.rdb + +# --- Settings ----------------------------------------------------- +.INCLUDE : settings.mk +.IF "$(L10N_framework)"=="" +DLLPRE = +# --- Files -------------------------------------------------------- +UNOUCRDEP=$(SOLARBINDIR)$/udkapi.rdb +UNOUCRRDB=$(SOLARBINDIR)$/udkapi.rdb +UNOUCROUT=$(OUT)$/inc$/stm +INCPRE+= $(UNOUCROUT) + + +SLOFILES = $(SLO)$/opipe.obj\ + $(SLO)$/factreg.obj\ + $(SLO)$/omark.obj\ + $(SLO)$/odata.obj \ + $(SLO)$/streamhelper.obj \ + $(SLO)$/opump.obj + +SHL1TARGET= $(TARGET) +SHL1VERSIONMAP = $(SOLARENV)/src/unloadablecomponent.map + +SHL1STDLIBS= \ + $(SALLIB) \ + $(CPPULIB) \ + $(CPPUHELPERLIB) + + +SHL1DEPN= +SHL1IMPLIB= i$(TARGET) +SHL1LIBS= $(SLB)$/$(TARGET).lib +SHL1DEF= $(MISC)$/$(SHL1TARGET).def +SHL1RPATH= URELIB + +DEF1NAME= $(SHL1TARGET) + + +# --- Targets ------------------------------------------------------ +.ENDIF # L10N_framework + +.INCLUDE : target.mk + diff --git a/io/source/stm/odata.cxx b/io/source/stm/odata.cxx new file mode 100644 index 000000000000..b5be8e855ba9 --- /dev/null +++ b/io/source/stm/odata.cxx @@ -0,0 +1,1667 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * 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. + * + ************************************************************************/ + +// MARKER(update_precomp.py): autogen include statement, do not remove +#include "precompiled_io.hxx" + + +// streams +#include <hash_map> +#include <vector> + +#include <com/sun/star/io/XObjectInputStream.hpp> +#include <com/sun/star/io/XObjectOutputStream.hpp> +#include <com/sun/star/io/XActiveDataSource.hpp> +#include <com/sun/star/io/XActiveDataSink.hpp> +#include <com/sun/star/io/XMarkableStream.hpp> +#include <com/sun/star/io/XConnectable.hpp> +#include <com/sun/star/io/UnexpectedEOFException.hpp> +#include <com/sun/star/io/WrongFormatException.hpp> +#include <com/sun/star/lang/XServiceInfo.hpp> + +#include <cppuhelper/weak.hxx> // OWeakObject +#include <cppuhelper/factory.hxx> +#include <cppuhelper/implbase4.hxx> +#include <cppuhelper/typeprovider.hxx> +#include <cppuhelper/queryinterface.hxx> + +#include <osl/mutex.hxx> + +#include <string.h> + + +using namespace ::cppu; +using namespace ::osl; +using namespace ::std; +using namespace ::rtl; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::lang; + +#include "factreg.hxx" + +namespace io_stm { + +class ODataInputStream : + public WeakImplHelper4 < + XDataInputStream, + XActiveDataSink, + XConnectable, + XServiceInfo + > +{ +public: + ODataInputStream( ) + : m_bValidStream( sal_False ) + { + g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); + } + + ~ODataInputStream(); +public: // XInputStream + virtual sal_Int32 SAL_CALL readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + virtual sal_Int32 SAL_CALL readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + virtual void SAL_CALL skipBytes(sal_Int32 nBytesToSkip) throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + virtual sal_Int32 SAL_CALL available(void) throw ( NotConnectedException, + RuntimeException); + virtual void SAL_CALL closeInput(void) throw ( NotConnectedException, + RuntimeException); + +public: // XDataInputStream + virtual sal_Int8 SAL_CALL readBoolean(void) throw (IOException, RuntimeException); + virtual sal_Int8 SAL_CALL readByte(void) throw (IOException, RuntimeException); + virtual sal_Unicode SAL_CALL readChar(void) throw (IOException, RuntimeException); + virtual sal_Int16 SAL_CALL readShort(void) throw (IOException, RuntimeException); + virtual sal_Int32 SAL_CALL readLong(void) throw (IOException, RuntimeException); + virtual sal_Int64 SAL_CALL readHyper(void) throw (IOException, RuntimeException); + virtual float SAL_CALL readFloat(void) throw (IOException, RuntimeException); + virtual double SAL_CALL readDouble(void) throw (IOException, RuntimeException); + virtual OUString SAL_CALL readUTF(void) throw (IOException, RuntimeException); + + + +public: // XActiveDataSink + virtual void SAL_CALL setInputStream(const Reference< XInputStream > & aStream) + throw (RuntimeException); + virtual Reference< XInputStream > SAL_CALL getInputStream(void) throw (RuntimeException); + +public: // XConnectable + virtual void SAL_CALL setPredecessor(const Reference < XConnectable >& aPredecessor) throw (RuntimeException); + virtual Reference < XConnectable > SAL_CALL getPredecessor(void) throw (RuntimeException); + virtual void SAL_CALL setSuccessor(const Reference < XConnectable >& aSuccessor) throw (RuntimeException); + virtual Reference < XConnectable > SAL_CALL getSuccessor(void) throw (RuntimeException) ; + + +public: // XServiceInfo + OUString SAL_CALL getImplementationName() throw (); + Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw (); + sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw (); + +protected: + + Reference < XConnectable > m_pred; + Reference < XConnectable > m_succ; + Reference < XInputStream > m_input; + sal_Bool m_bValidStream; +}; + +ODataInputStream::~ODataInputStream() +{ + g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); +} + +// XInputStream +sal_Int32 ODataInputStream::readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + sal_Int32 nRead; + + if( m_bValidStream ) + { + nRead = m_input->readBytes( aData , nBytesToRead ); + } + else + { + throw NotConnectedException( ); + } + + return nRead; +} + +sal_Int32 ODataInputStream::readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + sal_Int32 nRead; + if( m_bValidStream ) { + nRead = m_input->readSomeBytes( aData , nMaxBytesToRead ); + } + else { + throw NotConnectedException( ); + } + + return nRead; +} +void ODataInputStream::skipBytes(sal_Int32 nBytesToSkip) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + if( m_bValidStream ) { + m_input->skipBytes( nBytesToSkip ); + } + else + { + throw NotConnectedException( ); + } +} + + +sal_Int32 ODataInputStream::available(void) + throw ( NotConnectedException, + RuntimeException) +{ + sal_Int32 nAvail; + + if( m_bValidStream ) + { + nAvail = m_input->available( ); + } + else + { + throw NotConnectedException( ); + } + return nAvail; +} + +void ODataInputStream::closeInput(void ) + throw ( NotConnectedException, + RuntimeException) +{ + if( m_bValidStream ) { + m_input->closeInput( ); + setInputStream( Reference< XInputStream > () ); + setPredecessor( Reference < XConnectable >() ); + setSuccessor( Reference < XConnectable >() ); + m_bValidStream = sal_False; + } + else + { + throw NotConnectedException( ); + } +} + + + + +//== XDataInputStream =========================================== + +// XDataInputStream +sal_Int8 ODataInputStream::readBoolean(void) throw (IOException, RuntimeException) +{ + return readByte(); +} + +sal_Int8 ODataInputStream::readByte(void) throw (IOException, RuntimeException) +{ + Sequence<sal_Int8> aTmp(1); + if( 1 != readBytes( aTmp, 1 ) ) + { + throw UnexpectedEOFException(); + } + return aTmp.getArray()[0]; +} + +sal_Unicode ODataInputStream::readChar(void) throw (IOException, RuntimeException) +{ + Sequence<sal_Int8> aTmp(2); + if( 2 != readBytes( aTmp, 2 ) ) + { + throw UnexpectedEOFException(); + } + + const sal_uInt8 * pBytes = ( const sal_uInt8 * )aTmp.getConstArray(); + return ((sal_Unicode)pBytes[0] << 8) + pBytes[1]; +} + +sal_Int16 ODataInputStream::readShort(void) throw (IOException, RuntimeException) +{ + Sequence<sal_Int8> aTmp(2); + if( 2 != readBytes( aTmp, 2 ) ) + { + throw UnexpectedEOFException(); + } + + const sal_uInt8 * pBytes = ( const sal_uInt8 * ) aTmp.getConstArray(); + return ((sal_Int16)pBytes[0] << 8) + pBytes[1]; +} + + +sal_Int32 ODataInputStream::readLong(void) throw (IOException, RuntimeException) +{ + Sequence<sal_Int8> aTmp(4); + if( 4 != readBytes( aTmp, 4 ) ) + { + throw UnexpectedEOFException( ); + } + + const sal_uInt8 * pBytes = ( const sal_uInt8 * ) aTmp.getConstArray(); + return ((sal_Int32)pBytes[0] << 24) + ((sal_Int32)pBytes[1] << 16) + ((sal_Int32)pBytes[2] << 8) + pBytes[3]; +} + + +sal_Int64 ODataInputStream::readHyper(void) throw (IOException, RuntimeException) +{ + Sequence<sal_Int8> aTmp(8); + if( 8 != readBytes( aTmp, 8 ) ) + { + throw UnexpectedEOFException( ); + } + + const sal_uInt8 * pBytes = ( const sal_uInt8 * ) aTmp.getConstArray(); + return + (((sal_Int64)pBytes[0]) << 56) + + (((sal_Int64)pBytes[1]) << 48) + + (((sal_Int64)pBytes[2]) << 40) + + (((sal_Int64)pBytes[3]) << 32) + + (((sal_Int64)pBytes[4]) << 24) + + (((sal_Int64)pBytes[5]) << 16) + + (((sal_Int64)pBytes[6]) << 8) + + pBytes[7]; +} + +float ODataInputStream::readFloat(void) throw (IOException, RuntimeException) +{ + union { float f; sal_uInt32 n; } a; + a.n = readLong(); + return a.f; +} + +double ODataInputStream::readDouble(void) throw (IOException, RuntimeException) +{ + sal_uInt32 n = 1; + union { double d; struct { sal_uInt32 n1; sal_uInt32 n2; } ad; } a; + if( *(sal_uInt8 *)&n == 1 ) + { + // little endian + a.ad.n2 = readLong(); + a.ad.n1 = readLong(); + } + else + { + // big endian + a.ad.n1 = readLong(); + a.ad.n2 = readLong(); + } + return a.d; +} + +OUString ODataInputStream::readUTF(void) throw (IOException, RuntimeException) +{ + sal_uInt16 nShortLen = (sal_uInt16)readShort(); + sal_Int32 nUTFLen; + + if( ((sal_uInt16)0xffff) == nShortLen ) + { + // is interpreted as a sign, that string is longer than 64k + // incompatible to older XDataInputStream-routines, when strings are exactly 64k + nUTFLen = readLong(); + } + else + { + nUTFLen = ( sal_Int32 ) nShortLen; + } + + Sequence<sal_Unicode> aBuffer( nUTFLen ); + sal_Unicode * pStr = aBuffer.getArray(); + + sal_Int32 nCount = 0; + sal_Int32 nStrLen = 0; + while( nCount < nUTFLen ) + { + sal_uInt8 c = (sal_uInt8)readByte(); + sal_uInt8 char2, char3; + switch( c >> 4 ) + { + case 0: case 1: case 2: case 3: case 4: case 5: case 6: case 7: + // 0xxxxxxx + nCount++; + pStr[nStrLen++] = c; + break; + + case 12: case 13: + // 110x xxxx 10xx xxxx + nCount += 2; + if( ! ( nCount <= nUTFLen ) ) + { + throw WrongFormatException( ); + } + + char2 = (sal_uInt8)readByte(); + if( ! ( (char2 & 0xC0) == 0x80 ) ) + { + throw WrongFormatException( ); + } + + pStr[nStrLen++] = (sal_Unicode(c & 0x1F) << 6) | (char2 & 0x3F); + break; + + case 14: + // 1110 xxxx 10xx xxxx 10xx xxxx + nCount += 3; + if( !( nCount <= nUTFLen) ) + { + throw WrongFormatException( ); + } + + char2 = (sal_uInt8)readByte(); + char3 = (sal_uInt8)readByte(); + + if( (((char2 & 0xC0) != 0x80) || ((char3 & 0xC0) != 0x80)) ) { + throw WrongFormatException( ); + } + pStr[nStrLen++] = (sal_Unicode(c & 0x0F) << 12) | + (sal_Unicode(char2 & 0x3F) << 6) | + (char3 & 0x3F); + break; + + default: + // 10xx xxxx, 1111 xxxx + throw WrongFormatException(); + //throw new UTFDataFormatException(); + } + } + return OUString( pStr, nStrLen ); +} + + + +// XActiveDataSource +void ODataInputStream::setInputStream(const Reference< XInputStream > & aStream) + throw (RuntimeException) +{ + + if( m_input != aStream ) { + m_input = aStream; + + Reference < XConnectable > pred( m_input , UNO_QUERY ); + setPredecessor( pred ); + } + + m_bValidStream = m_input.is(); +} + +Reference< XInputStream > ODataInputStream::getInputStream(void) throw (RuntimeException) +{ + return m_input; +} + + + +// XDataSink +void ODataInputStream::setSuccessor( const Reference < XConnectable > &r ) throw (RuntimeException) +{ + /// if the references match, nothing needs to be done + if( m_succ != r ) { + /// store the reference for later use + m_succ = r; + + if( m_succ.is() ) { + /// set this instance as the sink ! + m_succ->setPredecessor( Reference< XConnectable > ( + SAL_STATIC_CAST( XConnectable * , this ) ) ); + } + } +} + +Reference < XConnectable > ODataInputStream::getSuccessor() throw (RuntimeException) +{ + return m_succ; +} + + +// XDataSource +void ODataInputStream::setPredecessor( const Reference < XConnectable > &r ) + throw (RuntimeException) +{ + if( r != m_pred ) { + m_pred = r; + if( m_pred.is() ) { + m_pred->setSuccessor( Reference< XConnectable > ( + SAL_STATIC_CAST( XConnectable * , this ) ) ); + } + } +} +Reference < XConnectable > ODataInputStream::getPredecessor() throw (RuntimeException) +{ + return m_pred; +} + +// XServiceInfo +OUString ODataInputStream::getImplementationName() throw () +{ + return ODataInputStream_getImplementationName(); +} + +// XServiceInfo +sal_Bool ODataInputStream::supportsService(const OUString& ServiceName) throw () +{ + Sequence< OUString > aSNL = getSupportedServiceNames(); + const OUString * pArray = aSNL.getConstArray(); + + for( sal_Int32 i = 0; i < aSNL.getLength(); i++ ) + if( pArray[i] == ServiceName ) + return sal_True; + + return sal_False; +} + +// XServiceInfo +Sequence< OUString > ODataInputStream::getSupportedServiceNames(void) throw () +{ + return ODataInputStream_getSupportedServiceNames(); +} + +/*** +* +* registration information +* +* +****/ + +Reference< XInterface > SAL_CALL ODataInputStream_CreateInstance( const Reference < XComponentContext > & ) throw( Exception) +{ + ODataInputStream *p = new ODataInputStream; + return Reference< XInterface > ( (OWeakObject * ) p ); +} + +OUString ODataInputStream_getImplementationName() +{ + return OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.io.stm.DataInputStream" ) ); +} + +Sequence<OUString> ODataInputStream_getSupportedServiceNames(void) +{ + Sequence<OUString> aRet(1); + aRet.getArray()[0] = OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.io.DataInputStream" ) ); + return aRet; +} + + + + +class ODataOutputStream : + public WeakImplHelper4 < + XDataOutputStream, + XActiveDataSource, + XConnectable, + XServiceInfo > +{ +public: + ODataOutputStream() + : m_bValidStream( sal_False ) + { + g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); + } + ~ODataOutputStream(); + +public: // XOutputStream + virtual void SAL_CALL writeBytes(const Sequence< sal_Int8 >& aData) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + virtual void SAL_CALL flush(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + virtual void SAL_CALL closeOutput(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + +public: // XDataOutputStream + virtual void SAL_CALL writeBoolean(sal_Bool Value) throw (IOException, RuntimeException); + virtual void SAL_CALL writeByte(sal_Int8 Value) throw (IOException, RuntimeException); + virtual void SAL_CALL writeChar(sal_Unicode Value) throw (IOException, RuntimeException); + virtual void SAL_CALL writeShort(sal_Int16 Value) throw (IOException, RuntimeException); + virtual void SAL_CALL writeLong(sal_Int32 Value) throw (IOException, RuntimeException); + virtual void SAL_CALL writeHyper(sal_Int64 Value) throw (IOException, RuntimeException); + virtual void SAL_CALL writeFloat(float Value) throw (IOException, RuntimeException); + virtual void SAL_CALL writeDouble(double Value) throw (IOException, RuntimeException); + virtual void SAL_CALL writeUTF(const OUString& Value) throw (IOException, RuntimeException); + +public: // XActiveDataSource + virtual void SAL_CALL setOutputStream(const Reference< XOutputStream > & aStream) + throw (RuntimeException); + virtual Reference < XOutputStream > SAL_CALL getOutputStream(void) throw (RuntimeException); + +public: // XConnectable + virtual void SAL_CALL setPredecessor(const Reference < XConnectable >& aPredecessor) + throw (RuntimeException); + virtual Reference < XConnectable > SAL_CALL getPredecessor(void) + throw (RuntimeException); + virtual void SAL_CALL setSuccessor(const Reference < XConnectable >& aSuccessor) + throw (RuntimeException); + virtual Reference < XConnectable > SAL_CALL getSuccessor(void) + throw (RuntimeException); + +public: // XServiceInfo + OUString SAL_CALL getImplementationName() throw (); + Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw (); + sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw (); + +protected: + Reference < XConnectable > m_succ; + Reference < XConnectable > m_pred; + Reference< XOutputStream > m_output; + sal_Bool m_bValidStream; +}; + +ODataOutputStream::~ODataOutputStream() +{ + g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); +} + + +// XOutputStream +void ODataOutputStream::writeBytes(const Sequence< sal_Int8 >& aData) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + if( m_bValidStream ) + { + m_output->writeBytes( aData ); + } + else { + throw NotConnectedException( ); + } +} + +void ODataOutputStream::flush(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + if( m_bValidStream ) + { + m_output->flush(); + } + else + { + throw NotConnectedException(); + } + +} + + +void ODataOutputStream::closeOutput(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + if( m_bValidStream ) + { + m_output->closeOutput(); + setOutputStream( Reference< XOutputStream > () ); + setPredecessor( Reference < XConnectable >() ); + setSuccessor( Reference < XConnectable >() ); + } + else + { + throw NotConnectedException(); + } +} + +// XDataOutputStream +void ODataOutputStream::writeBoolean(sal_Bool Value) + throw ( IOException, + RuntimeException) +{ + if( Value ) + { + writeByte( 1 ); + } + else + { + writeByte( 0 ); + } +} + + +void ODataOutputStream::writeByte(sal_Int8 Value) + throw ( IOException, + RuntimeException) +{ + Sequence<sal_Int8> aTmp( 1 ); + aTmp.getArray()[0] = Value; + writeBytes( aTmp ); +} + +void ODataOutputStream::writeChar(sal_Unicode Value) + throw ( IOException, + RuntimeException) +{ + Sequence<sal_Int8> aTmp( 2 ); + sal_Int8 * pBytes = ( sal_Int8 * ) aTmp.getArray(); + pBytes[0] = sal_Int8(Value >> 8); + pBytes[1] = sal_Int8(Value); + writeBytes( aTmp ); +} + + +void ODataOutputStream::writeShort(sal_Int16 Value) + throw ( IOException, + RuntimeException) +{ + Sequence<sal_Int8> aTmp( 2 ); + sal_Int8 * pBytes = aTmp.getArray(); + pBytes[0] = sal_Int8(Value >> 8); + pBytes[1] = sal_Int8(Value); + writeBytes( aTmp ); +} + +void ODataOutputStream::writeLong(sal_Int32 Value) + throw ( IOException, + RuntimeException) +{ + Sequence<sal_Int8> aTmp( 4 ); + sal_Int8 * pBytes = aTmp.getArray(); + pBytes[0] = sal_Int8(Value >> 24); + pBytes[1] = sal_Int8(Value >> 16); + pBytes[2] = sal_Int8(Value >> 8); + pBytes[3] = sal_Int8(Value); + writeBytes( aTmp ); +} + +void ODataOutputStream::writeHyper(sal_Int64 Value) + throw ( IOException, + RuntimeException) +{ + Sequence<sal_Int8> aTmp( 8 ); + sal_Int8 * pBytes = aTmp.getArray(); + pBytes[0] = sal_Int8(Value >> 56); + pBytes[1] = sal_Int8(Value >> 48); + pBytes[2] = sal_Int8(Value >> 40); + pBytes[3] = sal_Int8(Value >> 32); + pBytes[4] = sal_Int8(Value >> 24); + pBytes[5] = sal_Int8(Value >> 16); + pBytes[6] = sal_Int8(Value >> 8); + pBytes[7] = sal_Int8(Value); + writeBytes( aTmp ); +} + + +void ODataOutputStream::writeFloat(float Value) + throw ( IOException, + RuntimeException) +{ + union { float f; sal_uInt32 n; } a; + a.f = Value; + writeLong( a.n ); +} + +void ODataOutputStream::writeDouble(double Value) + throw ( IOException, + RuntimeException) +{ + sal_uInt32 n = 1; + union { double d; struct { sal_uInt32 n1; sal_uInt32 n2; } ad; } a; + a.d = Value; + if( *(sal_Int8 *)&n == 1 ) + { + // little endian + writeLong( a.ad.n2 ); + writeLong( a.ad.n1 ); + } + else + { + // big endian + writeLong( a.ad.n1 ); + writeLong( a.ad.n2 ); + } +} + +void ODataOutputStream::writeUTF(const OUString& Value) + throw ( IOException, + RuntimeException) +{ + sal_Int32 nStrLen = Value.getLength(); + const sal_Unicode * pStr = Value.getStr(); + sal_Int32 nUTFLen = 0; + sal_Int32 i; + + for( i = 0 ; i < nStrLen ; i++ ) + { + sal_uInt16 c = pStr[i]; + if( (c >= 0x0001) && (c <= 0x007F) ) + { + nUTFLen++; + } + else if( c > 0x07FF ) + { + nUTFLen += 3; + } + else + { + nUTFLen += 2; + } + } + + + // compatibility mode for older implementations, where it was not possible + // to write blocks bigger than 64 k. Note that there is a tradeoff. Blocks, + // that are exactly 64k long can not be read by older routines when written + // with these routines and the other way round !!!!! + if( nUTFLen >= 0xFFFF ) { + writeShort( (sal_Int16)-1 ); + writeLong( nUTFLen ); + } + else { + writeShort( ((sal_uInt16)nUTFLen) ); + } + for( i = 0 ; i < nStrLen ; i++ ) + { + sal_uInt16 c = pStr[i]; + if( (c >= 0x0001) && (c <= 0x007F) ) + { + writeByte(sal_Int8(c)); + } + else if( c > 0x07FF ) + { + writeByte(sal_Int8(0xE0 | ((c >> 12) & 0x0F))); + writeByte(sal_Int8(0x80 | ((c >> 6) & 0x3F))); + writeByte(sal_Int8(0x80 | ((c >> 0) & 0x3F))); + //written += 2; + } + else + { + writeByte(sal_Int8(0xC0 | ((c >> 6) & 0x1F))); + writeByte(sal_Int8(0x80 | ((c >> 0) & 0x3F))); + //written += 1; + } + } + //written += strlen + 2; +} + +// XActiveDataSource +void ODataOutputStream::setOutputStream(const Reference< XOutputStream > & aStream) + throw (RuntimeException) +{ + if( m_output != aStream ) { + m_output = aStream; + m_bValidStream = m_output.is(); + + Reference < XConnectable > succ( m_output , UNO_QUERY ); + setSuccessor( succ ); + } +} + +Reference< XOutputStream > ODataOutputStream::getOutputStream(void) + throw (RuntimeException) +{ + return m_output; +} + + + + +// XDataSink +void ODataOutputStream::setSuccessor( const Reference < XConnectable > &r ) + throw (RuntimeException) +{ + /// if the references match, nothing needs to be done + if( m_succ != r ) + { + /// store the reference for later use + m_succ = r; + + if( m_succ.is() ) + { + /// set this instance as the sink ! + m_succ->setPredecessor( Reference < XConnectable > ( + SAL_STATIC_CAST( XConnectable * , this ) )); + } + } +} +Reference < XConnectable > ODataOutputStream::getSuccessor() throw (RuntimeException) +{ + return m_succ; +} + + +// XDataSource +void ODataOutputStream::setPredecessor( const Reference < XConnectable > &r ) throw (RuntimeException) +{ + if( r != m_pred ) { + m_pred = r; + if( m_pred.is() ) { + m_pred->setSuccessor( Reference< XConnectable > ( + SAL_STATIC_CAST( XConnectable * , this ) )); + } + } +} +Reference < XConnectable > ODataOutputStream::getPredecessor() throw (RuntimeException) +{ + return m_pred; +} + + + +// XServiceInfo +OUString ODataOutputStream::getImplementationName() throw () +{ + return ODataOutputStream_getImplementationName(); +} + +// XServiceInfo +sal_Bool ODataOutputStream::supportsService(const OUString& ServiceName) throw () +{ + Sequence< OUString > aSNL = getSupportedServiceNames(); + const OUString * pArray = aSNL.getConstArray(); + + for( sal_Int32 i = 0; i < aSNL.getLength(); i++ ) + if( pArray[i] == ServiceName ) + return sal_True; + + return sal_False; +} + +// XServiceInfo +Sequence< OUString > ODataOutputStream::getSupportedServiceNames(void) throw () +{ + return ODataOutputStream_getSupportedServiceNames(); +} + + + + +Reference< XInterface > SAL_CALL ODataOutputStream_CreateInstance( const Reference < XComponentContext > & ) throw(Exception) +{ + ODataOutputStream *p = new ODataOutputStream; + Reference< XInterface > xService = *p; + return xService; +} + + +OUString ODataOutputStream_getImplementationName() +{ + return OUString(RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.io.stm.DataOutputStream" ) ); +} + +Sequence<OUString> ODataOutputStream_getSupportedServiceNames(void) +{ + Sequence<OUString> aRet(1); + aRet.getArray()[0] = OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.io.DataOutputStream" ) ); + return aRet; +} + +//-------------------------------------- +struct equalObjectContainer_Impl +{ + sal_Int32 operator()(const Reference< XInterface > & s1, + const Reference< XInterface > & s2) const + { + return s1 == s2; + } +}; + +//----------------------------------------------------------------------------- +struct hashObjectContainer_Impl +{ + size_t operator()(const Reference< XInterface > & xRef) const + { + return (size_t)xRef.get(); + } +}; + +typedef hash_map +< + Reference< XInterface >, + sal_Int32, + hashObjectContainer_Impl, + equalObjectContainer_Impl +> ObjectContainer_Impl; + +/*--------------------------------------------- +* +* +* +* +*--------------------------------------------*/ +class OObjectOutputStream : + public ODataOutputStream, + public XObjectOutputStream, + public XMarkableStream +{ +public: + OObjectOutputStream() + : m_nMaxId(0) , + m_bValidMarkable(sal_False) + { + g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); + } + + ~OObjectOutputStream(); + +public: + Any SAL_CALL queryInterface( const Type &type ) throw (::com::sun::star::uno::RuntimeException); + void SAL_CALL acquire() throw() { ODataOutputStream::acquire(); } + void SAL_CALL release() throw() { ODataOutputStream::release(); } + +public: + // XOutputStream + virtual void SAL_CALL writeBytes(const Sequence< sal_Int8 >& aData) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) + { ODataOutputStream::writeBytes( aData ); } + + virtual void SAL_CALL flush(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) + { ODataOutputStream::flush(); } + + virtual void SAL_CALL closeOutput(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) + { ODataOutputStream::closeOutput(); } + +public: + // XDataOutputStream + virtual void SAL_CALL writeBoolean(sal_Bool Value) throw (IOException, RuntimeException) + { ODataOutputStream::writeBoolean( Value ); } + virtual void SAL_CALL writeByte(sal_Int8 Value) throw (IOException, RuntimeException) + { ODataOutputStream::writeByte( Value ); } + virtual void SAL_CALL writeChar(sal_Unicode Value) throw (IOException, RuntimeException) + { ODataOutputStream::writeChar( Value ); } + virtual void SAL_CALL writeShort(sal_Int16 Value) throw (IOException, RuntimeException) + { ODataOutputStream::writeShort( Value ); } + virtual void SAL_CALL writeLong(sal_Int32 Value) throw (IOException, RuntimeException) + { ODataOutputStream::writeLong( Value ); } + virtual void SAL_CALL writeHyper(sal_Int64 Value) throw (IOException, RuntimeException) + { ODataOutputStream::writeHyper( Value ); } + virtual void SAL_CALL writeFloat(float Value) throw (IOException, RuntimeException) + { ODataOutputStream::writeFloat( Value ); } + virtual void SAL_CALL writeDouble(double Value) throw (IOException, RuntimeException) + { ODataOutputStream::writeDouble( Value ); } + virtual void SAL_CALL writeUTF(const OUString& Value) throw (IOException, RuntimeException) + { ODataOutputStream::writeUTF( Value );} + + // XObjectOutputStream + virtual void SAL_CALL writeObject( const Reference< XPersistObject > & r ) throw (::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException); + +public: // XMarkableStream + virtual sal_Int32 SAL_CALL createMark(void) throw (IOException, RuntimeException); + virtual void SAL_CALL deleteMark(sal_Int32 Mark) throw (IOException, IllegalArgumentException, RuntimeException); + virtual void SAL_CALL jumpToMark(sal_Int32 nMark) throw (IOException, IllegalArgumentException, RuntimeException); + virtual void SAL_CALL jumpToFurthest(void) throw (IOException, RuntimeException); + virtual sal_Int32 SAL_CALL offsetToMark(sal_Int32 nMark) + throw (IOException, IllegalArgumentException, RuntimeException); + +public: //XTypeProvider + virtual ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Type > SAL_CALL + getTypes( ) throw(::com::sun::star::uno::RuntimeException); + virtual ::com::sun::star::uno::Sequence< sal_Int8 > SAL_CALL + getImplementationId( ) throw(::com::sun::star::uno::RuntimeException); + +public: // XServiceInfo + OUString SAL_CALL getImplementationName() throw (); + Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw (); + sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw (); + +private: + void connectToMarkable(); +private: + ObjectContainer_Impl m_mapObject; + sal_Int32 m_nMaxId; + Reference< XMarkableStream > m_rMarkable; + sal_Bool m_bValidMarkable; +}; + +OObjectOutputStream::~OObjectOutputStream() +{ + g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); +} + +Any OObjectOutputStream::queryInterface( const Type &aType ) throw (::com::sun::star::uno::RuntimeException) +{ + Any a = ::cppu::queryInterface( + aType , + SAL_STATIC_CAST( XMarkableStream * , this ), + SAL_STATIC_CAST( XObjectOutputStream * , this ) ); + if( a.hasValue() ) + { + return a; + } + + return ODataOutputStream::queryInterface( aType ); + +} +void OObjectOutputStream::writeObject( const Reference< XPersistObject > & xPObj ) throw (::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException) +{ + + connectToMarkable(); + sal_Bool bWriteObj = sal_False; + // create Mark to write length of info + sal_uInt32 nInfoLenMark = m_rMarkable->createMark(); + + // length of the info data (is later rewritten) + OObjectOutputStream::writeShort( 0 ); + + // write the object identifier + if( xPObj.is() ) + { + Reference< XInterface > rX( xPObj , UNO_QUERY ); + + ObjectContainer_Impl::const_iterator aIt + = m_mapObject.find( rX ); + if( aIt == m_mapObject.end() ) + { + // insert new object in hash table + m_mapObject[ rX ] = ++m_nMaxId; + ODataOutputStream::writeLong( m_nMaxId ); + ODataOutputStream::writeUTF( xPObj->getServiceName() ); + bWriteObj = sal_True; + } + else + { + ODataOutputStream::writeLong( (*aIt).second ); + OUString aName; + ODataOutputStream::writeUTF( aName ); + } + } + else + { + ODataOutputStream::writeLong( 0 ); + OUString aName; + ODataOutputStream::writeUTF( aName ); + } + + sal_uInt32 nObjLenMark = m_rMarkable->createMark(); + ODataOutputStream::writeLong( 0 ); + + sal_Int32 nInfoLen = m_rMarkable->offsetToMark( nInfoLenMark ); + m_rMarkable->jumpToMark( nInfoLenMark ); + // write length of the info data + ODataOutputStream::writeShort( (sal_Int16)nInfoLen ); + // jump to the end of the stream + m_rMarkable->jumpToFurthest(); + + if( bWriteObj ) + xPObj->write( Reference< XObjectOutputStream > ( + SAL_STATIC_CAST( XObjectOutputStream * , this ) ) ); + + sal_Int32 nObjLen = m_rMarkable->offsetToMark( nObjLenMark ) -4; + m_rMarkable->jumpToMark( nObjLenMark ); + // write length of the info data + ODataOutputStream::writeLong( nObjLen ); + // jump to the end of the stream + m_rMarkable->jumpToFurthest(); + + m_rMarkable->deleteMark( nObjLenMark ); + m_rMarkable->deleteMark( nInfoLenMark ); +} + + + +void OObjectOutputStream::connectToMarkable(void) +{ + if( ! m_bValidMarkable ) { + if( ! m_bValidStream ) + { + throw NotConnectedException(); + } + + // find the markable stream ! + Reference< XInterface > rTry(m_output); + while( sal_True ) { + if( ! rTry.is() ) + { + throw NotConnectedException(); + } + Reference < XMarkableStream > markable( rTry , UNO_QUERY ); + if( markable.is() ) + { + m_rMarkable = markable; + break; + } + Reference < XActiveDataSource > source( rTry , UNO_QUERY ); + rTry = source; + } + m_bValidMarkable = sal_True; + } +} + + +sal_Int32 OObjectOutputStream::createMark(void) + throw (IOException, RuntimeException) +{ + connectToMarkable(); // throws an exception, if a markable is not connected ! + + return m_rMarkable->createMark(); +} + +void OObjectOutputStream::deleteMark(sal_Int32 Mark) + throw (IOException, IllegalArgumentException, RuntimeException) +{ + if( ! m_bValidMarkable ) + { + throw NotConnectedException(); + } + m_rMarkable->deleteMark( Mark ); +} + +void OObjectOutputStream::jumpToMark(sal_Int32 nMark) + throw (IOException, IllegalArgumentException, RuntimeException) +{ + if( ! m_bValidMarkable ) + { + throw NotConnectedException(); + } + m_rMarkable->jumpToMark( nMark ); +} + + +void OObjectOutputStream::jumpToFurthest(void) + throw (IOException, RuntimeException) +{ + connectToMarkable(); + m_rMarkable->jumpToFurthest(); +} + +sal_Int32 OObjectOutputStream::offsetToMark(sal_Int32 nMark) + throw (IOException, IllegalArgumentException, RuntimeException) +{ + if( ! m_bValidMarkable ) + { + throw NotConnectedException(); + } + return m_rMarkable->offsetToMark( nMark ); +} + + + + +Reference< XInterface > SAL_CALL OObjectOutputStream_CreateInstance( const Reference < XComponentContext > & ) + throw(Exception) +{ + OObjectOutputStream *p = new OObjectOutputStream; + return Reference< XInterface > ( SAL_STATIC_CAST( OWeakObject * , p ) ); +} + +OUString OObjectOutputStream_getImplementationName() +{ + return OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.io.stm.ObjectOutputStream" ) ); +} + +Sequence<OUString> OObjectOutputStream_getSupportedServiceNames(void) +{ + Sequence<OUString> aRet(1); + aRet.getArray()[0] = OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.io.ObjectOutputStream" ) ); + return aRet; +} + +Sequence< Type > SAL_CALL OObjectOutputStream::getTypes(void) throw( RuntimeException ) +{ + static OTypeCollection *pCollection = 0; + if( ! pCollection ) + { + MutexGuard guard( Mutex::getGlobalMutex() ); + if( ! pCollection ) + { + static OTypeCollection collection( + getCppuType( (Reference< XMarkableStream > * ) 0 ), + getCppuType( (Reference< XObjectOutputStream > * ) 0 ), + ODataOutputStream::getTypes() ); + pCollection = &collection; + } + } + return (*pCollection).getTypes(); +} + +Sequence< sal_Int8 > SAL_CALL OObjectOutputStream::getImplementationId( ) throw( RuntimeException) +{ + static OImplementationId *pId = 0; + if( ! pId ) + { + MutexGuard guard( Mutex::getGlobalMutex() ); + if( ! pId ) + { + static OImplementationId id( sal_False ); + pId = &id; + } + } + return (*pId).getImplementationId(); +} + + +// XServiceInfo +OUString OObjectOutputStream::getImplementationName() throw () +{ + return ODataInputStream_getImplementationName(); +} + +// XServiceInfo +sal_Bool OObjectOutputStream::supportsService(const OUString& ServiceName) throw () +{ + Sequence< OUString > aSNL = getSupportedServiceNames(); + const OUString * pArray = aSNL.getConstArray(); + + for( sal_Int32 i = 0; i < aSNL.getLength(); i++ ) + if( pArray[i] == ServiceName ) + return sal_True; + + return sal_False; +} + +// XServiceInfo +Sequence< OUString > OObjectOutputStream::getSupportedServiceNames(void) throw () +{ + return OObjectOutputStream_getSupportedServiceNames(); +} + + + + + +class OObjectInputStream : + public ODataInputStream, + public XObjectInputStream, + public XMarkableStream +{ +public: + OObjectInputStream( const Reference < XComponentContext > &r) + : m_rSMgr( r->getServiceManager() ) + , m_rCxt( r ) + , m_bValidMarkable(sal_False) + { + g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); + } + ~OObjectInputStream(); + +public: + Any SAL_CALL queryInterface( const Type &type ) throw(); + void SAL_CALL acquire() throw() { ODataInputStream::acquire(); } + void SAL_CALL release() throw() { ODataInputStream::release(); } + +public: // XInputStream + virtual sal_Int32 SAL_CALL readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) + { return ODataInputStream::readBytes( aData , nBytesToRead ); } + + virtual sal_Int32 SAL_CALL readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) + { return ODataInputStream::readSomeBytes( aData, nMaxBytesToRead ); } + + virtual void SAL_CALL skipBytes(sal_Int32 nBytesToSkip) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) + { ODataInputStream::skipBytes( nBytesToSkip ); } + + virtual sal_Int32 SAL_CALL available(void) + throw ( NotConnectedException, + RuntimeException) + { return ODataInputStream::available(); } + + virtual void SAL_CALL closeInput(void) + throw ( NotConnectedException, + RuntimeException) + { ODataInputStream::closeInput(); } + +public: // XDataInputStream + virtual sal_Int8 SAL_CALL readBoolean(void) throw (IOException, RuntimeException) + { return ODataInputStream::readBoolean(); } + virtual sal_Int8 SAL_CALL readByte(void) throw (IOException, RuntimeException) + { return ODataInputStream::readByte(); } + virtual sal_Unicode SAL_CALL readChar(void) throw (IOException, RuntimeException) + { return ODataInputStream::readChar(); } + virtual sal_Int16 SAL_CALL readShort(void) throw (IOException, RuntimeException) + { return ODataInputStream::readShort(); } + virtual sal_Int32 SAL_CALL readLong(void) throw (IOException, RuntimeException) + { return ODataInputStream::readLong(); } + virtual sal_Int64 SAL_CALL readHyper(void) throw (IOException, RuntimeException) + { return ODataInputStream::readHyper(); } + virtual float SAL_CALL readFloat(void) throw (IOException, RuntimeException) + { return ODataInputStream::readFloat(); } + virtual double SAL_CALL readDouble(void) throw (IOException, RuntimeException) + { return ODataInputStream::readDouble(); } + virtual OUString SAL_CALL readUTF(void) throw (IOException, RuntimeException) + { return ODataInputStream::readUTF(); } + +public: // XObjectInputStream + virtual Reference< XPersistObject > SAL_CALL readObject( ) throw (::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException); + +public: // XMarkableStream + virtual sal_Int32 SAL_CALL createMark(void) + throw (IOException, RuntimeException); + virtual void SAL_CALL deleteMark(sal_Int32 Mark) throw (IOException, IllegalArgumentException, RuntimeException); + virtual void SAL_CALL jumpToMark(sal_Int32 nMark) throw (IOException, IllegalArgumentException, RuntimeException); + virtual void SAL_CALL jumpToFurthest(void) throw (IOException, RuntimeException); + virtual sal_Int32 SAL_CALL offsetToMark(sal_Int32 nMark) + throw (IOException, IllegalArgumentException, RuntimeException); + +public: //XTypeProvider + virtual ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Type > SAL_CALL + getTypes( ) throw(::com::sun::star::uno::RuntimeException); + virtual ::com::sun::star::uno::Sequence< sal_Int8 > SAL_CALL + getImplementationId( ) throw(::com::sun::star::uno::RuntimeException); + +public: // XServiceInfo + OUString SAL_CALL getImplementationName() throw (); + Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw (); + sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw (); + +private: + void connectToMarkable(); +private: + Reference < XMultiComponentFactory > m_rSMgr; + Reference < XComponentContext > m_rCxt; + sal_Bool m_bValidMarkable; + Reference < XMarkableStream > m_rMarkable; + vector < Reference< XPersistObject > > m_aPersistVector; + +}; + +OObjectInputStream::~OObjectInputStream() +{ + g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); +} + +Any OObjectInputStream::queryInterface( const Type &aType ) throw () +{ + Any a = ::cppu::queryInterface( + aType , + SAL_STATIC_CAST( XMarkableStream * , this ), + SAL_STATIC_CAST( XObjectInputStream * , this ) ); + if( a.hasValue() ) + { + return a; + } + + return ODataInputStream::queryInterface( aType ); + +} + +Reference< XPersistObject > OObjectInputStream::readObject() throw (::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException) +{ + // check if chain contains a XMarkableStream + connectToMarkable(); + + Reference< XPersistObject > xLoadedObj; + + // create Mark to skip newer versions + sal_uInt32 nMark = m_rMarkable->createMark(); + // length of the data + sal_Int32 nLen = (sal_uInt16) ODataInputStream::readShort(); + if( nLen < 0xc ) + { + throw WrongFormatException(); + } + + // read the object identifier + sal_uInt32 nId = readLong(); + + // the name of the persist model + // MM ??? + OUString aName = readUTF(); + + // Read the length of the object + sal_Int32 nObjLen = readLong(); + if( ( 0 == nId && 0 != nObjLen ) ) + { + throw WrongFormatException(); + } + + // skip data of new version + skipBytes( nLen - m_rMarkable->offsetToMark( nMark ) ); + + sal_Bool bLoadSuccesfull = sal_True; + if( nId ) + { + if( aName.getLength() ) + { + // load the object + Reference< XInterface > x = m_rSMgr->createInstanceWithContext( aName, m_rCxt ); + xLoadedObj = Reference< XPersistObject >( x, UNO_QUERY ); + if( xLoadedObj.is() ) + { + sal_uInt32 nSize = m_aPersistVector.size(); + if( nSize <= nId ) + { + // grow to the right size + Reference< XPersistObject > xEmpty; + m_aPersistVector.insert( m_aPersistVector.end(), (long)(nId - nSize + 1), xEmpty ); + } + + m_aPersistVector[nId] = xLoadedObj; + xLoadedObj->read( Reference< XObjectInputStream >( + SAL_STATIC_CAST( XObjectInputStream *, this ) ) ); + } + else + { + // no service with this name could be instantiated + bLoadSuccesfull = sal_False; + } + } + else { + if( m_aPersistVector.size() < nId ) + { + // id unknown, load failure ! + bLoadSuccesfull = sal_False; + } + else + { + // Object has alread been read, + xLoadedObj = m_aPersistVector[nId]; + } + } + } + + // skip to the position behind the object + skipBytes( nObjLen + nLen - m_rMarkable->offsetToMark( nMark ) ); + m_rMarkable->deleteMark( nMark ); + + if( ! bLoadSuccesfull ) + { + throw WrongFormatException(); + } + return xLoadedObj; +} + + +void OObjectInputStream::connectToMarkable() +{ + if( ! m_bValidMarkable ) { + if( ! m_bValidStream ) + { + throw NotConnectedException( ); + } + + // find the markable stream ! + Reference< XInterface > rTry(m_input); + while( sal_True ) { + if( ! rTry.is() ) + { + throw NotConnectedException( ); + } + Reference< XMarkableStream > markable( rTry , UNO_QUERY ); + if( markable.is() ) + { + m_rMarkable = markable; + break; + } + Reference < XActiveDataSink > sink( rTry , UNO_QUERY ); + rTry = sink; + } + m_bValidMarkable = sal_True; + } +} + +sal_Int32 OObjectInputStream::createMark(void) throw (IOException, RuntimeException) +{ + connectToMarkable(); // throws an exception, if a markable is not connected ! + + return m_rMarkable->createMark(); +} + +void OObjectInputStream::deleteMark(sal_Int32 Mark) throw (IOException, IllegalArgumentException, RuntimeException) +{ + if( ! m_bValidMarkable ) + { + throw NotConnectedException(); + } + m_rMarkable->deleteMark( Mark ); +} + +void OObjectInputStream::jumpToMark(sal_Int32 nMark) throw (IOException, IllegalArgumentException, RuntimeException) +{ + if( ! m_bValidMarkable ) + { + throw NotConnectedException(); + } + m_rMarkable->jumpToMark( nMark ); +} +void OObjectInputStream::jumpToFurthest(void) throw (IOException, RuntimeException) +{ + connectToMarkable(); + m_rMarkable->jumpToFurthest(); +} + +sal_Int32 OObjectInputStream::offsetToMark(sal_Int32 nMark) + throw (IOException, IllegalArgumentException, RuntimeException) +{ + if( ! m_bValidMarkable ) + { + throw NotConnectedException(); + } + return m_rMarkable->offsetToMark( nMark ); +} + + +Sequence< Type > SAL_CALL OObjectInputStream::getTypes(void) throw( RuntimeException ) +{ + static OTypeCollection *pCollection = 0; + if( ! pCollection ) + { + MutexGuard guard( Mutex::getGlobalMutex() ); + if( ! pCollection ) + { + static OTypeCollection collection( + getCppuType( (Reference< XMarkableStream > * ) 0 ), + getCppuType( (Reference< XObjectInputStream > * ) 0 ), + ODataInputStream::getTypes() ); + pCollection = &collection; + } + } + return (*pCollection).getTypes(); +} + +Sequence< sal_Int8 > SAL_CALL OObjectInputStream::getImplementationId( ) throw( RuntimeException) +{ + static OImplementationId *pId = 0; + if( ! pId ) + { + MutexGuard guard( Mutex::getGlobalMutex() ); + if( ! pId ) + { + static OImplementationId id( sal_False ); + pId = &id; + } + } + return (*pId).getImplementationId(); +} + + +// XServiceInfo +OUString OObjectInputStream::getImplementationName() throw () +{ + return OObjectInputStream_getImplementationName(); +} + +// XServiceInfo +sal_Bool OObjectInputStream::supportsService(const OUString& ServiceName) throw () +{ + Sequence< OUString > aSNL = getSupportedServiceNames(); + const OUString * pArray = aSNL.getConstArray(); + + for( sal_Int32 i = 0; i < aSNL.getLength(); i++ ) + if( pArray[i] == ServiceName ) + return sal_True; + + return sal_False; +} + +// XServiceInfo +Sequence< OUString > OObjectInputStream::getSupportedServiceNames(void) throw () +{ + return OObjectInputStream_getSupportedServiceNames(); +} + + + + +Reference< XInterface > SAL_CALL OObjectInputStream_CreateInstance( const Reference < XComponentContext > & rCtx ) throw(Exception) +{ + OObjectInputStream *p = new OObjectInputStream( rCtx ); + return Reference< XInterface> ( SAL_STATIC_CAST( OWeakObject *, p ) ); +} + +OUString OObjectInputStream_getImplementationName() +{ + return OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.io.stm.ObjectInputStream" ) ); +} + +Sequence<OUString> OObjectInputStream_getSupportedServiceNames(void) +{ + Sequence<OUString> aRet(1); + aRet.getArray()[0] = OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.io.ObjectInputStream" ) ); + return aRet; +} + +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/source/stm/omark.cxx b/io/source/stm/omark.cxx new file mode 100644 index 000000000000..792920c2667a --- /dev/null +++ b/io/source/stm/omark.cxx @@ -0,0 +1,1018 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * 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. + * + ************************************************************************/ + +// MARKER(update_precomp.py): autogen include statement, do not remove +#include "precompiled_io.hxx" + +#include <map> +#include <vector> + +#include <com/sun/star/io/XMarkableStream.hpp> +#include <com/sun/star/io/XOutputStream.hpp> +#include <com/sun/star/io/XInputStream.hpp> +#include <com/sun/star/io/XActiveDataSource.hpp> +#include <com/sun/star/io/XActiveDataSink.hpp> +#include <com/sun/star/io/XConnectable.hpp> +#include <com/sun/star/lang/XServiceInfo.hpp> + +#include <cppuhelper/factory.hxx> +#include <cppuhelper/weak.hxx> // OWeakObject +#include <cppuhelper/implbase5.hxx> + +#include <osl/mutex.hxx> +#include <rtl/ustrbuf.hxx> + +#include <string.h> + + +using namespace ::std; +using namespace ::rtl; +using namespace ::cppu; +using namespace ::osl; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::lang; + +#include "streamhelper.hxx" +#include "factreg.hxx" + +namespace io_stm { + +/*********************** +* +* OMarkableOutputStream. +* +* This object allows to set marks in an outputstream. It is allowed to jump back to the marks and +* rewrite the some bytes. +* +* The object must buffer the data since the last mark set. Flush will not +* have any effect. As soon as the last mark has been removed, the object may write the data +* through to the chained object. +* +**********************/ +class OMarkableOutputStream : + public WeakImplHelper5< XOutputStream , + XActiveDataSource , + XMarkableStream , + XConnectable, + XServiceInfo + > +{ +public: + OMarkableOutputStream( ); + ~OMarkableOutputStream(); + +public: // XOutputStream + virtual void SAL_CALL writeBytes(const Sequence< sal_Int8 >& aData) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + virtual void SAL_CALL flush(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + virtual void SAL_CALL closeOutput(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + +public: // XMarkable + virtual sal_Int32 SAL_CALL createMark(void) + throw (IOException, RuntimeException); + virtual void SAL_CALL deleteMark(sal_Int32 Mark) + throw (IOException, + IllegalArgumentException, + RuntimeException); + virtual void SAL_CALL jumpToMark(sal_Int32 nMark) + throw (IOException, + IllegalArgumentException, + RuntimeException); + virtual void SAL_CALL jumpToFurthest(void) + throw (IOException, RuntimeException); + virtual sal_Int32 SAL_CALL offsetToMark(sal_Int32 nMark) + throw (IOException, + IllegalArgumentException, + RuntimeException); + +public: // XActiveDataSource + virtual void SAL_CALL setOutputStream(const Reference < XOutputStream > & aStream) + throw (RuntimeException); + virtual Reference < XOutputStream > SAL_CALL getOutputStream(void) + throw (RuntimeException); + +public: // XConnectable + virtual void SAL_CALL setPredecessor(const Reference < XConnectable > & aPredecessor) + throw (RuntimeException); + virtual Reference < XConnectable > SAL_CALL getPredecessor(void) throw (RuntimeException); + virtual void SAL_CALL setSuccessor(const Reference < XConnectable >& aSuccessor) + throw (RuntimeException); + virtual Reference< XConnectable > SAL_CALL getSuccessor(void) throw (RuntimeException); + +public: // XServiceInfo + OUString SAL_CALL getImplementationName() throw (); + Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw (); + sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw (); + +private: + // helper methods + void checkMarksAndFlush() throw( NotConnectedException, BufferSizeExceededException); + + Reference< XConnectable > m_succ; + Reference< XConnectable > m_pred; + + Reference< XOutputStream > m_output; + sal_Bool m_bValidStream; + + IRingBuffer *m_pBuffer; + map<sal_Int32,sal_Int32,less< sal_Int32 > > m_mapMarks; + sal_Int32 m_nCurrentPos; + sal_Int32 m_nCurrentMark; + + Mutex m_mutex; +}; + +OMarkableOutputStream::OMarkableOutputStream( ) +{ + g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); + m_pBuffer = new MemRingBuffer; + m_nCurrentPos = 0; + m_nCurrentMark = 0; +} + +OMarkableOutputStream::~OMarkableOutputStream() +{ + delete m_pBuffer; + g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); +} + + +// XOutputStream +void OMarkableOutputStream::writeBytes(const Sequence< sal_Int8 >& aData) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + if( m_bValidStream ) { + if( m_mapMarks.empty() && ( m_pBuffer->getSize() == 0 ) ) { + // no mark and buffer active, simple write through + m_output->writeBytes( aData ); + } + else { + MutexGuard guard( m_mutex ); + // new data must be buffered + try + { + m_pBuffer->writeAt( m_nCurrentPos , aData ); + m_nCurrentPos += aData.getLength(); + } + catch( IRingBuffer_OutOfBoundsException & ) + { + throw BufferSizeExceededException(); + } + catch( IRingBuffer_OutOfMemoryException & ) + { + throw BufferSizeExceededException(); + } + checkMarksAndFlush(); + } + } + else { + throw NotConnectedException(); + } +} + +void OMarkableOutputStream::flush(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + Reference< XOutputStream > output; + { + MutexGuard guard( m_mutex ); + output = m_output; + } + + // Markable cannot flush buffered data, because the data may get rewritten, + // however one can forward the flush to the chained stream to give it + // a chance to write data buffered in the chained stream. + if( output.is() ) + { + output->flush(); + } +} + +void OMarkableOutputStream::closeOutput(void) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + if( m_bValidStream ) { + MutexGuard guard( m_mutex ); + // all marks must be cleared and all + + if( ! m_mapMarks.empty() ) + { + m_mapMarks.clear(); + } + m_nCurrentPos = m_pBuffer->getSize(); + checkMarksAndFlush(); + + m_output->closeOutput(); + + setOutputStream( Reference< XOutputStream > () ); + setPredecessor( Reference < XConnectable >() ); + setSuccessor( Reference< XConnectable > () ); + } + else { + throw NotConnectedException(); + } +} + + +sal_Int32 OMarkableOutputStream::createMark(void) + throw ( IOException, + RuntimeException) +{ + MutexGuard guard( m_mutex ); + sal_Int32 nMark = m_nCurrentMark; + + m_mapMarks[nMark] = m_nCurrentPos; + + m_nCurrentMark ++; + return nMark; +} + +void OMarkableOutputStream::deleteMark(sal_Int32 Mark) + throw( IOException, + IllegalArgumentException, + RuntimeException) +{ + MutexGuard guard( m_mutex ); + map<sal_Int32,sal_Int32,less<sal_Int32> >::iterator ii = m_mapMarks.find( Mark ); + + if( ii == m_mapMarks.end() ) { + OUStringBuffer buf( 128 ); + buf.appendAscii( "MarkableOutputStream::deleteMark unknown mark (" ); + buf.append( Mark ); + buf.appendAscii( ")"); + throw IllegalArgumentException( buf.makeStringAndClear(), *this, 0); + } + else { + m_mapMarks.erase( ii ); + checkMarksAndFlush(); + } +} + +void OMarkableOutputStream::jumpToMark(sal_Int32 nMark) + throw (IOException, + IllegalArgumentException, + RuntimeException) +{ + MutexGuard guard( m_mutex ); + map<sal_Int32,sal_Int32,less<sal_Int32> >::iterator ii = m_mapMarks.find( nMark ); + + if( ii == m_mapMarks.end() ) { + OUStringBuffer buf( 128 ); + buf.appendAscii( "MarkableOutputStream::jumpToMark unknown mark (" ); + buf.append( nMark ); + buf.appendAscii( ")"); + throw IllegalArgumentException( buf.makeStringAndClear(), *this, 0); + } + else { + m_nCurrentPos = (*ii).second; + } +} + +void OMarkableOutputStream::jumpToFurthest(void) + throw (IOException, + RuntimeException) +{ + MutexGuard guard( m_mutex ); + m_nCurrentPos = m_pBuffer->getSize(); + checkMarksAndFlush(); +} + +sal_Int32 OMarkableOutputStream::offsetToMark(sal_Int32 nMark) + throw (IOException, + IllegalArgumentException, + RuntimeException) +{ + + MutexGuard guard( m_mutex ); + map<sal_Int32,sal_Int32,less<sal_Int32> >::const_iterator ii = m_mapMarks.find( nMark ); + + if( ii == m_mapMarks.end() ) + { + OUStringBuffer buf( 128 ); + buf.appendAscii( "MarkableOutputStream::offsetToMark unknown mark (" ); + buf.append( nMark ); + buf.appendAscii( ")"); + throw IllegalArgumentException( buf.makeStringAndClear(), *this, 0); + } + return m_nCurrentPos - (*ii).second; +} + + + +// XActiveDataSource2 +void OMarkableOutputStream::setOutputStream(const Reference < XOutputStream >& aStream) + throw (RuntimeException) +{ + if( m_output != aStream ) { + m_output = aStream; + + Reference < XConnectable > succ( m_output , UNO_QUERY ); + setSuccessor( succ ); + } + m_bValidStream = m_output.is(); +} + +Reference< XOutputStream > OMarkableOutputStream::getOutputStream(void) throw (RuntimeException) +{ + return m_output; +} + + + +void OMarkableOutputStream::setSuccessor( const Reference< XConnectable > &r ) + throw (RuntimeException) +{ + /// if the references match, nothing needs to be done + if( m_succ != r ) { + /// store the reference for later use + m_succ = r; + + if( m_succ.is() ) { + m_succ->setPredecessor( Reference < XConnectable > ( + SAL_STATIC_CAST( XConnectable * , this ) ) ); + } + } +} +Reference <XConnectable > OMarkableOutputStream::getSuccessor() throw (RuntimeException) +{ + return m_succ; +} + + +// XDataSource +void OMarkableOutputStream::setPredecessor( const Reference< XConnectable > &r ) + throw (RuntimeException) +{ + if( r != m_pred ) { + m_pred = r; + if( m_pred.is() ) { + m_pred->setSuccessor( Reference < XConnectable > ( + SAL_STATIC_CAST ( XConnectable * , this ) ) ); + } + } +} +Reference < XConnectable > OMarkableOutputStream::getPredecessor() throw (RuntimeException) +{ + return m_pred; +} + + +// private methods + +void OMarkableOutputStream::checkMarksAndFlush() throw( NotConnectedException, + BufferSizeExceededException) +{ + map<sal_Int32,sal_Int32,less<sal_Int32> >::iterator ii; + + // find the smallest mark + sal_Int32 nNextFound = m_nCurrentPos; + for( ii = m_mapMarks.begin() ; ii != m_mapMarks.end() ; ii ++ ) { + if( (*ii).second <= nNextFound ) { + nNextFound = (*ii).second; + } + } + + if( nNextFound ) { + // some data must be released ! + m_nCurrentPos -= nNextFound; + for( ii = m_mapMarks.begin() ; ii != m_mapMarks.end() ; ii ++ ) { + (*ii).second -= nNextFound; + } + + Sequence<sal_Int8> seq(nNextFound); + m_pBuffer->readAt( 0 , seq , nNextFound ); + m_pBuffer->forgetFromStart( nNextFound ); + + // now write data through to streams + m_output->writeBytes( seq ); + } + else { + // nothing to do. There is a mark or the current cursor position, that prevents + // releasing data ! + } +} + + +// XServiceInfo +OUString OMarkableOutputStream::getImplementationName() throw () +{ + return OMarkableOutputStream_getImplementationName(); +} + +// XServiceInfo +sal_Bool OMarkableOutputStream::supportsService(const OUString& ServiceName) throw () +{ + Sequence< OUString > aSNL = getSupportedServiceNames(); + const OUString * pArray = aSNL.getConstArray(); + + for( sal_Int32 i = 0; i < aSNL.getLength(); i++ ) + if( pArray[i] == ServiceName ) + return sal_True; + + return sal_False; +} + +// XServiceInfo +Sequence< OUString > OMarkableOutputStream::getSupportedServiceNames(void) throw () +{ + return OMarkableOutputStream_getSupportedServiceNames(); +} + + + + +/*------------------------ +* +* external binding +* +*------------------------*/ +Reference< XInterface > SAL_CALL OMarkableOutputStream_CreateInstance( const Reference < XComponentContext > & ) throw(Exception) +{ + OMarkableOutputStream *p = new OMarkableOutputStream( ); + + return Reference < XInterface > ( ( OWeakObject * ) p ); +} + +OUString OMarkableOutputStream_getImplementationName() +{ + return OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.io.stm.MarkableOutputStream" )); +} + +Sequence<OUString> OMarkableOutputStream_getSupportedServiceNames(void) +{ + Sequence<OUString> aRet(1); + aRet.getArray()[0] = OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.io.MarkableOutputStream" ) ); + + return aRet; +} + + + + + + +//------------------------------------------------ +// +// XMarkableInputStream +// +//------------------------------------------------ + +class OMarkableInputStream : + public WeakImplHelper5 + < + XInputStream, + XActiveDataSink, + XMarkableStream, + XConnectable, + XServiceInfo + > +{ +public: + OMarkableInputStream( ); + ~OMarkableInputStream(); + + +public: // XInputStream + virtual sal_Int32 SAL_CALL readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) ; + virtual sal_Int32 SAL_CALL readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + virtual void SAL_CALL skipBytes(sal_Int32 nBytesToSkip) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException); + + virtual sal_Int32 SAL_CALL available(void) + throw ( NotConnectedException, + RuntimeException); + virtual void SAL_CALL closeInput(void) throw (NotConnectedException, RuntimeException); + +public: // XMarkable + virtual sal_Int32 SAL_CALL createMark(void) + throw (IOException, RuntimeException); + virtual void SAL_CALL deleteMark(sal_Int32 Mark) + throw (IOException, IllegalArgumentException, RuntimeException); + virtual void SAL_CALL jumpToMark(sal_Int32 nMark) + throw (IOException, IllegalArgumentException, RuntimeException); + virtual void SAL_CALL jumpToFurthest(void) + throw (IOException, RuntimeException); + virtual sal_Int32 SAL_CALL offsetToMark(sal_Int32 nMark) + throw (IOException, IllegalArgumentException,RuntimeException); + +public: // XActiveDataSink + virtual void SAL_CALL setInputStream(const Reference < XInputStream > & aStream) + throw (RuntimeException); + virtual Reference < XInputStream > SAL_CALL getInputStream(void) + throw (RuntimeException); + +public: // XConnectable + virtual void SAL_CALL setPredecessor(const Reference < XConnectable > & aPredecessor) + throw (RuntimeException); + virtual Reference < XConnectable > SAL_CALL getPredecessor(void) + throw (RuntimeException); + virtual void SAL_CALL setSuccessor(const Reference < XConnectable > & aSuccessor) + throw (RuntimeException); + virtual Reference < XConnectable > SAL_CALL getSuccessor(void) throw (RuntimeException); + +public: // XServiceInfo + OUString SAL_CALL getImplementationName() throw (); + Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw (); + sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw (); + +private: + void checkMarksAndFlush(); + + Reference < XConnectable > m_succ; + Reference < XConnectable > m_pred; + + Reference< XInputStream > m_input; + sal_Bool m_bValidStream; + + IRingBuffer *m_pBuffer; + map<sal_Int32,sal_Int32,less< sal_Int32 > > m_mapMarks; + sal_Int32 m_nCurrentPos; + sal_Int32 m_nCurrentMark; + + Mutex m_mutex; +}; + +OMarkableInputStream::OMarkableInputStream() +{ + g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); + m_nCurrentPos = 0; + m_nCurrentMark = 0; + m_pBuffer = new MemRingBuffer; +} + + +OMarkableInputStream::~OMarkableInputStream() +{ + if( m_pBuffer ) { + delete m_pBuffer; + } + g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); +} + + + + +// XInputStream + +sal_Int32 OMarkableInputStream::readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + sal_Int32 nBytesRead; + + if( m_bValidStream ) { + MutexGuard guard( m_mutex ); + if( m_mapMarks.empty() && ! m_pBuffer->getSize() ) { + // normal read ! + nBytesRead = m_input->readBytes( aData, nBytesToRead ); + } + else { + // read from buffer + sal_Int32 nRead; + + // read enough bytes into buffer + if( m_pBuffer->getSize() - m_nCurrentPos < nBytesToRead ) { + sal_Int32 nToRead = nBytesToRead - ( m_pBuffer->getSize() - m_nCurrentPos ); + nRead = m_input->readBytes( aData , nToRead ); + + OSL_ASSERT( aData.getLength() == nRead ); + + try + { + m_pBuffer->writeAt( m_pBuffer->getSize() , aData ); + } + catch( IRingBuffer_OutOfMemoryException & ) { + throw BufferSizeExceededException(); + } + catch( IRingBuffer_OutOfBoundsException & ) { + throw BufferSizeExceededException(); + } + + if( nRead < nToRead ) { + nBytesToRead = nBytesToRead - (nToRead-nRead); + } + } + + OSL_ASSERT( m_pBuffer->getSize() - m_nCurrentPos >= nBytesToRead ); + + m_pBuffer->readAt( m_nCurrentPos , aData , nBytesToRead ); + + m_nCurrentPos += nBytesToRead; + nBytesRead = nBytesToRead; + } + } + else { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM("MarkableInputStream::readBytes NotConnectedException")) , + *this ); + } + return nBytesRead; +} + + +sal_Int32 OMarkableInputStream::readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + + sal_Int32 nBytesRead; + if( m_bValidStream ) { + MutexGuard guard( m_mutex ); + if( m_mapMarks.empty() && ! m_pBuffer->getSize() ) { + // normal read ! + nBytesRead = m_input->readSomeBytes( aData, nMaxBytesToRead ); + } + else { + // read from buffer + sal_Int32 nRead = 0; + sal_Int32 nInBuffer = m_pBuffer->getSize() - m_nCurrentPos; + sal_Int32 nAdditionalBytesToRead = Min(nMaxBytesToRead-nInBuffer,m_input->available()); + nAdditionalBytesToRead = Max(0 , nAdditionalBytesToRead ); + + // read enough bytes into buffer + if( 0 == nInBuffer ) { + nRead = m_input->readSomeBytes( aData , nMaxBytesToRead ); + } + else if( nAdditionalBytesToRead ) { + nRead = m_input->readBytes( aData , nAdditionalBytesToRead ); + } + + if( nRead ) { + aData.realloc( nRead ); + try + { + m_pBuffer->writeAt( m_pBuffer->getSize() , aData ); + } + catch( IRingBuffer_OutOfMemoryException & ) + { + throw BufferSizeExceededException(); + } + catch( IRingBuffer_OutOfBoundsException & ) + { + throw BufferSizeExceededException(); + } + } + + nBytesRead = Min( nMaxBytesToRead , nInBuffer + nRead ); + + // now take everything from buffer ! + m_pBuffer->readAt( m_nCurrentPos , aData , nBytesRead ); + + m_nCurrentPos += nBytesRead; + } + } + else + { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM("MarkableInputStream::readSomeBytes NotConnectedException")) , + *this ); + } + return nBytesRead; + + +} + + +void OMarkableInputStream::skipBytes(sal_Int32 nBytesToSkip) + throw ( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + if ( nBytesToSkip < 0 ) + throw BufferSizeExceededException( + ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("precondition not met: XInputStream::skipBytes: non-negative integer required!")), + *this + ); + + // this method is blocking + sal_Int32 nRead; + Sequence<sal_Int8> seqDummy( nBytesToSkip ); + + nRead = readBytes( seqDummy , nBytesToSkip ); +} + +sal_Int32 OMarkableInputStream::available(void) throw (NotConnectedException, RuntimeException) +{ + sal_Int32 nAvail; + if( m_bValidStream ) { + MutexGuard guard( m_mutex ); + nAvail = m_input->available() + ( m_pBuffer->getSize() - m_nCurrentPos ); + } + else + { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "MarkableInputStream::available NotConnectedException" ) ) , + *this ); + } + + return nAvail; +} + + +void OMarkableInputStream::closeInput(void) throw (NotConnectedException, RuntimeException) +{ + if( m_bValidStream ) { + MutexGuard guard( m_mutex ); + + m_input->closeInput(); + + setInputStream( Reference< XInputStream > () ); + setPredecessor( Reference< XConnectable > () ); + setSuccessor( Reference< XConnectable >() ); + + delete m_pBuffer; + m_pBuffer = 0; + m_nCurrentPos = 0; + m_nCurrentMark = 0; + } + else { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "MarkableInputStream::closeInput NotConnectedException" ) ) , + *this ); + } +} + +// XMarkable + +sal_Int32 OMarkableInputStream::createMark(void) throw (IOException, RuntimeException) +{ + MutexGuard guard( m_mutex ); + sal_Int32 nMark = m_nCurrentMark; + + m_mapMarks[nMark] = m_nCurrentPos; + + m_nCurrentMark ++; + return nMark; +} + +void OMarkableInputStream::deleteMark(sal_Int32 Mark) throw (IOException, IllegalArgumentException, RuntimeException) +{ + MutexGuard guard( m_mutex ); + map<sal_Int32,sal_Int32,less<sal_Int32> >::iterator ii = m_mapMarks.find( Mark ); + + if( ii == m_mapMarks.end() ) { + OUStringBuffer buf( 128 ); + buf.appendAscii( "MarkableInputStream::deleteMark unknown mark (" ); + buf.append( Mark ); + buf.appendAscii( ")"); + throw IllegalArgumentException( buf.makeStringAndClear(), *this , 0 ); + } + else { + m_mapMarks.erase( ii ); + checkMarksAndFlush(); + } +} + +void OMarkableInputStream::jumpToMark(sal_Int32 nMark) + throw (IOException, + IllegalArgumentException, + RuntimeException) +{ + MutexGuard guard( m_mutex ); + map<sal_Int32,sal_Int32,less<sal_Int32> >::iterator ii = m_mapMarks.find( nMark ); + + if( ii == m_mapMarks.end() ) + { + OUStringBuffer buf( 128 ); + buf.appendAscii( "MarkableInputStream::jumpToMark unknown mark (" ); + buf.append( nMark ); + buf.appendAscii( ")"); + throw IllegalArgumentException( buf.makeStringAndClear(), *this , 0 ); + } + else + { + m_nCurrentPos = (*ii).second; + } +} + +void OMarkableInputStream::jumpToFurthest(void) throw (IOException, RuntimeException) +{ + MutexGuard guard( m_mutex ); + m_nCurrentPos = m_pBuffer->getSize(); + checkMarksAndFlush(); +} + +sal_Int32 OMarkableInputStream::offsetToMark(sal_Int32 nMark) + throw (IOException, + IllegalArgumentException, + RuntimeException) +{ + MutexGuard guard( m_mutex ); + map<sal_Int32,sal_Int32,less<sal_Int32> >::const_iterator ii = m_mapMarks.find( nMark ); + + if( ii == m_mapMarks.end() ) + { + OUStringBuffer buf( 128 ); + buf.appendAscii( "MarkableInputStream::offsetToMark unknown mark (" ); + buf.append( nMark ); + buf.appendAscii( ")"); + throw IllegalArgumentException( buf.makeStringAndClear(), *this , 0 ); + } + return m_nCurrentPos - (*ii).second; +} + + + + + + + +// XActiveDataSource +void OMarkableInputStream::setInputStream(const Reference< XInputStream > & aStream) + throw (RuntimeException) +{ + + if( m_input != aStream ) { + m_input = aStream; + + Reference < XConnectable > pred( m_input , UNO_QUERY ); + setPredecessor( pred ); + } + + m_bValidStream = m_input.is(); + +} + +Reference< XInputStream > OMarkableInputStream::getInputStream(void) throw (RuntimeException) +{ + return m_input; +} + + + +// XDataSink +void OMarkableInputStream::setSuccessor( const Reference< XConnectable > &r ) + throw (RuntimeException) +{ + /// if the references match, nothing needs to be done + if( m_succ != r ) { + /// store the reference for later use + m_succ = r; + + if( m_succ.is() ) { + /// set this instance as the sink ! + m_succ->setPredecessor( Reference< XConnectable > ( + SAL_STATIC_CAST( XConnectable * , this ) ) ); + } + } +} + +Reference < XConnectable > OMarkableInputStream::getSuccessor() throw (RuntimeException) +{ + return m_succ; +} + + +// XDataSource +void OMarkableInputStream::setPredecessor( const Reference < XConnectable > &r ) + throw (RuntimeException) +{ + if( r != m_pred ) { + m_pred = r; + if( m_pred.is() ) { + m_pred->setSuccessor( Reference< XConnectable > ( + SAL_STATIC_CAST( XConnectable * , this ) ) ); + } + } +} +Reference< XConnectable > OMarkableInputStream::getPredecessor() throw (RuntimeException) +{ + return m_pred; +} + + + + +void OMarkableInputStream::checkMarksAndFlush() +{ + map<sal_Int32,sal_Int32,less<sal_Int32> >::iterator ii; + + // find the smallest mark + sal_Int32 nNextFound = m_nCurrentPos; + for( ii = m_mapMarks.begin() ; ii != m_mapMarks.end() ; ii ++ ) { + if( (*ii).second <= nNextFound ) { + nNextFound = (*ii).second; + } + } + + if( nNextFound ) { + // some data must be released ! + m_nCurrentPos -= nNextFound; + for( ii = m_mapMarks.begin() ; ii != m_mapMarks.end() ; ii ++ ) { + (*ii).second -= nNextFound; + } + + m_pBuffer->forgetFromStart( nNextFound ); + + } + else { + // nothing to do. There is a mark or the current cursor position, that prevents + // releasing data ! + } +} + + + +// XServiceInfo +OUString OMarkableInputStream::getImplementationName() throw () +{ + return OMarkableInputStream_getImplementationName(); +} + +// XServiceInfo +sal_Bool OMarkableInputStream::supportsService(const OUString& ServiceName) throw () +{ + Sequence< OUString > aSNL = getSupportedServiceNames(); + const OUString * pArray = aSNL.getConstArray(); + + for( sal_Int32 i = 0; i < aSNL.getLength(); i++ ) + if( pArray[i] == ServiceName ) + return sal_True; + + return sal_False; +} + +// XServiceInfo +Sequence< OUString > OMarkableInputStream::getSupportedServiceNames(void) throw () +{ + return OMarkableInputStream_getSupportedServiceNames(); +} + + +/*------------------------ +* +* external binding +* +*------------------------*/ +Reference < XInterface > SAL_CALL OMarkableInputStream_CreateInstance( + const Reference < XComponentContext > & ) throw(Exception) +{ + OMarkableInputStream *p = new OMarkableInputStream( ); + return Reference< XInterface > ( (OWeakObject * ) p ); +} + +OUString OMarkableInputStream_getImplementationName() +{ + return OUString(RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.io.stm.MarkableInputStream" )); +} + +Sequence<OUString> OMarkableInputStream_getSupportedServiceNames(void) +{ + Sequence<OUString> aRet(1); + aRet.getArray()[0] = OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.io.MarkableInputStream" )); + return aRet; +} + +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/source/stm/opipe.cxx b/io/source/stm/opipe.cxx new file mode 100644 index 000000000000..b17ce4081e0a --- /dev/null +++ b/io/source/stm/opipe.cxx @@ -0,0 +1,494 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * 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. + * + ************************************************************************/ + +// MARKER(update_precomp.py): autogen include statement, do not remove +#include "precompiled_io.hxx" + +// streams +#include <com/sun/star/io/XInputStream.hpp> +#include <com/sun/star/io/XOutputStream.hpp> +#include <com/sun/star/io/XConnectable.hpp> + +#include <com/sun/star/lang/XServiceInfo.hpp> + +#include <cppuhelper/factory.hxx> + +#include <cppuhelper/implbase4.hxx> // OWeakObject + +#include <osl/conditn.hxx> +#include <osl/mutex.hxx> + +#include <limits> +#include <string.h> + +using namespace ::rtl; +using namespace ::osl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::lang; + +#include "factreg.hxx" +#include "streamhelper.hxx" + +// Implementation and service names +#define IMPLEMENTATION_NAME "com.sun.star.comp.io.stm.Pipe" +#define SERVICE_NAME "com.sun.star.io.Pipe" + +namespace io_stm{ + +class OPipeImpl : + public WeakImplHelper4< XInputStream , XOutputStream , XConnectable , XServiceInfo > +{ +public: + OPipeImpl( ); + ~OPipeImpl(); + +public: // XInputStream + virtual sal_Int32 SAL_CALL readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException ); + virtual sal_Int32 SAL_CALL readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException ); + virtual void SAL_CALL skipBytes(sal_Int32 nBytesToSkip) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException ); + virtual sal_Int32 SAL_CALL available(void) + throw( NotConnectedException, + RuntimeException ); + virtual void SAL_CALL closeInput(void) + throw( NotConnectedException, + RuntimeException ); + +public: // XOutputStream + + virtual void SAL_CALL writeBytes(const Sequence< sal_Int8 >& aData) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException ); + virtual void SAL_CALL flush(void) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException ); + virtual void SAL_CALL closeOutput(void) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException ); + +public: // XConnectable + virtual void SAL_CALL setPredecessor(const Reference< XConnectable >& aPredecessor) + throw( RuntimeException ); + virtual Reference< XConnectable > SAL_CALL getPredecessor(void) throw( RuntimeException ); + virtual void SAL_CALL setSuccessor(const Reference < XConnectable > & aSuccessor) + throw( RuntimeException ); + virtual Reference < XConnectable > SAL_CALL getSuccessor(void) throw( RuntimeException ) ; + + +public: // XServiceInfo + OUString SAL_CALL getImplementationName() throw( ); + Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw( ); + sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw( ); + +private: + + // DEBUG + inline void checkInvariant(); + + Reference < XConnectable > m_succ; + Reference < XConnectable > m_pred; + + sal_Int32 m_nBytesToSkip; + + sal_Int8 *m_p; + + sal_Bool m_bOutputStreamClosed; + sal_Bool m_bInputStreamClosed; + + oslCondition m_conditionBytesAvail; + Mutex m_mutexAccess; + I_FIFO *m_pFIFO; +}; + + + +OPipeImpl::OPipeImpl() +{ + g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); + m_nBytesToSkip = 0; + + m_bOutputStreamClosed = sal_False; + m_bInputStreamClosed = sal_False; + + m_pFIFO = new MemFIFO; + m_conditionBytesAvail = osl_createCondition(); +} + +OPipeImpl::~OPipeImpl() +{ + osl_destroyCondition( m_conditionBytesAvail ); + delete m_pFIFO; + g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); +} + + +// These invariants must hold when entering a guarded method or leaving a guarded method. +void OPipeImpl::checkInvariant() +{ + +} + +sal_Int32 OPipeImpl::readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead) + throw( NotConnectedException, BufferSizeExceededException,RuntimeException ) +{ + while( sal_True ) + { + { // start guarded section + MutexGuard guard( m_mutexAccess ); + if( m_bInputStreamClosed ) + { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pipe::readBytes NotConnectedException" )), + *this ); + } + sal_Int32 nOccupiedBufferLen = m_pFIFO->getSize(); + + if( m_bOutputStreamClosed && nBytesToRead > nOccupiedBufferLen ) + { + nBytesToRead = nOccupiedBufferLen; + } + + if( nOccupiedBufferLen < nBytesToRead ) + { + // wait outside guarded section + osl_resetCondition( m_conditionBytesAvail ); + } + else { + // necessary bytes are available + m_pFIFO->read( aData , nBytesToRead ); + return nBytesToRead; + } + } // end guarded section + + // wait for new data outside guarded section! + osl_waitCondition( m_conditionBytesAvail , 0 ); + } +} + + +sal_Int32 OPipeImpl::readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException ) +{ + while( sal_True ) { + { + MutexGuard guard( m_mutexAccess ); + if( m_bInputStreamClosed ) + { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pipe::readSomeBytes NotConnectedException" )), + *this ); + } + if( m_pFIFO->getSize() ) + { + sal_Int32 nSize = Min( nMaxBytesToRead , m_pFIFO->getSize() ); + aData.realloc( nSize ); + m_pFIFO->read( aData , nSize ); + return nSize; + } + + if( m_bOutputStreamClosed ) + { + // no bytes in buffer anymore + return 0; + } + } + + osl_waitCondition( m_conditionBytesAvail , 0 ); + } +} + + +void OPipeImpl::skipBytes(sal_Int32 nBytesToSkip) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException ) +{ + MutexGuard guard( m_mutexAccess ); + if( m_bInputStreamClosed ) + { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pipe::skipBytes NotConnectedException" ) ), + *this ); + } + + if( nBytesToSkip < 0 + || (nBytesToSkip + > std::numeric_limits< sal_Int32 >::max() - m_nBytesToSkip) ) + { + throw BufferSizeExceededException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pipe::skipBytes BufferSizeExceededException" )), + *this ); + } + m_nBytesToSkip += nBytesToSkip; + + nBytesToSkip = Min( m_pFIFO->getSize() , m_nBytesToSkip ); + m_pFIFO->skip( nBytesToSkip ); + m_nBytesToSkip -= nBytesToSkip; +} + + +sal_Int32 OPipeImpl::available(void) + throw( NotConnectedException, + RuntimeException ) + { + MutexGuard guard( m_mutexAccess ); + if( m_bInputStreamClosed ) + { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pipe::available NotConnectedException" ) ), + *this ); + } + checkInvariant(); + return m_pFIFO->getSize(); +} + +void OPipeImpl::closeInput(void) + throw( NotConnectedException, + RuntimeException) +{ + MutexGuard guard( m_mutexAccess ); + + m_bInputStreamClosed = sal_True; + + delete m_pFIFO; + m_pFIFO = 0; + + // readBytes may throw an exception + osl_setCondition( m_conditionBytesAvail ); + + setSuccessor( Reference< XConnectable > () ); + return; +} + + +void OPipeImpl::writeBytes(const Sequence< sal_Int8 >& aData) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + MutexGuard guard( m_mutexAccess ); + checkInvariant(); + + if( m_bOutputStreamClosed ) + { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pipe::writeBytes NotConnectedException (outputstream)" )), + *this ); + } + + if( m_bInputStreamClosed ) + { + throw NotConnectedException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pipe::writeBytes NotConnectedException (inputstream)" )), + *this ); + } + + // check skipping + sal_Int32 nLen = aData.getLength(); + if( m_nBytesToSkip && m_nBytesToSkip >= nLen ) { + // all must be skipped - forget whole call + m_nBytesToSkip -= nLen; + return; + } + + // adjust buffersize if necessary + + try + { + if( m_nBytesToSkip ) + { + Sequence< sal_Int8 > seqCopy( nLen - m_nBytesToSkip ); + memcpy( seqCopy.getArray() , &( aData.getConstArray()[m_nBytesToSkip] ) , nLen-m_nBytesToSkip ); + m_pFIFO->write( seqCopy ); + } + else + { + m_pFIFO->write( aData ); + } + m_nBytesToSkip = 0; + } + catch ( I_FIFO_OutOfBoundsException & ) + { + throw BufferSizeExceededException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pipe::writeBytes BufferSizeExceededException" )), + *this ); + } + catch ( I_FIFO_OutOfMemoryException & ) + { + throw BufferSizeExceededException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pipe::writeBytes BufferSizeExceededException" )), + *this ); + } + + // readBytes may check again if enough bytes are available + osl_setCondition( m_conditionBytesAvail ); + + checkInvariant(); +} + + +void OPipeImpl::flush(void) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + // nothing to do for a pipe + return; +} + +void OPipeImpl::closeOutput(void) + throw( NotConnectedException, + BufferSizeExceededException, + RuntimeException) +{ + MutexGuard guard( m_mutexAccess ); + + m_bOutputStreamClosed = sal_True; + osl_setCondition( m_conditionBytesAvail ); + setPredecessor( Reference < XConnectable > () ); + return; +} + + +void OPipeImpl::setSuccessor( const Reference < XConnectable > &r ) + throw( RuntimeException ) +{ + /// if the references match, nothing needs to be done + if( m_succ != r ) { + /// store the reference for later use + m_succ = r; + + if( m_succ.is() ) + { + m_succ->setPredecessor( + Reference< XConnectable > ( SAL_STATIC_CAST( XConnectable * , this ) ) ); + } + } +} + +Reference < XConnectable > OPipeImpl::getSuccessor() throw( RuntimeException ) +{ + return m_succ; +} + + +// XDataSource +void OPipeImpl::setPredecessor( const Reference < XConnectable > &r ) + throw( RuntimeException ) +{ + if( r != m_pred ) { + m_pred = r; + if( m_pred.is() ) { + m_pred->setSuccessor( + Reference < XConnectable > ( SAL_STATIC_CAST( XConnectable * , this ) ) ); + } + } +} + +Reference < XConnectable > OPipeImpl::getPredecessor() throw( RuntimeException ) +{ + return m_pred; +} + + + + +// XServiceInfo +OUString OPipeImpl::getImplementationName() throw( ) +{ + return OPipeImpl_getImplementationName(); +} + +// XServiceInfo +sal_Bool OPipeImpl::supportsService(const OUString& ServiceName) throw( ) +{ + Sequence< OUString > aSNL = getSupportedServiceNames(); + const OUString * pArray = aSNL.getConstArray(); + + for( sal_Int32 i = 0; i < aSNL.getLength(); i++ ) + if( pArray[i] == ServiceName ) + return sal_True; + + return sal_False; +} + +// XServiceInfo +Sequence< OUString > OPipeImpl::getSupportedServiceNames(void) throw( ) +{ + return OPipeImpl_getSupportedServiceNames(); +} + + + + + +/* implementation functions +* +* +*/ + + +Reference < XInterface > SAL_CALL OPipeImpl_CreateInstance( + const Reference < XComponentContext > & ) throw(Exception) +{ + OPipeImpl *p = new OPipeImpl; + + return Reference < XInterface > ( SAL_STATIC_CAST( OWeakObject * , p ) ); +} + + +OUString OPipeImpl_getImplementationName() +{ + return OUString( RTL_CONSTASCII_USTRINGPARAM ( IMPLEMENTATION_NAME ) ); +} + +Sequence<OUString> OPipeImpl_getSupportedServiceNames(void) +{ + Sequence<OUString> aRet(1); + aRet.getArray()[0] = OUString( RTL_CONSTASCII_USTRINGPARAM( SERVICE_NAME )); + return aRet; +} +} + + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/source/stm/opump.cxx b/io/source/stm/opump.cxx new file mode 100644 index 000000000000..0d20908daae1 --- /dev/null +++ b/io/source/stm/opump.cxx @@ -0,0 +1,506 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * 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. + * + ************************************************************************/ + +// MARKER(update_precomp.py): autogen include statement, do not remove +#include "precompiled_io.hxx" + +#include <stdio.h> + +#include <osl/diagnose.h> + +#include <com/sun/star/io/XActiveDataSource.hpp> +#include <com/sun/star/io/XActiveDataSink.hpp> +#include <com/sun/star/io/XActiveDataControl.hpp> +#include <com/sun/star/io/XConnectable.hpp> +#include <com/sun/star/lang/XSingleServiceFactory.hpp> +#include <com/sun/star/lang/XMultiServiceFactory.hpp> +#include <com/sun/star/lang/XServiceInfo.hpp> +#include <com/sun/star/registry/XRegistryKey.hpp> + +#include <uno/dispatcher.h> +#include <uno/mapping.hxx> +#include <cppuhelper/implbase5.hxx> +#include <cppuhelper/factory.hxx> +#include <cppuhelper/interfacecontainer.hxx> +#include <osl/mutex.hxx> +#include <osl/thread.h> + + +using namespace osl; +using namespace std; +using namespace rtl; +using namespace cppu; +using namespace com::sun::star::uno; +using namespace com::sun::star::lang; +using namespace com::sun::star::registry; +using namespace com::sun::star::io; + +#include "factreg.hxx" + +namespace io_stm { + + class Pump : public WeakImplHelper5< + XActiveDataSource, XActiveDataSink, XActiveDataControl, XConnectable, XServiceInfo > + { + Mutex m_aMutex; + oslThread m_aThread; + + Reference< XConnectable > m_xPred; + Reference< XConnectable > m_xSucc; + Reference< XInputStream > m_xInput; + Reference< XOutputStream > m_xOutput; + OInterfaceContainerHelper m_cnt; + sal_Bool m_closeFired; + + void run(); + static void static_run( void* pObject ); + + void close(); + void fireClose(); + void fireStarted(); + void fireTerminated(); + void fireError( const Any &a ); + + public: + Pump(); + virtual ~Pump(); + + // XActiveDataSource + virtual void SAL_CALL setOutputStream( const Reference< ::com::sun::star::io::XOutputStream >& xOutput ) throw(); + virtual Reference< ::com::sun::star::io::XOutputStream > SAL_CALL getOutputStream() throw(); + + // XActiveDataSink + virtual void SAL_CALL setInputStream( const Reference< ::com::sun::star::io::XInputStream >& xStream ) throw(); + virtual Reference< ::com::sun::star::io::XInputStream > SAL_CALL getInputStream() throw(); + + // XActiveDataControl + virtual void SAL_CALL addListener( const Reference< ::com::sun::star::io::XStreamListener >& xListener ) throw(); + virtual void SAL_CALL removeListener( const Reference< ::com::sun::star::io::XStreamListener >& xListener ) throw(); + virtual void SAL_CALL start() throw( RuntimeException ); + virtual void SAL_CALL terminate() throw(); + + // XConnectable + virtual void SAL_CALL setPredecessor( const Reference< ::com::sun::star::io::XConnectable >& xPred ) throw(); + virtual Reference< ::com::sun::star::io::XConnectable > SAL_CALL getPredecessor() throw(); + virtual void SAL_CALL setSuccessor( const Reference< ::com::sun::star::io::XConnectable >& xSucc ) throw(); + virtual Reference< ::com::sun::star::io::XConnectable > SAL_CALL getSuccessor() throw(); + + public: // XServiceInfo + virtual OUString SAL_CALL getImplementationName() throw( ); + virtual Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw( ); + virtual sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw( ); + }; + +Pump::Pump() : m_aThread( 0 ), + m_cnt( m_aMutex ), + m_closeFired( sal_False ) +{ + g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); +} + +Pump::~Pump() +{ + // exit gracefully + if( m_aThread ) + { + osl_joinWithThread( m_aThread ); + osl_destroyThread( m_aThread ); + } + g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); +} + +void Pump::fireError( const Any & exception ) +{ + OInterfaceIteratorHelper iter( m_cnt ); + while( iter.hasMoreElements() ) + { + try + { + static_cast< XStreamListener * > ( iter.next() )->error( exception ); + } + catch ( RuntimeException &e ) + { + OString sMessage = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + OSL_ENSURE( !"com.sun.star.comp.stoc.Pump: unexpected exception during calling listeners", sMessage.getStr() ); + } + } +} + +void Pump::fireClose() +{ + sal_Bool bFire = sal_False; + { + MutexGuard guard( m_aMutex ); + if( ! m_closeFired ) + { + m_closeFired = sal_True; + bFire = sal_True; + } + } + + if( bFire ) + { + OInterfaceIteratorHelper iter( m_cnt ); + while( iter.hasMoreElements() ) + { + try + { + static_cast< XStreamListener * > ( iter.next() )->closed( ); + } + catch ( RuntimeException &e ) + { + OString sMessage = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + OSL_ENSURE( !"com.sun.star.comp.stoc.Pump: unexpected exception during calling listeners", sMessage.getStr() ); + } + } + } +} + +void Pump::fireStarted() +{ + OInterfaceIteratorHelper iter( m_cnt ); + while( iter.hasMoreElements() ) + { + try + { + static_cast< XStreamListener * > ( iter.next() )->started( ); + } + catch ( RuntimeException &e ) + { + OString sMessage = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + OSL_ENSURE( !"com.sun.star.comp.stoc.Pump: unexpected exception during calling listeners", sMessage.getStr() ); + } + } +} + +void Pump::fireTerminated() +{ + OInterfaceIteratorHelper iter( m_cnt ); + while( iter.hasMoreElements() ) + { + try + { + static_cast< XStreamListener * > ( iter.next() )->terminated(); + } + catch ( RuntimeException &e ) + { + OString sMessage = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + OSL_ENSURE( !"com.sun.star.comp.stoc.Pump: unexpected exception during calling listeners", sMessage.getStr() ); + } + } +} + + + +void Pump::close() +{ + // close streams and release references + Reference< XInputStream > rInput; + Reference< XOutputStream > rOutput; + { + MutexGuard guard( m_aMutex ); + rInput = m_xInput; + m_xInput.clear(); + + rOutput = m_xOutput; + m_xOutput.clear(); + m_xSucc.clear(); + m_xPred.clear(); + } + if( rInput.is() ) + { + try + { + rInput->closeInput(); + } + catch( Exception & ) + { + // go down calm + } + } + if( rOutput.is() ) + { + try + { + rOutput->closeOutput(); + } + catch( Exception & ) + { + // go down calm + } + } +} + +void Pump::static_run( void* pObject ) +{ + ((Pump*)pObject)->run(); + ((Pump*)pObject)->release(); +} + +void Pump::run() +{ + try + { + fireStarted(); + try + { + Reference< XInputStream > rInput; + Reference< XOutputStream > rOutput; + { + Guard< Mutex > aGuard( m_aMutex ); + rInput = m_xInput; + rOutput = m_xOutput; + } + + if( ! rInput.is() ) + { + NotConnectedException exception( + OUString(RTL_CONSTASCII_USTRINGPARAM("no input stream set")) , Reference<XInterface>((OWeakObject*)this) ); + throw exception; + } + Sequence< sal_Int8 > aData; + while( rInput->readSomeBytes( aData, 65536 ) ) + { + if( ! rOutput.is() ) + { + NotConnectedException exception( + OUString(RTL_CONSTASCII_USTRINGPARAM("no output stream set")) , Reference<XInterface>( (OWeakObject*)this) ); + throw exception; + } + rOutput->writeBytes( aData ); + osl_yieldThread(); + } + } + catch ( IOException & e ) + { + fireError( makeAny( e ) ); + } + catch ( RuntimeException & e ) + { + fireError( makeAny( e ) ); + } + catch ( Exception & e ) + { + fireError( makeAny( e ) ); + } + + close(); + fireClose(); + } + catch ( com::sun::star::uno::Exception &e ) + { + // we are the last on the stack. + // this is to avoid crashing the program, when e.g. a bridge crashes + OString sMessage = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + OSL_ENSURE( !"com.sun.star.comp.stoc.Pump: unexpected exception", sMessage.getStr() ); + } +} + +// ------------------------------------------------------------ + +/* + * XConnectable + */ + +void Pump::setPredecessor( const Reference< XConnectable >& xPred ) throw() +{ + Guard< Mutex > aGuard( m_aMutex ); + m_xPred = xPred; +} + +// ------------------------------------------------------------ + +Reference< XConnectable > Pump::getPredecessor() throw() +{ + Guard< Mutex > aGuard( m_aMutex ); + return m_xPred; +} + +// ------------------------------------------------------------ + +void Pump::setSuccessor( const Reference< XConnectable >& xSucc ) throw() +{ + Guard< Mutex > aGuard( m_aMutex ); + m_xSucc = xSucc; +} + +// ------------------------------------------------------------ + +Reference< XConnectable > Pump::getSuccessor() throw() +{ + Guard< Mutex > aGuard( m_aMutex ); + return m_xSucc; +} + +// ----------------------------------------------------------------- + +/* + * XActiveDataControl + */ + +void Pump::addListener( const Reference< XStreamListener >& xListener ) throw() +{ + m_cnt.addInterface( xListener ); +} + +// ------------------------------------------------------------ + +void Pump::removeListener( const Reference< XStreamListener >& xListener ) throw() +{ + m_cnt.removeInterface( xListener ); +} + +// ------------------------------------------------------------ + +void Pump::start() throw( RuntimeException ) +{ + Guard< Mutex > aGuard( m_aMutex ); + m_aThread = osl_createSuspendedThread((oslWorkerFunction)Pump::static_run,this); + if( m_aThread ) + { + // will be released by OPump::static_run + acquire(); + osl_resumeThread( m_aThread ); + } + else + { + throw RuntimeException( + OUString( RTL_CONSTASCII_USTRINGPARAM( "Pump::start Couldn't create worker thread" )), + *this); + } +} + +// ------------------------------------------------------------ + +void Pump::terminate() throw() +{ + close(); + + // wait for the worker to die + if( m_aThread ) + osl_joinWithThread( m_aThread ); + + fireTerminated(); + fireClose(); +} + +// ------------------------------------------------------------ + +/* + * XActiveDataSink + */ + +void Pump::setInputStream( const Reference< XInputStream >& xStream ) throw() +{ + Guard< Mutex > aGuard( m_aMutex ); + m_xInput = xStream; + Reference< XConnectable > xConnect( xStream, UNO_QUERY ); + if( xConnect.is() ) + xConnect->setSuccessor( this ); + // data transfer starts in XActiveDataControl::start +} + +// ------------------------------------------------------------ + +Reference< XInputStream > Pump::getInputStream() throw() +{ + Guard< Mutex > aGuard( m_aMutex ); + return m_xInput; +} + +// ------------------------------------------------------------ + +/* + * XActiveDataSource + */ + +void Pump::setOutputStream( const Reference< XOutputStream >& xOut ) throw() +{ + Guard< Mutex > aGuard( m_aMutex ); + m_xOutput = xOut; + Reference< XConnectable > xConnect( xOut, UNO_QUERY ); + if( xConnect.is() ) + xConnect->setPredecessor( this ); + // data transfer starts in XActiveDataControl::start +} + +// ------------------------------------------------------------ + +Reference< XOutputStream > Pump::getOutputStream() throw() +{ + Guard< Mutex > aGuard( m_aMutex ); + return m_xOutput; +} + + +// XServiceInfo +OUString Pump::getImplementationName() throw( ) +{ + return OPumpImpl_getImplementationName(); +} + +// XServiceInfo +sal_Bool Pump::supportsService(const OUString& ServiceName) throw( ) +{ + Sequence< OUString > aSNL = getSupportedServiceNames(); + const OUString * pArray = aSNL.getConstArray(); + + for( sal_Int32 i = 0; i < aSNL.getLength(); i++ ) + if( pArray[i] == ServiceName ) + return sal_True; + + return sal_False; +} + +// XServiceInfo +Sequence< OUString > Pump::getSupportedServiceNames(void) throw( ) +{ + return OPumpImpl_getSupportedServiceNames(); +} + + +Reference< XInterface > SAL_CALL OPumpImpl_CreateInstance( const Reference< XComponentContext > & ) throw (Exception) +{ + return Reference< XInterface >( *new Pump ); +} + +OUString OPumpImpl_getImplementationName() +{ + return OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.io.Pump") ); +} + +Sequence<OUString> OPumpImpl_getSupportedServiceNames(void) +{ + OUString s( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.io.Pump" ) ); + Sequence< OUString > seq( &s , 1 ); + return seq; +} + +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/source/stm/stm.xml b/io/source/stm/stm.xml new file mode 100644 index 000000000000..64e76dc8d2c7 --- /dev/null +++ b/io/source/stm/stm.xml @@ -0,0 +1,278 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE module-description PUBLIC "-//StarOffice//DTD ComponentDescription 1.0//EN" "module-description.dtd"> +<module-description xmlns:xlink="http://www.w3.org/1999/xlink"> + <module-name> streams.uno </module-name> + + <component-description> + <author> Joerg Budischewski </author> + <name> com.sun.star.comp.io.stm.Pipe </name> + <description> + This component provides ... + </description> + <loader-name> com.sun.star.loader.SharedLibrary </loader-name> + <language> c++ </language> + <status value="final"/> + <supported-service> com.sun.star.io.Pipe </supported-service> + <service-dependency> ... </service-dependency> + <type> com.sun.star.io.XObjectInputStream </type> + <type> com.sun.star.io.XObjectOutputStream </type> + <type> com.sun.star.io.XActiveDataSource </type> + <type> com.sun.star.io.XActiveDataSink </type> + <type> com.sun.star.io.XMarkableStream </type> + <type> com.sun.star.io.UnexpectedEOFException </type> + <type> com.sun.star.io.WrongFormatException </type> + <type> com.sun.star.lang.XComponent </type> + <type> com.sun.star.lang.XMultiServiceFactory </type> + <type> com.sun.star.lang.XSingleServiceFactory </type> + <type> com.sun.star.lang.XServiceInfo </type> + <type> com.sun.star.lang.XTypeProvider </type> + <type> com.sun.star.lang.IllegalArgumentException </type> + <type> com.sun.star.registry.XRegistryKey </type> + <type> com.sun.star.registry.XImplementationRegistration </type> + <type> com.sun.star.test.XSimpleTest </type> + <type> com.sun.star.lang.XSingleComponentFactory </type> + <type> com.sun.star.uno.XComponentContext </type> + <type> com.sun.star.uno.TypeClass </type> + <type> com.sun.star.uno.XWeak </type> + <type> com.sun.star.uno.XAggregation </type> + </component-description> + + <component-description> + <author> Joerg Budischewski </author> + <name> com.sun.star.comp.io.stm.DataInputStream </name> + <description> + This component provides ... + </description> + <loader-name> com.sun.star.loader.SharedLibrary </loader-name> + <language> c++ </language> + <status value="final"/> + <supported-service> com.sun.star.io.DataInputStream </supported-service> + <service-dependency> ... </service-dependency> + <type> com.sun.star.io.XObjectInputStream </type> + <type> com.sun.star.io.XObjectOutputStream </type> + <type> com.sun.star.io.XActiveDataSource </type> + <type> com.sun.star.io.XActiveDataSink </type> + <type> com.sun.star.io.XMarkableStream </type> + <type> com.sun.star.io.UnexpectedEOFException </type> + <type> com.sun.star.io.WrongFormatException </type> + <type> com.sun.star.lang.XComponent </type> + <type> com.sun.star.lang.XMultiServiceFactory </type> + <type> com.sun.star.lang.XSingleServiceFactory </type> + <type> com.sun.star.lang.XServiceInfo </type> + <type> com.sun.star.lang.XTypeProvider </type> + <type> com.sun.star.lang.IllegalArgumentException </type> + <type> com.sun.star.registry.XRegistryKey </type> + <type> com.sun.star.registry.XImplementationRegistration </type> + <type> com.sun.star.test.XSimpleTest </type> + <type> com.sun.star.uno.TypeClass </type> + <type> com.sun.star.uno.XWeak </type> + <type> com.sun.star.uno.XAggregation </type> + </component-description> + + <component-description> + <author> Joerg Budischewski </author> + <name> com.sun.star.comp.io.stm.DataOutputStream </name> + <description> + This component provides ... + </description> + <loader-name> com.sun.star.loader.SharedLibrary </loader-name> + <language> c++ </language> + <status value="final"/> + <supported-service> com.sun.star.io.DataOutputStream </supported-service> + <service-dependency> ... </service-dependency> + <type> com.sun.star.io.XObjectInputStream </type> + <type> com.sun.star.io.XObjectOutputStream </type> + <type> com.sun.star.io.XActiveDataSource </type> + <type> com.sun.star.io.XActiveDataSink </type> + <type> com.sun.star.io.XMarkableStream </type> + <type> com.sun.star.io.UnexpectedEOFException </type> + <type> com.sun.star.io.WrongFormatException </type> + <type> com.sun.star.lang.XComponent </type> + <type> com.sun.star.lang.XMultiServiceFactory </type> + <type> com.sun.star.lang.XSingleServiceFactory </type> + <type> com.sun.star.lang.XServiceInfo </type> + <type> com.sun.star.lang.XTypeProvider </type> + <type> com.sun.star.lang.IllegalArgumentException </type> + <type> com.sun.star.registry.XRegistryKey </type> + <type> com.sun.star.registry.XImplementationRegistration </type> + <type> com.sun.star.test.XSimpleTest </type> + <type> com.sun.star.lang.XSingleComponentFactory </type> + <type> com.sun.star.uno.XComponentContext </type> + <type> com.sun.star.uno.TypeClass </type> + <type> com.sun.star.uno.XWeak </type> + <type> com.sun.star.uno.XAggregation </type> + </component-description> + + <component-description> + <author> Joerg Budischewski </author> + <name> com.sun.star.comp.io.stm.ObjectInputStream </name> + <description> + This component provides ... + </description> + <loader-name> com.sun.star.loader.SharedLibrary </loader-name> + <language> c++ </language> + <status value="final"/> + <supported-service> com.sun.star.io.ObjectInputStream </supported-service> + <service-dependency> ... </service-dependency> + <type> com.sun.star.io.XObjectInputStream </type> + <type> com.sun.star.io.XObjectOutputStream </type> + <type> com.sun.star.io.XActiveDataSource </type> + <type> com.sun.star.io.XActiveDataSink </type> + <type> com.sun.star.io.XMarkableStream </type> + <type> com.sun.star.io.UnexpectedEOFException </type> + <type> com.sun.star.io.WrongFormatException </type> + <type> com.sun.star.lang.XComponent </type> + <type> com.sun.star.lang.XMultiServiceFactory </type> + <type> com.sun.star.lang.XSingleServiceFactory </type> + <type> com.sun.star.lang.XServiceInfo </type> + <type> com.sun.star.lang.XTypeProvider </type> + <type> com.sun.star.lang.IllegalArgumentException </type> + <type> com.sun.star.registry.XRegistryKey </type> + <type> com.sun.star.registry.XImplementationRegistration </type> + <type> com.sun.star.test.XSimpleTest </type> + <type> com.sun.star.lang.XSingleComponentFactory </type> + <type> com.sun.star.uno.XComponentContext </type> + <type> com.sun.star.uno.TypeClass </type> + <type> com.sun.star.uno.XWeak </type> + <type> com.sun.star.uno.XAggregation </type> + </component-description> + + <component-description> + <author> Joerg Budischewski </author> + <name> com.sun.star.comp.io.stm.ObjectOutputStream </name> + <description> + This component provides ... + </description> + <loader-name> com.sun.star.loader.SharedLibrary </loader-name> + <language> c++ </language> + <status value="final"/> + <supported-service> com.sun.star.io.ObjectOutputStream </supported-service> + <service-dependency> ... </service-dependency> + <type> com.sun.star.io.XObjectInputStream </type> + <type> com.sun.star.io.XObjectOutputStream </type> + <type> com.sun.star.io.XActiveDataSource </type> + <type> com.sun.star.io.XActiveDataSink </type> + <type> com.sun.star.io.XMarkableStream </type> + <type> com.sun.star.io.UnexpectedEOFException </type> + <type> com.sun.star.io.WrongFormatException </type> + <type> com.sun.star.lang.XComponent </type> + <type> com.sun.star.lang.XMultiServiceFactory </type> + <type> com.sun.star.lang.XSingleServiceFactory </type> + <type> com.sun.star.lang.XServiceInfo </type> + <type> com.sun.star.lang.XTypeProvider </type> + <type> com.sun.star.lang.IllegalArgumentException </type> + <type> com.sun.star.registry.XRegistryKey </type> + <type> com.sun.star.registry.XImplementationRegistration </type> + <type> com.sun.star.test.XSimpleTest </type> + <type> com.sun.star.lang.XSingleComponentFactory </type> + <type> com.sun.star.uno.XComponentContext </type> + <type> com.sun.star.uno.TypeClass </type> + <type> com.sun.star.uno.XWeak </type> + <type> com.sun.star.uno.XAggregation </type> + </component-description> + + <component-description> + <author> Joerg Budischewski </author> + <name> com.sun.star.comp.io.stm.MarkableInputStream </name> + <description> + This component provides ... + </description> + <loader-name> com.sun.star.loader.SharedLibrary </loader-name> + <language> c++ </language> + <status value="final"/> + <supported-service> com.sun.star.io.MarkableInputStream </supported-service> + <service-dependency> ... </service-dependency> + <type> com.sun.star.io.XObjectInputStream </type> + <type> com.sun.star.io.XObjectOutputStream </type> + <type> com.sun.star.io.XActiveDataSource </type> + <type> com.sun.star.io.XActiveDataSink </type> + <type> com.sun.star.io.XMarkableStream </type> + <type> com.sun.star.io.UnexpectedEOFException </type> + <type> com.sun.star.io.WrongFormatException </type> + <type> com.sun.star.lang.XComponent </type> + <type> com.sun.star.lang.XMultiServiceFactory </type> + <type> com.sun.star.lang.XSingleServiceFactory </type> + <type> com.sun.star.lang.XServiceInfo </type> + <type> com.sun.star.lang.XTypeProvider </type> + <type> com.sun.star.lang.IllegalArgumentException </type> + <type> com.sun.star.registry.XRegistryKey </type> + <type> com.sun.star.registry.XImplementationRegistration </type> + <type> com.sun.star.test.XSimpleTest </type> + <type> com.sun.star.lang.XSingleComponentFactory </type> + <type> com.sun.star.uno.XComponentContext </type> + <type> com.sun.star.uno.TypeClass </type> + <type> com.sun.star.uno.XWeak </type> + <type> com.sun.star.uno.XAggregation </type> + </component-description> + + <component-description> + <author> Joerg Budischewski </author> + <name> com.sun.star.comp.io.stm.MarkableOutputStream </name> + <description> + This component provides ... + </description> + <loader-name> com.sun.star.loader.SharedLibrary </loader-name> + <language> c++ </language> + <status value="final"/> + <supported-service> com.sun.star.io.MarkableOutputStream </supported-service> + <service-dependency> ... </service-dependency> + <type> com.sun.star.io.XObjectInputStream </type> + <type> com.sun.star.io.XObjectOutputStream </type> + <type> com.sun.star.io.XActiveDataSource </type> + <type> com.sun.star.io.XActiveDataSink </type> + <type> com.sun.star.io.XMarkableStream </type> + <type> com.sun.star.io.UnexpectedEOFException </type> + <type> com.sun.star.io.WrongFormatException </type> + <type> com.sun.star.lang.XComponent </type> + <type> com.sun.star.lang.XMultiServiceFactory </type> + <type> com.sun.star.lang.XSingleServiceFactory </type> + <type> com.sun.star.lang.XServiceInfo </type> + <type> com.sun.star.lang.XTypeProvider </type> + <type> com.sun.star.lang.IllegalArgumentException </type> + <type> com.sun.star.registry.XRegistryKey </type> + <type> com.sun.star.registry.XImplementationRegistration </type> + <type> com.sun.star.test.XSimpleTest </type> + <type> com.sun.star.lang.XSingleComponentFactory </type> + <type> com.sun.star.uno.XComponentContext </type> + <type> com.sun.star.uno.TypeClass </type> + <type> com.sun.star.uno.XWeak </type> + <type> com.sun.star.uno.XAggregation </type> + </component-description> + + <component-description> + <author> Joerg Budischewski </author> + <name> com.sun.star.comp.stoc.Pump </name> + <description> + This component provides ... + </description> + <loader-name> com.sun.star.loader.SharedLibrary </loader-name> + <language> c++ </language> + <status value="final"/> + <supported-service> com.sun.star.io.Pump </supported-service> + <service-dependency> ... </service-dependency> + <type> com.sun.star.io.XConnectable </type> + <type> com.sun.star.io.XActiveDataSource </type> + <type> com.sun.star.io.XActiveDataSink </type> + <type> com.sun.star.io.XActiveDataControl </type> + <type> com.sun.star.lang.DisposedException </type> + <type> com.sun.star.lang.XTypeProvider </type> + <type> com.sun.star.lang.XServiceInfo </type> + <type> com.sun.star.lang.XSingleServiceFactory </type> + <type> com.sun.star.lang.XMultiServiceFactory </type> + <type> com.sun.star.registry.XRegistryKey </type> + <type> com.sun.star.lang.XSingleComponentFactory </type> + <type> com.sun.star.uno.XComponentContext </type> + <type> com.sun.star.uno.XAggregation </type> + <type> com.sun.star.uno.XWeak </type> + <type> com.sun.star.uno.TypeClass </type> + </component-description> + + <project-build-dependency> cppuhelper </project-build-dependency> + <project-build-dependency> cppu </project-build-dependency> + <project-build-dependency> sal </project-build-dependency> + + <runtime-module-dependency> cppuhelper </runtime-module-dependency> + <runtime-module-dependency> cppu2 </runtime-module-dependency> + <runtime-module-dependency> sal2 </runtime-module-dependency> +</module-description> + diff --git a/io/source/stm/streamhelper.cxx b/io/source/stm/streamhelper.cxx new file mode 100644 index 000000000000..8791c016db7d --- /dev/null +++ b/io/source/stm/streamhelper.cxx @@ -0,0 +1,247 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * 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. + * + ************************************************************************/ + +// MARKER(update_precomp.py): autogen include statement, do not remove +#include "precompiled_io.hxx" +#include <rtl/alloc.h> + +#include <limits> +#include <string.h> + +#include <com/sun/star/uno/Sequence.hxx> + +#include <com/sun/star/uno/Exception.hpp> + +using namespace ::com::sun::star::uno; + +#include "streamhelper.hxx" + +namespace io_stm { + +void MemFIFO::write( const Sequence< sal_Int8 > &seq ) + throw ( I_FIFO_OutOfMemoryException, + I_FIFO_OutOfBoundsException ) +{ + try + { + writeAt(getSize(), seq ); + } + catch( IRingBuffer_OutOfMemoryException & ) + { + throw I_FIFO_OutOfMemoryException(); + } + catch( IRingBuffer_OutOfBoundsException & ) + { + throw I_FIFO_OutOfBoundsException(); + } +} + +void MemFIFO::read( Sequence<sal_Int8> &seq , sal_Int32 nBufferLen ) throw (I_FIFO_OutOfBoundsException) +{ + try + { + readAt(0, seq , nBufferLen); + forgetFromStart( nBufferLen ); + } + catch ( IRingBuffer_OutOfBoundsException & ) + { + throw I_FIFO_OutOfBoundsException(); + } +} + +void MemFIFO::skip( sal_Int32 nBytesToSkip ) throw ( I_FIFO_OutOfBoundsException ) +{ + try + { + forgetFromStart( nBytesToSkip ); + } + catch( IRingBuffer_OutOfBoundsException & ) + { + throw I_FIFO_OutOfBoundsException(); + } +} + + + +MemRingBuffer::MemRingBuffer() +{ + m_nBufferLen = 0; + m_p = 0; + m_nStart = 0; + m_nOccupiedBuffer = 0; +} + +MemRingBuffer::~MemRingBuffer() +{ + if( m_p ) { + rtl_freeMemory( m_p ); + } +} + +void MemRingBuffer::resizeBuffer( sal_Int32 nMinSize ) throw( IRingBuffer_OutOfMemoryException) +{ + sal_Int32 nNewLen = 1; + + while( nMinSize > nNewLen ) { + nNewLen = nNewLen << 1; + } + + // buffer never shrinks ! + if( nNewLen < m_nBufferLen ) { + nNewLen = m_nBufferLen; + } + + if( nNewLen != m_nBufferLen ) { + m_p = ( sal_Int8 * ) rtl_reallocateMemory( m_p , nNewLen ); + if( !m_p ) { + throw IRingBuffer_OutOfMemoryException(); + } + + if( m_nStart + m_nOccupiedBuffer > m_nBufferLen ) { + memmove( &( m_p[m_nStart+(nNewLen-m_nBufferLen)]) , &(m_p[m_nStart]) , m_nBufferLen - m_nStart ); + m_nStart += nNewLen - m_nBufferLen; + } + m_nBufferLen = nNewLen; + } +} + + +void MemRingBuffer::readAt( sal_Int32 nPos, Sequence<sal_Int8> &seq , sal_Int32 nBytesToRead ) const + throw(IRingBuffer_OutOfBoundsException) +{ + if( nPos + nBytesToRead > m_nOccupiedBuffer ) { + throw IRingBuffer_OutOfBoundsException(); + } + + sal_Int32 nStartReadingPos = nPos + m_nStart; + if( nStartReadingPos >= m_nBufferLen ) { + nStartReadingPos -= m_nBufferLen; + } + + seq.realloc( nBytesToRead ); + + if( nStartReadingPos + nBytesToRead > m_nBufferLen ) { + sal_Int32 nDeltaLen = m_nBufferLen - nStartReadingPos; + memcpy( seq.getArray() , &(m_p[nStartReadingPos]) , nDeltaLen ); + memcpy( &(seq.getArray()[nDeltaLen]), m_p , nBytesToRead - nDeltaLen ); + } + else { + memcpy( seq.getArray() , &(m_p[nStartReadingPos]) , nBytesToRead ); + } +} + + +void MemRingBuffer::writeAt( sal_Int32 nPos, const Sequence<sal_Int8> &seq ) + throw (IRingBuffer_OutOfBoundsException, + IRingBuffer_OutOfMemoryException ) +{ + checkInvariants(); + sal_Int32 nLen = seq.getLength(); + + if( nPos < 0 || nPos > std::numeric_limits< sal_Int32 >::max() - nLen ) + { + throw IRingBuffer_OutOfBoundsException(); + } + + if( nPos + nLen - m_nOccupiedBuffer > 0 ) { + resizeBuffer( nPos + seq.getLength() ); + } + + sal_Int32 nStartWritingIndex = m_nStart + nPos; + if( nStartWritingIndex >= m_nBufferLen ) { + nStartWritingIndex -= m_nBufferLen; + } + + if( nLen + nStartWritingIndex > m_nBufferLen ) { + // two area copy + memcpy( &(m_p[nStartWritingIndex]) , seq.getConstArray(), m_nBufferLen-nStartWritingIndex ); + memcpy( m_p , &( seq.getConstArray()[m_nBufferLen-nStartWritingIndex] ), + nLen - (m_nBufferLen-nStartWritingIndex) ); + + } + else { + // one area copy + memcpy( &( m_p[nStartWritingIndex]), seq.getConstArray() , nLen ); + } + m_nOccupiedBuffer = Max( nPos + seq.getLength() , m_nOccupiedBuffer ); + checkInvariants(); +} + + +sal_Int32 MemRingBuffer::getSize() const throw() +{ + return m_nOccupiedBuffer; +} + +void MemRingBuffer::forgetFromStart( sal_Int32 nBytesToForget ) throw (IRingBuffer_OutOfBoundsException) +{ + checkInvariants(); + if( nBytesToForget > m_nOccupiedBuffer ) { + throw IRingBuffer_OutOfBoundsException(); + } + m_nStart += nBytesToForget; + if( m_nStart >= m_nBufferLen ) { + m_nStart = m_nStart - m_nBufferLen; + } + m_nOccupiedBuffer -= nBytesToForget; + checkInvariants(); +} + + +void MemRingBuffer::forgetFromEnd( sal_Int32 nBytesToForget ) throw (IRingBuffer_OutOfBoundsException) +{ + checkInvariants(); + if( nBytesToForget > m_nOccupiedBuffer ) { + throw IRingBuffer_OutOfBoundsException(); + } + m_nOccupiedBuffer -= nBytesToForget; + checkInvariants(); +} + + +void MemRingBuffer::shrink() throw () +{ + checkInvariants(); + + // Up to now, only shrinking of while buffer works. + // No other shrinking supported up to now. + if( ! m_nOccupiedBuffer ) { + if( m_p ) { + free( m_p ); + } + m_p = 0; + m_nBufferLen = 0; + m_nStart = 0; + } + + checkInvariants(); +} + +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/source/stm/streamhelper.hxx b/io/source/stm/streamhelper.hxx new file mode 100644 index 000000000000..6a792732d4ef --- /dev/null +++ b/io/source/stm/streamhelper.hxx @@ -0,0 +1,165 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * 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. + * + ************************************************************************/ + +// Save NDEBUG state +#ifdef NDEBUG +#define STREAMHELPER_HXX_HAD_NDEBUG +#undef NDEBUG +#endif + +#if OSL_DEBUG_LEVEL == 0 +#define NDEBUG +#endif +#include <assert.h> + +#define Max( a, b ) (((a)>(b)) ? (a) : (b) ) +#define Min( a, b ) (((a)<(b)) ? (a) : (b) ) + +namespace io_stm { + +class I_FIFO_OutOfBoundsException : + public Exception +{}; + +class I_FIFO_OutOfMemoryException : + public Exception +{}; + +class I_FIFO +{ +public: + + + virtual void write( const Sequence<sal_Int8> &) throw( I_FIFO_OutOfMemoryException, + I_FIFO_OutOfBoundsException )=0; + + virtual void read( Sequence<sal_Int8> & , sal_Int32 nBytesToRead ) + throw( I_FIFO_OutOfBoundsException )=0; + virtual void skip( sal_Int32 nBytesToSkip ) + throw( I_FIFO_OutOfBoundsException )=0; + virtual sal_Int32 getSize() const throw( ) =0; + virtual void shrink() throw() = 0; + + virtual ~I_FIFO() {}; +}; + + +class IRingBuffer_OutOfBoundsException : + public Exception +{}; + +class IRingBuffer_OutOfMemoryException : + public Exception +{}; + +class IRingBuffer +{ +public: + /*** + * overwrites data at given position. Size is automatically extended, when + * data is written beyond end. + * + ***/ + + virtual void writeAt( sal_Int32 nPos, const Sequence<sal_Int8> &) + throw( IRingBuffer_OutOfMemoryException, + IRingBuffer_OutOfBoundsException )=0; + virtual void readAt( sal_Int32 nPos, Sequence<sal_Int8> & , sal_Int32 nBytesToRead ) const + throw( IRingBuffer_OutOfBoundsException )=0; + virtual sal_Int32 getSize() const throw( ) =0; + virtual void forgetFromStart( sal_Int32 nBytesToForget ) throw(IRingBuffer_OutOfBoundsException)=0; + virtual void forgetFromEnd( sal_Int32 nBytesToForget ) throw(IRingBuffer_OutOfBoundsException)=0; + virtual void shrink() throw() = 0; + virtual ~IRingBuffer() {}; +}; + + +class MemRingBuffer : + public IRingBuffer +{ +public: + MemRingBuffer(); + virtual ~MemRingBuffer(); + + virtual void writeAt( sal_Int32 nPos, const Sequence<sal_Int8> &) + throw( IRingBuffer_OutOfMemoryException, + IRingBuffer_OutOfBoundsException ); + virtual void readAt( sal_Int32 nPos, Sequence<sal_Int8> & , sal_Int32 nBytesToRead ) const + throw( IRingBuffer_OutOfBoundsException ); + virtual sal_Int32 getSize() const throw( ); + virtual void forgetFromStart( sal_Int32 nBytesToForget ) throw(IRingBuffer_OutOfBoundsException); + virtual void forgetFromEnd( sal_Int32 nBytesToForget ) throw(IRingBuffer_OutOfBoundsException); + + virtual void shrink() throw(); + +private: + + void resizeBuffer( sal_Int32 nMinSize ) throw( IRingBuffer_OutOfMemoryException ); + inline void checkInvariants() + { + assert( m_nBufferLen >= 0 ); + assert( m_nOccupiedBuffer >= 0 ); + assert( m_nOccupiedBuffer <= m_nBufferLen ); + assert( m_nStart >= 0 ); + assert( 0 == m_nStart || m_nStart < m_nBufferLen ); + } + + sal_Int8 *m_p; + sal_Int32 m_nBufferLen; + sal_Int32 m_nStart; + sal_Int32 m_nOccupiedBuffer; +}; + + +class MemFIFO : + public I_FIFO, + private MemRingBuffer +{ +public: + virtual void write( const Sequence<sal_Int8> &) throw( I_FIFO_OutOfMemoryException, + I_FIFO_OutOfBoundsException ); + virtual void read( Sequence<sal_Int8> & , sal_Int32 nBytesToRead ) + throw( I_FIFO_OutOfBoundsException ); + virtual void skip( sal_Int32 nBytesToSkip ) throw( I_FIFO_OutOfBoundsException ); + virtual sal_Int32 getSize() const throw( ) + { return MemRingBuffer::getSize(); } + virtual void shrink() throw() + { MemRingBuffer::shrink(); } + +}; + +// Restore NDEBUG state +#ifdef STREAMHELPER_HXX_HAD_NDEBUG +#define NDEBUG +#else +#undef NDEBUG +#endif + +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ |