Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #16460 from geetasg/pr10

Browse Source 
Preserve the order of steps done for snapshot
This commit is contained in:
Benjamin Wang 2023-08-23 16:01:31 +08:00 committed by GitHub
commit e44afcfadd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/etcdserver/server.go
View File

@ -2064,6 +2064,7 @@ func (s *EtcdServer) applyConfChange(cc raftpb.ConfChange, confState *raftpb.Con
// TODO: non-blocking snapshot // TODO: non-blocking snapshot
func (s *EtcdServer) snapshot(snapi uint64, confState raftpb.ConfState) { func (s *EtcdServer) snapshot(snapi uint64, confState raftpb.ConfState) {
d := GetMembershipInfoInV2Format(s.Logger(), s.cluster)
// commit kv to write metadata (for example: consistent index) to disk. // commit kv to write metadata (for example: consistent index) to disk.
// //
// This guarantees that Backend's consistent_index is >= index of last snapshot. // This guarantees that Backend's consistent_index is >= index of last snapshot.
@ -2074,7 +2075,6 @@ func (s *EtcdServer) snapshot(snapi uint64, confState raftpb.ConfState) {
// So KV().Commit() cannot run in parallel with toApply. It has to be called outside // So KV().Commit() cannot run in parallel with toApply. It has to be called outside
// the go routine created below. // the go routine created below.
s.KV().Commit() s.KV().Commit()
d := GetMembershipInfoInV2Format(s.Logger(), s.cluster)
s.GoAttach(func() { s.GoAttach(func() {
lg := s.Logger() lg := s.Logger()