maguro 2005/03/09 18:35:51
Added: modules/core/src/java/org/openejb/corba/util
OpenORBStubClassLoader.java
Log:
Stubs are now auto generated.
Revision Changes Path
1.1
openejb/modules/core/src/java/org/openejb/corba/util/OpenORBStubClassLoader.java
Index: OpenORBStubClassLoader.java
===================================================================
/**
* Redistribution and use of this software and associated documentation
* ("Software"), with or without modification, are permitted provided
* that the following conditions are met:
*
* 1. Redistributions of source code must retain copyright
* statements and notices. Redistributions must also contain a
* copy of this document.
*
* 2. Redistributions in binary form must reproduce the
* above copyright notice, this list of conditions and the
* following disclaimer in the documentation and/or other
* materials provided with the distribution.
*
* 3. The name "OpenEJB" must not be used to endorse or promote
* products derived from this Software without prior written
* permission of The OpenEJB Group. For written permission,
* please contact [EMAIL PROTECTED]
*
* 4. Products derived from this Software may not be called "OpenEJB"
* nor may "OpenEJB" appear in their names without prior written
* permission of The OpenEJB Group. OpenEJB is a registered
* trademark of The OpenEJB Group.
*
* 5. Due credit should be given to the OpenEJB Project
* (http://openejb.sf.net/).
*
* THIS SOFTWARE IS PROVIDED BY THE OPENEJB GROUP AND CONTRIBUTORS
* ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT
* NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
* FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
* THE OPENEJB GROUP OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
* STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
* OF THE POSSIBILITY OF SUCH DAMAGE.
*
* Copyright 2005 (C) The OpenEJB Group. All Rights Reserved.
*
* $Id: OpenORBStubClassLoader.java,v 1.1 2005/03/09 23:35:51 maguro Exp $
*/
package org.openejb.corba.util;
import java.io.File;
import java.io.IOException;
import java.net.URL;
import java.net.URLClassLoader;
import java.util.Collections;
import java.util.Hashtable;
import java.util.Map;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.geronimo.deployment.util.DeploymentUtil;
import org.apache.geronimo.gbean.GBeanInfo;
import org.apache.geronimo.gbean.GBeanInfoBuilder;
import org.apache.geronimo.gbean.GBeanLifecycle;
import org.apache.geronimo.j2ee.j2eeobjectnames.NameFactory;
import org.apache.geronimo.system.serverinfo.ServerInfo;
import org.openejb.corba.compiler.CompilerException;
import org.openejb.corba.compiler.StubGenerator;
/**
* @version $Revision: 1.1 $ $Date: 2005/03/09 23:35:51 $
*/
public class OpenORBStubClassLoader extends ClassLoader implements
GBeanLifecycle {
private static Log log = LogFactory.getLog(OpenORBStubClassLoader.class);
private final static int STOPPED = 0;
private final static int STARTED = 1;
private int state;
private final StubGenerator stubGenerator;
private final File cacheDir;
private final Map loaders = new Hashtable();
private static long jarId = 0;
public OpenORBStubClassLoader(ServerInfo serverInfo, StubGenerator
stubGenerator, String cacheDir) {
this.stubGenerator = stubGenerator;
this.cacheDir = new File(serverInfo.resolvePath(cacheDir),
"CORBA_STUB_CACHE");
this.state = STOPPED;
}
public synchronized Class loadClass(String name) throws
ClassNotFoundException {
if (state == STOPPED) return null;
if (log.isDebugEnabled()) log.debug("Load class " + name);
ClassLoader classLoader =
Thread.currentThread().getContextClassLoader();
Class result = null;
try {
result = classLoader.loadClass(name);
} catch (ClassNotFoundException e) {
if (log.isDebugEnabled()) log.debug("Unable to load class from
the context class loader");
}
if (result != null) return result;
if (result == null && name.endsWith("_Stub")) {
int begin = name.lastIndexOf('.') + 1;
if (name.charAt(begin) == '_') {
String iPackage = name.substring(0, begin);
String iName = iPackage + name.substring(begin + 1,
name.length() - 5);
ClassLoader loader = (ClassLoader) loaders.get(name);
if (loader == null) {
File file = null;
try {
file = new File(cacheDir, "STUB_" + (jarId++) +
".jar");
if (log.isDebugEnabled()) log.debug("Generating stubs
in " + file.toString());
stubGenerator.generateStubs(Collections.singleton(iName), file, classLoader);
loader = new URLClassLoader(new URL[]{file.toURL()},
classLoader);
loaders.put(name, loader);
} catch (IOException e) {
throw new ClassNotFoundException("Unable to generate
stub", e);
} catch (CompilerException e) {
throw new ClassNotFoundException("Unable to generate
stub", e);
}
} else {
if (log.isDebugEnabled()) log.debug("Found cached
loader");
}
result = loader.loadClass(name);
if (log.isDebugEnabled()) log.debug("result: " + (result ==
null ? "NULL" : result.getName()));
}
}
return result;
}
public synchronized void doStart() throws Exception {
cacheDir.delete();
cacheDir.mkdirs();
UtilDelegateImpl.setClassLoader(this);
this.state = STARTED;
log.info("Started - caching in " + cacheDir);
}
public synchronized void doStop() throws Exception {
this.state = STOPPED;
loaders.clear();
cacheDir.delete();
log.info("Stopped");
}
public synchronized void doFail() {
DeploymentUtil.recursiveDelete(cacheDir);
this.state = STOPPED;
log.info("Failed");
}
public static final GBeanInfo GBEAN_INFO;
static {
GBeanInfoBuilder infoFactory = new
GBeanInfoBuilder(OpenORBStubClassLoader.class);
infoFactory.addReference("ServerInfo", ServerInfo.class,
NameFactory.GERONIMO_SERVICE);
infoFactory.addReference("StubGenerator", StubGenerator.class,
NameFactory.GERONIMO_SERVICE);
infoFactory.addAttribute("cacheDir", String.class, true);
infoFactory.addOperation("loadClass", new Class[]{String.class});
infoFactory.setConstructor(new String[]{"ServerInfo",
"StubGenerator", "cacheDir"});
GBEAN_INFO = infoFactory.getBeanInfo();
}
public static GBeanInfo getGBeanInfo() {
return GBEAN_INFO;
}
}
