程序包 | 说明 |
---|---|
com.fr.third.jgroups.blocks.locking | |
com.fr.third.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
com.fr.third.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
限定符和类型 | 方法和说明 |
---|---|
void |
LockNotification.awaited(java.lang.String lock_name,
Owner owner) |
void |
LockNotification.awaiting(java.lang.String lock_name,
Owner owner) |
void |
LockNotification.locked(java.lang.String lock_name,
Owner owner) |
void |
LockNotification.unlocked(java.lang.String lock_name,
Owner owner) |
限定符和类型 | 方法和说明 |
---|---|
void |
LockServiceDemo.awaited(java.lang.String lock_name,
Owner owner) |
void |
LockServiceDemo.awaiting(java.lang.String lock_name,
Owner owner) |
void |
LockServiceDemo.locked(java.lang.String lock_name,
Owner owner) |
void |
LockServiceDemo.unlocked(java.lang.String lock_name,
Owner owner) |
限定符和类型 | 字段和说明 |
---|---|
protected Owner |
Locking.ServerLock.current_owner |
protected Owner |
Locking.ClientLock.owner |
protected Owner |
Locking.Request.owner |
protected Owner |
Locking.Response.owner |
protected Owner |
COUNTER.SimpleRequest.owner |
protected Owner |
COUNTER.SimpleResponse.owner |
限定符和类型 | 字段和说明 |
---|---|
protected java.util.Map<Owner,Tuple<COUNTER.Request,Promise>> |
COUNTER.pending_requests |
protected java.util.Queue<Owner> |
Locking.ServerCondition.queue |
protected java.util.concurrent.ConcurrentMap<java.lang.String,java.util.Map<Owner,Locking.ClientLock>> |
Locking.ClientLockTable.table |
限定符和类型 | 方法和说明 |
---|---|
protected Owner |
Locking.getOwner() |
protected Owner |
COUNTER.getOwner() |
限定符和类型 | 方法和说明 |
---|---|
protected java.util.Collection<java.util.Map<Owner,Locking.ClientLock>> |
Locking.ClientLockTable.values() |
限定符和类型 | 方法和说明 |
---|---|
void |
Locking.ServerCondition.addWaiter(Owner waiter) |
void |
CENTRAL_LOCK.awaited(java.lang.String lock_name,
Owner owner) |
void |
CENTRAL_LOCK.awaiting(java.lang.String lock_name,
Owner owner) |
protected Locking.ClientLock |
Locking.createLock(java.lang.String lock_name,
Owner owner) |
protected Locking.ClientLock |
Locking.ClientLockTable.getLock(java.lang.String name,
Owner owner,
boolean create_if_absent) |
protected void |
Locking.handleAwaitRequest(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.handleCreateAwaitingRequest(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.handleCreateLockRequest(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.handleDeleteAwaitingRequest(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.handleDeleteAwaitRequest(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.handleLockDeniedResponse(java.lang.String lock_name,
int lock_id,
Owner owner) |
protected void |
PEER_LOCK.PeerLock.handleLockGrantedResponse(Owner owner,
Address sender) |
protected void |
Locking.handleLockGrantedResponse(java.lang.String lock_name,
int lock_id,
Owner owner) |
protected void |
Locking.handleSignalResponse(java.lang.String lock_name,
Owner owner) |
protected boolean |
Locking.ServerLock.isRequestPresent(Locking.Type type,
Owner owner)
Checks if a certain request from a given owner is already in the queue
|
void |
CENTRAL_LOCK.locked(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.notifyAwaited(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.notifyAwaiting(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.notifyLocked(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.notifyUnlocked(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.ClientLockTable.removeClientLock(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.ServerLock.removeRequest(Locking.Type type,
Owner owner) |
void |
Locking.ServerCondition.removeWaiter(Owner waiter) |
protected void |
PEER_LOCK.sendAwaitConditionRequest(java.lang.String lock_name,
Owner owner) |
protected abstract void |
Locking.sendAwaitConditionRequest(java.lang.String lock_name,
Owner owner) |
protected void |
CENTRAL_LOCK.sendAwaitConditionRequest(java.lang.String lock_name,
Owner owner) |
protected void |
COUNTER.sendCounterNotFoundExceptionResponse(Address dest,
Owner owner,
java.lang.String counter_name) |
protected void |
CENTRAL_LOCK.sendCreateLockRequest(Address dest,
java.lang.String lock_name,
Owner owner) |
protected void |
PEER_LOCK.sendDeleteAwaitConditionRequest(java.lang.String lock_name,
Owner owner) |
protected abstract void |
Locking.sendDeleteAwaitConditionRequest(java.lang.String lock_name,
Owner owner) |
protected void |
CENTRAL_LOCK.sendDeleteAwaitConditionRequest(java.lang.String lock_name,
Owner owner) |
protected void |
PEER_LOCK.sendGrantLockRequest(java.lang.String lock_name,
int lock_id,
Owner owner,
long timeout,
boolean is_trylock) |
protected abstract void |
Locking.sendGrantLockRequest(java.lang.String lock_name,
int lock_id,
Owner owner,
long timeout,
boolean is_trylock) |
protected void |
CENTRAL_LOCK.sendGrantLockRequest(java.lang.String lock_name,
int lock_id,
Owner owner,
long timeout,
boolean is_trylock) |
protected void |
Locking.sendLockResponse(Locking.Type type,
Owner dest,
java.lang.String lock_name,
int lock_id) |
protected void |
PEER_LOCK.sendReleaseLockRequest(java.lang.String lock_name,
Owner owner) |
protected abstract void |
Locking.sendReleaseLockRequest(java.lang.String lock_name,
Owner owner) |
protected void |
CENTRAL_LOCK.sendReleaseLockRequest(java.lang.String lock_name,
Owner owner) |
protected void |
Locking.sendRequest(Address dest,
Locking.Type type,
java.lang.String lock_name,
int lock_id,
Owner owner,
long timeout,
boolean is_trylock) |
protected void |
Locking.sendRequest(Address dest,
Locking.Type type,
java.lang.String lock_name,
Owner owner,
long timeout,
boolean is_trylock) |
protected void |
Locking.sendSignalResponse(Owner dest,
java.lang.String lock_name) |
protected void |
Locking.ServerLock.setOwner(Owner owner) |
void |
CENTRAL_LOCK.unlocked(java.lang.String lock_name,
Owner owner) |
protected void |
CENTRAL_LOCK.updateBackups(Locking.Type type,
java.lang.String lock_name,
Owner owner) |
构造器和说明 |
---|
COUNTER.AddAndGetRequest(Owner owner,
java.lang.String name,
long value) |
COUNTER.BooleanResponse(Owner owner,
long version,
boolean result) |
COUNTER.CompareAndSetRequest(Owner owner,
java.lang.String name,
long expected,
long update) |
COUNTER.DeleteRequest(Owner owner,
java.lang.String name) |
COUNTER.ExceptionResponse(Owner owner,
java.lang.String error_message) |
COUNTER.GetOrCreateResponse(Owner owner,
long result,
long version) |
COUNTER.SetRequest(Owner owner,
java.lang.String name,
long value) |
COUNTER.SimpleRequest(Owner owner,
java.lang.String name) |
COUNTER.SimpleResponse(Owner owner,
long version) |
COUNTER.ValueResponse(Owner owner,
long result,
long version) |
Locking.ClientLock(java.lang.String name,
Owner owner) |
Locking.Request(Locking.Type type,
java.lang.String lock_name,
Owner owner,
long timeout) |
Locking.Request(Locking.Type type,
java.lang.String lock_name,
Owner owner,
long timeout,
boolean is_trylock) |
Locking.Response(Locking.Type type,
Owner owner,
java.lang.String lock_name,
int lock_id) |
Locking.ServerLock(java.lang.String lock_name,
Owner owner) |