Ything-RepoMirrors/rqlite
1
0
Fork 0
mirror of https://github.com/rqlite/rqlite.git synced 2026-01-25 04:16:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add missing defers

Browse Source
This commit is contained in:
Philip O'Toole
2026-01-19 18:29:00 -05:00
parent 29836c05af
commit 0e31e13713
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
snapshot2/store.go
View File

@@ -217,6 +217,7 @@ func (s *Store) Create(version raft.SnapshotVersion, index, term uint64, configu
if err := s.mrsw.BeginRead(); err != nil {
return nil, err
}
defer s.mrsw.EndRead()
sink := NewSink(s.dir, &raft.SnapshotMeta{
Version: version,
@@ -278,6 +279,7 @@ func (s *Store) Open(id string) (*raft.SnapshotMeta, io.ReadCloser, error) {
if err := s.mrsw.BeginRead(); err != nil {
return nil, nil, err
}
defer s.mrsw.EndRead()
dbfile, walFiles, err := ResolveSnapshots(s.dir, id)
if err != nil {
@@ -320,7 +322,9 @@ func (s *Store) Reap() (reapedN, chkN int, retErr error) {
}
}()
s.mrsw.BeginWrite("snapshot-reap")
if err := s.mrsw.BeginWrite("snapshot-reap"); err != nil {
return reapedN, chkN, err
}
defer s.mrsw.EndWrite()
if s.reapDisabled {