diff options
Diffstat (limited to 'cppu/source/helper/purpenv/helper_purpenv_Proxy.cxx')
| -rw-r--r-- | cppu/source/helper/purpenv/helper_purpenv_Proxy.cxx | 532 |
1 files changed, 0 insertions, 532 deletions
diff --git a/cppu/source/helper/purpenv/helper_purpenv_Proxy.cxx b/cppu/source/helper/purpenv/helper_purpenv_Proxy.cxx deleted file mode 100644 index 500909905..000000000 --- a/cppu/source/helper/purpenv/helper_purpenv_Proxy.cxx +++ /dev/null @@ -1,532 +0,0 @@ -/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ -/************************************************************************* - * - * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. - * - * Copyright 2000, 2010 Oracle and/or its affiliates. - * - * OpenOffice.org - a multi-platform office productivity suite - * - * This file is part of OpenOffice.org. - * - * OpenOffice.org is free software: you can redistribute it and/or modify - * it under the terms of the GNU Lesser General Public License version 3 - * only, as published by the Free Software Foundation. - * - * OpenOffice.org is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU Lesser General Public License version 3 for more details - * (a copy is included in the LICENSE file that accompanied this code). - * - * You should have received a copy of the GNU Lesser General Public License - * version 3 along with OpenOffice.org. If not, see - * <http://www.openoffice.org/license.html> - * for a copy of the LGPLv3 License. - * - ************************************************************************/ - -// MARKER(update_precomp.py): autogen include statement, do not remove -#include "precompiled_cppu.hxx" - -#include "Proxy.hxx" - -#include "sal/alloca.h" -#include "uno/dispatcher.h" -#include "typelib/typedescription.hxx" -#include "cppu/EnvDcp.hxx" - - -//#define LOG_LIFECYCLE_Proxy -#ifdef LOG_LIFECYCLE_Proxy -# include <iostream> -# define LOG_LIFECYCLE_Proxy_emit(x) x - -#else -# define LOG_LIFECYCLE_Proxy_emit(x) - -#endif - - -using namespace com::sun::star; - - -static bool relatesToInterface(typelib_TypeDescription * pTypeDescr) - SAL_THROW( () ) -{ - switch (pTypeDescr->eTypeClass) - { -// case typelib_TypeClass_TYPEDEF: - case typelib_TypeClass_SEQUENCE: - { - switch (((typelib_IndirectTypeDescription *)pTypeDescr)->pType->eTypeClass) - { - case typelib_TypeClass_INTERFACE: - case typelib_TypeClass_UNION: // might relate to interface - case typelib_TypeClass_ANY: // might relate to interface - return true; - case typelib_TypeClass_SEQUENCE: - case typelib_TypeClass_STRUCT: - case typelib_TypeClass_EXCEPTION: - { - typelib_TypeDescription * pTD = 0; - TYPELIB_DANGER_GET( &pTD, ((typelib_IndirectTypeDescription *)pTypeDescr)->pType ); - bool bRel = relatesToInterface( pTD ); - TYPELIB_DANGER_RELEASE( pTD ); - return bRel; - } - default: - ; - } - return false; - } - case typelib_TypeClass_STRUCT: - case typelib_TypeClass_EXCEPTION: - { - // ...optimized... to avoid getDescription() calls! - typelib_CompoundTypeDescription * pComp = (typelib_CompoundTypeDescription *)pTypeDescr; - typelib_TypeDescriptionReference ** pTypes = pComp->ppTypeRefs; - for ( sal_Int32 nPos = pComp->nMembers; nPos--; ) - { - switch (pTypes[nPos]->eTypeClass) - { - case typelib_TypeClass_INTERFACE: - case typelib_TypeClass_UNION: // might relate to interface - case typelib_TypeClass_ANY: // might relate to interface - return true; -// case typelib_TypeClass_TYPEDEF: - case typelib_TypeClass_SEQUENCE: - case typelib_TypeClass_STRUCT: - case typelib_TypeClass_EXCEPTION: - { - typelib_TypeDescription * pTD = 0; - TYPELIB_DANGER_GET( &pTD, pTypes[nPos] ); - bool bRel = relatesToInterface( pTD ); - TYPELIB_DANGER_RELEASE( pTD ); - if (bRel) - return true; - } - default: - ; - } - } - if (pComp->pBaseTypeDescription) - return relatesToInterface( (typelib_TypeDescription *)pComp->pBaseTypeDescription ); - break; - } - case typelib_TypeClass_UNION: // might relate to interface - case typelib_TypeClass_ANY: // might relate to interface - case typelib_TypeClass_INTERFACE: - return true; - - default: - ; - } - return false; -} - -extern "C" { static void SAL_CALL s_Proxy_dispatch( - uno_Interface * pUnoI, - typelib_TypeDescription const * pMemberType, - void * pReturn, - void * pArgs[], - uno_Any ** ppException) - SAL_THROW_EXTERN_C() -{ - Proxy * pThis = static_cast<Proxy *>(pUnoI); - - typelib_MethodParameter param; - sal_Int32 nParams = 0; - typelib_MethodParameter * pParams = 0; - typelib_TypeDescriptionReference * pReturnTypeRef = 0; - // sal_Int32 nOutParams = 0; - - switch (pMemberType->eTypeClass) - { - case typelib_TypeClass_INTERFACE_ATTRIBUTE: - if (pReturn) - { - pReturnTypeRef = - ((typelib_InterfaceAttributeTypeDescription *) - pMemberType)->pAttributeTypeRef; - nParams = 0; - pParams = NULL; - } - else - { - param.pTypeRef = ((typelib_InterfaceAttributeTypeDescription *) - pMemberType)->pAttributeTypeRef; - param.bIn = sal_True; - param.bOut = sal_False; - nParams = 1; - pParams = ¶m; - } - break; - case typelib_TypeClass_INTERFACE_METHOD: - { - typelib_InterfaceMethodTypeDescription * method_td = - (typelib_InterfaceMethodTypeDescription *) pMemberType; - pReturnTypeRef = method_td->pReturnTypeRef; - nParams = method_td->nParams; - pParams = method_td->pParams; - break; - } - default: - OSL_FAIL( "### illegal member typeclass!" ); - abort(); - } - - pThis->dispatch( pReturnTypeRef, - pParams, - nParams, - pMemberType, - pReturn, - pArgs, - ppException ); -}} - -extern "C" void SAL_CALL Proxy_free(uno_ExtEnvironment * /*pEnv*/, void * pProxy) SAL_THROW_EXTERN_C() -{ - Proxy * pThis = static_cast<Proxy * >(reinterpret_cast<uno_Interface *>(pProxy)); - delete pThis; -} - -extern "C" { -static void SAL_CALL s_Proxy_acquire(uno_Interface * pUnoI) SAL_THROW_EXTERN_C() -{ - Proxy * pProxy = static_cast<Proxy *>(pUnoI); - pProxy->acquire(); -} - -static void SAL_CALL s_Proxy_release(uno_Interface * pUnoI) SAL_THROW_EXTERN_C() -{ - Proxy * pProxy = static_cast<Proxy *>(pUnoI); - pProxy->release(); -} - -static void s_acquireAndRegister_v(va_list * pParam) -{ - uno_Interface * pUnoI = va_arg(*pParam, uno_Interface *); - rtl_uString * pOid = va_arg(*pParam, rtl_uString *); - typelib_InterfaceTypeDescription * pTypeDescr = va_arg(*pParam, typelib_InterfaceTypeDescription *); - uno_ExtEnvironment * pEnv = va_arg(*pParam, uno_ExtEnvironment *); - - pUnoI->acquire(pUnoI); - pEnv->registerInterface(pEnv, reinterpret_cast<void **>(&pUnoI), pOid, pTypeDescr); -} -} - -Proxy::Proxy(uno::Mapping const & to_from, - uno_Environment * pTo, - uno_Environment * pFrom, - uno_Interface * pUnoI, - typelib_InterfaceTypeDescription * pTypeDescr, - rtl::OUString const & rOId, - cppu::helper::purpenv::ProbeFun * probeFun, - void * pProbeContext -) - SAL_THROW(()) - : m_nRef (1), - m_from (pFrom), - m_to (pTo), - m_from_to (pFrom, pTo), - m_to_from (to_from), - m_pUnoI (pUnoI), - m_pTypeDescr (pTypeDescr), - m_aOId (rOId), - m_probeFun (probeFun), - m_pProbeContext(pProbeContext) -{ - LOG_LIFECYCLE_Proxy_emit(fprintf(stderr, "LIFE: %s -> %p\n", "Proxy::Proxy(<>)", this)); - - typelib_typedescription_acquire((typelib_TypeDescription *)m_pTypeDescr); - if (!((typelib_TypeDescription *)m_pTypeDescr)->bComplete) - typelib_typedescription_complete((typelib_TypeDescription **)&m_pTypeDescr); - - OSL_ENSURE(((typelib_TypeDescription *)m_pTypeDescr)->bComplete, "### type is incomplete!"); - - uno_Environment_invoke(m_to.get(), s_acquireAndRegister_v, m_pUnoI, rOId.pData, pTypeDescr, m_to.get()); - - // uno_Interface - uno_Interface::acquire = s_Proxy_acquire; - uno_Interface::release = s_Proxy_release; - uno_Interface::pDispatcher = s_Proxy_dispatch; -} - -extern "C" { static void s_releaseAndRevoke_v(va_list * pParam) -{ - uno_ExtEnvironment * pEnv = va_arg(*pParam, uno_ExtEnvironment *); - uno_Interface * pUnoI = va_arg(*pParam, uno_Interface *); - - pEnv->revokeInterface(pEnv, reinterpret_cast<void *>(pUnoI)); - pUnoI->release(pUnoI); -}} - -Proxy::~Proxy() -{ - LOG_LIFECYCLE_Proxy_emit(fprintf(stderr, "LIFE: %s -> %p\n", "Proxy::~Proxy()", this)); - - uno_Environment_invoke(m_to.get(), s_releaseAndRevoke_v, m_to.get(), m_pUnoI); - - typelib_typedescription_release((typelib_TypeDescription *)m_pTypeDescr); -} - -static uno::TypeDescription getAcquireMethod(void) -{ - typelib_TypeDescriptionReference * type_XInterface = - * typelib_static_type_getByTypeClass(typelib_TypeClass_INTERFACE); - - typelib_TypeDescription * pTXInterfaceDescr = 0; - TYPELIB_DANGER_GET (&pTXInterfaceDescr, type_XInterface); - uno::TypeDescription acquire( - reinterpret_cast< typelib_InterfaceTypeDescription * >( - pTXInterfaceDescr)->ppAllMembers[1]); - TYPELIB_DANGER_RELEASE(pTXInterfaceDescr); - - return acquire; -} - -static uno::TypeDescription getReleaseMethod(void) -{ - typelib_TypeDescriptionReference * type_XInterface = - * typelib_static_type_getByTypeClass(typelib_TypeClass_INTERFACE); - - typelib_TypeDescription * pTXInterfaceDescr = 0; - TYPELIB_DANGER_GET (&pTXInterfaceDescr, type_XInterface); - uno::TypeDescription release( - reinterpret_cast< typelib_InterfaceTypeDescription * >( - pTXInterfaceDescr)->ppAllMembers[2]); - TYPELIB_DANGER_RELEASE(pTXInterfaceDescr); - - return release; -} - -static uno::TypeDescription s_acquireMethod(getAcquireMethod()); -static uno::TypeDescription s_releaseMethod(getReleaseMethod()); - -void Proxy::acquire(void) -{ - if (m_probeFun) - m_probeFun(true, - this, - m_pProbeContext, - *typelib_static_type_getByTypeClass(typelib_TypeClass_VOID), - NULL, - 0, - s_acquireMethod.get(), - NULL, - NULL, - NULL); - - if (osl_incrementInterlockedCount(&m_nRef) == 1) - { - // rebirth of proxy zombie - void * pThis = this; - m_from.get()->pExtEnv->registerProxyInterface(m_from.get()->pExtEnv, - &pThis, - Proxy_free, - m_aOId.pData, - m_pTypeDescr); - OSL_ASSERT(pThis == this); - } - - if (m_probeFun) - m_probeFun(false, - this, - m_pProbeContext, - *typelib_static_type_getByTypeClass(typelib_TypeClass_VOID), - NULL, - 0, - s_acquireMethod.get(), - NULL, - NULL, - NULL); - -} - -void Proxy::release(void) -{ - cppu::helper::purpenv::ProbeFun * probeFun = m_probeFun; - void * pProbeContext = m_pProbeContext; - - if (m_probeFun) - m_probeFun(true, - this, - m_pProbeContext, - *typelib_static_type_getByTypeClass(typelib_TypeClass_VOID), - NULL, - 0, - s_releaseMethod.get(), - NULL, - NULL, - NULL); - - if (osl_decrementInterlockedCount(&m_nRef) == 0) - m_from.get()->pExtEnv->revokeInterface(m_from.get()->pExtEnv, this); - - if (probeFun) - probeFun(false, - this, - pProbeContext, - *typelib_static_type_getByTypeClass(typelib_TypeClass_VOID), - NULL, - 0, - s_releaseMethod.get(), - NULL, - NULL, - NULL); - -} - - -extern "C" { -static void s_type_destructData_v(va_list * pParam) -{ - void * ret = va_arg(*pParam, void *); - typelib_TypeDescriptionReference * pReturnTypeRef = va_arg(*pParam, typelib_TypeDescriptionReference *); - - uno_type_destructData(ret, pReturnTypeRef, 0); -} - -static void s_dispatcher_v(va_list * pParam) -{ - uno_Interface * pUnoI = va_arg(*pParam, uno_Interface *); - typelib_TypeDescription const * pMemberType = va_arg(*pParam, typelib_TypeDescription const *); - void * pReturn = va_arg(*pParam, void *); - void ** pArgs = va_arg(*pParam, void **); - uno_Any ** ppException = va_arg(*pParam, uno_Any **); - - pUnoI->pDispatcher(pUnoI, pMemberType, pReturn, pArgs, ppException); -} -} - -void Proxy::dispatch(typelib_TypeDescriptionReference * pReturnTypeRef, - typelib_MethodParameter * pParams, - sal_Int32 nParams, - typelib_TypeDescription const * pMemberType, - void * pReturn, - void * pArgs[], - uno_Any ** ppException) -{ - if (m_probeFun) - m_probeFun(true, - this, - m_pProbeContext, - pReturnTypeRef, - pParams, - nParams, - pMemberType, - pReturn, - pArgs, - ppException); - - void ** args = (void **) alloca( sizeof (void *) * nParams ); - - typelib_TypeDescription * return_td = 0; - void * ret = pReturn; - if (pReturnTypeRef) - { - TYPELIB_DANGER_GET(&return_td, pReturnTypeRef); - - if (relatesToInterface(return_td)) - ret = alloca(return_td->nSize); - - TYPELIB_DANGER_RELEASE(return_td); - } - - for (sal_Int32 nPos = 0; nPos < nParams; ++ nPos) - { - typelib_MethodParameter const & param = pParams[nPos]; - typelib_TypeDescription * td = 0; - TYPELIB_DANGER_GET( &td, param.pTypeRef ); - if (relatesToInterface(td)) - { - args[nPos] = alloca(td->nSize); - if (param.bIn) - { - uno_copyAndConvertData(args[nPos], pArgs[nPos], td, m_from_to.get()); - } - } - else - { - args[nPos] = pArgs[nPos]; - } - TYPELIB_DANGER_RELEASE( td ); - } - - uno_Any exc_data; - uno_Any * exc = &exc_data; - - // do the UNO call... - uno_Environment_invoke(m_to.get(), s_dispatcher_v, m_pUnoI, pMemberType, ret, args, &exc); - - if (exc == 0) - { - for (sal_Int32 nPos = 0; nPos < nParams; ++ nPos) - { - if (args[nPos] != pArgs[nPos]) - { - typelib_MethodParameter const & param = pParams[nPos]; - if (param.bOut) - { - if (param.bIn) // is inout - { - uno_type_destructData(pArgs[nPos], param.pTypeRef, 0); - } - uno_type_copyAndConvertData(pArgs[ nPos ], - args[ nPos ], - param.pTypeRef, - m_to_from.get()); - } - uno_Environment_invoke(m_to.get(), s_type_destructData_v, args[nPos], param.pTypeRef, 0); - } - } - if (ret != pReturn) - { - uno_type_copyAndConvertData(pReturn, - ret, - pReturnTypeRef, - m_to_from.get()); - - uno_Environment_invoke(m_to.get(), s_type_destructData_v, ret, pReturnTypeRef, 0); - } - - *ppException = 0; - } - else // exception occurred - { - for (sal_Int32 nPos = 0; nPos < nParams; ++ nPos) - { - if (args[nPos] != pArgs[nPos]) - { - typelib_MethodParameter const & param = pParams[nPos]; - if (param.bIn) - { - uno_Environment_invoke(m_to.get(), s_type_destructData_v, args[nPos], param.pTypeRef, 0); - } - } - } - - uno_type_any_constructAndConvert(*ppException, - exc->pData, - exc->pType, - m_to_from.get()); - - // FIXME: need to destruct in m_to - uno_any_destruct(exc, 0); - } - - if (m_probeFun) - m_probeFun(false, - this, - m_pProbeContext, - pReturnTypeRef, - pParams, - nParams, - pMemberType, - pReturn, - pArgs, - ppException); -} - -/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ |