From: Robert Varga <robert.varga@pantheon.tech>
Date: Thu, 22 Oct 2020 18:10:01 +0000 (+0200)
Subject: Log replicated log dataSize changes
X-Git-Tag: v2.0.6~7
X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=commitdiff_plain;h=5edcce54833474135be4a451468fce92e2fb0be1

Log replicated log dataSize changes

This is a bit of critical state, make sure we recalculate it atomically
and log its changes.

JIRA: CONTROLLER-1957
Change-Id: I09532384ce5bbaf7218c0ffdb64799541037fafc
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
(cherry picked from commit e96021b2e492bbaf7efe0804628bfe055b9733f7)
---

diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/AbstractReplicatedLogImpl.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/AbstractReplicatedLogImpl.java
index 2662d7151c..42af1502ee 100644
--- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/AbstractReplicatedLogImpl.java
+++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/AbstractReplicatedLogImpl.java
@@ -260,12 +260,14 @@ public abstract class AbstractReplicatedLogImpl implements ReplicatedLog {
         snapshottedJournal = null;
         previousSnapshotIndex = -1;
         previousSnapshotTerm = -1;
-        dataSize = 0;
+
         // need to recalc the datasize based on the entries left after precommit.
+        int newDataSize = 0;
         for (ReplicatedLogEntry logEntry : journal) {
-            dataSize += logEntry.size();
+            newDataSize += logEntry.size();
         }
-
+        LOG.trace("{}: Updated dataSize from {} to {}", logContext, dataSize, newDataSize);
+        dataSize = newDataSize;
     }
 
     @Override