From jbosscache-commits at lists.jboss.org Wed Jun 25 09:20:58 2008
Content-Type: multipart/mixed; boundary="===============4350014114028963148=="
MIME-Version: 1.0
From: jbosscache-commits at lists.jboss.org
To: jbosscache-commits at lists.jboss.org
Subject: [jbosscache-commits] JBoss Cache SVN: r6025 -
 core/trunk/src/main/java/org/jboss/cache/lock.
Date: Wed, 25 Jun 2008 09:20:58 -0400
Message-ID: <E1KBUvi-0006Dr-EL@committer01.frg.pub.inap.atl.jboss.com>

--===============4350014114028963148==
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: quoted-printable

Author: manik.surtani(a)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.ja=
va
=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/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=3D"mailto:manik(a)jboss.org">manik(a)jbo=
ss.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 =3D configuration;
+   }
+
+   @Start
+   public void setLockAcquisitionTimeout()
+   {
+      this.lockAcquisitionTimeout =3D configuration.getLockAcquisitionTime=
out();
+   }
+
+   public Object getLockOwner(InvocationContext ctx)
+   {
+      return ctx.getGlobalTransaction() !=3D null ? ctx.getGlobalTransacti=
on() : Thread.currentThread();
+   }
+}

Added: core/trunk/src/main/java/org/jboss/cache/lock/FqnLockManager.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/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=3D"mailto:manik(a)jboss.org">manik(a)jbo=
ss.org</a>)
+ * @since 3.0
+ */
+public abstract class FqnLockManager extends AbstractLockManager
+{
+   public boolean lock(NodeSPI node, LockType lockType, Object owner) thro=
ws 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, Invocatio=
nContext 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());
+   }
+}


--===============4350014114028963148==--