ucb/source/core/provprox.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include <osl/diagnose.h>
  21 #include <osl/thread.h>
  22 #include <rtl/strbuf.hxx>
  23 #include "provprox.hxx"
  24 #include <com/sun/star/lang/XInitialization.hpp>
  25
  26 using namespace com::sun::star::lang;
  27 using namespace com::sun::star::ucb;
  28 using namespace com::sun::star::uno;
  29
  30
  31 //=========================================================================
  32 //=========================================================================
  33 //
  34 // UcbContentProviderProxyFactory Implementation.
  35 //
  36 //=========================================================================
  37 //=========================================================================
  38
  39 UcbContentProviderProxyFactory::UcbContentProviderProxyFactory(
  40                         const Reference< XMultiServiceFactory >& rxSMgr )
  41 : m_xSMgr( rxSMgr )
  42 {
  43 }
  44
  45 //=========================================================================
  46 // virtual
  47 UcbContentProviderProxyFactory::~UcbContentProviderProxyFactory()
  48 {
  49 }
  50
  51 //=========================================================================
  52 //
  53 // XInterface methods.
  54 //
  55 //=========================================================================
  56
  57 XINTERFACE_IMPL_3( UcbContentProviderProxyFactory,
  58                    XTypeProvider,
  59                    XServiceInfo,
  60                    XContentProviderFactory );
  61
  62 //=========================================================================
  63 //
  64 // XTypeProvider methods.
  65 //
  66 //=========================================================================
  67
  68 XTYPEPROVIDER_IMPL_3( UcbContentProviderProxyFactory,
  69                           XTypeProvider,
  70                       XServiceInfo,
  71                           XContentProviderFactory );
  72
  73 //=========================================================================
  74 //
  75 // XServiceInfo methods.
  76 //
  77 //=========================================================================
  78
  79 XSERVICEINFO_IMPL_1( UcbContentProviderProxyFactory,
  80                      OUString( "com.sun.star.comp.ucb.UcbContentProviderProxyFactory" ),
  81                      OUString( PROVIDER_FACTORY_SERVICE_NAME ) );
  82
  83 //=========================================================================
  84 //
  85 // Service factory implementation.
  86 //
  87 //=========================================================================
  88
  89 ONE_INSTANCE_SERVICE_FACTORY_IMPL( UcbContentProviderProxyFactory );
  90
  91 //=========================================================================
  92 //
  93 // XContentProviderFactory methods.
  94 //
  95 //=========================================================================
  96
  97 // virtual
  98 Reference< XContentProvider > SAL_CALL
  99 UcbContentProviderProxyFactory::createContentProvider(
 100                                                 const OUString& Service )
 101     throw( RuntimeException )
 102 {
 103     return Reference< XContentProvider >(
 104                         new UcbContentProviderProxy( m_xSMgr, Service ) );
 105 }
 106
 107 //=========================================================================
 108 //=========================================================================
 109 //
 110 // UcbContentProviderProxy Implementation.
 111 //
 112 //=========================================================================
 113 //=========================================================================
 114
 115 UcbContentProviderProxy::UcbContentProviderProxy(
 116                         const Reference< XMultiServiceFactory >& rxSMgr,
 117                         const OUString& Service )
 118 : m_aService( Service ),
 119   m_bReplace( sal_False ),
 120   m_bRegister( sal_False ),
 121   m_xSMgr( rxSMgr )
 122 {
 123 }
 124
 125 //=========================================================================
 126 // virtual
 127 UcbContentProviderProxy::~UcbContentProviderProxy()
 128 {
 129 }
 130
 131 //=========================================================================
 132 //
 133 // XInterface methods.
 134 //
 135 //=========================================================================
 136
 137 XINTERFACE_COMMON_IMPL( UcbContentProviderProxy );
 138
 139 //============================================================================
 140 // virtual
 141 Any SAL_CALL
 142 UcbContentProviderProxy::queryInterface( const Type & rType )
 143     throw ( RuntimeException )
 144 {
 145     Any aRet = cppu::queryInterface( rType,
 146                 static_cast< XTypeProvider * >( this ),
 147                 static_cast< XServiceInfo * >( this ),
 148                 static_cast< XContentProvider * >( this ),
 149                 static_cast< XParameterizedContentProvider * >( this ),
 150                 static_cast< XContentProviderSupplier * >( this ) );
 151
 152     if ( !aRet.hasValue() )
 153         aRet = OWeakObject::queryInterface( rType );
 154
 155     if ( !aRet.hasValue() )
 156     {
 157         // Get original provider an forward the call...
 158         osl::Guard< osl::Mutex > aGuard( m_aMutex );
 159         Reference< XContentProvider > xProvider = getContentProvider();
 160         if ( xProvider.is() )
 161             aRet = xProvider->queryInterface( rType );
 162     }
 163
 164     return aRet;
 165 }
 166
 167 //=========================================================================
 168 //
 169 // XTypeProvider methods.
 170 //
 171 //=========================================================================
 172
 173 XTYPEPROVIDER_COMMON_IMPL( UcbContentProviderProxy );
 174
 175 //=========================================================================
 176
 177 Sequence< Type > SAL_CALL UcbContentProviderProxy::getTypes()                                                           \
 178     throw( RuntimeException )
 179 {
 180     // Get original provider an forward the call...
 181     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 182     Reference< XTypeProvider > xProvider( getContentProvider(), UNO_QUERY );
 183     if ( xProvider.is() )
 184     {
 185         return xProvider->getTypes();
 186     }
 187     else
 188     {
 189         static cppu::OTypeCollection collection(
 190             CPPU_TYPE_REF( XTypeProvider ),
 191             CPPU_TYPE_REF( XServiceInfo ),
 192             CPPU_TYPE_REF( XContentProvider ),
 193             CPPU_TYPE_REF( XParameterizedContentProvider ),
 194             CPPU_TYPE_REF( XContentProviderSupplier ) );
 195         return collection.getTypes();
 196     }
 197 }
 198
 199 //=========================================================================
 200 //
 201 // XServiceInfo methods.
 202 //
 203 //=========================================================================
 204
 205 XSERVICEINFO_NOFACTORY_IMPL_1( UcbContentProviderProxy,
 206                             OUString( "com.sun.star.comp.ucb.UcbContentProviderProxy" ),
 207                             OUString( PROVIDER_PROXY_SERVICE_NAME ) );
 208
 209 //=========================================================================
 210 //
 211 // XContentProvider methods.
 212 //
 213 //=========================================================================
 214
 215 // virtual
 216 Reference< XContent > SAL_CALL UcbContentProviderProxy::queryContent(
 217                         const Reference< XContentIdentifier >& Identifier )
 218     throw( IllegalIdentifierException,
 219            RuntimeException )
 220 {
 221     // Get original provider an forward the call...
 222
 223     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 224
 225     Reference< XContentProvider > xProvider = getContentProvider();
 226     if ( xProvider.is() )
 227         return xProvider->queryContent( Identifier );
 228
 229     return Reference< XContent >();
 230 }
 231
 232 //=========================================================================
 233 // virtual
 234 sal_Int32 SAL_CALL UcbContentProviderProxy::compareContentIds(
 235                        const Reference< XContentIdentifier >& Id1,
 236                        const Reference< XContentIdentifier >& Id2 )
 237     throw( RuntimeException )
 238 {
 239     // Get original provider an forward the call...
 240
 241     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 242     Reference< XContentProvider > xProvider = getContentProvider();
 243     if ( xProvider.is() )
 244         return xProvider->compareContentIds( Id1, Id2 );
 245
 246     // OSL_FAIL( // "UcbContentProviderProxy::compareContentIds - No provider!" );
 247
 248     // @@@ What else?
 249     return 0;
 250 }
 251
 252 //=========================================================================
 253 //
 254 // XParameterizedContentProvider methods.
 255 //
 256 //=========================================================================
 257
 258 // virtual
 259 Reference< XContentProvider > SAL_CALL
 260 UcbContentProviderProxy::registerInstance( const OUString& Template,
 261                                              const OUString& Arguments,
 262                                              sal_Bool ReplaceExisting )
 263     throw( IllegalArgumentException,
 264            RuntimeException )
 265 {
 266     // Just remember that this method was called ( and the params ).
 267
 268     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 269
 270     if ( !m_bRegister )
 271     {
 272 //      m_xTargetProvider = 0;
 273         m_aTemplate  = Template;
 274         m_aArguments = Arguments;
 275         m_bReplace   = ReplaceExisting;
 276
 277         m_bRegister  = sal_True;
 278     }
 279     return this;
 280 }
 281
 282 //=========================================================================
 283 // virtual
 284 Reference< XContentProvider > SAL_CALL
 285 UcbContentProviderProxy::deregisterInstance( const OUString& Template,
 286                                              const OUString& Arguments )
 287     throw( IllegalArgumentException,
 288            RuntimeException )
 289 {
 290     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 291
 292     // registerInstance called at proxy and at original?
 293     if ( m_bRegister && m_xTargetProvider.is() )
 294     {
 295         m_bRegister       = sal_False;
 296         m_xTargetProvider = 0;
 297
 298         Reference< XParameterizedContentProvider >
 299                                 xParamProvider( m_xProvider, UNO_QUERY );
 300         if ( xParamProvider.is() )
 301         {
 302             try
 303             {
 304                 xParamProvider->deregisterInstance( Template, Arguments );
 305             }
 306             catch ( IllegalIdentifierException const & )
 307             {
 308                 OSL_FAIL( "UcbContentProviderProxy::deregisterInstance - "
 309                     "Caught IllegalIdentifierException!" );
 310             }
 311         }
 312     }
 313
 314     return this;
 315 }
 316
 317 //=========================================================================
 318 //
 319 // XContentProviderSupplier methods.
 320 //
 321 //=========================================================================
 322
 323 // virtual
 324 Reference< XContentProvider > SAL_CALL
 325 UcbContentProviderProxy::getContentProvider()
 326     throw( RuntimeException )
 327 {
 328     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 329     if ( !m_xProvider.is() )
 330     {
 331         try
 332         {
 333             m_xProvider
 334                 = Reference< XContentProvider >(
 335                       m_xSMgr->createInstance( m_aService ), UNO_QUERY );
 336             if ( m_aArguments == "NoConfig" )
 337             {
 338                 Reference<XInitialization> xInit(m_xProvider,UNO_QUERY);
 339                 if(xInit.is()) {
 340                     Sequence<Any> aArgs(1);
 341                     aArgs[0] <<= m_aArguments;
 342                     xInit->initialize(aArgs);
 343                 }
 344             }
 345         }
 346         catch ( RuntimeException const & )
 347         {
 348             throw;
 349         }
 350         catch ( Exception const & e)
 351         {
 352             SAL_INFO( "ucb.core", "Exception when getting content provider: " << e.Message );
 353         }
 354
 355         // registerInstance called at proxy, but not yet at original?
 356         if ( m_xProvider.is() && m_bRegister )
 357         {
 358             Reference< XParameterizedContentProvider >
 359                 xParamProvider( m_xProvider, UNO_QUERY );
 360             if ( xParamProvider.is() )
 361             {
 362                 try
 363                 {
 364                     m_xTargetProvider
 365                         = xParamProvider->registerInstance( m_aTemplate,
 366                                                             m_aArguments,
 367                                                             m_bReplace );
 368                 }
 369                 catch ( IllegalIdentifierException const & )
 370                 {
 371                     OSL_FAIL( "UcbContentProviderProxy::getContentProvider - "
 372                         "Caught IllegalIdentifierException!" );
 373                 }
 374
 375                 OSL_ENSURE( m_xTargetProvider.is(),
 376                     "UcbContentProviderProxy::getContentProvider - "
 377                     "No provider!" );
 378             }
 379         }
 380         if ( !m_xTargetProvider.is() )
 381             m_xTargetProvider = m_xProvider;
 382     }
 383
 384     OSL_ENSURE( m_xProvider.is(),
 385         OStringBuffer("UcbContentProviderProxy::getContentProvider - No provider for '").append(OUStringToOString(m_aService, osl_getThreadTextEncoding())).append(".").getStr() );
 386     return m_xTargetProvider;
 387 }
 388
 389 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */