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

Wait until all committed entries are applied

Browse Source 
To take a snapshot
This commit is contained in:
Shintaro Murakami 2021-02-05 09:33:53 +09:00
parent cb14cdd774
commit be2167ebab
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
contrib/raftexample/raft.go
View File

@ -340,6 +340,15 @@ func (rc *raftNode) maybeTriggerSnapshot() {
return
}
// wait until all committed entries are applied
// commitC is synchronous channel, so consumption of the message signals
// full application of previous messages
select {
case rc.commitC <- nil:
case <-rc.stopc:
return
}
log.Printf("start snapshot [applied index: %d | last snapshot index: %d]", rc.appliedIndex, rc.snapshotIndex)
data, err := rc.getSnapshot()
if err != nil {