[jboss-cvs] JBossAS SVN: r95440 - branches/Branch_5_x/testsuite/src/main/org/jboss/test/cluster/defaultcfg/simpleweb/test.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu Oct 22 15:46:32 EDT 2009
Author: bstansberry at jboss.com
Date: 2009-10-22 15:46:31 -0400 (Thu, 22 Oct 2009)
New Revision: 95440
Added:
branches/Branch_5_x/testsuite/src/main/org/jboss/test/cluster/defaultcfg/simpleweb/test/MultipleWarSingleRedeployTestCase.java
Log:
[JBAS-7205] Add a test case
Copied: branches/Branch_5_x/testsuite/src/main/org/jboss/test/cluster/defaultcfg/simpleweb/test/MultipleWarSingleRedeployTestCase.java (from rev 95056, trunk/testsuite/src/main/org/jboss/test/cluster/defaultcfg/simpleweb/test/MultipleWarSingleRedeployTestCase.java)
===================================================================
--- branches/Branch_5_x/testsuite/src/main/org/jboss/test/cluster/defaultcfg/simpleweb/test/MultipleWarSingleRedeployTestCase.java (rev 0)
+++ branches/Branch_5_x/testsuite/src/main/org/jboss/test/cluster/defaultcfg/simpleweb/test/MultipleWarSingleRedeployTestCase.java 2009-10-22 19:46:31 UTC (rev 95440)
@@ -0,0 +1,222 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2008, 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.cluster.defaultcfg.simpleweb.test;
+
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.Set;
+
+import junit.framework.Test;
+
+import org.jboss.cache.pojo.PojoCache;
+import org.jboss.logging.Logger;
+import org.jboss.metadata.web.jboss.JBossWebMetaData;
+import org.jboss.metadata.web.jboss.ReplicationGranularity;
+import org.jboss.metadata.web.jboss.ReplicationTrigger;
+import org.jboss.test.JBossTestCase;
+import org.jboss.test.cluster.testutil.CacheConfigTestSetup;
+import org.jboss.test.cluster.testutil.SessionTestUtil;
+import org.jboss.test.cluster.web.mocks.BasicRequestHandler;
+import org.jboss.test.cluster.web.mocks.SetAttributesRequestHandler;
+import org.jboss.web.tomcat.service.session.JBossCacheManager;
+
+/**
+ * Tests for JBAS-7205. Deploy two wars on each node, sharing a cache between
+ * them. Confirm that redeploying one war results in state being received.
+ *
+ * @author Brian Stansberry
+ */
+public class MultipleWarSingleRedeployTestCase extends JBossTestCase
+{
+ protected static PojoCache[] pojoCaches = new PojoCache[2];
+
+ protected static long testId = System.currentTimeMillis();
+
+ protected static boolean useBuddyRepl = Boolean.valueOf(System.getProperty("jbosstest.cluster.web.cache.br")).booleanValue();
+
+ protected Logger log = Logger.getLogger(getClass());
+
+ protected Set<JBossCacheManager> managers = new HashSet<JBossCacheManager>();
+
+ protected Map<String, Object> allAttributes;
+
+ public MultipleWarSingleRedeployTestCase(String name)
+ {
+ super(name);
+ }
+
+ public static Test suite() throws Exception
+ {
+ return CacheConfigTestSetup.getTestSetup(MultipleWarSingleRedeployTestCase.class, pojoCaches, false, null, !useBuddyRepl, true);
+ }
+
+
+ @Override
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+
+ allAttributes = new HashMap<String, Object>();
+
+ allAttributes.put("key", "value");
+
+ allAttributes = Collections.unmodifiableMap(allAttributes);
+ }
+
+ @Override
+ protected void tearDown() throws Exception
+ {
+ super.tearDown();
+
+ SessionTestUtil.clearDistributedCacheManagerFactory();
+
+ for (JBossCacheManager manager : managers)
+ manager.stop();
+
+ managers.clear();
+ }
+
+ protected ReplicationGranularity getReplicationGranularity()
+ {
+ return ReplicationGranularity.SESSION;
+ }
+
+ protected ReplicationTrigger getReplicationTrigger()
+ {
+ return ReplicationTrigger.SET_AND_NON_PRIMITIVE_GET;
+ }
+
+ public void testMultipleWarSingleRedeploy() throws Exception
+ {
+ String warnameA = "A" + String.valueOf(++testId);
+ JBossCacheManager[] mgrsA = getCacheManagers(warnameA);
+ JBossCacheManager jbcmA0 = mgrsA[0];
+ JBossCacheManager jbcmA1 = mgrsA[1];
+
+ String warnameB = "B" + String.valueOf(testId);
+ JBossCacheManager[] mgrsB = getCacheManagers(warnameB);
+ JBossCacheManager jbcmB0 = mgrsB[0];
+ JBossCacheManager jbcmB1 = mgrsB[1];
+
+ // Establish session.
+ SetAttributesRequestHandler setHandler = new SetAttributesRequestHandler(allAttributes, false);
+ SessionTestUtil.invokeRequest(jbcmA0, setHandler, null);
+ validateNewSession(setHandler);
+ String idA = setHandler.getSessionId();
+
+ setHandler = new SetAttributesRequestHandler(allAttributes, false);
+ SessionTestUtil.invokeRequest(jbcmB0, setHandler, null);
+ validateNewSession(setHandler);
+ String idB = setHandler.getSessionId();
+
+ BasicRequestHandler getHandler = new BasicRequestHandler(allAttributes.keySet(), false);
+ SessionTestUtil.invokeRequest(jbcmA1, getHandler, idA);
+
+ validateExpectedAttributes(allAttributes, getHandler);
+
+ getHandler = new BasicRequestHandler(allAttributes.keySet(), false);
+ SessionTestUtil.invokeRequest(jbcmB1, getHandler, idB);
+
+ validateExpectedAttributes(allAttributes, getHandler);
+
+ // Undeploy one webapp on node 1
+ jbcmB1.stop();
+ managers.remove(jbcmB1);
+ log.info("jbcmB1 stopped");
+
+ // Deploy again
+ jbcmB1 = getCacheManager(warnameB, pojoCaches[1]);
+
+ log.info("jbcmB1 started");
+
+ log.info(pojoCaches[0].getCache().getMembers());
+ log.info(pojoCaches[1].getCache().getMembers());
+
+ getHandler = new BasicRequestHandler(allAttributes.keySet(), false);
+ SessionTestUtil.invokeRequest(jbcmA1, getHandler, idA);
+
+ validateExpectedAttributes(allAttributes, getHandler);
+
+ getHandler = new BasicRequestHandler(allAttributes.keySet(), false);
+ SessionTestUtil.invokeRequest(jbcmB1, getHandler, idB);
+
+ validateExpectedAttributes(allAttributes, getHandler);
+ }
+
+ protected JBossCacheManager[] getCacheManagers(String warname)
+ throws Exception
+ {
+ JBossCacheManager[] result = new JBossCacheManager[pojoCaches.length];
+ for (int i = 0; i < result.length; i++)
+ {
+ result[i] = getCacheManager(warname, pojoCaches[i]);
+ }
+ return result;
+ }
+
+ protected JBossCacheManager getCacheManager(String warname, PojoCache cache)
+ throws Exception
+ {
+ JBossCacheManager jbcm = SessionTestUtil.createManager(warname, 100, cache, null);
+ JBossWebMetaData metadata = SessionTestUtil.createWebMetaData(getReplicationGranularity(), getReplicationTrigger(), true, 30);
+ jbcm.init(warname, metadata);
+ this.managers.add(jbcm);
+ jbcm.start();
+
+ return jbcm;
+ }
+
+ protected void validateExpectedAttributes(Map<String, Object> expected, BasicRequestHandler handler)
+ {
+ assertFalse(handler.isNewSession());
+
+ if (handler.isCheckAttributeNames())
+ {
+ assertEquals(expected.size(), handler.getAttributeNames().size());
+ }
+ Map<String, Object> checked = handler.getCheckedAttributes();
+ assertEquals(expected.size(), checked.size());
+ for (Map.Entry<String, Object> entry : checked.entrySet())
+ {
+ assertEquals(entry.getKey(), expected.get(entry.getKey()), entry.getValue());
+ }
+
+ }
+
+ protected void validateNewSession(BasicRequestHandler handler)
+ {
+ assertTrue(handler.isNewSession());
+ assertEquals(handler.getCreationTime(), handler.getLastAccessedTime());
+ if (handler.isCheckAttributeNames())
+ {
+ assertEquals(0, handler.getAttributeNames().size());
+ }
+ Map<String, Object> checked = handler.getCheckedAttributes();
+ for (Map.Entry<String, Object> entry : checked.entrySet())
+ assertNull(entry.getKey(), entry.getValue());
+ }
+
+
+}
More information about the jboss-cvs-commits
mailing list