Skip to content

Commit ed98cff

Browse files
committed
Fixed default replication lag
1 parent a37db51 commit ed98cff

3 files changed

Lines changed: 5 additions & 1 deletion

File tree

src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/LeaderState.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@ internal sealed partial class LeaderState<TMember> : ConsensusState<TMember>
2525
internal LeaderState(IRaftStateMachine<TMember> stateMachine, int replicationLag)
2626
: base(stateMachine)
2727
{
28+
Debug.Assert(replicationLag > 0);
29+
2830
timerCancellation = new();
2931
Token = timerCancellation.Token;
3032
runningReplications = new(9, ReferenceEqualityComparer.Instance);

src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/RaftCluster.Configuration.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ public int MaxReplicationLag
164164
{
165165
get;
166166
init => field = value > 0 ? value : throw new ArgumentOutOfRangeException(nameof(value));
167-
}
167+
} = 16;
168168

169169
/// <inheritdoc cref="IClusterMemberConfiguration.IsLeaderLeaseEnabled"/>
170170
public bool IsLeaderLeaseEnabled { get; init; }

src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/ReplicationUtils/ReplicationProcess.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,8 @@ internal sealed class ReplicationProcess<TMember> : ReplicationProcess, ILogEntr
3838

3939
public ReplicationProcess(TMember member, int queueSize)
4040
{
41+
Debug.Assert(queueSize > 0);
42+
4143
this.member = member;
4244

4345
var channel = Channel.CreateBounded<ReplicationBarrier>(new BoundedChannelOptions(queueSize)

0 commit comments

Comments
 (0)