Release 1.5

Author: hhblaze

Deployment/!!!Raft.nuspec

@@ -2,7 +2,7 @@
 <package xmlns="http://schemas.microsoft.com/packaging/2011/08/nuspec.xsd">
     <metadata>
         <id>Raft</id>
-        <version>1.4.0</version>
+        <version>1.5.0</version>
         <title>Raft.NET dotnet consensus algorithm implementation</title>
         <authors>Alex Solovyov</authors>
         <owners>tiesky.com / Alex Solovyov</owners>
@@ -11,7 +11,7 @@
         <requireLicenseAcceptance>false</requireLicenseAcceptance>
         <description>Implementation of the RAFT consensus algorithm among TCP peers with disk or memory persistence</description>
         <summary>Raft.NET dotnet consensus algorithm implementation</summary>
-        <releaseNotes>fixed and optimized In-Memory implementation, added async implementation AddLogEntryAsync</releaseNotes>
+        <releaseNotes>raftNodeInstance.NodeIsInLatestState can help to understand if started node is in the latest update state</releaseNotes>
         <copyright>Copyright © 2018 tiesky.com / Alex Solovyov</copyright>
         <language>es-US</language>
         <tags>RAFT Raft.NET dotnet dbreeze netcore netstandard net framework</tags>

Deployment/Raft.1.5.0.nupkg

@@ -1220,6 +1220,29 @@ public AddLogEntryResult AddLogEntry(byte[] iData, byte[] externalId = null)
             return res;
         }
 
+        /// <summary>
+        /// NodeIsInLatestState
+        /// </summary>
+        public bool NodeIsInLatestState
+        {
+            get
+            {
+                lock (lock_Operations)
+                {
+                    if (this.NodeState == eNodeState.Leader)
+                        return true;
+                    else
+                    {
+                        if (this.LeaderHeartbeat == null)
+                            return false;
+
+                        return this.NodeStateLog.LastCommittedIndex == this.LeaderHeartbeat.LastStateLogCommittedIndex;
+                    }
+                }
+                    
+            }
+        }
+
 
         int inCommit = 0;
 
@@ -1253,7 +1276,9 @@ internal void Commited()
 
                     try
                     {
-                        
+                        ////if (this.LeaderHeartbeat != null)
+                        ////    Console.WriteLine($"LCIT={this.NodeStateLog.LastCommittedIndex}/{this.NodeStateLog.LastBusinessLogicCommittedIndex}/---{this.LeaderHeartbeat.LastStateLogCommittedIndex} ");
+
 
                         if (this.OnCommit(entitySettings.EntityName, sle.Index, sle.Data))
                         {
@@ -1263,6 +1288,7 @@ internal void Commited()
                                 this.NodeStateLog.BusinessLogicIsApplied(sle.Index);
                             }
 
+
                             //Notifying Async AddLog
                             if (sle.ExternalID != null && AsyncResponseHandler.df.TryGetValue(sle.ExternalID.ToBytesString(), out var responseCrate))
                             {

Raft/RaftNode.cs

@@ -160,7 +160,7 @@ static void Scenario1(string[] args)
 
             rn = TcpRaftNode.GetFromConfig(System.IO.File.ReadAllText(args[2]),
                dbreezePath, Convert.ToInt32(args[1]), log,
-               (entName, index, data) => { Console.WriteLine($"wow committed {entName}/{index}; DataLen: {(data == null ? -1 : data.Length)}"); return true; });
+               (entName, index, data) => { Console.WriteLine($"wow committed {entName}/{index}; DataLen: {(data == null ? -1 : data.Length)};"); return true; });