alluxio.master.file

Class MetadataSyncLockManager

java.lang.Object

alluxio.master.file.MetadataSyncLockManager

public class MetadataSyncLockManager
extends Object

Class for managing metadata sync locking.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MetadataSyncLockManager.MetadataSyncPathList Represents a locked path for a metadata sync path.

Constructor Summary

Constructors

Constructor and Description
MetadataSyncLockManager()

Method Summary

Modifier and Type	Method and Description
int	getLockPoolSize()
MetadataSyncLockManager.MetadataSyncPathList	lockPath(AlluxioURI uri) Acquire locks for a given path before metadata sync.

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataSyncLockManager

public MetadataSyncLockManager()

Method Detail

lockPath

public MetadataSyncLockManager.MetadataSyncPathList lockPath(AlluxioURI uri)
                                                      throws InvalidPathException,
                                                             IOException

Acquire locks for a given path before metadata sync. Locks are for leading paths of a uri instead of inodes and hence paths will be locked regardless if they exist in alluxio or not. All locks but the last one will be read locks and the last lock acquired will be a write lock. For example, for path /a/b/c/d, this method will acquire the following locks sequentially 1. a read lock on / 2. a read lock on /a/ 3. a read lock on /a/b/ 4. a read lock on /a/b/c/ 5. a write lock on /a/b/c/d/

Parameters:

uri - the alluxio uri to perform metadata sync

Returns:

the MetadataSyncLockManager.MetadataSyncPathList representing the locked paths

Throws:

InvalidPathException

IOException

getLockPoolSize

public int getLockPoolSize()

Returns:

the size of the lock pool