initial import

2 files changed, 828 insertions, 0 deletions

diff --git a/stoc/source/javaloader/javaloader.cxx b/stoc/source/javaloader/javaloader.cxx
new file mode 100644
index 000000000000..139e7a4d57df
--- /dev/null
+++ b/stoc/source/javaloader/javaloader.cxx
@@ -0,0 +1,674 @@
+/*************************************************************************
+ *
+ *  $RCSfile: javaloader.cxx,v $
+ *
+ *  $Revision: 1.1.1.1 $
+ *
+ *  last change: $Author: hr $ $Date: 2000-09-18 15:29:34 $
+ *
+ *  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 <string.h>
+
+#include <osl/diagnose.h>
+#include <osl/interlck.h>
+
+#include <rtl/ustring>
+#include <rtl/process.h>
+
+#include <uno/dispatcher.h>
+#include <uno/environment.h>
+#include <uno/mapping.h>
+#include <uno/mapping.hxx>
+
+#include <cppuhelper/servicefactory.hxx>
+
+#include <com/sun/star/uno/Reference.hxx>
+
+#ifdef LINUX
+#undef minor
+#undef major
+#endif
+#include <com/sun/star/corba/giop/MessageHeader_1_1.hpp>
+
+#include <com/sun/star/bridge/XBridgeFactory.hpp>
+#include <com/sun/star/bridge/XBridge.hpp>
+#include <com/sun/star/bridge/XInstanceProvider.hpp>
+
+#include <com/sun/star/connection/XConnection.hpp>
+
+#include <com/sun/star/java/XJavaVM.hpp>
+#include <com/sun/star/java/XJavaThreadRegister_11.hpp>
+
+#include <com/sun/star/lang/XMultiServiceFactory.hpp>
+
+#include <bridges/remote/context.h>
+#include <bridges/remote/connection.h>
+#include <bridges/remote/remote.h>
+
+#include "jni.h"
+
+#include <cppuhelper/factory.hxx>
+
+#include <cppuhelper/implbase1.hxx>
+#include <cppuhelper/implbase2.hxx>
+
+#include <com/sun/star/loader/XImplementationLoader.hpp>
+#include <com/sun/star/lang/IllegalArgumentException.hpp>
+#include <com/sun/star/lang/XMultiServiceFactory.hpp>
+#include <com/sun/star/lang/XServiceInfo.hpp>
+#include <com/sun/star/lang/XInitialization.hpp>
+#include <com/sun/star/registry/XRegistryKey.hpp>
+
+#include "jthreadpool.hxx"
+
+using namespace ::com::sun::star::bridge;
+using namespace ::com::sun::star::connection;
+using namespace ::com::sun::star::java;
+using namespace ::com::sun::star::lang;
+using namespace ::com::sun::star::loader;
+using namespace ::com::sun::star::uno;
+using namespace ::com::sun::star::registry;
+using namespace ::com::sun::star::io;
+
+using namespace ::cppu;
+using namespace ::rtl;
+
+namespace loader {
+    class JVMThreadAttach {
+        JavaVM * _pJavaVM;
+        Reference<XJavaThreadRegister_11> _xJavaThreadRegister_11;
+
+    public:
+        JNIEnv * _pJNIEnv;
+
+        JVMThreadAttach(JavaVM * pJavaVM, XJavaThreadRegister_11 * pXJavaThreadRegister_11) throw (RuntimeException);
+        ~JVMThreadAttach() throw (RuntimeException);
+    };
+
+    JVMThreadAttach::JVMThreadAttach(JavaVM * pJavaVM, XJavaThreadRegister_11 * pXJavaThreadRegister_11) throw (RuntimeException)
+        : _pJNIEnv(NULL),
+          _pJavaVM(pJavaVM),
+          _xJavaThreadRegister_11(pXJavaThreadRegister_11)
+    {
+        pXJavaThreadRegister_11->registerThread();
+        pJavaVM->AttachCurrentThread(&_pJNIEnv, NULL);
+    }
+
+    JVMThreadAttach::~JVMThreadAttach() throw (RuntimeException)
+    {
+        _xJavaThreadRegister_11->revokeThread();
+        if(!_xJavaThreadRegister_11->isThreadAttached())
+            _pJavaVM->DetachCurrentThread();
+    }
+
+
+
+    struct ConnectionWrapper : public remote_Connection {
+        sal_Int32                _refCount;
+
+        JavaVM *                 _pJavaVM;
+        XJavaThreadRegister_11 * _pXJavaThreadRegister_11;
+
+        jclass                   _jcByteArray;
+        jmethodID                _jmConnection_read;
+        jmethodID                _jmConnection_write;
+        jmethodID                _jmConnection_flush;
+        jmethodID                _jmConnection_close;
+        jobject                  _joConnection;
+
+        ConnectionWrapper(JavaVM * pJavaVM, XJavaThreadRegister_11 * pXJavaThreadRegister_11, jobject joConnection) throw(RuntimeException);
+        ~ConnectionWrapper() throw(RuntimeException);
+
+    };
+
+    void SAL_CALL ConnectionWrapper_acquire(remote_Connection * blb) {
+        ++ ((ConnectionWrapper *)blb)->_refCount;
+    }
+
+    void SAL_CALL ConnectionWrapper_release (remote_Connection * blb) {
+        if(!-- ((ConnectionWrapper *)blb)->_refCount)
+            delete (ConnectionWrapper *)blb;
+    }
+
+    sal_Int32 SAL_CALL ConnectionWrapper_read(remote_Connection * blb, sal_Int8 *pDest, sal_Int32 nSize) {
+        ConnectionWrapper * pC = (ConnectionWrapper *)blb;
+        jint jiRes = -1;
+
+        try {
+            JVMThreadAttach jvm(pC->_pJavaVM, pC->_pXJavaThreadRegister_11);
+
+            try {
+                jobjectArray joDest = jvm._pJNIEnv->NewObjectArray(1, pC->_jcByteArray, 0);                                       if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 1"), Reference<XInterface>());
+                jvm._pJNIEnv->SetObjectArrayElement(joDest, 0, jvm._pJNIEnv->NewByteArray(10));                                   if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 2"), Reference<XInterface>());
+
+                jiRes = jvm._pJNIEnv->CallIntMethod(pC->_joConnection, pC->_jmConnection_read, joDest, (jint)nSize);              if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 3"), Reference<XInterface>());
+
+                jbyteArray jaDest = reinterpret_cast<jbyteArray>(jvm._pJNIEnv->GetObjectArrayElement(joDest, 0));                 if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 4"), Reference<XInterface>());
+
+                jbyte * pBytes = jvm._pJNIEnv->GetByteArrayElements(jaDest, NULL);                                                if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 5"), Reference<XInterface>());
+                memcpy(pDest, pBytes, jiRes * sizeof(sal_Int8));
+                jvm._pJNIEnv->ReleaseByteArrayElements(jaDest, pBytes, 0);                                                        if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 6"), Reference<XInterface>());
+            }
+            catch(RuntimeException & runtimeException) {
+                if(jvm._pJNIEnv->ExceptionOccurred()) {
+                    jvm._pJNIEnv->ExceptionDescribe();
+                    jvm._pJNIEnv->ExceptionClear();
+                }
+
+                throw runtimeException;
+            }
+        }
+        catch(RuntimeException &) {
+            osl_trace("ConnectionWrapper_read - runtimeException occurred\n");
+            jiRes = -1;
+        }
+
+        return (sal_Int32)jiRes;
+    }
+
+    sal_Int32 SAL_CALL ConnectionWrapper_write(remote_Connection * blb, const sal_Int8 *pSource, sal_Int32 nSize) {
+        ConnectionWrapper * pC = (ConnectionWrapper *)blb;
+
+        try {
+            JVMThreadAttach jvm(pC->_pJavaVM, pC->_pXJavaThreadRegister_11);
+
+            try {
+                jbyteArray jaSource = jvm._pJNIEnv->NewByteArray(nSize);                                                       if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 7"), Reference<XInterface>());
+                jbyte * pBytes = jvm._pJNIEnv->GetByteArrayElements(jaSource, NULL);                                           if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 8"), Reference<XInterface>());
+                memcpy(pBytes, pSource, nSize * sizeof(jbyte));
+                jvm._pJNIEnv->ReleaseByteArrayElements(jaSource, pBytes, 0);                                                   if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 9"), Reference<XInterface>());
+
+                jvm._pJNIEnv->CallVoidMethod(pC->_joConnection, pC->_jmConnection_write, jaSource, (jint)nSize);               if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 10"), Reference<XInterface>());
+            }
+            catch(RuntimeException & runtimeException) {
+                if(jvm._pJNIEnv->ExceptionOccurred()) {
+                    jvm._pJNIEnv->ExceptionDescribe();
+                    jvm._pJNIEnv->ExceptionClear();
+                }
+
+                throw runtimeException;
+            }
+        }
+        catch(RuntimeException &) {
+            osl_trace("ConnectionWrapper_read - runtimeException occurred\n");
+            nSize = -1;
+        }
+
+        return nSize;
+    }
+
+    void SAL_CALL ConnectionWrapper_flush(remote_Connection * blb) {
+        ConnectionWrapper * pC = (ConnectionWrapper *)blb;
+
+        JVMThreadAttach jvm(pC->_pJavaVM, pC->_pXJavaThreadRegister_11);
+        jvm._pJNIEnv->CallVoidMethod(pC->_joConnection, pC->_jmConnection_flush);
+        if(jvm._pJNIEnv->ExceptionOccurred()) {
+            jvm._pJNIEnv->ExceptionDescribe();
+            jvm._pJNIEnv->ExceptionClear();
+        }
+    }
+
+    void SAL_CALL ConnectionWrapper_close(remote_Connection * blb) {
+        ConnectionWrapper * pC = (ConnectionWrapper *)blb;
+
+        JVMThreadAttach jvm(pC->_pJavaVM, pC->_pXJavaThreadRegister_11);
+        jvm._pJNIEnv->CallVoidMethod(pC->_joConnection, pC->_jmConnection_close);
+        if(jvm._pJNIEnv->ExceptionOccurred()) {
+            jvm._pJNIEnv->ExceptionDescribe();
+            jvm._pJNIEnv->ExceptionClear();
+        }
+    }
+
+    ConnectionWrapper::ConnectionWrapper(JavaVM * pJavaVM, XJavaThreadRegister_11 * pXJavaThreadRegister_11, jobject joConnection) throw(RuntimeException)
+        : _refCount(0),
+          _pJavaVM(pJavaVM),
+          _pXJavaThreadRegister_11(pXJavaThreadRegister_11)
+    {
+        if(!pJavaVM || !pXJavaThreadRegister_11 || !joConnection)
+            throw RuntimeException(OUString::createFromAscii("hier 11"), Reference<XInterface>());
+
+        acquire = ConnectionWrapper_acquire;
+        release = ConnectionWrapper_release;
+        read = ConnectionWrapper_read;
+        write = ConnectionWrapper_write;
+        flush = ConnectionWrapper_flush;
+        close = ConnectionWrapper_close;
+
+        JVMThreadAttach jvm(pJavaVM, pXJavaThreadRegister_11);
+
+        _jcByteArray = jvm._pJNIEnv->FindClass("[B");                                                                          if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 12"), Reference<XInterface>());
+        _jcByteArray = reinterpret_cast<jclass>(jvm._pJNIEnv->NewGlobalRef(reinterpret_cast<jobject>(_jcByteArray)));          if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 13"), Reference<XInterface>());
+
+        jclass jcConnection = jvm._pJNIEnv->FindClass("com/sun/star/connection/XConnection");                                  if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 14"), Reference<XInterface>());
+
+        _jmConnection_read  = jvm._pJNIEnv->GetMethodID(jcConnection, "read", "([[BI)I");                                      if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 15"), Reference<XInterface>());
+//          _jmConnection_read  = reinterpret_cast<jmethodID>(jvm._pJNIEnv->NewGlobalRef(reinterpret_cast<jobject>(_jmConnection_read)));
+        _jmConnection_write = jvm._pJNIEnv->GetMethodID(jcConnection, "write", "([B)V");                                       if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 16"), Reference<XInterface>());
+//          _jmConnection_write = reinterpret_cast<jmethodID>(jvm._pJNIEnv->NewGlobalRef(reinterpret_cast<jobject>(_jmConnection_write)));
+        _jmConnection_flush = jvm._pJNIEnv->GetMethodID(jcConnection, "flush", "()V");                                         if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 17"), Reference<XInterface>());
+//          _jmConnection_flush = reinterpret_cast<jmethodID>(jvm._pJNIEnv->NewGlobalRef(reinterpret_cast<jobject>(_jmConnection_flush)));
+        _jmConnection_close = jvm._pJNIEnv->GetMethodID(jcConnection, "close", "()V");                                         if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 18"), Reference<XInterface>());
+//          _jmConnection_close = reinterpret_cast<jmethodID>(jvm._pJNIEnv->NewGlobalRef(reinterpret_cast<jobject>(_jmConnection_close)));
+
+        _joConnection = jvm._pJNIEnv->NewGlobalRef(joConnection);                                                              if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 19"), Reference<XInterface>());
+    }
+
+    ConnectionWrapper::~ConnectionWrapper() throw(RuntimeException) {
+        JVMThreadAttach jvm(_pJavaVM, _pXJavaThreadRegister_11);
+
+        jvm._pJNIEnv->DeleteGlobalRef(_joConnection);                                                                          if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 20"), Reference<XInterface>());
+
+        jvm._pJNIEnv->DeleteGlobalRef(reinterpret_cast<jobject>(_jmConnection_read));                                          if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 21"), Reference<XInterface>());
+        jvm._pJNIEnv->DeleteGlobalRef(reinterpret_cast<jobject>(_jmConnection_write));                                         if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 22"), Reference<XInterface>());
+        jvm._pJNIEnv->DeleteGlobalRef(reinterpret_cast<jobject>(_jmConnection_flush));                                         if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 23"), Reference<XInterface>());
+        jvm._pJNIEnv->DeleteGlobalRef(reinterpret_cast<jobject>(_jmConnection_close));                                         if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 24"), Reference<XInterface>());
+
+        jvm._pJNIEnv->DeleteGlobalRef(_jcByteArray);                                                                           if(jvm._pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 25"), Reference<XInterface>());
+    }
+
+
+
+
+    class JavaComponentLoader : public WeakImplHelper2<XImplementationLoader, XServiceInfo> {
+        Reference<XMultiServiceFactory>  _xSMgr;
+        Reference<XImplementationLoader> _javaLoader;
+
+        uno_Environment                * _pRemote_Environment;
+    protected:
+        JavaComponentLoader(const Reference<XMultiServiceFactory> & rXSMgr) throw(RuntimeException);
+        ~JavaComponentLoader();
+
+    public:
+        static const OUString implname;
+        static const OUString servname;
+        static Reference<XInterface> CreateInstance(const Reference<XMultiServiceFactory> & rSMgr) throw(Exception);
+        static Sequence<OUString> SAL_CALL getSupportedServiceNames_Static();
+
+        // XServiceInfo
+        virtual OUString SAL_CALL getImplementationName() throw(::com::sun::star::uno::RuntimeException);
+        virtual sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw(::com::sun::star::uno::RuntimeException);
+        virtual Sequence<OUString> SAL_CALL getSupportedServiceNames() throw(::com::sun::star::uno::RuntimeException);
+
+        // XImplementationLoader
+        virtual Reference<XInterface> SAL_CALL activate(const OUString& implementationName, const OUString& implementationLoaderUrl, const OUString& locationUrl, const Reference<XRegistryKey>& xKey) throw(CannotActivateFactoryException, RuntimeException);
+        virtual sal_Bool SAL_CALL writeRegistryInfo(const Reference<XRegistryKey>& xKey, const OUString& implementationLoaderUrl, const OUString& locationUrl) throw(CannotRegisterImplementationException, RuntimeException);
+    };
+
+    const OUString JavaComponentLoader::implname = L"com.sun.star.comp.stoc.JavaComponentLoader";
+    const OUString JavaComponentLoader::servname = L"com.sun.star.loader.Java2";
+
+    Sequence<OUString> SAL_CALL JavaComponentLoader::getSupportedServiceNames_Static() {
+        return Sequence<OUString>(&servname, 1);
+    }
+
+
+    Reference<XInterface> SAL_CALL JavaComponentLoader::CreateInstance(const Reference<XMultiServiceFactory> & rSMgr) throw(Exception)
+    {
+        Reference<XInterface> xRet;
+
+        try {
+            XImplementationLoader *pXLoader = (XImplementationLoader *)new JavaComponentLoader(rSMgr);
+
+            xRet = Reference<XInterface>::query(pXLoader);
+        }
+        catch(RuntimeException & runtimeException) {
+            osl_trace("Could not init javaloader\n");
+            OString message = OUStringToOString(runtimeException.Message, RTL_TEXTENCODING_ASCII_US);
+            fprintf(stderr, "exception: %s\n", (const char *)message);
+        }
+
+        return xRet;
+    }
+
+    JavaComponentLoader::JavaComponentLoader(const Reference<XMultiServiceFactory> & rSMgr) throw(RuntimeException)
+        : _pRemote_Environment(NULL)
+    {
+        Reference<XJavaVM> xJavaVM(rSMgr->createInstance(OUString::createFromAscii("com.sun.star.java.JavaVirtualMachine")), UNO_QUERY);
+
+        Reference<XJavaThreadRegister_11> xJavaThreadRegister_11(xJavaVM, UNO_QUERY);
+
+        JavaVM * pJavaVM;
+
+
+        Sequence<sal_Int8> processID(16);
+        rtl_getGlobalProcessId(reinterpret_cast<sal_uInt8 *>(processID.getArray()));
+
+        pJavaVM = *(JavaVM **)(xJavaVM->getJavaVM(processID).getValue());
+//              pJavaVM = *reinterpret_cast<JavaVM **>(xJavaVM->getJavaVM(processID).getValue());
+
+        if(!pJavaVM)
+          throw RuntimeException(OUString::createFromAscii("hier -1"), Reference<XInterface>());
+
+        JNIEnv * pJNIEnv;
+
+          pJavaVM->AttachCurrentThread(&pJNIEnv, (void *)NULL);
+          xJavaThreadRegister_11->registerThread();
+
+        if( ! javaloader_initNativeThreadPool( pJNIEnv, xJavaThreadRegister_11 ) )
+          {
+              throw RuntimeException(
+                  OUString::createFromAscii( "native threadpool couldn't be initialzed" ),
+                  Reference< XInterface > () );
+          }
+
+        remote_Connection * pRemote_Connection = NULL;
+
+        try {
+          jclass jcServiceManager = pJNIEnv->FindClass("com/sun/star/comp/servicemanager/ServiceManager");                   if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 26"), Reference<XInterface>());
+          jmethodID jmServiceManager_init = pJNIEnv->GetMethodID(jcServiceManager, "<init>", "()V");                         if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 27"), Reference<XInterface>());
+          jobject joServiceManager = pJNIEnv->NewObject(jcServiceManager, jmServiceManager_init);                            if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 28"), Reference<XInterface>());
+
+          // we need to register the need services
+          static const char * neededServices[] = {
+              "com.sun.star.comp.servicemanager.ServiceManager",
+              "com.sun.star.comp.loader.JavaLoader",
+              "com.sun.star.lib.uno.bridges.java_remote.java_remote_bridge",
+              "com.sun.star.comp.connections.PipedConnection",
+              "com.sun.star.comp.connections.ConstantInstanceProvider"
+          };
+
+
+          jclass jcString = pJNIEnv->FindClass("java/lang/String");                                                          if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 29"), Reference<XInterface>());
+          jobjectArray jaNeededServices = pJNIEnv->NewObjectArray(sizeof(neededServices) / sizeof(char *), jcString, NULL);  if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 30"), Reference<XInterface>());
+          for(int i = 0; i < sizeof(neededServices) / sizeof(char *); ++ i) {
+              pJNIEnv->SetObjectArrayElement(jaNeededServices, i, pJNIEnv->NewStringUTF(neededServices[i]));                 if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 31"), Reference<XInterface>());
+          }
+
+          jmethodID jmServiceManager_addFactories = pJNIEnv->GetMethodID(jcServiceManager,
+                                                                         "addFactories",
+                                                                         "([Ljava/lang/String;)V");                          if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 32"), Reference<XInterface>());
+
+          pJNIEnv->CallVoidMethod(joServiceManager, jmServiceManager_addFactories, jaNeededServices);                        if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 33"), Reference<XInterface>());
+
+        //
+          jmethodID jmServiceManager_createInstanceWithArguments = pJNIEnv->GetMethodID(jcServiceManager,
+                                                                                        "createInstanceWithArguments",
+                                                                                        "(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/Object;"); if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 34"), Reference<XInterface>());
+
+          // create an instance of our special inprocess connection
+          jmethodID jmServiceManager_createInstance = pJNIEnv->GetMethodID(jcServiceManager,
+                                                                           "createInstance",
+                                                                           "(Ljava/lang/String;)Ljava/lang/Object;");        if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 35"), Reference<XInterface>());
+
+          jstring jsConnectionName = pJNIEnv->NewStringUTF("com.sun.star.connection.PipedConnection");                     if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 36"), Reference<XInterface>());
+          jobject joConnection_nativeSide = pJNIEnv->CallObjectMethod(joServiceManager,
+                                                                      jmServiceManager_createInstance,
+                                                                      jsConnectionName);                                     if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 37"), Reference<XInterface>());
+
+          jclass jcObject = pJNIEnv->FindClass("java/lang/Object");                                                        if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 38"), Reference<XInterface>());
+          jobjectArray jaArgs = pJNIEnv->NewObjectArray(1, jcObject, joConnection_nativeSide);
+          jobject joConnection_javaSide = pJNIEnv->CallObjectMethod(joServiceManager,
+                                                                    jmServiceManager_createInstanceWithArguments,
+                                                                    jsConnectionName, jaArgs);                             if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 39"), Reference<XInterface>());
+
+          // create an constant service provider with java servicemanager
+          jstring jsInstanceProvider = pJNIEnv->NewStringUTF("com.sun.star.comp.connection.InstanceProvider");             if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 40"), Reference<XInterface>());
+          jobject joInstanceProvider = pJNIEnv->CallObjectMethod(joServiceManager,
+                                                                 jmServiceManager_createInstance,
+                                                                 jsInstanceProvider);                                          if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 41"), Reference<XInterface>());
+
+          // create the bridge factory && the bridge
+          jaArgs = pJNIEnv->NewObjectArray(3, jcObject, NULL);                                                             if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 42"), Reference<XInterface>());
+
+          pJNIEnv->SetObjectArrayElement(jaArgs, 0, pJNIEnv->NewStringUTF("iiop"));                                        if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 43"), Reference<XInterface>());
+          pJNIEnv->SetObjectArrayElement(jaArgs, 1, joConnection_javaSide);                                                if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 44"), Reference<XInterface>());
+          pJNIEnv->SetObjectArrayElement(jaArgs, 2, joInstanceProvider);                                                       if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 45"), Reference<XInterface>());
+
+          jstring jsBridgeComponent = pJNIEnv->NewStringUTF("com.sun.star.bridge.Bridge");                                 if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 46"), Reference<XInterface>());
+          jobject joBridge = pJNIEnv->CallObjectMethod(joServiceManager,
+                                                       jmServiceManager_createInstanceWithArguments,
+                                                       jsBridgeComponent,
+                                                       jaArgs);                                                            if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 47"), Reference<XInterface>());
+
+          pRemote_Connection = new ConnectionWrapper(pJavaVM, xJavaThreadRegister_11.get(), joConnection_nativeSide);
+        }
+        catch(RuntimeException & runtimeException) {
+          if(pJNIEnv->ExceptionOccurred()) {
+            pJNIEnv->ExceptionDescribe();
+            pJNIEnv->ExceptionClear();
+          }
+
+          throw runtimeException;
+        }
+
+        xJavaThreadRegister_11->revokeThread();
+        if(!xJavaThreadRegister_11->isThreadAttached())
+            pJavaVM->DetachCurrentThread();
+
+
+        //
+        // everything is prepared to map an initial object from remote (java) to here
+        //
+        OString idStr("the id string");
+        OString dcpStr("the description string");
+        remote_Context * pRemote_Context = remote_createContext(pRemote_Connection, idStr.pData, dcpStr.pData, NULL);      if(!pRemote_Connection) throw RuntimeException(OUString::createFromAscii("hier 48"), Reference<XInterface>());
+
+        uno_getEnvironment(&_pRemote_Environment, "remote", pRemote_Context);                                              if(!_pRemote_Environment) throw RuntimeException(OUString::createFromAscii("hier 49"), Reference<XInterface>());
+
+        uno_Environment * pUNO_Environment = NULL;
+        uno_getEnvironment(&pUNO_Environment, "uno", NULL);                                                                if(!pUNO_Environment) throw RuntimeException(OUString::createFromAscii("hier 50"), Reference<XInterface>());
+
+        Mapping mapping(_pRemote_Environment, pUNO_Environment, OString());
+
+
+
+        OString remoteO("SERVICEMANAGER");
+
+        typelib_InterfaceTypeDescription *pType = 0;
+        getCppuType((Reference <XInterface> *) 0).getDescription((typelib_TypeDescription **) & pType) ;                   if(!pType) throw RuntimeException(OUString::createFromAscii("hier 51"), Reference<XInterface>());
+
+        remote_Interface *pRemoteI = 0;
+
+        getCppuType( (::com::sun::star::corba::giop::MessageHeader_1_1*)0 );
+
+
+        pRemote_Context->getRemoteInstance(_pRemote_Environment,
+                                           &pRemoteI,
+                                           remoteO.pData,
+                                           pType);                                                                         if(!pRemoteI) throw RuntimeException(OUString::createFromAscii("hier 52"), Reference<XInterface>());
+
+        // got an interface !
+        uno_Environment *pEnvCpp =0;
+        uno_getEnvironment(&pEnvCpp , CPPU_CURRENT_LANGUAGE_BINDING_NAME , 0);                                             if(!pEnvCpp) throw RuntimeException(OUString::createFromAscii("hier 53"), Reference<XInterface>());
+
+        Mapping map(_pRemote_Environment , pEnvCpp);
+
+        XInterface * pCppI = (XInterface *) map.mapInterface(pRemoteI, pType);                                             if(!pCppI) throw RuntimeException(OUString::createFromAscii("hier 54"), Reference<XInterface>());
+
+        Reference<XInterface> rReturn = Reference<XInterface>(pCppI);
+
+        Reference<XMultiServiceFactory> serviceManager(rReturn, UNO_QUERY);                                                if(!serviceManager.is()) throw RuntimeException(OUString::createFromAscii("hier 55"), Reference<XInterface>());
+
+        Reference<XInterface> javaLoader_xInterface =
+            serviceManager->createInstance(OUString::createFromAscii("com.sun.star.loader.Java"));                         if(!javaLoader_xInterface.is()) throw RuntimeException(OUString::createFromAscii("hier 56"), Reference<XInterface>());
+        _javaLoader = Reference<XImplementationLoader>(javaLoader_xInterface, UNO_QUERY);                                  if(!_javaLoader.is()) throw RuntimeException(OUString::createFromAscii("hier 57"), Reference<XInterface>());
+        _javaLoader->acquire();
+
+        Reference<XInitialization> javaLoader_xInit(javaLoader_xInterface, UNO_QUERY);
+
+        Any any_smgr;
+        any_smgr <<= rSMgr;
+        javaLoader_xInit->initialize(Sequence<Any>(&any_smgr, 1));
+
+
+        // important: release the context and the environments
+
+        pCppI->release();
+        pEnvCpp->release(pEnvCpp);
+        pRemoteI->release(pRemoteI);
+
+          pUNO_Environment->release(pUNO_Environment);
+          pRemote_Context->aBase.release(reinterpret_cast<uno_Context *>(pRemote_Context));
+    }
+
+
+    JavaComponentLoader::~JavaComponentLoader() {
+        if(_pRemote_Environment)
+        {
+            _pRemote_Environment->dispose(_pRemote_Environment);
+            _pRemote_Environment->release(_pRemote_Environment);
+        }
+
+//          JVMThreadAttach jvm(pC->_pJavaVM, pC->_pXJavaThreadRegister_11);
+
+//          try {
+//              jclass jcThreadPool = jvm._pJNIEnv->FindClass("com/sun/star/lib/uno/environments/remote/ThreadPool");             if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 1"), Reference<XInterface>());
+//              jmethodID jmThreadPool_reset = jvm._pJNIEnv->GetMethodID(jcThreadPool, "reset", "()V");                           if(pJNIEnv->ExceptionOccurred()) throw RuntimeException(OUString::createFromAscii("hier 1"), Reference<XInterface>());
+
+//              jvm._pJNIEnv->CallStaticVoidMethod(jcThreadPool, jmThreadPool_reset);
+//          }
+//          catch(
+    }
+
+    // XServiceInfo
+    OUString SAL_CALL JavaComponentLoader::getImplementationName() throw(::com::sun::star::uno::RuntimeException) {
+        return implname;
+    }
+
+    sal_Bool SAL_CALL JavaComponentLoader::supportsService(const OUString & ServiceName) throw(::com::sun::star::uno::RuntimeException) {
+        sal_Bool bSupport = sal_False;
+
+        Sequence<OUString> aSNL = getSupportedServiceNames();
+        const OUString * pArray = aSNL.getArray();
+        for(sal_Int32 i = 0; i < aSNL.getLength() && !bSupport; ++ i)
+            bSupport = pArray[i] == ServiceName;
+
+        return bSupport;
+    }
+
+    Sequence<OUString> SAL_CALL JavaComponentLoader::getSupportedServiceNames() throw(::com::sun::star::uno::RuntimeException) {
+        return getSupportedServiceNames_Static();
+    }
+
+
+
+    // XImplementationLoader
+    sal_Bool SAL_CALL JavaComponentLoader::writeRegistryInfo(const Reference<XRegistryKey> & xKey, const OUString & blabla, const OUString & rLibName)
+        throw(CannotRegisterImplementationException, RuntimeException)
+    {
+        sal_Bool bSuccess = sal_False;
+
+        bSuccess = _javaLoader->writeRegistryInfo(xKey, blabla, rLibName);
+
+        return bSuccess;
+    }
+
+
+    Reference<XInterface> SAL_CALL JavaComponentLoader::activate(const OUString & rImplName,
+                                                                 const OUString & blabla,
+                                                                 const OUString & rLibName,
+                                                                 const Reference<XRegistryKey> & xKey)
+        throw(CannotActivateFactoryException, RuntimeException)
+    {
+        return _javaLoader->activate(rImplName, blabla, rLibName, xKey);
+    }
+}
+
+
+extern "C"
+{
+    SAL_DLLEXPORT void SAL_CALL component_getImplementationEnvironment(const sal_Char ** ppEnvTypeName, uno_Environment ** ppEnv)   {
+        *ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME;
+    }
+
+    SAL_DLLEXPORT sal_Bool SAL_CALL component_writeInfo(XMultiServiceFactory * pServiceManager, XRegistryKey * pRegistryKey) {
+        sal_Bool bRes = sal_False;
+
+        if (pRegistryKey) {
+            try {
+                OUString x = OUString::createFromAscii("/");
+                x += ::loader::JavaComponentLoader::implname;
+                x += OUString::createFromAscii("/UNO/SERVICES");
+
+                Reference<XRegistryKey> xNewKey(pRegistryKey->createKey(x));
+
+                const Sequence<OUString> rSNL = ::loader::JavaComponentLoader::getSupportedServiceNames_Static();
+                const OUString * pArray = rSNL.getConstArray();
+                for (sal_Int32 nPos = rSNL.getLength(); nPos--;)
+                    xNewKey->createKey(pArray[nPos]);
+
+                bRes = sal_True;
+            }
+            catch (InvalidRegistryException &) {
+                OSL_ENSHURE( sal_False, "### InvalidRegistryException!" );
+            }
+        }
+
+        return bRes;
+    }
+
+    SAL_DLLEXPORT void * SAL_CALL component_getFactory(const sal_Char * pImplName, XMultiServiceFactory * pServiceManager, XRegistryKey * pRegistryKey) {
+        void * pRet = 0;
+
+
+        OString xx(::loader::JavaComponentLoader::implname.getStr(), ::loader::JavaComponentLoader::implname.getLength(), RTL_TEXTENCODING_DONTKNOW);
+        if (pServiceManager && rtl_str_compare(pImplName, xx) == 0)
+        {
+            Reference<XSingleServiceFactory> xFactory(createOneInstanceFactory(pServiceManager,
+                                                                               OUString::createFromAscii(pImplName),
+                                                                               ::loader::JavaComponentLoader::CreateInstance,
+                                                                               ::loader::JavaComponentLoader::getSupportedServiceNames_Static()));
+
+            if (xFactory.is())
+            {
+                xFactory->acquire();
+                pRet = xFactory.get();
+            }
+        }
+
+        return pRet;
+    }
+}
+
diff --git a/stoc/source/javaloader/makefile.mk b/stoc/source/javaloader/makefile.mk
new file mode 100644
index 000000000000..df9ba3a8b9cd
--- /dev/null
+++ b/stoc/source/javaloader/makefile.mk
@@ -0,0 +1,154 @@
+#*************************************************************************
+#
+#   $RCSfile: makefile.mk,v $
+#
+#   $Revision: 1.1.1.1 $
+#
+#   last change: $Author: hr $ $Date: 2000-09-18 15:29:34 $
+#
+#   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): _______________________________________
+#
+#
+#
+#*************************************************************************
+
+PRJ=..$/..
+
+PRJNAME=bridges
+TARGET=javaloader
+ENABLE_EXCEPTIONS=TRUE
+USE_DEFFILE=TRUE
+NO_BSYMBOLIC=TRUE
+
+# --- Settings -----------------------------------------------------
+
+.INCLUDE :  svpre.mk
+.INCLUDE :  settings.mk
+.INCLUDE :  sv.mk
+
+# ------------------------------------------------------------------
+
+CPPUMAKERFLAGS += -C
+UNOUCRDEP=$(SOLARBINDIR)$/applicat.rdb
+UNOUCRRDB=$(SOLARBINDIR)$/applicat.rdb 
+
+# output directory (one dir for each project)
+UNOUCROUT=$(OUT)$/inc
+
+# adding to inludepath
+INCPRE+=$(UNOUCROUT)
+
+UNOTYPES= \
+    com.sun.star.corba.giop.MessageHeader_1_1	\
+    com.sun.star.uno.TypeClass					\
+    com.sun.star.lang.XSingleServiceFactory		\
+    com.sun.star.lang.XMultiServiceFactory		\
+    com.sun.star.registry.XRegistryKey			\
+    com.sun.star.bridge.XBridgeFactory			\
+    com.sun.star.bridge.XBridge					\
+    com.sun.star.bridge.XInstanceProvider		\
+    com.sun.star.connection.XConnection			\
+    com.sun.star.java.XJavaVM					\
+    com.sun.star.java.XJavaThreadRegister_11	\
+    com.sun.star.uno.XWeak						\
+    com.sun.star.uno.XAggregation				\
+    com.sun.star.lang.XTypeProvider				\
+    com.sun.star.loader.XImplementationLoader	\
+    com.sun.star.lang.XServiceInfo				\
+    com.sun.star.lang.XInitialization
+
+SLOFILES= 	$(SLO)$/javaloader.obj \
+        $(SLO)$/jthreadpool.obj
+
+SHL1TARGET= $(TARGET)
+
+.IF "$(COM)" == "GCC"
+REMOTE_CONTEXTLIB = -lrmcxt1
+.ELIF "$(COM)" == "C50" 
+REMOTE_CONTEXTLIB = -lrmcxt1
+.ELSE
+REMOTE_CONTEXTLIB = irmcxt.lib
+.ENDIF
+
+SHL1STDLIBS=\
+        $(SALLIB)\
+        $(VOSLIB)\
+        $(CPPULIB)\
+        $(CPPUHELPERLIB) \
+        $(REMOTE_CONTEXTLIB)
+
+
+SHL1LIBS=\
+            $(SLB)$/$(TARGET).lib 
+
+
+# --- Targets ------------------------------------------------------
+
+.INCLUDE :	target.mk
+
+
+$(MISC)$/$(SHL1TARGET).def: makefile.mk
+    @echo ------------------------------
+    @echo Making: $@
+    @echo LIBRARY     $(SHL1TARGET)                                  >$@
+    @echo EXPORTS                                                   >>$@
+    @echo component_getImplementationEnvironment    >>$@
+    @echo component_writeInfo                       >>$@
+    @echo component_getFactory					    >>$@
+    @echo Java_com_sun_star_lib_uno_environments_remote_NativeThreadPool_add   >>$@
+    @echo Java_com_sun_star_lib_uno_environments_remote_NativeThreadPool_createTicket   >>$@
+    @echo Java_com_sun_star_lib_uno_environments_remote_NativeThreadPool_dispose   >>$@
+    @echo Java_com_sun_star_lib_uno_environments_remote_NativeThreadPool_reply   >>$@
+    @echo Java_com_sun_star_lib_uno_environments_remote_NativeThreadPool_request   >>$@
+    @echo Java_com_sun_star_lib_uno_environments_remote_NativeThreadPool_retrieve   >>$@
+    @echo Java_com_sun_star_lib_uno_environments_remote_NativeThreadPool_revoke   >>$@
+    @echo Java_com_sun_star_lib_uno_environments_remote_NativeThreadPool_stopDispose   >>$@
+    @echo Java_com_sun_star_lib_uno_environments_remote_NativeThreadPool_waitOnTicket  >>$@