alluxio.fuse

Class AlluxioJniFuseFileSystem

java.lang.Object

alluxio.jnifuse.AbstractFuseFileSystem

alluxio.fuse.AlluxioJniFuseFileSystem

All Implemented Interfaces:

FuseUmountable, FuseFileSystem

@ThreadSafe
public final class AlluxioJniFuseFileSystem
extends AbstractFuseFileSystem
implements FuseUmountable

Main FUSE implementation class.

Implements the FUSE callbacks defined by jni-fuse.

Field Summary

Fields

Modifier and Type	Field and Description
static int	UNKNOWN_INODES df command will treat -1 as an unknown value.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	chmod(java.lang.String path, long mode)
int	chown(java.lang.String path, long uid, long gid)
int	create(java.lang.String path, long mode, FuseFileInfo fi)
int	flush(java.lang.String path, FuseFileInfo fi)
int	getattr(java.lang.String path, FileStat stat)
java.lang.String	getFileSystemName()
int	mkdir(java.lang.String path, long mode)
int	open(java.lang.String path, FuseFileInfo fi)
int	read(java.lang.String path, java.nio.ByteBuffer buf, long size, long offset, FuseFileInfo fi)
int	readdir(java.lang.String path, long buff, long filter, long offset, FuseFileInfo fi)
int	release(java.lang.String path, FuseFileInfo fi)
int	rename(java.lang.String oldPath, java.lang.String newPath, int flags)
int	rmdir(java.lang.String path)
int	statfs(java.lang.String path, Statvfs stbuf) Gets the filesystem statistics.
int	symlink(java.lang.String linkname, java.lang.String path)
int	truncate(java.lang.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) Unmounts the Fuse application.
int	unlink(java.lang.String path)
int	utimens(java.lang.String path, long aSec, long aNsec, long mSec, long mNsec)
int	write(java.lang.String path, java.nio.ByteBuffer buf, long size, long offset, FuseFileInfo fi)

Methods inherited from class alluxio.jnifuse.AbstractFuseFileSystem

chmodCallback, chownCallback, createCallback, flushCallback, getattrCallback, getContext, getxattrCallback, listxattrCallback, mkdirCallback, mount, openCallback, readCallback, readdirCallback, releaseCallback, removexattrCallback, 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

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)

Creates a new instance of AlluxioJniFuseFileSystem.

Parameters:

fsContext - the file system context

fs - Alluxio file system

Method Detail

create

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

Specified by:

create in interface FuseFileSystem

open

public int open(java.lang.String path,
                FuseFileInfo fi)

Specified by:

open in interface FuseFileSystem

getattr

public int getattr(java.lang.String path,
                   FileStat stat)

Specified by:

getattr in interface FuseFileSystem

readdir

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

Specified by:

readdir in interface FuseFileSystem

read

public int read(java.lang.String path,
                java.nio.ByteBuffer buf,
                long size,
                long offset,
                FuseFileInfo fi)

Specified by:

read in interface FuseFileSystem

write

public int write(java.lang.String path,
                 java.nio.ByteBuffer buf,
                 long size,
                 long offset,
                 FuseFileInfo fi)

Specified by:

write in interface FuseFileSystem

flush

public int flush(java.lang.String path,
                 FuseFileInfo fi)

Specified by:

flush in interface FuseFileSystem

release

public int release(java.lang.String path,
                   FuseFileInfo fi)

Specified by:

release in interface FuseFileSystem

mkdir

public int mkdir(java.lang.String path,
                 long mode)

Specified by:

mkdir in interface FuseFileSystem

unlink

public int unlink(java.lang.String path)

Specified by:

unlink in interface FuseFileSystem

rmdir

public int rmdir(java.lang.String path)

Specified by:

rmdir in interface FuseFileSystem

rename

public int rename(java.lang.String oldPath,
                  java.lang.String newPath,
                  int flags)

Specified by:

rename in interface FuseFileSystem

chmod

public int chmod(java.lang.String path,
                 long mode)

Specified by:

chmod in interface FuseFileSystem

chown

public int chown(java.lang.String path,
                 long uid,
                 long gid)

Specified by:

chown in interface FuseFileSystem

truncate

public int truncate(java.lang.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.

Specified by:

truncate in interface FuseFileSystem

Parameters:

path - the file to truncate

size - the size to truncate to

Returns:

0 if succeed, error code otherwise

utimens

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

Specified by:

utimens in interface FuseFileSystem

symlink

public int symlink(java.lang.String linkname,
                   java.lang.String path)

Specified by:

symlink in interface FuseFileSystem

statfs

public int statfs(java.lang.String path,
                  Statvfs stbuf)

Gets the filesystem statistics.

Specified by:

statfs in interface FuseFileSystem

Parameters:

path - The FS path of the directory

stbuf - Statistics of a filesystem

Returns:

0 on success, a negative value on error

getFileSystemName

public java.lang.String getFileSystemName()

Specified by:

getFileSystemName in interface FuseFileSystem

Returns:

Name of the file system

umount

public void umount(boolean force)

Description copied from interface: FuseUmountable

Unmounts the Fuse application.

Specified by:

umount in interface FuseUmountable

Overrides:

umount in class AbstractFuseFileSystem

Parameters:

force - true to throw an exception and treat umount as a no-op when umount timeouts due to the fuse device is busy.