diff --git a/rafthttp/transport.go b/rafthttp/transport.go index 289e5ba93..cb5795803 100644 --- a/rafthttp/transport.go +++ b/rafthttp/transport.go @@ -187,6 +187,8 @@ func (t *Transport) Send(msgs []raftpb.Message) { } func (t *Transport) Stop() { + t.mu.Lock() + defer t.mu.Unlock() for _, r := range t.remotes { r.stop() }