diff options
Diffstat (limited to 'cpputools/source/unoexe/unoexe.cxx')
| -rw-r--r-- | cpputools/source/unoexe/unoexe.cxx | 899 |
1 files changed, 899 insertions, 0 deletions
diff --git a/cpputools/source/unoexe/unoexe.cxx b/cpputools/source/unoexe/unoexe.cxx new file mode 100644 index 000000000000..e45fb3c3784d --- /dev/null +++ b/cpputools/source/unoexe/unoexe.cxx @@ -0,0 +1,899 @@ +/************************************************************************* + * + * 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. + * + ************************************************************************/ + +#include <stdio.h> +#include <vector> + +#include "sal/main.h" +#include <osl/diagnose.h> +#include <osl/mutex.hxx> +#include <osl/conditn.hxx> +#include <osl/module.h> + +#include <rtl/process.h> +#include <rtl/string.h> +#include <rtl/strbuf.hxx> +#include <rtl/ustrbuf.hxx> + +#include <uno/environment.h> +#include <uno/mapping.hxx> + +#include <cppuhelper/factory.hxx> +#include <cppuhelper/bootstrap.hxx> +#include <cppuhelper/servicefactory.hxx> +#include <cppuhelper/shlib.hxx> +#include <cppuhelper/implbase1.hxx> + +#include <com/sun/star/lang/XMain.hpp> +#include <com/sun/star/lang/XInitialization.hpp> +#include <com/sun/star/lang/XComponent.hpp> +#include <com/sun/star/lang/XSingleServiceFactory.hpp> +#include <com/sun/star/lang/XMultiServiceFactory.hpp> +#include <com/sun/star/lang/XEventListener.hpp> +#include <com/sun/star/container/XSet.hpp> +#include <com/sun/star/loader/XImplementationLoader.hpp> +#include <com/sun/star/registry/XSimpleRegistry.hpp> +#include <com/sun/star/registry/XRegistryKey.hpp> +#include <com/sun/star/connection/XAcceptor.hpp> +#include <com/sun/star/connection/XConnection.hpp> +#include <com/sun/star/bridge/XBridgeFactory.hpp> +#include <com/sun/star/bridge/XBridge.hpp> +#include <osl/process.h> +#include <osl/thread.h> +#include <osl/file.hxx> + +#ifdef SAL_UNX +#define SEPARATOR '/' +#else +#define SEPARATOR '\\' +#endif + +using namespace std; +using namespace rtl; +using namespace osl; +using namespace cppu; +using namespace com::sun::star::uno; +using namespace com::sun::star::lang; +using namespace com::sun::star::loader; +using namespace com::sun::star::registry; +using namespace com::sun::star::connection; +using namespace com::sun::star::bridge; +using namespace com::sun::star::container; + +namespace unoexe +{ + +static sal_Bool isFileUrl(const OUString& fileName) +{ + if (fileName.indexOf(OUString::createFromAscii("file://")) == 0 ) + return sal_True; + return sal_False; +} + +static OUString convertToFileUrl(const OUString& fileName) +{ + if ( isFileUrl(fileName) ) + { + return fileName; + } + + OUString uUrlFileName; + if ( fileName.indexOf('.') == 0 || fileName.indexOf(SEPARATOR) < 0 ) + { + OUString uWorkingDir; + if (osl_getProcessWorkingDir(&uWorkingDir.pData) != osl_Process_E_None) { + OSL_ASSERT(false); + } + if (FileBase::getAbsoluteFileURL(uWorkingDir, fileName, uUrlFileName) + != FileBase::E_None) + { + OSL_ASSERT(false); + } + } else + { + if (FileBase::getFileURLFromSystemPath(fileName, uUrlFileName) + != FileBase::E_None) + { + OSL_ASSERT(false); + } + } + + return uUrlFileName; +} + +static sal_Bool s_quiet = false; + +//-------------------------------------------------------------------------------------------------- +static inline void out( const sal_Char * pText ) +{ + if (! s_quiet) + fprintf( stderr, pText ); +} +//-------------------------------------------------------------------------------------------------- +static inline void out( const OUString & rText ) +{ + if (! s_quiet) + { + OString aText( OUStringToOString( rText, RTL_TEXTENCODING_ASCII_US ) ); + fprintf( stderr, aText.getStr() ); + } +} + +//-------------------------------------------------------------------------------------------------- +static const char arUsingText[] = +"\nusing:\n\n" +"uno [-c ComponentImplementationName -l LocationUrl | -s ServiceName]\n" +" [-ro ReadOnlyRegistry1] [-ro ReadOnlyRegistry2] ... [-rw ReadWriteRegistry]\n" +" [-u uno:(socket[,host=HostName][,port=nnn]|pipe[,name=PipeName]);<protocol>;Name\n" +" [--singleaccept] [--singleinstance]]\n" +" [--quiet]\n" +" [-- Argument1 Argument2 ...]\n"; + +//-------------------------------------------------------------------------------------------------- +static sal_Bool readOption( OUString * pValue, const sal_Char * pOpt, + sal_Int32 * pnIndex, const OUString & aArg) + throw (RuntimeException) +{ + const OUString dash = OUString(RTL_CONSTASCII_USTRINGPARAM("-")); + if(aArg.indexOf(dash) != 0) + return sal_False; + + OUString aOpt = OUString::createFromAscii( pOpt ); + + if (aArg.getLength() < aOpt.getLength()) + return sal_False; + + if (aOpt.equalsIgnoreAsciiCase( aArg.copy(1) )) + { + // take next argument + ++(*pnIndex); + + rtl_getAppCommandArg(*pnIndex, &pValue->pData); + if (*pnIndex >= (sal_Int32)rtl_getAppCommandArgCount() || pValue->copy(1).equals(dash)) + { + OUStringBuffer buf( 32 ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("incomplete option \"-") ); + buf.appendAscii( pOpt ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\" given!") ); + throw RuntimeException( buf.makeStringAndClear(), Reference< XInterface >() ); + } + else + { +#if OSL_DEBUG_LEVEL > 1 + out( "\n> identified option -" ); + out( pOpt ); + out( " = " ); + OString tmp = OUStringToOString(aArg, RTL_TEXTENCODING_ASCII_US); + out( tmp.getStr() ); +#endif + ++(*pnIndex); + return sal_True; + } + } + else if (aArg.indexOf(aOpt) == 1) + { + *pValue = aArg.copy(1 + aOpt.getLength()); +#if OSL_DEBUG_LEVEL > 1 + out( "\n> identified option -" ); + out( pOpt ); + out( " = " ); + OString tmp = OUStringToOString(aArg.copy(aOpt.getLength()), RTL_TEXTENCODING_ASCII_US); + out( tmp.getStr() ); +#endif + ++(*pnIndex); + + return sal_True; + } + return sal_False; +} +//-------------------------------------------------------------------------------------------------- +static sal_Bool readOption( sal_Bool * pbOpt, const sal_Char * pOpt, + sal_Int32 * pnIndex, const OUString & aArg) +{ + const OUString dashdash(RTL_CONSTASCII_USTRINGPARAM("--")); + OUString aOpt = OUString::createFromAscii(pOpt); + + if(aArg.indexOf(dashdash) == 0 && aOpt.equals(aArg.copy(2))) + { + ++(*pnIndex); + *pbOpt = sal_True; +#if OSL_DEBUG_LEVEL > 1 + out( "\n> identified option --" ); + out( pOpt ); +#endif + return sal_True; + } + return sal_False; +} + + +//################################################################################################## +//################################################################################################## +//################################################################################################## + + +//-------------------------------------------------------------------------------------------------- +template< class T > +void createInstance( + Reference< T > & rxOut, + const Reference< XComponentContext > & xContext, + const OUString & rServiceName ) + throw (Exception) +{ + Reference< XMultiComponentFactory > xMgr( xContext->getServiceManager() ); + Reference< XInterface > x( xMgr->createInstanceWithContext( rServiceName, xContext ) ); + + if (! x.is()) + { + static sal_Bool s_bSet = sal_False; + if (! s_bSet) + { + MutexGuard aGuard( Mutex::getGlobalMutex() ); + if (! s_bSet) + { + Reference< XSet > xSet( xMgr, UNO_QUERY ); + if (xSet.is()) + { + Reference< XMultiServiceFactory > xSF( xMgr, UNO_QUERY ); + // acceptor + xSet->insert( makeAny( loadSharedLibComponentFactory( + OUString( RTL_CONSTASCII_USTRINGPARAM( + "acceptor.uno" SAL_DLLEXTENSION) ), + OUString(), + OUString( RTL_CONSTASCII_USTRINGPARAM( + "com.sun.star.comp.io.Acceptor") ), + xSF, Reference< XRegistryKey >() ) ) ); + // connector + xSet->insert( makeAny( loadSharedLibComponentFactory( + OUString( RTL_CONSTASCII_USTRINGPARAM( + "connector.uno" SAL_DLLEXTENSION) ), + OUString(), + OUString( RTL_CONSTASCII_USTRINGPARAM( + "com.sun.star.comp.io.Connector") ), + xSF, Reference< XRegistryKey >() ) ) ); + // iiop bridge + xSet->insert( makeAny( loadSharedLibComponentFactory( + OUString( RTL_CONSTASCII_USTRINGPARAM( + "remotebridge.uno" SAL_DLLEXTENSION) ), + OUString(), + OUString( RTL_CONSTASCII_USTRINGPARAM( + "com.sun.star.comp.remotebridges." + "Bridge.various") ), + xSF, Reference< XRegistryKey >() ) ) ); + // bridge factory + xSet->insert( makeAny( loadSharedLibComponentFactory( + OUString( RTL_CONSTASCII_USTRINGPARAM( + "bridgefac.uno" SAL_DLLEXTENSION) ), + OUString(), + OUString( RTL_CONSTASCII_USTRINGPARAM( + "com.sun.star.comp.remotebridges." + "BridgeFactory") ), + xSF, Reference< XRegistryKey >() ) ) ); + } + s_bSet = sal_True; + } + } + x = xMgr->createInstanceWithContext( rServiceName, xContext ); + } + + if (! x.is()) + { + OUStringBuffer buf( 64 ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("cannot get service instance \"") ); + buf.append( rServiceName ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\"!") ); + throw RuntimeException( buf.makeStringAndClear(), Reference< XInterface >() ); + } + + rxOut = Reference< T >::query( x ); + if (! rxOut.is()) + { + OUStringBuffer buf( 64 ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("service instance \"") ); + buf.append( rServiceName ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\" does not support demanded interface \"") ); + const Type & rType = ::getCppuType( (const Reference< T > *)0 ); + buf.append( rType.getTypeName() ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\"!") ); + throw RuntimeException( buf.makeStringAndClear(), Reference< XInterface >() ); + } +} +//-------------------------------------------------------------------------------------------------- +static Reference< XSimpleRegistry > nestRegistries( + const Reference< XSimpleRegistry > & xReadWrite, + const Reference< XSimpleRegistry > & xReadOnly ) + throw (Exception) +{ + Reference< XSimpleRegistry > xReg( createNestedRegistry() ); + if (! xReg.is()) + { + throw RuntimeException( + OUString( RTL_CONSTASCII_USTRINGPARAM("no nested registry service!" ) ), + Reference< XInterface >() ); + } + + Reference< XInitialization > xInit( xReg, UNO_QUERY ); + if (! xInit.is()) + throw RuntimeException( OUString( RTL_CONSTASCII_USTRINGPARAM("nested registry does not export interface \"com.sun.star.lang.XInitialization\"!" ) ), Reference< XInterface >() ); + + Sequence< Any > aArgs( 2 ); + aArgs[0] <<= xReadWrite; + aArgs[1] <<= xReadOnly; + xInit->initialize( aArgs ); + + return xReg; +} +//-------------------------------------------------------------------------------------------------- +static Reference< XSimpleRegistry > openRegistry( + const OUString & rURL, + sal_Bool bReadOnly, sal_Bool bCreate ) + throw (Exception) +{ + Reference< XSimpleRegistry > xNewReg( createSimpleRegistry() ); + if (! xNewReg.is()) + { + throw RuntimeException( + OUString( RTL_CONSTASCII_USTRINGPARAM("no simple registry service!" ) ), + Reference< XInterface >() ); + } + + try + { + xNewReg->open( convertToFileUrl(rURL), bReadOnly, bCreate ); + if (xNewReg->isValid()) + return xNewReg; + else + xNewReg->close(); + } + catch (Exception &) + { + } + + out( "\n> warning: cannot open registry \"" ); + out( rURL ); + if (bReadOnly) + out( "\" for reading, ignoring!" ); + else + out( "\" for reading and writing, ignoring!" ); + return Reference< XSimpleRegistry >(); +} +//-------------------------------------------------------------------------------------------------- +static Reference< XInterface > loadComponent( + const Reference< XComponentContext > & xContext, + const OUString & rImplName, const OUString & rLocation ) + throw (Exception) +{ + // determine loader to be used + sal_Int32 nDot = rLocation.lastIndexOf( '.' ); + if (nDot > 0 && nDot < rLocation.getLength()) + { + Reference< XImplementationLoader > xLoader; + + OUString aExt( rLocation.copy( nDot +1 ) ); + + if (aExt.compareToAscii( "dll" ) == 0 || + aExt.compareToAscii( "exe" ) == 0 || + aExt.compareToAscii( "dylib" ) == 0 || + aExt.compareToAscii( "so" ) == 0) + { + createInstance( + xLoader, xContext, OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.loader.SharedLibrary") ) ); + } + else if (aExt.compareToAscii( "jar" ) == 0 || + aExt.compareToAscii( "class" ) == 0) + { + createInstance( + xLoader, xContext, OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.loader.Java") ) ); + } + else + { + OUStringBuffer buf( 64 ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("unknown extension of \"") ); + buf.append( rLocation ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\"! No loader available!") ); + throw RuntimeException( buf.makeStringAndClear(), Reference< XInterface >() ); + } + + Reference< XInterface > xInstance; + + // activate + Reference< XInterface > xFactory( xLoader->activate( + rImplName, OUString(), rLocation, Reference< XRegistryKey >() ) ); + if (xFactory.is()) + { + Reference< XSingleComponentFactory > xCFac( xFactory, UNO_QUERY ); + if (xCFac.is()) + { + xInstance = xCFac->createInstanceWithContext( xContext ); + } + else + { + Reference< XSingleServiceFactory > xSFac( xFactory, UNO_QUERY ); + if (xSFac.is()) + { + out( "\n> warning: ignroing context for implementation \"" ); + out( rImplName ); + out( "\"!" ); + xInstance = xSFac->createInstance(); + } + } + } + + if (! xInstance.is()) + { + OUStringBuffer buf( 64 ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("activating component \"") ); + buf.append( rImplName ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\" from location \"") ); + buf.append( rLocation ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\" failed!") ); + throw RuntimeException( buf.makeStringAndClear(), Reference< XInterface >() ); + } + + return xInstance; + } + else + { + OUStringBuffer buf( 64 ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("location \"") ); + buf.append( rLocation ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\" has no extension! Cannot determine loader to be used!") ); + throw RuntimeException( buf.makeStringAndClear(), Reference< XInterface >() ); + } +} + + +//################################################################################################## +//################################################################################################## +//################################################################################################## + + +//================================================================================================== +class OInstanceProvider + : public WeakImplHelper1< XInstanceProvider > +{ + Reference< XComponentContext > _xContext; + + Mutex _aSingleInstanceMutex; + Reference< XInterface > _xSingleInstance; + sal_Bool _bSingleInstance; + + OUString _aImplName; + OUString _aLocation; + OUString _aServiceName; + Sequence< Any > _aInitParams; + + OUString _aInstanceName; + + inline Reference< XInterface > createInstance() throw (Exception); + +public: + OInstanceProvider( const Reference< XComponentContext > & xContext, + const OUString & rImplName, const OUString & rLocation, + const OUString & rServiceName, const Sequence< Any > & rInitParams, + sal_Bool bSingleInstance, const OUString & rInstanceName ) + : _xContext( xContext ) + , _bSingleInstance( bSingleInstance ) + , _aImplName( rImplName ) + , _aLocation( rLocation ) + , _aServiceName( rServiceName ) + , _aInitParams( rInitParams ) + , _aInstanceName( rInstanceName ) + {} + + // XInstanceProvider + virtual Reference< XInterface > SAL_CALL getInstance( const OUString & rName ) + throw (NoSuchElementException, RuntimeException); +}; +//__________________________________________________________________________________________________ +inline Reference< XInterface > OInstanceProvider::createInstance() + throw (Exception) +{ + Reference< XInterface > xRet; + if (_aImplName.getLength()) // manually via loader + xRet = loadComponent( _xContext, _aImplName, _aLocation ); + else // via service manager + unoexe::createInstance( xRet, _xContext, _aServiceName ); + + // opt XInit + Reference< XInitialization > xInit( xRet, UNO_QUERY ); + if (xInit.is()) + xInit->initialize( _aInitParams ); + + return xRet; +} +//__________________________________________________________________________________________________ +Reference< XInterface > OInstanceProvider::getInstance( const OUString & rName ) + throw (NoSuchElementException, RuntimeException) +{ + try + { + if (_aInstanceName == rName) + { + Reference< XInterface > xRet; + + if (_aImplName.getLength() == 0 && _aServiceName.getLength() == 0) + { + OSL_ASSERT( + rName.equalsAsciiL( + RTL_CONSTASCII_STRINGPARAM("uno.ComponentContext") ) ); + xRet = _xContext; + } + else if (_bSingleInstance) + { + if (! _xSingleInstance.is()) + { + MutexGuard aGuard( _aSingleInstanceMutex ); + if (! _xSingleInstance.is()) + { + _xSingleInstance = createInstance(); + } + } + xRet = _xSingleInstance; + } + else + { + xRet = createInstance(); + } + + return xRet; + } + } + catch (Exception & rExc) + { + out( "\n> error: " ); + out( rExc.Message ); + } + OUStringBuffer buf( 64 ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("no such element \"") ); + buf.append( rName ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\"!") ); + throw NoSuchElementException( buf.makeStringAndClear(), Reference< XInterface >() ); +} + +//================================================================================================== +struct ODisposingListener : public WeakImplHelper1< XEventListener > +{ + Condition cDisposed; + + // XEventListener + virtual void SAL_CALL disposing( const EventObject & rEvt ) + throw (RuntimeException); + + //---------------------------------------------------------------------------------------------- + static void waitFor( const Reference< XComponent > & xComp ); +}; +//__________________________________________________________________________________________________ +void ODisposingListener::disposing( const EventObject & ) + throw (RuntimeException) +{ + cDisposed.set(); +} +//-------------------------------------------------------------------------------------------------- +void ODisposingListener::waitFor( const Reference< XComponent > & xComp ) +{ + ODisposingListener * pListener = new ODisposingListener(); + Reference< XEventListener > xListener( pListener ); + + xComp->addEventListener( xListener ); + pListener->cDisposed.wait(); +} + + +//################################################################################################## +//################################################################################################## +//################################################################################################## + + +//################################################################################################## +} // namespace unoexe + +using namespace unoexe; + +SAL_IMPLEMENT_MAIN_WITH_ARGS(argc,) +{ + if (argc <= 1) + { + out( arUsingText ); + return 0; + } + + sal_Int32 nRet = 0; + Reference< XComponentContext > xContext; + + + try + { + OUString aImplName, aLocation, aServiceName, aUnoUrl; + vector< OUString > aReadOnlyRegistries; + Sequence< OUString > aParams; + sal_Bool bSingleAccept = sal_False; + sal_Bool bSingleInstance = sal_False; + + //#### read command line arguments ######################################################### + + bool bOldRegistryMimic = false; + bool bNewRegistryMimic = false; + OUString aReadWriteRegistry; + + sal_Int32 nPos = 0; + sal_Int32 nCount = (sal_Int32)rtl_getAppCommandArgCount(); + // read up to arguments + while (nPos < nCount) + { + OUString arg; + + rtl_getAppCommandArg(nPos, &arg.pData); + + const OUString dashdash = OUString(RTL_CONSTASCII_USTRINGPARAM("--")); + if (dashdash == arg) + { + ++nPos; + break; + } + + if (readOption( &aImplName, "c", &nPos, arg) || + readOption( &aLocation, "l", &nPos, arg) || + readOption( &aServiceName, "s", &nPos, arg) || + readOption( &aUnoUrl, "u", &nPos, arg) || + readOption( &s_quiet, "quiet", &nPos, arg) || + readOption( &bSingleAccept, "singleaccept", &nPos, arg) || + readOption( &bSingleInstance, "singleinstance", &nPos, arg)) + { + continue; + } + OUString aRegistry; + if (readOption( &aRegistry, "ro", &nPos, arg)) + { + aReadOnlyRegistries.push_back( aRegistry ); + bNewRegistryMimic = true; + continue; + } + if (readOption( &aReadWriteRegistry, "rw", &nPos, arg)) + { + bNewRegistryMimic = true; + continue; + } + if (readOption( &aRegistry, "r", &nPos, arg)) + { + aReadOnlyRegistries.push_back( aRegistry ); + aReadWriteRegistry = aRegistry; + out( "\n> warning: DEPRECATED use of option -r, use -ro or -rw!" ); + bOldRegistryMimic = true; + continue; + } + + // else illegal argument + OUStringBuffer buf( 64 ); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("unexpected parameter \"") ); + buf.append(arg); + buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\"!") ); + throw RuntimeException( buf.makeStringAndClear(), Reference< XInterface >() ); + } + + if (bOldRegistryMimic) // last one was set to be read-write + { + aReadOnlyRegistries.pop_back(); + if (bOldRegistryMimic && bNewRegistryMimic) + { + throw RuntimeException( + OUString( RTL_CONSTASCII_USTRINGPARAM("mixing with DEPRECATED registry options!") ), + Reference< XInterface >() ); + } + } + + if ((aImplName.getLength() != 0) && (aServiceName.getLength() != 0)) + throw RuntimeException( OUString( RTL_CONSTASCII_USTRINGPARAM("give component exOR service name!" ) ), Reference< XInterface >() ); + if (aImplName.getLength() == 0 && aServiceName.getLength() == 0) + { + if (! aUnoUrl.endsWithIgnoreAsciiCaseAsciiL( + RTL_CONSTASCII_STRINGPARAM(";uno.ComponentContext") )) + throw RuntimeException( + OUString( RTL_CONSTASCII_USTRINGPARAM( + "expected UNO-URL with instance name " + "uno.ComponentContext!") ), + Reference<XInterface>() ); + if (bSingleInstance) + throw RuntimeException( + OUString( RTL_CONSTASCII_USTRINGPARAM( + "unexpected option --singleinstance!") ), + Reference<XInterface>() ); + } + if (aImplName.getLength() && !aLocation.getLength()) + throw RuntimeException( OUString( RTL_CONSTASCII_USTRINGPARAM("give component location!" ) ), Reference< XInterface >() ); + if (aServiceName.getLength() && aLocation.getLength()) + out( "\n> warning: service name given, will ignore location!" ); + + // read component params + aParams.realloc( nCount - nPos ); + OUString * pParams = aParams.getArray(); + + sal_Int32 nOffset = nPos; + for ( ; nPos < nCount; ++nPos ) + { + if (rtl_getAppCommandArg( nPos, &pParams[nPos -nOffset].pData ) + != osl_Process_E_None) + { + OSL_ASSERT(false); + } + } + + if (aReadOnlyRegistries.size() > 0 || + aReadWriteRegistry.getLength() > 0) + { + //#### create registry ############################################# + + Reference< XSimpleRegistry > xRegistry; + + // ReadOnly registries + for ( size_t nReg = 0; nReg < aReadOnlyRegistries.size(); ++nReg ) + { +#if OSL_DEBUG_LEVEL > 1 + out( "\n> trying to open ro registry: " ); + out( OUStringToOString( + aReadOnlyRegistries[ nReg ], + RTL_TEXTENCODING_ASCII_US ).getStr() ); +#endif + Reference< XSimpleRegistry > xNewReg( + openRegistry( + aReadOnlyRegistries[ nReg ], sal_True, sal_False ) ); + if (xNewReg.is()) + xRegistry = (xRegistry.is() ? nestRegistries( + xNewReg, xRegistry ) : xNewReg); + } + if (aReadWriteRegistry.getLength()) + { +#if OSL_DEBUG_LEVEL > 1 + out( "\n> trying to open rw registry: " ); + out( OUStringToOString( + aReadWriteRegistry, + RTL_TEXTENCODING_ASCII_US ).getStr() ); +#endif + // ReadWrite registry + Reference< XSimpleRegistry > xNewReg( + openRegistry( aReadWriteRegistry, sal_False, sal_True ) ); + if (xNewReg.is()) + xRegistry = (xRegistry.is() + ? nestRegistries( xNewReg, xRegistry ) + : xNewReg); + } + + OSL_ASSERT( xRegistry.is() ); + xContext = bootstrap_InitialComponentContext( xRegistry ); + } + else // defaulting + { + xContext = defaultBootstrap_InitialComponentContext(); + } + + //#### accept, instanciate, etc. ########################################################### + + if (aUnoUrl.getLength()) // accepting connections + { + sal_Int32 nIndex = 0, nTokens = 0; + do { aUnoUrl.getToken( 0, ';', nIndex ); nTokens++; } while( nIndex != -1 ); + if (nTokens != 3 || aUnoUrl.getLength() < 10 || + !aUnoUrl.copy( 0, 4 ).equalsIgnoreAsciiCase( OUString( RTL_CONSTASCII_USTRINGPARAM("uno:") ) )) + { + throw RuntimeException( OUString( RTL_CONSTASCII_USTRINGPARAM("illegal uno url given!" ) ), Reference< XInterface >() ); + } + nIndex = 0; + OUString aConnectDescr( aUnoUrl.getToken( 0, ';', nIndex ).copy( 4 ) ); // uno:CONNECTDESCR;iiop;InstanceName + OUString aInstanceName( aUnoUrl.getToken( 1, ';', nIndex ) ); + + Reference< XAcceptor > xAcceptor; + createInstance( + xAcceptor, xContext, + OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.connection.Acceptor") ) ); + + // init params + Sequence< Any > aInitParams( aParams.getLength() ); + const OUString * p = aParams.getConstArray(); + Any * pInitParams = aInitParams.getArray(); + for ( sal_Int32 i = aParams.getLength(); i--; ) + { + pInitParams[i] = makeAny( p[i] ); + } + + // instance provider + Reference< XInstanceProvider > xInstanceProvider( new OInstanceProvider( + xContext, aImplName, aLocation, aServiceName, aInitParams, + bSingleInstance, aInstanceName ) ); + + nIndex = 0; + OUString aUnoUrlToken( aUnoUrl.getToken( 1, ';', nIndex ) ); + for (;;) + { + // accepting + out( "\n> accepting " ); + out( aConnectDescr ); + out( "..." ); + Reference< XConnection > xConnection( xAcceptor->accept( aConnectDescr ) ); + out( "connection established." ); + + Reference< XBridgeFactory > xBridgeFactory; + createInstance( + xBridgeFactory, xContext, + OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.bridge.BridgeFactory") ) ); + + // bridge + Reference< XBridge > xBridge( xBridgeFactory->createBridge( + OUString(), aUnoUrlToken, + xConnection, xInstanceProvider ) ); + + if (bSingleAccept) + { + Reference< XComponent > xComp( xBridge, UNO_QUERY ); + if (! xComp.is()) + throw RuntimeException( OUString( RTL_CONSTASCII_USTRINGPARAM("bridge factory does not export interface \"com.sun.star.lang.XComponent\"!" ) ), Reference< XInterface >() ); + ODisposingListener::waitFor( xComp ); + break; + } + } + } + else // no uno url + { + Reference< XInterface > xInstance; + if (aImplName.getLength()) // manually via loader + xInstance = loadComponent( xContext, aImplName, aLocation ); + else // via service manager + createInstance( xInstance, xContext, aServiceName ); + + // execution + Reference< XMain > xMain( xInstance, UNO_QUERY ); + if (xMain.is()) + { + nRet = xMain->run( aParams ); + } + else + { + Reference< XComponent > xComp( xInstance, UNO_QUERY ); + if (xComp.is()) + xComp->dispose(); + throw RuntimeException( OUString( RTL_CONSTASCII_USTRINGPARAM("component does not export interface interface \"com.sun.star.lang.XMain\"!" ) ), Reference< XInterface >() ); + } + } + } + catch (Exception & rExc) + { + out( "\n> error: " ); + out( rExc.Message ); + out( "\n> dying..." ); + nRet = 1; + } + + // cleanup + Reference< XComponent > xComp( xContext, UNO_QUERY ); + if (xComp.is()) + xComp->dispose(); + + out( "\n" ); + return nRet; +} + + + |