[jbossws-commits] JBossWS SVN: r16208 - in common/branches/jbossws-common-2.0.x/src: test/java/org/jboss/test/ws/common and 1 other directories.
jbossws-commits at lists.jboss.org
jbossws-commits at lists.jboss.org
Tue Apr 24 03:25:51 EDT 2012
Author: alessio.soldano at jboss.com
Date: 2012-04-24 03:25:50 -0400 (Tue, 24 Apr 2012)
New Revision: 16208
Added:
common/branches/jbossws-common-2.0.x/src/test/java/org/jboss/test/ws/common/management/
common/branches/jbossws-common-2.0.x/src/test/java/org/jboss/test/ws/common/management/DefaultEndpointRegistryTestCase.java
Removed:
common/branches/jbossws-common-2.0.x/src/test/java/org/jboss/test/ws/common/management/DefaultEndpointRegistryTestCase.java
Modified:
common/branches/jbossws-common-2.0.x/src/main/java/org/jboss/ws/common/management/DefaultEndpointRegistry.java
Log:
[JBPAPP-8811] ConcurrentModificationException when accessing to EndopointRegistry
Modified: common/branches/jbossws-common-2.0.x/src/main/java/org/jboss/ws/common/management/DefaultEndpointRegistry.java
===================================================================
--- common/branches/jbossws-common-2.0.x/src/main/java/org/jboss/ws/common/management/DefaultEndpointRegistry.java 2012-04-24 06:52:26 UTC (rev 16207)
+++ common/branches/jbossws-common-2.0.x/src/main/java/org/jboss/ws/common/management/DefaultEndpointRegistry.java 2012-04-24 07:25:50 UTC (rev 16208)
@@ -1,6 +1,6 @@
/*
* JBoss, Home of Professional Open Source.
- * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * Copyright 2012, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
@@ -21,10 +21,10 @@
*/
package org.jboss.ws.common.management;
-import java.util.HashMap;
import java.util.Map;
import java.util.ResourceBundle;
import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
import javax.management.ObjectName;
@@ -38,6 +38,8 @@
* A general endpoint registry.
*
* @author Thomas.Diesler at jboss.com
+ * @author alessio.soldano at jboss.com
+ *
* @since 20-Apr-2007
*/
public class DefaultEndpointRegistry implements EndpointRegistry
@@ -46,7 +48,7 @@
// provide logging
private static final Logger log = Logger.getLogger(DefaultEndpointRegistry.class);
- private Map<ObjectName, Endpoint> endpoints = new HashMap<ObjectName, Endpoint>();
+ private Map<ObjectName, Endpoint> endpoints = new ConcurrentHashMap<ObjectName, Endpoint>();
public Endpoint getEndpoint(ObjectName epName)
{
Deleted: common/branches/jbossws-common-2.0.x/src/test/java/org/jboss/test/ws/common/management/DefaultEndpointRegistryTestCase.java
===================================================================
--- common/trunk/src/test/java/org/jboss/test/ws/common/management/DefaultEndpointRegistryTestCase.java 2012-04-24 06:52:26 UTC (rev 16207)
+++ common/branches/jbossws-common-2.0.x/src/test/java/org/jboss/test/ws/common/management/DefaultEndpointRegistryTestCase.java 2012-04-24 07:25:50 UTC (rev 16208)
@@ -1,408 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source.
- * Copyright 2012, Red Hat Middleware LLC, and individual contributors
- * as indicated by the @author tags. See the copyright.txt file in the
- * distribution for a full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software 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 software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-package org.jboss.test.ws.common.management;
-
-import java.util.Collection;
-import java.util.Iterator;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.Callable;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
-import java.util.concurrent.TimeUnit;
-
-import javax.management.ObjectName;
-
-import org.jboss.ws.api.monitoring.Record;
-import org.jboss.ws.api.monitoring.RecordProcessor;
-import org.jboss.ws.common.management.DefaultEndpointRegistry;
-import org.jboss.wsf.spi.deployment.Endpoint;
-import org.jboss.wsf.spi.deployment.EndpointState;
-import org.jboss.wsf.spi.deployment.EndpointType;
-import org.jboss.wsf.spi.deployment.InstanceProvider;
-import org.jboss.wsf.spi.deployment.LifecycleHandler;
-import org.jboss.wsf.spi.deployment.Service;
-import org.jboss.wsf.spi.invocation.InvocationHandler;
-import org.jboss.wsf.spi.invocation.RequestHandler;
-import org.jboss.wsf.spi.management.EndpointMetrics;
-import org.jboss.wsf.spi.management.EndpointRegistry;
-import org.jboss.wsf.spi.security.SecurityDomainContext;
-
-import junit.framework.TestCase;
-
-/**
- * Test the DefaultEndpointRegistry
- *
- * @author alessio.soldano at jboss.com
- * @since 23-Apr-2012
- */
-public class DefaultEndpointRegistryTestCase extends TestCase
-{
- public void testSingleThreadAccess() throws Exception {
- final int MAX = 10;
- DefaultEndpointRegistry reg = new DefaultEndpointRegistry();
- for (int i = 0; i < MAX; i++) {
- Endpoint ep = getTestEndpoint("Foo" + i, "prop", "v" + i);
- reg.register(ep);
- }
-
- Iterator<ObjectName> it = reg.getEndpoints().iterator();
- checkContents(it, MAX);
-
- reg.register(getTestEndpoint("Foo" + MAX, "prop", "v" + MAX));
-
- assertFalse(it.hasNext());
- checkContents(reg.getEndpoints().iterator(), MAX + 1);
- }
-
- public void testConcurrentAccess() throws Exception {
- DefaultEndpointRegistry reg = new DefaultEndpointRegistry();
- reg.register(getTestEndpoint("Test", "prop", "my-value"));
- ExecutorService es = Executors.newFixedThreadPool(2);
- List<Callable<Boolean>> callables = new LinkedList<Callable<Boolean>>();
- final int size = 10;
- for (int i = 1; i <= 10; i++) {
- callables.add(new Register(reg, "Foo", i * size, size));
- }
- callables.add(new Reader(reg, "my-value"));
- for (int i = 11; i <= 20; i++) {
- callables.add(new Register(reg, "Foo", i * size, size));
- }
- callables.add(new Reader(reg, "my-value"));
-
- List<Future<Boolean>> results = es.invokeAll(callables);
- for (Future<Boolean> f : results) {
- assertTrue(f.get(10, TimeUnit.SECONDS));
- }
- es.shutdown();
- }
-
- private class Register implements Callable<Boolean> {
- private final EndpointRegistry reg;
- private final String name;
- private final int base;
- private final int n;
-
- public Register(EndpointRegistry reg, String name, int base, int n) {
- this.reg = reg;
- this.name = name;
- this.base = base;
- this.n = n;
- }
-
- @Override
- public Boolean call() throws Exception
- {
- for (int i = base; i < (base + n); i++) {
- try {
- Endpoint ep = getTestEndpoint(name + i, "prop", "v" + i);
- reg.register(ep);
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- }
- return true;
- }
- }
-
- private class Reader implements Callable<Boolean> {
- private final EndpointRegistry reg;
- private final String value;
-
- public Reader(EndpointRegistry reg, String value) {
- this.reg = reg;
- this.value = value;
- }
-
- @Override
- public Boolean call() throws Exception
- {
- boolean result = false;
- //below is what org.jboss.wsf.stack.cxf.transport.ServletHelper does for instance
- for (ObjectName on : reg.getEndpoints()) {
- if (on.getKeyProperty("prop").equalsIgnoreCase(value)) {
- result = true; //do not early exit
- }
- }
- return result;
- }
-
- }
-
- private static void checkContents(Iterator<ObjectName> it, int n) {
- List<String> values = new LinkedList<String>();
- for (int i = 0; i < n; i++) {
- values.add("v" + i);
- }
- while (it.hasNext()) {
- String p = it.next().getKeyProperty("prop");
- if (values.contains(p)) {
- values.remove(p);
- }
- }
- assertTrue("Could not find " + values, values.isEmpty());
- }
-
- private static Endpoint getTestEndpoint(String name, String prop, String value) throws Exception {
- final ObjectName objName = new ObjectName(name, prop, value);
- return new Endpoint()
- {
-
- @Override
- public void setProperty(String key, Object value)
- {
-
- }
-
- @Override
- public void setProperties(Map<String, Object> props)
- {
-
- }
-
- @Override
- public void removeProperty(String key)
- {
-
- }
-
- @Override
- public <T> T removeAttachment(Class<T> key)
- {
- return null;
- }
-
- @Override
- public Object getProperty(String key)
- {
- return null;
- }
-
- @Override
- public Set<String> getProperties()
- {
- return null;
- }
-
- @Override
- public <T> Collection<T> getAttachments()
- {
- return null;
- }
-
- @Override
- public <T> T getAttachment(Class<T> key)
- {
- return null;
- }
-
- @Override
- public <T> T addAttachment(Class<T> key, Object value)
- {
- return null;
- }
-
- @Override
- public void setType(EndpointType type)
- {
-
- }
-
- @Override
- public void setTargetBeanName(String epImpl)
- {
-
- }
-
- @Override
- public void setState(EndpointState state)
- {
-
- }
-
- @Override
- public void setShortName(String shortName)
- {
-
- }
-
- @Override
- public void setService(Service service)
- {
-
- }
-
- @Override
- public void setSecurityDomainContext(SecurityDomainContext context)
- {
-
- }
-
- @Override
- public void setRequestHandler(RequestHandler handler)
- {
-
- }
-
- @Override
- public void setRecordProcessors(List<RecordProcessor> recordProcessors)
- {
-
- }
-
- @Override
- public void setName(ObjectName epName)
- {
-
- }
-
- @Override
- public void setLifecycleHandler(LifecycleHandler handler)
- {
-
- }
-
- @Override
- public void setInvocationHandler(InvocationHandler invoker)
- {
-
- }
-
- @Override
- public void setInstanceProvider(InstanceProvider provider)
- {
-
- }
-
- @Override
- public void setEndpointMetrics(EndpointMetrics metrics)
- {
-
- }
-
- @Override
- public void setAddress(String address)
- {
-
- }
-
- @Override
- public void processRecord(Record record)
- {
-
- }
-
- @Override
- public EndpointType getType()
- {
- return null;
- }
-
- @Override
- public String getTargetBeanName()
- {
- return null;
- }
-
- @Override
- public Class getTargetBeanClass()
- {
- return null;
- }
-
- @Override
- public EndpointState getState()
- {
- return null;
- }
-
- @Override
- public String getShortName()
- {
- return null;
- }
-
- @Override
- public Service getService()
- {
- return null;
- }
-
- @Override
- public SecurityDomainContext getSecurityDomainContext()
- {
- return null;
- }
-
- @Override
- public RequestHandler getRequestHandler()
- {
- return null;
- }
-
- @Override
- public List<RecordProcessor> getRecordProcessors()
- {
- return null;
- }
-
- @Override
- public ObjectName getName()
- {
- return objName;
- }
-
- @Override
- public LifecycleHandler getLifecycleHandler()
- {
- return null;
- }
-
- @Override
- public InvocationHandler getInvocationHandler()
- {
- return null;
- }
-
- @Override
- public InstanceProvider getInstanceProvider()
- {
- return null;
- }
-
- @Override
- public EndpointMetrics getEndpointMetrics()
- {
- return null;
- }
-
- @Override
- public String getAddress()
- {
- return null;
- }
- };
- }
-}
Copied: common/branches/jbossws-common-2.0.x/src/test/java/org/jboss/test/ws/common/management/DefaultEndpointRegistryTestCase.java (from rev 16207, common/trunk/src/test/java/org/jboss/test/ws/common/management/DefaultEndpointRegistryTestCase.java)
===================================================================
--- common/branches/jbossws-common-2.0.x/src/test/java/org/jboss/test/ws/common/management/DefaultEndpointRegistryTestCase.java (rev 0)
+++ common/branches/jbossws-common-2.0.x/src/test/java/org/jboss/test/ws/common/management/DefaultEndpointRegistryTestCase.java 2012-04-24 07:25:50 UTC (rev 16208)
@@ -0,0 +1,408 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2012, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software 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 software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.test.ws.common.management;
+
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+
+import javax.management.ObjectName;
+
+import org.jboss.ws.api.monitoring.Record;
+import org.jboss.ws.api.monitoring.RecordProcessor;
+import org.jboss.ws.common.management.DefaultEndpointRegistry;
+import org.jboss.wsf.spi.deployment.Endpoint;
+import org.jboss.wsf.spi.deployment.EndpointState;
+import org.jboss.wsf.spi.deployment.EndpointType;
+import org.jboss.wsf.spi.deployment.InstanceProvider;
+import org.jboss.wsf.spi.deployment.LifecycleHandler;
+import org.jboss.wsf.spi.deployment.Service;
+import org.jboss.wsf.spi.invocation.InvocationHandler;
+import org.jboss.wsf.spi.invocation.RequestHandler;
+import org.jboss.wsf.spi.management.EndpointMetrics;
+import org.jboss.wsf.spi.management.EndpointRegistry;
+import org.jboss.wsf.spi.security.SecurityDomainContext;
+
+import junit.framework.TestCase;
+
+/**
+ * Test the DefaultEndpointRegistry
+ *
+ * @author alessio.soldano at jboss.com
+ * @since 23-Apr-2012
+ */
+public class DefaultEndpointRegistryTestCase extends TestCase
+{
+ public void testSingleThreadAccess() throws Exception {
+ final int MAX = 10;
+ DefaultEndpointRegistry reg = new DefaultEndpointRegistry();
+ for (int i = 0; i < MAX; i++) {
+ Endpoint ep = getTestEndpoint("Foo" + i, "prop", "v" + i);
+ reg.register(ep);
+ }
+
+ Iterator<ObjectName> it = reg.getEndpoints().iterator();
+ checkContents(it, MAX);
+
+ reg.register(getTestEndpoint("Foo" + MAX, "prop", "v" + MAX));
+
+ assertFalse(it.hasNext());
+ checkContents(reg.getEndpoints().iterator(), MAX + 1);
+ }
+
+ public void testConcurrentAccess() throws Exception {
+ DefaultEndpointRegistry reg = new DefaultEndpointRegistry();
+ reg.register(getTestEndpoint("Test", "prop", "my-value"));
+ ExecutorService es = Executors.newFixedThreadPool(2);
+ List<Callable<Boolean>> callables = new LinkedList<Callable<Boolean>>();
+ final int size = 10;
+ for (int i = 1; i <= 10; i++) {
+ callables.add(new Register(reg, "Foo", i * size, size));
+ }
+ callables.add(new Reader(reg, "my-value"));
+ for (int i = 11; i <= 20; i++) {
+ callables.add(new Register(reg, "Foo", i * size, size));
+ }
+ callables.add(new Reader(reg, "my-value"));
+
+ List<Future<Boolean>> results = es.invokeAll(callables);
+ for (Future<Boolean> f : results) {
+ assertTrue(f.get(10, TimeUnit.SECONDS));
+ }
+ es.shutdown();
+ }
+
+ private class Register implements Callable<Boolean> {
+ private final EndpointRegistry reg;
+ private final String name;
+ private final int base;
+ private final int n;
+
+ public Register(EndpointRegistry reg, String name, int base, int n) {
+ this.reg = reg;
+ this.name = name;
+ this.base = base;
+ this.n = n;
+ }
+
+ @Override
+ public Boolean call() throws Exception
+ {
+ for (int i = base; i < (base + n); i++) {
+ try {
+ Endpoint ep = getTestEndpoint(name + i, "prop", "v" + i);
+ reg.register(ep);
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ }
+ return true;
+ }
+ }
+
+ private class Reader implements Callable<Boolean> {
+ private final EndpointRegistry reg;
+ private final String value;
+
+ public Reader(EndpointRegistry reg, String value) {
+ this.reg = reg;
+ this.value = value;
+ }
+
+ @Override
+ public Boolean call() throws Exception
+ {
+ boolean result = false;
+ //below is what org.jboss.wsf.stack.cxf.transport.ServletHelper does for instance
+ for (ObjectName on : reg.getEndpoints()) {
+ if (on.getKeyProperty("prop").equalsIgnoreCase(value)) {
+ result = true; //do not early exit
+ }
+ }
+ return result;
+ }
+
+ }
+
+ private static void checkContents(Iterator<ObjectName> it, int n) {
+ List<String> values = new LinkedList<String>();
+ for (int i = 0; i < n; i++) {
+ values.add("v" + i);
+ }
+ while (it.hasNext()) {
+ String p = it.next().getKeyProperty("prop");
+ if (values.contains(p)) {
+ values.remove(p);
+ }
+ }
+ assertTrue("Could not find " + values, values.isEmpty());
+ }
+
+ private static Endpoint getTestEndpoint(String name, String prop, String value) throws Exception {
+ final ObjectName objName = new ObjectName(name, prop, value);
+ return new Endpoint()
+ {
+
+ @Override
+ public void setProperty(String key, Object value)
+ {
+
+ }
+
+ @Override
+ public void setProperties(Map<String, Object> props)
+ {
+
+ }
+
+ @Override
+ public void removeProperty(String key)
+ {
+
+ }
+
+ @Override
+ public <T> T removeAttachment(Class<T> key)
+ {
+ return null;
+ }
+
+ @Override
+ public Object getProperty(String key)
+ {
+ return null;
+ }
+
+ @Override
+ public Set<String> getProperties()
+ {
+ return null;
+ }
+
+ @Override
+ public <T> Collection<T> getAttachments()
+ {
+ return null;
+ }
+
+ @Override
+ public <T> T getAttachment(Class<T> key)
+ {
+ return null;
+ }
+
+ @Override
+ public <T> T addAttachment(Class<T> key, Object value)
+ {
+ return null;
+ }
+
+ @Override
+ public void setType(EndpointType type)
+ {
+
+ }
+
+ @Override
+ public void setTargetBeanName(String epImpl)
+ {
+
+ }
+
+ @Override
+ public void setState(EndpointState state)
+ {
+
+ }
+
+ @Override
+ public void setShortName(String shortName)
+ {
+
+ }
+
+ @Override
+ public void setService(Service service)
+ {
+
+ }
+
+ @Override
+ public void setSecurityDomainContext(SecurityDomainContext context)
+ {
+
+ }
+
+ @Override
+ public void setRequestHandler(RequestHandler handler)
+ {
+
+ }
+
+ @Override
+ public void setRecordProcessors(List<RecordProcessor> recordProcessors)
+ {
+
+ }
+
+ @Override
+ public void setName(ObjectName epName)
+ {
+
+ }
+
+ @Override
+ public void setLifecycleHandler(LifecycleHandler handler)
+ {
+
+ }
+
+ @Override
+ public void setInvocationHandler(InvocationHandler invoker)
+ {
+
+ }
+
+ @Override
+ public void setInstanceProvider(InstanceProvider provider)
+ {
+
+ }
+
+ @Override
+ public void setEndpointMetrics(EndpointMetrics metrics)
+ {
+
+ }
+
+ @Override
+ public void setAddress(String address)
+ {
+
+ }
+
+ @Override
+ public void processRecord(Record record)
+ {
+
+ }
+
+ @Override
+ public EndpointType getType()
+ {
+ return null;
+ }
+
+ @Override
+ public String getTargetBeanName()
+ {
+ return null;
+ }
+
+ @Override
+ public Class getTargetBeanClass()
+ {
+ return null;
+ }
+
+ @Override
+ public EndpointState getState()
+ {
+ return null;
+ }
+
+ @Override
+ public String getShortName()
+ {
+ return null;
+ }
+
+ @Override
+ public Service getService()
+ {
+ return null;
+ }
+
+ @Override
+ public SecurityDomainContext getSecurityDomainContext()
+ {
+ return null;
+ }
+
+ @Override
+ public RequestHandler getRequestHandler()
+ {
+ return null;
+ }
+
+ @Override
+ public List<RecordProcessor> getRecordProcessors()
+ {
+ return null;
+ }
+
+ @Override
+ public ObjectName getName()
+ {
+ return objName;
+ }
+
+ @Override
+ public LifecycleHandler getLifecycleHandler()
+ {
+ return null;
+ }
+
+ @Override
+ public InvocationHandler getInvocationHandler()
+ {
+ return null;
+ }
+
+ @Override
+ public InstanceProvider getInstanceProvider()
+ {
+ return null;
+ }
+
+ @Override
+ public EndpointMetrics getEndpointMetrics()
+ {
+ return null;
+ }
+
+ @Override
+ public String getAddress()
+ {
+ return null;
+ }
+ };
+ }
+}
More information about the jbossws-commits
mailing list