diff options
Diffstat (limited to 'io/test')
| -rw-r--r-- | io/test/makefile.mk | 83 | ||||
| -rw-r--r-- | io/test/stm/datatest.cxx | 1071 | ||||
| -rw-r--r-- | io/test/stm/exports.dxp | 2 | ||||
| -rw-r--r-- | io/test/stm/makefile.mk | 89 | ||||
| -rw-r--r-- | io/test/stm/marktest.cxx | 642 | ||||
| -rw-r--r-- | io/test/stm/pipetest.cxx | 416 | ||||
| -rw-r--r-- | io/test/stm/pumptest.cxx | 430 | ||||
| -rw-r--r-- | io/test/stm/testfactreg.cxx | 199 | ||||
| -rw-r--r-- | io/test/stm/testfactreg.hxx | 107 | ||||
| -rw-r--r-- | io/test/testcomponent.cxx | 206 | ||||
| -rw-r--r-- | io/test/testconnection.cxx | 257 |
11 files changed, 3502 insertions, 0 deletions
diff --git a/io/test/makefile.mk b/io/test/makefile.mk new file mode 100644 index 0000000000..c1d2c96498 --- /dev/null +++ b/io/test/makefile.mk @@ -0,0 +1,83 @@ +# +# This file is part of the LibreOffice project. +# +# This Source Code Form is subject to the terms of the Mozilla Public +# License, v. 2.0. If a copy of the MPL was not distributed with this +# file, You can obtain one at http://mozilla.org/MPL/2.0/. +# +# This file incorporates work covered by the following license notice: +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed +# with this work for additional information regarding copyright +# ownership. The ASF licenses this file to you under the Apache +# License, Version 2.0 (the "License"); you may not use this file +# except in compliance with the License. You may obtain a copy of +# the License at http://www.apache.org/licenses/LICENSE-2.0 . +# + +PRJ=.. + +PRJNAME=extensions +TARGET=workben +LIBTARGET=NO + +TARGETTYPE=CUI +ENABLE_EXCEPTIONS=TRUE + +# --- Settings ----------------------------------------------------- + +.INCLUDE : settings.mk +.IF "$(L10N_framework)"=="" +# --- Files -------------------------------------------------------- + +OBJFILES= $(OBJ)$/testcomponent.obj \ + $(OBJ)$/testconnection.obj + +UNOUCRDEP=$(SOLARBINDIR)$/udkapi.rdb +UNOUCRRDB=$(SOLARBINDIR)$/udkapi.rdb + +# output directory (one dir for each project) +UNOUCROUT=$(OUT)$/inc + +UNOTYPES = com.sun.star.connection.XConnector \ + com.sun.star.connection.XAcceptor \ + com.sun.star.registry.XImplementationRegistration \ + com.sun.star.lang.XComponent \ + com.sun.star.lang.XSingleServiceFactory \ + com.sun.star.lang.XMultiServiceFactory \ + com.sun.star.test.XSimpleTest \ + com.sun.star.lang.XSingleComponentFactory \ + com.sun.star.lang.XMultiComponentFactory + + +# +# std testcomponent +# + +APP1TARGET = testcomponent +APP1OBJS = $(OBJ)$/testcomponent.obj +APP1STDLIBS = $(SALLIB) \ + $(CPPULIB)\ + $(CPPUHELPERLIB) + +APP2TARGET = testconnection +APP2OBJS = $(OBJ)$/testconnection.obj +APP2STDLIBS = $(SALLIB) \ + $(CPPULIB) \ + $(CPPUHELPERLIB) + + + +# --- Targets ------------------------------------------------------ + +ALL : $(BIN)$/applicat.rdb \ + ALLTAR + +$(BIN)$/applicat.rdb: $(SOLARBINDIR)$/udkapi.rdb + rm -f $@ + regmerge $@ / $? + +.ENDIF # L10N_framework + +.INCLUDE : target.mk diff --git a/io/test/stm/datatest.cxx b/io/test/stm/datatest.cxx new file mode 100644 index 0000000000..ef31f099d4 --- /dev/null +++ b/io/test/stm/datatest.cxx @@ -0,0 +1,1071 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* + * This file is part of the LibreOffice project. + * + * This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. + * + * This file incorporates work covered by the following license notice: + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed + * with this work for additional information regarding copyright + * ownership. The ASF licenses this file to you under the Apache + * License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of + * the License at http://www.apache.org/licenses/LICENSE-2.0 . + */ + +#include <stdio.h> + +#include <com/sun/star/test/XSimpleTest.hpp> +#include <com/sun/star/io/XActiveDataSink.hpp> +#include <com/sun/star/io/XActiveDataSource.hpp> +#include <com/sun/star/io/XObjectInputStream.hpp> +#include <com/sun/star/io/XObjectOutputStream.hpp> +#include <com/sun/star/io/XMarkableStream.hpp> +#include <com/sun/star/io/XConnectable.hpp> +#include <com/sun/star/beans/XPropertySet.hpp> +#include <com/sun/star/lang/WrappedTargetException.hpp> +#include <com/sun/star/lang/IllegalArgumentException.hpp> +#include <com/sun/star/lang/XServiceInfo.hpp> + +#include <cppuhelper/factory.hxx> +#include <cppuhelper/implbase.hxx> + +#include <osl/conditn.hxx> + +#include <string.h> + +using namespace ::osl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::test; +using namespace ::com::sun::star::beans; +// streams + +#include "testfactreg.hxx" + +#define DATASTREAM_TEST_MAX_HANDLE 1 + +/* + * The following test class tests XDataInputStream and XDataOutputStream at equal terms, + * so when errors occur, it may be in either one implementation. + * The class also uses com.sun.star.io.pipe. If problems occur, make sure to run also the + * pipe test routines ( test.com.sun.star.io.pipe ). + */ + +class ODataStreamTest : + public WeakImplHelper< XSimpleTest > +{ +public: + explicit ODataStreamTest( const Reference < XMultiServiceFactory > & rFactory ) : + m_rFactory( rFactory ) + {} + +public: + virtual void SAL_CALL testInvariant(const OUString& TestName, const Reference < XInterface >& TestObject) + throw ( IllegalArgumentException, + RuntimeException); + + virtual sal_Int32 SAL_CALL test( const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, + RuntimeException); + + virtual sal_Bool SAL_CALL testPassed() throw ( RuntimeException); + virtual Sequence< OUString > SAL_CALL getErrors() throw (RuntimeException); + virtual Sequence< Any > SAL_CALL getErrorExceptions() throw (RuntimeException); + virtual Sequence< OUString > SAL_CALL getWarnings() throw (RuntimeException); + +private: + void testSimple( const Reference < XDataInputStream > & , const Reference < XDataOutputStream > &); + +protected: + Sequence<Any> m_seqExceptions; + Sequence<OUString> m_seqErrors; + Sequence<OUString> m_seqWarnings; + + Reference < XMultiServiceFactory > m_rFactory; +}; + + +void ODataStreamTest::testInvariant( + const OUString& TestName, + const Reference < XInterface >& TestObject ) + throw ( IllegalArgumentException, + RuntimeException) +{ + if( OUString("com.sun.star.io.DataInputStream") == TestName ) { + Reference < XConnectable > connect( TestObject , UNO_QUERY ); + Reference < XActiveDataSink > active( TestObject , UNO_QUERY ); + Reference < XInputStream > input( TestObject , UNO_QUERY ); + Reference < XDataInputStream > dataInput( TestObject , UNO_QUERY ); + + WARNING_ASSERT( connect.is(), "XConnectable cannot be queried" ); + WARNING_ASSERT( active.is() , "XActiveDataSink cannot be queried" ); + ERROR_ASSERT( input.is() , "XInputStream cannot be queried" ); + ERROR_ASSERT( dataInput.is() , "XDataInputStream cannot be queried" ); + + + } + else if( OUString("com.sun.star.io.DataOutputStream") == TestName ) { + Reference < XConnectable > connect( TestObject , UNO_QUERY ); + Reference < XActiveDataSource > active( TestObject , UNO_QUERY ); + Reference < XOutputStream > output( TestObject , UNO_QUERY ); + Reference < XDataOutputStream > dataOutput( TestObject , UNO_QUERY ); + + WARNING_ASSERT( connect.is(), "XConnectable cannot be queried" ); + WARNING_ASSERT( active.is() , "XActiveDataSink cannot be queried" ); + ERROR_ASSERT( output.is() , "XInputStream cannot be queried" ); + ERROR_ASSERT( dataOutput.is(), "XDataInputStream cannot be queried" ); + + } + + Reference < XServiceInfo > info( TestObject, UNO_QUERY ); + ERROR_ASSERT( info.is() , "XServiceInfo not supported !" ); + if( info.is() ) + { + ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" ); + ERROR_ASSERT( ! info->supportsService("bla bluzb") , "XServiceInfo test failed" ); + } + +} + + +sal_Int32 ODataStreamTest::test( + const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, + RuntimeException) +{ + if( OUString("com.sun.star.io.DataInputStream") == TestName || + OUString("com.sun.star.io.DataOutputStream") == TestName ) { + + try + { + if( 0 == hTestHandle ) { + testInvariant( TestName , TestObject ); + } + else { + Reference <XActiveDataSink > rSink( TestObject, UNO_QUERY ); + Reference <XActiveDataSource > rSource( TestObject , UNO_QUERY ); + + Reference < XDataInputStream > rInput( TestObject , UNO_QUERY ); + Reference < XDataOutputStream > rOutput( TestObject , UNO_QUERY ); + + + Reference < XInterface > x = m_rFactory->createInstance( + "com.sun.star.io.Pipe" ); + + Reference < XInputStream > rPipeInput( x , UNO_QUERY ); + Reference < XOutputStream > rPipeOutput( x , UNO_QUERY ); + + if( ! rSink.is() ) { + x = m_rFactory->createInstance( + "com.sun.star.io.DataInputStream" ); + rInput.set( x , UNO_QUERY); + rSink.set( x , UNO_QUERY ); + } + else if ( !rSource.is() ) + { + x = m_rFactory->createInstance( + "com.sun.star.io.DataOutputStream" ); + rOutput.set( x , UNO_QUERY ); + rSource.set( x, UNO_QUERY ); + } + + OSL_ASSERT( rPipeInput.is() ); + OSL_ASSERT( rPipeOutput.is() ); + rSink->setInputStream( rPipeInput ); + rSource->setOutputStream( rPipeOutput ); + + OSL_ASSERT( rSink->getInputStream().is() ); + OSL_ASSERT( rSource->getOutputStream().is() ); + + if( 1 == hTestHandle ) { + testSimple( rInput , rOutput ); + } + } + } + catch( const Exception & e ) + { + OString o = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + BUILD_ERROR( 0 , o.getStr() ); + } + catch( ... ) + { + BUILD_ERROR( 0 , "unknown exception (Exception is not base class)" ); + } + + hTestHandle ++; + + if( hTestHandle >= 2) { + // all tests finished. + hTestHandle = -1; + } + } + else { + BUILD_ERROR( 0 , "service not supported by test." ); + } + return hTestHandle; +} + + +sal_Bool ODataStreamTest::testPassed() throw (RuntimeException) +{ + return m_seqErrors.getLength() == 0; +} + + +Sequence< OUString > ODataStreamTest::getErrors() throw (RuntimeException) +{ + return m_seqErrors; +} + + +Sequence< Any > ODataStreamTest::getErrorExceptions() throw (RuntimeException) +{ + return m_seqExceptions; +} + + +Sequence< OUString > ODataStreamTest::getWarnings() throw (RuntimeException) +{ + return m_seqWarnings; +} + +void ODataStreamTest::testSimple( const Reference < XDataInputStream > &rInput, + const Reference < XDataOutputStream > &rOutput ) +{ + rOutput->writeLong( 0x34ff3c ); + rOutput->writeLong( 0x34ff3d ); + rOutput->writeLong( -1027 ); + + ERROR_ASSERT( 0x34ff3c == rInput->readLong() , "long read/write mismatch" ); + ERROR_ASSERT( 0x34ff3d == rInput->readLong() , "long read/write mismatch" ); + ERROR_ASSERT( -1027 == rInput->readLong() , "long read/write mismatch" ); + + rOutput->writeByte( 0x77 ); + ERROR_ASSERT( 0x77 == rInput->readByte() , "byte read/write mismatch" ); + + rOutput->writeBoolean( 25 ); + ERROR_ASSERT( rInput->readBoolean() , "boolean read/write mismatch" ); + + rOutput->writeBoolean( sal_False ); + ERROR_ASSERT( ! rInput->readBoolean() , "boolean read/write mismatch" ); + + rOutput->writeFloat( (float) 42.42 ); + ERROR_ASSERT( rInput->readFloat() == ((float)42.42) , "float read/write mismatch" ); + + rOutput->writeDouble( (double) 42.42 ); + ERROR_ASSERT( rInput->readDouble() == 42.42 , "double read/write mismatch" ); + + rOutput->writeHyper( 0x123456789abcdefLL ); + ERROR_ASSERT( rInput->readHyper() == 0x123456789abcdefLL , "int64 read/write mismatch" ); + + rOutput->writeUTF( OUString("Live long and prosper !") ); + ERROR_ASSERT( rInput->readUTF() == "Live long and prosper !", + "UTF read/write mismatch" ); + + Sequence<sal_Unicode> wc(0x10001); + for( int i = 0 ; i < 0x10000 ; i ++ ) { + wc.getArray()[i] = L'c'; + } + wc.getArray()[0x10000] = 0; + OUString str( wc.getArray() , 0x10000 ); + rOutput->writeUTF( str ); + ERROR_ASSERT( rInput->readUTF() == str , "error reading 64k block" ); + + rOutput->closeOutput(); + try + { + rInput->readLong(); + ERROR_ASSERT( 0 , "eof-exception does not occur !" ); + } + catch ( IOException & ) + { + //ok + } + catch( ... ) + { + ERROR_ASSERT( 0 , "wrong exception after reading beyond eof" ); + } + + Sequence<sal_Int8> dummy (1); + ERROR_ASSERT( ! rInput->readBytes( dummy , 1 ), + "stream must be on eof !" ); + + rInput->closeInput(); + + try + { + rOutput->writeByte( 1 ); + ERROR_ASSERT( 0 , "writing still possible though chain must be interrupted" ); + } + catch( IOException & ) + { + // ok + } + catch( ... ) { + ERROR_ASSERT( 0 , "IOException expected, but another exception was thrown" ); + } + +} + + +/** +* for external binding +* +* +**/ +Reference < XInterface > SAL_CALL ODataStreamTest_CreateInstance( const Reference < XMultiServiceFactory > & rSMgr ) throw(Exception) +{ + return getXWeak(new ODataStreamTest( rSMgr )); +} + +Sequence<OUString> ODataStreamTest_getSupportedServiceNames( int i) throw () +{ + Sequence<OUString> aRet { ODataStreamTest_getImplementationName( i) }; + return aRet; +} + +OUString ODataStreamTest_getServiceName( int i) throw () +{ + if( 1 == i ) { + return OUString( "test.com.sun.star.io.DataInputStream" ); + } + else { + return OUString( "test.com.sun.star.io.DataOutputStream" ); + } +} + +OUString ODataStreamTest_getImplementationName( int i) throw () +{ + if( 1 == i ) { + return OUString( + "test.com.sun.star.comp.extensions.stm.DataInputStream" ); + } + else { + return OUString( "test.com.sun.star.comp.extensions.stm.DataOutputStream" ); + } +} + +class MyPersistObject : public WeakImplHelper< XPersistObject , XPropertySet > +{ +public: + MyPersistObject( ) : m_sServiceName( OMyPersistObject_getServiceName() ) , + m_l( -392 ), + m_f( 7883.2 ), + m_d( -123923.5 ), + m_b( sal_True ), + m_byte( 42 ), + m_c( 429 ), + m_s( OUString( "foo" ) ) + {} + explicit MyPersistObject( const OUString & sServiceName ) : m_sServiceName( sServiceName ) + {} + + +public: + virtual OUString SAL_CALL getServiceName() throw (RuntimeException); + virtual void SAL_CALL write( const Reference< XObjectOutputStream >& OutStream ) + throw (IOException, RuntimeException); + virtual void SAL_CALL read(const Reference< XObjectInputStream >& InStream) + throw (IOException, RuntimeException); + +public: + + virtual Reference< XPropertySetInfo > SAL_CALL getPropertySetInfo() + throw (RuntimeException); + + virtual void SAL_CALL setPropertyValue(const OUString& aPropertyName, const Any& aValue) + throw ( UnknownPropertyException, + PropertyVetoException, + IllegalArgumentException, + WrappedTargetException, + RuntimeException); + virtual Any SAL_CALL getPropertyValue(const OUString& PropertyName) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException); + virtual void SAL_CALL addPropertyChangeListener( + const OUString& aPropertyName, + const Reference < XPropertyChangeListener > & xListener) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException); + + virtual void SAL_CALL removePropertyChangeListener( + const OUString& aPropertyName, + const Reference< XPropertyChangeListener > & aListener) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException); + virtual void SAL_CALL addVetoableChangeListener( + const OUString& PropertyName, + const Reference< XVetoableChangeListener > & aListener) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException); + + virtual void SAL_CALL removeVetoableChangeListener( + const OUString& PropertyName, + const Reference< XVetoableChangeListener >& aListener) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException); + +public: + sal_Int32 m_l; + float m_f; + double m_d; + sal_Bool m_b; + sal_Int8 m_byte; + sal_Unicode m_c; + OUString m_s; + Reference< XPersistObject > m_ref; + OUString m_sServiceName; +}; + + +Reference <XPropertySetInfo > MyPersistObject::getPropertySetInfo() + throw (RuntimeException) +{ + return Reference< XPropertySetInfo >(); +} + +void MyPersistObject::setPropertyValue( + const OUString& aPropertyName, + const Any& aValue) + throw ( UnknownPropertyException, + PropertyVetoException, + IllegalArgumentException, + WrappedTargetException, + RuntimeException) +{ + if( aPropertyName.equalsAscii("long") ) { + aValue >>= m_l; + } + else if ( aPropertyName.equalsAscii("float") ) { + aValue >>= m_f; + } + else if( aPropertyName.equalsAscii("double") ) { + aValue >>= m_d; + } + else if( aPropertyName.equalsAscii("bool") ) { + aValue >>= m_b; + } + else if( aPropertyName.equalsAscii("byte" ) ) { + aValue >>= m_byte; + } + else if( aPropertyName.equalsAscii("char") ) { + aValue >>= m_c; + } + else if( aPropertyName.equalsAscii("string") ) { + aValue >>= m_s; + } + else if( aPropertyName.equalsAscii("object") ) { + if( aValue.getValueType() == cppu::UnoType<XPersistObject>::get()) + { + aValue >>= m_ref; + } + else + { + m_ref = 0; + } + } +} + + +Any MyPersistObject::getPropertyValue(const OUString& aPropertyName) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException) +{ + Any aValue; + if( aPropertyName.equalsAscii("long" ) ) { + aValue <<= m_l; + } + else if ( aPropertyName.equalsAscii("float") ) { + aValue <<= m_f; + } + else if( aPropertyName.equalsAscii("double") ) { + aValue <<= m_d; + } + else if( aPropertyName.equalsAscii("bool") ) { + aValue <<= m_b; + } + else if( aPropertyName.equalsAscii("byte") ) { + aValue <<= m_byte; + } + else if( aPropertyName.equalsAscii("char" ) ) { + aValue <<= m_c; + } + else if( aPropertyName.equalsAscii("string") ) { + aValue <<= m_s; + } + else if( aPropertyName.equalsAscii("object" ) ) + { + aValue <<= m_ref; + } + return aValue; +} + + +void MyPersistObject::addPropertyChangeListener( + const OUString& aPropertyName, + const Reference< XPropertyChangeListener > & xListener) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException) +{ + +} + +void MyPersistObject::removePropertyChangeListener( + const OUString& aPropertyName, + const Reference < XPropertyChangeListener > & aListener) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException) +{ +} + + +void MyPersistObject::addVetoableChangeListener( + const OUString& PropertyName, + const Reference <XVetoableChangeListener >& aListener) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException) +{ + +} + +void MyPersistObject::removeVetoableChangeListener( + const OUString& PropertyName, + const Reference < XVetoableChangeListener > & aListener) + throw ( UnknownPropertyException, + WrappedTargetException, + RuntimeException) +{ + +} + + +OUString MyPersistObject::getServiceName() throw (RuntimeException) +{ + return m_sServiceName; +} + +void MyPersistObject::write( const Reference< XObjectOutputStream > & rOut ) + throw (IOException,RuntimeException) +{ + rOut->writeLong( m_l); + rOut->writeFloat( m_f ); + rOut->writeDouble( m_d ); + rOut->writeBoolean( m_b ); + rOut->writeByte( m_byte ); + rOut->writeChar( m_c ); + rOut->writeUTF( m_s ); + rOut->writeObject( m_ref ); +} + + +void MyPersistObject::read( const Reference< XObjectInputStream > & rIn ) + throw (IOException, RuntimeException) +{ + m_l = rIn->readLong(); + m_f = rIn->readFloat(); + m_d = rIn->readDouble(); + m_b = rIn->readBoolean(); + m_byte = rIn->readByte(); + m_c = rIn->readChar(); + m_s = rIn->readUTF(); + m_ref = rIn->readObject(); +} + +Reference < XInterface > SAL_CALL OMyPersistObject_CreateInstance( + const Reference < XMultiServiceFactory > & rSMgr ) + throw(Exception) +{ + return getXWeak(new MyPersistObject( )); +} + +Sequence<OUString> OMyPersistObject_getSupportedServiceNames( ) throw () +{ + Sequence<OUString> aRet { OMyPersistObject_getImplementationName() }; + return aRet; +} + +OUString OMyPersistObject_getServiceName( ) throw () +{ + return OUString( "test.com.sun.star.io.PersistTest" ); +} + +OUString OMyPersistObject_getImplementationName( ) throw () +{ + return OUString( "test.com.sun.star.io.PersistTest" ); +} + +class OObjectStreamTest : + public ODataStreamTest +{ +public: + explicit OObjectStreamTest( const Reference < XMultiServiceFactory > &r) : ODataStreamTest(r) {} + +public: + virtual void SAL_CALL testInvariant(const OUString& TestName, + const Reference < XInterface >& TestObject) + throw ( IllegalArgumentException, + RuntimeException); + + virtual sal_Int32 SAL_CALL test( + const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, + RuntimeException); + + +private: + void testObject( const Reference <XObjectOutputStream > &rOut, + const Reference <XObjectInputStream> &rIn ); + +private: +}; + + +void OObjectStreamTest::testInvariant( const OUString& TestName, + const Reference < XInterface >& TestObject ) + throw ( IllegalArgumentException, RuntimeException) +{ + + if( OUString( "com.sun.star.io.ObjectInputStream" ) + == TestName ) + { + ODataStreamTest::testInvariant( TestName , TestObject ); + Reference< XObjectInputStream > dataInput( TestObject , UNO_QUERY ); + Reference< XMarkableStream > markable( TestObject , UNO_QUERY ); + ERROR_ASSERT( dataInput.is() , "XObjectInputStream cannot be queried" ); + ERROR_ASSERT( markable.is() , "XMarkableStream cannot be queried" ); + } + else if( OUString( "com.sun.star.io.ObjectOutputStream" ) + == TestName ) + { + ODataStreamTest::testInvariant( TestName , TestObject ); + Reference < XMarkableStream > markable( TestObject , UNO_QUERY ); + Reference < XObjectOutputStream > dataOutput( TestObject , UNO_QUERY ); + ERROR_ASSERT( dataOutput.is(), "XObjectOutputStream cannot be queried" ); + ERROR_ASSERT( markable.is() , "XMarkableStream cannot be queried" ); + } + + Reference < XServiceInfo > info( TestObject, UNO_QUERY ); + ERROR_ASSERT( info.is() , "XServiceInfo not supported !" ); + if( info.is() ) + { + ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" ); + ERROR_ASSERT( ! info->supportsService("bla bluzb") , "XServiceInfo test failed" ); + } + +} + +sal_Int32 OObjectStreamTest::test( const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, + RuntimeException) +{ + if( TestName.equalsAscii("com.sun.star.io.ObjectInputStream") || + TestName.equalsAscii("com.sun.star.io.ObjectOutputStream") ) { + + try + { + if( 0 == hTestHandle ) { + testInvariant( TestName , TestObject ); + } + else if( DATASTREAM_TEST_MAX_HANDLE >= hTestHandle ) { + sal_Int32 hOldHandle = hTestHandle; + hTestHandle = ODataStreamTest::test( + OUString( "com.sun.star.io.DataInputStream" ), + TestObject , hTestHandle ); + if( hTestHandle == -1 ){ + hTestHandle = hOldHandle; + } + } + else { + + Reference<XActiveDataSink > rSink( TestObject, UNO_QUERY ); + Reference<XActiveDataSource > rSource( TestObject , UNO_QUERY ); + + Reference< XObjectInputStream > rInput( TestObject , UNO_QUERY ); + Reference< XObjectOutputStream > rOutput( TestObject , UNO_QUERY ); + + + Reference < XInterface > x = m_rFactory->createInstance( + "com.sun.star.io.Pipe" ); + + Reference <XInputStream > rPipeInput( x , UNO_QUERY ); + Reference <XOutputStream > rPipeOutput( x , UNO_QUERY ); + + x = m_rFactory->createInstance( + "com.sun.star.io.MarkableInputStream" ); + + Reference <XInputStream > markableInput( x , UNO_QUERY ); + Reference <XActiveDataSink> markableSink( x , UNO_QUERY ); + + x = m_rFactory->createInstance( "com.sun.star.io.MarkableOutputStream" ); + Reference <XOutputStream > markableOutput( x , UNO_QUERY ); + Reference <XActiveDataSource > markableSource( x , UNO_QUERY ); + + OSL_ASSERT( markableInput.is() ); + OSL_ASSERT( markableOutput.is() ); + OSL_ASSERT( markableSink.is() ); + OSL_ASSERT( markableSource.is() ); + + markableSink->setInputStream( rPipeInput ); + markableSource->setOutputStream( rPipeOutput ); + + if( ! rSink.is() ) { + x = m_rFactory->createInstance( + "com.sun.star.io.ObjectInputStream" ); + rInput.set( x , UNO_QUERY ); + rSink.set( x , UNO_QUERY ); + } + else if ( !rSource.is() ) { + x = m_rFactory->createInstance( + "com.sun.star.io.ObjectOutputStream" ); + rOutput.set( x , UNO_QUERY ); + rSource.set( x, UNO_QUERY ); + } + + OSL_ASSERT( rPipeInput.is() ); + OSL_ASSERT( rPipeOutput.is() ); + + rSink->setInputStream( markableInput ); + rSource->setOutputStream( markableOutput ); + + OSL_ASSERT( rSink->getInputStream().is() ); + OSL_ASSERT( rSource->getOutputStream().is() ); + + if( 1 + DATASTREAM_TEST_MAX_HANDLE == hTestHandle ) { + testObject( rOutput , rInput); + } + rInput->closeInput(); + rOutput->closeOutput(); + + } + } + catch( const Exception &e ) { + OString o = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + BUILD_ERROR( 0 , o.getStr() ); + } + catch( ... ) { + BUILD_ERROR( 0 , "unknown exception (Exception is not base class)" ); + } + + hTestHandle ++; + + if( hTestHandle > 1 +DATASTREAM_TEST_MAX_HANDLE ) { + // all tests finished. + hTestHandle = -1; + } + } + else { + BUILD_ERROR( 0 , "service not supported by test." ); + } + return hTestHandle; +} + + +sal_Bool compareMyPropertySet( Reference< XPropertySet > &r1 , Reference < XPropertySet > &r2 ) +{ + sal_Bool b = sal_True; + + if( r1->getPropertyValue("long").getValueType() == cppu::UnoType<void>::get() || + r2->getPropertyValue("long").getValueType() == cppu::UnoType<void>::get() ) { + + // one of the objects is not the correct propertyset ! + fprintf( stderr, "compareMyPropertySet: 1\n" ); + return sal_False; + } + + b = b && ( r1->getPropertyValue("long") == + r2->getPropertyValue("long") ); + if( ! b ) fprintf( stderr, "compareMyPropertySet: 2\n" ); + + b = b && ( r1->getPropertyValue("float") == + r2->getPropertyValue("float") ); + if( ! b ){ + float f1(0.0); + float f2(0.0); + r1->getPropertyValue("float") >>= f1; + r2->getPropertyValue("float") >>= f2; + fprintf( stderr, "compareMyPropertySet: %f %f 3\n",f1,f2 ); + } + + b = b && ( r1->getPropertyValue("double") == + r2->getPropertyValue("double") ); + if( ! b ) fprintf( stderr, "compareMyPropertySet: 4\n" ); + + sal_Bool b1(sal_False), b2(sal_False); + Any a =r1->getPropertyValue("bool"); + a >>= b1; + a = r2->getPropertyValue("bool"); + a >>= b2; + b = b && ( (b1 && b2) || b1 == b2 ); + if( ! b ) fprintf( stderr, "compareMyPropertySet: 5\n" ); + +// b = b && r1->getPropertyValue("bool") == +// r2->getPropertyValue("bool") ); + + b = b && ( r1->getPropertyValue("byte") == + r2->getPropertyValue("byte") ); + if( ! b ) fprintf( stderr, "compareMyPropertySet: 6\n" ); + + b = b && ( r1->getPropertyValue("char") == + r2->getPropertyValue("char") ); + if( ! b ) fprintf( stderr, "compareMyPropertySet: 7\n" ); + + b = b && ( r1->getPropertyValue("string") == + r2->getPropertyValue("string")); + if( ! b ) fprintf( stderr, "compareMyPropertySet: 8\n" ); + + Any o1 = r1->getPropertyValue("object"); + Any o2 = r2->getPropertyValue("object"); + + if( o1.getValueType() == cppu::UnoType<XPersistObject>::get()) { + + if( o2.getValueType() == cppu::UnoType<XPersistObject>::get()) { + Reference < XPersistObject > rPersist1; + Reference < XPersistObject > rPersist2; + o1 >>= rPersist1; + o2 >>= rPersist2; + Reference <XPropertySet > rProp1( rPersist1 , UNO_QUERY ); + Reference < XPropertySet > rProp2( rPersist2 , UNO_QUERY ); + + if( rProp1.is() && rProp2.is() && ! ( rProp1 == rProp2 ) + &&( rProp1 != r1 )) { + b = b && compareMyPropertySet( rProp1 , rProp2 ); + } + } + else { + b = sal_False; + } + if( ! b ) fprintf( stderr, "compareMyPropertySet: 9\n" ); + } + else { + if( o2.getValueType() == cppu::UnoType<XPersistObject>::get()) { + b = sal_False; + } + if( ! b ) fprintf( stderr, "compareMyPropertySet: 10\n" ); + } + + return b; +} + +void OObjectStreamTest::testObject( const Reference< XObjectOutputStream > &rOut, + const Reference < XObjectInputStream > &rIn ) +{ + ERROR_ASSERT( rOut.is() , "no objectOutputStream" ); + ERROR_ASSERT( rIn.is() , "no objectInputStream" ); + + + // tests, if saving an object with an unknown service name allows + // reading the data behind the object ! + { + Reference < XInterface > x = * new MyPersistObject( + OUString( "bla blubs") ); + + Reference< XPersistObject > persistRef( x , UNO_QUERY ); + ERROR_ASSERT( persistRef.is() , "couldn't instantiate PersistTest object" ); + + rOut->writeObject( persistRef ); + rOut->writeLong( (sal_Int32) 0xdeadbeef ); + + ERROR_ASSERT( 0 != rIn->available() , "no data arrived at input" ); + + try + { + Reference <XPersistObject > xReadPersistRef = rIn->readObject(); + ERROR_ASSERT( 0 , "expected exception not thrown" ); + } + catch( IOException & ) + { + // all is ok + } + + ERROR_ASSERT( (sal_Int32) 0xdeadbeef == rIn->readLong() , + "wrong data after object with unknown service name." ); + } + + { + Reference < XInterface > x = m_rFactory->createInstance( + "test.com.sun.star.io.PersistTest"); + Reference< XPersistObject > persistRef( x , UNO_QUERY ); + + ERROR_ASSERT( persistRef.is() , "couldn't instantiate PersistTest object" ); + + Reference < XPropertySet > rProp( persistRef , UNO_QUERY ); + ERROR_ASSERT( rProp.is() , "test object is no property set " ); + + Any any; + sal_Int32 i = 0x83482; + any <<= i; + rProp->setPropertyValue("long", any ); + + float f = (float)42.23; + any <<= f; + rProp->setPropertyValue("float", any ); + + double d = 233.321412; + any <<= d; + rProp->setPropertyValue("double", any ); + + sal_Bool b = sal_True; + any.setValue( &b , cppu::UnoType<bool>::get() ); + rProp->setPropertyValue("bool", any ); + + sal_Int8 by = 120; + any <<= by; + rProp->setPropertyValue("byte", any ); + + sal_Unicode c = 'h'; + any.setValue( &c , cppu::UnoType<cppu::UnoCharType>::get() ); + rProp->setPropertyValue("char", any ); + + OUString str( "hi du !" ); + any <<= str; + rProp->setPropertyValue("string", any ); + + any <<= persistRef; + rProp->setPropertyValue("object", any ); + + // do read and write + rOut->writeObject( persistRef ); + ERROR_ASSERT( 0 != rIn->available() , "no data arrived at input" ); + Reference< XPersistObject > xReadPersist = rIn->readObject( ); + + Reference< XPropertySet > rPropRead( xReadPersist , UNO_QUERY ); + ERROR_ASSERT( compareMyPropertySet( rProp , rPropRead ) , "objects has not been read properly !" ); + + // destroy selfreferences + rProp->setPropertyValue("object", Any() ); + rPropRead->setPropertyValue("object", Any() ); + } + + { + Reference< XMarkableStream > markableOut( rOut , UNO_QUERY ); + ERROR_ASSERT( markableOut.is() , "markable stream cannot be queried" ); + + // do the same thing multiple times to check if + // buffering and marks work correctly + for( int i = 0 ; i < 2000 ; i ++ ) { + + Reference < XInterface > x = m_rFactory->createInstance("test.com.sun.star.io.PersistTest"); + Reference< XPersistObject > persistRef( x , UNO_QUERY ); + + Reference < XPropertySet > rProp( persistRef , UNO_QUERY ); + ERROR_ASSERT( rProp.is() , "test object is no property set " ); + + Any any; + sal_Int32 i = 0x83482; + any <<= i; + rProp->setPropertyValue("long", any ); + + float f = 42.23; + any <<= f; + rProp->setPropertyValue("float", any ); + + double d = 233.321412; + any <<= d; + rProp->setPropertyValue("double", any ); + + sal_Bool b = sal_True; + any.setValue( &b , cppu::UnoType<bool>::get() ); + rProp->setPropertyValue("bool", any ); + + sal_Int8 by = 120; + any <<= by; + rProp->setPropertyValue("byte", any ); + + sal_Unicode c = 'h'; + any.setValue( &c , cppu::UnoType<cppu::UnoCharType>::get() ); + rProp->setPropertyValue("char", any ); + + OUString str( "hi du !" ); + any <<= str; + rProp->setPropertyValue("string", any ); + + x = m_rFactory->createInstance("test.com.sun.star.io.PersistTest"); + Reference <XPersistObject > persist2ndRef( x , UNO_QUERY ); + + // Note : persist2ndRef contains coincident values, but also coincident values must be + // saved properly ! + any <<= persist2ndRef; + rProp->setPropertyValue("object", any ); + + // simply test, if markable operations and object operations do not interfere + sal_Int32 nMark = markableOut->createMark(); + + // do read and write + rOut->writeObject( persistRef ); + + // further markable tests ! + sal_Int32 nOffset = markableOut->offsetToMark( nMark ); + markableOut->jumpToMark( nMark ); + markableOut->deleteMark( nMark ); + markableOut->jumpToFurthest(); + + + ERROR_ASSERT( 0 != rIn->available() , "no data arrived at input" ); + Reference < XPersistObject > xReadPersistRef = rIn->readObject( ); + + Reference< XPropertySet > rProp1( persistRef , UNO_QUERY ); + Reference< XPropertySet > rProp2( xReadPersistRef , UNO_QUERY ); + ERROR_ASSERT( compareMyPropertySet( rProp1, rProp2) , + "objects has not been read properly !" ); + } + } +} + + +Reference < XInterface > SAL_CALL OObjectStreamTest_CreateInstance( const Reference < XMultiServiceFactory > & rSMgr ) throw(Exception) +{ + return getXWeak(new OObjectStreamTest( rSMgr )); +} + +Sequence<OUString> OObjectStreamTest_getSupportedServiceNames( int i) throw () +{ + Sequence<OUString> aRet { OObjectStreamTest_getImplementationName( i) }; + return aRet; +} + +OUString OObjectStreamTest_getServiceName( int i) throw () +{ + if( 1 == i ) { + return OUString( "test.com.sun.star.io.ObjectInputStream" ); + } + else { + return OUString( "test.com.sun.star.io.ObjectOutputStream"); + } +} + +OUString OObjectStreamTest_getImplementationName( int i) throw () +{ + if( 1 == i ) { + return OUString( "test.com.sun.star.comp.extensions.stm.ObjectInputStream" ); + } + else { + return OUString( "test.com.sun.star.comp.extensions.stm.ObjectOutputStream"); + } +} + + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/test/stm/exports.dxp b/io/test/stm/exports.dxp new file mode 100644 index 0000000000..86214860d5 --- /dev/null +++ b/io/test/stm/exports.dxp @@ -0,0 +1,2 @@ +component_getFactory +component_writeInfo diff --git a/io/test/stm/makefile.mk b/io/test/stm/makefile.mk new file mode 100644 index 0000000000..1a7eaad0e7 --- /dev/null +++ b/io/test/stm/makefile.mk @@ -0,0 +1,89 @@ +# +# This file is part of the LibreOffice project. +# +# This Source Code Form is subject to the terms of the Mozilla Public +# License, v. 2.0. If a copy of the MPL was not distributed with this +# file, You can obtain one at http://mozilla.org/MPL/2.0/. +# +# This file incorporates work covered by the following license notice: +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed +# with this work for additional information regarding copyright +# ownership. The ASF licenses this file to you under the Apache +# License, Version 2.0 (the "License"); you may not use this file +# except in compliance with the License. You may obtain a copy of +# the License at http://www.apache.org/licenses/LICENSE-2.0 . +# +PRJ=..$/.. + +PRJNAME=io +TARGET=teststm +ENABLE_EXCEPTIONS=TRUE + +# --- Settings ----------------------------------------------------- +.INCLUDE : settings.mk +.IF "$(L10N_framework)"=="" +# --- Files -------------------------------------------------------- +UNOUCRDEP=$(SOLARBINDIR)$/udkapi.rdb +UNOUCRRDB=$(SOLARBINDIR)$/udkapi.rdb + +# output directory (one dir for each project) +UNOUCROUT=$(OUT)$/inc + +UNOTYPES = com.sun.star.test.XSimpleTest \ + com.sun.star.beans.XPropertySet \ + com.sun.star.io.UnexpectedEOFException \ + com.sun.star.io.WrongFormatException \ + com.sun.star.io.XActiveDataControl \ + com.sun.star.io.XActiveDataSink \ + com.sun.star.io.XActiveDataSource \ + com.sun.star.io.XConnectable \ + com.sun.star.io.XMarkableStream \ + com.sun.star.io.XObjectInputStream \ + com.sun.star.io.XObjectOutputStream \ + com.sun.star.lang.IllegalArgumentException \ + com.sun.star.lang.XComponent \ + com.sun.star.lang.XMultiServiceFactory \ + com.sun.star.lang.XServiceInfo \ + com.sun.star.lang.XSingleServiceFactory \ + com.sun.star.lang.XSingleComponentFactory \ + com.sun.star.lang.XMultiComponentFactory \ + com.sun.star.uno.XComponentContext \ + com.sun.star.lang.XTypeProvider \ + com.sun.star.registry.XImplementationRegistration \ + com.sun.star.registry.XRegistryKey \ + com.sun.star.test.XSimpleTest \ + com.sun.star.uno.TypeClass \ + com.sun.star.uno.XAggregation \ + com.sun.star.uno.XWeak + +SLOFILES= \ + $(SLO)$/testfactreg.obj \ + $(SLO)$/pipetest.obj \ + $(SLO)$/datatest.obj \ + $(SLO)$/marktest.obj \ + $(SLO)$/pumptest.obj + +SHL1TARGET= $(TARGET) + +SHL1STDLIBS= \ + $(SALLIB) \ + $(CPPULIB) \ + $(CPPUHELPERLIB) + +SHL1LIBS= $(SLB)$/$(TARGET).lib + +SHL1IMPLIB= i$(TARGET) + +SHL1DEPN= makefile.mk $(SHL1LIBS) +SHL1DEF= $(MISC)$/$(SHL1TARGET).def + +DEF1NAME= $(SHL1TARGET) +DEF1EXPORTFILE= exports.dxp + + +# --- Targets ------------------------------------------------------ +.ENDIF # L10N_framework + +.INCLUDE : target.mk diff --git a/io/test/stm/marktest.cxx b/io/test/stm/marktest.cxx new file mode 100644 index 0000000000..0dd01a7f77 --- /dev/null +++ b/io/test/stm/marktest.cxx @@ -0,0 +1,642 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* + * This file is part of the LibreOffice project. + * + * This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. + * + * This file incorporates work covered by the following license notice: + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed + * with this work for additional information regarding copyright + * ownership. The ASF licenses this file to you under the Apache + * License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of + * the License at http://www.apache.org/licenses/LICENSE-2.0 . + */ + +#include <com/sun/star/test/XSimpleTest.hpp> +#include <com/sun/star/io/XActiveDataSink.hpp> +#include <com/sun/star/io/XActiveDataSource.hpp> +#include <com/sun/star/io/XMarkableStream.hpp> +#include <com/sun/star/io/XConnectable.hpp> + +#include <com/sun/star/lang/XServiceInfo.hpp> + +#include <cppuhelper/factory.hxx> +#include <cppuhelper/implbase.hxx> + +#include <osl/conditn.hxx> + +using namespace ::osl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::test; +// streams + +#include "testfactreg.hxx" + + +class OMarkableOutputStreamTest : public WeakImplHelper< XSimpleTest > +{ +public: + explicit OMarkableOutputStreamTest( const Reference< XMultiServiceFactory > & rFactory ); + ~OMarkableOutputStreamTest(); + +public: // implementation names + static Sequence< OUString > getSupportedServiceNames_Static() throw (); + static OUString getImplementationName_Static() throw (); + +public: + virtual void SAL_CALL testInvariant( + const OUString& TestName, + const Reference < XInterface >& TestObject) + throw ( IllegalArgumentException, + RuntimeException) ; + + virtual sal_Int32 SAL_CALL test( const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, RuntimeException); + virtual sal_Bool SAL_CALL testPassed() + throw ( RuntimeException); + virtual Sequence< OUString > SAL_CALL getErrors() + throw (RuntimeException); + virtual Sequence< Any > SAL_CALL getErrorExceptions() + throw (RuntimeException); + virtual Sequence< OUString > SAL_CALL getWarnings() + throw (RuntimeException); + +private: + void testSimple( const Reference< XOutputStream > &r, const Reference < XInputStream > &rInput ); + +private: + Sequence<Any> m_seqExceptions; + Sequence<OUString> m_seqErrors; + Sequence<OUString> m_seqWarnings; + Reference< XMultiServiceFactory > m_rFactory; + +}; + +OMarkableOutputStreamTest::OMarkableOutputStreamTest( const Reference< XMultiServiceFactory > &rFactory ) + : m_rFactory( rFactory ) +{ + +} + +OMarkableOutputStreamTest::~OMarkableOutputStreamTest() +{ + +} + + +void OMarkableOutputStreamTest::testInvariant( const OUString& TestName, + const Reference < XInterface >& TestObject ) + throw ( IllegalArgumentException, RuntimeException) +{ + Reference< XServiceInfo > info( TestObject, UNO_QUERY ); + ERROR_ASSERT( info.is() , "XServiceInfo not supported !" ); + if( info.is() ) + { + ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" ); + ERROR_ASSERT( ! info->supportsService( + OUString( "bla bluzb") ) , "XServiceInfo test failed" ); + } +} + + +sal_Int32 OMarkableOutputStreamTest::test( + const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, RuntimeException) +{ + if( OUString( "com.sun.star.io.MarkableOutputStream" ) + == TestName ) { + try + { + if( 0 == hTestHandle ) + { + testInvariant( TestName , TestObject ); + } + else + { + Reference < XInterface > x = m_rFactory->createInstance("com.sun.star.io.Pipe"); + Reference< XOutputStream > rPipeOutput( x , UNO_QUERY ); + Reference < XInputStream > rPipeInput( x , UNO_QUERY ); + + Reference< XActiveDataSource > source( TestObject , UNO_QUERY ); + source->setOutputStream( rPipeOutput ); + + Reference< XOutputStream > rOutput( TestObject , UNO_QUERY ); + + OSL_ASSERT( rPipeInput.is() ); + OSL_ASSERT( rOutput.is() ); + if( 1 == hTestHandle ) { + // checks usual streaming + testSimple( rOutput , rPipeInput ); + } + } + + } + catch( const Exception &e ) + { + OString o = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + BUILD_ERROR( 0 , o.getStr() ); + } + catch( ... ) + { + BUILD_ERROR( 0 , "unknown exception (Exception is not base class)" ); + } + + hTestHandle ++; + + if( 2 == hTestHandle ) + { + // all tests finished. + hTestHandle = -1; + } + } + else { + throw IllegalArgumentException(); + } + return hTestHandle; +} + + +sal_Bool OMarkableOutputStreamTest::testPassed() throw (RuntimeException) +{ + return m_seqErrors.getLength() == 0; +} + + +Sequence< OUString > OMarkableOutputStreamTest::getErrors() throw (RuntimeException) +{ + return m_seqErrors; +} + + +Sequence< Any > OMarkableOutputStreamTest::getErrorExceptions() throw (RuntimeException) +{ + return m_seqExceptions; +} + + +Sequence< OUString > OMarkableOutputStreamTest::getWarnings() throw (RuntimeException) +{ + return m_seqWarnings; +} + + +void OMarkableOutputStreamTest::testSimple( const Reference< XOutputStream > &rOutput , + const Reference< XInputStream > &rInput ) +{ + Reference < XMarkableStream > rMarkable( rOutput , UNO_QUERY ); + + ERROR_ASSERT( rMarkable.is() , "no MarkableStream implemented" ); + + // first check normal input/output facility + char pcStr[] = "Live long and prosper !"; + + Sequence<sal_Int8> seqWrite( strlen( pcStr )+1 ); + memcpy( seqWrite.getArray() , pcStr , seqWrite.getLength() ); + + Sequence<sal_Int8> seqRead( seqWrite.getLength() ); + + int nMax = 10,i; + + for( i = 0 ; i < nMax ; i ++ ) { + rOutput->writeBytes( seqWrite ); + rInput->readBytes( seqRead , rInput->available() ); + ERROR_ASSERT( ! strcmp( (char *) seqWrite.getArray() , (char * )seqRead.getArray() ) , + "error during read/write/skip" ); + } + + // Check buffer resizing + nMax = 3000; + for( i = 0 ; i < nMax ; i ++ ) { + rOutput->writeBytes( seqWrite ); + } + + for( i = 0 ; i < nMax ; i ++ ) { + rInput->readBytes( seqRead , seqWrite.getLength() ); + ERROR_ASSERT( ! strcmp( (char *) seqWrite.getArray() , (char * )seqRead.getArray() ) , + "error during read/write" ); + } + + // Check creating marks ! + sal_Int32 nMark = rMarkable->createMark(); + + for( i = 0 ; i < nMax ; i ++ ) { + rOutput->writeBytes( seqWrite ); + } + + ERROR_ASSERT( 0 == rInput->available() , "bytes available though mark is holded" ); + + ERROR_ASSERT( nMax*seqWrite.getLength() == rMarkable->offsetToMark( nMark ) , + "offsetToMark failure" ); + + rMarkable->deleteMark( nMark ); + ERROR_ASSERT( nMax*seqWrite.getLength() == rInput->available(),"bytes are not available though mark has been deleted" ); + + rInput->skipBytes( nMax*seqWrite.getLength() ); + ERROR_ASSERT( 0 == rInput->available(), "skip bytes failure" ); + + try + { + rMarkable->jumpToMark( nMark ); + ERROR_ASSERT( 0 , "jump to non existing mark possible !" ); + } + catch ( IllegalArgumentException & ) + { + // ok, exception was thrown + } + + // test putting marks not at the end of the stream! + ERROR_ASSERT( 0 == rInput->available(), "stream isn't clean" ); + { + Sequence< sal_Int8 > aByte(256); + + for( i = 0 ; i < 256 ; i ++ ) + { + aByte.getArray()[i] = i; + } + sal_Int32 nMark1 = rMarkable->createMark(); + + rOutput->writeBytes( aByte ); + rMarkable->jumpToMark( nMark1 ); + aByte.realloc( 10 ); + rOutput->writeBytes( aByte ); + + sal_Int32 nMark2 = rMarkable->createMark( ); + + for( i = 0 ; i < 10 ; i ++ ) + { + aByte.getArray()[i] = i+10; + } + + rOutput->writeBytes( aByte ); + + // allow the bytes to be written ! + rMarkable->jumpToFurthest(); + rMarkable->deleteMark( nMark1 ); + rMarkable->deleteMark( nMark2 ); + + ERROR_ASSERT( 256 == rInput->available(), "in between mark failure" ); + rInput->readBytes( aByte ,256); + for( i = 0 ; i < 256 ; i ++ ) + { + ERROR_ASSERT( i == ((sal_uInt8*)(aByte.getArray()))[i] , "in between mark failure" ); + } + } + + { + // now a more extensive mark test ! + Sequence<sal_Int8> as[4]; + sal_Int32 an[4]; + + for( i = 0 ; i < 4 ; i ++ ) { + as[i].realloc(1); + as[i].getArray()[0] = i; + an[i] = rMarkable->createMark(); + rOutput->writeBytes( as[i] ); + } + + // check offset to mark + for( i = 0 ; i < 4 ; i ++ ) { + ERROR_ASSERT( rMarkable->offsetToMark( an[i] ) == 4-i , "offsetToMark failure" ); + } + + rMarkable->jumpToMark( an[1] ); + ERROR_ASSERT( rMarkable->offsetToMark( an[3] ) == -2 , "offsetToMark failure" ); + + rMarkable->jumpToFurthest( ); + ERROR_ASSERT( rMarkable->offsetToMark( an[0] ) == 4 , "offsetToMark failure" ); + + // now do a rewrite ! + for( i = 0 ; i < 4 ; i ++ ) { + rMarkable->jumpToMark( an[3-i] ); + rOutput->writeBytes( as[i] ); + } + // NOTE : CursorPos 1 + + // now delete the marks ! + for( i = 0 ; i < 4 ; i ++ ) { + rMarkable->deleteMark( an[i] ); + } + ERROR_ASSERT( rInput->available() == 1 , "wrong number of bytes flushed" ); + + rMarkable->jumpToFurthest(); + + ERROR_ASSERT( rInput->available() == 4 , "wrong number of bytes flushed" ); + + rInput->readBytes( seqRead , 4 ); + + ERROR_ASSERT( 3 == seqRead.getArray()[0] , "rewrite didn't work" ); + ERROR_ASSERT( 2 == seqRead.getArray()[1] , "rewrite didn't work" ); + ERROR_ASSERT( 1 == seqRead.getArray()[2] , "rewrite didn't work" ); + ERROR_ASSERT( 0 == seqRead.getArray()[3] , "rewrite didn't work" ); + + rOutput->closeOutput(); + rInput->closeInput(); + } + +} + +/*** +* the test methods +* +****/ + + +/** +* for external binding +* +* +**/ +Reference < XInterface > SAL_CALL OMarkableOutputStreamTest_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw(Exception) +{ + return getXWeak(new OMarkableOutputStreamTest( rSMgr )); +} + + +Sequence<OUString> OMarkableOutputStreamTest_getSupportedServiceNames() throw () +{ + Sequence<OUString> aRet { OMarkableOutputStreamTest_getImplementationName() }; + + return aRet; +} + +OUString OMarkableOutputStreamTest_getServiceName() throw () +{ + return OUString( "test.com.sun.star.io.MarkableOutputStream"); +} + +OUString OMarkableOutputStreamTest_getImplementationName() throw () +{ + return OUString( "test.com.sun.starextensions.stm.MarkableOutputStream"); +} + + +// Input stream + + +class OMarkableInputStreamTest : public WeakImplHelper< XSimpleTest > +{ +public: + explicit OMarkableInputStreamTest( const Reference< XMultiServiceFactory > & rFactory ); + ~OMarkableInputStreamTest(); + +public: // implementation names + static Sequence< OUString > getSupportedServiceNames_Static() throw () ; + static OUString getImplementationName_Static() throw () ; + +public: + virtual void SAL_CALL testInvariant( + const OUString& TestName, + const Reference < XInterface >& TestObject) + throw ( IllegalArgumentException, RuntimeException) ; + + virtual sal_Int32 SAL_CALL test( + const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, + RuntimeException) ; + + virtual sal_Bool SAL_CALL testPassed() + throw ( RuntimeException); + virtual Sequence< OUString > SAL_CALL getErrors() + throw (RuntimeException); + virtual Sequence< Any > SAL_CALL getErrorExceptions() + throw (RuntimeException); + virtual Sequence< OUString > SAL_CALL getWarnings() + throw (RuntimeException); + +private: + void testSimple( const Reference< XOutputStream > &r, + const Reference < XInputStream > &rInput ); + +private: + Sequence<Any> m_seqExceptions; + Sequence<OUString> m_seqErrors; + Sequence<OUString> m_seqWarnings; + Reference< XMultiServiceFactory > m_rFactory; + +}; + +OMarkableInputStreamTest::OMarkableInputStreamTest( const Reference< XMultiServiceFactory > &rFactory ) + : m_rFactory( rFactory ) +{ + +} + +OMarkableInputStreamTest::~OMarkableInputStreamTest() +{ + +} + + +void OMarkableInputStreamTest::testInvariant( + const OUString& TestName, const Reference < XInterface >& TestObject ) + throw ( IllegalArgumentException, RuntimeException) +{ + if( OUString( "com.sun.star.io.MarkableInputStream") + == TestName ) { + Reference <XServiceInfo > info( TestObject, UNO_QUERY ); + ERROR_ASSERT( info.is() , "XServiceInfo not supported !" ); + if( info.is() ) + { + ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" ); + ERROR_ASSERT( + ! info->supportsService( + OUString("bla bluzb") ) , + "XServiceInfo test failed" ); + } + } + else + { + throw IllegalArgumentException(); + } +} + + +sal_Int32 OMarkableInputStreamTest::test( + const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) throw ( IllegalArgumentException, RuntimeException) +{ + if( OUString( "com.sun.star.io.MarkableInputStream") == TestName ) + { + try + { + if( 0 == hTestHandle ) { + testInvariant( TestName , TestObject ); + } + else { + Reference < XInterface > x = m_rFactory->createInstance("com.sun.star.io.Pipe"); + Reference< XOutputStream > rPipeOutput( x , UNO_QUERY ); + Reference < XInputStream > rPipeInput( x , UNO_QUERY ); + + Reference < XActiveDataSink > sink( TestObject , UNO_QUERY ); + sink->setInputStream( rPipeInput ); + + Reference < XInputStream > rInput( TestObject , UNO_QUERY ); + + OSL_ASSERT( rPipeOutput.is() ); + OSL_ASSERT( rInput.is() ); + if( 1 == hTestHandle ) { + // checks usual streaming + testSimple( rPipeOutput , rInput ); + } + } + + } + catch( const Exception & e ) + { + OString o = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + BUILD_ERROR( 0 , o.getStr() ); + } + catch( ... ) + { + BUILD_ERROR( 0 , "unknown exception (Exception is not base class)" ); + } + + hTestHandle ++; + + if( 2 == hTestHandle ) { + // all tests finished. + hTestHandle = -1; + } + } + else + { + throw IllegalArgumentException(); + } + return hTestHandle; +} + + +sal_Bool OMarkableInputStreamTest::testPassed() throw (RuntimeException) +{ + return m_seqErrors.getLength() == 0; +} + + +Sequence< OUString > OMarkableInputStreamTest::getErrors() throw (RuntimeException) +{ + return m_seqErrors; +} + + +Sequence< Any > OMarkableInputStreamTest::getErrorExceptions() throw (RuntimeException) +{ + return m_seqExceptions; +} + + +Sequence< OUString > OMarkableInputStreamTest::getWarnings() throw (RuntimeException) +{ + return m_seqWarnings; +} + + +void OMarkableInputStreamTest::testSimple( const Reference< XOutputStream > &rOutput , + const Reference < XInputStream > &rInput ) +{ + Reference < XMarkableStream > rMarkable( rInput , UNO_QUERY ); + + Sequence<sal_Int8> seqWrite( 256 ); + Sequence<sal_Int8> seqRead(10); + + for( int i = 0 ; i < 256 ; i ++ ) + { + seqWrite.getArray()[i] = i; + } + + rOutput->writeBytes( seqWrite ); + ERROR_ASSERT( 256 == rInput->available() , "basic read/write failure" ); + + rInput->readBytes( seqRead , 10 ); + ERROR_ASSERT( 9 == seqRead.getArray()[9] , "basic read/write failure" ); + + sal_Int32 nMark = rMarkable->createMark(); + + rInput->skipBytes( 50 ); + ERROR_ASSERT( 256-10-50 == rInput->available() , "marking error" ); + ERROR_ASSERT( 50 == rMarkable->offsetToMark( nMark ) , "marking error" ); + + rMarkable->jumpToMark( nMark ); + ERROR_ASSERT( 256-10 == rInput->available() , "marking error" ); + + rInput->readBytes( seqRead , 10 ); + ERROR_ASSERT( 10 == seqRead.getArray()[0] , "marking error" ); + + // pos 20 + { + sal_Int32 nInBetweenMark = rMarkable->createMark( ); + rMarkable->jumpToMark( nMark ); + rMarkable->jumpToMark( nInBetweenMark ); + + rInput->readBytes( seqRead , 10 ); + ERROR_ASSERT( 20 == seqRead.getArray()[0] , "Inbetween mark failed!\n" ); + + rMarkable->deleteMark( nMark ); + + // Check if releasing the first bytes works correct. + rMarkable->jumpToMark( nInBetweenMark); + rInput->readBytes( seqRead , 10 ); + ERROR_ASSERT( 20 == seqRead.getArray()[0] , "Inbetween mark failed!\n" ); + + rMarkable->deleteMark( nInBetweenMark ); + } + + rMarkable->jumpToFurthest(); + ERROR_ASSERT( 256-10-50 == rInput->available() , "marking error" ); + + + ERROR_ASSERT( 100 == rInput->readSomeBytes( seqRead , 100 ) , "wrong results using readSomeBytes" ); + ERROR_ASSERT( 96 == rInput->readSomeBytes( seqRead , 1000) , "wrong results using readSomeBytes" ); + rOutput->closeOutput(); + rInput->closeInput(); +} + +/*** +* the test methods +* +****/ + + +/** +* for external binding +* +* +**/ +Reference < XInterface > SAL_CALL OMarkableInputStreamTest_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw(Exception) +{ + return getXWeak(new OMarkableInputStreamTest( rSMgr )); +} + + +Sequence<OUString> OMarkableInputStreamTest_getSupportedServiceNames() throw () +{ + Sequence<OUString> aRet { OMarkableInputStreamTest_getImplementationName() }; + + return aRet; +} + +OUString OMarkableInputStreamTest_getServiceName() throw () +{ + return OUString( "test.com.sun.star.io.MarkableInputStream"); +} + +OUString OMarkableInputStreamTest_getImplementationName() throw () +{ + return OUString( "test.com.sun.star.extensions.stm.MarkableInputStream" ); +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/test/stm/pipetest.cxx b/io/test/stm/pipetest.cxx new file mode 100644 index 0000000000..da5c5f20ba --- /dev/null +++ b/io/test/stm/pipetest.cxx @@ -0,0 +1,416 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* + * This file is part of the LibreOffice project. + * + * This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. + * + * This file incorporates work covered by the following license notice: + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed + * with this work for additional information regarding copyright + * ownership. The ASF licenses this file to you under the Apache + * License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of + * the License at http://www.apache.org/licenses/LICENSE-2.0 . + */ + + +#include <com/sun/star/test/XSimpleTest.hpp> +#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/IllegalArgumentException.hpp> + +#include <com/sun/star/lang/XServiceInfo.hpp> + +#include <cppuhelper/factory.hxx> + +#include <cppuhelper/implbase.hxx> + +#include <osl/conditn.hxx> +#include <osl/thread.hxx> + +#include <string.h> + +using namespace ::osl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::test; +// streams + +#include "testfactreg.hxx" + + +class WriteToStreamThread : + public Thread +{ + +public: + + WriteToStreamThread( Reference< XOutputStream > xOutput , int iMax ) + : m_output(xOutput), m_iMax(iMax) + { + } + + virtual ~WriteToStreamThread() {} + + +protected: + + /// Working method which should be overridden. + virtual void SAL_CALL run() { + for( int i = 0 ; i < m_iMax ; i ++ ) { + m_output->writeBytes( createIntSeq(i) ); + } + m_output->closeOutput(); + } + + /** Called when run() is done. + * You might want to override it to do some cleanup. + */ + virtual void SAL_CALL onTerminated() + { + delete this; + } + + +private: + + Reference < XOutputStream > m_output; + int m_iMax; +}; + + +class OPipeTest : public WeakImplHelper < XSimpleTest > +{ +public: + explicit OPipeTest( const Reference< XMultiServiceFactory > & rFactory ); + ~OPipeTest(); + +public: // implementation names + static Sequence< OUString > getSupportedServiceNames_Static() throw(); + static OUString getImplementationName_Static() throw(); + +public: + virtual void SAL_CALL testInvariant(const OUString& TestName, const Reference < XInterface >& TestObject) + throw ( IllegalArgumentException, RuntimeException) ; + + virtual sal_Int32 SAL_CALL test( const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, + RuntimeException); + + virtual sal_Bool SAL_CALL testPassed() throw ( RuntimeException) ; + virtual Sequence< OUString > SAL_CALL getErrors() throw (RuntimeException) ; + virtual Sequence< Any > SAL_CALL getErrorExceptions() throw (RuntimeException); + virtual Sequence< OUString > SAL_CALL getWarnings() throw (RuntimeException); + +private: + void testSimple( const Reference < XInterface > & ); + void testBufferResizing( const Reference < XInterface > & ); + void testMultithreading( const Reference < XInterface > & ); + +private: + Sequence<Any> m_seqExceptions; + Sequence<OUString> m_seqErrors; + Sequence<OUString> m_seqWarnings; + +}; + + +OPipeTest::OPipeTest( const Reference< XMultiServiceFactory > &rFactory ) +{ + +} + +OPipeTest::~OPipeTest() +{ + +} + + +void OPipeTest::testInvariant( const OUString& TestName, const Reference < XInterface >& TestObject ) + throw ( IllegalArgumentException, + RuntimeException) +{ + Reference< XServiceInfo > info( TestObject, UNO_QUERY ); + ERROR_ASSERT( info.is() , "XServiceInfo not supported !" ); + if( info.is() ) + { + ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" ); + ERROR_ASSERT( ! info->supportsService( + OUString("bla bluzb") ), "XServiceInfo test failed" ); + } + +} + + +sal_Int32 OPipeTest::test( + const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, RuntimeException) +{ + if( OUString("com.sun.star.io.Pipe") == TestName ) { + try + { + if( 0 == hTestHandle ) { + testInvariant( TestName , TestObject ); + } + else if( 1 == hTestHandle ) { + testSimple( TestObject ); + } + else if( 2 == hTestHandle ) { + testBufferResizing( TestObject ); + } + else if( 3 == hTestHandle ) { + testMultithreading( TestObject ); + } + } + catch( const Exception & e ) + { + OString s = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + BUILD_ERROR( 0 , s.getStr() ); + } + catch( ... ) + { + BUILD_ERROR( 0 , "unknown exception (Exception is not base class)" ); + } + + hTestHandle ++; + + if( 4 == hTestHandle ) + { + // all tests finished. + hTestHandle = -1; + } + } + else { + throw IllegalArgumentException(); + } + return hTestHandle; +} + + +sal_Bool OPipeTest::testPassed() throw (RuntimeException) +{ + return m_seqErrors.getLength() == 0; +} + + +Sequence< OUString > OPipeTest::getErrors() throw (RuntimeException) +{ + return m_seqErrors; +} + + +Sequence< Any > OPipeTest::getErrorExceptions() throw (RuntimeException) +{ + return m_seqExceptions; +} + + +Sequence< OUString > OPipeTest::getWarnings() throw (RuntimeException) +{ + return m_seqWarnings; +} + + +/*** +* the test methods +* +****/ + + +void OPipeTest::testSimple( const Reference < XInterface > &r ) +{ + + Reference< XInputStream > input( r , UNO_QUERY ); + Reference < XOutputStream > output( r , UNO_QUERY ); + + ERROR_ASSERT( input.is() , "queryInterface on XInputStream failed" ); + ERROR_ASSERT( output.is() , "queryInterface onXOutputStream failed" ); + + // basic read/write + Sequence<sal_Int8> seqWrite = createSeq( "Hallo, du Ei !" ); + + Sequence<sal_Int8> seqRead; + for( int i = 0 ; i < 5000 ; i ++ ) { + output->writeBytes( seqWrite ); + input->readBytes( seqRead , input->available() ); + + ERROR_ASSERT( ! strcmp( (char *) seqWrite.getArray() , (char * )seqRead.getArray() ) , + "error during read/write/skip" ); + ERROR_ASSERT( 0 == input->available() , + "error during read/write/skip" ); + + // available shouldn't return a negative value + input->skipBytes( seqWrite.getLength() - 5 ); + ERROR_ASSERT( 0 == input->available() , "wrong available after skip" ); + + // 5 bytes should be available + output->writeBytes( seqWrite ); + ERROR_ASSERT( 5 == input->available() , "wrong available after skip/write " ); + + input->readBytes( seqRead , 5 ); + ERROR_ASSERT( ! strcmp( (char*) seqRead.getArray() , + (char*) &( seqWrite.getArray()[seqWrite.getLength()-5] ) ), + "write/read mismatch" ); + + } + + output->writeBytes( seqWrite ); + ERROR_ASSERT( seqWrite.getLength() == input->available(), "wrong available() after write" ); + + ERROR_ASSERT( 10 == input->readSomeBytes( seqRead , 10 ) , "maximal number of bytes ignored" ); + ERROR_ASSERT( seqWrite.getLength() -10 == input->readSomeBytes( seqRead , 100 ) , + "something wrong with readSomeBytes" ); + + + output->closeOutput(); + try{ + output->writeBytes( Sequence<sal_Int8> (100) ); + ERROR_ASSERT( 0 , "writing on a closed stream does not cause an exception" ); + } + catch (IOException & ) + { + } + + ERROR_ASSERT(! input->readBytes( seqRead , 1 ), "eof not found !" ); + + input->closeInput(); + try + { + input->readBytes( seqRead , 1 ); + ERROR_ASSERT( 0 , "reading from a closed stream does not cause an exception" ); + } + catch( IOException & ) { + } + + try + { + input->available( ); + ERROR_ASSERT( 0 , "calling available from a closed stream should thrown an io exception" ); + } + catch( IOException & ) + { + + } + try + { + input->skipBytes(42 ); + ERROR_ASSERT( 0 , "calling available from a closed stream should thrown an io exception" ); + } + catch( IOException & ) + { + + } +} + +void OPipeTest::testBufferResizing( const Reference < XInterface > &r ) +{ + int i; + int iMax = 20000; + Reference< XInputStream > input( r , UNO_QUERY ); + Reference < XOutputStream > output( r , UNO_QUERY ); + + ERROR_ASSERT( input.is() , "queryInterface on XInputStream failed" ); + ERROR_ASSERT( output.is() , "queryInterface on XOutputStream failed" ); + + Sequence<sal_Int8> seqRead; + + // this is just to better check the + // internal buffers + output->writeBytes( Sequence<sal_Int8>(100) ); + Sequence< sal_Int8 > dummy; + input->readBytes( dummy , 100); + + for( i = 0 ; i < iMax ; i ++ ) { + output->writeBytes( createIntSeq( i ) ); + } + + for( i = 0 ; i < iMax ; i ++ ) { + input->readBytes( seqRead, createIntSeq(i).getLength() ); + ERROR_ASSERT( ! strcmp( (char*) seqRead.getArray() , + (char*) createIntSeq(i).getArray() ) , + "written/read mismatch\n" ); + } + + output->closeOutput(); + ERROR_ASSERT( ! input->readBytes( seqRead , 1 ) , "eof not reached !" ); + input->closeInput(); +} + + +void OPipeTest::testMultithreading( const Reference < XInterface > &r ) +{ + + int i; + int iMax = 30000; + + Reference< XInputStream > input( r , UNO_QUERY ); + Reference < XOutputStream > output( r , UNO_QUERY ); + + ERROR_ASSERT( input.is() , "queryInterface on XInputStream failed" ); + ERROR_ASSERT( output.is() , "queryInterface on XOutputStream failed" ); + + Sequence<sal_Int8> seqRead; + + // deletes itself + Thread *p = new WriteToStreamThread( output, iMax ); + + ERROR_ASSERT( p , "couldn't create thread for testing !\n" ); + + p->create(); + + for( i = 0 ; sal_True ; i ++ ) { + if( 0 == input->readBytes( seqRead, createIntSeq(i).getLength() ) ) { + // eof reached ! + break; + } + + ERROR_ASSERT( ! strcmp( (char*) seqRead.getArray() , + (char*) createIntSeq(i).getArray() ) , + "written/read mismatch\n" ); + } + + ERROR_ASSERT( i == iMax , "less elements read than written !"); + input->closeInput(); +} + + +/** +* for external binding +* +* +**/ +Reference < XInterface > SAL_CALL OPipeTest_CreateInstance( const Reference< XMultiServiceFactory> & rSMgr ) throw (Exception) +{ + return getXWeak(new OPipeTest( rSMgr )); +} + + +Sequence<OUString> OPipeTest_getSupportedServiceNames() throw() +{ + Sequence<OUString> aRet { OPipeTest_getServiceName() }; + + return aRet; +} + +OUString OPipeTest_getServiceName() throw() +{ + return OUString( "test.com.sun.star.io.Pipe" ); +} + +OUString OPipeTest_getImplementationName() throw() +{ + return OUString( "test.com.sun.star.comp.extensions.stm.Pipe" ); +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/test/stm/pumptest.cxx b/io/test/stm/pumptest.cxx new file mode 100644 index 0000000000..f0563153e9 --- /dev/null +++ b/io/test/stm/pumptest.cxx @@ -0,0 +1,430 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* + * This file is part of the LibreOffice project. + * + * This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. + * + * This file incorporates work covered by the following license notice: + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed + * with this work for additional information regarding copyright + * ownership. The ASF licenses this file to you under the Apache + * License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of + * the License at http://www.apache.org/licenses/LICENSE-2.0 . + */ + +#include <stdio.h> +#include <osl/time.h> + +#include <com/sun/star/test/XSimpleTest.hpp> + +#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/XServiceInfo.hpp> +#include <com/sun/star/lang/XSingleServiceFactory.hpp> +#include <com/sun/star/lang/XMultiServiceFactory.hpp> +#include <com/sun/star/registry/XRegistryKey.hpp> + +#include <uno/dispatcher.h> +#include <uno/mapping.hxx> +#include <cppuhelper/implbase.hxx> +#include <cppuhelper/factory.hxx> +#include <osl/thread.hxx> +#include <list> + + +using namespace ::osl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::test; + +#include "testfactreg.hxx" + +static void mywait() +{ + osl::Thread::wait(std::chrono::microseconds(10)); + osl_yieldThread(); + osl_yieldThread(); +} + +class OPumpTest : public WeakImplHelper < XSimpleTest > +{ +public: + explicit OPumpTest( const Reference< XMultiServiceFactory > & rFactory ); + ~OPumpTest(); + +public: // implementation names + static Sequence< OUString > getSupportedServiceNames_Static() throw(); + static OUString getImplementationName_Static() throw(); + +public: + virtual void SAL_CALL testInvariant(const OUString& TestName, const Reference < XInterface >& TestObject) + throw ( IllegalArgumentException, RuntimeException) ; + + virtual sal_Int32 SAL_CALL test( const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, + RuntimeException); + + virtual sal_Bool SAL_CALL testPassed() throw ( RuntimeException) ; + virtual Sequence< OUString > SAL_CALL getErrors() throw (RuntimeException) ; + virtual Sequence< Any > SAL_CALL getErrorExceptions() throw (RuntimeException); + virtual Sequence< OUString > SAL_CALL getWarnings() throw (RuntimeException); + +private: + void testSimple( const Reference < XInterface > & ); + void testWrongUsage( const Reference < XInterface > & ); + void testClose( const Reference< XInterface >& ); + void testTerminate( const Reference< XInterface >& ); + void testFunction( const Reference< XInterface >& ); +private: + Sequence<Any> m_seqExceptions; + Sequence<OUString> m_seqErrors; + Sequence<OUString> m_seqWarnings; + Reference< XMultiServiceFactory > m_rSmgr; + +}; + +OPumpTest::OPumpTest( const Reference< XMultiServiceFactory > &rFactory ) : + m_rSmgr( rFactory ) +{ + +} + +OPumpTest::~OPumpTest() +{ + +} + + +void OPumpTest::testInvariant( const OUString& TestName, const Reference < XInterface >& TestObject ) + throw ( IllegalArgumentException, + RuntimeException) +{ + Reference< XServiceInfo > info( TestObject, UNO_QUERY ); + ERROR_ASSERT( info.is() , "XServiceInfo not supported !" ); + if( info.is() ) + { + ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" ); + ERROR_ASSERT( ! info->supportsService( + OUString( "bla bluzb" ) ), "XServiceInfo test failed" ); + } + + Reference < XActiveDataSource > xActiveDataSource( TestObject, UNO_QUERY ); + Reference < XActiveDataSink > xActiveDataSink( TestObject, UNO_QUERY ); + Reference < XActiveDataControl > xActiveDataControl( TestObject , UNO_QUERY ); + Reference < XConnectable > xConnectable( TestObject , UNO_QUERY ); + + ERROR_ASSERT( xActiveDataSource.is() && xActiveDataSink.is() && xActiveDataControl.is () && + xConnectable.is(), "specified interface not supported" ); +} + + +sal_Int32 OPumpTest::test( + const OUString& TestName, + const Reference < XInterface >& TestObject, + sal_Int32 hTestHandle) + throw ( IllegalArgumentException, RuntimeException) +{ + if( OUString( "com.sun.star.io.Pump" ) == TestName ) { + try + { + if( 0 == hTestHandle ) { + testInvariant( TestName , TestObject ); + } + else if ( 1 == hTestHandle ) + { + testWrongUsage( TestObject); + } + else if ( 2 == hTestHandle ) + { + testClose( TestObject); + } + else if ( 3 == hTestHandle ) + { + testTerminate( TestObject ); + } + else if ( 4 == hTestHandle ) + { + testFunction( TestObject ); + } + } + catch( const Exception & e ) + { + OString s = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + BUILD_ERROR( 0 , s.getStr() ); + } + catch( ... ) + { + BUILD_ERROR( 0 , "unknown exception (Exception is not base class)" ); + } + + hTestHandle ++; + + if( 5 == hTestHandle ) + { + // all tests finished. + hTestHandle = -1; + } + } + else { + throw IllegalArgumentException(); + } + return hTestHandle; +} + + +sal_Bool OPumpTest::testPassed() throw (RuntimeException) +{ + return m_seqErrors.getLength() == 0; +} + + +Sequence< OUString > OPumpTest::getErrors() throw (RuntimeException) +{ + return m_seqErrors; +} + + +Sequence< Any > OPumpTest::getErrorExceptions() throw (RuntimeException) +{ + return m_seqExceptions; +} + + +Sequence< OUString > OPumpTest::getWarnings() throw (RuntimeException) +{ + return m_seqWarnings; +} + + +/*** +* the test methods +* +****/ + + +void OPumpTest::testSimple( const Reference < XInterface > &r ) +{ + // jbu todo: add sensible test + +} + +class TestListener: public WeakImplHelper< XStreamListener > +{ +public: + sal_Bool m_bStarted; + sal_Bool m_bClosed; + sal_Bool m_bTerminated; + sal_Bool m_bError; + sal_Bool m_bDisposed; + TestListener() : m_bStarted (sal_False), + m_bClosed (sal_False), + m_bTerminated ( sal_False ), + m_bError( sal_False ), + m_bDisposed( sal_False ) + {} + + virtual void SAL_CALL disposing( const EventObject &obj ) throw (css::uno::RuntimeException) + { + m_bDisposed = sal_True; +// printf( "disposing called\n"); + } + + virtual void SAL_CALL started( ) throw (css::uno::RuntimeException) + { + m_bStarted = sal_True; +// printf( "started called\n"); + } + virtual void SAL_CALL closed( ) throw (css::uno::RuntimeException) + { + m_bClosed = sal_True; +// printf( "closed called\n"); + } + virtual void SAL_CALL terminated( ) throw (css::uno::RuntimeException) + { + m_bTerminated = sal_True; +// printf( "terminated called\n"); + } + virtual void SAL_CALL error( const css::uno::Any& aException ) + throw (css::uno::RuntimeException) + { + m_bError = sal_True; + Exception e; + aException >>= e; +// printf( "error called %s\n", OUStringToOString( e.Message, RTL_TEXTENCODING_ASCII_US).getStr() ); + } +}; + +class TestCase +{ +public: + TestCase( const Reference< XMultiServiceFactory > & rSMgr, + const Reference< XInterface > &r ) : m_rSmgr( rSMgr ), m_pTestListener( 0 ) + { + m_rControl.set( r, UNO_QUERY ); + + Reference< XActiveDataSource > rSource ( r, UNO_QUERY ); + Reference< XActiveDataSink > rSink( r , UNO_QUERY ); + + m_rOutSource.set( createPipe() ); + rSink->setInputStream(Reference< XInputStream> (m_rOutSource,UNO_QUERY)); + + Reference< XOutputStream > rOutSink( createPipe() ); + m_rInSink.set( rOutSink, UNO_QUERY ); + rSource->setOutputStream( rOutSink ); + + m_pTestListener = new TestListener(); + m_pTestListener->acquire(); + m_rControl->addListener( m_pTestListener ); + } + + ~TestCase() + { + if( m_pTestListener ) + m_pTestListener->release(); + } + + TestListener *m_pTestListener; + Reference< XActiveDataControl > m_rControl; + Reference< XOutputStream > m_rOutSource; + Reference< XInputStream > m_rInSink; + Reference< XMultiServiceFactory > m_rSmgr; + +private: + Reference< XOutputStream > createPipe() + { + Reference< XOutputStream > rOut( m_rSmgr->createInstance( + "com.sun.star.io.Pipe"),UNO_QUERY); + return rOut; + } +}; + + +void OPumpTest::testClose( const Reference< XInterface > &r ) +{ + TestCase t( m_rSmgr, r ); + + ERROR_ASSERT( ! t.m_pTestListener->m_bStarted , "started too early" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bTerminated , "termination unexpected" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bError, "unexpected error" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bClosed, "unexpected close" ); + + t.m_rControl->start(); + mywait(); + + ERROR_ASSERT( t.m_pTestListener->m_bStarted , "should have been started already" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bTerminated , "termination unexpected" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bError, "unexpected error" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bClosed, "unexpected close" ); + + Reference< XStreamListener > rListener( new TestListener() ); + t.m_rControl->addListener( rListener ); + t.m_rControl->removeListener( rListener ); + + t.m_rOutSource->closeOutput(); + mywait(); + ERROR_ASSERT( t.m_pTestListener->m_bStarted , "should have been started already" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bTerminated , "should be terminated already" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bError, "unexpected error" ); + ERROR_ASSERT( t.m_pTestListener->m_bClosed, "should be closed already" ); +} + +void OPumpTest::testTerminate( const Reference< XInterface > &r ) +{ + TestCase t( m_rSmgr, r ); + + ERROR_ASSERT( ! t.m_pTestListener->m_bStarted , "started too early" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bTerminated , "termination unexpected" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bError, "unexpected error" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bClosed, "unexpected closed" ); + + t.m_rControl->start(); + mywait(); + + ERROR_ASSERT( t.m_pTestListener->m_bStarted , "should have been started already" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bTerminated , "termination unexpected" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bError, "unexpected error" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bClosed, "unexpected closed" ); + + t.m_rControl->terminate(); + + mywait(); + ERROR_ASSERT( t.m_pTestListener->m_bStarted , "should have been started already" ); + ERROR_ASSERT( t.m_pTestListener->m_bTerminated , "should be terminated already" ); + // terminate leads to an error, that is no surprise, in fact + // one can't tell whether the error occurs because of the terminate + // call or for some other reason! +// ERROR_ASSERT( ! t.m_pTestListener->m_bError, "unexpected error" ); + ERROR_ASSERT( t.m_pTestListener->m_bClosed, "should be closed already" ); +} + +void OPumpTest::testFunction( const Reference< XInterface > &r ) +{ + TestCase t( m_rSmgr, r ); + + t.m_rControl->start(); + + t.m_rOutSource->writeBytes( Sequence< sal_Int8 > ( 5 ) ); + + Sequence< sal_Int8 > dummy; + ERROR_ASSERT( 5 == t.m_rInSink->readBytes( dummy , 5 ), "couldn't read the expected number of bytes" ); + + t.m_rOutSource->closeOutput(); + mywait(); + + ERROR_ASSERT( t.m_pTestListener->m_bStarted , "should have been started already" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bTerminated , "should be terminated already" ); + ERROR_ASSERT( ! t.m_pTestListener->m_bError, "unexpected error" ); + ERROR_ASSERT( t.m_pTestListener->m_bClosed, "should be closed already" ); +} + +void OPumpTest::testWrongUsage( const Reference< XInterface > &r ) +{ + Reference< XActiveDataSource > rSource ( r, UNO_QUERY ); + Reference< XActiveDataSink > rSink( r , UNO_QUERY ); + Reference< XActiveDataControl > rControl( r, UNO_QUERY ); + + Reference< XInputStream > rIn( m_rSmgr->createInstance( + "com.sun.star.io.DataInputStream"),UNO_QUERY); + Reference< XOutputStream > rOut( m_rSmgr->createInstance( + "com.sun.star.io.DataOutputStream"),UNO_QUERY); + + rSink->setInputStream( rIn ); + rSource->setOutputStream( rOut ); + + rControl->start(); + + mywait(); +} + +Reference< XInterface > SAL_CALL OPumpTest_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw( Exception ) +{ + return *new OPumpTest( rSMgr ); +} + +Sequence<OUString> OPumpTest_getSupportedServiceNames() throw() +{ + return { OPumpTest_getServiceName() }; + +} +OUString OPumpTest_getServiceName() throw() +{ + return OUString( "test.com.sun.star.io.Pump" ); +} + +OUString OPumpTest_getImplementationName() throw() +{ + return OUString( "test.com.sun.star.comp.io.Pump" ); +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/test/stm/testfactreg.cxx b/io/test/stm/testfactreg.cxx new file mode 100644 index 0000000000..2250429e56 --- /dev/null +++ b/io/test/stm/testfactreg.cxx @@ -0,0 +1,199 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* + * This file is part of the LibreOffice project. + * + * This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. + * + * This file incorporates work covered by the following license notice: + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed + * with this work for additional information regarding copyright + * ownership. The ASF licenses this file to you under the Apache + * License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of + * the License at http://www.apache.org/licenses/LICENSE-2.0 . + */ + +#include <stdio.h> +#include <string.h> + +#include <osl/diagnose.h> + +#include <cppuhelper/factory.hxx> + +using namespace ::cppu; +using namespace ::com::sun::star::registry; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::lang; + +#include "testfactreg.hxx" + + +extern "C" +{ + +sal_Bool SAL_CALL component_writeInfo( + void * pServiceManager, void * pRegistryKey ) +{ + if (pRegistryKey) + { + try + { + Reference< XRegistryKey > xKey( + reinterpret_cast< XRegistryKey * >( pRegistryKey ) ); + + OUString str = "/" + + OPipeTest_getImplementationName() + + "/UNO/SERVICES"; + Reference< XRegistryKey > xNewKey = xKey->createKey( str ); + xNewKey->createKey( OPipeTest_getServiceName() ); + + str = "/" + + OPumpTest_getImplementationName() + + "/UNO/SERVICES"; + xNewKey = xKey->createKey( str ); + xNewKey->createKey( OPumpTest_getServiceName() ); + + str = "/" + + ODataStreamTest_getImplementationName(1) + + "/UNO/SERVICES"; + xNewKey = xKey->createKey( str ); + xNewKey->createKey( ODataStreamTest_getServiceName(1) ); + + str = "/" + + ODataStreamTest_getImplementationName(2) + + "/UNO/SERVICES"; + xNewKey = xKey->createKey( str ); + xNewKey->createKey( ODataStreamTest_getServiceName(2) ); + + str = "/" + + OObjectStreamTest_getImplementationName(1) + + "/UNO/SERVICES"; + xNewKey = xKey->createKey( str ); + xNewKey->createKey( OObjectStreamTest_getServiceName(1) ); + + str = "/" + + OObjectStreamTest_getImplementationName(2) + + "/UNO/SERVICES"; + xNewKey = xKey->createKey( str ); + xNewKey->createKey( OObjectStreamTest_getServiceName(2) ); + + str = "/" + + OMarkableOutputStreamTest_getImplementationName() + + "/UNO/SERVICES"; + xNewKey = xKey->createKey( str ); + xNewKey->createKey( OMarkableOutputStreamTest_getServiceName() ); + + str = "/" + + OMarkableInputStreamTest_getImplementationName() + + "/UNO/SERVICES"; + xNewKey = xKey->createKey( str ); + xNewKey->createKey( OMarkableInputStreamTest_getServiceName() ); + + str = "/" + + OMyPersistObject_getImplementationName() + + "/UNO/SERVICES"; + xNewKey = xKey->createKey( str ); + xNewKey->createKey( OMyPersistObject_getServiceName() ); + + return sal_True; + } + catch (InvalidRegistryException &) + { + OSL_FAIL( "### InvalidRegistryException!" ); + } + } + return sal_False; +} + +SAL_DLLPUBLIC_EXPORT void * SAL_CALL component_getFactory( + const char * pImplName, void * pServiceManager, void * pRegistryKey ) +{ + void * pRet = 0; + + if (pServiceManager ) + { + Reference< XSingleServiceFactory > xRet; + Reference< XMultiServiceFactory > xSMgr = + reinterpret_cast< XMultiServiceFactory * > ( pServiceManager ); + + OUString aImplementationName = OUString::createFromAscii( pImplName ); + + if (aImplementationName == OPipeTest_getImplementationName() ) + { + xRet = createSingleFactory( xSMgr, aImplementationName, + OPipeTest_CreateInstance, + OPipeTest_getSupportedServiceNames() ); + } + else if (aImplementationName == OPumpTest_getImplementationName() ) + { + xRet = createSingleFactory( xSMgr, aImplementationName, + OPumpTest_CreateInstance, + OPumpTest_getSupportedServiceNames() ); + } + + else if( aImplementationName == ODataStreamTest_getImplementationName(1) ) { + xRet = createSingleFactory( xSMgr , aImplementationName, + ODataStreamTest_CreateInstance, + ODataStreamTest_getSupportedServiceNames(1) ); + } + else if( aImplementationName == ODataStreamTest_getImplementationName(2) ) { + xRet = createSingleFactory( xSMgr , aImplementationName, + ODataStreamTest_CreateInstance, + ODataStreamTest_getSupportedServiceNames(2) ); + } + else if( aImplementationName == OObjectStreamTest_getImplementationName(1) ) { + xRet = createSingleFactory( xSMgr , aImplementationName, + OObjectStreamTest_CreateInstance, + OObjectStreamTest_getSupportedServiceNames(1) ); + } + else if( aImplementationName == OObjectStreamTest_getImplementationName(2) ) { + xRet = createSingleFactory( xSMgr , aImplementationName, + OObjectStreamTest_CreateInstance, + OObjectStreamTest_getSupportedServiceNames(2) ); + } + else if( aImplementationName == OMarkableOutputStreamTest_getImplementationName() ) { + xRet = createSingleFactory( xSMgr , aImplementationName, + OMarkableOutputStreamTest_CreateInstance, + OMarkableOutputStreamTest_getSupportedServiceNames() ); + } + else if( aImplementationName == OMarkableInputStreamTest_getImplementationName() ) { + xRet = createSingleFactory( xSMgr , aImplementationName, + OMarkableInputStreamTest_CreateInstance, + OMarkableInputStreamTest_getSupportedServiceNames() ); + } + else if( aImplementationName == OMyPersistObject_getImplementationName() ) { + xRet = createSingleFactory( xSMgr , aImplementationName, + OMyPersistObject_CreateInstance, + OMyPersistObject_getSupportedServiceNames() ); + } + if (xRet.is()) + { + xRet->acquire(); + pRet = xRet.get(); + } + } + + return pRet; +} + +} + +Sequence<sal_Int8 > createSeq( char * p ) +{ + Sequence<sal_Int8> seq( strlen( p )+1 ); + strcpy( (char * ) seq.getArray() , p ); + return seq; +} + +Sequence<sal_Int8> createIntSeq( sal_Int32 i ) +{ + char pcCount[20]; + sprintf( pcCount , "%d" , i ); + return createSeq( pcCount ); +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/test/stm/testfactreg.hxx b/io/test/stm/testfactreg.hxx new file mode 100644 index 0000000000..7952867b49 --- /dev/null +++ b/io/test/stm/testfactreg.hxx @@ -0,0 +1,107 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* + * This file is part of the LibreOffice project. + * + * This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. + * + * This file incorporates work covered by the following license notice: + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed + * with this work for additional information regarding copyright + * ownership. The ASF licenses this file to you under the Apache + * License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of + * the License at http://www.apache.org/licenses/LICENSE-2.0 . + */ + +#pragma once +#include <rtl/strbuf.hxx> + +Reference< XInterface > SAL_CALL OPipeTest_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw( Exception ); +Sequence<OUString> OPipeTest_getSupportedServiceNames() throw(); +OUString OPipeTest_getServiceName() throw(); +OUString OPipeTest_getImplementationName() throw(); + +Reference< XInterface > SAL_CALL OPumpTest_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw( Exception ); +Sequence<OUString> OPumpTest_getSupportedServiceNames() throw(); +OUString OPumpTest_getServiceName() throw(); +OUString OPumpTest_getImplementationName() throw(); + +Reference< XInterface > SAL_CALL ODataStreamTest_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw(Exception); +Sequence<OUString> ODataStreamTest_getSupportedServiceNames( int i) throw(); +OUString ODataStreamTest_getServiceName( int i) throw(); +OUString ODataStreamTest_getImplementationName( int i) throw(); + +Reference< XInterface > SAL_CALL OMarkableOutputStreamTest_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw(Exception); +Sequence<OUString> OMarkableOutputStreamTest_getSupportedServiceNames() throw(); +OUString OMarkableOutputStreamTest_getServiceName() throw(); +OUString OMarkableOutputStreamTest_getImplementationName() throw(); + +Reference< XInterface > SAL_CALL OMarkableInputStreamTest_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw(Exception); +Sequence<OUString> OMarkableInputStreamTest_getSupportedServiceNames() throw(); +OUString OMarkableInputStreamTest_getServiceName() throw(); +OUString OMarkableInputStreamTest_getImplementationName() throw(); + +Reference< XInterface > SAL_CALL OObjectStreamTest_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw(Exception); +Sequence<OUString> OObjectStreamTest_getSupportedServiceNames( int i) throw(); +OUString OObjectStreamTest_getServiceName( int i) throw(); +OUString OObjectStreamTest_getImplementationName( int i) throw(); + +Reference< XInterface > SAL_CALL OMyPersistObject_CreateInstance( const Reference< XMultiServiceFactory > & rSMgr ) throw(Exception); +Sequence<OUString> OMyPersistObject_getSupportedServiceNames( ) throw(); +OUString OMyPersistObject_getServiceName( ) throw(); +OUString OMyPersistObject_getImplementationName( ) throw(); + +Sequence<sal_Int8> createSeq( char * p ); +Sequence<sal_Int8> createIntSeq( sal_Int32 i ); + +#define BUILD_ERROR(expr, Message)\ + {\ + m_seqErrors.realloc( m_seqErrors.getLength() + 1 ); \ + m_seqExceptions.realloc( m_seqExceptions.getLength() + 1 ); \ + OStringBuffer str(128); \ + str.append( __FILE__ );\ + str.append( " " ); \ + str.append( "(" ); \ + str.append( OString::valueOf( (sal_Int32)__LINE__) );\ + str.append(")\n" );\ + str.append( "[ " ); \ + str.append( #expr ); \ + str.append( " ] : " ); \ + str.append( Message ); \ + m_seqErrors.getArray()[ m_seqErrors.getLength()-1] =\ + OStringToOUString( str.makeStringAndClear() , RTL_TEXTENCODING_ASCII_US ); \ + }\ + ((void)0) + + +#define WARNING_ASSERT(expr, Message) \ + if( ! (expr) ) { \ + m_seqWarnings.realloc( m_seqErrors.getLength() +1 ); \ + OStringBuffer str(128);\ + str.append( __FILE__);\ + str.append( " "); \ + str.append( "(" ); \ + str.append(OString::valueOf( (sal_Int32)__LINE__)) ;\ + str.append( ")\n");\ + str.append( "[ " ); \ + str.append( #expr ); \ + str.append( " ] : ") ; \ + str.append( Message); \ + m_seqWarnings.getArray()[ m_seqWarnings.getLength()-1] =\ + OStringToOUString( str.makeStringAndClear() , RTL_TEXTENCODING_ASCII_US ); \ + return; \ + }\ + ((void)0) + +#define ERROR_ASSERT(expr, Message) \ + if( ! (expr) ) { \ + BUILD_ERROR(expr, Message );\ + return; \ + }\ + ((void)0) + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/test/testcomponent.cxx b/io/test/testcomponent.cxx new file mode 100644 index 0000000000..2b317c9034 --- /dev/null +++ b/io/test/testcomponent.cxx @@ -0,0 +1,206 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* + * This file is part of the LibreOffice project. + * + * This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. + * + * This file incorporates work covered by the following license notice: + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed + * with this work for additional information regarding copyright + * ownership. The ASF licenses this file to you under the Apache + * License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of + * the License at http://www.apache.org/licenses/LICENSE-2.0 . + */ + + +// testcomponent - Loads a service and its testcomponent from dlls performs a test. +// Expands the dll-names depending on the actual environment. +// Example : testcomponent com.sun.star.io.Pipe stm +// +// Therefore the testcode must exist in teststm and the testservice must be named test.com.sun.star.io.Pipe + +#include <stdio.h> +#include <com/sun/star/registry/XImplementationRegistration.hpp> +#include <com/sun/star/lang/XComponent.hpp> + +#include <com/sun/star/test/XSimpleTest.hpp> + +#include <cppuhelper/servicefactory.hxx> + +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::test; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::registry; + +// Needed to switch on solaris threads + +int main (int argc, char **argv) +{ + + if( argc < 3) { + printf( "usage : testcomponent service dll [additional dlls]\n" ); + exit( 0 ); + } + + // create service manager + Reference< XMultiServiceFactory > xSMgr = createRegistryServiceFactory( + OUString( "applicat.rdb" ) ); + + Reference < XImplementationRegistration > xReg; + Reference < XSimpleRegistry > xSimpleReg; + + try + { + // Create registration service + Reference < XInterface > x = xSMgr->createInstance( + "com.sun.star.registry.ImplementationRegistration" ); + xReg.set( x , UNO_QUERY ); + } + catch( Exception & ) { + printf( "Couldn't create ImplementationRegistration service\n" ); + exit(1); + } + + char szBuf[1024]; + OString sTestName; + + try + { + // Load dll for the tested component + for( int n = 2 ; n <argc ; n ++ ) { + OUString aDllName = OStringToOUString( argv[n] , RTL_TEXTENCODING_ASCII_US ); + xReg->registerImplementation( + OUString("com.sun.star.loader.SharedLibrary"), + aDllName, + xSimpleReg ); + } + } + catch( const Exception &e ) { + printf( "%s\n" , OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ).getStr() ); + + exit(1); + } + + + try + { + // Load dll for the test component + sTestName = "test"; + sTestName += argv[2]; + +#if defined(_WIN32) + OUString aDllName = OStringToOUString( sTestName , RTL_TEXTENCODING_ASCII_US ); +#else + OUString aDllName("lib"); + aDllName += OStringToOUString( sTestName , RTL_TEXTENCODING_ASCII_US ); + aDllName += ".so"; +#endif + + xReg->registerImplementation( + OUString("com.sun.star.loader.SharedLibrary") , + aDllName, + xSimpleReg ); + } + catch( Exception & ) + { + printf( "Couldn't reach dll %s\n" , szBuf ); + exit(1); + } + + + // Instantiate test service + sTestName = "test."; + sTestName += argv[1]; + + Reference < XInterface > xIntTest = + xSMgr->createInstance( OStringToOUString( sTestName , RTL_TEXTENCODING_ASCII_US ) ); + Reference< XSimpleTest > xTest( xIntTest , UNO_QUERY ); + + if( ! xTest.is() ) { + printf( "Couldn't instantiate test service \n" ); + exit( 1 ); + } + + + sal_Int32 nHandle = 0; + sal_Int32 nNewHandle; + sal_Int32 nErrorCount = 0; + sal_Int32 nWarningCount = 0; + + // loop until all test are performed + while( nHandle != -1 ) + { + // Instantiate service + Reference< XInterface > x = + xSMgr->createInstance( OStringToOUString( argv[1] , RTL_TEXTENCODING_ASCII_US ) ); + if( ! x.is() ) + { + printf( "Couldn't instantiate service !\n" ); + exit( 1 ); + } + + // do the test + try + { + nNewHandle = xTest->test( + OStringToOUString( argv[1] , RTL_TEXTENCODING_ASCII_US ) , x , nHandle ); + } + catch( const Exception & e ) { + OString o = OUStringToOString( e.Message, RTL_TEXTENCODING_ASCII_US ); + printf( "testcomponent : uncaught exception %s\n" , o.getStr() ); + exit(1); + } + catch( ... ) + { + printf( "testcomponent : uncaught unknown exception\n" ); + exit(1); + } + + + // print errors and warning + Sequence<OUString> seqErrors = xTest->getErrors(); + Sequence<OUString> seqWarnings = xTest->getWarnings(); + if( seqWarnings.getLength() > nWarningCount ) + { + printf( "Warnings during test %d!\n" , nHandle ); + for( ; nWarningCount < seqWarnings.getLength() ; nWarningCount ++ ) + { + OString o = OUStringToOString( + seqWarnings.getArray()[nWarningCount], RTL_TEXTENCODING_ASCII_US ); + printf( "Warning\n%s\n---------\n" , o.getStr() ); + } + } + + + if( seqErrors.getLength() > nErrorCount ) { + printf( "Errors during test %d!\n" , nHandle ); + for( ; nErrorCount < seqErrors.getLength() ; nErrorCount ++ ) + { + OString o = OUStringToOString( + seqErrors.getArray()[nErrorCount], RTL_TEXTENCODING_ASCII_US ); + printf( "%s\n" , o.getStr() ); + } + } + + nHandle = nNewHandle; + } + + if( xTest->testPassed() ) { + printf( "Test passed !\n" ); + } + else { + printf( "Test failed !\n" ); + } + + Reference <XComponent > rComp( xSMgr , UNO_QUERY ); + rComp->dispose(); + return 0; +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/io/test/testconnection.cxx b/io/test/testconnection.cxx new file mode 100644 index 0000000000..4131bcf74d --- /dev/null +++ b/io/test/testconnection.cxx @@ -0,0 +1,257 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* + * This file is part of the LibreOffice project. + * + * This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. + * + * This file incorporates work covered by the following license notice: + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed + * with this work for additional information regarding copyright + * ownership. The ASF licenses this file to you under the Apache + * License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of + * the License at http://www.apache.org/licenses/LICENSE-2.0 . + */ + +#include <stdio.h> +#include <osl/time.h> + +#include <osl/diagnose.h> +#include <osl/thread.hxx> + +#include <com/sun/star/io/IOException.hpp> +#include <com/sun/star/lang/IllegalArgumentException.hpp> +#include <com/sun/star/lang/XComponent.hpp> +#include <com/sun/star/lang/XMultiServiceFactory.hpp> +#include <com/sun/star/uno/XComponentContext.hpp> + +#include <com/sun/star/connection/AlreadyAcceptingException.hpp> +#include <com/sun/star/connection/ConnectionSetupException.hpp> +#include <com/sun/star/connection/XConnector.hpp> +#include <com/sun/star/connection/XAcceptor.hpp> + +#include <cppuhelper/bootstrap.hxx> + +using namespace ::osl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::connection; + + +namespace { + +class MyThread : + public Thread +{ +public: + MyThread( const Reference< XAcceptor > &r , const OUString & sConnectionDescription) : + m_rAcceptor( r ), + m_sConnectionDescription( sConnectionDescription ) + {} + virtual void SAL_CALL run(); + + Reference < XAcceptor > m_rAcceptor; +private: + Reference < XConnection > m_rConnection; + OUString m_sConnectionDescription; +}; + +void doWrite( const Reference < XConnection > &r ) +{ + Sequence < sal_Int8 > seq(10); + for( sal_Int32 i = 0 ; i < 10 ; i ++ ) + { + seq.getArray()[i] = i; + } + + r->write( seq ); +} + +void doRead( const Reference < XConnection > &r ) +{ + Sequence < sal_Int8 > seq(10); + + OSL_ASSERT( 10 == r->read( seq , 10 ) ); + + for( sal_Int32 i = 0 ; i < 10 ; i ++ ) + { + OSL_ASSERT( seq.getConstArray()[i] == i ); + } +} + + +void MyThread::run() +{ + try + { + m_rConnection = m_rAcceptor->accept( m_sConnectionDescription ); + } + catch ( const Exception &e) + { + OString tmp= OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); + printf( "Exception was thrown by acceptor thread: %s\n", tmp.getStr() ); + } + + if( m_rConnection.is() ) + { + try + { + doWrite( m_rConnection ); + doRead( m_rConnection ); + } + catch (... ) + { + printf( "unknown exception was thrown\n" ); + throw; + } + } + +} + + +void testConnection( const OUString &sConnectionDescription , + const Reference < XAcceptor > &rAcceptor, + const Reference < XConnector > &rConnector ) +{ + MyThread thread( rAcceptor , sConnectionDescription ); + thread.create(); + + bool bGotit = false; + Reference < XConnection > r; + + while( ! bGotit ) + { + try + { + // Why is this wait necessary ???? + osl::Thread::wait(std::chrono::seconds(1)); + r = rConnector->connect( sConnectionDescription ); + OSL_ASSERT( r.is() ); + doWrite( r ); + doRead( r ); + bGotit = true; + } + catch( ... ) + { + printf( "Couldn't connect, retrying ...\n" ); + + } + } + + r->close(); + + try + { + Sequence < sal_Int8 > seq(10); + r->write( seq ); + OSL_FAIL( "expected exception not thrown" ); + } + catch ( IOException & ) + { + // everything is ok + } + catch ( ... ) + { + OSL_FAIL( "wrong exception was thrown" ); + } + + thread.join(); +} + +} + + +int main() +{ + Reference< XMultiServiceFactory > xMgr( + defaultBootstrap_InitialComponentContext()->getServiceManager(), UNO_QUERY ); + + Reference < XAcceptor > rAcceptor( + xMgr->createInstance( "com.sun.star.connection.Acceptor" ) , UNO_QUERY ); + + Reference < XAcceptor > rAcceptorPipe( + xMgr->createInstance( "com.sun.star.connection.Acceptor" ) , UNO_QUERY ); + + Reference < XConnector > rConnector( + xMgr->createInstance("com.sun.star.connection.Connector") , UNO_QUERY ); + + + printf( "Testing sockets" ); + fflush( stdout ); + testConnection( "socket,host=localhost,port=2001", rAcceptor , rConnector ); + printf( " Done\n" ); + + printf( "Testing pipe" ); + fflush( stdout ); + testConnection( "pipe,name=bla" , rAcceptorPipe , rConnector ); + printf( " Done\n" ); + + // check, if erroneous strings make any problem + rAcceptor.set( + xMgr->createInstance("com.sun.star.connection.Acceptor"), + UNO_QUERY ); + + try + { + rAcceptor->accept( OUString() ); + OSL_FAIL( "empty connection string" ); + } + catch( IllegalArgumentException & ) + { + // everything is fine + } + catch( ... ) + { + OSL_FAIL( "unexpected akexception with empty connection string" ); + } + + try + { + rConnector->connect( OUString() ); + OSL_FAIL( "empty connection string" ); + } + catch( ConnectionSetupException & ) + { + // everything is fine + } + catch( ... ) + { + OSL_FAIL( "unexpected exception with empty connection string" ); + } + + + MyThread thread( rAcceptor , "socket,host=localhost,port=2001" ); + thread.create(); + + osl::Thread::wait(std::chrono::seconds(1)); + try + { + rAcceptor->accept( "socket,host=localhost,port=2001" ); + OSL_FAIL( "already existing exception expected" ); + } + catch( AlreadyAcceptingException & ) + { + // everything is fine + } + catch( ... ) + { + OSL_FAIL( "unknown exception, already existing exception expected" ); + } + + rAcceptor->stopAccepting(); + thread.join(); + + Reference < XComponent > rComp( xMgr , UNO_QUERY ); + if( rComp.is() ) + { + rComp->dispose(); + } +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ |