Package org.aksw.commons.lock.db.impl

Class LockStoreImpl.ResourceLockImpl

java.lang.Object

org.aksw.commons.lock.db.impl.LockStoreImpl.ResourceLockImpl

All Implemented Interfaces:

ResourceLock<String>

Enclosing class:

LockStoreImpl

public class LockStoreImpl.ResourceLockImpl
extends Object
implements ResourceLock<String>

Field Summary

Fields

Modifier and Type	Field	Description
protected Path	lockAbsPath
protected org.aksw.commons.path.core.Path<String>	lockKey
protected Path	mgmtLockPath	The management lock file which when exists prevents modification of the read/write lock ownerships by other processes
protected Path	writeLockPath

Constructor Summary

Constructors

Constructor	Description
ResourceLockImpl(org.aksw.commons.path.core.Path<String> lockKey)

Method Summary

Modifier and Type	Method	Description
protected LockFromLockStore	createLockOwner(String ownerKey)
ReadWriteLockWithOwnership	get(String ownerKey)
String	getMgmtLockOwnerKey()	Get an exclusive lock on the lock which prevents concurent modification of the state of the read locks or the write lock.
String	getOwnerKey(Path linkFile)
Path	getWriteLock()
String	getWriteLockOwnerKey()	null if the write lock is not owned
String	linkTargetToKey(Path path)
Stream<String>	streamReadLockOwnerKeys()	Owner to lock
Stream<Path>	streamReadLockPaths()

Methods inherited from class java.lang.Object

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

Field Details

lockKey

protected org.aksw.commons.path.core.Path<String> lockKey

lockAbsPath

protected Path lockAbsPath

mgmtLockPath

protected Path mgmtLockPath

The management lock file which when exists prevents modification of the read/write lock ownerships by other processes

writeLockPath

protected Path writeLockPath

Constructor Details

ResourceLockImpl

public ResourceLockImpl(org.aksw.commons.path.core.Path<String> lockKey)

Method Details

getMgmtLockOwnerKey

public String getMgmtLockOwnerKey()

Description copied from interface: ResourceLock

Get an exclusive lock on the lock which prevents concurent modification of the state of the read locks or the write lock. This means that the

invalid reference

#acquireReadLock(Object)

and

invalid reference

#acquireWriteLock(Object)

methods both need to acquire the management lock first

Specified by:

getMgmtLockOwnerKey in interface ResourceLock<String>

Returns:

getWriteLock

public Path getWriteLock()

get

public ReadWriteLockWithOwnership get(String ownerKey)

Specified by:

get in interface ResourceLock<String>

streamReadLockPaths

public Stream<Path> streamReadLockPaths()
                                 throws IOException

Throws:

IOException

linkTargetToKey

public String linkTargetToKey(Path path)

getOwnerKey

public String getOwnerKey(Path linkFile)

streamReadLockOwnerKeys

public Stream<String> streamReadLockOwnerKeys()
                                       throws IOException

Description copied from interface: ResourceLock

Owner to lock

Specified by:

streamReadLockOwnerKeys in interface ResourceLock<String>

Throws:

IOException

getWriteLockOwnerKey

public String getWriteLockOwnerKey()
                            throws IOException

Description copied from interface: ResourceLock

null if the write lock is not owned

Specified by:

getWriteLockOwnerKey in interface ResourceLock<String>

Throws:

IOException

createLockOwner

protected LockFromLockStore createLockOwner(String ownerKey)