Package | Description |
---|---|
org.jgroups.blocks.locking | |
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Field and Description |
---|---|
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 |
Modifier and Type | Field and Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
protected Owner |
Locking.getOwner() |
protected Owner |
COUNTER.getOwner() |
protected Owner |
CENTRAL_LOCK.getOwner() |
Modifier and Type | Method and Description |
---|---|
protected java.util.Collection<java.util.Map<Owner,Locking.ClientLock>> |
Locking.ClientLockTable.values() |
Modifier and Type | Method and Description |
---|---|
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.handleLockReleasedResponse(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 boolean |
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 abstract void |
Locking.sendAwaitConditionRequest(java.lang.String lock_name,
Owner owner) |
protected void |
PEER_LOCK.sendAwaitConditionRequest(java.lang.String lock_name,
Owner owner)
Deprecated.
|
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 abstract void |
Locking.sendDeleteAwaitConditionRequest(java.lang.String lock_name,
Owner owner) |
protected void |
PEER_LOCK.sendDeleteAwaitConditionRequest(java.lang.String lock_name,
Owner owner)
Deprecated.
|
protected void |
CENTRAL_LOCK.sendDeleteAwaitConditionRequest(java.lang.String lock_name,
Owner owner) |
protected abstract void |
Locking.sendGrantLockRequest(java.lang.String lock_name,
int lock_id,
Owner owner,
long timeout,
boolean is_trylock) |
protected void |
PEER_LOCK.sendGrantLockRequest(java.lang.String lock_name,
int lock_id,
Owner owner,
long timeout,
boolean is_trylock)
Deprecated.
|
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 abstract void |
Locking.sendReleaseLockRequest(java.lang.String lock_name,
int lock_id,
Owner owner) |
protected void |
PEER_LOCK.sendReleaseLockRequest(java.lang.String lock_name,
int lock_id,
Owner owner)
Deprecated.
|
protected void |
CENTRAL_LOCK.sendReleaseLockRequest(java.lang.String lock_name,
int lock_id,
Owner owner) |
protected void |
PEER_LOCK.sendReleaseLockRequest(java.lang.String lock_name,
Owner owner)
Deprecated.
|
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) |
Constructor and Description |
---|
AddAndGetRequest(Owner owner,
java.lang.String name,
long value) |
BooleanResponse(Owner owner,
long version,
boolean result) |
ClientLock(java.lang.String name,
Owner owner) |
CompareAndSetRequest(Owner owner,
java.lang.String name,
long expected,
long update) |
DeleteRequest(Owner owner,
java.lang.String name) |
ExceptionResponse(Owner owner,
java.lang.String error_message) |
GetOrCreateResponse(Owner owner,
long result,
long version) |
Request(Locking.Type type,
java.lang.String lock_name,
Owner owner,
long timeout) |
Request(Locking.Type type,
java.lang.String lock_name,
Owner owner,
long timeout,
boolean is_trylock) |
Response(Locking.Type type,
Owner owner,
java.lang.String lock_name,
int lock_id) |
ServerLock(java.lang.String lock_name,
Owner owner) |
SetRequest(Owner owner,
java.lang.String name,
long value) |
SimpleRequest(Owner owner,
java.lang.String name) |
SimpleResponse(Owner owner,
long version) |
ValueResponse(Owner owner,
long result,
long version) |
Modifier and Type | Method and Description |
---|---|
int |
Owner.compareTo(Owner o) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.