This is an automated email from the ASF dual-hosted git repository.

namelchev pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new ff847ec15a3 IGNITE-19163 Added logging of snapshot check procedure 
(#10825)
ff847ec15a3 is described below

commit ff847ec15a3fc1a52c76608dec5d15e6c23618d3
Author: Julia Bakulina <[email protected]>
AuthorDate: Fri Aug 4 11:01:02 2023 +0300

    IGNITE-19163 Added logging of snapshot check procedure (#10825)
---
 .../cache/persistence/snapshot/IgniteSnapshotManager.java      | 10 ++++++++++
 .../persistence/snapshot/SnapshotPartitionsVerifyTask.java     |  6 ++++++
 2 files changed, 16 insertions(+)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotManager.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotManager.java
index 780470bf2e2..58efd68bff2 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotManager.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotManager.java
@@ -1834,6 +1834,11 @@ public class IgniteSnapshotManager extends 
GridCacheSharedManagerAdapter
 
         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),
@@ -1952,6 +1957,11 @@ public class IgniteSnapshotManager extends 
GridCacheSharedManagerAdapter
             }
         });
 
+        if (log.isInfoEnabled()) {
+            res.listen(f -> log.info("The check snapshot procedure finished 
[snpName=" + name +
+                ", snpPath=" + snpPath + ", incIdx=" + incIdx + ", grps=" + 
grps + ']'));
+        }
+
         return res;
     }
 
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyTask.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyTask.java
index 2fc31021490..40fa00fcedf 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyTask.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyTask.java
@@ -136,6 +136,12 @@ public class SnapshotPartitionsVerifyTask extends 
AbstractSnapshotVerificationTa
             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} */

Reply via email to