[jbossws-commits] JBossWS SVN: r5217 - in legacy/branches/jbossws-1.2.1.GA_JBWS-1900: jbossws-core/src/java/org/jboss/ws/core/jaxws/spi and 4 other directories.

Author: mageshbk(a)jboss.com Date: 2007-12-06 20:46:02 -0500 (Thu, 06 Dec 2007) New Revision: 5217 Modified: legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/CommonBindingProvider.java legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/jaxws/spi/ProviderImpl.java legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/server/ServiceEndpointManager.java legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/utils/DOMUtils.java legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/utils/ThreadLocalAssociation.java legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/metadata/umdm/EndpointMetaData.java legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-tests/src/java/org/jboss/test/ws/jaxrpc/jbws626/ServerHandler.java Log: [JBWS-1900] Ported JBWS-1860 Memory leak fixes for JBossWS1.2.1 Modified: legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/CommonBindingProvider.java =================================================================== --- legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/CommonBindingProvider.java 2007-12-07 01:20:25 UTC (rev 5216) +++ legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/CommonBindingProvider.java 2007-12-07 01:46:02 UTC (rev 5217) @@ -55,6 +55,7 @@ { this.epMetaData = epMetaData; initBinding(epMetaData.getBindingId(), epMetaData.getType()); + this.epMetaData.registerConfigObserver(this); configure(); } Modified: legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/jaxws/spi/ProviderImpl.java =================================================================== --- legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/jaxws/spi/ProviderImpl.java 2007-12-07 01:20:25 UTC (rev 5216) +++ legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/jaxws/spi/ProviderImpl.java 2007-12-07 01:46:02 UTC (rev 5217) @@ -38,6 +38,7 @@ import javax.xml.ws.wsaddressing.W3CEndpointReference; import org.jboss.util.NotImplementedException; +import org.jboss.ws.core.utils.DOMUtils; import org.w3c.dom.Element; /** @@ -59,6 +60,7 @@ public ServiceDelegate createServiceDelegate(URL wsdlLocation, QName serviceName, Class serviceClass) { ServiceDelegateImpl delegate = new ServiceDelegateImpl(wsdlLocation, serviceName, serviceClass); + DOMUtils.clearThreadLocals(); return delegate; } Modified: legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/server/ServiceEndpointManager.java =================================================================== --- legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/server/ServiceEndpointManager.java 2007-12-07 01:20:25 UTC (rev 5216) +++ legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/server/ServiceEndpointManager.java 2007-12-07 01:46:02 UTC (rev 5217) @@ -67,6 +67,7 @@ import org.jboss.ws.core.soap.MessageContextAssociation; import org.jboss.ws.core.soap.SOAPConnectionImpl; import org.jboss.ws.core.utils.ThreadLocalAssociation; +import org.jboss.ws.core.utils.DOMUtils; import org.jboss.ws.extensions.addressing.AddressingConstantsImpl; import org.jboss.ws.metadata.umdm.EndpointMetaData; import org.jboss.ws.metadata.umdm.HandlerMetaData; @@ -490,6 +491,8 @@ // clear thread local storage ThreadLocalAssociation.clear(); + + DOMUtils.clearThreadLocals(); } } Modified: legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/utils/DOMUtils.java =================================================================== --- legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/utils/DOMUtils.java 2007-12-07 01:20:25 UTC (rev 5216) +++ legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/utils/DOMUtils.java 2007-12-07 01:46:02 UTC (rev 5217) @@ -95,6 +95,12 @@ { } + public static void clearThreadLocals() + { + documentThreadLocal.remove(); + builderThreadLocal.remove(); + } + /** Initialise the the DocumentBuilder */ public static DocumentBuilder getDocumentBuilder() Modified: legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/utils/ThreadLocalAssociation.java =================================================================== --- legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/utils/ThreadLocalAssociation.java 2007-12-07 01:20:25 UTC (rev 5216) +++ legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/core/utils/ThreadLocalAssociation.java 2007-12-07 01:46:02 UTC (rev 5217) @@ -71,8 +71,8 @@ public static void clear() { - invokerMDBAssoc.set(null); - msgContextAssoc.set(null); - strTransformAssoc.set(null); + invokerMDBAssoc.remove(); + msgContextAssoc.remove(); + strTransformAssoc.remove(); } } Modified: legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/metadata/umdm/EndpointMetaData.java =================================================================== --- legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/metadata/umdm/EndpointMetaData.java 2007-12-07 01:20:25 UTC (rev 5216) +++ legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-core/src/java/org/jboss/ws/metadata/umdm/EndpointMetaData.java 2007-12-07 01:46:02 UTC (rev 5217) @@ -52,6 +52,8 @@ import java.lang.reflect.Method; import java.util.*; +import java.lang.ref.WeakReference; + /** * A Service component describes a set of endpoints. * @@ -604,9 +606,6 @@ if (config == null) initEndpointConfig(); - // register any configurable with the ConfigProvider - configObservable.addObserver(configurable); - // SOAPBinding configuration if (configurable instanceof CommonBindingProvider) { @@ -715,11 +714,51 @@ class ConfigObservable extends Observable { + + private List<WeakReference<Observer>> observer = new ArrayList<WeakReference<Observer>>(); + public void doNotify(Object object) { setChanged(); notifyObservers(object); } + + public synchronized void addObserver(Observer o) + { + observer.add( new WeakReference(o)); + } + + public synchronized void deleteObserver(Observer o) + { + for(WeakReference<Observer> w : observer) + { + Observer tmp = w.get(); + if(tmp.equals(o)) + { + observer.remove(o); + break; + } + + } + } + + public void notifyObservers() + { + notifyObservers(null); + } + + public void notifyObservers(Object arg) + { + if(hasChanged()) + { + for(WeakReference<Observer> w : observer) + { + Observer tmp = w.get(); + tmp.update(this, arg); + + } + } + } } public List<UnifiedPortComponentRefMetaData> getServiceRefContrib() Modified: legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-tests/src/java/org/jboss/test/ws/jaxrpc/jbws626/ServerHandler.java =================================================================== --- legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-tests/src/java/org/jboss/test/ws/jaxrpc/jbws626/ServerHandler.java 2007-12-07 01:20:25 UTC (rev 5216) +++ legacy/branches/jbossws-1.2.1.GA_JBWS-1900/jbossws-tests/src/java/org/jboss/test/ws/jaxrpc/jbws626/ServerHandler.java 2007-12-07 01:46:02 UTC (rev 5217) @@ -21,6 +21,8 @@ */ package org.jboss.test.ws.jaxrpc.jbws626; +import org.jboss.ws.core.CommonMessageContext; + import java.util.Iterator; import javax.xml.namespace.QName; @@ -83,6 +85,10 @@ wasName = soapElement.getElementName(); assertElementName(expName, wasName); } + + // for testing the CommonBindingProvider memory leak. Not related to this test... + ((CommonMessageContext)msgContext).setModified(true); + } catch (SOAPException ex) {