/************************************************************************* * * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * Copyright 2000, 2010 Oracle and/or its affiliates. * * OpenOffice.org - a multi-platform office productivity suite * * This file is part of OpenOffice.org. * * OpenOffice.org is free software: you can redistribute it and/or modify * it under the terms of the GNU Lesser General Public License version 3 * only, as published by the Free Software Foundation. * * OpenOffice.org is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Lesser General Public License version 3 for more details * (a copy is included in the LICENSE file that accompanied this code). * * You should have received a copy of the GNU Lesser General Public License * version 3 along with OpenOffice.org. If not, see * * for a copy of the LGPLv3 License. * ************************************************************************/ // MARKER(update_precomp.py): autogen include statement, do not remove #include "precompiled_ucb.hxx" #include #include #include #include #include #include #include using namespace com::sun::star::lang; using namespace com::sun::star::sdbc; using namespace com::sun::star::ucb; using namespace com::sun::star::uno; using namespace cppu; using namespace rtl; //-------------------------------------------------------------------------- //-------------------------------------------------------------------------- // class DynamicResultSetWrapper //-------------------------------------------------------------------------- //-------------------------------------------------------------------------- DynamicResultSetWrapper::DynamicResultSetWrapper( Reference< XDynamicResultSet > xOrigin , const Reference< XMultiServiceFactory > & xSMgr ) : m_bDisposed( sal_False ) , m_bInDispose( sal_False ) , m_pDisposeEventListeners( NULL ) , m_xSMgr( xSMgr ) , m_bStatic( sal_False ) , m_bGotWelcome( sal_False ) , m_xSource( xOrigin ) , m_xSourceResultOne( NULL ) , m_xSourceResultTwo( NULL ) // , m_xSourceResultCurrent( NULL ) // , m_bUseOne( NULL ) , m_xMyResultOne( NULL ) , m_xMyResultTwo( NULL ) , m_xListener( NULL ) { m_pMyListenerImpl = new DynamicResultSetWrapperListener( this ); m_xMyListenerImpl = Reference< XDynamicResultSetListener >( m_pMyListenerImpl ); //call impl_init() at the end of constructor of derived class }; void SAL_CALL DynamicResultSetWrapper::impl_init() { //call this at the end of constructor of derived class // Reference< XDynamicResultSet > xSource = NULL; { osl::Guard< osl::Mutex > aGuard( m_aMutex ); xSource = m_xSource; m_xSource = NULL; } if( xSource.is() ) setSource( xSource ); } DynamicResultSetWrapper::~DynamicResultSetWrapper() { //call impl_deinit() at start of destructor of derived class delete m_pDisposeEventListeners; }; void SAL_CALL DynamicResultSetWrapper::impl_deinit() { //call this at start of destructor of derived class // m_pMyListenerImpl->impl_OwnerDies(); } void SAL_CALL DynamicResultSetWrapper ::impl_EnsureNotDisposed() throw( DisposedException, RuntimeException ) { osl::Guard< osl::Mutex > aGuard( m_aMutex ); if( m_bDisposed ) throw DisposedException(); } //virtual void SAL_CALL DynamicResultSetWrapper ::impl_InitResultSetOne( const Reference< XResultSet >& xResultSet ) { osl::Guard< osl::Mutex > aGuard( m_aMutex ); OSL_ENSURE( !m_xSourceResultOne.is(), "Source ResultSet One is set already" ); m_xSourceResultOne = xResultSet; m_xMyResultOne = xResultSet; } //virtual void SAL_CALL DynamicResultSetWrapper ::impl_InitResultSetTwo( const Reference< XResultSet >& xResultSet ) { osl::Guard< osl::Mutex > aGuard( m_aMutex ); OSL_ENSURE( !m_xSourceResultTwo.is(), "Source ResultSet Two is set already" ); m_xSourceResultTwo = xResultSet; m_xMyResultTwo = xResultSet; } //-------------------------------------------------------------------------- // XInterface methods. //-------------------------------------------------------------------------- //list all interfaces inclusive baseclasses of interfaces QUERYINTERFACE_IMPL_START( DynamicResultSetWrapper ) SAL_STATIC_CAST( XComponent*, this ) //base of XDynamicResultSet , SAL_STATIC_CAST( XDynamicResultSet*, this ) , SAL_STATIC_CAST( XSourceInitialization*, this ) QUERYINTERFACE_IMPL_END //-------------------------------------------------------------------------- // XComponent methods. //-------------------------------------------------------------------------- // virtual void SAL_CALL DynamicResultSetWrapper ::dispose() throw( RuntimeException ) { impl_EnsureNotDisposed(); Reference< XComponent > xSourceComponent; { osl::ClearableGuard< osl::Mutex > aGuard( m_aMutex ); if( m_bInDispose || m_bDisposed ) return; m_bInDispose = sal_True; xSourceComponent = Reference< XComponent >(m_xSource, UNO_QUERY); if( m_pDisposeEventListeners && m_pDisposeEventListeners->getLength() ) { EventObject aEvt; aEvt.Source = static_cast< XComponent * >( this ); aGuard.clear(); m_pDisposeEventListeners->disposeAndClear( aEvt ); } } /* //@todo ?? ( only if java collection needs to long ) if( xSourceComponent.is() ) xSourceComponent->dispose(); */ osl::Guard< osl::Mutex > aGuard( m_aMutex ); m_bDisposed = sal_True; m_bInDispose = sal_False; } //-------------------------------------------------------------------------- // virtual void SAL_CALL DynamicResultSetWrapper ::addEventListener( const Reference< XEventListener >& Listener ) throw( RuntimeException ) { impl_EnsureNotDisposed(); osl::Guard< osl::Mutex > aGuard( m_aMutex ); if ( !m_pDisposeEventListeners ) m_pDisposeEventListeners = new OInterfaceContainerHelper( m_aContainerMutex ); m_pDisposeEventListeners->addInterface( Listener ); } //-------------------------------------------------------------------------- // virtual void SAL_CALL DynamicResultSetWrapper ::removeEventListener( const Reference< XEventListener >& Listener ) throw( RuntimeException ) { impl_EnsureNotDisposed(); osl::Guard< osl::Mutex > aGuard( m_aMutex ); if ( m_pDisposeEventListeners ) m_pDisposeEventListeners->removeInterface( Listener ); } //-------------------------------------------------------------------------- // own methods //-------------------------------------------------------------------------- //virtual void SAL_CALL DynamicResultSetWrapper ::impl_disposing( const EventObject& ) throw( RuntimeException ) { impl_EnsureNotDisposed(); osl::Guard< osl::Mutex > aGuard( m_aMutex ); if( !m_xSource.is() ) return; //release all references to the broadcaster: m_xSource.clear(); m_xSourceResultOne.clear();//?? or only when not static?? m_xSourceResultTwo.clear();//?? //@todo m_xMyResultOne.clear(); ??? //@todo m_xMyResultTwo.clear(); ??? } //virtual void SAL_CALL DynamicResultSetWrapper ::impl_notify( const ListEvent& Changes ) throw( RuntimeException ) { impl_EnsureNotDisposed(); //@todo /*

The Listener is allowed to blockade this call, until he really want to go to the new version. The only situation, where the listener has to return the update call at once is, while he disposes his broadcaster or while he is removing himsef as listener (otherwise you deadlock)!!! */ // handle the actions in the list ListEvent aNewEvent; aNewEvent.Source = static_cast< XDynamicResultSet * >( this ); aNewEvent.Changes = Changes.Changes; { osl::Guard< osl::Mutex > aGuard( m_aMutex ); for( long i=0; !m_bGotWelcome && i>= aWelcome ) { impl_InitResultSetOne( aWelcome.Old ); impl_InitResultSetTwo( aWelcome.New ); m_bGotWelcome = sal_True; aWelcome.Old = m_xMyResultOne; aWelcome.New = m_xMyResultTwo; rAction.ActionInfo <<= aWelcome; } else { OSL_ENSURE( sal_False, "ListActionType was WELCOME but ActionInfo didn't contain a WelcomeDynamicResultSetStruct" ); //throw RuntimeException(); } break; } } } OSL_ENSURE( m_bGotWelcome, "first notification was without WELCOME" ); } if( !m_xListener.is() ) m_aListenerSet.wait(); m_xListener->notify( aNewEvent ); /* m_bUseOne = !m_bUseOne; if( m_bUseOne ) m_xSourceResultCurrent = m_xSourceResultOne; else m_xSourceResultCurrent = m_xSourceResultTwo; */ } //-------------------------------------------------------------------------- // XSourceInitialization //-------------------------------------------------------------------------- //virtual void SAL_CALL DynamicResultSetWrapper ::setSource( const Reference< XInterface > & Source ) throw( AlreadyInitializedException, RuntimeException ) { impl_EnsureNotDisposed(); { osl::Guard< osl::Mutex > aGuard( m_aMutex ); if( m_xSource.is() ) { throw AlreadyInitializedException(); } } Reference< XDynamicResultSet > xSourceDynamic( Source, UNO_QUERY ); OSL_ENSURE( xSourceDynamic.is(), "the given source is not of required type XDynamicResultSet" ); Reference< XDynamicResultSetListener > xListener = NULL; Reference< XDynamicResultSetListener > xMyListenerImpl = NULL; sal_Bool bStatic = sal_False; { osl::Guard< osl::Mutex > aGuard( m_aMutex ); m_xSource = xSourceDynamic; xListener = m_xListener; bStatic = m_bStatic; xMyListenerImpl = m_xMyListenerImpl; } if( xListener.is() ) xSourceDynamic->setListener( m_xMyListenerImpl ); else if( bStatic ) { Reference< XComponent > xSourceComponent( Source, UNO_QUERY ); xSourceComponent->addEventListener( Reference< XEventListener > ::query( xMyListenerImpl ) ); } m_aSourceSet.set(); } //-------------------------------------------------------------------------- // XDynamicResultSet //-------------------------------------------------------------------------- //virtual Reference< XResultSet > SAL_CALL DynamicResultSetWrapper ::getStaticResultSet() throw( ListenerAlreadySetException, RuntimeException ) { impl_EnsureNotDisposed(); Reference< XDynamicResultSet > xSource = NULL; Reference< XEventListener > xMyListenerImpl = NULL; { osl::Guard< osl::Mutex > aGuard( m_aMutex ); if( m_xListener.is() ) throw ListenerAlreadySetException(); xSource = m_xSource; m_bStatic = sal_True; xMyListenerImpl = Reference< XEventListener > ::query( m_xMyListenerImpl ); } if( xSource.is() ) { Reference< XComponent > xSourceComponent( xSource, UNO_QUERY ); xSourceComponent->addEventListener( xMyListenerImpl ); } if( !xSource.is() ) m_aSourceSet.wait(); Reference< XResultSet > xResultSet = xSource->getStaticResultSet(); impl_InitResultSetOne( xResultSet ); return m_xMyResultOne; } //virtual void SAL_CALL DynamicResultSetWrapper ::setListener( const Reference< XDynamicResultSetListener > & Listener ) throw( ListenerAlreadySetException, RuntimeException ) { impl_EnsureNotDisposed(); Reference< XDynamicResultSet > xSource = NULL; Reference< XDynamicResultSetListener > xMyListenerImpl = NULL; { osl::Guard< osl::Mutex > aGuard( m_aMutex ); if( m_xListener.is() ) throw ListenerAlreadySetException(); if( m_bStatic ) throw ListenerAlreadySetException(); m_xListener = Listener; addEventListener( Reference< XEventListener >::query( Listener ) ); xSource = m_xSource; xMyListenerImpl = m_xMyListenerImpl; } if ( xSource.is() ) xSource->setListener( xMyListenerImpl ); m_aListenerSet.set(); } //virtual void SAL_CALL DynamicResultSetWrapper ::connectToCache( const Reference< XDynamicResultSet > & xCache ) throw( ListenerAlreadySetException, AlreadyInitializedException, ServiceNotFoundException, RuntimeException ) { impl_EnsureNotDisposed(); if( m_xListener.is() ) throw ListenerAlreadySetException(); if( m_bStatic ) throw ListenerAlreadySetException(); Reference< XSourceInitialization > xTarget( xCache, UNO_QUERY ); OSL_ENSURE( xTarget.is(), "The given Target dosn't have the required interface 'XSourceInitialization'" ); if( xTarget.is() && m_xSMgr.is() ) { //@todo m_aSourceSet.wait();? Reference< XCachedDynamicResultSetStubFactory > xStubFactory; try { xStubFactory = Reference< XCachedDynamicResultSetStubFactory >( m_xSMgr->createInstance( OUString::createFromAscii( "com.sun.star.ucb.CachedDynamicResultSetStubFactory" ) ), UNO_QUERY ); } catch ( Exception const & ) { } if( xStubFactory.is() ) { xStubFactory->connectToCache( this, xCache, Sequence< NumberedSortingInfo > (), NULL ); return; } } OSL_ENSURE( sal_False, "could not connect to cache" ); throw ServiceNotFoundException(); } //virtual sal_Int16 SAL_CALL DynamicResultSetWrapper ::getCapabilities() throw( RuntimeException ) { impl_EnsureNotDisposed(); m_aSourceSet.wait(); Reference< XDynamicResultSet > xSource = NULL; { osl::Guard< osl::Mutex > aGuard( m_aMutex ); xSource = m_xSource; } return xSource->getCapabilities(); } //-------------------------------------------------------------------------- //-------------------------------------------------------------------------- // class DynamicResultSetWrapperListener //-------------------------------------------------------------------------- //-------------------------------------------------------------------------- DynamicResultSetWrapperListener::DynamicResultSetWrapperListener( DynamicResultSetWrapper* pOwner ) : m_pOwner( pOwner ) { } DynamicResultSetWrapperListener::~DynamicResultSetWrapperListener() { } //-------------------------------------------------------------------------- // XInterface methods. //-------------------------------------------------------------------------- //list all interfaces inclusive baseclasses of interfaces XINTERFACE_IMPL_2( DynamicResultSetWrapperListener , XDynamicResultSetListener , XEventListener //base of XDynamicResultSetListener ); //-------------------------------------------------------------------------- // XDynamicResultSetListener methods: //-------------------------------------------------------------------------- //virtual void SAL_CALL DynamicResultSetWrapperListener ::disposing( const EventObject& rEventObject ) throw( RuntimeException ) { osl::Guard< osl::Mutex > aGuard( m_aMutex ); if( m_pOwner ) m_pOwner->impl_disposing( rEventObject ); } //virtual void SAL_CALL DynamicResultSetWrapperListener ::notify( const ListEvent& Changes ) throw( RuntimeException ) { osl::Guard< osl::Mutex > aGuard( m_aMutex ); if( m_pOwner ) m_pOwner->impl_notify( Changes ); } //-------------------------------------------------------------------------- // own methods: //-------------------------------------------------------------------------- void SAL_CALL DynamicResultSetWrapperListener ::impl_OwnerDies() { osl::Guard< osl::Mutex > aGuard( m_aMutex ); m_pOwner = NULL; }