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.
|
Modifier and Type | Method and Description |
---|---|
void |
LockNotification.awaited(String lock_name,
Owner owner) |
void |
LockNotification.awaiting(String lock_name,
Owner owner) |
void |
LockNotification.locked(String lock_name,
Owner owner) |
void |
LockNotification.unlocked(String lock_name,
Owner owner) |
Modifier and Type | Method and Description |
---|---|
void |
LockServiceDemo.awaited(String lock_name,
Owner owner) |
void |
LockServiceDemo.awaiting(String lock_name,
Owner owner) |
void |
LockServiceDemo.locked(String lock_name,
Owner owner) |
void |
LockServiceDemo.unlocked(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 |
COUNTER.SimpleRequest.owner |
protected Owner |
COUNTER.SimpleResponse.owner |
Modifier and Type | Field and Description |
---|---|
protected Map<String,Map<Owner,Locking.ClientLock>> |
Locking.client_locks |
protected Map<Owner,Tuple<COUNTER.Request,Promise>> |
COUNTER.pending_requests |
protected Queue<Owner> |
Locking.ServerCondition.queue |
Modifier and Type | Method and Description |
---|---|
protected Owner |
Locking.getOwner() |
protected Owner |
COUNTER.getOwner() |
Modifier and Type | Method and Description |
---|---|
void |
Locking.ServerCondition.addWaiter(Owner waiter) |
void |
CENTRAL_LOCK.awaited(String lock_name,
Owner owner) |
void |
CENTRAL_LOCK.awaiting(String lock_name,
Owner owner) |
protected Locking.ClientLock |
Locking.getLock(String name,
Owner owner,
boolean create_if_absent) |
protected void |
Locking.handleAwaitRequest(String lock_name,
Owner owner) |
protected void |
Locking.handleCreateAwaitingRequest(String lock_name,
Owner owner) |
protected void |
Locking.handleCreateLockRequest(String lock_name,
Owner owner) |
protected void |
Locking.handleDeleteAwaitingRequest(String lock_name,
Owner owner) |
protected void |
Locking.handleDeleteAwaitRequest(String lock_name,
Owner owner) |
protected void |
Locking.handleLockDeniedResponse(String lock_name,
Owner owner) |
protected void |
PEER_LOCK.PeerLock.handleLockGrantedResponse(Owner owner,
Address sender) |
protected void |
Locking.ClientLock.handleLockGrantedResponse(Owner owner,
Address sender) |
protected void |
Locking.handleLockGrantedResponse(String lock_name,
Owner owner,
Address sender) |
protected void |
Locking.handleSignalResponse(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(String lock_name,
Owner owner) |
protected void |
Locking.notifyAwaited(String lock_name,
Owner owner) |
protected void |
Locking.notifyAwaiting(String lock_name,
Owner owner) |
protected void |
Locking.notifyLocked(String lock_name,
Owner owner) |
protected void |
Locking.notifyUnlocked(String lock_name,
Owner owner) |
protected void |
Locking.removeClientLock(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(String lock_name,
Owner owner) |
protected abstract void |
Locking.sendAwaitConditionRequest(String lock_name,
Owner owner) |
protected void |
CENTRAL_LOCK.sendAwaitConditionRequest(String lock_name,
Owner owner) |
protected void |
COUNTER.sendCounterNotFoundExceptionResponse(Address dest,
Owner owner,
String counter_name) |
protected void |
CENTRAL_LOCK.sendCreateLockRequest(Address dest,
String lock_name,
Owner owner) |
protected void |
PEER_LOCK.sendDeleteAwaitConditionRequest(String lock_name,
Owner owner) |
protected abstract void |
Locking.sendDeleteAwaitConditionRequest(String lock_name,
Owner owner) |
protected void |
CENTRAL_LOCK.sendDeleteAwaitConditionRequest(String lock_name,
Owner owner) |
protected void |
PEER_LOCK.sendGrantLockRequest(String lock_name,
Owner owner,
long timeout,
boolean is_trylock) |
protected abstract void |
Locking.sendGrantLockRequest(String lock_name,
Owner owner,
long timeout,
boolean is_trylock) |
protected void |
CENTRAL_LOCK.sendGrantLockRequest(String lock_name,
Owner owner,
long timeout,
boolean is_trylock) |
protected void |
Locking.sendLockResponse(Locking.Type type,
Owner dest,
String lock_name) |
protected void |
PEER_LOCK.sendReleaseLockRequest(String lock_name,
Owner owner) |
protected abstract void |
Locking.sendReleaseLockRequest(String lock_name,
Owner owner) |
protected void |
CENTRAL_LOCK.sendReleaseLockRequest(String lock_name,
Owner owner) |
protected void |
Locking.sendRequest(Address dest,
Locking.Type type,
String lock_name,
Owner owner,
long timeout,
boolean is_trylock) |
protected void |
Locking.sendSignalResponse(Owner dest,
String lock_name) |
protected void |
Locking.ServerLock.setOwner(Owner owner) |
void |
CENTRAL_LOCK.unlocked(String lock_name,
Owner owner) |
protected void |
CENTRAL_LOCK.updateBackups(Locking.Type type,
String lock_name,
Owner owner) |
Constructor and Description |
---|
COUNTER.AddAndGetRequest(Owner owner,
String name,
long value) |
COUNTER.BooleanResponse(Owner owner,
long version,
boolean result) |
COUNTER.CompareAndSetRequest(Owner owner,
String name,
long expected,
long update) |
COUNTER.DeleteRequest(Owner owner,
String name) |
COUNTER.ExceptionResponse(Owner owner,
String error_message) |
COUNTER.GetOrCreateResponse(Owner owner,
long result,
long version) |
COUNTER.SetRequest(Owner owner,
String name,
long value) |
COUNTER.SimpleRequest(Owner owner,
String name) |
COUNTER.SimpleResponse(Owner owner,
long version) |
COUNTER.ValueResponse(Owner owner,
long result,
long version) |
Locking.Request(Locking.Type type,
String lock_name,
Owner owner,
long timeout) |
Locking.Request(Locking.Type type,
String lock_name,
Owner owner,
long timeout,
boolean is_trylock) |
Locking.ServerLock(String lock_name,
Owner owner) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.