package/source/xstor/ocompinstream.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: ocompinstream.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_package.hxx"
  33
  34 #include "ocompinstream.hxx"
  35 #include <com/sun/star/lang/DisposedException.hpp>
  36 #include <osl/diagnose.h>
  37
  38 #include "owriteablestream.hxx"
  39 #include "xstorage.hxx"
  40
  41 using namespace ::com::sun::star;
  42
  43 //-----------------------------------------------
  44 OInputCompStream::OInputCompStream( OWriteStream_Impl& aImpl,
  45                                     uno::Reference < io::XInputStream > xStream,
  46                                     const uno::Sequence< beans::PropertyValue >& aProps,
  47                                     sal_Int16 nStorageType )
  48 : m_pImpl( &aImpl )
  49 , m_rMutexRef( m_pImpl->m_rMutexRef )
  50 , m_xStream( xStream )
  51 , m_pInterfaceContainer( NULL )
  52 , m_aProperties( aProps )
  53 , m_bDisposed( sal_False )
  54 , m_nStorageType( nStorageType )
  55 {
  56     OSL_ENSURE( m_pImpl->m_rMutexRef.Is(), "No mutex is provided!\n" );
  57     if ( !m_pImpl->m_rMutexRef.Is() )
  58         throw uno::RuntimeException(); // just a disaster
  59
  60     OSL_ENSURE( xStream.is(), "No stream is provided!\n" );
  61 }
  62
  63 //-----------------------------------------------
  64 OInputCompStream::OInputCompStream( uno::Reference < io::XInputStream > xStream,
  65                                     const uno::Sequence< beans::PropertyValue >& aProps,
  66                                     sal_Int16 nStorageType )
  67 : m_pImpl( NULL )
  68 , m_rMutexRef( new SotMutexHolder )
  69 , m_xStream( xStream )
  70 , m_pInterfaceContainer( NULL )
  71 , m_aProperties( aProps )
  72 , m_bDisposed( sal_False )
  73 , m_nStorageType( nStorageType )
  74 {
  75     OSL_ENSURE( xStream.is(), "No stream is provided!\n" );
  76 }
  77
  78 //-----------------------------------------------
  79 OInputCompStream::~OInputCompStream()
  80 {
  81     {
  82         ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
  83
  84         if ( !m_bDisposed )
  85         {
  86             m_refCount++;
  87             dispose();
  88         }
  89
  90         if ( m_pInterfaceContainer )
  91             delete m_pInterfaceContainer;
  92     }
  93 }
  94
  95 //-----------------------------------------------
  96 uno::Any SAL_CALL OInputCompStream::queryInterface( const uno::Type& rType )
  97         throw( uno::RuntimeException )
  98 {
  99     uno::Any aReturn;
 100
 101     // common interfaces
 102     aReturn <<= ::cppu::queryInterface
 103                 (       rType
 104                     ,   static_cast<io::XInputStream*> ( this )
 105                     ,   static_cast<io::XStream*> ( this )
 106                     ,   static_cast<lang::XComponent*> ( this )
 107                     ,   static_cast<beans::XPropertySet*> ( this )
 108                     ,   static_cast<embed::XExtendedStorageStream*> ( this ) );
 109
 110     if ( aReturn.hasValue() == sal_True )
 111         return aReturn ;
 112
 113     if ( m_nStorageType == OFOPXML_STORAGE )
 114     {
 115         aReturn <<= ::cppu::queryInterface
 116                     (   rType
 117                         ,       static_cast<embed::XRelationshipAccess*> ( this ) );
 118
 119         if ( aReturn.hasValue() == sal_True )
 120             return aReturn ;
 121     }
 122
 123     return OWeakObject::queryInterface( rType );
 124 }
 125
 126 //-----------------------------------------------
 127 sal_Int32 SAL_CALL OInputCompStream::readBytes( uno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead )
 128         throw ( io::NotConnectedException,
 129                 io::BufferSizeExceededException,
 130                 io::IOException,
 131                 uno::RuntimeException )
 132 {
 133     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 134     if ( m_bDisposed )
 135     {
 136         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 137         throw lang::DisposedException();
 138     }
 139
 140     if ( !m_xStream.is() )
 141     {
 142         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "No stream!" ) ) );
 143         throw uno::RuntimeException();
 144     }
 145
 146     return m_xStream->readBytes( aData, nBytesToRead );
 147 }
 148
 149 //-----------------------------------------------
 150 sal_Int32 SAL_CALL OInputCompStream::readSomeBytes( uno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead )
 151         throw ( io::NotConnectedException,
 152                 io::BufferSizeExceededException,
 153                 io::IOException,
 154                 uno::RuntimeException )
 155 {
 156     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 157     if ( m_bDisposed )
 158     {
 159         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 160         throw lang::DisposedException();
 161     }
 162
 163     if ( !m_xStream.is() )
 164     {
 165         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "No stream!" ) ) );
 166         throw uno::RuntimeException();
 167     }
 168
 169     return m_xStream->readSomeBytes( aData, nMaxBytesToRead );
 170
 171 }
 172
 173 //-----------------------------------------------
 174 void SAL_CALL OInputCompStream::skipBytes( sal_Int32 nBytesToSkip )
 175         throw ( io::NotConnectedException,
 176                 io::BufferSizeExceededException,
 177                 io::IOException,
 178                 uno::RuntimeException )
 179 {
 180     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 181     if ( m_bDisposed )
 182     {
 183         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 184         throw lang::DisposedException();
 185     }
 186
 187     if ( !m_xStream.is() )
 188     {
 189         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "No stream!" ) ) );
 190         throw uno::RuntimeException();
 191     }
 192
 193     m_xStream->skipBytes( nBytesToSkip );
 194
 195 }
 196
 197 //-----------------------------------------------
 198 sal_Int32 SAL_CALL OInputCompStream::available(  )
 199         throw ( io::NotConnectedException,
 200                 io::IOException,
 201                 uno::RuntimeException )
 202 {
 203     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 204     if ( m_bDisposed )
 205     {
 206         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 207         throw lang::DisposedException();
 208     }
 209
 210     if ( !m_xStream.is() )
 211     {
 212         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "No stream!" ) ) );
 213         throw uno::RuntimeException();
 214     }
 215
 216     return m_xStream->available();
 217
 218 }
 219
 220 //-----------------------------------------------
 221 void SAL_CALL OInputCompStream::closeInput(  )
 222         throw ( io::NotConnectedException,
 223                 io::IOException,
 224                 uno::RuntimeException )
 225 {
 226     dispose();
 227 }
 228
 229 //-----------------------------------------------
 230 uno::Reference< io::XInputStream > SAL_CALL OInputCompStream::getInputStream()
 231         throw ( uno::RuntimeException )
 232 {
 233     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 234     if ( m_bDisposed )
 235     {
 236         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 237         throw lang::DisposedException();
 238     }
 239
 240     if ( !m_xStream.is() )
 241         return uno::Reference< io::XInputStream >();
 242
 243     return uno::Reference< io::XInputStream >( static_cast< io::XInputStream* >( this ), uno::UNO_QUERY );
 244 }
 245
 246 //-----------------------------------------------
 247 uno::Reference< io::XOutputStream > SAL_CALL OInputCompStream::getOutputStream()
 248         throw ( uno::RuntimeException )
 249 {
 250     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 251     if ( m_bDisposed )
 252     {
 253         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 254         throw lang::DisposedException();
 255     }
 256
 257     return uno::Reference< io::XOutputStream >();
 258 }
 259
 260 //-----------------------------------------------
 261 void OInputCompStream::InternalDispose()
 262 {
 263     // can be called only by OWriteStream_Impl
 264     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 265     if ( m_bDisposed )
 266     {
 267         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 268         throw lang::DisposedException();
 269     }
 270
 271     // the source object is also a kind of locker for the current object
 272     // since the listeners could dispose the object while being notified
 273     lang::EventObject aSource( static_cast< ::cppu::OWeakObject*>( this ) );
 274
 275     if ( m_pInterfaceContainer )
 276         m_pInterfaceContainer->disposeAndClear( aSource );
 277
 278     try
 279     {
 280         m_xStream->closeInput();
 281     }
 282     catch( uno::Exception& )
 283     {}
 284
 285     m_pImpl = NULL;
 286     m_bDisposed = sal_True;
 287 }
 288
 289 //-----------------------------------------------
 290 void SAL_CALL OInputCompStream::dispose(  )
 291         throw ( uno::RuntimeException )
 292 {
 293     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 294     if ( m_bDisposed )
 295     {
 296         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 297         throw lang::DisposedException();
 298     }
 299
 300     if ( m_pInterfaceContainer )
 301     {
 302         lang::EventObject aSource( static_cast< ::cppu::OWeakObject*>( this ) );
 303         m_pInterfaceContainer->disposeAndClear( aSource );
 304     }
 305
 306     m_xStream->closeInput();
 307
 308     if ( m_pImpl )
 309     {
 310         m_pImpl->InputStreamDisposed( this );
 311         m_pImpl = NULL;
 312     }
 313
 314     m_bDisposed = sal_True;
 315 }
 316
 317 //-----------------------------------------------
 318 void SAL_CALL OInputCompStream::addEventListener( const uno::Reference< lang::XEventListener >& xListener )
 319         throw ( uno::RuntimeException )
 320 {
 321     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 322     if ( m_bDisposed )
 323     {
 324         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 325         throw lang::DisposedException();
 326     }
 327
 328     if ( !m_pInterfaceContainer )
 329         m_pInterfaceContainer = new ::cppu::OInterfaceContainerHelper( m_rMutexRef->GetMutex() );
 330
 331     m_pInterfaceContainer->addInterface( xListener );
 332 }
 333
 334 //-----------------------------------------------
 335 void SAL_CALL OInputCompStream::removeEventListener( const uno::Reference< lang::XEventListener >& xListener )
 336         throw ( uno::RuntimeException )
 337 {
 338     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 339     if ( m_bDisposed )
 340     {
 341         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 342         throw lang::DisposedException();
 343     }
 344
 345     if ( m_pInterfaceContainer )
 346         m_pInterfaceContainer->removeInterface( xListener );
 347 }
 348
 349 //-----------------------------------------------
 350 sal_Bool SAL_CALL OInputCompStream::hasByID(  const ::rtl::OUString& sID )
 351         throw ( io::IOException,
 352                 uno::RuntimeException )
 353 {
 354     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 355
 356     if ( m_bDisposed )
 357     {
 358         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 359         throw lang::DisposedException();
 360     }
 361
 362     if ( m_nStorageType != OFOPXML_STORAGE )
 363         throw uno::RuntimeException();
 364
 365     try
 366     {
 367         getRelationshipByID( sID );
 368         return sal_True;
 369     }
 370     catch( container::NoSuchElementException& )
 371     {}
 372
 373     return sal_False;
 374 }
 375
 376 //-----------------------------------------------
 377 ::rtl::OUString SAL_CALL OInputCompStream::getTargetByID(  const ::rtl::OUString& sID  )
 378         throw ( container::NoSuchElementException,
 379                 io::IOException,
 380                 uno::RuntimeException )
 381 {
 382     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 383
 384     if ( m_bDisposed )
 385     {
 386         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 387         throw lang::DisposedException();
 388     }
 389
 390     if ( m_nStorageType != OFOPXML_STORAGE )
 391         throw uno::RuntimeException();
 392
 393     uno::Sequence< beans::StringPair > aSeq = getRelationshipByID( sID );
 394     for ( sal_Int32 nInd = 0; nInd < aSeq.getLength(); nInd++ )
 395         if ( aSeq[nInd].First.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( "Target" ) ) )
 396             return aSeq[nInd].Second;
 397
 398     return ::rtl::OUString();
 399 }
 400
 401 //-----------------------------------------------
 402 ::rtl::OUString SAL_CALL OInputCompStream::getTypeByID(  const ::rtl::OUString& sID  )
 403         throw ( container::NoSuchElementException,
 404                 io::IOException,
 405                 uno::RuntimeException )
 406 {
 407     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 408
 409     if ( m_bDisposed )
 410     {
 411         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 412         throw lang::DisposedException();
 413     }
 414
 415     if ( m_nStorageType != OFOPXML_STORAGE )
 416         throw uno::RuntimeException();
 417
 418     uno::Sequence< beans::StringPair > aSeq = getRelationshipByID( sID );
 419     for ( sal_Int32 nInd = 0; nInd < aSeq.getLength(); nInd++ )
 420         if ( aSeq[nInd].First.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( "Type" ) ) )
 421             return aSeq[nInd].Second;
 422
 423     return ::rtl::OUString();
 424 }
 425
 426 //-----------------------------------------------
 427 uno::Sequence< beans::StringPair > SAL_CALL OInputCompStream::getRelationshipByID(  const ::rtl::OUString& sID  )
 428         throw ( container::NoSuchElementException,
 429                 io::IOException,
 430                 uno::RuntimeException )
 431 {
 432     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 433
 434     if ( m_bDisposed )
 435     {
 436         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 437         throw lang::DisposedException();
 438     }
 439
 440     if ( m_nStorageType != OFOPXML_STORAGE )
 441         throw uno::RuntimeException();
 442
 443     // TODO/LATER: in future the unification of the ID could be checked
 444     uno::Sequence< uno::Sequence< beans::StringPair > > aSeq = getAllRelationships();
 445     for ( sal_Int32 nInd1 = 0; nInd1 < aSeq.getLength(); nInd1++ )
 446         for ( sal_Int32 nInd2 = 0; nInd2 < aSeq[nInd1].getLength(); nInd2++ )
 447             if ( aSeq[nInd1][nInd2].First.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( "Id" ) ) )
 448             {
 449                 if ( aSeq[nInd1][nInd2].Second.equals( sID ) )
 450                     return aSeq[nInd1];
 451                 break;
 452             }
 453
 454     throw container::NoSuchElementException();
 455 }
 456
 457 //-----------------------------------------------
 458 uno::Sequence< uno::Sequence< beans::StringPair > > SAL_CALL OInputCompStream::getRelationshipsByType(  const ::rtl::OUString& sType  )
 459         throw ( io::IOException,
 460                 uno::RuntimeException )
 461 {
 462     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 463
 464     if ( m_bDisposed )
 465     {
 466         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 467         throw lang::DisposedException();
 468     }
 469
 470     if ( m_nStorageType != OFOPXML_STORAGE )
 471         throw uno::RuntimeException();
 472
 473     uno::Sequence< uno::Sequence< beans::StringPair > > aResult;
 474     sal_Int32 nEntriesNum = 0;
 475
 476     // TODO/LATER: in future the unification of the ID could be checked
 477     uno::Sequence< uno::Sequence< beans::StringPair > > aSeq = getAllRelationships();
 478     for ( sal_Int32 nInd1 = 0; nInd1 < aSeq.getLength(); nInd1++ )
 479         for ( sal_Int32 nInd2 = 0; nInd2 < aSeq[nInd1].getLength(); nInd2++ )
 480             if ( aSeq[nInd1][nInd2].First.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( "Type" ) ) )
 481             {
 482                 if ( aSeq[nInd1][nInd2].Second.equals( sType ) )
 483                 {
 484                     aResult.realloc( nEntriesNum );
 485                     aResult[nEntriesNum-1] = aSeq[nInd1];
 486                 }
 487                 break;
 488             }
 489
 490     return aResult;
 491 }
 492
 493 //-----------------------------------------------
 494 uno::Sequence< uno::Sequence< beans::StringPair > > SAL_CALL OInputCompStream::getAllRelationships()
 495         throw (io::IOException, uno::RuntimeException)
 496 {
 497     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 498
 499     if ( m_bDisposed )
 500     {
 501         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 502         throw lang::DisposedException();
 503     }
 504
 505     if ( m_nStorageType != OFOPXML_STORAGE )
 506         throw uno::RuntimeException();
 507
 508     // TODO/LATER: in future the information could be taken directly from m_pImpl when possible
 509     uno::Sequence< uno::Sequence< beans::StringPair > > aResult;
 510     for ( sal_Int32 aInd = 0; aInd < m_aProperties.getLength(); aInd++ )
 511         if ( m_aProperties[aInd].Name.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( "RelationsInfo" ) ) )
 512         {
 513             if ( m_aProperties[aInd].Value >>= aResult )
 514                 return aResult;
 515
 516             break;
 517         }
 518
 519     throw io::IOException(); // the relations info could not be read
 520 }
 521
 522 //-----------------------------------------------
 523 void SAL_CALL OInputCompStream::insertRelationshipByID(  const ::rtl::OUString& /*sID*/, const uno::Sequence< beans::StringPair >& /*aEntry*/, ::sal_Bool /*bReplace*/  )
 524         throw ( container::ElementExistException,
 525                 io::IOException,
 526                 uno::RuntimeException )
 527 {
 528     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 529
 530     if ( m_bDisposed )
 531     {
 532         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 533         throw lang::DisposedException();
 534     }
 535
 536     if ( m_nStorageType != OFOPXML_STORAGE )
 537         throw uno::RuntimeException();
 538
 539     throw io::IOException(); // TODO: Access denied
 540 }
 541
 542 //-----------------------------------------------
 543 void SAL_CALL OInputCompStream::removeRelationshipByID(  const ::rtl::OUString& /*sID*/  )
 544         throw ( container::NoSuchElementException,
 545                 io::IOException,
 546                 uno::RuntimeException )
 547 {
 548     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 549
 550     if ( m_bDisposed )
 551     {
 552         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 553         throw lang::DisposedException();
 554     }
 555
 556     if ( m_nStorageType != OFOPXML_STORAGE )
 557         throw uno::RuntimeException();
 558
 559     throw io::IOException(); // TODO: Access denied
 560 }
 561
 562 //-----------------------------------------------
 563 void SAL_CALL OInputCompStream::insertRelationships(  const uno::Sequence< uno::Sequence< beans::StringPair > >& /*aEntries*/, ::sal_Bool /*bReplace*/  )
 564         throw ( container::ElementExistException,
 565                 io::IOException,
 566                 uno::RuntimeException )
 567 {
 568     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 569
 570     if ( m_bDisposed )
 571     {
 572         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 573         throw lang::DisposedException();
 574     }
 575
 576     if ( m_nStorageType != OFOPXML_STORAGE )
 577         throw uno::RuntimeException();
 578
 579     throw io::IOException(); // TODO: Access denied
 580 }
 581
 582 //-----------------------------------------------
 583 void SAL_CALL OInputCompStream::clearRelationships()
 584         throw ( io::IOException,
 585                 uno::RuntimeException )
 586 {
 587     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 588
 589     if ( m_bDisposed )
 590     {
 591         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 592         throw lang::DisposedException();
 593     }
 594
 595     if ( m_nStorageType != OFOPXML_STORAGE )
 596         throw uno::RuntimeException();
 597
 598     throw io::IOException(); // TODO: Access denied
 599 }
 600
 601 //-----------------------------------------------
 602 uno::Reference< beans::XPropertySetInfo > SAL_CALL OInputCompStream::getPropertySetInfo()
 603         throw ( uno::RuntimeException )
 604 {
 605     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 606
 607     if ( m_bDisposed )
 608     {
 609         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 610         throw lang::DisposedException();
 611     }
 612
 613     //TODO:
 614     return uno::Reference< beans::XPropertySetInfo >();
 615 }
 616
 617 //-----------------------------------------------
 618 void SAL_CALL OInputCompStream::setPropertyValue( const ::rtl::OUString& aPropertyName, const uno::Any& /*aValue*/ )
 619         throw ( beans::UnknownPropertyException,
 620                 beans::PropertyVetoException,
 621                 lang::IllegalArgumentException,
 622                 lang::WrappedTargetException,
 623                 uno::RuntimeException )
 624 {
 625     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 626
 627     if ( m_bDisposed )
 628     {
 629         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 630         throw lang::DisposedException();
 631     }
 632
 633     // all the provided properties are accessible
 634     for ( sal_Int32 aInd = 0; aInd < m_aProperties.getLength(); aInd++ )
 635     {
 636         if ( m_aProperties[aInd].Name.equals( aPropertyName ) )
 637         {
 638             throw beans::PropertyVetoException(); // TODO
 639         }
 640     }
 641
 642     throw beans::UnknownPropertyException(); // TODO
 643 }
 644
 645
 646 //-----------------------------------------------
 647 uno::Any SAL_CALL OInputCompStream::getPropertyValue( const ::rtl::OUString& aProp )
 648         throw ( beans::UnknownPropertyException,
 649                 lang::WrappedTargetException,
 650                 uno::RuntimeException )
 651 {
 652     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 653
 654     if ( m_bDisposed )
 655     {
 656         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 657         throw lang::DisposedException();
 658     }
 659
 660     ::rtl::OUString aPropertyName;
 661     if ( aProp.equalsAscii( "IsEncrypted" ) )
 662         aPropertyName = ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Encrypted" ) );
 663     else
 664         aPropertyName = aProp;
 665
 666     if ( aPropertyName.equalsAscii( "RelationsInfo" ) )
 667         throw beans::UnknownPropertyException(); // TODO
 668
 669     // all the provided properties are accessible
 670     for ( sal_Int32 aInd = 0; aInd < m_aProperties.getLength(); aInd++ )
 671     {
 672         if ( m_aProperties[aInd].Name.equals( aPropertyName ) )
 673         {
 674             return m_aProperties[aInd].Value;
 675         }
 676     }
 677
 678     throw beans::UnknownPropertyException(); // TODO
 679 }
 680
 681
 682 //-----------------------------------------------
 683 void SAL_CALL OInputCompStream::addPropertyChangeListener(
 684     const ::rtl::OUString& /*aPropertyName*/,
 685     const uno::Reference< beans::XPropertyChangeListener >& /*xListener*/ )
 686         throw ( beans::UnknownPropertyException,
 687                 lang::WrappedTargetException,
 688                 uno::RuntimeException )
 689 {
 690     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 691
 692     if ( m_bDisposed )
 693     {
 694         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 695         throw lang::DisposedException();
 696     }
 697
 698     //TODO:
 699 }
 700
 701
 702 //-----------------------------------------------
 703 void SAL_CALL OInputCompStream::removePropertyChangeListener(
 704     const ::rtl::OUString& /*aPropertyName*/,
 705     const uno::Reference< beans::XPropertyChangeListener >& /*aListener*/ )
 706         throw ( beans::UnknownPropertyException,
 707                 lang::WrappedTargetException,
 708                 uno::RuntimeException )
 709 {
 710     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 711
 712     if ( m_bDisposed )
 713     {
 714         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 715         throw lang::DisposedException();
 716     }
 717
 718     //TODO:
 719 }
 720
 721
 722 //-----------------------------------------------
 723 void SAL_CALL OInputCompStream::addVetoableChangeListener(
 724     const ::rtl::OUString& /*PropertyName*/,
 725     const uno::Reference< beans::XVetoableChangeListener >& /*aListener*/ )
 726         throw ( beans::UnknownPropertyException,
 727                 lang::WrappedTargetException,
 728                 uno::RuntimeException )
 729 {
 730     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 731
 732     if ( m_bDisposed )
 733     {
 734         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 735         throw lang::DisposedException();
 736     }
 737
 738     //TODO:
 739 }
 740
 741
 742 //-----------------------------------------------
 743 void SAL_CALL OInputCompStream::removeVetoableChangeListener(
 744     const ::rtl::OUString& /*PropertyName*/,
 745     const uno::Reference< beans::XVetoableChangeListener >& /*aListener*/ )
 746         throw ( beans::UnknownPropertyException,
 747                 lang::WrappedTargetException,
 748                 uno::RuntimeException )
 749 {
 750     ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() );
 751
 752     if ( m_bDisposed )
 753     {
 754         ::package::StaticAddLog( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX "Disposed!" ) ) );
 755         throw lang::DisposedException();
 756     }
 757
 758     //TODO:
 759 }
 760
 761