Skip to content

Commit

Permalink
use uuid instead
Browse files Browse the repository at this point in the history
  • Loading branch information
Sadanand Shenoy committed Jul 12, 2023
1 parent 44cd293 commit d516343
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,11 @@

import org.apache.hadoop.fs.Path;
import org.apache.hadoop.util.StringUtils;
import org.apache.hadoop.util.Time;

import javax.annotation.Nonnull;
import java.nio.file.Paths;
import java.util.UUID;

import static org.apache.hadoop.ozone.OzoneConsts.OM_KEY_PREFIX;
import static org.apache.hadoop.ozone.OzoneConsts.OZONE_URI_DELIMITER;
Expand Down Expand Up @@ -278,4 +280,8 @@ public static String removeTrailingSlashIfNeeded(String key) {
return key;
}
}

public static String generateUniqueTempSnapshotName() {
return "temp" + UUID.randomUUID() + SnapshotInfo.generateName(Time.now());
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,6 @@
import org.apache.hadoop.ozone.om.helpers.BucketLayout;
import org.apache.hadoop.ozone.om.helpers.OzoneFileStatus;
import org.apache.hadoop.ozone.om.helpers.OzoneFSUtils;
import org.apache.hadoop.ozone.om.helpers.SnapshotInfo;
import org.apache.hadoop.ozone.security.OzoneTokenIdentifier;
import org.apache.hadoop.ozone.snapshot.SnapshotDiffReportOzone;
import org.apache.hadoop.ozone.snapshot.SnapshotDiffResponse;
Expand All @@ -77,7 +76,6 @@
import static org.apache.hadoop.ozone.OzoneConsts.OZONE_URI_DELIMITER;
import static org.apache.hadoop.ozone.snapshot.SnapshotDiffResponse.JobStatus.DONE;

import org.apache.hadoop.util.Time;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

Expand Down Expand Up @@ -675,14 +673,14 @@ public SnapshotDiffReport getSnapshotDiffReport(Path snapshotDir,
// current state.
takeTemporaryToSnapshot = true;
toSnapshot = createSnapshot(snapshotDir.toString(),
"temp" + "-to-" + SnapshotInfo.generateName(Time.now()));
OzoneFSUtils.generateUniqueTempSnapshotName());
}
if (fromSnapshot.isEmpty()) {
// empty fromSnapshot implies diff b/w the current state
// & the toSnapshot
takeTemporaryFromSnapshot = true;
fromSnapshot = createSnapshot(snapshotDir.toString(),
"temp" + "-from-" + SnapshotInfo.generateName(Time.now()));
OzoneFSUtils.generateUniqueTempSnapshotName());
}
try {
SnapshotDiffReportOzone aggregated;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,6 @@
import org.apache.hadoop.ozone.om.helpers.OmKeyLocationInfoGroup;
import org.apache.hadoop.ozone.om.helpers.OzoneFileStatus;
import org.apache.hadoop.ozone.om.helpers.OzoneFSUtils;
import org.apache.hadoop.ozone.om.helpers.SnapshotInfo;
import org.apache.hadoop.ozone.security.OzoneTokenIdentifier;
import org.apache.hadoop.ozone.snapshot.SnapshotDiffReportOzone;
import org.apache.hadoop.ozone.snapshot.SnapshotDiffResponse;
Expand All @@ -84,7 +83,6 @@
import org.apache.hadoop.security.token.TokenRenewer;

import org.apache.commons.lang3.StringUtils;
import org.apache.hadoop.util.Time;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

Expand Down Expand Up @@ -1323,14 +1321,14 @@ public SnapshotDiffReport getSnapshotDiffReport(Path snapshotDir,
// current state.
takeTemporaryToSnapshot = true;
toSnapshot = createSnapshot(snapshotDir.toString(),
"temp" + "-to-" + SnapshotInfo.generateName(Time.now()));
OzoneFSUtils.generateUniqueTempSnapshotName());
}
if (fromSnapshot.isEmpty()) {
// empty fromSnapshot implies diff b/w the current state
// & the toSnapshot
takeTemporaryFromSnapshot = true;
fromSnapshot = createSnapshot(snapshotDir.toString(),
"temp" + "-from-" + SnapshotInfo.generateName(Time.now()));
OzoneFSUtils.generateUniqueTempSnapshotName());
}
OFSPath ofsPath = new OFSPath(snapshotDir, config);
String volume = ofsPath.getVolumeName();
Expand Down

0 comments on commit d516343

Please sign in to comment.