Package com.linkedin.venice.utils.locks

Class ClusterLockManager

java.lang.Object

com.linkedin.venice.utils.locks.ClusterLockManager

public class ClusterLockManager
extends Object

A centralized place to control the locking behavior, such as lock order and lock granularity. There is 1-1 mapping between ClusterLockManager instances and clusters. One instance only manages locks for one cluster. Each instance has a pair of cluster-level read/write locks and multiple store-level read/write locks. Every store-level read/write lock will take cluster-level read lock first. Locking on the whole cluster, including whole cluster write operations or controller shutdown, will take the cluster-level write lock.

Constructor Summary

Constructors

Constructor	Description
ClusterLockManager(String clusterName)

Method Summary

Modifier and Type	Method	Description
void	clear()
AutoCloseableLock	createClusterReadLock()
AutoCloseableLock	createClusterWriteLock()
AutoCloseableLock	createStoreReadLock(String storeName)
AutoCloseableLock	createStoreWriteLock(String storeName)
AutoCloseableLock	createStoreWriteLockOnly(String storeName)

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterLockManager

public ClusterLockManager(String clusterName)

Method Details

createClusterWriteLock

public AutoCloseableLock createClusterWriteLock()

createClusterReadLock

public AutoCloseableLock createClusterReadLock()

createStoreReadLock

public AutoCloseableLock createStoreReadLock(String storeName)

createStoreWriteLock

public AutoCloseableLock createStoreWriteLock(String storeName)

createStoreWriteLockOnly

public AutoCloseableLock createStoreWriteLockOnly(String storeName)

clear

public void clear()