| /************************************************************** |
| * |
| * 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 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| *************************************************************/ |
| |
| |
| |
| // MARKER(update_precomp.py): autogen include statement, do not remove |
| #include "precompiled_io.hxx" |
| |
| #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/implbase1.hxx> |
| #include <cppuhelper/implbase2.hxx> |
| |
| #include <osl/conditn.hxx> |
| #include <osl/mutex.hxx> |
| |
| #include <string.h> |
| |
| using namespace ::rtl; |
| using namespace ::osl; |
| using namespace ::cppu; |
| //using namespace ::vos; |
| 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 stardiv.uno.io.pipe. If problems occur, make sure to run also the |
| * pipe test routines ( test.com.sun.star.io.pipe ). |
| * |
| * |
| *****/ |
| |
| class ODataStreamTest : |
| public WeakImplHelper1< XSimpleTest > |
| { |
| public: |
| 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(void) throw ( RuntimeException); |
| virtual Sequence< OUString > SAL_CALL getErrors(void) throw (RuntimeException); |
| virtual Sequence< Any > SAL_CALL getErrorExceptions(void) throw (RuntimeException); |
| virtual Sequence< OUString > SAL_CALL getWarnings(void) 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::createFromAscii("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::createFromAscii("com.sun.star.io.DataInputStream") == 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( OUString::createFromAscii("bla bluzb") ) , "XServiceInfo test failed" ); |
| } |
| |
| } |
| |
| |
| sal_Int32 ODataStreamTest::test( |
| const OUString& TestName, |
| const Reference < XInterface >& TestObject, |
| sal_Int32 hTestHandle) |
| throw ( IllegalArgumentException, |
| RuntimeException) |
| { |
| if( OUString::createFromAscii("com.sun.star.io.DataInputStream") == TestName || |
| OUString::createFromAscii("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( |
| OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.Pipe" ))); |
| |
| Reference < XInputStream > rPipeInput( x , UNO_QUERY ); |
| Reference < XOutputStream > rPipeOutput( x , UNO_QUERY ); |
| |
| if( ! rSink.is() ) { |
| x = m_rFactory->createInstance( |
| OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.DataInputStream")) ); |
| rInput = Reference < XDataInputStream > ( x , UNO_QUERY); |
| rSink = Reference< XActiveDataSink > ( x , UNO_QUERY ); |
| } |
| else if ( !rSource.is() ) |
| { |
| x = m_rFactory->createInstance( |
| OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.DataOutputStream") ) ); |
| rOutput = Reference< XDataOutputStream > ( x , UNO_QUERY ); |
| rSource = Reference< XActiveDataSource > ( 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( 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(void) throw (RuntimeException) |
| { |
| return m_seqErrors.getLength() == 0; |
| } |
| |
| |
| Sequence< OUString > ODataStreamTest::getErrors(void) throw (RuntimeException) |
| { |
| return m_seqErrors; |
| } |
| |
| |
| Sequence< Any > ODataStreamTest::getErrorExceptions(void) throw (RuntimeException) |
| { |
| return m_seqExceptions; |
| } |
| |
| |
| Sequence< OUString > ODataStreamTest::getWarnings(void) 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::createFromAscii("Live long and prosper !") ); |
| ERROR_ASSERT( rInput->readUTF() == OUString::createFromAscii("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) |
| { |
| ODataStreamTest *p = new ODataStreamTest( rSMgr ); |
| return Reference < XInterface > ( SAL_STATIC_CAST( OWeakObject * , p ) ); |
| } |
| |
| Sequence<OUString> ODataStreamTest_getSupportedServiceNames( int i) throw () |
| { |
| Sequence<OUString> aRet(1); |
| |
| aRet.getArray()[0] = ODataStreamTest_getImplementationName( i); |
| |
| |
| return aRet; |
| } |
| |
| OUString ODataStreamTest_getServiceName( int i) throw () |
| { |
| if( 1 == i ) { |
| return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.DataInputStream" )); |
| } |
| else { |
| return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.DataOutputStream" )); |
| } |
| } |
| |
| OUString ODataStreamTest_getImplementationName( int i) throw () |
| { |
| if( 1 == i ) { |
| return OUString( |
| RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.comp.extensions.stm.DataInputStream") ); |
| } |
| else { |
| return OUString( RTL_CONSTASCII_USTRINGPARAM( |
| "test.com.sun.star.comp.extensions.stm.DataOutputStream" ) ); |
| } |
| } |
| |
| |
| /**------------------------------------------------------ |
| * |
| * |
| * |
| * |
| * |
| *------------------------------------------------------*/ |
| class MyPersistObject : public WeakImplHelper2< 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( RTL_CONSTASCII_USTRINGPARAM( "foo" ) ) ) |
| {} |
| MyPersistObject( const OUString & sServiceName ) : m_sServiceName( sServiceName ) |
| {} |
| |
| |
| public: |
| virtual OUString SAL_CALL getServiceName(void) 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(void) |
| 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(void) |
| throw (RuntimeException) |
| { |
| return Reference< XPropertySetInfo >(); |
| } |
| |
| void MyPersistObject::setPropertyValue( |
| const OUString& aPropertyName, |
| const Any& aValue) |
| throw ( UnknownPropertyException, |
| PropertyVetoException, |
| IllegalArgumentException, |
| WrappedTargetException, |
| RuntimeException) |
| { |
| if( 0 == aPropertyName.compareToAscii("long") ) { |
| aValue >>= m_l; |
| } |
| else if ( 0 == aPropertyName.compareToAscii("float") ) { |
| aValue >>= m_f; |
| } |
| else if( 0 == aPropertyName.compareToAscii("double") ) { |
| aValue >>= m_d; |
| } |
| else if( 0 == aPropertyName.compareToAscii("bool") ) { |
| aValue >>= m_b; |
| } |
| else if( 0 == aPropertyName.compareToAscii("byte" ) ) { |
| aValue >>= m_byte; |
| } |
| else if( 0 == aPropertyName.compareToAscii("char") ) { |
| aValue >>= m_c; |
| } |
| else if( 0 == aPropertyName.compareToAscii("string") ) { |
| aValue >>= m_s; |
| } |
| else if( 0 == aPropertyName.compareToAscii("object") ) { |
| if( aValue.getValueType() == getCppuType( (Reference< XPersistObject> *)0 ) ) |
| { |
| aValue >>= m_ref; |
| } |
| else |
| { |
| m_ref = 0; |
| } |
| } |
| } |
| |
| |
| Any MyPersistObject::getPropertyValue(const OUString& aPropertyName) |
| throw ( UnknownPropertyException, |
| WrappedTargetException, |
| RuntimeException) |
| { |
| Any aValue; |
| if( 0 == aPropertyName.compareToAscii("long" ) ) { |
| aValue <<= m_l; |
| } |
| else if ( 0 == aPropertyName.compareToAscii("float") ) { |
| aValue <<= m_f; |
| } |
| else if( 0 == aPropertyName.compareToAscii("double") ) { |
| aValue <<= m_d; |
| } |
| else if( 0 == aPropertyName.compareToAscii("bool") ) { |
| aValue <<= m_b; |
| } |
| else if( 0 == aPropertyName.compareToAscii("byte") ) { |
| aValue <<= m_byte; |
| } |
| else if( 0 == aPropertyName.compareToAscii("char" ) ) { |
| aValue <<= m_c; |
| } |
| else if( 0 == aPropertyName.compareToAscii("string") ) { |
| aValue <<= m_s; |
| } |
| else if( 0 == aPropertyName.compareToAscii("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) |
| { |
| MyPersistObject *p = new MyPersistObject( ); |
| return Reference < XInterface > ( SAL_STATIC_CAST( OWeakObject * , p ) ); |
| } |
| |
| Sequence<OUString> OMyPersistObject_getSupportedServiceNames( ) throw () |
| { |
| Sequence<OUString> aRet(1); |
| aRet.getArray()[0] = OMyPersistObject_getImplementationName(); |
| return aRet; |
| } |
| |
| OUString OMyPersistObject_getServiceName( ) throw () |
| { |
| return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.PersistTest" )); |
| } |
| |
| OUString OMyPersistObject_getImplementationName( ) throw () |
| { |
| return OUString( RTL_CONSTASCII_USTRINGPARAM( "test.com.sun.star.io.PersistTest" ) ); |
| } |
| |
| |
| // --------------------------------------------- |
| // ----------------------------------------------- |
| class OObjectStreamTest : |
| public ODataStreamTest |
| { |
| public: |
| 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 OObjectStreamTest::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( RTL_CONSTASCII_USTRINGPARAM( "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( RTL_CONSTASCII_USTRINGPARAM("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( OUString::createFromAscii("bla bluzb") ) , "XServiceInfo test failed" ); |
| } |
| |
| } |
| |
| sal_Int32 OObjectStreamTest::test( const OUString& TestName, |
| const Reference < XInterface >& TestObject, |
| sal_Int32 hTestHandle) |
| throw ( IllegalArgumentException, |
| RuntimeException) |
| { |
| if( 0 == TestName.compareToAscii("com.sun.star.io.ObjectInputStream") || |
| 0 == TestName.compareToAscii("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( RTL_CONSTASCII_USTRINGPARAM("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( |
| OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.Pipe" )) ); |
| |
| Reference <XInputStream > rPipeInput( x , UNO_QUERY ); |
| Reference <XOutputStream > rPipeOutput( x , UNO_QUERY ); |
| |
| x = m_rFactory->createInstance( |
| OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.MarkableInputStream") ) ); |
| |
| Reference <XInputStream > markableInput( x , UNO_QUERY ); |
| Reference <XActiveDataSink> markableSink( x , UNO_QUERY ); |
| |
| x = m_rFactory->createInstance( OUString( |
| RTL_CONSTASCII_USTRINGPARAM("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( |
| OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.ObjectInputStream") )); |
| rInput = Reference < XObjectInputStream > ( x , UNO_QUERY ); |
| rSink = Reference < XActiveDataSink > ( x , UNO_QUERY ); |
| } |
| else if ( !rSource.is() ) { |
| x = m_rFactory->createInstance( |
| OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.ObjectOutputStream" ))); |
| rOutput = Reference <XObjectOutputStream > ( x , UNO_QUERY ); |
| rSource = Reference <XActiveDataSource>( 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( 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( OUString::createFromAscii("long") ).getValueType() == getCppuVoidType() || |
| r2->getPropertyValue( OUString::createFromAscii("long") ).getValueType() == getCppuVoidType() ) { |
| |
| // one of the objects is not the correct propertyset ! |
| fprintf( stderr, "compareMyPropertySet: 1\n" ); |
| return sal_False; |
| } |
| |
| b = b && ( r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("long")) ) == |
| r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("long")) ) ); |
| if( ! b ) fprintf( stderr, "compareMyPropertySet: 2\n" ); |
| |
| b = b && ( r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("float")) ) == |
| r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("float")) ) ); |
| if( ! b ){ |
| float f1(0.0); |
| float f2(0.0); |
| r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("float")) ) >>= f1; |
| r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("float")) ) >>= f2; |
| fprintf( stderr, "compareMyPropertySet: %f %f 3\n",f1,f2 ); |
| } |
| |
| b = b && ( r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("double")) ) == |
| r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("double" ))) ); |
| if( ! b ) fprintf( stderr, "compareMyPropertySet: 4\n" ); |
| |
| sal_Bool b1(sal_False), b2(sal_False); |
| Any a =r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("bool")) ); |
| a >>= b1; |
| a = r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("bool")) ); |
| a >>= b2; |
| b = b && ( (b1 && b2) || b1 == b2 ); |
| if( ! b ) fprintf( stderr, "compareMyPropertySet: 5\n" ); |
| |
| // b = b && r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("bool")) ) == |
| // r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("bool")) ) ); |
| |
| b = b && ( r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("byte")) ) == |
| r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("byte")) ) ); |
| if( ! b ) fprintf( stderr, "compareMyPropertySet: 6\n" ); |
| |
| b = b && ( r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("char")) ) == |
| r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("char")) ) ); |
| if( ! b ) fprintf( stderr, "compareMyPropertySet: 7\n" ); |
| |
| b = b && ( r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("string")) ) == |
| r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("string")) )); |
| if( ! b ) fprintf( stderr, "compareMyPropertySet: 8\n" ); |
| |
| Any o1 = r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("object")) ); |
| Any o2 = r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("object")) ); |
| |
| if( o1.getValueType() == getCppuType( (Reference<XPersistObject>*)0 ) ) { |
| |
| if( o2.getValueType() == getCppuType( (Reference<XPersistObject>*)0 ) ) { |
| 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() == getCppuType( (Reference<XPersistObject>*)0 ) ) { |
| 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( RTL_CONSTASCII_USTRINGPARAM("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( |
| OUString( RTL_CONSTASCII_USTRINGPARAM("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( OUString( RTL_CONSTASCII_USTRINGPARAM("long")) , any ); |
| |
| float f = (float)42.23; |
| any <<= f; |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("float")) , any ); |
| |
| double d = 233.321412; |
| any <<= d; |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("double")) , any ); |
| |
| sal_Bool b = sal_True; |
| any.setValue( &b , getCppuBooleanType() ); |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("bool")) , any ); |
| |
| sal_Int8 by = 120; |
| any <<= by; |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("byte")) , any ); |
| |
| sal_Unicode c = 'h'; |
| any.setValue( &c , getCppuCharType() ); |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("char")) , any ); |
| |
| OUString str( RTL_CONSTASCII_USTRINGPARAM( "hi du !" ) ); |
| any <<= str; |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("string")) , any ); |
| |
| any <<= persistRef; |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("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( OUString::createFromAscii("object"), Any() ); |
| rPropRead->setPropertyValue( OUString::createFromAscii("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(OUString::createFromAscii("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( OUString( RTL_CONSTASCII_USTRINGPARAM("long")) , any ); |
| |
| float f = 42.23; |
| any <<= f; |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("float")) , any ); |
| |
| double d = 233.321412; |
| any <<= d; |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("double")) , any ); |
| |
| sal_Bool b = sal_True; |
| any.setValue( &b , getCppuBooleanType() ); |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("bool")) , any ); |
| |
| sal_Int8 by = 120; |
| any <<= by; |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("byte")) , any ); |
| |
| sal_Unicode c = 'h'; |
| any.setValue( &c , getCppuCharType() ); |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("char")) , any ); |
| |
| OUString str( RTL_CONSTASCII_USTRINGPARAM( "hi du !" ) ); |
| any <<= str; |
| rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("string")) , any ); |
| |
| x = m_rFactory->createInstance(OUString::createFromAscii("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( OUString::createFromAscii("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) |
| { |
| OObjectStreamTest *p = new OObjectStreamTest( rSMgr ); |
| return Reference < XInterface > ( SAL_STATIC_CAST( OWeakObject * , p ) ); |
| } |
| |
| Sequence<OUString> OObjectStreamTest_getSupportedServiceNames( int i) throw () |
| { |
| Sequence<OUString> aRet(1); |
| aRet.getArray()[0] = OObjectStreamTest_getImplementationName( i); |
| return aRet; |
| } |
| |
| OUString OObjectStreamTest_getServiceName( int i) throw () |
| { |
| if( 1 == i ) { |
| return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.ObjectInputStream" )); |
| } |
| else { |
| return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.ObjectOutputStream")); |
| } |
| } |
| |
| OUString OObjectStreamTest_getImplementationName( int i) throw () |
| { |
| if( 1 == i ) { |
| return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.comp.extensions.stm.ObjectInputStream" )); |
| } |
| else { |
| return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.comp.extensions.stm.ObjectOutputStream")); |
| } |
| } |
| |
| |