ucb/source/core/provprox.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: provprox.cxx,v $
  10  * $Revision: 1.10 $
  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_ucb.hxx"
  33 #include <osl/diagnose.h>
  34 #include "provprox.hxx"
  35 #include <com/sun/star/lang/XInitialization.hpp>
  36
  37 using namespace rtl;
  38 using namespace com::sun::star::lang;
  39 using namespace com::sun::star::ucb;
  40 using namespace com::sun::star::uno;
  41
  42 //=========================================================================
  43 //=========================================================================
  44 //
  45 // UcbContentProviderProxyFactory Implementation.
  46 //
  47 //=========================================================================
  48 //=========================================================================
  49
  50 UcbContentProviderProxyFactory::UcbContentProviderProxyFactory(
  51                         const Reference< XMultiServiceFactory >& rxSMgr )
  52 : m_xSMgr( rxSMgr )
  53 {
  54 }
  55
  56 //=========================================================================
  57 // virtual
  58 UcbContentProviderProxyFactory::~UcbContentProviderProxyFactory()
  59 {
  60 }
  61
  62 //=========================================================================
  63 //
  64 // XInterface methods.
  65 //
  66 //=========================================================================
  67
  68 XINTERFACE_IMPL_3( UcbContentProviderProxyFactory,
  69                    XTypeProvider,
  70                    XServiceInfo,
  71                    XContentProviderFactory );
  72
  73 //=========================================================================
  74 //
  75 // XTypeProvider methods.
  76 //
  77 //=========================================================================
  78
  79 XTYPEPROVIDER_IMPL_3( UcbContentProviderProxyFactory,
  80                           XTypeProvider,
  81                       XServiceInfo,
  82                           XContentProviderFactory );
  83
  84 //=========================================================================
  85 //
  86 // XServiceInfo methods.
  87 //
  88 //=========================================================================
  89
  90 XSERVICEINFO_IMPL_1( UcbContentProviderProxyFactory,
  91                      OUString::createFromAscii(
  92                          "com.sun.star.comp.ucb.UcbContentProviderProxyFactory" ),
  93                      OUString::createFromAscii(
  94                          PROVIDER_FACTORY_SERVICE_NAME ) );
  95
  96 //=========================================================================
  97 //
  98 // Service factory implementation.
  99 //
 100 //=========================================================================
 101
 102 ONE_INSTANCE_SERVICE_FACTORY_IMPL( UcbContentProviderProxyFactory );
 103
 104 //=========================================================================
 105 //
 106 // XContentProviderFactory methods.
 107 //
 108 //=========================================================================
 109
 110 // virtual
 111 Reference< XContentProvider > SAL_CALL
 112 UcbContentProviderProxyFactory::createContentProvider(
 113                                                 const OUString& Service )
 114     throw( RuntimeException )
 115 {
 116     return Reference< XContentProvider >(
 117                         new UcbContentProviderProxy( m_xSMgr, Service ) );
 118 }
 119
 120 //=========================================================================
 121 //=========================================================================
 122 //
 123 // UcbContentProviderProxy Implementation.
 124 //
 125 //=========================================================================
 126 //=========================================================================
 127
 128 UcbContentProviderProxy::UcbContentProviderProxy(
 129                         const Reference< XMultiServiceFactory >& rxSMgr,
 130                         const OUString& Service )
 131 : m_aService( Service ),
 132   m_bReplace( sal_False ),
 133   m_bRegister( sal_False ),
 134   m_xSMgr( rxSMgr )
 135 {
 136 }
 137
 138 //=========================================================================
 139 // virtual
 140 UcbContentProviderProxy::~UcbContentProviderProxy()
 141 {
 142 }
 143
 144 //=========================================================================
 145 //
 146 // XInterface methods.
 147 //
 148 //=========================================================================
 149
 150 XINTERFACE_COMMON_IMPL( UcbContentProviderProxy );
 151
 152 //============================================================================
 153 // virtual
 154 Any SAL_CALL
 155 UcbContentProviderProxy::queryInterface( const Type & rType )
 156     throw ( RuntimeException )
 157 {
 158     Any aRet = cppu::queryInterface( rType,
 159                 static_cast< XTypeProvider * >( this ),
 160                 static_cast< XServiceInfo * >( this ),
 161                 static_cast< XContentProvider * >( this ),
 162                 static_cast< XParameterizedContentProvider * >( this ),
 163                 static_cast< XContentProviderSupplier * >( this ) );
 164
 165     if ( !aRet.hasValue() )
 166         aRet = OWeakObject::queryInterface( rType );
 167
 168     if ( !aRet.hasValue() )
 169     {
 170         // Get original provider an forward the call...
 171         osl::Guard< osl::Mutex > aGuard( m_aMutex );
 172         Reference< XContentProvider > xProvider = getContentProvider();
 173         if ( xProvider.is() )
 174             aRet = xProvider->queryInterface( rType );
 175     }
 176
 177     return aRet;
 178 }
 179
 180 //=========================================================================
 181 //
 182 // XTypeProvider methods.
 183 //
 184 //=========================================================================
 185
 186 XTYPEPROVIDER_COMMON_IMPL( UcbContentProviderProxy );
 187
 188 //=========================================================================
 189
 190 Sequence< Type > SAL_CALL UcbContentProviderProxy::getTypes()                                                           \
 191     throw( RuntimeException )
 192 {
 193     // Get original provider an forward the call...
 194     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 195     Reference< XTypeProvider > xProvider( getContentProvider(), UNO_QUERY );
 196     if ( xProvider.is() )
 197     {
 198         return xProvider->getTypes();
 199     }
 200     else
 201     {
 202         static cppu::OTypeCollection collection(
 203             CPPU_TYPE_REF( XTypeProvider ),
 204             CPPU_TYPE_REF( XServiceInfo ),
 205             CPPU_TYPE_REF( XContentProvider ),
 206             CPPU_TYPE_REF( XParameterizedContentProvider ),
 207             CPPU_TYPE_REF( XContentProviderSupplier ) );
 208         return collection.getTypes();
 209     }
 210 }
 211
 212 //=========================================================================
 213 //
 214 // XServiceInfo methods.
 215 //
 216 //=========================================================================
 217
 218 XSERVICEINFO_NOFACTORY_IMPL_1( UcbContentProviderProxy,
 219                             OUString::createFromAscii(
 220                                 "com.sun.star.comp.ucb.UcbContentProviderProxy" ),
 221                             OUString::createFromAscii(
 222                              PROVIDER_PROXY_SERVICE_NAME ) );
 223
 224 //=========================================================================
 225 //
 226 // XContentProvider methods.
 227 //
 228 //=========================================================================
 229
 230 // virtual
 231 Reference< XContent > SAL_CALL UcbContentProviderProxy::queryContent(
 232                         const Reference< XContentIdentifier >& Identifier )
 233     throw( IllegalIdentifierException,
 234            RuntimeException )
 235 {
 236     // Get original provider an forward the call...
 237
 238     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 239
 240     Reference< XContentProvider > xProvider = getContentProvider();
 241     if ( xProvider.is() )
 242         return xProvider->queryContent( Identifier );
 243
 244     return Reference< XContent >();
 245 }
 246
 247 //=========================================================================
 248 // virtual
 249 sal_Int32 SAL_CALL UcbContentProviderProxy::compareContentIds(
 250                        const Reference< XContentIdentifier >& Id1,
 251                        const Reference< XContentIdentifier >& Id2 )
 252     throw( RuntimeException )
 253 {
 254     // Get original provider an forward the call...
 255
 256     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 257     Reference< XContentProvider > xProvider = getContentProvider();
 258     if ( xProvider.is() )
 259         return xProvider->compareContentIds( Id1, Id2 );
 260
 261     // OSL_ENSURE( sal_False,
 262     // "UcbContentProviderProxy::compareContentIds - No provider!" );
 263
 264     // @@@ What else?
 265     return 0;
 266 }
 267
 268 //=========================================================================
 269 //
 270 // XParameterizedContentProvider methods.
 271 //
 272 //=========================================================================
 273
 274 // virtual
 275 Reference< XContentProvider > SAL_CALL
 276 UcbContentProviderProxy::registerInstance( const OUString& Template,
 277                                              const OUString& Arguments,
 278                                              sal_Bool ReplaceExisting )
 279     throw( IllegalArgumentException,
 280            RuntimeException )
 281 {
 282     // Just remember that this method was called ( and the params ).
 283
 284     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 285
 286     if ( !m_bRegister )
 287     {
 288 //              m_xTargetProvider = 0;
 289         m_aTemplate  = Template;
 290         m_aArguments = Arguments;
 291         m_bReplace   = ReplaceExisting;
 292
 293         m_bRegister  = sal_True;
 294     }
 295     return this;
 296 }
 297
 298 //=========================================================================
 299 // virtual
 300 Reference< XContentProvider > SAL_CALL
 301 UcbContentProviderProxy::deregisterInstance( const OUString& Template,
 302                                              const OUString& Arguments )
 303     throw( IllegalArgumentException,
 304            RuntimeException )
 305 {
 306     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 307
 308     // registerInstance called at proxy and at original?
 309     if ( m_bRegister && m_xTargetProvider.is() )
 310     {
 311         m_bRegister       = sal_False;
 312         m_xTargetProvider = 0;
 313
 314         Reference< XParameterizedContentProvider >
 315                                 xParamProvider( m_xProvider, UNO_QUERY );
 316         if ( xParamProvider.is() )
 317         {
 318             try
 319             {
 320                 xParamProvider->deregisterInstance( Template, Arguments );
 321             }
 322             catch ( IllegalIdentifierException const & )
 323             {
 324                 OSL_ENSURE( sal_False,
 325                     "UcbContentProviderProxy::deregisterInstance - "
 326                     "Caught IllegalIdentifierException!" );
 327             }
 328         }
 329     }
 330
 331     return this;
 332 }
 333
 334 //=========================================================================
 335 //
 336 // XContentProviderSupplier methods.
 337 //
 338 //=========================================================================
 339
 340 // virtual
 341 Reference< XContentProvider > SAL_CALL
 342 UcbContentProviderProxy::getContentProvider()
 343     throw( RuntimeException )
 344 {
 345     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 346     if ( !m_xProvider.is() )
 347     {
 348         try
 349         {
 350             m_xProvider
 351                 = Reference< XContentProvider >(
 352                       m_xSMgr->createInstance( m_aService ), UNO_QUERY );
 353             if(m_aArguments.compareToAscii("NoConfig") == 0)
 354             {
 355                 Reference<XInitialization> xInit(m_xProvider,UNO_QUERY);
 356                 if(xInit.is()) {
 357                     Sequence<Any> aArgs(1);
 358                     aArgs[0] <<= m_aArguments;
 359                     xInit->initialize(aArgs);
 360                 }
 361             }
 362         }
 363         catch ( RuntimeException const & )
 364         {
 365             throw;
 366         }
 367         catch ( Exception const & )
 368         {
 369         }
 370
 371         // registerInstance called at proxy, but not yet at original?
 372         if ( m_xProvider.is() && m_bRegister )
 373         {
 374             Reference< XParameterizedContentProvider >
 375                 xParamProvider( m_xProvider, UNO_QUERY );
 376             if ( xParamProvider.is() )
 377             {
 378                 try
 379                 {
 380                     m_xTargetProvider
 381                         = xParamProvider->registerInstance( m_aTemplate,
 382                                                             m_aArguments,
 383                                                             m_bReplace );
 384                 }
 385                 catch ( IllegalIdentifierException const & )
 386                 {
 387                     OSL_ENSURE( sal_False,
 388                         "UcbContentProviderProxy::getContentProvider - "
 389                         "Caught IllegalIdentifierException!" );
 390                 }
 391
 392                 OSL_ENSURE( m_xTargetProvider.is(),
 393                     "UcbContentProviderProxy::getContentProvider - "
 394                     "No provider!" );
 395             }
 396         }
 397         if ( !m_xTargetProvider.is() )
 398             m_xTargetProvider = m_xProvider;
 399     }
 400
 401     OSL_ENSURE( m_xProvider.is(),
 402                 "UcbContentProviderProxy::getContentProvider - No provider!" );
 403     return m_xTargetProvider;
 404 }