com.fr.third.jgroups.protocols

类 Locking

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Locking

直接已知子类:

CENTRAL_LOCK, PEER_LOCK

public abstract class Locking
extends Protocol

Base locking protocol, handling most of the protocol communication with other instances. To use distributed locking, LockService is placed on a channel. LockService talks to a subclass of Locking via events.

从以下版本开始:

2.12

作者:

Bela Ban

另请参阅:

CENTRAL_LOCK

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	Locking.ClientCondition
protected class	Locking.ClientLock Implementation of Lock.
protected class	Locking.ClientLockTable Manages access to client locks
static class	Locking.LockingHeader
protected static class	Locking.Request
protected static class	Locking.Response A response to a request, to be sent back to the requester as a message
protected class	Locking.ServerCondition
protected class	Locking.ServerLock Server side queue for handling of lock requests (lock, release).
protected static class	Locking.Type

字段概要

字段

限定符和类型	字段和说明
protected boolean	bypass_bundling
protected Locking.ClientLockTable	client_lock_table
protected static java.util.concurrent.atomic.AtomicInteger	current_lock_id
protected Address	local_addr
protected java.util.Set<LockNotification>	lock_listeners
protected java.util.concurrent.locks.Lock[]	lock_stripes
protected int	lock_striping_size
protected java.util.concurrent.ConcurrentMap<java.lang.String,Locking.ServerLock>	server_locks
protected View	view

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

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

构造器概要

构造器

构造器和说明
Locking()

方法概要

方法

限定符和类型	方法和说明
protected java.util.concurrent.locks.Lock	_getLock(java.lang.String lock_name) Gets a lock from locks based on the hash of the lock name
void	addLockListener(LockNotification listener)
protected Locking.ClientLock	createLock(java.lang.String lock_name, Owner owner)
java.lang.Object	down(Event evt) An event is to be sent down the stack.
java.lang.String	getAddress()
boolean	getBypassBundling()
protected Locking.ClientLock	getLock(java.lang.String name)
protected Locking.ClientLock	getLock(java.lang.String name, boolean create_if_absent)
protected Owner	getOwner()
java.lang.String	getView()
protected void	handleAwaitRequest(java.lang.String lock_name, Owner owner)
protected void	handleCreateAwaitingRequest(java.lang.String lock_name, Owner owner)
protected void	handleCreateLockRequest(java.lang.String lock_name, Owner owner)
protected void	handleDeleteAwaitingRequest(java.lang.String lock_name, Owner owner)
protected void	handleDeleteAwaitRequest(java.lang.String lock_name, Owner owner)
protected void	handleDeleteLockRequest(java.lang.String lock_name)
protected void	handleLockDeniedResponse(java.lang.String lock_name, int lock_id, Owner owner)
protected void	handleLockGrantedResponse(java.lang.String lock_name, int lock_id, Owner owner)
protected void	handleLockRequest(Locking.Request req)
protected void	handleSignalRequest(Locking.Request req)
protected void	handleSignalResponse(java.lang.String lock_name, Owner owner)
protected void	handleView(View view)
void	init() Called after instance has been created (null constructor) and before protocol is started.
protected void	notifyAwaited(java.lang.String lock_name, Owner owner)
protected void	notifyAwaiting(java.lang.String lock_name, Owner owner)
protected void	notifyLockCreated(java.lang.String lock_name)
protected void	notifyLockDeleted(java.lang.String lock_name)
protected void	notifyLocked(java.lang.String lock_name, Owner owner)
protected void	notifyUnlocked(java.lang.String lock_name, Owner owner)
java.lang.String	printLocks()
void	removeLockListener(LockNotification listener)
protected void	send(Address dest, Locking.Request req)
protected abstract void	sendAwaitConditionRequest(java.lang.String lock_name, Owner owner)
protected abstract void	sendDeleteAwaitConditionRequest(java.lang.String lock_name, Owner owner)
protected abstract void	sendGrantLockRequest(java.lang.String lock_name, int lock_id, Owner owner, long timeout, boolean is_trylock)
protected void	sendLockResponse(Locking.Type type, Owner dest, java.lang.String lock_name, int lock_id)
protected abstract void	sendReleaseLockRequest(java.lang.String lock_name, Owner owner)
protected void	sendRequest(Address dest, Locking.Type type, java.lang.String lock_name, int lock_id, Owner owner, long timeout, boolean is_trylock)
protected void	sendRequest(Address dest, Locking.Type type, java.lang.String lock_name, Owner owner, long timeout, boolean is_trylock)
protected abstract void	sendSignalConditionRequest(java.lang.String lock_name, boolean all)
protected void	sendSignalResponse(Owner dest, java.lang.String lock_name)
void	setBypassBundling(boolean bypass_bundling)
void	unlockAll()
java.lang.Object	up(Event evt) An event was received from the layer below.

从类继承的方法 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

字段详细资料

bypass_bundling

protected boolean bypass_bundling

lock_striping_size

protected int lock_striping_size

local_addr

protected Address local_addr

view

protected View view

server_locks

protected final java.util.concurrent.ConcurrentMap<java.lang.String,Locking.ServerLock> server_locks

lock_stripes

protected java.util.concurrent.locks.Lock[] lock_stripes

client_lock_table

protected final Locking.ClientLockTable client_lock_table

lock_listeners

protected final java.util.Set<LockNotification> lock_listeners

current_lock_id

protected static final java.util.concurrent.atomic.AtomicInteger current_lock_id

构造器详细资料

Locking

public Locking()

方法详细资料

getBypassBundling

public boolean getBypassBundling()

setBypassBundling

public void setBypassBundling(boolean bypass_bundling)

addLockListener

public void addLockListener(LockNotification listener)

removeLockListener

public void removeLockListener(LockNotification listener)

getAddress

public java.lang.String getAddress()

getView

public java.lang.String getView()

init

public void init()
          throws java.lang.Exception

从类复制的说明: Protocol

Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.

覆盖:

init 在类中 Protocol

抛出:

java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the channel constructor will throw an exception

down

public java.lang.Object down(Event evt)

从类复制的说明: Protocol

An event is to be sent down the stack. The layer may want to examine its type and perform some action on it, depending on the event's type. If the event is a message MSG, then the layer may need to add a header to it (or do nothing at all) before sending it down the stack using down_prot.down(). In case of a GET_ADDRESS event (which tries to retrieve the stack's address from one of the bottom layers), the layer may need to send a new response event back up the stack using up_prot.up().

覆盖:

down 在类中 Protocol

up

public java.lang.Object up(Event evt)

从类复制的说明: Protocol

An event was received from the layer below. Usually the current layer will want to examine the event type and - depending on its type - perform some computation (e.g. removing headers from a MSG event type, or updating the internal membership list when receiving a VIEW_CHANGE event). Finally the event is either a) discarded, or b) an event is sent down the stack using down_prot.down() or c) the event (or another event) is sent up the stack using up_prot.up().

覆盖:

up 在类中 Protocol

getLock

protected Locking.ClientLock getLock(java.lang.String name)

getLock

protected Locking.ClientLock getLock(java.lang.String name,
                         boolean create_if_absent)

unlockAll

public void unlockAll()

printLocks

public java.lang.String printLocks()

handleView

protected void handleView(View view)

createLock

protected Locking.ClientLock createLock(java.lang.String lock_name,
                            Owner owner)

_getLock

protected java.util.concurrent.locks.Lock _getLock(java.lang.String lock_name)

Gets a lock from locks based on the hash of the lock name

getOwner

protected Owner getOwner()

sendGrantLockRequest

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

sendReleaseLockRequest

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

sendAwaitConditionRequest

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

sendSignalConditionRequest

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

sendDeleteAwaitConditionRequest

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

sendRequest

protected void sendRequest(Address dest,
               Locking.Type type,
               java.lang.String lock_name,
               Owner owner,
               long timeout,
               boolean is_trylock)

sendRequest

protected void sendRequest(Address dest,
               Locking.Type type,
               java.lang.String lock_name,
               int lock_id,
               Owner owner,
               long timeout,
               boolean is_trylock)

sendLockResponse

protected void sendLockResponse(Locking.Type type,
                    Owner dest,
                    java.lang.String lock_name,
                    int lock_id)

sendSignalResponse

protected void sendSignalResponse(Owner dest,
                      java.lang.String lock_name)

send

protected void send(Address dest,
        Locking.Request req)

handleLockRequest

protected void handleLockRequest(Locking.Request req)

handleLockGrantedResponse

protected void handleLockGrantedResponse(java.lang.String lock_name,
                             int lock_id,
                             Owner owner)

handleLockDeniedResponse

protected void handleLockDeniedResponse(java.lang.String lock_name,
                            int lock_id,
                            Owner owner)

handleAwaitRequest

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

handleDeleteAwaitRequest

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

handleSignalResponse

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

handleSignalRequest

protected void handleSignalRequest(Locking.Request req)

handleCreateLockRequest

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

handleDeleteLockRequest

protected void handleDeleteLockRequest(java.lang.String lock_name)

handleCreateAwaitingRequest

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

handleDeleteAwaitingRequest

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

notifyLockCreated

protected void notifyLockCreated(java.lang.String lock_name)

notifyLockDeleted

protected void notifyLockDeleted(java.lang.String lock_name)

notifyLocked

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

notifyUnlocked

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

notifyAwaiting

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

notifyAwaited

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