Package org.jgroups.protocols

Class CENTRAL_LOCK

java.lang.Object

org.jgroups.stack.Protocol

org.jgroups.protocols.Locking

org.jgroups.protocols.CENTRAL_LOCK

All Implemented Interfaces:

LockNotification, Lifecycle

@Deprecated
public class CENTRAL_LOCK
extends Locking
implements LockNotification

Deprecated.

See http://belaban.blogspot.com/2020/11/i-hate-distributed-locks.html.

Implementation of a locking protocol which acquires locks by contacting the coordinator.

Because the coordinator maintains all locks, no total order configuration is required.

CENTRAL_LOCK has all members send lock and unlock requests to a central coordinator. The coordinator has a queue for incoming requests, and grants locks based on order of arrival. To prevent all acquired locks from being forgotten when the coordinator crashes, setting num_backups lets the coordinator backup lock information to a number of backup nodes. Valid values for num_backups are 0 (no backup) to N-1, e.g. in a cluster of 4, we can have only 3 backup nodes.

Say we have a cluster of {A,B,C,D,E} and num_backups=1. A is the coordinator, and A updates all locks (and released locks) in B as well. When A crashes, everybody falls over to B for sending lock and unlock requests. B in turn copies all existing locks over to C and - when locks are acquired or released - forwards this information to C as well.

Since:

2.12

See Also:

• Locking

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.protocols.Locking

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

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<Address>	backups	Deprecated.
protected Address	coord	Deprecated.
protected boolean	is_coord	Deprecated.
protected int	num_backups	Deprecated.

Fields inherited from class org.jgroups.protocols.Locking

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

Fields inherited from class org.jgroups.stack.Protocol

after_creation_hook, down_prot, ergonomics, id, local_addr, log, policies, stack, stats, up_prot

Constructor Summary

Constructors

Constructor	Description
CENTRAL_LOCK()	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	awaited(String lock_name, Owner owner)	Deprecated.
void	awaiting(String lock_name, Owner owner)	Deprecated.
protected void	copyLocksTo(List<Address> new_joiners)	Deprecated.
String	getBackups()	Deprecated.
Address	getCoord()	Deprecated.
String	getCoordinator()	Deprecated.
int	getNumberOfBackups()	Deprecated.
protected Owner	getOwner()	Deprecated.
void	handleView(View view)	Deprecated.
boolean	isCoord()	Deprecated.
void	lockCreated(String name)	Deprecated.
void	lockDeleted(String name)	Deprecated.
void	locked(String lock_name, Owner owner)	Deprecated.
void	lockRevoked(String lock_name, Owner current_owner)	Deprecated.
protected void	sendAwaitConditionRequest(String lock_name, Owner owner)	Deprecated.
protected void	sendCreateLockRequest(Address dest, String lock_name, Owner owner)	Deprecated.
protected void	sendDeleteAwaitConditionRequest(String lock_name, Owner owner)	Deprecated.
protected void	sendDeleteLockRequest(Address dest, String lock_name)	Deprecated.
protected void	sendGrantLockRequest(String lock_name, int lock_id, Owner owner, long timeout, boolean is_trylock)	Deprecated.
protected void	sendReleaseLockRequest(String lock_name, int lock_id, Owner owner)	Deprecated.
protected void	sendSignalConditionRequest(String lock_name, boolean all)	Deprecated.
CENTRAL_LOCK	setNumberOfBackups(int num_backups)	Deprecated.
void	unlocked(String lock_name, Owner owner)	Deprecated.
protected void	updateBackups(Locking.Type type, String lock_name, Owner owner)	Deprecated.

Methods inherited from class org.jgroups.protocols.Locking

_getLock, addLockListener, bypassBundling, bypassBundling, createLock, down, getLock, getLock, getLockStripingSize, getNumClientLocks, getNumServerLocks, getView, handleAwaitRequest, handleCreateAwaitingRequest, handleCreateLockRequest, handleDeleteAwaitingRequest, handleDeleteAwaitRequest, handleDeleteLockRequest, handleLockDeniedResponse, handleLockGrantedResponse, handleLockInfoRequest, handleLockInfoResponse, handleLockReleasedResponse, handleLockRequest, handleLockRevoked, handleRequest, handleSignalRequest, handleSignalResponse, init, notifyAwaited, notifyAwaiting, notifyLockCreated, notifyLockDeleted, notifyLocked, notifyLockRevoked, notifyUnlocked, printLocks, printServerLocks, removeLockListener, requestReceived, send, sendLockResponse, sendRequest, sendRequest, sendSignalResponse, setLockStripingSize, unlockAll, unlockForce, up, up, useThreadIdForLockOwner, useThreadIdForLockOwner

Methods inherited from class org.jgroups.stack.Protocol

accept, addPolicy, addr, addr, afterCreationHook, destroy, down, down, enableStats, getAddress, getComponents, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getPolicies, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, policies, providedDownServices, providedUpServices, removePolicy, requiredDownServices, requiredUpServices, resetStatistics, resetStats, setAddress, setDownProtocol, setErgonomics, setId, setLevel, setPolicies, setProtocolStack, setSocketFactory, setUpProtocol, setValue, start, statsEnabled, stop, toString, up

Methods inherited from class java.lang.Object

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

Field Details

num_backups

protected int num_backups

Deprecated.

coord

protected Address coord

Deprecated.

is_coord

protected boolean is_coord

Deprecated.

backups

protected final List<Address> backups

Deprecated.

Constructor Details

CENTRAL_LOCK

public CENTRAL_LOCK()

Deprecated.

Method Details

getOwner

protected Owner getOwner()

Deprecated.

Overrides:

getOwner in class Locking

getCoord

public Address getCoord()

Deprecated.

isCoord

public boolean isCoord()

Deprecated.

getCoordinator

public String getCoordinator()

Deprecated.

getNumberOfBackups

public int getNumberOfBackups()

Deprecated.

setNumberOfBackups

public CENTRAL_LOCK setNumberOfBackups(int num_backups)

Deprecated.

getBackups

public String getBackups()

Deprecated.

sendGrantLockRequest

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

Deprecated.

Specified by:

sendGrantLockRequest in class Locking

sendReleaseLockRequest

protected void sendReleaseLockRequest(String lock_name,
 int lock_id,
 Owner owner)

Deprecated.

Specified by:

sendReleaseLockRequest in class Locking

sendCreateLockRequest

protected void sendCreateLockRequest(Address dest,
 String lock_name,
 Owner owner)

Deprecated.

sendDeleteLockRequest

protected void sendDeleteLockRequest(Address dest,
 String lock_name)

Deprecated.

sendAwaitConditionRequest

protected void sendAwaitConditionRequest(String lock_name,
 Owner owner)

Deprecated.

Specified by:

sendAwaitConditionRequest in class Locking

sendSignalConditionRequest

protected void sendSignalConditionRequest(String lock_name,
 boolean all)

Deprecated.

Specified by:

sendSignalConditionRequest in class Locking

sendDeleteAwaitConditionRequest

protected void sendDeleteAwaitConditionRequest(String lock_name,
 Owner owner)

Deprecated.

Specified by:

sendDeleteAwaitConditionRequest in class Locking

handleView

public void handleView(View view)

Deprecated.

Overrides:

handleView in class Locking

lockCreated

public void lockCreated(String name)

Deprecated.

Specified by:

lockCreated in interface LockNotification

lockDeleted

public void lockDeleted(String name)

Deprecated.

Specified by:

lockDeleted in interface LockNotification

locked

public void locked(String lock_name,
 Owner owner)

Deprecated.

Specified by:

locked in interface LockNotification

unlocked

public void unlocked(String lock_name,
 Owner owner)

Deprecated.

Specified by:

unlocked in interface LockNotification

lockRevoked

public void lockRevoked(String lock_name,
 Owner current_owner)

Deprecated.

Specified by:

lockRevoked in interface LockNotification

awaiting

public void awaiting(String lock_name,
 Owner owner)

Deprecated.

Specified by:

awaiting in interface LockNotification

awaited

public void awaited(String lock_name,
 Owner owner)

Deprecated.

Specified by:

awaited in interface LockNotification

updateBackups

protected void updateBackups(Locking.Type type,
 String lock_name,
 Owner owner)

Deprecated.

copyLocksTo

protected void copyLocksTo(List<Address> new_joiners)

Deprecated.