void waitCheckpointDone(BackupNode backup) { do { try { LOG.info("Waiting checkpoint to complete..."); Thread.sleep(1000); } catch (Exception e) {} } while(backup.getCheckpointState() != CheckpointStates.START); }
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()); }
CheckpointStates getCheckpointState() { return getFSImage().getCheckpointState(); }
void setCheckpointState(CheckpointStates cs) { getFSImage().setCheckpointState(cs); }