org.apache.hadoop.portmap

Class RpcProgramPortmap

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

org.apache.hadoop.oncrpc.RpcProgram

org.apache.hadoop.portmap.RpcProgramPortmap

All Implemented Interfaces:

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

public class RpcProgramPortmap
extends RpcProgram
implements PortmapInterface

An rpcbind request handler.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.portmap.PortmapInterface

PortmapInterface.Procedure

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	PROGRAM
static int	VERSION

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

RPCB_PORT

Constructor Summary

Constructors

Constructor and Description
RpcProgramPortmap()

Method Summary

Methods

Modifier and Type	Method and Description
XDR	dump(int xid, XDR in, XDR out) This procedure enumerates all entries in the port mapper's database.
XDR	getport(int xid, XDR in, XDR out) Given a program number "prog", version number "vers", and transport protocol number "prot", this procedure returns the port number on which the program is awaiting call requests.
void	handleInternal(org.jboss.netty.channel.ChannelHandlerContext ctx, RpcInfo info)
protected boolean	isIdempotent(RpcCall call)
XDR	nullOp(int xid, XDR in, XDR out) This procedure does no work.
void	register(PortmapMapping mapping) Register the program with Portmap or Rpcbind
XDR	set(int xid, XDR in, XDR out) When a program first becomes available on a machine, it registers itself with the port mapper program on the same machine.
XDR	unset(int xid, XDR in, XDR out) When a program becomes unavailable, it should unregister itself with the port mapper program on the same machine.

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

getPort, messageReceived, 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

PROGRAM

public static final int PROGRAM

See Also:

Constant Field Values

VERSION

public static final int VERSION

See Also:

Constant Field Values

Constructor Detail

RpcProgramPortmap

public RpcProgramPortmap()

Method Detail

nullOp

public XDR nullOp(int xid,
         XDR in,
         XDR out)

Description copied from interface: PortmapInterface

This procedure does no work. By convention, procedure zero of any protocol takes no parameters and returns no results.

Specified by:

nullOp in interface PortmapInterface

set

public XDR set(int xid,
      XDR in,
      XDR out)

Description copied from interface: PortmapInterface

When a program first becomes available on a machine, it registers itself with the port mapper program on the same machine. The program passes its program number "prog", version number "vers", transport protocol number "prot", and the port "port" on which it awaits service request. The procedure returns a boolean reply whose value is "TRUE" if the procedure successfully established the mapping and "FALSE" otherwise. The procedure refuses to establish a mapping if one already exists for the tuple "(prog, vers, prot)".

Specified by:

set in interface PortmapInterface

unset

public XDR unset(int xid,
        XDR in,
        XDR out)

Description copied from interface: PortmapInterface

When a program becomes unavailable, it should unregister itself with the port mapper program on the same machine. The parameters and results have meanings identical to those of "PMAPPROC_SET". The protocol and port number fields of the argument are ignored.

Specified by:

unset in interface PortmapInterface

getport

public XDR getport(int xid,
          XDR in,
          XDR out)

Description copied from interface: PortmapInterface

Given a program number "prog", version number "vers", and transport protocol number "prot", this procedure returns the port number on which the program is awaiting call requests. A port value of zeros means the program has not been registered. The "port" field of the argument is ignored.

Specified by:

getport in interface PortmapInterface

dump

public XDR dump(int xid,
       XDR in,
       XDR out)

Description copied from interface: PortmapInterface

This procedure enumerates all entries in the port mapper's database. The procedure takes no parameters and returns a list of program, version, protocol, and port values.

Specified by:

dump in interface PortmapInterface

register

public void register(PortmapMapping mapping)

Description copied from class: RpcProgram

Register the program with Portmap or Rpcbind

Overrides:

register in class RpcProgram

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