[infinispan-commits] Infinispan SVN: r302 - in trunk/core/src: test/java/org/infinispan/replication and 1 other directory.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-05-14 12:14:45 -0400 (Thu, 14 May 2009)
New Revision: 302

Modified:
   trunk/core/src/main/java/org/infinispan/CacheDelegate.java
   trunk/core/src/test/java/org/infinispan/replication/SyncReplLockingTest.java
Log:
Temporarily disabled lock API features

Modified: trunk/core/src/main/java/org/infinispan/CacheDelegate.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/CacheDelegate.java	2009-05-14 16:12:36 UTC (rev 301)
+++ trunk/core/src/main/java/org/infinispan/CacheDelegate.java	2009-05-14 16:14:45 UTC (rev 302)
@@ -228,12 +228,14 @@
    }
 
    public void lock(K key) {
+      if (true) throw new UnsupportedOperationException("Not yet implemented");
       if (key == null)
          throw new IllegalArgumentException("Cannot lock null key");
       lock(Collections.singletonList(key));
    }
 
    public void lock(Collection<? extends K> keys) {
+      if (true) throw new UnsupportedOperationException("Not yet implemented");
       if (keys == null || keys.isEmpty())
          throw new IllegalArgumentException("Cannot lock empty list of keys");
       LockControlCommand command = commandsFactory.buildLockControlCommand(keys, true);
@@ -241,12 +243,14 @@
    }
 
    public void unlock(K key) {
+      if (true) throw new UnsupportedOperationException("Not yet implemented");
       if (key == null)
          throw new IllegalArgumentException("Cannot unlock null key");
       unlock(Collections.singletonList(key));
    }
 
    public void unlock(Collection<? extends K> keys) {
+      if (true) throw new UnsupportedOperationException("Not yet implemented");
       if (keys == null || keys.isEmpty())
          throw new IllegalArgumentException("Cannot unlock empty list of keys");
       LockControlCommand command = commandsFactory.buildLockControlCommand(keys, false);

Modified: trunk/core/src/test/java/org/infinispan/replication/SyncReplLockingTest.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/replication/SyncReplLockingTest.java	2009-05-14 16:12:36 UTC (rev 301)
+++ trunk/core/src/test/java/org/infinispan/replication/SyncReplLockingTest.java	2009-05-14 16:14:45 UTC (rev 302)
@@ -22,7 +22,7 @@
 /**
  * @author <a href="mailto:manik at jboss.org">Manik Surtani (manik at jboss.org)</a>
  */
- at Test(groups = "functional", testName = "replication.SyncReplLockingTest")
+ at Test(groups = "functional", testName = "replication.SyncReplLockingTest", enabled = false, description = "TODO: Temporarily disabled.  Enable before BETA1")
 public class SyncReplLockingTest extends MultipleCacheManagersTest {
    Cache<String, String> cache1, cache2;
    String k = "key", v = "value";
@@ -37,13 +37,11 @@
       cache2 = manager(1).getCache("replSync");
    }
 
-   @Test(enabled = true)
    public void testLockingWithExplicitUnlock() throws Exception {
       lockingWithExplicitUnlockHelper(false);
       lockingWithExplicitUnlockHelper(true);
    }
 
-   @Test(enabled = true)
    public void testLocksReleasedWithoutExplicitUnlock() throws Exception {
       locksReleasedWithoutExplicitUnlockHelper(false);
       locksReleasedWithoutExplicitUnlockHelper(true);
@@ -78,7 +76,6 @@
       assert cache2.isEmpty();
    }
 
-   @Test(enabled = true)
    public void testConcurrentLocking() throws Exception {
       assertClusterSize("Should only be 2  caches in the cluster!!!", 2);