Release 1.4

Author: hhblaze

Deployment/!!!Raft.nuspec

@@ -2,24 +2,25 @@
 <package xmlns="http://schemas.microsoft.com/packaging/2011/08/nuspec.xsd">
     <metadata>
         <id>Raft</id>
-        <version>1.3.0</version>
+        <version>1.4.0</version>
         <title>Raft.NET dotnet consensus algorithm implementation</title>
         <authors>Alex Solovyov</authors>
         <owners>tiesky.com / Alex Solovyov</owners>
-        <licenseUrl>https://github.com/hhblaze/Raft.Net/blob/master/LICENSE</licenseUrl>
+        <license type="file">LICENSE.txt</license>
         <projectUrl>https://github.com/hhblaze/Raft.Net</projectUrl>
         <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>updated DBreeze, faster Biser.NET decoding</releaseNotes>
+        <releaseNotes>fixed and optimized In-Memory implementation, added async implementation AddLogEntryAsync</releaseNotes>
         <copyright>Copyright © 2018 tiesky.com / Alex Solovyov</copyright>
         <language>es-US</language>
         <tags>RAFT Raft.NET dotnet dbreeze netcore netstandard net framework</tags>
         <dependencies>
-            <dependency id="DBreeze" version="1.91.4" />
+            <dependency id="DBreeze" version="1.95.0" />
         </dependencies>
     </metadata>
     <files>
+		<file src="Raft\LICENSE.txt" target="LICENSE.txt" />
         <file src="Raft\bin\Release\Raft.dll" target="lib\net45\Raft.dll" />
         <file src="Raft\bin\Release\Raft.xml" target="lib\net45\Raft.xml" />
         <file src="Raft\bin\Release-NET47\Raft.dll" target="lib\net47\Raft.dll" />

Deployment/Raft.1.4.0.nupkg

@@ -27,5 +27,24 @@ public static byte[] GetMessageId()
                 return DateTime.UtcNow.To_8_bytes_array().Concat(MessageIdCnt.To_8_bytes_array_BigEndian());
             }
         }
+
+        public static void ResponseCrateCleanUp(object userToken)
+        {
+            try
+            {
+                DateTime now = DateTime.UtcNow;
+
+                foreach (var el in df.Where(r => now.Subtract(r.Value.created).TotalMilliseconds >= r.Value.TimeoutsMs).ToList())
+                {
+                    el.Value.IsRespOk = false;                   
+                    el.Value.Set_MRE();
+                }
+
+            }
+            catch (Exception ex) 
+            {
+
+            }
+        }
     }
 }

Raft/Async/AsyncResponseHandler.cs

@@ -0,0 +1,25 @@
+BSD 2-Clause License
+
+Copyright (c) 2018, Alexey Solovyov / tiesky.com
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+  list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+  this list of conditions and the following disclaimer in the documentation
+  and/or other materials provided with the distribution.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

Raft/LICENSE.txt

@@ -145,7 +145,10 @@ public RaftNode(RaftEntitySettings settings, DBreezeEngine dbEngine, IRaftComSen
             //Starting time master
             this.TM = new TimeMaster(log);
             //Starting state logger
-            NodeStateLog = new StateLog(this);            
+            NodeStateLog = new StateLog(this);
+
+            //Adding AddLogEntryAsync cleanup
+            this.TM.FireEventEach(10000, AsyncResponseHandler.ResponseCrateCleanUp, null, false);
         }
 
         int disposed = 0;
@@ -172,7 +175,9 @@ public void Dispose()
             //    db = null;
             //}
         }
-                
+
+       
+
 
         /// <summary>
         /// We need this value to calculate majority while leader election

Raft/RaftNode.cs

@@ -1001,7 +1001,8 @@ public void AddToLogFollower(StateLogEntrySuggestion suggestion)
 
             }
 
-            if (this.LastCommittedIndex < rn.LeaderHeartbeat.LastStateLogCommittedIndex)
+            //if (this.LastCommittedIndex < rn.LeaderHeartbeat.LastStateLogCommittedIndex)
+            if (rn.LeaderHeartbeat != null && this.LastCommittedIndex < rn.LeaderHeartbeat.LastStateLogCommittedIndex)
             {
                 rn.SyncronizeWithLeader(true);
             }

Raft/StateMachine/StateLog.cs

@@ -362,13 +362,7 @@ public async Task<bool> AddLogEntryAsync(byte[] data, string entityName = "defau
 
                 switch(aler.AddResult)
                 {
-                    case AddLogEntryResult.eAddLogEntryResult.ERROR_OCCURED:
-                    case AddLogEntryResult.eAddLogEntryResult.NO_LEADER_YET:
-
-                        resp.Dispose_MRE();
-                        AsyncResponseHandler.df.TryRemove(msgIdStr, out resp);
-
-                        return false;
+                 
                     case AddLogEntryResult.eAddLogEntryResult.LOG_ENTRY_IS_CACHED:
                     case AddLogEntryResult.eAddLogEntryResult.NODE_NOT_A_LEADER:
 
@@ -381,18 +375,23 @@ public async Task<bool> AddLogEntryAsync(byte[] data, string entityName = "defau
                         {
                             if (resp.IsRespOk)
                                 return true;
-
-                            //return new Tuple<bool, byte[]>(true, resp.res); //???? returning externalId or even nothing
                         }
 
                         break;
-                    
+                    default:
+                    //case AddLogEntryResult.eAddLogEntryResult.ERROR_OCCURED:
+                    //case AddLogEntryResult.eAddLogEntryResult.NO_LEADER_YET:
+
+                        resp.Dispose_MRE();
+                        AsyncResponseHandler.df.TryRemove(msgIdStr, out resp);
+
+                        return false;
                 }
             }
 
             //return new AddLogEntryResult { AddResult = AddLogEntryResult.eAddLogEntryResult.NODE_NOT_FOUND_BY_NAME };
             //return new Tuple<bool, byte[]>(false, null);
-            return true;
+            return false;
         }