import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto; //导入依赖的package包/类
public static RollingUpgradeStatusProto convertRollingUpgradeStatus(
    RollingUpgradeStatus status) {
  return RollingUpgradeStatusProto.newBuilder()
      .setBlockPoolId(status.getBlockPoolId())
      .setFinalized(status.isFinalized())
      .build();
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto; //导入依赖的package包/类
public static RollingUpgradeStatusProto convertRollingUpgradeStatus(
    RollingUpgradeStatus status) {
  return RollingUpgradeStatusProto.newBuilder()
      .setBlockPoolId(status.getBlockPoolId())
      .build();
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto; //导入依赖的package包/类
public static RollingUpgradeStatus convert(RollingUpgradeStatusProto proto) {
  return new RollingUpgradeStatus(proto.getBlockPoolId());
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto; //导入依赖的package包/类
public static RollingUpgradeInfo convert(RollingUpgradeInfoProto proto) {
  RollingUpgradeStatusProto status = proto.getStatus();
  return new RollingUpgradeInfo(status.getBlockPoolId(),
      proto.getCreatedRollbackImages(),
      proto.getStartTime(), proto.getFinalizeTime());
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto; //导入依赖的package包/类
@Override
public HeartbeatResponseProto sendHeartbeat(RpcController controller,
    HeartbeatRequestProto request) throws ServiceException {
  HeartbeatResponse response;
  try {
    final StorageReport[] report = PBHelperClient.convertStorageReports(
        request.getReportsList());
    VolumeFailureSummary volumeFailureSummary =
        request.hasVolumeFailureSummary() ? PBHelper.convertVolumeFailureSummary(
            request.getVolumeFailureSummary()) : null;
    response = impl.sendHeartbeat(PBHelper.convert(request.getRegistration()),
        report, request.getCacheCapacity(), request.getCacheUsed(),
        request.getXmitsInProgress(),
        request.getXceiverCount(), request.getFailedVolumes(),
        volumeFailureSummary, request.getRequestFullBlockReportLease());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  HeartbeatResponseProto.Builder builder = HeartbeatResponseProto
      .newBuilder();
  DatanodeCommand[] cmds = response.getCommands();
  if (cmds != null) {
    for (int i = 0; i < cmds.length; i++) {
      if (cmds[i] != null) {
        builder.addCmds(PBHelper.convert(cmds[i]));
      }
    }
  }
  builder.setHaStatus(PBHelper.convert(response.getNameNodeHaState()));
  RollingUpgradeStatus rollingUpdateStatus = response
      .getRollingUpdateStatus();
  if (rollingUpdateStatus != null) {
    // V2 is always set for newer datanodes.
    // To be compatible with older datanodes, V1 is set to null
    //  if the RU was finalized.
    RollingUpgradeStatusProto rus = PBHelperClient.
        convertRollingUpgradeStatus(rollingUpdateStatus);
    builder.setRollingUpgradeStatusV2(rus);
    if (!rollingUpdateStatus.isFinalized()) {
      builder.setRollingUpgradeStatus(rus);
    }
  }

  builder.setFullBlockReportLeaseId(response.getFullBlockReportLeaseId());
  return builder.build();
}
 

import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto; //导入依赖的package包/类
public static RollingUpgradeStatus convert(RollingUpgradeStatusProto proto) {
  return new RollingUpgradeStatus(proto.getBlockPoolId(),
      proto.getFinalized());
}