import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e)
    throws Exception {
  RpcInfo info = (RpcInfo) e.getMessage();
  RpcCall call = (RpcCall) info.header();
  
  SocketAddress remoteAddress = info.remoteAddress();
  if (LOG.isTraceEnabled()) {
    LOG.trace(program + " procedure #" + call.getProcedure());
  }
  
  if (this.progNumber != call.getProgram()) {
    LOG.warn("Invalid RPC call program " + call.getProgram());
    sendAcceptedReply(call, remoteAddress, AcceptState.PROG_UNAVAIL, ctx);
    return;
  }

  int ver = call.getVersion();
  if (ver < lowProgVersion || ver > highProgVersion) {
    LOG.warn("Invalid RPC call version " + ver);
    sendAcceptedReply(call, remoteAddress, AcceptState.PROG_MISMATCH, ctx);
    return;
  }
  
  handleInternal(ctx, info);
}
 

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
private void sendAcceptedReply(RpcCall call, SocketAddress remoteAddress,
    AcceptState acceptState, ChannelHandlerContext ctx) {
  RpcAcceptedReply reply = RpcAcceptedReply.getInstance(call.getXid(),
      acceptState, Verifier.VERIFIER_NONE);

  XDR out = new XDR();
  reply.write(out);
  if (acceptState == AcceptState.PROG_MISMATCH) {
    out.writeInt(lowProgVersion);
    out.writeInt(highProgVersion);
  }
  ChannelBuffer b = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap()
      .buffer());
  RpcResponse rsp = new RpcResponse(b, remoteAddress);
  RpcUtil.sendRpcResponse(ctx, rsp);
}
 

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
private void handle(RpcAcceptedReply acceptedReply, XDR xdr) {
  AcceptState acceptState = acceptedReply.getAcceptState();
  assert (acceptState == AcceptState.SUCCESS);
  boolean answer = xdr.readBoolean();
  if (answer != true) {
    LOG.warn("Portmap mapping registration failed, accept state:"
        + acceptState);
  }
  LOG.info("Portmap mapping registration succeeded");
}
 

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Test
public void testAcceptState() {
  assertEquals(AcceptState.SUCCESS, AcceptState.fromValue(0));
  assertEquals(AcceptState.PROG_UNAVAIL, AcceptState.fromValue(1));
  assertEquals(AcceptState.PROG_MISMATCH, AcceptState.fromValue(2));
  assertEquals(AcceptState.PROC_UNAVAIL, AcceptState.fromValue(3));
  assertEquals(AcceptState.GARBAGE_ARGS, AcceptState.fromValue(4));
  assertEquals(AcceptState.SYSTEM_ERR, AcceptState.fromValue(5));
}
 

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Test
public void testConstructor() {
  Verifier verifier = new VerifierNone();
  RpcAcceptedReply reply = new RpcAcceptedReply(0, 
      ReplyState.MSG_ACCEPTED, verifier, AcceptState.SUCCESS);
  assertEquals(0, reply.getXid());
  assertEquals(RpcMessage.Type.RPC_REPLY, reply.getMessageType());
  assertEquals(ReplyState.MSG_ACCEPTED, reply.getState());
  assertEquals(verifier, reply.getVerifier());
  assertEquals(AcceptState.SUCCESS, reply.getAcceptState());
}
 

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
private XDR programVersionMismatch(XDR out, RpcCall call) {
  LOG.warn("Invalid RPC call version " + call.getVersion());
  RpcAcceptedReply.voidReply(out, call.getXid(), AcceptState.PROG_MISMATCH);
  out.writeInt(lowProgVersion);
  out.writeInt(highProgVersion);
  return out;
}
 

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Test
public void testConstructor() {
  RpcAuthInfo verifier = new RpcAuthInfo(AuthFlavor.AUTH_NONE, new byte[0]);
  RpcAcceptedReply reply = new RpcAcceptedReply(0, RpcMessage.RPC_REPLY,
      ReplyState.MSG_ACCEPTED, verifier, AcceptState.SUCCESS);
  assertEquals(0, reply.getXid());
  assertEquals(RpcMessage.RPC_REPLY, reply.getMessageType());
  assertEquals(ReplyState.MSG_ACCEPTED, reply.getState());
  assertEquals(verifier, reply.getVerifier());
  assertEquals(AcceptState.SUCCESS, reply.getAcceptState());
}
 

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Test(expected = IndexOutOfBoundsException.class)
public void testAcceptStateFromInvalidValue() {
  AcceptState.fromValue(6);
}