Package ubic.gemma.core.util.locking

Class FileLockManagerImpl

java.lang.Object

ubic.gemma.core.util.locking.FileLockManagerImpl

All Implemented Interfaces:

FileLockManager

@Component
public class FileLockManagerImpl
extends Object
implements FileLockManager

Author:

poirigui

Constructor Summary

Constructors

Constructor	Description
FileLockManagerImpl()

Method Summary

Modifier and Type	Method	Description
LockedPath	acquirePathLock(Path path, boolean exclusive)	Lock a given path.
Collection<FileLockInfo>	getAllLockInfos()	Get the lock info for all paths known to the lock manager.
Stream<FileLockInfo>	getAllLockInfosByWalking(Path directory, int maxDepth)	Get the lock info for all paths obtained by walking the given directory.
FileLockInfo	getLockInfo(Path path)	Get the lock info for a given path.
Reader	newBufferedReader(Path path)
Writer	newBufferedWriter(Path path, OpenOption... openOptions)
InputStream	newInputStream(Path path, OpenOption... openOptions)
OutputStream	newOutputStream(Path path, OpenOption... openOptions)
LockedPath	tryAcquirePathLock(Path path, boolean exclusive, long timeout, TimeUnit timeUnit)	Attempt to lock a path.

Methods inherited from class java.lang.Object

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

Constructor Detail

FileLockManagerImpl

public FileLockManagerImpl()

Method Detail

getAllLockInfos

public Collection<FileLockInfo> getAllLockInfos()
                                         throws IOException

Description copied from interface: FileLockManager

Get the lock info for all paths known to the lock manager.

Specified by:

getAllLockInfos in interface FileLockManager

Throws:

IOException

getAllLockInfosByWalking

public Stream<FileLockInfo> getAllLockInfosByWalking(Path directory,
                                                     int maxDepth)
                                              throws IOException

Description copied from interface: FileLockManager

Get the lock info for all paths obtained by walking the given directory.

Specified by:

getAllLockInfosByWalking in interface FileLockManager

Throws:

IOException

getLockInfo

public FileLockInfo getLockInfo(Path path)
                         throws IOException

Description copied from interface: FileLockManager

Get the lock info for a given path.

Specified by:

getLockInfo in interface FileLockManager

Throws:

IOException

acquirePathLock

public LockedPath acquirePathLock(Path path,
                                  boolean exclusive)

Description copied from interface: FileLockManager

Lock a given path.

Specified by:

acquirePathLock in interface FileLockManager

Parameters:

path - the path to lock

exclusive - make the lock exclusive for the purpose of creating of modifying the path

tryAcquirePathLock

public LockedPath tryAcquirePathLock(Path path,
                                     boolean exclusive,
                                     long timeout,
                                     TimeUnit timeUnit)
                              throws TimeoutException,
                                     InterruptedException

Description copied from interface: FileLockManager

Attempt to lock a path.

Specified by:

tryAcquirePathLock in interface FileLockManager

Parameters:

path - the path to lock

exclusive - make the lock exclusive for the purpose of creating of modifying the path

Throws:

TimeoutException - if the lock acquisition timed out

InterruptedException - if the thread was interrupted while waiting for the lock

newInputStream

public InputStream newInputStream(Path path,
                                  OpenOption... openOptions)
                           throws IOException

Specified by:

newInputStream in interface FileLockManager

Throws:

IOException

See Also:

Files.newInputStream(Path, OpenOption...)

newBufferedReader

public Reader newBufferedReader(Path path)
                         throws IOException

Specified by:

newBufferedReader in interface FileLockManager

Throws:

IOException

See Also:

Files.newBufferedReader(Path)

newOutputStream

public OutputStream newOutputStream(Path path,
                                    OpenOption... openOptions)
                             throws IOException

Specified by:

newOutputStream in interface FileLockManager

Throws:

IOException

See Also:

Files.newOutputStream(Path, OpenOption...)

newBufferedWriter

public Writer newBufferedWriter(Path path,
                                OpenOption... openOptions)
                         throws IOException

Specified by:

newBufferedWriter in interface FileLockManager

Throws:

IOException

See Also:

(Path)