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: <E1JAqPe-0002CK-EW@committer01.frg.pub.inap.atl.jboss.com>

--===============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 (<a href=3D"mailto:manik(a)jboss.org">manik(a)jbo=
ss.org</a>)
+ * @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==--