import org.apache.hadoop.ipc.RpcConstants; //导入依赖的package包/类
@Test
public void testRpcClientId() {
  byte[] uuid = ClientId.getClientId();
  RpcRequestHeaderProto header = ProtoUtil.makeRpcRequestHeader(
      RpcKind.RPC_PROTOCOL_BUFFER, OperationProto.RPC_FINAL_PACKET, 0,
      RpcConstants.INVALID_RETRY_COUNT, uuid);
  assertTrue(Arrays.equals(uuid, header.getClientId().toByteArray()));
}
 

import org.apache.hadoop.ipc.RpcConstants; //导入依赖的package包/类
void readRpcIdsFromXml(Stanza st) {
  this.rpcClientId = st.hasChildren("RPC_CLIENTID") ? 
      ClientId.toBytes(st.getValue("RPC_CLIENTID"))
      : RpcConstants.DUMMY_CLIENT_ID;
  this.rpcCallId = st.hasChildren("RPC_CALLID") ? 
      Integer.parseInt(st.getValue("RPC_CALLID"))
      : RpcConstants.INVALID_CALL_ID;
}
 

import org.apache.hadoop.ipc.RpcConstants; //导入依赖的package包/类
void readRpcIdsFromXml(Stanza st) {
  this.rpcClientId = st.hasChildren("RPC_CLIENTID") ? 
      ClientId.toBytes(st.getValue("RPC_CLIENTID"))
      : RpcConstants.DUMMY_CLIENT_ID;
  this.rpcCallId = st.hasChildren("RPC_CALLID") ? 
      Integer.valueOf(st.getValue("RPC_CALLID"))
      : RpcConstants.INVALID_CALL_ID;
}
 

import org.apache.hadoop.ipc.RpcConstants; //导入依赖的package包/类
final void reset() {
  txid = HdfsConstants.INVALID_TXID;
  rpcClientId = RpcConstants.DUMMY_CLIENT_ID;
  rpcCallId = RpcConstants.INVALID_CALL_ID;
  resetSubFields();
}
 

import org.apache.hadoop.ipc.RpcConstants; //导入依赖的package包/类
public boolean hasRpcIds() {
  return rpcClientId != RpcConstants.DUMMY_CLIENT_ID
      && rpcCallId != RpcConstants.INVALID_CALL_ID;
}
 

import org.apache.hadoop.ipc.RpcConstants; //导入依赖的package包/类
/** this has to be called after calling {@link #hasRpcIds()} */
public byte[] getClientId() {
  Preconditions.checkState(rpcClientId != RpcConstants.DUMMY_CLIENT_ID);
  return rpcClientId;
}
 

import org.apache.hadoop.ipc.RpcConstants; //导入依赖的package包/类
/** this has to be called after calling {@link #hasRpcIds()} */
public int getCallId() {
  Preconditions.checkState(rpcCallId != RpcConstants.INVALID_CALL_ID);
  return rpcCallId;
}
 

import org.apache.hadoop.ipc.RpcConstants; //导入依赖的package包/类
public static void resetCall() {
  Server.Call call = new Server.Call(RpcConstants.INVALID_CALL_ID, 1, null,
      null, RpcKind.RPC_PROTOCOL_BUFFER, RpcConstants.DUMMY_CLIENT_ID);
  Server.getCurCall().set(call);
}
 

import org.apache.hadoop.ipc.RpcConstants; //导入依赖的package包/类
final void reset() {
  txid = HdfsServerConstants.INVALID_TXID;
  rpcClientId = RpcConstants.DUMMY_CLIENT_ID;
  rpcCallId = RpcConstants.INVALID_CALL_ID;
  resetSubFields();
}