com.fr.third.jgroups.protocols

类 PEER_LOCK

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Locking

com.fr.third.jgroups.protocols.PEER_LOCK

public class PEER_LOCK
extends Locking

Implementation of a locking protocol which acquires locks by contacting all of the nodes of a cluster.

Unless a total order configuration is used (e.g. SEQUENCER based), lock requests for the same resource from different senders may be received in different order, so deadlocks can occur. Example:

 - Nodes A and B
 - A and B call lock(X) at the same time
 - A receives L(X,A) followed by L(X,B): locks X(A), queues L(X,B)
 - B receives L(X,B) followed by L(X,A): locks X(B), queues L(X,A)
 

To acquire a lock, we need lock grants from both A and B, but this will never happen here. To fix this, either add SEQUENCER to the configuration, so that all lock requests are received in the same global order at both A and B, or use Lock.tryLock(long, java.util.concurrent.TimeUnit) with retries if a lock cannot be acquired.

An alternative is also the CENTRAL_LOCK protocol.

从以下版本开始:

2.12

作者:

Bela Ban

另请参阅:

Locking, CENTRAL_LOCK

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	PEER_LOCK.PeerLock Lock implementation which grants a lock when all non faulty cluster members OK it.

从类继承的嵌套类/接口 com.fr.third.jgroups.protocols.Locking

Locking.ClientCondition, Locking.ClientLock, Locking.ClientLockTable, Locking.LockingHeader, Locking.Request, Locking.Response, Locking.ServerCondition, Locking.ServerLock, Locking.Type

字段概要

从类继承的字段 com.fr.third.jgroups.protocols.Locking

bypass_bundling, client_lock_table, current_lock_id, local_addr, lock_listeners, lock_stripes, lock_striping_size, server_locks, view

从类继承的字段 com.fr.third.jgroups.stack.Protocol

down_prot, ergonomics, id, log, name, stack, stats, up_prot

构造器概要

构造器

构造器和说明
PEER_LOCK()

方法概要

方法

限定符和类型	方法和说明
protected Locking.ClientLock	createLock(java.lang.String lock_name)
void	handleView(View view)
protected void	sendAwaitConditionRequest(java.lang.String lock_name, Owner owner)
protected void	sendDeleteAwaitConditionRequest(java.lang.String lock_name, Owner owner)
protected void	sendGrantLockRequest(java.lang.String lock_name, int lock_id, Owner owner, long timeout, boolean is_trylock)
protected void	sendReleaseLockRequest(java.lang.String lock_name, Owner owner)
protected void	sendSignalConditionRequest(java.lang.String lock_name, boolean all)

从类继承的方法 com.fr.third.jgroups.protocols.Locking

_getLock, addLockListener, createLock, down, getAddress, getBypassBundling, getLock, getLock, getOwner, getView, handleAwaitRequest, handleCreateAwaitingRequest, handleCreateLockRequest, handleDeleteAwaitingRequest, handleDeleteAwaitRequest, handleDeleteLockRequest, handleLockDeniedResponse, handleLockGrantedResponse, handleLockRequest, handleSignalRequest, handleSignalResponse, init, notifyAwaited, notifyAwaiting, notifyLockCreated, notifyLockDeleted, notifyLocked, notifyUnlocked, printLocks, removeLockListener, send, sendLockResponse, sendRequest, sendRequest, sendSignalResponse, setBypassBundling, unlockAll, up

从类继承的方法 com.fr.third.jgroups.stack.Protocol

accept, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, resetStats, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, start, statsEnabled, stop, up

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

PEER_LOCK

public PEER_LOCK()

方法详细资料

sendGrantLockRequest

protected void sendGrantLockRequest(java.lang.String lock_name,
                        int lock_id,
                        Owner owner,
                        long timeout,
                        boolean is_trylock)

指定者:

sendGrantLockRequest 在类中 Locking

sendReleaseLockRequest

protected void sendReleaseLockRequest(java.lang.String lock_name,
                          Owner owner)

指定者:

sendReleaseLockRequest 在类中 Locking

sendAwaitConditionRequest

protected void sendAwaitConditionRequest(java.lang.String lock_name,
                             Owner owner)

指定者:

sendAwaitConditionRequest 在类中 Locking

sendSignalConditionRequest

protected void sendSignalConditionRequest(java.lang.String lock_name,
                              boolean all)

指定者:

sendSignalConditionRequest 在类中 Locking

sendDeleteAwaitConditionRequest

protected void sendDeleteAwaitConditionRequest(java.lang.String lock_name,
                                   Owner owner)

指定者:

sendDeleteAwaitConditionRequest 在类中 Locking

handleView

public void handleView(View view)

覆盖:

handleView 在类中 Locking

createLock

protected Locking.ClientLock createLock(java.lang.String lock_name)