alluxio.master.file

Class UfsSyncChecker

java.lang.Object

alluxio.master.file.UfsSyncChecker

@NotThreadSafe
public final class UfsSyncChecker
extends java.lang.Object

Class to check if the contents of the under storage is in-sync with the master.

Constructor Summary

Constructors

Constructor and Description
UfsSyncChecker(MountTable mountTable, ReadOnlyInodeStore inodeStore) Create a new instance of UfsSyncChecker.

Method Summary

Modifier and Type	Method and Description
void	checkDirectory(InodeDirectory inode, AlluxioURI alluxioUri) Check if immediate children of directory are in sync with UFS.
boolean	isDirectoryInSync(AlluxioURI alluxioUri) Based on directories for which checkDirectory(InodeDirectory, AlluxioURI) was called, this method returns whether any un-synced entries were found.

Methods inherited from class java.lang.Object

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

Constructor Detail

UfsSyncChecker

public UfsSyncChecker(MountTable mountTable,
                      ReadOnlyInodeStore inodeStore)

Create a new instance of UfsSyncChecker.

Parameters:

mountTable - to resolve path in under storage

inodeStore - to look up inode children

Method Detail

checkDirectory

public void checkDirectory(InodeDirectory inode,
                           AlluxioURI alluxioUri)
                    throws FileDoesNotExistException,
                           InvalidPathException,
                           java.io.IOException

Check if immediate children of directory are in sync with UFS.

Parameters:

inode - read-locked directory to check

alluxioUri - path of directory to to check

Throws:

FileDoesNotExistException

InvalidPathException

java.io.IOException

isDirectoryInSync

public boolean isDirectoryInSync(AlluxioURI alluxioUri)

Based on directories for which checkDirectory(InodeDirectory, AlluxioURI) was called, this method returns whether any un-synced entries were found.

Parameters:

alluxioUri - path of directory to check

Returns:

true, if in sync; false, otherwise