Package one.microstream.afs.types

Class AccessManager.Default<S extends AFileSystem>

java.lang.Object

one.microstream.afs.types.AccessManager.Default<S>

All Implemented Interfaces:

AccessManager

Enclosing interface:

AccessManager

public static class AccessManager.Default<S extends AFileSystem>
extends Object
implements AccessManager

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.afs.types.AccessManager

AccessManager.Creator, AccessManager.Default<S extends AFileSystem>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Default(S fileSystem)

Method Summary

Modifier and Type	Method	Description
protected void	decrementDirectoryUsageCount(ADirectory directory)
AReadableFile	downgrade(AWritableFile file)
<R> R	executeMutating(ADirectory directory, Function<? super ADirectory,R> logic)
S	fileSystem()
protected one.microstream.afs.types.AccessManager.Default.DirEntry	getNonNullDirEntry(ADirectory directory)
protected void	incrementDirectoryUsageCount(ADirectory directory)
protected boolean	internalUnregister(AReadableFile file)
protected boolean	internalUnregister(AReadableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)
protected AReadableFile	internalUseReading(AFile file, Object user, one.microstream.afs.types.AccessManager.Default.ConflictHandler conflictHandler)
protected AWritableFile	internalUseWriting(AFile file, Object user, one.microstream.afs.types.AccessManager.Default.ConflictHandler conflictHandler)
boolean	isMutating(ADirectory directory)
boolean	isUsed(ADirectory directory)
boolean	isUsed(AFile file)
boolean	isUsedReading(AFile file)
boolean	isUsedReading(AFile file, Object user)
boolean	isUsedWriting(AFile file)
boolean	isUsedWriting(AFile file, Object user)
protected Object	mutex()
protected void	removeExclusive(AWritableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)
protected static void	throwUnregisteredException(AReadableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)
AReadableFile	tryUseReading(AFile file, Object user)
AWritableFile	tryUseWriting(AFile file, Object user)
boolean	unregister(AReadableFile file)
boolean	unregister(AWritableFile file)
protected void	unregisterExclusive(AWritableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)
protected void	unregisterShared(AReadableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)
AReadableFile	useReading(AFile file, Object user)
AWritableFile	useWriting(AFile file, Object user)
protected void	validateExclusive(AWritableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)

Methods inherited from class java.lang.Object

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

Methods inherited from interface one.microstream.afs.types.AccessManager

defaultUser, tryUseReading, tryUseWriting, useReading, useWriting

Constructor Details

Default

protected Default(S fileSystem)

Method Details

mutex

protected final Object mutex()

fileSystem

public final S fileSystem()

Specified by:

fileSystem in interface AccessManager

isUsed

public boolean isUsed(ADirectory directory)

Specified by:

isUsed in interface AccessManager

isMutating

public boolean isMutating(ADirectory directory)

Specified by:

isMutating in interface AccessManager

isUsed

public boolean isUsed(AFile file)

Specified by:

isUsed in interface AccessManager

isUsedReading

public boolean isUsedReading(AFile file)

Specified by:

isUsedReading in interface AccessManager

isUsedWriting

public boolean isUsedWriting(AFile file)

Specified by:

isUsedWriting in interface AccessManager

isUsedReading

public boolean isUsedReading(AFile file, Object user)

Specified by:

isUsedReading in interface AccessManager

isUsedWriting

public boolean isUsedWriting(AFile file, Object user)

Specified by:

isUsedWriting in interface AccessManager

executeMutating

public final <R> R executeMutating(ADirectory directory, Function<? super ADirectory,R> logic)

Specified by:

executeMutating in interface AccessManager

useReading

public AReadableFile useReading(AFile file, Object user)

Specified by:

useReading in interface AccessManager

tryUseReading

public AReadableFile tryUseReading(AFile file, Object user)

Specified by:

tryUseReading in interface AccessManager

useWriting

public AWritableFile useWriting(AFile file, Object user)

Specified by:

useWriting in interface AccessManager

tryUseWriting

public AWritableFile tryUseWriting(AFile file, Object user)

Specified by:

tryUseWriting in interface AccessManager

incrementDirectoryUsageCount

protected final void incrementDirectoryUsageCount(ADirectory directory)

downgrade

public AReadableFile downgrade(AWritableFile file)

Specified by:

downgrade in interface AccessManager

internalUseReading

protected final AReadableFile internalUseReading(AFile file, Object user, one.microstream.afs.types.AccessManager.Default.ConflictHandler conflictHandler)

internalUseWriting

protected final AWritableFile internalUseWriting(AFile file, Object user, one.microstream.afs.types.AccessManager.Default.ConflictHandler conflictHandler)

unregister

public boolean unregister(AReadableFile file)

Specified by:

unregister in interface AccessManager

unregister

public boolean unregister(AWritableFile file)

Specified by:

unregister in interface AccessManager

internalUnregister

protected boolean internalUnregister(AReadableFile file)

decrementDirectoryUsageCount

protected void decrementDirectoryUsageCount(ADirectory directory)

getNonNullDirEntry

protected final one.microstream.afs.types.AccessManager.Default.DirEntry getNonNullDirEntry(ADirectory directory)

internalUnregister

protected boolean internalUnregister(AReadableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)

unregisterShared

protected void unregisterShared(AReadableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)

unregisterExclusive

protected void unregisterExclusive(AWritableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)

validateExclusive

protected void validateExclusive(AWritableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)

throwUnregisteredException

protected static void throwUnregisteredException(AReadableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)

removeExclusive

protected void removeExclusive(AWritableFile file, one.microstream.afs.types.AccessManager.Default.FileEntry entry)