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

Write snapshots without lock held

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-03-01 04:42:11 -08:00
parent 0dcdb9fb1c
commit a8db1d7322
1 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
server/raft.go
View File

@@ -775,19 +775,16 @@ func (n *raft) InstallSnapshot(data []byte) error {
snapDir := path.Join(n.sd, snapshotsDir)
sn := fmt.Sprintf(snapFileT, snap.lastTerm, snap.lastIndex)
sfile := path.Join(snapDir, sn)
if err := ioutil.WriteFile(sfile, n.encodeSnapshot(snap), 0640); err != nil {
n.setWriteErrLocked(err)
n.Unlock()
return err
}
// Remember our latest snapshot file.
n.snapfile = sfile
n.Unlock()
_, err := n.wal.Compact(snap.lastIndex)
if err != nil {
if err := ioutil.WriteFile(sfile, n.encodeSnapshot(snap), 0640); err != nil {
n.setWriteErr(err)
return err
}
if _, err := n.wal.Compact(snap.lastIndex); err != nil {
n.setWriteErr(err)
return err
}
@@ -801,7 +798,7 @@ func (n *raft) InstallSnapshot(data []byte) error {
}
}
return err
return nil
}
const (