Skip to content

Commit

Permalink
IGNITE-19163 Add logging of snapshot check
Browse files Browse the repository at this point in the history
  • Loading branch information
J-Bakuli committed Aug 3, 2023
1 parent 92650b0 commit 0903a62
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1834,6 +1834,11 @@ public IgniteInternalFuture<SnapshotPartitionsVerifyTaskResult> checkSnapshot(

GridFutureAdapter<SnapshotPartitionsVerifyTaskResult> res = new GridFutureAdapter<>();

if (log.isInfoEnabled()) {
log.info("The check snapshot procedure started [snpName=" + name + ", snpPath=" + snpPath +
", incIdx=" + incIdx + ", grps=" + grps + ']');
}

GridKernalContext kctx0 = cctx.kernalContext();

Collection<ClusterNode> bltNodes = F.view(cctx.discovery().serverNodes(AffinityTopologyVersion.NONE),
Expand Down Expand Up @@ -1952,6 +1957,11 @@ else if (f0.error() instanceof IgniteSnapshotVerifyException)
}
});

if (log.isInfoEnabled()) {
res.listen(f -> log.info("The check snapshot procedure finished [snpName=" + name +
", snpPath=" + snpPath + ", incIdx=" + incIdx + ", grps=" + grps + ']'));
}

return res;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -136,6 +136,12 @@ public VerifySnapshotPartitionsJob(
catch (IgniteCheckedException | IOException e) {
throw new IgniteException(e);
}
finally {
if (log.isInfoEnabled()) {
log.info("Verify snapshot partitions procedure has been finished " +
"[snpName=" + snpName + ", consId=" + consId + ']');
}
}
}

/** {@inheritDoc} */
Expand Down

0 comments on commit 0903a62

Please sign in to comment.