import org.apache.hadoop.oncrpc.SimpleTcpServer; //导入依赖的package包/类
private void startTCPServer() {
  SimpleTcpServer tcpServer = new SimpleTcpServer(rpcProgram.getPort(),
      rpcProgram, 1);
  rpcProgram.startDaemons();
  try {
    tcpServer.run();
  } catch (Throwable e) {
    LOG.fatal("Failed to start the TCP server.", e);
    if (tcpServer.getBoundPort() > 0) {
      rpcProgram.unregister(PortmapMapping.TRANSPORT_TCP,
          tcpServer.getBoundPort());
    }
    tcpServer.shutdown();
    terminate(1, e);
  }
  tcpBoundPort = tcpServer.getBoundPort();
}
 

import org.apache.hadoop.oncrpc.SimpleTcpServer; //导入依赖的package包/类
private void startTCPServer() {
  SimpleTcpServer tcpServer = new SimpleTcpServer(rpcProgram.getPort(),
      rpcProgram, 0);
  rpcProgram.startDaemons();
  try {
    tcpServer.run();
  } catch (Throwable e) {
    LOG.fatal("Failed to start the TCP server.", e);
    if (tcpServer.getBoundPort() > 0) {
      rpcProgram.unregister(PortmapMapping.TRANSPORT_TCP,
          tcpServer.getBoundPort());
    }
    tcpServer.shutdown();
    terminate(1, e);
  }
  nfsBoundPort = tcpServer.getBoundPort();
}
 

import org.apache.hadoop.oncrpc.SimpleTcpServer; //导入依赖的package包/类
private void startTCPServer() {
  SimpleTcpServer tcpServer = new SimpleTcpServer(Nfs3Constant.PORT,
      rpcProgram, 0) {
    @Override
    public ChannelPipelineFactory getPipelineFactory() {
      return new ChannelPipelineFactory() {
        @Override
        public ChannelPipeline getPipeline() {
          return Channels.pipeline(new RpcFrameDecoder(),
              new SimpleTcpServerHandler(rpcProgram));
        }
      };
    }
  };
  tcpServer.run();
}
 

import org.apache.hadoop.oncrpc.SimpleTcpServer; //导入依赖的package包/类
private void startTCPServer() {
  SimpleTcpServer tcpServer = new SimpleTcpServer(rpcProgram.getPort(),
      rpcProgram, 1);
  rpcProgram.startDaemons();
  tcpServer.run();
  tcpBoundPort = tcpServer.getBoundPort();
}
 

import org.apache.hadoop.oncrpc.SimpleTcpServer; //导入依赖的package包/类
private void startTCPServer() {
  SimpleTcpServer tcpServer = new SimpleTcpServer(rpcProgram.getPort(),
      rpcProgram, 0);
  rpcProgram.startDaemons();
  tcpServer.run();
  nfsBoundPort = tcpServer.getBoundPort();
}
 

import org.apache.hadoop.oncrpc.SimpleTcpServer; //导入依赖的package包/类
private void startTCPServer() {
  SimpleTcpServer tcpServer = new SimpleTcpServer(nfsPort,
      rpcProgram, 0);
  rpcProgram.startDaemons();
  tcpServer.run();
  nfsBoundPort = tcpServer.getBoundPort();
}
 

import org.apache.hadoop.oncrpc.SimpleTcpServer; //导入依赖的package包/类
private void startTCPServer() {
  SimpleTcpServer tcpServer = new SimpleTcpServer(rpcProgram.getPort(),
      rpcProgram, 1);
  tcpServer.run();
}
 

import org.apache.hadoop.oncrpc.SimpleTcpServer; //导入依赖的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.SimpleTcpServer; //导入依赖的package包/类
private void startTCPServer() {
  SimpleTcpServer tcpServer = new SimpleTcpServer(nfsPort,
      rpcProgram, 0);
  tcpServer.run();
}