Code cleanup

dotnet · Jul 26, 2023 · 024a7e9 · 024a7e9
1 parent 852bf04
commit 024a7e9
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/RaftCluster.cs b/src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/RaftCluster.cs
@@ -622,15 +622,15 @@ private async ValueTask StepDown()
                 if (await auditTrail.ContainsAsync(prevLogIndex, prevLogTerm, token).ConfigureAwait(false))
                 {
                     bool emptySet;
-                    ReplicationWithSenderTermDetector<TEntry>? proxy;
 
-                    if (emptySet = entries.RemainingCount is 0L)
+                    if (entries.RemainingCount is 0L)
                     {
-                        proxy = null;
+                        emptySet = true;
                     }
                     else
                     {
-                        entries = proxy = new(entries, senderTerm);
+                        entries = new ReplicationWithSenderTermDetector<TEntry>(entries, senderTerm);
+                        emptySet = false;
                     }
 
                     // prevent Follower state transition during processing of received log entries
@@ -644,7 +644,7 @@ private async ValueTask StepDown()
                         * If it is 'false' then the method will throw the exception and the node becomes unavailable in each replication cycle.
                         */
                         await auditTrail.AppendAndCommitAsync(entries, prevLogIndex + 1L, true, commitIndex, token).ConfigureAwait(false);
-                        result = result with { Value = proxy is { IsReplicatedWithExpectedTerm: true } };
+                        result = result with { Value = entries is ReplicationWithSenderTermDetector<TEntry> { IsReplicatedWithExpectedTerm: true } };
 
                         // process configuration
                         var fingerprint = (ConfigurationStorage.ProposedConfiguration ?? ConfigurationStorage.ActiveConfiguration).Fingerprint;