[jbosscache-commits] JBoss Cache SVN: r6025 - core/trunk/src/main/java/org/jboss/cache/lock.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-06-25 09:20:58 -0400 (Wed, 25 Jun 2008)
New Revision: 6025

Added:
   core/trunk/src/main/java/org/jboss/cache/lock/AbstractLockManager.java
   core/trunk/src/main/java/org/jboss/cache/lock/FqnLockManager.java
Log:
Added abstract classes to simplify lock manager implementations

Added: core/trunk/src/main/java/org/jboss/cache/lock/AbstractLockManager.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/lock/AbstractLockManager.java	                        (rev 0)
+++ core/trunk/src/main/java/org/jboss/cache/lock/AbstractLockManager.java	2008-06-25 13:20:58 UTC (rev 6025)
@@ -0,0 +1,35 @@
+package org.jboss.cache.lock;
+
+import org.jboss.cache.InvocationContext;
+import org.jboss.cache.config.Configuration;
+import org.jboss.cache.factories.annotations.Inject;
+import org.jboss.cache.factories.annotations.Start;
+
+/**
+ * Common lock manager functionality
+ *
+ * @author Manik Surtani (<a href="mailto:manik at jboss.org">manik at jboss.org</a>)
+ * @since 3.0
+ */
+public abstract class AbstractLockManager implements LockManager
+{
+   protected Configuration configuration;
+   protected long lockAcquisitionTimeout;
+
+   @Inject
+   public void injectConfiguration(Configuration configuration)
+   {
+      this.configuration = configuration;
+   }
+
+   @Start
+   public void setLockAcquisitionTimeout()
+   {
+      this.lockAcquisitionTimeout = configuration.getLockAcquisitionTimeout();
+   }
+
+   public Object getLockOwner(InvocationContext ctx)
+   {
+      return ctx.getGlobalTransaction() != null ? ctx.getGlobalTransaction() : Thread.currentThread();
+   }
+}

Added: core/trunk/src/main/java/org/jboss/cache/lock/FqnLockManager.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/lock/FqnLockManager.java	                        (rev 0)
+++ core/trunk/src/main/java/org/jboss/cache/lock/FqnLockManager.java	2008-06-25 13:20:58 UTC (rev 6025)
@@ -0,0 +1,50 @@
+package org.jboss.cache.lock;
+
+import org.jboss.cache.InvocationContext;
+import org.jboss.cache.NodeSPI;
+
+import java.util.Collection;
+
+/**
+ * An abstract lock manager that deals with Fqns rather than nodes.
+ *
+ * @author Manik Surtani (<a href="mailto:manik at jboss.org">manik at jboss.org</a>)
+ * @since 3.0
+ */
+public abstract class FqnLockManager extends AbstractLockManager
+{
+   public boolean lock(NodeSPI node, LockType lockType, Object owner) throws InterruptedException
+   {
+      return lock(node.getFqn(), lockType, owner);
+   }
+
+   public boolean lock(NodeSPI node, LockType lockType, Object owner, long timeout) throws InterruptedException
+   {
+      return lock(node.getFqn(), lockType, owner, timeout);
+   }
+
+   public boolean lockAndRecord(NodeSPI node, LockType lockType, InvocationContext ctx) throws InterruptedException
+   {
+      return lockAndRecord(node.getFqn(), lockType, ctx);
+   }
+
+   public void unlock(NodeSPI node, Object owner)
+   {
+      unlock(node.getFqn(), owner);
+   }
+
+   public boolean ownsLock(NodeSPI node, Object owner)
+   {
+      return ownsLock(node.getFqn(), owner);
+   }
+
+   public Object getWriteOwner(NodeSPI node)
+   {
+      return getWriteOwner(node.getFqn());
+   }
+
+   public Collection<Object> getReadOwners(NodeSPI node)
+   {
+      return getReadOwners(node.getFqn());
+   }
+}