Raft HTTP: fix pause/resume race condition
parent
2c5162af5c
commit
b1812a410f
|
@ -437,12 +437,16 @@ type Pausable interface {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *Transport) Pause() {
|
func (t *Transport) Pause() {
|
||||||
|
t.mu.RLock()
|
||||||
|
defer t.mu.RUnlock()
|
||||||
for _, p := range t.peers {
|
for _, p := range t.peers {
|
||||||
p.(Pausable).Pause()
|
p.(Pausable).Pause()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *Transport) Resume() {
|
func (t *Transport) Resume() {
|
||||||
|
t.mu.RLock()
|
||||||
|
defer t.mu.RUnlock()
|
||||||
for _, p := range t.peers {
|
for _, p := range t.peers {
|
||||||
p.(Pausable).Resume()
|
p.(Pausable).Resume()
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue