From jbosscache-commits at lists.jboss.org Fri Jan 4 12:32:54 2008 Content-Type: multipart/mixed; boundary="===============2318144387552775757==" MIME-Version: 1.0 From: jbosscache-commits at lists.jboss.org To: jbosscache-commits at lists.jboss.org Subject: [jbosscache-commits] JBoss Cache SVN: r4988 - core/trunk/src/test/java/org/jboss/cache/buddyreplication. Date: Fri, 04 Jan 2008 12:32:54 -0500 Message-ID: --===============2318144387552775757== Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Author: manik.surtani(a)jboss.com Date: 2008-01-04 12:32:54 -0500 (Fri, 04 Jan 2008) New Revision: 4988 Added: core/trunk/src/test/java/org/jboss/cache/buddyreplication/GravitationCle= anupTest.java Log: Added test to ensure proper cleanup after gravitation Added: core/trunk/src/test/java/org/jboss/cache/buddyreplication/Gravitatio= nCleanupTest.java =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D --- core/trunk/src/test/java/org/jboss/cache/buddyreplication/GravitationCl= eanupTest.java (rev 0) +++ core/trunk/src/test/java/org/jboss/cache/buddyreplication/GravitationCl= eanupTest.java 2008-01-04 17:32:54 UTC (rev 4988) @@ -0,0 +1,55 @@ +package org.jboss.cache.buddyreplication; + +import org.jboss.cache.CacheSPI; +import org.jboss.cache.Fqn; +import org.jboss.cache.util.CachePrinter; +import org.testng.annotations.Test; + +/** + * @author Manik Surtani (manik(a)jbo= ss.org) + * @since 2.1.0 + */ +(a)Test(groups =3D "functional") +public class GravitationCleanupTest extends BuddyReplicationTestsBase +{ + Fqn fqn =3D Fqn.fromString("/a/b/c"); + Object key =3D "key", value =3D "value"; + + public void testStaleRegionOnDataOwner() throws Exception + { + caches =3D createCaches(1, 2, false, true, false); + + // add some stuff on the primary + CacheSPI dataOwner =3D caches.get(0); + CacheSPI buddy =3D caches.get(1); + + dataOwner.put(fqn, key, value); + + System.out.println("dataOwner: " + CachePrinter.printCacheLockingInf= o(dataOwner)); + System.out.println("buddy: " + CachePrinter.printCacheLockingInfo(bu= ddy)); + + assert dataOwner.peek(fqn, false) !=3D null : "Should have data"; + assert dataOwner.peek(new Fqn(BuddyManager.BUDDY_BACKUP_SUBTREE_FQN,= BuddyManager.getGroupNameFromAddress(buddy.getLocalAddress())), false) != =3D null : "Should have backup node for buddy"; + assert dataOwner.peek(new Fqn(BuddyManager.BUDDY_BACKUP_SUBTREE_FQN,= BuddyManager.getGroupNameFromAddress(dataOwner.getLocalAddress())), false)= =3D=3D null : "Should NOT have backup node for self!"; + + assert buddy.peek(fqn, false) =3D=3D null : "Should not have data"; + assert buddy.peek(new Fqn(BuddyManager.BUDDY_BACKUP_SUBTREE_FQN, Bud= dyManager.getGroupNameFromAddress(buddy.getLocalAddress())), false) =3D=3D = null : "Should NOT have backup node for self!"; + assert buddy.peek(new Fqn(BuddyManager.BUDDY_BACKUP_SUBTREE_FQN, Bud= dyManager.getGroupNameFromAddress(dataOwner.getLocalAddress())), false) != =3D null : "Should have backup node for buddy"; + assert buddy.peek(BuddyManager.getBackupFqn(dataOwner.getLocalAddres= s(), fqn), false) !=3D null : "Should have backup data"; + + // now do a gravitate call. + assert buddy.get(fqn, key).equals(value) : "Data should have gravita= ted!"; + + System.out.println("dataOwner: " + CachePrinter.printCacheLockingInf= o(dataOwner)); + System.out.println("buddy: " + CachePrinter.printCacheLockingInfo(bu= ddy)); + + assert buddy.peek(fqn, false) !=3D null : "Should have data"; + assert buddy.peek(new Fqn(BuddyManager.BUDDY_BACKUP_SUBTREE_FQN, Bud= dyManager.getGroupNameFromAddress(dataOwner.getLocalAddress())), false) != =3D null : "Should have backup node for buddy"; + assert buddy.peek(new Fqn(BuddyManager.BUDDY_BACKUP_SUBTREE_FQN, Bud= dyManager.getGroupNameFromAddress(buddy.getLocalAddress())), false) =3D=3D = null : "Should NOT have backup node for self!"; + + assert dataOwner.peek(fqn, false) =3D=3D null : "Should not have dat= a"; + assert dataOwner.peek(new Fqn(BuddyManager.BUDDY_BACKUP_SUBTREE_FQN,= BuddyManager.getGroupNameFromAddress(dataOwner.getLocalAddress())), false)= =3D=3D null : "Should NOT have backup node for self!"; + assert dataOwner.peek(new Fqn(BuddyManager.BUDDY_BACKUP_SUBTREE_FQN,= BuddyManager.getGroupNameFromAddress(buddy.getLocalAddress())), false) != =3D null : "Should have backup node for buddy"; + assert dataOwner.peek(BuddyManager.getBackupFqn(buddy.getLocalAddres= s(), fqn), false) !=3D null : "Should have backup data"; + } +} --===============2318144387552775757==--