|
@@ -260,7 +260,11 @@ func (r *raftNode) start(rh *raftReadyHandler) {
|
|
|
// blocks until 'applyAll' calls 'applyWait.Trigger'
|
|
// blocks until 'applyAll' calls 'applyWait.Trigger'
|
|
|
// to be in sync with scheduled config-change job
|
|
// to be in sync with scheduled config-change job
|
|
|
// (assume raftDone has cap of 1)
|
|
// (assume raftDone has cap of 1)
|
|
|
- raftDone <- struct{}{}
|
|
|
|
|
|
|
+ select {
|
|
|
|
|
+ case raftDone <- struct{}{}:
|
|
|
|
|
+ case <-r.stopped:
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// gofail: var raftBeforeFollowerSend struct{}
|
|
// gofail: var raftBeforeFollowerSend struct{}
|