diff --git a/rafthttp/transport.go b/rafthttp/transport.go index 16e854c8a..9ec765086 100644 --- 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() }