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 <tools/diagnose_ex.h>
  24 #include "provprox.hxx"
  25 #include <com/sun/star/lang/XInitialization.hpp>
  26 #include <com/sun/star/ucb/IllegalIdentifierException.hpp>
  27 #include <cppuhelper/queryinterface.hxx>
  28 #include <cppuhelper/weak.hxx>
  29 #include <ucbhelper/macros.hxx>
  30
  31 using namespace com::sun::star::lang;
  32 using namespace com::sun::star::ucb;
  33 using namespace com::sun::star::uno;
  34
  35 // UcbContentProviderProxyFactory Implementation.
  36
  37
  38 UcbContentProviderProxyFactory::UcbContentProviderProxyFactory(
  39                         const Reference< XComponentContext >& rxContext )
  40 : UcbContentProviderProxyFactory_Base(m_aMutex), m_xContext( rxContext )
  41 {
  42 }
  43
  44
  45 // virtual
  46 UcbContentProviderProxyFactory::~UcbContentProviderProxyFactory()
  47 {
  48 }
  49
  50 // XServiceInfo methods.
  51
  52 OUString SAL_CALL UcbContentProviderProxyFactory::getImplementationName()
  53 {
  54     return "com.sun.star.comp.ucb.UcbContentProviderProxyFactory";
  55 }
  56 sal_Bool SAL_CALL UcbContentProviderProxyFactory::supportsService( const OUString& ServiceName )
  57 {
  58     return cppu::supportsService( this, ServiceName );
  59 }
  60 css::uno::Sequence< OUString > SAL_CALL UcbContentProviderProxyFactory::getSupportedServiceNames()
  61 {
  62     return { "com.sun.star.ucb.ContentProviderProxyFactory" };
  63 }
  64
  65 // Service factory implementation.
  66
  67
  68 extern "C" SAL_DLLPUBLIC_EXPORT css::uno::XInterface*
  69 ucb_UcbContentProviderProxyFactory_get_implementation(
  70     css::uno::XComponentContext* context , css::uno::Sequence<css::uno::Any> const&)
  71 {
  72     return cppu::acquire(
  73         static_cast<cppu::OWeakObject*>(new UcbContentProviderProxyFactory(context)));
  74 }
  75
  76
  77 // XContentProviderFactory methods.
  78
  79
  80 // virtual
  81 Reference< XContentProvider > SAL_CALL
  82 UcbContentProviderProxyFactory::createContentProvider(
  83                                                 const OUString& Service )
  84 {
  85     return Reference< XContentProvider >(
  86                         new UcbContentProviderProxy( m_xContext, Service ) );
  87 }
  88
  89
  90 // UcbContentProviderProxy Implementation.
  91
  92
  93 UcbContentProviderProxy::UcbContentProviderProxy(
  94                         const Reference< XComponentContext >& rxContext,
  95                         const OUString& Service )
  96 : m_aService( Service ),
  97   m_bReplace( false ),
  98   m_bRegister( false ),
  99   m_xContext( rxContext )
 100 {
 101 }
 102
 103
 104 // virtual
 105 UcbContentProviderProxy::~UcbContentProviderProxy()
 106 {
 107 }
 108
 109
 110 // XInterface methods.
 111 void SAL_CALL UcbContentProviderProxy::acquire()
 112     throw()
 113 {
 114     OWeakObject::acquire();
 115 }
 116
 117 void SAL_CALL UcbContentProviderProxy::release()
 118     throw()
 119 {
 120     OWeakObject::release();
 121 }
 122
 123 // virtual
 124 Any SAL_CALL
 125 UcbContentProviderProxy::queryInterface( const Type & rType )
 126 {
 127     Any aRet = cppu::queryInterface( rType,
 128                 static_cast< XTypeProvider * >( this ),
 129                 static_cast< XServiceInfo * >( this ),
 130                 static_cast< XContentProvider * >( this ),
 131                 static_cast< XParameterizedContentProvider * >( this ),
 132                 static_cast< XContentProviderSupplier * >( this ) );
 133
 134     if ( !aRet.hasValue() )
 135         aRet = OWeakObject::queryInterface( rType );
 136
 137     if ( !aRet.hasValue() )
 138     {
 139         // Get original provider and forward the call...
 140         osl::Guard< osl::Mutex > aGuard( m_aMutex );
 141         Reference< XContentProvider > xProvider = getContentProvider();
 142         if ( xProvider.is() )
 143             aRet = xProvider->queryInterface( rType );
 144     }
 145
 146     return aRet;
 147 }
 148
 149
 150 // XTypeProvider methods.
 151
 152
 153 XTYPEPROVIDER_COMMON_IMPL( UcbContentProviderProxy );
 154
 155
 156 Sequence< Type > SAL_CALL UcbContentProviderProxy::getTypes()
 157 {
 158     // Get original provider and forward the call...
 159     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 160     Reference< XTypeProvider > xProvider( getContentProvider(), UNO_QUERY );
 161     if ( xProvider.is() )
 162     {
 163         return xProvider->getTypes();
 164     }
 165     else
 166     {
 167         static cppu::OTypeCollection s_aCollection(
 168             CPPU_TYPE_REF( XTypeProvider ),
 169             CPPU_TYPE_REF( XServiceInfo ),
 170             CPPU_TYPE_REF( XContentProvider ),
 171             CPPU_TYPE_REF( XParameterizedContentProvider ),
 172             CPPU_TYPE_REF( XContentProviderSupplier ) );
 173         return s_aCollection.getTypes();
 174     }
 175 }
 176
 177
 178 // XServiceInfo methods.
 179
 180 OUString SAL_CALL UcbContentProviderProxy::getImplementationName()
 181 {
 182     return "com.sun.star.comp.ucb.UcbContentProviderProxy";
 183 }
 184
 185 sal_Bool SAL_CALL UcbContentProviderProxy::supportsService( const OUString& ServiceName )
 186 {
 187     return cppu::supportsService( this, ServiceName );
 188 }
 189
 190 css::uno::Sequence< OUString > SAL_CALL UcbContentProviderProxy::getSupportedServiceNames()
 191 {
 192     return { "com.sun.star.ucb.ContentProviderProxy" };
 193 }
 194
 195
 196 // XContentProvider methods.
 197
 198
 199 // virtual
 200 Reference< XContent > SAL_CALL UcbContentProviderProxy::queryContent(
 201                         const Reference< XContentIdentifier >& Identifier )
 202 {
 203     // Get original provider and forward the call...
 204
 205     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 206
 207     Reference< XContentProvider > xProvider = getContentProvider();
 208     if ( xProvider.is() )
 209         return xProvider->queryContent( Identifier );
 210
 211     return Reference< XContent >();
 212 }
 213
 214
 215 // virtual
 216 sal_Int32 SAL_CALL UcbContentProviderProxy::compareContentIds(
 217                        const Reference< XContentIdentifier >& Id1,
 218                        const Reference< XContentIdentifier >& Id2 )
 219 {
 220     // Get original provider and forward the call...
 221
 222     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 223     Reference< XContentProvider > xProvider = getContentProvider();
 224     if ( xProvider.is() )
 225         return xProvider->compareContentIds( Id1, Id2 );
 226
 227     // OSL_FAIL( // "UcbContentProviderProxy::compareContentIds - No provider!" );
 228
 229     // @@@ What else?
 230     return 0;
 231 }
 232
 233
 234 // XParameterizedContentProvider methods.
 235
 236
 237 // virtual
 238 Reference< XContentProvider > SAL_CALL
 239 UcbContentProviderProxy::registerInstance( const OUString& Template,
 240                                              const OUString& Arguments,
 241                                              sal_Bool ReplaceExisting )
 242 {
 243     // Just remember that this method was called ( and the params ).
 244
 245     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 246
 247     if ( !m_bRegister )
 248     {
 249 //      m_xTargetProvider = 0;
 250         m_aTemplate  = Template;
 251         m_aArguments = Arguments;
 252         m_bReplace   = ReplaceExisting;
 253
 254         m_bRegister  = true;
 255     }
 256     return this;
 257 }
 258
 259
 260 // virtual
 261 Reference< XContentProvider > SAL_CALL
 262 UcbContentProviderProxy::deregisterInstance( const OUString& Template,
 263                                              const OUString& Arguments )
 264 {
 265     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 266
 267     // registerInstance called at proxy and at original?
 268     if ( m_bRegister && m_xTargetProvider.is() )
 269     {
 270         m_bRegister       = false;
 271         m_xTargetProvider = nullptr;
 272
 273         Reference< XParameterizedContentProvider >
 274                                 xParamProvider( m_xProvider, UNO_QUERY );
 275         if ( xParamProvider.is() )
 276         {
 277             try
 278             {
 279                 xParamProvider->deregisterInstance( Template, Arguments );
 280             }
 281             catch ( IllegalIdentifierException const & )
 282             {
 283                 OSL_FAIL( "UcbContentProviderProxy::deregisterInstance - "
 284                     "Caught IllegalIdentifierException!" );
 285             }
 286         }
 287     }
 288
 289     return this;
 290 }
 291
 292
 293 // XContentProviderSupplier methods.
 294
 295
 296 // virtual
 297 Reference< XContentProvider > SAL_CALL
 298 UcbContentProviderProxy::getContentProvider()
 299 {
 300     osl::Guard< osl::Mutex > aGuard( m_aMutex );
 301     if ( !m_xProvider.is() )
 302     {
 303         try
 304         {
 305             m_xProvider.set( m_xContext->getServiceManager()->createInstanceWithContext( m_aService,m_xContext ), UNO_QUERY );
 306             if ( m_aArguments == "NoConfig" )
 307             {
 308                 Reference<XInitialization> xInit(m_xProvider,UNO_QUERY);
 309                 if(xInit.is()) {
 310                     Sequence<Any> aArgs(1);
 311                     aArgs[0] <<= m_aArguments;
 312                     xInit->initialize(aArgs);
 313                 }
 314             }
 315         }
 316         catch ( RuntimeException const & )
 317         {
 318             throw;
 319         }
 320         catch ( Exception const & )
 321         {
 322             TOOLS_INFO_EXCEPTION( "ucb.core", "Exception getting content provider");
 323         }
 324
 325         // registerInstance called at proxy, but not yet at original?
 326         if ( m_xProvider.is() && m_bRegister )
 327         {
 328             Reference< XParameterizedContentProvider >
 329                 xParamProvider( m_xProvider, UNO_QUERY );
 330             if ( xParamProvider.is() )
 331             {
 332                 try
 333                 {
 334                     m_xTargetProvider
 335                         = xParamProvider->registerInstance( m_aTemplate,
 336                                                             m_aArguments,
 337                                                             m_bReplace );
 338                 }
 339                 catch ( IllegalIdentifierException const & )
 340                 {
 341                     OSL_FAIL( "UcbContentProviderProxy::getContentProvider - "
 342                         "Caught IllegalIdentifierException!" );
 343                 }
 344
 345                 OSL_ENSURE( m_xTargetProvider.is(),
 346                     "UcbContentProviderProxy::getContentProvider - "
 347                     "No provider!" );
 348             }
 349         }
 350         if ( !m_xTargetProvider.is() )
 351             m_xTargetProvider = m_xProvider;
 352     }
 353
 354     OSL_ENSURE( m_xProvider.is(),
 355         OStringBuffer("UcbContentProviderProxy::getContentProvider - No provider for '").append(OUStringToOString(m_aService, osl_getThreadTextEncoding())).append(".").getStr() );
 356     return m_xTargetProvider;
 357 }
 358
 359 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */