Package org.jgroups.protocols
Class Locking.ServerLock
- java.lang.Object
-
- org.jgroups.protocols.Locking.ServerLock
-
- Enclosing class:
- Locking
protected class Locking.ServerLock extends java.lang.ObjectServer side queue for handling of lock requests (lock, release).- Author:
- Bela Ban
-
-
Field Summary
Fields Modifier and Type Field Description protected Locking.ServerConditionconditionprotected java.lang.Stringlock_nameprotected Ownerownerprotected java.util.List<Locking.Request>queue
-
Constructor Summary
Constructors Modifier Constructor Description ServerLock(java.lang.String lock_name)protectedServerLock(java.lang.String lock_name, Owner owner)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidaddToQueue(Locking.Request req)protected Locking.RequestgetNextRequest()protected Locking.ResponsehandleRequest(Locking.Request req)protected Locking.ResponsehandleView(java.util.List<Address> members)booleanisEmpty()protected booleanisRequestPresent(Locking.Type type, Owner owner)Checks if a certain request from a given owner is already in the queueprotected Locking.ResponseprocessQueue()protected voidremoveRequest(Locking.Type type, Owner owner)protected voidsetOwner(Owner owner)java.lang.StringtoString()
-
-
-
Field Detail
-
lock_name
protected final java.lang.String lock_name
-
owner
protected Owner owner
-
queue
protected final java.util.List<Locking.Request> queue
-
condition
protected final Locking.ServerCondition condition
-
-
Constructor Detail
-
ServerLock
public ServerLock(java.lang.String lock_name)
-
ServerLock
protected ServerLock(java.lang.String lock_name, Owner owner)
-
-
Method Detail
-
handleRequest
protected Locking.Response handleRequest(Locking.Request req)
-
handleView
protected Locking.Response handleView(java.util.List<Address> members)
-
addToQueue
protected void addToQueue(Locking.Request req)
-
isRequestPresent
protected boolean isRequestPresent(Locking.Type type, Owner owner)
Checks if a certain request from a given owner is already in the queue
-
removeRequest
protected void removeRequest(Locking.Type type, Owner owner)
-
getNextRequest
protected Locking.Request getNextRequest()
-
processQueue
protected Locking.Response processQueue()
-
setOwner
protected void setOwner(Owner owner)
-
isEmpty
public boolean isEmpty()
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-