io/test/stm/datatest.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: datatest.cxx,v $
  10  * $Revision: 1.12 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_io.hxx"
  33
  34 #include <stdio.h>
  35
  36 #include <com/sun/star/test/XSimpleTest.hpp>
  37 #include <com/sun/star/io/XActiveDataSink.hpp>
  38 #include <com/sun/star/io/XActiveDataSource.hpp>
  39 #include <com/sun/star/io/XObjectInputStream.hpp>
  40 #include <com/sun/star/io/XObjectOutputStream.hpp>
  41 #include <com/sun/star/io/XMarkableStream.hpp>
  42 #include <com/sun/star/io/XConnectable.hpp>
  43 #include <com/sun/star/beans/XPropertySet.hpp>
  44 #include <com/sun/star/lang/WrappedTargetException.hpp>
  45
  46 #include <com/sun/star/lang/IllegalArgumentException.hpp>
  47
  48 #include <com/sun/star/lang/XServiceInfo.hpp>
  49
  50 #include <cppuhelper/factory.hxx>
  51
  52 #include <cppuhelper/implbase1.hxx>
  53 #include <cppuhelper/implbase2.hxx>
  54
  55 #include <osl/conditn.hxx>
  56 #include <osl/mutex.hxx>
  57
  58 #if OSL_DEBUG_LEVEL == 0
  59 #define NDEBUG
  60 #endif
  61 #include <assert.h>
  62 #include <string.h>
  63
  64 using namespace ::rtl;
  65 using namespace ::osl;
  66 using namespace ::cppu;
  67 //using namespace ::vos;
  68 using namespace ::com::sun::star::uno;
  69 using namespace ::com::sun::star::io;
  70 using namespace ::com::sun::star::lang;
  71 using namespace ::com::sun::star::test;
  72 using namespace ::com::sun::star::beans;
  73 // streams
  74
  75 #include "testfactreg.hxx"
  76
  77 #define DATASTREAM_TEST_MAX_HANDLE 1
  78
  79 /****
  80 * The following test class tests XDataInputStream and XDataOutputStream at equal terms,
  81 * so when errors occur, it may be in either one implementation.
  82 * The class also  uses stardiv.uno.io.pipe. If problems occur, make sure to run also the
  83 * pipe test routines ( test.com.sun.star.io.pipe ).
  84 *
  85 *
  86 *****/
  87
  88 class ODataStreamTest :
  89         public WeakImplHelper1< XSimpleTest >
  90 {
  91 public:
  92     ODataStreamTest( const Reference < XMultiServiceFactory > & rFactory ) :
  93         m_rFactory( rFactory )
  94         {}
  95
  96 public:
  97     virtual void SAL_CALL testInvariant(const OUString& TestName, const Reference < XInterface >& TestObject)
  98         throw ( IllegalArgumentException,
  99                     RuntimeException);
 100
 101     virtual sal_Int32 SAL_CALL test(    const OUString& TestName,
 102                                         const Reference < XInterface >& TestObject,
 103                                         sal_Int32 hTestHandle)
 104         throw ( IllegalArgumentException,
 105                 RuntimeException);
 106
 107     virtual sal_Bool SAL_CALL testPassed(void)                                                          throw ( RuntimeException);
 108     virtual Sequence< OUString > SAL_CALL getErrors(void)                               throw (RuntimeException);
 109     virtual Sequence< Any > SAL_CALL getErrorExceptions(void)           throw (RuntimeException);
 110     virtual Sequence< OUString > SAL_CALL getWarnings(void)                             throw (RuntimeException);
 111
 112 private:
 113     void testSimple( const Reference < XDataInputStream > & , const Reference < XDataOutputStream > &);
 114
 115 protected:
 116     Sequence<Any>  m_seqExceptions;
 117     Sequence<OUString> m_seqErrors;
 118     Sequence<OUString> m_seqWarnings;
 119
 120     Reference < XMultiServiceFactory > m_rFactory;
 121 };
 122
 123
 124
 125
 126 void ODataStreamTest::testInvariant(
 127     const OUString& TestName,
 128     const Reference < XInterface >& TestObject )
 129     throw (     IllegalArgumentException,
 130             RuntimeException)
 131 {
 132     if( OUString::createFromAscii("com.sun.star.io.DataInputStream") == TestName ) {
 133         Reference < XConnectable > connect( TestObject , UNO_QUERY );
 134         Reference < XActiveDataSink > active( TestObject , UNO_QUERY );
 135         Reference < XInputStream >  input( TestObject , UNO_QUERY );
 136         Reference < XDataInputStream > dataInput( TestObject , UNO_QUERY );
 137
 138         WARNING_ASSERT( connect.is(), "XConnectable cannot be queried" );
 139         WARNING_ASSERT( active.is() , "XActiveDataSink cannot be queried" );
 140         ERROR_ASSERT( input.is() , "XInputStream cannot be queried" );
 141         ERROR_ASSERT( dataInput.is() , "XDataInputStream cannot be queried" );
 142
 143
 144     }
 145     else if( OUString::createFromAscii("com.sun.star.io.DataInputStream") == TestName ) {
 146         Reference < XConnectable >  connect( TestObject , UNO_QUERY );
 147         Reference < XActiveDataSource > active( TestObject , UNO_QUERY );
 148         Reference < XOutputStream > output( TestObject , UNO_QUERY );
 149         Reference < XDataOutputStream > dataOutput( TestObject , UNO_QUERY );
 150
 151         WARNING_ASSERT( connect.is(),           "XConnectable cannot be queried" );
 152         WARNING_ASSERT( active.is() ,   "XActiveDataSink cannot be queried" );
 153         ERROR_ASSERT(   output.is() ,   "XInputStream cannot be queried" );
 154         ERROR_ASSERT(   dataOutput.is(),        "XDataInputStream cannot be queried" );
 155
 156     }
 157
 158     Reference < XServiceInfo >  info( TestObject, UNO_QUERY );
 159     ERROR_ASSERT( info.is() , "XServiceInfo not supported !" );
 160     if( info.is() )
 161     {
 162         ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" );
 163         ERROR_ASSERT( ! info->supportsService( OUString::createFromAscii("bla bluzb") ) , "XServiceInfo test failed" );
 164     }
 165
 166 }
 167
 168
 169 sal_Int32 ODataStreamTest::test(
 170     const OUString& TestName,
 171     const Reference < XInterface >& TestObject,
 172     sal_Int32 hTestHandle)
 173     throw (     IllegalArgumentException,
 174             RuntimeException)
 175 {
 176     if( OUString::createFromAscii("com.sun.star.io.DataInputStream") == TestName ||
 177         OUString::createFromAscii("com.sun.star.io.DataOutputStream") == TestName )  {
 178
 179         try
 180         {
 181             if( 0 == hTestHandle ) {
 182                 testInvariant( TestName , TestObject );
 183             }
 184             else {
 185                 Reference <XActiveDataSink > rSink( TestObject, UNO_QUERY );
 186                 Reference <XActiveDataSource > rSource( TestObject , UNO_QUERY );
 187
 188                 Reference < XDataInputStream > rInput( TestObject , UNO_QUERY );
 189                 Reference < XDataOutputStream > rOutput( TestObject , UNO_QUERY );
 190
 191
 192                 Reference < XInterface > x = m_rFactory->createInstance(
 193                     OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.Pipe" )));
 194
 195                 Reference < XInputStream >   rPipeInput( x , UNO_QUERY );
 196                 Reference < XOutputStream >  rPipeOutput( x , UNO_QUERY );
 197
 198                 if( ! rSink.is() ) {
 199                     x = m_rFactory->createInstance(
 200                         OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.DataInputStream")) );
 201                     rInput = Reference < XDataInputStream > ( x , UNO_QUERY);
 202                     rSink = Reference<  XActiveDataSink > ( x , UNO_QUERY );
 203                 }
 204                 else if ( !rSource.is() )
 205                 {
 206                     x = m_rFactory->createInstance(
 207                         OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.DataOutputStream") ) );
 208                     rOutput = Reference< XDataOutputStream > ( x , UNO_QUERY );
 209                     rSource = Reference< XActiveDataSource > ( x, UNO_QUERY );
 210                 }
 211
 212                 assert( rPipeInput.is() );
 213                 assert( rPipeOutput.is() );
 214                 rSink->setInputStream( rPipeInput );
 215                 rSource->setOutputStream( rPipeOutput );
 216
 217                 assert( rSink->getInputStream().is() );
 218                 assert( rSource->getOutputStream().is() );
 219
 220                 if( 1 == hTestHandle ) {
 221                     testSimple( rInput , rOutput );
 222                 }
 223             }
 224         }
 225         catch( Exception & e )
 226         {
 227             OString o = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US );
 228             BUILD_ERROR( 0 , o.getStr() );
 229         }
 230         catch( ... )
 231         {
 232             BUILD_ERROR( 0 , "unknown exception (Exception is  not base class)" );
 233         }
 234
 235         hTestHandle ++;
 236
 237         if( hTestHandle >= 2) {
 238             // all tests finished.
 239             hTestHandle = -1;
 240         }
 241     }
 242     else {
 243         BUILD_ERROR( 0 , "service not supported by test." );
 244     }
 245     return hTestHandle;
 246 }
 247
 248
 249
 250 sal_Bool ODataStreamTest::testPassed(void)                                                                              throw (RuntimeException)
 251 {
 252     return m_seqErrors.getLength() == 0;
 253 }
 254
 255
 256 Sequence< OUString > ODataStreamTest::getErrors(void)                                                   throw (RuntimeException)
 257 {
 258     return m_seqErrors;
 259 }
 260
 261
 262 Sequence< Any > ODataStreamTest::getErrorExceptions(void)                                       throw (RuntimeException)
 263 {
 264     return m_seqExceptions;
 265 }
 266
 267
 268 Sequence< OUString > ODataStreamTest::getWarnings(void)                                                 throw (RuntimeException)
 269 {
 270     return m_seqWarnings;
 271 }
 272
 273 void ODataStreamTest::testSimple(       const Reference < XDataInputStream > &rInput,
 274                                     const Reference < XDataOutputStream > &rOutput )
 275 {
 276     rOutput->writeLong( 0x34ff3c );
 277     rOutput->writeLong( 0x34ff3d );
 278     rOutput->writeLong( -1027 );
 279
 280     ERROR_ASSERT( 0x34ff3c ==  rInput->readLong() , "long read/write mismatch" );
 281     ERROR_ASSERT( 0x34ff3d ==  rInput->readLong() , "long read/write mismatch" );
 282     ERROR_ASSERT( -1027    ==  rInput->readLong() , "long read/write mismatch" );
 283
 284     rOutput->writeByte( 0x77 );
 285     ERROR_ASSERT( 0x77 == rInput->readByte() , "byte read/write mismatch" );
 286
 287     rOutput->writeBoolean( 25 );
 288     ERROR_ASSERT( rInput->readBoolean() , "boolean read/write mismatch" );
 289
 290     rOutput->writeBoolean( sal_False );
 291     ERROR_ASSERT( ! rInput->readBoolean() , "boolean read/write mismatch" );
 292
 293     rOutput->writeFloat( (float) 42.42 );
 294     ERROR_ASSERT( rInput->readFloat() == ((float)42.42) , "float read/write mismatch" );
 295
 296     rOutput->writeDouble( (double) 42.42 );
 297     ERROR_ASSERT( rInput->readDouble() == 42.42 , "double read/write mismatch" );
 298
 299     rOutput->writeHyper( 0x123456789abcdefLL );
 300     ERROR_ASSERT( rInput->readHyper() == 0x123456789abcdefLL , "int64 read/write mismatch" );
 301
 302     rOutput->writeUTF( OUString::createFromAscii("Live long and prosper !") );
 303     ERROR_ASSERT( rInput->readUTF() == OUString::createFromAscii("Live long and prosper !") ,
 304                     "UTF read/write mismatch" );
 305
 306     Sequence<sal_Unicode> wc(0x10001);
 307     for( int i = 0 ; i < 0x10000  ; i ++ ) {
 308         wc.getArray()[i] = L'c';
 309     }
 310     wc.getArray()[0x10000] = 0;
 311     OUString str( wc.getArray() , 0x10000 );
 312     rOutput->writeUTF( str );
 313     ERROR_ASSERT( rInput->readUTF() == str , "error reading 64k block" );
 314
 315     rOutput->closeOutput();
 316     try
 317     {
 318         rInput->readLong();
 319         ERROR_ASSERT( 0 , "eof-exception does not occur !" );
 320     }
 321     catch ( IOException & )
 322     {
 323         //ok
 324     }
 325     catch( ... )
 326     {
 327         ERROR_ASSERT( 0 , "wrong exception after reading beyond eof" );
 328     }
 329
 330     Sequence<sal_Int8> dummy (1);
 331     ERROR_ASSERT( ! rInput->readBytes( dummy , 1 ),
 332                     "stream must be on eof !" );
 333
 334     rInput->closeInput();
 335
 336     try
 337     {
 338         rOutput->writeByte( 1 );
 339         ERROR_ASSERT( 0 , "writing still possible though chain must be interrupted" );
 340     }
 341     catch( IOException & )
 342     {
 343         // ok
 344     }
 345     catch( ... ) {
 346         ERROR_ASSERT( 0 , "IOException  expected, but another exception was thrown" );
 347     }
 348
 349 }
 350
 351
 352
 353 /**
 354 * for external binding
 355 *
 356 *
 357 **/
 358 Reference < XInterface > SAL_CALL ODataStreamTest_CreateInstance( const Reference < XMultiServiceFactory > & rSMgr ) throw(Exception)
 359 {
 360     ODataStreamTest *p = new ODataStreamTest( rSMgr );
 361     return Reference < XInterface > ( SAL_STATIC_CAST( OWeakObject * , p ) );
 362 }
 363
 364 Sequence<OUString> ODataStreamTest_getSupportedServiceNames( int i) throw ()
 365 {
 366     Sequence<OUString> aRet(1);
 367
 368     aRet.getArray()[0] = ODataStreamTest_getImplementationName( i);
 369
 370
 371     return aRet;
 372 }
 373
 374 OUString     ODataStreamTest_getServiceName( int i) throw ()
 375 {
 376     if( 1 == i ) {
 377         return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.DataInputStream" ));
 378     }
 379     else {
 380         return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.DataOutputStream" ));
 381     }
 382 }
 383
 384 OUString        ODataStreamTest_getImplementationName( int i) throw ()
 385 {
 386     if( 1 == i ) {
 387         return OUString(
 388             RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.comp.extensions.stm.DataInputStream") );
 389     }
 390     else {
 391         return OUString( RTL_CONSTASCII_USTRINGPARAM(
 392             "test.com.sun.star.comp.extensions.stm.DataOutputStream" ) );
 393     }
 394 }
 395
 396
 397 /**------------------------------------------------------
 398 *
 399 *
 400 *
 401 *
 402 *
 403 *------------------------------------------------------*/
 404 class MyPersistObject : public WeakImplHelper2< XPersistObject , XPropertySet >
 405 {
 406 public:
 407     MyPersistObject( ) : m_sServiceName( OMyPersistObject_getServiceName() ) ,
 408         m_l( -392 ),
 409         m_f( 7883.2 ),
 410         m_d( -123923.5 ),
 411         m_b( sal_True ),
 412         m_byte( 42 ),
 413         m_c( 429 ),
 414         m_s( OUString( RTL_CONSTASCII_USTRINGPARAM( "foo" ) ) )
 415         {}
 416     MyPersistObject( const OUString & sServiceName ) : m_sServiceName( sServiceName )
 417         {}
 418
 419
 420 public:
 421     virtual OUString SAL_CALL getServiceName(void)  throw (RuntimeException);
 422     virtual void SAL_CALL write( const Reference< XObjectOutputStream >& OutStream )
 423         throw (IOException, RuntimeException);
 424     virtual void SAL_CALL read(const Reference< XObjectInputStream >& InStream)
 425         throw (IOException, RuntimeException);
 426
 427 public:
 428
 429     virtual Reference< XPropertySetInfo > SAL_CALL getPropertySetInfo(void)
 430         throw (RuntimeException);
 431
 432     virtual void SAL_CALL setPropertyValue(const OUString& aPropertyName, const Any& aValue)
 433         throw ( UnknownPropertyException,
 434                 PropertyVetoException,
 435                 IllegalArgumentException,
 436                 WrappedTargetException,
 437                 RuntimeException);
 438     virtual Any SAL_CALL getPropertyValue(const OUString& PropertyName)
 439         throw ( UnknownPropertyException,
 440                 WrappedTargetException,
 441                 RuntimeException);
 442     virtual void SAL_CALL addPropertyChangeListener(
 443         const OUString& aPropertyName,
 444         const Reference < XPropertyChangeListener > & xListener)
 445         throw ( UnknownPropertyException,
 446                 WrappedTargetException,
 447                 RuntimeException);
 448
 449     virtual void SAL_CALL removePropertyChangeListener(
 450         const OUString& aPropertyName,
 451         const Reference< XPropertyChangeListener > & aListener)
 452         throw ( UnknownPropertyException,
 453                 WrappedTargetException,
 454                 RuntimeException);
 455     virtual void SAL_CALL addVetoableChangeListener(
 456         const OUString& PropertyName,
 457         const Reference< XVetoableChangeListener > & aListener)
 458         throw ( UnknownPropertyException,
 459                 WrappedTargetException,
 460                 RuntimeException);
 461
 462     virtual void SAL_CALL removeVetoableChangeListener(
 463         const OUString& PropertyName,
 464         const Reference<  XVetoableChangeListener >& aListener)
 465         throw ( UnknownPropertyException,
 466                 WrappedTargetException,
 467                 RuntimeException);
 468
 469 public:
 470     sal_Int32   m_l;
 471     float       m_f;
 472     double      m_d;
 473     sal_Bool    m_b;
 474     sal_Int8    m_byte;
 475     sal_Unicode m_c;
 476     OUString    m_s;
 477     Reference< XPersistObject > m_ref;
 478     OUString m_sServiceName;
 479 };
 480
 481
 482
 483 Reference <XPropertySetInfo > MyPersistObject::getPropertySetInfo(void)
 484     throw (RuntimeException)
 485 {
 486     return Reference< XPropertySetInfo >();
 487 }
 488
 489 void MyPersistObject::setPropertyValue(
 490     const OUString& aPropertyName,
 491     const Any& aValue)
 492     throw (     UnknownPropertyException,
 493             PropertyVetoException,
 494             IllegalArgumentException,
 495             WrappedTargetException,
 496             RuntimeException)
 497 {
 498     if( 0 == aPropertyName.compareToAscii("long")  ) {
 499         aValue >>= m_l;
 500     }
 501     else if ( 0 == aPropertyName.compareToAscii("float") ) {
 502         aValue >>= m_f;
 503     }
 504     else if( 0 == aPropertyName.compareToAscii("double") ) {
 505         aValue >>= m_d;
 506     }
 507     else if( 0  == aPropertyName.compareToAscii("bool") ) {
 508         aValue >>= m_b;
 509     }
 510     else if( 0 == aPropertyName.compareToAscii("byte" ) ) {
 511         aValue >>= m_byte;
 512     }
 513     else if( 0 == aPropertyName.compareToAscii("char") ) {
 514         aValue >>= m_c;
 515     }
 516     else if( 0 == aPropertyName.compareToAscii("string") ) {
 517         aValue >>= m_s;
 518     }
 519     else if( 0 == aPropertyName.compareToAscii("object") ) {
 520         if( aValue.getValueType() == getCppuType( (Reference< XPersistObject> *)0 ) )
 521         {
 522             aValue >>= m_ref;
 523         }
 524         else
 525         {
 526             m_ref = 0;
 527         }
 528     }
 529 }
 530
 531
 532 Any MyPersistObject::getPropertyValue(const OUString& aPropertyName)
 533     throw (     UnknownPropertyException,
 534             WrappedTargetException,
 535             RuntimeException)
 536 {
 537     Any aValue;
 538     if( 0 == aPropertyName.compareToAscii("long" )  ) {
 539         aValue <<= m_l;
 540     }
 541     else if ( 0 == aPropertyName.compareToAscii("float") ) {
 542         aValue <<= m_f;
 543     }
 544     else if( 0 == aPropertyName.compareToAscii("double") ) {
 545         aValue <<= m_d;
 546     }
 547     else if( 0 == aPropertyName.compareToAscii("bool") ) {
 548         aValue <<= m_b;
 549     }
 550     else if( 0 == aPropertyName.compareToAscii("byte") ) {
 551         aValue <<= m_byte;
 552     }
 553     else if( 0 == aPropertyName.compareToAscii("char" ) ) {
 554         aValue <<= m_c;
 555     }
 556     else if( 0 == aPropertyName.compareToAscii("string") ) {
 557         aValue <<= m_s;
 558     }
 559     else if( 0 == aPropertyName.compareToAscii("object" ) )
 560     {
 561         aValue <<= m_ref;
 562     }
 563     return aValue;
 564 }
 565
 566
 567 void MyPersistObject::addPropertyChangeListener(
 568     const OUString& aPropertyName,
 569     const Reference< XPropertyChangeListener > & xListener)
 570     throw (     UnknownPropertyException,
 571             WrappedTargetException,
 572             RuntimeException)
 573 {
 574
 575 }
 576
 577 void MyPersistObject::removePropertyChangeListener(
 578     const OUString& aPropertyName,
 579     const Reference < XPropertyChangeListener > & aListener)
 580     throw (     UnknownPropertyException,
 581             WrappedTargetException,
 582             RuntimeException)
 583 {
 584 }
 585
 586
 587 void MyPersistObject::addVetoableChangeListener(
 588     const OUString& PropertyName,
 589     const Reference <XVetoableChangeListener >& aListener)
 590     throw (     UnknownPropertyException,
 591             WrappedTargetException,
 592             RuntimeException)
 593 {
 594
 595 }
 596
 597 void MyPersistObject::removeVetoableChangeListener(
 598     const OUString& PropertyName,
 599     const Reference < XVetoableChangeListener > & aListener)
 600     throw (     UnknownPropertyException,
 601             WrappedTargetException,
 602             RuntimeException)
 603 {
 604
 605 }
 606
 607
 608
 609
 610 OUString MyPersistObject::getServiceName() throw (RuntimeException)
 611 {
 612     return m_sServiceName;
 613 }
 614
 615 void MyPersistObject::write( const Reference< XObjectOutputStream >  & rOut )
 616     throw (IOException,RuntimeException)
 617 {
 618     rOut->writeLong( m_l);
 619     rOut->writeFloat( m_f );
 620     rOut->writeDouble( m_d );
 621     rOut->writeBoolean( m_b );
 622     rOut->writeByte( m_byte );
 623     rOut->writeChar( m_c );
 624     rOut->writeUTF( m_s );
 625     rOut->writeObject( m_ref );
 626 }
 627
 628
 629 void MyPersistObject::read( const Reference< XObjectInputStream > & rIn )
 630     throw (IOException, RuntimeException)
 631 {
 632     m_l = rIn->readLong();
 633     m_f = rIn->readFloat();
 634     m_d = rIn->readDouble();
 635     m_b = rIn->readBoolean();
 636     m_byte = rIn->readByte();
 637     m_c = rIn->readChar();
 638     m_s = rIn->readUTF();
 639     m_ref = rIn->readObject();
 640 }
 641
 642 Reference < XInterface > SAL_CALL OMyPersistObject_CreateInstance(
 643     const Reference < XMultiServiceFactory > & rSMgr )
 644     throw(Exception)
 645 {
 646     MyPersistObject *p = new MyPersistObject( );
 647     return Reference < XInterface > ( SAL_STATIC_CAST( OWeakObject * , p ) );
 648 }
 649
 650 Sequence<OUString> OMyPersistObject_getSupportedServiceNames( ) throw ()
 651 {
 652     Sequence<OUString> aRet(1);
 653     aRet.getArray()[0] = OMyPersistObject_getImplementationName();
 654     return aRet;
 655 }
 656
 657 OUString     OMyPersistObject_getServiceName( ) throw ()
 658 {
 659     return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.PersistTest" ));
 660 }
 661
 662 OUString        OMyPersistObject_getImplementationName( ) throw ()
 663 {
 664     return OUString( RTL_CONSTASCII_USTRINGPARAM( "test.com.sun.star.io.PersistTest" ) );
 665 }
 666
 667
 668 // ---------------------------------------------
 669 // -----------------------------------------------
 670 class OObjectStreamTest :
 671         public ODataStreamTest
 672 {
 673 public:
 674     OObjectStreamTest( const Reference < XMultiServiceFactory > &r) : ODataStreamTest(r) {}
 675
 676 public:
 677     virtual void SAL_CALL testInvariant(const OUString& TestName,
 678                                const Reference < XInterface >& TestObject)
 679         throw ( IllegalArgumentException,
 680                 RuntimeException);
 681
 682     virtual sal_Int32 SAL_CALL test(
 683         const OUString& TestName,
 684         const Reference < XInterface >& TestObject,
 685         sal_Int32 hTestHandle)
 686         throw ( IllegalArgumentException,
 687                 RuntimeException);
 688
 689
 690 private:
 691         void testObject(        const Reference <XObjectOutputStream > &rOut,
 692                                                 const Reference <XObjectInputStream> &rIn );
 693
 694 private:
 695 };
 696
 697
 698 void OObjectStreamTest::testInvariant( const OUString& TestName,
 699                                        const Reference < XInterface >& TestObject )
 700     throw (     IllegalArgumentException, RuntimeException)
 701 {
 702
 703     if( OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.io.ObjectInputStream" ) )
 704                   == TestName )
 705     {
 706         ODataStreamTest::testInvariant( TestName , TestObject );
 707         Reference< XObjectInputStream > dataInput( TestObject , UNO_QUERY );
 708         Reference< XMarkableStream >  markable( TestObject , UNO_QUERY );
 709         ERROR_ASSERT( dataInput.is() , "XObjectInputStream cannot be queried" );
 710         ERROR_ASSERT(   markable.is() , "XMarkableStream cannot be queried" );
 711     }
 712     else if( OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.ObjectOutputStream") )
 713              == TestName )
 714     {
 715         ODataStreamTest::testInvariant( TestName , TestObject );
 716         Reference < XMarkableStream > markable( TestObject , UNO_QUERY );
 717         Reference < XObjectOutputStream > dataOutput( TestObject , UNO_QUERY );
 718         ERROR_ASSERT(   dataOutput.is(),        "XObjectOutputStream cannot be queried" );
 719         ERROR_ASSERT(   markable.is() , "XMarkableStream cannot be queried" );
 720     }
 721
 722     Reference < XServiceInfo > info( TestObject, UNO_QUERY );
 723     ERROR_ASSERT( info.is() , "XServiceInfo not supported !" );
 724     if( info.is() )
 725     {
 726         ERROR_ASSERT( info->supportsService( TestName ), "XServiceInfo test failed" );
 727         ERROR_ASSERT( ! info->supportsService( OUString::createFromAscii("bla bluzb") ) , "XServiceInfo test failed" );
 728     }
 729
 730 }
 731
 732 sal_Int32 OObjectStreamTest::test(      const OUString& TestName,
 733                         const Reference < XInterface >& TestObject,
 734                         sal_Int32 hTestHandle)
 735     throw (     IllegalArgumentException,
 736             RuntimeException)
 737 {
 738     if( 0 == TestName.compareToAscii("com.sun.star.io.ObjectInputStream") ||
 739         0 == TestName.compareToAscii("com.sun.star.io.ObjectOutputStream" ) )  {
 740
 741         try
 742         {
 743             if( 0 == hTestHandle ) {
 744                 testInvariant( TestName , TestObject );
 745             }
 746             else if( DATASTREAM_TEST_MAX_HANDLE >= hTestHandle ) {
 747                 sal_Int32 hOldHandle = hTestHandle;
 748                 hTestHandle = ODataStreamTest::test(
 749                     OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.DataInputStream" )),
 750                     TestObject , hTestHandle );
 751                 if( hTestHandle == -1 ){
 752                     hTestHandle = hOldHandle;
 753                 }
 754             }
 755             else {
 756
 757                 Reference<XActiveDataSink >  rSink( TestObject, UNO_QUERY );
 758                 Reference<XActiveDataSource >  rSource( TestObject , UNO_QUERY );
 759
 760                 Reference< XObjectInputStream >  rInput( TestObject , UNO_QUERY );
 761                 Reference< XObjectOutputStream > rOutput( TestObject , UNO_QUERY );
 762
 763
 764                 Reference < XInterface > x = m_rFactory->createInstance(
 765                     OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.Pipe" )) );
 766
 767                 Reference <XInputStream > rPipeInput( x , UNO_QUERY );
 768                 Reference <XOutputStream >  rPipeOutput( x , UNO_QUERY );
 769
 770                 x = m_rFactory->createInstance(
 771                     OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.MarkableInputStream") ) );
 772
 773                 Reference <XInputStream > markableInput( x , UNO_QUERY );
 774                 Reference <XActiveDataSink> markableSink( x , UNO_QUERY );
 775
 776                 x = m_rFactory->createInstance( OUString(
 777                     RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.MarkableOutputStream" ) ) );
 778                 Reference <XOutputStream >      markableOutput( x , UNO_QUERY );
 779                 Reference <XActiveDataSource >  markableSource( x , UNO_QUERY );
 780
 781                 assert( markableInput.is()      );
 782                 assert( markableOutput.is() );
 783                 assert( markableSink.is()       );
 784                 assert( markableSource.is() );
 785
 786                 markableSink->setInputStream( rPipeInput );
 787                 markableSource->setOutputStream( rPipeOutput );
 788
 789                 if( ! rSink.is() ) {
 790                     x = m_rFactory->createInstance(
 791                         OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.ObjectInputStream") ));
 792                     rInput = Reference < XObjectInputStream > ( x , UNO_QUERY );
 793                     rSink = Reference < XActiveDataSink > ( x , UNO_QUERY );
 794                 }
 795                 else if ( !rSource.is() ) {
 796                     x = m_rFactory->createInstance(
 797                         OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.io.ObjectOutputStream" )));
 798                     rOutput = Reference <XObjectOutputStream > ( x , UNO_QUERY );
 799                     rSource = Reference <XActiveDataSource>( x, UNO_QUERY );
 800                 }
 801
 802                 assert( rPipeInput.is() );
 803                 assert( rPipeOutput.is() );
 804
 805                 rSink->setInputStream( markableInput );
 806                 rSource->setOutputStream( markableOutput );
 807
 808                 assert( rSink->getInputStream().is() );
 809                 assert( rSource->getOutputStream().is() );
 810
 811                 if( 1 + DATASTREAM_TEST_MAX_HANDLE == hTestHandle ) {
 812                     testObject( rOutput , rInput);
 813                 }
 814                 rInput->closeInput();
 815                 rOutput->closeOutput();
 816
 817             }
 818         }
 819         catch( Exception &e )  {
 820             OString o = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US );
 821             BUILD_ERROR( 0 , o.getStr() );
 822         }
 823         catch( ... ) {
 824             BUILD_ERROR( 0 , "unknown exception (Exception is  not base class)" );
 825         }
 826
 827         hTestHandle ++;
 828
 829         if( hTestHandle > 1 +DATASTREAM_TEST_MAX_HANDLE ) {
 830             // all tests finished.
 831             hTestHandle = -1;
 832         }
 833     }
 834     else {
 835         BUILD_ERROR( 0 , "service not supported by test." );
 836     }
 837     return hTestHandle;
 838 }
 839
 840
 841 sal_Bool compareMyPropertySet( Reference< XPropertySet > &r1 , Reference < XPropertySet > &r2 )
 842 {
 843     sal_Bool b = sal_True;
 844
 845     if( r1->getPropertyValue( OUString::createFromAscii("long") ).getValueType() == getCppuVoidType() ||
 846         r2->getPropertyValue( OUString::createFromAscii("long") ).getValueType() == getCppuVoidType() ) {
 847
 848         // one of the objects is not the correct propertyset !
 849         fprintf( stderr, "compareMyPropertySet: 1\n" );
 850         return sal_False;
 851     }
 852
 853     b = b && (  r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("long")) ) ==
 854                 r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("long")) ) );
 855     if( ! b ) fprintf( stderr, "compareMyPropertySet: 2\n" );
 856
 857     b = b && (  r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("float")) ) ==
 858                 r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("float")) ) );
 859     if( ! b ){
 860         float f1;
 861         float f2;
 862         r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("float")) ) >>= f1;
 863         r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("float")) ) >>= f2;
 864         fprintf( stderr, "compareMyPropertySet: %f %f 3\n",f1,f2 );
 865     }
 866
 867     b = b && (  r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("double")) ) ==
 868                 r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("double" ))) );
 869     if( ! b ) fprintf( stderr, "compareMyPropertySet: 4\n" );
 870
 871     sal_Bool b1 ,b2;
 872     Any a =r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("bool")) );
 873     a >>= b1;
 874     a = r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("bool")) );
 875     a >>= b2;
 876     b = b && ( (b1 && b2) || b1 == b2 );
 877     if( ! b ) fprintf( stderr, "compareMyPropertySet: 5\n" );
 878
 879 //      b = b &&        r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("bool")) ) ==
 880 //                              r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("bool")) ) );
 881
 882     b = b && (  r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("byte")) ) ==
 883                 r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("byte")) ) );
 884     if( ! b ) fprintf( stderr, "compareMyPropertySet: 6\n" );
 885
 886     b = b && (  r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("char")) ) ==
 887                 r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("char")) ) );
 888     if( ! b ) fprintf( stderr, "compareMyPropertySet: 7\n" );
 889
 890     b = b && (  r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("string")) ) ==
 891                 r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("string")) ));
 892     if( ! b ) fprintf( stderr, "compareMyPropertySet: 8\n" );
 893
 894     Any o1 = r1->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("object")) );
 895     Any o2 = r2->getPropertyValue( OUString(RTL_CONSTASCII_USTRINGPARAM("object")) );
 896
 897     if( o1.getValueType() == getCppuType( (Reference<XPersistObject>*)0 ) ) {
 898
 899         if( o2.getValueType() == getCppuType( (Reference<XPersistObject>*)0 ) ) {
 900             Reference < XPersistObject > rPersist1;
 901             Reference < XPersistObject > rPersist2;
 902             o1 >>= rPersist1;
 903             o2 >>= rPersist2;
 904             Reference <XPropertySet > rProp1( rPersist1 , UNO_QUERY );
 905             Reference < XPropertySet > rProp2( rPersist2 , UNO_QUERY );
 906
 907             if( rProp1.is() && rProp2.is() && ! ( rProp1 == rProp2 )
 908                 &&( rProp1 != r1 )) {
 909                     b = b && compareMyPropertySet( rProp1 , rProp2 );
 910             }
 911         }
 912         else {
 913             b = sal_False;
 914         }
 915         if( ! b ) fprintf( stderr, "compareMyPropertySet: 9\n" );
 916     }
 917     else {
 918         if( o2.getValueType()  == getCppuType( (Reference<XPersistObject>*)0 ) ) {
 919             b = sal_False;
 920         }
 921         if( ! b ) fprintf( stderr, "compareMyPropertySet: 10\n" );
 922     }
 923
 924     return b;
 925 }
 926
 927 void OObjectStreamTest::testObject(     const Reference<  XObjectOutputStream >  &rOut,
 928                                         const Reference < XObjectInputStream > &rIn )
 929 {
 930     ERROR_ASSERT( rOut.is() , "no objectOutputStream" );
 931     ERROR_ASSERT( rIn.is() , "no objectInputStream" );
 932
 933
 934
 935     // tests, if saving an object with an unknown service name allows
 936     // reading the data behind the object !
 937     {
 938         Reference < XInterface > x = * new MyPersistObject(
 939             OUString( RTL_CONSTASCII_USTRINGPARAM("bla blubs")) );
 940
 941         Reference< XPersistObject > persistRef( x , UNO_QUERY );
 942         ERROR_ASSERT( persistRef.is() , "couldn't instantiate PersistTest object" );
 943
 944         rOut->writeObject( persistRef );
 945         rOut->writeLong( (sal_Int32) 0xdeadbeef );
 946
 947         ERROR_ASSERT( 0 != rIn->available() , "no data arrived at input" );
 948
 949         try
 950         {
 951             Reference <XPersistObject >  xReadPersistRef = rIn->readObject();
 952             ERROR_ASSERT( 0 , "expected exception not thrown" );
 953         }
 954         catch( IOException & )
 955         {
 956             // all is ok
 957         }
 958
 959         ERROR_ASSERT( (sal_Int32) 0xdeadbeef == rIn->readLong() ,
 960                       "wrong data after object with unknown service name." );
 961     }
 962
 963     {
 964         Reference < XInterface > x = m_rFactory->createInstance(
 965             OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.PersistTest")));
 966         Reference< XPersistObject > persistRef( x , UNO_QUERY );
 967
 968         ERROR_ASSERT( persistRef.is() , "couldn't instantiate PersistTest object" );
 969
 970         Reference < XPropertySet > rProp( persistRef , UNO_QUERY );
 971         ERROR_ASSERT( rProp.is() , "test object is no property set " );
 972
 973         Any any;
 974         sal_Int32 i = 0x83482;
 975         any <<= i;
 976         rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("long")) , any );
 977
 978         float f = (float)42.23;
 979         any <<= f;
 980         rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("float")) , any );
 981
 982         double d = 233.321412;
 983         any <<= d;
 984         rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("double")) , any );
 985
 986         sal_Bool b = sal_True;
 987         any.setValue( &b , getCppuBooleanType() );
 988         rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("bool")) , any );
 989
 990         sal_Int8 by = 120;
 991         any <<= by;
 992         rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("byte")) , any );
 993
 994         sal_Unicode c = 'h';
 995         any.setValue( &c , getCppuCharType() );
 996         rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("char")) , any );
 997
 998         OUString str( RTL_CONSTASCII_USTRINGPARAM( "hi du !" ) );
 999         any <<= str;
1000         rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("string")) , any );
1001
1002         any <<= persistRef;
1003         rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("object")) , any );
1004
1005         // do read and write
1006         rOut->writeObject( persistRef );
1007         ERROR_ASSERT( 0 != rIn->available() , "no data arrived at input" );
1008         Reference< XPersistObject > xReadPersist        =       rIn->readObject( );
1009
1010         Reference< XPropertySet >  rPropRead( xReadPersist , UNO_QUERY );
1011         ERROR_ASSERT( compareMyPropertySet( rProp , rPropRead ) , "objects has not been read properly !" );
1012
1013         // destroy selfreferences
1014         rProp->setPropertyValue( OUString::createFromAscii("object"), Any() );
1015         rPropRead->setPropertyValue( OUString::createFromAscii("object"), Any() );
1016     }
1017
1018     {
1019         Reference< XMarkableStream > markableOut( rOut , UNO_QUERY );
1020         ERROR_ASSERT( markableOut.is() , "markable stream cannot be queried" );
1021
1022         // do the same thing multiple times to check if
1023         // buffering and marks work correctly
1024         for( int i = 0 ; i < 2000 ; i ++ ) {
1025
1026             Reference < XInterface > x = m_rFactory->createInstance(OUString::createFromAscii("test.com.sun.star.io.PersistTest"));
1027             Reference< XPersistObject >  persistRef( x , UNO_QUERY );
1028
1029             Reference < XPropertySet >  rProp( persistRef , UNO_QUERY );
1030             ERROR_ASSERT( rProp.is() , "test object is no property set " );
1031
1032             Any any;
1033             sal_Int32 i = 0x83482;
1034             any <<= i;
1035             rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("long")) , any );
1036
1037             float f = 42.23;
1038             any <<= f;
1039             rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("float")) , any );
1040
1041             double d = 233.321412;
1042             any <<= d;
1043             rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("double")) , any );
1044
1045             sal_Bool b = sal_True;
1046             any.setValue( &b , getCppuBooleanType() );
1047             rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("bool")) , any );
1048
1049             sal_Int8 by = 120;
1050             any <<= by;
1051             rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("byte")) , any );
1052
1053             sal_Unicode c = 'h';
1054             any.setValue( &c , getCppuCharType() );
1055             rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("char")) , any );
1056
1057             OUString str( RTL_CONSTASCII_USTRINGPARAM( "hi du !" ) );
1058             any <<= str;
1059             rProp->setPropertyValue( OUString( RTL_CONSTASCII_USTRINGPARAM("string")) , any );
1060
1061             x = m_rFactory->createInstance(OUString::createFromAscii("test.com.sun.star.io.PersistTest"));
1062             Reference <XPersistObject > persist2ndRef( x , UNO_QUERY );
1063
1064             // Note : persist2ndRef contains coincident values, but also coincident values must be
1065             // saved properly !
1066             any <<= persist2ndRef;
1067             rProp->setPropertyValue( OUString::createFromAscii("object") , any );
1068
1069             // simply test, if markable operations and object operations do not interfere
1070             sal_Int32 nMark = markableOut->createMark();
1071
1072             // do read and write
1073             rOut->writeObject( persistRef );
1074
1075             // further markable tests !
1076             sal_Int32 nOffset = markableOut->offsetToMark( nMark );
1077             markableOut->jumpToMark( nMark );
1078             markableOut->deleteMark( nMark );
1079             markableOut->jumpToFurthest();
1080
1081
1082
1083
1084
1085             ERROR_ASSERT( 0 != rIn->available() , "no data arrived at input" );
1086             Reference < XPersistObject > xReadPersistRef        =       rIn->readObject( );
1087
1088             Reference< XPropertySet > rProp1( persistRef , UNO_QUERY );
1089             Reference< XPropertySet >  rProp2( xReadPersistRef , UNO_QUERY );
1090             ERROR_ASSERT( compareMyPropertySet( rProp1, rProp2) ,
1091                           "objects has not been read properly !" );
1092         }
1093     }
1094 }
1095
1096
1097 Reference < XInterface > SAL_CALL OObjectStreamTest_CreateInstance( const Reference < XMultiServiceFactory > & rSMgr ) throw(Exception)
1098 {
1099     OObjectStreamTest *p = new OObjectStreamTest( rSMgr );
1100     return Reference < XInterface > ( SAL_STATIC_CAST( OWeakObject * , p ) );
1101 }
1102
1103 Sequence<OUString> OObjectStreamTest_getSupportedServiceNames( int i) throw ()
1104 {
1105     Sequence<OUString> aRet(1);
1106     aRet.getArray()[0] = OObjectStreamTest_getImplementationName( i);
1107     return aRet;
1108 }
1109
1110 OUString     OObjectStreamTest_getServiceName( int i) throw ()
1111 {
1112     if( 1 == i ) {
1113         return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.ObjectInputStream" ));
1114     }
1115     else {
1116         return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.io.ObjectOutputStream"));
1117     }
1118 }
1119
1120 OUString        OObjectStreamTest_getImplementationName( int i) throw ()
1121 {
1122     if( 1 == i ) {
1123         return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.comp.extensions.stm.ObjectInputStream" ));
1124     }
1125     else {
1126         return OUString( RTL_CONSTASCII_USTRINGPARAM("test.com.sun.star.comp.extensions.stm.ObjectOutputStream"));
1127     }
1128 }
1129
1130