1 files changed, 54 insertions, 0 deletions
diff --git a/java/JACE/netsvcs/Token/RWMutexHandler.java b/java/JACE/netsvcs/Token/RWMutexHandler.java
new file mode 100644
index 00000000000..89dc679dd8d
--- /dev/null
+++ b/java/JACE/netsvcs/Token/RWMutexHandler.java
@@ -0,0 +1,54 @@
+package JACE.netsvcs.Token;
+
+import JACE.Concurrency.*;
+
+/**
+ * LockHandler implementation for a reader/writer mutex lock.  
+ * <P>
+ * Since it uses RWMutex as the actual lock, it doesn't support
+ * nested acquires.
+ *
+ *@see LockHandler
+ */
+public class RWMutexHandler extends LockHandlerAdapter
+{
+  static class ExtendedRWMutex extends RWMutex
+  {
+    // This is so that we don't make any assumptions about previous
+    // implementations of LockAdapter, and enable owner checking with
+    // the client ID from TokenRequest.  The thread name is set in
+    // handleRequest.
+    protected Object accessorID ()
+    {
+      return Thread.currentThread().getName();
+    }
+  }
+
+  /**
+   * Default constructor.
+   */
+  public RWMutexHandler ()
+  {
+    super (new ExtendedRWMutex ());
+  }
+
+  public TokenReply handleRequest (TokenRequestHandler caller,
+				   TokenRequest request)
+  {
+    // Set the name of this thread to the client ID to perform
+    // proper owner checking.
+    Thread.currentThread().setName (request.clientID ());
+    
+    // process the request
+    return super.handleRequest (caller, request);
+  }
+
+  public void abandonLock (String clientID)
+  {
+    // Set the name of this thread to the client ID to perform
+    // proper owner checking.
+    Thread.currentThread().setName (clientID);
+
+    super.abandonLock (clientID);
+  }
+}