/************************************************************** * * 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_ucbhelper.hxx" /************************************************************************** TODO ************************************************************************** - This implementation is far away from completion. It has no interface for changes notifications etc. *************************************************************************/ #include #include #include #include #include #include #include "osl/diagnose.h" using namespace com::sun::star; //========================================================================= //========================================================================= // // ResultSetImplHelper Implementation. // //========================================================================= //========================================================================= namespace ucbhelper { //========================================================================= ResultSetImplHelper::ResultSetImplHelper( const uno::Reference< lang::XMultiServiceFactory >& rxSMgr ) : m_pDisposeEventListeners( 0 ), m_bStatic( sal_False ), m_bInitDone( sal_False ), m_xSMgr( rxSMgr ) { } //========================================================================= ResultSetImplHelper::ResultSetImplHelper( const uno::Reference< lang::XMultiServiceFactory >& rxSMgr, const com::sun::star::ucb::OpenCommandArgument2& rCommand ) : m_pDisposeEventListeners( 0 ), m_bStatic( sal_False ), m_bInitDone( sal_False ), m_aCommand( rCommand ), m_xSMgr( rxSMgr ) { } //========================================================================= // virtual ResultSetImplHelper::~ResultSetImplHelper() { delete m_pDisposeEventListeners; } //========================================================================= // // XInterface methods. // //========================================================================= XINTERFACE_IMPL_4( ResultSetImplHelper, lang::XTypeProvider, lang::XServiceInfo, lang::XComponent, /* base of XDynamicResultSet */ com::sun::star::ucb::XDynamicResultSet ); //========================================================================= // // XTypeProvider methods. // //========================================================================= XTYPEPROVIDER_IMPL_3( ResultSetImplHelper, lang::XTypeProvider, lang::XServiceInfo, com::sun::star::ucb::XDynamicResultSet ); //========================================================================= // // XServiceInfo methods. // //========================================================================= XSERVICEINFO_NOFACTORY_IMPL_1( ResultSetImplHelper, rtl::OUString::createFromAscii( "ResultSetImplHelper" ), rtl::OUString::createFromAscii( DYNAMICRESULTSET_SERVICE_NAME ) ); //========================================================================= // // XComponent methods. // //========================================================================= // virtual void SAL_CALL ResultSetImplHelper::dispose() throw( uno::RuntimeException ) { osl::MutexGuard aGuard( m_aMutex ); if ( m_pDisposeEventListeners && m_pDisposeEventListeners->getLength() ) { lang::EventObject aEvt; aEvt.Source = static_cast< lang::XComponent * >( this ); m_pDisposeEventListeners->disposeAndClear( aEvt ); } } //========================================================================= // virtual void SAL_CALL ResultSetImplHelper::addEventListener( const uno::Reference< lang::XEventListener >& Listener ) throw( uno::RuntimeException ) { osl::MutexGuard aGuard( m_aMutex ); if ( !m_pDisposeEventListeners ) m_pDisposeEventListeners = new cppu::OInterfaceContainerHelper( m_aMutex ); m_pDisposeEventListeners->addInterface( Listener ); } //========================================================================= // virtual void SAL_CALL ResultSetImplHelper::removeEventListener( const uno::Reference< lang::XEventListener >& Listener ) throw( uno::RuntimeException ) { osl::MutexGuard aGuard( m_aMutex ); if ( m_pDisposeEventListeners ) m_pDisposeEventListeners->removeInterface( Listener ); } //========================================================================= // // XDynamicResultSet methods. // //========================================================================= // virtual uno::Reference< sdbc::XResultSet > SAL_CALL ResultSetImplHelper::getStaticResultSet() throw( com::sun::star::ucb::ListenerAlreadySetException, uno::RuntimeException ) { osl::MutexGuard aGuard( m_aMutex ); if ( m_xListener.is() ) throw com::sun::star::ucb::ListenerAlreadySetException(); init( sal_True ); return m_xResultSet1; } //========================================================================= // virtual void SAL_CALL ResultSetImplHelper::setListener( const uno::Reference< com::sun::star::ucb::XDynamicResultSetListener >& Listener ) throw( com::sun::star::ucb::ListenerAlreadySetException, uno::RuntimeException ) { osl::ClearableMutexGuard aGuard( m_aMutex ); if ( m_bStatic || m_xListener.is() ) throw com::sun::star::ucb::ListenerAlreadySetException(); m_xListener = Listener; ////////////////////////////////////////////////////////////////////// // Create "welcome event" and send it to listener. ////////////////////////////////////////////////////////////////////// // Note: We only have the implementation for a static result set at the // moment (src590). The dynamic result sets passed to the listener // are a fake. This implementation will never call "notify" at the // listener to propagate any changes!!! init( sal_False ); uno::Any aInfo; aInfo <<= com::sun::star::ucb::WelcomeDynamicResultSetStruct( m_xResultSet1 /* "old" */, m_xResultSet2 /* "new" */ ); uno::Sequence< com::sun::star::ucb::ListAction > aActions( 1 ); aActions.getArray()[ 0 ] = com::sun::star::ucb::ListAction( 0, // Position; not used 0, // Count; not used com::sun::star::ucb::ListActionType::WELCOME, aInfo ); aGuard.clear(); Listener->notify( com::sun::star::ucb::ListEvent( static_cast< cppu::OWeakObject * >( this ), aActions ) ); } //========================================================================= // virtual sal_Int16 SAL_CALL ResultSetImplHelper::getCapabilities() throw( uno::RuntimeException ) { // ! com::sun::star::ucb::ContentResultSetCapability::SORTED return 0; } //========================================================================= // virtual void SAL_CALL ResultSetImplHelper::connectToCache( const uno::Reference< com::sun::star::ucb::XDynamicResultSet > & xCache ) throw( com::sun::star::ucb::ListenerAlreadySetException, com::sun::star::ucb::AlreadyInitializedException, com::sun::star::ucb::ServiceNotFoundException, uno::RuntimeException ) { if ( m_xListener.is() ) throw com::sun::star::ucb::ListenerAlreadySetException(); if ( m_bStatic ) throw com::sun::star::ucb::ListenerAlreadySetException(); uno::Reference< com::sun::star::ucb::XSourceInitialization > xTarget( xCache, uno::UNO_QUERY ); if ( xTarget.is() ) { uno::Reference< com::sun::star::ucb::XCachedDynamicResultSetStubFactory > xStubFactory; try { xStubFactory = uno::Reference< com::sun::star::ucb::XCachedDynamicResultSetStubFactory >( m_xSMgr->createInstance( rtl::OUString::createFromAscii( "com.sun.star.ucb.CachedDynamicResultSetStubFactory" ) ), uno::UNO_QUERY ); } catch ( uno::Exception const & ) { } if ( xStubFactory.is() ) { xStubFactory->connectToCache( this, xCache, m_aCommand.SortingInfo, 0 ); return; } } throw com::sun::star::ucb::ServiceNotFoundException(); } //========================================================================= // // Non-interface methods. // //========================================================================= void ResultSetImplHelper::init( sal_Bool bStatic ) { osl::MutexGuard aGuard( m_aMutex ); if ( !m_bInitDone ) { try { if ( bStatic ) { // virtual... derived class fills m_xResultSet1 initStatic(); OSL_ENSURE( m_xResultSet1.is(), "ResultSetImplHelper::init - No 1st result set!" ); m_bStatic = sal_True; } else { // virtual... derived class fills m_xResultSet1 and m_xResultSet2 initDynamic(); OSL_ENSURE( m_xResultSet1.is(), "ResultSetImplHelper::init - No 1st result set!" ); OSL_ENSURE( m_xResultSet2.is(), "ResultSetImplHelper::init - No 2nd result set!" ); m_bStatic = sal_False; } m_bInitDone = sal_True; } catch ( uno::RuntimeException const &runtimeException ) { throw runtimeException; } catch ( uno::Exception const &exception ) { throw uno::RuntimeException( exception.Message, uno::Reference< XInterface >() ); } } } } // namespace ucbhelper