alluxio.fuse

Class AlluxioJniFuseFileSystem

java.lang.Object

alluxio.jnifuse.AbstractFuseFileSystem

alluxio.fuse.AlluxioJniFuseFileSystem

All Implemented Interfaces:

FuseFileSystem

@ThreadSafe
public class AlluxioJniFuseFileSystem
extends AbstractFuseFileSystem

Main FUSE implementation class.

Implements the FUSE callbacks defined by jni-fuse.

Field Summary

Fields

Modifier and Type	Field and Description
static IndexDefinition<FuseFileEntry<FuseFileStream>,Long>	ID_INDEX
protected IndexedSet<FuseFileEntry<FuseFileStream>>	mFileEntries
protected com.google.common.cache.LoadingCache<String,AlluxioURI>	mPathResolverCache
static IndexDefinition<FuseFileEntry<FuseFileStream>,String>	PATH_INDEX
static int	UNKNOWN_INODES df command will treat -1 as an unknown value.

Constructor Summary

Constructors

Constructor and Description
AlluxioJniFuseFileSystem(FileSystemContext fsContext, FileSystem fs, FuseOptions fuseOptions) Creates a new instance of AlluxioJniFuseFileSystem.

Method Summary

Modifier and Type	Method and Description
int	chmod(String path, long mode)
int	chown(String path, long uid, long gid)
int	create(String path, long mode, FuseFileInfo fi)
int	flush(String path, FuseFileInfo fi)
protected int	flushInternal(String path, long fd)
int	getattr(String path, FileStat stat)
AuthPolicy	getAuthPolicy() Get the file system authority policy.
FileSystem	getFileSystem() Get the file system on which FuseFileSystem is based.
String	getFileSystemName()
FuseStreamFactory	getFuseStreamFactory() Get the FuseStreamFactory instance member that is for creating FuseFileStream.
int	mkdir(String path, long mode)
int	open(String path, FuseFileInfo fi)
int	read(String path, ByteBuffer buf, long size, long offset, FuseFileInfo fi)
int	readdir(String path, long buff, long filter, long offset, FuseFileInfo fi)
int	release(String path, FuseFileInfo fi)
protected int	releaseInternal(String path, long fd)
int	rename(String oldPath, String newPath, int flags)
int	rmdir(String path)
void	setFuseStreamFactory(FuseStreamFactory fuseStreamFactory) Set the FuseStreamFactory instance member that is for creating FuseFileStream.
int	statfs(String path, Statvfs stbuf) Gets the filesystem statistics.
int	symlink(String linkname, String path)
int	truncate(String path, long size) Since files can be written only once, only sequentially, and never be modified in Alluxio, truncate is not supported internally by Alluxio.
void	umount(boolean force) Umount the mount point of this Fuse Filesystem.
int	unlink(String path)
int	utimens(String path, long aSec, long aNsec, long mSec, long mNsec)
int	write(String path, ByteBuffer buf, long size, long offset, FuseFileInfo fi)
protected int	writeInternal(String path, ByteBuffer buf, long size, long offset, long fd)

Methods inherited from class alluxio.jnifuse.AbstractFuseFileSystem

chmodCallback, chownCallback, createCallback, flushCallback, getattrCallback, getContext, getxattrCallback, listxattrCallback, mkdirCallback, mount, openCallback, readCallback, readdirCallback, releaseCallback, removexattrCallback, renameCallback, renameCallback, rmdirCallback, setxattrCallback, statfsCallback, symlinkCallback, truncateCallback, unlinkCallback, utimensCallback, writeCallback

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.jnifuse.FuseFileSystem

link, opendir, releasedir

Field Detail

mPathResolverCache

protected final com.google.common.cache.LoadingCache<String,AlluxioURI> mPathResolverCache

ID_INDEX

public static final IndexDefinition<FuseFileEntry<FuseFileStream>,Long> ID_INDEX

PATH_INDEX

public static final IndexDefinition<FuseFileEntry<FuseFileStream>,String> PATH_INDEX

mFileEntries

protected final IndexedSet<FuseFileEntry<FuseFileStream>> mFileEntries

UNKNOWN_INODES

public static final int UNKNOWN_INODES

df command will treat -1 as an unknown value.

See Also:

Constant Field Values

Constructor Detail

AlluxioJniFuseFileSystem

public AlluxioJniFuseFileSystem(FileSystemContext fsContext,
                                FileSystem fs,
                                FuseOptions fuseOptions)

Creates a new instance of AlluxioJniFuseFileSystem.

Parameters:

fsContext - the file system context

fs - Alluxio file system

fuseOptions - the fuse options

Method Detail

create

public int create(String path,
                  long mode,
                  FuseFileInfo fi)

open

public int open(String path,
                FuseFileInfo fi)

getattr

public int getattr(String path,
                   FileStat stat)

readdir

public int readdir(String path,
                   long buff,
                   long filter,
                   long offset,
                   FuseFileInfo fi)

read

public int read(String path,
                ByteBuffer buf,
                long size,
                long offset,
                FuseFileInfo fi)

write

public int write(String path,
                 ByteBuffer buf,
                 long size,
                 long offset,
                 FuseFileInfo fi)

writeInternal

protected int writeInternal(String path,
                            ByteBuffer buf,
                            long size,
                            long offset,
                            long fd)

flush

public int flush(String path,
                 FuseFileInfo fi)

flushInternal

protected int flushInternal(String path,
                            long fd)

release

public int release(String path,
                   FuseFileInfo fi)

releaseInternal

protected int releaseInternal(String path,
                              long fd)

mkdir

public int mkdir(String path,
                 long mode)

unlink

public int unlink(String path)

rmdir

public int rmdir(String path)

rename

public int rename(String oldPath,
                  String newPath,
                  int flags)

chmod

public int chmod(String path,
                 long mode)

chown

public int chown(String path,
                 long uid,
                 long gid)

truncate

public int truncate(String path,
                    long size)

Since files can be written only once, only sequentially, and never be modified in Alluxio, truncate is not supported internally by Alluxio. In Alluxio Fuse, we support truncate in some special cases.

Parameters:

path - the file to truncate

size - the size to truncate to

Returns:

0 if succeed, error code otherwise

utimens

public int utimens(String path,
                   long aSec,
                   long aNsec,
                   long mSec,
                   long mNsec)

symlink

public int symlink(String linkname,
                   String path)

statfs

public int statfs(String path,
                  Statvfs stbuf)

Gets the filesystem statistics.

Parameters:

path - The FS path of the directory

stbuf - Statistics of a filesystem

Returns:

0 on success, a negative value on error

getFileSystemName

public String getFileSystemName()

Returns:

Name of the file system

umount

public void umount(boolean force)

Description copied from class: AbstractFuseFileSystem

Umount the mount point of this Fuse Filesystem.

Overrides:

umount in class AbstractFuseFileSystem

Parameters:

force - whether to do a force umount

getFuseStreamFactory

public FuseStreamFactory getFuseStreamFactory()

Get the FuseStreamFactory instance member that is for creating FuseFileStream.

Returns:

the FuseStreamFactory instance member

setFuseStreamFactory

public void setFuseStreamFactory(FuseStreamFactory fuseStreamFactory)

Set the FuseStreamFactory instance member that is for creating FuseFileStream.

Parameters:

fuseStreamFactory - the FuseStreamFactory instance for creating FuseFileStream

getFileSystem

public FileSystem getFileSystem()

Get the file system on which FuseFileSystem is based.

Returns:

the file system on which FuseFileSystem is based

getAuthPolicy

public AuthPolicy getAuthPolicy()

Get the file system authority policy.

Returns:

the file system authority policy