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 #3893 from nats-io/raft-fixes

Browse Source 
[FIXED] Spurious "Error storing entry to WAL" log messages
This commit is contained in:
Derek Collison
2023-02-20 18:23:40 -07:00
committed by GitHub
parent 7e67ec5b1f 2a9f085d55
commit 53cf6635e2
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/raft.go
View File

@@ -1,4 +1,4 @@
// Copyright 2020-2022 The NATS Authors
// Copyright 2020-2023 The NATS Authors
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
@@ -2872,7 +2872,7 @@ func (n *raft) processAppendEntry(ae *appendEntry, sub *subscription) {
}
if ae.pterm != n.pterm || ae.pindex != n.pindex {
// Check if this is a lower index than what we were expecting.
// Check if this is a lower or equal index than what we were expecting.
if ae.pindex <= n.pindex {
n.debug("AppendEntry detected pindex less than ours: %d:%d vs %d:%d", ae.pterm, ae.pindex, n.pterm, n.pindex)
var ar *appendEntryResponse
@@ -2938,7 +2938,7 @@ func (n *raft) processAppendEntry(ae *appendEntry, sub *subscription) {
n.pterm = ae.pterm
n.commit = ae.pindex
if _, err := n.wal.Compact(n.pindex); err != nil {
if _, err := n.wal.Compact(n.pindex + 1); err != nil {
n.setWriteErrLocked(err)
n.Unlock()
return