[jboss-cvs] JBossAS SVN: r59920 - in branches/JBoss_3_2_7_CP/testsuite/src: resources/testbeancluster and 1 other directory.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Mon Jan 22 12:52:14 EST 2007
Author: jaroslaw.kijanowski
Date: 2007-01-22 12:52:13 -0500 (Mon, 22 Jan 2007)
New Revision: 59920
Added:
branches/JBoss_3_2_7_CP/testsuite/src/main/org/jboss/test/testbeancluster/test/PooledHAUnitTestCase.java
branches/JBoss_3_2_7_CP/testsuite/src/resources/testbeancluster/pooledha-ejb-jar.xml
branches/JBoss_3_2_7_CP/testsuite/src/resources/testbeancluster/pooledha-jboss.xml
Log:
porting missing test for JBAS-3166 fix
Added: branches/JBoss_3_2_7_CP/testsuite/src/main/org/jboss/test/testbeancluster/test/PooledHAUnitTestCase.java
===================================================================
--- branches/JBoss_3_2_7_CP/testsuite/src/main/org/jboss/test/testbeancluster/test/PooledHAUnitTestCase.java (rev 0)
+++ branches/JBoss_3_2_7_CP/testsuite/src/main/org/jboss/test/testbeancluster/test/PooledHAUnitTestCase.java 2007-01-22 17:52:13 UTC (rev 59920)
@@ -0,0 +1,273 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2006, 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.testbeancluster.test;
+
+import java.util.Date;
+import java.util.Properties;
+import java.io.ObjectOutputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.ByteArrayInputStream;
+import java.io.ObjectInputStream;
+
+import javax.naming.Context;
+import javax.naming.InitialContext;
+
+import org.jboss.test.JBossClusteredTestCase;
+import org.jboss.test.testbean.interfaces.StatefulSessionHome;
+import org.jboss.test.testbeancluster.interfaces.StatelessSessionHome;
+import org.jboss.test.testbeancluster.interfaces.StatelessSession;
+import org.jboss.test.testbeancluster.interfaces.StatefulSession;
+import org.jboss.test.testbeancluster.interfaces.NodeAnswer;
+import org.jboss.invocation.pooled.interfaces.PooledInvokerProxy;
+import org.jboss.invocation.pooled.interfaces.ServerAddress;
+import junit.framework.Test;
+
+/**
+ * Tests of stateless/stateful HA behavior using the pooled invoker
+ *
+ * @author <a href="mailto:sacha.labourey at jboss.org">Sacha Labourey</a>.
+ * @author Scott.Stark at jboss.org
+ * @version $Revision$
+ */
+public class PooledHAUnitTestCase extends JBossClusteredTestCase
+{
+ static boolean deployed = false;
+ static Date startDate = new Date();
+
+ protected final String namingFactory =
+ System.getProperty(Context.INITIAL_CONTEXT_FACTORY);
+
+ protected final String providerURL =
+ System.getProperty(Context.PROVIDER_URL);
+
+ public PooledHAUnitTestCase (String name)
+ {
+ super(name);
+ }
+
+ public static Test suite() throws Exception
+ {
+ Test t1 = JBossClusteredTestCase.getDeploySetup(PooledHAUnitTestCase.class, "pooledha.jar");
+ return t1;
+ }
+
+ /**
+ * Test the equals/hashCode behavior for ServerAddress
+ * @throws Exception
+ */
+ public void testServerAddressHashEquals()
+ throws Exception
+ {
+ ServerAddress sa1 = new ServerAddress("127.0.0.1", 4445, false, 60, null);
+ ServerAddress sa2 = new ServerAddress("127.0.0.1", 4445, false, 61, null);
+ assertEquals(sa1, sa2);
+ assertEquals(sa1.hashCode(), sa2.hashCode());
+
+ ByteArrayOutputStream baos = new ByteArrayOutputStream();
+ ObjectOutputStream oos = new ObjectOutputStream(baos);
+ oos.writeObject(sa1);
+ ByteArrayInputStream bais = new ByteArrayInputStream(baos.toByteArray());
+ ObjectInputStream ois = new ObjectInputStream(bais);
+ sa2 = (ServerAddress) ois.readObject();
+ assertEquals(sa1, sa2);
+ assertEquals(sa1.hashCode(), sa2.hashCode());
+
+ // Different tcpNoDelay should not be equal
+ sa2 = new ServerAddress("127.0.0.1", 4445, true, 61, null);
+ assertNotSame(sa1, sa2);
+ // Different ports should not be equal
+ sa2 = new ServerAddress("127.0.0.1", 4446, false, 60, null);
+ assertNotSame(sa1, sa2);
+ // Different host should not be equal
+ sa2 = new ServerAddress("127.0.0.2", 4445, false, 60, null);
+ assertNotSame(sa1, sa2);
+ }
+
+ public void testStatelessBeanLoadBalancing()
+ throws Exception
+ {
+ log.debug("testStatelessBeanLoadBalancing - Trying the context...");
+
+ // Connect to the server0 JNDI
+ String[] urls = getNamingURLs();
+ Properties env1 = new Properties();
+ env1.setProperty(Context.INITIAL_CONTEXT_FACTORY,
+ "org.jnp.interfaces.NamingContextFactory");
+ env1.setProperty(Context.PROVIDER_URL, urls[0]);
+ InitialContext ctx = new InitialContext(env1);
+
+ log.debug("Looking up the home pooledha_StatelessSession..."+urls[0]);
+ StatelessSessionHome homeHA =
+ (StatelessSessionHome) ctx.lookup("pooledha_StatelessSession");
+ log.debug("Looking up the home pooled_StatelessSession..."+urls[0]);
+ StatelessSessionHome home =
+ (StatelessSessionHome) ctx.lookup("pooled_StatelessSession");
+
+ // Simple connection count stress test
+ PooledInvokerProxy.clearStats();
+ PooledInvokerProxy.clearPools();
+ for(int n = 0; n < 100; n ++)
+ {
+ StatelessSession tmp = homeHA.create();
+ StatelessSession tmp2 = home.create();
+ tmp.getCallCount();
+ tmp2.getCallCount();
+ tmp.getCallCount();
+ tmp2.getCallCount();
+ int totalCount = PooledInvokerProxy.getTotalPoolCount();
+ // N cluster nodes + 1 for unclustered
+ int expectedCount = urls.length + 1;
+ assertEquals("TotalPoolCount", expectedCount, totalCount);
+ long usedPooled = PooledInvokerProxy.getUsedPooled();
+ // iter * Ncalls - expectedCount (for the initial conn creation)
+ int expectedUsedPooled = (n+1) * 6 - expectedCount;
+ assertEquals("UsedPooled", expectedUsedPooled, usedPooled);
+ }
+ long inUseCount = PooledInvokerProxy.getInUseCount();
+ assertEquals("InUseCount", 0, inUseCount);
+
+ log.debug("Calling create on StatelessSessionHome...");
+ StatelessSession statelessSession = homeHA.create();
+ assertTrue("homeHA.create() != null", statelessSession != null);
+ log.debug("Calling getEJBHome() on StatelessSession...");
+ assertTrue("statelessSession.getEJBHome() != null", statelessSession.getEJBHome() != null);
+
+ log.debug("Reseting the number of calls made on beans (making 2 calls)... ");
+ for (int i=0; i<6; i++)
+ {
+ log.debug("Reseting number... ");
+ statelessSession.resetNumberOfCalls ();
+ }
+
+ log.debug("- "+"Now making 20 calls on this remote... ");
+ for (int i=0; i<20; i++)
+ {
+ log.debug("- "+" Calling remote... ");
+ statelessSession.makeCountedCall ();
+ }
+
+ log.debug("- "+"Getting the number of calls that have been performed on each bean... ");
+ long node1 = statelessSession.getCallCount();
+ log.debug("- "+"One node has received: " + node1);
+
+ long node2 = statelessSession.getCallCount();
+ log.debug("- "+"The other node has received: " + node2);
+
+ if (node1 == node2 && node1 == 10)
+ {
+ log.debug("- "+"Test is ok.");
+ }
+ else if( urls.length > 1 )
+ {
+ log.debug("- "+"Something wrong has happened! Calls seems not to have been load-balanced.");
+ fail ("call count mismatch: "+node1+" != "+node2);
+ }
+
+ statelessSession.remove();
+ log.debug("ok");
+ }
+
+ public void testStatefulBeanFailover()
+ throws Exception
+ {
+ log.debug("testStatelessBeanLoadBalancing - Trying the context...");
+
+ // Connect to the server0 JNDI
+ String[] urls = getNamingURLs();
+ Properties env1 = new Properties();
+ env1.setProperty(Context.INITIAL_CONTEXT_FACTORY,
+ "org.jnp.interfaces.NamingContextFactory");
+ env1.setProperty(Context.PROVIDER_URL, urls[0]);
+ InitialContext ctx = new InitialContext(env1);
+
+ log.debug("Looking up the home pooledha_StatefulSession..."+urls[0]);
+ StatefulSessionHome homeHA =
+ (StatefulSessionHome) ctx.lookup("pooledha_StatefulSession");
+ log.debug("Looking up the home pooled_StatelessSession..."+urls[0]);
+ StatelessSessionHome home =
+ (StatelessSessionHome) ctx.lookup("pooled_StatelessSession");
+
+ // Simple connection count stress test
+ PooledInvokerProxy.clearStats();
+ PooledInvokerProxy.clearPools();
+ for(int n = 0; n < 100; n ++)
+ {
+ StatefulSession tmp = (StatefulSession) homeHA.create();
+ tmp.remove();
+ tmp = (StatefulSession) homeHA.create();
+ StatelessSession tmp2 = home.create();
+ tmp.getNodeState();
+ tmp2.getCallCount();
+ tmp.getNodeState();
+ tmp2.getCallCount();
+ tmp.remove();
+ int totalCount = PooledInvokerProxy.getTotalPoolCount();
+ // N cluster nodes + 1 for unclustered
+ int expectedCount = urls.length + 1;
+ assertEquals("TotalPoolCount", expectedCount, totalCount);
+ long usedPooled = PooledInvokerProxy.getUsedPooled();
+ // iter * Ncalls - expectedCount (for the initial conn creation)
+ int expectedUsedPooled = (n+1) * 9 - expectedCount;
+ assertEquals("UsedPooled", expectedUsedPooled, usedPooled);
+ }
+ long inUseCount = PooledInvokerProxy.getInUseCount();
+ assertEquals("InUseCount", 0, inUseCount);
+
+ log.debug("Test Stateful Bean Failover");
+ log.debug("Looking up the home nextgen.StatefulSession...");
+ log.debug("Calling create on StatefulSessionHome...");
+ StatefulSession statefulSession =
+ (StatefulSession)homeHA.create("Bupple-Dupple");
+ assertTrue("statefulSessionHome.create() != null", statefulSession != null);
+
+ NodeAnswer node1 = statefulSession.getNodeState ();
+ getLog ().debug (node1);
+
+ // Now we switch to the other node, simulating a failure on node 1
+ System.setProperty ("JBossCluster-DoFail", "once");
+ NodeAnswer node2 = statefulSession.getNodeState ();
+ log.debug (node2);
+ assertEquals("Value is identical on replicated node1", "Bupple-Dupple", node1.answer);
+ assertEquals("Value is identical on replicated node2", "Bupple-Dupple", node2.answer);
+
+ // we change our name to see if it replicates to node 1
+ statefulSession.setName ("Changed");
+
+ // now we travel back on node 1
+ System.setProperty ("JBossCluster-DoFail", "once");
+ node1 = statefulSession.getNodeState ();
+ log.debug(node1);
+
+ assertEquals("Value is identical on replicated node1", "Changed", node1.answer);
+ node2 = statefulSession.getNodeState ();
+ log.debug(node2);
+ assertEquals("Value is identical on replicated node2", "Changed", node2.answer);
+
+ statefulSession.remove();
+
+ int totalCount = PooledInvokerProxy.getTotalPoolCount();
+ // N cluster nodes + 1 for unclustered
+ int expectedCount = urls.length + 1;
+ assertEquals("TotalPoolCount", expectedCount, totalCount);
+ }
+}
+
Added: branches/JBoss_3_2_7_CP/testsuite/src/resources/testbeancluster/pooledha-ejb-jar.xml
===================================================================
--- branches/JBoss_3_2_7_CP/testsuite/src/resources/testbeancluster/pooledha-ejb-jar.xml (rev 0)
+++ branches/JBoss_3_2_7_CP/testsuite/src/resources/testbeancluster/pooledha-ejb-jar.xml 2007-01-22 17:52:13 UTC (rev 59920)
@@ -0,0 +1,55 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE ejb-jar
+ PUBLIC "-//Sun Microsystems, Inc.//DTD Enterprise JavaBeans 2.0//EN"
+ "http://java.sun.com/dtd/ejb-jar_2_0.dtd">
+
+<ejb-jar>
+ <enterprise-beans>
+
+ <session>
+ <description>Stateless session bean</description>
+ <ejb-name>pooledha_StatelessSession</ejb-name>
+ <home>org.jboss.test.testbeancluster.interfaces.StatelessSessionHome</home>
+ <remote>org.jboss.test.testbeancluster.interfaces.StatelessSession</remote>
+ <ejb-class>org.jboss.test.testbeancluster.bean.StatelessSessionBean</ejb-class>
+ <session-type>Stateless</session-type>
+ <transaction-type>Container</transaction-type>
+ </session>
+ <session>
+ <description>Stateless session bean</description>
+ <ejb-name>pooled_StatelessSession</ejb-name>
+ <home>org.jboss.test.testbeancluster.interfaces.StatelessSessionHome</home>
+ <remote>org.jboss.test.testbeancluster.interfaces.StatelessSession</remote>
+ <ejb-class>org.jboss.test.testbeancluster.bean.StatelessSessionBean</ejb-class>
+ <session-type>Stateless</session-type>
+ <transaction-type>Container</transaction-type>
+ </session>
+
+ <session>
+ <description>Stateful session bean</description>
+ <ejb-name>pooledha_StatefulSession</ejb-name>
+ <home>org.jboss.test.testbean.interfaces.StatefulSessionHome</home>
+ <remote>org.jboss.test.testbeancluster.interfaces.StatefulSession</remote>
+ <ejb-class>org.jboss.test.testbeancluster.bean.StatefulSessionBean</ejb-class>
+ <session-type>Stateful</session-type>
+ <transaction-type>Container</transaction-type>
+ </session>
+ </enterprise-beans>
+
+ <assembly-descriptor>
+
+ <container-transaction>
+ <method>
+ <ejb-name>pooledha_StatelessSession</ejb-name>
+ <method-name>*</method-name>
+ </method>
+ <method>
+ <ejb-name>pooledha_StatefulSession</ejb-name>
+ <method-name>*</method-name>
+ </method>
+ <trans-attribute>Required</trans-attribute>
+ </container-transaction>
+
+ </assembly-descriptor>
+</ejb-jar>
+
Added: branches/JBoss_3_2_7_CP/testsuite/src/resources/testbeancluster/pooledha-jboss.xml
===================================================================
--- branches/JBoss_3_2_7_CP/testsuite/src/resources/testbeancluster/pooledha-jboss.xml (rev 0)
+++ branches/JBoss_3_2_7_CP/testsuite/src/resources/testbeancluster/pooledha-jboss.xml 2007-01-22 17:52:13 UTC (rev 59920)
@@ -0,0 +1,128 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE jboss PUBLIC
+ "-//JBoss//DTD JBOSS 4.0//EN"
+ "http://www.jboss.org/j2ee/dtd/jboss_4_0.dtd">
+
+<jboss>
+
+ <enterprise-beans>
+ <session>
+ <ejb-name>pooledha_StatelessSession</ejb-name>
+ <configuration-name>Pooled Stateless SessionBean</configuration-name>
+ <invoker-bindings>
+ <invoker>
+ <invoker-proxy-binding-name>pooledha-stateless-invoker</invoker-proxy-binding-name>
+ <jndi-name>pooledha_StatelessSession</jndi-name>
+ </invoker>
+ </invoker-bindings>
+ <clustered>true</clustered>
+ </session>
+ <session>
+ <ejb-name>pooled_StatelessSession</ejb-name>
+ <invoker-bindings>
+ <invoker>
+ <invoker-proxy-binding-name>stateless-pooled-invoker</invoker-proxy-binding-name>
+ <jndi-name>pooled_StatelessSession</jndi-name>
+ </invoker>
+ </invoker-bindings>
+ </session>
+ <session>
+ <ejb-name>pooledha_StatefulSession</ejb-name>
+ <configuration-name>Pooled Stateful SessionBean</configuration-name>
+ <invoker-bindings>
+ <invoker>
+ <invoker-proxy-binding-name>pooledha-stateful-invoker</invoker-proxy-binding-name>
+ <jndi-name>pooledha_StatefulSession</jndi-name>
+ </invoker>
+ </invoker-bindings>
+ <clustered>true</clustered>
+ </session>
+
+ </enterprise-beans>
+
+ <invoker-proxy-bindings>
+ <!-- Override default clustered invoker bindings -->
+ <invoker-proxy-binding>
+ <name>pooledha-stateless-invoker</name>
+ <invoker-mbean>jboss:service=invoker,type=pooledha</invoker-mbean>
+ <proxy-factory>org.jboss.proxy.ejb.ProxyFactoryHA</proxy-factory>
+ <proxy-factory-config>
+ <client-interceptors exposeContainer="true">
+ <home>
+ <interceptor>org.jboss.ha.framework.test.ExplicitFailoverClientInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.ejb.HomeInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.SecurityInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.TransactionInterceptor</interceptor>
+ <interceptor>org.jboss.invocation.InvokerInterceptor</interceptor>
+ </home>
+ <bean>
+ <interceptor>org.jboss.ha.framework.test.ExplicitFailoverClientInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.ejb.StatelessSessionInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.SecurityInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.TransactionInterceptor</interceptor>
+ <interceptor>org.jboss.invocation.InvokerInterceptor</interceptor>
+ </bean>
+ </client-interceptors>
+ </proxy-factory-config>
+ </invoker-proxy-binding>
+
+ <invoker-proxy-binding>
+ <name>pooledha-stateful-invoker</name>
+ <invoker-mbean>jboss:service=invoker,type=pooledha</invoker-mbean>
+ <proxy-factory>org.jboss.proxy.ejb.ProxyFactoryHA</proxy-factory>
+ <proxy-factory-config>
+ <client-interceptors exposeContainer="true">
+ <home>
+ <interceptor>org.jboss.ha.framework.test.ExplicitFailoverClientInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.ejb.HomeInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.SecurityInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.TransactionInterceptor</interceptor>
+ <interceptor>org.jboss.invocation.InvokerInterceptor</interceptor>
+ </home>
+ <bean>
+ <interceptor>org.jboss.ha.framework.test.ExplicitFailoverClientInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.ejb.StatefulSessionInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.SecurityInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.TransactionInterceptor</interceptor>
+ <interceptor>org.jboss.invocation.InvokerInterceptor</interceptor>
+ </bean>
+ </client-interceptors>
+ </proxy-factory-config>
+ </invoker-proxy-binding>
+
+ <invoker-proxy-binding>
+ <name>stateless-pooled-invoker</name>
+ <invoker-mbean>jboss:service=invoker,type=pooled</invoker-mbean>
+ <proxy-factory>org.jboss.proxy.ejb.ProxyFactory</proxy-factory>
+ <proxy-factory-config>
+ <client-interceptors>
+ <home>
+ <interceptor>org.jboss.proxy.ejb.HomeInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.SecurityInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.TransactionInterceptor</interceptor>
+ <interceptor>org.jboss.invocation.InvokerInterceptor</interceptor>
+ </home>
+ <bean>
+ <interceptor>org.jboss.proxy.ejb.StatelessSessionInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.SecurityInterceptor</interceptor>
+ <interceptor>org.jboss.proxy.TransactionInterceptor</interceptor>
+ <interceptor>org.jboss.invocation.InvokerInterceptor</interceptor>
+ </bean>
+ </client-interceptors>
+ </proxy-factory-config>
+ </invoker-proxy-binding>
+
+ </invoker-proxy-bindings>
+
+ <container-configurations>
+ <container-configuration extends="Clustered Stateless SessionBean">
+ <container-name>Pooled Stateless SessionBean</container-name>
+ <invoker-proxy-binding-name>pooledha-stateless-invoker</invoker-proxy-binding-name>
+ </container-configuration>
+ <container-configuration extends="Clustered Stateful SessionBean">
+ <container-name>Pooled Stateful SessionBean</container-name>
+ <invoker-proxy-binding-name>pooledha-stateful-invoker</invoker-proxy-binding-name>
+ </container-configuration>
+ </container-configurations>
+</jboss>
+
More information about the jboss-cvs-commits
mailing list