| java.lang.Object com.tc.objectserver.lockmanager.impl.LockManagerImpl
LockManagerImpl | public class LockManagerImpl implements LockManager,LockManagerMBean,WaitTimerCallback(Code) | | Server representation of lock management. We will need to keep track of what locks are checkedout, who has the lock
and who wants the lock
author: steve |
Inner Class :public static class LockManagerError extends Error | |
Inner Class :public static class LockManagerErrorDescription | |
Method Summary | |
public synchronized void | clearAllLocksFor(NodeID nid) | public synchronized void | disableClientStat(LockID lockID, Set statEnabledClients, Sink sink) | public synchronized void | dump() | public synchronized void | enableClientStat(LockID lockID, Sink sink, int stackTraceDepth, int statCollectFrequency) | public LockMBean[] | getAllLocks() | public synchronized int | getLockCount() | public int | getLockPolicy() | public synchronized int | getThreadContextCount() | public synchronized boolean | hasPending(LockID id) | public synchronized void | interrupt(LockID lockID, NodeID cid, ThreadID threadID) | public synchronized void | notify(LockID lid, NodeID cid, ThreadID tid, boolean all, NotifiedWaiters addNotifiedWaitersTo) | public synchronized void | queryLock(LockID lockID, NodeID cid, ThreadID threadID, Sink lockResponseSink) | public synchronized void | recallCommit(LockID lid, NodeID cid, Collection lockContexts, Collection waitContexts, Collection pendingLockContexts, Collection pendingTryLockContexts, Sink lockResponseSink) | public synchronized void | reestablishLock(LockID lockID, NodeID nid, ThreadID sourceID, int requestedLevel, Sink lockResponseSink) | public synchronized void | reestablishWait(LockID lid, NodeID cid, ThreadID tid, int lockLevel, WaitInvocation call, Sink lockResponseSink) | public synchronized boolean | requestLock(LockID lockID, NodeID nodeID, ThreadID sourceID, int requestedLevel, Sink lockResponseSink) | public synchronized void | scanForDeadlocks(DeadlockResults output) | public DeadlockChain[] | scanForDeadlocks() | public void | setLockPolicy(int lockPolicy) | public void | start() | public synchronized void | stop() | public synchronized boolean | tryRequestLock(LockID lockID, NodeID nodeID, ThreadID sourceID, int requestedLevel, WaitInvocation timeout, Sink lockResponseSink) | public synchronized void | unlock(LockID id, NodeID channelID, ThreadID threadID) | public synchronized void | verify(NodeID nodeID, LockID[] lockIDs) | public synchronized void | wait(LockID lid, NodeID cid, ThreadID tid, WaitInvocation call, Sink lockResponseSink) | public void | waitTimeout(Object callbackObject) |
ALTRUISTIC_LOCK_POLICY | final public static int ALTRUISTIC_LOCK_POLICY(Code) | | |
GREEDY_LOCK_POLICY | final public static int GREEDY_LOCK_POLICY(Code) | | |
IS_STARTING_ERROR | final public static LockManagerErrorDescription IS_STARTING_ERROR(Code) | | |
IS_STOPPED_ERROR | final public static LockManagerErrorDescription IS_STOPPED_ERROR(Code) | | |
LOCK_ALREADY_GRANTED_ERROR | final public static LockManagerErrorDescription LOCK_ALREADY_GRANTED_ERROR(Code) | | |
NOT_STARTED_ERROR | final public static LockManagerErrorDescription NOT_STARTED_ERROR(Code) | | |
NOT_STARTING_ERROR | final public static LockManagerErrorDescription NOT_STARTING_ERROR(Code) | | |
UNINITIALIZED_LOCK_POLICY | final public static int UNINITIALIZED_LOCK_POLICY(Code) | | |
clearAllLocksFor | public synchronized void clearAllLocksFor(NodeID nid)(Code) | | |
disableClientStat | public synchronized void disableClientStat(LockID lockID, Set statEnabledClients, Sink sink)(Code) | | |
dump | public synchronized void dump()(Code) | | |
enableClientStat | public synchronized void enableClientStat(LockID lockID, Sink sink, int stackTraceDepth, int statCollectFrequency)(Code) | | |
getLockCount | public synchronized int getLockCount()(Code) | | |
getLockPolicy | public int getLockPolicy()(Code) | | |
getThreadContextCount | public synchronized int getThreadContextCount()(Code) | | |
hasPending | public synchronized boolean hasPending(LockID id)(Code) | | |
reestablishLock | public synchronized void reestablishLock(LockID lockID, NodeID nid, ThreadID sourceID, int requestedLevel, Sink lockResponseSink)(Code) | | |
setLockPolicy | public void setLockPolicy(int lockPolicy)(Code) | | |
start | public void start()(Code) | | |
waitTimeout | public void waitTimeout(Object callbackObject)(Code) | | |
|
|