[jbosscache-commits] JBoss Cache SVN: r7667 - core/branches/flat/src/test/java/org/horizon/expiry.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-02-09 13:29:38 -0500 (Mon, 09 Feb 2009)
New Revision: 7667

Added:
   core/branches/flat/src/test/java/org/horizon/expiry/ReplicatedExpiryTest.java
Log:
Added new expiry test

Added: core/branches/flat/src/test/java/org/horizon/expiry/ReplicatedExpiryTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/expiry/ReplicatedExpiryTest.java	                        (rev 0)
+++ core/branches/flat/src/test/java/org/horizon/expiry/ReplicatedExpiryTest.java	2009-02-09 18:29:38 UTC (rev 7667)
@@ -0,0 +1,42 @@
+package org.horizon.expiry;
+
+import org.horizon.BaseClusteredTest;
+import org.horizon.Cache;
+import org.horizon.config.Configuration;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.Test;
+
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+ at Test(groups = "functional", sequential = true)
+public class ReplicatedExpiryTest extends BaseClusteredTest {
+
+   Cache c1, c2;
+
+   @BeforeMethod
+   public void setUp() {
+      Configuration cfg = new Configuration();
+      cfg.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+      List<Cache> caches = createClusteredCaches(2, "cache", cfg);
+      c1 = caches.get(0);
+      c2 = caches.get(1);
+   }
+
+   public void testExpiryReplicates() throws InterruptedException {
+      long start = System.currentTimeMillis();
+      long lifespan = 10000;
+      c1.put("k", "v", lifespan, TimeUnit.MILLISECONDS);
+
+      while (System.currentTimeMillis() < start + lifespan + 1000) {
+         if (System.currentTimeMillis() < start + lifespan) {
+            assert c1.get("k").equals("v");
+            assert c2.get("k").equals("v");
+         } else {
+            assert c1.get("k") == null;
+            assert c2.get("k") == null;
+         }
+         Thread.sleep(250);
+      }
+   }
+}