cppu/source/threadpool/current.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: current.cxx,v $
  10  * $Revision: 1.16 $
  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_cppu.hxx"
  33
  34 #include "rtl/uuid.h"
  35 #include "osl/thread.h"
  36 #include "osl/mutex.hxx"
  37
  38 #include "uno/environment.hxx"
  39 #include "uno/mapping.hxx"
  40 #include "uno/lbnames.h"
  41 #include "typelib/typedescription.h"
  42
  43 #include "current.hxx"
  44
  45
  46 using namespace ::osl;
  47 using namespace ::rtl;
  48 using namespace ::cppu;
  49 using namespace ::com::sun::star::uno;
  50
  51 namespace cppu
  52 {
  53
  54 //--------------------------------------------------------------------------------------------------
  55 class SAL_NO_VTABLE XInterface
  56 {
  57 public:
  58     virtual void SAL_CALL slot_queryInterface() = 0;
  59     virtual void SAL_CALL acquire() throw () = 0;
  60     virtual void SAL_CALL release() throw () = 0;
  61 };
  62 //--------------------------------------------------------------------------------------------------
  63 static typelib_InterfaceTypeDescription * get_type_XCurrentContext()
  64 {
  65     static typelib_InterfaceTypeDescription * s_type_XCurrentContext = 0;
  66     if (0 == s_type_XCurrentContext)
  67     {
  68         ::osl::MutexGuard aGuard( ::osl::Mutex::getGlobalMutex() );
  69         if (0 == s_type_XCurrentContext)
  70         {
  71             OUString sTypeName( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.uno.XCurrentContext") );
  72             typelib_InterfaceTypeDescription * pTD = 0;
  73             typelib_TypeDescriptionReference * pMembers[1] = { 0 };
  74             OUString sMethodName0(
  75                 RTL_CONSTASCII_USTRINGPARAM("com.sun.star.uno.XCurrentContext::getValueByName") );
  76             typelib_typedescriptionreference_new(
  77                 &pMembers[0],
  78                 typelib_TypeClass_INTERFACE_METHOD,
  79                 sMethodName0.pData );
  80             typelib_typedescription_newInterface(
  81                 &pTD,
  82                 sTypeName.pData, 0x00000000, 0x0000, 0x0000, 0x00000000, 0x00000000,
  83                 * typelib_static_type_getByTypeClass( typelib_TypeClass_INTERFACE ),
  84                 1,
  85                 pMembers );
  86
  87             typelib_typedescription_register( (typelib_TypeDescription**)&pTD );
  88             typelib_typedescriptionreference_release( pMembers[0] );
  89
  90             typelib_InterfaceMethodTypeDescription * pMethod = 0;
  91             typelib_Parameter_Init aParameters[1];
  92             OUString sParamName0( RTL_CONSTASCII_USTRINGPARAM("Name") );
  93             OUString sParamType0( RTL_CONSTASCII_USTRINGPARAM("string") );
  94             aParameters[0].pParamName = sParamName0.pData;
  95             aParameters[0].eTypeClass = typelib_TypeClass_STRING;
  96             aParameters[0].pTypeName = sParamType0.pData;
  97             aParameters[0].bIn = sal_True;
  98             aParameters[0].bOut = sal_False;
  99             rtl_uString * pExceptions[1];
 100             OUString sExceptionName0(
 101                 RTL_CONSTASCII_USTRINGPARAM("com.sun.star.uno.RuntimeException") );
 102             pExceptions[0] = sExceptionName0.pData;
 103             OUString sReturnType0( RTL_CONSTASCII_USTRINGPARAM("any") );
 104             typelib_typedescription_newInterfaceMethod(
 105                 &pMethod,
 106                 3, sal_False,
 107                 sMethodName0.pData,
 108                 typelib_TypeClass_ANY, sReturnType0.pData,
 109                 1, aParameters, 1, pExceptions );
 110             typelib_typedescription_register( (typelib_TypeDescription**)&pMethod );
 111             typelib_typedescription_release( (typelib_TypeDescription*)pMethod );
 112 #if ! defined CPPU_LEAK_STATIC_DATA
 113             // another static ref
 114             ++reinterpret_cast< typelib_TypeDescription * >( pTD )->
 115                 nStaticRefCount;
 116 #endif
 117             s_type_XCurrentContext = pTD;
 118         }
 119     }
 120     return s_type_XCurrentContext;
 121 }
 122
 123 //##################################################################################################
 124
 125 //==================================================================================================
 126 class ThreadKey
 127 {
 128     sal_Bool     _bInit;
 129     oslThreadKey _hThreadKey;
 130     oslThreadKeyCallbackFunction _pCallback;
 131
 132 public:
 133     inline oslThreadKey getThreadKey() SAL_THROW( () );
 134
 135     inline ThreadKey( oslThreadKeyCallbackFunction pCallback ) SAL_THROW( () );
 136     inline ~ThreadKey() SAL_THROW( () );
 137 };
 138 //__________________________________________________________________________________________________
 139 inline ThreadKey::ThreadKey( oslThreadKeyCallbackFunction pCallback ) SAL_THROW( () )
 140     : _bInit( sal_False )
 141     , _pCallback( pCallback )
 142 {
 143 }
 144 //__________________________________________________________________________________________________
 145 inline ThreadKey::~ThreadKey() SAL_THROW( () )
 146 {
 147     if (_bInit)
 148     {
 149         ::osl_destroyThreadKey( _hThreadKey );
 150     }
 151 }
 152 //__________________________________________________________________________________________________
 153 inline oslThreadKey ThreadKey::getThreadKey() SAL_THROW( () )
 154 {
 155     if (! _bInit)
 156     {
 157         MutexGuard aGuard( Mutex::getGlobalMutex() );
 158         if (! _bInit)
 159         {
 160             _hThreadKey = ::osl_createThreadKey( _pCallback );
 161             _bInit = sal_True;
 162         }
 163     }
 164     return _hThreadKey;
 165 }
 166
 167 //==================================================================================================
 168 extern "C" void SAL_CALL delete_IdContainer( void * p )
 169 {
 170     if (p)
 171     {
 172         IdContainer * pId = reinterpret_cast< IdContainer * >( p );
 173         if (pId->pCurrentContext)
 174         {
 175             (*pId->pCurrentContextEnv->releaseInterface)(
 176                 pId->pCurrentContextEnv, pId->pCurrentContext );
 177             (*((uno_Environment *)pId->pCurrentContextEnv)->release)(
 178                 (uno_Environment *)pId->pCurrentContextEnv );
 179         }
 180         if (pId->bInit)
 181         {
 182             ::rtl_byte_sequence_release( pId->pLocalThreadId );
 183             ::rtl_byte_sequence_release( pId->pCurrentId );
 184         }
 185         delete pId;
 186     }
 187 }
 188 //==================================================================================================
 189 IdContainer * getIdContainer() SAL_THROW( () )
 190 {
 191     static ThreadKey s_key( delete_IdContainer );
 192     oslThreadKey aKey = s_key.getThreadKey();
 193
 194     IdContainer * pId = reinterpret_cast< IdContainer * >( ::osl_getThreadKeyData( aKey ) );
 195     if (! pId)
 196     {
 197         pId = new IdContainer();
 198         pId->pCurrentContext = 0;
 199         pId->pCurrentContextEnv = 0;
 200         pId->bInit = sal_False;
 201         ::osl_setThreadKeyData( aKey, pId );
 202     }
 203     return pId;
 204 }
 205
 206 }
 207
 208 //##################################################################################################
 209 extern "C" sal_Bool SAL_CALL uno_setCurrentContext(
 210     void * pCurrentContext,
 211     rtl_uString * pEnvTypeName, void * pEnvContext )
 212     SAL_THROW_EXTERN_C()
 213 {
 214     IdContainer * pId = getIdContainer();
 215     OSL_ASSERT( pId );
 216
 217     // free old one
 218     if (pId->pCurrentContext)
 219     {
 220         (*pId->pCurrentContextEnv->releaseInterface)(
 221             pId->pCurrentContextEnv, pId->pCurrentContext );
 222         (*((uno_Environment *)pId->pCurrentContextEnv)->release)(
 223             (uno_Environment *)pId->pCurrentContextEnv );
 224         pId->pCurrentContextEnv = 0;
 225
 226         pId->pCurrentContext = 0;
 227     }
 228
 229     if (pCurrentContext)
 230     {
 231         uno_Environment * pEnv = 0;
 232         ::uno_getEnvironment( &pEnv, pEnvTypeName, pEnvContext );
 233         OSL_ASSERT( pEnv && pEnv->pExtEnv );
 234         if (pEnv)
 235         {
 236             if (pEnv->pExtEnv)
 237             {
 238                 pId->pCurrentContextEnv = pEnv->pExtEnv;
 239                 (*pId->pCurrentContextEnv->acquireInterface)(
 240                     pId->pCurrentContextEnv, pCurrentContext );
 241                 pId->pCurrentContext = pCurrentContext;
 242             }
 243             else
 244             {
 245                 (*pEnv->release)( pEnv );
 246                 return sal_False;
 247             }
 248         }
 249         else
 250         {
 251             return sal_False;
 252         }
 253     }
 254     return sal_True;
 255 }
 256 //##################################################################################################
 257 extern "C" sal_Bool SAL_CALL uno_getCurrentContext(
 258     void ** ppCurrentContext, rtl_uString * pEnvTypeName, void * pEnvContext )
 259     SAL_THROW_EXTERN_C()
 260 {
 261     IdContainer * pId = getIdContainer();
 262     OSL_ASSERT( pId );
 263
 264     Environment target_env;
 265
 266     // release inout parameter
 267     if (*ppCurrentContext)
 268     {
 269         target_env = Environment(rtl::OUString(pEnvTypeName), pEnvContext);
 270         OSL_ASSERT( target_env.is() );
 271         if (! target_env.is())
 272             return sal_False;
 273         uno_ExtEnvironment * pEnv = target_env.get()->pExtEnv;
 274         OSL_ASSERT( 0 != pEnv );
 275         if (0 == pEnv)
 276             return sal_False;
 277         (*pEnv->releaseInterface)( pEnv, *ppCurrentContext );
 278
 279         *ppCurrentContext = 0;
 280     }
 281
 282     // case: null-ref
 283     if (0 == pId->pCurrentContext)
 284         return sal_True;
 285
 286     if (! target_env.is())
 287     {
 288         target_env = Environment(rtl::OUString(pEnvTypeName), pEnvContext);
 289         OSL_ASSERT( target_env.is() );
 290         if (! target_env.is())
 291             return sal_False;
 292     }
 293
 294     Mapping mapping((uno_Environment *) pId->pCurrentContextEnv, target_env.get());
 295     OSL_ASSERT( mapping.is() );
 296     if (! mapping.is())
 297         return sal_False;
 298
 299     mapping.mapInterface(ppCurrentContext, pId->pCurrentContext, ::cppu::get_type_XCurrentContext() );
 300
 301     return sal_True;
 302 }