Java 类org.apache.hadoop.hdfs.protocol.RollingUpgradeException 实例源码

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

RollingUpgradeInfo finalizeRollingUpgradeInternal(long finalizeTime)
    throws RollingUpgradeException {
  if (!isRollingUpgrade()) {
    throw new RollingUpgradeException(
        "Failed to finalize rolling upgrade since there is no rolling upgrade in progress.");
  }

  final long startTime = rollingUpgradeInfo.getStartTime();
  rollingUpgradeInfo = null;
  return new RollingUpgradeInfo(blockPoolId, false, startTime, finalizeTime);
}

RollingUpgradeInfo finalizeRollingUpgradeInternal(long finalizeTime)
    throws RollingUpgradeException {
  final long startTime = rollingUpgradeInfo.getStartTime();
  rollingUpgradeInfo = null;
  return new RollingUpgradeInfo(blockPoolId, false, startTime, finalizeTime);
}

RollingUpgradeInfo finalizeRollingUpgradeInternal(long finalizeTime)
    throws RollingUpgradeException {
  final long startTime = rollingUpgradeInfo.getStartTime();
  rollingUpgradeInfo = null;
  return new RollingUpgradeInfo(blockPoolId, false, startTime, finalizeTime);
}

RollingUpgradeInfo finalizeRollingUpgradeInternal(long finalizeTime)
    throws RollingUpgradeException {
  final long startTime = rollingUpgradeInfo.getStartTime();
  rollingUpgradeInfo = null;
  return new RollingUpgradeInfo(blockPoolId, false, startTime, finalizeTime);
}