Merge pull request #4 from yznima/pr-race-appian

Raft HTTP: fix pause/resume race condition
appian · Jun 17, 2019 · c3c13d6 · c3c13d6
2 parents 6c369d1 + 9ce26f4
commit c3c13d6
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/rafthttp/transport.go b/rafthttp/transport.go
@@ -372,12 +372,16 @@ type Pausable interface {
 }
 
 func (t *Transport) Pause() {
+	t.mu.RLock()
+	defer t.mu.RUnlock()
 	for _, p := range t.peers {
 		p.(Pausable).Pause()
 	}
 }
 
 func (t *Transport) Resume() {
+	t.mu.RLock()
+	defer t.mu.RUnlock()
 	for _, p := range t.peers {
 		p.(Pausable).Resume()
 	}