/**************************************************************
 * 
 * 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_extensions.hxx"
#include <smart/com/sun/star/test/XSimpleTest.hxx>
#include <smart/com/sun/star/io/XObjectOutputStream.hxx>
#include <smart/com/sun/star/io/XObjectInputStream.hxx>
#include <smart/com/sun/star/io/XActiveDataSink.hxx>
#include <smart/com/sun/star/io/XActiveDataSource.hxx>
#include <smart/com/sun/star/io/XConnectable.hxx>
#include <smart/com/sun/star/io/XMarkableStream.hxx>

#include <smart/com/sun/star/lang/XServiceInfo.hxx>

#include <smart/com/sun/star/beans/XPropertySet.hxx>

#include <usr/services.hxx>
#include <usr/factoryhlp.hxx>

#include <usr/reflserv.hxx>  // for EXTERN_SERVICE_CALLTYPE
#include <usr/weak.hxx>      // OWeakObject

#include <vos/conditn.hxx>
#include <vos/mutex.hxx>
#include <vos/thread.hxx>

#include <string.h>

#include "testfactreg.hxx"

using namespace vos;
using namespace usr;

#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 XSimpleTest,
        public OWeakObject
{
public:
	ODataStreamTest( const XMultiServiceFactoryRef & rFactory ) : m_rFactory( rFactory ){}

public: // refcounting
	BOOL						queryInterface( Uik aUik, XInterfaceRef & rOut );
	void 						acquire() 						 { OWeakObject::acquire(); }
	void 						release() 						 { OWeakObject::release(); }
	void* 						getImplementation(Reflection *p) { return OWeakObject::getImplementation(p); }

public:
    virtual void testInvariant(const UString& TestName, const XInterfaceRef& TestObject)
    															THROWS( (	IllegalArgumentException,
    																		UsrSystemException) );

    virtual INT32 test(	const UString& TestName,
    					const XInterfaceRef& TestObject,
    					INT32 hTestHandle) 						THROWS( (	IllegalArgumentException,
    																		UsrSystemException) );

    virtual BOOL testPassed(void) 								THROWS( (	UsrSystemException) );
    virtual Sequence< UString > getErrors(void) 				THROWS( (UsrSystemException) );
    virtual Sequence< UsrAny > getErrorExceptions(void) 		THROWS( (UsrSystemException) );
    virtual Sequence< UString > getWarnings(void) 				THROWS( (UsrSystemException) );

private:
	void testSimple( const XDataInputStreamRef & , const XDataOutputStreamRef &);

protected:
	Sequence<UsrAny>  m_seqExceptions;
	Sequence<UString> m_seqErrors;
	Sequence<UString> m_seqWarnings;

	XMultiServiceFactoryRef m_rFactory;
};


BOOL ODataStreamTest::queryInterface( Uik uik , XInterfaceRef &rOut )
{
	if( XSimpleTest::getSmartUik() == uik ) {
		rOut = (XSimpleTest *) this;
	}
	else {
		return OWeakObject::queryInterface( uik , rOut );
	}
	return TRUE;
}


void ODataStreamTest::testInvariant( const UString& TestName, const XInterfaceRef& TestObject )
    															THROWS( (	IllegalArgumentException,
    																		UsrSystemException) )
{
	if( L"com.sun.star.io.DataInputStream" == TestName ) {
		XConnectableRef connect( TestObject , USR_QUERY );
		XActiveDataSinkRef active( TestObject , USR_QUERY );
		XInputStreamRef input( TestObject , USR_QUERY );
		XDataInputStreamRef dataInput( TestObject , USR_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( L"com.sun.star.io.DataInputStream" == TestName ) {
		XConnectableRef connect( TestObject , USR_QUERY );
		XActiveDataSourceRef active( TestObject , USR_QUERY );
		XOutputStreamRef output( TestObject , USR_QUERY );
		XDataOutputStreamRef dataOutput( TestObject , USR_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" );

	}

	XServiceInfoRef info( TestObject, USR_QUERY );
	ERROR_ASSERT( info.is() , "XServiceInfo not supported !" );
	if( info.is() )
	{
		ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" );
		ERROR_ASSERT( ! info->supportsService( L"bla bluzb" ) , "XServiceInfo test failed" );
	}

}


INT32 ODataStreamTest::test(	const UString& TestName,
    					const XInterfaceRef& TestObject,
    					INT32 hTestHandle) 						THROWS( (	IllegalArgumentException,
    																		UsrSystemException) )
{
	if( L"com.sun.star.io.DataInputStream" == TestName || 
		L"com.sun.star.io.DataOutputStream" == TestName )  {
		
		try {
			if( 0 == hTestHandle ) {
				testInvariant( TestName , TestObject );
			}
			else {
				XActiveDataSinkRef rSink( TestObject, USR_QUERY );
				XActiveDataSourceRef rSource( TestObject , USR_QUERY );

				XDataInputStreamRef rInput( TestObject , USR_QUERY );
				XDataOutputStreamRef rOutput( TestObject , USR_QUERY );

				
				XInterfaceRef x = m_rFactory->createInstance( L"com.sun.star.io.Pipe");

				XInputStreamRef  rPipeInput( x , USR_QUERY );
				XOutputStreamRef rPipeOutput( x , USR_QUERY );
				
				if( ! rSink.is() ) {					
					x = m_rFactory->createInstance( L"com.sun.star.io.DataInputStream" );
					x->queryInterface( XDataInputStream::getSmartUik() , rInput );
					x->queryInterface( XActiveDataSink::getSmartUik() , rSink );
				}
				else if ( !rSource.is() ) {

					x = m_rFactory->createInstance( L"com.sun.star.io.DataOutputStream" );
					x->queryInterface( XDataOutputStream::getSmartUik() , rOutput );
					x->queryInterface( XActiveDataSource::getSmartUik() , rSource );
				}

				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 )  {
			BUILD_ERROR( 0 , UStringToString( e.getName() , CHARSET_SYSTEM ).GetCharStr() );
		}
		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;
}													


BOOL ODataStreamTest::testPassed(void) 										THROWS( (UsrSystemException) )
{
	return m_seqErrors.getLen() == 0;	
}


Sequence< UString > ODataStreamTest::getErrors(void) 							THROWS( (UsrSystemException) )
{
	return m_seqErrors;
}


Sequence< UsrAny > ODataStreamTest::getErrorExceptions(void) 					THROWS( (UsrSystemException) )
{
	return m_seqExceptions;
}


Sequence< UString > ODataStreamTest::getWarnings(void) 						THROWS( (UsrSystemException) )
{
	return m_seqWarnings;
}

void ODataStreamTest::testSimple( 	const XDataInputStreamRef &rInput, 
									const XDataOutputStreamRef &rOutput )
{
	rOutput->writeLong( 0x34ff3c );
	rOutput->writeLong( 0x34ff3d );

	ERROR_ASSERT( 0x34ff3c ==  rInput->readLong() , "long read/write mismatch" );
	ERROR_ASSERT( 0x34ff3d ==  rInput->readLong() , "long read/write mismatch" );
	
	rOutput->writeByte( 0x87 );
	ERROR_ASSERT( 0x87 == rInput->readByte() , "byte read/write mismatch" );
	
	rOutput->writeBoolean( 25 );
	ERROR_ASSERT( rInput->readBoolean() , "boolean read/write mismatch" );
	
	rOutput->writeBoolean( 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->writeUTF( L"Live long and prosper !" );
	ERROR_ASSERT( rInput->readUTF() == L"Live long and prosper !" ,
					"UTF read/write mismatch" );
	
	Sequence<wchar_t> wc(0x10001);
	for( int i = 0 ; i < 0x10000  ; i ++ ) {
		wc.getArray()[i] = L'c';	
	}
	wc.getArray()[0x10000] = 0;
	UString 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& e ){
		//ok	
		e.getName();
	}
	catch(...)	{
		ERROR_ASSERT( 0 , "wrong exception after reading beyond eof" );
	}
	
	ERROR_ASSERT( ! rInput->readBytes( Sequence<BYTE> (1) , 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& e ) 
	{
		e.getName();
		// ok	
	}
	catch( ... ) {
		ERROR_ASSERT( 0 , "IOException	expected, but another exception was thrown" );
	}
	
}


/** 
* for external binding
*
*
**/
XInterfaceRef ODataStreamTest_CreateInstance( const XMultiServiceFactoryRef & rSMgr ) THROWS((Exception))
{	
	ODataStreamTest *p = new ODataStreamTest( rSMgr );
	XInterfaceRef xService = *p;	
	return xService;
}

Sequence<UString> ODataStreamTest_getSupportedServiceNames( int i) THROWS( () )
{
	Sequence<UString> aRet(1);
	
	aRet.getArray()[0] = ODataStreamTest_getImplementationName( i);
	
	
	return aRet;
}

UString     ODataStreamTest_getServiceName( int i) THROWS( () )
{
	if( 1 == i ) {
		return L"test.com.sun.star.io.DataInputStream";
	} 
	else {
		return L"test.com.sun.star.io.DataOutputStream";	
	}
}

UString 	ODataStreamTest_getImplementationName( int i) THROWS( () )
{
	if( 1 == i ) {
		return L"test.com.sun.star.comp.extensions.stm.DataInputStream";
	}
	else {
		return L"test.com.sun.star.comp.extensions.stm.DataOutputStream";	
	}
}


/**------------------------------------------------------
*
*
*
*
*
*------------------------------------------------------*/
class MyPersistObject : 
			public XPersistObject,
			public XPropertySet,
			public OWeakObject
{
public:
	MyPersistObject( ) : m_sServiceName( OMyPersistObject_getServiceName() )
		{}
	MyPersistObject( const UString & sServiceName ) : m_sServiceName( sServiceName )
		{}
	~MyPersistObject()
		{}
	
public:
	BOOL						queryInterface( Uik aUik, XInterfaceRef & rOut );
	void 						acquire() 						 { OWeakObject::acquire(); }
	void 						release() 						 { OWeakObject::release(); }
	void* 						getImplementation(Reflection *p) { return OWeakObject::getImplementation(p); }

public:
    virtual UString getServiceName(void) const THROWS( (UsrSystemException) );
    virtual void write(const XObjectOutputStreamRef& OutStream) THROWS( (IOException, UsrSystemException) );
    virtual void read(const XObjectInputStreamRef& InStream) THROWS( (IOException, UsrSystemException) );

public:

    virtual XPropertySetInfoRef getPropertySetInfo(void) const 	THROWS( (UsrSystemException) );
    virtual void setPropertyValue(const UString& aPropertyName, const UsrAny& aValue) 
    															THROWS( (	UnknownPropertyException, 
    																		PropertyVetoException, 
    																		IllegalArgumentException,
    																		WrappedTargetException, 
    																		UsrSystemException) );
    virtual UsrAny getPropertyValue(const UString& PropertyName) const 
    															THROWS( (	UnknownPropertyException, 
    																		WrappedTargetException, 
    																		UsrSystemException) );
    virtual void addPropertyChangeListener(	const UString& aPropertyName, 
    										const XPropertyChangeListenerRef& xListener) 
    															THROWS( (	UnknownPropertyException, 
    																		WrappedTargetException, 
    																		UsrSystemException) );
    virtual void removePropertyChangeListener(	const UString& aPropertyName, 
    											const XPropertyChangeListenerRef& aListener) 
    															THROWS( (	UnknownPropertyException, 
    																		WrappedTargetException, 
    																		UsrSystemException) );
    virtual void addVetoableChangeListener(		const UString& PropertyName, 
    											const XVetoableChangeListenerRef& aListener) 
    															THROWS( (	UnknownPropertyException,
    																		WrappedTargetException, 
    																		UsrSystemException) );
    virtual void removeVetoableChangeListener(	const UString& PropertyName, 
    											const XVetoableChangeListenerRef& aListener) 
    															THROWS( (	UnknownPropertyException, 
    																		WrappedTargetException, 
    																		UsrSystemException) );

public:
	INT32	m_l;
	float	m_f;
	double	m_d;
	BOOL	m_b;
	BYTE	m_byte;
	wchar_t	m_c;
	UString	m_s;
	XPersistObjectRef 	m_ref;
	UString m_sServiceName;
};


XPropertySetInfoRef MyPersistObject::getPropertySetInfo(void) const 	THROWS( (UsrSystemException) )
{
	return XPropertySetInfoRef();	
}

void MyPersistObject::setPropertyValue(const UString& aPropertyName, const UsrAny& aValue) 
    															THROWS( (	UnknownPropertyException, 
    																		PropertyVetoException, 
    																		IllegalArgumentException,
    																		WrappedTargetException, 
    																		UsrSystemException) )
{
	if( L"long" == aPropertyName  ) {
		m_l = aValue.getINT32();	
	}
	else if ( L"float" == aPropertyName ) {
		m_f = aValue.getFloat();	
	}
	else if( L"double" == aPropertyName ) {
		m_d = aValue.getDouble();	
	}
	else if( L"bool" == aPropertyName ) {
		m_b = aValue.getBOOL();
	}
	else if( L"byte" == aPropertyName ) {
		m_byte = aValue.getBYTE();
	}
	else if( L"char" == aPropertyName ) {
		m_c = aValue.getChar();	
	}
	else if( L"string" == aPropertyName ) {
		m_s = aValue.getString();	
	}
	else if( L"object" == aPropertyName ) {
		if( aValue.getReflection() == XPersistObject_getReflection() ) {
			XPersistObjectRef *pRef = (XPersistObjectRef*) aValue.get();	
			if( pRef ) {
				m_ref = *pRef;
			}
			else {
				m_ref = 0;
			}
		}
		else
		{
			m_ref = 0;
		}
	}
}


UsrAny MyPersistObject::getPropertyValue(const UString& aPropertyName) const 
    															THROWS( (	UnknownPropertyException, 
    																		WrappedTargetException, 
    																		UsrSystemException) )
{
	UsrAny aValue;
	if( L"long" == aPropertyName  ) {
		aValue.setINT32( m_l );	
	}
	else if ( L"float" == aPropertyName ) {
		aValue.setFloat( m_f );	
	}
	else if( L"double" == aPropertyName ) {
		aValue.setDouble( m_d );	
	}
	else if( L"bool" == aPropertyName ) {
		aValue.setBOOL( m_b );
	}
	else if( L"byte" == aPropertyName ) {
		aValue.setBYTE( m_byte );
	}
	else if( L"char" == aPropertyName ) {
		aValue.setChar( m_c );	
	}
	else if( L"string" == aPropertyName ) {
		aValue.setString( m_s );	
	}
	else if( L"object" == aPropertyName ) {
		aValue.set( &m_ref , XPersistObject_getReflection() );
	}
	return aValue;
}


void MyPersistObject::addPropertyChangeListener(	const UString& aPropertyName, 
    												const XPropertyChangeListenerRef& xListener) 
    															THROWS( (	UnknownPropertyException, 
    																		WrappedTargetException, 
    																		UsrSystemException) )
{
	
}

void MyPersistObject::removePropertyChangeListener(	const UString& aPropertyName, 
    												const XPropertyChangeListenerRef& aListener) 
    															THROWS( (	UnknownPropertyException, 
    																		WrappedTargetException, 
    																		UsrSystemException) )
{
}
void MyPersistObject::addVetoableChangeListener(const UString& PropertyName, 
    											const XVetoableChangeListenerRef& aListener) 
    															THROWS( (	UnknownPropertyException,
    																		WrappedTargetException, 
    																		UsrSystemException) )
{
	
}

void MyPersistObject::removeVetoableChangeListener(	const UString& PropertyName, 
    								const XVetoableChangeListenerRef& aListener) 
    															THROWS( (	UnknownPropertyException, 
    																		WrappedTargetException, 
    																		UsrSystemException) )
{
	
}


BOOL MyPersistObject::queryInterface( Uik aUik , XInterfaceRef &rOut )
{
	if( XPersistObject::getSmartUik() == aUik ) {
		rOut = ( XPersistObject * ) this;	
	}
	else if( XPropertySet::getSmartUik() == aUik ) {
		rOut = ( XPropertySet * ) this;	
	}
	else
		return OWeakObject::queryInterface( aUik , rOut );
		
	return TRUE;
}

UString MyPersistObject::getServiceName() const THROWS( (UsrSystemException) )
{
	return m_sServiceName;
}

void MyPersistObject::write( const XObjectOutputStreamRef & rOut ) 
													THROWS( (IOException,UsrSystemException))
{
	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 XObjectInputStreamRef & rIn ) 
													THROWS( (IOException, UsrSystemException) )
{
	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();
}

XInterfaceRef OMyPersistObject_CreateInstance( const XMultiServiceFactoryRef & rSMgr ) 
													THROWS((Exception))
{	
	MyPersistObject *p = new MyPersistObject( );
	XInterfaceRef xService = *p;	
	return xService;
}

Sequence<UString> OMyPersistObject_getSupportedServiceNames( ) THROWS( () )
{
	Sequence<UString> aRet(1);
	aRet.getArray()[0] = OMyPersistObject_getImplementationName();
	return aRet;
}

UString     OMyPersistObject_getServiceName( ) THROWS( () )
{
	return L"test.com.sun.star.io.PersistTest";
}

UString 	OMyPersistObject_getImplementationName( ) THROWS( () )
{
	return L"test.com.sun.star.io.PersistTest";
}


// ---------------------------------------------
// -----------------------------------------------
class OObjectStreamTest :
		public ODataStreamTest
{
public:
	OObjectStreamTest( const XMultiServiceFactoryRef &r) : ODataStreamTest(r) {}
public: // refcounting	
	BOOL						queryInterface( Uik aUik, XInterfaceRef & rOut );

public:	
    virtual void testInvariant(const UString& TestName, const XInterfaceRef& TestObject) 
    															THROWS( (	IllegalArgumentException, 
    																		UsrSystemException) );

    virtual INT32 test(	const UString& TestName, 
    					const XInterfaceRef& TestObject, 
    					INT32 hTestHandle) 						THROWS( (	IllegalArgumentException, 
    																		UsrSystemException) );


private:
	void OObjectStreamTest::testObject( 	const XObjectOutputStreamRef &rOut, 
											const XObjectInputStreamRef &rIn );

private:
};


BOOL OObjectStreamTest::queryInterface( Uik uik , XInterfaceRef &rOut )
{
	if( XSimpleTest::getSmartUik() == uik ) {
		rOut = (XSimpleTest *) this;
	}	
	else {
		return ODataStreamTest::queryInterface( uik , rOut );
	}	
	return TRUE;
}


void OObjectStreamTest::testInvariant( const UString& TestName, const XInterfaceRef& TestObject ) 
    															THROWS( (	IllegalArgumentException, 
    																		UsrSystemException) )
{
	

	if( L"com.sun.star.io.ObjectInputStream" == TestName ) {
		ODataStreamTest::testInvariant( TestName , TestObject );
		XObjectInputStreamRef dataInput( TestObject , USR_QUERY );		
		XMarkableStreamRef markable( TestObject , USR_QUERY );
		ERROR_ASSERT( dataInput.is() , "XObjectInputStream cannot be queried" );
		ERROR_ASSERT(   markable.is() , "XMarkableStream cannot be queried" );
	}
	else if( L"com.sun.star.io.ObjectOutputStream" == TestName ) {
		ODataStreamTest::testInvariant( TestName , TestObject );
		XMarkableStreamRef markable( TestObject , USR_QUERY );
		XObjectOutputStreamRef dataOutput( TestObject , USR_QUERY );
		ERROR_ASSERT( 	dataOutput.is(),	"XObjectOutputStream cannot be queried" );
		ERROR_ASSERT(   markable.is() , "XMarkableStream cannot be queried" );
	}

	XServiceInfoRef info( TestObject, USR_QUERY );
	ERROR_ASSERT( info.is() , "XServiceInfo not supported !" );
	if( info.is() )
	{
		ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" );
		ERROR_ASSERT( ! info->supportsService( L"bla bluzb" ) , "XServiceInfo test failed" );
	}

}

INT32 OObjectStreamTest::test(	const UString& TestName, 
    					const XInterfaceRef& TestObject, 
    					INT32 hTestHandle) 						THROWS( (	IllegalArgumentException, 
    																		UsrSystemException) )
{
	if( L"com.sun.star.io.ObjectInputStream" == TestName || 
		L"com.sun.star.io.ObjectOutputStream" == TestName )  {
		
		try {
			if( 0 == hTestHandle ) {
				testInvariant( TestName , TestObject );
			}
			else if( DATASTREAM_TEST_MAX_HANDLE >= hTestHandle ) {
				INT32 hOldHandle = hTestHandle;
				hTestHandle = ODataStreamTest::test( L"com.sun.star.io.DataInputStream" , 
														TestObject , hTestHandle );
				if( hTestHandle == -1 ){
					hTestHandle = hOldHandle;
				}
			}
			else {
				
				XActiveDataSinkRef rSink( TestObject, USR_QUERY );
				XActiveDataSourceRef rSource( TestObject , USR_QUERY );

				XObjectInputStreamRef rInput( TestObject , USR_QUERY );
				XObjectOutputStreamRef rOutput( TestObject , USR_QUERY );

				
				XInterfaceRef x = m_rFactory->createInstance( L"com.sun.star.io.Pipe");

				XInputStreamRef  rPipeInput( x , USR_QUERY );
				XOutputStreamRef rPipeOutput( x , USR_QUERY );
				
				x = m_rFactory->createInstance( L"com.sun.star.io.MarkableInputStream" );
				XInputStreamRef 	markableInput( x , USR_QUERY );
				XActiveDataSinkRef markableSink( x , USR_QUERY );
				
				x = m_rFactory->createInstance( L"com.sun.star.io.MarkableOutputStream" );
				XOutputStreamRef 	markableOutput( x , USR_QUERY );
				XActiveDataSourceRef	markableSource( x , USR_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( L"com.sun.star.io.ObjectInputStream" );
					x->queryInterface( XObjectInputStream::getSmartUik() , rInput );
					x->queryInterface( XActiveDataSink::getSmartUik() , rSink );
				}
				else if ( !rSource.is() ) {
					x = m_rFactory->createInstance( L"com.sun.star.io.ObjectOutputStream" );
					x->queryInterface( XObjectOutputStream::getSmartUik() , rOutput );
					x->queryInterface( XActiveDataSource::getSmartUik() , rSource );
				}

				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 )  {
			BUILD_ERROR( 0 , UStringToString( e.getName() , CHARSET_SYSTEM ).GetCharStr() );
		}
		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;
}													


BOOL compareMyPropertySet( XPropertySetRef &r1 , XPropertySetRef &r2 )
{
	BOOL b = TRUE;

	if( r1->getPropertyValue( L"long" ).getReflection() == Void_getReflection() ||
		r2->getPropertyValue( L"long" ).getReflection() == Void_getReflection() ) {
		
		// one of the objects is not the correct propertyset !
		return FALSE;
	}
	
	b = b && ( 	r1->getPropertyValue( L"long" ).getINT32() == 
				r2->getPropertyValue( L"long" ).getINT32() );

	b = b && ( 	r1->getPropertyValue( L"float" ).getFloat() == 
				r2->getPropertyValue( L"float" ).getFloat() );
	
	b = b && ( 	r1->getPropertyValue( L"double" ).getDouble() == 
				r2->getPropertyValue( L"double" ).getDouble() );

	b = b && ( 	r1->getPropertyValue( L"bool" ).getBOOL() == 
				r2->getPropertyValue( L"bool" ).getBOOL() );
				
	b = b && ( 	r1->getPropertyValue( L"byte" ).getBYTE() == 
				r2->getPropertyValue( L"byte" ).getBYTE() );
				
	b = b && ( 	r1->getPropertyValue( L"char" ).getChar() == 
				r2->getPropertyValue( L"char" ).getChar() );

	b = b && ( 	r1->getPropertyValue( L"string" ).getString() == 
				r2->getPropertyValue( L"string" ).getString() );

	UsrAny o1 = r1->getPropertyValue( L"object" );
	UsrAny o2 = r2->getPropertyValue( L"object" );
	
	if( o1.getReflection() == XPersistObject_getReflection() ) {

		if( o2.getReflection() == XPersistObject_getReflection() ) {
			XPersistObjectRef rPersist1 = *((XPersistObjectRef*) o1.get());
			XPersistObjectRef rPersist2 = *((XPersistObjectRef*) o2.get());
			XPropertySetRef rProp1( rPersist1 , USR_QUERY );
			XPropertySetRef rProp2( rPersist2 , USR_QUERY );
						
			if( rProp1.is() && rProp2.is() && ! ( rProp1 == rProp2 ) 
				&&( rProp1 != r1 )) {
					compareMyPropertySet( rProp1 , rProp2 );
			}		
		}
		else {
			b = FALSE;	
		}
	}
	else {
		if( o2.getReflection() == XPersistObject_getReflection() ) {
			b = FALSE;	
		}
	}

	return b;
}

void OObjectStreamTest::testObject( 	const XObjectOutputStreamRef &rOut, 
										const XObjectInputStreamRef &rIn )
{
	ERROR_ASSERT( rOut.is() , "no objectOutputStream" );
	ERROR_ASSERT( rIn.is() , "no objectInputStream" );
	
	XMultiServiceFactoryRef xProv = getProcessServiceManager();
	ERROR_ASSERT( xProv.is() , "no global service manager" );
	

	// tests, if saving an object with an unknown service name allows
	// reading the data behind the object !
	{
		XInterfaceRef x = * new MyPersistObject( L"bla blubs" );

		XPersistObjectRef persistRef( x , USR_QUERY );
		ERROR_ASSERT( persistRef.is() , "couldn't instantiate PersistTest object" );

		rOut->writeObject( persistRef );
		rOut->writeLong( (INT32) 0xdeadbeef );

		ERROR_ASSERT( 0 != rIn->available() , "no data arrived at input" );

		try
		{
			XPersistObjectRef xReadPersistRef = rIn->readObject();
			ERROR_ASSERT( 0 , "expected exception not thrown" );
		}
		catch( IOException& e )
		{
			// all is ok
		}

		ERROR_ASSERT( (INT32) 0xdeadbeef == rIn->readLong() ,
					  "wrong data after object with unknown service name." );
	}

	{
		XInterfaceRef x = xProv->createInstance(L"test.com.sun.star.io.PersistTest");
		XPersistObjectRef persistRef( x , USR_QUERY );

		ERROR_ASSERT( persistRef.is() , "couldn't instantiate PersistTest object" );
		
		XPropertySetRef rProp( persistRef , USR_QUERY );
		ERROR_ASSERT( rProp.is() , "test object is no property set " );
	
		UsrAny any;
		any.setINT32( 0x83482 );
		rProp->setPropertyValue( L"long" , any );
		
		any.setFloat( 42.23 );
		rProp->setPropertyValue( L"float" , any );

		any.setDouble( 	233.321412 );
		rProp->setPropertyValue( L"double" , any );
		
		any.setBOOL( TRUE );
		rProp->setPropertyValue( L"bool" , any );

		any.setBYTE( 130 );
		rProp->setPropertyValue( L"byte" , any );
		
		any.setChar( 'h' );
		rProp->setPropertyValue( L"char" , any );
		
		any.setString( L"hi du !" );
		rProp->setPropertyValue( L"string" , any );
		
		any.set( &persistRef, XPersistObject_getReflection() ); // try a self reference
		rProp->setPropertyValue( L"object" , any );
	
		// do read and write 
		rOut->writeObject( persistRef );	
		ERROR_ASSERT( 0 != rIn->available() , "no data arrived at input" );
		XPersistObjectRef xReadPersistRef	= 	rIn->readObject( );
		
		XPropertySetRef rPropRead( xReadPersistRef , USR_QUERY );
		ERROR_ASSERT( compareMyPropertySet( rProp , rPropRead ) , "objects has not been read properly !" );

		// destroy selfreferences
		rProp->setPropertyValue( L"object", UsrAny() );
		rPropRead->setPropertyValue( L"object", UsrAny() );
	}

	{
		XMarkableStreamRef markableOut( rOut , USR_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 ++ ) {

			XInterfaceRef x = xProv->createInstance(L"test.com.sun.star.io.PersistTest");
			XPersistObjectRef persistRef( x , USR_QUERY );
		
			XPropertySetRef rProp( persistRef , USR_QUERY );
			ERROR_ASSERT( rProp.is() , "test object is no property set " );
		
			UsrAny any;
			any.setINT32( 0x83482 );
			rProp->setPropertyValue( L"long" , any );
			
			any.setFloat( 42.23 );
			rProp->setPropertyValue( L"float" , any );
	
			any.setDouble( 	233.321412 );
			rProp->setPropertyValue( L"double" , any );
			
			any.setBOOL( TRUE );
			rProp->setPropertyValue( L"bool" , any );
	
			any.setBYTE( 130 );
			rProp->setPropertyValue( L"byte" , any );
			
			any.setChar( 'h' );
			rProp->setPropertyValue( L"char" , any );
			
			any.setString( L"hi du !" );
			rProp->setPropertyValue( L"string" , any );
			
			
			x = xProv->createInstance(L"test.com.sun.star.io.PersistTest");
			XPersistObjectRef persist2ndRef( x , USR_QUERY );
			
	
			// Note : persist2ndRef contains coincident values, but also coincident values must be
			// saved properly !		
			any.set( &persist2ndRef, XPersistObject_getReflection() ); // try a self reference
			rProp->setPropertyValue( L"object" , any );
			
			// simply test, if markable operations and object operations do not interfere
			INT32 nMark = markableOut->createMark();

			// do read and write 
			rOut->writeObject( persistRef );	
			
			// further markable tests !
			INT32 nOffset = markableOut->offsetToMark( nMark );
			markableOut->jumpToMark( nMark );
			markableOut->deleteMark( nMark );
			markableOut->jumpToFurthest();
			

			ERROR_ASSERT( 0 != rIn->available() , "no data arrived at input" );
			XPersistObjectRef xReadPersistRef	= 	rIn->readObject( );
			
			XPropertySetRef rProp1( persistRef , USR_QUERY );
			XPropertySetRef rProp2( xReadPersistRef , USR_QUERY );
			ERROR_ASSERT( compareMyPropertySet( rProp1, rProp2) , "objects has not been read properly !" );
		}
	}
}


XInterfaceRef OObjectStreamTest_CreateInstance( const XMultiServiceFactoryRef & rSMgr ) THROWS((Exception))
{	
	OObjectStreamTest *p = new OObjectStreamTest( rSMgr );
	XInterfaceRef xService = *p;	
	return xService;
}

Sequence<UString> OObjectStreamTest_getSupportedServiceNames( int i) THROWS( () )
{
	Sequence<UString> aRet(1);
	aRet.getArray()[0] = OObjectStreamTest_getImplementationName( i);
	return aRet;
}

UString     OObjectStreamTest_getServiceName( int i) THROWS( () )
{
	if( 1 == i ) {
		return L"test.com.sun.star.io.ObjectInputStream";
	} 
	else {
		return L"test.com.sun.star.io.ObjectOutputStream";	
	}
}

UString 	OObjectStreamTest_getImplementationName( int i) THROWS( () )
{
	if( 1 == i ) {
		return L"test.com.sun.star.comp.extensions.stm.ObjectInputStream";
	}
	else {
		return L"test.com.sun.star.comp.extensions.stm.ObjectOutputStream";	
	}
}