mir/libreoffice
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
5059fd3bd5ac8a87b37c9dce4e245c22b6ba947d
libreoffice/cpputools/source/unoexe/unoexe.cxx

898 lines
34 KiB
C++
Raw Normal View History

initial import
2000-09-18 15:18:56 +00:00
/*************************************************************************
*
* $RCSfile: unoexe.cxx,v $
*
removed ChangeGlobalInit
2001-02-01 11:42:49 +00:00
* $Revision: 1.6 $
initial import
2000-09-18 15:18:56 +00:00
*
removed ChangeGlobalInit
2001-02-01 11:42:49 +00:00
* last change: $Author: mfe $ $Date: 2001-02-01 12:42:49 $
initial import
2000-09-18 15:18:56 +00:00
*
* The Contents of this file are made available subject to the terms of
* either of the following licenses
*
* - GNU Lesser General Public License Version 2.1
* - Sun Industry Standards Source License Version 1.1
*
* Sun Microsystems Inc., October, 2000
*
* GNU Lesser General Public License Version 2.1
* =============================================
* Copyright 2000 by Sun Microsystems, Inc.
* 901 San Antonio Road, Palo Alto, CA 94303, USA
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software Foundation.
*
* This library 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 for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston,
* MA 02111-1307 USA
*
*
* Sun Industry Standards Source License Version 1.1
* =================================================
* The contents of this file are subject to the Sun Industry Standards
* Source License Version 1.1 (the "License"); You may not use this file
* except in compliance with the License. You may obtain a copy of the
* License at http://www.openoffice.org/license.html.
*
* Software provided under this License is provided on an "AS IS" basis,
* WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING,
* WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
* MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
* See the License for the specific provisions governing your rights and
* obligations concerning the Software.
*
* The Initial Developer of the Original Code is: Sun Microsystems, Inc.
*
* Copyright: 2000 by Sun Microsystems, Inc.
*
* All Rights Reserved.
*
* Contributor(s): _______________________________________
*
*
************************************************************************/
#include <stdio.h>
Remove stl/ from #include statement
2000-11-22 22:17:29 +00:00
#include <vector>
initial import
2000-09-18 15:18:56 +00:00
#include <osl/diagnose.h>
#include <osl/mutex.hxx>
#include <osl/conditn.hxx>
#include <osl/module.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/servicefactory.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>
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 inline void out( const sal_Char * pText )
{
fprintf( stderr, pText );
}
//--------------------------------------------------------------------------------------------------
static inline void out( const OUString & rText )
{
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"
" [-r Registry1] [-r Registry2] ...\n"
" [-u uno:(socket[,host=HostName][,port=nnn]|pipe[,name=PipeName]);iiop;Name\n"
" [--singleaccept] [--singleinstance]]\n"
" [-- Argument1 Argument2 ...]\n";
//--------------------------------------------------------------------------------------------------
static sal_Bool readOption( OUString * pValue, sal_Char cOpt,
sal_Int32 * pnIndex, const sal_Char * argv[], sal_Int32 argc )
throw (RuntimeException)
{
const sal_Char * pArg = argv[ *pnIndex ];
cOpt |= 0x20; // ascii lower case
if (pArg[0] && pArg[0] == '-' && (pArg[1] | 0x20) == cOpt) // right option
{
if (pArg[2])
{
*pValue = OUString::createFromAscii( pArg+2 );
}
else // take next argument
{
++(*pnIndex);
if (*pnIndex >= argc || argv[ *pnIndex ][0] == '-')
{
OUStringBuffer buf( 32 );
buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("incomplete option \"-") );
buf.appendAscii( &cOpt, 1 );
buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\" given!") );
throw RuntimeException( buf.makeStringAndClear(), Reference< XInterface >() );
}
*pValue = OUString::createFromAscii( argv[ *pnIndex ] );
}
++(*pnIndex);
return sal_True;
}
return sal_False;
}
//--------------------------------------------------------------------------------------------------
static sal_Bool readOption( sal_Bool * pbOpt, const sal_Char * pOpt,
sal_Int32 * pnIndex, const sal_Char * argv[], sal_Int32 argc )
{
const sal_Char * pArg = argv[ *pnIndex ];
if (pArg[0] == '-' && pArg[1] == '-' && rtl_str_equalsIgnoreCase( pArg+2, pOpt ))
{
++(*pnIndex);
*pbOpt = sal_True;
return sal_True;
}
return sal_False;
}
//##################################################################################################
//##################################################################################################
//##################################################################################################
//==================================================================================================
Reference< XSingleServiceFactory > loadLibComponentFactory(
const OUString & rLibName, const OUString & rImplName,
const Reference< XMultiServiceFactory > & xSF, const Reference< XRegistryKey > & xKey )
{
Reference< XSingleServiceFactory > xRet;
OUStringBuffer aLibNameBuf( 32 );
#ifdef SAL_UNX
aLibNameBuf.appendAscii( RTL_CONSTASCII_STRINGPARAM("lib") );
aLibNameBuf.append( rLibName );
aLibNameBuf.appendAscii( RTL_CONSTASCII_STRINGPARAM(".so") );
#else
aLibNameBuf.append( rLibName );
aLibNameBuf.appendAscii( RTL_CONSTASCII_STRINGPARAM(".dll") );
#endif
OUString aLibName( aLibNameBuf.makeStringAndClear() );
oslModule lib = osl_loadModule( aLibName.pData, SAL_LOADMODULE_LAZY | SAL_LOADMODULE_GLOBAL );
if (lib)
{
void * pSym;
// ========================= LATEST VERSION =========================
OUString aGetEnvName( RTL_CONSTASCII_USTRINGPARAM(COMPONENT_GETENV) );
if (pSym = osl_getSymbol( lib, aGetEnvName.pData ))
{
uno_Environment * pCurrentEnv = 0;
uno_Environment * pEnv = 0;
const sal_Char * pEnvTypeName = 0;
(*((component_getImplementationEnvironmentFunc)pSym))( &pEnvTypeName, &pEnv );
sal_Bool bNeedsMapping =
(pEnv || 0 != rtl_str_compare( pEnvTypeName, CPPU_CURRENT_LANGUAGE_BINDING_NAME ));
OUString aEnvTypeName( OUString::createFromAscii( pEnvTypeName ) );
if (bNeedsMapping)
{
if (! pEnv)
uno_getEnvironment( &pEnv, aEnvTypeName.pData, 0 );
if (pEnv)
{
OUString aCppEnvTypeName( RTL_CONSTASCII_USTRINGPARAM(CPPU_CURRENT_LANGUAGE_BINDING_NAME) );
uno_getEnvironment( &pCurrentEnv, aCppEnvTypeName.pData, 0 );
if (pCurrentEnv)
bNeedsMapping = (pEnv != pCurrentEnv);
}
}
OUString aGetFactoryName( RTL_CONSTASCII_USTRINGPARAM(COMPONENT_GETFACTORY) );
if (pSym = osl_getSymbol( lib, aGetFactoryName.pData ))
{
OString aImplName( OUStringToOString( rImplName, RTL_TEXTENCODING_ASCII_US ) );
if (bNeedsMapping)
{
if (pEnv && pCurrentEnv)
{
Mapping aCurrent2Env( pCurrentEnv, pEnv );
Mapping aEnv2Current( pEnv, pCurrentEnv );
if (aCurrent2Env.is() && aEnv2Current.is())
{
void * pSMgr = aCurrent2Env.mapInterface(
xSF.get(), ::getCppuType( (const Reference< XMultiServiceFactory > *)0 ) );
void * pKey = aCurrent2Env.mapInterface(
xKey.get(), ::getCppuType( (const Reference< XRegistryKey > *)0 ) );
void * pSSF = (*((component_getFactoryFunc)pSym))(
aImplName.getStr(), pSMgr, pKey );
if (pKey)
(*pEnv->pExtEnv->releaseInterface)( pEnv->pExtEnv, pKey );
if (pSMgr)
(*pEnv->pExtEnv->releaseInterface)( pEnv->pExtEnv, pSMgr );
if (pSSF)
{
aEnv2Current.mapInterface(
reinterpret_cast< void ** >( &xRet ),
pSSF, ::getCppuType( (const Reference< XSingleServiceFactory > *)0 ) );
(*pEnv->pExtEnv->releaseInterface)( pEnv->pExtEnv, pSSF );
}
}
}
}
else
{
XSingleServiceFactory * pRet = (XSingleServiceFactory *)
(*((component_getFactoryFunc)pSym))(
aImplName.getStr(), xSF.get(), xKey.get() );
if (pRet)
{
xRet = pRet;
pRet->release();
}
}
}
if (pEnv)
(*pEnv->release)( pEnv );
if (pCurrentEnv)
(*pCurrentEnv->release)( pCurrentEnv );
}
// ========================= PREVIOUS VERSION =========================
else
{
OUString aGetFactoryName( RTL_CONSTASCII_USTRINGPARAM(CREATE_COMPONENT_FACTORY_FUNCTION) );
if (pSym = osl_getSymbol( lib, aGetFactoryName.pData ))
{
OUString aCppEnvTypeName( RTL_CONSTASCII_USTRINGPARAM(CPPU_CURRENT_LANGUAGE_BINDING_NAME) );
OUString aUnoEnvTypeName( RTL_CONSTASCII_USTRINGPARAM(UNO_LB_UNO) );
Mapping aUno2Cpp( aUnoEnvTypeName, aCppEnvTypeName );
Mapping aCpp2Uno( aCppEnvTypeName, aUnoEnvTypeName );
OSL_ENSHURE( aUno2Cpp.is() && aCpp2Uno.is(), "### cannot get uno mappings!" );
if (aUno2Cpp.is() && aCpp2Uno.is())
{
uno_Interface * pUComponentFactory = 0;
uno_Interface * pUSFactory = (uno_Interface *)aCpp2Uno.mapInterface(
xSF.get(), ::getCppuType( (const Reference< XMultiServiceFactory > *)0 ) );
uno_Interface * pUKey = (uno_Interface *)aCpp2Uno.mapInterface(
xKey.get(), ::getCppuType( (const Reference< XRegistryKey > *)0 ) );
pUComponentFactory = (*((CreateComponentFactoryFunc)pSym))(
rImplName.getStr(), pUSFactory, pUKey );
if (pUKey)
(*pUKey->release)( pUKey );
if (pUSFactory)
(*pUSFactory->release)( pUSFactory );
if (pUComponentFactory)
{
XSingleServiceFactory * pXFactory =
(XSingleServiceFactory *)aUno2Cpp.mapInterface(
pUComponentFactory, ::getCppuType( (const Reference< XSingleServiceFactory > *)0 ) );
(*pUComponentFactory->release)( pUComponentFactory );
if (pXFactory)
{
xRet = pXFactory;
pXFactory->release();
}
}
}
}
}
if (! xRet.is())
osl_unloadModule( lib );
}
return xRet;
}
//--------------------------------------------------------------------------------------------------
template< class T >
void createInstance( Reference< T > & rxOut,
const Reference< XMultiServiceFactory > & xMgr,
const OUString & rServiceName )
throw (Exception)
{
Reference< XInterface > x( xMgr->createInstance( rServiceName ), UNO_QUERY );
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())
{
// acceptor
xSet->insert( makeAny( loadLibComponentFactory(
OUString( RTL_CONSTASCII_USTRINGPARAM("acceptor") ),
OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.comp.io.Acceptor") ),
xMgr, Reference< XRegistryKey >() ) ) );
// connector
xSet->insert( makeAny( loadLibComponentFactory(
OUString( RTL_CONSTASCII_USTRINGPARAM("connectr") ),
OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.comp.io.Connector") ),
xMgr, Reference< XRegistryKey >() ) ) );
// iiop bridge
xSet->insert( makeAny( loadLibComponentFactory(
name of iiopbrdg-dll changed to remotebridge
2000-10-13 09:47:26 +00:00
OUString( RTL_CONSTASCII_USTRINGPARAM("remotebridge") ),
initial import
2000-09-18 15:18:56 +00:00
OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.comp.remotebridges.Bridge.various") ),
xMgr, Reference< XRegistryKey >() ) ) );
// bridge factory
xSet->insert( makeAny( loadLibComponentFactory(
OUString( RTL_CONSTASCII_USTRINGPARAM("brdgfctr") ),
OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.comp.remotebridges.BridgeFactory") ),
xMgr, Reference< XRegistryKey >() ) ) );
}
s_bSet = sal_True;
}
}
x = xMgr->createInstance( rServiceName );
}
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< XMultiServiceFactory > & xMgr,
const Reference< XSimpleRegistry > & xReadWrite,
const Reference< XSimpleRegistry > & xReadOnly )
throw (Exception)
{
Reference< XSimpleRegistry > xReg;
createInstance(
xReg, xMgr,
OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.registry.NestedRegistry") ) );
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] = makeAny( xReadWrite );
aArgs[1] = makeAny( xReadOnly );
xInit->initialize( aArgs );
return xReg;
}
//--------------------------------------------------------------------------------------------------
static Reference< XSimpleRegistry > openRegistry(
const Reference< XMultiServiceFactory > & xMgr,
const OUString & rURL,
sal_Bool bReadOnly, sal_Bool bCreate )
throw (Exception)
{
Reference< XSimpleRegistry > xNewReg;
createInstance(
xNewReg, xMgr,
OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.registry.SimpleRegistry") ) );
try
{
xNewReg->open( 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< XMultiServiceFactory > & xMgr,
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( "so" ) == 0)
{
createInstance(
xLoader, xMgr,
OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.loader.SharedLibrary") ) );
}
else if (aExt.compareToAscii( "jar" ) == 0 ||
aExt.compareToAscii( "class" ) == 0)
{
createInstance(
xLoader, xMgr,
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< XSingleServiceFactory > xFactory( xLoader->activate(
rImplName, OUString(), rLocation, Reference< XRegistryKey >() ), UNO_QUERY );
if (xFactory.is())
xInstance = xFactory->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< XMultiServiceFactory > _xMgr;
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< XMultiServiceFactory > & xMgr,
const OUString & rImplName, const OUString & rLocation,
const OUString & rServiceName, const Sequence< Any > & rInitParams,
sal_Bool bSingleInstance, const OUString & rInstanceName )
: _xMgr( xMgr )
, _bSingleInstance( bSingleInstance )
, _aImplName( rImplName )
, _aLocation( rLocation )
, _aServiceName( rServiceName )
OInstanceProvider fixed init params bug
2000-11-02 12:58:02 +00:00
, _aInitParams( rInitParams )
initial import
2000-09-18 15:18:56 +00:00
, _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( _xMgr, _aImplName, _aLocation );
else // via service manager
unoexe::createInstance( xRet, _xMgr, _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 (_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 & rEvt )
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();
}
//##################################################################################################
//##################################################################################################
//##################################################################################################
//##################################################################################################
extern "C" int SAL_CALL main( int argc, const char * argv[] )
{
if (argc <= 1)
{
out( arUsingText );
return 0;
}
sal_Int32 nRet = 0;
Reference< XMultiServiceFactory > xMgr;
Reference< XSimpleRegistry > xRegistry;
try
{
OUString aImplName, aLocation, aServiceName, aUnoUrl;
vector< OUString > aRegistries;
Sequence< OUString > aParams;
sal_Bool bSingleAccept = sal_False;
sal_Bool bSingleInstance = sal_False;
//#### read command line arguments #########################################################
sal_Int32 nPos = 1;
// read up to arguments
while (nPos < argc)
{
if (rtl_str_compare( argv[nPos], "--" ) == 0)
{
++nPos;
break;
}
if (readOption( &aImplName, 'c', &nPos, argv, argc ) ||
readOption( &aLocation, 'l', &nPos, argv, argc ) ||
readOption( &aServiceName, 's', &nPos, argv, argc ) ||
readOption( &aUnoUrl, 'u', &nPos, argv, argc ) ||
readOption( &bSingleAccept, "singleaccept", &nPos, argv, argc ) ||
readOption( &bSingleInstance, "singleinstance", &nPos, argv, argc ))
{
continue;
}
OUString aRegistry;
if (readOption( &aRegistry, 'r', &nPos, argv, argc ))
{
aRegistries.push_back( aRegistry );
continue;
}
// else illegal argument
OUStringBuffer buf( 64 );
buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("unexpected parameter \"") );
buf.appendAscii( argv[nPos] );
buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\"!") );
throw RuntimeException( buf.makeStringAndClear(), 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() && !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( argc - nPos );
OUString * pParams = aParams.getArray();
sal_Int32 nOffset = nPos;
for ( ; nPos < argc; ++nPos )
{
pParams[nPos -nOffset] = OUString::createFromAscii( argv[nPos] );
}
//#### create registry #####################################################################
xMgr = createServiceFactory();
if (! xMgr.is())
throw RuntimeException( OUString( RTL_CONSTASCII_USTRINGPARAM("cannot boot strap service manager!" ) ), Reference< XInterface >() );
// registries to be used
if (aRegistries.size())
{
// ReadOnly registries
sal_Int32 nPos = 0;
sal_Int32 nReadOnly = aRegistries.size() -1;
for ( ; nPos < nReadOnly; ++nPos )
{
Reference< XSimpleRegistry > xNewReg(
openRegistry( xMgr, aRegistries[nPos], sal_True, sal_False ) );
if (xNewReg.is())
xRegistry = (xRegistry.is() ? nestRegistries( xMgr, xNewReg, xRegistry ) : xNewReg);
}
// ReadWrite registry
Reference< XSimpleRegistry > xNewReg(
openRegistry( xMgr, aRegistries[nPos], sal_False, sal_True ) );
if (xNewReg.is())
xRegistry = (xRegistry.is() ? nestRegistries( xMgr, xNewReg, xRegistry ) : xNewReg);
}
// init service manager with registry
if (xRegistry.is())
{
Reference< XInitialization > xInit( xMgr, UNO_QUERY );
if (! xInit.is())
throw RuntimeException( OUString( RTL_CONSTASCII_USTRINGPARAM("service manager does not export interface \"com.sun.star.lang.XInitialization\"!" ) ), Reference< XInterface >() );
Any aReg( makeAny( xRegistry ) );
xInit->initialize( Sequence< Any >( &aReg, 1 ) );
}
else
{
out( "\n> warning: no registry given!" );
}
//#### accept, instanciate, etc. ###########################################################
if (aUnoUrl.getLength()) // accepting connections
{
if (aUnoUrl.getTokenCount( ';' ) != 3 || aUnoUrl.getLength() < 10 ||
!aUnoUrl.copy( 0, 4 ).equalsIgnoreCase( OUString( RTL_CONSTASCII_USTRINGPARAM("uno:") ) ))
{
throw RuntimeException( OUString( RTL_CONSTASCII_USTRINGPARAM("illegal uno url given!" ) ), Reference< XInterface >() );
}
OUString aConnectDescr( aUnoUrl.getToken( 0 ).copy( 4 ) ); // uno:CONNECTDESCR;iiop;InstanceName
OUString aInstanceName( aUnoUrl.getToken( 2 ) );
Reference< XAcceptor > xAcceptor;
createInstance(
xAcceptor, xMgr,
OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.connection.Acceptor") ) );
// init params
Sequence< Any > aInitParams( aParams.getLength() );
const OUString * pParams = aParams.getConstArray();
Any * pInitParams = aInitParams.getArray();
for ( sal_Int32 nPos = aParams.getLength(); nPos--; )
{
pInitParams[nPos] = makeAny( pParams[nPos] );
}
// instance provider
Reference< XInstanceProvider > xInstanceProvider( new OInstanceProvider(
xMgr, aImplName, aLocation, aServiceName, aInitParams,
bSingleInstance, aInstanceName ) );
for (;;)
{
// accepting
out( "\n> accepting " );
out( aConnectDescr );
out( "..." );
Reference< XConnection > xConnection( xAcceptor->accept( aConnectDescr ) );
out( "connection established." );
Reference< XBridgeFactory > xBridgeFactory;
createInstance(
xBridgeFactory, xMgr,
OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.bridge.BridgeFactory") ) );
// bridge
Reference< XBridge > xBridge( xBridgeFactory->createBridge(
OUString(), aUnoUrl.getToken(1),
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( xMgr, aImplName, aLocation );
else // via service manager
createInstance( xInstance, xMgr, 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
if (xMgr.is())
{
Reference< XComponent > xComp( xMgr, UNO_QUERY );
if (xComp.is())
xComp->dispose();
}
if (xRegistry.is())
{
xRegistry->close();
}
out( "\n" );
return nRet;
}
}
Reference in New Issue Copy Permalink