Skip to content

Commit

Permalink
minority
Browse files Browse the repository at this point in the history
  • Loading branch information
Vladsz83 committed Jul 11, 2024
1 parent 1105e3f commit fca7aed
Showing 1 changed file with 5 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -396,9 +396,10 @@ public Map<PartitionKeyV2, PartitionHashRecordV2> checkSnapshotFiles(
Set<Integer> grpIds,
SnapshotMetadata meta,
boolean forCreation,
boolean skipHash,
boolean punchHoleEnabled
boolean skipHash
) throws IgniteCheckedException {
boolean pouchHoleEnabled = isPunchHoleEnabled(meta, snpDir, grpIds);

IgniteBiTuple<Map<Integer, File>, Set<File>> grpAndPartFiles = preparePartitions(meta, grpIds, snpDir);

Map<PartitionKeyV2, PartitionHashRecordV2> res = new ConcurrentHashMap<>();
Expand All @@ -424,7 +425,7 @@ public Map<PartitionKeyV2, PartitionHashRecordV2> checkSnapshotFiles(
) {
pageStore.init();

if (punchHoleEnabled && meta.isGroupWithCompression(grpId) && forCreation) {
if (pouchHoleEnabled && meta.isGroupWithCompression(grpId) && forCreation) {
byte pageType = partId == INDEX_PARTITION ? FLAG_IDX : FLAG_DATA;

checkPartitionsPageCrcSum(() -> pageStore, partId, pageType, (id, buffer) -> {
Expand Down Expand Up @@ -593,7 +594,7 @@ public Map<PartitionKeyV2, PartitionHashRecordV2> checkPartitions(
if (meta.dump())
return checkDumpFiles(snpDir, meta, grps, locNode.consistentId(), skipPartsHashes);

return checkSnapshotFiles(snpDir, grps, meta, forCreation, skipPartsHashes, isPunchHoleEnabled(meta, snpDir, grps));
return checkSnapshotFiles(snpDir, grps, meta, forCreation, skipPartsHashes);
}

/** */
Expand Down

0 comments on commit fca7aed

Please sign in to comment.