alluxio.master.file.meta

Class InodeTreePersistentState

java.lang.Object

alluxio.master.file.meta.InodeTreePersistentState

All Implemented Interfaces:

Checkpointed, Journaled, JournalEntryIterable

public class InodeTreePersistentState
extends java.lang.Object
implements Journaled

Class for managing persistent inode tree state. This class owns all persistent inode tree state, and all inode tree modifications must go through this class. To modify the inode tree, create a journal entry and call one of the applyAndJournal methods.

Constructor Summary

Constructors

Constructor and Description
InodeTreePersistentState(InodeStore inodeStore, InodeLockManager lockManager, TtlBucketList ttlBucketList)

Method Summary

Modifier and Type	Method and Description
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, File.DeleteFileEntry entry) Deletes an inode (may be either a file or directory).
long	applyAndJournal(java.util.function.Supplier<JournalContext> context, File.NewBlockEntry entry) Allocates and returns the next block ID for the indicated inode.
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, File.RenameEntry entry) Renames an inode.
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, File.SetAclEntry entry) Sets an ACL for an inode.
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, File.UpdateInodeDirectoryEntry entry) Updates an inode directory's state.
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, File.UpdateInodeEntry entry) Updates an inode's state.
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, File.UpdateInodeFileEntry entry) Updates an inode file's state.
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, MutableInode<?> inode, java.lang.String path) Adds an inode to the inode tree.
File.UpdateInodeEntry	applyInodeAccessTime(long inodeId, long accessTime) Updates last access time for Inode without journaling.
CheckpointName	getCheckpointName()
long	getInodeCount()
java.util.Iterator<Journal.JournalEntry>	getJournalEntryIterator()
java.util.Set<java.lang.Long>	getPinnedInodeFileIds()
java.util.Set<java.lang.Long>	getReplicationLimitedFileIds()
InodeDirectory	getRoot()
java.util.Set<java.lang.Long>	getToBePersistedIds()
boolean	processJournalEntry(Journal.JournalEntry entry)
void	resetState()
void	restoreFromCheckpoint(CheckpointInputStream input)
void	writeToCheckpoint(java.io.OutputStream output)

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal

Constructor Detail

InodeTreePersistentState

public InodeTreePersistentState(InodeStore inodeStore,
                                InodeLockManager lockManager,
                                TtlBucketList ttlBucketList)

Parameters:

inodeStore - file store which holds inode metadata

lockManager - manager for inode locks

ttlBucketList - reference to the ttl bucket list so that the list can be updated when the inode tree is modified

Method Detail

getReplicationLimitedFileIds

public java.util.Set<java.lang.Long> getReplicationLimitedFileIds()

Returns:

an unmodifiable view of the replication limited file ids

getRoot

public InodeDirectory getRoot()

Returns:

the root of the inode tree

getPinnedInodeFileIds

public java.util.Set<java.lang.Long> getPinnedInodeFileIds()

Returns:

the pinned inode file ids;

getInodeCount

public long getInodeCount()

Returns:

the number of inodes in the tree

getToBePersistedIds

public java.util.Set<java.lang.Long> getToBePersistedIds()

Returns:

an unmodifiable view of the files with persistence state PersistenceState.TO_BE_PERSISTED

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            File.DeleteFileEntry entry)

Deletes an inode (may be either a file or directory).

Parameters:

context - journal context supplier

entry - delete file entry

applyAndJournal

public long applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            File.NewBlockEntry entry)

Allocates and returns the next block ID for the indicated inode.

Parameters:

context - journal context supplier

entry - new block entry

Returns:

the new block id

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            File.RenameEntry entry)

Renames an inode.

Parameters:

context - journal context supplier

entry - rename entry

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            File.SetAclEntry entry)

Sets an ACL for an inode.

Parameters:

context - journal context supplier

entry - set acl entry

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            File.UpdateInodeEntry entry)

Updates an inode's state. This is used for state common to both files and directories.

Parameters:

context - journal context supplier

entry - update inode entry

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            File.UpdateInodeDirectoryEntry entry)

Updates an inode directory's state.

Parameters:

context - journal context supplier

entry - update inode directory entry

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            File.UpdateInodeFileEntry entry)

Updates an inode file's state.

Parameters:

context - journal context supplier

entry - update inode file entry

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            MutableInode<?> inode,
                            java.lang.String path)

Adds an inode to the inode tree.

Parameters:

context - journal context supplier

inode - an inode to add and create a journal entry for

path - path of the new inode

applyInodeAccessTime

public File.UpdateInodeEntry applyInodeAccessTime(long inodeId,
                                                  long accessTime)

Updates last access time for Inode without journaling. The caller should apply the journal entry separately.

Parameters:

inodeId - the id of the target inode

accessTime - the new value for last access time

Returns:

the journal entry that represents the update

processJournalEntry

public boolean processJournalEntry(Journal.JournalEntry entry)

Specified by:

processJournalEntry in interface Journaled

resetState

public void resetState()

Specified by:

resetState in interface Journaled

writeToCheckpoint

public void writeToCheckpoint(java.io.OutputStream output)
                       throws java.io.IOException,
                              java.lang.InterruptedException

Specified by:

writeToCheckpoint in interface Checkpointed

Specified by:

writeToCheckpoint in interface Journaled

Throws:

java.io.IOException

java.lang.InterruptedException

restoreFromCheckpoint

public void restoreFromCheckpoint(CheckpointInputStream input)
                           throws java.io.IOException

Specified by:

restoreFromCheckpoint in interface Checkpointed

Specified by:

restoreFromCheckpoint in interface Journaled

Throws:

java.io.IOException

getJournalEntryIterator

public java.util.Iterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

getCheckpointName

public CheckpointName getCheckpointName()

Specified by:

getCheckpointName in interface Checkpointed