gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-15 10:40:41 -07:00
Code Issues Packages Projects Releases Wiki Activity

Log error on write errors

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-09-19 12:14:31 -07:00
parent d79a00499d
commit 08b498fbda
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
server/raft.go
View File

@@ -2978,7 +2978,7 @@ func (n *raft) setWriteErrLocked(err error) {
// For now since this can be happening all under the covers, we will call up and disable JetStream.
n.Unlock()
n.s.handleOutOfSpace("")
n.s.handleOutOfSpace(_EMPTY_)
n.Lock()
}
@@ -3009,6 +3009,7 @@ func (n *raft) fileWriter() {
n.RUnlock()
if err := ioutil.WriteFile(tvf, buf[:], 0640); err != nil {
n.setWriteErr(err)
n.error("Error writing term and vote file for %q: %v", n.group, err)
}
case <-n.wpsch:
n.RLock()
@@ -3016,6 +3017,7 @@ func (n *raft) fileWriter() {
n.RUnlock()
if err := ioutil.WriteFile(psf, buf, 0640); err != nil {
n.setWriteErr(err)
n.error("Error writing peer state file for %q: %v", n.group, err)
}
}
}