alluxio.master.file.meta

Class InodeLockManager

java.lang.Object

alluxio.master.file.meta.InodeLockManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class InodeLockManager
extends Object
implements Closeable

Class for managing inode locking. We manage locks centrally instead of embedded in the inode tree. This allows us to create locks only as needed, and garbage collect locks that aren't in use. As a result, we save memory when the inode tree contains many millions of files. We use WeakSafeReentrantReadWriteLock instead of ReentrantReadWriteLock because the read locks and write locks returned by ReentrantReadWriteLock do not contain a reference to the original ReentrantReadWriteLock, so the original lock can be garbage collected early. WeakSafeReentrantReadWriteLock stores the reference to the original lock to avoid this problem. See https://github.com/google/guava/issues/2477

Constructor Summary

Constructors

Constructor and Description
InodeLockManager() Creates a new instance of InodeLockManager.

Method Summary

Modifier and Type	Method and Description
void	assertAllLocksReleased() Asserts that all locks have been released, throwing an exception if any locks are still taken.
void	close()
RWLockResource	lockEdge(Edge edge, LockMode mode, boolean useTryLock) Acquires an edge lock.
RWLockResource	lockInode(InodeView inode, LockMode mode, boolean useTryLock) Acquires an inode lock.
LockResource	lockUpdate(long inodeId) Acquires the lock for modifying an inode's last modified time or size.
Optional<Scoped>	tryAcquirePersistingLock(long inodeId) Tries to acquire a lock for persisting the specified inode id.
Optional<RWLockResource>	tryLockEdge(Edge edge, LockMode mode) Attempts to acquire an edge lock.
Optional<RWLockResource>	tryLockInode(Long inodeId, LockMode mode) Attempts to acquire an inode lock.

Methods inherited from class java.lang.Object

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

Constructor Detail

InodeLockManager

public InodeLockManager()

Creates a new instance of InodeLockManager.

Method Detail

assertAllLocksReleased

public void assertAllLocksReleased()

Asserts that all locks have been released, throwing an exception if any locks are still taken.

lockInode

public RWLockResource lockInode(InodeView inode,
                                LockMode mode,
                                boolean useTryLock)

Acquires an inode lock.

Parameters:

inode - the inode to lock

mode - the mode to lock in

useTryLock - whether to acquire with Lock.tryLock() or Lock.lock(). This method differs from tryLockInode(Long, LockMode) because it will block until the inode has been successfully locked.

Returns:

a lock resource which must be closed to release the lock

See Also:

tryLockInode(Long, LockMode)

tryLockInode

public Optional<RWLockResource> tryLockInode(Long inodeId,
                                             LockMode mode)

Attempts to acquire an inode lock.

Parameters:

inodeId - the inode id to try locking

mode - the mode to lock in

Returns:

either an empty optional, or a lock resource which must be closed to release the lock

lockEdge

public RWLockResource lockEdge(Edge edge,
                               LockMode mode,
                               boolean useTryLock)

Acquires an edge lock.

Parameters:

edge - the edge to lock

mode - the mode to lock in

useTryLock - whether to acquire with Lock.tryLock() or Lock.lock(). This method differs from tryLockEdge(Edge, LockMode) because it will block until the edge has been successfully locked.

Returns:

a lock resource which must be closed to release the lock

See Also:

tryLockEdge(Edge, LockMode)

tryLockEdge

public Optional<RWLockResource> tryLockEdge(Edge edge,
                                            LockMode mode)

Attempts to acquire an edge lock.

Parameters:

edge - the edge to try locking

mode - the mode to lock in

Returns:

either an empty optional, or a lock resource which must be closed to release the lock

tryAcquirePersistingLock

public Optional<Scoped> tryAcquirePersistingLock(long inodeId)

Tries to acquire a lock for persisting the specified inode id.

Parameters:

inodeId - the inode to acquire the lock for

Returns:

an optional wrapping a closure for releasing the lock on success, or Optional.empty if the lock is already taken

lockUpdate

public LockResource lockUpdate(long inodeId)

Acquires the lock for modifying an inode's last modified time or size. As a pre-requisite, the current thread should already hold a read lock on the inode.

Parameters:

inodeId - the id of the inode to lock

Returns:

a lock resource which must be closed to release the lock

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException