From 3ac6052b329f26a80ed9c7ca0cbba4489877821b Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Fri, 11 Nov 2022 16:08:58 -0800 Subject: [PATCH] Updated pae threshold and reporting modulo to not spam logs as much. Signed-off-by: Derek Collison --- server/raft.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/server/raft.go b/server/raft.go index 1275818e..f7142f7c 100644 --- a/server/raft.go +++ b/server/raft.go @@ -2940,7 +2940,7 @@ func (n *raft) processAppendEntry(ae *appendEntry, sub *subscription) { } // Save in memory for faster processing during applyCommit. n.pae[n.pindex] = ae - if l := len(n.pae); l > paeWarnThreshold && l%1000 == 0 { + if l := len(n.pae); l > paeWarnThreshold && l%paeWarnModulo == 0 { n.warn("%d append entries pending", len(n.pae)) } @@ -3092,7 +3092,8 @@ func (n *raft) storeToWAL(ae *appendEntry) error { return nil } -const paeWarnThreshold = 32 * 1024 +const paeWarnThreshold = 20_000 +const paeWarnModulo = 5_000 func (n *raft) sendAppendEntry(entries []*Entry) { n.Lock() @@ -3117,7 +3118,7 @@ func (n *raft) sendAppendEntry(entries []*Entry) { // Save in memory for faster processing during applyCommit. n.pae[n.pindex] = ae - if l := len(n.pae); l > paeWarnThreshold && l%1000 == 0 { + if l := len(n.pae); l > paeWarnThreshold && l%paeWarnModulo == 0 { n.warn("%d append entries pending", len(n.pae)) } }