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 long	ID_NOT_SET_VALUE
static long	ID_NOT_SET_VALUE_UNSIGNED
static int	MAX_NAME_LENGTH Most FileSystems on linux limit the length of file name beyond 255 characters.
static int	UNKNOWN_INODES df command will treat -1 as an unknown value.

Constructor Summary

Constructors

Constructor and Description
AlluxioJniFuseFileSystem(FileSystem fs, FuseMountOptions opts, AlluxioConfiguration conf) 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)
int	getattr(String path, FileStat stat)
String	getFileSystemName()
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)
int	rename(String oldPath, String newPath)
int	rmdir(String path)
int	symlink(String linkname, String path)
int	truncate(String path, long size) Truncate is not supported internally by Alluxio.
void	umount(boolean force) Unmounts the Fuse application.
int	unlink(String path)
int	utimensCallback(String path, long aSec, long aNsec, long mSec, long mNsec)
int	write(String path, 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, 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, statfs

Field Detail

ID_NOT_SET_VALUE

public static final long ID_NOT_SET_VALUE

See Also:

Constant Field Values

ID_NOT_SET_VALUE_UNSIGNED

public static final long ID_NOT_SET_VALUE_UNSIGNED

See Also:

Constant Field Values

UNKNOWN_INODES

public static final int UNKNOWN_INODES

df command will treat -1 as an unknown value.

See Also:

Constant Field Values

MAX_NAME_LENGTH

public static final int MAX_NAME_LENGTH

Most FileSystems on linux limit the length of file name beyond 255 characters.

See Also:

Constant Field Values

Constructor Detail

AlluxioJniFuseFileSystem

public AlluxioJniFuseFileSystem(FileSystem fs,
                                FuseMountOptions opts,
                                AlluxioConfiguration conf)

Creates a new instance of AlluxioJniFuseFileSystem.

Parameters:

fs - Alluxio file system

opts - options

conf - Alluxio configuration

Method Detail

create

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

Specified by:

create in interface FuseFileSystem

getattr

public int getattr(String path,
                   FileStat stat)

Specified by:

getattr in interface FuseFileSystem

readdir

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

Specified by:

readdir in interface FuseFileSystem

open

public int open(String path,
                FuseFileInfo fi)

Specified by:

open in interface FuseFileSystem

read

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

Specified by:

read in interface FuseFileSystem

write

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

Specified by:

write in interface FuseFileSystem

flush

public int flush(String path,
                 FuseFileInfo fi)

Specified by:

flush in interface FuseFileSystem

release

public int release(String path,
                   FuseFileInfo fi)

Specified by:

release in interface FuseFileSystem

mkdir

public int mkdir(String path,
                 long mode)

Specified by:

mkdir in interface FuseFileSystem

unlink

public int unlink(String path)

Specified by:

unlink in interface FuseFileSystem

rmdir

public int rmdir(String path)

Specified by:

rmdir in interface FuseFileSystem

rename

public int rename(String oldPath,
                  String newPath)

Specified by:

rename in interface FuseFileSystem

chmod

public int chmod(String path,
                 long mode)

Specified by:

chmod in interface FuseFileSystem

chown

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

Specified by:

chown in interface FuseFileSystem

truncate

public int truncate(String path,
                    long size)

Truncate is not supported internally by Alluxio. Truncate is supported here only for a special overwrite case. Libfuse issues open() - truncate() to size 0 - write() new contents - release() to overwrite an existing file. Since files can be written only once, only sequentially, and never be modified in Alluxio, we delete the existing file and create a new file for writing in open() and consider truncate() to size 0 as a noop to fulfill the overwrite requirement.

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

utimensCallback

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

Specified by:

utimensCallback in interface FuseFileSystem

symlink

public int symlink(String linkname,
                   String path)

Specified by:

symlink in interface FuseFileSystem

getFileSystemName

public String getFileSystemName()

Specified by:

getFileSystemName in interface FuseFileSystem

Returns:

Name of the file system

umount

public void umount(boolean force)
            throws FuseException

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.

Throws:

FuseException