gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3619 from nats-io/pae-thresh

Browse Source 
Updated pae threshold and reporting modulo to not spam logs as much.
This commit is contained in:
Derek Collison
2022-11-11 17:07:59 -08:00
committed by GitHub
parent 38dffbbe2a 3ac6052b32
commit a64c41a7fa
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
server/raft.go
View File

@@ -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))
}
}