import org.apache.hadoop.oncrpc.security.Credentials; //导入依赖的package包/类
@Test
public void testConstructor() {
  Credentials credential = new CredentialsNone();
  Verifier verifier = new VerifierNone();
  int rpcVersion = RpcCall.RPC_VERSION;
  int program = 2;
  int version = 3;
  int procedure = 4;
  RpcCall call = new RpcCall(0, RpcMessage.Type.RPC_CALL, rpcVersion, program,
      version, procedure, credential, verifier);
  assertEquals(0, call.getXid());
  assertEquals(RpcMessage.Type.RPC_CALL, call.getMessageType());
  assertEquals(rpcVersion, call.getRpcVersion());
  assertEquals(program, call.getProgram());
  assertEquals(version, call.getVersion());
  assertEquals(procedure, call.getProcedure());
  assertEquals(credential, call.getCredential());
  assertEquals(verifier, call.getVerifier());
}
 

import org.apache.hadoop.oncrpc.security.Credentials; //导入依赖的package包/类
private SecurityHandler getSecurityHandler(Credentials credentials,
    Verifier verifier) {
  if (credentials instanceof CredentialsSys) {
    return new SysSecurityHandler((CredentialsSys) credentials, iug);
  } else {
    // TODO: support GSS and handle other cases
    return null;
  }
}
 

import org.apache.hadoop.oncrpc.security.Credentials; //导入依赖的package包/类
protected RpcCall(int xid, RpcMessage.Type messageType, int rpcVersion,
    int program, int version, int procedure, Credentials credential,
    Verifier verifier) {
  super(xid, messageType);
  this.rpcVersion = rpcVersion;
  this.program = program;
  this.version = version;
  this.procedure = procedure;
  this.credentials = credential;
  this.verifier = verifier;
  if (LOG.isTraceEnabled()) {
    LOG.trace(this);
  }
  validate();
}
 

import org.apache.hadoop.oncrpc.security.Credentials; //导入依赖的package包/类
@Override
public XDR write(XDR xdr) {
  xdr.writeInt(xid);
  xdr.writeInt(RpcMessage.Type.RPC_CALL.getValue());
  xdr.writeInt(2);
  xdr.writeInt(program);
  xdr.writeInt(version);
  xdr.writeInt(procedure);
  Credentials.writeFlavorAndCredentials(credentials, xdr);
  Verifier.writeFlavorAndVerifier(verifier, xdr);
  return xdr;
}
 

import org.apache.hadoop.oncrpc.security.Credentials; //导入依赖的package包/类
public static RpcCall read(XDR xdr) {
  return new RpcCall(xdr.readInt(), RpcMessage.Type.fromValue(xdr.readInt()),
      xdr.readInt(), xdr.readInt(), xdr.readInt(), xdr.readInt(), 
      Credentials.readFlavorAndCredentials(xdr),
      Verifier.readFlavorAndVerifier(xdr));
}
 

import org.apache.hadoop.oncrpc.security.Credentials; //导入依赖的package包/类
public static RpcCall getInstance(int xid, int program, int version,
    int procedure, Credentials cred, Verifier verifier) {
  return new RpcCall(xid, RpcMessage.Type.RPC_CALL, 2, program, version,
      procedure, cred, verifier);
}
 

import org.apache.hadoop.oncrpc.security.Credentials; //导入依赖的package包/类
public Credentials getCredential() {
  return credentials;
}