org.apache.hadoop.hdfs.nfs.nfs3

Class RpcProgramNfs3

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

org.apache.hadoop.oncrpc.RpcProgram

org.apache.hadoop.hdfs.nfs.nfs3.RpcProgramNfs3

All Implemented Interfaces:

Nfs3Interface, org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler

public class RpcProgramNfs3
extends RpcProgram
implements Nfs3Interface

RPC program corresponding to nfs daemon. See Nfs3.

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

org.jboss.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_UMASK
static FsPermission	umask

Fields inherited from class org.apache.hadoop.oncrpc.RpcProgram

RPCB_PORT

Constructor Summary

Constructors

Constructor and Description
RpcProgramNfs3()
RpcProgramNfs3(Configuration config)

Method Summary

Methods

Modifier and Type	Method and Description
ACCESS3Response	access(XDR xdr, SecurityHandler securityHandler, InetAddress client) ACCESS: Check access permission
COMMIT3Response	commit(XDR xdr, SecurityHandler securityHandler, InetAddress client) COMMIT: Commit cached data on a server to stable storage
CREATE3Response	create(XDR xdr, SecurityHandler securityHandler, InetAddress client) CREATE: Create a file
FSINFO3Response	fsinfo(XDR xdr, SecurityHandler securityHandler, InetAddress client) FSINFO: Get static file system information
FSSTAT3Response	fsstat(XDR xdr, SecurityHandler securityHandler, InetAddress client) FSSTAT: Get dynamic file system information
GETATTR3Response	getattr(XDR xdr, SecurityHandler securityHandler, InetAddress client) GETATTR: Get file attributes
void	handleInternal(org.jboss.netty.channel.ChannelHandlerContext ctx, RpcInfo info)
protected boolean	isIdempotent(RpcCall call)
READDIR3Response	link(XDR xdr, SecurityHandler securityHandler, InetAddress client)
LOOKUP3Response	lookup(XDR xdr, SecurityHandler securityHandler, InetAddress client) LOOKUP: Lookup filename
MKDIR3Response	mkdir(XDR xdr, SecurityHandler securityHandler, InetAddress client) MKDIR: Create a directory
READDIR3Response	mknod(XDR xdr, SecurityHandler securityHandler, InetAddress client)
NFS3Response	nullProcedure() RPC call handlers
PATHCONF3Response	pathconf(XDR xdr, SecurityHandler securityHandler, InetAddress client) PATHCONF: Retrieve POSIX information
READ3Response	read(XDR xdr, SecurityHandler securityHandler, InetAddress client) READ: Read from file
READDIR3Response	readdir(XDR xdr, SecurityHandler securityHandler, InetAddress client) READDIR: Read From directory
READDIRPLUS3Response	readdirplus(XDR xdr, SecurityHandler securityHandler, InetAddress client)
READLINK3Response	readlink(XDR xdr, SecurityHandler securityHandler, InetAddress client)
REMOVE3Response	remove(XDR xdr, SecurityHandler securityHandler, InetAddress client) REMOVE: Remove a file
RENAME3Response	rename(XDR xdr, SecurityHandler securityHandler, InetAddress client) RENAME: Rename a file or directory
RMDIR3Response	rmdir(XDR xdr, SecurityHandler securityHandler, InetAddress client) RMDIR: Remove a directory
SETATTR3Response	setattr(XDR xdr, SecurityHandler securityHandler, InetAddress client) SETATTR: Set file attributes
SYMLINK3Response	symlink(XDR xdr, SecurityHandler securityHandler, InetAddress client) SYMLINK: Create a symbolic link
WRITE3Response	write(XDR xdr, org.jboss.netty.channel.Channel channel, int xid, SecurityHandler securityHandler, InetAddress client) WRITE: Write to file

Methods inherited from class org.apache.hadoop.oncrpc.RpcProgram

getPort, messageReceived, register, register, toString

Methods inherited from class org.jboss.netty.channel.SimpleChannelUpstreamHandler

channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, exceptionCaught, handleUpstream, writeComplete

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_UMASK

public static final int DEFAULT_UMASK

See Also:

Constant Field Values

umask

public static final FsPermission umask

Constructor Detail

RpcProgramNfs3

public RpcProgramNfs3()
               throws IOException

Throws:

IOException

RpcProgramNfs3

public RpcProgramNfs3(Configuration config)
               throws IOException

Throws:

IOException

Method Detail

nullProcedure

public NFS3Response nullProcedure()

RPC call handlers

Specified by:

nullProcedure in interface Nfs3Interface

getattr

public GETATTR3Response getattr(XDR xdr,
                       SecurityHandler securityHandler,
                       InetAddress client)

Description copied from interface: Nfs3Interface

GETATTR: Get file attributes

Specified by:

getattr in interface Nfs3Interface

setattr

public SETATTR3Response setattr(XDR xdr,
                       SecurityHandler securityHandler,
                       InetAddress client)

Description copied from interface: Nfs3Interface

SETATTR: Set file attributes

Specified by:

setattr in interface Nfs3Interface

lookup

public LOOKUP3Response lookup(XDR xdr,
                     SecurityHandler securityHandler,
                     InetAddress client)

Description copied from interface: Nfs3Interface

LOOKUP: Lookup filename

Specified by:

lookup in interface Nfs3Interface

access

public ACCESS3Response access(XDR xdr,
                     SecurityHandler securityHandler,
                     InetAddress client)

Description copied from interface: Nfs3Interface

ACCESS: Check access permission

Specified by:

access in interface Nfs3Interface

readlink

public READLINK3Response readlink(XDR xdr,
                         SecurityHandler securityHandler,
                         InetAddress client)

read

public READ3Response read(XDR xdr,
                 SecurityHandler securityHandler,
                 InetAddress client)

Description copied from interface: Nfs3Interface

READ: Read from file

Specified by:

read in interface Nfs3Interface

write

public WRITE3Response write(XDR xdr,
                   org.jboss.netty.channel.Channel channel,
                   int xid,
                   SecurityHandler securityHandler,
                   InetAddress client)

Description copied from interface: Nfs3Interface

WRITE: Write to file

Specified by:

write in interface Nfs3Interface

create

public CREATE3Response create(XDR xdr,
                     SecurityHandler securityHandler,
                     InetAddress client)

Description copied from interface: Nfs3Interface

CREATE: Create a file

Specified by:

create in interface Nfs3Interface

mkdir

public MKDIR3Response mkdir(XDR xdr,
                   SecurityHandler securityHandler,
                   InetAddress client)

Description copied from interface: Nfs3Interface

MKDIR: Create a directory

Specified by:

mkdir in interface Nfs3Interface

mknod

public READDIR3Response mknod(XDR xdr,
                     SecurityHandler securityHandler,
                     InetAddress client)

remove

public REMOVE3Response remove(XDR xdr,
                     SecurityHandler securityHandler,
                     InetAddress client)

Description copied from interface: Nfs3Interface

REMOVE: Remove a file

Specified by:

remove in interface Nfs3Interface

rmdir

public RMDIR3Response rmdir(XDR xdr,
                   SecurityHandler securityHandler,
                   InetAddress client)

Description copied from interface: Nfs3Interface

RMDIR: Remove a directory

Specified by:

rmdir in interface Nfs3Interface

rename

public RENAME3Response rename(XDR xdr,
                     SecurityHandler securityHandler,
                     InetAddress client)

Description copied from interface: Nfs3Interface

RENAME: Rename a file or directory

Specified by:

rename in interface Nfs3Interface

symlink

public SYMLINK3Response symlink(XDR xdr,
                       SecurityHandler securityHandler,
                       InetAddress client)

Description copied from interface: Nfs3Interface

SYMLINK: Create a symbolic link

Specified by:

symlink in interface Nfs3Interface

link

public READDIR3Response link(XDR xdr,
                    SecurityHandler securityHandler,
                    InetAddress client)

readdir

public READDIR3Response readdir(XDR xdr,
                       SecurityHandler securityHandler,
                       InetAddress client)

Description copied from interface: Nfs3Interface

READDIR: Read From directory

Specified by:

readdir in interface Nfs3Interface

readdirplus

public READDIRPLUS3Response readdirplus(XDR xdr,
                               SecurityHandler securityHandler,
                               InetAddress client)

fsstat

public FSSTAT3Response fsstat(XDR xdr,
                     SecurityHandler securityHandler,
                     InetAddress client)

Description copied from interface: Nfs3Interface

FSSTAT: Get dynamic file system information

Specified by:

fsstat in interface Nfs3Interface

fsinfo

public FSINFO3Response fsinfo(XDR xdr,
                     SecurityHandler securityHandler,
                     InetAddress client)

Description copied from interface: Nfs3Interface

FSINFO: Get static file system information

Specified by:

fsinfo in interface Nfs3Interface

pathconf

public PATHCONF3Response pathconf(XDR xdr,
                         SecurityHandler securityHandler,
                         InetAddress client)

Description copied from interface: Nfs3Interface

PATHCONF: Retrieve POSIX information

Specified by:

pathconf in interface Nfs3Interface

commit

public COMMIT3Response commit(XDR xdr,
                     SecurityHandler securityHandler,
                     InetAddress client)

Description copied from interface: Nfs3Interface

COMMIT: Commit cached data on a server to stable storage

Specified by:

commit in interface Nfs3Interface

handleInternal

public void handleInternal(org.jboss.netty.channel.ChannelHandlerContext ctx,
                  RpcInfo info)

Specified by:

handleInternal in class RpcProgram

isIdempotent

protected boolean isIdempotent(RpcCall call)

Specified by:

isIdempotent in class RpcProgram