Java 类org.apache.hadoop.hdfs.server.namenode.FSImage.CheckpointStates 实例源码

项目:cumulus    文件:TestBackupNode.java   
void waitCheckpointDone(BackupNode backup) {
  do {
    try {
      LOG.info("Waiting checkpoint to complete...");
      Thread.sleep(1000);
    } catch (Exception e) {}
  } while(backup.getCheckpointState() != CheckpointStates.START);
}
项目:RDFS    文件:CheckpointSignature.java   
public void readFields(DataInput in) throws IOException {
  layoutVersion = in.readInt();
  namespaceID = in.readInt();
  cTime = in.readLong();
  editsTime = in.readLong();
  checkpointTime = in.readLong();
  imageDigest = new MD5Hash();
  imageDigest.readFields(in);
  checkpointState = CheckpointStates.deserialize(in.readInt());
}
项目:cumulus    文件:BackupNode.java   
CheckpointStates getCheckpointState() {
  return getFSImage().getCheckpointState();
}
项目:cumulus    文件:BackupNode.java   
void setCheckpointState(CheckpointStates cs) {
  getFSImage().setCheckpointState(cs);
}