ucb/source/ucp/gvfs/provider.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: provider.cxx,v $
  10  * $Revision: 1.9 $
  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
  34 #include <ucbhelper/contentidentifier.hxx>
  35 #include <osl/mutex.hxx>
  36 #include <vcl/svapp.hxx>
  37
  38 #include <libgnomevfs/gnome-vfs-init.h>
  39 #include "provider.hxx"
  40 #include "content.hxx"
  41
  42 using namespace com::sun::star;
  43 using namespace gvfs;
  44
  45 //=========================================================================
  46 //=========================================================================
  47 //
  48 // ContentProvider Implementation.
  49 //
  50 //=========================================================================
  51 //=========================================================================
  52
  53 ContentProvider::ContentProvider(
  54     const uno::Reference< lang::XMultiServiceFactory >& rSMgr )
  55 : ::ucbhelper::ContentProviderImplHelper( rSMgr )
  56 {
  57 }
  58 // sdafas
  59 //=========================================================================
  60 // virtual
  61 ContentProvider::~ContentProvider()
  62 {
  63 }
  64
  65 //=========================================================================
  66 //
  67 // XInterface methods.
  68 //
  69 //=========================================================================
  70
  71 XINTERFACE_IMPL_3( ContentProvider,
  72                    lang::XTypeProvider,
  73                    lang::XServiceInfo,
  74                    com::sun::star::ucb::XContentProvider );
  75
  76 //=========================================================================
  77 //
  78 // XTypeProvider methods.
  79 //
  80 //=========================================================================
  81
  82 XTYPEPROVIDER_IMPL_3( ContentProvider,
  83                       lang::XTypeProvider,
  84                       lang::XServiceInfo,
  85                       com::sun::star::ucb::XContentProvider );
  86
  87 //=========================================================================
  88 //
  89 // XServiceInfo methods.
  90 //
  91 //=========================================================================
  92
  93 XSERVICEINFO_IMPL_1( ContentProvider,
  94                      rtl::OUString::createFromAscii(
  95             "com.sun.star.comp.GnomeVFSContentProvider" ),
  96                      rtl::OUString::createFromAscii(
  97             "com.sun.star.ucb.GnomeVFSContentProvider" ) );
  98 //=========================================================================
  99 //
 100 // Service factory implementation.
 101 //
 102 //=========================================================================
 103
 104 ONE_INSTANCE_SERVICE_FACTORY_IMPL( ContentProvider );
 105
 106 //=========================================================================
 107 //
 108 // XContentProvider methods.
 109 //
 110 //=========================================================================
 111
 112 uno::Reference< com::sun::star::ucb::XContent > SAL_CALL
 113 ContentProvider::queryContent(
 114             const uno::Reference<
 115                     com::sun::star::ucb::XContentIdentifier >& Identifier )
 116     throw( com::sun::star::ucb::IllegalIdentifierException,
 117            uno::RuntimeException )
 118 {
 119 #ifdef DEBUG
 120     g_warning ("QueryContent: '%s'",
 121                (const sal_Char *)rtl::OUStringToOString
 122                (Identifier->getContentIdentifier(), RTL_TEXTENCODING_UTF8));
 123 #endif
 124
 125     osl::MutexGuard aGuard( m_aMutex );
 126
 127     // Check, if a content with given id already exists...
 128     uno::Reference< com::sun::star::ucb::XContent > xContent
 129         = queryExistingContent( Identifier ).get();
 130     if ( xContent.is() )
 131         return xContent;
 132
 133     try
 134     {
 135         xContent = new ::gvfs::Content(m_xSMgr, this, Identifier );
 136         registerNewContent( xContent );
 137     }
 138     catch ( com::sun::star::ucb::ContentCreationException const & )
 139     {
 140         throw com::sun::star::ucb::IllegalIdentifierException();
 141     }
 142
 143     if ( !xContent->getIdentifier().is() )
 144         throw com::sun::star::ucb::IllegalIdentifierException();
 145
 146     return xContent;
 147 }
 148
 149
 150 //============================ shlib entry points =============================================
 151
 152
 153 // cut and paste verbatim from webdav (that sucks).
 154 static sal_Bool
 155 writeInfo( void                                 *pRegistryKey,
 156        const rtl::OUString                  &rImplementationName,
 157        uno::Sequence< rtl::OUString > const &rServiceNames )
 158 {
 159     rtl::OUString aKeyName( rtl::OUString::createFromAscii( "/" ) );
 160     aKeyName += rImplementationName;
 161     aKeyName += rtl::OUString::createFromAscii( "/UNO/SERVICES" );
 162
 163     uno::Reference< registry::XRegistryKey > xKey;
 164     try {
 165         xKey = static_cast< registry::XRegistryKey * >
 166             (pRegistryKey )->createKey( aKeyName );
 167     }
 168     catch ( registry::InvalidRegistryException const & ) {
 169     }
 170
 171     if ( !xKey.is() )
 172         return sal_False;
 173
 174     sal_Bool bSuccess = sal_True;
 175
 176     for ( sal_Int32 n = 0; n < rServiceNames.getLength(); ++n ) {
 177         try {
 178             xKey->createKey( rServiceNames[ n ] );
 179
 180         } catch ( registry::InvalidRegistryException const & ) {
 181             bSuccess = sal_False;
 182             break;
 183         }
 184     }
 185     return bSuccess;
 186 }
 187
 188 extern "C" void SAL_CALL
 189 component_getImplementationEnvironment( const sal_Char  **ppEnvTypeName,
 190                     uno_Environment **/*ppEnv*/ )
 191 {
 192     *ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME;
 193 }
 194
 195 extern "C" sal_Bool SAL_CALL
 196 component_writeInfo( void */*pServiceManager*/,
 197              void *pRegistryKey )
 198 {
 199     return pRegistryKey &&
 200         writeInfo( pRegistryKey,
 201                ::gvfs::ContentProvider::getImplementationName_Static(),
 202                ::gvfs::ContentProvider::getSupportedServiceNames_Static() );
 203 }
 204
 205 /* This class is here to be able to initialize gnome-vfs in the main thread */
 206 class GnomeVFSInitializator
 207 {
 208 private:
 209     osl::Mutex m_aLock;
 210     bool m_bInitialized;
 211
 212 public:
 213     GnomeVFSInitializator() : m_bInitialized( false ) {}
 214
 215     void init()
 216     {
 217         Application::PostUserEvent( LINK( this, GnomeVFSInitializator, ImplInitializeGnomeVFS ) );
 218
 219         // cannot use a condition variable here, leads to a deadlock
 220         while (1)
 221         {
 222             {
 223                 osl::MutexGuard aGuard( m_aLock );
 224                 if ( m_bInitialized )
 225                     break;
 226             }
 227             Application::Yield();
 228         }
 229     }
 230
 231 private:
 232     DECL_LINK( ImplInitializeGnomeVFS, void* );
 233 };
 234
 235 IMPL_LINK( GnomeVFSInitializator, ImplInitializeGnomeVFS, void*, EMPTYARG )
 236 {
 237     osl::MutexGuard aGuard( osl::Mutex::getGlobalMutex() );
 238
 239     // this must be performed in the same thread where we initialized
 240     // Gtk+ (if we did)
 241     if ( !gnome_vfs_initialized () )
 242         gnome_vfs_init ();
 243     if ( !auth_queue )
 244         auth_queue = g_private_new( auth_queue_destroy );
 245
 246     m_aLock.acquire();
 247     m_bInitialized = true;
 248     m_aLock.release();
 249
 250     return 0;
 251 }
 252
 253 extern "C" void * SAL_CALL
 254 component_getFactory( const sal_Char *pImplName,
 255               void           *pServiceManager,
 256               void           */*pRegistryKey*/ )
 257 {
 258     void * pRet = 0;
 259
 260         GnomeVFSInitializator aInitializator;
 261         aInitializator.init();
 262
 263     uno::Reference< lang::XMultiServiceFactory > xSMgr
 264         (reinterpret_cast< lang::XMultiServiceFactory * >( pServiceManager ) );
 265     uno::Reference< lang::XSingleServiceFactory > xFactory;
 266
 267     if ( !::gvfs::ContentProvider::getImplementationName_Static().compareToAscii( pImplName ) )
 268         xFactory = ::gvfs::ContentProvider::createServiceFactory( xSMgr );
 269
 270     if ( xFactory.is() ) {
 271         xFactory->acquire();
 272         pRet = xFactory.get();
 273     }
 274
 275     return pRet;
 276 }
 277
 278