import org.apache.hadoop.oncrpc.RpcProgram; //导入依赖的package包/类
public static void main(String[] args) {
  StringUtils.startupShutdownMessage(Portmap.class, args, LOG);

  final int port = RpcProgram.RPCB_PORT;
  Portmap pm = new Portmap();
  try {
    pm.start(DEFAULT_IDLE_TIME_MILLISECONDS,
        new InetSocketAddress(port), new InetSocketAddress(port));
  } catch (Throwable e) {
    LOG.fatal("Failed to start the server. Cause:", e);
    pm.shutdown();
    System.exit(-1);
  }
}
 

import org.apache.hadoop.oncrpc.RpcProgram; //导入依赖的package包/类
RpcProgramPortmap(ChannelGroup allChannels) {
  this.allChannels = allChannels;
  PortmapMapping m = new PortmapMapping(PROGRAM, VERSION,
      PortmapMapping.TRANSPORT_TCP, RpcProgram.RPCB_PORT);
  PortmapMapping m1 = new PortmapMapping(PROGRAM, VERSION,
      PortmapMapping.TRANSPORT_UDP, RpcProgram.RPCB_PORT);
  map.put(PortmapMapping.key(m), m);
  map.put(PortmapMapping.key(m1), m1);
}
 

import org.apache.hadoop.oncrpc.RpcProgram; //导入依赖的package包/类
public RpcProgram getRpcProgram() {
  return rpcProgram;
}
 

import org.apache.hadoop.oncrpc.RpcProgram; //导入依赖的package包/类
protected Nfs3Base(RpcProgram rpcProgram, Configuration conf) {
  this.rpcProgram = rpcProgram;
  LOG.info("NFS server port set to: " + rpcProgram.getPort());
}
 

import org.apache.hadoop.oncrpc.RpcProgram; //导入依赖的package包/类
protected Nfs3Base(MountdBase mountd, RpcProgram program) {
  this.mountd = mountd;
  this.rpcProgram = program;
}
 

import org.apache.hadoop.oncrpc.RpcProgram; //导入依赖的package包/类
private static void startUDPServer(RpcProgramPortmap rpcProgram) {
  rpcProgram.register(PortmapMapping.TRANSPORT_UDP);
  SimpleUdpServer udpServer = new SimpleUdpServer(RpcProgram.RPCB_PORT,
      rpcProgram, 1);
  udpServer.run();
}
 

import org.apache.hadoop.oncrpc.RpcProgram; //导入依赖的package包/类
private static void startTCPServer(final RpcProgramPortmap rpcProgram) {
  rpcProgram.register(PortmapMapping.TRANSPORT_TCP);
  SimpleTcpServer tcpServer = new SimpleTcpServer(RpcProgram.RPCB_PORT,
      rpcProgram, 1);
  tcpServer.run();
}
 

import org.apache.hadoop.oncrpc.RpcProgram; //导入依赖的package包/类
protected Nfs3Base(MountdBase mountd, RpcProgram program, Configuration conf) {
  this.mountd = mountd;
  this.rpcProgram = program;
  this.nfsPort = conf.getInt("nfs3.server.port", Nfs3Constant.PORT);
  LOG.info("NFS server port set to: "+nfsPort);
}